Merge branch 'stable-1.2' into fix/qt5-vst
# Conflicts: # plugins/vst_base/RemoteVstPlugin.cpp
This commit is contained in:
@@ -72,7 +72,7 @@ IF("${PLUGIN_LIST}" STREQUAL "")
|
||||
LadspaEffect
|
||||
lb302
|
||||
MidiImport
|
||||
# MidiExport - temporarily disabled, MIDI export is broken
|
||||
MidiExport
|
||||
MultitapEcho
|
||||
monstro
|
||||
nes
|
||||
|
||||
@@ -1,7 +1,8 @@
|
||||
/*
|
||||
* MidiExport.cpp - support for importing MIDI files
|
||||
* MidiExport.cpp - support for Exporting MIDI files
|
||||
*
|
||||
* Author: Mohamed Abdel Maksoud <mohamed at amaksoud.com>
|
||||
* Copyright (c) 2015 Mohamed Abdel Maksoud <mohamed at amaksoud.com>
|
||||
* Copyright (c) 2017 Hyunjin Song <tteu.ingog/at/gmail.com>
|
||||
*
|
||||
* This file is part of LMMS - https://lmms.io
|
||||
*
|
||||
@@ -30,8 +31,10 @@
|
||||
#include <QProgressDialog>
|
||||
|
||||
#include "MidiExport.h"
|
||||
#include "Engine.h"
|
||||
|
||||
#include "lmms_math.h"
|
||||
#include "TrackContainer.h"
|
||||
#include "BBTrack.h"
|
||||
#include "InstrumentTrack.h"
|
||||
|
||||
|
||||
@@ -44,7 +47,8 @@ Plugin::Descriptor PLUGIN_EXPORT midiexport_plugin_descriptor =
|
||||
"MIDI Export",
|
||||
QT_TRANSLATE_NOOP( "pluginBrowser",
|
||||
"Filter for exporting MIDI-files from LMMS" ),
|
||||
"Mohamed Abdel Maksoud <mohamed at amaksoud.com>",
|
||||
"Mohamed Abdel Maksoud <mohamed at amaksoud.com> and "
|
||||
"Hyunjin Song <tteu.ingog/at/gmail.com>",
|
||||
0x0100,
|
||||
Plugin::ExportFilter,
|
||||
NULL,
|
||||
@@ -68,99 +72,269 @@ MidiExport::~MidiExport()
|
||||
|
||||
|
||||
|
||||
bool MidiExport::tryExport( const TrackContainer::TrackList &tracks, int tempo, const QString &filename )
|
||||
bool MidiExport::tryExport(const TrackContainer::TrackList &tracks,
|
||||
const TrackContainer::TrackList &tracks_BB,
|
||||
int tempo, int masterPitch, const QString &filename)
|
||||
{
|
||||
QFile f(filename);
|
||||
f.open(QIODevice::WriteOnly);
|
||||
QDataStream midiout(&f);
|
||||
|
||||
InstrumentTrack* instTrack;
|
||||
BBTrack* bbTrack;
|
||||
QDomElement element;
|
||||
|
||||
|
||||
int nTracks = 0;
|
||||
const int BUFFER_SIZE = 50*1024;
|
||||
uint8_t buffer[BUFFER_SIZE];
|
||||
uint32_t size;
|
||||
|
||||
for( const Track* track : tracks ) if( track->type() == Track::InstrumentTrack ) nTracks++;
|
||||
for (const Track* track : tracks) if (track->type() == Track::InstrumentTrack) nTracks++;
|
||||
for (const Track* track : tracks_BB) if (track->type() == Track::InstrumentTrack) nTracks++;
|
||||
|
||||
// midi header
|
||||
MidiFile::MIDIHeader header(nTracks);
|
||||
size = header.writeToBuffer(buffer);
|
||||
midiout.writeRawData((char *)buffer, size);
|
||||
|
||||
// midi tracks
|
||||
for( Track* track : tracks )
|
||||
{
|
||||
DataFile dataFile( DataFile::SongProject );
|
||||
MidiFile::MIDITrack<BUFFER_SIZE> mtrack;
|
||||
|
||||
if( track->type() != Track::InstrumentTrack ) continue;
|
||||
std::vector<std::vector<std::pair<int,int>>> plists;
|
||||
|
||||
// midi tracks
|
||||
for (Track* track : tracks)
|
||||
{
|
||||
DataFile dataFile(DataFile::SongProject);
|
||||
MTrack mtrack;
|
||||
|
||||
if (track->type() == Track::InstrumentTrack)
|
||||
{
|
||||
|
||||
mtrack.addName(track->name().toStdString(), 0);
|
||||
//mtrack.addProgramChange(0, 0);
|
||||
mtrack.addTempo(tempo, 0);
|
||||
|
||||
instTrack = dynamic_cast<InstrumentTrack *>(track);
|
||||
element = instTrack->saveState(dataFile, dataFile.content());
|
||||
|
||||
int base_pitch = 0;
|
||||
double base_volume = 1.0;
|
||||
int base_time = 0;
|
||||
|
||||
MidiNoteVector pat;
|
||||
|
||||
for (QDomNode n = element.firstChild(); !n.isNull(); n = n.nextSibling())
|
||||
{
|
||||
|
||||
if (n.nodeName() == "instrumenttrack")
|
||||
{
|
||||
QDomElement it = n.toElement();
|
||||
// transpose +12 semitones, workaround for #1857
|
||||
base_pitch = (69 - it.attribute("basenote", "57").toInt());
|
||||
if (it.attribute("usemasterpitch", "1").toInt())
|
||||
{
|
||||
base_pitch += masterPitch;
|
||||
}
|
||||
base_volume = it.attribute("volume", "100").toDouble()/100.0;
|
||||
}
|
||||
|
||||
if (n.nodeName() == "pattern")
|
||||
{
|
||||
base_time = n.toElement().attribute("pos", "0").toInt();
|
||||
writePattern(pat, n, base_pitch, base_volume, base_time);
|
||||
}
|
||||
|
||||
}
|
||||
ProcessBBNotes(pat, INT_MAX);
|
||||
writePatternToTrack(mtrack, pat);
|
||||
size = mtrack.writeToBuffer(buffer);
|
||||
midiout.writeRawData((char *)buffer, size);
|
||||
}
|
||||
|
||||
if (track->type() == Track::BBTrack)
|
||||
{
|
||||
bbTrack = dynamic_cast<BBTrack *>(track);
|
||||
element = bbTrack->saveState(dataFile, dataFile.content());
|
||||
|
||||
std::vector<std::pair<int,int>> plist;
|
||||
for (QDomNode n = element.firstChild(); !n.isNull(); n = n.nextSibling())
|
||||
{
|
||||
|
||||
if (n.nodeName() == "bbtco")
|
||||
{
|
||||
QDomElement it = n.toElement();
|
||||
int pos = it.attribute("pos", "0").toInt();
|
||||
int len = it.attribute("len", "0").toInt();
|
||||
plist.push_back(std::pair<int,int>(pos, pos+len));
|
||||
}
|
||||
}
|
||||
std::sort(plist.begin(), plist.end());
|
||||
plists.push_back(plist);
|
||||
|
||||
}
|
||||
} // for each track
|
||||
|
||||
// midi tracks in BB tracks
|
||||
for (Track* track : tracks_BB)
|
||||
{
|
||||
DataFile dataFile(DataFile::SongProject);
|
||||
MTrack mtrack;
|
||||
|
||||
auto itr = plists.begin();
|
||||
std::vector<std::pair<int,int>> st;
|
||||
|
||||
if (track->type() != Track::InstrumentTrack) continue;
|
||||
|
||||
//qDebug() << "exporting " << track->name();
|
||||
|
||||
|
||||
mtrack.addName(track->name().toStdString(), 0);
|
||||
//mtrack.addProgramChange(0, 0);
|
||||
mtrack.addTempo(tempo, 0);
|
||||
|
||||
instTrack = dynamic_cast<InstrumentTrack *>( track );
|
||||
element = instTrack->saveState( dataFile, dataFile.content() );
|
||||
|
||||
// instrumentTrack
|
||||
// - instrumentTrack
|
||||
// - pattern
|
||||
int base_pitch = 0;
|
||||
|
||||
instTrack = dynamic_cast<InstrumentTrack *>(track);
|
||||
element = instTrack->saveState(dataFile, dataFile.content());
|
||||
|
||||
int base_pitch = 0;
|
||||
double base_volume = 1.0;
|
||||
int base_time = 0;
|
||||
|
||||
|
||||
for(QDomNode n = element.firstChild(); !n.isNull(); n = n.nextSibling())
|
||||
|
||||
for (QDomNode n = element.firstChild(); !n.isNull(); n = n.nextSibling())
|
||||
{
|
||||
//QDomText txt = n.toText();
|
||||
//qDebug() << ">> child node " << n.nodeName();
|
||||
|
||||
if (n.nodeName() == "instrumenttrack")
|
||||
{
|
||||
// TODO interpret pan="0" fxch="0" usemasterpitch="1" pitchrange="1" pitch="0" basenote="57"
|
||||
QDomElement it = n.toElement();
|
||||
base_pitch = it.attribute("pitch", "0").toInt();
|
||||
base_volume = it.attribute("volume", "100").toDouble()/100.0;
|
||||
// transpose +12 semitones, workaround for #1857
|
||||
base_pitch = (69 - it.attribute("basenote", "57").toInt());
|
||||
if (it.attribute("usemasterpitch", "1").toInt())
|
||||
{
|
||||
base_pitch += masterPitch;
|
||||
}
|
||||
base_volume = it.attribute("volume", "100").toDouble() / 100.0;
|
||||
}
|
||||
|
||||
|
||||
if (n.nodeName() == "pattern")
|
||||
{
|
||||
base_time = n.toElement().attribute("pos", "0").toInt();
|
||||
// TODO interpret steps="12" muted="0" type="1" name="Piano1" len="2592"
|
||||
for(QDomNode nn = n.firstChild(); !nn.isNull(); nn = nn.nextSibling())
|
||||
std::vector<std::pair<int,int>> &plist = *itr;
|
||||
|
||||
MidiNoteVector nv, pat;
|
||||
writePattern(pat, n, base_pitch, base_volume, 0);
|
||||
|
||||
// workaround for nested BBTCOs
|
||||
int pos = 0;
|
||||
int len = n.toElement().attribute("steps", "1").toInt() * 12;
|
||||
for (auto it = plist.begin(); it != plist.end(); ++it)
|
||||
{
|
||||
QDomElement note = nn.toElement();
|
||||
if (note.attribute("len", "0") == "0" || note.attribute("vol", "0") == "0") continue;
|
||||
#if 0
|
||||
qDebug() << ">>>> key " << note.attribute( "key", "0" )
|
||||
<< " " << note.attribute("len", "0") << " @"
|
||||
<< note.attribute("pos", "0");
|
||||
#endif
|
||||
mtrack.addNote(
|
||||
note.attribute("key", "0").toInt()+base_pitch
|
||||
, 100 * base_volume * (note.attribute("vol", "100").toDouble()/100)
|
||||
, (base_time+note.attribute("pos", "0").toDouble())/48
|
||||
, (note.attribute("len", "0")).toDouble()/48);
|
||||
while (!st.empty() && st.back().second <= it->first)
|
||||
{
|
||||
writeBBPattern(pat, nv, len, st.back().first, pos, st.back().second);
|
||||
pos = st.back().second;
|
||||
st.pop_back();
|
||||
}
|
||||
|
||||
if (!st.empty() && st.back().second <= it->second)
|
||||
{
|
||||
writeBBPattern(pat, nv, len, st.back().first, pos, it->first);
|
||||
pos = it->first;
|
||||
while (!st.empty() && st.back().second <= it->second)
|
||||
{
|
||||
st.pop_back();
|
||||
}
|
||||
}
|
||||
|
||||
st.push_back(*it);
|
||||
pos = it->first;
|
||||
}
|
||||
|
||||
while (!st.empty())
|
||||
{
|
||||
writeBBPattern(pat, nv, len, st.back().first, pos, st.back().second);
|
||||
pos = st.back().second;
|
||||
st.pop_back();
|
||||
}
|
||||
|
||||
ProcessBBNotes(nv, pos);
|
||||
writePatternToTrack(mtrack, nv);
|
||||
++itr;
|
||||
}
|
||||
|
||||
}
|
||||
size = mtrack.writeToBuffer(buffer);
|
||||
midiout.writeRawData((char *)buffer, size);
|
||||
} // for each track
|
||||
|
||||
}
|
||||
|
||||
return true;
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
void MidiExport::writePattern(MidiNoteVector &pat, QDomNode n,
|
||||
int base_pitch, double base_volume, int base_time)
|
||||
{
|
||||
// TODO interpret steps="12" muted="0" type="1" name="Piano1" len="2592"
|
||||
for (QDomNode nn = n.firstChild(); !nn.isNull(); nn = nn.nextSibling())
|
||||
{
|
||||
QDomElement note = nn.toElement();
|
||||
if (note.attribute("len", "0") == "0") continue;
|
||||
// TODO interpret pan="0" fxch="0" pitchrange="1"
|
||||
MidiNote mnote;
|
||||
mnote.pitch = qMax(0, qMin(127, note.attribute("key", "0").toInt() + base_pitch));
|
||||
mnote.volume = qMin(qRound(base_volume * note.attribute("vol", "100").toDouble()), 127);
|
||||
mnote.time = base_time + note.attribute("pos", "0").toInt();
|
||||
mnote.duration = note.attribute("len", "0").toInt();
|
||||
pat.push_back(mnote);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
void MidiExport::writePatternToTrack(MTrack &mtrack, MidiNoteVector &nv)
|
||||
{
|
||||
for (auto it = nv.begin(); it != nv.end(); ++it)
|
||||
{
|
||||
mtrack.addNote(it->pitch, it->volume, it->time / 48.0, it->duration / 48.0);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
void MidiExport::writeBBPattern(MidiNoteVector &src, MidiNoteVector &dst,
|
||||
int len, int base, int start, int end)
|
||||
{
|
||||
if (start >= end) { return; }
|
||||
start -= base;
|
||||
end -= base;
|
||||
std::sort(src.begin(), src.end());
|
||||
for (auto it = src.begin(); it != src.end(); ++it)
|
||||
{
|
||||
for (int time = it->time + ceil((start - it->time) / len)
|
||||
* len; time < end; time += len)
|
||||
{
|
||||
MidiNote note;
|
||||
note.duration = it->duration;
|
||||
note.pitch = it->pitch;
|
||||
note.time = base + time;
|
||||
note.volume = it->volume;
|
||||
dst.push_back(note);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
void MidiExport::ProcessBBNotes(MidiNoteVector &nv, int cutPos)
|
||||
{
|
||||
std::sort(nv.begin(), nv.end());
|
||||
int cur = INT_MAX, next = INT_MAX;
|
||||
for (auto it = nv.rbegin(); it != nv.rend(); ++it)
|
||||
{
|
||||
if (it->time < cur)
|
||||
{
|
||||
next = cur;
|
||||
cur = it->time;
|
||||
}
|
||||
if (it->duration < 0)
|
||||
{
|
||||
it->duration = qMin(qMin(-it->duration, next - cur), cutPos - it->time);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
void MidiExport::error()
|
||||
{
|
||||
|
||||
@@ -1,7 +1,8 @@
|
||||
/*
|
||||
* MidiExport.h - support for Exporting MIDI-files
|
||||
*
|
||||
* Author: Mohamed Abdel Maksoud <mohamed at amaksoud.com>
|
||||
* Copyright (c) 2015 Mohamed Abdel Maksoud <mohamed at amaksoud.com>
|
||||
* Copyright (c) 2017 Hyunjin Song <tteu.ingog/at/gmail.com>
|
||||
*
|
||||
* This file is part of LMMS - https://lmms.io
|
||||
*
|
||||
@@ -31,25 +32,52 @@
|
||||
#include "MidiFile.hpp"
|
||||
|
||||
|
||||
const int BUFFER_SIZE = 50*1024;
|
||||
typedef MidiFile::MIDITrack<BUFFER_SIZE> MTrack;
|
||||
|
||||
struct MidiNote
|
||||
{
|
||||
int time;
|
||||
uint8_t pitch;
|
||||
int duration;
|
||||
uint8_t volume;
|
||||
|
||||
inline bool operator<(const MidiNote &b) const
|
||||
{
|
||||
return this->time < b.time;
|
||||
}
|
||||
} ;
|
||||
|
||||
typedef std::vector<MidiNote> MidiNoteVector;
|
||||
typedef std::vector<MidiNote>::iterator MidiNoteIterator;
|
||||
|
||||
|
||||
|
||||
class MidiExport: public ExportFilter
|
||||
{
|
||||
// Q_OBJECT
|
||||
public:
|
||||
MidiExport( );
|
||||
MidiExport();
|
||||
~MidiExport();
|
||||
|
||||
virtual PluginView * instantiateView( QWidget * )
|
||||
virtual PluginView *instantiateView(QWidget *)
|
||||
{
|
||||
return( NULL );
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
virtual bool tryExport( const TrackContainer::TrackList &tracks, int tempo, const QString &filename );
|
||||
virtual bool tryExport(const TrackContainer::TrackList &tracks,
|
||||
const TrackContainer::TrackList &tracks_BB,
|
||||
int tempo, int masterPitch, const QString &filename);
|
||||
|
||||
private:
|
||||
|
||||
void writePattern(MidiNoteVector &pat, QDomNode n,
|
||||
int base_pitch, double base_volume, int base_time);
|
||||
void writePatternToTrack(MTrack &mtrack, MidiNoteVector &nv);
|
||||
void writeBBPattern(MidiNoteVector &src, MidiNoteVector &dst,
|
||||
int len, int base, int start, int end);
|
||||
void ProcessBBNotes(MidiNoteVector &nv, int cutPos);
|
||||
|
||||
void error( void );
|
||||
void error();
|
||||
|
||||
|
||||
} ;
|
||||
|
||||
@@ -156,8 +156,10 @@ struct Event
|
||||
writeBigEndian4(int(60000000.0 / tempo), fourbytes);
|
||||
|
||||
//printf("tempo of %x translates to ", tempo);
|
||||
/*
|
||||
for (int i=0; i<3; i++) printf("%02x ", fourbytes[i+1]);
|
||||
printf("\n");
|
||||
*/
|
||||
buffer[size++] = fourbytes[1];
|
||||
buffer[size++] = fourbytes[2];
|
||||
buffer[size++] = fourbytes[3];
|
||||
@@ -186,7 +188,8 @@ struct Event
|
||||
|
||||
// events are sorted by their time
|
||||
inline bool operator < (const Event& b) const {
|
||||
return this->time < b.time;
|
||||
return this->time < b.time ||
|
||||
(this->time == b.time && this->type > b.type);
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
@@ -32,6 +32,7 @@
|
||||
#include <QMenu>
|
||||
#include <QDomElement>
|
||||
|
||||
#include "BufferManager.h"
|
||||
#include "Engine.h"
|
||||
#include "gui_templates.h"
|
||||
#include "InstrumentPlayHandle.h"
|
||||
@@ -285,16 +286,19 @@ void vestigeInstrument::loadFile( const QString & _file )
|
||||
void vestigeInstrument::play( sampleFrame * _buf )
|
||||
{
|
||||
m_pluginMutex.lock();
|
||||
|
||||
const fpp_t frames = Engine::mixer()->framesPerPeriod();
|
||||
|
||||
if( m_plugin == NULL )
|
||||
{
|
||||
BufferManager::clear( _buf, frames );
|
||||
|
||||
m_pluginMutex.unlock();
|
||||
return;
|
||||
}
|
||||
|
||||
m_plugin->process( NULL, _buf );
|
||||
|
||||
const fpp_t frames = Engine::mixer()->framesPerPeriod();
|
||||
|
||||
instrumentTrack()->processAudioBuffer( _buf, frames, NULL );
|
||||
|
||||
m_pluginMutex.unlock();
|
||||
|
||||
@@ -130,7 +130,7 @@ private:
|
||||
offset = ( m_randomize / 2.0f -
|
||||
m_randomize ) * r;
|
||||
_dl->data[i] = _scale *
|
||||
_values[_dl->length - i] +
|
||||
_values[_dl->length - i - 1] +
|
||||
offset;
|
||||
}
|
||||
for( int i = _pick; i < _dl->length; i++ )
|
||||
|
||||
@@ -44,6 +44,10 @@
|
||||
|
||||
#ifdef LMMS_BUILD_LINUX
|
||||
|
||||
#ifndef NOMINMAX
|
||||
#define NOMINMAX
|
||||
#endif
|
||||
|
||||
#ifndef O_BINARY
|
||||
#define O_BINARY 0
|
||||
#endif
|
||||
@@ -60,6 +64,7 @@
|
||||
#include <windows.h>
|
||||
|
||||
#include <vector>
|
||||
#include <queue>
|
||||
#include <string>
|
||||
|
||||
|
||||
@@ -105,7 +110,7 @@ class RemoteVstPlugin;
|
||||
|
||||
RemoteVstPlugin * __plugin = NULL;
|
||||
|
||||
DWORD __GuiThreadID = 0;
|
||||
HWND __MessageHwnd = NULL;
|
||||
|
||||
|
||||
|
||||
@@ -237,8 +242,58 @@ public:
|
||||
pthread_mutex_unlock( &m_pluginLock );
|
||||
}
|
||||
|
||||
inline void lockShm()
|
||||
{
|
||||
pthread_mutex_lock( &m_shmLock );
|
||||
}
|
||||
|
||||
inline void unlockShm()
|
||||
{
|
||||
pthread_mutex_unlock( &m_shmLock );
|
||||
}
|
||||
|
||||
inline bool isShmValid()
|
||||
{
|
||||
return m_shmValid;
|
||||
}
|
||||
|
||||
inline void setShmIsValid( bool valid )
|
||||
{
|
||||
m_shmValid = valid;
|
||||
}
|
||||
|
||||
inline bool isProcessing() const
|
||||
{
|
||||
return m_processing;
|
||||
}
|
||||
|
||||
inline void setProcessing( bool processing )
|
||||
{
|
||||
m_processing = processing;
|
||||
}
|
||||
|
||||
inline void queueMessage( const message & m ) {
|
||||
m_messageList.push( m );
|
||||
}
|
||||
|
||||
inline bool shouldGiveIdle() const
|
||||
{
|
||||
return m_shouldGiveIdle;
|
||||
}
|
||||
|
||||
inline void setShouldGiveIdle( bool shouldGiveIdle )
|
||||
{
|
||||
m_shouldGiveIdle = shouldGiveIdle;
|
||||
}
|
||||
|
||||
void idle();
|
||||
void processUIThreadMessages();
|
||||
|
||||
static DWORD WINAPI processingThread( LPVOID _param );
|
||||
static DWORD WINAPI guiEventLoop( LPVOID _param );
|
||||
static bool setupMessageWindow();
|
||||
static DWORD WINAPI guiEventLoop();
|
||||
static LRESULT CALLBACK messageWndProc( HWND hwnd, UINT uMsg,
|
||||
WPARAM wParam, LPARAM lParam );
|
||||
|
||||
|
||||
private:
|
||||
@@ -297,11 +352,18 @@ private:
|
||||
bool m_registeredWindowClass;
|
||||
|
||||
pthread_mutex_t m_pluginLock;
|
||||
bool m_processing;
|
||||
|
||||
std::queue<message> m_messageList;
|
||||
bool m_shouldGiveIdle;
|
||||
|
||||
|
||||
float * * m_inputs;
|
||||
float * * m_outputs;
|
||||
|
||||
pthread_mutex_t m_shmLock;
|
||||
bool m_shmValid;
|
||||
|
||||
typedef std::vector<VstMidiEvent> VstMidiEventList;
|
||||
VstMidiEventList m_midiEvents;
|
||||
|
||||
@@ -342,8 +404,13 @@ RemoteVstPlugin::RemoteVstPlugin( const char * socketPath ) :
|
||||
m_initialized( false ),
|
||||
m_registeredWindowClass( false ),
|
||||
m_pluginLock(),
|
||||
m_processing( false ),
|
||||
m_messageList(),
|
||||
m_shouldGiveIdle( false ),
|
||||
m_inputs( NULL ),
|
||||
m_outputs( NULL ),
|
||||
m_shmLock(),
|
||||
m_shmValid( false ),
|
||||
m_midiEvents(),
|
||||
m_bpm( 0 ),
|
||||
m_currentSamplePos( 0 ),
|
||||
@@ -353,6 +420,7 @@ RemoteVstPlugin::RemoteVstPlugin( const char * socketPath ) :
|
||||
m_vstSyncData( NULL )
|
||||
{
|
||||
pthread_mutex_init( &m_pluginLock, NULL );
|
||||
pthread_mutex_init( &m_shmLock, NULL );
|
||||
|
||||
__plugin = this;
|
||||
|
||||
@@ -444,6 +512,7 @@ RemoteVstPlugin::~RemoteVstPlugin()
|
||||
delete[] m_inputs;
|
||||
delete[] m_outputs;
|
||||
|
||||
pthread_mutex_destroy( &m_shmLock );
|
||||
pthread_mutex_destroy( &m_pluginLock );
|
||||
}
|
||||
|
||||
@@ -838,6 +907,16 @@ void RemoteVstPlugin::process( const sampleFrame * _in, sampleFrame * _out )
|
||||
|
||||
// now we're ready to fetch sound from VST-plugin
|
||||
|
||||
lock();
|
||||
lockShm();
|
||||
|
||||
if( !isShmValid() )
|
||||
{
|
||||
unlockShm();
|
||||
unlock();
|
||||
return;
|
||||
}
|
||||
|
||||
for( int i = 0; i < inputCount(); ++i )
|
||||
{
|
||||
m_inputs[i] = &((float *) _in)[i * bufferSize()];
|
||||
@@ -849,8 +928,6 @@ void RemoteVstPlugin::process( const sampleFrame * _in, sampleFrame * _out )
|
||||
memset( m_outputs[i], 0, bufferSize() * sizeof( float ) );
|
||||
}
|
||||
|
||||
lock();
|
||||
|
||||
#ifdef OLD_VST_SDK
|
||||
if( m_plugin->flags & effFlagsCanReplacing )
|
||||
{
|
||||
@@ -866,6 +943,7 @@ void RemoteVstPlugin::process( const sampleFrame * _in, sampleFrame * _out )
|
||||
}
|
||||
#endif
|
||||
|
||||
unlockShm();
|
||||
unlock();
|
||||
|
||||
m_currentSamplePos += bufferSize();
|
||||
@@ -1351,20 +1429,7 @@ void RemoteVstPlugin::loadPresetFile( const std::string & _file )
|
||||
|
||||
void RemoteVstPlugin::loadChunkFromFile( const std::string & _file, int _len )
|
||||
{
|
||||
char * buf = NULL;
|
||||
|
||||
void * chunk = NULL;
|
||||
// various plugins need this in order to not crash when setting
|
||||
// chunk (also we let the plugin allocate "safe" memory this way)
|
||||
const int actualLen = pluginDispatch( 23, 0, 0, &chunk );
|
||||
|
||||
// allocated buffer big enough?
|
||||
if( _len > actualLen )
|
||||
{
|
||||
// no, then manually allocate a buffer
|
||||
buf = new char[_len];
|
||||
chunk = buf;
|
||||
}
|
||||
char * chunk = new char[_len];
|
||||
|
||||
const int fd = open( _file.c_str(), O_RDONLY | O_BINARY );
|
||||
if ( ::read( fd, chunk, _len ) != _len )
|
||||
@@ -1372,9 +1437,10 @@ void RemoteVstPlugin::loadChunkFromFile( const std::string & _file, int _len )
|
||||
fprintf( stderr, "Error loading chunk from file.\n" );
|
||||
}
|
||||
close_check( fd );
|
||||
pluginDispatch( 24, 0, _len, chunk );
|
||||
|
||||
delete[] buf;
|
||||
pluginDispatch( effSetChunk, 0, _len, chunk );
|
||||
|
||||
delete[] chunk;
|
||||
}
|
||||
|
||||
|
||||
@@ -1382,14 +1448,19 @@ void RemoteVstPlugin::loadChunkFromFile( const std::string & _file, int _len )
|
||||
|
||||
void RemoteVstPlugin::updateInOutCount()
|
||||
{
|
||||
lockShm();
|
||||
|
||||
setShmIsValid( false );
|
||||
|
||||
unlockShm();
|
||||
|
||||
delete[] m_inputs;
|
||||
delete[] m_outputs;
|
||||
|
||||
m_inputs = NULL;
|
||||
m_outputs = NULL;
|
||||
|
||||
setInputCount( inputCount() );
|
||||
setOutputCount( outputCount() );
|
||||
setInputOutputCount( inputCount(), outputCount() );
|
||||
|
||||
char buf[64];
|
||||
sprintf( buf, "inputs: %d output: %d\n", inputCount(), outputCount() );
|
||||
@@ -1462,8 +1533,7 @@ intptr_t RemoteVstPlugin::hostCallback( AEffect * _effect, int32_t _opcode,
|
||||
SHOW_CALLBACK ("amc: audioMasterIdle\n" );
|
||||
// call application idle routine (this will
|
||||
// call effEditIdle for all open editors too)
|
||||
PostThreadMessage( __GuiThreadID,
|
||||
WM_USER, GiveIdle, 0 );
|
||||
PostMessage( __MessageHwnd, WM_USER, GiveIdle, 0 );
|
||||
return 0;
|
||||
|
||||
case audioMasterPinConnected:
|
||||
@@ -1764,8 +1834,7 @@ intptr_t RemoteVstPlugin::hostCallback( AEffect * _effect, int32_t _opcode,
|
||||
case audioMasterUpdateDisplay:
|
||||
SHOW_CALLBACK( "amc: audioMasterUpdateDisplay\n" );
|
||||
// something has changed, update 'multi-fx' display
|
||||
PostThreadMessage( __GuiThreadID,
|
||||
WM_USER, GiveIdle, 0 );
|
||||
PostMessage( __MessageHwnd, WM_USER, GiveIdle, 0 );
|
||||
return 0;
|
||||
|
||||
#if kVstVersion > 2
|
||||
@@ -1798,6 +1867,43 @@ intptr_t RemoteVstPlugin::hostCallback( AEffect * _effect, int32_t _opcode,
|
||||
|
||||
|
||||
|
||||
void RemoteVstPlugin::idle()
|
||||
{
|
||||
if( isProcessing() )
|
||||
{
|
||||
setShouldGiveIdle( true );
|
||||
return;
|
||||
}
|
||||
setProcessing( true );
|
||||
pluginDispatch( effEditIdle );
|
||||
setShouldGiveIdle( false );
|
||||
setProcessing( false );
|
||||
// We might have received a message whilst idling
|
||||
processUIThreadMessages();
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void RemoteVstPlugin::processUIThreadMessages()
|
||||
{
|
||||
setProcessing( true );
|
||||
while( m_messageList.size() )
|
||||
{
|
||||
processMessage( m_messageList.front() );
|
||||
m_messageList.pop();
|
||||
if( shouldGiveIdle() )
|
||||
{
|
||||
pluginDispatch( effEditIdle );
|
||||
setShouldGiveIdle( false );
|
||||
}
|
||||
}
|
||||
setProcessing( false );
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
DWORD WINAPI RemoteVstPlugin::processingThread( LPVOID _param )
|
||||
{
|
||||
RemoteVstPlugin * _this = static_cast<RemoteVstPlugin *>( _param );
|
||||
@@ -1809,9 +1915,14 @@ DWORD WINAPI RemoteVstPlugin::processingThread( LPVOID _param )
|
||||
{
|
||||
_this->processMessage( m );
|
||||
}
|
||||
else if( m.id == IdChangeSharedMemoryKey )
|
||||
{
|
||||
_this->processMessage( m );
|
||||
_this->setShmIsValid( true );
|
||||
}
|
||||
else
|
||||
{
|
||||
PostThreadMessage( __GuiThreadID,
|
||||
PostMessage( __MessageHwnd,
|
||||
WM_USER,
|
||||
ProcessPluginMessage,
|
||||
(LPARAM) new message( m ) );
|
||||
@@ -1819,7 +1930,7 @@ DWORD WINAPI RemoteVstPlugin::processingThread( LPVOID _param )
|
||||
}
|
||||
|
||||
// notify GUI thread about shutdown
|
||||
PostThreadMessage( __GuiThreadID, WM_USER, ClosePlugin, 0 );
|
||||
PostMessage( __MessageHwnd, WM_USER, ClosePlugin, 0 );
|
||||
|
||||
return 0;
|
||||
}
|
||||
@@ -1827,68 +1938,44 @@ DWORD WINAPI RemoteVstPlugin::processingThread( LPVOID _param )
|
||||
|
||||
|
||||
|
||||
DWORD WINAPI RemoteVstPlugin::guiEventLoop( LPVOID _param )
|
||||
bool RemoteVstPlugin::setupMessageWindow()
|
||||
{
|
||||
RemoteVstPlugin * _this = static_cast<RemoteVstPlugin *>( _param );
|
||||
|
||||
HMODULE hInst = GetModuleHandle( NULL );
|
||||
if( hInst == NULL )
|
||||
{
|
||||
_this->debugMessage( "guiEventLoop(): can't get "
|
||||
__plugin->debugMessage( "setupMessageWindow(): can't get "
|
||||
"module handle\n" );
|
||||
return -1;
|
||||
return false;
|
||||
}
|
||||
|
||||
HWND timerWindow = CreateWindowEx( 0, "LVSL", "dummy",
|
||||
__MessageHwnd = CreateWindowEx( 0, "LVSL", "dummy",
|
||||
0, 0, 0, 0, 0, NULL, NULL,
|
||||
hInst, NULL );
|
||||
SetWindowLongPtr( __MessageHwnd, GWLP_WNDPROC,
|
||||
reinterpret_cast<LONG_PTR>( RemoteVstPlugin::messageWndProc ) );
|
||||
// install GUI update timer
|
||||
SetTimer( timerWindow, 1000, 50, NULL );
|
||||
SetTimer( __MessageHwnd, 1000, 50, NULL );
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
DWORD WINAPI RemoteVstPlugin::guiEventLoop()
|
||||
{
|
||||
MSG msg;
|
||||
|
||||
bool quit = false;
|
||||
while( quit == false && GetMessage( &msg, NULL, 0, 0 ) )
|
||||
while( GetMessage( &msg, NULL, 0, 0 ) > 0 )
|
||||
{
|
||||
TranslateMessage( &msg );
|
||||
|
||||
if( msg.message == WM_SYSCOMMAND && msg.wParam == SC_CLOSE )
|
||||
{
|
||||
_this->destroyEditor();
|
||||
__plugin->destroyEditor();
|
||||
continue;
|
||||
}
|
||||
|
||||
DispatchMessage( &msg );
|
||||
|
||||
if( msg.message == WM_TIMER && _this->isInitialized() )
|
||||
{
|
||||
// give plugin some idle-time for GUI-update
|
||||
_this->pluginDispatch( effEditIdle );
|
||||
}
|
||||
else if( msg.message == WM_USER )
|
||||
{
|
||||
switch( msg.wParam )
|
||||
{
|
||||
case ProcessPluginMessage:
|
||||
{
|
||||
message * m = (message *) msg.lParam;
|
||||
_this->processMessage( *m );
|
||||
delete m;
|
||||
break;
|
||||
}
|
||||
|
||||
case GiveIdle:
|
||||
_this->pluginDispatch( effEditIdle );
|
||||
break;
|
||||
|
||||
case ClosePlugin:
|
||||
quit = true;
|
||||
break;
|
||||
|
||||
default:
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return 0;
|
||||
@@ -1897,6 +1984,49 @@ DWORD WINAPI RemoteVstPlugin::guiEventLoop( LPVOID _param )
|
||||
|
||||
|
||||
|
||||
LRESULT CALLBACK RemoteVstPlugin::messageWndProc( HWND hwnd, UINT uMsg,
|
||||
WPARAM wParam, LPARAM lParam )
|
||||
{
|
||||
if( uMsg == WM_TIMER && __plugin->isInitialized() )
|
||||
{
|
||||
// give plugin some idle-time for GUI-update
|
||||
__plugin->idle();
|
||||
return 0;
|
||||
}
|
||||
else if( uMsg == WM_USER )
|
||||
{
|
||||
switch( wParam )
|
||||
{
|
||||
case ProcessPluginMessage:
|
||||
{
|
||||
message * m = (message *) lParam;
|
||||
__plugin->queueMessage( *m );
|
||||
delete m;
|
||||
if( !__plugin->isProcessing() )
|
||||
{
|
||||
__plugin->processUIThreadMessages();
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
case GiveIdle:
|
||||
__plugin->idle();
|
||||
return 0;
|
||||
|
||||
case ClosePlugin:
|
||||
PostQuitMessage(0);
|
||||
return 0;
|
||||
|
||||
default:
|
||||
break;
|
||||
}
|
||||
}
|
||||
return DefWindowProc( hwnd, uMsg, wParam, lParam );
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
int main( int _argc, char * * _argv )
|
||||
{
|
||||
#ifdef SYNC_WITH_SHM_FIFO
|
||||
@@ -1944,7 +2074,10 @@ int main( int _argc, char * * _argv )
|
||||
|
||||
if( __plugin->isInitialized() )
|
||||
{
|
||||
__GuiThreadID = GetCurrentThreadId();
|
||||
if( RemoteVstPlugin::setupMessageWindow() == false )
|
||||
{
|
||||
return -1;
|
||||
}
|
||||
if( CreateThread( NULL, 0, RemoteVstPlugin::processingThread,
|
||||
__plugin, 0, NULL ) == NULL )
|
||||
{
|
||||
@@ -1952,7 +2085,7 @@ int main( int _argc, char * * _argv )
|
||||
"processingThread\n" );
|
||||
return -1;
|
||||
}
|
||||
RemoteVstPlugin::guiEventLoop( __plugin );
|
||||
RemoteVstPlugin::guiEventLoop();
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -394,7 +394,7 @@ int VstPlugin::currentProgram()
|
||||
{
|
||||
lock();
|
||||
sendMessage( message( IdVstCurrentProgram ) );
|
||||
waitForMessage( IdVstCurrentProgram );
|
||||
waitForMessage( IdVstCurrentProgram, true );
|
||||
unlock();
|
||||
|
||||
return m_currentProgram;
|
||||
@@ -406,7 +406,7 @@ const QMap<QString, QString> & VstPlugin::parameterDump()
|
||||
{
|
||||
lock();
|
||||
sendMessage( IdVstGetParameterDump );
|
||||
waitForMessage( IdVstParameterDump );
|
||||
waitForMessage( IdVstParameterDump, true );
|
||||
unlock();
|
||||
|
||||
return m_parameterDump;
|
||||
@@ -533,7 +533,7 @@ void VstPlugin::openPreset( )
|
||||
QSTR_TO_STDSTR(
|
||||
QDir::toNativeSeparators( ofd.selectedFiles()[0] ) ) )
|
||||
);
|
||||
waitForMessage( IdLoadPresetFile );
|
||||
waitForMessage( IdLoadPresetFile, true );
|
||||
unlock();
|
||||
}
|
||||
}
|
||||
@@ -545,7 +545,7 @@ void VstPlugin::setProgram( int index )
|
||||
{
|
||||
lock();
|
||||
sendMessage( message( IdVstSetProgram ).addInt( index ) );
|
||||
waitForMessage( IdVstSetProgram );
|
||||
waitForMessage( IdVstSetProgram, true );
|
||||
unlock();
|
||||
}
|
||||
|
||||
@@ -556,7 +556,7 @@ void VstPlugin::rotateProgram( int offset )
|
||||
{
|
||||
lock();
|
||||
sendMessage( message( IdVstRotateProgram ).addInt( offset ) );
|
||||
waitForMessage( IdVstRotateProgram );
|
||||
waitForMessage( IdVstRotateProgram, true );
|
||||
unlock();
|
||||
}
|
||||
|
||||
@@ -567,7 +567,7 @@ void VstPlugin::loadProgramNames()
|
||||
{
|
||||
lock();
|
||||
sendMessage( message( IdVstProgramNames ) );
|
||||
waitForMessage( IdVstProgramNames );
|
||||
waitForMessage( IdVstProgramNames, true );
|
||||
unlock();
|
||||
}
|
||||
|
||||
@@ -604,7 +604,7 @@ void VstPlugin::savePreset( )
|
||||
QSTR_TO_STDSTR(
|
||||
QDir::toNativeSeparators( fns ) ) )
|
||||
);
|
||||
waitForMessage( IdSavePresetFile );
|
||||
waitForMessage( IdSavePresetFile, true );
|
||||
unlock();
|
||||
}
|
||||
}
|
||||
@@ -616,7 +616,7 @@ void VstPlugin::setParam( int i, float f )
|
||||
{
|
||||
lock();
|
||||
sendMessage( message( IdVstSetParameter ).addInt( i ).addFloat( f ) );
|
||||
//waitForMessage( IdVstSetParameter );
|
||||
//waitForMessage( IdVstSetParameter, true );
|
||||
unlock();
|
||||
}
|
||||
|
||||
@@ -645,7 +645,7 @@ void VstPlugin::loadChunk( const QByteArray & _chunk )
|
||||
QSTR_TO_STDSTR(
|
||||
QDir::toNativeSeparators( tf.fileName() ) ) ).
|
||||
addInt( _chunk.size() ) );
|
||||
waitForMessage( IdLoadSettingsFromFile );
|
||||
waitForMessage( IdLoadSettingsFromFile, true );
|
||||
unlock();
|
||||
}
|
||||
}
|
||||
@@ -664,7 +664,7 @@ QByteArray VstPlugin::saveChunk()
|
||||
addString(
|
||||
QSTR_TO_STDSTR(
|
||||
QDir::toNativeSeparators( tf.fileName() ) ) ) );
|
||||
waitForMessage( IdSaveSettingsToFile );
|
||||
waitForMessage( IdSaveSettingsToFile, true );
|
||||
unlock();
|
||||
a = tf.readAll();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user