Port librfb to 0.10 (#376106).

Original commit message from CVS:
Patch by: Andre Moreira Magalhaes <andrunko@gmail.com>
* configure.ac:
* gst/librfb/Makefile.am:
* gst/librfb/gstrfbsrc.c:
* gst/librfb/rfb.c:
* gst/librfb/rfb.h:
* gst/librfb/rfbbuffer.c:
* gst/librfb/rfbbuffer.h:
* gst/librfb/rfbbytestream.c:
* gst/librfb/rfbbytestream.h:
* gst/librfb/rfbcontext.h:
* gst/librfb/rfbdecoder.c:
* gst/librfb/rfbdecoder.h:
* gst/librfb/rfbutil.h:
Port librfb to 0.10 (#376106).

1 files changed, 204 insertions, 376 deletions

diff --git a/gst/librfb/gstrfbsrc.c b/gst/librfb/gstrfbsrc.c
index 85dfe356..66214f1a 100644
--- a/gst/librfb/gstrfbsrc.c
+++ b/gst/librfb/gstrfbsrc.c
@@ -1,4 +1,5 @@
 /* GStreamer
+ * Copyright (C) <2006> Andre Moreira Magalhaes <andre.magalhaes@indt.org.br>
  * Copyright (C) <2004> David A. Schleef <ds@schleef.org>
  * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
  *
@@ -22,370 +23,302 @@
 #include "config.h"
 #endif
 
-#include <gst/gst.h>
+#include "gstrfbsrc.h"
+
 #include <gst/video/video.h>
 
 #include <string.h>
 #include <stdlib.h>
 
-#include <librfb/rfb.h>
-
-
-#define GST_TYPE_RFBSRC \
-  (gst_rfbsrc_get_type())
-#define GST_RFBSRC(obj) \
-  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_RFBSRC,GstRfbsrc))
-#define GST_RFBSRC_CLASS(klass) \
-  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RFBSRC,GstRfbsrc))
-#define GST_IS_RFBSRC(obj) \
-  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RFBSRC))
-#define GST_IS_RFBSRC_CLASS(klass) \
-  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RFBSRC))
-
-typedef struct _GstRfbsrc GstRfbsrc;
-typedef struct _GstRfbsrcClass GstRfbsrcClass;
-
-struct _GstRfbsrc
-{
-  GstElement element;
-
-  GstPad *srcpad;
-
-  RfbDecoder *decoder;
-
-  char *server;
-  int port;
-
-  guint8 *frame;
-  gboolean go;
-  gboolean inter;
-
-  unsigned int button_mask;
-
-  double framerate;
-};
-
-struct _GstRfbsrcClass
-{
-  GstElementClass parent_class;
-};
-
-GType gst_rfbsrc_get_type (void);
-
-
-static const GstElementDetails rfbsrc_details =
-GST_ELEMENT_DETAILS ("Video test source",
-    "Source/Video",
-    "Creates a test video stream",
-    "David A. Schleef <ds@schleef.org>");
-
-/* GstRfbsrc signals and args */
-enum
-{
-  /* FILL ME */
-  LAST_SIGNAL
-};
-
 enum
 {
   ARG_0,
-  ARG_SERVER,
+  ARG_HOST,
   ARG_PORT,
-  /* FILL ME */
 };
 
-static void gst_rfbsrc_base_init (gpointer g_class);
-static void gst_rfbsrc_class_init (GstRfbsrcClass * klass);
-static void gst_rfbsrc_init (GstRfbsrc * rfbsrc);
-static GstStateChangeReturn gst_rfbsrc_change_state (GstElement * element);
-
-static void gst_rfbsrc_set_property (GObject * object, guint prop_id,
-    const GValue * value, GParamSpec * pspec);
-static void gst_rfbsrc_get_property (GObject * object, guint prop_id,
-    GValue * value, GParamSpec * pspec);
-
-static GstData *gst_rfbsrc_get (GstPad * pad);
-
-static const GstQueryType *gst_rfbsrc_get_query_types (GstPad * pad);
-static gboolean gst_rfbsrc_src_query (GstPad * pad,
-    GstQueryType type, GstFormat * format, gint64 * value);
-static void gst_rfbsrc_paint_rect (RfbDecoder * decoder, int x, int y,
-    int w, int h, guint8 * data);
-static gboolean gst_rfbsrc_handle_src_event (GstPad * pad, GstEvent * event);
-
-static GstCaps *gst_rfbsrc_getcaps (GstPad * pad);
-static GstPadLinkReturn gst_rfbsrc_link (GstPad * pad, const GstCaps * caps);
-static GstCaps *gst_rfbsrc_fixate (GstPad * pad, const GstCaps * caps);
+#define RGB332_R(x)  ((((x)&0x07) * 0x124)>>3)
+#define RGB332_G(x)  ((((x)&0x38) * 0x124)>>6)
+#define RGB332_B(x)  ((((x)&0xc0) * 0x149)>>8)
 
-static GstElementClass *parent_class = NULL;
+GST_DEBUG_CATEGORY_STATIC (rfbsrc_debug);
+#define GST_CAT_DEFAULT rfbsrc_debug
 
+static const GstElementDetails gst_rfb_src_details =
+GST_ELEMENT_DETAILS ("Rfb source",
+    "Source/Video",
+    "Creates a rfb video stream",
+    "David A. Schleef <ds@schleef.org>, "
+    "Andre Moreira Magalhaes <andre.magalhaes@indt.org.br");
 
-static GstStaticPadTemplate gst_rfbsrc_src_template =
+static GstStaticPadTemplate gst_rfb_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, "
+        "endianness = (int) 4321, "
         "red_mask = (int) 0x0000ff00, "
         "green_mask = (int) 0x00ff0000, "
         "blue_mask = (int) 0xff000000, "
-        "width = [ 16, 4096 ], "
-        "height = [ 16, 4096 ], " "framerate = [ 1.0, 60.0] ")
+        "width = (int) [ 16, 4096 ], "
+        "height = (int) [ 16, 4096 ], " "framerate = (fraction) 30/1")
     );
 
