diff --git a/lib/client/client.js b/lib/client/client.js index 8cd2d34..e9414d5 100644 --- a/lib/client/client.js +++ b/lib/client/client.js @@ -163,7 +163,7 @@ function setupSocket(socket, opts) { socket.on('error', function onError(err) { if (log.trace()) log.trace({err: err}, 'error event: %s', new Error().stack); - + if (opts.connectTimer) { clearTimeout(opts.connectTimer); opts.connectTimer = false; diff --git a/lib/client/pool.js b/lib/client/pool.js index 4e7900e..571fbaf 100644 --- a/lib/client/pool.js +++ b/lib/client/pool.js @@ -31,7 +31,7 @@ var RETURN_VAL_OPS = [ ///--- Internal Functions -function createPool(options, self) { +function createPool(options, clientpool) { assert.ok(options); return pooling.createPool({ @@ -47,13 +47,13 @@ function createPool(options, self) { client.on('error', function (err) { client.removeAllListeners('connect'); client.removeAllListeners('connectTimeout'); - self.emit('error', err); + clientpool.emit('error', err); return callback(err); }); client.on('connectTimeout', function () { client.removeAllListeners('connect'); - self.emit('connectTimeout'); + clientpool.emit('connectTimeout'); }); client.once('connect', function onConnect() { @@ -248,7 +248,7 @@ ClientPool.prototype.bind = function bind(dn, creds, controls, callback) { self.options.bindControls = null; return this.pool.shutdown(function () { - self.pool = createPool(self.options); + self.pool = createPool(self.options, self); return self.pool.acquire(function onAcquire(err, client) { if (err)