root/trunk/libs/hydrogen/src/hydrogen.cpp @ 1467

/*
 * Hydrogen
 * Copyright(c) 2002-2008 by Alex >Comix< Cominu [comix@users.sourceforge.net]
 *
 * http://www.hydrogen-music.org
 *
 * 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.
 *
 * This program 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 this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 */

#include "config.h"

#ifdef WIN32
#    include "hydrogen/timeHelper.h"
#else
#    include <unistd.h>
#    include <sys/time.h>
#endif

#include <pthread.h>
#include <cassert>
#include <cstdio>
#include <deque>
#include <queue>
#include <iostream>
#include <ctime>
#include <cmath>
#include <algorithm>

#include <QtCore/QMutex>
#include <QtCore/QMutexLocker>

#include <hydrogen/LocalFileMng.h>
#include <hydrogen/event_queue.h>
#include <hydrogen/adsr.h>
#include <hydrogen/SoundLibrary.h>
#include <hydrogen/h2_exception.h>
#include <hydrogen/audio_engine.h>
#include <hydrogen/instrument.h>
#include <hydrogen/sample.h>
#include <hydrogen/hydrogen.h>
#include <hydrogen/Pattern.h>
#include <hydrogen/note.h>
#include <hydrogen/fx/LadspaFX.h>
#include <hydrogen/fx/Effects.h>
#include <hydrogen/IO/AudioOutput.h>
#include <hydrogen/IO/JackOutput.h>
#include <hydrogen/IO/NullDriver.h>
#include <hydrogen/IO/MidiInput.h>
#include <hydrogen/IO/MidiOutput.h>
#include <hydrogen/IO/CoreMidiDriver.h>
#include <hydrogen/IO/TransportInfo.h>
#include <hydrogen/Preferences.h>
#include <hydrogen/data_path.h>
#include <hydrogen/sampler/Sampler.h>
#include <hydrogen/midiMap.h>
#include <hydrogen/playlist.h>

#include "IO/OssDriver.h"
#include "IO/FakeDriver.h"
#include "IO/AlsaAudioDriver.h"
#include "IO/PortAudioDriver.h"
#include "IO/DiskWriterDriver.h"
#include "IO/AlsaMidiDriver.h"
#include "IO/PortMidiDriver.h"
#include "IO/CoreAudioDriver.h"

namespace H2Core
{

// GLOBALS

// info
float m_fMasterPeak_L = 0.0f;           ///< Master peak (left channel)
float m_fMasterPeak_R = 0.0f;           ///< Master peak (right channel)
float m_fProcessTime = 0.0f;            ///< time used in process function
float m_fMaxProcessTime = 0.0f;         ///< max ms usable in process with no xrun
//~ info


// beatcounter

//100,000 ms in 1 second.
#define US_DIVIDER .000001

float m_ntaktoMeterCompute = 1;         ///< beatcounter note length
int m_nbeatsToCount = 4;                ///< beatcounter beats to count
int eventCount = 1;                     ///< beatcounter event
int tempochangecounter = 0;             ///< count tempochanges for timeArray
int beatCount = 1;                      ///< beatcounter beat to count
double beatDiffs[16];                   ///< beat diff
timeval currentTime, lastTime;          ///< timeval
double lastBeatTime, currentBeatTime, beatDiff;         ///< timediff
float beatCountBpm;                     ///< bpm
int m_nCoutOffset = 0;                  ///ms default 0
int m_nStartOffset = 0;                 ///ms default 0
//~ beatcounter

//jack time master
float m_nNewBpmJTM = 120;
unsigned long m_nHumantimeFrames = 0;
//~ jack time master

AudioOutput *m_pAudioDriver = NULL;     ///< Audio output
QMutex mutex_OutputPointer;     ///< Mutex for audio output pointer, allows multiple readers
                                        ///< When locking this AND AudioEngine, always lock AudioEngine first.
MidiInput *m_pMidiDriver = NULL;        ///< MIDI input
MidiOutput *m_pMidiDriverOut = NULL;    ///< MIDI output

// overload the the > operator of Note objects for priority_queue
struct compare_pNotes {
bool operator() (Note* pNote1, Note* pNote2) {
        return (pNote1->m_nHumanizeDelay
                + pNote1->get_position() * m_pAudioDriver->m_transport.m_nTickSize)
                >
                (pNote2->m_nHumanizeDelay
                 + pNote2->get_position() * m_pAudioDriver->m_transport.m_nTickSize);
}
};

                                                               /// Song Note FIFO
std::priority_queue<Note*, std::deque<Note*>, compare_pNotes > m_songNoteQueue;
std::deque<Note*> m_midiNoteQueue;      ///< Midi Note FIFO

Song *m_pSong;                          ///< Current song
PatternList* m_pNextPatterns;           ///< Next pattern (used only in Pattern mode)
bool m_bAppendNextPattern;              ///< Add the next pattern to the list instead
                                        /// of replace.
bool m_bDeleteNextPattern;              ///< Delete the next pattern from the list.


PatternList* m_pPlayingPatterns;
int m_nSongPos;                         ///< Is the position inside the song

int m_nSelectedPatternNumber;
int m_nSelectedInstrumentNumber;

Instrument *m_pMetronomeInstrument = NULL;      ///< Metronome instrument


// Buffers used in the process function
unsigned m_nBufferSize = 0;
float *m_pMainBuffer_L = NULL;
float *m_pMainBuffer_R = NULL;


Hydrogen* hydrogenInstance = NULL;   ///< Hydrogen class instance (used for log)


int  m_audioEngineState = STATE_UNINITIALIZED;  ///< Audio engine state



#ifdef LADSPA_SUPPORT
float m_fFXPeak_L[MAX_FX];
float m_fFXPeak_R[MAX_FX];
#endif


int m_nPatternStartTick = -1;
int m_nPatternTickPosition = 0;
int m_nLookaheadFrames = 0;

// used in findPatternInTick
int m_nSongSizeInTicks = 0;

struct timeval m_currentTickTime;

unsigned long m_nRealtimeFrames = 0;
unsigned int m_naddrealtimenotetickposition = 0;




// PROTOTYPES
void    audioEngine_init();
void    audioEngine_destroy();
int     audioEngine_start( bool bLockEngine = false, unsigned nTotalFrames = 0 );
void    audioEngine_stop( bool bLockEngine = false );
void    audioEngine_setSong( Song *newSong );
void    audioEngine_removeSong();
static void     audioEngine_noteOn( Note *note );
//static void   audioEngine_noteOff( Note *note );
int     audioEngine_process( uint32_t nframes, void *arg );
inline void audioEngine_clearNoteQueue();
inline void audioEngine_process_checkBPMChanged();
inline void audioEngine_process_playNotes( unsigned long nframes );
inline void audioEngine_process_transport();

inline unsigned audioEngine_renderNote( Note* pNote, const unsigned& nBufferSize );
inline int audioEngine_updateNoteQueue( unsigned nFrames );
inline void audioEngine_prepNoteQueue();

inline int findPatternInTick( int tick, bool loopMode, int *patternStartTick );

void audioEngine_seek( long long nFrames, bool bLoopMode = false );

void audioEngine_restartAudioDrivers();
void audioEngine_startAudioDrivers();
void audioEngine_stopAudioDrivers();


inline timeval currentTime2()
{
        struct timeval now;
        gettimeofday( &now, NULL );
        return now;
}



inline int randomValue( int max )
{
        return rand() % max;
}


inline float getGaussian( float z )
{
        // gaussian distribution -- dimss
        float x1, x2, w;
        do {
                x1 = 2.0 * ( ( ( float ) rand() ) / RAND_MAX ) - 1.0;
                x2 = 2.0 * ( ( ( float ) rand() ) / RAND_MAX ) - 1.0;
                w = x1 * x1 + x2 * x2;
        } while ( w >= 1.0 );

        w = sqrtf( ( -2.0 * logf( w ) ) / w );
        return x1 * w * z + 0.0; // tunable
}



void audioEngine_raiseError( unsigned nErrorCode )
{
        EventQueue::get_instance()->push_event( EVENT_ERROR, nErrorCode );
}



void updateTickSize()
{
        float sampleRate = ( float )m_pAudioDriver->getSampleRate();
        m_pAudioDriver->m_transport.m_nTickSize =
                ( sampleRate * 60.0 /  m_pSong->__bpm / m_pSong->__resolution );
}



void audioEngine_init()
{
        _INFOLOG( "*** Hydrogen audio engine init ***" );

        // check current state
        if ( m_audioEngineState != STATE_UNINITIALIZED ) {
                _ERRORLOG( "Error the audio engine is not in UNINITIALIZED state" );
                AudioEngine::get_instance()->unlock();
                return;
        }

        m_pSong = NULL;
        m_pPlayingPatterns = new PatternList();
        m_pNextPatterns = new PatternList();
        m_nSongPos = -1;
        m_nSelectedPatternNumber = 0;
        m_nSelectedInstrumentNumber = 0;
        m_nPatternTickPosition = 0;
        m_pMetronomeInstrument = NULL;
        m_pAudioDriver = NULL;

        m_pMainBuffer_L = NULL;
        m_pMainBuffer_R = NULL;

        srand( time( NULL ) );

        // Create metronome instrument
        QString sMetronomeFilename = QString( "%1/click.wav" )
                                        .arg( DataPath::get_data_path() );
        m_pMetronomeInstrument =
                new Instrument( sMetronomeFilename, "metronome", new ADSR() );
        m_pMetronomeInstrument->set_layer(
                new InstrumentLayer( Sample::load( sMetronomeFilename ) ),
                0
                );

        // Change the current audio engine state
        m_audioEngineState = STATE_INITIALIZED;

#ifdef LADSPA_SUPPORT
        Effects::create_instance();
#endif
        AudioEngine::create_instance();
        Playlist::create_instance();

        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_INITIALIZED );

}



void audioEngine_destroy()
{
        // check current state
        if ( m_audioEngineState != STATE_INITIALIZED ) {
                _ERRORLOG( "Error the audio engine is not in INITIALIZED state" );
                return;
        }
        AudioEngine::get_instance()->get_sampler()->stop_playing_notes();

        AudioEngine::get_instance()->lock( RIGHT_HERE );
        _INFOLOG( "*** Hydrogen audio engine shutdown ***" );

        // delete all copied notes in the song notes queue
        while ( !m_songNoteQueue.empty() ) {
                m_songNoteQueue.top()->get_instrument()->dequeue();
                delete m_songNoteQueue.top();
                m_songNoteQueue.pop();
        }
        // delete all copied notes in the midi notes queue
        for ( unsigned i = 0; i < m_midiNoteQueue.size(); ++i ) {
                Note *note = m_midiNoteQueue[i];
                delete note;
                note = NULL;
        }
        m_midiNoteQueue.clear();

        // change the current audio engine state
        m_audioEngineState = STATE_UNINITIALIZED;

        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_UNINITIALIZED );

        delete m_pPlayingPatterns;
        m_pPlayingPatterns = NULL;

        delete m_pNextPatterns;
        m_pNextPatterns = NULL;

        delete m_pMetronomeInstrument;
        m_pMetronomeInstrument = NULL;

        AudioEngine::get_instance()->unlock();
}





/// Start playing
/// return 0 = OK
/// return -1 = NULL Audio Driver
/// return -2 = Driver connect() error
int audioEngine_start( bool bLockEngine, unsigned nTotalFrames )
{
        if ( bLockEngine ) {
                AudioEngine::get_instance()->lock( RIGHT_HERE );
        }

        _INFOLOG( "[audioEngine_start]" );

        // check current state
        if ( m_audioEngineState != STATE_READY ) {
                _ERRORLOG( "Error the audio engine is not in READY state" );
                if ( bLockEngine ) {
                        AudioEngine::get_instance()->unlock();
                }
                return 0;       // FIXME!!
        }

        m_fMasterPeak_L = 0.0f;
        m_fMasterPeak_R = 0.0f;
        m_pAudioDriver->m_transport.m_nFrames = nTotalFrames;   // reset total frames
        m_nSongPos = -1;
        m_nPatternStartTick = -1;
        m_nPatternTickPosition = 0;

        // prepare the tickSize for this song
        updateTickSize();

        // change the current audio engine state
        m_audioEngineState = STATE_PLAYING;
        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_PLAYING );

        if ( bLockEngine ) {
                AudioEngine::get_instance()->unlock();
        }
        return 0; // per ora restituisco sempre OK
}



/// Stop the audio engine
void audioEngine_stop( bool bLockEngine )
{
        if ( bLockEngine ) {
                AudioEngine::get_instance()->lock( RIGHT_HERE );
        }
        _INFOLOG( "[audioEngine_stop]" );

        // check current state
        if ( m_audioEngineState != STATE_PLAYING ) {
                _ERRORLOG( "Error the audio engine is not in PLAYING state" );
                if ( bLockEngine ) {
                        AudioEngine::get_instance()->unlock();
                }
                return;
        }

        // change the current audio engine state
        m_audioEngineState = STATE_READY;
        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_READY );

        m_fMasterPeak_L = 0.0f;
        m_fMasterPeak_R = 0.0f;
//      m_nPatternTickPosition = 0;
        m_nPatternStartTick = -1;

        // delete all copied notes in the song notes queue
        while(!m_songNoteQueue.empty()){
                m_songNoteQueue.top()->get_instrument()->dequeue();
                delete m_songNoteQueue.top();
                m_songNoteQueue.pop();
        }
        /*      // delete all copied notes in the playing notes queue
                for (unsigned i = 0; i < m_playingNotesQueue.size(); ++i) {
                        Note *note = m_playingNotesQueue[i];
                        delete note;
                }
                m_playingNotesQueue.clear();
        */

        // delete all copied notes in the midi notes queue
        for ( unsigned i = 0; i < m_midiNoteQueue.size(); ++i ) {
                Note *note = m_midiNoteQueue[i];
                delete note;
        }
        m_midiNoteQueue.clear();

        if ( bLockEngine ) {
                AudioEngine::get_instance()->unlock();
        }
}

