/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | tdriver-dbrm.cpp | 145 vector<LBID_t> lbids; in brm_dumb_1() local 177 vector<LBID_t> lbids; in brm_extentmap_good_1() local 312 vector<LBID_t> lbids; in brm_good_2() local 345 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_2() 503 vector<LBID_t> lbids; in brm_good_3() local 537 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_3() 639 sort<vector<LBID_t>::iterator>(lbids.begin(), lbids.end()); in brm_good_3() 640 lbid = lbids.begin(); in brm_good_3() 782 vector<LBID_t> lbids; in DBRM_resource_graph_1() local 817 vector<LBID_t> lbids; in DBRM_resource_graph_deadlock() local [all …]
|
H A D | tdriver-load.cpp | 142 vector<LBID_t> lbids; in extentMap_good_1() local 249 vector<LBID_t> lbids; in extentMap_freelist() local 299 vector<LBID_t> lbids; in extentMap_overfill() local 381 vector<LBID_t> lbids; in brm_extentmap_good_1() local 479 vector<LBID_t> lbids; in brm_good_2() local 510 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_2() 664 vector<LBID_t> lbids; in brm_good_3() local 696 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_3() 798 sort<vector<LBID_t>::iterator>(lbids.begin(), lbids.end()); in brm_good_3() 799 lbid = lbids.begin(); in brm_good_3() [all …]
|
H A D | tdriver.cpp | 251 vector<LBID_t> lbids; in extentMap_good_1() local 377 vector<LBID_t> lbids; in extentMap_range_1() local 465 vector<LBID_t> lbids; in extentMap_freelist() local 518 vector<LBID_t> lbids; in extentMap_overfill() local 607 vector<LBID_t> lbids; in brm_extentmap_good_1() local 784 vector<LBID_t> lbids; in brm_extentmap_range_1() local 880 vector<LBID_t> lbids; in brm_good_2() local 1072 vector<LBID_t> lbids; in brm_good_3() local 1208 sort<vector<LBID_t>::iterator>(lbids.begin(), lbids.end()); in brm_good_3() 1209 lbid = lbids.begin(); in brm_good_3() [all …]
|
H A D | tdriver-brm.cpp | 190 vector<LBID_t> lbids; in BRMRunner_1() local 261 vector<LBID_t> lbids; in BRMRunner_1() local 615 vector<LBID_t> lbids; in BRMRunner_si() local 685 vector<LBID_t> lbids; in BRMRunner_si() local 1021 vector<LBID_t> lbids; in EMRunner() local 1091 vector<LBID_t> lbids; in EMRunner() local 1416 vector<LBID_t> lbids; in EMRunner_si() local 1485 vector<LBID_t> lbids; in EMRunner_si() local 1803 vector<LBID_t> lbids; in EMRangeRunner_si() local 2192 LBIDRange_v lbids; in EMRangeRunner_si() local [all …]
|
H A D | tdriver-dbrm2.cpp | 190 vector<LBID_t> lbids; in BRMRunner_1() local 240 newEm->LBIDstart = lbids[i]; in BRMRunner_1() 264 vector<LBID_t> lbids; in BRMRunner_1() local 308 newEm->LBIDstart = lbids[i]; in BRMRunner_1() 615 vector<LBID_t> lbids; in BRMRunner_si() local 661 newEm->LBIDstart = lbids[i]; in BRMRunner_si() 685 vector<LBID_t> lbids; in BRMRunner_si() local 1021 vector<LBID_t> lbids; in EMRunner() local 1091 vector<LBID_t> lbids; in EMRunner() local 1416 vector<LBID_t> lbids; in EMRunner_si() local [all …]
|
H A D | slavedbrmnode.cpp | 277 LBIDRange_v lbids; in deleteOID() local 288 err = lookup(oid, lbids); in deleteOID() 290 if (err == -1 || lbids.empty()) in deleteOID() 293 for (it = lbids.begin(); it != lbids.end(); it++) in deleteOID() 326 LBIDRange_v lbids; in deleteOIDs() local 327 err = lookup(mapit->second, lbids); in deleteOIDs() 332 for (it = lbids.begin(); it != lbids.end(); it++) in deleteOIDs() 548 for (size_t i = 0; i < lbids.size(); i++) in bulkWriteVBEntry() 572 vss.setVBFlag(lbids[i], oldVerID, true); in bulkWriteVBEntry() 578 vss.insert(lbids[i], transID, false, true); in bulkWriteVBEntry() [all …]
|
H A D | vss.h | 239 EXPORT void getUncommittedLBIDs(VER_t txnID, std::vector<LBID_t>& lbids); 240 EXPORT void getUnlockedLBIDs(BlockList_t& lbids); 241 EXPORT void getLockedLBIDs(BlockList_t& lbids);
|
H A D | vss.cpp | 970 void VSS::getUncommittedLBIDs(VER_t txnID, vector<LBID_t>& lbids) in getUncommittedLBIDs() argument 974 lbids.clear(); in getUncommittedLBIDs() 1007 lbids.push_back(storage[i].lbid); in getUncommittedLBIDs() 1012 void VSS::getUnlockedLBIDs(BlockList_t& lbids) in getUnlockedLBIDs() argument 1014 lbids.clear(); in getUnlockedLBIDs() 1018 lbids.push_back(LVP_t(storage[i].lbid, storage[i].verID)); in getUnlockedLBIDs() 1021 void VSS::getLockedLBIDs(BlockList_t& lbids) in getLockedLBIDs() argument 1023 lbids.clear(); in getLockedLBIDs() 1027 lbids.push_back(LVP_t(storage[i].lbid, storage[i].verID)); in getLockedLBIDs()
|
H A D | dbrm.h | 201 …EXPORT int bulkVSSLookup(const std::vector<LBID_t>& lbids, const QueryContext_vss& qc, VER_t txnID, 214 EXPORT int bulkGetCurrentVersion(const std::vector<LBID_t>& lbids, std::vector<VER_t>* versions, 628 const std::vector<BRM::LBID_t>& lbids, 823 EXPORT int markExtentsInvalid(const std::vector<LBID_t>& lbids,
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | tdriver-dbrm.cpp | 145 vector<LBID_t> lbids; in brm_dumb_1() local 177 vector<LBID_t> lbids; in brm_extentmap_good_1() local 312 vector<LBID_t> lbids; in brm_good_2() local 345 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_2() 503 vector<LBID_t> lbids; in brm_good_3() local 537 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_3() 639 sort<vector<LBID_t>::iterator>(lbids.begin(), lbids.end()); in brm_good_3() 640 lbid = lbids.begin(); in brm_good_3() 782 vector<LBID_t> lbids; in DBRM_resource_graph_1() local 817 vector<LBID_t> lbids; in DBRM_resource_graph_deadlock() local [all …]
|
H A D | tdriver-load.cpp | 142 vector<LBID_t> lbids; in extentMap_good_1() local 249 vector<LBID_t> lbids; in extentMap_freelist() local 299 vector<LBID_t> lbids; in extentMap_overfill() local 381 vector<LBID_t> lbids; in brm_extentmap_good_1() local 479 vector<LBID_t> lbids; in brm_good_2() local 510 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_2() 664 vector<LBID_t> lbids; in brm_good_3() local 696 CPPUNIT_ASSERT(lbids.size() == 1); in brm_good_3() 798 sort<vector<LBID_t>::iterator>(lbids.begin(), lbids.end()); in brm_good_3() 799 lbid = lbids.begin(); in brm_good_3() [all …]
|
H A D | tdriver.cpp | 251 vector<LBID_t> lbids; in extentMap_good_1() local 377 vector<LBID_t> lbids; in extentMap_range_1() local 465 vector<LBID_t> lbids; in extentMap_freelist() local 518 vector<LBID_t> lbids; in extentMap_overfill() local 607 vector<LBID_t> lbids; in brm_extentmap_good_1() local 784 vector<LBID_t> lbids; in brm_extentmap_range_1() local 880 vector<LBID_t> lbids; in brm_good_2() local 1072 vector<LBID_t> lbids; in brm_good_3() local 1208 sort<vector<LBID_t>::iterator>(lbids.begin(), lbids.end()); in brm_good_3() 1209 lbid = lbids.begin(); in brm_good_3() [all …]
|
H A D | tdriver-brm.cpp | 190 vector<LBID_t> lbids; in BRMRunner_1() local 261 vector<LBID_t> lbids; in BRMRunner_1() local 615 vector<LBID_t> lbids; in BRMRunner_si() local 685 vector<LBID_t> lbids; in BRMRunner_si() local 1021 vector<LBID_t> lbids; in EMRunner() local 1091 vector<LBID_t> lbids; in EMRunner() local 1416 vector<LBID_t> lbids; in EMRunner_si() local 1485 vector<LBID_t> lbids; in EMRunner_si() local 1803 vector<LBID_t> lbids; in EMRangeRunner_si() local 2192 LBIDRange_v lbids; in EMRangeRunner_si() local [all …]
|
H A D | tdriver-dbrm2.cpp | 190 vector<LBID_t> lbids; in BRMRunner_1() local 240 newEm->LBIDstart = lbids[i]; in BRMRunner_1() 264 vector<LBID_t> lbids; in BRMRunner_1() local 308 newEm->LBIDstart = lbids[i]; in BRMRunner_1() 615 vector<LBID_t> lbids; in BRMRunner_si() local 661 newEm->LBIDstart = lbids[i]; in BRMRunner_si() 685 vector<LBID_t> lbids; in BRMRunner_si() local 1021 vector<LBID_t> lbids; in EMRunner() local 1091 vector<LBID_t> lbids; in EMRunner() local 1416 vector<LBID_t> lbids; in EMRunner_si() local [all …]
|
H A D | slavedbrmnode.cpp | 277 LBIDRange_v lbids; in deleteOID() local 288 err = lookup(oid, lbids); in deleteOID() 290 if (err == -1 || lbids.empty()) in deleteOID() 293 for (it = lbids.begin(); it != lbids.end(); it++) in deleteOID() 326 LBIDRange_v lbids; in deleteOIDs() local 327 err = lookup(mapit->second, lbids); in deleteOIDs() 332 for (it = lbids.begin(); it != lbids.end(); it++) in deleteOIDs() 548 for (size_t i = 0; i < lbids.size(); i++) in bulkWriteVBEntry() 572 vss.setVBFlag(lbids[i], oldVerID, true); in bulkWriteVBEntry() 578 vss.insert(lbids[i], transID, false, true); in bulkWriteVBEntry() [all …]
|
H A D | vss.h | 239 EXPORT void getUncommittedLBIDs(VER_t txnID, std::vector<LBID_t>& lbids); 240 EXPORT void getUnlockedLBIDs(BlockList_t& lbids); 241 EXPORT void getLockedLBIDs(BlockList_t& lbids);
|
H A D | vss.cpp | 970 void VSS::getUncommittedLBIDs(VER_t txnID, vector<LBID_t>& lbids) in getUncommittedLBIDs() argument 974 lbids.clear(); in getUncommittedLBIDs() 1007 lbids.push_back(storage[i].lbid); in getUncommittedLBIDs() 1012 void VSS::getUnlockedLBIDs(BlockList_t& lbids) in getUnlockedLBIDs() argument 1014 lbids.clear(); in getUnlockedLBIDs() 1018 lbids.push_back(LVP_t(storage[i].lbid, storage[i].verID)); in getUnlockedLBIDs() 1021 void VSS::getLockedLBIDs(BlockList_t& lbids) in getLockedLBIDs() argument 1023 lbids.clear(); in getLockedLBIDs() 1027 lbids.push_back(LVP_t(storage[i].lbid, storage[i].verID)); in getLockedLBIDs()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/tools/rebuildEM/ |
H A D | main.cpp | 222 vector<LBID_t> lbids; in walkDB() local 232 em.createExtent(numBlocks, oid, lbids, allocdsize); in walkDB() 242 vector<LBID_t>::iterator iter = lbids.begin(); in walkDB() 243 vector<LBID_t>::iterator end = lbids.end(); in walkDB()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/tools/rebuildEM/ |
H A D | main.cpp | 222 vector<LBID_t> lbids; in walkDB() local 232 em.createExtent(numBlocks, oid, lbids, allocdsize); in walkDB() 242 vector<LBID_t>::iterator iter = lbids.begin(); in walkDB() 243 vector<LBID_t>::iterator end = lbids.end(); in walkDB()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/ |
H A D | rtscommand.cpp | 235 void RTSCommand::getLBIDList(uint32_t loopCount, vector<int64_t>* lbids) in getLBIDList() argument 237 dict.getLBIDList(loopCount, lbids); in getLBIDList() 240 col.getLBIDList(loopCount, lbids); in getLBIDList()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/ |
H A D | rtscommand.cpp | 235 void RTSCommand::getLBIDList(uint32_t loopCount, vector<int64_t>* lbids) in getLBIDList() argument 237 dict.getLBIDList(loopCount, lbids); in getLBIDList() 240 col.getLBIDList(loopCount, lbids); in getLBIDList()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
H A D | filebuffermgr.cpp | 482 uint32_t FileBufferMgr::bulkFind(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** buffer… in bulkFind() argument 494 gPMStatsPtr->markEvent(lbids[i], GetCurrentThreadId(), gSession, 'L'); in bulkFind() 496 gPMStatsPtr->markEvent(lbids[i], pthread_self(), gSession, 'L'); in bulkFind() 508 gPMStatsPtr->markEvent(lbids[i], GetCurrentThreadId(), gSession, 'M'); in bulkFind() 510 gPMStatsPtr->markEvent(lbids[i], pthread_self(), gSession, 'M'); in bulkFind() 518 it[i] = fbSet.find(HashObject_t(lbids[i], vers[i], 0)); in bulkFind() 546 gPMStatsPtr->markEvent(lbids[i], GetCurrentThreadId(), gSession, 'U'); in bulkFind() 548 gPMStatsPtr->markEvent(lbids[i], pthread_self(), gSession, 'U'); in bulkFind()
|
H A D | blockcacheclient.h | 104 … inline int getCachedBlocks(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** bufferPtrs, in getCachedBlocks() argument 107 return fBCCBrp->getCachedBlocks(lbids, vers, bufferPtrs, wasCached, blockCount); in getCachedBlocks()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
H A D | filebuffermgr.cpp | 482 uint32_t FileBufferMgr::bulkFind(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** buffer… in bulkFind() argument 494 gPMStatsPtr->markEvent(lbids[i], GetCurrentThreadId(), gSession, 'L'); in bulkFind() 496 gPMStatsPtr->markEvent(lbids[i], pthread_self(), gSession, 'L'); in bulkFind() 508 gPMStatsPtr->markEvent(lbids[i], GetCurrentThreadId(), gSession, 'M'); in bulkFind() 510 gPMStatsPtr->markEvent(lbids[i], pthread_self(), gSession, 'M'); in bulkFind() 518 it[i] = fbSet.find(HashObject_t(lbids[i], vers[i], 0)); in bulkFind() 546 gPMStatsPtr->markEvent(lbids[i], GetCurrentThreadId(), gSession, 'U'); in bulkFind() 548 gPMStatsPtr->markEvent(lbids[i], pthread_self(), gSession, 'U'); in bulkFind()
|
H A D | blockcacheclient.h | 104 … inline int getCachedBlocks(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** bufferPtrs, in getCachedBlocks() argument 107 return fBCCBrp->getCachedBlocks(lbids, vers, bufferPtrs, wasCached, blockCount); in getCachedBlocks()
|