Lines Matching refs:udpsrc
2012 if (stream->udpsrc[0] == src) in find_stream_by_udpsrc()
2014 if (stream->udpsrc[1] == src) in find_stream_by_udpsrc()
2441 if (stream->udpsrc[i]) { in gst_rtspsrc_stream_free()
2442 gst_element_set_state (stream->udpsrc[i], GST_STATE_NULL); in gst_rtspsrc_stream_free()
2443 if (gst_object_has_as_parent (GST_OBJECT (stream->udpsrc[i]), in gst_rtspsrc_stream_free()
2445 gst_bin_remove (GST_BIN_CAST (src), stream->udpsrc[i]); in gst_rtspsrc_stream_free()
2446 gst_object_unref (stream->udpsrc[i]); in gst_rtspsrc_stream_free()
2681 stream->udpsrc[0] = gst_object_ref_sink (udpsrc0); in gst_rtspsrc_alloc_udp_ports()
2682 stream->udpsrc[1] = gst_object_ref_sink (udpsrc1); in gst_rtspsrc_alloc_udp_ports()
2683 gst_element_set_locked_state (stream->udpsrc[0], TRUE); in gst_rtspsrc_alloc_udp_ports()
2684 gst_element_set_locked_state (stream->udpsrc[1], TRUE); in gst_rtspsrc_alloc_udp_ports()
2743 if (stream->udpsrc[i]) in gst_rtspsrc_set_state()
2744 gst_element_set_state (stream->udpsrc[i], state); in gst_rtspsrc_set_state()
4224 if (stream->udpsrc[i]) { in gst_rtspsrc_stream_free_udp()
4226 gst_element_set_state (stream->udpsrc[i], GST_STATE_NULL); in gst_rtspsrc_stream_free_udp()
4227 gst_object_unref (stream->udpsrc[i]); in gst_rtspsrc_stream_free_udp()
4228 stream->udpsrc[i] = NULL; in gst_rtspsrc_stream_free_udp()
4404 stream->udpsrc[0] = in gst_rtspsrc_stream_configure_mcast()
4407 if (stream->udpsrc[0] == NULL) in gst_rtspsrc_stream_configure_mcast()
4411 gst_object_ref_sink (stream->udpsrc[0]); in gst_rtspsrc_stream_configure_mcast()
4414 g_object_set (G_OBJECT (stream->udpsrc[0]), "buffer-size", in gst_rtspsrc_stream_configure_mcast()
4418 g_object_set (G_OBJECT (stream->udpsrc[0]), "multicast-iface", in gst_rtspsrc_stream_configure_mcast()
4422 gst_element_set_locked_state (stream->udpsrc[0], TRUE); in gst_rtspsrc_stream_configure_mcast()
4423 gst_element_set_state (stream->udpsrc[0], GST_STATE_READY); in gst_rtspsrc_stream_configure_mcast()
4431 stream->udpsrc[1] = in gst_rtspsrc_stream_configure_mcast()
4434 if (stream->udpsrc[1] == NULL) in gst_rtspsrc_stream_configure_mcast()
4442 g_object_set (stream->udpsrc[1], "caps", caps, NULL); in gst_rtspsrc_stream_configure_mcast()
4446 gst_object_ref_sink (stream->udpsrc[1]); in gst_rtspsrc_stream_configure_mcast()
4449 g_object_set (G_OBJECT (stream->udpsrc[1]), "multicast-iface", in gst_rtspsrc_stream_configure_mcast()
4452 gst_element_set_state (stream->udpsrc[1], GST_STATE_READY); in gst_rtspsrc_stream_configure_mcast()
4481 if (stream->udpsrc[0]) { in gst_rtspsrc_stream_configure_udp()
4484 gst_element_set_locked_state (stream->udpsrc[0], TRUE); in gst_rtspsrc_stream_configure_udp()
4485 gst_bin_add (GST_BIN_CAST (src), stream->udpsrc[0]); in gst_rtspsrc_stream_configure_udp()
4492 g_object_set (G_OBJECT (stream->udpsrc[0]), "timeout", in gst_rtspsrc_stream_configure_udp()
4496 g_object_set (stream->udpsrc[0], "caps", caps, NULL); in gst_rtspsrc_stream_configure_udp()
4499 *outpad = gst_element_get_static_pad (stream->udpsrc[0], "src"); in gst_rtspsrc_stream_configure_udp()
4531 if (stream->udpsrc[1]) { in gst_rtspsrc_stream_configure_udp()
4534 gst_element_set_locked_state (stream->udpsrc[1], TRUE); in gst_rtspsrc_stream_configure_udp()
4535 gst_bin_add (GST_BIN_CAST (src), stream->udpsrc[1]); in gst_rtspsrc_stream_configure_udp()
4542 g_object_set (stream->udpsrc[1], "caps", caps, NULL); in gst_rtspsrc_stream_configure_udp()
4550 pad = gst_element_get_static_pad (stream->udpsrc[1], "src"); in gst_rtspsrc_stream_configure_udp()
4611 if (stream->udpsrc[0]) { in gst_rtspsrc_stream_configure_udp_sinks()
4614 g_object_get (G_OBJECT (stream->udpsrc[0]), "used-socket", &socket, NULL); in gst_rtspsrc_stream_configure_udp_sinks()
4676 if (stream->udpsrc[1]) { in gst_rtspsrc_stream_configure_udp_sinks()
4680 g_object_get (G_OBJECT (stream->udpsrc[1]), "used-socket", &socket, NULL); in gst_rtspsrc_stream_configure_udp_sinks()
4903 if (stream->udpsrc[0]) { in gst_rtspsrc_activate_streams()
4906 g_object_set (G_OBJECT (stream->udpsrc[0]), "timeout", (guint64) 0, NULL); in gst_rtspsrc_activate_streams()
4998 if (stream->udpsrc[0]) in gst_rtspsrc_configure_caps()
4999 g_object_set (stream->udpsrc[0], "caps", caps, NULL); in gst_rtspsrc_configure_caps()
5054 if (stream->udpsrc[0]) { in gst_rtspsrc_stream_push_event()
5064 res = gst_element_send_event (stream->udpsrc[0], sent_event); in gst_rtspsrc_stream_push_event()
5073 if (stream->udpsrc[1]) { in gst_rtspsrc_stream_push_event()
5085 res &= gst_element_send_event (stream->udpsrc[1], sent_event); in gst_rtspsrc_stream_push_event()
5520 if (ostream->udpsrc[0]) { in gst_rtspsrc_handle_data()
5521 gst_element_send_event (ostream->udpsrc[0], in gst_rtspsrc_handle_data()
5539 if (ostream->udpsrc[1]) { in gst_rtspsrc_handle_data()
5540 gst_element_send_event (ostream->udpsrc[1], in gst_rtspsrc_handle_data()
7206 } else if (stream->udpsrc[0] && stream->udpsrc[1] && rtpport && rtcpport) { in gst_rtsp_src_setup_stream_from_response()
7208 g_object_get (G_OBJECT (stream->udpsrc[0]), "port", rtpport, NULL); in gst_rtsp_src_setup_stream_from_response()
7209 g_object_get (G_OBJECT (stream->udpsrc[1]), "port", rtcpport, NULL); in gst_rtsp_src_setup_stream_from_response()
8578 if (item->pt == stream->default_pt && stream->udpsrc[0]) in clear_rtp_base()
8579 g_object_set (stream->udpsrc[0], "caps", item->caps, NULL); in clear_rtp_base()
9083 GstObject *udpsrc; in gst_rtspsrc_handle_message() local
9087 udpsrc = GST_MESSAGE_SRC (message); in gst_rtspsrc_handle_message()
9090 GST_ELEMENT_NAME (udpsrc)); in gst_rtspsrc_handle_message()
9092 stream = find_stream (rtspsrc, udpsrc, (gpointer) find_stream_by_udpsrc); in gst_rtspsrc_handle_message()
9097 if (stream->udpsrc[1] == GST_ELEMENT_CAST (udpsrc)) in gst_rtspsrc_handle_message()