PZmqBackend_impl.h

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#ifndef __PZMQ_BACKEND_IMPL_H__
#define __PZMQ_BACKEND_IMPL_H__
 
#include <string>
#include "phoenix_data_stream.h"
#include "PZmqBackend.h"


template <typename T>
std::string statusToStr(T status) {
    if constexpr (std::is_same_v<T, PSendStatus::PSendStatus>) {
        switch (status) {
            case PSendStatus::OK: return "OK";
            case PSendStatus::SOCKET_NOT_AVAILABLE: return "SOCKET_NOT_AVAILABLE";
            case PSendStatus::NO_ROUTE_TO_RECEIVER: return "NO_ROUTE_TO_RECEIVER";
            case PSendStatus::SIGNAL_INTERRUPTION: return "SIGNAL_INTERRUPTION";
            case PSendStatus::BROKEN_BACKEND: return "BROKEN_BACKEND";
            case PSendStatus::BROKEN_SOCKET: return "BROKEN_SOCKET";
            case PSendStatus::CANNOT_SERIALIZE_DATA: return "CANNOT_SERIALIZE_DATA";
            default: return "UNKNOWN_SEND_STATUS";
        }
    } else if constexpr (std::is_same_v<T, PRecvStatus::PRecvStatus>) {
        switch (status) {
            case PRecvStatus::OK: return "OK";
            case PRecvStatus::SOCKET_NOT_AVAILABLE: return "SOCKET_NOT_AVAILABLE";
            case PRecvStatus::SIGNAL_INTERRUPTION: return "SIGNAL_INTERRUPTION";
            case PRecvStatus::BROKEN_BACKEND: return "BROKEN_BACKEND";
            case PRecvStatus::BROKEN_SOCKET: return "BROKEN_SOCKET";
            case PRecvStatus::NO_MESSAGE_RECEIVED: return "NO_MESSAGE_RECEIVED";
            case PRecvStatus::CANNOT_DESERIALIZE_DATA: return "CANNOT_DESERIALIZE_DATA";
            default: return "UNKNOWN_RECV_STATUS";
        }
    } else {
        return "UNKNOWN_STATUS_TYPE";
    }
}


template<typename T>
PSendStatus::PSendStatus PZmqSocket::sendData(const T & data, PSendFlag::PSendFlag flag){
    size_t dataSize(data_size<T>(data));
        Message msg;
        msg.rebuild(dataSize);
        DataStreamIter iter = (DataStreamIter)msg.data();
        if(data_message_save<T>(iter, data)){                   //Save the message
                return sendMsg(msg, flag);
        }else{
                return PSendStatus::CANNOT_SERIALIZE_DATA;
        }
}


template<typename T>
PRecvStatus::PRecvStatus PZmqSocket::recvData(T & data, PRecvFlag::PRecvFlag flag){
        PRecvStatus::PRecvStatus recvStatus = PRecvStatus::OK;
        Message msg;
        recvStatus = recvMsg(msg, flag);
    if(recvStatus == PRecvStatus::OK){
        //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)){
                return PRecvStatus::CANNOT_DESERIALIZE_DATA;
            }
        }else{
            return PRecvStatus::NO_MESSAGE_RECEIVED;
        }
    }
        
    return recvStatus;
}
 
 
#endif