{"header":{"message":"Concurrent hydra-evaluator","description":"This rewrites the top-level loop of hydra-evaluator in C++. The Perl\nstuff is moved into hydra-eval-jobset. (Rewriting the entire evaluator\nwould be nice but is a bit too much work.) The new version has some\nadvantages:\n\n* It can run multiple jobset evaluations in parallel.\n\n* It uses PostgreSQL notifications so it doesn't have to poll the\n database. So if a jobset is triggered via the web interface or from\n a GitHub / Bitbucket webhook, evaluation of the jobset will start\n almost instantaneously (assuming the evaluator is not at its\n concurrency limit).\n\n* It imposes a timeout on evaluations. So if e.g. hydra-eval-jobset\n hangs connecting to a Mercurial server, it will eventually be\n killed.","timestamp":"2016-10-13T13:53:05Z","authors":[{"email":"edolstra@gmail.com","name":"Eelco Dolstra"}]},"hash":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC","authors":[],"deps":{"hashes":[["4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC","Concurrent hydra-evaluator"],["AA",null],["Z4Y3TVEEN6LIGBRCMWVFZYFFE6NKHUSO76RZ3GSPTZEME3CBLUTAC","hydra-queue-{runner,evaluator}: don't clutter the system log with debug messages"],["3CVY4QJXRFFA6V4JVBPMSPRKL2KGBCCE3HSOFWVUK76GIGO3NDPAC","hydra-evaluator: Do the actual work in a subprocess"],["N66HHKLQGRAVLPEO2LTAOGGXKZUYKYQSSOG4MQAMQVUIXVHIYP3QC","Drop the 5 minute minimum interval between triggered evals"],["ACBS7C6QGXAMPLQ336WAQMMGLZXBDNNYPE26ZBPUQ24GL4BF643AC","hydra-queue-runner: Detect changes to the scheduling shares"],["Q3VTDUSQ75JD5L55VWQV6MGAS6IC4AWGSADL2ISMX5E7R3LBVBHAC","Fix the API test"],["4VYY2ADPFENPAC36FJCSEMEHOPL6E2T4RPXJKYVF47DFKAO6PLIAC","Allow the machines file to specify host public keys"],["3X6FN7RGF2MNQDBVXQHWOCVGWBMGAJXTXHH2B4N7JIRSZZSWU3UAC","Print jobset name when evaluator fails"],["PKTKSVTLHM5L6MOKXDQOJZ35FV2VXAD556S26QMICR6SNIY56LBQC","Bump Nix"],["FYXZQ55GY3O5B4HHKUDU2UQZPTB7RXF4GXBF4ZZL5IIM4TVL7Y3QC","Drop obsolete -laws-cpp-sdk-s3"],["AMFMXR52JXHUOWWG4VZ5DHQGLF4F7H7XSJRLX5XNEXOCCWYLDQOAC","Provide a command ‘hydra-init’ to initialise/upgrade the database"],["J7WIAUWTYAUXLXVND7I45NOGHMDT4GGB5GPRJCXJJDGKQHWSVVGQC","Better error message"],["Q6SOGMDQJAUDMVINADMRAFUMN4TDTUAX3ZEIL3DBEXNRLDN5UNUQC","Hydra/28: Rename \"scheduler\" to \"evaluator\""],["TULPZ62YXEHXUWGBZMLCLYILEXPQS5ADPT22574BIRFU4CZMBSKAC","* Perform builds in parallel."],["Y6H7Y3OTXVLF6PJ5BR6WXS7KVS4VMTUKRYVM6FALKMY3DCBYEJSQC","Capture the path to `guile', when available."],["MB3TISH2KYBIGY6XJKMN4HO2S6TCN2GORJENMECCKLXGGIRS2O2AC","Rate-limit the number of threads copying closures at the same time"],["3YHNO5H2IBHEAHVVYKTD4TYWR5AU2MUWYYMMCRSEIL5MDGRXMTIAC","Don't use Perl's -w flag"],["N4IROACVZ4MU73J5SM6WXJMKQSFR3VN5SOKENNNZNEGMTGB2Q3HAC","Move buildRemote() into State"],["V6H6BWMKUGENVYLLCT56NWU7YYPADYI65Q4KSGPOJIZF2LWQRN2QC","Sync with Nix"],["C3AG65SWAGDSML5MBD4ZPRCHI2LNNDN6IQZOI3HLYRJRPAW3QPAAC","Add one-shot jobsets"],["7LB6QBXYOGU43UDLJDJQZFGT4XDALULXDF3WX3WWHL7X3JTB54CQC","Keep track of the number of build steps that are being built"],["FV2M6MOTAP4BJMEKU5XUDVEACWEJGEIRCCE2MRY3F6SF2SFOE3MQC","hydra: use autoconf/-make"],["YI3BZG5NWMKBT7T2HEOHVHSZBQ5KPDWSI3VRYOMQ346LRFB4MR2AC","Cleanup Jobset serialization"],["24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","Start of single-process hydra-queue-runner"],["3YSJ3LYKWE7ZXYGXLJI56CN6CGXXC4QO2ZDDA5VYGDSVXJ5QSIDQC","Remove finally.hh"],["UGA45FNCYAHX77QI3MTMSRF676N2BUW2ZUUI4OZCI2C3EJOYKY3QC","Add a plugin for backing up builds in s3"],["7VHPMFAGIYN4NCFBVPVCYDENEDB6KPNMHPWML7WJJUESK6ZQYMJQC","Use /usr/bin/env to find perl"],["M2CFFNJYY5BNXNIIYA72FKME3NUAETW4OWWWBSO4KMU7VP2YAXNAC","Remove unused file"],["SQQSV4NBN6QB6BZVC7FCUFMWEKSGSNATQ3IFOVXJNTGSSGP4YM3QC","* Top-level: don't exit on errors."],["QIW2WZKWE3ULO4O4QB6EQWUKZY2UFNN7WA464FMIZOAHP3UHFGSAC","Fix indentation"],["T4LLYESZ2HUXSLKZ6GNBLVWUVG7R5IDFHYHYO773QIZ6QTOOXR2AC","* Nix expression for building Hydra."],["4VYSDP4IAWIIVLXCKXJEYWIHZV3PUD3VACX3K4EIQKPFGWLZK6HQC","Add eager fetching of relations and enable that for jobset->jobsetinputs"],["MQYHIUEEIMJHLABLHRJTJSHITJMHRHMF7NACHRD7QRBJCA3GQPRQC","Cleanup eval serialization"],["QMW24O5S43MYF5ZTBULUEZNDW2FKJ3QP2GL46P6B2SVGSQLVEACAC","Add support for Guile & Guix."],["MDAIP23T737NBX64IA4Z3HY2HVHLOQYPV6DYTDUXR6ERAXB7XYZQC","hydra-evaluator: Respect triggers of disabled jobsets"],["YZAI5GQU3HNMK5MEGF2Y7WS445AN4YKD3HNJQVQP545ODN3F5DLAC","Implement a database connection pool"],["34UH6B6LBITNUL6HXSPLL3657R73LC6C34QMJJLKTMLUGHFTLUSQC","Build against the bleeding edge of Nix"],["OB7GB5DLJ3NCVUELTTNPBNGIT757BIYQ452WKNOCNLY3SAI4HHAQC","Test environment cleanups"],["MS676RZWKHV4QNY2IILGKVA4DYOKFMSUCP2WTTJT374R3B3U2D6QC","Remove s3binarystore (moved to nix in d155d80)"],["NI5BVF2VLMDA7REXTV455SUCQAYMKPKNKQSRII2SJJGG2TCX4CTAC","* In job inputs of type \"build\", allow the project and jobset names of"],["RXVJFQ5AV3WME4HDVBPSRCALQTXROT4KQPOQVO6KTWTBNZIZZGPAC","Evaluator cleanups"],["PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC","Support push notification of repository changes"],["DODOGD7MRCMRVGX23RPY2243WG54HCMCEZ6DCHOGID3GBQB66CXQC","Send queue runner stats to statsd"],["L4AI5YL6CBMVS5GEPME3WIL2CHACMU7PGEKKNKLHHF5SP4ID3LCQC","Rename hydra_*.pl to hydra-*"],["5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","Basic remote building"],["UXRNODRJJU7A33F4PG24WOHKTJFI3XQMZGT2MUOBRAH2MPQ7NZ2AC","Remove hydra-build and the old hydra-queue-runner"],["SBKX3YH2EOCYY2IDACGOTXHJZSYSRHD5EC7FB6WGPKHLFYOF6SAAC","cleanup"],["UQYHPQ6UO7LIQ4P6NSCAEV677K52RQOQKCF4KSGNXMMFOQKY7IPQC","Run PostgreSQL during \"make check\""],["XLYHZUHTGM3HJBIINHPY4JLMENBFXPQEZYNEXENUOX3C47JLXJMAC","Cache .narinfo lookups"],["FS3HUMVUIZ2YWZVAO4VWJES23FUSFTQ5TMWWDCJ7KPZBRPXTN35AC","Fix Makefile.am"],["N2NKSKHSFR6SDMGZO2ALNDVIOLOEE26BPQHCSWUGEFE3DVVVV4MAC","Refactor local binary cache code into a subclass"],["X27GNHDV5KPZ5GSH6DCAJMNCEMZLCP7M43JWF2X3O5QWXMOX273AC","* Basic job info in the database."],["GH4S4AWM2RUS3RUDU4E4TVQJF3N3LKM7OQQSZTG6H7NNMH6FKR7AC","Rename file"],["JK2QWPH6EOQXGCADV7C5HSYRVWC5M53LAKVN26EMTLY65IKU3AEQC",""],["ERNOO5ZZ5OBBIGIXCLWZHCR73UDUDK7VV5GFWV4HNSWFD4AHCESQC","* Reorganising."],["N22GPKYTOLZLBGTGDATQDVZ4R5APZEAOIA7L32X4UXBH4XNI7MWAC","* Put info about logs / build products in the DB."],["D5QIOJGPKQJIYBUCSC3MFJ3TXLPNZ2XMI37GXMFRVRFWWR2VMTFAC","* Move everything up one directory."],["XHOZT4WTBN3Y7Q2MBANFS65X4HYL6SGPA7JNB7T7OD726SU2ACWAC","Add a command `hydra-create-user' for managing user accounts"],["6MGFQDR2QXUVURENQQLXMYKKNB24PQZSQM6TGBXDV2AO2NYBLQDQC","deleted some old scripts"],["J74UTA3I7FHYJBO7FZMTQ3AQTZPD36DD7RFVGJHLHLOZ5YBPNONQC","Handle the case where a jobset has never been evaluated"],["ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC","Make concurrency more robust"],["73YR46NJNYZQKHA3QDJCAZYAKC2CGEF5LIS44NOIPDZU6FX6BDPQC","hydra-queue-runner: Write directly to a binary cache"],["7VQ4ALFYKJBFR46T3WZDMGOXNRR3QNJEJQVBYJM4HSJUOOUD6WBQC","Update \"make check\" for the new queue runner"],["GTUZLZRHJ6GL5BNXOO3GA6Y3GFO7AXLIVPQHSG26LCF42KC2N7LQC","Add an S3-backed binary cache store"],["B2L4T3X63XVYJQXEDU4WT5Y4R6PMDXGC6WN2KGOMHRQILSABNQOAC","Sync with Nix"],["MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","Split hydra-queue-runner.cc more"],["HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","Refactor"],["KS7NNPQWGV6HRWZLF23H673PPA3EPORWIT75SLRYDKOZIAOWMASQC","Bleh Automake"],["DIEY5USNXFN6O2ARZ5IPBS2VX4OH7KE4RMX2JWAWTVMMSYA6GREAC","Keep better bytesReceived/bytesSent stats"],["RBZRCTALK2SLKX6HDMBS25BRNYPK3GK364MGAVCXP3MW5CEW5TKQC","hydra: fixed and re-enabled evaluation tests"],["OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC","hydra-evaluator: Always pick the jobset that hasn't been evaluated longest"],["GAZHOBWEXOSWFNJYOYXASH3LCOLREWB3DZXELIAP2Q6L2X2ZSI4QC","Better fix"],["6K5PBUUN4GQAMOVX5BS6YYMHJ3PIF2PPZBTIEQ4R7BQNHC23GS3AC","Use buildEnv to combine Hydra's Perl dependencies"],["NP7IOJ4QI25BLULQEYBACUR4KXWMYLNTM2K5VNPX2FAFGHZ37WYAC","Flesh out the API a bit"],["53PW36WSP3WZOGHI4OSMX2I26O32WWZOZJH3B2W67JZMRKAOWTXAC","hydra-evaluator: When evaluating a single jobset, exit with a failure code if evaluation fails"],["UN2KZL3A6LWA72ZFRHSFUV23OZSVVP26BX7IGQDWJZGAHAXWJO3QC","Rename c -> hydra-eval-jobs"],["6L3ZM55SJNE7HNUZ46SFEXV6MGDZNI26XJTEDTGTP5ZPACNF43AAC","Add font for the captcha"],["RBQEBVT5RL4VVP6Y2V3IIKIX4E7USU5COI3W7Y2Y36VV3QFCTQQQC","Doh"],["WQ2VQ7H3CTHM47EOW3F3BB2OUAI7ZXX5FBBAD2DODQOFO5LRM4WAC","Use hydra-module.nix in the tests"],["D6YQQQCNJT7RJ4KF5JN76NM5HT4FVROBGSNB26LYPRYVLEG576MAC","* Don't ignore SIGCHLD after all, Perl doesn't like it. Just do"],["3PNG7NIBQQURUUPRVQXYL342OT7JUUYOMY2JJNP6YDX7SYJDZMYAC","Remove trailing whitespace"],["5QYMALGUFECBH44BDVLFRZR5CQ24UTSEELVMAGDNKY2JAKBZKQ3AC","Fix Perl error in tests.api"],["LZVO64YG43JD7YMZSCTZNOBS5ROZA4FMPKJW2YOMHX2V5PTGBVWQC","Merge in the first bits of the API work"],["5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC",""],["QAJK5MCERGUNMSKILOUAQKAYI5Y6HDNWTQUIN4M2KEENCSCJ35TQC","Remove obsolete hydra-control script"],["KYSBJAYN5KFQL7WV3TMQJD5BCKTQ3ZMKL6FREJ3NK2IPKCSCRDZAC","Allow dashes in jobset input names"],["ARD6Z67TDHK2XMW47CSVOXXF327YGOMYK3EAXTSVVXNDAFQYNO5AC","Do incremental SVN checkouts"],["KX5L74EYLS4YVSFG5H6U5H5TB6BQUFHHFUMLHTUUU6WFJLSRF5ZAC","add nix-prefetch- scripts for now, were externals in svn"],["TIOBBINAK6IEDTCFBP67QDP3U7BHPVJOHBD6FEHASSSIQGNLCUXAC","* Some renaming."],["QLOLZHRXOUSNVLJG2SWVC5EISFUOUKJIT32XN6DNW4VFFJMN5PMAC","Allow a per-jobset check interval"],["WJTP6VZILETQ4GWUNE7QPHQK3HWJJ6J5ILX2E7KYKUANAA4DBF4QC","Fix building against the latest Nix"],["IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC","hydra-queue-runner: Send build notifications"],["YQWH4POV22KYCCKOTZXD36QKUOWEQ2DSPYPO5DNZDZ344RI25OAAC","* Simplify."],["CLXEECMFKLUIN5QBV3BPPPSU6G5UF6MXRSNWA6LXUBNQGSJY4U5QC","* Start putting build results in a database."],["G2ZB6464XGPBIMSZIPSB24EIXSCCGV4XWC3IWPS2CXYPDSUZSU5QC","first test, not yet in buildprocess"],["HX4QYOYAKKFKK4KF6SZ6FQCM5ZF7ZFDTQUR4GS5WPPTYZASYZZUAC","add first evaluations tests"]],"deps":["Z4Y3TVEEN6LIGBRCMWVFZYFFE6NKHUSO76RZ3GSPTZEME3CBLUTAC","3CVY4QJXRFFA6V4JVBPMSPRKL2KGBCCE3HSOFWVUK76GIGO3NDPAC","N66HHKLQGRAVLPEO2LTAOGGXKZUYKYQSSOG4MQAMQVUIXVHIYP3QC","ACBS7C6QGXAMPLQ336WAQMMGLZXBDNNYPE26ZBPUQ24GL4BF643AC","Q3VTDUSQ75JD5L55VWQV6MGAS6IC4AWGSADL2ISMX5E7R3LBVBHAC","4VYY2ADPFENPAC36FJCSEMEHOPL6E2T4RPXJKYVF47DFKAO6PLIAC","3X6FN7RGF2MNQDBVXQHWOCVGWBMGAJXTXHH2B4N7JIRSZZSWU3UAC","PKTKSVTLHM5L6MOKXDQOJZ35FV2VXAD556S26QMICR6SNIY56LBQC","FYXZQ55GY3O5B4HHKUDU2UQZPTB7RXF4GXBF4ZZL5IIM4TVL7Y3QC"],"known":["N22GPKYTOLZLBGTGDATQDVZ4R5APZEAOIA7L32X4UXBH4XNI7MWAC","X27GNHDV5KPZ5GSH6DCAJMNCEMZLCP7M43JWF2X3O5QWXMOX273AC","TULPZ62YXEHXUWGBZMLCLYILEXPQS5ADPT22574BIRFU4CZMBSKAC","JK2QWPH6EOQXGCADV7C5HSYRVWC5M53LAKVN26EMTLY65IKU3AEQC","ERNOO5ZZ5OBBIGIXCLWZHCR73UDUDK7VV5GFWV4HNSWFD4AHCESQC","T4LLYESZ2HUXSLKZ6GNBLVWUVG7R5IDFHYHYO773QIZ6QTOOXR2AC","D6YQQQCNJT7RJ4KF5JN76NM5HT4FVROBGSNB26LYPRYVLEG576MAC","5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC","D5QIOJGPKQJIYBUCSC3MFJ3TXLPNZ2XMI37GXMFRVRFWWR2VMTFAC","NI5BVF2VLMDA7REXTV455SUCQAYMKPKNKQSRII2SJJGG2TCX4CTAC","SQQSV4NBN6QB6BZVC7FCUFMWEKSGSNATQ3IFOVXJNTGSSGP4YM3QC","TIOBBINAK6IEDTCFBP67QDP3U7BHPVJOHBD6FEHASSSIQGNLCUXAC","6MGFQDR2QXUVURENQQLXMYKKNB24PQZSQM6TGBXDV2AO2NYBLQDQC","Q6SOGMDQJAUDMVINADMRAFUMN4TDTUAX3ZEIL3DBEXNRLDN5UNUQC","FV2M6MOTAP4BJMEKU5XUDVEACWEJGEIRCCE2MRY3F6SF2SFOE3MQC","SBKX3YH2EOCYY2IDACGOTXHJZSYSRHD5EC7FB6WGPKHLFYOF6SAAC","RBZRCTALK2SLKX6HDMBS25BRNYPK3GK364MGAVCXP3MW5CEW5TKQC","KX5L74EYLS4YVSFG5H6U5H5TB6BQUFHHFUMLHTUUU6WFJLSRF5ZAC","L4AI5YL6CBMVS5GEPME3WIL2CHACMU7PGEKKNKLHHF5SP4ID3LCQC","ARD6Z67TDHK2XMW47CSVOXXF327YGOMYK3EAXTSVVXNDAFQYNO5AC","OB7GB5DLJ3NCVUELTTNPBNGIT757BIYQ452WKNOCNLY3SAI4HHAQC","AMFMXR52JXHUOWWG4VZ5DHQGLF4F7H7XSJRLX5XNEXOCCWYLDQOAC","RXVJFQ5AV3WME4HDVBPSRCALQTXROT4KQPOQVO6KTWTBNZIZZGPAC","GAZHOBWEXOSWFNJYOYXASH3LCOLREWB3DZXELIAP2Q6L2X2ZSI4QC","QMW24O5S43MYF5ZTBULUEZNDW2FKJ3QP2GL46P6B2SVGSQLVEACAC","Y6H7Y3OTXVLF6PJ5BR6WXS7KVS4VMTUKRYVM6FALKMY3DCBYEJSQC","3PNG7NIBQQURUUPRVQXYL342OT7JUUYOMY2JJNP6YDX7SYJDZMYAC","QIW2WZKWE3ULO4O4QB6EQWUKZY2UFNN7WA464FMIZOAHP3UHFGSAC","OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC","J74UTA3I7FHYJBO7FZMTQ3AQTZPD36DD7RFVGJHLHLOZ5YBPNONQC","PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC","6L3ZM55SJNE7HNUZ46SFEXV6MGDZNI26XJTEDTGTP5ZPACNF43AAC","MDAIP23T737NBX64IA4Z3HY2HVHLOQYPV6DYTDUXR6ERAXB7XYZQC","QLOLZHRXOUSNVLJG2SWVC5EISFUOUKJIT32XN6DNW4VFFJMN5PMAC","6K5PBUUN4GQAMOVX5BS6YYMHJ3PIF2PPZBTIEQ4R7BQNHC23GS3AC","LZVO64YG43JD7YMZSCTZNOBS5ROZA4FMPKJW2YOMHX2V5PTGBVWQC","UGA45FNCYAHX77QI3MTMSRF676N2BUW2ZUUI4OZCI2C3EJOYKY3QC","KYSBJAYN5KFQL7WV3TMQJD5BCKTQ3ZMKL6FREJ3NK2IPKCSCRDZAC","C3AG65SWAGDSML5MBD4ZPRCHI2LNNDN6IQZOI3HLYRJRPAW3QPAAC","YI3BZG5NWMKBT7T2HEOHVHSZBQ5KPDWSI3VRYOMQ346LRFB4MR2AC","4VYSDP4IAWIIVLXCKXJEYWIHZV3PUD3VACX3K4EIQKPFGWLZK6HQC","MQYHIUEEIMJHLABLHRJTJSHITJMHRHMF7NACHRD7QRBJCA3GQPRQC","NP7IOJ4QI25BLULQEYBACUR4KXWMYLNTM2K5VNPX2FAFGHZ37WYAC","M2CFFNJYY5BNXNIIYA72FKME3NUAETW4OWWWBSO4KMU7VP2YAXNAC","QAJK5MCERGUNMSKILOUAQKAYI5Y6HDNWTQUIN4M2KEENCSCJ35TQC","XHOZT4WTBN3Y7Q2MBANFS65X4HYL6SGPA7JNB7T7OD726SU2ACWAC","WQ2VQ7H3CTHM47EOW3F3BB2OUAI7ZXX5FBBAD2DODQOFO5LRM4WAC","53PW36WSP3WZOGHI4OSMX2I26O32WWZOZJH3B2W67JZMRKAOWTXAC","WJTP6VZILETQ4GWUNE7QPHQK3HWJJ6J5ILX2E7KYKUANAA4DBF4QC","3YHNO5H2IBHEAHVVYKTD4TYWR5AU2MUWYYMMCRSEIL5MDGRXMTIAC","J7WIAUWTYAUXLXVND7I45NOGHMDT4GGB5GPRJCXJJDGKQHWSVVGQC","UN2KZL3A6LWA72ZFRHSFUV23OZSVVP26BX7IGQDWJZGAHAXWJO3QC","RBQEBVT5RL4VVP6Y2V3IIKIX4E7USU5COI3W7Y2Y36VV3QFCTQQQC","5QYMALGUFECBH44BDVLFRZR5CQ24UTSEELVMAGDNKY2JAKBZKQ3AC","24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","ENXUSMSVOU3AZFMH2ZXR4ZVPV2LRRQYQJ6IFX33YN6IH2ORSNSAAC","YZAI5GQU3HNMK5MEGF2Y7WS445AN4YKD3HNJQVQP545ODN3F5DLAC","5AIYUMTBY6TFQTBRP3MJ2PYWUMRF57I77NIVWYE74UMEVQMBWZVQC","7LB6QBXYOGU43UDLJDJQZFGT4XDALULXDF3WX3WWHL7X3JTB54CQC","UXRNODRJJU7A33F4PG24WOHKTJFI3XQMZGT2MUOBRAH2MPQ7NZ2AC","IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC","MB3TISH2KYBIGY6XJKMN4HO2S6TCN2GORJENMECCKLXGGIRS2O2AC","DODOGD7MRCMRVGX23RPY2243WG54HCMCEZ6DCHOGID3GBQB66CXQC","7VQ4ALFYKJBFR46T3WZDMGOXNRR3QNJEJQVBYJM4HSJUOOUD6WBQC","UQYHPQ6UO7LIQ4P6NSCAEV677K52RQOQKCF4KSGNXMMFOQKY7IPQC","HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","N4IROACVZ4MU73J5SM6WXJMKQSFR3VN5SOKENNNZNEGMTGB2Q3HAC","MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","7VHPMFAGIYN4NCFBVPVCYDENEDB6KPNMHPWML7WJJUESK6ZQYMJQC","73YR46NJNYZQKHA3QDJCAZYAKC2CGEF5LIS44NOIPDZU6FX6BDPQC","GH4S4AWM2RUS3RUDU4E4TVQJF3N3LKM7OQQSZTG6H7NNMH6FKR7AC","N2NKSKHSFR6SDMGZO2ALNDVIOLOEE26BPQHCSWUGEFE3DVVVV4MAC","GTUZLZRHJ6GL5BNXOO3GA6Y3GFO7AXLIVPQHSG26LCF42KC2N7LQC","XLYHZUHTGM3HJBIINHPY4JLMENBFXPQEZYNEXENUOX3C47JLXJMAC","KS7NNPQWGV6HRWZLF23H673PPA3EPORWIT75SLRYDKOZIAOWMASQC","B2L4T3X63XVYJQXEDU4WT5Y4R6PMDXGC6WN2KGOMHRQILSABNQOAC","V6H6BWMKUGENVYLLCT56NWU7YYPADYI65Q4KSGPOJIZF2LWQRN2QC","DIEY5USNXFN6O2ARZ5IPBS2VX4OH7KE4RMX2JWAWTVMMSYA6GREAC","FS3HUMVUIZ2YWZVAO4VWJES23FUSFTQ5TMWWDCJ7KPZBRPXTN35AC","MS676RZWKHV4QNY2IILGKVA4DYOKFMSUCP2WTTJT374R3B3U2D6QC","34UH6B6LBITNUL6HXSPLL3657R73LC6C34QMJJLKTMLUGHFTLUSQC","3YSJ3LYKWE7ZXYGXLJI56CN6CGXXC4QO2ZDDA5VYGDSVXJ5QSIDQC"]},"hunks":[{"Replacement":{"inode":{"change":11,"pos":15951},"path":"configure.ac","line":14,"ins":{"up_context":[{"change":11,"pos":1}],"down_context":[{"change":11,"pos":16096}],"flag":"BLOCK","start":0,"end":24,"inode":{"change":11,"pos":15951}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1},"to":{"change":7,"start":0,"end":24},"introduced_by":7}],"inode":{"change":11,"pos":15951}},"ins_contents":[{"Add":{"text":"CXXFLAGS+=\" -std=c++17\"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:23"}}],"del_contents":[{"Del":{"text":"CXXFLAGS+=\" -std=c++11\"","pos":"4VYY2ADPFENPAC36FJCSEMEHOPL6E2T4RPXJKYVF47DFKAO6PLIAC:23"}}]}},{"Edit":{"inode":{"change":11,"pos":15951},"path":"configure.ac","line":73,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":16466}],"down_context":[{"change":11,"pos":38}],"flag":"BLOCK","start":25,"end":56,"inode":{"change":11,"pos":15951}}},"contents":[{"Add":{"text":" src/hydra-evaluator/Makefile","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:55"}}]}},{"Replacement":{"inode":{"change":11,"pos":1},"path":"release.nix","line":61,"ins":{"up_context":[{"change":11,"pos":565}],"down_context":[{"change":11,"pos":700}],"flag":"BLOCK","start":57,"end":192,"inode":{"change":11,"pos":1}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":565},"to":{"change":9,"start":0,"end":135},"introduced_by":9}],"inode":{"change":11,"pos":1}},"ins_contents":[{"Add":{"text":" rev = \"5e61b422c58baac26b232233d39f5814cc35d52a\";","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:116"}},{"Add":{"text":" sha256 = \"0awic5zwibgpj5shpgjf2364imp2f84c8xi5r0x4p351q4kpg9z4\";","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:191"}}],"del_contents":[{"Del":{"text":" rev = \"edf9eb8181e01f6b2123e5690019cfeeb44fc1c2\";","pos":"PKTKSVTLHM5L6MOKXDQOJZ35FV2VXAD556S26QMICR6SNIY56LBQC:59"}},{"Del":{"text":" sha256 = \"1a00q9pypfziyi9hxl4rsammhwj7991wm4b1z9zcgl7zqksr3582\";","pos":"PKTKSVTLHM5L6MOKXDQOJZ35FV2VXAD556S26QMICR6SNIY56LBQC:134"}}]}},{"Edit":{"inode":{"change":11,"pos":1},"path":"release.nix","line":127,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":926}],"down_context":[{"change":94,"pos":1760}],"flag":"BLOCK","start":193,"end":233,"inode":{"change":11,"pos":1}}},"contents":[{"Add":{"text":" stdenv = overrideCC stdenv gcc6;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:231"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:232"}}]}},{"Replacement":{"inode":{"change":11,"pos":21},"path":"src/Makefile.am","line":1,"ins":{"up_context":[{"change":11,"pos":21}],"down_context":[{"change":11,"pos":62}],"flag":"BLOCK","start":234,"end":323,"inode":{"change":11,"pos":21}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":21},"to":{"change":11,"start":112,"end":185},"introduced_by":11}],"inode":{"change":11,"pos":21}},"ins_contents":[{"Add":{"text":"SUBDIRS = hydra-evaluator hydra-eval-jobs hydra-queue-runner sql script lib root xsl ttf","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:322"}}],"del_contents":[{"Del":{"text":"SUBDIRS = hydra-eval-jobs hydra-queue-runner sql script lib root xsl ttf","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:184"}}]}},{"FileAdd":{"meta":{"basename":"hydra-evaluator","metadata":576},"context":[{"change":95,"pos":4}],"contents":[]}},{"FileAdd":{"meta":{"basename":"Makefile.am","metadata":0},"context":[{"change":0,"pos":325}],"contents":[{"Add":{"text":"bin_PROGRAMS = hydra-evaluator","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:385"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:386"}},{"Add":{"text":"hydra_evaluator_SOURCES = hydra-evaluator.cc","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:431"}},{"Add":{"text":"hydra_evaluator_LDADD = $(NIX_LIBS) -lpqxx","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:474"}},{"Add":{"text":"hydra_evaluator_CXXFLAGS = $(NIX_CFLAGS) -Wall -I ../libhydra","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:536"}}]}},{"FileAdd":{"meta":{"basename":"hydra-evaluator.cc","metadata":0},"context":[{"change":0,"pos":325}],"contents":[{"Add":{"text":"#include \"shared.hh\"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:596"}},{"Add":{"text":"#include \"db.hh\"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:613"}},{"Add":{"text":"#include \"pool.hh\"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:632"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:633"}},{"Add":{"text":"#include ","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:654"}},{"Add":{"text":"#include ","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:672"}},{"Add":{"text":"#include ","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:691"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:692"}},{"Add":{"text":"#include ","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:715"}},{"Add":{"text":"#include ","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:737"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:738"}},{"Add":{"text":"using namespace nix;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:759"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:760"}},{"Add":{"text":"struct Evaluator","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:777"}},{"Add":{"text":"{","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:779"}},{"Add":{"text":" nix::Pool dbPool;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:813"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:814"}},{"Add":{"text":" typedef std::pair JobsetName;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:874"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:875"}},{"Add":{"text":" struct Jobset","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:893"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:899"}},{"Add":{"text":" JobsetName name;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:924"}},{"Add":{"text":" time_t lastCheckedTime, triggerTime;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:969"}},{"Add":{"text":" int checkInterval;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:996"}},{"Add":{"text":" Pid pid;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1013"}},{"Add":{"text":" };","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1020"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1021"}},{"Add":{"text":" typedef std::map Jobsets;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1071"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1072"}},{"Add":{"text":" int evalTimeout = 3600;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1100"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1101"}},{"Add":{"text":" size_t maxEvals = 4;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1126"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1127"}},{"Add":{"text":" struct State","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1144"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1150"}},{"Add":{"text":" size_t runningEvals = 0;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1183"}},{"Add":{"text":" Jobsets jobsets;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1208"}},{"Add":{"text":" };","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1215"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1216"}},{"Add":{"text":" Sync state_;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1240"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1241"}},{"Add":{"text":" std::condition_variable childStarted;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1283"}},{"Add":{"text":" std::condition_variable maybeDoWork;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1324"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1325"}},{"Add":{"text":" const time_t notTriggered = std::numeric_limits::max();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1393"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1394"}},{"Add":{"text":" void readJobsets()","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1417"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1423"}},{"Add":{"text":" auto conn(dbPool.get());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1456"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1457"}},{"Add":{"text":" pqxx::work txn(*conn);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1488"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1489"}},{"Add":{"text":" auto res = txn.parameterized","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1526"}},{"Add":{"text":" (\"select project, j.name, lastCheckedTime, triggerTime, checkInterval from Jobsets j join Projects p on j.project = p.name \"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1663"}},{"Add":{"text":" \"where j.enabled != 0 and p.enabled != 0\").exec();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1727"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1728"}},{"Add":{"text":" auto state(state_.lock());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1763"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1764"}},{"Add":{"text":" std::set seen;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1799"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1800"}},{"Add":{"text":" for (auto const & row : res) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1839"}},{"Add":{"text":" auto name = JobsetName{row[\"project\"].as(), row[\"name\"].as()};","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1940"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:1941"}},{"Add":{"text":" auto res = state->jobsets.try_emplace(name, Jobset{name});","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2012"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2013"}},{"Add":{"text":" auto & jobset = res.first->second;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2060"}},{"Add":{"text":" jobset.lastCheckedTime = row[\"lastCheckedTime\"].as(0);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2135"}},{"Add":{"text":" jobset.triggerTime = row[\"triggerTime\"].as(notTriggered);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2213"}},{"Add":{"text":" jobset.checkInterval = row[\"checkInterval\"].as();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2283"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2284"}},{"Add":{"text":" seen.insert(name);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2315"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2325"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2326"}},{"Add":{"text":" for (auto i = state->jobsets.begin(); i != state->jobsets.end(); )","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2401"}},{"Add":{"text":" if (seen.count(i->first))","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2439"}},{"Add":{"text":" ++i;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2460"}},{"Add":{"text":" else {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2479"}},{"Add":{"text":" printInfo(\"forgetting jobset ‘%s:%s’\", i->first.first, i->first.second);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2572"}},{"Add":{"text":" i = state->jobsets.erase(i);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2617"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2631"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2637"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2638"}},{"Add":{"text":" void startEval(State & state, Jobset & jobset)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2689"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2695"}},{"Add":{"text":" printInfo(\"starting evaluation of jobset ‘%s:%s’\", jobset.name.first, jobset.name.second);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2798"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2799"}},{"Add":{"text":" assert(jobset.pid == -1);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2833"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2834"}},{"Add":{"text":" jobset.pid = startProcess([&]() {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:2876"}},{"Add":{"text":" Strings args = { \"timeout\", \"-s\", \"KILL\", std::to_string(evalTimeout), \"hydra-eval-jobset\", jobset.name.first, jobset.name.second };","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3021"}},{"Add":{"text":" execvp(args.front().c_str(), stringsToCharPtrs(args).data());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3095"}},{"Add":{"text":" throw SysError(format(\"executing ‘%1%’\") % args.front());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3169"}},{"Add":{"text":" });","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3181"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3182"}},{"Add":{"text":" state.runningEvals++;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3212"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3213"}},{"Add":{"text":" childStarted.notify_one();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3248"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3249"}},{"Add":{"text":" time_t now = time(0);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3279"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3280"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3290"}},{"Add":{"text":" auto conn(dbPool.get());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3327"}},{"Add":{"text":" pqxx::work txn(*conn);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3362"}},{"Add":{"text":" txn.parameterized","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3392"}},{"Add":{"text":" (\"update Jobsets set lastCheckedTime = $1, triggerTime = null where project = $2 and name = $3\")","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3505"}},{"Add":{"text":" (now)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3527"}},{"Add":{"text":" (jobset.name.first)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3563"}},{"Add":{"text":" (jobset.name.second)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3600"}},{"Add":{"text":" .exec();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3625"}},{"Add":{"text":" txn.commit();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3651"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3652"}},{"Add":{"text":" jobset.lastCheckedTime = now;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3694"}},{"Add":{"text":" jobset.triggerTime = notTriggered;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3741"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3751"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3757"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3758"}},{"Add":{"text":" void startEvals(State & state)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3793"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3799"}},{"Add":{"text":" std::vector sorted;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3846"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3847"}},{"Add":{"text":" time_t now = time(0);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3877"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3878"}},{"Add":{"text":" /* Filter out jobsets that have been evaluated recently and have","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3951"}},{"Add":{"text":" not been triggered. */","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:3985"}},{"Add":{"text":" for (auto i = state.jobsets.begin(); i != state.jobsets.end(); ++i)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4061"}},{"Add":{"text":" if (i->second.pid == -1 &&","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4100"}},{"Add":{"text":" (i->second.triggerTime != std::numeric_limits::max() ||","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4180"}},{"Add":{"text":" (i->second.checkInterval > 0 && i->second.lastCheckedTime + i->second.checkInterval <= now)))","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4294"}},{"Add":{"text":" sorted.push_back(i);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4331"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4332"}},{"Add":{"text":" /* Put jobsets in order of ascending trigger time, last checked","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4404"}},{"Add":{"text":" time, and name. */","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4434"}},{"Add":{"text":" std::sort(sorted.begin(), sorted.end(),","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4482"}},{"Add":{"text":" [](const Jobsets::iterator & a, const Jobsets::iterator & b) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4557"}},{"Add":{"text":" return","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4580"}},{"Add":{"text":" a->second.triggerTime != b->second.triggerTime","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4647"}},{"Add":{"text":" ? a->second.triggerTime < b->second.triggerTime","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4715"}},{"Add":{"text":" : a->second.lastCheckedTime != b->second.lastCheckedTime","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4792"}},{"Add":{"text":" ? a->second.lastCheckedTime < b->second.lastCheckedTime","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4870"}},{"Add":{"text":" : a->first < b->first;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4915"}},{"Add":{"text":" });","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4931"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4932"}},{"Add":{"text":" /* Start jobset evaluations up to the concurrency limit.*/","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:4999"}},{"Add":{"text":" for (auto & i : sorted) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5033"}},{"Add":{"text":" if (state.runningEvals >= maxEvals) break;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5088"}},{"Add":{"text":" startEval(state, i->second);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5129"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5139"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5145"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5146"}},{"Add":{"text":" void loop()","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5162"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5168"}},{"Add":{"text":" auto state(state_.lock());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5203"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5204"}},{"Add":{"text":" while (true) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5227"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5228"}},{"Add":{"text":" time_t now = time(0);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5262"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5263"}},{"Add":{"text":" std::chrono::seconds sleepTime = std::chrono::seconds::max();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5337"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5338"}},{"Add":{"text":" if (state->runningEvals < maxEvals) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5388"}},{"Add":{"text":" for (auto & i : state->jobsets)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5436"}},{"Add":{"text":" if (i.second.pid == -1 &&","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5482"}},{"Add":{"text":" i.second.checkInterval > 0)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5534"}},{"Add":{"text":" sleepTime = std::min(sleepTime, std::chrono::seconds(","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5612"}},{"Add":{"text":" std::max((time_t) 1, i.second.lastCheckedTime - now + i.second.checkInterval)));","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5725"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5739"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5740"}},{"Add":{"text":" debug(\"waiting for %d s\", sleepTime.count());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5798"}},{"Add":{"text":" if (sleepTime == std::chrono::seconds::max())","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5856"}},{"Add":{"text":" state.wait(maybeDoWork);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5897"}},{"Add":{"text":" else","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5914"}},{"Add":{"text":" state.wait_for(maybeDoWork, sleepTime);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5970"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:5971"}},{"Add":{"text":" startEvals(*state);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6003"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6013"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6019"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6020"}},{"Add":{"text":" /* A thread that listens to PostgreSQL notifications about jobset","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6090"}},{"Add":{"text":" changes, updates the jobsets map, and signals the main thread","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6159"}},{"Add":{"text":" to start evaluations. */","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6191"}},{"Add":{"text":" void databaseMonitor()","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6218"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6224"}},{"Add":{"text":" while (true) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6247"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6248"}},{"Add":{"text":" try {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6266"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6267"}},{"Add":{"text":" auto conn(dbPool.get());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6308"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6309"}},{"Add":{"text":" receiver jobsetsAdded(*conn, \"jobsets_added\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6372"}},{"Add":{"text":" receiver jobsetsDeleted(*conn, \"jobsets_deleted\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6439"}},{"Add":{"text":" receiver jobsetsChanged(*conn, \"jobset_scheduling_changed\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6516"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6517"}},{"Add":{"text":" while (true) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6548"}},{"Add":{"text":" /* Note: we read/notify before","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6599"}},{"Add":{"text":" await_notification() to ensure we don't miss a","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6669"}},{"Add":{"text":" state change. */","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6709"}},{"Add":{"text":" readJobsets();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6744"}},{"Add":{"text":" maybeDoWork.notify_one();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6790"}},{"Add":{"text":" conn->await_notification();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6838"}},{"Add":{"text":" printInfo(\"received jobset event\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6894"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6912"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6913"}},{"Add":{"text":" } catch (std::exception & e) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:6956"}},{"Add":{"text":" printError(\"exception in database monitor thread: %s\", e.what());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7038"}},{"Add":{"text":" sleep(30);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7065"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7079"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7089"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7095"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7096"}},{"Add":{"text":" /* A thread that reaps child processes.*/","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7142"}},{"Add":{"text":" void reaper()","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7160"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7166"}},{"Add":{"text":" while (true) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7189"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7203"}},{"Add":{"text":" auto state(state_.lock());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7246"}},{"Add":{"text":" while (!state->runningEvals)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7291"}},{"Add":{"text":" state.wait(childStarted);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7337"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7351"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7352"}},{"Add":{"text":" int status;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7376"}},{"Add":{"text":" pid_t pid = waitpid(-1, &status, 0);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7425"}},{"Add":{"text":" if (pid == -1) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7454"}},{"Add":{"text":" if (errno == EINTR) continue;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7500"}},{"Add":{"text":" throw SysError(\"waiting for children\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7556"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7570"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7571"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7585"}},{"Add":{"text":" auto state(state_.lock());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7628"}},{"Add":{"text":" assert(state->runningEvals);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7673"}},{"Add":{"text":" state->runningEvals--;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7712"}},{"Add":{"text":" for (auto & jobset : state->jobsets)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7765"}},{"Add":{"text":" if (jobset.second.pid == pid) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7817"}},{"Add":{"text":" printInfo(\"evaluation of jobset ‘%s:%s’ finished with status %d\",","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7911"}},{"Add":{"text":" jobset.first.first, jobset.first.second, status);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:7989"}},{"Add":{"text":" jobset.second.pid.release();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8042"}},{"Add":{"text":" maybeDoWork.notify_one();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8092"}},{"Add":{"text":" break;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8123"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8145"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8159"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8169"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8175"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8176"}},{"Add":{"text":" void run()","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8191"}},{"Add":{"text":" {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8197"}},{"Add":{"text":" std::thread reaperThread([&]() { reaper(); });","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8252"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8253"}},{"Add":{"text":" std::thread monitorThread([&]() { databaseMonitor(); });","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8318"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8319"}},{"Add":{"text":" while (true) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8342"}},{"Add":{"text":" try {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8360"}},{"Add":{"text":" loop();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8384"}},{"Add":{"text":" } catch (std::exception & e) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8427"}},{"Add":{"text":" printError(\"exception in main loop: %s\", e.what());","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8495"}},{"Add":{"text":" sleep(30);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8522"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8536"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8546"}},{"Add":{"text":" }","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8552"}},{"Add":{"text":"};","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8555"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8556"}},{"Add":{"text":"int main(int argc, char * * argv)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8590"}},{"Add":{"text":"{","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8592"}},{"Add":{"text":" return handleExceptions(argv[0], [&]() {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8637"}},{"Add":{"text":" initNix();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8656"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8657"}},{"Add":{"text":" signal(SIGINT, SIG_DFL);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8690"}},{"Add":{"text":" signal(SIGTERM, SIG_DFL);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8724"}},{"Add":{"text":" signal(SIGHUP, SIG_DFL);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8757"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8758"}},{"Add":{"text":" parseCmdLine(argc, argv, [&](Strings::iterator & arg, const Strings::iterator & end) {","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8853"}},{"Add":{"text":" return false;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8879"}},{"Add":{"text":" });","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8891"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8892"}},{"Add":{"text":" Evaluator().run();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8919"}},{"Add":{"text":" });","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8927"}},{"Add":{"text":"}","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:8929"}}]}},{"Replacement":{"inode":{"change":11,"pos":219},"path":"src/hydra-queue-runner/Makefile.am","line":7,"ins":{"up_context":[{"change":11,"pos":368}],"down_context":[],"flag":"BLOCK","start":8974,"end":9039,"inode":{"change":11,"pos":219}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":368},"to":{"change":11,"start":368,"end":369},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":369},"to":{"change":10,"start":0,"end":34},"introduced_by":10}],"inode":{"change":11,"pos":219}},"ins_contents":[{"Add":{"text":"hydra_queue_runner_CXXFLAGS = $(NIX_CFLAGS) -Wall -I ../libhydra","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9038"}}],"del_contents":[{"Del":{"text":"","pos":"24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC:368"}},{"Del":{"text":"AM_CXXFLAGS = $(NIX_CFLAGS) -Wall","pos":"FYXZQ55GY3O5B4HHKUDU2UQZPTB7RXF4GXBF4ZZL5IIM4TVL7Y3QC:33"}}]}},{"FileAdd":{"meta":{"basename":"libhydra","metadata":576},"context":[{"change":95,"pos":4}],"contents":[]}},{"FileMove":{"meta":{"basename":"db.hh","metadata":0},"old":[{"basename":"db.hh","metadata":0}],"up":[{"change":0,"pos":9041}],"down":[{"change":11,"pos":93}],"show_perms":false}},{"Replacement":{"inode":{"change":11,"pos":2198648},"path":"src/script/Makefile.am","line":7,"ins":{"up_context":[{"change":11,"pos":422}],"down_context":[{"change":11,"pos":491}],"flag":"BLOCK","start":9091,"end":9116,"inode":{"change":11,"pos":2198648}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":442},"to":{"change":11,"start":442,"end":465},"introduced_by":11}],"inode":{"change":11,"pos":2198648}},"ins_contents":[{"Add":{"text":" hydra-eval-jobset\t\t\t\t\\","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9115"}}],"del_contents":[{"Del":{"text":" hydra-evaluator\t\t\t\t\\","pos":"Y6H7Y3OTXVLF6PJ5BR6WXS7KVS4VMTUKRYVM6FALKMY3DCBYEJSQC:464"}}]}},{"FileMove":{"meta":{"basename":"hydra-eval-jobset","metadata":64},"old":[{"basename":"hydra-evaluator","metadata":64}],"up":[{"change":11,"pos":2543}],"down":[{"change":11,"pos":1319}],"show_perms":false}},{"Replacement":{"inode":{"change":11,"pos":1319},"path":"src/script/hydra-eval-jobset","line":348,"ins":{"up_context":[{"change":11,"pos":9901}],"down_context":[{"change":11,"pos":2931}],"flag":"BLOCK","start":9158,"end":9215,"inode":{"change":11,"pos":1319}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":477},"to":{"change":11,"start":477,"end":499},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":499},"to":{"change":11,"start":2600,"end":2660},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":2660},"to":{"change":11,"start":499,"end":553},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":499},"to":{"change":11,"start":499,"end":553},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":553},"to":{"change":4,"start":0,"end":46},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":46},"to":{"change":11,"start":2857,"end":2931},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2857},"to":{"change":11,"start":2857,"end":2931},"introduced_by":11}],"inode":{"change":11,"pos":1319}},"ins_contents":[{"Add":{"text":"die \"syntax: $0 \\n\" unless @ARGV == 2;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9214"}}],"del_contents":[{"Del":{"text":"sub checkSomeJobset {","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:498"}},{"Del":{"text":" # If any jobset has been triggered by a push, check it.","pos":"PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC:2659"}},{"Del":{"text":" my ($jobset) = $db->resultset('Jobsets')->search(","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:552"}},{"Del":{"text":" { 'triggertime' => { '!=', undef } },","pos":"N66HHKLQGRAVLPEO2LTAOGGXKZUYKYQSSOG4MQAMQVUIXVHIYP3QC:45"}},{"Del":{"text":" { join => 'project', order_by => [ 'triggertime' ], rows => 1 });","pos":"PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC:2930"}}]}},{"Replacement":{"inode":{"change":11,"pos":1319},"path":"src/script/hydra-eval-jobset","line":350,"ins":{"up_context":[{"change":11,"pos":2932}],"down_context":[],"flag":"BLOCK","start":9216,"end":9451,"inode":{"change":11,"pos":1319}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2932},"to":{"change":11,"start":2932,"end":2999},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":2999},"to":{"change":11,"start":1015,"end":1111},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1111},"to":{"change":11,"start":3086,"end":3137},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3086},"to":{"change":11,"start":3086,"end":3137},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3137},"to":{"change":11,"start":1609,"end":1674},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1674},"to":{"change":11,"start":1112,"end":1270},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":3190},"to":{"change":11,"start":1112,"end":1270},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1270},"to":{"change":11,"start":3191,"end":3312},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":308},"to":{"change":11,"start":3191,"end":3312},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":398},"to":{"change":11,"start":744,"end":783},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":3312},"to":{"change":11,"start":744,"end":783},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":744},"to":{"change":11,"start":744,"end":783},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":783},"to":{"change":3,"start":0,"end":67},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":67},"to":{"change":11,"start":0,"end":4},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":11,"pos":824},"to":{"change":11,"start":0,"end":4},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":10180},"to":{"change":11,"start":0,"end":4},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":56},"to":{"change":11,"start":56,"end":144},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":144},"to":{"change":8,"start":0,"end":160},"introduced_by":8},{"previous":"","flag":"DELETED","from":{"change":11,"pos":124},"to":{"change":11,"start":64,"end":95},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":8,"pos":160},"to":{"change":11,"start":64,"end":95},"introduced_by":8},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":228},"to":{"change":11,"start":64,"end":95},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":95},"to":{"change":11,"start":10180,"end":10184},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":284},"to":{"change":11,"start":10180,"end":10184},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":10180},"to":{"change":11,"start":10180,"end":10184},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":10184},"to":{"change":11,"start":968,"end":980},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":980},"to":{"change":11,"start":0,"end":11},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":11},"to":{"change":11,"start":852,"end":1029},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1029},"to":{"change":2,"start":0,"end":44},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":44},"to":{"change":11,"start":1071,"end":1103},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1071},"to":{"change":11,"start":1071,"end":1103},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1103},"to":{"change":11,"start":30,"end":37},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":1461},"to":{"change":11,"start":30,"end":37},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":30},"to":{"change":11,"start":30,"end":37},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":37},"to":{"change":11,"start":3067,"end":3102},"introduced_by":11},{"previous":"","flag":"DELETED","from":{"change":11,"pos":869},"to":{"change":11,"start":1036,"end":1038},"introduced_by":11},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1036},"to":{"change":11,"start":1036,"end":1038},"introduced_by":11}],"inode":{"change":11,"pos":1319}},"ins_contents":[{"Add":{"text":"my $projectName = $ARGV[0];","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9243"}},{"Add":{"text":"my $jobsetName = $ARGV[1];","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9270"}},{"Add":{"text":"my $jobset = $db->resultset('Jobsets')->find($projectName, $jobsetName) or","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9345"}},{"Add":{"text":" die \"$0: specified jobset \\\"$projectName:$jobsetName\\\" does not exist\\n\";","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9423"}},{"Add":{"text":"exit checkJobset($jobset);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9450"}}],"del_contents":[{"Del":{"text":" # Otherwise, check the jobset that hasn't been checked for the","pos":"PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC:2998"}},{"Del":{"text":" # longest time (but don't check more often than the jobset's","pos":"QLOLZHRXOUSNVLJG2SWVC5EISFUOUKJIT32XN6DNW4VFFJMN5PMAC:1079"}},{"Del":{"text":" # minimal check interval).","pos":"QLOLZHRXOUSNVLJG2SWVC5EISFUOUKJIT32XN6DNW4VFFJMN5PMAC:1110"}},{"Del":{"text":" ($jobset) = $db->resultset('Jobsets')->search(","pos":"PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC:3136"}},{"Del":{"text":" { 'project.enabled' => 1, 'me.enabled' => { '!=' => 0 },","pos":"C3AG65SWAGDSML5MBD4ZPRCHI2LNNDN6IQZOI3HLYRJRPAW3QPAAC:1673"}},{"Del":{"text":" , 'checkinterval' => { '!=', 0 }","pos":"QLOLZHRXOUSNVLJG2SWVC5EISFUOUKJIT32XN6DNW4VFFJMN5PMAC:1152"}},{"Del":{"text":" , -or => [ 'lastcheckedtime' => undef, 'lastcheckedtime' => { '<', \\ (time() . \" - me.checkinterval\") } ] },","pos":"QLOLZHRXOUSNVLJG2SWVC5EISFUOUKJIT32XN6DNW4VFFJMN5PMAC:1269"}},{"Del":{"text":" { join => 'project', order_by => [ 'lastcheckedtime nulls first' ], rows => 1 })","pos":"PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC:3279"}},{"Del":{"text":" unless defined $jobset;","pos":"PCKLFRT5IZVLG47GQQ23GBSROKUR4CUEZW4PRVGREHNDFTCZ7VBAC:3311"}},{"Del":{"text":"","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:744"}},{"Del":{"text":" return 0 unless defined $jobset;","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:781"}},{"Del":{"text":"","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:782"}},{"Del":{"text":" return system($0, $jobset->project->name, $jobset->name) == 0;","pos":"3CVY4QJXRFFA6V4JVBPMSPRKL2KGBCCE3HSOFWVUK76GIGO3NDPAC:66"}},{"Del":{"text":"}","pos":"5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC:1"}},{"Del":{"text":"","pos":"5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC:2"}},{"Del":{"text":"","pos":"5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC:3"}},{"Del":{"text":"if (scalar @ARGV == 2) {","pos":"5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC:80"}},{"Del":{"text":" my $projectName = $ARGV[0];","pos":"5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC:112"}},{"Del":{"text":" my $jobsetName = $ARGV[1];","pos":"5GRJZZORI57MXOZPWMCEZQNBYDXJUAC4QVEO5APLECV5UFXAJHYAC:143"}},{"Del":{"text":" my $jobset = $db->resultset('Jobsets')->find($projectName, $jobsetName) or ","pos":"3X6FN7RGF2MNQDBVXQHWOCVGWBMGAJXTXHH2B4N7JIRSZZSWU3UAC:79"}},{"Del":{"text":" die \"$0: specified jobset \\\"$projectName:$jobsetName\\\" does not exist\\n\";","pos":"3X6FN7RGF2MNQDBVXQHWOCVGWBMGAJXTXHH2B4N7JIRSZZSWU3UAC:159"}},{"Del":{"text":" exit checkJobset($jobset);","pos":"53PW36WSP3WZOGHI4OSMX2I26O32WWZOZJH3B2W67JZMRKAOWTXAC:94"}},{"Del":{"text":"}","pos":"X27GNHDV5KPZ5GSH6DCAJMNCEMZLCP7M43JWF2X3O5QWXMOX273AC:10181"}},{"Del":{"text":"","pos":"X27GNHDV5KPZ5GSH6DCAJMNCEMZLCP7M43JWF2X3O5QWXMOX273AC:10182"}},{"Del":{"text":"","pos":"X27GNHDV5KPZ5GSH6DCAJMNCEMZLCP7M43JWF2X3O5QWXMOX273AC:10183"}},{"Del":{"text":"while (1) {","pos":"TULPZ62YXEHXUWGBZMLCLYILEXPQS5ADPT22574BIRFU4CZMBSKAC:979"}},{"Del":{"text":" eval {","pos":"SQQSV4NBN6QB6BZVC7FCUFMWEKSGSNATQ3IFOVXJNTGSSGP4YM3QC:10"}},{"Del":{"text":" if (checkSomeJobset) {","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:882"}},{"Del":{"text":" # Just so we don't go completely crazy if lastcheckedtime","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:952"}},{"Del":{"text":" # isn't updated properly.","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:990"}},{"Del":{"text":" sleep 1;","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:1011"}},{"Del":{"text":" } else {","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:1028"}},{"Del":{"text":" # print STDERR \"sleeping...\\n\";","pos":"Z4Y3TVEEN6LIGBRCMWVFZYFFE6NKHUSO76RZ3GSPTZEME3CBLUTAC:43"}},{"Del":{"text":" sleep 30;","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:1092"}},{"Del":{"text":" }","pos":"OVR2RWBIUXNW2XSG63KFL2S3Q7UVTLHOEYO3573LZBY7AMLUKKTQC:1102"}},{"Del":{"text":" };","pos":"SQQSV4NBN6QB6BZVC7FCUFMWEKSGSNATQ3IFOVXJNTGSSGP4YM3QC:36"}},{"Del":{"text":" if ($@) { print STDERR \"$@\"; }","pos":"RXVJFQ5AV3WME4HDVBPSRCALQTXROT4KQPOQVO6KTWTBNZIZZGPAC:3101"}},{"Del":{"text":"}","pos":"TULPZ62YXEHXUWGBZMLCLYILEXPQS5ADPT22574BIRFU4CZMBSKAC:1037"}}]}},{"Edit":{"inode":{"change":11,"pos":1},"path":"src/sql/hydra.sql","line":85,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":1688}],"down_context":[{"change":5,"pos":1688}],"flag":"BLOCK","start":9452,"end":9667,"inode":{"change":11,"pos":1}}},"contents":[{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9452"}},{"Add":{"text":"create function notifyJobsetsAdded() returns trigger as 'begin notify jobsets_added; return null; end;' language plpgsql;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9574"}},{"Add":{"text":"create trigger JobsetsAdded after insert on Jobsets execute procedure notifyJobsetsAdded();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9666"}}]}},{"Edit":{"inode":{"change":11,"pos":1},"path":"src/sql/hydra.sql","line":89,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":1689}],"down_context":[{"change":5,"pos":1689}],"flag":"BLOCK","start":9668,"end":10350,"inode":{"change":11,"pos":1}}},"contents":[{"Add":{"text":"create function notifyJobsetsDeleted() returns trigger as 'begin notify jobsets_deleted; return null; end;' language plpgsql;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9793"}},{"Add":{"text":"create trigger JobsetsDeleted after delete on Jobsets execute procedure notifyJobsetsDeleted();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9889"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:9890"}},{"Add":{"text":"create function notifyJobsetSchedulingChanged() returns trigger as 'begin notify jobset_scheduling_changed; return null; end;' language plpgsql;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10035"}},{"Add":{"text":"create trigger JobsetSchedulingChanged after update on Jobsets for each row","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10111"}},{"Add":{"text":" when (((old.triggerTime is distinct from new.triggerTime) and (new.triggerTime is not null))","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10206"}},{"Add":{"text":" or old.checkInterval != new.checkInterval","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10256"}},{"Add":{"text":" or old.enabled != new.enabled)","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10295"}},{"Add":{"text":" execute procedure notifyJobsetSchedulingChanged();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10348"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10349"}}]}},{"FileAdd":{"meta":{"basename":"upgrade-50.sql","metadata":0},"context":[{"change":11,"pos":3004}],"contents":[{"Add":{"text":"create function notifyJobsetsAdded() returns trigger as 'begin notify jobsets_added; return null; end;' language plpgsql;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10474"}},{"Add":{"text":"create trigger JobsetsAdded after insert on Jobsets execute procedure notifyJobsetsAdded();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10566"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10567"}},{"Add":{"text":"create function notifyJobsetsDeleted() returns trigger as 'begin notify jobsets_deleted; return null; end;' language plpgsql;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10693"}},{"Add":{"text":"create trigger JobsetsDeleted after delete on Jobsets execute procedure notifyJobsetsDeleted();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10789"}},{"Add":{"text":"","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10790"}},{"Add":{"text":"create function notifyJobsetSchedulingChanged() returns trigger as 'begin notify jobset_scheduling_changed; return null; end;' language plpgsql;","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:10935"}},{"Add":{"text":"create trigger JobsetSchedulingChanged after update on Jobsets for each row","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11011"}},{"Add":{"text":" when ((old.triggerTime is distinct from new.triggerTime) and (new.triggerTime is not null))","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11105"}},{"Add":{"text":" or old.checkInterval != new.checkInterval","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11155"}},{"Add":{"text":" or old.enabled != new.enabled","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11193"}},{"Add":{"text":" execute procedure notifyJobsetSchedulingChanged();","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11246"}}]}},{"Replacement":{"inode":{"change":96,"pos":92},"path":"tests/Makefile.am","line":16,"ins":{"up_context":[{"change":11,"pos":58}],"down_context":[{"change":11,"pos":37753}],"flag":"BLOCK","start":11287,"end":11449,"inode":{"change":96,"pos":92}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":58},"to":{"change":11,"start":106,"end":230},"introduced_by":11}],"inode":{"change":96,"pos":92}},"ins_contents":[{"Add":{"text":" PATH=$(abs_top_srcdir)/src/hydra-evaluator:$(abs_top_srcdir)/src/script:$(abs_top_srcdir)/src/hydra-eval-jobs:$(abs_top_srcdir)/src/hydra-queue-runner:$$PATH \\","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11448"}}],"del_contents":[{"Del":{"text":" PATH=$(abs_top_srcdir)/src/script:$(abs_top_srcdir)/src/hydra-eval-jobs:$(abs_top_srcdir)/src/hydra-queue-runner:$$PATH \\","pos":"UQYHPQ6UO7LIQ4P6NSCAEV677K52RQOQKCF4KSGNXMMFOQKY7IPQC:229"}}]}},{"Replacement":{"inode":{"change":97,"pos":518},"path":"tests/Setup.pm","line":64,"ins":{"up_context":[{"change":11,"pos":1336}],"down_context":[{"change":11,"pos":1469}],"flag":"BLOCK","start":11450,"end":11571,"inode":{"change":97,"pos":518}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":1336},"to":{"change":11,"start":9344,"end":9463},"introduced_by":11}],"inode":{"change":97,"pos":518}},"ins_contents":[{"Add":{"text":" my ($res, $stdout, $stderr) = captureStdoutStderr(60, (\"hydra-eval-jobset\", $jobset->project->name, $jobset->name));","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11570"}}],"del_contents":[{"Del":{"text":" my ($res, $stdout, $stderr) = captureStdoutStderr(60, (\"hydra-evaluator\", $jobset->project->name, $jobset->name));","pos":"UGA45FNCYAHX77QI3MTMSRF676N2BUW2ZUUI4OZCI2C3EJOYKY3QC:9462"}}]}},{"Replacement":{"inode":{"change":11,"pos":36450},"path":"tests/api-test.pl","line":52,"ins":{"up_context":[{"change":11,"pos":245}],"down_context":[{"change":11,"pos":38737}],"flag":"BLOCK","start":11572,"end":11616,"inode":{"change":11,"pos":36450}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":245},"to":{"change":6,"start":175,"end":217},"introduced_by":6}],"inode":{"change":11,"pos":36450}},"ins_contents":[{"Add":{"text":"system(\"hydra-eval-jobset sample default\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11615"}}],"del_contents":[{"Del":{"text":"system(\"hydra-evaluator sample default\");","pos":"Q3VTDUSQ75JD5L55VWQV6MGAS6IC4AWGSADL2ISMX5E7R3LBVBHAC:216"}}]}},{"Replacement":{"inode":{"change":11,"pos":36450},"path":"tests/api-test.pl","line":59,"ins":{"up_context":[{"change":11,"pos":39017}],"down_context":[{"change":11,"pos":39299}],"flag":"BLOCK","start":11617,"end":11694,"inode":{"change":11,"pos":36450}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":39017},"to":{"change":6,"start":218,"end":293},"introduced_by":6}],"inode":{"change":11,"pos":36450}},"ins_contents":[{"Add":{"text":"system(\"echo >> /run/jobset/default.nix; hydra-eval-jobset sample default\");","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11693"}}],"del_contents":[{"Del":{"text":"system(\"echo >> /run/jobset/default.nix; hydra-evaluator sample default\");","pos":"Q3VTDUSQ75JD5L55VWQV6MGAS6IC4AWGSADL2ISMX5E7R3LBVBHAC:292"}}]}},{"Replacement":{"inode":{"change":11,"pos":9772},"path":"tests/s3-backup-test.pl","line":22,"ins":{"up_context":[{"change":11,"pos":10569}],"down_context":[{"change":11,"pos":10644}],"flag":"BLOCK","start":11695,"end":11772,"inode":{"change":11,"pos":9772}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":10569},"to":{"change":11,"start":10569,"end":10644},"introduced_by":11}],"inode":{"change":11,"pos":9772}},"ins_contents":[{"Add":{"text":"system(\"hydra-eval-jobset \" . $jobset->project->name . \" \" . $jobset->name);","pos":"4YCF3KBGI4VYKHJXAREJLCJLY3UWB2FX447CJ4XQWFRKRFKG5WCQC:11771"}}],"del_contents":[{"Del":{"text":"system(\"hydra-evaluator \" . $jobset->project->name . \" \" . $jobset->name);","pos":"UGA45FNCYAHX77QI3MTMSRF676N2BUW2ZUUI4OZCI2C3EJOYKY3QC:10643"}}]}}],"owner":"grahamc","repo":"hydra2","token":"sY6n45CMjpVOlL3xYwYgUDhh+GN2B/N1ixp2x9rvOiw=","login":null}

…

Dependencies

Change contents

Review