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.

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