PMockBackend.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PMockSocketGenerator_H__
#define __PMockSocketGenerator_H__
 
#include "PSocketFlag.h"
#include "phoenix_generic_mock.h"

struct PMockParam{};

class PMockSocket{
        public:
                typedef DataStreamMsg Message;
                typedef PMockParam Param;
                
                PMockSocket();
                virtual ~PMockSocket();
                
                bool createClientSocket(const PSocketParam & socketParam, const Param & extraParam);
                bool createServerSocket(const PSocketParam & socketParam, const Param & extraParam);
                
                void setMockPrefix(const std::string & mockPrefix);
                void setIsMockRecord(bool isMockRecord);
                
                template<typename T>
                PSendStatus::PSendStatus sendData(const T & data, PSendFlag::PSendFlag flag = PSendFlag::BLOCK);
                PSendStatus::PSendStatus sendMsg(const 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:
                PGenericVecMock<DataStreamMsg> p_mock;
                PSocketParam p_socketParam;
                Param p_extraParam;
};

class PMockSocketGenerator{
        public:
                typedef PMockSocket Socket;
                typedef DataStreamMsg Message;
                typedef PMockParam Param;
                
                PMockSocketGenerator();
                
                static Param client();
                static Param server();
                
                bool createClientSocket(Socket & socket, const PSocketParam & socketParam, const PMockParam & param);
                bool createServerSocket(Socket & socket, const PSocketParam & socketParam, const PMockParam & param);
                
                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 msgToMock(DataStreamMsg & mockMsg, const Message & msg);
                static void mockToMsg(Message & msg, DataStreamMsg & mockMsg);
};
 
bool phoenix_initializeMockSocket(PMockSocket & mock, const PSocketParam & socketParam, const std::string & prefix = "", const PMockParam & extraParam = PMockParam());
 
#include "PMockBackend_impl.h"
 
#endif