void getQueuedBuilds(Connection & conn, std::shared_ptr<StoreAPI> store, unsigned int & lastBuildId);

    void getQueuedBuilds(std::shared_ptr<StoreAPI> store, unsigned int & lastBuildId);

    void removeCancelledBuilds(Connection & conn);

        getQueuedBuilds(store, lastBuildId);

        getQueuedBuilds(*conn, store, lastBuildId);

            removeCancelledBuilds(*conn);

void State::getQueuedBuilds(std::shared_ptr<StoreAPI> store, unsigned int & lastBuildId)

void State::getQueuedBuilds(Connection & conn, std::shared_ptr<StoreAPI> store, unsigned int & lastBuildId)

    auto conn(dbPool.get());

        pqxx::work txn(*conn);

        pqxx::work txn(conn);

        // FIXME: query only builds with ID higher than the previous
        // highest.

            pqxx::work txn(*conn);

            pqxx::work txn(conn);

            pqxx::work txn(*conn);

            pqxx::work txn(conn);

void State::removeCancelledBuilds(Connection & conn)
{
    /* Get the current set of queued builds. */
    std::set<BuildID> currentIds;
    {
        pqxx::work txn(conn);
        auto res = txn.exec("select id from Builds where finished = 0");
        for (auto const & row : res)
            currentIds.insert(row["id"].as<BuildID>());
    }
    auto builds_(builds.lock());
    for (auto i = builds_->begin(); i != builds_->end(); ) {
        if (currentIds.find(i->first) == currentIds.end()) {
            printMsg(lvlInfo, format("discarding cancelled build %1%") % i->first);
            i = builds_->erase(i);
            // FIXME: ideally we would interrupt active build steps here.
        } else
            ++i;
    }
}

        $db->storage->dbh->do("notify builds_cancelled");