Method UpdateDeuqueStat

phxqueue/store/storemeta.cpp:227–237

}

void StoreMetaQueue::UpdateDeuqueStat(const StoreMeta &meta) {
    lock_guard<mutex> lock_guard(impl_->lock);

    if (-1 == meta.GetCursorID()) return;

    auto &&it = impl_->metas.lower_bound(meta);
    if (it == impl_->metas.end()) return;
    if (-1 == impl_->last_dequeue_meta.GetCursorID() || impl_->last_dequeue_meta < *it) {
        impl_->last_dequeue_meta = *it;
    }
}

int StoreMetaQueue::Size() {
    lock_guard<mutex> lock_guard(impl_->lock);