Searched refs:write_batch_ (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_base.cc | 29 write_batch_(cmp_, 0, true, 0), in TransactionBaseImpl()
45 write_batch_.Clear(); in Clear()
127 write_batch_.SetSavePoint(); in SetSavePoint()
142 Status s = write_batch_.RollbackToSavePoint(); in RollbackToSavePoint()
191 assert(write_batch_.PopSavePoint().IsNotFound()); in PopSavePoint()
238 return write_batch_.PopSavePoint(); in PopSavePoint()
364 return write_batch_.NewIteratorWithBase(db_iter); in GetIterator()
588 write_batch_.PutLogData(blob); in PutLogData()
592 return &write_batch_; in GetWriteBatch()
715 return &write_batch_; in GetBatchForWrite()
[all …]
|
| D | write_unprepared_txn.cc | 252 write_batch_.GetWriteBatch()->Count() > 0 && in MaybeFlushWriteBatchToDB()
253 write_batch_.GetDataSize() > in MaybeFlushWriteBatchToDB()
464 std::swap(wb, write_batch_); in FlushWriteBatchWithSavePointToDB()
471 SavePointBatchHandler sp_handler(&write_batch_, in FlushWriteBatchWithSavePointToDB()
488 if (write_batch_.GetWriteBatch()->Count() > 0) { in FlushWriteBatchWithSavePointToDB()
814 unflushed_save_points_->push_back(write_batch_.GetDataSize()); in SetSavePoint()
857 WriteRollbackKeys(tracked_keys, &write_batch_, &callback, roptions); in RollbackToSavePointInternal()
870 write_batch_.SetSavePoint(); in RollbackToSavePointInternal()
897 write_batch_.SetSavePoint(); in PopSavePoint()
917 write_batch_.MultiGetFromBatchAndDB(db_, options, column_family, num_keys, in MultiGet()
[all …]
|
| D | transaction_base.h | 280 write_batch_.Clear();
282 assert(write_batch_.GetDataSize() == WriteBatchInternal::kHeader);
283 WriteBatchInternal::InsertNoop(write_batch_.GetWriteBatch());
330 WriteBatchWithIndex write_batch_; variable
|
| D | write_prepared_txn.cc | 53 write_batch_.MultiGetFromBatchAndDB(db_, options, column_family, num_keys, in MultiGet()
73 auto res = write_batch_.GetFromBatchAndDB(db_, options, column_family, key, in Get()
90 return write_batch_.NewIteratorWithBase(db_iter); in GetIterator()
99 return write_batch_.NewIteratorWithBase(column_family, db_iter); in GetIterator()
|
| D | pessimistic_transaction.cc | 66 write_batch_.SetMaxBytes(txn_options.max_write_batch_size); in Initialize()
|
| /rocksdb-6.9/db/ |
| D | write_callback_test.cc | 93 write_batch_.Put(key, val); in TEST_F()
98 write_batch_.Clear(); in TEST_F()
103 WriteBatch write_batch_; in TEST_F() member
315 WriteBatchInternal::InsertNoop(&write_op.write_batch_); in TEST_F()
318 woptions, &write_op.write_batch_, &write_op.callback_, in TEST_F()
323 woptions, &write_op.write_batch_, &write_op.callback_); in TEST_F()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_internal.h | 100 : default_comparator_(_default_comparator), write_batch_(write_batch) {} in WriteBatchEntryComparator()
122 const ReadableWriteBatch* write_batch_; variable
|
| D | write_batch_with_index_internal.cc | 120 key1 = Slice(write_batch_->Data().data() + entry1->key_offset, in operator ()()
126 key2 = Slice(write_batch_->Data().data() + entry2->key_offset, in operator ()()
|
| D | write_batch_with_index.cc | 352 write_batch_(write_batch) {} in WBWIIteratorImpl()
409 auto s = write_batch_->GetEntryFromDataOffset( in Entry()
431 const ReadableWriteBatch* write_batch_; member in ROCKSDB_NAMESPACE::WBWIIteratorImpl
|