Function reader_init

gpcontrib/gpcloud/src/gpreader.cpp:86–123

invoked by s3_import(), need to be exception safe

// invoked by s3_import(), need to be exception safe
GPReader* reader_init(const char* url_with_options) {
    GPReader* reader = NULL;
    s3extErrorMessage.clear();

    try {
        if (!url_with_options) {
            return NULL;
        }

        string urlWithOptions(url_with_options);

        S3Params params = InitConfig(urlWithOptions);

        InitRemoteLog();

        // Prepare memory to be used for thread chunk buffer.
        PrepareS3MemContext(params);

        reader = new GPReader(params);
        if (reader == NULL) {
            return NULL;
        }

        reader->open(params);
        return reader;
    } catch (S3Exception& e) {
        delete reader;
        s3extErrorMessage =
            "reader_init caught a " + e.getType() + " exception: " + e.getFullMessage();
        S3ERROR("reader_init caught %s: %s", e.getType().c_str(), s3extErrorMessage.c_str());
        return NULL;
    } catch (...) {
        delete reader;
        S3ERROR("Caught an unexpected exception.");
        s3extErrorMessage = "Caught an unexpected exception.";
        return NULL;
    }
}

// invoked by s3_import(), need to be exception safe
bool reader_transfer_data(GPReader* reader, char* data_buf, int& data_len) {