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.

825 lines
26KB

  1. /*
  2. * Carla Plugin Host
  3. * Copyright (C) 2011-2014 Filipe Coelho <falktx@falktx.com>
  4. *
  5. * This program is free software; you can redistribute it and/or
  6. * modify it under the terms of the GNU General Public License as
  7. * published by the Free Software Foundation; either version 2 of
  8. * the License, or any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * For a full copy of the GNU General Public License see the doc/GPL.txt file.
  16. */
  17. #ifndef BUILD_BRIDGE
  18. # error This file should not be compiled if not building bridge
  19. #endif
  20. #include "CarlaEngineInternal.hpp"
  21. #include "CarlaPlugin.hpp"
  22. #include "CarlaBackendUtils.hpp"
  23. #include "CarlaBridgeUtils.hpp"
  24. #include "CarlaMIDI.h"
  25. #include "jackbridge/JackBridge.hpp"
  26. #include <cerrno>
  27. #include <ctime>
  28. using juce::File;
  29. using juce::String;
  30. // -------------------------------------------------------------------
  31. #ifdef JACKBRIDGE_EXPORT
  32. bool jackbridge_is_ok() noexcept
  33. {
  34. return true;
  35. }
  36. #endif
  37. template<typename T>
  38. bool jackbridge_shm_map2(char* shm, T*& value) noexcept
  39. {
  40. value = (T*)jackbridge_shm_map(shm, sizeof(T));
  41. return (value != nullptr);
  42. }
  43. // -------------------------------------------------------------------
  44. CARLA_BACKEND_START_NAMESPACE
  45. // -------------------------------------------------------------------
  46. struct BridgeAudioPool {
  47. CarlaString filename;
  48. float* data;
  49. char shm[32];
  50. BridgeAudioPool() noexcept
  51. : data(nullptr)
  52. {
  53. carla_zeroChar(shm, 32);
  54. jackbridge_shm_init(shm);
  55. }
  56. ~BridgeAudioPool() noexcept
  57. {
  58. // should be cleared by now
  59. CARLA_SAFE_ASSERT(data == nullptr);
  60. clear();
  61. }
  62. bool attach() noexcept
  63. {
  64. jackbridge_shm_attach(shm, filename);
  65. return jackbridge_shm_is_valid(shm);
  66. }
  67. void clear() noexcept
  68. {
  69. filename.clear();
  70. data = nullptr;
  71. if (jackbridge_shm_is_valid(shm))
  72. jackbridge_shm_close(shm);
  73. }
  74. CARLA_DECLARE_NON_COPY_STRUCT(BridgeAudioPool)
  75. };
  76. // -------------------------------------------------------------------
  77. struct BridgeRtControl : public CarlaRingBuffer<StackBuffer> {
  78. CarlaString filename;
  79. BridgeRtData* data;
  80. char shm[32];
  81. BridgeRtControl() noexcept
  82. : data(nullptr)
  83. {
  84. carla_zeroChar(shm, 32);
  85. jackbridge_shm_init(shm);
  86. }
  87. ~BridgeRtControl() noexcept
  88. {
  89. // should be cleared by now
  90. CARLA_SAFE_ASSERT(data == nullptr);
  91. clear();
  92. }
  93. bool attach() noexcept
  94. {
  95. jackbridge_shm_attach(shm, filename);
  96. return jackbridge_shm_is_valid(shm);
  97. }
  98. void clear() noexcept
  99. {
  100. filename.clear();
  101. data = nullptr;
  102. if (jackbridge_shm_is_valid(shm))
  103. jackbridge_shm_close(shm);
  104. }
  105. bool mapData() noexcept
  106. {
  107. CARLA_SAFE_ASSERT(data == nullptr);
  108. if (jackbridge_shm_map2<BridgeRtData>(shm, data))
  109. {
  110. setRingBuffer(&data->ringBuffer, false);
  111. return true;
  112. }
  113. return false;
  114. }
  115. PluginBridgeRtOpcode readOpcode() noexcept
  116. {
  117. return static_cast<PluginBridgeRtOpcode>(readInt());
  118. }
  119. CARLA_DECLARE_NON_COPY_STRUCT(BridgeRtControl)
  120. };
  121. // -------------------------------------------------------------------
  122. struct BridgeNonRtControl : public CarlaRingBuffer<BigStackBuffer> {
  123. CarlaString filename;
  124. BridgeNonRtData* data;
  125. char shm[32];
  126. BridgeNonRtControl() noexcept
  127. : CarlaRingBuffer<BigStackBuffer>(),
  128. data(nullptr)
  129. {
  130. carla_zeroChar(shm, 32);
  131. jackbridge_shm_init(shm);
  132. }
  133. ~BridgeNonRtControl() noexcept
  134. {
  135. // should be cleared by now
  136. CARLA_SAFE_ASSERT(data == nullptr);
  137. clear();
  138. }
  139. bool attach() noexcept
  140. {
  141. jackbridge_shm_attach(shm, filename);
  142. return jackbridge_shm_is_valid(shm);
  143. }
  144. void clear() noexcept
  145. {
  146. filename.clear();
  147. data = nullptr;
  148. if (jackbridge_shm_is_valid(shm))
  149. jackbridge_shm_close(shm);
  150. }
  151. bool mapData() noexcept
  152. {
  153. CARLA_SAFE_ASSERT(data == nullptr);
  154. if (jackbridge_shm_map2<BridgeNonRtData>(shm, data))
  155. {
  156. setRingBuffer(&data->ringBuffer, false);
  157. return true;
  158. }
  159. return false;
  160. }
  161. PluginBridgeNonRtOpcode readOpcode() noexcept
  162. {
  163. return static_cast<PluginBridgeNonRtOpcode>(readInt());
  164. }
  165. CARLA_DECLARE_NON_COPY_STRUCT(BridgeNonRtControl)
  166. };
  167. // -------------------------------------------------------------------
  168. class CarlaEngineBridge : public CarlaEngine,
  169. public CarlaThread
  170. {
  171. public:
  172. CarlaEngineBridge(const char* const audioPoolBaseName, const char* const rtBaseName, const char* const nonRtBaseName)
  173. : CarlaEngine(),
  174. CarlaThread("CarlaEngineBridge"),
  175. fIsRunning(false),
  176. fIsOffline(false)
  177. {
  178. carla_stdout("CarlaEngineBridge::CarlaEngineBridge(\"%s\", \"%s\", \"%s\")", audioPoolBaseName, rtBaseName, nonRtBaseName);
  179. fShmAudioPool.filename = "/carla-bridge_shm_ap_";
  180. fShmAudioPool.filename += audioPoolBaseName;
  181. fShmRtControl.filename = "/carla-bridge_shm_rt_";
  182. fShmRtControl.filename += rtBaseName;
  183. fShmNonRtControl.filename = "/carla-bridge_shm_nonrt_";
  184. fShmNonRtControl.filename += nonRtBaseName;
  185. }
  186. ~CarlaEngineBridge() noexcept override
  187. {
  188. carla_debug("CarlaEngineBridge::~CarlaEngineBridge()");
  189. }
  190. // -------------------------------------
  191. // CarlaEngine virtual calls
  192. bool init(const char* const clientName) override
  193. {
  194. carla_debug("CarlaEngineBridge::init(\"%s\")", clientName);
  195. if (! fShmAudioPool.attach())
  196. {
  197. carla_stdout("Failed to attach to audio pool shared memory");
  198. return false;
  199. }
  200. if (! fShmRtControl.attach())
  201. {
  202. clear();
  203. carla_stdout("Failed to attach to rt control shared memory");
  204. return false;
  205. }
  206. if (! fShmRtControl.mapData())
  207. {
  208. clear();
  209. carla_stdout("Failed to map rt control shared memory");
  210. return false;
  211. }
  212. if (! fShmNonRtControl.attach())
  213. {
  214. clear();
  215. carla_stdout("Failed to attach to non-rt control shared memory");
  216. return false;
  217. }
  218. if (! fShmNonRtControl.mapData())
  219. {
  220. clear();
  221. carla_stdout("Failed to map non-rt control shared memory");
  222. return false;
  223. }
  224. PluginBridgeNonRtOpcode opcode;
  225. opcode = fShmNonRtControl.readOpcode();
  226. CARLA_SAFE_ASSERT_INT(opcode == kPluginBridgeNonRtNull, opcode);
  227. const uint32_t shmRtDataSize = fShmNonRtControl.readUInt();
  228. CARLA_SAFE_ASSERT_INT2(shmRtDataSize == sizeof(BridgeRtData), shmRtDataSize, sizeof(BridgeRtData));
  229. const uint32_t shmNonRtDataSize = fShmNonRtControl.readUInt();
  230. CARLA_SAFE_ASSERT_INT2(shmNonRtDataSize == sizeof(BridgeNonRtData), shmNonRtDataSize, sizeof(BridgeNonRtData));
  231. opcode = fShmNonRtControl.readOpcode();
  232. CARLA_SAFE_ASSERT_INT(opcode == kPluginBridgeNonRtSetBufferSize, opcode);
  233. pData->bufferSize = fShmNonRtControl.readUInt();
  234. opcode = fShmNonRtControl.readOpcode();
  235. CARLA_SAFE_ASSERT_INT(opcode == kPluginBridgeNonRtSetSampleRate, opcode);
  236. pData->sampleRate = fShmNonRtControl.readDouble();
  237. carla_stdout("Carla Client Info:");
  238. carla_stdout(" BufferSize: %i", pData->bufferSize);
  239. carla_stdout(" SampleRate: %g", pData->sampleRate);
  240. carla_stdout(" sizeof(BridgeRtData): %i/" P_SIZE, shmRtDataSize, sizeof(BridgeRtData));
  241. carla_stdout(" sizeof(BridgeNonRtData): %i/" P_SIZE, shmNonRtDataSize, sizeof(BridgeNonRtData));
  242. startThread();
  243. CarlaEngine::init(clientName);
  244. return true;
  245. }
  246. bool close() override
  247. {
  248. carla_debug("CarlaEnginePlugin::close()");
  249. CarlaEngine::close();
  250. stopThread(5000);
  251. clear();
  252. return true;
  253. }
  254. bool isRunning() const noexcept override
  255. {
  256. return isThreadRunning();
  257. }
  258. bool isOffline() const noexcept override
  259. {
  260. return fIsOffline;
  261. }
  262. EngineType getType() const noexcept override
  263. {
  264. return kEngineTypeBridge;
  265. }
  266. const char* getCurrentDriverName() const noexcept
  267. {
  268. return "Bridge";
  269. }
  270. void idle() noexcept override
  271. {
  272. CarlaEngine::idle();
  273. try {
  274. handleNonRtData();
  275. } CARLA_SAFE_EXCEPTION("handleNonRtData");
  276. }
  277. // -------------------------------------------------------------------
  278. void clear() noexcept
  279. {
  280. fShmAudioPool.clear();
  281. fShmRtControl.clear();
  282. fShmNonRtControl.clear();
  283. }
  284. void handleNonRtData()
  285. {
  286. for (; fShmNonRtControl.isDataAvailableForReading();)
  287. {
  288. const PluginBridgeNonRtOpcode opcode(fShmNonRtControl.readOpcode());
  289. CarlaPlugin* const plugin(pData->plugins[0].plugin);
  290. if (opcode != kPluginBridgeNonRtPing)
  291. carla_stdout("CarlaEngineBridge::handleNonRtData() - got opcode: %s", PluginBridgeNonRtOpcode2str(opcode));
  292. switch (opcode)
  293. {
  294. case kPluginBridgeNonRtNull:
  295. break;
  296. case kPluginBridgeNonRtPing:
  297. oscSend_bridge_pong();
  298. break;
  299. case kPluginBridgeNonRtActivate:
  300. if (plugin != nullptr && plugin->isEnabled())
  301. plugin->setActive(true, false, false);
  302. break;
  303. case kPluginBridgeNonRtDeactivate:
  304. if (plugin != nullptr && plugin->isEnabled())
  305. plugin->setActive(false, false, false);
  306. break;
  307. case kPluginBridgeNonRtSetBufferSize: {
  308. const uint32_t bufferSize(fShmNonRtControl.readUInt());
  309. pData->bufferSize = bufferSize;
  310. bufferSizeChanged(bufferSize);
  311. break;
  312. }
  313. case kPluginBridgeNonRtSetSampleRate: {
  314. const double sampleRate(fShmNonRtControl.readDouble());
  315. pData->sampleRate = sampleRate;
  316. sampleRateChanged(sampleRate);
  317. break;
  318. }
  319. case kPluginBridgeNonRtSetOffline:
  320. fIsOffline = true;
  321. offlineModeChanged(true);
  322. break;
  323. case kPluginBridgeNonRtSetOnline:
  324. fIsOffline = false;
  325. offlineModeChanged(false);
  326. break;
  327. case kPluginBridgeNonRtSetParameterValue: {
  328. const uint32_t index(fShmNonRtControl.readUInt());
  329. const float value(fShmNonRtControl.readFloat());
  330. if (plugin != nullptr && plugin->isEnabled())
  331. plugin->setParameterValue(index, value, false, false, false);
  332. break;
  333. }
  334. case kPluginBridgeNonRtSetProgram: {
  335. const int32_t index(fShmNonRtControl.readInt());
  336. if (plugin != nullptr && plugin->isEnabled())
  337. plugin->setProgram(index, false, false, false);
  338. break;
  339. }
  340. case kPluginBridgeNonRtSetMidiProgram: {
  341. const int32_t index(fShmNonRtControl.readInt());
  342. if (plugin != nullptr && plugin->isEnabled())
  343. plugin->setMidiProgram(index, false, false, false);
  344. break;
  345. }
  346. case kPluginBridgeNonRtSetCustomData: {
  347. // type
  348. const uint32_t typeSize(fShmNonRtControl.readUInt());
  349. char typeStr[typeSize+1];
  350. carla_zeroChar(typeStr, typeSize+1);
  351. fShmNonRtControl.readCustomData(typeStr, typeSize);
  352. // key
  353. const uint32_t keySize(fShmNonRtControl.readUInt());
  354. char keyStr[keySize+1];
  355. carla_zeroChar(keyStr, keySize+1);
  356. fShmNonRtControl.readCustomData(keyStr, keySize);
  357. // value
  358. const uint32_t valueSize(fShmNonRtControl.readUInt());
  359. char valueStr[valueSize+1];
  360. carla_zeroChar(valueStr, valueSize+1);
  361. fShmNonRtControl.readCustomData(valueStr, valueSize);
  362. if (plugin != nullptr && plugin->isEnabled())
  363. plugin->setCustomData(typeStr, keyStr, valueStr, true);
  364. break;
  365. }
  366. case kPluginBridgeNonRtSetChunkDataFile: {
  367. const uint32_t size(fShmNonRtControl.readUInt());
  368. CARLA_SAFE_ASSERT_BREAK(size > 0);
  369. char chunkFilePathTry[size+1];
  370. carla_zeroChar(chunkFilePathTry, size+1);
  371. fShmNonRtControl.readCustomData(chunkFilePathTry, size);
  372. CARLA_SAFE_ASSERT_BREAK(chunkFilePathTry[0] != '\0');
  373. if (plugin == nullptr || ! plugin->isEnabled()) break;
  374. String chunkFilePath(chunkFilePathTry);
  375. #ifdef CARLA_OS_WIN
  376. if (chunkFilePath.startsWith("/"))
  377. {
  378. // running under Wine, posix host
  379. chunkFilePath = chunkFilePath.replaceSection(0, 1, "Z:\\").replace("/", "\\");
  380. }
  381. #endif
  382. File chunkFile(chunkFilePath);
  383. CARLA_SAFE_ASSERT_BREAK(chunkFile.existsAsFile());
  384. String chunkData(chunkFile.loadFileAsString());
  385. chunkFile.deleteFile();
  386. CARLA_SAFE_ASSERT_BREAK(chunkData.isNotEmpty());
  387. plugin->setChunkData(chunkData.toRawUTF8());
  388. break;
  389. }
  390. case kPluginBridgeNonRtPrepareForSave: {
  391. if (plugin == nullptr || ! plugin->isEnabled()) break;
  392. plugin->prepareForSave();
  393. for (uint32_t i=0, count=plugin->getCustomDataCount(); i<count; ++i)
  394. {
  395. const CustomData& cdata(plugin->getCustomData(i));
  396. oscSend_bridge_set_custom_data(cdata.type, cdata.key, cdata.value);
  397. }
  398. if (plugin->getOptionsEnabled() & PLUGIN_OPTION_USE_CHUNKS)
  399. {
  400. if (const char* const chunkData = carla_get_chunk_data(0))
  401. //if (const char* const chunkData = plugin->getChunkData())
  402. {
  403. String filePath(File::getSpecialLocation(File::tempDirectory).getFullPathName());
  404. filePath += OS_SEP_STR;
  405. filePath += ".CarlaChunk_";
  406. filePath += fShmAudioPool.filename.buffer() + 18;
  407. if (File(filePath).replaceWithText(chunkData))
  408. oscSend_bridge_set_chunk_data_file(filePath.toRawUTF8());
  409. }
  410. }
  411. oscSend_bridge_configure(CARLA_BRIDGE_MSG_SAVED, "");
  412. break;
  413. }
  414. case kPluginBridgeNonRtShowUI:
  415. if (plugin != nullptr && plugin->isEnabled())
  416. plugin->showCustomUI(true);
  417. break;
  418. case kPluginBridgeNonRtHideUI:
  419. if (plugin != nullptr && plugin->isEnabled())
  420. plugin->showCustomUI(false);
  421. break;
  422. case kPluginBridgeNonRtUiParameterChange: {
  423. const uint32_t index(fShmNonRtControl.readUInt());
  424. const float value(fShmNonRtControl.readFloat());
  425. if (plugin != nullptr && plugin->isEnabled())
  426. plugin->uiParameterChange(index, value);
  427. break;
  428. }
  429. case kPluginBridgeNonRtUiProgramChange: {
  430. const uint32_t index(fShmNonRtControl.readUInt());
  431. if (plugin != nullptr && plugin->isEnabled())
  432. plugin->uiProgramChange(index);
  433. break;
  434. }
  435. case kPluginBridgeNonRtUiMidiProgramChange: {
  436. const uint32_t index(fShmNonRtControl.readUInt());
  437. if (plugin != nullptr && plugin->isEnabled())
  438. plugin->uiMidiProgramChange(index);
  439. break;
  440. }
  441. case kPluginBridgeNonRtUiNoteOn: {
  442. const uint8_t chnl(fShmNonRtControl.readByte());
  443. const uint8_t note(fShmNonRtControl.readByte());
  444. const uint8_t velo(fShmNonRtControl.readByte());
  445. if (plugin != nullptr && plugin->isEnabled())
  446. plugin->uiNoteOn(chnl, note, velo);
  447. break;
  448. }
  449. case kPluginBridgeNonRtUiNoteOff: {
  450. const uint8_t chnl(fShmNonRtControl.readByte());
  451. const uint8_t note(fShmNonRtControl.readByte());
  452. if (plugin != nullptr && plugin->isEnabled())
  453. plugin->uiNoteOff(chnl, note);
  454. break;
  455. }
  456. case kPluginBridgeNonRtQuit:
  457. signalThreadShouldExit();
  458. break;
  459. }
  460. }
  461. }
  462. // -------------------------------------------------------------------
  463. protected:
  464. void run() override
  465. {
  466. for (; ! shouldThreadExit();)
  467. {
  468. if (! jackbridge_sem_timedwait(&fShmRtControl.data->sem.server, 5))
  469. {
  470. if (errno == ETIMEDOUT)
  471. {
  472. signalThreadShouldExit();
  473. break;
  474. }
  475. }
  476. for (; fShmRtControl.isDataAvailableForReading();)
  477. {
  478. const PluginBridgeRtOpcode opcode(fShmRtControl.readOpcode());
  479. CarlaPlugin* const plugin(pData->plugins[0].plugin);
  480. if (opcode != kPluginBridgeRtProcess) {
  481. carla_stdout("CarlaEngineBridgeRtThread::run() - got opcode: %s", PluginBridgeRtOpcode2str(opcode));
  482. }
  483. switch (opcode)
  484. {
  485. case kPluginBridgeRtNull:
  486. break;
  487. case kPluginBridgeRtSetAudioPool: {
  488. const uint64_t poolSize(fShmRtControl.readULong());
  489. CARLA_SAFE_ASSERT_BREAK(poolSize > 0);
  490. fShmAudioPool.data = (float*)jackbridge_shm_map(fShmAudioPool.shm, static_cast<size_t>(poolSize));
  491. break;
  492. }
  493. case kPluginBridgeRtSetParameter: {
  494. const uint32_t index(fShmRtControl.readUInt());
  495. const float value(fShmRtControl.readFloat());
  496. if (plugin != nullptr && plugin->isEnabled())
  497. plugin->setParameterValue(index, value, false, false, false);
  498. break;
  499. }
  500. case kPluginBridgeRtSetProgram: {
  501. const int32_t index(fShmRtControl.readInt());
  502. CARLA_SAFE_ASSERT_BREAK(index >= -1);
  503. if (plugin != nullptr && plugin->isEnabled())
  504. plugin->setProgram(index, false, false, false);
  505. break;
  506. }
  507. case kPluginBridgeRtSetMidiProgram: {
  508. const int32_t index(fShmRtControl.readInt());
  509. CARLA_SAFE_ASSERT_BREAK(index >= -1);
  510. if (plugin != nullptr && plugin->isEnabled())
  511. plugin->setMidiProgram(index, false, false, false);
  512. break;
  513. }
  514. case kPluginBridgeRtMidiEvent: {
  515. const uint32_t time(fShmRtControl.readUInt());
  516. const uint32_t size(fShmRtControl.readUInt());
  517. CARLA_SAFE_ASSERT_BREAK(size > 0 && size <= 4);
  518. uint8_t data[size];
  519. for (uint32_t i=0; i < size; ++i)
  520. data[i] = fShmRtControl.readByte();
  521. CARLA_SAFE_ASSERT_BREAK(pData->events.in != nullptr);
  522. for (ushort i=0; i < kMaxEngineEventInternalCount; ++i)
  523. {
  524. EngineEvent& event(pData->events.in[i]);
  525. if (event.type != kEngineEventTypeNull)
  526. continue;
  527. event.time = time;
  528. event.fillFromMidiData(static_cast<uint8_t>(size), data);
  529. break;
  530. }
  531. break;
  532. }
  533. case kPluginBridgeRtAllSoundOff: {
  534. const uint32_t time(fShmRtControl.readUInt());
  535. CARLA_SAFE_ASSERT_BREAK(pData->events.in != nullptr);
  536. for (ushort i=0; i < kMaxEngineEventInternalCount; ++i)
  537. {
  538. EngineEvent& event(pData->events.in[i]);
  539. if (event.type != kEngineEventTypeNull)
  540. continue;
  541. event.type = kEngineEventTypeControl;
  542. event.time = time;
  543. event.channel = 0;
  544. event.ctrl.type = kEngineControlEventTypeAllSoundOff;
  545. event.ctrl.param = 0;
  546. event.ctrl.value = 0.0f;
  547. break;
  548. }
  549. }
  550. case kPluginBridgeRtAllNotesOff: {
  551. const uint32_t time(fShmRtControl.readUInt());
  552. CARLA_SAFE_ASSERT_BREAK(pData->events.in != nullptr);
  553. for (ushort i=0; i < kMaxEngineEventInternalCount; ++i)
  554. {
  555. EngineEvent& event(pData->events.in[i]);
  556. if (event.type != kEngineEventTypeNull)
  557. continue;
  558. event.type = kEngineEventTypeControl;
  559. event.time = time;
  560. event.channel = 0;
  561. event.ctrl.type = kEngineControlEventTypeAllNotesOff;
  562. event.ctrl.param = 0;
  563. event.ctrl.value = 0.0f;
  564. break;
  565. }
  566. }
  567. case kPluginBridgeRtProcess: {
  568. CARLA_SAFE_ASSERT_BREAK(fShmAudioPool.data != nullptr);
  569. if (plugin != nullptr && plugin->isEnabled() && plugin->tryLock(false))
  570. {
  571. const BridgeTimeInfo& bridgeTimeInfo(fShmRtControl.data->timeInfo);
  572. const uint32_t inCount(plugin->getAudioInCount());
  573. const uint32_t outCount(plugin->getAudioOutCount());
  574. float* inBuffer[inCount];
  575. float* outBuffer[outCount];
  576. for (uint32_t i=0; i < inCount; ++i)
  577. inBuffer[i] = fShmAudioPool.data + i*pData->bufferSize;
  578. for (uint32_t i=0; i < outCount; ++i)
  579. outBuffer[i] = fShmAudioPool.data + (i+inCount)*pData->bufferSize;
  580. EngineTimeInfo& timeInfo(pData->timeInfo);
  581. timeInfo.playing = bridgeTimeInfo.playing;
  582. timeInfo.frame = bridgeTimeInfo.frame;
  583. timeInfo.usecs = bridgeTimeInfo.usecs;
  584. timeInfo.valid = bridgeTimeInfo.valid;
  585. if (timeInfo.valid & EngineTimeInfo::kValidBBT)
  586. {
  587. timeInfo.bbt.bar = bridgeTimeInfo.bar;
  588. timeInfo.bbt.beat = bridgeTimeInfo.beat;
  589. timeInfo.bbt.tick = bridgeTimeInfo.tick;
  590. timeInfo.bbt.beatsPerBar = bridgeTimeInfo.beatsPerBar;
  591. timeInfo.bbt.beatType = bridgeTimeInfo.beatType;
  592. timeInfo.bbt.ticksPerBeat = bridgeTimeInfo.ticksPerBeat;
  593. timeInfo.bbt.beatsPerMinute = bridgeTimeInfo.beatsPerMinute;
  594. timeInfo.bbt.barStartTick = bridgeTimeInfo.barStartTick;
  595. }
  596. plugin->initBuffers();
  597. plugin->process(inBuffer, outBuffer, pData->bufferSize);
  598. plugin->unlock();
  599. }
  600. // clear buffer
  601. CARLA_SAFE_ASSERT_BREAK(pData->events.in != nullptr);
  602. if (pData->events.in[0].type != kEngineEventTypeNull)
  603. carla_zeroStruct<EngineEvent>(pData->events.in, kMaxEngineEventInternalCount);
  604. break;
  605. }
  606. }
  607. }
  608. if (! jackbridge_sem_post(&fShmRtControl.data->sem.client))
  609. carla_stderr2("Could not post to rt semaphore");
  610. }
  611. fIsRunning = false;
  612. callback(ENGINE_CALLBACK_ENGINE_STOPPED, 0, 0, 0, 0.0f, nullptr);
  613. }
  614. // -------------------------------------------------------------------
  615. private:
  616. BridgeAudioPool fShmAudioPool;
  617. BridgeRtControl fShmRtControl;
  618. BridgeNonRtControl fShmNonRtControl;
  619. bool fIsRunning;
  620. bool fIsOffline;
  621. CARLA_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR(CarlaEngineBridge)
  622. };
  623. // -----------------------------------------------------------------------
  624. CarlaEngine* CarlaEngine::newBridge(const char* const audioPoolBaseName, const char* const rtBaseName, const char* const nonRtBaseName)
  625. {
  626. return new CarlaEngineBridge(audioPoolBaseName, rtBaseName, nonRtBaseName);
  627. }
  628. CARLA_BACKEND_END_NAMESPACE
  629. // -----------------------------------------------------------------------
  630. #if defined(CARLA_OS_WIN) && ! defined(__WINE__)
  631. extern "C" __declspec (dllexport)
  632. #else
  633. extern "C" __attribute__ ((visibility("default")))
  634. #endif
  635. void carla_register_native_plugin_carla();
  636. void carla_register_native_plugin_carla(){}
  637. // -----------------------------------------------------------------------