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.
2469 Commits
16 Branches
167MB
Tree: 90805901b5
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '90805901b5'
${ noResults }
Carla/source/backend/plugin/CarlaPluginThread.cpp

389 lines
13KB
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.     String filename(fPlugin->getFilename());

  142. 

  143.     if (name.isEmpty())

  144.         name = "(none)";

  145. 

  146.     if (filename.isEmpty())

  147.         filename = "\"\"";

  148. 

  149.     if (fLabel.isEmpty())

  150.         fLabel = "\"\"";

  151. 

  152.     StringArray arguments;

  153. 

  154. #ifndef CARLA_OS_WIN

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

  156.         arguments.add("wine");

  157. #endif

  158. 

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

  160. 

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

  162.     static CarlaMutex sEnvMutex;

  163. 

  164.     char strBuf[STR_MAX+1];

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

  166. 

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

  168. 

  169.     sEnvMutex.lock();

  170. 

  171.     carla_setenv("CARLA_CLIENT_NAME", name.toRawUTF8());

  172. 

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

  174.     carla_setenv("CARLA_SAMPLE_RATE", strBuf);

  175. 

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

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

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

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

  180. 

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

  182.     carla_setenv("ENGINE_OPTION_MAX_PARAMETERS", strBuf);

  183. 

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

  185.     carla_setenv("ENGINE_OPTION_UI_BRIDGES_TIMEOUT",strBuf);

  186. 

  187.     if (options.pathLADSPA != nullptr)

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

  189.     else

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

  191. 

  192.     if (options.pathDSSI != nullptr)

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

  194.     else

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

  196. 

  197.     if (options.pathLV2 != nullptr)

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

  199.     else

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

  201. 

  202.     if (options.pathVST != nullptr)

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

  204.     else

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

  206. 

  207.     if (options.pathVST3 != nullptr)

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

  209.     else

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

  211. 

  212.     if (options.pathAU != nullptr)

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

  214.     else

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

  216. 

  217.     if (options.pathGIG != nullptr)

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

  219.     else

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

  221. 

  222.     if (options.pathSF2 != nullptr)

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

  224.     else

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

  226. 

  227.     if (options.pathSFZ != nullptr)

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

  229.     else

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

  231. 

  232.     if (options.binaryDir != nullptr)

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

  234.     else

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

  236. 

  237.     if (options.resourceDir != nullptr)

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

  239.     else

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

  241. 

  242.     carla_setenv("ENGINE_OPTION_PREVENT_BAD_BEHAVIOUR", bool2str(options.preventBadBehaviour));

  243. 

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

  245.     carla_setenv("ENGINE_OPTION_FRONTEND_WIN_ID", strBuf);

  246. 

  247. #ifdef CARLA_OS_LINUX

  248.     const char* const oldPreload(std::getenv("LD_PRELOAD"));

  249.     ::unsetenv("LD_PRELOAD");

  250. #endif

  251. 

  252.     switch (fMode)

  253.     {

  254.     case PLUGIN_THREAD_NULL:

  255.         break;

  256. 

  257.     case PLUGIN_THREAD_DSSI_GUI:

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

  259.         /* filename */ arguments.add(filename);

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

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

  262.         break;

  263. 

  264.     case PLUGIN_THREAD_LV2_GUI:

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

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

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

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

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

  270.         break;

  271. 

  272.     case PLUGIN_THREAD_VST_GUI:

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

  274.         /* filename */ arguments.add(filename);

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

  276.         break;

  277. 

  278.     case PLUGIN_THREAD_BRIDGE:

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

  280.         /* filename */ arguments.add(filename);

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

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

  283. 

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

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

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

  287.         break;

  288.     }

  289. 

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

  291. 

  292.     fProcess->start(arguments);

  293. 

  294. #ifdef CARLA_OS_LINUX

  295.     if (oldPreload != nullptr)

  296.         ::setenv("LD_PRELOAD", oldPreload, 1);

  297. #endif

  298. 

  299.     sEnvMutex.unlock();

  300. 

  301.     switch (fMode)

  302.     {

  303.     case PLUGIN_THREAD_NULL:

  304.         break;

  305. 

  306.     case PLUGIN_THREAD_DSSI_GUI:

  307.     case PLUGIN_THREAD_LV2_GUI:

  308.     case PLUGIN_THREAD_VST_GUI:

  309.         if (fPlugin->waitForOscGuiShow())

  310.         {

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

  312.                 carla_sleep(1);

  313. 

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

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

  316.             {

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

  318. 

  319.                 if (fProcess->isRunning())

  320.                 {

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

  322.                     fProcess->kill();

  323.                 }

  324.                 else

  325.                 {

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

  327.                 }

  328.             }

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

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

  331.             else

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

  333. 

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

  335.         }

  336.         else

  337.         {

  338.             fProcess->kill();

  339. 

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

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

  342.         }

  343.         break;

  344. 

  345.     case PLUGIN_THREAD_BRIDGE:

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

  347. 

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

  349.             carla_sleep(1);

  350. 

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

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

  353.         {

  354.             fProcess->waitForProcessToFinish(2000);

  355. 

  356.             if (fProcess->isRunning())

  357.             {

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

  359.                 fProcess->kill();

  360.             }

  361.             else

  362.             {

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

  364.             }

  365.         }

  366.         else

  367.         {

  368.             // forced quit, may have crashed

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

  370.             {

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

  372. 

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

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

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

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

  377.             }

  378.         }

  379.         break;

  380.     }

  381. 

  382.     carla_stdout("app finished");

  383.     fProcess = nullptr;

  384. }

  385. 

  386. // -----------------------------------------------------------------------

  387. 

  388. CARLA_BACKEND_END_NAMESPACE