/* GStreamer * Copyright (C) <2005> Wim Taymans * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. */ /** * SECTION:element-udpsink * @see_also: udpsrc, multifdsink * * udpsink is a network sink that sends UDP packets to the network. * It can be combined with RTP payloaders to implement RTP streaming. * * * Examples * |[ * gst-launch -v audiotestsrc ! udpsink * ]| * */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #include "gstudpsink.h" #include #include #ifdef HAVE_UNISTD_H #include #endif #include #include #define UDP_DEFAULT_HOST "localhost" #define UDP_DEFAULT_PORT 4951 /* UDPSink signals and args */ enum { /* FILL ME */ LAST_SIGNAL }; enum { PROP_0, PROP_HOST, PROP_PORT, PROP_URI, /* FILL ME */ }; static void gst_udpsink_base_init (gpointer g_class); static void gst_udpsink_class_init (GstUDPSink * klass); static void gst_udpsink_init (GstUDPSink * udpsink); static void gst_udpsink_finalize (GstUDPSink * udpsink); static void gst_udpsink_uri_handler_init (gpointer g_iface, gpointer iface_data); static void gst_udpsink_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec); static void gst_udpsink_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec); static GstElementClass *parent_class = NULL; /*static guint gst_udpsink_signals[LAST_SIGNAL] = { 0 }; */ GType gst_udpsink_get_type (void) { static GType udpsink_type = 0; if (!udpsink_type) { static const GTypeInfo udpsink_info = { sizeof (GstUDPSinkClass), gst_udpsink_base_init, NULL, (GClassInitFunc) gst_udpsink_class_init, NULL, NULL, sizeof (GstUDPSink), 0, (GInstanceInitFunc) gst_udpsink_init, NULL }; static const GInterfaceInfo urihandler_info = { gst_udpsink_uri_handler_init, NULL, NULL }; udpsink_type = g_type_register_static (GST_TYPE_MULTIUDPSINK, "GstUDPSink", &udpsink_info, 0); g_type_add_interface_static (udpsink_type, GST_TYPE_URI_HANDLER, &urihandler_info); } return udpsink_type; } static void gst_udpsink_base_init (gpointer g_class) { GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); gst_element_class_set_details_simple (element_class, "UDP packet sender", "Sink/Network", "Send data over the network via UDP", "Wim Taymans "); } static void gst_udpsink_class_init (GstUDPSink * klass) { GObjectClass *gobject_class; gobject_class = (GObjectClass *) klass; parent_class = g_type_class_peek_parent (klass); gobject_class->set_property = gst_udpsink_set_property; gobject_class->get_property = gst_udpsink_get_property; gobject_class->finalize = (GObjectFinalizeFunc) gst_udpsink_finalize; g_object_class_install_property (G_OBJECT_CLASS (klass), PROP_HOST, g_param_spec_string ("host", "host", "The host/IP/Multicast group to send the packets to", UDP_DEFAULT_HOST, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); g_object_class_install_property (G_OBJECT_CLASS (klass), PROP_PORT, g_param_spec_int ("port", "port", "The port to send the packets to", 0, 65535, UDP_DEFAULT_PORT, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); } static void gst_udpsink_init (GstUDPSink * udpsink) { gst_udp_uri_init (&udpsink->uri, UDP_DEFAULT_HOST, UDP_DEFAULT_PORT); gst_multiudpsink_add (GST_MULTIUDPSINK (udpsink), udpsink->uri.host, udpsink->uri.port); } static void gst_udpsink_finalize (GstUDPSink * udpsink) { gst_udp_uri_free (&udpsink->uri); g_free (udpsink->uristr); G_OBJECT_CLASS (parent_class)->finalize ((GObject *) udpsink); } static gboolean gst_udpsink_set_uri (GstUDPSink * sink, const gchar * uri) { gst_multiudpsink_remove (GST_MULTIUDPSINK (sink), sink->uri.host, sink->uri.port); if (gst_udp_parse_uri (uri, &sink->uri) < 0) goto wrong_uri; gst_multiudpsink_add (GST_MULTIUDPSINK (sink), sink->uri.host, sink->uri.port); return TRUE; /* ERRORS */ wrong_uri: { GST_ELEMENT_ERROR (sink, RESOURCE, READ, (NULL), ("error parsing uri %s", uri)); return FALSE; } } static void gst_udpsink_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec) { GstUDPSink *udpsink; udpsink = GST_UDPSINK (object); /* remove old host */ gst_multiudpsink_remove (GST_MULTIUDPSINK (udpsink), udpsink->uri.host, udpsink->uri.port); switch (prop_id) { case PROP_HOST: { const gchar *host; host = g_value_get_string (value); if (host) gst_udp_uri_update (&udpsink->uri, host, -1); else gst_udp_uri_update (&udpsink->uri, UDP_DEFAULT_HOST, -1); break; } case PROP_PORT: gst_udp_uri_update (&udpsink->uri, NULL, g_value_get_int (value)); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } /* add new host */ gst_multiudpsink_add (GST_MULTIUDPSINK (udpsink), udpsink->uri.host, udpsink->uri.port); } static void gst_udpsink_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec) { GstUDPSink *udpsink; udpsink = GST_UDPSINK (object); switch (prop_id) { case PROP_HOST: g_value_set_string (value, udpsink->uri.host); break; case PROP_PORT: g_value_set_int (value, udpsink->uri.port); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } /*** GSTURIHANDLER INTERFACE *************************************************/ static GstURIType gst_udpsink_uri_get_type (void) { return GST_URI_SINK; } static gchar ** gst_udpsink_uri_get_protocols (void) { static gchar *protocols[] = { (char *) "udp", NULL }; return protocols; } static const gchar * gst_udpsink_uri_get_uri (GstURIHandler * handler) { GstUDPSink *sink = GST_UDPSINK (handler); g_free (sink->uristr); sink->uristr = gst_udp_uri_string (&sink->uri); return sink->uristr; } static gboolean gst_udpsink_uri_set_uri (GstURIHandler * handler, const gchar * uri) { gboolean ret; GstUDPSink *sink = GST_UDPSINK (handler); ret = gst_udpsink_set_uri (sink, uri); return ret; } static void gst_udpsink_uri_handler_init (gpointer g_iface, gpointer iface_data) { GstURIHandlerInterface *iface = (GstURIHandlerInterface *) g_iface; iface->get_type = gst_udpsink_uri_get_type; iface->get_protocols = gst_udpsink_uri_get_protocols; iface->get_uri = gst_udpsink_uri_get_uri; iface->set_uri = gst_udpsink_uri_set_uri; }