diff options
Diffstat (limited to 'src/rharchive.c')
-rw-r--r-- | src/rharchive.c | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/rharchive.c b/src/rharchive.c index 6ab1538..dc3c552 100644 --- a/src/rharchive.c +++ b/src/rharchive.c @@ -48,7 +48,7 @@ static gboolean bus_call(GstBus *bus, GstMessage *msg, gpointer data) switch (GST_MESSAGE_TYPE(msg)) { case GST_MESSAGE_EOS: { log_printf(NOTICE, "End of stream"); - g_main_loop_quit (loop); + g_main_loop_quit(loop); break; } case GST_MESSAGE_ERROR: { @@ -77,7 +77,7 @@ int main_loop(options_t* opt) GstElement *pipeline, *source, *encoder, *muxer, *sink; GstBus *bus; - loop = g_main_loop_new (NULL, FALSE); + loop = g_main_loop_new(NULL, FALSE); pipeline = gst_pipeline_new("rharchive"); source = gst_element_factory_make("audiotestsrc", "raw-source"); @@ -101,7 +101,9 @@ int main_loop(options_t* opt) log_printf(INFO, "Set State: Playing"); gst_element_set_state(pipeline, GST_STATE_PLAYING); - g_main_loop_run (loop); + signal_start(loop); + g_main_loop_run(loop); + signal_stop(); log_printf(INFO, "Stopping pipeline"); gst_element_set_state (pipeline, GST_STATE_NULL); @@ -199,6 +201,7 @@ int main(int argc, char* argv[]) fclose(pid_file); } + signal_init(); gst_init(NULL, NULL); const gchar *nano_str; guint major, minor, micro, nano; @@ -215,12 +218,7 @@ int main(int argc, char* argv[]) options_clear(&opt); - if(!ret) - log_printf(NOTICE, "normal shutdown"); - else if(ret < 0) - log_printf(NOTICE, "shutdown after error"); - else - log_printf(NOTICE, "shutdown after signal"); + log_printf(NOTICE, "rharchive shutdown"); gst_deinit(); log_close(); |