/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/ |
H A D | SecondaryCursor.java | 228 lockMode == LockMode.RMW) { in delete() 439 getLockPrimaryOnly(lockMode, data)); in getFirst() 521 getLockPrimaryOnly(lockMode, data)); in getLast() 778 lockMode); in getNextNoDup() 1155 lockMode); in getSearchKey() 1239 lockMode); in getSearchKeyRange() 1308 lockMode); in getSearchBoth() 1383 lockMode); in getSearchBothRange() 1519 final LockMode lockMode, in retrieveNext() argument 1535 key, pKey, data, lockMode, in retrieveNext() [all …]
|
H A D | Cursor.java | 914 final LockMode lockMode) in getCurrent() argument 973 final LockMode lockMode) in getFirst() argument 1026 final LockMode lockMode) in getLast() argument 1083 final LockMode lockMode) in getNext() argument 1141 final LockMode lockMode) in getNextDup() argument 1199 final LockMode lockMode) in getNextNoDup() argument 1260 final LockMode lockMode) in getPrev() argument 1318 final LockMode lockMode) in getPrevDup() argument 1758 lockMode); in getSearchBothRange() 4708 } else if (lockMode == null || lockMode == LockMode.DEFAULT) { in getLockType() [all …]
|
H A D | DiskOrderedCursor.java | 262 final LockMode lockMode) in getCurrent() argument 268 checkLockMode(lockMode); in getCurrent() 320 final LockMode lockMode) in getNext() argument 326 checkLockMode(lockMode); in getNext() 327 trace(Level.FINEST, "DiskOrderedCursor.getNext: ", lockMode); in getNext() 353 private void checkLockMode(final LockMode lockMode) { in checkLockMode() argument 354 if (lockMode == null || in checkLockMode() 355 lockMode == LockMode.READ_UNCOMMITTED) { in checkLockMode() 380 final LockMode lockMode) { in trace() argument 384 if (lockMode != null) { in trace() [all …]
|
/dports/databases/db5/db-5.3.28/lang/java/src/com/sleepycat/util/keyrange/ |
H A D | RangeCursor.java | 266 status = doGetFirst(lockMode); in getFirst() 338 status = doGetLast(lockMode); in getLast() 380 status = doGetLast(lockMode); in getLast() 423 status = doGetNext(lockMode); in getNext() 445 status = doGetNextDup(lockMode); in getNext() 509 status = doGetPrev(lockMode); in getPrev() 531 status = doGetPrevDup(lockMode); in getPrev() 744 status = doGetNextDup(lockMode); in getNextDup() 759 status = doGetNextDup(lockMode); in getNextDup() 777 status = doGetPrevDup(lockMode); in getPrevDup() [all …]
|
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/util/keyrange/ |
H A D | RangeCursor.java | 266 status = doGetFirst(lockMode); in getFirst() 349 status = doGetLast(lockMode); in getLast() 390 return doGetLast(lockMode); in getLastInKeyRange() 452 status = doGetLast(lockMode); in getLastInKeyRange() 486 return doGetSearchBoth(lockMode); in getLastInPKeyRange() 495 return doGetSearchKey(lockMode); in getLastInPKeyRange() 614 status = doGetNext(lockMode); in getNext() 636 status = doGetNextDup(lockMode); in getNext() 700 status = doGetPrev(lockMode); in getPrev() 722 status = doGetPrevDup(lockMode); in getPrev() [all …]
|
/dports/databases/db5/db-5.3.28/lang/java/src/com/sleepycat/db/ |
H A D | SecondaryCursor.java | 127 LockMode lockMode) in getCurrent() argument 170 LockMode lockMode) in getFirst() argument 212 LockMode lockMode) in getLast() argument 261 LockMode lockMode) in getNext() argument 304 LockMode lockMode) in getNextDup() argument 352 LockMode lockMode) in getNextNoDup() argument 400 LockMode lockMode) in getPrev() argument 442 LockMode lockMode) in getPrevDup() argument 519 LockMode lockMode) in getPrevNoDup() argument 607 LockMode lockMode) in getSearchKey() argument [all …]
|
H A D | Cursor.java | 259 LockMode.getFlag(lockMode) | in getCurrent() 298 LockMode.getFlag(lockMode) | in getFirst() 336 LockMode.getFlag(lockMode) | in getLast() 381 LockMode.getFlag(lockMode) | in getNext() 420 LockMode.getFlag(lockMode) | in getNextDup() 464 LockMode.getFlag(lockMode) | in getNextNoDup() 508 LockMode.getFlag(lockMode) | in getPrev() 546 LockMode.getFlag(lockMode) | in getPrevDup() 589 LockMode.getFlag(lockMode) | in getPrevNoDup() 626 LockMode.getFlag(lockMode) | in getRecordNumber() [all …]
|
/dports/databases/db18/db-18.1.40/lang/java/src/com/sleepycat/db/ |
H A D | SecondaryCursor.java | 135 LockMode lockMode) in getCurrent() argument 178 LockMode lockMode) in getFirst() argument 220 LockMode lockMode) in getLast() argument 269 LockMode lockMode) in getNext() argument 312 LockMode lockMode) in getNextDup() argument 360 LockMode lockMode) in getNextNoDup() argument 408 LockMode lockMode) in getPrev() argument 450 LockMode lockMode) in getPrevDup() argument 527 LockMode lockMode) in getPrevNoDup() argument 615 LockMode lockMode) in getSearchKey() argument [all …]
|
H A D | Cursor.java | 252 LockMode.getFlag(lockMode) | in getCurrent() 291 LockMode.getFlag(lockMode) | in getFirst() 329 LockMode.getFlag(lockMode) | in getLast() 374 LockMode.getFlag(lockMode) | in getNext() 413 LockMode.getFlag(lockMode) | in getNextDup() 457 LockMode.getFlag(lockMode) | in getNextNoDup() 501 LockMode.getFlag(lockMode) | in getPrev() 539 LockMode.getFlag(lockMode) | in getPrevDup() 582 LockMode.getFlag(lockMode) | in getPrevNoDup() 619 LockMode.getFlag(lockMode) | in getRecordNumber() [all …]
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
H A D | resource_lock.c | 48 LOCKMODE lockMode; member 199 if (lockMode == RowExclusiveLock) in lock_shard_resources() 230 LockShardResource(shardId, lockMode); in lock_shard_resources() 757 LockShardResource(shardId, lockMode); in LockShardListResources() 779 LockShardResource(shardId, lockMode); in LockRelationShardResources() 815 LOCKMODE lockMode = -1; in LockModeTextToLockMode() local 822 lockMode = lockMap->lockMode; in LockModeTextToLockMode() 828 if (lockMode == -1) in LockModeTextToLockMode() 835 return lockMode; in LockModeTextToLockMode() 853 if (lockMode == lockMap->lockMode) in LockModeToLockModeText() [all …]
|
/dports/databases/db5/db-5.3.28/lang/java/src/com/sleepycat/persist/ |
H A D | BasicCursor.java | 50 public V first(LockMode lockMode) in first() argument 62 public V last(LockMode lockMode) in last() argument 74 public V next(LockMode lockMode) in next() argument 86 public V nextDup(LockMode lockMode) in nextDup() argument 99 public V nextNoDup(LockMode lockMode) in nextNoDup() argument 111 public V prev(LockMode lockMode) in prev() argument 123 public V prevDup(LockMode lockMode) in prevDup() argument 136 public V prevNoDup(LockMode lockMode) in prevNoDup() argument 148 public V current(LockMode lockMode) in current() argument 168 public Iterator<V> iterator(LockMode lockMode) { in iterator() argument [all …]
|
H A D | EntityCursor.java | 301 V first(LockMode lockMode) in first() argument 330 V last(LockMode lockMode) in last() argument 363 V next(LockMode lockMode) in next() argument 400 V nextDup(LockMode lockMode) in nextDup() argument 435 V nextNoDup(LockMode lockMode) in nextNoDup() argument 468 V prev(LockMode lockMode) in prev() argument 505 V prevDup(LockMode lockMode) in prevDup() argument 540 V prevNoDup(LockMode lockMode) in prevNoDup() argument 575 V current(LockMode lockMode) in current() argument 623 Iterator<V> iterator(LockMode lockMode); in iterator() argument
|
H A D | BasicIterator.java | 26 private LockMode lockMode; field in BasicIterator 32 BasicIterator(EntityCursor<V> entityCursor, LockMode lockMode) { in BasicIterator() argument 35 this.lockMode = lockMode; in BasicIterator() 41 BasicIterator(ForwardCursor<V> forwardCursor, LockMode lockMode) { in BasicIterator() argument 43 this.lockMode = lockMode; in BasicIterator() 49 nextValue = forwardCursor.next(lockMode); in hasNext()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
H A D | distributed_execution_locks.c | 95 LOCKMODE lockMode = NoLock; in AcquireExecutorMultiShardLocks() local 131 lockMode = RowExclusiveLock; in AcquireExecutorMultiShardLocks() 141 lockMode = ExclusiveLock; in AcquireExecutorMultiShardLocks() 252 LOCKMODE lockMode = NoLock; in AcquireExecutorShardLockForRowModify() local 268 lockMode = NoLock; in AcquireExecutorShardLockForRowModify() 281 lockMode = RowExclusiveLock; in AcquireExecutorShardLockForRowModify() 289 lockMode = NoLock; in AcquireExecutorShardLockForRowModify() 305 lockMode = RowExclusiveLock; in AcquireExecutorShardLockForRowModify() 326 lockMode = RowExclusiveLock; in AcquireExecutorShardLockForRowModify() 343 lockMode = ExclusiveLock; in AcquireExecutorShardLockForRowModify() [all …]
|
/dports/databases/db18/db-18.1.40/lang/java/src/com/sleepycat/persist/ |
H A D | BasicCursor.java | 53 public V first(LockMode lockMode) in first() argument 66 public V last(LockMode lockMode) in last() argument 79 public V next(LockMode lockMode) in next() argument 92 public V nextDup(LockMode lockMode) in nextDup() argument 106 public V nextNoDup(LockMode lockMode) in nextNoDup() argument 120 public V prev(LockMode lockMode) in prev() argument 133 public V prevDup(LockMode lockMode) in prevDup() argument 147 public V prevNoDup(LockMode lockMode) in prevNoDup() argument 161 public V current(LockMode lockMode) in current() argument 183 public Iterator<V> iterator(LockMode lockMode) { in iterator() argument [all …]
|
H A D | EntityCursor.java | 302 V first(LockMode lockMode) in first() argument 331 V last(LockMode lockMode) in last() argument 364 V next(LockMode lockMode) in next() argument 401 V nextDup(LockMode lockMode) in nextDup() argument 436 V nextNoDup(LockMode lockMode) in nextNoDup() argument 469 V prev(LockMode lockMode) in prev() argument 506 V prevDup(LockMode lockMode) in prevDup() argument 541 V prevNoDup(LockMode lockMode) in prevNoDup() argument 576 V current(LockMode lockMode) in current() argument 625 Iterator<V> iterator(LockMode lockMode); in iterator() argument
|
H A D | BasicIterator.java | 26 private LockMode lockMode; field in BasicIterator 32 BasicIterator(EntityCursor<V> entityCursor, LockMode lockMode) { in BasicIterator() argument 35 this.lockMode = lockMode; in BasicIterator() 41 BasicIterator(ForwardCursor<V> forwardCursor, LockMode lockMode) { in BasicIterator() argument 43 this.lockMode = lockMode; in BasicIterator() 49 nextValue = forwardCursor.next(lockMode); in hasNext()
|
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/persist/ |
H A D | BasicCursor.java | 53 public V first(LockMode lockMode) in first() argument 65 public V last(LockMode lockMode) in last() argument 77 public V next(LockMode lockMode) in next() argument 89 public V nextDup(LockMode lockMode) in nextDup() argument 102 public V nextNoDup(LockMode lockMode) in nextNoDup() argument 114 public V prev(LockMode lockMode) in prev() argument 126 public V prevDup(LockMode lockMode) in prevDup() argument 139 public V prevNoDup(LockMode lockMode) in prevNoDup() argument 151 public V current(LockMode lockMode) in current() argument 204 public Iterator<V> iterator(LockMode lockMode) { in iterator() argument [all …]
|
H A D | EntityCursor.java | 326 V first(LockMode lockMode) in first() argument 371 V last(LockMode lockMode) in last() argument 420 V next(LockMode lockMode) in next() argument 473 V nextDup(LockMode lockMode) in nextDup() argument 524 V nextNoDup(LockMode lockMode) in nextNoDup() argument 573 V prev(LockMode lockMode) in prev() argument 626 V prevDup(LockMode lockMode) in prevDup() argument 677 V prevNoDup(LockMode lockMode) in prevNoDup() argument 728 V current(LockMode lockMode) in current() argument 1004 Iterator<V> iterator(LockMode lockMode); in iterator() argument
|
H A D | BasicIterator.java | 26 private LockMode lockMode; field in BasicIterator 32 BasicIterator(EntityCursor<V> entityCursor, LockMode lockMode) { in BasicIterator() argument 35 this.lockMode = lockMode; in BasicIterator() 41 BasicIterator(ForwardCursor<V> forwardCursor, LockMode lockMode) { in BasicIterator() argument 43 this.lockMode = lockMode; in BasicIterator() 49 nextValue = forwardCursor.next(lockMode); in hasNext()
|
/dports/databases/cego/cego-2.47.11/src/ |
H A D | CegoLockHandler.cc | 322 if ( lockMode == READ ) in lockRecord() 336 Chain lockMode; in lockRecord() local 420 if ( lockMode == READ ) in lockRBRecord() 434 Chain lockMode; in lockRBRecord() local 535 Chain lockMode; in lockSysRecord() local 634 Chain lockMode; in lockSysPage() local 764 Chain lockMode; in lockDataPage() local 868 Chain lockMode; in lockIndexPage() local 974 Chain lockMode; in lockRBPage() local 1070 Chain lockMode; in lockDataFile() local [all …]
|
H A D | CegoLockHandler.h | 46 unsigned long long lockRecord(const CegoDataPointer& dp, enum LockMode lockMode); 49 unsigned long long lockRBRecord(const CegoDataPointer& dp, enum LockMode lockMode); 52 unsigned long long lockSysRecord(const CegoDataPointer& dp, enum LockMode lockMode); 55 unsigned long long lockSysPage(PageIdType pageId, enum LockMode lockMode); 58 …nsigned long long lockData(CegoObject::ObjectType type, PageIdType pageId, enum LockMode lockMode); 61 void lockDataFile(int fileId, enum LockMode lockMode); 64 void lockBufferPool(int hashId, enum LockMode lockMode); 75 unsigned long long lockDataPage(PageIdType pageId, enum LockMode lockMode); 78 unsigned long long lockIndexPage(PageIdType pageId, enum LockMode lockMode); 81 unsigned long long lockRBPage(PageIdType pageId, enum LockMode lockMode);
|
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
H A D | resource_lock.h | 114 extern void LockShardDistributionMetadata(int64 shardId, LOCKMODE lockMode); 133 extern void LockColocationId(int colocationId, LOCKMODE lockMode); 134 extern void UnlockColocationId(int colocationId, LOCKMODE lockMode); 137 extern void LockShardListMetadata(List *shardIntervalList, LOCKMODE lockMode); 139 LOCKMODE lockMode); 141 extern void LockTransactionRecovery(LOCKMODE lockMode); 143 extern void SerializeNonCommutativeWrites(List *shardIntervalList, LOCKMODE lockMode); 144 extern void LockRelationShardResources(List *relationShardList, LOCKMODE lockMode); 148 extern void LockParentShardResourceIfPartition(uint64 shardId, LOCKMODE lockMode); 152 extern const char * LockModeToLockModeText(LOCKMODE lockMode);
|
/dports/databases/db5/db-5.3.28/lang/java/src/com/sleepycat/collections/ |
H A D | DataCursor.java | 238 LockMode lockMode = getLockMode(lockForWrite); in repositionRange() local 294 LockMode lockMode = getLockMode(lockForWrite); in repositionExact() local 419 LockMode lockMode = getLockMode(lockForWrite); in getFirst() local 424 lockMode); in getFirst() 434 LockMode lockMode = getLockMode(lockForWrite); in getNext() local 439 lockMode); in getNext() 449 LockMode lockMode = getLockMode(lockForWrite); in getNextNoDup() local 506 LockMode lockMode = getLockMode(lockForWrite); in getPrevNoDup() local 565 LockMode lockMode = getLockMode(lockForWrite); in doGetSearchKey() local 583 LockMode lockMode = getLockMode(lockForWrite); in getSearchKeyRange() local [all …]
|
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/collections/ |
H A D | DataCursor.java | 238 LockMode lockMode = getLockMode(lockForWrite); in repositionRange() local 294 LockMode lockMode = getLockMode(lockForWrite); in repositionExact() local 419 LockMode lockMode = getLockMode(lockForWrite); in getFirst() local 424 lockMode); in getFirst() 434 LockMode lockMode = getLockMode(lockForWrite); in getNext() local 439 lockMode); in getNext() 449 LockMode lockMode = getLockMode(lockForWrite); in getNextNoDup() local 506 LockMode lockMode = getLockMode(lockForWrite); in getPrevNoDup() local 565 LockMode lockMode = getLockMode(lockForWrite); in doGetSearchKey() local 583 LockMode lockMode = getLockMode(lockForWrite); in getSearchKeyRange() local [all …]
|