MCPcopy Create free account
hub / github.com/bytedance/bolt / waitForWrite

Method waitForWrite

bolt/dwio/dwrf/test/CacheInputTest.cpp:377–384  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

375 }
376
377 void waitForWrite() {
378 auto ssd = cache_->ssdCache();
379 if (ssd) {
380 while (ssd->writeInProgress()) {
381 std::this_thread::sleep_for(std::chrono::milliseconds(50)); // NOLINT
382 }
383 }
384 }
385
386 // Serializes 'pathToInput_' and 'fileIds_' in multithread test.
387 std::mutex mutex_;

Callers

nothing calls this directly

Calls 2

ssdCacheMethod · 0.80
writeInProgressMethod · 0.80

Tested by

no test coverage detected