[PATCH v3 3/5] tests: create and use a template file for events

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



This template will be reused for main loop

Signed-off-by: Frediano Ziglio <fziglio@xxxxxxxxxx>
---
 server/event-loop.c             | 183 ++++++++++++++++++++++++++++++++++++++++
 server/event-loop.h             |  34 ++++++++
 server/tests/Makefile.am        |   1 +
 server/tests/basic_event_loop.c | 157 ++--------------------------------
 4 files changed, 223 insertions(+), 152 deletions(-)
 create mode 100644 server/event-loop.c
 create mode 100644 server/event-loop.h

diff --git a/server/event-loop.c b/server/event-loop.c
new file mode 100644
index 0000000..e0a70d3
--- /dev/null
+++ b/server/event-loop.c
@@ -0,0 +1,183 @@
+/* -*- Mode: C; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+/*
+   Copyright (C) 2009-2015 Red Hat, Inc.
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2.1 of the License, or (at your option) any later version.
+
+   This library is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with this library; if not, see <http://www.gnu.org/licenses/>.
+*/
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include "spice/macros.h"
+#include "common/mem.h"
+#include "event-loop.h"
+
+#ifndef CORE_CHANNEL_EVENT
+#define CORE_CHANNEL_EVENT NULL
+#endif
+
+struct SpiceTimer {
+    SpiceTimerFunc func;
+    void *opaque;
+    GSource *source;
+};
+
+static SpiceTimer* timer_add(SpiceTimerFunc func, void *opaque)
+{
+    SpiceTimer *timer = spice_malloc0(sizeof(SpiceTimer));
+
+    timer->func = func;
+    timer->opaque = opaque;
+
+    return timer;
+}
+
+static gboolean timer_func(gpointer user_data)
+{
+    SpiceTimer *timer = user_data;
+
+    timer->func(timer->opaque);
+    /* timer might be free after func(), don't touch */
+
+    return FALSE;
+}
+
+static void timer_cancel(SpiceTimer *timer)
+{
+    if (timer->source) {
+        g_source_destroy(timer->source);
+        g_source_unref(timer->source);
+        timer->source = NULL;
+    }
+}
+
+static void timer_start(SpiceTimer *timer, uint32_t ms)
+{
+    timer_cancel(timer);
+
+    timer->source = g_timeout_source_new(ms);
+    spice_assert(timer->source != NULL);
+
+    g_source_set_callback(timer->source, timer_func, timer, NULL);
+
+    g_source_attach(timer->source, event_loop_context_from_opaque(timer->opaque));
+}
+
+static void timer_remove(SpiceTimer *timer)
+{
+    timer_cancel(timer);
+    spice_assert(timer->source == NULL);
+    free(timer);
+}
+
+struct SpiceWatch {
+    void *opaque;
+    GSource *source;
+    GIOChannel *channel;
+    SpiceWatchFunc func;
+};
+
+static GIOCondition spice_event_to_giocondition(int event_mask)
+{
+    GIOCondition condition = 0;
+
+    if (event_mask & SPICE_WATCH_EVENT_READ)
+        condition |= G_IO_IN;
+    if (event_mask & SPICE_WATCH_EVENT_WRITE)
+        condition |= G_IO_OUT;
+
+    return condition;
+}
+
+static int giocondition_to_spice_event(GIOCondition condition)
+{
+    int event = 0;
+
+    if (condition & G_IO_IN)
+        event |= SPICE_WATCH_EVENT_READ;
+    if (condition & G_IO_OUT)
+        event |= SPICE_WATCH_EVENT_WRITE;
+
+    return event;
+}
+
+static gboolean watch_func(GIOChannel *source, GIOCondition condition,
+                           gpointer data)
+{
+    SpiceWatch *watch = data;
+    int fd = g_io_channel_unix_get_fd(source);
+
+    watch->func(fd, giocondition_to_spice_event(condition), watch->opaque);
+
+    return TRUE;
+}
+
+static void watch_update_mask(SpiceWatch *watch, int event_mask)
+{
+    if (watch->source) {
+        g_source_destroy(watch->source);
+        g_source_unref(watch->source);
+        watch->source = NULL;
+    }
+
+    if (!event_mask)
+        return;
+
+    watch->source = g_io_create_watch(watch->channel, spice_event_to_giocondition(event_mask));
+    g_source_set_callback(watch->source, (GSourceFunc)watch_func, watch, NULL);
+    g_source_attach(watch->source, event_loop_context_from_opaque(watch->opaque));
+}
+
+static SpiceWatch *watch_add(int fd, int event_mask, SpiceWatchFunc func, void *opaque)
+{
+    SpiceWatch *watch;
+
+    spice_return_val_if_fail(fd != -1, NULL);
+    spice_return_val_if_fail(func != NULL, NULL);
+
+    watch = spice_malloc0(sizeof(SpiceWatch));
+    watch->channel = g_io_channel_unix_new(fd);
+    watch->func = func;
+    watch->opaque = opaque;
+
+    watch_update_mask(watch, event_mask);
+
+    return watch;
+}
+
+static void watch_remove(SpiceWatch *watch)
+{
+    watch_update_mask(watch, 0);
+    spice_assert(watch->source == NULL);
+
+    g_io_channel_unref(watch->channel);
+    free(watch);
+}
+
+SpiceCoreInterface event_loop_core = {
+    .base = {
+        .major_version = SPICE_INTERFACE_CORE_MAJOR,
+        .minor_version = SPICE_INTERFACE_CORE_MINOR,
+    },
+    .timer_add = timer_add,
+    .timer_start = timer_start,
+    .timer_cancel = timer_cancel,
+    .timer_remove = timer_remove,
+
+    .watch_add = watch_add,
+    .watch_update_mask = watch_update_mask,
+    .watch_remove = watch_remove,
+
+    .channel_event = event_loop_channel_event
+};
diff --git a/server/event-loop.h b/server/event-loop.h
new file mode 100644
index 0000000..aabfe33
--- /dev/null
+++ b/server/event-loop.h
@@ -0,0 +1,34 @@
+/* -*- Mode: C; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+/*
+   Copyright (C) 2009-2015 Red Hat, Inc.
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2.1 of the License, or (at your option) any later version.
+
+   This library is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with this library; if not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef EVENT_LOOP_H_
+#define EVENT_LOOP_H_
+
+#include "red-common.h"
+
+#include <glib.h>
+
+extern SpiceCoreInterface event_loop_core;
+
+/* Missing functions to be defined externally */
+
+GMainContext *event_loop_context_from_opaque(void *opaque);
+
+void event_loop_channel_event(int event, SpiceChannelEventInfo *info);
+
+#endif /* EVENT_LOOP_H_ */
diff --git a/server/tests/Makefile.am b/server/tests/Makefile.am
index d0bd5a0..05fb262 100644
--- a/server/tests/Makefile.am
+++ b/server/tests/Makefile.am
@@ -29,6 +29,7 @@ LDADD =								\
 COMMON_BASE =					\
 	basic_event_loop.c			\
 	basic_event_loop.h			\
