STORAGE/AliStorageEventManager.h

   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