audio_server.cpp 40 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453
  1. /*************************************************************************/
  2. /* audio_server.cpp */
  3. /*************************************************************************/
  4. /* This file is part of: */
  5. /* GODOT ENGINE */
  6. /* https://godotengine.org */
  7. /*************************************************************************/
  8. /* Copyright (c) 2007-2021 Juan Linietsky, Ariel Manzur. */
  9. /* Copyright (c) 2014-2021 Godot Engine contributors (cf. AUTHORS.md). */
  10. /* */
  11. /* Permission is hereby granted, free of charge, to any person obtaining */
  12. /* a copy of this software and associated documentation files (the */
  13. /* "Software"), to deal in the Software without restriction, including */
  14. /* without limitation the rights to use, copy, modify, merge, publish, */
  15. /* distribute, sublicense, and/or sell copies of the Software, and to */
  16. /* permit persons to whom the Software is furnished to do so, subject to */
  17. /* the following conditions: */
  18. /* */
  19. /* The above copyright notice and this permission notice shall be */
  20. /* included in all copies or substantial portions of the Software. */
  21. /* */
  22. /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
  23. /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
  24. /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
  25. /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
  26. /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
  27. /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
  28. /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
  29. /*************************************************************************/
  30. #include "audio_server.h"
  31. #include "core/config/project_settings.h"
  32. #include "core/debugger/engine_debugger.h"
  33. #include "core/io/resource_loader.h"
  34. #include "core/os/file_access.h"
  35. #include "core/os/os.h"
  36. #include "scene/resources/audio_stream_sample.h"
  37. #include "servers/audio/audio_driver_dummy.h"
  38. #include "servers/audio/effects/audio_effect_compressor.h"
  39. #ifdef TOOLS_ENABLED
  40. #define MARK_EDITED set_edited(true);
  41. #else
  42. #define MARK_EDITED
  43. #endif
  44. AudioDriver *AudioDriver::singleton = nullptr;
  45. AudioDriver *AudioDriver::get_singleton() {
  46. return singleton;
  47. }
  48. void AudioDriver::set_singleton() {
  49. singleton = this;
  50. }
  51. void AudioDriver::audio_server_process(int p_frames, int32_t *p_buffer, bool p_update_mix_time) {
  52. if (p_update_mix_time) {
  53. update_mix_time(p_frames);
  54. }
  55. if (AudioServer::get_singleton()) {
  56. AudioServer::get_singleton()->_driver_process(p_frames, p_buffer);
  57. }
  58. }
  59. void AudioDriver::update_mix_time(int p_frames) {
  60. _last_mix_frames = p_frames;
  61. if (OS::get_singleton()) {
  62. _last_mix_time = OS::get_singleton()->get_ticks_usec();
  63. }
  64. }
  65. double AudioDriver::get_time_since_last_mix() {
  66. lock();
  67. uint64_t last_mix_time = _last_mix_time;
  68. unlock();
  69. return (OS::get_singleton()->get_ticks_usec() - last_mix_time) / 1000000.0;
  70. }
  71. double AudioDriver::get_time_to_next_mix() {
  72. lock();
  73. uint64_t last_mix_time = _last_mix_time;
  74. uint64_t last_mix_frames = _last_mix_frames;
  75. unlock();
  76. double total = (OS::get_singleton()->get_ticks_usec() - last_mix_time) / 1000000.0;
  77. double mix_buffer = last_mix_frames / (double)get_mix_rate();
  78. return mix_buffer - total;
  79. }
  80. void AudioDriver::input_buffer_init(int driver_buffer_frames) {
  81. const int input_buffer_channels = 2;
  82. input_buffer.resize(driver_buffer_frames * input_buffer_channels * 4);
  83. input_position = 0;
  84. input_size = 0;
  85. }
  86. void AudioDriver::input_buffer_write(int32_t sample) {
  87. if ((int)input_position < input_buffer.size()) {
  88. input_buffer.write[input_position++] = sample;
  89. if ((int)input_position >= input_buffer.size()) {
  90. input_position = 0;
  91. }
  92. if ((int)input_size < input_buffer.size()) {
  93. input_size++;
  94. }
  95. } else {
  96. WARN_PRINT("input_buffer_write: Invalid input_position=" + itos(input_position) + " input_buffer.size()=" + itos(input_buffer.size()));
  97. }
  98. }
  99. AudioDriver::SpeakerMode AudioDriver::get_speaker_mode_by_total_channels(int p_channels) const {
  100. switch (p_channels) {
  101. case 4:
  102. return SPEAKER_SURROUND_31;
  103. case 6:
  104. return SPEAKER_SURROUND_51;
  105. case 8:
  106. return SPEAKER_SURROUND_71;
  107. }
  108. // Default to STEREO
  109. return SPEAKER_MODE_STEREO;
  110. }
  111. int AudioDriver::get_total_channels_by_speaker_mode(AudioDriver::SpeakerMode p_mode) const {
  112. switch (p_mode) {
  113. case SPEAKER_MODE_STEREO:
  114. return 2;
  115. case SPEAKER_SURROUND_31:
  116. return 4;
  117. case SPEAKER_SURROUND_51:
  118. return 6;
  119. case SPEAKER_SURROUND_71:
  120. return 8;
  121. }
  122. ERR_FAIL_V(2);
  123. }
  124. Array AudioDriver::get_device_list() {
  125. Array list;
  126. list.push_back("Default");
  127. return list;
  128. }
  129. String AudioDriver::get_device() {
  130. return "Default";
  131. }
  132. Array AudioDriver::capture_get_device_list() {
  133. Array list;
  134. list.push_back("Default");
  135. return list;
  136. }
  137. AudioDriver::AudioDriver() {
  138. _last_mix_time = 0;
  139. _last_mix_frames = 0;
  140. input_position = 0;
  141. input_size = 0;
  142. #ifdef DEBUG_ENABLED
  143. prof_time = 0;
  144. #endif
  145. }
  146. AudioDriverDummy AudioDriverManager::dummy_driver;
  147. AudioDriver *AudioDriverManager::drivers[MAX_DRIVERS] = {
  148. &AudioDriverManager::dummy_driver,
  149. };
  150. int AudioDriverManager::driver_count = 1;
  151. void AudioDriverManager::add_driver(AudioDriver *p_driver) {
  152. ERR_FAIL_COND(driver_count >= MAX_DRIVERS);
  153. drivers[driver_count - 1] = p_driver;
  154. // Last driver is always our dummy driver
  155. drivers[driver_count++] = &AudioDriverManager::dummy_driver;
  156. }
  157. int AudioDriverManager::get_driver_count() {
  158. return driver_count;
  159. }
  160. void AudioDriverManager::initialize(int p_driver) {
  161. GLOBAL_DEF_RST("audio/driver/enable_input", false);
  162. GLOBAL_DEF_RST("audio/driver/mix_rate", DEFAULT_MIX_RATE);
  163. GLOBAL_DEF_RST("audio/driver/output_latency", DEFAULT_OUTPUT_LATENCY);
  164. GLOBAL_DEF_RST("audio/driver/output_latency.web", 50); // Safer default output_latency for web.
  165. int failed_driver = -1;
  166. // Check if there is a selected driver
  167. if (p_driver >= 0 && p_driver < driver_count) {
  168. if (drivers[p_driver]->init() == OK) {
  169. drivers[p_driver]->set_singleton();
  170. return;
  171. } else {
  172. failed_driver = p_driver;
  173. }
  174. }
  175. // No selected driver, try them all in order
  176. for (int i = 0; i < driver_count; i++) {
  177. // Don't re-init the driver if it failed above
  178. if (i == failed_driver) {
  179. continue;
  180. }
  181. if (drivers[i]->init() == OK) {
  182. drivers[i]->set_singleton();
  183. break;
  184. }
  185. }
  186. if (driver_count > 1 && String(AudioDriver::get_singleton()->get_name()) == "Dummy") {
  187. WARN_PRINT("All audio drivers failed, falling back to the dummy driver.");
  188. }
  189. }
  190. AudioDriver *AudioDriverManager::get_driver(int p_driver) {
  191. ERR_FAIL_INDEX_V(p_driver, driver_count, nullptr);
  192. return drivers[p_driver];
  193. }
  194. //////////////////////////////////////////////
  195. //////////////////////////////////////////////
  196. //////////////////////////////////////////////
  197. //////////////////////////////////////////////
  198. void AudioServer::_driver_process(int p_frames, int32_t *p_buffer) {
  199. int todo = p_frames;
  200. #ifdef DEBUG_ENABLED
  201. uint64_t prof_ticks = OS::get_singleton()->get_ticks_usec();
  202. #endif
  203. if (channel_count != get_channel_count()) {
  204. // Amount of channels changed due to a device change
  205. // reinitialize the buses channels and buffers
  206. init_channels_and_buffers();
  207. }
  208. while (todo) {
  209. if (to_mix == 0) {
  210. _mix_step();
  211. }
  212. int to_copy = MIN(to_mix, todo);
  213. Bus *master = buses[0];
  214. int from = buffer_size - to_mix;
  215. int from_buf = p_frames - todo;
  216. //master master, send to output
  217. int cs = master->channels.size();
  218. for (int k = 0; k < cs; k++) {
  219. if (master->channels[k].active) {
  220. const AudioFrame *buf = master->channels[k].buffer.ptr();
  221. for (int j = 0; j < to_copy; j++) {
  222. float l = CLAMP(buf[from + j].l, -1.0, 1.0);
  223. int32_t vl = l * ((1 << 20) - 1);
  224. int32_t vl2 = (vl < 0 ? -1 : 1) * (ABS(vl) << 11);
  225. p_buffer[(from_buf + j) * (cs * 2) + k * 2 + 0] = vl2;
  226. float r = CLAMP(buf[from + j].r, -1.0, 1.0);
  227. int32_t vr = r * ((1 << 20) - 1);
  228. int32_t vr2 = (vr < 0 ? -1 : 1) * (ABS(vr) << 11);
  229. p_buffer[(from_buf + j) * (cs * 2) + k * 2 + 1] = vr2;
  230. }
  231. } else {
  232. for (int j = 0; j < to_copy; j++) {
  233. p_buffer[(from_buf + j) * (cs * 2) + k * 2 + 0] = 0;
  234. p_buffer[(from_buf + j) * (cs * 2) + k * 2 + 1] = 0;
  235. }
  236. }
  237. }
  238. todo -= to_copy;
  239. to_mix -= to_copy;
  240. }
  241. #ifdef DEBUG_ENABLED
  242. prof_time += OS::get_singleton()->get_ticks_usec() - prof_ticks;
  243. #endif
  244. }
  245. void AudioServer::_mix_step() {
  246. bool solo_mode = false;
  247. for (int i = 0; i < buses.size(); i++) {
  248. Bus *bus = buses[i];
  249. bus->index_cache = i; //might be moved around by editor, so..
  250. for (int k = 0; k < bus->channels.size(); k++) {
  251. bus->channels.write[k].used = false;
  252. }
  253. if (bus->solo) {
  254. //solo chain
  255. solo_mode = true;
  256. bus->soloed = true;
  257. do {
  258. if (bus != buses[0]) {
  259. //everything has a send save for master bus
  260. if (!bus_map.has(bus->send)) {
  261. bus = buses[0]; //send to master
  262. } else {
  263. int prev_index_cache = bus->index_cache;
  264. bus = bus_map[bus->send];
  265. if (prev_index_cache >= bus->index_cache) { //invalid, send to master
  266. bus = buses[0];
  267. }
  268. }
  269. bus->soloed = true;
  270. } else {
  271. bus = nullptr;
  272. }
  273. } while (bus);
  274. } else {
  275. bus->soloed = false;
  276. }
  277. }
  278. //make callbacks for mixing the audio
  279. for (Set<CallbackItem>::Element *E = callbacks.front(); E; E = E->next()) {
  280. E->get().callback(E->get().userdata);
  281. }
  282. for (int i = buses.size() - 1; i >= 0; i--) {
  283. //go bus by bus
  284. Bus *bus = buses[i];
  285. for (int k = 0; k < bus->channels.size(); k++) {
  286. if (bus->channels[k].active && !bus->channels[k].used) {
  287. //buffer was not used, but it's still active, so it must be cleaned
  288. AudioFrame *buf = bus->channels.write[k].buffer.ptrw();
  289. for (uint32_t j = 0; j < buffer_size; j++) {
  290. buf[j] = AudioFrame(0, 0);
  291. }
  292. }
  293. }
  294. //process effects
  295. if (!bus->bypass) {
  296. for (int j = 0; j < bus->effects.size(); j++) {
  297. if (!bus->effects[j].enabled) {
  298. continue;
  299. }
  300. #ifdef DEBUG_ENABLED
  301. uint64_t ticks = OS::get_singleton()->get_ticks_usec();
  302. #endif
  303. for (int k = 0; k < bus->channels.size(); k++) {
  304. if (!(bus->channels[k].active || bus->channels[k].effect_instances[j]->process_silence())) {
  305. continue;
  306. }
  307. bus->channels.write[k].effect_instances.write[j]->process(bus->channels[k].buffer.ptr(), temp_buffer.write[k].ptrw(), buffer_size);
  308. }
  309. //swap buffers, so internal buffer always has the right data
  310. for (int k = 0; k < bus->channels.size(); k++) {
  311. if (!(buses[i]->channels[k].active || bus->channels[k].effect_instances[j]->process_silence())) {
  312. continue;
  313. }
  314. SWAP(bus->channels.write[k].buffer, temp_buffer.write[k]);
  315. }
  316. #ifdef DEBUG_ENABLED
  317. bus->effects.write[j].prof_time += OS::get_singleton()->get_ticks_usec() - ticks;
  318. #endif
  319. }
  320. }
  321. //process send
  322. Bus *send = nullptr;
  323. if (i > 0) {
  324. //everything has a send save for master bus
  325. if (!bus_map.has(bus->send)) {
  326. send = buses[0];
  327. } else {
  328. send = bus_map[bus->send];
  329. if (send->index_cache >= bus->index_cache) { //invalid, send to master
  330. send = buses[0];
  331. }
  332. }
  333. }
  334. for (int k = 0; k < bus->channels.size(); k++) {
  335. if (!bus->channels[k].active) {
  336. bus->channels.write[k].peak_volume = AudioFrame(AUDIO_MIN_PEAK_DB, AUDIO_MIN_PEAK_DB);
  337. continue;
  338. }
  339. AudioFrame *buf = bus->channels.write[k].buffer.ptrw();
  340. AudioFrame peak = AudioFrame(0, 0);
  341. float volume = Math::db2linear(bus->volume_db);
  342. if (solo_mode) {
  343. if (!bus->soloed) {
  344. volume = 0.0;
  345. }
  346. } else {
  347. if (bus->mute) {
  348. volume = 0.0;
  349. }
  350. }
  351. //apply volume and compute peak
  352. for (uint32_t j = 0; j < buffer_size; j++) {
  353. buf[j] *= volume;
  354. float l = ABS(buf[j].l);
  355. if (l > peak.l) {
  356. peak.l = l;
  357. }
  358. float r = ABS(buf[j].r);
  359. if (r > peak.r) {
  360. peak.r = r;
  361. }
  362. }
  363. bus->channels.write[k].peak_volume = AudioFrame(Math::linear2db(peak.l + AUDIO_PEAK_OFFSET), Math::linear2db(peak.r + AUDIO_PEAK_OFFSET));
  364. if (!bus->channels[k].used) {
  365. //see if any audio is contained, because channel was not used
  366. if (MAX(peak.r, peak.l) > Math::db2linear(channel_disable_threshold_db)) {
  367. bus->channels.write[k].last_mix_with_audio = mix_frames;
  368. } else if (mix_frames - bus->channels[k].last_mix_with_audio > channel_disable_frames) {
  369. bus->channels.write[k].active = false;
  370. continue; //went inactive, don't mix.
  371. }
  372. }
  373. if (send) {
  374. //if not master bus, send
  375. AudioFrame *target_buf = thread_get_channel_mix_buffer(send->index_cache, k);
  376. for (uint32_t j = 0; j < buffer_size; j++) {
  377. target_buf[j] += buf[j];
  378. }
  379. }
  380. }
  381. }
  382. mix_frames += buffer_size;
  383. to_mix = buffer_size;
  384. }
  385. bool AudioServer::thread_has_channel_mix_buffer(int p_bus, int p_buffer) const {
  386. if (p_bus < 0 || p_bus >= buses.size()) {
  387. return false;
  388. }
  389. if (p_buffer < 0 || p_buffer >= buses[p_bus]->channels.size()) {
  390. return false;
  391. }
  392. return true;
  393. }
  394. AudioFrame *AudioServer::thread_get_channel_mix_buffer(int p_bus, int p_buffer) {
  395. ERR_FAIL_INDEX_V(p_bus, buses.size(), nullptr);
  396. ERR_FAIL_INDEX_V(p_buffer, buses[p_bus]->channels.size(), nullptr);
  397. AudioFrame *data = buses.write[p_bus]->channels.write[p_buffer].buffer.ptrw();
  398. if (!buses[p_bus]->channels[p_buffer].used) {
  399. buses.write[p_bus]->channels.write[p_buffer].used = true;
  400. buses.write[p_bus]->channels.write[p_buffer].active = true;
  401. buses.write[p_bus]->channels.write[p_buffer].last_mix_with_audio = mix_frames;
  402. for (uint32_t i = 0; i < buffer_size; i++) {
  403. data[i] = AudioFrame(0, 0);
  404. }
  405. }
  406. return data;
  407. }
  408. int AudioServer::thread_get_mix_buffer_size() const {
  409. return buffer_size;
  410. }
  411. int AudioServer::thread_find_bus_index(const StringName &p_name) {
  412. if (bus_map.has(p_name)) {
  413. return bus_map[p_name]->index_cache;
  414. } else {
  415. return 0;
  416. }
  417. }
  418. void AudioServer::set_bus_count(int p_count) {
  419. ERR_FAIL_COND(p_count < 1);
  420. ERR_FAIL_INDEX(p_count, 256);
  421. MARK_EDITED
  422. lock();
  423. int cb = buses.size();
  424. if (p_count < buses.size()) {
  425. for (int i = p_count; i < buses.size(); i++) {
  426. bus_map.erase(buses[i]->name);
  427. memdelete(buses[i]);
  428. }
  429. }
  430. buses.resize(p_count);
  431. for (int i = cb; i < buses.size(); i++) {
  432. String attempt = "New Bus";
  433. int attempts = 1;
  434. while (true) {
  435. bool name_free = true;
  436. for (int j = 0; j < i; j++) {
  437. if (buses[j]->name == attempt) {
  438. name_free = false;
  439. break;
  440. }
  441. }
  442. if (!name_free) {
  443. attempts++;
  444. attempt = "New Bus " + itos(attempts);
  445. } else {
  446. break;
  447. }
  448. }
  449. buses.write[i] = memnew(Bus);
  450. buses.write[i]->channels.resize(channel_count);
  451. for (int j = 0; j < channel_count; j++) {
  452. buses.write[i]->channels.write[j].buffer.resize(buffer_size);
  453. }
  454. buses[i]->name = attempt;
  455. buses[i]->solo = false;
  456. buses[i]->mute = false;
  457. buses[i]->bypass = false;
  458. buses[i]->volume_db = 0;
  459. if (i > 0) {
  460. buses[i]->send = "Master";
  461. }
  462. bus_map[attempt] = buses[i];
  463. }
  464. unlock();
  465. emit_signal("bus_layout_changed");
  466. }
  467. void AudioServer::remove_bus(int p_index) {
  468. ERR_FAIL_INDEX(p_index, buses.size());
  469. ERR_FAIL_COND(p_index == 0);
  470. MARK_EDITED
  471. lock();
  472. bus_map.erase(buses[p_index]->name);
  473. memdelete(buses[p_index]);
  474. buses.remove(p_index);
  475. unlock();
  476. emit_signal("bus_layout_changed");
  477. }
  478. void AudioServer::add_bus(int p_at_pos) {
  479. MARK_EDITED
  480. if (p_at_pos >= buses.size()) {
  481. p_at_pos = -1;
  482. } else if (p_at_pos == 0) {
  483. if (buses.size() > 1) {
  484. p_at_pos = 1;
  485. } else {
  486. p_at_pos = -1;
  487. }
  488. }
  489. String attempt = "New Bus";
  490. int attempts = 1;
  491. while (true) {
  492. bool name_free = true;
  493. for (int j = 0; j < buses.size(); j++) {
  494. if (buses[j]->name == attempt) {
  495. name_free = false;
  496. break;
  497. }
  498. }
  499. if (!name_free) {
  500. attempts++;
  501. attempt = "New Bus " + itos(attempts);
  502. } else {
  503. break;
  504. }
  505. }
  506. Bus *bus = memnew(Bus);
  507. bus->channels.resize(channel_count);
  508. for (int j = 0; j < channel_count; j++) {
  509. bus->channels.write[j].buffer.resize(buffer_size);
  510. }
  511. bus->name = attempt;
  512. bus->solo = false;
  513. bus->mute = false;
  514. bus->bypass = false;
  515. bus->volume_db = 0;
  516. bus_map[attempt] = bus;
  517. if (p_at_pos == -1) {
  518. buses.push_back(bus);
  519. } else {
  520. buses.insert(p_at_pos, bus);
  521. }
  522. emit_signal("bus_layout_changed");
  523. }
  524. void AudioServer::move_bus(int p_bus, int p_to_pos) {
  525. ERR_FAIL_COND(p_bus < 1 || p_bus >= buses.size());
  526. ERR_FAIL_COND(p_to_pos != -1 && (p_to_pos < 1 || p_to_pos > buses.size()));
  527. MARK_EDITED
  528. if (p_bus == p_to_pos) {
  529. return;
  530. }
  531. Bus *bus = buses[p_bus];
  532. buses.remove(p_bus);
  533. if (p_to_pos == -1) {
  534. buses.push_back(bus);
  535. } else if (p_to_pos < p_bus) {
  536. buses.insert(p_to_pos, bus);
  537. } else {
  538. buses.insert(p_to_pos - 1, bus);
  539. }
  540. emit_signal("bus_layout_changed");
  541. }
  542. int AudioServer::get_bus_count() const {
  543. return buses.size();
  544. }
  545. void AudioServer::set_bus_name(int p_bus, const String &p_name) {
  546. ERR_FAIL_INDEX(p_bus, buses.size());
  547. if (p_bus == 0 && p_name != "Master") {
  548. return; //bus 0 is always master
  549. }
  550. MARK_EDITED
  551. lock();
  552. if (buses[p_bus]->name == p_name) {
  553. unlock();
  554. return;
  555. }
  556. String attempt = p_name;
  557. int attempts = 1;
  558. while (true) {
  559. bool name_free = true;
  560. for (int i = 0; i < buses.size(); i++) {
  561. if (buses[i]->name == attempt) {
  562. name_free = false;
  563. break;
  564. }
  565. }
  566. if (name_free) {
  567. break;
  568. }
  569. attempts++;
  570. attempt = p_name + " " + itos(attempts);
  571. }
  572. bus_map.erase(buses[p_bus]->name);
  573. buses[p_bus]->name = attempt;
  574. bus_map[attempt] = buses[p_bus];
  575. unlock();
  576. emit_signal("bus_layout_changed");
  577. }
  578. String AudioServer::get_bus_name(int p_bus) const {
  579. ERR_FAIL_INDEX_V(p_bus, buses.size(), String());
  580. return buses[p_bus]->name;
  581. }
  582. int AudioServer::get_bus_index(const StringName &p_bus_name) const {
  583. for (int i = 0; i < buses.size(); ++i) {
  584. if (buses[i]->name == p_bus_name) {
  585. return i;
  586. }
  587. }
  588. return -1;
  589. }
  590. void AudioServer::set_bus_volume_db(int p_bus, float p_volume_db) {
  591. ERR_FAIL_INDEX(p_bus, buses.size());
  592. MARK_EDITED
  593. buses[p_bus]->volume_db = p_volume_db;
  594. }
  595. float AudioServer::get_bus_volume_db(int p_bus) const {
  596. ERR_FAIL_INDEX_V(p_bus, buses.size(), 0);
  597. return buses[p_bus]->volume_db;
  598. }
  599. int AudioServer::get_bus_channels(int p_bus) const {
  600. ERR_FAIL_INDEX_V(p_bus, buses.size(), 0);
  601. return buses[p_bus]->channels.size();
  602. }
  603. void AudioServer::set_bus_send(int p_bus, const StringName &p_send) {
  604. ERR_FAIL_INDEX(p_bus, buses.size());
  605. MARK_EDITED
  606. buses[p_bus]->send = p_send;
  607. }
  608. StringName AudioServer::get_bus_send(int p_bus) const {
  609. ERR_FAIL_INDEX_V(p_bus, buses.size(), StringName());
  610. return buses[p_bus]->send;
  611. }
  612. void AudioServer::set_bus_solo(int p_bus, bool p_enable) {
  613. ERR_FAIL_INDEX(p_bus, buses.size());
  614. MARK_EDITED
  615. buses[p_bus]->solo = p_enable;
  616. }
  617. bool AudioServer::is_bus_solo(int p_bus) const {
  618. ERR_FAIL_INDEX_V(p_bus, buses.size(), false);
  619. return buses[p_bus]->solo;
  620. }
  621. void AudioServer::set_bus_mute(int p_bus, bool p_enable) {
  622. ERR_FAIL_INDEX(p_bus, buses.size());
  623. MARK_EDITED
  624. buses[p_bus]->mute = p_enable;
  625. }
  626. bool AudioServer::is_bus_mute(int p_bus) const {
  627. ERR_FAIL_INDEX_V(p_bus, buses.size(), false);
  628. return buses[p_bus]->mute;
  629. }
  630. void AudioServer::set_bus_bypass_effects(int p_bus, bool p_enable) {
  631. ERR_FAIL_INDEX(p_bus, buses.size());
  632. MARK_EDITED
  633. buses[p_bus]->bypass = p_enable;
  634. }
  635. bool AudioServer::is_bus_bypassing_effects(int p_bus) const {
  636. ERR_FAIL_INDEX_V(p_bus, buses.size(), false);
  637. return buses[p_bus]->bypass;
  638. }
  639. void AudioServer::_update_bus_effects(int p_bus) {
  640. for (int i = 0; i < buses[p_bus]->channels.size(); i++) {
  641. buses.write[p_bus]->channels.write[i].effect_instances.resize(buses[p_bus]->effects.size());
  642. for (int j = 0; j < buses[p_bus]->effects.size(); j++) {
  643. Ref<AudioEffectInstance> fx = buses.write[p_bus]->effects.write[j].effect->instance();
  644. if (Object::cast_to<AudioEffectCompressorInstance>(*fx)) {
  645. Object::cast_to<AudioEffectCompressorInstance>(*fx)->set_current_channel(i);
  646. }
  647. buses.write[p_bus]->channels.write[i].effect_instances.write[j] = fx;
  648. }
  649. }
  650. }
  651. void AudioServer::add_bus_effect(int p_bus, const Ref<AudioEffect> &p_effect, int p_at_pos) {
  652. ERR_FAIL_COND(p_effect.is_null());
  653. ERR_FAIL_INDEX(p_bus, buses.size());
  654. MARK_EDITED
  655. lock();
  656. Bus::Effect fx;
  657. fx.effect = p_effect;
  658. //fx.instance=p_effect->instance();
  659. fx.enabled = true;
  660. #ifdef DEBUG_ENABLED
  661. fx.prof_time = 0;
  662. #endif
  663. if (p_at_pos >= buses[p_bus]->effects.size() || p_at_pos < 0) {
  664. buses[p_bus]->effects.push_back(fx);
  665. } else {
  666. buses[p_bus]->effects.insert(p_at_pos, fx);
  667. }
  668. _update_bus_effects(p_bus);
  669. unlock();
  670. }
  671. void AudioServer::remove_bus_effect(int p_bus, int p_effect) {
  672. ERR_FAIL_INDEX(p_bus, buses.size());
  673. MARK_EDITED
  674. lock();
  675. buses[p_bus]->effects.remove(p_effect);
  676. _update_bus_effects(p_bus);
  677. unlock();
  678. }
  679. int AudioServer::get_bus_effect_count(int p_bus) {
  680. ERR_FAIL_INDEX_V(p_bus, buses.size(), 0);
  681. return buses[p_bus]->effects.size();
  682. }
  683. Ref<AudioEffectInstance> AudioServer::get_bus_effect_instance(int p_bus, int p_effect, int p_channel) {
  684. ERR_FAIL_INDEX_V(p_bus, buses.size(), Ref<AudioEffectInstance>());
  685. ERR_FAIL_INDEX_V(p_effect, buses[p_bus]->effects.size(), Ref<AudioEffectInstance>());
  686. ERR_FAIL_INDEX_V(p_channel, buses[p_bus]->channels.size(), Ref<AudioEffectInstance>());
  687. return buses[p_bus]->channels[p_channel].effect_instances[p_effect];
  688. }
  689. Ref<AudioEffect> AudioServer::get_bus_effect(int p_bus, int p_effect) {
  690. ERR_FAIL_INDEX_V(p_bus, buses.size(), Ref<AudioEffect>());
  691. ERR_FAIL_INDEX_V(p_effect, buses[p_bus]->effects.size(), Ref<AudioEffect>());
  692. return buses[p_bus]->effects[p_effect].effect;
  693. }
  694. void AudioServer::swap_bus_effects(int p_bus, int p_effect, int p_by_effect) {
  695. ERR_FAIL_INDEX(p_bus, buses.size());
  696. ERR_FAIL_INDEX(p_effect, buses[p_bus]->effects.size());
  697. ERR_FAIL_INDEX(p_by_effect, buses[p_bus]->effects.size());
  698. MARK_EDITED
  699. lock();
  700. SWAP(buses.write[p_bus]->effects.write[p_effect], buses.write[p_bus]->effects.write[p_by_effect]);
  701. _update_bus_effects(p_bus);
  702. unlock();
  703. }
  704. void AudioServer::set_bus_effect_enabled(int p_bus, int p_effect, bool p_enabled) {
  705. ERR_FAIL_INDEX(p_bus, buses.size());
  706. ERR_FAIL_INDEX(p_effect, buses[p_bus]->effects.size());
  707. MARK_EDITED
  708. buses.write[p_bus]->effects.write[p_effect].enabled = p_enabled;
  709. }
  710. bool AudioServer::is_bus_effect_enabled(int p_bus, int p_effect) const {
  711. ERR_FAIL_INDEX_V(p_bus, buses.size(), false);
  712. ERR_FAIL_INDEX_V(p_effect, buses[p_bus]->effects.size(), false);
  713. return buses[p_bus]->effects[p_effect].enabled;
  714. }
  715. float AudioServer::get_bus_peak_volume_left_db(int p_bus, int p_channel) const {
  716. ERR_FAIL_INDEX_V(p_bus, buses.size(), 0);
  717. ERR_FAIL_INDEX_V(p_channel, buses[p_bus]->channels.size(), 0);
  718. return buses[p_bus]->channels[p_channel].peak_volume.l;
  719. }
  720. float AudioServer::get_bus_peak_volume_right_db(int p_bus, int p_channel) const {
  721. ERR_FAIL_INDEX_V(p_bus, buses.size(), 0);
  722. ERR_FAIL_INDEX_V(p_channel, buses[p_bus]->channels.size(), 0);
  723. return buses[p_bus]->channels[p_channel].peak_volume.r;
  724. }
  725. bool AudioServer::is_bus_channel_active(int p_bus, int p_channel) const {
  726. ERR_FAIL_INDEX_V(p_bus, buses.size(), false);
  727. ERR_FAIL_INDEX_V(p_channel, buses[p_bus]->channels.size(), false);
  728. return buses[p_bus]->channels[p_channel].active;
  729. }
  730. void AudioServer::set_global_rate_scale(float p_scale) {
  731. ERR_FAIL_COND(p_scale <= 0);
  732. global_rate_scale = p_scale;
  733. }
  734. float AudioServer::get_global_rate_scale() const {
  735. return global_rate_scale;
  736. }
  737. void AudioServer::init_channels_and_buffers() {
  738. channel_count = get_channel_count();
  739. temp_buffer.resize(channel_count);
  740. for (int i = 0; i < temp_buffer.size(); i++) {
  741. temp_buffer.write[i].resize(buffer_size);
  742. }
  743. for (int i = 0; i < buses.size(); i++) {
  744. buses[i]->channels.resize(channel_count);
  745. for (int j = 0; j < channel_count; j++) {
  746. buses.write[i]->channels.write[j].buffer.resize(buffer_size);
  747. }
  748. }
  749. }
  750. void AudioServer::init() {
  751. channel_disable_threshold_db = GLOBAL_DEF_RST("audio/buses/channel_disable_threshold_db", -60.0);
  752. channel_disable_frames = float(GLOBAL_DEF_RST("audio/buses/channel_disable_time", 2.0)) * get_mix_rate();
  753. ProjectSettings::get_singleton()->set_custom_property_info("audio/buses/channel_disable_time", PropertyInfo(Variant::FLOAT, "audio/buses/channel_disable_time", PROPERTY_HINT_RANGE, "0,5,0.01,or_greater"));
  754. buffer_size = 1024; //hardcoded for now
  755. init_channels_and_buffers();
  756. mix_count = 0;
  757. set_bus_count(1);
  758. set_bus_name(0, "Master");
  759. if (AudioDriver::get_singleton()) {
  760. AudioDriver::get_singleton()->start();
  761. }
  762. #ifdef TOOLS_ENABLED
  763. set_edited(false); //avoid editors from thinking this was edited
  764. #endif
  765. GLOBAL_DEF_RST("audio/video/video_delay_compensation_ms", 0);
  766. }
  767. void AudioServer::update() {
  768. #ifdef DEBUG_ENABLED
  769. if (EngineDebugger::is_profiling("servers")) {
  770. // Driver time includes server time + effects times
  771. // Server time includes effects times
  772. uint64_t driver_time = AudioDriver::get_singleton()->get_profiling_time();
  773. uint64_t server_time = prof_time;
  774. // Subtract the server time from the driver time
  775. if (driver_time > server_time) {
  776. driver_time -= server_time;
  777. }
  778. Array values;
  779. for (int i = buses.size() - 1; i >= 0; i--) {
  780. Bus *bus = buses[i];
  781. if (bus->bypass) {
  782. continue;
  783. }
  784. for (int j = 0; j < bus->effects.size(); j++) {
  785. if (!bus->effects[j].enabled) {
  786. continue;
  787. }
  788. values.push_back(String(bus->name) + bus->effects[j].effect->get_name());
  789. values.push_back(USEC_TO_SEC(bus->effects[j].prof_time));
  790. // Subtract the effect time from the driver and server times
  791. if (driver_time > bus->effects[j].prof_time) {
  792. driver_time -= bus->effects[j].prof_time;
  793. }
  794. if (server_time > bus->effects[j].prof_time) {
  795. server_time -= bus->effects[j].prof_time;
  796. }
  797. }
  798. }
  799. values.push_back("audio_server");
  800. values.push_back(USEC_TO_SEC(server_time));
  801. values.push_back("audio_driver");
  802. values.push_back(USEC_TO_SEC(driver_time));
  803. values.push_front("audio_thread");
  804. EngineDebugger::profiler_add_frame_data("servers", values);
  805. }
  806. // Reset profiling times
  807. for (int i = buses.size() - 1; i >= 0; i--) {
  808. Bus *bus = buses[i];
  809. if (bus->bypass) {
  810. continue;
  811. }
  812. for (int j = 0; j < bus->effects.size(); j++) {
  813. if (!bus->effects[j].enabled) {
  814. continue;
  815. }
  816. bus->effects.write[j].prof_time = 0;
  817. }
  818. }
  819. AudioDriver::get_singleton()->reset_profiling_time();
  820. prof_time = 0;
  821. #endif
  822. for (Set<CallbackItem>::Element *E = update_callbacks.front(); E; E = E->next()) {
  823. E->get().callback(E->get().userdata);
  824. }
  825. }
  826. void AudioServer::load_default_bus_layout() {
  827. String layout_path = ProjectSettings::get_singleton()->get("audio/buses/default_bus_layout");
  828. if (ResourceLoader::exists(layout_path)) {
  829. Ref<AudioBusLayout> default_layout = ResourceLoader::load(layout_path);
  830. if (default_layout.is_valid()) {
  831. set_bus_layout(default_layout);
  832. }
  833. }
  834. }
  835. void AudioServer::finish() {
  836. for (int i = 0; i < AudioDriverManager::get_driver_count(); i++) {
  837. AudioDriverManager::get_driver(i)->finish();
  838. }
  839. for (int i = 0; i < buses.size(); i++) {
  840. memdelete(buses[i]);
  841. }
  842. buses.clear();
  843. }
  844. /* MISC config */
  845. void AudioServer::lock() {
  846. AudioDriver::get_singleton()->lock();
  847. }
  848. void AudioServer::unlock() {
  849. AudioDriver::get_singleton()->unlock();
  850. }
  851. AudioServer::SpeakerMode AudioServer::get_speaker_mode() const {
  852. return (AudioServer::SpeakerMode)AudioDriver::get_singleton()->get_speaker_mode();
  853. }
  854. float AudioServer::get_mix_rate() const {
  855. return AudioDriver::get_singleton()->get_mix_rate();
  856. }
  857. float AudioServer::read_output_peak_db() const {
  858. return 0;
  859. }
  860. AudioServer *AudioServer::get_singleton() {
  861. return singleton;
  862. }
  863. double AudioServer::get_output_latency() const {
  864. return AudioDriver::get_singleton()->get_latency();
  865. }
  866. double AudioServer::get_time_to_next_mix() const {
  867. return AudioDriver::get_singleton()->get_time_to_next_mix();
  868. }
  869. double AudioServer::get_time_since_last_mix() const {
  870. return AudioDriver::get_singleton()->get_time_since_last_mix();
  871. }
  872. AudioServer *AudioServer::singleton = nullptr;
  873. void AudioServer::add_callback(AudioCallback p_callback, void *p_userdata) {
  874. lock();
  875. CallbackItem ci;
  876. ci.callback = p_callback;
  877. ci.userdata = p_userdata;
  878. callbacks.insert(ci);
  879. unlock();
  880. }
  881. void AudioServer::remove_callback(AudioCallback p_callback, void *p_userdata) {
  882. lock();
  883. CallbackItem ci;
  884. ci.callback = p_callback;
  885. ci.userdata = p_userdata;
  886. callbacks.erase(ci);
  887. unlock();
  888. }
  889. void AudioServer::add_update_callback(AudioCallback p_callback, void *p_userdata) {
  890. lock();
  891. CallbackItem ci;
  892. ci.callback = p_callback;
  893. ci.userdata = p_userdata;
  894. update_callbacks.insert(ci);
  895. unlock();
  896. }
  897. void AudioServer::remove_update_callback(AudioCallback p_callback, void *p_userdata) {
  898. lock();
  899. CallbackItem ci;
  900. ci.callback = p_callback;
  901. ci.userdata = p_userdata;
  902. update_callbacks.erase(ci);
  903. unlock();
  904. }
  905. void AudioServer::set_bus_layout(const Ref<AudioBusLayout> &p_bus_layout) {
  906. ERR_FAIL_COND(p_bus_layout.is_null() || p_bus_layout->buses.size() == 0);
  907. lock();
  908. for (int i = 0; i < buses.size(); i++) {
  909. memdelete(buses[i]);
  910. }
  911. buses.resize(p_bus_layout->buses.size());
  912. bus_map.clear();
  913. for (int i = 0; i < p_bus_layout->buses.size(); i++) {
  914. Bus *bus = memnew(Bus);
  915. if (i == 0) {
  916. bus->name = "Master";
  917. } else {
  918. bus->name = p_bus_layout->buses[i].name;
  919. bus->send = p_bus_layout->buses[i].send;
  920. }
  921. bus->solo = p_bus_layout->buses[i].solo;
  922. bus->mute = p_bus_layout->buses[i].mute;
  923. bus->bypass = p_bus_layout->buses[i].bypass;
  924. bus->volume_db = p_bus_layout->buses[i].volume_db;
  925. for (int j = 0; j < p_bus_layout->buses[i].effects.size(); j++) {
  926. Ref<AudioEffect> fx = p_bus_layout->buses[i].effects[j].effect;
  927. if (fx.is_valid()) {
  928. Bus::Effect bfx;
  929. bfx.effect = fx;
  930. bfx.enabled = p_bus_layout->buses[i].effects[j].enabled;
  931. bus->effects.push_back(bfx);
  932. }
  933. }
  934. bus_map[bus->name] = bus;
  935. buses.write[i] = bus;
  936. buses[i]->channels.resize(channel_count);
  937. for (int j = 0; j < channel_count; j++) {
  938. buses.write[i]->channels.write[j].buffer.resize(buffer_size);
  939. }
  940. _update_bus_effects(i);
  941. }
  942. #ifdef TOOLS_ENABLED
  943. set_edited(false);
  944. #endif
  945. unlock();
  946. }
  947. Ref<AudioBusLayout> AudioServer::generate_bus_layout() const {
  948. Ref<AudioBusLayout> state;
  949. state.instance();
  950. state->buses.resize(buses.size());
  951. for (int i = 0; i < buses.size(); i++) {
  952. state->buses.write[i].name = buses[i]->name;
  953. state->buses.write[i].send = buses[i]->send;
  954. state->buses.write[i].mute = buses[i]->mute;
  955. state->buses.write[i].solo = buses[i]->solo;
  956. state->buses.write[i].bypass = buses[i]->bypass;
  957. state->buses.write[i].volume_db = buses[i]->volume_db;
  958. for (int j = 0; j < buses[i]->effects.size(); j++) {
  959. AudioBusLayout::Bus::Effect fx;
  960. fx.effect = buses[i]->effects[j].effect;
  961. fx.enabled = buses[i]->effects[j].enabled;
  962. state->buses.write[i].effects.push_back(fx);
  963. }
  964. }
  965. return state;
  966. }
  967. Array AudioServer::get_device_list() {
  968. return AudioDriver::get_singleton()->get_device_list();
  969. }
  970. String AudioServer::get_device() {
  971. return AudioDriver::get_singleton()->get_device();
  972. }
  973. void AudioServer::set_device(String device) {
  974. AudioDriver::get_singleton()->set_device(device);
  975. }
  976. Array AudioServer::capture_get_device_list() {
  977. return AudioDriver::get_singleton()->capture_get_device_list();
  978. }
  979. String AudioServer::capture_get_device() {
  980. return AudioDriver::get_singleton()->capture_get_device();
  981. }
  982. void AudioServer::capture_set_device(const String &p_name) {
  983. AudioDriver::get_singleton()->capture_set_device(p_name);
  984. }
  985. void AudioServer::_bind_methods() {
  986. ClassDB::bind_method(D_METHOD("set_bus_count", "amount"), &AudioServer::set_bus_count);
  987. ClassDB::bind_method(D_METHOD("get_bus_count"), &AudioServer::get_bus_count);
  988. ClassDB::bind_method(D_METHOD("remove_bus", "index"), &AudioServer::remove_bus);
  989. ClassDB::bind_method(D_METHOD("add_bus", "at_position"), &AudioServer::add_bus, DEFVAL(-1));
  990. ClassDB::bind_method(D_METHOD("move_bus", "index", "to_index"), &AudioServer::move_bus);
  991. ClassDB::bind_method(D_METHOD("set_bus_name", "bus_idx", "name"), &AudioServer::set_bus_name);
  992. ClassDB::bind_method(D_METHOD("get_bus_name", "bus_idx"), &AudioServer::get_bus_name);
  993. ClassDB::bind_method(D_METHOD("get_bus_index", "bus_name"), &AudioServer::get_bus_index);
  994. ClassDB::bind_method(D_METHOD("get_bus_channels", "bus_idx"), &AudioServer::get_bus_channels);
  995. ClassDB::bind_method(D_METHOD("set_bus_volume_db", "bus_idx", "volume_db"), &AudioServer::set_bus_volume_db);
  996. ClassDB::bind_method(D_METHOD("get_bus_volume_db", "bus_idx"), &AudioServer::get_bus_volume_db);
  997. ClassDB::bind_method(D_METHOD("set_bus_send", "bus_idx", "send"), &AudioServer::set_bus_send);
  998. ClassDB::bind_method(D_METHOD("get_bus_send", "bus_idx"), &AudioServer::get_bus_send);
  999. ClassDB::bind_method(D_METHOD("set_bus_solo", "bus_idx", "enable"), &AudioServer::set_bus_solo);
  1000. ClassDB::bind_method(D_METHOD("is_bus_solo", "bus_idx"), &AudioServer::is_bus_solo);
  1001. ClassDB::bind_method(D_METHOD("set_bus_mute", "bus_idx", "enable"), &AudioServer::set_bus_mute);
  1002. ClassDB::bind_method(D_METHOD("is_bus_mute", "bus_idx"), &AudioServer::is_bus_mute);
  1003. ClassDB::bind_method(D_METHOD("set_bus_bypass_effects", "bus_idx", "enable"), &AudioServer::set_bus_bypass_effects);
  1004. ClassDB::bind_method(D_METHOD("is_bus_bypassing_effects", "bus_idx"), &AudioServer::is_bus_bypassing_effects);
  1005. ClassDB::bind_method(D_METHOD("add_bus_effect", "bus_idx", "effect", "at_position"), &AudioServer::add_bus_effect, DEFVAL(-1));
  1006. ClassDB::bind_method(D_METHOD("remove_bus_effect", "bus_idx", "effect_idx"), &AudioServer::remove_bus_effect);
  1007. ClassDB::bind_method(D_METHOD("get_bus_effect_count", "bus_idx"), &AudioServer::get_bus_effect_count);
  1008. ClassDB::bind_method(D_METHOD("get_bus_effect", "bus_idx", "effect_idx"), &AudioServer::get_bus_effect);
  1009. ClassDB::bind_method(D_METHOD("get_bus_effect_instance", "bus_idx", "effect_idx", "channel"), &AudioServer::get_bus_effect_instance, DEFVAL(0));
  1010. ClassDB::bind_method(D_METHOD("swap_bus_effects", "bus_idx", "effect_idx", "by_effect_idx"), &AudioServer::swap_bus_effects);
  1011. ClassDB::bind_method(D_METHOD("set_bus_effect_enabled", "bus_idx", "effect_idx", "enabled"), &AudioServer::set_bus_effect_enabled);
  1012. ClassDB::bind_method(D_METHOD("is_bus_effect_enabled", "bus_idx", "effect_idx"), &AudioServer::is_bus_effect_enabled);
  1013. ClassDB::bind_method(D_METHOD("get_bus_peak_volume_left_db", "bus_idx", "channel"), &AudioServer::get_bus_peak_volume_left_db);
  1014. ClassDB::bind_method(D_METHOD("get_bus_peak_volume_right_db", "bus_idx", "channel"), &AudioServer::get_bus_peak_volume_right_db);
  1015. ClassDB::bind_method(D_METHOD("set_global_rate_scale", "scale"), &AudioServer::set_global_rate_scale);
  1016. ClassDB::bind_method(D_METHOD("get_global_rate_scale"), &AudioServer::get_global_rate_scale);
  1017. ClassDB::bind_method(D_METHOD("lock"), &AudioServer::lock);
  1018. ClassDB::bind_method(D_METHOD("unlock"), &AudioServer::unlock);
  1019. ClassDB::bind_method(D_METHOD("get_speaker_mode"), &AudioServer::get_speaker_mode);
  1020. ClassDB::bind_method(D_METHOD("get_mix_rate"), &AudioServer::get_mix_rate);
  1021. ClassDB::bind_method(D_METHOD("get_device_list"), &AudioServer::get_device_list);
  1022. ClassDB::bind_method(D_METHOD("get_device"), &AudioServer::get_device);
  1023. ClassDB::bind_method(D_METHOD("set_device", "device"), &AudioServer::set_device);
  1024. ClassDB::bind_method(D_METHOD("get_time_to_next_mix"), &AudioServer::get_time_to_next_mix);
  1025. ClassDB::bind_method(D_METHOD("get_time_since_last_mix"), &AudioServer::get_time_since_last_mix);
  1026. ClassDB::bind_method(D_METHOD("get_output_latency"), &AudioServer::get_output_latency);
  1027. ClassDB::bind_method(D_METHOD("capture_get_device_list"), &AudioServer::capture_get_device_list);
  1028. ClassDB::bind_method(D_METHOD("capture_get_device"), &AudioServer::capture_get_device);
  1029. ClassDB::bind_method(D_METHOD("capture_set_device", "name"), &AudioServer::capture_set_device);
  1030. ClassDB::bind_method(D_METHOD("set_bus_layout", "bus_layout"), &AudioServer::set_bus_layout);
  1031. ClassDB::bind_method(D_METHOD("generate_bus_layout"), &AudioServer::generate_bus_layout);
  1032. ADD_PROPERTY(PropertyInfo(Variant::INT, "bus_count"), "set_bus_count", "get_bus_count");
  1033. ADD_PROPERTY(PropertyInfo(Variant::STRING, "device"), "set_device", "get_device");
  1034. ADD_PROPERTY(PropertyInfo(Variant::FLOAT, "global_rate_scale"), "set_global_rate_scale", "get_global_rate_scale");
  1035. ADD_SIGNAL(MethodInfo("bus_layout_changed"));
  1036. BIND_ENUM_CONSTANT(SPEAKER_MODE_STEREO);
  1037. BIND_ENUM_CONSTANT(SPEAKER_SURROUND_31);
  1038. BIND_ENUM_CONSTANT(SPEAKER_SURROUND_51);
  1039. BIND_ENUM_CONSTANT(SPEAKER_SURROUND_71);
  1040. }
  1041. AudioServer::AudioServer() {
  1042. singleton = this;
  1043. mix_frames = 0;
  1044. channel_count = 0;
  1045. to_mix = 0;
  1046. #ifdef DEBUG_ENABLED
  1047. prof_time = 0;
  1048. #endif
  1049. mix_time = 0;
  1050. mix_size = 0;
  1051. global_rate_scale = 1;
  1052. }
  1053. AudioServer::~AudioServer() {
  1054. singleton = nullptr;
  1055. }
  1056. /////////////////////////////////
  1057. bool AudioBusLayout::_set(const StringName &p_name, const Variant &p_value) {
  1058. String s = p_name;
  1059. if (s.begins_with("bus/")) {
  1060. int index = s.get_slice("/", 1).to_int();
  1061. if (buses.size() <= index) {
  1062. buses.resize(index + 1);
  1063. }
  1064. Bus &bus = buses.write[index];
  1065. String what = s.get_slice("/", 2);
  1066. if (what == "name") {
  1067. bus.name = p_value;
  1068. } else if (what == "solo") {
  1069. bus.solo = p_value;
  1070. } else if (what == "mute") {
  1071. bus.mute = p_value;
  1072. } else if (what == "bypass_fx") {
  1073. bus.bypass = p_value;
  1074. } else if (what == "volume_db") {
  1075. bus.volume_db = p_value;
  1076. } else if (what == "send") {
  1077. bus.send = p_value;
  1078. } else if (what == "effect") {
  1079. int which = s.get_slice("/", 3).to_int();
  1080. if (bus.effects.size() <= which) {
  1081. bus.effects.resize(which + 1);
  1082. }
  1083. Bus::Effect &fx = bus.effects.write[which];
  1084. String fxwhat = s.get_slice("/", 4);
  1085. if (fxwhat == "effect") {
  1086. fx.effect = p_value;
  1087. } else if (fxwhat == "enabled") {
  1088. fx.enabled = p_value;
  1089. } else {
  1090. return false;
  1091. }
  1092. return true;
  1093. } else {
  1094. return false;
  1095. }
  1096. return true;
  1097. }
  1098. return false;
  1099. }
  1100. bool AudioBusLayout::_get(const StringName &p_name, Variant &r_ret) const {
  1101. String s = p_name;
  1102. if (s.begins_with("bus/")) {
  1103. int index = s.get_slice("/", 1).to_int();
  1104. if (index < 0 || index >= buses.size()) {
  1105. return false;
  1106. }
  1107. const Bus &bus = buses[index];
  1108. String what = s.get_slice("/", 2);
  1109. if (what == "name") {
  1110. r_ret = bus.name;
  1111. } else if (what == "solo") {
  1112. r_ret = bus.solo;
  1113. } else if (what == "mute") {
  1114. r_ret = bus.mute;
  1115. } else if (what == "bypass_fx") {
  1116. r_ret = bus.bypass;
  1117. } else if (what == "volume_db") {
  1118. r_ret = bus.volume_db;
  1119. } else if (what == "send") {
  1120. r_ret = bus.send;
  1121. } else if (what == "effect") {
  1122. int which = s.get_slice("/", 3).to_int();
  1123. if (which < 0 || which >= bus.effects.size()) {
  1124. return false;
  1125. }
  1126. const Bus::Effect &fx = bus.effects[which];
  1127. String fxwhat = s.get_slice("/", 4);
  1128. if (fxwhat == "effect") {
  1129. r_ret = fx.effect;
  1130. } else if (fxwhat == "enabled") {
  1131. r_ret = fx.enabled;
  1132. } else {
  1133. return false;
  1134. }
  1135. return true;
  1136. } else {
  1137. return false;
  1138. }
  1139. return true;
  1140. }
  1141. return false;
  1142. }
  1143. void AudioBusLayout::_get_property_list(List<PropertyInfo> *p_list) const {
  1144. for (int i = 0; i < buses.size(); i++) {
  1145. p_list->push_back(PropertyInfo(Variant::STRING, "bus/" + itos(i) + "/name", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1146. p_list->push_back(PropertyInfo(Variant::BOOL, "bus/" + itos(i) + "/solo", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1147. p_list->push_back(PropertyInfo(Variant::BOOL, "bus/" + itos(i) + "/mute", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1148. p_list->push_back(PropertyInfo(Variant::BOOL, "bus/" + itos(i) + "/bypass_fx", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1149. p_list->push_back(PropertyInfo(Variant::FLOAT, "bus/" + itos(i) + "/volume_db", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1150. p_list->push_back(PropertyInfo(Variant::FLOAT, "bus/" + itos(i) + "/send", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1151. for (int j = 0; j < buses[i].effects.size(); j++) {
  1152. p_list->push_back(PropertyInfo(Variant::OBJECT, "bus/" + itos(i) + "/effect/" + itos(j) + "/effect", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1153. p_list->push_back(PropertyInfo(Variant::BOOL, "bus/" + itos(i) + "/effect/" + itos(j) + "/enabled", PROPERTY_HINT_NONE, "", PROPERTY_USAGE_NOEDITOR | PROPERTY_USAGE_INTERNAL));
  1154. }
  1155. }
  1156. }
  1157. AudioBusLayout::AudioBusLayout() {
  1158. buses.resize(1);
  1159. buses.write[0].name = "Master";
  1160. }