JackClient.cpp

Go to the documentation of this file.

/*******************************************************************************
 * JackClient.cpp (JackFX) 
 ******************************************************************************/

#include "JackClient.h"
#include "SoundFrame.h"

#include "ISoundElement.h"
#include "JackPort.h"

JackClient* JackClient::m_singleton = NULL;

JackClient::JackClient()
{
    assert(!m_singleton);
    m_singleton = this;

    jack_status_t status;

    m_client = jack_client_open("JackFX", JackNullOption, &status);
    if (m_client == NULL) {
        if (status & JackServerFailed) {
            throw jack_init_error("JackFX was unable to connect to the Jack server.");
        }
        else {
            throw jack_init_error("Jack client initialization failed.");
        }
    }

    if (status & JackServerStarted) {
        cout << "Jack server started." << endl;
    }

    if (status & JackNameNotUnique) {
        cout << "Client with name `JackFX' already existed. Client named `" << 
                jack_get_client_name(m_client) << "'" << endl;
    }

    jack_set_process_callback(m_client, JackClient::JackProcess, this);
    jack_on_shutdown(m_client, JackClient::JackShutdown, this);

    if (jack_activate(m_client)) {
        jack_client_close(m_client);
        throw jack_init_error("Unable to activate client.");
    }

    cout << "Jack client initialized. Sample rate is " << jack_get_sample_rate(m_client) << endl;
}

JackClient::~JackClient()
{
    jack_client_close(m_client);
    m_singleton = NULL;
}

jack_client_t* JackClient::GetClient() const
{
    if (m_client) {
        return m_client;
    }
    throw jack_client_error("Jack client does not exist.");
}

JackClient* JackClient::GetSingleton()
{
    if (m_singleton) {
        return m_singleton;
    }
    throw jack_client_error("Jack client does not exist.");
}

pthread_t JackClient::GetThread() const
{
    return jack_client_thread_id(m_client);
}

void JackClient::Process(jack_nframes_t nframes)
{
    //Generate a tick id
    unsigned int tickid = rand();

    list<JackMidiPort*>::iterator mi;
    for (mi = m_midiports.begin(); mi != m_midiports.end(); ++mi) {
        (*mi)->Read(nframes);
    }

    list<ISoundSource*>::iterator si;
    for (si = m_sources.begin(); si != m_sources.end(); ++si) {
        ISoundSource::Lock l(*si);
        //Unconditionally update all of our sound sources.
        (*si)->_Update(tickid, nframes);
    }

    list<ISoundElement*>::iterator ei;
    bool didwork = true;
    while (didwork) {
        //cout << "Executing pass." << endl;
        didwork = false;
        for (ei = m_elements.begin(); ei != m_elements.end(); ++ei) {
            //cout << "Testing " << *ei << endl;
            if ((*ei)->_Updatable(tickid)) {
                //cout << "Updating " << *ei << endl;
                (*ei)->_Update(tickid, nframes);
                didwork = true;
            }
        }
    }
}

void JackClient::JackShutdown(void* arg)
{
    JackClient* j = static_cast<JackClient*>(arg);
}

int JackClient::JackProcess(jack_nframes_t nframes, void* arg)
{
    JackClient* j = static_cast<JackClient*>(arg);
    j->Process(nframes);
    return 0;
}