Backend to use Mock library with PAbtractSocket. More...

#include <PMockBackend.h>

Public Types
typedef DataStreamMsg	Message
	Define the type of message used by the PAbstractSocketManager. More...

typedef PMockParam	Param
	Define the type of extra parameters which can be used to create a Socket used by the PAbstractSocketManager. More...

typedef PMockSocket	Socket
	Define the socket of the backend used by the PAbstractSocketManager. More...

Public Member Functions
	PMockBackend ()
	Default constructor of PMockBackend. More...

Static Public Member Functions
static Param	client (const std::string &address, size_t port, bool isMockRecord, const std::string &mockDirectory)
	Create param for a client socket. More...

static void	close (Socket &socket)
	Close the given socket. More...

static bool	createClientSocket (Socket &socket, const PMockParam &param)
	Create a client socket. More...

static bool	createServerSocket (Socket &socket, const PMockParam &param)
	Create a client socket. More...

static bool	isConnected (const Socket &socket)
	Say if the given socket is connected. More...

static void	mockToMsg (Message &msg, DataStreamMsg &mockMsg)
	Copy mock message data into current backend message. More...

static const DataStreamIter	msgData (const Message &msg)
	Get the data of a message. More...

static DataStreamIter	msgData (Message &msg)
	Get the data of a message. More...

static void	msgResize (Message &msg, size_t sizeMsg)
	Resize a message. More...

static size_t	msgSize (const Message &msg)
	Get the size of a message. More...

static void	msgToMock (DataStreamMsg &mockMsg, const Message &msg)
	Copy current backend message data into mock message. More...

static bool	recv (Socket &socket, Message &msg, PRecvFlag::PRecvFlag flag)
	Recieve message from the given socket. More...

static bool	send (Socket &socket, const Message &msg, PSendFlag::PSendFlag flag)
	Send message on the given socket. More...

static Param	server (const std::string &address, size_t port, bool isMockRecord, const std::string &mockDirectory)
	Create param for a server socket. More...

Detailed Description

Backend to use Mock library with PAbtractSocket.

Definition at line 38 of file PMockBackend.h.

Member Typedef Documentation

◆ Message

typedef DataStreamMsg PMockBackend::Message

Define the type of message used by the PAbstractSocketManager.

Definition at line 43 of file PMockBackend.h.

◆ Param

typedef PMockParam PMockBackend::Param

Define the type of extra parameters which can be used to create a Socket used by the PAbstractSocketManager.

Definition at line 45 of file PMockBackend.h.

◆ Socket

typedef PMockSocket PMockBackend::Socket

Define the socket of the backend used by the PAbstractSocketManager.

Definition at line 41 of file PMockBackend.h.

Constructor & Destructor Documentation

◆ PMockBackend()

PMockBackend::PMockBackend ( )

Default constructor of PMockBackend.

Definition at line 37 of file PMockBackend.cpp.

                           {
         
 }

Member Function Documentation

◆ client()

PMockBackend::Param PMockBackend::client	(	const std::string &	address,
		size_t	port,
		bool	isMockRecord,
		const std::string &	mockDirectory
	)

static

Create param for a client socket.

Parameters

address	: address of the server to be connected to
port	: port to be used
isMockRecord	: true if the mock is in record mode
mockDirectory	: directory where to find/save mocks

Returns: corresponding parameters

Definition at line 48 of file PMockBackend.cpp.

                                                                                                                                 {
         PMockBackend::Param param;
         param.address = address;
         param.port = port;
         param.isMockRecord = isMockRecord;
         param.mockDirectory = mockDirectory;
         return param;
 }

References PMockParam::address, PMockParam::isMockRecord, PMockParam::mockDirectory, and PMockParam::port.

Referenced by server().

Here is the caller graph for this function:

◆ close()

void PMockBackend::close ( PMockBackend::Socket & socket )

static

Close the given socket.

Parameters

[out] socket : socket to be closed

Definition at line 188 of file PMockBackend.cpp.

                                                    {
         if(socket.param.isMockRecord){
                 data_save(socket.fileNameMessage, socket.vecMessage);
         }
 }

References data_save(), PMockSocket::fileNameMessage, PMockParam::isMockRecord, PMockSocket::param, and PMockSocket::vecMessage.

Here is the call graph for this function:

◆ createClientSocket()

bool PMockBackend::createClientSocket	(	PMockBackend::Socket &	socket,
		const PMockParam &	param
	)

static

Create a client socket.

