Method GetAccessToken

src/common/cloud_provider_base.cpp:158–196

}

std::string CloudProviderBase::GetAccessToken() {
    std::unique_lock<std::mutex> lock(m_mtx);

    if (TokenValid()) return m_tok.access;
    if (m_tok.refresh.empty()) {
        LOG("%s GetAccessToken: no refresh token", LogTag());
        if (m_authFailureCb) m_authFailureCb(AuthFailureName());
        return {};
    }

    if (m_refreshing) {
        if (!m_refreshCv.wait_for(lock, std::chrono::seconds(30),
                                   [this] { return !m_refreshing; })) {
            LOG("%s GetAccessToken: timed out waiting for in-flight refresh", LogTag());
            return {};
        }
        if (TokenValid()) return m_tok.access;
        LOG("%s GetAccessToken: other thread refresh failed", LogTag());
        return {};
    }

    if (m_lastRefreshFailTime > 0 &&
        (int64_t)time(nullptr) - m_lastRefreshFailTime < REFRESH_BACKOFF_SECS) {
        LOG("%s GetAccessToken: in backoff period", LogTag());
        return {};
    }

    m_refreshing = true;
    lock.unlock();

    bool ok = RefreshAccessToken();

    lock.lock();
    m_refreshing = false;
    m_refreshCv.notify_all();

    if (!ok) return {};
    return m_tok.access;
}

// ── Transport delegation ───────────────────────────────────────────────────