summaryrefslogtreecommitdiff
path: root/src/3rd_party-static/MessageBroker/include/mb_controller.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/3rd_party-static/MessageBroker/include/mb_controller.hpp')
-rw-r--r--src/3rd_party-static/MessageBroker/include/mb_controller.hpp9
1 files changed, 2 insertions, 7 deletions
diff --git a/src/3rd_party-static/MessageBroker/include/mb_controller.hpp b/src/3rd_party-static/MessageBroker/include/mb_controller.hpp
index 930a53b385..2d196aced2 100644
--- a/src/3rd_party-static/MessageBroker/include/mb_controller.hpp
+++ b/src/3rd_party-static/MessageBroker/include/mb_controller.hpp
@@ -13,6 +13,7 @@
#include "mb_tcpclient.hpp"
#include "utils/lock.h"
+#include "utils/atomic_object.h"
#include <cstring>
@@ -196,7 +197,7 @@ namespace NsMessageBroker
/**
* @brief flag top stop thread
*/
- volatile bool stop;
+ sync_primitives::atomic_bool stop;
private:
/**
@@ -247,12 +248,6 @@ namespace NsMessageBroker
* @brief mutex for mWaitResponseQueue
*/
sync_primitives::Lock queue_lock_;
-
- /*
- * @brief mutex for Mutex for correct finishing of receiving thread
- */
- sync_primitives::Lock receiving_thread_lock_;
-
};
} /* namespace NsMessageBroker */
#endif /* MB_CONTROLLER_H */