| /dports/www/osrm-backend/osrm-backend-5.26.0/third_party/libosmium/include/osmium/io/detail/ |
| H A D | write_thread.hpp | 57 class WriteThread { class
65 WriteThread(future_string_queue_type& input_queue, in WriteThread() function in osmium::io::detail::WriteThread
73 WriteThread(const WriteThread&) = delete;
74 WriteThread& operator=(const WriteThread&) = delete;
76 WriteThread(WriteThread&&) = delete;
77 WriteThread& operator=(WriteThread&&) = delete;
79 ~WriteThread() noexcept = default;
|
| /dports/astro/libosmium/libosmium-2.17.2/include/osmium/io/detail/ |
| H A D | write_thread.hpp | 57 class WriteThread { class
66 WriteThread(future_string_queue_type& input_queue, in WriteThread() function in osmium::io::detail::WriteThread
76 WriteThread(const WriteThread&) = delete;
77 WriteThread& operator=(const WriteThread&) = delete;
79 WriteThread(WriteThread&&) = delete;
80 WriteThread& operator=(WriteThread&&) = delete;
82 ~WriteThread() noexcept = default;
|
| /dports/converters/osm2pgsql/osm2pgsql-1.5.1/contrib/libosmium/include/osmium/io/detail/ |
| H A D | write_thread.hpp | 57 class WriteThread { class
66 WriteThread(future_string_queue_type& input_queue, in WriteThread() function in osmium::io::detail::WriteThread
76 WriteThread(const WriteThread&) = delete;
77 WriteThread& operator=(const WriteThread&) = delete;
79 WriteThread(WriteThread&&) = delete;
80 WriteThread& operator=(WriteThread&&) = delete;
82 ~WriteThread() noexcept = default;
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in rocksdb::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
259 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
284 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
296 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
336 void WriteThread::BeginWriteStall() { in BeginWriteStall()
366 void WriteThread::EndWriteStall() { in EndWriteStall()
381 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
500 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
623 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
777 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
259 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
284 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
296 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
336 void WriteThread::BeginWriteStall() { in BeginWriteStall()
366 void WriteThread::EndWriteStall() { in EndWriteStall()
381 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
500 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
623 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
777 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/rocksdb/rocksdb-6.26.1/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
259 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
284 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
296 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
336 void WriteThread::BeginWriteStall() { in BeginWriteStall()
366 void WriteThread::EndWriteStall() { in EndWriteStall()
381 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
500 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
623 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
777 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
259 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
284 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
296 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
336 void WriteThread::BeginWriteStall() { in BeginWriteStall()
366 void WriteThread::EndWriteStall() { in EndWriteStall()
381 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
500 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
623 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
777 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
259 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
284 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
296 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
336 void WriteThread::BeginWriteStall() { in BeginWriteStall()
366 void WriteThread::EndWriteStall() { in EndWriteStall()
381 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
500 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
623 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
777 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/ |
| H A D | write_thread.cc | 17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
467 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
544 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
654 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
682 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
689 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1251 WriteThread::Writer nonmem_w; in SwitchWAL()
1328 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1553 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/ |
| H A D | GroupCommitTest.java | 152 final WriteThread wt[] = new WriteThread[count]; in doWrites()
155 wt[i] = new WriteThread(menv); in doWrites()
170 private class WriteThread extends Thread { class in GroupCommitTest
173 WriteThread(ReplicatedEnvironment menv) { in WriteThread() method in GroupCommitTest.WriteThread
|
| /dports/biology/bbmap/bbmap/current/driver/ |
| H A D | ConcatenateTextFiles.java | 59 WriteThread wt=new WriteThread(outname); in concatenate()
81 private static void processTerm(String term, ArrayList<String>[] bufferptr, WriteThread wt){ in processTerm()
123 private static class WriteThread extends Thread{ class in ConcatenateTextFiles
125 public WriteThread(String fname_){ in WriteThread() method in ConcatenateTextFiles.WriteThread
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/db_impl/ |
| H A D | db_impl_write.cc | 197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
479 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
572 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
687 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
717 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
724 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1339 WriteThread::Writer nonmem_w; in SwitchWAL()
1423 WriteThread::Writer nonmem_w; in HandleWriteBufferManagerFlush()
1685 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
|