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.

2338 lines
78KB

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