//
///  Update Tick size and frame position in the audio driver from Song->__bpm
//
inline void audioEngine_process_checkBPMChanged()
{

        if ( ( m_audioEngineState == STATE_READY ) || ( m_audioEngineState == STATE_PLAYING ) ) {

                float fNewTickSize =
                        m_pAudioDriver->getSampleRate() * 60.0
                        / m_pSong->__bpm
                        / m_pSong->__resolution;

                if ( fNewTickSize != m_pAudioDriver->m_transport.m_nTickSize ) {
                        // cerco di convertire ...
                        float fTickNumber =
                                ( float )m_pAudioDriver->m_transport.m_nFrames
                                / ( float )m_pAudioDriver->m_transport.m_nTickSize;

                        m_pAudioDriver->m_transport.m_nTickSize = fNewTickSize;

                        if ( m_pAudioDriver->m_transport.m_nTickSize == 0 ) {
                                return;
                        }

                        _WARNINGLOG( "Tempo change: Recomputing ticksize and frame position" );
                        long long nNewFrames = ( long long )( fTickNumber * fNewTickSize );
                        // update frame position
                        m_pAudioDriver->m_transport.m_nFrames = nNewFrames;
                        
#ifdef JACK_SUPPORT
                        if ( "JackOutput" == m_pAudioDriver->get_class_name()
                             && m_audioEngineState == STATE_PLAYING ) {
                                static_cast< JackOutput* >( m_pAudioDriver )
                                        ->calculateFrameOffset();
                        }
#endif
                        EventQueue::get_instance()->push_event( EVENT_RECALCULATERUBBERBAND, -1);
                }
        }
}

inline void audioEngine_process_playNotes( unsigned long nframes )
{
        unsigned int framepos;

        if (  m_audioEngineState == STATE_PLAYING ) {
                framepos = m_pAudioDriver->m_transport.m_nFrames;
        } else {
                // use this to support realtime events when not playing
                framepos = m_nRealtimeFrames;
        }

        // reading from m_songNoteQueue
        while ( !m_songNoteQueue.empty() ) {
                Note *pNote = m_songNoteQueue.top();

                // verifico se la nota rientra in questo ciclo
                unsigned int noteStartInFrames =
                        (int)( pNote->get_position() * m_pAudioDriver->m_transport.m_nTickSize );
                        
                // if there is a negative Humanize delay, take into account so
                // we don't miss the time slice.  ignore positive delay, or we
                // might end the queue processing prematurely based on NoteQueue
                // placement.  the sampler handles positive delay.
                if (pNote->m_nHumanizeDelay < 0) {
                        noteStartInFrames += pNote->m_nHumanizeDelay;
                }

                // m_nTotalFrames <= NotePos < m_nTotalFrames + bufferSize
                bool isNoteStart = ( ( noteStartInFrames >= framepos )
                                     && ( noteStartInFrames < ( framepos + nframes ) ) );
                bool isOldNote = noteStartInFrames < framepos;
                if ( isNoteStart || isOldNote ) {
                        // Humanize - Velocity parameter
                        if ( m_pSong->get_humanize_velocity_value() != 0 ) {
                                float random = m_pSong->get_humanize_velocity_value()
                                               * getGaussian( 0.2 );
                                pNote->set_velocity(
                                        pNote->get_velocity()
                                        + ( random
                                            - ( m_pSong->get_humanize_velocity_value() / 2.0 ) ) 
                                        );
                                if ( pNote->get_velocity() > 1.0 ) {
                                        pNote->set_velocity( 1.0 );
                                } else if ( pNote->get_velocity() < 0.0 ) {
                                        pNote->set_velocity( 0.0 );
                                }
                        }

                        // Random Pitch ;)
                        const float fMaxPitchDeviation = 2.0;
                        pNote->set_pitch( pNote->get_pitch()
                                          + ( fMaxPitchDeviation * getGaussian( 0.2 )
                                              - fMaxPitchDeviation / 2.0 )
                                          * pNote->get_instrument()->get_random_pitch_factor() );

                        Instrument * noteInstrument = pNote->get_instrument();
                        if ( noteInstrument->is_stop_notes() ){ 
                                Note *pOffNote = new Note( noteInstrument,
                                                        0.0,
                                                        0.0,
                                                        0.0,
                                                        0.0,
                                                        -1,
                                                        0 );
                                pOffNote->set_noteoff( true );
                                AudioEngine::get_instance()->get_sampler()->note_on( pOffNote );
                        }

                        AudioEngine::get_instance()->get_sampler()->note_on( pNote );

                        m_songNoteQueue.pop(); // rimuovo la nota dalla lista di note
                        pNote->get_instrument()->dequeue();
                        // raise noteOn event
                        int nInstrument = m_pSong->get_instrument_list()
                                                 ->get_pos( pNote->get_instrument() );
                        EventQueue::get_instance()->push_event( EVENT_NOTEON, nInstrument );
                        continue;
                } else {
                        // this note will not be played
                        break;
                }
        }
}


void audioEngine_seek( long long nFrames, bool bLoopMode )
{
        if ( m_pAudioDriver->m_transport.m_nFrames == nFrames ) {
                return;
        }

        if ( nFrames < 0 ) {
                _ERRORLOG( "nFrames < 0" );
        }

        char tmp[200];
        sprintf( tmp, "seek in %lld (old pos = %d)",
                 nFrames,
                 ( int )m_pAudioDriver->m_transport.m_nFrames );
        _INFOLOG( tmp );

        m_pAudioDriver->m_transport.m_nFrames = nFrames;

        int tickNumber_start = ( unsigned )(
                m_pAudioDriver->m_transport.m_nFrames
                / m_pAudioDriver->m_transport.m_nTickSize );
//      sprintf(tmp, "[audioEngine_seek()] tickNumber_start = %d", tickNumber_start);
//      hydrogenInstance->infoLog(tmp);

        bool loop = m_pSong->is_loop_enabled();

        if ( bLoopMode ) {
                loop = true;
        }
        
        m_nSongPos = findPatternInTick( tickNumber_start, loop, &m_nPatternStartTick );
//      sprintf(tmp, "[audioEngine_seek()] m_nSongPos = %d", m_nSongPos);
//      hydrogenInstance->infoLog(tmp);

        audioEngine_clearNoteQueue();
}



inline void audioEngine_process_transport()
{
        if ( ( m_audioEngineState == STATE_READY )
             || ( m_audioEngineState == STATE_PLAYING ) ) {
                m_pAudioDriver->updateTransportInfo();
                unsigned long nNewFrames = m_pAudioDriver->m_transport.m_nFrames;

                // ??? audioEngine_seek returns IMMEDIATELY
                // when nNewFrames == m_pAudioDriver->m_transport.m_nFrames ???
                // audioEngine_seek( nNewFrames, true );

                switch ( m_pAudioDriver->m_transport.m_status ) {
                case TransportInfo::ROLLING:

                        if ( m_audioEngineState == STATE_READY ) {
                                audioEngine_start( false, nNewFrames ); // no engine lock
                        }

                        if ( m_pSong->__bpm != m_pAudioDriver->m_transport.m_nBPM ) {
                                _INFOLOG(
                                        QString( "song bpm: (%1) gets transport bpm: (%2)" )
                                        .arg( m_pSong->__bpm )
                                        .arg( m_pAudioDriver->m_transport.m_nBPM ) );

                                m_pSong->__bpm = m_pAudioDriver->m_transport.m_nBPM;
                        }

                        m_nRealtimeFrames = m_pAudioDriver->m_transport.m_nFrames;
                        break;


                case TransportInfo::STOPPED:
                        if ( m_audioEngineState == STATE_PLAYING ) {
                                audioEngine_stop( false );      // no engine lock
                        }

                        if ( m_pSong->__bpm != m_pAudioDriver->m_transport.m_nBPM ) {
                                m_pSong->__bpm = m_pAudioDriver->m_transport.m_nBPM;
                        }

                        // go ahead and increment the realtimeframes by buffersize
                        // to support our realtime keyboard and midi event timing
                        m_nRealtimeFrames += m_nBufferSize;
                        break;
                }
        }
}



void audioEngine_clearNoteQueue()
{
        //_INFOLOG( "clear notes...");

        // delete all copied notes in the song notes queue
        while (!m_songNoteQueue.empty()) {
                m_songNoteQueue.top()->get_instrument()->dequeue();
                delete m_songNoteQueue.top();
                m_songNoteQueue.pop();
        }

        AudioEngine::get_instance()->get_sampler()->stop_playing_notes();

        // delete all copied notes in the midi notes queue
        for ( unsigned i = 0; i < m_midiNoteQueue.size(); ++i ) {
                delete m_midiNoteQueue[i];
        }
        m_midiNoteQueue.clear();

}



/// Clear all audio buffers
inline void audioEngine_process_clearAudioBuffers( uint32_t nFrames )
{
        QMutexLocker mx( &mutex_OutputPointer );

        // clear main out Left and Right
        if ( m_pAudioDriver ) {
                m_pMainBuffer_L = m_pAudioDriver->getOut_L();
                m_pMainBuffer_R = m_pAudioDriver->getOut_R();
        } else {
                m_pMainBuffer_L = m_pMainBuffer_R = 0;
        }
        if ( m_pMainBuffer_L ) {
                memset( m_pMainBuffer_L, 0, nFrames * sizeof( float ) );
        }
        if ( m_pMainBuffer_R ) {
                memset( m_pMainBuffer_R, 0, nFrames * sizeof( float ) );
        }

#ifdef JACK_SUPPORT
        JackOutput* jo = dynamic_cast<JackOutput*>(m_pAudioDriver);
        if( jo && jo->has_track_outs() ) {
                float* buf;
                int k;
                for( k=0 ; k<jo->getNumTracks() ; ++k ) {
                        buf = jo->getTrackOut_L(k);
                        if( buf ) {
                                memset( buf, 0, nFrames * sizeof( float ) );
                        }
                        buf = jo->getTrackOut_R(k);
                        if( buf ) {
                                memset( buf, 0, nFrames * sizeof( float ) );
                        }
                }
        }
#endif

        mx.unlock();

#ifdef LADSPA_SUPPORT
        if ( m_audioEngineState >= STATE_READY ) {
                Effects* pEffects = Effects::get_instance();
                for ( unsigned i = 0; i < MAX_FX; ++i ) {       // clear FX buffers
                        LadspaFX* pFX = pEffects->getLadspaFX( i );
                        if ( pFX ) {
                                assert( pFX->m_pBuffer_L );
                                assert( pFX->m_pBuffer_R );
                                memset( pFX->m_pBuffer_L, 0, nFrames * sizeof( float ) );
                                memset( pFX->m_pBuffer_R, 0, nFrames * sizeof( float ) );
                        }
                }
        }
#endif
}

