K5G5GZY7D7KWVR5RAGZFHH3ZPG5OCLZT4HZ6XIJJ7YYVUMC2CTZQC
PLOZBRTR6USSGJX7GR2RZKNPVYG2Q6QM7LW6IA35MKL63ZTQVD7QC
24BMQDZAWDQ7VNIA7TIROXSOYLOJBNZ2E4264WHWNJAEN6ZB3UOAC
GS4BE6TB6GH2JUZJHDPHL6YG7J7YYESF3YOZJZ2CFABXUTO4VYPQC
NJJ7H64SZOX5EGACDCQAUQ7R6UEWD5IIC35A2MWFOOJV55DJYPHAC
#include "pathlocks.hh"
/* Acquire the global queue runner lock, or null if somebody else has it. */ std::shared_ptr<PathLocks> acquireGlobalLock();
/* Acquire the global queue runner lock, or null if somebody else
has it. */
std::shared_ptr<PathLocks> acquireGlobalLock();
}std::shared_ptr<PathLocks> State::acquireGlobalLock(){ Path lockPath = hydraData + "/queue-runner"; auto lock = std::make_shared<PathLocks>(); if (!lock->lockPaths(PathSet({lockPath}), "", false)) return 0; return lock;
}
std::shared_ptr<PathLocks> State::acquireGlobalLock()
{
Path lockPath = hydraData + "/queue-runner";
auto lock = std::make_shared<PathLocks>();
if (!lock->lockPaths(PathSet({lockPath}), "", false)) return 0;
return lock;
auto lock = acquireGlobalLock(); if (!lock) throw Error("hydra-queue-runner is currently running");
auto lock = acquireGlobalLock();
if (!lock)
throw Error("hydra-queue-runner is currently running");
auto lock = acquireGlobalLock(); if (!lock) throw Error("hydra-queue-runner is already running");
throw Error("hydra-queue-runner is already running");