Home
last modified time | relevance | path

Searched refs:lbids (Results 1 – 25 of 64) sorted by relevance

123

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dtdriver-dbrm.cpp145 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 Dtdriver-load.cpp142 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 Dtdriver.cpp251 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 Dtdriver-brm.cpp190 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 Dtdriver-dbrm2.cpp190 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 Dslavedbrmnode.cpp277 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 Dvss.h239 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 Dvss.cpp970 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 Ddbrm.h201 …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 Dtdriver-dbrm.cpp145 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 Dtdriver-load.cpp142 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 Dtdriver.cpp251 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 Dtdriver-brm.cpp190 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 Dtdriver-dbrm2.cpp190 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 Dslavedbrmnode.cpp277 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 Dvss.h239 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 Dvss.cpp970 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 Dmain.cpp222 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 Dmain.cpp222 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 Drtscommand.cpp235 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 Drtscommand.cpp235 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 Dfilebuffermgr.cpp482 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 Dblockcacheclient.h104 … 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 Dfilebuffermgr.cpp482 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 Dblockcacheclient.h104 … 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()

123