{"header":{"message":"Revive jobset scheduling","description":"(I.e. taking the jobset scheduling share into account.)","timestamp":"2015-08-10T23:30:24Z","authors":[{"email":"eelco.dolstra@logicblox.com","name":"Eelco Dolstra"}]},"hash":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC","authors":[],"deps":{"hashes":[["IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC","Revive jobset scheduling"],["AA",null],["WE5Q2NVIIK4R2DUUZYLJFQVYK5O26EDEJRPK3CPGWHU3SEAC2DQAC","Allow build to be bumped to the front of the queue via the web interface"],["46ADBTMQAHQAPW3OCI24F4I5DVK5N5QVHUA4TQVB6HFN337CHAVQC","Start steps in order of ascending build ID"],["MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","Split hydra-queue-runner.cc more"],["T5BIOVJEMBIASP7EKQVV2N3VD6I56UXH6LCD5I33BDQEVHJAMGKQC","Add support for tracking custom metrics"],["4I2HF4L3JOC6KPYLI2YTEVTHBRRYO5XKXOZ6VQ2SJKSQKAPNQXCQC","Unindent"],["24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC","Start of single-process hydra-queue-runner"],["PLOZBRTR6USSGJX7GR2RZKNPVYG2Q6QM7LW6IA35MKL63ZTQVD7QC","Add command ‘hydra-queue-runner --status’ to show current status"],["RQUAATWBGEP3YT4F555XLJYRRRGHDTEILHFORES7AM2XAOVMVJSAC","Add status dump facility"],["HJOEIMLRDVQ2KZI5HGL2HKGBM3AHP7YIKGKDAGFUNKRUXVRB24NAC","Refactor"],["NAYQT2GTCJPBFRSK7CBFX655F2NGTBPICJSCYG2CSCQ5NRDHZG6QC","hydra-queue-runner: Use cmdBuildDerivation"]],"deps":["WE5Q2NVIIK4R2DUUZYLJFQVYK5O26EDEJRPK3CPGWHU3SEAC2DQAC"],"known":["MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC","T5BIOVJEMBIASP7EKQVV2N3VD6I56UXH6LCD5I33BDQEVHJAMGKQC","46ADBTMQAHQAPW3OCI24F4I5DVK5N5QVHUA4TQVB6HFN337CHAVQC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":133},"path":"src/hydra-queue-runner/builder.cc","line":133,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4778}],"down_context":[{"change":3,"pos":4778}],"flag":"BLOCK","start":0,"end":390,"inode":{"change":3,"pos":133}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:0"}},{"Add":{"text":" /* Account the time we spent building this step by dividing it","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:67"}},{"Add":{"text":" among the jobsets that depend on it. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:114"}},{"Add":{"text":" {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:120"}},{"Add":{"text":" auto step_(step->state.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:160"}},{"Add":{"text":" // FIXME: loss of precision.","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:197"}},{"Add":{"text":" time_t charge = (result.stopTime - result.startTime) / step_->jobsets.size();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:283"}},{"Add":{"text":" for (auto & jobset : step_->jobsets)","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:328"}},{"Add":{"text":" jobset->addStep(result.startTime, charge);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:383"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:389"}}]}},{"Edit":{"inode":{"change":3,"pos":14628},"path":"src/hydra-queue-runner/dispatcher.cc","line":1,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":14628},"to":{"change":3,"start":0,"end":20},"introduced_by":3}],"inode":{"change":3,"pos":14628}}},"contents":[{"Del":{"text":"#include ","pos":"46ADBTMQAHQAPW3OCI24F4I5DVK5N5QVHUA4TQVB6HFN337CHAVQC:19"}}]}},{"Edit":{"inode":{"change":3,"pos":14628},"path":"src/hydra-queue-runner/dispatcher.cc","line":56,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":627}],"down_context":[{"change":3,"pos":21}],"flag":"BLOCK","start":391,"end":905,"inode":{"change":3,"pos":14628}}},"contents":[{"Add":{"text":" /* Prune old historical build step info from the jobsets. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:455"}},{"Add":{"text":" {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:461"}},{"Add":{"text":" auto jobsets_(jobsets.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:500"}},{"Add":{"text":" for (auto & jobset : *jobsets_) {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:542"}},{"Add":{"text":" auto s1 = jobset.second->shareUsed();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:592"}},{"Add":{"text":" jobset.second->pruneSteps();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:633"}},{"Add":{"text":" auto s2 = jobset.second->shareUsed();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:683"}},{"Add":{"text":" if (s1 != s2)","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:709"}},{"Add":{"text":" printMsg(lvlDebug, format(\"pruned scheduling window of ‘%1%:%2%’ from %3% to %4%\")","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:812"}},{"Add":{"text":" % jobset.first.first % jobset.first.second % s1 % s2);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:887"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:897"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:903"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:904"}}]}},{"Edit":{"inode":{"change":3,"pos":14628},"path":"src/hydra-queue-runner/dispatcher.cc","line":154,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":515}],"down_context":[{"change":3,"pos":515}],"flag":"BLOCK","start":906,"end":1193,"inode":{"change":3,"pos":14628}}},"contents":[{"Add":{"text":" for (auto & step : runnableSorted) {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:950"}},{"Add":{"text":" auto step_(step->state.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:994"}},{"Add":{"text":" step_->lowestShareUsed = 1e9;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1036"}},{"Add":{"text":" for (auto & jobset : step_->jobsets)","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1085"}},{"Add":{"text":" step_->lowestShareUsed = std::min(step_->lowestShareUsed, jobset->shareUsed());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1181"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1191"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1192"}}]}},{"Edit":{"inode":{"change":3,"pos":14628},"path":"src/hydra-queue-runner/dispatcher.cc","line":168,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":156}],"down_context":[{"change":2,"pos":156}],"flag":"BLOCK","start":1194,"end":1303,"inode":{"change":3,"pos":14628}}},"contents":[{"Add":{"text":" a_->lowestShareUsed != b_->lowestShareUsed ? a_->lowestShareUsed < b_->lowestShareUsed :","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1302"}}]}},{"Edit":{"inode":{"change":3,"pos":14628},"path":"src/hydra-queue-runner/dispatcher.cc","line":227,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":19999}],"down_context":[],"flag":"BLOCK","start":1304,"end":1729,"inode":{"change":3,"pos":14628}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1304"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1305"}},{"Add":{"text":"void Jobset::addStep(time_t startTime, time_t duration)","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1361"}},{"Add":{"text":"{","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1363"}},{"Add":{"text":" auto steps_(steps.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1394"}},{"Add":{"text":" (*steps_)[startTime] = duration;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1431"}},{"Add":{"text":" seconds += duration;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1456"}},{"Add":{"text":"}","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1458"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1459"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1460"}},{"Add":{"text":"void Jobset::pruneSteps()","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1486"}},{"Add":{"text":"{","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1488"}},{"Add":{"text":" time_t now = time(0);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1514"}},{"Add":{"text":" auto steps_(steps.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1545"}},{"Add":{"text":" while (!steps_->empty()) {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1576"}},{"Add":{"text":" auto i = steps_->begin();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1610"}},{"Add":{"text":" if (i->first > now - schedulingWindow) break;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1664"}},{"Add":{"text":" seconds -= i->second;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1694"}},{"Add":{"text":" steps_->erase(i);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1720"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1726"}},{"Add":{"text":"}","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1728"}}]}},{"Edit":{"inode":{"change":8,"pos":4840},"path":"src/hydra-queue-runner/hydra-queue-runner.cc","line":465,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":2016}],"down_context":[{"change":10,"pos":401}],"flag":"BLOCK","start":1730,"end":2189,"inode":{"change":8,"pos":4840}}},"contents":[{"Add":{"text":" {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1739"}},{"Add":{"text":" root.attr(\"jobsets\");","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1773"}},{"Add":{"text":" JSONObject nested(out);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1809"}},{"Add":{"text":" auto jobsets_(jobsets.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1852"}},{"Add":{"text":" for (auto & jobset : *jobsets_) {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1898"}},{"Add":{"text":" nested.attr(jobset.first.first + \":\" + jobset.first.second);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:1975"}},{"Add":{"text":" JSONObject nested2(out);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2016"}},{"Add":{"text":" nested2.attr(\"shareUsed\"); out << jobset.second->shareUsed();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2094"}},{"Add":{"text":" nested2.attr(\"seconds\", jobset.second->getSeconds());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2164"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2178"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2188"}}]}},{"Edit":{"inode":{"change":3,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":52,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":21501},"to":{"change":3,"start":21501,"end":21502},"introduced_by":3}],"inode":{"change":3,"pos":20067}}},"contents":[{"Del":{"text":"","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:21501"}}]}},{"Edit":{"inode":{"change":3,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":86,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":748}],"down_context":[{"change":3,"pos":22781}],"flag":"BLOCK","start":2190,"end":2276,"inode":{"change":3,"pos":20067}}},"contents":[{"Add":{"text":" build->jobset = createJobset(txn, build->projectName, build->jobsetName);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2275"}}]}},{"Edit":{"inode":{"change":3,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":212,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":27613}],"down_context":[{"change":3,"pos":27613}],"flag":"BLOCK","start":2277,"end":2316,"inode":{"change":3,"pos":20067}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2277"}},{"Add":{"text":" build->propagatePriorities();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2315"}}]}},{"Edit":{"inode":{"change":3,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":235,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2401},"to":{"change":2,"start":749,"end":787},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":787},"to":{"change":3,"start":28327,"end":28328},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":3,"pos":2765},"to":{"change":3,"start":28327,"end":28328},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":28327},"to":{"change":3,"start":28327,"end":28328},"introduced_by":3}],"inode":{"change":3,"pos":20067}}},"contents":[{"Del":{"text":" build->propagatePriorities();","pos":"WE5Q2NVIIK4R2DUUZYLJFQVYK5O26EDEJRPK3CPGWHU3SEAC2DQAC:786"}},{"Del":{"text":"","pos":"MHVIT4JYWUYD4UCGB2AHLXWLX6B5SYE22BREERNGANT7RGGDUFOAC:28327"}}]}},{"Edit":{"inode":{"change":3,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":256,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1300}],"down_context":[{"change":2,"pos":1300}],"flag":"BLOCK","start":2317,"end":2356,"inode":{"change":3,"pos":20067}}},"contents":[{"Add":{"text":" step_->jobsets.insert(jobset);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2355"}}]}},{"Edit":{"inode":{"change":3,"pos":20067},"path":"src/hydra-queue-runner/queue-monitor.cc","line":399,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":32923}],"down_context":[],"flag":"BLOCK","start":2357,"end":3643,"inode":{"change":3,"pos":20067}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2357"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2358"}},{"Add":{"text":"Jobset::ptr State::createJobset(pqxx::work & txn,","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2408"}},{"Add":{"text":" const std::string & projectName, const std::string & jobsetName)","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2477"}},{"Add":{"text":"{","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2479"}},{"Add":{"text":" auto jobsets_(jobsets.lock());","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2514"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2515"}},{"Add":{"text":" auto p = std::make_pair(projectName, jobsetName);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2569"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2570"}},{"Add":{"text":" auto i = jobsets_->find(p);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2602"}},{"Add":{"text":" if (i != jobsets_->end()) return i->second;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2650"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2651"}},{"Add":{"text":" auto res = txn.parameterized","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2684"}},{"Add":{"text":" (\"select schedulingShares from Jobsets where project = $1 and name = $2\")","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2766"}},{"Add":{"text":" (projectName)(jobsetName).exec();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2808"}},{"Add":{"text":" if (res.empty()) throw Error(\"missing jobset - can't happen\");","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2875"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2876"}},{"Add":{"text":" auto shares = res[0][\"schedulingShares\"].as();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2941"}},{"Add":{"text":" if (shares == 0) shares = 1;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2974"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:2975"}},{"Add":{"text":" auto jobset = std::make_shared(shares);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3027"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3028"}},{"Add":{"text":" /* Load the build steps from the last 24 hours. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3083"}},{"Add":{"text":" res = txn.parameterized","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3111"}},{"Add":{"text":" (\"select s.startTime, s.stopTime from BuildSteps s join Builds b on build = id \"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3200"}},{"Add":{"text":" \"where s.startTime is not null and s.stopTime > $1 and project = $2 and jobset = $3\")","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3295"}},{"Add":{"text":" (time(0) - Jobset::schedulingWindow * 10)(projectName)(jobsetName).exec();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3378"}},{"Add":{"text":" for (auto const & row : res) {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3413"}},{"Add":{"text":" time_t startTime = row[\"startTime\"].as();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3471"}},{"Add":{"text":" time_t stopTime = row[\"stopTime\"].as();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3527"}},{"Add":{"text":" jobset->addStep(startTime, stopTime - startTime);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3585"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3591"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3592"}},{"Add":{"text":" (*jobsets_)[p] = jobset;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3621"}},{"Add":{"text":" return jobset;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3640"}},{"Add":{"text":"}","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3642"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":61,"atom":{"NewVertex":{"up_context":[{"change":12,"pos":3783}],"down_context":[{"change":11,"pos":1954}],"flag":"BLOCK","start":3644,"end":3873,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3644"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3645"}},{"Add":{"text":"class Jobset","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3658"}},{"Add":{"text":"{","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3660"}},{"Add":{"text":"public:","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3668"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3669"}},{"Add":{"text":" typedef std::shared_ptr ptr;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3710"}},{"Add":{"text":" typedef std::weak_ptr wptr;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3750"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3751"}},{"Add":{"text":" Jobset(unsigned int shares) : shares(shares) { }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3804"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3805"}},{"Add":{"text":" static const time_t schedulingWindow = 24 * 60 * 60;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3862"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3863"}},{"Add":{"text":"private:","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3872"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":76,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":1955}],"down_context":[{"change":11,"pos":1955}],"flag":"BLOCK","start":3874,"end":3948,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":" std::atomic seconds{0};","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3909"}},{"Add":{"text":" std::atomic shares;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:3947"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":79,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":1956}],"down_context":[{"change":11,"pos":1956}],"flag":"BLOCK","start":3949,"end":4276,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":" /* The start time and duration of the most recent build steps. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4018"}},{"Add":{"text":" Sync> steps;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4060"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4061"}},{"Add":{"text":"public:","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4069"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4070"}},{"Add":{"text":" double shareUsed()","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4093"}},{"Add":{"text":" {","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4099"}},{"Add":{"text":" return (double) seconds / shares;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4141"}},{"Add":{"text":" }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4147"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4148"}},{"Add":{"text":" time_t getSeconds() { return seconds; }","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4192"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4193"}},{"Add":{"text":" void addStep(time_t startTime, time_t duration);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4246"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4247"}},{"Add":{"text":" void pruneSteps();","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4270"}},{"Add":{"text":"};","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4273"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4274"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4275"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":111,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":2233}],"down_context":[{"change":11,"pos":2233}],"flag":"BLOCK","start":4277,"end":4302,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4277"}},{"Add":{"text":" Jobset::ptr jobset;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4301"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":149,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":2904}],"down_context":[{"change":11,"pos":2904}],"flag":"BLOCK","start":4303,"end":4446,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":" /* Jobsets to which this step belongs. Used for determining","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4370"}},{"Add":{"text":" scheduling priority. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4405"}},{"Add":{"text":" std::set jobsets;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4444"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4445"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":162,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":2151}],"down_context":[{"change":2,"pos":2151}],"flag":"BLOCK","start":4447,"end":4565,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4447"}},{"Add":{"text":" /* The lowest share used of any jobset depending on this","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4512"}},{"Add":{"text":" step. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4532"}},{"Add":{"text":" double lowestShareUsed;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4564"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":249,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":4521}],"down_context":[{"change":11,"pos":4521}],"flag":"BLOCK","start":4566,"end":4697,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4566"}},{"Add":{"text":" /* The jobsets. */","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4589"}},{"Add":{"text":" typedef std::map, Jobset::ptr> Jobsets;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4669"}},{"Add":{"text":" Sync jobsets;","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4696"}}]}},{"Edit":{"inode":{"change":11,"pos":1128},"path":"src/hydra-queue-runner/state.hh","line":350,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":8033}],"down_context":[{"change":11,"pos":8033}],"flag":"BLOCK","start":4698,"end":4820,"inode":{"change":11,"pos":1128}}},"contents":[{"Add":{"text":" Jobset::ptr createJobset(pqxx::work & txn,","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4744"}},{"Add":{"text":" const std::string & projectName, const std::string & jobsetName);","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4818"}},{"Add":{"text":"","pos":"IK2UBDAU6QKUXHJG3SXJKYGIIXRDKI6UVRTFC6ZVDXDCGNCMEWVAC:4819"}}]}}],"owner":"grahamc","repo":"hydra","token":"Mwnucpie5CYvZQUZ8w8JVmcw7BMaPPLQ4uajlPXU1FM=","login":null}

…

Dependencies

Change contents

Review