5 files changed, 260 insertions, 191 deletions

diff --git a/gst/chart/gstchart.c b/gst/chart/gstchart.c
index 6b5eb456..d84eadcd 100644
--- a/gst/chart/gstchart.c
+++ b/gst/chart/gstchart.c
@@ -184,7 +184,7 @@ gst_chart_init (GstChart * chart)
 
   gst_pad_set_chain_function (chart->sinkpad, gst_chart_chain);
   gst_pad_set_link_function (chart->sinkpad, gst_chart_sinkconnect);
-  gst_pad_set_link_function (chart->sinkpad, gst_chart_srcconnect);
+  gst_pad_set_link_function (chart->srcpad, gst_chart_srcconnect);
 
   chart->next_time = 0;
 
@@ -229,13 +229,12 @@ gst_chart_srcconnect (GstPad * pad, const GstCaps * caps)
 
   structure = gst_caps_get_structure (caps, 0);
 
-  if (gst_structure_get_double (structure, "framerate", &chart->framerate)) {
-    chart->samples_between_frames = chart->samplerate / chart->framerate;
-  }
-
-  gst_structure_get_int (structure, "width", &chart->width);
-  gst_structure_get_int (structure, "height", &chart->height);
+  if (!gst_structure_get_double (structure, "framerate", &chart->framerate) ||
+      !gst_structure_get_int (structure, "width", &chart->width) ||
+      !gst_structure_get_int (structure, "height", &chart->height))
+    return GST_PAD_LINK_REFUSED;
 
+  chart->samples_between_frames = chart->samplerate / chart->framerate;
   GST_DEBUG ("CHART: new src caps: framerate %f, %dx%d",
       chart->framerate, chart->width, chart->height);
 
diff --git a/gst/smoothwave/Makefile.am b/gst/smoothwave/Makefile.am
index 6dd55d9c..d7312a4f 100644
--- a/gst/smoothwave/Makefile.am
+++ b/gst/smoothwave/Makefile.am
@@ -2,18 +2,17 @@
 plugin_LTLIBRARIES = libgstsmoothwave.la
 
 libgstsmoothwave_la_SOURCES = gstsmoothwave.c
-libgstsmoothwave_la_CFLAGS = $(GST_CFLAGS) $(GTK_CFLAGS)
-libgstsmoothwave_la_LIBADD = $(GTK_LIBS)
+libgstsmoothwave_la_CFLAGS = $(GST_CFLAGS) 
+libgstsmoothwave_la_LIBADD = 
 libgstsmoothwave_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
 
 noinst_HEADERS = gstsmoothwave.h
 
 if HAVE_GTK
 noinst_PROGRAMS = demo-osssrc
-endif
-
 demo_osssrc_SOURCES = demo-osssrc.c
 demo_osssrc_CFLAGS  = $(GST_CFLAGS) $(GTK_CFLAGS)
 demo_osssrc_LDFLAGS = $(GST_LIBS) $(GTK_LIBS)
+endif
 
 EXTRA_DIST = README
