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.
5025 Commits
17 Branches
341MB
Tree: 0f497f5f9a
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '0f497f5f9a'
${ noResults }
Carla/source/backend/plugin/CarlaPluginLADSPA.cpp

1849 lines
65KB
Raw Blame History 

  1. /*

  2.  * Carla Plugin, LADSPA implementation

  3.  * Copyright (C) 2011-2018 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.           fNeedsFixedBuffers(false)

  44.     {

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

  46. 

  47.         carla_zeroPointers(fExtraStereoBuffer, 2);

  48.     }

  49. 

  50.     ~CarlaPluginLADSPA() noexcept override

  51.     {

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

  53. 

  54.         pData->singleMutex.lock();

  55.         pData->masterMutex.lock();

  56. 

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

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

  59. 

  60.         if (pData->active)

  61.         {

  62.             deactivate();

  63.             pData->active = false;

  64.         }

  65. 

  66.         if (fDescriptor != nullptr)

  67.         {

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

  69.             {

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

  71.                 {

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

  73.                     CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  74. 

  75.                     try {

  76.                         fDescriptor->cleanup(handle);

  77.                     } CARLA_SAFE_EXCEPTION("LADSPA cleanup");

  78.                 }

  79.             }

  80. 

  81.             fHandles.clear();

  82.             fDescriptor = nullptr;

  83.         }

  84. 

  85.         if (fRdfDescriptor != nullptr)

  86.         {

  87.             delete fRdfDescriptor;

  88.             fRdfDescriptor = nullptr;

  89.         }

  90. 

  91.         clearBuffers();

  92.     }

  93. 

  94.     // -------------------------------------------------------------------

  95.     // Information (base)

  96. 

  97.     PluginType getType() const noexcept override

  98.     {

  99.         return PLUGIN_LADSPA;

  100.     }

  101. 

  102.     PluginCategory getCategory() const noexcept override

  103.     {

  104.         if (fRdfDescriptor != nullptr)

  105.         {

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

  107. 

  108.             // Specific Types

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

  110.                 return PLUGIN_CATEGORY_DELAY;

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

  112.                 return PLUGIN_CATEGORY_MODULATOR;

  113.             if (category & (LADSPA_PLUGIN_AMPLIFIER))

  114.                 return PLUGIN_CATEGORY_DYNAMICS;

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

  116.                 return PLUGIN_CATEGORY_UTILITY;

  117. 

  118.             // Pre-set LADSPA Types

  119.             if (LADSPA_IS_PLUGIN_DYNAMICS(category))

  120.                 return PLUGIN_CATEGORY_DYNAMICS;

  121.             if (LADSPA_IS_PLUGIN_AMPLITUDE(category))

  122.                 return PLUGIN_CATEGORY_MODULATOR;

  123.             if (LADSPA_IS_PLUGIN_EQ(category))

  124.                 return PLUGIN_CATEGORY_EQ;

  125.             if (LADSPA_IS_PLUGIN_FILTER(category))

  126.                 return PLUGIN_CATEGORY_FILTER;

  127.             if (LADSPA_IS_PLUGIN_FREQUENCY(category))

  128.                 return PLUGIN_CATEGORY_UTILITY;

  129.             if (LADSPA_IS_PLUGIN_SIMULATOR(category))

  130.                 return PLUGIN_CATEGORY_OTHER;

  131.             if (LADSPA_IS_PLUGIN_TIME(category))

  132.                 return PLUGIN_CATEGORY_DELAY;

  133.             if (LADSPA_IS_PLUGIN_GENERATOR(category))

  134.                 return PLUGIN_CATEGORY_SYNTH;

  135.         }

  136. 

  137.         return CarlaPlugin::getCategory();

  138.     }

  139. 

  140.     int64_t getUniqueId() const noexcept override

  141.     {

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

  143. 

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

  145.     }

  146. 

  147.     uint32_t getLatencyInFrames() const noexcept override

  148.     {

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

  150.             return 0;

  151. 

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

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

  154. 

  155.         return static_cast<uint32_t>(latency);

  156.     }

  157. 

  158.     // -------------------------------------------------------------------

  159.     // Information (count)

  160. 

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

  162.     {

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

  164. 

  165.         if (fRdfDescriptor == nullptr)

  166.             return 0;

  167. 

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

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

  170. 

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

  172.             return 0;

  173. 

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

  175.         return static_cast<uint32_t>(port.ScalePointCount);

  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.         // can't disable fixed buffers if using latency

  191.         if (fLatencyIndex == -1 && ! fNeedsFixedBuffers)

  192.             options |= PLUGIN_OPTION_FIXED_BUFFERS;

  193. 

  194.         // can't disable forced stereo if enabled in the engine

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

  196.             pass();

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

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

  199.             options |= PLUGIN_OPTION_FORCE_STEREO;

  200. 

  201.         return options;

  202.     }

  203. 

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

  205.     {

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

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

  208. 

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

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

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

  212. 

  213.         // not output, should be fine

  214.         return fParamBuffers[parameterId];

  215.     }

  216. 

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

  218.     {

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

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

  221. 

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

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

  224.         CARLA_SAFE_ASSERT_RETURN(rindex < static_cast<int32_t>(fRdfDescriptor->PortCount), 0.0f);

  225. 

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

  227.         CARLA_SAFE_ASSERT_RETURN(scalePointId < port.ScalePointCount, 0.0f);

  228. 

  229.         const LADSPA_RDF_ScalePoint& scalePoint(port.ScalePoints[scalePointId]);

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

  231.     }

  232. 

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

  234.     {

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

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

  237. 

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

  239.     }

  240. 

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

  242.     {

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

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

  245. 

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

  247.         {

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

  249.             return;

  250.         }

  251. 

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

  253.     }

  254. 

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

  256.     {

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

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

  259. 

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

  261.     }

  262. 

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

  264.     {

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

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

  267. 

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

  269.         {

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

  271.             return;

  272.         }

  273. 

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

  275.     }

  276. 

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

  278.     {

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

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

  281. 

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

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

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

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

  286. 

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

  288.             return;

  289. 

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

  291.     }

  292. 

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

  294.     {

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

  296. 

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

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

  299. 

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

  301.         {

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

  303. 

  304.             if (LADSPA_PORT_HAS_UNIT(port.Hints))

  305.             {

  306.                 switch (port.Unit)

  307.                 {

  308.                 case LADSPA_UNIT_DB:

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

  310.                     return;

  311.                 case LADSPA_UNIT_COEF:

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

  313.                     return;

  314.                 case LADSPA_UNIT_HZ:

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

  316.                     return;

  317.                 case LADSPA_UNIT_S:

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

  319.                     return;

  320.                 case LADSPA_UNIT_MS:

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

  322.                     return;

  323.                 case LADSPA_UNIT_MIN:

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

  325.                     return;

  326.                 }

  327.             }

  328.         }

  329. 

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

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

  332. 

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

  334.             return;

  335. 

  336.         nullStrBuf(strBuf);

  337.     }

  338. 

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

  340.     {

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

  342. 

  343.         if (fRdfDescriptor == nullptr)

  344.             return nullStrBuf(strBuf);

  345. 

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

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

  348. 

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

  350.             return nullStrBuf(strBuf);

  351. 

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

  353. 

  354.         if (! LADSPA_PORT_HAS_LABEL(port.Hints))

  355.             return nullStrBuf(strBuf);

  356. 

  357.         CARLA_SAFE_ASSERT_RETURN(port.Label != nullptr, nullStrBuf(strBuf));

  358. 

  359.         std::strncpy(strBuf, port.Label, STR_MAX);

  360.     }

  361. 

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

  363.     {

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

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

  366. 

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

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

  369.         CARLA_SAFE_ASSERT_RETURN(rindex < static_cast<int32_t>(fRdfDescriptor->PortCount), nullStrBuf(strBuf));

  370. 

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

  372.         CARLA_SAFE_ASSERT_RETURN(scalePointId < port.ScalePointCount, nullStrBuf(strBuf));

  373. 

  374.         const LADSPA_RDF_ScalePoint& scalePoint(port.ScalePoints[scalePointId]);

  375.         CARLA_SAFE_ASSERT_RETURN(scalePoint.Label != nullptr, nullStrBuf(strBuf));

  376. 

  377.         std::strncpy(strBuf, scalePoint.Label, STR_MAX);

  378.     }

  379. 

  380.     // -------------------------------------------------------------------

  381.     // Set data (state)

  382. 

  383.     // nothing

  384. 

  385.     // -------------------------------------------------------------------

  386.     // Set data (internal stuff)

  387. 

  388.     // nothing

  389. 

  390.     // -------------------------------------------------------------------

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

  392. 

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

  394.     {

  395.         CARLA_SAFE_ASSERT_RETURN(fParamBuffers != nullptr,);

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

  397. 

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

  399.         fParamBuffers[parameterId] = fixedValue;

  400. 

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

  402.     }

  403. 

  404.     void setParameterValueRT(const uint32_t parameterId, const float value) noexcept override

  405.     {

  406.         CARLA_SAFE_ASSERT_RETURN(fParamBuffers != nullptr,);

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

  408. 

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

  410.         fParamBuffers[parameterId] = fixedValue;

  411. 

  412.         CarlaPlugin::setParameterValueRT(parameterId, fixedValue);

  413.     }

  414. 

  415.     // -------------------------------------------------------------------

  416.     // Misc

  417. 

  418.     // nothing

  419. 

  420.     // -------------------------------------------------------------------

  421.     // Plugin state

  422. 

  423.     void reload() override

  424.     {

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

  426.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

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

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

  429. 

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

  431. 

  432.         // Safely disable plugin for reload

  433.         const ScopedDisabler sd(this);

  434. 

  435.         if (pData->active)

  436.             deactivate();

  437. 

  438.         clearBuffers();

  439. 

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

  441.         const uint32_t portCount(getSafePortCount());

  442. 

  443.         uint32_t aIns, aOuts, params;

  444.         aIns = aOuts = params = 0;

  445. 

  446.         bool forcedStereoIn, forcedStereoOut;

  447.         forcedStereoIn = forcedStereoOut = false;

  448. 

  449.         bool needsCtrlIn, needsCtrlOut;

  450.         needsCtrlIn = needsCtrlOut = false;

  451. 

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

  453.         {

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

  455. 

  456.             if (LADSPA_IS_PORT_AUDIO(portType))

  457.             {

  458.                 if (LADSPA_IS_PORT_INPUT(portType))

  459.                     aIns += 1;

  460.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  461.                     aOuts += 1;

  462.             }

  463.             else if (LADSPA_IS_PORT_CONTROL(portType))

  464.                 params += 1;

  465.         }

  466. 

  467.         if (pData->options & PLUGIN_OPTION_FORCE_STEREO)

  468.         {

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

  470.             {

  471.                 if (aIns == 1)

  472.                 {

  473.                     aIns = 2;

  474.                     forcedStereoIn = true;

  475.                 }

  476.                 if (aOuts == 1)

  477.                 {

  478.                     aOuts = 2;

  479.                     forcedStereoOut = true;

  480.                 }

  481.             }

  482.         }

  483. 

  484.         if (aIns > 0)

  485.         {

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

  487.             fAudioInBuffers = new float*[aIns];

  488. 

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

  490.                 fAudioInBuffers[i] = nullptr;

  491.         }

  492. 

  493.         if (aOuts > 0)

  494.         {

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

  496.             fAudioOutBuffers = new float*[aOuts];

  497.             needsCtrlIn = true;

  498. 

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

  500.                 fAudioOutBuffers[i] = nullptr;

  501.         }

  502. 

  503.         if (params > 0)

  504.         {

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

  506. 

  507.             fParamBuffers = new float[params];

  508.             carla_zeroFloats(fParamBuffers, params);

  509.         }

  510. 

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

  512.         CarlaString portName;

  513. 

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

  515.         {

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

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

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

  519. 

  520.             if (LADSPA_IS_PORT_AUDIO(portType))

  521.             {

  522.                 portName.clear();

  523. 

  524.                 if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  525.                 {

  526.                     portName  = pData->name;

  527.                     portName += ":";

  528.                 }

  529. 

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

  531.                 {

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

  533.                 }

  534.                 else

  535.                 {

  536.                     if (LADSPA_IS_PORT_INPUT(portType))

  537.                     {

  538.                         if (aIns > 1)

  539.                         {

  540.                             portName += "audio-in_";

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

  542.                         }

  543.                         else

  544.                             portName += "audio-in";

  545.                     }

  546.                     else

  547.                     {

  548.                         if (aOuts > 1)

  549.                         {

  550.                             portName += "audio-out_";

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

  552.                         }

  553.                         else

  554.                             portName += "audio-out";

  555.                     }

  556.                 }

  557. 

  558.                 portName.truncate(portNameSize);

  559. 

  560.                 if (LADSPA_IS_PORT_INPUT(portType))

  561.                 {

  562.                     const uint32_t j = iAudioIn++;

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

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

  565. 

  566.                     if (forcedStereoIn)

  567.                     {

  568.                         portName += "_2";

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

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

  571.                     }

  572.                 }

  573.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  574.                 {

  575.                     const uint32_t j = iAudioOut++;

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

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

  578. 

  579.                     if (forcedStereoOut)

  580.                     {

  581.                         portName += "_2";

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

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

  584.                     }

  585.                 }

  586.                 else

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

  588.             }

  589.             else if (LADSPA_IS_PORT_CONTROL(portType))

  590.             {

  591.                 const uint32_t j = iCtrl++;

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

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

  594. 

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

  596. 

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

  598. 

  599.                 // min value

  600.                 if (LADSPA_IS_HINT_BOUNDED_BELOW(portRangeHints.HintDescriptor))

  601.                     min = portRangeHints.LowerBound;

  602.                 else

  603.                     min = 0.0f;

  604. 

  605.                 // max value

  606.                 if (LADSPA_IS_HINT_BOUNDED_ABOVE(portRangeHints.HintDescriptor))

  607.                     max = portRangeHints.UpperBound;

  608.                 else

  609.                     max = 1.0f;

  610. 

  611.                 if (LADSPA_IS_HINT_SAMPLE_RATE(portRangeHints.HintDescriptor))

  612.                 {

  613.                     min *= sampleRate;

  614.                     max *= sampleRate;

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

  616.                 }

  617. 

  618.                 if (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_TOGGLED(portRangeHints.HintDescriptor))

  636.                 {

  637.                     step = max - min;

  638.                     stepSmall = step;

  639.                     stepLarge = step;

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

  641.                 }

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

  643.                 {

  644.                     step = 1.0f;

  645.                     stepSmall = 1.0f;

  646.                     stepLarge = 10.0f;

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

  648.                 }

  649.                 else

  650.                 {

  651.                     const float range = max - min;

  652.                     step = range/100.0f;

  653.                     stepSmall = range/1000.0f;

  654.                     stepLarge = range/10.0f;

  655.                 }

  656. 

  657.                 if (LADSPA_IS_PORT_INPUT(portType))

  658.                 {

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

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

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

  662.                     needsCtrlIn = true;

  663.                 }

  664.                 else if (LADSPA_IS_PORT_OUTPUT(portType))

  665.                 {

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

  667. 

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

  669.                     {

  670.                         min = 0.0f;

  671.                         max = sampleRate;

  672.                         def = 0.0f;

  673.                         step = 1.0f;

  674.                         stepSmall = 1.0f;

  675.                         stepLarge = 1.0f;

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

  677.                         CARLA_SAFE_ASSERT_INT2(fLatencyIndex == static_cast<int32_t>(j), fLatencyIndex, j);

  678.                     }

  679.                     else

  680.                     {

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

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

  683.                         needsCtrlOut = true;

  684.                     }

  685.                 }

  686.                 else

  687.                 {

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

  689.                 }

  690. 

  691.                 // extra parameter hints

  692.                 if (LADSPA_IS_HINT_LOGARITHMIC(portRangeHints.HintDescriptor))

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

  694. 

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

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

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

  698. 

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

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

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

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

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

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

  705. 

  706.                 // Start parameters in their default values

  707.                 fParamBuffers[j] = def;

  708. 

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

  710.                 {

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

  712.                     CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  713. 

  714.                     try {

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

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

  717.                 }

  718.             }

  719.             else

  720.             {

  721.                 // Not Audio or Control

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

  723. 

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

  725.                 {

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

  727.                     CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  728. 

  729.                     try {

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

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

  732.                 }

  733.             }

  734.         }

  735. 

  736.         if (needsCtrlIn)

  737.         {

  738.             portName.clear();

  739. 

  740.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  741.             {

  742.                 portName  = pData->name;

  743.                 portName += ":";

  744.             }

  745. 

  746.             portName += "events-in";

  747.             portName.truncate(portNameSize);

  748. 

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

  750.         }

  751. 

  752.         if (needsCtrlOut)

  753.         {

  754.             portName.clear();

  755. 

  756.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  757.             {

  758.                 portName  = pData->name;

  759.                 portName += ":";

  760.             }

  761. 

  762.             portName += "events-out";

  763.             portName.truncate(portNameSize);

  764. 

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

  766.         }

  767. 

  768.         if (forcedStereoIn || forcedStereoOut)

  769.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  770.         else

  771.             pData->options &= ~PLUGIN_OPTION_FORCE_STEREO;

  772. 

  773.         // plugin hints

  774.         pData->hints = 0x0;

  775. 

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

  777.             pData->hints |= PLUGIN_IS_RTSAFE;

  778. 

  779. #ifndef BUILD_BRIDGE_ALTERNATIVE_ARCH

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

  781.             pData->hints |= PLUGIN_CAN_DRYWET;

  782. 

  783.         if (aOuts > 0)

  784.             pData->hints |= PLUGIN_CAN_VOLUME;

  785. 

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

  787.             pData->hints |= PLUGIN_CAN_BALANCE;

  788. #endif

  789. 

  790.         // extra plugin hints

  791.         pData->extraHints = 0x0;

  792. 

  793.         // check initial latency

  794.         findInitialLatencyValue(aIns, aOuts);

  795. 

  796.         fForcedStereoIn  = forcedStereoIn;

  797.         fForcedStereoOut = forcedStereoOut;

  798. 

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

  800. 

  801.         if (pData->active)

  802.             activate();

  803. 

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

  805.     }

  806. 

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

  808.     {

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

  810.             return;

  811. 

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

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

  814.         CARLA_SAFE_ASSERT_RETURN(handle != nullptr,);

  815. 

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

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

  818. 

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

  820.         {

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

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

  823. 

  824.             try {

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

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

  827.         }

  828. 

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

  830.         {

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

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

  833. 

  834.             try {

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

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

  837.         }

  838. 

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

  840.         {

  841.             try {

  842.                 fDescriptor->activate(handle);

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

  844.         }

  845. 

  846.         try {

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

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

  849. 

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

  851.         {

  852.             try {

  853.                 fDescriptor->deactivate(handle);

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

  855.         }

  856. 

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

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

  859.         {

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

  861. #ifndef BUILD_BRIDGE

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

  863. #endif

  864.         }

  865.     }

  866. 

  867.     // -------------------------------------------------------------------

  868.     // Plugin processing

  869. 

  870.     void activate() noexcept override

  871.     {

  872.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  873. 

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

  875.         {

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

  877.             {

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

  879.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  880. 

  881.                 try {

  882.                     fDescriptor->activate(handle);

  883.                 } CARLA_SAFE_EXCEPTION("LADSPA activate");

  884.             }

  885.         }

  886.     }

  887. 

  888.     void deactivate() noexcept override

  889.     {

  890.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  891. 

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

  893.         {

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

  895.             {

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

  897.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  898. 

  899.                 try {

  900.                     fDescriptor->deactivate(handle);

  901.                 } CARLA_SAFE_EXCEPTION("LADSPA deactivate");

  902.             }

  903.         }

  904.     }

  905. 

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

  907.     {

  908.         // --------------------------------------------------------------------------------------------------------

  909.         // Check if active

  910. 

  911.         if (! pData->active)

  912.         {

  913.             // disable any output sound

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

  915.                 carla_zeroFloats(audioOut[i], frames);

  916.             return;

  917.         }

  918. 

  919.         // --------------------------------------------------------------------------------------------------------

  920.         // Check if needs reset

  921. 

  922.         if (pData->needsReset)

  923.         {

  924.             // nothing to do

  925.             pData->needsReset = false;

  926.         }

  927. 

  928.         // --------------------------------------------------------------------------------------------------------

  929.         // Event Input and Processing

  930. 

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

  932.         {

  933.             // ----------------------------------------------------------------------------------------------------

  934.             // Event Input (System)

  935. 

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

  937. 

  938.             uint32_t timeOffset = 0;

  939. 

  940.             for (uint32_t i=0, numEvents=pData->event.portIn->getEventCount(); i < numEvents; ++i)

  941.             {

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

  943. 

  944.                 uint32_t eventTime = event.time;

  945.                 CARLA_SAFE_ASSERT_UINT2_CONTINUE(eventTime < frames, eventTime, frames);

  946. 

  947.                 if (eventTime < timeOffset)

  948.                 {

  949.                     carla_stderr2("Timing error, eventTime:%u < timeOffset:%u for '%s'",

  950.                                   eventTime, timeOffset, pData->name);

  951.                     eventTime = timeOffset;

  952.                 }

  953. 

  954.                 if (isSampleAccurate && eventTime > timeOffset)

  955.                 {

  956.                     if (processSingle(audioIn, audioOut, eventTime - timeOffset, timeOffset))

  957.                         timeOffset = eventTime;

  958.                 }

  959. 

  960.                 switch (event.type)

  961.                 {

  962.                 case kEngineEventTypeNull:

  963.                     break;

  964. 

  965.                 case kEngineEventTypeControl: {

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

  967. 

  968.                     switch (ctrlEvent.type)

  969.                     {

  970.                     case kEngineControlEventTypeNull:

  971.                         break;

  972. 

  973.                     case kEngineControlEventTypeParameter: {

  974. #ifndef BUILD_BRIDGE_ALTERNATIVE_ARCH

  975.                         // Control backend stuff

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

  977.                         {

  978.                             float value;

  979. 

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

  981.                             {

  982.                                 value = ctrlEvent.value;

  983.                                 setDryWetRT(value);

  984.                             }

  985. 

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

  987.                             {

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

  989.                                 setVolumeRT(value);

  990.                             }

  991. 

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

  993.                             {

  994.                                 float left, right;

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

  996. 

  997.                                 if (value < 0.0f)

  998.                                 {

  999.                                     left  = -1.0f;

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

  1001.                                 }

  1002.                                 else if (value > 0.0f)

  1003.                                 {

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

  1005.                                     right = 1.0f;

  1006.                                 }

  1007.                                 else

  1008.                                 {

  1009.                                     left  = -1.0f;

  1010.                                     right = 1.0f;

  1011.                                 }

  1012. 

  1013.                                 setBalanceLeftRT(left);

  1014.                                 setBalanceRightRT(right);

  1015.                             }

  1016.                         }

  1017. #endif

  1018.                         // Control plugin parameters

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

  1020.                         {

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

  1022.                                 continue;

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

  1024.                                 continue;

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

  1026.                                 continue;

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

  1028.                                 continue;

  1029. 

  1030.                             float value;

  1031. 

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

  1033.                             {

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

  1035.                             }

  1036.                             else

  1037.                             {

  1038.                                 if (pData->param.data[k].hints & PARAMETER_IS_LOGARITHMIC)

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

  1040.                                 else

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

  1042. 

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

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

  1045.                             }

  1046. 

  1047.                             setParameterValueRT(k, value);

  1048.                         }

  1049. 

  1050.                         break;

  1051.                     } // case kEngineControlEventTypeParameter

  1052. 

  1053.                     case kEngineControlEventTypeMidiBank:

  1054.                     case kEngineControlEventTypeMidiProgram:

  1055.                     case kEngineControlEventTypeAllSoundOff:

  1056.                     case kEngineControlEventTypeAllNotesOff:

  1057.                         break;

  1058.                     } // switch (ctrlEvent.type)

  1059.                     break;

  1060.                 } // case kEngineEventTypeControl

  1061. 

  1062.                 case kEngineEventTypeMidi:

  1063.                     break;

  1064.                 } // switch (event.type)

  1065.             }

  1066. 

  1067.             pData->postRtEvents.trySplice();

  1068. 

  1069.             if (frames > timeOffset)

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

  1071. 

  1072.         } // End of Event Input and Processing

  1073. 

  1074.         // --------------------------------------------------------------------------------------------------------

  1075.         // Plugin processing (no events)

  1076. 

  1077.         else

  1078.         {

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

  1080. 

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

  1082. 

  1083.         // --------------------------------------------------------------------------------------------------------

  1084.         // Control Output

  1085. 

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

  1087.         {

  1088.             uint8_t  channel;

  1089.             uint16_t param;

  1090.             float    value;

  1091. 

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

  1093.             {

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

  1095.                     continue;

  1096. 

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

  1098. 

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

  1100.                 {

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

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

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

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

  1105.                 }

  1106.             }

  1107.         } // End of Control Output

  1108.     }

  1109. 

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

  1111.                        const uint32_t timeOffset)

  1112.     {

  1113.         CARLA_SAFE_ASSERT_RETURN(frames > 0, false);

  1114. 

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

  1116.         {

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

  1118.         }

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

  1120.         {

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

  1122.         }

  1123. 

  1124.         // --------------------------------------------------------------------------------------------------------

  1125.         // Try lock, silence otherwise

  1126. 

  1127. #ifndef STOAT_TEST_BUILD

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

  1129.         {

  1130.             pData->singleMutex.lock();

  1131.         }

  1132.         else

  1133. #endif

  1134.         if (! pData->singleMutex.tryLock())

  1135.         {

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

  1137.             {

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

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

  1140.             }

  1141. 

  1142.             return false;

  1143.         }

  1144. 

  1145.         // --------------------------------------------------------------------------------------------------------

  1146.         // Set audio buffers

  1147. 

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

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

  1150. 

  1151.         if (! customMonoOut)

  1152.         {

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

  1154.                 carla_zeroFloats(fAudioOutBuffers[i], frames);

  1155.         }

  1156. 

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

  1158.             carla_copyFloats(fAudioInBuffers[i], audioIn[i]+timeOffset, frames);

  1159. 

  1160.         // --------------------------------------------------------------------------------------------------------

  1161.         // Run plugin

  1162. 

  1163.         uint instn = 0;

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

  1165.         {

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

  1167.             CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1168. 

  1169.             // ----------------------------------------------------------------------------------------------------

  1170.             // Mixdown for forced stereo

  1171. 

  1172.             if (customMonoOut)

  1173.                 carla_zeroFloats(fAudioOutBuffers[instn], frames);

  1174. 

  1175.             // ----------------------------------------------------------------------------------------------------

  1176.             // Run it

  1177. 

  1178.             try {

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

  1180.             } CARLA_SAFE_EXCEPTION("LADSPA run");

  1181. 

  1182.             // ----------------------------------------------------------------------------------------------------

  1183.             // Mixdown for forced stereo

  1184. 

  1185.             if (customMonoOut)

  1186.                 carla_multiply(fAudioOutBuffers[instn], 0.5f, frames);

  1187.             else if (customStereoOut)

  1188.                 carla_copyFloats(fExtraStereoBuffer[instn], fAudioOutBuffers[instn], frames);

  1189.         }

  1190. 

  1191.         if (customStereoOut)

  1192.         {

  1193.             carla_copyFloats(fAudioOutBuffers[0], fExtraStereoBuffer[0], frames);

  1194.             carla_copyFloats(fAudioOutBuffers[1], fExtraStereoBuffer[1], frames);

  1195.         }

  1196. 

  1197. #ifndef BUILD_BRIDGE_ALTERNATIVE_ARCH

  1198.         // --------------------------------------------------------------------------------------------------------

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

  1200. 

  1201.         {

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

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

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

  1205. 

  1206.             bool isPair;

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

  1208. 

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

  1210.             {

  1211.                 // Dry/Wet

  1212.                 if (doDryWet)

  1213.                 {

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

  1215. 

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

  1217.                     {

  1218. # ifndef BUILD_BRIDGE

  1219.                         if (k < pData->latency.frames && pData->latency.buffers != nullptr)

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

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

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

  1223.                         else

  1224. # endif

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

  1226. 

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

  1228.                     }

  1229.                 }

  1230. 

  1231.                 // Balance

  1232.                 if (doBalance)

  1233.                 {

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

  1235. 

  1236.                     if (isPair)

  1237.                     {

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

  1239.                         carla_copyFloats(oldBufLeft, fAudioOutBuffers[i], frames);

  1240.                     }

  1241. 

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

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

  1244. 

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

  1246.                     {

  1247.                         if (isPair)

  1248.                         {

  1249.                             // left

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

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

  1252.                         }

  1253.                         else

  1254.                         {

  1255.                             // right

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

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

  1258.                         }

  1259.                     }

  1260.                 }

  1261. 

  1262.                 // Volume (and buffer copy)

  1263.                 {

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

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

  1266.                 }

  1267.             }

  1268. 

  1269.         } // End of Post-processing

  1270. 

  1271. # ifndef BUILD_BRIDGE

  1272.         // --------------------------------------------------------------------------------------------------------

  1273.         // Save latency values for next callback

  1274. 

  1275.         if (pData->latency.frames != 0 && pData->latency.buffers != nullptr)

  1276.         {

  1277.             CARLA_SAFE_ASSERT(timeOffset == 0);

  1278.             const uint32_t latframes = pData->latency.frames;

  1279. 

  1280.             if (latframes <= frames)

  1281.             {

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

  1283.                     carla_copyFloats(pData->latency.buffers[i], audioIn[i]+(frames-latframes), latframes);

  1284.             }

  1285.             else

  1286.             {

  1287.                 const uint32_t diff = latframes - frames;

  1288. 

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

  1290.                 {

  1291.                     // push back buffer by 'frames'

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

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

  1294. 

  1295.                     // put current input at the end

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

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

  1298.                 }

  1299.             }

  1300.         }

  1301. # endif

  1302. #else // BUILD_BRIDGE_ALTERNATIVE_ARCH

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

  1304.         {

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

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

  1307.         }

  1308. #endif

  1309. 

  1310.         // --------------------------------------------------------------------------------------------------------

  1311. 

  1312.         pData->singleMutex.unlock();

  1313.         return true;

  1314.     }

  1315. 

  1316.     void bufferSizeChanged(const uint32_t newBufferSize) override

  1317.     {

  1318.         CARLA_ASSERT_INT(newBufferSize > 0, newBufferSize);

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

  1320. 

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

  1322.         {

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

  1324.                 delete[] fAudioInBuffers[i];

  1325. 

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

  1327.             carla_zeroFloats(fAudioInBuffers[i], newBufferSize);

  1328.         }

  1329. 

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

  1331.         {

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

  1333.                 delete[] fAudioOutBuffers[i];

  1334. 

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

  1336.             carla_zeroFloats(fAudioOutBuffers[i], newBufferSize);

  1337.         }

  1338. 

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

  1340.         {

  1341.             delete[] fExtraStereoBuffer[0];

  1342.             fExtraStereoBuffer[0] = nullptr;

  1343.         }

  1344. 

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

  1346.         {

  1347.             delete[] fExtraStereoBuffer[1];

  1348.             fExtraStereoBuffer[1] = nullptr;

  1349.         }

  1350. 

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

  1352.         {

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

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

  1355.             carla_zeroFloats(fExtraStereoBuffer[0], newBufferSize);

  1356.             carla_zeroFloats(fExtraStereoBuffer[1], newBufferSize);

  1357.         }

  1358. 

  1359.         reconnectAudioPorts();

  1360. 

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

  1362.     }

  1363. 

  1364.     void sampleRateChanged(const double newSampleRate) override

  1365.     {

  1366.         CARLA_ASSERT_INT(newSampleRate > 0.0, newSampleRate);

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

  1368. 

  1369.         if (pData->active)

  1370.             deactivate();

  1371. 

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

  1373. 

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

  1375.         {

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

  1377.             {

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

  1379.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1380. 

  1381.                 try {

  1382.                     fDescriptor->cleanup(handle);

  1383.                 } CARLA_SAFE_EXCEPTION("LADSPA cleanup");

  1384.             }

  1385.         }

  1386. 

  1387.         fHandles.clear();

  1388. 

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

  1390.             addInstance();

  1391. 

  1392.         reconnectAudioPorts();

  1393. 

  1394.         if (pData->active)

  1395.             activate();

  1396. 

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

  1398.     }

  1399. 

  1400.     void reconnectAudioPorts() const noexcept

  1401.     {

  1402.         if (fForcedStereoIn)

  1403.         {

  1404.             if (LADSPA_Handle const handle = fHandles.getFirst(nullptr))

  1405.             {

  1406.                 try {

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

  1408.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo input, first)");

  1409.             }

  1410. 

  1411.             if (LADSPA_Handle const handle = fHandles.getLast(nullptr))

  1412.             {

  1413.                 try {

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

  1415.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo input, last)");

  1416.             }

  1417.         }

  1418.         else

  1419.         {

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

  1421.             {

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

  1423.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1424. 

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

  1426.                 {

  1427.                     try {

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

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

  1430.                 }

  1431.             }

  1432.         }

  1433. 

  1434.         if (fForcedStereoOut)

  1435.         {

  1436.             if (LADSPA_Handle const handle = fHandles.getFirst(nullptr))

  1437.             {

  1438.                 try {

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

  1440.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo output, first)");

  1441.             }

  1442. 

  1443.             if (LADSPA_Handle const handle = fHandles.getLast(nullptr))

  1444.             {

  1445.                 try {

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

  1447.                 } CARLA_SAFE_EXCEPTION("LADSPA connect_port (forced stereo output, last)");

  1448.             }

  1449.         }

  1450.         else

  1451.         {

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

  1453.             {

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

  1455.                 CARLA_SAFE_ASSERT_CONTINUE(handle != nullptr);

  1456. 

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

  1458.                 {

  1459.                     try {

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

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

  1462.                 }

  1463.             }

  1464.         }

  1465.     }

  1466. 

  1467.     // -------------------------------------------------------------------

  1468.     // Plugin buffers

  1469. 

  1470.     void clearBuffers() noexcept override

  1471.     {

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

  1473. 

  1474.         if (fAudioInBuffers != nullptr)

  1475.         {

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

  1477.             {

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

  1479.                 {

  1480.                     delete[] fAudioInBuffers[i];

  1481.                     fAudioInBuffers[i] = nullptr;

  1482.                 }

  1483.             }

  1484. 

  1485.             delete[] fAudioInBuffers;

  1486.             fAudioInBuffers = nullptr;

  1487.         }

  1488. 

  1489.         if (fAudioOutBuffers != nullptr)

  1490.         {

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

  1492.             {

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

  1494.                 {

  1495.                     delete[] fAudioOutBuffers[i];

  1496.                     fAudioOutBuffers[i] = nullptr;

  1497.                 }

  1498.             }

  1499. 

  1500.             delete[] fAudioOutBuffers;

  1501.             fAudioOutBuffers = nullptr;

  1502.         }

  1503. 

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

  1505.         {

  1506.             delete[] fExtraStereoBuffer[0];

  1507.             fExtraStereoBuffer[0] = nullptr;

  1508.         }

  1509. 

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

  1511.         {

  1512.             delete[] fExtraStereoBuffer[1];

  1513.             fExtraStereoBuffer[1] = nullptr;

  1514.         }

  1515. 

  1516.         if (fParamBuffers != nullptr)

  1517.         {

  1518.             delete[] fParamBuffers;

  1519.             fParamBuffers = nullptr;

  1520.         }

  1521. 

  1522.         CarlaPlugin::clearBuffers();

  1523. 

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

  1525.     }

  1526. 

  1527.     // -------------------------------------------------------------------

  1528. 

  1529.     const void* getNativeDescriptor() const noexcept override

  1530.     {

  1531.         return fDescriptor;

  1532.     }

  1533. 

  1534.     const void* getExtraStuff() const noexcept override

  1535.     {

  1536.         return fRdfDescriptor;

  1537.     }

  1538. 

  1539.     // -------------------------------------------------------------------

  1540. 

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

  1542.               const LADSPA_RDF_Descriptor* const rdfDescriptor)

  1543.     {

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

  1545. 

  1546.         // ---------------------------------------------------------------

  1547.         // first checks

  1548. 

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

  1550.         {

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

  1552.             return false;

  1553.         }

  1554. 

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

  1556.         {

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

  1558.             return false;

  1559.         }

  1560. 

  1561.         // ---------------------------------------------------------------

  1562.         // open DLL

  1563. 

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

  1565.         {

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

  1567.             return false;

  1568.         }

  1569. 

  1570.         // ---------------------------------------------------------------

  1571.         // get DLL main entry

  1572. 

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

  1574. 

  1575.         if (descFn == nullptr)

  1576.         {

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

  1578.             return false;

  1579.         }

  1580. 

  1581.         // ---------------------------------------------------------------

  1582.         // get descriptor that matches label

  1583. 

  1584.         // if label is null, get first valid plugin

  1585.         const bool nullLabel = (label == nullptr || label[0] == '\0');

  1586. 

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

  1588.         {

  1589.             try {

  1590.                 fDescriptor = descFn(d);

  1591.             }

  1592.             catch(...) {

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

  1594.                 fDescriptor = nullptr;

  1595.                 break;

  1596.             }

  1597. 

  1598.             if (fDescriptor == nullptr)

  1599.                 break;

  1600. 

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

  1602.             {

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

  1604.                 fDescriptor = nullptr;

  1605.                 break;

  1606.             }

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

  1608.             {

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

  1610.                 fDescriptor = nullptr;

  1611.                 break;

  1612.             }

  1613. 

  1614.             if (nullLabel || std::strcmp(fDescriptor->Label, label) == 0)

  1615.                 break;

  1616.         }

  1617. 

  1618.         if (fDescriptor == nullptr)

  1619.         {

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

  1621.             return false;

  1622.         }

  1623. 

  1624.         // ---------------------------------------------------------------

  1625.         // check for fixed buffer size requirement

  1626. 

  1627.         fNeedsFixedBuffers = CarlaString(filename).contains("dssi-vst", true);

  1628. 

  1629.         if (fNeedsFixedBuffers && ! pData->engine->usesConstantBufferSize())

  1630.         {

  1631.             pData->engine->setLastError("Cannot use this plugin under the current engine.\n"

  1632.                                         "The plugin requires a fixed block size which is not possible right now.");

  1633.             return false;

  1634.         }

  1635. 

  1636.         // ---------------------------------------------------------------

  1637.         // get info

  1638. 

  1639.         if (is_ladspa_rdf_descriptor_valid(rdfDescriptor, fDescriptor))

  1640.             fRdfDescriptor = ladspa_rdf_dup(rdfDescriptor);

  1641. 

  1642.         if (name == nullptr || name[0] == '\0')

  1643.         {

  1644.             /**/ if (fRdfDescriptor != nullptr && fRdfDescriptor->Title != nullptr && fRdfDescriptor->Title[0] != '\0')

  1645.                 name = fRdfDescriptor->Title;

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

  1647.                 name = fDescriptor->Name;

  1648.             else

  1649.                 name = fDescriptor->Label;

  1650.         }

  1651. 

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

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

  1654. 

  1655.         // ---------------------------------------------------------------

  1656.         // register client

  1657. 

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

  1659. 

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

  1661.         {

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

  1663.             return false;

  1664.         }

  1665. 

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

  1667.         // initialize plugin

  1668. 

  1669.         if (! addInstance())

  1670.             return false;

  1671. 

  1672.         // ---------------------------------------------------------------

  1673.         // find latency port index

  1674. 

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

  1676.         {

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

  1678. 

  1679.             if (! LADSPA_IS_PORT_CONTROL(portType))

  1680.                 continue;

  1681. 

  1682.             const uint32_t index(iCtrl++);

  1683. 

  1684.             if (! LADSPA_IS_PORT_OUTPUT(portType))

  1685.                 continue;

  1686. 

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

  1688.             CARLA_SAFE_ASSERT_BREAK(portName != nullptr);

  1689. 

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

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

  1692.             {

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

  1694.                 break;

  1695.             }

  1696.         }

  1697. 

  1698.         // ---------------------------------------------------------------

  1699.         // set default options

  1700. 

  1701.         pData->options = 0x0;

  1702. 

  1703.         /**/ if (fLatencyIndex >= 0 || fNeedsFixedBuffers)

  1704.             pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1705.          else if (options & PLUGIN_OPTION_FIXED_BUFFERS)

  1706.             pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1707. 

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

  1709.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  1710.          else if (options & PLUGIN_OPTION_FORCE_STEREO)

  1711.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  1712. 

  1713.         return true;

  1714.     }

  1715. 

  1716.     // -------------------------------------------------------------------

  1717. 

  1718. private:

  1719.     LinkedList<LADSPA_Handle>    fHandles;

  1720.     const LADSPA_Descriptor*     fDescriptor;

  1721.     const LADSPA_RDF_Descriptor* fRdfDescriptor;

  1722. 

  1723.     float** fAudioInBuffers;

  1724.     float** fAudioOutBuffers;

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

  1726.     float*  fParamBuffers;

  1727. 

  1728.     int32_t fLatencyIndex; // -1 if invalid

  1729.     bool    fForcedStereoIn;

  1730.     bool    fForcedStereoOut;

  1731.     bool    fNeedsFixedBuffers;

  1732. 

  1733.     // -------------------------------------------------------------------

  1734. 

  1735.     bool addInstance()

  1736.     {

  1737.         LADSPA_Handle handle;

  1738. 

  1739.         try {

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

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

  1742. 

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

  1744.         {

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

  1746.             CARLA_SAFE_ASSERT_CONTINUE(rindex >= 0);

  1747. 

  1748.             try {

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

  1750.             } CARLA_SAFE_EXCEPTION("LADSPA connect_port");

  1751.         }

  1752. 

  1753.         if (fHandles.append(handle))

  1754.             return true;

  1755. 

  1756.         try {

  1757.             fDescriptor->cleanup(handle);

  1758.         } CARLA_SAFE_EXCEPTION("LADSPA cleanup");

  1759. 

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

  1761.         return false;

  1762.     }

  1763. 

  1764.     uint32_t getSafePortCount() const noexcept

  1765.     {

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

  1767.             return 0;

  1768. 

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

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

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

  1772. 

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

  1774.     }

  1775. 

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

  1777.     {

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

  1779.             return true;

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

  1781.             return true;

  1782.         return false;

  1783.     }

  1784. 

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

  1786.                                                      const bool wantName, const bool useBracket) noexcept

  1787.     {

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

  1789. 

  1790.         if (sepBracketStart == nullptr)

  1791.             return false;

  1792. 

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

  1794. 

  1795.         if (sepBracketEnd == nullptr)

  1796.             return false;

  1797. 

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

  1799. 

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

  1801.             return false;

  1802. 

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

  1804. 

  1805.         // just in case

  1806.         if (sepIndex+2 >= STR_MAX)

  1807.             return false;

  1808. 

  1809.         if (wantName)

  1810.         {

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

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

  1813.         }

  1814.         else

  1815.         {

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

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

  1818.         }

  1819. 

  1820.         return true;

  1821.     }

  1822. 

  1823.     // -------------------------------------------------------------------

  1824. 

  1825.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaPluginLADSPA)

  1826. };

  1827. 

  1828. // -------------------------------------------------------------------------------------------------------------------

  1829. 

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

  1831. {

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

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

  1834. 

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

  1836. 

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

  1838.     {

  1839.         delete plugin;

  1840.         return nullptr;

  1841.     }

  1842. 

  1843.     return plugin;

  1844. }

  1845. 

  1846. // -------------------------------------------------------------------------------------------------------------------

  1847. 

  1848. CARLA_BACKEND_END_NAMESPACE