started receiver mode pipeline implementation

2 files changed, 16 insertions, 5 deletions

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;
 }