Home
last modified time | relevance | path

Searched refs:newest_writer (Results 1 – 24 of 24) sorted by relevance

/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc225 assert(newest_writer != nullptr); in LinkOne()
253 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
261 assert(newest_writer != nullptr); in LinkGroup()
443 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
448 while (w != newest_writer) { in EnterAsBatchGroupLeader()
525 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
528 while (w != newest_writer) { in EnterAsMemTableWriter()
565 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
568 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
779 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h412 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
417 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/rocksdb-lite/rocksdb-6.26.1/db/
H A Dwrite_thread.cc225 assert(newest_writer != nullptr); in LinkOne()
253 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
261 assert(newest_writer != nullptr); in LinkGroup()
443 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
448 while (w != newest_writer) { in EnterAsBatchGroupLeader()
525 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
528 while (w != newest_writer) { in EnterAsMemTableWriter()
565 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
568 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
779 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h412 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
417 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/rocksdb/rocksdb-6.26.1/db/
H A Dwrite_thread.cc225 assert(newest_writer != nullptr); in LinkOne()
253 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
261 assert(newest_writer != nullptr); in LinkGroup()
443 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
448 while (w != newest_writer) { in EnterAsBatchGroupLeader()
525 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
528 while (w != newest_writer) { in EnterAsMemTableWriter()
565 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
568 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
779 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h412 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
417 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc225 assert(newest_writer != nullptr); in LinkOne()
253 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
261 assert(newest_writer != nullptr); in LinkGroup()
443 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
448 while (w != newest_writer) { in EnterAsBatchGroupLeader()
525 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
528 while (w != newest_writer) { in EnterAsMemTableWriter()
565 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
568 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
779 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h412 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
417 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc225 assert(newest_writer != nullptr); in LinkOne()
253 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
261 assert(newest_writer != nullptr); in LinkGroup()
443 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
448 while (w != newest_writer) { in EnterAsBatchGroupLeader()
525 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
528 while (w != newest_writer) { in EnterAsMemTableWriter()
565 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
568 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
779 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h412 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
417 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/
H A Dwrite_thread.cc224 assert(newest_writer != nullptr); in LinkOne()
251 if (newest_writer->compare_exchange_weak(writers, w)) { in LinkOne()
259 assert(newest_writer != nullptr); in LinkGroup()
435 CreateMissingNewerLinks(newest_writer); in EnterAsBatchGroupLeader()
440 while (w != newest_writer) { in EnterAsBatchGroupLeader()
511 CreateMissingNewerLinks(newest_writer); in EnterAsMemTableWriter()
514 while (w != newest_writer) { in EnterAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter() local
553 CreateMissingNewerLinks(newest_writer); in ExitAsMemTableWriter()
754 Writer* newest_writer = w; in ExitUnbatched() local
[all …]
H A Dwrite_thread.h407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);