Commit 424be070 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 55791aaf
......@@ -668,7 +668,7 @@ func (m *Master) verify(ctx context.Context) (err error) {
})
ack := make(chan struct{})
verifyq <- storVerify{stor: stor, lastOid: lastOid, lastTid: lastTid, err: err}
verifyq <- storVerify{stor: stor, lastOid: lastOid, lastTid: lastTid, err: err, ack: ack}
<-ack
// canceled verify does not mean we should down the storage node
......@@ -736,7 +736,7 @@ loop:
//
// FIXME actually implement logic to decide to finish/rollback transactions
case v := <-verifyq:
// XXX ack
close(v.ack) // XXX explain why (see recovery)
inprogress--
if v.err != nil {
......
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