Method ClearInvalidSubIDs

phxqueue/consumer/hblock.cpp:181–193

}

void HeartBeatLock::ClearInvalidSubIDs(const set<int> &valid_sub_ids) {
    comm::utils::RWLock l(impl_->rwlock, comm::utils::RWLock::LockMode::WRITE);

    for (int vpid{0}; vpid < impl_->nproc; ++vpid) {
        Queue_t *queue{&impl_->buf->queues[vpid]};
        if (LOCK_ITEM_MAGIC == queue->magic) {
            if (valid_sub_ids.end() == valid_sub_ids.find(queue->sub_id)) {
                QLInfo("QUEUEINFO: vpid %d clear sub %u store %u queue %u", vpid, queue->sub_id, queue->store_id, queue->queue_id);
                memset(queue, 0, sizeof(Queue_t));
            }
        }
    }
}

void HeartBeatLock::DistubePendingQueues(const map<int, vector<Queue_t>> &sub_id2pending_queues) {
    //if (impl_->ossid) OssAttrInc(impl_->ossid, 20, 1);