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 451 of file NetworkSubsystem.cpp.

453{
454 std::shared_lock lock(m_callbacks_mutex);
455 auto it = m_endpoint_callbacks.find(endpoint_id);
456 if (it != m_endpoint_callbacks.end() && it->second) {
457 it->second(endpoint_id, data, size, sender_addr);
458 }
459}
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().