/// Main audio processing function. Called by audio drivers.
int audioEngine_process( uint32_t nframes, void* /*arg*/ )
{
        timeval startTimeval = currentTime2();

        audioEngine_process_clearAudioBuffers( nframes );

        if( m_audioEngineState < STATE_READY) {
                return 0;
        }


        AudioEngine::get_instance()->lock( RIGHT_HERE );

        if( m_audioEngineState < STATE_READY) {
                AudioEngine::get_instance()->unlock();
                return 0;
        }

        if ( m_nBufferSize != nframes ) {
                _INFOLOG(
                        QString( "Buffer size changed. Old size = %1, new size = %2" )
                        .arg( m_nBufferSize )
                        .arg( nframes )
                        );
                m_nBufferSize = nframes;
        }

        // m_pAudioDriver->bpm updates Song->__bpm. (!!(Calls audioEngine_seek))
        audioEngine_process_transport();
        audioEngine_process_checkBPMChanged(); // m_pSong->__bpm decides tick size

        bool sendPatternChange = false;
        // always update note queue.. could come from pattern or realtime input
        // (midi, keyboard)
        int res2 = audioEngine_updateNoteQueue( nframes );
        if ( res2 == -1 ) {     // end of song
                _INFOLOG( "End of song received, calling engine_stop()" );
                AudioEngine::get_instance()->unlock();
                m_pAudioDriver->stop();
                m_pAudioDriver->locate( 0 ); // locate 0, reposition from start of the song

                static QString sDiskWriterDriver("DiskWriterDriver");
                static QString sFakeDriver("FakeDriver");
                static QString sJackOutput("JackOutput");

                if ( ( m_pAudioDriver->get_class_name() == sDiskWriterDriver )
                     || ( m_pAudioDriver->get_class_name() == sFakeDriver ) ) {
                        _INFOLOG( "End of song." );
                        return 1;       // kill the audio AudioDriver thread
                }
#ifdef JACK_SUPPORT
                else if ( m_pAudioDriver->get_class_name() == sJackOutput ) {
                        // Do something clever :-s ... Jakob Lund
                        // Mainly to keep sync with Ardour.
                        static_cast<JackOutput*>(m_pAudioDriver)->locateInNCycles( 0 );
                }
#endif
                return 0;
        } else if ( res2 == 2 ) {       // send pattern change
                sendPatternChange = true;
        }

        // play all notes
        audioEngine_process_playNotes( nframes );

        // SAMPLER
        AudioEngine::get_instance()->get_sampler()->process( nframes, m_pSong );
        float* out_L = AudioEngine::get_instance()->get_sampler()->__main_out_L;
        float* out_R = AudioEngine::get_instance()->get_sampler()->__main_out_R;
        for ( unsigned i = 0; i < nframes; ++i ) {
                m_pMainBuffer_L[ i ] += out_L[ i ];
                m_pMainBuffer_R[ i ] += out_R[ i ];
        }

        // SYNTH
        AudioEngine::get_instance()->get_synth()->process( nframes );
        out_L = AudioEngine::get_instance()->get_synth()->m_pOut_L;
        out_R = AudioEngine::get_instance()->get_synth()->m_pOut_R;
        for ( unsigned i = 0; i < nframes; ++i ) {
                m_pMainBuffer_L[ i ] += out_L[ i ];
                m_pMainBuffer_R[ i ] += out_R[ i ];
        }


        timeval renderTime_end = currentTime2();



        timeval ladspaTime_start = renderTime_end;
#ifdef LADSPA_SUPPORT
        // Process LADSPA FX
        if ( m_audioEngineState >= STATE_READY ) {
                for ( unsigned nFX = 0; nFX < MAX_FX; ++nFX ) {
                        LadspaFX *pFX = Effects::get_instance()->getLadspaFX( nFX );
                        if ( ( pFX ) && ( pFX->isEnabled() ) ) {
                                pFX->processFX( nframes );
                                float *buf_L = NULL;
                                float *buf_R = NULL;
                                if ( pFX->getPluginType() == LadspaFX::STEREO_FX ) {
                                        buf_L = pFX->m_pBuffer_L;
                                        buf_R = pFX->m_pBuffer_R;
                                } else { // MONO FX
                                        buf_L = pFX->m_pBuffer_L;
                                        buf_R = buf_L;
                                }
                                for ( unsigned i = 0; i < nframes; ++i ) {
                                        m_pMainBuffer_L[ i ] += buf_L[ i ];
                                        m_pMainBuffer_R[ i ] += buf_R[ i ];
                                        if ( buf_L[ i ] > m_fFXPeak_L[nFX] )
                                                m_fFXPeak_L[nFX] = buf_L[ i ];
                                        if ( buf_R[ i ] > m_fFXPeak_R[nFX] )
                                                m_fFXPeak_R[nFX] = buf_R[ i ];
                                }
                        }
                }
        }
#endif
        timeval ladspaTime_end = currentTime2();

        // update master peaks
        float val_L;
        float val_R;
        if ( m_audioEngineState >= STATE_READY ) {
                for ( unsigned i = 0; i < nframes; ++i ) {
                        val_L = m_pMainBuffer_L[i];
                        val_R = m_pMainBuffer_R[i];
                        if ( val_L > m_fMasterPeak_L ) {
                                m_fMasterPeak_L = val_L;
                        }
                        if ( val_R > m_fMasterPeak_R ) {
                                m_fMasterPeak_R = val_R;
                        }
                }
        }

        // update total frames number
        if ( m_audioEngineState == STATE_PLAYING ) {
                m_pAudioDriver->m_transport.m_nFrames += nframes;
        }

//      float fRenderTime = (renderTime_end.tv_sec - renderTime_start.tv_sec) * 1000.0 + (renderTime_end.tv_usec - renderTime_start.tv_usec) / 1000.0;
        float fLadspaTime =
                ( ladspaTime_end.tv_sec - ladspaTime_start.tv_sec ) * 1000.0
                + ( ladspaTime_end.tv_usec - ladspaTime_start.tv_usec ) / 1000.0;

        timeval finishTimeval = currentTime2();
        m_fProcessTime =
                ( finishTimeval.tv_sec - startTimeval.tv_sec ) * 1000.0
                + ( finishTimeval.tv_usec - startTimeval.tv_usec ) / 1000.0;

        float sampleRate = ( float )m_pAudioDriver->getSampleRate();
        m_fMaxProcessTime = 1000.0 / ( sampleRate / nframes );

#ifdef CONFIG_DEBUG
        if ( m_fProcessTime > m_fMaxProcessTime ) {
                _WARNINGLOG( "" );
                _WARNINGLOG( "----XRUN----" );
                _WARNINGLOG( QString( "XRUN of %1 msec (%2 > %3)" )
                             .arg( ( m_fProcessTime - m_fMaxProcessTime ) )
                             .arg( m_fProcessTime ).arg( m_fMaxProcessTime ) );
                _WARNINGLOG( QString( "Ladspa process time = %1" ).arg( fLadspaTime ) );
                _WARNINGLOG( "------------" );
                _WARNINGLOG( "" );
                // raise xRun event
                EventQueue::get_instance()->push_event( EVENT_XRUN, -1 );
        }
#endif

        AudioEngine::get_instance()->unlock();

        if ( sendPatternChange ) {
                EventQueue::get_instance()->push_event( EVENT_PATTERN_CHANGED, -1 );
        }

        return 0;
}





void audioEngine_setupLadspaFX( unsigned nBufferSize )
{
        //_INFOLOG( "buffersize=" + to_string(nBufferSize) );

        if ( m_pSong == NULL ) {
                //_INFOLOG( "m_pSong=NULL" );
                return;
        }
        if ( nBufferSize == 0 ) {
                _ERRORLOG( "nBufferSize=0" );
                return;
        }

#ifdef LADSPA_SUPPORT
        for ( unsigned nFX = 0; nFX < MAX_FX; ++nFX ) {
                LadspaFX *pFX = Effects::get_instance()->getLadspaFX( nFX );
                if ( pFX == NULL ) {
                        return;
                }

                pFX->deactivate();

//              delete[] pFX->m_pBuffer_L;
//              pFX->m_pBuffer_L = NULL;
//              delete[] pFX->m_pBuffer_R;
//              pFX->m_pBuffer_R = NULL;
//              if ( nBufferSize != 0 ) {
                //pFX->m_nBufferSize = nBufferSize;
                //pFX->m_pBuffer_L = new float[ nBufferSize ];
                //pFX->m_pBuffer_R = new float[ nBufferSize ];
//              }

                Effects::get_instance()->getLadspaFX( nFX )->connectAudioPorts(
                    pFX->m_pBuffer_L,
                    pFX->m_pBuffer_R,
                    pFX->m_pBuffer_L,
                    pFX->m_pBuffer_R
                );
                pFX->activate();
        }
#endif
}



void audioEngine_renameJackPorts()
{
#ifdef JACK_SUPPORT
        // renames jack ports
        if ( m_pSong == NULL ) {
                return;
        }
        if ( m_pAudioDriver->get_class_name() == "JackOutput" ) {
                static_cast< JackOutput* >( m_pAudioDriver )->makeTrackOutputs( m_pSong );
        }
#endif
}



void audioEngine_setSong( Song *newSong )
{
        _WARNINGLOG( QString( "Set song: %1" ).arg( newSong->__name ) );

        AudioEngine::get_instance()->lock( RIGHT_HERE );

        if ( m_audioEngineState == STATE_PLAYING ) {
                m_pAudioDriver->stop();
                audioEngine_stop( false );
        }

        // check current state
        if ( m_audioEngineState != STATE_PREPARED ) {
                _ERRORLOG( "Error the audio engine is not in PREPARED state" );
        }

        m_pPlayingPatterns->clear();
        m_pNextPatterns->clear();

        EventQueue::get_instance()->push_event( EVENT_SELECTED_PATTERN_CHANGED, -1 );
        EventQueue::get_instance()->push_event( EVENT_PATTERN_CHANGED, -1 );
        EventQueue::get_instance()->push_event( EVENT_SELECTED_INSTRUMENT_CHANGED, -1 );

        //sleep( 1 );

        audioEngine_clearNoteQueue();

        assert( m_pSong == NULL );
        m_pSong = newSong;

        // setup LADSPA FX
        audioEngine_setupLadspaFX( m_pAudioDriver->getBufferSize() );

        // update ticksize
        audioEngine_process_checkBPMChanged();

        // find the first pattern and set as current
        if ( m_pSong->get_pattern_list()->get_size() > 0 ) {
                m_pPlayingPatterns->add( m_pSong->get_pattern_list()->get( 0 ) );
        }


        audioEngine_renameJackPorts();

        m_pAudioDriver->setBpm( m_pSong->__bpm );

        // change the current audio engine state
        m_audioEngineState = STATE_READY;

        m_pAudioDriver->locate( 0 );

        AudioEngine::get_instance()->unlock();

        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_READY );
}



void audioEngine_removeSong()
{
        AudioEngine::get_instance()->lock( RIGHT_HERE );

        if ( m_audioEngineState == STATE_PLAYING ) {
                m_pAudioDriver->stop();
                audioEngine_stop( false );
        }

        // check current state
        if ( m_audioEngineState != STATE_READY ) {
                _ERRORLOG( "Error the audio engine is not in READY state" );
                AudioEngine::get_instance()->unlock();
                return;
        }

        m_pSong = NULL;
        m_pPlayingPatterns->clear();
        m_pNextPatterns->clear();

        audioEngine_clearNoteQueue();

        // change the current audio engine state
        m_audioEngineState = STATE_PREPARED;
        AudioEngine::get_instance()->unlock();

        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_PREPARED );
}


