unregister_waiter()

void MayaFlux::Vruta::NetworkSource::unregister_waiter ( Kriya::NetworkAwaiter *  awaiter )

private

Definition at line 106 of file NetworkSource.cpp.

{
    auto* expected = awaiter;
    if (m_waiters_head.compare_exchange_strong(expected,
            awaiter->m_next.load(std::memory_order_relaxed),
            std::memory_order_acq_rel)) {
        return;
    }
 
    auto* cur = m_waiters_head.load(std::memory_order_acquire);
    while (cur) {
        auto* next = cur->m_next.load(std::memory_order_relaxed);
        if (next == awaiter) {
            cur->m_next.compare_exchange_strong(next,
                awaiter->m_next.load(std::memory_order_relaxed),
                std::memory_order_acq_rel);
            return;
        }
        cur = next;
    }
}

References MayaFlux::Kriya::NetworkAwaiter::m_next, and m_waiters_head.

Referenced by MayaFlux::Kriya::NetworkAwaiter::await_suspend(), and MayaFlux::Kriya::NetworkAwaiter::~NetworkAwaiter().

Here is the caller graph for this function: