+/**

+ * OpenAL cross platform audio library

+ * Copyright (C) 1999-2007 by authors.

+ * This library is free software; you can redistribute it and/or

+ * modify it under the terms of the GNU Library General Public

+ * License as published by the Free Software Foundation; either

+ * version 2 of the License, or (at your option) any later version.

+ *

+ * This library is distributed in the hope that it will be useful,

+ * but WITHOUT ANY WARRANTY; without even the implied warranty of

+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU

+ * Library General Public License for more details.

+ *

+ * You should have received a copy of the GNU Library General Public

+ * License along with this library; if not, write to the

+ * Free Software Foundation, Inc.,

+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.

+ * Or go to http://www.gnu.org/copyleft/lgpl.html

+ */

+

+#include "config.h"

+

+#include <stdlib.h>

+#include <stdio.h>

+#include <memory.h>

+

+#include <dsound.h>

+#include <cguid.h>

+#include <mmreg.h>

+#ifndef _WAVEFORMATEXTENSIBLE_

+#include <ks.h>

+#include <ksmedia.h>

+#endif

+

+#include <atomic>

+#include <thread>

+#include <string>

+#include <vector>

+#include <algorithm>

+

+#include "alMain.h"

+#include "alu.h"

+#include "ringbuffer.h"

+#include "compat.h"

+

+#include "backends/base.h"

+

+#ifndef DSSPEAKER_5POINT1

+# define DSSPEAKER_5POINT1 0x00000006

+#endif

+#ifndef DSSPEAKER_5POINT1_BACK

+# define DSSPEAKER_5POINT1_BACK 0x00000006

+#endif

+#ifndef DSSPEAKER_7POINT1

+# define DSSPEAKER_7POINT1 0x00000007

+#endif

+#ifndef DSSPEAKER_7POINT1_SURROUND

+# define DSSPEAKER_7POINT1_SURROUND 0x00000008

+#endif

+#ifndef DSSPEAKER_5POINT1_SURROUND

+# define DSSPEAKER_5POINT1_SURROUND 0x00000009

+#endif

+

+

+/* Some headers seem to define these as macros for __uuidof, which is annoying

+ * since some headers don't declare them at all. Hopefully the ifdef is enough

+ * to tell if they need to be declared.

+ */

+#ifndef KSDATAFORMAT_SUBTYPE_PCM

+DEFINE_GUID(KSDATAFORMAT_SUBTYPE_PCM, 0x00000001, 0x0000, 0x0010, 0x80, 0x00, 0x00, 0xaa, 0x00, 0x38, 0x9b, 0x71);

+#endif

+#ifndef KSDATAFORMAT_SUBTYPE_IEEE_FLOAT

+DEFINE_GUID(KSDATAFORMAT_SUBTYPE_IEEE_FLOAT, 0x00000003, 0x0000, 0x0010, 0x80, 0x00, 0x00, 0xaa, 0x00, 0x38, 0x9b, 0x71);

+#endif

+

+namespace {

+

+#define DEVNAME_HEAD "OpenAL Soft on "

+

+

+#ifdef HAVE_DYNLOAD

+static void *ds_handle;

+static HRESULT (WINAPI *pDirectSoundCreate)(const GUID *pcGuidDevice, IDirectSound **ppDS, IUnknown *pUnkOuter);

+static HRESULT (WINAPI *pDirectSoundEnumerateW)(LPDSENUMCALLBACKW pDSEnumCallback, void *pContext);

+static HRESULT (WINAPI *pDirectSoundCaptureCreate)(const GUID *pcGuidDevice, IDirectSoundCapture **ppDSC, IUnknown *pUnkOuter);

+static HRESULT (WINAPI *pDirectSoundCaptureEnumerateW)(LPDSENUMCALLBACKW pDSEnumCallback, void *pContext);

+

+#define DirectSoundCreate pDirectSoundCreate

+#define DirectSoundEnumerateW pDirectSoundEnumerateW

+#define DirectSoundCaptureCreate pDirectSoundCaptureCreate

+#define DirectSoundCaptureEnumerateW pDirectSoundCaptureEnumerateW

+#endif

+

+

+static ALCboolean DSoundLoad(void)

+{

+#ifdef HAVE_DYNLOAD

+ if(!ds_handle)

+ {

+ ds_handle = LoadLib("dsound.dll");

+ if(!ds_handle)

+ {

+ ERR("Failed to load dsound.dll\n");

+ return ALC_FALSE;

+ }

+

+#define LOAD_FUNC(f) do { \

+ p##f = reinterpret_cast<decltype(p##f)>(GetSymbol(ds_handle, #f)); \

+ if(!p##f) \

+ { \

+ CloseLib(ds_handle); \

+ ds_handle = nullptr; \

+ return ALC_FALSE; \

+ } \

+} while(0)

+ LOAD_FUNC(DirectSoundCreate);

+ LOAD_FUNC(DirectSoundEnumerateW);

+ LOAD_FUNC(DirectSoundCaptureCreate);

+ LOAD_FUNC(DirectSoundCaptureEnumerateW);

+#undef LOAD_FUNC

+ }

+#endif

+ return ALC_TRUE;

+}

+

+

+#define MAX_UPDATES 128

+

+struct DevMap {

+ std::string name;

+ GUID guid;

+

+ template<typename T0, typename T1>

+ DevMap(T0&& name_, T1&& guid_)

+ : name{std::forward<T0>(name_)}, guid{std::forward<T1>(guid_)}

+ { }

+};

+

+std::vector<DevMap> PlaybackDevices;

+std::vector<DevMap> CaptureDevices;

+

+bool checkName(const std::vector<DevMap> &list, const std::string &name)

+{

+ return std::find_if(list.cbegin(), list.cend(),

+ [&name](const DevMap &entry) -> bool

+ { return entry.name == name; }

+ ) != list.cend();

+}

+

+BOOL CALLBACK DSoundEnumDevices(GUID *guid, const WCHAR *desc, const WCHAR* UNUSED(drvname), void *data)

+{

+ if(!guid)

+ return TRUE;

+

+ auto& devices = *reinterpret_cast<std::vector<DevMap>*>(data);

+ const std::string basename{DEVNAME_HEAD + wstr_to_utf8(desc)};

+

+ int count{1};

+ std::string newname{basename};

+ while(checkName(devices, newname))

+ {

+ newname = basename;

+ newname += " #";

+ newname += std::to_string(++count);

+ }

+ devices.emplace_back(std::move(newname), *guid);

+ const DevMap &newentry = devices.back();

+

+ OLECHAR *guidstr{nullptr};

+ HRESULT hr{StringFromCLSID(*guid, &guidstr)};

+ if(SUCCEEDED(hr))

+ {

+ TRACE("Got device \"%s\", GUID \"%ls\"\n", newentry.name.c_str(), guidstr);

+ CoTaskMemFree(guidstr);

+ }

+

+ return TRUE;

+}

+

+} // namespace

+

+

+struct ALCdsoundPlayback final : public ALCbackend {

+ IDirectSound *DS{nullptr};

+ IDirectSoundBuffer *PrimaryBuffer{nullptr};

+ IDirectSoundBuffer *Buffer{nullptr};

+ IDirectSoundNotify *Notifies{nullptr};

+ HANDLE NotifyEvent{nullptr};

+

+ std::atomic<ALenum> killNow{AL_TRUE};

+ std::thread thread;

+};

+

+static int ALCdsoundPlayback_mixerProc(ALCdsoundPlayback *self);

+

+static void ALCdsoundPlayback_Construct(ALCdsoundPlayback *self, ALCdevice *device);

+static void ALCdsoundPlayback_Destruct(ALCdsoundPlayback *self);

+static ALCenum ALCdsoundPlayback_open(ALCdsoundPlayback *self, const ALCchar *name);

+static ALCboolean ALCdsoundPlayback_reset(ALCdsoundPlayback *self);

+static ALCboolean ALCdsoundPlayback_start(ALCdsoundPlayback *self);

+static void ALCdsoundPlayback_stop(ALCdsoundPlayback *self);

+static DECLARE_FORWARD2(ALCdsoundPlayback, ALCbackend, ALCenum, captureSamples, void*, ALCuint)

+static DECLARE_FORWARD(ALCdsoundPlayback, ALCbackend, ALCuint, availableSamples)

+static DECLARE_FORWARD(ALCdsoundPlayback, ALCbackend, ClockLatency, getClockLatency)

+static DECLARE_FORWARD(ALCdsoundPlayback, ALCbackend, void, lock)

+static DECLARE_FORWARD(ALCdsoundPlayback, ALCbackend, void, unlock)

+DECLARE_DEFAULT_ALLOCATORS(ALCdsoundPlayback)

+

+DEFINE_ALCBACKEND_VTABLE(ALCdsoundPlayback);

+

+

+static void ALCdsoundPlayback_Construct(ALCdsoundPlayback *self, ALCdevice *device)

+{

+ new (self) ALCdsoundPlayback{};

+ ALCbackend_Construct(STATIC_CAST(ALCbackend, self), device);

+ SET_VTABLE2(ALCdsoundPlayback, ALCbackend, self);

+}

+

+static void ALCdsoundPlayback_Destruct(ALCdsoundPlayback *self)

+{

+ if(self->Notifies)

+ self->Notifies->Release();

+ self->Notifies = nullptr;

+ if(self->Buffer)

+ self->Buffer->Release();

+ self->Buffer = nullptr;

+ if(self->PrimaryBuffer)

+ self->PrimaryBuffer->Release();

+ self->PrimaryBuffer = nullptr;

+

+ if(self->DS)

+ self->DS->Release();

+ self->DS = nullptr;

+ if(self->NotifyEvent)

+ CloseHandle(self->NotifyEvent);

+ self->NotifyEvent = nullptr;

+

+ ALCbackend_Destruct(STATIC_CAST(ALCbackend, self));

+ self->~ALCdsoundPlayback();

+}

+

+

+FORCE_ALIGN static int ALCdsoundPlayback_mixerProc(ALCdsoundPlayback *self)

+{

+ ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;

+

+ SetRTPriority();

+ althrd_setname(althrd_current(), MIXER_THREAD_NAME);

+

+ IDirectSoundBuffer *const Buffer{self->Buffer};

+

+ DSBCAPS DSBCaps{};

+ DSBCaps.dwSize = sizeof(DSBCaps);

+ HRESULT err{Buffer->GetCaps(&DSBCaps)};

+ if(FAILED(err))

+ {

+ ERR("Failed to get buffer caps: 0x%lx\n", err);

+ ALCdevice_Lock(device);

+ aluHandleDisconnect(device, "Failure retrieving playback buffer info: 0x%lx", err);

+ ALCdevice_Unlock(device);

+ return 1;

+ }

+

+ ALsizei FrameSize{FrameSizeFromDevFmt(device->FmtChans, device->FmtType, device->AmbiOrder)};

+ DWORD FragSize{device->UpdateSize * FrameSize};

+

+ bool Playing{false};

+ DWORD LastCursor{0u};

+ Buffer->GetCurrentPosition(&LastCursor, nullptr);

+ while(!self->killNow.load(almemory_order_acquire) &&

+ ATOMIC_LOAD(&device->Connected, almemory_order_acquire))

+ {

+ // Get current play cursor

+ DWORD PlayCursor;

+ Buffer->GetCurrentPosition(&PlayCursor, nullptr);

+ DWORD avail = (PlayCursor-LastCursor+DSBCaps.dwBufferBytes) % DSBCaps.dwBufferBytes;

+

+ if(avail < FragSize)

+ {

+ if(!Playing)

+ {

+ err = Buffer->Play(0, 0, DSBPLAY_LOOPING);

+ if(FAILED(err))

+ {

+ ERR("Failed to play buffer: 0x%lx\n", err);

+ ALCdevice_Lock(device);

+ aluHandleDisconnect(device, "Failure starting playback: 0x%lx", err);

+ ALCdevice_Unlock(device);

+ return 1;

+ }

+ Playing = true;

+ }

+

+ avail = WaitForSingleObjectEx(self->NotifyEvent, 2000, FALSE);

+ if(avail != WAIT_OBJECT_0)

+ ERR("WaitForSingleObjectEx error: 0x%lx\n", avail);

+ continue;

+ }

+ avail -= avail%FragSize;

+

+ // Lock output buffer

+ void *WritePtr1, *WritePtr2;

+ DWORD WriteCnt1{0u}, WriteCnt2{0u};

+ err = Buffer->Lock(LastCursor, avail, &WritePtr1, &WriteCnt1, &WritePtr2, &WriteCnt2, 0);

+

+ // If the buffer is lost, restore it and lock

+ if(err == DSERR_BUFFERLOST)

+ {

+ WARN("Buffer lost, restoring...\n");

+ err = Buffer->Restore();

+ if(SUCCEEDED(err))

+ {

+ Playing = false;

+ LastCursor = 0;

+ err = Buffer->Lock(0, DSBCaps.dwBufferBytes, &WritePtr1, &WriteCnt1,

+ &WritePtr2, &WriteCnt2, 0);

+ }

+ }

+

+ // Successfully locked the output buffer

+ if(SUCCEEDED(err))

+ {

+ // If we have an active context, mix data directly into output buffer otherwise fill with silence

+ ALCdevice_Lock(device);

+ aluMixData(device, WritePtr1, WriteCnt1/FrameSize);

+ aluMixData(device, WritePtr2, WriteCnt2/FrameSize);

+ ALCdevice_Unlock(device);

+

+ // Unlock output buffer only when successfully locked

+ Buffer->Unlock(WritePtr1, WriteCnt1, WritePtr2, WriteCnt2);

+ }

+ else

+ {

+ ERR("Buffer lock error: %#lx\n", err);

+ ALCdevice_Lock(device);

+ aluHandleDisconnect(device, "Failed to lock output buffer: 0x%lx", err);

+ ALCdevice_Unlock(device);

+ return 1;

+ }

+

+ // Update old write cursor location

+ LastCursor += WriteCnt1+WriteCnt2;

+ LastCursor %= DSBCaps.dwBufferBytes;

+ }

+

+ return 0;

+}

+

+static ALCenum ALCdsoundPlayback_open(ALCdsoundPlayback *self, const ALCchar *deviceName)

+{

+ ALCdevice *device{STATIC_CAST(ALCbackend, self)->mDevice};

+

+ HRESULT hr;

+ if(PlaybackDevices.empty())

+ {

+ /* Initialize COM to prevent name truncation */

+ HRESULT hrcom{CoInitialize(nullptr)};

+ hr = DirectSoundEnumerateW(DSoundEnumDevices, &PlaybackDevices);

+ if(FAILED(hr))

+ ERR("Error enumerating DirectSound devices (0x%lx)!\n", hr);

+ if(SUCCEEDED(hrcom))

+ CoUninitialize();

+ }

+

+ const GUID *guid{nullptr};

+ if(!deviceName && !PlaybackDevices.empty())

+ {

+ deviceName = PlaybackDevices[0].name.c_str();

+ guid = &PlaybackDevices[0].guid;

+ }

+ else

+ {

+ auto iter = std::find_if(PlaybackDevices.cbegin(), PlaybackDevices.cend(),

+ [deviceName](const DevMap &entry) -> bool

+ { return entry.name == deviceName; }

+ );

+ if(iter == PlaybackDevices.cend())

+ return ALC_INVALID_VALUE;

+ guid = &iter->guid;

+ }

+

+ hr = DS_OK;

+ self->NotifyEvent = CreateEventW(nullptr, FALSE, FALSE, nullptr);

+ if(!self->NotifyEvent) hr = E_FAIL;

+

+ //DirectSound Init code

+ if(SUCCEEDED(hr))

+ hr = DirectSoundCreate(guid, &self->DS, nullptr);

+ if(SUCCEEDED(hr))

+ hr = self->DS->SetCooperativeLevel(GetForegroundWindow(), DSSCL_PRIORITY);

+ if(FAILED(hr))

+ {

+ ERR("Device init failed: 0x%08lx\n", hr);

+ return ALC_INVALID_VALUE;

+ }

+

+ alstr_copy_cstr(&device->DeviceName, deviceName);

+

+ return ALC_NO_ERROR;

+}

+

+static ALCboolean ALCdsoundPlayback_reset(ALCdsoundPlayback *self)

+{

+ ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;

+

+ if(self->Notifies)

+ self->Notifies->Release();

+ self->Notifies = nullptr;

+ if(self->Buffer)

+ self->Buffer->Release();

+ self->Buffer = nullptr;

+ if(self->PrimaryBuffer)

+ self->PrimaryBuffer->Release();

+ self->PrimaryBuffer = nullptr;

+

+ switch(device->FmtType)

+ {

+ case DevFmtByte:

+ device->FmtType = DevFmtUByte;

+ break;

+ case DevFmtFloat:

+ if((device->Flags&DEVICE_SAMPLE_TYPE_REQUEST))

+ break;

+ /* fall-through */

+ case DevFmtUShort:

+ device->FmtType = DevFmtShort;

+ break;

+ case DevFmtUInt:

+ device->FmtType = DevFmtInt;

+ break;

+ case DevFmtUByte:

+ case DevFmtShort:

+ case DevFmtInt:

+ break;

+ }

+

+ WAVEFORMATEXTENSIBLE OutputType{};

+ DWORD speakers;

+ HRESULT hr{self->DS->GetSpeakerConfig(&speakers)};

+ if(SUCCEEDED(hr))

+ {

+ speakers = DSSPEAKER_CONFIG(speakers);

+ if(!(device->Flags&DEVICE_CHANNELS_REQUEST))

+ {

+ if(speakers == DSSPEAKER_MONO)

+ device->FmtChans = DevFmtMono;

+ else if(speakers == DSSPEAKER_STEREO || speakers == DSSPEAKER_HEADPHONE)

+ device->FmtChans = DevFmtStereo;

+ else if(speakers == DSSPEAKER_QUAD)

+ device->FmtChans = DevFmtQuad;

+ else if(speakers == DSSPEAKER_5POINT1_SURROUND)

+ device->FmtChans = DevFmtX51;

+ else if(speakers == DSSPEAKER_5POINT1_BACK)

+ device->FmtChans = DevFmtX51Rear;

+ else if(speakers == DSSPEAKER_7POINT1 || speakers == DSSPEAKER_7POINT1_SURROUND)

+ device->FmtChans = DevFmtX71;

+ else

+ ERR("Unknown system speaker config: 0x%lx\n", speakers);

+ }

+ device->IsHeadphones = (device->FmtChans == DevFmtStereo &&

+ speakers == DSSPEAKER_HEADPHONE);

+

+ switch(device->FmtChans)

+ {

+ case DevFmtMono:

+ OutputType.dwChannelMask = SPEAKER_FRONT_CENTER;

+ break;

+ case DevFmtAmbi3D:

+ device->FmtChans = DevFmtStereo;

+ /*fall-through*/

+ case DevFmtStereo:

+ OutputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT;

+ break;

+ case DevFmtQuad:

+ OutputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_BACK_LEFT |

+ SPEAKER_BACK_RIGHT;

+ break;

+ case DevFmtX51:

+ OutputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_SIDE_LEFT |

+ SPEAKER_SIDE_RIGHT;

+ break;

+ case DevFmtX51Rear:

+ OutputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_BACK_LEFT |

+ SPEAKER_BACK_RIGHT;

+ break;

+ case DevFmtX61:

+ OutputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_BACK_CENTER |

+ SPEAKER_SIDE_LEFT |

+ SPEAKER_SIDE_RIGHT;

+ break;

+ case DevFmtX71:

+ OutputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_BACK_LEFT |

+ SPEAKER_BACK_RIGHT |

+ SPEAKER_SIDE_LEFT |

+ SPEAKER_SIDE_RIGHT;

+ break;

+ }

+

+retry_open:

+ hr = S_OK;

+ OutputType.Format.wFormatTag = WAVE_FORMAT_PCM;

+ OutputType.Format.nChannels = ChannelsFromDevFmt(device->FmtChans, device->AmbiOrder);

+ OutputType.Format.wBitsPerSample = BytesFromDevFmt(device->FmtType) * 8;

+ OutputType.Format.nBlockAlign = OutputType.Format.nChannels*OutputType.Format.wBitsPerSample/8;

+ OutputType.Format.nSamplesPerSec = device->Frequency;

+ OutputType.Format.nAvgBytesPerSec = OutputType.Format.nSamplesPerSec*OutputType.Format.nBlockAlign;

+ OutputType.Format.cbSize = 0;

+ }

+

+ if(OutputType.Format.nChannels > 2 || device->FmtType == DevFmtFloat)

+ {

+ OutputType.Format.wFormatTag = WAVE_FORMAT_EXTENSIBLE;

+ OutputType.Samples.wValidBitsPerSample = OutputType.Format.wBitsPerSample;

+ OutputType.Format.cbSize = sizeof(WAVEFORMATEXTENSIBLE) - sizeof(WAVEFORMATEX);

+ if(device->FmtType == DevFmtFloat)

+ OutputType.SubFormat = KSDATAFORMAT_SUBTYPE_IEEE_FLOAT;

+ else

+ OutputType.SubFormat = KSDATAFORMAT_SUBTYPE_PCM;

+

+ if(self->PrimaryBuffer)

+ self->PrimaryBuffer->Release();

+ self->PrimaryBuffer = nullptr;

+ }

+ else

+ {

+ if(SUCCEEDED(hr) && !self->PrimaryBuffer)

+ {

+ DSBUFFERDESC DSBDescription{};

+ DSBDescription.dwSize = sizeof(DSBDescription);

+ DSBDescription.dwFlags = DSBCAPS_PRIMARYBUFFER;

+ hr = self->DS->CreateSoundBuffer(&DSBDescription, &self->PrimaryBuffer, nullptr);

+ }

+ if(SUCCEEDED(hr))

+ hr = self->PrimaryBuffer->SetFormat(&OutputType.Format);

+ }

+

+ if(SUCCEEDED(hr))

+ {

+ if(device->NumUpdates > MAX_UPDATES)

+ {

+ device->UpdateSize = (device->UpdateSize*device->NumUpdates +

+ MAX_UPDATES-1) / MAX_UPDATES;

+ device->NumUpdates = MAX_UPDATES;

+ }

+

+ DSBUFFERDESC DSBDescription{};

+ DSBDescription.dwSize = sizeof(DSBDescription);

+ DSBDescription.dwFlags = DSBCAPS_CTRLPOSITIONNOTIFY | DSBCAPS_GETCURRENTPOSITION2 |

+ DSBCAPS_GLOBALFOCUS;

+ DSBDescription.dwBufferBytes = device->UpdateSize * device->NumUpdates *

+ OutputType.Format.nBlockAlign;

+ DSBDescription.lpwfxFormat = &OutputType.Format;

+

+ hr = self->DS->CreateSoundBuffer(&DSBDescription, &self->Buffer, nullptr);

+ if(FAILED(hr) && device->FmtType == DevFmtFloat)

+ {

+ device->FmtType = DevFmtShort;

+ goto retry_open;

+ }

+ }

+

+ if(SUCCEEDED(hr))

+ {

+ void *ptr;

+ hr = self->Buffer->QueryInterface(IID_IDirectSoundNotify, &ptr);

+ if(SUCCEEDED(hr))

+ {

+ auto Notifies = reinterpret_cast<IDirectSoundNotify*>(ptr);

+ self->Notifies = Notifies;

+

+ device->NumUpdates = minu(device->NumUpdates, MAX_UPDATES);

+

+ std::array<DSBPOSITIONNOTIFY,MAX_UPDATES> nots;

+ for(ALuint i{0};i < device->NumUpdates;++i)

+ {

+ nots[i].dwOffset = i * device->UpdateSize * OutputType.Format.nBlockAlign;

+ nots[i].hEventNotify = self->NotifyEvent;

+ }

+ if(Notifies->SetNotificationPositions(device->NumUpdates, nots.data()) != DS_OK)

+ hr = E_FAIL;

+ }

+ }

+

+ if(FAILED(hr))

+ {

+ if(self->Notifies)

+ self->Notifies->Release();

+ self->Notifies = nullptr;

+ if(self->Buffer)

+ self->Buffer->Release();

+ self->Buffer = nullptr;

+ if(self->PrimaryBuffer)

+ self->PrimaryBuffer->Release();

+ self->PrimaryBuffer = nullptr;

+ return ALC_FALSE;

+ }

+

+ ResetEvent(self->NotifyEvent);

+ SetDefaultWFXChannelOrder(device);

+

+ return ALC_TRUE;

+}

