summaryrefslogtreecommitdiff
path: root/lib/net.js
diff options
context:
space:
mode:
authorisaacs <i@izs.me>2013-05-24 17:16:08 -0700
committerisaacs <i@izs.me>2013-05-27 14:46:52 -0700
commitba048e72b02e17f0c73e0dcb7d37e76a03327c5a (patch)
treebe9aa3f1f745db25ce2fa12116acf07ac48683cd /lib/net.js
parent9c7078cea2b719defbb6519d10a14ab15e733822 (diff)
parentf904d614bf62d4bbf9c3adffb485f84d5c77c2d8 (diff)
downloadnodejs-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.js14
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');