falkTX
/
Carla
mirror of https://github.com/falkTX/Carla
1
0
Fork 0
Code Releases 42 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.
3037 Commits
16 Branches
191MB
Tree: 12bfd1ca61
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '12bfd1ca61'
${ noResults }
Carla/source/backend/plugin/CarlaPluginLADSPA.cpp

1853 lines
66KB
Raw Blame History 

  1. /*

  2.  * Carla Plugin, LADSPA implementation

  3.  * Copyright (C) 2011-2015 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. #include "CarlaLadspaUtils.hpp"

  22. #include "CarlaMathUtils.hpp"

  23. 

  24. CARLA_BACKEND_START_NAMESPACE

  25. 

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

  27. 

  28. class CarlaPluginLADSPA : public CarlaPlugin

  29. {

  30. public:

  31.     CarlaPluginLADSPA(CarlaEngine* const engine, const uint id) noexcept

  32.         : CarlaPlugin(engine, id),

  33.           fHandles(),

  34.           fDescriptor(nullptr),

  35.           fRdfDescriptor(nullptr),

  36.           fAudioInBuffers(nullptr),

  37.           fAudioOutBuffers(nullptr),

  38.           fExtraStereoBuffer(),

  39.           fParamBuffers(nullptr),

  40.           fLatencyIndex(-1),

  41.           fForcedStereoIn(false),

  42.           fForcedStereoOut(false),

  43.           fIsDssiVst(false),

  44.           leakDetector_CarlaPluginLADSPA()

  45.     {

  46.         carla_debug("CarlaPluginLADSPA::CarlaPluginLADSPA(%p, %i)", engine, id);

  47. 

  48.         carla_zeroPointers(fExtraStereoBuffer, 2);

  49.     }

  50. 

  51.     ~CarlaPluginLADSPA() noexcept override

  52.     {

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

  54. 

  55.         pData->singleMutex.lock();

  56.         pData->masterMutex.lock();

  57. 

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

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

  60. 

  61.         if (pData->active)

  62.         {

  63.             deactivate();

  64.             pData->active = false;

  65.         }

  66. 

  67.         if (fDescriptor != nullptr)

  68.         {

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

  70.             {

  71.                 for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  72.                 {

  73.                     LADSPA_Handle const handle(it.getValue(nullptr));

  74.                     CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  75. 

  76.                     try {

  77.                         fDescriptor->cleanup(handle);

  78.                     } CARLA_SAFE_EXCEPTION("LADSPA cleanup");

  79.                 }

  80.             }

  81. 

  82.             fHandles.clear();

  83.             fDescriptor = nullptr;

  84.         }

  85. 

  86.         if (fRdfDescriptor != nullptr)

  87.         {

  88.             delete fRdfDescriptor;

  89.             fRdfDescriptor = nullptr;

  90.         }

  91. 

  92.         clearBuffers();

  93.     }

  94. 

  95.     // -------------------------------------------------------------------

  96.     // Information (base)

  97. 

  98.     PluginType getType() const noexcept override

  99.     {

  100.         return PLUGIN_LADSPA;

  101.     }

  102. 

  103.     PluginCategory getCategory() const noexcept override

  104.     {

  105.         if (fRdfDescriptor != nullptr)

  106.         {

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

  108. 

  109.             // Specific Types

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

  111.                 return PLUGIN_CATEGORY_DELAY;

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

  113.                 return PLUGIN_CATEGORY_MODULATOR;

  114.             if (category & (LADSPA_PLUGIN_AMPLIFIER))

  115.                 return PLUGIN_CATEGORY_DYNAMICS;

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

  117.                 return PLUGIN_CATEGORY_UTILITY;

  118. 

  119.             // Pre-set LADSPA Types

  120.             if (LADSPA_IS_PLUGIN_DYNAMICS(category))

  121.                 return PLUGIN_CATEGORY_DYNAMICS;

  122.             if (LADSPA_IS_PLUGIN_AMPLITUDE(category))

  123.                 return PLUGIN_CATEGORY_MODULATOR;

  124.             if (LADSPA_IS_PLUGIN_EQ(category))

  125.                 return PLUGIN_CATEGORY_EQ;

  126.             if (LADSPA_IS_PLUGIN_FILTER(category))

  127.                 return PLUGIN_CATEGORY_FILTER;

  128.             if (LADSPA_IS_PLUGIN_FREQUENCY(category))

  129.                 return PLUGIN_CATEGORY_UTILITY;

  130.             if (LADSPA_IS_PLUGIN_SIMULATOR(category))

  131.                 return PLUGIN_CATEGORY_OTHER;

  132.             if (LADSPA_IS_PLUGIN_TIME(category))

  133.                 return PLUGIN_CATEGORY_DELAY;

  134.             if (LADSPA_IS_PLUGIN_GENERATOR(category))

  135.                 return PLUGIN_CATEGORY_SYNTH;

  136.         }

  137. 

  138.         return CarlaPlugin::getCategory();

  139.     }

  140. 

  141.     int64_t getUniqueId() const noexcept override

  142.     {

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

  144. 

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

  146.     }

  147. 

  148.     uint32_t getLatencyInFrames() const noexcept override

  149.     {

  150.         if (fLatencyIndex < 0 || fParamBuffers == nullptr)

  151.             return 0;

  152. 

  153.         const float latency(fParamBuffers[fLatencyIndex]);

  154.         CARLA_SAFE_ASSERT_RETURN(latency >= 0.0f, 0);

  155. 

  156.         return static_cast<uint32_t>(latency);

  157.     }

  158. 

  159.     // -------------------------------------------------------------------

  160.     // Information (count)

  161. 

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

  163.     {

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

  165. 

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

  167.         CARLA_SAFE_ASSERT_RETURN(rindex >= 0,                      0);

  168. 

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

  170.         {

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

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

  173.         }

  174. 

  175.         return 0;

  176.     }

  177. 

  178.     // -------------------------------------------------------------------

  179.     // Information (current data)

  180. 

  181.     // nothing

  182. 

  183.     // -------------------------------------------------------------------

  184.     // Information (per-plugin data)

  185. 

  186.     uint getOptionsAvailable() const noexcept override

  187.     {

  188.         uint options = 0x0;

  189. 

  190.         if (! fIsDssiVst)

  191.         {

  192.             // can't disable fixed buffers if using latency

  193.             if (fLatencyIndex == -1)

  194.                 options |= PLUGIN_OPTION_FIXED_BUFFERS;

  195. 

  196.             // can't disable forced stereo if in rack mode

  197.             if (pData->engine->getProccessMode() == ENGINE_PROCESS_MODE_CONTINUOUS_RACK)

  198.                 pass();

  199.             // if inputs or outputs are just 1, then yes we can force stereo

  200.             else if (pData->audioIn.count == 1 || pData->audioOut.count == 1 || fForcedStereoIn || fForcedStereoOut)

  201.                 options |= PLUGIN_OPTION_FORCE_STEREO;

  202.         }

  203. 

  204.         return options;

  205.     }

  206. 

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

  208.     {

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

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

  211. 

  212.         // bad plugins might have set output values out of bounds

  213.         if (pData->param.data[parameterId].type == PARAMETER_OUTPUT)

  214.             return pData->param.ranges[parameterId].getFixedValue(fParamBuffers[parameterId]);

  215. 

  216.         // not output, should be fine

  217.         return fParamBuffers[parameterId];

  218.     }

  219. 

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

  221.     {

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

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

  224. 

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

  226.         CARLA_SAFE_ASSERT_RETURN(rindex >= 0,                      0.0f);

  227. 

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

  229.         {

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

  231.             CARLA_SAFE_ASSERT_RETURN(scalePointId < port->ScalePointCount, 0.0f);

  232. 

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

  234.             return pData->param.ranges[parameterId].getFixedValue(scalePoint->Value);

  235.         }

  236. 

  237.         return 0.0f;

  238.     }

  239. 

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

  241.     {

  242.         CARLA_SAFE_ASSERT_RETURN(fDescriptor        != nullptr, nullStrBuf(strBuf));

  243.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->Label != nullptr, nullStrBuf(strBuf));

  244. 

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

  246.     }

  247. 

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

  249.     {

  250.         CARLA_SAFE_ASSERT_RETURN(fDescriptor        != nullptr, nullStrBuf(strBuf));

  251.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->Maker != nullptr, nullStrBuf(strBuf));

  252. 

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

  254.         {

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

  256.             return;

  257.         }

  258. 

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

  260.     }

  261. 

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

  263.     {

  264.         CARLA_SAFE_ASSERT_RETURN(fDescriptor            != nullptr, nullStrBuf(strBuf));

  265.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->Copyright != nullptr, nullStrBuf(strBuf));

  266. 

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

  268.     }

  269. 

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

  271.     {

  272.         CARLA_SAFE_ASSERT_RETURN(fDescriptor       != nullptr, nullStrBuf(strBuf));

  273.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->Name != nullptr, nullStrBuf(strBuf));

  274. 

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

  276.         {

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

  278.             return;

  279.         }

  280. 

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

  282.     }

  283. 

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

  285.     {

  286.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,           nullStrBuf(strBuf));

  287.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, nullStrBuf(strBuf));

  288. 

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

  290.         CARLA_SAFE_ASSERT_RETURN(rindex >= 0,                      nullStrBuf(strBuf));

  291. 

  292.         CARLA_SAFE_ASSERT_RETURN(rindex < static_cast<int32_t>(fDescriptor->PortCount), nullStrBuf(strBuf));

  293.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->PortNames[rindex] != nullptr,             nullStrBuf(strBuf));

  294. 

  295.         if (getSeparatedParameterNameOrUnit(fDescriptor->PortNames[rindex], strBuf, true))

  296.             return;

  297. 

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

  299.     }

  300. 

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

  302.     {

  303.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, nullStrBuf(strBuf));

  304. 

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

  306.         CARLA_SAFE_ASSERT_RETURN(rindex >= 0,                      nullStrBuf(strBuf));

  307. 

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

  309.         {

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

  311. 

  312.             if (LADSPA_PORT_HAS_LABEL(port->Hints))

  313.             {

  314.                 CARLA_SAFE_ASSERT_RETURN(port->Label != nullptr, nullStrBuf(strBuf));

  315. 

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

  317.                 return;

  318.             }

  319.         }

  320. 

  321.         nullStrBuf(strBuf);

  322.     }

  323. 

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

  325.     {

  326.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, nullStrBuf(strBuf));

  327. 

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

  329.         CARLA_SAFE_ASSERT_RETURN(rindex >= 0,                      nullStrBuf(strBuf));

  330. 

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

  332.         {

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

  334. 

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

  336.             {

  337.                 switch (port->Unit)

  338.                 {

  339.                 case LADSPA_UNIT_DB:

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

  341.                     return;

  342.                 case LADSPA_UNIT_COEF:

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

  344.                     return;

  345.                 case LADSPA_UNIT_HZ:

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

  347.                     return;

  348.                 case LADSPA_UNIT_S:

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

  350.                     return;

  351.                 case LADSPA_UNIT_MS:

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

  353.                     return;

  354.                 case LADSPA_UNIT_MIN:

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

  356.                     return;

  357.                 }

  358.             }

  359.         }

  360. 

  361.         CARLA_SAFE_ASSERT_RETURN(rindex < static_cast<int32_t>(fDescriptor->PortCount), nullStrBuf(strBuf));

  362.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->PortNames[rindex] != nullptr,             nullStrBuf(strBuf));

  363. 

  364.         if (getSeparatedParameterNameOrUnit(fDescriptor->PortNames[rindex], strBuf, false))

  365.             return;

  366. 

  367.         nullStrBuf(strBuf);

  368.     }

  369. 

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

  371.     {

  372.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,        nullStrBuf(strBuf));

  373.         CARLA_SAFE_ASSERT_RETURN(parameterId < pData->param.count, nullStrBuf(strBuf));

  374. 

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

  376.         CARLA_SAFE_ASSERT_RETURN(rindex >= 0,                      nullStrBuf(strBuf));

  377. 

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

  379.         {

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

  381.             CARLA_SAFE_ASSERT_RETURN(scalePointId < port->ScalePointCount, nullStrBuf(strBuf));

  382. 

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

  384.             CARLA_SAFE_ASSERT_RETURN(scalePoint->Label != nullptr,         nullStrBuf(strBuf));

  385. 

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

  387.             return;

  388.         }

  389. 

  390.         nullStrBuf(strBuf);

  391.     }

  392. 

  393.     // -------------------------------------------------------------------

  394.     // Set data (state)

  395. 

  396.     // nothing

  397. 

  398.     // -------------------------------------------------------------------

  399.     // Set data (internal stuff)

  400. 

  401.     // nothing

  402. 

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

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

  405. 

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

  407.     {

  408.         CARLA_SAFE_ASSERT_RETURN(fParamBuffers != nullptr,);

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

  410. 

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

  412.         fParamBuffers[parameterId] = fixedValue;

  413. 

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

  415.     }

  416. 

  417.     // -------------------------------------------------------------------

  418.     // Misc

  419. 

  420.     // nothing

  421. 

  422.     // -------------------------------------------------------------------

  423.     // Plugin state

  424. 

  425.     void reload() override

  426.     {

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

  428.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  429.         CARLA_SAFE_ASSERT_RETURN(fHandles.count() > 0,);

  430.         carla_debug("CarlaPluginLADSPA::reload() - start");

  431. 

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

  433. 

  434.         // Safely disable plugin for reload

  435.         const ScopedDisabler sd(this);

  436. 

  437.         if (pData->active)

  438.             deactivate();

  439. 

  440.         clearBuffers();

  441. 

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

  443.         const uint32_t portCount(getSafePortCount());

  444. 

  445.         uint32_t aIns, aOuts, params;

  446.         aIns = aOuts = params = 0;

  447. 

  448.         bool forcedStereoIn, forcedStereoOut;

  449.         forcedStereoIn = forcedStereoOut = false;

  450. 

  451.         bool needsCtrlIn, needsCtrlOut;

  452.         needsCtrlIn = needsCtrlOut = false;

  453. 

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

  455.         {

  456.             const LADSPA_PortDescriptor portType(fDescriptor->PortDescriptors[i]);

  457. 

  458.             if (LADSPA_IS_PORT_AUDIO(portType))

  459.             {

  460.                 if (LADSPA_IS_PORT_INPUT(portType))

  461.                     aIns += 1;

  462.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  463.                     aOuts += 1;

  464.             }

  465.             else if (LADSPA_IS_PORT_CONTROL(portType))

  466.                 params += 1;

  467.         }

  468. 

  469.         if (pData->options & PLUGIN_OPTION_FORCE_STEREO)

  470.         {

  471.             if ((aIns == 1 || aOuts == 1) && fHandles.count() == 1 && addInstance())

  472.             {

  473.                 if (aIns == 1)

  474.                 {

  475.                     aIns = 2;

  476.                     forcedStereoIn = true;

  477.                 }

  478.                 if (aOuts == 1)

  479.                 {

  480.                     aOuts = 2;

  481.                     forcedStereoOut = true;

  482.                 }

  483.             }

  484.         }

  485. 

  486.         if (aIns > 0)

  487.         {

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

  489.             fAudioInBuffers = new float*[aIns];

  490. 

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

  492.                 fAudioInBuffers[i] = nullptr;

  493.         }

  494. 

  495.         if (aOuts > 0)

  496.         {

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

  498.             fAudioOutBuffers = new float*[aOuts];

  499.             needsCtrlIn = true;

  500. 

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

  502.                 fAudioOutBuffers[i] = nullptr;

  503.         }

  504. 

  505.         if (params > 0)

  506.         {

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

  508. 

  509.             fParamBuffers = new float[params];

  510.             FloatVectorOperations::clear(fParamBuffers, static_cast<int>(params));

  511.         }

  512. 

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

  514.         CarlaString portName;

  515. 

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

  517.         {

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

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

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

  521. 

  522.             if (LADSPA_IS_PORT_AUDIO(portType))

  523.             {

  524.                 portName.clear();

  525. 

  526.                 if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  527.                 {

  528.                     portName  = pData->name;

  529.                     portName += ":";

  530.                 }

  531. 

  532.                 if (fDescriptor->PortNames[i] != nullptr && fDescriptor->PortNames[i][0] != '\0')

  533.                 {

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

  535.                 }

  536.                 else

  537.                 {

  538.                     if (LADSPA_IS_PORT_INPUT(portType))

  539.                     {

  540.                         if (aIns > 1)

  541.                         {

  542.                             portName += "audio-in_";

  543.                             portName += CarlaString(iAudioIn+1);

  544.                         }

  545.                         else

  546.                             portName += "audio-in";

  547.                     }

  548.                     else

  549.                     {

  550.                         if (aOuts > 1)

  551.                         {

  552.                             portName += "audio-out_";

  553.                             portName += CarlaString(iAudioOut+1);

  554.                         }

  555.                         else

  556.                             portName += "audio-out";

  557.                     }

  558.                 }

  559. 

  560.                 portName.truncate(portNameSize);

  561. 

  562.                 if (LADSPA_IS_PORT_INPUT(portType))

  563.                 {

  564.                     const uint32_t j = iAudioIn++;

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

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

  567. 

  568.                     if (forcedStereoIn)

  569.                     {

  570.                         portName += "_2";

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

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

  573.                     }

  574.                 }

  575.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  576.                 {

  577.                     const uint32_t j = iAudioOut++;

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

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

  580. 

  581.                     if (forcedStereoOut)

  582.                     {

  583.                         portName += "_2";

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

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

  586.                     }

  587.                 }

  588.                 else

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

  590.             }

  591.             else if (LADSPA_IS_PORT_CONTROL(portType))

  592.             {

  593.                 const uint32_t j = iCtrl++;

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

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

  596. 

  597.                 const char* const paramName(fDescriptor->PortNames[i] != nullptr ? fDescriptor->PortNames[i] : "unknown");

  598. 

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

  600. 

  601.                 // min value

  602.                 if (LADSPA_IS_HINT_BOUNDED_BELOW(portRangeHints.HintDescriptor))

  603.                     min = portRangeHints.LowerBound;

  604.                 else

  605.                     min = 0.0f;

  606. 

  607.                 // max value

  608.                 if (LADSPA_IS_HINT_BOUNDED_ABOVE(portRangeHints.HintDescriptor))

  609.                     max = portRangeHints.UpperBound;

  610.                 else

  611.                     max = 1.0f;

  612. 

  613.                 if (min > max)

  614.                 {

  615.                     carla_stderr2("WARNING - Broken plugin parameter '%s': min > max", paramName);

  616.                     min = max - 0.1f;

  617.                 }

  618.                 else if (carla_isEqual(min, max))

  619.                 {

  620.                     carla_stderr2("WARNING - Broken plugin parameter '%s': min == max", paramName);

  621.                     max = min + 0.1f;

  622.                 }

  623. 

  624.                 // default value

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

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

  627.                 else

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

  629. 

  630.                 if (def < min)

  631.                     def = min;

  632.                 else if (def > max)

  633.                     def = max;

  634. 

  635.                 if (LADSPA_IS_HINT_SAMPLE_RATE(portRangeHints.HintDescriptor))

  636.                 {

  637.                     min *= sampleRate;

  638.                     max *= sampleRate;

  639.                     def *= sampleRate;

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

  641.                 }

  642. 

  643.                 if (LADSPA_IS_HINT_TOGGLED(portRangeHints.HintDescriptor))

  644.                 {

  645.                     step = max - min;

  646.                     stepSmall = step;

  647.                     stepLarge = step;

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

  649.                 }

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

  651.                 {

  652.                     step = 1.0f;

  653.                     stepSmall = 1.0f;

  654.                     stepLarge = 10.0f;

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

  656.                 }

  657.                 else

  658.                 {

  659.                     const float range = max - min;

  660.                     step = range/100.0f;

  661.                     stepSmall = range/1000.0f;

  662.                     stepLarge = range/10.0f;

  663.                 }

  664. 

  665.                 if (LADSPA_IS_PORT_INPUT(portType))

  666.                 {

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

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

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

  670.                     needsCtrlIn = true;

  671.                 }

  672.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  673.                 {

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

  675. 

  676.                     if (std::strcmp(paramName, "latency") == 0 || std::strcmp(paramName, "_latency") == 0)

  677.                     {

  678.                         min = 0.0f;

  679.                         max = sampleRate;

  680.                         def = 0.0f;

  681.                         step = 1.0f;

  682.                         stepSmall = 1.0f;

  683.                         stepLarge = 1.0f;

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

  685.                         CARLA_SAFE_ASSERT(fLatencyIndex == static_cast<int32_t>(j));

  686.                     }

  687.                     else

  688.                     {

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

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

  691.                         needsCtrlOut = true;

  692.                     }

  693.                 }

  694.                 else

  695.                 {

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

  697.                 }

  698. 

  699.                 // extra parameter hints

  700.                 if (LADSPA_IS_HINT_LOGARITHMIC(portRangeHints.HintDescriptor))

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

  702. 

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

  704.                 if (hasPortRDF && fRdfDescriptor->Ports[i].ScalePointCount >= 2)

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

  706. 

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

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

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

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

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

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

  713. 

  714.                 // Start parameters in their default values

  715.                 fParamBuffers[j] = def;

  716. 

  717.                 for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  718.                 {

  719.                     LADSPA_Handle const handle(it.getValue(nullptr));

  720.                     CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  721. 

  722.                     try {

  723.                         fDescriptor->connect_port(handle, i, &fParamBuffers[j]);

  724.                     } CARLA_SAFE_EXCEPTION("LADSPA connect_port (parameter)");

  725.                 }

  726.             }

  727.             else

  728.             {

  729.                 // Not Audio or Control

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

  731. 

  732.                 for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  733.                 {

  734.                     LADSPA_Handle const handle(it.getValue(nullptr));

  735.                     CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  736. 

  737.                     try {

  738.                         fDescriptor->connect_port(handle, i, nullptr);

  739.                     } CARLA_SAFE_EXCEPTION("LADSPA connect_port (null)");

  740.                 }

  741.             }

  742.         }

  743. 

  744.         if (needsCtrlIn)

  745.         {

  746.             portName.clear();

  747. 

  748.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  749.             {

  750.                 portName  = pData->name;

  751.                 portName += ":";

  752.             }

  753. 

  754.             portName += "events-in";

  755.             portName.truncate(portNameSize);

  756. 

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

  758.         }

  759. 

  760.         if (needsCtrlOut)

  761.         {

  762.             portName.clear();

  763. 

  764.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  765.             {

  766.                 portName  = pData->name;

  767.                 portName += ":";

  768.             }

  769. 

  770.             portName += "events-out";

  771.             portName.truncate(portNameSize);

  772. 

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

  774.         }

  775. 

  776.         if (forcedStereoIn || forcedStereoOut)

  777.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  778.         else

  779.             pData->options &= ~PLUGIN_OPTION_FORCE_STEREO;

  780. 

  781.         // plugin hints

  782.         pData->hints = 0x0;

  783. 

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

  785.             pData->hints |= PLUGIN_IS_RTSAFE;

  786. 

  787. #ifndef BUILD_BRIDGE

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

  789.             pData->hints |= PLUGIN_CAN_DRYWET;

  790. 

  791.         if (aOuts > 0)

  792.             pData->hints |= PLUGIN_CAN_VOLUME;

  793. 

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

  795.             pData->hints |= PLUGIN_CAN_BALANCE;

  796. #endif

  797. 

  798.         // extra plugin hints

  799.         pData->extraHints  = 0x0;

  800.         pData->extraHints |= PLUGIN_EXTRA_HINT_CAN_RUN_RACK;

  801. 

  802.         // check initial latency

  803.         findInitialLatencyValue(aIns, aOuts);

  804. 

  805.         fForcedStereoIn  = forcedStereoIn;

  806.         fForcedStereoOut = forcedStereoOut;

  807. 

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

  809. 

  810.         if (pData->active)

  811.             activate();

  812. 

  813.         carla_debug("CarlaPluginLADSPA::reload() - end");

  814.     }

  815. 

  816.     void findInitialLatencyValue(const uint32_t aIns, const uint32_t aOuts) const

  817.     {

  818.         if (fLatencyIndex < 0 || fHandles.count() == 0)

  819.             return;

  820. 

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

  822.         const LADSPA_Handle handle(fHandles.getFirst(nullptr));

  823.         CARLA_SAFE_ASSERT_RETURN(handle != nullptr,);

  824. 

  825.         float tmpIn [(aIns > 0)  ? aIns  : 1][2];

  826.         float tmpOut[(aOuts > 0) ? aOuts : 1][2];

  827. 

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

  829.         {

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

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

  832. 

  833.             try {

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

  835.             } CARLA_SAFE_EXCEPTION("LADSPA connect_port (latency input)");

  836.         }

  837. 

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

  839.         {

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

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

  842. 

  843.             try {

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

  845.             } CARLA_SAFE_EXCEPTION("LADSPA connect_port (latency output)");

  846.         }

  847. 

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

  849.         {

  850.             try {

  851.                 fDescriptor->activate(handle);

  852.             } CARLA_SAFE_EXCEPTION("LADSPA latency activate");

  853.         }

  854. 

  855.         try {

  856.             fDescriptor->run(handle, 2);

  857.         } CARLA_SAFE_EXCEPTION("LADSPA latency run");

  858. 

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

  860.         {

  861.             try {

  862.                 fDescriptor->deactivate(handle);

  863.             } CARLA_SAFE_EXCEPTION("LADSPA latency deactivate");

  864.         }

  865. 

  866.         // done, let's get the value

  867.         if (const uint32_t latency = getLatencyInFrames())

  868.         {

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

  870.             pData->latency.recreateBuffers(std::max(aIns, aOuts), latency);

  871.         }

  872.     }

  873. 

  874.     // -------------------------------------------------------------------

  875.     // Plugin processing

  876. 

  877.     void activate() noexcept override

  878.     {

  879.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  880. 

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

  882.         {

  883.             for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  884.             {

  885.                 LADSPA_Handle const handle(it.getValue(nullptr));

  886.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  887. 

  888.                 try {

  889.                     fDescriptor->activate(handle);

  890.                 } CARLA_SAFE_EXCEPTION("LADSPA activate");

  891.             }

  892.         }

  893.     }

  894. 

  895.     void deactivate() noexcept override

  896.     {

  897.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  898. 

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

  900.         {

  901.             for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  902.             {

  903.                 LADSPA_Handle const handle(it.getValue(nullptr));

  904.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  905. 

  906.                 try {

  907.                     fDescriptor->deactivate(handle);

  908.                 } CARLA_SAFE_EXCEPTION("LADSPA deactivate");

  909.             }

  910.         }

  911.     }

  912. 

  913.     void process(const float** const audioIn, float** const audioOut, const float** const, float** const, const uint32_t frames) override

  914.     {

  915.         // --------------------------------------------------------------------------------------------------------

  916.         // Check if active

  917. 

  918.         if (! pData->active)

  919.         {

  920.             // disable any output sound

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

  922.                 FloatVectorOperations::clear(audioOut[i], static_cast<int>(frames));

  923.             return;

  924.         }

  925. 

  926.         // --------------------------------------------------------------------------------------------------------

  927.         // Event Input and Processing

  928. 

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

  930.         {

  931.             // ----------------------------------------------------------------------------------------------------

  932.             // Event Input (System)

  933. 

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

  935. 

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

  937.             uint32_t timeOffset = 0;

  938. 

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

  940.             {

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

  942. 

  943.                 if (event.time >= frames)

  944.                     continue;

  945. 

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

  947. 

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

  949.                 {

  950.                     if (processSingle(audioIn, audioOut, event.time - timeOffset, timeOffset))

  951.                         timeOffset = event.time;

  952.                 }

  953. 

  954.                 switch (event.type)

  955.                 {

  956.                 case kEngineEventTypeNull:

  957.                     break;

  958. 

  959.                 case kEngineEventTypeControl: {

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

  961. 

  962.                     switch (ctrlEvent.type)

  963.                     {

  964.                     case kEngineControlEventTypeNull:

  965.                         break;

  966. 

  967.                     case kEngineControlEventTypeParameter: {

  968. #ifndef BUILD_BRIDGE

  969.                         // Control backend stuff

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

  971.                         {

  972.                             float value;

  973. 

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

  975.                             {

  976.                                 value = ctrlEvent.value;

  977.                                 setDryWet(value, false, false);

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

  979.                                 break;

  980.                             }

  981. 

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

  983.                             {

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

  985.                                 setVolume(value, false, false);

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

  987.                                 break;

  988.                             }

  989. 

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

  991.                             {

  992.                                 float left, right;

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

  994. 

  995.                                 if (value < 0.0f)

  996.                                 {

  997.                                     left  = -1.0f;

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

  999.                                 }

  1000.                                 else if (value > 0.0f)

  1001.                                 {

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

  1003.                                     right = 1.0f;

  1004.                                 }

  1005.                                 else

  1006.                                 {

  1007.                                     left  = -1.0f;

  1008.                                     right = 1.0f;

  1009.                                 }

  1010. 

  1011.                                 setBalanceLeft(left, false, false);

  1012.                                 setBalanceRight(right, false, false);

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

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

  1015.                                 break;

  1016.                             }

  1017.                         }

  1018. #endif

  1019.                         // Control plugin parameters

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

  1021.                         {

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

  1023.                                 continue;

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

  1025.                                 continue;

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

  1027.                                 continue;

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

  1029.                                 continue;

  1030. 

  1031.                             float value;

  1032. 

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

  1034.                             {

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

  1036.                             }

  1037.                             else

  1038.                             {

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

  1040. 

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

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

  1043.                             }

  1044. 

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

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

  1047.                             break;

  1048.                         }

  1049.                         break;

  1050.                     } // case kEngineControlEventTypeParameter

  1051. 

  1052.                     case kEngineControlEventTypeMidiBank:

  1053.                     case kEngineControlEventTypeMidiProgram:

  1054.                     case kEngineControlEventTypeAllSoundOff:

  1055.                     case kEngineControlEventTypeAllNotesOff:

  1056.                         break;

  1057.                     } // switch (ctrlEvent.type)

  1058.                     break;

  1059.                 } // case kEngineEventTypeControl

  1060. 

  1061.                 case kEngineEventTypeMidi:

  1062.                     break;

  1063.                 } // switch (event.type)

  1064.             }

  1065. 

  1066.             pData->postRtEvents.trySplice();

  1067. 

  1068.             if (frames > timeOffset)

  1069.                 processSingle(audioIn, audioOut, frames - timeOffset, timeOffset);

  1070. 

  1071.         } // End of Event Input and Processing

  1072. 

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

  1074.         // Plugin processing (no events)

  1075. 

  1076.         else

  1077.         {

  1078.             processSingle(audioIn, audioOut, frames, 0);

  1079. 

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

  1081. 

  1082.         // --------------------------------------------------------------------------------------------------------

  1083.         // Control Output

  1084. 

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

  1086.         {

  1087.             uint8_t  channel;

  1088.             uint16_t param;

  1089.             float    value;

  1090. 

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

  1092.             {

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

  1094.                     continue;

  1095. 

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

  1097. 

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

  1099.                 {

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

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

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

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

  1104.                 }

  1105.             }

  1106.         } // End of Control Output

  1107.     }

  1108. 

  1109.     bool processSingle(const float** const audioIn, float** const audioOut, const uint32_t frames,

  1110.                        const uint32_t timeOffset)

  1111.     {

  1112.         CARLA_SAFE_ASSERT_RETURN(frames > 0, false);

  1113. 

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

  1115.         {

  1116.             CARLA_SAFE_ASSERT_RETURN(audioIn != nullptr, false);

  1117.         }

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

  1119.         {

  1120.             CARLA_SAFE_ASSERT_RETURN(audioOut != nullptr, false);

  1121.         }

  1122. 

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

  1124.         // Try lock, silence otherwise

  1125. 

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

  1127.         {

  1128.             pData->singleMutex.lock();

  1129.         }

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

  1131.         {

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

  1133.             {

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

  1135.                     audioOut[i][k+timeOffset] = 0.0f;

  1136.             }

  1137. 

  1138.             return false;

  1139.         }

  1140. 

  1141.         const int iframes(static_cast<int>(frames));

  1142. 

  1143.         // --------------------------------------------------------------------------------------------------------

  1144.         // Handle needsReset

  1145. 

  1146.         if (pData->needsReset)

  1147.         {

  1148.             if (pData->latency.frames > 0)

  1149.             {

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

  1151.                     FloatVectorOperations::clear(pData->latency.buffers[i], static_cast<int>(pData->latency.frames));

  1152.             }

  1153. 

  1154.             pData->needsReset = false;

  1155.         }

  1156. 

  1157.         // --------------------------------------------------------------------------------------------------------

  1158.         // Set audio buffers

  1159. 

  1160.         const bool customMonoOut   = pData->audioOut.count == 2 && fForcedStereoOut && ! fForcedStereoIn;

  1161.         const bool customStereoOut = pData->audioOut.count == 2 && fForcedStereoIn  && ! fForcedStereoOut;

  1162. 

  1163.         if (! customMonoOut)

  1164.         {

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

  1166.                 FloatVectorOperations::clear(fAudioOutBuffers[i], iframes);

  1167.         }

  1168. 

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

  1170.             FloatVectorOperations::copy(fAudioInBuffers[i], audioIn[i]+timeOffset, iframes);

  1171. 

  1172.         // --------------------------------------------------------------------------------------------------------

  1173.         // Run plugin

  1174. 

  1175.         uint instn = 0;

  1176.         for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next(), ++instn)

  1177.         {

  1178.             LADSPA_Handle const handle(it.getValue(nullptr));

  1179.             CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1180. 

  1181.             // ----------------------------------------------------------------------------------------------------

  1182.             // Mixdown for forced stereo

  1183. 

  1184.             if (customMonoOut)

  1185.                 FloatVectorOperations::clear(fAudioOutBuffers[instn], iframes);

  1186. 

  1187.             // ----------------------------------------------------------------------------------------------------

  1188.             // Run it

  1189. 

  1190.             try {

  1191.                 fDescriptor->run(handle, frames);

  1192.             } CARLA_SAFE_EXCEPTION("LADSPA run");

  1193. 

  1194.             // ----------------------------------------------------------------------------------------------------

  1195.             // Mixdown for forced stereo

  1196. 

  1197.             if (customMonoOut)

  1198.                 FloatVectorOperations::multiply(fAudioOutBuffers[instn], 0.5f, iframes);

  1199.             else if (customStereoOut)

  1200.                 FloatVectorOperations::copy(fExtraStereoBuffer[instn], fAudioOutBuffers[instn], iframes);

  1201.         }

  1202. 

  1203.         if (customStereoOut)

  1204.         {

  1205.             FloatVectorOperations::copy(fAudioOutBuffers[0], fExtraStereoBuffer[0], iframes);

  1206.             FloatVectorOperations::copy(fAudioOutBuffers[1], fExtraStereoBuffer[1], iframes);

  1207.         }

  1208. 

  1209. #ifndef BUILD_BRIDGE

  1210.         // --------------------------------------------------------------------------------------------------------

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

  1212. 

  1213.         {

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

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

  1216.             const bool isMono    = (pData->audioIn.count == 1);

  1217. 

  1218.             bool isPair;

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

  1220. 

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

  1222.             {

  1223.                 // Dry/Wet

  1224.                 if (doDryWet)

  1225.                 {

  1226.                     const uint32_t c = isMono ? 0 : i;

  1227. 

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

  1229.                     {

  1230.                         if (k < pData->latency.frames)

  1231.                             bufValue = pData->latency.buffers[c][k];

  1232.                         else if (pData->latency.frames < frames)

  1233.                             bufValue = fAudioInBuffers[c][k-pData->latency.frames];

  1234.                         else

  1235.                             bufValue = fAudioInBuffers[c][k];

  1236. 

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

  1238.                     }

  1239.                 }

  1240. 

  1241.                 // Balance

  1242.                 if (doBalance)

  1243.                 {

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

  1245. 

  1246.                     if (isPair)

  1247.                     {

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

  1249.                         FloatVectorOperations::copy(oldBufLeft, fAudioOutBuffers[i], iframes);

  1250.                     }

  1251. 

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

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

  1254. 

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

  1256.                     {

  1257.                         if (isPair)

  1258.                         {

  1259.                             // left

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

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

  1262.                         }

  1263.                         else

  1264.                         {

  1265.                             // right

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

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

  1268.                         }

  1269.                     }

  1270.                 }

  1271. 

  1272.                 // Volume (and buffer copy)

  1273.                 {

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

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

  1276.                 }

  1277.             }

  1278. 

  1279.         } // End of Post-processing

  1280. 

  1281. #else // BUILD_BRIDGE

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

  1283.         {

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

  1285.                 audioOut[i][k+timeOffset] = fAudioOutBuffers[i][k];

  1286.         }

  1287. #endif

  1288. 

  1289.         // --------------------------------------------------------------------------------------------------------

  1290.         // Save latency values for next callback

  1291. 

  1292.         if (const uint32_t latframes = pData->latency.frames)

  1293.         {

  1294.             CARLA_SAFE_ASSERT(timeOffset == 0);

  1295. 

  1296.             if (latframes <= frames)

  1297.             {

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

  1299.                     FloatVectorOperations::copy(pData->latency.buffers[i], audioIn[i]+(frames-latframes), static_cast<int>(latframes));

  1300.             }

  1301.             else

  1302.             {

  1303.                 const uint32_t diff = pData->latency.frames-frames;

  1304. 

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

  1306.                 {

  1307.                     // push back buffer by 'frames'

  1308.                     for (k=0; k < diff; ++k)

  1309.                         pData->latency.buffers[i][k] = pData->latency.buffers[i][k+frames];

  1310. 

  1311.                     // put current input at the end

  1312.                     for (uint32_t j=0; k < latframes; ++j, ++k)

  1313.                         pData->latency.buffers[i][k] = audioIn[i][j];

  1314.                 }

  1315.             }

  1316.         }

  1317. 

  1318.         // --------------------------------------------------------------------------------------------------------

  1319. 

  1320.         pData->singleMutex.unlock();

  1321.         return true;

  1322.     }

  1323. 

  1324.     void bufferSizeChanged(const uint32_t newBufferSize) override

  1325.     {

  1326.         CARLA_ASSERT_INT(newBufferSize > 0, newBufferSize);

  1327.         carla_debug("CarlaPluginLADSPA::bufferSizeChanged(%i) - start", newBufferSize);

  1328. 

  1329.         const int iBufferSize(static_cast<int>(newBufferSize));

  1330. 

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

  1332.         {

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

  1334.                 delete[] fAudioInBuffers[i];

  1335. 

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

  1337.             FloatVectorOperations::clear(fAudioInBuffers[i], iBufferSize);

  1338.         }

  1339. 

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

  1341.         {

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

  1343.                 delete[] fAudioOutBuffers[i];

  1344. 

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

  1346.             FloatVectorOperations::clear(fAudioOutBuffers[i], iBufferSize);

  1347.         }

  1348. 

  1349.         if (fExtraStereoBuffer[0] != nullptr)

  1350.         {

  1351.             delete[] fExtraStereoBuffer[0];

  1352.             fExtraStereoBuffer[0] = nullptr;

  1353.         }

  1354. 

  1355.         if (fExtraStereoBuffer[1] != nullptr)

  1356.         {

  1357.             delete[] fExtraStereoBuffer[1];

  1358.             fExtraStereoBuffer[1] = nullptr;

  1359.         }

  1360. 

  1361.         if (fForcedStereoIn && pData->audioOut.count == 2)

  1362.         {

  1363.             fExtraStereoBuffer[0] = new float[newBufferSize];

  1364.             fExtraStereoBuffer[1] = new float[newBufferSize];

  1365.             FloatVectorOperations::clear(fExtraStereoBuffer[0], iBufferSize);

  1366.             FloatVectorOperations::clear(fExtraStereoBuffer[1], iBufferSize);

  1367.         }

  1368. 

  1369.         reconnectAudioPorts();

  1370. 

  1371.         carla_debug("CarlaPluginLADSPA::bufferSizeChanged(%i) - end", newBufferSize);

  1372.     }

  1373. 

  1374.     void sampleRateChanged(const double newSampleRate) override

  1375.     {

  1376.         CARLA_ASSERT_INT(newSampleRate > 0.0, newSampleRate);

  1377.         carla_stdout("CarlaPluginLADSPA::sampleRateChanged(%g) - start", newSampleRate);

  1378. 

  1379.         if (pData->active)

  1380.             deactivate();

  1381. 

  1382.         const std::size_t instanceCount(fHandles.count());

  1383. 

  1384.         if (fDescriptor->cleanup == nullptr)

  1385.         {

  1386.             for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  1387.             {

  1388.                 LADSPA_Handle const handle(it.getValue(nullptr));

  1389.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1390. 

  1391.                 try {

  1392.                     fDescriptor->cleanup(handle);

  1393.                 } CARLA_SAFE_EXCEPTION("LADSPA cleanup");

  1394.             }

  1395.         }

  1396. 

  1397.         fHandles.clear();

  1398. 

  1399.         for (std::size_t i=0; i<instanceCount; ++i)

  1400.             addInstance();

  1401. 

  1402.         reconnectAudioPorts();

  1403. 

  1404.         if (pData->active)

  1405.             activate();

  1406. 

  1407.         carla_stdout("CarlaPluginLADSPA::sampleRateChanged(%g) - end", newSampleRate);

  1408.     }

  1409. 

  1410.     void reconnectAudioPorts() const noexcept

  1411.     {

  1412.         if (fForcedStereoIn)

  1413.         {

  1414.             if (LADSPA_Handle const handle = fHandles.getAt(0, nullptr))

  1415.             {

  1416.                 try {

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

  1418.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo input)");

  1419.             }

  1420. 

  1421.             if (LADSPA_Handle const handle = fHandles.getAt(1, nullptr))

  1422.             {

  1423.                 try {

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

  1425.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo input)");

  1426.             }

  1427.         }

  1428.         else

  1429.         {

  1430.             for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  1431.             {

  1432.                 LADSPA_Handle const handle(it.getValue(nullptr));

  1433.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1434. 

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

  1436.                 {

  1437.                     try {

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

  1439.                     } CARLA_SAFE_EXCEPTION("LADSPA connect_port (audio input)");

  1440.                 }

  1441.             }

  1442.         }

  1443. 

  1444.         if (fForcedStereoOut)

  1445.         {

  1446.             if (LADSPA_Handle const handle = fHandles.getAt(0, nullptr))

  1447.             {

  1448.                 try {

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

  1450.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo output)");

  1451.             }

  1452. 

  1453.             if (LADSPA_Handle const handle = fHandles.getAt(1, nullptr))

  1454.             {

  1455.                 try {

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

  1457.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo output)");

  1458.             }

  1459.         }

  1460.         else

  1461.         {

  1462.             for (LinkedList<LADSPA_Handle>::Itenerator it = fHandles.begin2(); it.valid(); it.next())

  1463.             {

  1464.                 LADSPA_Handle const handle(it.getValue(nullptr));

  1465.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1466. 

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

  1468.                 {

  1469.                     try {

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

  1471.                     } CARLA_SAFE_EXCEPTION("LADSPA connect_port (audio output)");

  1472.                 }

  1473.             }

  1474.         }

  1475.     }

  1476. 

  1477.     // -------------------------------------------------------------------

  1478.     // Plugin buffers

  1479. 

  1480.     void clearBuffers() noexcept override

  1481.     {

  1482.         carla_debug("CarlaPluginLADSPA::clearBuffers() - start");

  1483. 

  1484.         if (fAudioInBuffers != nullptr)

  1485.         {

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

  1487.             {

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

  1489.                 {

  1490.                     delete[] fAudioInBuffers[i];

  1491.                     fAudioInBuffers[i] = nullptr;

  1492.                 }

  1493.             }

  1494. 

  1495.             delete[] fAudioInBuffers;

  1496.             fAudioInBuffers = nullptr;

  1497.         }

  1498. 

  1499.         if (fAudioOutBuffers != nullptr)

  1500.         {

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

  1502.             {

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

  1504.                 {

  1505.                     delete[] fAudioOutBuffers[i];

  1506.                     fAudioOutBuffers[i] = nullptr;

  1507.                 }

  1508.             }

  1509. 

  1510.             delete[] fAudioOutBuffers;

  1511.             fAudioOutBuffers = nullptr;

  1512.         }

  1513. 

  1514.         if (fExtraStereoBuffer[0] != nullptr)

  1515.         {

  1516.             delete[] fExtraStereoBuffer[0];

  1517.             fExtraStereoBuffer[0] = nullptr;

  1518.         }

  1519. 

  1520.         if (fExtraStereoBuffer[1] != nullptr)

  1521.         {

  1522.             delete[] fExtraStereoBuffer[1];

  1523.             fExtraStereoBuffer[1] = nullptr;

  1524.         }

  1525. 

  1526.         if (fParamBuffers != nullptr)

  1527.         {

  1528.             delete[] fParamBuffers;

  1529.             fParamBuffers = nullptr;

  1530.         }

  1531. 

  1532.         CarlaPlugin::clearBuffers();

  1533. 

  1534.         carla_debug("CarlaPluginLADSPA::clearBuffers() - end");

  1535.     }

  1536. 

  1537.     // -------------------------------------------------------------------

  1538. 

  1539.     const void* getNativeDescriptor() const noexcept override

  1540.     {

  1541.         return fDescriptor;

  1542.     }

  1543. 

  1544.     const void* getExtraStuff() const noexcept override

  1545.     {

  1546.         return fRdfDescriptor;

  1547.     }

  1548. 

  1549.     // -------------------------------------------------------------------

  1550. 

  1551.     bool init(const char* const filename, const char* const name, const char* const label, const uint options,

  1552.               const LADSPA_RDF_Descriptor* const rdfDescriptor)

  1553.     {

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

  1555. 

  1556.         // ---------------------------------------------------------------

  1557.         // first checks

  1558. 

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

  1560.         {

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

  1562.             return false;

  1563.         }

  1564. 

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

  1566.         {

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

  1568.             return false;

  1569.         }

  1570. 

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

  1572.         {

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

  1574.             return false;

  1575.         }

  1576. 

  1577.         // ---------------------------------------------------------------

  1578.         // open DLL

  1579. 

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

  1581.         {

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

  1583.             return false;

  1584.         }

  1585. 

  1586.         // ---------------------------------------------------------------

  1587.         // get DLL main entry

  1588. 

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

  1590. 

  1591.         if (descFn == nullptr)

  1592.         {

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

  1594.             return false;

  1595.         }

  1596. 

  1597.         // ---------------------------------------------------------------

  1598.         // get descriptor that matches label

  1599. 

  1600.         for (ulong d=0;; ++d)

  1601.         {

  1602.             try {

  1603.                 fDescriptor = descFn(d);

  1604.             }

  1605.             catch(...) {

  1606.                 carla_stderr2("Caught exception when trying to get LADSPA descriptor");

  1607.                 fDescriptor = nullptr;

  1608.                 break;

  1609.             }

  1610. 

  1611.             if (fDescriptor == nullptr)

  1612.                 break;

  1613. 

  1614.             if (fDescriptor->Label == nullptr || fDescriptor->Label[0] == '\0')

  1615.             {

  1616.                 carla_stderr2("WARNING - Got an invalid label, will not use this plugin");

  1617.                 fDescriptor = nullptr;

  1618.                 break;

  1619.             }

  1620.             if (fDescriptor->run == nullptr)

  1621.             {

  1622.                 carla_stderr2("WARNING - Plugin has no run, cannot use it");

  1623.                 fDescriptor = nullptr;

  1624.                 break;

  1625.             }

  1626. 

  1627.             if (std::strcmp(fDescriptor->Label, label) == 0)

  1628.                 break;

  1629.         }

  1630. 

  1631.         if (fDescriptor == nullptr)

  1632.         {

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

  1634.             return false;

  1635.         }

  1636. 

  1637.         // ---------------------------------------------------------------

  1638.         // get info

  1639. 

  1640.         if (is_ladspa_rdf_descriptor_valid(rdfDescriptor, fDescriptor))

  1641.             fRdfDescriptor = ladspa_rdf_dup(rdfDescriptor);

  1642. 

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

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

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

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

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

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

  1649.         else

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

  1651. 

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

  1653. 

  1654.         // ---------------------------------------------------------------

  1655.         // register client

  1656. 

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

  1658. 

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

  1660.         {

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

  1662.             return false;

  1663.         }

  1664. 

  1665.         // ---------------------------------------------------------------

  1666.         // initialize plugin

  1667. 

  1668.         if (! addInstance())

  1669.             return false;

  1670. 

  1671.         // ---------------------------------------------------------------

  1672.         // find latency port index

  1673. 

  1674.         for (uint32_t i=0, iCtrl=0, count=getSafePortCount(); i<count; ++i)

  1675.         {

  1676.             const int portType(fDescriptor->PortDescriptors[i]);

  1677. 

  1678.             if (! LADSPA_IS_PORT_CONTROL(portType))

  1679.                 continue;

  1680. 

  1681.             const uint32_t index(iCtrl++);

  1682. 

  1683.             if (! LADSPA_IS_PORT_OUTPUT(portType))

  1684.                 continue;

  1685. 

  1686.             const char* const portName(fDescriptor->PortNames[i]);

  1687.             CARLA_SAFE_ASSERT_BREAK(portName != nullptr);

  1688. 

  1689.             if (std::strcmp(portName, "latency")  == 0 ||

  1690.                 std::strcmp(portName, "_latency") == 0)

  1691.             {

  1692.                 fLatencyIndex = static_cast<int32_t>(index);

  1693.                 break;

  1694.             }

  1695.         }

  1696. 

  1697.         // ---------------------------------------------------------------

  1698.         // check if this is dssi-vst

  1699. 

  1700.         fIsDssiVst = CarlaString(filename).contains("dssi-vst", true);

  1701. 

  1702.         // ---------------------------------------------------------------

  1703.         // set default options

  1704. 

  1705.         pData->options = 0x0;

  1706. 

  1707.         /**/ if (fLatencyIndex >= 0 || fIsDssiVst)

  1708.             pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1709.          else if (options & PLUGIN_OPTION_FIXED_BUFFERS)

  1710.             pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1711. 

  1712.         /**/ if (pData->engine->getOptions().forceStereo)

  1713.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  1714.          else if (options & PLUGIN_OPTION_FORCE_STEREO)

  1715.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  1716. 

  1717.         return true;

  1718.     }

  1719. 

  1720.     // -------------------------------------------------------------------

  1721. 

  1722. private:

  1723.     LinkedList<LADSPA_Handle>    fHandles;

  1724.     const LADSPA_Descriptor*     fDescriptor;

  1725.     const LADSPA_RDF_Descriptor* fRdfDescriptor;

  1726. 

  1727.     float** fAudioInBuffers;

  1728.     float** fAudioOutBuffers;

  1729.     float*  fExtraStereoBuffer[2]; // used only if forcedStereoIn and audioOut == 2

  1730.     float*  fParamBuffers;

  1731. 

  1732.     int32_t fLatencyIndex; // -1 if invalid

  1733.     bool    fForcedStereoIn;

  1734.     bool    fForcedStereoOut;

  1735.     bool    fIsDssiVst;

  1736. 

  1737.     // -------------------------------------------------------------------

  1738. 

  1739.     bool addInstance()

  1740.     {

  1741.         LADSPA_Handle handle;

  1742. 

  1743.         try {

  1744.             handle = fDescriptor->instantiate(fDescriptor, static_cast<ulong>(pData->engine->getSampleRate()));

  1745.         } CARLA_SAFE_EXCEPTION_RETURN_ERR("LADSPA instantiate", "Plugin failed to initialize");

  1746. 

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

  1748.         {

  1749.             const int32_t rindex(pData->param.data[i].rindex);

  1750.             CARLA_SAFE_ASSERT_CONTINUE(rindex >= 0);

  1751. 

  1752.             try {

  1753.                 fDescriptor->connect_port(handle, static_cast<ulong>(rindex), &fParamBuffers[i]);

  1754.             } CARLA_SAFE_EXCEPTION("LADSPA connect_port");

  1755.         }

  1756. 

  1757.         if (fHandles.append(handle))

  1758.             return true;

  1759. 

  1760.         try {

  1761.             fDescriptor->cleanup(handle);

  1762.         } CARLA_SAFE_EXCEPTION("LADSPA cleanup");

  1763. 

  1764.         pData->engine->setLastError("Out of memory");

  1765.         return false;

  1766.     }

  1767. 

  1768.     uint32_t getSafePortCount() const noexcept

  1769.     {

  1770.         if (fDescriptor->PortCount == 0)

  1771.             return 0;

  1772. 

  1773.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->PortDescriptors != nullptr, 0);

  1774.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->PortRangeHints != nullptr, 0);

  1775.         CARLA_SAFE_ASSERT_RETURN(fDescriptor->PortNames != nullptr, 0);

  1776. 

  1777.         return static_cast<uint32_t>(fDescriptor->PortCount);

  1778.     }

  1779. 

  1780.     bool getSeparatedParameterNameOrUnit(const char* const paramName, char* const strBuf, const bool wantName) const noexcept

  1781.     {

  1782.         if (_getSeparatedParameterNameOrUnitImpl(paramName, strBuf, wantName, true))

  1783.             return true;

  1784.         if (_getSeparatedParameterNameOrUnitImpl(paramName, strBuf, wantName, false))

  1785.             return true;

  1786.         return false;

  1787.     }

  1788. 

  1789.     static bool _getSeparatedParameterNameOrUnitImpl(const char* const paramName, char* const strBuf,

  1790.                                                      const bool wantName, const bool useBracket) noexcept

  1791.     {

  1792.         const char* const sepBracketStart(std::strstr(paramName, useBracket ? " [" : " ("));

  1793. 

  1794.         if (sepBracketStart == nullptr)

  1795.             return false;

  1796. 

  1797.         const char* const sepBracketEnd(std::strstr(sepBracketStart, useBracket ? "]" : ")"));

  1798. 

  1799.         if (sepBracketEnd == nullptr)

  1800.             return false;

  1801. 

  1802.         const std::size_t unitSize(static_cast<std::size_t>(sepBracketEnd-sepBracketStart-2));

  1803. 

  1804.         if (unitSize > 7) // very unlikely to have such big unit

  1805.             return false;

  1806. 

  1807.         const std::size_t sepIndex(std::strlen(paramName)-unitSize-3);

  1808. 

  1809.         // just in case

  1810.         if (sepIndex+2 >= STR_MAX)

  1811.             return false;

  1812. 

  1813.         if (wantName)

  1814.         {

  1815.             std::strncpy(strBuf, paramName, sepIndex);

  1816.             strBuf[sepIndex] = '\0';

  1817.         }

  1818.         else

  1819.         {

  1820.             std::strncpy(strBuf, paramName+(sepIndex+2), unitSize);

  1821.             strBuf[unitSize] = '\0';

  1822.         }

  1823. 

  1824.         return true;

  1825.     }

  1826. 

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

  1828. 

  1829.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaPluginLADSPA)

  1830. };

  1831. 

  1832. // -------------------------------------------------------------------------------------------------------------------

  1833. 

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

  1835. {

  1836.     carla_debug("CarlaPlugin::newLADSPA({%p, \"%s\", \"%s\", \"%s\", " P_INT64 ", %x}, %p)",

  1837.                 init.engine, init.filename, init.name, init.label, init.uniqueId, init.options, rdfDescriptor);

  1838. 

  1839.     CarlaPluginLADSPA* const plugin(new CarlaPluginLADSPA(init.engine, init.id));

  1840. 

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

  1842.     {

  1843.         delete plugin;

  1844.         return nullptr;

  1845.     }

  1846. 

  1847.     return plugin;

  1848. }

  1849. 

  1850. // -------------------------------------------------------------------------------------------------------------------

  1851. 

  1852. CARLA_BACKEND_END_NAMESPACE