Comparing version 0.2.0 to 0.2.1
@@ -61,8 +61,11 @@ var header = require('./header'); | ||
var self = this; | ||
var waiting = false; | ||
if (!self._socket) { | ||
self._socket = net.connect(this.port, this.host, function() { | ||
self.once('authenticated', function() { | ||
waiting = true; | ||
go(self._socket); | ||
}); | ||
this.on('data', function(dataBuf) { | ||
waiting = false; | ||
self.responseHandler(dataBuf) | ||
@@ -77,2 +80,3 @@ }); | ||
self._socket.on('error', function(error) { | ||
waiting = false; | ||
self._socket = undefined; | ||
@@ -82,7 +86,10 @@ self.emit('error', error); | ||
self._socket.setTimeout(self.options.timeout * 1000, function() { | ||
self._socket.end(); | ||
self._socket = undefined; | ||
self.emit('error', {message:'hello'}); | ||
if (waiting) { | ||
self._socket.end(); | ||
self._socket = undefined; | ||
self.emit('error', new Error('socket timed out.')); | ||
} | ||
}); | ||
} else { | ||
waiting = true; | ||
go(self._socket, false); | ||
@@ -106,2 +113,2 @@ } | ||
exports.Server = Server; | ||
exports.Server = Server; |
@@ -5,3 +5,3 @@ { | ||
"description": "A memcache client for node using the binary protocol and SASL authentication", | ||
"version": "0.2.0", | ||
"version": "0.2.1", | ||
"homepage": "http://github.com/alevy/memjs", | ||
@@ -8,0 +8,0 @@ "repository": { |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
27854
709
1