/home/maxime/Projets/Mixxx/1.10/mixxx/src/midi/midideviceportmidi.cpp

Go to the documentation of this file.

/***************************************************************************
*                                                                         *
*   This program 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.                                   *
*                                                                         *
***************************************************************************/

#include <QtCore>
#include "configobject.h"
#include "midimapping.h"
#include "midideviceportmidi.h"

QMutex MidiDevicePortMidi::m_sPMLock;   // PortMidi is not thread-safe

MidiDevicePortMidi::MidiDevicePortMidi(MidiMapping* mapping,
                                       const PmDeviceInfo* inputDeviceInfo,
                                       const PmDeviceInfo* outputDeviceInfo,
                                       int inputDeviceIndex,
                                       int outputDeviceIndex)
                                        : MidiDevice(mapping)
{
    m_pInputStream = NULL;
    m_pOutputStream = NULL;
    m_bStopRequested = false;
    m_pInputDeviceInfo = inputDeviceInfo;
    m_pOutputDeviceInfo = outputDeviceInfo;
    m_iInputDeviceIndex = inputDeviceIndex;
    m_iOutputDeviceIndex = outputDeviceIndex;

    //Note: We prepend the input stream's index to the device's name to prevent duplicate devices from causing mayhem.
    m_strDeviceName = QString("%1. %2").arg(QString::number(m_iInputDeviceIndex)).arg(inputDeviceInfo->name);

    if (inputDeviceInfo) {
        m_bIsInputDevice = m_pInputDeviceInfo->input;
    }
    if (outputDeviceInfo) {
        m_bIsOutputDevice = m_pOutputDeviceInfo->output;
    }

    m_pMidiMapping->setName(m_strDeviceName);
}

MidiDevicePortMidi::~MidiDevicePortMidi()
{
    int success = close();

    // Wait until run() has actually finished before letting the
    //  destructor finish up
    if (success == 0) this->wait();
    //Otherwise the stream was already closed, so we don't have to wait.
}

int MidiDevicePortMidi::open()
{
    QMutexLocker Locker(&m_mutex); //Make this function thread safe.

    if (m_bIsOpen) {
        qDebug() << "PortMIDI device" << m_strDeviceName << "already open";
        return -1;
    }

    setReceiveInhibit(false);

    startup();

    m_bStopRequested = false;

    if (m_strDeviceName == MIXXX_PORTMIDI_NO_DEVICE_STRING)
        return -1;

    m_sPMLock.lock();
    PmError err = Pm_Initialize();
    m_sPMLock.unlock();
    if( err != pmNoError )
    {
        qDebug() << "PortMidi error:" << Pm_GetErrorText(err);
        return -1;
    }

    if (m_pInputDeviceInfo)
    {
        if (m_bIsInputDevice)
        {
            if (midiDebugging()) qDebug() << "MidiDevicePortMidi: Opening" << m_pInputDeviceInfo->name << "index" << m_iInputDeviceIndex << "for input";

            m_sPMLock.lock();
            err = Pm_OpenInput( &m_pInputStream,
                    m_iInputDeviceIndex,
                    NULL, //No drive hacks
                    MIXXX_PORTMIDI_BUFFER_LEN,
                    NULL,
                    NULL);
            m_sPMLock.unlock();

            if( err != pmNoError )
            {
                qDebug() << "PortMidi error:" << Pm_GetErrorText(err);
                return -2;
            }
        }
    }
    if (m_pOutputDeviceInfo)
    {
        if (m_bIsOutputDevice)
        {
            if (midiDebugging()) qDebug() << "MidiDevicePortMidi: Opening" << m_pOutputDeviceInfo->name << "index" << m_iOutputDeviceIndex << "for output";

            m_sPMLock.lock();
            err = Pm_OpenOutput( &m_pOutputStream,
                    m_iOutputDeviceIndex,
                    NULL, // No driver hacks
                    0,      // No buffering
                    NULL, // Use PortTime for timing
                    NULL, // No time info
                    0);   // No latency compensation.
            m_sPMLock.unlock();

            if( err != pmNoError )
            {
                qDebug() << "PortMidi error:" << Pm_GetErrorText(err);
                return -2;
            }
        }
    }

    m_bIsOpen = true;
    start();

    return 0;

}

int MidiDevicePortMidi::close()
{
    setReceiveInhibit(true);    // Prevent deadlock

    if (!m_bIsOpen) {
        qDebug() << "PortMIDI device" << m_strDeviceName << "already closed";
        return -1;
    }

    shutdown();

    //shutdown() locks so we must lock after it.
    QMutexLocker Locker(&m_mutex);

    m_bStopRequested = true;

    if (m_pInputStream)
    {
        m_sPMLock.lock();
        PmError err = Pm_Close(m_pInputStream);
        if( err != pmNoError )
        {
            qDebug() << "PortMidi error:" << Pm_GetErrorText(err);
            m_sPMLock.unlock();
            return -1;
        }
        m_sPMLock.unlock();
    }

    if (m_pOutputStream)
    {
        m_sPMLock.lock();
        PmError err = Pm_Close(m_pOutputStream);
        if( err != pmNoError )
        {
            qDebug() << "PortMidi error:" << Pm_GetErrorText(err);
            m_sPMLock.unlock();
            return -1;
        }
        m_sPMLock.unlock();
    }

    m_bIsOpen = false;

    return 0;
}

