| 94 | } |
| 95 | |
| 96 | static void ClearConsumeStat(ConsumeStat_t &consume_stat, const int nhandle_id) { |
| 97 | consume_stat.nget = 0; |
| 98 | consume_stat.nhandle_tot = 0; |
| 99 | for (int i{0}; i < nhandle_id; ++i) consume_stat.handle_id_rank2nhandle[i] = 0; |
| 100 | } |
| 101 | |
| 102 | void FreqMan::UpdateConsumeStat(const int vpid, const comm::proto::ConsumerContext &cc, |
| 103 | const vector<shared_ptr<comm::proto::QItem>> &items) { |
no outgoing calls
no test coverage detected