12 #ifndef ROC_PIPELINE_SENDER_SLOT_H_
13 #define ROC_PIPELINE_SENDER_SLOT_H_
Fanout. Duplicates audio stream to multiple output writers.
IArena & arena() const
Get arena.
Base class for list element.
Optionally constructed object.
Base class for object with reference counter.
Sender endpoint sub-pipeline.
Sender session sub-pipeline.
audio::IFrameWriter * writer()
Get audio writer.
void get_metrics(SenderSlotMetrics &slot_metrics, SenderSessionMetrics *sess_metrics) const
Get metrics for slot and its session.
SenderEndpoint * add_endpoint(address::Interface iface, address::Protocol proto, const address::SocketAddr &dest_address, packet::IWriter &dest_writer)
Add endpoint.
SenderSlot(const SenderConfig &config, const rtp::FormatMap &format_map, audio::Fanout &fanout, packet::PacketFactory &packet_factory, core::BufferFactory< uint8_t > &byte_buffer_factory, core::BufferFactory< audio::sample_t > &sample_buffer_factory, core::IArena &arena)
Initialize.
core::nanoseconds_t refresh(core::nanoseconds_t current_time)
Refresh pipeline according to current time.
bool is_complete() const
Check if slot configuration is complete.
int64_t nanoseconds_t
Nanoseconds.
Optionally constructed object.
Base class for object with reference counter.
Sender endpoint pipeline.
Metrics of sender session (connection to receiver).