From 42d77ccc199812f692d10d30a1eda1a81e5f235b Mon Sep 17 00:00:00 2001 From: schneefux Date: Mon, 24 Jul 2017 13:22:07 +0200 Subject: send matches to player cruncher --- worker.js | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/worker.js b/worker.js index 37cc25a..16f7708 100644 --- a/worker.js +++ b/worker.js @@ -26,6 +26,8 @@ const RABBITMQ_URI = process.env.RABBITMQ_URI, MAXCONNS = parseInt(process.env.MAXCONNS) || 10, // how many concurrent actions DOANALYZEMATCH = process.env.DOANALYZEMATCH == "true", ANALYZE_QUEUE = process.env.ANALYZE_QUEUE || "analyze", + DOCRUNCHMATCH = process.env.DOCRUNCHMATCH == "true", + CRUNCH_PLAYER_QUEUE = process.env.CRUNCH_PLAYER_QUEUE || "crunch_player", LOAD_TIMEOUT = parseFloat(process.env.LOAD_TIMEOUT) || 5000, // ms IDLE_TIMEOUT = parseFloat(process.env.IDLE_TIMEOUT) || 700; // ms @@ -275,6 +277,11 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { await Promise.each(match_objects, async (m) => await ch.sendToQueue(ANALYZE_QUEUE, new Buffer(m.id), { persistent: true })); + if (DOCRUNCHMATCH) { + await Promise.each(match_objects, async (m) => + await ch.sendToQueue(CRUNCH_PLAYER_QUEUE, new Buffer(m.id), + { persistent: true })); + } } catch (err) { if (err instanceof Seq.TimeoutError) { // deadlocks / timeout -- cgit v1.3.1