dofs/docs/hosts/subscriber.md

hosts/subscriber.h

Subscriber::Subscriber

Subscriber(Simulator *sim, NodeId id, Publisher *publisher, std::unique_ptr<SubBasePolicy> policy, Time mgmt_latency, Time heartbeat_period) noexcept

Subscriber::recv_flow

void recv_flow(NodeId src, FlowId flow, FlowPriority prio, Bytes flow_size) override

Subscriber::recv_frame

void recv_frame(const Packet &frame) override

Subscriber::recv_mgmt_msg

virtual void recv_mgmt_msg(MgmtMsgPtr msg) noexcept override

Subscriber::set_publisher

void set_publisher(Publisher *p) noexcept

Subscriber::set_status

void set_status(NodeStatus s) noexcept

dofs::on_heartbeat_timer

void on_heartbeat_timer() noexcept;

dofs::schedule_next_heartbeat

void schedule_next_heartbeat(Time delay) noexcept;

dofs::send_job_finished

void send_job_finished(FlowId flow) noexcept;