[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH V4 13/16] filter: Add handle_event method for NetFil
From: |
Zhang Chen |
Subject: |
[Qemu-devel] [PATCH V4 13/16] filter: Add handle_event method for NetFilterClass |
Date: |
Fri, 19 Jan 2018 21:44:42 +0800 |
Filter needs to process the event of checkpoint/failover or
other event passed by COLO frame.
Signed-off-by: zhanghailiang <address@hidden>
---
include/net/filter.h | 5 +++++
net/filter.c | 17 +++++++++++++++++
net/net.c | 28 ++++++++++++++++++++++++++++
3 files changed, 50 insertions(+)
diff --git a/include/net/filter.h b/include/net/filter.h
index 0c4a2ea..df4510d 100644
--- a/include/net/filter.h
+++ b/include/net/filter.h
@@ -37,6 +37,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;
@@ -44,6 +46,7 @@ typedef struct NetFilterClass {
FilterSetup *setup;
FilterCleanup *cleanup;
FilterStatusChanged *status_changed;
+ FilterHandleEvent *handle_event;
/* mandatory */
FilterReceiveIOV *receive_iov;
} NetFilterClass;
@@ -76,4 +79,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 2fd7d7d..0f17eba 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 dummy_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 = dummy_handle_event;
}
static const TypeInfo netfilter_info = {
diff --git a/net/net.c b/net/net.c
index 2b81c93..56a54e7 100644
--- a/net/net.c
+++ b/net/net.c
@@ -1399,6 +1399,34 @@ void hmp_info_network(Monitor *mon, const QDict *qdict)
}
}
+void colo_notify_filters_event(int event, Error **errp)
+{
+ NetClientState *nc, *peer;
+ NetClientDriver type;
+ NetFilterState *nf;
+ NetFilterClass *nfc = NULL;
+ Error *local_err = NULL;
+
+ QTAILQ_FOREACH(nc, &net_clients, next) {
+ peer = nc->peer;
+ type = nc->info->type;
+ if (!peer || type != NET_CLIENT_DRIVER_TAP) {
+ continue;
+ }
+ QTAILQ_FOREACH(nf, &nc->filters, next) {
+ nfc = NETFILTER_GET_CLASS(OBJECT(nf));
+ if (!nfc->handle_event) {
+ continue;
+ }
+ 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.7.4
- [Qemu-devel] [PATCH V4 03/16] colo-compare: use notifier to notify packets comparing result, (continued)
- [Qemu-devel] [PATCH V4 03/16] colo-compare: use notifier to notify packets comparing result, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 04/16] COLO: integrate colo compare with colo frame, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 05/16] COLO: Add block replication into colo process, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 06/16] COLO: Remove colo_state migration struct, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 07/16] COLO: Load dirty pages into SVM's RAM cache firstly, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 08/16] ram/COLO: Record the dirty pages that SVM received, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 09/16] COLO: Flush memory data from ram cache, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 10/16] qmp event: Add COLO_EXIT event to notify users while exited COLO, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 11/16] savevm: split the process of different stages for loadvm/savevm, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 12/16] COLO: flush host dirty ram from cache, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 13/16] filter: Add handle_event method for NetFilterClass,
Zhang Chen <=
- [Qemu-devel] [PATCH V4 14/16] filter-rewriter: handle checkpoint and failover event, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 15/16] COLO: notify net filters about checkpoint/failover event, Zhang Chen, 2018/01/19
- [Qemu-devel] [PATCH V4 16/16] COLO: quick failover process by kick COLO thread, Zhang Chen, 2018/01/19
- Re: [Qemu-devel] [PATCH V4 00/16] COLO: integrate colo frame with block replication and COLO proxy, Zhang Chen, 2018/01/30