Method threadWorkerLoop

src/core/net/NetworkManagerImpl.cpp:553–689

}

Future<> NetworkManagerImpl::threadWorkerLoop() {
    using enum qn::ConnectionState;

    // might happen when exiting, just wait and return (to not busy loop)
    if (!m_centralConn) {
        co_await arc::sleep(Duration::fromMillis(100));
        co_return;
    }

    // Worker task has the following duties:
    // - Watch the connection state
    // - When connected, periodically ping game servers and decide to resend own data
    auto connState = m_centralConn->state();
    auto prevState = m_workerState.prevCentralState;
    m_workerState.prevCentralState = connState;

    // reset connection info on disconnect, and create it when needed
    if (connState == Disconnected) {
        m_connInfo.lock()->reset();
    } else if (connState == Connected && connState != prevState) {
        auto info = m_connInfo.lock();
        if (!*info) info->emplace();

        auto& i = **info;
        i.m_centralUrl = m_connectingCentralUrl;
        i.m_icons = m_connectingIcons;
    }

    switch (connState) {
        case Connected: {
            // if we weren't connected before, do some initial setup
            if (prevState != qn::ConnectionState::Connected) {
                m_workerState.nextGSPing = Instant::now();
                m_workerState.pingResultRx.drain();
                globed::setValue<bool>("core.was-connected", true);

                co_await this->threadSetupLogger(true);
            }

            {
                auto info = this->connInfo();

                // if we aren't authenticated yet, try to do auth
                if (!info->m_established && !info->m_authenticating) {
                    info.unlock();
                    co_await this->threadTryAuth();
                    co_return;
                }

                // check if icons or friend list need to be resent
                this->threadMaybeResendOwnData(info);

                // reset the timer to ping game servers if the server list was updated
                if (info->m_gameServersUpdated) {
                    log::debug("Pinging servers again soon");
                    info->m_gameServersUpdated = false;
                    m_workerState.nextGSPing = Instant::now();
                }