|
@@ -53,7 +53,9 @@ int AcqVendor::Run()
|
|
{
|
|
{
|
|
std::vector<settings::ConfigParser::DataCenter> dataCenters = configParser_.GetDataCenter();
|
|
std::vector<settings::ConfigParser::DataCenter> dataCenters = configParser_.GetDataCenter();
|
|
for(settings::ConfigParser::DataCenter &dc: dataCenters) {
|
|
for(settings::ConfigParser::DataCenter &dc: dataCenters) {
|
|
|
|
+ HTELINK_LOG_INFO("add rpc %s, yunId = %d", dc.name.c_str(), dc.yunID);
|
|
std::shared_ptr<leoyun::YunRpc> rpc = leoyun::YunRpc::GetRpcInstance(dc.yunID);
|
|
std::shared_ptr<leoyun::YunRpc> rpc = leoyun::YunRpc::GetRpcInstance(dc.yunID);
|
|
|
|
+ ASSERT(rpc != nullptr);
|
|
rpc->SetDataCenter(dc);
|
|
rpc->SetDataCenter(dc);
|
|
acqTask_->PushRpc(dc.name, rpc);
|
|
acqTask_->PushRpc(dc.name, rpc);
|
|
}
|
|
}
|