Method ApiRequest

src/common/cloud_provider_base.cpp:231–270

}

HttpResp CloudProviderBase::ApiRequest(const char* method, const std::string& path,
                                        const std::string& body,
                                        const std::string& contentType) {
    // Exponential backoff with jitter: base 1s, factor 2x, up to 5 attempts.
    // Retries on rate-limit (429 / 403+rateLimitExceeded) AND timeout (HTTP 0).
    static constexpr int kMaxAttempts = 5;
    static thread_local std::mt19937 rng{std::random_device{}()};

    HttpResp lastResp;
    for (int attempt = 0; attempt < kMaxAttempts; ++attempt) {
        if (attempt > 0) {
            int baseMs = 1000 * (1 << (attempt - 1)); // 1s, 2s, 4s, 8s
            int jitter = std::uniform_int_distribution<int>(0, baseMs / 2)(rng);
            int delayMs = baseMs + jitter;
            LOG("%s Backoff %s %s: attempt %d, waiting %dms",
                LogTag(), method, path.c_str(), attempt + 1, delayMs);
            std::this_thread::sleep_for(std::chrono::milliseconds(delayMs));
        }
        auto token = GetAccessToken();
        if (token.empty()) {
            LOG("%s ApiRequest: no access token for %s %s", LogTag(), method, path.c_str());
            return {};
        }
        ThrottleApiCall();
        std::vector<std::string> hdrs = {"Authorization: Bearer " + token};
        if (!contentType.empty())
            hdrs.push_back("Content-Type: " + contentType);
        lastResp = Request(method, ApiHost(), path, body, hdrs);
        bool rateLimited = IsRateLimited(lastResp.status, lastResp.body);
        bool timedOut = (lastResp.status == 0);
        if (!rateLimited && !timedOut) return lastResp;
        if (rateLimited)
            g_rateLimitHits.fetch_add(1, std::memory_order_relaxed);
        LOG("%s %s (%s attempt %d, HTTP %d), retrying",
            LogTag(), rateLimited ? "Rate limited" : "Timeout",
            method, attempt + 1, lastResp.status);
    }
    LOG("%s Retries exhausted for %s %s (HTTP %d)", LogTag(), method, path.c_str(), lastResp.status);
    return lastResp;
}

// ── Init / Shutdown / IsAuthenticated ──────────────────────────────────────