Method _onUpdate

core/network/Downloader-curl.cpp:860–891

}

void DownloaderCURL::_onUpdate(float)
{
    std::vector<std::shared_ptr<DownloadTask>> tasks;

    // update processing tasks
    _impl->getProcessTasks(tasks);
    for (auto&& task : tasks)
    {
        auto context = static_cast<DownloadContextCURL*>(task->_context.get());
        std::lock_guard<std::recursive_mutex> lock(context->_mutex);
        if (context->_bytesReceived)
        {
            _updateTaskProgressInfo(*task);
            onTaskProgress(*task);
            context->_bytesReceived = 0;
        }
    }
    tasks.clear();

    // update finished tasks
    _impl->getFinishedTasks(tasks);
    if (_impl->stopped())
    {
        if (_scheduler)
            _scheduler->pauseTarget(this);
    }

    for (auto&& task : tasks)
    {
        _onDownloadFinished(*task);
    }
}

void DownloaderCURL::_updateTaskProgressInfo(DownloadTask& task, int64_t totalExpected)
{