Method Open

framework/data_source/curl/curl_data_source.cpp:151–203

}

int CurlDataSource::Open(int flags)
{
    // TODO: deal with ret
    mOpenTimeMS = af_gettime_relative() / 1000;
    bool isRTMP = mUri.compare(0, 7, "rtmp://") == 0;
    mLocation = (isRTMP ? (mUri + " live=1").c_str() : mUri.c_str());
    pConfig = &mConfig;

    if (headerList) {
        curl_slist_free_all(headerList);
        headerList = nullptr;
    }

    if (getProperty("ro.network.http.globeHeader")) {
        headerList = curl_slist_append(headerList, getProperty("ro.network.http.globeHeader"));
    }

    std::vector<std::string> &customHeaders = mConfig.customHeaders;

    for (string &item : customHeaders) {
        if (!item.empty()) {
            headerList = curl_slist_append(headerList, item.c_str());
        }
    }

    if (pConfig->so_rcv_size >= MIN_SO_RCVBUF_SIZE) {
        pConfig->so_rcv_size = pConfig->so_rcv_size >> 12;
        pConfig->so_rcv_size = pConfig->so_rcv_size << 12;
        AF_LOGI("so_rcv_size is %d\n", pConfig->so_rcv_size);
    } else if (pConfig->so_rcv_size > 0) {
        AF_LOGI("so_rcv_size too small\n");
        pConfig->so_rcv_size = 0;
    }

    {
        std::lock_guard<std::mutex> lock(mMutex);
        mPConnection = initConnection();
        mPConnection->setInterrupt(&mInterrupt);
    }

    int ret = curl_connect(mPConnection, rangeStart != INT64_MIN ? rangeStart : 0);
    mOpenTimeMS = af_gettime_relative() / 1000 - mOpenTimeMS;

    if (ret >= 0) {
        fillConnectInfo();
    }

    if (nullptr == mConnections) {
        mConnections = new std::vector<CURLConnection *>();
    }

    return ret;
}

int CurlDataSource::Open(const string &url)
{