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

1644 lines
55KB
Raw Blame History 

  1. /*

  2.  * Carla LV2 Plugin

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

  4.  *

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

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

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

  8.  * the License, or any later version.

  9.  *

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

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

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

  13.  * GNU General Public License for more details.

  14.  *

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

  16.  */

  17. 

  18. #include "CarlaPluginInternal.hpp"

  19. #include "CarlaEngine.hpp"

  20. 

  21. #ifdef WANT_LV2

  22. 

  23. #include "CarlaLv2Utils.hpp"

  24. #include "CarlaLibUtils.hpp"

  25. #include "Lv2AtomQueue.hpp"

  26. 

  27. #include "../engine/CarlaEngineOsc.hpp"

  28. 

  29. extern "C" {

  30. #include "rtmempool/rtmempool-lv2.h"

  31. }

  32. 

  33. #include <QtCore/QDir>

  34. #include <QtCore/QUrl>

  35. 

  36. // -----------------------------------------------------

  37. 

  38. CARLA_BACKEND_START_NAMESPACE

  39. 

  40. #if 0

  41. }

  42. #endif

  43. 

  44. // Extra Parameter Hints

  45. const unsigned int PARAMETER_IS_STRICT_BOUNDS = 0x1000;

  46. const unsigned int PARAMETER_IS_TRIGGER       = 0x2000;

  47. 

  48. // LV2 Feature Ids

  49. const uint32_t kFeatureCount = 0;

  50. 

  51. // -----------------------------------------------------

  52. 

  53. class Lv2Plugin : public CarlaPlugin

  54. {

  55. public:

  56.     Lv2Plugin(CarlaEngine* const engine, const unsigned int id)

  57.         : CarlaPlugin(engine, id),

  58.           fHandle(nullptr),

  59.           fHandle2(nullptr),

  60.           fDescriptor(nullptr),

  61.           fRdfDescriptor(nullptr),

  62.           fAudioInBuffers(nullptr),

  63.           fAudioOutBuffers(nullptr),

  64.           fParamBuffers(nullptr)

  65.     {

  66.         carla_debug("Lv2Plugin::Lv2Plugin(%p, %i)", engine, id);

  67. 

  68.         carla_fill<LV2_Feature*>(fFeatures, kFeatureCount+1, nullptr);

  69. 

  70.         pData->osc.thread.setMode(CarlaPluginThread::PLUGIN_THREAD_LV2_GUI);

  71.     }

  72. 

  73.     ~Lv2Plugin() override

  74.     {

  75.         carla_debug("Lv2Plugin::~Lv2Plugin()");

  76. 

  77.         pData->singleMutex.lock();

  78.         pData->masterMutex.lock();

  79. 

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

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

  82. 

  83.         if (pData->active)

  84.         {

  85.             deactivate();

  86.             pData->active = false;

  87.         }

  88. 

  89.         if (fDescriptor != nullptr)

  90.         {

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

  92.             {

  93.                 if (fHandle != nullptr)

  94.                     fDescriptor->cleanup(fHandle);

  95.                 if (fHandle2 != nullptr)

  96.                     fDescriptor->cleanup(fHandle2);

  97.             }

  98. 

  99.             fHandle  = nullptr;

  100.             fHandle2 = nullptr;

  101.             fDescriptor = nullptr;

  102.         }

  103. 

  104.         if (fRdfDescriptor != nullptr)

  105.         {

  106.             delete fRdfDescriptor;

  107.             fRdfDescriptor = nullptr;

  108.         }

  109. 

  110.         clearBuffers();

  111.     }

  112. 

  113.     // -------------------------------------------------------------------

  114.     // Information (base)

  115. 

  116.     PluginType getType() const noexcept override

  117.     {

  118.         return PLUGIN_LV2;

  119.     }

  120. 

  121.     PluginCategory getCategory() const noexcept override

  122.     {

  123.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr, CarlaPlugin::getCategory());

  124. 

  125.         const LV2_Property cat1(fRdfDescriptor->Type[0]);

  126.         const LV2_Property cat2(fRdfDescriptor->Type[1]);

  127. 

  128.         if (LV2_IS_DELAY(cat1, cat2))

  129.             return PLUGIN_CATEGORY_DELAY;

  130.         if (LV2_IS_DISTORTION(cat1, cat2))

  131.             return PLUGIN_CATEGORY_OTHER;

  132.         if (LV2_IS_DYNAMICS(cat1, cat2))

  133.             return PLUGIN_CATEGORY_DYNAMICS;

  134.         if (LV2_IS_EQ(cat1, cat2))

  135.             return PLUGIN_CATEGORY_EQ;

  136.         if (LV2_IS_FILTER(cat1, cat2))

  137.             return PLUGIN_CATEGORY_FILTER;

  138.         if (LV2_IS_GENERATOR(cat1, cat2))

  139.             return PLUGIN_CATEGORY_SYNTH;

  140.         if (LV2_IS_MODULATOR(cat1, cat2))

  141.             return PLUGIN_CATEGORY_MODULATOR;

  142.         if (LV2_IS_REVERB(cat1, cat2))

  143.             return PLUGIN_CATEGORY_DELAY;

  144.         if (LV2_IS_SIMULATOR(cat1, cat2))

  145.             return PLUGIN_CATEGORY_OTHER;

  146.         if (LV2_IS_SPATIAL(cat1, cat2))

  147.             return PLUGIN_CATEGORY_OTHER;

  148.         if (LV2_IS_SPECTRAL(cat1, cat2))

  149.             return PLUGIN_CATEGORY_UTILITY;

  150.         if (LV2_IS_UTILITY(cat1, cat2))

  151.             return PLUGIN_CATEGORY_UTILITY;

  152. 

  153.         return CarlaPlugin::getCategory();

  154.     }

  155. 

  156.     long getUniqueId() const noexcept override

  157.     {

  158.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr, 0);

  159. 

  160.         return fRdfDescriptor->UniqueID;

  161.     }

  162. 

  163.     // -------------------------------------------------------------------

  164.     // Information (count)

  165. 

  166.     uint32_t getMidiInCount() const noexcept override

  167.     {

  168.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr, 0);

  169. 

  170.         uint32_t count = 0;

  171. 

  172.         for (uint32_t i=0; i < fRdfDescriptor->PortCount; ++i)

  173.         {

  174.             const LV2_Property portTypes(fRdfDescriptor->Ports[i].Types);

  175. 

  176.             if (LV2_IS_PORT_INPUT(portTypes) && LV2_PORT_SUPPORTS_MIDI_EVENT(portTypes))

  177.                 count += 1;

  178.         }

  179. 

  180.         return count;

  181.     }

  182. 

  183.     uint32_t getMidiOutCount() const noexcept override

  184.     {

  185.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr, 0);

  186. 

  187.         uint32_t count = 0;

  188. 

  189.         for (uint32_t i=0; i < fRdfDescriptor->PortCount; ++i)

  190.         {

  191.             const LV2_Property portTypes(fRdfDescriptor->Ports[i].Types);

  192. 

  193.             if (LV2_IS_PORT_OUTPUT(portTypes) && LV2_PORT_SUPPORTS_MIDI_EVENT(portTypes))

  194.                 count += 1;

  195.         }

  196. 

  197.         return count;

  198.     }

  199. 

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

  201.     {

  202.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr, 0);

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

  204. 

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

  206. 

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

  208.         {

  209.             const LV2_RDF_Port& port(fRdfDescriptor->Ports[rindex]);

  210.             return port.ScalePointCount;

  211.         }

  212. 

  213.         return 0;

  214.     }

  215. 

  216.     // -------------------------------------------------------------------

  217.     // Information (current data)

  218. 

  219.     // nothing

  220. 

  221.     // -------------------------------------------------------------------

  222.     // Information (per-plugin data)

  223. 

  224.     unsigned int getOptionsAvailable() const noexcept override

  225.     {

  226.         const uint32_t hasMidiIn(getMidiInCount() > 0);

  227. 

  228.         unsigned int options = 0x0;

  229. 

  230.         options |= PLUGIN_OPTION_MAP_PROGRAM_CHANGES;

  231. 

  232.         if (! (hasMidiIn || needsFixedBuffer()))

  233.             options |= PLUGIN_OPTION_FIXED_BUFFERS;

  234. 

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

  236.         {

  237.             if (pData->options & PLUGIN_OPTION_FORCE_STEREO)

  238.                 options |= PLUGIN_OPTION_FORCE_STEREO;

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

  240.                 options |= PLUGIN_OPTION_FORCE_STEREO;

  241.         }

  242. 

  243.         if (hasMidiIn)

  244.         {

  245.             options |= PLUGIN_OPTION_SEND_CONTROL_CHANGES;

  246.             options |= PLUGIN_OPTION_SEND_CHANNEL_PRESSURE;

  247.             options |= PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH;

  248.             options |= PLUGIN_OPTION_SEND_PITCHBEND;

  249.             options |= PLUGIN_OPTION_SEND_ALL_SOUND_OFF;

  250.         }

  251. 

  252.         return options;

  253.     }

  254. 

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

  256.     {

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

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

  259. 

  260.         if (pData->param.data[parameterId].hints & PARAMETER_IS_STRICT_BOUNDS)

  261.             pData->param.ranges[parameterId].fixValue(fParamBuffers[parameterId]);

  262. 

  263.         return fParamBuffers[parameterId];

  264.     }

  265. 

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

  267.     {

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

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

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

  271. 

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

  273. 

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

  275.         {

  276.             const LV2_RDF_Port& port(fRdfDescriptor->Ports[rindex]);

  277. 

  278.             if (scalePointId < port.ScalePointCount)

  279.             {

  280.                 const LV2_RDF_PortScalePoint& portScalePoint(port.ScalePoints[scalePointId]);

  281.                 return portScalePoint.Value;

  282.             }

  283.         }

  284. 

  285.         return 0.0f;

  286.     }

  287. 

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

  289.     {

  290.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

  291.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor->URI != nullptr,);

  292. 

  293.         if (fRdfDescriptor->URI != nullptr)

  294.             std::strncpy(strBuf, fRdfDescriptor->URI, STR_MAX);

  295.         else

  296.             CarlaPlugin::getLabel(strBuf);

  297.     }

  298. 

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

  300.     {

  301.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

  302. 

  303.         if (fRdfDescriptor->Author != nullptr)

  304.             std::strncpy(strBuf, fRdfDescriptor->Author, STR_MAX);

  305.         else

  306.             CarlaPlugin::getMaker(strBuf);

  307.     }

  308. 

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

  310.     {

  311.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

  312. 

  313.         if (fRdfDescriptor->License != nullptr)

  314.             std::strncpy(strBuf, fRdfDescriptor->License, STR_MAX);

  315.         else

  316.             CarlaPlugin::getCopyright(strBuf);

  317.     }

  318. 

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

  320.     {

  321.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

  322. 

  323.         if (fRdfDescriptor->Name != nullptr)

  324.             std::strncpy(strBuf, fRdfDescriptor->Name, STR_MAX);

  325.         else

  326.             CarlaPlugin::getRealName(strBuf);

  327.     }

  328. 

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

  330.     {

  331.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

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

  333. 

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

  335. 

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

  337.             std::strncpy(strBuf, fRdfDescriptor->Ports[rindex].Name, STR_MAX);

  338.         else

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

  340.     }

  341. 

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

  343.     {

  344.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

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

  346. 

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

  348. 

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

  350.             std::strncpy(strBuf, fRdfDescriptor->Ports[rindex].Symbol, STR_MAX);

  351.         else

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

  353.     }

  354. 

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

  356.     {

  357.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

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

  359. 

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

  361. 

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

  363.         {

  364.             const LV2_RDF_Port& port(fRdfDescriptor->Ports[rindex]);

  365. 

  366.             if (LV2_HAVE_PORT_UNIT_SYMBOL(port.Unit.Hints) && port.Unit.Symbol != nullptr)

  367.             {

  368.                 std::strncpy(strBuf, port.Unit.Symbol, STR_MAX);

  369.                 return;

  370.             }

  371.             else if (LV2_HAVE_PORT_UNIT_UNIT(port.Unit.Hints))

  372.             {

  373.                 switch (port.Unit.Unit)

  374.                 {

  375.                 case LV2_PORT_UNIT_BAR:

  376.                     std::strncpy(strBuf, "bars", STR_MAX);

  377.                     return;

  378.                 case LV2_PORT_UNIT_BEAT:

  379.                     std::strncpy(strBuf, "beats", STR_MAX);

  380.                     return;

  381.                 case LV2_PORT_UNIT_BPM:

  382.                     std::strncpy(strBuf, "BPM", STR_MAX);

  383.                     return;

  384.                 case LV2_PORT_UNIT_CENT:

  385.                     std::strncpy(strBuf, "ct", STR_MAX);

  386.                     return;

  387.                 case LV2_PORT_UNIT_CM:

  388.                     std::strncpy(strBuf, "cm", STR_MAX);

  389.                     return;

  390.                 case LV2_PORT_UNIT_COEF:

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

  392.                     return;

  393.                 case LV2_PORT_UNIT_DB:

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

  395.                     return;

  396.                 case LV2_PORT_UNIT_DEGREE:

  397.                     std::strncpy(strBuf, "deg", STR_MAX);

  398.                     return;

  399.                 case LV2_PORT_UNIT_FRAME:

  400.                     std::strncpy(strBuf, "frames", STR_MAX);

  401.                     return;

  402.                 case LV2_PORT_UNIT_HZ:

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

  404.                     return;

  405.                 case LV2_PORT_UNIT_INCH:

  406.                     std::strncpy(strBuf, "in", STR_MAX);

  407.                     return;

  408.                 case LV2_PORT_UNIT_KHZ:

  409.                     std::strncpy(strBuf, "kHz", STR_MAX);

  410.                     return;

  411.                 case LV2_PORT_UNIT_KM:

  412.                     std::strncpy(strBuf, "km", STR_MAX);

  413.                     return;

  414.                 case LV2_PORT_UNIT_M:

  415.                     std::strncpy(strBuf, "m", STR_MAX);

  416.                     return;

  417.                 case LV2_PORT_UNIT_MHZ:

  418.                     std::strncpy(strBuf, "MHz", STR_MAX);

  419.                     return;

  420.                 case LV2_PORT_UNIT_MIDINOTE:

  421.                     std::strncpy(strBuf, "note", STR_MAX);

  422.                     return;

  423.                 case LV2_PORT_UNIT_MILE:

  424.                     std::strncpy(strBuf, "mi", STR_MAX);

  425.                     return;

  426.                 case LV2_PORT_UNIT_MIN:

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

  428.                     return;

  429.                 case LV2_PORT_UNIT_MM:

  430.                     std::strncpy(strBuf, "mm", STR_MAX);

  431.                     return;

  432.                 case LV2_PORT_UNIT_MS:

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

  434.                     return;

  435.                 case LV2_PORT_UNIT_OCT:

  436.                     std::strncpy(strBuf, "oct", STR_MAX);

  437.                     return;

  438.                 case LV2_PORT_UNIT_PC:

  439.                     std::strncpy(strBuf, "%", STR_MAX);

  440.                     return;

  441.                 case LV2_PORT_UNIT_S:

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

  443.                     return;

  444.                 case LV2_PORT_UNIT_SEMITONE:

  445.                     std::strncpy(strBuf, "semi", STR_MAX);

  446.                     return;

  447.                 }

  448.             }

  449.         }

  450. 

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

  452.     }

  453. 

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

  455.     {

  456.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

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

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

  459. 

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

  461. 

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

  463.         {

  464.             const LV2_RDF_Port& port(fRdfDescriptor->Ports[rindex]);

  465. 

  466.             if (scalePointId < port.ScalePointCount)

  467.             {

  468.                 const LV2_RDF_PortScalePoint& portScalePoint(port.ScalePoints[scalePointId]);

  469. 

  470.                 if (portScalePoint.Label != nullptr)

  471.                 {

  472.                     std::strncpy(strBuf, portScalePoint.Label, STR_MAX);

  473.                     return;

  474.                 }

  475.             }

  476.         }

  477. 

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

  479.     }

  480. 

  481.     // -------------------------------------------------------------------

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

  483. 

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

  485.     {

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

  487. 

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

  489.         fParamBuffers[parameterId] = fixedValue;

  490. 

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

  492.     }

  493. 

  494.     // -------------------------------------------------------------------

  495.     // Plugin state

  496. 

  497.     void reload() override

  498.     {

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

  500.         CARLA_SAFE_ASSERT_RETURN(fHandle != nullptr,);

  501.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  502.         CARLA_SAFE_ASSERT_RETURN(fRdfDescriptor != nullptr,);

  503.         carla_debug("Lv2Plugin::reload() - start");

  504. 

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

  506. 

  507.         // Safely disable plugin for reload

  508.         const ScopedDisabler sd(this);

  509. 

  510.         if (pData->active)

  511.             deactivate();

  512. 

  513.         clearBuffers();

  514. 

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

  516.         const uint32_t portCount(static_cast<uint32_t>(fRdfDescriptor->PortCount));

  517. 

  518.         uint32_t aIns, aOuts, params, j;

  519.         aIns = aOuts = params = 0;

  520. 

  521.         bool forcedStereoIn, forcedStereoOut;

  522.         forcedStereoIn = forcedStereoOut = false;

  523. 

  524.         bool needsCtrlIn, needsCtrlOut;

  525.         needsCtrlIn = needsCtrlOut = false;

  526. 

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

  528.         {

  529.             const LV2_Property portTypes(fRdfDescriptor->Ports[i].Types);

  530. 

  531.             if (LV2_IS_PORT_AUDIO(portTypes))

  532.             {

  533.                 if (LV2_IS_PORT_INPUT(portTypes))

  534.                     aIns += 1;

  535.                 else if (LV2_IS_PORT_OUTPUT(portTypes))

  536.                     aOuts += 1;

  537.             }

  538.             else if (LV2_IS_PORT_CONTROL(portTypes))

  539.                 params += 1;

  540.         }

  541. 

  542.         if ((pData->options & PLUGIN_OPTION_FORCE_STEREO) != 0 && (aIns == 1 || aOuts == 1) /*&& fExt.state == nullptr && fExt.worker == nullptr*/)

  543.         {

  544.             if (fHandle2 == nullptr)

  545.                 fHandle2 = fDescriptor->instantiate(fDescriptor, sampleRate, fRdfDescriptor->Bundle, fFeatures);

  546. 

  547.             if (fHandle2 != nullptr)

  548.             {

  549.                 if (aIns == 1)

  550.                 {

  551.                     aIns = 2;

  552.                     forcedStereoIn = true;

  553.                 }

  554. 

  555.                 if (aOuts == 1)

  556.                 {

  557.                     aOuts = 2;

  558.                     forcedStereoOut = true;

  559.                 }

  560.             }

  561.         }

  562. 

  563.         if (aIns > 0)

  564.         {

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

  566.             fAudioInBuffers = new float*[aIns];

  567. 

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

  569.                 fAudioInBuffers[i] = nullptr;

  570.         }

  571. 

  572.         if (aOuts > 0)

  573.         {

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

  575.             fAudioOutBuffers = new float*[aOuts];

  576.             needsCtrlIn = true;

  577. 

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

  579.                 fAudioOutBuffers[i] = nullptr;

  580.         }

  581. 

  582.         if (params > 0)

  583.         {

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

  585. 

  586.             fParamBuffers = new float[params];

  587.             FLOAT_CLEAR(fParamBuffers, params);

  588.         }

  589. 

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

  591.         CarlaString portName;

  592. 

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

  594.         {

  595.             const LV2_Property portTypes(fRdfDescriptor->Ports[i].Types);

  596. 

  597.             portName.clear();

  598. 

  599.             if (LV2_IS_PORT_AUDIO(portTypes) || LV2_IS_PORT_ATOM_SEQUENCE(portTypes) || LV2_IS_PORT_CV(portTypes) || LV2_IS_PORT_EVENT(portTypes) || LV2_IS_PORT_MIDI_LL(portTypes))

  600.             {

  601.                 if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  602.                 {

  603.                     portName  = pData->name;

  604.                     portName += ":";

  605.                 }

  606. 

  607.                 portName += fRdfDescriptor->Ports[i].Name;

  608.                 portName.truncate(portNameSize);

  609.             }

  610. 

  611.             if (LV2_IS_PORT_AUDIO(portTypes))

  612.             {

  613.                 if (LV2_IS_PORT_INPUT(portTypes))

  614.                 {

  615.                     j = iAudioIn++;

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

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

  618. 

  619.                     if (forcedStereoIn)

  620.                     {

  621.                         portName += "_2";

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

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

  624.                     }

  625.                 }

  626.                 else if (LV2_IS_PORT_OUTPUT(portTypes))

  627.                 {

  628.                     j = iAudioOut++;

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

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

  631. 

  632.                     if (forcedStereoOut)

  633.                     {

  634.                         portName += "_2";

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

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

  637.                     }

  638.                 }

  639.                 else

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

  641.             }

  642.             else if (LV2_IS_PORT_CONTROL(portTypes))

  643.             {

  644.                 const LV2_Property portProps(fRdfDescriptor->Ports[i].Properties);

  645.                 const LV2_Property portDesignation(fRdfDescriptor->Ports[i].Designation);

  646.                 const LV2_RDF_PortPoints portPoints(fRdfDescriptor->Ports[i].Points);

  647. 

  648.                 j = iCtrl++;

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

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

  651.                 pData->param.data[j].index  = j;

  652.                 pData->param.data[j].rindex = i;

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

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

  655. 

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

  657. 

  658.                 // min value

  659.                 if (LV2_HAVE_MINIMUM_PORT_POINT(portPoints.Hints))

  660.                     min = portPoints.Minimum;

  661.                 else

  662.                     min = 0.0f;

  663. 

  664.                 // max value

  665.                 if (LV2_HAVE_MAXIMUM_PORT_POINT(portPoints.Hints))

  666.                     max = portPoints.Maximum;

  667.                 else

  668.                     max = 1.0f;

  669. 

  670.                 if (min > max)

  671.                     max = min;

  672.                 else if (max < min)

  673.                     min = max;

  674. 

  675.                 // stupid hack for ir.lv2 (broken plugin)

  676.                 if (std::strcmp(fRdfDescriptor->URI, "http://factorial.hu/plugins/lv2/ir") == 0 && std::strncmp(fRdfDescriptor->Ports[i].Name, "FileHash", 8) == 0)

  677.                 {

  678.                     min = 0.0f;

  679.                     max = (float)0xffffff;

  680.                 }

  681. 

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

  683.                 {

  684.                     carla_stderr2("WARNING - Broken plugin parameter '%s': max - min == 0.0f", fRdfDescriptor->Ports[i].Name);

  685.                     max = min + 0.1f;

  686.                 }

  687. 

  688.                 // default value

  689.                 if (LV2_HAVE_DEFAULT_PORT_POINT(portPoints.Hints))

  690.                 {

  691.                     def = portPoints.Default;

  692.                 }

  693.                 else

  694.                 {

  695.                     // no default value

  696.                     if (min < 0.0f && max > 0.0f)

  697.                         def = 0.0f;

  698.                     else

  699.                         def = min;

  700.                 }

  701. 

  702.                 if (def < min)

  703.                     def = min;

  704.                 else if (def > max)

  705.                     def = max;

  706. 

  707.                 if (LV2_IS_PORT_SAMPLE_RATE(portProps))

  708.                 {

  709.                     min *= sampleRate;

  710.                     max *= sampleRate;

  711.                     def *= sampleRate;

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

  713.                 }

  714. 

  715.                 if (LV2_IS_PORT_TOGGLED(portProps))

  716.                 {

  717.                     step = max - min;

  718.                     stepSmall = step;

  719.                     stepLarge = step;

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

  721.                 }

  722.                 else if (LV2_IS_PORT_INTEGER(portProps))

  723.                 {

  724.                     step = 1.0f;

  725.                     stepSmall = 1.0f;

  726.                     stepLarge = 10.0f;

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

  728.                 }

  729.                 else

  730.                 {

  731.                     float range = max - min;

  732.                     step = range/100.0f;

  733.                     stepSmall = range/1000.0f;

  734.                     stepLarge = range/10.0f;

  735.                 }

  736. 

  737.                 if (LV2_IS_PORT_INPUT(portTypes))

  738.                 {

  739.                     if (LV2_IS_PORT_DESIGNATION_LATENCY(portDesignation))

  740.                     {

  741.                         carla_stderr("Plugin has latency input port, this should not happen!");

  742.                     }

  743.                     else if (LV2_IS_PORT_DESIGNATION_SAMPLE_RATE(portDesignation))

  744.                     {

  745.                         def = sampleRate;

  746.                         step = 1.0f;

  747.                         stepSmall = 1.0f;

  748.                         stepLarge = 1.0f;

  749. 

  750.                         //pData->param.data[j].type  = PARAMETER_SAMPLE_RATE;

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

  752.                     }

  753.                     else if (LV2_IS_PORT_DESIGNATION_FREEWHEELING(portDesignation))

  754.                     {

  755.                         //pData->param.data[j].type = PARAMETER_LV2_FREEWHEEL;

  756.                     }

  757.                     else if (LV2_IS_PORT_DESIGNATION_TIME(portDesignation))

  758.                     {

  759.                         //pData->param.data[j].type = PARAMETER_LV2_TIME;

  760.                     }

  761.                     else

  762.                     {

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

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

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

  766.                         needsCtrlIn = true;

  767.                     }

  768. 

  769.                     // MIDI CC value

  770.                     const LV2_RDF_PortMidiMap& portMidiMap(fRdfDescriptor->Ports[i].MidiMap);

  771. 

  772.                     if (LV2_IS_PORT_MIDI_MAP_CC(portMidiMap.Type))

  773.                     {

  774.                         if (portMidiMap.Number < 0x5F && ! MIDI_IS_CONTROL_BANK_SELECT(portMidiMap.Number))

  775.                             pData->param.data[j].midiCC = int16_t(portMidiMap.Number);

  776.                     }

  777.                 }

  778.                 else if (LV2_IS_PORT_OUTPUT(portTypes))

  779.                 {

  780.                     if (LV2_IS_PORT_DESIGNATION_LATENCY(portDesignation))

  781.                     {

  782.                         min = 0.0f;

  783.                         max = sampleRate;

  784.                         def = 0.0f;

  785.                         step = 1.0f;

  786.                         stepSmall = 1.0f;

  787.                         stepLarge = 1.0f;

  788. 

  789.                         //pData->param.data[j].type  = PARAMETER_LATENCY;

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

  791.                     }

  792.                     else if (LV2_IS_PORT_DESIGNATION_SAMPLE_RATE(portDesignation))

  793.                     {

  794.                         def = sampleRate;

  795.                         step = 1.0f;

  796.                         stepSmall = 1.0f;

  797.                         stepLarge = 1.0f;

  798. 

  799.                         //pData->param.data[j].type  = PARAMETER_SAMPLE_RATE;

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

  801.                     }

  802.                     else if (LV2_IS_PORT_DESIGNATION_FREEWHEELING(portDesignation))

  803.                     {

  804.                         carla_stderr("Plugin has freewheeling output port, this should not happen!");

  805.                     }

  806.                     else if (LV2_IS_PORT_DESIGNATION_TIME(portDesignation))

  807.                     {

  808.                         //pData->param.data[j].type = PARAMETER_LV2_TIME;

  809.                     }

  810.                     else

  811.                     {

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

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

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

  815.                         needsCtrlOut = true;

  816.                     }

  817.                 }

  818.                 else

  819.                 {

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

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

  822.                 }

  823. 

  824.                 // extra parameter hints

  825.                 if (LV2_IS_PORT_ENUMERATION(portProps))

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

  827. 

  828.                 if (LV2_IS_PORT_LOGARITHMIC(portProps))

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

  830. 

  831.                 if (LV2_IS_PORT_TRIGGER(portProps))

  832.                     pData->param.data[j].hints |= PARAMETER_IS_TRIGGER;

  833. 

  834.                 if (LV2_IS_PORT_STRICT_BOUNDS(portProps))

  835.                     pData->param.data[j].hints |= PARAMETER_IS_STRICT_BOUNDS;

  836. 

  837.                 // check if parameter is not enabled or automable

  838.                 if (LV2_IS_PORT_NOT_ON_GUI(portProps))

  839.                 {

  840.                     pData->param.data[j].hints &= ~(PARAMETER_IS_ENABLED|PARAMETER_IS_AUTOMABLE);

  841.                 }

  842.                 else if (LV2_IS_PORT_CAUSES_ARTIFACTS(portProps) || LV2_IS_PORT_EXPENSIVE(portProps) || LV2_IS_PORT_NOT_AUTOMATIC(portProps))

  843.                     pData->param.data[j].hints &= ~PARAMETER_IS_AUTOMABLE;

  844. 

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

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

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

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

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

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

  851. 

  852.                 // Start parameters in their default values

  853.                 //if (pData->param.data[j].type != PARAMETER_LV2_FREEWHEEL)

  854.                     fParamBuffers[j] = def;

  855.                 //else

  856.                 //    fParamBuffers[j] = min;

  857. 

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

  859. 

  860.                 if (fHandle2 != nullptr)

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

  862.             }

  863.             else

  864.             {

  865.                 // Port Type not supported, but it's optional anyway

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

  867. 

  868.                 if (fHandle2 != nullptr)

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

  870.             }

  871.         }

  872. 

  873.         if (needsCtrlIn)

  874.         {

  875.             portName.clear();

  876. 

  877.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  878.             {

  879.                 portName  = pData->name;

  880.                 portName += ":";

  881.             }

  882. 

  883.             portName += "events-in";

  884.             portName.truncate(portNameSize);

  885. 

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

  887.         }

  888. 

  889.         if (needsCtrlOut)

  890.         {

  891.             portName.clear();

  892. 

  893.             if (processMode == ENGINE_PROCESS_MODE_SINGLE_CLIENT)

  894.             {

  895.                 portName  = pData->name;

  896.                 portName += ":";

  897.             }

  898. 

  899.             portName += "events-out";

  900.             portName.truncate(portNameSize);

  901. 

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

  903.         }

  904. 

  905.         if (forcedStereoIn || forcedStereoOut)

  906.             pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  907.         else

  908.             pData->options &= ~PLUGIN_OPTION_FORCE_STEREO;

  909. 

  910.         // plugin hints

  911.         pData->hints = 0x0;

  912. 

  913.         if (isRealtimeSafe())

  914.             pData->hints |= PLUGIN_IS_RTSAFE;

  915. 

  916.         if (LV2_IS_GENERATOR(fRdfDescriptor->Type[0], fRdfDescriptor->Type[1]))

  917.             pData->hints |= PLUGIN_IS_SYNTH;

  918. 

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

  920.             pData->hints |= PLUGIN_CAN_DRYWET;

  921. 

  922.         if (aOuts > 0)

  923.             pData->hints |= PLUGIN_CAN_VOLUME;

  924. 

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

  926.             pData->hints |= PLUGIN_CAN_BALANCE;

  927. 

  928.         // extra plugin hints

  929.         pData->extraHints &= ~PLUGIN_EXTRA_HINT_CAN_RUN_RACK;

  930. 

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

  932.         reloadPrograms(true);

  933. 

  934.         if (pData->active)

  935.             activate();

  936. 

  937.         carla_debug("Lv2Plugin::reload() - end");

  938.     }

  939. 

  940.     // -------------------------------------------------------------------

  941.     // Plugin processing

  942. 

  943.     void activate() noexcept override

  944.     {

  945.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  946.         CARLA_SAFE_ASSERT_RETURN(fHandle != nullptr,);

  947. 

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

  949.         {

  950.             try {

  951.                 fDescriptor->activate(fHandle);

  952.             } catch(...) {}

  953. 

  954.             if (fHandle2 != nullptr)

  955.             {

  956.                 try {

  957.                     fDescriptor->activate(fHandle2);

  958.                 } catch(...) {}

  959.             }

  960.         }

  961.     }

  962. 

  963.     void deactivate() noexcept override

  964.     {

  965.         CARLA_SAFE_ASSERT_RETURN(fDescriptor != nullptr,);

  966.         CARLA_SAFE_ASSERT_RETURN(fHandle != nullptr,);

  967. 

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

  969.         {

  970.             try {

  971.                 fDescriptor->deactivate(fHandle);

  972.             } catch(...) {}

  973. 

  974.             if (fHandle2 != nullptr)

  975.             {

  976.                 try {

  977.                     fDescriptor->deactivate(fHandle2);

  978.                 } catch(...) {}

  979.             }

  980.         }

  981.     }

  982. 

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

  984.     {

  985.         uint32_t i, k;

  986. 

  987.         // --------------------------------------------------------------------------------------------------------

  988.         // Check if active

  989. 

  990.         if (! pData->active)

  991.         {

  992.             // disable any output sound

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

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

  995.             return;

  996.         }

  997. 

  998.         // --------------------------------------------------------------------------------------------------------

  999.         // Plugin processing (no events)

  1000. 

  1001.         {

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

  1003. 

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

  1005. 

  1006.         // --------------------------------------------------------------------------------------------------------

  1007.         // Control Output

  1008. 

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

  1010.         {

  1011.             uint8_t  channel;

  1012.             uint16_t param;

  1013.             float    value;

  1014. 

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

  1016.             {

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

  1018.                     continue;

  1019. 

  1020.                 if (pData->param.data[k].hints & PARAMETER_IS_STRICT_BOUNDS)

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

  1022. 

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

  1024.                 {

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

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

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

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

  1029.                 }

  1030.             }

  1031. 

  1032.         } // End of Control Output

  1033. 

  1034.         CARLA_PROCESS_CONTINUE_CHECK;

  1035. 

  1036.         // --------------------------------------------------------------------------------------------------------

  1037.     }

  1038. 

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

  1040.     {

  1041.         CARLA_SAFE_ASSERT_RETURN(frames > 0, false);

  1042. 

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

  1044.         {

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

  1046.         }

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

  1048.         {

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

  1050.         }

  1051. 

  1052.         uint32_t i, k;

  1053. 

  1054.         // --------------------------------------------------------------------------------------------------------

  1055.         // Try lock, silence otherwise

  1056. 

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

  1058.         {

  1059.             pData->singleMutex.lock();

  1060.         }

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

  1062.         {

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

  1064.             {

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

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

  1067.             }

  1068. 

  1069.             return false;

  1070.         }

  1071. 

  1072.         // --------------------------------------------------------------------------------------------------------

  1073.         // Reset audio buffers

  1074. 

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

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

  1077. 

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

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

  1080. 

  1081.         // --------------------------------------------------------------------------------------------------------

  1082.         // Run plugin

  1083. 

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

  1085. 

  1086.         if (fHandle2 != nullptr)

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

  1088. 

  1089.         // --------------------------------------------------------------------------------------------------------

  1090.         // Special Parameters

  1091. 

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

  1093.         {

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

  1095.                 continue;

  1096. 

  1097.             if (pData->param.data[k].hints & PARAMETER_IS_TRIGGER)

  1098.             {

  1099.                 if (fParamBuffers[k] != pData->param.ranges[k].def)

  1100.                 {

  1101.                     fParamBuffers[k] = pData->param.ranges[k].def;

  1102.                     pData->postponeRtEvent(kPluginPostRtEventParameterChange, static_cast<int32_t>(k), 0, fParamBuffers[k]);

  1103.                 }

  1104.             }

  1105.         }

  1106. 

  1107.         pData->postRtEvents.trySplice();

  1108. 

  1109. #ifndef BUILD_BRIDGE

  1110.         // --------------------------------------------------------------------------------------------------------

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

  1112. 

  1113.         {

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

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

  1116. 

  1117.             bool isPair;

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

  1119. 

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

  1121.             {

  1122.                 // Dry/Wet

  1123.                 if (doDryWet)

  1124.                 {

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

  1126.                     {

  1127.                         // TODO

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

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

  1130.                         //else

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

  1132. 

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

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

  1135.                     }

  1136.                 }

  1137. 

  1138.                 // Balance

  1139.                 if (doBalance)

  1140.                 {

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

  1142. 

  1143.                     if (isPair)

  1144.                     {

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

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

  1147.                     }

  1148. 

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

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

  1151. 

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

  1153.                     {

  1154.                         if (isPair)

  1155.                         {

  1156.                             // left

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

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

  1159.                         }

  1160.                         else

  1161.                         {

  1162.                             // right

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

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

  1165.                         }

  1166.                     }

  1167.                 }

  1168. 

  1169.                 // Volume (and buffer copy)

  1170.                 {

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

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

  1173.                 }

  1174.             }

  1175.         } // End of Post-processing

  1176. #else

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

  1178.         {

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

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

  1181.         }

  1182. #endif

  1183. 

  1184.         // --------------------------------------------------------------------------------------------------------

  1185. 

  1186.         pData->singleMutex.unlock();

  1187.         return true;

  1188.     }

  1189. 

  1190.     void bufferSizeChanged(const uint32_t newBufferSize) override

  1191.     {

  1192.         CARLA_ASSERT_INT(newBufferSize > 0, newBufferSize);

  1193.         carla_debug("Lv2Plugin::bufferSizeChanged(%i) - start", newBufferSize);

  1194. 

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

  1196.         {

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

  1198.                 delete[] fAudioInBuffers[i];

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

  1200.         }

  1201. 

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

  1203.         {

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

  1205.                 delete[] fAudioOutBuffers[i];

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

  1207.         }

  1208. 

  1209.         if (fHandle2 == nullptr)

  1210.         {

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

  1212.             {

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

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

  1215.             }

  1216. 

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

  1218.             {

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

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

  1221.             }

  1222.         }

  1223.         else

  1224.         {

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

  1226.             {

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

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

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

  1230. 

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

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

  1233.             }

  1234. 

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

  1236.             {

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

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

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

  1240. 

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

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

  1243.             }

  1244.         }

  1245. 

  1246.         carla_debug("Lv2Plugin::bufferSizeChanged(%i) - end", newBufferSize);

  1247.     }

  1248. 

  1249.     void sampleRateChanged(const double newSampleRate) override

  1250.     {

  1251.         CARLA_ASSERT_INT(newSampleRate > 0.0, int(newSampleRate));

  1252.         carla_debug("Lv2Plugin::sampleRateChanged(%g) - start", newSampleRate);

  1253. 

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

  1255.         {

  1256.             if (pData->param.data[k].type == PARAMETER_INPUT && pData->param.special[k] == PARAMETER_SPECIAL_SAMPLE_RATE)

  1257.             {

  1258.                 fParamBuffers[k] = float(newSampleRate);

  1259.                 pData->postponeRtEvent(kPluginPostRtEventParameterChange, static_cast<int32_t>(k), 1, fParamBuffers[k]);

  1260.                 break;

  1261.             }

  1262.         }

  1263. 

  1264.         carla_debug("Lv2Plugin::sampleRateChanged(%g) - end", newSampleRate);

  1265.     }

  1266. 

  1267.     void offlineModeChanged(const bool isOffline) override

  1268.     {

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

  1270.         {

  1271.             if (pData->param.data[k].type == PARAMETER_INPUT && pData->param.special[k] == PARAMETER_SPECIAL_LV2_FREEWHEEL)

  1272.             {

  1273.                 fParamBuffers[k] = isOffline ? pData->param.ranges[k].max : pData->param.ranges[k].min;

  1274.                 pData->postponeRtEvent(kPluginPostRtEventParameterChange, static_cast<int32_t>(k), 1, fParamBuffers[k]);

  1275.                 break;

  1276.             }

  1277.         }

  1278.     }

  1279. 

  1280.     // -------------------------------------------------------------------

  1281.     // Plugin buffers

  1282. 

  1283.     void clearBuffers() override

  1284.     {

  1285.         carla_debug("Lv2Plugin::clearBuffers() - start");

  1286. 

  1287.         if (fAudioInBuffers != nullptr)

  1288.         {

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

  1290.             {

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

  1292.                 {

  1293.                     delete[] fAudioInBuffers[i];

  1294.                     fAudioInBuffers[i] = nullptr;

  1295.                 }

  1296.             }

  1297. 

  1298.             delete[] fAudioInBuffers;

  1299.             fAudioInBuffers = nullptr;

  1300.         }

  1301. 

  1302.         if (fAudioOutBuffers != nullptr)

  1303.         {

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

  1305.             {

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

  1307.                 {

  1308.                     delete[] fAudioOutBuffers[i];

  1309.                     fAudioOutBuffers[i] = nullptr;

  1310.                 }

  1311.             }

  1312. 

  1313.             delete[] fAudioOutBuffers;

  1314.             fAudioOutBuffers = nullptr;

  1315.         }

  1316. 

  1317.         if (fParamBuffers != nullptr)

  1318.         {

  1319.             delete[] fParamBuffers;

  1320.             fParamBuffers = nullptr;

  1321.         }

  1322. 

  1323.         CarlaPlugin::clearBuffers();

  1324. 

  1325.         carla_debug("Lv2Plugin::clearBuffers() - end");

  1326.     }

  1327. 

  1328.     // -------------------------------------------------------------------

  1329. 

  1330.     bool isRealtimeSafe() const

  1331.     {

  1332.         CARLA_ASSERT(fRdfDescriptor != nullptr);

  1333. 

  1334.         for (uint32_t i=0; i < fRdfDescriptor->FeatureCount; ++i)

  1335.         {

  1336.             if (std::strcmp(fRdfDescriptor->Features[i].URI, LV2_CORE__hardRTCapable) == 0)

  1337.                 return true;

  1338.         }

  1339. 

  1340.         return false;

  1341.     }

  1342. 

  1343.     bool needsFixedBuffer() const

  1344.     {

  1345.         CARLA_ASSERT(fRdfDescriptor != nullptr);

  1346. 

  1347.         for (uint32_t i=0; i < fRdfDescriptor->FeatureCount; ++i)

  1348.         {

  1349.             if (std::strcmp(fRdfDescriptor->Features[i].URI, LV2_BUF_SIZE__fixedBlockLength) == 0)

  1350.                 return true;

  1351.         }

  1352. 

  1353.         return false;

  1354.     }

  1355. 

  1356.     // -------------------------------------------------------------------

  1357. 

  1358. public:

  1359.     bool init(const char* const bundle, const char* const name, const char* const uri)

  1360.     {

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

  1362. 

  1363.         // ---------------------------------------------------------------

  1364.         // first checks

  1365. 

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

  1367.         {

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

  1369.             return false;

  1370.         }

  1371. 

  1372.         if (bundle == nullptr || bundle[0] == '\0')

  1373.         {

  1374.             pData->engine->setLastError("null bundle");

  1375.             return false;

  1376.         }

  1377. 

  1378.         if (uri == nullptr || uri[0] == '\0')

  1379.         {

  1380.             pData->engine->setLastError("null uri");

  1381.             return false;

  1382.         }

  1383. 

  1384.         // ---------------------------------------------------------------

  1385.         // get plugin from lv2_rdf (lilv)

  1386. 

  1387.         Lv2WorldClass& lv2World(Lv2WorldClass::getInstance());

  1388. 

  1389.         // Convert bundle filename to URI

  1390.         QString qBundle(QUrl::fromLocalFile(bundle).toString());

  1391.         if (! qBundle.endsWith(OS_SEP_STR))

  1392.             qBundle += OS_SEP_STR;

  1393. 

  1394.         // Load bundle

  1395.         Lilv::Node lilvBundle(lv2World.new_uri(qBundle.toUtf8().constData()));

  1396.         lv2World.load_bundle(lilvBundle);

  1397. 

  1398.         fRdfDescriptor = lv2_rdf_new(uri, true);

  1399. 

  1400.         if (fRdfDescriptor == nullptr)

  1401.         {

  1402.             pData->engine->setLastError("Failed to find the requested plugin in the LV2 Bundle");

  1403.             return false;

  1404.         }

  1405. 

  1406.         // ---------------------------------------------------------------

  1407.         // open DLL

  1408. 

  1409.         if (! pData->libOpen(fRdfDescriptor->Binary))

  1410.         {

  1411.             pData->engine->setLastError(lib_error(fRdfDescriptor->Binary));

  1412.             return false;

  1413.         }

  1414. 

  1415.         // ---------------------------------------------------------------

  1416.         // get DLL main entry

  1417. 

  1418.         const LV2_Descriptor_Function descFn = (LV2_Descriptor_Function)pData->libSymbol("lv2_descriptor");

  1419. 

  1420.         if (descFn == nullptr)

  1421.         {

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

  1423.             return false;

  1424.         }

  1425. 

  1426.         // -----------------------------------------------------------

  1427.         // get descriptor that matches URI

  1428. 

  1429.         uint32_t i = 0;

  1430.         while ((fDescriptor = descFn(i++)))

  1431.         {

  1432.             carla_debug("LV2 Init @%i => '%s' vs '%s'", i, fDescriptor->URI, uri);

  1433.             if (std::strcmp(fDescriptor->URI, uri) == 0)

  1434.                 break;

  1435.         }

  1436. 

  1437.         if (fDescriptor == nullptr)

  1438.         {

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

  1440.             return false;

  1441.         }

  1442. 

  1443.         // ---------------------------------------------------------------

  1444.         // check supported port-types and features

  1445. 

  1446.         bool canContinue = true;

  1447. 

  1448.         // Check supported ports

  1449.         for (uint32_t i=0; i < fRdfDescriptor->PortCount; ++i)

  1450.         {

  1451.             const LV2_Property portTypes(fRdfDescriptor->Ports[i].Types);

  1452. 

  1453.             if (! is_lv2_port_supported(portTypes))

  1454.             {

  1455.                 if (! LV2_IS_PORT_OPTIONAL(fRdfDescriptor->Ports[i].Properties))

  1456.                 {

  1457.                     pData->engine->setLastError("Plugin requires a port type that is not currently supported");

  1458.                     canContinue = false;

  1459.                     break;

  1460.                 }

  1461.             }

  1462.         }

  1463. 

  1464.         // Check supported features

  1465.         for (uint32_t i=0; i < fRdfDescriptor->FeatureCount && canContinue; ++i)

  1466.         {

  1467.             if (LV2_IS_FEATURE_REQUIRED(fRdfDescriptor->Features[i].Type) && ! is_lv2_feature_supported(fRdfDescriptor->Features[i].URI))

  1468.             {

  1469. //                 QString msg(QString("Plugin requires a feature that is not supported:\n%1").arg(fRdfDescriptor->Features[i].URI));

  1470. //                 pData->engine->setLastError(msg.toUtf8().constData());

  1471.                 canContinue = false;

  1472.                 break;

  1473.             }

  1474.         }

  1475. 

  1476.         if (! canContinue)

  1477.         {

  1478.             // error already set

  1479.             return false;

  1480.         }

  1481. 

  1482.         // ---------------------------------------------------------------

  1483.         // get info

  1484. 

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

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

  1487.         else

  1488.             pData->name = pData->engine->getUniquePluginName(fRdfDescriptor->Name);

  1489. 

  1490.         // ---------------------------------------------------------------

  1491.         // register client

  1492. 

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

  1494. 

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

  1496.         {

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

  1498.             return false;

  1499.         }

  1500. 

  1501.         // ---------------------------------------------------------------

  1502.         // initialize plugin

  1503. 

  1504.         fHandle = fDescriptor->instantiate(fDescriptor, pData->engine->getSampleRate(), fRdfDescriptor->Bundle, fFeatures);

  1505. 

  1506.         if (fHandle == nullptr)

  1507.         {

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

  1509.             return false;

  1510.         }

  1511. 

  1512.         // ---------------------------------------------------------------

  1513.         // load plugin settings

  1514. 

  1515.         {

  1516.             // set default options

  1517.             pData->options = 0x0;

  1518. 

  1519.             pData->options |= PLUGIN_OPTION_MAP_PROGRAM_CHANGES;

  1520. 

  1521.             if (getMidiInCount() > 0 || needsFixedBuffer())

  1522.                 pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1523. 

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

  1525.                 pData->options |= PLUGIN_OPTION_FORCE_STEREO;

  1526. 

  1527.             if (getMidiInCount() > 0)

  1528.             {

  1529.                 pData->options |= PLUGIN_OPTION_SEND_CHANNEL_PRESSURE;

  1530.                 pData->options |= PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH;

  1531.                 pData->options |= PLUGIN_OPTION_SEND_PITCHBEND;

  1532.                 pData->options |= PLUGIN_OPTION_SEND_ALL_SOUND_OFF;

  1533.             }

  1534. 

  1535.             // set identifier string

  1536.             CarlaString identifier("V2/");

  1537.             identifier += uri;

  1538. 

  1539.             // load settings

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

  1541. 

  1542.             // ignore settings, we need this anyway

  1543.             if (getMidiInCount() > 0 || needsFixedBuffer())

  1544.                 pData->options |= PLUGIN_OPTION_FIXED_BUFFERS;

  1545.         }

  1546. 

  1547.         // ---------------------------------------------------------------

  1548.         // gui stuff

  1549. 

  1550.         if (fRdfDescriptor->UICount == 0)

  1551.             return true;

  1552. 

  1553.         return true;

  1554.     }

  1555. 

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

  1557. 

  1558. private:

  1559.     LV2_Handle   fHandle;

  1560.     LV2_Handle   fHandle2;

  1561.     LV2_Feature* fFeatures[kFeatureCount+1];

  1562.     const LV2_Descriptor*     fDescriptor;

  1563.     const LV2_RDF_Descriptor* fRdfDescriptor;

  1564. 

  1565.     float** fAudioInBuffers;

  1566.     float** fAudioOutBuffers;

  1567.     float*  fParamBuffers;

  1568. 

  1569.     // -------------------------------------------------------------------

  1570. 

  1571.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(Lv2Plugin)

  1572. };

  1573. 

  1574. // -------------------------------------------------------------------------------------------------------------------

  1575. 

  1576. #define lv2PluginPtr ((Lv2Plugin*)plugin)

  1577. 

  1578. int CarlaEngineOsc::handleMsgLv2AtomTransfer(CARLA_ENGINE_OSC_HANDLE_ARGS2)

  1579. {

  1580.     CARLA_ENGINE_OSC_CHECK_OSC_TYPES(2, "is");

  1581.     carla_debug("CarlaOsc::handleMsgLv2AtomTransfer()");

  1582. 

  1583.     return 0;

  1584. 

  1585.     // unused for now

  1586.     (void)argv;

  1587.     (void)plugin;

  1588. }

  1589. 

  1590. int CarlaEngineOsc::handleMsgLv2UridMap(CARLA_ENGINE_OSC_HANDLE_ARGS2)

  1591. {

  1592.     CARLA_ENGINE_OSC_CHECK_OSC_TYPES(2, "is");

  1593.     carla_debug("CarlaOsc::handleMsgLv2EventTransfer()");

  1594. 

  1595.     return 0;

  1596. 

  1597.     // unused for now

  1598.     (void)argv;

  1599.     (void)plugin;

  1600. }

  1601. 

  1602. #undef lv2PluginPtr

  1603. 

  1604. CARLA_BACKEND_END_NAMESPACE

  1605. 

  1606. #endif // WANT_LV2

  1607. 

  1608. // -------------------------------------------------------------------------------------------------------------------

  1609. 

  1610. CARLA_BACKEND_START_NAMESPACE

  1611. 

  1612. CarlaPlugin* CarlaPlugin::newLV2(const Initializer& init)

  1613. {

  1614.     carla_debug("CarlaPlugin::newLV2({%p, \"%s\", \"%s\"})", init.engine, init.name, init.label);

  1615. 

  1616. #ifdef WANT_LV2

  1617.     Lv2Plugin* const plugin(new Lv2Plugin(init.engine, init.id));

  1618. 

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

  1620.     {

  1621.         delete plugin;

  1622.         return nullptr;

  1623.     }

  1624. 

  1625.     plugin->reload();

  1626. 

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

  1628.     {

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

  1630.         delete plugin;

  1631.         return nullptr;

  1632.     }

  1633. 

  1634.     return plugin;

  1635. #else

  1636.     init.engine->setLastError("LV2 support not available");

  1637.     return nullptr;

  1638. #endif

  1639. }

  1640. 

  1641. CARLA_BACKEND_END_NAMESPACE

  1642. 

  1643. // -------------------------------------------------------------------------------------------------------------------