?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Fix lambda callback parameter type
[openal-soft.git] / alc / alc.cpp
blob63f9eb00ee8a69fdcbf74e662a5bbbbf786c5ea1
1 /**
2 * OpenAL cross platform audio library
3 * Copyright (C) 1999-2007 by authors.
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Library General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
8 *
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Library General Public License for more details.
13 *
14 * You should have received a copy of the GNU Library General Public
15 * License along with this library; if not, write to the
16 * Free Software Foundation, Inc.,
17 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
18 * Or go to http://www.gnu.org/copyleft/lgpl.html
19 */
20
21 #include "config.h"
22
23 #include "version.h"
24
25 #ifdef _WIN32
26 #define WIN32_LEAN_AND_MEAN
27 #include <windows.h>
28 #endif
29
30 #include <algorithm>
31 #include <array>
32 #include <atomic>
33 #include <bitset>
34 #include <cassert>
35 #include <cctype>
36 #include <chrono>
37 #include <cinttypes>
38 #include <climits>
39 #include <cmath>
40 #include <csignal>
41 #include <cstddef>
42 #include <cstdio>
43 #include <cstdlib>
44 #include <cstring>
45 #include <exception>
46 #include <functional>
47 #include <iterator>
48 #include <limits>
49 #include <memory>
50 #include <mutex>
51 #include <new>
52 #include <optional>
53 #include <stdexcept>
54 #include <string>
55 #include <string_view>
56 #include <tuple>
57 #include <utility>
58 #include <vector>
59
60 #include "AL/al.h"
61 #include "AL/alc.h"
62 #include "AL/alext.h"
63 #include "AL/efx.h"
64
65 #include "al/auxeffectslot.h"
66 #include "al/buffer.h"
67 #include "al/debug.h"
68 #include "al/effect.h"
69 #include "al/filter.h"
70 #include "al/source.h"
71 #include "alc/events.h"
72 #include "albit.h"
73 #include "alconfig.h"
74 #include "almalloc.h"
75 #include "alnumbers.h"
76 #include "alnumeric.h"
77 #include "alspan.h"
78 #include "alstring.h"
79 #include "alu.h"
80 #include "atomic.h"
81 #include "context.h"
82 #include "core/ambidefs.h"
83 #include "core/bformatdec.h"
84 #include "core/bs2b.h"
85 #include "core/context.h"
86 #include "core/cpu_caps.h"
87 #include "core/devformat.h"
88 #include "core/device.h"
89 #include "core/effects/base.h"
90 #include "core/effectslot.h"
91 #include "core/filters/nfc.h"
92 #include "core/helpers.h"
93 #include "core/mastering.h"
94 #include "core/fpu_ctrl.h"
95 #include "core/logging.h"
96 #include "core/uhjfilter.h"
97 #include "core/voice.h"
98 #include "core/voice_change.h"
99 #include "device.h"
100 #include "effects/base.h"
101 #include "export_list.h"
102 #include "flexarray.h"
103 #include "inprogext.h"
104 #include "intrusive_ptr.h"
105 #include "opthelpers.h"
106 #include "strutils.h"
107
108 #include "backends/base.h"
109 #include "backends/null.h"
110 #include "backends/loopback.h"
111 #ifdef HAVE_PIPEWIRE
112 #include "backends/pipewire.h"
113 #endif
114 #ifdef HAVE_JACK
115 #include "backends/jack.h"
116 #endif
117 #ifdef HAVE_PULSEAUDIO
118 #include "backends/pulseaudio.h"
119 #endif
120 #ifdef HAVE_ALSA
121 #include "backends/alsa.h"
122 #endif
123 #ifdef HAVE_WASAPI
124 #include "backends/wasapi.h"
125 #endif
126 #ifdef HAVE_COREAUDIO
127 #include "backends/coreaudio.h"
128 #endif
129 #ifdef HAVE_OPENSL
130 #include "backends/opensl.h"
131 #endif
132 #ifdef HAVE_OBOE
133 #include "backends/oboe.h"
134 #endif
135 #ifdef HAVE_SOLARIS
136 #include "backends/solaris.h"
137 #endif
138 #ifdef HAVE_SNDIO
139 #include "backends/sndio.h"
140 #endif
141 #ifdef HAVE_OSS
142 #include "backends/oss.h"
143 #endif
144 #ifdef HAVE_DSOUND
145 #include "backends/dsound.h"
146 #endif
147 #ifdef HAVE_WINMM
148 #include "backends/winmm.h"
149 #endif
150 #ifdef HAVE_PORTAUDIO
151 #include "backends/portaudio.h"
152 #endif
153 #ifdef HAVE_SDL2
154 #include "backends/sdl2.h"
155 #endif
156 #ifdef HAVE_OTHERIO
157 #include "backends/otherio.h"
158 #endif
159 #ifdef HAVE_WAVE
160 #include "backends/wave.h"
161 #endif
162
163 #ifdef ALSOFT_EAX
164 #include "al/eax/api.h"
165 #include "al/eax/globals.h"
166 #endif
167
168
169 /************************************************
170 * Library initialization
171 ************************************************/
172 #if defined(_WIN32) && !defined(AL_LIBTYPE_STATIC)
173 BOOL APIENTRY DllMain(HINSTANCE module, DWORD reason, LPVOID /*reserved*/)
174 {
175 switch(reason)
176 {
177 case DLL_PROCESS_ATTACH:
178 /* Pin the DLL so we won't get unloaded until the process terminates */
179 GetModuleHandleExW(GET_MODULE_HANDLE_EX_FLAG_PIN | GET_MODULE_HANDLE_EX_FLAG_FROM_ADDRESS,
180 reinterpret_cast<WCHAR*>(module), &module);
181 break;
182 }
183 return TRUE;
184 }
185 #endif
186
187 namespace {
188
189 using namespace std::string_view_literals;
190 using std::chrono::seconds;
191 using std::chrono::nanoseconds;
192
193 using voidp = void*;
194 using float2 = std::array<float,2>;
195
196
197 auto gProcessRunning = true;
198 struct ProcessWatcher {
199 ProcessWatcher() = default;
200 ProcessWatcher(const ProcessWatcher&) = delete;
201 ProcessWatcher& operator=(const ProcessWatcher&) = delete;
202 ~ProcessWatcher() { gProcessRunning = false; }
203 };
204 ProcessWatcher gProcessWatcher;
205
206 /************************************************
207 * Backends
208 ************************************************/
209 struct BackendInfo {
210 const char *name;
211 BackendFactory& (*getFactory)();
212 };
213
214 std::array BackendList{
215 #ifdef HAVE_PIPEWIRE
216 BackendInfo{"pipewire", PipeWireBackendFactory::getFactory},
217 #endif
218 #ifdef HAVE_PULSEAUDIO
219 BackendInfo{"pulse", PulseBackendFactory::getFactory},
220 #endif
221 #ifdef HAVE_WASAPI
222 BackendInfo{"wasapi", WasapiBackendFactory::getFactory},
223 #endif
224 #ifdef HAVE_COREAUDIO
225 BackendInfo{"core", CoreAudioBackendFactory::getFactory},
226 #endif
227 #ifdef HAVE_OBOE
228 BackendInfo{"oboe", OboeBackendFactory::getFactory},
229 #endif
230 #ifdef HAVE_OPENSL
231 BackendInfo{"opensl", OSLBackendFactory::getFactory},
232 #endif
233 #ifdef HAVE_ALSA
234 BackendInfo{"alsa", AlsaBackendFactory::getFactory},
235 #endif
236 #ifdef HAVE_SOLARIS
237 BackendInfo{"solaris", SolarisBackendFactory::getFactory},
238 #endif
239 #ifdef HAVE_SNDIO
240 BackendInfo{"sndio", SndIOBackendFactory::getFactory},
241 #endif
242 #ifdef HAVE_OSS
243 BackendInfo{"oss", OSSBackendFactory::getFactory},
244 #endif
245 #ifdef HAVE_JACK
246 BackendInfo{"jack", JackBackendFactory::getFactory},
247 #endif
248 #ifdef HAVE_DSOUND
249 BackendInfo{"dsound", DSoundBackendFactory::getFactory},
250 #endif
251 #ifdef HAVE_WINMM
252 BackendInfo{"winmm", WinMMBackendFactory::getFactory},
253 #endif
254 #ifdef HAVE_PORTAUDIO
255 BackendInfo{"port", PortBackendFactory::getFactory},
256 #endif
257 #ifdef HAVE_SDL2
258 BackendInfo{"sdl2", SDL2BackendFactory::getFactory},
259 #endif
260 #ifdef HAVE_OTHERIO
261 BackendInfo{"otherio", OtherIOBackendFactory::getFactory},
262 #endif
263
264 BackendInfo{"null", NullBackendFactory::getFactory},
265 #ifdef HAVE_WAVE
266 BackendInfo{"wave", WaveBackendFactory::getFactory},
267 #endif
268 };
269
270 BackendFactory *PlaybackFactory{};
271 BackendFactory *CaptureFactory{};
272
273
274 [[nodiscard]] constexpr auto GetNoErrorString() noexcept { return "No Error"; }
275 [[nodiscard]] constexpr auto GetInvalidDeviceString() noexcept { return "Invalid Device"; }
276 [[nodiscard]] constexpr auto GetInvalidContextString() noexcept { return "Invalid Context"; }
277 [[nodiscard]] constexpr auto GetInvalidEnumString() noexcept { return "Invalid Enum"; }
278 [[nodiscard]] constexpr auto GetInvalidValueString() noexcept { return "Invalid Value"; }
279 [[nodiscard]] constexpr auto GetOutOfMemoryString() noexcept { return "Out of Memory"; }
280
281 [[nodiscard]] constexpr auto GetDefaultName() noexcept { return "OpenAL Soft\0"; }
282
283 #ifdef _WIN32
284 [[nodiscard]] constexpr auto GetDevicePrefix() noexcept { return "OpenAL Soft on "sv; }
285 #else
286 [[nodiscard]] constexpr auto GetDevicePrefix() noexcept { return std::string_view{}; }
287 #endif
288
289 /************************************************
290 * Global variables
291 ************************************************/
292
293 /* Enumerated device names */
294 std::vector<std::string> alcAllDevicesArray;
295 std::vector<std::string> alcCaptureDeviceArray;
296 std::string alcAllDevicesList;
297 std::string alcCaptureDeviceList;
298
299 /* Default is always the first in the list */
300 std::string alcDefaultAllDevicesSpecifier;
301 std::string alcCaptureDefaultDeviceSpecifier;
302
303 std::atomic<ALCenum> LastNullDeviceError{ALC_NO_ERROR};
304
305 /* Flag to trap ALC device errors */
306 bool TrapALCError{false};
307
308 /* One-time configuration init control */
309 std::once_flag alc_config_once{};
310
311 /* Flag to specify if alcSuspendContext/alcProcessContext should defer/process
312 * updates.
313 */
314 bool SuspendDefers{true};
315
316 /* Initial seed for dithering. */
317 constexpr uint DitherRNGSeed{22222u};
318
319
320 /************************************************
321 * ALC information
322 ************************************************/
323 [[nodiscard]] constexpr auto GetNoDeviceExtList() noexcept -> const char*
324 {
325 return "ALC_ENUMERATE_ALL_EXT "
326 "ALC_ENUMERATION_EXT "
327 "ALC_EXT_CAPTURE "
328 "ALC_EXT_direct_context "
329 "ALC_EXT_EFX "
330 "ALC_EXT_thread_local_context "
331 "ALC_SOFT_loopback "
332 "ALC_SOFT_loopback_bformat "
333 "ALC_SOFT_reopen_device "
334 "ALC_SOFT_system_events";
335 }
336 [[nodiscard]] constexpr auto GetExtensionList() noexcept -> const char*
337 {
338 return "ALC_ENUMERATE_ALL_EXT "
339 "ALC_ENUMERATION_EXT "
340 "ALC_EXT_CAPTURE "
341 "ALC_EXT_debug "
342 "ALC_EXT_DEDICATED "
343 "ALC_EXT_direct_context "
344 "ALC_EXT_disconnect "
345 "ALC_EXT_EFX "
346 "ALC_EXT_thread_local_context "
347 "ALC_SOFT_device_clock "
348 "ALC_SOFT_HRTF "
349 "ALC_SOFT_loopback "
350 "ALC_SOFT_loopback_bformat "
351 "ALC_SOFT_output_limiter "
352 "ALC_SOFT_output_mode "
353 "ALC_SOFT_pause_device "
354 "ALC_SOFT_reopen_device "
355 "ALC_SOFT_system_events";
356 }
357
358 constexpr int alcMajorVersion{1};
359 constexpr int alcMinorVersion{1};
360
361 constexpr int alcEFXMajorVersion{1};
362 constexpr int alcEFXMinorVersion{0};
363
364
365 using DeviceRef = al::intrusive_ptr<ALCdevice>;
366
367
368 /************************************************
369 * Device lists
370 ************************************************/
371 std::vector<ALCdevice*> DeviceList;
372 std::vector<ALCcontext*> ContextList;
373
374 std::recursive_mutex ListLock;
375
376
377 void alc_initconfig()
378 {
379 if(auto loglevel = al::getenv("ALSOFT_LOGLEVEL"))
380 {
381 long lvl = strtol(loglevel->c_str(), nullptr, 0);
382 if(lvl >= static_cast<long>(LogLevel::Trace))
383 gLogLevel = LogLevel::Trace;
384 else if(lvl <= static_cast<long>(LogLevel::Disable))
385 gLogLevel = LogLevel::Disable;
386 else
387 gLogLevel = static_cast<LogLevel>(lvl);
388 }
389
390 #ifdef _WIN32
391 if(const auto logfile = al::getenv(L"ALSOFT_LOGFILE"))
392 {
393 FILE *logf{_wfopen(logfile->c_str(), L"wt")};
394 if(logf) gLogFile = logf;
395 else
396 {
397 auto u8name = wstr_to_utf8(*logfile);
398 ERR("Failed to open log file '%s'\n", u8name.c_str());
399 }
400 }
401 #else
402 if(const auto logfile = al::getenv("ALSOFT_LOGFILE"))
403 {
404 FILE *logf{fopen(logfile->c_str(), "wt")};
405 if(logf) gLogFile = logf;
406 else ERR("Failed to open log file '%s'\n", logfile->c_str());
407 }
408 #endif
409
410 TRACE("Initializing library v%s-%s %s\n", ALSOFT_VERSION, ALSOFT_GIT_COMMIT_HASH,
411 ALSOFT_GIT_BRANCH);
412 {
413 std::string names;
414 if(std::size(BackendList) < 1)
415 names = "(none)";
416 else
417 {
418 const al::span<const BackendInfo> infos{BackendList};
419 names = infos[0].name;
420 for(const auto &backend : infos.subspan<1>())
421 {
422 names += ", ";
423 names += backend.name;
424 }
425 }
426 TRACE("Supported backends: %s\n", names.c_str());
427 }
428 ReadALConfig();
429
430 if(auto suspendmode = al::getenv("__ALSOFT_SUSPEND_CONTEXT"))
431 {
432 if(al::case_compare(*suspendmode, "ignore"sv) == 0)
433 {
434 SuspendDefers = false;
435 TRACE("Selected context suspend behavior, \"ignore\"\n");
436 }
437 else
438 ERR("Unhandled context suspend behavior setting: \"%s\"\n", suspendmode->c_str());
439 }
440
441 int capfilter{0};
442 #if defined(HAVE_SSE4_1)
443 capfilter |= CPU_CAP_SSE | CPU_CAP_SSE2 | CPU_CAP_SSE3 | CPU_CAP_SSE4_1;
444 #elif defined(HAVE_SSE3)
445 capfilter |= CPU_CAP_SSE | CPU_CAP_SSE2 | CPU_CAP_SSE3;
446 #elif defined(HAVE_SSE2)
447 capfilter |= CPU_CAP_SSE | CPU_CAP_SSE2;
448 #elif defined(HAVE_SSE)
449 capfilter |= CPU_CAP_SSE;
450 #endif
451 #ifdef HAVE_NEON
452 capfilter |= CPU_CAP_NEON;
453 #endif
454 if(auto cpuopt = ConfigValueStr({}, {}, "disable-cpu-exts"sv))
455 {
456 std::string_view cpulist{*cpuopt};
457 if(al::case_compare(cpulist, "all"sv) == 0)
458 capfilter = 0;
459 else while(!cpulist.empty())
460 {
461 auto nextpos = std::min(cpulist.find(','), cpulist.size());
462 auto entry = cpulist.substr(0, nextpos);
463
464 while(nextpos < cpulist.size() && cpulist[nextpos] == ',')
465 ++nextpos;
466 cpulist.remove_prefix(nextpos);
467
468 while(!entry.empty() && std::isspace(entry.front()))
469 entry.remove_prefix(1);
470 while(!entry.empty() && std::isspace(entry.back()))
471 entry.remove_suffix(1);
472 if(entry.empty())
473 continue;
474
475 if(al::case_compare(entry, "sse"sv) == 0)
476 capfilter &= ~CPU_CAP_SSE;
477 else if(al::case_compare(entry, "sse2"sv) == 0)
478 capfilter &= ~CPU_CAP_SSE2;
479 else if(al::case_compare(entry, "sse3"sv) == 0)
480 capfilter &= ~CPU_CAP_SSE3;
481 else if(al::case_compare(entry, "sse4.1"sv) == 0)
482 capfilter &= ~CPU_CAP_SSE4_1;
483 else if(al::case_compare(entry, "neon"sv) == 0)
484 capfilter &= ~CPU_CAP_NEON;
485 else
486 WARN("Invalid CPU extension \"%.*s\"\n", al::sizei(entry), entry.data());
487 }
488 }
489 if(auto cpuopt = GetCPUInfo())
490 {
491 if(!cpuopt->mVendor.empty() || !cpuopt->mName.empty())
492 {
493 TRACE("Vendor ID: \"%s\"\n", cpuopt->mVendor.c_str());
494 TRACE("Name: \"%s\"\n", cpuopt->mName.c_str());
495 }
496 const int caps{cpuopt->mCaps};
497 TRACE("Extensions:%s%s%s%s%s%s\n",
498 ((capfilter&CPU_CAP_SSE) ? ((caps&CPU_CAP_SSE) ? " +SSE" : " -SSE") : ""),
499 ((capfilter&CPU_CAP_SSE2) ? ((caps&CPU_CAP_SSE2) ? " +SSE2" : " -SSE2") : ""),
500 ((capfilter&CPU_CAP_SSE3) ? ((caps&CPU_CAP_SSE3) ? " +SSE3" : " -SSE3") : ""),
501 ((capfilter&CPU_CAP_SSE4_1) ? ((caps&CPU_CAP_SSE4_1) ? " +SSE4.1" : " -SSE4.1") : ""),
502 ((capfilter&CPU_CAP_NEON) ? ((caps&CPU_CAP_NEON) ? " +NEON" : " -NEON") : ""),
503 ((!capfilter) ? " -none-" : ""));
504 CPUCapFlags = caps & capfilter;
505 }
506
507 if(auto priopt = ConfigValueInt({}, {}, "rt-prio"sv))
508 RTPrioLevel = *priopt;
509 if(auto limopt = ConfigValueBool({}, {}, "rt-time-limit"sv))
510 AllowRTTimeLimit = *limopt;
511
512 {
513 CompatFlagBitset compatflags{};
514 auto checkflag = [](const char *envname, const std::string_view optname) -> bool
515 {
516 if(auto optval = al::getenv(envname))
517 {
518 return al::case_compare(*optval, "true"sv) == 0
519 || strtol(optval->c_str(), nullptr, 0) == 1;
520 }
521 return GetConfigValueBool({}, "game_compat", optname, false);
522 };
523 sBufferSubDataCompat = checkflag("__ALSOFT_ENABLE_SUB_DATA_EXT", "enable-sub-data-ext"sv);
524 compatflags.set(CompatFlags::ReverseX, checkflag("__ALSOFT_REVERSE_X", "reverse-x"sv));
525 compatflags.set(CompatFlags::ReverseY, checkflag("__ALSOFT_REVERSE_Y", "reverse-y"sv));
526 compatflags.set(CompatFlags::ReverseZ, checkflag("__ALSOFT_REVERSE_Z", "reverse-z"sv));
527
528 aluInit(compatflags, ConfigValueFloat({}, "game_compat"sv, "nfc-scale"sv).value_or(1.0f));
529 }
530 Voice::InitMixer(ConfigValueStr({}, {}, "resampler"sv));
531
532 if(auto uhjfiltopt = ConfigValueStr({}, "uhj"sv, "decode-filter"sv))
533 {
534 if(al::case_compare(*uhjfiltopt, "fir256"sv) == 0)
535 UhjDecodeQuality = UhjQualityType::FIR256;
536 else if(al::case_compare(*uhjfiltopt, "fir512"sv) == 0)
537 UhjDecodeQuality = UhjQualityType::FIR512;
538 else if(al::case_compare(*uhjfiltopt, "iir"sv) == 0)
539 UhjDecodeQuality = UhjQualityType::IIR;
540 else
541 WARN("Unsupported uhj/decode-filter: %s\n", uhjfiltopt->c_str());
542 }
543 if(auto uhjfiltopt = ConfigValueStr({}, "uhj"sv, "encode-filter"sv))
544 {
545 if(al::case_compare(*uhjfiltopt, "fir256"sv) == 0)
546 UhjEncodeQuality = UhjQualityType::FIR256;
547 else if(al::case_compare(*uhjfiltopt, "fir512"sv) == 0)
548 UhjEncodeQuality = UhjQualityType::FIR512;
549 else if(al::case_compare(*uhjfiltopt, "iir"sv) == 0)
550 UhjEncodeQuality = UhjQualityType::IIR;
551 else
552 WARN("Unsupported uhj/encode-filter: %s\n", uhjfiltopt->c_str());
553 }
554
555 if(auto traperr = al::getenv("ALSOFT_TRAP_ERROR"); traperr
556 && (al::case_compare(*traperr, "true"sv) == 0
557 || std::strtol(traperr->c_str(), nullptr, 0) == 1))
558 {
559 TrapALError = true;
560 TrapALCError = true;
561 }
562 else
563 {
564 traperr = al::getenv("ALSOFT_TRAP_AL_ERROR");
565 if(traperr)
566 TrapALError = al::case_compare(*traperr, "true"sv) == 0
567 || strtol(traperr->c_str(), nullptr, 0) == 1;
568 else
569 TrapALError = GetConfigValueBool({}, {}, "trap-al-error"sv, false);
570
571 traperr = al::getenv("ALSOFT_TRAP_ALC_ERROR");
572 if(traperr)
573 TrapALCError = al::case_compare(*traperr, "true"sv) == 0
574 || strtol(traperr->c_str(), nullptr, 0) == 1;
575 else
576 TrapALCError = GetConfigValueBool({}, {}, "trap-alc-error"sv, false);
577 }
578
579 if(auto boostopt = ConfigValueFloat({}, "reverb"sv, "boost"sv))
580 {
581 const float valf{std::isfinite(*boostopt) ? std::clamp(*boostopt, -24.0f, 24.0f) : 0.0f};
582 ReverbBoost *= std::pow(10.0f, valf / 20.0f);
583 }
584
585 auto BackendListEnd = BackendList.end();
586 auto devopt = al::getenv("ALSOFT_DRIVERS");
587 if(!devopt) devopt = ConfigValueStr({}, {}, "drivers"sv);
588 if(devopt)
589 {
590 auto backendlist_cur = BackendList.begin();
591
592 bool endlist{true};
593 std::string_view drvlist{*devopt};
594 while(!drvlist.empty())
595 {
596 auto nextpos = std::min(drvlist.find(','), drvlist.size());
597 auto entry = drvlist.substr(0, nextpos);
598
599 endlist = true;
600 if(nextpos < drvlist.size())
601 {
602 endlist = false;
603 while(nextpos < drvlist.size() && drvlist[nextpos] == ',')
604 ++nextpos;
605 }
606 drvlist.remove_prefix(nextpos);
607
608 while(!entry.empty() && std::isspace(entry.front()))
609 entry.remove_prefix(1);
610 const bool delitem{!entry.empty() && entry.front() == '-'};
611 if(delitem) entry.remove_prefix(1);
612
613 while(!entry.empty() && std::isspace(entry.back()))
614 entry.remove_suffix(1);
615 if(entry.empty())
616 continue;
617
618 #ifdef HAVE_WASAPI
619 /* HACK: For backwards compatibility, convert backend references of
620 * mmdevapi to wasapi. This should eventually be removed.
621 */
622 if(entry == "mmdevapi"sv)
623 entry = "wasapi"sv;
624 #endif
625
626 auto find_backend = [entry](const BackendInfo &backend) -> bool
627 { return entry == backend.name; };
628 auto this_backend = std::find_if(BackendList.begin(), BackendListEnd, find_backend);
629
630 if(this_backend == BackendListEnd)
631 continue;
632
633 if(delitem)
634 BackendListEnd = std::move(this_backend+1, BackendListEnd, this_backend);
635 else
636 backendlist_cur = std::rotate(backendlist_cur, this_backend, this_backend+1);
637 }
638
639 if(endlist)
640 BackendListEnd = backendlist_cur;
641 }
642
643 auto init_backend = [](BackendInfo &backend) -> void
644 {
645 if(PlaybackFactory && CaptureFactory)
646 return;
647
648 BackendFactory &factory = backend.getFactory();
649 if(!factory.init())
650 {
651 WARN("Failed to initialize backend \"%s\"\n", backend.name);
652 return;
653 }
654
655 TRACE("Initialized backend \"%s\"\n", backend.name);
656 if(!PlaybackFactory && factory.querySupport(BackendType::Playback))
657 {
658 PlaybackFactory = &factory;
659 TRACE("Added \"%s\" for playback\n", backend.name);
660 }
661 if(!CaptureFactory && factory.querySupport(BackendType::Capture))
662 {
663 CaptureFactory = &factory;
664 TRACE("Added \"%s\" for capture\n", backend.name);
665 }
666 };
667 std::for_each(BackendList.begin(), BackendListEnd, init_backend);
668
669 LoopbackBackendFactory::getFactory().init();
670
671 if(!PlaybackFactory)
672 WARN("No playback backend available!\n");
673 if(!CaptureFactory)
674 WARN("No capture backend available!\n");
675
676 if(auto exclopt = ConfigValueStr({}, {}, "excludefx"sv))
677 {
678 std::string_view exclude{*exclopt};
679 while(!exclude.empty())
680 {
681 const auto nextpos = exclude.find(',');
682 const auto entry = exclude.substr(0, nextpos);
683 exclude.remove_prefix((nextpos < exclude.size()) ? nextpos+1 : exclude.size());
684
685 std::for_each(gEffectList.cbegin(), gEffectList.cend(),
686 [entry](const EffectList &effectitem) noexcept
687 {
688 if(entry == std::data(effectitem.name))
689 DisabledEffects.set(effectitem.type);
690 });
691 }
692 }
693
694 InitEffect(&ALCcontext::sDefaultEffect);
695 auto defrevopt = al::getenv("ALSOFT_DEFAULT_REVERB");
696 if(!defrevopt) defrevopt = ConfigValueStr({}, {}, "default-reverb"sv);
697 if(defrevopt) LoadReverbPreset(*defrevopt, &ALCcontext::sDefaultEffect);
698
699 #ifdef ALSOFT_EAX
700 {
701 if(const auto eax_enable_opt = ConfigValueBool({}, "eax", "enable"))
702 {
703 eax_g_is_enabled = *eax_enable_opt;
704 if(!eax_g_is_enabled)
705 TRACE("%s\n", "EAX disabled by a configuration.");
706 }
707 else
708 eax_g_is_enabled = true;
709
710 if((DisabledEffects.test(EAXREVERB_EFFECT) || DisabledEffects.test(CHORUS_EFFECT))
711 && eax_g_is_enabled)
712 {
713 eax_g_is_enabled = false;
714 TRACE("EAX disabled because %s disabled.\n",
715 (DisabledEffects.test(EAXREVERB_EFFECT) && DisabledEffects.test(CHORUS_EFFECT))
716 ? "EAXReverb and Chorus are" :
717 DisabledEffects.test(EAXREVERB_EFFECT) ? "EAXReverb is" :
718 DisabledEffects.test(CHORUS_EFFECT) ? "Chorus is" : "");
719 }
720 }
721 #endif // ALSOFT_EAX
722 }
723 inline void InitConfig()
724 { std::call_once(alc_config_once, [](){alc_initconfig();}); }
725
726
727 /************************************************
728 * Device enumeration
729 ************************************************/
730 void ProbeAllDevicesList()
731 {
732 InitConfig();
733
734 std::lock_guard<std::recursive_mutex> listlock{ListLock};
735 if(!PlaybackFactory)
736 {
737 decltype(alcAllDevicesArray){}.swap(alcAllDevicesArray);
738 decltype(alcAllDevicesList){}.swap(alcAllDevicesList);
739 }
740 else
741 {
742 alcAllDevicesArray = PlaybackFactory->enumerate(BackendType::Playback);
743 if(const auto prefix = GetDevicePrefix(); !prefix.empty())
744 std::for_each(alcAllDevicesArray.begin(), alcAllDevicesArray.end(),
745 [prefix](std::string &name) { name.insert(0, prefix); });
746
747 decltype(alcAllDevicesList){}.swap(alcAllDevicesList);
748 if(alcAllDevicesArray.empty())
749 alcAllDevicesList += '\0';
750 else for(auto &devname : alcAllDevicesArray)
751 alcAllDevicesList.append(devname) += '\0';
752 }
753 }
754 void ProbeCaptureDeviceList()
755 {
756 InitConfig();
757
758 std::lock_guard<std::recursive_mutex> listlock{ListLock};
759 if(!CaptureFactory)
760 {
761 decltype(alcCaptureDeviceArray){}.swap(alcCaptureDeviceArray);
762 decltype(alcCaptureDeviceList){}.swap(alcCaptureDeviceList);
763 }
764 else
765 {
766 alcCaptureDeviceArray = CaptureFactory->enumerate(BackendType::Capture);
767 if(const auto prefix = GetDevicePrefix(); !prefix.empty())
768 std::for_each(alcCaptureDeviceArray.begin(), alcCaptureDeviceArray.end(),
769 [prefix](std::string &name) { name.insert(0, prefix); });
770
771 decltype(alcCaptureDeviceList){}.swap(alcCaptureDeviceList);
772 if(alcCaptureDeviceArray.empty())
773 alcCaptureDeviceList += '\0';
774 else for(auto &devname : alcCaptureDeviceArray)
775 alcCaptureDeviceList.append(devname) += '\0';
776 }
777 }
778
779
780 al::span<const ALCint> SpanFromAttributeList(const ALCint *attribs) noexcept
781 {
782 al::span<const ALCint> attrSpan;
783 if(attribs)
784 {
785 const ALCint *attrEnd{attribs};
786 while(*attrEnd != 0)
787 attrEnd += 2; /* NOLINT(cppcoreguidelines-pro-bounds-pointer-arithmetic) */
788 attrSpan = {attribs, attrEnd};
789 }
790 return attrSpan;
791 }
792
793 struct DevFmtPair { DevFmtChannels chans; DevFmtType type; };
794 std::optional<DevFmtPair> DecomposeDevFormat(ALenum format)
795 {
796 struct FormatType {
797 ALenum format;
798 DevFmtChannels channels;
799 DevFmtType type;
800 };
801 static constexpr std::array list{
802 FormatType{AL_FORMAT_MONO8, DevFmtMono, DevFmtUByte},
803 FormatType{AL_FORMAT_MONO16, DevFmtMono, DevFmtShort},
804 FormatType{AL_FORMAT_MONO_I32, DevFmtMono, DevFmtInt},
805 FormatType{AL_FORMAT_MONO_FLOAT32, DevFmtMono, DevFmtFloat},
806
807 FormatType{AL_FORMAT_STEREO8, DevFmtStereo, DevFmtUByte},
808 FormatType{AL_FORMAT_STEREO16, DevFmtStereo, DevFmtShort},
809 FormatType{AL_FORMAT_STEREO_I32, DevFmtStereo, DevFmtInt},
810 FormatType{AL_FORMAT_STEREO_FLOAT32, DevFmtStereo, DevFmtFloat},
811
812 FormatType{AL_FORMAT_QUAD8, DevFmtQuad, DevFmtUByte},
813 FormatType{AL_FORMAT_QUAD16, DevFmtQuad, DevFmtShort},
814 FormatType{AL_FORMAT_QUAD32, DevFmtQuad, DevFmtFloat},
815 FormatType{AL_FORMAT_QUAD_I32, DevFmtQuad, DevFmtInt},
816 FormatType{AL_FORMAT_QUAD_FLOAT32, DevFmtQuad, DevFmtFloat},
817
818 FormatType{AL_FORMAT_51CHN8, DevFmtX51, DevFmtUByte},
819 FormatType{AL_FORMAT_51CHN16, DevFmtX51, DevFmtShort},
820 FormatType{AL_FORMAT_51CHN32, DevFmtX51, DevFmtFloat},
821 FormatType{AL_FORMAT_51CHN_I32, DevFmtX51, DevFmtInt},
822 FormatType{AL_FORMAT_51CHN_FLOAT32, DevFmtX51, DevFmtFloat},
823
824 FormatType{AL_FORMAT_61CHN8, DevFmtX61, DevFmtUByte},
825 FormatType{AL_FORMAT_61CHN16, DevFmtX61, DevFmtShort},
826 FormatType{AL_FORMAT_61CHN32, DevFmtX61, DevFmtFloat},
827 FormatType{AL_FORMAT_61CHN_I32, DevFmtX61, DevFmtInt},
828 FormatType{AL_FORMAT_61CHN_FLOAT32, DevFmtX61, DevFmtFloat},
829
830 FormatType{AL_FORMAT_71CHN8, DevFmtX71, DevFmtUByte},
831 FormatType{AL_FORMAT_71CHN16, DevFmtX71, DevFmtShort},
832 FormatType{AL_FORMAT_71CHN32, DevFmtX71, DevFmtFloat},
833 FormatType{AL_FORMAT_71CHN_I32, DevFmtX71, DevFmtInt},
834 FormatType{AL_FORMAT_71CHN_FLOAT32, DevFmtX71, DevFmtFloat},
835 };
836
837 for(const auto &item : list)
838 {
839 if(item.format == format)
840 return DevFmtPair{item.channels, item.type};
841 }
842
843 return std::nullopt;
844 }
845
846 std::optional<DevFmtType> DevFmtTypeFromEnum(ALCenum type)
847 {
848 switch(type)
849 {
850 case ALC_BYTE_SOFT: return DevFmtByte;
851 case ALC_UNSIGNED_BYTE_SOFT: return DevFmtUByte;
852 case ALC_SHORT_SOFT: return DevFmtShort;
853 case ALC_UNSIGNED_SHORT_SOFT: return DevFmtUShort;
854 case ALC_INT_SOFT: return DevFmtInt;
855 case ALC_UNSIGNED_INT_SOFT: return DevFmtUInt;
856 case ALC_FLOAT_SOFT: return DevFmtFloat;
857 }
858 WARN("Unsupported format type: 0x%04x\n", type);
859 return std::nullopt;
860 }
861 ALCenum EnumFromDevFmt(DevFmtType type)
862 {
863 switch(type)
864 {
865 case DevFmtByte: return ALC_BYTE_SOFT;
866 case DevFmtUByte: return ALC_UNSIGNED_BYTE_SOFT;
867 case DevFmtShort: return ALC_SHORT_SOFT;
868 case DevFmtUShort: return ALC_UNSIGNED_SHORT_SOFT;
869 case DevFmtInt: return ALC_INT_SOFT;
870 case DevFmtUInt: return ALC_UNSIGNED_INT_SOFT;
871 case DevFmtFloat: return ALC_FLOAT_SOFT;
872 }
873 throw std::runtime_error{"Invalid DevFmtType: "+std::to_string(int(type))};
874 }
875
876 std::optional<DevFmtChannels> DevFmtChannelsFromEnum(ALCenum channels)
877 {
878 switch(channels)
879 {
880 case ALC_MONO_SOFT: return DevFmtMono;
881 case ALC_STEREO_SOFT: return DevFmtStereo;
882 case ALC_QUAD_SOFT: return DevFmtQuad;
883 case ALC_5POINT1_SOFT: return DevFmtX51;
884 case ALC_6POINT1_SOFT: return DevFmtX61;
885 case ALC_7POINT1_SOFT: return DevFmtX71;
886 case ALC_BFORMAT3D_SOFT: return DevFmtAmbi3D;
887 }
888 WARN("Unsupported format channels: 0x%04x\n", channels);
889 return std::nullopt;
890 }
891 ALCenum EnumFromDevFmt(DevFmtChannels channels)
892 {
893 switch(channels)
894 {
895 case DevFmtMono: return ALC_MONO_SOFT;
896 case DevFmtStereo: return ALC_STEREO_SOFT;
897 case DevFmtQuad: return ALC_QUAD_SOFT;
898 case DevFmtX51: return ALC_5POINT1_SOFT;
899 case DevFmtX61: return ALC_6POINT1_SOFT;
900 case DevFmtX71: return ALC_7POINT1_SOFT;
901 case DevFmtAmbi3D: return ALC_BFORMAT3D_SOFT;
902 /* FIXME: Shouldn't happen. */
903 case DevFmtX714:
904 case DevFmtX7144:
905 case DevFmtX3D71: break;
906 }
907 throw std::runtime_error{"Invalid DevFmtChannels: "+std::to_string(int(channels))};
908 }
909
910 std::optional<DevAmbiLayout> DevAmbiLayoutFromEnum(ALCenum layout)
911 {
912 switch(layout)
913 {
914 case ALC_FUMA_SOFT: return DevAmbiLayout::FuMa;
915 case ALC_ACN_SOFT: return DevAmbiLayout::ACN;
916 }
917 WARN("Unsupported ambisonic layout: 0x%04x\n", layout);
918 return std::nullopt;
919 }
920 ALCenum EnumFromDevAmbi(DevAmbiLayout layout)
921 {
922 switch(layout)
923 {
924 case DevAmbiLayout::FuMa: return ALC_FUMA_SOFT;
925 case DevAmbiLayout::ACN: return ALC_ACN_SOFT;
926 }
927 throw std::runtime_error{"Invalid DevAmbiLayout: "+std::to_string(int(layout))};
928 }
929
930 std::optional<DevAmbiScaling> DevAmbiScalingFromEnum(ALCenum scaling)
931 {
932 switch(scaling)
933 {
934 case ALC_FUMA_SOFT: return DevAmbiScaling::FuMa;
935 case ALC_SN3D_SOFT: return DevAmbiScaling::SN3D;
936 case ALC_N3D_SOFT: return DevAmbiScaling::N3D;
937 }
938 WARN("Unsupported ambisonic scaling: 0x%04x\n", scaling);
939 return std::nullopt;
940 }
941 ALCenum EnumFromDevAmbi(DevAmbiScaling scaling)
942 {
943 switch(scaling)
944 {
945 case DevAmbiScaling::FuMa: return ALC_FUMA_SOFT;
946 case DevAmbiScaling::SN3D: return ALC_SN3D_SOFT;
947 case DevAmbiScaling::N3D: return ALC_N3D_SOFT;
948 }
949 throw std::runtime_error{"Invalid DevAmbiScaling: "+std::to_string(int(scaling))};
950 }
951
952
953 /* Downmixing channel arrays, to map a device format's missing channels to
954 * existing ones. Based on what PipeWire does, though simplified.
955 */
956 constexpr float inv_sqrt2f{static_cast<float>(1.0 / al::numbers::sqrt2)};
957 constexpr std::array FrontStereo3dB{
958 InputRemixMap::TargetMix{FrontLeft, inv_sqrt2f},
959 InputRemixMap::TargetMix{FrontRight, inv_sqrt2f}
960 };
961 constexpr std::array FrontStereo6dB{
962 InputRemixMap::TargetMix{FrontLeft, 0.5f},
963 InputRemixMap::TargetMix{FrontRight, 0.5f}
964 };
965 constexpr std::array SideStereo3dB{
966 InputRemixMap::TargetMix{SideLeft, inv_sqrt2f},
967 InputRemixMap::TargetMix{SideRight, inv_sqrt2f}
968 };
969 constexpr std::array BackStereo3dB{
970 InputRemixMap::TargetMix{BackLeft, inv_sqrt2f},
971 InputRemixMap::TargetMix{BackRight, inv_sqrt2f}
972 };
973 constexpr std::array FrontLeft3dB{InputRemixMap::TargetMix{FrontLeft, inv_sqrt2f}};
974 constexpr std::array FrontRight3dB{InputRemixMap::TargetMix{FrontRight, inv_sqrt2f}};
975 constexpr std::array SideLeft0dB{InputRemixMap::TargetMix{SideLeft, 1.0f}};
976 constexpr std::array SideRight0dB{InputRemixMap::TargetMix{SideRight, 1.0f}};
977 constexpr std::array BackLeft0dB{InputRemixMap::TargetMix{BackLeft, 1.0f}};
978 constexpr std::array BackRight0dB{InputRemixMap::TargetMix{BackRight, 1.0f}};
979 constexpr std::array BackCenter3dB{InputRemixMap::TargetMix{BackCenter, inv_sqrt2f}};
980
981 constexpr std::array StereoDownmix{
982 InputRemixMap{FrontCenter, FrontStereo3dB},
983 InputRemixMap{SideLeft, FrontLeft3dB},
984 InputRemixMap{SideRight, FrontRight3dB},
985 InputRemixMap{BackLeft, FrontLeft3dB},
986 InputRemixMap{BackRight, FrontRight3dB},
987 InputRemixMap{BackCenter, FrontStereo6dB},
988 };
989 constexpr std::array QuadDownmix{
990 InputRemixMap{FrontCenter, FrontStereo3dB},
991 InputRemixMap{SideLeft, BackLeft0dB},
992 InputRemixMap{SideRight, BackRight0dB},
993 InputRemixMap{BackCenter, BackStereo3dB},
994 };
995 constexpr std::array X51Downmix{
996 InputRemixMap{BackLeft, SideLeft0dB},
997 InputRemixMap{BackRight, SideRight0dB},
998 InputRemixMap{BackCenter, SideStereo3dB},
999 };
1000 constexpr std::array X61Downmix{
1001 InputRemixMap{BackLeft, BackCenter3dB},
1002 InputRemixMap{BackRight, BackCenter3dB},
1003 };
1004 constexpr std::array X71Downmix{
1005 InputRemixMap{BackCenter, BackStereo3dB},
1006 };
1007
1008
1009 std::unique_ptr<Compressor> CreateDeviceLimiter(const ALCdevice *device, const float threshold)
1010 {
1011 static constexpr bool AutoKnee{true};
1012 static constexpr bool AutoAttack{true};
1013 static constexpr bool AutoRelease{true};
1014 static constexpr bool AutoPostGain{true};
1015 static constexpr bool AutoDeclip{true};
1016 static constexpr float LookAheadTime{0.001f};
1017 static constexpr float HoldTime{0.002f};
1018 static constexpr float PreGainDb{0.0f};
1019 static constexpr float PostGainDb{0.0f};
1020 static constexpr float Ratio{std::numeric_limits<float>::infinity()};
1021 static constexpr float KneeDb{0.0f};
1022 static constexpr float AttackTime{0.02f};
1023 static constexpr float ReleaseTime{0.2f};
1024
1025 return Compressor::Create(device->RealOut.Buffer.size(), static_cast<float>(device->Frequency),
1026 AutoKnee, AutoAttack, AutoRelease, AutoPostGain, AutoDeclip, LookAheadTime, HoldTime,
1027 PreGainDb, PostGainDb, threshold, Ratio, KneeDb, AttackTime, ReleaseTime);
1028 }
1029
1030 /**
1031 * Updates the device's base clock time with however many samples have been
1032 * done. This is used so frequency changes on the device don't cause the time
1033 * to jump forward or back. Must not be called while the device is running/
1034 * mixing.
1035 */
1036 inline void UpdateClockBase(ALCdevice *device)
1037 {
1038 const auto mixLock = device->getWriteMixLock();
1039
1040 auto samplesDone = device->mSamplesDone.load(std::memory_order_relaxed);
1041 auto clockBase = device->mClockBase.load(std::memory_order_relaxed);
1042
1043 clockBase += nanoseconds{seconds{samplesDone}} / device->Frequency;
1044 device->mClockBase.store(clockBase, std::memory_order_relaxed);
1045 device->mSamplesDone.store(0, std::memory_order_relaxed);
1046 }
1047
1048 /**
1049 * Updates device parameters according to the attribute list (caller is
1050 * responsible for holding the list lock).
1051 */
1052 ALCenum UpdateDeviceParams(ALCdevice *device, const al::span<const int> attrList)
1053 {
1054 if(attrList.empty() && device->Type == DeviceType::Loopback)
1055 {
1056 WARN("Missing attributes for loopback device\n");
1057 return ALC_INVALID_VALUE;
1058 }
1059
1060 uint numMono{device->NumMonoSources};
1061 uint numStereo{device->NumStereoSources};
1062 uint numSends{device->NumAuxSends};
1063 std::optional<StereoEncoding> stereomode;
1064 std::optional<bool> optlimit;
1065 std::optional<uint> optsrate;
1066 std::optional<DevFmtChannels> optchans;
1067 std::optional<DevFmtType> opttype;
1068 std::optional<DevAmbiLayout> optlayout;
1069 std::optional<DevAmbiScaling> optscale;
1070 uint period_size{DefaultUpdateSize};
1071 uint buffer_size{DefaultUpdateSize * DefaultNumUpdates};
1072 int hrtf_id{-1};
1073 uint aorder{0u};
1074
1075 if(device->Type != DeviceType::Loopback)
1076 {
1077 /* Get default settings from the user configuration */
1078
1079 if(auto freqopt = device->configValue<uint>({}, "frequency"))
1080 {
1081 optsrate = std::clamp<uint>(*freqopt, MinOutputRate, MaxOutputRate);
1082
1083 const double scale{static_cast<double>(*optsrate) / double{DefaultOutputRate}};
1084 period_size = static_cast<uint>(std::lround(period_size * scale));
1085 }
1086
1087 if(auto persizeopt = device->configValue<uint>({}, "period_size"))
1088 period_size = std::clamp(*persizeopt, 64u, 8192u);
1089 if(auto numperopt = device->configValue<uint>({}, "periods"))
1090 buffer_size = std::clamp(*numperopt, 2u, 16u) * period_size;
1091 else
1092 buffer_size = period_size * uint{DefaultNumUpdates};
1093
1094 if(auto typeopt = device->configValue<std::string>({}, "sample-type"))
1095 {
1096 struct TypeMap {
1097 std::string_view name;
1098 DevFmtType type;
1099 };
1100 constexpr std::array typelist{
1101 TypeMap{"int8"sv, DevFmtByte },
1102 TypeMap{"uint8"sv, DevFmtUByte },
1103 TypeMap{"int16"sv, DevFmtShort },
1104 TypeMap{"uint16"sv, DevFmtUShort},
1105 TypeMap{"int32"sv, DevFmtInt },
1106 TypeMap{"uint32"sv, DevFmtUInt },
1107 TypeMap{"float32"sv, DevFmtFloat },
1108 };
1109
1110 const ALCchar *fmt{typeopt->c_str()};
1111 auto iter = std::find_if(typelist.begin(), typelist.end(),
1112 [svfmt=std::string_view{fmt}](const TypeMap &entry) -> bool
1113 { return al::case_compare(entry.name, svfmt) == 0; });
1114 if(iter == typelist.end())
1115 ERR("Unsupported sample-type: %s\n", fmt);
1116 else
1117 opttype = iter->type;
1118 }
1119 if(auto chanopt = device->configValue<std::string>({}, "channels"))
1120 {
1121 struct ChannelMap {
1122 std::string_view name;
1123 DevFmtChannels chans;
1124 uint8_t order;
1125 };
1126 constexpr std::array chanlist{
1127 ChannelMap{"mono"sv, DevFmtMono, 0},
1128 ChannelMap{"stereo"sv, DevFmtStereo, 0},
1129 ChannelMap{"quad"sv, DevFmtQuad, 0},
1130 ChannelMap{"surround51"sv, DevFmtX51, 0},
1131 ChannelMap{"surround61"sv, DevFmtX61, 0},
1132 ChannelMap{"surround71"sv, DevFmtX71, 0},
1133 ChannelMap{"surround714"sv, DevFmtX714, 0},
1134 ChannelMap{"surround7144"sv, DevFmtX7144, 0},
1135 ChannelMap{"surround3d71"sv, DevFmtX3D71, 0},
1136 ChannelMap{"surround51rear"sv, DevFmtX51, 0},
1137 ChannelMap{"ambi1"sv, DevFmtAmbi3D, 1},
1138 ChannelMap{"ambi2"sv, DevFmtAmbi3D, 2},
1139 ChannelMap{"ambi3"sv, DevFmtAmbi3D, 3},
1140 };
1141
1142 const ALCchar *fmt{chanopt->c_str()};
1143 auto iter = std::find_if(chanlist.begin(), chanlist.end(),
1144 [svfmt=std::string_view{fmt}](const ChannelMap &entry) -> bool
1145 { return al::case_compare(entry.name, svfmt) == 0; });
1146 if(iter == chanlist.end())
1147 ERR("Unsupported channels: %s\n", fmt);
1148 else
1149 {
1150 optchans = iter->chans;
1151 aorder = iter->order;
1152 }
1153 }
1154 if(auto ambiopt = device->configValue<std::string>({}, "ambi-format"sv))
1155 {
1156 if(al::case_compare(*ambiopt, "fuma"sv) == 0)
1157 {
1158 optlayout = DevAmbiLayout::FuMa;
1159 optscale = DevAmbiScaling::FuMa;
1160 }
1161 else if(al::case_compare(*ambiopt, "acn+fuma"sv) == 0)
1162 {
1163 optlayout = DevAmbiLayout::ACN;
1164 optscale = DevAmbiScaling::FuMa;
1165 }
1166 else if(al::case_compare(*ambiopt, "ambix"sv) == 0
1167 || al::case_compare(*ambiopt, "acn+sn3d"sv) == 0)
1168 {
1169 optlayout = DevAmbiLayout::ACN;
1170 optscale = DevAmbiScaling::SN3D;
1171 }
1172 else if(al::case_compare(*ambiopt, "acn+n3d"sv) == 0)
1173 {
1174 optlayout = DevAmbiLayout::ACN;
1175 optscale = DevAmbiScaling::N3D;
1176 }
1177 else
1178 ERR("Unsupported ambi-format: %s\n", ambiopt->c_str());
1179 }
1180
1181 if(auto hrtfopt = device->configValue<std::string>({}, "hrtf"sv))
1182 {
1183 WARN("general/hrtf is deprecated, please use stereo-encoding instead\n");
1184
1185 if(al::case_compare(*hrtfopt, "true"sv) == 0)
1186 stereomode = StereoEncoding::Hrtf;
1187 else if(al::case_compare(*hrtfopt, "false"sv) == 0)
1188 {
1189 if(!stereomode || *stereomode == StereoEncoding::Hrtf)
1190 stereomode = StereoEncoding::Default;
1191 }
1192 else if(al::case_compare(*hrtfopt, "auto"sv) != 0)
1193 ERR("Unexpected hrtf value: %s\n", hrtfopt->c_str());
1194 }
1195 }
1196
1197 if(auto encopt = device->configValue<std::string>({}, "stereo-encoding"sv))
1198 {
1199 if(al::case_compare(*encopt, "basic"sv) == 0 || al::case_compare(*encopt, "panpot"sv) == 0)
1200 stereomode = StereoEncoding::Basic;
1201 else if(al::case_compare(*encopt, "uhj") == 0)
1202 stereomode = StereoEncoding::Uhj;
1203 else if(al::case_compare(*encopt, "hrtf") == 0)
1204 stereomode = StereoEncoding::Hrtf;
1205 else
1206 ERR("Unexpected stereo-encoding: %s\n", encopt->c_str());
1207 }
1208
1209 // Check for app-specified attributes
1210 if(!attrList.empty())
1211 {
1212 ALenum outmode{ALC_ANY_SOFT};
1213 std::optional<bool> opthrtf;
1214 int freqAttr{};
1215
1216 #define ATTRIBUTE(a) a: TRACE("%s = %d\n", #a, attrList[attrIdx + 1]);
1217 for(size_t attrIdx{0};attrIdx < attrList.size();attrIdx+=2)
1218 {
1219 switch(attrList[attrIdx])
1220 {
1221 case ATTRIBUTE(ALC_FORMAT_CHANNELS_SOFT)
1222 if(device->Type == DeviceType::Loopback)
1223 optchans = DevFmtChannelsFromEnum(attrList[attrIdx + 1]);
1224 break;
1225
1226 case ATTRIBUTE(ALC_FORMAT_TYPE_SOFT)
1227 if(device->Type == DeviceType::Loopback)
1228 opttype = DevFmtTypeFromEnum(attrList[attrIdx + 1]);
1229 break;
1230
1231 case ATTRIBUTE(ALC_FREQUENCY)
1232 freqAttr = attrList[attrIdx + 1];
1233 break;
1234
1235 case ATTRIBUTE(ALC_AMBISONIC_LAYOUT_SOFT)
1236 if(device->Type == DeviceType::Loopback)
1237 optlayout = DevAmbiLayoutFromEnum(attrList[attrIdx + 1]);
1238 break;
1239
1240 case ATTRIBUTE(ALC_AMBISONIC_SCALING_SOFT)
1241 if(device->Type == DeviceType::Loopback)
1242 optscale = DevAmbiScalingFromEnum(attrList[attrIdx + 1]);
1243 break;
1244
1245 case ATTRIBUTE(ALC_AMBISONIC_ORDER_SOFT)
1246 if(device->Type == DeviceType::Loopback)
1247 aorder = static_cast<uint>(attrList[attrIdx + 1]);
1248 break;
1249
1250 case ATTRIBUTE(ALC_MONO_SOURCES)
1251 numMono = static_cast<uint>(attrList[attrIdx + 1]);
1252 if(numMono > INT_MAX) numMono = 0;
1253 break;
1254
1255 case ATTRIBUTE(ALC_STEREO_SOURCES)
1256 numStereo = static_cast<uint>(attrList[attrIdx + 1]);
1257 if(numStereo > INT_MAX) numStereo = 0;
1258 break;
1259
1260 case ATTRIBUTE(ALC_MAX_AUXILIARY_SENDS)
1261 numSends = static_cast<uint>(attrList[attrIdx + 1]);
1262 if(numSends > uint{std::numeric_limits<int>::max()}) numSends = 0;
1263 else numSends = std::min(numSends, uint{MaxSendCount});
1264 break;
1265
1266 case ATTRIBUTE(ALC_HRTF_SOFT)
1267 if(attrList[attrIdx + 1] == ALC_FALSE)
1268 opthrtf = false;
1269 else if(attrList[attrIdx + 1] == ALC_TRUE)
1270 opthrtf = true;
1271 else if(attrList[attrIdx + 1] == ALC_DONT_CARE_SOFT)
1272 opthrtf = std::nullopt;
1273 break;
1274
1275 case ATTRIBUTE(ALC_HRTF_ID_SOFT)
1276 hrtf_id = attrList[attrIdx + 1];
1277 break;
1278
1279 case ATTRIBUTE(ALC_OUTPUT_LIMITER_SOFT)
1280 if(attrList[attrIdx + 1] == ALC_FALSE)
1281 optlimit = false;
1282 else if(attrList[attrIdx + 1] == ALC_TRUE)
1283 optlimit = true;
1284 else if(attrList[attrIdx + 1] == ALC_DONT_CARE_SOFT)
1285 optlimit = std::nullopt;
1286 break;
1287
1288 case ATTRIBUTE(ALC_OUTPUT_MODE_SOFT)
1289 outmode = attrList[attrIdx + 1];
1290 break;
1291
1292 default:
1293 TRACE("0x%04X = %d (0x%x)\n", attrList[attrIdx],
1294 attrList[attrIdx + 1], attrList[attrIdx + 1]);
1295 break;
1296 }
1297 }
1298 #undef ATTRIBUTE
1299
1300 if(device->Type == DeviceType::Loopback)
1301 {
1302 if(!optchans || !opttype)
1303 return ALC_INVALID_VALUE;
1304 if(freqAttr < int{MinOutputRate} || freqAttr > int{MaxOutputRate})
1305 return ALC_INVALID_VALUE;
1306 if(*optchans == DevFmtAmbi3D)
1307 {
1308 if(!optlayout || !optscale)
1309 return ALC_INVALID_VALUE;
1310 if(aorder < 1 || aorder > MaxAmbiOrder)
1311 return ALC_INVALID_VALUE;
1312 if((*optlayout == DevAmbiLayout::FuMa || *optscale == DevAmbiScaling::FuMa)
1313 && aorder > 3)
1314 return ALC_INVALID_VALUE;
1315 }
1316 else if(*optchans == DevFmtStereo)
1317 {
1318 if(opthrtf)
1319 {
1320 if(*opthrtf)
1321 stereomode = StereoEncoding::Hrtf;
1322 else
1323 {
1324 if(stereomode.value_or(StereoEncoding::Hrtf) == StereoEncoding::Hrtf)
1325 stereomode = StereoEncoding::Default;
1326 }
1327 }
1328
1329 if(outmode == ALC_STEREO_BASIC_SOFT)
1330 stereomode = StereoEncoding::Basic;
1331 else if(outmode == ALC_STEREO_UHJ_SOFT)
1332 stereomode = StereoEncoding::Uhj;
1333 else if(outmode == ALC_STEREO_HRTF_SOFT)
1334 stereomode = StereoEncoding::Hrtf;
1335 }
1336
1337 optsrate = static_cast<uint>(freqAttr);
1338 }
1339 else
1340 {
1341 if(opthrtf)
1342 {
1343 if(*opthrtf)
1344 stereomode = StereoEncoding::Hrtf;
1345 else
1346 {
1347 if(stereomode.value_or(StereoEncoding::Hrtf) == StereoEncoding::Hrtf)
1348 stereomode = StereoEncoding::Default;
1349 }
1350 }
1351
1352 if(outmode != ALC_ANY_SOFT)
1353 {
1354 using OutputMode = ALCdevice::OutputMode;
1355 switch(OutputMode(outmode))
1356 {
1357 case OutputMode::Any: break;
1358 case OutputMode::Mono: optchans = DevFmtMono; break;
1359 case OutputMode::Stereo: optchans = DevFmtStereo; break;
1360 case OutputMode::StereoBasic:
1361 optchans = DevFmtStereo;
1362 stereomode = StereoEncoding::Basic;
1363 break;
1364 case OutputMode::Uhj2:
1365 optchans = DevFmtStereo;
1366 stereomode = StereoEncoding::Uhj;
1367 break;
1368 case OutputMode::Hrtf:
1369 optchans = DevFmtStereo;
1370 stereomode = StereoEncoding::Hrtf;
1371 break;
1372 case OutputMode::Quad: optchans = DevFmtQuad; break;
1373 case OutputMode::X51: optchans = DevFmtX51; break;
1374 case OutputMode::X61: optchans = DevFmtX61; break;
1375 case OutputMode::X71: optchans = DevFmtX71; break;
1376 }
1377 }
1378
1379 if(freqAttr)
1380 {
1381 uint oldrate = optsrate.value_or(DefaultOutputRate);
1382 freqAttr = std::clamp<int>(freqAttr, MinOutputRate, MaxOutputRate);
1383
1384 const double scale{static_cast<double>(freqAttr) / oldrate};
1385 period_size = static_cast<uint>(std::lround(period_size * scale));
1386 buffer_size = static_cast<uint>(std::lround(buffer_size * scale));
1387 optsrate = static_cast<uint>(freqAttr);
1388 }
1389 }
1390
1391 /* If a context is already running on the device, stop playback so the
1392 * device attributes can be updated.
1393 */
1394 if(device->mDeviceState == DeviceState::Playing)
1395 {
1396 device->Backend->stop();
1397 device->mDeviceState = DeviceState::Unprepared;
1398 }
1399
1400 UpdateClockBase(device);
1401 }
1402
1403 if(device->mDeviceState == DeviceState::Playing)
1404 return ALC_NO_ERROR;
1405
1406 device->mDeviceState = DeviceState::Unprepared;
1407 device->AvgSpeakerDist = 0.0f;
1408 device->mNFCtrlFilter = NfcFilter{};
1409 device->mUhjEncoder = nullptr;
1410 device->AmbiDecoder = nullptr;
1411 device->Bs2b = nullptr;
1412 device->PostProcess = nullptr;
1413
1414 device->Limiter = nullptr;
1415 device->ChannelDelays = nullptr;
1416
1417 std::fill(std::begin(device->HrtfAccumData), std::end(device->HrtfAccumData), float2{});
1418
1419 device->Dry.AmbiMap.fill(BFChannelConfig{});
1420 device->Dry.Buffer = {};
1421 std::fill(std::begin(device->NumChannelsPerOrder), std::end(device->NumChannelsPerOrder), 0u);
1422 device->RealOut.RemixMap = {};
1423 device->RealOut.ChannelIndex.fill(InvalidChannelIndex);
1424 device->RealOut.Buffer = {};
1425 device->MixBuffer.clear();
1426 device->MixBuffer.shrink_to_fit();
1427
1428 UpdateClockBase(device);
1429 device->FixedLatency = nanoseconds::zero();
1430
1431 device->DitherDepth = 0.0f;
1432 device->DitherSeed = DitherRNGSeed;
1433
1434 device->mHrtfStatus = ALC_HRTF_DISABLED_SOFT;
1435
1436 /*************************************************************************
1437 * Update device format request
1438 */
1439
1440 if(device->Type == DeviceType::Loopback)
1441 {
1442 device->Frequency = *optsrate;
1443 device->FmtChans = *optchans;
1444 device->FmtType = *opttype;
1445 if(device->FmtChans == DevFmtAmbi3D)
1446 {
1447 device->mAmbiOrder = aorder;
1448 device->mAmbiLayout = *optlayout;
1449 device->mAmbiScale = *optscale;
1450 }
1451 device->Flags.set(FrequencyRequest).set(ChannelsRequest).set(SampleTypeRequest);
1452 }
1453 else
1454 {
1455 device->FmtType = opttype.value_or(DevFmtTypeDefault);
1456 device->FmtChans = optchans.value_or(DevFmtChannelsDefault);
1457 device->mAmbiOrder = 0;
1458 device->BufferSize = buffer_size;
1459 device->UpdateSize = period_size;
1460 device->Frequency = optsrate.value_or(DefaultOutputRate);
1461 device->Flags.set(FrequencyRequest, optsrate.has_value())
1462 .set(ChannelsRequest, optchans.has_value())
1463 .set(SampleTypeRequest, opttype.has_value());
1464
1465 if(device->FmtChans == DevFmtAmbi3D)
1466 {
1467 device->mAmbiOrder = std::clamp(aorder, 1u, uint{MaxAmbiOrder});
1468 device->mAmbiLayout = optlayout.value_or(DevAmbiLayout::Default);
1469 device->mAmbiScale = optscale.value_or(DevAmbiScaling::Default);
1470 if(device->mAmbiOrder > 3
1471 && (device->mAmbiLayout == DevAmbiLayout::FuMa
1472 || device->mAmbiScale == DevAmbiScaling::FuMa))
1473 {
1474 ERR("FuMa is incompatible with %d%s order ambisonics (up to 3rd order only)\n",
1475 device->mAmbiOrder, GetCounterSuffix(device->mAmbiOrder));
1476 device->mAmbiOrder = 3;
1477 }
1478 }
1479 }
1480
1481 TRACE("Pre-reset: %s%s, %s%s, %s%uhz, %u / %u buffer\n",
1482 device->Flags.test(ChannelsRequest)?"*":"", DevFmtChannelsString(device->FmtChans),
1483 device->Flags.test(SampleTypeRequest)?"*":"", DevFmtTypeString(device->FmtType),
1484 device->Flags.test(FrequencyRequest)?"*":"", device->Frequency,
1485 device->UpdateSize, device->BufferSize);
1486
1487 const uint oldFreq{device->Frequency};
1488 const DevFmtChannels oldChans{device->FmtChans};
1489 const DevFmtType oldType{device->FmtType};
1490 try {
1491 auto backend = device->Backend.get();
1492 if(!backend->reset())
1493 throw al::backend_exception{al::backend_error::DeviceError, "Device reset failure"};
1494 }
1495 catch(std::exception &e) {
1496 ERR("Device error: %s\n", e.what());
1497 device->handleDisconnect("%s", e.what());
1498 return ALC_INVALID_DEVICE;
1499 }
1500
1501 if(device->FmtChans != oldChans && device->Flags.test(ChannelsRequest))
1502 {
1503 ERR("Failed to set %s, got %s instead\n", DevFmtChannelsString(oldChans),
1504 DevFmtChannelsString(device->FmtChans));
1505 device->Flags.reset(ChannelsRequest);
1506 }
1507 if(device->FmtType != oldType && device->Flags.test(SampleTypeRequest))
1508 {
1509 ERR("Failed to set %s, got %s instead\n", DevFmtTypeString(oldType),
1510 DevFmtTypeString(device->FmtType));
1511 device->Flags.reset(SampleTypeRequest);
1512 }
1513 if(device->Frequency != oldFreq && device->Flags.test(FrequencyRequest))
1514 {
1515 WARN("Failed to set %uhz, got %uhz instead\n", oldFreq, device->Frequency);
1516 device->Flags.reset(FrequencyRequest);
1517 }
1518
1519 TRACE("Post-reset: %s, %s, %uhz, %u / %u buffer\n",
1520 DevFmtChannelsString(device->FmtChans), DevFmtTypeString(device->FmtType),
1521 device->Frequency, device->UpdateSize, device->BufferSize);
1522
1523 if(device->Type != DeviceType::Loopback)
1524 {
1525 if(auto modeopt = device->configValue<std::string>({}, "stereo-mode"))
1526 {
1527 if(al::case_compare(*modeopt, "headphones"sv) == 0)
1528 device->Flags.set(DirectEar);
1529 else if(al::case_compare(*modeopt, "speakers"sv) == 0)
1530 device->Flags.reset(DirectEar);
1531 else if(al::case_compare(*modeopt, "auto"sv) != 0)
1532 ERR("Unexpected stereo-mode: %s\n", modeopt->c_str());
1533 }
1534 }
1535
1536 aluInitRenderer(device, hrtf_id, stereomode);
1537
1538 /* Calculate the max number of sources, and split them between the mono and
1539 * stereo count given the requested number of stereo sources.
1540 */
1541 if(auto srcsopt = device->configValue<uint>({}, "sources"sv))
1542 {
1543 if(*srcsopt <= 0) numMono = 256;
1544 else numMono = std::max(*srcsopt, 16u);
1545 }
1546 else
1547 {
1548 numMono = std::min(numMono, std::numeric_limits<int>::max()-numStereo);
1549 numMono = std::max(numMono+numStereo, 256u);
1550 }
1551 numStereo = std::min(numStereo, numMono);
1552 numMono -= numStereo;
1553 device->SourcesMax = numMono + numStereo;
1554 device->NumMonoSources = numMono;
1555 device->NumStereoSources = numStereo;
1556
1557 if(auto sendsopt = device->configValue<uint>({}, "sends"sv))
1558 numSends = std::min(numSends, std::clamp(*sendsopt, 0u, uint{MaxSendCount}));
1559 device->NumAuxSends = numSends;
1560
1561 TRACE("Max sources: %d (%d + %d), effect slots: %d, sends: %d\n",
1562 device->SourcesMax, device->NumMonoSources, device->NumStereoSources,
1563 device->AuxiliaryEffectSlotMax, device->NumAuxSends);
1564
1565 switch(device->FmtChans)
1566 {
1567 case DevFmtMono: break;
1568 case DevFmtStereo:
1569 if(!device->mUhjEncoder)
1570 device->RealOut.RemixMap = StereoDownmix;
1571 break;
1572 case DevFmtQuad: device->RealOut.RemixMap = QuadDownmix; break;
1573 case DevFmtX51: device->RealOut.RemixMap = X51Downmix; break;
1574 case DevFmtX61: device->RealOut.RemixMap = X61Downmix; break;
1575 case DevFmtX71: device->RealOut.RemixMap = X71Downmix; break;
1576 case DevFmtX714: device->RealOut.RemixMap = X71Downmix; break;
1577 case DevFmtX7144: device->RealOut.RemixMap = X71Downmix; break;
1578 case DevFmtX3D71: device->RealOut.RemixMap = X51Downmix; break;
1579 case DevFmtAmbi3D: break;
1580 }
1581
1582 size_t sample_delay{0};
1583 if(auto *encoder{device->mUhjEncoder.get()})
1584 sample_delay += encoder->getDelay();
1585
1586 if(device->getConfigValueBool({}, "dither"sv, true))
1587 {
1588 int depth{device->configValue<int>({}, "dither-depth"sv).value_or(0)};
1589 if(depth <= 0)
1590 {
1591 switch(device->FmtType)
1592 {
1593 case DevFmtByte:
1594 case DevFmtUByte:
1595 depth = 8;
1596 break;
1597 case DevFmtShort:
1598 case DevFmtUShort:
1599 depth = 16;
1600 break;
1601 case DevFmtInt:
1602 case DevFmtUInt:
1603 case DevFmtFloat:
1604 break;
1605 }
1606 }
1607
1608 if(depth > 0)
1609 {
1610 depth = std::clamp(depth, 2, 24);
1611 device->DitherDepth = std::pow(2.0f, static_cast<float>(depth-1));
1612 }
1613 }
1614 if(!(device->DitherDepth > 0.0f))
1615 TRACE("Dithering disabled\n");
1616 else
1617 TRACE("Dithering enabled (%d-bit, %g)\n", float2int(std::log2(device->DitherDepth)+0.5f)+1,
1618 device->DitherDepth);
1619
1620 if(!optlimit)
1621 optlimit = device->configValue<bool>({}, "output-limiter");
1622
1623 /* If the gain limiter is unset, use the limiter for integer-based output
1624 * (where samples must be clamped), and don't for floating-point (which can
1625 * take unclamped samples).
1626 */
1627 if(!optlimit)
1628 {
1629 switch(device->FmtType)
1630 {
1631 case DevFmtByte:
1632 case DevFmtUByte:
1633 case DevFmtShort:
1634 case DevFmtUShort:
1635 case DevFmtInt:
1636 case DevFmtUInt:
1637 optlimit = true;
1638 break;
1639 case DevFmtFloat:
1640 break;
1641 }
1642 }
1643 if(!optlimit.value_or(false))
1644 TRACE("Output limiter disabled\n");
1645 else
1646 {
1647 float thrshld{1.0f};
1648 switch(device->FmtType)
1649 {
1650 case DevFmtByte:
1651 case DevFmtUByte:
1652 thrshld = 127.0f / 128.0f;
1653 break;
1654 case DevFmtShort:
1655 case DevFmtUShort:
1656 thrshld = 32767.0f / 32768.0f;
1657 break;
1658 case DevFmtInt:
1659 case DevFmtUInt:
1660 case DevFmtFloat:
1661 break;
1662 }
1663 if(device->DitherDepth > 0.0f)
1664 thrshld -= 1.0f / device->DitherDepth;
1665
1666 const float thrshld_dB{std::log10(thrshld) * 20.0f};
1667 auto limiter = CreateDeviceLimiter(device, thrshld_dB);
1668
1669 sample_delay += limiter->getLookAhead();
1670 device->Limiter = std::move(limiter);
1671 TRACE("Output limiter enabled, %.4fdB limit\n", thrshld_dB);
1672 }
1673
1674 /* Convert the sample delay from samples to nanosamples to nanoseconds. */
1675 sample_delay = std::min<size_t>(sample_delay, std::numeric_limits<int>::max());
1676 device->FixedLatency += nanoseconds{seconds{sample_delay}} / device->Frequency;
1677 TRACE("Fixed device latency: %" PRId64 "ns\n", int64_t{device->FixedLatency.count()});
1678
1679 FPUCtl mixer_mode{};
1680 auto reset_context = [device](ContextBase *ctxbase)
1681 {
1682 auto *context = dynamic_cast<ALCcontext*>(ctxbase);
1683 assert(context != nullptr);
1684 if(!context) return;
1685
1686 std::unique_lock<std::mutex> proplock{context->mPropLock};
1687 std::unique_lock<std::mutex> slotlock{context->mEffectSlotLock};
1688
1689 /* Clear out unused effect slot clusters. */
1690 auto slot_cluster_not_in_use = [](ContextBase::EffectSlotCluster &clusterptr) -> bool
1691 {
1692 return std::none_of(clusterptr->begin(), clusterptr->end(),
1693 std::mem_fn(&EffectSlot::InUse));
1694 };
1695 auto slotcluster_end = std::remove_if(context->mEffectSlotClusters.begin(),
1696 context->mEffectSlotClusters.end(), slot_cluster_not_in_use);
1697 context->mEffectSlotClusters.erase(slotcluster_end, context->mEffectSlotClusters.end());
1698
1699 /* Free all wet buffers. Any in use will be reallocated with an updated
1700 * configuration in aluInitEffectPanning.
1701 */
1702 auto clear_wetbuffers = [](ContextBase::EffectSlotCluster &clusterptr)
1703 {
1704 auto clear_buffer = [](EffectSlot &slot)
1705 {
1706 slot.mWetBuffer.clear();
1707 slot.mWetBuffer.shrink_to_fit();
1708 slot.Wet.Buffer = {};
1709 };
1710 std::for_each(clusterptr->begin(), clusterptr->end(), clear_buffer);
1711 };
1712 std::for_each(context->mEffectSlotClusters.begin(), context->mEffectSlotClusters.end(),
1713 clear_wetbuffers);
1714
1715 if(ALeffectslot *slot{context->mDefaultSlot.get()})
1716 {
1717 auto *slotbase = slot->mSlot;
1718 aluInitEffectPanning(slotbase, context);
1719
1720 if(auto *props = slotbase->Update.exchange(nullptr, std::memory_order_relaxed))
1721 AtomicReplaceHead(context->mFreeEffectSlotProps, props);
1722
1723 EffectState *state{slot->Effect.State.get()};
1724 state->mOutTarget = device->Dry.Buffer;
1725 state->deviceUpdate(device, slot->Buffer);
1726 slot->mPropsDirty = true;
1727 }
1728
1729 if(EffectSlotArray *curarray{context->mActiveAuxSlots.load(std::memory_order_relaxed)})
1730 std::fill(curarray->begin()+ptrdiff_t(curarray->size()>>1), curarray->end(), nullptr);
1731 auto reset_slots = [device,context](EffectSlotSubList &sublist)
1732 {
1733 uint64_t usemask{~sublist.FreeMask};
1734 while(usemask)
1735 {
1736 const auto idx = static_cast<uint>(al::countr_zero(usemask));
1737 auto &slot = (*sublist.EffectSlots)[idx];
1738 usemask &= ~(1_u64 << idx);
1739
1740 auto *slotbase = slot.mSlot;
1741 aluInitEffectPanning(slotbase, context);
1742
1743 if(auto *props = slotbase->Update.exchange(nullptr, std::memory_order_relaxed))
1744 AtomicReplaceHead(context->mFreeEffectSlotProps, props);
1745
1746 EffectState *state{slot.Effect.State.get()};
1747 state->mOutTarget = device->Dry.Buffer;
1748 state->deviceUpdate(device, slot.Buffer);
1749 slot.mPropsDirty = true;
1750 }
1751 };
1752 std::for_each(context->mEffectSlotList.begin(), context->mEffectSlotList.end(),
1753 reset_slots);
1754
1755 /* Clear all effect slot props to let them get allocated again. */
1756 context->mEffectSlotPropClusters.clear();
1757 context->mFreeEffectSlotProps.store(nullptr, std::memory_order_relaxed);
1758 slotlock.unlock();
1759
1760 std::unique_lock<std::mutex> srclock{context->mSourceLock};
1761 const uint num_sends{device->NumAuxSends};
1762 auto reset_sources = [num_sends](SourceSubList &sublist)
1763 {
1764 uint64_t usemask{~sublist.FreeMask};
1765 while(usemask)
1766 {
1767 const auto idx = static_cast<uint>(al::countr_zero(usemask));
1768 auto &source = (*sublist.Sources)[idx];
1769 usemask &= ~(1_u64 << idx);
1770
1771 auto clear_send = [](ALsource::SendData &send) -> void
1772 {
1773 if(send.Slot)
1774 DecrementRef(send.Slot->ref);
1775 send.Slot = nullptr;
1776 send.Gain = 1.0f;
1777 send.GainHF = 1.0f;
1778 send.HFReference = LowPassFreqRef;
1779 send.GainLF = 1.0f;
1780 send.LFReference = HighPassFreqRef;
1781 };
1782 const auto sends = al::span{source.Send}.subspan(num_sends);
1783 std::for_each(sends.begin(), sends.end(), clear_send);
1784
1785 source.mPropsDirty = true;
1786 }
1787 };
1788 std::for_each(context->mSourceList.begin(), context->mSourceList.end(), reset_sources);
1789
1790 auto reset_voice = [device,num_sends,context](Voice *voice)
1791 {
1792 /* Clear extraneous property set sends. */
1793 const auto sendparams = al::span{voice->mProps.Send}.subspan(num_sends);
1794 std::fill(sendparams.begin(), sendparams.end(), VoiceProps::SendData{});
1795
1796 std::fill(voice->mSend.begin()+num_sends, voice->mSend.end(), Voice::TargetData{});
1797 auto clear_wetparams = [num_sends](Voice::ChannelData &chandata)
1798 {
1799 const auto wetparams = al::span{chandata.mWetParams}.subspan(num_sends);
1800 std::fill(wetparams.begin(), wetparams.end(), SendParams{});
1801 };
1802 std::for_each(voice->mChans.begin(), voice->mChans.end(), clear_wetparams);
1803
1804 if(VoicePropsItem *props{voice->mUpdate.exchange(nullptr, std::memory_order_relaxed)})
1805 AtomicReplaceHead(context->mFreeVoiceProps, props);
1806
1807 /* Force the voice to stopped if it was stopping. */
1808 Voice::State vstate{Voice::Stopping};
1809 voice->mPlayState.compare_exchange_strong(vstate, Voice::Stopped,
1810 std::memory_order_acquire, std::memory_order_acquire);
1811 if(voice->mSourceID.load(std::memory_order_relaxed) == 0u)
1812 return;
1813
1814 voice->prepare(device);
1815 };
1816 const auto voicespan = context->getVoicesSpan();
1817 std::for_each(voicespan.begin(), voicespan.end(), reset_voice);
1818
1819 /* Clear all voice props to let them get allocated again. */
1820 context->mVoicePropClusters.clear();
1821 context->mFreeVoiceProps.store(nullptr, std::memory_order_relaxed);
1822 srclock.unlock();
1823
1824 context->mPropsDirty = false;
1825 UpdateContextProps(context);
1826 UpdateAllEffectSlotProps(context);
1827 UpdateAllSourceProps(context);
1828 };
1829 auto ctxspan = al::span{*device->mContexts.load()};
1830 std::for_each(ctxspan.begin(), ctxspan.end(), reset_context);
1831 mixer_mode.leave();
1832
1833 device->mDeviceState = DeviceState::Configured;
1834 if(!device->Flags.test(DevicePaused))
1835 {
1836 try {
1837 auto backend = device->Backend.get();
1838 backend->start();
1839 device->mDeviceState = DeviceState::Playing;
1840 }
1841 catch(al::backend_exception& e) {
1842 ERR("%s\n", e.what());
1843 device->handleDisconnect("%s", e.what());
1844 return ALC_INVALID_DEVICE;
1845 }
1846 TRACE("Post-start: %s, %s, %uhz, %u / %u buffer\n",
1847 DevFmtChannelsString(device->FmtChans), DevFmtTypeString(device->FmtType),
1848 device->Frequency, device->UpdateSize, device->BufferSize);
1849 }
1850
1851 return ALC_NO_ERROR;
1852 }
1853
1854 /**
1855 * Updates device parameters as above, and also first clears the disconnected
1856 * status, if set.
1857 */
1858 bool ResetDeviceParams(ALCdevice *device, const al::span<const int> attrList)
1859 {
1860 /* If the device was disconnected, reset it since we're opened anew. */
1861 if(!device->Connected.load(std::memory_order_relaxed)) UNLIKELY
1862 {
1863 /* Make sure disconnection is finished before continuing on. */
1864 std::ignore = device->waitForMix();
1865
1866 for(ContextBase *ctxbase : *device->mContexts.load(std::memory_order_acquire))
1867 {
1868 auto *ctx = dynamic_cast<ALCcontext*>(ctxbase);
1869 assert(ctx != nullptr);
1870 if(!ctx || !ctx->mStopVoicesOnDisconnect.load(std::memory_order_acquire))
1871 continue;
1872
1873 /* Clear any pending voice changes and reallocate voices to get a
1874 * clean restart.
1875 */
1876 std::lock_guard<std::mutex> sourcelock{ctx->mSourceLock};
1877 auto *vchg = ctx->mCurrentVoiceChange.load(std::memory_order_acquire);
1878 while(auto *next = vchg->mNext.load(std::memory_order_acquire))
1879 vchg = next;
1880 ctx->mCurrentVoiceChange.store(vchg, std::memory_order_release);
1881
1882 ctx->mVoicePropClusters.clear();
1883 ctx->mFreeVoiceProps.store(nullptr, std::memory_order_relaxed);
1884
1885 ctx->mVoiceClusters.clear();
1886 ctx->allocVoices(std::max<size_t>(256,
1887 ctx->mActiveVoiceCount.load(std::memory_order_relaxed)));
1888 }
1889
1890 device->Connected.store(true);
1891 }
1892
1893 ALCenum err{UpdateDeviceParams(device, attrList)};
1894 if(err == ALC_NO_ERROR) LIKELY return ALC_TRUE;
1895
1896 alcSetError(device, err);
1897 return ALC_FALSE;
1898 }
1899
1900
1901 /** Checks if the device handle is valid, and returns a new reference if so. */
1902 DeviceRef VerifyDevice(ALCdevice *device)
1903 {
1904 std::lock_guard<std::recursive_mutex> listlock{ListLock};
1905 auto iter = std::lower_bound(DeviceList.begin(), DeviceList.end(), device);
1906 if(iter != DeviceList.end() && *iter == device)
1907 {
1908 (*iter)->add_ref();
1909 return DeviceRef{*iter};
1910 }
1911 return nullptr;
1912 }
1913
1914
1915 /**
1916 * Checks if the given context is valid, returning a new reference to it if so.
1917 */
1918 ContextRef VerifyContext(ALCcontext *context)
1919 {
1920 std::lock_guard<std::recursive_mutex> listlock{ListLock};
1921 auto iter = std::lower_bound(ContextList.begin(), ContextList.end(), context);
1922 if(iter != ContextList.end() && *iter == context)
1923 {
1924 (*iter)->add_ref();
1925 return ContextRef{*iter};
1926 }
1927 return nullptr;
1928 }
1929
1930 } // namespace
1931
1932 FORCE_ALIGN void ALC_APIENTRY alsoft_set_log_callback(LPALSOFTLOGCALLBACK callback, void *userptr) noexcept
1933 {
1934 al_set_log_callback(callback, userptr);
1935 }
1936
1937 /** Returns a new reference to the currently active context for this thread. */
1938 ContextRef GetContextRef() noexcept
1939 {
1940 ALCcontext *context{ALCcontext::getThreadContext()};
1941 if(context)
1942 context->add_ref();
1943 else
1944 {
1945 while(ALCcontext::sGlobalContextLock.exchange(true, std::memory_order_acquire)) {
1946 /* Wait to make sure another thread isn't trying to change the
1947 * current context and bring its refcount to 0.
1948 */
1949 }
1950 context = ALCcontext::sGlobalContext.load(std::memory_order_acquire);
1951 if(context) LIKELY context->add_ref();
1952 ALCcontext::sGlobalContextLock.store(false, std::memory_order_release);
1953 }
1954 return ContextRef{context};
1955 }
1956
1957 void alcSetError(ALCdevice *device, ALCenum errorCode)
1958 {
1959 WARN("Error generated on device %p, code 0x%04x\n", voidp{device}, errorCode);
1960 if(TrapALCError)
1961 {
1962 #ifdef _WIN32
1963 /* DebugBreak() will cause an exception if there is no debugger */
1964 if(IsDebuggerPresent())
1965 DebugBreak();
1966 #elif defined(SIGTRAP)
1967 raise(SIGTRAP);
1968 #endif
1969 }
1970
1971 if(device)
1972 device->LastError.store(errorCode);
1973 else
1974 LastNullDeviceError.store(errorCode);
1975 }
1976
1977 /************************************************
1978 * Standard ALC functions
1979 ************************************************/
1980
1981 ALC_API ALCenum ALC_APIENTRY alcGetError(ALCdevice *device) noexcept
1982 {
1983 if(!gProcessRunning)
1984 return ALC_INVALID_DEVICE;
1985
1986 DeviceRef dev{VerifyDevice(device)};
1987 if(dev) return dev->LastError.exchange(ALC_NO_ERROR);
1988 return LastNullDeviceError.exchange(ALC_NO_ERROR);
1989 }
1990
1991
1992 ALC_API void ALC_APIENTRY alcSuspendContext(ALCcontext *context) noexcept
1993 {
1994 ContextRef ctx{VerifyContext(context)};
1995 if(!ctx)
1996 {
1997 alcSetError(nullptr, ALC_INVALID_CONTEXT);
1998 return;
1999 }
2000
2001 if(ctx->mContextFlags.test(ContextFlags::DebugBit)) UNLIKELY
2002 ctx->debugMessage(DebugSource::API, DebugType::Portability, 0, DebugSeverity::Medium,
2003 "alcSuspendContext behavior is not portable -- some implementations suspend all "
2004 "rendering, some only defer property changes, and some are completely no-op; consider "
2005 "using alcDevicePauseSOFT to suspend all rendering, or alDeferUpdatesSOFT to only "
2006 "defer property changes");
2007
2008 if(SuspendDefers)
2009 {
2010 std::lock_guard<std::mutex> proplock{ctx->mPropLock};
2011 ctx->deferUpdates();
2012 }
2013 }
2014
2015 ALC_API void ALC_APIENTRY alcProcessContext(ALCcontext *context) noexcept
2016 {
2017 ContextRef ctx{VerifyContext(context)};
2018 if(!ctx)
2019 {
2020 alcSetError(nullptr, ALC_INVALID_CONTEXT);
2021 return;
2022 }
2023
2024 if(ctx->mContextFlags.test(ContextFlags::DebugBit)) UNLIKELY
2025 ctx->debugMessage(DebugSource::API, DebugType::Portability, 1, DebugSeverity::Medium,
2026 "alcProcessContext behavior is not portable -- some implementations resume rendering, "
2027 "some apply deferred property changes, and some are completely no-op; consider using "
2028 "alcDeviceResumeSOFT to resume rendering, or alProcessUpdatesSOFT to apply deferred "
2029 "property changes");
2030
2031 if(SuspendDefers)
2032 {
2033 std::lock_guard<std::mutex> proplock{ctx->mPropLock};
2034 ctx->processUpdates();
2035 }
2036 }
2037
2038
2039 ALC_API auto ALC_APIENTRY alcGetString(ALCdevice *Device, ALCenum param) noexcept -> const ALCchar*
2040 {
2041 switch(param)
2042 {
2043 case ALC_NO_ERROR: return GetNoErrorString();
2044 case ALC_INVALID_ENUM: return GetInvalidEnumString();
2045 case ALC_INVALID_VALUE: return GetInvalidValueString();
2046 case ALC_INVALID_DEVICE: return GetInvalidDeviceString();
2047 case ALC_INVALID_CONTEXT: return GetInvalidContextString();
2048 case ALC_OUT_OF_MEMORY: return GetOutOfMemoryString();
2049
2050 case ALC_DEVICE_SPECIFIER:
2051 return GetDefaultName();
2052
2053 case ALC_ALL_DEVICES_SPECIFIER:
2054 if(DeviceRef dev{VerifyDevice(Device)})
2055 {
2056 if(dev->Type == DeviceType::Capture)
2057 {
2058 alcSetError(dev.get(), ALC_INVALID_ENUM);
2059 return nullptr;
2060 }
2061 if(dev->Type == DeviceType::Loopback)
2062 return GetDefaultName();
2063
2064 auto statelock = std::lock_guard{dev->StateLock};
2065 return dev->mDeviceName.c_str();
2066 }
2067 ProbeAllDevicesList();
2068 return alcAllDevicesList.c_str();
2069
2070 case ALC_CAPTURE_DEVICE_SPECIFIER:
2071 if(DeviceRef dev{VerifyDevice(Device)})
2072 {
2073 if(dev->Type != DeviceType::Capture)
2074 {
2075 alcSetError(dev.get(), ALC_INVALID_ENUM);
2076 return nullptr;
2077 }
2078
2079 auto statelock = std::lock_guard{dev->StateLock};
2080 return dev->mDeviceName.c_str();
2081 }
2082 ProbeCaptureDeviceList();
2083 return alcCaptureDeviceList.c_str();
2084
2085 /* Default devices are always first in the list */
2086 case ALC_DEFAULT_DEVICE_SPECIFIER:
2087 return GetDefaultName();
2088
2089 case ALC_DEFAULT_ALL_DEVICES_SPECIFIER:
2090 if(alcAllDevicesList.empty())
2091 ProbeAllDevicesList();
2092
2093 /* Copy first entry as default. */
2094 if(alcAllDevicesArray.empty())
2095 return GetDefaultName();
2096
2097 alcDefaultAllDevicesSpecifier = alcAllDevicesArray.front();
2098 return alcDefaultAllDevicesSpecifier.c_str();
2099
2100 case ALC_CAPTURE_DEFAULT_DEVICE_SPECIFIER:
2101 if(alcCaptureDeviceList.empty())
2102 ProbeCaptureDeviceList();
2103
2104 /* Copy first entry as default. */
2105 if(alcCaptureDeviceArray.empty())
2106 return GetDefaultName();
2107
2108 alcCaptureDefaultDeviceSpecifier = alcCaptureDeviceArray.front();
2109 return alcCaptureDefaultDeviceSpecifier.c_str();
2110
2111 case ALC_EXTENSIONS:
2112 if(VerifyDevice(Device))
2113 return GetExtensionList();
2114 return GetNoDeviceExtList();
2115
2116 case ALC_HRTF_SPECIFIER_SOFT:
2117 if(DeviceRef dev{VerifyDevice(Device)})
2118 {
2119 std::lock_guard<std::mutex> statelock{dev->StateLock};
2120 return dev->mHrtf ? dev->mHrtfName.c_str() : "";
2121 }
2122 alcSetError(nullptr, ALC_INVALID_DEVICE);
2123 return nullptr;
2124
2125 default:
2126 alcSetError(VerifyDevice(Device).get(), ALC_INVALID_ENUM);
2127 }
2128
2129 return nullptr;
2130 }
2131
2132
2133 static size_t GetIntegerv(ALCdevice *device, ALCenum param, const al::span<int> values)
2134 {
2135 if(values.empty())
2136 {
2137 alcSetError(device, ALC_INVALID_VALUE);
2138 return 0;
2139 }
2140
2141 if(!device)
2142 {
2143 switch(param)
2144 {
2145 case ALC_MAJOR_VERSION:
2146 values[0] = alcMajorVersion;
2147 return 1;
2148 case ALC_MINOR_VERSION:
2149 values[0] = alcMinorVersion;
2150 return 1;
2151
2152 case ALC_EFX_MAJOR_VERSION:
2153 values[0] = alcEFXMajorVersion;
2154 return 1;
2155 case ALC_EFX_MINOR_VERSION:
2156 values[0] = alcEFXMinorVersion;
2157 return 1;
2158 case ALC_MAX_AUXILIARY_SENDS:
2159 values[0] = MaxSendCount;
2160 return 1;
2161
2162 case ALC_ATTRIBUTES_SIZE:
2163 case ALC_ALL_ATTRIBUTES:
2164 case ALC_FREQUENCY:
2165 case ALC_REFRESH:
2166 case ALC_SYNC:
2167 case ALC_MONO_SOURCES:
2168 case ALC_STEREO_SOURCES:
2169 case ALC_CAPTURE_SAMPLES:
2170 case ALC_FORMAT_CHANNELS_SOFT:
2171 case ALC_FORMAT_TYPE_SOFT:
2172 case ALC_AMBISONIC_LAYOUT_SOFT:
2173 case ALC_AMBISONIC_SCALING_SOFT:
2174 case ALC_AMBISONIC_ORDER_SOFT:
2175 case ALC_MAX_AMBISONIC_ORDER_SOFT:
2176 alcSetError(nullptr, ALC_INVALID_DEVICE);
2177 return 0;
2178
2179 default:
2180 alcSetError(nullptr, ALC_INVALID_ENUM);
2181 }
2182 return 0;
2183 }
2184
2185 std::lock_guard<std::mutex> statelock{device->StateLock};
2186 if(device->Type == DeviceType::Capture)
2187 {
2188 static constexpr int MaxCaptureAttributes{9};
2189 switch(param)
2190 {
2191 case ALC_ATTRIBUTES_SIZE:
2192 values[0] = MaxCaptureAttributes;
2193 return 1;
2194 case ALC_ALL_ATTRIBUTES:
2195 if(values.size() >= MaxCaptureAttributes)
2196 {
2197 size_t i{0};
2198 values[i++] = ALC_MAJOR_VERSION;
2199 values[i++] = alcMajorVersion;
2200 values[i++] = ALC_MINOR_VERSION;
2201 values[i++] = alcMinorVersion;
2202 values[i++] = ALC_CAPTURE_SAMPLES;
2203 values[i++] = static_cast<int>(device->Backend->availableSamples());
2204 values[i++] = ALC_CONNECTED;
2205 values[i++] = device->Connected.load(std::memory_order_relaxed);
2206 values[i++] = 0;
2207 assert(i == MaxCaptureAttributes);
2208 return i;
2209 }
2210 alcSetError(device, ALC_INVALID_VALUE);
2211 return 0;
2212
2213 case ALC_MAJOR_VERSION:
2214 values[0] = alcMajorVersion;
2215 return 1;
2216 case ALC_MINOR_VERSION:
2217 values[0] = alcMinorVersion;
2218 return 1;
2219
2220 case ALC_CAPTURE_SAMPLES:
2221 values[0] = static_cast<int>(device->Backend->availableSamples());
2222 return 1;
2223
2224 case ALC_CONNECTED:
2225 values[0] = device->Connected.load(std::memory_order_acquire);
2226 return 1;
2227
2228 default:
2229 alcSetError(device, ALC_INVALID_ENUM);
2230 }
2231 return 0;
2232 }
2233
2234 /* render device */
2235 auto NumAttrsForDevice = [](const ALCdevice *aldev) noexcept -> uint8_t
2236 {
2237 if(aldev->Type == DeviceType::Loopback && aldev->FmtChans == DevFmtAmbi3D)
2238 return 37;
2239 return 31;
2240 };
2241 switch(param)
2242 {
2243 case ALC_ATTRIBUTES_SIZE:
2244 values[0] = NumAttrsForDevice(device);
2245 return 1;
2246
2247 case ALC_ALL_ATTRIBUTES:
2248 if(values.size() >= NumAttrsForDevice(device))
2249 {
2250 size_t i{0};
2251 values[i++] = ALC_MAJOR_VERSION;
2252 values[i++] = alcMajorVersion;
2253 values[i++] = ALC_MINOR_VERSION;
2254 values[i++] = alcMinorVersion;
2255 values[i++] = ALC_EFX_MAJOR_VERSION;
2256 values[i++] = alcEFXMajorVersion;
2257 values[i++] = ALC_EFX_MINOR_VERSION;
2258 values[i++] = alcEFXMinorVersion;
2259
2260 values[i++] = ALC_FREQUENCY;
2261 values[i++] = static_cast<int>(device->Frequency);
2262 if(device->Type != DeviceType::Loopback)
2263 {
2264 values[i++] = ALC_REFRESH;
2265 values[i++] = static_cast<int>(device->Frequency / device->UpdateSize);
2266
2267 values[i++] = ALC_SYNC;
2268 values[i++] = ALC_FALSE;
2269 }
2270 else
2271 {
2272 if(device->FmtChans == DevFmtAmbi3D)
2273 {
2274 values[i++] = ALC_AMBISONIC_LAYOUT_SOFT;
2275 values[i++] = EnumFromDevAmbi(device->mAmbiLayout);
2276
2277 values[i++] = ALC_AMBISONIC_SCALING_SOFT;
2278 values[i++] = EnumFromDevAmbi(device->mAmbiScale);
2279
2280 values[i++] = ALC_AMBISONIC_ORDER_SOFT;
2281 values[i++] = static_cast<int>(device->mAmbiOrder);
2282 }
2283
2284 values[i++] = ALC_FORMAT_CHANNELS_SOFT;
2285 values[i++] = EnumFromDevFmt(device->FmtChans);
2286
2287 values[i++] = ALC_FORMAT_TYPE_SOFT;
2288 values[i++] = EnumFromDevFmt(device->FmtType);
2289 }
2290
2291 values[i++] = ALC_MONO_SOURCES;
2292 values[i++] = static_cast<int>(device->NumMonoSources);
2293
2294 values[i++] = ALC_STEREO_SOURCES;
2295 values[i++] = static_cast<int>(device->NumStereoSources);
2296
2297 values[i++] = ALC_MAX_AUXILIARY_SENDS;
2298 values[i++] = static_cast<int>(device->NumAuxSends);
2299
2300 values[i++] = ALC_HRTF_SOFT;
2301 values[i++] = (device->mHrtf ? ALC_TRUE : ALC_FALSE);
2302
2303 values[i++] = ALC_HRTF_STATUS_SOFT;
2304 values[i++] = device->mHrtfStatus;
2305
2306 values[i++] = ALC_OUTPUT_LIMITER_SOFT;
2307 values[i++] = device->Limiter ? ALC_TRUE : ALC_FALSE;
2308
2309 values[i++] = ALC_MAX_AMBISONIC_ORDER_SOFT;
2310 values[i++] = MaxAmbiOrder;
2311
2312 values[i++] = ALC_OUTPUT_MODE_SOFT;
2313 values[i++] = static_cast<ALCenum>(device->getOutputMode1());
2314
2315 values[i++] = 0;
2316 assert(i == NumAttrsForDevice(device));
2317 return i;
2318 }
2319 alcSetError(device, ALC_INVALID_VALUE);
2320 return 0;
2321
2322 case ALC_MAJOR_VERSION:
2323 values[0] = alcMajorVersion;
2324 return 1;
2325
2326 case ALC_MINOR_VERSION:
2327 values[0] = alcMinorVersion;
2328 return 1;
2329
2330 case ALC_EFX_MAJOR_VERSION:
2331 values[0] = alcEFXMajorVersion;
2332 return 1;
2333
2334 case ALC_EFX_MINOR_VERSION:
2335 values[0] = alcEFXMinorVersion;
2336 return 1;
2337
2338 case ALC_FREQUENCY:
2339 values[0] = static_cast<int>(device->Frequency);
2340 return 1;
2341
2342 case ALC_REFRESH:
2343 if(device->Type == DeviceType::Loopback)
2344 {
2345 alcSetError(device, ALC_INVALID_DEVICE);
2346 return 0;
2347 }
2348 values[0] = static_cast<int>(device->Frequency / device->UpdateSize);
2349 return 1;
2350
2351 case ALC_SYNC:
2352 if(device->Type == DeviceType::Loopback)
2353 {
2354 alcSetError(device, ALC_INVALID_DEVICE);
2355 return 0;
2356 }
2357 values[0] = ALC_FALSE;
2358 return 1;
2359
2360 case ALC_FORMAT_CHANNELS_SOFT:
2361 if(device->Type != DeviceType::Loopback)
2362 {
2363 alcSetError(device, ALC_INVALID_DEVICE);
2364 return 0;
2365 }
2366 values[0] = EnumFromDevFmt(device->FmtChans);
2367 return 1;
2368
2369 case ALC_FORMAT_TYPE_SOFT:
2370 if(device->Type != DeviceType::Loopback)
2371 {
2372 alcSetError(device, ALC_INVALID_DEVICE);
2373 return 0;
2374 }
2375 values[0] = EnumFromDevFmt(device->FmtType);
2376 return 1;
2377
2378 case ALC_AMBISONIC_LAYOUT_SOFT:
2379 if(device->Type != DeviceType::Loopback || device->FmtChans != DevFmtAmbi3D)
2380 {
2381 alcSetError(device, ALC_INVALID_DEVICE);
2382 return 0;
2383 }
2384 values[0] = EnumFromDevAmbi(device->mAmbiLayout);
2385 return 1;
2386
2387 case ALC_AMBISONIC_SCALING_SOFT:
2388 if(device->Type != DeviceType::Loopback || device->FmtChans != DevFmtAmbi3D)
2389 {
2390 alcSetError(device, ALC_INVALID_DEVICE);
2391 return 0;
2392 }
2393 values[0] = EnumFromDevAmbi(device->mAmbiScale);
2394 return 1;
2395
2396 case ALC_AMBISONIC_ORDER_SOFT:
2397 if(device->Type != DeviceType::Loopback || device->FmtChans != DevFmtAmbi3D)
2398 {
2399 alcSetError(device, ALC_INVALID_DEVICE);
2400 return 0;
2401 }
2402 values[0] = static_cast<int>(device->mAmbiOrder);
2403 return 1;
2404
2405 case ALC_MONO_SOURCES:
2406 values[0] = static_cast<int>(device->NumMonoSources);
2407 return 1;
2408
2409 case ALC_STEREO_SOURCES:
2410 values[0] = static_cast<int>(device->NumStereoSources);
2411 return 1;
2412
2413 case ALC_MAX_AUXILIARY_SENDS:
2414 values[0] = static_cast<int>(device->NumAuxSends);
2415 return 1;
2416
2417 case ALC_CONNECTED:
2418 values[0] = device->Connected.load(std::memory_order_acquire);
2419 return 1;
2420
2421 case ALC_HRTF_SOFT:
2422 values[0] = (device->mHrtf ? ALC_TRUE : ALC_FALSE);
2423 return 1;
2424
2425 case ALC_HRTF_STATUS_SOFT:
2426 values[0] = device->mHrtfStatus;
2427 return 1;
2428
2429 case ALC_NUM_HRTF_SPECIFIERS_SOFT:
2430 device->enumerateHrtfs();
2431 values[0] = static_cast<int>(std::min(device->mHrtfList.size(),
2432 size_t{std::numeric_limits<int>::max()}));
2433 return 1;
2434
2435 case ALC_OUTPUT_LIMITER_SOFT:
2436 values[0] = device->Limiter ? ALC_TRUE : ALC_FALSE;
2437 return 1;
2438
2439 case ALC_MAX_AMBISONIC_ORDER_SOFT:
2440 values[0] = MaxAmbiOrder;
2441 return 1;
2442
2443 case ALC_OUTPUT_MODE_SOFT:
2444 values[0] = static_cast<ALCenum>(device->getOutputMode1());
2445 return 1;
2446
2447 default:
2448 alcSetError(device, ALC_INVALID_ENUM);
2449 }
2450 return 0;
2451 }
2452
2453 ALC_API void ALC_APIENTRY alcGetIntegerv(ALCdevice *device, ALCenum param, ALCsizei size, ALCint *values) noexcept
2454 {
2455 DeviceRef dev{VerifyDevice(device)};
2456 if(size <= 0 || values == nullptr)
2457 alcSetError(dev.get(), ALC_INVALID_VALUE);
2458 else
2459 GetIntegerv(dev.get(), param, {values, static_cast<uint>(size)});
2460 }
2461
2462 ALC_API void ALC_APIENTRY alcGetInteger64vSOFT(ALCdevice *device, ALCenum pname, ALCsizei size, ALCint64SOFT *values) noexcept
2463 {
2464 DeviceRef dev{VerifyDevice(device)};
2465 if(size <= 0 || values == nullptr)
2466 {
2467 alcSetError(dev.get(), ALC_INVALID_VALUE);
2468 return;
2469 }
2470 const auto valuespan = al::span{values, static_cast<uint>(size)};
2471 if(!dev || dev->Type == DeviceType::Capture)
2472 {
2473 auto ivals = std::vector<int>(valuespan.size());
2474 if(size_t got{GetIntegerv(dev.get(), pname, ivals)})
2475 std::copy_n(ivals.cbegin(), got, valuespan.begin());
2476 return;
2477 }
2478 /* render device */
2479 auto NumAttrsForDevice = [](ALCdevice *aldev) noexcept -> size_t
2480 {
2481 if(aldev->Type == DeviceType::Loopback && aldev->FmtChans == DevFmtAmbi3D)
2482 return 41;
2483 return 35;
2484 };
2485 std::lock_guard<std::mutex> statelock{dev->StateLock};
2486 switch(pname)
2487 {
2488 case ALC_ATTRIBUTES_SIZE:
2489 valuespan[0] = static_cast<ALCint64SOFT>(NumAttrsForDevice(dev.get()));
2490 break;
2491
2492 case ALC_ALL_ATTRIBUTES:
2493 if(valuespan.size() < NumAttrsForDevice(dev.get()))
2494 alcSetError(dev.get(), ALC_INVALID_VALUE);
2495 else
2496 {
2497 size_t i{0};
2498 valuespan[i++] = ALC_FREQUENCY;
2499 valuespan[i++] = dev->Frequency;
2500
2501 if(dev->Type != DeviceType::Loopback)
2502 {
2503 valuespan[i++] = ALC_REFRESH;
2504 valuespan[i++] = dev->Frequency / dev->UpdateSize;
2505
2506 valuespan[i++] = ALC_SYNC;
2507 valuespan[i++] = ALC_FALSE;
2508 }
2509 else
2510 {
2511 valuespan[i++] = ALC_FORMAT_CHANNELS_SOFT;
2512 valuespan[i++] = EnumFromDevFmt(dev->FmtChans);
2513
2514 valuespan[i++] = ALC_FORMAT_TYPE_SOFT;
2515 valuespan[i++] = EnumFromDevFmt(dev->FmtType);
2516
2517 if(dev->FmtChans == DevFmtAmbi3D)
2518 {
2519 valuespan[i++] = ALC_AMBISONIC_LAYOUT_SOFT;
2520 valuespan[i++] = EnumFromDevAmbi(dev->mAmbiLayout);
2521
2522 valuespan[i++] = ALC_AMBISONIC_SCALING_SOFT;
2523 valuespan[i++] = EnumFromDevAmbi(dev->mAmbiScale);
2524
2525 valuespan[i++] = ALC_AMBISONIC_ORDER_SOFT;
2526 valuespan[i++] = dev->mAmbiOrder;
2527 }
2528 }
2529
2530 valuespan[i++] = ALC_MONO_SOURCES;
2531 valuespan[i++] = dev->NumMonoSources;
2532
2533 valuespan[i++] = ALC_STEREO_SOURCES;
2534 valuespan[i++] = dev->NumStereoSources;
2535
2536 valuespan[i++] = ALC_MAX_AUXILIARY_SENDS;
2537 valuespan[i++] = dev->NumAuxSends;
2538
2539 valuespan[i++] = ALC_HRTF_SOFT;
2540 valuespan[i++] = (dev->mHrtf ? ALC_TRUE : ALC_FALSE);
2541
2542 valuespan[i++] = ALC_HRTF_STATUS_SOFT;
2543 valuespan[i++] = dev->mHrtfStatus;
2544
2545 valuespan[i++] = ALC_OUTPUT_LIMITER_SOFT;
2546 valuespan[i++] = dev->Limiter ? ALC_TRUE : ALC_FALSE;
2547
2548 ClockLatency clock{GetClockLatency(dev.get(), dev->Backend.get())};
2549 valuespan[i++] = ALC_DEVICE_CLOCK_SOFT;
2550 valuespan[i++] = clock.ClockTime.count();
2551
2552 valuespan[i++] = ALC_DEVICE_LATENCY_SOFT;
2553 valuespan[i++] = clock.Latency.count();
2554
2555 valuespan[i++] = ALC_OUTPUT_MODE_SOFT;
2556 valuespan[i++] = al::to_underlying(device->getOutputMode1());
2557
2558 valuespan[i++] = 0;
2559 }
2560 break;
2561
2562 case ALC_DEVICE_CLOCK_SOFT:
2563 {
2564 uint samplecount, refcount;
2565 nanoseconds basecount;
2566 do {
2567 refcount = dev->waitForMix();
2568 basecount = dev->mClockBase.load(std::memory_order_relaxed);
2569 samplecount = dev->mSamplesDone.load(std::memory_order_relaxed);
2570 std::atomic_thread_fence(std::memory_order_acquire);
2571 } while(refcount != dev->mMixCount.load(std::memory_order_relaxed));
2572 basecount += nanoseconds{seconds{samplecount}} / dev->Frequency;
2573 valuespan[0] = basecount.count();
2574 }
2575 break;
2576
2577 case ALC_DEVICE_LATENCY_SOFT:
2578 valuespan[0] = GetClockLatency(dev.get(), dev->Backend.get()).Latency.count();
2579 break;
2580
2581 case ALC_DEVICE_CLOCK_LATENCY_SOFT:
2582 if(size < 2)
2583 alcSetError(dev.get(), ALC_INVALID_VALUE);
2584 else
2585 {
2586 ClockLatency clock{GetClockLatency(dev.get(), dev->Backend.get())};
2587 valuespan[0] = clock.ClockTime.count();
2588 valuespan[1] = clock.Latency.count();
2589 }
2590 break;
2591
2592 default:
2593 auto ivals = std::vector<int>(valuespan.size());
2594 if(size_t got{GetIntegerv(dev.get(), pname, ivals)})
2595 std::copy_n(ivals.cbegin(), got, valuespan.begin());
2596 break;
2597 }
2598 }
2599
2600
2601 ALC_API ALCboolean ALC_APIENTRY alcIsExtensionPresent(ALCdevice *device, const ALCchar *extName) noexcept
2602 {
2603 DeviceRef dev{VerifyDevice(device)};
2604 if(!extName)
2605 {
2606 alcSetError(dev.get(), ALC_INVALID_VALUE);
2607 return ALC_FALSE;
2608 }
2609
2610 const std::string_view tofind{extName};
2611 const auto extlist = dev ? std::string_view{GetExtensionList()}
2612 : std::string_view{GetNoDeviceExtList()};
2613 auto matchpos = extlist.find(tofind);
2614 while(matchpos != std::string_view::npos)
2615 {
2616 const auto endpos = matchpos + tofind.size();
2617 if((matchpos == 0 || std::isspace(extlist[matchpos-1]))
2618 && (endpos == extlist.size() || std::isspace(extlist[endpos])))
2619 return ALC_TRUE;
2620 matchpos = extlist.find(tofind, matchpos+1);
2621 }
2622 return ALC_FALSE;
2623 }
2624
2625
2626 ALCvoid* ALC_APIENTRY alcGetProcAddress2(ALCdevice *device, const ALCchar *funcName) noexcept
2627 { return alcGetProcAddress(device, funcName); }
2628
2629 ALC_API ALCvoid* ALC_APIENTRY alcGetProcAddress(ALCdevice *device, const ALCchar *funcName) noexcept
2630 {
2631 if(!funcName)
2632 {
2633 DeviceRef dev{VerifyDevice(device)};
2634 alcSetError(dev.get(), ALC_INVALID_VALUE);
2635 return nullptr;
2636 }
2637
2638 #ifdef ALSOFT_EAX
2639 if(eax_g_is_enabled)
2640 {
2641 for(const auto &func : eaxFunctions)
2642 {
2643 if(strcmp(func.funcName, funcName) == 0)
2644 return func.address;
2645 }
2646 }
2647 #endif
2648 for(const auto &func : alcFunctions)
2649 {
2650 if(strcmp(func.funcName, funcName) == 0)
2651 return func.address;
2652 }
2653 return nullptr;
2654 }
2655
2656
2657 ALC_API ALCenum ALC_APIENTRY alcGetEnumValue(ALCdevice *device, const ALCchar *enumName) noexcept
2658 {
2659 if(!enumName)
2660 {
2661 DeviceRef dev{VerifyDevice(device)};
2662 alcSetError(dev.get(), ALC_INVALID_VALUE);
2663 return 0;
2664 }
2665
2666 #ifdef ALSOFT_EAX
2667 if(eax_g_is_enabled)
2668 {
2669 for(const auto &enm : eaxEnumerations)
2670 {
2671 if(strcmp(enm.enumName, enumName) == 0)
2672 return enm.value;
2673 }
2674 }
2675 #endif
2676 for(const auto &enm : alcEnumerations)
2677 {
2678 if(strcmp(enm.enumName, enumName) == 0)
2679 return enm.value;
2680 }
2681
2682 return 0;
2683 }
2684
2685
2686 ALC_API ALCcontext* ALC_APIENTRY alcCreateContext(ALCdevice *device, const ALCint *attrList) noexcept
2687 {
2688 /* Explicitly hold the list lock while taking the StateLock in case the
2689 * device is asynchronously destroyed, to ensure this new context is
2690 * properly cleaned up after being made.
2691 */
2692 std::unique_lock<std::recursive_mutex> listlock{ListLock};
2693 DeviceRef dev{VerifyDevice(device)};
2694 if(!dev || dev->Type == DeviceType::Capture || !dev->Connected.load(std::memory_order_relaxed))
2695 {
2696 listlock.unlock();
2697 alcSetError(dev.get(), ALC_INVALID_DEVICE);
2698 return nullptr;
2699 }
2700 std::unique_lock<std::mutex> statelock{dev->StateLock};
2701 listlock.unlock();
2702
2703 dev->LastError.store(ALC_NO_ERROR);
2704
2705 const auto attrSpan = SpanFromAttributeList(attrList);
2706 ALCenum err{UpdateDeviceParams(dev.get(), attrSpan)};
2707 if(err != ALC_NO_ERROR)
2708 {
2709 alcSetError(dev.get(), err);
2710 return nullptr;
2711 }
2712
2713 ContextFlagBitset ctxflags{0};
2714 for(size_t i{0};i < attrSpan.size();i+=2)
2715 {
2716 if(attrSpan[i] == ALC_CONTEXT_FLAGS_EXT)
2717 {
2718 ctxflags = static_cast<ALuint>(attrSpan[i+1]);
2719 break;
2720 }
2721 }
2722
2723 auto context = ContextRef{new(std::nothrow) ALCcontext{dev, ctxflags}};
2724 if(!context)
2725 {
2726 alcSetError(dev.get(), ALC_OUT_OF_MEMORY);
2727 return nullptr;
2728 }
2729 context->init();
2730
2731 if(auto volopt = dev->configValue<float>({}, "volume-adjust"))
2732 {
2733 const float valf{*volopt};
2734 if(!std::isfinite(valf))
2735 ERR("volume-adjust must be finite: %f\n", valf);
2736 else
2737 {
2738 const float db{std::clamp(valf, -24.0f, 24.0f)};
2739 if(db != valf)
2740 WARN("volume-adjust clamped: %f, range: +/-%f\n", valf, 24.0f);
2741 context->mGainBoost = std::pow(10.0f, db/20.0f);
2742 TRACE("volume-adjust gain: %f\n", context->mGainBoost);
2743 }
2744 }
2745
2746 {
2747 using ContextArray = al::FlexArray<ContextBase*>;
2748
2749 /* Allocate a new context array, which holds 1 more than the current/
2750 * old array.
2751 */
2752 auto *oldarray = device->mContexts.load();
2753 auto newarray = ContextArray::Create(oldarray->size() + 1);
2754
2755 /* Copy the current/old context handles to the new array, appending the
2756 * new context.
2757 */
2758 auto iter = std::copy(oldarray->begin(), oldarray->end(), newarray->begin());
2759 *iter = context.get();
2760
2761 /* Store the new context array in the device. Wait for any current mix
2762 * to finish before deleting the old array.
2763 */
2764 auto prevarray = dev->mContexts.exchange(std::move(newarray));
2765 std::ignore = dev->waitForMix();
2766 }
2767 statelock.unlock();
2768
2769 {
2770 listlock.lock();
2771 auto iter = std::lower_bound(ContextList.cbegin(), ContextList.cend(), context.get());
2772 ContextList.emplace(iter, context.get());
2773 listlock.unlock();
2774 }
2775
2776 if(ALeffectslot *slot{context->mDefaultSlot.get()})
2777 {
2778 ALenum sloterr{slot->initEffect(0, ALCcontext::sDefaultEffect.type,
2779 ALCcontext::sDefaultEffect.Props, context.get())};
2780 if(sloterr == AL_NO_ERROR)
2781 slot->updateProps(context.get());
2782 else
2783 ERR("Failed to initialize the default effect\n");
2784 }
2785
2786 TRACE("Created context %p\n", voidp{context.get()});
2787 return context.release();
2788 }
2789
2790 ALC_API void ALC_APIENTRY alcDestroyContext(ALCcontext *context) noexcept
2791 {
2792 if(!gProcessRunning)
2793 return;
2794
2795 std::unique_lock<std::recursive_mutex> listlock{ListLock};
2796 auto iter = std::lower_bound(ContextList.begin(), ContextList.end(), context);
2797 if(iter == ContextList.end() || *iter != context)
2798 {
2799 listlock.unlock();
2800 alcSetError(nullptr, ALC_INVALID_CONTEXT);
2801 return;
2802 }
2803
2804 /* Hold a reference to this context so it remains valid until the ListLock
2805 * is released.
2806 */
2807 ContextRef ctx{*iter};
2808 ContextList.erase(iter);
2809
2810 ALCdevice *Device{ctx->mALDevice.get()};
2811
2812 std::lock_guard<std::mutex> statelock{Device->StateLock};
2813 ctx->deinit();
2814 }
2815
2816
2817 ALC_API auto ALC_APIENTRY alcGetCurrentContext() noexcept -> ALCcontext*
2818 {
2819 ALCcontext *Context{ALCcontext::getThreadContext()};
2820 if(!Context) Context = ALCcontext::sGlobalContext.load();
2821 return Context;
2822 }
2823
2824 /** Returns the currently active thread-local context. */
2825 ALC_API auto ALC_APIENTRY alcGetThreadContext() noexcept -> ALCcontext*
2826 { return ALCcontext::getThreadContext(); }
2827
2828 ALC_API ALCboolean ALC_APIENTRY alcMakeContextCurrent(ALCcontext *context) noexcept
2829 {
2830 /* context must be valid or nullptr */
2831 ContextRef ctx;
2832 if(context)
2833 {
2834 ctx = VerifyContext(context);
2835 if(!ctx)
2836 {
2837 alcSetError(nullptr, ALC_INVALID_CONTEXT);
2838 return ALC_FALSE;
2839 }
2840 }
2841 /* Release this reference (if any) to store it in the GlobalContext
2842 * pointer. Take ownership of the reference (if any) that was previously
2843 * stored there, and let the reference go.
2844 */
2845 while(ALCcontext::sGlobalContextLock.exchange(true, std::memory_order_acquire)) {
2846 /* Wait to make sure another thread isn't getting or trying to change
2847 * the current context as its refcount is decremented.
2848 */
2849 }
2850 ctx = ContextRef{ALCcontext::sGlobalContext.exchange(ctx.release())};
2851 ALCcontext::sGlobalContextLock.store(false, std::memory_order_release);
2852
2853 /* Take ownership of the thread-local context reference (if any), clearing
2854 * the storage to null.
2855 */
2856 ctx = ContextRef{ALCcontext::getThreadContext()};
2857 if(ctx) ALCcontext::setThreadContext(nullptr);
2858 /* Reset (decrement) the previous thread-local reference. */
2859
2860 return ALC_TRUE;
2861 }
2862
2863 /** Makes the given context the active context for the current thread. */
2864 ALC_API ALCboolean ALC_APIENTRY alcSetThreadContext(ALCcontext *context) noexcept
2865 {
2866 /* context must be valid or nullptr */
2867 ContextRef ctx;
2868 if(context)
2869 {
2870 ctx = VerifyContext(context);
2871 if(!ctx)
2872 {
2873 alcSetError(nullptr, ALC_INVALID_CONTEXT);
2874 return ALC_FALSE;
2875 }
2876 }
2877 /* context's reference count is already incremented */
2878 ContextRef old{ALCcontext::getThreadContext()};
2879 ALCcontext::setThreadContext(ctx.release());
2880
2881 return ALC_TRUE;
2882 }
2883
2884
2885 ALC_API ALCdevice* ALC_APIENTRY alcGetContextsDevice(ALCcontext *Context) noexcept
2886 {
2887 ContextRef ctx{VerifyContext(Context)};
2888 if(!ctx)
2889 {
2890 alcSetError(nullptr, ALC_INVALID_CONTEXT);
2891 return nullptr;
2892 }
2893 return ctx->mALDevice.get();
2894 }
2895
2896
2897 ALC_API ALCdevice* ALC_APIENTRY alcOpenDevice(const ALCchar *deviceName) noexcept
2898 {
2899 InitConfig();
2900
2901 if(!PlaybackFactory)
2902 {
2903 alcSetError(nullptr, ALC_INVALID_VALUE);
2904 return nullptr;
2905 }
2906
2907 std::string_view devname{deviceName ? deviceName : ""};
2908 if(!devname.empty())
2909 {
2910 TRACE("Opening playback device \"%.*s\"\n", al::sizei(devname), devname.data());
2911 if(al::case_compare(devname, GetDefaultName()) == 0
2912 #ifdef _WIN32
2913 /* Some old Windows apps hardcode these expecting OpenAL to use a
2914 * specific audio API, even when they're not enumerated. Creative's
2915 * router effectively ignores them too.
2916 */
2917 || al::case_compare(devname, "DirectSound3D"sv) == 0
2918 || al::case_compare(devname, "DirectSound"sv) == 0
2919 || al::case_compare(devname, "MMSYSTEM"sv) == 0
2920 #endif
2921 /* Some old Linux apps hardcode configuration strings that were
2922 * supported by the OpenAL SI. We can't really do anything useful
2923 * with them, so just ignore.
2924 */
2925 || al::starts_with(devname, "'("sv)
2926 || al::case_compare(devname, "openal-soft"sv) == 0)
2927 devname = {};
2928 else
2929 {
2930 const auto prefix = GetDevicePrefix();
2931 if(!prefix.empty() && devname.size() > prefix.size()
2932 && al::starts_with(devname, prefix))
2933 devname = devname.substr(prefix.size());
2934 }
2935 }
2936 else
2937 TRACE("Opening default playback device\n");
2938
2939 const uint DefaultSends{
2940 #ifdef ALSOFT_EAX
2941 eax_g_is_enabled ? uint{EAX_MAX_FXSLOTS} :
2942 #endif // ALSOFT_EAX
2943 uint{DefaultSendCount}
2944 };
2945
2946 DeviceRef device{new(std::nothrow) ALCdevice{DeviceType::Playback}};
2947 if(!device)
2948 {
2949 WARN("Failed to create playback device handle\n");
2950 alcSetError(nullptr, ALC_OUT_OF_MEMORY);
2951 return nullptr;
2952 }
2953
2954 /* Set output format */
2955 device->FmtChans = DevFmtChannelsDefault;
2956 device->FmtType = DevFmtTypeDefault;
2957 device->Frequency = DefaultOutputRate;
2958 device->UpdateSize = DefaultUpdateSize;
2959 device->BufferSize = DefaultUpdateSize * DefaultNumUpdates;
2960
2961 device->SourcesMax = 256;
2962 device->NumStereoSources = 1;
2963 device->NumMonoSources = device->SourcesMax - device->NumStereoSources;
2964 device->AuxiliaryEffectSlotMax = 64;
2965 device->NumAuxSends = DefaultSends;
2966
2967 try {
2968 auto backend = PlaybackFactory->createBackend(device.get(), BackendType::Playback);
2969 std::lock_guard<std::recursive_mutex> listlock{ListLock};
2970 backend->open(devname);
2971 device->mDeviceName = std::string{GetDevicePrefix()}+backend->mDeviceName;
2972 device->Backend = std::move(backend);
2973 }
2974 catch(al::backend_exception &e) {
2975 WARN("Failed to open playback device: %s\n", e.what());
2976 alcSetError(nullptr, (e.errorCode() == al::backend_error::OutOfMemory)
2977 ? ALC_OUT_OF_MEMORY : ALC_INVALID_VALUE);
2978 return nullptr;
2979 }
2980
2981 auto checkopt = [&device](const char *envname, const std::string_view optname)
2982 {
2983 if(auto optval = al::getenv(envname)) return optval;
2984 return device->configValue<std::string>("game_compat", optname);
2985 };
2986 if(auto overrideopt = checkopt("__ALSOFT_VENDOR_OVERRIDE", "vendor-override"sv))
2987 {
2988 device->mVendorOverride = std::move(*overrideopt);
2989 TRACE("Overriding vendor string: \"%s\"\n", device->mVendorOverride.c_str());
2990 }
2991 if(auto overrideopt = checkopt("__ALSOFT_VERSION_OVERRIDE", "version-override"sv))
2992 {
2993 device->mVersionOverride = std::move(*overrideopt);
2994 TRACE("Overriding version string: \"%s\"\n", device->mVersionOverride.c_str());
2995 }
2996 if(auto overrideopt = checkopt("__ALSOFT_RENDERER_OVERRIDE", "renderer-override"sv))
2997 {
2998 device->mRendererOverride = std::move(*overrideopt);
2999 TRACE("Overriding renderer string: \"%s\"\n", device->mRendererOverride.c_str());
3000 }
3001
3002 {
3003 std::lock_guard<std::recursive_mutex> listlock{ListLock};
3004 auto iter = std::lower_bound(DeviceList.cbegin(), DeviceList.cend(), device.get());
3005 DeviceList.emplace(iter, device.get());
3006 }
3007
3008 TRACE("Created device %p, \"%s\"\n", voidp{device.get()}, device->mDeviceName.c_str());
3009 return device.release();
3010 }
3011
3012 ALC_API ALCboolean ALC_APIENTRY alcCloseDevice(ALCdevice *device) noexcept
3013 {
3014 if(!gProcessRunning)
3015 return ALC_FALSE;
3016
3017 std::unique_lock<std::recursive_mutex> listlock{ListLock};
3018 auto iter = std::lower_bound(DeviceList.begin(), DeviceList.end(), device);
3019 if(iter == DeviceList.end() || *iter != device)
3020 {
3021 alcSetError(nullptr, ALC_INVALID_DEVICE);
3022 return ALC_FALSE;
3023 }
3024 if((*iter)->Type == DeviceType::Capture)
3025 {
3026 alcSetError(*iter, ALC_INVALID_DEVICE);
3027 return ALC_FALSE;
3028 }
3029
3030 /* Erase the device, and any remaining contexts left on it, from their
3031 * respective lists.
3032 */
3033 DeviceRef dev{*iter};
3034 DeviceList.erase(iter);
3035
3036 std::unique_lock<std::mutex> statelock{dev->StateLock};
3037 std::vector<ContextRef> orphanctxs;
3038 for(ContextBase *ctx : *dev->mContexts.load())
3039 {
3040 auto ctxiter = std::lower_bound(ContextList.begin(), ContextList.end(), ctx);
3041 if(ctxiter != ContextList.end() && *ctxiter == ctx)
3042 {
3043 orphanctxs.emplace_back(*ctxiter);
3044 ContextList.erase(ctxiter);
3045 }
3046 }
3047 listlock.unlock();
3048
3049 for(ContextRef &context : orphanctxs)
3050 {
3051 WARN("Releasing orphaned context %p\n", voidp{context.get()});
3052 context->deinit();
3053 }
3054 orphanctxs.clear();
3055
3056 if(dev->mDeviceState == DeviceState::Playing)
3057 {
3058 dev->Backend->stop();
3059 dev->mDeviceState = DeviceState::Configured;
3060 }
3061
3062 return ALC_TRUE;
3063 }
3064
3065
3066 /************************************************
3067 * ALC capture functions
3068 ************************************************/
3069 ALC_API ALCdevice* ALC_APIENTRY alcCaptureOpenDevice(const ALCchar *deviceName, ALCuint frequency, ALCenum format, ALCsizei samples) noexcept
3070 {
3071 InitConfig();
3072
3073 if(!CaptureFactory)
3074 {
3075 alcSetError(nullptr, ALC_INVALID_VALUE);
3076 return nullptr;
3077 }
3078
3079 if(samples <= 0)
3080 {
3081 alcSetError(nullptr, ALC_INVALID_VALUE);
3082 return nullptr;
3083 }
3084
3085 std::string_view devname{deviceName ? deviceName : ""};
3086 if(!devname.empty())
3087 {
3088 TRACE("Opening capture device \"%.*s\"\n", al::sizei(devname), devname.data());
3089 if(al::case_compare(devname, GetDefaultName()) == 0
3090 || al::case_compare(devname, "openal-soft"sv) == 0)
3091 devname = {};
3092 else
3093 {
3094 const auto prefix = GetDevicePrefix();
3095 if(!prefix.empty() && devname.size() > prefix.size()
3096 && al::starts_with(devname, prefix))
3097 devname = devname.substr(prefix.size());
3098 }
3099 }
3100 else
3101 TRACE("Opening default capture device\n");
3102
3103 DeviceRef device{new(std::nothrow) ALCdevice{DeviceType::Capture}};
3104 if(!device)
3105 {
3106 WARN("Failed to create capture device handle\n");
3107 alcSetError(nullptr, ALC_OUT_OF_MEMORY);
3108 return nullptr;
3109 }
3110
3111 auto decompfmt = DecomposeDevFormat(format);
3112 if(!decompfmt)
3113 {
3114 alcSetError(nullptr, ALC_INVALID_ENUM);
3115 return nullptr;
3116 }
3117
3118 device->Frequency = frequency;
3119 device->FmtChans = decompfmt->chans;
3120 device->FmtType = decompfmt->type;
3121 device->Flags.set(FrequencyRequest);
3122 device->Flags.set(ChannelsRequest);
3123 device->Flags.set(SampleTypeRequest);
3124
3125 device->UpdateSize = static_cast<uint>(samples);
3126 device->BufferSize = static_cast<uint>(samples);
3127
3128 TRACE("Capture format: %s, %s, %uhz, %u / %u buffer\n", DevFmtChannelsString(device->FmtChans),
3129 DevFmtTypeString(device->FmtType), device->Frequency, device->UpdateSize,
3130 device->BufferSize);
3131
3132 try {
3133 auto backend = CaptureFactory->createBackend(device.get(), BackendType::Capture);
3134 std::lock_guard<std::recursive_mutex> listlock{ListLock};
3135 backend->open(devname);
3136 device->mDeviceName = std::string{GetDevicePrefix()}+backend->mDeviceName;
3137 device->Backend = std::move(backend);
3138 }
3139 catch(al::backend_exception &e) {
3140 WARN("Failed to open capture device: %s\n", e.what());
3141 alcSetError(nullptr, (e.errorCode() == al::backend_error::OutOfMemory)
3142 ? ALC_OUT_OF_MEMORY : ALC_INVALID_VALUE);
3143 return nullptr;
3144 }
3145
3146 {
3147 std::lock_guard<std::recursive_mutex> listlock{ListLock};
3148 auto iter = std::lower_bound(DeviceList.cbegin(), DeviceList.cend(), device.get());
3149 DeviceList.emplace(iter, device.get());
3150 }
3151 device->mDeviceState = DeviceState::Configured;
3152
3153 TRACE("Created capture device %p, \"%s\"\n", voidp{device.get()}, device->mDeviceName.c_str());
3154 return device.release();
3155 }
3156
3157 ALC_API ALCboolean ALC_APIENTRY alcCaptureCloseDevice(ALCdevice *device) noexcept
3158 {
3159 if(!gProcessRunning)
3160 return ALC_FALSE;
3161
3162 std::unique_lock<std::recursive_mutex> listlock{ListLock};
3163 auto iter = std::lower_bound(DeviceList.begin(), DeviceList.end(), device);
3164 if(iter == DeviceList.end() || *iter != device)
3165 {
3166 alcSetError(nullptr, ALC_INVALID_DEVICE);
3167 return ALC_FALSE;
3168 }
3169 if((*iter)->Type != DeviceType::Capture)
3170 {
3171 alcSetError(*iter, ALC_INVALID_DEVICE);
3172 return ALC_FALSE;
3173 }
3174
3175 DeviceRef dev{*iter};
3176 DeviceList.erase(iter);
3177 listlock.unlock();
3178
3179 std::lock_guard<std::mutex> statelock{dev->StateLock};
3180 if(dev->mDeviceState == DeviceState::Playing)
3181 {
3182 dev->Backend->stop();
3183 dev->mDeviceState = DeviceState::Configured;
3184 }
3185
3186 return ALC_TRUE;
3187 }
3188
3189 ALC_API void ALC_APIENTRY alcCaptureStart(ALCdevice *device) noexcept
3190 {
3191 DeviceRef dev{VerifyDevice(device)};
3192 if(!dev || dev->Type != DeviceType::Capture)
3193 {
3194 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3195 return;
3196 }
3197
3198 std::lock_guard<std::mutex> statelock{dev->StateLock};
3199 if(!dev->Connected.load(std::memory_order_acquire)
3200 || dev->mDeviceState < DeviceState::Configured)
3201 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3202 else if(dev->mDeviceState != DeviceState::Playing)
3203 {
3204 try {
3205 auto backend = dev->Backend.get();
3206 backend->start();
3207 dev->mDeviceState = DeviceState::Playing;
3208 }
3209 catch(al::backend_exception& e) {
3210 ERR("%s\n", e.what());
3211 dev->handleDisconnect("%s", e.what());
3212 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3213 }
3214 }
3215 }
3216
3217 ALC_API void ALC_APIENTRY alcCaptureStop(ALCdevice *device) noexcept
3218 {
3219 DeviceRef dev{VerifyDevice(device)};
3220 if(!dev || dev->Type != DeviceType::Capture)
3221 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3222 else
3223 {
3224 std::lock_guard<std::mutex> statelock{dev->StateLock};
3225 if(dev->mDeviceState == DeviceState::Playing)
3226 {
3227 dev->Backend->stop();
3228 dev->mDeviceState = DeviceState::Configured;
3229 }
3230 }
3231 }
3232
3233 ALC_API void ALC_APIENTRY alcCaptureSamples(ALCdevice *device, ALCvoid *buffer, ALCsizei samples) noexcept
3234 {
3235 DeviceRef dev{VerifyDevice(device)};
3236 if(!dev || dev->Type != DeviceType::Capture)
3237 {
3238 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3239 return;
3240 }
3241
3242 if(samples < 0 || (samples > 0 && buffer == nullptr))
3243 {
3244 alcSetError(dev.get(), ALC_INVALID_VALUE);
3245 return;
3246 }
3247 if(samples < 1)
3248 return;
3249
3250 std::lock_guard<std::mutex> statelock{dev->StateLock};
3251 BackendBase *backend{dev->Backend.get()};
3252
3253 const auto usamples = static_cast<uint>(samples);
3254 if(usamples > backend->availableSamples())
3255 {
3256 alcSetError(dev.get(), ALC_INVALID_VALUE);
3257 return;
3258 }
3259
3260 backend->captureSamples(static_cast<std::byte*>(buffer), usamples);
3261 }
3262
3263
3264 /************************************************
3265 * ALC loopback functions
3266 ************************************************/
3267
3268 /** Open a loopback device, for manual rendering. */
3269 ALC_API ALCdevice* ALC_APIENTRY alcLoopbackOpenDeviceSOFT(const ALCchar *deviceName) noexcept
3270 {
3271 InitConfig();
3272
3273 /* Make sure the device name, if specified, is us. */
3274 if(deviceName && strcmp(deviceName, GetDefaultName()) != 0)
3275 {
3276 alcSetError(nullptr, ALC_INVALID_VALUE);
3277 return nullptr;
3278 }
3279
3280 const uint DefaultSends{
3281 #ifdef ALSOFT_EAX
3282 eax_g_is_enabled ? uint{EAX_MAX_FXSLOTS} :
3283 #endif // ALSOFT_EAX
3284 uint{DefaultSendCount}
3285 };
3286
3287 DeviceRef device{new(std::nothrow) ALCdevice{DeviceType::Loopback}};
3288 if(!device)
3289 {
3290 WARN("Failed to create loopback device handle\n");
3291 alcSetError(nullptr, ALC_OUT_OF_MEMORY);
3292 return nullptr;
3293 }
3294
3295 device->SourcesMax = 256;
3296 device->AuxiliaryEffectSlotMax = 64;
3297 device->NumAuxSends = DefaultSends;
3298
3299 //Set output format
3300 device->BufferSize = 0;
3301 device->UpdateSize = 0;
3302
3303 device->Frequency = DefaultOutputRate;
3304 device->FmtChans = DevFmtChannelsDefault;
3305 device->FmtType = DevFmtTypeDefault;
3306
3307 device->NumStereoSources = 1;
3308 device->NumMonoSources = device->SourcesMax - device->NumStereoSources;
3309
3310 try {
3311 auto backend = LoopbackBackendFactory::getFactory().createBackend(device.get(),
3312 BackendType::Playback);
3313 backend->open("Loopback");
3314 device->mDeviceName = std::string{GetDevicePrefix()}+backend->mDeviceName;
3315 device->Backend = std::move(backend);
3316 }
3317 catch(al::backend_exception &e) {
3318 WARN("Failed to open loopback device: %s\n", e.what());
3319 alcSetError(nullptr, (e.errorCode() == al::backend_error::OutOfMemory)
3320 ? ALC_OUT_OF_MEMORY : ALC_INVALID_VALUE);
3321 return nullptr;
3322 }
3323
3324 {
3325 std::lock_guard<std::recursive_mutex> listlock{ListLock};
3326 auto iter = std::lower_bound(DeviceList.cbegin(), DeviceList.cend(), device.get());
3327 DeviceList.emplace(iter, device.get());
3328 }
3329
3330 TRACE("Created loopback device %p\n", voidp{device.get()});
3331 return device.release();
3332 }
3333
3334 /**
3335 * Determines if the loopback device supports the given format for rendering.
3336 */
3337 ALC_API ALCboolean ALC_APIENTRY alcIsRenderFormatSupportedSOFT(ALCdevice *device, ALCsizei freq, ALCenum channels, ALCenum type) noexcept
3338 {
3339 DeviceRef dev{VerifyDevice(device)};
3340 if(!dev || dev->Type != DeviceType::Loopback)
3341 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3342 else if(freq <= 0)
3343 alcSetError(dev.get(), ALC_INVALID_VALUE);
3344 else
3345 {
3346 if(DevFmtTypeFromEnum(type).has_value() && DevFmtChannelsFromEnum(channels).has_value()
3347 && freq >= int{MinOutputRate} && freq <= int{MaxOutputRate})
3348 return ALC_TRUE;
3349 }
3350
3351 return ALC_FALSE;
3352 }
3353
3354 /**
3355 * Renders some samples into a buffer, using the format last set by the
3356 * attributes given to alcCreateContext.
3357 */
3358 #if defined(__GNUC__) && defined(__i386__)
3359 /* Needed on x86-32 even without SSE codegen, since the mixer may still use SSE
3360 * and GCC assumes the stack is aligned (x86-64 ABI guarantees alignment).
3361 */
3362 [[gnu::force_align_arg_pointer]]
3363 #endif
3364 ALC_API void ALC_APIENTRY alcRenderSamplesSOFT(ALCdevice *device, ALCvoid *buffer, ALCsizei samples) noexcept
3365 {
3366 if(!device || device->Type != DeviceType::Loopback) UNLIKELY
3367 alcSetError(device, ALC_INVALID_DEVICE);
3368 else if(samples < 0 || (samples > 0 && buffer == nullptr)) UNLIKELY
3369 alcSetError(device, ALC_INVALID_VALUE);
3370 else
3371 device->renderSamples(buffer, static_cast<uint>(samples), device->channelsFromFmt());
3372 }
3373
3374
3375 /************************************************
3376 * ALC DSP pause/resume functions
3377 ************************************************/
3378
3379 /** Pause the DSP to stop audio processing. */
3380 ALC_API void ALC_APIENTRY alcDevicePauseSOFT(ALCdevice *device) noexcept
3381 {
3382 DeviceRef dev{VerifyDevice(device)};
3383 if(!dev || dev->Type != DeviceType::Playback)
3384 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3385 else
3386 {
3387 std::lock_guard<std::mutex> statelock{dev->StateLock};
3388 if(dev->mDeviceState == DeviceState::Playing)
3389 {
3390 dev->Backend->stop();
3391 dev->mDeviceState = DeviceState::Configured;
3392 }
3393 dev->Flags.set(DevicePaused);
3394 }
3395 }
3396
3397 /** Resume the DSP to restart audio processing. */
3398 ALC_API void ALC_APIENTRY alcDeviceResumeSOFT(ALCdevice *device) noexcept
3399 {
3400 DeviceRef dev{VerifyDevice(device)};
3401 if(!dev || dev->Type != DeviceType::Playback)
3402 {
3403 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3404 return;
3405 }
3406
3407 std::lock_guard<std::mutex> statelock{dev->StateLock};
3408 if(!dev->Flags.test(DevicePaused))
3409 return;
3410 if(dev->mDeviceState < DeviceState::Configured)
3411 {
3412 WARN("Cannot resume unconfigured device\n");
3413 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3414 return;
3415 }
3416 if(!dev->Connected.load())
3417 {
3418 WARN("Cannot resume a disconnected device\n");
3419 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3420 return;
3421 }
3422 dev->Flags.reset(DevicePaused);
3423 if(dev->mContexts.load()->empty())
3424 return;
3425
3426 try {
3427 auto backend = dev->Backend.get();
3428 backend->start();
3429 dev->mDeviceState = DeviceState::Playing;
3430 }
3431 catch(al::backend_exception& e) {
3432 ERR("%s\n", e.what());
3433 dev->handleDisconnect("%s", e.what());
3434 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3435 return;
3436 }
3437 TRACE("Post-resume: %s, %s, %uhz, %u / %u buffer\n",
3438 DevFmtChannelsString(dev->FmtChans), DevFmtTypeString(dev->FmtType),
3439 dev->Frequency, dev->UpdateSize, dev->BufferSize);
3440 }
3441
3442
3443 /************************************************
3444 * ALC HRTF functions
3445 ************************************************/
3446
3447 /** Gets a string parameter at the given index. */
3448 ALC_API const ALCchar* ALC_APIENTRY alcGetStringiSOFT(ALCdevice *device, ALCenum paramName, ALCsizei index) noexcept
3449 {
3450 DeviceRef dev{VerifyDevice(device)};
3451 if(!dev || dev->Type == DeviceType::Capture)
3452 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3453 else switch(paramName)
3454 {
3455 case ALC_HRTF_SPECIFIER_SOFT:
3456 if(index >= 0 && static_cast<uint>(index) < dev->mHrtfList.size())
3457 return dev->mHrtfList[static_cast<uint>(index)].c_str();
3458 alcSetError(dev.get(), ALC_INVALID_VALUE);
3459 break;
3460
3461 default:
3462 alcSetError(dev.get(), ALC_INVALID_ENUM);
3463 break;
3464 }
3465
3466 return nullptr;
3467 }
3468
3469 /** Resets the given device output, using the specified attribute list. */
3470 ALC_API ALCboolean ALC_APIENTRY alcResetDeviceSOFT(ALCdevice *device, const ALCint *attribs) noexcept
3471 {
3472 std::unique_lock<std::recursive_mutex> listlock{ListLock};
3473 DeviceRef dev{VerifyDevice(device)};
3474 if(!dev || dev->Type == DeviceType::Capture)
3475 {
3476 listlock.unlock();
3477 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3478 return ALC_FALSE;
3479 }
3480 std::lock_guard<std::mutex> statelock{dev->StateLock};
3481 listlock.unlock();
3482
3483 /* Force the backend to stop mixing first since we're resetting. Also reset
3484 * the connected state so lost devices can attempt recover.
3485 */
3486 if(dev->mDeviceState == DeviceState::Playing)
3487 {
3488 dev->Backend->stop();
3489 dev->mDeviceState = DeviceState::Configured;
3490 }
3491
3492 return ResetDeviceParams(dev.get(), SpanFromAttributeList(attribs)) ? ALC_TRUE : ALC_FALSE;
3493 }
3494
3495
3496 /************************************************
3497 * ALC device reopen functions
3498 ************************************************/
3499
3500 /** Reopens the given device output, using the specified name and attribute list. */
3501 FORCE_ALIGN ALCboolean ALC_APIENTRY alcReopenDeviceSOFT(ALCdevice *device,
3502 const ALCchar *deviceName, const ALCint *attribs) noexcept
3503 {
3504 std::unique_lock<std::recursive_mutex> listlock{ListLock};
3505 DeviceRef dev{VerifyDevice(device)};
3506 if(!dev || dev->Type != DeviceType::Playback)
3507 {
3508 listlock.unlock();
3509 alcSetError(dev.get(), ALC_INVALID_DEVICE);
3510 return ALC_FALSE;
3511 }
3512 std::lock_guard<std::mutex> statelock{dev->StateLock};
3513
3514 std::string_view devname{deviceName ? deviceName : ""};
3515 if(!devname.empty())
3516 {
3517 if(devname.length() >= size_t{std::numeric_limits<int>::max()})
3518 {
3519 ERR("Device name too long (%zu >= %d)\n", devname.length(),
3520 std::numeric_limits<int>::max());
3521 alcSetError(dev.get(), ALC_INVALID_VALUE);
3522 return ALC_FALSE;
3523 }
3524 if(al::case_compare(devname, GetDefaultName()) == 0)
3525 devname = {};
3526 else
3527 {
3528 const auto prefix = GetDevicePrefix();
3529 if(!prefix.empty() && devname.size() > prefix.size()
3530 && al::starts_with(devname, prefix))
3531 devname = devname.substr(prefix.size());
3532 }
3533 }
3534
3535 /* Force the backend device to stop first since we're opening another one. */
3536 const bool wasPlaying{dev->mDeviceState == DeviceState::Playing};
3537 if(wasPlaying)
3538 {
3539 dev->Backend->stop();
3540 dev->mDeviceState = DeviceState::Configured;
3541 }
3542
3543 BackendPtr newbackend;
3544 try {
3545 newbackend = PlaybackFactory->createBackend(dev.get(), BackendType::Playback);
3546 newbackend->open(devname);
3547 }
3548 catch(al::backend_exception &e) {
3549 listlock.unlock();
3550 newbackend = nullptr;
3551
3552 WARN("Failed to reopen playback device: %s\n", e.what());
3553 alcSetError(dev.get(), (e.errorCode() == al::backend_error::OutOfMemory)
3554 ? ALC_OUT_OF_MEMORY : ALC_INVALID_VALUE);
3555
3556 if(dev->Connected.load(std::memory_order_relaxed) && wasPlaying)
3557 {
3558 try {
3559 auto backend = dev->Backend.get();
3560 backend->start();
3561 dev->mDeviceState = DeviceState::Playing;
3562 }
3563 catch(al::backend_exception &be) {
3564 ERR("%s\n", be.what());
3565 dev->handleDisconnect("%s", be.what());
3566 }
3567 }
3568 return ALC_FALSE;
3569 }
3570 listlock.unlock();
3571 dev->mDeviceName = std::string{GetDevicePrefix()}+newbackend->mDeviceName;
3572 dev->Backend = std::move(newbackend);
3573 dev->mDeviceState = DeviceState::Unprepared;
3574 TRACE("Reopened device %p, \"%s\"\n", voidp{dev.get()}, dev->mDeviceName.c_str());
3575
3576 std::string{}.swap(dev->mVendorOverride);
3577 std::string{}.swap(dev->mVersionOverride);
3578 std::string{}.swap(dev->mRendererOverride);
3579 auto checkopt = [&dev](const char *envname, const std::string_view optname)
3580 {
3581 if(auto optval = al::getenv(envname)) return optval;
3582 return dev->configValue<std::string>("game_compat", optname);
3583 };
3584 if(auto overrideopt = checkopt("__ALSOFT_VENDOR_OVERRIDE", "vendor-override"sv))
3585 {
3586 dev->mVendorOverride = std::move(*overrideopt);
3587 TRACE("Overriding vendor string: \"%s\"\n", dev->mVendorOverride.c_str());
3588 }
3589 if(auto overrideopt = checkopt("__ALSOFT_VERSION_OVERRIDE", "version-override"sv))
3590 {
3591 dev->mVersionOverride = std::move(*overrideopt);
3592 TRACE("Overriding version string: \"%s\"\n", dev->mVersionOverride.c_str());
3593 }
3594 if(auto overrideopt = checkopt("__ALSOFT_RENDERER_OVERRIDE", "renderer-override"sv))
3595 {
3596 dev->mRendererOverride = std::move(*overrideopt);
3597 TRACE("Overriding renderer string: \"%s\"\n", dev->mRendererOverride.c_str());
3598 }
3599
3600 /* Always return true even if resetting fails. It shouldn't fail, but this
3601 * is primarily to avoid confusion by the app seeing the function return
3602 * false while the device is on the new output anyway. We could try to
3603 * restore the old backend if this fails, but the configuration would be
3604 * changed with the new backend and would need to be reset again with the
3605 * old one, and the provided attributes may not be appropriate or desirable
3606 * for the old device.
3607 *
3608 * In this way, we essentially act as if the function succeeded, but
3609 * immediately disconnects following it.
3610 */
3611 ResetDeviceParams(dev.get(), SpanFromAttributeList(attribs));
3612 return ALC_TRUE;
3613 }
3614
3615 /************************************************
3616 * ALC event query functions
3617 ************************************************/
3618
3619 FORCE_ALIGN ALCenum ALC_APIENTRY alcEventIsSupportedSOFT(ALCenum eventType, ALCenum deviceType) noexcept
3620 {
3621 auto etype = alc::GetEventType(eventType);
3622 if(!etype)
3623 {
3624 WARN("Invalid event type: 0x%04x\n", eventType);
3625 alcSetError(nullptr, ALC_INVALID_ENUM);
3626 return ALC_FALSE;
3627 }
3628
3629 auto supported = alc::EventSupport::NoSupport;
3630 switch(deviceType)
3631 {
3632 case ALC_PLAYBACK_DEVICE_SOFT:
3633 if(PlaybackFactory)
3634 supported = PlaybackFactory->queryEventSupport(*etype, BackendType::Playback);
3635 return al::to_underlying(supported);
3636
3637 case ALC_CAPTURE_DEVICE_SOFT:
3638 if(CaptureFactory)
3639 supported = CaptureFactory->queryEventSupport(*etype, BackendType::Capture);
3640 return al::to_underlying(supported);
3641 }
3642 WARN("Invalid device type: 0x%04x\n", deviceType);
3643 alcSetError(nullptr, ALC_INVALID_ENUM);
3644 return ALC_FALSE;
3645 }
Software OpenAL implementation