/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | vss.cpp | 64 lbid = -1; in VSSEntry() 399 if (lbid < 0) in insert() 413 entry.lbid = lbid; in insert() 515 if (listEntry->lbid == lbid) in lookup() 581 if (listEntry->lbid == lbid && !listEntry->vbFlag) in getCurrentVersion() 611 if ((listEntry->lbid == lbid && listEntry->vbFlag) && in getHighestVerInVB() 747 if (storage[index].lbid == lbid) in removeEntry() 855 if (listEntry->lbid == lbid) in isEntryLocked() 1058 for (lbid = range.start; lbid <= lastLBID; lbid++) in removeEntriesFromDB() 1065 if (storage[index].lbid == lbid) in removeEntriesFromDB() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | vss.cpp | 64 lbid = -1; in VSSEntry() 399 if (lbid < 0) in insert() 413 entry.lbid = lbid; in insert() 515 if (listEntry->lbid == lbid) in lookup() 581 if (listEntry->lbid == lbid && !listEntry->vbFlag) in getCurrentVersion() 611 if ((listEntry->lbid == lbid && listEntry->vbFlag) && in getHighestVerInVB() 747 if (storage[index].lbid == lbid) in removeEntry() 855 if (listEntry->lbid == lbid) in isEntryLocked() 1058 for (lbid = range.start; lbid <= lastLBID; lbid++) in removeEntriesFromDB() 1065 if (storage[index].lbid == lbid) in removeEntriesFromDB() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_dbfileop.cpp | 119 const uint64_t lbid, in readDBFile() argument 130 fboOffset = (lbid) * (long)BYTE_PER_BLOCK; in readDBFile() 139 const uint64_t lbid, in readDBFile() argument 143 block->no = lbid; in readDBFile() 152 const uint64_t lbid ) in readDBFile() argument 158 if ( Cache::cacheKeyExist( cb.file.oid, lbid ) ) in readDBFile() 170 int fbo = lbid; in readDBFile() 308 range.start = lbid; in writeDBFile() 417 return writeDBFile( pFile, block->data, lbid ); in writeSubBlockEntry() 428 return writeDBFile( cb, block->data, lbid ); in writeSubBlockEntry() [all …]
|
H A D | we_dbfileop.h | 87 const uint64_t lbid, 91 const uint64_t lbid ); 95 const uint64_t lbid, 99 const uint64_t lbid ) in readDBFile() argument 101 return readDBFile( cb, block->data, lbid ); in readDBFile() 110 const uint64_t lbid, 118 const uint64_t lbid, 151 const uint64_t lbid, 155 const uint64_t lbid, 175 return writeDBFile( pFile, block->data, lbid ); in writeDBFile() [all …]
|
H A D | we_cache.h | 103 static bool cacheKeyExist( CacheMap* map, const OID oid, const uint64_t lbid ) 105 CacheKey key = getCacheKey( oid, lbid ); 110 return cacheKeyExist( map, (*buffer).cb.file.oid, (*buffer).block.lbid ); 112 static bool cacheKeyExist( const OID oid, const uint64_t lbid ) 114 return cacheKeyExist( m_lruList, oid, lbid ) || cacheKeyExist( m_writeList, oid, lbid ); 135 static CacheKey getCacheKey( const OID oid, const uint64_t lbid ) 137 CacheKey key = lbid; /*Convertor::int2Str( oid ) + "|" + Convertor::int2Str(lbid)*/; 142 return getCacheKey( (*buffer).cb.file.oid, (*buffer).block.lbid ); 159 …EXPORT static int insertLRUList( CommBlock& cb, const uint64_t lbid, const uint64_t fbo, const… 160 …static int insertLRUList( CommBlock& cb, const uint64_t lbid, const uint64_t fbo, const DataBl… [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_dbfileop.cpp | 119 const uint64_t lbid, in readDBFile() argument 130 fboOffset = (lbid) * (long)BYTE_PER_BLOCK; in readDBFile() 139 const uint64_t lbid, in readDBFile() argument 143 block->no = lbid; in readDBFile() 152 const uint64_t lbid ) in readDBFile() argument 158 if ( Cache::cacheKeyExist( cb.file.oid, lbid ) ) in readDBFile() 170 int fbo = lbid; in readDBFile() 308 range.start = lbid; in writeDBFile() 417 return writeDBFile( pFile, block->data, lbid ); in writeSubBlockEntry() 428 return writeDBFile( cb, block->data, lbid ); in writeSubBlockEntry() [all …]
|
H A D | we_dbfileop.h | 87 const uint64_t lbid, 91 const uint64_t lbid ); 95 const uint64_t lbid, 99 const uint64_t lbid ) in readDBFile() argument 101 return readDBFile( cb, block->data, lbid ); in readDBFile() 110 const uint64_t lbid, 118 const uint64_t lbid, 151 const uint64_t lbid, 155 const uint64_t lbid, 175 return writeDBFile( pFile, block->data, lbid ); in writeDBFile() [all …]
|
H A D | we_cache.h | 103 static bool cacheKeyExist( CacheMap* map, const OID oid, const uint64_t lbid ) 105 CacheKey key = getCacheKey( oid, lbid ); 110 return cacheKeyExist( map, (*buffer).cb.file.oid, (*buffer).block.lbid ); 112 static bool cacheKeyExist( const OID oid, const uint64_t lbid ) 114 return cacheKeyExist( m_lruList, oid, lbid ) || cacheKeyExist( m_writeList, oid, lbid ); 135 static CacheKey getCacheKey( const OID oid, const uint64_t lbid ) 137 CacheKey key = lbid; /*Convertor::int2Str( oid ) + "|" + Convertor::int2Str(lbid)*/; 142 return getCacheKey( (*buffer).cb.file.oid, (*buffer).block.lbid ); 159 …EXPORT static int insertLRUList( CommBlock& cb, const uint64_t lbid, const uint64_t fbo, const… 160 …static int insertLRUList( CommBlock& cb, const uint64_t lbid, const uint64_t fbo, const DataBl… [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/testbc/ |
H A D | blockcacheclient.cpp | 47 void blockCacheClient::check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache) in check() argument 49 fBCCBrp->check(lbid, ver, flg, wasBlockInCache); in check() 59 FileBuffer* blockCacheClient::getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in getBlockPtr() argument 61 FileBuffer* fb = fBCCBrp->getBlockPtr(lbid, ver); in getBlockPtr() 65 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() argument 67 int ret = fBCCBrp->read(lbid, ver, fb); in read() 71 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() argument 73 int ret = fBCCBrp->read(lbid, ver, bufferPtr); in read() 85 int ret = fBCCBrp->getBlock(lbid, ver, bufferPtr, flg, wasCached); in getBlock() 89 bool blockCacheClient::exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument [all …]
|
H A D | blockrequestprocessor.cpp | 138 if (fbMgr.exists(lbid, ver) == true) in check() 146 fileRequest rqstBlk(lbid, ver, flg); in check() 167 fb.lbid = range.start + idx; in read() 184 FileBuffer* BlockRequestProcessor::getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver ) in getBlockPtr() argument 187 HashObject_t hashObj = {lbid, ver, 0}; in getBlockPtr() 196 HashObject_t hashObj = {lbid, ver, 0}; in read() 207 HashObject_t hashObj = {lbid, ver, 0}; in read() 218 HashObject_t hashObj = {lbid, ver, 0}; in getBlock() 225 fileRequest rqstBlk(lbid, ver, flg, (uint8_t*) bufferPtr); in getBlock() 230 bool BlockRequestProcessor::exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument [all …]
|
H A D | filebuffermgr.cpp | 81 const HashObject_t fb = {lbid, ver, 0}; in exists() 182 gPMStatsPtr->markEvent(lbid, pthread_self(), gSession, 'I'); in insert() 185 HashObject_t fbIndex = { lbid, ver, 0}; in insert() 194 FBData_t fbdata = {lbid, ver}; in insert() 213 HashObject_t lastFB = {fbdata.lbid, fbdata.ver, 0}; in insert() 226 FileBuffer fb(lbid, ver, NULL, 0); in insert() 242 FileBuffer fb(lbid, ver, NULL, 0); in insert() 249 FileBuffer fb(lbid, ver, NULL, 0); in insert() 264 gPMStatsPtr->markEvent(lbid, pthread_self(), gSession, 'J'); in insert() 278 HashObject_t lastFB = {fbdata.lbid, fbdata.ver, 0}; in depleteCache() [all …]
|
H A D | filebuffermgr.h | 52 BRM::LBID_t lbid; member 64 return (((rhs.ver & 0xffffULL) << 48) | (rhs.lbid & 0xffffffffffffULL)); in operator() 73 return ((f1.lbid == f2.lbid) && (f1.ver == f2.ver)); in operator() 81 if (f1.lbid < f2.lbid) 83 else if (f1.lbid == f2.lbid) 119 bool exists(const BRM::LBID_t& lbid, const BRM::VER_t& ver) const; 129 const int insert(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data);
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/testbc/ |
H A D | blockcacheclient.cpp | 47 void blockCacheClient::check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache) in check() argument 49 fBCCBrp->check(lbid, ver, flg, wasBlockInCache); in check() 59 FileBuffer* blockCacheClient::getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in getBlockPtr() argument 61 FileBuffer* fb = fBCCBrp->getBlockPtr(lbid, ver); in getBlockPtr() 65 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() argument 67 int ret = fBCCBrp->read(lbid, ver, fb); in read() 71 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() argument 73 int ret = fBCCBrp->read(lbid, ver, bufferPtr); in read() 85 int ret = fBCCBrp->getBlock(lbid, ver, bufferPtr, flg, wasCached); in getBlock() 89 bool blockCacheClient::exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument [all …]
|
H A D | blockrequestprocessor.cpp | 138 if (fbMgr.exists(lbid, ver) == true) in check() 146 fileRequest rqstBlk(lbid, ver, flg); in check() 167 fb.lbid = range.start + idx; in read() 184 FileBuffer* BlockRequestProcessor::getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver ) in getBlockPtr() argument 187 HashObject_t hashObj = {lbid, ver, 0}; in getBlockPtr() 196 HashObject_t hashObj = {lbid, ver, 0}; in read() 207 HashObject_t hashObj = {lbid, ver, 0}; in read() 218 HashObject_t hashObj = {lbid, ver, 0}; in getBlock() 225 fileRequest rqstBlk(lbid, ver, flg, (uint8_t*) bufferPtr); in getBlock() 230 bool BlockRequestProcessor::exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument [all …]
|
H A D | filebuffermgr.cpp | 81 const HashObject_t fb = {lbid, ver, 0}; in exists() 182 gPMStatsPtr->markEvent(lbid, pthread_self(), gSession, 'I'); in insert() 185 HashObject_t fbIndex = { lbid, ver, 0}; in insert() 194 FBData_t fbdata = {lbid, ver}; in insert() 213 HashObject_t lastFB = {fbdata.lbid, fbdata.ver, 0}; in insert() 226 FileBuffer fb(lbid, ver, NULL, 0); in insert() 242 FileBuffer fb(lbid, ver, NULL, 0); in insert() 249 FileBuffer fb(lbid, ver, NULL, 0); in insert() 264 gPMStatsPtr->markEvent(lbid, pthread_self(), gSession, 'J'); in insert() 278 HashObject_t lastFB = {fbdata.lbid, fbdata.ver, 0}; in depleteCache() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
H A D | blockcacheclient.h | 63 fBCCBrp->check(lbid, ver, txn, flg, compType, wasBlockInCache); in check() 75 inline FileBuffer* getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver, bool flg) in getBlockPtr() argument 77 return fBCCBrp->getBlockPtr(lbid, ver, flg); in getBlockPtr() 83 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() argument 85 return fBCCBrp->read(lbid, ver, fb); in read() 91 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() argument 93 return fBCCBrp->read(lbid, ver, bufferPtr); in read() 110 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument 112 return fBCCBrp->exists(lbid, ver); in exists() 126 inline void flushOne(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in flushOne() argument [all …]
|
H A D | filebuffermgr.h | 61 FileBufferIndex(BRM::LBID_t l, BRM::VER_t v, uint32_t p) : lbid(l), ver(v), poolIdx(p) {} in FileBufferIndex() 62 BRM::LBID_t lbid; member 70 lbid(l), ver(v), data(d) { } in CacheInsert_t() 71 BRM::LBID_t lbid; member 83 return (((rhs.ver & 0xffffULL) << 48) | (rhs.lbid & 0xffffffffffffULL)); in operator() 92 return ((f1.lbid == f2.lbid) && (f1.ver == f2.ver)); in operator() 98 return ((f1.lbid < f2.lbid) || (f1.lbid == f2.lbid && f1.ver < f2.ver)); 127 bool exists(const BRM::LBID_t& lbid, const BRM::VER_t& ver) const; 137 int insert(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data); 157 void flushOne(const BRM::LBID_t lbid, const BRM::VER_t ver); [all …]
|
H A D | filebuffermgr.cpp | 158 BRM::LBID_t lbid; in flushMany() local 395 const HashObject_t fb(lbid, ver, 0); in exists() 596 HashObject_t fbIndex(lbid, ver, 0); in insert() 605 FBData_t fbdata = {lbid, ver, 0}; in insert() 653 FileBuffer fb(lbid, ver, NULL, 0); in insert() 672 FileBuffer fb(lbid, ver, NULL, 0); in insert() 679 FileBuffer fb(lbid, ver, NULL, 0); in insert() 788 fFBPool[poolIdx].Lbid(lbid); in doBlockCopy() 818 HashObject_t fbIndex(op.lbid, op.ver, 0); in bulkInsert() 835 fLog << op.lbid << " " << op.ver << ", "; in bulkInsert() [all …]
|
H A D | blockrequestprocessor.h | 88 inline FileBuffer* getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver, bool flg) in getBlockPtr() argument 90 return fbMgr.findPtr(HashObject_t(lbid, ver, flg)); in getBlockPtr() 93 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() argument 95 return (fbMgr.find(HashObject_t(lbid, ver, 0), fb) ? 1 : 0); in read() 101 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() argument 103 return (fbMgr.find(HashObject_t(lbid, ver, 0), bufferPtr) ? 1 : 0); in read() 106 … int getBlock(const BRM::LBID_t& lbid, const BRM::QueryContext& ver, BRM::VER_t txn, int compType, 113 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument 115 return fbMgr.exists(HashObject_t(lbid, ver, 0)); in exists() 129 void flushOne(BRM::LBID_t lbid, BRM::VER_t ver) in flushOne() argument [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
H A D | blockcacheclient.h | 63 fBCCBrp->check(lbid, ver, txn, flg, compType, wasBlockInCache); in check() 75 inline FileBuffer* getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver, bool flg) in getBlockPtr() argument 77 return fBCCBrp->getBlockPtr(lbid, ver, flg); in getBlockPtr() 83 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() argument 85 return fBCCBrp->read(lbid, ver, fb); in read() 91 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() argument 93 return fBCCBrp->read(lbid, ver, bufferPtr); in read() 110 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument 112 return fBCCBrp->exists(lbid, ver); in exists() 126 inline void flushOne(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in flushOne() argument [all …]
|
H A D | filebuffermgr.h | 61 FileBufferIndex(BRM::LBID_t l, BRM::VER_t v, uint32_t p) : lbid(l), ver(v), poolIdx(p) {} in FileBufferIndex() 62 BRM::LBID_t lbid; member 70 lbid(l), ver(v), data(d) { } in CacheInsert_t() 71 BRM::LBID_t lbid; member 83 return (((rhs.ver & 0xffffULL) << 48) | (rhs.lbid & 0xffffffffffffULL)); in operator() 92 return ((f1.lbid == f2.lbid) && (f1.ver == f2.ver)); in operator() 98 return ((f1.lbid < f2.lbid) || (f1.lbid == f2.lbid && f1.ver < f2.ver)); 127 bool exists(const BRM::LBID_t& lbid, const BRM::VER_t& ver) const; 137 int insert(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data); 157 void flushOne(const BRM::LBID_t lbid, const BRM::VER_t ver); [all …]
|
H A D | filebuffermgr.cpp | 158 BRM::LBID_t lbid; in flushMany() local 395 const HashObject_t fb(lbid, ver, 0); in exists() 596 HashObject_t fbIndex(lbid, ver, 0); in insert() 605 FBData_t fbdata = {lbid, ver, 0}; in insert() 653 FileBuffer fb(lbid, ver, NULL, 0); in insert() 672 FileBuffer fb(lbid, ver, NULL, 0); in insert() 679 FileBuffer fb(lbid, ver, NULL, 0); in insert() 788 fFBPool[poolIdx].Lbid(lbid); in doBlockCopy() 818 HashObject_t fbIndex(op.lbid, op.ver, 0); in bulkInsert() 835 fLog << op.lbid << " " << op.ver << ", "; in bulkInsert() [all …]
|
H A D | blockrequestprocessor.h | 88 inline FileBuffer* getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver, bool flg) in getBlockPtr() argument 90 return fbMgr.findPtr(HashObject_t(lbid, ver, flg)); in getBlockPtr() 93 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() argument 95 return (fbMgr.find(HashObject_t(lbid, ver, 0), fb) ? 1 : 0); in read() 101 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() argument 103 return (fbMgr.find(HashObject_t(lbid, ver, 0), bufferPtr) ? 1 : 0); in read() 106 … int getBlock(const BRM::LBID_t& lbid, const BRM::QueryContext& ver, BRM::VER_t txn, int compType, 113 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() argument 115 return fbMgr.exists(HashObject_t(lbid, ver, 0)); in exists() 129 void flushOne(BRM::LBID_t lbid, BRM::VER_t ver) in flushOne() argument [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/index/ |
H A D | we_indexlist_common.cpp | 245 m_blockZero.lbid = lbid0; in resetBlkZero() 369 uint64_t lbid; in setLastLbid() local 416 if ((m_hdrBlock.lbid == lbid) && (m_hdrBlock.state >= BLK_READ)) in setLastFboPtr() 422 else if ((m_curBlock.lbid == lbid) && (m_curBlock.state >= BLK_READ)) in setLastFboPtr() 454 uint64_t lbid; in getLastLbid() local 493 if ((m_hdrBlock.lbid == lbid) && (m_hdrBlock.state >= BLK_READ)) in getLastFboPtr() 498 else if ((m_curBlock.lbid == lbid) && (m_curBlock.state >= BLK_READ)) in getLastFboPtr() 523 uint64_t lbid; in getSubBlk() local 535 if (lbid != INVALID_LBID) in getSubBlk() 563 lbid = INVALID_LBID; in getSubBlk() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/index/ |
H A D | we_indexlist_common.cpp | 245 m_blockZero.lbid = lbid0; in resetBlkZero() 369 uint64_t lbid; in setLastLbid() local 416 if ((m_hdrBlock.lbid == lbid) && (m_hdrBlock.state >= BLK_READ)) in setLastFboPtr() 422 else if ((m_curBlock.lbid == lbid) && (m_curBlock.state >= BLK_READ)) in setLastFboPtr() 454 uint64_t lbid; in getLastLbid() local 493 if ((m_hdrBlock.lbid == lbid) && (m_hdrBlock.state >= BLK_READ)) in getLastFboPtr() 498 else if ((m_curBlock.lbid == lbid) && (m_curBlock.state >= BLK_READ)) in getLastFboPtr() 523 uint64_t lbid; in getSubBlk() local 535 if (lbid != INVALID_LBID) in getSubBlk() 563 lbid = INVALID_LBID; in getSubBlk() [all …]
|