Example of a mock socket with vector of messages. More...

#include <PMockBackendFile.h>

Collaboration diagram for PMockSocketFile:

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

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

Public Member Functions
void	close ()
	Close the PMockSocketFile.

bool	createClientSocket (const PSocketParam &socketParam, const Param &extraParam)
	Initialise a client socket.

bool	createServerSocket (const PSocketParam &socketParam, const Param &extraParam)
	Initialise a server socket.

bool	isConnected () const
	Say if the PMockSocketFile is connected.

	PMockSocketFile ()
	Default constructor of hte PMockSocketFile.

template<typename T>
PRecvStatus::PRecvStatus	recvData (T &data, PRecvFlag::PRecvFlag flag)
	Recieved data with the socket.

PRecvStatus::PRecvStatus	recvMsg (Message &msg, PRecvFlag::PRecvFlag flag)
	Recieved data with the socket.

template<typename T>
PSendStatus::PSendStatus	sendData (const T &data, PSendFlag::PSendFlag flag)
	Send data with the socket.

PSendStatus::PSendStatus	sendMsg (const Message &msg, PSendFlag::PSendFlag flag)
	Specialisation to send a Message with the socket.

void	setIsMockRecord (bool isMockRecord)
	Set the mock prefix (where to find/save it)

void	setMockPrefix (const std::string &mockPrefix)
	Set the mock prefix (where to find/save it)

virtual	~PMockSocketFile ()
	Default destructor of hte PMockSocketFile.

Private Attributes
Param	p_extraParam
	Extra parameters of the socket.

PGenericFileMock< DataStreamMsg >	p_mock
	Mock handler.

PSocketParam	p_socketParam
	Parameters of the socket.

Detailed Description

Example of a mock socket with vector of messages.

Definition at line 17 of file PMockBackendFile.h.

Member Typedef Documentation

◆ Message

typedef DataStreamMsg PMockSocketFile::Message

Define the type of message used by the PAbstractSocketManager.

Definition at line 20 of file PMockBackendFile.h.

◆ Param

typedef PMockParamFile PMockSocketFile::Param

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

Definition at line 22 of file PMockBackendFile.h.

Constructor & Destructor Documentation

◆ PMockSocketFile()

PMockSocketFile::PMockSocketFile ( )

Default constructor of hte PMockSocketFile.

Definition at line 27 of file PMockBackendFile.cpp.

                                {
        
}

◆ ~PMockSocketFile()

PMockSocketFile::~PMockSocketFile ( )

virtual

Default destructor of hte PMockSocketFile.

Definition at line 32 of file PMockBackendFile.cpp.

                                 {
        
}

Member Function Documentation

◆ close()

void PMockSocketFile::close ( )

Close the PMockSocketFile.

Definition at line 111 of file PMockBackendFile.cpp.

                           {
        p_mock.close();
}

References p_mock.

◆ createClientSocket()

bool PMockSocketFile::createClientSocket	(	const PSocketParam &	socketParam,
		const Param &	extraParam )

Initialise a client socket.

Parameters

socketParam	: parameters to be use to initialise the socket (hostname, port, etc)
extraParam	: extra customisable parameters for the creation of the socket (depends on the backend)

Definition at line 40 of file PMockBackendFile.cpp.

                                                                                                                 {
        p_socketParam = socketParam;
        p_extraParam = extraParam;
        return true;
}

References p_extraParam, and p_socketParam.

Referenced by PMockBackendFile::createClientSocket(), createServerSocket(), and phoenix_createMockBackend().

Here is the caller graph for this function:

◆ createServerSocket()

bool PMockSocketFile::createServerSocket	(	const PSocketParam &	socketParam,
		const Param &	extraParam )

Initialise a server socket.

Parameters

socketParam	: parameters to be use to initialise the socket (hostname, port, etc)
extraParam	: extra customisable parameters for the creation of the socket (depends on the backend)

Definition at line 50 of file PMockBackendFile.cpp.

                                                                                                                 {
        return createClientSocket(socketParam, extraParam);
}

