ma27/hydra
0
0
Fork 0
forked from lix-project/hydra
Code Pull requests Activity

Lock builds for a shorter amount of time

Browse source
This commit is contained in:
Eelco Dolstra 2015-06-10 15:36:21 +02:00
parent 6d738a31bf
commit a4fb93c119
1 changed files with 1 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/hydra-queue-runner/hydra-queue-runner.cc
View file

@ -421,18 +421,6 @@ void State::getQueuedBuilds(std::shared_ptr<StoreAPI> store)
auto conn(dbPool.get()); auto conn(dbPool.get());
#if 0
{
auto runnable_(runnable.lock());
auto builds_(builds.lock());
auto steps_(steps.lock());
printMsg(lvlError, format("%1% builds, %2% steps, %3% runnable steps")
% builds_->size()
% steps_->size()
% runnable_->size());
}
#endif
/* Grab the queued builds from the database, but don't process /* Grab the queued builds from the database, but don't process
them yet (since we don't want a long-running transaction). */ them yet (since we don't want a long-running transaction). */
std::list<Build::ptr> newBuilds; // FIXME: use queue std::list<Build::ptr> newBuilds; // FIXME: use queue
@ -444,9 +432,8 @@ void State::getQueuedBuilds(std::shared_ptr<StoreAPI> store)
// highest. // highest.
auto res = txn.exec("select * from Builds where finished = 0 order by id"); auto res = txn.exec("select * from Builds where finished = 0 order by id");
auto builds_(builds.lock());
for (auto const & row : res) { for (auto const & row : res) {
auto builds_(builds.lock());
BuildID id = row["id"].as<BuildID>(); BuildID id = row["id"].as<BuildID>();
if (has(*builds_, id)) continue; if (has(*builds_, id)) continue;