Function main

framework/data_source/data_source_test.cpp:94–232

int main(int argc, const char **argv)
{
    log_enable_color(1);
//    if (argc < 3) {
//        printf("Usage: %s fileName outPutPath\n", argv[0]);
//        return -1;
//    }
    std::string url = BiDataSource::createUrl(
            "/Users/moqi/work/xx/apsaraPlayer/CicadaPlayer/platform/Apple/source/cmake-build-debug/mediaPlayer.out/framework.out/aliyunmedia.mp4",
            "http://player.alicdn.com/video/aliyunmedia.mp4", 146057805);
    int ret;
    mainCont *pHandle = static_cast<mainCont *>(malloc(sizeof(mainCont)));
    pHandle->pDownloader = dataSourcePrototype::create(url);
    pHandle->isEOS = false;
    IDataSource::SourceConfig config{};
    config.low_speed_time = 5;
    config.low_speed_limit = 1;
    config.connect_time = 5;
    pHandle->pDownloader->Set_config(config);
    config.connect_time = 0;
    pHandle->pDownloader->Get_config(config);
    AF_LOGD("config.connect_time is %d\n", config.connect_time);
    std::string location("location");
    ret = pHandle->pDownloader->Open(0);

    if (ret < 0) {
        AF_LOGE("open error!");
        goto fail;
    }

//    printf("location is %s\n", pHandle->pDownloader->Get_option(location).c_str());
//    pHandle->fileSize = pHandle->pDownloader->Seek(0, SEEK_SIZE);
//    printf("fileSize is %lld\n", pHandle->fileSize);
//    {
//        int ret = 0;
//        dataSourceIO *du = new dataSourceIO(pHandle->pDownloader);
//        char *buffer = static_cast<char *>(malloc(1024));
//        memset(buffer, 0, 1024);
//        while (du->get_line(buffer, 1024) > 0)
//            printf("get_line %s \n", buffer);
//        du->seek(0, SEEK_SET);
//        while (du->get_line(buffer, 1024) > 0)
//            printf("get_line %s \n", buffer);
//
//        delete du;
//        free(buffer);
//    }
//    return 0;
    argv[2] = "xx.flv";
    unlink(argv[2]);
    pHandle->outFd = open(argv[2], O_CREAT | O_WRONLY, 0666);

    if (pHandle->outFd < 0) {
        printf("open %s error \n", argv[2]);
        goto fail;
    }

    pthread_t read_thread_id;