summaryrefslogtreecommitdiff
path: root/src/KingSystem/Utils/Thread/MessageReceiverEx.cpp
diff options
context:
space:
mode:
authorLéo Lam <leo@leolam.fr>2021-02-03 22:23:39 +0100
committerLéo Lam <leo@leolam.fr>2021-02-03 23:52:03 +0100
commite237bf4b5d0556e91309927c99ccbfe4874c1b63 (patch)
tree1fdd74fe77902f2f021bde9d06db6a3781e9e1d8 /src/KingSystem/Utils/Thread/MessageReceiverEx.cpp
parentdf58679ddae8a97b1a64fe3ec62298b11b86a76d (diff)
ksys: Rename messaging system members for clarity
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;
}
}