[Qemu-devel] [PATCH COLO-Frame v11 37/39] filter-buffer: Introduce a helper function to release packets

[zhanghailiang <zhang.zhanghailiang@huawei.com>]

We need to release all the packets from VM in COLO or Micro-checkpoint,
here we add a new helper function to realse the packets that buffered
by default buffer-filter

Signed-off-by: zhanghailiang <zhang.zhanghailiang@huawei.com>
Cc: Jason Wang <jasowang@redhat.com>
Cc: Yang Hongyang <hongyang.yang@easystack.cn>
---
v11:
- New patch
---
 include/net/filter.h |  1 +
 net/filter-buffer.c  | 19 +++++++++++++++++++
 2 files changed, 20 insertions(+)

diff --git a/include/net/filter.h b/include/net/filter.h
index b57b29a..e1e8d9b 100644
--- a/include/net/filter.h
+++ b/include/net/filter.h
@@ -77,5 +77,6 @@ ssize_t qemu_netfilter_pass_to_next(NetClientState *sender,
 void netdev_add_default_filter_buffer(const char *netdev_id,
                                       NetFilterDirection direction,
                                       Error **errp);
+void qemu_release_default_filters_packets(void);
 void qemu_set_default_filter_buffers(bool enable_buffer);
 #endif /* QEMU_NET_FILTER_H */
diff --git a/net/filter-buffer.c b/net/filter-buffer.c
index 7115a2b..06f2190 100644
--- a/net/filter-buffer.c
+++ b/net/filter-buffer.c
@@ -167,6 +167,25 @@ out:
     error_propagate(errp, local_err);
 }
 
+static void default_filter_release_packets(NetFilterState *nf,
+                                           void *opaque,
+                                           Error **errp)
+{
+    if (!strcmp(object_get_typename(OBJECT(nf)), TYPE_FILTER_BUFFER)) {
+        FilterBufferState *s = FILTER_BUFFER(nf);
+
+        if (s->is_default) {
+            filter_buffer_flush(nf);
+        }
+    }
+}
+
+/* public APIs */
+void qemu_release_default_filters_packets(void)
+{
+    qemu_foreach_netfilter(default_filter_release_packets, NULL, NULL);
+}
+
 static void default_filter_set_buffer_flag(NetFilterState *nf,
                                            void *opaque,
                                            Error **errp)
-- 
1.8.3.1