--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/gst_plugins_base/gst/audioresample/buffer.c	Thu Dec 17 08:53:32 2009 +0200
@@ -0,0 +1,326 @@
+/*
+* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description: 
+*
+*/
+
+
+#ifndef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <glib.h>
+#include <string.h>
+
+#include "buffer.h"
+#include "debug.h"
+
+static void audioresample_buffer_free_mem (AudioresampleBuffer * buffer,
+    void *);
+static void audioresample_buffer_free_subbuffer (AudioresampleBuffer * buffer,
+    void *priv);
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+
+AudioresampleBuffer *
+audioresample_buffer_new (void)
+{
+  AudioresampleBuffer *buffer;
+
+  buffer = g_new0 (AudioresampleBuffer, 1);
+  buffer->ref_count = 1;
+  return buffer;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+AudioresampleBuffer *
+audioresample_buffer_new_and_alloc (int size)
+{
+  AudioresampleBuffer *buffer = audioresample_buffer_new ();
+
+  buffer->data = g_malloc (size);
+  buffer->length = size;
+  buffer->free = audioresample_buffer_free_mem;
+
+  return buffer;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+AudioresampleBuffer *
+audioresample_buffer_new_with_data (void *data, int size)
+{
+  AudioresampleBuffer *buffer = audioresample_buffer_new ();
+
+  buffer->data = data;
+  buffer->length = size;
+  buffer->free = audioresample_buffer_free_mem;
+
+  return buffer;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+AudioresampleBuffer *
+audioresample_buffer_new_subbuffer (AudioresampleBuffer * buffer, int offset,
+    int length)
+{
+  AudioresampleBuffer *subbuffer = audioresample_buffer_new ();
+
+  if (buffer->parent) {
+    audioresample_buffer_ref (buffer->parent);
+    subbuffer->parent = buffer->parent;
+  } else {
+    audioresample_buffer_ref (buffer);
+    subbuffer->parent = buffer;
+  }
+  subbuffer->data = buffer->data + offset;
+  subbuffer->length = length;
+  subbuffer->free = audioresample_buffer_free_subbuffer;
+
+  return subbuffer;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+void
+audioresample_buffer_ref (AudioresampleBuffer * buffer)
+{
+  buffer->ref_count++;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+void
+audioresample_buffer_unref (AudioresampleBuffer * buffer)
+{
+  buffer->ref_count--;
+  if (buffer->ref_count == 0) {
+    if (buffer->free)
+      buffer->free (buffer, buffer->priv);
+    g_free (buffer);
+  }
+}
+
+static void
+audioresample_buffer_free_mem (AudioresampleBuffer * buffer, void *priv)
+{
+  g_free (buffer->data);
+}
+
+static void
+audioresample_buffer_free_subbuffer (AudioresampleBuffer * buffer, void *priv)
+{
+  audioresample_buffer_unref (buffer->parent);
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+
+AudioresampleBufferQueue *
+audioresample_buffer_queue_new (void)
+{
+  return g_new0 (AudioresampleBufferQueue, 1);
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+int
+audioresample_buffer_queue_get_depth (AudioresampleBufferQueue * queue)
+{
+  return queue->depth;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+int
+audioresample_buffer_queue_get_offset (AudioresampleBufferQueue * queue)
+{
+  return queue->offset;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+void
+audioresample_buffer_queue_free (AudioresampleBufferQueue * queue)
+{
+  GList *g;
+
+  for (g = g_list_first (queue->buffers); g; g = g_list_next (g)) {
+    audioresample_buffer_unref ((AudioresampleBuffer *) g->data);
+  }
+  g_list_free (queue->buffers);
+  g_free (queue);
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+void
+audioresample_buffer_queue_push (AudioresampleBufferQueue * queue,
+    AudioresampleBuffer * buffer)
+{
+  queue->buffers = g_list_append (queue->buffers, buffer);
+  queue->depth += buffer->length;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+AudioresampleBuffer *
+audioresample_buffer_queue_pull (AudioresampleBufferQueue * queue, int length)
+{
+  GList *g;
+  AudioresampleBuffer *newbuffer;
+  AudioresampleBuffer *buffer;
+  AudioresampleBuffer *subbuffer;
+
+  g_return_val_if_fail (length > 0, NULL);
+
+  if (queue->depth < length) {
+    return NULL;
+  }
+
+  RESAMPLE_LOG ("pulling %d, %d available", length, queue->depth);
+
+  g = g_list_first (queue->buffers);
+  buffer = g->data;
+
+  if (buffer->length > length) {
+    newbuffer = audioresample_buffer_new_subbuffer (buffer, 0, length);
+
+    subbuffer = audioresample_buffer_new_subbuffer (buffer, length,
+        buffer->length - length);
+    g->data = subbuffer;
+    audioresample_buffer_unref (buffer);
+  } else {
+    int offset = 0;
+
+    newbuffer = audioresample_buffer_new_and_alloc (length);
+
+    while (offset < length) {
+      g = g_list_first (queue->buffers);
+      buffer = g->data;
+
+      if (buffer->length > length - offset) {
+        int n = length - offset;
+
+        memcpy (newbuffer->data + offset, buffer->data, n);
+        subbuffer =
+            audioresample_buffer_new_subbuffer (buffer, n, buffer->length - n);
+        g->data = subbuffer;
+        audioresample_buffer_unref (buffer);
+        offset += n;
+      } else {
+        memcpy (newbuffer->data + offset, buffer->data, buffer->length);
+
+        queue->buffers = g_list_delete_link (queue->buffers, g);
+        offset += buffer->length;
+        audioresample_buffer_unref (buffer);
+      }
+    }
+  }
+
+  queue->depth -= length;
+  queue->offset += length;
+
+  return newbuffer;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+AudioresampleBuffer *
+audioresample_buffer_queue_peek (AudioresampleBufferQueue * queue, int length)
+{
+  GList *g;
+  AudioresampleBuffer *newbuffer;
+  AudioresampleBuffer *buffer;
+  int offset = 0;
+
+  g_return_val_if_fail (length > 0, NULL);
+
+  if (queue->depth < length) {
+    return NULL;
+  }
+
+  RESAMPLE_LOG ("peeking %d, %d available", length, queue->depth);
+
+  g = g_list_first (queue->buffers);
+  buffer = g->data;
+  if (buffer->length > length) {
+    newbuffer = audioresample_buffer_new_subbuffer (buffer, 0, length);
+  } else {
+    newbuffer = audioresample_buffer_new_and_alloc (length);
+    while (offset < length) {
+      buffer = g->data;
+
+      if (buffer->length > length - offset) {
+        int n = length - offset;
+
+        memcpy (newbuffer->data + offset, buffer->data, n);
+        offset += n;
+      } else {
+        memcpy (newbuffer->data + offset, buffer->data, buffer->length);
+        offset += buffer->length;
+      }
+      g = g_list_next (g);
+    }
+  }
+
+  return newbuffer;
+}
+#ifdef __SYMBIAN32__
+EXPORT_C
+#endif
+
+
+void
+audioresample_buffer_queue_flush (AudioresampleBufferQueue * queue)
+{
+  GList *g;
+
+  for (g = g_list_first (queue->buffers); g; g = g_list_next (g)) {
+    audioresample_buffer_unref ((AudioresampleBuffer *) g->data);
+  }
+  g_list_free (queue->buffers);
+  queue->buffers = NULL;
+  queue->depth = 0;
+  queue->offset = 0;
+}