-GType
-gst_rfbsrc_get_type (void)
-{
-  static GType rfbsrc_type = 0;
-
-  if (!rfbsrc_type) {
-    static const GTypeInfo rfbsrc_info = {
-      sizeof (GstRfbsrcClass),
-      gst_rfbsrc_base_init,
-      NULL,
-      (GClassInitFunc) gst_rfbsrc_class_init,
-      NULL,
-      NULL,
-      sizeof (GstRfbsrc),
-      0,
-      (GInstanceInitFunc) gst_rfbsrc_init,
-    };
-
-    rfbsrc_type =
-        g_type_register_static (GST_TYPE_ELEMENT, "GstRfbsrc", &rfbsrc_info, 0);
-  }
-  return rfbsrc_type;
-}
+static void gst_rfb_src_base_init (gpointer g_class);
+static void gst_rfb_src_class_init (GstRfbSrcClass * klass);
+static void gst_rfb_src_dispose (GObject * object);
+static void gst_rfb_src_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_rfb_src_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static gboolean gst_rfb_src_start (GstBaseSrc * bsrc);
+static gboolean gst_rfb_src_stop (GstBaseSrc * bsrc);
+static gboolean gst_rfb_src_event (GstBaseSrc * bsrc, GstEvent * event);
+static GstFlowReturn gst_rfb_src_create (GstPushSrc * psrc,
+    GstBuffer ** outbuf);
+static void gst_rfb_src_paint_rect (RfbDecoder * decoder, gint x, gint y,
+    gint w, gint h, guint8 * data);
+
+GST_BOILERPLATE (GstRfbSrc, gst_rfb_src, GstPushSrc, GST_TYPE_PUSH_SRC);
 
 static void
-gst_rfbsrc_base_init (gpointer g_class)
+gst_rfb_src_base_init (gpointer g_class)
 {
   GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
 
-  gst_element_class_set_details (element_class, &rfbsrc_details);
-
   gst_element_class_add_pad_template (element_class,
-      gst_static_pad_template_get (&gst_rfbsrc_src_template));
+      gst_static_pad_template_get (&gst_rfb_src_template));
+
+  gst_element_class_set_details (element_class, &gst_rfb_src_details);
 }
 
 static void
