.

go/neo/client.go

@@ -221,6 +221,7 @@ func (c *Client) talkMaster(ctx context.Context) (err error) {
 	for {
 		err := c.talkMaster1(ctx)
 		log.Warning(ctx, err)	// XXX Warning ok? -> Error?
+		// XXX if err == "reject identification / protocol error" -> shutdown client
 
 		// TODO if err = shutdown -> return
 

go/neo/client_test.go

@@ -227,6 +227,8 @@ func withNEO(t *testing.T, f func(t *testing.T, nsrv NEOSrv, ndrv *Client), optv
 	}, optv...)
 }
 
+// XXX connect with wrong clusterName -> rejected
+
 func TestEmptyDB(t *testing.T) {
 	withNEO(t, func(t *testing.T, nsrv NEOSrv, n *Client) {
 		xtesting.DrvTestEmptyDB(t, n)