Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: NixOS/hydra
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 4e27796eba97
Choose a base ref
...
head repository: NixOS/hydra
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 09a4c9fad25c
Choose a head ref
  • 1 commit
  • 1 file changed
  • 1 contributor

Commits on May 16, 2018

  1. hydra-evaluator: Allow setting the maximum number of concurrent evalu… 

    …ations
    @edolstra
    edolstra committed May 16, 2018
    Copy the full SHA
    09a4c9f View commit details
Showing with 10 additions and 2 deletions.
  1. +10 −2 src/hydra-evaluator/hydra-evaluator.cc
12 changes: 10 additions & 2 deletions src/hydra-evaluator/hydra-evaluator.cc
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
#include "shared.hh"
#include "db.hh"
#include "hydra-config.hh"
#include "pool.hh"
#include "shared.hh"

#include <algorithm>
#include <thread>
@@ -16,6 +17,8 @@ typedef std::pair<std::string, std::string> JobsetName;

struct Evaluator
{
std::unique_ptr<Config> config;

nix::Pool<Connection> dbPool;

struct Jobset
@@ -30,7 +33,7 @@ struct Evaluator

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

size_t maxEvals = 4;
const size_t maxEvals;

struct State
{
@@ -45,6 +48,11 @@ struct Evaluator

const time_t notTriggered = std::numeric_limits<time_t>::max();

Evaluator()
: config(std::make_unique<::Config>())
, maxEvals(std::max((size_t) 1, (size_t) config->getIntOption("max_concurrent_evals", 4)))
{ }

void readJobsets()
{
auto conn(dbPool.get());