.

go/neo/t_cluster_test.go

@@ -456,16 +456,16 @@ func (t0 *tEnv) NewCluster_MS(name string, Sback storage.Backend) *tCluster {
 	}))
 
 	// M starts recovery on S
-	t.Expect("m-s", conntx("m:2", "s:2", 0, &proto.Recovery{}))
-	t.Expect("m-s", conntx("s:2", "m:2", 0, &proto.AnswerRecovery{
+	t.Expect("m-s", conntx("m:2", "s:2", 2, &proto.Recovery{}))
+	t.Expect("m-s", conntx("s:2", "m:2", 2, &proto.AnswerRecovery{
 		// empty new node
 		PTid:		0,
 		BackupTid:	proto.INVALID_TID,
 		TruncateTid:	proto.INVALID_TID,
 	}))
 
-	t.Expect("m-s", conntx("m:2", "s:2", 2, &proto.AskPartitionTable{}))
-	t.Expect("m-s", conntx("s:2", "m:2", 2, &proto.AnswerPartitionTable{
+	t.Expect("m-s", conntx("m:2", "s:2", 4, &proto.AskPartitionTable{}))
+	t.Expect("m-s", conntx("s:2", "m:2", 4, &proto.AnswerPartitionTable{
 		PTid:		0,
 		NumReplicas:	0,
 		RowList:	[]proto.RowInfo{},