diff --git a/gst/smoothwave/demo-osssrc.c b/gst/smoothwave/demo-osssrc.c
index c39bc72c..6e5d2760 100644
--- a/gst/smoothwave/demo-osssrc.c
+++ b/gst/smoothwave/demo-osssrc.c
@@ -11,12 +11,9 @@ int
 main (int argc, char *argv[])
 {
   GstElement *bin;
-  GstElementFactory *srcfactory;
   GstElement *src;
-  GstElementFactory *wavefactory;
   GstElement *wave;
-  GtkWidget *wave_widget;
-  GtkWidget *appwindow;
+  GstElement *ximage;
 
   gst_init (&argc, &argv);
   gst_plugin_load ("libsmoothwave.so");
@@ -24,31 +21,19 @@ main (int argc, char *argv[])
 
   bin = gst_pipeline_new ("bin");
 
-  srcfactory = gst_element_factory_find ("sinesrc");
-  g_return_val_if_fail (srcfactory != NULL, -1);
-  wavefactory = gst_element_factory_find ("smoothwave");
-  g_return_val_if_fail (wavefactory != NULL, -1);
+  src = gst_element_factory_make ("sinesrc", "src");
+  wave = gst_element_factory_make ("smoothwave", "wave");
+  ximage = gst_element_factory_make ("ximagesink", "sink");
+  g_return_val_if_fail (src != NULL, -1);
+  g_return_val_if_fail (wave != NULL, -1);
+  g_return_val_if_fail (ximage != NULL, -1);
 
-  src = gst_element_factory_create (srcfactory, "src");
-  //g_object_set(G_OBJECT(src),"bytes_per_read",(gulong)2048,NULL);
-  wave = gst_element_factory_create (wavefactory, "wave");
-  g_object_set (G_OBJECT (wave), "width", 256, "height", 100, NULL);
 
+  gst_bin_add_many (GST_BIN (bin), src, wave, ximage, NULL);
+  g_return_val_if_fail (gst_element_link_many (src, wave, ximage,
+          NULL) != FALSE, -1);
 
-  gst_bin_add (GST_BIN (bin), GST_ELEMENT (src));
-  gst_bin_add (GST_BIN (bin), GST_ELEMENT (wave));
-
-  gst_pad_link (gst_element_get_pad (src, "src"),
-      gst_element_get_pad (wave, "sink"));
-
-  appwindow = gtk_window_new (GTK_WINDOW_TOPLEVEL);
-  g_object_get (G_OBJECT (wave), "widget", &wave_widget, NULL);
-  gtk_container_add (GTK_CONTAINER (appwindow), wave_widget);
-  gtk_widget_show_all (appwindow);
-
-  gst_element_set_state (GST_ELEMENT (bin), GST_STATE_READY);
   gst_element_set_state (GST_ELEMENT (bin), GST_STATE_PLAYING);
-
   g_idle_add (idle_func, bin);
 
   gtk_main ();
diff --git a/gst/smoothwave/gstsmoothwave.c b/gst/smoothwave/gstsmoothwave.c
index 7f1dc9cd..4fd998fd 100644
--- a/gst/smoothwave/gstsmoothwave.c
+++ b/gst/smoothwave/gstsmoothwave.c
@@ -23,6 +23,10 @@
 #endif
 #include <string.h>
 
+#include <gst/gst.h>
+#include <gst/video/video.h>
+#include <gst/audio/audio.h>
+
 #include "gstsmoothwave.h"
 
 static GstElementDetails gst_smoothwave_details =
@@ -39,29 +43,58 @@ enum
   LAST_SIGNAL
 };
 
-enum
-{
-  ARG_0,
-  ARG_WIDTH,
-  ARG_HEIGHT,
-  ARG_WIDGET
-};
-
 static void gst_smoothwave_base_init (gpointer g_class);
 static void gst_smoothwave_class_init (GstSmoothWaveClass * klass);
 static void gst_smoothwave_init (GstSmoothWave * smoothwave);
-
-static void gst_smoothwave_set_property (GObject * object, guint prop_id,
-    const GValue * value, GParamSpec * pspec);
-static void gst_smoothwave_get_property (GObject * object, guint prop_id,
-    GValue * value, GParamSpec * pspec);
-
+static void gst_smoothwave_dispose (GObject * object);
+static GstElementStateReturn gst_sw_change_state (GstElement * element);
 static void gst_smoothwave_chain (GstPad * pad, GstData * _data);
+static GstPadLinkReturn gst_sw_sinklink (GstPad * pad, const GstCaps * caps);
+static GstPadLinkReturn gst_sw_srclink (GstPad * pad, const GstCaps * caps);
 
 static GstElementClass *parent_class = NULL;
 
 /*static guint gst_smoothwave_signals[LAST_SIGNAL] = { 0 }; */
 
