SysDirectedStreamsMessage.hh

Go to the documentation of this file.

 
#ifndef LibMultiSense_SysDirectedStreamsMessage
#define LibMultiSense_SysDirectedStreamsMessage
 
#include "utility/Portability.hh"
 
namespace crl {
namespace multisense {
namespace details {
namespace wire {
 
class DirectedStream {
public:
    static CRL_CONSTEXPR VersionType VERSION = 1;
 
    uint32_t    mask;
    std::string address;
    uint16_t    udpPort;
    uint32_t    fpsDecimation;
 
    DirectedStream() {};
    DirectedStream(uint32_t           m,
                   const std::string& addr,
                   uint16_t           p,
                   uint32_t           dec) :
        mask(m),
        address(addr),
        udpPort(p),
        fpsDecimation(dec) {};
 
    template<class Archive>
        void serialize(Archive&          message,
                       const VersionType version)
    {
        (void) version;
        VersionType thisVersion = VERSION;
 
        message & thisVersion;
        message & mask;
        message & address;
        message & udpPort;
        message & fpsDecimation;
    }
};
 
class SysDirectedStreams {
public:
    static CRL_CONSTEXPR IdType      ID        = ID_DATA_SYS_DIRECTED_STREAMS;
    static CRL_CONSTEXPR VersionType VERSION   = 1;
 
    static CRL_CONSTEXPR uint32_t    CMD_NONE  = 0;
    static CRL_CONSTEXPR uint32_t    CMD_START = 1;
    static CRL_CONSTEXPR uint32_t    CMD_STOP  = 2;
 
    uint32_t                          command;
    std::vector<wire::DirectedStream> streams;
 
    //
    // Constructors
 
    SysDirectedStreams(utility::BufferStreamReader&r, VersionType v) {serialize(r,v);};
    SysDirectedStreams(uint32_t cmd) : command(cmd) {};
    SysDirectedStreams() : command(CMD_NONE) {};
 
    //
    // Serialization routine
 
    template<class Archive>
        void serialize(Archive&          message,
                       const VersionType version)
    {
        message & command;
        uint32_t elements = static_cast<uint32_t> (streams.size());
        message & elements;
        streams.resize(elements);
        for(uint32_t i=0; i<elements; i++)
            streams[i].serialize(message, version);
    }
};
 
}}}} // namespaces
 
#endif