<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40"> <head> <meta http-equiv="Content-Type" content="text/html; charset=us-ascii"> <meta name="Generator" content="Microsoft Word 15 (filtered medium)"> <style></style> </head> <body lang="EN-GB" link="#0563C1" vlink="#954F72"> <div class="WordSection1"> Hello everyone<o:p></o:p> <o:p> </o:p> I have encountered a problem using udpsink in windows and wonder if anyone can help.<o:p></o:p> <o:p> </o:p> I am not sure if the issue is down to me (as I have ported it use the current V1.0 release), or it is in fact a bug.<o:p></o:p> <o:p> </o:p> The problem that I have is that the udpsink is not sending any packets at all. The code catches the following warning message being emitted from the pipeline:<o:p></o:p> <o:p> </o:p> WarningMessage:- Error sending UDP packet<o:p></o:p> DebugInfo:- gstmultiudpsink.c(545): gst_multiudpsink_= render (): /GstPipeline:pipeline0/GstUDPSink:rtpsink:<o:p></o:p> Reason: Error sending message: The system detected an invalid pointer address in attempting to use a pointer argument in a call.<o:p></o:p> <o:p> </o:p> I have run the equivalent pipeline from a launch line on a virtual machine running Ubuntu V12.04 and everything works fine. I can even connect to this stream using windows but the same message is emitted by the udpsink in this pipeline that is used for the rtcp connection.<o:p></o:p> <o:p> </o:p> Any help or information would be appreciated.<o:p></o:p> <o:p> </o:p> Kind Regards<o:p></o:p> <o:p> </o:p> Jon<o:p></o:p> <o:p> </o:p> The code that I have ported is as follows:<o:p></o:p> <o:p> </o:p> /*<o:p></o:p> * A Hands-On Course in GStreamer Development<o:p></o:p> * Copyright 2008 Wim Taymans <wim.taymans@gmail.com><o:p></o:p> * <o:p></o:p> * Permission is hereby granted, free of charge, to any person obtaining a<o:p></o:p> * copy of this software and associated documentation files (the "Software"),<o:p></o:p> * to deal in the Software without restriction, including without limitation<o:p></o:p> * the rights to use, copy, modify, merge, publish, distribute, sublicense,<o:p></o:p> * and/or sell copies of the Software, and to permit persons to whom the<o:p></o:p> * Software is furnished to do so, subject to the following conditions:<o:p></o:p> *<o:p></o:p> * The above copyright notice and this permission notice shall be included in<o:p></o:p> * all copies or substantial portions of the Software.<o:p></o:p> *<o:p></o:p> * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR<o:p></o:p> * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,<o:p></o:p> * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE<o:p></o:p> * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER<o:p></o:p> * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING<o:p></o:p> * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER<o:p></o:p> * DEALINGS IN THE SOFTWARE.<o:p></o:p> */<o:p></o:p> <o:p> </o:p> #include <gst/gst.h><o:p></o:p> <o:p> </o:p> /*<o:p></o:p> * A simple RTP server<o:p></o:p> * sends the output of alsasrc as alaw encoded RTP on port 5002, RTCP is sent on<o:p></o:p> * port 5003. The destination is 127.0.0.1.<o:p></o:p> * the receiver RTCP reports are received on port 5007<o:p></o:p> *<o:p></o:p> * .-------. .-------. .-------. .----------. .-------.<o:p></o:p> * | src | |alawenc| |pcmapay| | rtpbin | |udpsink| RTP<o:p></o:p> * | src->sink src->sink src->send_rtp send_rtp->sink | port=5002<o:p></o:p> * '-------' '-------' '-------' | | '-------'<o:p></o:p> * | |<o:p></o:p> * | | .-------.<o:p></o:p> * | | |udpsink| RTCP<o:p></o:p> * | send_rtcp->sink | port=5003<o:p></o:p> * .-------. | | '-------' sync=false<o:p></o:p> * RTCP |udpsrc | | | async=false<o:p></o:p> * port=5007 | src->recv_rtcp |<o:p></o:p> * '-------' '----------'<o:p></o:p> */<o:p></o:p> <o:p> </o:p> static void<o:p></o:p> on_ssrc_active_cb (GObject *session, GObject *source, gpointer user_data)<o:p></o:p> {<o:p></o:p> GstStructure *stats;<o:p></o:p> gchar *str;<o:p></o:p> <o:p> </o:p> /* get the source stats */<o:p></o:p> g_object_get (source, "stats", &stats, NULL);<o:p></o:p> <o:p> </o:p> /* simply dump the stats structure */<o:p></o:p> str = gst_structure_to_string (stats);<o:p></o:p> g_print ("source stats: %s\n", str);<o:p></o:p> <o:p> </o:p> gst_structure_free (stats);<o:p></o:p> g_free (str);<o:p></o:p> }<o:p></o:p> <o:p> </o:p> static void<o:p></o:p> on_sending_rtcp_cb (GObject *session, GstBuffer *buffer, gboolean early, gpointer user_data)<o:p></o:p> {<o:p></o:p> GstMapInfo info;<o:p></o:p> <o:p> </o:p> g_print ("we're sending RTCP\n");<o:p></o:p> <o:p> </o:p> if(gst_buffer_map(buffer, &info, GST_MAP_READ))<o:p></o:p> {<o:p></o:p> gst_util_dump_mem (info.data, gst_buffer_get_size(buffer));<o:p></o:p> <o:p> </o:p> gst_buffer_unmap(buffer, &info);<o:p></o:p> }<o:p></o:p> }<o:p></o:p> <o:p> </o:p> int<o:p></o:p> main (int argc, char *argv[])<o:p></o:p> {<o:p></o:p> GstElement *pipeline, *src, *enc, *pay;<o:p></o:p> GstElement *rtpbin, *rtpsink, *rtcpsink, *rtcpsrc;<o:p></o:p> GError *error = NULL;<o:p></o:p> GstStateChangeReturn res;<o:p></o:p> GstBus *bus;<o:p></o:p> gboolean done, eres;<o:p></o:p> GstPadLinkReturn lres;<o:p></o:p> GstPad *srcpad, *sinkpad;<o:p></o:p> GObject *session;<o:p></o:p> gchar *host = "127.0.0.1";<o:p></o:p> <o:p> </o:p> /* must be called first */<o:p></o:p> gst_init (&argc, &argv);<o:p></o:p> <o:p> </o:p> if(argc > 1)<o:p></o:p> {<o:p></o:p> host = argv[1];<o:p></o:p> }<o:p></o:p> <o:p> </o:p> g_print ("Creating pipeline\n");<o:p></o:p> <o:p> </o:p> /* create the pipeline */<o:p></o:p> /* "audiotestsrc ! alawenc ! rtppcmapay ! udpsink port=5002 host=127.0.0.1" */<o:p></o:p> pipeline = gst_pipeline_new ("pipeline");<o:p></o:p> g_assert (pipeline);<o:p></o:p> <o:p> </o:p> src = gst_element_factory_make ("audiotestsrc", "src");<o:p></o:p> g_assert (src);<o:p></o:p> <o:p> </o:p> enc = gst_element_factory_make ("alawenc", "enc");<o:p></o:p> g_assert (enc);<o:p></o:p> <o:p> </o:p> pay = gst_element_factory_make ("rtppcmapay", "pay");<o:p></o:p> g_assert (pay);<o:p></o:p> <o:p> </o:p> /* add capture and payloading to the pipeline and link */<o:p></o:p> gst_bin_add_many (GST_BIN (pipeline), src, enc, pay, NULL);<o:p></o:p> <o:p> </o:p> eres = gst_element_link_many (src, enc, pay, NULL);<o:p></o:p> g_assert (eres == TRUE);<o:p></o:p> <o:p> </o:p> /* the rtpbin element */<o:p></o:p> rtpbin = gst_element_factory_make ("rtpbin", "rtpbin");<o:p></o:p> g_assert (rtpbin);<o:p></o:p> <o:p> </o:p> gst_bin_add (GST_BIN (pipeline), rtpbin);<o:p></o:p> <o:p> </o:p> /* the udp sinks and source we will use for RTP and RTCP */<o:p></o:p> rtpsink = gst_element_factory_make ("udpsink", "rtpsink");<o:p></o:p> g_assert (rtpsink);<o:p></o:p> g_object_set (rtpsink, "port", 5002, "host", host, NULL);<o:p></o:p> <o:p> </o:p> rtcpsink = gst_element_factory_make ("udpsink", "rtcpsink");<o:p></o:p> g_assert (rtcpsink);<o:p></o:p> g_object_set (rtcpsink, "port", 5003, "host", host, NULL);<o:p></o:p> /* no need for synchronisation or preroll on the RTCP sink */<o:p></o:p> g_object_set (rtcpsink, "async", FALSE, "sync", FALSE, NULL);<o:p></o:p> <o:p> </o:p> rtcpsrc = gst_element_factory_make ("udpsrc", "rtcpsrc");<o:p></o:p> g_assert (rtcpsrc);<o:p></o:p> g_object_set (rtcpsrc, "port", 5007, NULL);<o:p></o:p> <o:p> </o:p> gst_bin_add_many (GST_BIN (pipeline), rtpsink, rtcpsink, rtcpsrc, NULL);<o:p></o:p> <o:p> </o:p> /* now link all to the rtpbin, start by getting an RTP sinkpad for session 0 */<o:p></o:p> sinkpad = gst_element_get_request_pad (rtpbin, "send_rtp_sink_0");<o:p></o:p> srcpad = gst_element_get_static_pad (pay, "src");<o:p></o:p> lres = gst_pad_link (srcpad, sinkpad);<o:p></o:p> g_assert (lres == GST_PAD_LINK_OK);<o:p></o:p> gst_object_unref (srcpad);<o:p></o:p> <o:p> </o:p> /* get the RTP srcpad that was created when we requested the sinkpad above and<o:p></o:p> * link it to the rtpsink sinkpad*/<o:p></o:p> srcpad = gst_element_get_static_pad (rtpbin, "send_rtp_src_0");<o:p></o:p> sinkpad = gst_element_get_static_pad (rtpsink, "sink");<o:p></o:p> lres = gst_pad_link (srcpad, sinkpad);<o:p></o:p> g_assert (lres == GST_PAD_LINK_OK);<o:p></o:p> gst_object_unref (srcpad);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> <o:p> </o:p> /* get an RTCP srcpad for sending RTCP to the receiver */<o:p></o:p> srcpad = gst_element_get_request_pad (rtpbin, "send_rtcp_src_0");<o:p></o:p> sinkpad = gst_element_get_static_pad (rtcpsink, "sink");<o:p></o:p> lres = gst_pad_link (srcpad, sinkpad);<o:p></o:p> g_assert (lres == GST_PAD_LINK_OK);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> <o:p> </o:p> /* we also want to receive RTCP, request an RTCP sinkpad for session 0 and<o:p></o:p> * link it to the srcpad of the udpsrc for RTCP */<o:p></o:p> srcpad = gst_element_get_static_pad (rtcpsrc, "src");<o:p></o:p> sinkpad = gst_element_get_request_pad (rtpbin, "recv_rtcp_sink_0");<o:p></o:p> lres = gst_pad_link (srcpad, sinkpad);<o:p></o:p> g_assert (lres == GST_PAD_LINK_OK);<o:p></o:p> gst_object_unref (srcpad);<o:p></o:p> <o:p> </o:p> g_print ("Starting playback until EOS\n");<o:p></o:p> <o:p> </o:p> /* start playing */<o:p></o:p> res = gst_element_set_state (pipeline, GST_STATE_PLAYING);<o:p></o:p> if (res == GST_STATE_CHANGE_FAILURE) {<o:p></o:p> g_print ("An error occured\n");<o:p></o:p> //return -1;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> GST_DEBUG_BIN_TO_DOT_FILE_WITH_TS(GST_BIN(pipeline), GST_DEBUG_GRAPH_SHOW_ALL, "RTP Server", NULL);<o:p></o:p> <o:p> </o:p> <o:p> </o:p> /* wait for EOS on the bus here */<o:p></o:p> /* get the bus from the pipeline */<o:p></o:p> bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));<o:p></o:p> <o:p> </o:p> /* setup callback for activity */<o:p></o:p> g_signal_emit_by_name (rtpbin, "get-internal-session", 0, &session);<o:p></o:p> g_signal_connect (session, "on-ssrc-active", (GCallback) on_ssrc_active_cb,<o:p></o:p> NULL);<o:p></o:p> <o:p> </o:p> /* we're going to loop here until we get the EOS message */<o:p></o:p> done = FALSE;<o:p></o:p> while (!done) {<o:p></o:p> GstMessage *message;<o:p></o:p> <o:p> </o:p> message = gst_bus_timed_pop (bus, -1);<o:p></o:p> <o:p> </o:p> switch (GST_MESSAGE_TYPE (message)) {<o:p></o:p> case GST_MESSAGE_ERROR:<o:p></o:p> {<o:p></o:p> GError *err;<o:p></o:p> gchar *debug;<o:p></o:p> <o:p></o:p> gst_message_parse_error (message, &err, &debug);<o:p></o:p> g_print ("Error: %s\n", err->message);<o:p></o:p> if (debug != NULL)<o:p></o:p> {<o:p></o:p> g_printerr ("Additional debug info:\n%s\n", debug);<o:p></o:p> }<o:p></o:p> g_error_free (err);<o:p></o:p> g_free (debug);<o:p></o:p> done = TRUE;<o:p></o:p> break;<o:p></o:p> }<o:p></o:p> case GST_MESSAGE_WARNING:<o:p></o:p> {<o:p></o:p> GError *err;<o:p></o:p> gchar *debug;<o:p></o:p> <o:p></o:p> gst_message_parse_warning (message, &err, &debug);<o:p></o:p> g_print ("Warning: %s\n", err->message);<o:p></o:p> if (debug != NULL)<o:p></o:p> {<o:p></o:p> g_printerr ("Additional debug info:\n%s\n", debug);<o:p></o:p> }<o:p></o:p> g_error_free (err);<o:p></o:p> g_free (debug);<o:p></o:p> break;<o:p></o:p> }<o:p></o:p> case GST_MESSAGE_EOS:<o:p></o:p> g_print ("got EOS!\n");<o:p></o:p> done = TRUE;<o:p></o:p> break;<o:p></o:p> default:<o:p></o:p> /* don't really care about other messages */<o:p></o:p> g_print("Unhandled %s Message.\n", GST_MESSAGE_TYPE_NAME(message));<o:p></o:p> break;<o:p></o:p> }<o:p></o:p> gst_message_unref (message);<o:p></o:p> }<o:p></o:p> <o:p> </o:p> gst_object_unref (bus);<o:p></o:p> <o:p> </o:p> g_print ("Ending playback and stopping pipeline\n");<o:p></o:p> <o:p> </o:p> /* stop the pipeline */<o:p></o:p> gst_element_set_state (pipeline, GST_STATE_NULL);<o:p></o:p> <o:p> </o:p> /* Unreffing the pipeline will clean up all its children too */<o:p></o:p> gst_object_unref (pipeline);<o:p></o:p> <o:p> </o:p> return 0;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> </div> </body> </html>