+

+static ALCboolean ALCdsoundPlayback_start(ALCdsoundPlayback *self)

+{

+ try {

+ self->killNow.store(AL_FALSE, almemory_order_release);

+ self->thread = std::thread(ALCdsoundPlayback_mixerProc, self);

+ return ALC_TRUE;

+ }

+ catch(std::exception& e) {

+ ERR("Failed to start mixing thread: %s\n", e.what());

+ }

+ catch(...) {

+ }

+ return ALC_FALSE;

+}

+

+static void ALCdsoundPlayback_stop(ALCdsoundPlayback *self)

+{

+ if(self->killNow.exchange(AL_TRUE, almemory_order_acq_rel) || !self->thread.joinable())

+ return;

+

+ self->thread.join();

+

+ self->Buffer->Stop();

+}

+

+

+struct ALCdsoundCapture final : public ALCbackend {

+ IDirectSoundCapture *DSC{nullptr};

+ IDirectSoundCaptureBuffer *DSCbuffer{nullptr};

+ DWORD BufferBytes{0u};

+ DWORD Cursor{0u};

+

+ ll_ringbuffer_t *Ring{nullptr};

+};

+

+static void ALCdsoundCapture_Construct(ALCdsoundCapture *self, ALCdevice *device);

+static void ALCdsoundCapture_Destruct(ALCdsoundCapture *self);

+static ALCenum ALCdsoundCapture_open(ALCdsoundCapture *self, const ALCchar *name);

+static DECLARE_FORWARD(ALCdsoundCapture, ALCbackend, ALCboolean, reset)

+static ALCboolean ALCdsoundCapture_start(ALCdsoundCapture *self);

+static void ALCdsoundCapture_stop(ALCdsoundCapture *self);

+static ALCenum ALCdsoundCapture_captureSamples(ALCdsoundCapture *self, ALCvoid *buffer, ALCuint samples);

+static ALCuint ALCdsoundCapture_availableSamples(ALCdsoundCapture *self);

