From 8d9e210a560db1f8a6931d9491a63128e4a6323d Mon Sep 17 00:00:00 2001 From: Dom Dwyer Date: Thu, 19 Oct 2017 13:26:16 +0100 Subject: [PATCH] Revert "do not lock while writing to a socket (#52)" This reverts commit 95448edf47106376ec01ca6e44f9365c2d7742fa. --- socket.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/socket.go b/socket.go index f6158189c..72fab9cf7 100644 --- a/socket.go +++ b/socket.go @@ -549,15 +549,16 @@ func (socket *mongoSocket) Query(ops ...interface{}) (err error) { socket.replyFuncs[requestId] = request.replyFunc requestId++ } - socket.Unlock() - debugf("Socket %p to %s: sending %d op(s) (%d bytes)", socket, socket.addr, len(ops), len(buf)) + debugf("Socket %p to %s: sending %d op(s) (%d bytes)", socket, socket.addr, len(ops), len(buf)) stats.sentOps(len(ops)) + socket.updateDeadline(writeDeadline) _, err = socket.conn.Write(buf) if !wasWaiting && requestCount > 0 { socket.updateDeadline(readDeadline) } + socket.Unlock() return err }