equal
deleted
inserted
replaced
1059 progress.echo("Waiting for external workers ...") |
1059 progress.echo("Waiting for external workers ...") |
1060 } |
1060 } |
1061 |
1061 |
1062 try { |
1062 try { |
1063 while (!finished()) { |
1063 while (!finished()) { |
1064 if (progress.stopped) synchronized_database { _state.stop_running() } |
1064 synchronized_database { |
1065 |
1065 if (progress.stopped) _state.stop_running() |
1066 for (build <- synchronized_database { _state.finished_running() }) { |
1066 |
1067 val job_name = build.job_name |
1067 for (build <- _state.finished_running()) { |
1068 val (process_result, output_shasum) = build.join |
1068 val job_name = build.job_name |
1069 synchronized_database { |
1069 val (process_result, output_shasum) = build.join |
1070 _state = _state. |
1070 _state = _state. |
1071 remove_pending(job_name). |
1071 remove_pending(job_name). |
1072 remove_running(job_name). |
1072 remove_running(job_name). |
1073 make_result(job_name, process_result, output_shasum, node_info = build.node_info) |
1073 make_result(job_name, process_result, output_shasum, node_info = build.node_info) |
1074 } |
1074 } |