src/Pure/Build/build_manager.scala
changeset 80644 6a996ad11af2
parent 80575 01edf83f6dee
child 80645 a1dce0cc6c26
equal deleted inserted replaced
80643:11b8f2e4c3d2 80644:6a996ad11af2
   931           val timeout_msg = "Timeout after " + job.timeout.message_hms
   931           val timeout_msg = "Timeout after " + job.timeout.message_hms
   932           store.report(job.kind, job.id).progress.echo_error_message(timeout_msg)
   932           store.report(job.kind, job.id).progress.echo_error_message(timeout_msg)
   933           echo(job.name + ": " + timeout_msg)
   933           echo(job.name + ": " + timeout_msg)
   934         }
   934         }
   935 
   935 
   936         val cancelled = for (name <- state.running if _state.running(name).cancelled) yield name
   936         val cancelled =
   937         state.cancel(cancelled)
   937           for {
       
   938             name <- state.running
       
   939             job = _state.running(name)
       
   940             if job.cancelled
       
   941           } yield job
       
   942 
       
   943         cancelled.foreach(job => store.report(job.kind, job.id).progress.echo("Cancelling ..."))
       
   944         state.cancel(cancelled.map(_.name))
   938       }
   945       }
   939 
   946 
   940     private def finish_job(name: String, process_result: Process_Result): Unit =
   947     private def finish_job(name: String, process_result: Process_Result): Unit =
   941       synchronized_database("finish_job") {
   948       synchronized_database("finish_job") {
   942         val job = _state.running(name)
   949         val job = _state.running(name)