diff options
| author | Léo Lam <leo@leolam.fr> | 2021-02-02 16:25:42 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-02-02 16:25:42 +0100 |
| commit | 4edc9e6eeb61be6a67fabe5106cd78325e8d53a8 (patch) | |
| tree | ff11d2a49d689cc7469898fc53884ffccc49bc29 /src/KingSystem/Utils/Thread/MessageProcessor.cpp | |
| parent | 76b9041c7846567c72b727c73f51b9f4f681ec2b (diff) | |
| parent | dfef8dfff7a66851b5797f1863a4507cdad6e44c (diff) | |
Merge pull request #26 from leoetlino/dispatcher2
ksys: Implement several more MessageDispatcher functions
Diffstat (limited to 'src/KingSystem/Utils/Thread/MessageProcessor.cpp')
| -rw-r--r-- | src/KingSystem/Utils/Thread/MessageProcessor.cpp | 6 |
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()}; |
