| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | WriteOptionsTest.java | 25 public void writeOptions() { in writeOptions() method in WriteOptionsTest 28 writeOptions.setSync(true); in writeOptions() 29 assertThat(writeOptions.sync()).isTrue(); in writeOptions() 30 writeOptions.setSync(false); in writeOptions() 31 assertThat(writeOptions.sync()).isFalse(); in writeOptions() 33 writeOptions.setDisableWAL(true); in writeOptions() 35 writeOptions.setDisableWAL(false); in writeOptions() 44 writeOptions.setNoSlowdown(true); in writeOptions() 46 writeOptions.setNoSlowdown(false); in writeOptions() 49 writeOptions.setLowPri(true); in writeOptions() [all …]
|
| D | TransactionDBTest.java | 66 final WriteOptions writeOptions = new WriteOptions()) { in beginTransaction() 68 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction() 80 final WriteOptions writeOptions = new WriteOptions(); in beginTransaction_transactionOptions() argument 83 try(final Transaction txn = tdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions() 96 final WriteOptions writeOptions = new WriteOptions()) { in beginTransaction_withOld() argument 98 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld() 112 final WriteOptions writeOptions = new WriteOptions(); in beginTransaction_withOld_transactionOptions() argument 115 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions() 116 final Transaction txnReused = tdb.beginTransaction(writeOptions, in beginTransaction_withOld_transactionOptions() 129 final WriteOptions writeOptions = new WriteOptions(); in lockStatusData() argument [all …]
|
| D | OptimisticTransactionDBTest.java | 64 final WriteOptions writeOptions = new WriteOptions()) { in beginTransaction() 66 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction() 77 final WriteOptions writeOptions = new WriteOptions(); in beginTransaction_transactionOptions() argument 81 try(final Transaction txn = otdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions() 93 final WriteOptions writeOptions = new WriteOptions()) { in beginTransaction_withOld() argument 95 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld() 96 final Transaction txnReused = otdb.beginTransaction(writeOptions, txn); in beginTransaction_withOld() 108 final WriteOptions writeOptions = new WriteOptions(); in beginTransaction_withOld_transactionOptions() argument 112 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions() 113 final Transaction txnReused = otdb.beginTransaction(writeOptions, in beginTransaction_withOld_transactionOptions()
|
| D | TransactionTest.java | 259 final WriteOptions writeOptions = new WriteOptions(); in startDb() local 262 return new TransactionDBContainer(txnOptions, writeOptions, in startDb() 273 final TransactionOptions txnOptions, final WriteOptions writeOptions, in TransactionDBContainer() argument 278 super(writeOptions, columnFamilyHandles, columnFamilyOptions, in TransactionDBContainer() 287 return txnDb.beginTransaction(writeOptions, txnOptions); in beginTransaction() 291 public Transaction beginTransaction(final WriteOptions writeOptions) { in beginTransaction() argument 292 return txnDb.beginTransaction(writeOptions, txnOptions); in beginTransaction() 298 writeOptions.close(); in close()
|
| D | OptimisticTransactionTest.java | 299 final WriteOptions writeOptions = new WriteOptions(); in startDb() local 304 writeOptions, columnFamilyHandles, optimisticTxnDb, columnFamilyOptions, in startDb() 316 final WriteOptions writeOptions, in OptimisticTransactionDBContainer() argument 321 super(writeOptions, columnFamilyHandles, columnFamilyOptions, in OptimisticTransactionDBContainer() 329 return optimisticTxnDb.beginTransaction(writeOptions, in beginTransaction() 334 public Transaction beginTransaction(final WriteOptions writeOptions) { in beginTransaction() argument 335 return optimisticTxnDb.beginTransaction(writeOptions, in beginTransaction() 342 writeOptions.close(); in close()
|
| D | BlockBasedTableConfigTest.java | 191 final WriteOptions writeOptions = new WriteOptions(); in blockCacheCompressedIntegration() 196 db.put(writeOptions, key1, value); in blockCacheCompressedIntegration() 197 db.put(writeOptions, key2, value); in blockCacheCompressedIntegration() 198 db.put(writeOptions, key3, value); in blockCacheCompressedIntegration() 199 db.put(writeOptions, key4, value); in blockCacheCompressedIntegration()
|
| D | AbstractTransactionTest.java | 725 public void writeOptions() throws RocksDBException { in writeOptions() method in AbstractTransactionTest 730 final WriteOptions writeOptions = new WriteOptions() in writeOptions() 733 final Transaction txn = dbContainer.beginTransaction(writeOptions)) { in writeOptions() 740 assertThat(txnWriteOptions).isNotSameAs(writeOptions); in writeOptions() 748 assertThat(txnWriteOptions).isNotSameAs(writeOptions); in writeOptions() 875 protected final WriteOptions writeOptions; field in AbstractTransactionTest.DBContainer 880 public DBContainer(final WriteOptions writeOptions, in DBContainer() argument 884 this.writeOptions = writeOptions; in DBContainer() 893 final WriteOptions writeOptions); in beginTransaction() argument
|
| D | WalFilterTest.java | 64 try (final WriteOptions writeOptions = new WriteOptions()) { in walFilter() argument 71 db.write(writeOptions, batch); in walFilter()
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | OptimisticTransactionSample.java | 24 try (final WriteOptions writeOptions = new WriteOptions(); in main() argument 32 readCommitted(txnDb, writeOptions, readOptions); in main() 41 repeatableRead(txnDb, writeOptions, readOptions); in main() 59 final WriteOptions writeOptions, final ReadOptions readOptions) in readCommitted() argument 68 try(final Transaction txn = txnDb.beginTransaction(writeOptions)) { in readCommitted() 83 txnDb.put(writeOptions, key2, value2); in readCommitted() 94 final WriteOptions writeOptions, final ReadOptions readOptions) in repeatableRead() argument 104 txnDb.beginTransaction(writeOptions, txnOptions)) { in repeatableRead() 109 txnDb.put(writeOptions, key1, value1); in repeatableRead() 153 txnDb.beginTransaction(writeOptions, txnOptions)) { in readCommitted_monotonicAtomicViews() [all …]
|
| D | TransactionSample.java | 25 try (final WriteOptions writeOptions = new WriteOptions(); in main() argument 33 readCommitted(txnDb, writeOptions, readOptions); in main() 42 repeatableRead(txnDb, writeOptions, readOptions); in main() 60 final WriteOptions writeOptions, final ReadOptions readOptions) in readCommitted() argument 84 txnDb.put(writeOptions, key2, value2); in readCommitted() 95 final WriteOptions writeOptions, final ReadOptions readOptions) in repeatableRead() argument 105 txnDb.beginTransaction(writeOptions, txnOptions)) { in repeatableRead() 110 txnDb.put(writeOptions, key1, value1); in repeatableRead() 138 final TransactionDB txnDb, final WriteOptions writeOptions, in readCommitted_monotonicAtomicViews() argument 150 txnDb.beginTransaction(writeOptions, txnOptions)) { in readCommitted_monotonicAtomicViews() [all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | OptimisticTransactionDB.java | 146 public Transaction beginTransaction(final WriteOptions writeOptions) { in beginTransaction() argument 148 writeOptions.nativeHandle_)); in beginTransaction() 152 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 155 writeOptions.nativeHandle_, in beginTransaction() 166 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 169 writeOptions.nativeHandle_, oldTransaction.nativeHandle_); in beginTransaction() 180 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 184 writeOptions.nativeHandle_, optimisticTransactionOptions.nativeHandle_, in beginTransaction()
|
| D | TransactionDB.java | 155 public Transaction beginTransaction(final WriteOptions writeOptions) { in beginTransaction() argument 157 writeOptions.nativeHandle_)); in beginTransaction() 161 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 164 writeOptions.nativeHandle_, transactionOptions.nativeHandle_)); in beginTransaction() 174 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 177 writeOptions.nativeHandle_, oldTransaction.nativeHandle_); in beginTransaction() 188 public Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 192 writeOptions.nativeHandle_, transactionOptions.nativeHandle_, in beginTransaction()
|
| D | TransactionalDB.java | 21 Transaction beginTransaction(final WriteOptions writeOptions); in beginTransaction() argument 33 Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 49 Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument 66 Transaction beginTransaction(final WriteOptions writeOptions, in beginTransaction() argument
|
| D | Transaction.java | 1570 final WriteOptions writeOptions = in getWriteOptions() local 1572 return writeOptions; in getWriteOptions() 1580 public void setWriteOptions(final WriteOptions writeOptions) { in setWriteOptions() argument 1582 setWriteOptions(nativeHandle_, writeOptions.nativeHandle_); in setWriteOptions()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | BytewiseComparatorTest.java | 229 final WriteOptions writeOptions = new WriteOptions()) { in doRandomIterationTest() 242 db.put(writeOptions, bytes(key), bytes(key)); in doRandomIterationTest() 249 db.delete(writeOptions, bytes(key)); in doRandomIterationTest()
|