diff --git a/session.go b/session.go
index 7bdfef964..c053dba39 100644
--- a/session.go
+++ b/session.go
@@ -4545,13 +4545,7 @@ func (iter *Iter) getMore() {
 	} else {
 		op = &iter.op
 	}
-	// We unlock the iterator around socket.Query because it will call the
-	// replyFunc if the socket is dead, which would deadlock if the iterator
-	// were still locked.
-	iter.m.Unlock()
-	err = socket.Query(op)
-	iter.m.Lock()
-	if err != nil {
+	if err := socket.Query(op); err != nil {
 		iter.docsToReceive--
 		iter.err = err
 	}