| 273 | } |
| 274 | |
| 275 | static void BufferedOutputStreamLargeWritesToPipe( |
| 276 | benchmark::State& state) { // NOLINT non-const reference |
| 277 | std::shared_ptr<io::OutputStream> stream; |
| 278 | std::shared_ptr<BackgroundReader> reader; |
| 279 | SetupPipeWriter(&stream, &reader); |
| 280 | |
| 281 | auto buffered_stream = |
| 282 | *io::BufferedOutputStream::Create(kBufferSize, default_memory_pool(), stream); |
| 283 | |
| 284 | BenchmarkStreamingWrites(state, large_sizes, buffered_stream.get(), reader.get()); |
| 285 | } |
| 286 | |
| 287 | // We use real time as we don't want to count CPU time spent in the |
| 288 | // BackgroundReader thread |
nothing calls this directly
no test coverage detected