12 #ifndef ROC_NODE_SENDER_ENCODER_H_
13 #define ROC_NODE_SENDER_ENCODER_H_
#define ROC_ATTR_NODISCARD
Emit warning if function result is not checked.
Atomic integer. Provides sequential consistency. For a fine-grained memory order control,...
Optionally constructed object.
Process pending pipeline tasks on control thread.
Context & context()
All nodes hold reference to context.
bool activate(address::Interface iface, address::Protocol proto)
Activate interface.
sndio::ISink & sink()
Sink for writing frames for encoding.
bool is_valid() const
Check if successfully constructed.
bool get_metrics(pipeline::SenderSlotMetrics &slot_metrics, pipeline::SenderSessionMetrics &sess_metrics)
Get metrics.
bool is_complete()
Check if everything is connected.
SenderEncoder(Context &context, const pipeline::SenderConfig &pipeline_config)
Initialize.
~SenderEncoder()
Deinitialize.
ROC_ATTR_NODISCARD status::StatusCode read(address::Interface iface, packet::PacketPtr &packet)
Read encoded packet.
Pipeline task scheduler interface. PipelineLoop uses this interface to schedule asynchronous work....
Base class for task-based pipelines.
struct SlotHandle * SlotHandle
Opaque slot handle.
Concurrent blocking packet queue.
Pipeline task scheduler interface.
@ Iface_Max
Number of interfaces.
int64_t nanoseconds_t
Nanoseconds.
Optionally constructed object.
Metrics of sender session (connection to receiver).