MayaFlux 0.5.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 426 of file NetworkSubsystem.cpp.

428{
429 std::shared_lock lock(m_callbacks_mutex);
430 auto it = m_endpoint_callbacks.find(endpoint_id);
431 if (it != m_endpoint_callbacks.end() && it->second) {
432 it->second(endpoint_id, data, size, sender_addr);
433 }
434}
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().