Method ThreadProc

src/plugins/httpdatastream/HttpDataStream.cpp:403–463

}

void HttpDataStream::ThreadProc() {
    if (this->curlEasy) {
        static const int kMaxRetries = 10;
        int retryCount = 0; /* note: weighted based on failure type */
        while (this->state != State::Downloaded && !this->interrupted) {
            auto const curlCode = curl_easy_perform(this->curlEasy);
            long httpStatusCode = 0;
            curl_easy_getinfo(this->curlEasy, CURLINFO_RESPONSE_CODE, &httpStatusCode);
            if (httpStatusCode == 200) {
                this->state = curlCode != CURLE_OK
                    ? State::Aborted
                    : State::Downloaded;

                if (this->reader) {
                    if (this->written > 0) {
                        this->reader->Add(this->written);
                        this->written = 0;
                    }
                    this->reader->Completed();
                }
            }
            else {
                if (httpStatusCode == 429) { /* too many requests */
                     this->state = State::Retrying;
                    retryCount += 1;
                    sleepMs(5000);
                }
                else if ((httpStatusCode < 400 || httpStatusCode >= 500) && retryCount < kMaxRetries) {
                    {
                        std::unique_lock<std::mutex> lock(this->stateMutex);
                        this->ResetFileHandles();
                    }
                    this->state = State::Retrying;
                    retryCount += 2;
                    sleepMs(2000);
                }
                else {
                    this->state = State::Error;
                    this->interrupted = true;
                }
            }
        }

        startedContition.notify_all(); /* in case the header write function was never called */

        if (this->curlEasy) {
            curl_easy_cleanup(this->curlEasy);
            this->curlEasy = nullptr;
        }

        if (this->curlHeaders) {
            curl_slist_free_all(this->curlHeaders);
            this->curlHeaders = nullptr;
        }

        if (this->writeFile) {
            fclose(this->writeFile);
            this->writeFile = nullptr;