/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/ |
H A D | dropindexprocessor.cpp | 41 BRM::TxnID txnID; in processPackage() local 42 txnID.id = fTxnid.id; in processPackage() 43 txnID.valid = fTxnid.valid; in processPackage() 52 SQLLogger logger(dropIndexStmt.fSql, fDDLLoggingId, dropIndexStmt.fSessionID, txnID.id); in processPackage() 62 removeSysIndexMetaData(dropIndexStmt.fSessionID, txnID.id, result, *dropIndexStmt.fIndexName); in processPackage() 81 err = fWriteEngine.dropIndex(txnID.id, indexOID.objnum, indexOID.listOID); in processPackage() 90 logging::logDDL(dropIndexStmt.fSessionID, txnID.id, dropIndexStmt.fSql, dropIndexStmt.fOwner); in processPackage() 93 err = fWriteEngine.commit( txnID.id ); in processPackage() 101 fSessionManager.committed(txnID); in processPackage() 107 fWriteEngine.rollbackTran(txnID.id, dropIndexStmt.fSessionID); in processPackage() [all …]
|
H A D | createindexprocessor.cpp | 58 BRM::TxnID txnID; in processPackage() local 59 txnID.id = fTxnid.id; in processPackage() 60 txnID.valid = fTxnid.valid; in processPackage() 412 err = fWriteEngine.commit( txnID.id ); in processPackage() 419 fSessionManager.committed(txnID); in processPackage() 430 result = rollBackCreateIndex(msg, txnID, createIndexStmt.fSessionID); in processPackage() 457 rollBackIndex(txnID, sessionId); in rollBackCreateIndex() 461 void CreateIndexProcessor::rollBackIndex(BRM::TxnID& txnID, int sessionId) in rollBackIndex() argument 463 fWriteEngine.rollbackTran(txnID.id, sessionId); in rollBackIndex() 464 fWriteEngine.dropIndex(txnID.id, fIdxOID.listOID, fIdxOID.treeOID); in rollBackIndex() [all …]
|
H A D | droptableprocessor.cpp | 67 BRM::TxnID txnID; in processPackage() local 68 txnID.id = fTxnid.id; in processPackage() 69 txnID.valid = fTxnid.valid; in processPackage() 176 int32_t txnid = txnID.id; in processPackage() 228 txnid = txnID.id; in processPackage() 483 … cout << txnID.id << " rolledback transaction " << " and valid is " << txnID.valid << endl; in processPackage() 488 …cout << txnID.id << " commiting transaction " << txnID.id << " and valid is " << txnID.valid << en… in processPackage() 740 BRM::TxnID txnID; in processPackage() local 741 txnID.id = fTxnid.id; in processPackage() 742 txnID.valid = fTxnid.valid; in processPackage() [all …]
|
H A D | altertableprocessor.h | 56 …EXPORT void addColumn(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult& re… 66 …EXPORT void dropColumn(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult& r… 76 …EXPORT void dropColumns(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult& … 86 …EXPORT void addTableConstraint(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLR… 96 …EXPORT void setColumnDefault(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLRes… 106 …EXPORT void dropColumnDefault(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLRe… 116 …EXPORT void dropTableConstraint(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDL… 125 EXPORT void renameTable(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, 135 …EXPORT void renameColumn(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult&… 145 …EXPORT void tableComment(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult&… [all …]
|
H A D | createtableprocessor.cpp | 57 BRM::TxnID txnID; in processPackage() local 58 txnID.id = fTxnid.id; in processPackage() 59 txnID.valid = fTxnid.valid; in processPackage() 72 fSessionManager.rolledback(txnID); in processPackage() 83 fSessionManager.rolledback(txnID); in processPackage() 144 fSessionManager.rolledback(txnID); in processPackage() 157 fSessionManager.rolledback(txnID); in processPackage() 199 fSessionManager.rolledback(txnID); in processPackage() 233 fSessionManager.rolledback(txnID); in processPackage() 297 bytestream << (uint32_t)txnID.id; in processPackage() [all …]
|
H A D | restorepartitionprocessor.cpp | 47 BRM::TxnID txnID; in processPackage() local 48 txnID.id = fTxnid.id; in processPackage() 49 txnID.valid = fTxnid.valid; in processPackage() 62 fSessionManager.rolledback(txnID); in processPackage() 115 fSessionManager.rolledback(txnID); in processPackage() 148 txnID.id = fTxnid.id; in processPackage() 149 txnID.valid = fTxnid.valid; in processPackage() 246 fSessionManager.rolledback(txnID); in processPackage() 274 fSessionManager.rolledback(txnID); in processPackage() 289 fSessionManager.rolledback(txnID); in processPackage() [all …]
|
H A D | droppartitionprocessor.cpp | 56 BRM::TxnID txnID; in processPackage() local 57 txnID.id = fTxnid.id; in processPackage() 58 txnID.valid = fTxnid.valid; in processPackage() 68 fSessionManager.rolledback(txnID); in processPackage() 96 fSessionManager.rolledback(txnID); in processPackage() 107 fSessionManager.rolledback(txnID); in processPackage() 184 txnID.id = fTxnid.id; in processPackage() 185 txnID.valid = fTxnid.valid; in processPackage() 326 fSessionManager.rolledback(txnID); in processPackage() 354 fSessionManager.rolledback(txnID); in processPackage() [all …]
|
H A D | markpartitionprocessor.cpp | 47 BRM::TxnID txnID; in processPackage() local 48 txnID.id = fTxnid.id; in processPackage() 49 txnID.valid = fTxnid.valid; in processPackage() 62 fSessionManager.rolledback(txnID); in processPackage() 115 fSessionManager.rolledback(txnID); in processPackage() 148 txnID.id = fTxnid.id; in processPackage() 149 txnID.valid = fTxnid.valid; in processPackage() 246 fSessionManager.rolledback(txnID); in processPackage() 274 fSessionManager.rolledback(txnID); in processPackage() 289 fSessionManager.rolledback(txnID); in processPackage() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/ |
H A D | dropindexprocessor.cpp | 41 BRM::TxnID txnID; in processPackage() local 42 txnID.id = fTxnid.id; in processPackage() 43 txnID.valid = fTxnid.valid; in processPackage() 52 SQLLogger logger(dropIndexStmt.fSql, fDDLLoggingId, dropIndexStmt.fSessionID, txnID.id); in processPackage() 62 removeSysIndexMetaData(dropIndexStmt.fSessionID, txnID.id, result, *dropIndexStmt.fIndexName); in processPackage() 81 err = fWriteEngine.dropIndex(txnID.id, indexOID.objnum, indexOID.listOID); in processPackage() 90 logging::logDDL(dropIndexStmt.fSessionID, txnID.id, dropIndexStmt.fSql, dropIndexStmt.fOwner); in processPackage() 93 err = fWriteEngine.commit( txnID.id ); in processPackage() 101 fSessionManager.committed(txnID); in processPackage() 107 fWriteEngine.rollbackTran(txnID.id, dropIndexStmt.fSessionID); in processPackage() [all …]
|
H A D | createindexprocessor.cpp | 58 BRM::TxnID txnID; in processPackage() local 59 txnID.id = fTxnid.id; in processPackage() 60 txnID.valid = fTxnid.valid; in processPackage() 412 err = fWriteEngine.commit( txnID.id ); in processPackage() 419 fSessionManager.committed(txnID); in processPackage() 430 result = rollBackCreateIndex(msg, txnID, createIndexStmt.fSessionID); in processPackage() 457 rollBackIndex(txnID, sessionId); in rollBackCreateIndex() 461 void CreateIndexProcessor::rollBackIndex(BRM::TxnID& txnID, int sessionId) in rollBackIndex() argument 463 fWriteEngine.rollbackTran(txnID.id, sessionId); in rollBackIndex() 464 fWriteEngine.dropIndex(txnID.id, fIdxOID.listOID, fIdxOID.treeOID); in rollBackIndex() [all …]
|
H A D | droptableprocessor.cpp | 67 BRM::TxnID txnID; in processPackage() local 68 txnID.id = fTxnid.id; in processPackage() 69 txnID.valid = fTxnid.valid; in processPackage() 176 int32_t txnid = txnID.id; in processPackage() 228 txnid = txnID.id; in processPackage() 483 … cout << txnID.id << " rolledback transaction " << " and valid is " << txnID.valid << endl; in processPackage() 488 …cout << txnID.id << " commiting transaction " << txnID.id << " and valid is " << txnID.valid << en… in processPackage() 740 BRM::TxnID txnID; in processPackage() local 741 txnID.id = fTxnid.id; in processPackage() 742 txnID.valid = fTxnid.valid; in processPackage() [all …]
|
H A D | altertableprocessor.h | 56 …EXPORT void addColumn(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult& re… 66 …EXPORT void dropColumn(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult& r… 76 …EXPORT void dropColumns(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult& … 86 …EXPORT void addTableConstraint(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLR… 96 …EXPORT void setColumnDefault(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLRes… 106 …EXPORT void dropColumnDefault(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLRe… 116 …EXPORT void dropTableConstraint(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDL… 125 EXPORT void renameTable(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, 135 …EXPORT void renameColumn(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult&… 145 …EXPORT void tableComment(uint32_t sessionID, execplan::CalpontSystemCatalog::SCN txnID, DDLResult&… [all …]
|
H A D | createtableprocessor.cpp | 57 BRM::TxnID txnID; in processPackage() local 58 txnID.id = fTxnid.id; in processPackage() 59 txnID.valid = fTxnid.valid; in processPackage() 72 fSessionManager.rolledback(txnID); in processPackage() 83 fSessionManager.rolledback(txnID); in processPackage() 144 fSessionManager.rolledback(txnID); in processPackage() 157 fSessionManager.rolledback(txnID); in processPackage() 199 fSessionManager.rolledback(txnID); in processPackage() 233 fSessionManager.rolledback(txnID); in processPackage() 297 bytestream << (uint32_t)txnID.id; in processPackage() [all …]
|
H A D | restorepartitionprocessor.cpp | 47 BRM::TxnID txnID; in processPackage() local 48 txnID.id = fTxnid.id; in processPackage() 49 txnID.valid = fTxnid.valid; in processPackage() 62 fSessionManager.rolledback(txnID); in processPackage() 115 fSessionManager.rolledback(txnID); in processPackage() 148 txnID.id = fTxnid.id; in processPackage() 149 txnID.valid = fTxnid.valid; in processPackage() 246 fSessionManager.rolledback(txnID); in processPackage() 274 fSessionManager.rolledback(txnID); in processPackage() 289 fSessionManager.rolledback(txnID); in processPackage() [all …]
|
H A D | droppartitionprocessor.cpp | 56 BRM::TxnID txnID; in processPackage() local 57 txnID.id = fTxnid.id; in processPackage() 58 txnID.valid = fTxnid.valid; in processPackage() 68 fSessionManager.rolledback(txnID); in processPackage() 96 fSessionManager.rolledback(txnID); in processPackage() 107 fSessionManager.rolledback(txnID); in processPackage() 184 txnID.id = fTxnid.id; in processPackage() 185 txnID.valid = fTxnid.valid; in processPackage() 326 fSessionManager.rolledback(txnID); in processPackage() 354 fSessionManager.rolledback(txnID); in processPackage() [all …]
|
H A D | markpartitionprocessor.cpp | 47 BRM::TxnID txnID; in processPackage() local 48 txnID.id = fTxnid.id; in processPackage() 49 txnID.valid = fTxnid.valid; in processPackage() 62 fSessionManager.rolledback(txnID); in processPackage() 115 fSessionManager.rolledback(txnID); in processPackage() 148 txnID.id = fTxnid.id; in processPackage() 149 txnID.valid = fTxnid.valid; in processPackage() 246 fSessionManager.rolledback(txnID); in processPackage() 274 fSessionManager.rolledback(txnID); in processPackage() 289 fSessionManager.rolledback(txnID); in processPackage() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/tools/dbbuilder/ |
H A D | systemcatalog.cpp | 39 TxnID txnID = 0; in build() local 108 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSTABLE_TABLENAME, 65, dbRoot, partition, segment, … in build() 125 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSTABLE_SCHEMA, 65, dbRoot, partition, segment, com… in build() 161 …rc = fWriteEngine.createColumn( txnID, OID_SYSTABLE_INIT, CalpontSystemCatalog::INT, 4, dbRoot, pa… in build() 170 …rc = fWriteEngine.createColumn( txnID, OID_SYSTABLE_NEXT, CalpontSystemCatalog::INT, 4, dbRoot, pa… in build() 265 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_SCHEMA, 65, dbRoot, partition, segment, co… in build() 281 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_TABLENAME, 65, dbRoot, partition, segment,… in build() 297 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_COLNAME, 65, dbRoot, partition, segment, c… in build() 387 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_DEFAULTVAL, 9, dbRoot, partition, segment,… in build() 457 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_MINVALUE, 65, dbRoot, partition, segment, … in build() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/tools/dbbuilder/ |
H A D | systemcatalog.cpp | 39 TxnID txnID = 0; in build() local 108 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSTABLE_TABLENAME, 65, dbRoot, partition, segment, … in build() 125 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSTABLE_SCHEMA, 65, dbRoot, partition, segment, com… in build() 161 …rc = fWriteEngine.createColumn( txnID, OID_SYSTABLE_INIT, CalpontSystemCatalog::INT, 4, dbRoot, pa… in build() 170 …rc = fWriteEngine.createColumn( txnID, OID_SYSTABLE_NEXT, CalpontSystemCatalog::INT, 4, dbRoot, pa… in build() 265 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_SCHEMA, 65, dbRoot, partition, segment, co… in build() 281 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_TABLENAME, 65, dbRoot, partition, segment,… in build() 297 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_COLNAME, 65, dbRoot, partition, segment, c… in build() 387 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_DEFAULTVAL, 9, dbRoot, partition, segment,… in build() 457 …rc = fWriteEngine.createDctnry(txnID, DICTOID_SYSCOLUMN_MINVALUE, 65, dbRoot, partition, segment, … in build() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
H A D | we_ddlcommandproc.cpp | 130 txnID = tmp32; in writeSystable() 1186 int txnID; in createtablefiles() local 1246 int txnID; in commitVersion() local 1268 int txnID; in rollbackBlocks() local 1300 int txnID; in rollbackVersion() local 1323 int txnID; in deleteSyscolumn() local 1456 int txnID; in deleteSyscolumnRow() local 1590 int txnID; in deleteSystable() local 1725 int txnID; in deleteSystables() local 1984 int txnID; in updateSyscolumnAuto() local [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
H A D | we_ddlcommandproc.cpp | 130 txnID = tmp32; in writeSystable() 1186 int txnID; in createtablefiles() local 1246 int txnID; in commitVersion() local 1268 int txnID; in rollbackBlocks() local 1300 int txnID; in rollbackVersion() local 1323 int txnID; in deleteSyscolumn() local 1456 int txnID; in deleteSyscolumnRow() local 1590 int txnID; in deleteSystable() local 1725 int txnID; in deleteSystables() local 1984 int txnID; in updateSyscolumnAuto() local [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | rollback.cpp | 72 void rollbackTxn(VER_t txnID) in rollbackTxn() argument 78 err = brm.getUncommittedLBIDs(txnID, lbidList); in rollbackTxn() 83 err = brm.vbRollback(txnID, lbidList); in rollbackTxn() 96 VER_t txnID = -1; in main() local 104 txnID = atoi (optarg); in main() 106 if (txnID < 1) in main() 113 rollbackTxn(txnID); in main()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/tools/qfe/ |
H A D | parsequery.cpp | 76 TxnID txnID; in parseQuery() local 77 txnID = sm.getTxnID(sid); in parseQuery() 79 if (!txnID.valid) in parseQuery() 81 txnID.id = 0; in parseQuery() 82 txnID.valid = true; in parseQuery() 88 csep->txnID(txnID.id); in parseQuery()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | rollback.cpp | 72 void rollbackTxn(VER_t txnID) in rollbackTxn() argument 78 err = brm.getUncommittedLBIDs(txnID, lbidList); in rollbackTxn() 83 err = brm.vbRollback(txnID, lbidList); in rollbackTxn() 96 VER_t txnID = -1; in main() local 104 txnID = atoi (optarg); in main() 106 if (txnID < 1) in main() 113 rollbackTxn(txnID); in main()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/tools/qfe/ |
H A D | parsequery.cpp | 76 TxnID txnID; in parseQuery() local 77 txnID = sm.getTxnID(sid); in parseQuery() 79 if (!txnID.valid) in parseQuery() 81 txnID.id = 0; in parseQuery() 82 txnID.valid = true; in parseQuery() 88 csep->txnID(txnID.id); in parseQuery()
|
/dports/devel/etcd/etcd-2.3.8/storage/ |
H A D | consistent_watchable_store.go | 106 func (s *consistentWatchableStore) TxnRange(txnID int64, key, end []byte, limit, rangeRev int64) (k… 110 return s.watchableStore.TxnRange(txnID, key, end, limit, rangeRev) 113 func (s *consistentWatchableStore) TxnPut(txnID int64, key, value []byte, lease lease.LeaseID) (rev… 117 return s.watchableStore.TxnPut(txnID, key, value, lease) 120 func (s *consistentWatchableStore) TxnDeleteRange(txnID int64, key, end []byte) (n, rev int64, err … 124 return s.watchableStore.TxnDeleteRange(txnID, key, end) 127 func (s *consistentWatchableStore) TxnEnd(txnID int64) error { 130 return s.watchableStore.TxnEnd(txnID)
|