1 /*****************************************************************************
2 * block.c: Data blocks management functions
3 *****************************************************************************
4 * Copyright (C) 2003-2004 VideoLAN
5 * $Id: block.c,v 1.7 2004/02/25 17:48:52 fenrir Exp $
7 * Authors: Laurent Aimar <fenrir@videolan.org>
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA.
22 *****************************************************************************/
24 /*****************************************************************************
26 *****************************************************************************/
31 #include "vlc_block.h"
38 uint8_t *p_allocated_buffer;
39 int i_allocated_buffer;
41 vlc_bool_t b_modify; /* has it been put in modified state */
42 int i_duplicated; /* how many times has the content been
47 static void BlockRelease( block_t *p_block )
49 vlc_mutex_lock( &p_block->p_sys->lock );
51 p_block->p_sys->i_duplicated--;
52 if( p_block->p_sys->i_duplicated < 0 )
54 vlc_mutex_unlock( &p_block->p_sys->lock );
55 vlc_mutex_destroy( &p_block->p_sys->lock );
56 free( p_block->p_sys->p_allocated_buffer );
57 free( p_block->p_sys );
63 vlc_mutex_unlock( &p_block->p_sys->lock );
67 static block_t *__BlockDupContent( block_t *p_block )
71 p_dup = block_New( p_block->p_manager, p_block->i_buffer );
72 memcpy( p_dup->p_buffer, p_block->p_buffer, p_block->i_buffer );
73 p_dup->i_flags = p_block->i_flags;
74 p_dup->i_pts = p_block->i_pts;
75 p_dup->i_dts = p_block->i_dts;
80 static block_t *BlockModify( block_t *p_block, vlc_bool_t b_will_modify )
82 block_t *p_mod = p_block; /* by default */
84 vlc_mutex_lock( &p_block->p_sys->lock );
86 if( p_block->p_sys->b_modify == b_will_modify )
88 vlc_mutex_unlock( &p_block->p_sys->lock );
92 if( p_block->p_sys->i_duplicated == 0 )
94 p_block->p_sys->b_modify = b_will_modify;
95 vlc_mutex_unlock( &p_block->p_sys->lock );
99 /* FIXME we could avoid that
100 * we just need to create a new p_sys with new mem FIXME */
101 p_mod = __BlockDupContent( p_block );
102 vlc_mutex_unlock( &p_block->p_sys->lock );
104 BlockRelease( p_block );
109 static block_t *BlockDuplicate( block_t *p_block )
113 vlc_mutex_lock( &p_block->p_sys->lock );
114 if( !p_block->p_sys->b_modify )
116 p_block->p_sys->i_duplicated++;
117 vlc_mutex_unlock( &p_block->p_sys->lock );
118 p_dup = block_NewEmpty();
119 memcpy( p_dup, p_block, sizeof( block_t ) );
120 p_dup->p_next = NULL;
123 p_dup = __BlockDupContent( p_block );
124 vlc_mutex_unlock( &p_block->p_sys->lock );
129 static block_t *BlockRealloc( block_t *p_block, int i_prebody, int i_body )
132 vlc_mutex_lock( &p_block->p_sys->lock );
133 if( i_prebody < 0 || p_block->p_buffer - i_prebody >
134 p_block->p_sys->p_allocated_buffer )
136 p_block->p_buffer -= i_prebody;
137 p_block->i_buffer += i_prebody;
141 p_block->p_buffer + i_body < p_block->p_sys->p_allocated_buffer +
142 p_block->p_sys->i_allocated_buffer )
144 p_block->i_buffer = i_body;
147 vlc_mutex_unlock( &p_block->p_sys->lock );
151 block_t *p_rea = block_New( p_block->p_manager, i_prebody + i_body );
153 memcpy( &p_rea->p_buffer[i_prebody], p_block->p_buffer,
162 block_t *p_rea = BlockModify( p_block, VLC_TRUE );
164 i_start = p_rea->p_buffer - p_rea->p_sys->p_allocated_buffer;
166 p_rea->p_sys->i_allocated_buffer += i_body - p_rea->i_buffer;
167 p_rea->p_sys->p_allocated_buffer =
168 realloc( p_rea->p_sys->p_allocated_buffer,
169 p_rea->p_sys->i_allocated_buffer );
171 p_rea->p_buffer = &p_rea->p_sys->p_allocated_buffer[i_start];
172 p_rea->i_buffer = i_body;
180 /*****************************************************************************
181 * Standard block management
183 *****************************************************************************/
184 /* to be used by other block management */
185 block_t *block_NewEmpty( void )
189 p_block = malloc( sizeof( block_t ) );
190 memset( p_block, 0, sizeof( block_t ) );
192 p_block->p_next = NULL;
193 p_block->i_flags = 0;
196 p_block->i_length = 0;
198 p_block->i_buffer = 0;
199 p_block->p_buffer = NULL;
201 p_block->pf_release = NULL;
202 p_block->pf_duplicate = NULL;
203 p_block->pf_modify = NULL;
204 p_block->pf_realloc = NULL;
206 p_block->p_manager = NULL;
207 p_block->p_sys = NULL;
211 block_t *__block_New( vlc_object_t *p_obj, int i_size )
216 p_block = block_NewEmpty();
218 p_block->i_buffer = i_size;
221 p_block->p_buffer = malloc( i_size );
224 p_block->pf_release = BlockRelease;
225 p_block->pf_duplicate = BlockDuplicate;
226 p_block->pf_modify = BlockModify;
227 p_block->pf_realloc = BlockRealloc;
229 /* that should be ok (no comunication between multiple p_vlc) */
230 p_block->p_manager = VLC_OBJECT( p_obj->p_vlc );
232 p_block->p_sys = p_sys = malloc( sizeof( block_sys_t ) );
233 vlc_mutex_init( p_obj, &p_sys->lock );
234 p_sys->p_allocated_buffer = p_block->p_buffer;
235 p_sys->i_allocated_buffer = p_block->i_buffer;
236 p_sys->i_duplicated = 0;
237 p_sys->b_modify = VLC_TRUE;
242 void block_ChainAppend( block_t **pp_list, block_t *p_block )
245 if( *pp_list == NULL )
251 block_t *p = *pp_list;
261 void block_ChainRelease( block_t *p_block )
266 p_next = p_block->p_next;
267 p_block->pf_release( p_block );
272 int block_ChainExtract( block_t *p_list, void *p_data, int i_max )
278 for( b = p_list; b != NULL; b = b->p_next )
282 i_copy = __MIN( i_max, b->i_buffer );
285 memcpy( p, b->p_buffer, i_copy );
299 block_t *block_ChainGather( block_t *p_list )
304 if( p_list->p_next == NULL )
306 /* only one, so no need */
310 for( b = p_list; b != NULL; b = b->p_next )
312 i_total += b->i_buffer;
315 g = block_New( p_list->p_manager, i_total );
316 block_ChainExtract( p_list, g->p_buffer, g->i_buffer );
318 g->i_flags = p_list->i_flags;
319 g->i_pts = p_list->i_pts;
320 g->i_dts = p_list->i_dts;
323 block_ChainRelease( p_list );
327 /*****************************************************************************
328 * block_fifo_t management
329 *****************************************************************************/
330 block_fifo_t *__block_FifoNew( vlc_object_t *p_obj )
332 block_fifo_t *p_fifo;
334 p_fifo = malloc( sizeof( vlc_object_t ) );
335 vlc_mutex_init( p_obj, &p_fifo->lock );
336 vlc_cond_init( p_obj, &p_fifo->wait );
338 p_fifo->p_first = NULL;
339 p_fifo->pp_last = &p_fifo->p_first;
344 void block_FifoRelease( block_fifo_t *p_fifo )
346 block_FifoEmpty( p_fifo );
347 vlc_cond_destroy( &p_fifo->wait );
348 vlc_mutex_destroy( &p_fifo->lock );
352 void block_FifoEmpty( block_fifo_t *p_fifo )
356 vlc_mutex_lock( &p_fifo->lock );
357 for( b = p_fifo->p_first; b != NULL; )
367 p_fifo->p_first = NULL;
368 p_fifo->pp_last = &p_fifo->p_first;
369 vlc_mutex_unlock( &p_fifo->lock );
372 int block_FifoPut( block_fifo_t *p_fifo, block_t *p_block )
375 vlc_mutex_lock( &p_fifo->lock );
379 i_size += p_block->i_buffer;
381 *p_fifo->pp_last = p_block;
382 p_fifo->pp_last = &p_block->p_next;
385 p_block = p_block->p_next;
389 /* warn there is data in this fifo */
390 vlc_cond_signal( &p_fifo->wait );
391 vlc_mutex_unlock( &p_fifo->lock );
396 block_t *block_FifoGet( block_fifo_t *p_fifo )
400 vlc_mutex_lock( &p_fifo->lock );
402 if( p_fifo->p_first == NULL )
404 vlc_cond_wait( &p_fifo->wait, &p_fifo->lock );
409 p_fifo->p_first = b->p_next;
412 if( p_fifo->p_first == NULL )
414 p_fifo->pp_last = &p_fifo->p_first;
417 vlc_mutex_unlock( &p_fifo->lock );
423 block_t *block_FifoShow( block_fifo_t *p_fifo )
427 vlc_mutex_lock( &p_fifo->lock );
429 if( p_fifo->p_first == NULL )
431 vlc_cond_wait( &p_fifo->wait, &p_fifo->lock );
436 vlc_mutex_unlock( &p_fifo->lock );