Changeset 111850c for select.c

Timestamp:

Mar 25, 2011, 3:55:41 AM (13 years ago)

Author:

David Benjamin <davidben@mit.edu>

Children:

25f7c57

Parents:

6eaafb0

git-author:

David Benjamin <davidben@mit.edu> (03/02/11 13:47:21)

git-committer:

David Benjamin <davidben@mit.edu> (03/25/11 03:55:41)

Message:

Add owl_select_post_task helper function

Honestly, the only thing you'd ever want to do to a message loop from
another thread is post a one-off task to it. Why Glib makes this so
difficult is beyond me.

File:

• select.c (modified) (3 diffs)

select.c

@@ -2 +2 @@
 
 static GMainLoop *loop = NULL;
+static GMainContext *context;
 static int dispatch_active = 0;
 
@@ -310 +311 @@
 void owl_select_run_loop(void)
 {
-  loop = g_main_loop_new(NULL, FALSE);
+  context = g_main_context_default();
+  loop = g_main_loop_new(context, FALSE);
   g_main_loop_run(loop);
 }
@@ -321 +323 @@
   }
 }
+
+typedef struct _owl_task { /*noproto*/
+  void (*cb)(void *);
+  void *cbdata;
+  void (*destroy_cbdata)(void *);
+} owl_task;
+
+static gboolean _run_task(gpointer data)
+{
+  owl_task *t = data;
+  if (t->cb)
+    t->cb(t->cbdata);
+  return FALSE;
+}
+
+static void _destroy_task(void *data)
+{
+  owl_task *t = data;
+  if (t->destroy_cbdata)
+    t->destroy_cbdata(t->cbdata);
+  g_free(t);
+}
+
+void owl_select_post_task(void (*cb)(void*), void *cbdata, void (*destroy_cbdata)(void*))
+{
+  GSource *source = g_idle_source_new();
+  owl_task *t = g_new0(owl_task, 1);
+  t->cb = cb;
+  t->cbdata = cbdata;
+  t->destroy_cbdata = destroy_cbdata;
+  g_source_set_priority(source, G_PRIORITY_DEFAULT);
+  g_source_set_callback(source, _run_task, t, _destroy_task);
+  g_source_attach(source, context);
+  g_source_unref(source);
+}