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.
1822 Commits
17 Branches
940MB
Tree: 7b97dc6d6c
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '7b97dc6d6c'
${ noResults }
Carla/source/backend/plugin/LadspaPlugin.cpp

1541 lines
53KB
Raw Blame History 

  1. /*

  2.  * Carla LADSPA Plugin

  3.  * Copyright (C) 2011-2014 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 doc/GPL.txt file.

  16.  */

  17. 

  18. #include "CarlaPluginInternal.hpp"

  19. #include "CarlaEngine.hpp"

  20. 

  21. #ifdef WANT_LADSPA

  22. 

  23. #include "CarlaLadspaUtils.hpp"

  24. #include "CarlaMathUtils.hpp"

  25. 

  26. // -----------------------------------------------------

  27. 

  28. CARLA_BACKEND_START_NAMESPACE

  29. 

  30. #if 0

  31. }

  32. #endif

  33. 

  34. // -----------------------------------------------------

  35. 

  36. class LadspaPlugin : public CarlaPlugin

  37. {

  38. public:

  39.     LadspaPlugin(CarlaEngine* const engine, const uint id) noexcept

  40.         : CarlaPlugin(engine, id),

  41.           fHandle(nullptr),

  42.           fHandle2(nullptr),

  43.           fDescriptor(nullptr),

  44.           fRdfDescriptor(nullptr),

  45.           fAudioInBuffers(nullptr),

  46.           fAudioOutBuffers(nullptr),

  47.           fParamBuffers(nullptr)

  48.     {

  49.         carla_debug("LadspaPlugin::LadspaPlugin(%p, %i)", engine, id);

  50.     }

  51. 

  52.     ~LadspaPlugin() noexcept override

  53.     {

  54.         carla_debug("LadspaPlugin::~LadspaPlugin()");

  55. 

  56.         pData->singleMutex.lock();

  57.         pData->masterMutex.lock();

  58. 

  59.         if (pData->client != nullptr && pData->client->isActive())

  60.             pData->client->deactivate();

  61. 

  62.         if (pData->active)

  63.         {

  64.             deactivate();

  65.             pData->active = false;

  66.         }

  67. 

  68.         if (fDescriptor != nullptr)

  69.         {

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

  71.             {

  72.                 if (fHandle != nullptr)

  73.                 {

  74.                     try {

  75.                         fDescriptor->cleanup(fHandle);

  76.                     } catch(...) {}

  77.                 }

  78. 

  79.                 if (fHandle2 != nullptr)

  80.                 {

  81.                     try {

  82.                         fDescriptor->cleanup(fHandle2);

  83.                     } catch(...) {}

  84.                 }

  85.             }

  86. 

  87.             fHandle  = nullptr;

  88.             fHandle2 = nullptr;

  89.             fDescriptor = nullptr;

  90.         }

  91. 

  92.         if (fRdfDescriptor != nullptr)

  93.         {

  94.             delete fRdfDescriptor;

  95.             fRdfDescriptor = nullptr;

  96.         }

  97. 

  98.         clearBuffers();

  99.     }

  100. 

  101.     // -------------------------------------------------------------------

  102.     // Information (base)

  103. 

  104.     PluginType getType() const noexcept override

  105.     {

  106.         return PLUGIN_LADSPA;

  107.     }

  108. 

  109.     PluginCategory getCategory() const noexcept override

  110.     {

  111.         if (fRdfDescriptor != nullptr)

  112.         {

  113.             const LADSPA_PluginType category(fRdfDescriptor->Type);

  114. 

  115.             // Specific Types

  116.             if (category & (LADSPA_PLUGIN_DELAY|LADSPA_PLUGIN_REVERB))

  117.                 return PLUGIN_CATEGORY_DELAY;

  118.             if (category & (LADSPA_PLUGIN_PHASER|LADSPA_PLUGIN_FLANGER|LADSPA_PLUGIN_CHORUS))

  119.                 return PLUGIN_CATEGORY_MODULATOR;

  120.             if (category & (LADSPA_PLUGIN_AMPLIFIER))

  121.                 return PLUGIN_CATEGORY_DYNAMICS;

  122.             if (category & (LADSPA_PLUGIN_UTILITY|LADSPA_PLUGIN_SPECTRAL|LADSPA_PLUGIN_FREQUENCY_METER))

  123.                 return PLUGIN_CATEGORY_UTILITY;

  124. 

  125.             // Pre-set LADSPA Types

  126.             if (LADSPA_IS_PLUGIN_DYNAMICS(category))

  127.                 return PLUGIN_CATEGORY_DYNAMICS;

  128.             if (LADSPA_IS_PLUGIN_AMPLITUDE(category))

  129.                 return PLUGIN_CATEGORY_MODULATOR;

  130.             if (LADSPA_IS_PLUGIN_EQ(category))

  131.                 return PLUGIN_CATEGORY_EQ;

  132.             if (LADSPA_IS_PLUGIN_FILTER(category))

  133.                 return PLUGIN_CATEGORY_FILTER;

  134.             if (LADSPA_IS_PLUGIN_FREQUENCY(category))

  135.                 return PLUGIN_CATEGORY_UTILITY;

  136.             if (LADSPA_IS_PLUGIN_SIMULATOR(category))

  137.                 return PLUGIN_CATEGORY_OTHER;

  138.             if (LADSPA_IS_PLUGIN_TIME(category))

  139.                 return PLUGIN_CATEGORY_DELAY;

  140.             if (LADSPA_IS_PLUGIN_GENERATOR(category))

  141.                 return PLUGIN_CATEGORY_SYNTH;

  142.         }

  143. 

  144.         return CarlaPlugin::getCategory();

  145.     }

  146. 

  147.     int64_t getUniqueId() const noexcept override

  148.     {

  149.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr, 0);

  150. 

  151.         return static_cast<int64_t>(fDescriptor->UniqueID);

  152.     }

  153. 

  154.     // -------------------------------------------------------------------

  155.     // Information (count)

  156. 

  157.     uint32_t getParameterScalePointCount(const uint32_t parameterId) const noexcept override

  158.     {

  159.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, 0);

  160. 

  161.         const int32_t rindex(pData->param.data[parameterId].rindex);

  162. 

  163.         if (fRdfDescriptor != nullptr && rindex < static_cast<int32_t>(fRdfDescriptor->PortCount))

  164.         {

  165.             const LADSPA_RDF_Port* const port(&fRdfDescriptor->Ports[rindex]);

  166.             return static_cast<uint32_t>(port->ScalePointCount);

  167.         }

  168. 

  169.         return 0;

  170.     }

  171. 

  172.     // -------------------------------------------------------------------

  173.     // Information (current data)

  174. 

  175.     // nothing

  176. 

  177.     // -------------------------------------------------------------------

  178.     // Information (per-plugin data)

  179. 

  180.     uint getOptionsAvailable() const noexcept override

  181.     {

  182. #ifdef __USE_GNU

  183.         const bool isDssiVst(strcasestr(pData->filename, "dssi-vst"));

  184. #else

  185.         const bool isDssiVst(std::strstr(pData->filename, "dssi-vst"));

  186. #endif

  187. 

  188.         uint options = 0x0;

  189. 

  190.         if (! isDssiVst)

  191.         {

  192.             options |= PLUGIN_OPTION_FIXED_BUFFERS;

  193. 

  194.             if (pData->engine->getProccessMode() != ENGINE_PROCESS_MODE_CONTINUOUS_RACK)

  195.             {

  196.                 if (pData->options & PLUGIN_OPTION_FORCE_STEREO)

  197.                     options |= PLUGIN_OPTION_FORCE_STEREO;

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

  199.                     options |= PLUGIN_OPTION_FORCE_STEREO;

  200.             }

  201.         }

  202. 

  203.         return options;

  204.     }

  205. 

  206.     float getParameterValue(const uint32_t parameterId) const noexcept override

  207.     {

  208.         CARLA_SAFE_ASSERT_RETURN(fParamBuffers != nullptr, 0.0f);

  209.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, 0.0f);

  210. 

  211.         return fParamBuffers[parameterId];

  212.     }

  213. 

  214.     float getParameterScalePointValue(const uint32_t parameterId, const uint32_t scalePointId) const noexcept override

  215.     {

  216.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr, 0.0f);

  217.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, 0.0f);

  218.         CARLA_SAFE_ASSERT_RETURN(scalePointId < getParameterScalePointCount(parameterId), 0.0f);

  219. 

  220.         const int32_t rindex(pData->param.data[parameterId].rindex);

  221. 

  222.         if (rindex < static_cast<int32_t>(fRdfDescriptor->PortCount))

  223.         {

  224.             const LADSPA_RDF_Port* const port(&fRdfDescriptor->Ports[rindex]);

  225. 

  226.             if (scalePointId < port->ScalePointCount)

  227.             {

  228.                 const LADSPA_RDF_ScalePoint* const scalePoint(&port->ScalePoints[scalePointId]);

  229.                 return scalePoint->Value;

  230.             }

  231.         }

  232. 

  233.         return 0.0f;

  234.     }

  235. 

  236.     void getLabel(char* const strBuf) const noexcept override

  237.     {

  238.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  239. 

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

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

  242.         else

  243.             CarlaPlugin::getLabel(strBuf);

  244.     }

  245. 

  246.     void getMaker(char* const strBuf) const noexcept override

  247.     {

  248.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  249. 

  250.         if (fRdfDescriptor != nullptr && fRdfDescriptor->Creator != nullptr)

  251.             std::strncpy(strBuf, fRdfDescriptor->Creator, STR_MAX);

  252.         else if (fDescriptor->Maker != nullptr)

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

  254.         else

  255.             CarlaPlugin::getMaker(strBuf);

  256.     }

  257. 

  258.     void getCopyright(char* const strBuf) const noexcept override

  259.     {

  260.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  261. 

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

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

  264.         else

  265.             CarlaPlugin::getCopyright(strBuf);

  266.     }

  267. 

  268.     void getRealName(char* const strBuf) const noexcept override

  269.     {

  270.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  271. 

  272.         if (fRdfDescriptor != nullptr && fRdfDescriptor->Title != nullptr)

  273.             std::strncpy(strBuf, fRdfDescriptor->Title, STR_MAX);

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

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

  276.         else

  277.             CarlaPlugin::getRealName(strBuf);

  278.     }

  279. 

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

  281.     {

  282.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  283.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count,);

  284. 

  285.         const int32_t rindex(pData->param.data[parameterId].rindex);

  286. 

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

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

  289.         else

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

  291.     }

  292. 

  293.     void getParameterSymbol(const uint32_t parameterId, char* const strBuf) const noexcept override

  294.     {

  295.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count,);

  296. 

  297.         const int32_t rindex(pData->param.data[parameterId].rindex);

  298. 

  299.         if (fRdfDescriptor != nullptr && rindex < static_cast<int32_t>(fRdfDescriptor->PortCount))

  300.         {

  301.             const LADSPA_RDF_Port* const port(&fRdfDescriptor->Ports[rindex]);

  302. 

  303.             if (LADSPA_PORT_HAS_LABEL(port->Hints) && port->Label != nullptr)

  304.             {

  305.                 std::strncpy(strBuf, port->Label, STR_MAX);

  306.                 return;

  307.             }

  308.         }

  309. 

  310.         CarlaPlugin::getParameterSymbol(parameterId, strBuf);

  311.     }

  312. 

  313.     void getParameterUnit(const uint32_t parameterId, char* const strBuf) const noexcept override

  314.     {

  315.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count,);

  316. 

  317.         const int32_t rindex(pData->param.data[parameterId].rindex);

  318. 

  319.         if (fRdfDescriptor != nullptr && rindex < static_cast<int32_t>(fRdfDescriptor->PortCount))

  320.         {

  321.             const LADSPA_RDF_Port* const port(&fRdfDescriptor->Ports[rindex]);

  322. 

  323.             if (LADSPA_PORT_HAS_UNIT(port->Hints))

  324.             {

  325.                 switch (port->Unit)

  326.                 {

  327.                 case LADSPA_UNIT_DB:

  328.                     std::strncpy(strBuf, "dB", STR_MAX);

  329.                     return;

  330.                 case LADSPA_UNIT_COEF:

  331.                     std::strncpy(strBuf, "(coef)", STR_MAX);

  332.                     return;

  333.                 case LADSPA_UNIT_HZ:

  334.                     std::strncpy(strBuf, "Hz", STR_MAX);

  335.                     return;

  336.                 case LADSPA_UNIT_S:

  337.                     std::strncpy(strBuf, "s", STR_MAX);

  338.                     return;

  339.                 case LADSPA_UNIT_MS:

  340.                     std::strncpy(strBuf, "ms", STR_MAX);

  341.                     return;

  342.                 case LADSPA_UNIT_MIN:

  343.                     std::strncpy(strBuf, "min", STR_MAX);

  344.                     return;

  345.                 }

  346.             }

  347.         }

  348. 

  349.         CarlaPlugin::getParameterUnit(parameterId, strBuf);

  350.     }

  351. 

  352.     void getParameterScalePointLabel(const uint32_t parameterId, const uint32_t scalePointId, char* const strBuf) const noexcept override

  353.     {

  354.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

  355.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count,);

  356.         CARLA_SAFE_ASSERT_RETURN(scalePointId < getParameterScalePointCount(parameterId),);

  357. 

  358.         const int32_t rindex(pData->param.data[parameterId].rindex);

  359. 

  360.         if (rindex < static_cast<int32_t>(fRdfDescriptor->PortCount))

  361.         {

  362.             const LADSPA_RDF_Port* const port(&fRdfDescriptor->Ports[rindex]);

  363. 

  364.             if (scalePointId < port->ScalePointCount)

  365.             {

  366.                 const LADSPA_RDF_ScalePoint* const scalePoint(&port->ScalePoints[scalePointId]);

  367. 

  368.                 if (scalePoint->Label != nullptr)

  369.                 {

  370.                     std::strncpy(strBuf, scalePoint->Label, STR_MAX);

  371.                     return;

  372.                 }

  373.             }

  374.         }

  375. 

  376.         CarlaPlugin::getParameterScalePointLabel(parameterId, scalePointId, strBuf);

  377.     }

  378. 

  379.     // -------------------------------------------------------------------

  380.     // Set data (state)

  381. 

  382.     // nothing

  383. 

  384.     // -------------------------------------------------------------------

  385.     // Set data (internal stuff)

  386. 

  387.     // nothing

  388. 

  389.     // -------------------------------------------------------------------

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

  391. 

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

  393.     {

  394.         CARLA_SAFE_ASSERT_RETURN(fParamBuffers != nullptr,);

  395.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count,);

  396. 

  397.         const float fixedValue(pData->param.getFixedValue(parameterId, value));

  398.         fParamBuffers[parameterId] = fixedValue;

  399. 

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

  401.     }

  402. 

  403.     // -------------------------------------------------------------------

  404.     // Set ui stuff

  405. 

  406.     // nothing

  407. 

  408.     // -------------------------------------------------------------------

  409.     // Plugin state

  410. 

  411.     void reload() override

  412.     {

  413.         CARLA_SAFE_ASSERT_RETURN(pData->engine != nullptr,);

  414.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  415.         CARLA_SAFE_ASSERT_RETURN(fHandle != nullptr,);

  416.         carla_debug("LadspaPlugin::reload() - start");

  417. 

  418.         const EngineProcessMode processMode(pData->engine->getProccessMode());

  419. 

  420.         // Safely disable plugin for reload

  421.         const ScopedDisabler sd(this);

  422. 

  423.         if (pData->active)

  424.             deactivate();

  425. 

  426.         clearBuffers();

  427. 

  428.         const float sampleRate(static_cast<float>(pData->engine->getSampleRate()));

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

  430. 

  431.         uint32_t aIns, aOuts, params;

  432.         aIns = aOuts = params = 0;

  433. 

  434.         bool forcedStereoIn, forcedStereoOut;

  435.         forcedStereoIn = forcedStereoOut = false;

  436. 

  437.         bool needsCtrlIn, needsCtrlOut;

  438.         needsCtrlIn = needsCtrlOut = false;

  439. 

  440.         if (portCount > 0)

  441.         {

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

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

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

  445. 

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

  447.             {

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

  449. 

  450.                 if (LADSPA_IS_PORT_AUDIO(portType))

  451.                 {

  452.                     if (LADSPA_IS_PORT_INPUT(portType))

  453.                         aIns += 1;

  454.                     else if (LADSPA_IS_PORT_OUTPUT(portType))

  455.                         aOuts += 1;

  456.                 }

  457.                 else if (LADSPA_IS_PORT_CONTROL(portType))

  458.                     params += 1;

  459.             }

  460.         }

  461. 

  462.         if ((pData->options & PLUGIN_OPTION_FORCE_STEREO) != 0 && (aIns == 1 || aOuts == 1))

  463.         {

  464.             if (fHandle2 == nullptr)

  465.             {

  466.                 try {

  467.                     fHandle2 = fDescriptor->instantiate(fDescriptor, (ulong)sampleRate);

  468.                 } catch(...) {}

  469.             }

  470. 

  471.             if (fHandle2 != nullptr)

  472.             {

  473.                 if (aIns == 1)

  474.                 {

  475.                     aIns = 2;

  476.                     forcedStereoIn = true;

  477.                 }

  478. 

  479.                 if (aOuts == 1)

  480.                 {

  481.                     aOuts = 2;

  482.                     forcedStereoOut = true;

  483.                 }

  484.             }

  485.         }

  486. 

  487.         if (aIns > 0)

  488.         {

  489.             pData->audioIn.createNew(aIns);

  490.             fAudioInBuffers = new float*[aIns];

  491. 

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

  493.                 fAudioInBuffers[i] = nullptr;

  494.         }

  495. 

  496.         if (aOuts > 0)

  497.         {

  498.             pData->audioOut.createNew(aOuts);

  499.             fAudioOutBuffers = new float*[aOuts];

  500.             needsCtrlIn = true;

  501. 

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

  503.                 fAudioOutBuffers[i] = nullptr;

  504.         }

  505. 

  506.         if (params > 0)

  507.         {

  508.             pData->param.createNew(params, true);

  509. 

  510.             fParamBuffers = new float[params];

  511.             FLOAT_CLEAR(fParamBuffers, params);

  512.         }

  513. 

  514.         const uint portNameSize(pData->engine->getMaxPortNameSize());

  515.         CarlaString portName;

  516. 

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

  518.         {

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

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

  521.             const bool hasPortRDF = (fRdfDescriptor != nullptr && i < fRdfDescriptor->PortCount);

  522. 

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

  524. 

  525.             if (LADSPA_IS_PORT_AUDIO(portType))

  526.             {

  527.                 portName.clear();

  528. 

  529.                 if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  530.                 {

  531.                     portName  = pData->name;

  532.                     portName += ":";

  533.                 }

  534. 

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

  536.                 portName.truncate(portNameSize);

  537. 

  538.                 if (LADSPA_IS_PORT_INPUT(portType))

  539.                 {

  540.                     uint32_t j = iAudioIn++;

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

  542.                     pData->audioIn.ports[j].rindex = i;

  543. 

  544.                     if (forcedStereoIn)

  545.                     {

  546.                         portName += "_2";

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

  548.                         pData->audioIn.ports[1].rindex = i;

  549.                     }

  550.                 }

  551.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  552.                 {

  553.                     uint32_t j = iAudioOut++;

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

  555.                     pData->audioOut.ports[j].rindex = i;

  556. 

  557.                     if (forcedStereoOut)

  558.                     {

  559.                         portName += "_2";

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

  561.                         pData->audioOut.ports[1].rindex = i;

  562.                     }

  563.                 }

  564.                 else

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

  566.             }

  567.             else if (LADSPA_IS_PORT_CONTROL(portType))

  568.             {

  569.                 uint32_t j = iCtrl++;

  570.                 pData->param.data[j].hints  = 0x0;

  571.                 pData->param.data[j].index  = static_cast<int32_t>(j);

  572.                 pData->param.data[j].rindex = static_cast<int32_t>(i);

  573.                 pData->param.data[j].midiCC = -1;

  574.                 pData->param.data[j].midiChannel = 0;

  575.                 pData->param.special[j] = PARAMETER_SPECIAL_NULL;

  576. 

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

  578. 

  579.                 // min value

  580.                 if (LADSPA_IS_HINT_BOUNDED_BELOW(portRangeHints.HintDescriptor))

  581.                     min = portRangeHints.LowerBound;

  582.                 else

  583.                     min = 0.0f;

  584. 

  585.                 // max value

  586.                 if (LADSPA_IS_HINT_BOUNDED_ABOVE(portRangeHints.HintDescriptor))

  587.                     max = portRangeHints.UpperBound;

  588.                 else

  589.                     max = 1.0f;

  590. 

  591.                 if (min > max)

  592.                     max = min;

  593. 

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

  595.                 {

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

  597.                     max = min + 0.1f;

  598.                 }

  599. 

  600.                 // default value

  601.                 if (hasPortRDF && LADSPA_PORT_HAS_DEFAULT(fRdfDescriptor->Ports[i].Hints))

  602.                     def = fRdfDescriptor->Ports[i].Default;

  603.                 else

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

  605. 

  606.                 if (def < min)

  607.                     def = min;

  608.                 else if (def > max)

  609.                     def = max;

  610. 

  611.                 if (LADSPA_IS_HINT_SAMPLE_RATE(portRangeHints.HintDescriptor))

  612.                 {

  613.                     min *= sampleRate;

  614.                     max *= sampleRate;

  615.                     def *= sampleRate;

  616.                     pData->param.data[j].hints |= PARAMETER_USES_SAMPLERATE;

  617.                 }

  618. 

  619.                 if (LADSPA_IS_HINT_TOGGLED(portRangeHints.HintDescriptor))

  620.                 {

  621.                     step = max - min;

  622.                     stepSmall = step;

  623.                     stepLarge = step;

  624.                     pData->param.data[j].hints |= PARAMETER_IS_BOOLEAN;

  625.                 }

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

  627.                 {

  628.                     step = 1.0f;

  629.                     stepSmall = 1.0f;

  630.                     stepLarge = 10.0f;

  631.                     pData->param.data[j].hints |= PARAMETER_IS_INTEGER;

  632.                 }

  633.                 else

  634.                 {

  635.                     float range = max - min;

  636.                     step = range/100.0f;

  637.                     stepSmall = range/1000.0f;

  638.                     stepLarge = range/10.0f;

  639.                 }

  640. 

  641.                 if (LADSPA_IS_PORT_INPUT(portType))

  642.                 {

  643.                     pData->param.data[j].type   = PARAMETER_INPUT;

  644.                     pData->param.data[j].hints |= PARAMETER_IS_ENABLED;

  645.                     pData->param.data[j].hints |= PARAMETER_IS_AUTOMABLE;

  646.                     needsCtrlIn = true;

  647.                 }

  648.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  649.                 {

  650.                     pData->param.data[j].type = PARAMETER_OUTPUT;

  651. 

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

  653.                     {

  654.                         min = 0.0f;

  655.                         max = sampleRate;

  656.                         def = 0.0f;

  657.                         step = 1.0f;

  658.                         stepSmall = 1.0f;

  659.                         stepLarge = 1.0f;

  660.                         pData->param.special[j] = PARAMETER_SPECIAL_LATENCY;

  661.                     }

  662.                     else

  663.                     {

  664.                         pData->param.data[j].hints |= PARAMETER_IS_ENABLED;

  665.                         pData->param.data[j].hints |= PARAMETER_IS_AUTOMABLE;

  666.                         needsCtrlOut = true;

  667.                     }

  668.                 }

  669.                 else

  670.                 {

  671.                     pData->param.data[j].type = PARAMETER_UNKNOWN;

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

  673.                 }

  674. 

  675.                 // extra parameter hints

  676.                 if (LADSPA_IS_HINT_LOGARITHMIC(portRangeHints.HintDescriptor))

  677.                     pData->param.data[j].hints |= PARAMETER_IS_LOGARITHMIC;

  678. 

  679.                 // check for scalepoints, require at least 2 to make it useful

  680.                 if (hasPortRDF && fRdfDescriptor->Ports[i].ScalePointCount > 1)

  681.                     pData->param.data[j].hints |= PARAMETER_USES_SCALEPOINTS;

  682. 

  683.                 pData->param.ranges[j].min = min;

  684.                 pData->param.ranges[j].max = max;

  685.                 pData->param.ranges[j].def = def;

  686.                 pData->param.ranges[j].step = step;

  687.                 pData->param.ranges[j].stepSmall = stepSmall;

  688.                 pData->param.ranges[j].stepLarge = stepLarge;

  689. 

  690.                 // Start parameters in their default values

  691.                 fParamBuffers[j] = def;

  692. 

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

  694. 

  695.                 if (fHandle2 != nullptr)

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

  697.             }

  698.             else

  699.             {

  700.                 // Not Audio or Control

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

  702. 

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

  704. 

  705.                 if (fHandle2 != nullptr)

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

  707.             }

  708.         }

  709. 

  710.         if (needsCtrlIn)

  711.         {

  712.             portName.clear();

  713. 

  714.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  715.             {

  716.                 portName  = pData->name;

  717.                 portName += ":";

  718.             }

  719. 

  720.             portName += "events-in";

  721.             portName.truncate(portNameSize);

  722. 

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

  724.         }

  725. 

  726.         if (needsCtrlOut)

  727.         {

  728.             portName.clear();

  729. 

  730.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  731.             {

  732.                 portName  = pData->name;

  733.                 portName += ":";

  734.             }

  735. 

  736.             portName += "events-out";

  737.             portName.truncate(portNameSize);

  738. 

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

  740.         }

  741. 

  742.         if (forcedStereoIn || forcedStereoOut)

  743.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  744.         else

  745.             pData->options &= ~PLUGIN_OPTION_FORCE_STEREO;

  746. 

  747.         // plugin hints

  748.         pData->hints = 0x0;

  749. 

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

  751.             pData->hints |= PLUGIN_IS_RTSAFE;

  752. 

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

  754.             pData->hints |= PLUGIN_CAN_DRYWET;

  755. 

  756.         if (aOuts > 0)

  757.             pData->hints |= PLUGIN_CAN_VOLUME;

  758. 

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

  760.             pData->hints |= PLUGIN_CAN_BALANCE;

  761. 

  762.         // extra plugin hints

  763.         pData->extraHints = 0x0;

  764. 

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

  766.             pData->extraHints |= PLUGIN_EXTRA_HINT_CAN_RUN_RACK;

  767. 

  768.         // check latency

  769.         if (pData->hints & PLUGIN_CAN_DRYWET)

  770.         {

  771.             for (uint32_t i=0; i < pData->param.count; ++i)

  772.             {

  773.                 if (pData->param.special[i] != PARAMETER_SPECIAL_LATENCY)

  774.                    continue;

  775. 

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

  777. 

  778.                 float tmpIn[aIns][2];

  779.                 float tmpOut[aOuts][2];

  780. 

  781.                 for (uint32_t j=0; j < aIns; ++j)

  782.                 {

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

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

  785. 

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

  787.                 }

  788. 

  789.                 for (uint32_t j=0; j < aOuts; ++j)

  790.                 {

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

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

  793. 

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

  795.                 }

  796. 

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

  798.                     fDescriptor->activate(fHandle);

  799. 

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

  801. 

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

  803.                     fDescriptor->deactivate(fHandle);

  804. 

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

  806. 

  807.                 if (pData->latency != latency)

  808.                 {

  809.                     pData->latency = latency;

  810.                     pData->client->setLatency(latency);

  811.                     pData->recreateLatencyBuffers();

  812.                 }

  813. 

  814.                 break;

  815.             }

  816.         }

  817. 

  818.         bufferSizeChanged(pData->engine->getBufferSize());

  819. 

  820.         if (pData->active)

  821.             activate();

  822. 

  823.         carla_debug("LadspaPlugin::reload() - end");

  824.     }

  825. 

  826.     // -------------------------------------------------------------------

  827.     // Plugin processing

  828. 

  829.     void activate() noexcept override

  830.     {

  831.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  832.         CARLA_SAFE_ASSERT_RETURN(fHandle != nullptr,);

  833. 

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

  835.         {

  836.             try {

  837.                 fDescriptor->activate(fHandle);

  838.             } catch(...) {}

  839. 

  840.             if (fHandle2 != nullptr)

  841.             {

  842.                 try {

  843.                     fDescriptor->activate(fHandle2);

  844.                 } catch(...) {}

  845.             }

  846.         }

  847.     }

  848. 

  849.     void deactivate() noexcept override

  850.     {

  851.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  852.         CARLA_SAFE_ASSERT_RETURN(fHandle != nullptr,);

  853. 

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

  855.         {

  856.             try {

  857.                 fDescriptor->deactivate(fHandle);

  858.             } catch(...) {}

  859. 

  860.             if (fHandle2 != nullptr)

  861.             {

  862.                 try {

  863.                     fDescriptor->deactivate(fHandle2);

  864.                 } catch(...) {}

  865.             }

  866.         }

  867.     }

  868. 

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

  870.     {

  871.         // --------------------------------------------------------------------------------------------------------

  872.         // Check if active

  873. 

  874.         if (! pData->active)

  875.         {

  876.             // disable any output sound

  877.             for (uint32_t i=0; i < pData->audioOut.count; ++i)

  878.                 FLOAT_CLEAR(outBuffer[i], frames);

  879.             return;

  880.         }

  881. 

  882.         // --------------------------------------------------------------------------------------------------------

  883.         // Check if needs reset

  884. 

  885.         if (pData->needsReset)

  886.         {

  887.             if (pData->latency > 0)

  888.             {

  889.                 for (uint32_t i=0; i < pData->audioIn.count; ++i)

  890.                     FLOAT_CLEAR(pData->latencyBuffers[i], pData->latency);

  891.             }

  892. 

  893.             pData->needsReset = false;

  894.         }

  895. 

  896.         // --------------------------------------------------------------------------------------------------------

  897.         // Event Input and Processing

  898. 

  899.         if (pData->event.portIn != nullptr)

  900.         {

  901.             // ----------------------------------------------------------------------------------------------------

  902.             // Event Input (System)

  903. 

  904.             bool isSampleAccurate  = (pData->options & PLUGIN_OPTION_FIXED_BUFFERS) == 0;

  905. 

  906.             uint32_t numEvents  = pData->event.portIn->getEventCount();

  907.             uint32_t timeOffset = 0;

  908. 

  909.             for (uint32_t i=0; i < numEvents; ++i)

  910.             {

  911.                 const EngineEvent& event(pData->event.portIn->getEvent(i));

  912. 

  913.                 if (event.time >= frames)

  914.                     continue;

  915. 

  916.                 CARLA_ASSERT_INT2(event.time >= timeOffset, event.time, timeOffset);

  917. 

  918.                 if (isSampleAccurate && event.time > timeOffset)

  919.                 {

  920.                     if (processSingle(inBuffer, outBuffer, event.time - timeOffset, timeOffset))

  921.                         timeOffset = event.time;

  922.                 }

  923. 

  924.                 switch (event.type)

  925.                 {

  926.                 case kEngineEventTypeNull:

  927.                     break;

  928. 

  929.                 case kEngineEventTypeControl: {

  930.                     const EngineControlEvent& ctrlEvent(event.ctrl);

  931. 

  932.                     switch (ctrlEvent.type)

  933.                     {

  934.                     case kEngineControlEventTypeNull:

  935.                         break;

  936. 

  937.                     case kEngineControlEventTypeParameter: {

  938. #ifndef BUILD_BRIDGE

  939.                         // Control backend stuff

  940.                         if (event.channel == pData->ctrlChannel)

  941.                         {

  942.                             float value;

  943. 

  944.                             if (MIDI_IS_CONTROL_BREATH_CONTROLLER(ctrlEvent.param) && (pData->hints & PLUGIN_CAN_DRYWET) != 0)

  945.                             {

  946.                                 value = ctrlEvent.value;

  947.                                 setDryWet(value, false, false);

  948.                                 pData->postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_DRYWET, 0, value);

  949.                                 break;

  950.                             }

  951. 

  952.                             if (MIDI_IS_CONTROL_CHANNEL_VOLUME(ctrlEvent.param) && (pData->hints & PLUGIN_CAN_VOLUME) != 0)

  953.                             {

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

  955.                                 setVolume(value, false, false);

  956.                                 pData->postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_VOLUME, 0, value);

  957.                                 break;

  958.                             }

  959. 

  960.                             if (MIDI_IS_CONTROL_BALANCE(ctrlEvent.param) && (pData->hints & PLUGIN_CAN_BALANCE) != 0)

  961.                             {

  962.                                 float left, right;

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

  964. 

  965.                                 if (value < 0.0f)

  966.                                 {

  967.                                     left  = -1.0f;

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

  969.                                 }

  970.                                 else if (value > 0.0f)

  971.                                 {

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

  973.                                     right = 1.0f;

  974.                                 }

  975.                                 else

  976.                                 {

  977.                                     left  = -1.0f;

  978.                                     right = 1.0f;

  979.                                 }

  980. 

  981.                                 setBalanceLeft(left, false, false);

  982.                                 setBalanceRight(right, false, false);

  983.                                 pData->postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_BALANCE_LEFT, 0, left);

  984.                                 pData->postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_BALANCE_RIGHT, 0, right);

  985.                                 break;

  986.                             }

  987.                         }

  988. #endif

  989. 

  990.                         // Control plugin parameters

  991.                         for (uint32_t k=0; k < pData->param.count; ++k)

  992.                         {

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

  994.                                 continue;

  995.                             if (pData->param.data[k].midiCC != ctrlEvent.param)

  996.                                 continue;

  997.                             if (pData->param.data[k].type != PARAMETER_INPUT)

  998.                                 continue;

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

  1000.                                 continue;

  1001. 

  1002.                             float value;

  1003. 

  1004.                             if (pData->param.data[k].hints & PARAMETER_IS_BOOLEAN)

  1005.                             {

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

  1007.                             }

  1008.                             else

  1009.                             {

  1010.                                 value = pData->param.ranges[k].getUnnormalizedValue(ctrlEvent.value);

  1011. 

  1012.                                 if (pData->param.data[k].hints & PARAMETER_IS_INTEGER)

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

  1014.                             }

  1015. 

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

  1017.                             pData->postponeRtEvent(kPluginPostRtEventParameterChange, static_cast<int32_t>(k), 0, value);

  1018.                             break;

  1019.                         }

  1020. 

  1021.                         break;

  1022.                     } // case kEngineControlEventTypeParameter

  1023. 

  1024.                     case kEngineControlEventTypeMidiBank:

  1025.                     case kEngineControlEventTypeMidiProgram:

  1026.                     case kEngineControlEventTypeAllSoundOff:

  1027.                     case kEngineControlEventTypeAllNotesOff:

  1028.                         break;

  1029.                     } // switch (ctrlEvent.type)

  1030.                     break;

  1031.                 } // case kEngineEventTypeControl

  1032. 

  1033.                 case kEngineEventTypeMidi:

  1034.                     break;

  1035.                 } // switch (event.type)

  1036.             }

  1037. 

  1038.             pData->postRtEvents.trySplice();

  1039. 

  1040.             if (frames > timeOffset)

  1041.                 processSingle(inBuffer, outBuffer, frames - timeOffset, timeOffset);

  1042. 

  1043.         } // End of Event Input and Processing

  1044. 

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

  1046.         // Plugin processing (no events)

  1047. 

  1048.         else

  1049.         {

  1050.             processSingle(inBuffer, outBuffer, frames, 0);

  1051. 

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

  1053. 

  1054.         CARLA_PROCESS_CONTINUE_CHECK;

  1055. 

  1056.         // --------------------------------------------------------------------------------------------------------

  1057.         // Control Output

  1058. 

  1059.         if (pData->event.portOut != nullptr)

  1060.         {

  1061.             uint8_t  channel;

  1062.             uint16_t param;

  1063.             float    value;

  1064. 

  1065.             for (uint32_t k=0; k < pData->param.count; ++k)

  1066.             {

  1067.                 if (pData->param.data[k].type != PARAMETER_OUTPUT)

  1068.                     continue;

  1069. 

  1070.                 pData->param.ranges[k].fixValue(fParamBuffers[k]);

  1071. 

  1072.                 if (pData->param.data[k].midiCC > 0)

  1073.                 {

  1074.                     channel = pData->param.data[k].midiChannel;

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

  1076.                     value   = pData->param.ranges[k].getNormalizedValue(fParamBuffers[k]);

  1077.                     pData->event.portOut->writeControlEvent(0, channel, kEngineControlEventTypeParameter, param, value);

  1078.                 }

  1079.             }

  1080.         } // End of Control Output

  1081.     }

  1082. 

  1083.     bool processSingle(float** const inBuffer, float** const outBuffer, const uint32_t frames, const uint32_t timeOffset)

  1084.     {

  1085.         CARLA_SAFE_ASSERT_RETURN(frames > 0, false);

  1086. 

  1087.         if (pData->audioIn.count > 0)

  1088.         {

  1089.             CARLA_SAFE_ASSERT_RETURN(inBuffer != nullptr, false);

  1090.         }

  1091.         if (pData->audioOut.count > 0)

  1092.         {

  1093.             CARLA_SAFE_ASSERT_RETURN(outBuffer != nullptr, false);

  1094.         }

  1095. 

  1096.         // --------------------------------------------------------------------------------------------------------

  1097.         // Try lock, silence otherwise

  1098. 

  1099.         if (pData->engine->isOffline())

  1100.         {

  1101.             pData->singleMutex.lock();

  1102.         }

  1103.         else if (! pData->singleMutex.tryLock())

  1104.         {

  1105.             for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1106.             {

  1107.                 for (uint32_t k=0; k < frames; ++k)

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

  1109.             }

  1110. 

  1111.             return false;

  1112.         }

  1113. 

  1114.         // --------------------------------------------------------------------------------------------------------

  1115.         // Reset audio buffers

  1116. 

  1117.         for (uint32_t i=0; i < pData->audioIn.count; ++i)

  1118.             FLOAT_COPY(fAudioInBuffers[i], inBuffer[i]+timeOffset, frames);

  1119. 

  1120.         for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1121.             FLOAT_CLEAR(fAudioOutBuffers[i], frames);

  1122. 

  1123.         // --------------------------------------------------------------------------------------------------------

  1124.         // Run plugin

  1125. 

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

  1127. 

  1128.         if (fHandle2 != nullptr)

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

  1130. 

  1131. #ifndef BUILD_BRIDGE

  1132.         // --------------------------------------------------------------------------------------------------------

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

  1134. 

  1135.         {

  1136.             const bool doDryWet  = (pData->hints & PLUGIN_CAN_DRYWET) != 0 && pData->postProc.dryWet != 1.0f;

  1137.             const bool doBalance = (pData->hints & PLUGIN_CAN_BALANCE) != 0 && (pData->postProc.balanceLeft != -1.0f || pData->postProc.balanceRight != 1.0f);

  1138. 

  1139.             bool isPair;

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

  1141. 

  1142.             for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1143.             {

  1144.                 // Dry/Wet

  1145.                 if (doDryWet)

  1146.                 {

  1147.                     for (uint32_t k=0; k < frames; ++k)

  1148.                     {

  1149.                         // TODO

  1150.                         //if (k < pData->latency && pData->latency < frames)

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

  1152.                         //else

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

  1154. 

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

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

  1157.                     }

  1158.                 }

  1159. 

  1160.                 // Balance

  1161.                 if (doBalance)

  1162.                 {

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

  1164. 

  1165.                     if (isPair)

  1166.                     {

  1167.                         CARLA_ASSERT(i+1 < pData->audioOut.count);

  1168.                         FLOAT_COPY(oldBufLeft, fAudioOutBuffers[i], frames);

  1169.                     }

  1170. 

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

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

  1173. 

  1174.                     for (uint32_t k=0; k < frames; ++k)

  1175.                     {

  1176.                         if (isPair)

  1177.                         {

  1178.                             // left

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

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

  1181.                         }

  1182.                         else

  1183.                         {

  1184.                             // right

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

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

  1187.                         }

  1188.                     }

  1189.                 }

  1190. 

  1191.                 // Volume (and buffer copy)

  1192.                 {

  1193.                     for (uint32_t k=0; k < frames; ++k)

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

  1195.                 }

  1196.             }

  1197. 

  1198. #if 0

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

  1200.             if (pData->latency > 0 && pData->latency < frames)

  1201.             {

  1202.                 for (i=0; i < pData->audioIn.count; ++i)

  1203.                     FLOAT_COPY(pData->latencyBuffers[i], inBuffer[i] + (frames - pData->latency), pData->latency);

  1204.             }

  1205. #endif

  1206.         } // End of Post-processing

  1207. 

  1208. #else // BUILD_BRIDGE

  1209.         for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1210.         {

  1211.             for (uint32_t k=0; k < frames; ++k)

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

  1213.         }

  1214. #endif

  1215. 

  1216.         // --------------------------------------------------------------------------------------------------------

  1217. 

  1218.         pData->singleMutex.unlock();

  1219.         return true;

  1220.     }

  1221. 

  1222.     void bufferSizeChanged(const uint32_t newBufferSize) override

  1223.     {

  1224.         CARLA_ASSERT_INT(newBufferSize > 0, newBufferSize);

  1225.         carla_debug("LadspaPlugin::bufferSizeChanged(%i) - start", newBufferSize);

  1226. 

  1227.         for (uint32_t i=0; i < pData->audioIn.count; ++i)

  1228.         {

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

  1230.                 delete[] fAudioInBuffers[i];

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

  1232.         }

  1233. 

  1234.         for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1235.         {

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

  1237.                 delete[] fAudioOutBuffers[i];

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

  1239.         }

  1240. 

  1241.         if (fHandle2 == nullptr)

  1242.         {

  1243.             for (uint32_t i=0; i < pData->audioIn.count; ++i)

  1244.             {

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

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

  1247.             }

  1248. 

  1249.             for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1250.             {

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

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

  1253.             }

  1254.         }

  1255.         else

  1256.         {

  1257.             if (pData->audioIn.count > 0)

  1258.             {

  1259.                 CARLA_ASSERT(pData->audioIn.count == 2);

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

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

  1262. 

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

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

  1265.             }

  1266. 

  1267.             if (pData->audioOut.count > 0)

  1268.             {

  1269.                 CARLA_ASSERT(pData->audioOut.count == 2);

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

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

  1272. 

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

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

  1275.             }

  1276.         }

  1277. 

  1278.         carla_debug("LadspaPlugin::bufferSizeChanged(%i) - end", newBufferSize);

  1279.     }

  1280. 

  1281.     void sampleRateChanged(const double newSampleRate) override

  1282.     {

  1283.         CARLA_ASSERT_INT(newSampleRate > 0.0, newSampleRate);

  1284.         carla_debug("LadspaPlugin::sampleRateChanged(%g) - start", newSampleRate);

  1285. 

  1286.         // TODO

  1287.         (void)newSampleRate;

  1288. 

  1289.         carla_debug("LadspaPlugin::sampleRateChanged(%g) - end", newSampleRate);

  1290.     }

  1291. 

  1292.     // -------------------------------------------------------------------

  1293.     // Plugin buffers

  1294. 

  1295.     void clearBuffers() noexcept override

  1296.     {

  1297.         carla_debug("LadspaPlugin::clearBuffers() - start");

  1298. 

  1299.         if (fAudioInBuffers != nullptr)

  1300.         {

  1301.             for (uint32_t i=0; i < pData->audioIn.count; ++i)

  1302.             {

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

  1304.                 {

  1305.                     delete[] fAudioInBuffers[i];

  1306.                     fAudioInBuffers[i] = nullptr;

  1307.                 }

  1308.             }

  1309. 

  1310.             delete[] fAudioInBuffers;

  1311.             fAudioInBuffers = nullptr;

  1312.         }

  1313. 

  1314.         if (fAudioOutBuffers != nullptr)

  1315.         {

  1316.             for (uint32_t i=0; i < pData->audioOut.count; ++i)

  1317.             {

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

  1319.                 {

  1320.                     delete[] fAudioOutBuffers[i];

  1321.                     fAudioOutBuffers[i] = nullptr;

  1322.                 }

  1323.             }

  1324. 

  1325.             delete[] fAudioOutBuffers;

  1326.             fAudioOutBuffers = nullptr;

  1327.         }

  1328. 

  1329.         if (fParamBuffers != nullptr)

  1330.         {

  1331.             delete[] fParamBuffers;

  1332.             fParamBuffers = nullptr;

  1333.         }

  1334. 

  1335.         CarlaPlugin::clearBuffers();

  1336. 

  1337.         carla_debug("LadspaPlugin::clearBuffers() - end");

  1338.     }

  1339. 

  1340.     // -------------------------------------------------------------------

  1341. 

  1342.     const void* getExtraStuff() const noexcept override

  1343.     {

  1344.         return fRdfDescriptor;

  1345.     }

  1346. 

  1347.     bool init(const char* const filename, const char* const name, const char* const label, const LADSPA_RDF_Descriptor* const rdfDescriptor)

  1348.     {

  1349.         CARLA_SAFE_ASSERT_RETURN(pData->engine != nullptr, false);

  1350. 

  1351.         // ---------------------------------------------------------------

  1352.         // first checks

  1353. 

  1354.         if (pData->client != nullptr)

  1355.         {

  1356.             pData->engine->setLastError("Plugin client is already registered");

  1357.             return false;

  1358.         }

  1359. 

  1360.         if (filename == nullptr || filename[0] == '\0')

  1361.         {

  1362.             pData->engine->setLastError("null filename");

  1363.             return false;

  1364.         }

  1365. 

  1366.         if (label == nullptr || label[0] == '\0')

  1367.         {

  1368.             pData->engine->setLastError("null label");

  1369.             return false;

  1370.         }

  1371. 

  1372.         // ---------------------------------------------------------------

  1373.         // open DLL

  1374. 

  1375.         if (! pData->libOpen(filename))

  1376.         {

  1377.             pData->engine->setLastError(pData->libError(filename));

  1378.             return false;

  1379.         }

  1380. 

  1381.         // ---------------------------------------------------------------

  1382.         // get DLL main entry

  1383. 

  1384.         const LADSPA_Descriptor_Function descFn = (LADSPA_Descriptor_Function)pData->libSymbol("ladspa_descriptor");

  1385. 

  1386.         if (descFn == nullptr)

  1387.         {

  1388.             pData->engine->setLastError("Could not find the LASDPA Descriptor in the plugin library");

  1389.             return false;

  1390.         }

  1391. 

  1392.         // ---------------------------------------------------------------

  1393.         // get descriptor that matches label

  1394. 

  1395.         ulong i = 0;

  1396.         while ((fDescriptor = descFn(i++)) != nullptr)

  1397.         {

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

  1399.                 break;

  1400.         }

  1401. 

  1402.         if (fDescriptor == nullptr)

  1403.         {

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

  1405.             return false;

  1406.         }

  1407. 

  1408.         // ---------------------------------------------------------------

  1409.         // get info

  1410. 

  1411.         if (is_ladspa_rdf_descriptor_valid(rdfDescriptor, fDescriptor))

  1412.             fRdfDescriptor = ladspa_rdf_dup(rdfDescriptor);

  1413. 

  1414.         if (name != nullptr && name[0] != '\0')

  1415.             pData->name = pData->engine->getUniquePluginName(name);

  1416.         else if (fRdfDescriptor != nullptr && fRdfDescriptor->Title != nullptr && fRdfDescriptor->Title[0] != '\0')

  1417.             pData->name = pData->engine->getUniquePluginName(fRdfDescriptor->Title);

  1418.         else if (fDescriptor->Name != nullptr && fDescriptor->Name[0] != '\0')

  1419.             pData->name = pData->engine->getUniquePluginName(fDescriptor->Name);

  1420.         else

  1421.             pData->name = pData->engine->getUniquePluginName(fDescriptor->Label);

  1422. 

  1423.         pData->filename = carla_strdup(filename);

  1424. 

  1425.         // ---------------------------------------------------------------

  1426.         // register client

  1427. 

  1428.         pData->client = pData->engine->addClient(this);

  1429. 

  1430.         if (pData->client == nullptr || ! pData->client->isOk())

  1431.         {

  1432.             pData->engine->setLastError("Failed to register plugin client");

  1433.             return false;

  1434.         }

  1435. 

  1436.         // ---------------------------------------------------------------

  1437.         // initialize plugin

  1438. 

  1439.         try {

  1440.             fHandle = fDescriptor->instantiate(fDescriptor, (ulong)pData->engine->getSampleRate());

  1441.         } catch(...) {}

  1442. 

  1443.         if (fHandle == nullptr)

  1444.         {

  1445.             pData->engine->setLastError("Plugin failed to initialize");

  1446.             return false;

  1447.         }

  1448. 

  1449.         // ---------------------------------------------------------------

  1450.         // load plugin settings

  1451. 

  1452.         {

  1453. #ifdef __USE_GNU

  1454.             const bool isDssiVst(strcasestr(pData->filename, "dssi-vst"));

  1455. #else

  1456.             const bool isDssiVst(std::strstr(pData->filename, "dssi-vst"));

  1457. #endif

  1458. 

  1459.             // set default options

  1460.             pData->options = 0x0;

  1461. 

  1462.             if (isDssiVst)

  1463.                 pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1464. 

  1465.             if (pData->engine->getOptions().forceStereo)

  1466.                 pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  1467. 

  1468.             // set identifier string

  1469.             CarlaString identifier("LADSPA/");

  1470.             identifier += CarlaString(getUniqueId());

  1471.             identifier += ",";

  1472.             identifier += label;

  1473.             pData->identifier = identifier.dup();

  1474. 

  1475.             // load settings

  1476.             pData->options = pData->loadSettings(pData->options, getOptionsAvailable());

  1477. 

  1478.             // ignore settings, we need this anyway

  1479.             if (isDssiVst)

  1480.                 pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1481.         }

  1482. 

  1483.         return true;

  1484.     }

  1485. 

  1486.     // -------------------------------------------------------------------

  1487. 

  1488. private:

  1489.     LADSPA_Handle fHandle;

  1490.     LADSPA_Handle fHandle2;

  1491.     const LADSPA_Descriptor*     fDescriptor;

  1492.     const LADSPA_RDF_Descriptor* fRdfDescriptor;

  1493. 

  1494.     float** fAudioInBuffers;

  1495.     float** fAudioOutBuffers;

  1496.     float*  fParamBuffers;

  1497. 

  1498.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(LadspaPlugin)

  1499. };

  1500. 

  1501. CARLA_BACKEND_END_NAMESPACE

  1502. 

  1503. #endif // WANT_LADSPA

  1504. 

  1505. // -------------------------------------------------------------------------------------------------------------------

  1506. 

  1507. CARLA_BACKEND_START_NAMESPACE

  1508. 

  1509. CarlaPlugin* CarlaPlugin::newLADSPA(const Initializer& init, const LADSPA_RDF_Descriptor* const rdfDescriptor)

  1510. {

  1511.     carla_debug("CarlaPlugin::newLADSPA({%p, \"%s\", \"%s\", \"%s\", " P_INT64 "}, %p)", init.engine, init.filename, init.name, init.label, init.uniqueId, rdfDescriptor);

  1512. 

  1513. #ifdef WANT_LADSPA

  1514.     LadspaPlugin* const plugin(new LadspaPlugin(init.engine, init.id));

  1515. 

  1516.     if (! plugin->init(init.filename, init.name, init.label, rdfDescriptor))

  1517.     {

  1518.         delete plugin;

  1519.         return nullptr;

  1520.     }

  1521. 

  1522.     plugin->reload();

  1523. 

  1524.     if (init.engine->getProccessMode() == ENGINE_PROCESS_MODE_CONTINUOUS_RACK && ! plugin->canRunInRack())

  1525.     {

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

  1527.         delete plugin;

  1528.         return nullptr;

  1529.     }

  1530. 

  1531.     return plugin;

  1532. #else

  1533.     init.engine->setLastError("LADSPA support not available");

  1534.     return nullptr;

  1535. #endif

  1536. }

  1537. 

  1538. CARLA_BACKEND_END_NAMESPACE

  1539. 

  1540. // -------------------------------------------------------------------------------------------------------------------