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 /*
 469             if ( aout_date < p_fifo->date[p_fifo->l_next_frame] )
 470             {
 471 */
 472                 p_fifo->b_next_frame = 1;
 473                 break;
 474 /*
 475             }
 476             else
 477             {
 478                 fprintf(stderr, "-");
 479                 p_fifo->l_start_frame = p_fifo->l_next_frame;
 480             }
 481 */
 482         }
 483         p_fifo->l_next_frame = (p_fifo->l_next_frame + 1) & AOUT_FIFO_SIZE;
 484     }
 485     if ( p_fifo->l_next_frame == p_fifo->l_end_frame )
 486     {
 487         if ( (((p_fifo->l_end_frame + 1) - p_fifo->l_start_frame) & AOUT_FIFO_SIZE) == 0 )
 488         {
 489             p_fifo->l_start_frame = 0;
 490             p_fifo->b_start_frame = 0;
 491             /* p_fifo->l_next_frame = 0; */
 492             /* p_fifo->b_next_frame = 0; */
 493             p_fifo->l_end_frame = 0;
 494         }
 495         pthread_mutex_unlock( &p_fifo->data_lock );
 496         return( -1 );
 497     }
 498
 499     l_units = ((p_fifo->l_next_frame - p_fifo->l_start_frame) & AOUT_FIFO_SIZE)
 500         * (AOUT_FRAME_SIZE >> p_fifo->b_stereo);
 501
 502     l_rate = (long)( ((mtime_t)l_units * 1000000)
 503         / (p_fifo->date[p_fifo->l_next_frame] - p_fifo->date[p_fifo->l_start_frame]) );
 504
 505     InitializeIncrement( &p_fifo->unit_increment, l_rate, p_aout->dsp.l_rate );
 506
 507     p_fifo->l_units = (((l_units - (p_fifo->l_unit -
 508         (p_fifo->l_start_frame * (AOUT_FRAME_SIZE >> p_fifo->b_stereo))))
 509         * p_aout->dsp.l_rate) / l_rate) + 1;
 510
 511     /* We release the lock before leaving */
 512     pthread_mutex_unlock( &p_fifo->data_lock );
 513     return( 0 );
 514 }
 515
 516 void aout_Thread_S8_Mono( aout_thread_t * p_aout )
 517 {
 518 }
 519
 520 void aout_Thread_S8_Stereo( aout_thread_t * p_aout )
 521 {
 522 }
 523
 524 void aout_Thread_U8_Mono( aout_thread_t * p_aout )
 525 {
 526 }
 527
 528 void aout_Thread_U8_Stereo( aout_thread_t * p_aout )
 529 {
 530 }
 531
 532 void aout_Thread_S16_Mono( aout_thread_t * p_aout )
 533 {
 534 }
 535
 536 void aout_Thread_S16_Stereo( aout_thread_t * p_aout )
 537 {
 538     int i_fifo;
 539     long l_units;
 540     long l_buffer, l_buffer_limit;
 541
 542     intf_DbgMsg("adec debug: running audio output thread (%p) (pid == %i)\n", p_aout, getpid());
 543
 544     /* As the s32_buffer was created with calloc(), we don't have to set this
 545      * memory to zero and we can immediately jump into the thread's loop */
 546     while ( !p_aout->b_die )
 547     {
 548         pthread_mutex_lock( &p_aout->fifos_lock );
 549         for ( i_fifo = 0; i_fifo < AOUT_MAX_FIFOS; i_fifo++ )
 550         {
 551             switch ( p_aout->fifo[i_fifo].i_type )
 552             {
 553                 case AOUT_EMPTY_FIFO:
 554                     break;
 555
 556                 case AOUT_INTF_MONO_FIFO:
 557                     if ( p_aout->fifo[i_fifo].l_units > p_aout->l_units )
 558                     {
 559                         l_buffer = 0;
 560                         while ( l_buffer < (p_aout->l_units << 1) ) /* p_aout->dsp.b_stereo == 1 */
 561                         {
 562                             p_aout->s32_buffer[l_buffer++] +=
 563                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 564                             p_aout->s32_buffer[l_buffer++] +=
 565                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 566                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 567                         }
 568                         p_aout->fifo[i_fifo].l_units -= p_aout->l_units;
 569                     }
 570                     else
 571                     {
 572                         l_buffer = 0;
 573                         while ( l_buffer < (p_aout->fifo[i_fifo].l_units << 1) ) /* p_aout->dsp.b_stereo == 1 */
 574                         {
 575                             p_aout->s32_buffer[l_buffer++] +=
 576                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 577                             p_aout->s32_buffer[l_buffer++] +=
 578                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 579                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 580                         }
 581                         free( p_aout->fifo[i_fifo].buffer ); /* !! */
 582                         p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 583                         intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]); /* !! */
 584                     }
 585                     break;
 586
 587                 case AOUT_INTF_STEREO_FIFO:
 588                     if ( p_aout->fifo[i_fifo].l_units > p_aout->l_units )
 589                     {
 590                         l_buffer = 0;
 591                         while ( l_buffer < (p_aout->l_units << 1) ) /* p_aout->dsp.b_stereo == 1 */
 592                         {
 593                             p_aout->s32_buffer[l_buffer++] +=
 594                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 595                             p_aout->s32_buffer[l_buffer++] +=
 596                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 597                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 598                         }
 599                         p_aout->fifo[i_fifo].l_units -= p_aout->l_units;
 600                     }
 601                     else
 602                     {
 603                         l_buffer = 0;
 604                         while ( l_buffer < (p_aout->fifo[i_fifo].l_units << 1) ) /* p_aout->dsp.b_stereo */
 605                         {
 606                             p_aout->s32_buffer[l_buffer++] +=
 607                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 608                             p_aout->s32_buffer[l_buffer++] +=
 609                                 (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 610                             UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 611                         }
 612                         free( p_aout->fifo[i_fifo].buffer ); /* !! */
 613                         p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 614                         intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]); /* !! */
 615                     }
 616                     break;
 617
 618                 case AOUT_ADEC_MONO_FIFO:
 619                     l_units = p_aout->l_units;
 620                     l_buffer = 0;
 621                     while ( l_units > 0 )
 622                     {
 623                         if ( !p_aout->fifo[i_fifo].b_next_frame )
 624                         {
 625                             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)) )
 626                             {
 627                                 break;
 628                             }
 629                         }
 630
 631                         if ( p_aout->fifo[i_fifo].l_units > l_units )
 632                         {
 633                             l_buffer_limit = p_aout->l_units << 1; /* p_aout->dsp.b_stereo == 1 */
 634                             while ( l_buffer < l_buffer_limit )
 635                             {
 636                                 p_aout->s32_buffer[l_buffer++] +=
 637                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 638                                 p_aout->s32_buffer[l_buffer++] +=
 639                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 640
 641                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 642                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 643                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0)) )
 644                                 {
 645                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 646                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0));
 647                                 }
 648                             }
 649                             p_aout->fifo[i_fifo].l_units -= l_units;
 650                             break;
 651                         }
 652                         else
 653                         {
 654                             l_buffer_limit = l_buffer + (p_aout->fifo[i_fifo].l_units << 1);
 655                             /* p_aout->dsp.b_stereo == 1 */
 656                             while ( l_buffer < l_buffer_limit )
 657                             {
 658                                 p_aout->s32_buffer[l_buffer++] +=
 659                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 660                                 p_aout->s32_buffer[l_buffer++] +=
 661                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[p_aout->fifo[i_fifo].l_unit] );
 662
 663                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 664                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 665                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0)) )
 666                                 {
 667                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 0 */
 668                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 0));
 669                                 }
 670                             }
 671                             l_units -= p_aout->fifo[i_fifo].l_units;
 672
 673                             pthread_mutex_lock( &p_aout->fifo[i_fifo].data_lock );
 674                             p_aout->fifo[i_fifo].l_start_frame = p_aout->fifo[i_fifo].l_next_frame;
 675                             pthread_cond_signal( &p_aout->fifo[i_fifo].data_wait );
 676                             pthread_mutex_unlock( &p_aout->fifo[i_fifo].data_lock );
 677
 678                             /* p_aout->fifo[i_fifo].b_start_frame = 1; */
 679                             p_aout->fifo[i_fifo].l_next_frame += 1;
 680                             p_aout->fifo[i_fifo].l_next_frame &= AOUT_FIFO_SIZE;
 681                             p_aout->fifo[i_fifo].b_next_frame = 0;
 682                         }
 683                     }
 684                     break;
 685
 686                 case AOUT_ADEC_STEREO_FIFO:
 687                     l_units = p_aout->l_units;
 688                     l_buffer = 0;
 689                     while ( l_units > 0 )
 690                     {
 691                         if ( !p_aout->fifo[i_fifo].b_next_frame )
 692                         {
 693                             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)) )
 694                             {
 695                                 break;
 696                             }
 697                         }
 698
 699                         if ( p_aout->fifo[i_fifo].l_units > l_units )
 700                         {
 701                             l_buffer_limit = p_aout->l_units << 1; /* p_aout->dsp.b_stereo == 1 */
 702                             while ( l_buffer < l_buffer_limit )
 703                             {
 704                                 p_aout->s32_buffer[l_buffer++] +=
 705                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 706                                 p_aout->s32_buffer[l_buffer++] +=
 707                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 708
 709                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 710                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 711                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1)) )
 712                                 {
 713                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 714                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1));
 715                                 }
 716                             }
 717                             p_aout->fifo[i_fifo].l_units -= l_units;
 718                             break;
 719                         }
 720                         else
 721                         {
 722                             l_buffer_limit = l_buffer + (p_aout->fifo[i_fifo].l_units << 1);
 723                             /* p_aout->dsp.b_stereo == 1 */
 724                             while ( l_buffer < l_buffer_limit )
 725                             {
 726                                 p_aout->s32_buffer[l_buffer++] +=
 727                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit] );
 728                                 p_aout->s32_buffer[l_buffer++] +=
 729                                     (s32)( ((s16 *)p_aout->fifo[i_fifo].buffer)[2*p_aout->fifo[i_fifo].l_unit+1] );
 730
 731                                 UPDATE_INCREMENT( p_aout->fifo[i_fifo].unit_increment, p_aout->fifo[i_fifo].l_unit )
 732                                 if ( p_aout->fifo[i_fifo].l_unit >= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 733                                      ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1)) )
 734                                 {
 735                                     p_aout->fifo[i_fifo].l_unit -= /* p_aout->fifo[i_fifo].b_stereo == 1 */
 736                                         ((AOUT_FIFO_SIZE + 1) * (AOUT_FRAME_SIZE >> 1));
 737                                 }
 738                             }
 739                             l_units -= p_aout->fifo[i_fifo].l_units;
 740
 741                             pthread_mutex_lock( &p_aout->fifo[i_fifo].data_lock );
 742                             p_aout->fifo[i_fifo].l_start_frame = p_aout->fifo[i_fifo].l_next_frame;
 743                             pthread_cond_signal( &p_aout->fifo[i_fifo].data_wait );
 744                             pthread_mutex_unlock( &p_aout->fifo[i_fifo].data_lock );
 745
 746                             /* p_aout->fifo[i_fifo].b_start_frame = 1; */
 747                             p_aout->fifo[i_fifo].l_next_frame += 1;
 748                             p_aout->fifo[i_fifo].l_next_frame &= AOUT_FIFO_SIZE;
 749                             p_aout->fifo[i_fifo].b_next_frame = 0;
 750                         }
 751                     }
 752                     break;
 753
 754                 default:
 755                     intf_DbgMsg("aout debug: unknown fifo type (%i)\n", p_aout->fifo[i_fifo].i_type);
 756                     break;
 757             }
 758         }
 759         pthread_mutex_unlock( &p_aout->fifos_lock );
 760
 761         l_buffer_limit = p_aout->l_units << 1; /* p_aout->dsp.b_stereo == 1 */
 762
 763         for ( l_buffer = 0; l_buffer < l_buffer_limit; l_buffer++ )
 764         {
 765             ((s16 *)p_aout->buffer)[l_buffer] = S32_TO_S16( p_aout->s32_buffer[l_buffer] / AOUT_MAX_FIFOS );
 766             p_aout->s32_buffer[l_buffer] = 0;
 767         }
 768
 769         aout_dspGetBufInfo( &p_aout->dsp );
 770         if ( p_aout->dsp.buf_info.fragments == p_aout->dsp.buf_info.fragstotal ) /* ?? */
 771         {
 772             aout_dspPlaySamples( &p_aout->dsp, (byte_t *)p_aout->buffer, sizeof(s16) * l_buffer_limit );
 773             p_aout->date = mdate();
 774         }
 775         else if ( p_aout->dsp.buf_info.bytes >=
 776             ((p_aout->dsp.buf_info.fragsize * p_aout->dsp.buf_info.fragstotal) -
 777             (sizeof(s16) * l_buffer_limit)) )
 778         {
 779             aout_dspPlaySamples( &p_aout->dsp, (byte_t *)p_aout->buffer, sizeof(s16) * l_buffer_limit );
 780         }
 781         else
 782         {
 783             aout_dspPlaySamples( &p_aout->dsp, (byte_t *)p_aout->buffer, sizeof(s16) * l_buffer_limit );
 784             msleep( p_aout->date_increment.l_euclidean_integer );
 785         }
 786         UPDATE_INCREMENT( p_aout->date_increment, p_aout->date )
 787     }
 788
 789     pthread_mutex_lock( &p_aout->fifos_lock );
 790     for ( i_fifo = 0; i_fifo < AOUT_MAX_FIFOS; i_fifo++ )
 791     {
 792         switch ( p_aout->fifo[i_fifo].i_type )
 793         {
 794             case AOUT_EMPTY_FIFO:
 795                 break;
 796
 797             case AOUT_INTF_MONO_FIFO:
 798             case AOUT_INTF_STEREO_FIFO:
 799                 free( p_aout->fifo[i_fifo].buffer ); /* !! */
 800                 p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 801                 intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]);
 802                 break;
 803
 804             case AOUT_ADEC_MONO_FIFO:
 805             case AOUT_ADEC_STEREO_FIFO:
 806                 free( p_aout->fifo[i_fifo].buffer );
 807                 free( p_aout->fifo[i_fifo].date );
 808                 p_aout->fifo[i_fifo].i_type = AOUT_EMPTY_FIFO; /* !! */
 809                 intf_DbgMsg("aout debug: audio output fifo (%p) destroyed\n", &p_aout->fifo[i_fifo]);
 810                 break;
 811
 812             default:
 813                 break;
 814         }
 815     }
 816     pthread_mutex_unlock( &p_aout->fifos_lock );
 817 }
 818
 819 void aout_Thread_U16_Mono( aout_thread_t * p_aout )
 820 {
 821 }
 822
 823 void aout_Thread_U16_Stereo( aout_thread_t * p_aout )
 824 {
 825 }