From eaf177e2be6ad7be3f32632dcfcea48402f67c7d Mon Sep 17 00:00:00 2001 From: Jon Bergli Heier Date: Thu, 26 Aug 2010 21:42:13 +0200 Subject: Removed communication source, not needed at this point. --- communication_source.c | 47 ----------------------------------------------- communication_source.h | 16 ---------------- main.c | 3 --- 3 files changed, 66 deletions(-) delete mode 100644 communication_source.c delete mode 100644 communication_source.h diff --git a/communication_source.c b/communication_source.c deleted file mode 100644 index 509366f..0000000 --- a/communication_source.c +++ /dev/null @@ -1,47 +0,0 @@ -#include "communication_source.h" -#include "servers.h" -#include "server_communication.h" - -static GQueue *jobqueue = NULL; - -void communication_job_add(struct server *server) { - g_queue_push_head(jobqueue, server); -} - -gboolean comsrc_prepare(GSource *source, gint *timeout) { - g_debug("comsrc_prepare()"); - *timeout = 2000; - return g_queue_get_length(jobqueue) > 0 ? TRUE : FALSE; -} - -gboolean comsrc_check(GSource *source) { - g_debug("comsrc_check()"); - return g_queue_get_length(jobqueue) > 0 ? TRUE : FALSE; -} - -gboolean comsrc_dispatch(GSource *source, GSourceFuncs callback, gpointer user_data) { - g_debug("comsrc_dispatch(), callback is %x, user_data is %x", callback, user_data); - struct server *server = g_queue_pop_tail(jobqueue); - server_ping(server); - return TRUE; -} - -void comsrc_finalize(GSource *source) { -} - -static const GSourceFuncs com_src_funcs = { - .prepare = comsrc_prepare, - .check = comsrc_check, - .dispatch = comsrc_dispatch, - .finalize = comsrc_finalize, -}; - -void communication_source_init(GMainLoop *mainloop) { - jobqueue = g_queue_new(); - - GMainContext *context = g_main_loop_get_context(mainloop); - GSource *source = g_source_new(&com_src_funcs, sizeof(GSource)); - g_source_attach(source, context); - - communication_job_add(servers->data); -} diff --git a/communication_source.h b/communication_source.h deleted file mode 100644 index 0856cf4..0000000 --- a/communication_source.h +++ /dev/null @@ -1,16 +0,0 @@ -#ifndef COMMUNICATION_SOURCE_H -#define COMMUNICATION_SOURCE_H - -#include "servers.h" - -#include - -struct communication_job { - struct server *server; -}; - -void communication_job_add(struct server *server); - -void communication_source_init(GMainLoop *mainloop); - -#endif diff --git a/main.c b/main.c index 4d0f46b..07eb66e 100644 --- a/main.c +++ b/main.c @@ -4,7 +4,6 @@ #include "conf.h" #include "servers.h" #include "control_service.h" -#include "communication_source.h" #include #include @@ -37,8 +36,6 @@ int main(int argc, char **argv) { main_loop = g_main_loop_new(NULL, FALSE); - communication_source_init(main_loop); - g_main_loop_run(main_loop); g_main_loop_unref(main_loop); -- cgit v1.2.3