equal
deleted
inserted
replaced
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 } |