breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Optimize Kafka client compare_topics

Browse Source
This commit is contained in:
Xie Han
2023-07-05 21:10:28 +08:00
parent 86ff9fbc1b
commit 7dd352ac3d
1 changed files with 16 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/client/WFKafkaClient.cc
View File

@@ -766,25 +766,26 @@ void KafkaClientTask::set_meta_status(bool status)
bool KafkaClientTask::compare_topics(KafkaClientTask *task)
{
protocol::KafkaMetaList *meta_list1 = &this->meta_list;
protocol::KafkaMetaList *meta_list2 = &task->meta_list;
KafkaMeta *meta1, *meta2;
auto first1 = topic_set.cbegin(), last1 = topic_set.cend();
auto first2 = task->topic_set.cbegin(), last2 = task->topic_set.cend();
int cmp;
meta_list1->rewind();
meta_list2->rewind();
while (1)
// check whether task->topic_set is a subset of topic_set
while (first1 != last1 && first2 != last2)
{
meta1 = meta_list1->get_next();
meta2 = meta_list2->get_next();
if (!meta1 && !meta2)
return true;
if (!meta1 || !meta2)
return false;
if (strcmp(meta1->get_topic(), meta2->get_topic()))
cmp = first1->compare(*first2);
if (cmp == 0)
{
++first1;
++first2;
}
else if (cmp < 0)
++first1;
else
return false;
}
return first2 == last2;
}
bool KafkaClientTask::check_cgroup()