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

1656 lines
54KB
Raw Blame History 

  1. /*

  2.  * Carla Plugin Host

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

  4.  *

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

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

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

  8.  * the License, or any later version.

  9.  *

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

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

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

  13.  * GNU General Public License for more details.

  14.  *

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

  16.  */

  17. 

  18. #include "CarlaDefines.h"

  19. 

  20. #ifdef BUILD_BRIDGE

  21. # error This file should not be compiled if building bridge

  22. #endif

  23. #ifdef CARLA_OS_WIN

  24. # error This file should not be compiled for Windows

  25. #endif

  26. 

  27. #include "CarlaEngineInternal.hpp"

  28. #include "CarlaPlugin.hpp"

  29. 

  30. #include "CarlaBackendUtils.hpp"

  31. #include "CarlaBase64Utils.hpp"

  32. #include "CarlaBinaryUtils.hpp"

  33. #include "CarlaMathUtils.hpp"

  34. #include "CarlaStateUtils.hpp"

  35. 

  36. #include "CarlaExternalUI.hpp"

  37. #include "CarlaNative.hpp"

  38. 

  39. #include "juce_audio_basics.h"

  40. 

  41. #if defined(CARLA_OS_MAC) || defined(CARLA_OS_WIN)

  42. # include "juce_gui_basics.h"

  43. #else

  44. namespace juce {

  45. # include "juce_events/messages/juce_Initialisation.h"

  46. } // namespace juce

  47. #endif

  48. 

  49. using juce::File;

  50. using juce::FloatVectorOperations;

  51. using juce::MemoryOutputStream;

  52. using juce::ScopedPointer;

  53. using juce::String;

  54. using juce::XmlDocument;

  55. using juce::XmlElement;

  56. 

  57. static bool gNeedsJuceHandling = false;

  58. static int  gJuceReferenceCounter = 0;

  59. 

  60. CARLA_BACKEND_START_NAMESPACE

  61. 

  62. // -----------------------------------------------------------------------

  63. 

  64. class CarlaEngineNativeUI : public CarlaExternalUI

  65. {

  66. public:

  67.     CarlaEngineNativeUI(CarlaEngine* const engine)

  68.         : fEngine(engine),

  69.           leakDetector_CarlaEngineNativeUI()

  70.     {

  71.         carla_debug("CarlaEngineNativeUI::CarlaEngineNativeUI(%p)", engine);

  72.     }

  73. 

  74.     ~CarlaEngineNativeUI() override

  75.     {

  76.         carla_debug("CarlaEngineNativeUI::~CarlaEngineNativeUI()");

  77.     }

  78. 

  79.     CarlaMutex& getWriteLock() noexcept

  80.     {

  81.         return fWriteLock;

  82.     }

  83. 

  84. protected:

  85.     bool msgReceived(const char* const msg) noexcept override

  86.     {

  87.         if (CarlaExternalUI::msgReceived(msg))

  88.             return true;

  89. 

  90.         bool ok = true;

  91. 

  92.         if (std::strcmp(msg, "set_engine_option") == 0)

  93.         {

  94.             uint32_t option;

  95.             int32_t value;

  96.             const char* valueStr = nullptr;

  97. 

  98.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(option), true);

  99.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(value), true);

  100.             readNextLineAsString(valueStr); // can be null

  101. 

  102.             try {

  103.                 fEngine->setOption(static_cast<EngineOption>(option), value, valueStr);

  104.             } CARLA_SAFE_EXCEPTION("setOption");

  105. 

  106.             delete[] valueStr;

  107.         }

  108.         else if (std::strcmp(msg, "load_file") == 0)

  109.         {

  110.             const char* filename;

  111. 

  112.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);

  113. 

  114.             try {

  115.                 ok = fEngine->loadFile(filename);

  116.             } CARLA_SAFE_EXCEPTION("loadFile");

  117. 

  118.             delete[] filename;

  119.         }

  120.         else if (std::strcmp(msg, "load_project") == 0)

  121.         {

  122.             const char* filename;

  123. 

  124.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);

  125. 

  126.             try {

  127.                 ok = fEngine->loadProject(filename);

  128.             } CARLA_SAFE_EXCEPTION("loadProject");

  129. 

  130.             delete[] filename;

  131.         }

  132.         else if (std::strcmp(msg, "save_project") == 0)

  133.         {

  134.             const char* filename;

  135. 

  136.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);

  137. 

  138.             try {

  139.                 ok = fEngine->saveProject(filename);

  140.             } CARLA_SAFE_EXCEPTION("saveProject");

  141. 

  142.             delete[] filename;

  143.         }

  144.         else if (std::strcmp(msg, "patchbay_connect") == 0)

  145.         {

  146.             uint32_t groupA, portA, groupB, portB;

  147. 

  148.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(groupA), true);

  149.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(portA), true);

  150.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(groupB), true);

  151.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(portB), true);

  152. 

  153.             try {

  154.                 ok = fEngine->patchbayConnect(groupA, portA, groupB, portB);

  155.             } CARLA_SAFE_EXCEPTION("patchbayConnect");

  156.         }

  157.         else if (std::strcmp(msg, "patchbay_disconnect") == 0)

  158.         {

  159.             uint32_t connectionId;

  160. 

  161.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(connectionId), true);

  162. 

  163.             try {

  164.                 ok = fEngine->patchbayDisconnect(connectionId);

  165.             } CARLA_SAFE_EXCEPTION("patchbayDisconnect");

  166.         }

  167.         else if (std::strcmp(msg, "patchbay_refresh") == 0)

  168.         {

  169.             try {

  170.                 ok = fEngine->patchbayRefresh(false);

  171.             } CARLA_SAFE_EXCEPTION("patchbayRefresh");

  172.         }

  173.         else if (std::strcmp(msg, "transport_play") == 0)

  174.         {

  175.             fEngine->transportPlay();

  176.         }

  177.         else if (std::strcmp(msg, "transport_pause") == 0)

  178.         {

  179.             fEngine->transportPause();

  180.         }

  181.         else if (std::strcmp(msg, "transport_relocate") == 0)

  182.         {

  183.             uint64_t frame;

  184. 

  185.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsULong(frame), true);

  186. 

  187.             fEngine->transportRelocate(frame);

  188.         }

  189.         else if (std::strcmp(msg, "add_plugin") == 0)

  190.         {

  191.             uint32_t btype, ptype;

  192.             const char* filename = nullptr;

  193.             const char* name;

  194.             const char* label;

  195.             int64_t uniqueId;

  196. 

  197.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(btype), true);

  198.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(ptype), true);

  199.             readNextLineAsString(filename); // can be null

  200.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(name), true);

  201.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(label), true);

  202.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsLong(uniqueId), true);

  203. 

  204.             if (filename != nullptr && std::strcmp(filename, "(null)") == 0)

  205.             {

  206.                 delete[] filename;

  207.                 filename = nullptr;

  208.             }

  209. 

  210.             if (std::strcmp(name, "(null)") == 0)

  211.             {

  212.                 delete[] name;

  213.                 name = nullptr;

  214.             }

  215. 

  216.             ok = fEngine->addPlugin(static_cast<BinaryType>(btype), static_cast<PluginType>(ptype), filename, name, label, uniqueId, nullptr);

  217. 

  218.             if (filename != nullptr)

  219.                 delete[] filename;

  220.             if (name != nullptr)

  221.                 delete[] name;

  222.             delete[] label;

  223.         }

  224.         else if (std::strcmp(msg, "remove_plugin") == 0)

  225.         {

  226.             uint32_t pluginId;

  227. 

  228.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  229. 

  230.             ok = fEngine->removePlugin(pluginId);

  231.         }

  232.         else if (std::strcmp(msg, "remove_all_plugins") == 0)

  233.         {

  234.             ok = fEngine->removeAllPlugins();

  235.         }

  236.         else if (std::strcmp(msg, "rename_plugin") == 0)

  237.         {

  238.             uint32_t pluginId;

  239.             const char* newName;

  240. 

  241.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  242.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(newName), true);

  243. 

  244.             // TODO

  245.             /*const char* name =*/ fEngine->renamePlugin(pluginId, newName);

  246. 

  247.             delete[] newName;

  248.         }

  249.         else if (std::strcmp(msg, "clone_plugin") == 0)

  250.         {

  251.             uint32_t pluginId;

  252. 

  253.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  254. 

  255.             ok = fEngine->clonePlugin(pluginId);

  256.         }

  257.         else if (std::strcmp(msg, "replace_plugin") == 0)

  258.         {

  259.             uint32_t pluginId;

  260. 

  261.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  262. 

  263.             ok = fEngine->replacePlugin(pluginId);

  264.         }

  265.         else if (std::strcmp(msg, "switch_plugins") == 0)

  266.         {

  267.             uint32_t pluginIdA, pluginIdB;

  268. 

  269.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginIdA), true);

  270.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginIdB), true);

  271. 

  272.             ok = fEngine->switchPlugins(pluginIdA, pluginIdB);

  273.         }

  274.         else if (std::strcmp(msg, "load_plugin_state") == 0)

  275.         {

  276.             uint32_t pluginId;

  277.             const char* filename;

  278. 

  279.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  280.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);

  281. 

  282.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  283.                 plugin->loadStateFromFile(filename);

  284. 

  285.             delete[] filename;

  286.         }

  287.         else if (std::strcmp(msg, "save_plugin_state") == 0)

  288.         {

  289.             uint32_t pluginId;

  290.             const char* filename;

  291. 

  292.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  293.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);

  294. 

  295.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  296.                 plugin->saveStateToFile(filename);

  297. 

  298.             delete[] filename;

  299.         }

  300.         else if (std::strcmp(msg, "set_option") == 0)

  301.         {

  302.             uint32_t pluginId, option;

  303.             bool yesNo;

  304. 

  305.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  306.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(option), true);

  307.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(yesNo), true);

  308. 

  309.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  310.                 plugin->setOption(option, yesNo, false);

  311.         }

  312.         else if (std::strcmp(msg, "set_active") == 0)

  313.         {

  314.             uint32_t pluginId;

  315.             bool onOff;

  316. 

  317.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  318.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(onOff), true);

  319. 

  320.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  321.                 plugin->setActive(onOff, true, false);

  322.         }

  323.         else if (std::strcmp(msg, "set_drywet") == 0)

  324.         {

  325.             uint32_t pluginId;

  326.             float value;

  327. 

  328.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  329.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);

  330. 

  331.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  332.                 plugin->setDryWet(value, true, false);

  333.         }

  334.         else if (std::strcmp(msg, "set_volume") == 0)

  335.         {

  336.             uint32_t pluginId;

  337.             float value;

  338. 

  339.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  340.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);

  341. 

  342.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  343.                 plugin->setVolume(value, true, false);

  344.         }

  345.         else if (std::strcmp(msg, "set_balance_left") == 0)

  346.         {

  347.             uint32_t pluginId;

  348.             float value;

  349. 

  350.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  351.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);

  352. 

  353.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  354.                 plugin->setBalanceLeft(value, true, false);

  355.         }

  356.         else if (std::strcmp(msg, "set_balance_right") == 0)

  357.         {

  358.             uint32_t pluginId;

  359.             float value;

  360. 

  361.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  362.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);

  363. 

  364.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  365.                 plugin->setBalanceRight(value, true, false);

  366.         }

  367.         else if (std::strcmp(msg, "set_panning") == 0)

  368.         {

  369.             uint32_t pluginId;

  370.             float value;

  371. 

  372.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  373.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);

  374. 

  375.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  376.                 plugin->setPanning(value, true, false);

  377.         }

  378.         else if (std::strcmp(msg, "set_ctrl_channel") == 0)

  379.         {

  380.             uint32_t pluginId;

  381.             int32_t channel;

  382. 

  383.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  384.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(channel), true);

  385.             CARLA_SAFE_ASSERT_RETURN(channel >= -1 && channel < MAX_MIDI_CHANNELS, true);

  386. 

  387.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  388.                 plugin->setCtrlChannel(int8_t(channel), true, false);

  389.         }

  390.         else if (std::strcmp(msg, "set_parameter_value") == 0)

  391.         {

  392.             uint32_t pluginId, parameterId;

  393.             float value;

  394. 

  395.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  396.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);

  397.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);

  398. 

  399.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  400.                 plugin->setParameterValue(parameterId, value, true, true, false);

  401.         }

  402.         else if (std::strcmp(msg, "set_parameter_midi_channel") == 0)

  403.         {

  404.             uint32_t pluginId, parameterId, channel;

  405. 

  406.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  407.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);

  408.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(channel), true);

  409.             CARLA_SAFE_ASSERT_RETURN(channel < MAX_MIDI_CHANNELS, true);

  410. 

  411.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  412.                 plugin->setParameterMidiChannel(parameterId, static_cast<uint8_t>(channel), true, false);

  413.         }

  414.         else if (std::strcmp(msg, "set_parameter_midi_cc") == 0)

  415.         {

  416.             uint32_t pluginId, parameterId;

  417.             int32_t cc;

  418. 

  419.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  420.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);

  421.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(cc), true);

  422.             CARLA_SAFE_ASSERT_RETURN(cc >= -1 && cc < 0x5F, true);

  423. 

  424.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  425.                 plugin->setParameterMidiCC(parameterId, static_cast<int16_t>(cc), true, false);

  426.         }

  427.         else if (std::strcmp(msg, "set_program") == 0)

  428.         {

  429.             uint32_t pluginId;

  430.             int32_t index;

  431. 

  432.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  433.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(index), true);

  434. 

  435.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  436.                 plugin->setProgram(index, true, true, false);

  437.         }

  438.         else if (std::strcmp(msg, "set_midi_program") == 0)

  439.         {

  440.             uint32_t pluginId;

  441.             int32_t index;

  442. 

  443.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  444.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(index), true);

  445. 

  446.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  447.                 plugin->setMidiProgram(index, true, true, false);

  448.         }

  449.         else if (std::strcmp(msg, "set_custom_data") == 0)

  450.         {

  451.             uint32_t pluginId;

  452.             const char* type;

  453.             const char* key;

  454.             const char* value;

  455. 

  456.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  457.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(type), true);

  458.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(key), true);

  459.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(value), true);

  460. 

  461.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  462.                 plugin->setCustomData(type, key, value, true);

  463. 

  464.             delete[] type;

  465.             delete[] key;

  466.             delete[] value;

  467.         }

  468.         else if (std::strcmp(msg, "set_chunk_data") == 0)

  469.         {

  470.             uint32_t pluginId;

  471.             const char* cdata;

  472. 

  473.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  474.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(cdata), true);

  475. 

  476.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  477.             {

  478.                 std::vector<uint8_t> chunk(carla_getChunkFromBase64String(cdata));

  479.                 plugin->setChunkData(chunk.data(), chunk.size());

  480.             }

  481. 

  482.             delete[] cdata;

  483.         }

  484.         else if (std::strcmp(msg, "prepare_for_save") == 0)

  485.         {

  486.             uint32_t pluginId;

  487. 

  488.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  489. 

  490.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  491.                 plugin->prepareForSave();

  492.         }

  493.         else if (std::strcmp(msg, "reset_parameters") == 0)

  494.         {

  495.             uint32_t pluginId;

  496. 

  497.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  498. 

  499.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  500.                 plugin->resetParameters();

  501.         }

  502.         else if (std::strcmp(msg, "randomize_parameters") == 0)

  503.         {

  504.             uint32_t pluginId;

  505. 

  506.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  507. 

  508.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  509.                 plugin->randomizeParameters();

  510.         }

  511.         else if (std::strcmp(msg, "send_midi_note") == 0)

  512.         {

  513.             uint32_t pluginId, channel, note, velocity;

  514. 

  515.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  516.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(channel), true);

  517.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(note), true);

  518.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(velocity), true);

  519.             CARLA_SAFE_ASSERT_RETURN(channel < MAX_MIDI_CHANNELS, true);

  520.             CARLA_SAFE_ASSERT_RETURN(note < MAX_MIDI_VALUE, true);

  521.             CARLA_SAFE_ASSERT_RETURN(velocity < MAX_MIDI_VALUE, true);

  522. 

  523.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  524.                 plugin->sendMidiSingleNote(static_cast<uint8_t>(channel), static_cast<uint8_t>(note), static_cast<uint8_t>(velocity), true, true, false);

  525.         }

  526.         else if (std::strcmp(msg, "show_custom_ui") == 0)

  527.         {

  528.             uint32_t pluginId;

  529.             bool yesNo;

  530. 

  531.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);

  532.             CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(yesNo), true);

  533. 

  534.             if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))

  535.                 plugin->showCustomUI(yesNo);

  536.         }

  537.         else

  538.         {

  539.             carla_stderr("msgReceived : %s", msg);

  540.             return false;

  541.         }

  542. 

  543.         if (! ok)

  544.         {

  545.             const CarlaMutexLocker cml(fWriteLock);

  546.             writeMsg("error\n", 6);

  547.             writeAndFixMsg(fEngine->getLastError());

  548.         }

  549. 

  550.         return true;

  551.     }

  552. 

  553. private:

  554.     CarlaEngine* const fEngine;

  555. 

  556.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineNativeUI)

  557. };

  558. 

  559. // -----------------------------------------------------------------------

  560. 

  561. class CarlaEngineNative : public CarlaEngine

  562. {

  563. public:

  564.     CarlaEngineNative(const NativeHostDescriptor* const host, const bool isPatchbay)

  565.         : CarlaEngine(),

  566.           pHost(host),

  567.           kIsPatchbay(isPatchbay),

  568.           fIsActive(false),

  569.           fIsRunning(false),

  570.           fUiServer(this),

  571.           leakDetector_CarlaEngineNative()

  572.     {

  573.         carla_debug("CarlaEngineNative::CarlaEngineNative()");

  574. 

  575.         CARLA_SAFE_ASSERT_INT(gJuceReferenceCounter >= 0, gJuceReferenceCounter);

  576. 

  577.         if (gNeedsJuceHandling && ++gJuceReferenceCounter == 1)

  578.             juce::initialiseJuce_GUI();

  579. 

  580.         carla_zeroChar(fTmpBuf, STR_MAX+1);

  581. 

  582.         // set-up engine

  583.         if (kIsPatchbay)

  584.         {

  585.             pData->options.processMode         = ENGINE_PROCESS_MODE_PATCHBAY;

  586.             pData->options.transportMode       = ENGINE_TRANSPORT_MODE_PLUGIN;

  587.             pData->options.forceStereo         = false;

  588.             pData->options.preferPluginBridges = false;

  589.             pData->options.preferUiBridges     = false;

  590.             init("Carla-Patchbay");

  591.             pData->graph.create(false, pData->sampleRate, pData->bufferSize, 2, 2);

  592.         }

  593.         else

  594.         {

  595.             pData->options.processMode         = ENGINE_PROCESS_MODE_CONTINUOUS_RACK;

  596.             pData->options.transportMode       = ENGINE_TRANSPORT_MODE_PLUGIN;

  597.             pData->options.forceStereo         = true;

  598.             pData->options.preferPluginBridges = false;

  599.             pData->options.preferUiBridges     = false;

  600.             init("Carla-Rack");

  601.             pData->graph.create(true, pData->sampleRate, pData->bufferSize, 0, 0);

  602.         }

  603. 

  604.         if (pData->options.resourceDir != nullptr)

  605.             delete[] pData->options.resourceDir;

  606.         if (pData->options.binaryDir != nullptr)

  607.             delete[] pData->options.binaryDir;

  608. 

  609.         pData->options.resourceDir = carla_strdup(pHost->resourceDir);

  610.         pData->options.binaryDir   = carla_strdup(File(pHost->resourceDir).getParentDirectory().getFullPathName().toRawUTF8());

  611. 

  612.         setCallback(_ui_server_callback, this);

  613.     }

  614. 

  615.     ~CarlaEngineNative() override

  616.     {

  617.         CARLA_SAFE_ASSERT(! fIsActive);

  618.         carla_debug("CarlaEngineNative::~CarlaEngineNative() - START");

  619. 

  620.         pData->aboutToClose = true;

  621.         fIsRunning = false;

  622. 

  623.         removeAllPlugins();

  624.         //runPendingRtEvents();

  625.         close();

  626. 

  627.         pData->graph.destroy();

  628. 

  629.         if (gNeedsJuceHandling && --gJuceReferenceCounter == 0)

  630.             juce::shutdownJuce_GUI();

  631. 

  632.         carla_debug("CarlaEngineNative::~CarlaEngineNative() - END");

  633.     }

  634. 

  635. protected:

  636.     // -------------------------------------

  637.     // CarlaEngine virtual calls

  638. 

  639.     bool init(const char* const clientName) override

  640.     {

  641.         carla_debug("CarlaEngineNative::init(\"%s\")", clientName);

  642. 

  643.         if (! pData->init(clientName))

  644.         {

  645.             close();

  646.             setLastError("Failed to init internal data");

  647.             return false;

  648.         }

  649. 

  650.         pData->bufferSize = pHost->get_buffer_size(pHost->handle);

  651.         pData->sampleRate = pHost->get_sample_rate(pHost->handle);

  652. 

  653.         fIsRunning = true;

  654.         return true;

  655.     }

  656. 

  657.     bool isRunning() const noexcept override

  658.     {

  659.         return fIsRunning;

  660.     }

  661. 

  662.     bool isOffline() const noexcept override

  663.     {

  664.         return pHost->is_offline(pHost->handle);

  665.     }

  666. 

  667.     EngineType getType() const noexcept override

  668.     {

  669.         return kEngineTypePlugin;

  670.     }

  671. 

  672.     const char* getCurrentDriverName() const noexcept override

  673.     {

  674.         return "Plugin";

  675.     }

  676. 

  677.     // -------------------------------------------------------------------

  678. 

  679.     const char* renamePlugin(const uint id, const char* const newName) override

  680.     {

  681.         if (const char* const retName = CarlaEngine::renamePlugin(id, newName))

  682.         {

  683.             uiServerCallback(ENGINE_CALLBACK_PLUGIN_RENAMED, id, 0, 0, 0.0f, retName);

  684.             return retName;

  685.         }

  686. 

  687.         return nullptr;

  688.     }

  689. 

  690.     // -------------------------------------------------------------------

  691. 

  692.     void bufferSizeChanged(const uint32_t newBufferSize)

  693.     {

  694.         if (pData->bufferSize == newBufferSize)

  695.             return;

  696. 

  697.         pData->bufferSize = newBufferSize;

  698.         CarlaEngine::bufferSizeChanged(newBufferSize);

  699.     }

  700. 

  701.     void sampleRateChanged(const double newSampleRate)

  702.     {

  703.         if (carla_compareFloats(pData->sampleRate, newSampleRate))

  704.             return;

  705. 

  706.         pData->sampleRate = newSampleRate;

  707.         CarlaEngine::sampleRateChanged(newSampleRate);

  708.     }

  709. 

  710.     // -------------------------------------------------------------------

  711. 

  712.     void uiServerSendPluginInfo(CarlaPlugin* const plugin)

  713.     {

  714.         const CarlaMutexLocker cml(fUiServer.getWriteLock());

  715. 

  716.         const uint pluginId(plugin->getId());

  717. 

  718.         std::sprintf(fTmpBuf, "PLUGIN_INFO_%i\n", pluginId);

  719.         fUiServer.writeMsg(fTmpBuf);

  720. 

  721.         std::sprintf(fTmpBuf, "%i:%i:%i:" P_INT64 ":%i:%i\n", plugin->getType(), plugin->getCategory(), plugin->getHints(), plugin->getUniqueId(), plugin->getOptionsAvailable(), plugin->getOptionsEnabled());

  722.         fUiServer.writeMsg(fTmpBuf);

  723. 

  724.         if (const char* const filename = plugin->getFilename())

  725.         {

  726.             std::sprintf(fTmpBuf, "%s", filename);

  727.             fUiServer.writeAndFixMsg(fTmpBuf);

  728.         }

  729.         else

  730.             fUiServer.writeMsg("\n");

  731. 

  732.         if (const char* const name = plugin->getName())

  733.         {

  734.             std::sprintf(fTmpBuf, "%s", name);

  735.             fUiServer.writeAndFixMsg(fTmpBuf);

  736.         }

  737.         else

  738.             fUiServer.writeMsg("\n");

  739. 

  740.         if (const char* const iconName = plugin->getIconName())

  741.         {

  742.             std::sprintf(fTmpBuf, "%s", iconName);

  743.             fUiServer.writeAndFixMsg(fTmpBuf);

  744.         }

  745.         else

  746.             fUiServer.writeMsg("\n");

  747. 

  748.         plugin->getRealName(fTmpBuf);

  749.         fUiServer.writeAndFixMsg(fTmpBuf);

  750. 

  751.         plugin->getLabel(fTmpBuf);

  752.         fUiServer.writeAndFixMsg(fTmpBuf);

  753. 

  754.         plugin->getMaker(fTmpBuf);

  755.         fUiServer.writeAndFixMsg(fTmpBuf);

  756. 

  757.         plugin->getCopyright(fTmpBuf);

  758.         fUiServer.writeAndFixMsg(fTmpBuf);

  759. 

  760.         std::sprintf(fTmpBuf, "AUDIO_COUNT_%i:%i:%i\n", pluginId, plugin->getAudioInCount(), plugin->getAudioOutCount());

  761.         fUiServer.writeMsg(fTmpBuf);

  762. 

  763.         std::sprintf(fTmpBuf, "MIDI_COUNT_%i:%i:%i\n", pluginId, plugin->getMidiInCount(), plugin->getMidiOutCount());

  764.         fUiServer.writeMsg(fTmpBuf);

  765.     }

  766. 

  767.     void uiServerSendPluginParameters(CarlaPlugin* const plugin)

  768.     {

  769.         const CarlaMutexLocker cml(fUiServer.getWriteLock());

  770. 

  771.         const uint pluginId(plugin->getId());

  772. 

  773.         uint32_t ins, outs, count;

  774.         plugin->getParameterCountInfo(ins, outs);

  775.         count = plugin->getParameterCount();

  776.         std::sprintf(fTmpBuf, "PARAMETER_COUNT_%i:%i:%i:%i\n", pluginId, ins, outs, count);

  777.         fUiServer.writeMsg(fTmpBuf);

  778. 

  779.         for (uint32_t i=0; i<count; ++i)

  780.         {

  781.             const ParameterData& paramData(plugin->getParameterData(i));

  782.             const ParameterRanges& paramRanges(plugin->getParameterRanges(i));

  783. 

  784.             std::sprintf(fTmpBuf, "PARAMETER_DATA_%i:%i\n", pluginId, i);

  785.             fUiServer.writeMsg(fTmpBuf);

  786.             std::sprintf(fTmpBuf, "%i:%i:%i:%i\n", paramData.type, paramData.hints, paramData.midiChannel, paramData.midiCC);

  787.             fUiServer.writeMsg(fTmpBuf);

  788.             plugin->getParameterName(i, fTmpBuf);

  789.             fUiServer.writeAndFixMsg(fTmpBuf);

  790.             plugin->getParameterUnit(i, fTmpBuf);

  791.             fUiServer.writeAndFixMsg(fTmpBuf);

  792. 

  793.             std::sprintf(fTmpBuf, "PARAMETER_RANGES_%i:%i\n", pluginId, i);

  794.             fUiServer.writeMsg(fTmpBuf);

  795.             std::sprintf(fTmpBuf, "%f:%f:%f:%f:%f:%f\n", paramRanges.def, paramRanges.min, paramRanges.max, paramRanges.step, paramRanges.stepSmall, paramRanges.stepLarge);

  796.             fUiServer.writeMsg(fTmpBuf);

  797. 

  798.             std::sprintf(fTmpBuf, "PARAMVAL_%i:%i\n", pluginId, i);

  799.             fUiServer.writeMsg(fTmpBuf);

  800.             std::sprintf(fTmpBuf, "%f\n", plugin->getParameterValue(i));

  801.             fUiServer.writeMsg(fTmpBuf);

  802.         }

  803.     }

  804. 

  805.     void uiServerSendPluginPrograms(CarlaPlugin* const plugin)

  806.     {

  807.         const CarlaMutexLocker cml(fUiServer.getWriteLock());

  808. 

  809.         const uint pluginId(plugin->getId());

  810. 

  811.         uint32_t count = plugin->getProgramCount();

  812.         std::sprintf(fTmpBuf, "PROGRAM_COUNT_%i:%i:%i\n", pluginId, count, plugin->getCurrentProgram());

  813.         fUiServer.writeMsg(fTmpBuf);

  814. 

  815.         for (uint32_t i=0; i<count; ++i)

  816.         {

  817.             std::sprintf(fTmpBuf, "PROGRAM_NAME_%i:%i\n", pluginId, i);

  818.             fUiServer.writeMsg(fTmpBuf);

  819.             plugin->getProgramName(i, fTmpBuf);

  820.             fUiServer.writeAndFixMsg(fTmpBuf);

  821.         }

  822. 

  823.         count = plugin->getMidiProgramCount();

  824.         std::sprintf(fTmpBuf, "MIDI_PROGRAM_COUNT_%i:%i:%i\n", pluginId, count, plugin->getCurrentMidiProgram());

  825.         fUiServer.writeMsg(fTmpBuf);

  826. 

  827.         for (uint32_t i=0; i<count; ++i)

  828.         {

  829.             std::sprintf(fTmpBuf, "MIDI_PROGRAM_DATA_%i:%i\n", pluginId, i);

  830.             fUiServer.writeMsg(fTmpBuf);

  831. 

  832.             const MidiProgramData& mpData(plugin->getMidiProgramData(i));

  833.             std::sprintf(fTmpBuf, "%i:%i\n", mpData.bank, mpData.program);

  834.             fUiServer.writeMsg(fTmpBuf);

  835.             std::sprintf(fTmpBuf, "%s", mpData.name);

  836.             fUiServer.writeAndFixMsg(fTmpBuf);

  837.         }

  838.     }

  839. 

  840.     void uiServerCallback(const EngineCallbackOpcode action, const uint pluginId, const int value1, const int value2, const float value3, const char* const valueStr)

  841.     {

  842.         if (! fIsRunning)

  843.             return;

  844.         if (! fUiServer.isOk())

  845.             return;

  846. 

  847.         CarlaPlugin* plugin;

  848. 

  849.         switch (action)

  850.         {

  851.         case ENGINE_CALLBACK_RELOAD_INFO:

  852.             plugin = getPlugin(pluginId);

  853. 

  854.             if (plugin != nullptr && plugin->isEnabled())

  855.             {

  856.                 CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);

  857.                 uiServerSendPluginInfo(plugin);

  858.             }

  859.             break;

  860. 

  861.         case ENGINE_CALLBACK_RELOAD_PARAMETERS:

  862.             plugin = getPlugin(pluginId);

  863. 

  864.             if (plugin != nullptr && plugin->isEnabled())

  865.             {

  866.                 CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);

  867.                 uiServerSendPluginParameters(plugin);

  868.             }

  869.             break;

  870. 

  871.         case ENGINE_CALLBACK_RELOAD_PROGRAMS:

  872.             plugin = getPlugin(pluginId);

  873. 

  874.             if (plugin != nullptr && plugin->isEnabled())

  875.             {

  876.                 CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);

  877.                 uiServerSendPluginPrograms(plugin);

  878.             }

  879.             break;

  880. 

  881.         case ENGINE_CALLBACK_RELOAD_ALL:

  882.         case ENGINE_CALLBACK_PLUGIN_ADDED:

  883.             plugin = getPlugin(pluginId);

  884. 

  885.             if (plugin != nullptr && plugin->isEnabled())

  886.             {

  887.                 CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);

  888.                 uiServerSendPluginInfo(plugin);

  889.                 uiServerSendPluginParameters(plugin);

  890.                 uiServerSendPluginPrograms(plugin);

  891.             }

  892.             break;

  893. 

  894.         default:

  895.             break;

  896.         }

  897. 

  898.         const CarlaMutexLocker cml(fUiServer.getWriteLock());

  899. 

  900.         std::sprintf(fTmpBuf, "ENGINE_CALLBACK_%i\n", int(action));

  901.         fUiServer.writeMsg(fTmpBuf);

  902. 

  903.         std::sprintf(fTmpBuf, "%u\n", pluginId);

  904.         fUiServer.writeMsg(fTmpBuf);

  905. 

  906.         std::sprintf(fTmpBuf, "%i\n", value1);

  907.         fUiServer.writeMsg(fTmpBuf);

  908. 

  909.         std::sprintf(fTmpBuf, "%i\n", value2);

  910.         fUiServer.writeMsg(fTmpBuf);

  911. 

  912.         std::sprintf(fTmpBuf, "%f\n", value3);

  913.         fUiServer.writeMsg(fTmpBuf);

  914. 

  915.         fUiServer.writeAndFixMsg(valueStr);

  916.     }

  917. 

  918.     // -------------------------------------------------------------------

  919.     // Plugin parameter calls

  920. 

  921.     uint32_t getParameterCount() const

  922.     {

  923.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  924.             return plugin->getParameterCount();

  925. 

  926.         return 0;

  927.     }

  928. 

  929.     const NativeParameter* getParameterInfo(const uint32_t index) const

  930.     {

  931.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  932.         {

  933.             if (index < plugin->getParameterCount())

  934.             {

  935.                 static NativeParameter param;

  936.                 static char strBufName[STR_MAX+1];

  937.                 static char strBufUnit[STR_MAX+1];

  938. 

  939.                 const ParameterData& paramData(plugin->getParameterData(index));

  940.                 const ParameterRanges& paramRanges(plugin->getParameterRanges(index));

  941. 

  942.                 plugin->getParameterName(index, strBufName);

  943.                 plugin->getParameterUnit(index, strBufUnit);

  944. 

  945.                 uint hints = 0x0;

  946. 

  947.                 if (paramData.hints & PARAMETER_IS_BOOLEAN)

  948.                     hints |= ::PARAMETER_IS_BOOLEAN;

  949.                 if (paramData.hints & PARAMETER_IS_INTEGER)

  950.                     hints |= ::PARAMETER_IS_INTEGER;

  951.                 if (paramData.hints & PARAMETER_IS_LOGARITHMIC)

  952.                     hints |= ::PARAMETER_IS_LOGARITHMIC;

  953.                 if (paramData.hints & PARAMETER_IS_AUTOMABLE)

  954.                     hints |= ::PARAMETER_IS_AUTOMABLE;

  955.                 if (paramData.hints & PARAMETER_USES_SAMPLERATE)

  956.                     hints |= ::PARAMETER_USES_SAMPLE_RATE;

  957.                 if (paramData.hints & PARAMETER_USES_SCALEPOINTS)

  958.                     hints |= ::PARAMETER_USES_SCALEPOINTS;

  959.                 if (paramData.hints & PARAMETER_USES_CUSTOM_TEXT)

  960.                     hints |= ::PARAMETER_USES_CUSTOM_TEXT;

  961. 

  962.                 if (paramData.type == PARAMETER_INPUT || paramData.type == PARAMETER_OUTPUT)

  963.                 {

  964.                     if (paramData.hints & PARAMETER_IS_ENABLED)

  965.                         hints |= ::PARAMETER_IS_ENABLED;

  966.                     if (paramData.type == PARAMETER_OUTPUT)

  967.                         hints |= ::PARAMETER_IS_OUTPUT;

  968.                 }

  969. 

  970.                 param.hints = static_cast<NativeParameterHints>(hints);

  971.                 param.name  = strBufName;

  972.                 param.unit  = strBufUnit;

  973.                 param.ranges.def = paramRanges.def;

  974.                 param.ranges.min = paramRanges.min;

  975.                 param.ranges.max = paramRanges.max;

  976.                 param.ranges.step = paramRanges.step;

  977.                 param.ranges.stepSmall = paramRanges.stepSmall;

  978.                 param.ranges.stepLarge = paramRanges.stepLarge;

  979.                 param.scalePointCount = 0; // TODO

  980.                 param.scalePoints = nullptr;

  981. 

  982.                 return &param;

  983.             }

  984.         }

  985. 

  986.         return nullptr;

  987.     }

  988. 

  989.     float getParameterValue(const uint32_t index) const

  990.     {

  991.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  992.         {

  993.             if (index < plugin->getParameterCount())

  994.                 return plugin->getParameterValue(index);

  995.         }

  996. 

  997.         return 0.0f;

  998.     }

  999. 

  1000.     const char* getParameterText(const uint32_t index /*, const float value*/) const

  1001.     {

  1002.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  1003.         {

  1004.             if (index < plugin->getParameterCount())

  1005.             {

  1006.                 static char strBuf[STR_MAX+1];

  1007.                 carla_zeroChar(strBuf, STR_MAX+1);

  1008. 

  1009.                 plugin->getParameterText(index, /*value,*/ strBuf);

  1010. 

  1011.                 return strBuf;

  1012.             }

  1013.         }

  1014. 

  1015.         return nullptr;

  1016.     }

  1017. 

  1018.     // -------------------------------------------------------------------

  1019.     // Plugin midi-program calls

  1020. 

  1021.     uint32_t getMidiProgramCount() const

  1022.     {

  1023.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  1024.             return plugin->getMidiProgramCount();

  1025. 

  1026.         return 0;

  1027.     }

  1028. 

  1029.     const NativeMidiProgram* getMidiProgramInfo(const uint32_t index) const

  1030.     {

  1031.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  1032.         {

  1033.             if (index < plugin->getMidiProgramCount())

  1034.             {

  1035.                 static NativeMidiProgram midiProg;

  1036. 

  1037.                 {

  1038.                     const MidiProgramData& midiProgData(plugin->getMidiProgramData(index));

  1039. 

  1040.                     midiProg.bank    = midiProgData.bank;

  1041.                     midiProg.program = midiProgData.program;

  1042.                     midiProg.name    = midiProgData.name;

  1043.                 }

  1044. 

  1045.                 return &midiProg;

  1046.             }

  1047.         }

  1048. 

  1049.         return nullptr;

  1050.     }

  1051. 

  1052.     // -------------------------------------------------------------------

  1053.     // Plugin state calls

  1054. 

  1055.     void setParameterValue(const uint32_t index, const float value)

  1056.     {

  1057.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  1058.         {

  1059.             if (index < plugin->getParameterCount())

  1060.                 plugin->setParameterValue(index, value, false, false, false);

  1061.         }

  1062.     }

  1063. 

  1064.     void setMidiProgram(const uint8_t, const uint32_t bank, const uint32_t program)

  1065.     {

  1066.         if (CarlaPlugin* const plugin = _getFirstPlugin())

  1067.             plugin->setMidiProgramById(bank, program, false, false, false);

  1068.     }

  1069. 

  1070.     // -------------------------------------------------------------------

  1071.     // Plugin process calls

  1072. 

  1073.     void activate()

  1074.     {

  1075. #if 0

  1076.         for (uint32_t i=0; i < pData->curPluginCount; ++i)

  1077.         {

  1078.             CarlaPlugin* const plugin(pData->plugins[i].plugin);

  1079. 

  1080.             if (plugin == nullptr || ! plugin->isEnabled())

  1081.                 continue;

  1082. 

  1083.             plugin->setActive(true, true, false);

  1084.         }

  1085. #endif

  1086.         fIsActive = true;

  1087.     }

  1088. 

  1089.     void deactivate()

  1090.     {

  1091.         fIsActive = false;

  1092. #if 0

  1093.         for (uint32_t i=0; i < pData->curPluginCount; ++i)

  1094.         {

  1095.             CarlaPlugin* const plugin(pData->plugins[i].plugin);

  1096. 

  1097.             if (plugin == nullptr || ! plugin->isEnabled())

  1098.                 continue;

  1099. 

  1100.             plugin->setActive(false, true, false);

  1101.         }

  1102. #endif

  1103. 

  1104.         // just in case

  1105.         //runPendingRtEvents();

  1106.     }

  1107. 

  1108.     void process(float** const inBuffer, float** const outBuffer, const uint32_t frames, const NativeMidiEvent* const midiEvents, const uint32_t midiEventCount)

  1109.     {

  1110.         const PendingRtEventsRunner prt(this);

  1111. 

  1112.         if (pData->curPluginCount == 0 && ! kIsPatchbay)

  1113.         {

  1114.             FloatVectorOperations::copy(outBuffer[0], inBuffer[0], static_cast<int>(frames));

  1115.             FloatVectorOperations::copy(outBuffer[1], inBuffer[1], static_cast<int>(frames));

  1116.             return;

  1117.         }

  1118. 

  1119.         // ---------------------------------------------------------------

  1120.         // Time Info

  1121. 

  1122.         const NativeTimeInfo* const timeInfo(pHost->get_time_info(pHost->handle));

  1123. 

  1124.         pData->timeInfo.playing = timeInfo->playing;

  1125.         pData->timeInfo.frame   = timeInfo->frame;

  1126.         pData->timeInfo.usecs   = timeInfo->usecs;

  1127.         pData->timeInfo.valid   = 0x0;

  1128. 

  1129.         if (timeInfo->bbt.valid)

  1130.         {

  1131.             pData->timeInfo.valid |= EngineTimeInfo::kValidBBT;

  1132. 

  1133.             pData->timeInfo.bbt.bar = timeInfo->bbt.bar;

  1134.             pData->timeInfo.bbt.beat = timeInfo->bbt.beat;

  1135.             pData->timeInfo.bbt.tick = timeInfo->bbt.tick;

  1136.             pData->timeInfo.bbt.barStartTick = timeInfo->bbt.barStartTick;

  1137. 

  1138.             pData->timeInfo.bbt.beatsPerBar = timeInfo->bbt.beatsPerBar;

  1139.             pData->timeInfo.bbt.beatType = timeInfo->bbt.beatType;

  1140. 

  1141.             pData->timeInfo.bbt.ticksPerBeat = timeInfo->bbt.ticksPerBeat;

  1142.             pData->timeInfo.bbt.beatsPerMinute = timeInfo->bbt.beatsPerMinute;

  1143.         }

  1144. 

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

  1146.         // initialize events

  1147. 

  1148.         carla_zeroStruct<EngineEvent>(pData->events.in,  kMaxEngineEventInternalCount);

  1149.         carla_zeroStruct<EngineEvent>(pData->events.out, kMaxEngineEventInternalCount);

  1150. 

  1151.         // ---------------------------------------------------------------

  1152.         // events input (before processing)

  1153. 

  1154.         {

  1155.             uint32_t engineEventIndex = 0;

  1156. 

  1157.             for (uint32_t i=0; i < midiEventCount && engineEventIndex < kMaxEngineEventInternalCount; ++i)

  1158.             {

  1159.                 const NativeMidiEvent& midiEvent(midiEvents[i]);

  1160.                 EngineEvent&           engineEvent(pData->events.in[engineEventIndex++]);

  1161. 

  1162.                 engineEvent.time = midiEvent.time;

  1163.                 engineEvent.fillFromMidiData(midiEvent.size, midiEvent.data);

  1164. 

  1165.                 if (engineEventIndex >= kMaxEngineEventInternalCount)

  1166.                     break;

  1167.             }

  1168.         }

  1169. 

  1170.         if (kIsPatchbay)

  1171.         {

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

  1173.             // process

  1174. 

  1175.             pData->graph.process(pData, inBuffer, outBuffer, frames);

  1176.         }

  1177.         else

  1178.         {

  1179.             // -----------------------------------------------------------

  1180.             // create audio buffers

  1181. 

  1182.             const float* inBuf[2]  = {  inBuffer[0],  inBuffer[1] };

  1183.             /* */ float* outBuf[2] = { outBuffer[0], outBuffer[1] };

  1184. 

  1185.             // -----------------------------------------------------------

  1186.             // process

  1187. 

  1188.             pData->graph.processRack(pData, inBuf, outBuf, frames);

  1189.         }

  1190. 

  1191.         // ---------------------------------------------------------------

  1192.         // events output (after processing)

  1193. 

  1194.         carla_zeroStruct<EngineEvent>(pData->events.in, kMaxEngineEventInternalCount);

  1195. 

  1196.         {

  1197.             NativeMidiEvent midiEvent;

  1198. 

  1199.             for (uint32_t i=0; i < kMaxEngineEventInternalCount; ++i)

  1200.             {

  1201.                 const EngineEvent& engineEvent(pData->events.out[i]);

  1202. 

  1203.                 if (engineEvent.type == kEngineEventTypeNull)

  1204.                     break;

  1205. 

  1206.                 midiEvent.time = engineEvent.time;

  1207. 

  1208.                 if (engineEvent.type == CarlaBackend::kEngineEventTypeControl)

  1209.                 {

  1210.                     midiEvent.port = 0;

  1211.                     engineEvent.ctrl.convertToMidiData(engineEvent.channel, midiEvent.size, midiEvent.data);

  1212.                 }

  1213.                 else if (engineEvent.type == kEngineEventTypeMidi)

  1214.                 {

  1215.                     if (engineEvent.midi.size > 4 || engineEvent.midi.dataExt != nullptr)

  1216.                         continue;

  1217. 

  1218.                     midiEvent.port = engineEvent.midi.port;

  1219.                     midiEvent.size = engineEvent.midi.size;

  1220. 

  1221.                     midiEvent.data[0] = static_cast<uint8_t>(engineEvent.midi.data[0] + engineEvent.channel);

  1222. 

  1223.                     for (uint8_t j=1; j < midiEvent.size; ++j)

  1224.                         midiEvent.data[j] = engineEvent.midi.data[j];

  1225.                 }

  1226.                 else

  1227.                 {

  1228.                     carla_stderr("Unknown event type...");

  1229.                     continue;

  1230.                 }

  1231. 

  1232.                 pHost->write_midi_event(pHost->handle, &midiEvent);

  1233.             }

  1234.         }

  1235.     }

  1236. 

  1237.     // -------------------------------------------------------------------

  1238.     // Plugin UI calls

  1239. 

  1240.     void uiShow(const bool show)

  1241.     {

  1242.         if (show)

  1243.         {

  1244.             if (fUiServer.isOk())

  1245.                 return;

  1246. 

  1247.             CarlaString path(pHost->resourceDir);

  1248. 

  1249.             if (kIsPatchbay)

  1250.                 path += "/carla-plugin-patchbay";

  1251.             else

  1252.                 path += "/carla-plugin";

  1253. 

  1254.             carla_stdout("Trying to start carla-plugin using \"%s\"", path.buffer());

  1255. 

  1256.             fUiServer.setData(path, pData->sampleRate, pHost->uiName);

  1257.             fUiServer.start();

  1258. 

  1259.             for (uint i=0; i < pData->curPluginCount; ++i)

  1260.             {

  1261.                 CarlaPlugin* const plugin(pData->plugins[i].plugin);

  1262. 

  1263.                 if (plugin != nullptr && plugin->isEnabled())

  1264.                 {

  1265.                     uiServerCallback(ENGINE_CALLBACK_PLUGIN_ADDED, i, 0, 0, 0.0f, plugin->getName());

  1266.                 }

  1267.             }

  1268. 

  1269.             if (kIsPatchbay)

  1270.                 patchbayRefresh(false);

  1271.         }

  1272.         else

  1273.         {

  1274.             fUiServer.stop();

  1275.         }

  1276.     }

  1277. 

  1278.     void uiIdle()

  1279.     {

  1280.         CarlaEngine::idle();

  1281.         fUiServer.idle();

  1282. 

  1283.         if (! fUiServer.isOk())

  1284.             return;

  1285. 

  1286.         for (uint i=0; i < pData->curPluginCount; ++i)

  1287.         {

  1288.             const EnginePluginData& plugData(pData->plugins[i]);

  1289.             const CarlaPlugin* const plugin(pData->plugins[i].plugin);

  1290. 

  1291.             {

  1292.                 const CarlaMutexLocker cml(fUiServer.getWriteLock());

  1293. 

  1294.                 std::sprintf(fTmpBuf, "PEAKS_%i\n", i);

  1295.                 fUiServer.writeMsg(fTmpBuf);

  1296. 

  1297.                 std::sprintf(fTmpBuf, "%f:%f:%f:%f\n", plugData.insPeak[0], plugData.insPeak[1], plugData.outsPeak[0], plugData.outsPeak[1]);

  1298.                 fUiServer.writeMsg(fTmpBuf);

  1299.             }

  1300. 

  1301.             for (uint32_t j=0, count=plugin->getParameterCount(); j < count; ++j)

  1302.             {

  1303.                 if (plugin->isParameterOutput(j))

  1304.                     continue;

  1305. 

  1306.                 const CarlaMutexLocker cml(fUiServer.getWriteLock());

  1307. 

  1308.                 std::sprintf(fTmpBuf, "PARAMVAL_%i:%i\n", i, j);

  1309.                 fUiServer.writeMsg(fTmpBuf);

  1310.                 std::sprintf(fTmpBuf, "%f\n", plugin->getParameterValue(j));

  1311.                 fUiServer.writeMsg(fTmpBuf);

  1312.             }

  1313.         }

  1314. 

  1315.         switch (fUiServer.getAndResetUiState())

  1316.         {

  1317.         case CarlaExternalUI::UiNone:

  1318.         case CarlaExternalUI::UiShow:

  1319.             break;

  1320.         case CarlaExternalUI::UiCrashed:

  1321.             pHost->dispatcher(pHost->handle, HOST_OPCODE_UI_UNAVAILABLE, 0, 0, nullptr, 0.0f);

  1322.             break;

  1323.         case CarlaExternalUI::UiHide:

  1324.             pHost->ui_closed(pHost->handle);

  1325.             fUiServer.stop();

  1326.             break;

  1327.         }

  1328.     }

  1329. 

  1330.     // -------------------------------------------------------------------

  1331.     // Plugin state calls

  1332. 

  1333.     char* getState() const

  1334.     {

  1335.         MemoryOutputStream out;

  1336.         saveProjectInternal(out);

  1337.         return strdup(out.toString().toRawUTF8());

  1338.     }

  1339. 

  1340.     void setState(const char* const data)

  1341.     {

  1342.         const String state(data);

  1343.         XmlDocument xml(state);

  1344.         loadProjectInternal(xml);

  1345.     }

  1346. 

  1347.     // -------------------------------------------------------------------

  1348. 

  1349. public:

  1350.     #define handlePtr ((CarlaEngineNative*)handle)

  1351. 

  1352.     static NativePluginHandle _instantiateRack(const NativeHostDescriptor* host)

  1353.     {

  1354.         return new CarlaEngineNative(host, false);

  1355.     }

  1356. 

  1357.     static NativePluginHandle _instantiatePatchbay(const NativeHostDescriptor* host)

  1358.     {

  1359.         return new CarlaEngineNative(host, true);

  1360.     }

  1361. 

  1362.     static void _cleanup(NativePluginHandle handle)

  1363.     {

  1364.         delete handlePtr;

  1365.     }

  1366. 

  1367.     static uint32_t _get_parameter_count(NativePluginHandle handle)

  1368.     {

  1369.         return handlePtr->getParameterCount();

  1370.     }

  1371. 

  1372.     static const NativeParameter* _get_parameter_info(NativePluginHandle handle, uint32_t index)

  1373.     {

  1374.         return handlePtr->getParameterInfo(index);

  1375.     }

  1376. 

  1377.     static float _get_parameter_value(NativePluginHandle handle, uint32_t index)

  1378.     {

  1379.         return handlePtr->getParameterValue(index);

  1380.     }

  1381. 

  1382.     static const char* _get_parameter_text(NativePluginHandle handle, uint32_t index /*, float value*/)

  1383.     {

  1384.         return handlePtr->getParameterText(index /*, value*/);

  1385.     }

  1386. 

  1387.     static uint32_t _get_midi_program_count(NativePluginHandle handle)

  1388.     {

  1389.         return handlePtr->getMidiProgramCount();

  1390.     }

  1391. 

  1392.     static const NativeMidiProgram* _get_midi_program_info(NativePluginHandle handle, uint32_t index)

  1393.     {

  1394.         return handlePtr->getMidiProgramInfo(index);

  1395.     }

  1396. 

  1397.     static void _set_parameter_value(NativePluginHandle handle, uint32_t index, float value)

  1398.     {

  1399.         handlePtr->setParameterValue(index, value);

  1400.     }

  1401. 

  1402.     static void _set_midi_program(NativePluginHandle handle, uint8_t channel, uint32_t bank, uint32_t program)

  1403.     {

  1404.         handlePtr->setMidiProgram(channel, bank, program);

  1405.     }

  1406. 

  1407.     static void _ui_show(NativePluginHandle handle, bool show)

  1408.     {

  1409.         handlePtr->uiShow(show);

  1410.     }

  1411. 

  1412.     static void _ui_idle(NativePluginHandle handle)

  1413.     {

  1414.         handlePtr->uiIdle();

  1415.     }

  1416. 

  1417.     static void _activate(NativePluginHandle handle)

  1418.     {

  1419.         handlePtr->activate();

  1420.     }

  1421. 

  1422.     static void _deactivate(NativePluginHandle handle)

  1423.     {

  1424.         handlePtr->deactivate();

  1425.     }

  1426. 

  1427.     static void _process(NativePluginHandle handle, float** inBuffer, float** outBuffer, const uint32_t frames, const NativeMidiEvent* midiEvents, uint32_t midiEventCount)

  1428.     {

  1429.         handlePtr->process(inBuffer, outBuffer, frames, midiEvents, midiEventCount);

  1430.     }

  1431. 

  1432.     static char* _get_state(NativePluginHandle handle)

  1433.     {

  1434.         return handlePtr->getState();

  1435.     }

  1436. 

  1437.     static void _set_state(NativePluginHandle handle, const char* data)

  1438.     {

  1439.         handlePtr->setState(data);

  1440.     }

  1441. 

  1442.     static intptr_t _dispatcher(NativePluginHandle handle, NativePluginDispatcherOpcode opcode, int32_t index, intptr_t value, void* ptr, float opt)

  1443.     {

  1444.         switch(opcode)

  1445.         {

  1446.         case PLUGIN_OPCODE_NULL:

  1447.             return 0;

  1448.         case PLUGIN_OPCODE_BUFFER_SIZE_CHANGED:

  1449.             CARLA_SAFE_ASSERT_RETURN(value > 0, 0);

  1450.             handlePtr->bufferSizeChanged(static_cast<uint32_t>(value));

  1451.             return 0;

  1452.         case PLUGIN_OPCODE_SAMPLE_RATE_CHANGED:

  1453.             CARLA_SAFE_ASSERT_RETURN(opt > 0.0, 0);

  1454.             handlePtr->sampleRateChanged(static_cast<double>(opt));

  1455.             return 0;

  1456.         case PLUGIN_OPCODE_OFFLINE_CHANGED:

  1457.             handlePtr->offlineModeChanged(value != 0);

  1458.             return 0;

  1459.         case PLUGIN_OPCODE_UI_NAME_CHANGED:

  1460.             //handlePtr->uiNameChanged(static_cast<const char*>(ptr));

  1461.             return 0;

  1462.         }

  1463. 

  1464.         return 0;

  1465. 

  1466.         // unused

  1467.         (void)index;

  1468.         (void)ptr;

  1469.     }

  1470. 

  1471.     // -------------------------------------------------------------------

  1472. 

  1473.     static void _ui_server_callback(void* handle, EngineCallbackOpcode action, uint pluginId, int value1, int value2, float value3, const char* valueStr)

  1474.     {

  1475.         handlePtr->uiServerCallback(action, pluginId, value1, value2, value3, valueStr);

  1476.     }

  1477. 

  1478.     // -------------------------------------------------------------------

  1479. 

  1480.     #undef handlePtr

  1481. 

  1482. private:

  1483.     const NativeHostDescriptor* const pHost;

  1484. 

  1485.     const bool kIsPatchbay; // rack if false

  1486.     bool fIsActive, fIsRunning;

  1487.     CarlaEngineNativeUI fUiServer;

  1488. 

  1489.     char fTmpBuf[STR_MAX+1];

  1490. 

  1491.     CarlaPlugin* _getFirstPlugin() const noexcept

  1492.     {

  1493.         if (pData->curPluginCount == 0 || pData->plugins == nullptr)

  1494.             return nullptr;

  1495. 

  1496.         CarlaPlugin* const plugin(pData->plugins[0].plugin);

  1497. 

  1498.         if (plugin == nullptr || ! plugin->isEnabled())

  1499.             return nullptr;

  1500. 

  1501.         return pData->plugins[0].plugin;

  1502.     }

  1503. 

  1504.     CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineNative)

  1505. };

  1506. 

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

  1508. 

  1509. static const NativePluginDescriptor carlaRackDesc = {

  1510.     /* category  */ ::PLUGIN_CATEGORY_OTHER,

  1511.     /* hints     */ static_cast<NativePluginHints>(::PLUGIN_IS_SYNTH|::PLUGIN_HAS_UI|::PLUGIN_NEEDS_FIXED_BUFFERS|::PLUGIN_NEEDS_SINGLE_THREAD|::PLUGIN_USES_STATE|::PLUGIN_USES_TIME),

  1512.     /* supports  */ static_cast<NativePluginSupports>(::PLUGIN_SUPPORTS_EVERYTHING),

  1513.     /* audioIns  */ 2,

  1514.     /* audioOuts */ 2,

  1515.     /* midiIns   */ 1,

  1516.     /* midiOuts  */ 1,

  1517.     /* paramIns  */ 0,

  1518.     /* paramOuts */ 0,

  1519.     /* name      */ "Carla-Rack",

  1520.     /* label     */ "carlarack",

  1521.     /* maker     */ "falkTX",

  1522.     /* copyright */ "GNU GPL v2+",

  1523.     CarlaEngineNative::_instantiateRack,

  1524.     CarlaEngineNative::_cleanup,

  1525.     CarlaEngineNative::_get_parameter_count,

  1526.     CarlaEngineNative::_get_parameter_info,

  1527.     CarlaEngineNative::_get_parameter_value,

  1528.     CarlaEngineNative::_get_parameter_text,

  1529.     CarlaEngineNative::_get_midi_program_count,

  1530.     CarlaEngineNative::_get_midi_program_info,

  1531.     CarlaEngineNative::_set_parameter_value,

  1532.     CarlaEngineNative::_set_midi_program,

  1533.     /* _set_custom_data        */ nullptr,

  1534.     CarlaEngineNative::_ui_show,

  1535.     CarlaEngineNative::_ui_idle,

  1536.     /* _ui_set_parameter_value */ nullptr,

  1537.     /* _ui_set_midi_program    */ nullptr,

  1538.     /* _ui_set_custom_data     */ nullptr,

  1539.     CarlaEngineNative::_activate,

  1540.     CarlaEngineNative::_deactivate,

  1541.     CarlaEngineNative::_process,

  1542.     CarlaEngineNative::_get_state,

  1543.     CarlaEngineNative::_set_state,

  1544.     CarlaEngineNative::_dispatcher

  1545. };

  1546. 

  1547. static const NativePluginDescriptor carlaPatchbayDesc = {

  1548.     /* category  */ ::PLUGIN_CATEGORY_OTHER,

  1549.     /* hints     */ static_cast<NativePluginHints>(::PLUGIN_IS_SYNTH|::PLUGIN_HAS_UI|::PLUGIN_NEEDS_FIXED_BUFFERS|::PLUGIN_NEEDS_SINGLE_THREAD|::PLUGIN_USES_STATE|::PLUGIN_USES_TIME),

  1550.     /* supports  */ static_cast<NativePluginSupports>(::PLUGIN_SUPPORTS_EVERYTHING),

  1551.     /* audioIns  */ 2,

  1552.     /* audioOuts */ 2,

  1553.     /* midiIns   */ 1,

  1554.     /* midiOuts  */ 1,

  1555.     /* paramIns  */ 0,

  1556.     /* paramOuts */ 0,

  1557.     /* name      */ "Carla-Patchbay",

  1558.     /* label     */ "carlapatchbay",

  1559.     /* maker     */ "falkTX",

  1560.     /* copyright */ "GNU GPL v2+",

  1561.     CarlaEngineNative::_instantiatePatchbay,

  1562.     CarlaEngineNative::_cleanup,

  1563.     CarlaEngineNative::_get_parameter_count,

  1564.     CarlaEngineNative::_get_parameter_info,

  1565.     CarlaEngineNative::_get_parameter_value,

  1566.     CarlaEngineNative::_get_parameter_text,

  1567.     CarlaEngineNative::_get_midi_program_count,

  1568.     CarlaEngineNative::_get_midi_program_info,

  1569.     CarlaEngineNative::_set_parameter_value,

  1570.     CarlaEngineNative::_set_midi_program,

  1571.     /* _set_custom_data        */ nullptr,

  1572.     CarlaEngineNative::_ui_show,

  1573.     CarlaEngineNative::_ui_idle,

  1574.     /* _ui_set_parameter_value */ nullptr,

  1575.     /* _ui_set_midi_program    */ nullptr,

  1576.     /* _ui_set_custom_data     */ nullptr,

  1577.     CarlaEngineNative::_activate,

  1578.     CarlaEngineNative::_deactivate,

  1579.     CarlaEngineNative::_process,

  1580.     CarlaEngineNative::_get_state,

  1581.     CarlaEngineNative::_set_state,

  1582.     CarlaEngineNative::_dispatcher

  1583. };

  1584. 

  1585. CARLA_BACKEND_END_NAMESPACE

  1586. 

  1587. // -----------------------------------------------------------------------

  1588. 

  1589. CARLA_EXPORT

  1590. void carla_register_native_plugin_carla();

  1591. 

  1592. void carla_register_native_plugin_carla()

  1593. {

  1594.     CARLA_BACKEND_USE_NAMESPACE;

  1595.     carla_register_native_plugin(&carlaRackDesc);

  1596.     carla_register_native_plugin(&carlaPatchbayDesc);

  1597. }

  1598. 

  1599. // -----------------------------------------------------------------------

  1600. 

  1601. CARLA_EXPORT

  1602. const NativePluginDescriptor* carla_get_native_rack_plugin();

  1603. const NativePluginDescriptor* carla_get_native_rack_plugin()

  1604. {

  1605.     // if this is called then we're running as special plugin

  1606.     gNeedsJuceHandling = true;

  1607. 

  1608.     CARLA_BACKEND_USE_NAMESPACE;

  1609.     return &carlaRackDesc;

  1610. }

  1611. 

  1612. CARLA_EXPORT

  1613. const NativePluginDescriptor* carla_get_native_patchbay_plugin();

  1614. const NativePluginDescriptor* carla_get_native_patchbay_plugin()

  1615. {

  1616.     // if this is called then we're running as special plugin

  1617.     gNeedsJuceHandling = true;

  1618. 

  1619.     CARLA_BACKEND_USE_NAMESPACE;

  1620.     return &carlaPatchbayDesc;

  1621. }

  1622. 

  1623. // -----------------------------------------------------------------------

  1624. // Extra stuff for linking purposes

  1625. 

  1626. #ifdef CARLA_PLUGIN_EXPORT

  1627. 

  1628. CARLA_BACKEND_START_NAMESPACE

  1629. 

  1630. CarlaEngine* CarlaEngine::newJack() { return nullptr; }

  1631. 

  1632. # if defined(CARLA_OS_MAC) || defined(CARLA_OS_WIN)

  1633. CarlaEngine*       CarlaEngine::newJuce(const AudioApi)           { return nullptr; }

  1634. uint               CarlaEngine::getJuceApiCount()                 { return 0;       }

  1635. const char*        CarlaEngine::getJuceApiName(const uint)        { return nullptr; }

  1636. const char* const* CarlaEngine::getJuceApiDeviceNames(const uint) { return nullptr; }

  1637. const EngineDriverDeviceInfo* CarlaEngine::getJuceDeviceInfo(const uint, const char* const) { return nullptr; }

  1638. # else

  1639. CarlaEngine*       CarlaEngine::newRtAudio(const AudioApi)           { return nullptr; }

  1640. uint               CarlaEngine::getRtAudioApiCount()                 { return 0;       }

  1641. const char*        CarlaEngine::getRtAudioApiName(const uint)        { return nullptr; }

  1642. const char* const* CarlaEngine::getRtAudioApiDeviceNames(const uint) { return nullptr; }

  1643. const EngineDriverDeviceInfo* CarlaEngine::getRtAudioDeviceInfo(const uint, const char* const) { return nullptr; }

  1644. # endif

  1645. 

  1646. CARLA_BACKEND_END_NAMESPACE

  1647. 

  1648. #include "CarlaPluginUI.cpp"

  1649. #include "CarlaDssiUtils.cpp"

  1650. #include "CarlaStateUtils.cpp"

  1651. #include "CarlaJuceEvents.cpp"

  1652. 

  1653. #endif

  1654. 

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