Method write_callback

framework/data_source/curl/CURLConnection.cpp:208–260

}

size_t Cicada::CURLConnection::write_callback(char *buffer, size_t size, size_t nitems, void *userp)
{
    CURLConnection *pHandle = (CURLConnection *) userp;
    uint32_t amount = (uint32_t) (size * nitems);

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

    if (pHandle->overflowSize) {
        // we have our overflow buffer - first get rid of as much as we can
        uint32_t maxWriteable = std::min(RingBuffergetMaxWriteSize(pHandle->pRbuf), pHandle->overflowSize);

        if (maxWriteable) {
            if (RingBufferWriteData(pHandle->pRbuf, pHandle->pOverflowBuffer, maxWriteable) != maxWriteable) {
                AF_LOGE("write ring buffer error\n");
            }

            if (pHandle->overflowSize > maxWriteable) { // still have some more - copy it down
                memmove(pHandle->pOverflowBuffer, pHandle->pOverflowBuffer + maxWriteable, pHandle->overflowSize - maxWriteable);
            }

            pHandle->overflowSize -= maxWriteable;
        }
    }

    uint32_t maxWriteable = std::min(RingBuffergetMaxWriteSize(pHandle->pRbuf), amount);

    if (maxWriteable) {
        if (RingBufferWriteData(pHandle->pRbuf, buffer, maxWriteable) != maxWriteable) {
            AF_LOGE("write ring buffer error\n");
        } else {
            amount -= maxWriteable;
            buffer += maxWriteable;
        }
    }

    if (amount) {
        char *p = (char *) realloc(pHandle->pOverflowBuffer, pHandle->overflowSize + amount);

        if (p == nullptr) {
            AF_LOGE("av_realloc error\n");
            return -ENOMEM;
        }

        pHandle->pOverflowBuffer = p;
        memcpy(pHandle->pOverflowBuffer + pHandle->overflowSize, buffer, amount);
        pHandle->overflowSize += amount;
    }
    pHandle->mWriteSize += size * nitems;
    return size * nitems;
}

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