| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlproc.cpp | 271 if (tableLocks[i].ownerTxnID > 0) //transaction rollback in rollbackAll()
274 oss << "DMLProc is rolling back transaction " << tableLocks[i].ownerTxnID; in rollbackAll()
281 dbrm->invalidateUncommittedExtentLBIDs(tableLocks[i].ownerTxnID); in rollbackAll()
283 txnId.id = tableLocks[i].ownerTxnID; in rollbackAll()
290 …oss << "DMLProc rolled back transaction " << tableLocks[i].ownerTxnID << " and is releasing table … in rollbackAll()
305 logging::logCommand(0, tableLocks[i].ownerTxnID, "ROLLBACK;"); in rollbackAll()
326 …oss << "DMLProc rolled back transaction " << tableLocks[i].ownerTxnID << " and table lock id " << … in rollbackAll()
337 …oss << "DMLProc rolled back transaction " << tableLocks[i].ownerTxnID << " and table lock id " << … in rollbackAll()
350 …oss << " problem with rollback transaction " << tableLocks[i].ownerTxnID << "and DBRM is setting t… in rollbackAll()
359 errorTxn = tableLocks[i].ownerTxnID; in rollbackAll()
|
| H A D | dmlprocessor.cpp | 196 txnId.id = tableLocks[i].ownerTxnID; in operator ()()
209 … logging::logCommand(0, tableLocks[i].ownerTxnID, "ROLLBACK;"); in operator ()()
227 …oss << "DMLProc rolled back idle transaction " << tableLocks[i].ownerTxnID << " and table lock id … in operator ()()
233 …oss << "DMLProc rolled back idle transaction " << tableLocks[i].ownerTxnID << " and tble lock id "… in operator ()()
240 …<< " problem with bulk rollback of idle transaction " << tableLocks[i].ownerTxnID << "and DBRM is … in operator ()()
248 …oss << " problem with rollback of idle transaction " << tableLocks[i].ownerTxnID << "and DBRM is s… in operator ()()
271 if (tableLocks[j].ownerTxnID == activeTxns[i].txnid.id) in operator ()()
284 … oss << "DMLProc rolled back idle transaction with no tablelock" << tableLocks[i].ownerTxnID; in operator ()()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlproc.cpp | 271 if (tableLocks[i].ownerTxnID > 0) //transaction rollback in rollbackAll()
274 oss << "DMLProc is rolling back transaction " << tableLocks[i].ownerTxnID; in rollbackAll()
281 dbrm->invalidateUncommittedExtentLBIDs(tableLocks[i].ownerTxnID); in rollbackAll()
283 txnId.id = tableLocks[i].ownerTxnID; in rollbackAll()
290 …oss << "DMLProc rolled back transaction " << tableLocks[i].ownerTxnID << " and is releasing table … in rollbackAll()
305 logging::logCommand(0, tableLocks[i].ownerTxnID, "ROLLBACK;"); in rollbackAll()
326 …oss << "DMLProc rolled back transaction " << tableLocks[i].ownerTxnID << " and table lock id " << … in rollbackAll()
337 …oss << "DMLProc rolled back transaction " << tableLocks[i].ownerTxnID << " and table lock id " << … in rollbackAll()
350 …oss << " problem with rollback transaction " << tableLocks[i].ownerTxnID << "and DBRM is setting t… in rollbackAll()
359 errorTxn = tableLocks[i].ownerTxnID; in rollbackAll()
|
| H A D | dmlprocessor.cpp | 196 txnId.id = tableLocks[i].ownerTxnID; in operator ()()
209 … logging::logCommand(0, tableLocks[i].ownerTxnID, "ROLLBACK;"); in operator ()()
227 …oss << "DMLProc rolled back idle transaction " << tableLocks[i].ownerTxnID << " and table lock id … in operator ()()
233 …oss << "DMLProc rolled back idle transaction " << tableLocks[i].ownerTxnID << " and tble lock id "… in operator ()()
240 …<< " problem with bulk rollback of idle transaction " << tableLocks[i].ownerTxnID << "and DBRM is … in operator ()()
248 …oss << " problem with rollback of idle transaction " << tableLocks[i].ownerTxnID << "and DBRM is s… in operator ()()
271 if (tableLocks[j].ownerTxnID == activeTxns[i].txnid.id) in operator ()()
284 … oss << "DMLProc rolled back idle transaction with no tablelock" << tableLocks[i].ownerTxnID; in operator ()()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
| H A D | tablelockserver.cpp | 150 tli->ownerTxnID = it->second.ownerTxnID; in lock()
249 oldTxnID = it->second.ownerTxnID; in changeOwner()
253 it->second.ownerTxnID = txnID; in changeOwner()
264 it->second.ownerTxnID = oldTxnID; in changeOwner()
|
| H A D | brmtypes.cpp | 412 (uint32_t) ownerTxnID << (uint8_t) state; in serialize()
424 ownerTxnID = tmp322; in deserialize()
440 o.write((char*) &ownerTxnID, 4); in serialize()
461 i.read((char*) &ownerTxnID, 4); in deserialize()
484 o->write((char*) &ownerTxnID, 4); in serialize()
505 i->read((char*) &ownerTxnID, 4); in deserialize()
|
| H A D | dbrm.h | 810 int32_t* ownerTxnID, LockState state);
814 int32_t ownerSessionID, int32_t ownerTxnID);
|
| H A D | brmtypes.h | 230 int32_t ownerTxnID;
|
| H A D | dbrm.cpp | 4075 …ring* ownerName, uint32_t* ownerPID, int32_t* ownerSessionID, int32_t* ownerTxnID, LockState state) in getTableLock() argument
4100 tli.ownerTxnID = *ownerTxnID; in getTableLock()
4130 *ownerTxnID = tmp32; in getTableLock()
4190 int32_t ownerTxnID) in changeOwner() argument
4196 (uint32_t) ownerSessionID << (uint32_t) ownerTxnID; in changeOwner()
|
| H A D | masterdbrmnode.cpp | 2194 reply << (uint32_t) tli.ownerTxnID; in doGetTableLock()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
| H A D | tablelockserver.cpp | 150 tli->ownerTxnID = it->second.ownerTxnID; in lock()
249 oldTxnID = it->second.ownerTxnID; in changeOwner()
253 it->second.ownerTxnID = txnID; in changeOwner()
264 it->second.ownerTxnID = oldTxnID; in changeOwner()
|
| H A D | brmtypes.cpp | 412 (uint32_t) ownerTxnID << (uint8_t) state; in serialize()
424 ownerTxnID = tmp322; in deserialize()
440 o.write((char*) &ownerTxnID, 4); in serialize()
461 i.read((char*) &ownerTxnID, 4); in deserialize()
484 o->write((char*) &ownerTxnID, 4); in serialize()
505 i->read((char*) &ownerTxnID, 4); in deserialize()
|
| H A D | dbrm.h | 810 int32_t* ownerTxnID, LockState state);
814 int32_t ownerSessionID, int32_t ownerTxnID);
|
| H A D | brmtypes.h | 230 int32_t ownerTxnID;
|
| H A D | dbrm.cpp | 4075 …ring* ownerName, uint32_t* ownerPID, int32_t* ownerSessionID, int32_t* ownerTxnID, LockState state) in getTableLock() argument
4100 tli.ownerTxnID = *ownerTxnID; in getTableLock()
4130 *ownerTxnID = tmp32; in getTableLock()
4190 int32_t ownerTxnID) in changeOwner() argument
4196 (uint32_t) ownerSessionID << (uint32_t) ownerTxnID; in changeOwner()
|
| H A D | masterdbrmnode.cpp | 2194 reply << (uint32_t) tli.ownerTxnID; in doGetTableLock()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/tools/viewtablelock/ |
| H A D | viewtablelock.cpp | 141 maxTxnID = std::max(maxTxnID, tableLocks[i].ownerTxnID); in printTableLocks()
239 if (tableLocks[idx].ownerTxnID < 0) in printTableLocks()
243 tableLocks[idx].ownerTxnID; in printTableLocks()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/tools/viewtablelock/ |
| H A D | viewtablelock.cpp | 141 maxTxnID = std::max(maxTxnID, tableLocks[i].ownerTxnID); in printTableLocks()
239 if (tableLocks[idx].ownerTxnID < 0) in printTableLocks()
243 tableLocks[idx].ownerTxnID; in printTableLocks()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/dmlpackageproc/ |
| H A D | commandpackageprocessor.cpp | 640 if (tableLocks[idx].ownerTxnID > maxTxnID) in viewTableLock()
641 maxTxnID = tableLocks[idx].ownerTxnID; in viewTableLock()
759 if (tableLocks[idx].ownerTxnID < 0) in viewTableLock()
763 tableLocks[idx].ownerTxnID; in viewTableLock()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/dmlpackageproc/ |
| H A D | commandpackageprocessor.cpp | 640 if (tableLocks[idx].ownerTxnID > maxTxnID) in viewTableLock()
641 maxTxnID = tableLocks[idx].ownerTxnID; in viewTableLock()
759 if (tableLocks[idx].ownerTxnID < 0) in viewTableLock()
763 tableLocks[idx].ownerTxnID; in viewTableLock()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/ddlproc/ |
| H A D | ddlprocessor.cpp | 553 if (tableLocks[k].ownerTxnID == txnid.id) in process()
618 if (tableLocks[k].ownerTxnID == txnid.id) in process()
716 if (tableLocks[k].ownerTxnID == txnid.id) in process()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/ddlproc/ |
| H A D | ddlprocessor.cpp | 553 if (tableLocks[k].ownerTxnID == txnid.id) in process()
618 if (tableLocks[k].ownerTxnID == txnid.id) in process()
716 if (tableLocks[k].ownerTxnID == txnid.id) in process()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/tools/cleartablelock/ |
| H A D | cleartablelock.cpp | 655 txn.id = tInfo.ownerTxnID; in main()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/tools/cleartablelock/ |
| H A D | cleartablelock.cpp | 655 txn.id = tInfo.ownerTxnID; in main()
|