| /rocksdb-6.9/util/ |
| D | timer_queue.h | 74 std::function<std::pair<bool, int64_t>(bool)> handler) { in add() argument
80 item.handler = std::move(handler); in add()
105 if (item.id == id && item.handler) { in cancel()
111 newItem.handler = std::move(item.handler); in cancel()
131 if (item.id && item.handler) { in cancelAll()
172 if (m_items.top().handler) { in calcWaitTime_lock()
191 if (item.handler) { in checkWork()
193 auto reschedule_pair = item.handler(item.id == 0); in checkWork()
217 std::function<std::pair<bool, int64_t>(bool)> handler; member
|
| D | thread_local.cc | 83 void SetHandler(uint32_t id, UnrefHandler handler);
469 void ThreadLocalPtr::StaticMeta::SetHandler(uint32_t id, UnrefHandler handler) { in SetHandler() argument
471 handler_map_[id] = handler; in SetHandler()
519 ThreadLocalPtr::ThreadLocalPtr(UnrefHandler handler) in ThreadLocalPtr() argument
521 if (handler != nullptr) { in ThreadLocalPtr()
522 Instance()->SetHandler(id_, handler); in ThreadLocalPtr()
|
| D | thread_local.h | 46 explicit ThreadLocalPtr(UnrefHandler handler = nullptr);
|
| D | thread_local_test.cc | 31 UnrefHandler handler = nullptr) in Params()
39 tls1(handler), in Params()
|
| /rocksdb-6.9/db/ |
| D | write_batch_test.cc | 377 TestHandler handler; in TEST_F() local
388 handler.seen); in TEST_F()
404 TestHandler handler; in TEST_F() local
413 handler.seen); in TEST_F()
473 } handler; in TEST_F() local
524 } handler; in TEST_F() local
559 } handler; in TEST_F() local
575 handler.seen); in TEST_F()
634 TestHandler handler; in TEST_F() local
646 handler.seen); in TEST_F()
[all …]
|
| D | write_batch.cc | 547 handler_continue = handler->Continue(); in Iterate()
635 handler->LogData(blob); in Iterate()
642 handler->MarkBeginPrepare(); in Iterate()
644 if (!handler->WriteAfterCommit()) { in Iterate()
661 handler->MarkBeginPrepare(); in Iterate()
663 if (handler->WriteAfterCommit()) { in Iterate()
676 if (handler->WriteAfterCommit()) { in Iterate()
693 handler->MarkEndPrepare(xid); in Iterate()
699 handler->MarkCommit(xid); in Iterate()
705 handler->MarkRollback(xid); in Iterate()
[all …]
|
| D | db_log_iter_test.cc | 269 } handler; in TEST_F() local
270 res.writeBatchPtr->Iterate(&handler); in TEST_F()
278 handler.seen); in TEST_F()
|
| D | c.cc | 1570 H handler; in rocksdb_writebatch_iterate() local
1571 handler.state_ = state; in rocksdb_writebatch_iterate()
1572 handler.put_ = put; in rocksdb_writebatch_iterate()
1573 handler.deleted_ = deleted; in rocksdb_writebatch_iterate()
1574 b->rep.Iterate(&handler); in rocksdb_writebatch_iterate()
1814 H handler; in rocksdb_writebatch_wi_iterate() local
1815 handler.state_ = state; in rocksdb_writebatch_wi_iterate()
1816 handler.put_ = put; in rocksdb_writebatch_wi_iterate()
1817 handler.deleted_ = deleted; in rocksdb_writebatch_wi_iterate()
1818 b->rep->GetWriteBatch()->Iterate(&handler); in rocksdb_writebatch_wi_iterate()
|
| D | write_batch_internal.h | 202 static Status Iterate(const WriteBatch* wb, WriteBatch::Handler* handler,
|
| D | db_test2.cc | 719 ChangeBatchHandler handler(new_batch, num_keys_to_add_in_new_batch_); in TEST_F() local
720 batch.Iterate(&handler); in TEST_F()
924 } handler(log_number, cf_log_number_map_, cf_wal_keys_); in TEST_F() local
926 batch.Iterate(&handler); in TEST_F()
|
| D | db_test.cc | 2807 Handler handler; in Write() local
2808 handler.map_ = &map_; in Write()
2809 return batch->Iterate(&handler); in Write()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | WriteBatchTest.java | 70 try(final CapturingWriteBatchHandler handler = in multipleBatchOperations() argument
72 batch.iterate(handler); in multipleBatchOperations()
74 assertThat(handler.getEvents().size()).isEqualTo(7); in multipleBatchOperations()
76 assertThat(handler.getEvents().get(0)).isEqualTo(new Event(PUT, foo, bar)); in multipleBatchOperations()
78 assertThat(handler.getEvents().get(2)).isEqualTo(new Event(PUT, baz, boo)); in multipleBatchOperations()
79 assertThat(handler.getEvents().get(3)).isEqualTo(new Event(MERGE, baz, hoo)); in multipleBatchOperations()
82 assertThat(handler.getEvents().get(6)).isEqualTo(new Event(LOG, null, hello)); in multipleBatchOperations()
258 batch.iterate(handler); in restorePoints()
260 assertThat(handler.getEvents().size()).isEqualTo(2); in restorePoints()
305 batch.iterate(handler); in popSavePoint()
[all …]
|
| D | WriteBatchHandlerTest.java | 63 try (final CapturingWriteBatchHandler handler = in writeBatchHandler() argument
65 batch.iterate(handler); in writeBatchHandler()
69 handler.getEvents(); in writeBatchHandler()
|
| /rocksdb-6.9/file/ |
| D | sst_file_manager_impl.cc | 363 void SstFileManagerImpl::StartErrorRecovery(ErrorHandler* handler, in StartErrorRecovery() argument
384 error_handler_list_.push_back(handler); in StartErrorRecovery()
399 if ((*iter) == handler) { in StartErrorRecovery()
403 error_handler_list_.push_back(handler); in StartErrorRecovery()
407 bool SstFileManagerImpl::CancelErrorRecovery(ErrorHandler* handler) { in CancelErrorRecovery() argument
410 if (cur_instance_ == handler) { in CancelErrorRecovery()
419 if ((*iter) == handler) { in CancelErrorRecovery()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 309 Handler handler(GetEnv()); in Write() local
310 updates->Iterate(&handler); in Write()
311 if (!handler.batch_rewrite_status.ok()) { in Write()
312 return handler.batch_rewrite_status; in Write()
314 return db_->Write(opts, &(handler.updates_ttl)); in Write()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_secondary.h | 281 ColumnFamilyCollector handler; in CollectColumnFamilyIdsFromWriteBatch() local
282 Status s = batch.Iterate(&handler); in CollectColumnFamilyIdsFromWriteBatch()
284 for (const auto& cf : handler.column_families()) { in CollectColumnFamilyIdsFromWriteBatch()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | WriteBatch.java | 62 public void iterate(final Handler handler) throws RocksDBException { in iterate() argument
63 iterate(nativeHandle_, handler.nativeHandle_); in iterate()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction.cc | 501 Handler handler; in LockBatch() local
502 batch->Iterate(&handler); in LockBatch()
507 for (const auto& cf_iter : handler.keys_) { in LockBatch()
|
| D | write_unprepared_txn.cc | 243 TrackKeyHandler handler(this, in RebuildFromWriteBatch() local
245 return wb->Iterate(&handler); in RebuildFromWriteBatch()
344 UntrackedKeyHandler handler( in FlushWriteBatchToDBInternal() local
346 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&handler); in FlushWriteBatchToDBInternal()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-05-14-lock.markdown | 49 …handler needs to be evicted based on LRU, those information is cleared. When the SST table needs t…
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_test.cc | 245 TestHandler handler; in TestValueAsSecondaryIndexHelper() local
246 batch->GetWriteBatch()->Iterate(&handler); in TestValueAsSecondaryIndexHelper()
250 ASSERT_EQ(entries.size(), handler.seen[data.GetID()].size()); in TestValueAsSecondaryIndexHelper()
252 for (auto e : handler.seen[data.GetID()]) { in TestValueAsSecondaryIndexHelper()
264 ASSERT_EQ(entries.size(), handler.seen[index.GetID()].size()); in TestValueAsSecondaryIndexHelper()
266 for (auto e : handler.seen[index.GetID()]) { in TestValueAsSecondaryIndexHelper()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | write_batch.h | 278 Status Iterate(Handler* handler) const;
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd.cc | 2251 InMemoryHandler handler(row, print_values, is_write_committed); in DumpWalFile() local
2252 batch.Iterate(&handler); in DumpWalFile()
|