[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH V12 15/19] filter: Add handle_event method for NetFi
From: |
Zhang Chen |
Subject: |
[Qemu-devel] [PATCH V12 15/19] filter: Add handle_event method for NetFilterClass |
Date: |
Mon, 3 Sep 2018 12:38:56 +0800 |
Filter needs to process the event of checkpoint/failover or
other event passed by COLO frame.
Signed-off-by: zhanghailiang <address@hidden>
Signed-off-by: Zhang Chen <address@hidden>
Signed-off-by: Zhang Chen <address@hidden>
---
include/net/filter.h | 5 +++++
net/filter.c | 17 +++++++++++++++++
net/net.c | 19 +++++++++++++++++++
3 files changed, 41 insertions(+)
diff --git a/include/net/filter.h b/include/net/filter.h
index 435acd6f82..49da666ac0 100644
--- a/include/net/filter.h
+++ b/include/net/filter.h
@@ -38,6 +38,8 @@ typedef ssize_t (FilterReceiveIOV)(NetFilterState *nc,
typedef void (FilterStatusChanged) (NetFilterState *nf, Error **errp);
+typedef void (FilterHandleEvent) (NetFilterState *nf, int event, Error **errp);
+
typedef struct NetFilterClass {
ObjectClass parent_class;
@@ -45,6 +47,7 @@ typedef struct NetFilterClass {
FilterSetup *setup;
FilterCleanup *cleanup;
FilterStatusChanged *status_changed;
+ FilterHandleEvent *handle_event;
/* mandatory */
FilterReceiveIOV *receive_iov;
} NetFilterClass;
@@ -77,4 +80,6 @@ ssize_t qemu_netfilter_pass_to_next(NetClientState *sender,
int iovcnt,
void *opaque);
+void colo_notify_filters_event(int event, Error **errp);
+
#endif /* QEMU_NET_FILTER_H */
diff --git a/net/filter.c b/net/filter.c
index 2fd7d7d663..c9f9e5fa08 100644
--- a/net/filter.c
+++ b/net/filter.c
@@ -17,6 +17,8 @@
#include "net/vhost_net.h"
#include "qom/object_interfaces.h"
#include "qemu/iov.h"
+#include "net/colo.h"
+#include "migration/colo.h"
static inline bool qemu_can_skip_netfilter(NetFilterState *nf)
{
@@ -245,11 +247,26 @@ static void netfilter_finalize(Object *obj)
g_free(nf->netdev_id);
}
+static void default_handle_event(NetFilterState *nf, int event, Error **errp)
+{
+ switch (event) {
+ case COLO_EVENT_CHECKPOINT:
+ break;
+ case COLO_EVENT_FAILOVER:
+ object_property_set_str(OBJECT(nf), "off", "status", errp);
+ break;
+ default:
+ break;
+ }
+}
+
static void netfilter_class_init(ObjectClass *oc, void *data)
{
UserCreatableClass *ucc = USER_CREATABLE_CLASS(oc);
+ NetFilterClass *nfc = NETFILTER_CLASS(oc);
ucc->complete = netfilter_complete;
+ nfc->handle_event = default_handle_event;
}
static const TypeInfo netfilter_info = {
diff --git a/net/net.c b/net/net.c
index 2a3133990c..fd8efebfdb 100644
--- a/net/net.c
+++ b/net/net.c
@@ -1331,6 +1331,25 @@ void hmp_info_network(Monitor *mon, const QDict *qdict)
}
}
+void colo_notify_filters_event(int event, Error **errp)
+{
+ NetClientState *nc;
+ NetFilterState *nf;
+ NetFilterClass *nfc = NULL;
+ Error *local_err = NULL;
+
+ QTAILQ_FOREACH(nc, &net_clients, next) {
+ QTAILQ_FOREACH(nf, &nc->filters, next) {
+ nfc = NETFILTER_GET_CLASS(OBJECT(nf));
+ nfc->handle_event(nf, event, &local_err);
+ if (local_err) {
+ error_propagate(errp, local_err);
+ return;
+ }
+ }
+ }
+}
+
void qmp_set_link(const char *name, bool up, Error **errp)
{
NetClientState *ncs[MAX_QUEUE_NUM];
--
2.17.GIT
- Re: [Qemu-devel] [PATCH V12 05/19] COLO: Add block replication into colo process, (continued)
- [Qemu-devel] [PATCH V12 06/19] COLO: Remove colo_state migration struct, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 07/19] COLO: Load dirty pages into SVM's RAM cache firstly, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 08/19] ram/COLO: Record the dirty pages that SVM received, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 09/19] COLO: Flush memory data from ram cache, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 10/19] qmp event: Add COLO_EXIT event to notify users while exited COLO, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 11/19] qapi/migration.json: Rename COLO unknown mode to none mode., Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 12/19] qapi: Add new command to query colo status, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 13/19] savevm: split the process of different stages for loadvm/savevm, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 14/19] COLO: flush host dirty ram from cache, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 15/19] filter: Add handle_event method for NetFilterClass,
Zhang Chen <=
- [Qemu-devel] [PATCH V12 16/19] filter-rewriter: handle checkpoint and failover event, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 17/19] COLO: notify net filters about checkpoint/failover event, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 18/19] COLO: quick failover process by kick COLO thread, Zhang Chen, 2018/09/03
- [Qemu-devel] [PATCH V12 19/19] docs: Add COLO status diagram to COLO-FT.txt, Zhang Chen, 2018/09/03
- Re: [Qemu-devel] [PATCH V12 00/19] COLO: integrate colo frame with block replication and COLO proxy, Zhang Chen, 2018/09/10