1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
#pragma once
#include "KingSystem/Utils/Thread/MessageBroker.h"
#include "KingSystem/Utils/Thread/MessageDispatcherBase.h"
namespace ksys {
template <class T>
bool sendMessageImpl(T* transceiver, const MesTransceiverId& dest, const MessageType& type,
void* user_data, bool ack, bool x = false) {
MessageDispatcherBase* dispatcher = transceiver->getDispatcher();
const bool ok = dispatcher->sendMessage(*transceiver->getReceiver()->MessageReceiver::getId(),
dest, type, user_data, ack, x);
if (ok)
transceiver->getReceiver()->setFlag(ack);
return ok;
}
template <class T>
bool sendMessageOnProcessingThreadImpl(T* transceiver, const MesTransceiverId& dest,
const MessageType& type, void* user_data, bool ack,
bool x = false) {
MessageDispatcherBase* dispatcher = transceiver->getDispatcher();
const bool ok = dispatcher->sendMessageOnProcessingThread(
*transceiver->getReceiver()->MessageReceiver::getId(), dest, type, user_data, ack, x);
if (ok)
transceiver->getReceiver()->setFlag(ack);
return ok;
}
template <class T>
bool sendMessageImpl(T* transceiver, IMessageBroker& broker, const MessageType& type,
void* user_data, bool ack, bool x = false) {
MessageDispatcherBase* dispatcher = transceiver->getDispatcher();
const bool ok =
dispatcher->sendMessage(*transceiver->getReceiver()->MessageReceiver::getId(),
*transceiver->getRegister(broker), type, user_data, ack, x);
if (ok) {
for (int i = 0, n = broker.countTransceivers(); i < n; ++i)
transceiver->getReceiver()->setFlag(ack);
}
return ok;
}
template <class T>
bool sendMessageOnProcessingThreadImpl(T* transceiver, IMessageBroker& broker,
const MessageType& type, void* user_data, bool ack,
bool x = false) {
MessageDispatcherBase* dispatcher = transceiver->getDispatcher();
const bool ok = dispatcher->sendMessageOnProcessingThread(
*transceiver->getReceiver()->MessageReceiver::getId(), *transceiver->getRegister(broker),
type, user_data, ack, x);
if (ok) {
for (int i = 0, n = broker.countTransceivers(); i < n; ++i)
transceiver->getReceiver()->setFlag(ack);
}
return ok;
}
} // namespace ksys
|
