newbuf = gst_buffer_new ();
gst_buffer_append_memory (newbuf,
gst_memory_new_wrapped (free_func ? 0 : GST_MEMORY_FLAG_READONLY,
- data, free_func, offset + size, offset, size));
+ data, offset + size, offset, size, data, free_func));
return newbuf;
}
GstMemory mem;
gsize slice_size;
guint8 *data;
- GFreeFunc free_func;
+ gpointer user_data;
+ GDestroyNotify notify;
} GstMemoryDefault;
/* the default allocator */
static void
_default_mem_init (GstMemoryDefault * mem, GstMemoryFlags flags,
GstMemory * parent, gsize slice_size, gpointer data,
- GFreeFunc free_func, gsize maxsize, gsize offset, gsize size)
+ gsize maxsize, gsize offset, gsize size, gpointer user_data,
+ GDestroyNotify notify)
{
mem->mem.allocator = _default_mem_impl;
mem->mem.flags = flags;
mem->mem.size = size;
mem->slice_size = slice_size;
mem->data = data;
- mem->free_func = free_func;
+ mem->user_data = user_data;
+ mem->notify = notify;
GST_CAT_DEBUG (GST_CAT_MEMORY, "new memory %p", mem);
}
/* create a new memory block that manages the given memory */
static GstMemoryDefault *
_default_mem_new (GstMemoryFlags flags, GstMemory * parent, gpointer data,
- GFreeFunc free_func, gsize maxsize, gsize offset, gsize size)
+ gsize maxsize, gsize offset, gsize size, gpointer user_data,
+ GDestroyNotify notify)
{
GstMemoryDefault *mem;
gsize slice_size;
mem = g_slice_alloc (slice_size);
_default_mem_init (mem, flags, parent, slice_size,
- data, free_func, maxsize, offset, size);
+ data, maxsize, offset, size, user_data, notify);
return mem;
}
if ((aoffset = ((guintptr) data & align)))
aoffset = (align + 1) - aoffset;
- _default_mem_init (mem, 0, NULL, slice_size, data, NULL, maxsize,
- aoffset + offset, size);
+ _default_mem_init (mem, 0, NULL, slice_size, data, maxsize,
+ aoffset + offset, size, NULL, NULL);
return mem;
}
if (mem->mem.parent)
gst_memory_unref (mem->mem.parent);
- if (mem->free_func)
- mem->free_func (mem->data);
+ if (mem->notify)
+ mem->notify (mem->user_data);
g_slice_free1 (mem->slice_size, mem);
}
size = mem->mem.size - offset;
sub =
- _default_mem_new (parent->flags, parent, mem->data, NULL,
- mem->mem.maxsize, mem->mem.offset + offset, size);
+ _default_mem_new (parent->flags, parent, mem->data,
+ mem->mem.maxsize, mem->mem.offset + offset, size, NULL, NULL);
return sub;
}
* gst_memory_new_wrapped:
* @flags: #GstMemoryFlags
* @data: data to wrap
- * @free_func: function to free @data
* @maxsize: allocated size of @data
* @offset: offset in @data
* @size: size of valid data
+ * @user_data: user_data
+ * @notify: called with @user_data when the memory is freed
*
* Allocate a new memory block that wraps the given @data.
*
*/
GstMemory *
gst_memory_new_wrapped (GstMemoryFlags flags, gpointer data,
- GFreeFunc free_func, gsize maxsize, gsize offset, gsize size)
+ gsize maxsize, gsize offset, gsize size, gpointer user_data,
+ GDestroyNotify notify)
{
GstMemoryDefault *mem;
g_return_val_if_fail (data != NULL, NULL);
g_return_val_if_fail (offset + size <= maxsize, NULL);
- mem = _default_mem_new (flags, NULL, data, free_func, maxsize, offset, size);
+ mem =
+ _default_mem_new (flags, NULL, data, maxsize, offset, size, user_data,
+ notify);
#ifndef GST_DISABLE_TRACE
_gst_alloc_trace_new (_gst_memory_trace, mem);
GstMemory * gst_allocator_alloc (GstAllocator * allocator,
gsize maxsize, gsize align);
-GstMemory * gst_memory_new_wrapped (GstMemoryFlags flags, gpointer data, GFreeFunc free_func,
- gsize maxsize, gsize offset, gsize size);
+GstMemory * gst_memory_new_wrapped (GstMemoryFlags flags, gpointer data, gsize maxsize,
+ gsize offset, gsize size, gpointer user_data,
+ GDestroyNotify notify);
/* refcounting */
GstMemory * gst_memory_ref (GstMemory *mem);
buffer = gst_buffer_new ();
gst_buffer_take_memory (buffer, -1,
- gst_memory_new_wrapped (0, data, g_free, nbytes, 0, nbytes));
+ gst_memory_new_wrapped (0, data, nbytes, 0, nbytes, data, g_free));
done:
gst_adapter_flush_unchecked (adapter, nbytes);
tmpbuf = gst_buffer_new ();
gst_buffer_take_memory (tmpbuf, -1,
gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY |
- GST_MEMORY_FLAG_NO_SHARE, (gpointer) data, NULL, av, 0, av));
+ GST_MEMORY_FLAG_NO_SHARE, (gpointer) data, av, 0, av, NULL, NULL));
/* keep the adapter mapped, so keep track of what has to be flushed */
ret = gst_base_parse_handle_buffer (parse, tmpbuf, &skip, &flush);
buffer = gst_buffer_new ();
if (data != NULL) {
gst_buffer_take_memory (buffer, -1,
- gst_memory_new_wrapped (0, data, g_free, size, 0, size));
+ gst_memory_new_wrapped (0, data, size, 0, size, data, g_free));
}
return buffer;
gst_fake_src_prepare_buffer (src, data, size);
gst_buffer_take_memory (buf, -1,
- gst_memory_new_wrapped (0, data, g_free, size, 0, size));
+ gst_memory_new_wrapped (0, data, size, 0, size, data, g_free));
}
return buf;
/* assign some read-only data to the new buffer */
gst_buffer_take_memory (buf, -1,
gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY,
- (gpointer) ro_memory, NULL,
- sizeof (ro_memory), 0, sizeof (ro_memory)));
+ (gpointer) ro_memory, sizeof (ro_memory),
+ 0, sizeof (ro_memory), NULL, NULL));
return buf;
}
/* assign some read-only data to the new memory */
mem = gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY,
- (gpointer) ro_memory, NULL, sizeof (ro_memory), 0, sizeof (ro_memory));
+ (gpointer) ro_memory, sizeof (ro_memory), 0, sizeof (ro_memory), NULL,
+ NULL);
fail_unless (GST_MEMORY_IS_READONLY (mem));
return mem;
GstMapInfo info;
gst_buffer_take_memory (buffer, -1,
- gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY, data, NULL, 4, 0, 4));
+ gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY, data, 4, 0, 4, NULL,
+ NULL));
fail_unless (gst_bit_reader_get_bits_uint8 (&reader, &x, 8));
fail_unless_equals_int (x, 0x01);
GstMapInfo info;
gst_buffer_take_memory (buffer, -1,
- gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY, data, NULL, 4, 0, 4));
+ gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY, data, 4, 0, 4, NULL,
+ NULL));
fail_unless (gst_byte_reader_get_uint8 (&reader, &x));
fail_unless_equals_int (x, 0x01);
gst_buffer_take_memory (buf, -1,
gst_memory_new_wrapped (GST_MEMORY_FLAG_READONLY,
- (gpointer) vorbisid, NULL, 30, 0, 30));
+ (gpointer) vorbisid, 30, 0, 30, NULL, NULL));
caps = gst_type_find_helper_for_buffer (NULL, buf, NULL);
fail_unless (caps != NULL);