PZmqBackend.h

Go to the documentation of this file.

/***************************************
        Auteur : Thibaut Oprinsen
        Mail : thibaut.oprinsen@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PZMQBACKEND_H__
#define __PZMQBACKEND_H__
 
#include <string>
#include "PSocketFlag.h"
#include "phoenix_generic_mock.h"
#include "phoenix_data_stream.h"
#include "phoenix_zmq.h"

struct PZmqParam{
        int type;
        int nbBufferMessage;
        int bufferSizeByte;
        size_t threadAffinity;
        ssize_t dataRate;
};
 
PZmqParam pzmq_createParamClient(int type, int nbBufferMessage = 10000, int bufferSizeByte = 1000000, size_t threadAffinity = 0lu, ssize_t dataRate = 200000l);
PZmqParam pzmq_createParamServer(int type, int nbBufferMessage = 10000, int bufferSizeByte = 1000000, size_t threadAffinity = 0lu, ssize_t dataRate = 200000l);
template <typename T>
std::string statusToStr(T status);
PSendStatus::PSendStatus checkSendStatus(zmq::send_result_t res);
PRecvStatus::PRecvStatus checkRecvStatus(zmq::recv_result_t res);

class PZmqSocket{
        public:
                typedef zmq::message_t Message;
                typedef PZmqParam Param;
                
                PZmqSocket();
                virtual ~PZmqSocket();
                
                bool createClientSocket(zmq::context_t & context, const PSocketParam & socketParam, const Param & extraParam);
                bool createServerSocket(zmq::context_t & context, const PSocketParam & socketParam, const Param & extraParam);
                
                template<typename T>
                PSendStatus::PSendStatus sendData(const T & data, PSendFlag::PSendFlag flag = PSendFlag::BLOCK);
                PSendStatus::PSendStatus sendMsg(Message & msg, PSendFlag::PSendFlag flag = PSendFlag::BLOCK);
                
                template<typename T>
                PRecvStatus::PRecvStatus recvData(T & data, PRecvFlag::PRecvFlag flag = PRecvFlag::BLOCK);
                PRecvStatus::PRecvStatus recvMsg(Message & msg, PRecvFlag::PRecvFlag flag = PRecvFlag::BLOCK);
                
                bool isConnected() const;
                void close();
        private:
                zmq::socket_t* p_socket;
};

class PZmqBackend{
        public:
                typedef PZmqSocket Socket;
                typedef zmq::message_t Message;
                typedef PZmqParam Param;
                
                PZmqBackend();
                
                static Param client();
                static Param server();
                
                bool createClientSocket(Socket & socket, const PSocketParam & socketParam, const PZmqParam & param);
                bool createServerSocket(Socket & socket, const PSocketParam & socketParam, const PZmqParam & param);
                
                void msgToMock(DataStreamMsg & mockMsg, const Message & msg);
                void mockToMsg(Message & msg, DataStreamMsg & mockMsg);
 
        private:
                zmq::context_t p_context;
};
 
#include "PZmqBackend_impl.h"
 
#endif