Function read_thread

framework/data_source/data_source_test.cpp:22–55

} mainCont;

static void *read_thread(void *arg)
{
    mainCont *pHandle = (mainCont *) arg;
    auto *pDownloader = pHandle->pDownloader;
    int total_size = 0;
    int ret;
    int read_size = 1024;
    auto *buffer = static_cast<uint8_t *>(malloc(static_cast<size_t>(read_size + 1)));

    do {
        ret = static_cast<int>(pDownloader->Read(buffer, read_size));

        if (ret > 0) {
            total_size += ret;

            if (pHandle->outFd > 0) {
                write(pHandle->outFd, buffer, static_cast<size_t>(ret));
            }

            //    buffer[ret] = 0;
            //    printf("%s", buffer);
        }
    } while (ret > 0 && !pHandle->isCanceled);

    //   printf("\n");
    if (ret < 0) {
        printf("read error %d (%s)\n", ret, pDownloader->Get_error_info(ret).c_str());
    }

    printf("total_size is %d\n", total_size);
    free(buffer);
    pHandle->isEOS = true;
    return nullptr;
}

static void *seek_thread
(void *arg)