Roc Toolkit internal modules
Roc Toolkit: real-time audio streaming
|
Receiver session group. More...
#include <receiver_session_group.h>
Public Member Functions | |
ReceiverSessionGroup (const ReceiverConfig &receiver_config, ReceiverState &receiver_state, audio::Mixer &mixer, const rtp::FormatMap &format_map, packet::PacketFactory &packet_factory, core::BufferFactory< uint8_t > &byte_buffer_factory, core::BufferFactory< audio::sample_t > &sample_buffer_factory, core::IArena &arena) | |
Initialize. More... | |
ROC_ATTR_NODISCARD status::StatusCode | route_packet (const packet::PacketPtr &packet) |
Route packet to session. More... | |
core::nanoseconds_t | refresh_sessions (core::nanoseconds_t current_time) |
Refresh pipeline according to current time. More... | |
void | reclock_sessions (core::nanoseconds_t playback_time) |
Adjust session clock to match consumer clock. More... | |
size_t | num_sessions () const |
Get number of alive sessions. More... | |
void | get_metrics (ReceiverSessionMetrics *metrics, size_t *metrics_size) const |
Get metrics for all sessions. More... | |
Receiver session group.
Contains:
Definition at line 33 of file receiver_session_group.h.
roc::pipeline::ReceiverSessionGroup::ReceiverSessionGroup | ( | const ReceiverConfig & | receiver_config, |
ReceiverState & | receiver_state, | ||
audio::Mixer & | mixer, | ||
const rtp::FormatMap & | format_map, | ||
packet::PacketFactory & | packet_factory, | ||
core::BufferFactory< uint8_t > & | byte_buffer_factory, | ||
core::BufferFactory< audio::sample_t > & | sample_buffer_factory, | ||
core::IArena & | arena | ||
) |
Initialize.
void roc::pipeline::ReceiverSessionGroup::get_metrics | ( | ReceiverSessionMetrics * | metrics, |
size_t * | metrics_size | ||
) | const |
Get metrics for all sessions.
metrics
defines array of metrics structs, and metrics_size
defines number of array elements. Metrics are written to given array, and metrics_size
is updated of actual number of elements written. If there is not enough space for all sessions, result is truncated. size_t roc::pipeline::ReceiverSessionGroup::num_sessions | ( | ) | const |
Get number of alive sessions.
void roc::pipeline::ReceiverSessionGroup::reclock_sessions | ( | core::nanoseconds_t | playback_time | ) |
Adjust session clock to match consumer clock.
playback_time
specified absolute time when first sample of last frame retrieved from pipeline will be actually played on sink core::nanoseconds_t roc::pipeline::ReceiverSessionGroup::refresh_sessions | ( | core::nanoseconds_t | current_time | ) |
Refresh pipeline according to current time.
ROC_ATTR_NODISCARD status::StatusCode roc::pipeline::ReceiverSessionGroup::route_packet | ( | const packet::PacketPtr & | packet | ) |
Route packet to session.