summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-09-24 20:43:40 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-09-24 20:45:35 +0200
commit28e27106d0fcddf31330ca0d2b30fe796f897470 (patch)
tree2cec43aa72e9e25a62f08a1590b6e8c0a9675fe3
parent3a1c5a0ba111d3a144b17f2a06487b7e1e6684fe (diff)
downloadprocessor-release/2.15.0.tar.gz
processor-release/2.15.0.zip
attempt to fix service stuck with 'nothing to do'release/2.15.0
-rw-r--r--worker.js10
1 files changed, 5 insertions, 5 deletions
diff --git a/worker.js b/worker.js
index 7e63343..1695fd0 100644
--- a/worker.js
+++ b/worker.js
@@ -228,16 +228,16 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
idle_timer = undefined;
load_timer = undefined;
- if (player_data.size + match_data.size == 0) {
- logger.info("buffers empty, nothing to do");
- return;
- }
-
const player_objects = new Set(player_data),
match_objects = new Set(match_data);
player_data.clear();
match_data.clear();
+ if (player_data.size + match_data.size == 0) {
+ logger.info("buffers empty, nothing to do");
+ return;
+ }
+
try {
await process(player_objects, match_objects);