| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/recovery/stepwise/ |
| H A D | CommitEntry.java | 19 private long txnId; field in CommitEntry
21 CommitEntry(long lsn, long txnId) { in CommitEntry()
|
| H A D | TxnalEntry.java | 23 private long txnId; field in TxnalEntry
28 long txnId) { in TxnalEntry()
|
| H A D | TxnalDeletedEntry.java | 23 private long txnId; field in TxnalDeletedEntry
28 long txnId) { in TxnalDeletedEntry()
|
| H A D | EntryTrackerReader.java | 110 long txnId = useLogEntry.getTransactionId(); in processEntry() local
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/recovery/ |
| H A D | RollbackTrackerTest.java | 449 final long txnId; field in RollbackTrackerTest.TxnLogRecord
451 TxnLogRecord(long lsn, long txnId) { in TxnLogRecord()
474 VisibleLN(long ownLSN, long txnId) { in VisibleLN()
497 InvisibleLN(long ownLSN, long txnId) { in InvisibleLN()
525 AlreadyRBLN(long ownLSN, long txnId) { in AlreadyRBLN()
550 Abort(long ownLSN, long txnId) { in Abort()
565 Commit(long ownLSN, long txnId) { in Commit()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/recovery/ |
| H A D | RollbackTracker.java | 251 void checkCommit(long commitLSN, long txnId) { in checkCommit()
454 abstract boolean positionAndCheck(long lsn, long txnId); in positionAndCheck()
461 public void rollback(Long txnId, in rollback()
529 public boolean positionAndCheck(long lsn, long txnId) { in positionAndCheck()
575 public boolean positionAndCheck(long lsn, long txnId) { in positionAndCheck()
928 boolean containsLN(long lsn, long txnId) { in containsLN()
949 RollbackPeriod findTarget(long lsn, long txnId) { in findTarget()
969 boolean notInRollbackStartAndEnd(long lsn, long txnId) { in notInRollbackStartAndEnd()
1006 TxnChain getChain(long txnId, long undoLsn, EnvironmentImpl envImpl) { in getChain()
|
| /dports/net-im/spectral/libQuotient-58dfe74390ebdd8ec6611d3b8fecfe7d051ff955/tests/ |
| H A D | quotest.cpp | 140 bool TestSuite::validatePendingEvent(const QString& txnId) in validatePendingEvent()
328 auto txnId = targetRoom->postPlainText("Hello, " % origin % " is here"); in TEST_IMPL() local
354 const auto txnId = targetRoom->postReaction(targetEvtId, key); in TEST_IMPL() local
396 const auto txnId = in TEST_IMPL() local
430 const QString& txnId, in checkFileSendingOutcome()
494 auto txnId = targetRoom->postPlainText(origin % ": message to redact"); in TEST_IMPL() local
641 auto txnId = room->postHtmlText(plainReport, htmlReport); in conclude() local
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/loggingcpp/ |
| H A D | messagelog.cpp | 217 void logDML(unsigned sessionId, unsigned txnId, const string& statement, const string& owner) in logDML()
232 void logDDL(unsigned sessionId, unsigned txnId, const string& statement, const string& owner) in logDDL()
248 void logCommand(unsigned sessionId, unsigned txnId, const string& statement) in logCommand()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/loggingcpp/ |
| H A D | messagelog.cpp | 217 void logDML(unsigned sessionId, unsigned txnId, const string& statement, const string& owner) in logDML()
232 void logDDL(unsigned sessionId, unsigned txnId, const string& statement, const string& owner) in logDDL()
248 void logCommand(unsigned sessionId, unsigned txnId, const string& statement) in logCommand()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/ |
| H A D | TransactionStats.java | 50 private long txnId; field in TransactionStats.Active
87 public Active(String name, long txnId, long parentId) { in Active()
|
| /dports/net-im/libquotient/libQuotient-0.6.8/lib/csapi/ |
| H A D | room_send.cpp | 12 const QString& txnId, const QJsonObject& body) in SendMessageJob()
|
| H A D | redaction.cpp | 12 const QString& txnId, const QString& reason) in RedactEventJob()
|
| H A D | to_device.cpp | 12 const QString& eventType, const QString& txnId, in SendToDeviceJob()
|
| /dports/net-im/libquotient/libQuotient-0.6.8/tests/ |
| H A D | quotest.cpp | 148 bool TestSuite::validatePendingEvent(const QString& txnId) in validatePendingEvent()
335 auto txnId = targetRoom->postPlainText("Hello, " % origin % " is here"); in TEST_IMPL() local
361 const auto txnId = targetRoom->postReaction(targetEvtId, key); in TEST_IMPL() local
401 const auto txnId = in TEST_IMPL() local
435 const QString& txnId, in checkFileSendingOutcome()
515 auto txnId = targetRoom->postPlainText(origin % ": message to redact"); in TEST_IMPL() local
813 auto txnId = room->postHtmlText(plainReport, htmlReport); in conclude() local
|
| /dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/log/ |
| H A D | LNFileReaderTest.java | 327 long txnId = userTxn.getId(); in createLogFile() local
483 long txnId; field in LNFileReaderTest.CheckInfo
485 CheckInfo(long lsn, LN ln, byte[] key, long txnId) { in CheckInfo()
|
| /dports/net-im/spectral/libQuotient-58dfe74390ebdd8ec6611d3b8fecfe7d051ff955/lib/csapi/ |
| H A D | to_device.cpp | 18 const QString& eventType, const QString& txnId, in SendToDeviceJob()
|
| H A D | room_send.cpp | 24 const QString& txnId, const QJsonObject& body) in SendMessageJob()
|
| H A D | redaction.cpp | 24 const QString& txnId, const QString& reason) in RedactEventJob()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/util/ |
| H A D | DbScavenger.java | 255 final long txnId = entry.getTransactionId(); in checkProcessEntry() local
447 private void setCommittedTxn(final long txnId) { in setCommittedTxn()
455 private boolean isCommittedTxn(final long txnId) { in isCommittedTxn()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/stream/ |
| H A D | FeederTxns.java | 82 public MasterTxn getAckTxn(long txnId) { in getAckTxn()
103 public VLSN noteReplicaAck(final RepNodeImpl replica, final long txnId) { in noteReplicaAck()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/impl/node/ |
| H A D | Feeder.java | 590 long txnId = ((Ack) response).getTxnId(); in runResponseLoop() local
983 final long txnId = record.getCommitTxnId(); in writeAvailableEntries() local
1079 private Message createMessage(long txnId, in createMessage()
1153 private void deemAcked(long txnId) { in deemAcked()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/txn/ |
| H A D | TxnChain.java | 81 long txnId, in TxnChain()
93 long txnId, in TxnChain()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
| H A D | task_runner_test.cpp | 129 auto txnId = _testRunTaskTwice(*this, TaskRunner::NextAction::kDisposeOperationContext); in TEST_F() local
141 auto txnId = in TEST_F() local
147 auto txnId = _testRunTaskTwice(*this, TaskRunner::NextAction::kKeepOperationContext); in TEST_F() local
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/rep/txn/ |
| H A D | ReplayTxn.java | 82 long txnId, in ReplayTxn()
97 long txnId, in ReplayTxn()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | batchinsertprocessor.cpp | 55 …BatchInsertProc(bool isAutocommitOn, uint32_t tableOid, execplan::CalpontSystemCatalog::SCN txnId,… in BatchInsertProc()
95 int32_t txnId = fTxnid; in grabTableLock() local
|