.

go/neo/client/client.go

@@ -285,7 +285,8 @@ func (c *Client) recvMaster(ctx context.Context, mlink *neo.NodeLink) error {
 		}
 
 		// update .operational + notify those who was waiting for it
-		operational := c.node.ClusterState == neo.ClusterRunning &&
+		// XXX py client does not wait for cluster state = running
+		operational := // c.node.ClusterState == neo.ClusterRunning &&
 			c.node.PartTab.OperationalWith(c.node.NodeTab)
 
 		var opready chan struct{}
@@ -398,8 +399,7 @@ func (c *Client) Load(ctx context.Context, xid zodb.Xid) (data []byte, serial zo
 	// retry from the beginning if all are found to fail?
 	stor := storv[rand.Intn(len(storv))]
 
-	slink := stor.Link // XXX temp stub
-	//slink, err := stor.Link()
+	slink, err := stor.Link()
 	if err != nil {
 		return nil, 0, err	// XXX err ctx
 	}

go/neo/server/cluster_test.go

@@ -416,7 +416,10 @@ func TestMasterStorage(t *testing.T) {
 		Tid: lastTid,
 	}))
 
-	// C starts loading first object
+	xwait(wg)
+
+	println("000")
+	// C starts loading first object -> connects to S
 	data, serial, err := C.Load(bg, zodb.Xid{Oid: 1, XTid: zodb.XTid{Tid: zodb.TidMax, TidBefore: true}})
 	_, _, _ = data, serial, err