12#ifndef ROC_PIPELINE_RECEIVER_ENDPOINT_H_
13#define ROC_PIPELINE_RECEIVER_ENDPOINT_H_
Memory allocator interface.
Base class for list element.
Thread-safe lock-free node-based intrusive multi-producer single-consumer queue.
Optionally constructed object.
Base class for reference counted object.
IAllocator & allocator() const
Get allocator.
Receiver endpoint sub-pipeline.
bool valid() const
Check if the port pipeline was succefully constructed.
packet::IWriter & writer()
Get endpoint writer.
void pull_packets()
Pull packets writter to endpoint writer.
address::Protocol proto() const
Get protocol.
ReceiverEndpoint(address::Protocol proto, ReceiverState &receiver_state, ReceiverSessionGroup &session_group, const rtp::FormatMap &format_map, core::IAllocator &allocator)
Initialize.
Receiver pipeline state. Thread-safe.
Memory allocator interface.
Multi-producer single-consumer queue.
Optionally constructed object.
Base class for reference counted object.