1 files changed, 13 insertions, 18 deletions

diff --git a/src/pipelines.c b/src/pipelines.c
index c8eae3e..55054f8 100644
--- a/src/pipelines.c
+++ b/src/pipelines.c
@@ -243,10 +243,14 @@ static gboolean create_rtp_reflector(options_t* opt, GstElement* pipeline, struc
   log_printf(INFO, "udp reflector sinks created successfully!");
 
   int rtp_port_reflector = opt->rtp_port_base_reflector_;
-  g_object_set(G_OBJECT(rtp_video), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++, "sync", FALSE, NULL);
-  g_object_set(G_OBJECT(rtcp_video), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++, "sync", FALSE, NULL);
-  g_object_set(G_OBJECT(rtp_audio), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++, "sync", FALSE, NULL);
-  g_object_set(G_OBJECT(rtcp_audio), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++, "sync", FALSE, NULL);
+  g_object_set(G_OBJECT(rtp_video), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++,
+                                    "sync", FALSE, "async", FALSE, NULL);
+  g_object_set(G_OBJECT(rtcp_video), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++,
+                                     "sync", FALSE, "async", FALSE, NULL);
+  g_object_set(G_OBJECT(rtp_audio), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++,
+                                    "sync", FALSE, "async", FALSE, NULL);
+  g_object_set(G_OBJECT(rtcp_audio), "host", opt->rtp_host_reflector_, "port", rtp_port_reflector++,
+                                     "sync", FALSE, "async", FALSE, NULL);
 
   log_printf(INFO, "udp reflector sinks configured successfully!");
 
@@ -275,19 +279,15 @@ static gboolean create_udp_sources(options_t* opt, GstElement* pipeline, GstElem
 
   sources->rtp_video_ = sydra_create_element("udpsrc", "udprtpv");
   tees.rtpv_ = sydra_create_element("tee", "rtpvt");
-  GstElement* qrtpv = sydra_create_element("queue", NULL);
   sources->rtcp_video_ = sydra_create_element("udpsrc", "udprtcpv");
   tees.rtcpv_ = sydra_create_element("tee", "rtcpvt");
-  GstElement* qrtcpv = sydra_create_element("queue", NULL);
   sources->rtp_audio_ = sydra_create_element("udpsrc", "udprtpa");
   tees.rtpa_ = sydra_create_element("tee", "rtpat");
-  GstElement* qrtpa = sydra_create_element("queue", NULL);
   sources->rtcp_audio_ = sydra_create_element("udpsrc", "udprtcpa");
   tees.rtcpa_ = sydra_create_element("tee", "rtcpat");
-  GstElement* qrtcpa = sydra_create_element("queue", NULL);
 
   if(!(sources->rtp_video_) || !(sources->rtcp_video_) || !(sources->rtp_audio_) || !(sources->rtcp_audio_) ||
-     !(tees.rtpv_) || !(tees.rtcpv_) || !(tees.rtpa_) || !(tees.rtcpa_) || !qrtpv || !qrtcpv || !qrtpa || !qrtcpa)
+     !(tees.rtpv_) || !(tees.rtcpv_) || !(tees.rtpa_) || !(tees.rtcpa_))
     return FALSE;
 
   log_printf(INFO, "udp sources created successfully!");
@@ -317,21 +317,16 @@ static gboolean create_udp_sources(options_t* opt, GstElement* pipeline, GstElem
 
   gst_bin_add_many(GST_BIN(pipeline), sources->rtp_video_, sources->rtcp_video_, sources->rtp_audio_, sources->rtcp_audio_, NULL);
   gst_bin_add_many(GST_BIN(pipeline), tees.rtpv_, tees.rtcpv_, tees.rtpa_, tees.rtcpa_, NULL);
-  gst_bin_add_many(GST_BIN(pipeline), qrtpv, qrtcpv, qrtpa, qrtcpa, NULL);
 
   gst_element_link(sources->rtp_video_, tees.rtpv_);
   gst_element_link(sources->rtcp_video_, tees.rtcpv_);
   gst_element_link(sources->rtp_audio_, tees.rtpa_);
   gst_element_link(sources->rtcp_audio_, tees.rtcpa_);
 
-  if(!sydra_link_request_static(tees.rtpv_, "src_%u", qrtpv, "sink") ||
-     !sydra_link_static_request(qrtpv, "src", rtp, "recv_rtp_sink_0") ||
-     !sydra_link_request_static(tees.rtcpv_, "src_%u", qrtcpv, "sink") ||
-     !sydra_link_static_request(qrtcpv, "src", rtp, "recv_rtcp_sink_0") ||
-     !sydra_link_request_static(tees.rtpa_, "src_%u", qrtpa, "sink") ||
-     !sydra_link_static_request(qrtpa, "src", rtp, "recv_rtp_sink_1") ||
-     !sydra_link_request_static(tees.rtcpa_, "src_%u", qrtcpa, "sink") ||
-     !sydra_link_static_request(qrtcpa, "src", rtp, "recv_rtcp_sink_1"))
+  if(!sydra_link_request_request(tees.rtpv_, "src_%u", rtp, "recv_rtp_sink_0") ||
+     !sydra_link_request_request(tees.rtcpv_, "src_%u", rtp, "recv_rtcp_sink_0") ||
+     !sydra_link_request_request(tees.rtpa_, "src_%u", rtp, "recv_rtp_sink_1") ||
+     !sydra_link_request_request(tees.rtcpa_, "src_%u", rtp, "recv_rtcp_sink_1"))
     return FALSE;
 
   log_printf(INFO, "udp sources linked successfully!");