Searched refs:txnNum (Results 1 – 7 of 7) sorted by relevance
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/ |
| H A D | session_test.cpp | 138 const TxnNumber txnNum = 20; in TEST_F() local
156 const TxnNumber txnNum = 21; in TEST_F() local
228 const TxnNumber txnNum = 20; in TEST_F() local
247 const TxnNumber txnNum = 21; in TEST_F() local
262 const TxnNumber txnNum = 100; in TEST_F() local
303 const TxnNumber txnNum = 100; in TEST_F() local
326 const TxnNumber txnNum = 100; in TEST_F() local
353 const TxnNumber txnNum = 100; in TEST_F() local
393 const TxnNumber txnNum = 2; in TEST_F() local
461 const TxnNumber txnNum = 2; in TEST_F() local
[all …]
|
| H A D | session_txn_record.idl | 58 txnNum:
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/s/ |
| H A D | session_catalog_migration_destination.cpp | 64 TxnNumber txnNum; member
108 const auto txnNum = *sessionInfo.getTxnNumber(); in extractPrePostImageTs() local
120 << lastResult.txnNum, in extractPrePostImageTs()
121 lastResult.txnNum == txnNum); in extractPrePostImageTs()
216 result.txnNum = *sessionInfo.getTxnNumber(); in processSessionOplog()
254 opCtx->setTxnNumber(result.txnNum); in processSessionOplog()
258 session->beginTxn(opCtx, result.txnNum); in processSessionOplog()
261 if (session->checkStatementExecuted(opCtx, result.txnNum, stmtId)) { in processSessionOplog()
282 oplogLink.prevOpTime = session->getLastWriteOpTime(result.txnNum); in processSessionOplog()
323 opCtx, result.txnNum, {stmtId}, oplogOpTime, *oplogEntry.getWallClockTime()); in processSessionOplog()
|
| H A D | session_catalog_migration_destination_test.cpp | 185 const TxnNumber& txnNum) { in getSessionWithTxn() argument
187 scopedSession->beginTxn(opCtx, txnNum); in getSessionWithTxn()
396 TxnNumber txnNum(2); in TEST_F() local
398 sessionInfo.setTxnNumber(txnNum++); in TEST_F()
407 sessionInfo.setTxnNumber(txnNum++); in TEST_F()
416 sessionInfo.setTxnNumber(txnNum); in TEST_F()
430 auto session = getSessionWithTxn(opCtx, sessionId, txnNum); in TEST_F()
431 TransactionHistoryIterator historyIter(session->getLastWriteOpTime(txnNum)); in TEST_F()
437 checkStatementExecuted(opCtx, session.get(), txnNum, 5, oplog3); in TEST_F()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
| H A D | idempotency_test_fixture.h | 166 TxnNumber txnNum,
|
| H A D | idempotency_test_fixture.cpp | 305 TxnNumber txnNum, in makeInsertDocumentOplogEntryWithSessionInfoAndStmtId() argument
309 info.setTxnNumber(txnNum); in makeInsertDocumentOplogEntryWithSessionInfoAndStmtId()
|
| /dports/benchmarks/sipp/sipp-3.5.1/src/ |
| H A D | scenario.cpp | 388 int txnNum = transactions.size(); in get_txn() local
389 txnMap[txnName] = txnNum; in get_txn()
391 return txnNum; in get_txn()
|