Merge pull request #1256 from cransom/hydra-evaluator-broken-connection
exit with error if database connectivity lost
This commit is contained in:
commit
f48f00ee6d
|
@ -366,6 +366,9 @@ struct Evaluator
|
||||||
printInfo("received jobset event");
|
printInfo("received jobset event");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
} catch (pqxx::broken_connection & e) {
|
||||||
|
printError("Database connection broken: %s", e.what());
|
||||||
|
std::_Exit(1);
|
||||||
} catch (std::exception & e) {
|
} catch (std::exception & e) {
|
||||||
printError("exception in database monitor thread: %s", e.what());
|
printError("exception in database monitor thread: %s", e.what());
|
||||||
sleep(30);
|
sleep(30);
|
||||||
|
@ -473,6 +476,9 @@ struct Evaluator
|
||||||
while (true) {
|
while (true) {
|
||||||
try {
|
try {
|
||||||
loop();
|
loop();
|
||||||
|
} catch (pqxx::broken_connection & e) {
|
||||||
|
printError("Database connection broken: %s", e.what());
|
||||||
|
std::_Exit(1);
|
||||||
} catch (std::exception & e) {
|
} catch (std::exception & e) {
|
||||||
printError("exception in main loop: %s", e.what());
|
printError("exception in main loop: %s", e.what());
|
||||||
sleep(30);
|
sleep(30);
|
||||||
|
|
Loading…
Reference in a new issue