Fixes #5876.
--- /dev/null
+// Copyright Joyent, Inc. and other Node contributors.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a
+// copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to permit
+// persons to whom the Software is furnished to do so, subject to the
+// following conditions:
+//
+// The above copyright notice and this permission notice shall be included
+// in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
+// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
+// USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+var common = require('../common'),
+ assert = require('assert'),
+ dgram = require('dgram'),
+ util = require('util'),
+ assert = require('assert'),
+ Buffer = require('buffer').Buffer,
+ fork = require('child_process').fork,
+ LOCAL_BROADCAST_HOST = '224.0.0.114',
+ TIMEOUT = 5000,
+ messages = [
+ new Buffer('First message to send'),
+ new Buffer('Second message to send'),
+ new Buffer('Third message to send'),
+ new Buffer('Fourth message to send')
+ ];
+
+if (process.argv[2] !== 'child') {
+ var workers = {},
+ listeners = 3,
+ listening = 0,
+ dead = 0,
+ i = 0,
+ done = 0,
+ timer = null;
+
+ //exit the test if it doesn't succeed within TIMEOUT
+ timer = setTimeout(function() {
+ console.error('[PARENT] Responses were not received within %d ms.',
+ TIMEOUT);
+ console.error('[PARENT] Fail');
+
+ killChildren(workers);
+
+ process.exit(1);
+ }, TIMEOUT);
+
+ //launch child processes
+ for (var x = 0; x < listeners; x++) {
+ (function() {
+ var worker = fork(process.argv[1], ['child']);
+ workers[worker.pid] = worker;
+
+ worker.messagesReceived = [];
+
+ //handle the death of workers
+ worker.on('exit', function(code, signal) {
+ // don't consider this the true death if the
+ // worker has finished successfully
+
+ // or if the exit code is 0
+ if (worker.isDone || code === 0) {
+ return;
+ }
+
+ dead += 1;
+ console.error('[PARENT] Worker %d died. %d dead of %d',
+ worker.pid,
+ dead,
+ listeners);
+
+ if (dead === listeners) {
+ console.error('[PARENT] All workers have died.');
+ console.error('[PARENT] Fail');
+
+ killChildren(workers);
+
+ process.exit(1);
+ }
+ });
+
+ worker.on('message', function(msg) {
+ if (msg.listening) {
+ listening += 1;
+
+ if (listening === listeners) {
+ //all child process are listening, so start sending
+ sendSocket.sendNext();
+ }
+ }
+ else if (msg.message) {
+ worker.messagesReceived.push(msg.message);
+
+ if (worker.messagesReceived.length === messages.length) {
+ done += 1;
+ worker.isDone = true;
+ console.error('[PARENT] %d received %d messages total.',
+ worker.pid,
+ worker.messagesReceived.length);
+ }
+
+ if (done === listeners) {
+ console.error('[PARENT] All workers have received the ' +
+ 'required number of messages. Will now compare.');
+
+ Object.keys(workers).forEach(function(pid) {
+ var worker = workers[pid];
+
+ var count = 0;
+
+ worker.messagesReceived.forEach(function(buf) {
+ for (var i = 0; i < messages.length; ++i) {
+ if (buf.toString() === messages[i].toString()) {
+ count++;
+ break;
+ }
+ }
+ });
+
+ console.error('[PARENT] %d received %d matching messages.',
+ worker.pid, count);
+
+ assert.equal(count, messages.length,
+ 'A worker received an invalid multicast message');
+ });
+
+ clearTimeout(timer);
+ console.error('[PARENT] Success');
+ killChildren(workers);
+ }
+ }
+ });
+ })(x);
+ }
+
+ var sendSocket = dgram.createSocket('udp4');
+ // FIXME a libuv limitation makes it necessary to bind()
+ // before calling any of the set*() functions - the bind()
+ // call is what creates the actual socket...
+ sendSocket.bind();
+
+ // The socket is actually created async now
+ sendSocket.on('listening', function () {
+ sendSocket.setTTL(1);
+ sendSocket.setBroadcast(true);
+ sendSocket.setMulticastTTL(1);
+ sendSocket.setMulticastLoopback(true);
+ });
+
+ sendSocket.on('close', function() {
+ console.error('[PARENT] sendSocket closed');
+ });
+
+ sendSocket.sendNext = function() {
+ var buf = messages[i++];
+
+ if (!buf) {
+ try { sendSocket.close(); } catch (e) {}
+ return;
+ }
+
+ sendSocket.send(buf, 0, buf.length,
+ common.PORT, LOCAL_BROADCAST_HOST, function(err) {
+ if (err) throw err;
+ console.error('[PARENT] sent %s to %s:%s',
+ util.inspect(buf.toString()),
+ LOCAL_BROADCAST_HOST, common.PORT);
+ process.nextTick(sendSocket.sendNext);
+ });
+ };
+
+ function killChildren(children) {
+ Object.keys(children).forEach(function(key) {
+ var child = children[key];
+ child.kill();
+ });
+ }
+}
+
+if (process.argv[2] === 'child') {
+ var receivedMessages = [];
+ var listenSocket = dgram.createSocket('udp4');
+
+ listenSocket.on('message', function(buf, rinfo) {
+ console.error('[CHILD] %s received %s from %j', process.pid,
+ util.inspect(buf.toString()), rinfo);
+
+ receivedMessages.push(buf);
+
+ process.send({ message: buf.toString() });
+
+ if (receivedMessages.length == messages.length) {
+ listenSocket.dropMembership(LOCAL_BROADCAST_HOST);
+
+ process.nextTick(function() { // TODO should be changed to below.
+ // listenSocket.dropMembership(LOCAL_BROADCAST_HOST, function() {
+ listenSocket.close();
+ });
+ }
+ });
+
+ listenSocket.on('close', function() {
+ //HACK: Wait to exit the process to ensure that the parent
+ //process has had time to receive all messages via process.send()
+ //This may be indicitave of some other issue.
+ setTimeout(function() {
+ process.exit();
+ }, 1000);
+ });
+
+ listenSocket.on('listening', function() {
+ process.send({ listening: true });
+ });
+
+ listenSocket.bind(common.PORT);
+
+ listenSocket.on('listening', function () {
+ listenSocket.addMembership(LOCAL_BROADCAST_HOST);
+ });
+}
--- /dev/null
+// Copyright Joyent, Inc. and other Node contributors.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a
+// copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to permit
+// persons to whom the Software is furnished to do so, subject to the
+// following conditions:
+//
+// The above copyright notice and this permission notice shall be included
+// in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
+// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
+// USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+var common = require('../common');
+var assert = require('assert');
+var net = require('net');
+
+var client, killed = false, ended = false;
+var TIMEOUT = 10 * 1000
+
+client = net.createConnection(53, '8.8.8.8', function() {
+ client.unref();
+});
+
+client.on('close', function() {
+ ended = true;
+});
+
+setTimeout(function() {
+ killed = true;
+ client.end();
+}, TIMEOUT).unref();
+
+process.on('exit', function() {
+ assert.strictEqual(killed, false, 'A client should have connected');
+ assert.strictEqual(ended, false, 'A client should stay connected');
+});
+++ /dev/null
-// Copyright Joyent, Inc. and other Node contributors.
-//
-// Permission is hereby granted, free of charge, to any person obtaining a
-// copy of this software and associated documentation files (the
-// "Software"), to deal in the Software without restriction, including
-// without limitation the rights to use, copy, modify, merge, publish,
-// distribute, sublicense, and/or sell copies of the Software, and to permit
-// persons to whom the Software is furnished to do so, subject to the
-// following conditions:
-//
-// The above copyright notice and this permission notice shall be included
-// in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
-// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
-// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
-// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
-// USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-var common = require('../common'),
- assert = require('assert'),
- dgram = require('dgram'),
- util = require('util'),
- assert = require('assert'),
- Buffer = require('buffer').Buffer,
- fork = require('child_process').fork,
- LOCAL_BROADCAST_HOST = '224.0.0.114',
- TIMEOUT = 5000,
- messages = [
- new Buffer('First message to send'),
- new Buffer('Second message to send'),
- new Buffer('Third message to send'),
- new Buffer('Fourth message to send')
- ];
-
-if (process.argv[2] !== 'child') {
- var workers = {},
- listeners = 3,
- listening = 0,
- dead = 0,
- i = 0,
- done = 0,
- timer = null;
-
- //exit the test if it doesn't succeed within TIMEOUT
- timer = setTimeout(function() {
- console.error('[PARENT] Responses were not received within %d ms.',
- TIMEOUT);
- console.error('[PARENT] Fail');
-
- killChildren(workers);
-
- process.exit(1);
- }, TIMEOUT);
-
- //launch child processes
- for (var x = 0; x < listeners; x++) {
- (function() {
- var worker = fork(process.argv[1], ['child']);
- workers[worker.pid] = worker;
-
- worker.messagesReceived = [];
-
- //handle the death of workers
- worker.on('exit', function(code, signal) {
- // don't consider this the true death if the
- // worker has finished successfully
-
- // or if the exit code is 0
- if (worker.isDone || code === 0) {
- return;
- }
-
- dead += 1;
- console.error('[PARENT] Worker %d died. %d dead of %d',
- worker.pid,
- dead,
- listeners);
-
- if (dead === listeners) {
- console.error('[PARENT] All workers have died.');
- console.error('[PARENT] Fail');
-
- killChildren(workers);
-
- process.exit(1);
- }
- });
-
- worker.on('message', function(msg) {
- if (msg.listening) {
- listening += 1;
-
- if (listening === listeners) {
- //all child process are listening, so start sending
- sendSocket.sendNext();
- }
- }
- else if (msg.message) {
- worker.messagesReceived.push(msg.message);
-
- if (worker.messagesReceived.length === messages.length) {
- done += 1;
- worker.isDone = true;
- console.error('[PARENT] %d received %d messages total.',
- worker.pid,
- worker.messagesReceived.length);
- }
-
- if (done === listeners) {
- console.error('[PARENT] All workers have received the ' +
- 'required number of messages. Will now compare.');
-
- Object.keys(workers).forEach(function(pid) {
- var worker = workers[pid];
-
- var count = 0;
-
- worker.messagesReceived.forEach(function(buf) {
- for (var i = 0; i < messages.length; ++i) {
- if (buf.toString() === messages[i].toString()) {
- count++;
- break;
- }
- }
- });
-
- console.error('[PARENT] %d received %d matching messages.',
- worker.pid, count);
-
- assert.equal(count, messages.length,
- 'A worker received an invalid multicast message');
- });
-
- clearTimeout(timer);
- console.error('[PARENT] Success');
- killChildren(workers);
- }
- }
- });
- })(x);
- }
-
- var sendSocket = dgram.createSocket('udp4');
- // FIXME a libuv limitation makes it necessary to bind()
- // before calling any of the set*() functions - the bind()
- // call is what creates the actual socket...
- sendSocket.bind();
-
- // The socket is actually created async now
- sendSocket.on('listening', function () {
- sendSocket.setTTL(1);
- sendSocket.setBroadcast(true);
- sendSocket.setMulticastTTL(1);
- sendSocket.setMulticastLoopback(true);
- });
-
- sendSocket.on('close', function() {
- console.error('[PARENT] sendSocket closed');
- });
-
- sendSocket.sendNext = function() {
- var buf = messages[i++];
-
- if (!buf) {
- try { sendSocket.close(); } catch (e) {}
- return;
- }
-
- sendSocket.send(buf, 0, buf.length,
- common.PORT, LOCAL_BROADCAST_HOST, function(err) {
- if (err) throw err;
- console.error('[PARENT] sent %s to %s:%s',
- util.inspect(buf.toString()),
- LOCAL_BROADCAST_HOST, common.PORT);
- process.nextTick(sendSocket.sendNext);
- });
- };
-
- function killChildren(children) {
- Object.keys(children).forEach(function(key) {
- var child = children[key];
- child.kill();
- });
- }
-}
-
-if (process.argv[2] === 'child') {
- var receivedMessages = [];
- var listenSocket = dgram.createSocket('udp4');
-
- listenSocket.on('message', function(buf, rinfo) {
- console.error('[CHILD] %s received %s from %j', process.pid,
- util.inspect(buf.toString()), rinfo);
-
- receivedMessages.push(buf);
-
- process.send({ message: buf.toString() });
-
- if (receivedMessages.length == messages.length) {
- listenSocket.dropMembership(LOCAL_BROADCAST_HOST);
-
- process.nextTick(function() { // TODO should be changed to below.
- // listenSocket.dropMembership(LOCAL_BROADCAST_HOST, function() {
- listenSocket.close();
- });
- }
- });
-
- listenSocket.on('close', function() {
- //HACK: Wait to exit the process to ensure that the parent
- //process has had time to receive all messages via process.send()
- //This may be indicitave of some other issue.
- setTimeout(function() {
- process.exit();
- }, 1000);
- });
-
- listenSocket.on('listening', function() {
- process.send({ listening: true });
- });
-
- listenSocket.bind(common.PORT);
-
- listenSocket.on('listening', function () {
- listenSocket.addMembership(LOCAL_BROADCAST_HOST);
- });
-}
+++ /dev/null
-// Copyright Joyent, Inc. and other Node contributors.
-//
-// Permission is hereby granted, free of charge, to any person obtaining a
-// copy of this software and associated documentation files (the
-// "Software"), to deal in the Software without restriction, including
-// without limitation the rights to use, copy, modify, merge, publish,
-// distribute, sublicense, and/or sell copies of the Software, and to permit
-// persons to whom the Software is furnished to do so, subject to the
-// following conditions:
-//
-// The above copyright notice and this permission notice shall be included
-// in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
-// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
-// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
-// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
-// USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-var common = require('../common');
-var assert = require('assert');
-var net = require('net');
-
-var client, killed = false, ended = false;
-var TIMEOUT = 10 * 1000
-
-client = net.createConnection(53, '8.8.8.8', function() {
- client.unref();
-});
-
-client.on('close', function() {
- ended = true;
-});
-
-setTimeout(function() {
- killed = true;
- client.end();
-}, TIMEOUT).unref();
-
-process.on('exit', function() {
- assert.strictEqual(killed, false, 'A client should have connected');
- assert.strictEqual(ended, false, 'A client should stay connected');
-});
projects / platform / upstream / nodejs.git / commitdiff