From d048447e6bee06400acd3854f999e4c264172ac0 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Thu, 2 Oct 2014 23:25:28 +0200 Subject: renamed the sydra utility to sydra-rtp --- src/Makefile | 4 +- src/configure | 4 +- src/datatypes.h | 2 +- src/log_targets.h | 4 +- src/options.c | 4 +- src/options.h | 2 +- src/pipelines.c | 4 +- src/sydra-rtp.c | 327 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ src/sydra.c | 327 ------------------------------------------------------ 9 files changed, 339 insertions(+), 339 deletions(-) create mode 100644 src/sydra-rtp.c delete mode 100644 src/sydra.c (limited to 'src') diff --git a/src/Makefile b/src/Makefile index 3fcf405..ac211d8 100644 --- a/src/Makefile +++ b/src/Makefile @@ -37,14 +37,14 @@ ifneq ($(MAKECMDGOALS),distclean) include include.mk endif -EXECUTABLE := sydra +EXECUTABLE := sydra-rtp C_OBJS := log.o \ options.o \ utils.o \ pipelines.o \ udp.o \ - sydra.o + sydra-rtp.o C_SRCS := $(C_OBJS:%.o=%.c) diff --git a/src/configure b/src/configure index acb7a20..515399f 100755 --- a/src/configure +++ b/src/configure @@ -150,7 +150,7 @@ DATE=`date +"%d.%m.%Y %H:%M:%S %Z"` cat > config.h < config.h < -typedef enum { SENDER, RECEIVER } sydra_mode_t; +typedef enum { SENDER, RECEIVER } sydra_rtp_mode_t; struct addr_port { enum { IPv4, IPv6 } type_; diff --git a/src/log_targets.h b/src/log_targets.h index c27cc1a..71e56b9 100644 --- a/src/log_targets.h +++ b/src/log_targets.h @@ -87,7 +87,7 @@ int log_target_syslog_init(log_target_t* self, const char* conf) char* logname; const char* end = NULL; if(!conf) - logname = strdup("sydra"); + logname = strdup("sydra-rtp"); else { end = strchr(conf, ','); if(end) { @@ -216,7 +216,7 @@ int log_target_file_init(log_target_t* self, const char* conf) char* logfilename; if(!conf) - logfilename = strdup("sydra.log"); + logfilename = strdup("sydra-rtp.log"); else { const char* end = strchr(conf, ','); if(end) { diff --git a/src/options.c b/src/options.c index 89c55fc..483d6d7 100644 --- a/src/options.c +++ b/src/options.c @@ -49,7 +49,7 @@ static void options_defaults(options_t* opt) if(!opt) return; - opt->progname_ = g_strdup("sydra"); + opt->progname_ = g_strdup("sydra-rtp"); opt->daemonize_ = TRUE; opt->username_ = NULL; opt->groupname_ = NULL; @@ -335,7 +335,7 @@ static int options_parse_post(options_t* opt) if(!g_strv_length(opt->log_targets_)) { opt->log_targets_ = g_new(gchar*, 2); if(!opt->log_targets_) return -127; - opt->log_targets_[0] = g_strdup("syslog:3,sydra,daemon"); + opt->log_targets_[0] = g_strdup("syslog:3,sydra-rtp,daemon"); if(!(opt->log_targets_[0])) return -127; opt->log_targets_[1] = NULL; } diff --git a/src/options.h b/src/options.h index 9ebcb01..afc5ae6 100644 --- a/src/options.h +++ b/src/options.h @@ -49,7 +49,7 @@ struct options_struct { gboolean debug_; gchar* appname_; - sydra_mode_t mode_; + sydra_rtp_mode_t mode_; gchar* source_; gchar* sink_; diff --git a/src/pipelines.c b/src/pipelines.c index 114a2c5..fa33562 100644 --- a/src/pipelines.c +++ b/src/pipelines.c @@ -353,7 +353,7 @@ static gboolean create_recorder_elements(options_t* opt, GstElement* pipeline, s GstElement* create_sender_pipeline(options_t* opt, struct udp_sinks *udp) { - GstElement *pipeline = gst_pipeline_new ("sydra-sender"); + GstElement *pipeline = gst_pipeline_new ("sydra-rtp-sender"); if(!pipeline) { log_printf(ERROR, "Creating pipeline failed!"); return NULL; @@ -434,7 +434,7 @@ static void rtpbin_pad_added(GstElement* rtp, GstPad* pad, gpointer user_data) GstElement* create_receiver_pipeline(options_t* opt, struct udp_sources *udp) { - GstElement *pipeline = gst_pipeline_new ("sydra-receiver"); + GstElement *pipeline = gst_pipeline_new ("sydra-rtp-receiver"); if(!pipeline) { log_printf(ERROR, "Creating pipeline failed!"); return NULL; diff --git a/src/sydra-rtp.c b/src/sydra-rtp.c new file mode 100644 index 0000000..c8c15da --- /dev/null +++ b/src/sydra-rtp.c @@ -0,0 +1,327 @@ +/* + * sydra + * + * sydra is a toolbox which allows you to set up multiple bidirectional + * Video/Audio streams from external locations. + * sydra has been written to be used for the Elevate Festival in Graz + * Austria in order to involve external locations to present themselves + * at the festival. + * Sydra is based on GStreamer and is written in C. + * + * + * Copyright (C) 2014 Christian Pointner + * + * This file is part of sydra. + * + * sydra is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * any later version. + * + * sydra 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 General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with sydra. If not, see . + * + * In addition, as a special exception, the copyright holders hereby + * grant permission for non-GPL-compatible GStreamer plugins to be used + * and distributed together with GStreamer and sydra. + * This permission goes above and beyond the permissions granted by the + * GPL license sydra is covered by. + */ + +#define _GNU_SOURCE +#include +#include +#include +#include +#include +#include + +#include +#include +#include + +#include "datatypes.h" +#include "options.h" +#include "log.h" +#include "daemon.h" +#include "utils.h" +#include "pipelines.h" +#include "udp.h" + + +static gboolean sig_handler_terminate(gpointer user_data) +{ + GMainLoop *loop = (GMainLoop *)user_data; + + log_printf(NOTICE, "signal received, closing application"); + g_main_loop_quit(loop); + return TRUE; +} + +static gboolean bus_call(GstBus *bus, GstMessage *msg, gpointer data) +{ + GMainLoop *loop = (GMainLoop *)data; + + switch (GST_MESSAGE_TYPE(msg)) { + case GST_MESSAGE_EOS: { + log_printf(NOTICE, "End of stream"); + g_main_loop_quit(loop); + break; + } + case GST_MESSAGE_INFO: { + GError *info; + gst_message_parse_info(msg, &info, NULL); + log_printf(INFO, "%s", info->message); + g_error_free(info); + break; + } + case GST_MESSAGE_WARNING: { + GError *warning; + gst_message_parse_warning(msg, &warning, NULL); + log_printf(WARNING, "%s", warning->message); + g_error_free(warning); + break; + } + case GST_MESSAGE_ERROR: { + GError *error; + gst_message_parse_error(msg, &error, NULL); + log_printf(ERROR, "%s", error->message); + g_error_free(error); + g_main_loop_quit(loop); + break; + } + case GST_MESSAGE_STATE_CHANGED: { + GstState old_state, new_state; + gst_message_parse_state_changed(msg, &old_state, &new_state, NULL); + log_printf(DEBUG, "Element '%s' changed state from %s to %s", + (msg->src ? GST_OBJECT_NAME(msg->src) : "NULL"), + gst_element_state_get_name(old_state), + gst_element_state_get_name(new_state)); + break; + } + case GST_MESSAGE_NEW_CLOCK: + { + GstClock *clock; + gst_message_parse_new_clock(msg, &clock); + log_printf(NOTICE, "New clock: %s", (clock ? GST_OBJECT_NAME (clock) : "NULL")); + break; + } + case GST_MESSAGE_QOS: { + guint64 running_time, stream_time, timestamp, duration; + gst_message_parse_qos(msg, NULL, &running_time, &stream_time, ×tamp, &duration); + log_printf(WARNING, "Element '%s' dropped frames running_time=%lu, stream_time=%lu, timestamp=%lu, duration=%lu", + (msg->src ? GST_OBJECT_NAME(msg->src) : "NULL"), running_time, stream_time, timestamp, duration); + break; + } + /* case GST_MESSAGE_STREAM_STATUS: */ + /* { */ + /* GstStreamStatusType type; */ + /* GstElement *owner; */ + /* const GValue *val; */ + /* gchar *path, *ownerstr; */ + /* GstTask *task = NULL; */ + + /* gst_message_parse_stream_status (msg, &type, &owner); */ + /* val = gst_message_get_stream_status_object (msg); */ + + /* path = gst_object_get_path_string (GST_MESSAGE_SRC (msg)); */ + /* ownerstr = gst_object_get_path_string (GST_OBJECT (owner)); */ + /* log_printf(DEBUG,"Recevied Stream-Status message type: %d, source: %s, owner: %s, object: type %s, value %p", */ + /* type, path, ownerstr, G_VALUE_TYPE_NAME (val), g_value_get_object (val)); */ + /* g_free (path); */ + /* g_free (ownerstr); */ + + /* /\* see if we know how to deal with this object *\/ */ + /* if (G_VALUE_TYPE (val) == GST_TYPE_TASK) { */ + /* task = g_value_get_object (val); */ + /* } */ + + /* switch (type) { */ + /* case GST_STREAM_STATUS_TYPE_CREATE: */ + /* log_printf(DEBUG," created task %p", task); */ + /* break; */ + /* case GST_STREAM_STATUS_TYPE_ENTER: */ + /* /\* log_printf(DEBUG," raising task priority"); *\/ */ + /* /\* setpriority (PRIO_PROCESS, 0, -10); *\/ */ + /* break; */ + /* case GST_STREAM_STATUS_TYPE_LEAVE: */ + /* break; */ + /* default: */ + /* break; */ + /* } */ + /* break; */ + /* } */ + default: + /* log_printf(DEBUG, "unkonwn message %s from %s", GST_MESSAGE_TYPE_NAME(msg), GST_MESSAGE_SRC_NAME(msg)); */ + return TRUE; + } + return TRUE; +} + +int main_loop(options_t* opt) +{ + log_printf(NOTICE, "entering main loop"); + + struct udp_sinks sinks = { { NULL, NULL }, { NULL, NULL }, + { NULL, NULL }, { NULL, NULL }, opt->timeout_ }; + struct udp_sources sources = { NULL, NULL, NULL, NULL, opt->keepalive_int_, NULL , opt->rtp_port_base_ }; + GstElement *pipeline = opt->mode_ == SENDER ? create_sender_pipeline(opt, &sinks) : + create_receiver_pipeline(opt, &sources); + if(!pipeline) { + log_printf(ERROR, "creating pipeline failed - exitting"); + return -1; + } + + GMainLoop *loop = g_main_loop_new(NULL, FALSE); + + GstBus *bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline)); + gst_bus_add_watch(bus, bus_call, loop); + gst_object_unref(GST_OBJECT(bus)); + + gulong deep_notify_id = 0; + if(opt->debug_) { + deep_notify_id = g_signal_connect(pipeline, "deep-notify", + G_CALLBACK(gst_object_default_deep_notify), NULL); + } + + log_printf(NOTICE, "Set State: Paused"); + gst_element_set_state(pipeline, GST_STATE_PAUSED); + + if((opt->mode_ == SENDER && opt->auto_client_ && !attach_udpsinks(&sinks)) || + (opt->mode_ == RECEIVER && !attach_udpsources(&sources, opt->rtp_host_))) + return -1; + + log_printf(NOTICE, "Set State: Playing"); + gst_element_set_state(pipeline, GST_STATE_PLAYING); + + g_unix_signal_add(SIGHUP, sig_handler_terminate, loop); + g_unix_signal_add(SIGINT, sig_handler_terminate, loop); + g_unix_signal_add(SIGTERM, sig_handler_terminate, loop); + g_main_loop_run(loop); + + if(opt->mode_ == RECEIVER) + detach_udpsources(&sources); + + if (deep_notify_id != 0) + g_signal_handler_disconnect(pipeline, deep_notify_id); + + log_printf(NOTICE, "Stopping pipeline"); + gst_element_set_state(pipeline, GST_STATE_NULL); + gst_object_unref(GST_OBJECT(pipeline)); + + return 0; +} + +int main(int argc, char* argv[]) +{ + log_init(); + log_close(); + + options_t opt; + int ret = options_parse(&opt, argc, argv); + if(ret) { + if(ret == -1) { + options_print_version(); + ret = 0; + } + options_clear(&opt); + log_close(); + exit(ret); + } + + guint len = g_strv_length(opt.log_targets_); + guint i; + for(i = 0; i < len; ++i) { + ret = log_add_target(opt.log_targets_[i]); + if(ret) { + switch(ret) { + case -2: fprintf(stderr, "memory error on log_add_target, exitting\n"); break; + case -3: fprintf(stderr, "unknown log target: '%s', exitting\n", (char*)(opt.log_targets_[i])); break; + case -4: fprintf(stderr, "this log target is only allowed once: '%s', exitting\n", (char*)(opt.log_targets_[i])); break; + default: fprintf(stderr, "syntax error near: '%s', exitting\n", (char*)(opt.log_targets_[i])); break; + } + + options_clear(&opt); + log_close(); + exit(ret); + } + } + + log_printf(NOTICE, "just started..."); + + if(opt.debug_) + options_print(&opt); + + if(opt.appname_) + g_set_prgname (opt.appname_); + else + g_set_prgname (opt.progname_); + + priv_info_t priv; + if(opt.username_) + if(priv_init(&priv, opt.username_, opt.groupname_)) { + options_clear(&opt); + log_close(); + exit(-1); + } + + FILE* pid_file = NULL; + if(opt.pid_file_) { + pid_file = fopen(opt.pid_file_, "w"); + if(!pid_file) { + log_printf(WARNING, "unable to open pid file: %s", strerror(errno)); + } + } + + if(opt.chroot_dir_) + if(do_chroot(opt.chroot_dir_)) { + options_clear(&opt); + log_close(); + exit(-1); + } + if(opt.username_) + if(priv_drop(&priv)) { + options_clear(&opt); + log_close(); + exit(-1); + } + + if(opt.daemonize_) { + pid_t oldpid = getpid(); + daemonize(); + log_printf(INFO, "running in background now (old pid: %d)", oldpid); + } + + if(pid_file) { + pid_t pid = getpid(); + fprintf(pid_file, "%d", pid); + fclose(pid_file); + } + + const gchar *nano_str; + guint major, minor, micro, nano; + gst_version(&major, &minor, µ, &nano); + if (nano == 1) + nano_str = " (CVS)"; + else if (nano == 2) + nano_str = " (Prerelease)"; + else + nano_str = ""; + log_printf(NOTICE, "sydra-rtp linked against GStreamer %d.%d.%d%s", major, minor, micro, nano_str); + + ret = main_loop(&opt); + + options_clear(&opt); + + log_printf(NOTICE, "sydra-rtp shutdown"); + + gst_deinit(); + log_close(); + + return ret; +} diff --git a/src/sydra.c b/src/sydra.c deleted file mode 100644 index 70b9e56..0000000 --- a/src/sydra.c +++ /dev/null @@ -1,327 +0,0 @@ -/* - * sydra - * - * sydra is a toolbox which allows you to set up multiple bidirectional - * Video/Audio streams from external locations. - * sydra has been written to be used for the Elevate Festival in Graz - * Austria in order to involve external locations to present themselves - * at the festival. - * Sydra is based on GStreamer and is written in C. - * - * - * Copyright (C) 2014 Christian Pointner - * - * This file is part of sydra. - * - * sydra is free software: you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation, either version 3 of the License, or - * any later version. - * - * sydra 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 General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with sydra. If not, see . - * - * In addition, as a special exception, the copyright holders hereby - * grant permission for non-GPL-compatible GStreamer plugins to be used - * and distributed together with GStreamer and sydra. - * This permission goes above and beyond the permissions granted by the - * GPL license sydra is covered by. - */ - -#define _GNU_SOURCE -#include -#include -#include -#include -#include -#include - -#include -#include -#include - -#include "datatypes.h" -#include "options.h" -#include "log.h" -#include "daemon.h" -#include "utils.h" -#include "pipelines.h" -#include "udp.h" - - -static gboolean sig_handler_terminate(gpointer user_data) -{ - GMainLoop *loop = (GMainLoop *)user_data; - - log_printf(NOTICE, "signal received, closing application"); - g_main_loop_quit(loop); - return TRUE; -} - -static gboolean bus_call(GstBus *bus, GstMessage *msg, gpointer data) -{ - GMainLoop *loop = (GMainLoop *)data; - - switch (GST_MESSAGE_TYPE(msg)) { - case GST_MESSAGE_EOS: { - log_printf(NOTICE, "End of stream"); - g_main_loop_quit(loop); - break; - } - case GST_MESSAGE_INFO: { - GError *info; - gst_message_parse_info(msg, &info, NULL); - log_printf(INFO, "%s", info->message); - g_error_free(info); - break; - } - case GST_MESSAGE_WARNING: { - GError *warning; - gst_message_parse_warning(msg, &warning, NULL); - log_printf(WARNING, "%s", warning->message); - g_error_free(warning); - break; - } - case GST_MESSAGE_ERROR: { - GError *error; - gst_message_parse_error(msg, &error, NULL); - log_printf(ERROR, "%s", error->message); - g_error_free(error); - g_main_loop_quit(loop); - break; - } - case GST_MESSAGE_STATE_CHANGED: { - GstState old_state, new_state; - gst_message_parse_state_changed(msg, &old_state, &new_state, NULL); - log_printf(DEBUG, "Element '%s' changed state from %s to %s", - (msg->src ? GST_OBJECT_NAME(msg->src) : "NULL"), - gst_element_state_get_name(old_state), - gst_element_state_get_name(new_state)); - break; - } - case GST_MESSAGE_NEW_CLOCK: - { - GstClock *clock; - gst_message_parse_new_clock(msg, &clock); - log_printf(NOTICE, "New clock: %s", (clock ? GST_OBJECT_NAME (clock) : "NULL")); - break; - } - case GST_MESSAGE_QOS: { - guint64 running_time, stream_time, timestamp, duration; - gst_message_parse_qos(msg, NULL, &running_time, &stream_time, ×tamp, &duration); - log_printf(WARNING, "Element '%s' dropped frames running_time=%lu, stream_time=%lu, timestamp=%lu, duration=%lu", - (msg->src ? GST_OBJECT_NAME(msg->src) : "NULL"), running_time, stream_time, timestamp, duration); - break; - } - /* case GST_MESSAGE_STREAM_STATUS: */ - /* { */ - /* GstStreamStatusType type; */ - /* GstElement *owner; */ - /* const GValue *val; */ - /* gchar *path, *ownerstr; */ - /* GstTask *task = NULL; */ - - /* gst_message_parse_stream_status (msg, &type, &owner); */ - /* val = gst_message_get_stream_status_object (msg); */ - - /* path = gst_object_get_path_string (GST_MESSAGE_SRC (msg)); */ - /* ownerstr = gst_object_get_path_string (GST_OBJECT (owner)); */ - /* log_printf(DEBUG,"Recevied Stream-Status message type: %d, source: %s, owner: %s, object: type %s, value %p", */ - /* type, path, ownerstr, G_VALUE_TYPE_NAME (val), g_value_get_object (val)); */ - /* g_free (path); */ - /* g_free (ownerstr); */ - - /* /\* see if we know how to deal with this object *\/ */ - /* if (G_VALUE_TYPE (val) == GST_TYPE_TASK) { */ - /* task = g_value_get_object (val); */ - /* } */ - - /* switch (type) { */ - /* case GST_STREAM_STATUS_TYPE_CREATE: */ - /* log_printf(DEBUG," created task %p", task); */ - /* break; */ - /* case GST_STREAM_STATUS_TYPE_ENTER: */ - /* /\* log_printf(DEBUG," raising task priority"); *\/ */ - /* /\* setpriority (PRIO_PROCESS, 0, -10); *\/ */ - /* break; */ - /* case GST_STREAM_STATUS_TYPE_LEAVE: */ - /* break; */ - /* default: */ - /* break; */ - /* } */ - /* break; */ - /* } */ - default: - /* log_printf(DEBUG, "unkonwn message %s from %s", GST_MESSAGE_TYPE_NAME(msg), GST_MESSAGE_SRC_NAME(msg)); */ - return TRUE; - } - return TRUE; -} - -int main_loop(options_t* opt) -{ - log_printf(NOTICE, "entering main loop"); - - struct udp_sinks sinks = { { NULL, NULL }, { NULL, NULL }, - { NULL, NULL }, { NULL, NULL }, opt->timeout_ }; - struct udp_sources sources = { NULL, NULL, NULL, NULL, opt->keepalive_int_, NULL , opt->rtp_port_base_ }; - GstElement *pipeline = opt->mode_ == SENDER ? create_sender_pipeline(opt, &sinks) : - create_receiver_pipeline(opt, &sources); - if(!pipeline) { - log_printf(ERROR, "creating pipeline failed - exitting"); - return -1; - } - - GMainLoop *loop = g_main_loop_new(NULL, FALSE); - - GstBus *bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline)); - gst_bus_add_watch(bus, bus_call, loop); - gst_object_unref(GST_OBJECT(bus)); - - gulong deep_notify_id = 0; - if(opt->debug_) { - deep_notify_id = g_signal_connect(pipeline, "deep-notify", - G_CALLBACK(gst_object_default_deep_notify), NULL); - } - - log_printf(NOTICE, "Set State: Paused"); - gst_element_set_state(pipeline, GST_STATE_PAUSED); - - if((opt->mode_ == SENDER && opt->auto_client_ && !attach_udpsinks(&sinks)) || - (opt->mode_ == RECEIVER && !attach_udpsources(&sources, opt->rtp_host_))) - return -1; - - log_printf(NOTICE, "Set State: Playing"); - gst_element_set_state(pipeline, GST_STATE_PLAYING); - - g_unix_signal_add(SIGHUP, sig_handler_terminate, loop); - g_unix_signal_add(SIGINT, sig_handler_terminate, loop); - g_unix_signal_add(SIGTERM, sig_handler_terminate, loop); - g_main_loop_run(loop); - - if(opt->mode_ == RECEIVER) - detach_udpsources(&sources); - - if (deep_notify_id != 0) - g_signal_handler_disconnect(pipeline, deep_notify_id); - - log_printf(NOTICE, "Stopping pipeline"); - gst_element_set_state(pipeline, GST_STATE_NULL); - gst_object_unref(GST_OBJECT(pipeline)); - - return 0; -} - -int main(int argc, char* argv[]) -{ - log_init(); - log_close(); - - options_t opt; - int ret = options_parse(&opt, argc, argv); - if(ret) { - if(ret == -1) { - options_print_version(); - ret = 0; - } - options_clear(&opt); - log_close(); - exit(ret); - } - - guint len = g_strv_length(opt.log_targets_); - guint i; - for(i = 0; i < len; ++i) { - ret = log_add_target(opt.log_targets_[i]); - if(ret) { - switch(ret) { - case -2: fprintf(stderr, "memory error on log_add_target, exitting\n"); break; - case -3: fprintf(stderr, "unknown log target: '%s', exitting\n", (char*)(opt.log_targets_[i])); break; - case -4: fprintf(stderr, "this log target is only allowed once: '%s', exitting\n", (char*)(opt.log_targets_[i])); break; - default: fprintf(stderr, "syntax error near: '%s', exitting\n", (char*)(opt.log_targets_[i])); break; - } - - options_clear(&opt); - log_close(); - exit(ret); - } - } - - log_printf(NOTICE, "just started..."); - - if(opt.debug_) - options_print(&opt); - - if(opt.appname_) - g_set_prgname (opt.appname_); - else - g_set_prgname (opt.progname_); - - priv_info_t priv; - if(opt.username_) - if(priv_init(&priv, opt.username_, opt.groupname_)) { - options_clear(&opt); - log_close(); - exit(-1); - } - - FILE* pid_file = NULL; - if(opt.pid_file_) { - pid_file = fopen(opt.pid_file_, "w"); - if(!pid_file) { - log_printf(WARNING, "unable to open pid file: %s", strerror(errno)); - } - } - - if(opt.chroot_dir_) - if(do_chroot(opt.chroot_dir_)) { - options_clear(&opt); - log_close(); - exit(-1); - } - if(opt.username_) - if(priv_drop(&priv)) { - options_clear(&opt); - log_close(); - exit(-1); - } - - if(opt.daemonize_) { - pid_t oldpid = getpid(); - daemonize(); - log_printf(INFO, "running in background now (old pid: %d)", oldpid); - } - - if(pid_file) { - pid_t pid = getpid(); - fprintf(pid_file, "%d", pid); - fclose(pid_file); - } - - const gchar *nano_str; - guint major, minor, micro, nano; - gst_version(&major, &minor, µ, &nano); - if (nano == 1) - nano_str = " (CVS)"; - else if (nano == 2) - nano_str = " (Prerelease)"; - else - nano_str = ""; - log_printf(NOTICE, "sydra linked against GStreamer %d.%d.%d%s", major, minor, micro, nano_str); - - ret = main_loop(&opt); - - options_clear(&opt); - - log_printf(NOTICE, "sydra shutdown"); - - gst_deinit(); - log_close(); - - return ret; -} -- cgit v1.2.3