-gst_rfbsrc_class_init (GstRfbsrcClass * klass)
+gst_rfb_src_class_init (GstRfbSrcClass * klass)
 {
   GObjectClass *gobject_class;
-  GstElementClass *gstelement_class;
+  GstBaseSrcClass *gstbasesrc_class;
+  GstPushSrcClass *gstpushsrc_class;
 
   gobject_class = (GObjectClass *) klass;
-  gstelement_class = (GstElementClass *) klass;
-
-#if 0
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_WIDTH,
-      g_param_spec_int ("width", "width", "Default width",
-          1, G_MAXINT, 320, G_PARAM_READWRITE));
-#endif
+  gstbasesrc_class = (GstBaseSrcClass *) klass;
+  gstpushsrc_class = (GstPushSrcClass *) klass;
 
-  parent_class = g_type_class_peek_parent (klass);
+  gobject_class->dispose = gst_rfb_src_dispose;
+  gobject_class->set_property = gst_rfb_src_set_property;
+  gobject_class->get_property = gst_rfb_src_get_property;
 
-  g_object_class_install_property (gobject_class, ARG_SERVER,
-      g_param_spec_string ("server", "Server", "Server",
+  g_object_class_install_property (gobject_class, ARG_HOST,
+      g_param_spec_string ("host", "Host to connect to", "Host to connect to",
           "127.0.0.1", G_PARAM_READWRITE));
   g_object_class_install_property (gobject_class, ARG_PORT,
       g_param_spec_int ("port", "Port", "Port",
           1, 65535, 5900, G_PARAM_READWRITE));
 
-  gobject_class->set_property = gst_rfbsrc_set_property;
-  gobject_class->get_property = gst_rfbsrc_get_property;
+  gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_rfb_src_start);
+  gstbasesrc_class->stop = GST_DEBUG_FUNCPTR (gst_rfb_src_stop);
+  gstbasesrc_class->event = GST_DEBUG_FUNCPTR (gst_rfb_src_event);
+  gstpushsrc_class->create = GST_DEBUG_FUNCPTR (gst_rfb_src_create);
 
-  gstelement_class->change_state = gst_rfbsrc_change_state;
+  GST_DEBUG_CATEGORY_INIT (rfbsrc_debug, "rfbsrc", 0, "Rfb source");
 }
 
-static GstStateChangeReturn
-gst_rfbsrc_change_state (GstElement * element, GstStateChange transition)
+static void
+gst_rfb_src_init (GstRfbSrc * src, GstRfbSrcClass * klass)
 {
-  GstRfbsrc *rfbsrc;
+  GstBaseSrc *bsrc = GST_BASE_SRC (src);
 
-  rfbsrc = GST_RFBSRC (element);
+  gst_pad_use_fixed_caps (GST_BASE_SRC_PAD (bsrc));
+  gst_base_src_set_live (bsrc, TRUE);
+  gst_base_src_set_format (bsrc, GST_FORMAT_TIME);
 
-  switch (transition) {
-    case GST_STATE_CHANGE_NULL_TO_READY:
-      rfbsrc->decoder = rfb_decoder_new ();
-      rfb_decoder_connect_tcp (rfbsrc->decoder, rfbsrc->server, rfbsrc->port);
-      rfbsrc->decoder->paint_rect = gst_rfbsrc_paint_rect;
-      rfbsrc->decoder->decoder_private = rfbsrc;
-      break;
-    case GST_STATE_CHANGE_READY_TO_PAUSED:
-      break;
-    case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
-      break;
-    case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
+  src->host = g_strdup ("127.0.0.1");
+  src->port = 5900;
+}
+
+static void
+gst_rfb_src_dispose (GObject * object)
+{
+  GstRfbSrc *src = GST_RFB_SRC (object);
+
+  g_free (src->host);
+
+  G_OBJECT_CLASS (parent_class)->dispose (object);
+}
+
+static void
+gst_rfb_src_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstRfbSrc *src = GST_RFB_SRC (object);
+
+  switch (prop_id) {
+    case ARG_HOST:
+      src->host = g_strdup (g_value_get_string (value));
       break;
-    case GST_STATE_CHANGE_PAUSED_TO_READY:
-      //rfbsrc->timestamp_offset = 0;
-      //rfbsrc->n_frames = 0;
+    case ARG_PORT:
+      src->port = g_value_get_int (value);
       break;
-    case GST_STATE_CHANGE_READY_TO_NULL:
-      if (rfbsrc->frame) {
-        g_free (rfbsrc->frame);
-        rfbsrc->frame = NULL;
-      }
+    default:
       break;
   }
-
-  return parent_class->change_state (element, transition);
 }
 
 static void