// return -1 = end of song
// return 2 = send pattern changed event!!
inline int audioEngine_updateNoteQueue( unsigned nFrames )
{
        static int nLastTick = -1;
        bool bSendPatternChange = false;
        int nMaxTimeHumanize = 2000;
        int nLeadLagFactor = m_pAudioDriver->m_transport.m_nTickSize * 5;  // 5 ticks

        unsigned int framepos;
        if (  m_audioEngineState == STATE_PLAYING ) {
                framepos = m_pAudioDriver->m_transport.m_nFrames;
        } else {
                // use this to support realtime events when not playing
                framepos = m_nRealtimeFrames;
        }

        int tickNumber_start = 0;

        // We need to look ahead in the song for notes with negative offsets
        // from LeadLag or Humanize.  When starting from the beginning, we prime
        // the note queue with notes between 0 and nFrames plus
        // lookahead. lookahead should be equal or greater than the
        // nLeadLagFactor + nMaxTimeHumanize.
        int lookahead = nLeadLagFactor + nMaxTimeHumanize + 1;
        m_nLookaheadFrames = lookahead;
        if ( framepos == 0
             || ( m_audioEngineState == STATE_PLAYING
                  && m_pSong->get_mode() == Song::SONG_MODE
                  && m_nSongPos == -1 ) ) {
                tickNumber_start = (int)( framepos
                                          / m_pAudioDriver->m_transport.m_nTickSize );
        }
        else {
                tickNumber_start = (int)( (framepos + lookahead)
                                          / m_pAudioDriver->m_transport.m_nTickSize );
        }
        int tickNumber_end = (int)( (framepos + nFrames + lookahead)
                                    / m_pAudioDriver->m_transport.m_nTickSize );

        int tick = tickNumber_start;

//      _WARNINGLOG( "Lookahead: " + to_string( lookahead
//                                              / m_pAudioDriver->m_transport.m_nTickSize ) );
        // get initial timestamp for first tick
        gettimeofday( &m_currentTickTime, NULL );
        

        while ( tick <= tickNumber_end ) {
                if ( tick == nLastTick ) {
                        ++tick;
                        continue;
                } else {
                        nLastTick = tick;
                }


                // midi events now get put into the m_songNoteQueue as well,
                // based on their timestamp
                while ( m_midiNoteQueue.size() > 0 ) {
                        Note *note = m_midiNoteQueue[0];

                        if ( ( int )note->get_position() <= tick ) {
                                // printf ("tick=%d  pos=%d\n", tick, note->getPosition());
                                m_midiNoteQueue.pop_front();
                                note->get_instrument()->enqueue();
                                m_songNoteQueue.push( note );
                        } else {
                                break;
                        }
                }

                if (  m_audioEngineState != STATE_PLAYING ) {
                        // only keep going if we're playing
                        continue;
                }

//              if ( m_nPatternStartTick == -1 ) { // for debugging pattern mode :s
//                      _WARNINGLOG( "m_nPatternStartTick == -1; tick = "
//                                   + to_string( tick ) );
//              }


                // SONG MODE
                bool doErase = m_audioEngineState == STATE_PLAYING
                        && Preferences::get_instance()->getRecordEvents()
                        && Preferences::get_instance()->getDestructiveRecord()
                        && Preferences::get_instance()->m_nRecPreDelete == 0;
                if ( m_pSong->get_mode() == Song::SONG_MODE ) {
                        if ( m_pSong->get_pattern_group_vector()->size() == 0 ) {
                                // there's no song!!
                                _ERRORLOG( "no patterns in song." );
                                m_pAudioDriver->stop();
                                return -1;
                        }

                        m_nSongPos = findPatternInTick( tick,
                                                        m_pSong->is_loop_enabled(),
                                                        &m_nPatternStartTick );
                        if ( m_nSongSizeInTicks != 0 ) {
                                m_nPatternTickPosition = ( tick - m_nPatternStartTick )
                                                         % m_nSongSizeInTicks;
                        } else {
                                m_nPatternTickPosition = tick - m_nPatternStartTick;
                        }


                        if ( m_nPatternTickPosition == 0 ) {
                                bSendPatternChange = true;
                        }

//                      PatternList *pPatternList =
//                               (*(m_pSong->getPatternGroupVector()))[m_nSongPos];
                        if ( m_nSongPos == -1 ) {
                                _INFOLOG( "song pos = -1" );
                                if ( m_pSong->is_loop_enabled() == true ) {
                                        m_nSongPos = findPatternInTick( 0,
                                                                        true,
                                                                        &m_nPatternStartTick );
                                } else {

                                        _INFOLOG( "End of Song" );

                                        if( Hydrogen::get_instance()->getMidiOutput() != NULL ){
                                            Hydrogen::get_instance()->getMidiOutput()->handleQueueAllNoteOff();
                                        }

                                        return -1;
                                }
                        }
                        PatternList *pPatternList =
                                ( *( m_pSong->get_pattern_group_vector() ) )[m_nSongPos];
                                
                        std::set<Pattern*> patternsToPlay;
                        for ( unsigned i = 0; i < pPatternList->get_size(); ++i ) {
                            Pattern *curPattern = pPatternList->get(i);
                            patternsToPlay.insert(curPattern);
                            
                            for (std::set<Pattern*>::const_iterator virtualIter = curPattern->virtual_pattern_transitive_closure_set.begin(); virtualIter != curPattern->virtual_pattern_transitive_closure_set.end(); ++virtualIter) {
                                patternsToPlay.insert(*virtualIter);
                            }//for
                        }//for
                                
                        // copio tutti i pattern
                        m_pPlayingPatterns->clear();
                        for (std::set<Pattern*>::const_iterator virtualIter = patternsToPlay.begin(); virtualIter != patternsToPlay.end(); ++virtualIter) {
                            m_pPlayingPatterns->add(*virtualIter);
                        }//for
                        
                        //if ( pPatternList ) {
                                //for ( unsigned i = 0; i < pPatternList->get_size(); ++i ) {
                                //      m_pPlayingPatterns->add( pPatternList->get( i ) );
                                //}
                                
                        //}

                        // Set destructive record depending on punch area
                        doErase = doErase && Preferences::get_instance()->inPunchArea(m_nSongPos);
                }
                
                // PATTERN MODE
                else if ( m_pSong->get_mode() == Song::PATTERN_MODE )   {
                        // per ora considero solo il primo pattern, se ce ne
                        // saranno piu' di uno bisognera' prendere quello piu'
                        // piccolo

                        //m_nPatternTickPosition = tick % m_pCurrentPattern->getSize();
                        int nPatternSize = MAX_NOTES;

                        
                        if ( Preferences::get_instance()->patternModePlaysSelected() )
                        {
                                m_pPlayingPatterns->clear();
                                Pattern * pSelectedPattern =
                                        m_pSong->get_pattern_list()
                                               ->get(m_nSelectedPatternNumber);
                                
                                std::set<Pattern*> patternsToPlay;
                                patternsToPlay.insert(pSelectedPattern);
                                for (std::set<Pattern*>::const_iterator virtualIter = pSelectedPattern->virtual_pattern_transitive_closure_set.begin(); virtualIter != pSelectedPattern->virtual_pattern_transitive_closure_set.end(); ++virtualIter) {
                                    patternsToPlay.insert(*virtualIter);
                                }//for
                                
                                for (std::set<Pattern*>::const_iterator virtualIter = patternsToPlay.begin(); virtualIter != patternsToPlay.end(); ++virtualIter) {
                                   m_pPlayingPatterns->add(*virtualIter);
                                }//for
                                
                                //m_pPlayingPatterns->add( pSelectedPattern );
                        }


                        if ( m_pPlayingPatterns->get_size() != 0 ) {
                                Pattern *pFirstPattern = m_pPlayingPatterns->get( 0 );
                                nPatternSize = pFirstPattern->get_length();
                        }

                        if ( nPatternSize == 0 ) {
                                _ERRORLOG( "nPatternSize == 0" );
                        }

                        if ( ( tick == m_nPatternStartTick + nPatternSize )
                             || ( m_nPatternStartTick == -1 ) ) {
                                if ( m_pNextPatterns->get_size() > 0 ) {
                                        Pattern * p;
                                        for ( uint i = 0;
                                              i < m_pNextPatterns->get_size();
                                              i++ ) {
                                                p = m_pNextPatterns->get( i );
//                                              _WARNINGLOG( QString( "Got pattern # %1" )
//                                                           .arg( i + 1 ) );
                                                // if the pattern isn't playing
                                                // already, start it now.
                                                if ( ( m_pPlayingPatterns->del( p ) ) == NULL ) {
                                                        m_pPlayingPatterns->add( p );
                                                }
                                        }
                                        m_pNextPatterns->clear();
                                        bSendPatternChange = true;
                                }
                                if ( m_nPatternStartTick == -1 ) {
                                        m_nPatternStartTick = tick - (tick % nPatternSize);
//                                      _WARNINGLOG( "set Pattern Start Tick to "
//                                                   + to_string( m_nPatternStartTick ) );
                                } else {
                                        m_nPatternStartTick = tick;
                                }
                        }
                        m_nPatternTickPosition = tick - m_nPatternStartTick;
                        if ( m_nPatternTickPosition > nPatternSize ) {
                                m_nPatternTickPosition = tick % nPatternSize;
                        }
                }

                // metronome
//              if (  ( m_nPatternStartTick == tick )
//                    || ( ( tick - m_nPatternStartTick ) % 48 == 0 ) ) {
                if ( m_nPatternTickPosition % 48 == 0 ) {
                        float fPitch;
                        float fVelocity;
//                      _INFOLOG( "Beat: " + to_string(m_nPatternTickPosition / 48 + 1)
//                                 + "@ " + to_string( tick ) );
                        if ( m_nPatternTickPosition == 0 ) {
                                fPitch = 3;
                                fVelocity = 1.0;
                                EventQueue::get_instance()->push_event( EVENT_METRONOME, 1 );
                        } else {
                                fPitch = 0;
                                fVelocity = 0.8;
                                EventQueue::get_instance()->push_event( EVENT_METRONOME, 0 );
                        }
                        if ( Preferences::get_instance()->m_bUseMetronome ) {
                                m_pMetronomeInstrument->set_volume(
                                        Preferences::get_instance()->m_fMetronomeVolume
                                        );
                                Note *pMetronomeNote = new Note( m_pMetronomeInstrument,
                                                                 tick,
                                                                 fVelocity,
                                                                 0.5,
                                                                 0.5,
                                                                 -1,
                                                                 fPitch
                                        );
                                m_pMetronomeInstrument->enqueue();
                                m_songNoteQueue.push( pMetronomeNote );
                        }
                }

                // update the notes queue
                if ( m_pPlayingPatterns->get_size() != 0 ) {
                        for ( unsigned nPat = 0 ;
                              nPat < m_pPlayingPatterns->get_size() ;
                              ++nPat ) {
                                Pattern *pPattern = m_pPlayingPatterns->get( nPat );
                                assert( pPattern != NULL );

                                // Delete notes before attempting to play them
                                if ( doErase ) {
                                        std::multimap <int, Note*>::iterator pos0;
                                        for ( pos0 = pPattern->note_map.lower_bound( m_nPatternTickPosition );
                                                        pos0 != pPattern->note_map.upper_bound( m_nPatternTickPosition );
                                                        ++pos0 ) {
                                                Note *pNote = pos0->second;
                                                assert( pNote != NULL );
                                                if ( pNote->m_bJustRecorded == false ) {
                                                        delete pNote;
                                                        pPattern->note_map.erase( pos0 );
                                                }
                                        }
                                }

                                assert( pPattern != NULL );

                                // Now play notes
                                std::multimap <int, Note*>::iterator pos;
                                for ( pos = pPattern->note_map.lower_bound( m_nPatternTickPosition ) ;
                                      pos != pPattern->note_map.upper_bound( m_nPatternTickPosition ) ;
                                      ++pos ) {
                                        Note *pNote = pos->second;
                                        if ( pNote ) {
                                                pNote->m_bJustRecorded = false;
                                                int nOffset = 0;

                                                // Swing
                                                float fSwingFactor = m_pSong->get_swing_factor();
                                                
                                                if ( ( ( m_nPatternTickPosition % 12 ) == 0 )
                                                     && ( ( m_nPatternTickPosition % 24 ) != 0 ) ) {
                                                        // da l'accento al tick 4, 12, 20, 36...
                                                        nOffset += ( int )(
                                                                6.0
                                                                * m_pAudioDriver->m_transport.m_nTickSize
                                                                * fSwingFactor
                                                                );
                                                }

                                                // Humanize - Time parameter
                                                if ( m_pSong->get_humanize_time_value() != 0 ) {
                                                        nOffset += ( int )(
                                                                getGaussian( 0.3 )
                                                                * m_pSong->get_humanize_time_value()
                                                                * nMaxTimeHumanize
                                                                );
                                                }
                                                //~
                                                // Lead or Lag - timing parameter
                                                nOffset += (int) ( pNote->get_leadlag()
                                                                   * nLeadLagFactor);
                                                //~

                                                if((tick == 0) && (nOffset < 0)) {
                                                        nOffset = 0;
                                                }
                                                Note *pCopiedNote = new Note( pNote );
                                                pCopiedNote->set_position( tick );

                                                // humanize time
                                                pCopiedNote->m_nHumanizeDelay = nOffset;
                                                pNote->get_instrument()->enqueue();
                                                m_songNoteQueue.push( pCopiedNote );
                                                //pCopiedNote->dumpInfo();
                                        }
                                }
                        }
                }
                ++tick;
        }
        

        // audioEngine_process must send the pattern change event after mutex unlock
        if ( bSendPatternChange ) {
                return 2;
        }
        return 0;
}



/// restituisce l'indice relativo al patternGroup in base al tick
inline int findPatternInTick( int nTick, bool bLoopMode, int *pPatternStartTick )
{
        assert( m_pSong );

        int nTotalTick = 0;
        m_nSongSizeInTicks = 0;

        std::vector<PatternList*> *pPatternColumns = m_pSong->get_pattern_group_vector();
        int nColumns = pPatternColumns->size();

        int nPatternSize;
        for ( int i = 0; i < nColumns; ++i ) {
                PatternList *pColumn = ( *pPatternColumns )[ i ];
                if ( pColumn->get_size() != 0 ) {
                        // tengo in considerazione solo il primo pattern. I
                        // pattern nel gruppo devono avere la stessa lunghezza.
                        nPatternSize = pColumn->get( 0 )->get_length();
                } else {
                        nPatternSize = MAX_NOTES;
                }

                if ( ( nTick >= nTotalTick ) && ( nTick < nTotalTick + nPatternSize ) ) {
                        ( *pPatternStartTick ) = nTotalTick;
                        return i;
                }
                nTotalTick += nPatternSize;
        }

        if ( bLoopMode ) {
                m_nSongSizeInTicks = nTotalTick;
                int nLoopTick = 0;
                if ( m_nSongSizeInTicks != 0 ) {
                        nLoopTick = nTick % m_nSongSizeInTicks;
                }
                nTotalTick = 0;
                for ( int i = 0; i < nColumns; ++i ) {
                        PatternList *pColumn = ( *pPatternColumns )[ i ];
                        if ( pColumn->get_size() != 0 ) {
                                // tengo in considerazione solo il primo
                                // pattern. I pattern nel gruppo devono avere la
                                // stessa lunghezza.
                                nPatternSize = pColumn->get( 0 )->get_length();
                        } else {
                                nPatternSize = MAX_NOTES;
                        }

                        if ( ( nLoopTick >= nTotalTick )
                             && ( nLoopTick < nTotalTick + nPatternSize ) ) {
                                ( *pPatternStartTick ) = nTotalTick;
                                return i;
                        }
                        nTotalTick += nPatternSize;
                }
        }

        QString err = QString( "[findPatternInTick] tick = %1. No pattern found" ).arg( QString::number(nTick) );
        _ERRORLOG( err );
        return -1;
}



void audioEngine_noteOn( Note *note )
{
        // check current state
        if ( ( m_audioEngineState != STATE_READY )
             && ( m_audioEngineState != STATE_PLAYING ) ) {
                _ERRORLOG( "Error the audio engine is not in READY state" );
                delete note;
                return;
        }

        m_midiNoteQueue.push_back( note );
}


/*
void audioEngine_noteOff( Note *note )
{
        if ( note == NULL )     {
                _ERRORLOG( "Error, note == NULL" );
        }

        AudioEngine::get_instance()->lock( RIGHT_HERE );

        // check current state
        if ( ( m_audioEngineState != STATE_READY )
             && ( m_audioEngineState != STATE_PLAYING ) ) {
                _ERRORLOG( "Error the audio engine is not in READY state" );
                delete note;
                AudioEngine::get_instance()->unlock();
                return;
        }

//      AudioEngine::get_instance()->get_sampler()->note_off( note );
        AudioEngine::get_instance()->unlock();
        delete note;

}
*/


// unsigned long audioEngine_getTickPosition()
// {
//      return m_nPatternTickPosition;
// }


AudioOutput* createDriver( const QString& sDriver )
{
        _INFOLOG( QString( "Driver: '%1'" ).arg( sDriver ) );
        Preferences *pPref = Preferences::get_instance();
        AudioOutput *pDriver = NULL;

        if ( sDriver == "Oss" ) {
                pDriver = new OssDriver( audioEngine_process );
                if ( pDriver->get_class_name() == "NullDriver" ) {
                        delete pDriver;
                        pDriver = NULL;
                }
        } else if ( sDriver == "Jack" ) {
                pDriver = new JackOutput( audioEngine_process );
                if ( pDriver->get_class_name() == "NullDriver" ) {
                        delete pDriver;
                        pDriver = NULL;
                } else {
#ifdef JACK_SUPPORT
                        static_cast<JackOutput*>(pDriver)->setConnectDefaults(
                                Preferences::get_instance()->m_bJackConnectDefaults
                                );
#endif
                }
        } else if ( sDriver == "Alsa" ) {
                pDriver = new AlsaAudioDriver( audioEngine_process );
                if ( pDriver->get_class_name() == "NullDriver" ) {
                        delete pDriver;
                        pDriver = NULL;
                }
        } else if ( sDriver == "PortAudio" ) {
                pDriver = new PortAudioDriver( audioEngine_process );
                if ( pDriver->get_class_name() == "NullDriver" ) {
                        delete pDriver;
                        pDriver = NULL;
                }
        }
//#ifdef Q_OS_MACX
        else if ( sDriver == "CoreAudio" ) {
                _INFOLOG( "Creating CoreAudioDriver" );
                pDriver = new CoreAudioDriver( audioEngine_process );
                if ( pDriver->get_class_name() == "NullDriver" ) {
                        delete pDriver;
                        pDriver = NULL;
                }
        }
//#endif
        else if ( sDriver == "Fake" ) {
                _WARNINGLOG( "*** Using FAKE audio driver ***" );
                pDriver = new FakeDriver( audioEngine_process );
        } else {
                _ERRORLOG( "Unknown driver " + sDriver );
                audioEngine_raiseError( Hydrogen::UNKNOWN_DRIVER );
        }

        if ( pDriver  ) {
                // initialize the audio driver
                int res = pDriver->init( pPref->m_nBufferSize );
                if ( res != 0 ) {
                        _ERRORLOG( "Error starting audio driver [audioDriver::init()]" );
                        delete pDriver;
                        pDriver = NULL;
                }
        }

        return pDriver;
}


