PMockBackendFile_impl.h

Go to the documentation of this file.

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


template<typename T>
PSendStatus::PSendStatus PMockSocketFile::sendData(const T & data, PSendFlag::PSendFlag flag){
        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;
        }
}


template<typename T>
PRecvStatus::PRecvStatus PMockSocketFile::recvData(T & data, PRecvFlag::PRecvFlag flag){
        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;
}
 
#endif