From 974279959f104909b590d992e9ea102183fa7033 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joa=CC=83o=20Lui=CC=81s?= Date: Mon, 29 Aug 2016 11:15:06 +0100 Subject: [PATCH] Ignore tasksets that aren't running * This avoid unnecessary notifications of the master --- rrrspec-server/lib/rrrspec/server/worker_runner.rb | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/rrrspec-server/lib/rrrspec/server/worker_runner.rb b/rrrspec-server/lib/rrrspec/server/worker_runner.rb index dee3115..961dd87 100644 --- a/rrrspec-server/lib/rrrspec/server/worker_runner.rb +++ b/rrrspec-server/lib/rrrspec/server/worker_runner.rb @@ -178,9 +178,14 @@ def cleaning_process(logger, taskset, cancel_watcher_pid, pid_to_slave_number) def work @worker.update_current_taskset(nil) - taskset = @worker.dequeue_taskset - worker_log = WorkerLog.create(@worker, taskset) - logger = TimedLogger.new(worker_log) + + while true do + taskset = @worker.dequeue_taskset + worker_log = WorkerLog.create(@worker, taskset) + logger = TimedLogger.new(worker_log) + + break if taskset.status == 'running' + end check = proc do unless taskset.status == 'running'