CStreamItem.cpp

Go to the documentation of this file.

/* Copyright (C) 2013 Wildfire Games.
 * This file is part of 0 A.D.
 *
 * 0 A.D. is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 2 of the License, or
 * (at your option) any later version.
 *
 * 0 A.D. is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with 0 A.D.  If not, see <http://www.gnu.org/licenses/>.
 */

#include "precompiled.h"

#include "CStreamItem.h"

#if CONFIG2_AUDIO

#include "soundmanager/data/OggData.h"
#include "soundmanager/SoundManager.h"

#include <iostream>

CStreamItem::CStreamItem(CSoundData* sndData)
{
    ResetVars();
    if (InitOpenAL())
        Attach(sndData);
}

CStreamItem::~CStreamItem()
{
    Stop();
    ReleaseOpenALStream();
}

void CStreamItem::ReleaseOpenALStream()
{   
    if (m_ALSource != 0)
    {
        int num_processed;
        AL_CHECK
        alGetSourcei(m_ALSource, AL_BUFFERS_PROCESSED, &num_processed);
        AL_CHECK

        if (num_processed > 0)
        {
            ALuint* al_buf = new ALuint[num_processed];
            alSourceUnqueueBuffers(m_ALSource, num_processed, al_buf);
            AL_CHECK
            delete[] al_buf;
        }
        alSourcei(m_ALSource, AL_BUFFER, 0);
        AL_CHECK
        ((CSoundManager*)g_SoundManager)->ReleaseALSource(m_ALSource);
        AL_CHECK
        m_ALSource = 0;
    }
}

bool CStreamItem::IdleTask()
{
    AL_CHECK
    HandleFade();
    AL_CHECK

    if (m_ALSource != 0)
    {
        int proc_state;
        alGetSourcei(m_ALSource, AL_SOURCE_STATE, &proc_state);
        AL_CHECK
        
        if (proc_state == AL_STOPPED)
        {
            if (m_LastPlay)
                return (proc_state != AL_STOPPED);
        }
        else if (m_SoundData != NULL)
        {
            COggData* theData = (COggData*)m_SoundData;
            
            if (! theData->IsFileFinished())
            {
                int num_processed;
                alGetSourcei(m_ALSource, AL_BUFFERS_PROCESSED, &num_processed);
                AL_CHECK
                
                if (num_processed > 0)
                {
                    ALuint* al_buf = new ALuint[num_processed];
                    alSourceUnqueueBuffers(m_ALSource, num_processed, al_buf);
                    AL_CHECK
                    int didWrite = theData->FetchDataIntoBuffer(num_processed, al_buf);
                    alSourceQueueBuffers(m_ALSource, didWrite, al_buf);
                    AL_CHECK
                    delete[] al_buf;
                }
            }
            else if (GetLooping())
            {
                theData->ResetFile();
            }
            else
            {
                int num_processed;
                alGetSourcei(m_ALSource, AL_BUFFERS_QUEUED, &num_processed);
                m_ShouldBePlaying = ( num_processed == 0 );
            }
        }
    }
    AL_CHECK
    return true;
}

void CStreamItem::Attach(CSoundData* itemData)
{
    if (m_SoundData != NULL)
    {
        CSoundData::ReleaseSoundData(m_SoundData);
        m_SoundData = 0;
    }

    if (itemData != NULL)
    {
        m_SoundData = itemData->IncrementCount();
        alSourceQueueBuffers(m_ALSource, m_SoundData->GetBufferCount(), (const ALuint *)m_SoundData->GetBufferPtr());
        AL_CHECK
    }
}

void CStreamItem::SetLooping(bool loops)
{
    m_Looping = loops;
}

#endif // CONFIG2_AUDIO