| /dports/databases/percona57-client/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 …]
|
| /dports/databases/percona57-pam-for-mysql/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 …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | db_write_buffer_manager_test.cc | 101 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
122 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
347 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
371 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
488 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
514 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
651 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
677 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
|
| H A D | write_callback_test.cc | 223 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
227 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
229 ASSERT_TRUE(writer->state == WriteThread::State::STATE_INIT); in TEST_P()
253 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
258 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
260 ASSERT_TRUE(writer->state == WriteThread::State::STATE_COMPLETED || in TEST_P()
263 WriteThread::State::STATE_MEMTABLE_WRITER_LEADER)); in TEST_P()
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/db/ |
| H A D | db_write_buffer_manager_test.cc | 101 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
122 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
347 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
371 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
488 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
514 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
651 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
677 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
|
| H A D | write_callback_test.cc | 224 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
228 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
230 ASSERT_TRUE(writer->state == WriteThread::State::STATE_INIT); in TEST_P()
254 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
259 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
261 ASSERT_TRUE(writer->state == WriteThread::State::STATE_COMPLETED || in TEST_P()
264 WriteThread::State::STATE_MEMTABLE_WRITER_LEADER)); in TEST_P()
|
| /dports/databases/rocksdb/rocksdb-6.26.1/db/ |
| H A D | db_write_buffer_manager_test.cc | 101 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
122 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
347 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
371 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
488 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
514 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
651 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
677 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
|
| H A D | write_callback_test.cc | 224 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
228 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
230 ASSERT_TRUE(writer->state == WriteThread::State::STATE_INIT); in TEST_P()
254 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
259 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
261 ASSERT_TRUE(writer->state == WriteThread::State::STATE_COMPLETED || in TEST_P()
264 WriteThread::State::STATE_MEMTABLE_WRITER_LEADER)); in TEST_P()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | db_write_buffer_manager_test.cc | 101 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
122 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
347 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
371 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
488 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
514 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
651 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
677 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
|
| H A D | write_callback_test.cc | 223 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
227 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
229 ASSERT_TRUE(writer->state == WriteThread::State::STATE_INIT); in TEST_P()
253 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
258 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
260 ASSERT_TRUE(writer->state == WriteThread::State::STATE_COMPLETED || in TEST_P()
263 WriteThread::State::STATE_MEMTABLE_WRITER_LEADER)); in TEST_P()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
| H A D | db_write_buffer_manager_test.cc | 101 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
122 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
347 std::unordered_set<WriteThread::Writer*> w_set; in TEST_P()
371 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
488 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
514 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
651 std::unordered_set<WriteThread::Writer*> w_slowdown_set; in TEST_P()
677 WriteThread::Writer* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
|
| H A D | write_callback_test.cc | 223 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
227 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
229 ASSERT_TRUE(writer->state == WriteThread::State::STATE_INIT); in TEST_P()
253 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
258 WriteThread::State::STATE_GROUP_LEADER); in TEST_P()
260 ASSERT_TRUE(writer->state == WriteThread::State::STATE_COMPLETED || in TEST_P()
263 WriteThread::State::STATE_MEMTABLE_WRITER_LEADER)); in TEST_P()
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg);
215 WriteThread::State::STATE_GROUP_LEADER);
218 WriteThread::State::STATE_INIT);
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg);
247 WriteThread::State::STATE_GROUP_LEADER);
250 WriteThread::State::STATE_COMPLETED ||
253 WriteThread::State::
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/db/ |
| H A D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/db/db_impl/ |
| H A D | db_impl_write.cc | 194 assert(w.state == WriteThread::STATE_COMPLETED); in WriteImpl()
197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
483 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
576 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
689 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
719 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
726 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1357 WriteThread::Writer nonmem_w; in SwitchWAL()
1441 WriteThread::Writer nonmem_w; in HandleWriteBufferManagerFlush()
[all …]
|
| /dports/databases/rocksdb/rocksdb-6.26.1/db/db_impl/ |
| H A D | db_impl_write.cc | 194 assert(w.state == WriteThread::STATE_COMPLETED); in WriteImpl()
197 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
215 WriteThread::WriteGroup write_group; in WriteImpl()
483 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
576 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
689 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
719 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
726 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1357 WriteThread::Writer nonmem_w; in SwitchWAL()
1441 WriteThread::Writer nonmem_w; in HandleWriteBufferManagerFlush()
[all …]
|
| /dports/biology/bbmap/bbmap/current/bloom/ |
| H A D | KCountArray5MT.java | 311 writers[i]=new WriteThread(i); in initialize()
340 for(WriteThread wt : writers){ in shutdown()
345 for(WriteThread wt : writers){ in shutdown()
366 private class WriteThread extends Thread{ class in KCountArray5MT
368 public WriteThread(int tnum){ in WriteThread() method in KCountArray5MT.WriteThread
498 private final WriteThread[] writers=new WriteThread[numArrays];
|
| H A D | KCountArray6MT.java | 313 writers[i]=new WriteThread(i); in initialize()
345 for(WriteThread wt : writers){ in shutdown()
350 for(WriteThread wt : writers){ in shutdown()
371 private class WriteThread extends Thread{ class in KCountArray6MT
373 public WriteThread(int tnum){ in WriteThread() method in KCountArray6MT.WriteThread
502 private final WriteThread[] writers=new WriteThread[numArrays];
|
| /dports/editors/libreoffice/libreoffice-7.2.6.2/configmgr/source/ |
| H A D | components.cxx | 149 class Components::WriteThread: public salhelper::Thread { class in configmgr::Components
151 WriteThread(
152 rtl::Reference< WriteThread > * reference, Components & components,
158 virtual ~WriteThread() override {} in ~WriteThread()
162 rtl::Reference< WriteThread > * reference_;
170 Components::WriteThread::WriteThread( in WriteThread() function in configmgr::Components::WriteThread
171 rtl::Reference< WriteThread > * reference, Components & components, in WriteThread()
180 void Components::WriteThread::execute() { in execute()
282 writeThread_ = new WriteThread( in writeModifications()
296 rtl::Reference< WriteThread > thread; in flushModifications()
|
| /dports/editors/libreoffice6/libreoffice-6.4.7.2/configmgr/source/ |
| H A D | components.cxx | 149 class Components::WriteThread: public salhelper::Thread { class in configmgr::Components
151 WriteThread(
152 rtl::Reference< WriteThread > * reference, Components & components,
158 virtual ~WriteThread() override {} in ~WriteThread()
162 rtl::Reference< WriteThread > * reference_;
170 Components::WriteThread::WriteThread( in WriteThread() function in configmgr::Components::WriteThread
171 rtl::Reference< WriteThread > * reference, Components & components, in WriteThread()
180 void Components::WriteThread::execute() { in execute()
280 writeThread_ = new WriteThread( in writeModifications()
295 rtl::Reference< WriteThread > thread; in flushModifications()
|