References createClientSocket().

Here is the call graph for this function:

◆ isConnected()

bool PMockSocketFile::isConnected ( ) const

Say if the PMockSocketFile is connected.

Returns: true if the PMockSocketFile is connected, false otherwise

Definition at line 106 of file PMockBackendFile.cpp.

                                       {
        return true;
}

◆ recvData()

template<typename T>

PRecvStatus::PRecvStatus PMockSocketFile::recvData	(	T &	data,
		PRecvFlag::PRecvFlag	flag )

Recieved data with the socket.

Parameters

[out]	data	: data to be recieved with the socket
	flag	: recieving flag (BLOCK, NON_BLOCK)

Returns: status of the recv

Definition at line 52 of file PMockBackendFile_impl.h.

                                                                                 {
        PRecvStatus::PRecvStatus recvStatus = PRecvStatus::OK;
        PMockSocketFile::Message msg;
        recvStatus = recvMsg(msg, flag);
        //If the message is empty we cannot initialise the given data, so, this is an error
        if(msg.size() != 0lu){
                DataStreamIter iter = (DataStreamIter)msg.data();
                if(!data_message_load<T>(iter, data)){
                        recvStatus = PRecvStatus::CANNOT_DESERIALIZE_DATA;
                }
        }else{
                recvStatus = PRecvStatus::NO_MESSAGE_RECEIVED;
        }
        return recvStatus;
}

References PRecvStatus::CANNOT_DESERIALIZE_DATA, PRecvStatus::NO_MESSAGE_RECEIVED, PRecvStatus::OK, and recvMsg().

Here is the call graph for this function:

◆ recvMsg()

PRecvStatus::PRecvStatus PMockSocketFile::recvMsg	(	PMockSocketFile::Message &	msg,
		PRecvFlag::PRecvFlag	flag )

Recieved data with the socket.

Parameters

[out]	msg	: Message to be recieved with the socket
	flag	: recieving flag (BLOCK, NON_BLOCK)

Returns: status of the recv

Definition at line 89 of file PMockBackendFile.cpp.

                                                                                                    {
        if(p_mock.getIsRecord()){
                p_mock.append(msg);
                return PRecvStatus::OK;
        }else{
                p_mock.getCurrentValue(msg);
                if(msg.size() == 0lu){  //If the message is empty, it is not received
                        return PRecvStatus::NO_MESSAGE_RECEIVED;
                }else{
                        return PRecvStatus::OK;
                }
        }
}

References PRecvStatus::NO_MESSAGE_RECEIVED, PRecvStatus::OK, and p_mock.

Referenced by recvData().

Here is the caller graph for this function:

◆ sendData()

template<typename T>

PSendStatus::PSendStatus PMockSocketFile::sendData	(	const T &	data,
		PSendFlag::PSendFlag	flag )

Send data with the socket.

Parameters

data	: data to be sent with the socket
flag	: sending flag (BLOCK, NON_BLOCK)

Returns: status of the send

Definition at line 18 of file PMockBackendFile_impl.h.

                                                                                       {
        if(p_mock.getIsRecord()){
                size_t dataSize(data_size<T>(data));
                PSendStatus::PSendStatus sendStatus = PSendStatus::OK;
                PMockSocketFile::Message msg;
                msg.resize(dataSize);
                DataStreamIter iter = (DataStreamIter)msg.data();
                if(data_message_save<T>(iter, data)){                   //Save the message
                        sendStatus = sendMsg(msg, flag);
                }else{
                        sendStatus = PSendStatus::CANNOT_SERIALIZE_DATA;
                }
                return sendStatus;
        }else{
                T referenceData;
                PMockSocketFile::Message referenceMsg;
                p_mock.getCurrentValue(referenceMsg);     //Let's get the reference message
                if(referenceMsg.size() != 0lu){
                        DataStreamIter iter = (DataStreamIter)referenceMsg.data();
                        check_stream_assert(data_message_load<T>(iter, referenceData));
                        std::stringstream index;
                        index << p_mock.getCurrentIndex();
                        check_stream_assert(phoenix_check_stream("mock '"+p_mock.getFileName()+"', [mock index = "+index.str()+"]", data, referenceData));
                }
                return PSendStatus::OK;
        }
}

