.

go/neo/master.go

@@ -780,11 +780,11 @@ 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 cancel on ctx
-
 	slink := stor.node.Link()
 	defer task.Runningf(&ctx, "vctl %s", stor.node.NID)(&err)
 
+	// XXX cancel on ctx
+
 	lastOid = zodb.InvalidOid
 	lastTid = zodb.InvalidTid
 

go/neo/mastered.go

@@ -284,7 +284,7 @@ func (node *_MasteredNode) recvδstate(ctx context.Context, msg proto.Msg) (δpt
 
 		case *proto.NotifyClusterState:
 			log.Infof(ctx, "<- state: %s", msg.State)
-			node.State.Code = msg.State
+			node.State.Code.Set(msg.State)
 			traceClusterStateChanged(&node.State.Code)
 		}
 	})

go/neo/xneo/parttab.go

@@ -260,6 +260,7 @@ func (pt *PartitionTable) Dump() []proto.RowInfo { // XXX also include .ptid? ->
 	return rowv
 }
 
+// XXX +nreplica
 func PartTabFromDump(ptid proto.PTid, rowv []proto.RowInfo) *PartitionTable {
 	// reconstruct partition table from response
 	pt := &PartitionTable{}