diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index e9eb6041a..e4a2a90b2 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -616,6 +616,10 @@ void PostgreSQL::membersDbWatcher() } PQfinish(conn); conn = NULL; + if (_run == 1) { + fprintf(stderr, "ERROR: %s membersDbWatcher should still be running! Exiting Controller.\n", _myAddressStr.c_str()); + exit(9); + } } void PostgreSQL::networksDbWatcher() @@ -667,6 +671,10 @@ void PostgreSQL::networksDbWatcher() } PQfinish(conn); conn = NULL; + if (_run == 1) { + fprintf(stderr, "ERROR: %s networksDbWatcher should still be running! Exiting Controller.\n", _myAddressStr.c_str()); + exit(8); + } } void PostgreSQL::commitThread() @@ -1143,6 +1151,10 @@ void PostgreSQL::commitThread() } PQfinish(conn); + if (_run == 1) { + fprintf(stderr, "ERROR: %s commitThread should still be running! Exiting Controller.\n", _myAddressStr.c_str()); + exit(7); + } } void PostgreSQL::onlineNotificationThread()