/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | vbbm.cpp | 79 vbOID = 0; in VBBMEntry() 482 if (vbOID == files[i].OID) in insert() 503 entry.vbOID = vbOID; in insert() 586 oid = storage[index].vbOID; in lookup() 603 fileIndex = addVBFileIfNotExists(vbOID); in getBlocks() 632 range.vbOID = files[fileIndex].OID; in getBlocks() 651 vbOID = it->vbOID; in getBlocks() 684 if (storage[i].lbid != -1 && storage[i].vbOID == vbOID && in getBlocks() 941 if (storage[j].vbOID == storage[i].vbOID && in checkConsistency() 1185 if (files[i].OID == vbOID) in addVBFileIfNotExists() [all …]
|
H A D | brmtypes.cpp | 153 vbOID = 0; in VBRange() 160 vbOID = v.vbOID; in VBRange() 171 vbOID = v.vbOID; in operator =() 182 vbOID = tmp; in deserialize() 189 bs << (uint32_t) vbOID; in serialize()
|
H A D | oidserver.h | 93 EXPORT int getDBRootOfVBOID(uint32_t vbOID); 98 EXPORT int getVBOIDOfDBRoot(uint32_t vbOID);
|
H A D | vbbm.h | 89 OID_t vbOID; member 206 EXPORT void getBlocks(int num, OID_t vbOID, std::vector<VBRange>& vbRanges, VSS& vss, 256 uint32_t addVBFileIfNotExists(OID_t vbOID);
|
H A D | slavedbrmnode.h | 364 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, 378 OID_t vbOID, 398 EXPORT int beginVBCopy(VER_t transID, uint16_t vbOID,
|
H A D | slavedbrmnode.cpp | 467 int SlaveDBRMNode::writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, in writeVBEntry() argument 506 vbbm.insert(lbid, oldVerID, vbOID, vbFBO); in writeVBEntry() 528 OID_t vbOID, in bulkWriteVBEntry() argument 569 vbbm.insert(lbids[i], oldVerID, vbOID, vbFBOs[i]); in bulkWriteVBEntry() 590 int SlaveDBRMNode::beginVBCopy(VER_t transID, uint16_t vbOID, in beginVBCopy() argument 704 vbbm.getBlocks(sum, vbOID, freeList, vss, flushPMCache); in beginVBCopy()
|
H A D | oidserver.cpp | 656 int OIDServer::getDBRootOfVBOID(uint32_t vbOID) in getDBRootOfVBOID() argument 659 if (vbOID >= vbOidDBRootMap.size()) in getDBRootOfVBOID() 662 return vbOidDBRootMap[vbOID]; in getDBRootOfVBOID()
|
H A D | dbrm.h | 615 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, 629 OID_t vbOID, 997 EXPORT int getDBRootOfVBOID(uint32_t vbOID);
|
H A D | slavecomm.cpp | 1728 OID_t vbOID; in do_writeVBEntry() local 1743 vbOID = tmp; in do_writeVBEntry() 1749 vbOID << " vbFBO=" << vbFBO << endl; in do_writeVBEntry() 1753 err = slave->writeVBEntry(transID, lbid, vbOID, vbFBO); in do_writeVBEntry() 1769 OID_t vbOID; in do_bulkWriteVBEntry() local 1783 vbOID = tmp; in do_bulkWriteVBEntry() 1792 vbOID << " vbFBO=" << vbFBOs[i] << endl; in do_bulkWriteVBEntry() 1796 err = slave->bulkWriteVBEntry(transID, lbids, vbOID, vbFBOs); in do_bulkWriteVBEntry()
|
H A D | dbrm.cpp | 2195 int DBRM::writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, in writeVBEntry() argument 2206 TRACER_ADDINPUT(vbOID); in writeVBEntry() 2216 command << WRITE_VB_ENTRY << (uint32_t) transID << (uint64_t) lbid << (uint32_t) vbOID << vbFBO; in writeVBEntry() 2232 OID_t vbOID, in bulkWriteVBEntry() argument 2251 command << (uint32_t) vbOID; in bulkWriteVBEntry() 2294 OID_t vbOID; in getDBRootsForRollback() local 2316 err = vbbm->lookup(it->lbid, transID, vbOID, tmp32); in getDBRootsForRollback() 2321 vbOIDs.insert(vbOID); in getDBRootsForRollback() 4001 int DBRM::getDBRootOfVBOID(uint32_t vbOID) in getDBRootOfVBOID() argument 4007 command << GETDBROOTOFVBOID << (uint32_t) vbOID; in getDBRootOfVBOID()
|
H A D | tdriver.cpp | 971 err = brm.writeVBEntry(1, i, vbRange.vbOID, vbRange.vbFBO + i); in brm_good_2() 1033 CPPUNIT_ASSERT(oid == vbRange.vbOID); in brm_good_2() 1166 err = brm.writeVBEntry(1, i, vbRange.vbOID, vbRange.vbFBO + i); in brm_good_3() 1399 vbbm.insert(i, i + 1, (*it).vbOID, fbo); in vbbm_good_1() 1403 CPPUNIT_ASSERT(oid == (*it).vbOID); in vbbm_good_1() 1429 CPPUNIT_ASSERT(oid == (*it).vbOID); in vbbm_good_1()
|
H A D | tdriver-load.cpp | 568 err = brm.writeVBEntry(1, i, vbRange.vbOID, vbRange.vbFBO + i); in brm_good_2() 627 CPPUNIT_ASSERT(oid == vbRange.vbOID); in brm_good_2() 756 err = brm.writeVBEntry(1, i, vbRange.vbOID, vbRange.vbFBO + i); in brm_good_3()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | vbbm.cpp | 79 vbOID = 0; in VBBMEntry() 482 if (vbOID == files[i].OID) in insert() 503 entry.vbOID = vbOID; in insert() 586 oid = storage[index].vbOID; in lookup() 603 fileIndex = addVBFileIfNotExists(vbOID); in getBlocks() 632 range.vbOID = files[fileIndex].OID; in getBlocks() 651 vbOID = it->vbOID; in getBlocks() 684 if (storage[i].lbid != -1 && storage[i].vbOID == vbOID && in getBlocks() 941 if (storage[j].vbOID == storage[i].vbOID && in checkConsistency() 1185 if (files[i].OID == vbOID) in addVBFileIfNotExists() [all …]
|
H A D | brmtypes.cpp | 153 vbOID = 0; in VBRange() 160 vbOID = v.vbOID; in VBRange() 171 vbOID = v.vbOID; in operator =() 182 vbOID = tmp; in deserialize() 189 bs << (uint32_t) vbOID; in serialize()
|
H A D | oidserver.h | 93 EXPORT int getDBRootOfVBOID(uint32_t vbOID); 98 EXPORT int getVBOIDOfDBRoot(uint32_t vbOID);
|
H A D | vbbm.h | 89 OID_t vbOID; member 206 EXPORT void getBlocks(int num, OID_t vbOID, std::vector<VBRange>& vbRanges, VSS& vss, 256 uint32_t addVBFileIfNotExists(OID_t vbOID);
|
H A D | slavedbrmnode.h | 364 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, 378 OID_t vbOID, 398 EXPORT int beginVBCopy(VER_t transID, uint16_t vbOID,
|
H A D | slavedbrmnode.cpp | 467 int SlaveDBRMNode::writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, in writeVBEntry() argument 506 vbbm.insert(lbid, oldVerID, vbOID, vbFBO); in writeVBEntry() 528 OID_t vbOID, in bulkWriteVBEntry() argument 569 vbbm.insert(lbids[i], oldVerID, vbOID, vbFBOs[i]); in bulkWriteVBEntry() 590 int SlaveDBRMNode::beginVBCopy(VER_t transID, uint16_t vbOID, in beginVBCopy() argument 704 vbbm.getBlocks(sum, vbOID, freeList, vss, flushPMCache); in beginVBCopy()
|
H A D | oidserver.cpp | 656 int OIDServer::getDBRootOfVBOID(uint32_t vbOID) in getDBRootOfVBOID() argument 659 if (vbOID >= vbOidDBRootMap.size()) in getDBRootOfVBOID() 662 return vbOidDBRootMap[vbOID]; in getDBRootOfVBOID()
|
H A D | dbrm.h | 615 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, 629 OID_t vbOID, 997 EXPORT int getDBRootOfVBOID(uint32_t vbOID);
|
H A D | slavecomm.cpp | 1728 OID_t vbOID; in do_writeVBEntry() local 1743 vbOID = tmp; in do_writeVBEntry() 1749 vbOID << " vbFBO=" << vbFBO << endl; in do_writeVBEntry() 1753 err = slave->writeVBEntry(transID, lbid, vbOID, vbFBO); in do_writeVBEntry() 1769 OID_t vbOID; in do_bulkWriteVBEntry() local 1783 vbOID = tmp; in do_bulkWriteVBEntry() 1792 vbOID << " vbFBO=" << vbFBOs[i] << endl; in do_bulkWriteVBEntry() 1796 err = slave->bulkWriteVBEntry(transID, lbids, vbOID, vbFBOs); in do_bulkWriteVBEntry()
|
H A D | dbrm.cpp | 2195 int DBRM::writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID, in writeVBEntry() argument 2206 TRACER_ADDINPUT(vbOID); in writeVBEntry() 2216 command << WRITE_VB_ENTRY << (uint32_t) transID << (uint64_t) lbid << (uint32_t) vbOID << vbFBO; in writeVBEntry() 2232 OID_t vbOID, in bulkWriteVBEntry() argument 2251 command << (uint32_t) vbOID; in bulkWriteVBEntry() 2294 OID_t vbOID; in getDBRootsForRollback() local 2316 err = vbbm->lookup(it->lbid, transID, vbOID, tmp32); in getDBRootsForRollback() 2321 vbOIDs.insert(vbOID); in getDBRootsForRollback() 4001 int DBRM::getDBRootOfVBOID(uint32_t vbOID) in getDBRootOfVBOID() argument 4007 command << GETDBROOTOFVBOID << (uint32_t) vbOID; in getDBRootOfVBOID()
|
H A D | tdriver.cpp | 971 err = brm.writeVBEntry(1, i, vbRange.vbOID, vbRange.vbFBO + i); in brm_good_2() 1033 CPPUNIT_ASSERT(oid == vbRange.vbOID); in brm_good_2() 1166 err = brm.writeVBEntry(1, i, vbRange.vbOID, vbRange.vbFBO + i); in brm_good_3() 1399 vbbm.insert(i, i + 1, (*it).vbOID, fbo); in vbbm_good_1() 1403 CPPUNIT_ASSERT(oid == (*it).vbOID); in vbbm_good_1() 1429 CPPUNIT_ASSERT(oid == (*it).vbOID); in vbbm_good_1()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_brm.cpp | 1672 cout << "\t VBOid : " << freeList[i].vbOID ; in writeVB() 1689 fileInfo.oid = freeList[0].vbOID; in writeVB() 1720 vbOid = freeList[0].vbOID; in writeVB() 1729 if (vbOid == freeList[i].vbOID) in writeVB() 1750 rc = blockRsltnMgrPtr->bulkWriteVBEntry(transID, lbids, freeList[i].vbOID, in writeVB()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_brm.cpp | 1672 cout << "\t VBOid : " << freeList[i].vbOID ; in writeVB() 1689 fileInfo.oid = freeList[0].vbOID; in writeVB() 1720 vbOid = freeList[0].vbOID; in writeVB() 1729 if (vbOid == freeList[i].vbOID) in writeVB() 1750 rc = blockRsltnMgrPtr->bulkWriteVBEntry(transID, lbids, freeList[i].vbOID, in writeVB()
|