Home
last modified time | relevance | path

Searched refs:lbid (Results 1 – 25 of 227) sorted by relevance

12345678910

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dvss.cpp64 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 Dvss.cpp64 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 Dwe_dbfileop.cpp119 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 Dwe_dbfileop.h87 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 Dwe_cache.h103 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 Dwe_dbfileop.cpp119 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 Dwe_dbfileop.h87 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 Dwe_cache.h103 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 Dblockcacheclient.cpp47 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 Dblockrequestprocessor.cpp138 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 Dfilebuffermgr.cpp81 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 Dfilebuffermgr.h52 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 Dblockcacheclient.cpp47 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 Dblockrequestprocessor.cpp138 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 Dfilebuffermgr.cpp81 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 Dblockcacheclient.h63 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 Dfilebuffermgr.h61 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 Dfilebuffermgr.cpp158 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 Dblockrequestprocessor.h88 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 Dblockcacheclient.h63 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 Dfilebuffermgr.h61 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 Dfilebuffermgr.cpp158 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 Dblockrequestprocessor.h88 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 Dwe_indexlist_common.cpp245 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 Dwe_indexlist_common.cpp245 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 …]

12345678910