Home
last modified time | relevance | path

Searched defs:batch (Results 1 – 25 of 66) sorted by relevance

123

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchTest.java44 try (final WriteBatch batch = new WriteBatch()) { in emptyWriteBatch()
61 try (final WriteBatch batch = new WriteBatch()) { in multipleBatchOperations()
90 try (WriteBatch batch = new WriteBatch()) { in multipleBatchOperationsDirect()
155 try (final WriteBatch batch = new WriteBatch()) { in blobOperation()
176 try (final WriteBatch batch = new WriteBatch()) { in savePoints()
245 try (final WriteBatch batch = new WriteBatch()) { in restorePoints()
269 try (final WriteBatch batch = new WriteBatch()) { in restorePoints_withoutSavePoints()
276 try (final WriteBatch batch = new WriteBatch()) { in restorePoints_withoutSavePoints_nested()
288 try (final WriteBatch batch = new WriteBatch()) { in popSavePoint()
316 try (final WriteBatch batch = new WriteBatch()) { in popSavePoint_withoutSavePoints()
[all …]
DWalFilterTest.java67 final WriteBatch batch = new WriteBatch(); in walFilter() local
141 final long logNumber, final String logFileName, final WriteBatch batch, in logRecordFound()
DWriteBatchHandlerTest.java39 try (final WriteBatch batch = new WriteBatch()) { in writeBatchHandler()
/rocksdb-6.9/db/
Dwrite_batch_test.cc133 WriteBatch batch; in TEST_F() local
140 WriteBatch batch; in TEST_F() local
158 WriteBatch batch; in TEST_F() local
222 WriteBatch batch; in TEST_F() local
318 WriteBatch batch; in TEST_F() local
328 WriteBatch batch; in TEST_F() local
338 WriteBatch batch; in TEST_F() local
348 WriteBatch batch; in TEST_F() local
358 WriteBatch batch; in TEST_F() local
392 WriteBatch batch; in TEST_F() local
[all …]
Dwrite_batch_internal.h134 static Slice Contents(const WriteBatch* batch) { in Contents()
138 static size_t ByteSize(const WriteBatch* batch) { in ByteSize()
214 explicit LocalSavePoint(WriteBatch* batch) in LocalSavePoint()
Derror_handler_fs_test.cc725 WriteBatch batch; in TEST_F() local
737 WriteBatch batch; in TEST_F() local
801 WriteBatch batch; in TEST_F() local
815 WriteBatch batch; in TEST_F() local
852 WriteBatch batch; in TEST_F() local
892 WriteBatch batch; in TEST_F() local
906 WriteBatch batch; in TEST_F() local
997 WriteBatch batch; in TEST_F() local
1011 WriteBatch batch; in TEST_F() local
1110 WriteBatch batch; in TEST_F() local
[all …]
Dtransaction_log_impl.cc208 const WriteBatch* batch, const SequenceNumber expected_seq) { in IsBatchExpected()
225 std::unique_ptr<WriteBatch> batch(new WriteBatch()); in UpdateCurrentWriteBatch() local
Ddb_log_iter_test.cc218 WriteBatch batch; in TEST_F() local
238 WriteBatch batch; in TEST_F() local
Dwal_manager_test.cc69 WriteBatch batch; in Put() local
140 WriteBatch batch; in TEST_F() local
Dwrite_thread.h116 WriteBatch* batch; member
160 : batch(_batch), in batch() function
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc289 WriteBatchWithIndex batch(nullptr, 20); in TEST_F() local
316 WriteBatchWithIndex batch(BytewiseComparator(), 20); in TEST_F() local
403 WriteBatchWithIndex batch(BytewiseComparator(), 20, true); in TEST_F() local
932 WriteBatchWithIndex batch; in TEST_F() local
992 WriteBatchWithIndex batch; in TEST_F() local
1042 WriteBatchWithIndex batch(BytewiseComparator(), 0, true); in TEST_F() local
1097 WriteBatchWithIndex batch; in TEST_F() local
1150 WriteBatchWithIndex batch; in TEST_F() local
1329 WriteBatchWithIndex batch; in TEST_F() local
1597 WriteBatchWithIndex batch; in TEST_F() local
[all …]
Dwrite_batch_with_index_internal.cc155 const ImmutableDBOptions& immuable_db_options, WriteBatchWithIndex* batch, in GetFromBatch()
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc52 Status PutBlobIndex(WriteBatch* batch, const Slice& key, in PutBlobIndex()
58 Status Write(WriteBatch* batch) { in Write()
143 WriteBatch batch; in TEST_F() local
160 WriteBatch batch; in TEST_F() local
185 WriteBatch batch; in TEST_F() local
336 WriteBatch batch; in TEST_F() local
/rocksdb-6.9/utilities/
Denv_librados_test.cc357 WriteBatch batch; in TEST_F() local
475 WriteBatch batch; in TEST_F() local
514 WriteBatch batch; in TEST_F() local
559 WriteBatch batch; in TEST_F() local
598 WriteBatch batch; in TEST_F() local
643 WriteBatch batch; in TEST_F() local
694 WriteBatch batch; in TEST_F() local
900 WriteBatch batch; in TEST_F() local
942 WriteBatch batch; in TEST_F() local
985 WriteBatch batch; in TEST_F() local
/rocksdb-6.9/examples/
Dcolumn_families_example.cc55 WriteBatch batch; in main() local
Dsimple_example.cc41 WriteBatch batch; in main() local
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DWalFilter.java57 final String logFileName, final WriteBatch batch, in logRecordFound()
/rocksdb-6.9/include/rocksdb/
Dwal_filter.h83 const WriteBatch& batch, WriteBatch* new_batch, bool* batch_changed) { in LogRecordFound()
/rocksdb-6.9/tools/rdb/
Ddb_wrapper.cc290 bool DBWrapper::AddToBatch(ROCKSDB_NAMESPACE::WriteBatch& batch, bool del, in AddToBatch()
321 bool DBWrapper::AddToBatch(ROCKSDB_NAMESPACE::WriteBatch& batch, bool del, in AddToBatch()
366 ROCKSDB_NAMESPACE::WriteBatch batch; in WriteBatch() local
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc134 Status PessimisticTransaction::CommitBatch(WriteBatch* batch) { in CommitBatch()
360 Status WriteCommittedTxn::CommitBatchInternal(WriteBatch* batch, size_t) { in CommitBatchInternal()
461 Status PessimisticTransaction::LockBatch(WriteBatch* batch, in LockBatch()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc1813 WriteBatch batch(key.size() + value.size() + 24); in Put() local
1823 WriteBatch batch(key.size() + ts_sz + value.size() + 24, /*max_bytes=*/0, in Put() local
1838 WriteBatch batch; in Delete() local
1845 WriteBatch batch; in SingleDelete() local
1853 WriteBatch batch; in DeleteRange() local
1860 WriteBatch batch; in Merge() local
/rocksdb-6.9/java/rocksjni/
Dwal_filter_jnicallback.cc97 const WriteBatch& batch, WriteBatch* new_batch, bool* batch_changed) { in LogRecordFound()
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java149 try (final WriteBatch batch = new WriteBatch()) { in main()
/rocksdb-6.9/db_stress_tool/
Dbatched_ops_stress.cc34 WriteBatch batch; in TestPut() local
69 WriteBatch batch; in TestDelete() local
Dcf_consistency_stress.cc31 WriteBatch batch; in TestPut() local
58 WriteBatch batch; in TestDelete() local
88 WriteBatch batch; in TestDeleteRange() local

123