Revision 5e7e51c2 lib/cluster.js
| lib/cluster.js | ||
|---|---|---|
| 227 | 227 |
|
| 228 | 228 |
if (serverHandlers.hasOwnProperty(key)) {
|
| 229 | 229 |
handler = serverHandlers[key]; |
| 230 |
} else if (message.addressType === 'udp4' || |
|
| 231 |
message.addressType === 'udp6') {
|
|
| 232 |
var dgram = require('dgram');
|
|
| 233 |
handler = dgram._createSocketHandle.apply(net, args); |
|
| 234 |
serverHandlers[key] = handler; |
|
| 230 | 235 |
} else {
|
| 231 |
handler = serverHandlers[key] = net._createServerHandle.apply(net, args); |
|
| 236 |
handler = net._createServerHandle.apply(net, args); |
|
| 237 |
serverHandlers[key] = handler; |
|
| 232 | 238 |
} |
| 233 | 239 |
|
| 234 | 240 |
// echo callback with the fd handler associated with it |
| ... | ... | |
| 259 | 265 |
messageHandler.suicide = function(message, worker) {
|
| 260 | 266 |
worker.suicide = true; |
| 261 | 267 |
}; |
| 262 |
|
|
| 263 | 268 |
} |
| 264 | 269 |
|
| 270 |
|
|
| 265 | 271 |
// Messages to a worker will be handled using these methods |
| 266 | 272 |
else if (cluster.isWorker) {
|
| 267 | 273 |
|
| ... | ... | |
| 541 | 547 |
sendInternalMessage(worker, { cmd: 'online' });
|
| 542 | 548 |
}; |
| 543 | 549 |
|
| 544 |
// Internal function. Called by lib/net.js when attempting to bind a server. |
|
| 550 |
// Internal function. Called by net.js and dgram.js when attempting to bind a |
|
| 551 |
// TCP server or UDP socket. |
|
| 545 | 552 |
cluster._getServer = function(tcpSelf, address, port, addressType, fd, cb) {
|
| 546 | 553 |
// This can only be called from a worker. |
| 547 | 554 |
assert(cluster.isWorker); |
Also available in: Unified diff