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.

1790 lines
59KB

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