Method ClearSyncCtrl

phxqueue/store/syncctrl.cpp:200–272

}

void SyncCtrl::ClearSyncCtrl() {
    if (!impl_->buf) {
        QLErr("impl_->buf null");
        return;
    }

    const int topic_id{impl_->store->GetTopicID()};

    comm::RetCode ret;
    shared_ptr<const config::TopicConfig> topic_config;
    if (comm::RetCode::RET_OK !=
        (ret = config::GlobalConfig::GetThreadInstance()->
         GetTopicConfigByTopicID(topic_id, topic_config))) {
        QLErr("GetTopicConfigByTopicID ret %d", as_integer(ret));
        return;
    }

    thread_local uint64_t topic_config_last_mod_time{0};
    auto tmp_last_mod_time = topic_config->GetLastModTime();
    if (topic_config_last_mod_time == tmp_last_mod_time) return;
    topic_config_last_mod_time = tmp_last_mod_time;

    auto opt(impl_->store->GetStoreOption());
    comm::proto::Addr addr;
    addr.set_ip(opt->ip);
    addr.set_port(opt->port);
    addr.set_paxos_port(opt->paxos_port);

    shared_ptr<const config::StoreConfig> store_config;
    if (comm::RetCode::RET_OK !=
        (ret = config::GlobalConfig::GetThreadInstance()->
         GetStoreConfig(topic_id, store_config))) {
        QLErr("GetStoreConfig ret %d topic_id %d", as_integer(ret), topic_id);
        return;
    }

    int store_id;
    if (comm::RetCode::RET_OK != (ret = store_config->GetStoreIDByAddr(addr, store_id))) {
        QLErr("GetStoreIDByAddr ret %d", as_integer(ret));
        return;
    }

    set<int> pub_ids;
    if (comm::RetCode::RET_OK !=
        (ret = config::utils::GetPubIDsByStoreID(topic_id, store_id, pub_ids))) {
        QLErr("GetPubIDsByStoreID ret %d topic_id %d store_id %d",
              as_integer(ret), topic_id, store_id);
        return;
    }

    uint64_t cursor_id;
    for (int queue_id{0}; queue_id < opt->nqueue; ++queue_id) {
        for (int sub_id{1}; sub_id <= opt->nsub; ++sub_id) {
            bool valid = false;
            for (auto &&pub_id : pub_ids) {
                if (topic_config->IsValidQueue(queue_id, pub_id, sub_id)) {
                    valid = true;
                    break;