diff options
author | isaacs <i@izs.me> | 2013-05-24 17:16:08 -0700 |
---|---|---|
committer | isaacs <i@izs.me> | 2013-05-27 14:46:52 -0700 |
commit | ba048e72b02e17f0c73e0dcb7d37e76a03327c5a (patch) | |
tree | be9aa3f1f745db25ce2fa12116acf07ac48683cd /lib/net.js | |
parent | 9c7078cea2b719defbb6519d10a14ab15e733822 (diff) | |
parent | f904d614bf62d4bbf9c3adffb485f84d5c77c2d8 (diff) | |
download | nodejs-ba048e72b02e17f0c73e0dcb7d37e76a03327c5a.tar.gz nodejs-ba048e72b02e17f0c73e0dcb7d37e76a03327c5a.tar.bz2 nodejs-ba048e72b02e17f0c73e0dcb7d37e76a03327c5a.zip |
Merge remote-tracking branch 'ry/v0.10'
Conflicts:
AUTHORS
ChangeLog
configure
deps/uv/ChangeLog
deps/uv/src/unix/darwin.c
deps/uv/src/unix/stream.c
deps/uv/src/version.c
deps/v8/src/isolate.cc
deps/v8/src/version.cc
lib/http.js
src/node_version.h
Diffstat (limited to 'lib/net.js')
-rw-r--r-- | lib/net.js | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/lib/net.js b/lib/net.js index e248bdfb3..4ada1dc78 100644 --- a/lib/net.js +++ b/lib/net.js @@ -298,7 +298,7 @@ Socket.prototype.listen = function() { Socket.prototype.setTimeout = function(msecs, callback) { if (msecs > 0 && !isNaN(msecs) && isFinite(msecs)) { timers.enroll(this, msecs); - timers.active(this); + timers._unrefActive(this); if (callback) { this.once('timeout', callback); } @@ -472,7 +472,7 @@ function onread(buffer, offset, length) { var self = handle.owner; assert(handle === self._handle, 'handle != self._handle'); - timers.active(self); + timers._unrefActive(self); var end = offset + length; debug('onread', process._errno, offset, length, end); @@ -603,7 +603,7 @@ Socket.prototype._writeGeneric = function(writev, data, encoding, cb) { this._pendingData = null; this._pendingEncoding = ''; - timers.active(this); + timers._unrefActive(this); if (!this._handle) { this._destroy(new Error('This socket is closed.'), cb); @@ -744,7 +744,7 @@ function afterWrite(status, handle, req) { return; } - timers.active(self); + timers._unrefActive(self); if (self !== process.stderr && self !== process.stdout) debug('afterWrite call cb'); @@ -825,7 +825,7 @@ Socket.prototype.connect = function(options, cb) { self.once('connect', cb); } - timers.active(this); + timers._unrefActive(this); self._connecting = true; self.writable = true; @@ -858,7 +858,7 @@ Socket.prototype.connect = function(options, cb) { self._destroy(); }); } else { - timers.active(self); + timers._unrefActive(self); addressType = addressType || 4; @@ -905,7 +905,7 @@ function afterConnect(status, handle, req, readable, writable) { if (status == 0) { self.readable = readable; self.writable = writable; - timers.active(self); + timers._unrefActive(self); self.emit('connect'); |