.

wcfs/internal/xbtree/δbtail.go

@@ -531,7 +531,7 @@ func (δTtail *_ΔTtail) rebuild1(atPrev zodb.Tid, δZ zodb.ΔRevEntry, trackNew
 
 
 	// open ZODB connection corresponding to "current" and "prev" states
-	txn, ctx := transaction.New(context.TODO()) // XXX
+	txn, ctx := transaction.New(context.TODO()) // TODO - merge in cancel via ctx arg
 	defer txn.Abort()
 
 	zconnPrev, err := db.Open(ctx, &zodb.ConnOptions{At: atPrev})
@@ -592,7 +592,7 @@ func widenTrackNew(trackNew blib.PPTreeSubSet, δtkeycov *blib.RangedKeySet, roo
 	defer xerr.Contextf(&err, "widenTrackNew tree<%s> @%s +%s", root, at, δtkeycov)
 	debugfΔBtail("\n  widenTrackNew %s @%s +%s", root, at, δtkeycov)
 
-	txn, ctx := transaction.New(context.TODO()) // XXX
+	txn, ctx := transaction.New(context.TODO()) // TODO - merge in cancel via ctx arg
 	defer txn.Abort()
 
 	zhead, err := db.Open(ctx, &zodb.ConnOptions{At: at});  /*X*/ if err != nil { return err }
@@ -726,7 +726,7 @@ func (δBtail *ΔBtail) _Update1(δZ *zodb.EventCommit) (δB1 _ΔBUpdate1, err e
 
 	// open ZODB connections corresponding to "old" and "new" states
 	// TODO caller should provide one of those (probably new) as usually it has it
-	txn, ctx := transaction.New(context.TODO()) // XXX
+	txn, ctx := transaction.New(context.TODO()) // TODO - merge in cancel via ctx arg
 	defer txn.Abort()
 	zconnOld, err := δBtail.db.Open(ctx, &zodb.ConnOptions{At: headOld})
 	if err != nil {