+static DECLARE_FORWARD(ALCdsoundCapture, ALCbackend, ClockLatency, getClockLatency)

+static DECLARE_FORWARD(ALCdsoundCapture, ALCbackend, void, lock)

+static DECLARE_FORWARD(ALCdsoundCapture, ALCbackend, void, unlock)

+DECLARE_DEFAULT_ALLOCATORS(ALCdsoundCapture)

+

+DEFINE_ALCBACKEND_VTABLE(ALCdsoundCapture);

+

+static void ALCdsoundCapture_Construct(ALCdsoundCapture *self, ALCdevice *device)

+{

+ new (self) ALCdsoundCapture{};

+ ALCbackend_Construct(STATIC_CAST(ALCbackend, self), device);

+ SET_VTABLE2(ALCdsoundCapture, ALCbackend, self);

+}

+

+static void ALCdsoundCapture_Destruct(ALCdsoundCapture *self)

+{

+ ll_ringbuffer_free(self->Ring);

+ self->Ring = nullptr;

+

+ if(self->DSCbuffer)

+ {

+ self->DSCbuffer->Stop();

+ self->DSCbuffer->Release();

+ self->DSCbuffer = nullptr;

+ }

+

+ if(self->DSC)

+ self->DSC->Release();

+ self->DSC = nullptr;

+

+ ALCbackend_Destruct(STATIC_CAST(ALCbackend, self));

+ self->~ALCdsoundCapture();

+}

+

+

+static ALCenum ALCdsoundCapture_open(ALCdsoundCapture *self, const ALCchar *deviceName)

+{

+ ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;

+

+ HRESULT hr;

+ if(CaptureDevices.empty())

+ {

+ /* Initialize COM to prevent name truncation */

+ HRESULT hrcom{CoInitialize(nullptr)};

+ hr = DirectSoundCaptureEnumerateW(DSoundEnumDevices, &CaptureDevices);

+ if(FAILED(hr))

+ ERR("Error enumerating DirectSound devices (0x%lx)!\n", hr);

+ if(SUCCEEDED(hrcom))

+ CoUninitialize();

+ }

+

+ const GUID *guid{nullptr};

+ if(!deviceName && !CaptureDevices.empty())

+ {

+ deviceName = CaptureDevices[0].name.c_str();

+ guid = &CaptureDevices[0].guid;

+ }

+ else

+ {

+ auto iter = std::find_if(CaptureDevices.cbegin(), CaptureDevices.cend(),

+ [deviceName](const DevMap &entry) -> bool

+ { return entry.name == deviceName; }

+ );

+ if(iter == CaptureDevices.cend())

+ return ALC_INVALID_VALUE;

+ guid = &iter->guid;

+ }

+

+ switch(device->FmtType)

+ {

+ case DevFmtByte:

+ case DevFmtUShort:

+ case DevFmtUInt:

+ WARN("%s capture samples not supported\n", DevFmtTypeString(device->FmtType));

+ return ALC_INVALID_ENUM;

+

+ case DevFmtUByte:

+ case DevFmtShort:

+ case DevFmtInt:

+ case DevFmtFloat:

+ break;

+ }

+

+ WAVEFORMATEXTENSIBLE InputType{};

+ switch(device->FmtChans)

+ {

+ case DevFmtMono:

+ InputType.dwChannelMask = SPEAKER_FRONT_CENTER;

+ break;

+ case DevFmtStereo:

+ InputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT;

+ break;

+ case DevFmtQuad:

+ InputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_BACK_LEFT |

+ SPEAKER_BACK_RIGHT;

+ break;

+ case DevFmtX51:

+ InputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_SIDE_LEFT |

+ SPEAKER_SIDE_RIGHT;

+ break;

+ case DevFmtX51Rear:

+ InputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_BACK_LEFT |

+ SPEAKER_BACK_RIGHT;

+ break;

+ case DevFmtX61:

+ InputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_BACK_CENTER |

+ SPEAKER_SIDE_LEFT |

+ SPEAKER_SIDE_RIGHT;

+ break;

+ case DevFmtX71:

+ InputType.dwChannelMask = SPEAKER_FRONT_LEFT |

+ SPEAKER_FRONT_RIGHT |

+ SPEAKER_FRONT_CENTER |

+ SPEAKER_LOW_FREQUENCY |

+ SPEAKER_BACK_LEFT |

+ SPEAKER_BACK_RIGHT |

+ SPEAKER_SIDE_LEFT |

+ SPEAKER_SIDE_RIGHT;

+ break;

+ case DevFmtAmbi3D:

+ WARN("%s capture not supported\n", DevFmtChannelsString(device->FmtChans));

+ return ALC_INVALID_ENUM;

+ }

+

+ InputType.Format.wFormatTag = WAVE_FORMAT_PCM;

+ InputType.Format.nChannels = ChannelsFromDevFmt(device->FmtChans, device->AmbiOrder);

+ InputType.Format.wBitsPerSample = BytesFromDevFmt(device->FmtType) * 8;

+ InputType.Format.nBlockAlign = InputType.Format.nChannels*InputType.Format.wBitsPerSample/8;

+ InputType.Format.nSamplesPerSec = device->Frequency;

+ InputType.Format.nAvgBytesPerSec = InputType.Format.nSamplesPerSec*InputType.Format.nBlockAlign;

+ InputType.Format.cbSize = 0;

+ InputType.Samples.wValidBitsPerSample = InputType.Format.wBitsPerSample;

+ if(device->FmtType == DevFmtFloat)

+ InputType.SubFormat = KSDATAFORMAT_SUBTYPE_IEEE_FLOAT;

+ else

+ InputType.SubFormat = KSDATAFORMAT_SUBTYPE_PCM;

+

+ if(InputType.Format.nChannels > 2 || device->FmtType == DevFmtFloat)

+ {

+ InputType.Format.wFormatTag = WAVE_FORMAT_EXTENSIBLE;

+ InputType.Format.cbSize = sizeof(WAVEFORMATEXTENSIBLE) - sizeof(WAVEFORMATEX);

+ }

+

+ ALuint samples{device->UpdateSize * device->NumUpdates};

+ samples = maxu(samples, 100 * device->Frequency / 1000);

+

+ DSCBUFFERDESC DSCBDescription{};

+ DSCBDescription.dwSize = sizeof(DSCBDescription);

+ DSCBDescription.dwFlags = 0;

+ DSCBDescription.dwBufferBytes = samples * InputType.Format.nBlockAlign;

+ DSCBDescription.lpwfxFormat = &InputType.Format;

+

+ //DirectSoundCapture Init code

+ hr = DirectSoundCaptureCreate(guid, &self->DSC, nullptr);

+ if(SUCCEEDED(hr))

+ self->DSC->CreateCaptureBuffer(&DSCBDescription, &self->DSCbuffer, nullptr);

+ if(SUCCEEDED(hr))

+ {

+ self->Ring = ll_ringbuffer_create(device->UpdateSize*device->NumUpdates,

+ InputType.Format.nBlockAlign, false);

+ if(!self->Ring) hr = DSERR_OUTOFMEMORY;

+ }

+

+ if(FAILED(hr))

+ {

+ ERR("Device init failed: 0x%08lx\n", hr);

+

+ ll_ringbuffer_free(self->Ring);

+ self->Ring = nullptr;

+ if(self->DSCbuffer)

+ self->DSCbuffer->Release();

+ self->DSCbuffer = nullptr;

+ if(self->DSC)

+ self->DSC->Release();

+ self->DSC = nullptr;

+

+ return ALC_INVALID_VALUE;

+ }

+

+ self->BufferBytes = DSCBDescription.dwBufferBytes;

+ SetDefaultWFXChannelOrder(device);

+

+ alstr_copy_cstr(&device->DeviceName, deviceName);

+

+ return ALC_NO_ERROR;

+}

