Add flushGop for RingBuffer

Author: xia-chu

src/Util/RingBuffer.h

@@ -433,6 +433,13 @@ class RingBuffer : public std::enable_shared_from_this<RingBuffer<T>> {
         }
     }
 
+    void flushGop(std::function<void(const T &)> cb) {
+        LOCK_GUARD(_mtx_map);
+        _storage->getCache().for_each([&](const List<std::pair<bool, T>> &lst) {
+            lst.for_each([&](const std::pair<bool, T> &pr) { cb(pr.second); });
+        });
+    }
+
     void getInfoList(const onGetInfoCB &cb, const typename RingReaderDispatcher::onChangeInfoCB &on_change = nullptr) {
         if (!cb) {
             return;