Commit e7625f45 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 0e00297d
...@@ -41,8 +41,6 @@ import ( ...@@ -41,8 +41,6 @@ import (
"lab.nexedi.com/kirr/go123/xnet" "lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/go123/xnet/pipenet" "lab.nexedi.com/kirr/go123/xnet/pipenet"
"lab.nexedi.com/kirr/go123/xsync" "lab.nexedi.com/kirr/go123/xsync"
"time"
) )
...@@ -64,22 +62,6 @@ func tracetestMasterStorage(t0 *tracetest.T) { ...@@ -64,22 +62,6 @@ func tracetestMasterStorage(t0 *tracetest.T) {
lastTid, err := zstor.Sync(bg); X(err) lastTid, err := zstor.Sync(bg); X(err)
/*
// start nodes XXX move starting to TestCluster?
gwg := xsync.NewWorkGroup(bg)
defer xwait(gwg) // FIXME not yet correctly stopped on context cancel
gwg.Go(func(ctx context.Context) error {
return M.Run(ctx)
})
gwg.Go(func(ctx context.Context) error {
return S.Run(ctx)
})
gwg.Go(func(ctx context.Context) error {
return C.Run(ctx)
})
*/
tM := t.Checker("m") tM := t.Checker("m")
tS := t.Checker("s") tS := t.Checker("s")
tC := t.Checker("c") tC := t.Checker("c")
...@@ -423,8 +405,6 @@ func tracetestMasterStorage(t0 *tracetest.T) { ...@@ -423,8 +405,6 @@ func tracetestMasterStorage(t0 *tracetest.T) {
// TODO test M.recovery starting back from verification/service // TODO test M.recovery starting back from verification/service
// (M needs to resend to all storages recovery messages just from start) // (M needs to resend to all storages recovery messages just from start)
time.Sleep(100*time.Millisecond) // XXX temp so net tx'ers could actually tx
} }
......
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