+

+static ALCboolean ALCdsoundCapture_start(ALCdsoundCapture *self)

+{

+ HRESULT hr{self->DSCbuffer->Start(DSCBSTART_LOOPING)};

+ if(FAILED(hr))

+ {

+ ERR("start failed: 0x%08lx\n", hr);

+ aluHandleDisconnect(STATIC_CAST(ALCbackend, self)->mDevice,

+ "Failure starting capture: 0x%lx", hr);

+ return ALC_FALSE;

+ }

+

+ return ALC_TRUE;

+}

+

+static void ALCdsoundCapture_stop(ALCdsoundCapture *self)

+{

+ HRESULT hr{self->DSCbuffer->Stop()};

+ if(FAILED(hr))

+ {

+ ERR("stop failed: 0x%08lx\n", hr);

+ aluHandleDisconnect(STATIC_CAST(ALCbackend, self)->mDevice,

+ "Failure stopping capture: 0x%lx", hr);

+ }

+}

+

+static ALCenum ALCdsoundCapture_captureSamples(ALCdsoundCapture *self, ALCvoid *buffer, ALCuint samples)

+{

+ ll_ringbuffer_read(self->Ring, reinterpret_cast<char*>(buffer), samples);

+ return ALC_NO_ERROR;

+}

+

+static ALCuint ALCdsoundCapture_availableSamples(ALCdsoundCapture *self)

+{

+ ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;

+

+ if(!ATOMIC_LOAD(&device->Connected, almemory_order_acquire))

+ return ll_ringbuffer_read_space(self->Ring);

+

+ ALsizei FrameSize{FrameSizeFromDevFmt(device->FmtChans, device->FmtType, device->AmbiOrder)};

+ DWORD BufferBytes{self->BufferBytes};

+ DWORD LastCursor{self->Cursor};

+

+ DWORD ReadCursor;

+ void *ReadPtr1, *ReadPtr2;

+ DWORD ReadCnt1, ReadCnt2;

+ HRESULT hr{self->DSCbuffer->GetCurrentPosition(nullptr, &ReadCursor)};

+ if(SUCCEEDED(hr))

+ {

+ DWORD NumBytes{(ReadCursor-LastCursor + BufferBytes) % BufferBytes};

+ if(!NumBytes) return ll_ringbuffer_read_space(self->Ring);

+ hr = self->DSCbuffer->Lock(LastCursor, NumBytes, &ReadPtr1, &ReadCnt1,

+ &ReadPtr2, &ReadCnt2, 0);

+ }

+ if(SUCCEEDED(hr))

+ {

+ ll_ringbuffer_write(self->Ring, reinterpret_cast<const char*>(ReadPtr1),

+ ReadCnt1/FrameSize);

+ if(ReadPtr2 != nullptr)

+ ll_ringbuffer_write(self->Ring, reinterpret_cast<const char*>(ReadPtr2),

+ ReadCnt2/FrameSize);

+ hr = self->DSCbuffer->Unlock(ReadPtr1, ReadCnt1, ReadPtr2, ReadCnt2);

+ self->Cursor = (LastCursor+ReadCnt1+ReadCnt2) % BufferBytes;

+ }

+

+ if(FAILED(hr))

+ {

+ ERR("update failed: 0x%08lx\n", hr);

+ aluHandleDisconnect(device, "Failure retrieving capture data: 0x%lx", hr);

+ }

+

+ return ll_ringbuffer_read_space(self->Ring);

+}

