PZmqBackend.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PZMQBACKEND_H__
#define __PZMQBACKEND_H__
 
#include "PSocketFlag.h"
#include "phoenix_data_stream.h"
#include "phoenix_zmq.h"
 
struct PZmqParam{
        zmq::context_t* context;
        std::string address;
        size_t port;
        int type;
        int nbBufferMessage;
        int bufferSizeByte;
        size_t threadAffinity;
        ssize_t dataRate;
};
 
PZmqParam pzmq_createParamClient(const std::string & address, size_t port, zmq::context_t* context = NULL, int type = ZMQ_PULL, int nbBufferMessage = 10000, int bufferSizeByte = 1000000, size_t threadAffinity = 0lu, ssize_t dataRate = 200000l);
PZmqParam pzmq_createParamServer(const std::string & address, size_t port, zmq::context_t* context = NULL, int type = ZMQ_PUSH, int nbBufferMessage = 10000, int bufferSizeByte = 1000000, size_t threadAffinity = 0lu, ssize_t dataRate = 200000l);
 
class PZmqBackend{
        public:
                typedef zmq::socket_t* Socket;
                typedef zmq::message_t Message;
                typedef PZmqParam Param;
 
                PZmqBackend();
                
                static Param client(const std::string & address, size_t port, zmq::context_t* context = NULL, int type = ZMQ_PULL, int nbBufferMessage = 10000, int bufferSizeByte = 1000000, size_t threadAffinity = 0lu, ssize_t dataRate = 200000l);
                static Param server(const std::string & address, size_t port, zmq::context_t* context = NULL, int type = ZMQ_PUSH, int nbBufferMessage = 10000, int bufferSizeByte = 1000000, size_t threadAffinity = 0lu, ssize_t dataRate = 200000l);
                
                static bool createClientSocket(Socket & socket, const std::string & address, size_t port, const PZmqParam & param);
                static bool createServerSocket(Socket & socket, const std::string & address, size_t port, const PZmqParam & param);
                
                static bool createClientSocket(Socket & socket, const Param & param);
                static bool createServerSocket(Socket & socket, const Param & param);
                
                static bool send(Socket & socket, Message & msg, PSendFlag::PSendFlag flag);
                static bool recv(Socket & socket, Message & msg, PRecvFlag::PRecvFlag flag);
                
                static void msgResize(Message& msg, size_t sizeMsg);
                static size_t msgSize(const Message& msg);
                static const DataStreamIter msgData(const Message& msg);
                static DataStreamIter msgData(Message& msg);
                
                static void close(Socket & socket);
                static bool isConnected(const Socket & socket);
                
                static void msgToMock(DataStreamMsg & mockMsg, const Message & msg);
                static void mockToMsg(Message & msg, DataStreamMsg & mockMsg);
};
 
 
 
#endif