MCPcopy Create free account
hub / github.com/apache/cloudberry / reset

Method reset

gpcontrib/gpcloud/src/s3key_reader.cpp:263–275  ·  view source on GitHub ↗

reset marks before reading next key

Source from the content-addressed store, hash-verified

261
262// reset marks before reading next key
263void S3KeyReader::reset() {
264 this->sharedError = false;
265 this->curReadingChunk = 0;
266 this->transferredKeyLen = 0;
267
268 this->offsetMgr.reset();
269
270 this->chunkBuffers.clear();
271 this->threads.clear();
272
273 this->hasEol = false;
274 this->eolAppended = false;
275}
276
277void S3KeyReader::close() {
278 // to interupt downlading thread, we must: (check ChunkBuffer::fill())

Callers 3

closeMethod · 0.95
MemoryContextResetOnlyFunction · 0.45
TESTFunction · 0.45

Calls 1

clearMethod · 0.80

Tested by 1

TESTFunction · 0.36