void MidiDevicePortMidi::run()
{
    QThread::currentThread()->setObjectName(QString("PM %1").arg(m_strDeviceName));
    int numEvents = 0;
    bool stopRunning = false;
    // Storage for SysEx messages
    unsigned char receive_msg[1024];
    int receive_msg_index = 0;
    bool inSysex = false;
    bool endSysex = false;

    do
    {
        if (m_pInputStream)
        {
            // TODO: Inhibit receiving of MIDI messages to prevent race condition?
            m_sPMLock.lock();
            numEvents = Pm_Read(m_pInputStream, m_midiBuffer, MIXXX_PORTMIDI_BUFFER_LEN);
            m_sPMLock.unlock();

            if (numEvents < 0) {
                qDebug() << "PortMidi error:" << Pm_GetErrorText((PmError)numEvents);

                // Don't process anything, continue to loop
                numEvents = 0;
            }

            for (int i = 0; i < numEvents; i++)
            {
                unsigned char status = Pm_MessageStatus(m_midiBuffer[i].message);

                if ((status & 0xF8) == 0xF8) {
                    // Handle real-time MIDI messages at any time
                    MidiDevice::receive((MidiStatusByte)status, 0, 0, 0);
                }

                if (!inSysex) {
                    if (status == 0xF0) {
                        inSysex=true;
                        status = 0;
                    }
                    else {
                        unsigned char channel = status & 0x0F;
                        unsigned char note = Pm_MessageData1(m_midiBuffer[i].message);
                        unsigned char velocity = Pm_MessageData2(m_midiBuffer[i].message);

                        // mini-rant: this is WRONG. The MidiStatusByte enum does not
                        // contain the full range of possible MIDI status bytes (for
                        // example, 0x91) but the local 'status' could very well be
                        // '0x91', making the MidiStatusByte type meaningless (at least
                        // C enums aren't anything more than glorified constants, otherwise
                        // this would be bloody murder) -bkgood XXX FIXME TODO(bkgood)
                        MidiDevice::receive((MidiStatusByte)status, channel, note, velocity);
                    }
                }

                if (inSysex) {
                    int data = 0;
                    // Collect bytes from PmMessage
                    for (int shift = 0; shift < 32 && (data != MIDI_STATUS_EOX); shift += 8) {
                        receive_msg[receive_msg_index++] = data = 
                            (m_midiBuffer[i].message >> shift) & 0xFF;
                    }
                    // End System Exclusive message if the EOX byte or
                    //  a non-realtime status byte was received
                    if (data == MIDI_STATUS_EOX || status > 0x7F) endSysex=true;
                }
            }

            if (inSysex && endSysex) {
                MidiDevice::receive(receive_msg, receive_msg_index);
                inSysex=false;
                endSysex=false;
                receive_msg_index = 0;
            }

            // Check if new events came while we were processing, if not, sleep
            m_sPMLock.lock();
            PmError gotEvents = Pm_Poll(m_pInputStream);
            m_sPMLock.unlock();

            if (gotEvents == FALSE) {
                // Sleep this thread for 5 milliseconds between checking for new
                // MIDI event.
                usleep(5000);
            } else if (gotEvents < 0) {
                qDebug() << "PortMidi error:" << Pm_GetErrorText(gotEvents);
            }
        }

        m_mutex.lock();
        stopRunning = m_bStopRequested; //Cache locally for thread-safety.
        //Have to unlock inside the loop to give the other thread a chance to lock.
        m_mutex.unlock();

    } while (!stopRunning);
}

void MidiDevicePortMidi::sendShortMsg(unsigned int word)
{
    QMutexLocker Locker(&m_mutex);

    if (m_pOutputStream)
    {
        m_sPMLock.lock();
        PmError err = Pm_WriteShort(m_pOutputStream, 0, word);
        if( err != pmNoError ) qDebug() << "PortMidi sendShortMsg error:" << Pm_GetErrorText(err);
        m_sPMLock.unlock();
    }

}

// The sysex data must already contain the start byte 0xf0 and the end byte 0xf7.
void MidiDevicePortMidi::sendSysexMsg(unsigned char data[], unsigned int length)
{
    Q_UNUSED(length);   // We have to accept it even if we don't use it
                        // to be consistent with other MIDI APIs that do need it
    QMutexLocker Locker(&m_mutex);

    if (m_pOutputStream)
    {
        m_sPMLock.lock();
        PmError err = Pm_WriteSysEx(m_pOutputStream, 0, data);
        if( err != pmNoError ) qDebug() << "PortMidi sendSysexMsg error:" << Pm_GetErrorText(err);
        m_sPMLock.unlock();
    }
}