summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/ha/StatusCheck.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/ha/StatusCheck.h')
-rw-r--r--qpid/cpp/src/qpid/ha/StatusCheck.h5
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/ha/StatusCheck.h b/qpid/cpp/src/qpid/ha/StatusCheck.h
index 087e586b2b..2ff6f1ffba 100644
--- a/qpid/cpp/src/qpid/ha/StatusCheck.h
+++ b/qpid/cpp/src/qpid/ha/StatusCheck.h
@@ -25,6 +25,7 @@
#include "BrokerInfo.h"
#include "Settings.h"
#include "qpid/Url.h"
+#include "qpid/sys/AtomicValue.h"
#include "qpid/sys/Thread.h"
#include "qpid/sys/Mutex.h"
#include "qpid/sys/Runnable.h"
@@ -60,10 +61,12 @@ class StatusCheck
bool canPromote();
private:
- void setPromote(bool p);
+ void noPromote();
+ void endThread();
sys::Mutex lock;
std::vector<sys::Thread> threads;
+ sys::AtomicValue<int> threadCount;
bool promote;
const Settings settings;
const sys::Duration heartbeat;