mongodb-core - npm Package Compare versions

Comparing version 2.1.12 to 2.1.13

HISTORY.md

@@ -0,1 +1,6 @@
+2.1.13 2017-06-19
+-----------------
+- NODE-1039 ensure we force destroy server instances, forcing queue to be flushed.
+-  Use actual server type in standalone SDAM events.
+
 2.1.12 2017-06-02
@@ -2,0 +7,0 @@ -----------------

lib/connection/pool.js

@@ -861,2 +861,13 @@ "use strict";
       .concat(self.connectingConnections);
+
+    // Flush any remaining work items with
+    // an error
+    while(self.queue.length > 0) {
+      var workItem = self.queue.shift();
+      if(typeof workItem.cb == 'function') {
+        workItem.cb(null, err);
+      }
+    }
+
+    // Destroy the topology 
     return destroy(self, connections);
@@ -863,0 +874,0 @@ }

lib/topologies/replset.js

@@ -257,3 +257,3 @@ "use strict"
       if(self.state == DESTROYED || self.state == UNREFERENCED) {
-        return this.destroy();
+        return this.destroy({force:true});
       }
@@ -264,3 +264,3 @@
         if(self.state == DESTROYED || self.state == UNREFERENCED) {
-          return _self.destroy();
+          return _self.destroy({force:true});
         }
@@ -272,3 +272,3 @@
           if(self.state == DESTROYED || self.state == UNREFERENCED) {
-            return _self.destroy();
+            return _self.destroy({force:true});
           }
@@ -302,7 +302,7 @@
           } else {
-            _self.destroy();
+            _self.destroy({force:true});
           }
         });
       } else if(event == 'connect' && self.authenticating) {
-        this.destroy();
+        this.destroy({force:true});
       } else if(event == 'error') {
@@ -380,3 +380,3 @@ error = err;
     if(self.state == DESTROYED || self.state == UNREFERENCED) {
-      server.destroy();
+      server.destroy({force:true});
       return cb(err, r);
@@ -566,7 +566,7 @@ }
         self.emit('error', new MongoError('no primary found in replicaset'));
-        return self.destroy();
+        return self.destroy({force:true});
       } else if(!self.s.replicaSetState.hasSecondary() && self.s.options.secondaryOnlyConnectionAllowed) {
         if(err) return self.emit('error', err);
         self.emit('error', new MongoError('no secondary found in replicaset'));
-        return self.destroy();
+        return self.destroy({force:true});
       }
@@ -688,3 +688,3 @@
     if(self.state == DESTROYED || self.state == UNREFERENCED) {
-      return this.destroy();
+      return this.destroy({force:true});
     }
@@ -698,3 +698,3 @@
         if(self.state == DESTROYED || self.state == UNREFERENCED) {
-          return _this.destroy();
+          return _this.destroy({force:true});
         }
@@ -742,7 +742,7 @@
         } else if(result instanceof MongoError) {
-          _this.destroy();
-          self.destroy();
+          _this.destroy({force:true});
+          self.destroy({force:true});
           return self.emit('error', result);
         } else {
-          _this.destroy();
+          _this.destroy({force:true});
         }
@@ -749,0 +749,0 @@ });

lib/topologies/server.js

@@ -290,3 +290,3 @@ "use strict"
           sdam.emitTopologyDescriptionChanged(self, {
-            topologyType: 'Single', servers: [{address: self.name, arbiters: [], hosts: [], passives: [], type: 'Standalone'}]
+            topologyType: 'Single', servers: [{address: self.name, arbiters: [], hosts: [], passives: [], type: sdam.getTopologyType(self)}]
           });
@@ -293,0 +293,0 @@ }

package.json

 {
   "name": "mongodb-core",
-  "version": "2.1.12",
+  "version": "2.1.13",
   "description": "Core MongoDB driver functionality, no bells and whistles and meant for integration not end applications",
@@ -5,0 +5,0 @@ "main": "index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

609969

increased by0.1%

Lines of code

10660

increased by0.08%

No dependency changes