/// Start all audio drivers
void audioEngine_startAudioDrivers()
{
        Preferences *preferencesMng = Preferences::get_instance();

        AudioEngine::get_instance()->lock( RIGHT_HERE );
        QMutexLocker mx(&mutex_OutputPointer);

        _INFOLOG( "[audioEngine_startAudioDrivers]" );

        // check current state
        if ( m_audioEngineState != STATE_INITIALIZED ) {
                _ERRORLOG( QString( "Error the audio engine is not in INITIALIZED"
                                    " state. state=%1" )
                           .arg( m_audioEngineState ) );
                AudioEngine::get_instance()->unlock();
                return;
        }

        if ( m_pAudioDriver ) { // check if the audio m_pAudioDriver is still alive
                _ERRORLOG( "The audio driver is still alive" );
        }
        if ( m_pMidiDriver ) {  // check if midi driver is still alive
                _ERRORLOG( "The MIDI driver is still active" );
        }


        QString sAudioDriver = preferencesMng->m_sAudioDriver;
//      sAudioDriver = "Auto";
        if ( sAudioDriver == "Auto" ) {
                if ( ( m_pAudioDriver = createDriver( "Jack" ) ) == NULL ) {
                        if ( ( m_pAudioDriver = createDriver( "Alsa" ) ) == NULL ) {
                                if ( ( m_pAudioDriver = createDriver( "CoreAudio" ) ) == NULL ) {
                                        if ( ( m_pAudioDriver = createDriver( "PortAudio" ) ) == NULL ) {
                                                if ( ( m_pAudioDriver = createDriver( "Oss" ) ) == NULL ) {
                                                        audioEngine_raiseError( Hydrogen::ERROR_STARTING_DRIVER );
                                                        _ERRORLOG( "Error starting audio driver" );
                                                        _ERRORLOG( "Using the NULL output audio driver" );

                                                        // use the NULL output driver
                                                        m_pAudioDriver = new NullDriver( audioEngine_process );
                                                        m_pAudioDriver->init( 0 );
                                                }
                                        }
                                }
                        }
                }
        } else {
                m_pAudioDriver = createDriver( sAudioDriver );
                if ( m_pAudioDriver == NULL ) {
                        audioEngine_raiseError( Hydrogen::ERROR_STARTING_DRIVER );
                        _ERRORLOG( "Error starting audio driver" );
                        _ERRORLOG( "Using the NULL output audio driver" );

                        // use the NULL output driver
                        m_pAudioDriver = new NullDriver( audioEngine_process );
                        m_pAudioDriver->init( 0 );
                }
        }

        if ( preferencesMng->m_sMidiDriver == "ALSA" ) {
#ifdef ALSA_SUPPORT
                // Create MIDI driver
                AlsaMidiDriver *alsaMidiDriver = new AlsaMidiDriver();
                m_pMidiDriverOut = alsaMidiDriver;
                m_pMidiDriver = alsaMidiDriver;
                m_pMidiDriver->open();
                m_pMidiDriver->setActive( true );
#endif
        } else if ( preferencesMng->m_sMidiDriver == "PortMidi" ) {
#ifdef PORTMIDI_SUPPORT
                m_pMidiDriver = new PortMidiDriver();
                m_pMidiDriver->open();
                m_pMidiDriver->setActive( true );
#endif
        } else if ( preferencesMng->m_sMidiDriver == "CoreMidi" ) {
#ifdef COREMIDI_SUPPORT
                m_pMidiDriver = new CoreMidiDriver();
                m_pMidiDriver->open();
                m_pMidiDriver->setActive( true );
#endif
        }

        // change the current audio engine state
        if ( m_pSong == NULL ) {
                m_audioEngineState = STATE_PREPARED;
        } else {
                m_audioEngineState = STATE_READY;
        }


        if ( m_pSong ) {
                m_pAudioDriver->setBpm( m_pSong->__bpm );
        }

        if ( m_audioEngineState == STATE_PREPARED ) {
                EventQueue::get_instance()->push_event( EVENT_STATE, STATE_PREPARED );
        } else if ( m_audioEngineState == STATE_READY ) {
                EventQueue::get_instance()->push_event( EVENT_STATE, STATE_READY );
        }

        // Unlocking earlier might execute the jack process() callback before we
        // are fully initialized.
        mx.unlock();
        AudioEngine::get_instance()->unlock();

        if ( m_pAudioDriver ) {
                int res = m_pAudioDriver->connect();
                if ( res != 0 ) {
                        audioEngine_raiseError( Hydrogen::ERROR_STARTING_DRIVER );
                        _ERRORLOG( "Error starting audio driver [audioDriver::connect()]" );
                        _ERRORLOG( "Using the NULL output audio driver" );

                        mx.relock();
                        delete m_pAudioDriver;
                        m_pAudioDriver = new NullDriver( audioEngine_process );
                        mx.unlock();
                        m_pAudioDriver->init( 0 );
                        m_pAudioDriver->connect();
                }

                if ( ( m_pMainBuffer_L = m_pAudioDriver->getOut_L() ) == NULL ) {
                        _ERRORLOG( "m_pMainBuffer_L == NULL" );
                }
                if ( ( m_pMainBuffer_R = m_pAudioDriver->getOut_R() ) == NULL ) {
                        _ERRORLOG( "m_pMainBuffer_R == NULL" );
                }

#ifdef JACK_SUPPORT
                audioEngine_renameJackPorts();
#endif

                audioEngine_setupLadspaFX( m_pAudioDriver->getBufferSize() );
        }


}



/// Stop all audio drivers
void audioEngine_stopAudioDrivers()
{
        _INFOLOG( "[audioEngine_stopAudioDrivers]" );

        // check current state
        if ( m_audioEngineState == STATE_PLAYING ) {
                audioEngine_stop();
        }

        if ( ( m_audioEngineState != STATE_PREPARED )
             && ( m_audioEngineState != STATE_READY ) ) {
                _ERRORLOG( QString( "Error: the audio engine is not in PREPARED"
                                    " or READY state. state=%1" )
                           .arg( m_audioEngineState ) );
                return;
        }

        // change the current audio engine state
        m_audioEngineState = STATE_INITIALIZED;
        EventQueue::get_instance()->push_event( EVENT_STATE, STATE_INITIALIZED );

        AudioEngine::get_instance()->lock( RIGHT_HERE );

        // delete MIDI driver
        if ( m_pMidiDriver ) {
                m_pMidiDriver->close();
                delete m_pMidiDriver;
                m_pMidiDriver = NULL;
                m_pMidiDriverOut = NULL;
        }

        // delete audio driver
        if ( m_pAudioDriver ) {
                m_pAudioDriver->disconnect();
                QMutexLocker mx( &mutex_OutputPointer );
                delete m_pAudioDriver;
                m_pAudioDriver = NULL;
                mx.unlock();
        }

        AudioEngine::get_instance()->unlock();
}



/// Restart all audio and midi drivers
void audioEngine_restartAudioDrivers()
{
        audioEngine_stopAudioDrivers();
        audioEngine_startAudioDrivers();
}






//----------------------------------------------------------------------------
//
// Implementation of Hydrogen class
//
//----------------------------------------------------------------------------

/// static reference of Hydrogen class (Singleton)
Hydrogen* Hydrogen::__instance = NULL;



Hydrogen::Hydrogen()
                : Object( "Hydrogen" )
{
        if ( __instance ) {
                _ERRORLOG( "Hydrogen audio engine is already running" );
                throw H2Exception( "Hydrogen audio engine is already running" );
        }

        _INFOLOG( "[Hydrogen]" );

        hydrogenInstance = this;
//      __instance = this;
        audioEngine_init();
        // Prevent double creation caused by calls from MIDI thread 
        __instance = this; 
        audioEngine_startAudioDrivers();

}



Hydrogen::~Hydrogen()
{
        _INFOLOG( "[~Hydrogen]" );
        if ( m_audioEngineState == STATE_PLAYING ) {
                audioEngine_stop();
        }
        removeSong();
        audioEngine_stopAudioDrivers();
        audioEngine_destroy();
        __kill_instruments();
        __instance = NULL;
}



void Hydrogen::create_instance()
{
        // Create all the other instances that we need
        // ....and in the right order
        Logger::create_instance();
        MidiMap::create_instance();
        Preferences::create_instance();
        EventQueue::create_instance();
        ActionManager::create_instance();

        if( __instance == 0 ) {
                __instance = new Hydrogen;
        }

        // See audioEngine_init() for:
        // AudioEngine::create_instance();
        // Effects::create_instance();
        // Playlist::create_instance();
}

/// Start the internal sequencer
void Hydrogen::sequencer_play()
{
        getSong()->get_pattern_list()->set_to_old();
        m_pAudioDriver->play();
}



/// Stop the internal sequencer
void Hydrogen::sequencer_stop()
{
    if( Hydrogen::get_instance()->getMidiOutput() != NULL ){
                Hydrogen::get_instance()->getMidiOutput()->handleQueueAllNoteOff();
    }

    m_pAudioDriver->stop();
    Preferences::get_instance()->setRecordEvents(false);
}



void Hydrogen::setSong( Song *pSong )
{
        audioEngine_setSong( pSong );
}



void Hydrogen::removeSong()
{
        audioEngine_removeSong();
}



Song* Hydrogen::getSong()
{
        return m_pSong;
}



void Hydrogen::midi_noteOn( Note *note )
{
        audioEngine_noteOn( note );
}



