diff options
Diffstat (limited to 'gst/librfb/gstrfbsrc.c')
| -rw-r--r-- | gst/librfb/gstrfbsrc.c | 580 |
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, |