PMockBackend_impl.h

Go to the documentation of this file.

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


template<typename T>
bool socket_serialize_message(PMockSocket::Message & msg, const T & data){
        size_t dataSize(data_size<T>(data));
        msg.resize(dataSize);
        DataStreamIter iter = (DataStreamIter)msg.data();
        return data_message_save<T>(iter, data);
}
 


template<typename T>
PSendStatus::PSendStatus PMockSocket::sendData(const T & data, PSendFlag::PSendFlag flag){
        if(p_mock.getIsRecord()){
                PMockSocket::Message msg;
                if(socket_serialize_message(msg, data)){
                        return sendMsg(msg, flag);
                }else{
                        return PSendStatus::CANNOT_SERIALIZE_DATA;
                }
        }else{
                T referenceData;
                PMockSocket::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 PMockSocket::recvData(T & data, PRecvFlag::PRecvFlag flag){
        PRecvStatus::PRecvStatus recvStatus = PRecvStatus::OK;
        PMockSocket::Message msg;
        if(p_mock.getIsRecord()){
                if(socket_serialize_message(msg, data)){
                        return recvMsg(msg, flag);
                }else{
                        return PRecvStatus::CANNOT_DESERIALIZE_DATA;
                }
        }
        else{
                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