blob: 6869bc200c7971e106f1a2b2378830c3606514b5 (
plain)
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
|
#pragma once
#include <basis/seadTypes.h>
#include "KingSystem/Utils/Thread/MessageDispatcherBase.h"
#include "KingSystem/Utils/Thread/MessageReceiverEx.h"
namespace ksys {
class IMessageBroker;
class IMessageBrokerRegister;
struct MesTransceiverId;
struct MessageType;
class MessageTransceiverBase {
public:
MessageTransceiverBase();
virtual ~MessageTransceiverBase();
bool checkReceiverFlag();
bool isWaitingForAck();
virtual bool sendMessage(const MesTransceiverId& dest, const MessageType& type, void* user_data,
bool ack);
virtual bool sendMessageOnProcessingThread(const MesTransceiverId& dest,
const MessageType& type, void* user_data, bool ack);
virtual bool sendMessage(IMessageBroker& broker, const MessageType& type, void* user_data,
bool ack);
virtual bool sendMessageOnProcessingThread(IMessageBroker& broker, const MessageType& type,
void* user_data, bool ack);
virtual MessageReceiverEx* getReceiver() = 0;
MessageDispatcherBase* getDispatcher();
MesTransceiverId* getId() const { return mId; }
IMessageBrokerRegister* getRegister(IMessageBroker& broker) const;
static void setGlobalDispatcher(MessageDispatcherBase* dispatcher);
protected:
void registerReceiver(MessageReceiverEx& receiver) {
getDispatcher()->registerTransceiver(receiver);
mId = receiver.MessageReceiver::getId();
}
void deregisterReceiver(MessageReceiverEx& receiver) {
getDispatcher()->deregisterTransceiver(receiver);
}
private:
static MessageDispatcherBase* sDispatcher;
MessageDispatcherBase* mDispatcher = sDispatcher;
MesTransceiverId* mId{};
};
} // namespace ksys
|
