signal()

void MayaFlux::Vruta::NetworkSource::signal

(

const Core::NetworkMessage &

message

)

Signal that a message arrived (called from Asio IO thread)

Parameters

message

The received message.

Lock-free. Pushes into ring buffer, atomically detaches the full waiter list, and calls try_resume() on every registered awaiter. Safe to call from any thread.

Definition at line 57 of file NetworkSource.cpp.

{
    auto* w = m_waiters_head.exchange(nullptr, std::memory_order_acq_rel);
 
    if (w) {
        while (w) {
            auto* next = w->m_next.load(std::memory_order_relaxed);
            w->deliver(message);
            w = next;
        }
    } else {
        (void)m_queue.push(message);
    }
}

References m_queue, and m_waiters_head.

Referenced by NetworkSource().

Here is the caller graph for this function: