From 2edfdd805749d8c06a89055d1d3f67ffd3ea1b39 Mon Sep 17 00:00:00 2001 From: Dan Aprahamian Date: Tue, 12 Dec 2017 16:51:31 -0500 Subject: [PATCH] fix(topologies): unify topologies connect API Eliminates the DB parameter from the `connect` call in replset and mongos to unify the api with server --- lib/topologies/mongos.js | 5 +++-- lib/topologies/replset.js | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/lib/topologies/mongos.js b/lib/topologies/mongos.js index 52d08f101b5..a1847e2c171 100644 --- a/lib/topologies/mongos.js +++ b/lib/topologies/mongos.js @@ -209,7 +209,7 @@ class Mongos extends TopologyBase { } // Connect - connect(db, _options, callback) { + connect(_options, callback) { var self = this; if ('function' === typeof _options) (callback = _options), (_options = {}); if (_options == null) _options = {}; @@ -218,7 +218,8 @@ class Mongos extends TopologyBase { self.s.options = _options; // Update bufferMaxEntries - self.s.storeOptions.bufferMaxEntries = db.bufferMaxEntries; + self.s.storeOptions.bufferMaxEntries = + typeof _options.bufferMaxEntries === 'number' ? _options.bufferMaxEntries : -1; // Error handler var connectErrorHandler = function() { diff --git a/lib/topologies/replset.js b/lib/topologies/replset.js index ee584b7276a..e04260c0a8f 100644 --- a/lib/topologies/replset.js +++ b/lib/topologies/replset.js @@ -236,7 +236,7 @@ class ReplSet extends TopologyBase { } // Connect method - connect(db, _options, callback) { + connect(_options, callback) { var self = this; if ('function' === typeof _options) (callback = _options), (_options = {}); if (_options == null) _options = {}; @@ -245,7 +245,8 @@ class ReplSet extends TopologyBase { self.s.options = _options; // Update bufferMaxEntries - self.s.storeOptions.bufferMaxEntries = db.bufferMaxEntries; + self.s.storeOptions.bufferMaxEntries = + typeof _options.bufferMaxEntries === 'number' ? _options.bufferMaxEntries : -1; // Actual handler var errorHandler = function(event) {