summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorBenjamin Gruenbaum <inglor@gmail.com>2016-03-23 11:49:12 +0200
committerBenjamin Gruenbaum <inglor@gmail.com>2016-03-27 12:51:33 +0300
commita6b9b554eb7ddcc362ee8e93931a3c6bec53b0b2 (patch)
treed521da00edc88ea15844d5e1f28d0c3fa3b12280 /lib
parent1213535701dbff5688f15d3fdaf39878941378ae (diff)
downloadandroid-node-v8-a6b9b554eb7ddcc362ee8e93931a3c6bec53b0b2.tar.gz
android-node-v8-a6b9b554eb7ddcc362ee8e93931a3c6bec53b0b2.tar.bz2
android-node-v8-a6b9b554eb7ddcc362ee8e93931a3c6bec53b0b2.zip
child_process: refactor self=this in socket_list
The socket list module (used by child_process) currently uses the `var self = this;` pattern for context in several places, this PR replaces this with arrow functions or passing a parameter in where appropriate. Note that the `var self = this` in the _request is intentioanlly left in place since it is not trivial to refactor it and the current pattern isn't bad given the use case. PR-URL: https://github.com/nodejs/node/pull/5860 Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Brian White <mscdex@mscdex.net>
Diffstat (limited to 'lib')
-rw-r--r--lib/internal/socket_list.js28
1 files changed, 12 insertions, 16 deletions
diff --git a/lib/internal/socket_list.js b/lib/internal/socket_list.js
index 950d632a26..0f4be6df23 100644
--- a/lib/internal/socket_list.js
+++ b/lib/internal/socket_list.js
@@ -58,13 +58,11 @@ SocketListSend.prototype.getConnections = function getConnections(callback) {
function SocketListReceive(slave, key) {
EventEmitter.call(this);
- var self = this;
-
this.connections = 0;
this.key = key;
this.slave = slave;
- function onempty() {
+ function onempty(self) {
if (!self.slave.connected) return;
self.slave.send({
@@ -73,21 +71,21 @@ function SocketListReceive(slave, key) {
});
}
- this.slave.on('internalMessage', function(msg) {
- if (msg.key !== self.key) return;
+ this.slave.on('internalMessage', (msg) => {
+ if (msg.key !== this.key) return;
if (msg.cmd === 'NODE_SOCKET_NOTIFY_CLOSE') {
// Already empty
- if (self.connections === 0) return onempty();
+ if (this.connections === 0) return onempty(this);
// Wait for sockets to get closed
- self.once('empty', onempty);
+ this.once('empty', onempty);
} else if (msg.cmd === 'NODE_SOCKET_GET_COUNT') {
- if (!self.slave.connected) return;
- self.slave.send({
+ if (!this.slave.connected) return;
+ this.slave.send({
cmd: 'NODE_SOCKET_COUNT',
- key: self.key,
- count: self.connections
+ key: this.key,
+ count: this.connections
});
}
});
@@ -95,14 +93,12 @@ function SocketListReceive(slave, key) {
util.inherits(SocketListReceive, EventEmitter);
SocketListReceive.prototype.add = function(obj) {
- var self = this;
-
this.connections++;
// Notify previous owner of socket about its state change
- obj.socket.once('close', function() {
- self.connections--;
+ obj.socket.once('close', () => {
+ this.connections--;
- if (self.connections === 0) self.emit('empty');
+ if (this.connections === 0) this.emit('empty', this);
});
};