gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
/* GStreamer
|
|
|
|
* Copyright (C) 2004 Benjamin Otte <otte@gnome.org>
|
2006-05-30 15:53:40 +00:00
|
|
|
* 2005 Wim Taymans <wim@fluendo.com>
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
|
|
|
* This library is free software; you can redistribute it and/or
|
|
|
|
* modify it under the terms of the GNU Library General Public
|
|
|
|
* License as published by the Free Software Foundation; either
|
|
|
|
* version 2 of the License, or (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This library is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
|
|
* Library General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU Library General Public
|
|
|
|
* License along with this library; if not, write to the
|
|
|
|
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
|
|
|
* Boston, MA 02111-1307, USA.
|
|
|
|
*/
|
|
|
|
|
2005-08-05 10:02:44 +00:00
|
|
|
/**
|
|
|
|
* SECTION:gstadapter
|
2005-11-09 09:48:16 +00:00
|
|
|
* @short_description: adapts incoming data on a sink pad into chunks of N bytes
|
2005-08-05 10:02:44 +00:00
|
|
|
*
|
2005-10-15 15:30:24 +00:00
|
|
|
* This class is for elements that receive buffers in an undesired size.
|
|
|
|
* While for example raw video contains one image per buffer, the same is not
|
|
|
|
* true for a lot of other formats, especially those that come directly from
|
|
|
|
* a file. So if you have undefined buffer sizes and require a specific size,
|
2005-08-05 10:02:44 +00:00
|
|
|
* this object is for you.
|
|
|
|
*
|
2006-03-15 16:22:26 +00:00
|
|
|
* An adapter is created with gst_adapter_new(). It can be freed again with
|
|
|
|
* g_object_unref().
|
|
|
|
*
|
2005-08-05 10:02:44 +00:00
|
|
|
* The theory of operation is like this: All buffers received are put
|
2005-10-15 15:30:24 +00:00
|
|
|
* into the adapter using gst_adapter_push() and the data is then read back
|
2005-08-05 10:02:44 +00:00
|
|
|
* in chunks of the desired size using gst_adapter_peek(). After the data is
|
2005-11-09 09:48:16 +00:00
|
|
|
* processed, it is freed using gst_adapter_flush().
|
|
|
|
*
|
2009-05-13 16:50:23 +00:00
|
|
|
* Other methods such as gst_adapter_take() and gst_adapter_take_buffer()
|
|
|
|
* combine gst_adapter_peek() and gst_adapter_flush() in one method and are
|
2009-08-28 16:03:44 +00:00
|
|
|
* potentially more convenient for some use cases.
|
2009-05-13 16:50:23 +00:00
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* For example, a sink pad's chain function that needs to pass data to a library
|
|
|
|
* in 512-byte chunks could be implemented like this:
|
2005-08-05 10:02:44 +00:00
|
|
|
* <programlisting>
|
2005-11-09 09:48:16 +00:00
|
|
|
* static GstFlowReturn
|
|
|
|
* sink_pad_chain (GstPad *pad, GstBuffer *buffer)
|
2005-08-05 10:02:44 +00:00
|
|
|
* {
|
2005-11-09 09:48:16 +00:00
|
|
|
* MyElement *this;
|
|
|
|
* GstAdapter *adapter;
|
|
|
|
* GstFlowReturn ret = GST_FLOW_OK;
|
2009-08-28 16:03:44 +00:00
|
|
|
*
|
|
|
|
* // will give the element an extra ref; remember to drop it
|
2005-11-09 09:48:16 +00:00
|
|
|
* this = MY_ELEMENT (gst_pad_get_parent (pad));
|
|
|
|
* adapter = this->adapter;
|
2009-08-28 16:03:44 +00:00
|
|
|
*
|
2005-08-05 10:02:44 +00:00
|
|
|
* // put buffer into adapter
|
2006-01-27 22:34:51 +00:00
|
|
|
* gst_adapter_push (adapter, buffer);
|
2005-11-09 09:48:16 +00:00
|
|
|
* // while we can read out 512 bytes, process them
|
2006-01-27 22:34:51 +00:00
|
|
|
* while (gst_adapter_available (adapter) >= 512 && ret == GST_FLOW_OK) {
|
2005-11-09 09:48:16 +00:00
|
|
|
* // use flowreturn as an error value
|
2006-01-27 22:34:51 +00:00
|
|
|
* ret = my_library_foo (gst_adapter_peek (adapter, 512));
|
|
|
|
* gst_adapter_flush (adapter, 512);
|
2005-08-05 10:02:44 +00:00
|
|
|
* }
|
2009-08-28 16:03:44 +00:00
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* gst_object_unref (this);
|
|
|
|
* return ret;
|
2005-08-05 10:02:44 +00:00
|
|
|
* }
|
|
|
|
* </programlisting>
|
|
|
|
* For another example, a simple element inside GStreamer that uses GstAdapter
|
|
|
|
* is the libvisual element.
|
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* An element using GstAdapter in its sink pad chain function should ensure that
|
|
|
|
* when the FLUSH_STOP event is received, that any queued data is cleared using
|
|
|
|
* gst_adapter_clear(). Data should also be cleared or processed on EOS and
|
|
|
|
* when changing state from #GST_STATE_PAUSED to #GST_STATE_READY.
|
|
|
|
*
|
2006-03-07 16:21:02 +00:00
|
|
|
* Also check the GST_BUFFER_FLAG_DISCONT flag on the buffer. Some elements might
|
|
|
|
* need to clear the adapter after a discontinuity.
|
|
|
|
*
|
2009-05-13 16:50:23 +00:00
|
|
|
* Since 0.10.24, the adapter will keep track of the timestamps of the buffers
|
|
|
|
* that were pushed. The last seen timestamp before the current position
|
|
|
|
* can be queried with gst_adapter_prev_timestamp(). This function can
|
|
|
|
* optionally return the amount of bytes between the start of the buffer that
|
|
|
|
* carried the timestamp and the current adapter position. The distance is
|
|
|
|
* useful when dealing with, for example, raw audio samples because it allows
|
|
|
|
* you to calculate the timestamp of the current adapter position by using the
|
|
|
|
* last seen timestamp and the amount of bytes since.
|
|
|
|
*
|
2005-10-15 15:30:24 +00:00
|
|
|
* A last thing to note is that while GstAdapter is pretty optimized,
|
2009-05-13 16:50:23 +00:00
|
|
|
* merging buffers still might be an operation that requires a malloc() and
|
|
|
|
* memcpy() operation, and these operations are not the fastest. Because of
|
|
|
|
* this, some functions like gst_adapter_available_fast() are provided to help
|
|
|
|
* speed up such cases should you want to. To avoid repeated memory allocations,
|
|
|
|
* gst_adapter_copy() can be used to copy data into a (statically allocated)
|
|
|
|
* user provided buffer.
|
2005-11-09 09:48:16 +00:00
|
|
|
*
|
|
|
|
* GstAdapter is not MT safe. All operations on an adapter must be serialized by
|
|
|
|
* the caller. This is not normally a problem, however, as the normal use case
|
|
|
|
* of GstAdapter is inside one pad's chain function, in which case access is
|
2006-03-07 16:21:02 +00:00
|
|
|
* serialized via the pad's STREAM_LOCK.
|
2005-11-09 09:48:16 +00:00
|
|
|
*
|
2009-08-28 16:03:44 +00:00
|
|
|
* Note that gst_adapter_push() takes ownership of the buffer passed. Use
|
2006-03-07 16:21:02 +00:00
|
|
|
* gst_buffer_ref() before pushing it into the adapter if you still want to
|
|
|
|
* access the buffer later. The adapter will never modify the data in the
|
|
|
|
* buffer pushed in it.
|
libs/gst/: Documentation updates.
Original commit message from CVS:
* libs/gst/base/gstadapter.c:
* libs/gst/base/gstadapter.h:
* libs/gst/base/gstbasesink.c: (gst_base_sink_class_init),
(gst_base_sink_get_position):
* libs/gst/base/gstbasesink.h:
* libs/gst/base/gstbasesrc.c: (gst_base_src_class_init),
(gst_base_src_default_query), (gst_base_src_default_do_seek),
(gst_base_src_do_seek), (gst_base_src_perform_seek),
(gst_base_src_send_event), (gst_base_src_update_length),
(gst_base_src_get_range), (gst_base_src_loop),
(gst_base_src_start):
* libs/gst/base/gstbasesrc.h:
* libs/gst/base/gstbasetransform.h:
* libs/gst/base/gstcollectpads.h:
* libs/gst/base/gstpushsrc.c:
* libs/gst/base/gstpushsrc.h:
* libs/gst/dataprotocol/dataprotocol.c:
* libs/gst/dataprotocol/dataprotocol.h:
* libs/gst/net/gstnetclientclock.h:
* libs/gst/net/gstnettimeprovider.h:
Documentation updates.
2005-12-18 16:04:41 +00:00
|
|
|
*
|
2009-05-13 16:50:23 +00:00
|
|
|
* Last reviewed on 2009-05-13 (0.10.24).
|
2005-08-05 10:02:44 +00:00
|
|
|
*/
|
|
|
|
|
2009-06-29 08:24:04 +00:00
|
|
|
#include <gst/gst_private.h>
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
#include "gstadapter.h"
|
2006-05-04 15:20:14 +00:00
|
|
|
#include <string.h>
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
|
|
|
/* default size for the assembled data buffer */
|
2009-05-20 10:48:41 +00:00
|
|
|
#define DEFAULT_SIZE 4096
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
|
|
|
GST_DEBUG_CATEGORY_STATIC (gst_adapter_debug);
|
|
|
|
#define GST_CAT_DEFAULT gst_adapter_debug
|
|
|
|
|
2009-05-13 19:35:23 +00:00
|
|
|
#define GST_ADAPTER_GET_PRIVATE(obj) \
|
|
|
|
(G_TYPE_INSTANCE_GET_PRIVATE ((obj), GST_TYPE_ADAPTER, GstAdapterPrivate))
|
|
|
|
|
|
|
|
struct _GstAdapterPrivate
|
|
|
|
{
|
|
|
|
GstClockTime timestamp;
|
|
|
|
guint64 distance;
|
|
|
|
};
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
#define _do_init(thing) \
|
2005-11-07 10:13:47 +00:00
|
|
|
GST_DEBUG_CATEGORY_INIT (gst_adapter_debug, "adapter", 0, "object to splice and merge buffers to desired size")
|
2005-11-09 09:48:16 +00:00
|
|
|
GST_BOILERPLATE_FULL (GstAdapter, gst_adapter, GObject, G_TYPE_OBJECT,
|
|
|
|
_do_init);
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
2005-11-09 09:48:16 +00:00
|
|
|
static void gst_adapter_dispose (GObject * object);
|
|
|
|
static void gst_adapter_finalize (GObject * object);
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
2005-11-09 09:48:16 +00:00
|
|
|
static void
|
|
|
|
gst_adapter_base_init (gpointer g_class)
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
{
|
2005-11-09 09:48:16 +00:00
|
|
|
/* nop */
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
gst_adapter_class_init (GstAdapterClass * klass)
|
|
|
|
{
|
|
|
|
GObjectClass *object = G_OBJECT_CLASS (klass);
|
|
|
|
|
2009-05-13 19:35:23 +00:00
|
|
|
g_type_class_add_private (klass, sizeof (GstAdapterPrivate));
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
object->dispose = gst_adapter_dispose;
|
|
|
|
object->finalize = gst_adapter_finalize;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2005-08-28 17:45:58 +00:00
|
|
|
gst_adapter_init (GstAdapter * adapter, GstAdapterClass * g_class)
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
{
|
2009-05-13 19:35:23 +00:00
|
|
|
adapter->priv = GST_ADAPTER_GET_PRIVATE (adapter);
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
adapter->assembled_data = g_malloc (DEFAULT_SIZE);
|
|
|
|
adapter->assembled_size = DEFAULT_SIZE;
|
2009-05-13 19:35:23 +00:00
|
|
|
adapter->priv->timestamp = GST_CLOCK_TIME_NONE;
|
|
|
|
adapter->priv->distance = 0;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
gst_adapter_dispose (GObject * object)
|
|
|
|
{
|
|
|
|
GstAdapter *adapter = GST_ADAPTER (object);
|
|
|
|
|
|
|
|
gst_adapter_clear (adapter);
|
|
|
|
|
|
|
|
GST_CALL_PARENT (G_OBJECT_CLASS, dispose, (object));
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
gst_adapter_finalize (GObject * object)
|
|
|
|
{
|
|
|
|
GstAdapter *adapter = GST_ADAPTER (object);
|
|
|
|
|
|
|
|
g_free (adapter->assembled_data);
|
|
|
|
|
|
|
|
GST_CALL_PARENT (G_OBJECT_CLASS, finalize, (object));
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_adapter_new:
|
|
|
|
*
|
2006-03-15 16:22:26 +00:00
|
|
|
* Creates a new #GstAdapter. Free with g_object_unref().
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
|
|
|
* Returns: a new #GstAdapter
|
|
|
|
*/
|
|
|
|
GstAdapter *
|
|
|
|
gst_adapter_new (void)
|
|
|
|
{
|
|
|
|
return g_object_new (GST_TYPE_ADAPTER, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_adapter_clear:
|
2005-11-09 09:48:16 +00:00
|
|
|
* @adapter: a #GstAdapter
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* Removes all buffers from @adapter.
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*/
|
|
|
|
void
|
|
|
|
gst_adapter_clear (GstAdapter * adapter)
|
|
|
|
{
|
|
|
|
g_return_if_fail (GST_IS_ADAPTER (adapter));
|
|
|
|
|
|
|
|
g_slist_foreach (adapter->buflist, (GFunc) gst_mini_object_unref, NULL);
|
|
|
|
g_slist_free (adapter->buflist);
|
|
|
|
adapter->buflist = NULL;
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
adapter->buflist_end = NULL;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
adapter->size = 0;
|
|
|
|
adapter->skip = 0;
|
|
|
|
adapter->assembled_len = 0;
|
2009-05-13 19:35:23 +00:00
|
|
|
adapter->priv->timestamp = GST_CLOCK_TIME_NONE;
|
|
|
|
adapter->priv->distance = 0;
|
2009-05-13 14:09:20 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static inline void
|
|
|
|
update_timestamp (GstAdapter * adapter, GstBuffer * buf)
|
|
|
|
{
|
|
|
|
GstClockTime timestamp;
|
|
|
|
|
|
|
|
timestamp = GST_BUFFER_TIMESTAMP (buf);
|
|
|
|
if (GST_CLOCK_TIME_IS_VALID (timestamp)) {
|
|
|
|
GST_LOG_OBJECT (adapter, "new timestamp %" GST_TIME_FORMAT,
|
|
|
|
GST_TIME_ARGS (timestamp));
|
2009-05-13 19:35:23 +00:00
|
|
|
adapter->priv->timestamp = timestamp;
|
|
|
|
adapter->priv->distance = 0;
|
2009-05-13 14:09:20 +00:00
|
|
|
}
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
|
|
|
|
2009-05-19 20:13:04 +00:00
|
|
|
/* copy data into @dest, skipping @skip bytes from the head buffers */
|
|
|
|
static void
|
|
|
|
copy_into_unchecked (GstAdapter * adapter, guint8 * dest, guint skip,
|
|
|
|
guint size)
|
|
|
|
{
|
|
|
|
GSList *g;
|
|
|
|
GstBuffer *buf;
|
|
|
|
guint bsize, csize;
|
|
|
|
|
2009-05-20 08:27:43 +00:00
|
|
|
/* first step, do skipping */
|
2009-05-19 20:13:04 +00:00
|
|
|
g = adapter->buflist;
|
2009-05-20 08:27:43 +00:00
|
|
|
buf = g->data;
|
|
|
|
bsize = GST_BUFFER_SIZE (buf);
|
2009-05-20 09:12:43 +00:00
|
|
|
while (G_UNLIKELY (skip >= bsize)) {
|
2009-05-20 08:27:43 +00:00
|
|
|
skip -= bsize;
|
2009-05-19 20:13:04 +00:00
|
|
|
g = g_slist_next (g);
|
2009-05-20 08:27:43 +00:00
|
|
|
buf = g->data;
|
2009-05-19 20:13:04 +00:00
|
|
|
bsize = GST_BUFFER_SIZE (buf);
|
|
|
|
}
|
2009-05-20 08:27:43 +00:00
|
|
|
/* copy partial buffer */
|
|
|
|
csize = MIN (bsize - skip, size);
|
|
|
|
memcpy (dest, GST_BUFFER_DATA (buf) + skip, csize);
|
|
|
|
size -= csize;
|
|
|
|
dest += csize;
|
|
|
|
|
2009-05-19 20:13:04 +00:00
|
|
|
/* second step, copy remainder */
|
2009-05-20 09:36:11 +00:00
|
|
|
while (size > 0) {
|
2009-05-19 20:13:04 +00:00
|
|
|
g = g_slist_next (g);
|
2009-05-20 08:27:43 +00:00
|
|
|
buf = g->data;
|
2009-05-19 20:13:04 +00:00
|
|
|
csize = MIN (GST_BUFFER_SIZE (buf), size);
|
|
|
|
memcpy (dest, GST_BUFFER_DATA (buf), csize);
|
|
|
|
size -= csize;
|
|
|
|
dest += csize;
|
2009-05-20 09:36:11 +00:00
|
|
|
}
|
2009-05-19 20:13:04 +00:00
|
|
|
}
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_push:
|
|
|
|
* @adapter: a #GstAdapter
|
2005-11-09 18:41:53 +00:00
|
|
|
* @buf: a #GstBuffer to add to queue in the adapter
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
2005-10-15 15:30:24 +00:00
|
|
|
* Adds the data from @buf to the data stored inside @adapter and takes
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
* ownership of the buffer.
|
2009-03-04 08:20:43 +00:00
|
|
|
* Empty buffers will be automatically dereferenced and not stored in the
|
|
|
|
* @adapter.
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*/
|
|
|
|
void
|
|
|
|
gst_adapter_push (GstAdapter * adapter, GstBuffer * buf)
|
|
|
|
{
|
2008-11-13 18:09:45 +00:00
|
|
|
guint size;
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
g_return_if_fail (GST_IS_ADAPTER (adapter));
|
|
|
|
g_return_if_fail (GST_IS_BUFFER (buf));
|
|
|
|
|
2008-11-13 18:09:45 +00:00
|
|
|
size = GST_BUFFER_SIZE (buf);
|
|
|
|
|
2009-03-04 08:20:43 +00:00
|
|
|
if (G_UNLIKELY (size == 0)) {
|
2009-05-19 20:13:04 +00:00
|
|
|
/* we can't have empty buffers, several parts in this file rely on it, this
|
|
|
|
* has some problems for the timestamp tracking. */
|
2009-03-04 08:20:43 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "discarding empty buffer");
|
|
|
|
gst_buffer_unref (buf);
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
} else {
|
2009-03-04 08:20:43 +00:00
|
|
|
adapter->size += size;
|
|
|
|
|
|
|
|
/* Note: merging buffers at this point is premature. */
|
|
|
|
if (G_UNLIKELY (adapter->buflist == NULL)) {
|
|
|
|
GST_LOG_OBJECT (adapter, "pushing first %u bytes", size);
|
|
|
|
adapter->buflist = adapter->buflist_end = g_slist_append (NULL, buf);
|
2009-05-13 14:09:20 +00:00
|
|
|
update_timestamp (adapter, buf);
|
2009-03-04 08:20:43 +00:00
|
|
|
} else {
|
|
|
|
/* Otherwise append to the end, and advance our end pointer */
|
|
|
|
GST_LOG_OBJECT (adapter, "pushing %u bytes at end, size now %u", size,
|
|
|
|
adapter->size);
|
|
|
|
adapter->buflist_end = g_slist_append (adapter->buflist_end, buf);
|
|
|
|
adapter->buflist_end = g_slist_next (adapter->buflist_end);
|
|
|
|
}
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2007-04-13 11:53:00 +00:00
|
|
|
/* Internal method only. Tries to merge buffers at the head of the queue
|
|
|
|
* to form a single larger buffer of size 'size'. Only merges buffers that
|
|
|
|
* where 'gst_buffer_is_span_fast' returns TRUE.
|
|
|
|
*
|
|
|
|
* Returns TRUE if it managed to merge anything.
|
|
|
|
*/
|
|
|
|
static gboolean
|
|
|
|
gst_adapter_try_to_merge_up (GstAdapter * adapter, guint size)
|
|
|
|
{
|
|
|
|
GstBuffer *cur, *head;
|
|
|
|
GSList *g;
|
|
|
|
|
|
|
|
g = adapter->buflist;
|
|
|
|
if (g == NULL)
|
|
|
|
return FALSE;
|
|
|
|
|
|
|
|
head = g->data;
|
|
|
|
g = g_slist_next (g);
|
|
|
|
|
|
|
|
/* How large do we want our head buffer? The requested size, plus whatever's
|
|
|
|
* been skipped already */
|
|
|
|
size += adapter->skip;
|
|
|
|
|
|
|
|
while (g != NULL && GST_BUFFER_SIZE (head) < size) {
|
|
|
|
cur = g->data;
|
|
|
|
if (!gst_buffer_is_span_fast (head, cur))
|
|
|
|
return TRUE;
|
|
|
|
|
|
|
|
/* Merge the head buffer and the next in line */
|
|
|
|
GST_LOG_OBJECT (adapter,
|
|
|
|
"Merging buffers of size %u & %u in search of target %u",
|
|
|
|
GST_BUFFER_SIZE (head), GST_BUFFER_SIZE (cur), size);
|
|
|
|
|
|
|
|
head = gst_buffer_join (head, cur);
|
|
|
|
|
2009-08-28 16:03:44 +00:00
|
|
|
/* Delete the front list item, and store our new buffer in the 2nd list
|
2007-04-13 11:53:00 +00:00
|
|
|
* item */
|
|
|
|
adapter->buflist = g_slist_delete_link (adapter->buflist, adapter->buflist);
|
|
|
|
g->data = head;
|
|
|
|
}
|
|
|
|
|
|
|
|
return FALSE;
|
|
|
|
}
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_peek:
|
|
|
|
* @adapter: a #GstAdapter
|
2005-11-09 09:48:16 +00:00
|
|
|
* @size: the number of bytes to peek
|
|
|
|
*
|
|
|
|
* Gets the first @size bytes stored in the @adapter. The returned pointer is
|
|
|
|
* valid until the next function is called on the adapter.
|
|
|
|
*
|
|
|
|
* Note that setting the returned pointer as the data of a #GstBuffer is
|
|
|
|
* incorrect for general-purpose plugins. The reason is that if a downstream
|
|
|
|
* element stores the buffer so that it has access to it outside of the bounds
|
|
|
|
* of its chain function, the buffer will have an invalid data pointer after
|
|
|
|
* your element flushes the bytes. In that case you should use
|
|
|
|
* gst_adapter_take(), which returns a freshly-allocated buffer that you can set
|
2009-08-28 16:03:44 +00:00
|
|
|
* as #GstBuffer malloc_data or the potentially more performant
|
2006-05-04 14:19:53 +00:00
|
|
|
* gst_adapter_take_buffer().
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* Returns #NULL if @size bytes are not available.
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* Returns: a pointer to the first @size bytes of data, or NULL.
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*/
|
|
|
|
const guint8 *
|
|
|
|
gst_adapter_peek (GstAdapter * adapter, guint size)
|
|
|
|
{
|
|
|
|
GstBuffer *cur;
|
2009-05-19 20:13:04 +00:00
|
|
|
guint skip;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
|
|
|
g_return_val_if_fail (GST_IS_ADAPTER (adapter), NULL);
|
|
|
|
g_return_val_if_fail (size > 0, NULL);
|
|
|
|
|
2006-05-04 14:19:53 +00:00
|
|
|
/* we don't have enough data, return NULL. This is unlikely
|
2006-05-30 15:53:40 +00:00
|
|
|
* as one usually does an _available() first instead of peeking a
|
2006-05-04 14:19:53 +00:00
|
|
|
* random size. */
|
|
|
|
if (G_UNLIKELY (size > adapter->size))
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
return NULL;
|
|
|
|
|
|
|
|
/* we have enough assembled data, return it */
|
|
|
|
if (adapter->assembled_len >= size)
|
|
|
|
return adapter->assembled_data;
|
|
|
|
|
|
|
|
/* our head buffer has enough data left, return it */
|
|
|
|
cur = adapter->buflist->data;
|
2009-05-19 20:13:04 +00:00
|
|
|
skip = adapter->skip;
|
|
|
|
if (GST_BUFFER_SIZE (cur) >= size + skip)
|
|
|
|
return GST_BUFFER_DATA (cur) + skip;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
2009-08-28 16:03:44 +00:00
|
|
|
/* We may be able to efficiently merge buffers in our pool to
|
2007-04-13 11:53:00 +00:00
|
|
|
* gather a big enough chunk to return it from the head buffer directly */
|
|
|
|
if (gst_adapter_try_to_merge_up (adapter, size)) {
|
|
|
|
/* Merged something! Check if there's enough avail now */
|
|
|
|
cur = adapter->buflist->data;
|
2009-05-19 20:13:04 +00:00
|
|
|
if (GST_BUFFER_SIZE (cur) >= size + skip)
|
|
|
|
return GST_BUFFER_DATA (cur) + skip;
|
2007-04-13 11:53:00 +00:00
|
|
|
}
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
|
2007-04-13 11:53:00 +00:00
|
|
|
/* Gonna need to copy stuff out */
|
2009-05-13 20:51:18 +00:00
|
|
|
if (G_UNLIKELY (adapter->assembled_size < size)) {
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
adapter->assembled_size = (size / DEFAULT_SIZE + 1) * DEFAULT_SIZE;
|
2009-05-13 20:51:18 +00:00
|
|
|
GST_DEBUG_OBJECT (adapter, "resizing internal buffer to %u",
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
adapter->assembled_size);
|
2009-05-13 21:52:02 +00:00
|
|
|
/* no g_realloc to avoid a memcpy that is not desired here since we are
|
|
|
|
* going to copy new data into the area below */
|
|
|
|
g_free (adapter->assembled_data);
|
|
|
|
adapter->assembled_data = g_malloc (adapter->assembled_size);
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
|
|
|
adapter->assembled_len = size;
|
2006-05-04 14:19:53 +00:00
|
|
|
|
2009-06-29 08:24:04 +00:00
|
|
|
GST_CAT_DEBUG (GST_CAT_PERFORMANCE, "copy data from adapter");
|
2009-05-19 20:13:04 +00:00
|
|
|
copy_into_unchecked (adapter, adapter->assembled_data, skip, size);
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
|
|
|
return adapter->assembled_data;
|
|
|
|
}
|
|
|
|
|
2007-01-25 10:50:03 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_copy:
|
|
|
|
* @adapter: a #GstAdapter
|
|
|
|
* @dest: the memory where to copy to
|
|
|
|
* @offset: the bytes offset in the adapter to start from
|
|
|
|
* @size: the number of bytes to copy
|
|
|
|
*
|
|
|
|
* Copies @size bytes of data starting at @offset out of the buffers
|
|
|
|
* contained in @GstAdapter into an array @dest provided by the caller.
|
|
|
|
*
|
|
|
|
* The array @dest should be large enough to contain @size bytes.
|
|
|
|
* The user should check that the adapter has (@offset + @size) bytes
|
|
|
|
* available before calling this function.
|
|
|
|
*
|
|
|
|
* Since: 0.10.12
|
|
|
|
*/
|
|
|
|
void
|
|
|
|
gst_adapter_copy (GstAdapter * adapter, guint8 * dest, guint offset, guint size)
|
|
|
|
{
|
|
|
|
g_return_if_fail (GST_IS_ADAPTER (adapter));
|
|
|
|
g_return_if_fail (size > 0);
|
2009-05-19 20:13:04 +00:00
|
|
|
g_return_if_fail (offset + size <= adapter->size);
|
2007-01-25 10:50:03 +00:00
|
|
|
|
2009-05-19 20:13:04 +00:00
|
|
|
copy_into_unchecked (adapter, dest, offset + adapter->skip, size);
|
2007-01-25 10:50:03 +00:00
|
|
|
}
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_flush:
|
|
|
|
* @adapter: a #GstAdapter
|
2005-11-09 09:48:16 +00:00
|
|
|
* @flush: the number of bytes to flush
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
2005-11-09 18:41:53 +00:00
|
|
|
* Flushes the first @flush bytes in the @adapter. The caller must ensure that
|
|
|
|
* at least this many bytes are available.
|
2005-11-09 09:48:16 +00:00
|
|
|
*
|
|
|
|
* See also: gst_adapter_peek().
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*/
|
|
|
|
void
|
|
|
|
gst_adapter_flush (GstAdapter * adapter, guint flush)
|
|
|
|
{
|
|
|
|
GstBuffer *cur;
|
2009-05-13 14:20:26 +00:00
|
|
|
guint size;
|
2009-05-20 20:18:16 +00:00
|
|
|
GstAdapterPrivate *priv;
|
|
|
|
GSList *g;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
|
|
|
|
g_return_if_fail (GST_IS_ADAPTER (adapter));
|
|
|
|
g_return_if_fail (flush <= adapter->size);
|
|
|
|
|
gst/: Implement gst_pad_pause/start/stop_task(), take STREAM lock in task function.
Original commit message from CVS:
* gst/base/gstadapter.c: (gst_adapter_peek), (gst_adapter_flush):
* gst/base/gstbasesink.c: (gst_basesink_preroll_queue_push),
(gst_basesink_finish_preroll), (gst_basesink_chain),
(gst_basesink_loop), (gst_basesink_activate),
(gst_basesink_change_state):
* gst/base/gstbasesrc.c: (gst_basesrc_do_seek),
(gst_basesrc_get_range), (gst_basesrc_loop),
(gst_basesrc_activate):
* gst/elements/gsttee.c: (gst_tee_sink_activate):
* gst/gstpad.c: (gst_pad_dispose), (gst_real_pad_class_init),
(gst_real_pad_init), (gst_real_pad_set_property),
(gst_real_pad_get_property), (gst_pad_set_active),
(gst_pad_is_active), (gst_pad_get_query_types), (gst_pad_unlink),
(gst_pad_link_prepare), (gst_pad_link), (gst_pad_get_real_parent),
(gst_real_pad_get_caps_unlocked), (gst_pad_peer_get_caps),
(gst_pad_accept_caps), (gst_pad_get_peer), (gst_pad_realize),
(gst_pad_event_default_dispatch), (gst_pad_event_default),
(gst_pad_dispatcher), (gst_pad_query), (gst_real_pad_dispose),
(gst_pad_save_thyself), (handle_pad_block), (gst_pad_chain),
(gst_pad_push), (gst_pad_get_range), (gst_pad_pull_range),
(gst_pad_send_event), (gst_pad_start_task), (gst_pad_pause_task),
(gst_pad_stop_task):
* gst/gstpad.h:
* gst/gstqueue.c: (gst_queue_handle_sink_event), (gst_queue_chain),
(gst_queue_loop), (gst_queue_src_activate):
* gst/gsttask.c: (gst_task_init), (gst_task_set_lock),
(gst_task_get_state):
* gst/gsttask.h:
* gst/schedulers/threadscheduler.c:
(gst_thread_scheduler_task_start), (gst_thread_scheduler_func):
Implement gst_pad_pause/start/stop_task(), take STREAM lock
in task function.
Remove ACTIVE pad flag, use FLUSHING everywhere
Added _pad_chain(), _pad_get_range() to call chain/getrange
functions.
Add locks around IS_FLUSHING when reading.
Take STREAM lock in chain(), get_range() functions so plugins
don't need to take it anymore.
2005-05-25 11:50:11 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "flushing %u bytes", flush);
|
2009-05-20 20:18:16 +00:00
|
|
|
|
|
|
|
/* flushing out 0 bytes will do nothing */
|
|
|
|
if (G_UNLIKELY (flush == 0))
|
|
|
|
return;
|
|
|
|
|
|
|
|
priv = adapter->priv;
|
|
|
|
|
|
|
|
/* clear state */
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
adapter->size -= flush;
|
|
|
|
adapter->assembled_len = 0;
|
2009-05-20 20:18:16 +00:00
|
|
|
|
|
|
|
/* take skip into account */
|
|
|
|
flush += adapter->skip;
|
|
|
|
/* distance is always at least the amount of skipped bytes */
|
|
|
|
priv->distance -= adapter->skip;
|
|
|
|
|
|
|
|
g = adapter->buflist;
|
|
|
|
cur = g->data;
|
|
|
|
size = GST_BUFFER_SIZE (cur);
|
|
|
|
while (flush >= size) {
|
|
|
|
/* can skip whole buffer */
|
|
|
|
GST_LOG_OBJECT (adapter, "flushing out head buffer");
|
|
|
|
priv->distance += size;
|
|
|
|
flush -= size;
|
|
|
|
|
|
|
|
gst_buffer_unref (cur);
|
|
|
|
g = g_slist_delete_link (g, g);
|
|
|
|
|
|
|
|
if (G_UNLIKELY (g == NULL)) {
|
|
|
|
GST_LOG_OBJECT (adapter, "adapter empty now");
|
|
|
|
adapter->buflist_end = NULL;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
break;
|
|
|
|
}
|
2009-05-20 20:18:16 +00:00
|
|
|
/* there is a new head buffer, update the timestamp */
|
|
|
|
cur = g->data;
|
|
|
|
update_timestamp (adapter, cur);
|
|
|
|
size = GST_BUFFER_SIZE (cur);
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
2009-05-20 20:18:16 +00:00
|
|
|
adapter->buflist = g;
|
|
|
|
/* account for the remaining bytes */
|
|
|
|
adapter->skip = flush;
|
|
|
|
adapter->priv->distance += flush;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
|
|
|
|
2005-08-16 17:23:55 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_take:
|
|
|
|
* @adapter: a #GstAdapter
|
2005-11-09 09:48:16 +00:00
|
|
|
* @nbytes: the number of bytes to take
|
2005-08-16 17:23:55 +00:00
|
|
|
*
|
|
|
|
* Returns a freshly allocated buffer containing the first @nbytes bytes of the
|
2006-01-18 18:01:54 +00:00
|
|
|
* @adapter. The returned bytes will be flushed from the adapter.
|
2005-11-09 09:48:16 +00:00
|
|
|
*
|
libs/gst/: Documentation updates.
Original commit message from CVS:
* libs/gst/base/gstadapter.c:
* libs/gst/base/gstadapter.h:
* libs/gst/base/gstbasesink.c: (gst_base_sink_class_init),
(gst_base_sink_get_position):
* libs/gst/base/gstbasesink.h:
* libs/gst/base/gstbasesrc.c: (gst_base_src_class_init),
(gst_base_src_default_query), (gst_base_src_default_do_seek),
(gst_base_src_do_seek), (gst_base_src_perform_seek),
(gst_base_src_send_event), (gst_base_src_update_length),
(gst_base_src_get_range), (gst_base_src_loop),
(gst_base_src_start):
* libs/gst/base/gstbasesrc.h:
* libs/gst/base/gstbasetransform.h:
* libs/gst/base/gstcollectpads.h:
* libs/gst/base/gstpushsrc.c:
* libs/gst/base/gstpushsrc.h:
* libs/gst/dataprotocol/dataprotocol.c:
* libs/gst/dataprotocol/dataprotocol.h:
* libs/gst/net/gstnetclientclock.h:
* libs/gst/net/gstnettimeprovider.h:
Documentation updates.
2005-12-18 16:04:41 +00:00
|
|
|
* Caller owns returned value. g_free after usage.
|
2005-08-16 17:23:55 +00:00
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* Returns: oven-fresh hot data, or #NULL if @nbytes bytes are not available
|
2005-08-16 17:23:55 +00:00
|
|
|
*/
|
|
|
|
guint8 *
|
|
|
|
gst_adapter_take (GstAdapter * adapter, guint nbytes)
|
|
|
|
{
|
|
|
|
guint8 *data;
|
|
|
|
|
|
|
|
g_return_val_if_fail (GST_IS_ADAPTER (adapter), NULL);
|
|
|
|
g_return_val_if_fail (nbytes > 0, NULL);
|
|
|
|
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
/* we don't have enough data, return NULL. This is unlikely
|
|
|
|
* as one usually does an _available() first instead of peeking a
|
|
|
|
* random size. */
|
|
|
|
if (G_UNLIKELY (nbytes > adapter->size))
|
2005-08-16 17:23:55 +00:00
|
|
|
return NULL;
|
|
|
|
|
2009-05-20 10:48:41 +00:00
|
|
|
/* we have enough assembled data, take from there */
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
if (adapter->assembled_len >= nbytes) {
|
|
|
|
GST_LOG_OBJECT (adapter, "taking %u bytes already assembled", nbytes);
|
2009-05-20 10:48:41 +00:00
|
|
|
data = adapter->assembled_data;
|
|
|
|
/* allocate new data, assembled_len will be set to 0 in the flush below */
|
|
|
|
adapter->assembled_data = g_malloc (adapter->assembled_size);
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
} else {
|
2009-05-20 10:48:41 +00:00
|
|
|
/* we need to allocate and copy. We could potentially copy bytes from the
|
|
|
|
* assembled data before doing the copy_into */
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "taking %u bytes by collection", nbytes);
|
2009-05-20 10:48:41 +00:00
|
|
|
data = g_malloc (nbytes);
|
2009-05-19 20:13:04 +00:00
|
|
|
copy_into_unchecked (adapter, data, adapter->skip, nbytes);
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
}
|
2005-08-16 17:23:55 +00:00
|
|
|
|
|
|
|
gst_adapter_flush (adapter, nbytes);
|
|
|
|
|
|
|
|
return data;
|
|
|
|
}
|
|
|
|
|
2006-05-04 14:19:53 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_take_buffer:
|
|
|
|
* @adapter: a #GstAdapter
|
|
|
|
* @nbytes: the number of bytes to take
|
|
|
|
*
|
|
|
|
* Returns a #GstBuffer containing the first @nbytes bytes of the
|
|
|
|
* @adapter. The returned bytes will be flushed from the adapter.
|
2009-08-28 16:03:44 +00:00
|
|
|
* This function is potentially more performant than gst_adapter_take()
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
* since it can reuse the memory in pushed buffers by subbuffering
|
2006-05-04 14:19:53 +00:00
|
|
|
* or merging.
|
|
|
|
*
|
|
|
|
* Caller owns returned value. gst_buffer_unref() after usage.
|
|
|
|
*
|
|
|
|
* Since: 0.10.6
|
|
|
|
*
|
2009-08-28 16:03:44 +00:00
|
|
|
* Returns: a #GstBuffer containing the first @nbytes of the adapter,
|
2006-05-04 14:19:53 +00:00
|
|
|
* or #NULL if @nbytes bytes are not available
|
|
|
|
*/
|
|
|
|
GstBuffer *
|
|
|
|
gst_adapter_take_buffer (GstAdapter * adapter, guint nbytes)
|
|
|
|
{
|
|
|
|
GstBuffer *buffer;
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
GstBuffer *cur;
|
2009-05-19 20:13:04 +00:00
|
|
|
guint hsize, skip;
|
2006-05-04 14:19:53 +00:00
|
|
|
|
|
|
|
g_return_val_if_fail (GST_IS_ADAPTER (adapter), NULL);
|
|
|
|
g_return_val_if_fail (nbytes > 0, NULL);
|
|
|
|
|
|
|
|
GST_LOG_OBJECT (adapter, "taking buffer of %u bytes", nbytes);
|
|
|
|
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
/* we don't have enough data, return NULL. This is unlikely
|
2007-04-13 11:53:00 +00:00
|
|
|
* as one usually does an _available() first instead of grabbing a
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
* random size. */
|
|
|
|
if (G_UNLIKELY (nbytes > adapter->size))
|
|
|
|
return NULL;
|
|
|
|
|
|
|
|
cur = adapter->buflist->data;
|
2009-05-19 20:13:04 +00:00
|
|
|
skip = adapter->skip;
|
2009-04-27 08:13:01 +00:00
|
|
|
hsize = GST_BUFFER_SIZE (cur);
|
|
|
|
|
|
|
|
/* our head buffer has enough data left, return it */
|
2009-05-19 20:13:04 +00:00
|
|
|
if (skip == 0 && hsize == nbytes) {
|
2009-04-27 08:13:01 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "providing buffer of %d bytes as head buffer",
|
|
|
|
nbytes);
|
|
|
|
buffer = gst_buffer_ref (cur);
|
|
|
|
goto done;
|
2009-05-19 20:13:04 +00:00
|
|
|
} else if (hsize >= nbytes + skip) {
|
2006-11-10 10:50:19 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "providing buffer of %d bytes via sub-buffer",
|
|
|
|
nbytes);
|
2009-05-19 20:13:04 +00:00
|
|
|
buffer = gst_buffer_create_sub (cur, skip, nbytes);
|
2009-04-27 08:13:01 +00:00
|
|
|
goto done;
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
}
|
|
|
|
|
2007-04-13 11:53:00 +00:00
|
|
|
if (gst_adapter_try_to_merge_up (adapter, nbytes)) {
|
|
|
|
/* Merged something, let's try again for sub-buffering */
|
|
|
|
cur = adapter->buflist->data;
|
2009-05-19 20:13:04 +00:00
|
|
|
if (GST_BUFFER_SIZE (cur) >= nbytes + skip) {
|
2007-04-13 11:53:00 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "providing buffer of %d bytes via sub-buffer",
|
|
|
|
nbytes);
|
2009-05-19 20:13:04 +00:00
|
|
|
buffer = gst_buffer_create_sub (cur, skip, nbytes);
|
2009-04-27 08:13:01 +00:00
|
|
|
goto done;
|
2007-04-13 11:53:00 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2007-03-29 15:53:03 +00:00
|
|
|
/* we have enough assembled data, copy from there */
|
|
|
|
if (adapter->assembled_len >= nbytes) {
|
|
|
|
GST_LOG_OBJECT (adapter, "taking %u bytes already assembled", nbytes);
|
2009-05-20 10:48:41 +00:00
|
|
|
buffer = gst_buffer_new ();
|
|
|
|
GST_BUFFER_SIZE (buffer) = nbytes;
|
|
|
|
GST_BUFFER_DATA (buffer) = adapter->assembled_data;
|
|
|
|
GST_BUFFER_MALLOCDATA (buffer) = adapter->assembled_data;
|
|
|
|
/* flush will set the assembled_len to 0 */
|
|
|
|
adapter->assembled_data = g_malloc (adapter->assembled_size);
|
2007-03-29 15:53:03 +00:00
|
|
|
} else {
|
2009-05-20 10:48:41 +00:00
|
|
|
/* we need to allocate and copy. We could potentially copy bytes from the
|
|
|
|
* assembled data before doing the copy_into */
|
|
|
|
buffer = gst_buffer_new_and_alloc (nbytes);
|
2007-03-29 15:53:03 +00:00
|
|
|
GST_LOG_OBJECT (adapter, "taking %u bytes by collection", nbytes);
|
2009-05-19 20:13:04 +00:00
|
|
|
copy_into_unchecked (adapter, GST_BUFFER_DATA (buffer), skip, nbytes);
|
2007-03-29 15:53:03 +00:00
|
|
|
}
|
2006-05-04 14:19:53 +00:00
|
|
|
|
2009-04-27 08:13:01 +00:00
|
|
|
done:
|
2007-03-29 15:53:03 +00:00
|
|
|
gst_adapter_flush (adapter, nbytes);
|
2006-05-04 14:19:53 +00:00
|
|
|
|
|
|
|
return buffer;
|
|
|
|
}
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
/**
|
|
|
|
* gst_adapter_available:
|
|
|
|
* @adapter: a #GstAdapter
|
|
|
|
*
|
2005-10-15 15:30:24 +00:00
|
|
|
* Gets the maximum amount of bytes available, that is it returns the maximum
|
|
|
|
* value that can be supplied to gst_adapter_peek() without that function
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
* returning NULL.
|
|
|
|
*
|
2005-11-09 09:48:16 +00:00
|
|
|
* Returns: number of bytes available in @adapter
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*/
|
|
|
|
guint
|
|
|
|
gst_adapter_available (GstAdapter * adapter)
|
|
|
|
{
|
|
|
|
g_return_val_if_fail (GST_IS_ADAPTER (adapter), 0);
|
|
|
|
|
|
|
|
return adapter->size;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_adapter_available_fast:
|
|
|
|
* @adapter: a #GstAdapter
|
|
|
|
*
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
* Gets the maximum number of bytes that are immediately available without
|
2009-08-28 16:03:44 +00:00
|
|
|
* requiring any expensive operations (like copying the data into a
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
* temporary buffer).
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*
|
2009-08-28 16:03:44 +00:00
|
|
|
* Returns: number of bytes that are available in @adapter without expensive
|
Do some optimisation work in GstAdapter to avoid copies in more cases.
Original commit message from CVS:
* Makefile.am:
* configure.ac:
* libs/gst/base/gstadapter.c: (gst_adapter_clear),
(gst_adapter_push), (gst_adapter_peek_into), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_take), (gst_adapter_take_buffer):
* libs/gst/base/gstadapter.h:
* tests/check/libs/adapter.c: (create_and_fill_adapter),
(GST_START_TEST), (gst_adapter_suite):
* tests/examples/Makefile.am:
Do some optimisation work in GstAdapter to avoid copies in more cases.
It could still do slightly better by merging buffers when
gst_buffer_is_span_fast is true, but is already faster.
Also, avoid traversing a single-linked list to append each incoming
buffer inside the adapter.
Add simple test app that times the adapter behaviour in different
situations, and extend the unit test to check that bytes enter and
exit the adapter in their original order.
2006-11-09 14:37:38 +00:00
|
|
|
* operations
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
*/
|
|
|
|
guint
|
|
|
|
gst_adapter_available_fast (GstAdapter * adapter)
|
|
|
|
{
|
2008-05-07 09:47:27 +00:00
|
|
|
GstBuffer *first;
|
|
|
|
guint size;
|
|
|
|
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
g_return_val_if_fail (GST_IS_ADAPTER (adapter), 0);
|
|
|
|
|
2006-05-04 14:19:53 +00:00
|
|
|
/* no buffers, we have no data */
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
if (!adapter->buflist)
|
|
|
|
return 0;
|
2006-05-04 14:19:53 +00:00
|
|
|
|
|
|
|
/* some stuff we already assembled */
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
if (adapter->assembled_len)
|
|
|
|
return adapter->assembled_len;
|
2006-05-04 14:19:53 +00:00
|
|
|
|
2008-05-07 09:47:27 +00:00
|
|
|
/* take the first buffer and its size */
|
|
|
|
first = GST_BUFFER_CAST (adapter->buflist->data);
|
|
|
|
size = GST_BUFFER_SIZE (first);
|
|
|
|
|
2009-05-19 20:13:04 +00:00
|
|
|
/* we can quickly get the (remaining) data of the first buffer */
|
2008-05-07 09:47:27 +00:00
|
|
|
return size - adapter->skip;
|
gst/base/: Ported and added adapter to the base classes.
Original commit message from CVS:
* gst/base/Makefile.am:
* gst/base/gstadapter.c: (gst_adapter_base_init),
(gst_adapter_class_init), (gst_adapter_init),
(gst_adapter_dispose), (gst_adapter_finalize), (gst_adapter_new),
(gst_adapter_clear), (gst_adapter_push), (gst_adapter_peek),
(gst_adapter_flush), (gst_adapter_available),
(gst_adapter_available_fast):
* gst/base/gstadapter.h:
Ported and added adapter to the base classes.
2005-05-18 09:55:43 +00:00
|
|
|
}
|
2009-05-13 14:09:20 +00:00
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_adapter_prev_timestamp:
|
|
|
|
* @adapter: a #GstAdapter
|
|
|
|
* @distance: pointer to location for distance or NULL
|
|
|
|
*
|
|
|
|
* Get the timestamp that was before the current byte in the adapter. When
|
|
|
|
* @distance is given, the amount of bytes between the timestamp and the current
|
|
|
|
* position is returned.
|
|
|
|
*
|
|
|
|
* The timestamp is reset to GST_CLOCK_TIME_NONE when the adapter is first
|
|
|
|
* created or when it is cleared.
|
|
|
|
*
|
|
|
|
* Returns: The previously seen timestamp.
|
|
|
|
*
|
|
|
|
* Since: 0.10.24
|
|
|
|
*/
|
|
|
|
GstClockTime
|
|
|
|
gst_adapter_prev_timestamp (GstAdapter * adapter, guint64 * distance)
|
|
|
|
{
|
|
|
|
g_return_val_if_fail (GST_IS_ADAPTER (adapter), GST_CLOCK_TIME_NONE);
|
|
|
|
|
|
|
|
if (distance)
|
2009-05-13 19:35:23 +00:00
|
|
|
*distance = adapter->priv->distance;
|
2009-05-13 14:09:20 +00:00
|
|
|
|
2009-05-13 19:35:23 +00:00
|
|
|
return adapter->priv->timestamp;
|
2009-05-13 14:09:20 +00:00
|
|
|
}
|
2009-05-19 22:37:53 +00:00
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_adapter_masked_scan_uint32:
|
|
|
|
* @adapter: a #GstAdapter
|
|
|
|
* @mask: mask to apply to data before matching against @pattern
|
|
|
|
* @pattern: pattern to match (after mask is applied)
|
|
|
|
* @offset: offset into the adapter data from which to start scanning, returns
|
|
|
|
* the last scanned position.
|
|
|
|
* @size: number of bytes to scan from offset
|
|
|
|
*
|
|
|
|
* Scan for pattern @pattern with applied mask @mask in the adapter data,
|
2009-08-28 16:03:44 +00:00
|
|
|
* starting from offset @offset.
|
2009-05-28 20:02:21 +00:00
|
|
|
*
|
|
|
|
* The bytes in @pattern and @mask are interpreted left-to-right, regardless
|
|
|
|
* of endianness. All four bytes of the pattern must be present in the
|
|
|
|
* adapter for it to match, even if the first or last bytes are masked out.
|
2009-05-19 22:37:53 +00:00
|
|
|
*
|
|
|
|
* It is an error to call this function without making sure that there is
|
|
|
|
* enough data (offset+size bytes) in the adapter.
|
|
|
|
*
|
|
|
|
* Returns: offset of the first match, or -1 if no match was found.
|
|
|
|
*
|
2009-05-28 20:02:21 +00:00
|
|
|
* Example:
|
|
|
|
* <programlisting>
|
|
|
|
* // Assume the adapter contains 0x00 0x01 0x02 ... 0xfe 0xff
|
2009-08-28 16:03:44 +00:00
|
|
|
*
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffffffff, 0x00010203, 0, 256);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns 0
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffffffff, 0x00010203, 1, 255);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns -1
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffffffff, 0x01020304, 1, 255);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns 1
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffff, 0x0001, 0, 256);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns -1
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffff, 0x0203, 0, 256);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns 0
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffff0000, 0x02030000, 0, 256);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns 2
|
2009-07-16 13:17:03 +00:00
|
|
|
* gst_adapter_masked_scan_uint32 (adapter, 0xffff0000, 0x02030000, 0, 4);
|
2009-05-28 20:02:21 +00:00
|
|
|
* // -> returns -1
|
|
|
|
* </programlisting>
|
|
|
|
*
|
2009-05-19 22:37:53 +00:00
|
|
|
* Since: 0.10.24
|
|
|
|
*/
|
|
|
|
guint
|
|
|
|
gst_adapter_masked_scan_uint32 (GstAdapter * adapter, guint32 mask,
|
|
|
|
guint32 pattern, guint offset, guint size)
|
|
|
|
{
|
|
|
|
GSList *g;
|
|
|
|
guint skip, bsize, i;
|
|
|
|
guint32 state;
|
|
|
|
guint8 *bdata;
|
2009-05-20 08:27:43 +00:00
|
|
|
GstBuffer *buf;
|
2009-05-19 22:37:53 +00:00
|
|
|
|
|
|
|
g_return_val_if_fail (size > 0, -1);
|
|
|
|
g_return_val_if_fail (offset + size <= adapter->size, -1);
|
|
|
|
|
|
|
|
/* we can't find the pattern with less than 4 bytes */
|
|
|
|
if (G_UNLIKELY (size < 4))
|
|
|
|
return -1;
|
|
|
|
|
|
|
|
skip = offset + adapter->skip;
|
|
|
|
|
|
|
|
/* first step, do skipping and position on the first buffer */
|
|
|
|
g = adapter->buflist;
|
2009-05-20 08:27:43 +00:00
|
|
|
buf = g->data;
|
|
|
|
bsize = GST_BUFFER_SIZE (buf);
|
2009-05-20 09:12:43 +00:00
|
|
|
while (G_UNLIKELY (skip >= bsize)) {
|
2009-05-19 22:37:53 +00:00
|
|
|
skip -= bsize;
|
|
|
|
g = g_slist_next (g);
|
2009-05-20 08:27:43 +00:00
|
|
|
buf = g->data;
|
|
|
|
bsize = GST_BUFFER_SIZE (buf);
|
2009-05-19 22:37:53 +00:00
|
|
|
}
|
|
|
|
/* get the data now */
|
|
|
|
bsize -= skip;
|
2009-05-20 08:27:43 +00:00
|
|
|
bdata = GST_BUFFER_DATA (buf) + skip;
|
2009-05-28 20:02:21 +00:00
|
|
|
skip = 0;
|
2009-05-19 22:37:53 +00:00
|
|
|
|
|
|
|
/* set the state to something that does not match */
|
|
|
|
state = ~pattern;
|
|
|
|
|
|
|
|
/* now find data */
|
2009-05-20 09:12:43 +00:00
|
|
|
do {
|
2009-05-19 22:37:53 +00:00
|
|
|
bsize = MIN (bsize, size);
|
2009-05-20 09:36:11 +00:00
|
|
|
for (i = 0; i < bsize; i++) {
|
|
|
|
state = ((state << 8) | bdata[i]);
|
2009-05-28 20:02:21 +00:00
|
|
|
if (G_UNLIKELY ((state & mask) == pattern)) {
|
|
|
|
/* we have a match but we need to have skipped at
|
|
|
|
* least 4 bytes to fill the state. */
|
|
|
|
if (G_LIKELY (skip + i >= 3))
|
|
|
|
return offset + skip + i - 3;
|
|
|
|
}
|
2009-05-19 22:37:53 +00:00
|
|
|
}
|
|
|
|
size -= bsize;
|
2009-05-20 09:12:43 +00:00
|
|
|
if (size == 0)
|
|
|
|
break;
|
|
|
|
|
|
|
|
/* nothing found yet, go to next buffer */
|
2009-05-28 20:02:21 +00:00
|
|
|
skip += bsize;
|
2009-05-20 09:12:43 +00:00
|
|
|
g = g_slist_next (g);
|
|
|
|
buf = g->data;
|
|
|
|
bsize = GST_BUFFER_SIZE (buf);
|
|
|
|
bdata = GST_BUFFER_DATA (buf);
|
|
|
|
} while (TRUE);
|
|
|
|
|
2009-05-19 22:37:53 +00:00
|
|
|
/* nothing found */
|
2009-05-20 09:36:11 +00:00
|
|
|
return -1;
|
2009-05-19 22:37:53 +00:00
|
|
|
}
|