+#if G_BYTE_ORDER == G_BIG_ENDIAN
+static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS ("video/x-raw-rgb, "
+        "bpp = (int) 32, "
+        "depth = (int) 24, "
+        "endianness = (int) BIG_ENDIAN, "
+        "red_mask = (int) " GST_VIDEO_BYTE2_MASK_32 ", "
+        "green_mask = (int) " GST_VIDEO_BYTE3_MASK_32 ", "
+        "blue_mask = (int) " GST_VIDEO_BYTE4_MASK_32 ", "
+        "width = (int)512, "
+        "height = (int)256, " "framerate = " GST_VIDEO_FPS_RANGE)
+    );
+#else
+static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS ("video/x-raw-rgb, "
+        "bpp = (int) 32, "
+        "depth = (int) 24, "
+        "endianness = (int) BIG_ENDIAN, "
+        "red_mask = (int) " GST_VIDEO_BYTE3_MASK_32 ", "
+        "green_mask = (int) " GST_VIDEO_BYTE2_MASK_32 ", "
+        "blue_mask = (int) " GST_VIDEO_BYTE1_MASK_32 ", "
+        "width = (int)512, "
+        "height = (int)256, " "framerate = " GST_VIDEO_FPS_RANGE)
+    );
+#endif
+
+static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS ("audio/x-raw-int, "
+        "rate = (int) [ 1, MAX ], "
+        "channels = (int) [ 1, 2 ], "
+        "endianness = (int) BYTE_ORDER, "
+        "width = (int) 16, " "depth = (int) 16, " "signed = (boolean) true")
+    );
 
 GType
 gst_smoothwave_get_type (void)
