ISoundElement.cpp

Go to the documentation of this file.

/*******************************************************************************
 * ISoundElement.cpp (JackFX) 
 ******************************************************************************/

#include "ISoundElement.h"
#include "JackClient.h"

ISoundElement::ISoundElement()
{
    JackClient::GetSingleton()->m_elements.push_back(this);
    pthread_mutex_init(&m_mtx, NULL);
}

ISoundElement::~ISoundElement()
{
    pthread_mutex_destroy(&m_mtx);
    try {
        JackClient::GetSingleton()->m_elements.remove(this);
    }
    catch(...) {} //Ignore.
}


SoundFrame& ISoundElement::GetPipe()
{
    return m_pipe;
}

void ISoundElement::Process(jack_nframes_t count)
{
    GetPipe().Zero();
    list<ISoundElement*>::iterator i;
    for (i = m_inputs.begin(); i != m_inputs.end(); i++) {
        GetPipe() += (*i)->GetPipe();
    }
}

void ISoundElement::AddInput(ISoundElement* element)
{
    Lock l(this);
    m_inputs.push_back(element);
}

void ISoundElement::RemoveInput(ISoundElement* element)
{
    Lock l(this);
    m_inputs.remove(element);
}

ISoundElement* ISoundElement::GetParameter(const string& pname)
{
    Lock l(this);
    map<string, ISoundElement*>::iterator i = m_parameters.find(pname);
    if (i != m_parameters.end()) {
        return i->second;
    }
    throw runtime_error("No parameter named " + pname + "." );
}

void ISoundElement::SetParameter(const string& pname, ISoundElement* e)
{
    m_parameters[pname] = e;
}

void ISoundElement::DelParameter(const string& pname)
{
    m_parameters.erase(pname);
}

bool ISoundElement::_Updatable(unsigned int tickid)
{
    Lock l(this);

    list<ISoundElement*>::iterator i;
    for (i = m_inputs.begin(); i != m_inputs.end(); ++i) {
        //If any of our inputs still need updating, we're not yet updatable.
        if ((*i)->_Ready(tickid) == true) {
            return false;
        }
    }

    map<string, ISoundElement*>::iterator pi;
    for (pi = m_parameters.begin(); pi != m_parameters.end(); ++pi) {
        //If any of our parameters still need updating, we're not yet updatable.
        if (pi->second->_Ready(tickid) == true) {
            return false;
        }
    }

    return true && _Ready(tickid);
}

bool ISoundElement::_Ready(unsigned int tickid)
{
    //Return whether our pipe is out of date.
    return m_lasttickid != tickid;
}

void ISoundElement::_Update(unsigned int tickid, jack_nframes_t count)
{
    //Lock l(this);

    m_lasttickid = tickid;
    Process(count);
}



ISoundSource::ISoundSource()
{
    JackClient::GetSingleton()->m_sources.push_back(this);
}

ISoundSource::~ISoundSource()
{
    try {
        JackClient::GetSingleton()->m_sources.remove(this);
    }
    catch(...) {} //Ignore.
}

void ISoundSource::Process(jack_nframes_t count)
{
    GetPipe().Set(count);
    GetPipe().Zero();
}

ISoundElement::Lock::Lock(ISoundElement* e) : m_element(e)
{
    pthread_mutex_lock(&(m_element->m_mtx));
}

ISoundElement::Lock::~Lock()
{
    pthread_mutex_unlock(&(m_element->m_mtx));
}