/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
H A D | blockrequestprocessor.h | 77 …int check(BRM::LBID_t lbid, const BRM::QueryContext& ver, BRM::VER_t txn, bool flg, int compType, … 82 …int check(const BRM::InlineLBIDRange& range, const BRM::QueryContext& ver, const BRM::VER_t txn, c… 88 inline FileBuffer* getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver, bool flg) in getBlockPtr() 93 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() 101 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() 106 … int getBlock(const BRM::LBID_t& lbid, const BRM::QueryContext& ver, BRM::VER_t txn, int compType, 110 int getCachedBlocks(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** ptrs, 113 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() 129 void flushOne(BRM::LBID_t lbid, BRM::VER_t ver) in flushOne() 149 …void flushPartition(const std::vector<BRM::OID_t>& oids, const std::set<BRM::LogicalPartition>& pa… in flushPartition() [all …]
|
H A D | blockcacheclient.h | 61 …inline void check(BRM::LBID_t lbid, const BRM::QueryContext& ver, BRM::VER_t txn, bool flg, int co… in check() 69 …inline void check(const BRM::InlineLBIDRange& range, const BRM::QueryContext& ver, const BRM::VER_… in check() 75 inline FileBuffer* getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver, bool flg) in getBlockPtr() 83 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() 91 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() 96 …inline int getBlock(const BRM::LBID_t& lbid, const BRM::QueryContext& ver, const BRM::VER_t txn, c… 104 … inline int getCachedBlocks(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** bufferPtrs, in getCachedBlocks() 110 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() 126 inline void flushOne(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in flushOne() 142 inline void flushManyAllversion(const BRM::LBID_t* laVptr, uint32_t cnt) in flushManyAllversion() [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; 63 BRM::VER_t ver; 69 CacheInsert_t(const BRM::LBID_t& l, const BRM::VER_t& v, const uint8_t* d) : in CacheInsert_t() 71 BRM::LBID_t lbid; 72 BRM::VER_t 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); 185 uint32_t bulkFind(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** buffers, [all …]
|
H A D | filebuffer.h | 53 BRM::LBID_t lbid; 54 BRM::VER_t ver; 76 … FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data, const uint32_t len); 81 FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver); 139 inline BRM::LBID_t Lbid() const in Lbid() 143 inline void Lbid(const BRM::LBID_t l) in Lbid() 151 inline BRM::VER_t Verid() const in Verid() 155 inline void Verid(BRM::VER_t v) in Verid() 178 BRM::LBID_t fLbid; 179 BRM::VER_t fVerid;
|
H A D | filerequest.h | 66 …fileRequest(BRM::LBID_t lbid, const BRM::QueryContext& ver, bool flg, BRM::VER_t txn, int compType, 72 …fileRequest(const BRM::InlineLBIDRange& range, const BRM::QueryContext& ver, BRM::VER_t txn, int c… 133 BRM::LBID_t Lbid() const in Lbid() 141 const BRM::QueryContext Ver() const in Ver() 154 BRM::VER_t Txn() const in Txn() 307 BRM::LBID_t fLBID; 308 BRM::QueryContext fVer; 310 BRM::VER_t fTxn;
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/ |
H A D | blockrequestprocessor.h | 77 …int check(BRM::LBID_t lbid, const BRM::QueryContext& ver, BRM::VER_t txn, bool flg, int compType, … 82 …int check(const BRM::InlineLBIDRange& range, const BRM::QueryContext& ver, const BRM::VER_t txn, c… 88 inline FileBuffer* getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver, bool flg) in getBlockPtr() 93 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() 101 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() 106 … int getBlock(const BRM::LBID_t& lbid, const BRM::QueryContext& ver, BRM::VER_t txn, int compType, 110 int getCachedBlocks(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** ptrs, 113 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() 129 void flushOne(BRM::LBID_t lbid, BRM::VER_t ver) in flushOne() 149 …void flushPartition(const std::vector<BRM::OID_t>& oids, const std::set<BRM::LogicalPartition>& pa… in flushPartition() [all …]
|
H A D | blockcacheclient.h | 61 …inline void check(BRM::LBID_t lbid, const BRM::QueryContext& ver, BRM::VER_t txn, bool flg, int co… in check() 69 …inline void check(const BRM::InlineLBIDRange& range, const BRM::QueryContext& ver, const BRM::VER_… in check() 75 inline FileBuffer* getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver, bool flg) in getBlockPtr() 83 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() 91 inline int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() 96 …inline int getBlock(const BRM::LBID_t& lbid, const BRM::QueryContext& ver, const BRM::VER_t txn, c… 104 … inline int getCachedBlocks(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** bufferPtrs, in getCachedBlocks() 110 inline bool exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists() 126 inline void flushOne(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in flushOne() 142 inline void flushManyAllversion(const BRM::LBID_t* laVptr, uint32_t cnt) in flushManyAllversion() [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; 63 BRM::VER_t ver; 69 CacheInsert_t(const BRM::LBID_t& l, const BRM::VER_t& v, const uint8_t* d) : in CacheInsert_t() 71 BRM::LBID_t lbid; 72 BRM::VER_t 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); 185 uint32_t bulkFind(const BRM::LBID_t* lbids, const BRM::VER_t* vers, uint8_t** buffers, [all …]
|
H A D | filebuffer.h | 53 BRM::LBID_t lbid; 54 BRM::VER_t ver; 76 … FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data, const uint32_t len); 81 FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver); 139 inline BRM::LBID_t Lbid() const in Lbid() 143 inline void Lbid(const BRM::LBID_t l) in Lbid() 151 inline BRM::VER_t Verid() const in Verid() 155 inline void Verid(BRM::VER_t v) in Verid() 178 BRM::LBID_t fLbid; 179 BRM::VER_t fVerid;
|
H A D | filerequest.h | 66 …fileRequest(BRM::LBID_t lbid, const BRM::QueryContext& ver, bool flg, BRM::VER_t txn, int compType, 72 …fileRequest(const BRM::InlineLBIDRange& range, const BRM::QueryContext& ver, BRM::VER_t txn, int c… 133 BRM::LBID_t Lbid() const in Lbid() 141 const BRM::QueryContext Ver() const in Ver() 154 BRM::VER_t Txn() const in Txn() 307 BRM::LBID_t fLBID; 308 BRM::QueryContext fVer; 310 BRM::VER_t fTxn;
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_brm.h | 140 BRM::LBID_t& lbid ); 317 BRM::VER_t transID); 437 const BRM::VER_t transID, 453 BRM::DBRM* getDbrmObject(); 454 void pruneLBIDList(BRM::VER_t transID, 515 BRM::DBRM* blockRsltnMgrPtr; 523 blockRsltnMgrPtr = new BRM::DBRM(); in BRMWrapper() 534 inline BRM::DBRM* BRMWrapper::getDbrmObject() in getDbrmObject() 540 if (brmRc == BRM::ERR_OK) in getRC() 661 BRM::HWM_t hwm ) in rollbackColumnExtents_DBroot() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_brm.h | 140 BRM::LBID_t& lbid ); 317 BRM::VER_t transID); 437 const BRM::VER_t transID, 453 BRM::DBRM* getDbrmObject(); 454 void pruneLBIDList(BRM::VER_t transID, 515 BRM::DBRM* blockRsltnMgrPtr; 523 blockRsltnMgrPtr = new BRM::DBRM(); in BRMWrapper() 534 inline BRM::DBRM* BRMWrapper::getDbrmObject() in getDbrmObject() 540 if (brmRc == BRM::ERR_OK) in getRC() 661 BRM::HWM_t hwm ) in rollbackColumnExtents_DBroot() [all …]
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/testbc/ |
H A D | blockcacheclient.h | 61 void check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache); 66 void check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t& rCount); 71 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb); 73 FileBuffer* getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver); 78 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr); 83 … const int read(const BRM::InlineLBIDRange& range, FileBufferList_t& fbList, const BRM::VER_t ver); 85 const int getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr, 88 bool exists(BRM::LBID_t lbid, BRM::VER_t ver);
|
H A D | blockrequestprocessor.h | 72 int check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache); 77 int check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t& lbidCount); 82 FileBuffer* getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver); 84 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb); 89 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr); 94 … const int read(const BRM::InlineLBIDRange& range, FileBufferList_t& fbList, const BRM::VER_t ver); 96 const int getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr, 99 bool exists(BRM::LBID_t lbid, BRM::VER_t ver); 130 BRM::DBRM fdbrm;
|
H A D | blockcacheclient.cpp | 47 void blockCacheClient::check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache) in check() 53 void blockCacheClient::check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t& rCo… in check() 59 FileBuffer* blockCacheClient::getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in getBlockPtr() 65 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() 71 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() 77 const int blockCacheClient::read(const BRM::InlineLBIDRange& range, FileBufferList_t& fbList, const… in read() 83 const int blockCacheClient::getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPt… in getBlock() 89 bool blockCacheClient::exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists()
|
H A D | blockrequestprocessor.cpp | 62 int BlockRequestProcessor::check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t&… in check() 77 BRM::OID_t oid; in check() 93 BRM::InlineLBIDRange adjRange; in check() 103 BRM::OID_t oid; in check() 136 int BlockRequestProcessor::check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache) in check() 160 …onst int BlockRequestProcessor::read(const BRM::InlineLBIDRange& range, FileBufferList_t& readList… in read() 184 FileBuffer* BlockRequestProcessor::getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver ) in getBlockPtr() 193 const int BlockRequestProcessor::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& f… in read() 205 const int BlockRequestProcessor::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferP… in read() 216 const int BlockRequestProcessor::getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* buf… in getBlock() [all …]
|
H A D | filebuffer.h | 55 BRM::LBID_t lbid; 56 BRM::VER_t ver; 76 … FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data, const uint32_t len); 81 FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver); 138 const BRM::LBID_t Lbid() const in Lbid() 142 void Lbid(const BRM::LBID_t l) in Lbid() 150 const BRM::VER_t Verid() const in Verid() 154 void Verid(BRM::VER_t v) in Verid() 178 BRM::LBID_t fLbid; 179 BRM::VER_t fVerid;
|
H A D | filerequest.h | 60 fileRequest(BRM::LBID_t lbid, BRM::VER_t ver, bool flg); 62 fileRequest(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, uint8_t* ptr); 66 fileRequest(const BRM::InlineLBIDRange& range, const BRM::VER_t ver); 124 const BRM::LBID_t Lbid() const in Lbid() 132 const BRM::VER_t Ver() const in Ver() 246 BRM::LBID_t fLBID; 247 BRM::VER_t fVer;
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/testbc/ |
H A D | blockcacheclient.h | 61 void check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache); 66 void check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t& rCount); 71 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb); 73 FileBuffer* getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver); 78 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr); 83 … const int read(const BRM::InlineLBIDRange& range, FileBufferList_t& fbList, const BRM::VER_t ver); 85 const int getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr, 88 bool exists(BRM::LBID_t lbid, BRM::VER_t ver);
|
H A D | blockrequestprocessor.h | 72 int check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache); 77 int check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t& lbidCount); 82 FileBuffer* getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver); 84 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb); 89 const int read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr); 94 … const int read(const BRM::InlineLBIDRange& range, FileBufferList_t& fbList, const BRM::VER_t ver); 96 const int getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr, 99 bool exists(BRM::LBID_t lbid, BRM::VER_t ver); 130 BRM::DBRM fdbrm;
|
H A D | blockcacheclient.cpp | 47 void blockCacheClient::check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache) in check() 53 void blockCacheClient::check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t& rCo… in check() 59 FileBuffer* blockCacheClient::getBlockPtr(const BRM::LBID_t& lbid, const BRM::VER_t& ver) in getBlockPtr() 65 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& fb) in read() 71 const int blockCacheClient::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPtr) in read() 77 const int blockCacheClient::read(const BRM::InlineLBIDRange& range, FileBufferList_t& fbList, const… in read() 83 const int blockCacheClient::getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferPt… in getBlock() 89 bool blockCacheClient::exists(BRM::LBID_t lbid, BRM::VER_t ver) in exists()
|
H A D | blockrequestprocessor.cpp | 62 int BlockRequestProcessor::check(const BRM::InlineLBIDRange& range, const BRM::VER_t ver, uint32_t&… in check() 77 BRM::OID_t oid; in check() 93 BRM::InlineLBIDRange adjRange; in check() 103 BRM::OID_t oid; in check() 136 int BlockRequestProcessor::check(BRM::LBID_t lbid, BRM::VER_t ver, bool flg, bool& wasBlockInCache) in check() 160 …onst int BlockRequestProcessor::read(const BRM::InlineLBIDRange& range, FileBufferList_t& readList… in read() 184 FileBuffer* BlockRequestProcessor::getBlockPtr(const BRM::LBID_t lbid, const BRM::VER_t ver ) in getBlockPtr() 193 const int BlockRequestProcessor::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, FileBuffer& f… in read() 205 const int BlockRequestProcessor::read(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* bufferP… in read() 216 const int BlockRequestProcessor::getBlock(const BRM::LBID_t& lbid, const BRM::VER_t& ver, void* buf… in getBlock() [all …]
|
H A D | filebuffer.h | 55 BRM::LBID_t lbid; 56 BRM::VER_t ver; 76 … FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver, const uint8_t* data, const uint32_t len); 81 FileBuffer(const BRM::LBID_t lbid, const BRM::VER_t ver); 138 const BRM::LBID_t Lbid() const in Lbid() 142 void Lbid(const BRM::LBID_t l) in Lbid() 150 const BRM::VER_t Verid() const in Verid() 154 void Verid(BRM::VER_t v) in Verid() 178 BRM::LBID_t fLbid; 179 BRM::VER_t fVerid;
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/execplan/ |
H A D | sessionmanager.h | 116 const BRM::QueryContext verID(); 122 const BRM::QueryContext sysCatVerID(); 137 const BRM::TxnID newTxnID(const SID session, bool block = true, bool isDDL = false); 147 void committed(BRM::TxnID& txnid); 157 void rolledback(BRM::TxnID& txnid); 167 const BRM::TxnID getTxnID(const SID session); 180 boost::shared_array<BRM::SIDTIDEntry> SIDTIDMap(int& len); 209 bool checkActiveTransaction(const SID sessionId, bool& bIsDbrmUp, BRM::SIDTIDEntry& blocker); 213 BRM::DBRM dbrm;
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/execplan/ |
H A D | sessionmanager.h | 116 const BRM::QueryContext verID(); 122 const BRM::QueryContext sysCatVerID(); 137 const BRM::TxnID newTxnID(const SID session, bool block = true, bool isDDL = false); 147 void committed(BRM::TxnID& txnid); 157 void rolledback(BRM::TxnID& txnid); 167 const BRM::TxnID getTxnID(const SID session); 180 boost::shared_array<BRM::SIDTIDEntry> SIDTIDMap(int& len); 209 bool checkActiveTransaction(const SID sessionId, bool& bIsDbrmUp, BRM::SIDTIDEntry& blocker); 213 BRM::DBRM dbrm;
|