Method Init

phxqueue/scheduler/scheduler.cpp:56–97

}

comm::RetCode Scheduler::Init() {
    comm::RetCode ret;

    if (impl_->opt.log_func) {
        comm::Logger::GetInstance()->SetLogFunc(impl_->opt.log_func);
    }

    if (impl_->opt.config_factory_create_func) {
        plugin::ConfigFactory::SetConfigFactoryCreateFunc(impl_->opt.config_factory_create_func);
    }

    if (impl_->opt.break_point_factory_create_func) {
        plugin::BreakPointFactory::SetBreakPointFactoryCreateFunc(impl_->opt.break_point_factory_create_func);
    }

    impl_->addr.set_ip(impl_->opt.ip);
    impl_->addr.set_port(impl_->opt.port);

    ret = InitTopicID();
    if (comm::RetCode::RET_OK != ret) {
        QLErr("InitTopicID ret %d", as_integer(ret));

        return ret;
    }

    impl_->scheduler_mgr = unique_ptr<SchedulerMgr>(new SchedulerMgr(this));

    impl_->load_balance_thread = unique_ptr<LoadBalanceThread>(new LoadBalanceThread(this));
    impl_->keep_master_thread = unique_ptr<KeepMasterThread>(new KeepMasterThread(this));

    ret = impl_->scheduler_mgr->Init();
    if (comm::RetCode::RET_OK != ret) {
        QLErr("scheduler_mgr Init ret %d", as_integer(ret));

        return ret;
    }

    impl_->load_balance_thread->Run();
    impl_->keep_master_thread->Run();

    return comm::RetCode::RET_OK;
}

comm::RetCode Scheduler::Dispose() {
    comm::SchedulerBP::GetThreadInstance()->OnDispose();