Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorisaacs <i@izs.me>2012-03-20 00:34:12 +0400
committerisaacs <i@izs.me>2012-03-20 01:28:39 +0400
commitdce86828273ee2bca41fe2bf41e62ba044544177 (patch)
tree7bc6c65360e1e1b0118f650a46168d5ecef25d67 /lib
parent94d337eb0fbf78bda2af6938b4a65d3c94808caf (diff)
cluster: English language fixing
Diffstat (limited to 'lib')
-rw-r--r--lib/cluster.js38
1 files changed, 19 insertions, 19 deletions
diff --git a/lib/cluster.js b/lib/cluster.js
index 686d05d3bdc..c47270585ee 100644
--- a/lib/cluster.js
+++ b/lib/cluster.js
@@ -51,7 +51,7 @@ var ids = 0;
var serverHandlers = {};
// Used in the worker:
-var serverLisenters = {};
+var serverListeners = {};
var queryIds = 0;
var queryCallbacks = {};
@@ -153,7 +153,7 @@ function handleResponse(outMessage, outHandle, inMessage, inHandle, worker) {
}
// Handle messages from both master and workers
-var messageHandingObject = {};
+var messageHandler = {};
function handleMessage(worker, inMessage, inHandle) {
//Remove internal prefix
@@ -161,14 +161,14 @@ function handleMessage(worker, inMessage, inHandle) {
message.cmd = inMessage.cmd.substr(INTERNAL_PREFIX.length);
var respondUsed = false;
- var respond = function(outMessage, outHandler) {
+ function respond(outMessage, outHandler) {
respondUsed = true;
handleResponse(outMessage, outHandler, inMessage, inHandle, worker);
- };
+ }
// Run handler if it exist
- if (messageHandingObject[message.cmd]) {
- messageHandingObject[message.cmd](message, worker, respond);
+ if (messageHandler[message.cmd]) {
+ messageHandler[message.cmd](message, worker, respond);
}
// Send respond if it wasn't done
@@ -181,7 +181,7 @@ function handleMessage(worker, inMessage, inHandle) {
if (cluster.isMaster) {
// Handle online messages from workers
- messageHandingObject.online = function(message, worker) {
+ messageHandler.online = function(message, worker) {
worker.state = 'online';
debug('Worker ' + worker.process.pid + ' online');
worker.emit('online', worker);
@@ -189,7 +189,7 @@ if (cluster.isMaster) {
};
// Handle queryServer messages form workers
- messageHandingObject.queryServer = function(message, worker, send) {
+ messageHandler.queryServer = function(message, worker, send) {
// This sequence of infomation is unique to the connection but not
// to the worker
@@ -208,7 +208,7 @@ if (cluster.isMaster) {
};
// Handle listening messages from workers
- messageHandingObject.listening = function(message, worker) {
+ messageHandler.listening = function(message, worker) {
worker.state = 'listening';
@@ -226,7 +226,7 @@ if (cluster.isMaster) {
};
// Handle suicide messages from workers
- messageHandingObject.suicide = function(message, worker) {
+ messageHandler.suicide = function(message, worker) {
worker.suicide = true;
};
@@ -236,7 +236,7 @@ if (cluster.isMaster) {
else if (cluster.isWorker) {
// Handle worker.disconnect from master
- messageHandingObject.disconnect = function(message, worker) {
+ messageHandler.disconnect = function(message, worker) {
worker.disconnect();
};
}
@@ -412,12 +412,12 @@ if (cluster.isMaster) {
this.suicide = true;
// keep track of open servers
- var servers = Object.keys(serverLisenters).length;
+ var servers = Object.keys(serverListeners).length;
var progress = new ProgressTracker(servers, function() {
// there are no more servers open so we will close the IPC channel.
- // Closeing the IPC channel will emit emit a disconnect event
+ // Closing the IPC channel will emit a disconnect event
// in both master and worker on the process object.
- // This event will be handled by prepearDeath.
+ // This event will be handled by prepareDeath.
self.process.disconnect();
});
@@ -428,10 +428,10 @@ if (cluster.isMaster) {
// in case there are no servers
progress.check();
- // closeing all servers graceful
+ // closing all servers gracefully
var server;
- for (var key in serverLisenters) {
- server = serverLisenters[key];
+ for (var key in serverListeners) {
+ server = serverListeners[key];
// in case the server is closed we wont close it again
if (server._handle === null) {
@@ -491,7 +491,7 @@ cluster._setupWorker = function() {
// Get worker class
var worker = cluster.worker = new Worker();
- // when the worker is disconnected from parent accidently
+ // when the worker is disconnected from parent accidentally
// we will terminate the worker
process.once('disconnect', function() {
if (worker.suicide !== true) {
@@ -511,7 +511,7 @@ cluster._getServer = function(tcpSelf, address, port, addressType, cb) {
// Store tcp instance for later use
var key = [address, port, addressType].join(':');
- serverLisenters[key] = tcpSelf;
+ serverListeners[key] = tcpSelf;
// Send a listening message to the master
tcpSelf.once('listening', function() {