MayaFlux 0.4.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ on_backend_receive()

void MayaFlux::Core::NetworkSubsystem::on_backend_receive ( uint64_t  endpoint_id,
const uint8_t *  data,
size_t  size,
std::string_view  sender_addr 
)
private

Wired as the receive callback on each backend.

Routes to per-endpoint callbacks in m_endpoint_callbacks.

Definition at line 445 of file NetworkSubsystem.cpp.

447{
448 std::shared_lock lock(m_callbacks_mutex);
449 auto it = m_endpoint_callbacks.find(endpoint_id);
450 if (it != m_endpoint_callbacks.end() && it->second) {
451 it->second(endpoint_id, data, size, sender_addr);
452 }
453}
Range size
std::unordered_map< uint64_t, NetworkReceiveCallback > m_endpoint_callbacks
std::shared_mutex m_callbacks_mutex
Per-endpoint receive callbacks set by consumers via set_endpoint_receive_callback().

References size.