stronk/OrchestratorTracker
1
0
Fork 0
mirror of https://github.com/stronk-dev/OrchestratorTracker.git synced 2025-07-05 10:55:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

Changes to timouts

Browse Source
This commit is contained in:
Marco van Dijk 2022-08-09 18:11:28 +02:00
parent cb96d3f408
commit b9b669cf37
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
client/src/routes/orchTester.js
View File

@ -172,17 +172,16 @@ function hexToBytes(hex) {
const discoverOrchestrator = async function (target) { const discoverOrchestrator = async function (target) {
if (!target) { return; } if (!target) { return; }
var client = new livepeerProto.Orchestrator(target, ssl_creds); var client = new livepeerProto.Orchestrator(target, ssl_creds);
const addr = CONF_BROADCASTER;
var receivedResults = false; var receivedResults = false;
var orchestratorInfo; var orchestratorInfo;
const start = new Date().getTime(); const start = new Date().getTime();
var elapsed = null; var elapsed = null;
await client.GetOrchestrator({ await client.GetOrchestrator({
address: hexToBytes(addr), address: hexToBytes(CONF_BROADCASTER),
sig: CONT_SIG sig: CONT_SIG
}, function (err, res) { }, function (err, res) {
if (err) { if (err) {
console.log("discovery err: ", err.details); console.log("Discovery error: ", err.details);
orchestratorInfo = err.details; orchestratorInfo = err.details;
elapsed = null; elapsed = null;
} else { } else {
@ -191,7 +190,7 @@ const discoverOrchestrator = async function (target) {
} }
receivedResults = true; receivedResults = true;
}); });
while (!receivedResults && new Date().getTime() - start < 5000) { await sleep(200); } while (!receivedResults && new Date().getTime() - start < 4000) { await sleep(20); }
return { discoveryResults: orchestratorInfo, elapsed }; return { discoveryResults: orchestratorInfo, elapsed };
} }
@ -213,7 +212,7 @@ const pingOrchestrator = async function (target) {
} }
receivedResults = true; receivedResults = true;
}); });
while (!receivedResults && new Date().getTime() - start < 5000) { await sleep(200); } while (!receivedResults && new Date().getTime() - start < 4000) { await sleep(20); }
return { pingResults: pingPong, elapsed }; return { pingResults: pingPong, elapsed };
} }