.

go/neo/neo_test.go

@@ -107,14 +107,14 @@ func _TestMasterStorage(t0 *tEnv) {
 		},
 	}))
 
-	tMS.Expect(conntx("m:2", "s:2", 6, &proto.LockedTransactions{}))
-	tMS.Expect(conntx("s:2", "m:2", 6, &proto.AnswerLockedTransactions{
+	tMS.Expect(conntx("m:2", "s:2", 10, &proto.LockedTransactions{}))
+	tMS.Expect(conntx("s:2", "m:2", 10, &proto.AnswerLockedTransactions{
 		TidDict: nil,	// map[zodb.Tid]zodb.Tid{},
 	}))
 
 	lastOid, err := zstor.LastOid(bg);  X(err)
-	tMS.Expect(conntx("m:2", "s:2", 8, &proto.LastIDs{}))
-	tMS.Expect(conntx("s:2", "m:2", 8, &proto.AnswerLastIDs{
+	tMS.Expect(conntx("m:2", "s:2", 12, &proto.LastIDs{}))
+	tMS.Expect(conntx("s:2", "m:2", 12, &proto.AnswerLastIDs{
 		LastOid: lastOid,
 		LastTid: lastTid,
 	}))
@@ -130,8 +130,8 @@ func _TestMasterStorage(t0 *tEnv) {
 	tM.Expect(clusterState("m", proto.ClusterRunning))
 	// TODO ^^^ should be sent to S
 
-	tMS.Expect(conntx("m:2", "s:2", 10, &proto.StartOperation{Backup: false}))
-	tMS.Expect(conntx("s:2", "m:2", 10, &proto.NotifyReady{}))
+	tMS.Expect(conntx("m:2", "s:2", 14, &proto.StartOperation{Backup: false}))
+	tMS.Expect(conntx("s:2", "m:2", 14, &proto.NotifyReady{}))
 
 	// TODO S leave while service
 	// TODO S join while service