Commit a726770c authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 31f4e061
......@@ -663,13 +663,15 @@ func (m *Master) verify(ctx context.Context) (err error) {
stor.wg.Go(func(peerCtx context.Context) error {
defer wg.Done()
var ...
var lastOid zodb.Oid
var lastTid zodb.Tid
err := stor.run(ctx, func() error {
... = storCtlVerify(ctx, stor, m.node.State.PartTab)
var err error
lastOid, lastTid, err = storCtlVerify(ctx, stor, m.node.State.PartTab)
})
ack := make(chan struct{})
verifyq <- storVerify{stor: stor, ...}
verifyq <- storVerify{stor: stor, lastOid: lastOid, lastTid: lastTid, err: err}
<-ack
// canceled verify does not mean we should down the storage node
......@@ -677,7 +679,7 @@ func (m *Master) verify(ctx context.Context) (err error) {
err = nil
}
return err
}()
})
}
// start verification on all storages we are currently in touch with
......
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