{"header":{"message":"Turn hydra-notify into a daemon","description":"It now receives notifications about started/finished builds/steps via\nPostgreSQL. This gets rid of the (substantial) overhead of starting\nhydra-notify for every event. It also allows other programs (even on\nother machines) to listen to Hydra notifications.","timestamp":"2019-08-09T17:11:38Z","authors":[{"email":"edolstra@gmail.com","name":"Eelco Dolstra"}]},"hash":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC","authors":[],"deps":{"hashes":[["32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC","Turn hydra-notify into a daemon"],["AA",null],["FHVJYJFEZEGR6DVIQ2HGE7DLWA65QAGAI3K2KACGNM2JTDJTRJ4AC","Upload build logs to the binary cache"],["SMUWBAD5D2WF2Q5B75YIUQL76FQHY3C4W25OZDFVFCF5AIYUD4YAC","Send BuildFinished notifications on cached build results."],["PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC","Add buildQueued plugin hook"],["ZUXMEUX6PPFXU7ELM3DL7ICM44UBRDNFHOKYZUD2YEJQSVWLTRSQC","Improve erorr message"],["HZZCYIYTIZ7PUGXNMZSEO463LS4VO7ADUH3QPZQCLMBTPPPOOJSQC","hydra-queue-runner: Allow concurrent notifications"],["B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC","hydra-queue-runner: Make build notification more reliable"],["LSUX6IQR7TBTTCDQAVD3KDAVARLM7SUD7PPVTR5IOKA3BNZDYA7AC","Update to latest nixUnstable"],["7Q2PXRZAERQFX53OEZGY26ZELA2KRWGXDA5QEYQQVUF5ME65Z7TQC","hydra-notify step-finished: Don't barf if the step has no log file"],["7LD275CWWC7L5V4ETGIQRMOEJV5JRUSYQ7LUFINAUGAHWANCREGAC","allow using a shorter context and increase hydra-notify debug"],["X6FOUYFJ5ODEOMHLL6AHM6KI2JRZ2XOI76NYJYJNDUQBTV5UJLBAC","int2String -> std::to_string"],["X4KYZJBQ7WULUWTHAPX5BZTZR7C6HRCC4N4J5K726PGZKSY6FQOQC","Use latest nixUnstable"],["BRAESISHTN4IIWUBVDMPDMY7QLMJDKX7GQ7K6NSJN66L5VPWSX3QC","Warn if PostgreSQL appears stalled"],["SL3WSRACCX2IMJHHLTRAUQT7QDLCOKYLVO2FEHWIHXM5GPKSRJTQC","hydra-queue-runner: Limit memory usage"],["MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","Split hydra-queue-runner.cc more"],["KQ3EGUQYAFZ25JSZCY4RI554LJ3ZWACBQFHL2HTYVXIVTBEJPMGAC","Add some instrumentation to keep track of dispatcher cost"],["HHOMBU7GGRAEXODSDY3WUHQGOSQ35OTGRNBWKKAS2D4YEIZTTNUAC","hydra-queue-runner: Implement timeouts"],["BCDHO4OULIMAC2RNZM5LKDOD2CYENXU6JGEHQZEXZBUMXK3QC3AAC","Set propagatedFrom for cached failed build steps"],["K5G5GZY7D7KWVR5RAGZFHH3ZPG5OCLZT4HZ6XIJJ7YYVUMC2CTZQC","Guard against concurrent invocations of hydra-queue-runner"],["GS4BE6TB6GH2JUZJHDPHL6YG7J7YYESF3YOZJZ2CFABXUTO4VYPQC","Asynchronously compress build logs"],["T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC","On SIGINT, shut down the builder threads"],["OG3Z3QGCG2FNDGF4VQYWOXLZCF7LGTZCUMGKUCBNAPAQ5FRFHQ2AC","Namespace cleanup"],["UVQJBDHNWHTGOAEL426F6RZPD67QABBRP73E6QB5ND5OV2S3267QC","Move log compression to a plugin"],["OKQLN5AGZNONICDJFHFOOF7G6BHZUQU32PZA4KJAGRTPIKNFBX2AC","Set proper charset on log files"],["RNJILKTWUYDBY2AX22BRVYFLT3FIPKEXAKGOAW3PA54XBQDENULQC","Upload log files to the right location"],["7LWB2J2ZFB4XJDN5MBL2WDKVBRYQD7Y6RQU7LUYKH7PZTXK2H7KQC","Periodically clear orphaned build steps"],["LVQXQIYA7QMLVYOANYEFHDBTFAOSE3D2IYAVOG2DXURTASRCUNYQC","Kill active build steps when builds are cancelled"],["5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","Basic remote building"],["HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","Refactor"],["UYUVQWXQZUOEM2DIUIS2XMC6I6FUNUCAI6VRUH6XDIO6BOD6L7EQC","Fix hydra-queue-runner --build-one"],["EPWEMRI23UN6C777AL2GWEOXYZRTPEPFC2SZVZ4JTWUGYVFDL5XAC","Allow determinism checking for entire jobsets"],["IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC","hydra-queue-runner: Send build notifications"],["NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC","Provide a plugin hook for when build steps finish"],["B2L4T3X63XVYJQXEDU4WT5Y4R6PMDXGC6WN2KGOMHRQILSABNQOAC","Sync with Nix"],["YTAYNN7VNYZNLGUSGY3EF33MGQWMJW76FKV657SBKASQFQC7EB3AC","Queue monitor: Bail out earlier if a step has failed previously"],["JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC","hydra-queue-runner: Keep some notification statistics"],["C6HOMHZWMSC7ORGFUF5YG2ACKV2SCP26HL3UH6VXH6RNDYRXH5DAC","Don't try to handle SIGINT"],["XV4AEKJCFTNCOR52IRFYHORCNNFKIHOADIUARTC2U5Z6ZQBEEFYQC","hydra-queue-runner: Handle status queries on the main thread"],["FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC","Add buildStarted plugin hook"],["6WRGCITDYP7JIBYP25QIWCHWRJWFPDP2D3TJS3WO3KUHQQJAWHMQC","Enable declarative projects."],["24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","Start of single-process hydra-queue-runner"]],"deps":["FHVJYJFEZEGR6DVIQ2HGE7DLWA65QAGAI3K2KACGNM2JTDJTRJ4AC","SMUWBAD5D2WF2Q5B75YIUQL76FQHY3C4W25OZDFVFCF5AIYUD4YAC","PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC","ZUXMEUX6PPFXU7ELM3DL7ICM44UBRDNFHOKYZUD2YEJQSVWLTRSQC","HZZCYIYTIZ7PUGXNMZSEO463LS4VO7ADUH3QPZQCLMBTPPPOOJSQC","B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC","LSUX6IQR7TBTTCDQAVD3KDAVARLM7SUD7PPVTR5IOKA3BNZDYA7AC","7Q2PXRZAERQFX53OEZGY26ZELA2KRWGXDA5QEYQQVUF5ME65Z7TQC","7LD275CWWC7L5V4ETGIQRMOEJV5JRUSYQ7LUFINAUGAHWANCREGAC"],"known":["T2EIYJNGPIANHKJ4HBJIPTINWKG7RDLHR3PVHFYAPPLHZAJQBVWAC","5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","C6HOMHZWMSC7ORGFUF5YG2ACKV2SCP26HL3UH6VXH6RNDYRXH5DAC","HHOMBU7GGRAEXODSDY3WUHQGOSQ35OTGRNBWKKAS2D4YEIZTTNUAC","XV4AEKJCFTNCOR52IRFYHORCNNFKIHOADIUARTC2U5Z6ZQBEEFYQC","GS4BE6TB6GH2JUZJHDPHL6YG7J7YYESF3YOZJZ2CFABXUTO4VYPQC","K5G5GZY7D7KWVR5RAGZFHH3ZPG5OCLZT4HZ6XIJJ7YYVUMC2CTZQC","IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC","HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","OG3Z3QGCG2FNDGF4VQYWOXLZCF7LGTZCUMGKUCBNAPAQ5FRFHQ2AC","MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","BCDHO4OULIMAC2RNZM5LKDOD2CYENXU6JGEHQZEXZBUMXK3QC3AAC","X6FOUYFJ5ODEOMHLL6AHM6KI2JRZ2XOI76NYJYJNDUQBTV5UJLBAC","UYUVQWXQZUOEM2DIUIS2XMC6I6FUNUCAI6VRUH6XDIO6BOD6L7EQC","B2L4T3X63XVYJQXEDU4WT5Y4R6PMDXGC6WN2KGOMHRQILSABNQOAC","BRAESISHTN4IIWUBVDMPDMY7QLMJDKX7GQ7K6NSJN66L5VPWSX3QC","KQ3EGUQYAFZ25JSZCY4RI554LJ3ZWACBQFHL2HTYVXIVTBEJPMGAC","SL3WSRACCX2IMJHHLTRAUQT7QDLCOKYLVO2FEHWIHXM5GPKSRJTQC","7LWB2J2ZFB4XJDN5MBL2WDKVBRYQD7Y6RQU7LUYKH7PZTXK2H7KQC","FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC","YTAYNN7VNYZNLGUSGY3EF33MGQWMJW76FKV657SBKASQFQC7EB3AC","6WRGCITDYP7JIBYP25QIWCHWRJWFPDP2D3TJS3WO3KUHQQJAWHMQC","NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC","LVQXQIYA7QMLVYOANYEFHDBTFAOSE3D2IYAVOG2DXURTASRCUNYQC","EPWEMRI23UN6C777AL2GWEOXYZRTPEPFC2SZVZ4JTWUGYVFDL5XAC","X4KYZJBQ7WULUWTHAPX5BZTZR7C6HRCC4N4J5K726PGZKSY6FQOQC","UVQJBDHNWHTGOAEL426F6RZPD67QABBRP73E6QB5ND5OV2S3267QC","OKQLN5AGZNONICDJFHFOOF7G6BHZUQU32PZA4KJAGRTPIKNFBX2AC","RNJILKTWUYDBY2AX22BRVYFLT3FIPKEXAKGOAW3PA54XBQDENULQC","JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC"]},"hunks":[{"Edit":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":101,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":500}],"down_context":[{"change":11,"pos":2164}],"flag":"BLOCK","start":0,"end":30,"inode":{"change":11,"pos":133}}},"contents":[{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:0"}},{"Add":{"text":" auto conn(dbPool.get());","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:29"}}]}},{"Replacement":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":127,"ins":{"up_context":[{"change":11,"pos":93}],"down_context":[{"change":11,"pos":501}],"flag":"BLOCK","start":31,"end":184,"inode":{"change":11,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":93},"to":{"change":11,"start":93,"end":123},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":123},"to":{"change":11,"start":0,"end":90},"introduced_by":11}],"inode":{"change":11,"pos":133}},"ins_contents":[{"Add":{"text":" build = build2;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:62"}},{"Add":{"text":" pqxx::work txn(*conn);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:101"}},{"Add":{"text":" notifyBuildStarted(txn, build->id);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:153"}},{"Add":{"text":" txn.commit();","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:183"}}],"del_contents":[{"Del":{"text":" build = build2;","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:122"}},{"Del":{"text":" enqueueNotificationItem({NotificationItem::Type::BuildStarted, build->id});","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:89"}}]}},{"Edit":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":151,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3461},"to":{"change":11,"start":3461,"end":3491},"introduced_by":11}],"inode":{"change":11,"pos":133}}},"contents":[{"Del":{"text":" auto conn(dbPool.get());","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:3489"}},{"Del":{"text":"","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:3490"}}]}},{"Edit":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":175,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":596},"to":{"change":2,"start":596,"end":597},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":597},"to":{"change":11,"start":33,"end":320},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":33},"to":{"change":11,"start":33,"end":320},"introduced_by":11}],"inode":{"change":11,"pos":133}}},"contents":[{"Del":{"text":"","pos":"FHVJYJFEZEGR6DVIQ2HGE7DLWA65QAGAI3K2KACGNM2JTDJTRJ4AC:596"}},{"Del":{"text":" /* Asynchronously run plugins. FIXME: if we're killed,","pos":"UVQJBDHNWHTGOAEL426F6RZPD67QABBRP73E6QB5ND5OV2S3267QC:99"}},{"Del":{"text":" plugin actions might not be run. Need to ensure","pos":"UVQJBDHNWHTGOAEL426F6RZPD67QABBRP73E6QB5ND5OV2S3267QC:162"}},{"Del":{"text":" at-least-once semantics. */","pos":"UVQJBDHNWHTGOAEL426F6RZPD67QABBRP73E6QB5ND5OV2S3267QC:205"}},{"Del":{"text":" enqueueNotificationItem({NotificationItem::Type::StepFinished, buildId, {}, stepNr, result.logFile});","pos":"UVQJBDHNWHTGOAEL426F6RZPD67QABBRP73E6QB5ND5OV2S3267QC:319"}}]}},{"Replacement":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":342,"ins":{"up_context":[{"change":11,"pos":8217}],"down_context":[{"change":11,"pos":8514}],"flag":"BLOCK","start":185,"end":353,"inode":{"change":11,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":8217},"to":{"change":11,"start":226,"end":341},"introduced_by":11}],"inode":{"change":11,"pos":133}},"ins_contents":[{"Add":{"text":" {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:194"}},{"Add":{"text":" pqxx::work txn(*conn);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:229"}},{"Add":{"text":" for (auto id : buildIDs)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:266"}},{"Add":{"text":" notifyBuildFinished(txn, id, {});","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:316"}},{"Add":{"text":" txn.commit();","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:342"}},{"Add":{"text":" }","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:352"}}],"del_contents":[{"Del":{"text":" for (auto id : buildIDs)","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:258"}},{"Del":{"text":" enqueueNotificationItem({NotificationItem::Type::BuildFinished, id});","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:340"}}]}},{"Replacement":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":466,"ins":{"up_context":[{"change":11,"pos":13945}],"down_context":[{"change":11,"pos":14107}],"flag":"BLOCK","start":354,"end":476,"inode":{"change":11,"pos":133}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":13945},"to":{"change":11,"start":13945,"end":14020},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":14020},"to":{"change":11,"start":2506,"end":2630},"introduced_by":11}],"inode":{"change":11,"pos":133}},"ins_contents":[{"Add":{"text":" pqxx::work txn(*conn);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:388"}},{"Add":{"text":" notifyBuildFinished(txn, buildId, dependentIDs);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:449"}},{"Add":{"text":" txn.commit();","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:475"}}],"del_contents":[{"Del":{"text":" auto notificationSenderQueue_(notificationSenderQueue.lock());","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:14019"}},{"Del":{"text":" notificationSenderQueue_->push(NotificationItem{NotificationItem::Type::BuildFinished, buildId, dependentIDs});","pos":"LVQXQIYA7QMLVYOANYEFHDBTFAOSE3D2IYAVOG2DXURTASRCUNYQC:2629"}}]}},{"Edit":{"inode":{"change":11,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":470,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":14117},"to":{"change":11,"start":14117,"end":14165},"introduced_by":11}],"inode":{"change":11,"pos":133}}},"contents":[{"Del":{"text":" notificationSenderWakeup.notify_one();","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:14163"}},{"Del":{"text":"","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:14164"}}]}},{"Edit":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":302,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":2024}],"down_context":[{"change":42,"pos":13421}],"flag":"BLOCK","start":477,"end":668,"inode":{"change":42,"pos":4840}}},"contents":[{"Add":{"text":" assert(result.logFile.find('\\'') == std::string::npos);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:536"}},{"Add":{"text":" txn.exec(fmt(\"notify step_finished, '%d %d %s'\", buildId, stepNr,","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:606"}},{"Add":{"text":" result.logFile.empty() ? \"-\" : result.logFile));","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:667"}}]}},{"Replacement":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":456,"ins":{"up_context":[{"change":11,"pos":1820}],"down_context":[{"change":11,"pos":1381}],"flag":"BLOCK","start":669,"end":735,"inode":{"change":42,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1348},"to":{"change":11,"start":1348,"end":1381},"introduced_by":11}],"inode":{"change":42,"pos":4840}},"ins_contents":[{"Add":{"text":"void State::notifyBuildStarted(pqxx::work & txn, BuildID buildId)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:734"}}],"del_contents":[{"Del":{"text":"void State::notificationSender()","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1380"}}]}},{"Replacement":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":458,"ins":{"up_context":[{"change":11,"pos":1383}],"down_context":[{"change":7,"pos":771}],"flag":"BLOCK","start":736,"end":796,"inode":{"change":42,"pos":4840}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1383},"to":{"change":11,"start":1383,"end":1416},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1416},"to":{"change":11,"start":170,"end":171},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":170},"to":{"change":11,"start":170,"end":171},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":171},"to":{"change":11,"start":1417,"end":1801},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1801},"to":{"change":11,"start":0,"end":1},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1},"to":{"change":8,"start":512,"end":578},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":11,"pos":58},"to":{"change":11,"start":1801,"end":1802},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":8,"pos":578},"to":{"change":11,"start":1801,"end":1802},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1801},"to":{"change":11,"start":1801,"end":1802},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1802},"to":{"change":11,"start":653,"end":744},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":744},"to":{"change":11,"start":1896,"end":1897},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1896},"to":{"change":11,"start":1896,"end":1897},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1897},"to":{"change":11,"start":59,"end":118},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":118},"to":{"change":11,"start":1897,"end":1940},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1897},"to":{"change":11,"start":1897,"end":1940},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1940},"to":{"change":11,"start":1732,"end":2662},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2662},"to":{"change":10,"start":0,"end":94},"introduced_by":10},{"previous":"","flag":"DELETED","from":{"change":10,"pos":94},"to":{"change":11,"start":2117,"end":2300},"introduced_by":10},{"previous":"","flag":"DELETED","from":{"change":11,"pos":212},"to":{"change":11,"start":2117,"end":2300},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":2662},"to":{"change":11,"start":2117,"end":2300},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2117},"to":{"change":11,"start":2117,"end":2300},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2300},"to":{"change":11,"start":184,"end":218},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":218},"to":{"change":11,"start":2338,"end":2339},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2338},"to":{"change":11,"start":2338,"end":2339},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2339},"to":{"change":5,"start":0,"end":133},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":133},"to":{"change":11,"start":2505,"end":2506},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":11,"pos":990},"to":{"change":11,"start":2505,"end":2506},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2505},"to":{"change":11,"start":2505,"end":2506},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2506},"to":{"change":11,"start":119,"end":178},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":178},"to":{"change":7,"start":396,"end":771},"introduced_by":7}],"inode":{"change":42,"pos":4840}},"ins_contents":[{"Add":{"text":" txn.exec(fmt(\"notify build_started, '%s'\", buildId));","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:793"}},{"Add":{"text":"}","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:795"}}],"del_contents":[{"Del":{"text":" while (true) {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1401"}},{"Del":{"text":" try {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1415"}},{"Del":{"text":"","pos":"K5G5GZY7D7KWVR5RAGZFHH3ZPG5OCLZT4HZ6XIJJ7YYVUMC2CTZQC:170"}},{"Del":{"text":" NotificationItem item;","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1451"}},{"Del":{"text":" {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1465"}},{"Del":{"text":" auto notificationSenderQueue_(notificationSenderQueue.lock());","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1544"}},{"Del":{"text":" while (notificationSenderQueue_->empty())","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1602"}},{"Del":{"text":" notificationSenderQueue_.wait(notificationSenderWakeup);","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1679"}},{"Del":{"text":" item = notificationSenderQueue_->front();","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1737"}},{"Del":{"text":" notificationSenderQueue_->pop();","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1786"}},{"Del":{"text":" }","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1800"}},{"Del":{"text":"","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:0"}},{"Del":{"text":" MaintainCount mc(nrNotificationsInProgress);","pos":"LSUX6IQR7TBTTCDQAVD3KDAVARLM7SUD7PPVTR5IOKA3BNZDYA7AC:577"}},{"Del":{"text":"","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1801"}},{"Del":{"text":" printMsg(lvlChatty, format(\"sending notification about build %1%\") % item.id);","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:743"}},{"Del":{"text":"","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1896"}},{"Del":{"text":" auto now1 = std::chrono::steady_clock::now();","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:116"}},{"Del":{"text":"","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:117"}},{"Del":{"text":" Pid pid = startProcess([&]() {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:1939"}},{"Del":{"text":" Strings argv;","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:1761"}},{"Del":{"text":" switch (item.type) {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:1798"}},{"Del":{"text":" case NotificationItem::Type::BuildStarted:","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:1861"}},{"Del":{"text":" argv = {\"hydra-notify\", \"build-started\", std::to_string(item.id)};","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:1952"}},{"Del":{"text":" for (auto id : item.dependentIds)","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2010"}},{"Del":{"text":" argv.push_back(std::to_string(id));","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2074"}},{"Del":{"text":" break;","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2105"}},{"Del":{"text":" case NotificationItem::Type::BuildFinished:","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2169"}},{"Del":{"text":" argv = {\"hydra-notify\", \"build-finished\", std::to_string(item.id)};","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2261"}},{"Del":{"text":" for (auto id : item.dependentIds)","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2319"}},{"Del":{"text":" argv.push_back(std::to_string(id));","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2383"}},{"Del":{"text":" break;","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2414"}},{"Del":{"text":" case NotificationItem::Type::StepFinished:","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2477"}},{"Del":{"text":" argv = {\"hydra-notify\", \"step-finished\", std::to_string(item.id), std::to_string(item.stepNr), item.logPath};","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2611"}},{"Del":{"text":" break;","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2642"}},{"Del":{"text":" };","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2661"}},{"Del":{"text":" printMsg(lvlChatty, \"Executing hydra-notify \" + concatStringsSep(\" \", argv));","pos":"7LD275CWWC7L5V4ETGIQRMOEJV5JRUSYQ7LUFINAUGAHWANCREGAC:93"}},{"Del":{"text":" execvp(\"hydra-notify\", (char * *) stringsToCharPtrs(argv).data()); // FIXME: remove cast","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2221"}},{"Del":{"text":" throw SysError(\"cannot start hydra-notify\");","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2282"}},{"Del":{"text":" });","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2298"}},{"Del":{"text":"","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2299"}},{"Del":{"text":" int res = pid.wait();","pos":"X4KYZJBQ7WULUWTHAPX5BZTZR7C6HRCC4N4J5K726PGZKSY6FQOQC:217"}},{"Del":{"text":"","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2338"}},{"Del":{"text":" if (!statusOk(res))","pos":"ZUXMEUX6PPFXU7ELM3DL7ICM44UBRDNFHOKYZUD2YEJQSVWLTRSQC:31"}},{"Del":{"text":" throw Error(\"notification about build %d failed: %s\", item.id, statusToString(res));","pos":"ZUXMEUX6PPFXU7ELM3DL7ICM44UBRDNFHOKYZUD2YEJQSVWLTRSQC:132"}},{"Del":{"text":"","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2505"}},{"Del":{"text":" auto now2 = std::chrono::steady_clock::now();","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:176"}},{"Del":{"text":"","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:177"}},{"Del":{"text":" if (item.type == NotificationItem::Type::BuildFinished) {","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:465"}},{"Del":{"text":" auto conn(dbPool.get());","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:506"}},{"Del":{"text":" pqxx::work txn(*conn);","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:545"}},{"Del":{"text":" txn.parameterized","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:579"}},{"Del":{"text":" (\"update Builds set notificationPendingSince = null where id = $1\")","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:667"}},{"Del":{"text":" (item.id)","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:697"}},{"Del":{"text":" .exec();","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:726"}},{"Del":{"text":" txn.commit();","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:756"}},{"Del":{"text":" }","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:770"}}]}},{"Edit":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":461,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":7,"pos":772},"to":{"change":11,"start":178,"end":325},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":178},"to":{"change":11,"start":178,"end":325},"introduced_by":11}],"inode":{"change":42,"pos":4840}}},"contents":[{"Del":{"text":" nrNotificationTimeMs += std::chrono::duration_cast(now2 - now1).count();","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:289"}},{"Del":{"text":" nrNotificationsDone++;","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:324"}}]}},{"Replacement":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":462,"ins":{"up_context":[{"change":11,"pos":326}],"down_context":[{"change":11,"pos":2662}],"flag":"BLOCK","start":797,"end":1145,"inode":{"change":42,"pos":4840}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":11,"pos":326},"to":{"change":11,"start":2506,"end":2545},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2506},"to":{"change":11,"start":2506,"end":2545},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2545},"to":{"change":11,"start":327,"end":364},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":364},"to":{"change":11,"start":2545,"end":2662},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2545},"to":{"change":11,"start":2545,"end":2662},"introduced_by":11}],"inode":{"change":42,"pos":4840}},"ins_contents":[{"Add":{"text":"void State::notifyBuildFinished(pqxx::work & txn, BuildID buildId,","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:863"}},{"Add":{"text":" const std::vector & dependentIds)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:910"}},{"Add":{"text":"{","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:912"}},{"Add":{"text":" auto payload = fmt(\"%d \", buildId);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:952"}},{"Add":{"text":" for (auto & d : dependentIds)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:986"}},{"Add":{"text":" payload += fmt(\"%d \", d);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1020"}},{"Add":{"text":" // FIXME: apparently parameterized() doesn't support NOTIFY.","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1085"}},{"Add":{"text":" txn.exec(fmt(\"notify build_finished, '%s'\", payload));","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1144"}}],"del_contents":[{"Del":{"text":" } catch (std::exception & e) {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2544"}},{"Del":{"text":" nrNotificationsFailed++;","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:363"}},{"Del":{"text":" printMsg(lvlError, format(\"notification sender: %1%\") % e.what());","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2623"}},{"Del":{"text":" sleep(5);","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2645"}},{"Del":{"text":" }","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2655"}},{"Del":{"text":" }","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2661"}}]}},{"Edit":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":541,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1487},"to":{"change":11,"start":365,"end":938},"introduced_by":11}],"inode":{"change":42,"pos":4840}}},"contents":[{"Del":{"text":" root.attr(\"nrNotificationsDone\", nrNotificationsDone);","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:427"}},{"Del":{"text":" root.attr(\"nrNotificationsFailed\", nrNotificationsFailed);","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:494"}},{"Del":{"text":" root.attr(\"nrNotificationsInProgress\", nrNotificationsInProgress);","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:569"}},{"Del":{"text":" root.attr(\"nrNotificationsPending\", notificationSenderQueue.lock()->size());","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:654"}},{"Del":{"text":" root.attr(\"nrNotificationTimeMs\", nrNotificationTimeMs);","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:719"}},{"Del":{"text":" uint64_t nrNotificationsTotal = nrNotificationsDone + nrNotificationsFailed;","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:804"}},{"Del":{"text":" root.attr(\"nrNotificationTimeAvgMs\", nrNotificationsTotal == 0 ? 0.0 : (float) nrNotificationTimeMs / nrNotificationsTotal);","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:937"}}]}},{"Edit":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":787,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":92},"to":{"change":11,"start":398,"end":399},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3153},"to":{"change":11,"start":2722,"end":2763},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2763},"to":{"change":6,"start":0,"end":221},"introduced_by":6}],"inode":{"change":42,"pos":4840}}},"contents":[{"Del":{"text":"","pos":"XV4AEKJCFTNCOR52IRFYHORCNNFKIHOADIUARTC2U5Z6ZQBEEFYQC:398"}},{"Del":{"text":" /* Idem for notification sending. */","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:2762"}},{"Del":{"text":" auto maxConcurrentNotifications = config->getIntOption(\"max-concurrent-notifications\", 2);","pos":"HZZCYIYTIZ7PUGXNMZSEO463LS4VO7ADUH3QPZQCLMBTPPPOOJSQC:94"}},{"Del":{"text":" for (uint64_t i = 0; i < maxConcurrentNotifications; ++i)","pos":"HZZCYIYTIZ7PUGXNMZSEO463LS4VO7ADUH3QPZQCLMBTPPPOOJSQC:156"}},{"Del":{"text":" std::thread(&State::notificationSender, this).detach();","pos":"HZZCYIYTIZ7PUGXNMZSEO463LS4VO7ADUH3QPZQCLMBTPPPOOJSQC:220"}}]}},{"Edit":{"inode":{"change":42,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":788,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2824},"to":{"change":7,"start":773,"end":1280},"introduced_by":7}],"inode":{"change":42,"pos":4840}}},"contents":[{"Del":{"text":" /* Enqueue notification items for builds that were finished","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:836"}},{"Del":{"text":" previously, but for which we didn't manage to send","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:894"}},{"Del":{"text":" notifications. */","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:919"}},{"Del":{"text":" {","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:925"}},{"Del":{"text":" auto conn(dbPool.get());","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:958"}},{"Del":{"text":" pqxx::work txn(*conn);","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:989"}},{"Del":{"text":" auto res = txn.parameterized(\"select id from Builds where notificationPendingSince > 0\").exec();","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1094"}},{"Del":{"text":" for (auto const & row : res) {","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1133"}},{"Del":{"text":" auto id = row[\"id\"].as();","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1180"}},{"Del":{"text":" enqueueNotificationItem({NotificationItem::Type::BuildFinished, id});","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1262"}},{"Del":{"text":" }","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1272"}},{"Del":{"text":" }","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1278"}},{"Del":{"text":"","pos":"B7ENVLRS2KLKEG66TY5G4EW6M274JZOBDUCRB7BFBXLTBG455STQC:1279"}}]}},{"Edit":{"inode":{"change":11,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":196,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":2304}],"down_context":[{"change":11,"pos":2304}],"flag":"BLOCK","start":1146,"end":1203,"inode":{"change":11,"pos":20067}}},"contents":[{"Add":{"text":" notifyBuildFinished(txn, build->id, {});","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1202"}}]}},{"Edit":{"inode":{"change":11,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":201,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2424},"to":{"change":3,"start":0,"end":90},"introduced_by":3}],"inode":{"change":11,"pos":20067}}},"contents":[{"Del":{"text":"","pos":"SMUWBAD5D2WF2Q5B75YIUQL76FQHY3C4W25OZDFVFCF5AIYUD4YAC:0"}},{"Del":{"text":" enqueueNotificationItem({NotificationItem::Type::BuildFinished, build->id});","pos":"SMUWBAD5D2WF2Q5B75YIUQL76FQHY3C4W25OZDFVFCF5AIYUD4YAC:89"}}]}},{"Edit":{"inode":{"change":11,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":232,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":25116}],"down_context":[{"change":11,"pos":25116}],"flag":"BLOCK","start":1204,"end":1257,"inode":{"change":11,"pos":20067}}},"contents":[{"Add":{"text":" notifyBuildFinished(txn, build->id, {});","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1256"}}]}},{"Edit":{"inode":{"change":11,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":238,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":92},"to":{"change":3,"start":92,"end":181},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":181},"to":{"change":11,"start":25183,"end":25184},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":25183},"to":{"change":11,"start":25183,"end":25184},"introduced_by":11}],"inode":{"change":11,"pos":20067}}},"contents":[{"Del":{"text":" enqueueNotificationItem({NotificationItem::Type::BuildFinished, build->id});","pos":"SMUWBAD5D2WF2Q5B75YIUQL76FQHY3C4W25OZDFVFCF5AIYUD4YAC:180"}},{"Del":{"text":"","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:25183"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":350,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":910},"to":{"change":11,"start":939,"end":1092},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":910},"to":{"change":11,"start":6084,"end":6085},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1092},"to":{"change":11,"start":6084,"end":6085},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":6084},"to":{"change":11,"start":6084,"end":6085},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":6223},"to":{"change":11,"start":6223,"end":6498},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":6498},"to":{"change":11,"start":991,"end":1058},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1058},"to":{"change":11,"start":2843,"end":2919},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":2919},"to":{"change":11,"start":1098,"end":1191},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1098},"to":{"change":11,"start":1098,"end":1191},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1191},"to":{"change":11,"start":2920,"end":2976},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":2976},"to":{"change":11,"start":1191,"end":1198},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1191},"to":{"change":11,"start":1191,"end":1198},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1198},"to":{"change":11,"start":2097,"end":2220},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":6569},"to":{"change":11,"start":2097,"end":2220},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":2220},"to":{"change":11,"start":6691,"end":6692},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":6691},"to":{"change":11,"start":6691,"end":6692},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":6692},"to":{"change":11,"start":2977,"end":3249},"introduced_by":11}],"inode":{"change":11,"pos":1128}}},"contents":[{"Del":{"text":" counter nrNotificationsDone{0};","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:974"}},{"Del":{"text":" counter nrNotificationsFailed{0};","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:1012"}},{"Del":{"text":" counter nrNotificationsInProgress{0};","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:1054"}},{"Del":{"text":" counter nrNotificationTimeMs{0};","pos":"JPHDKOMJEDZQYRACBIJ57SJME7IZNLDJY7RB6QR47KG7IL3PG7UAC:1091"}},{"Del":{"text":"","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:6084"}},{"Del":{"text":" /* Notification sender work queue. FIXME: if hydra-queue-runner is","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:6293"}},{"Del":{"text":" killed before it has finished sending notifications about a","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:6360"}},{"Del":{"text":" build, then the notifications may be lost. It would be better","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:6429"}},{"Del":{"text":" to mark builds with pending notification in the database. */","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:6497"}},{"Del":{"text":" struct NotificationItem","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1018"}},{"Del":{"text":" {","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1024"}},{"Del":{"text":" enum class Type : char {","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1057"}},{"Del":{"text":" BuildStarted,","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2867"}},{"Del":{"text":" BuildFinished,","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2893"}},{"Del":{"text":" StepFinished,","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2918"}},{"Del":{"text":" };","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1108"}},{"Del":{"text":" Type type;","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1127"}},{"Del":{"text":" BuildID id;","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1147"}},{"Del":{"text":" std::vector dependentIds;","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1190"}},{"Del":{"text":" unsigned int stepNr;","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2948"}},{"Del":{"text":" nix::Path logPath;","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:2975"}},{"Del":{"text":" };","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1197"}},{"Del":{"text":" nix::Sync> notificationSenderQueue;","pos":"B2L4T3X63XVYJQXEDU4WT5Y4R6PMDXGC6WN2KGOMHRQILSABNQOAC:2165"}},{"Del":{"text":" std::condition_variable notificationSenderWakeup;","pos":"B2L4T3X63XVYJQXEDU4WT5Y4R6PMDXGC6WN2KGOMHRQILSABNQOAC:2219"}},{"Del":{"text":"","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:6691"}},{"Del":{"text":" void enqueueNotificationItem(const NotificationItem && item)","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3041"}},{"Del":{"text":" {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3047"}},{"Del":{"text":" {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3057"}},{"Del":{"text":" auto notificationSenderQueue_(notificationSenderQueue.lock());","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3132"}},{"Del":{"text":" notificationSenderQueue_->emplace(item);","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3185"}},{"Del":{"text":" }","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3195"}},{"Del":{"text":" notificationSenderWakeup.notify_one();","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3242"}},{"Del":{"text":" }","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3248"}}]}},{"Replacement":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":510,"ins":{"up_context":[{"change":11,"pos":8698}],"down_context":[{"change":11,"pos":8917}],"flag":"BLOCK","start":1258,"end":1439,"inode":{"change":11,"pos":1128}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":8792},"to":{"change":11,"start":8792,"end":8917},"introduced_by":11}],"inode":{"change":11,"pos":1128}},"ins_contents":[{"Add":{"text":" void notifyBuildStarted(pqxx::work & txn, BuildID buildId);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1321"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1322"}},{"Add":{"text":" void notifyBuildFinished(pqxx::work & txn, BuildID buildId,","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1386"}},{"Add":{"text":" const std::vector & dependentIds);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1438"}}],"del_contents":[{"Del":{"text":" /* Thread that asynchronously invokes hydra-notify to send build","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:8860"}},{"Del":{"text":" notifications. */","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:8885"}},{"Del":{"text":" void notificationSender();","pos":"HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC:8916"}}]}},{"Edit":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":8,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":5666}],"down_context":[{"change":11,"pos":3128}],"flag":"BLOCK","start":1440,"end":1456,"inode":{"change":11,"pos":2994}}},"contents":[{"Add":{"text":"use IO::Select;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1455"}}]}},{"Edit":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":18,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":3326}],"down_context":[{"change":11,"pos":3326}],"flag":"BLOCK","start":1457,"end":1487,"inode":{"change":11,"pos":2994}}},"contents":[{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1457"}},{"Add":{"text":"my $dbh = $db->storage->dbh;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1486"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":21,"ins":{"up_context":[{"change":11,"pos":3327}],"down_context":[{"change":11,"pos":3412}],"flag":"BLOCK","start":1488,"end":1635,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3327},"to":{"change":11,"start":3662,"end":3820},"introduced_by":11}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":"$dbh->do(\"listen build_started\");","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1521"}},{"Add":{"text":"$dbh->do(\"listen build_finished\");","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1556"}},{"Add":{"text":"$dbh->do(\"listen step_finished\");","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1590"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1591"}},{"Add":{"text":"sub buildStarted {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1610"}},{"Add":{"text":" my ($buildId) = @_;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1634"}}],"del_contents":[{"Del":{"text":"my $cmd = shift @ARGV or die \"Syntax: hydra-notify build-started BUILD | build-finished BUILD-ID [BUILD-IDs...] | step-finished BUILD-ID STEP-NR LOG-PATH\\n\";","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:3819"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":28,"ins":{"up_context":[{"change":11,"pos":3413}],"down_context":[{"change":11,"pos":3821}],"flag":"BLOCK","start":1636,"end":1921,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3413},"to":{"change":11,"start":1658,"end":1791},"introduced_by":11}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":" my $build = $db->resultset('Builds')->find($buildId)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1692"}},{"Add":{"text":" or die \"build $buildId does not exist\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1742"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1743"}},{"Add":{"text":" foreach my $plugin (@plugins) {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1779"}},{"Add":{"text":" eval { $plugin->buildStarted($build); };","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1828"}},{"Add":{"text":" if ($@) {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1846"}},{"Add":{"text":" print STDERR \"$plugin->buildStarted: $@\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1902"}},{"Add":{"text":" }","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1912"}},{"Add":{"text":" }","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1918"}},{"Add":{"text":"}","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1920"}}],"del_contents":[{"Del":{"text":"my $buildId = shift @ARGV or die;","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1691"}},{"Del":{"text":"my $build = $db->resultset('Builds')->find($buildId)","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1744"}},{"Del":{"text":" or die \"build $buildId does not exist\\n\";","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1790"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":39,"ins":{"up_context":[{"change":11,"pos":3822}],"down_context":[{"change":11,"pos":5667}],"flag":"BLOCK","start":1922,"end":1972,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":11,"pos":3822},"to":{"change":11,"start":1791,"end":1823},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1791},"to":{"change":11,"start":1791,"end":1823},"introduced_by":11}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":"sub buildFinished {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1941"}},{"Add":{"text":" my ($build, @deps) = @_;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1970"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1971"}}],"del_contents":[{"Del":{"text":"if ($cmd eq \"build-finished\") {","pos":"FCTX433OH7QIVWHXL23DKVSUKBQSLQTRK3PFCKKSMLX6A634456QC:1822"}}]}},{"Edit":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":47,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":5892}],"down_context":[{"change":11,"pos":3581}],"flag":"BLOCK","start":1973,"end":1974,"inode":{"change":11,"pos":2994}}},"contents":[{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1973"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":49,"ins":{"up_context":[{"change":11,"pos":3601}],"down_context":[{"change":11,"pos":3630}],"flag":"BLOCK","start":1975,"end":2004,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3601},"to":{"change":11,"start":3601,"end":3630},"introduced_by":11}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":" foreach my $id (@deps) {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2003"}}],"del_contents":[{"Del":{"text":" foreach my $id (@ARGV) {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:3629"}}]}},{"Edit":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":61,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":4016}],"down_context":[{"change":11,"pos":4016}],"flag":"BLOCK","start":2005,"end":2065,"inode":{"change":11,"pos":2994}}},"contents":[{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2005"}},{"Add":{"text":" $build->update({ notificationpendingsince => undef });","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2064"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":65,"ins":{"up_context":[{"change":11,"pos":4019}],"down_context":[{"change":4,"pos":473}],"flag":"BLOCK","start":2066,"end":2128,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":4019},"to":{"change":4,"start":265,"end":473},"introduced_by":4}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":"sub stepFinished {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2084"}},{"Add":{"text":" my ($buildId, $stepNr, $logPath) = @_;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2127"}}],"del_contents":[{"Del":{"text":"elsif ($cmd eq \"build-queued\") {","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:297"}},{"Del":{"text":" foreach my $plugin (@plugins) {","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:333"}},{"Del":{"text":" eval { $plugin->buildQueued($build); };","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:381"}},{"Del":{"text":" if ($@) {","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:399"}},{"Del":{"text":" print STDERR \"$plugin->buildQueued: $@\\n\";","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:454"}},{"Del":{"text":" }","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:464"}},{"Del":{"text":" }","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:470"}},{"Del":{"text":"}","pos":"PXTSKX4GBDOBMI4MDO64DBIHSEVTM6IZ5O6GUFXK6UL63GHWBMBAC:472"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":68,"ins":{"up_context":[{"change":4,"pos":474}],"down_context":[{"change":11,"pos":4230}],"flag":"BLOCK","start":2129,"end":2236,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":474},"to":{"change":11,"start":4019,"end":4230},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":4019},"to":{"change":11,"start":4019,"end":4230},"introduced_by":11}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":" my $build = $db->resultset('Builds')->find($buildId)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2185"}},{"Add":{"text":" or die \"build $buildId does not exist\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2235"}}],"del_contents":[{"Del":{"text":"elsif ($cmd eq \"build-started\") {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4052"}},{"Del":{"text":" foreach my $plugin (@plugins) {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4088"}},{"Del":{"text":" eval { $plugin->buildStarted($build); };","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4137"}},{"Del":{"text":" if ($@) {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4155"}},{"Del":{"text":" print STDERR \"$plugin->buildStarted: $@\\n\";","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4211"}},{"Del":{"text":" }","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4221"}},{"Del":{"text":" }","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4227"}},{"Del":{"text":"}","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4229"}}]}},{"Edit":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":71,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":4231},"to":{"change":11,"start":4231,"end":4265},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":4265},"to":{"change":9,"start":0,"end":59},"introduced_by":9}],"inode":{"change":11,"pos":2994}}},"contents":[{"Del":{"text":"elsif ($cmd eq \"step-finished\") {","pos":"NTEDD7T4M7XXYCWNZN57EJOEH3KI3UYMHOANV4MY2LSUPWX3JRDQC:4264"}},{"Del":{"text":" die if scalar @ARGV < 2;","pos":"7Q2PXRZAERQFX53OEZGY26ZELA2KRWGXDA5QEYQQVUF5ME65Z7TQC:28"}},{"Del":{"text":" my $stepNr = shift @ARGV;","pos":"7Q2PXRZAERQFX53OEZGY26ZELA2KRWGXDA5QEYQQVUF5ME65Z7TQC:58"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":73,"ins":{"up_context":[{"change":11,"pos":4411}],"down_context":[{"change":11,"pos":4449}],"flag":"BLOCK","start":2237,"end":2279,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":4411},"to":{"change":9,"start":60,"end":131},"introduced_by":9}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2237"}},{"Add":{"text":" $logPath = undef if $logPath eq \"-\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2278"}}],"del_contents":[{"Del":{"text":" my $logPath = shift @ARGV;","pos":"7Q2PXRZAERQFX53OEZGY26ZELA2KRWGXDA5QEYQQVUF5ME65Z7TQC:90"}},{"Del":{"text":" $logPath = undef if $logPath eq \"\";","pos":"7Q2PXRZAERQFX53OEZGY26ZELA2KRWGXDA5QEYQQVUF5ME65Z7TQC:130"}}]}},{"Replacement":{"inode":{"change":11,"pos":2994},"path":"src/script/hydra-notify","line":84,"ins":{"up_context":[{"change":11,"pos":3833}],"down_context":[{"change":11,"pos":3877}],"flag":"BLOCK","start":2280,"end":3569,"inode":{"change":11,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3833},"to":{"change":11,"start":3833,"end":3877},"introduced_by":11}],"inode":{"change":11,"pos":2994}},"ins_contents":[{"Add":{"text":"# Process builds that finished while hydra-notify wasn't running.","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2345"}},{"Add":{"text":"for my $build ($db->resultset('Builds')->search(","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2394"}},{"Add":{"text":" { notificationpendingsince => { '!=', undef } }))","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2463"}},{"Add":{"text":"{","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2465"}},{"Add":{"text":" my $buildId = $build->id;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2495"}},{"Add":{"text":" print STDERR \"sending notifications for build ${\\$buildId}...\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2565"}},{"Add":{"text":" buildFinished($build);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2592"}},{"Add":{"text":"}","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2594"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2595"}},{"Add":{"text":"# Process incoming notifications.","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2629"}},{"Add":{"text":"my $fd = $dbh->func(\"getfd\");","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2659"}},{"Add":{"text":"my $sel = IO::Select->new($fd);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2691"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2692"}},{"Add":{"text":"while (1) {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2704"}},{"Add":{"text":" $sel->can_read;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2724"}},{"Add":{"text":" my $notify = $dbh->func(\"pg_notifies\");","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2768"}},{"Add":{"text":" next if !$notify;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2790"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2791"}},{"Add":{"text":" my ($channelName, $pid, $payload) = @$notify;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2841"}},{"Add":{"text":" #print STDERR \"got '$channelName' from $pid: $payload\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2903"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2904"}},{"Add":{"text":" my @payload = split / /, $payload;","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2943"}},{"Add":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2944"}},{"Add":{"text":" eval {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2955"}},{"Add":{"text":" if ($channelName eq \"build_started\") {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3002"}},{"Add":{"text":" buildStarted(int($payload[0]));","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3046"}},{"Add":{"text":" } elsif ($channelName eq \"build_finished\") {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3099"}},{"Add":{"text":" my $buildId = int($payload[0]);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3143"}},{"Add":{"text":" my $build = $db->resultset('Builds')->find($buildId)","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3208"}},{"Add":{"text":" or die \"build $buildId does not exist\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3266"}},{"Add":{"text":" buildFinished($build, @payload[1..$#payload]);","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3325"}},{"Add":{"text":" } elsif ($channelName eq \"step_finished\") {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3377"}},{"Add":{"text":" stepFinished(int($payload[0]), int($payload[1]));","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3439"}},{"Add":{"text":" }","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3449"}},{"Add":{"text":" };","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3456"}},{"Add":{"text":" if ($@) {","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3470"}},{"Add":{"text":" print STDERR \"error processing message '$payload' on channel '$channelName': $@\\n\";","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3562"}},{"Add":{"text":" }","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:3568"}}],"del_contents":[{"Del":{"text":"else {","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:3839"}},{"Del":{"text":" die \"unknown action ‘$cmd’\";","pos":"IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC:3876"}}]}}],"owner":"grahamc","repo":"hydra","token":"lxfMzsgBKCc2jo5VnJNDvrUh7BweDWk6XMVYygZsE7I=","login":null}

…

Dependencies

Change contents

Review