+	../event-loop.c			\
 	test_util.h				\
 	$(NULL)
 
diff --git a/server/tests/basic_event_loop.c b/server/tests/basic_event_loop.c
index 067657e..e7c5b9a 100644
--- a/server/tests/basic_event_loop.c
+++ b/server/tests/basic_event_loop.c
@@ -26,6 +26,7 @@
 #include "common/ring.h"
 #include "common/mem.h"
 #include "test_util.h"
+#include "../event-loop.h"
 #include "basic_event_loop.h"
 
 int debug = 0;
@@ -43,145 +44,12 @@ GMainContext *basic_event_loop_get_context(void)
     return main_context;
 }
 
-struct SpiceTimer {
-    SpiceTimerFunc func;
-    void *opaque;
-    GSource *source;
-};
-
-static SpiceTimer* timer_add(SpiceTimerFunc func, void *opaque)
-{
-    SpiceTimer *timer = spice_malloc0(sizeof(SpiceTimer));
-
-    timer->func = func;
-    timer->opaque = opaque;
-
-    return timer;
-}
-
-static gboolean timer_func(gpointer user_data)
-{
-    SpiceTimer *timer = user_data;
-
-    timer->func(timer->opaque);
-    /* timer might be free after func(), don't touch */
-
-    return FALSE;
-}
-
-static void timer_cancel(SpiceTimer *timer)
-{
-    if (timer->source) {
-        g_source_destroy(timer->source);
-        g_source_unref(timer->source);
-        timer->source = NULL;
-    }
-}
-
-static void timer_start(SpiceTimer *timer, uint32_t ms)
-{
-    timer_cancel(timer);
-
-    timer->source = g_timeout_source_new(ms);
-    spice_assert(timer->source != NULL);
-
-    g_source_set_callback(timer->source, timer_func, timer, NULL);
-
-    g_source_attach(timer->source, main_context);
-}
-
-static void timer_remove(SpiceTimer *timer)
-{
-    timer_cancel(timer);
-    spice_assert(timer->source == NULL);
-    free(timer);
-}
-
-struct SpiceWatch {
-    void *opaque;
-    GSource *source;
-    GIOChannel *channel;
-    SpiceWatchFunc func;
-};
-
-static GIOCondition spice_event_to_giocondition(int event_mask)
-{
-    GIOCondition condition = 0;
-
-    if (event_mask & SPICE_WATCH_EVENT_READ)
-        condition |= G_IO_IN;
-    if (event_mask & SPICE_WATCH_EVENT_WRITE)
-        condition |= G_IO_OUT;
-
-    return condition;
-}
-
-static int giocondition_to_spice_event(GIOCondition condition)
-{
-    int event = 0;
-
-    if (condition & G_IO_IN)
-        event |= SPICE_WATCH_EVENT_READ;
-    if (condition & G_IO_OUT)
-        event |= SPICE_WATCH_EVENT_WRITE;
-
-    return event;
-}
-
-static gboolean watch_func(GIOChannel *source, GIOCondition condition,
-                           gpointer data)
+GMainContext *event_loop_context_from_opaque(void *opaque)
 {
-    SpiceWatch *watch = data;
-    int fd = g_io_channel_unix_get_fd(source);
-
-    watch->func(fd, giocondition_to_spice_event(condition), watch->opaque);
-
-    return TRUE;
-}
-
-static void watch_update_mask(SpiceWatch *watch, int event_mask)
-{
-    if (watch->source) {
-        g_source_destroy(watch->source);
-        g_source_unref(watch->source);
-        watch->source = NULL;
-    }
-
-    if (!event_mask)
-        return;
-
-    watch->source = g_io_create_watch(watch->channel, spice_event_to_giocondition(event_mask));
-    g_source_set_callback(watch->source, (GSourceFunc)watch_func, watch, NULL);
-    g_source_attach(watch->source, main_context);
-}
-
-static SpiceWatch *watch_add(int fd, int event_mask, SpiceWatchFunc func, void *opaque)
-{
-    SpiceWatch *watch;
-
-    spice_return_val_if_fail(fd != -1, NULL);
-    spice_return_val_if_fail(func != NULL, NULL);
-
-    watch = spice_malloc0(sizeof(SpiceWatch));
-    watch->channel = g_io_channel_unix_new(fd);
-    watch->func = func;
-    watch->opaque = opaque;
-
-    watch_update_mask(watch, event_mask);
-
-    return watch;
-}
-
-static void watch_remove(SpiceWatch *watch)
-{
-    watch_update_mask(watch, 0);
-    spice_assert(watch->source == NULL);
-
-    g_io_channel_unref(watch->channel);
-    free(watch);
+    return main_context;
 }
 