void Hydrogen::addRealtimeNote( int instrument,
                                float velocity,
                                float pan_L,
                                float pan_R,
                                float pitch,
                                bool noteOff,
                                bool forcePlay,
                                int msg1 )
{
        UNUSED( pitch );

        Preferences *pref = Preferences::get_instance();
        unsigned int realcolumn = 0;
        unsigned res = pref->getPatternEditorGridResolution();
        int nBase = pref->isPatternEditorUsingTriplets() ? 3 : 4;
        int scalar = ( 4 * MAX_NOTES ) / ( res * nBase );
        bool hearnote = forcePlay;

        AudioEngine::get_instance()->lock( RIGHT_HERE );


        Song *song = getSong();
        if ( !pref->__playselectedinstrument ){
                if ( instrument >= ( int )song->get_instrument_list()->get_size() ) {
                        // unused instrument
                        AudioEngine::get_instance()->unlock();
                        return;
                }
        }

        // Get current partern and column, compensating for "lookahead" if required
        Pattern* currentPattern = NULL;
        unsigned int column = 0;
        unsigned int lookaheadTicks = m_nLookaheadFrames / m_pAudioDriver->m_transport.m_nTickSize;
        bool doRecord = pref->getRecordEvents();
        if ( m_pSong->get_mode() == Song::SONG_MODE && doRecord &&
                        m_audioEngineState == STATE_PLAYING ) {

                // Recording + song playback mode + actually playing
                PatternList *pPatternList = m_pSong->get_pattern_list();
                int ipattern = getPatternPos(); // playlist index
                if ( ipattern < 0 || ipattern >= (int) pPatternList->get_size() ) {
                        AudioEngine::get_instance()->unlock(); // unlock the audio engine
                        return;
                }
                // Locate column -- may need to jump back in the pattern list
                column = getTickPosition();
                while ( column < lookaheadTicks ) {
                        ipattern -= 1;
                        if ( ipattern < 0 || ipattern >= (int) pPatternList->get_size() ) {
                                AudioEngine::get_instance()->unlock(); // unlock the audio engine
                                return;
                        }
                        // Convert from playlist index to actual pattern index
                        std::vector<PatternList*> *pColumns = m_pSong->get_pattern_group_vector();
                        for ( int i = 0; i <= ipattern; ++i ) {
                                PatternList *pColumn = ( *pColumns )[i];
                                currentPattern = pColumn->get( 0 );
                        }
                        column = column + currentPattern->get_length();
//                      WARNINGLOG( "Undoing lookahead: corrected (" + to_string( ipattern+1 ) +
//                              "," + to_string( (int) ( column - currentPattern->get_length() ) -
//                              (int) lookaheadTicks ) + ") -> (" + to_string(ipattern) +
//                              "," + to_string( (int) column - (int) lookaheadTicks ) + ")." );
                }
                column -= lookaheadTicks;
                // Convert from playlist index to actual pattern index (if not already done above)
                if ( currentPattern == NULL ) {
                        std::vector<PatternList*> *pColumns = m_pSong->get_pattern_group_vector();
                        for ( int i = 0; i <= ipattern; ++i ) {
                                PatternList *pColumn = ( *pColumns )[i];
                                currentPattern = pColumn->get( 0 );
                        }
                }

                // Cancel recording if punch area disagrees
                doRecord = pref->inPunchArea( ipattern );

        } else {

                // Not song-record mode
                PatternList *pPatternList = m_pSong->get_pattern_list();
                if ( ( m_nSelectedPatternNumber != -1 )
                && ( m_nSelectedPatternNumber < ( int )pPatternList->get_size() ) ) {
                        currentPattern = pPatternList->get( m_nSelectedPatternNumber );
                }
                if( currentPattern == NULL ){
                        AudioEngine::get_instance()->unlock(); // unlock the audio engine
                        return;
                }
                // Locate column -- may need to wrap around end of pattern
                column = getTickPosition();
                if ( column >= lookaheadTicks ) {
                        column -= lookaheadTicks;
                } else {
                        lookaheadTicks %= currentPattern->get_length();
                        column = (column + currentPattern->get_length() - lookaheadTicks)
                                % currentPattern->get_length();
                }

        }

        realcolumn = getRealtimeTickPosition();

        if ( pref->getQuantizeEvents() ) {
                // quantize it to scale
                unsigned qcolumn = ( unsigned )::round( column / ( double )scalar ) * scalar;

        //we have to make sure that no beat is added on the last displayed note in a bar 
        //for example: if the pattern has 4 beats, the editor displays 5 beats, so we should avoid adding beats an note 5.
        if ( qcolumn == currentPattern->get_length() ) qcolumn = 0;
                column = qcolumn;
        }


        unsigned position = column;
        m_naddrealtimenotetickposition = column;


        Instrument *instrRef = 0;
        if ( song ) {
                instrRef = song->get_instrument_list()->get( instrument );
        }

        if ( currentPattern && ( getState() == STATE_PLAYING ) ) {

                if( doRecord && pref->getDestructiveRecord() && pref->m_nRecPreDelete>0 ) {
                        // Delete notes around current note if option toggled

                        int postdelete = 0;
                        int predelete = 0;
                        int prefpredelete = pref->m_nRecPreDelete-1;
                        int prefpostdelete = pref->m_nRecPostDelete;
                        int length = currentPattern->get_length();
                        bool fp = false;
                        postdelete = column;

                        switch (prefpredelete) {
                                case 0: predelete = length ; postdelete = 0; fp = true; break;
                                case 1: predelete = length ; fp = true; break;
                                case 2: predelete = length / 2; fp = true; break;
                                case 3: predelete = length / 4; fp = true; break;
                                case 4: predelete = length / 8; fp = true; break;
                                case 5: predelete = length / 16; fp = true; break;
                                case 6: predelete = length / 32; fp = true; break;
                                case 7: predelete = length / 64; fp = true; break;                      
                                case 8: predelete = length / 64; break;
                                case 9: predelete = length / 32; break;
                                case 10: predelete = length / 16; break;
                                case 11: predelete = length / 8; break;
                                case 12: predelete = length / 4; break;
                                case 13: predelete = length / 2; break;
                                case 14: predelete = length; break;
                                case 15: break;
                                default : predelete = 1; break;
                        }

                        if(!fp ){
                                switch (prefpostdelete) {
                                        case 0: postdelete = column; break;
                                        case 1: postdelete -= length / 64; break;
                                        case 2: postdelete -= length / 32; break;
                                        case 3: postdelete -= length / 16; break;
                                        case 4: postdelete -= length / 8; break;
                                        case 5: postdelete -= length / 4; break;
                                        case 6: postdelete -= length / 2; break;
                                        case 7: postdelete -= length ; break;
                                        default : postdelete = column; break;
                                }
                                if (postdelete<0) postdelete = 0;
                                
                        }

                        std::multimap <int, Note*>::iterator pos0;
                        for ( pos0 = currentPattern->note_map.begin(); pos0 != currentPattern->note_map.end(); ++pos0 ) {
                                Note *pNote = pos0->second;
                                assert( pNote );

                                if( pref->__playselectedinstrument ){//fix me 
                                        if( song->get_instrument_list()->get( getSelectedInstrumentNumber()) == pNote->get_instrument() ){
                                                if(prefpredelete>=1 && prefpredelete <=14 )
                                                        pNote->m_bJustRecorded = false;
                
                                                if( (prefpredelete == 15) && (pNote->m_bJustRecorded == false)){
                                                        delete pNote;
                                                        currentPattern->note_map.erase( pos0 );
                                                        continue;
                                                }
                
                                                if( ( pNote->m_bJustRecorded == false ) && (pNote->get_position() >= postdelete && pNote->get_position() <column + predelete +1 )){
                                                        delete pNote;
                                                        currentPattern->note_map.erase( pos0 );
                                                }
                                        }
                                        continue;       
                                }

                                if ( !fp && pNote->get_instrument() != instrRef ) {
                                        continue;
                                }

                                if(prefpredelete>=1 && prefpredelete <=14 )
                                        pNote->m_bJustRecorded = false;

                                if( (prefpredelete == 15) && (pNote->m_bJustRecorded == false)){
                                        delete pNote;
                                        currentPattern->note_map.erase( pos0 );
                                        continue;
                                }

                                if( ( pNote->m_bJustRecorded == false ) && (pNote->get_position() >= postdelete && pNote->get_position() <column + predelete +1 )){
                                        delete pNote;
                                        currentPattern->note_map.erase( pos0 );
                                }
                                
                        }
                }
                assert( currentPattern != NULL );

                bool bNoteAlreadyExist = false;
                Note *pNoteOld = NULL;
                for ( unsigned nNote = 0 ;
                      nNote < currentPattern->get_length() ;
                      nNote++ ) {
                        std::multimap <int, Note*>::iterator pos;
                        for ( pos = currentPattern->note_map.lower_bound( nNote ) ;
                              pos != currentPattern->note_map.upper_bound( nNote ) ;
                              ++pos ) {
                                pNoteOld = pos->second;
                                if ( pNoteOld!=NULL ) {
                                        if ( pNoteOld->get_instrument() == instrRef
                                             && nNote==column ) {
                                                bNoteAlreadyExist = true;
                                                break;
                                        }
                                }
                        }
                }

                if ( bNoteAlreadyExist ) {
                        // in this case, we'll leave the note alone
                        // hear note only if not playing too
                        if ( pref->getHearNewNotes()
                             && getState() == STATE_READY ) {
                                hearnote = true;
                        }
                        // Update velocity and flag as just recorded
                        if ( doRecord ) {
                                pNoteOld->set_velocity( velocity );
                                pNoteOld->m_bJustRecorded = true;
                        }
                } else if ( !doRecord ) {
                        if ( pref->getHearNewNotes()
                             && ( getState() == STATE_READY
                                  || getState() == STATE_PLAYING ) ) {
                                hearnote = true;
                        }
                } else {
                        if ( !pref->__playselectedinstrument ){
                                // create the new note
                                Note *note = new Note( instrRef,
                                                position,
                                                velocity,
                                                pan_L,
                                                pan_R,
                                                -1,
                                                0 );
                                currentPattern->note_map.insert(
                                        std::make_pair( column, note )
                                        );

                                // hear note if its not in the future
                                if ( pref->getHearNewNotes()
                                        && position <= getTickPosition() ) {
                                        hearnote = true;
                                }
        
                                note->m_bJustRecorded = true;
                                song->__is_modified = true;
        
                                EventQueue::get_instance()->push_event( EVENT_PATTERN_MODIFIED, -1 );
                        }
                        else if ( pref->__playselectedinstrument ){

                                Note *note = new Note( song->get_instrument_list()->get( getSelectedInstrumentNumber()),
                                                        position,
                                                        velocity,
                                                        pan_L,
                                                        pan_R,
                                                        -1,
                                                        0 );
        
                                                                int divider = msg1 / 12;
                                int octave = divider -3;
                                int notehigh = msg1 - (12 * divider);
                                note->m_noteKey.m_nOctave = octave;
                                note->set_midimsg1( msg1 );
                                if ( notehigh == 0) note->m_noteKey.m_key = H2Core::NoteKey::C;
                                else if ( notehigh == 1 ) note->m_noteKey.m_key = H2Core::NoteKey::Cs;
                                else if ( notehigh == 2 ) note->m_noteKey.m_key = H2Core::NoteKey::D;
                                else if ( notehigh == 3 ) note->m_noteKey.m_key = H2Core::NoteKey::Ef;
                                else if ( notehigh == 4 ) note->m_noteKey.m_key = H2Core::NoteKey::E;
                                else if ( notehigh == 5 ) note->m_noteKey.m_key = H2Core::NoteKey::F;
                                else if ( notehigh == 6 ) note->m_noteKey.m_key = H2Core::NoteKey::Fs;
                                else if ( notehigh == 7 ) note->m_noteKey.m_key = H2Core::NoteKey::G;
                                else if ( notehigh == 8 ) note->m_noteKey.m_key = H2Core::NoteKey::Af;
                                else if ( notehigh == 9 ) note->m_noteKey.m_key = H2Core::NoteKey::A;
                                else if ( notehigh == 10 ) note->m_noteKey.m_key = H2Core::NoteKey::Bf;
                                else if ( notehigh == 11 ) note->m_noteKey.m_key = H2Core::NoteKey::B;

                                currentPattern->note_map.insert(
                                        std::make_pair( column, note )
                                        );

                                // hear note if its not in the future
                                if ( pref->getHearNewNotes()
                                        && position <= getTickPosition() ) {
                                        hearnote = true;
                                }

                                note->m_bJustRecorded = true;
                                song->__is_modified = true;
        
                                EventQueue::get_instance()->push_event( EVENT_PATTERN_MODIFIED, -1 );                           
                        }
                }
        } else if ( pref->getHearNewNotes() ) {
                hearnote = true;
        }
        
        if ( !pref->__playselectedinstrument ){
                if ( hearnote && instrRef ) {
                        Note *note2 = new Note( instrRef,
                                                realcolumn,
                                                velocity,
                                                pan_L,
                                                pan_R,
                                                -1,
                                                0 );
                        midi_noteOn( note2 );
                }
        }else
        {
                if ( hearnote  ) {
                        Note *note2 = new Note( song->get_instrument_list()->get( getSelectedInstrumentNumber()),
                                                realcolumn,
                                                velocity,
                                                pan_L,
                                                pan_R,
                                                -1,
                                                0 );

                        int divider = msg1 / 12;
                        int octave = divider -3;
                        int notehigh = msg1 - (12 * divider);

                        //ERRORLOG( QString( "octave: %1, note: %2, instrument %3" ).arg( octave ).arg(notehigh).arg(instrument));
                        note2->m_noteKey.m_nOctave = octave;
                        if ( notehigh == 0) note2->m_noteKey.m_key = H2Core::NoteKey::C;
                        else if ( notehigh == 1 ) note2->m_noteKey.m_key = H2Core::NoteKey::Cs;
                        else if ( notehigh == 2 ) note2->m_noteKey.m_key = H2Core::NoteKey::D;
                        else if ( notehigh == 3 ) note2->m_noteKey.m_key = H2Core::NoteKey::Ef;
                        else if ( notehigh == 4 ) note2->m_noteKey.m_key = H2Core::NoteKey::E;
                        else if ( notehigh == 5 ) note2->m_noteKey.m_key = H2Core::NoteKey::F;
                        else if ( notehigh == 6 ) note2->m_noteKey.m_key = H2Core::NoteKey::Fs;
                        else if ( notehigh == 7 ) note2->m_noteKey.m_key = H2Core::NoteKey::G;
                        else if ( notehigh == 8 ) note2->m_noteKey.m_key = H2Core::NoteKey::Af;
                        else if ( notehigh == 9 ) note2->m_noteKey.m_key = H2Core::NoteKey::A;
                        else if ( notehigh == 10 ) note2->m_noteKey.m_key = H2Core::NoteKey::Bf;
                        else if ( notehigh == 11 ) note2->m_noteKey.m_key = H2Core::NoteKey::B;

                        note2->set_midimsg1( msg1 );
                        midi_noteOn( note2 );
                }       

        }


        AudioEngine::get_instance()->unlock(); // unlock the audio engine
}



float Hydrogen::getMasterPeak_L()
{
        return m_fMasterPeak_L;
}



float Hydrogen::getMasterPeak_R()
{
        return m_fMasterPeak_R;
}



unsigned long Hydrogen::getTickPosition()
{
        return m_nPatternTickPosition;
}



unsigned long Hydrogen::getRealtimeTickPosition()
{
        //unsigned long initTick = audioEngine_getTickPosition();
        unsigned int initTick = ( unsigned int )( m_nRealtimeFrames
                                                  / m_pAudioDriver->m_transport.m_nTickSize );
        unsigned long retTick;

        struct timeval currtime;
        struct timeval deltatime;

        double sampleRate = ( double ) m_pAudioDriver->getSampleRate();
        gettimeofday ( &currtime, NULL );

        timersub( &currtime, &m_currentTickTime, &deltatime );

        // add a buffers worth for jitter resistance
        double deltaSec =
                ( double ) deltatime.tv_sec
                + ( deltatime.tv_usec / 1000000.0 )
                + ( m_pAudioDriver->getBufferSize() / ( double )sampleRate );

        retTick = ( unsigned long ) ( ( sampleRate
                                        / ( double ) m_pAudioDriver->m_transport.m_nTickSize )
                                      * deltaSec );

        retTick = initTick + retTick;

        return retTick;
}



PatternList* Hydrogen::getCurrentPatternList()
{
        return m_pPlayingPatterns;
}

PatternList * Hydrogen::getNextPatterns()
{
        return m_pNextPatterns;
}

/// Set the next pattern (Pattern mode only)
void Hydrogen::sequencer_setNextPattern( int pos, bool appendPattern, bool deletePattern )
{
        m_bAppendNextPattern = appendPattern;
        m_bDeleteNextPattern = deletePattern;

        AudioEngine::get_instance()->lock( RIGHT_HERE );

        if ( m_pSong && m_pSong->get_mode() == Song::PATTERN_MODE ) {
                PatternList *patternList = m_pSong->get_pattern_list();
                Pattern * p = patternList->get( pos );
                if ( ( pos >= 0 ) && ( pos < ( int )patternList->get_size() ) ) {
                        // if p is already on the next pattern list, delete it.
                        if ( m_pNextPatterns->del( p ) == NULL ) {
//                              WARNINGLOG( "Adding to nextPatterns" );
                                m_pNextPatterns->add( p );
                        }/* else {
//                              WARNINGLOG( "Removing " + to_string(pos) );
                        }*/
                } else {
                        _ERRORLOG( QString( "pos not in patternList range. pos=%1 "
                                            "patternListSize=%2" )
                                   .arg( pos )
                                   .arg( patternList->get_size() ) );
                        m_pNextPatterns->clear();
                }
        } else {
                _ERRORLOG( "can't set next pattern in song mode" );
                m_pNextPatterns->clear();
        }

        AudioEngine::get_instance()->unlock();
}



int Hydrogen::getPatternPos()
{
        return m_nSongPos;
}



void Hydrogen::restartDrivers()
{
        audioEngine_restartAudioDrivers();
}