@@ -100,56 +133,111 @@ static void
 gst_smoothwave_class_init (GstSmoothWaveClass * klass)
 {
   GObjectClass *gobject_class;
-  GstElementClass *gstelement_class;
+  GstElementClass *element_class;
 
   gobject_class = (GObjectClass *) klass;
-  gstelement_class = (GstElementClass *) klass;
+  element_class = (GstElementClass *) klass;
 
   parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
+  gobject_class->dispose = gst_smoothwave_dispose;
+  element_class->change_state = gst_sw_change_state;
 
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_WIDTH, g_param_spec_int ("width", "width", "width", G_MININT, G_MAXINT, 0, G_PARAM_READWRITE));  /* CHECKME */
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_HEIGHT, g_param_spec_int ("height", "height", "height", G_MININT, G_MAXINT, 0, G_PARAM_READWRITE));      /* CHECKME */
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_WIDGET, g_param_spec_object ("widget", "widget", "widget", GTK_TYPE_WIDGET, G_PARAM_READABLE));  /* CHECKME! */
-
-  gobject_class->set_property = gst_smoothwave_set_property;
-  gobject_class->get_property = gst_smoothwave_get_property;
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&src_template));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&sink_template));
 }
 
 static void
 gst_smoothwave_init (GstSmoothWave * smoothwave)
 {
   int i;
-  guint32 palette[256];
 
-  smoothwave->sinkpad = gst_pad_new ("sink", GST_PAD_SINK);
+  smoothwave->sinkpad =
+      gst_pad_new_from_template (gst_static_pad_template_get (&sink_template),
+      "sink");
+  smoothwave->srcpad =
+      gst_pad_new_from_template (gst_static_pad_template_get (&src_template),
+      "src");
   gst_element_add_pad (GST_ELEMENT (smoothwave), smoothwave->sinkpad);
   gst_pad_set_chain_function (smoothwave->sinkpad, gst_smoothwave_chain);
-  smoothwave->srcpad = gst_pad_new ("src", GST_PAD_SRC);
+  gst_pad_set_link_function (smoothwave->sinkpad, gst_sw_sinklink);
+
   gst_element_add_pad (GST_ELEMENT (smoothwave), smoothwave->srcpad);
+  gst_pad_set_link_function (smoothwave->srcpad, gst_sw_srclink);
+
+  GST_FLAG_SET (smoothwave, GST_ELEMENT_EVENT_AWARE);
+
+  smoothwave->adapter = gst_adapter_new ();
 
-/*  smoothwave->meta = NULL; */
   smoothwave->width = 512;
   smoothwave->height = 256;
 
-  gdk_rgb_init ();
-/*  gtk_widget_set_default_colormap (gdk_rgb_get_cmap()); */
-/*  gtk_widget_set_default_visual (gdk_rgb_get_visual()); */
+#define SPLIT_PT 96
 
-/*  GST_DEBUG ("creating palette"); */
-  for (i = 0; i < 256; i++)
-    palette[i] = (i << 16) || (i << 8);
-/*  GST_DEBUG ("creating cmap"); */
-  smoothwave->cmap = gdk_rgb_cmap_new (palette, 256);
-/*  GST_DEBUG ("created cmap"); */
-/*  gtk_widget_set_default_colormap (smoothwave->cmap); */
+  /* Fade in blue up to the split point */
+  for (i = 0; i < SPLIT_PT; i++)
+    smoothwave->palette[i] = (255 * i / SPLIT_PT);
 
-  smoothwave->image = gtk_drawing_area_new ();
-  gtk_drawing_area_size (GTK_DRAWING_AREA (smoothwave->image),
-      smoothwave->width, smoothwave->height);
-  gtk_widget_show (smoothwave->image);
+  /* After the split point, fade out blue and fade in red */
+  for (; i < 256; i++) {
+    gint val = (i - SPLIT_PT) * 255 / (255 - SPLIT_PT);
+
+    smoothwave->palette[i] = (255 - val) | (val << 16);
+  }
 
   smoothwave->imagebuffer = g_malloc (smoothwave->width * smoothwave->height);
   memset (smoothwave->imagebuffer, 0, smoothwave->width * smoothwave->height);
+
+  smoothwave->fps = 0;
+  smoothwave->sample_rate = 0;
+  smoothwave->audio_basetime = GST_CLOCK_TIME_NONE;
+  smoothwave->samples_consumed = 0;
+}
+
+static void
+gst_smoothwave_dispose (GObject * object)
+{
+  GstSmoothWave *sw = GST_SMOOTHWAVE (object);
+
+  if (sw->adapter != NULL) {
+    g_object_unref (sw->adapter);
+    sw->adapter = NULL;
+  }
+  G_OBJECT_CLASS (parent_class)->dispose (object);
+}
+
+static GstPadLinkReturn
+gst_sw_sinklink (GstPad * pad, const GstCaps * caps)
+{
+  GstSmoothWave *sw = GST_SMOOTHWAVE (GST_OBJECT_PARENT (pad));
+  GstStructure *structure;
+
+  g_return_val_if_fail (sw != NULL, GST_PAD_LINK_REFUSED);
+
+  structure = gst_caps_get_structure (caps, 0);
+  if (!gst_structure_get_int (structure, "channels", &sw->channels) ||
+      !gst_structure_get_int (structure, "rate", &sw->sample_rate))
+    return GST_PAD_LINK_REFUSED;
+
+  return GST_PAD_LINK_OK;
+}
+
+static GstPadLinkReturn
+gst_sw_srclink (GstPad * pad, const GstCaps * caps)
+{
+  GstSmoothWave *sw = GST_SMOOTHWAVE (GST_OBJECT_PARENT (pad));
+  GstStructure *structure;
+
+  g_return_val_if_fail (sw != NULL, GST_PAD_LINK_REFUSED);
+
+  structure = gst_caps_get_structure (caps, 0);
+  if (!gst_structure_get_int (structure, "width", &sw->width) ||
+      !gst_structure_get_int (structure, "height", &sw->height) ||
+      !gst_structure_get_double (structure, "framerate", &sw->fps))
+    return GST_PAD_LINK_REFUSED;
+
+  return GST_PAD_LINK_OK;
 }
 
 static void
