Commit 6639ad9b authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 15f1e05f
...@@ -48,7 +48,7 @@ func TestClusterRecoveryBasic(t *testing.T) { ...@@ -48,7 +48,7 @@ func TestClusterRecoveryBasic(t *testing.T) {
}) })
} }
// M drives cluster with 1 S & C through recovery -> verification -> service -> shutdown // M drives cluster with 1 S & C through recovery -> verification -> service -> shutdown.
func TestMasterStorage(t *testing.T) { func TestMasterStorage(t *testing.T) {
Verify(t, _TestMasterStorage) Verify(t, _TestMasterStorage)
} }
...@@ -196,13 +196,13 @@ func _TestMasterStorage(t0 *tEnv) { ...@@ -196,13 +196,13 @@ func _TestMasterStorage(t0 *tEnv) {
// ---------------------------------------- // ----------------------------------------
// C asks M about last tid XXX better master sends it itself on new client connected // C asks M about last tid
wg = xsync.NewWorkGroup(bg) wg = xsync.NewWorkGroup(bg)
gox(wg, func(ctx context.Context) { gox(wg, func(ctx context.Context) {
cLastTid, err := C.Sync(ctx); X(err) cLastTid, err := C.Sync(ctx); X(err)
if cLastTid != lastTid { if cLastTid != lastTid {
exc.Raisef("C.LastTid -> %v ; want %v", cLastTid, lastTid) exc.Raisef("C.Sync -> %v ; want %v", cLastTid, lastTid)
} }
}) })
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment