Implement RFE #326532: remove BonoboStream usage from
[platform/core/uifw/at-spi2-atk.git] / cspi / spi_streamablecontent.c
index aa91106..8b6b266 100644 (file)
 #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;
 };
 
@@ -52,7 +51,7 @@ stream_cache_item_free (gpointer a)
 
 static GHashTable *streams = NULL;
 
-GHashTable *
+static GHashTable *
 get_streams (void) 
 {
   if (streams == NULL)
@@ -62,12 +61,11 @@ get_streams (void)
 }
 
 static CORBA_long
-accessible_bonobo_stream_client_seek (const Bonobo_Stream stream,
+accessible_content_stream_client_seek (const Accessibility_ContentStream stream,
                                      CORBA_long offset,
-                                     Bonobo_Stream_SeekType seek_type,
+                                     Accessibility_ContentStream_SeekType seek_type,
                                      CORBA_Environment  *opt_ev)
 {
-       Bonobo_StorageInfo *info;
        CORBA_Environment  *ev, temp_ev;
        CORBA_long ret_offset;
        
@@ -77,7 +75,7 @@ accessible_bonobo_stream_client_seek (const Bonobo_Stream stream,
        } else
                ev = opt_ev;
 
-       ret_offset = Bonobo_Stream_seek (stream, offset, seek_type, ev);
+       ret_offset = Accessibility_ContentStream_seek (stream, offset, seek_type, ev);
        if (BONOBO_EX (ev))
                ret_offset = -1;
 
@@ -87,6 +85,65 @@ accessible_bonobo_stream_client_seek (const Bonobo_Stream stream,
        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)
@@ -105,6 +162,7 @@ cspi_streams_close_all (void)
  *
  * Increment the reference count for an #AccessibleStreamableContent object.
  *
+ * @Since: AT-SPI 1.4
  **/
 void
 AccessibleStreamableContent_ref (AccessibleStreamableContent *obj)
@@ -119,6 +177,7 @@ AccessibleStreamableContent_ref (AccessibleStreamableContent *obj)
  *
  * Decrement the reference count for an #AccessibleStreamableContent object.
  *
+ * @Since: AT-SPI 1.4
  **/
 void
 AccessibleStreamableContent_unref (AccessibleStreamableContent *obj)
@@ -133,6 +192,8 @@ 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.
  *
@@ -157,7 +218,17 @@ AccessibleStreamableContent_getContentTypes (AccessibleStreamableContent *obj)
 
   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)
@@ -183,6 +254,8 @@ AccessibleStreamableContent_freeContentTypesList (AccessibleStreamableContent *o
  * 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.
  *
  **/
@@ -190,7 +263,7 @@ SPIBoolean
 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,
@@ -214,6 +287,8 @@ AccessibleStreamableContent_open (AccessibleStreamableContent *obj,
  * 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.
  *
@@ -239,6 +314,8 @@ AccessibleStreamableContent_close (AccessibleStreamableContent *obj)
  *     #AccessibleStreamableContent_open()) to seek to a particular offset in the
  *     stream.
  *
+ * @Since: AT-SPI 1.4
+ *
  * Returns: #TRUE if successful, #FALSE if unsuccessful.
  *
  **/
@@ -247,10 +324,10 @@ AccessibleStreamableContent_seek (AccessibleStreamableContent *obj,
                                  long int offset,
                                  AccessibleStreamableContentSeekType seek_type)
 {
-  Bonobo_Stream stream;
+  Accessibility_ContentStream stream;
   long int ret_offset = 0;
   struct StreamCacheItem *cached; 
-  Bonobo_Stream_SeekType bonobo_seek_type;
+  Accessibility_ContentStream_SeekType content_seek_type;
 
   cached = g_hash_table_lookup (get_streams (), CSPI_OBJREF (obj));
   if (cached)
@@ -258,22 +335,20 @@ AccessibleStreamableContent_seek (AccessibleStreamableContent *obj,
       stream = cached->stream;
       if (stream != CORBA_OBJECT_NIL)
        {
-          guint8 *mem;
          switch (seek_type) {
          case SPI_STREAM_SEEK_SET:
-           bonobo_seek_type = Bonobo_Stream_SeekSet
+           content_seek_type = Accessibility_ContentStream_SEEK_SET
            break;
          case SPI_STREAM_SEEK_END:
-           bonobo_seek_type = Bonobo_Stream_SeekEnd
+           content_seek_type = Accessibility_ContentStream_SEEK_END
            break;
          case SPI_STREAM_SEEK_CUR:
          default:
-           bonobo_seek_type = Bonobo_Stream_SeekCur
+           content_seek_type = Accessibility_ContentStream_SEEK_CURRENT
            break;
          }
-         /* bonobo-client doesn't wrap seek yet, so we have to. */
-         ret_offset = accessible_bonobo_stream_client_seek (stream, offset, 
-                                                            bonobo_seek_type, cspi_ev ());
+         ret_offset = accessible_content_stream_client_seek (stream, offset, 
+                                                            content_seek_type, cspi_ev ());
          cspi_return_val_if_ev ("seek", FALSE);
        }
     }
@@ -294,6 +369,8 @@ AccessibleStreamableContent_seek (AccessibleStreamableContent *obj,
  *     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.
  *
  **/
@@ -303,7 +380,7 @@ AccessibleStreamableContent_read (AccessibleStreamableContent *obj,
                                  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)
@@ -313,7 +390,7 @@ AccessibleStreamableContent_read (AccessibleStreamableContent *obj,
       if (stream != CORBA_OBJECT_NIL)
        {
           guint8 *mem;
-         mem = bonobo_stream_client_read (stream, (size_t) nbytes, &len_read, cspi_ev ());
+         mem = accessible_content_stream_client_read (stream, (size_t) nbytes, &len_read, cspi_ev ());
          cspi_return_val_if_ev ("read", FALSE);
          if (mem)
             {