fix(replset): destroy servers that are removed during SDAM flow

mongodb · Oct 15, 2019 · 9ea0190 · 9ea0190
1 parent 63fbdee
commit 9ea0190
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/lib/core/topologies/replset_state.js b/lib/core/topologies/replset_state.js
@@ -391,7 +391,7 @@ ReplSetState.prototype.update = function(server) {
     removeFrom(server, self.unknownServers);
 
     // Destroy the instance
-    server.destroy();
+    server.destroy({ force: true });
 
     // Set the type of topology we have
     if (this.primary && !this.primary.equals(server)) {
@@ -555,7 +555,7 @@ ReplSetState.prototype.update = function(server) {
     // Signal primary left
     self.emit('left', 'primary', this.primary);
     // Destroy the instance
-    self.primary.destroy();
+    self.primary.destroy({ force: true });
     // Set the new instance
     self.primary = server;
     // Set the set information
@@ -607,7 +607,7 @@ ReplSetState.prototype.update = function(server) {
 
     // Remove primary
     if (this.primary && this.primary.name.toLowerCase() === serverName) {
-      server.destroy();
+      server.destroy({ force: true });
       this.primary = null;
       self.emit('left', 'primary', server);
     }
@@ -659,7 +659,7 @@ ReplSetState.prototype.update = function(server) {
 
     // Remove primary
     if (this.primary && this.primary.name.toLowerCase() === serverName) {
-      server.destroy();
+      server.destroy({ force: true });
       this.primary = null;
       self.emit('left', 'primary', server);
     }
@@ -674,7 +674,7 @@ ReplSetState.prototype.update = function(server) {
   //
   if (this.set[serverName] && this.set[serverName].type === ServerType.RSPrimary) {
     self.emit('left', 'primary', this.primary);
-    this.primary.destroy();
+    this.primary.destroy({ force: true });
     this.primary = null;
     this.topologyType = TopologyType.ReplicaSetNoPrimary;
     return false;