src/Pure/Build/build_process.scala
changeset 79701 e8122e84aa58
parent 79698 b676998d7f97
child 79710 32ca3d1283de
equal deleted inserted replaced
79700:aeb53334f521 79701:e8122e84aa58
   783         Sessions.table,
   783         Sessions.table,
   784         Pending.table,
   784         Pending.table,
   785         Running.table,
   785         Running.table,
   786         Results.table)
   786         Results.table)
   787 
   787 
   788     val build_uuid_tables =
   788     private val build_uuid_tables =
   789       tables.filter(table =>
   789       tables.filter(table =>
   790         table.columns.exists(column => column.name == Generic.build_uuid.name))
   790         table.columns.exists(column => column.name == Generic.build_uuid.name))
   791 
   791 
   792     def pull_database(db: SQL.Database, worker_uuid: String, state: State): State = {
   792     def pull_database(db: SQL.Database, worker_uuid: String, state: State): State = {
   793       val serial_db = read_serial(db)
   793       val serial_db = read_serial(db)
   919   protected val log: Logger = Logger.make_system_log(progress, build_options)
   919   protected val log: Logger = Logger.make_system_log(progress, build_options)
   920 
   920 
   921   protected def open_build_cluster(): Build_Cluster =
   921   protected def open_build_cluster(): Build_Cluster =
   922     Build_Cluster.make(build_context, progress = build_progress).open()
   922     Build_Cluster.make(build_context, progress = build_progress).open()
   923 
   923 
   924   protected val _build_cluster =
   924   protected val _build_cluster: Build_Cluster =
   925     try {
   925     try {
   926       if (build_context.master && _build_database.isDefined) open_build_cluster()
   926       if (build_context.master && _build_database.isDefined) open_build_cluster()
   927       else Build_Cluster.none
   927       else Build_Cluster.none
   928     }
   928     }
   929     catch { case exn: Throwable => close(); throw exn }
   929     catch { case exn: Throwable => close(); throw exn }