.

go/neo/client/client.go

@@ -271,7 +271,7 @@ func (c *Client) recvMaster(ctx context.Context, mlink *neo.NodeLink) error {
 		case *neo.NotifyNodeInformation:
 			// XXX msg.IdTimestamp ?
 			for _, nodeInfo := range msg.NodeList {
-				log.Infof(ctx, "rx peer update: %v", nodeInfo)
+				log.Infof(ctx, "rx node update: %v", nodeInfo)
 				c.node.NodeTab.Update(nodeInfo, /*XXX conn should not be here*/nil)
 			}
 
@@ -279,6 +279,8 @@ func (c *Client) recvMaster(ctx context.Context, mlink *neo.NodeLink) error {
 			log.Infof(ctx, "full nodetab:\n%s", c.node.NodeTab)
 
 		case *neo.NotifyClusterState:
+			// XXX loging under lock
+			log.Infof(ctx, "rx state update: %v", msg.State)
 			c.node.ClusterState.Set(msg.State)
 		}
 

go/neo/server/cluster_test.go

@@ -384,6 +384,7 @@ func TestMasterStorage(t *testing.T) {
 	}))
 
 	// C <- M NotifyNodeInformation C1,M1,S1
+	// FIXME this might come in parallel with ^^^ "C asks M about PT"
 	tc.Expect(conntx("m:3", "c:1", 0, &neo.NotifyNodeInformation{
 		IdTimestamp:	0,	// XXX ?
 		NodeList:	[]neo.NodeInfo{