falkTX
/
Carla
mirror of https://github.com/falkTX/Carla
1
0
Fork 0
Code Releases 43 Activity
Audio plugin host https://kx.studio/carla
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
751 Commits
17 Branches
625MB
Tree: 99b895bd1e
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '99b895bd1e'
${ noResults }
Carla/source/backend/plugin/DssiPlugin.cpp

2058 lines
72KB
Raw Blame History 

  1. /*

  2.  * Carla DSSI Plugin

  3.  * Copyright (C) 2011-2013 Filipe Coelho <falktx@falktx.com>

  4.  *

  5.  * This program is free software; you can redistribute it and/or

  6.  * modify it under the terms of the GNU General Public License as

  7.  * published by the Free Software Foundation; either version 2 of

  8.  * the License, or any later version.

  9.  *

  10.  * This program is distributed in the hope that it will be useful,

  11.  * but WITHOUT ANY WARRANTY; without even the implied warranty of

  12.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

  13.  * GNU General Public License for more details.

  14.  *

  15.  * For a full copy of the GNU General Public License see the GPL.txt file

  16.  */

  17. 

  18. #include "CarlaPluginInternal.hpp"

  19. 

  20. #ifdef WANT_DSSI

  21. 

  22. #include "CarlaLadspaUtils.hpp"

  23. #include "dssi/dssi.h"

  24. 

  25. CARLA_BACKEND_START_NAMESPACE

  26. 

  27. #if 0

  28. }

  29. #endif

  30. 

  31. class DssiPlugin : public CarlaPlugin

  32. {

  33. public:

  34.     DssiPlugin(CarlaEngine* const engine, const unsigned int id)

  35.         : CarlaPlugin(engine, id),

  36.           fHandle(nullptr),

  37.           fHandle2(nullptr),

  38.           fDescriptor(nullptr),

  39.           fDssiDescriptor(nullptr),

  40.           fAudioInBuffers(nullptr),

  41.           fAudioOutBuffers(nullptr),

  42.           fParamBuffers(nullptr)

  43.     {

  44.         carla_debug("DssiPlugin::DssiPlugin(%p, %i)", engine, id);

  45. 

  46.         carla_zeroStruct<snd_seq_event_t>(fMidiEvents, MAX_MIDI_EVENTS);

  47. 

  48.         kData->osc.thread.setMode(CarlaPluginThread::PLUGIN_THREAD_DSSI_GUI);

  49.     }

  50. 

  51.     ~DssiPlugin() override

  52.     {

  53.         carla_debug("DssiPlugin::~DssiPlugin()");

  54. 

  55.         // close UI

  56.         if (fHints & PLUGIN_HAS_GUI)

  57.         {

  58.             showGui(false);

  59. 

  60.             // Wait a bit first, then force kill

  61.             if (kData->osc.thread.isRunning() && ! kData->osc.thread.wait(kData->engine->getOptions().oscUiTimeout))

  62.             {

  63.                 carla_stderr("DSSI GUI thread still running, forcing termination now");

  64.                 kData->osc.thread.terminate();

  65.             }

  66.         }

  67. 

  68.         kData->singleMutex.lock();

  69.         kData->masterMutex.lock();

  70. 

  71.         if (kData->client != nullptr && kData->client->isActive())

  72.             kData->client->deactivate();

  73. 

  74.         if (kData->active)

  75.         {

  76.             deactivate();

  77.             kData->active = false;

  78.         }

  79. 

  80.         if (fDescriptor != nullptr)

  81.         {

  82.             if (fName.isNotEmpty() && fDssiDescriptor != nullptr && fDssiDescriptor->run_synth == nullptr && fDssiDescriptor->run_multiple_synths != nullptr)

  83.             {

  84.                 removeUniqueMultiSynth(fDescriptor->Label);

  85.             }

  86. 

  87.             if (fDescriptor->cleanup != nullptr)

  88.             {

  89.                 if (fHandle != nullptr)

  90.                     fDescriptor->cleanup(fHandle);

  91.                 if (fHandle2 != nullptr)

  92.                     fDescriptor->cleanup(fHandle2);

  93.             }

  94. 

  95.             fHandle  = nullptr;

  96.             fHandle2 = nullptr;

  97.             fDescriptor = nullptr;

  98.             fDssiDescriptor = nullptr;

  99.         }

  100. 

  101.         clearBuffers();

  102.     }

  103. 

  104.     // -------------------------------------------------------------------

  105.     // Information (base)

  106. 

  107.     PluginType type() const override

  108.     {

  109.         return PLUGIN_DSSI;

  110.     }

  111. 

  112.     PluginCategory category() override

  113.     {

  114.         if (fHints & PLUGIN_IS_SYNTH)

  115.             return PLUGIN_CATEGORY_SYNTH;

  116. 

  117.         return getPluginCategoryFromName(fName);

  118.     }

  119. 

  120.     long uniqueId() const override

  121.     {

  122.         CARLA_ASSERT(fDescriptor != nullptr);

  123. 

  124.         return fDescriptor->UniqueID;

  125.     }

  126. 

  127.     // -------------------------------------------------------------------

  128.     // Information (count)

  129. 

  130.     // nothing

  131. 

  132.     // -------------------------------------------------------------------

  133.     // Information (current data)

  134. 

  135.     int32_t chunkData(void** const dataPtr) override

  136.     {

  137.         CARLA_ASSERT(fOptions & PLUGIN_OPTION_USE_CHUNKS);

  138.         CARLA_ASSERT(fDssiDescriptor != nullptr);

  139.         CARLA_ASSERT(fDssiDescriptor->get_custom_data != nullptr);

  140.         CARLA_ASSERT(fHandle != nullptr);

  141.         CARLA_ASSERT(fHandle2 == nullptr);

  142.         CARLA_ASSERT(dataPtr != nullptr);

  143. 

  144.         unsigned long dataSize = 0;

  145. 

  146.         if (fDssiDescriptor->get_custom_data != nullptr && fDssiDescriptor->get_custom_data(fHandle, dataPtr, &dataSize) != 0)

  147.             return static_cast<int32_t>(dataSize);

  148. 

  149.         return 0;

  150.     }

  151. 

  152.     // -------------------------------------------------------------------

  153.     // Information (per-plugin data)

  154. 

  155.     unsigned int availableOptions() override

  156.     {

  157.         CARLA_ASSERT(fDssiDescriptor != nullptr);

  158. 

  159.         if (fDssiDescriptor == nullptr)

  160.             return 0x0;

  161. 

  162. #ifdef __USE_GNU

  163.         const bool isDssiVst = fFilename.contains("dssi-vst", true);

  164. #else

  165.         const bool isDssiVst = fFilename.contains("dssi-vst");

  166. #endif

  167. 

  168.         unsigned int options = 0x0;

  169. 

  170.         options |= PLUGIN_OPTION_MAP_PROGRAM_CHANGES;

  171. 

  172.         if (isDssiVst)

  173.         {

  174.             if (kData->engine->getOptions().useDssiVstChunks && fDssiDescriptor->get_custom_data != nullptr && fDssiDescriptor->set_custom_data != nullptr)

  175.                 options |= PLUGIN_OPTION_USE_CHUNKS;

  176.         }

  177.         else

  178.         {

  179.             if (kData->engine->getProccessMode() != PROCESS_MODE_CONTINUOUS_RACK)

  180.             {

  181.                 if (fOptions & PLUGIN_OPTION_FORCE_STEREO)

  182.                     options |= PLUGIN_OPTION_FORCE_STEREO;

  183.                 else if (kData->audioIn.count <= 1 && kData->audioOut.count <= 1 && (kData->audioIn.count != 0 || kData->audioOut.count != 0))

  184.                     options |= PLUGIN_OPTION_FORCE_STEREO;

  185.             }

  186. 

  187.             options |= PLUGIN_OPTION_FIXED_BUFFER;

  188.         }

  189. 

  190.         if (fDssiDescriptor->run_synth != nullptr || fDssiDescriptor->run_multiple_synths != nullptr)

  191.         {

  192.             options |= PLUGIN_OPTION_SEND_CONTROL_CHANGES;

  193.             options |= PLUGIN_OPTION_SEND_CHANNEL_PRESSURE;

  194.             options |= PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH;

  195.             options |= PLUGIN_OPTION_SEND_PITCHBEND;

  196.             options |= PLUGIN_OPTION_SEND_ALL_SOUND_OFF;

  197.         }

  198. 

  199.         return options;

  200.     }

  201. 

  202.     float getParameterValue(const uint32_t parameterId) override

  203.     {

  204.         CARLA_ASSERT(fParamBuffers != nullptr);

  205.         CARLA_ASSERT(parameterId < kData->param.count);

  206. 

  207.         return fParamBuffers[parameterId];

  208.     }

  209. 

  210.     void getLabel(char* const strBuf) override

  211.     {

  212.         CARLA_ASSERT(fDescriptor != nullptr);

  213. 

  214.         if (fDescriptor->Label != nullptr)

  215.             std::strncpy(strBuf, fDescriptor->Label, STR_MAX);

  216.         else

  217.             CarlaPlugin::getLabel(strBuf);

  218.     }

  219. 

  220.     void getMaker(char* const strBuf) override

  221.     {

  222.         CARLA_ASSERT(fDescriptor != nullptr);

  223. 

  224.         if (fDescriptor->Maker != nullptr)

  225.             std::strncpy(strBuf, fDescriptor->Maker, STR_MAX);

  226.         else

  227.             CarlaPlugin::getMaker(strBuf);

  228.     }

  229. 

  230.     void getCopyright(char* const strBuf) override

  231.     {

  232.         CARLA_ASSERT(fDescriptor != nullptr);

  233. 

  234.         if (fDescriptor->Copyright != nullptr)

  235.             std::strncpy(strBuf, fDescriptor->Copyright, STR_MAX);

  236.         else

  237.             CarlaPlugin::getCopyright(strBuf);

  238.     }

  239. 

  240.     void getRealName(char* const strBuf) override

  241.     {

  242.         CARLA_ASSERT(fDescriptor != nullptr);

  243. 

  244.         if (fDescriptor->Name != nullptr)

  245.             std::strncpy(strBuf, fDescriptor->Name, STR_MAX);

  246.         else

  247.             CarlaPlugin::getRealName(strBuf);

  248.     }

  249. 

  250.     void getParameterName(const uint32_t parameterId, char* const strBuf) override

  251.     {

  252.         CARLA_ASSERT(fDescriptor != nullptr);

  253.         CARLA_ASSERT(parameterId < kData->param.count);

  254. 

  255.         const int32_t rindex(kData->param.data[parameterId].rindex);

  256. 

  257.         if (rindex < static_cast<int32_t>(fDescriptor->PortCount))

  258.             std::strncpy(strBuf, fDescriptor->PortNames[rindex], STR_MAX);

  259.         else

  260.             CarlaPlugin::getParameterName(parameterId, strBuf);

  261.     }

  262. 

  263.     // -------------------------------------------------------------------

  264.     // Set data (state)

  265. 

  266.     // nothing

  267. 

  268.     // -------------------------------------------------------------------

  269.     // Set data (internal stuff)

  270. 

  271.     // nothing

  272. 

  273.     // -------------------------------------------------------------------

  274.     // Set data (plugin-specific stuff)

  275. 

  276.     void setParameterValue(const uint32_t parameterId, const float value, const bool sendGui, const bool sendOsc, const bool sendCallback) override

  277.     {

  278.         CARLA_ASSERT(parameterId < kData->param.count);

  279. 

  280.         const float fixedValue(kData->param.fixValue(parameterId, value));

  281.         fParamBuffers[parameterId] = fixedValue;

  282. 

  283.         CarlaPlugin::setParameterValue(parameterId, fixedValue, sendGui, sendOsc, sendCallback);

  284.     }

  285. 

  286.     void setCustomData(const char* const type, const char* const key, const char* const value, const bool sendGui) override

  287.     {

  288.         CARLA_ASSERT(fDescriptor != nullptr);

  289.         CARLA_ASSERT(fHandle != nullptr);

  290.         CARLA_ASSERT(type != nullptr);

  291.         CARLA_ASSERT(key != nullptr);

  292.         CARLA_ASSERT(value != nullptr);

  293.         carla_debug("DssiPlugin::setCustomData(%s, %s, %s, %s)", type, key, value, bool2str(sendGui));

  294. 

  295.         if (type == nullptr)

  296.             return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - type is invalid", type, key, value, bool2str(sendGui));

  297. 

  298.         if (std::strcmp(type, CUSTOM_DATA_STRING) != 0)

  299.             return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - type is not string", type, key, value, bool2str(sendGui));

  300. 

  301.         if (key == nullptr)

  302.             return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - key is null", type, key, value, bool2str(sendGui));

  303. 

  304.         if (value == nullptr)

  305.             return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - value is null", type, key, value, bool2str(sendGui));

  306. 

  307.         if (fDssiDescriptor->configure != nullptr)

  308.         {

  309.             fDssiDescriptor->configure(fHandle, key, value);

  310. 

  311.             if (fHandle2)

  312.                 fDssiDescriptor->configure(fHandle2, key, value);

  313.         }

  314. 

  315.         if (sendGui && kData->osc.data.target != nullptr)

  316.             osc_send_configure(&kData->osc.data, key, value);

  317. 

  318.         if (std::strcmp(key, "reloadprograms") == 0 || std::strcmp(key, "load") == 0 || std::strncmp(key, "patches", 7) == 0)

  319.         {

  320.             const ScopedDisabler sd(this);

  321.             reloadPrograms(false);

  322.         }

  323. 

  324.         CarlaPlugin::setCustomData(type, key, value, sendGui);

  325.     }

  326. 

  327.     void setChunkData(const char* const stringData) override

  328.     {

  329.         CARLA_ASSERT(fOptions & PLUGIN_OPTION_USE_CHUNKS);

  330.         CARLA_ASSERT(fDssiDescriptor != nullptr);

  331.         CARLA_ASSERT(fDssiDescriptor->set_custom_data != nullptr);

  332.         CARLA_ASSERT(fHandle != nullptr);

  333.         CARLA_ASSERT(fHandle2 == nullptr);

  334.         CARLA_ASSERT(stringData != nullptr);

  335. 

  336.         if (fDssiDescriptor->set_custom_data == nullptr)

  337.             return;

  338. 

  339.         QByteArray chunk(QByteArray::fromBase64(stringData));

  340. 

  341.         CARLA_ASSERT(chunk.size() > 0);

  342. 

  343.         if (chunk.size() > 0)

  344.         {

  345.             const ScopedSingleProcessLocker spl(this, true);

  346.             fDssiDescriptor->set_custom_data(fHandle, chunk.data(), chunk.size());

  347.         }

  348.     }

  349. 

  350.     void setMidiProgram(int32_t index, const bool sendGui, const bool sendOsc, const bool sendCallback) override

  351.     {

  352.         CARLA_ASSERT(fDssiDescriptor != nullptr);

  353.         CARLA_ASSERT(fHandle != nullptr);

  354.         CARLA_ASSERT(index >= -1 && index < static_cast<int32_t>(kData->midiprog.count));

  355. 

  356.         if (index < -1)

  357.             index = -1;

  358.         else if (index > static_cast<int32_t>(kData->midiprog.count))

  359.             return;

  360. 

  361.         if (index >= 0 && fDssiDescriptor != nullptr && fDssiDescriptor->select_program != nullptr)

  362.         {

  363.             const uint32_t bank    = kData->midiprog.data[index].bank;

  364.             const uint32_t program = kData->midiprog.data[index].program;

  365. 

  366.             const ScopedSingleProcessLocker spl(this, (sendGui || sendOsc || sendCallback));

  367. 

  368.             fDssiDescriptor->select_program(fHandle, bank, program);

  369. 

  370.             if (fHandle2 != nullptr)

  371.                 fDssiDescriptor->select_program(fHandle2, bank, program);

  372.         }

  373. 

  374.         CarlaPlugin::setMidiProgram(index, sendGui, sendOsc, sendCallback);

  375.     }

  376. 

  377.     // -------------------------------------------------------------------

  378.     // Set gui stuff

  379. 

  380.     void showGui(const bool yesNo) override

  381.     {

  382.         if (yesNo)

  383.         {

  384.             kData->osc.data.free();

  385.             kData->osc.thread.start();

  386.         }

  387.         else

  388.         {

  389.             if (kData->osc.data.target != nullptr)

  390.             {

  391.                 osc_send_hide(&kData->osc.data);

  392.                 osc_send_quit(&kData->osc.data);

  393.                 kData->osc.data.free();

  394.             }

  395. 

  396.             if (kData->osc.thread.isRunning() && ! kData->osc.thread.wait(kData->engine->getOptions().oscUiTimeout))

  397.                 kData->osc.thread.terminate();

  398.         }

  399.     }

  400. 

  401.     // -------------------------------------------------------------------

  402.     // Plugin state

  403. 

  404.     void reload() override

  405.     {

  406.         carla_debug("DssiPlugin::reload() - start");

  407.         CARLA_ASSERT(kData->engine != nullptr);

  408.         CARLA_ASSERT(fDescriptor != nullptr);

  409.         CARLA_ASSERT(fDssiDescriptor != nullptr);

  410.         CARLA_ASSERT(fHandle != nullptr);

  411. 

  412.         if (kData->engine == nullptr)

  413.             return;

  414.         if (fDescriptor == nullptr)

  415.             return;

  416.         if (fDssiDescriptor == nullptr)

  417.             return;

  418.         if (fHandle == nullptr)

  419.             return;

  420. 

  421.         const ProcessMode processMode(kData->engine->getProccessMode());

  422. 

  423.         // Safely disable plugin for reload

  424.         const ScopedDisabler sd(this);

  425. 

  426.         if (kData->active)

  427.             deactivate();

  428. 

  429.         clearBuffers();

  430. 

  431.         const float sampleRate(static_cast<float>(kData->engine->getSampleRate()));

  432.         const uint32_t portCount(static_cast<uint32_t>(fDescriptor->PortCount));

  433. 

  434.         uint32_t aIns, aOuts, mIns, params, j;

  435.         aIns = aOuts = mIns = params = 0;

  436. 

  437.         bool forcedStereoIn, forcedStereoOut;

  438.         forcedStereoIn = forcedStereoOut = false;

  439. 

  440.         bool needsCtrlIn, needsCtrlOut;

  441.         needsCtrlIn = needsCtrlOut = false;

  442. 

  443.         if (portCount > 0)

  444.         {

  445.             CARLA_ASSERT(fDescriptor->PortDescriptors != nullptr);

  446.             CARLA_ASSERT(fDescriptor->PortRangeHints != nullptr);

  447.             CARLA_ASSERT(fDescriptor->PortNames != nullptr);

  448. 

  449.             for (uint32_t i=0; i < portCount; ++i)

  450.             {

  451.                 const LADSPA_PortDescriptor portType = fDescriptor->PortDescriptors[i];

  452. 

  453.                 if (LADSPA_IS_PORT_AUDIO(portType))

  454.                 {

  455.                     if (LADSPA_IS_PORT_INPUT(portType))

  456.                         aIns += 1;

  457.                     else if (LADSPA_IS_PORT_OUTPUT(portType))

  458.                         aOuts += 1;

  459.                 }

  460.                 else if (LADSPA_IS_PORT_CONTROL(portType))

  461.                     params += 1;

  462.             }

  463.         }

  464. 

  465.         if ((fOptions & PLUGIN_OPTION_FORCE_STEREO) != 0 && (aIns == 1 || aOuts == 1))

  466.         {

  467.             if (fHandle2 == nullptr)

  468.                 fHandle2 = fDescriptor->instantiate(fDescriptor, (unsigned long)sampleRate);

  469. 

  470.             if (fHandle2 != nullptr)

  471.             {

  472.                 if (aIns == 1)

  473.                 {

  474.                     aIns = 2;

  475.                     forcedStereoIn = true;

  476.                 }

  477. 

  478.                 if (aOuts == 1)

  479.                 {

  480.                     aOuts = 2;

  481.                     forcedStereoOut = true;

  482.                 }

  483.             }

  484.         }

  485. 

  486.         if (fDssiDescriptor->run_synth != nullptr || fDssiDescriptor->run_multiple_synths != nullptr)

  487.         {

  488.             mIns = 1;

  489.             needsCtrlIn = true;

  490.         }

  491. 

  492.         if (aIns > 0)

  493.         {

  494.             kData->audioIn.createNew(aIns);

  495.             fAudioInBuffers = new float*[aIns];

  496. 

  497.             for (uint32_t i=0; i < aIns; ++i)

  498.                 fAudioInBuffers[i] = nullptr;

  499.         }

  500. 

  501.         if (aOuts > 0)

  502.         {

  503.             kData->audioOut.createNew(aOuts);

  504.             fAudioOutBuffers = new float*[aOuts];

  505.             needsCtrlIn = true;

  506. 

  507.             for (uint32_t i=0; i < aOuts; ++i)

  508.                 fAudioOutBuffers[i] = nullptr;

  509.         }

  510. 

  511.         if (params > 0)

  512.         {

  513.             kData->param.createNew(params);

  514.             fParamBuffers = new float[params];

  515. 

  516.             for (uint32_t i=0; i < params; ++i)

  517.                 fParamBuffers[i] = 0.0f;

  518.         }

  519. 

  520.         const uint portNameSize(kData->engine->maxPortNameSize());

  521.         CarlaString portName;

  522. 

  523.         for (uint32_t i=0, iAudioIn=0, iAudioOut=0, iCtrl=0; i < portCount; ++i)

  524.         {

  525.             const LADSPA_PortDescriptor portType      = fDescriptor->PortDescriptors[i];

  526.             const LADSPA_PortRangeHint portRangeHints = fDescriptor->PortRangeHints[i];

  527. 

  528.             CARLA_ASSERT(fDescriptor->PortNames[i] != nullptr);

  529. 

  530.             if (LADSPA_IS_PORT_AUDIO(portType))

  531.             {

  532.                 portName.clear();

  533. 

  534.                 if (processMode == PROCESS_MODE_SINGLE_CLIENT)

  535.                 {

  536.                     portName  = fName;

  537.                     portName += ":";

  538.                 }

  539. 

  540.                 portName += fDescriptor->PortNames[i];

  541.                 portName.truncate(portNameSize);

  542. 

  543.                 if (LADSPA_IS_PORT_INPUT(portType))

  544.                 {

  545.                     j = iAudioIn++;

  546.                     kData->audioIn.ports[j].port   = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, true);

  547.                     kData->audioIn.ports[j].rindex = i;

  548. 

  549.                     if (forcedStereoIn)

  550.                     {

  551.                         portName += "_2";

  552.                         kData->audioIn.ports[1].port   = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, true);

  553.                         kData->audioIn.ports[1].rindex = i;

  554.                     }

  555.                 }

  556.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  557.                 {

  558.                     j = iAudioOut++;

  559.                     kData->audioOut.ports[j].port   = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, false);

  560.                     kData->audioOut.ports[j].rindex = i;

  561. 

  562.                     if (forcedStereoOut)

  563.                     {

  564.                         portName += "_2";

  565.                         kData->audioOut.ports[1].port   = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, false);

  566.                         kData->audioOut.ports[1].rindex = i;

  567.                     }

  568.                 }

  569.                 else

  570.                     carla_stderr2("WARNING - Got a broken Port (Audio, but not input or output)");

  571.             }

  572.             else if (LADSPA_IS_PORT_CONTROL(portType))

  573.             {

  574.                 j = iCtrl++;

  575.                 kData->param.data[j].index  = j;

  576.                 kData->param.data[j].rindex = i;

  577.                 kData->param.data[j].hints  = 0x0;

  578.                 kData->param.data[j].midiChannel = 0;

  579.                 kData->param.data[j].midiCC = -1;

  580. 

  581.                 float min, max, def, step, stepSmall, stepLarge;

  582. 

  583.                 // min value

  584.                 if (LADSPA_IS_HINT_BOUNDED_BELOW(portRangeHints.HintDescriptor))

  585.                     min = portRangeHints.LowerBound;

  586.                 else

  587.                     min = 0.0f;

  588. 

  589.                 // max value

  590.                 if (LADSPA_IS_HINT_BOUNDED_ABOVE(portRangeHints.HintDescriptor))

  591.                     max = portRangeHints.UpperBound;

  592.                 else

  593.                     max = 1.0f;

  594. 

  595.                 if (min > max)

  596.                     max = min;

  597.                 else if (max < min)

  598.                     min = max;

  599. 

  600.                 if (max - min == 0.0f)

  601.                 {

  602.                     carla_stderr2("WARNING - Broken plugin parameter '%s': max - min == 0.0f", fDescriptor->PortNames[i]);

  603.                     max = min + 0.1f;

  604.                 }

  605. 

  606.                 // default value

  607.                 def = get_default_ladspa_port_value(portRangeHints.HintDescriptor, min, max);

  608. 

  609.                 if (def < min)

  610.                     def = min;

  611.                 else if (def > max)

  612.                     def = max;

  613. 

  614.                 if (LADSPA_IS_HINT_SAMPLE_RATE(portRangeHints.HintDescriptor))

  615.                 {

  616.                     min *= sampleRate;

  617.                     max *= sampleRate;

  618.                     def *= sampleRate;

  619.                     kData->param.data[j].hints |= PARAMETER_USES_SAMPLERATE;

  620.                 }

  621. 

  622.                 if (LADSPA_IS_HINT_TOGGLED(portRangeHints.HintDescriptor))

  623.                 {

  624.                     step = max - min;

  625.                     stepSmall = step;

  626.                     stepLarge = step;

  627.                     kData->param.data[j].hints |= PARAMETER_IS_BOOLEAN;

  628.                 }

  629.                 else if (LADSPA_IS_HINT_INTEGER(portRangeHints.HintDescriptor))

  630.                 {

  631.                     step = 1.0f;

  632.                     stepSmall = 1.0f;

  633.                     stepLarge = 10.0f;

  634.                     kData->param.data[j].hints |= PARAMETER_IS_INTEGER;

  635.                 }

  636.                 else

  637.                 {

  638.                     float range = max - min;

  639.                     step = range/100.0f;

  640.                     stepSmall = range/1000.0f;

  641.                     stepLarge = range/10.0f;

  642.                 }

  643. 

  644.                 if (LADSPA_IS_PORT_INPUT(portType))

  645.                 {

  646.                     kData->param.data[j].type   = PARAMETER_INPUT;

  647.                     kData->param.data[j].hints |= PARAMETER_IS_ENABLED;

  648.                     kData->param.data[j].hints |= PARAMETER_IS_AUTOMABLE;

  649.                     needsCtrlIn = true;

  650. 

  651.                     // MIDI CC value

  652.                     if (fDssiDescriptor->get_midi_controller_for_port != nullptr)

  653.                     {

  654.                         int controller = fDssiDescriptor->get_midi_controller_for_port(fHandle, i);

  655.                         if (DSSI_CONTROLLER_IS_SET(controller) && DSSI_IS_CC(controller))

  656.                         {

  657.                             int16_t cc = DSSI_CC_NUMBER(controller);

  658.                             if (! MIDI_IS_CONTROL_BANK_SELECT(cc))

  659.                                 kData->param.data[j].midiCC = cc;

  660.                         }

  661.                     }

  662.                 }

  663.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  664.                 {

  665.                     if (std::strcmp(fDescriptor->PortNames[i], "latency") == 0 || std::strcmp(fDescriptor->PortNames[i], "_latency") == 0)

  666.                     {

  667.                         min = 0.0f;

  668.                         max = sampleRate;

  669.                         def = 0.0f;

  670.                         step = 1.0f;

  671.                         stepSmall = 1.0f;

  672.                         stepLarge = 1.0f;

  673. 

  674.                         kData->param.data[j].type  = PARAMETER_LATENCY;

  675.                         kData->param.data[j].hints = 0;

  676.                     }

  677.                     else if (std::strcmp(fDescriptor->PortNames[i], "_sample-rate") == 0)

  678.                     {

  679.                         def = sampleRate;

  680.                         step = 1.0f;

  681.                         stepSmall = 1.0f;

  682.                         stepLarge = 1.0f;

  683. 

  684.                         kData->param.data[j].type  = PARAMETER_SAMPLE_RATE;

  685.                         kData->param.data[j].hints = 0;

  686.                     }

  687.                     else

  688.                     {

  689.                         kData->param.data[j].type   = PARAMETER_OUTPUT;

  690.                         kData->param.data[j].hints |= PARAMETER_IS_ENABLED;

  691.                         kData->param.data[j].hints |= PARAMETER_IS_AUTOMABLE;

  692.                         needsCtrlOut = true;

  693.                     }

  694.                 }

  695.                 else

  696.                 {

  697.                     kData->param.data[j].type = PARAMETER_UNKNOWN;

  698.                     carla_stderr2("WARNING - Got a broken Port (Control, but not input or output)");

  699.                 }

  700. 

  701.                 // extra parameter hints

  702.                 if (LADSPA_IS_HINT_LOGARITHMIC(portRangeHints.HintDescriptor))

  703.                     kData->param.data[j].hints |= PARAMETER_IS_LOGARITHMIC;

  704. 

  705.                 kData->param.ranges[j].min = min;

  706.                 kData->param.ranges[j].max = max;

  707.                 kData->param.ranges[j].def = def;

  708.                 kData->param.ranges[j].step = step;

  709.                 kData->param.ranges[j].stepSmall = stepSmall;

  710.                 kData->param.ranges[j].stepLarge = stepLarge;

  711. 

  712.                 // Start parameters in their default values

  713.                 fParamBuffers[j] = def;

  714. 

  715.                 fDescriptor->connect_port(fHandle, i, &fParamBuffers[j]);

  716. 

  717.                 if (fHandle2 != nullptr)

  718.                     fDescriptor->connect_port(fHandle2, i, &fParamBuffers[j]);

  719.             }

  720.             else

  721.             {

  722.                 // Not Audio or Control

  723.                 carla_stderr2("ERROR - Got a broken Port (neither Audio or Control)");

  724. 

  725.                 fDescriptor->connect_port(fHandle, i, nullptr);

  726. 

  727.                 if (fHandle2 != nullptr)

  728.                     fDescriptor->connect_port(fHandle2, i, nullptr);

  729.             }

  730.         }

  731. 

  732.         if (needsCtrlIn)

  733.         {

  734.             portName.clear();

  735. 

  736.             if (processMode == PROCESS_MODE_SINGLE_CLIENT)

  737.             {

  738.                 portName  = fName;

  739.                 portName += ":";

  740.             }

  741. 

  742.             portName += "events-in";

  743.             portName.truncate(portNameSize);

  744. 

  745.             kData->event.portIn = (CarlaEngineEventPort*)kData->client->addPort(kEnginePortTypeEvent, portName, true);

  746.         }

  747. 

  748.         if (needsCtrlOut)

  749.         {

  750.             portName.clear();

  751. 

  752.             if (processMode == PROCESS_MODE_SINGLE_CLIENT)

  753.             {

  754.                 portName  = fName;

  755.                 portName += ":";

  756.             }

  757. 

  758.             portName += "events-out";

  759.             portName.truncate(portNameSize);

  760. 

  761.             kData->event.portOut = (CarlaEngineEventPort*)kData->client->addPort(kEnginePortTypeEvent, portName, false);

  762.         }

  763. 

  764.         if (forcedStereoIn || forcedStereoOut)

  765.             fOptions |= PLUGIN_OPTION_FORCE_STEREO;

  766.         else

  767.             fOptions &= ~PLUGIN_OPTION_FORCE_STEREO;

  768. 

  769.         // plugin hints

  770.         fHints = 0x0;

  771. 

  772.         if (LADSPA_IS_HARD_RT_CAPABLE(fDescriptor->Properties))

  773.             fHints |= PLUGIN_IS_RTSAFE;

  774. 

  775.         if (fGuiFilename.isNotEmpty())

  776.             fHints |= PLUGIN_HAS_GUI;

  777. 

  778.         if (mIns == 1 && aIns == 0 && aOuts > 0)

  779.             fHints |= PLUGIN_IS_SYNTH;

  780. 

  781.         if (aOuts > 0 && (aIns == aOuts || aIns == 1))

  782.             fHints |= PLUGIN_CAN_DRYWET;

  783. 

  784.         if (aOuts > 0)

  785.             fHints |= PLUGIN_CAN_VOLUME;

  786. 

  787.         if (aOuts >= 2 && aOuts % 2 == 0)

  788.             fHints |= PLUGIN_CAN_BALANCE;

  789. 

  790.         // extra plugin hints

  791.         kData->extraHints = 0x0;

  792. 

  793.         if (mIns > 0)

  794.             kData->extraHints |= PLUGIN_HINT_HAS_MIDI_IN;

  795. 

  796.         if (aIns <= 2 && aOuts <= 2 && (aIns == aOuts || aIns == 0 || aOuts == 0))

  797.             kData->extraHints |= PLUGIN_HINT_CAN_RUN_RACK;

  798. 

  799.         // check latency

  800.         if (fHints & PLUGIN_CAN_DRYWET)

  801.         {

  802.             for (uint32_t i=0; i < kData->param.count; ++i)

  803.             {

  804.                 if (kData->param.data[i].type != PARAMETER_LATENCY)

  805.                     continue;

  806. 

  807.                 // we need to pre-run the plugin so it can update its latency control-port

  808. 

  809.                 float tmpIn[aIns][2];

  810.                 float tmpOut[aOuts][2];

  811. 

  812.                 for (j=0; j < aIns; ++j)

  813.                 {

  814.                     tmpIn[j][0] = 0.0f;

  815.                     tmpIn[j][1] = 0.0f;

  816. 

  817.                     fDescriptor->connect_port(fHandle, kData->audioIn.ports[j].rindex, tmpIn[j]);

  818.                 }

  819. 

  820.                 for (j=0; j < aOuts; ++j)

  821.                 {

  822.                     tmpOut[j][0] = 0.0f;

  823.                     tmpOut[j][1] = 0.0f;

  824. 

  825.                     fDescriptor->connect_port(fHandle, kData->audioOut.ports[j].rindex, tmpOut[j]);

  826.                 }

  827. 

  828.                 if (fDescriptor->activate != nullptr)

  829.                     fDescriptor->activate(fHandle);

  830. 

  831.                 fDescriptor->run(fHandle, 2);

  832. 

  833.                 if (fDescriptor->deactivate != nullptr)

  834.                     fDescriptor->deactivate(fHandle);

  835. 

  836.                 const uint32_t latency = (uint32_t)fParamBuffers[i];

  837. 

  838.                 if (kData->latency != latency)

  839.                 {

  840.                     kData->latency = latency;

  841.                     kData->client->setLatency(latency);

  842.                     kData->recreateLatencyBuffers();

  843.                 }

  844. 

  845.                 break;

  846.             }

  847.         }

  848. 

  849.         bufferSizeChanged(kData->engine->getBufferSize());

  850.         reloadPrograms(true);

  851. 

  852.         if (kData->active)

  853.             activate();

  854. 

  855.         carla_debug("DssiPlugin::reload() - end");

  856.     }

  857. 

  858.     void reloadPrograms(const bool init) override

  859.     {

  860.         carla_debug("DssiPlugin::reloadPrograms(%s)", bool2str(init));

  861.         uint32_t i, oldCount  = kData->midiprog.count;

  862.         const int32_t current = kData->midiprog.current;

  863. 

  864.         // Delete old programs

  865.         kData->midiprog.clear();

  866. 

  867.         // Query new programs

  868.         uint32_t count = 0;

  869.         if (fDssiDescriptor->get_program != nullptr && fDssiDescriptor->select_program != nullptr)

  870.         {

  871.             while (fDssiDescriptor->get_program(fHandle, count))

  872.                 count++;

  873.         }

  874. 

  875.         if (count > 0)

  876.         {

  877.             kData->midiprog.createNew(count);

  878. 

  879.             // Update data

  880.             for (i=0; i < count; ++i)

  881.             {

  882.                 const DSSI_Program_Descriptor* const pdesc(fDssiDescriptor->get_program(fHandle, i));

  883.                 CARLA_ASSERT(pdesc != nullptr);

  884.                 CARLA_ASSERT(pdesc->Name != nullptr);

  885. 

  886.                 kData->midiprog.data[i].bank    = static_cast<uint32_t>(pdesc->Bank);

  887.                 kData->midiprog.data[i].program = static_cast<uint32_t>(pdesc->Program);

  888.                 kData->midiprog.data[i].name    = carla_strdup(pdesc->Name);

  889.             }

  890.         }

  891. 

  892. #ifndef BUILD_BRIDGE

  893.         // Update OSC Names

  894.         if (kData->engine->isOscControlRegistered())

  895.         {

  896.             kData->engine->osc_send_control_set_midi_program_count(fId, count);

  897. 

  898.             for (i=0; i < count; ++i)

  899.                 kData->engine->osc_send_control_set_midi_program_data(fId, i, kData->midiprog.data[i].bank, kData->midiprog.data[i].program, kData->midiprog.data[i].name);

  900.         }

  901. #endif

  902. 

  903.         if (init)

  904.         {

  905.             if (count > 0)

  906.                 setMidiProgram(0, false, false, false);

  907.         }

  908.         else

  909.         {

  910.             // Check if current program is invalid

  911.             bool programChanged = false;

  912. 

  913.             if (count == oldCount+1)

  914.             {

  915.                 // one midi program added, probably created by user

  916.                 kData->midiprog.current = oldCount;

  917.                 programChanged = true;

  918.             }

  919.             else if (current < 0 && count > 0)

  920.             {

  921.                 // programs exist now, but not before

  922.                 kData->midiprog.current = 0;

  923.                 programChanged = true;

  924.             }

  925.             else if (current >= 0 && count == 0)

  926.             {

  927.                 // programs existed before, but not anymore

  928.                 kData->midiprog.current = -1;

  929.                 programChanged = true;

  930.             }

  931.             else if (current >= static_cast<int32_t>(count))

  932.             {

  933.                 // current midi program > count

  934.                 kData->midiprog.current = 0;

  935.                 programChanged = true;

  936.             }

  937.             else

  938.             {

  939.                 // no change

  940.                 kData->midiprog.current = current;

  941.             }

  942. 

  943.             if (programChanged)

  944.                 setMidiProgram(kData->midiprog.current, true, true, true);

  945. 

  946.             kData->engine->callback(CALLBACK_RELOAD_PROGRAMS, fId, 0, 0, 0.0f, nullptr);

  947.         }

  948.     }

  949. 

  950.     // -------------------------------------------------------------------

  951.     // Plugin processing

  952. 

  953.     void activate() override

  954.     {

  955.         CARLA_ASSERT(fDescriptor != nullptr);

  956.         CARLA_ASSERT(fHandle != nullptr);

  957. 

  958.         if (fDescriptor->activate != nullptr)

  959.         {

  960.             fDescriptor->activate(fHandle);

  961. 

  962.             if (fHandle2 != nullptr)

  963.                 fDescriptor->activate(fHandle2);

  964.         }

  965.     }

  966. 

  967.     void deactivate() override

  968.     {

  969.         CARLA_ASSERT(fDescriptor != nullptr);

  970.         CARLA_ASSERT(fHandle != nullptr);

  971. 

  972.         if (fDescriptor->deactivate != nullptr)

  973.         {

  974.             fDescriptor->deactivate(fHandle);

  975. 

  976.             if (fHandle2 != nullptr)

  977.                 fDescriptor->deactivate(fHandle2);

  978.         }

  979.     }

  980. 

  981.     void process(float** const inBuffer, float** const outBuffer, const uint32_t frames) override

  982.     {

  983.         uint32_t i, k;

  984. 

  985.         // --------------------------------------------------------------------------------------------------------

  986.         // Check if active

  987. 

  988.         if (! kData->active)

  989.         {

  990.             // disable any output sound

  991.             for (i=0; i < kData->audioOut.count; ++i)

  992.                 carla_zeroFloat(outBuffer[i], frames);

  993. 

  994.             return;

  995.         }

  996. 

  997.         unsigned long midiEventCount = 0;

  998. 

  999.         // --------------------------------------------------------------------------------------------------------

  1000.         // Check if needs reset

  1001. 

  1002.         if (kData->needsReset)

  1003.         {

  1004.             if (fOptions & PLUGIN_OPTION_SEND_ALL_SOUND_OFF)

  1005.             {

  1006.                 for (unsigned char j=0, l=MAX_MIDI_CHANNELS; j < MAX_MIDI_CHANNELS; ++j)

  1007.                 {

  1008.                     carla_zeroStruct<snd_seq_event_t>(fMidiEvents[j]);

  1009.                     carla_zeroStruct<snd_seq_event_t>(fMidiEvents[j+l]);

  1010. 

  1011.                     fMidiEvents[j].type = SND_SEQ_EVENT_CONTROLLER;

  1012.                     fMidiEvents[j].data.control.channel = j;

  1013.                     fMidiEvents[j].data.control.param   = MIDI_CONTROL_ALL_NOTES_OFF;

  1014. 

  1015.                     fMidiEvents[j+l].type = SND_SEQ_EVENT_CONTROLLER;

  1016.                     fMidiEvents[j+l].data.control.channel = j;

  1017.                     fMidiEvents[j+l].data.control.param   = MIDI_CONTROL_ALL_SOUND_OFF;

  1018.                 }

  1019. 

  1020.                 midiEventCount = MAX_MIDI_CHANNELS*2;

  1021.             }

  1022.             else if (kData->ctrlChannel >= 0 && kData->ctrlChannel < MAX_MIDI_CHANNELS)

  1023.             {

  1024.                 for (unsigned char j=0; j < MAX_MIDI_NOTE; ++j)

  1025.                 {

  1026.                     carla_zeroStruct<snd_seq_event_t>(fMidiEvents[j]);

  1027. 

  1028.                     fMidiEvents[j].type = SND_SEQ_EVENT_NOTEOFF;

  1029.                     fMidiEvents[j].data.note.channel = kData->ctrlChannel;

  1030.                     fMidiEvents[j].data.note.note    = j;

  1031.                 }

  1032. 

  1033.                 midiEventCount = MAX_MIDI_NOTE;

  1034.             }

  1035. 

  1036.             if (kData->latency > 0)

  1037.             {

  1038.                 for (i=0; i < kData->audioIn.count; ++i)

  1039.                     carla_zeroFloat(kData->latencyBuffers[i], kData->latency);

  1040.             }

  1041. 

  1042.             kData->needsReset = false;

  1043.         }

  1044. 

  1045.         // --------------------------------------------------------------------------------------------------------

  1046.         // Event Input and Processing

  1047. 

  1048.         if (kData->event.portIn != nullptr)

  1049.         {

  1050.             // ----------------------------------------------------------------------------------------------------

  1051.             // MIDI Input (External)

  1052. 

  1053.             if (kData->extNotes.mutex.tryLock())

  1054.             {

  1055.                 while (midiEventCount < MAX_MIDI_EVENTS && ! kData->extNotes.data.isEmpty())

  1056.                 {

  1057.                     const ExternalMidiNote& note(kData->extNotes.data.getFirst(true));

  1058. 

  1059.                     CARLA_ASSERT(note.channel >= 0 && note.channel < MAX_MIDI_CHANNELS);

  1060. 

  1061.                     fMidiEvents[midiEventCount].type               = (note.velo > 0) ? SND_SEQ_EVENT_NOTEON : SND_SEQ_EVENT_NOTEOFF;

  1062.                     fMidiEvents[midiEventCount].data.note.channel  = note.channel;

  1063.                     fMidiEvents[midiEventCount].data.note.note     = note.note;

  1064.                     fMidiEvents[midiEventCount].data.note.velocity = note.velo;

  1065. 

  1066.                     midiEventCount += 1;

  1067.                 }

  1068. 

  1069.                 kData->extNotes.mutex.unlock();

  1070. 

  1071.             } // End of MIDI Input (External)

  1072. 

  1073.             // ----------------------------------------------------------------------------------------------------

  1074.             // Event Input (System)

  1075. 

  1076.             bool allNotesOffSent = false;

  1077.             bool sampleAccurate  = (fOptions & PLUGIN_OPTION_FIXED_BUFFER) == 0;

  1078. 

  1079.             uint32_t time, nEvents = kData->event.portIn->getEventCount();

  1080.             uint32_t startTime  = 0;

  1081.             uint32_t timeOffset = 0;

  1082.             uint32_t nextBankId = 0;

  1083. 

  1084.             if (kData->midiprog.current >= 0 && kData->midiprog.count > 0)

  1085.                 nextBankId = kData->midiprog.data[kData->midiprog.current].bank;

  1086. 

  1087.             for (i=0; i < nEvents; ++i)

  1088.             {

  1089.                 const EngineEvent& event(kData->event.portIn->getEvent(i));

  1090. 

  1091.                 time = event.time;

  1092. 

  1093.                 if (time >= frames)

  1094.                     continue;

  1095. 

  1096.                 CARLA_ASSERT_INT2(time >= timeOffset, time, timeOffset);

  1097. 

  1098.                 if (time > timeOffset && sampleAccurate)

  1099.                 {

  1100.                     if (processSingle(inBuffer, outBuffer, time - timeOffset, timeOffset, midiEventCount))

  1101.                     {

  1102.                         startTime  = 0;

  1103.                         timeOffset = time;

  1104.                         midiEventCount = 0;

  1105. 

  1106.                         if (kData->midiprog.current >= 0 && kData->midiprog.count > 0)

  1107.                             nextBankId = kData->midiprog.data[kData->midiprog.current].bank;

  1108.                         else

  1109.                             nextBankId = 0;

  1110.                     }

  1111.                     else

  1112.                         startTime += timeOffset;

  1113.                 }

  1114. 

  1115.                 // Control change

  1116.                 switch (event.type)

  1117.                 {

  1118.                 case kEngineEventTypeNull:

  1119.                     break;

  1120. 

  1121.                 case kEngineEventTypeControl:

  1122.                 {

  1123.                     const EngineControlEvent& ctrlEvent = event.ctrl;

  1124. 

  1125.                     switch (ctrlEvent.type)

  1126.                     {

  1127.                     case kEngineControlEventTypeNull:

  1128.                         break;

  1129. 

  1130.                     case kEngineControlEventTypeParameter:

  1131.                     {

  1132. #ifndef BUILD_BRIDGE

  1133.                         // Control backend stuff

  1134.                         if (event.channel == kData->ctrlChannel)

  1135.                         {

  1136.                             float value;

  1137. 

  1138.                             if (MIDI_IS_CONTROL_BREATH_CONTROLLER(ctrlEvent.param) && (fHints & PLUGIN_CAN_DRYWET) > 0)

  1139.                             {

  1140.                                 value = ctrlEvent.value;

  1141.                                 setDryWet(value, false, false);

  1142.                                 postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_DRYWET, 0, value);

  1143.                             }

  1144. 

  1145.                             if (MIDI_IS_CONTROL_CHANNEL_VOLUME(ctrlEvent.param) && (fHints & PLUGIN_CAN_VOLUME) > 0)

  1146.                             {

  1147.                                 value = ctrlEvent.value*127.0f/100.0f;

  1148.                                 setVolume(value, false, false);

  1149.                                 postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_VOLUME, 0, value);

  1150.                             }

  1151. 

  1152.                             if (MIDI_IS_CONTROL_BALANCE(ctrlEvent.param) && (fHints & PLUGIN_CAN_BALANCE) > 0)

  1153.                             {

  1154.                                 float left, right;

  1155.                                 value = ctrlEvent.value/0.5f - 1.0f;

  1156. 

  1157.                                 if (value < 0.0f)

  1158.                                 {

  1159.                                     left  = -1.0f;

  1160.                                     right = (value*2.0f)+1.0f;

  1161.                                 }

  1162.                                 else if (value > 0.0f)

  1163.                                 {

  1164.                                     left  = (value*2.0f)-1.0f;

  1165.                                     right = 1.0f;

  1166.                                 }

  1167.                                 else

  1168.                                 {

  1169.                                     left  = -1.0f;

  1170.                                     right = 1.0f;

  1171.                                 }

  1172. 

  1173.                                 setBalanceLeft(left, false, false);

  1174.                                 setBalanceRight(right, false, false);

  1175.                                 postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_BALANCE_LEFT, 0, left);

  1176.                                 postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_BALANCE_RIGHT, 0, right);

  1177.                             }

  1178.                         }

  1179. #endif

  1180. 

  1181.                         // Control plugin parameters

  1182.                         for (k=0; k < kData->param.count; ++k)

  1183.                         {

  1184.                             if (kData->param.data[k].midiChannel != event.channel)

  1185.                                 continue;

  1186.                             if (kData->param.data[k].midiCC != ctrlEvent.param)

  1187.                                 continue;

  1188.                             if (kData->param.data[k].type != PARAMETER_INPUT)

  1189.                                 continue;

  1190.                             if ((kData->param.data[k].hints & PARAMETER_IS_AUTOMABLE) == 0)

  1191.                                 continue;

  1192. 

  1193.                             float value;

  1194. 

  1195.                             if (kData->param.data[k].hints & PARAMETER_IS_BOOLEAN)

  1196.                             {

  1197.                                 value = (ctrlEvent.value < 0.5f) ? kData->param.ranges[k].min : kData->param.ranges[k].max;

  1198.                             }

  1199.                             else

  1200.                             {

  1201.                                 value = kData->param.ranges[k].unnormalizeValue(ctrlEvent.value);

  1202. 

  1203.                                 if (kData->param.data[k].hints & PARAMETER_IS_INTEGER)

  1204.                                     value = std::rint(value);

  1205.                             }

  1206. 

  1207.                             setParameterValue(k, value, false, false, false);

  1208.                             postponeRtEvent(kPluginPostRtEventParameterChange, static_cast<int32_t>(k), 0, value);

  1209.                         }

  1210. 

  1211.                         if ((fOptions & PLUGIN_OPTION_SEND_CONTROL_CHANGES) != 0 && ctrlEvent.param <= 0x5F)

  1212.                         {

  1213.                             if (midiEventCount >= MAX_MIDI_EVENTS)

  1214.                                 continue;

  1215. 

  1216.                             carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);

  1217. 

  1218.                             fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;

  1219. 

  1220.                             fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;

  1221.                             fMidiEvents[midiEventCount].data.control.channel = event.channel;

  1222.                             fMidiEvents[midiEventCount].data.control.param   = ctrlEvent.param;

  1223.                             fMidiEvents[midiEventCount].data.control.value   = ctrlEvent.value*127.0f;

  1224. 

  1225.                             midiEventCount += 1;

  1226.                         }

  1227. 

  1228.                         break;

  1229.                     }

  1230. 

  1231.                     case kEngineControlEventTypeMidiBank:

  1232.                         if (event.channel == kData->ctrlChannel && (fOptions & PLUGIN_OPTION_MAP_PROGRAM_CHANGES) != 0)

  1233.                             nextBankId = ctrlEvent.param;

  1234.                         break;

  1235. 

  1236.                     case kEngineControlEventTypeMidiProgram:

  1237.                         if (event.channel == kData->ctrlChannel && (fOptions & PLUGIN_OPTION_MAP_PROGRAM_CHANGES) != 0)

  1238.                         {

  1239.                             const uint32_t nextProgramId = ctrlEvent.param;

  1240. 

  1241.                             for (k=0; k < kData->midiprog.count; ++k)

  1242.                             {

  1243.                                 if (kData->midiprog.data[k].bank == nextBankId && kData->midiprog.data[k].program == nextProgramId)

  1244.                                 {

  1245.                                     setMidiProgram(k, false, false, false);

  1246.                                     postponeRtEvent(kPluginPostRtEventMidiProgramChange, k, 0, 0.0f);

  1247.                                     break;

  1248.                                 }

  1249.                             }

  1250.                         }

  1251.                         break;

  1252. 

  1253.                     case kEngineControlEventTypeAllSoundOff:

  1254.                         if (fOptions & PLUGIN_OPTION_SEND_ALL_SOUND_OFF)

  1255.                         {

  1256.                             if (midiEventCount >= MAX_MIDI_EVENTS)

  1257.                                 continue;

  1258. 

  1259.                             carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);

  1260. 

  1261.                             fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;

  1262. 

  1263.                             fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;

  1264.                             fMidiEvents[midiEventCount].data.control.channel = event.channel;

  1265.                             fMidiEvents[midiEventCount].data.control.param   = MIDI_CONTROL_ALL_SOUND_OFF;

  1266. 

  1267.                             midiEventCount += 1;

  1268.                         }

  1269.                         break;

  1270. 

  1271.                     case kEngineControlEventTypeAllNotesOff:

  1272.                         if (fOptions & PLUGIN_OPTION_SEND_ALL_SOUND_OFF)

  1273.                         {

  1274.                             if (event.channel == kData->ctrlChannel && ! allNotesOffSent)

  1275.                             {

  1276.                                 allNotesOffSent = true;

  1277.                                 sendMidiAllNotesOffToCallback();

  1278.                             }

  1279. 

  1280.                             if (midiEventCount >= MAX_MIDI_EVENTS)

  1281.                                 continue;

  1282. 

  1283.                             carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);

  1284. 

  1285.                             fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;

  1286. 

  1287.                             fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;

  1288.                             fMidiEvents[midiEventCount].data.control.channel = event.channel;

  1289.                             fMidiEvents[midiEventCount].data.control.param   = MIDI_CONTROL_ALL_NOTES_OFF;

  1290. 

  1291.                             midiEventCount += 1;

  1292.                         }

  1293.                         break;

  1294.                     }

  1295. 

  1296.                     break;

  1297.                 }

  1298. 

  1299.                 case kEngineEventTypeMidi:

  1300.                 {

  1301.                     if (midiEventCount >= MAX_MIDI_EVENTS)

  1302.                         continue;

  1303. 

  1304.                     const EngineMidiEvent& midiEvent(event.midi);

  1305. 

  1306.                     uint8_t status  = MIDI_GET_STATUS_FROM_DATA(midiEvent.data);

  1307.                     uint8_t channel = event.channel;

  1308. 

  1309.                     // Fix bad note-off (per DSSI spec)

  1310.                     if (MIDI_IS_STATUS_NOTE_ON(status) && midiEvent.data[2] == 0)

  1311.                         status -= 0x10;

  1312. 

  1313.                     carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);

  1314. 

  1315.                     fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;

  1316. 

  1317.                     if (MIDI_IS_STATUS_NOTE_OFF(status))

  1318.                     {

  1319.                         const uint8_t note = midiEvent.data[1];

  1320. 

  1321.                         fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_NOTEOFF;

  1322.                         fMidiEvents[midiEventCount].data.note.channel = channel;

  1323.                         fMidiEvents[midiEventCount].data.note.note    = note;

  1324. 

  1325.                         postponeRtEvent(kPluginPostRtEventNoteOff, channel, note, 0.0f);

  1326.                     }

  1327.                     else if (MIDI_IS_STATUS_NOTE_ON(status))

  1328.                     {

  1329.                         const uint8_t note = midiEvent.data[1];

  1330.                         const uint8_t velo = midiEvent.data[2];

  1331. 

  1332.                         fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_NOTEON;

  1333.                         fMidiEvents[midiEventCount].data.note.channel  = channel;

  1334.                         fMidiEvents[midiEventCount].data.note.note     = note;

  1335.                         fMidiEvents[midiEventCount].data.note.velocity = velo;

  1336. 

  1337.                         postponeRtEvent(kPluginPostRtEventNoteOn, channel, note, velo);

  1338.                     }

  1339.                     else if (MIDI_IS_STATUS_POLYPHONIC_AFTERTOUCH(status) && (fOptions & PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH) != 0)

  1340.                     {

  1341.                         const uint8_t note     = midiEvent.data[1];

  1342.                         const uint8_t pressure = midiEvent.data[2];

  1343. 

  1344.                         fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_KEYPRESS;

  1345.                         fMidiEvents[midiEventCount].data.note.channel  = channel;

  1346.                         fMidiEvents[midiEventCount].data.note.note     = note;

  1347.                         fMidiEvents[midiEventCount].data.note.velocity = pressure;

  1348.                     }

  1349.                     else if (MIDI_IS_STATUS_CONTROL_CHANGE(status) && (fOptions & PLUGIN_OPTION_SEND_CONTROL_CHANGES) != 0)

  1350.                     {

  1351.                         const uint8_t control = midiEvent.data[1];

  1352.                         const uint8_t value   = midiEvent.data[2];

  1353. 

  1354.                         fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;

  1355.                         fMidiEvents[midiEventCount].data.control.channel = channel;

  1356.                         fMidiEvents[midiEventCount].data.control.param   = control;

  1357.                         fMidiEvents[midiEventCount].data.control.value   = value;

  1358.                     }

  1359.                     else if (MIDI_IS_STATUS_AFTERTOUCH(status) && (fOptions & PLUGIN_OPTION_SEND_CHANNEL_PRESSURE) != 0)

  1360.                     {

  1361.                         const uint8_t pressure = midiEvent.data[1];

  1362. 

  1363.                         fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CHANPRESS;

  1364.                         fMidiEvents[midiEventCount].data.control.channel = channel;

  1365.                         fMidiEvents[midiEventCount].data.control.value   = pressure;

  1366.                     }

  1367.                     else if (MIDI_IS_STATUS_PITCH_WHEEL_CONTROL(status) && (fOptions & PLUGIN_OPTION_SEND_PITCHBEND) != 0)

  1368.                     {

  1369.                         const uint8_t lsb = midiEvent.data[1];

  1370.                         const uint8_t msb = midiEvent.data[2];

  1371. 

  1372.                         fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_PITCHBEND;

  1373.                         fMidiEvents[midiEventCount].data.control.channel = channel;

  1374.                         fMidiEvents[midiEventCount].data.control.value   = ((msb << 7) | lsb) - 8192;

  1375.                     }

  1376.                     else

  1377.                         continue;

  1378. 

  1379.                     midiEventCount += 1;

  1380. 

  1381.                     break;

  1382.                 }

  1383.                 }

  1384.             }

  1385. 

  1386.             kData->postRtEvents.trySplice();

  1387. 

  1388.             if (frames > timeOffset)

  1389.                 processSingle(inBuffer, outBuffer, frames - timeOffset, timeOffset, midiEventCount);

  1390. 

  1391.         } // End of Event Input and Processing

  1392. 

  1393.         // --------------------------------------------------------------------------------------------------------

  1394.         // Plugin processing (no events)

  1395. 

  1396.         else

  1397.         {

  1398.             processSingle(inBuffer, outBuffer, frames, 0, midiEventCount);

  1399. 

  1400.         } // End of Plugin processing (no events)

  1401. 

  1402.         CARLA_PROCESS_CONTINUE_CHECK;

  1403. 

  1404.         // --------------------------------------------------------------------------------------------------------

  1405.         // Control Output

  1406. 

  1407.         if (kData->event.portOut != nullptr)

  1408.         {

  1409.             uint8_t  channel;

  1410.             uint16_t param;

  1411.             float    value;

  1412. 

  1413.             for (k=0; k < kData->param.count; ++k)

  1414.             {

  1415.                 if (kData->param.data[k].type != PARAMETER_OUTPUT)

  1416.                     continue;

  1417. 

  1418.                 kData->param.ranges[k].fixValue(fParamBuffers[k]);

  1419. 

  1420.                 if (kData->param.data[k].midiCC > 0)

  1421.                 {

  1422.                     channel = kData->param.data[k].midiChannel;

  1423.                     param   = static_cast<uint16_t>(kData->param.data[k].midiCC);

  1424.                     value   = kData->param.ranges[k].normalizeValue(fParamBuffers[k]);

  1425.                     kData->event.portOut->writeControlEvent(0, channel, kEngineControlEventTypeParameter, param, value);

  1426.                 }

  1427.             }

  1428. 

  1429.         } // End of Control Output

  1430.     }

  1431. 

  1432.     bool processSingle(float** const inBuffer, float** const outBuffer, const uint32_t frames, const uint32_t timeOffset, const unsigned long midiEventCount)

  1433.     {

  1434.         CARLA_ASSERT(frames > 0);

  1435. 

  1436.         if (frames == 0)

  1437.             return false;

  1438. 

  1439.         if (kData->audioIn.count > 0)

  1440.         {

  1441.             CARLA_ASSERT(inBuffer != nullptr);

  1442.             if (inBuffer == nullptr)

  1443.                 return false;

  1444.         }

  1445.         if (kData->audioOut.count > 0)

  1446.         {

  1447.             CARLA_ASSERT(outBuffer != nullptr);

  1448.             if (outBuffer == nullptr)

  1449.                 return false;

  1450.         }

  1451. 

  1452.         uint32_t i, k;

  1453. 

  1454.         // --------------------------------------------------------------------------------------------------------

  1455.         // Try lock, silence otherwise

  1456. 

  1457.         if (kData->engine->isOffline())

  1458.         {

  1459.             kData->singleMutex.lock();

  1460.         }

  1461.         else if (! kData->singleMutex.tryLock())

  1462.         {

  1463.             for (i=0; i < kData->audioOut.count; ++i)

  1464.             {

  1465.                 for (k=0; k < frames; ++k)

  1466.                     outBuffer[i][k+timeOffset] = 0.0f;

  1467.             }

  1468. 

  1469.             return false;

  1470.         }

  1471. 

  1472.         // --------------------------------------------------------------------------------------------------------

  1473.         // Reset audio buffers

  1474. 

  1475.         for (i=0; i < kData->audioIn.count; ++i)

  1476.             carla_copyFloat(fAudioInBuffers[i], inBuffer[i]+timeOffset, frames);

  1477.         for (i=0; i < kData->audioOut.count; ++i)

  1478.             carla_zeroFloat(fAudioOutBuffers[i], frames);

  1479. 

  1480.         // --------------------------------------------------------------------------------------------------------

  1481.         // Run plugin

  1482. 

  1483.         if (fDssiDescriptor->run_synth != nullptr)

  1484.         {

  1485.             fDssiDescriptor->run_synth(fHandle, frames, fMidiEvents, midiEventCount);

  1486. 

  1487.             if (fHandle2 != nullptr)

  1488.                 fDssiDescriptor->run_synth(fHandle2, frames, fMidiEvents, midiEventCount);

  1489.         }

  1490.         else if (fDssiDescriptor->run_multiple_synths != nullptr)

  1491.         {

  1492.             unsigned long instances = (fHandle2 != nullptr) ? 2 : 1;

  1493.             LADSPA_Handle handlePtr[2] = { fHandle, fHandle2 };

  1494.             snd_seq_event_t* midiEventsPtr[2] = { fMidiEvents, fMidiEvents };

  1495.             unsigned long midiEventCountPtr[2] = { midiEventCount, midiEventCount };

  1496.             fDssiDescriptor->run_multiple_synths(instances, handlePtr, frames, midiEventsPtr, midiEventCountPtr);

  1497.         }

  1498.         else

  1499.         {

  1500.             fDescriptor->run(fHandle, frames);

  1501. 

  1502.             if (fHandle2 != nullptr)

  1503.                 fDescriptor->run(fHandle2, frames);

  1504.         }

  1505. 

  1506. #ifndef BUILD_BRIDGE

  1507.         // --------------------------------------------------------------------------------------------------------

  1508.         // Post-processing (dry/wet, volume and balance)

  1509. 

  1510.         {

  1511.             const bool doDryWet  = (fHints & PLUGIN_CAN_DRYWET) != 0 && kData->postProc.dryWet != 1.0f;

  1512.             const bool doBalance = (fHints & PLUGIN_CAN_BALANCE) != 0 && (kData->postProc.balanceLeft != -1.0f || kData->postProc.balanceRight != 1.0f);

  1513. 

  1514.             bool isPair;

  1515.             float bufValue, oldBufLeft[doBalance ? frames : 1];

  1516. 

  1517.             for (i=0; i < kData->audioOut.count; ++i)

  1518.             {

  1519.                 // Dry/Wet

  1520.                 if (doDryWet)

  1521.                 {

  1522.                     for (k=0; k < frames; ++k)

  1523.                     {

  1524.                         // TODO

  1525.                         //if (k < kData->latency && kData->latency < frames)

  1526.                         //    bufValue = (kData->audioIn.count == 1) ? kData->latencyBuffers[0][k] : kData->latencyBuffers[i][k];

  1527.                         //else

  1528.                         //    bufValue = (kData->audioIn.count == 1) ? inBuffer[0][k-m_latency] : inBuffer[i][k-m_latency];

  1529. 

  1530.                         bufValue = fAudioInBuffers[(kData->audioIn.count == 1) ? 0 : i][k];

  1531.                         fAudioOutBuffers[i][k] = (fAudioOutBuffers[i][k] * kData->postProc.dryWet) + (bufValue * (1.0f - kData->postProc.dryWet));

  1532.                     }

  1533.                 }

  1534. 

  1535.                 // Balance

  1536.                 if (doBalance)

  1537.                 {

  1538.                     isPair = (i % 2 == 0);

  1539. 

  1540.                     if (isPair)

  1541.                     {

  1542.                         CARLA_ASSERT(i+1 < kData->audioOut.count);

  1543.                         carla_copyFloat(oldBufLeft, fAudioOutBuffers[i], frames);

  1544.                     }

  1545. 

  1546.                     float balRangeL = (kData->postProc.balanceLeft  + 1.0f)/2.0f;

  1547.                     float balRangeR = (kData->postProc.balanceRight + 1.0f)/2.0f;

  1548. 

  1549.                     for (k=0; k < frames; ++k)

  1550.                     {

  1551.                         if (isPair)

  1552.                         {

  1553.                             // left

  1554.                             fAudioOutBuffers[i][k]  = oldBufLeft[k]            * (1.0f - balRangeL);

  1555.                             fAudioOutBuffers[i][k] += fAudioOutBuffers[i+1][k] * (1.0f - balRangeR);

  1556.                         }

  1557.                         else

  1558.                         {

  1559.                             // right

  1560.                             fAudioOutBuffers[i][k]  = fAudioOutBuffers[i][k] * balRangeR;

  1561.                             fAudioOutBuffers[i][k] += oldBufLeft[k]          * balRangeL;

  1562.                         }

  1563.                     }

  1564.                 }

  1565. 

  1566.                 // Volume (and buffer copy)

  1567.                 {

  1568.                     for (k=0; k < frames; ++k)

  1569.                         outBuffer[i][k+timeOffset] = fAudioOutBuffers[i][k] * kData->postProc.volume;

  1570.                 }

  1571.             }

  1572. 

  1573. #if 0

  1574.             // Latency, save values for next callback, TODO

  1575.             if (kData->latency > 0 && kData->latency < frames)

  1576.             {

  1577.                 for (i=0; i < kData->audioIn.count; ++i)

  1578.                     carla_copyFloat(kData->latencyBuffers[i], inBuffer[i] + (frames - kData->latency), kData->latency);

  1579.             }

  1580. #endif

  1581.         } // End of Post-processing

  1582. #else

  1583.         for (i=0; i < kData->audioOut.count; ++i)

  1584.         {

  1585.             for (k=0; k < frames; ++k)

  1586.                 outBuffer[i][k+timeOffset] = fAudioOutBuffers[i][k];

  1587.         }

  1588. #endif

  1589. 

  1590.         // --------------------------------------------------------------------------------------------------------

  1591. 

  1592.         kData->singleMutex.unlock();

  1593.         return true;

  1594.     }

  1595. 

  1596.     void bufferSizeChanged(const uint32_t newBufferSize) override

  1597.     {

  1598.         CARLA_ASSERT_INT(newBufferSize > 0, newBufferSize);

  1599.         carla_debug("DssiPlugin::bufferSizeChanged(%i) - start", newBufferSize);

  1600. 

  1601.         for (uint32_t i=0; i < kData->audioIn.count; ++i)

  1602.         {

  1603.             if (fAudioInBuffers[i] != nullptr)

  1604.                 delete[] fAudioInBuffers[i];

  1605.             fAudioInBuffers[i] = new float[newBufferSize];

  1606.         }

  1607. 

  1608.         for (uint32_t i=0; i < kData->audioOut.count; ++i)

  1609.         {

  1610.             if (fAudioOutBuffers[i] != nullptr)

  1611.                 delete[] fAudioOutBuffers[i];

  1612.             fAudioOutBuffers[i] = new float[newBufferSize];

  1613.         }

  1614. 

  1615.         if (fHandle2 == nullptr)

  1616.         {

  1617.             for (uint32_t i=0; i < kData->audioIn.count; ++i)

  1618.             {

  1619.                 CARLA_ASSERT(fAudioInBuffers[i] != nullptr);

  1620.                 fDescriptor->connect_port(fHandle, kData->audioIn.ports[i].rindex, fAudioInBuffers[i]);

  1621.             }

  1622. 

  1623.             for (uint32_t i=0; i < kData->audioOut.count; ++i)

  1624.             {

  1625.                 CARLA_ASSERT(fAudioOutBuffers[i] != nullptr);

  1626.                 fDescriptor->connect_port(fHandle, kData->audioOut.ports[i].rindex, fAudioOutBuffers[i]);

  1627.             }

  1628.         }

  1629.         else

  1630.         {

  1631.             if (kData->audioIn.count > 0)

  1632.             {

  1633.                 CARLA_ASSERT(kData->audioIn.count == 2);

  1634.                 CARLA_ASSERT(fAudioInBuffers[0] != nullptr);

  1635.                 CARLA_ASSERT(fAudioInBuffers[1] != nullptr);

  1636. 

  1637.                 fDescriptor->connect_port(fHandle,  kData->audioIn.ports[0].rindex, fAudioInBuffers[0]);

  1638.                 fDescriptor->connect_port(fHandle2, kData->audioIn.ports[1].rindex, fAudioInBuffers[1]);

  1639.             }

  1640. 

  1641.             if (kData->audioOut.count > 0)

  1642.             {

  1643.                 CARLA_ASSERT(kData->audioOut.count == 2);

  1644.                 CARLA_ASSERT(fAudioOutBuffers[0] != nullptr);

  1645.                 CARLA_ASSERT(fAudioOutBuffers[1] != nullptr);

  1646. 

  1647.                 fDescriptor->connect_port(fHandle,  kData->audioOut.ports[0].rindex, fAudioOutBuffers[0]);

  1648.                 fDescriptor->connect_port(fHandle2, kData->audioOut.ports[1].rindex, fAudioOutBuffers[1]);

  1649.             }

  1650.         }

  1651. 

  1652.         carla_debug("DssiPlugin::bufferSizeChanged(%i) - start", newBufferSize);

  1653.     }

  1654. 

  1655.     void sampleRateChanged(const double newSampleRate) override

  1656.     {

  1657.         CARLA_ASSERT_INT(newSampleRate > 0.0, newSampleRate);

  1658.         carla_debug("DssiPlugin::sampleRateChanged(%g) - start", newSampleRate);

  1659. 

  1660.         // TODO

  1661.         (void)newSampleRate;

  1662. 

  1663.         carla_debug("DssiPlugin::sampleRateChanged(%g) - end", newSampleRate);

  1664.     }

  1665. 

  1666.     // -------------------------------------------------------------------

  1667.     // Plugin buffers

  1668. 

  1669.     void clearBuffers() override

  1670.     {

  1671.         carla_debug("DssiPlugin::clearBuffers() - start");

  1672. 

  1673.         if (fAudioInBuffers != nullptr)

  1674.         {

  1675.             for (uint32_t i=0; i < kData->audioIn.count; ++i)

  1676.             {

  1677.                 if (fAudioInBuffers[i] != nullptr)

  1678.                 {

  1679.                     delete[] fAudioInBuffers[i];

  1680.                     fAudioInBuffers[i] = nullptr;

  1681.                 }

  1682.             }

  1683. 

  1684.             delete[] fAudioInBuffers;

  1685.             fAudioInBuffers = nullptr;

  1686.         }

  1687. 

  1688.         if (fAudioOutBuffers != nullptr)

  1689.         {

  1690.             for (uint32_t i=0; i < kData->audioOut.count; ++i)

  1691.             {

  1692.                 if (fAudioOutBuffers[i] != nullptr)

  1693.                 {

  1694.                     delete[] fAudioOutBuffers[i];

  1695.                     fAudioOutBuffers[i] = nullptr;

  1696.                 }

  1697.             }

  1698. 

  1699.             delete[] fAudioOutBuffers;

  1700.             fAudioOutBuffers = nullptr;

  1701.         }

  1702. 

  1703.         if (fParamBuffers != nullptr)

  1704.         {

  1705.             delete[] fParamBuffers;

  1706.             fParamBuffers = nullptr;

  1707.         }

  1708. 

  1709.         CarlaPlugin::clearBuffers();

  1710. 

  1711.         carla_debug("DssiPlugin::clearBuffers() - end");

  1712.     }

  1713. 

  1714.     // -------------------------------------------------------------------

  1715.     // Post-poned UI Stuff

  1716. 

  1717.     void uiParameterChange(const uint32_t index, const float value) override

  1718.     {

  1719.         CARLA_ASSERT(index < kData->param.count);

  1720. 

  1721.         if (index >= kData->param.count)

  1722.             return;

  1723.         if (kData->osc.data.target == nullptr)

  1724.             return;

  1725. 

  1726.         osc_send_control(&kData->osc.data, kData->param.data[index].rindex, value);

  1727.     }

  1728. 

  1729.     void uiMidiProgramChange(const uint32_t index) override

  1730.     {

  1731.         CARLA_ASSERT(index < kData->midiprog.count);

  1732. 

  1733.         if (index >= kData->midiprog.count)

  1734.             return;

  1735.         if (kData->osc.data.target == nullptr)

  1736.             return;

  1737. 

  1738.         osc_send_program(&kData->osc.data, kData->midiprog.data[index].bank, kData->midiprog.data[index].program);

  1739.     }

  1740. 

  1741.     void uiNoteOn(const uint8_t channel, const uint8_t note, const uint8_t velo) override

  1742.     {

  1743.         CARLA_ASSERT(channel < MAX_MIDI_CHANNELS);

  1744.         CARLA_ASSERT(note < MAX_MIDI_NOTE);

  1745.         CARLA_ASSERT(velo > 0 && velo < MAX_MIDI_VALUE);

  1746. 

  1747.         if (channel >= MAX_MIDI_CHANNELS)

  1748.             return;

  1749.         if (note >= MAX_MIDI_NOTE)

  1750.             return;

  1751.         if (velo >= MAX_MIDI_VALUE)

  1752.             return;

  1753.         if (kData->osc.data.target == nullptr)

  1754.             return;

  1755. 

  1756. #if 0

  1757.         uint8_t midiData[4] = { 0 };

  1758.         midiData[1] = MIDI_STATUS_NOTE_ON + channel;

  1759.         midiData[2] = note;

  1760.         midiData[3] = velo;

  1761. 

  1762.         osc_send_midi(&kData->osc.data, midiData);

  1763. #endif

  1764.     }

  1765. 

  1766.     void uiNoteOff(const uint8_t channel, const uint8_t note) override

  1767.     {

  1768.         CARLA_ASSERT(channel < MAX_MIDI_CHANNELS);

  1769.         CARLA_ASSERT(note < MAX_MIDI_NOTE);

  1770. 

  1771.         if (channel >= MAX_MIDI_CHANNELS)

  1772.             return;

  1773.         if (note >= MAX_MIDI_NOTE)

  1774.             return;

  1775.         if (kData->osc.data.target == nullptr)

  1776.             return;

  1777. 

  1778. #if 0

  1779.         uint8_t midiData[4] = { 0 };

  1780.         midiData[1] = MIDI_STATUS_NOTE_OFF + channel;

  1781.         midiData[2] = note;

  1782. 

  1783.         osc_send_midi(&kData->osc.data, midiData);

  1784. #endif

  1785.     }

  1786. 

  1787.     // -------------------------------------------------------------------

  1788. 

  1789.     const void* getExtraStuff() const override

  1790.     {

  1791.         return fGuiFilename.isNotEmpty() ? (const char*)fGuiFilename : nullptr;

  1792.     }

  1793. 

  1794.     bool init(const char* const filename, const char* const name, const char* const label, const char* const guiFilename)

  1795.     {

  1796.         CARLA_ASSERT(kData->engine != nullptr);

  1797.         CARLA_ASSERT(kData->client == nullptr);

  1798.         CARLA_ASSERT(filename != nullptr);

  1799.         CARLA_ASSERT(label != nullptr);

  1800. 

  1801.         // ---------------------------------------------------------------

  1802.         // first checks

  1803. 

  1804.         if (kData->engine == nullptr)

  1805.         {

  1806.             return false;

  1807.         }

  1808. 

  1809.         if (kData->client != nullptr)

  1810.         {

  1811.             kData->engine->setLastError("Plugin client is already registered");

  1812.             return false;

  1813.         }

  1814. 

  1815.         if (filename == nullptr)

  1816.         {

  1817.             kData->engine->setLastError("null filename");

  1818.             return false;

  1819.         }

  1820. 

  1821.         if (label == nullptr)

  1822.         {

  1823.             kData->engine->setLastError("null label");

  1824.             return false;

  1825.         }

  1826. 

  1827.         // ---------------------------------------------------------------

  1828.         // open DLL

  1829. 

  1830.         if (! kData->libOpen(filename))

  1831.         {

  1832.             kData->engine->setLastError(kData->libError(filename));

  1833.             return false;

  1834.         }

  1835. 

  1836.         // ---------------------------------------------------------------

  1837.         // get DLL main entry

  1838. 

  1839.         const DSSI_Descriptor_Function descFn = (DSSI_Descriptor_Function)kData->libSymbol("dssi_descriptor");

  1840. 

  1841.         if (descFn == nullptr)

  1842.         {

  1843.             kData->engine->setLastError("Could not find the DSSI Descriptor in the plugin library");

  1844.             return false;

  1845.         }

  1846. 

  1847.         // ---------------------------------------------------------------

  1848.         // get descriptor that matches label

  1849. 

  1850.         unsigned long i = 0;

  1851.         while ((fDssiDescriptor = descFn(i++)) != nullptr)

  1852.         {

  1853.             fDescriptor = fDssiDescriptor->LADSPA_Plugin;

  1854.             if (fDescriptor != nullptr && fDescriptor->Label != nullptr && std::strcmp(fDescriptor->Label, label) == 0)

  1855.                 break;

  1856.         }

  1857. 

  1858.         if (fDescriptor == nullptr || fDssiDescriptor == nullptr)

  1859.         {

  1860.             kData->engine->setLastError("Could not find the requested plugin label in the plugin library");

  1861.             return false;

  1862.         }

  1863. 

  1864.         // ---------------------------------------------------------------

  1865.         // check if uses global instance

  1866. 

  1867.         if (fDssiDescriptor->run_synth == nullptr && fDssiDescriptor->run_multiple_synths != nullptr)

  1868.         {

  1869.             if (! addUniqueMultiSynth(fDescriptor->Label))

  1870.             {

  1871.                 kData->engine->setLastError("This plugin uses a global instance and can't be used more than once safely");

  1872.                 return false;

  1873.             }

  1874.         }

  1875. 

  1876.         // ---------------------------------------------------------------

  1877.         // get info

  1878. 

  1879.         if (name != nullptr)

  1880.             fName = kData->engine->getUniquePluginName(name);

  1881.         else if (fDescriptor->Name != nullptr)

  1882.             fName = kData->engine->getUniquePluginName(fDescriptor->Name);

  1883.         else

  1884.             fName = kData->engine->getUniquePluginName(fDescriptor->Label);

  1885. 

  1886.         fFilename = filename;

  1887. 

  1888.         // ---------------------------------------------------------------

  1889.         // register client

  1890. 

  1891.         kData->client = kData->engine->addClient(this);

  1892. 

  1893.         if (kData->client == nullptr || ! kData->client->isOk())

  1894.         {

  1895.             kData->engine->setLastError("Failed to register plugin client");

  1896.             return false;

  1897.         }

  1898. 

  1899.         // ---------------------------------------------------------------

  1900.         // initialize plugin

  1901. 

  1902.         fHandle = fDescriptor->instantiate(fDescriptor, (unsigned long)kData->engine->getSampleRate());

  1903. 

  1904.         if (fHandle == nullptr)

  1905.         {

  1906.             kData->engine->setLastError("Plugin failed to initialize");

  1907.             return false;

  1908.         }

  1909. 

  1910.         // ---------------------------------------------------------------

  1911.         // gui stuff

  1912. 

  1913.         if (guiFilename != nullptr)

  1914.         {

  1915.             fGuiFilename = guiFilename;

  1916.             kData->osc.thread.setOscData(guiFilename, fDescriptor->Label);

  1917.         }

  1918. 

  1919.         // ---------------------------------------------------------------

  1920.         // load plugin settings

  1921. 

  1922.         {

  1923. #ifdef __USE_GNU

  1924.             const bool isDssiVst = fFilename.contains("dssi-vst", true);

  1925. #else

  1926.             const bool isDssiVst = fFilename.contains("dssi-vst");

  1927. #endif

  1928. 

  1929.             // set default options

  1930.             fOptions = 0x0;

  1931. 

  1932.             fOptions |= PLUGIN_OPTION_MAP_PROGRAM_CHANGES;

  1933. 

  1934.             if (kData->engine->getOptions().forceStereo)

  1935.                 fOptions |= PLUGIN_OPTION_FORCE_STEREO;

  1936. 

  1937.             if (isDssiVst)

  1938.             {

  1939.                 fOptions |= PLUGIN_OPTION_FIXED_BUFFER;

  1940. 

  1941.                 if (kData->engine->getOptions().useDssiVstChunks && fDssiDescriptor->get_custom_data != nullptr && fDssiDescriptor->set_custom_data != nullptr)

  1942.                     fOptions |= PLUGIN_OPTION_USE_CHUNKS;

  1943.             }

  1944. 

  1945.             if (fDssiDescriptor->run_synth != nullptr || fDssiDescriptor->run_multiple_synths != nullptr)

  1946.             {

  1947.                 fOptions |= PLUGIN_OPTION_SEND_CHANNEL_PRESSURE;

  1948.                 fOptions |= PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH;

  1949.                 fOptions |= PLUGIN_OPTION_SEND_PITCHBEND;

  1950.                 fOptions |= PLUGIN_OPTION_SEND_ALL_SOUND_OFF;

  1951. 

  1952.                 if (fDssiDescriptor->run_synth == nullptr)

  1953.                     carla_stderr2("Plugin can ONLY use run_multiple_synths!");

  1954.             }

  1955. 

  1956.             // load settings

  1957.             kData->idStr  = "DSSI/";

  1958.             kData->idStr += std::strrchr(filename, OS_SEP)+1;

  1959.             kData->idStr += "/";

  1960.             kData->idStr += label;

  1961.             fOptions = kData->loadSettings(fOptions, availableOptions());

  1962. 

  1963.             // ignore settings, we need this anyway

  1964.             if (isDssiVst)

  1965.                 fOptions |= PLUGIN_OPTION_FIXED_BUFFER;

  1966.         }

  1967. 

  1968.         return true;

  1969.     }

  1970. 

  1971. private:

  1972.     LADSPA_Handle fHandle;

  1973.     LADSPA_Handle fHandle2;

  1974.     const LADSPA_Descriptor* fDescriptor;

  1975.     const DSSI_Descriptor*   fDssiDescriptor;

  1976. 

  1977.     CarlaString fGuiFilename;

  1978. 

  1979.     float** fAudioInBuffers;

  1980.     float** fAudioOutBuffers;

  1981.     float*  fParamBuffers;

  1982.     snd_seq_event_t fMidiEvents[MAX_MIDI_EVENTS];

  1983. 

  1984.     static NonRtList<const char*> sMultiSynthList;

  1985. 

  1986.     static bool addUniqueMultiSynth(const char* const label)

  1987.     {

  1988.         for (NonRtList<const char*>::Itenerator it = sMultiSynthList.begin(); it.valid(); it.next())

  1989.         {

  1990.             const char*& itLabel(*it);

  1991. 

  1992.             if (std::strcmp(label, itLabel) == 0)

  1993.                 return false;

  1994.         }

  1995. 

  1996.         sMultiSynthList.append(carla_strdup(label));

  1997.         return true;

  1998.     }

  1999. 

  2000.     static void removeUniqueMultiSynth(const char* const label)

  2001.     {

  2002.         for (NonRtList<const char*>::Itenerator it = sMultiSynthList.begin(); it.valid(); it.next())

  2003.         {

  2004.             const char*& itLabel(*it);

  2005. 

  2006.             if (std::strcmp(label, itLabel) == 0)

  2007.             {

  2008.                 sMultiSynthList.remove(it);

  2009.                 delete[] itLabel;

  2010.                 return;

  2011.             }

  2012.         }

  2013.     }

  2014. 

  2015.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(DssiPlugin)

  2016. };

  2017. 

  2018. NonRtList<const char*> DssiPlugin::sMultiSynthList;

  2019. 

  2020. CARLA_BACKEND_END_NAMESPACE

  2021. 

  2022. #else // WANT_DSSI

  2023. # warning Building without DSSI support

  2024. #endif

  2025. 

  2026. CARLA_BACKEND_START_NAMESPACE

  2027. 

  2028. CarlaPlugin* CarlaPlugin::newDSSI(const Initializer& init, const char* const guiFilename)

  2029. {

  2030.     carla_debug("CarlaPlugin::newDSSI({%p, \"%s\", \"%s\", \"%s\"}, \"%s\")", init.engine, init.filename, init.name, init.label, guiFilename);

  2031. 

  2032. #ifdef WANT_DSSI

  2033.     DssiPlugin* const plugin(new DssiPlugin(init.engine, init.id));

  2034. 

  2035.     if (! plugin->init(init.filename, init.name, init.label, guiFilename))

  2036.     {

  2037.         delete plugin;

  2038.         return nullptr;

  2039.     }

  2040. 

  2041.     plugin->reload();

  2042. 

  2043.     if (init.engine->getProccessMode() == PROCESS_MODE_CONTINUOUS_RACK && ! CarlaPluginProtectedData::canRunInRack(plugin))

  2044.     {

  2045.         init.engine->setLastError("Carla's rack mode can only work with Mono or Stereo DSSI plugins, sorry!");

  2046.         delete plugin;

  2047.         return nullptr;

  2048.     }

  2049. 

  2050.     return plugin;

  2051. #else

  2052.     init.engine->setLastError("DSSI support not available");

  2053.     return nullptr;

  2054. #endif

  2055. }

  2056. 

  2057. CARLA_BACKEND_END_NAMESPACE