]>
Commit | Line | Data |
---|---|---|
5eb34a26 | 1 | #ifndef AliStorageEventManager_H |
2 | #define AliStorageEventManager_H | |
3 | ||
4 | #include "AliESDEvent.h" | |
5 | #include "AliStorageTypes.h" | |
6 | ||
7 | #include <vector> | |
8 | ||
9 | #include <TMessage.h> | |
10 | ||
11 | namespace zmq | |
12 | { | |
13 | class socket_t; | |
14 | class message_t; | |
15 | } | |
16 | ||
17 | class AliStorageEventManager | |
18 | { | |
19 | public: | |
20 | AliStorageEventManager(); | |
21 | ~AliStorageEventManager(); | |
22 | ||
23 | void Send(std::vector<serverListStruct> list,zmq::socket_t *socket); | |
24 | void Send(struct serverRequestStruct *request,zmq::socket_t *socket); | |
25 | void Send(struct clientRequestStruct *request,zmq::socket_t *socket); | |
26 | void Send(AliESDEvent *event, zmq::socket_t *socket); | |
27 | void Send(long message,zmq::socket_t *socket); | |
28 | void Send(bool message,zmq::socket_t *socket); | |
29 | ||
30 | std::vector<serverListStruct> GetServerListVector(zmq::socket_t *socket); | |
31 | AliESDEvent* GetEvent(zmq::socket_t *socket); | |
32 | ||
33 | private: | |
34 | void SendStreamerInfos(TMessage *mess, zmq::socket_t *socket); | |
35 | zmq::message_t* RecvStreamerInfos(zmq::socket_t *socket); | |
36 | }; | |
37 | ||
38 | #endif |