diff options
| -rw-r--r-- | src/pjctl.c | 17 |
1 files changed, 12 insertions, 5 deletions
diff --git a/src/pjctl.c b/src/pjctl.c index 0069c9d..58e120e 100644 --- a/src/pjctl.c +++ b/src/pjctl.c @@ -46,7 +46,6 @@ struct pjctl { GSocketConnection *con; GPollableInputStream *in; GOutputStream *out; - GSource *insrc; }; struct queue_command { @@ -605,6 +604,8 @@ main(int argc, char **argv) int port = 4352; GError *error = NULL; int i; + GSource *src; + guint src_id; memset(&pjctl, 0, sizeof pjctl); @@ -653,14 +654,20 @@ main(int argc, char **argv) return 1; } - pjctl.insrc = g_pollable_input_stream_create_source(pjctl.in, NULL); - g_source_set_callback(pjctl.insrc, (GSourceFunc) read_cb, &pjctl, NULL); - g_source_attach(pjctl.insrc, NULL); - g_source_unref(pjctl.insrc); + src = g_pollable_input_stream_create_source(pjctl.in, NULL); + g_source_set_callback(src, (GSourceFunc) read_cb, &pjctl, NULL); + src_id = g_source_attach(src, NULL); + g_source_unref(src); pjctl.state = PJCTL_AWAIT_INITIAL; g_main_loop_run(pjctl.loop); + + g_source_remove(src_id); + g_object_unref(pjctl.in); + g_object_unref(pjctl.out); + g_object_unref(pjctl.con); + g_object_unref(pjctl.sc); g_main_loop_unref(pjctl.loop); return 0; |