/// Export a song to a wav file, returns the elapsed time in mSec
void Hydrogen::startExportSong( const QString& filename, int rate, int depth )
{
        if ( getState() == STATE_PLAYING ) {
                sequencer_stop();
        }
        AudioEngine::get_instance()->get_sampler()->stop_playing_notes();
        Preferences *pPref = Preferences::get_instance();

        m_oldEngineMode = m_pSong->get_mode();
        m_bOldLoopEnabled = m_pSong->is_loop_enabled();

        m_pSong->set_mode( Song::SONG_MODE );
        m_pSong->set_loop_enabled( true );
//      unsigned nSamplerate = m_pAudioDriver->getSampleRate();
        unsigned nSamplerate = (unsigned)rate;
        // stop all audio drivers
        audioEngine_stopAudioDrivers();

        /*
                FIXME: Questo codice fa davvero schifo....
        */


        m_pAudioDriver = new DiskWriterDriver( audioEngine_process, nSamplerate, filename, depth);

        
        // reset
        m_pAudioDriver->m_transport.m_nFrames = 0;      // reset total frames
        m_pAudioDriver->setBpm( m_pSong->__bpm );
        m_nSongPos = 0;
        m_nPatternTickPosition = 0;
        m_audioEngineState = STATE_PLAYING;
        m_nPatternStartTick = -1;

        int res = m_pAudioDriver->init( pPref->m_nBufferSize );
        if ( res != 0 ) {
                _ERRORLOG( "Error starting disk writer driver "
                           "[DiskWriterDriver::init()]" );
        }

        m_pMainBuffer_L = m_pAudioDriver->getOut_L();
        m_pMainBuffer_R = m_pAudioDriver->getOut_R();

        audioEngine_setupLadspaFX( m_pAudioDriver->getBufferSize() );

        audioEngine_seek( 0, false );

        res = m_pAudioDriver->connect();
        if ( res != 0 ) {
                _ERRORLOG( "Error starting disk writer driver "
                           "[DiskWriterDriver::connect()]" );
        }
}



void Hydrogen::stopExportSong()
{
        if ( m_pAudioDriver->get_class_name() != "DiskWriterDriver" ) {
                return;
        }

//      audioEngine_stopAudioDrivers();
        m_pAudioDriver->disconnect();

        m_audioEngineState = STATE_INITIALIZED;
        delete m_pAudioDriver;
        m_pAudioDriver = NULL;

        m_pMainBuffer_L = NULL;
        m_pMainBuffer_R = NULL;

        m_pSong->set_mode( m_oldEngineMode );
        m_pSong->set_loop_enabled( m_bOldLoopEnabled );

        m_nSongPos = -1;
        m_nPatternTickPosition = 0;
        audioEngine_startAudioDrivers();

        if ( m_pAudioDriver ) {
                m_pAudioDriver->setBpm( m_pSong->__bpm );
        } else {
                _ERRORLOG( "m_pAudioDriver = NULL" );
        }
}



/// Used to display audio driver info
AudioOutput* Hydrogen::getAudioOutput()
{
        return m_pAudioDriver;
}



/// Used to display midi driver info
MidiInput* Hydrogen::getMidiInput()
{
        return m_pMidiDriver;
}

MidiOutput* Hydrogen::getMidiOutput()
{
        return m_pMidiDriverOut;
}



void Hydrogen::setMasterPeak_L( float value )
{
        m_fMasterPeak_L = value;
}



void Hydrogen::setMasterPeak_R( float value )
{
        m_fMasterPeak_R = value;
}



int Hydrogen::getState()
{
        return m_audioEngineState;
}



void Hydrogen::setCurrentPatternList( PatternList *pPatternList )
{
        AudioEngine::get_instance()->lock( RIGHT_HERE );
        m_pPlayingPatterns = pPatternList;
        EventQueue::get_instance()->push_event( EVENT_PATTERN_CHANGED, -1 );
        AudioEngine::get_instance()->unlock();
}



float Hydrogen::getProcessTime()
{
        return m_fProcessTime;
}



float Hydrogen::getMaxProcessTime()
{
        return m_fMaxProcessTime;
}



int Hydrogen::loadDrumkit( Drumkit *drumkitInfo )
{
        int old_ae_state = m_audioEngineState;
        if( m_audioEngineState >= STATE_READY ) {
                m_audioEngineState = STATE_PREPARED;
        }

        INFOLOG( drumkitInfo->getName() );
        m_currentDrumkit = drumkitInfo->getName();
        LocalFileMng fileMng;
        QString sDrumkitPath = fileMng.getDrumkitDirectory( drumkitInfo->getName() );


        //current instrument list
        InstrumentList *songInstrList = m_pSong->get_instrument_list();

        //new instrument list
        InstrumentList *pDrumkitInstrList = drumkitInfo->getInstrumentList();

        /*
                If the old drumkit is bigger then the new drumkit,
                delete all instruments with a bigger pos then
                pDrumkitInstrList->get_size(). Otherwise the instruments
                from our old instrumentlist with
                pos > pDrumkitInstrList->get_size() stay in the
                new instrumentlist
                
        wolke: info!
                this has moved to the end of this function
                because we get lost objects in memory
                now: 
                1. the new drumkit will loaded
                2. all not used instruments will complete deleted 
        
        old funktion:
        while ( pDrumkitInstrList->get_size() < songInstrList->get_size() )
        {
                songInstrList->del(songInstrList->get_size() - 1);
        }
        */
        
        //needed for the new delete function
        int instrumentDiff =  songInstrList->get_size() - pDrumkitInstrList->get_size();

        for ( unsigned nInstr = 0; nInstr < pDrumkitInstrList->get_size(); ++nInstr ) {
                Instrument *pInstr = NULL;
                if ( nInstr < songInstrList->get_size() ) {
                        //instrument exists already
                        pInstr = songInstrList->get( nInstr );
                        assert( pInstr );
                } else {
                        pInstr = Instrument::create_empty();
                        // The instrument isn't playing yet; no need for locking
                        // :-) - Jakob Lund.  AudioEngine::get_instance()->lock(
                        // "Hydrogen::loadDrumkit" );
                        songInstrList->add( pInstr );
                        // AudioEngine::get_instance()->unlock();
                }

                Instrument *pNewInstr = pDrumkitInstrList->get( nInstr );
                assert( pNewInstr );
                _INFOLOG( QString( "Loading instrument (%1 of %2) [%3]" )
                          .arg( nInstr )
                          .arg( pDrumkitInstrList->get_size() )
                          .arg( pNewInstr->get_name() ) );
                
                // creo i nuovi layer in base al nuovo strumento
                // Moved code from here right into the Instrument class - Jakob Lund.
                pInstr->load_from_placeholder( pNewInstr );
        }


//wolke: new delete funktion
        if ( instrumentDiff >=0 ){
                for ( int i = 0; i < instrumentDiff ; i++ ){
                        removeInstrument(
                                m_pSong->get_instrument_list()->get_size() - 1,
                                true
                                );
                }
        }

        #ifdef JACK_SUPPORT
        AudioEngine::get_instance()->lock( RIGHT_HERE );
                renameJackPorts();
        AudioEngine::get_instance()->unlock();
        #endif

        m_audioEngineState = old_ae_state;

        return 0;       //ok
}


//this is also a new function and will used from the new delete function in
//Hydrogen::loadDrumkit to delete the instruments by number
void Hydrogen::removeInstrument( int instrumentnumber, bool conditional )
{
        Instrument *pInstr = m_pSong->get_instrument_list()->get( instrumentnumber );


        PatternList* pPatternList = getSong()->get_pattern_list();
        
        if ( conditional ) {
        // new! this check if a pattern has an active note if there is an note
        //inside the pattern the intrument would not be deleted
                for ( int nPattern = 0 ;
                      nPattern < (int)pPatternList->get_size() ;
                      ++nPattern ) {
                        if( pPatternList
                            ->get( nPattern )
                            ->references_instrument( pInstr ) ) {
                                return;
                        }
                }
        } else {
                getSong()->purge_instrument( pInstr );
        }

        Song *pSong = getSong();
        InstrumentList* pList = pSong->get_instrument_list();
        if(pList->get_size()==1){
                AudioEngine::get_instance()->lock( RIGHT_HERE );
                Instrument* pInstr = pList->get( 0 );
                pInstr->set_name( (QString( "Instrument 1" )) );
                // remove all layers
                for ( int nLayer = 0; nLayer < MAX_LAYERS; nLayer++ ) {
                        InstrumentLayer* pLayer = pInstr->get_layer( nLayer );
                        delete pLayer;
                        pInstr->set_layer( NULL, nLayer );
                }               
        AudioEngine::get_instance()->unlock();
        EventQueue::get_instance()->push_event( EVENT_SELECTED_INSTRUMENT_CHANGED, -1 );
        INFOLOG("clear last instrument to empty instrument 1 instead delete the last instrument");
        return;
        }

        // if the instrument was the last on the instruments list, select the
        // next-last
        if ( instrumentnumber
             >= (int)getSong()->get_instrument_list()->get_size() - 1 ) {
                Hydrogen::get_instance()
                        ->setSelectedInstrumentNumber(
                                std::max(0, instrumentnumber - 1)
                                );
        }
        // delete the instrument from the instruments list
        AudioEngine::get_instance()->lock( RIGHT_HERE );
        getSong()->get_instrument_list()->del( instrumentnumber );
        getSong()->__is_modified = true;
        AudioEngine::get_instance()->unlock();
        
        // At this point the instrument has been removed from both the
        // instrument list and every pattern in the song.  Hence there's no way
        // (NOTE) to play on that instrument, and once all notes have stopped
        // playing it will be save to delete.
        // the ugly name is just for debugging...
        QString xxx_name = QString( "XXX_%1" ) . arg( pInstr->get_name() );
        pInstr->set_name( xxx_name );
        __instrument_death_row.push_back( pInstr );
        __kill_instruments(); // checks if there are still notes.
        
        // this will force a GUI update.
        EventQueue::get_instance()->push_event( EVENT_SELECTED_INSTRUMENT_CHANGED, -1 );
}


void Hydrogen::raiseError( unsigned nErrorCode )
{
        audioEngine_raiseError( nErrorCode );
}


unsigned long Hydrogen::getTotalFrames()
{
        return m_pAudioDriver->m_transport.m_nFrames;
}

unsigned long Hydrogen::getRealtimeFrames()
{
        return m_nRealtimeFrames;
}

/**
 * Get the ticks for pattern at pattern pos
 * @a int pos -- position in song
 * @return -1 if pos > number of patterns in the song, tick no. > 0 otherwise
 * The driver should be LOCKED when calling this!!
 */
long Hydrogen::getTickForPosition( int pos )
{
        int nPatternGroups = m_pSong->get_pattern_group_vector()->size();
        if( nPatternGroups == 0 ) return -1;    

        if ( pos >= nPatternGroups ) {
                if ( m_pSong->is_loop_enabled() ) {
                        pos = pos % nPatternGroups;
                } else {
                        _WARNINGLOG( QString( "patternPos > nPatternGroups. pos:"
                                              " %1, nPatternGroups: %2")
                                     .arg( pos )
                                     .arg(  nPatternGroups ) );
                        return -1;
                }
        }

        std::vector<PatternList*> *pColumns = m_pSong->get_pattern_group_vector();
        long totalTick = 0;
        int nPatternSize;
        Pattern *pPattern = NULL;
        for ( int i = 0; i < pos; ++i ) {
                PatternList *pColumn = ( *pColumns )[ i ];
                // prendo solo il primo. I pattern nel gruppo devono avere la
                // stessa lunghezza
                pPattern = pColumn->get( 0 );
                if ( pPattern ) {
                        nPatternSize = pPattern->get_length();
                } else {
                        nPatternSize = MAX_NOTES;
                }

                totalTick += nPatternSize;
        }
        return totalTick;
}

/// Set the position in the song
void Hydrogen::setPatternPos( int pos )
{
        AudioEngine::get_instance()->lock( RIGHT_HERE );
        EventQueue::get_instance()->push_event( EVENT_METRONOME, 2 );
        long totalTick = getTickForPosition( pos );
        if ( totalTick < 0 ) {
                AudioEngine::get_instance()->unlock();
                return;
        }

        if ( getState() != STATE_PLAYING ) {
                // find pattern immediately when not playing
//              int dummy;
//              m_nSongPos = findPatternInTick( totalTick,
//                                              m_pSong->is_loop_enabled(),
//                                              &dummy );
                m_nSongPos = pos;
                m_nPatternTickPosition = 0;
        }
        m_pAudioDriver->locate(
                ( int ) ( totalTick * m_pAudioDriver->m_transport.m_nTickSize )
                );

        AudioEngine::get_instance()->unlock();
}




void Hydrogen::getLadspaFXPeak( int nFX, float *fL, float *fR )
{
#ifdef LADSPA_SUPPORT
        ( *fL ) = m_fFXPeak_L[nFX];
        ( *fR ) = m_fFXPeak_R[nFX];
#else
        ( *fL ) = 0;
        ( *fR ) = 0;
#endif
}



void Hydrogen::setLadspaFXPeak( int nFX, float fL, float fR )
{
#ifdef LADSPA_SUPPORT
        m_fFXPeak_L[nFX] = fL;
        m_fFXPeak_R[nFX] = fR;
#endif
}


void Hydrogen::onTapTempoAccelEvent()
{
#ifndef WIN32
        INFOLOG( "tap tempo" );
        static timeval oldTimeVal;

        struct timeval now;
        gettimeofday(&now, NULL);

        float fInterval =
                (now.tv_sec - oldTimeVal.tv_sec) * 1000.0
                + (now.tv_usec - oldTimeVal.tv_usec) / 1000.0;

        oldTimeVal = now;

        if ( fInterval < 1000.0 ) {
                setTapTempo( fInterval );
        }
#endif
}

