Method IsForceMaster

phxqueue/scheduler/schedulermgr.cpp:893–929

}

void SchedulerMgr::IsForceMaster(bool &force, bool &master) {
    force = false;

    comm::RetCode ret;

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

        return;
    }

    QLInfo("local %s:%d force master %s:%d",
           impl_->scheduler->GetSchedulerOption()->ip.c_str(),
           impl_->scheduler->GetSchedulerOption()->port,
           topic_config->GetProto().topic().scheduler_master_ip().c_str(),
           topic_config->GetProto().topic().scheduler_master_port());
    if (0 != topic_config->GetProto().topic().scheduler_master_port() &&
        !topic_config->GetProto().topic().scheduler_master_ip().empty() &&
        "0.0.0.0" != topic_config->GetProto().topic().scheduler_master_ip()) {
        force = true;
        if (impl_->scheduler->GetSchedulerOption()->ip ==
            topic_config->GetProto().topic().scheduler_master_ip() &&
            impl_->scheduler->GetSchedulerOption()->port ==
            topic_config->GetProto().topic().scheduler_master_port()) {
            master = true;

            return;
        }
        master = false;

        return;
    }

    return;
}

void SchedulerMgr::TraceMap(const int topic_id, const TopicData &topic_data) {
    string s;