| 99 | } |
| 100 | |
| 101 | comm::RetCode KeepMasterThread::AdjustMasterRate() { |
| 102 | // TODO: |
| 103 | //MMPHXQueueSchedConfig *conf{mgr_->mutable_conf()}; |
| 104 | |
| 105 | //Comm::ZKMgrClient *ptZKMgrClient{Comm::ZKMgrClient::GetDefault()}; |
| 106 | //if (ptZKMgrClient && ptZKMgrClient->IsSvrBlocked(conf->GetEpollConfig()->GetSvrIP(), |
| 107 | // conf->GetEpollConfig()->GetSvrPort())) { |
| 108 | // OssAttr4SvrClientMasterHostShieldGlobal(conf->GetEpollConfig()->GetOssAttrID(), 1); |
| 109 | // QLInfo("svr %s:%d blocked", conf->GetEpollConfig()->GetSvrIP(), conf->GetEpollConfig()->GetSvrPort()); |
| 110 | // impl_->master_rate = 0; |
| 111 | //} else { |
| 112 | // impl_->master_rate = 100; |
| 113 | //} |
| 114 | |
| 115 | QLInfo("MASTERSTAT: master_rate %d", impl_->master_rate); |
| 116 | |
| 117 | return comm::RetCode::RET_OK; |
| 118 | } |
| 119 | |
| 120 | comm::RetCode KeepMasterThread::KeepMaster() { |
| 121 | const int topic_id{impl_->scheduler->GetTopicID()}; |
nothing calls this directly
no outgoing calls
no test coverage detected