{"header":{"message":"Basic remote building","description":"This removes the need for Nix's build-remote.pl.\n\nBuild logs are now written to $HYDRA_DATA/build-logs because\nhydra-queue-runner doesn't have write permission to /nix/var/log.","timestamp":"2015-06-09T12:21:21Z","authors":[{"email":"eelco.dolstra@logicblox.com","name":"Eelco Dolstra"}]},"hash":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","authors":[],"deps":{"hashes":[["5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","Basic remote building"],["AA",null],["O776XDS2CAQ6CMDEWAXU5ZGBH4ETZB77CODANQM233BARYWBRIXQC","Make getDrvLogPath work with both bucketed and non-bucketed nix logs."],["YZAI5GQU3HNMK5MEGF2Y7WS445AN4YKD3HNJQVQP545ODN3F5DLAC","Implement a database connection pool"],["ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC","Make concurrency more robust"],["NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC","Very basic multi-threaded queue runner"],["ZH6B56XRZON7AGKUPGKABU2SWOIQSYBTXVOMR66X6P6MG25Y4WZAC","Try harder to find build logs"],["Y6AHH4THYQA43V77L43YM42DYRPCMDSWLUV4NKWAQYMPL4NTUIPQC","Remove the logfile and logSize columns from the database"],["24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","Start of single-process hydra-queue-runner"],["T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC","On SIGINT, shut down the builder threads"],["62MQPRXCZCP7ZQKOOAFU5V36P7DBS6RCFDYK53PDCFGI4FAOQWMQC","Pass null values to libpqxx properly"],["2GK5DOU7ODF4WBSN3QTD3WIO52VTL2LOAXKGCDEMMAQPTEO4A4HAC","* Downloading closures."]],"deps":["O776XDS2CAQ6CMDEWAXU5ZGBH4ETZB77CODANQM233BARYWBRIXQC","YZAI5GQU3HNMK5MEGF2Y7WS445AN4YKD3HNJQVQP545ODN3F5DLAC"],"known":["Y6AHH4THYQA43V77L43YM42DYRPCMDSWLUV4NKWAQYMPL4NTUIPQC","ZH6B56XRZON7AGKUPGKABU2SWOIQSYBTXVOMR66X6P6MG25Y4WZAC","24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","62MQPRXCZCP7ZQKOOAFU5V36P7DBS6RCFDYK53PDCFGI4FAOQWMQC","NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC","ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC","T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC"]},"hunks":[{"Replacement":{"inode":{"change":4,"pos":219},"path":"src/hydra-queue-runner/Makefile.am","line":3,"ins":{"up_context":[{"change":4,"pos":255}],"down_context":[{"change":4,"pos":322}],"flag":"BLOCK","start":0,"end":83,"inode":{"change":4,"pos":219}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":255},"to":{"change":4,"start":255,"end":322},"introduced_by":4}],"inode":{"change":4,"pos":219}},"ins_contents":[{"Add":{"text":"hydra_queue_runner_SOURCES = hydra-queue-runner.cc build-result.cc build-remote.cc","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:82"}}],"del_contents":[{"Del":{"text":"hydra_queue_runner_SOURCES = hydra-queue-runner.cc build-result.cc","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:321"}}]}},{"FileAdd":{"meta":{"basename":"build-remote.cc","metadata":0},"context":[{"change":4,"pos":187}],"contents":[{"Add":{"text":"#include ","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:106"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:107"}},{"Add":{"text":"#include ","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:130"}},{"Add":{"text":"#include ","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:152"}},{"Add":{"text":"#include ","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:171"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:172"}},{"Add":{"text":"#include \"build-remote.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:199"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:200"}},{"Add":{"text":"#include \"util.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:219"}},{"Add":{"text":"#include \"misc.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:238"}},{"Add":{"text":"#include \"serve-protocol.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:267"}},{"Add":{"text":"#include \"worker-protocol.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:297"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:298"}},{"Add":{"text":"using namespace nix;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:319"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:320"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:321"}},{"Add":{"text":"struct Child","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:334"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:336"}},{"Add":{"text":" Pid pid;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:349"}},{"Add":{"text":" AutoCloseFD to, from;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:375"}},{"Add":{"text":"};","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:378"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:379"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:380"}},{"Add":{"text":"static void openConnection(const string & sshName, const string & sshKey,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:454"}},{"Add":{"text":" int stderrFD, Child & child)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:487"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:489"}},{"Add":{"text":" Pipe to, from;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:508"}},{"Add":{"text":" to.create();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:525"}},{"Add":{"text":" from.create();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:544"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:545"}},{"Add":{"text":" child.pid = startProcess([&]() {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:582"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:583"}},{"Add":{"text":" if (dup2(to.readSide, STDIN_FILENO) == -1)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:634"}},{"Add":{"text":" throw SysError(\"cannot dup input pipe to stdin\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:696"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:697"}},{"Add":{"text":" if (dup2(from.writeSide, STDOUT_FILENO) == -1)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:752"}},{"Add":{"text":" throw SysError(\"cannot dup output pipe to stdout\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:816"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:817"}},{"Add":{"text":" if (dup2(stderrFD, STDERR_FILENO) == -1)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:866"}},{"Add":{"text":" throw SysError(\"cannot dup stderr\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:915"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:916"}},{"Add":{"text":" Strings argv({\"ssh\", \"-x\", \"-a\", sshName, \"--\", \"nix-store\", \"--serve\", \"--write\"});","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1009"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1010"}},{"Add":{"text":" execvp(\"ssh\", (char * *) stringsToCharPtrs(argv).data()); // FIXME: remove cast","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1098"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1099"}},{"Add":{"text":" throw SysError(\"cannot start ssh\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1143"}},{"Add":{"text":" });","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1151"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1152"}},{"Add":{"text":" to.readSide.close();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1177"}},{"Add":{"text":" from.writeSide.close();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1205"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1206"}},{"Add":{"text":" child.to = to.writeSide.borrow();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1244"}},{"Add":{"text":" child.from = from.readSide.borrow();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1285"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1287"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1288"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1289"}},{"Add":{"text":"static void copyClosureTo(std::shared_ptr store,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1348"}},{"Add":{"text":" FdSource & from, FdSink & to, const PathSet & paths,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1405"}},{"Add":{"text":" bool useSubstitutes = false)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1438"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1440"}},{"Add":{"text":" PathSet closure;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1461"}},{"Add":{"text":" for (auto & path : paths)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1491"}},{"Add":{"text":" computeFSClosure(*store, path, closure);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1540"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1541"}},{"Add":{"text":" Paths sorted = topoSortPaths(*store, closure);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1592"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1593"}},{"Add":{"text":" /* Send the \"query valid paths\" command with the \"lock\" option","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1660"}},{"Add":{"text":" enabled. This prevents a race where the remote host","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1719"}},{"Add":{"text":" garbage-collect paths that are already there. Optionally, ask","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1788"}},{"Add":{"text":" the remote host to substitute missing paths. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1843"}},{"Add":{"text":" writeInt(cmdQueryValidPaths, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1881"}},{"Add":{"text":" writeInt(1, to); // == lock paths","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1919"}},{"Add":{"text":" writeInt(useSubstitutes, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1953"}},{"Add":{"text":" writeStrings(sorted, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1983"}},{"Add":{"text":" to.flush();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:1999"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2000"}},{"Add":{"text":" /* Get back the set of paths that are already valid on the remote","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2070"}},{"Add":{"text":" host. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2086"}},{"Add":{"text":" auto present = readStorePaths(from);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2136"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2137"}},{"Add":{"text":" PathSet missing;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2158"}},{"Add":{"text":" std::set_difference(closure.begin(), closure.end(), present.begin(), present.end(),","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2246"}},{"Add":{"text":" std::inserter(missing, missing.end()));","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2294"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2295"}},{"Add":{"text":" printMsg(lvlError, format(\"sending %1% missing paths\") % missing.size());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2373"}},{"Add":{"text":" if (missing.empty()) return;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2406"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2407"}},{"Add":{"text":" throw Error(\"NOT IMPL 1\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2438"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2440"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2441"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2442"}},{"Add":{"text":"static void copyClosureFrom(std::shared_ptr store,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2503"}},{"Add":{"text":" FdSource & from, FdSink & to, const PathSet & paths)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2560"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2562"}},{"Add":{"text":" writeInt(cmdExportPaths, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2596"}},{"Add":{"text":" writeInt(0, to); // == don't sign","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2634"}},{"Add":{"text":" writeStrings(paths, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2663"}},{"Add":{"text":" to.flush();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2679"}},{"Add":{"text":" store->importPaths(false, from);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2716"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2718"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2719"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2720"}},{"Add":{"text":"void buildRemote(std::shared_ptr store,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2770"}},{"Add":{"text":" const string & sshName, const string & sshKey,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2821"}},{"Add":{"text":" const Path & drvPath, const Derivation & drv,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2871"}},{"Add":{"text":" const nix::Path & logDir, RemoteResult & result)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2924"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2926"}},{"Add":{"text":" string base = baseNameOf(drvPath);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:2965"}},{"Add":{"text":" Path logFile = logDir + \"/\" + string(base, 0, 2) + \"/\" + string(base, 2);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3043"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3044"}},{"Add":{"text":" createDirs(dirOf(logFile));","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3076"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3077"}},{"Add":{"text":" AutoCloseFD logFD(open(logFile.c_str(), O_CREAT | O_TRUNC | O_WRONLY, 0666));","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3159"}},{"Add":{"text":" if (logFD == -1) throw SysError(format(\"creating log file ‘%1%’\") % logFile);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3245"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3246"}},{"Add":{"text":" Child child;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3263"}},{"Add":{"text":" openConnection(sshName, sshKey, logFD, child);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3314"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3315"}},{"Add":{"text":" logFD.close();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3334"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3335"}},{"Add":{"text":" FdSource from(child.from);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3366"}},{"Add":{"text":" FdSink to(child.to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3391"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3392"}},{"Add":{"text":" /* Handshake. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3413"}},{"Add":{"text":" writeInt(SERVE_MAGIC_1, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3446"}},{"Add":{"text":" writeInt(SERVE_PROTOCOL_VERSION, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3488"}},{"Add":{"text":" to.flush();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3504"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3505"}},{"Add":{"text":" unsigned int magic = readInt(from);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3545"}},{"Add":{"text":" if (magic != SERVE_MAGIC_2)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3577"}},{"Add":{"text":" throw Error(format(\"protocol mismatch with ‘nix-store --serve’ on ‘%1%’\") % sshName);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3679"}},{"Add":{"text":" unsigned int version = readInt(from);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3721"}},{"Add":{"text":" if (GET_PROTOCOL_MAJOR(version) != 0x200)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3767"}},{"Add":{"text":" throw Error(format(\"unsupported ‘nix-store --serve’ protocol version on ‘%1%’\") % sshName);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3875"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3876"}},{"Add":{"text":" /* Copy the input closure. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:3910"}},{"Add":{"text":" printMsg(lvlError, format(\"sending closure of ‘%1%’ to ‘%2%’\") % drvPath % sshName);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4007"}},{"Add":{"text":" copyClosureTo(store, from, to, PathSet({drvPath}));","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4063"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4064"}},{"Add":{"text":" /* Do the build. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4088"}},{"Add":{"text":" printMsg(lvlError, format(\"building ‘%1%’ on ‘%2%’\") % drvPath % sshName);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4175"}},{"Add":{"text":" writeInt(cmdBuildPaths, to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4208"}},{"Add":{"text":" writeStrings(PathSet({drvPath}), to);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4250"}},{"Add":{"text":" writeInt(3600, to); // == maxSilentTime, FIXME","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4301"}},{"Add":{"text":" writeInt(7200, to); // == buildTimeout, FIXME","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4351"}},{"Add":{"text":" to.flush();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4367"}},{"Add":{"text":" result.startTime = time(0);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4399"}},{"Add":{"text":" int res = readInt(from);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4428"}},{"Add":{"text":" result.stopTime = time(0);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4459"}},{"Add":{"text":" if (res) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4474"}},{"Add":{"text":" result.errorMsg = (format(\"%1% on ‘%2%’\") % readString(from) % sshName).str();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4565"}},{"Add":{"text":" if (res == 100) result.status = RemoteResult::rrPermanentFailure;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4639"}},{"Add":{"text":" else if (res == 101) result.status = RemoteResult::rrTimedOut;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4710"}},{"Add":{"text":" else result.status = RemoteResult::rrMiscFailure;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4768"}},{"Add":{"text":" return;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4784"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4790"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4791"}},{"Add":{"text":" /* Copy the output paths. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4824"}},{"Add":{"text":" printMsg(lvlError, format(\"copying outputs of ‘%1%’ from ‘%2%’\") % drvPath % sshName);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4923"}},{"Add":{"text":" PathSet outputs;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4944"}},{"Add":{"text":" for (auto & output : drv.outputs)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:4982"}},{"Add":{"text":" outputs.insert(output.second.path);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5026"}},{"Add":{"text":" copyClosureFrom(store, from, to, outputs);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5073"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5074"}},{"Add":{"text":" /* Shut down the connection. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5110"}},{"Add":{"text":" child.to.close();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5132"}},{"Add":{"text":" child.pid.wait(true);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5158"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5159"}},{"Add":{"text":" result.status = RemoteResult::rrSuccess;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5204"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5206"}}]}},{"FileAdd":{"meta":{"basename":"build-remote.hh","metadata":0},"context":[{"change":4,"pos":187}],"contents":[{"Add":{"text":"#pragma once","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5262"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5263"}},{"Add":{"text":"#include \"store-api.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5287"}},{"Add":{"text":"#include \"derivations.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5313"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5314"}},{"Add":{"text":"struct RemoteResult","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5334"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5336"}},{"Add":{"text":" enum {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5347"}},{"Add":{"text":" rrSuccess = 0,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5370"}},{"Add":{"text":" rrPermanentFailure = 1,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5402"}},{"Add":{"text":" rrTimedOut = 2,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5426"}},{"Add":{"text":" rrMiscFailure = 3","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5452"}},{"Add":{"text":" } status = rrMiscFailure;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5482"}},{"Add":{"text":" std::string errorMsg;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5508"}},{"Add":{"text":" time_t startTime = 0, stopTime = 0;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5548"}},{"Add":{"text":"};","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5551"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5552"}},{"Add":{"text":"void buildRemote(std::shared_ptr store,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5607"}},{"Add":{"text":" const std::string & sshName, const std::string & sshKey,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5668"}},{"Add":{"text":" const nix::Path & drvPath, const nix::Derivation & drv,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5728"}},{"Add":{"text":" const nix::Path & logDir, RemoteResult & result);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5782"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":11,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":4943}],"down_context":[{"change":4,"pos":0}],"flag":"BLOCK","start":5824,"end":5851,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":"#include \"build-remote.hh\"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5850"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":137,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":657}],"down_context":[{"change":4,"pos":5993}],"flag":"BLOCK","start":5852,"end":5920,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5852"}},{"Add":{"text":" std::atomic_bool destroyed;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5884"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5885"}},{"Add":{"text":" Step() : destroyed(false) { }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5919"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":145,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":745}],"down_context":[{"change":4,"pos":745}],"flag":"BLOCK","start":5921,"end":6293,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5926"}},{"Add":{"text":"};","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5929"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5930"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5931"}},{"Add":{"text":"struct Machine","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5946"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5948"}},{"Add":{"text":" typedef std::shared_ptr ptr;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5990"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:5991"}},{"Add":{"text":" std::string sshName, sshKey;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6024"}},{"Add":{"text":" std::set systemTypes, supportedFeatures, mandatoryFeatures;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6101"}},{"Add":{"text":" unsigned int maxJobs = 1;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6131"}},{"Add":{"text":" float speedFactor = 1.0;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6160"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6161"}},{"Add":{"text":" Sync currentJobs;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6197"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6198"}},{"Add":{"text":" Machine()","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6212"}},{"Add":{"text":" {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6218"}},{"Add":{"text":" auto currentJobs_(currentJobs.lock());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6265"}},{"Add":{"text":" *currentJobs_ = 0;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6292"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":168,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":6102}],"down_context":[{"change":4,"pos":6102}],"flag":"BLOCK","start":6294,"end":6787,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":"/* A RAII helper that manages the currentJobs field of Machine","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6356"}},{"Add":{"text":" objects. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6371"}},{"Add":{"text":"struct MachineReservation","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6397"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6399"}},{"Add":{"text":" typedef std::shared_ptr ptr;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6452"}},{"Add":{"text":" Machine::ptr machine;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6478"}},{"Add":{"text":" MachineReservation(Machine::ptr machine) : machine(machine)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6542"}},{"Add":{"text":" {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6548"}},{"Add":{"text":" auto currentJobs_(machine->currentJobs.lock());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6604"}},{"Add":{"text":" (*currentJobs_)++;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6631"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6637"}},{"Add":{"text":" ~MachineReservation()","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6663"}},{"Add":{"text":" {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6669"}},{"Add":{"text":" auto currentJobs_(machine->currentJobs.lock());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6725"}},{"Add":{"text":" if (*currentJobs_ > 0) (*currentJobs_)--;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6775"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6781"}},{"Add":{"text":"};","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6784"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6785"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6786"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":191,"ins":{"up_context":[{"change":4,"pos":911}],"down_context":[{"change":3,"pos":20}],"flag":"BLOCK","start":6788,"end":6816,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":911},"to":{"change":4,"start":911,"end":947},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" Path hydraData, logDir;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6815"}}],"del_contents":[{"Del":{"text":" std::thread queueMonitorThread;","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:946"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":214,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":96}],"down_context":[{"change":3,"pos":96}],"flag":"BLOCK","start":6817,"end":6939,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" /* CV for waking up the dispatcher. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6859"}},{"Add":{"text":" std::condition_variable dispatcherWakeup;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6905"}},{"Add":{"text":" std::mutex dispatcherMutex;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6937"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6938"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":221,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1020}],"down_context":[{"change":4,"pos":6420}],"flag":"BLOCK","start":6940,"end":7254,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" /* The build machines. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:6969"}},{"Add":{"text":" typedef std::list Machines;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7015"}},{"Add":{"text":" Sync machines;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7044"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7045"}},{"Add":{"text":" /* The currently active builder threads. FIXME: We could re-use","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7113"}},{"Add":{"text":" these, but since they're fairly long-running, it's probably not","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7184"}},{"Add":{"text":" worth it. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7204"}},{"Add":{"text":" // std::vector builderThreads;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7252"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7253"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":235,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":6457}],"down_context":[{"change":3,"pos":164}],"flag":"BLOCK","start":7255,"end":7281,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" void loadMachines();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7279"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7280"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":242,"ins":{"up_context":[{"change":4,"pos":6731}],"down_context":[{"change":4,"pos":6820}],"flag":"BLOCK","start":7282,"end":7389,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6731},"to":{"change":4,"start":6731,"end":6820},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" void finishBuildStep(pqxx::work & txn, time_t startTime, time_t stopTime, BuildID buildId, int stepNr,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7388"}}],"del_contents":[{"Del":{"text":" void finishBuildStep(pqxx::work & txn, time_t stopTime, BuildID buildId, int stepNr,","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:6819"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":261,"ins":{"up_context":[{"change":4,"pos":7289}],"down_context":[{"change":4,"pos":1304}],"flag":"BLOCK","start":7390,"end":7475,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":7289},"to":{"change":4,"start":1265,"end":1304},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" /* The thread that selects and starts runnable builds. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7451"}},{"Add":{"text":" void dispatcher();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7474"}}],"del_contents":[{"Del":{"text":" void builderThreadEntry(int slot);","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:1303"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":264,"ins":{"up_context":[{"change":4,"pos":1305}],"down_context":[{"change":4,"pos":7327}],"flag":"BLOCK","start":7476,"end":7503,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1305},"to":{"change":4,"start":1305,"end":1376},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" void wakeDispatcher();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7502"}}],"del_contents":[{"Del":{"text":" void doBuildStep(std::shared_ptr store, Step::ptr step);","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:1375"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":266,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":7328}],"down_context":[{"change":4,"pos":7328}],"flag":"BLOCK","start":7504,"end":7736,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" MachineReservation::ptr findMachine(Step::ptr step);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7560"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7561"}},{"Add":{"text":" void builder(Step::ptr step, MachineReservation::ptr reservation);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7632"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7633"}},{"Add":{"text":" void doBuildStep(std::shared_ptr store, Step::ptr step,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7703"}},{"Add":{"text":" Machine::ptr machine);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7734"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7735"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":282,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":7503}],"down_context":[{"change":4,"pos":7503}],"flag":"BLOCK","start":7737,"end":7892,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" hydraData = getEnv(\"HYDRA_DATA\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7774"}},{"Add":{"text":" if (hydraData == \"\") throw Error(\"$HYDRA_DATA must be set\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7839"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7840"}},{"Add":{"text":" logDir = canonPath(hydraData + \"/build-logs\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7891"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":298,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":7731}],"down_context":[{"change":4,"pos":7731}],"flag":"BLOCK","start":7893,"end":7999,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7893"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7894"}},{"Add":{"text":"void State::loadMachines()","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7921"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7923"}},{"Add":{"text":" Path machinesFile = getEnv(\"NIX_REMOTE_SYSTEMS\", \"/etc/nix/machines\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:7998"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":304,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":7732}],"down_context":[{"change":4,"pos":7732}],"flag":"BLOCK","start":8000,"end":8998,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" Machines newMachines;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8025"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8026"}},{"Add":{"text":" if (pathExists(machinesFile)) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8062"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8063"}},{"Add":{"text":" for (auto line : tokenizeString(readFile(machinesFile), \"\\n\")) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8145"}},{"Add":{"text":" line = trim(string(line, 0, line.find('#')));","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8203"}},{"Add":{"text":" auto tokens = tokenizeString>(line);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8277"}},{"Add":{"text":" if (tokens.size() < 3) continue;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8322"}},{"Add":{"text":" tokens.resize(7);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8352"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8353"}},{"Add":{"text":" auto machine = std::make_shared();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8409"}},{"Add":{"text":" machine->sshName = tokens[0];","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8451"}},{"Add":{"text":" machine->systemTypes = tokenizeString(tokens[1], \",\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8529"}},{"Add":{"text":" machine->sshKey = tokens[2];","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8570"}},{"Add":{"text":" if (tokens[3] != \"\")","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8603"}},{"Add":{"text":" string2Int(tokens[3], machine->maxJobs);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8660"}},{"Add":{"text":" else","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8677"}},{"Add":{"text":" machine->maxJobs = 1;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8715"}},{"Add":{"text":" machine->speedFactor = atof(tokens[4].c_str());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8775"}},{"Add":{"text":" machine->supportedFeatures = tokenizeString(tokens[5], \",\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8859"}},{"Add":{"text":" machine->mandatoryFeatures = tokenizeString(tokens[6], \",\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8943"}},{"Add":{"text":" newMachines.push_back(machine);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8987"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:8997"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":328,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":7733}],"down_context":[{"change":3,"pos":331}],"flag":"BLOCK","start":8999,"end":9443,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" } else {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9011"}},{"Add":{"text":" auto machine = std::make_shared();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9063"}},{"Add":{"text":" machine->sshName = \"localhost\";","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9103"}},{"Add":{"text":" machine->systemTypes = StringSet({settings.thisSystem});","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9168"}},{"Add":{"text":" if (settings.thisSystem == \"x86_64-linux\")","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9219"}},{"Add":{"text":" machine->systemTypes.insert(\"i686-linux\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9274"}},{"Add":{"text":" machine->maxJobs = settings.maxBuildJobs;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9324"}},{"Add":{"text":" newMachines.push_back(machine);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9364"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9370"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9371"}},{"Add":{"text":" auto machines_(machines.lock());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9408"}},{"Add":{"text":" *machines_ = newMachines;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9438"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9440"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9441"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9442"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":378,"ins":{"up_context":[{"change":4,"pos":9262}],"down_context":[{"change":4,"pos":9354}],"flag":"BLOCK","start":9444,"end":9554,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":9262},"to":{"change":4,"start":9262,"end":9354},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":"void State::finishBuildStep(pqxx::work & txn, time_t startTime, time_t stopTime, BuildID buildId, int stepNr,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9553"}}],"del_contents":[{"Del":{"text":"void State::finishBuildStep(pqxx::work & txn, time_t stopTime, BuildID buildId, int stepNr,","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:9353"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":381,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":9438}],"down_context":[{"change":4,"pos":391}],"flag":"BLOCK","start":9555,"end":9600,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" assert(startTime);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9577"}},{"Add":{"text":" assert(stopTime);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9599"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":384,"ins":{"up_context":[{"change":4,"pos":413}],"down_context":[{"change":4,"pos":414}],"flag":"BLOCK","start":9601,"end":9757,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":413},"to":{"change":4,"start":9471,"end":9611},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":9471},"to":{"change":4,"start":9471,"end":9611},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" (\"update BuildSteps set busy = 0, status = $1, propagatedFrom = $4, errorMsg = $5, startTime = $6, stopTime = $7 where build = $2 and stepnr = $3\")","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9756"}}],"del_contents":[{"Del":{"text":" (\"update BuildSteps set busy = 0, status = $1, propagatedFrom = $4, errorMsg = $5, stopTime = $6 where build = $2 and stepnr = $3\")","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:9610"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":388,"ins":{"up_context":[{"change":4,"pos":535}],"down_context":[{"change":4,"pos":9821}],"flag":"BLOCK","start":9758,"end":9796,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":535},"to":{"change":4,"start":535,"end":577},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" (startTime)(stopTime).exec();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9795"}}],"del_contents":[{"Del":{"text":" (stopTime, stopTime != 0).exec();","pos":"62MQPRXCZCP7ZQKOOAFU5V36P7DBS6RCFDYK53PDCFGI4FAOQWMQC:576"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":464,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":10582}],"down_context":[{"change":3,"pos":606}],"flag":"BLOCK","start":9797,"end":9876,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" printMsg(lvlInfo, format(\"aborting GC'ed build %1%\") % build->id);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9875"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":484,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":2064}],"down_context":[{"change":4,"pos":11213}],"flag":"BLOCK","start":9877,"end":9949,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9877"}},{"Add":{"text":" printMsg(lvlInfo, format(\"cached build %1%\") % build->id);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:9948"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":506,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":3558}],"down_context":[{"change":4,"pos":3558}],"flag":"BLOCK","start":9950,"end":10111,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" printMsg(lvlInfo, format(\"added build %1% (top-level step %2%, %3% new runnable steps)\")","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10046"}},{"Add":{"text":" % build->id % step->drvPath % newRunnable.size());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10109"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10110"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":586,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":12643}],"down_context":[{"change":4,"pos":5073}],"flag":"BLOCK","start":10112,"end":10174,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" if (step->destroyed) return;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10144"}},{"Add":{"text":" step->destroyed = true;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10172"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10173"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":674,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":14048}],"down_context":[{"change":4,"pos":6558}],"flag":"BLOCK","start":10175,"end":10257,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" printMsg(lvlInfo, format(\"step ‘%1%’ is now runnable\") % step->drvPath);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10255"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10256"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":686,"ins":{"up_context":[{"change":4,"pos":2459}],"down_context":[{"change":4,"pos":14262}],"flag":"BLOCK","start":10258,"end":10280,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2459},"to":{"change":4,"start":396,"end":429},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" wakeDispatcher();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10279"}}],"del_contents":[{"Del":{"text":" runnableWakeup.notify_one();","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:428"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":690,"ins":{"up_context":[{"change":4,"pos":14266}],"down_context":[{"change":4,"pos":2530}],"flag":"BLOCK","start":10281,"end":10306,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":14266},"to":{"change":4,"start":2489,"end":2530},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":"void State::dispatcher()","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10305"}}],"del_contents":[{"Del":{"text":"void State::builderThreadEntry(int slot)","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:2529"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":692,"ins":{"up_context":[{"change":4,"pos":2532}],"down_context":[{"change":4,"pos":2577}],"flag":"BLOCK","start":10307,"end":10387,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2532},"to":{"change":4,"start":2532,"end":2577},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" while (!exitRequested) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10335"}},{"Add":{"text":" printMsg(lvlError, \"dispatcher woken up\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10386"}}],"del_contents":[{"Del":{"text":" auto store = openStore(); // FIXME: pool","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:2576"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":695,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2578},"to":{"change":4,"start":2578,"end":2598},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2598},"to":{"change":4,"start":6726,"end":6793},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":6793},"to":{"change":4,"start":2598,"end":2622},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2598},"to":{"change":4,"start":2598,"end":2622},"introduced_by":4}],"inode":{"change":4,"pos":4840}}},"contents":[{"Del":{"text":" while (true) {","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:2597"}},{"Del":{"text":" /* Sleep until a runnable build step becomes available. */","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:6792"}},{"Del":{"text":" Step::ptr step;","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:2621"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":697,"ins":{"up_context":[{"change":4,"pos":6839}],"down_context":[{"change":4,"pos":2842}],"flag":"BLOCK","start":10388,"end":11503,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6839},"to":{"change":4,"start":430,"end":573},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":573},"to":{"change":4,"start":6922,"end":7068},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6922},"to":{"change":4,"start":6922,"end":7068},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" printMsg(lvlError, format(\"%1% runnable builds\") % runnable_->size());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10470"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10471"}},{"Add":{"text":" /* FIXME: we're holding the runnable lock too long","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10534"}},{"Add":{"text":" here. This could be more efficient. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10588"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10589"}},{"Add":{"text":" for (auto i = runnable_->begin(); i != runnable_->end(); ) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10662"}},{"Add":{"text":" auto step = i->lock();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10701"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10702"}},{"Add":{"text":" /* Delete dead steps. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10743"}},{"Add":{"text":" if (!step) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10772"}},{"Add":{"text":" i = runnable_->erase(i);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10817"}},{"Add":{"text":" continue;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10847"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10865"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10866"}},{"Add":{"text":" auto reservation = findMachine(step);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10920"}},{"Add":{"text":" if (!reservation) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:10956"}},{"Add":{"text":" printMsg(lvlError, format(\"cannot execute step ‘%1%’ right now\") % step->drvPath);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11063"}},{"Add":{"text":" ++i;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11088"}},{"Add":{"text":" continue;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11118"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11136"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11137"}},{"Add":{"text":" printMsg(lvlInfo, format(\"WOOHOO: starting step ‘%1%’ on machine ‘%2%’\")","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11234"}},{"Add":{"text":" % step->drvPath % reservation->machine->sshName);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11304"}},{"Add":{"text":" i = runnable_->erase(i);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11345"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11346"}},{"Add":{"text":" auto builderThread = std::thread(&State::builder, this, step, reservation);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11438"}},{"Add":{"text":" builderThread.detach(); // FIXME?","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11488"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11502"}}],"del_contents":[{"Del":{"text":" while (runnable_->empty() && !exitRequested)","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:486"}},{"Del":{"text":" runnable_.wait(runnableWakeup);","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:534"}},{"Del":{"text":" if (exitRequested) break;","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:572"}},{"Del":{"text":" auto weak = *runnable_->begin();","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:6966"}},{"Del":{"text":" runnable_->pop_front();","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:7002"}},{"Del":{"text":" step = weak.lock();","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:7034"}},{"Del":{"text":" if (!step) continue;","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:7067"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":727,"ins":{"up_context":[{"change":4,"pos":2853}],"down_context":[{"change":4,"pos":2985}],"flag":"BLOCK","start":11504,"end":11754,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2853},"to":{"change":4,"start":7069,"end":7093},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":7093},"to":{"change":4,"start":2853,"end":2950},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2853},"to":{"change":4,"start":2853,"end":2950},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2951},"to":{"change":4,"start":2951,"end":2985},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" /* Sleep until we're woken up (either because a runnable build","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11574"}},{"Add":{"text":" is added, or because a build finishes). */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11628"}},{"Add":{"text":" {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11638"}},{"Add":{"text":" std::unique_lock lock(dispatcherMutex);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11702"}},{"Add":{"text":" dispatcherWakeup.wait(lock);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11743"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11753"}}],"del_contents":[{"Del":{"text":" /* Build it. */","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:7092"}},{"Del":{"text":" printMsg(lvlError, format(\"slot %1%: got build step ‘%2%’\") % slot % step->drvPath);","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:2949"}},{"Del":{"text":" doBuildStep(store, step);","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:2984"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":735,"ins":{"up_context":[{"change":4,"pos":2992}],"down_context":[{"change":4,"pos":3040}],"flag":"BLOCK","start":11755,"end":11939,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2992},"to":{"change":4,"start":2992,"end":3040},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" printMsg(lvlError, \"dispatcher exits\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11798"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11800"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11801"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11802"}},{"Add":{"text":"void State::wakeDispatcher()","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11831"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11833"}},{"Add":{"text":" { std::lock_guard lock(dispatcherMutex); } // barrier","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11903"}},{"Add":{"text":" dispatcherWakeup.notify_all();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11938"}}],"del_contents":[{"Del":{"text":" printMsg(lvlError, \"builder thread exits\");","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:3039"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":746,"ins":{"up_context":[{"change":4,"pos":3044}],"down_context":[{"change":4,"pos":14306}],"flag":"BLOCK","start":11940,"end":13242,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3044},"to":{"change":4,"start":3044,"end":3117},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":"MachineReservation::ptr State::findMachine(Step::ptr step)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:11998"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12000"}},{"Add":{"text":" auto machines_(machines.lock());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12037"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12038"}},{"Add":{"text":" for (auto & machine : *machines_) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12078"}},{"Add":{"text":" if (!has(machine->systemTypes, step->drv.platform)) continue;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12148"}},{"Add":{"text":" // FIXME: check features","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12181"}},{"Add":{"text":" {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12191"}},{"Add":{"text":" auto currentJobs_(machine->currentJobs.lock());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12251"}},{"Add":{"text":" if (*currentJobs_ >= machine->maxJobs) continue;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12312"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12322"}},{"Add":{"text":" return std::make_shared(machine);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12384"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12390"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12391"}},{"Add":{"text":" /* FIXME: distinguish between permanent failures (a matching","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12456"}},{"Add":{"text":" machine doesn't exist) and temporary failures (a matching","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12521"}},{"Add":{"text":" machine is not available). */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12558"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12559"}},{"Add":{"text":" return 0;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12573"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12575"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12576"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12577"}},{"Add":{"text":"void State::builder(Step::ptr step, MachineReservation::ptr reservation)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12650"}},{"Add":{"text":"{","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12652"}},{"Add":{"text":" try {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12662"}},{"Add":{"text":" auto store = openStore(); // FIXME: pool","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12711"}},{"Add":{"text":" doBuildStep(store, step, reservation->machine);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12767"}},{"Add":{"text":" } catch (std::exception & e) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12802"}},{"Add":{"text":" printMsg(lvlError, format(\"build thread for ‘%1%’: %2%\") % step->drvPath % e.what());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12900"}},{"Add":{"text":" // FIXME: put step back in runnable and retry","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12954"}},{"Add":{"text":" }","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12960"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:12961"}},{"Add":{"text":" /* Release the machine and wake up the dispatcher. */","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13019"}},{"Add":{"text":" assert(reservation.unique());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13053"}},{"Add":{"text":" reservation = 0;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13074"}},{"Add":{"text":" wakeDispatcher();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13096"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13097"}},{"Add":{"text":" printMsg(lvlError, \"builder exits\");","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13138"}},{"Add":{"text":"}","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13140"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13141"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13142"}},{"Add":{"text":"void State::doBuildStep(std::shared_ptr store, Step::ptr step,","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13215"}},{"Add":{"text":" Machine::ptr machine)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13241"}}],"del_contents":[{"Del":{"text":"void State::doBuildStep(std::shared_ptr store, Step::ptr step)","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:3116"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":825,"ins":{"up_context":[{"change":3,"pos":707}],"down_context":[{"change":4,"pos":15550}],"flag":"BLOCK","start":13243,"end":13300,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":707},"to":{"change":4,"start":15518,"end":15550},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15518},"to":{"change":4,"start":15518,"end":15550},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" RemoteResult result;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13267"}},{"Add":{"text":" result.startTime = time(0);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13299"}}],"del_contents":[{"Del":{"text":" time_t startTime = time(0);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15549"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":830,"ins":{"up_context":[{"change":3,"pos":739}],"down_context":[{"change":4,"pos":15674}],"flag":"BLOCK","start":13301,"end":13380,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":739},"to":{"change":4,"start":15602,"end":15674},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15602},"to":{"change":4,"start":15602,"end":15674},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" stepNr = createBuildStep(txn, result.startTime, build, step, bssBusy);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13379"}}],"del_contents":[{"Del":{"text":" stepNr = createBuildStep(txn, startTime, build, step, bssBusy);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15673"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":834,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15703},"to":{"change":4,"start":15703,"end":15755},"introduced_by":4}],"inode":{"change":4,"pos":4840}}},"contents":[{"Del":{"text":" bool success = false;","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15728"}},{"Del":{"text":" std::string errorMsg;","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15754"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":835,"ins":{"up_context":[{"change":4,"pos":15765}],"down_context":[{"change":4,"pos":15842}],"flag":"BLOCK","start":13381,"end":13486,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15765},"to":{"change":4,"start":15765,"end":15842},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" buildRemote(store, machine->sshName, machine->sshKey, step->drvPath, step->drv, logDir, result);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13485"}}],"del_contents":[{"Del":{"text":" store->buildPaths(PathSet({step->drvPath}));","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15817"}},{"Del":{"text":" success = true;","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15841"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":837,"ins":{"up_context":[{"change":4,"pos":15868}],"down_context":[{"change":4,"pos":15896}],"flag":"BLOCK","start":13487,"end":13652,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15868},"to":{"change":4,"start":15868,"end":15896},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" result.status = RemoteResult::rrMiscFailure;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13539"}},{"Add":{"text":" result.errorMsg = e.msg();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13574"}},{"Add":{"text":" printMsg(lvlError, format(\"ERROR: %1%\") % e.msg());","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13634"}},{"Add":{"text":" abort();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13651"}}],"del_contents":[{"Del":{"text":" errorMsg = e.msg();","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15895"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":843,"ins":{"up_context":[{"change":4,"pos":15903}],"down_context":[{"change":4,"pos":15934}],"flag":"BLOCK","start":13653,"end":13706,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15903},"to":{"change":4,"start":15903,"end":15934},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" if (!result.stopTime) result.stopTime = time(0);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13705"}}],"del_contents":[{"Del":{"text":" time_t stopTime = time(0);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:15933"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":846,"ins":{"up_context":[{"change":4,"pos":15956}],"down_context":[{"change":4,"pos":16006}],"flag":"BLOCK","start":13707,"end":13797,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":15956},"to":{"change":4,"start":3118,"end":3175},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" if (result.status == RemoteResult::rrSuccess) res = getBuildResult(store, step->drv);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13796"}}],"del_contents":[{"Del":{"text":" if (success) res = getBuildResult(store, step->drv);","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:3174"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":877,"ins":{"up_context":[{"change":4,"pos":16153}],"down_context":[{"change":4,"pos":16176}],"flag":"BLOCK","start":13798,"end":13854,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16153},"to":{"change":4,"start":16153,"end":16176},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" if (result.status == RemoteResult::rrSuccess) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13853"}}],"del_contents":[{"Del":{"text":" if (success) {","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:16175"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":879,"ins":{"up_context":[{"change":4,"pos":16177}],"down_context":[{"change":4,"pos":16252}],"flag":"BLOCK","start":13855,"end":13955,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16177},"to":{"change":4,"start":16177,"end":16252},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" finishBuildStep(txn, result.startTime, result.stopTime, build->id, stepNr, bssSuccess);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:13954"}}],"del_contents":[{"Del":{"text":" finishBuildStep(txn, stopTime, build->id, stepNr, bssSuccess);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:16251"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":884,"ins":{"up_context":[{"change":4,"pos":9047}],"down_context":[{"change":4,"pos":16587}],"flag":"BLOCK","start":13956,"end":14052,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":9047},"to":{"change":4,"start":16491,"end":16573},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16491},"to":{"change":4,"start":16491,"end":16573},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" markSucceededBuild(txn, build2, res, false, result.startTime, result.stopTime);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14051"}}],"del_contents":[{"Del":{"text":" markSucceededBuild(txn, build2, res, false, startTime, stopTime);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:16572"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":889,"ins":{"up_context":[{"change":4,"pos":16702}],"down_context":[{"change":4,"pos":16786}],"flag":"BLOCK","start":14053,"end":14169,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16702},"to":{"change":4,"start":16702,"end":16786},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" finishBuildStep(txn, result.startTime, result.stopTime, build->id, stepNr, bssFailed, result.errorMsg);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14168"}}],"del_contents":[{"Del":{"text":" finishBuildStep(txn, stopTime, build->id, stepNr, bssFailed, errorMsg);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:16785"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":893,"ins":{"up_context":[{"change":4,"pos":16875}],"down_context":[{"change":4,"pos":16969}],"flag":"BLOCK","start":14170,"end":14278,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16875},"to":{"change":4,"start":16875,"end":16969},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" createBuildStep(txn, result.stopTime, build2, step, bssFailed, result.errorMsg, build->id);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14277"}}],"del_contents":[{"Del":{"text":" createBuildStep(txn, stopTime, build2, step, bssFailed, errorMsg, build->id);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:16968"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":898,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":9139}],"down_context":[{"change":4,"pos":17101}],"flag":"BLOCK","start":14279,"end":14367,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" printMsg(lvlError, format(\"marking build %1% as failed\") % build2->id);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14366"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":903,"ins":{"up_context":[{"change":4,"pos":17393}],"down_context":[{"change":4,"pos":17464}],"flag":"BLOCK","start":14368,"end":14453,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":17393},"to":{"change":4,"start":17393,"end":17464},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" (result.startTime)","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14406"}},{"Add":{"text":" (result.stopTime).exec();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14452"}}],"del_contents":[{"Del":{"text":" (startTime)","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:17424"}},{"Del":{"text":" (stopTime).exec();","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:17463"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":917,"ins":{"up_context":[{"change":4,"pos":9426}],"down_context":[{"change":4,"pos":9478}],"flag":"BLOCK","start":14454,"end":14538,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":9426},"to":{"change":4,"start":9426,"end":9478},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" if (build2->toplevel == step || result.status != RemoteResult::rrSuccess) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14537"}}],"del_contents":[{"Del":{"text":" if (build2->toplevel == step || !success) {","pos":"ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC:9477"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":925,"ins":{"up_context":[{"change":4,"pos":9718}],"down_context":[{"change":4,"pos":17669}],"flag":"BLOCK","start":14539,"end":14604,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":9718},"to":{"change":4,"start":17637,"end":17669},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":17637},"to":{"change":4,"start":17637,"end":17669},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" destroyStep(step, result.status == RemoteResult::rrSuccess);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14603"}}],"del_contents":[{"Del":{"text":" destroyStep(step, success);","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:17668"}}]}},{"Edit":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":932,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":17826}],"down_context":[{"change":4,"pos":578}],"flag":"BLOCK","start":14605,"end":14684,"inode":{"change":4,"pos":4840}}},"contents":[{"Add":{"text":" printMsg(lvlError, format(\"marking build %1% as succeeded\") % build->id);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14682"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14683"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":969,"ins":{"up_context":[{"change":4,"pos":3286}],"down_context":[{"change":4,"pos":3363}],"flag":"BLOCK","start":14685,"end":14705,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3286},"to":{"change":4,"start":574,"end":640},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" loadMachines();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14704"}}],"del_contents":[{"Del":{"text":" queueMonitorThread = std::thread(&State::queueMonitor, this);","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:639"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":971,"ins":{"up_context":[{"change":4,"pos":3364}],"down_context":[{"change":4,"pos":771}],"flag":"BLOCK","start":14706,"end":14845,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3364},"to":{"change":4,"start":641,"end":686},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":686},"to":{"change":4,"start":3379,"end":3411},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3379},"to":{"change":4,"start":3379,"end":3411},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3411},"to":{"change":4,"start":687,"end":771},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" auto queueMonitorThread = std::thread(&State::queueMonitor, this);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14776"}},{"Add":{"text":"","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14777"}},{"Add":{"text":" auto dispatcherThread = std::thread(&State::dispatcher, this);","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14844"}}],"del_contents":[{"Del":{"text":" std::vector builderThreads;","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:685"}},{"Del":{"text":" for (int n = 0; n < 4; n++)","pos":"NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC:3410"}},{"Del":{"text":" builderThreads.push_back(std::thread(&State::builderThreadEntry, this, n));","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:770"}}]}},{"Replacement":{"inode":{"change":4,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":989,"ins":{"up_context":[{"change":4,"pos":1131}],"down_context":[{"change":3,"pos":811}],"flag":"BLOCK","start":14846,"end":14897,"inode":{"change":4,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1131},"to":{"change":4,"start":1131,"end":1272},"introduced_by":4}],"inode":{"change":4,"pos":4840}},"ins_contents":[{"Add":{"text":" wakeDispatcher();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14867"}},{"Add":{"text":" dispatcherThread.join();","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14896"}}],"del_contents":[{"Del":{"text":" { auto runnable_(runnable.lock()); } // barrier","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:1182"}},{"Del":{"text":" runnableWakeup.notify_all();","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:1215"}},{"Del":{"text":" for (auto & thread : builderThreads) thread.join();","pos":"T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC:1271"}}]}},{"Replacement":{"inode":{"change":12,"pos":436},"path":"src/lib/Hydra/Helper/Nix.pm","line":136,"ins":{"up_context":[{"change":2,"pos":132}],"down_context":[{"change":2,"pos":251}],"flag":"BLOCK","start":14898,"end":15096,"inode":{"change":12,"pos":436}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":132},"to":{"change":2,"start":132,"end":251},"introduced_by":2}],"inode":{"change":12,"pos":436}},"ins_contents":[{"Add":{"text":" my $fn2 = Hydra::Model::DB::getHydraPath . \"/build-logs/\";","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:14960"}},{"Add":{"text":" for ($fn2 . $bucketed, $fn . $bucketed . \".bz2\", $fn . $bucketed, $fn . $base . \".bz2\", $fn . $base) {","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:15067"}},{"Add":{"text":" return $_ if -f $_;","pos":"5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC:15095"}}],"del_contents":[{"Del":{"text":" for ($fn . $bucketed . \".bz2\", $fn . $bucketed, $fn . $base . \".bz2\", $fn . $base) {","pos":"O776XDS2CAQ6CMDEWAXU5ZGBH4ETZB77CODANQM233BARYWBRIXQC:220"}},{"Del":{"text":" return $_ if (-f $_);","pos":"O776XDS2CAQ6CMDEWAXU5ZGBH4ETZB77CODANQM233BARYWBRIXQC:250"}}]}}],"owner":"grahamc","repo":"hydra2","token":"MmPqGu0HVmhtPY410+RIJ0cAYvuVqseh94vzQy2TF+o=","login":null}

…

Dependencies

Change contents

Review