Home
last modified time | relevance | path

Searched refs:txnID (Results 1 – 25 of 175) sorted by relevance

1234567

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/
H A Ddropindexprocessor.cpp41 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 Dcreateindexprocessor.cpp58 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 Ddroptableprocessor.cpp67 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 Daltertableprocessor.h56 …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 Dcreatetableprocessor.cpp57 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 Drestorepartitionprocessor.cpp47 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 Ddroppartitionprocessor.cpp56 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 Dmarkpartitionprocessor.cpp47 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 Ddropindexprocessor.cpp41 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 Dcreateindexprocessor.cpp58 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 Ddroptableprocessor.cpp67 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 Daltertableprocessor.h56 …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 Dcreatetableprocessor.cpp57 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 Drestorepartitionprocessor.cpp47 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 Ddroppartitionprocessor.cpp56 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 Dmarkpartitionprocessor.cpp47 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 Dsystemcatalog.cpp39 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 Dsystemcatalog.cpp39 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 Dwe_ddlcommandproc.cpp130 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 Dwe_ddlcommandproc.cpp130 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 Drollback.cpp72 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 Dparsequery.cpp76 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 Drollback.cpp72 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 Dparsequery.cpp76 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 Dconsistent_watchable_store.go106 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)

1234567