| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | TransactionDB.java | 235 private final boolean exclusive; field in TransactionDB.KeyLockInfo
238 final boolean exclusive) { in KeyLockInfo() argument
241 this.exclusive = exclusive; in KeyLockInfo()
268 return exclusive; in isExclusive()
294 final String waitingKey, final boolean exclusive) { in newDeadlockInfo() argument
296 waitingKey, exclusive); in newDeadlockInfo()
303 private final boolean exclusive; field in TransactionDB.DeadlockInfo
306 final String waitingKey, final boolean exclusive) { in DeadlockInfo() argument
310 this.exclusive = exclusive; in DeadlockInfo()
346 return exclusive; in isExclusive()
|
| D | Transaction.java | 445 final ColumnFamilyHandle columnFamilyHandle, final byte[] key, final boolean exclusive, in getForUpdate() argument
449 columnFamilyHandle.nativeHandle_, exclusive, doValidate); in getForUpdate()
472 final boolean exclusive) throws RocksDBException { in getForUpdate() argument
475 columnFamilyHandle.nativeHandle_, exclusive, true /*doValidate*/); in getForUpdate()
523 final boolean exclusive) throws RocksDBException { in getForUpdate() argument
526 nativeHandle_, readOptions.nativeHandle_, key, key.length, exclusive, true /*doValidate*/); in getForUpdate()
1908 final byte key[], final int keyLength, final long columnFamilyHandle, final boolean exclusive, in getForUpdate() argument
1911 final byte key[], final int keyLen, final boolean exclusive, final boolean doValidate) in getForUpdate() argument
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_lock_mgr.cc | 31 bool exclusive; member
38 : exclusive(ex), expiration_time(time) { in LockInfo()
42 : exclusive(lock_info.exclusive), in LockInfo()
289 bool exclusive) { in TryLock() argument
368 lock_info.exclusive, env)) { in AcquireWithTimeout()
447 wait_txn_map_.Insert(id, {wait_ids, cf_id, exclusive, key}); in IncrementWaiters()
534 assert(lock_info.txn_ids.size() == 1 || !lock_info.exclusive); in AcquireLocked()
536 if (lock_info.exclusive || txn_lock_info.exclusive) { in AcquireLocked()
540 lock_info.exclusive = txn_lock_info.exclusive; in AcquireLocked()
550 lock_info.exclusive = txn_lock_info.exclusive; in AcquireLocked()
[all …]
|
| D | transaction_util.h | 30 bool exclusive; member
33 : seq(seq_no), num_writes(0), num_reads(0), exclusive(false) {} in TransactionKeyMapInfo()
40 exclusive |= info.exclusive; in Merge()
|
| D | transaction_base.h | 44 bool read_only, bool exclusive,
69 std::string* value, bool exclusive,
74 PinnableSlice* pinnable_val, bool exclusive,
78 std::string* value, bool exclusive, in GetForUpdate() argument
81 exclusive, do_validate); in GetForUpdate()
261 bool readonly, bool exclusive);
266 bool readonly, bool exclusive);
365 bool read_only, bool exclusive, const bool do_validate = true,
|
| D | transaction_base.cc | 103 bool exclusive, const bool do_validate, in TryLock() argument
117 return TryLock(column_family, str, read_only, exclusive, do_validate, in TryLock()
264 bool exclusive, in GetForUpdate() argument
272 TryLock(column_family, key, true /* read_only */, exclusive, do_validate); in GetForUpdate()
290 bool exclusive, in GetForUpdate() argument
619 bool exclusive) { in TrackKey() argument
621 TrackKey(&tracked_keys_, cfh_id, key, seq, read_only, exclusive); in TrackKey()
626 exclusive); in TrackKey()
635 bool read_only, bool exclusive) { in TrackKey() argument
666 iter->second.exclusive |= exclusive; in TrackKey()
[all …]
|
| D | pessimistic_transaction.cc | 541 bool exclusive, const bool do_validate, in TryLock() argument
565 if (!iter->second.exclusive && exclusive) { in TryLock()
576 s = txn_db_impl_->TryLock(this, cfh_id, key_str, exclusive); in TryLock()
644 TrackKey(cfh_id, key_str, tracked_at_seq, read_only, exclusive); in TryLock()
650 assert(info.exclusive == exclusive); in TryLock()
|
| D | optimistic_transaction.cc | 136 bool exclusive, const bool do_validate, in TryLock() argument
156 TrackKey(cfh_id, key_str, seq, read_only, exclusive); in TryLock()
|
| D | transaction_lock_mgr.h | 77 const std::string& key, Env* env, bool exclusive);
150 const bool& exclusive, Env* const env);
|
| D | optimistic_transaction.h | 54 bool read_only, bool exclusive, const bool do_validate = true,
|
| D | pessimistic_transaction.h | 142 bool read_only, bool exclusive, const bool do_validate = true,
|
| D | pessimistic_transaction_db.cc | 400 bool exclusive) { in TryLock() argument
401 return lock_mgr_.TryLock(txn, cfh_id, key, GetEnv(), exclusive); in TryLock()
|
| D | pessimistic_transaction_db.h | 101 const std::string& key, bool exclusive);
|
| D | transaction_test.cc | 394 ASSERT_FALSE(cf_iterator->second.exclusive); in TEST_P()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | transaction.h | 256 bool exclusive = true,
264 bool exclusive = true,
268 return GetForUpdate(options, column_family, key, null_str, exclusive,
272 pinnable_val->GetSelf(), exclusive, do_validate);
279 std::string* value, bool exclusive = true,
|
| D | transaction_db.h | 198 bool exclusive; member
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 722 bool exclusive = options.exclusive_manual_compaction; in CompactRange() local
732 final_output_level, options, begin, end, exclusive, in CompactRange()
810 exclusive, false, max_file_num_to_ignore); in CompactRange()
1425 const Slice* end, bool exclusive, bool disallow_trivial_move, in RunManualCompaction() argument
1443 manual.exclusive = exclusive; in RunManualCompaction()
1484 if (exclusive) { in RunManualCompaction()
1520 assert(!exclusive || !manual_conflict); in RunManualCompaction()
2975 if (m->exclusive) { in ShouldntRunManualCompaction()
3003 if ((*it)->exclusive) { in HaveManualCompaction()
3021 if ((*it)->exclusive) { in HasExclusiveManualCompaction()
[all …]
|
| D | db_impl.h | 578 bool exclusive, bool disallow_trivial_move,
1288 bool exclusive; // current behavior of only one manual member
|
| /rocksdb-6.9/ |
| D | LICENSE.Apache | 69 worldwide, non-exclusive, no-charge, royalty-free, irrevocable
76 worldwide, non-exclusive, no-charge, royalty-free, irrevocable
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-04-21-indexing-sst-files-for-better-lookup-performance.markdown | 16 … below, SST files are sorted based on key. Their key range are mutually exclusive. Instead of scan…
|
| D | 2014-05-14-lock.markdown | 48 …only one single major lock, I was lying. In RocksDB, all LRU caches had exclusive mutexes within t…
|
| /rocksdb-6.9/include/rocksdb/ |
| D | c.h | 1574 const char* key, size_t klen, size_t* vlen, unsigned char exclusive,
1580 size_t* vlen, unsigned char exclusive, char** errptr);
|
| /rocksdb-6.9/db/ |
| D | c.cc | 3993 size_t* vlen, unsigned char exclusive, in rocksdb_transaction_get_for_update() argument
3998 txn->rep->GetForUpdate(options->rep, Slice(key, klen), &tmp, exclusive); in rocksdb_transaction_get_for_update()
4014 size_t* vlen, unsigned char exclusive, char** errptr) { in rocksdb_transaction_get_for_update_cf() argument
4018 Slice(key, klen), &tmp, exclusive); in rocksdb_transaction_get_for_update_cf()
|
| /rocksdb-6.9/docs/ |
| D | LICENSE-DOCUMENTATION | 137 non-sublicensable, non-exclusive, irrevocable license to
|
| /rocksdb-6.9/java/rocksjni/ |
| D | portal.h | 5712 const bool exclusive) { in newDeadlockInfo() argument
5735 jwaiting_key, exclusive); in newDeadlockInfo()
5842 jkey, jtransactions_ids, key_lock_info.exclusive); in construct()
|