Method write_callback

framework/data_source/curl/CURLConnection2.cpp:179–204

}

size_t Cicada::CURLConnection2::write_callback(char *buffer, size_t size, size_t nitems, void *userp)
{
    if (!userp) {
        return CURL_WRITEFUNC_PAUSE;
    }
    auto *pHandle = (CURLConnection2 *) userp;
    assert(!pHandle->mPaused);
    auto amount = (uint32_t) (size * nitems);
    std::lock_guard<std::mutex> lock(pHandle->mCurlCbMutex);
    //    AF_LOGD("RingBuffergetMaxWriteSize(pHandle->pRbuf) is %u\n",RingBuffergetMaxWriteSize(pHandle->pRbuf));
    if (RingBuffergetMaxWriteSize(pHandle->pRbuf) < amount) {
        pHandle->mPaused = true;
        AF_LOGD("write_callback %p paused\n", pHandle);
        return CURL_WRITEFUNC_PAUSE;
    }
    if (RingBufferWriteData(pHandle->pRbuf, buffer, amount) != amount) {
        AF_LOGE("write ring buffer error %u %u\n", amount, RingBuffergetMaxWriteSize(pHandle->pRbuf));
        assert(0);
    }

    if (pHandle->mPConfig && pHandle->mPConfig->listener) {
        // TODO: get file type form content type
        pHandle->mPConfig->listener->onNetWorkInPut(amount, IDataSource::Listener::bitStreamTypeMedia);
    }
    return amount;
}

void Cicada::CURLConnection2::debugHeader(bool in, char *data, size_t size)
{