mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-19 14:56:36 +00:00
Code Issues 1 Projects Releases Wiki Activity

rtpcollision: Fix memory leaks in unit test

Browse source
This commit is contained in:
Sebastian Dröge 2014-04-17 16:39:59 +02:00
parent 77badda6b9
commit 0c073b2d1d
1 changed files with 12 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
tests/check/elements/rtpcollision.c
View file

@ -78,32 +78,32 @@ message_received (GstBus * bus, GstMessage * message, GstPipeline * bin)
static GstBuffer * static GstBuffer *
create_rtcp_app (guint32 ssrc) create_rtcp_app (guint32 ssrc)
{ {
GInetAddress *inet_addr_0 = g_inet_address_new_from_string ("192.168.1.1"); GInetAddress *inet_addr_0;
guint16 port = 5678; guint16 port = 5678;
GSocketAddress *socket_addr_0 = g_inet_socket_address_new (inet_addr_0, port); GSocketAddress *socket_addr_0;
GstBuffer *old_rtcp_buffer = gst_rtcp_buffer_new (1400); GstBuffer *rtcp_buffer;
GstBuffer *rtcp_buffer = NULL;
GstRTCPPacket *rtcp_packet = NULL; GstRTCPPacket *rtcp_packet = NULL;
GstRTCPBuffer rtcp = GST_RTCP_BUFFER_INIT; GstRTCPBuffer rtcp = GST_RTCP_BUFFER_INIT;
/* make sure to have a writable buffer before inet_addr_0 = g_inet_address_new_from_string ("192.168.1.1");
* changing anything socket_addr_0 = g_inet_socket_address_new (inet_addr_0, port);
*/ g_object_unref (inet_addr_0);
rtcp_buffer = gst_buffer_make_writable (old_rtcp_buffer);
if (old_rtcp_buffer != rtcp_buffer) { rtcp_buffer = gst_rtcp_buffer_new (1400);
gst_buffer_unref (old_rtcp_buffer);
}
gst_buffer_add_net_address_meta (rtcp_buffer, socket_addr_0); gst_buffer_add_net_address_meta (rtcp_buffer, socket_addr_0);
g_object_unref (socket_addr_0);
/* need to begin with rr */ /* need to begin with rr */
gst_rtcp_buffer_map (rtcp_buffer, GST_MAP_READWRITE, &rtcp); gst_rtcp_buffer_map (rtcp_buffer, GST_MAP_READWRITE, &rtcp);
rtcp_packet = g_slice_new0 (GstRTCPPacket); rtcp_packet = g_slice_new0 (GstRTCPPacket);
gst_rtcp_buffer_add_packet (&rtcp, GST_RTCP_TYPE_RR, rtcp_packet); gst_rtcp_buffer_add_packet (&rtcp, GST_RTCP_TYPE_RR, rtcp_packet);
gst_rtcp_packet_rr_set_ssrc (rtcp_packet, ssrc); gst_rtcp_packet_rr_set_ssrc (rtcp_packet, ssrc);
g_slice_free (GstRTCPPacket, rtcp_packet);
/* useful to make the rtcp buffer valid */ /* useful to make the rtcp buffer valid */
rtcp_packet = g_slice_new0 (GstRTCPPacket); rtcp_packet = g_slice_new0 (GstRTCPPacket);
gst_rtcp_buffer_add_packet (&rtcp, GST_RTCP_TYPE_APP, rtcp_packet); gst_rtcp_buffer_add_packet (&rtcp, GST_RTCP_TYPE_APP, rtcp_packet);
g_slice_free (GstRTCPPacket, rtcp_packet);
gst_rtcp_buffer_unmap (&rtcp); gst_rtcp_buffer_unmap (&rtcp);
return rtcp_buffer; return rtcp_buffer;
@ -152,6 +152,7 @@ rtpsession_sinkpad_probe (GstPad * pad, GstPadProbeInfo * info,
static GstFlowReturn static GstFlowReturn
fake_udp_sink_chain_func (GstPad * pad, GstObject * parent, GstBuffer * buffer) fake_udp_sink_chain_func (GstPad * pad, GstObject * parent, GstBuffer * buffer)
{ {
gst_buffer_unref (buffer);
return GST_FLOW_OK; return GST_FLOW_OK;
} }