| 260 | } |
| 261 | |
| 262 | void StoreMetaQueue::ClearDequeueStat() { |
| 263 | lock_guard<mutex> lock_guard(impl_->lock); |
| 264 | |
| 265 | if (-1 != impl_->last_dequeue_meta.GetCursorID()) { |
| 266 | impl_->last_dequeue_meta = StoreMeta(); |
| 267 | } |
| 268 | |
| 269 | } |
| 270 | |
| 271 | |
| 272 | } // namespace store |
no test coverage detected