.

go/neo/client.go

@@ -31,7 +31,6 @@ import (
 //	"time"
 
 	"github.com/pkg/errors"
-//	"golang.org/x/sync/errgroup"
 	"lab.nexedi.com/kirr/go123/mem"
 	"lab.nexedi.com/kirr/go123/xerr"
 	"lab.nexedi.com/kirr/go123/xnet"
@@ -308,26 +307,6 @@ func (c *Client) Load(ctx context.Context, xid zodb.Xid) (buf *mem.Buf, serial z
 		return nil, 0, err
 	}
 
-/*
-	err = c.withOperational(ctx)
-	if err != nil {
-		return nil, 0, err
-	}
-
-	// here we have cluster state operational and rlocked. Retrieve
-	// storages we might need to access and release the lock.
-	storv := make([]*xneo.Node, 0, 1)
-	for _, cell := range c.node.PartTab.Get(xid.Oid) {
-		if cell.Readable() {
-			stor := c.node.NodeTab.Get(cell.NID)
-			// this storage might not yet come up
-			if stor != nil && stor.State == proto.RUNNING {
-				storv = append(storv, stor)
-			}
-		}
-	}
-	c.node.StateMu.RUnlock()
-*/
 
 	if len(storv) == 0 {
 		// XXX recheck it adds traceback to log -> XXX it does not -> add our Bugf which always forces +v on such error print

go/neo/mastered.go

@@ -231,6 +231,8 @@ func (node *_MasteredNode) talkMaster1(ctx, ctxPreTalkM context.Context, f func(
 				// keep mlink=nil on shutdown so that
 				// .operational does not change to y.
 				node.mlink = mlink
+
+				// XXX also set node.state.NodeTab[Mnid].link = mlink ?
 			}
 		})
 		if err != nil {