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.

2430 lines
81KB

  1. /*
  2. * Carla Plugin Host
  3. * Copyright (C) 2011-2019 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. #include "CarlaDefines.h"
  18. #ifdef BUILD_BRIDGE_ALTERNATIVE_ARCH
  19. # error This file should not be compiled if building alternative-arch bridges
  20. #endif
  21. #include "CarlaEngineInternal.hpp"
  22. #include "CarlaPlugin.hpp"
  23. #include "CarlaBackendUtils.hpp"
  24. #include "CarlaBase64Utils.hpp"
  25. #include "CarlaBinaryUtils.hpp"
  26. #include "CarlaMathUtils.hpp"
  27. #include "CarlaStateUtils.hpp"
  28. #include "CarlaExternalUI.hpp"
  29. #include "CarlaHost.h"
  30. #include "CarlaNative.hpp"
  31. #include "CarlaNativePlugin.h"
  32. #if defined(USING_JUCE) && ! (defined(CARLA_OS_MAC) || defined(CARLA_OS_WIN))
  33. # include "AppConfig.h"
  34. # include "juce_events/juce_events.h"
  35. # define USE_JUCE_MESSAGE_THREAD
  36. #endif
  37. #include "water/files/File.h"
  38. #include "water/streams/MemoryOutputStream.h"
  39. #include "water/xml/XmlDocument.h"
  40. #include "water/xml/XmlElement.h"
  41. using water::File;
  42. using water::MemoryOutputStream;
  43. using water::String;
  44. using water::XmlDocument;
  45. using water::XmlElement;
  46. CARLA_BACKEND_START_NAMESPACE
  47. // -----------------------------------------------------------------------
  48. #ifdef USE_JUCE_MESSAGE_THREAD
  49. static int numScopedInitInstances = 0;
  50. class SharedJuceMessageThread : public juce::Thread
  51. {
  52. public:
  53. SharedJuceMessageThread()
  54. : juce::Thread ("SharedJuceMessageThread"),
  55. initialised (false) {}
  56. ~SharedJuceMessageThread()
  57. {
  58. CARLA_SAFE_ASSERT(numScopedInitInstances == 0);
  59. // in case something fails
  60. juce::MessageManager::getInstance()->stopDispatchLoop();
  61. waitForThreadToExit (5000);
  62. }
  63. void incRef()
  64. {
  65. if (numScopedInitInstances++ == 0)
  66. {
  67. startThread (7);
  68. while (! initialised)
  69. juce::Thread::sleep (1);
  70. }
  71. }
  72. void decRef()
  73. {
  74. if (--numScopedInitInstances == 0)
  75. {
  76. juce::MessageManager::getInstance()->stopDispatchLoop();
  77. waitForThreadToExit (5000);
  78. }
  79. }
  80. protected:
  81. void run() override
  82. {
  83. const juce::ScopedJuceInitialiser_GUI juceInitialiser;
  84. juce::MessageManager::getInstance()->setCurrentThreadAsMessageThread();
  85. initialised = true;
  86. juce::MessageManager::getInstance()->runDispatchLoop();
  87. }
  88. private:
  89. volatile bool initialised;
  90. };
  91. #endif
  92. // -----------------------------------------------------------------------
  93. class CarlaEngineNativeUI : public CarlaExternalUI
  94. {
  95. public:
  96. CarlaEngineNativeUI(CarlaEngine* const engine)
  97. : fEngine(engine)
  98. {
  99. carla_debug("CarlaEngineNativeUI::CarlaEngineNativeUI(%p)", engine);
  100. }
  101. ~CarlaEngineNativeUI() noexcept override
  102. {
  103. carla_debug("CarlaEngineNativeUI::~CarlaEngineNativeUI()");
  104. }
  105. protected:
  106. bool msgReceived(const char* const msg) noexcept override
  107. {
  108. if (CarlaExternalUI::msgReceived(msg))
  109. return true;
  110. bool ok = true;
  111. if (std::strcmp(msg, "set_engine_option") == 0)
  112. {
  113. uint32_t option;
  114. int32_t value;
  115. const char* valueStr = nullptr;
  116. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(option), true);
  117. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(value), true);
  118. readNextLineAsString(valueStr); // can be null
  119. try {
  120. fEngine->setOption(static_cast<EngineOption>(option), value, valueStr);
  121. } CARLA_SAFE_EXCEPTION("setOption");
  122. if (valueStr != nullptr)
  123. delete[] valueStr;
  124. }
  125. else if (std::strcmp(msg, "load_file") == 0)
  126. {
  127. const char* filename;
  128. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  129. try {
  130. ok = fEngine->loadFile(filename);
  131. } CARLA_SAFE_EXCEPTION("loadFile");
  132. delete[] filename;
  133. }
  134. else if (std::strcmp(msg, "load_project") == 0)
  135. {
  136. const char* filename;
  137. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  138. try {
  139. ok = fEngine->loadProject(filename);
  140. } CARLA_SAFE_EXCEPTION("loadProject");
  141. delete[] filename;
  142. }
  143. else if (std::strcmp(msg, "save_project") == 0)
  144. {
  145. const char* filename;
  146. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  147. try {
  148. ok = fEngine->saveProject(filename);
  149. } CARLA_SAFE_EXCEPTION("saveProject");
  150. delete[] filename;
  151. }
  152. else if (std::strcmp(msg, "patchbay_connect") == 0)
  153. {
  154. uint32_t groupA, portA, groupB, portB;
  155. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(groupA), true);
  156. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(portA), true);
  157. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(groupB), true);
  158. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(portB), true);
  159. try {
  160. ok = fEngine->patchbayConnect(groupA, portA, groupB, portB);
  161. } CARLA_SAFE_EXCEPTION("patchbayConnect");
  162. }
  163. else if (std::strcmp(msg, "patchbay_disconnect") == 0)
  164. {
  165. uint32_t connectionId;
  166. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(connectionId), true);
  167. try {
  168. ok = fEngine->patchbayDisconnect(connectionId);
  169. } CARLA_SAFE_EXCEPTION("patchbayDisconnect");
  170. }
  171. else if (std::strcmp(msg, "patchbay_refresh") == 0)
  172. {
  173. try {
  174. ok = fEngine->patchbayRefresh(false);
  175. } CARLA_SAFE_EXCEPTION("patchbayRefresh");
  176. }
  177. else if (std::strcmp(msg, "transport_play") == 0)
  178. {
  179. fEngine->transportPlay();
  180. }
  181. else if (std::strcmp(msg, "transport_pause") == 0)
  182. {
  183. fEngine->transportPause();
  184. }
  185. else if (std::strcmp(msg, "transport_bpm") == 0)
  186. {
  187. double bpm;
  188. CARLA_SAFE_ASSERT_RETURN(readNextLineAsDouble(bpm), true);
  189. fEngine->transportBPM(bpm);
  190. }
  191. else if (std::strcmp(msg, "transport_relocate") == 0)
  192. {
  193. uint64_t frame;
  194. CARLA_SAFE_ASSERT_RETURN(readNextLineAsULong(frame), true);
  195. fEngine->transportRelocate(frame);
  196. }
  197. else if (std::strcmp(msg, "add_plugin") == 0)
  198. {
  199. uint32_t btype, ptype;
  200. const char* filename = nullptr;
  201. const char* name;
  202. const char* label;
  203. int64_t uniqueId;
  204. uint options;
  205. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(btype), true);
  206. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(ptype), true);
  207. readNextLineAsString(filename); // can be null
  208. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(name), true);
  209. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(label), true);
  210. CARLA_SAFE_ASSERT_RETURN(readNextLineAsLong(uniqueId), true);
  211. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(options), true);
  212. if (filename != nullptr && std::strcmp(filename, "(null)") == 0)
  213. {
  214. delete[] filename;
  215. filename = nullptr;
  216. }
  217. if (std::strcmp(name, "(null)") == 0)
  218. {
  219. delete[] name;
  220. name = nullptr;
  221. }
  222. ok = fEngine->addPlugin(static_cast<BinaryType>(btype), static_cast<PluginType>(ptype),
  223. filename, name, label, uniqueId, nullptr, options);
  224. if (filename != nullptr)
  225. delete[] filename;
  226. if (name != nullptr)
  227. delete[] name;
  228. delete[] label;
  229. }
  230. else if (std::strcmp(msg, "remove_plugin") == 0)
  231. {
  232. uint32_t pluginId;
  233. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  234. ok = fEngine->removePlugin(pluginId);
  235. }
  236. else if (std::strcmp(msg, "remove_all_plugins") == 0)
  237. {
  238. ok = fEngine->removeAllPlugins();
  239. }
  240. else if (std::strcmp(msg, "rename_plugin") == 0)
  241. {
  242. uint32_t pluginId;
  243. const char* newName;
  244. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  245. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(newName), true);
  246. // TODO
  247. /*const char* name =*/ fEngine->renamePlugin(pluginId, newName);
  248. delete[] newName;
  249. }
  250. else if (std::strcmp(msg, "clone_plugin") == 0)
  251. {
  252. uint32_t pluginId;
  253. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  254. ok = fEngine->clonePlugin(pluginId);
  255. }
  256. else if (std::strcmp(msg, "replace_plugin") == 0)
  257. {
  258. uint32_t pluginId;
  259. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  260. ok = fEngine->replacePlugin(pluginId);
  261. }
  262. else if (std::strcmp(msg, "switch_plugins") == 0)
  263. {
  264. uint32_t pluginIdA, pluginIdB;
  265. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginIdA), true);
  266. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginIdB), true);
  267. ok = fEngine->switchPlugins(pluginIdA, pluginIdB);
  268. }
  269. else if (std::strcmp(msg, "load_plugin_state") == 0)
  270. {
  271. uint32_t pluginId;
  272. const char* filename;
  273. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  274. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  275. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  276. plugin->loadStateFromFile(filename);
  277. delete[] filename;
  278. }
  279. else if (std::strcmp(msg, "save_plugin_state") == 0)
  280. {
  281. uint32_t pluginId;
  282. const char* filename;
  283. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  284. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  285. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  286. plugin->saveStateToFile(filename);
  287. delete[] filename;
  288. }
  289. else if (std::strcmp(msg, "set_option") == 0)
  290. {
  291. uint32_t pluginId, option;
  292. bool yesNo;
  293. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  294. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(option), true);
  295. CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(yesNo), true);
  296. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  297. plugin->setOption(option, yesNo, false);
  298. }
  299. else if (std::strcmp(msg, "set_active") == 0)
  300. {
  301. uint32_t pluginId;
  302. bool onOff;
  303. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  304. CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(onOff), true);
  305. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  306. plugin->setActive(onOff, true, false);
  307. }
  308. else if (std::strcmp(msg, "set_drywet") == 0)
  309. {
  310. uint32_t pluginId;
  311. float value;
  312. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  313. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  314. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  315. plugin->setDryWet(value, true, false);
  316. }
  317. else if (std::strcmp(msg, "set_volume") == 0)
  318. {
  319. uint32_t pluginId;
  320. float value;
  321. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  322. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  323. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  324. plugin->setVolume(value, true, false);
  325. }
  326. else if (std::strcmp(msg, "set_balance_left") == 0)
  327. {
  328. uint32_t pluginId;
  329. float value;
  330. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  331. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  332. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  333. plugin->setBalanceLeft(value, true, false);
  334. }
  335. else if (std::strcmp(msg, "set_balance_right") == 0)
  336. {
  337. uint32_t pluginId;
  338. float value;
  339. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  340. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  341. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  342. plugin->setBalanceRight(value, true, false);
  343. }
  344. else if (std::strcmp(msg, "set_panning") == 0)
  345. {
  346. uint32_t pluginId;
  347. float value;
  348. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  349. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  350. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  351. plugin->setPanning(value, true, false);
  352. }
  353. else if (std::strcmp(msg, "set_ctrl_channel") == 0)
  354. {
  355. uint32_t pluginId;
  356. int32_t channel;
  357. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  358. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(channel), true);
  359. CARLA_SAFE_ASSERT_RETURN(channel >= -1 && channel < MAX_MIDI_CHANNELS, true);
  360. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  361. plugin->setCtrlChannel(int8_t(channel), true, false);
  362. }
  363. else if (std::strcmp(msg, "set_parameter_value") == 0)
  364. {
  365. uint32_t pluginId, parameterId;
  366. float value;
  367. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  368. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);
  369. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  370. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  371. plugin->setParameterValue(parameterId, value, true, true, false);
  372. }
  373. else if (std::strcmp(msg, "set_parameter_midi_channel") == 0)
  374. {
  375. uint32_t pluginId, parameterId, channel;
  376. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  377. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);
  378. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(channel), true);
  379. CARLA_SAFE_ASSERT_RETURN(channel < MAX_MIDI_CHANNELS, true);
  380. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  381. plugin->setParameterMidiChannel(parameterId, static_cast<uint8_t>(channel), true, false);
  382. }
  383. else if (std::strcmp(msg, "set_parameter_midi_cc") == 0)
  384. {
  385. uint32_t pluginId, parameterId;
  386. int32_t cc;
  387. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  388. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);
  389. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(cc), true);
  390. CARLA_SAFE_ASSERT_RETURN(cc >= -1 && cc < MAX_MIDI_CONTROL, true);
  391. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  392. plugin->setParameterMidiCC(parameterId, static_cast<int16_t>(cc), true, false);
  393. }
  394. else if (std::strcmp(msg, "set_program") == 0)
  395. {
  396. uint32_t pluginId;
  397. int32_t index;
  398. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  399. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(index), true);
  400. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  401. {
  402. plugin->setProgram(index, true, true, false);
  403. _updateParamValues(plugin, pluginId);
  404. }
  405. }
  406. else if (std::strcmp(msg, "set_midi_program") == 0)
  407. {
  408. uint32_t pluginId;
  409. int32_t index;
  410. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  411. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(index), true);
  412. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  413. {
  414. plugin->setMidiProgram(index, true, true, false);
  415. _updateParamValues(plugin, pluginId);
  416. }
  417. }
  418. else if (std::strcmp(msg, "set_custom_data") == 0)
  419. {
  420. uint32_t pluginId;
  421. const char* type;
  422. const char* key;
  423. const char* value;
  424. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  425. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(type), true);
  426. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(key), true);
  427. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(value), true);
  428. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  429. plugin->setCustomData(type, key, value, true);
  430. delete[] type;
  431. delete[] key;
  432. delete[] value;
  433. }
  434. else if (std::strcmp(msg, "set_chunk_data") == 0)
  435. {
  436. uint32_t pluginId;
  437. const char* cdata;
  438. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  439. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(cdata), true);
  440. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  441. {
  442. std::vector<uint8_t> chunk(carla_getChunkFromBase64String(cdata));
  443. #ifdef CARLA_PROPER_CPP11_SUPPORT
  444. plugin->setChunkData(chunk.data(), chunk.size());
  445. #else
  446. plugin->setChunkData(&chunk.front(), chunk.size());
  447. #endif
  448. }
  449. delete[] cdata;
  450. }
  451. else if (std::strcmp(msg, "prepare_for_save") == 0)
  452. {
  453. uint32_t pluginId;
  454. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  455. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  456. plugin->prepareForSave();
  457. }
  458. else if (std::strcmp(msg, "reset_parameters") == 0)
  459. {
  460. uint32_t pluginId;
  461. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  462. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  463. plugin->resetParameters();
  464. }
  465. else if (std::strcmp(msg, "randomize_parameters") == 0)
  466. {
  467. uint32_t pluginId;
  468. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  469. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  470. plugin->randomizeParameters();
  471. }
  472. else if (std::strcmp(msg, "send_midi_note") == 0)
  473. {
  474. uint32_t pluginId, channel, note, velocity;
  475. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  476. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(channel), true);
  477. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(note), true);
  478. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(velocity), true);
  479. CARLA_SAFE_ASSERT_RETURN(channel < MAX_MIDI_CHANNELS, true);
  480. CARLA_SAFE_ASSERT_RETURN(note < MAX_MIDI_VALUE, true);
  481. CARLA_SAFE_ASSERT_RETURN(velocity < MAX_MIDI_VALUE, true);
  482. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  483. plugin->sendMidiSingleNote(static_cast<uint8_t>(channel), static_cast<uint8_t>(note), static_cast<uint8_t>(velocity), true, true, false);
  484. }
  485. else if (std::strcmp(msg, "show_custom_ui") == 0)
  486. {
  487. uint32_t pluginId;
  488. bool yesNo;
  489. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  490. CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(yesNo), true);
  491. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  492. plugin->showCustomUI(yesNo);
  493. }
  494. else
  495. {
  496. carla_stderr("CarlaEngineNativeUI::msgReceived : %s", msg);
  497. return false;
  498. }
  499. if (! ok)
  500. {
  501. const CarlaMutexLocker cml(getPipeLock());
  502. if (writeMessage("error\n", 6) && writeAndFixMessage(fEngine->getLastError()))
  503. flushMessages();
  504. }
  505. return true;
  506. }
  507. private:
  508. CarlaEngine* const fEngine;
  509. void _updateParamValues(CarlaPlugin* const plugin, const uint32_t pluginId) const noexcept
  510. {
  511. for (uint32_t i=0, count=plugin->getParameterCount(); i<count; ++i)
  512. fEngine->callback(ENGINE_CALLBACK_PARAMETER_VALUE_CHANGED,
  513. pluginId, static_cast<int>(i), 0, plugin->getParameterValue(i), nullptr);
  514. }
  515. CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineNativeUI)
  516. };
  517. // -----------------------------------------------------------------------
  518. class CarlaEngineNative : public CarlaEngine
  519. {
  520. public:
  521. CarlaEngineNative(const NativeHostDescriptor* const host, const bool isPatchbay, const bool withMidiOut,
  522. const uint32_t inChan = 2, uint32_t outChan = 2)
  523. : CarlaEngine(),
  524. pHost(host),
  525. kIsPatchbay(isPatchbay),
  526. kHasMidiOut(withMidiOut),
  527. fIsActive(false),
  528. fIsRunning(false),
  529. fUiServer(this),
  530. fOptionsForced(false)
  531. #ifdef USE_JUCE_MESSAGE_THREAD
  532. // if not running inside Carla, we will have to run event loop ourselves
  533. , kNeedsJuceMsgThread(host->dispatcher(pHost->handle,
  534. NATIVE_HOST_OPCODE_INTERNAL_PLUGIN, 0, 0, nullptr, 0.0f) == 0)
  535. #endif
  536. {
  537. carla_debug("CarlaEngineNative::CarlaEngineNative()");
  538. #ifdef USE_JUCE_MESSAGE_THREAD
  539. if (kNeedsJuceMsgThread)
  540. sJuceMsgThread->incRef();
  541. #endif
  542. pData->bufferSize = pHost->get_buffer_size(pHost->handle);
  543. pData->sampleRate = pHost->get_sample_rate(pHost->handle);
  544. pData->initTime(nullptr);
  545. if (outChan == 0)
  546. outChan = inChan;
  547. // set-up engine
  548. if (kIsPatchbay)
  549. {
  550. pData->options.processMode = ENGINE_PROCESS_MODE_PATCHBAY;
  551. pData->options.transportMode = ENGINE_TRANSPORT_MODE_PLUGIN;
  552. pData->options.forceStereo = false;
  553. pData->options.preferPluginBridges = false;
  554. pData->options.preferUiBridges = false;
  555. init("Carla-Patchbay");
  556. pData->graph.create(inChan, outChan);
  557. }
  558. else
  559. {
  560. CARLA_SAFE_ASSERT(inChan == 2);
  561. CARLA_SAFE_ASSERT(outChan == 2);
  562. pData->options.processMode = ENGINE_PROCESS_MODE_CONTINUOUS_RACK;
  563. pData->options.transportMode = ENGINE_TRANSPORT_MODE_PLUGIN;
  564. pData->options.forceStereo = true;
  565. pData->options.preferPluginBridges = false;
  566. pData->options.preferUiBridges = false;
  567. init("Carla-Rack");
  568. pData->graph.create(0, 0); // FIXME?
  569. }
  570. if (pData->options.resourceDir != nullptr)
  571. delete[] pData->options.resourceDir;
  572. if (pData->options.binaryDir != nullptr)
  573. delete[] pData->options.binaryDir;
  574. pData->options.resourceDir = carla_strdup(pHost->resourceDir);
  575. pData->options.binaryDir = carla_strdup(carla_get_library_folder());
  576. setCallback(_ui_server_callback, this);
  577. setFileCallback(_ui_file_callback, this);
  578. }
  579. ~CarlaEngineNative() override
  580. {
  581. CARLA_SAFE_ASSERT(! fIsActive);
  582. carla_debug("CarlaEngineNative::~CarlaEngineNative() - START");
  583. pData->aboutToClose = true;
  584. fIsRunning = false;
  585. removeAllPlugins();
  586. //runPendingRtEvents();
  587. close();
  588. pData->graph.destroy();
  589. #ifdef USE_JUCE_MESSAGE_THREAD
  590. if (kNeedsJuceMsgThread)
  591. sJuceMsgThread->decRef();
  592. #endif
  593. carla_debug("CarlaEngineNative::~CarlaEngineNative() - END");
  594. }
  595. protected:
  596. // -------------------------------------
  597. // CarlaEngine virtual calls
  598. bool init(const char* const clientName) override
  599. {
  600. carla_debug("CarlaEngineNative::init(\"%s\")", clientName);
  601. fIsRunning = true;
  602. if (! pData->init(clientName))
  603. {
  604. close();
  605. setLastError("Failed to init internal data");
  606. return false;
  607. }
  608. pData->bufferSize = pHost->get_buffer_size(pHost->handle);
  609. pData->sampleRate = pHost->get_sample_rate(pHost->handle);
  610. return true;
  611. }
  612. bool close() override
  613. {
  614. fIsRunning = false;
  615. CarlaEngine::close();
  616. return true;
  617. }
  618. bool isRunning() const noexcept override
  619. {
  620. return fIsRunning;
  621. }
  622. bool isOffline() const noexcept override
  623. {
  624. return pHost->is_offline(pHost->handle);
  625. }
  626. bool usesConstantBufferSize() const noexcept override
  627. {
  628. // TODO LV2 hosts can report this, till then we allow this
  629. return true;
  630. }
  631. EngineType getType() const noexcept override
  632. {
  633. return kEngineTypePlugin;
  634. }
  635. const char* getCurrentDriverName() const noexcept override
  636. {
  637. return "Plugin";
  638. }
  639. void callback(const EngineCallbackOpcode action, const uint pluginId, const int value1, const int value2, const float value3, const char* const valueStr) noexcept override
  640. {
  641. CarlaEngine::callback(action, pluginId, value1, value2, value3, valueStr);
  642. if (action == ENGINE_CALLBACK_IDLE && ! pData->aboutToClose)
  643. pHost->dispatcher(pHost->handle, NATIVE_HOST_OPCODE_HOST_IDLE, 0, 0, nullptr, 0.0f);
  644. }
  645. // -------------------------------------------------------------------
  646. const char* renamePlugin(const uint id, const char* const newName) override
  647. {
  648. if (const char* const retName = CarlaEngine::renamePlugin(id, newName))
  649. {
  650. uiServerCallback(ENGINE_CALLBACK_PLUGIN_RENAMED, id, 0, 0, 0.0f, retName);
  651. return retName;
  652. }
  653. return nullptr;
  654. }
  655. // -------------------------------------------------------------------
  656. void bufferSizeChanged(const uint32_t newBufferSize)
  657. {
  658. if (pData->bufferSize == newBufferSize)
  659. return;
  660. {
  661. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  662. if (fUiServer.writeAndFixMessage("buffer-size"))
  663. {
  664. char tmpBuf[STR_MAX];
  665. carla_zeroChars(tmpBuf, STR_MAX);
  666. std::sprintf(tmpBuf, "%i\n", newBufferSize);
  667. if (fUiServer.writeMessage(tmpBuf))
  668. fUiServer.flushMessages();
  669. }
  670. }
  671. pData->bufferSize = newBufferSize;
  672. CarlaEngine::bufferSizeChanged(newBufferSize);
  673. }
  674. void sampleRateChanged(const double newSampleRate)
  675. {
  676. if (carla_isEqual(pData->sampleRate, newSampleRate))
  677. return;
  678. {
  679. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  680. if (fUiServer.writeAndFixMessage("sample-rate"))
  681. {
  682. char tmpBuf[STR_MAX];
  683. carla_zeroChars(tmpBuf, STR_MAX);
  684. {
  685. const ScopedLocale csl;
  686. std::sprintf(tmpBuf, "%f\n", newSampleRate);
  687. }
  688. if (fUiServer.writeMessage(tmpBuf))
  689. fUiServer.flushMessages();
  690. }
  691. }
  692. pData->sampleRate = newSampleRate;
  693. CarlaEngine::sampleRateChanged(newSampleRate);
  694. }
  695. // -------------------------------------------------------------------
  696. void uiServerSendPluginInfo(CarlaPlugin* const plugin)
  697. {
  698. char tmpBuf[STR_MAX];
  699. carla_zeroChars(tmpBuf, STR_MAX);
  700. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  701. const uint pluginId(plugin->getId());
  702. std::sprintf(tmpBuf, "PLUGIN_INFO_%i\n", pluginId);
  703. if (! fUiServer.writeMessage(tmpBuf))
  704. return;
  705. std::sprintf(tmpBuf, "%i:%i:%i:" P_INT64 ":%i:%i\n", plugin->getType(), plugin->getCategory(), plugin->getHints(), plugin->getUniqueId(), plugin->getOptionsAvailable(), plugin->getOptionsEnabled());
  706. if (! fUiServer.writeMessage(tmpBuf))
  707. return;
  708. if (const char* const filename = plugin->getFilename())
  709. {
  710. std::sprintf(tmpBuf, "%s", filename);
  711. if (! fUiServer.writeAndFixMessage(tmpBuf))
  712. return;
  713. }
  714. else
  715. {
  716. if (! fUiServer.writeMessage("\n"))
  717. return;
  718. }
  719. if (const char* const name = plugin->getName())
  720. {
  721. std::sprintf(tmpBuf, "%s", name);
  722. if (! fUiServer.writeAndFixMessage(tmpBuf))
  723. return;
  724. }
  725. else
  726. {
  727. if (! fUiServer.writeMessage("\n"))
  728. return;
  729. }
  730. if (const char* const iconName = plugin->getIconName())
  731. {
  732. std::sprintf(tmpBuf, "%s", iconName);
  733. if (! fUiServer.writeAndFixMessage(tmpBuf))
  734. return;
  735. }
  736. else
  737. {
  738. if (! fUiServer.writeMessage("\n"))
  739. return;
  740. }
  741. plugin->getRealName(tmpBuf);
  742. if (! fUiServer.writeAndFixMessage(tmpBuf))
  743. return;
  744. plugin->getLabel(tmpBuf);
  745. if (! fUiServer.writeAndFixMessage(tmpBuf))
  746. return;
  747. plugin->getMaker(tmpBuf);
  748. if (! fUiServer.writeAndFixMessage(tmpBuf))
  749. return;
  750. plugin->getCopyright(tmpBuf);
  751. if (! fUiServer.writeAndFixMessage(tmpBuf))
  752. return;
  753. std::sprintf(tmpBuf, "AUDIO_COUNT_%i:%i:%i\n", pluginId, plugin->getAudioInCount(), plugin->getAudioOutCount());
  754. if (! fUiServer.writeMessage(tmpBuf))
  755. return;
  756. std::sprintf(tmpBuf, "MIDI_COUNT_%i:%i:%i\n", pluginId, plugin->getMidiInCount(), plugin->getMidiOutCount());
  757. if (! fUiServer.writeMessage(tmpBuf))
  758. return;
  759. fUiServer.flushMessages();
  760. }
  761. void uiServerSendPluginParameters(CarlaPlugin* const plugin)
  762. {
  763. char tmpBuf[STR_MAX];
  764. carla_zeroChars(tmpBuf, STR_MAX);
  765. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  766. const ScopedLocale csl;
  767. const uint pluginId(plugin->getId());
  768. for (int32_t i=PARAMETER_ACTIVE; i>PARAMETER_MAX; --i)
  769. {
  770. std::sprintf(tmpBuf, "PARAMVAL_%i:%i\n", pluginId, i);
  771. if (! fUiServer.writeMessage(tmpBuf))
  772. return;
  773. std::sprintf(tmpBuf, "%f\n", static_cast<double>(plugin->getInternalParameterValue(i)));
  774. if (! fUiServer.writeMessage(tmpBuf))
  775. return;
  776. fUiServer.flushMessages();
  777. }
  778. uint32_t ins, outs, count;
  779. plugin->getParameterCountInfo(ins, outs);
  780. count = plugin->getParameterCount();
  781. std::sprintf(tmpBuf, "PARAMETER_COUNT_%i:%i:%i:%i\n", pluginId, ins, outs, count);
  782. if (! fUiServer.writeMessage(tmpBuf))
  783. return;
  784. for (uint32_t i=0; i<count; ++i)
  785. {
  786. const ParameterData& paramData(plugin->getParameterData(i));
  787. const ParameterRanges& paramRanges(plugin->getParameterRanges(i));
  788. std::sprintf(tmpBuf, "PARAMETER_DATA_%i:%i\n", pluginId, i);
  789. if (! fUiServer.writeMessage(tmpBuf))
  790. return;
  791. std::sprintf(tmpBuf, "%i:%i:%i:%i\n", paramData.type, paramData.hints, paramData.midiChannel, paramData.midiCC);
  792. if (! fUiServer.writeMessage(tmpBuf))
  793. return;
  794. plugin->getParameterName(i, tmpBuf);
  795. if (! fUiServer.writeAndFixMessage(tmpBuf))
  796. return;
  797. plugin->getParameterUnit(i, tmpBuf);
  798. if (! fUiServer.writeAndFixMessage(tmpBuf))
  799. return;
  800. std::sprintf(tmpBuf, "PARAMETER_RANGES_%i:%i\n", pluginId, i);
  801. if (! fUiServer.writeMessage(tmpBuf))
  802. return;
  803. std::sprintf(tmpBuf, "%f:%f:%f:%f:%f:%f\n",
  804. static_cast<double>(paramRanges.def),
  805. static_cast<double>(paramRanges.min),
  806. static_cast<double>(paramRanges.max),
  807. static_cast<double>(paramRanges.step),
  808. static_cast<double>(paramRanges.stepSmall),
  809. static_cast<double>(paramRanges.stepLarge));
  810. if (! fUiServer.writeMessage(tmpBuf))
  811. return;
  812. std::sprintf(tmpBuf, "PARAMVAL_%i:%i\n", pluginId, i);
  813. if (! fUiServer.writeMessage(tmpBuf))
  814. return;
  815. std::sprintf(tmpBuf, "%f\n", static_cast<double>(plugin->getParameterValue(i)));
  816. if (! fUiServer.writeMessage(tmpBuf))
  817. return;
  818. }
  819. fUiServer.flushMessages();
  820. }
  821. void uiServerSendPluginPrograms(CarlaPlugin* const plugin)
  822. {
  823. char tmpBuf[STR_MAX];
  824. carla_zeroChars(tmpBuf, STR_MAX);
  825. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  826. const uint pluginId(plugin->getId());
  827. uint32_t count = plugin->getProgramCount();
  828. std::sprintf(tmpBuf, "PROGRAM_COUNT_%i:%i:%i\n", pluginId, count, plugin->getCurrentProgram());
  829. if (! fUiServer.writeMessage(tmpBuf))
  830. return;
  831. for (uint32_t i=0; i<count; ++i)
  832. {
  833. std::sprintf(tmpBuf, "PROGRAM_NAME_%i:%i\n", pluginId, i);
  834. if (! fUiServer.writeMessage(tmpBuf))
  835. return;
  836. plugin->getProgramName(i, tmpBuf);
  837. if (! fUiServer.writeAndFixMessage(tmpBuf))
  838. return;
  839. }
  840. fUiServer.flushMessages();
  841. count = plugin->getMidiProgramCount();
  842. std::sprintf(tmpBuf, "MIDI_PROGRAM_COUNT_%i:%i:%i\n", pluginId, count, plugin->getCurrentMidiProgram());
  843. if (! fUiServer.writeMessage(tmpBuf))
  844. return;
  845. for (uint32_t i=0; i<count; ++i)
  846. {
  847. std::sprintf(tmpBuf, "MIDI_PROGRAM_DATA_%i:%i\n", pluginId, i);
  848. if (! fUiServer.writeMessage(tmpBuf))
  849. return;
  850. const MidiProgramData& mpData(plugin->getMidiProgramData(i));
  851. std::sprintf(tmpBuf, "%i:%i\n", mpData.bank, mpData.program);
  852. if (! fUiServer.writeMessage(tmpBuf))
  853. return;
  854. std::sprintf(tmpBuf, "%s", mpData.name);
  855. if (! fUiServer.writeAndFixMessage(tmpBuf))
  856. return;
  857. }
  858. fUiServer.flushMessages();
  859. }
  860. void uiServerSendPluginProperties(CarlaPlugin* const plugin)
  861. {
  862. char tmpBuf[STR_MAX];
  863. carla_zeroChars(tmpBuf, STR_MAX);
  864. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  865. const uint pluginId(plugin->getId());
  866. uint32_t count = plugin->getCustomDataCount();
  867. std::sprintf(tmpBuf, "CUSTOM_DATA_COUNT_%i:%i\n", pluginId, count);
  868. if (! fUiServer.writeMessage(tmpBuf))
  869. return;
  870. for (uint32_t i=0; i<count; ++i)
  871. {
  872. const CustomData& customData(plugin->getCustomData(i));
  873. CARLA_SAFE_ASSERT_CONTINUE(customData.isValid());
  874. if (std::strcmp(customData.type, CUSTOM_DATA_TYPE_PROPERTY) != 0)
  875. continue;
  876. std::sprintf(tmpBuf, "CUSTOM_DATA_%i:%i\n", pluginId, i);
  877. if (! fUiServer.writeMessage(tmpBuf))
  878. return;
  879. if (! fUiServer.writeAndFixMessage(customData.type))
  880. return;
  881. if (! fUiServer.writeAndFixMessage(customData.key))
  882. return;
  883. if (! fUiServer.writeAndFixMessage(customData.value))
  884. return;
  885. }
  886. fUiServer.flushMessages();
  887. }
  888. void uiServerCallback(const EngineCallbackOpcode action, const uint pluginId, const int value1, const int value2, const float value3, const char* const valueStr)
  889. {
  890. if (! fIsRunning)
  891. return;
  892. if (! fUiServer.isPipeRunning())
  893. return;
  894. CarlaPlugin* plugin;
  895. switch (action)
  896. {
  897. case ENGINE_CALLBACK_UPDATE:
  898. plugin = getPlugin(pluginId);
  899. if (plugin != nullptr && plugin->isEnabled())
  900. {
  901. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  902. uiServerSendPluginProperties(plugin);
  903. }
  904. break;
  905. case ENGINE_CALLBACK_RELOAD_INFO:
  906. plugin = getPlugin(pluginId);
  907. if (plugin != nullptr && plugin->isEnabled())
  908. {
  909. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  910. uiServerSendPluginInfo(plugin);
  911. }
  912. break;
  913. case ENGINE_CALLBACK_RELOAD_PARAMETERS:
  914. plugin = getPlugin(pluginId);
  915. if (plugin != nullptr && plugin->isEnabled())
  916. {
  917. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  918. uiServerSendPluginParameters(plugin);
  919. }
  920. break;
  921. case ENGINE_CALLBACK_RELOAD_PROGRAMS:
  922. plugin = getPlugin(pluginId);
  923. if (plugin != nullptr && plugin->isEnabled())
  924. {
  925. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  926. uiServerSendPluginPrograms(plugin);
  927. }
  928. break;
  929. case ENGINE_CALLBACK_RELOAD_ALL:
  930. case ENGINE_CALLBACK_PLUGIN_ADDED:
  931. plugin = getPlugin(pluginId);
  932. if (plugin != nullptr && plugin->isEnabled())
  933. {
  934. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  935. uiServerSendPluginInfo(plugin);
  936. uiServerSendPluginParameters(plugin);
  937. uiServerSendPluginPrograms(plugin);
  938. uiServerSendPluginProperties(plugin);
  939. }
  940. break;
  941. default:
  942. break;
  943. }
  944. char tmpBuf[STR_MAX];
  945. carla_zeroChars(tmpBuf, STR_MAX);
  946. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  947. std::sprintf(tmpBuf, "ENGINE_CALLBACK_%i\n", int(action));
  948. if (! fUiServer.writeMessage(tmpBuf))
  949. return;
  950. std::sprintf(tmpBuf, "%u\n", pluginId);
  951. if (! fUiServer.writeMessage(tmpBuf))
  952. return;
  953. std::sprintf(tmpBuf, "%i\n", value1);
  954. if (! fUiServer.writeMessage(tmpBuf))
  955. return;
  956. std::sprintf(tmpBuf, "%i\n", value2);
  957. if (! fUiServer.writeMessage(tmpBuf))
  958. return;
  959. {
  960. const ScopedLocale csl;
  961. std::sprintf(tmpBuf, "%f\n", static_cast<double>(value3));
  962. }
  963. if (! fUiServer.writeMessage(tmpBuf))
  964. return;
  965. if (! fUiServer.writeAndFixMessage(valueStr != nullptr ? valueStr : ""))
  966. return;
  967. fUiServer.flushMessages();
  968. }
  969. const char* uiFileCallback(FileCallbackOpcode action, bool isDir, const char* title, const char* filter)
  970. {
  971. switch (action)
  972. {
  973. case FILE_CALLBACK_DEBUG:
  974. return nullptr;
  975. case FILE_CALLBACK_OPEN:
  976. return pHost->ui_open_file(pHost->handle, isDir, title, filter);
  977. case FILE_CALLBACK_SAVE:
  978. return pHost->ui_save_file(pHost->handle, isDir, title, filter);
  979. }
  980. return nullptr;
  981. }
  982. void uiServerInfo()
  983. {
  984. CARLA_SAFE_ASSERT_RETURN(fIsRunning,);
  985. CARLA_SAFE_ASSERT_RETURN(fUiServer.isPipeRunning(),);
  986. char tmpBuf[STR_MAX];
  987. carla_zeroChars(tmpBuf, STR_MAX);
  988. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  989. #if defined(HAVE_LIBLO) && !defined(BUILD_BRIDGE)
  990. if (! fUiServer.writeAndFixMessage("osc-urls"))
  991. return;
  992. if (! fUiServer.writeAndFixMessage(pData->osc.getServerPathTCP()))
  993. return;
  994. if (! fUiServer.writeAndFixMessage(pData->osc.getServerPathUDP()))
  995. return;
  996. #endif
  997. if (! fUiServer.writeAndFixMessage("max-plugin-number"))
  998. return;
  999. std::sprintf(tmpBuf, "%i\n", pData->maxPluginNumber);
  1000. if (! fUiServer.writeMessage(tmpBuf))
  1001. return;
  1002. if (! fUiServer.writeAndFixMessage("buffer-size"))
  1003. return;
  1004. std::sprintf(tmpBuf, "%i\n", pData->bufferSize);
  1005. if (! fUiServer.writeMessage(tmpBuf))
  1006. return;
  1007. if (! fUiServer.writeAndFixMessage("sample-rate"))
  1008. return;
  1009. {
  1010. const ScopedLocale csl;
  1011. std::sprintf(tmpBuf, "%f\n", pData->sampleRate);
  1012. }
  1013. if (! fUiServer.writeMessage(tmpBuf))
  1014. return;
  1015. fUiServer.flushMessages();
  1016. }
  1017. void uiServerOptions()
  1018. {
  1019. CARLA_SAFE_ASSERT_RETURN(fIsRunning,);
  1020. CARLA_SAFE_ASSERT_RETURN(fUiServer.isPipeRunning(),);
  1021. char tmpBuf[STR_MAX];
  1022. carla_zeroChars(tmpBuf, STR_MAX);
  1023. const EngineOptions& options(pData->options);
  1024. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  1025. const char* const optionsForcedStr(fOptionsForced ? "true\n" : "false\n");
  1026. const std::size_t optionsForcedStrSize(fOptionsForced ? 5 : 6);
  1027. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_PROCESS_MODE);
  1028. if (! fUiServer.writeMessage(tmpBuf))
  1029. return;
  1030. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1031. return;
  1032. std::sprintf(tmpBuf, "%i\n", options.processMode);
  1033. if (! fUiServer.writeMessage(tmpBuf))
  1034. return;
  1035. fUiServer.flushMessages();
  1036. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_TRANSPORT_MODE);
  1037. if (! fUiServer.writeMessage(tmpBuf))
  1038. return;
  1039. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1040. return;
  1041. std::sprintf(tmpBuf, "%i\n", options.transportMode);
  1042. if (! fUiServer.writeMessage(tmpBuf))
  1043. return;
  1044. fUiServer.flushMessages();
  1045. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_FORCE_STEREO);
  1046. if (! fUiServer.writeMessage(tmpBuf))
  1047. return;
  1048. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1049. return;
  1050. if (! fUiServer.writeMessage(options.forceStereo ? "true\n" : "false\n"))
  1051. return;
  1052. fUiServer.flushMessages();
  1053. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_PREFER_PLUGIN_BRIDGES);
  1054. if (! fUiServer.writeMessage(tmpBuf))
  1055. return;
  1056. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1057. return;
  1058. if (! fUiServer.writeMessage(options.preferPluginBridges ? "true\n" : "false\n"))
  1059. return;
  1060. fUiServer.flushMessages();
  1061. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_PREFER_UI_BRIDGES);
  1062. if (! fUiServer.writeMessage(tmpBuf))
  1063. return;
  1064. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1065. return;
  1066. if (! fUiServer.writeMessage(options.preferUiBridges ? "true\n" : "false\n"))
  1067. return;
  1068. fUiServer.flushMessages();
  1069. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_UIS_ALWAYS_ON_TOP);
  1070. if (! fUiServer.writeMessage(tmpBuf))
  1071. return;
  1072. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1073. return;
  1074. if (! fUiServer.writeMessage(options.uisAlwaysOnTop ? "true\n" : "false\n"))
  1075. return;
  1076. fUiServer.flushMessages();
  1077. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_MAX_PARAMETERS);
  1078. if (! fUiServer.writeMessage(tmpBuf))
  1079. return;
  1080. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1081. return;
  1082. std::sprintf(tmpBuf, "%i\n", options.maxParameters);
  1083. if (! fUiServer.writeMessage(tmpBuf))
  1084. return;
  1085. fUiServer.flushMessages();
  1086. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_UI_BRIDGES_TIMEOUT);
  1087. if (! fUiServer.writeMessage(tmpBuf))
  1088. return;
  1089. if (! fUiServer.writeMessage(optionsForcedStr, optionsForcedStrSize))
  1090. return;
  1091. std::sprintf(tmpBuf, "%i\n", options.uiBridgesTimeout);
  1092. if (! fUiServer.writeMessage(tmpBuf))
  1093. return;
  1094. fUiServer.flushMessages();
  1095. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_PATH_BINARIES);
  1096. if (! fUiServer.writeMessage(tmpBuf))
  1097. return;
  1098. if (! fUiServer.writeMessage("true\n", 5))
  1099. return;
  1100. std::sprintf(tmpBuf, "%s\n", options.binaryDir);
  1101. if (! fUiServer.writeMessage(tmpBuf))
  1102. return;
  1103. fUiServer.flushMessages();
  1104. std::sprintf(tmpBuf, "ENGINE_OPTION_%i\n", ENGINE_OPTION_PATH_RESOURCES);
  1105. if (! fUiServer.writeMessage(tmpBuf))
  1106. return;
  1107. if (! fUiServer.writeMessage("true\n", 5))
  1108. return;
  1109. std::sprintf(tmpBuf, "%s\n", options.resourceDir);
  1110. if (! fUiServer.writeMessage(tmpBuf))
  1111. return;
  1112. fUiServer.flushMessages();
  1113. }
  1114. // -------------------------------------------------------------------
  1115. // Plugin parameter calls
  1116. uint32_t getParameterCount() const
  1117. {
  1118. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1119. return plugin->getParameterCount();
  1120. return 0;
  1121. }
  1122. const NativeParameter* getParameterInfo(const uint32_t index) const
  1123. {
  1124. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1125. {
  1126. if (index < plugin->getParameterCount())
  1127. {
  1128. static NativeParameter param;
  1129. static char strBufName[STR_MAX+1];
  1130. static char strBufUnit[STR_MAX+1];
  1131. const ParameterData& paramData(plugin->getParameterData(index));
  1132. const ParameterRanges& paramRanges(plugin->getParameterRanges(index));
  1133. plugin->getParameterName(index, strBufName);
  1134. plugin->getParameterUnit(index, strBufUnit);
  1135. uint hints = 0x0;
  1136. if (paramData.hints & PARAMETER_IS_BOOLEAN)
  1137. hints |= NATIVE_PARAMETER_IS_BOOLEAN;
  1138. if (paramData.hints & PARAMETER_IS_INTEGER)
  1139. hints |= NATIVE_PARAMETER_IS_INTEGER;
  1140. if (paramData.hints & PARAMETER_IS_LOGARITHMIC)
  1141. hints |= NATIVE_PARAMETER_IS_LOGARITHMIC;
  1142. if (paramData.hints & PARAMETER_IS_AUTOMABLE)
  1143. hints |= NATIVE_PARAMETER_IS_AUTOMABLE;
  1144. if (paramData.hints & PARAMETER_USES_SAMPLERATE)
  1145. hints |= NATIVE_PARAMETER_USES_SAMPLE_RATE;
  1146. if (paramData.hints & PARAMETER_USES_SCALEPOINTS)
  1147. hints |= NATIVE_PARAMETER_USES_SCALEPOINTS;
  1148. if (paramData.type == PARAMETER_INPUT || paramData.type == PARAMETER_OUTPUT)
  1149. {
  1150. if (paramData.hints & PARAMETER_IS_ENABLED)
  1151. hints |= NATIVE_PARAMETER_IS_ENABLED;
  1152. if (paramData.type == PARAMETER_OUTPUT)
  1153. hints |= NATIVE_PARAMETER_IS_OUTPUT;
  1154. }
  1155. param.hints = static_cast<NativeParameterHints>(hints);
  1156. param.name = strBufName;
  1157. param.unit = strBufUnit;
  1158. param.ranges.def = paramRanges.def;
  1159. param.ranges.min = paramRanges.min;
  1160. param.ranges.max = paramRanges.max;
  1161. param.ranges.step = paramRanges.step;
  1162. param.ranges.stepSmall = paramRanges.stepSmall;
  1163. param.ranges.stepLarge = paramRanges.stepLarge;
  1164. param.scalePointCount = 0; // TODO
  1165. param.scalePoints = nullptr;
  1166. return &param;
  1167. }
  1168. }
  1169. return nullptr;
  1170. }
  1171. float getParameterValue(const uint32_t index) const
  1172. {
  1173. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1174. {
  1175. if (index < plugin->getParameterCount())
  1176. return plugin->getParameterValue(index);
  1177. }
  1178. return 0.0f;
  1179. }
  1180. // -------------------------------------------------------------------
  1181. // Plugin midi-program calls
  1182. uint32_t getMidiProgramCount() const
  1183. {
  1184. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1185. return plugin->getMidiProgramCount();
  1186. return 0;
  1187. }
  1188. const NativeMidiProgram* getMidiProgramInfo(const uint32_t index) const
  1189. {
  1190. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1191. {
  1192. if (index < plugin->getMidiProgramCount())
  1193. {
  1194. static NativeMidiProgram midiProg;
  1195. {
  1196. const MidiProgramData& midiProgData(plugin->getMidiProgramData(index));
  1197. midiProg.bank = midiProgData.bank;
  1198. midiProg.program = midiProgData.program;
  1199. midiProg.name = midiProgData.name;
  1200. }
  1201. return &midiProg;
  1202. }
  1203. }
  1204. return nullptr;
  1205. }
  1206. // -------------------------------------------------------------------
  1207. // Plugin state calls
  1208. void setParameterValue(const uint32_t index, const float value)
  1209. {
  1210. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1211. {
  1212. if (index < plugin->getParameterCount())
  1213. plugin->setParameterValue(index, value, false, false, false);
  1214. }
  1215. }
  1216. void setMidiProgram(const uint8_t, const uint32_t bank, const uint32_t program)
  1217. {
  1218. if (CarlaPlugin* const plugin = _getFirstPlugin())
  1219. plugin->setMidiProgramById(bank, program, false, false, false);
  1220. }
  1221. // -------------------------------------------------------------------
  1222. // Plugin process calls
  1223. void activate()
  1224. {
  1225. #if 0
  1226. for (uint i=0; i < pData->curPluginCount; ++i)
  1227. {
  1228. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1229. if (plugin == nullptr || ! plugin->isEnabled())
  1230. continue;
  1231. plugin->setActive(true, true, false);
  1232. }
  1233. #endif
  1234. fIsActive = true;
  1235. }
  1236. void deactivate()
  1237. {
  1238. fIsActive = false;
  1239. #if 0
  1240. for (uint i=0; i < pData->curPluginCount; ++i)
  1241. {
  1242. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1243. if (plugin == nullptr || ! plugin->isEnabled())
  1244. continue;
  1245. plugin->setActive(false, true, false);
  1246. }
  1247. #endif
  1248. // just in case
  1249. //runPendingRtEvents();
  1250. }
  1251. void process(float** const inBuffer, float** const outBuffer, const uint32_t frames,
  1252. const NativeMidiEvent* const midiEvents, const uint32_t midiEventCount)
  1253. {
  1254. const PendingRtEventsRunner prt(this, frames);
  1255. // ---------------------------------------------------------------
  1256. // Time Info
  1257. const NativeTimeInfo* const timeInfo(pHost->get_time_info(pHost->handle));
  1258. pData->timeInfo.playing = timeInfo->playing;
  1259. pData->timeInfo.frame = timeInfo->frame;
  1260. pData->timeInfo.usecs = timeInfo->usecs;
  1261. pData->timeInfo.bbt.valid = timeInfo->bbt.valid;
  1262. if (timeInfo->bbt.valid)
  1263. {
  1264. pData->timeInfo.bbt.bar = timeInfo->bbt.bar;
  1265. pData->timeInfo.bbt.beat = timeInfo->bbt.beat;
  1266. pData->timeInfo.bbt.tick = timeInfo->bbt.tick;
  1267. pData->timeInfo.bbt.barStartTick = timeInfo->bbt.barStartTick;
  1268. pData->timeInfo.bbt.beatsPerBar = timeInfo->bbt.beatsPerBar;
  1269. pData->timeInfo.bbt.beatType = timeInfo->bbt.beatType;
  1270. pData->timeInfo.bbt.ticksPerBeat = timeInfo->bbt.ticksPerBeat;
  1271. pData->timeInfo.bbt.beatsPerMinute = timeInfo->bbt.beatsPerMinute;
  1272. }
  1273. // ---------------------------------------------------------------
  1274. // Do nothing if no plugins and rack mode
  1275. if (pData->curPluginCount == 0 && ! kIsPatchbay)
  1276. {
  1277. if (outBuffer[0] != inBuffer[0])
  1278. carla_copyFloats(outBuffer[0], inBuffer[0], frames);
  1279. if (outBuffer[1] != inBuffer[1])
  1280. carla_copyFloats(outBuffer[1], inBuffer[1], frames);
  1281. for (uint32_t i=0; i < midiEventCount; ++i)
  1282. {
  1283. if (! pHost->write_midi_event(pHost->handle, &midiEvents[i]))
  1284. break;
  1285. }
  1286. return;
  1287. }
  1288. // ---------------------------------------------------------------
  1289. // initialize events
  1290. carla_zeroStructs(pData->events.in, kMaxEngineEventInternalCount);
  1291. carla_zeroStructs(pData->events.out, kMaxEngineEventInternalCount);
  1292. // ---------------------------------------------------------------
  1293. // events input (before processing)
  1294. {
  1295. uint32_t engineEventIndex = 0;
  1296. for (uint32_t i=0; i < midiEventCount && engineEventIndex < kMaxEngineEventInternalCount; ++i)
  1297. {
  1298. const NativeMidiEvent& midiEvent(midiEvents[i]);
  1299. EngineEvent& engineEvent(pData->events.in[engineEventIndex++]);
  1300. engineEvent.time = midiEvent.time;
  1301. engineEvent.fillFromMidiData(midiEvent.size, midiEvent.data, 0);
  1302. if (engineEventIndex >= kMaxEngineEventInternalCount)
  1303. break;
  1304. }
  1305. }
  1306. if (kIsPatchbay)
  1307. {
  1308. // -----------------------------------------------------------
  1309. // process
  1310. pData->graph.process(pData, inBuffer, outBuffer, frames);
  1311. }
  1312. else
  1313. {
  1314. // -----------------------------------------------------------
  1315. // create audio buffers
  1316. const float* inBuf[2] = { inBuffer[0], inBuffer[1] };
  1317. /* */ float* outBuf[2] = { outBuffer[0], outBuffer[1] };
  1318. // -----------------------------------------------------------
  1319. // process
  1320. pData->graph.processRack(pData, inBuf, outBuf, frames);
  1321. }
  1322. // ---------------------------------------------------------------
  1323. // events output (after processing)
  1324. carla_zeroStructs(pData->events.in, kMaxEngineEventInternalCount);
  1325. if (kHasMidiOut)
  1326. {
  1327. NativeMidiEvent midiEvent;
  1328. for (uint32_t i=0; i < kMaxEngineEventInternalCount; ++i)
  1329. {
  1330. const EngineEvent& engineEvent(pData->events.out[i]);
  1331. if (engineEvent.type == kEngineEventTypeNull)
  1332. break;
  1333. carla_zeroStruct(midiEvent);
  1334. midiEvent.time = engineEvent.time;
  1335. /**/ if (engineEvent.type == kEngineEventTypeControl)
  1336. {
  1337. midiEvent.port = 0;
  1338. midiEvent.size = engineEvent.ctrl.convertToMidiData(engineEvent.channel, midiEvent.data);
  1339. }
  1340. else if (engineEvent.type == kEngineEventTypeMidi)
  1341. {
  1342. if (engineEvent.midi.size > 4)
  1343. continue;
  1344. midiEvent.port = engineEvent.midi.port;
  1345. midiEvent.size = engineEvent.midi.size;
  1346. midiEvent.data[0] = static_cast<uint8_t>(engineEvent.midi.data[0] | (engineEvent.channel & MIDI_CHANNEL_BIT));
  1347. for (uint8_t j=1; j < midiEvent.size; ++j)
  1348. midiEvent.data[j] = engineEvent.midi.data[j];
  1349. }
  1350. else
  1351. {
  1352. continue;
  1353. }
  1354. if (midiEvent.size > 0)
  1355. pHost->write_midi_event(pHost->handle, &midiEvent);
  1356. }
  1357. }
  1358. }
  1359. // -------------------------------------------------------------------
  1360. // Plugin UI calls
  1361. void uiShow(const bool show)
  1362. {
  1363. if (show)
  1364. {
  1365. if (fUiServer.isPipeRunning())
  1366. {
  1367. fUiServer.writeFocusMessage();
  1368. return;
  1369. }
  1370. CarlaString path(pHost->resourceDir);
  1371. if (kIsPatchbay)
  1372. path += CARLA_OS_SEP_STR "carla-plugin-patchbay";
  1373. else
  1374. path += CARLA_OS_SEP_STR "carla-plugin";
  1375. #ifdef CARLA_OS_WIN
  1376. path += ".exe";
  1377. #endif
  1378. carla_stdout("Trying to start carla-plugin using \"%s\"", path.buffer());
  1379. fUiServer.setData(path, pData->sampleRate, pHost->uiName);
  1380. if (! fUiServer.startPipeServer(false))
  1381. {
  1382. pHost->dispatcher(pHost->handle, NATIVE_HOST_OPCODE_UI_UNAVAILABLE, 0, 0, nullptr, 0.0f);
  1383. return;
  1384. }
  1385. uiServerInfo();
  1386. uiServerOptions();
  1387. uiServerCallback(ENGINE_CALLBACK_ENGINE_STARTED, 0,
  1388. pData->options.processMode, pData->options.transportMode,
  1389. static_cast<float>(pData->sampleRate), "Plugin");
  1390. fUiServer.writeShowMessage();
  1391. for (uint i=0; i < pData->curPluginCount; ++i)
  1392. {
  1393. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1394. if (plugin != nullptr && plugin->isEnabled())
  1395. {
  1396. uiServerCallback(ENGINE_CALLBACK_PLUGIN_ADDED, i, 0, 0, 0.0f, plugin->getName());
  1397. }
  1398. }
  1399. if (kIsPatchbay)
  1400. patchbayRefresh(false);
  1401. }
  1402. else
  1403. {
  1404. fUiServer.stopPipeServer(2000);
  1405. // hide all custom uis
  1406. for (uint i=0; i < pData->curPluginCount; ++i)
  1407. {
  1408. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1409. if (plugin != nullptr && plugin->isEnabled())
  1410. {
  1411. if (plugin->getHints() & PLUGIN_HAS_CUSTOM_UI)
  1412. {
  1413. try {
  1414. plugin->showCustomUI(false);
  1415. } CARLA_SAFE_EXCEPTION_CONTINUE("Plugin showCustomUI (hide)");
  1416. }
  1417. }
  1418. }
  1419. }
  1420. }
  1421. void uiIdle()
  1422. {
  1423. for (uint i=0; i < pData->curPluginCount; ++i)
  1424. {
  1425. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1426. if (plugin != nullptr && plugin->isEnabled())
  1427. {
  1428. const uint hints(plugin->getHints());
  1429. if ((hints & PLUGIN_HAS_CUSTOM_UI) != 0 && (hints & PLUGIN_NEEDS_UI_MAIN_THREAD) != 0)
  1430. {
  1431. try {
  1432. plugin->uiIdle();
  1433. } CARLA_SAFE_EXCEPTION_CONTINUE("Plugin uiIdle");
  1434. }
  1435. }
  1436. }
  1437. idlePipe();
  1438. switch (fUiServer.getAndResetUiState())
  1439. {
  1440. case CarlaExternalUI::UiNone:
  1441. case CarlaExternalUI::UiShow:
  1442. break;
  1443. case CarlaExternalUI::UiCrashed:
  1444. pHost->dispatcher(pHost->handle, NATIVE_HOST_OPCODE_UI_UNAVAILABLE, 0, 0, nullptr, 0.0f);
  1445. break;
  1446. case CarlaExternalUI::UiHide:
  1447. pHost->ui_closed(pHost->handle);
  1448. fUiServer.stopPipeServer(1000);
  1449. break;
  1450. }
  1451. }
  1452. void idlePipe()
  1453. {
  1454. if (! fUiServer.isPipeRunning())
  1455. return;
  1456. fUiServer.idlePipe();
  1457. char tmpBuf[STR_MAX];
  1458. carla_zeroChars(tmpBuf, STR_MAX);
  1459. const CarlaMutexLocker cml(fUiServer.getPipeLock());
  1460. const ScopedLocale csl;
  1461. const EngineTimeInfo& timeInfo(pData->timeInfo);
  1462. // send transport
  1463. if (! fUiServer.writeAndFixMessage("transport"))
  1464. return;
  1465. if (! fUiServer.writeMessage(timeInfo.playing ? "true\n" : "false\n"))
  1466. return;
  1467. if (timeInfo.bbt.valid)
  1468. {
  1469. std::sprintf(tmpBuf, P_UINT64 ":%i:%i:%i\n",
  1470. timeInfo.frame, timeInfo.bbt.bar, timeInfo.bbt.beat, static_cast<int>(timeInfo.bbt.tick + 0.5));
  1471. if (! fUiServer.writeMessage(tmpBuf))
  1472. return;
  1473. std::sprintf(tmpBuf, "%f\n", timeInfo.bbt.beatsPerMinute);
  1474. if (! fUiServer.writeMessage(tmpBuf))
  1475. return;
  1476. }
  1477. else
  1478. {
  1479. std::sprintf(tmpBuf, P_UINT64 ":0:0:0\n", timeInfo.frame);
  1480. if (! fUiServer.writeMessage(tmpBuf))
  1481. return;
  1482. if (! fUiServer.writeMessage("0.0\n"))
  1483. return;
  1484. }
  1485. fUiServer.flushMessages();
  1486. // send peaks and param outputs for all plugins
  1487. for (uint i=0; i < pData->curPluginCount; ++i)
  1488. {
  1489. const EnginePluginData& plugData(pData->plugins[i]);
  1490. const CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1491. std::sprintf(tmpBuf, "PEAKS_%i\n", i);
  1492. if (! fUiServer.writeMessage(tmpBuf))
  1493. return;
  1494. std::sprintf(tmpBuf, "%f:%f:%f:%f\n",
  1495. static_cast<double>(plugData.peaks[0]),
  1496. static_cast<double>(plugData.peaks[1]),
  1497. static_cast<double>(plugData.peaks[2]),
  1498. static_cast<double>(plugData.peaks[3]));
  1499. if (! fUiServer.writeMessage(tmpBuf))
  1500. return;
  1501. fUiServer.flushMessages();
  1502. for (uint32_t j=0, count=plugin->getParameterCount(); j < count; ++j)
  1503. {
  1504. if (! plugin->isParameterOutput(j))
  1505. continue;
  1506. std::sprintf(tmpBuf, "PARAMVAL_%i:%i\n", i, j);
  1507. if (! fUiServer.writeMessage(tmpBuf))
  1508. return;
  1509. std::sprintf(tmpBuf, "%f\n", static_cast<double>(plugin->getParameterValue(j)));
  1510. if (! fUiServer.writeMessage(tmpBuf))
  1511. return;
  1512. fUiServer.flushMessages();
  1513. }
  1514. }
  1515. }
  1516. // -------------------------------------------------------------------
  1517. // Plugin state calls
  1518. char* getState() const
  1519. {
  1520. MemoryOutputStream out;
  1521. saveProjectInternal(out);
  1522. return strdup(out.toString().toRawUTF8());
  1523. }
  1524. void setState(const char* const data)
  1525. {
  1526. // remove all plugins from UI side
  1527. for (uint i=0, count=pData->curPluginCount; i < count; ++i)
  1528. CarlaEngine::callback(ENGINE_CALLBACK_PLUGIN_REMOVED, count-i-1, 0, 0, 0.0f, nullptr);
  1529. // remove all plugins from backend, no lock
  1530. fIsRunning = false;
  1531. removeAllPlugins();
  1532. fIsRunning = true;
  1533. // stopped during removeAllPlugins()
  1534. if (! pData->thread.isThreadRunning())
  1535. pData->thread.startThread();
  1536. fOptionsForced = true;
  1537. const String state(data);
  1538. XmlDocument xml(state);
  1539. loadProjectInternal(xml);
  1540. }
  1541. // -------------------------------------------------------------------
  1542. public:
  1543. #define handlePtr ((CarlaEngineNative*)handle)
  1544. static NativePluginHandle _instantiateRack(const NativeHostDescriptor* host)
  1545. {
  1546. return new CarlaEngineNative(host, false, true);
  1547. }
  1548. static NativePluginHandle _instantiateRackNoMidiOut(const NativeHostDescriptor* host)
  1549. {
  1550. return new CarlaEngineNative(host, false, false);
  1551. }
  1552. static NativePluginHandle _instantiatePatchbay(const NativeHostDescriptor* host)
  1553. {
  1554. return new CarlaEngineNative(host, true, true);
  1555. }
  1556. static NativePluginHandle _instantiatePatchbay3s(const NativeHostDescriptor* host)
  1557. {
  1558. return new CarlaEngineNative(host, true, true, 3, 2);
  1559. }
  1560. static NativePluginHandle _instantiatePatchbay16(const NativeHostDescriptor* host)
  1561. {
  1562. return new CarlaEngineNative(host, true, true, 16, 16);
  1563. }
  1564. static NativePluginHandle _instantiatePatchbay32(const NativeHostDescriptor* host)
  1565. {
  1566. return new CarlaEngineNative(host, true, true, 32, 32);
  1567. }
  1568. static void _cleanup(NativePluginHandle handle)
  1569. {
  1570. delete handlePtr;
  1571. }
  1572. static uint32_t _get_parameter_count(NativePluginHandle handle)
  1573. {
  1574. return handlePtr->getParameterCount();
  1575. }
  1576. static const NativeParameter* _get_parameter_info(NativePluginHandle handle, uint32_t index)
  1577. {
  1578. return handlePtr->getParameterInfo(index);
  1579. }
  1580. static float _get_parameter_value(NativePluginHandle handle, uint32_t index)
  1581. {
  1582. return handlePtr->getParameterValue(index);
  1583. }
  1584. static uint32_t _get_midi_program_count(NativePluginHandle handle)
  1585. {
  1586. return handlePtr->getMidiProgramCount();
  1587. }
  1588. static const NativeMidiProgram* _get_midi_program_info(NativePluginHandle handle, uint32_t index)
  1589. {
  1590. return handlePtr->getMidiProgramInfo(index);
  1591. }
  1592. static void _set_parameter_value(NativePluginHandle handle, uint32_t index, float value)
  1593. {
  1594. handlePtr->setParameterValue(index, value);
  1595. }
  1596. static void _set_midi_program(NativePluginHandle handle, uint8_t channel, uint32_t bank, uint32_t program)
  1597. {
  1598. handlePtr->setMidiProgram(channel, bank, program);
  1599. }
  1600. static void _ui_show(NativePluginHandle handle, bool show)
  1601. {
  1602. handlePtr->uiShow(show);
  1603. }
  1604. static void _ui_idle(NativePluginHandle handle)
  1605. {
  1606. handlePtr->uiIdle();
  1607. }
  1608. static void _activate(NativePluginHandle handle)
  1609. {
  1610. handlePtr->activate();
  1611. }
  1612. static void _deactivate(NativePluginHandle handle)
  1613. {
  1614. handlePtr->deactivate();
  1615. }
  1616. static void _process(NativePluginHandle handle, float** inBuffer, float** outBuffer, const uint32_t frames, const NativeMidiEvent* midiEvents, uint32_t midiEventCount)
  1617. {
  1618. handlePtr->process(inBuffer, outBuffer, frames, midiEvents, midiEventCount);
  1619. }
  1620. static char* _get_state(NativePluginHandle handle)
  1621. {
  1622. return handlePtr->getState();
  1623. }
  1624. static void _set_state(NativePluginHandle handle, const char* data)
  1625. {
  1626. handlePtr->setState(data);
  1627. }
  1628. static intptr_t _dispatcher(NativePluginHandle handle, NativePluginDispatcherOpcode opcode, int32_t index, intptr_t value, void* ptr, float opt)
  1629. {
  1630. switch(opcode)
  1631. {
  1632. case NATIVE_PLUGIN_OPCODE_NULL:
  1633. return 0;
  1634. case NATIVE_PLUGIN_OPCODE_BUFFER_SIZE_CHANGED:
  1635. CARLA_SAFE_ASSERT_RETURN(value > 0, 0);
  1636. handlePtr->bufferSizeChanged(static_cast<uint32_t>(value));
  1637. return 0;
  1638. case NATIVE_PLUGIN_OPCODE_SAMPLE_RATE_CHANGED:
  1639. CARLA_SAFE_ASSERT_RETURN(opt > 0.0f, 0);
  1640. handlePtr->sampleRateChanged(static_cast<double>(opt));
  1641. return 0;
  1642. case NATIVE_PLUGIN_OPCODE_OFFLINE_CHANGED:
  1643. handlePtr->offlineModeChanged(value != 0);
  1644. return 0;
  1645. case NATIVE_PLUGIN_OPCODE_UI_NAME_CHANGED:
  1646. //handlePtr->uiNameChanged(static_cast<const char*>(ptr));
  1647. return 0;
  1648. case NATIVE_PLUGIN_OPCODE_GET_INTERNAL_HANDLE: {
  1649. CarlaEngineNative* const engine = handlePtr;
  1650. return (intptr_t)(CarlaEngine*)engine;
  1651. }
  1652. }
  1653. return 0;
  1654. // unused
  1655. (void)index;
  1656. (void)ptr;
  1657. }
  1658. // -------------------------------------------------------------------
  1659. static void _ui_server_callback(void* handle, EngineCallbackOpcode action, uint pluginId, int value1, int value2, float value3, const char* valueStr)
  1660. {
  1661. handlePtr->uiServerCallback(action, pluginId, value1, value2, value3, valueStr);
  1662. }
  1663. static const char* _ui_file_callback(void* handle, FileCallbackOpcode action, bool isDir, const char* title, const char* filter)
  1664. {
  1665. return handlePtr->uiFileCallback(action, isDir, title, filter);
  1666. }
  1667. // -------------------------------------------------------------------
  1668. #undef handlePtr
  1669. private:
  1670. const NativeHostDescriptor* const pHost;
  1671. const bool kIsPatchbay; // rack if false
  1672. const bool kHasMidiOut;
  1673. bool fIsActive, fIsRunning;
  1674. CarlaEngineNativeUI fUiServer;
  1675. bool fOptionsForced;
  1676. #ifdef USE_JUCE_MESSAGE_THREAD
  1677. const bool kNeedsJuceMsgThread;
  1678. const juce::SharedResourcePointer<SharedJuceMessageThread> sJuceMsgThread;
  1679. #endif
  1680. CarlaPlugin* _getFirstPlugin() const noexcept
  1681. {
  1682. if (pData->curPluginCount == 0 || pData->plugins == nullptr)
  1683. return nullptr;
  1684. CarlaPlugin* const plugin(pData->plugins[0].plugin);
  1685. if (plugin == nullptr || ! plugin->isEnabled())
  1686. return nullptr;
  1687. return pData->plugins[0].plugin;
  1688. }
  1689. CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineNative)
  1690. };
  1691. // -----------------------------------------------------------------------
  1692. static const NativePluginDescriptor carlaRackDesc = {
  1693. /* category */ NATIVE_PLUGIN_CATEGORY_OTHER,
  1694. /* hints */ static_cast<NativePluginHints>(NATIVE_PLUGIN_IS_SYNTH
  1695. |NATIVE_PLUGIN_HAS_UI
  1696. |NATIVE_PLUGIN_NEEDS_UI_MAIN_THREAD
  1697. |NATIVE_PLUGIN_USES_STATE
  1698. |NATIVE_PLUGIN_USES_TIME),
  1699. /* supports */ static_cast<NativePluginSupports>(NATIVE_PLUGIN_SUPPORTS_EVERYTHING),
  1700. /* audioIns */ 2,
  1701. /* audioOuts */ 2,
  1702. /* midiIns */ 1,
  1703. /* midiOuts */ 1,
  1704. /* paramIns */ 0,
  1705. /* paramOuts */ 0,
  1706. /* name */ "Carla-Rack",
  1707. /* label */ "carlarack",
  1708. /* maker */ "falkTX",
  1709. /* copyright */ "GNU GPL v2+",
  1710. CarlaEngineNative::_instantiateRack,
  1711. CarlaEngineNative::_cleanup,
  1712. CarlaEngineNative::_get_parameter_count,
  1713. CarlaEngineNative::_get_parameter_info,
  1714. CarlaEngineNative::_get_parameter_value,
  1715. CarlaEngineNative::_get_midi_program_count,
  1716. CarlaEngineNative::_get_midi_program_info,
  1717. CarlaEngineNative::_set_parameter_value,
  1718. CarlaEngineNative::_set_midi_program,
  1719. /* _set_custom_data */ nullptr,
  1720. CarlaEngineNative::_ui_show,
  1721. CarlaEngineNative::_ui_idle,
  1722. /* _ui_set_parameter_value */ nullptr,
  1723. /* _ui_set_midi_program */ nullptr,
  1724. /* _ui_set_custom_data */ nullptr,
  1725. CarlaEngineNative::_activate,
  1726. CarlaEngineNative::_deactivate,
  1727. CarlaEngineNative::_process,
  1728. CarlaEngineNative::_get_state,
  1729. CarlaEngineNative::_set_state,
  1730. CarlaEngineNative::_dispatcher
  1731. };
  1732. static const NativePluginDescriptor carlaRackNoMidiOutDesc = {
  1733. /* category */ NATIVE_PLUGIN_CATEGORY_OTHER,
  1734. /* hints */ static_cast<NativePluginHints>(NATIVE_PLUGIN_IS_SYNTH
  1735. |NATIVE_PLUGIN_HAS_UI
  1736. |NATIVE_PLUGIN_NEEDS_UI_MAIN_THREAD
  1737. |NATIVE_PLUGIN_USES_STATE
  1738. |NATIVE_PLUGIN_USES_TIME),
  1739. /* supports */ static_cast<NativePluginSupports>(NATIVE_PLUGIN_SUPPORTS_EVERYTHING),
  1740. /* audioIns */ 2,
  1741. /* audioOuts */ 2,
  1742. /* midiIns */ 1,
  1743. /* midiOuts */ 0,
  1744. /* paramIns */ 0,
  1745. /* paramOuts */ 0,
  1746. /* name */ "Carla-Rack (no midi out)",
  1747. /* label */ "carlarack-nomidiout",
  1748. /* maker */ "falkTX",
  1749. /* copyright */ "GNU GPL v2+",
  1750. CarlaEngineNative::_instantiateRackNoMidiOut,
  1751. CarlaEngineNative::_cleanup,
  1752. CarlaEngineNative::_get_parameter_count,
  1753. CarlaEngineNative::_get_parameter_info,
  1754. CarlaEngineNative::_get_parameter_value,
  1755. CarlaEngineNative::_get_midi_program_count,
  1756. CarlaEngineNative::_get_midi_program_info,
  1757. CarlaEngineNative::_set_parameter_value,
  1758. CarlaEngineNative::_set_midi_program,
  1759. /* _set_custom_data */ nullptr,
  1760. CarlaEngineNative::_ui_show,
  1761. CarlaEngineNative::_ui_idle,
  1762. /* _ui_set_parameter_value */ nullptr,
  1763. /* _ui_set_midi_program */ nullptr,
  1764. /* _ui_set_custom_data */ nullptr,
  1765. CarlaEngineNative::_activate,
  1766. CarlaEngineNative::_deactivate,
  1767. CarlaEngineNative::_process,
  1768. CarlaEngineNative::_get_state,
  1769. CarlaEngineNative::_set_state,
  1770. CarlaEngineNative::_dispatcher
  1771. };
  1772. static const NativePluginDescriptor carlaPatchbayDesc = {
  1773. /* category */ NATIVE_PLUGIN_CATEGORY_OTHER,
  1774. /* hints */ static_cast<NativePluginHints>(NATIVE_PLUGIN_IS_SYNTH
  1775. |NATIVE_PLUGIN_HAS_UI
  1776. |NATIVE_PLUGIN_NEEDS_UI_MAIN_THREAD
  1777. |NATIVE_PLUGIN_USES_STATE
  1778. |NATIVE_PLUGIN_USES_TIME),
  1779. /* supports */ static_cast<NativePluginSupports>(NATIVE_PLUGIN_SUPPORTS_EVERYTHING),
  1780. /* audioIns */ 2,
  1781. /* audioOuts */ 2,
  1782. /* midiIns */ 1,
  1783. /* midiOuts */ 1,
  1784. /* paramIns */ 0,
  1785. /* paramOuts */ 0,
  1786. /* name */ "Carla-Patchbay",
  1787. /* label */ "carlapatchbay",
  1788. /* maker */ "falkTX",
  1789. /* copyright */ "GNU GPL v2+",
  1790. CarlaEngineNative::_instantiatePatchbay,
  1791. CarlaEngineNative::_cleanup,
  1792. CarlaEngineNative::_get_parameter_count,
  1793. CarlaEngineNative::_get_parameter_info,
  1794. CarlaEngineNative::_get_parameter_value,
  1795. CarlaEngineNative::_get_midi_program_count,
  1796. CarlaEngineNative::_get_midi_program_info,
  1797. CarlaEngineNative::_set_parameter_value,
  1798. CarlaEngineNative::_set_midi_program,
  1799. /* _set_custom_data */ nullptr,
  1800. CarlaEngineNative::_ui_show,
  1801. CarlaEngineNative::_ui_idle,
  1802. /* _ui_set_parameter_value */ nullptr,
  1803. /* _ui_set_midi_program */ nullptr,
  1804. /* _ui_set_custom_data */ nullptr,
  1805. CarlaEngineNative::_activate,
  1806. CarlaEngineNative::_deactivate,
  1807. CarlaEngineNative::_process,
  1808. CarlaEngineNative::_get_state,
  1809. CarlaEngineNative::_set_state,
  1810. CarlaEngineNative::_dispatcher
  1811. };
  1812. static const NativePluginDescriptor carlaPatchbay3sDesc = {
  1813. /* category */ NATIVE_PLUGIN_CATEGORY_OTHER,
  1814. /* hints */ static_cast<NativePluginHints>(NATIVE_PLUGIN_IS_SYNTH
  1815. |NATIVE_PLUGIN_HAS_UI
  1816. |NATIVE_PLUGIN_NEEDS_UI_MAIN_THREAD
  1817. |NATIVE_PLUGIN_USES_STATE
  1818. |NATIVE_PLUGIN_USES_TIME),
  1819. /* supports */ static_cast<NativePluginSupports>(NATIVE_PLUGIN_SUPPORTS_EVERYTHING),
  1820. /* audioIns */ 3,
  1821. /* audioOuts */ 2,
  1822. /* midiIns */ 1,
  1823. /* midiOuts */ 1,
  1824. /* paramIns */ 0,
  1825. /* paramOuts */ 0,
  1826. /* name */ "Carla-Patchbay (sidechain)",
  1827. /* label */ "carlapatchbay3s",
  1828. /* maker */ "falkTX",
  1829. /* copyright */ "GNU GPL v2+",
  1830. CarlaEngineNative::_instantiatePatchbay3s,
  1831. CarlaEngineNative::_cleanup,
  1832. CarlaEngineNative::_get_parameter_count,
  1833. CarlaEngineNative::_get_parameter_info,
  1834. CarlaEngineNative::_get_parameter_value,
  1835. CarlaEngineNative::_get_midi_program_count,
  1836. CarlaEngineNative::_get_midi_program_info,
  1837. CarlaEngineNative::_set_parameter_value,
  1838. CarlaEngineNative::_set_midi_program,
  1839. /* _set_custom_data */ nullptr,
  1840. CarlaEngineNative::_ui_show,
  1841. CarlaEngineNative::_ui_idle,
  1842. /* _ui_set_parameter_value */ nullptr,
  1843. /* _ui_set_midi_program */ nullptr,
  1844. /* _ui_set_custom_data */ nullptr,
  1845. CarlaEngineNative::_activate,
  1846. CarlaEngineNative::_deactivate,
  1847. CarlaEngineNative::_process,
  1848. CarlaEngineNative::_get_state,
  1849. CarlaEngineNative::_set_state,
  1850. CarlaEngineNative::_dispatcher
  1851. };
  1852. static const NativePluginDescriptor carlaPatchbay16Desc = {
  1853. /* category */ NATIVE_PLUGIN_CATEGORY_OTHER,
  1854. /* hints */ static_cast<NativePluginHints>(NATIVE_PLUGIN_IS_SYNTH
  1855. |NATIVE_PLUGIN_HAS_UI
  1856. |NATIVE_PLUGIN_NEEDS_UI_MAIN_THREAD
  1857. |NATIVE_PLUGIN_USES_STATE
  1858. |NATIVE_PLUGIN_USES_TIME),
  1859. /* supports */ static_cast<NativePluginSupports>(NATIVE_PLUGIN_SUPPORTS_EVERYTHING),
  1860. /* audioIns */ 16,
  1861. /* audioOuts */ 16,
  1862. /* midiIns */ 1,
  1863. /* midiOuts */ 1,
  1864. /* paramIns */ 0,
  1865. /* paramOuts */ 0,
  1866. /* name */ "Carla-Patchbay (16chan)",
  1867. /* label */ "carlapatchbay16",
  1868. /* maker */ "falkTX",
  1869. /* copyright */ "GNU GPL v2+",
  1870. CarlaEngineNative::_instantiatePatchbay16,
  1871. CarlaEngineNative::_cleanup,
  1872. CarlaEngineNative::_get_parameter_count,
  1873. CarlaEngineNative::_get_parameter_info,
  1874. CarlaEngineNative::_get_parameter_value,
  1875. CarlaEngineNative::_get_midi_program_count,
  1876. CarlaEngineNative::_get_midi_program_info,
  1877. CarlaEngineNative::_set_parameter_value,
  1878. CarlaEngineNative::_set_midi_program,
  1879. /* _set_custom_data */ nullptr,
  1880. CarlaEngineNative::_ui_show,
  1881. CarlaEngineNative::_ui_idle,
  1882. /* _ui_set_parameter_value */ nullptr,
  1883. /* _ui_set_midi_program */ nullptr,
  1884. /* _ui_set_custom_data */ nullptr,
  1885. CarlaEngineNative::_activate,
  1886. CarlaEngineNative::_deactivate,
  1887. CarlaEngineNative::_process,
  1888. CarlaEngineNative::_get_state,
  1889. CarlaEngineNative::_set_state,
  1890. CarlaEngineNative::_dispatcher
  1891. };
  1892. static const NativePluginDescriptor carlaPatchbay32Desc = {
  1893. /* category */ NATIVE_PLUGIN_CATEGORY_OTHER,
  1894. /* hints */ static_cast<NativePluginHints>(NATIVE_PLUGIN_IS_SYNTH
  1895. |NATIVE_PLUGIN_HAS_UI
  1896. |NATIVE_PLUGIN_NEEDS_UI_MAIN_THREAD
  1897. |NATIVE_PLUGIN_USES_STATE
  1898. |NATIVE_PLUGIN_USES_TIME),
  1899. /* supports */ static_cast<NativePluginSupports>(NATIVE_PLUGIN_SUPPORTS_EVERYTHING),
  1900. /* audioIns */ 32,
  1901. /* audioOuts */ 32,
  1902. /* midiIns */ 1,
  1903. /* midiOuts */ 1,
  1904. /* paramIns */ 0,
  1905. /* paramOuts */ 0,
  1906. /* name */ "Carla-Patchbay (32chan)",
  1907. /* label */ "carlapatchbay32",
  1908. /* maker */ "falkTX",
  1909. /* copyright */ "GNU GPL v2+",
  1910. CarlaEngineNative::_instantiatePatchbay32,
  1911. CarlaEngineNative::_cleanup,
  1912. CarlaEngineNative::_get_parameter_count,
  1913. CarlaEngineNative::_get_parameter_info,
  1914. CarlaEngineNative::_get_parameter_value,
  1915. CarlaEngineNative::_get_midi_program_count,
  1916. CarlaEngineNative::_get_midi_program_info,
  1917. CarlaEngineNative::_set_parameter_value,
  1918. CarlaEngineNative::_set_midi_program,
  1919. /* _set_custom_data */ nullptr,
  1920. CarlaEngineNative::_ui_show,
  1921. CarlaEngineNative::_ui_idle,
  1922. /* _ui_set_parameter_value */ nullptr,
  1923. /* _ui_set_midi_program */ nullptr,
  1924. /* _ui_set_custom_data */ nullptr,
  1925. CarlaEngineNative::_activate,
  1926. CarlaEngineNative::_deactivate,
  1927. CarlaEngineNative::_process,
  1928. CarlaEngineNative::_get_state,
  1929. CarlaEngineNative::_set_state,
  1930. CarlaEngineNative::_dispatcher
  1931. };
  1932. CARLA_BACKEND_END_NAMESPACE
  1933. // -----------------------------------------------------------------------
  1934. CARLA_EXPORT
  1935. void carla_register_native_plugin_carla();
  1936. void carla_register_native_plugin_carla()
  1937. {
  1938. CARLA_BACKEND_USE_NAMESPACE;
  1939. carla_register_native_plugin(&carlaRackDesc);
  1940. carla_register_native_plugin(&carlaRackNoMidiOutDesc);
  1941. carla_register_native_plugin(&carlaPatchbayDesc);
  1942. carla_register_native_plugin(&carlaPatchbay3sDesc);
  1943. carla_register_native_plugin(&carlaPatchbay16Desc);
  1944. carla_register_native_plugin(&carlaPatchbay32Desc);
  1945. }
  1946. // -----------------------------------------------------------------------
  1947. const NativePluginDescriptor* carla_get_native_rack_plugin()
  1948. {
  1949. CARLA_BACKEND_USE_NAMESPACE;
  1950. return &carlaRackDesc;
  1951. }
  1952. const NativePluginDescriptor* carla_get_native_patchbay_plugin()
  1953. {
  1954. CARLA_BACKEND_USE_NAMESPACE;
  1955. return &carlaPatchbayDesc;
  1956. }
  1957. const NativePluginDescriptor* carla_get_native_patchbay16_plugin()
  1958. {
  1959. CARLA_BACKEND_USE_NAMESPACE;
  1960. return &carlaPatchbay16Desc;
  1961. }
  1962. const NativePluginDescriptor* carla_get_native_patchbay32_plugin()
  1963. {
  1964. CARLA_BACKEND_USE_NAMESPACE;
  1965. return &carlaPatchbay32Desc;
  1966. }
  1967. // -----------------------------------------------------------------------
  1968. // Extra stuff for linking purposes
  1969. #ifdef CARLA_PLUGIN_EXPORT
  1970. CARLA_BACKEND_START_NAMESPACE
  1971. CarlaEngine* CarlaEngine::newJack() { return nullptr; }
  1972. # ifdef USING_JUCE
  1973. CarlaEngine* CarlaEngine::newJuce(const AudioApi) { return nullptr; }
  1974. uint CarlaEngine::getJuceApiCount() { return 0; }
  1975. const char* CarlaEngine::getJuceApiName(const uint) { return nullptr; }
  1976. const char* const* CarlaEngine::getJuceApiDeviceNames(const uint) { return nullptr; }
  1977. const EngineDriverDeviceInfo* CarlaEngine::getJuceDeviceInfo(const uint, const char* const) { return nullptr; }
  1978. # else
  1979. CarlaEngine* CarlaEngine::newRtAudio(const AudioApi) { return nullptr; }
  1980. uint CarlaEngine::getRtAudioApiCount() { return 0; }
  1981. const char* CarlaEngine::getRtAudioApiName(const uint) { return nullptr; }
  1982. const char* const* CarlaEngine::getRtAudioApiDeviceNames(const uint) { return nullptr; }
  1983. const EngineDriverDeviceInfo* CarlaEngine::getRtAudioDeviceInfo(const uint, const char* const) { return nullptr; }
  1984. # endif
  1985. CARLA_BACKEND_END_NAMESPACE
  1986. #define CARLA_PLUGIN_UI_CLASS_PREFIX EngineNative
  1987. #include "CarlaHostCommon.cpp"
  1988. #include "CarlaPluginUI.cpp"
  1989. #include "CarlaDssiUtils.cpp"
  1990. #include "CarlaMacUtils.cpp"
  1991. #include "CarlaPatchbayUtils.cpp"
  1992. #include "CarlaPipeUtils.cpp"
  1993. #include "CarlaStateUtils.cpp"
  1994. #endif
  1995. // -----------------------------------------------------------------------