mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-15 22:01:27 +00:00
Code Issues 1 Projects Releases Wiki Activity

Added a mutex around the mem_chunck alloc routines

Browse source 
Original commit message from CVS:
Added a mutex around the mem_chunck alloc routines
This commit is contained in:
Wim Taymans 2001-01-06 18:08:04 +00:00
parent 45d5c57cb9
commit f130a170c2
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
gst/gstbuffer.c
View file

@ -28,12 +28,15 @@
GMemChunk *_gst_buffer_chunk; GMemChunk *_gst_buffer_chunk;
GMutex *chunck_lock;
void void
_gst_buffer_initialize (void) _gst_buffer_initialize (void)
{ {
_gst_buffer_chunk = g_mem_chunk_new ("GstBuffer", sizeof(GstBuffer), _gst_buffer_chunk = g_mem_chunk_new ("GstBuffer", sizeof(GstBuffer),
sizeof(GstBuffer) * 16, G_ALLOC_AND_FREE); sizeof(GstBuffer) * 16, G_ALLOC_AND_FREE);
chunck_lock = g_mutex_new ();
} }
/** /**
@ -48,7 +51,9 @@ gst_buffer_new(void)
{ {
GstBuffer *buffer; GstBuffer *buffer;
g_mutex_lock (chunck_lock);
buffer = g_mem_chunk_alloc (_gst_buffer_chunk); buffer = g_mem_chunk_alloc (_gst_buffer_chunk);
g_mutex_unlock (chunck_lock);
GST_INFO (GST_CAT_BUFFER,"creating new buffer %p",buffer); GST_INFO (GST_CAT_BUFFER,"creating new buffer %p",buffer);
// g_print("allocating new mutex\n"); // g_print("allocating new mutex\n");
@ -107,7 +112,9 @@ gst_buffer_create_sub (GstBuffer *parent,
g_return_val_if_fail (size > 0, NULL); g_return_val_if_fail (size > 0, NULL);
g_return_val_if_fail ((offset+size) <= parent->size, NULL); g_return_val_if_fail ((offset+size) <= parent->size, NULL);
g_mutex_lock (chunck_lock);
buffer = g_mem_chunk_alloc (_gst_buffer_chunk); buffer = g_mem_chunk_alloc (_gst_buffer_chunk);
g_mutex_unlock (chunck_lock);
GST_INFO (GST_CAT_BUFFER,"creating new subbuffer %p from parent %p", buffer, parent); GST_INFO (GST_CAT_BUFFER,"creating new subbuffer %p from parent %p", buffer, parent);
buffer->lock = g_mutex_new (); buffer->lock = g_mutex_new ();
@ -228,7 +235,9 @@ void gst_buffer_destroy (GstBuffer *buffer)
//g_print("freed mutex\n"); //g_print("freed mutex\n");
// remove it entirely from memory // remove it entirely from memory
g_mutex_lock (chunck_lock);
g_mem_chunk_free (_gst_buffer_chunk,buffer); g_mem_chunk_free (_gst_buffer_chunk,buffer);
g_mutex_unlock (chunck_lock);
} }
/** /**