| 322 | |
| 323 | |
| 324 | comm::RetCode TopicConfig::GetQueueInfoIDRankByPubID(const int queue_info_id, const int pub_id, uint64_t &rank) const { |
| 325 | rank = 0; |
| 326 | |
| 327 | shared_ptr<const proto::Pub> pub; |
| 328 | |
| 329 | comm::RetCode ret; |
| 330 | if (comm::RetCode::RET_OK != (ret = GetPubByPubID(pub_id, pub)) || !pub) { |
| 331 | return ret; |
| 332 | } |
| 333 | return GetQueueInfoIDRankByPub(queue_info_id, pub.get(), rank); |
| 334 | } |
| 335 | |
| 336 | |
| 337 | bool TopicConfig::IsValidQueue(const int queue_id, const int pub_id, const int sub_id) const { |
no outgoing calls