Skip to content

Commit 9ea0190

Browse files
committed
fix(replset): destroy servers that are removed during SDAM flow
1 parent 63fbdee commit 9ea0190

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

lib/core/topologies/replset_state.js

+5-5
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ ReplSetState.prototype.update = function(server) {
391391
removeFrom(server, self.unknownServers);
392392

393393
// Destroy the instance
394-
server.destroy();
394+
server.destroy({ force: true });
395395

396396
// Set the type of topology we have
397397
if (this.primary && !this.primary.equals(server)) {
@@ -555,7 +555,7 @@ ReplSetState.prototype.update = function(server) {
555555
// Signal primary left
556556
self.emit('left', 'primary', this.primary);
557557
// Destroy the instance
558-
self.primary.destroy();
558+
self.primary.destroy({ force: true });
559559
// Set the new instance
560560
self.primary = server;
561561
// Set the set information
@@ -607,7 +607,7 @@ ReplSetState.prototype.update = function(server) {
607607

608608
// Remove primary
609609
if (this.primary && this.primary.name.toLowerCase() === serverName) {
610-
server.destroy();
610+
server.destroy({ force: true });
611611
this.primary = null;
612612
self.emit('left', 'primary', server);
613613
}
@@ -659,7 +659,7 @@ ReplSetState.prototype.update = function(server) {
659659

660660
// Remove primary
661661
if (this.primary && this.primary.name.toLowerCase() === serverName) {
662-
server.destroy();
662+
server.destroy({ force: true });
663663
this.primary = null;
664664
self.emit('left', 'primary', server);
665665
}
@@ -674,7 +674,7 @@ ReplSetState.prototype.update = function(server) {
674674
//
675675
if (this.set[serverName] && this.set[serverName].type === ServerType.RSPrimary) {
676676
self.emit('left', 'primary', this.primary);
677-
this.primary.destroy();
677+
this.primary.destroy({ force: true });
678678
this.primary = null;
679679
this.topologyType = TopologyType.ReplicaSetNoPrimary;
680680
return false;

0 commit comments

Comments
 (0)