|
|
@ -215,6 +215,10 @@ Stream.prototype.open = function (fd, type) { |
|
|
|
|
|
|
|
setImplmentationMethods(this); |
|
|
|
|
|
|
|
if (this.type === "unix") { |
|
|
|
this._writeWatcher.isUnixSocket = true; |
|
|
|
} |
|
|
|
|
|
|
|
this._writeWatcher.set(this.fd, false, true); |
|
|
|
this.writable = true; |
|
|
|
}; |
|
|
@ -520,6 +524,7 @@ Stream.prototype.destroy = function (exception) { |
|
|
|
this._writeWatcher.socket = null; |
|
|
|
this._writeWatcher.firstBucket = null; |
|
|
|
this._writeWatcher.lastBucket = null; |
|
|
|
this._writeWatcher.isUnixSocket = false; |
|
|
|
ioWatchers.free(this._writeWatcher); |
|
|
|
this._writeWatcher = null; |
|
|
|
} |
|
|
|