[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [RFC PATCH v5 06/14] net: port tap-win32 onto GSource
From: |
Liu Ping Fan |
Subject: |
[Qemu-devel] [RFC PATCH v5 06/14] net: port tap-win32 onto GSource |
Date: |
Fri, 26 Apr 2013 10:47:27 +0800 |
From: Liu Ping Fan <address@hidden>
Signed-off-by: Liu Ping Fan <address@hidden>
---
net/tap-win32.c | 31 +++++++++++++++++++++++++++++--
1 files changed, 29 insertions(+), 2 deletions(-)
diff --git a/net/tap-win32.c b/net/tap-win32.c
index 91e9e84..7a84195 100644
--- a/net/tap-win32.c
+++ b/net/tap-win32.c
@@ -635,13 +635,14 @@ static int tap_win32_open(tap_win32_overlapped_t
**phandle,
typedef struct TAPState {
NetClientState nc;
tap_win32_overlapped_t *handle;
+ EventGSource *nsrc;
} TAPState;
static void tap_cleanup(NetClientState *nc)
{
TAPState *s = DO_UPCAST(TAPState, nc, nc);
- qemu_del_wait_object(s->handle->tap_semaphore, NULL, NULL);
+ event_source_release(s->nsrc);
/* FIXME: need to kill thread and close file handle:
tap_win32_close(s);
@@ -669,13 +670,37 @@ static void tap_win32_send(void *opaque)
}
}
+static void tap_bind_ctx(NetClientState *nc, GMainContext *ctx)
+{
+ TAPState *s = DO_UPCAST(TAPState, nc, nc);
+
+ g_source_attach(&s->nsrc->source, ctx);
+}
+
static NetClientInfo net_tap_win32_info = {
.type = NET_CLIENT_OPTIONS_KIND_TAP,
.size = sizeof(TAPState),
.receive = tap_receive,
.cleanup = tap_cleanup,
+ .bind_ctx = tap_bind_ctx,
};
+static gboolean tap_win32_handler(gpointer data)
+{
+ EventGSource *nsrc = data;
+ TAPState *s = nsrc->opaque;
+
+ if (nsrc->gfd.revents & G_IO_IN) {
+ tap_win32_send(s);
+ }
+ return true;
+}
+
+static gushort readable(void *opaque)
+{
+ return G_IO_IN;
+}
+
static int tap_win32_init(NetClientState *peer, const char *model,
const char *name, const char *ifname)
{
@@ -697,7 +722,9 @@ static int tap_win32_init(NetClientState *peer, const char
*model,
s->handle = handle;
- qemu_add_wait_object(s->handle->tap_semaphore, tap_win32_send, s);
+ s->nsrc = event_source_new(s->handle->tap_semaphore, tap_win32_handler, s);
+ s->nsrc->readable = readable;
+ nc->info->bind_ctx(&s->nc, NULL);
return 0;
}
--
1.7.4.4
- Re: [Qemu-devel] [RFC PATCH v5 01/14] util: introduce gsource event abstraction, (continued)
[Qemu-devel] [RFC PATCH v5 02/14] net: introduce bind_ctx to NetClientInfo, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 03/14] net: port tap onto GSource, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 04/14] net: port vde onto GSource, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 05/14] net: port socket to GSource, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 06/14] net: port tap-win32 onto GSource,
Liu Ping Fan <=
[Qemu-devel] [RFC PATCH v5 07/14] net: hub use lock to protect ports list, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 08/14] net: introduce lock to protect NetQueue, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 09/14] net: introduce lock to protect NetClientState's peer's access, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 10/14] net: make netclient re-entrant with refcnt, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 11/14] slirp: make timeout local, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 12/14] slirp: make slirp event dispatch based on slirp instance, not global, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 13/14] slirp: handle race condition, Liu Ping Fan, 2013/04/25
[Qemu-devel] [RFC PATCH v5 14/14] slirp: use lock to protect the slirp_instances, Liu Ping Fan, 2013/04/25