Home
last modified time | relevance | path

Searched refs:wb (Results 1 – 25 of 29) sorted by relevance

12

/rocksdb-6.9/java/rocksjni/
Dwrite_batch.cc33 auto* wb = in Java_org_rocksdb_WriteBatch_newWriteBatch__I() local
69 assert(wb != nullptr); in Java_org_rocksdb_WriteBatch_count0()
82 assert(wb != nullptr); in Java_org_rocksdb_WriteBatch_clear0()
84 wb->Clear(); in Java_org_rocksdb_WriteBatch_clear0()
96 assert(wb != nullptr); in Java_org_rocksdb_WriteBatch_setSavePoint0()
98 wb->SetSavePoint(); in Java_org_rocksdb_WriteBatch_setSavePoint0()
110 assert(wb != nullptr); in Java_org_rocksdb_WriteBatch_rollbackToSavePoint0()
128 assert(wb != nullptr); in Java_org_rocksdb_WriteBatch_popSavePoint()
147 assert(wb != nullptr); in Java_org_rocksdb_WriteBatch_setMaxBytes()
379 wb->Delete(key); in Java_org_rocksdb_WriteBatch_removeDirect()
[all …]
Dwrite_batch_test.cc47 ROCKSDB_NAMESPACE::WriteBufferManager wb(options.db_write_buffer_size); in Java_org_rocksdb_WriteBatchTest_getContents() local
51 ROCKSDB_NAMESPACE::MutableCFOptions(options), &wb, in Java_org_rocksdb_WriteBatchTest_getContents()
161 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchTestInternalHelper_setSequence() local
162 assert(wb != nullptr); in Java_org_rocksdb_WriteBatchTestInternalHelper_setSequence()
165 wb, static_cast<ROCKSDB_NAMESPACE::SequenceNumber>(jsn)); in Java_org_rocksdb_WriteBatchTestInternalHelper_setSequence()
176 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchTestInternalHelper_sequence() local
177 assert(wb != nullptr); in Java_org_rocksdb_WriteBatchTestInternalHelper_sequence()
180 ROCKSDB_NAMESPACE::WriteBatchInternal::Sequence(wb)); in Java_org_rocksdb_WriteBatchTestInternalHelper_sequence()
Dwrite_batch_with_index.cc142 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchWithIndex_putDirect() local
143 assert(wb != nullptr); in Java_org_rocksdb_WriteBatchWithIndex_putDirect()
146 auto put = [&wb, &cf_handle](ROCKSDB_NAMESPACE::Slice& key, in Java_org_rocksdb_WriteBatchWithIndex_putDirect()
149 wb->Put(key, value); in Java_org_rocksdb_WriteBatchWithIndex_putDirect()
151 wb->Put(cf_handle, key, value); in Java_org_rocksdb_WriteBatchWithIndex_putDirect()
311 assert(wb != nullptr); in Java_org_rocksdb_WriteBatchWithIndex_removeDirect()
314 auto remove = [&wb, &cf_handle](ROCKSDB_NAMESPACE::Slice& key) { in Java_org_rocksdb_WriteBatchWithIndex_removeDirect()
316 wb->Delete(key); in Java_org_rocksdb_WriteBatchWithIndex_removeDirect()
318 wb->Delete(cf_handle, key); in Java_org_rocksdb_WriteBatchWithIndex_removeDirect()
496 auto* wb = wbwi->GetWriteBatch(); in Java_org_rocksdb_WriteBatchWithIndex_getWriteBatch() local
[all …]
Drocksjni.cc1296 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_RocksDB_write0() local
1298 ROCKSDB_NAMESPACE::Status s = db->Write(*write_options, wb); in Java_org_rocksdb_RocksDB_write0()
1318 auto* wb = wbwi->GetWriteBatch(); in Java_org_rocksdb_RocksDB_write1() local
1320 ROCKSDB_NAMESPACE::Status s = db->Write(*write_options, wb); in Java_org_rocksdb_RocksDB_write1()
/rocksdb-6.9/db/
Dc_test.c720 rocksdb_writebatch_clear(wb); in main()
732 rocksdb_writebatch_clear(wb); in main()
740 rocksdb_writebatch_clear(wb); in main()
750 rocksdb_writebatch_destroy(wb); in main()
768 rocksdb_writebatch_destroy(wb); in main()
788 rocksdb_writebatch_destroy(wb); in main()
856 rocksdb_writebatch_wi_destroy(wb); in main()
1260 rocksdb_writebatch_clear(wb); in main()
1272 rocksdb_writebatch_destroy(wb); in main()
1551 rocksdb_writebatch_clear(wb); in main()
[all …]
Ddb_memtable_test.cc144 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
145 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
185 mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
197 mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
224 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
225 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
Dwrite_batch.cc523 Status WriteBatchInternal::Iterate(const WriteBatch* wb, in Iterate() argument
526 if (begin > wb->rep_.size() || end > wb->rep_.size() || end < begin) { in Iterate()
577 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
587 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
597 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
607 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
617 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
627 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
640 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
659 assert(wb->content_flags_.load(std::memory_order_relaxed) & in Iterate()
[all …]
Dwrite_callback_test.cc392 WriteBatch wb; in TEST_F() local
394 wb.Put("a", "value.a"); in TEST_F()
395 wb.Delete("x"); in TEST_F()
398 s = db->Write(write_options, &wb); in TEST_F()
Dmemtable_list_test.cc234 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
235 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
351 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
352 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()
527 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
544 MemTable* mem = new MemTable(cmp, ioptions, mutable_cf_options, &wb, in TEST_F()
791 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
814 new MemTable(cmp, ioptions, *(mutable_cf_options_list.back()), &wb, in TEST_F()
Dwrite_batch_internal.h202 static Status Iterate(const WriteBatch* wb, WriteBatch::Handler* handler,
Dwrite_batch_test.cc32 WriteBufferManager wb(options.db_write_buffer_size); in PrintContents() local
33 MemTable* mem = new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in PrintContents()
Dc.cc1822 WriteBatch* wb = b->rep->GetWriteBatch(); in rocksdb_writebatch_wi_data() local
1823 *size = wb->GetDataSize(); in rocksdb_writebatch_wi_data()
1824 return wb->Data().c_str(); in rocksdb_writebatch_wi_data()
1950 WriteBatch* wb = wbwi->rep->GetWriteBatch(); in rocksdb_write_writebatch_wi() local
1951 SaveError(errptr, db->rep->Write(options->rep, wb)); in rocksdb_write_writebatch_wi()
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBColumnFamilySample.java60 try (final WriteBatch wb = new WriteBatch()) { in main() argument
61 wb.put(columnFamilyHandles.get(0), "key2".getBytes(), in main()
63 wb.put(columnFamilyHandles.get(1), "key3".getBytes(), in main()
65 wb.remove(columnFamilyHandles.get(0), "key".getBytes()); in main()
66 db.write(new WriteOptions(), wb); in main()
/rocksdb-6.9/utilities/transactions/
Dtransaction_test.h243 WriteBatch wb; variable
245 ASSERT_OK(wb.Put("k1" + istr, "v1"));
246 ASSERT_OK(wb.Put("k2" + istr, "v2"));
247 ASSERT_OK(wb.Put("k3" + istr, "v3"));
249 auto s = db->Write(wopts, &wb);
406 WriteBatch wb; in CrossCompatibilityTest() local
408 wb.Put(k, v); in CrossCompatibilityTest()
410 wb.Put(k, v2); in CrossCompatibilityTest()
411 ASSERT_OK(db->Write(write_options, &wb)); in CrossCompatibilityTest()
Dwrite_unprepared_txn.cc191 Status WriteUnpreparedTxn::RebuildFromWriteBatch(WriteBatch* wb) { in RebuildFromWriteBatch() argument
245 return wb->Iterate(&handler); in RebuildFromWriteBatch()
415 WriteBatchWithIndex* wb, in FlushWriteBatchWithSavePointToDB()
417 : wb_(wb), handles_(handles) {} in FlushWriteBatchWithSavePointToDB()
459 WriteBatchWithIndex wb(wpt_db_->DefaultColumnFamily()->GetComparator(), 0, in FlushWriteBatchWithSavePointToDB() local
464 std::swap(wb, write_batch_); in FlushWriteBatchWithSavePointToDB()
473 size_t curr_boundary = trailing_batch ? wb.GetWriteBatch()->GetDataSize() in FlushWriteBatchWithSavePointToDB()
482 Status s = WriteBatchInternal::Iterate(wb.GetWriteBatch(), &sp_handler, in FlushWriteBatchWithSavePointToDB()
Dwrite_unprepared_transaction_test.cc668 auto wb = txn->GetWriteBatch()->GetWriteBatch(); in TEST_P() local
670 ASSERT_OK(wb->Put("a_untrack", "a_untrack")); in TEST_P()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DReadOnlyTest.java257 final WriteBatch wb = new WriteBatch(); in failToWriteBatchReadOnly()
260 wb.put("key".getBytes(), "value".getBytes()); in failToWriteBatchReadOnly()
261 rDb.write(wOpts, wb); in failToWriteBatchReadOnly()
290 final WriteBatch wb = new WriteBatch(); in failToCFWriteBatchReadOnly()
293 wb.put(readOnlyColumnFamilyHandleList.get(0), "key".getBytes(), in failToCFWriteBatchReadOnly()
295 rDb.write(wOpts, wb); in failToCFWriteBatchReadOnly()
DWriteBatchTest.java485 static byte[] getContents(final WriteBatch wb) { in getContents() argument
486 return getContents(wb.nativeHandle_); in getContents()
489 static String getFromWriteBatch(final WriteBatch wb, final String key) in getFromWriteBatch() argument
493 wb.iterate(getter); in getFromWriteBatch()
509 static void setSequence(final WriteBatch wb, final long sn) { in setSequence() argument
510 setSequence(wb.nativeHandle_, sn); in setSequence()
513 static long sequence(final WriteBatch wb) { in sequence() argument
514 return sequence(wb.nativeHandle_); in sequence()
DWriteBatchThreadedTest.java62 try (final WriteBatch wb = new WriteBatch(); in threadedWrites()
65 wb.put(ByteBuffer.allocate(4).putInt(i).array(), "parallel rocks test".getBytes()); in threadedWrites()
67 db.write(w_opt, wb); in threadedWrites()
DWriteBatchWithIndexTest.java444 final WriteBatch wb = wbwi.getWriteBatch(); in getWriteBatch() local
445 assertThat(wb).isNotNull(); in getWriteBatch()
446 assertThat(wb.isOwningHandle()).isFalse(); in getWriteBatch()
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc773 WriteBatch wb; in TEST_F() local
774 wb.Put("key0", "value0"); in TEST_F()
775 wb.Put("key1", "value1"); in TEST_F()
776 ASSERT_OK(dbfull()->Write(write_opts, &wb)); in TEST_F()
/rocksdb-6.9/tools/
Dldb_cmd_test.cc191 WriteBufferManager wb(options_.db_write_buffer_size); in VerifyChecksumInManifest() local
193 VersionSet versions(dbname_, &immutable_db_options, sopt, tc.get(), &wb, in VerifyChecksumInManifest()
Dldb_cmd.cc1024 WriteBufferManager wb(options.db_write_buffer_size); in DumpManifestFile() local
1026 VersionSet versions(dbname, &immutable_db_options, sopt, tc.get(), &wb, &wc, in DumpManifestFile()
1166 WriteBufferManager wb(options.db_write_buffer_size); in GetLiveFilesChecksumInfoFromVersionSet() local
1168 VersionSet versions(dbname, &immutable_db_options, sopt, tc.get(), &wb, &wc, in GetLiveFilesChecksumInfoFromVersionSet()
1879 WriteBufferManager wb(opt.db_write_buffer_size); in GetOldNumOfLevels() local
1880 VersionSet versions(db_path_, &db_options, soptions, tc.get(), &wb, &wc, in GetOldNumOfLevels()
/rocksdb-6.9/memtable/
Dmemtablerep_bench.cc607 ROCKSDB_NAMESPACE::WriteBufferManager wb(FLAGS_write_buffer_size); in main() local
/rocksdb-6.9/table/
Dtable_test.cc464 explicit MemTableConstructor(const Comparator* cmp, WriteBufferManager* wb) in MemTableConstructor() argument
467 write_buffer_manager_(wb), in MemTableConstructor()
473 wb, kMaxSequenceNumber, 0 /* column_family_id */); in MemTableConstructor()
3674 WriteBufferManager wb(options.db_write_buffer_size); in TEST_F() local
3676 new MemTable(cmp, ioptions, MutableCFOptions(options), &wb, in TEST_F()

12