AddEndpoint(SlotHandle slot, address::Interface iface, address::Protocol proto, const address::SocketAddr &inbound_address, packet::IWriter *outbound_writer) | roc::pipeline::ReceiverLoop::Tasks::AddEndpoint | |
func_ | roc::pipeline::ReceiverLoop::Task | protected |
get_inbound_writer() const | roc::pipeline::ReceiverLoop::Tasks::AddEndpoint | |
iface_ | roc::pipeline::ReceiverLoop::Task | protected |
inbound_address_ | roc::pipeline::ReceiverLoop::Task | protected |
inbound_writer_ | roc::pipeline::ReceiverLoop::Task | protected |
mpsc_queue_data() const | roc::core::MpscQueueNode< Tag > | inline |
mpsc_queue_node(MpscQueueData *data) | roc::core::MpscQueueNode< Tag > | inlinestatic |
NonCopyable() (defined in roc::core::NonCopyable< MpscQueueNode< void > >) | roc::core::NonCopyable< MpscQueueNode< void > > | inlineprotected |
outbound_writer_ | roc::pipeline::ReceiverLoop::Task | protected |
party_count_ | roc::pipeline::ReceiverLoop::Task | protected |
party_metrics_ | roc::pipeline::ReceiverLoop::Task | protected |
PipelineTask() (defined in roc::pipeline::PipelineTask) | roc::pipeline::PipelineTask | protected |
proto_ | roc::pipeline::ReceiverLoop::Task | protected |
slot_ | roc::pipeline::ReceiverLoop::Task | protected |
slot_config_ | roc::pipeline::ReceiverLoop::Task | protected |
slot_metrics_ | roc::pipeline::ReceiverLoop::Task | protected |
success() const | roc::pipeline::PipelineTask | |
Task() (defined in roc::pipeline::ReceiverLoop::Task) | roc::pipeline::ReceiverLoop::Task | protected |
~MpscQueueNode() (defined in roc::core::MpscQueueNode< Tag >) | roc::core::MpscQueueNode< Tag > | inline |
~PipelineTask() (defined in roc::pipeline::PipelineTask) | roc::pipeline::PipelineTask | |