@@ -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