| 560 | } |
| 561 | |
| 562 | comm::RetCode SchedulerMgr::BuildTopicScaleResponse(const TopicData &topic_data, |
| 563 | comm::proto::GetAddrScaleResponse &resp) { |
| 564 | resp.mutable_addr_scales()->Clear(); |
| 565 | resp.mutable_addr_scales()->Reserve(topic_data.consumer_addr2info_map.size()); |
| 566 | for (auto &&consumer_addr2info_kv : topic_data.consumer_addr2info_map) { |
| 567 | comm::proto::AddrScale *addr_scale{resp.add_addr_scales()}; |
| 568 | comm::utils::DecodeAddr(consumer_addr2info_kv.first, *(addr_scale->mutable_addr())); |
| 569 | addr_scale->set_scale(consumer_addr2info_kv.second.weight); |
| 570 | } |
| 571 | |
| 572 | return comm::RetCode::RET_OK; |
| 573 | } |
| 574 | |
| 575 | comm::RetCode SchedulerMgr::BuildTopicScaleString(const TopicData &topic_data, string &s) { |
| 576 | for (auto &&consumer_addr2info_kv : topic_data.consumer_addr2info_map) { |
nothing calls this directly
no test coverage detected