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

Function BufferedOutputStreamSmallWritesToPipe

cpp/src/arrow/io/file_benchmark.cc:264–273  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

262}
263
264static void BufferedOutputStreamSmallWritesToPipe(
265 benchmark::State& state) { // NOLINT non-const reference
266 std::shared_ptr<io::OutputStream> stream;
267 std::shared_ptr<BackgroundReader> reader;
268 SetupPipeWriter(&stream, &reader);
269
270 auto buffered_stream =
271 *io::BufferedOutputStream::Create(kBufferSize, default_memory_pool(), stream);
272 BenchmarkStreamingWrites(state, small_sizes, buffered_stream.get(), reader.get());
273}
274
275static void BufferedOutputStreamLargeWritesToPipe(
276 benchmark::State& state) { // NOLINT non-const reference

Callers

nothing calls this directly

Calls 4

SetupPipeWriterFunction · 0.85
default_memory_poolFunction · 0.85
BenchmarkStreamingWritesFunction · 0.85
getMethod · 0.45

Tested by

no test coverage detected