Parameters

[out]	socket	: socket to be created
	param	: extra customisable parameters for the creation of the socket (depends on the backend)

Returns: true if the socket has been created, false otherwise

Definition at line 73 of file PMockBackend.cpp.

                                                                                           {
         socket.param = param;
         socket.eventIndex = 0lu;
         std::stringstream socketFileName;
         if(param.mockDirectory != ""){
                 socketFileName << param.mockDirectory << "/";
         }
         socketFileName << param.address << "_" << param.port << ".pmockbackend";
         socket.fileNameMessage = socketFileName.str();
         bool b(true);
         if(!socket.param.isMockRecord){ //If we are not in record mode, we load all the exchange
                 b &= data_load(socket.fileNameMessage, socket.vecMessage);
                 if(!b){
                         std::cerr << "PMockBackend::createClientSocket : cannot load file '"<<socket.fileNameMessage<<"'" << std::endl;
                 }
         }
         return b;
 }

References PMockParam::address, data_load(), PMockSocket::eventIndex, PMockSocket::fileNameMessage, PMockParam::isMockRecord, PMockParam::mockDirectory, PMockSocket::param, PMockParam::port, and PMockSocket::vecMessage.

Referenced by createServerSocket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ createServerSocket()

bool PMockBackend::createServerSocket	(	PMockBackend::Socket &	socket,
		const PMockParam &	param
	)

static

Create a client socket.

Parameters

[out]	socket	: socket to be created
	param	: extra customisable parameters for the creation of the socket (depends on the backend)

Returns: true if the socket has been created, false otherwise

Definition at line 97 of file PMockBackend.cpp.

                                                                                           {
         return createClientSocket(socket, param);
 }

References createClientSocket().

Here is the call graph for this function:

◆ isConnected()

bool PMockBackend::isConnected ( const Socket & socket )

static

Say if the given socket is connected.

Parameters

socket : socket to be checked

Returns: true if the socket is connected, false otherwise

Definition at line 198 of file PMockBackend.cpp.

                                                                {
         return true;
 }

◆ mockToMsg()

void PMockBackend::mockToMsg	(	PMockBackend::Message &	msg,
		DataStreamMsg &	mockMsg
	)

static

Copy mock message data into current backend message.

Parameters

[out]	msg	: message of the current backend to be converted
	mockMsg	: mock message

Definition at line 216 of file PMockBackend.cpp.

                                                                               {
         size_t dataSize(mockMsg.size());
         PMockBackend::msgResize(msg, dataSize);
         memcpy(PMockBackend::msgData(msg), mockMsg.data(), dataSize);
 }

References msgData(), and msgResize().

Here is the call graph for this function:

◆ msgData() [1/2]

const DataStreamIter PMockBackend::msgData ( const Message & msg )

static

Get the data of a message.

Parameters

msg	: message to be used

Returns: data of the message in bytes

Definition at line 173 of file PMockBackend.cpp.

                                                                          {
         return (const DataStreamIter)msg.data();
 }

Referenced by mockToMsg(), and msgToMock().

Here is the caller graph for this function:

◆ msgData() [2/2]

DataStreamIter PMockBackend::msgData ( PMockBackend::Message & msg )

static

Get the data of a message.

Parameters

msg	: message to be used

Returns: data of the message in bytes

Definition at line 181 of file PMockBackend.cpp.

                                                              {
         return msg.data();
 }

◆ msgResize()

void PMockBackend::msgResize	(	PMockBackend::Message &	msg,
		size_t	sizeMsg
	)

static

Resize a message.

Parameters

[out]	msg	: message to be resized
	sizeMsg	: new size of the message

Definition at line 157 of file PMockBackend.cpp.

                                                                      {
         msg.resize(sizeMsg);
 }

Referenced by mockToMsg().

Here is the caller graph for this function:

◆ msgSize()

size_t PMockBackend::msgSize ( const Message & msg )

static

Get the size of a message.

Parameters

msg	: message to be used

Returns: size of the message in bytes

Definition at line 165 of file PMockBackend.cpp.

                                                            {
         return msg.size();
 }

Referenced by msgToMock().

Here is the caller graph for this function:

◆ msgToMock()

void PMockBackend::msgToMock	(	DataStreamMsg &	mockMsg,
		const Message &	msg
	)

static

Copy current backend message data into mock message.

Parameters

[out]	mockMsg	: mock message
	msg	: message of the current backend to be converted

