ExecStopPost = "${cfg.package}/bin/hydra-evaluator --unlock";

#include <experimental/optional>

typedef std::pair<std::string, std::string> JobsetName;

    typedef std::pair<std::string, std::string> JobsetName;

    std::experimental::optional<JobsetName> evalOne;

            if (evalOne && name != *evalOne) continue;

        if (evalOne && seen.empty()) {
            printError("the specified jobset does not exist");
            std::_Exit(1);
        }

        printInfo("starting evaluation of jobset ‘%s:%s’", jobset.name.first, jobset.name.second);

        time_t now = time(0);
        printInfo("starting evaluation of jobset ‘%s:%s’ (last checked %d s ago)",
            jobset.name.first, jobset.name.second,
            now - jobset.lastCheckedTime);
        {
            auto conn(dbPool.get());
            pqxx::work txn(*conn);
            txn.parameterized
                ("update Jobsets set startTime = $1 where project = $2 and name = $3")
                (now)
                (jobset.name.first)
                (jobset.name.second)
                .exec();
            txn.commit();
        }

        time_t now = time(0);
        {
            auto conn(dbPool.get());
            pqxx::work txn(*conn);
            txn.parameterized
                ("update Jobsets set lastCheckedTime = $1, triggerTime = null where project = $2 and name = $3")
                (now)
                (jobset.name.first)
                (jobset.name.second)
                .exec();
            txn.commit();
            jobset.lastCheckedTime = now;
            jobset.triggerTime = notTriggered;
        }

            if (i->second.pid == -1 &&
                (i->second.triggerTime != std::numeric_limits<time_t>::max() ||
                    (i->second.checkInterval > 0 && i->second.lastCheckedTime + i->second.checkInterval <= now)))

            if (evalOne ||
                (i->second.pid == -1 &&
                 (i->second.triggerTime != std::numeric_limits<time_t>::max() ||
                     (i->second.checkInterval > 0 && i->second.lastCheckedTime + i->second.checkInterval <= now))))

                for (auto & jobset : state->jobsets)
                    if (jobset.second.pid == pid) {

                // FIXME: should use a map.
                for (auto & i : state->jobsets) {
                    auto & jobset(i.second);
                    if (jobset.pid == pid) {

                            jobset.first.first, jobset.first.second, statusToString(status));

                            jobset.name.first, jobset.name.second, statusToString(status));
                        auto now = time(0);
                        jobset.triggerTime = notTriggered;
                        jobset.lastCheckedTime = now;

                            auto conn(dbPool.get());
                            pqxx::work txn(*conn);
                            /* Clear the trigger time to prevent this
                               jobset from getting stuck in an endless
                               failing eval loop. */
                            txn.parameterized
                                ("update Jobsets set triggerTime = null where project = $1 and name = $2 and startTime is not null and triggerTime < startTime")
                                (jobset.name.first)
                                (jobset.name.second)
                                .exec();
                            /* Clear the start time. */
                            txn.parameterized
                                ("update Jobsets set startTime = null where project = $1 and name = $2")
                                (jobset.name.first)
                                (jobset.name.second)
                                .exec();

                                auto conn(dbPool.get());
                                pqxx::work txn(*conn);

                                    ("update Jobsets set errorMsg = $1, errorTime = $2")

                                    ("update Jobsets set errorMsg = $1, lastCheckedTime = $2, errorTime = $2, fetchErrorMsg = null where project = $3 and name = $4")

                                    (time(0))

                                    (now)
                                    (jobset.name.first)
                                    (jobset.name.second)

                                txn.commit();

                            txn.commit();

                        jobset.second.pid.release();

                        jobset.pid.release();

                        if (evalOne) std::_Exit(0);

                }

    void unlock()
    {
        auto conn(dbPool.get());
        pqxx::work txn(*conn);
        txn.parameterized("update Jobsets set startTime = null").exec();
        txn.commit();
    }

        unlock();

        auto callback = createInterruptCallback([&]() { std::_Exit(0); });

        auto callback = createInterruptCallback([&]() { std::_Exit(1); });

        bool unlock = false;
        Evaluator evaluator;
        std::vector<std::string> args;

            return false;

            if (*arg == "--unlock")
                unlock = true;
            else if (hasPrefix(*arg, "-"))
                return false;
            args.push_back(*arg);
            return true;

        Evaluator().run();

        if (!args.empty()) {
            if (args.size() != 2) throw UsageError("Syntax: hydra-evaluator [<project> <jobset>]");
            evaluator.evalOne = JobsetName(args[0], args[1]);
        }
        if (unlock)
            evaluator.unlock();
        else
            evaluator.run();

    $c->stash->{latestEval} = $c->stash->{jobset}->jobsetevals->search({}, { rows => 1, order_by => ["id desc"] })->single;

    $c->stash->{latestEval} = $c->stash->{jobset}->jobsetevals->search({ hasnewbuilds => 1 }, { rows => 1, order_by => ["id desc"] })->single;

  is_nullable: 1
=head2 starttime
  data_type: 'integer'

  "starttime",
  { data_type => "integer", is_nullable => 1 },

# Created by DBIx::Class::Schema::Loader v0.07045 @ 2016-10-24 20:12:51
# DO NOT MODIFY THIS OR ANYTHING ABOVE! md5sum:PSR66NnVRNTMFhDEm10erA

# Created by DBIx::Class::Schema::Loader v0.07045 @ 2017-03-09 13:03:05
# DO NOT MODIFY THIS OR ANYTHING ABOVE! md5sum:ivYvsUyhEeaeI4EmRQ0/QQ

      [% IF jobset.triggertime %]

      [% IF jobset.starttime %]
      <tr>
        <th>Evaluation running since:</th>
        <td>[% INCLUDE renderRelativeDate timestamp = jobset.starttime %]</td>
      </tr>
      [% ELSIF jobset.triggertime %]

        <td>[% INCLUDE renderDateTime timestamp = jobset.triggertime %]</td>

        <td>[% INCLUDE renderRelativeDate timestamp = jobset.triggertime %]</td>

    print STDERR "considering jobset ", $jobset->project->name, ":", $jobset->name,
      $jobset->lastcheckedtime
          ? " (last checked " . (time() - $jobset->lastcheckedtime) . "s ago)\n"
          : " (never checked)\n";
    my $triggerTime = $jobset->triggertime;

    }
    if (defined $triggerTime) {
        txn_do($db, sub {
            # Only clear the trigger time if the jobset hasn't been
            # triggered in the meantime.  In that case, we need to
            # evaluate again.
            my $new = $jobset->get_from_storage();
            $jobset->update({ triggertime => undef })
                if $new->triggertime == $triggerTime;
        }) if !$dryRun;

    startTime     integer, -- if jobset is currently running

alter table Jobsets add column startTime integer;