git.sesse.net Git - vlc/blob - src/audio_output/audio_output.c

   1 /******************************************************************************
   2  * audio_output.c : audio output thread
   3  * (c)1999 VideoLAN
   4  ******************************************************************************/
   5
   6 /* TODO:
   7  *
   8  * - Passer un certain nombre de "fonctions" (genre add_samples) en macro ou
   9  *   inline
  10  * - Faire les optimisations dans les fonctions threads :
  11  *   = Stocker les "petits calculs" dans des variables au lieu de les refaire
  12  *     à chaque boucle
  13  *   = Utiliser des tables pour les gros calculs
  14  * - Faire une structure différente pour intf/adec fifo
  15  * - Rajouter des pthread_cond_signal ?
  16  *
  17  */
  18
  19 /******************************************************************************
  20  * Preamble
  21  ******************************************************************************/
  22 #include <unistd.h>
  23
  24 #include <pthread.h>
  25 #include <sys/soundcard.h>
  26 #include <stdio.h>                                            /* "intf_msg.h" */
  27 #include <stdlib.h>                             /* calloc(), malloc(), free() */
  28
  29 #include "common.h"
  30 #include "config.h"
  31 #include "mtime.h"                              /* mtime_t, mdate(), msleep() */
  32
  33 #include "intf_msg.h"                         /* intf_DbgMsg(), intf_ErrMsg() */
  34
  35 #include "audio_output.h"
  36 #include "audio_dsp.h"
  37
  38 /******************************************************************************
  39  * Local prototypes
  40  ******************************************************************************/
  41
  42 /* Creating as much aout_Thread functions as configurations is one solution,
  43  * examining the different cases in the Thread loop of an unique function is
  44  * another. I chose the first solution. */
  45 void aout_Thread_S8_Mono        ( aout_thread_t * p_aout );
  46 void aout_Thread_U8_Mono        ( aout_thread_t * p_aout );
  47 void aout_Thread_S16_Mono       ( aout_thread_t * p_aout );
  48 void aout_Thread_U16_Mono       ( aout_thread_t * p_aout );
  49 void aout_Thread_S8_Stereo      ( aout_thread_t * p_aout );
  50 void aout_Thread_U8_Stereo      ( aout_thread_t * p_aout );
  51 void aout_Thread_S16_Stereo     ( aout_thread_t * p_aout );
  52 void aout_Thread_U16_Stereo     ( aout_thread_t * p_aout );
  53
  54 static __inline__ void InitializeIncrement( aout_increment_t * p_increment, long l_numerator, long l_denominator );
  55 static __inline__ int NextFrame( aout_thread_t * p_aout, aout_fifo_t * p_fifo, mtime_t aout_date );
  56
  57 /******************************************************************************
  58  * aout_Open
  59  ******************************************************************************/
  60 int aout_Open( aout_thread_t * p_aout )
  61 {
  62     if ( aout_dspOpen( &p_aout->dsp ) )
  63     {
  64         return( -1 );
  65     }
  66
  67     if ( aout_dspReset( &p_aout->dsp ) )
  68     {
  69         aout_dspClose( &p_aout->dsp );
  70         return( -1 );
  71     }
  72
  73     if ( aout_dspSetFormat( &p_aout->dsp ) )
  74     {
  75         aout_dspClose( &p_aout->dsp );
  76         return( -1 );
  77     }
  78
  79     if ( aout_dspSetChannels( &p_aout->dsp ) )
  80     {
  81         aout_dspClose( &p_aout->dsp );
  82         return( -1 );
  83     }
  84
  85     if ( aout_dspSetRate( &p_aout->dsp ) )
  86     {
  87         aout_dspClose( &p_aout->dsp );
  88         return( -1 );
  89     }
  90
  91     intf_DbgMsg("aout debug: audio device (%s) opened (format=%i, stereo=%i, rate=%li)\n",
  92         p_aout->dsp.psz_device,
  93         p_aout->dsp.i_format,
  94         p_aout->dsp.b_stereo, p_aout->dsp.l_rate);
  95
  96     return( 0 );
  97 }
  98
  99 /******************************************************************************
 100  * aout_SpawnThread
 101  ******************************************************************************/
 102 int aout_SpawnThread( aout_thread_t * p_aout )
 103 {
 104     int         i_fifo;
 105     long        l_bytes;
 106     s64         s64_numerator, s64_denominator;
 107     void *      aout_thread = NULL;
 108
 109     intf_DbgMsg("aout debug: spawning audio output thread (%p)\n", p_aout);
 110
 111     /* We want the audio output thread to live */
 112     p_aout->b_die = 0;
 113
 114     /* Initialize the fifos lock */
 115     pthread_mutex_init( &p_aout->fifos_lock, NULL );
 116     /* Initialize audio fifos : set all fifos as empty and initialize locks */
 117     for ( i_fifo = 0; i_fifo < AOUT_MAX_FIFOS; i_fifo++ )
 118     {
 119         p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO;
 120         pthread_mutex_init( &p_aout->fifo[i_fifo].data_lock, NULL );
 121         pthread_cond_init( &p_aout->fifo[i_fifo].data_wait, NULL );
 122     }
 123
 124     /* Compute the size (in audio units) of the audio output buffer. Although
 125      * AOUT_BUFFER_DURATION is given in microseconds, the output rate is given
 126      * in Hz, that's why we need to divide by 10^6 microseconds (1 second) */
 127     p_aout->l_units = (long)( ((s64)p_aout->dsp.l_rate * AOUT_BUFFER_DURATION) / 1000000 );
 128
 129     /* Make aout_thread point to the right thread function, and compute the
 130      * byte size of the audio output buffer */
 131     switch ( p_aout->dsp.b_stereo )
 132     {
 133         /* Audio output is mono */
 134         case 0:
 135             switch ( p_aout->dsp.i_format )
 136             {
 137                 case AFMT_U8:
 138                     l_bytes = 1 * sizeof(u8) * p_aout->l_units;
 139                     aout_thread = (void *)aout_Thread_U8_Mono;
 140                     break;
 141
 142                 case AFMT_S8:
 143                     l_bytes = 1 * sizeof(s8) * p_aout->l_units;
 144                     aout_thread = (void *)aout_Thread_S8_Mono;
 145                     break;
 146
 147                 case AFMT_U16_LE:
 148                 case AFMT_U16_BE:
 149                     l_bytes = 1 * sizeof(u16) * p_aout->l_units;
 150                     aout_thread = (void *)aout_Thread_U16_Mono;
 151                     break;
 152
 153                 case AFMT_S16_LE:
 154                 case AFMT_S16_BE:
 155                     l_bytes = 1 * sizeof(s16) * p_aout->l_units;
 156                     aout_thread = (void *)aout_Thread_S16_Mono;
 157                     break;
 158
 159                 default:
 160                     intf_ErrMsg("aout error: unknown audio output format (%i)\n",
 161                         p_aout->dsp.i_format);
 162                     return( -1 );
 163             }
 164             break;
 165
 166         /* Audio output is stereo */
 167         case 1:
 168             switch ( p_aout->dsp.i_format )
 169             {
 170                 case AFMT_U8:
 171                     l_bytes = 2 * sizeof(u8) * p_aout->l_units;
 172                     aout_thread = (void *)aout_Thread_U8_Stereo;
 173                     break;
 174
 175                 case AFMT_S8:
 176                     l_bytes = 2 * sizeof(s8) * p_aout->l_units;
 177                     aout_thread = (void *)aout_Thread_S8_Stereo;
 178                     break;
 179
 180                 case AFMT_U16_LE:
 181                 case AFMT_U16_BE:
 182                     l_bytes = 2 * sizeof(u16) * p_aout->l_units;
 183                     aout_thread = (void *)aout_Thread_U16_Stereo;
 184                     break;
 185
 186                 case AFMT_S16_LE:
 187                 case AFMT_S16_BE:
 188                     l_bytes = 2 * sizeof(s16) * p_aout->l_units;
 189                     aout_thread = (void *)aout_Thread_S16_Stereo;
 190                     break;
 191
 192                 default:
 193                     intf_ErrMsg("aout error: unknown audio output format (%i)\n",
 194                         p_aout->dsp.i_format);
 195                     return( -1 );
 196             }
 197             break;
 198
 199         default:
 200             intf_ErrMsg("aout error: unknown number of audio channels (%i)\n",
 201                 p_aout->dsp.b_stereo + 1);
 202             return( -1 );
 203     }
 204
 205     /* Allocate the memory needed by the audio output buffers, and set to zero
 206      * the s32 buffer's memory */
 207     if ( (p_aout->buffer = malloc(l_bytes)) == NULL )
 208     {
 209         intf_ErrMsg("aout error: not enough memory to create the output buffer\n");
 210         return( -1 );
 211     }
 212     if ( (p_aout->s32_buffer = (s32 *)calloc(p_aout->l_units, sizeof(s32) << p_aout->dsp.b_stereo)) == NULL )
 213     {
 214         intf_ErrMsg("aout error: not enough memory to create the s32 output buffer\n");
 215         free( p_aout->buffer );
 216         return( -1 );
 217     }
 218
 219     /* Initialize the incremental structure that is used to work out the date
 220      * of the first audio unit in the output buffer */
 221     s64_numerator = (s64)p_aout->l_units * 1000000;
 222     s64_denominator = (s64)p_aout->dsp.l_rate;
 223
 224     p_aout->date_increment.l_remainder = -(long)s64_denominator;
 225
 226     p_aout->date_increment.l_euclidean_integer = 0;
 227     while ( s64_numerator >= s64_denominator )
 228     {
 229         p_aout->date_increment.l_euclidean_integer++;
 230         s64_numerator -= s64_denominator;
 231     }
 232
 233     p_aout->date_increment.l_euclidean_remainder = (long)s64_numerator;
 234
 235     p_aout->date_increment.l_euclidean_denominator = (long)s64_denominator;
 236
 237     /* Before launching the thread, we try to predict the date of the first
 238      * audio unit in the first output buffer */
 239     p_aout->date = mdate();
 240
 241     /* Launch the thread */
 242     if ( pthread_create( &p_aout->thread_id, NULL, aout_thread, p_aout ) )
 243     {
 244         intf_ErrMsg("aout error: can't spawn audio output thread (%p)\n", p_aout);
 245         free( p_aout->buffer );
 246         free( p_aout->s32_buffer );
 247         return( -1 );
 248     }
 249
 250     intf_DbgMsg("aout debug: audio output thread (%p) spawned\n", p_aout);
 251     return( 0 );
 252 }
 253
 254 /******************************************************************************
 255  * aout_CancelThread
 256  ******************************************************************************/
 257 void aout_CancelThread( aout_thread_t * p_aout )
 258 {
 259     intf_DbgMsg("aout debug: requesting termination of audio output thread (%p)\n", p_aout);
 260
 261     /* Ask thread to kill itself and wait until it's done */
 262     p_aout->b_die = 1;
 263     pthread_join( p_aout->thread_id, NULL );
 264
 265     /* Free the allocated memory */
 266     free( p_aout->buffer );
 267     free( p_aout->s32_buffer );
 268 }
 269
 270 /******************************************************************************
 271  * aout_Close
 272  ******************************************************************************/
 273 void aout_Close( aout_thread_t * p_aout )
 274 {
 275     aout_dspClose( &p_aout->dsp );
 276     intf_DbgMsg("aout debug: audio device (%s) closed\n", p_aout->dsp.psz_device);
 277 }
 278
 279 /******************************************************************************
 280  * aout_CreateFifo
 281  ******************************************************************************/
 282 aout_fifo_t * aout_CreateFifo( aout_thread_t * p_aout, aout_fifo_t * p_fifo )
 283 {
 284     int i_fifo;
 285
 286     /* Take the fifos lock */
 287     pthread_mutex_lock( &p_aout->fifos_lock );
 288
 289     /* Looking for a free fifo structure */
 290     for ( i_fifo = 0; i_fifo < AOUT_MAX_FIFOS; i_fifo++ )
 291     {
 292         if ( p_aout->fifo[i_fifo].i_type == AOUT_EMPTY_FIFO)
 293         {
 294             break;
 295         }
 296     }
 297     if ( i_fifo == AOUT_MAX_FIFOS )
 298     {
 299         intf_ErrMsg("aout error: no empty fifo available\n");
 300         pthread_mutex_unlock( &p_aout->fifos_lock );
 301         return( NULL );
 302     }
 303
 304     /* Initialize the new fifo structure */
 305     switch ( p_aout->fifo[i_fifo].i_type = p_fifo->i_type )
 306     {
 307         case AOUT_INTF_MONO_FIFO:
 308         case AOUT_INTF_STEREO_FIFO:
 309             p_aout->fifo[i_fifo].b_die = 0;
 310
 311             p_aout->fifo[i_fifo].b_stereo = p_fifo->b_stereo;
 312             p_aout->fifo[i_fifo].l_rate = p_fifo->l_rate;
 313
 314             p_aout->fifo[i_fifo].buffer = p_fifo->buffer;
 315
 316             p_aout->fifo[i_fifo].l_unit = 0;
 317             InitializeIncrement( &p_aout->fifo[i_fifo].unit_increment, p_fifo->l_rate, p_aout->dsp.l_rate );
 318             p_aout->fifo[i_fifo].l_units = p_fifo->l_units;
 319             break;
 320
 321         case AOUT_ADEC_MONO_FIFO:
 322         case AOUT_ADEC_STEREO_FIFO:
 323             p_aout->b_die = 0;
 324
 325             p_aout->fifo[i_fifo].b_stereo = p_fifo->b_stereo;
 326             p_aout->fifo[i_fifo].l_rate = p_fifo->l_rate;
 327
 328             /* Allocate the memory needed to store the audio frames. As the
 329              * fifo is a rotative fifo, we must be able to find out whether the
 330              * fifo is full or empty, that's why we must in fact allocate memory
 331              * for (AOUT_FIFO_SIZE+1) audio frames. */
 332             if ( (p_aout->fifo[i_fifo].buffer = malloc( sizeof(s16)*(AOUT_FIFO_SIZE+1)*AOUT_FRAME_SIZE )) == NULL )
 333             {
 334                 intf_ErrMsg("aout error: not enough memory to create the frames buffer\n");
 335                 p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO;
 336                 pthread_mutex_unlock( &p_aout->fifos_lock );
 337                 return( NULL );
 338             }
 339
 340             /* Allocate the memory needed to store the dates of the frames */
 341             if ( (p_aout->fifo[i_fifo].date = (mtime_t *)malloc( sizeof(mtime_t)*(AOUT_FIFO_SIZE+1) )) == NULL )
 342             {
 343                 intf_ErrMsg("aout error: not enough memory to create the dates buffer\n");
 344                 free( p_aout->fifo[i_fifo].buffer );
 345                 p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO;
 346                 pthread_mutex_unlock( &p_aout->fifos_lock );
 347                 return( NULL );
 348             }
 349
 350             /* Set the fifo's buffer as empty (the first frame that is to be
 351              * played is also the first frame that is not to be played) */
 352             p_aout->fifo[i_fifo].l_start_frame = 0;
 353             /* p_aout->fifo[i_fifo].l_next_frame = 0; */
 354             p_aout->fifo[i_fifo].l_end_frame = 0;
 355
 356             /* Waiting for the audio decoder to compute enough frames to work
 357              * out the fifo's current rate (as soon as the decoder has decoded
 358              * enough frames, the members of the fifo structure that are not
 359              * initialized now will be calculated) */
 360             p_aout->fifo[i_fifo].l_unit = 0; /* !! */
 361             p_aout->fifo[i_fifo].b_start_frame = 0;
 362             p_aout->fifo[i_fifo].b_next_frame = 0;
 363             break;
 364
 365         default:
 366             intf_ErrMsg("aout error: unknown fifo type (%i)\n", p_aout->fifo[i_fifo].i_type);
 367             p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO;
 368             pthread_mutex_unlock( &p_aout->fifos_lock );
 369             return( NULL );
 370     }
 371
 372     /* Release the fifos lock */
 373     pthread_mutex_unlock( &p_aout->fifos_lock );
 374
 375     /* Return the pointer to the fifo structure */
 376     intf_DbgMsg("aout debug: audio output fifo (%p) allocated\n", &p_aout->fifo[i_fifo]);
 377     return( &p_aout->fifo[i_fifo] );
 378 }
 379
 380 /******************************************************************************
 381  * aout_DestroyFifo
 382  ******************************************************************************/
 383 void aout_DestroyFifo( aout_fifo_t * p_fifo )
 384 {
 385     intf_DbgMsg("aout debug: requesting destruction of audio output fifo (%p)\n", p_fifo);
 386     p_fifo->b_die = 1;
 387 }
 388
 389 /* Here are the local macros */
 390
 391 #define S32_TO_S16( sample ) \
 392     (s16)( (sample) )
 393
 394 #define UPDATE_INCREMENT( increment, integer ) \
 395     if ( ((increment).l_remainder += (increment).l_euclidean_remainder) >= 0 ) \
 396     { \
 397         (integer) += (increment).l_euclidean_integer + 1; \
 398         (increment).l_remainder -= (increment).l_euclidean_denominator; \
 399     } \
 400     else \
 401     { \
 402         (integer) += (increment).l_euclidean_integer; \
 403     }
 404
 405 /* Following functions are local */
 406
 407 /******************************************************************************
 408  * InitializeIncrement
 409  ******************************************************************************/
 410 static __inline__ void InitializeIncrement( aout_increment_t * p_increment, long l_numerator, long l_denominator )
 411 {
 412     p_increment->l_remainder = -l_denominator;
 413
 414     p_increment->l_euclidean_integer = 0;
 415     while ( l_numerator >= l_denominator )
 416     {
 417         p_increment->l_euclidean_integer++;
 418         l_numerator -= l_denominator;
 419     }
 420
 421     p_increment->l_euclidean_remainder = l_numerator;
 422
 423     p_increment->l_euclidean_denominator = l_denominator;
 424 }
 425
 426 /******************************************************************************
 427  * NextFrame
 428  ******************************************************************************/
 429 static __inline__ int NextFrame( aout_thread_t * p_aout, aout_fifo_t * p_fifo, mtime_t aout_date )
 430 {
 431     long l_units, l_rate;
 432
 433     /* We take the lock */
 434     pthread_mutex_lock( &p_fifo->data_lock );
 435
 436     /* Are we looking for a dated start frame ? */
 437     if ( !p_fifo->b_start_frame )
 438     {
 439         while ( p_fifo->l_start_frame != p_fifo->l_end_frame )
 440         {
 441             if ( p_fifo->date[p_fifo->l_start_frame] != LAST_MDATE )
 442             {
 443                 p_fifo->b_start_frame = 1;
 444                 p_fifo->l_next_frame = (p_fifo->l_start_frame + 1) & AOUT_FIFO_SIZE;
 445                 break;
 446             }
 447             p_fifo->l_start_frame = (p_fifo->l_start_frame + 1) & AOUT_FIFO_SIZE;
 448         }
 449         if ( p_fifo->l_start_frame == p_fifo->l_end_frame )
 450         {
 451             pthread_mutex_unlock( &p_fifo->data_lock );
 452             return( -1 );
 453         }
 454     }
 455
 456     if ( aout_date < p_fifo->date[p_fifo->l_start_frame] )
 457     {
 458         fprintf(stderr, "+");
 459         pthread_mutex_unlock( &p_fifo->data_lock );
 460         return( -1 );
 461     }
 462
 463     /* We are looking for the next dated frame */
 464     while ( p_fifo->l_next_frame != p_fifo->l_end_frame )
 465     {
 466         if ( p_fifo->date[p_fifo->l_next_frame] != LAST_MDATE )
 467         {
 468             if ( aout_date < p_fifo->date[p_fifo->l_next_frame] )
 469             {
 470                 p_fifo->b_next_frame = 1;
 471                 break;
 472             }
 473             else
 474             {
 475                 fprintf(stderr, "-");
 476                 p_fifo->l_start_frame = p_fifo->l_next_frame;
 477             }
 478         }
 479         p_fifo->l_next_frame = (p_fifo->l_next_frame + 1) & AOUT_FIFO_SIZE;
 480     }
 481     if ( p_fifo->l_next_frame == p_fifo->l_end_frame )
 482     {
 483         if ( (((p_fifo->l_end_frame + 1) - p_fifo->l_start_frame) & AOUT_FIFO_SIZE) == 0 )
 484         {
 485             p_fifo->l_start_frame = 0;
 486             p_fifo->b_start_frame = 0;
 487             /* p_fifo->l_next_frame = 0; */
 488             /* p_fifo->b_next_frame = 0; */
 489             p_fifo->l_end_frame = 0;
 490         }
 491         pthread_mutex_unlock( &p_fifo->data_lock );
 492         return( -1 );
 493     }
 494
 495     l_units = ((p_fifo->l_next_frame - p_fifo->l_start_frame) & AOUT_FIFO_SIZE)
 496         * (AOUT_FRAME_SIZE >> p_fifo->b_stereo);
 497
 498     l_rate = (long)( ((mtime_t)l_units * 1000000)
 499         / (p_fifo->date[p_fifo->l_next_frame] - p_fifo->date[p_fifo->l_start_frame]) );
 500
 501     InitializeIncrement( &p_fifo->unit_increment, l_rate, p_aout->dsp.l_rate );
 502
 503     p_fifo->l_units = (((l_units - (p_fifo->l_unit -
 504         (p_fifo->l_start_frame * (AOUT_FRAME_SIZE >> p_fifo->b_stereo))))
 505         * p_aout->dsp.l_rate) / l_rate) + 1;
 506
 507     /* We release the lock before leaving */
 508     pthread_mutex_unlock( &p_fifo->data_lock );
 509     return( 0 );
 510 }
 511
 512 void aout_Thread_S8_Mono( aout_thread_t * p_aout )
 513 {
 514 }
 515
 516 void aout_Thread_S8_Stereo( aout_thread_t * p_aout )
 517 {
 518 }
 519
 520 void aout_Thread_U8_Mono( aout_thread_t * p_aout )
 521 {
 522 }
 523
 524 void aout_Thread_U8_Stereo( aout_thread_t * p_aout )
 525 {
 526 }
 527
 528 void aout_Thread_S16_Mono( aout_thread_t * p_aout )
 529 {
 530 }
 531
 532 void aout_Thread_S16_Stereo( aout_thread_t * p_aout )
 533 {
 534     int i_fifo;
 535     long l_units;
 536     long l_buffer, l_buffer_limit;
 537
 538     intf_DbgMsg("adec debug: running audio output thread (%p) (pid == %i)\n", p_aout, getpid());
 539
 540     /* As the s32_buffer was created with calloc(), we don't have to set this
 541      * memory to zero and we can immediately jump into the thread's loop */
 542     while ( !p_aout->b_die )
 543     {
 544         pthread_mutex_lock( &p_aout->fifos_lock );
 545         for ( i_fifo = 0; i_fifo < AOUT_MAX_FIFOS; i_fifo++ )
 546         {
 547             switch ( p_aout->fifo[i_fifo].i_type )
 548             {
 549                 case AOUT_EMPTY_FIFO:
 550                     break;
 551
 552                 case AOUT_INTF_MONO_FIFO:
 553                     if ( p_aout->fifo[i_fifo].l_units > p_aout->l_units )
 554                     {
 555                         l_buffer = 0;
 556                         while ( l_buffer < (p_aout->l_units << 1) ) /* p_aout->dsp.b_stereo == 1 */
 557                         {
 558                             p_aout->s32_buffer[l_buffer++] +=
 559                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 560                             p_aout->s32_buffer[l_buffer++] +=
 561                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 562                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 563                         }
 564                         p_aout->fifo[i_fifo].l_units -= p_aout->l_units;
 565                     }
 566                     else
 567                     {
 568                         l_buffer = 0;
 569                         while ( l_buffer < (p_aout->fifo[i_fifo].l_units << 1) ) /* p_aout->dsp.b_stereo == 1 */
 570                         {
 571                             p_aout->s32_buffer[l_buffer++] +=
 572                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 573                             p_aout->s32_buffer[l_buffer++] +=
 574                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 575                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 576                         }
 577                         free( p_aout->fifo[i_fifo].buffer ); /* !! */
 578                         p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 579                         intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]); /* !! */
 580                     }
 581                     break;
 582
 583                 case AOUT_INTF_STEREO_FIFO:
 584                     if ( p_aout->fifo[i_fifo].l_units > p_aout->l_units )
 585                     {
 586                         l_buffer = 0;
 587                         while ( l_buffer < (p_aout->l_units << 1) ) /* p_aout->dsp.b_stereo == 1 */
 588                         {
 589                             p_aout->s32_buffer[l_buffer++] +=
 590                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 591                             p_aout->s32_buffer[l_buffer++] +=
 592                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 593                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 594                         }
 595                         p_aout->fifo[i_fifo].l_units -= p_aout->l_units;
 596                     }
 597                     else
 598                     {
 599                         l_buffer = 0;
 600                         while ( l_buffer < (p_aout->fifo[i_fifo].l_units << 1) ) /* p_aout->dsp.b_stereo */
 601                         {
 602                             p_aout->s32_buffer[l_buffer++] +=
 603                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 604                             p_aout->s32_buffer[l_buffer++] +=
 605                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 606                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 607                         }
 608                         free( p_aout->fifo[i_fifo].buffer ); /* !! */
 609                         p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 610                         intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]); /* !! */
 611                     }
 612                     break;
 613
 614                 case AOUT_ADEC_MONO_FIFO:
 615                     l_units = p_aout->l_units;
 616                     l_buffer = 0;
 617                     while ( l_units > 0 )
 618                     {
 619                         if ( !p_aout->fifo[i_fifo].b_next_frame )
 620                         {
 621                             if ( NextFrame(p_aout, &p_aout->fifo[i_fifo], p_aout->date + (mtime_t)((l_buffer >> p_aout->dsp.b_stereo) / p_aout->dsp.l_rate)) )
 622                             {
 623                                 break;
 624                             }
 625                         }
 626
 627                         if ( p_aout->fifo[i_fifo].l_units > l_units )
 628                         {
 629                             l_buffer_limit = p_aout->l_units << 1; /* p_aout->dsp.b_stereo == 1 */
 630                             while ( l_buffer < l_buffer_limit )
 631                             {
 632                                 p_aout->s32_buffer[l_buffer++] +=
 633                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 634                                 p_aout->s32_buffer[l_buffer++] +=
 635                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 636
 637                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 638                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 639                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0)) )
 640                                 {
 641                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 642                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0));
 643                                 }
 644                             }
 645                             p_aout->fifo[i_fifo].l_units -= l_units;
 646                             break;
 647                         }
 648                         else
 649                         {
 650                             l_buffer_limit = l_buffer + (p_aout->fifo[i_fifo].l_units << 1);
 651                             /* p_aout->dsp.b_stereo == 1 */
 652                             while ( l_buffer < l_buffer_limit )
 653                             {
 654                                 p_aout->s32_buffer[l_buffer++] +=
 655                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 656                                 p_aout->s32_buffer[l_buffer++] +=
 657                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 658
 659                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 660                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 661                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0)) )
 662                                 {
 663                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 664                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0));
 665                                 }
 666                             }
 667                             l_units -= p_aout->fifo[i_fifo].l_units;
 668
 669                             pthread_mutex_lock( &p_aout->fifo[i_fifo].data_lock );
 670                             p_aout->fifo[i_fifo].l_start_frame = p_aout->fifo[i_fifo].l_next_frame;
 671                             pthread_cond_signal( &p_aout->fifo[i_fifo].data_wait );
 672                             pthread_mutex_unlock( &p_aout->fifo[i_fifo].data_lock );
 673
 674                             /* p_aout->fifo[i_fifo].b_start_frame = 1; */
 675                             p_aout->fifo[i_fifo].l_next_frame += 1;
 676                             p_aout->fifo[i_fifo].l_next_frame &= AOUT_FIFO_SIZE;
 677                             p_aout->fifo[i_fifo].b_next_frame = 0;
 678                         }
 679                     }
 680                     break;
 681
 682                 case AOUT_ADEC_STEREO_FIFO:
 683                     l_units = p_aout->l_units;
 684                     l_buffer = 0;
 685                     while ( l_units > 0 )
 686                     {
 687                         if ( !p_aout->fifo[i_fifo].b_next_frame )
 688                         {
 689                             if ( NextFrame(p_aout, &p_aout->fifo[i_fifo], p_aout->date + (mtime_t)((l_buffer >> p_aout->dsp.b_stereo) / p_aout->dsp.l_rate)) )
 690                             {
 691                                 break;
 692                             }
 693                         }
 694
 695                         if ( p_aout->fifo[i_fifo].l_units > l_units )
 696                         {
 697                             l_buffer_limit = p_aout->l_units << 1; /* p_aout->dsp.b_stereo == 1 */
 698                             while ( l_buffer < l_buffer_limit )
 699                             {
 700                                 p_aout->s32_buffer[l_buffer++] +=
 701                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 702                                 p_aout->s32_buffer[l_buffer++] +=
 703                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 704
 705                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 706                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 707                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1)) )
 708                                 {
 709                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 710                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1));
 711                                 }
 712                             }
 713                             p_aout->fifo[i_fifo].l_units -= l_units;
 714                             break;
 715                         }
 716                         else
 717                         {
 718                             l_buffer_limit = l_buffer + (p_aout->fifo[i_fifo].l_units << 1);
 719                             /* p_aout->dsp.b_stereo == 1 */
 720                             while ( l_buffer < l_buffer_limit )
 721                             {
 722                                 p_aout->s32_buffer[l_buffer++] +=
 723                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 724                                 p_aout->s32_buffer[l_buffer++] +=
 725                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 726
 727                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 728                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 729                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1)) )
 730                                 {
 731                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 732                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1));
 733                                 }
 734                             }
 735                             l_units -= p_aout->fifo[i_fifo].l_units;
 736
 737                             pthread_mutex_lock( &p_aout->fifo[i_fifo].data_lock );
 738                             p_aout->fifo[i_fifo].l_start_frame = p_aout->fifo[i_fifo].l_next_frame;
 739                             pthread_cond_signal( &p_aout->fifo[i_fifo].data_wait );
 740                             pthread_mutex_unlock( &p_aout->fifo[i_fifo].data_lock );
 741
 742                             /* p_aout->fifo[i_fifo].b_start_frame = 1; */
 743                             p_aout->fifo[i_fifo].l_next_frame += 1;
 744                             p_aout->fifo[i_fifo].l_next_frame &= AOUT_FIFO_SIZE;
 745                             p_aout->fifo[i_fifo].b_next_frame = 0;
 746                         }
 747                     }
 748                     break;
 749
 750                 default:
 751                     intf_DbgMsg("aout debug: unknown fifo type (%i)\n", p_aout->fifo[i_fifo].i_type);
 752                     break;
 753             }
 754         }
 755         pthread_mutex_unlock( &p_aout->fifos_lock );
 756
 757         l_buffer_limit = p_aout->l_units << 1; /* p_aout->dsp.b_stereo == 1 */
 758
 759         for ( l_buffer = 0; l_buffer < l_buffer_limit; l_buffer++ )
 760         {
 761             ((s16 *)p_aout->buffer)[l_buffer] = S32_TO_S16( p_aout->s32_buffer[l_buffer] / AOUT_MAX_FIFOS );
 762             p_aout->s32_buffer[l_buffer] = 0;
 763         }
 764
 765         aout_dspGetBufInfo( &p_aout->dsp );
 766         if ( p_aout->dsp.buf_info.fragments == p_aout->dsp.buf_info.fragstotal ) /* ?? */
 767         {
 768             aout_dspPlaySamples( &p_aout->dsp, (byte_t *)p_aout->buffer, sizeof(s16) * l_buffer_limit );
 769             p_aout->date = mdate();
 770         }
 771         else if ( p_aout->dsp.buf_info.bytes >=
 772             ((p_aout->dsp.buf_info.fragsize * p_aout->dsp.buf_info.fragstotal) -
 773             (sizeof(s16) * l_buffer_limit)) )
 774         {
 775             aout_dspPlaySamples( &p_aout->dsp, (byte_t *)p_aout->buffer, sizeof(s16) * l_buffer_limit );
 776         }
 777         else
 778         {
 779             aout_dspPlaySamples( &p_aout->dsp, (byte_t *)p_aout->buffer, sizeof(s16) * l_buffer_limit );
 780             msleep( p_aout->date_increment.l_euclidean_integer );
 781         }
 782         UPDATE_INCREMENT( p_aout->date_increment, p_aout->date )
 783     }
 784
 785     pthread_mutex_lock( &p_aout->fifos_lock );
 786     for ( i_fifo = 0; i_fifo < AOUT_MAX_FIFOS; i_fifo++ )
 787     {
 788         switch ( p_aout->fifo[i_fifo].i_type )
 789         {
 790             case AOUT_EMPTY_FIFO:
 791                 break;
 792
 793             case AOUT_INTF_MONO_FIFO:
 794             case AOUT_INTF_STEREO_FIFO:
 795                 free( p_aout->fifo[i_fifo].buffer ); /* !! */
 796                 p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 797                 intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]);
 798                 break;
 799
 800             case AOUT_ADEC_MONO_FIFO:
 801             case AOUT_ADEC_STEREO_FIFO:
 802                 free( p_aout->fifo[i_fifo].buffer );
 803                 free( p_aout->fifo[i_fifo].date );
 804                 p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 805                 intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]);
 806                 break;
 807
 808             default:
 809                 break;
 810         }
 811     }
 812     pthread_mutex_unlock( &p_aout->fifos_lock );
 813 }
 814
 815 void aout_Thread_U16_Mono( aout_thread_t * p_aout )
 816 {
 817 }
 818
 819 void aout_Thread_U16_Stereo( aout_thread_t * p_aout )
 820 {
 821 }