Skip to content

Commit 221aab3

Browse files
committed
refactor(replset): reduce server count when destroyed
1 parent 1a5537e commit 221aab3

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

lib/core/topologies/replset.js

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -300,15 +300,11 @@ function connectNewServers(self, servers, callback) {
300300

301301
// Destroyed
302302
if (self.state === DESTROYED || self.state === UNREFERENCED) {
303-
return this.destroy({ force: true });
303+
this.destroy({ force: true });
304+
return done();
304305
}
305306

306307
if (event === 'connect') {
307-
// Destroyed
308-
if (self.state === DESTROYED || self.state === UNREFERENCED) {
309-
return _self.destroy({ force: true });
310-
}
311-
312308
// Update the state
313309
var result = self.s.replicaSetState.update(_self);
314310
// Update the state with the new server
@@ -363,8 +359,7 @@ function connectNewServers(self, servers, callback) {
363359
connectingServer.destroy({ force: true });
364360

365361
self.s.connectingServers.splice(existingServerIdx, 1);
366-
done();
367-
return;
362+
return done();
368363
}
369364

370365
// Create a new server instance

0 commit comments

Comments
 (0)