trying to follow wtay's advice

Original commit message from CVS:
trying to follow wtay's advice

diff --git a/gst/udp/gstudpsrc.c b/gst/udp/gstudpsrc.c
index 4917920..abb4f85 100644 (file)
--- a/gst/udp/gstudpsrc.c
+++ b/gst/udp/gstudpsrc.c
@@ -73,6 +73,7 @@ static void           gst_udpsrc_set_property         (GObject *object, guint prop_id,
                                                         const GValue *value, GParamSpec *pspec);
 static void            gst_udpsrc_get_property         (GObject *object, guint prop_id, 
                                                         GValue *value, GParamSpec *pspec);
+static void            gst_udpsrc_set_clock            (GstElement *element, GstClock *clock);
 
 static GstElementClass *parent_class = NULL;
 /*static guint gst_udpsrc_signals[LAST_SIGNAL] = { 0 }; */
@@ -123,8 +124,18 @@ gst_udpsrc_class_init (GstUDPSrc *klass)
   gobject_class->get_property = gst_udpsrc_get_property;
 
   gstelement_class->change_state = gst_udpsrc_change_state;
+  gstelement_class->set_clock = gst_udpsrc_set_clock;
 }
 
+static void
+gst_udpsrc_set_clock (GstElement *element, GstClock *clock)
+{
+  GstUDPSrc *udpsrc;
+             
+  udpsrc = GST_UDPSRC (element);
+
+  udpsrc->clock = clock;
+}
 
 static void
 gst_udpsrc_init (GstUDPSrc *udpsrc)
@@ -136,6 +147,9 @@ gst_udpsrc_init (GstUDPSrc *udpsrc)
 
   udpsrc->port = UDP_DEFAULT_PORT;
   udpsrc->control = CONTROL_UDP;
+  udpsrc->clock = NULL;
+
+  udpsrc->first_buf = TRUE;
 }
 
 static GstBuffer*
@@ -216,6 +230,28 @@ gst_udpsrc_get (GstPad *pad)
       GST_BUFFER_DATA (outbuf) = g_malloc (24000);
       GST_BUFFER_SIZE (outbuf) = 24000;
 
+      if (udpsrc->first_buf) {
+       if (udpsrc->clock) {
+          GstClockTime current_time;
+
+          current_time = gst_clock_get_time (udpsrc->clock);
+          
+          GST_BUFFER_TIMESTAMP (outbuf) = current_time;
+          GstEvent *discont;
+
+          discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME, 
+                               current_time, NULL);
+
+          gst_pad_push (udpsrc->srcpad, GST_BUFFER (discont));
+       }
+
+       udpsrc->first_buf = FALSE;
+      }
+      
+      else {
+       GST_BUFFER_TIMESTAMP (outbuf) = GST_CLOCK_TIME_NONE;
+      }
+
       numbytes = recvfrom (udpsrc->sock, GST_BUFFER_DATA (outbuf),
                  GST_BUFFER_SIZE (outbuf), 0, (struct sockaddr *)&tmpaddr, &len);
 
@@ -287,8 +323,8 @@ gst_udpsrc_init_receive (GstUDPSrc *src)
 {
   guint bc_val;
   bzero (&src->myaddr, sizeof (src->myaddr));
-  src->myaddr.sin_family = AF_INET;         /* host byte order */
-  src->myaddr.sin_port = htons (src->port);     /* short, network byte order */
+  src->myaddr.sin_family = AF_INET;           /* host byte order */
+  src->myaddr.sin_port = htons (src->port);   /* short, network byte order */
   src->myaddr.sin_addr.s_addr = INADDR_ANY;
 
   if ((src->sock = socket (AF_INET, SOCK_DGRAM, 0)) == -1) {

diff --git a/gst/udp/gstudpsrc.h b/gst/udp/gstudpsrc.h
index c912f76..6fd01cf 100644 (file)
--- a/gst/udp/gstudpsrc.h
+++ b/gst/udp/gstudpsrc.h
@@ -67,6 +67,9 @@ struct _GstUDPSrc {
   int control_sock;
   Gst_UDP_Control control;
   struct sockaddr_in myaddr;
+  GstClock *clock;
+
+  gboolean first_buf;
 };
 
 struct _GstUDPSrcClass {