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.

1978 lines
69KB

  1. /*
  2. * Carla DSSI Plugin
  3. * Copyright (C) 2011-2013 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 GPL.txt file
  16. */
  17. #include "CarlaPluginInternal.hpp"
  18. #ifdef WANT_DSSI
  19. #include "CarlaLadspaUtils.hpp"
  20. #include "dssi/dssi.h"
  21. CARLA_BACKEND_START_NAMESPACE
  22. #if 0
  23. }
  24. #endif
  25. class DssiPlugin : public CarlaPlugin
  26. {
  27. public:
  28. DssiPlugin(CarlaEngine* const engine, const unsigned int id)
  29. : CarlaPlugin(engine, id),
  30. fHandle(nullptr),
  31. fHandle2(nullptr),
  32. fDescriptor(nullptr),
  33. fDssiDescriptor(nullptr),
  34. fAudioInBuffers(nullptr),
  35. fAudioOutBuffers(nullptr),
  36. fParamBuffers(nullptr)
  37. {
  38. carla_debug("DssiPlugin::DssiPlugin(%p, %i)", engine, id);
  39. carla_zeroStruct<snd_seq_event_t>(fMidiEvents, MAX_MIDI_EVENTS);
  40. kData->osc.thread.setMode(CarlaPluginThread::PLUGIN_THREAD_DSSI_GUI);
  41. }
  42. ~DssiPlugin() override
  43. {
  44. carla_debug("DssiPlugin::~DssiPlugin()");
  45. // close UI
  46. if (fHints & PLUGIN_HAS_GUI)
  47. {
  48. showGui(false);
  49. // Wait a bit first, then force kill
  50. if (kData->osc.thread.isRunning() && ! kData->osc.thread.wait(kData->engine->getOptions().oscUiTimeout))
  51. {
  52. carla_stderr("DSSI GUI thread still running, forcing termination now");
  53. kData->osc.thread.terminate();
  54. }
  55. }
  56. kData->singleMutex.lock();
  57. kData->masterMutex.lock();
  58. if (kData->active)
  59. {
  60. deactivate();
  61. kData->active = false;
  62. }
  63. if (fDescriptor != nullptr)
  64. {
  65. if (fDescriptor->cleanup != nullptr)
  66. {
  67. if (fHandle != nullptr)
  68. fDescriptor->cleanup(fHandle);
  69. if (fHandle2 != nullptr)
  70. fDescriptor->cleanup(fHandle2);
  71. }
  72. fHandle = nullptr;
  73. fHandle2 = nullptr;
  74. fDescriptor = nullptr;
  75. fDssiDescriptor = nullptr;
  76. }
  77. clearBuffers();
  78. }
  79. // -------------------------------------------------------------------
  80. // Information (base)
  81. PluginType type() const override
  82. {
  83. return PLUGIN_DSSI;
  84. }
  85. PluginCategory category() override
  86. {
  87. if (fHints & PLUGIN_IS_SYNTH)
  88. return PLUGIN_CATEGORY_SYNTH;
  89. return getPluginCategoryFromName(fName);
  90. }
  91. long uniqueId() const override
  92. {
  93. CARLA_ASSERT(fDescriptor != nullptr);
  94. return fDescriptor->UniqueID;
  95. }
  96. // -------------------------------------------------------------------
  97. // Information (count)
  98. // nothing
  99. // -------------------------------------------------------------------
  100. // Information (current data)
  101. int32_t chunkData(void** const dataPtr) override
  102. {
  103. CARLA_ASSERT(fOptions & PLUGIN_OPTION_USE_CHUNKS);
  104. CARLA_ASSERT(fDssiDescriptor != nullptr);
  105. CARLA_ASSERT(fDssiDescriptor->get_custom_data != nullptr);
  106. CARLA_ASSERT(fHandle != nullptr);
  107. CARLA_ASSERT(fHandle2 == nullptr);
  108. CARLA_ASSERT(dataPtr != nullptr);
  109. unsigned long dataSize = 0;
  110. if (fDssiDescriptor->get_custom_data != nullptr && fDssiDescriptor->get_custom_data(fHandle, dataPtr, &dataSize) != 0)
  111. return static_cast<int32_t>(dataSize);
  112. return 0;
  113. }
  114. // -------------------------------------------------------------------
  115. // Information (per-plugin data)
  116. unsigned int availableOptions() override
  117. {
  118. CARLA_ASSERT(fDssiDescriptor != nullptr);
  119. if (fDssiDescriptor == nullptr)
  120. return 0x0;
  121. #ifdef __USE_GNU
  122. const bool isDssiVst = fFilename.contains("dssi-vst", true);
  123. #else
  124. const bool isDssiVst = fFilename.contains("dssi-vst");
  125. #endif
  126. unsigned int options = 0x0;
  127. options |= PLUGIN_OPTION_MAP_PROGRAM_CHANGES;
  128. if (isDssiVst)
  129. {
  130. if (kData->engine->getOptions().useDssiVstChunks && fDssiDescriptor->get_custom_data != nullptr && fDssiDescriptor->set_custom_data != nullptr)
  131. options |= PLUGIN_OPTION_USE_CHUNKS;
  132. }
  133. else
  134. {
  135. if (kData->engine->getProccessMode() != PROCESS_MODE_CONTINUOUS_RACK)
  136. {
  137. if (fOptions & PLUGIN_OPTION_FORCE_STEREO)
  138. options |= PLUGIN_OPTION_FORCE_STEREO;
  139. else if (kData->audioIn.count <= 1 && kData->audioOut.count <= 1 && (kData->audioIn.count != 0 || kData->audioOut.count != 0))
  140. options |= PLUGIN_OPTION_FORCE_STEREO;
  141. }
  142. options |= PLUGIN_OPTION_FIXED_BUFFER;
  143. }
  144. if (fDssiDescriptor->run_synth != nullptr || fDssiDescriptor->run_multiple_synths != nullptr)
  145. {
  146. options |= PLUGIN_OPTION_SEND_CONTROL_CHANGES;
  147. options |= PLUGIN_OPTION_SEND_CHANNEL_PRESSURE;
  148. options |= PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH;
  149. options |= PLUGIN_OPTION_SEND_PITCHBEND;
  150. options |= PLUGIN_OPTION_SEND_ALL_SOUND_OFF;
  151. }
  152. return options;
  153. }
  154. float getParameterValue(const uint32_t parameterId) override
  155. {
  156. CARLA_ASSERT(fParamBuffers != nullptr);
  157. CARLA_ASSERT(parameterId < kData->param.count);
  158. return fParamBuffers[parameterId];
  159. }
  160. void getLabel(char* const strBuf) override
  161. {
  162. CARLA_ASSERT(fDescriptor != nullptr);
  163. if (fDescriptor->Label != nullptr)
  164. std::strncpy(strBuf, fDescriptor->Label, STR_MAX);
  165. else
  166. CarlaPlugin::getLabel(strBuf);
  167. }
  168. void getMaker(char* const strBuf) override
  169. {
  170. CARLA_ASSERT(fDescriptor != nullptr);
  171. if (fDescriptor->Maker != nullptr)
  172. std::strncpy(strBuf, fDescriptor->Maker, STR_MAX);
  173. else
  174. CarlaPlugin::getMaker(strBuf);
  175. }
  176. void getCopyright(char* const strBuf) override
  177. {
  178. CARLA_ASSERT(fDescriptor != nullptr);
  179. if (fDescriptor->Copyright != nullptr)
  180. std::strncpy(strBuf, fDescriptor->Copyright, STR_MAX);
  181. else
  182. CarlaPlugin::getCopyright(strBuf);
  183. }
  184. void getRealName(char* const strBuf) override
  185. {
  186. CARLA_ASSERT(fDescriptor != nullptr);
  187. if (fDescriptor->Name != nullptr)
  188. std::strncpy(strBuf, fDescriptor->Name, STR_MAX);
  189. else
  190. CarlaPlugin::getRealName(strBuf);
  191. }
  192. void getParameterName(const uint32_t parameterId, char* const strBuf) override
  193. {
  194. CARLA_ASSERT(fDescriptor != nullptr);
  195. CARLA_ASSERT(parameterId < kData->param.count);
  196. const int32_t rindex(kData->param.data[parameterId].rindex);
  197. if (rindex < static_cast<int32_t>(fDescriptor->PortCount))
  198. std::strncpy(strBuf, fDescriptor->PortNames[rindex], STR_MAX);
  199. else
  200. CarlaPlugin::getParameterName(parameterId, strBuf);
  201. }
  202. // -------------------------------------------------------------------
  203. // Set data (state)
  204. // nothing
  205. // -------------------------------------------------------------------
  206. // Set data (internal stuff)
  207. // nothing
  208. // -------------------------------------------------------------------
  209. // Set data (plugin-specific stuff)
  210. void setParameterValue(const uint32_t parameterId, const float value, const bool sendGui, const bool sendOsc, const bool sendCallback) override
  211. {
  212. CARLA_ASSERT(parameterId < kData->param.count);
  213. const float fixedValue(kData->param.fixValue(parameterId, value));
  214. fParamBuffers[parameterId] = fixedValue;
  215. CarlaPlugin::setParameterValue(parameterId, fixedValue, sendGui, sendOsc, sendCallback);
  216. }
  217. void setCustomData(const char* const type, const char* const key, const char* const value, const bool sendGui) override
  218. {
  219. CARLA_ASSERT(fDescriptor != nullptr);
  220. CARLA_ASSERT(fHandle != nullptr);
  221. CARLA_ASSERT(type != nullptr);
  222. CARLA_ASSERT(key != nullptr);
  223. CARLA_ASSERT(value != nullptr);
  224. carla_debug("DssiPlugin::setCustomData(%s, %s, %s, %s)", type, key, value, bool2str(sendGui));
  225. if (type == nullptr)
  226. return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - type is invalid", type, key, value, bool2str(sendGui));
  227. if (std::strcmp(type, CUSTOM_DATA_STRING) != 0)
  228. return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - type is not string", type, key, value, bool2str(sendGui));
  229. if (key == nullptr)
  230. return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - key is null", type, key, value, bool2str(sendGui));
  231. if (value == nullptr)
  232. return carla_stderr2("DssiPlugin::setCustomData(\"%s\", \"%s\", \"%s\", %s) - value is null", type, key, value, bool2str(sendGui));
  233. if (fDssiDescriptor->configure != nullptr)
  234. {
  235. fDssiDescriptor->configure(fHandle, key, value);
  236. if (fHandle2)
  237. fDssiDescriptor->configure(fHandle2, key, value);
  238. }
  239. if (sendGui && kData->osc.data.target != nullptr)
  240. osc_send_configure(&kData->osc.data, key, value);
  241. if (std::strcmp(key, "reloadprograms") == 0 || std::strcmp(key, "load") == 0 || std::strncmp(key, "patches", 7) == 0)
  242. {
  243. const ScopedDisabler sd(this);
  244. reloadPrograms(false);
  245. }
  246. CarlaPlugin::setCustomData(type, key, value, sendGui);
  247. }
  248. void setChunkData(const char* const stringData) override
  249. {
  250. CARLA_ASSERT(fOptions & PLUGIN_OPTION_USE_CHUNKS);
  251. CARLA_ASSERT(fDssiDescriptor != nullptr);
  252. CARLA_ASSERT(fDssiDescriptor->set_custom_data != nullptr);
  253. CARLA_ASSERT(fHandle != nullptr);
  254. CARLA_ASSERT(fHandle2 == nullptr);
  255. CARLA_ASSERT(stringData != nullptr);
  256. if (fDssiDescriptor->set_custom_data == nullptr)
  257. return;
  258. QByteArray chunk(QByteArray::fromBase64(stringData));
  259. CARLA_ASSERT(chunk.size() > 0);
  260. if (chunk.size() > 0)
  261. {
  262. const ScopedSingleProcessLocker spl(this, true);
  263. fDssiDescriptor->set_custom_data(fHandle, chunk.data(), chunk.size());
  264. }
  265. }
  266. void setMidiProgram(int32_t index, const bool sendGui, const bool sendOsc, const bool sendCallback) override
  267. {
  268. CARLA_ASSERT(fDssiDescriptor != nullptr);
  269. CARLA_ASSERT(fHandle != nullptr);
  270. CARLA_ASSERT(index >= -1 && index < static_cast<int32_t>(kData->midiprog.count));
  271. if (index < -1)
  272. index = -1;
  273. else if (index > static_cast<int32_t>(kData->midiprog.count))
  274. return;
  275. if (index >= 0 && fDssiDescriptor != nullptr && fDssiDescriptor->select_program != nullptr)
  276. {
  277. const uint32_t bank = kData->midiprog.data[index].bank;
  278. const uint32_t program = kData->midiprog.data[index].program;
  279. const ScopedSingleProcessLocker spl(this, (sendGui || sendOsc || sendCallback));
  280. fDssiDescriptor->select_program(fHandle, bank, program);
  281. if (fHandle2 != nullptr)
  282. fDssiDescriptor->select_program(fHandle2, bank, program);
  283. }
  284. CarlaPlugin::setMidiProgram(index, sendGui, sendOsc, sendCallback);
  285. }
  286. // -------------------------------------------------------------------
  287. // Set gui stuff
  288. void showGui(const bool yesNo) override
  289. {
  290. if (yesNo)
  291. {
  292. kData->osc.thread.start();
  293. }
  294. else
  295. {
  296. if (kData->osc.data.target != nullptr)
  297. {
  298. osc_send_hide(&kData->osc.data);
  299. osc_send_quit(&kData->osc.data);
  300. kData->osc.data.free();
  301. }
  302. if (kData->osc.thread.isRunning() && ! kData->osc.thread.wait(kData->engine->getOptions().oscUiTimeout))
  303. kData->osc.thread.terminate();
  304. }
  305. }
  306. // -------------------------------------------------------------------
  307. // Plugin state
  308. void reload() override
  309. {
  310. carla_debug("DssiPlugin::reload() - start");
  311. CARLA_ASSERT(kData->engine != nullptr);
  312. CARLA_ASSERT(fDescriptor != nullptr);
  313. CARLA_ASSERT(fDssiDescriptor != nullptr);
  314. CARLA_ASSERT(fHandle != nullptr);
  315. if (kData->engine == nullptr)
  316. return;
  317. if (fDescriptor == nullptr)
  318. return;
  319. if (fDssiDescriptor == nullptr)
  320. return;
  321. if (fHandle == nullptr)
  322. return;
  323. const ProcessMode processMode(kData->engine->getProccessMode());
  324. // Safely disable plugin for reload
  325. const ScopedDisabler sd(this);
  326. if (kData->active)
  327. deactivate();
  328. clearBuffers();
  329. const float sampleRate = (float)kData->engine->getSampleRate();
  330. const uint32_t portCount = static_cast<uint32_t>(fDescriptor->PortCount);
  331. uint32_t aIns, aOuts, mIns, params, j;
  332. aIns = aOuts = mIns = params = 0;
  333. bool forcedStereoIn, forcedStereoOut;
  334. forcedStereoIn = forcedStereoOut = false;
  335. bool needsCtrlIn, needsCtrlOut;
  336. needsCtrlIn = needsCtrlOut = false;
  337. if (portCount > 0)
  338. {
  339. CARLA_ASSERT(fDescriptor->PortDescriptors != nullptr);
  340. CARLA_ASSERT(fDescriptor->PortRangeHints != nullptr);
  341. CARLA_ASSERT(fDescriptor->PortNames != nullptr);
  342. for (uint32_t i=0; i < portCount; ++i)
  343. {
  344. const LADSPA_PortDescriptor portType = fDescriptor->PortDescriptors[i];
  345. if (LADSPA_IS_PORT_AUDIO(portType))
  346. {
  347. if (LADSPA_IS_PORT_INPUT(portType))
  348. aIns += 1;
  349. else if (LADSPA_IS_PORT_OUTPUT(portType))
  350. aOuts += 1;
  351. }
  352. else if (LADSPA_IS_PORT_CONTROL(portType))
  353. params += 1;
  354. }
  355. }
  356. if ((fOptions & PLUGIN_OPTION_FORCE_STEREO) != 0 && (aIns == 1 || aOuts == 1))
  357. {
  358. if (fHandle2 == nullptr)
  359. fHandle2 = fDescriptor->instantiate(fDescriptor, (unsigned long)sampleRate);
  360. if (aIns == 1)
  361. {
  362. aIns = 2;
  363. forcedStereoIn = true;
  364. }
  365. if (aOuts == 1)
  366. {
  367. aOuts = 2;
  368. forcedStereoOut = true;
  369. }
  370. }
  371. if (fDssiDescriptor->run_synth != nullptr || fDssiDescriptor->run_multiple_synths != nullptr)
  372. {
  373. mIns = 1;
  374. needsCtrlIn = true;
  375. }
  376. if (aIns > 0)
  377. {
  378. kData->audioIn.createNew(aIns);
  379. fAudioInBuffers = new float*[aIns];
  380. for (uint32_t i=0; i < aIns; ++i)
  381. fAudioInBuffers[i] = nullptr;
  382. }
  383. if (aOuts > 0)
  384. {
  385. kData->audioOut.createNew(aOuts);
  386. fAudioOutBuffers = new float*[aOuts];
  387. needsCtrlIn = true;
  388. for (uint32_t i=0; i < aOuts; ++i)
  389. fAudioOutBuffers[i] = nullptr;
  390. }
  391. if (params > 0)
  392. {
  393. kData->param.createNew(params);
  394. fParamBuffers = new float[params];
  395. for (uint32_t i=0; i < params; ++i)
  396. fParamBuffers[i] = 0.0f;
  397. }
  398. const uint portNameSize(kData->engine->maxPortNameSize());
  399. CarlaString portName;
  400. for (uint32_t i=0, iAudioIn=0, iAudioOut=0, iCtrl=0; i < portCount; ++i)
  401. {
  402. const LADSPA_PortDescriptor portType = fDescriptor->PortDescriptors[i];
  403. const LADSPA_PortRangeHint portRangeHints = fDescriptor->PortRangeHints[i];
  404. CARLA_ASSERT(fDescriptor->PortNames[i] != nullptr);
  405. if (LADSPA_IS_PORT_AUDIO(portType))
  406. {
  407. portName.clear();
  408. if (processMode == PROCESS_MODE_SINGLE_CLIENT)
  409. {
  410. portName = fName;
  411. portName += ":";
  412. }
  413. portName += fDescriptor->PortNames[i];
  414. portName.truncate(portNameSize);
  415. if (LADSPA_IS_PORT_INPUT(portType))
  416. {
  417. j = iAudioIn++;
  418. kData->audioIn.ports[j].port = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, true);
  419. kData->audioIn.ports[j].rindex = i;
  420. if (forcedStereoIn)
  421. {
  422. portName += "_2";
  423. kData->audioIn.ports[1].port = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, true);
  424. kData->audioIn.ports[1].rindex = i;
  425. }
  426. }
  427. else if (LADSPA_IS_PORT_OUTPUT(portType))
  428. {
  429. j = iAudioOut++;
  430. kData->audioOut.ports[j].port = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, false);
  431. kData->audioOut.ports[j].rindex = i;
  432. if (forcedStereoOut)
  433. {
  434. portName += "_2";
  435. kData->audioOut.ports[1].port = (CarlaEngineAudioPort*)kData->client->addPort(kEnginePortTypeAudio, portName, false);
  436. kData->audioOut.ports[1].rindex = i;
  437. }
  438. }
  439. else
  440. carla_stderr2("WARNING - Got a broken Port (Audio, but not input or output)");
  441. }
  442. else if (LADSPA_IS_PORT_CONTROL(portType))
  443. {
  444. j = iCtrl++;
  445. kData->param.data[j].index = j;
  446. kData->param.data[j].rindex = i;
  447. kData->param.data[j].hints = 0x0;
  448. kData->param.data[j].midiChannel = 0;
  449. kData->param.data[j].midiCC = -1;
  450. float min, max, def, step, stepSmall, stepLarge;
  451. // min value
  452. if (LADSPA_IS_HINT_BOUNDED_BELOW(portRangeHints.HintDescriptor))
  453. min = portRangeHints.LowerBound;
  454. else
  455. min = 0.0f;
  456. // max value
  457. if (LADSPA_IS_HINT_BOUNDED_ABOVE(portRangeHints.HintDescriptor))
  458. max = portRangeHints.UpperBound;
  459. else
  460. max = 1.0f;
  461. if (min > max)
  462. max = min;
  463. else if (max < min)
  464. min = max;
  465. if (max - min == 0.0f)
  466. {
  467. carla_stderr2("WARNING - Broken plugin parameter '%s': max - min == 0.0f", fDescriptor->PortNames[i]);
  468. max = min + 0.1f;
  469. }
  470. // default value
  471. def = get_default_ladspa_port_value(portRangeHints.HintDescriptor, min, max);
  472. if (def < min)
  473. def = min;
  474. else if (def > max)
  475. def = max;
  476. if (LADSPA_IS_HINT_SAMPLE_RATE(portRangeHints.HintDescriptor))
  477. {
  478. min *= sampleRate;
  479. max *= sampleRate;
  480. def *= sampleRate;
  481. kData->param.data[j].hints |= PARAMETER_USES_SAMPLERATE;
  482. }
  483. if (LADSPA_IS_HINT_TOGGLED(portRangeHints.HintDescriptor))
  484. {
  485. step = max - min;
  486. stepSmall = step;
  487. stepLarge = step;
  488. kData->param.data[j].hints |= PARAMETER_IS_BOOLEAN;
  489. }
  490. else if (LADSPA_IS_HINT_INTEGER(portRangeHints.HintDescriptor))
  491. {
  492. step = 1.0f;
  493. stepSmall = 1.0f;
  494. stepLarge = 10.0f;
  495. kData->param.data[j].hints |= PARAMETER_IS_INTEGER;
  496. }
  497. else
  498. {
  499. float range = max - min;
  500. step = range/100.0f;
  501. stepSmall = range/1000.0f;
  502. stepLarge = range/10.0f;
  503. }
  504. if (LADSPA_IS_PORT_INPUT(portType))
  505. {
  506. kData->param.data[j].type = PARAMETER_INPUT;
  507. kData->param.data[j].hints |= PARAMETER_IS_ENABLED;
  508. kData->param.data[j].hints |= PARAMETER_IS_AUTOMABLE;
  509. needsCtrlIn = true;
  510. // MIDI CC value
  511. if (fDssiDescriptor->get_midi_controller_for_port != nullptr)
  512. {
  513. int controller = fDssiDescriptor->get_midi_controller_for_port(fHandle, i);
  514. if (DSSI_CONTROLLER_IS_SET(controller) && DSSI_IS_CC(controller))
  515. {
  516. int16_t cc = DSSI_CC_NUMBER(controller);
  517. if (! MIDI_IS_CONTROL_BANK_SELECT(cc))
  518. kData->param.data[j].midiCC = cc;
  519. }
  520. }
  521. }
  522. else if (LADSPA_IS_PORT_OUTPUT(portType))
  523. {
  524. if (std::strcmp(fDescriptor->PortNames[i], "latency") == 0 || std::strcmp(fDescriptor->PortNames[i], "_latency") == 0)
  525. {
  526. min = 0.0f;
  527. max = sampleRate;
  528. def = 0.0f;
  529. step = 1.0f;
  530. stepSmall = 1.0f;
  531. stepLarge = 1.0f;
  532. kData->param.data[j].type = PARAMETER_LATENCY;
  533. kData->param.data[j].hints = 0;
  534. }
  535. else if (std::strcmp(fDescriptor->PortNames[i], "_sample-rate") == 0)
  536. {
  537. def = sampleRate;
  538. step = 1.0f;
  539. stepSmall = 1.0f;
  540. stepLarge = 1.0f;
  541. kData->param.data[j].type = PARAMETER_SAMPLE_RATE;
  542. kData->param.data[j].hints = 0;
  543. }
  544. else
  545. {
  546. kData->param.data[j].type = PARAMETER_OUTPUT;
  547. kData->param.data[j].hints |= PARAMETER_IS_ENABLED;
  548. kData->param.data[j].hints |= PARAMETER_IS_AUTOMABLE;
  549. needsCtrlOut = true;
  550. }
  551. }
  552. else
  553. {
  554. kData->param.data[j].type = PARAMETER_UNKNOWN;
  555. carla_stderr2("WARNING - Got a broken Port (Control, but not input or output)");
  556. }
  557. // extra parameter hints
  558. if (LADSPA_IS_HINT_LOGARITHMIC(portRangeHints.HintDescriptor))
  559. kData->param.data[j].hints |= PARAMETER_IS_LOGARITHMIC;
  560. kData->param.ranges[j].min = min;
  561. kData->param.ranges[j].max = max;
  562. kData->param.ranges[j].def = def;
  563. kData->param.ranges[j].step = step;
  564. kData->param.ranges[j].stepSmall = stepSmall;
  565. kData->param.ranges[j].stepLarge = stepLarge;
  566. // Start parameters in their default values
  567. fParamBuffers[j] = def;
  568. fDescriptor->connect_port(fHandle, i, &fParamBuffers[j]);
  569. if (fHandle2 != nullptr)
  570. fDescriptor->connect_port(fHandle2, i, &fParamBuffers[j]);
  571. }
  572. else
  573. {
  574. // Not Audio or Control
  575. carla_stderr2("ERROR - Got a broken Port (neither Audio or Control)");
  576. fDescriptor->connect_port(fHandle, i, nullptr);
  577. if (fHandle2 != nullptr)
  578. fDescriptor->connect_port(fHandle2, i, nullptr);
  579. }
  580. }
  581. if (needsCtrlIn)
  582. {
  583. portName.clear();
  584. if (processMode == PROCESS_MODE_SINGLE_CLIENT)
  585. {
  586. portName = fName;
  587. portName += ":";
  588. }
  589. portName += "events-in";
  590. portName.truncate(portNameSize);
  591. kData->event.portIn = (CarlaEngineEventPort*)kData->client->addPort(kEnginePortTypeEvent, portName, true);
  592. }
  593. if (needsCtrlOut)
  594. {
  595. portName.clear();
  596. if (processMode == PROCESS_MODE_SINGLE_CLIENT)
  597. {
  598. portName = fName;
  599. portName += ":";
  600. }
  601. portName += "events-out";
  602. portName.truncate(portNameSize);
  603. kData->event.portOut = (CarlaEngineEventPort*)kData->client->addPort(kEnginePortTypeEvent, portName, false);
  604. }
  605. if (forcedStereoIn || forcedStereoOut)
  606. fOptions |= PLUGIN_OPTION_FORCE_STEREO;
  607. else
  608. fOptions &= ~PLUGIN_OPTION_FORCE_STEREO;
  609. // plugin hints
  610. fHints = 0x0;
  611. if (fGuiFilename.isNotEmpty())
  612. fHints |= PLUGIN_HAS_GUI;
  613. if (mIns == 1 && aIns == 0 && aOuts > 0)
  614. fHints |= PLUGIN_IS_SYNTH;
  615. if (aOuts > 0 && (aIns == aOuts || aIns == 1))
  616. fHints |= PLUGIN_CAN_DRYWET;
  617. if (aOuts > 0)
  618. fHints |= PLUGIN_CAN_VOLUME;
  619. if (aOuts >= 2 && aOuts % 2 == 0)
  620. fHints |= PLUGIN_CAN_BALANCE;
  621. // extra plugin hints
  622. kData->extraHints = 0x0;
  623. if (mIns > 0)
  624. kData->extraHints |= PLUGIN_HINT_HAS_MIDI_IN;
  625. if (aIns <= 2 && aOuts <= 2 && (aIns == aOuts || aIns == 0 || aOuts == 0))
  626. kData->extraHints |= PLUGIN_HINT_CAN_RUN_RACK;
  627. // check latency
  628. if (fHints & PLUGIN_CAN_DRYWET)
  629. {
  630. for (uint32_t i=0; i < kData->param.count; ++i)
  631. {
  632. if (kData->param.data[i].type != PARAMETER_LATENCY)
  633. continue;
  634. // we need to pre-run the plugin so it can update its latency control-port
  635. float tmpIn[aIns][2];
  636. float tmpOut[aOuts][2];
  637. for (j=0; j < aIns; ++j)
  638. {
  639. tmpIn[j][0] = 0.0f;
  640. tmpIn[j][1] = 0.0f;
  641. fDescriptor->connect_port(fHandle, kData->audioIn.ports[j].rindex, tmpIn[j]);
  642. }
  643. for (j=0; j < aOuts; ++j)
  644. {
  645. tmpOut[j][0] = 0.0f;
  646. tmpOut[j][1] = 0.0f;
  647. fDescriptor->connect_port(fHandle, kData->audioOut.ports[j].rindex, tmpOut[j]);
  648. }
  649. if (fDescriptor->activate != nullptr)
  650. fDescriptor->activate(fHandle);
  651. fDescriptor->run(fHandle, 2);
  652. if (fDescriptor->deactivate != nullptr)
  653. fDescriptor->deactivate(fHandle);
  654. const uint32_t latency = (uint32_t)fParamBuffers[i];
  655. if (kData->latency != latency)
  656. {
  657. kData->latency = latency;
  658. kData->client->setLatency(latency);
  659. kData->recreateLatencyBuffers();
  660. }
  661. break;
  662. }
  663. }
  664. bufferSizeChanged(kData->engine->getBufferSize());
  665. reloadPrograms(true);
  666. if (kData->active)
  667. activate();
  668. carla_debug("DssiPlugin::reload() - end");
  669. }
  670. void reloadPrograms(const bool init) override
  671. {
  672. carla_debug("DssiPlugin::reloadPrograms(%s)", bool2str(init));
  673. uint32_t i, oldCount = kData->midiprog.count;
  674. const int32_t current = kData->midiprog.current;
  675. // Delete old programs
  676. kData->midiprog.clear();
  677. // Query new programs
  678. uint32_t count = 0;
  679. if (fDssiDescriptor->get_program != nullptr && fDssiDescriptor->select_program != nullptr)
  680. {
  681. while (fDssiDescriptor->get_program(fHandle, count))
  682. count++;
  683. }
  684. if (count > 0)
  685. {
  686. kData->midiprog.createNew(count);
  687. // Update data
  688. for (i=0; i < count; ++i)
  689. {
  690. const DSSI_Program_Descriptor* const pdesc(fDssiDescriptor->get_program(fHandle, i));
  691. CARLA_ASSERT(pdesc != nullptr);
  692. CARLA_ASSERT(pdesc->Name != nullptr);
  693. kData->midiprog.data[i].bank = static_cast<uint32_t>(pdesc->Bank);
  694. kData->midiprog.data[i].program = static_cast<uint32_t>(pdesc->Program);
  695. kData->midiprog.data[i].name = carla_strdup(pdesc->Name);
  696. }
  697. }
  698. #ifndef BUILD_BRIDGE
  699. // Update OSC Names
  700. if (kData->engine->isOscControlRegistered())
  701. {
  702. kData->engine->osc_send_control_set_midi_program_count(fId, count);
  703. for (i=0; i < count; ++i)
  704. kData->engine->osc_send_control_set_midi_program_data(fId, i, kData->midiprog.data[i].bank, kData->midiprog.data[i].program, kData->midiprog.data[i].name);
  705. }
  706. #endif
  707. if (init)
  708. {
  709. if (count > 0)
  710. setMidiProgram(0, false, false, false);
  711. }
  712. else
  713. {
  714. // Check if current program is invalid
  715. bool programChanged = false;
  716. if (count == oldCount+1)
  717. {
  718. // one midi program added, probably created by user
  719. kData->midiprog.current = oldCount;
  720. programChanged = true;
  721. }
  722. else if (current < 0 && count > 0)
  723. {
  724. // programs exist now, but not before
  725. kData->midiprog.current = 0;
  726. programChanged = true;
  727. }
  728. else if (current >= 0 && count == 0)
  729. {
  730. // programs existed before, but not anymore
  731. kData->midiprog.current = -1;
  732. programChanged = true;
  733. }
  734. else if (current >= static_cast<int32_t>(count))
  735. {
  736. // current midi program > count
  737. kData->midiprog.current = 0;
  738. programChanged = true;
  739. }
  740. else
  741. {
  742. // no change
  743. kData->midiprog.current = current;
  744. }
  745. if (programChanged)
  746. setMidiProgram(kData->midiprog.current, true, true, true);
  747. kData->engine->callback(CALLBACK_RELOAD_PROGRAMS, fId, 0, 0, 0.0f, nullptr);
  748. }
  749. }
  750. // -------------------------------------------------------------------
  751. // Plugin processing
  752. void activate() override
  753. {
  754. CARLA_ASSERT(fDescriptor != nullptr);
  755. CARLA_ASSERT(fHandle != nullptr);
  756. if (fDescriptor->activate != nullptr)
  757. {
  758. fDescriptor->activate(fHandle);
  759. if (fHandle2 != nullptr)
  760. fDescriptor->activate(fHandle2);
  761. }
  762. }
  763. void deactivate() override
  764. {
  765. CARLA_ASSERT(fDescriptor != nullptr);
  766. CARLA_ASSERT(fHandle != nullptr);
  767. if (fDescriptor->deactivate != nullptr)
  768. {
  769. fDescriptor->deactivate(fHandle);
  770. if (fHandle2 != nullptr)
  771. fDescriptor->deactivate(fHandle2);
  772. }
  773. }
  774. void process(float** const inBuffer, float** const outBuffer, const uint32_t frames) override
  775. {
  776. uint32_t i, k;
  777. // --------------------------------------------------------------------------------------------------------
  778. // Check if active
  779. if (! kData->active)
  780. {
  781. // disable any output sound
  782. for (i=0; i < kData->audioOut.count; ++i)
  783. carla_zeroFloat(outBuffer[i], frames);
  784. return;
  785. }
  786. unsigned long midiEventCount = 0;
  787. // --------------------------------------------------------------------------------------------------------
  788. // Check if needs reset
  789. if (kData->needsReset)
  790. {
  791. // TODO!
  792. if (fOptions & PLUGIN_OPTION_SEND_ALL_SOUND_OFF)
  793. {
  794. for (unsigned char j=0, l=MAX_MIDI_CHANNELS; j < MAX_MIDI_CHANNELS; ++j)
  795. {
  796. carla_zeroStruct<snd_seq_event_t>(fMidiEvents[j]);
  797. carla_zeroStruct<snd_seq_event_t>(fMidiEvents[j+l]);
  798. fMidiEvents[j].type = SND_SEQ_EVENT_CONTROLLER;
  799. fMidiEvents[j].data.control.channel = j;
  800. fMidiEvents[j].data.control.param = MIDI_CONTROL_ALL_SOUND_OFF;
  801. fMidiEvents[j+l].type = SND_SEQ_EVENT_CONTROLLER;
  802. fMidiEvents[j+l].data.control.channel = j;
  803. fMidiEvents[j+l].data.control.param = MIDI_CONTROL_ALL_NOTES_OFF;
  804. }
  805. midiEventCount = MAX_MIDI_CHANNELS*2;
  806. }
  807. else
  808. {
  809. }
  810. if (kData->latency > 0)
  811. {
  812. for (i=0; i < kData->audioIn.count; ++i)
  813. carla_zeroFloat(kData->latencyBuffers[i], kData->latency);
  814. }
  815. kData->needsReset = false;
  816. }
  817. // --------------------------------------------------------------------------------------------------------
  818. // Event Input and Processing
  819. if (kData->event.portIn != nullptr)
  820. {
  821. // ----------------------------------------------------------------------------------------------------
  822. // MIDI Input (External)
  823. if (kData->extNotes.mutex.tryLock())
  824. {
  825. while (midiEventCount < MAX_MIDI_EVENTS && ! kData->extNotes.data.isEmpty())
  826. {
  827. const ExternalMidiNote& note(kData->extNotes.data.getFirst(true));
  828. CARLA_ASSERT(note.channel >= 0 && note.channel < MAX_MIDI_CHANNELS);
  829. fMidiEvents[midiEventCount].type = (note.velo > 0) ? SND_SEQ_EVENT_NOTEON : SND_SEQ_EVENT_NOTEOFF;
  830. fMidiEvents[midiEventCount].data.note.channel = note.channel;
  831. fMidiEvents[midiEventCount].data.note.note = note.note;
  832. fMidiEvents[midiEventCount].data.note.velocity = note.velo;
  833. midiEventCount += 1;
  834. }
  835. kData->extNotes.mutex.unlock();
  836. } // End of MIDI Input (External)
  837. // ----------------------------------------------------------------------------------------------------
  838. // Event Input (System)
  839. bool allNotesOffSent = false;
  840. bool sampleAccurate = (fOptions & PLUGIN_OPTION_FIXED_BUFFER) == 0;
  841. uint32_t time, nEvents = kData->event.portIn->getEventCount();
  842. uint32_t startTime = 0;
  843. uint32_t timeOffset = 0;
  844. uint32_t nextBankId = 0;
  845. if (kData->midiprog.current >= 0 && kData->midiprog.count > 0)
  846. nextBankId = kData->midiprog.data[kData->midiprog.current].bank;
  847. for (i=0; i < nEvents; ++i)
  848. {
  849. const EngineEvent& event = kData->event.portIn->getEvent(i);
  850. time = event.time;
  851. if (time >= frames)
  852. continue;
  853. CARLA_ASSERT_INT2(time >= timeOffset, time, timeOffset);
  854. if (time > timeOffset && sampleAccurate)
  855. {
  856. if (processSingle(inBuffer, outBuffer, time - timeOffset, timeOffset, midiEventCount))
  857. {
  858. startTime = 0;
  859. timeOffset = time;
  860. midiEventCount = 0;
  861. if (kData->midiprog.current >= 0 && kData->midiprog.count > 0)
  862. nextBankId = kData->midiprog.data[kData->midiprog.current].bank;
  863. else
  864. nextBankId = 0;
  865. }
  866. else
  867. startTime += timeOffset;
  868. }
  869. // Control change
  870. switch (event.type)
  871. {
  872. case kEngineEventTypeNull:
  873. break;
  874. case kEngineEventTypeControl:
  875. {
  876. const EngineControlEvent& ctrlEvent = event.ctrl;
  877. switch (ctrlEvent.type)
  878. {
  879. case kEngineControlEventTypeNull:
  880. break;
  881. case kEngineControlEventTypeParameter:
  882. {
  883. // Control backend stuff
  884. if (event.channel == kData->ctrlChannel)
  885. {
  886. float value;
  887. if (MIDI_IS_CONTROL_BREATH_CONTROLLER(ctrlEvent.param) && (fHints & PLUGIN_CAN_DRYWET) > 0)
  888. {
  889. value = ctrlEvent.value;
  890. setDryWet(value, false, false);
  891. postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_DRYWET, 0, value);
  892. continue;
  893. }
  894. if (MIDI_IS_CONTROL_CHANNEL_VOLUME(ctrlEvent.param) && (fHints & PLUGIN_CAN_VOLUME) > 0)
  895. {
  896. value = ctrlEvent.value*127.0f/100.0f;
  897. setVolume(value, false, false);
  898. postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_VOLUME, 0, value);
  899. continue;
  900. }
  901. if (MIDI_IS_CONTROL_BALANCE(ctrlEvent.param) && (fHints & PLUGIN_CAN_BALANCE) > 0)
  902. {
  903. float left, right;
  904. value = ctrlEvent.value/0.5f - 1.0f;
  905. if (value < 0.0f)
  906. {
  907. left = -1.0f;
  908. right = (value*2.0f)+1.0f;
  909. }
  910. else if (value > 0.0f)
  911. {
  912. left = (value*2.0f)-1.0f;
  913. right = 1.0f;
  914. }
  915. else
  916. {
  917. left = -1.0f;
  918. right = 1.0f;
  919. }
  920. setBalanceLeft(left, false, false);
  921. setBalanceRight(right, false, false);
  922. postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_BALANCE_LEFT, 0, left);
  923. postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_BALANCE_RIGHT, 0, right);
  924. continue;
  925. }
  926. }
  927. // Control plugin parameters
  928. for (k=0; k < kData->param.count; ++k)
  929. {
  930. if (kData->param.data[k].midiChannel != event.channel)
  931. continue;
  932. if (kData->param.data[k].midiCC != ctrlEvent.param)
  933. continue;
  934. if (kData->param.data[k].type != PARAMETER_INPUT)
  935. continue;
  936. if ((kData->param.data[k].hints & PARAMETER_IS_AUTOMABLE) == 0)
  937. continue;
  938. float value;
  939. if (kData->param.data[k].hints & PARAMETER_IS_BOOLEAN)
  940. {
  941. value = (ctrlEvent.value < 0.5f) ? kData->param.ranges[k].min : kData->param.ranges[k].max;
  942. }
  943. else
  944. {
  945. value = kData->param.ranges[i].unnormalizeValue(ctrlEvent.value);
  946. if (kData->param.data[k].hints & PARAMETER_IS_INTEGER)
  947. value = std::rint(value);
  948. }
  949. setParameterValue(k, value, false, false, false);
  950. postponeRtEvent(kPluginPostRtEventParameterChange, static_cast<int32_t>(k), 0, value);
  951. }
  952. break;
  953. }
  954. case kEngineControlEventTypeMidiBank:
  955. if (event.channel == kData->ctrlChannel && (fOptions & PLUGIN_OPTION_MAP_PROGRAM_CHANGES) != 0)
  956. nextBankId = ctrlEvent.param;
  957. break;
  958. case kEngineControlEventTypeMidiProgram:
  959. if (event.channel == kData->ctrlChannel && (fOptions & PLUGIN_OPTION_MAP_PROGRAM_CHANGES) != 0)
  960. {
  961. const uint32_t nextProgramId = ctrlEvent.param;
  962. for (k=0; k < kData->midiprog.count; ++k)
  963. {
  964. if (kData->midiprog.data[k].bank == nextBankId && kData->midiprog.data[k].program == nextProgramId)
  965. {
  966. setMidiProgram(k, false, false, false);
  967. postponeRtEvent(kPluginPostRtEventMidiProgramChange, k, 0, 0.0f);
  968. break;
  969. }
  970. }
  971. }
  972. break;
  973. case kEngineControlEventTypeAllSoundOff:
  974. if (event.channel == kData->ctrlChannel)
  975. {
  976. if (! allNotesOffSent)
  977. {
  978. sendMidiAllNotesOff();
  979. allNotesOffSent = true;
  980. }
  981. postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_ACTIVE, 0, 0.0f);
  982. postponeRtEvent(kPluginPostRtEventParameterChange, PARAMETER_ACTIVE, 0, 1.0f);
  983. }
  984. if (midiEventCount >= MAX_MIDI_EVENTS)
  985. continue;
  986. if (fOptions & PLUGIN_OPTION_SEND_ALL_SOUND_OFF)
  987. {
  988. carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);
  989. fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;
  990. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;
  991. fMidiEvents[midiEventCount].data.control.channel = event.channel;
  992. fMidiEvents[midiEventCount].data.control.param = MIDI_CONTROL_ALL_SOUND_OFF;
  993. midiEventCount += 1;
  994. }
  995. break;
  996. case kEngineControlEventTypeAllNotesOff:
  997. if (event.channel == kData->ctrlChannel)
  998. {
  999. if (! allNotesOffSent)
  1000. {
  1001. allNotesOffSent = true;
  1002. sendMidiAllNotesOff();
  1003. }
  1004. }
  1005. if (midiEventCount >= MAX_MIDI_EVENTS)
  1006. continue;
  1007. if (fOptions & PLUGIN_OPTION_SEND_ALL_SOUND_OFF)
  1008. {
  1009. carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);
  1010. fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;
  1011. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;
  1012. fMidiEvents[midiEventCount].data.control.channel = event.channel;
  1013. fMidiEvents[midiEventCount].data.control.param = MIDI_CONTROL_ALL_NOTES_OFF;
  1014. midiEventCount += 1;
  1015. }
  1016. break;
  1017. }
  1018. break;
  1019. }
  1020. case kEngineEventTypeMidi:
  1021. {
  1022. if (midiEventCount >= MAX_MIDI_EVENTS)
  1023. continue;
  1024. const EngineMidiEvent& midiEvent = event.midi;
  1025. uint8_t status = MIDI_GET_STATUS_FROM_DATA(midiEvent.data);
  1026. uint8_t channel = event.channel;
  1027. // Fix bad note-off (per DSSI spec)
  1028. if (MIDI_IS_STATUS_NOTE_ON(status) && midiEvent.data[2] == 0)
  1029. status -= 0x10;
  1030. carla_zeroStruct<snd_seq_event_t>(fMidiEvents[midiEventCount]);
  1031. fMidiEvents[midiEventCount].time.tick = sampleAccurate ? startTime : time;
  1032. if (MIDI_IS_STATUS_NOTE_OFF(status))
  1033. {
  1034. const uint8_t note = midiEvent.data[1];
  1035. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_NOTEOFF;
  1036. fMidiEvents[midiEventCount].data.note.channel = channel;
  1037. fMidiEvents[midiEventCount].data.note.note = note;
  1038. postponeRtEvent(kPluginPostRtEventNoteOff, channel, note, 0.0f);
  1039. }
  1040. else if (MIDI_IS_STATUS_NOTE_ON(status))
  1041. {
  1042. const uint8_t note = midiEvent.data[1];
  1043. const uint8_t velo = midiEvent.data[2];
  1044. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_NOTEON;
  1045. fMidiEvents[midiEventCount].data.note.channel = channel;
  1046. fMidiEvents[midiEventCount].data.note.note = note;
  1047. fMidiEvents[midiEventCount].data.note.velocity = velo;
  1048. postponeRtEvent(kPluginPostRtEventNoteOn, channel, note, velo);
  1049. }
  1050. else if (MIDI_IS_STATUS_POLYPHONIC_AFTERTOUCH(status) && (fOptions & PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH) != 0)
  1051. {
  1052. const uint8_t note = midiEvent.data[1];
  1053. const uint8_t pressure = midiEvent.data[2];
  1054. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_KEYPRESS;
  1055. fMidiEvents[midiEventCount].data.note.channel = channel;
  1056. fMidiEvents[midiEventCount].data.note.note = note;
  1057. fMidiEvents[midiEventCount].data.note.velocity = pressure;
  1058. }
  1059. else if (MIDI_IS_STATUS_CONTROL_CHANGE(status) && (fOptions & PLUGIN_OPTION_SEND_CONTROL_CHANGES) != 0)
  1060. {
  1061. const uint8_t control = midiEvent.data[1];
  1062. const uint8_t value = midiEvent.data[2];
  1063. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CONTROLLER;
  1064. fMidiEvents[midiEventCount].data.control.channel = channel;
  1065. fMidiEvents[midiEventCount].data.control.param = control;
  1066. fMidiEvents[midiEventCount].data.control.value = value;
  1067. }
  1068. else if (MIDI_IS_STATUS_AFTERTOUCH(status) && (fOptions & PLUGIN_OPTION_SEND_CHANNEL_PRESSURE) != 0)
  1069. {
  1070. const uint8_t pressure = midiEvent.data[1];
  1071. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_CHANPRESS;
  1072. fMidiEvents[midiEventCount].data.control.channel = channel;
  1073. fMidiEvents[midiEventCount].data.control.value = pressure;
  1074. }
  1075. else if (MIDI_IS_STATUS_PITCH_WHEEL_CONTROL(status) && (fOptions & PLUGIN_OPTION_SEND_PITCHBEND) != 0)
  1076. {
  1077. const uint8_t lsb = midiEvent.data[1];
  1078. const uint8_t msb = midiEvent.data[2];
  1079. fMidiEvents[midiEventCount].type = SND_SEQ_EVENT_PITCHBEND;
  1080. fMidiEvents[midiEventCount].data.control.channel = channel;
  1081. fMidiEvents[midiEventCount].data.control.value = ((msb << 7) | lsb) - 8192;
  1082. }
  1083. else
  1084. continue;
  1085. midiEventCount += 1;
  1086. break;
  1087. }
  1088. }
  1089. }
  1090. kData->postRtEvents.trySplice();
  1091. if (frames > timeOffset)
  1092. processSingle(inBuffer, outBuffer, frames - timeOffset, timeOffset, midiEventCount);
  1093. } // End of Event Input and Processing
  1094. // --------------------------------------------------------------------------------------------------------
  1095. // Plugin processing (no events)
  1096. else
  1097. {
  1098. processSingle(inBuffer, outBuffer, frames, 0, midiEventCount);
  1099. } // End of Plugin processing (no events)
  1100. CARLA_PROCESS_CONTINUE_CHECK;
  1101. // --------------------------------------------------------------------------------------------------------
  1102. // Control Output
  1103. if (kData->event.portOut != nullptr)
  1104. {
  1105. uint8_t channel;
  1106. uint16_t param;
  1107. float value;
  1108. for (k=0; k < kData->param.count; ++k)
  1109. {
  1110. if (kData->param.data[k].type != PARAMETER_OUTPUT)
  1111. continue;
  1112. kData->param.ranges[k].fixValue(fParamBuffers[k]);
  1113. if (kData->param.data[k].midiCC > 0)
  1114. {
  1115. channel = kData->param.data[k].midiChannel;
  1116. param = static_cast<uint16_t>(kData->param.data[k].midiCC);
  1117. value = kData->param.ranges[k].normalizeValue(fParamBuffers[k]);
  1118. kData->event.portOut->writeControlEvent(0, channel, kEngineControlEventTypeParameter, param, value);
  1119. }
  1120. }
  1121. } // End of Control Output
  1122. }
  1123. bool processSingle(float** const inBuffer, float** const outBuffer, const uint32_t frames, const uint32_t timeOffset, const unsigned long midiEventCount)
  1124. {
  1125. CARLA_ASSERT(frames > 0);
  1126. if (frames == 0)
  1127. return false;
  1128. if (kData->audioIn.count > 0)
  1129. {
  1130. CARLA_ASSERT(inBuffer != nullptr);
  1131. if (inBuffer == nullptr)
  1132. return false;
  1133. }
  1134. if (kData->audioOut.count > 0)
  1135. {
  1136. CARLA_ASSERT(outBuffer != nullptr);
  1137. if (outBuffer == nullptr)
  1138. return false;
  1139. }
  1140. uint32_t i, k;
  1141. // --------------------------------------------------------------------------------------------------------
  1142. // Try lock, silence otherwise
  1143. if (kData->engine->isOffline())
  1144. {
  1145. kData->singleMutex.lock();
  1146. }
  1147. else if (! kData->singleMutex.tryLock())
  1148. {
  1149. for (i=0; i < kData->audioOut.count; ++i)
  1150. {
  1151. for (k=0; k < frames; ++k)
  1152. outBuffer[i][k+timeOffset] = 0.0f;
  1153. }
  1154. return false;
  1155. }
  1156. // --------------------------------------------------------------------------------------------------------
  1157. // Reset audio buffers
  1158. for (i=0; i < kData->audioIn.count; ++i)
  1159. carla_copyFloat(fAudioInBuffers[i], inBuffer[i]+timeOffset, frames);
  1160. for (i=0; i < kData->audioOut.count; ++i)
  1161. carla_zeroFloat(fAudioOutBuffers[i], frames);
  1162. // --------------------------------------------------------------------------------------------------------
  1163. // Run plugin
  1164. if (fDssiDescriptor->run_synth != nullptr)
  1165. {
  1166. fDssiDescriptor->run_synth(fHandle, frames, fMidiEvents, midiEventCount);
  1167. if (fHandle2 != nullptr)
  1168. fDssiDescriptor->run_synth(fHandle2, frames, fMidiEvents, midiEventCount);
  1169. }
  1170. else if (fDssiDescriptor->run_multiple_synths != nullptr)
  1171. {
  1172. unsigned long instances = (fHandle2 != nullptr) ? 2 : 1;
  1173. LADSPA_Handle handlePtr[2] = { fHandle, fHandle2 };
  1174. snd_seq_event_t* midiEventsPtr[2] = { fMidiEvents, fMidiEvents };
  1175. unsigned long midiEventCountPtr[2] = { midiEventCount, midiEventCount };
  1176. fDssiDescriptor->run_multiple_synths(instances, handlePtr, frames, midiEventsPtr, midiEventCountPtr);
  1177. }
  1178. else
  1179. {
  1180. fDescriptor->run(fHandle, frames);
  1181. if (fHandle2 != nullptr)
  1182. fDescriptor->run(fHandle2, frames);
  1183. }
  1184. // --------------------------------------------------------------------------------------------------------
  1185. // Post-processing (dry/wet, volume and balance)
  1186. {
  1187. const bool doDryWet = (fHints & PLUGIN_CAN_DRYWET) != 0 && kData->postProc.dryWet != 1.0f;
  1188. const bool doBalance = (fHints & PLUGIN_CAN_BALANCE) != 0 && (kData->postProc.balanceLeft != -1.0f || kData->postProc.balanceRight != 1.0f);
  1189. bool isPair;
  1190. float bufValue, oldBufLeft[doBalance ? frames : 1];
  1191. for (i=0; i < kData->audioOut.count; ++i)
  1192. {
  1193. // Dry/Wet
  1194. if (doDryWet)
  1195. {
  1196. for (k=0; k < frames; ++k)
  1197. {
  1198. // TODO
  1199. //if (k < kData->latency && kData->latency < frames)
  1200. // bufValue = (kData->audioIn.count == 1) ? kData->latencyBuffers[0][k] : kData->latencyBuffers[i][k];
  1201. //else
  1202. // bufValue = (kData->audioIn.count == 1) ? inBuffer[0][k-m_latency] : inBuffer[i][k-m_latency];
  1203. bufValue = fAudioInBuffers[(kData->audioIn.count == 1) ? 0 : i][k];
  1204. fAudioOutBuffers[i][k] = (fAudioOutBuffers[i][k] * kData->postProc.dryWet) + (bufValue * (1.0f - kData->postProc.dryWet));
  1205. }
  1206. }
  1207. // Balance
  1208. if (doBalance)
  1209. {
  1210. isPair = (i % 2 == 0);
  1211. if (isPair)
  1212. {
  1213. CARLA_ASSERT(i+1 < kData->audioOut.count);
  1214. carla_copyFloat(oldBufLeft, fAudioOutBuffers[i], frames);
  1215. }
  1216. float balRangeL = (kData->postProc.balanceLeft + 1.0f)/2.0f;
  1217. float balRangeR = (kData->postProc.balanceRight + 1.0f)/2.0f;
  1218. for (k=0; k < frames; ++k)
  1219. {
  1220. if (isPair)
  1221. {
  1222. // left
  1223. fAudioOutBuffers[i][k] = oldBufLeft[k] * (1.0f - balRangeL);
  1224. fAudioOutBuffers[i][k] += fAudioOutBuffers[i+1][k] * (1.0f - balRangeR);
  1225. }
  1226. else
  1227. {
  1228. // right
  1229. fAudioOutBuffers[i][k] = fAudioOutBuffers[i][k] * balRangeR;
  1230. fAudioOutBuffers[i][k] += oldBufLeft[k] * balRangeL;
  1231. }
  1232. }
  1233. }
  1234. // Volume (and buffer copy)
  1235. {
  1236. for (k=0; k < frames; ++k)
  1237. outBuffer[i][k+timeOffset] = fAudioOutBuffers[i][k] * kData->postProc.volume;
  1238. }
  1239. }
  1240. #if 0
  1241. // Latency, save values for next callback, TODO
  1242. if (kData->latency > 0 && kData->latency < frames)
  1243. {
  1244. for (i=0; i < kData->audioIn.count; ++i)
  1245. carla_copyFloat(kData->latencyBuffers[i], inBuffer[i] + (frames - kData->latency), kData->latency);
  1246. }
  1247. #endif
  1248. } // End of Post-processing
  1249. // --------------------------------------------------------------------------------------------------------
  1250. kData->singleMutex.unlock();
  1251. return true;
  1252. }
  1253. void bufferSizeChanged(const uint32_t newBufferSize) override
  1254. {
  1255. CARLA_ASSERT_INT(newBufferSize > 0, newBufferSize);
  1256. carla_debug("DssiPlugin::bufferSizeChanged(%i) - start", newBufferSize);
  1257. for (uint32_t i=0; i < kData->audioIn.count; ++i)
  1258. {
  1259. if (fAudioInBuffers[i] != nullptr)
  1260. delete[] fAudioInBuffers[i];
  1261. fAudioInBuffers[i] = new float[newBufferSize];
  1262. }
  1263. for (uint32_t i=0; i < kData->audioOut.count; ++i)
  1264. {
  1265. if (fAudioOutBuffers[i] != nullptr)
  1266. delete[] fAudioOutBuffers[i];
  1267. fAudioOutBuffers[i] = new float[newBufferSize];
  1268. }
  1269. if (fHandle2 == nullptr)
  1270. {
  1271. for (uint32_t i=0; i < kData->audioIn.count; ++i)
  1272. {
  1273. CARLA_ASSERT(fAudioInBuffers[i] != nullptr);
  1274. fDescriptor->connect_port(fHandle, kData->audioIn.ports[i].rindex, fAudioInBuffers[i]);
  1275. }
  1276. for (uint32_t i=0; i < kData->audioOut.count; ++i)
  1277. {
  1278. CARLA_ASSERT(fAudioOutBuffers[i] != nullptr);
  1279. fDescriptor->connect_port(fHandle, kData->audioOut.ports[i].rindex, fAudioOutBuffers[i]);
  1280. }
  1281. }
  1282. else
  1283. {
  1284. if (kData->audioIn.count > 0)
  1285. {
  1286. CARLA_ASSERT(kData->audioIn.count == 2);
  1287. CARLA_ASSERT(fAudioInBuffers[0] != nullptr);
  1288. CARLA_ASSERT(fAudioInBuffers[1] != nullptr);
  1289. fDescriptor->connect_port(fHandle, kData->audioIn.ports[0].rindex, fAudioInBuffers[0]);
  1290. fDescriptor->connect_port(fHandle2, kData->audioIn.ports[1].rindex, fAudioInBuffers[1]);
  1291. }
  1292. if (kData->audioOut.count > 0)
  1293. {
  1294. CARLA_ASSERT(kData->audioOut.count == 2);
  1295. CARLA_ASSERT(fAudioOutBuffers[0] != nullptr);
  1296. CARLA_ASSERT(fAudioOutBuffers[1] != nullptr);
  1297. fDescriptor->connect_port(fHandle, kData->audioOut.ports[0].rindex, fAudioOutBuffers[0]);
  1298. fDescriptor->connect_port(fHandle2, kData->audioOut.ports[1].rindex, fAudioOutBuffers[1]);
  1299. }
  1300. }
  1301. carla_debug("DssiPlugin::bufferSizeChanged(%i) - start", newBufferSize);
  1302. }
  1303. void sampleRateChanged(const double newSampleRate) override
  1304. {
  1305. CARLA_ASSERT_INT(newSampleRate > 0.0, newSampleRate);
  1306. carla_debug("DssiPlugin::sampleRateChanged(%g) - start", newSampleRate);
  1307. // TODO
  1308. (void)newSampleRate;
  1309. carla_debug("DssiPlugin::sampleRateChanged(%g) - end", newSampleRate);
  1310. }
  1311. // -------------------------------------------------------------------
  1312. // Plugin buffers
  1313. void clearBuffers() override
  1314. {
  1315. carla_debug("DssiPlugin::clearBuffers() - start");
  1316. if (fAudioInBuffers != nullptr)
  1317. {
  1318. for (uint32_t i=0; i < kData->audioIn.count; ++i)
  1319. {
  1320. if (fAudioInBuffers[i] != nullptr)
  1321. {
  1322. delete[] fAudioInBuffers[i];
  1323. fAudioInBuffers[i] = nullptr;
  1324. }
  1325. }
  1326. delete[] fAudioInBuffers;
  1327. fAudioInBuffers = nullptr;
  1328. }
  1329. if (fAudioOutBuffers != nullptr)
  1330. {
  1331. for (uint32_t i=0; i < kData->audioOut.count; ++i)
  1332. {
  1333. if (fAudioOutBuffers[i] != nullptr)
  1334. {
  1335. delete[] fAudioOutBuffers[i];
  1336. fAudioOutBuffers[i] = nullptr;
  1337. }
  1338. }
  1339. delete[] fAudioOutBuffers;
  1340. fAudioOutBuffers = nullptr;
  1341. }
  1342. if (fParamBuffers != nullptr)
  1343. {
  1344. delete[] fParamBuffers;
  1345. fParamBuffers = nullptr;
  1346. }
  1347. CarlaPlugin::clearBuffers();
  1348. carla_debug("DssiPlugin::clearBuffers() - end");
  1349. }
  1350. // -------------------------------------------------------------------
  1351. // Post-poned UI Stuff
  1352. void uiParameterChange(const uint32_t index, const float value) override
  1353. {
  1354. CARLA_ASSERT(index < kData->param.count);
  1355. if (index >= kData->param.count)
  1356. return;
  1357. if (kData->osc.data.target == nullptr)
  1358. return;
  1359. osc_send_control(&kData->osc.data, kData->param.data[index].rindex, value);
  1360. }
  1361. void uiMidiProgramChange(const uint32_t index) override
  1362. {
  1363. CARLA_ASSERT(index < kData->midiprog.count);
  1364. if (index >= kData->midiprog.count)
  1365. return;
  1366. if (kData->osc.data.target == nullptr)
  1367. return;
  1368. osc_send_program(&kData->osc.data, kData->midiprog.data[index].bank, kData->midiprog.data[index].program);
  1369. }
  1370. void uiNoteOn(const uint8_t channel, const uint8_t note, const uint8_t velo) override
  1371. {
  1372. CARLA_ASSERT(channel < MAX_MIDI_CHANNELS);
  1373. CARLA_ASSERT(note < MAX_MIDI_NOTE);
  1374. CARLA_ASSERT(velo > 0 && velo < MAX_MIDI_VALUE);
  1375. if (channel >= MAX_MIDI_CHANNELS)
  1376. return;
  1377. if (note >= MAX_MIDI_NOTE)
  1378. return;
  1379. if (velo >= MAX_MIDI_VALUE)
  1380. return;
  1381. if (kData->osc.data.target == nullptr)
  1382. return;
  1383. uint8_t midiData[4] = { 0 };
  1384. midiData[1] = MIDI_STATUS_NOTE_ON + channel;
  1385. midiData[2] = note;
  1386. midiData[3] = velo;
  1387. osc_send_midi(&kData->osc.data, midiData);
  1388. }
  1389. void uiNoteOff(const uint8_t channel, const uint8_t note) override
  1390. {
  1391. CARLA_ASSERT(channel < MAX_MIDI_CHANNELS);
  1392. CARLA_ASSERT(note < MAX_MIDI_NOTE);
  1393. if (channel >= MAX_MIDI_CHANNELS)
  1394. return;
  1395. if (note >= MAX_MIDI_NOTE)
  1396. return;
  1397. if (kData->osc.data.target == nullptr)
  1398. return;
  1399. uint8_t midiData[4] = { 0 };
  1400. midiData[1] = MIDI_STATUS_NOTE_OFF + channel;
  1401. midiData[2] = note;
  1402. osc_send_midi(&kData->osc.data, midiData);
  1403. }
  1404. // -------------------------------------------------------------------
  1405. const void* getExtraStuff() override
  1406. {
  1407. return fGuiFilename.isNotEmpty() ? (const char*)fGuiFilename : nullptr;
  1408. }
  1409. bool init(const char* const filename, const char* const name, const char* const label, const char* const guiFilename)
  1410. {
  1411. CARLA_ASSERT(kData->engine != nullptr);
  1412. CARLA_ASSERT(kData->client == nullptr);
  1413. CARLA_ASSERT(filename != nullptr);
  1414. CARLA_ASSERT(label != nullptr);
  1415. // ---------------------------------------------------------------
  1416. // first checks
  1417. if (kData->engine == nullptr)
  1418. {
  1419. return false;
  1420. }
  1421. if (kData->client != nullptr)
  1422. {
  1423. kData->engine->setLastError("Plugin client is already registered");
  1424. return false;
  1425. }
  1426. if (filename == nullptr)
  1427. {
  1428. kData->engine->setLastError("null filename");
  1429. return false;
  1430. }
  1431. if (label == nullptr)
  1432. {
  1433. kData->engine->setLastError("null label");
  1434. return false;
  1435. }
  1436. // ---------------------------------------------------------------
  1437. // open DLL
  1438. if (! kData->libOpen(filename))
  1439. {
  1440. kData->engine->setLastError(kData->libError(filename));
  1441. return false;
  1442. }
  1443. // ---------------------------------------------------------------
  1444. // get DLL main entry
  1445. const DSSI_Descriptor_Function descFn = (DSSI_Descriptor_Function)kData->libSymbol("dssi_descriptor");
  1446. if (descFn == nullptr)
  1447. {
  1448. kData->engine->setLastError("Could not find the DSSI Descriptor in the plugin library");
  1449. return false;
  1450. }
  1451. // ---------------------------------------------------------------
  1452. // get descriptor that matches label
  1453. unsigned long i = 0;
  1454. while ((fDssiDescriptor = descFn(i++)) != nullptr)
  1455. {
  1456. fDescriptor = fDssiDescriptor->LADSPA_Plugin;
  1457. if (fDescriptor != nullptr && fDescriptor->Label != nullptr && std::strcmp(fDescriptor->Label, label) == 0)
  1458. break;
  1459. }
  1460. if (fDescriptor == nullptr || fDssiDescriptor == nullptr)
  1461. {
  1462. kData->engine->setLastError("Could not find the requested plugin label in the plugin library");
  1463. return false;
  1464. }
  1465. // ---------------------------------------------------------------
  1466. // get info
  1467. if (name != nullptr)
  1468. fName = kData->engine->getUniquePluginName(name);
  1469. else if (fDescriptor->Name != nullptr)
  1470. fName = kData->engine->getUniquePluginName(fDescriptor->Name);
  1471. else
  1472. fName = kData->engine->getUniquePluginName(fDescriptor->Label);
  1473. fFilename = filename;
  1474. // ---------------------------------------------------------------
  1475. // register client
  1476. kData->client = kData->engine->addClient(this);
  1477. if (kData->client == nullptr || ! kData->client->isOk())
  1478. {
  1479. kData->engine->setLastError("Failed to register plugin client");
  1480. return false;
  1481. }
  1482. // ---------------------------------------------------------------
  1483. // initialize plugin
  1484. fHandle = fDescriptor->instantiate(fDescriptor, (unsigned long)kData->engine->getSampleRate());
  1485. if (fHandle == nullptr)
  1486. {
  1487. kData->engine->setLastError("Plugin failed to initialize");
  1488. return false;
  1489. }
  1490. // ---------------------------------------------------------------
  1491. // gui stuff
  1492. if (guiFilename != nullptr)
  1493. {
  1494. fGuiFilename = guiFilename;
  1495. kData->osc.thread.setOscData(guiFilename, fDescriptor->Label);
  1496. }
  1497. // ---------------------------------------------------------------
  1498. // load plugin settings
  1499. {
  1500. #ifdef __USE_GNU
  1501. const bool isDssiVst = fFilename.contains("dssi-vst", true);
  1502. #else
  1503. const bool isDssiVst = fFilename.contains("dssi-vst");
  1504. #endif
  1505. // set default options
  1506. fOptions = 0x0;
  1507. fOptions |= PLUGIN_OPTION_MAP_PROGRAM_CHANGES;
  1508. if (kData->engine->getOptions().forceStereo)
  1509. fOptions |= PLUGIN_OPTION_FORCE_STEREO;
  1510. if (isDssiVst)
  1511. {
  1512. fOptions |= PLUGIN_OPTION_FIXED_BUFFER;
  1513. if (kData->engine->getOptions().useDssiVstChunks && fDssiDescriptor->get_custom_data != nullptr && fDssiDescriptor->set_custom_data != nullptr)
  1514. fOptions |= PLUGIN_OPTION_USE_CHUNKS;
  1515. }
  1516. if (fDssiDescriptor->run_synth != nullptr || fDssiDescriptor->run_multiple_synths != nullptr)
  1517. {
  1518. fOptions |= PLUGIN_OPTION_SEND_CHANNEL_PRESSURE;
  1519. fOptions |= PLUGIN_OPTION_SEND_NOTE_AFTERTOUCH;
  1520. fOptions |= PLUGIN_OPTION_SEND_PITCHBEND;
  1521. fOptions |= PLUGIN_OPTION_SEND_ALL_SOUND_OFF;
  1522. if (fDssiDescriptor->run_synth == nullptr)
  1523. carla_stderr2("Plugin can ONLY use run_multiple_synths!");
  1524. }
  1525. // load settings
  1526. kData->idStr = "DSSI/";
  1527. kData->idStr += std::strrchr(filename, OS_SEP)+1;
  1528. kData->idStr += "/";
  1529. kData->idStr += label;
  1530. fOptions = kData->loadSettings(fOptions, availableOptions());
  1531. // ignore settings, we need this anyway
  1532. if (isDssiVst)
  1533. fOptions |= PLUGIN_OPTION_FIXED_BUFFER;
  1534. }
  1535. return true;
  1536. }
  1537. private:
  1538. LADSPA_Handle fHandle;
  1539. LADSPA_Handle fHandle2;
  1540. const LADSPA_Descriptor* fDescriptor;
  1541. const DSSI_Descriptor* fDssiDescriptor;
  1542. CarlaString fGuiFilename;
  1543. float** fAudioInBuffers;
  1544. float** fAudioOutBuffers;
  1545. float* fParamBuffers;
  1546. snd_seq_event_t fMidiEvents[MAX_MIDI_EVENTS];
  1547. CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(DssiPlugin)
  1548. };
  1549. CARLA_BACKEND_END_NAMESPACE
  1550. #else // WANT_DSSI
  1551. # warning Building without DSSI support
  1552. #endif
  1553. CARLA_BACKEND_START_NAMESPACE
  1554. CarlaPlugin* CarlaPlugin::newDSSI(const Initializer& init, const char* const guiFilename)
  1555. {
  1556. carla_debug("CarlaPlugin::newDSSI({%p, \"%s\", \"%s\", \"%s\"}, \"%s\")", init.engine, init.filename, init.name, init.label, guiFilename);
  1557. #ifdef WANT_DSSI
  1558. DssiPlugin* const plugin(new DssiPlugin(init.engine, init.id));
  1559. if (! plugin->init(init.filename, init.name, init.label, guiFilename))
  1560. {
  1561. delete plugin;
  1562. return nullptr;
  1563. }
  1564. plugin->reload();
  1565. if (init.engine->getProccessMode() == PROCESS_MODE_CONTINUOUS_RACK && ! CarlaPluginProtectedData::canRunInRack(plugin))
  1566. {
  1567. init.engine->setLastError("Carla's rack mode can only work with Mono or Stereo DSSI plugins, sorry!");
  1568. delete plugin;
  1569. return nullptr;
  1570. }
  1571. return plugin;
  1572. #else
  1573. init.engine->setLastError("DSSI support not available");
  1574. return nullptr;
  1575. #endif
  1576. }
  1577. CARLA_BACKEND_END_NAMESPACE