diff --git a/inroducer/index.js b/inroducer/index.js index 4d9ce21c375b58b3e9883f26253c3cea8f1fb6dd..1e09e30d82187bfad16f40a1bbe2b9eddbefdb12 100644 --- a/inroducer/index.js +++ b/inroducer/index.js @@ -145,4 +145,8 @@ socket.on("message", function(message, rinfo) { machines = machines.filter(m => m.toString()[0] !== text[1]); getPairings(machines); } + + if (text[0] === "dead") { + console.log(text) + } }); diff --git a/machine/index.js b/machine/index.js index fb89e4adb88a679d0503cca690a902c7ae5d7909..e0e36bbfdd15b8e07d339104f336e7e1deb10105 100644 --- a/machine/index.js +++ b/machine/index.js @@ -118,21 +118,21 @@ function updateTimeStamp(ackMachineNumber) { function updateStatuses() { Object.keys(connections).forEach(connection => { - if (Date.now() - connections[connection].timestamp >= (2 * 10000)) { + if (Date.now() - connections[connection].timestamp >= (5000)) { connections[connection].status = "dead" const message = Buffer.from(`dead ${connection}`); console.log(message.toString()) console.log(Date.now() - connections[connection].timestamp) - // socket.send( - // message, - // 0, - // message.length, - // PORT, - // machineToIps[machineNumberBeingChecked.toString()[0]], - // function() {} - // ); + socket.send( + message, + 0, + message.length, + PORT, + machineToIps["1"], + function() {} + ); } else {