Home
last modified time | relevance | path

Searched refs:vbOID (Results 1 – 25 of 34) sorted by relevance

12

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dvbbm.cpp79 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 Dbrmtypes.cpp153 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 Doidserver.h93 EXPORT int getDBRootOfVBOID(uint32_t vbOID);
98 EXPORT int getVBOIDOfDBRoot(uint32_t vbOID);
H A Dvbbm.h89 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 Dslavedbrmnode.h364 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 Dslavedbrmnode.cpp467 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 Doidserver.cpp656 int OIDServer::getDBRootOfVBOID(uint32_t vbOID) in getDBRootOfVBOID() argument
659 if (vbOID >= vbOidDBRootMap.size()) in getDBRootOfVBOID()
662 return vbOidDBRootMap[vbOID]; in getDBRootOfVBOID()
H A Ddbrm.h615 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 Dslavecomm.cpp1728 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 Ddbrm.cpp2195 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 Dtdriver.cpp971 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 Dtdriver-load.cpp568 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 Dvbbm.cpp79 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 Dbrmtypes.cpp153 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 Doidserver.h93 EXPORT int getDBRootOfVBOID(uint32_t vbOID);
98 EXPORT int getVBOIDOfDBRoot(uint32_t vbOID);
H A Dvbbm.h89 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 Dslavedbrmnode.h364 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 Dslavedbrmnode.cpp467 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 Doidserver.cpp656 int OIDServer::getDBRootOfVBOID(uint32_t vbOID) in getDBRootOfVBOID() argument
659 if (vbOID >= vbOidDBRootMap.size()) in getDBRootOfVBOID()
662 return vbOidDBRootMap[vbOID]; in getDBRootOfVBOID()
H A Ddbrm.h615 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 Dslavecomm.cpp1728 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 Ddbrm.cpp2195 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 Dtdriver.cpp971 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 Dwe_brm.cpp1672 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 Dwe_brm.cpp1672 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()

12