.

go/neo/master.go

@@ -44,7 +44,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-//	"sync"
 	"time"
 
 	xxcontext "lab.nexedi.com/kirr/go123/xcontext"
@@ -790,8 +789,7 @@ type storVerify struct {
 
 // storCtlVerify drives a storage node during cluster verifying (= starting) state.
 func storCtlVerify(ctx context.Context, stor *_MasteredPeer, pt *xneo.PartitionTable) (lastOid zodb.Oid, lastTid zodb.Tid, err error) {
-	// XXX link.Close on err	-> = xcontext.WithCloseOnErrCancel
-	// XXX cancel on ctx		-> = ^^^
+	// XXX cancel on ctx
 
 	slink := stor.node.Link()
 	defer task.Runningf(&ctx, "%s verify", stor.node.NID)(&err)
@@ -992,7 +990,7 @@ func storCtlServe(ctx context.Context, stor *_MasteredPeer) (err error) {
 
 
 	// now wait in a loop
-	// XXX this should be also controlling transactions
+	// TODO this should be also controlling transactions
 	for {
 		select {
 		// XXX stub
@@ -1011,7 +1009,7 @@ func (m *Master) serveClient(ctx context.Context, cli *_MasteredPeer) (err error
 	defer task.Runningf(&ctx, "%s: serve client", cli.node.NID)(&err)
 	clink := cli.node.Link()
 
-	defer xio.CloseWhenDone(ctx, clink)()	// XXX -> cli.ResetLink?  (better not here)
+	defer xio.CloseWhenDone(ctx, clink)()
 
 	// M <- C requests handler
 	for {