void Hydrogen::setTapTempo( float fInterval )
{

//      infoLog( "set tap tempo" );
        static float fOldBpm1 = -1;
        static float fOldBpm2 = -1;
        static float fOldBpm3 = -1;
        static float fOldBpm4 = -1;
        static float fOldBpm5 = -1;
        static float fOldBpm6 = -1;
        static float fOldBpm7 = -1;
        static float fOldBpm8 = -1;

        float fBPM = 60000.0 / fInterval;

        if ( fabs( fOldBpm1 - fBPM ) > 20 ) {   // troppa differenza, niente media
                fOldBpm1 = fBPM;
                fOldBpm2 = fBPM;
                fOldBpm3 = fBPM;
                fOldBpm4 = fBPM;
                fOldBpm5 = fBPM;
                fOldBpm6 = fBPM;
                fOldBpm7 = fBPM;
                fOldBpm8 = fBPM;
        }

        if ( fOldBpm1 == -1 ) {
                fOldBpm1 = fBPM;
                fOldBpm2 = fBPM;
                fOldBpm3 = fBPM;
                fOldBpm4 = fBPM;
                fOldBpm5 = fBPM;
                fOldBpm6 = fBPM;
                fOldBpm7 = fBPM;
                fOldBpm8 = fBPM;
        }

        fBPM = ( fBPM + fOldBpm1 + fOldBpm2 + fOldBpm3 + fOldBpm4 + fOldBpm5
                 + fOldBpm6 + fOldBpm7 + fOldBpm8 ) / 9.0;


        _INFOLOG( QString( "avg BPM = %1" ).arg( fBPM ) );
        fOldBpm8 = fOldBpm7;
        fOldBpm7 = fOldBpm6;
        fOldBpm6 = fOldBpm5;
        fOldBpm5 = fOldBpm4;
        fOldBpm4 = fOldBpm3;
        fOldBpm3 = fOldBpm2;
        fOldBpm2 = fOldBpm1;
        fOldBpm1 = fBPM;

        AudioEngine::get_instance()->lock( RIGHT_HERE );

//      m_pAudioDriver->setBpm( fBPM );
//      m_pSong->setBpm( fBPM );

        setBPM( fBPM );

        AudioEngine::get_instance()->unlock();
}


// Called with audioEngine in LOCKED state.
void Hydrogen::setBPM( float fBPM )
{
        if ( m_pAudioDriver && m_pSong ) {
                m_pAudioDriver->setBpm( fBPM );
                m_pSong->__bpm = fBPM;
                m_nNewBpmJTM = fBPM;
//              audioEngine_process_checkBPMChanged();
        }
}



void Hydrogen::restartLadspaFX()
{
        if ( m_pAudioDriver ) {
                AudioEngine::get_instance()->lock( RIGHT_HERE );
                audioEngine_setupLadspaFX( m_pAudioDriver->getBufferSize() );
                AudioEngine::get_instance()->unlock();
        } else {
                _ERRORLOG( "m_pAudioDriver = NULL" );
        }
}



int Hydrogen::getSelectedPatternNumber()
{
        return m_nSelectedPatternNumber;
}



void Hydrogen::setSelectedPatternNumber( int nPat )
{
        // FIXME: controllare se e' valido..
        if ( nPat == m_nSelectedPatternNumber ) return;
        
        
        if ( Preferences::get_instance()->patternModePlaysSelected() ) {
                AudioEngine::get_instance()->lock( RIGHT_HERE );
        
                m_nSelectedPatternNumber = nPat;
                AudioEngine::get_instance()->unlock();
        } else {
                m_nSelectedPatternNumber = nPat;
        }

        EventQueue::get_instance()->push_event( EVENT_SELECTED_PATTERN_CHANGED, -1 );
}



int Hydrogen::getSelectedInstrumentNumber()
{
        return m_nSelectedInstrumentNumber;
}



void Hydrogen::setSelectedInstrumentNumber( int nInstrument )
{
        if ( m_nSelectedInstrumentNumber == nInstrument )       return;

        m_nSelectedInstrumentNumber = nInstrument;
        EventQueue::get_instance()->push_event( EVENT_SELECTED_INSTRUMENT_CHANGED, -1 );
}


#ifdef JACK_SUPPORT
void Hydrogen::renameJackPorts()
{
        if( Preferences::get_instance()->m_bJackTrackOuts == true ){
                audioEngine_renameJackPorts();
        }
}
#endif


///BeatCounter

void Hydrogen::setbeatsToCount( int beatstocount)
{
        m_nbeatsToCount = beatstocount;
}


int Hydrogen::getbeatsToCount()
{
        return m_nbeatsToCount;
}


void Hydrogen::setNoteLength( float notelength)
{
        m_ntaktoMeterCompute = notelength;
}



float Hydrogen::getNoteLength()
{
        return m_ntaktoMeterCompute;
}



int Hydrogen::getBcStatus()
{
        return eventCount;
}


void Hydrogen::setBcOffsetAdjust()
{
        //individual fine tuning for the beatcounter
        //to adjust  ms_offset from different people and controller
        Preferences *pref = Preferences::get_instance();

        m_nCoutOffset = pref->m_countOffset;
        m_nStartOffset = pref->m_startOffset;
}


void Hydrogen::handleBeatCounter()
{
        // Get first time value:
        if (beatCount == 1)
                gettimeofday(&currentTime,NULL);

        eventCount++;
                
        // Set wlastTime to wcurrentTime to remind the time:            
        lastTime = currentTime;
        
        // Get new time:
        gettimeofday(&currentTime,NULL);
        

        // Build doubled time difference:
        lastBeatTime = (double)(
                lastTime.tv_sec
                + (double)(lastTime.tv_usec * US_DIVIDER)
                + (int)m_nCoutOffset * .0001
                );
        currentBeatTime = (double)(
                currentTime.tv_sec
                + (double)(currentTime.tv_usec * US_DIVIDER)
                );
        beatDiff = beatCount == 1 ? 0 : currentBeatTime - lastBeatTime;
                
        //if differences are to big reset the beatconter
                if( beatDiff > 3.001 * 1/m_ntaktoMeterCompute ){
                        eventCount = 1;
                        beatCount = 1;
                        return;
                } 
        // Only accept differences big enough
                if (beatCount == 1 || beatDiff > .001) {
                        if (beatCount > 1)
                                beatDiffs[beatCount - 2] = beatDiff ;
                // Compute and reset:
                        if (beatCount == m_nbeatsToCount){
//                              unsigned long currentframe = getRealtimeFrames();
                                double beatTotalDiffs = 0;
                                for(int i = 0; i < (m_nbeatsToCount - 1); i++) 
                                        beatTotalDiffs += beatDiffs[i];
                                double beatDiffAverage =
                                        beatTotalDiffs
                                        / (beatCount - 1)
                                        * m_ntaktoMeterCompute ;
                                beatCountBpm =
                                        (float) ((int) (60 / beatDiffAverage * 100))
                                        / 100;
                                AudioEngine::get_instance()->lock( RIGHT_HERE );
                                if ( beatCountBpm > 500)
                                                beatCountBpm = 500; 
                                setBPM( beatCountBpm );
                                AudioEngine::get_instance()->unlock();
                                if (Preferences::get_instance()->m_mmcsetplay
                                    == Preferences::SET_PLAY_OFF) {
                                        beatCount = 1; 
                                        eventCount = 1;
                                }else{
                                        if ( m_audioEngineState != STATE_PLAYING ){
                                                unsigned bcsamplerate =
                                                        m_pAudioDriver->getSampleRate();
                                                unsigned long rtstartframe = 0;
                                                if ( m_ntaktoMeterCompute <= 1){
                                                        rtstartframe =
                                                                bcsamplerate
                                                                * beatDiffAverage
                                                                * ( 1/ m_ntaktoMeterCompute );
                                                }else
                                                {
                                                        rtstartframe =
                                                                bcsamplerate
                                                                * beatDiffAverage
                                                                / m_ntaktoMeterCompute ;
                                                }

                                                int sleeptime =
                                                        ( (float) rtstartframe
                                                          / (float) bcsamplerate
                                                          * (int) 1000 )
                                                        + (int)m_nCoutOffset
                                                        + (int) m_nStartOffset;
                                                #ifdef WIN32
                                                Sleep( sleeptime );
                                                #else
                                                usleep( 1000 * sleeptime );
                                                #endif

                                                sequencer_play();
                                        }
                                        
                                        beatCount = 1; 
                                        eventCount = 1;
                                        return;
                                }
                        }
                        else {
                                beatCount ++;
                        }                               
                }
                return;
}
//~ beatcounter

// jack transport master
unsigned long Hydrogen::getHumantimeFrames()
{
        return m_nHumantimeFrames;
}

void Hydrogen::setHumantimeFrames(unsigned long hframes)
{
        m_nHumantimeFrames = hframes;
}



#ifdef JACK_SUPPORT
void Hydrogen::offJackMaster()
{
        if ( m_pAudioDriver->get_class_name() == "JackOutput" ) {
                static_cast< JackOutput* >( m_pAudioDriver )->com_release();
        }
}

void Hydrogen::onJackMaster()
{
        if ( m_pAudioDriver->get_class_name() == "JackOutput" ) {
                static_cast< JackOutput* >( m_pAudioDriver )->initTimeMaster();
        }
}

unsigned long Hydrogen::getTimeMasterFrames()
{
        float allframes = 0 ;

        if ( m_pAudioDriver->m_transport.m_status == TransportInfo::STOPPED ){

                int oldtick = getTickPosition();
                for (int i = 0; i <= getPatternPos(); i++){
                        float framesforposition =
                                (long)getTickForHumanPosition(i)
                                * (float)m_pAudioDriver->m_transport.m_nTickSize;
                        allframes = framesforposition + allframes;
                }
                unsigned long framesfortimemaster = (unsigned int)(
                        allframes
                        + oldtick * (float)m_pAudioDriver->m_transport.m_nTickSize
                        );
                m_nHumantimeFrames = framesfortimemaster;
                return framesfortimemaster;
        }else
        {
        return m_nHumantimeFrames;
        }
}
#endif

long Hydrogen::getTickForHumanPosition( int humanpos )
{
        std::vector< PatternList* > * columns = m_pSong->get_pattern_group_vector();
        
        int nPatternGroups = columns->size();
        if ( humanpos >= nPatternGroups ) {
                if ( m_pSong->is_loop_enabled() ) {
                        humanpos = humanpos % nPatternGroups;
                } else {
                        return -1;
                }
        }

//      std::vector<PatternList*> *pColumns =
//              m_pSong->get_pattern_group_vector()[ humanpos - 1 ]
//                      .get( 0 )->get_length();
        
//      ERRORLOG( "Kick me!" );
        if ( humanpos == 0 ) return 0;
        Pattern *pPattern = columns->at( humanpos - 1 )->get( 0 );
        if ( pPattern ) {
                return pPattern->get_length();
        } else {
                return MAX_NOTES;
        }
//      int nPatternSize;
        
//      pColumns
        
/*      Pattern *pPattern = NULL;
        for ( int i = 0; i < humanpos; ++i ) {
                PatternList *pColumn = ( *pColumns )[ i ];
                pPattern = pColumn->get( 0 );
                if ( pPattern ) {
                        nPatternSize = pPattern->get_length();
                } else {
                        nPatternSize = MAX_NOTES;
                }

                humanTick = nPatternSize;
        }*/
//      return humanTick;
}



float Hydrogen::getNewBpmJTM()
{
        return m_nNewBpmJTM;
}

void Hydrogen::setNewBpmJTM( float bpmJTM )
{
        m_nNewBpmJTM = bpmJTM;
}


void Hydrogen::ComputeHumantimeFrames(uint32_t nFrames)
{
        if ( ( m_audioEngineState == STATE_PLAYING ) )
        m_nHumantimeFrames = nFrames + m_nHumantimeFrames;
}


//~ jack transport master

void Hydrogen::triggerRelocateDuringPlay()
{
        if ( m_pSong->get_mode() == Song::PATTERN_MODE )
                m_nPatternStartTick = -1; // This forces the barline position 
}


void Hydrogen::togglePlaysSelected()
{
        if ( getSong()->get_mode() != Song::PATTERN_MODE )
                return;
        Preferences * P = Preferences::get_instance();
        
        AudioEngine::get_instance()->lock( RIGHT_HERE );
        
        bool isPlaysSelected = P->patternModePlaysSelected();

        if (isPlaysSelected)
        {
                m_pPlayingPatterns->clear();
                Pattern * pSelectedPattern =
                        m_pSong
                        ->get_pattern_list()
                        ->get(m_nSelectedPatternNumber);
                m_pPlayingPatterns->add( pSelectedPattern );
        }

        P->setPatternModePlaysSelected( !isPlaysSelected );
        
        AudioEngine::get_instance()->unlock();
        
}

void Hydrogen::__kill_instruments()
{
        int c = 0;
        Instrument * pInstr = NULL;
        while ( __instrument_death_row.size()
                && __instrument_death_row.front()->is_queued() == 0 ) {
                pInstr = __instrument_death_row.front();
                __instrument_death_row.pop_front();
                INFOLOG( QString( "Deleting unused instrument (%1). "
                                  "%2 unused remain." )
                        . arg( pInstr->get_name() )
                        . arg( __instrument_death_row.size() ) );
                delete pInstr;
                c++;
        }
        if ( __instrument_death_row.size() ) {
                pInstr = __instrument_death_row.front();
                INFOLOG( QString( "Instrument %1 still has %2 active notes. "
                                  "Delaying 'delete instrument' operation." )
                        . arg( pInstr->get_name() )
                        . arg( pInstr->is_queued() ) );
        }
}



void Hydrogen::__panic()
{
        sequencer_stop();       
        AudioEngine::get_instance()->get_sampler()->stop_playing_notes();
}

int Hydrogen::__get_selected_PatterNumber()
{
        return m_nSelectedPatternNumber;
}

unsigned int Hydrogen::__getMidiRealtimeNoteTickPosition()
{
        return m_naddrealtimenotetickposition;
}


void Hydrogen::sortVolVectors()
{
        //sort the volume vector to xframes a < b
        sort(m_volumen.begin(), m_volumen.end(), VolComparator());
}


void Hydrogen::sortPanVectors()
{
        //sort the pan vector to xframes a < b
        sort(m_pan.begin(), m_pan.end(), PanComparator());
}

void Hydrogen::sortTimelineVector()
{
        //sort the timeline vector to beats a < b
        sort(m_timelinevector.begin(), m_timelinevector.end(), TimelineComparator());
}

void Hydrogen::sortTimelineTagVector()
{
        //sort the timeline vector to beats a < b
        sort(m_timelinetagvector.begin(), m_timelinetagvector.end(), TimelineTagComparator());
}

};