src/audio/stream_sound_source.cpp

   1 //  $Id$
   2 //
   3 //  SuperTux
   4 //  Copyright (C) 2006 Matthias Braun <matze@braunis.de>
   5 //
   6 //  This program is free software; you can redistribute it and/or
   7 //  modify it under the terms of the GNU General Public License
   8 //  as published by the Free Software Foundation; either version 2
   9 //  of the License, or (at your option) any later version.
  10 //
  11 //  This program is distributed in the hope that it will be useful,
  12 //  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 //  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14 //  GNU General Public License for more details.
  15 //
  16 //  You should have received a copy of the GNU General Public License
  17 //  along with this program; if not, write to the Free Software
  18 //  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  19
  20 #include <config.h>
  21 #include <assert.h>
  22
  23 #include <SDL.h>
  24
  25 #include "stream_sound_source.hpp"
  26 #include "sound_manager.hpp"
  27 #include "sound_file.hpp"
  28 #include "timer.hpp"
  29 #include "log.hpp"
  30
  31 StreamSoundSource::StreamSoundSource()
  32   : file(0), fade_state(NoFading), looping(false)
  33 {
  34   alGenBuffers(STREAMFRAGMENTS, buffers);
  35   SoundManager::check_al_error("Couldn't allocate audio buffers: ");
  36 }
  37
  38 StreamSoundSource::~StreamSoundSource()
  39 {
  40   delete file;
  41   stop();
  42   alDeleteBuffers(STREAMFRAGMENTS, buffers);
  43   SoundManager::check_al_error("Couldn't delete audio buffers: ");
  44 }
  45
  46 void
  47 StreamSoundSource::set_sound_file(SoundFile* newfile)
  48 {
  49   delete file;
  50   file = newfile;
  51
  52   ALint queued;
  53   alGetSourcei(source, AL_BUFFERS_QUEUED, &queued);
  54   for(size_t i = 0; i < STREAMFRAGMENTS - queued; ++i) {
  55     if(fillBufferAndQueue(buffers[i]) == false)
  56       break;
  57   }
  58 }
  59
  60 void
  61 StreamSoundSource::update()
  62 {
  63   ALint processed = 0;
  64   alGetSourcei(source, AL_BUFFERS_PROCESSED, &processed);
  65   for(ALint i = 0; i < processed; ++i) {
  66     ALuint buffer;
  67     alSourceUnqueueBuffers(source, 1, &buffer);
  68     SoundManager::check_al_error("Couldn't unqueu audio buffer: ");
  69
  70     if(fillBufferAndQueue(buffer) == false)
  71       break;
  72   }
  73
  74   if(!playing()) {
  75     if(processed == 0 || !looping)
  76       return;
  77
  78     // we might have to restart the source if we had a buffer underrun
  79     log_info << "Restarting audio source because of buffer underrun" << std::endl;
  80     play();
  81   }
  82
  83   if(fade_state == FadingOn) {
  84     float time = real_time - fade_start_time;
  85     if(time >= fade_time) {
  86       set_gain(1.0);
  87       fade_state = NoFading;
  88     } else {
  89       set_gain(time / fade_time);
  90     }
  91   } else if(fade_state == FadingOff) {
  92     float time = real_time - fade_start_time;
  93     if(time >= fade_time) {
  94       stop();
  95       fade_state = NoFading;
  96     } else {
  97       set_gain( (fade_time-time) / fade_time);
  98     }
  99   }
 100 }
 101
 102 void
 103 StreamSoundSource::set_fading(FadeState state, float fade_time)
 104 {
 105   this->fade_state = state;
 106   this->fade_time = fade_time;
 107   this->fade_start_time = real_time;
 108 }
 109
 110 bool
 111 StreamSoundSource::fillBufferAndQueue(ALuint buffer)
 112 {
 113   // fill buffer
 114   char* bufferdata = new char[STREAMFRAGMENTSIZE];
 115   size_t bytesread = 0;
 116   do {
 117     bytesread += file->read(bufferdata + bytesread,
 118         STREAMFRAGMENTSIZE - bytesread);
 119     // end of sound file
 120     if(bytesread < STREAMFRAGMENTSIZE) {
 121       if(looping)
 122         file->reset();
 123       else
 124         break;
 125     }
 126   } while(bytesread < STREAMFRAGMENTSIZE);
 127
 128   if(bytesread > 0) {
 129     ALenum format = SoundManager::get_sample_format(file);
 130     alBufferData(buffer, format, bufferdata, bytesread, file->rate);
 131     delete[] bufferdata;
 132     SoundManager::check_al_error("Couldn't refill audio buffer: ");
 133
 134     alSourceQueueBuffers(source, 1, &buffer);
 135     SoundManager::check_al_error("Couldn't queue audio buffer: ");
 136   }
 137
 138   // return false if there aren't more buffers to fill
 139   return bytesread >= STREAMFRAGMENTSIZE;
 140 }
 141