AliZMQManager.h

Go to the documentation of this file.

#ifndef AliZMQManager_H
#define AliZMQManager_H

#include "AliESDEvent.h"
#include "AliStorageTypes.h"

#include <vector>
#include <string>
#include <sstream>
#include <set>

#include <TMessage.h>
#include <TFile.h>

struct zmq_msg_t;

class AliZMQManager
{
public:
  static AliZMQManager* GetInstance();
    void Close();
    void CreateSocket(storageSockets socket);
    void RecreateSocket(storageSockets socket);
    
    // methods to send data (1 = success, 0 = timeout, -1 = socket closed):
  int Send(std::vector<serverListStruct> list,storageSockets socket);
    int Send(std::vector<string100> list,storageSockets socket);
  int Send(struct serverRequestStruct *request,storageSockets socket);
  int Send(struct clientRequestStruct *request,storageSockets socket);
  int Send(AliESDEvent *event,storageSockets socket);
  int Send(long message,storageSockets socket);
  int Send(bool message,storageSockets socket);
    int SendAsXml(AliESDEvent *event,storageSockets socket);
  
    // methods to receive data (1 = success, 0 = timeout, -1 = socket closed):
    int Get(std::vector<serverListStruct>* &result,storageSockets socket);
    int Get(std::vector<string100>* &result,storageSockets socket);
    int Get(AliESDEvent* &result, storageSockets socket);
  int Get(struct serverRequestStruct* &result, storageSockets socket);
  int Get(struct clientRequestStruct* &result, storageSockets socket);
  int Get(long *result, storageSockets socket);
  int Get(bool *result, storageSockets socket);

private:
  AliZMQManager();
  ~AliZMQManager();
  static AliZMQManager *fManagerInstance; 
    
    // ZMQ methods wrappers (1 = success, 0 = timeout, -1 = socket closed):
    bool zmqInit(zmq_msg_t *msg,size_t size=0);
    int zmqSend(zmq_msg_t *msg,void *socket,int flags);
    int zmqRecv(zmq_msg_t *msg,void *socket,int flags);
    
    // hostnames and ports read from config file:
  std::string fStorageServer; 
  std::string fEventServer;   
  int fStorageServerPort;     
  int fStorageClientPort;     
  int fEventServerPort;       
  int fXmlServerPort;         
  
    // ZMQ sockets and contexts:
  void *fContext; 
  void *fSockets[NUMBER_OF_SOCKETS];  

    // copy constructor and assignment operator:
  AliZMQManager(const AliZMQManager&);
  AliZMQManager& operator=(const AliZMQManager&);
};

#endif