serial::vita49::StreamRegistry Class Reference

#include "stream_registry.h"

Public Member Functions
std::uint32_t	registerStream (const core::ReceiverStreamDescriptor &stream)
bool	contains (std::uint32_t stream_id) const
const core::ReceiverStreamDescriptor &	descriptor (std::uint32_t stream_id) const

Detailed Description

Definition at line 17 of file stream_registry.h.

Member Function Documentation

contains()

bool serial::vita49::StreamRegistry::contains

(

std::uint32_t

stream_id

)

const

Definition at line 65 of file stream_registry.cpp.

{ return _by_stream_id.contains(stream_id); }

descriptor()

const core::ReceiverStreamDescriptor & serial::vita49::StreamRegistry::descriptor

(

std::uint32_t

stream_id

)

const

Definition at line 67 of file stream_registry.cpp.

    {
        const auto found = _descriptors.find(stream_id);
        if (found == _descriptors.end())
        {
            throw std::out_of_range("Unknown VITA stream ID");
        }
        return found->second;
    }

References max.

registerStream()

std::uint32_t serial::vita49::StreamRegistry::registerStream

(

const core::ReceiverStreamDescriptor &

stream

)

Definition at line 37 of file stream_registry.cpp.

    {
        Key key{.receiver_id = stream.receiver_id, .receiver_name = stream.receiver_name, .mode = stream.mode};
        if (const auto found = _by_key.find(key); found != _by_key.end())
        {
            return found->second;
        }
 
        std::uint32_t stream_id = initialStreamId(key);
        for (std::uint32_t attempts = 0; attempts < 0x7FFFFFFFu; ++attempts)
        {
            if (stream_id == 0)
            {
                stream_id = 1;
            }
            if (!_by_stream_id.contains(stream_id))
            {
                _by_key.emplace(key, stream_id);
                _by_stream_id.emplace(stream_id, key);
                _descriptors.emplace(stream_id, stream);
                return stream_id;
            }
            stream_id = (stream_id & 0x7FFFFFFFu) + 1u;
        }
 
        throw std::runtime_error("Unable to allocate collision-free VITA stream ID");
    }

References max, core::ReceiverStreamDescriptor::mode, core::ReceiverStreamDescriptor::receiver_id, and core::ReceiverStreamDescriptor::receiver_name.

Referenced by serial::vita49::Vita49OutputSink::registerStream().

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• packages/libfers/src/serial/vita49/stream_registry.h
• packages/libfers/src/serial/vita49/stream_registry.cpp