| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
| H A D | rollback.cpp | 58 set<VER_t> txnList; in printTxnIDs() local
62 err = brm.getCurrentTxnIDs(txnList); in printTxnIDs()
67 for (it = txnList.begin(); it != txnList.end(); it++) in printTxnIDs()
|
| H A D | copylocks.h | 147 EXPORT void getCurrentTxnIDs(std::set<VER_t>& txnList) const;
|
| H A D | vss.h | 249 EXPORT void getCurrentTxnIDs(std::set<VER_t>& txnList) const;
|
| H A D | dbrm.h | 749 EXPORT int getCurrentTxnIDs(std::set<VER_t>& txnList) throw();
|
| H A D | dbrm.cpp | 2906 int DBRM::getCurrentTxnIDs(set<VER_t>& txnList) throw() in getCurrentTxnIDs() argument
2917 txnList.clear(); in getCurrentTxnIDs()
2922 copylocks->getCurrentTxnIDs(txnList); in getCurrentTxnIDs()
2923 vss->getCurrentTxnIDs(txnList); in getCurrentTxnIDs()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
| H A D | rollback.cpp | 58 set<VER_t> txnList; in printTxnIDs() local
62 err = brm.getCurrentTxnIDs(txnList); in printTxnIDs()
67 for (it = txnList.begin(); it != txnList.end(); it++) in printTxnIDs()
|
| H A D | copylocks.h | 147 EXPORT void getCurrentTxnIDs(std::set<VER_t>& txnList) const;
|
| H A D | vss.h | 249 EXPORT void getCurrentTxnIDs(std::set<VER_t>& txnList) const;
|
| H A D | dbrm.h | 749 EXPORT int getCurrentTxnIDs(std::set<VER_t>& txnList) throw();
|
| H A D | dbrm.cpp | 2906 int DBRM::getCurrentTxnIDs(set<VER_t>& txnList) throw() in getCurrentTxnIDs() argument
2917 txnList.clear(); in getCurrentTxnIDs()
2922 copylocks->getCurrentTxnIDs(txnList); in getCurrentTxnIDs()
2923 vss->getCurrentTxnIDs(txnList); in getCurrentTxnIDs()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlproc.cpp | 435 set<VER_t> txnList; in rollbackAll() local
436 rc = dbrm->getCurrentTxnIDs(txnList); in rollbackAll()
438 if (txnList.size() > 0) in rollbackAll()
441 oss << "DMLProc will rollback " << txnList.size() << " transactions."; in rollbackAll()
449 for (curTxnID = txnList.begin(); curTxnID != txnList.end(); ++curTxnID) in rollbackAll()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlproc.cpp | 435 set<VER_t> txnList; in rollbackAll() local
436 rc = dbrm->getCurrentTxnIDs(txnList); in rollbackAll()
438 if (txnList.size() > 0) in rollbackAll()
441 oss << "DMLProc will rollback " << txnList.size() << " transactions."; in rollbackAll()
449 for (curTxnID = txnList.begin(); curTxnID != txnList.end(); ++curTxnID) in rollbackAll()
|
| /dports/databases/db5/db-5.3.28/examples/java/src/db/ |
| H A D | TpcbExample.java | 359 TxnThread[] txnList = new TxnThread[threads]; in run() local
361 txnList[i] = new TxnThread("Thread " + String.valueOf(i), ntxns); in run()
365 txnList[i].start(); in run()
368 txnList[i].join(); in run()
376 txns += txnList[i].txns; in run()
377 failed += txnList[i].failed; in run()
|
| /dports/databases/db18/db-18.1.40/examples/java/src/db/ |
| H A D | TpcbExample.java | 358 TxnThread[] txnList = new TxnThread[threads]; in run() local
360 txnList[i] = new TxnThread("Thread " + String.valueOf(i), ntxns); in run()
364 txnList[i].start(); in run()
367 txnList[i].join(); in run()
375 txns += txnList[i].txns; in run()
376 failed += txnList[i].failed; in run()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/ |
| H A D | LoadFromLogNoServerTest.java | 133 List<Txn> txnList = new ArrayList<Txn>(); in doOp() local
139 txnList.add(txact); in doOp()
140 txn = new MultiTxn(txnList); in doOp()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/persistence/ |
| H A D | TxnLogToolkit.java | 339 List<Txn> txnList = multiTxn.getTxns(); in getFormattedTxnStr() local
340 for (int i = 0; i < txnList.size(); i++) { in getFormattedTxnStr()
341 Txn t = txnList.get(i); in getFormattedTxnStr()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/mscorlib/system/deployment/ |
| H A D | isolationinterop.cs | 2506 StoreTransactionOperation[] txnList = new StoreTransactionOperation[_list.Count]; in GenerateStoreOpsList()
2513 txnList[i].Data.DataPtr = Marshal.AllocCoTaskMem(Marshal.SizeOf(o)); in GenerateStoreOpsList()
2514 Marshal.StructureToPtr(o, txnList[i].Data.DataPtr, false); in GenerateStoreOpsList()
2523 txnList[i].Operation = StoreTransactionOperationType.StageComponent; in GenerateStoreOpsList()
2527 txnList[i].Operation = StoreTransactionOperationType.PinDeployment; in GenerateStoreOpsList()
2531 txnList[i].Operation = StoreTransactionOperationType.UnpinDeployment; in GenerateStoreOpsList()
2535 txnList[i].Operation = StoreTransactionOperationType.StageComponentFile; in GenerateStoreOpsList()
2539 txnList[i].Operation = StoreTransactionOperationType.InstallDeployment; in GenerateStoreOpsList()
2543 txnList[i].Operation = StoreTransactionOperationType.UninstallDeployment; in GenerateStoreOpsList()
2551 txnList[i].Operation = StoreTransactionOperationType.Scavenge; in GenerateStoreOpsList()
[all …]
|