12 #ifndef ROC_PIPELINE_RECEIVER_SLOT_H_
13 #define ROC_PIPELINE_RECEIVER_SLOT_H_
71 size_t* sess_metrics_size)
const;
Mixer. Mixes multiple input streams into one output stream.
IArena & arena() const
Get arena.
Base class for list element.
Optionally constructed object.
Base class for object with reference counter.
Receiver endpoint sub-pipeline.
ReceiverEndpoint * add_endpoint(address::Interface iface, address::Protocol proto)
Add endpoint.
ReceiverSlot(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 get_metrics(ReceiverSlotMetrics &slot_metrics, ReceiverSessionMetrics *sess_metrics, size_t *sess_metrics_size) const
Get metrics for slot and its sessions.
core::nanoseconds_t refresh(core::nanoseconds_t current_time)
Pull packets and refresh sessions according to current time.
void reclock(core::nanoseconds_t playback_time)
Adjust sessions clock to match consumer clock.
size_t num_sessions() const
Get number of alive sessions.
Receiver pipeline state. Thread-safe.
Intrusive doubly-linked list.
int64_t nanoseconds_t
Nanoseconds.
Receiver endpoint pipeline.
Base class for object with reference counter.
Metrics of receiver session (connection from sender).
Metrics of receiver slot.