PEmptyBackend_impl.h

Go to the documentation of this file.

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


template<typename T>
PSendStatus::PSendStatus PEmptySocket::sendData(const T & data, PSendFlag::PSendFlag flag){
        size_t dataSize(data_size<T>(data));
        PSendStatus::PSendStatus sendStatus = PSendStatus::OK;
        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;
}


template<typename T>
PRecvStatus::PRecvStatus PEmptySocket::recvData(T & data, PRecvFlag::PRecvFlag flag){
        PRecvStatus::PRecvStatus recvStatus = PRecvStatus::OK;
        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