MCPcopy Create free account
hub / github.com/apache/arrow / PoolResetGuard

Class PoolResetGuard

cpp/src/arrow/dataset/file_parquet_test.cc:463–466  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

461TEST_F(TestParquetFileFormat, SingleThreadExecutor) {
462 // Reset capacity for io executor
463 struct PoolResetGuard {
464 int original_capacity = io::GetIOThreadPoolCapacity();
465 ~PoolResetGuard() { DCHECK_OK(io::SetIOThreadPoolCapacity(original_capacity)); }
466 } guard;
467 ASSERT_OK(io::SetIOThreadPoolCapacity(1));
468
469 auto reader = GetRecordBatchReader(schema({field("utf8", utf8())}));

Callers

nothing calls this directly

Calls 1

GetIOThreadPoolCapacityFunction · 0.50

Tested by

no test coverage detected