| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/ddlcleanup/ |
| H A D | ddlcleanuputil.cpp | 145 rc = dbrmp->markPartitionForDeletion( aLogInfo.oids, aLogInfo.partitionNums, emsg); in ddl_cleanup()
154 … ddlpackageprocessor.removePartitionFiles( aLogInfo.oids, aLogInfo.partitionNums, uniqueId ); in ddl_cleanup()
155 cacheutils::flushPartition( aLogInfo.oids, aLogInfo.partitionNums ); in ddl_cleanup()
157 rc = dbrmp->deletePartition( aLogInfo.oids, aLogInfo.partitionNums, emsg); in ddl_cleanup()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/ddlcleanup/ |
| H A D | ddlcleanuputil.cpp | 145 rc = dbrmp->markPartitionForDeletion( aLogInfo.oids, aLogInfo.partitionNums, emsg); in ddl_cleanup()
154 … ddlpackageprocessor.removePartitionFiles( aLogInfo.oids, aLogInfo.partitionNums, uniqueId ); in ddl_cleanup()
155 cacheutils::flushPartition( aLogInfo.oids, aLogInfo.partitionNums ); in ddl_cleanup()
157 rc = dbrmp->deletePartition( aLogInfo.oids, aLogInfo.partitionNums, emsg); in ddl_cleanup()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/mysql/ |
| H A D | ha_mcs_partition.cpp | 449 set<LogicalPartition>& partitionNums, in parsePartitionString() argument
464 partitionNums.clear(); in parsePartitionString()
529 partitionNums.insert(lp); in parsePartitionString()
532 if (partitionNums.empty()) in parsePartitionString()
547 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in parsePartitionString()
900 stmt->fPartitions = partitionNums; in ha_mcs_impl_markpartitions_()
922 stmt->fPartitions = partitionNums; in ha_mcs_impl_restorepartitions_()
945 stmt->fPartitions = partitionNums; in ha_mcs_impl_droppartitions_()
1231 set <LogicalPartition> partitionNums; in caldisablepartitions() local
1238 parsePartitionString(args, 2, partitionNums, errMsg, tableName); in caldisablepartitions()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/mysql/ |
| H A D | ha_mcs_partition.cpp | 449 set<LogicalPartition>& partitionNums, in parsePartitionString() argument
464 partitionNums.clear(); in parsePartitionString()
529 partitionNums.insert(lp); in parsePartitionString()
532 if (partitionNums.empty()) in parsePartitionString()
547 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in parsePartitionString()
900 stmt->fPartitions = partitionNums; in ha_mcs_impl_markpartitions_()
922 stmt->fPartitions = partitionNums; in ha_mcs_impl_restorepartitions_()
945 stmt->fPartitions = partitionNums; in ha_mcs_impl_droppartitions_()
1231 set <LogicalPartition> partitionNums; in caldisablepartitions() local
1238 parsePartitionString(args, 2, partitionNums, errMsg, tableName); in caldisablepartitions()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
| H A D | slavecomm.cpp | 1469 set<LogicalPartition> partitionNums; in do_deletePartition() local
1470 deserializeSet<LogicalPartition>(msg, partitionNums); in do_deletePartition()
1479 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in do_deletePartition()
1499 err = slave->deletePartition(oids, partitionNums, emsg); in do_deletePartition()
1532 set<LogicalPartition> partitionNums; in do_markPartitionForDeletion() local
1533 deserializeSet<LogicalPartition>(msg, partitionNums); in do_markPartitionForDeletion()
1541 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in do_markPartitionForDeletion()
1642 set<LogicalPartition> partitionNums; in do_restorePartition() local
1643 deserializeSet<LogicalPartition>(msg, partitionNums); in do_restorePartition()
1652 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in do_restorePartition()
[all …]
|
| H A D | extentmap.cpp | 4749 for (partIt=partitionNums.begin(); partIt!=partitionNums.end(); ++partIt) in deletePartition()
4786 (partitionNums.find(lp) != partitionNums.end())) in deletePartition()
4804 for (partIt = partitionNums.begin(); in deletePartition()
4853 for (partIt=partitionNums.begin(); partIt!=partitionNums.end(); ++partIt) in markPartitionForDeletion()
4890 (partitionNums.find(lp) != partitionNums.end())) in markPartitionForDeletion()
4921 for (partIt = partitionNums.begin(); in markPartitionForDeletion()
5019 for (partIt=partitionNums.begin(); partIt!=partitionNums.end(); ++partIt) in restorePartition()
5051 if ((fExtentMap[i].range.size != 0 ) && partitionNums.find(lp) != partitionNums.end()) in restorePartition()
5074 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in restorePartition()
5121 partitionNums.clear(); in getOutOfServicePartitions()
[all …]
|
| H A D | dbrm.h | 556 … const std::set<LogicalPartition>& partitionNums, std::string& emsg) DBRM_THROW;
571 … const std::set<LogicalPartition>& partitionNums, std::string& emsg) DBRM_THROW;
579 … const std::set<LogicalPartition>& partitionNums, std::string& emsg) DBRM_THROW;
588 std::set<LogicalPartition>& partitionNums) throw();
|
| H A D | extentmap.h | 772 const std::set<LogicalPartition>& partitionNums, std::string& emsg);
780 … const std::set<LogicalPartition>& partitionNums, std::string& emsg);
794 … const std::set<LogicalPartition>& partitionNums, std::string& emsg);
803 std::set<LogicalPartition>& partitionNums);
|
| H A D | slavedbrmnode.h | 326 … std::set<LogicalPartition>& partitionNums, std::string& emsg) throw();
334 … std::set<LogicalPartition>& partitionNums, std::string& emsg) throw();
|
| H A D | slavedbrmnode.cpp | 1227 set<LogicalPartition>& partitionNums, string& emsg) throw() in deletePartition() argument
1231 em.deletePartition(oids, partitionNums, emsg); in deletePartition()
1265 set<LogicalPartition>& partitionNums, string& emsg) throw() in markPartitionForDeletion() argument
1269 em.markPartitionForDeletion(oids, partitionNums, emsg); in markPartitionForDeletion()
1340 set<LogicalPartition>& partitionNums, string& emsg) throw() in restorePartition() argument
1344 em.restorePartition(oids, partitionNums, emsg); in restorePartition()
|
| H A D | dbrm.cpp | 1876 const std::set<LogicalPartition>& partitionNums, string& emsg) DBRM_THROW in deletePartition() argument
1887 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in deletePartition()
1906 serializeSet<LogicalPartition>(command, partitionNums); in deletePartition()
1935 … const std::set<LogicalPartition>& partitionNums, string& emsg) DBRM_THROW in markPartitionForDeletion() argument
1946 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in markPartitionForDeletion()
1965 serializeSet<LogicalPartition>(command, partitionNums); in markPartitionForDeletion()
2041 const std::set<LogicalPartition>& partitionNums, string& emsg) DBRM_THROW in restorePartition() argument
2052 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in restorePartition()
2072 serializeSet<LogicalPartition>(command, partitionNums); in restorePartition()
2100 std::set<LogicalPartition>& partitionNums) throw() in getOutOfServicePartitions() argument
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
| H A D | slavecomm.cpp | 1469 set<LogicalPartition> partitionNums; in do_deletePartition() local
1470 deserializeSet<LogicalPartition>(msg, partitionNums); in do_deletePartition()
1479 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in do_deletePartition()
1499 err = slave->deletePartition(oids, partitionNums, emsg); in do_deletePartition()
1532 set<LogicalPartition> partitionNums; in do_markPartitionForDeletion() local
1533 deserializeSet<LogicalPartition>(msg, partitionNums); in do_markPartitionForDeletion()
1541 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in do_markPartitionForDeletion()
1642 set<LogicalPartition> partitionNums; in do_restorePartition() local
1643 deserializeSet<LogicalPartition>(msg, partitionNums); in do_restorePartition()
1652 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in do_restorePartition()
[all …]
|
| H A D | extentmap.cpp | 4749 for (partIt=partitionNums.begin(); partIt!=partitionNums.end(); ++partIt) in deletePartition()
4786 (partitionNums.find(lp) != partitionNums.end())) in deletePartition()
4804 for (partIt = partitionNums.begin(); in deletePartition()
4853 for (partIt=partitionNums.begin(); partIt!=partitionNums.end(); ++partIt) in markPartitionForDeletion()
4890 (partitionNums.find(lp) != partitionNums.end())) in markPartitionForDeletion()
4921 for (partIt = partitionNums.begin(); in markPartitionForDeletion()
5019 for (partIt=partitionNums.begin(); partIt!=partitionNums.end(); ++partIt) in restorePartition()
5051 if ((fExtentMap[i].range.size != 0 ) && partitionNums.find(lp) != partitionNums.end()) in restorePartition()
5074 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in restorePartition()
5121 partitionNums.clear(); in getOutOfServicePartitions()
[all …]
|
| H A D | dbrm.h | 556 … const std::set<LogicalPartition>& partitionNums, std::string& emsg) DBRM_THROW;
571 … const std::set<LogicalPartition>& partitionNums, std::string& emsg) DBRM_THROW;
579 … const std::set<LogicalPartition>& partitionNums, std::string& emsg) DBRM_THROW;
588 std::set<LogicalPartition>& partitionNums) throw();
|
| H A D | extentmap.h | 772 const std::set<LogicalPartition>& partitionNums, std::string& emsg);
780 … const std::set<LogicalPartition>& partitionNums, std::string& emsg);
794 … const std::set<LogicalPartition>& partitionNums, std::string& emsg);
803 std::set<LogicalPartition>& partitionNums);
|
| H A D | slavedbrmnode.h | 326 … std::set<LogicalPartition>& partitionNums, std::string& emsg) throw();
334 … std::set<LogicalPartition>& partitionNums, std::string& emsg) throw();
|
| H A D | slavedbrmnode.cpp | 1227 set<LogicalPartition>& partitionNums, string& emsg) throw() in deletePartition() argument
1231 em.deletePartition(oids, partitionNums, emsg); in deletePartition()
1265 set<LogicalPartition>& partitionNums, string& emsg) throw() in markPartitionForDeletion() argument
1269 em.markPartitionForDeletion(oids, partitionNums, emsg); in markPartitionForDeletion()
1340 set<LogicalPartition>& partitionNums, string& emsg) throw() in restorePartition() argument
1344 em.restorePartition(oids, partitionNums, emsg); in restorePartition()
|
| H A D | dbrm.cpp | 1876 const std::set<LogicalPartition>& partitionNums, string& emsg) DBRM_THROW in deletePartition() argument
1887 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in deletePartition()
1906 serializeSet<LogicalPartition>(command, partitionNums); in deletePartition()
1935 … const std::set<LogicalPartition>& partitionNums, string& emsg) DBRM_THROW in markPartitionForDeletion() argument
1946 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in markPartitionForDeletion()
1965 serializeSet<LogicalPartition>(command, partitionNums); in markPartitionForDeletion()
2041 const std::set<LogicalPartition>& partitionNums, string& emsg) DBRM_THROW in restorePartition() argument
2052 for (partIt = partitionNums.begin(); partIt != partitionNums.end(); ++partIt) in restorePartition()
2072 serializeSet<LogicalPartition>(command, partitionNums); in restorePartition()
2100 std::set<LogicalPartition>& partitionNums) throw() in getOutOfServicePartitions() argument
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/ |
| H A D | ddlpackageprocessor.cpp | 1262 PartitionNums partitionNums; in fetchLogFile() local
1277 partitionNums.insert(lp); in fetchLogFile()
1284 aLog.partitionNums = partitionNums; in fetchLogFile()
1311 const PartitionNums& partitionNums, in createWritePartitionLogFile() argument
1327 bytestream << (uint32_t) partitionNums.size(); in createWritePartitionLogFile()
1330 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in createWritePartitionLogFile()
|
| H A D | ddlpackageprocessor.h | 109 PartitionNums partitionNums; member
379 const PartitionNums& partitionNums,
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/ddlpackageproc/ |
| H A D | ddlpackageprocessor.cpp | 1262 PartitionNums partitionNums; in fetchLogFile() local
1277 partitionNums.insert(lp); in fetchLogFile()
1284 aLog.partitionNums = partitionNums; in fetchLogFile()
1311 const PartitionNums& partitionNums, in createWritePartitionLogFile() argument
1327 bytestream << (uint32_t) partitionNums.size(); in createWritePartitionLogFile()
1330 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in createWritePartitionLogFile()
|
| H A D | ddlpackageprocessor.h | 109 PartitionNums partitionNums; member
379 const PartitionNums& partitionNums,
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/cacheutils/ |
| H A D | cacheutils.cpp | 274 int flushPartition(const std::vector<BRM::OID_t>& oids, set<BRM::LogicalPartition>& partitionNums) in flushPartition() argument
293 serializeSet<BRM::LogicalPartition>(bs, partitionNums); in flushPartition()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/cacheutils/ |
| H A D | cacheutils.cpp | 274 int flushPartition(const std::vector<BRM::OID_t>& oids, set<BRM::LogicalPartition>& partitionNums) in flushPartition() argument
293 serializeSet<BRM::LogicalPartition>(bs, partitionNums); in flushPartition()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/server/ |
| H A D | we_ddlcommandproc.cpp | 3668 std::set<BRM::LogicalPartition> partitionNums; in writeDropPartitionLog() local
3675 partitionNums.insert(lp); in writeDropPartitionLog()
3730 for (it = partitionNums.begin(); it != partitionNums.end(); ++it) in writeDropPartitionLog()
4000 vector<BRM::LogicalPartition> partitionNums; in fetchDDLLog() local
4022 partitionNums.push_back(partition); in fetchDDLLog()
4037 bs << (uint32_t) partitionNums.size(); in fetchDDLLog()
4039 for ( unsigned j = 0; j < partitionNums.size(); j++ ) in fetchDDLLog()
4041 partitionNums[j].serialize(bs); in fetchDDLLog()
|