Definition at line 206 of file PMockBackend.cpp.

                                                                                     {
         size_t dataSize(PMockBackend::msgSize(msg));
         mockMsg.resize(dataSize);
         memcpy(mockMsg.data(), PMockBackend::msgData(msg), dataSize);
 }

References msgData(), and msgSize().

Here is the call graph for this function:

◆ recv()

bool PMockBackend::recv	(	PMockBackend::Socket &	socket,
		PMockBackend::Message &	msg,
		PRecvFlag::PRecvFlag	flag
	)

static

Recieve message from the given socket.

Parameters

socket	: socket to be used
msg	: message to be recieved
flag	: flag to be used to send the message (BLOCK, NON_BLOCK, etc)

Returns: true on success, false otherwise

Definition at line 135 of file PMockBackend.cpp.

                                                                                                       {
         if(socket.param.isMockRecord){  //If we record all events
                 socket.vecMessage.push_back(msg);
         }else{
                 if(socket.vecMessage.size() == 0lu){
                         std::cerr << "PMockBackend::recv : empty vector of message" << std::endl;
                         return false;
                 }
                 //Let's pick the current message
                 if(socket.eventIndex >= socket.vecMessage.size()){
                         socket.eventIndex = 0lu;        //Let's loop if all the events were used
                 }
                 msg = socket.vecMessage[socket.eventIndex];
         }
         ++socket.eventIndex;
         return true;
 }

References PMockSocket::eventIndex, PMockParam::isMockRecord, PMockSocket::param, and PMockSocket::vecMessage.

◆ send()

bool PMockBackend::send	(	PMockBackend::Socket &	socket,
		const Message &	msg,
		PSendFlag::PSendFlag	flag
	)

static

Send message on the given socket.

Parameters

socket	: socket to be used
msg	: message to be sent
flag	: flag to be used to send the message (BLOCK, NON_BLOCK, etc)

Returns: true on success, false otherwise

Definition at line 107 of file PMockBackend.cpp.

                                                                                                             {
         bool b(true);
         if(socket.param.isMockRecord){  //If we record all events
                 socket.vecMessage.push_back(msg);
         }else{
                 if(socket.vecMessage.size() == 0lu){
                         std::cerr << "PMockBackend::send : empty vector of message" << std::endl;
                         return false;
                 }
                 //Let's pick the current message
                 if(socket.eventIndex >= socket.vecMessage.size()){
                         socket.eventIndex = 0lu;        //Let's loop if all the events were used
                 }
                 //Let's check if the current message matches the message we are supposed to send
                 std::stringstream strEvent;
                 strEvent << socket.eventIndex;
                 b &= checkValue("PMockBackend::send : event " + strEvent.str(), msg, socket.vecMessage[socket.eventIndex]);
         }
         ++socket.eventIndex;
         return b;
 }

References checkValue(), PMockSocket::eventIndex, PMockParam::isMockRecord, PMockSocket::param, and PMockSocket::vecMessage.

Here is the call graph for this function:

◆ server()

PMockBackend::Param PMockBackend::server	(	const std::string &	address,
		size_t	port,
		bool	isMockRecord,
		const std::string &	mockDirectory
	)

static

Create param for a server socket.

Parameters

address	: address of the server to be connected to
port	: port to be used
isMockRecord	: true if the mock is in record mode
mockDirectory	: directory where to find/save mocks

Returns: corresponding parameters

Definition at line 64 of file PMockBackend.cpp.

                                                                                                                                 {
         return PMockBackend::client(address, port, isMockRecord, mockDirectory);
 }

References client().

Here is the call graph for this function:

The documentation for this class was generated from the following files:

/builds/CTA-LAPP/PHOENIX_LIBS2/PhoenixZMQ/tmp_project/PhoenixSocket/src/PMockBackend.h
/builds/CTA-LAPP/PHOENIX_LIBS2/PhoenixZMQ/tmp_project/PhoenixSocket/src/PMockBackend.cpp

Public Types

Public Member Functions

Static Public Member Functions

Detailed Description

Member Typedef Documentation

◆ Message

◆ Param

◆ Socket

Constructor & Destructor Documentation

◆ PMockBackend()

Member Function Documentation

◆ client()

◆ close()

◆ createClientSocket()

◆ createServerSocket()

◆ isConnected()

◆ mockToMsg()

◆ msgData() [1/2]

◆ msgData() [2/2]

◆ msgResize()

◆ msgSize()

◆ msgToMock()

◆ recv()

◆ send()

◆ server()