equal
deleted
inserted
replaced
439 if (progress.stopped) stop_running() |
439 if (progress.stopped) stop_running() |
440 |
440 |
441 for (job <- finished_running()) finish_job(job) |
441 for (job <- finished_running()) finish_job(job) |
442 |
442 |
443 next_pending() match { |
443 next_pending() match { |
444 case Some(session_name) => start_job(session_name) |
444 case Some(name) => start_job(name) |
445 case None => sleep() |
445 case None => sleep() |
446 } |
446 } |
447 } |
447 } |
448 synchronized { |
448 synchronized { |
449 for ((name, result) <- _state.results) yield name -> result.process_result |
449 for ((name, result) <- _state.results) yield name -> result.process_result |