diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-09-24 20:43:40 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-09-24 20:45:35 +0200 |
| commit | 28e27106d0fcddf31330ca0d2b30fe796f897470 (patch) | |
| tree | 2cec43aa72e9e25a62f08a1590b6e8c0a9675fe3 | |
| parent | 3a1c5a0ba111d3a144b17f2a06487b7e1e6684fe (diff) | |
| download | processor-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.js | 10 |
1 files changed, 5 insertions, 5 deletions
@@ -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); |