-gst_rfbsrc_init (GstRfbsrc * rfbsrc)
+gst_rfb_src_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec)
 {
-  GST_DEBUG ("gst_rfbsrc_init");
-
-  rfbsrc->srcpad =
-      gst_pad_new_from_template (gst_static_pad_template_get
-      (&gst_rfbsrc_src_template), "src");
-  gst_element_add_pad (GST_ELEMENT (rfbsrc), rfbsrc->srcpad);
-  gst_pad_set_getcaps_function (rfbsrc->srcpad, gst_rfbsrc_getcaps);
-  gst_pad_set_link_function (rfbsrc->srcpad, gst_rfbsrc_link);
-  gst_pad_set_fixate_function (rfbsrc->srcpad, gst_rfbsrc_fixate);
-  gst_pad_set_get_function (rfbsrc->srcpad, gst_rfbsrc_get);
-  gst_pad_set_query_function (rfbsrc->srcpad, gst_rfbsrc_src_query);
-  gst_pad_set_query_type_function (rfbsrc->srcpad, gst_rfbsrc_get_query_types);
-  gst_pad_set_event_function (rfbsrc->srcpad, gst_rfbsrc_handle_src_event);
-
-  rfbsrc->server = g_strdup ("127.0.0.1");
-  rfbsrc->port = 5900;
+  GstRfbSrc *src = GST_RFB_SRC (object);
+
+  switch (prop_id) {
+    case ARG_HOST:
+      g_value_set_string (value, src->host);
+      break;
+    case ARG_PORT:
+      g_value_set_int (value, src->port);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
 }
 
-static GstCaps *
-gst_rfbsrc_getcaps (GstPad * pad)
+static gboolean
+gst_rfb_src_start (GstBaseSrc * bsrc)
 {
-  GstRfbsrc *rfbsrc;
+  GstRfbSrc *src = GST_RFB_SRC (bsrc);
+  RfbDecoder *decoder;
   GstCaps *caps;
 
-  rfbsrc = GST_RFBSRC (gst_pad_get_parent (pad));
+  decoder = rfb_decoder_new ();
 
-  caps = gst_caps_copy (gst_pad_get_pad_template_caps (pad));
-
-  if (rfbsrc->decoder && rfbsrc->decoder->inited) {
-    gst_caps_set_simple (caps,
-        "width", G_TYPE_INT, rfbsrc->decoder->width,
-        "height", G_TYPE_INT, rfbsrc->decoder->height, NULL);
+  GST_DEBUG_OBJECT (src, "connecting to host %s on port %d",
+      src->host, src->port);
+  if (!rfb_decoder_connect_tcp (decoder, src->host, src->port)) {
+    GST_ELEMENT_ERROR (src, LIBRARY, INIT, (NULL),
+        ("Could not connect to host %s on port %d", src->host, src->port));
+    rfb_decoder_free (decoder);
+    return FALSE;
   }
 
-  return caps;
-}
+  src->decoder = decoder;
+  src->inter = FALSE;
 
-static GstCaps *
-gst_rfbsrc_fixate (GstPad * pad, const GstCaps * caps)
-{
-  GstStructure *structure;
-  GstCaps *newcaps;
+  while (!decoder->inited) {
+    rfb_decoder_iterate (decoder);
+  }
 
-  if (gst_caps_get_size (caps) > 1)
-    return NULL;
+  g_object_set (bsrc, "blocksize",
+      src->decoder->width * src->decoder->height * 4, NULL);
 
-  newcaps = gst_caps_copy (caps);
-  structure = gst_caps_get_structure (newcaps, 0);
+  src->frame = g_malloc (bsrc->blocksize);
+  decoder->paint_rect = gst_rfb_src_paint_rect;
+  decoder->decoder_private = src;
 
-  if (gst_structure_fixate_field_nearest_double (structure, "framerate", 30.0)) {
-    return newcaps;
-  }
+  GST_DEBUG_OBJECT (src, "setting caps width to %d and height to %d",
+      decoder->width, decoder->height);
+
+  caps =
+      gst_caps_copy (gst_pad_get_pad_template_caps (GST_BASE_SRC_PAD (bsrc)));
+  gst_caps_set_simple (caps, "width", G_TYPE_INT, decoder->width, "height",
+      G_TYPE_INT, decoder->height, NULL);
+  gst_pad_set_caps (GST_BASE_SRC_PAD (bsrc), caps);
+  gst_caps_unref (caps);
 
-  gst_caps_free (newcaps);
-  return NULL;
+  return TRUE;
 }
 
-static GstPadLinkReturn
-gst_rfbsrc_link (GstPad * pad, const GstCaps * caps)
+static gboolean
+gst_rfb_src_stop (GstBaseSrc * bsrc)
 {
-  GstRfbsrc *rfbsrc;
-  GstStructure *structure;
+  GstRfbSrc *src = GST_RFB_SRC (bsrc);
 
-  rfbsrc = GST_RFBSRC (gst_pad_get_parent (pad));
+  rfb_decoder_free (src->decoder);
 
-  structure = gst_caps_get_structure (caps, 0);
-
-  gst_structure_get_double (structure, "framerate", &rfbsrc->framerate);
+  if (src->frame) {
+    g_free (src->frame);
+    src->frame = NULL;
+  }
 
-  return GST_PAD_LINK_OK;
+  return TRUE;
 }
 
-static const GstQueryType *
-gst_rfbsrc_get_query_types (GstPad * pad)
+static GstFlowReturn
+gst_rfb_src_create (GstPushSrc * psrc, GstBuffer ** outbuf)
 {
-  static const GstQueryType query_types[] = {
-    GST_QUERY_POSITION,
-    0,
-  };
+  GstRfbSrc *src = GST_RFB_SRC (psrc);
+  RfbDecoder *decoder = src->decoder;
+  gulong newsize;
+  GstFlowReturn ret;
 
-  return query_types;
-}
+  rfb_decoder_send_update_request (decoder, src->inter, 0, 0,
+      decoder->width, decoder->height);
+  // src->inter = TRUE;
 
-static gboolean
-gst_rfbsrc_src_query (GstPad * pad,
-    GstQueryType type, GstFormat * format, gint64 * value)
-{
-  gboolean res = FALSE;
-
-  //GstRfbsrc *rfbsrc = GST_RFBSRC (gst_pad_get_parent (pad));
-
-  switch (type) {
-    case GST_QUERY_POSITION:
-      switch (*format) {
-        case GST_FORMAT_TIME:
-          //*value = rfbsrc->n_frames * GST_SECOND / (double) rfbsrc->rate;
-          res = TRUE;
-          break;
-        case GST_FORMAT_DEFAULT:       /* frames */
-          //*value = rfbsrc->n_frames;
-          res = TRUE;
-          break;
-        default:
-          break;
-      }
-      break;
-    default:
-      break;
+  src->go = TRUE;
+  while (src->go) {
+    rfb_decoder_iterate (decoder);
   }
 
-  return res;
+  newsize = GST_BASE_SRC (psrc)->blocksize;
+
+  /* Create the buffer. */
+  ret = gst_pad_alloc_buffer (GST_BASE_SRC_PAD (GST_BASE_SRC (psrc)),
+      GST_BUFFER_OFFSET_NONE, newsize,
+      GST_PAD_CAPS (GST_BASE_SRC_PAD (GST_BASE_SRC (psrc))), outbuf);
+
+  if (G_UNLIKELY (ret != GST_FLOW_OK)) {
+    return GST_FLOW_ERROR;
+  }
+
+  memcpy (GST_BUFFER_DATA (*outbuf), src->frame, newsize);
+  GST_BUFFER_SIZE (*outbuf) = newsize;
+
+  return GST_FLOW_OK;
 }
 
 static gboolean
-gst_rfbsrc_handle_src_event (GstPad * pad, GstEvent * event)
+gst_rfb_src_event (GstBaseSrc * bsrc, GstEvent * event)
 {
-  GstRfbsrc *rfbsrc;
-  double x, y;
-  int button;
+  GstRfbSrc *src = GST_RFB_SRC (bsrc);
+  gdouble x, y;
+  gint button;
   GstStructure *structure;
-  const char *event_type;
-
-  rfbsrc = GST_RFBSRC (gst_pad_get_parent (pad));
+  const gchar *event_type;
 
   switch (GST_EVENT_TYPE (event)) {
     case GST_EVENT_NAVIGATION:
-      structure = event->event_data.structure.structure;
+      structure = event->structure;
       event_type = gst_structure_get_string (structure, "event");
       gst_structure_get_double (structure, "pointer_x", &x);
       gst_structure_get_double (structure, "pointer_y", &y);
       button = 0;
 
       if (strcmp (event_type, "key-press") == 0) {
-        const char *key = gst_structure_get_string (structure, "key");
+        const gchar *key = gst_structure_get_string (structure, "key");
 
-        rfb_decoder_send_key_event (rfbsrc->decoder, key[0], 1);
-        rfb_decoder_send_key_event (rfbsrc->decoder, key[0], 0);
+        GST_LOG_OBJECT (src, "sending key event for key %d", key[0]);
+        rfb_decoder_send_key_event (src->decoder, key[0], 1);
+        rfb_decoder_send_key_event (src->decoder, key[0], 0);
       } else if (strcmp (event_type, "mouse-move") == 0) {
-        rfb_decoder_send_pointer_event (rfbsrc->decoder, rfbsrc->button_mask,
-            (int) x, (int) y);
+        GST_LOG_OBJECT (src, "sending mouse-move event "
+            "button_mask=%d, x=%d, y=%d", src->button_mask, (gint) x, (gint) y);
+        rfb_decoder_send_pointer_event (src->decoder, src->button_mask,
+            (gint) x, (gint) y);
       } else if (strcmp (event_type, "mouse-button-release") == 0) {
-        rfbsrc->button_mask &= ~(1 << button);
-        rfb_decoder_send_pointer_event (rfbsrc->decoder, rfbsrc->button_mask,
-            (int) x, (int) y);
+        src->button_mask &= ~(1 << button);
+        GST_LOG_OBJECT (src, "sending mouse-button-release event "
+            "button_mask=%d, x=%d, y=%d", src->button_mask, (gint) x, (gint) y);
+        rfb_decoder_send_pointer_event (src->decoder, src->button_mask,
+            (gint) x, (gint) y);
       } else if (strcmp (event_type, "mouse-button-press") == 0) {
-        rfbsrc->button_mask |= (1 << button);
-        rfb_decoder_send_pointer_event (rfbsrc->decoder, rfbsrc->button_mask,
-            (int) x, (int) y);
+        src->button_mask |= (1 << button);
+        GST_LOG_OBJECT (src, "sending mouse-button-press event "
+            "button_mask=%d, x=%d, y=%d", src->button_mask, (gint) x, (gint) y);
+        rfb_decoder_send_pointer_event (src->decoder, src->button_mask,
+            (gint) x, (gint) y);
       }
       break;
     default:
@@ -396,28 +329,25 @@ gst_rfbsrc_handle_src_event (GstPad * pad, GstEvent * event)
 }
 
 static void
-gst_rfbsrc_paint_rect (RfbDecoder * decoder, int x, int y, int w, int h,
+gst_rfb_src_paint_rect (RfbDecoder * decoder, gint x, gint y, gint w, gint h,
     guint8 * data)
 {
-  int i, j;
+  gint i, j;
   guint8 *frame;
   guint8 color;
-  GstRfbsrc *rfbsrc;
-  int width;
-  int offset;
+  GstRfbSrc *src;
+  gint width;
+  gint offset;
 
-  GST_DEBUG ("painting %d,%d (%dx%d)\n", x, y, w, h);
-  rfbsrc = GST_RFBSRC (decoder->decoder_private);
+  // GST_DEBUG ("painting %d,%d (%dx%d)\n", x, y, w, h);
+  src = GST_RFB_SRC (decoder->decoder_private);
 
-  frame = rfbsrc->frame;
+  frame = src->frame;
   width = decoder->width;
   for (j = 0; j < h; j++) {
     for (i = 0; i < w; i++) {
       color = data[j * w + i];
 
-#define RGB332_R(x)  ((((x)&0x07) * 0x124)>>3)
-#define RGB332_G(x)  ((((x)&0x38) * 0x124)>>6)
-#define RGB332_B(x)  ((((x)&0xc0) * 0x149)>>8)
       offset = ((j + x) * width + (i + x)) * 4;
       frame[offset + 0] = RGB332_B (color);
       frame[offset + 1] = RGB332_G (color);
@@ -426,116 +356,14 @@ gst_rfbsrc_paint_rect (RfbDecoder * decoder, int x, int y, int w, int h,
     }
   }
 
-  rfbsrc->go = FALSE;
+  src->go = FALSE;
 }
 
-static GstData *
-gst_rfbsrc_get (GstPad * pad)
-{
-  GstRfbsrc *rfbsrc;
-  gulong newsize;
-  GstBuffer *buf;
-  RfbDecoder *decoder;
-
-  GST_DEBUG ("gst_rfbsrc_get");
-
-  g_return_val_if_fail (pad != NULL, NULL);
-  g_return_val_if_fail (GST_IS_PAD (pad), NULL);
-
-  rfbsrc = GST_RFBSRC (gst_pad_get_parent (pad));
-  decoder = rfbsrc->decoder;
-
-  if (!decoder->inited) {
-    while (!decoder->inited) {
-      rfb_decoder_iterate (decoder);
-    }
-
-    gst_pad_renegotiate (rfbsrc->srcpad);
-
-    if (rfbsrc->frame)
-      g_free (rfbsrc->frame);
-    rfbsrc->frame = g_malloc (decoder->width * decoder->height * 4);
-
-    GST_DEBUG ("red_mask = %08x\n", decoder->red_max << decoder->red_shift);
-    GST_DEBUG ("green_mask = %08x\n",
-        decoder->green_max << decoder->green_shift);
-    GST_DEBUG ("blue_mask = %08x\n", decoder->blue_max << decoder->blue_shift);
-    rfbsrc->inter = FALSE;
-  }
-
-  rfb_decoder_send_update_request (decoder, rfbsrc->inter, 0, 0, decoder->width,
-      decoder->height);
-  //rfbsrc->inter = TRUE;
-
-  rfbsrc->go = TRUE;
-  while (rfbsrc->go) {
-    rfb_decoder_iterate (decoder);
-    GST_DEBUG ("iterate...\n");
-  }
-
-  newsize = decoder->width * decoder->height * 4;
-  g_return_val_if_fail (newsize > 0, NULL);
-
-  GST_DEBUG ("size=%ld %dx%d", newsize, decoder->width, decoder->height);
-
-  buf = gst_buffer_new_and_alloc (newsize);
-  g_return_val_if_fail (GST_BUFFER_DATA (buf) != NULL, NULL);
-
-  memcpy (GST_BUFFER_DATA (buf), rfbsrc->frame, newsize);
-
-  return GST_DATA (buf);
-}
-
-static void
-gst_rfbsrc_set_property (GObject * object, guint prop_id, const GValue * value,
-    GParamSpec * pspec)
-{
-  GstRfbsrc *src;
-
-  g_return_if_fail (GST_IS_RFBSRC (object));
-  src = GST_RFBSRC (object);
-
-  GST_DEBUG ("gst_rfbsrc_set_property");
-  switch (prop_id) {
-    case ARG_SERVER:
-      src->server = g_strdup (g_value_get_string (value));
-      break;
-    case ARG_PORT:
-      src->port = g_value_get_int (value);
-      break;
-    default:
-      break;
-  }
-}
-
-static void
-gst_rfbsrc_get_property (GObject * object, guint prop_id, GValue * value,
-    GParamSpec * pspec)
-{
-  GstRfbsrc *src;
-
-  g_return_if_fail (GST_IS_RFBSRC (object));
-  src = GST_RFBSRC (object);
-
-  switch (prop_id) {
-    case ARG_SERVER:
-      g_value_set_string (value, src->server);
-      break;
-    case ARG_PORT:
-      g_value_set_int (value, src->port);
-      break;
-    default:
-      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
-      break;
-  }
-}
-
-
 static gboolean
 plugin_init (GstPlugin * plugin)
 {
   return gst_element_register (plugin, "rfbsrc", GST_RANK_NONE,
-      GST_TYPE_RFBSRC);
+      GST_TYPE_RFB_SRC);
 }
 
 GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,