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.
2319 Commits
17 Branches
992MB
Tree: 5cb048cd27
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '5cb048cd27'
${ noResults }
Carla/source/backend/plugin/CarlaPluginThread.cpp

374 lines
12KB
Raw Blame History 

  1. /*

  2.  * Carla Plugin

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

  4.  *

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

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

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

  8.  * the License, or any later version.

  9.  *

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

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

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

  13.  * GNU General Public License for more details.

  14.  *

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

  16.  */

  17. 

  18. #include "CarlaPlugin.hpp"

  19. #include "CarlaPluginThread.hpp"

  20. #include "CarlaEngine.hpp"

  21. 

  22. #include "juce_core.h"

  23. 

  24. using juce::String;

  25. using juce::StringArray;

  26. 

  27. CARLA_BACKEND_START_NAMESPACE

  28. 

  29. // -----------------------------------------------------------------------

  30. 

  31. #ifdef DEBUG

  32. static inline

  33. const char* PluginThreadMode2str(const CarlaPluginThread::Mode mode) noexcept

  34. {

  35.     switch (mode)

  36.     {

  37.     case CarlaPluginThread::PLUGIN_THREAD_NULL:

  38.         return "PLUGIN_THREAD_NULL";

  39.     case CarlaPluginThread::PLUGIN_THREAD_DSSI_GUI:

  40.         return "PLUGIN_THREAD_DSSI_GUI";

  41.     case CarlaPluginThread::PLUGIN_THREAD_LV2_GUI:

  42.         return "PLUGIN_THREAD_LV2_GUI";

  43.     case CarlaPluginThread::PLUGIN_THREAD_VST_GUI:

  44.         return "PLUGIN_THREAD_VST_GUI";

  45.     case CarlaPluginThread::PLUGIN_THREAD_BRIDGE:

  46.         return "PLUGIN_THREAD_BRIDGE";

  47.     }

  48. 

  49.     carla_stderr("CarlaPluginThread::PluginThreadMode2str(%i) - invalid mode", mode);

  50.     return nullptr;

  51. }

  52. #endif

  53. 

  54. // -----------------------------------------------------------------------

  55. 

  56. CarlaPluginThread::CarlaPluginThread(CarlaBackend::CarlaEngine* const engine, CarlaBackend::CarlaPlugin* const plugin, const Mode mode) noexcept

  57.     : CarlaThread("CarlaPluginThread"),

  58.       fEngine(engine),

  59.       fPlugin(plugin),

  60.       fMode(mode),

  61.       fBinary(),

  62.       fLabel(),

  63.       fExtra1(),

  64.       fExtra2(),

  65.       fProcess(nullptr),

  66.       leakDetector_CarlaPluginThread()

  67. {

  68.     carla_debug("CarlaPluginThread::CarlaPluginThread(%p, %p, %s)", engine, plugin, PluginThreadMode2str(mode));

  69. }

  70. 

  71. CarlaPluginThread::~CarlaPluginThread() noexcept

  72. {

  73.     carla_debug("CarlaPluginThread::~CarlaPluginThread()");

  74. 

  75.     if (fProcess != nullptr)

  76.     {

  77.         //fProcess.release();

  78.         //try {

  79.             //delete fProcess;

  80.         //} CARLA_SAFE_EXCEPTION("~CarlaPluginThread(): delete ChildProcess");

  81.         fProcess = nullptr;

  82.     }

  83. }

  84. 

  85. void CarlaPluginThread::setMode(const CarlaPluginThread::Mode mode) noexcept

  86. {

  87.     CARLA_SAFE_ASSERT(! isThreadRunning());

  88.     carla_debug("CarlaPluginThread::setMode(%s)", PluginThreadMode2str(mode));

  89. 

  90.     fMode = mode;

  91. }

  92. 

  93. void CarlaPluginThread::setOscData(const char* const binary, const char* const label, const char* const extra1, const char* const extra2) noexcept

  94. {

  95.     CARLA_SAFE_ASSERT(! isThreadRunning());

  96.     carla_debug("CarlaPluginThread::setOscData(\"%s\", \"%s\", \"%s\", \"%s\")", binary, label, extra1, extra2);

  97. 

  98.     fBinary = binary;

  99.     fLabel  = label;

  100.     fExtra1 = extra1;

  101.     fExtra2 = extra2;

  102. }

  103. 

  104. uintptr_t CarlaPluginThread::getPid() const

  105. {

  106.     CARLA_SAFE_ASSERT_RETURN(fProcess != nullptr, 0);

  107. 

  108.     return (uintptr_t)fProcess->getPID();

  109. }

  110. 

  111. void CarlaPluginThread::run()

  112. {

  113.     carla_debug("CarlaPluginThread::run()");

  114. 

  115.     if (fProcess == nullptr)

  116.     {

  117.        fProcess = new ChildProcess;

  118.        //fProcess->setProcessChannelMode(QProcess::ForwardedChannels);

  119.     }

  120.     else if (fProcess->isRunning())

  121.     {

  122.         carla_stderr("CarlaPluginThread::run() - already running, giving up...");

  123. 

  124.         switch (fMode)

  125.         {

  126.         case PLUGIN_THREAD_NULL:

  127.         case PLUGIN_THREAD_BRIDGE:

  128.             break;

  129. 

  130.         case PLUGIN_THREAD_DSSI_GUI:

  131.         case PLUGIN_THREAD_LV2_GUI:

  132.         case PLUGIN_THREAD_VST_GUI:

  133.             fEngine->callback(CarlaBackend::ENGINE_CALLBACK_UI_STATE_CHANGED, fPlugin->getId(), 0, 0, 0.0f, nullptr);

  134.             fProcess->kill();

  135.             fProcess = nullptr;

  136.             return;

  137.         }

  138.     }

  139. 

  140.     String name(fPlugin->getName());

  141. 

  142.     if (name.isEmpty())

  143.         name = "(none)";

  144. 

  145.     if (fLabel.isEmpty())

  146.         fLabel = "\"\"";

  147. 

  148.     StringArray arguments;

  149. 

  150. #ifndef CARLA_OS_WIN

  151.     if (fBinary.endsWith(".exe"))

  152.         arguments.add("wine");

  153. #endif

  154. 

  155.     arguments.add(fBinary.buffer());

  156. 

  157.     // use a global mutex to ensure bridge environment is correct

  158.     static CarlaMutex sEnvMutex;

  159. 

  160.     char strBuf[STR_MAX+1];

  161.     strBuf[STR_MAX] = '\0';

  162. 

  163.     const EngineOptions& options(fEngine->getOptions());

  164. 

  165.     sEnvMutex.lock();

  166. 

  167.     std::snprintf(strBuf, STR_MAX, "%f", fEngine->getSampleRate());

  168.     carla_setenv("CARLA_SAMPLE_RATE", strBuf);

  169. 

  170.     carla_setenv("ENGINE_OPTION_FORCE_STEREO",          bool2str(options.forceStereo));

  171.     carla_setenv("ENGINE_OPTION_PREFER_PLUGIN_BRIDGES", bool2str(options.preferPluginBridges));

  172.     carla_setenv("ENGINE_OPTION_PREFER_UI_BRIDGES",     bool2str(options.preferUiBridges));

  173.     carla_setenv("ENGINE_OPTION_UIS_ALWAYS_ON_TOP",     bool2str(options.uisAlwaysOnTop));

  174. 

  175.     std::snprintf(strBuf, STR_MAX, "%u", options.maxParameters);

  176.     carla_setenv("ENGINE_OPTION_MAX_PARAMETERS", strBuf);

  177. 

  178.     std::snprintf(strBuf, STR_MAX, "%u", options.uiBridgesTimeout);

  179.     carla_setenv("ENGINE_OPTION_UI_BRIDGES_TIMEOUT",strBuf);

  180. 

  181.     if (options.pathLADSPA != nullptr)

  182.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_LADSPA", options.pathLADSPA);

  183.     else

  184.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_LADSPA", "");

  185. 

  186.     if (options.pathDSSI != nullptr)

  187.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_DSSI", options.pathDSSI);

  188.     else

  189.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_DSSI", "");

  190. 

  191.     if (options.pathLV2 != nullptr)

  192.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_LV2", options.pathLV2);

  193.     else

  194.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_LV2", "");

  195. 

  196.     if (options.pathVST != nullptr)

  197.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_VST", options.pathVST);

  198.     else

  199.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_VST", "");

  200. 

  201.     if (options.pathVST3 != nullptr)

  202.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_VST3", options.pathVST3);

  203.     else

  204.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_VST3", "");

  205. 

  206.     if (options.pathAU != nullptr)

  207.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_AU", options.pathAU);

  208.     else

  209.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_AU", "");

  210. 

  211.     if (options.pathGIG != nullptr)

  212.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_GIG", options.pathGIG);

  213.     else

  214.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_GIG", "");

  215. 

  216.     if (options.pathSF2 != nullptr)

  217.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_SF2", options.pathSF2);

  218.     else

  219.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_SF2", "");

  220. 

  221.     if (options.pathSFZ != nullptr)

  222.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_SFZ", options.pathSFZ);

  223.     else

  224.         carla_setenv("ENGINE_OPTION_PLUGIN_PATH_SFZ", "");

  225. 

  226.     if (options.binaryDir != nullptr)

  227.         carla_setenv("ENGINE_OPTION_PATH_BINARIES", options.binaryDir);

  228.     else

  229.         carla_setenv("ENGINE_OPTION_PATH_BINARIES", "");

  230. 

  231.     if (options.resourceDir != nullptr)

  232.         carla_setenv("ENGINE_OPTION_PATH_RESOURCES", options.resourceDir);

  233.     else

  234.         carla_setenv("ENGINE_OPTION_PATH_RESOURCES", "");

  235. 

  236.     std::snprintf(strBuf, STR_MAX, P_UINTPTR, options.frontendWinId);

  237.     carla_setenv("ENGINE_OPTION_FRONTEND_WIN_ID", strBuf);

  238. 

  239.     switch (fMode)

  240.     {

  241.     case PLUGIN_THREAD_NULL:

  242.         break;

  243. 

  244.     case PLUGIN_THREAD_DSSI_GUI:

  245.         /* osc-url  */ arguments.add(String(fEngine->getOscServerPathUDP()) + String("/") + String(fPlugin->getId()));

  246.         /* filename */ arguments.add(fPlugin->getFilename());

  247.         /* label    */ arguments.add(fLabel.buffer());

  248.         /* ui-title */ arguments.add(name + String(" (GUI)"));

  249.         break;

  250. 

  251.     case PLUGIN_THREAD_LV2_GUI:

  252.         /* osc-url   */ arguments.add(String(fEngine->getOscServerPathUDP()) + String("/") + String(fPlugin->getId()));

  253.         /* URI       */ arguments.add(fLabel.buffer());

  254.         /* UI URI    */ arguments.add(fExtra1.buffer());

  255.         /* UI Bundle */ arguments.add(fExtra2.buffer());

  256.         /* UI Title  */ arguments.add(name + String(" (GUI)"));

  257.         break;

  258. 

  259.     case PLUGIN_THREAD_VST_GUI:

  260.         /* osc-url  */ arguments.add(String(fEngine->getOscServerPathUDP()) + String("/") + String(fPlugin->getId()));

  261.         /* filename */ arguments.add(fPlugin->getFilename());

  262.         /* ui-title */ arguments.add(name + String(" (GUI)"));

  263.         break;

  264. 

  265.     case PLUGIN_THREAD_BRIDGE:

  266.         /* osc-url  */ arguments.add(String(fEngine->getOscServerPathUDP()) + String("/") + String(fPlugin->getId()));

  267.         /* stype    */ arguments.add(fExtra1.buffer());

  268.         /* filename */ arguments.add(fPlugin->getFilename());

  269.         /* name     */ arguments.add(name);

  270.         /* label    */ arguments.add(fLabel.buffer());

  271.         /* uniqueId */ arguments.add(String(static_cast<juce::int64>(fPlugin->getUniqueId())));

  272. 

  273.         carla_setenv("ENGINE_BRIDGE_SHM_IDS", fExtra2.buffer());

  274.         carla_setenv("ENGINE_BRIDGE_CLIENT_NAME", name.toRawUTF8());

  275.         carla_setenv("ENGINE_BRIDGE_OSC_URL", String(String(fEngine->getOscServerPathUDP()) + String("/") + String(fPlugin->getId())).toRawUTF8());

  276.         carla_setenv("WINEDEBUG", "-all");

  277.         break;

  278.     }

  279. 

  280.     carla_stdout("starting app..");

  281. 

  282.     fProcess->start(arguments);

  283. 

  284.     sEnvMutex.unlock();

  285. 

  286.     switch (fMode)

  287.     {

  288.     case PLUGIN_THREAD_NULL:

  289.         break;

  290. 

  291.     case PLUGIN_THREAD_DSSI_GUI:

  292.     case PLUGIN_THREAD_LV2_GUI:

  293.     case PLUGIN_THREAD_VST_GUI:

  294.         if (fPlugin->waitForOscGuiShow())

  295.         {

  296.             while (fProcess->isRunning() && ! shouldThreadExit())

  297.                 carla_sleep(1);

  298. 

  299.             // we only get here if UI was closed or thread asked to exit

  300.             if (fProcess->isRunning() && shouldThreadExit())

  301.             {

  302.                 fProcess->waitForProcessToFinish(static_cast<int>(fEngine->getOptions().uiBridgesTimeout));

  303. 

  304.                 if (fProcess->isRunning())

  305.                 {

  306.                     carla_stdout("CarlaPluginThread::run() - UI refused to close, force kill now");

  307.                     fProcess->kill();

  308.                 }

  309.                 else

  310.                 {

  311.                     carla_stdout("CarlaPluginThread::run() - UI auto-closed successfully");

  312.                 }

  313.             }

  314.             else if (fProcess->getExitCode() != 0 /*|| fProcess->exitStatus() == QProcess::CrashExit*/)

  315.                 carla_stderr("CarlaPluginThread::run() - UI crashed while running");

  316.             else

  317.                 carla_stdout("CarlaPluginThread::run() - UI closed cleanly");

  318. 

  319.             fEngine->callback(CarlaBackend::ENGINE_CALLBACK_UI_STATE_CHANGED, fPlugin->getId(), 0, 0, 0.0f, nullptr);

  320.         }

  321.         else

  322.         {

  323.             fProcess->kill();

  324. 

  325.             carla_stdout("CarlaPluginThread::run() - GUI timeout");

  326.             fEngine->callback(CarlaBackend::ENGINE_CALLBACK_UI_STATE_CHANGED, fPlugin->getId(), 0, 0, 0.0f, nullptr);

  327.         }

  328.         break;

  329. 

  330.     case PLUGIN_THREAD_BRIDGE:

  331.         //fProcess->waitForFinished(-1);

  332. 

  333.         while (fProcess->isRunning() && ! shouldThreadExit())

  334.             carla_sleep(1);

  335. 

  336.         // we only get here if bridge crashed or thread asked to exit

  337.         if (fProcess->isRunning() && shouldThreadExit())

  338.         {

  339.             fProcess->waitForProcessToFinish(2000);

  340. 

  341.             if (fProcess->isRunning())

  342.             {

  343.                 carla_stdout("CarlaPluginThread::run() - bridge refused to close, force kill now");

  344.                 fProcess->kill();

  345.             }

  346.             else

  347.             {

  348.                 carla_stdout("CarlaPluginThread::run() - bridge auto-closed successfully");

  349.             }

  350.         }

  351.         else

  352.         {

  353.             // forced quit, may have crashed

  354.             if (fProcess->getExitCode() != 0 /*|| fProcess->exitStatus() == QProcess::CrashExit*/)

  355.             {

  356.                 carla_stderr("CarlaPluginThread::run() - bridge crashed");

  357. 

  358.                 CarlaString errorString("Plugin '" + CarlaString(fPlugin->getName()) + "' has crashed!\n"

  359.                                         "Saving now will lose its current settings.\n"

  360.                                         "Please remove this plugin, and not rely on it from this point.");

  361.                 fEngine->callback(CarlaBackend::ENGINE_CALLBACK_ERROR, fPlugin->getId(), 0, 0, 0.0f, errorString);

  362.             }

  363.         }

  364.         break;

  365.     }

  366. 

  367.     carla_stdout("app finished");

  368.     fProcess = nullptr;

  369. }

  370. 

  371. // -----------------------------------------------------------------------

  372. 

  373. CARLA_BACKEND_END_NAMESPACE