* Boston, MA 02111-1307, USA.
*/
+#include <string.h>
+#include <libbonobo.h>
#include <cspi/spi-private.h>
-
-/* TODO: factor/wrap Bonobo_Stream dependency to cspi/bonobo */
+#define CORBA_BLOCK_SIZE 65536 /* see libbonobo, dunno where this is officially dictated */
struct StreamCacheItem {
- Bonobo_Stream stream;
+ Accessibility_ContentStream stream;
gchar *mimetype;
};
}
static void
-stream_release (gpointer a)
-{
- bonobo_object_release_unref (a);
-}
-
-static void
stream_cache_item_free (gpointer a)
{
struct StreamCacheItem *cache_item = a;
- if (cache_item) {
- bonobo_object_release_unref (cache_item->stream);
- SPI_freeString (cache_item->mimetype);
- g_free (cache_item);
- }
+
+ cspi_release_unref (cache_item->stream);
+ SPI_freeString (cache_item->mimetype);
+ g_free (cache_item);
}
static GHashTable *streams = NULL;
-GHashTable *
+static GHashTable *
get_streams (void)
{
- if (streams == NULL) {
- streams = g_hash_table_new_full (g_direct_hash, streams_equal_func,
- stream_release, stream_cache_item_free);
- }
+ if (streams == NULL)
+ streams = g_hash_table_new_full (g_direct_hash, streams_equal_func,
+ NULL, stream_cache_item_free);
return streams;
}
+static CORBA_long
+accessible_content_stream_client_seek (const Accessibility_ContentStream stream,
+ CORBA_long offset,
+ Accessibility_ContentStream_SeekType seek_type,
+ CORBA_Environment *opt_ev)
+{
+ CORBA_Environment *ev, temp_ev;
+ CORBA_long ret_offset;
+
+ if (!opt_ev) {
+ CORBA_exception_init (&temp_ev);
+ ev = &temp_ev;
+ } else
+ ev = opt_ev;
+
+ ret_offset = Accessibility_ContentStream_seek (stream, offset, seek_type, ev);
+ if (BONOBO_EX (ev))
+ ret_offset = -1;
+
+ if (!opt_ev)
+ CORBA_exception_free (&temp_ev);
+
+ return ret_offset;
+}
+
+static guint8*
+accessible_content_stream_client_read (const Accessibility_ContentStream stream,
+ const size_t size,
+ CORBA_long *length_read,
+ CORBA_Environment *ev)
+{
+ size_t pos;
+ guint8 *mem;
+ size_t length;
+
+ g_return_val_if_fail (ev != NULL, NULL);
+
+ if (length_read)
+ *length_read = size;
+
+ length = size;
+
+ if (length == 0)
+ return NULL;
+
+ mem = g_try_malloc (length);
+ if (!mem) {
+ CORBA_exception_set_system (ev, ex_CORBA_NO_MEMORY,
+ CORBA_COMPLETED_NO);
+ return NULL;
+ }
+
+ *length_read = 0;
+
+ for (pos = 0; pos < length;) {
+ Bonobo_Stream_iobuf *buf;
+ CORBA_long len;
+
+ len = (pos + CORBA_BLOCK_SIZE < length) ?
+ CORBA_BLOCK_SIZE : length - pos;
+
+ Accessibility_ContentStream_read (stream, len, &buf, ev);
+
+ if (BONOBO_EX (ev) || !buf)
+ goto io_error;
+
+ if (buf->_length > 0) {
+ memcpy (mem + pos, buf->_buffer, buf->_length);
+ pos += buf->_length;
+ } else {
+ g_warning ("Buffer length %d", buf->_length);
+ goto io_error;
+ }
+ *length_read += buf->_length;
+
+ CORBA_free (buf);
+ }
+
+ return mem;
+
+ io_error:
+ return NULL;
+}
+
/* internal use only, declared in cspi-private.h */
void
cspi_streams_close_all (void)
{
- g_hash_table_destroy (get_streams ());
+ if (streams)
+ {
+ g_hash_table_destroy (streams);
+ streams = NULL;
+ }
}
/**
*
* Increment the reference count for an #AccessibleStreamableContent object.
*
+ * @Since: AT-SPI 1.4
**/
void
AccessibleStreamableContent_ref (AccessibleStreamableContent *obj)
*
* Decrement the reference count for an #AccessibleStreamableContent object.
*
+ * @Since: AT-SPI 1.4
**/
void
AccessibleStreamableContent_unref (AccessibleStreamableContent *obj)
* Get a list of strings containing the content mimetypes available from an
* #AccessibleStreamableContent implementor.
*
+ * @Since: AT-SPI 1.4
+ *
* Returns: an array of strings, terminated by a NULL string, specifying the
* mimetypes for which the streamed content is available.
*
**/
+
char **
AccessibleStreamableContent_getContentTypes (AccessibleStreamableContent *obj)
{
mimeseq = Accessibility_StreamableContent_getContentTypes (CSPI_OBJREF (obj),
cspi_ev ());
+ cspi_return_val_if_ev ("getContentTypes", NULL);
content_types = g_new0 (char *, mimeseq->_length + 1);
- for (i = 0; i < mimeseq->_length; ++i) {
+ for (i = 0; i < mimeseq->_length; ++i)
content_types[i] = CORBA_string_dup (mimeseq->_buffer[i]);
- }
content_types [mimeseq->_length] = NULL;
CORBA_free (mimeseq);
return content_types;
}
+/**
+* AccessibleStreamableContent_freeContentTypesList:
+* @obj: the AccessibleStreamableContent implementor on which to operate.
+* @content_types: a list of content types previously returned by
+* #AccessibleStreamableContent_getContentTypes.
+*
+* Free the memory associated with a call to #AccessibleStreamableContent_getContentTypes, once
+* the result has been used.
+*
+* @Since: AT-SPI 1.4
+**/
+void
+AccessibleStreamableContent_freeContentTypesList (AccessibleStreamableContent *obj,
+ char **content_types)
+{
+ if (content_types)
+ {
+ gint i = 0;
+ while (content_types[i])
+ {
+ g_free (content_types[i]);
+ i++;
+ }
+ g_free (content_types);
+ }
+}
/**
* AccessibleStreamableContent_open:
* Open a streaming connection to an AccessibleStreamableContent implementor,
* of a particular content type
*
+ * @Since: AT-SPI 1.4
+ *
* Returns: #TRUE if successful, #FALSE if unsuccessful.
*
**/
AccessibleStreamableContent_open (AccessibleStreamableContent *obj,
const char *content_type)
{
- Bonobo_Stream stream;
+ Accessibility_ContentStream stream;
struct StreamCacheItem *cache;
stream = Accessibility_StreamableContent_getContent (CSPI_OBJREF (obj),
content_type,
- cspi_ev ());
+ cspi_ev ());
+ cspi_return_val_if_ev ("getContent", FALSE);
+
if (stream != CORBA_OBJECT_NIL) {
cache = g_new0 (struct StreamCacheItem, 1);
cache->stream = stream;
* Close the current streaming connection to an AccessibleStreamableContent implementor.
* This must be called before any subsequent AccessibleStreamableContent_open
* calls on the same object.
+ *
+ * @Since: AT-SPI 1.4
*
* Returns: #TRUE if successful, #FALSE if unsuccessful.
*
* #AccessibleStreamableContent_open()) to seek to a particular offset in the
* stream.
*
+ * @Since: AT-SPI 1.4
+ *
* Returns: #TRUE if successful, #FALSE if unsuccessful.
*
**/
-SPIBoolean
+long int
AccessibleStreamableContent_seek (AccessibleStreamableContent *obj,
long int offset,
- unsigned int seek_type)
+ AccessibleStreamableContentSeekType seek_type)
{
- /* currently Bonobo_Stream does not appear to support seek operations */
- return FALSE;
+ Accessibility_ContentStream stream;
+ long int ret_offset = 0;
+ struct StreamCacheItem *cached;
+ Accessibility_ContentStream_SeekType content_seek_type;
+
+ cached = g_hash_table_lookup (get_streams (), CSPI_OBJREF (obj));
+ if (cached)
+ {
+ stream = cached->stream;
+ if (stream != CORBA_OBJECT_NIL)
+ {
+ switch (seek_type) {
+ case SPI_STREAM_SEEK_SET:
+ content_seek_type = Accessibility_ContentStream_SEEK_SET;
+ break;
+ case SPI_STREAM_SEEK_END:
+ content_seek_type = Accessibility_ContentStream_SEEK_END;
+ break;
+ case SPI_STREAM_SEEK_CUR:
+ default:
+ content_seek_type = Accessibility_ContentStream_SEEK_CURRENT;
+ break;
+ }
+ ret_offset = accessible_content_stream_client_seek (stream, offset,
+ content_seek_type, cspi_ev ());
+ cspi_return_val_if_ev ("seek", FALSE);
+ }
+ }
+ return ret_offset;
}
/**
* if blocking is not allowed, etc.
*
* Copy (read) bytes from the currently open streamable content connection
- * to a buffer.
+ * to a buffer. This is a blocking API, in the sense that it does not
+ * return until the bytes have been read, or an error condition is
+ * detected.
+ *
+ * @Since: AT-SPI 1.4
*
* Returns: an integer indicating the number of bytes read, or -1 on error.
*
long int nbytes,
unsigned int read_type)
{
- Bonobo_Stream stream;
+ Accessibility_ContentStream stream;
struct StreamCacheItem *cached;
cached = g_hash_table_lookup (get_streams (), CSPI_OBJREF (obj));
- if (cached) {
- CORBA_long len_read;
- stream = cached->stream;
- if (stream != CORBA_OBJECT_NIL) {
- guint8 *mem;
- mem = bonobo_stream_client_read (stream, (size_t) nbytes, &len_read, cspi_ev ());
- if (mem) memcpy (buff, mem, len_read);
- if (mem && ((nbytes == -1) || (len_read == nbytes)))
- return TRUE;
+ if (cached)
+ {
+ CORBA_long len_read;
+ stream = cached->stream;
+ if (stream != CORBA_OBJECT_NIL)
+ {
+ guint8 *mem;
+ mem = accessible_content_stream_client_read (stream, (size_t) nbytes, &len_read, cspi_ev ());
+ cspi_return_val_if_ev ("read", FALSE);
+ if (mem)
+ {
+ memcpy (buff, mem, len_read);
+ g_free (mem);
+ if ((nbytes == -1) || (len_read == nbytes))
+ return TRUE;
+ }
+ }
}
- }
return FALSE;
}
projects / platform / core / uifw / at-spi2-atk.git / blobdiff