Method readBlobGranulesFinish

fdbclient/MultiVersionTransaction.actor.cpp:310–343

};

ThreadResult<RangeResult> DLTransaction::readBlobGranulesFinish(
    ThreadFuture<Standalone<VectorRef<BlobGranuleChunkRef>>> startFuture,
    const KeyRangeRef& keyRange,
    Version beginVersion,
    Version readVersion,
    ReadBlobGranuleContext granuleContext) {
	if (!api->transactionReadBlobGranulesFinish) {
		return unsupported_operation();
	}

	// convert back to fdb future for API
	FdbCApi::FDBFuture* f = (FdbCApi::FDBFuture*)(startFuture.extractPtr());

	// FIXME: better way to convert here?
	FdbCApi::FDBReadBlobGranuleContext context;
	context.userContext = granuleContext.userContext;
	context.start_load_f = granuleContext.start_load_f;
	context.get_load_f = granuleContext.get_load_f;
	context.free_load_f = granuleContext.free_load_f;
	context.debugNoMaterialize = granuleContext.debugNoMaterialize;
	context.granuleParallelism = granuleContext.granuleParallelism;

	FdbCApi::FDBResult* r = api->transactionReadBlobGranulesFinish(tr,
	                                                               f,
	                                                               keyRange.begin.begin(),
	                                                               keyRange.begin.size(),
	                                                               keyRange.end.begin(),
	                                                               keyRange.end.size(),
	                                                               beginVersion,
	                                                               readVersion,
	                                                               &context);

	return ThreadResult<RangeResult>((ThreadSingleAssignmentVar<RangeResult>*)(r));
};

ThreadFuture<Standalone<VectorRef<BlobGranuleSummaryRef>>>
DLTransaction::summarizeBlobGranules(const KeyRangeRef& keyRange, Optional<Version> summaryVersion, int rangeLimit) {