diff --git a/cli/src/commands/leave.js b/cli/src/commands/leave.js index d1f9eed7ae28b705c9d784c74c3251779c651956..fdb96392e7358ebc92e2bd4c75d7c866846c2e6e 100644 --- a/cli/src/commands/leave.js +++ b/cli/src/commands/leave.js @@ -41,6 +41,8 @@ function sendMessage(number) { function sendMessageToNode(number) { const message = Buffer.from(`leave ${number}`); + console.log(machineToIps[number]) + console.log(message.toString()) socket.send(message, 0, message.length, PORT, machineToIps[number], function() {}); } @@ -48,6 +50,6 @@ module.exports.handler = handleErrors(async (argv: {}) => { console.log("Sending message to introducer"); let number = argv.number; await sendMessage(number); - sendMessageToNode(number) + await sendMessageToNode(number); process.exit(0); }); diff --git a/introducer/index.js b/introducer/index.js index eac95c84ebe4c081f59518e21d99402bfdf0845c..d2e1988deb789dc0b94ea020b4d2a5ed0dca4c1c 100644 --- a/introducer/index.js +++ b/introducer/index.js @@ -98,12 +98,12 @@ function getPairings(machines) { surroundingNodes.push(machines[i - 2]); } - // console.log( - // "Node :" + - // machines[i] + - // " is connect to " + - // Array.from(new Set(surroundingNodes)) - // ); + console.log( + "Node :" + + machines[i] + + " is connect to " + + Array.from(new Set(surroundingNodes)) + ); initialize(machines[i][0], Array.from(new Set(surroundingNodes))); } }