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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
/*
* Copyright (C) 2005-2013 Team XBMC
* http://xbmc.org
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*
*/
#pragma once
#include "threads/Thread.h"
#include "utils/log.h"
#include <queue>
#include "memory.h"
#define MSG_INTERNAL_BUFFER_SIZE 32
namespace Actor
{
class Protocol;
class Message
{
friend class Protocol;
public:
int signal;
bool isSync;
bool isSyncFini;
bool isOut;
bool isSyncTimeout;
int payloadSize;
uint8_t buffer[MSG_INTERNAL_BUFFER_SIZE];
uint8_t *data;
Message *replyMessage;
Protocol *origin;
CEvent *event;
void Release();
bool Reply(int sig, void *data = NULL, int size = 0);
private:
Message() {isSync = false; data = NULL; event = NULL; replyMessage = NULL;};
};
class Protocol
{
public:
Protocol(std::string name, CEvent* inEvent, CEvent *outEvent)
: portName(name), inDefered(false), outDefered(false) {containerInEvent = inEvent; containerOutEvent = outEvent;};
virtual ~Protocol();
Message *GetMessage();
void ReturnMessage(Message *msg);
bool SendOutMessage(int signal, void *data = NULL, int size = 0, Message *outMsg = NULL);
bool SendInMessage(int signal, void *data = NULL, int size = 0, Message *outMsg = NULL);
bool SendOutMessageSync(int signal, Message **retMsg, int timeout, void *data = NULL, int size = 0);
bool ReceiveOutMessage(Message **msg);
bool ReceiveInMessage(Message **msg);
void Purge();
void PurgeIn(int signal);
void PurgeOut(int signal);
void DeferIn(bool value) {inDefered = value;};
void DeferOut(bool value) {outDefered = value;};
void Lock() {criticalSection.lock();};
void Unlock() {criticalSection.unlock();};
std::string portName;
protected:
CEvent *containerInEvent, *containerOutEvent;
CCriticalSection criticalSection;
std::queue<Message*> outMessages;
std::queue<Message*> inMessages;
std::queue<Message*> freeMessageQueue;
bool inDefered, outDefered;
};
}
|
