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.

1683 lines
55KB

  1. /*
  2. * Carla Plugin Host
  3. * Copyright (C) 2011-2014 Filipe Coelho <falktx@falktx.com>
  4. *
  5. * This program is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU General Public License as
  7. * published by the Free Software Foundation; either version 2 of
  8. * the License, or any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * For a full copy of the GNU General Public License see the doc/GPL.txt file.
  16. */
  17. #include "CarlaDefines.h"
  18. #ifdef BUILD_BRIDGE
  19. # error This file should not be compiled if building bridge
  20. #endif
  21. #ifdef CARLA_OS_WIN
  22. # error This file should not be compiled for Windows
  23. #endif
  24. #include "CarlaEngineInternal.hpp"
  25. #include "CarlaPlugin.hpp"
  26. #include "CarlaBackendUtils.hpp"
  27. #include "CarlaBinaryUtils.hpp"
  28. #include "CarlaMathUtils.hpp"
  29. #include "CarlaStateUtils.hpp"
  30. #include "CarlaExternalUI.hpp"
  31. #include "CarlaNative.hpp"
  32. #include "juce_audio_basics.h"
  33. using juce::FloatVectorOperations;
  34. using juce::MemoryOutputStream;
  35. using juce::ScopedPointer;
  36. using juce::String;
  37. using juce::XmlDocument;
  38. using juce::XmlElement;
  39. CARLA_BACKEND_START_NAMESPACE
  40. // -----------------------------------------------------------------------
  41. class CarlaEngineNativeUI : public CarlaExternalUI
  42. {
  43. public:
  44. CarlaEngineNativeUI(CarlaEngine* const engine)
  45. : fEngine(engine)
  46. {
  47. carla_debug("CarlaEngineNativeUI::CarlaEngineNativeUI(%p)", engine);
  48. }
  49. ~CarlaEngineNativeUI() override
  50. {
  51. carla_debug("CarlaEngineNativeUI::~CarlaEngineNativeUI()");
  52. }
  53. CarlaMutex& getWriteLock() noexcept
  54. {
  55. return fWriteLock;
  56. }
  57. protected:
  58. bool msgReceived(const char* const msg) noexcept override
  59. {
  60. if (CarlaExternalUI::msgReceived(msg))
  61. return true;
  62. bool ok = true;
  63. if (std::strcmp(msg, "set_engine_option") == 0)
  64. {
  65. uint32_t option;
  66. int32_t value;
  67. const char* valueStr;
  68. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(option), true);
  69. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(value), true);
  70. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(valueStr), true);
  71. try {
  72. fEngine->setOption(static_cast<EngineOption>(option), value, valueStr);
  73. } catch(...) {}
  74. delete[] valueStr;
  75. }
  76. else if (std::strcmp(msg, "load_file") == 0)
  77. {
  78. const char* filename;
  79. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  80. try {
  81. ok = fEngine->loadFile(filename);
  82. } catch(...) {}
  83. delete[] filename;
  84. }
  85. else if (std::strcmp(msg, "load_project") == 0)
  86. {
  87. const char* filename;
  88. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  89. try {
  90. ok = fEngine->loadProject(filename);
  91. } catch(...) {}
  92. delete[] filename;
  93. }
  94. else if (std::strcmp(msg, "save_project") == 0)
  95. {
  96. const char* filename;
  97. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  98. try {
  99. ok = fEngine->saveProject(filename);
  100. } catch(...) {}
  101. delete[] filename;
  102. }
  103. else if (std::strcmp(msg, "patchbay_connect") == 0)
  104. {
  105. uint32_t groupA, portA, groupB, portB;
  106. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(groupA), true);
  107. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(portA), true);
  108. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(groupB), true);
  109. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(portB), true);
  110. try {
  111. ok = fEngine->patchbayConnect(groupA, portA, groupB, portB);
  112. } catch(...) {}
  113. }
  114. else if (std::strcmp(msg, "patchbay_disconnect") == 0)
  115. {
  116. uint32_t connectionId;
  117. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(connectionId), true);
  118. try {
  119. ok = fEngine->patchbayDisconnect(connectionId);
  120. } catch(...) {}
  121. }
  122. else if (std::strcmp(msg, "patchbay_refresh") == 0)
  123. {
  124. try {
  125. ok = fEngine->patchbayRefresh();
  126. } catch(...) {}
  127. }
  128. else if (std::strcmp(msg, "transport_play") == 0)
  129. {
  130. fEngine->transportPlay();
  131. }
  132. else if (std::strcmp(msg, "transport_pause") == 0)
  133. {
  134. fEngine->transportPause();
  135. }
  136. else if (std::strcmp(msg, "transport_relocate") == 0)
  137. {
  138. uint64_t frame;
  139. CARLA_SAFE_ASSERT_RETURN(readNextLineAsULong(frame), true);
  140. fEngine->transportRelocate(frame);
  141. }
  142. else if (std::strcmp(msg, "add_plugin") == 0)
  143. {
  144. uint32_t btype, ptype;
  145. const char* filename = nullptr;
  146. const char* name;
  147. const char* label;
  148. int64_t uniqueId;
  149. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(btype), true);
  150. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(ptype), true);
  151. readNextLineAsString(filename); // can be null
  152. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(name), true);
  153. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(label), true);
  154. CARLA_SAFE_ASSERT_RETURN(readNextLineAsLong(uniqueId), true);
  155. if (filename != nullptr && std::strcmp(filename, "(null)") == 0)
  156. {
  157. delete[] filename;
  158. filename = nullptr;
  159. }
  160. if (std::strcmp(name, "(null)") == 0)
  161. {
  162. delete[] name;
  163. name = nullptr;
  164. }
  165. ok = fEngine->addPlugin(static_cast<BinaryType>(btype), static_cast<PluginType>(ptype), filename, name, label, uniqueId, nullptr);
  166. if (filename != nullptr)
  167. delete[] filename;
  168. if (name != nullptr)
  169. delete[] name;
  170. delete[] label;
  171. }
  172. else if (std::strcmp(msg, "remove_plugin") == 0)
  173. {
  174. uint32_t pluginId;
  175. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  176. ok = fEngine->removePlugin(pluginId);
  177. }
  178. else if (std::strcmp(msg, "remove_all_plugins") == 0)
  179. {
  180. ok = fEngine->removeAllPlugins();
  181. }
  182. else if (std::strcmp(msg, "rename_plugin") == 0)
  183. {
  184. uint32_t pluginId;
  185. const char* newName;
  186. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  187. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(newName), true);
  188. // TODO
  189. /*const char* name =*/ fEngine->renamePlugin(pluginId, newName);
  190. delete[] newName;
  191. }
  192. else if (std::strcmp(msg, "clone_plugin") == 0)
  193. {
  194. uint32_t pluginId;
  195. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  196. ok = fEngine->clonePlugin(pluginId);
  197. }
  198. else if (std::strcmp(msg, "replace_plugin") == 0)
  199. {
  200. uint32_t pluginId;
  201. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  202. ok = fEngine->replacePlugin(pluginId);
  203. }
  204. else if (std::strcmp(msg, "switch_plugins") == 0)
  205. {
  206. uint32_t pluginIdA, pluginIdB;
  207. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginIdA), true);
  208. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginIdB), true);
  209. ok = fEngine->switchPlugins(pluginIdA, pluginIdB);
  210. }
  211. else if (std::strcmp(msg, "load_plugin_state") == 0)
  212. {
  213. uint32_t pluginId;
  214. const char* filename;
  215. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  216. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  217. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  218. plugin->loadStateFromFile(filename);
  219. delete[] filename;
  220. }
  221. else if (std::strcmp(msg, "save_plugin_state") == 0)
  222. {
  223. uint32_t pluginId;
  224. const char* filename;
  225. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  226. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(filename), true);
  227. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  228. plugin->saveStateToFile(filename);
  229. delete[] filename;
  230. }
  231. else if (std::strcmp(msg, "set_option") == 0)
  232. {
  233. uint32_t pluginId, option;
  234. bool yesNo;
  235. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  236. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(option), true);
  237. CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(yesNo), true);
  238. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  239. plugin->setOption(option, yesNo, false);
  240. }
  241. else if (std::strcmp(msg, "set_active") == 0)
  242. {
  243. uint32_t pluginId;
  244. bool onOff;
  245. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  246. CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(onOff), true);
  247. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  248. plugin->setActive(onOff, true, false);
  249. }
  250. else if (std::strcmp(msg, "set_drywet") == 0)
  251. {
  252. uint32_t pluginId;
  253. float value;
  254. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  255. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  256. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  257. plugin->setDryWet(value, true, false);
  258. }
  259. else if (std::strcmp(msg, "set_volume") == 0)
  260. {
  261. uint32_t pluginId;
  262. float value;
  263. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  264. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  265. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  266. plugin->setVolume(value, true, false);
  267. }
  268. else if (std::strcmp(msg, "set_balance_left") == 0)
  269. {
  270. uint32_t pluginId;
  271. float value;
  272. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  273. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  274. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  275. plugin->setBalanceLeft(value, true, false);
  276. }
  277. else if (std::strcmp(msg, "set_balance_right") == 0)
  278. {
  279. uint32_t pluginId;
  280. float value;
  281. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  282. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  283. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  284. plugin->setBalanceRight(value, true, false);
  285. }
  286. else if (std::strcmp(msg, "set_panning") == 0)
  287. {
  288. uint32_t pluginId;
  289. float value;
  290. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  291. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  292. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  293. plugin->setPanning(value, true, false);
  294. }
  295. else if (std::strcmp(msg, "set_ctrl_channel") == 0)
  296. {
  297. uint32_t pluginId;
  298. int32_t channel;
  299. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  300. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(channel), true);
  301. CARLA_SAFE_ASSERT_RETURN(channel >= -1 && channel < MAX_MIDI_CHANNELS, true);
  302. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  303. plugin->setCtrlChannel(int8_t(channel), true, false);
  304. }
  305. else if (std::strcmp(msg, "set_parameter_value") == 0)
  306. {
  307. uint32_t pluginId, parameterId;
  308. float value;
  309. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  310. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);
  311. CARLA_SAFE_ASSERT_RETURN(readNextLineAsFloat(value), true);
  312. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  313. plugin->setParameterValue(parameterId, value, true, true, false);
  314. }
  315. else if (std::strcmp(msg, "set_parameter_midi_channel") == 0)
  316. {
  317. uint32_t pluginId, parameterId, channel;
  318. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  319. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);
  320. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(channel), true);
  321. CARLA_SAFE_ASSERT_RETURN(channel < MAX_MIDI_CHANNELS, true);
  322. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  323. plugin->setParameterMidiChannel(parameterId, static_cast<uint8_t>(channel), true, false);
  324. }
  325. else if (std::strcmp(msg, "set_parameter_midi_cc") == 0)
  326. {
  327. uint32_t pluginId, parameterId;
  328. int32_t cc;
  329. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  330. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(parameterId), true);
  331. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(cc), true);
  332. CARLA_SAFE_ASSERT_RETURN(cc >= -1 && cc < 0x5F, true);
  333. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  334. plugin->setParameterMidiCC(parameterId, static_cast<int16_t>(cc), true, false);
  335. }
  336. else if (std::strcmp(msg, "set_program") == 0)
  337. {
  338. uint32_t pluginId;
  339. int32_t index;
  340. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  341. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(index), true);
  342. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  343. plugin->setProgram(index, true, true, false);
  344. }
  345. else if (std::strcmp(msg, "set_midi_program") == 0)
  346. {
  347. uint32_t pluginId;
  348. int32_t index;
  349. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  350. CARLA_SAFE_ASSERT_RETURN(readNextLineAsInt(index), true);
  351. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  352. plugin->setMidiProgram(index, true, true, false);
  353. }
  354. else if (std::strcmp(msg, "set_custom_data") == 0)
  355. {
  356. uint32_t pluginId;
  357. const char* type;
  358. const char* key;
  359. const char* value;
  360. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  361. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(type), true);
  362. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(key), true);
  363. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(value), true);
  364. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  365. plugin->setCustomData(type, key, value, true);
  366. delete[] type;
  367. delete[] key;
  368. delete[] value;
  369. }
  370. else if (std::strcmp(msg, "set_chunk_data") == 0)
  371. {
  372. uint32_t pluginId;
  373. const char* cdata;
  374. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  375. CARLA_SAFE_ASSERT_RETURN(readNextLineAsString(cdata), true);
  376. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  377. plugin->setChunkData(cdata);
  378. delete[] cdata;
  379. }
  380. else if (std::strcmp(msg, "prepare_for_save") == 0)
  381. {
  382. uint32_t pluginId;
  383. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  384. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  385. plugin->prepareForSave();
  386. }
  387. else if (std::strcmp(msg, "reset_parameters") == 0)
  388. {
  389. uint32_t pluginId;
  390. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  391. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  392. plugin->resetParameters();
  393. }
  394. else if (std::strcmp(msg, "randomize_parameters") == 0)
  395. {
  396. uint32_t pluginId;
  397. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  398. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  399. plugin->randomizeParameters();
  400. }
  401. else if (std::strcmp(msg, "send_midi_note") == 0)
  402. {
  403. uint32_t pluginId, channel, note, velocity;
  404. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  405. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(channel), true);
  406. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(note), true);
  407. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(velocity), true);
  408. CARLA_SAFE_ASSERT_RETURN(channel < MAX_MIDI_CHANNELS, true);
  409. CARLA_SAFE_ASSERT_RETURN(note < MAX_MIDI_VALUE, true);
  410. CARLA_SAFE_ASSERT_RETURN(velocity < MAX_MIDI_VALUE, true);
  411. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  412. plugin->sendMidiSingleNote(static_cast<uint8_t>(channel), static_cast<uint8_t>(note), static_cast<uint8_t>(velocity), true, true, false);
  413. }
  414. else if (std::strcmp(msg, "show_custom_ui") == 0)
  415. {
  416. uint32_t pluginId;
  417. bool yesNo;
  418. CARLA_SAFE_ASSERT_RETURN(readNextLineAsUInt(pluginId), true);
  419. CARLA_SAFE_ASSERT_RETURN(readNextLineAsBool(yesNo), true);
  420. if (CarlaPlugin* const plugin = fEngine->getPlugin(pluginId))
  421. plugin->showCustomUI(yesNo);
  422. }
  423. else
  424. {
  425. carla_stderr("msgReceived : %s", msg);
  426. return false;
  427. }
  428. if (! ok)
  429. {
  430. const CarlaMutexLocker cml(fWriteLock);
  431. writeMsg("error\n", 6);
  432. writeAndFixMsg(fEngine->getLastError());
  433. }
  434. return true;
  435. }
  436. private:
  437. CarlaEngine* const fEngine;
  438. CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineNativeUI)
  439. };
  440. // -----------------------------------------------------------------------
  441. class CarlaEngineNative : public CarlaEngine
  442. {
  443. public:
  444. CarlaEngineNative(const NativeHostDescriptor* const host, const bool isPatchbay)
  445. : CarlaEngine(),
  446. pHost(host),
  447. fIsPatchbay(isPatchbay),
  448. fIsActive(false),
  449. fIsRunning(false),
  450. fUiServer(this)
  451. {
  452. carla_debug("CarlaEngineNative::CarlaEngineNative()");
  453. carla_zeroChar(fTmpBuf, STR_MAX+1);
  454. // set-up engine
  455. if (fIsPatchbay)
  456. {
  457. pData->options.processMode = ENGINE_PROCESS_MODE_PATCHBAY;
  458. pData->options.transportMode = ENGINE_TRANSPORT_MODE_PLUGIN;
  459. pData->options.forceStereo = false;
  460. pData->options.preferPluginBridges = false;
  461. pData->options.preferUiBridges = false;
  462. init("Carla-Patchbay");
  463. pData->graph.create(false, pData->sampleRate, pData->bufferSize, 2, 2);
  464. }
  465. else
  466. {
  467. pData->options.processMode = ENGINE_PROCESS_MODE_CONTINUOUS_RACK;
  468. pData->options.transportMode = ENGINE_TRANSPORT_MODE_PLUGIN;
  469. pData->options.forceStereo = true;
  470. pData->options.preferPluginBridges = false;
  471. pData->options.preferUiBridges = false;
  472. init("Carla-Rack");
  473. pData->graph.create(true, pData->sampleRate, pData->bufferSize, 0, 0);
  474. }
  475. if (pData->options.resourceDir != nullptr)
  476. delete[] pData->options.resourceDir;
  477. if (pData->options.binaryDir != nullptr)
  478. delete[] pData->options.binaryDir;
  479. pData->options.resourceDir = carla_strdup(pHost->resourceDir);
  480. pData->options.binaryDir = carla_strdup(pHost->resourceDir);
  481. setCallback(_ui_server_callback, this);
  482. }
  483. ~CarlaEngineNative() override
  484. {
  485. CARLA_SAFE_ASSERT(! fIsActive);
  486. carla_debug("CarlaEngineNative::~CarlaEngineNative() - START");
  487. pData->aboutToClose = true;
  488. fIsRunning = false;
  489. removeAllPlugins();
  490. runPendingRtEvents();
  491. close();
  492. pData->graph.destroy();
  493. carla_debug("CarlaEngineNative::~CarlaEngineNative() - END");
  494. }
  495. protected:
  496. // -------------------------------------
  497. // CarlaEngine virtual calls
  498. bool init(const char* const clientName) override
  499. {
  500. carla_debug("CarlaEngineNative::init(\"%s\")", clientName);
  501. pData->bufferSize = pHost->get_buffer_size(pHost->handle);
  502. pData->sampleRate = pHost->get_sample_rate(pHost->handle);
  503. fIsRunning = true;
  504. CarlaEngine::init(clientName);
  505. return true;
  506. }
  507. bool isRunning() const noexcept override
  508. {
  509. return fIsRunning;
  510. }
  511. bool isOffline() const noexcept override
  512. {
  513. return pHost->is_offline(pHost->handle);
  514. }
  515. EngineType getType() const noexcept override
  516. {
  517. return kEngineTypePlugin;
  518. }
  519. const char* getCurrentDriverName() const noexcept override
  520. {
  521. return "Plugin";
  522. }
  523. // -------------------------------------------------------------------
  524. const char* renamePlugin(const uint id, const char* const newName) override
  525. {
  526. if (const char* const retName = CarlaEngine::renamePlugin(id, newName))
  527. {
  528. uiServerCallback(ENGINE_CALLBACK_PLUGIN_RENAMED, id, 0, 0, 0.0f, retName);
  529. return retName;
  530. }
  531. return nullptr;
  532. }
  533. // -------------------------------------------------------------------
  534. void bufferSizeChanged(const uint32_t newBufferSize)
  535. {
  536. pData->bufferSize = newBufferSize;
  537. CarlaEngine::bufferSizeChanged(newBufferSize);
  538. }
  539. void sampleRateChanged(const double newSampleRate)
  540. {
  541. pData->sampleRate = newSampleRate;
  542. CarlaEngine::sampleRateChanged(newSampleRate);
  543. }
  544. // -------------------------------------------------------------------
  545. void uiServerSendPluginInfo(CarlaPlugin* const plugin)
  546. {
  547. const CarlaMutexLocker cml(fUiServer.getWriteLock());
  548. const uint pluginId(plugin->getId());
  549. std::sprintf(fTmpBuf, "PLUGIN_INFO_%i\n", pluginId);
  550. fUiServer.writeMsg(fTmpBuf);
  551. std::sprintf(fTmpBuf, "%i:%i:%i:" P_INT64 ":%i:%i\n", plugin->getType(), plugin->getCategory(), plugin->getHints(), plugin->getUniqueId(), plugin->getOptionsAvailable(), plugin->getOptionsEnabled());
  552. fUiServer.writeMsg(fTmpBuf);
  553. if (const char* const filename = plugin->getFilename())
  554. {
  555. std::sprintf(fTmpBuf, "%s", filename);
  556. fUiServer.writeAndFixMsg(fTmpBuf);
  557. }
  558. else
  559. fUiServer.writeMsg("\n");
  560. if (const char* const name = plugin->getName())
  561. {
  562. std::sprintf(fTmpBuf, "%s", name);
  563. fUiServer.writeAndFixMsg(fTmpBuf);
  564. }
  565. else
  566. fUiServer.writeMsg("\n");
  567. if (const char* const iconName = plugin->getIconName())
  568. {
  569. std::sprintf(fTmpBuf, "%s", iconName);
  570. fUiServer.writeAndFixMsg(fTmpBuf);
  571. }
  572. else
  573. fUiServer.writeMsg("\n");
  574. plugin->getRealName(fTmpBuf);
  575. fUiServer.writeAndFixMsg(fTmpBuf);
  576. plugin->getLabel(fTmpBuf);
  577. fUiServer.writeAndFixMsg(fTmpBuf);
  578. plugin->getMaker(fTmpBuf);
  579. fUiServer.writeAndFixMsg(fTmpBuf);
  580. plugin->getCopyright(fTmpBuf);
  581. fUiServer.writeAndFixMsg(fTmpBuf);
  582. std::sprintf(fTmpBuf, "AUDIO_COUNT_%i:%i:%i\n", pluginId, plugin->getAudioInCount(), plugin->getAudioOutCount());
  583. fUiServer.writeMsg(fTmpBuf);
  584. std::sprintf(fTmpBuf, "MIDI_COUNT_%i:%i:%i\n", pluginId, plugin->getMidiInCount(), plugin->getMidiOutCount());
  585. fUiServer.writeMsg(fTmpBuf);
  586. }
  587. void uiServerSendPluginParameters(CarlaPlugin* const plugin)
  588. {
  589. const CarlaMutexLocker cml(fUiServer.getWriteLock());
  590. const uint pluginId(plugin->getId());
  591. uint32_t ins, outs, count;
  592. plugin->getParameterCountInfo(ins, outs);
  593. count = plugin->getParameterCount();
  594. std::sprintf(fTmpBuf, "PARAMETER_COUNT_%i:%i:%i:%i\n", pluginId, ins, outs, count);
  595. fUiServer.writeMsg(fTmpBuf);
  596. for (uint32_t i=0; i<count; ++i)
  597. {
  598. const ParameterData& paramData(plugin->getParameterData(i));
  599. const ParameterRanges& paramRanges(plugin->getParameterRanges(i));
  600. std::sprintf(fTmpBuf, "PARAMETER_DATA_%i:%i\n", pluginId, i);
  601. fUiServer.writeMsg(fTmpBuf);
  602. std::sprintf(fTmpBuf, "%i:%i:%i:%i\n", paramData.type, paramData.hints, paramData.midiChannel, paramData.midiCC);
  603. fUiServer.writeMsg(fTmpBuf);
  604. plugin->getParameterName(i, fTmpBuf);
  605. fUiServer.writeAndFixMsg(fTmpBuf);
  606. plugin->getParameterUnit(i, fTmpBuf);
  607. fUiServer.writeAndFixMsg(fTmpBuf);
  608. std::sprintf(fTmpBuf, "PARAMETER_RANGES_%i:%i\n", pluginId, i);
  609. fUiServer.writeMsg(fTmpBuf);
  610. std::sprintf(fTmpBuf, "%f:%f:%f:%f:%f:%f\n", paramRanges.def, paramRanges.min, paramRanges.max, paramRanges.step, paramRanges.stepSmall, paramRanges.stepLarge);
  611. fUiServer.writeMsg(fTmpBuf);
  612. std::sprintf(fTmpBuf, "PARAMVAL_%i:%i\n", pluginId, i);
  613. fUiServer.writeMsg(fTmpBuf);
  614. std::sprintf(fTmpBuf, "%f\n", plugin->getParameterValue(i));
  615. fUiServer.writeMsg(fTmpBuf);
  616. }
  617. }
  618. void uiServerSendPluginPrograms(CarlaPlugin* const plugin)
  619. {
  620. const CarlaMutexLocker cml(fUiServer.getWriteLock());
  621. const uint pluginId(plugin->getId());
  622. uint32_t count = plugin->getProgramCount();
  623. std::sprintf(fTmpBuf, "PROGRAM_COUNT_%i:%i:%i\n", pluginId, count, plugin->getCurrentProgram());
  624. fUiServer.writeMsg(fTmpBuf);
  625. for (uint32_t i=0; i<count; ++i)
  626. {
  627. std::sprintf(fTmpBuf, "PROGRAM_NAME_%i:%i\n", pluginId, i);
  628. fUiServer.writeMsg(fTmpBuf);
  629. plugin->getProgramName(i, fTmpBuf);
  630. fUiServer.writeAndFixMsg(fTmpBuf);
  631. }
  632. count = plugin->getMidiProgramCount();
  633. std::sprintf(fTmpBuf, "MIDI_PROGRAM_COUNT_%i:%i:%i\n", pluginId, count, plugin->getCurrentMidiProgram());
  634. fUiServer.writeMsg(fTmpBuf);
  635. for (uint32_t i=0; i<count; ++i)
  636. {
  637. std::sprintf(fTmpBuf, "MIDI_PROGRAM_DATA_%i:%i\n", pluginId, i);
  638. fUiServer.writeMsg(fTmpBuf);
  639. const MidiProgramData& mpData(plugin->getMidiProgramData(i));
  640. std::sprintf(fTmpBuf, "%i:%i\n", mpData.bank, mpData.program);
  641. fUiServer.writeMsg(fTmpBuf);
  642. std::sprintf(fTmpBuf, "%s", mpData.name);
  643. fUiServer.writeAndFixMsg(fTmpBuf);
  644. }
  645. }
  646. void uiServerCallback(const EngineCallbackOpcode action, const uint pluginId, const int value1, const int value2, const float value3, const char* const valueStr)
  647. {
  648. if (! fIsRunning)
  649. return;
  650. if (! fUiServer.isOk())
  651. return;
  652. CarlaPlugin* plugin;
  653. switch (action)
  654. {
  655. case ENGINE_CALLBACK_RELOAD_INFO:
  656. plugin = getPlugin(pluginId);
  657. if (plugin != nullptr && plugin->isEnabled())
  658. {
  659. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  660. uiServerSendPluginInfo(plugin);
  661. }
  662. break;
  663. case ENGINE_CALLBACK_RELOAD_PARAMETERS:
  664. plugin = getPlugin(pluginId);
  665. if (plugin != nullptr && plugin->isEnabled())
  666. {
  667. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  668. uiServerSendPluginParameters(plugin);
  669. }
  670. break;
  671. case ENGINE_CALLBACK_RELOAD_PROGRAMS:
  672. plugin = getPlugin(pluginId);
  673. if (plugin != nullptr && plugin->isEnabled())
  674. {
  675. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  676. uiServerSendPluginPrograms(plugin);
  677. }
  678. break;
  679. case ENGINE_CALLBACK_RELOAD_ALL:
  680. case ENGINE_CALLBACK_PLUGIN_ADDED:
  681. plugin = getPlugin(pluginId);
  682. if (plugin != nullptr && plugin->isEnabled())
  683. {
  684. CARLA_SAFE_ASSERT_BREAK(plugin->getId() == pluginId);
  685. uiServerSendPluginInfo(plugin);
  686. uiServerSendPluginParameters(plugin);
  687. uiServerSendPluginPrograms(plugin);
  688. }
  689. break;
  690. default:
  691. break;
  692. }
  693. const CarlaMutexLocker cml(fUiServer.getWriteLock());
  694. std::sprintf(fTmpBuf, "ENGINE_CALLBACK_%i\n", int(action));
  695. fUiServer.writeMsg(fTmpBuf);
  696. std::sprintf(fTmpBuf, "%u\n", pluginId);
  697. fUiServer.writeMsg(fTmpBuf);
  698. std::sprintf(fTmpBuf, "%i\n", value1);
  699. fUiServer.writeMsg(fTmpBuf);
  700. std::sprintf(fTmpBuf, "%i\n", value2);
  701. fUiServer.writeMsg(fTmpBuf);
  702. std::sprintf(fTmpBuf, "%f\n", value3);
  703. fUiServer.writeMsg(fTmpBuf);
  704. fUiServer.writeAndFixMsg(valueStr);
  705. }
  706. // -------------------------------------------------------------------
  707. // Plugin parameter calls
  708. uint32_t getParameterCount() const
  709. {
  710. if (CarlaPlugin* const plugin = _getFirstPlugin())
  711. return plugin->getParameterCount();
  712. return 0;
  713. }
  714. const NativeParameter* getParameterInfo(const uint32_t index) const
  715. {
  716. if (CarlaPlugin* const plugin = _getFirstPlugin())
  717. {
  718. if (index < plugin->getParameterCount())
  719. {
  720. static NativeParameter param;
  721. static char strBufName[STR_MAX+1];
  722. static char strBufUnit[STR_MAX+1];
  723. const ParameterData& paramData(plugin->getParameterData(index));
  724. const ParameterRanges& paramRanges(plugin->getParameterRanges(index));
  725. plugin->getParameterName(index, strBufName);
  726. plugin->getParameterUnit(index, strBufUnit);
  727. uint hints = 0x0;
  728. if (paramData.hints & PARAMETER_IS_BOOLEAN)
  729. hints |= ::PARAMETER_IS_BOOLEAN;
  730. if (paramData.hints & PARAMETER_IS_INTEGER)
  731. hints |= ::PARAMETER_IS_INTEGER;
  732. if (paramData.hints & PARAMETER_IS_LOGARITHMIC)
  733. hints |= ::PARAMETER_IS_LOGARITHMIC;
  734. if (paramData.hints & PARAMETER_IS_AUTOMABLE)
  735. hints |= ::PARAMETER_IS_AUTOMABLE;
  736. if (paramData.hints & PARAMETER_USES_SAMPLERATE)
  737. hints |= ::PARAMETER_USES_SAMPLE_RATE;
  738. if (paramData.hints & PARAMETER_USES_SCALEPOINTS)
  739. hints |= ::PARAMETER_USES_SCALEPOINTS;
  740. if (paramData.hints & PARAMETER_USES_CUSTOM_TEXT)
  741. hints |= ::PARAMETER_USES_CUSTOM_TEXT;
  742. if (paramData.type == PARAMETER_INPUT || paramData.type == PARAMETER_OUTPUT)
  743. {
  744. if (paramData.hints & PARAMETER_IS_ENABLED)
  745. hints |= ::PARAMETER_IS_ENABLED;
  746. if (paramData.type == PARAMETER_OUTPUT)
  747. hints |= ::PARAMETER_IS_OUTPUT;
  748. }
  749. param.hints = static_cast<NativeParameterHints>(hints);
  750. param.name = strBufName;
  751. param.unit = strBufUnit;
  752. param.ranges.def = paramRanges.def;
  753. param.ranges.min = paramRanges.min;
  754. param.ranges.max = paramRanges.max;
  755. param.ranges.step = paramRanges.step;
  756. param.ranges.stepSmall = paramRanges.stepSmall;
  757. param.ranges.stepLarge = paramRanges.stepLarge;
  758. param.scalePointCount = 0; // TODO
  759. param.scalePoints = nullptr;
  760. return &param;
  761. }
  762. }
  763. return nullptr;
  764. }
  765. float getParameterValue(const uint32_t index) const
  766. {
  767. if (CarlaPlugin* const plugin = _getFirstPlugin())
  768. {
  769. if (index < plugin->getParameterCount())
  770. return plugin->getParameterValue(index);
  771. }
  772. return 0.0f;
  773. }
  774. const char* getParameterText(const uint32_t index /*, const float value*/) const
  775. {
  776. if (CarlaPlugin* const plugin = _getFirstPlugin())
  777. {
  778. if (index < plugin->getParameterCount())
  779. {
  780. static char strBuf[STR_MAX+1];
  781. carla_zeroChar(strBuf, STR_MAX+1);
  782. plugin->getParameterText(index, /*value,*/ strBuf);
  783. return strBuf;
  784. }
  785. }
  786. return nullptr;
  787. }
  788. // -------------------------------------------------------------------
  789. // Plugin midi-program calls
  790. uint32_t getMidiProgramCount() const
  791. {
  792. if (CarlaPlugin* const plugin = _getFirstPlugin())
  793. return plugin->getMidiProgramCount();
  794. return 0;
  795. }
  796. const NativeMidiProgram* getMidiProgramInfo(const uint32_t index) const
  797. {
  798. if (CarlaPlugin* const plugin = _getFirstPlugin())
  799. {
  800. if (index < plugin->getMidiProgramCount())
  801. {
  802. static NativeMidiProgram midiProg;
  803. {
  804. const MidiProgramData& midiProgData(plugin->getMidiProgramData(index));
  805. midiProg.bank = midiProgData.bank;
  806. midiProg.program = midiProgData.program;
  807. midiProg.name = midiProgData.name;
  808. }
  809. return &midiProg;
  810. }
  811. }
  812. return nullptr;
  813. }
  814. // -------------------------------------------------------------------
  815. // Plugin state calls
  816. void setParameterValue(const uint32_t index, const float value)
  817. {
  818. if (CarlaPlugin* const plugin = _getFirstPlugin())
  819. {
  820. if (index < plugin->getParameterCount())
  821. plugin->setParameterValue(index, value, false, false, false);
  822. }
  823. }
  824. void setMidiProgram(const uint8_t, const uint32_t bank, const uint32_t program)
  825. {
  826. if (CarlaPlugin* const plugin = _getFirstPlugin())
  827. plugin->setMidiProgramById(bank, program, false, false, false);
  828. }
  829. // -------------------------------------------------------------------
  830. // Plugin process calls
  831. void activate()
  832. {
  833. #if 0
  834. for (uint32_t i=0; i < pData->curPluginCount; ++i)
  835. {
  836. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  837. if (plugin == nullptr || ! plugin->isEnabled())
  838. continue;
  839. plugin->setActive(true, true, false);
  840. }
  841. #endif
  842. fIsActive = true;
  843. }
  844. void deactivate()
  845. {
  846. fIsActive = false;
  847. #if 0
  848. for (uint32_t i=0; i < pData->curPluginCount; ++i)
  849. {
  850. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  851. if (plugin == nullptr || ! plugin->isEnabled())
  852. continue;
  853. plugin->setActive(false, true, false);
  854. }
  855. #endif
  856. // just in case
  857. runPendingRtEvents();
  858. }
  859. void process(float** const inBuffer, float** const outBuffer, const uint32_t frames, const NativeMidiEvent* const midiEvents, const uint32_t midiEventCount)
  860. {
  861. if (pData->curPluginCount == 0 && ! fIsPatchbay)
  862. {
  863. FloatVectorOperations::copy(outBuffer[0], inBuffer[0], static_cast<int>(frames));
  864. FloatVectorOperations::copy(outBuffer[1], inBuffer[1], static_cast<int>(frames));
  865. return runPendingRtEvents();;
  866. }
  867. // ---------------------------------------------------------------
  868. // Time Info
  869. const NativeTimeInfo* const timeInfo(pHost->get_time_info(pHost->handle));
  870. pData->timeInfo.playing = timeInfo->playing;
  871. pData->timeInfo.frame = timeInfo->frame;
  872. pData->timeInfo.usecs = timeInfo->usecs;
  873. pData->timeInfo.valid = 0x0;
  874. if (timeInfo->bbt.valid)
  875. {
  876. pData->timeInfo.valid |= EngineTimeInfo::kValidBBT;
  877. pData->timeInfo.bbt.bar = timeInfo->bbt.bar;
  878. pData->timeInfo.bbt.beat = timeInfo->bbt.beat;
  879. pData->timeInfo.bbt.tick = timeInfo->bbt.tick;
  880. pData->timeInfo.bbt.barStartTick = timeInfo->bbt.barStartTick;
  881. pData->timeInfo.bbt.beatsPerBar = timeInfo->bbt.beatsPerBar;
  882. pData->timeInfo.bbt.beatType = timeInfo->bbt.beatType;
  883. pData->timeInfo.bbt.ticksPerBeat = timeInfo->bbt.ticksPerBeat;
  884. pData->timeInfo.bbt.beatsPerMinute = timeInfo->bbt.beatsPerMinute;
  885. }
  886. // ---------------------------------------------------------------
  887. // initialize events
  888. carla_zeroStruct<EngineEvent>(pData->events.in, kMaxEngineEventInternalCount);
  889. carla_zeroStruct<EngineEvent>(pData->events.out, kMaxEngineEventInternalCount);
  890. // ---------------------------------------------------------------
  891. // events input (before processing)
  892. {
  893. uint32_t engineEventIndex = 0;
  894. for (uint32_t i=0; i < midiEventCount && engineEventIndex < kMaxEngineEventInternalCount; ++i)
  895. {
  896. const NativeMidiEvent& midiEvent(midiEvents[i]);
  897. EngineEvent& engineEvent(pData->events.in[engineEventIndex++]);
  898. engineEvent.time = midiEvent.time;
  899. engineEvent.fillFromMidiData(midiEvent.size, midiEvent.data);
  900. if (engineEventIndex >= kMaxEngineEventInternalCount)
  901. break;
  902. }
  903. }
  904. if (fIsPatchbay)
  905. {
  906. // -----------------------------------------------------------
  907. // process
  908. pData->graph.process(pData, inBuffer, outBuffer, frames);
  909. }
  910. else
  911. {
  912. // -----------------------------------------------------------
  913. // create audio buffers
  914. const float* inBuf[2] = { inBuffer[0], inBuffer[1] };
  915. float* outBuf[2] = { outBuffer[0], outBuffer[1] };
  916. // -----------------------------------------------------------
  917. // process
  918. pData->graph.processRack(pData, inBuf, outBuf, frames);
  919. }
  920. // ---------------------------------------------------------------
  921. // events output (after processing)
  922. carla_zeroStruct<EngineEvent>(pData->events.in, kMaxEngineEventInternalCount);
  923. {
  924. NativeMidiEvent midiEvent;
  925. for (uint32_t i=0; i < kMaxEngineEventInternalCount; ++i)
  926. {
  927. const EngineEvent& engineEvent(pData->events.out[i]);
  928. if (engineEvent.type == kEngineEventTypeNull)
  929. break;
  930. midiEvent.time = engineEvent.time;
  931. if (engineEvent.type == CarlaBackend::kEngineEventTypeControl)
  932. {
  933. midiEvent.port = 0;
  934. engineEvent.ctrl.convertToMidiData(engineEvent.channel, midiEvent.size, midiEvent.data);
  935. }
  936. else if (engineEvent.type == kEngineEventTypeMidi)
  937. {
  938. if (engineEvent.midi.size > 4 || engineEvent.midi.dataExt != nullptr)
  939. continue;
  940. midiEvent.port = engineEvent.midi.port;
  941. midiEvent.size = engineEvent.midi.size;
  942. midiEvent.data[0] = static_cast<uint8_t>(engineEvent.midi.data[0] + engineEvent.channel);
  943. for (uint8_t j=1; j < midiEvent.size; ++j)
  944. midiEvent.data[j] = engineEvent.midi.data[j];
  945. }
  946. else
  947. {
  948. carla_stderr("Unknown event type...");
  949. continue;
  950. }
  951. pHost->write_midi_event(pHost->handle, &midiEvent);
  952. }
  953. }
  954. runPendingRtEvents();
  955. }
  956. // -------------------------------------------------------------------
  957. // Plugin UI calls
  958. void uiShow(const bool show)
  959. {
  960. if (show)
  961. {
  962. if (fUiServer.isOk())
  963. return;
  964. CarlaString path(pHost->resourceDir);
  965. path += "/carla-plugin";
  966. carla_stdout("Trying to start carla-plugin using \"%s\"", path.buffer());
  967. fUiServer.setData(path, pData->sampleRate, pHost->uiName);
  968. fUiServer.start();
  969. for (uint i=0; i < pData->curPluginCount; ++i)
  970. {
  971. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  972. if (plugin != nullptr && plugin->isEnabled())
  973. {
  974. uiServerCallback(ENGINE_CALLBACK_PLUGIN_ADDED, i, 0, 0, 0.0f, plugin->getName());
  975. }
  976. }
  977. }
  978. else
  979. {
  980. fUiServer.stop();
  981. }
  982. }
  983. void uiIdle()
  984. {
  985. CarlaEngine::idle();
  986. fUiServer.idle();
  987. if (! fUiServer.isOk())
  988. return;
  989. for (uint i=0; i < pData->curPluginCount; ++i)
  990. {
  991. const EnginePluginData& plugData(pData->plugins[i]);
  992. const CarlaPlugin* const plugin(pData->plugins[i].plugin);
  993. {
  994. const CarlaMutexLocker cml(fUiServer.getWriteLock());
  995. std::sprintf(fTmpBuf, "PEAKS_%i\n", i);
  996. fUiServer.writeMsg(fTmpBuf);
  997. std::sprintf(fTmpBuf, "%f:%f:%f:%f\n", plugData.insPeak[0], plugData.insPeak[1], plugData.outsPeak[0], plugData.outsPeak[1]);
  998. fUiServer.writeMsg(fTmpBuf);
  999. }
  1000. for (uint32_t j=0, count=plugin->getParameterCount(); j < count; ++j)
  1001. {
  1002. if (plugin->isParameterOutput(j))
  1003. continue;
  1004. const CarlaMutexLocker cml(fUiServer.getWriteLock());
  1005. std::sprintf(fTmpBuf, "PARAMVAL_%i:%i\n", i, j);
  1006. fUiServer.writeMsg(fTmpBuf);
  1007. std::sprintf(fTmpBuf, "%f\n", plugin->getParameterValue(j));
  1008. fUiServer.writeMsg(fTmpBuf);
  1009. }
  1010. }
  1011. switch (fUiServer.getAndResetUiState())
  1012. {
  1013. case CarlaExternalUI::UiNone:
  1014. case CarlaExternalUI::UiShow:
  1015. break;
  1016. case CarlaExternalUI::UiCrashed:
  1017. pHost->dispatcher(pHost->handle, HOST_OPCODE_UI_UNAVAILABLE, 0, 0, nullptr, 0.0f);
  1018. break;
  1019. case CarlaExternalUI::UiHide:
  1020. pHost->ui_closed(pHost->handle);
  1021. fUiServer.stop();
  1022. break;
  1023. }
  1024. }
  1025. // -------------------------------------------------------------------
  1026. // Plugin state calls
  1027. char* getState() const
  1028. {
  1029. MemoryOutputStream out;
  1030. out << "<?xml version='1.0' encoding='UTF-8'?>\n";
  1031. out << "<!DOCTYPE CARLA-PROJECT>\n";
  1032. out << "<CARLA-PROJECT VERSION='2.0'>\n";
  1033. bool firstPlugin = true;
  1034. char strBuf[STR_MAX+1];
  1035. for (uint i=0; i < pData->curPluginCount; ++i)
  1036. {
  1037. CarlaPlugin* const plugin(pData->plugins[i].plugin);
  1038. if (plugin != nullptr && plugin->isEnabled())
  1039. {
  1040. if (! firstPlugin)
  1041. out << "\n";
  1042. strBuf[0] = '\0';
  1043. plugin->getRealName(strBuf);
  1044. //if (strBuf[0] != '\0')
  1045. // out << QString(" <!-- %1 -->\n").arg(xmlSafeString(strBuf, true));
  1046. out << " <Plugin>\n";
  1047. out << plugin->getStateSave().toString();
  1048. out << " </Plugin>\n";
  1049. firstPlugin = false;
  1050. }
  1051. }
  1052. out << "</CARLA-PROJECT>\n";
  1053. return strdup(out.toString().toRawUTF8());
  1054. }
  1055. void setState(const char* const data)
  1056. {
  1057. const String text(data);
  1058. XmlDocument xml(text);
  1059. ScopedPointer<XmlElement> xmlElement(xml.getDocumentElement(true));
  1060. CARLA_SAFE_ASSERT_RETURN(xmlElement != nullptr,);
  1061. CARLA_SAFE_ASSERT_RETURN(xmlElement->getTagName().equalsIgnoreCase("carla-project"),);
  1062. // completely load file
  1063. xmlElement = xml.getDocumentElement(false);
  1064. CARLA_SAFE_ASSERT_RETURN(xmlElement != nullptr,);
  1065. //bool pluginsAdded = false;
  1066. for (XmlElement* elem = xmlElement->getFirstChildElement(); elem != nullptr; elem = elem->getNextElement())
  1067. {
  1068. const String& tagName(elem->getTagName());
  1069. if (tagName.equalsIgnoreCase("plugin"))
  1070. {
  1071. StateSave stateSave;
  1072. stateSave.fillFromXmlElement(elem);
  1073. CARLA_SAFE_ASSERT_CONTINUE(stateSave.type != nullptr);
  1074. const void* extraStuff = nullptr;
  1075. // check if using GIG or SF2 16outs
  1076. static const char kUse16OutsSuffix[] = " (16 outs)";
  1077. const BinaryType btype(getBinaryTypeFromFile(stateSave.binary));
  1078. const PluginType ptype(getPluginTypeFromString(stateSave.type));
  1079. if (CarlaString(stateSave.label).endsWith(kUse16OutsSuffix))
  1080. {
  1081. if (ptype == PLUGIN_GIG || ptype == PLUGIN_SF2)
  1082. extraStuff = "true";
  1083. }
  1084. // TODO - proper find&load plugins
  1085. if (addPlugin(btype, ptype, stateSave.binary, stateSave.name, stateSave.label, stateSave.uniqueId, extraStuff))
  1086. {
  1087. if (CarlaPlugin* const plugin = getPlugin(pData->curPluginCount-1))
  1088. plugin->loadStateSave(stateSave);
  1089. }
  1090. //pluginsAdded = true;
  1091. }
  1092. }
  1093. //if (pluginsAdded)
  1094. // pHost->dispatcher(pHost->handle, HOST_OPCODE_RELOAD_ALL, 0, 0, nullptr, 0.0f);
  1095. }
  1096. // -------------------------------------------------------------------
  1097. public:
  1098. #define handlePtr ((CarlaEngineNative*)handle)
  1099. static NativePluginHandle _instantiateRack(const NativeHostDescriptor* host)
  1100. {
  1101. return new CarlaEngineNative(host, false);
  1102. }
  1103. static NativePluginHandle _instantiatePatchbay(const NativeHostDescriptor* host)
  1104. {
  1105. return new CarlaEngineNative(host, true);
  1106. }
  1107. static void _cleanup(NativePluginHandle handle)
  1108. {
  1109. delete handlePtr;
  1110. }
  1111. static uint32_t _get_parameter_count(NativePluginHandle handle)
  1112. {
  1113. return handlePtr->getParameterCount();
  1114. }
  1115. static const NativeParameter* _get_parameter_info(NativePluginHandle handle, uint32_t index)
  1116. {
  1117. return handlePtr->getParameterInfo(index);
  1118. }
  1119. static float _get_parameter_value(NativePluginHandle handle, uint32_t index)
  1120. {
  1121. return handlePtr->getParameterValue(index);
  1122. }
  1123. static const char* _get_parameter_text(NativePluginHandle handle, uint32_t index /*, float value*/)
  1124. {
  1125. return handlePtr->getParameterText(index /*, value*/);
  1126. }
  1127. static uint32_t _get_midi_program_count(NativePluginHandle handle)
  1128. {
  1129. return handlePtr->getMidiProgramCount();
  1130. }
  1131. static const NativeMidiProgram* _get_midi_program_info(NativePluginHandle handle, uint32_t index)
  1132. {
  1133. return handlePtr->getMidiProgramInfo(index);
  1134. }
  1135. static void _set_parameter_value(NativePluginHandle handle, uint32_t index, float value)
  1136. {
  1137. handlePtr->setParameterValue(index, value);
  1138. }
  1139. static void _set_midi_program(NativePluginHandle handle, uint8_t channel, uint32_t bank, uint32_t program)
  1140. {
  1141. handlePtr->setMidiProgram(channel, bank, program);
  1142. }
  1143. static void _ui_show(NativePluginHandle handle, bool show)
  1144. {
  1145. handlePtr->uiShow(show);
  1146. }
  1147. static void _ui_idle(NativePluginHandle handle)
  1148. {
  1149. handlePtr->uiIdle();
  1150. }
  1151. static void _activate(NativePluginHandle handle)
  1152. {
  1153. handlePtr->activate();
  1154. }
  1155. static void _deactivate(NativePluginHandle handle)
  1156. {
  1157. handlePtr->deactivate();
  1158. }
  1159. static void _process(NativePluginHandle handle, float** inBuffer, float** outBuffer, const uint32_t frames, const NativeMidiEvent* midiEvents, uint32_t midiEventCount)
  1160. {
  1161. handlePtr->process(inBuffer, outBuffer, frames, midiEvents, midiEventCount);
  1162. }
  1163. static char* _get_state(NativePluginHandle handle)
  1164. {
  1165. return handlePtr->getState();
  1166. }
  1167. static void _set_state(NativePluginHandle handle, const char* data)
  1168. {
  1169. handlePtr->setState(data);
  1170. }
  1171. static intptr_t _dispatcher(NativePluginHandle handle, NativePluginDispatcherOpcode opcode, int32_t index, intptr_t value, void* ptr, float opt)
  1172. {
  1173. switch(opcode)
  1174. {
  1175. case PLUGIN_OPCODE_NULL:
  1176. return 0;
  1177. case PLUGIN_OPCODE_BUFFER_SIZE_CHANGED:
  1178. CARLA_SAFE_ASSERT_RETURN(value > 0, 0);
  1179. handlePtr->bufferSizeChanged(static_cast<uint32_t>(value));
  1180. return 0;
  1181. case PLUGIN_OPCODE_SAMPLE_RATE_CHANGED:
  1182. CARLA_SAFE_ASSERT_RETURN(opt > 0.0, 0);
  1183. handlePtr->sampleRateChanged(static_cast<double>(opt));
  1184. return 0;
  1185. case PLUGIN_OPCODE_OFFLINE_CHANGED:
  1186. handlePtr->offlineModeChanged(value != 0);
  1187. return 0;
  1188. case PLUGIN_OPCODE_UI_NAME_CHANGED:
  1189. //handlePtr->uiNameChanged(static_cast<const char*>(ptr));
  1190. return 0;
  1191. }
  1192. return 0;
  1193. // unused
  1194. (void)index;
  1195. (void)ptr;
  1196. }
  1197. // -------------------------------------------------------------------
  1198. static void _ui_server_callback(void* handle, EngineCallbackOpcode action, uint pluginId, int value1, int value2, float value3, const char* valueStr)
  1199. {
  1200. handlePtr->uiServerCallback(action, pluginId, value1, value2, value3, valueStr);
  1201. }
  1202. // -------------------------------------------------------------------
  1203. #undef handlePtr
  1204. private:
  1205. const NativeHostDescriptor* const pHost;
  1206. const bool fIsPatchbay; // rack if false
  1207. bool fIsActive, fIsRunning;
  1208. CarlaEngineNativeUI fUiServer;
  1209. char fTmpBuf[STR_MAX+1];
  1210. CarlaPlugin* _getFirstPlugin() const noexcept
  1211. {
  1212. if (pData->curPluginCount == 0 || pData->plugins == nullptr)
  1213. return nullptr;
  1214. CarlaPlugin* const plugin(pData->plugins[0].plugin);
  1215. if (plugin == nullptr || ! plugin->isEnabled())
  1216. return nullptr;
  1217. return pData->plugins[0].plugin;
  1218. }
  1219. CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineNative)
  1220. };
  1221. // -----------------------------------------------------------------------
  1222. static const NativePluginDescriptor carlaRackDesc = {
  1223. /* category */ ::PLUGIN_CATEGORY_OTHER,
  1224. /* hints */ static_cast<NativePluginHints>(::PLUGIN_IS_SYNTH|::PLUGIN_HAS_UI|::PLUGIN_NEEDS_FIXED_BUFFERS|::PLUGIN_NEEDS_SINGLE_THREAD|::PLUGIN_USES_STATE|::PLUGIN_USES_TIME),
  1225. /* supports */ static_cast<NativePluginSupports>(::PLUGIN_SUPPORTS_EVERYTHING),
  1226. /* audioIns */ 2,
  1227. /* audioOuts */ 2,
  1228. /* midiIns */ 1,
  1229. /* midiOuts */ 1,
  1230. /* paramIns */ 0,
  1231. /* paramOuts */ 0,
  1232. /* name */ "Carla-Rack",
  1233. /* label */ "carlarack",
  1234. /* maker */ "falkTX",
  1235. /* copyright */ "GNU GPL v2+",
  1236. CarlaEngineNative::_instantiateRack,
  1237. CarlaEngineNative::_cleanup,
  1238. CarlaEngineNative::_get_parameter_count,
  1239. CarlaEngineNative::_get_parameter_info,
  1240. CarlaEngineNative::_get_parameter_value,
  1241. CarlaEngineNative::_get_parameter_text,
  1242. CarlaEngineNative::_get_midi_program_count,
  1243. CarlaEngineNative::_get_midi_program_info,
  1244. CarlaEngineNative::_set_parameter_value,
  1245. CarlaEngineNative::_set_midi_program,
  1246. /* _set_custom_data */ nullptr,
  1247. CarlaEngineNative::_ui_show,
  1248. CarlaEngineNative::_ui_idle,
  1249. /* _ui_set_parameter_value */ nullptr,
  1250. /* _ui_set_midi_program */ nullptr,
  1251. /* _ui_set_custom_data */ nullptr,
  1252. CarlaEngineNative::_activate,
  1253. CarlaEngineNative::_deactivate,
  1254. CarlaEngineNative::_process,
  1255. CarlaEngineNative::_get_state,
  1256. CarlaEngineNative::_set_state,
  1257. CarlaEngineNative::_dispatcher
  1258. };
  1259. #if 0
  1260. static const NativePluginDescriptor carlaPatchbayDesc = {
  1261. /* category */ ::PLUGIN_CATEGORY_OTHER,
  1262. /* hints */ static_cast<NativePluginHints>(::PLUGIN_IS_SYNTH|::PLUGIN_HAS_UI|::PLUGIN_NEEDS_FIXED_BUFFERS|::PLUGIN_NEEDS_SINGLE_THREAD|::PLUGIN_USES_STATE|::PLUGIN_USES_TIME),
  1263. /* supports */ static_cast<NativePluginSupports>(::PLUGIN_SUPPORTS_EVERYTHING),
  1264. /* audioIns */ 2,
  1265. /* audioOuts */ 2,
  1266. /* midiIns */ 1,
  1267. /* midiOuts */ 1,
  1268. /* paramIns */ 0,
  1269. /* paramOuts */ 0,
  1270. /* name */ "Carla-Patchbay",
  1271. /* label */ "carlapatchbay",
  1272. /* maker */ "falkTX",
  1273. /* copyright */ "GNU GPL v2+",
  1274. CarlaEngineNative::_instantiatePatchbay,
  1275. CarlaEngineNative::_cleanup,
  1276. CarlaEngineNative::_get_parameter_count,
  1277. CarlaEngineNative::_get_parameter_info,
  1278. CarlaEngineNative::_get_parameter_value,
  1279. CarlaEngineNative::_get_parameter_text,
  1280. CarlaEngineNative::_get_midi_program_count,
  1281. CarlaEngineNative::_get_midi_program_info,
  1282. CarlaEngineNative::_set_parameter_value,
  1283. CarlaEngineNative::_set_midi_program,
  1284. /* _set_custom_data */ nullptr,
  1285. CarlaEngineNative::_ui_show,
  1286. CarlaEngineNative::_ui_idle,
  1287. /* _ui_set_parameter_value */ nullptr,
  1288. /* _ui_set_midi_program */ nullptr,
  1289. /* _ui_set_custom_data */ nullptr,
  1290. CarlaEngineNative::_activate,
  1291. CarlaEngineNative::_deactivate,
  1292. CarlaEngineNative::_process,
  1293. CarlaEngineNative::_get_state,
  1294. CarlaEngineNative::_set_state,
  1295. CarlaEngineNative::_dispatcher
  1296. };
  1297. #endif
  1298. CARLA_BACKEND_END_NAMESPACE
  1299. // -----------------------------------------------------------------------
  1300. CARLA_EXPORT
  1301. void carla_register_native_plugin_carla();
  1302. void carla_register_native_plugin_carla()
  1303. {
  1304. CARLA_BACKEND_USE_NAMESPACE;
  1305. carla_register_native_plugin(&carlaRackDesc);
  1306. #if 0
  1307. carla_register_native_plugin(&carlaPatchbayDesc);
  1308. #endif
  1309. }
  1310. // -----------------------------------------------------------------------
  1311. CARLA_EXPORT
  1312. const NativePluginDescriptor* get_carla_native_plugin();
  1313. const NativePluginDescriptor* get_carla_native_plugin()
  1314. {
  1315. CARLA_BACKEND_USE_NAMESPACE;
  1316. return &carlaRackDesc;
  1317. }
  1318. // -----------------------------------------------------------------------
  1319. // Extra stuff for linking purposes
  1320. #ifdef CARLA_PLUGIN_EXPORT
  1321. CARLA_BACKEND_START_NAMESPACE
  1322. CarlaEngine* CarlaEngine::newJack() { return nullptr; }
  1323. # if defined(CARLA_OS_MAC) || defined(CARLA_OS_WIN)
  1324. CarlaEngine* CarlaEngine::newJuce(const AudioApi) { return nullptr; }
  1325. uint CarlaEngine::getJuceApiCount() { return 0; }
  1326. const char* CarlaEngine::getJuceApiName(const uint) { return nullptr; }
  1327. const char* const* CarlaEngine::getJuceApiDeviceNames(const uint) { return nullptr; }
  1328. const EngineDriverDeviceInfo* CarlaEngine::getJuceDeviceInfo(const uint, const char* const) { return nullptr; }
  1329. # else
  1330. CarlaEngine* CarlaEngine::newRtAudio(const AudioApi) { return nullptr; }
  1331. uint CarlaEngine::getRtAudioApiCount() { return 0; }
  1332. const char* CarlaEngine::getRtAudioApiName(const uint) { return nullptr; }
  1333. const char* const* CarlaEngine::getRtAudioApiDeviceNames(const uint) { return nullptr; }
  1334. const EngineDriverDeviceInfo* CarlaEngine::getRtAudioDeviceInfo(const uint, const char* const) { return nullptr; }
  1335. # endif
  1336. CARLA_BACKEND_END_NAMESPACE
  1337. #include "CarlaPluginUI.cpp"
  1338. #include "CarlaDssiUtils.cpp"
  1339. #include "CarlaStateUtils.cpp"
  1340. #endif
  1341. // -----------------------------------------------------------------------