summaryrefslogtreecommitdiff
path: root/src/KingSystem/Utils/Thread/MessageProcessor.cpp
diff options
context:
space:
mode:
authorLéo Lam <leo@leolam.fr>2021-02-01 21:17:56 +0100
committerLéo Lam <leo@leolam.fr>2021-02-02 14:56:58 +0100
commitdfef8dfff7a66851b5797f1863a4507cdad6e44c (patch)
treeff11d2a49d689cc7469898fc53884ffccc49bc29 /src/KingSystem/Utils/Thread/MessageProcessor.cpp
parent76b9041c7846567c72b727c73f51b9f4f681ec2b (diff)
ksys: Implement several more MessageDispatcher functions
Diffstat (limited to 'src/KingSystem/Utils/Thread/MessageProcessor.cpp')
-rw-r--r--src/KingSystem/Utils/Thread/MessageProcessor.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/KingSystem/Utils/Thread/MessageProcessor.cpp b/src/KingSystem/Utils/Thread/MessageProcessor.cpp
index 88ce1b93..779afde6 100644
--- a/src/KingSystem/Utils/Thread/MessageProcessor.cpp
+++ b/src/KingSystem/Utils/Thread/MessageProcessor.cpp
@@ -19,17 +19,17 @@ bool MessageProcessor::process(Message* message) {
bool dest_valid = false;
const auto& dest = message->getDestination();
- if (Message::checkTransceiver(dest)) {
+ if (dest.isRegistered()) {
success = dest.receiver->receive(*message) & 1;
mLogger->log(*message, success);
dest_valid = true;
}
const auto& src = message->getSource();
- if (!message->hasDelayer() || Message::checkTransceiver(src)) {
+ if (!message->hasDelayer() || src.isRegistered()) {
if (message->shouldAck()) {
const auto& source = message->getSource();
- if (Message::checkTransceiver(source)) {
+ if (source.isRegistered()) {
auto* receiver = source.receiver;
const MessageAck ack{dest_valid, success, message->getDestination(),
message->getType(), message->getUserData()};