PIpBusBackend.h

Go to the documentation of this file.

/***************************************
        Auteur : Jean Jacquemier & Thibaut Oprinsen
        Mail : jean.jacquemier@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PIPBUSBACKEND_H__
#define __PIPBUSBACKEND_H__
 
#include "PSocketFlag.h"
#include "phoenix_generic_mock.h"
#include "phoenix_data_stream.h"
#include "uaMessage.h"
#include "ipbrw.h"

struct PIpBusParam {
        std::string connectionFilePath;
        std::string connectionId;
};
 
template <typename T>
std::string statusToStr(T status);

class PIpBusSocket {
        public:
                typedef UaMessage Message;
                typedef PIpBusParam Param;
 
                PIpBusSocket();
                virtual ~PIpBusSocket();
 
                bool createClientSocket(const Param & extraParam);
                bool createServerSocket(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:
                IpBusImpl* p_uaSocket;
};

class PIpBusBackend {
        public:
                typedef PIpBusSocket Socket;
                typedef UaMessage Message;
                typedef PIpBusParam Param;
 
                PIpBusBackend();
 
                static Param client(std::string &connectionFilePath, std::string &connectionId);
                static Param server(std::string &connectionFilePath, std::string &connectionId);
 
                bool createClientSocket(Socket & socket, const PSocketParam & socketParam, const Param & param);
                bool createServerSocket(Socket & socket, const PSocketParam & socketParam, const Param & param);
 
                static void msgToMock(DataStreamMsg & mockMsg, const Message & msg);
                static void mockToMsg(Message & msg, DataStreamMsg & mockMsg);
};
 
#include "PIpBusBackend_impl.h"
 
#endif