We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8a9677c commit 728c7dfCopy full SHA for 728c7df
session.go
@@ -4545,13 +4545,7 @@ func (iter *Iter) getMore() {
4545
} else {
4546
op = &iter.op
4547
}
4548
- // We unlock the iterator around socket.Query because it will call the
4549
- // replyFunc if the socket is dead, which would deadlock if the iterator
4550
- // were still locked.
4551
- iter.m.Unlock()
4552
- err = socket.Query(op)
4553
- iter.m.Lock()
4554
- if err != nil {
+ if err := socket.Query(op); err != nil {
4555
iter.docsToReceive--
4556
iter.err = err
4557
0 commit comments