+

+

+struct ALCdsoundBackendFactory final : public ALCbackendFactory {

+ ALCdsoundBackendFactory() noexcept;

+};

+#define ALCDSOUNDBACKENDFACTORY_INITIALIZER GET_VTABLE2(ALCdsoundBackendFactory, ALCbackendFactory)

+

+ALCbackendFactory *ALCdsoundBackendFactory_getFactory(void);

+

+static ALCboolean ALCdsoundBackendFactory_init(ALCdsoundBackendFactory *self);

+static void ALCdsoundBackendFactory_deinit(ALCdsoundBackendFactory *self);

+static ALCboolean ALCdsoundBackendFactory_querySupport(ALCdsoundBackendFactory *self, ALCbackend_Type type);

+static void ALCdsoundBackendFactory_probe(ALCdsoundBackendFactory *self, enum DevProbe type, al_string *outnames);

+static ALCbackend* ALCdsoundBackendFactory_createBackend(ALCdsoundBackendFactory *self, ALCdevice *device, ALCbackend_Type type);

+DEFINE_ALCBACKENDFACTORY_VTABLE(ALCdsoundBackendFactory);

+

+

+ALCdsoundBackendFactory::ALCdsoundBackendFactory() noexcept

+ : ALCbackendFactory{ALCDSOUNDBACKENDFACTORY_INITIALIZER}

+{ }

+

+

+ALCbackendFactory *ALCdsoundBackendFactory_getFactory(void)

+{

+ static ALCdsoundBackendFactory factory{};

+ return STATIC_CAST(ALCbackendFactory, &factory);

+}

+

+

+static ALCboolean ALCdsoundBackendFactory_init(ALCdsoundBackendFactory* UNUSED(self))

+{

+ if(!DSoundLoad())

+ return ALC_FALSE;

+ return ALC_TRUE;

+}

+

+static void ALCdsoundBackendFactory_deinit(ALCdsoundBackendFactory* UNUSED(self))

+{

+ PlaybackDevices.clear();

+ CaptureDevices.clear();

+

+#ifdef HAVE_DYNLOAD

+ if(ds_handle)

+ CloseLib(ds_handle);

+ ds_handle = nullptr;

+#endif

+}

+

+static ALCboolean ALCdsoundBackendFactory_querySupport(ALCdsoundBackendFactory* UNUSED(self), ALCbackend_Type type)

+{

+ if(type == ALCbackend_Playback || type == ALCbackend_Capture)

+ return ALC_TRUE;

+ return ALC_FALSE;

+}

+

+static void ALCdsoundBackendFactory_probe(ALCdsoundBackendFactory* UNUSED(self), enum DevProbe type, al_string *outnames)

+{

+ auto add_device = [outnames](const DevMap &entry) -> void

+ {

+ const char *name{entry.name.c_str()};

+ size_t namelen{entry.name.length()};

+ /* +1 to also append the null char (to ensure a null-separated list and

+ * double-null terminated list).

+ */

+ alstr_append_range(outnames, name, name + namelen+1);

+ };

+

+ /* Initialize COM to prevent name truncation */

+ HRESULT hr;

+ HRESULT hrcom{CoInitialize(nullptr)};

+ switch(type)

+ {

+ case ALL_DEVICE_PROBE:

+ PlaybackDevices.clear();

+ hr = DirectSoundEnumerateW(DSoundEnumDevices, &PlaybackDevices);

+ if(FAILED(hr))

+ ERR("Error enumerating DirectSound playback devices (0x%lx)!\n", hr);

+ std::for_each(PlaybackDevices.cbegin(), PlaybackDevices.cend(), add_device);

+ break;

+

+ case CAPTURE_DEVICE_PROBE:

+ CaptureDevices.clear();

+ hr = DirectSoundCaptureEnumerateW(DSoundEnumDevices, &CaptureDevices);

+ if(FAILED(hr))

+ ERR("Error enumerating DirectSound capture devices (0x%lx)!\n", hr);

+ std::for_each(CaptureDevices.cbegin(), CaptureDevices.cend(), add_device);

+ break;

+ }

+ if(SUCCEEDED(hrcom))

+ CoUninitialize();

+}

+

+static ALCbackend* ALCdsoundBackendFactory_createBackend(ALCdsoundBackendFactory* UNUSED(self), ALCdevice *device, ALCbackend_Type type)

+{

+ if(type == ALCbackend_Playback)

+ {

+ ALCdsoundPlayback *backend;

+ NEW_OBJ(backend, ALCdsoundPlayback)(device);

+ if(!backend) return nullptr;

+ return STATIC_CAST(ALCbackend, backend);

+ }

+

+ if(type == ALCbackend_Capture)

+ {

+ ALCdsoundCapture *backend;

+ NEW_OBJ(backend, ALCdsoundCapture)(device);

+ if(!backend) return nullptr;

+ return STATIC_CAST(ALCbackend, backend);

+ }

+

+ return nullptr;

+}