File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -133,6 +133,9 @@ func (socket *mongoSocket) resetNonce() {
133133 if result .Code == 13390 {
134134 // mongos doesn't yet support auth (see http://j.mp/mongos-auth)
135135 result .Nonce = "mongos"
136+ } else if result .Code == 11600 {
137+ socket .kill (errServerClosed , true )
138+ return
136139 } else if result .Nonce == "" {
137140 var msg string
138141 if result .Err != "" {
@@ -343,7 +346,7 @@ func (socket *mongoSocket) loginSASL(cred Credential) error {
343346 server .close (true )
344347 }
345348 lock (false )
346- socket .kill (errors . New ( "server_shutdown: " + res . ErrMsg ) , true )
349+ socket .kill (errServerClosed , true )
347350 }
348351 return fmt .Errorf ("server returned error on SASL authentication step: %s" , res .ErrMsg )
349352 }
Original file line number Diff line number Diff line change @@ -769,7 +769,7 @@ func (socket *mongoSocket) readLoop() {
769769 if socket .server != nil {
770770 socket .server .close (true )
771771 }
772- socket .kill (errors . New ( "server_shutdown: " + replyError . ErrMsg ) , true )
772+ socket .kill (errServerClosed , true )
773773 return
774774 }
775775
You can’t perform that action at this time.
0 commit comments