Method GetPendingQueues

phxqueue/consumer/hblock.cpp:526–538

}

comm::RetCode HeartBeatLock::GetPendingQueues(const vector<Queue_t> &all_queues, const AddrScales &addr_scales, vector<Queue_t> &pending_queues) {
    comm::RetCode ret;
    set<size_t> queue_idxs;
    if (comm::RetCode::RET_OK != (ret = impl_->consumer->GetQueueByAddrScale(all_queues, addr_scales, queue_idxs))) {
        QLErr("ERR: GetQueueByAddrScale ret %d", comm::as_integer(ret));
        return ret;
    }
    for (auto &&idx : queue_idxs) {
        pending_queues.push_back(all_queues[idx]);
        QLVerb("add into pending_queues. idx %d", idx);
    }
    return comm::RetCode::RET_OK;
}

void HeartBeatLock::UpdateProcUsed() {
    int proc_used = 0;