Searched refs:writers (Results 1 – 6 of 6) sorted by relevance
38 DEFINE_int32(writers, 8, "");356 std::deque<Writer> writers; in main() local357 while (static_cast<int>(writers.size()) < FLAGS_writers) { in main()358 writers.emplace_back(&shard_states, db_raw); in main()366 shard_states[i].writer = &writers[writer_dist(rng)]; in main()370 for (Writer& w : writers) { in main()374 writers.clear(); in main()
226 Writer* writers = newest_writer->load(std::memory_order_relaxed); in LinkOne() local231 if (writers == &write_stall_dummy_) { in LinkOne()241 writers = newest_writer->load(std::memory_order_relaxed); in LinkOne()242 if (writers == &write_stall_dummy_) { in LinkOne()245 writers = newest_writer->load(std::memory_order_relaxed); in LinkOne()250 w->link_older = writers; in LinkOne()251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()252 return (writers == nullptr); in LinkOne()
3636 std::deque<ManifestWriter>& writers, InstrumentedMutex* mu, in ProcessManifestWrites() argument3639 assert(!writers.empty()); in ProcessManifestWrites()3640 ManifestWriter& first_writer = writers.front(); in ProcessManifestWrites()4045 for (const auto& w : writers) { in ProcessManifestWrites()4097 std::deque<ManifestWriter> writers; in LogAndApply() local4103 writers.emplace_back(mu, column_family_datas[i], in LogAndApply()4105 manifest_writers_.push_back(&writers[i]); in LogAndApply()4107 assert(!writers.empty()); in LogAndApply()4108 ManifestWriter& first_writer = writers.front(); in LogAndApply()4117 for (const auto& writer : writers) { in LogAndApply()[all …]
1207 Status ProcessManifestWrites(std::deque<ManifestWriter>& writers,
22 * Coordinating writers
65 …rite threads to hang when a slowdown/stall happens and there is a mix of writers with WriteOptions…370 * Fix corner case where a write group leader blocked due to write stall blocks other writers in que…912 * Add DB::SyncWAL() that does a WAL sync without blocking writers.1111 we will ignore it. We assume that writers of these records were interrupted