| 64 | } |
| 65 | |
| 66 | void GPReader::open(const S3Params& params) { |
| 67 | this->s3InterfaceService.setRESTfulService(this->restfulServicePtr); |
| 68 | this->bucketReader.setS3InterfaceService(&this->s3InterfaceService); |
| 69 | this->bucketReader.setUpstreamReader(&this->commonReader); |
| 70 | this->commonReader.setS3InterfaceService(&this->s3InterfaceService); |
| 71 | this->bucketReader.open(this->params); |
| 72 | } |
| 73 | |
| 74 | // read() attempts to read up to count bytes into the buffer. |
| 75 | // Return 0 if EOF. Throw exception if encounters errors. |