{"header":{"message":"hydra-queue-runner: Write directly to a binary cache","description":null,"timestamp":"2016-02-15T20:10:29Z","authors":[{"email":"eelco.dolstra@logicblox.com","name":"Eelco Dolstra"}]},"hash":"73YR46NJNYZQKHA3QDJCAZYAKC2CGEF5LIS44NOIPDZU6FX6BDPQC","authors":[],"deps":{"hashes":[["73YR46NJNYZQKHA3QDJCAZYAKC2CGEF5LIS44NOIPDZU6FX6BDPQC","hydra-queue-runner: Write directly to a binary cache"],["AA",null],["DWFTK56EAGNPSKWWWY5MFPATQWO5PZGHF5D53JOEJ2DG5NLLYRBQC","Keep track of how many threads are waiting"],["X6FOUYFJ5ODEOMHLL6AHM6KI2JRZ2XOI76NYJYJNDUQBTV5UJLBAC","int2String -> std::to_string"],["DKJFD6JNNK5LJMRGQABMJZKMFZLGY3ADKJWF6J4BBHEUPY3NB67QC","Process Nix API changes"],["ZK76B5ZZCEOJQUDOVKDZPE6IN2YIXQONFUIJ633OAXNC73OG3YSAC","Load the queue in order of global priority"],["6TY4LNHHAUSZNFDN34CHUWMZSQN5I3LNOOSV457M44FDGZB76X4AC","Finish copyClosure"],["A2GL5FOZ3UJ2NM5RPRWTNPFTKLBA54B2UC6UIYO4M3N3RFNC4BTAC","Moar stats"],["7VQ4ALFYKJBFR46T3WZDMGOXNRR3QNJEJQVBYJM4HSJUOOUD6WBQC","Update \"make check\" for the new queue runner"],["IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC","Revive jobset scheduling"],["4CQWOODYIBUEMPSLWTXZPZZTQBYYRGCORKLY4SKG2WVCVXGT654QC","Don't abort steps that have an unsupported system type"],["YR2IM6Y5XA6XDFBWJUFSVNMQQKLIW6A2LDS4F77A3OZLEMBACCRAC","Temporarily disable machines after a connection failure"],["OG3Z3QGCG2FNDGF4VQYWOXLZCF7LGTZCUMGKUCBNAPAQ5FRFHQ2AC","Namespace cleanup"],["CNLNT3T4IXU42GAC64CU5CEDTDLM2SHSJZEVHTMOCWYFXSQNC76QC","Allow only 1 thread to send a closure to a given machine at the same time"],["N4IROACVZ4MU73J5SM6WXJMKQSFR3VN5SOKENNNZNEGMTGB2Q3HAC","Move buildRemote() into State"],["H7SZRHUBSEDJ3PQ3VOV4ZEEFUWTBPGZN53G6W26HHXPJDO7MSHJAC","Use nix::willBuildLocally()"],["NAYQT2GTCJPBFRSK7CBFX655F2NGTBPICJSCYG2CSCQ5NRDHZG6QC","hydra-queue-runner: Use cmdBuildDerivation"],["24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","Start of single-process hydra-queue-runner"],["TPNHTE5VJ36IPKMFENDERDBFBHLYFXOVNDLV2QSC4G5STPPMBLMAC","Remove obsolete Builds columns and provide accurate \"Running builds\""],["OCZ4LSGGSCMSLGC3C32D5JUYYHS5CIPOKOAMADEFAFZOFXJ3YY3AC","Automatically retry aborted builds"],["EYR3EW6JVHNVLXMI57FUVPHQAHPETBML4H44OGJFHUT54KTTHIGQC","Keep stats for the Hydra auto scaler"],["VQISTKOPNAEUS2K2F73CMNNLGZATWUYIURD5CSVNBNF7Q5ZF4PXQC","hydra-queue-runner: Use substitutes"],["RND7XFNHXVORJ6JPEHGS7PCIW7DMOTWMZQPTEMXWLR7CZUQ2VCQQC","getQueuedBuilds(): Periodically stop to handle priority bumps"],["WE5Q2NVIIK4R2DUUZYLJFQVYK5O26EDEJRPK3CPGWHU3SEAC2DQAC","Allow build to be bumped to the front of the queue via the web interface"],["5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","Basic remote building"],["HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","Refactor"],["ACBS7C6QGXAMPLQ336WAQMMGLZXBDNNYPE26ZBPUQ24GL4BF643AC","hydra-queue-runner: Detect changes to the scheduling shares"],["LE4VZIY5VZ52FOP5QQRIJINWIMWTAPRTZTGO77JXUEPGRPRSQYMAC","More stats"],["MB3TISH2KYBIGY6XJKMN4HO2S6TCN2GORJENMECCKLXGGIRS2O2AC","Rate-limit the number of threads copying closures at the same time"],["SODOV2CMWA4JMIKRQNJ6MD3U3BS2XTSLINLRAG4SFY742IIJNI5QC","Automatically reload $NIX_REMOTE_SYSTEMS when it changes"],["MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","Split hydra-queue-runner.cc more"],["O3NM62IZE5EMW4KY56TV53BUZZL2NHAC55W7NBPTD7A4CKT4CHUQC","Support multiple machines files"],["YHP5DSOOKAXAYHUDMYO6EKX2YAN7DLDQPJX5K52TCP7EXQVP6JAAC","Improve parsing of hydra-build-products"],["T5BIOVJEMBIASP7EKQVV2N3VD6I56UXH6LCD5I33BDQEVHJAMGKQC","Add support for tracking custom metrics"],["ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC","Make concurrency more robust"]],"deps":["DWFTK56EAGNPSKWWWY5MFPATQWO5PZGHF5D53JOEJ2DG5NLLYRBQC","X6FOUYFJ5ODEOMHLL6AHM6KI2JRZ2XOI76NYJYJNDUQBTV5UJLBAC","DKJFD6JNNK5LJMRGQABMJZKMFZLGY3ADKJWF6J4BBHEUPY3NB67QC"],"known":["24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","6TY4LNHHAUSZNFDN34CHUWMZSQN5I3LNOOSV457M44FDGZB76X4AC","OCZ4LSGGSCMSLGC3C32D5JUYYHS5CIPOKOAMADEFAFZOFXJ3YY3AC","MB3TISH2KYBIGY6XJKMN4HO2S6TCN2GORJENMECCKLXGGIRS2O2AC","LE4VZIY5VZ52FOP5QQRIJINWIMWTAPRTZTGO77JXUEPGRPRSQYMAC","SODOV2CMWA4JMIKRQNJ6MD3U3BS2XTSLINLRAG4SFY742IIJNI5QC","7VQ4ALFYKJBFR46T3WZDMGOXNRR3QNJEJQVBYJM4HSJUOOUD6WBQC","A2GL5FOZ3UJ2NM5RPRWTNPFTKLBA54B2UC6UIYO4M3N3RFNC4BTAC","HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","N4IROACVZ4MU73J5SM6WXJMKQSFR3VN5SOKENNNZNEGMTGB2Q3HAC","OG3Z3QGCG2FNDGF4VQYWOXLZCF7LGTZCUMGKUCBNAPAQ5FRFHQ2AC","CNLNT3T4IXU42GAC64CU5CEDTDLM2SHSJZEVHTMOCWYFXSQNC76QC","NAYQT2GTCJPBFRSK7CBFX655F2NGTBPICJSCYG2CSCQ5NRDHZG6QC","MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","YR2IM6Y5XA6XDFBWJUFSVNMQQKLIW6A2LDS4F77A3OZLEMBACCRAC","WE5Q2NVIIK4R2DUUZYLJFQVYK5O26EDEJRPK3CPGWHU3SEAC2DQAC","IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC","ZK76B5ZZCEOJQUDOVKDZPE6IN2YIXQONFUIJ633OAXNC73OG3YSAC","ACBS7C6QGXAMPLQ336WAQMMGLZXBDNNYPE26ZBPUQ24GL4BF643AC","EYR3EW6JVHNVLXMI57FUVPHQAHPETBML4H44OGJFHUT54KTTHIGQC","4CQWOODYIBUEMPSLWTXZPZZTQBYYRGCORKLY4SKG2WVCVXGT654QC","O3NM62IZE5EMW4KY56TV53BUZZL2NHAC55W7NBPTD7A4CKT4CHUQC","VQISTKOPNAEUS2K2F73CMNNLGZATWUYIURD5CSVNBNF7Q5ZF4PXQC","H7SZRHUBSEDJ3PQ3VOV4ZEEFUWTBPGZN53G6W26HHXPJDO7MSHJAC","RND7XFNHXVORJ6JPEHGS7PCIW7DMOTWMZQPTEMXWLR7CZUQ2VCQQC","TPNHTE5VJ36IPKMFENDERDBFBHLYFXOVNDLV2QSC4G5STPPMBLMAC"]},"hunks":[{"Replacement":{"inode":{"change":5,"pos":219},"path":"src/hydra-queue-runner/Makefile.am","line":5,"ins":{"up_context":[{"change":5,"pos":131}],"down_context":[{"change":5,"pos":322}],"flag":"BLOCK","start":0,"end":122,"inode":{"change":5,"pos":219}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":5,"pos":131},"to":{"change":5,"start":0,"end":75},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":85},"to":{"change":5,"start":0,"end":75},"introduced_by":5}],"inode":{"change":5,"pos":219}},"ins_contents":[{"Add":" build-result.hh counter.hh pool.hh sync.hh token-server.hh state.hh db.hh \\"},{"Add":" local-binary-cache.hh local-binary-cache.cc"}],"del_contents":[{"Del":" build-result.hh counter.hh pool.hh sync.hh token-server.hh state.hh db.hh\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":76,"ins":{"up_context":[{"change":5,"pos":1290}],"down_context":[{"change":5,"pos":1349}],"flag":"BLOCK","start":123,"end":171,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1290},"to":{"change":4,"start":139,"end":183},"introduced_by":4}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":"static void copyClosureTo(ref destStore,"}],"del_contents":[{"Del":"static void copyClosureTo(ref store,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":83,"ins":{"up_context":[{"change":5,"pos":1492}],"down_context":[{"change":5,"pos":1593}],"flag":"BLOCK","start":172,"end":224,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1492},"to":{"change":4,"start":184,"end":232},"introduced_by":4}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" destStore->computeFSClosure(path, closure);"}],"del_contents":[{"Del":" store->computeFSClosure(path, closure);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":98,"ins":{"up_context":[{"change":5,"pos":83}],"down_context":[{"change":5,"pos":134}],"flag":"BLOCK","start":225,"end":279,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":83},"to":{"change":4,"start":233,"end":283},"introduced_by":4}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" Paths sorted = destStore->topoSortPaths(closure);"}],"del_contents":[{"Del":" Paths sorted = store->topoSortPaths(closure);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":107,"ins":{"up_context":[{"change":5,"pos":94}],"down_context":[{"change":5,"pos":285}],"flag":"BLOCK","start":280,"end":338,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":94},"to":{"change":5,"start":94,"end":148},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" bytesSent += destStore->queryPathInfo(p).narSize;"}],"del_contents":[{"Del":" bytesSent += store->queryPathInfo(p).narSize;\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":110,"ins":{"up_context":[{"change":5,"pos":91}],"down_context":[{"change":5,"pos":365}],"flag":"BLOCK","start":339,"end":387,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":91},"to":{"change":4,"start":284,"end":328},"introduced_by":4}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" destStore->exportPaths(missing, false, to);"}],"del_contents":[{"Del":" store->exportPaths(missing, false, to);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":118,"ins":{"up_context":[{"change":5,"pos":2443}],"down_context":[{"change":5,"pos":149}],"flag":"BLOCK","start":388,"end":438,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2443},"to":{"change":4,"start":329,"end":375},"introduced_by":4}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":"static void copyClosureFrom(ref destStore,"}],"del_contents":[{"Del":"static void copyClosureFrom(ref store,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":123,"ins":{"up_context":[{"change":5,"pos":2680}],"down_context":[{"change":5,"pos":232}],"flag":"BLOCK","start":439,"end":480,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2680},"to":{"change":5,"start":2680,"end":2717},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" destStore->importPaths(false, from);"}],"del_contents":[{"Del":" store->importPaths(false, from);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":126,"ins":{"up_context":[{"change":5,"pos":260}],"down_context":[{"change":5,"pos":2717}],"flag":"BLOCK","start":481,"end":543,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":260},"to":{"change":5,"start":260,"end":318},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" bytesReceived += destStore->queryPathInfo(p).narSize;"}],"del_contents":[{"Del":" bytesReceived += store->queryPathInfo(p).narSize;\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":130,"ins":{"up_context":[{"change":5,"pos":2721}],"down_context":[{"change":5,"pos":173}],"flag":"BLOCK","start":544,"end":590,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2721},"to":{"change":4,"start":376,"end":418},"introduced_by":4}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":"void State::buildRemote(ref destStore,"}],"del_contents":[{"Del":"void State::buildRemote(ref store,\n"}]}},{"Edit":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":224,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":755}],"down_context":[{"change":5,"pos":3876}],"flag":"BLOCK","start":591,"end":861,"inode":{"change":5,"pos":85}}},"contents":[{"Add":""},{"Add":" /* Ensure that the inputs exist in the destination store. This is"},{"Add":" a no-op for regular stores, but for the binary cache store,"},{"Add":" this will copy the inputs to the binary cache from the local"},{"Add":" store. */"},{"Add":" destStore->buildPaths(basicDrv.inputSrcs);"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":232,"ins":{"up_context":[{"change":5,"pos":3911}],"down_context":[{"change":2,"pos":0}],"flag":"BLOCK","start":862,"end":916,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":3911},"to":{"change":5,"start":830,"end":873},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" if (/* machine->sshName != \"localhost\" */ true) {"}],"del_contents":[{"Del":" if (machine->sshName != \"localhost\") {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":238,"ins":{"up_context":[{"change":2,"pos":251}],"down_context":[{"change":5,"pos":277}],"flag":"BLOCK","start":917,"end":980,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":251},"to":{"change":5,"start":98,"end":157},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":98},"to":{"change":5,"start":98,"end":157},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" copyClosureTo(destStore, from, to, inputs, bytesSent);"}],"del_contents":[{"Del":" copyClosureTo(store, from, to, inputs, bytesSent);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":286,"ins":{"up_context":[{"change":5,"pos":4825}],"down_context":[{"change":5,"pos":1286}],"flag":"BLOCK","start":981,"end":1035,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":4825},"to":{"change":5,"start":1243,"end":1286},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" if (/* machine->sshName != \"localhost\" */ true) {"}],"del_contents":[{"Del":" if (machine->sshName != \"localhost\") {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":85},"path":"src/hydra-queue-runner/build-remote.cc","line":292,"ins":{"up_context":[{"change":5,"pos":336}],"down_context":[{"change":5,"pos":387}],"flag":"BLOCK","start":1036,"end":1106,"inode":{"change":5,"pos":85}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":336},"to":{"change":5,"start":932,"end":998},"introduced_by":5}],"inode":{"change":5,"pos":85}},"ins_contents":[{"Add":" copyClosureFrom(destStore, from, to, outputs, bytesReceived);"}],"del_contents":[{"Del":" copyClosureFrom(store, from, to, outputs, bytesReceived);\n"}]}},{"Edit":{"inode":{"change":5,"pos":441},"path":"src/hydra-queue-runner/build-result.cc","line":44,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":1146}],"down_context":[{"change":33,"pos":21}],"flag":"BLOCK","start":1107,"end":1113,"inode":{"change":5,"pos":441}}},"contents":[{"Add":"#if 0"}]}},{"Edit":{"inode":{"change":5,"pos":441},"path":"src/hydra-queue-runner/build-result.cc","line":101,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":3219}],"down_context":[{"change":5,"pos":3219}],"flag":"BLOCK","start":1114,"end":1121,"inode":{"change":5,"pos":441}}},"contents":[{"Add":"#endif"}]}},{"Edit":{"inode":{"change":5,"pos":441},"path":"src/hydra-queue-runner/build-result.cc","line":113,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":3665}],"down_context":[{"change":5,"pos":3665}],"flag":"BLOCK","start":1122,"end":1128,"inode":{"change":5,"pos":441}}},"contents":[{"Add":"#if 0"}]}},{"Edit":{"inode":{"change":5,"pos":441},"path":"src/hydra-queue-runner/build-result.cc","line":118,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":3865}],"down_context":[{"change":5,"pos":3865}],"flag":"BLOCK","start":1129,"end":1136,"inode":{"change":5,"pos":441}}},"contents":[{"Add":"#endif"}]}},{"Edit":{"inode":{"change":5,"pos":441},"path":"src/hydra-queue-runner/build-result.cc","line":123,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":3931}],"down_context":[{"change":5,"pos":3931}],"flag":"BLOCK","start":1137,"end":1143,"inode":{"change":5,"pos":441}}},"contents":[{"Add":"#if 0"}]}},{"Edit":{"inode":{"change":5,"pos":441},"path":"src/hydra-queue-runner/build-result.cc","line":147,"atom":{"NewVertex":{"up_context":[{"change":34,"pos":1208}],"down_context":[{"change":34,"pos":1208}],"flag":"BLOCK","start":1144,"end":1151,"inode":{"change":5,"pos":441}}},"contents":[{"Add":"#endif"}]}},{"Replacement":{"inode":{"change":5,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":18,"ins":{"up_context":[{"change":5,"pos":399}],"down_context":[{"change":5,"pos":499}],"flag":"BLOCK","start":1152,"end":1261,"inode":{"change":5,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":399},"to":{"change":5,"start":399,"end":448},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":448},"to":{"change":5,"start":95,"end":159},"introduced_by":5}],"inode":{"change":5,"pos":133}},"ins_contents":[{"Add":" auto destStore = getDestStore();"},{"Add":" retry = doBuildStep(destStore, step, reservation->machine);"}],"del_contents":[{"Del":" auto store = openStore(); // FIXME: pool\n"},{"Del":" retry = doBuildStep(store, step, reservation->machine);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":48,"ins":{"up_context":[{"change":5,"pos":1479}],"down_context":[{"change":5,"pos":1552}],"flag":"BLOCK","start":1262,"end":1329,"inode":{"change":5,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1479},"to":{"change":4,"start":631,"end":694},"introduced_by":4}],"inode":{"change":5,"pos":133}},"ins_contents":[{"Add":"bool State::doBuildStep(nix::ref destStore, Step::ptr step,"}],"del_contents":[{"Del":"bool State::doBuildStep(nix::ref store, Step::ptr step,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":123,"ins":{"up_context":[{"change":5,"pos":4376}],"down_context":[{"change":5,"pos":4474}],"flag":"BLOCK","start":1330,"end":1432,"inode":{"change":5,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":4376},"to":{"change":5,"start":4376,"end":4474},"introduced_by":5}],"inode":{"change":5,"pos":133}},"ins_contents":[{"Add":" buildRemote(destStore, machine, step, build->maxSilentTime, build->buildTimeout, result);"}],"del_contents":[{"Del":" buildRemote(store, machine, step, build->maxSilentTime, build->buildTimeout, result);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":129,"ins":{"up_context":[{"change":5,"pos":4608}],"down_context":[{"change":5,"pos":4678}],"flag":"BLOCK","start":1433,"end":1507,"inode":{"change":5,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":4608},"to":{"change":5,"start":4608,"end":4678},"introduced_by":5}],"inode":{"change":5,"pos":133}},"ins_contents":[{"Add":" if (result.success()) res = getBuildOutput(destStore, step->drv);"}],"del_contents":[{"Del":" if (result.success()) res = getBuildOutput(store, step->drv);\n"}]}},{"Edit":{"inode":{"change":5,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":10,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":20065}],"down_context":[{"change":35,"pos":19}],"flag":"BLOCK","start":1508,"end":1541,"inode":{"change":5,"pos":4840}}},"contents":[{"Add":"#include \"local-binary-cache.hh\""}]}},{"Edit":{"inode":{"change":5,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":25,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":7892}],"down_context":[{"change":5,"pos":7503}],"flag":"BLOCK","start":1542,"end":1737,"inode":{"change":5,"pos":4840}}},"contents":[{"Add":"}"},{"Add":""},{"Add":""},{"Add":"ref State::getLocalStore()"},{"Add":"{"},{"Add":" return openStore(); // FIXME: pool"},{"Add":"}"},{"Add":""},{"Add":""},{"Add":"ref State::getDestStore()"},{"Add":"{"},{"Add":" return make_ref(getLocalStore(), \"/tmp/binary-cache\");"}]}},{"Replacement":{"inode":{"change":5,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":110,"ins":{"up_context":[{"change":5,"pos":309}],"down_context":[{"change":3,"pos":0}],"flag":"BLOCK","start":1738,"end":1877,"inode":{"change":5,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":309},"to":{"change":5,"start":0,"end":57},"introduced_by":5}],"inode":{"change":5,"pos":4840}},"ins_contents":[{"Add":" parseMachines(\"localhost \" +"},{"Add":" (settings.thisSystem == \"x86_64-linux\" ? \"x86_64-linux,i686-linux\" : settings.thisSystem)"}],"del_contents":[{"Del":" parseMachines(\"localhost \" + settings.thisSystem\n"}]}},{"FileAdd":{"meta":{"basename":"local-binary-cache.cc","metadata":0},"context":[{"change":5,"pos":187}],"contents":[{"Add":"#include \"local-binary-cache.hh\""},{"Add":""},{"Add":"#include \"archive.hh\""},{"Add":"#include \"derivations.hh\""},{"Add":"#include \"globals.hh\""},{"Add":"#include \"worker-protocol.hh\""},{"Add":""},{"Add":"namespace nix {"},{"Add":""},{"Add":"LocalBinaryCache::LocalBinaryCache(ref localStore, const Path & binaryCacheDir)"},{"Add":" : localStore(localStore), binaryCacheDir(binaryCacheDir)"},{"Add":"{"},{"Add":" createDirs(binaryCacheDir + \"/nar\");"},{"Add":"}"},{"Add":""},{"Add":"Path LocalBinaryCache::narInfoFileFor(const Path & storePath)"},{"Add":"{"},{"Add":" assertStorePath(storePath);"},{"Add":" return binaryCacheDir + \"/\" + storePathToHash(storePath) + \".narinfo\";"},{"Add":"}"},{"Add":""},{"Add":"void atomicWrite(const Path & path, const std::string & s)"},{"Add":"{"},{"Add":" Path tmp = path + \".tmp.\" + std::to_string(getpid());"},{"Add":" AutoDelete del(tmp, false);"},{"Add":" writeFile(tmp, s);"},{"Add":" if (rename(tmp.c_str(), path.c_str()))"},{"Add":" throw SysError(format(\"renaming ‘%1%’ to ‘%2%’\") % tmp % path);"},{"Add":" del.cancel();"},{"Add":"}"},{"Add":""},{"Add":"void LocalBinaryCache::addToCache(const ValidPathInfo & info,"},{"Add":" const string & nar)"},{"Add":"{"},{"Add":" size_t narSize = nar.size();"},{"Add":" Hash narHash = hashString(htSHA256, nar);"},{"Add":""},{"Add":" if (info.hash.type != htUnknown && info.hash != narHash)"},{"Add":" throw Error(format(\"refusing to copy corrupted path ‘%1%’ to binary cache\") % info.path);"},{"Add":""},{"Add":" printMsg(lvlTalkative, format(\"copying path ‘%1%’ (%2% bytes) to binary cache\")"},{"Add":" % info.path % narSize);"},{"Add":""},{"Add":" /* Atomically write the NAR file. */"},{"Add":" string narFileRel = \"nar/\" + printHash(narHash) + \".nar\";"},{"Add":" Path narFile = binaryCacheDir + \"/\" + narFileRel;"},{"Add":" if (!pathExists(narFile)) atomicWrite(narFile, nar);"},{"Add":""},{"Add":" /* Atomically write the NAR info file.*/"},{"Add":" Path narInfoFile = narInfoFileFor(info.path);"},{"Add":""},{"Add":" if (!pathExists(narInfoFile)) {"},{"Add":""},{"Add":" Strings refs;"},{"Add":" for (auto & r : info.references)"},{"Add":" refs.push_back(baseNameOf(r));"},{"Add":""},{"Add":" std::string narInfo;"},{"Add":" narInfo += \"StorePath: \" + info.path + \"\\n\";"},{"Add":" narInfo += \"URL: \" + narFileRel + \"\\n\";"},{"Add":" narInfo += \"Compression: none\\n\";"},{"Add":" narInfo += \"FileHash: sha256:\" + printHash(narHash) + \"\\n\";"},{"Add":" narInfo += \"FileSize: \" + std::to_string(narSize) + \"\\n\";"},{"Add":" narInfo += \"NarHash: sha256:\" + printHash(narHash) + \"\\n\";"},{"Add":" narInfo += \"NarSize: \" + std::to_string(narSize) + \"\\n\";"},{"Add":" narInfo += \"References: \" + concatStringsSep(\" \", refs) + \"\\n\";"},{"Add":""},{"Add":" // FIXME: add signature"},{"Add":""},{"Add":" atomicWrite(narInfoFile, narInfo);"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"LocalBinaryCache::NarInfo LocalBinaryCache::readNarInfo(const Path & storePath)"},{"Add":"{"},{"Add":" NarInfo res;"},{"Add":""},{"Add":" Path narInfoFile = narInfoFileFor(storePath);"},{"Add":" if (!pathExists(narInfoFile))"},{"Add":" abort();"},{"Add":" std::string narInfo = readFile(narInfoFile);"},{"Add":""},{"Add":" auto corrupt = [&]() {"},{"Add":" throw Error(format(\"corrupt NAR info file ‘%1%’\") % narInfoFile);"},{"Add":" };"},{"Add":""},{"Add":" size_t pos = 0;"},{"Add":" while (pos < narInfo.size()) {"},{"Add":""},{"Add":" size_t colon = narInfo.find(':', pos);"},{"Add":" if (colon == std::string::npos) corrupt();"},{"Add":""},{"Add":" std::string name(narInfo, pos, colon - pos);"},{"Add":""},{"Add":" size_t eol = narInfo.find('\\n', colon + 2);"},{"Add":" if (eol == std::string::npos) corrupt();"},{"Add":""},{"Add":" std::string value(narInfo, colon + 2, eol - colon - 2);"},{"Add":""},{"Add":" if (name == \"StorePath\") {"},{"Add":" res.info.path = value;"},{"Add":" if (value != storePath) corrupt();"},{"Add":" res.info.path = value;"},{"Add":" }"},{"Add":" else if (name == \"References\") {"},{"Add":" auto refs = tokenizeString(value, \" \");"},{"Add":" if (!res.info.references.empty()) corrupt();"},{"Add":" for (auto & r : refs)"},{"Add":" res.info.references.insert(settings.nixStore + \"/\" + r);"},{"Add":" }"},{"Add":" else if (name == \"URL\") {"},{"Add":" res.narUrl = value;"},{"Add":" }"},{"Add":""},{"Add":" pos = eol + 1;"},{"Add":" }"},{"Add":""},{"Add":" if (res.info.path.empty() || res.narUrl.empty()) corrupt();"},{"Add":""},{"Add":" return res;"},{"Add":"}"},{"Add":""},{"Add":"bool LocalBinaryCache::isValidPath(const Path & storePath)"},{"Add":"{"},{"Add":" Path narInfoFile = narInfoFileFor(storePath);"},{"Add":""},{"Add":" printMsg(lvlDebug, format(\"checking %1% -> %2%\") % storePath % narInfoFile);"},{"Add":""},{"Add":" return pathExists(narInfoFile);"},{"Add":"}"},{"Add":""},{"Add":"void LocalBinaryCache::exportPath(const Path & storePath, bool sign, Sink & sink)"},{"Add":"{"},{"Add":" assert(!sign);"},{"Add":""},{"Add":" auto res = readNarInfo(storePath);"},{"Add":""},{"Add":" auto nar = readFile(binaryCacheDir + \"/\" + res.narUrl);"},{"Add":""},{"Add":" printMsg(lvlTalkative, format(\"exporting path ‘%1%’ (%2% bytes)\") % storePath % nar.size());"},{"Add":""},{"Add":" assert(nar.size() % 8 == 0);"},{"Add":""},{"Add":" sink((unsigned char *) nar.c_str(), nar.size());"},{"Add":""},{"Add":" // FIXME: check integrity of NAR."},{"Add":""},{"Add":" sink << exportMagic << storePath << res.info.references << res.info.deriver << 0;"},{"Add":"}"},{"Add":""},{"Add":"Paths LocalBinaryCache::importPaths(bool requireSignature, Source & source)"},{"Add":"{"},{"Add":" assert(!requireSignature);"},{"Add":" Paths res;"},{"Add":" while (true) {"},{"Add":" unsigned long long n = readLongLong(source);"},{"Add":" if (n == 0) break;"},{"Add":" if (n != 1) throw Error(\"input doesn't look like something created by ‘nix-store --export’\");"},{"Add":" res.push_back(importPath(source));"},{"Add":" }"},{"Add":" return res;"},{"Add":"}"},{"Add":""},{"Add":"struct TeeSource : Source"},{"Add":"{"},{"Add":" Source & readSource;"},{"Add":" std::string data;"},{"Add":" TeeSource(Source & readSource) : readSource(readSource)"},{"Add":" {"},{"Add":" }"},{"Add":" size_t read(unsigned char * data, size_t len)"},{"Add":" {"},{"Add":" size_t n = readSource.read(data, len);"},{"Add":" this->data.append((char *) data, n);"},{"Add":" return n;"},{"Add":" }"},{"Add":"};"},{"Add":""},{"Add":"struct NopSink : ParseSink"},{"Add":"{"},{"Add":"};"},{"Add":""},{"Add":"Path LocalBinaryCache::importPath(Source & source)"},{"Add":"{"},{"Add":" /* FIXME: some cut&paste of LocalStore::importPath(). */"},{"Add":""},{"Add":" /* Extract the NAR from the source. */"},{"Add":" TeeSource tee(source);"},{"Add":" NopSink sink;"},{"Add":" parseDump(sink, tee);"},{"Add":""},{"Add":" uint32_t magic = readInt(source);"},{"Add":" if (magic != exportMagic)"},{"Add":" throw Error(\"Nix archive cannot be imported; wrong format\");"},{"Add":""},{"Add":" ValidPathInfo info;"},{"Add":" info.path = readStorePath(source);"},{"Add":""},{"Add":" info.references = readStorePaths(source);"},{"Add":""},{"Add":" readString(source); // deriver, don't care"},{"Add":""},{"Add":" bool haveSignature = readInt(source) == 1;"},{"Add":" assert(!haveSignature);"},{"Add":""},{"Add":" addToCache(info, tee.data);"},{"Add":""},{"Add":" return info.path;"},{"Add":"}"},{"Add":""},{"Add":"ValidPathInfo LocalBinaryCache::queryPathInfo(const Path & storePath)"},{"Add":"{"},{"Add":" return readNarInfo(storePath).info;"},{"Add":"}"},{"Add":""},{"Add":"void LocalBinaryCache::querySubstitutablePathInfos(const PathSet & paths,"},{"Add":" SubstitutablePathInfos & infos)"},{"Add":"{"},{"Add":" PathSet left;"},{"Add":""},{"Add":" for (auto & storePath : paths) {"},{"Add":" if (!localStore->isValidPath(storePath)) {"},{"Add":" left.insert(storePath);"},{"Add":" continue;"},{"Add":" }"},{"Add":" ValidPathInfo info = localStore->queryPathInfo(storePath);"},{"Add":" SubstitutablePathInfo sub;"},{"Add":" sub.references = info.references;"},{"Add":" sub.downloadSize = 0;"},{"Add":" sub.narSize = info.narSize;"},{"Add":" infos.emplace(storePath, sub);"},{"Add":" }"},{"Add":""},{"Add":" localStore->querySubstitutablePathInfos(left, infos);"},{"Add":"}"},{"Add":""},{"Add":"void LocalBinaryCache::buildPaths(const PathSet & paths, BuildMode buildMode)"},{"Add":"{"},{"Add":" for (auto & storePath : paths) {"},{"Add":" assert(!isDerivation(storePath));"},{"Add":""},{"Add":" if (isValidPath(storePath)) continue;"},{"Add":""},{"Add":" localStore->addTempRoot(storePath);"},{"Add":""},{"Add":" if (!localStore->isValidPath(storePath))"},{"Add":" localStore->ensurePath(storePath);"},{"Add":""},{"Add":" ValidPathInfo info = localStore->queryPathInfo(storePath);"},{"Add":""},{"Add":" for (auto & ref : info.references)"},{"Add":" if (ref != storePath)"},{"Add":" ensurePath(ref);"},{"Add":""},{"Add":" StringSink sink;"},{"Add":" dumpPath(storePath, sink);"},{"Add":""},{"Add":" addToCache(info, sink.s);"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"void LocalBinaryCache::ensurePath(const Path & path)"},{"Add":"{"},{"Add":" buildPaths({path});"},{"Add":"}"},{"Add":""},{"Add":"}"}]}},{"FileAdd":{"meta":{"basename":"local-binary-cache.hh","metadata":0},"context":[{"change":5,"pos":187}],"contents":[{"Add":"#pragma once"},{"Add":""},{"Add":"#include \"store-api.hh\""},{"Add":""},{"Add":"namespace nix {"},{"Add":""},{"Add":"class LocalBinaryCache : public nix::Store"},{"Add":"{"},{"Add":"private:"},{"Add":" ref localStore;"},{"Add":" Path binaryCacheDir;"},{"Add":""},{"Add":"public:"},{"Add":""},{"Add":" LocalBinaryCache(ref localStore, const Path & binaryCacheDir);"},{"Add":""},{"Add":"private:"},{"Add":""},{"Add":" Path narInfoFileFor(const Path & storePath);"},{"Add":""},{"Add":" void addToCache(const ValidPathInfo & info, const string & nar);"},{"Add":""},{"Add":" struct NarInfo"},{"Add":" {"},{"Add":" ValidPathInfo info;"},{"Add":" std::string narUrl;"},{"Add":" };"},{"Add":""},{"Add":" NarInfo readNarInfo(const Path & storePath);"},{"Add":""},{"Add":"public:"},{"Add":""},{"Add":" bool isValidPath(const Path & path) override;"},{"Add":""},{"Add":" PathSet queryValidPaths(const PathSet & paths) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" PathSet queryAllValidPaths() override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" ValidPathInfo queryPathInfo(const Path & path) override;"},{"Add":""},{"Add":" Hash queryPathHash(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void queryReferrers(const Path & path,"},{"Add":" PathSet & referrers) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" Path queryDeriver(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" PathSet queryValidDerivers(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" PathSet queryDerivationOutputs(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" StringSet queryDerivationOutputNames(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" Path queryPathFromHashPart(const string & hashPart) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" PathSet querySubstitutablePaths(const PathSet & paths) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void querySubstitutablePathInfos(const PathSet & paths,"},{"Add":" SubstitutablePathInfos & infos) override;"},{"Add":""},{"Add":" Path addToStore(const string & name, const Path & srcPath,"},{"Add":" bool recursive = true, HashType hashAlgo = htSHA256,"},{"Add":" PathFilter & filter = defaultPathFilter, bool repair = false) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" Path addTextToStore(const string & name, const string & s,"},{"Add":" const PathSet & references, bool repair = false) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void exportPath(const Path & path, bool sign,"},{"Add":" Sink & sink) override;"},{"Add":""},{"Add":" Paths importPaths(bool requireSignature, Source & source) override;"},{"Add":""},{"Add":" Path importPath(Source & source);"},{"Add":""},{"Add":" void buildPaths(const PathSet & paths, BuildMode buildMode = bmNormal) override;"},{"Add":""},{"Add":" BuildResult buildDerivation(const Path & drvPath, const BasicDerivation & drv,"},{"Add":" BuildMode buildMode = bmNormal) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void ensurePath(const Path & path) override;"},{"Add":""},{"Add":" void addTempRoot(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void addIndirectRoot(const Path & path) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void syncWithGC() override"},{"Add":" { }"},{"Add":""},{"Add":" Roots findRoots() override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" void collectGarbage(const GCOptions & options, GCResults & results) override"},{"Add":" { abort(); }"},{"Add":""},{"Add":" PathSet queryFailedPaths() override"},{"Add":" { return PathSet(); }"},{"Add":""},{"Add":" void clearFailedPaths(const PathSet & paths) override"},{"Add":" { }"},{"Add":""},{"Add":" void optimiseStore() override"},{"Add":" { }"},{"Add":""},{"Add":" bool verifyStore(bool checkContents, bool repair) override"},{"Add":" { return true; }"},{"Add":""},{"Add":"};"},{"Add":""},{"Add":"}"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":33,"ins":{"up_context":[{"change":5,"pos":20720}],"down_context":[{"change":5,"pos":20765}],"flag":"BLOCK","start":12280,"end":12356,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":20720},"to":{"change":5,"start":20720,"end":20765},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" auto localStore = getLocalStore();"},{"Add":" auto destStore = getDestStore();"}],"del_contents":[{"Del":" auto store = openStore(); // FIXME: pool\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":39,"ins":{"up_context":[{"change":5,"pos":20820}],"down_context":[{"change":5,"pos":20872}],"flag":"BLOCK","start":12357,"end":12437,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":20820},"to":{"change":5,"start":0,"end":64},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" bool done = getQueuedBuilds(*conn, localStore, destStore, lastBuildId);"}],"del_contents":[{"Del":" bool done = getQueuedBuilds(*conn, store, lastBuildId);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":67,"ins":{"up_context":[{"change":5,"pos":21512}],"down_context":[{"change":5,"pos":21620}],"flag":"BLOCK","start":12438,"end":12562,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21512},"to":{"change":4,"start":809,"end":902},"introduced_by":4}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":"bool State::getQueuedBuilds(Connection & conn, ref localStore,"},{"Add":" ref destStore, unsigned int & lastBuildId)"}],"del_contents":[{"Del":"bool State::getQueuedBuilds(Connection & conn, ref store, unsigned int & lastBuildId)\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":123,"ins":{"up_context":[{"change":5,"pos":23144}],"down_context":[{"change":5,"pos":23195}],"flag":"BLOCK","start":12563,"end":12619,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":23144},"to":{"change":5,"start":23144,"end":23195},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" if (!localStore->isValidPath(build->drvPath)) {"}],"del_contents":[{"Del":" if (!store->isValidPath(build->drvPath)) {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":143,"ins":{"up_context":[{"change":5,"pos":24028}],"down_context":[{"change":5,"pos":24135}],"flag":"BLOCK","start":12620,"end":12756,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":24028},"to":{"change":5,"start":1282,"end":1402},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" Step::ptr step = createStep(destStore, conn, build, build->drvPath,"},{"Add":" build, 0, finishedDrvs, newSteps, newRunnable);"}],"del_contents":[{"Del":" Step::ptr step = createStep(store, conn, build, build->drvPath, build, 0, finishedDrvs, newSteps, newRunnable);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":162,"ins":{"up_context":[{"change":5,"pos":24924}],"down_context":[{"change":5,"pos":24982}],"flag":"BLOCK","start":12757,"end":12819,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":24924},"to":{"change":5,"start":24924,"end":24982},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" BuildOutput res = getBuildOutput(destStore, drv);"}],"del_contents":[{"Del":" BuildOutput res = getBuildOutput(store, drv);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":320,"ins":{"up_context":[{"change":5,"pos":29402}],"down_context":[{"change":5,"pos":1464}],"flag":"BLOCK","start":12820,"end":12870,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":29402},"to":{"change":4,"start":903,"end":949},"introduced_by":4}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":"Step::ptr State::createStep(ref destStore,"}],"del_contents":[{"Del":"Step::ptr State::createStep(ref store,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":400,"ins":{"up_context":[{"change":5,"pos":1670}],"down_context":[{"change":5,"pos":31995}],"flag":"BLOCK","start":12871,"end":12925,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":5,"pos":1670},"to":{"change":5,"start":31945,"end":31995},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":31945},"to":{"change":5,"start":31945,"end":31995},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" if (!destStore->isValidPath(i.second.path)) {"}],"del_contents":[{"Del":" if (!store->isValidPath(i.second.path)) {\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":412,"ins":{"up_context":[{"change":5,"pos":2120}],"down_context":[{"change":5,"pos":2185}],"flag":"BLOCK","start":12926,"end":13004,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2120},"to":{"change":5,"start":2120,"end":2185},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" destStore->querySubstitutablePathInfos(missingPaths, infos); // FIXME"}],"del_contents":[{"Del":" store->querySubstitutablePathInfos(missingPaths, infos);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":420,"ins":{"up_context":[{"change":5,"pos":2491}],"down_context":[{"change":5,"pos":2545}],"flag":"BLOCK","start":13005,"end":13063,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2491},"to":{"change":5,"start":2491,"end":2545},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" destStore->ensurePath(i.second.path);"}],"del_contents":[{"Del":" store->ensurePath(i.second.path);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":449,"ins":{"up_context":[{"change":5,"pos":32426}],"down_context":[{"change":5,"pos":32519}],"flag":"BLOCK","start":13064,"end":13174,"inode":{"change":5,"pos":20067}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":32426},"to":{"change":5,"start":2967,"end":3073},"introduced_by":5}],"inode":{"change":5,"pos":20067}},"ins_contents":[{"Add":" auto dep = createStep(destStore, conn, build, i.first, 0, step, finishedDrvs, newSteps, newRunnable);"}],"del_contents":[{"Del":" auto dep = createStep(store, conn, build, i.first, 0, step, finishedDrvs, newSteps, newRunnable);\n"}]}},{"Edit":{"inode":{"change":5,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":352,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":6809}],"down_context":[{"change":5,"pos":6809}],"flag":"BLOCK","start":13175,"end":13412,"inode":{"change":5,"pos":1128}}},"contents":[{"Add":""},{"Add":" /* Return a store object that can access derivations produced by"},{"Add":" hydra-evaluator. */"},{"Add":" nix::ref getLocalStore();"},{"Add":""},{"Add":" /* Return a store object to store build results. */"},{"Add":" nix::ref getDestStore();"}]}},{"Replacement":{"inode":{"change":5,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":387,"ins":{"up_context":[{"change":5,"pos":2260}],"down_context":[{"change":5,"pos":7732}],"flag":"BLOCK","start":13413,"end":13559,"inode":{"change":5,"pos":1128}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2260},"to":{"change":4,"start":1058,"end":1159},"introduced_by":4}],"inode":{"change":5,"pos":1128}},"ins_contents":[{"Add":" bool getQueuedBuilds(Connection & conn, nix::ref localStore,"},{"Add":" nix::ref destStore, unsigned int & lastBuildId);"}],"del_contents":[{"Del":" bool getQueuedBuilds(Connection & conn, nix::ref store, unsigned int & lastBuildId);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":416,"ins":{"up_context":[{"change":5,"pos":8377}],"down_context":[{"change":5,"pos":8447}],"flag":"BLOCK","start":13560,"end":13629,"inode":{"change":5,"pos":1128}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":8377},"to":{"change":4,"start":1214,"end":1279},"introduced_by":4}],"inode":{"change":5,"pos":1128}},"ins_contents":[{"Add":" bool doBuildStep(nix::ref destStore, Step::ptr step,"}],"del_contents":[{"Del":" bool doBuildStep(nix::ref store, Step::ptr step,\n"}]}},{"Replacement":{"inode":{"change":5,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":419,"ins":{"up_context":[{"change":5,"pos":8479}],"down_context":[{"change":5,"pos":1875}],"flag":"BLOCK","start":13630,"end":13683,"inode":{"change":5,"pos":1128}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":8479},"to":{"change":4,"start":1280,"end":1329},"introduced_by":4}],"inode":{"change":5,"pos":1128}},"ins_contents":[{"Add":" void buildRemote(nix::ref destStore,"}],"del_contents":[{"Del":" void buildRemote(nix::ref store,\n"}]}}],"owner":"grahamc","repo":"hydra2","token":"EBLYYJvdIj2hIbAjYZ7FgNGqM9cZksEt+voLfvNfEVY=","login":null}

…

Dependencies

Change contents