/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/txn/ |
H A D | SyncedLockManager.java | 29 public Set<LockInfo> getOwners(Long lsn) { in getOwners() argument 43 public boolean isLockUncontended(Long lsn) { in isLockUncontended() argument 54 Lock lookupLock(Long lsn) { in lookupLock() argument 65 LockAttemptResult attemptLock(Long lsn, in attemptLock() argument 87 long lsn, in getTimeoutInfo() argument 120 void demote(long lsn, Locker locker) { in demote() argument 131 boolean isLocked(Long lsn) { in isLocked() argument 167 int nWaiters(Long lsn) { in nWaiters() argument 179 int nOwners(Long lsn) { in nOwners() argument 191 Locker getWriteOwnerLocker(Long lsn) { in getWriteOwnerLocker() argument [all …]
|
H A D | DummyLockManager.java | 42 public Set<LockInfo> getOwners(Long lsn) { in getOwners() argument 60 Lock lookupLock(Long lsn) in lookupLock() argument 71 LockAttemptResult attemptLock(Long lsn, in attemptLock() argument 92 long lsn, in getTimeoutInfo() argument 139 void demote(long lsn, Locker locker) in demote() argument 153 boolean isLocked(Long lsn) in isLocked() argument 183 int nWaiters(Long lsn) in nWaiters() argument 193 int nOwners(Long lsn) in nOwners() argument 203 Locker getWriteOwnerLocker(Long lsn) in getWriteOwnerLocker() argument 213 boolean validateOwnership(Long lsn, in validateOwnership() argument [all …]
|
H A D | LockManager.java | 188 int getLockTableIndex(Long lsn) { in getLockTableIndex() argument 193 int getLockTableIndex(long lsn) { in getLockTableIndex() argument 238 public LockGrantType lock(long lsn, in lock() argument 280 Long nid = Long.valueOf(lsn); in lockInternal() 461 abstract Lock lookupLock(Long lsn) in lookupLock() argument 534 long lsn, in makeTimeoutException() argument 586 long lsn, in getTimeoutInfo() argument 601 long lsn, in getTimeoutInfoInternal() argument 874 boolean isOwnerInternal(Long lsn, in isOwnerInternal() argument 915 abstract int nWaiters(Long lsn) in nWaiters() argument [all …]
|
/dports/textproc/htdig/htdig-3.2.0b6/db/ |
H A D | log_put.c | 55 DB_LSN *lsn; 86 DB_LSN *lsn; 107 lsn->file = lp->lsn.file; 108 lsn->offset = lp->lsn.offset; 141 lsn->file = lp->lsn.file; 142 lsn->offset = lp->lsn.offset; 157 lsn->file = lp->lsn.file; 158 lsn->offset = lp->lsn.offset; 299 if (lsn->file > lp->lsn.file || 300 (lsn->file == lp->lsn.file && [all …]
|
/dports/textproc/mifluz/mifluz-0.26.0/db/ |
H A D | log_put.c | 61 DB_LSN *lsn; 97 DB_LSN *lsn; 116 lsn->file = lp->lsn.file; 117 lsn->offset = lp->lsn.offset; 150 lsn->file = lp->lsn.file; 151 lsn->offset = lp->lsn.offset; 170 lsn->file = lp->lsn.file; 171 lsn->offset = lp->lsn.offset; 303 if (lsn->file > lp->lsn.file || 304 (lsn->file == lp->lsn.file && [all …]
|
/dports/sysutils/libcdio-paranoia/libcdio-paranoia-10.2+2.0.1/test/cdda_interface/ |
H A D | toc.c | 63 lsn_t lsn = 0; in testit() local 75 lsn = cdda_disc_firstsector(d); in testit() 76 if ( lsn != 0 ) { in testit() 81 lsn = cdda_disc_lastsector(d); in testit() 82 if ( lsn != 301 ) { in testit() 89 lsn = cdda_track_firstsector(d, 0); in testit() 90 if ( lsn != -402 ) { in testit() 95 lsn = cdda_track_lastsector(d, 0); in testit() 96 if ( lsn != -402 ) { in testit() 104 if ( lsn != 0 ) { in testit() [all …]
|
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/tree/ |
H A D | ChildReference.java | 29 private long lsn; field in ChildReference 52 long lsn, in ChildReference() argument 59 long lsn, in init() argument 63 this.lsn = lsn; in init() 104 if (lsn == DbLsn.NULL_LSN) { in fetchTarget() 198 return lsn; in getLsn() 206 public void setLsn(long lsn) { in setLsn() argument 207 this.lsn = lsn; in setLsn() 215 if ((lsn == DbLsn.NULL_LSN) && in updateLsnAfterOptionalLog() 223 setLsn(lsn); in updateLsnAfterOptionalLog() [all …]
|
/dports/databases/tarantool-c/tarantool-c-0ab37e8/tntrpl/ |
H A D | tnt_dir.c | 70 int *top, char *name, uint64_t lsn) in tnt_dir_put() argument 79 current->lsn = lsn; in tnt_dir_put() 90 if (a->lsn == b->lsn) in tnt_dir_cmp() 92 return (a->lsn > b->lsn) ? 1: -1; in tnt_dir_cmp() 128 uint64_t lsn = strtoll(de.d_name, &ext, 10); in tnt_dir_scan() local 129 if (lsn == LLONG_MAX || lsn == LLONG_MIN) in tnt_dir_scan() 132 rc = tnt_dir_put(d, &top, de.d_name, lsn); in tnt_dir_scan() 154 *out = d->files[d->count -1].lsn; in tnt_dir_match_gt() 164 if (d->files[current].lsn <= lsn && lsn <= d->files[current + 1].lsn) { in tnt_dir_match_inc() 165 *out = d->files[current].lsn; in tnt_dir_match_inc() [all …]
|
/dports/benchmarks/nosqlbench/nosqlbench-0.0.20151214/third_party/tarantool-c/tntrpl/ |
H A D | tnt_dir.c | 70 int *top, char *name, uint64_t lsn) in tnt_dir_put() argument 79 current->lsn = lsn; in tnt_dir_put() 90 if (a->lsn == b->lsn) in tnt_dir_cmp() 92 return (a->lsn > b->lsn) ? 1: -1; in tnt_dir_cmp() 128 uint64_t lsn = strtoll(de.d_name, &ext, 10); in tnt_dir_scan() local 129 if (lsn == LLONG_MAX || lsn == LLONG_MIN) in tnt_dir_scan() 132 rc = tnt_dir_put(d, &top, de.d_name, lsn); in tnt_dir_scan() 154 *out = d->files[d->count -1].lsn; in tnt_dir_match_gt() 164 if (d->files[current].lsn <= lsn && lsn <= d->files[current + 1].lsn) { in tnt_dir_match_inc() 165 *out = d->files[current].lsn; in tnt_dir_match_inc() [all …]
|
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/utilint/ |
H A D | DbLsn.java | 68 return lsn == NULL_LSN || isTransient(lsn); in isTransientOrNull() 71 public static long longToLsn(Long lsn) { in longToLsn() argument 72 if (lsn == null) { in longToLsn() 76 return lsn.longValue(); in longToLsn() 83 public static long getFileNumber(long lsn) { in getFileNumber() argument 84 return (lsn >> 32) & INT_MASK; in getFileNumber() 91 public static long getFileOffset(long lsn) { in getFileOffset() argument 92 return (lsn & INT_MASK); in getFileOffset() 103 return (int) getFileOffset(lsn); in getFileOffsetAsInt() 136 public static String toString(long lsn) { in toString() argument [all …]
|
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/vlsn/ |
H A D | VLSNBucketTest.java | 75 assertEquals(vals.get(0).lsn, in testBasic() 77 assertEquals(vals.get(2).lsn, in testBasic() 79 assertEquals(vals.get(2).lsn, in testBasic() 119 assertEquals(vals.get(0).lsn, in checkAccess() 127 assertEquals(vals.get(3).lsn, in checkAccess() 132 assertEquals(vals.get(0).lsn, in checkAccess() 134 assertEquals(vals.get(3).lsn, in checkAccess() 138 assertEquals(vals.get(3).lsn, in checkAccess() 142 assertEquals(vals.get(5).lsn, in checkAccess() 316 p.lsn, lsn); in testRemoveFromTail() [all …]
|
/dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/recovery/ |
H A D | RollbackTracker.java | 273 void setCheckpointStart(long lsn) { in setCheckpointStart() argument 274 checkpointStart = lsn; in setCheckpointStart() 333 for (Long lsn : rollbackLsns) { in setInvisible() 349 perFileLsns.add(lsn); in setInvisible() 536 (lsn, txnId) : in positionAndCheck() 923 boolean contains(long lsn) { in contains() argument 932 void positionChildren(long lsn) { in positionChildren() argument 959 if (containsLN(lsn, txnId)) { in findTarget() 983 return lsn + " [" + DbLsn.getNoFormatString(lsn) + in bracketFailure() 994 boolean follows(long lsn) { in follows() argument [all …]
|
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/innobase/log/ |
H A D | log0log.cc | 143 lsn_t lsn; in log_buf_pool_get_oldest_modification() local 149 if (!lsn) { in log_buf_pool_get_oldest_modification() 151 lsn = log_sys.lsn; in log_buf_pool_get_oldest_modification() 416 lsn = log_sys.lsn; in log_close() 1152 lsn = log_sys.lsn; in log_buffer_sync_in_background() 1182 lsn = log_sys.lsn; in log_flush_margin() 1877 lsn = log_sys.lsn; in logs_empty_and_mark_files_at_shutdown() 1904 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1928 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1941 *lsn = log_sys.lsn; in log_peek_lsn() [all …]
|
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/innobase/log/ |
H A D | log0log.cc | 143 lsn_t lsn; in log_buf_pool_get_oldest_modification() local 149 if (!lsn) { in log_buf_pool_get_oldest_modification() 151 lsn = log_sys.lsn; in log_buf_pool_get_oldest_modification() 416 lsn = log_sys.lsn; in log_close() 1152 lsn = log_sys.lsn; in log_buffer_sync_in_background() 1182 lsn = log_sys.lsn; in log_flush_margin() 1877 lsn = log_sys.lsn; in logs_empty_and_mark_files_at_shutdown() 1904 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1928 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1941 *lsn = log_sys.lsn; in log_peek_lsn() [all …]
|
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/innobase/log/ |
H A D | log0log.cc | 143 lsn_t lsn; in log_buf_pool_get_oldest_modification() local 149 if (!lsn) { in log_buf_pool_get_oldest_modification() 151 lsn = log_sys.lsn; in log_buf_pool_get_oldest_modification() 419 lsn = log_sys.lsn; in log_close() 1157 lsn = log_sys.lsn; in log_buffer_sync_in_background() 1187 lsn = log_sys.lsn; in log_flush_margin() 1882 lsn = log_sys.lsn; in logs_empty_and_mark_files_at_shutdown() 1909 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1933 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1946 *lsn = log_sys.lsn; in log_peek_lsn() [all …]
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/innobase/log/ |
H A D | log0log.cc | 143 lsn_t lsn; in log_buf_pool_get_oldest_modification() local 149 if (!lsn) { in log_buf_pool_get_oldest_modification() 151 lsn = log_sys.lsn; in log_buf_pool_get_oldest_modification() 419 lsn = log_sys.lsn; in log_close() 1157 lsn = log_sys.lsn; in log_buffer_sync_in_background() 1187 lsn = log_sys.lsn; in log_flush_margin() 1882 lsn = log_sys.lsn; in logs_empty_and_mark_files_at_shutdown() 1909 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1933 ut_a(lsn == log_sys.lsn in logs_empty_and_mark_files_at_shutdown() 1946 *lsn = log_sys.lsn; in log_peek_lsn() [all …]
|
/dports/sysutils/libcdio/libcdio-2.1.0/test/driver/ |
H A D | track.c | 68 lsn_t lsn; in main() local 87 for(lsn=0; lsn<10; lsn++) { in main() 88 i_track = cdio_get_track(cdObj, lsn); in main() 90 printf("LSN %d should return 1. Got %d\n", lsn, i_track); in main() 101 for(lsn=301; lsn > 300; lsn--) { in main() 102 i_track = cdio_get_track(cdObj, lsn); in main() 104 printf("LSN %d should return 1. Got %d\n", lsn, i_track); in main()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/innobase/log/ |
H A D | log0log.cc | 151 lsn_t lsn; in log_buf_pool_get_oldest_modification() local 157 if (!lsn) { in log_buf_pool_get_oldest_modification() 159 lsn = log_sys->lsn; in log_buf_pool_get_oldest_modification() 494 lsn = log->lsn; in log_close() 709 group->lsn = lsn; in log_group_set_fields() 1443 lsn = log_sys->lsn; in log_buffer_sync_in_background() 1474 lsn = log->lsn; in log_flush_margin() 2285 lsn = log_sys->lsn; in logs_empty_and_mark_files_at_shutdown() 2342 ut_a(lsn == log_sys->lsn); in logs_empty_and_mark_files_at_shutdown() 2365 ut_a(lsn == log_sys->lsn); in logs_empty_and_mark_files_at_shutdown() [all …]
|
/dports/databases/mysql57-client/mysql-5.7.36/storage/innobase/log/ |
H A D | log0log.cc | 151 lsn_t lsn; in log_buf_pool_get_oldest_modification() local 157 if (!lsn) { in log_buf_pool_get_oldest_modification() 159 lsn = log_sys->lsn; in log_buf_pool_get_oldest_modification() 494 lsn = log->lsn; in log_close() 709 group->lsn = lsn; in log_group_set_fields() 1443 lsn = log_sys->lsn; in log_buffer_sync_in_background() 1474 lsn = log->lsn; in log_flush_margin() 2285 lsn = log_sys->lsn; in logs_empty_and_mark_files_at_shutdown() 2342 ut_a(lsn == log_sys->lsn); in logs_empty_and_mark_files_at_shutdown() 2365 ut_a(lsn == log_sys->lsn); in logs_empty_and_mark_files_at_shutdown() [all …]
|
/dports/databases/libcouchbase/libcouchbase-2.10.7/tests/iotests/ |
H A D | t_confmon.cc | 137 struct listener2 lsn; in TEST_F() local 138 lsn.io = instance->iotable; in TEST_F() 139 lsn.reset(); in TEST_F() 140 mon->add_listener(&lsn); in TEST_F() 157 runConfmonTest(lsn.io, mon); in TEST_F() 160 ASSERT_EQ(1, lsn.call_count); in TEST_F() 164 lsn.reset(); in TEST_F() 166 runConfmonTest(lsn.io, mon); in TEST_F() 167 ASSERT_EQ(1, lsn.call_count); in TEST_F() 172 lsn.reset(); in TEST_F() [all …]
|
/dports/databases/db18/db-18.1.40/lang/java/src/com/sleepycat/db/ |
H A D | LogCursor.java | 67 logc.get(lsn, data, DbConstants.DB_CURRENT)); in getCurrent() 90 public OperationStatus getNext(final LogSequenceNumber lsn, in getNext() argument 95 logc.get(lsn, data, DbConstants.DB_NEXT)); in getNext() 116 public OperationStatus getFirst(final LogSequenceNumber lsn, in getFirst() argument 121 logc.get(lsn, data, DbConstants.DB_FIRST)); in getFirst() 142 public OperationStatus getLast(final LogSequenceNumber lsn, in getLast() argument 147 logc.get(lsn, data, DbConstants.DB_LAST)); in getLast() 170 public OperationStatus getPrev(final LogSequenceNumber lsn, in getPrev() argument 175 logc.get(lsn, data, DbConstants.DB_PREV)); in getPrev() 195 public OperationStatus set(final LogSequenceNumber lsn, in set() argument [all …]
|
/dports/databases/db5/db-5.3.28/lang/java/src/com/sleepycat/db/ |
H A D | LogCursor.java | 67 logc.get(lsn, data, DbConstants.DB_CURRENT)); in getCurrent() 91 public OperationStatus getNext(final LogSequenceNumber lsn, in getNext() argument 96 logc.get(lsn, data, DbConstants.DB_NEXT)); in getNext() 118 public OperationStatus getFirst(final LogSequenceNumber lsn, in getFirst() argument 123 logc.get(lsn, data, DbConstants.DB_FIRST)); in getFirst() 145 public OperationStatus getLast(final LogSequenceNumber lsn, in getLast() argument 150 logc.get(lsn, data, DbConstants.DB_LAST)); in getLast() 174 public OperationStatus getPrev(final LogSequenceNumber lsn, in getPrev() argument 179 logc.get(lsn, data, DbConstants.DB_PREV)); in getPrev() 200 public OperationStatus set(final LogSequenceNumber lsn, in set() argument [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/fs/xfs/ |
H A D | xfs_trans_ail.c | 41 xfs_lsn_t lsn; in xfs_ail_check() local 58 lsn = lip->li_lsn; in xfs_ail_check() 127 xfs_lsn_t lsn; in xfs_ail_min_lsn() local 133 return lsn; in xfs_ail_min_lsn() 152 return lsn; in xfs_ail_max_lsn() 233 xfs_lsn_t lsn) in xfs_trans_ail_cursor_first() argument 239 if (lsn == 0) { in xfs_trans_ail_cursor_first() 259 xfs_lsn_t lsn) in __xfs_trans_ail_cursor_last() argument 280 xfs_lsn_t lsn) in xfs_trans_ail_cursor_last() argument 298 xfs_lsn_t lsn) in xfs_ail_splice() argument [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/fs/xfs/ |
H A D | xfs_trans_ail.c | 41 xfs_lsn_t lsn; in xfs_ail_check() local 58 lsn = lip->li_lsn; in xfs_ail_check() 127 xfs_lsn_t lsn; in xfs_ail_min_lsn() local 133 return lsn; in xfs_ail_min_lsn() 152 return lsn; in xfs_ail_max_lsn() 233 xfs_lsn_t lsn) in xfs_trans_ail_cursor_first() argument 239 if (lsn == 0) { in xfs_trans_ail_cursor_first() 259 xfs_lsn_t lsn) in __xfs_trans_ail_cursor_last() argument 280 xfs_lsn_t lsn) in xfs_trans_ail_cursor_last() argument 298 xfs_lsn_t lsn) in xfs_ail_splice() argument [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/fs/xfs/ |
H A D | xfs_trans_ail.c | 41 xfs_lsn_t lsn; in xfs_ail_check() local 58 lsn = lip->li_lsn; in xfs_ail_check() 127 xfs_lsn_t lsn; in xfs_ail_min_lsn() local 133 return lsn; in xfs_ail_min_lsn() 152 return lsn; in xfs_ail_max_lsn() 233 xfs_lsn_t lsn) in xfs_trans_ail_cursor_first() argument 239 if (lsn == 0) { in xfs_trans_ail_cursor_first() 259 xfs_lsn_t lsn) in __xfs_trans_ail_cursor_last() argument 280 xfs_lsn_t lsn) in xfs_trans_ail_cursor_last() argument 298 xfs_lsn_t lsn) in xfs_ail_splice() argument [all …]
|