Home
last modified time | relevance | path

Searched refs:BRM (Results 1 – 25 of 641) sorted by relevance

12345678910>>...26

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/blockcache/
H A Dblockrequestprocessor.h77 …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 Dblockcacheclient.h61 …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 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;
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 Dfilebuffer.h53 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 Dfilerequest.h66 …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 Dblockrequestprocessor.h77 …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 Dblockcacheclient.h61 …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 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;
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 Dfilebuffer.h53 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 Dfilerequest.h66 …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 Dwe_brm.h140 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 Dwe_brm.h140 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 Dblockcacheclient.h61 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 Dblockrequestprocessor.h72 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 Dblockcacheclient.cpp47 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 Dblockrequestprocessor.cpp62 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 Dfilebuffer.h55 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 Dfilerequest.h60 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 Dblockcacheclient.h61 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 Dblockrequestprocessor.h72 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 Dblockcacheclient.cpp47 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 Dblockrequestprocessor.cpp62 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 Dfilebuffer.h55 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 Dsessionmanager.h116 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 Dsessionmanager.h116 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;

12345678910>>...26