From 7d202145f41a4b5e4e738138648b11077647f5e3 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Sat, 27 Sep 2014 18:39:40 +0200 Subject: started receiver mode pipeline implementation --- src/pipelines.c | 17 ++++++++++++++--- src/udp.c | 4 ++-- 2 files changed, 16 insertions(+), 5 deletions(-) (limited to 'src') diff --git a/src/pipelines.c b/src/pipelines.c index b241cde..3fe09e8 100644 --- a/src/pipelines.c +++ b/src/pipelines.c @@ -263,12 +263,23 @@ GstElement* create_sender_pipeline(options_t* opt, struct udp_sinks *udp) return NULL; } - log_printf(DEBUG, "pipeline created successfully!"); + log_printf(DEBUG, "sender pipeline created successfully!"); return pipeline; } GstElement* create_receiver_pipeline(options_t* opt, struct udp_sources *udp) { - log_printf(ERROR, "Receiver Mode is not yet implemented!"); - return NULL; + GstElement *pipeline = gst_pipeline_new ("sydra"); + if(!pipeline) { + log_printf(ERROR, "Creating pipeline failed!"); + return NULL; + } + GstElement *rtp = sydra_create_element("rtpbin", "rtpbin"); + if(!rtp || !gst_bin_add(GST_BIN(pipeline), rtp)) { + return NULL; + } + log_printf(DEBUG, "rtpbin created successfully!"); + + log_printf(DEBUG, "receiver pipeline created successfully!"); + return pipeline; } diff --git a/src/udp.c b/src/udp.c index 85a8b39..470df36 100644 --- a/src/udp.c +++ b/src/udp.c @@ -236,7 +236,7 @@ gboolean attach_udpsources(struct udp_sources *sources) if(!sources) return FALSE; - log_printf(ERROR, "Receiver Mode is not yet implemented!"); + log_printf(WARNING, "udp source keep alive messages are not implemented yet!"); - return FALSE; + return TRUE; } -- cgit v1.2.3