References PSendStatus::CANNOT_SERIALIZE_DATA, PSendStatus::OK, p_mock, and sendMsg().

Here is the call graph for this function:

◆ sendMsg()

PSendStatus::PSendStatus PMockSocketFile::sendMsg	(	const Message &	msg,
		PSendFlag::PSendFlag	flag )

Specialisation to send a Message with the socket.

Parameters

msg	: Message to be sent
flag	: sending flag (BLOCK, NON_BLOCK)

Returns: status of the send

Definition at line 75 of file PMockBackendFile.cpp.

                                                                                                          {
        if(p_mock.getIsRecord()){
                p_mock.append(msg);
        }else{
                check_stream_assert(p_mock.checkCurrentValue("PMockSocketFile::sendMsg", msg));
        }
        return PSendStatus::OK;
}

References PSendStatus::OK, and p_mock.

Referenced by sendData().

Here is the caller graph for this function:

◆ setIsMockRecord()

void PMockSocketFile::setIsMockRecord ( bool isMockRecord )

Set the mock prefix (where to find/save it)

Parameters

isMockRecord : true if the mock has to be recorded

Definition at line 66 of file PMockBackendFile.cpp.

                                                      {
        p_mock.setIsRecord(isMockRecord);
}

References p_mock.

Referenced by phoenix_createMockBackend().

Here is the caller graph for this function:

◆ setMockPrefix()

void PMockSocketFile::setMockPrefix ( const std::string & mockPrefix )

Set the mock prefix (where to find/save it)

Parameters

mockPrefix : prefix of the mock to find or write it

Definition at line 57 of file PMockBackendFile.cpp.

                                                               {
        std::stringstream socketFileName;
        socketFileName << mockPrefix << p_socketParam.hostname << "_" << p_socketParam.port << ".pmockbackend";
        p_mock.setFileName(socketFileName.str());
}

References p_mock, and p_socketParam.

Referenced by phoenix_createMockBackend().

Here is the caller graph for this function:

Member Data Documentation

◆ p_extraParam

Param PMockSocketFile::p_extraParam

private

Extra parameters of the socket.

Definition at line 49 of file PMockBackendFile.h.

Referenced by createClientSocket().

◆ p_mock

PGenericFileMock<DataStreamMsg> PMockSocketFile::p_mock

private

Mock handler.

Definition at line 45 of file PMockBackendFile.h.

Referenced by close(), recvMsg(), sendData(), sendMsg(), setIsMockRecord(), and setMockPrefix().

◆ p_socketParam

PSocketParam PMockSocketFile::p_socketParam

private

Parameters of the socket.

Definition at line 47 of file PMockBackendFile.h.

Referenced by createClientSocket(), and setMockPrefix().

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

/builds/CTA-LAPP/PHOENIX_LIBS2/network/PhoenixSocket/src/PMockBackendFile.h
/builds/CTA-LAPP/PHOENIX_LIBS2/network/PhoenixSocket/src/PMockBackendFile.cpp
/builds/CTA-LAPP/PHOENIX_LIBS2/network/PhoenixSocket/src/PMockBackendFile_impl.h

Public Types

Public Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ Message

◆ Param

Constructor & Destructor Documentation

◆ PMockSocketFile()

◆ ~PMockSocketFile()

Member Function Documentation

◆ close()

◆ createClientSocket()

◆ createServerSocket()

◆ isConnected()

◆ recvData()

◆ recvMsg()

◆ sendData()

◆ sendMsg()

◆ setIsMockRecord()

◆ setMockPrefix()

Member Data Documentation

◆ p_extraParam

◆ p_mock

◆ p_socketParam