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.

2221 lines
75KB

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