Skip to content

Commit

Permalink
net: destructure primordials
Browse files Browse the repository at this point in the history
Refs: #29766
PR-URL: #30447
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
Reviewed-By: Denys Otrishko <shishugi@gmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
  • Loading branch information
Guilherme Goncalves authored and MylesBorins committed Dec 17, 2019
1 parent 4834a31 commit 0ae1d17
Showing 1 changed file with 22 additions and 17 deletions.
39 changes: 22 additions & 17 deletions lib/net.js
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,12 @@

'use strict';

const { Object } = primordials;
const {
Object: {
defineProperty: ObjectDefineProperty,
setPrototypeOf: ObjectSetPrototypeOf
}
} = primordials;

const EventEmitter = require('events');
const stream = require('stream');
Expand Down Expand Up @@ -336,7 +341,7 @@ function Socket(options) {
// makeSyncWrite adjusts this value like the original handle would, so
// we need to let it do that by turning it into a writable, own
// property.
Object.defineProperty(this._handle, 'bytesWritten', {
ObjectDefineProperty(this._handle, 'bytesWritten', {
value: 0, writable: true
});
}
Expand Down Expand Up @@ -372,8 +377,8 @@ function Socket(options) {
this[kBytesRead] = 0;
this[kBytesWritten] = 0;
}
Object.setPrototypeOf(Socket.prototype, stream.Duplex.prototype);
Object.setPrototypeOf(Socket, stream.Duplex);
ObjectSetPrototypeOf(Socket.prototype, stream.Duplex.prototype);
ObjectSetPrototypeOf(Socket, stream.Duplex);

// Refresh existing timeouts.
Socket.prototype._unrefTimer = function _unrefTimer() {
Expand Down Expand Up @@ -503,21 +508,21 @@ Socket.prototype.address = function() {
};


Object.defineProperty(Socket.prototype, '_connecting', {
ObjectDefineProperty(Socket.prototype, '_connecting', {
get: function() {
return this.connecting;
}
});

Object.defineProperty(Socket.prototype, 'pending', {
ObjectDefineProperty(Socket.prototype, 'pending', {
get() {
return !this._handle || this.connecting;
},
configurable: true
});


Object.defineProperty(Socket.prototype, 'readyState', {
ObjectDefineProperty(Socket.prototype, 'readyState', {
get: function() {
if (this.connecting) {
return 'opening';
Expand All @@ -534,15 +539,15 @@ Object.defineProperty(Socket.prototype, 'readyState', {
});


Object.defineProperty(Socket.prototype, 'bufferSize', {
get: function() { // eslint-disable-line getter-return
ObjectDefineProperty(Socket.prototype, 'bufferSize', {
get: function() {
if (this._handle) {
return this[kLastWriteQueueSize] + this.writableLength;
}
}
});

Object.defineProperty(Socket.prototype, kUpdateTimer, {
ObjectDefineProperty(Socket.prototype, kUpdateTimer, {
get: function() {
return this._unrefTimer;
}
Expand Down Expand Up @@ -690,7 +695,7 @@ Socket.prototype._getpeername = function() {
};

function protoGetter(name, callback) {
Object.defineProperty(Socket.prototype, name, {
ObjectDefineProperty(Socket.prototype, name, {
configurable: false,
enumerable: true,
get: callback
Expand Down Expand Up @@ -1162,7 +1167,7 @@ function Server(options, connectionListener) {

this._connections = 0;

Object.defineProperty(this, 'connections', {
ObjectDefineProperty(this, 'connections', {
get: deprecate(() => {

if (this._usingWorkers) {
Expand All @@ -1186,8 +1191,8 @@ function Server(options, connectionListener) {
this.allowHalfOpen = options.allowHalfOpen || false;
this.pauseOnConnect = !!options.pauseOnConnect;
}
Object.setPrototypeOf(Server.prototype, EventEmitter.prototype);
Object.setPrototypeOf(Server, EventEmitter);
ObjectSetPrototypeOf(Server.prototype, EventEmitter.prototype);
ObjectSetPrototypeOf(Server, EventEmitter);


function toNumber(x) { return (x = Number(x)) >= 0 ? x : false; }
Expand Down Expand Up @@ -1491,7 +1496,7 @@ function lookupAndListen(self, port, address, backlog, exclusive, flags) {
});
}

Object.defineProperty(Server.prototype, 'listening', {
ObjectDefineProperty(Server.prototype, 'listening', {
get: function() {
return !!this._handle;
},
Expand Down Expand Up @@ -1648,12 +1653,12 @@ function emitCloseNT(self) {

// Legacy alias on the C++ wrapper object. This is not public API, so we may
// want to runtime-deprecate it at some point. There's no hurry, though.
Object.defineProperty(TCP.prototype, 'owner', {
ObjectDefineProperty(TCP.prototype, 'owner', {
get() { return this[owner_symbol]; },
set(v) { return this[owner_symbol] = v; }
});

Object.defineProperty(Socket.prototype, '_handle', {
ObjectDefineProperty(Socket.prototype, '_handle', {
get() { return this[kHandle]; },
set(v) { return this[kHandle] = v; }
});
Expand Down

0 comments on commit 0ae1d17

Please sign in to comment.