SysDirectedStreamsMessage.h

Go to the documentation of this file.

#ifndef LibMultiSense_SysDirectedStreamsMessage
#define LibMultiSense_SysDirectedStreamsMessage

#include "details/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