@@ -157,146 +245,140 @@ gst_smoothwave_chain (GstPad * pad, GstData * _data)
 {
   GstBuffer *buf = GST_BUFFER (_data);
   GstSmoothWave *smoothwave;
-  gint16 *samples;
-  gint samplecount, i;
-  register guint32 *ptr;
+  guint32 bytesperread;
+  gint samples_per_frame;
   gint qheight;
 
   g_return_if_fail (pad != NULL);
   g_return_if_fail (GST_IS_PAD (pad));
   g_return_if_fail (buf != NULL);
-/*  g_return_if_fail(GST_IS_BUFFER(buf)); */
 
   smoothwave = GST_SMOOTHWAVE (GST_OBJECT_PARENT (pad));
 
-  /* first deal with audio metadata */
-#if 0
-  if (buf->meta) {
-    if (smoothwave->meta != NULL) {
-      /* FIXME: need to unref the old metadata so it goes away */
+  if (GST_IS_EVENT (_data)) {
+    GstEvent *event = GST_EVENT (_data);
+
+    switch (GST_EVENT_TYPE (event)) {
+      case GST_EVENT_DISCONTINUOUS:
+      {
+        gint64 value = 0;
+
+        gst_event_discont_get_value (event, GST_FORMAT_TIME, &value);
+        gst_adapter_clear (smoothwave->adapter);
+        smoothwave->audio_basetime = value;
+        smoothwave->samples_consumed = 0;
+      }
+      default:
+        gst_pad_event_default (pad, event);
+        break;
     }
-    /* we just make a copy of the pointer */
-    smoothwave->meta = (MetaAudioRaw *) (buf->meta);
-    /* FIXME: now we have to ref the metadata so it doesn't go away */
+    return;
   }
-#endif
 
-/*  g_return_if_fail(smoothwave->meta != NULL); */
-
-  samples = (gint16 *) GST_BUFFER_DATA (buf);
-/*  samplecount = buf->datasize / (smoothwave->meta->channels * sizeof(gint16)); */
-  samplecount = GST_BUFFER_SIZE (buf) / (2 * sizeof (gint16));
-
-  qheight = smoothwave->height / 4;
-
-/*  GST_DEBUG ("traversing %d",smoothwave->width); */
-  for (i = 0; i < MAX (smoothwave->width, samplecount); i++) {
-    gint16 y1 = (gint32) (samples[i * 2] * qheight) / 32768 + qheight;
-    gint16 y2 = (gint32) (samples[(i * 2) + 1] * qheight) / 32768 +
-        (qheight * 3);
-    smoothwave->imagebuffer[y1 * smoothwave->width + i] = 0xff;
-    smoothwave->imagebuffer[y2 * smoothwave->width + i] = 0xff;
-/*    smoothwave->imagebuffer[i+(smoothwave->width*5)] = i; */
+  if (!GST_PAD_IS_USABLE (smoothwave->srcpad)) {
+    gst_buffer_unref (buf);
+    return;
   }
-
-  ptr = (guint32 *) smoothwave->imagebuffer;
-  for (i = 0; i < (smoothwave->width * smoothwave->height) / 4; i++) {
-    if (*ptr) {
-      *ptr -= ((*ptr & 0xf0f0f0f0ul) >> 4) + ((*ptr & 0xe0e0e0e0ul) >> 5);
-      ptr++;
+  if (smoothwave->audio_basetime == GST_CLOCK_TIME_NONE)
+    smoothwave->audio_basetime = GST_BUFFER_TIMESTAMP (buf);
+  if (smoothwave->audio_basetime == GST_CLOCK_TIME_NONE)
+    smoothwave->audio_basetime = 0;
+
+  bytesperread = smoothwave->width * smoothwave->channels * sizeof (gint16);
+  samples_per_frame = smoothwave->sample_rate / smoothwave->fps;
+
+  gst_adapter_push (smoothwave->adapter, buf);
+  while (gst_adapter_available (smoothwave->adapter) > MAX (bytesperread,
+          samples_per_frame * smoothwave->channels * sizeof (gint16))) {
+    const gint16 *samples =
+        (const guint16 *) gst_adapter_peek (smoothwave->adapter, bytesperread);
+    register guint32 *ptr;
+    gint i;
+
+    /* First draw the new waveform */
+    if (smoothwave->channels == 2) {
+      qheight = smoothwave->height / 4;
+      for (i = 0; i < smoothwave->width; i++) {
+        gint16 y1 = (gint32) (samples[i * 2] * qheight) / 32768 + qheight;
+        gint16 y2 = (gint32) (samples[(i * 2) + 1] * qheight) / 32768 +
+            (qheight + smoothwave->height / 2);
+        smoothwave->imagebuffer[y1 * smoothwave->width + i] = 0xff;
+        smoothwave->imagebuffer[y2 * smoothwave->width + i] = 0xff;
+      }
     } else {
-      ptr++;
-    }
-  }
+      qheight = smoothwave->height / 2;
+      for (i = 0; i < smoothwave->width; i++) {
+        gint16 y1 = (gint32) (samples[i] * qheight) / 32768 + qheight;
 
-/*  GST_DEBUG ("drawing"); */
-/*  GST_DEBUG ("gdk_draw_indexed_image(%p,%p,%d,%d,%d,%d,%s,%p,%d,%p);",
-        smoothwave->image->window,
-	smoothwave->image->style->fg_gc[GTK_STATE_NORMAL],
-	0,0,smoothwave->width,smoothwave->height,
-	"GDK_RGB_DITHER_NORMAL",
-	smoothwave->imagebuffer,smoothwave->width,
-	smoothwave->cmap);*/
-/*  gdk_draw_indexed_image(smoothwave->image->window,
-	smoothwave->image->style->fg_gc[GTK_STATE_NORMAL],
-	0,0,smoothwave->width,smoothwave->height,
-	GDK_RGB_DITHER_NONE,
-	smoothwave->imagebuffer,smoothwave->width,
-	smoothwave->cmap);*/
-  gdk_draw_gray_image (smoothwave->image->window,
-      smoothwave->image->style->fg_gc[GTK_STATE_NORMAL],
-      0, 0, smoothwave->width, smoothwave->height,
-      GDK_RGB_DITHER_NORMAL, smoothwave->imagebuffer, smoothwave->width);
-
-/*  gst_trace_add_entry(NULL,0,buf,"smoothwave: calculated smoothwave"); */
-
-  gst_buffer_unref (buf);
-}
+        smoothwave->imagebuffer[y1 * smoothwave->width + i] = 0xff;
+      }
+    }
 
-static void
-gst_smoothwave_set_property (GObject * object, guint prop_id,
-    const GValue * value, GParamSpec * pspec)
-{
-  GstSmoothWave *smoothwave;
+    /* Now fade stuff out */
+    ptr = (guint32 *) smoothwave->imagebuffer;
+    for (i = 0; i < (smoothwave->width * smoothwave->height) / 4; i++) {
+      if (*ptr)
+        *ptr -= ((*ptr & 0xf0f0f0f0ul) >> 4) + ((*ptr & 0xe0e0e0e0ul) >> 5);
+      ptr++;
+    }
 
-  /* it's not null if we got it, but it might not be ours */
-  g_return_if_fail (GST_IS_SMOOTHWAVE (object));
-  smoothwave = GST_SMOOTHWAVE (object);
-
-  switch (prop_id) {
-    case ARG_WIDTH:
-      smoothwave->width = g_value_get_int (value);
-      gtk_drawing_area_size (GTK_DRAWING_AREA (smoothwave->image),
-          smoothwave->width, smoothwave->height);
-      gtk_widget_set_usize (GTK_WIDGET (smoothwave->image),
-          smoothwave->width, smoothwave->height);
-      break;
-    case ARG_HEIGHT:
-      smoothwave->height = g_value_get_int (value);
-      gtk_drawing_area_size (GTK_DRAWING_AREA (smoothwave->image),
-          smoothwave->width, smoothwave->height);
-      gtk_widget_set_usize (GTK_WIDGET (smoothwave->image),
-          smoothwave->width, smoothwave->height);
-      break;
-    default:
-      break;
+    {
+      guint32 *out;
+      guchar *in;
+      GstBuffer *bufout;
+
+      bufout =
+          gst_buffer_new_and_alloc (smoothwave->width * smoothwave->height * 4);
+
+      GST_BUFFER_TIMESTAMP (bufout) =
+          smoothwave->audio_basetime +
+          (GST_SECOND * smoothwave->samples_consumed / smoothwave->sample_rate);
+      GST_BUFFER_DURATION (bufout) = GST_SECOND / smoothwave->fps;
+      out = (guint32 *) GST_BUFFER_DATA (bufout);
+      in = smoothwave->imagebuffer;
+
+      for (i = 0; i < (smoothwave->width * smoothwave->height); i++) {
+        // guchar t = *in++;
+        *out++ = smoothwave->palette[*in++];    // t | (t << 8) | (t << 16) | (t << 24);
+      }
+      gst_pad_push (smoothwave->srcpad, GST_DATA (bufout));
+    }
+    smoothwave->samples_consumed += samples_per_frame;
+    gst_adapter_flush (smoothwave->adapter,
+        samples_per_frame * smoothwave->channels * sizeof (gint16));
   }
 }
 
-static void
-gst_smoothwave_get_property (GObject * object, guint prop_id, GValue * value,
-    GParamSpec * pspec)
+static GstElementStateReturn
+gst_sw_change_state (GstElement * element)
 {
-  GstSmoothWave *smoothwave;
+  GstSmoothWave *sw = GST_SMOOTHWAVE (element);
 
-  /* it's not null if we got it, but it might not be ours */
-  smoothwave = GST_SMOOTHWAVE (object);
-
-  switch (prop_id) {
-    case ARG_WIDTH:{
-      g_value_set_int (value, smoothwave->width);
+  switch (GST_STATE_TRANSITION (element)) {
+    case GST_STATE_NULL_TO_READY:
       break;
-    }
-    case ARG_HEIGHT:{
-      g_value_set_int (value, smoothwave->height);
+    case GST_STATE_READY_TO_NULL:
       break;
-    }
-    case ARG_WIDGET:{
-      g_value_set_object (value, smoothwave->image);
+    case GST_STATE_READY_TO_PAUSED:
+      sw->audio_basetime = GST_CLOCK_TIME_NONE;
+      gst_adapter_clear (sw->adapter);
       break;
-    }
-    default:{
-      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+    case GST_STATE_PAUSED_TO_READY:
+      sw->channels = 0;
+      break;
+    default:
       break;
-    }
   }
-}
-
 
+  return GST_ELEMENT_CLASS (parent_class)->change_state (element);
+}
 
 static gboolean
 plugin_init (GstPlugin * plugin)
 {
+  if (!gst_library_load ("gstbytestream"))
+    return FALSE;
+
   if (!gst_element_register (plugin, "smoothwave", GST_RANK_NONE,
           GST_TYPE_SMOOTHWAVE))
     return FALSE;
diff --git a/gst/smoothwave/gstsmoothwave.h b/gst/smoothwave/gstsmoothwave.h
index 87165131..a0dfe402 100644
--- a/gst/smoothwave/gstsmoothwave.h
+++ b/gst/smoothwave/gstsmoothwave.h
@@ -23,13 +23,12 @@
 
 
 #include <gst/gst.h>
-#include <gtk/gtk.h>
+#include <gst/bytestream/adapter.h>
 
 #ifdef __cplusplus
 extern "C" {
 #endif /* __cplusplus */
 
-
 #define GST_TYPE_SMOOTHWAVE \
   (gst_smoothwave_get_type())
 #define GST_SMOOTHWAVE(obj) \
@@ -48,12 +47,17 @@ struct _GstSmoothWave {
   GstElement element;
 
   GstPad *sinkpad,*srcpad;
+  GstAdapter *adapter;
 
-  gint width,height;
-
-  GdkRgbCmap *cmap;
-  GtkWidget *image;
   guchar *imagebuffer;
+  GstClockTime audio_basetime;
+  guint64 samples_consumed;
+
+  gint    sample_rate;
+  gint    width,height;
+  gdouble fps;
+  gint    channels;
+  guint32 palette[256];
 };
 
 struct _GstSmoothWaveClass {