Commit 48f3f0bb authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 424be070
...@@ -887,6 +887,8 @@ func (m *Master) service(ctx context.Context) (err error) { ...@@ -887,6 +887,8 @@ func (m *Master) service(ctx context.Context) (err error) {
} }
// XXX do we need vvv ? // XXX do we need vvv ?
// FIXME deadlock wrt when loop is over and noone reads from servedq
// (XXX review similar places in recovery and verify)
ack := make(chan struct{}) ack := make(chan struct{})
servedq <- serviceDone{peer: peer, err: err, ack: ack} servedq <- serviceDone{peer: peer, err: err, ack: ack}
<-ack <-ack
......
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