Home
last modified time | relevance | path

Searched refs:empty_batch (Results 1 – 10 of 10) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc219 WriteBatch empty_batch; in CommitInternal() local
220 empty_batch.PutLogData(Slice()); in CommitInternal()
222 WriteBatchInternal::InsertNoop(&empty_batch); in CommitInternal()
226 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in CommitInternal()
404 WriteBatch empty_batch; in RollbackInternal() local
405 empty_batch.PutLogData(Slice()); in RollbackInternal()
407 WriteBatchInternal::InsertNoop(&empty_batch); in RollbackInternal()
408 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in RollbackInternal()
Dwrite_unprepared_txn.cc325 Status MarkNoop(bool empty_batch) override { in FlushWriteBatchToDBInternal()
326 return empty_batch ? Status::OK() : Status::InvalidArgument(); in FlushWriteBatchToDBInternal()
436 Status MarkNoop(bool empty_batch) override { in FlushWriteBatchWithSavePointToDB()
437 return empty_batch ? Status::OK() : Status::InvalidArgument(); in FlushWriteBatchWithSavePointToDB()
619 WriteBatch empty_batch; in CommitInternal() local
620 empty_batch.PutLogData(Slice()); in CommitInternal()
622 WriteBatchInternal::InsertNoop(&empty_batch); in CommitInternal()
626 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in CommitInternal()
769 WriteBatch empty_batch; in RollbackInternal() local
771 empty_batch.PutLogData(Slice()); in RollbackInternal()
[all …]
Dwrite_prepared_txn_db.cc214 WriteBatch empty_batch; in WriteInternal() local
218 s = db_impl_->WriteImpl(write_options, &empty_batch, nullptr, nullptr, in WriteInternal()
/rocksdb-6.9/db/
Dwrite_batch.cc539 bool empty_batch = true; in Iterate() local
581 empty_batch = false; in Iterate()
637 empty_batch = false; in Iterate()
643 empty_batch = false; in Iterate()
662 empty_batch = false; in Iterate()
675 empty_batch = false; in Iterate()
694 empty_batch = true; in Iterate()
700 empty_batch = true; in Iterate()
706 empty_batch = true; in Iterate()
710 empty_batch = true; in Iterate()
[all …]
Dtransaction_log_impl.cc252 Status MarkNoop(bool empty_batch) override { in UpdateCurrentWriteBatch()
253 if (!empty_batch) { in UpdateCurrentWriteBatch()
Dwrite_batch_test.cc302 Status MarkNoop(bool empty_batch) override { in MarkNoop()
303 seen += "MarkNoop(" + std::string(empty_batch ? "true" : "false") + ")"; in MarkNoop()
Ddb_test.cc209 WriteBatch empty_batch; in TEST_F() local
210 ASSERT_OK(dbfull()->Write(wo, &empty_batch)); in TEST_F()
/rocksdb-6.9/java/rocksjni/
Dwritebatchhandlerjnicallback.h48 Status MarkNoop(bool empty_batch);
Dwritebatchhandlerjnicallback.cc370 bool empty_batch) { in MarkNoop() argument
371 m_env->CallVoidMethod(m_jcallback_obj, m_jMarkNoopMethodId, static_cast<jboolean>(empty_batch)); in MarkNoop()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1501 WriteBatch empty_batch; in Open() local
1502 WriteBatchInternal::SetSequence(&empty_batch, recovered_seq); in Open()
1506 s = impl->WriteToWAL(empty_batch, log_writer, &log_used, &log_size); in Open()