gst/udp/gstmultiudpsink.h

   1 /* GStreamer
   2  * Copyright (C) <2005> Wim Taymans <wim@fluendo.com>
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Library General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Library General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Library General Public
  15  * License along with this library; if not, write to the
  16  * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
  17  * Boston, MA 02110-1301, USA.
  18  */
  19
  20 #ifndef __GST_MULTIUDPSINK_H__
  21 #define __GST_MULTIUDPSINK_H__
  22
  23 #include <gst/gst.h>
  24 #include <gst/base/gstbasesink.h>
  25 #include <gio/gio.h>
  26
  27 G_BEGIN_DECLS
  28
  29 #include "gstudpnetutils.h"
  30
  31 #define GST_TYPE_MULTIUDPSINK            (gst_multiudpsink_get_type())
  32 #define GST_MULTIUDPSINK(obj)            (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_MULTIUDPSINK,GstMultiUDPSink))
  33 #define GST_MULTIUDPSINK_CLASS(klass)    (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_MULTIUDPSINK,GstMultiUDPSinkClass))
  34 #define GST_IS_MULTIUDPSINK(obj)         (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MULTIUDPSINK))
  35 #define GST_IS_MULTIUDPSINK_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MULTIUDPSINK))
  36 #define GST_MULTIUDPSINK_CAST(obj)       ((GstMultiUDPSink*)(obj))
  37
  38 typedef struct _GstMultiUDPSink GstMultiUDPSink;
  39 typedef struct _GstMultiUDPSinkClass GstMultiUDPSinkClass;
  40
  41 #if GLIB_CHECK_VERSION (2, 43, 2)
  42 #define HAVE_G_SOCKET_SEND_MESSAGES
  43 #endif
  44
  45 #ifndef HAVE_G_SOCKET_SEND_MESSAGES
  46 /* same as GOutputMessage used for g_socket_send_messages() */
  47 typedef struct {
  48   /*< private >*/
  49   GSocketAddress         *address;
  50
  51   GOutputVector          *vectors;
  52   guint                   num_vectors;
  53
  54   guint                   bytes_sent;
  55
  56   GSocketControlMessage **control_messages;
  57   guint                   num_control_messages;
  58 } GstOutputMessage;
  59 #else
  60 typedef GOutputMessage GstOutputMessage;
  61 #endif /* HAVE_G_SOCKET_SEND_MESSAGES*/
  62
  63 typedef struct {
  64   gint ref_count;         /* for memory management */
  65   gint add_count;         /* how often this address has been added */
  66
  67   GSocketAddress *addr;
  68   gchar *host;
  69   gint port;
  70
  71   /* Per-client stats */
  72   guint64 bytes_sent;
  73   guint64 packets_sent;
  74   guint64 connect_time;
  75   guint64 disconnect_time;
  76 } GstUDPClient;
  77
  78 /* sends udp packets to multiple host/port pairs.
  79  */
  80 struct _GstMultiUDPSink {
  81   GstBaseSink parent;
  82
  83   GSocket       *used_socket, *used_socket_v6;
  84   GCancellable  *cancellable;
  85
  86   /* client management */
  87   GMutex         client_lock;
  88   GList         *clients;
  89   guint          num_v4_unique;  /* number IPv4 clients (excluding duplicates) */
  90   guint          num_v4_all;     /* number IPv4 clients (including duplicates) */
  91   guint          num_v6_unique;  /* number IPv6 clients (excluding duplicates) */
  92   guint          num_v6_all;     /* number IPv6 clients (including duplicates) */
  93
  94   /* pre-allocated scrap space for render function */
  95   GOutputVector *vec;
  96   GstMapInfo *map;
  97
  98   /* properties */
  99   guint64        bytes_to_serve;
 100   guint64        bytes_served;
 101   GSocket       *socket, *socket_v6;
 102   gboolean       close_socket;
 103
 104   gboolean       external_socket;
 105
 106   gboolean       auto_multicast;
 107   gchar         *multi_iface;
 108   gint           ttl;
 109   gint           ttl_mc;
 110   gboolean       loop;
 111   gboolean       force_ipv4;
 112   gint           qos_dscp;
 113
 114   gboolean       send_duplicates;
 115   gint           buffer_size;
 116   gchar         *bind_address;
 117   gint           bind_port;
 118 };
 119
 120 struct _GstMultiUDPSinkClass {
 121   GstBaseSinkClass parent_class;
 122
 123   /* element methods */
 124   void          (*add)          (GstMultiUDPSink *sink, const gchar *host, gint port);
 125   void          (*remove)       (GstMultiUDPSink *sink, const gchar *host, gint port);
 126   void          (*clear)        (GstMultiUDPSink *sink);
 127   GstStructure* (*get_stats)    (GstMultiUDPSink *sink, const gchar *host, gint port);
 128
 129   /* signals */
 130   void          (*client_added) (GstElement *element, const gchar *host, gint port);
 131   void          (*client_removed) (GstElement *element, const gchar *host, gint port);
 132 };
 133
 134 GType gst_multiudpsink_get_type(void);
 135
 136 void            gst_multiudpsink_add            (GstMultiUDPSink *sink, const gchar *host, gint port);
 137 void            gst_multiudpsink_remove         (GstMultiUDPSink *sink, const gchar *host, gint port);
 138 void            gst_multiudpsink_clear          (GstMultiUDPSink *sink);
 139 GstStructure*   gst_multiudpsink_get_stats      (GstMultiUDPSink *sink, const gchar *host, gint port);
 140
 141 G_END_DECLS
 142
 143 #endif /* __GST_MULTIUDPSINK_H__ */