| 212 | |
| 213 | |
| 214 | void CheckConfig::CheckConsumerConfig(const int topic_id, const config::ConsumerConfig *consumer_config) { |
| 215 | |
| 216 | std::vector<std::shared_ptr<const config::proto::Consumer>> consumers; |
| 217 | |
| 218 | PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(consumer_config->GetAllConsumer(consumers))); |
| 219 | |
| 220 | for (auto &&consumer : consumers) { |
| 221 | std::shared_ptr<const config::proto::Consumer> tmp_consumer; |
| 222 | PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(consumer_config->GetConsumerByAddr(consumer->addr(), tmp_consumer))); |
| 223 | } |
| 224 | } |
| 225 | |
| 226 | void CheckConfig::CheckStoreConfig(const int topic_id, const config::StoreConfig *store_config) { |
| 227 |
nothing calls this directly
no test coverage detected