-static void channel_event(int event, SpiceChannelEventInfo *info)
+void event_loop_channel_event(int event, SpiceChannelEventInfo *info)
 {
     DPRINTF(0, "channel event con, type, id, event: %d, %d, %d, %d",
             info->connection_id, info->type, info->id, event);
@@ -205,25 +73,10 @@ static void ignore_sigpipe(void)
     sigaction(SIGPIPE, &act, NULL);
 }
 
-static SpiceCoreInterface core = {
-    .base = {
-        .major_version = SPICE_INTERFACE_CORE_MAJOR,
-        .minor_version = SPICE_INTERFACE_CORE_MINOR,
-    },
-    .timer_add = timer_add,
-    .timer_start = timer_start,
-    .timer_cancel = timer_cancel,
-    .timer_remove = timer_remove,
-    .watch_add = watch_add,
-    .watch_update_mask = watch_update_mask,
-    .watch_remove = watch_remove,
-    .channel_event = channel_event,
-};
-
 SpiceCoreInterface *basic_event_loop_init(void)
 {
     ignore_sigpipe();
     spice_assert(main_context == NULL);
     main_context = g_main_context_new();
-    return &core;
+    return &event_loop_core;
 }
-- 
2.4.3

_______________________________________________
Spice-devel mailing list
Spice-devel@xxxxxxxxxxxxxxxxxxxxx
http://lists.freedesktop.org/mailman/listinfo/spice-devel




[Index of Archives]     [Linux ARM Kernel]     [Linux ARM]     [Linux Omap]     [Fedora ARM]     [IETF Annouce]     [Security]     [Bugtraq]     [Linux]     [Linux OMAP]     [Linux MIPS]     [ECOS]     [Asterisk Internet PBX]     [Linux API]     [Monitors]