Method SizeGT

phxqueue/store/storemeta.cpp:245–251

}

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

    auto &&it = impl_->metas.upper_bound(meta);
    if (it == impl_->metas.end()) return 0;
    return impl_->metas.rbegin()->GetIndex() - it->GetIndex() + 1;
}


void StoreMetaQueue::Clear() {