1 /*****************************************************************************
2 * block.c: Data blocks management functions
3 *****************************************************************************
4 * Copyright (C) 2003 VideoLAN
5 * $Id: block.c,v 1.5 2003/11/22 14:42:47 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->b_frame_display = p_block->b_frame_display;
74 p_dup->b_frame_start = p_block->b_frame_start;
75 p_dup->i_pts = p_block->i_pts;
76 p_dup->i_dts = p_block->i_dts;
77 p_dup->b_discontinuity = p_block->b_discontinuity;
82 static block_t *BlockModify( block_t *p_block, vlc_bool_t b_will_modify )
84 block_t *p_mod = p_block; /* by default */
86 vlc_mutex_lock( &p_block->p_sys->lock );
88 if( p_block->p_sys->b_modify == b_will_modify )
90 vlc_mutex_unlock( &p_block->p_sys->lock );
94 if( p_block->p_sys->i_duplicated == 0 )
96 p_block->p_sys->b_modify = b_will_modify;
97 vlc_mutex_unlock( &p_block->p_sys->lock );
101 /* FIXME we could avoid that
102 * we just need to create a new p_sys with new mem FIXME */
103 p_mod = __BlockDupContent( p_block );
104 vlc_mutex_unlock( &p_block->p_sys->lock );
106 BlockRelease( p_block );
111 static block_t *BlockDuplicate( block_t *p_block )
115 vlc_mutex_lock( &p_block->p_sys->lock );
116 if( !p_block->p_sys->b_modify )
118 p_block->p_sys->i_duplicated++;
119 vlc_mutex_unlock( &p_block->p_sys->lock );
120 p_dup = block_NewEmpty();
121 memcpy( p_dup, p_block, sizeof( block_t ) );
122 p_dup->p_next = NULL;
125 p_dup = __BlockDupContent( p_block );
126 vlc_mutex_unlock( &p_block->p_sys->lock );
131 static block_t *BlockRealloc( block_t *p_block, int i_prebody, int i_body )
134 vlc_mutex_lock( &p_block->p_sys->lock );
135 if( i_prebody < 0 || p_block->p_buffer - i_prebody >
136 p_block->p_sys->p_allocated_buffer )
138 p_block->p_buffer -= i_prebody;
139 p_block->i_buffer += i_prebody;
143 p_block->p_buffer + i_body < p_block->p_sys->p_allocated_buffer +
144 p_block->p_sys->i_allocated_buffer )
146 p_block->i_buffer = i_body;
149 vlc_mutex_unlock( &p_block->p_sys->lock );
153 block_t *p_rea = block_New( p_block->p_manager, i_prebody + i_body );
155 memcpy( &p_rea->p_buffer[i_prebody], p_block->p_buffer,
164 block_t *p_rea = BlockModify( p_block, VLC_TRUE );
166 i_start = p_rea->p_buffer - p_rea->p_sys->p_allocated_buffer;
168 p_rea->p_sys->i_allocated_buffer += i_body - p_rea->i_buffer;
169 p_rea->p_sys->p_allocated_buffer =
170 realloc( p_rea->p_sys->p_allocated_buffer,
171 p_rea->p_sys->i_allocated_buffer );
173 p_rea->p_buffer = &p_rea->p_sys->p_allocated_buffer[i_start];
174 p_rea->i_buffer = i_body;
182 /*****************************************************************************
183 * Standard block management
185 *****************************************************************************/
186 /* to be used by other block management */
187 block_t *block_NewEmpty( void )
191 p_block = malloc( sizeof( block_t ) );
192 memset( p_block, 0, sizeof( block_t ) );
194 p_block->p_next = NULL;
195 p_block->b_frame_display= VLC_TRUE;
196 p_block->b_frame_start = VLC_FALSE;
199 p_block->i_length = 0;
201 p_block->b_discontinuity= VLC_FALSE;
203 p_block->i_buffer = 0;
204 p_block->p_buffer = NULL;
206 p_block->pf_release = NULL;
207 p_block->pf_duplicate = NULL;
208 p_block->pf_modify = NULL;
209 p_block->pf_realloc = NULL;
211 p_block->p_manager = NULL;
212 p_block->p_sys = NULL;
216 block_t *__block_New( vlc_object_t *p_obj, int i_size )
221 p_block = block_NewEmpty();
223 p_block->i_buffer = i_size;
226 p_block->p_buffer = malloc( i_size );
229 p_block->pf_release = BlockRelease;
230 p_block->pf_duplicate = BlockDuplicate;
231 p_block->pf_modify = BlockModify;
232 p_block->pf_realloc = BlockRealloc;
234 /* that should be ok (no comunication between multiple p_vlc) */
235 p_block->p_manager = VLC_OBJECT( p_obj->p_vlc );
237 p_block->p_sys = p_sys = malloc( sizeof( block_sys_t ) );
238 vlc_mutex_init( p_obj, &p_sys->lock );
239 p_sys->p_allocated_buffer = p_block->p_buffer;
240 p_sys->i_allocated_buffer = p_block->i_buffer;
241 p_sys->i_duplicated = 0;
242 p_sys->b_modify = VLC_TRUE;
247 void block_ChainAppend( block_t **pp_list, block_t *p_block )
250 if( *pp_list == NULL )
256 block_t *p = *pp_list;
266 void block_ChainRelease( block_t *p_block )
271 p_next = p_block->p_next;
272 p_block->pf_release( p_block );
277 int block_ChainExtract( block_t *p_list, void *p_data, int i_max )
283 for( b = p_list; b != NULL; b = b->p_next )
287 i_copy = __MIN( i_max, b->i_buffer );
290 memcpy( p, b->p_buffer, i_copy );
304 block_t *block_ChainGather( block_t *p_list )
309 if( p_list->p_next == NULL )
311 /* only one, so no need */
315 for( b = p_list; b != NULL; b = b->p_next )
317 i_total += b->i_buffer;
320 g = block_New( p_list->p_manager, i_total );
321 block_ChainExtract( p_list, g->p_buffer, g->i_buffer );
323 g->b_frame_display = p_list->b_frame_display;
324 g->b_frame_start = p_list->b_frame_start;
325 g->i_pts = p_list->i_pts;
326 g->i_dts = p_list->i_dts;
329 block_ChainRelease( p_list );
333 /*****************************************************************************
334 * block_fifo_t management
335 *****************************************************************************/
336 block_fifo_t *__block_FifoNew( vlc_object_t *p_obj )
338 block_fifo_t *p_fifo;
340 p_fifo = malloc( sizeof( vlc_object_t ) );
341 vlc_mutex_init( p_obj, &p_fifo->lock );
342 vlc_cond_init( p_obj, &p_fifo->wait );
344 p_fifo->p_first = NULL;
345 p_fifo->pp_last = &p_fifo->p_first;
350 void block_FifoRelease( block_fifo_t *p_fifo )
352 block_FifoEmpty( p_fifo );
353 vlc_cond_destroy( &p_fifo->wait );
354 vlc_mutex_destroy( &p_fifo->lock );
358 void block_FifoEmpty( block_fifo_t *p_fifo )
362 vlc_mutex_lock( &p_fifo->lock );
363 for( b = p_fifo->p_first; b != NULL; )
373 p_fifo->p_first = NULL;
374 p_fifo->pp_last = &p_fifo->p_first;
375 vlc_mutex_unlock( &p_fifo->lock );
378 int block_FifoPut( block_fifo_t *p_fifo, block_t *p_block )
381 vlc_mutex_lock( &p_fifo->lock );
385 i_size += p_block->i_buffer;
387 *p_fifo->pp_last = p_block;
388 p_fifo->pp_last = &p_block->p_next;
391 p_block = p_block->p_next;
395 /* warn there is data in this fifo */
396 vlc_cond_signal( &p_fifo->wait );
397 vlc_mutex_unlock( &p_fifo->lock );
402 block_t *block_FifoGet( block_fifo_t *p_fifo )
406 vlc_mutex_lock( &p_fifo->lock );
408 if( p_fifo->p_first == NULL )
410 vlc_cond_wait( &p_fifo->wait, &p_fifo->lock );
415 p_fifo->p_first = b->p_next;
418 if( p_fifo->p_first == NULL )
420 p_fifo->pp_last = &p_fifo->p_first;
423 vlc_mutex_unlock( &p_fifo->lock );
429 block_t *block_FifoShow( block_fifo_t *p_fifo )
433 vlc_mutex_lock( &p_fifo->lock );
435 if( p_fifo->p_first == NULL )
437 vlc_cond_wait( &p_fifo->wait, &p_fifo->lock );
442 vlc_mutex_unlock( &p_fifo->lock );
448 block_t *block_FifoGetFrame( block_fifo_t *p_fifo )
455 block_ChainAppend( &b, block_FifoGet( p_fifo ) );
456 p_next = block_FifoShow( p_fifo );
457 if( p_next == NULL || p_next->b_frame_start )