summaryrefslogtreecommitdiff
path: root/src/KingSystem/Utils/Thread/MessageReceiverEx.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/KingSystem/Utils/Thread/MessageReceiverEx.cpp')
-rw-r--r--src/KingSystem/Utils/Thread/MessageReceiverEx.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/KingSystem/Utils/Thread/MessageReceiverEx.cpp b/src/KingSystem/Utils/Thread/MessageReceiverEx.cpp
index 40a7b894..91564f13 100644
--- a/src/KingSystem/Utils/Thread/MessageReceiverEx.cpp
+++ b/src/KingSystem/Utils/Thread/MessageReceiverEx.cpp
@@ -12,22 +12,22 @@ int MessageReceiverEx::receive(const Message& message) {
void MessageReceiverEx::receive(const MessageAck& ack) {
handleAck(ack);
- --mCounter;
- static_cast<void>(mCounter.load());
+ --mNumPendingAcks;
+ static_cast<void>(mNumPendingAcks.load());
}
bool MessageReceiverEx::checkFlag() const {
return mFlag && *mFlag == 1;
}
-bool MessageReceiverEx::checkCounter() const {
- return mCounter > 0;
+bool MessageReceiverEx::isWaitingForAck() const {
+ return mNumPendingAcks > 0;
}
-void MessageReceiverEx::setFlag(bool update_counter) {
+void MessageReceiverEx::setFlag(bool ack_requested) {
if (mFlag) {
- if (update_counter)
- mCounter.increment();
+ if (ack_requested)
+ mNumPendingAcks.increment();
*mFlag = 1;
}
}