Merge pull request globalsign#37 from joomcode/feature/close-after-shutdown-error

Close socket immediately after `server_shutdown` error

Author: bozaro

socket.go

@@ -760,6 +760,16 @@ func (socket *mongoSocket) readLoop() {
 					replyFunc(nil, &reply, i, b)
 				}
 
+				var replyError queryError
+				if err := bson.Unmarshal(b, &replyError); err != nil {
+					debugf("Socket %p to %s: received broken document: %#v", socket, socket.addr, err)
+				}
+				switch replyError.Code {
+				case 11600:
+					socket.kill(errors.New("server_shutdown: "+replyError.ErrMsg), true)
+					return
+				}
+
 				// XXX Do bound checking against totalLen.
 			}
 		}