Commit 8d420d23 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9bd894f0
...@@ -56,7 +56,7 @@ func tracetestMasterStorage(t0 *tracetest.T) { ...@@ -56,7 +56,7 @@ func tracetestMasterStorage(t0 *tracetest.T) {
// create the cluster // create the cluster
t := tNewCluster_MS(t0, "abc1", zback) t := tNewCluster_MS(t0, "abc1", zback)
defer t.Stop() defer t.Stop()
M := t.Master("m")
C := t.NewClient("c", "m:1") C := t.NewClient("c", "m:1")
tM := t.Checker("m") tM := t.Checker("m")
...@@ -66,13 +66,11 @@ func tracetestMasterStorage(t0 *tracetest.T) { ...@@ -66,13 +66,11 @@ func tracetestMasterStorage(t0 *tracetest.T) {
tMC := t.Checker("m-c") tMC := t.Checker("m-c")
tCS := t.Checker("c-s") tCS := t.Checker("c-s")
// ----------------------------------------
// TODO create C; C tries connect to master - rejected ("not yet operational") // TODO create C; C tries connect to master - rejected ("not yet operational")
// TODO test ID rejects (uuid already registered, ...) // TODO test ID rejects (uuid already registered, ...)
// M <- start cmd // M <- start cmd
M := t.Master("m")
wg := xsync.NewWorkGroup(bg) wg := xsync.NewWorkGroup(bg)
gox(wg, func(ctx context.Context) { gox(wg, func(ctx context.Context) {
err := M.Start(); X(err) err := M.Start(); X(err)
......
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