Alc/backends/winmm.c

   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 <stdlib.h>
  24 #include <stdio.h>
  25 #include <memory.h>
  26
  27 #include <windows.h>
  28 #include <mmsystem.h>
  29
  30 #include "alMain.h"
  31 #include "alu.h"
  32 #include "threads.h"
  33
  34 #include "backends/base.h"
  35
  36 #ifndef WAVE_FORMAT_IEEE_FLOAT
  37 #define WAVE_FORMAT_IEEE_FLOAT  0x0003
  38 #endif
  39
  40 #define DEVNAME_HEAD "OpenAL Soft on "
  41
  42
  43 static vector_al_string PlaybackDevices;
  44 static vector_al_string CaptureDevices;
  45
  46 static void clear_devlist(vector_al_string *list)
  47 {
  48     VECTOR_FOR_EACH(al_string, *list, al_string_deinit);
  49     VECTOR_RESIZE(*list, 0);
  50 }
  51
  52
  53 static void ProbePlaybackDevices(void)
  54 {
  55     ALuint numdevs;
  56     ALuint i;
  57
  58     clear_devlist(&PlaybackDevices);
  59
  60     numdevs = waveOutGetNumDevs();
  61     VECTOR_RESERVE(PlaybackDevices, numdevs);
  62     for(i = 0;i < numdevs;i++)
  63     {
  64         WAVEOUTCAPSW WaveCaps;
  65         const al_string *iter;
  66         al_string dname;
  67
  68         AL_STRING_INIT(dname);
  69         if(waveOutGetDevCapsW(i, &WaveCaps, sizeof(WaveCaps)) == MMSYSERR_NOERROR)
  70         {
  71             ALuint count = 0;
  72             while(1)
  73             {
  74                 al_string_copy_cstr(&dname, DEVNAME_HEAD);
  75                 al_string_append_wcstr(&dname, WaveCaps.szPname);
  76                 if(count != 0)
  77                 {
  78                     char str[64];
  79                     snprintf(str, sizeof(str), " #%d", count+1);
  80                     al_string_append_cstr(&dname, str);
  81                 }
  82                 count++;
  83
  84 #define MATCH_ENTRY(i) (al_string_cmp(dname, *(i)) == 0)
  85                 VECTOR_FIND_IF(iter, const al_string, PlaybackDevices, MATCH_ENTRY);
  86                 if(iter == VECTOR_END(PlaybackDevices)) break;
  87 #undef MATCH_ENTRY
  88             }
  89
  90             TRACE("Got device \"%s\", ID %u\n", al_string_get_cstr(dname), i);
  91         }
  92         VECTOR_PUSH_BACK(PlaybackDevices, dname);
  93     }
  94 }
  95
  96 static void ProbeCaptureDevices(void)
  97 {
  98     ALuint numdevs;
  99     ALuint i;
 100
 101     clear_devlist(&CaptureDevices);
 102
 103     numdevs = waveInGetNumDevs();
 104     VECTOR_RESERVE(CaptureDevices, numdevs);
 105     for(i = 0;i < numdevs;i++)
 106     {
 107         WAVEINCAPSW WaveCaps;
 108         const al_string *iter;
 109         al_string dname;
 110
 111         AL_STRING_INIT(dname);
 112         if(waveInGetDevCapsW(i, &WaveCaps, sizeof(WaveCaps)) == MMSYSERR_NOERROR)
 113         {
 114             ALuint count = 0;
 115             while(1)
 116             {
 117                 al_string_copy_cstr(&dname, DEVNAME_HEAD);
 118                 al_string_append_wcstr(&dname, WaveCaps.szPname);
 119                 if(count != 0)
 120                 {
 121                     char str[64];
 122                     snprintf(str, sizeof(str), " #%d", count+1);
 123                     al_string_append_cstr(&dname, str);
 124                 }
 125                 count++;
 126
 127 #define MATCH_ENTRY(i) (al_string_cmp(dname, *(i)) == 0)
 128                 VECTOR_FIND_IF(iter, const al_string, CaptureDevices, MATCH_ENTRY);
 129                 if(iter == VECTOR_END(CaptureDevices)) break;
 130 #undef MATCH_ENTRY
 131             }
 132
 133             TRACE("Got device \"%s\", ID %u\n", al_string_get_cstr(dname), i);
 134         }
 135         VECTOR_PUSH_BACK(CaptureDevices, dname);
 136     }
 137 }
 138
 139
 140 typedef struct ALCwinmmPlayback {
 141     DERIVE_FROM_TYPE(ALCbackend);
 142
 143     RefCount WaveBuffersCommitted;
 144     WAVEHDR WaveBuffer[4];
 145
 146     HWAVEOUT OutHdl;
 147
 148     WAVEFORMATEX Format;
 149
 150     volatile ALboolean killNow;
 151     althrd_t thread;
 152 } ALCwinmmPlayback;
 153
 154 static void ALCwinmmPlayback_Construct(ALCwinmmPlayback *self, ALCdevice *device);
 155 static void ALCwinmmPlayback_Destruct(ALCwinmmPlayback *self);
 156
 157 static void CALLBACK ALCwinmmPlayback_waveOutProc(HWAVEOUT device, UINT msg, DWORD_PTR instance, DWORD_PTR param1, DWORD_PTR param2);
 158 static int ALCwinmmPlayback_mixerProc(void *arg);
 159
 160 static ALCenum ALCwinmmPlayback_open(ALCwinmmPlayback *self, const ALCchar *name);
 161 static void ALCwinmmPlayback_close(ALCwinmmPlayback *self);
 162 static ALCboolean ALCwinmmPlayback_reset(ALCwinmmPlayback *self);
 163 static ALCboolean ALCwinmmPlayback_start(ALCwinmmPlayback *self);
 164 static void ALCwinmmPlayback_stop(ALCwinmmPlayback *self);
 165 static DECLARE_FORWARD2(ALCwinmmPlayback, ALCbackend, ALCenum, captureSamples, ALCvoid*, ALCuint)
 166 static DECLARE_FORWARD(ALCwinmmPlayback, ALCbackend, ALCuint, availableSamples)
 167 static DECLARE_FORWARD(ALCwinmmPlayback, ALCbackend, ALint64, getLatency)
 168 static DECLARE_FORWARD(ALCwinmmPlayback, ALCbackend, void, lock)
 169 static DECLARE_FORWARD(ALCwinmmPlayback, ALCbackend, void, unlock)
 170 DECLARE_DEFAULT_ALLOCATORS(ALCwinmmPlayback)
 171
 172 DEFINE_ALCBACKEND_VTABLE(ALCwinmmPlayback);
 173
 174
 175 static void ALCwinmmPlayback_Construct(ALCwinmmPlayback *self, ALCdevice *device)
 176 {
 177     ALCbackend_Construct(STATIC_CAST(ALCbackend, self), device);
 178     SET_VTABLE2(ALCwinmmPlayback, ALCbackend, self);
 179
 180     InitRef(&self->WaveBuffersCommitted, 0);
 181     self->OutHdl = NULL;
 182
 183     self->killNow = AL_TRUE;
 184 }
 185
 186 static void ALCwinmmPlayback_Destruct(ALCwinmmPlayback *self)
 187 {
 188     if(self->OutHdl)
 189         waveOutClose(self->OutHdl);
 190     self->OutHdl = 0;
 191
 192     ALCbackend_Destruct(STATIC_CAST(ALCbackend, self));
 193 }
 194
 195
 196 /* ALCwinmmPlayback_waveOutProc
 197  *
 198  * Posts a message to 'ALCwinmmPlayback_mixerProc' everytime a WaveOut Buffer
 199  * is completed and returns to the application (for more data)
 200  */
 201 static void CALLBACK ALCwinmmPlayback_waveOutProc(HWAVEOUT UNUSED(device), UINT msg, DWORD_PTR instance, DWORD_PTR param1, DWORD_PTR UNUSED(param2))
 202 {
 203     ALCwinmmPlayback *self = (ALCwinmmPlayback*)instance;
 204
 205     if(msg != WOM_DONE)
 206         return;
 207
 208     DecrementRef(&self->WaveBuffersCommitted);
 209     PostThreadMessage(self->thread, msg, 0, param1);
 210 }
 211
 212 FORCE_ALIGN static int ALCwinmmPlayback_mixerProc(void *arg)
 213 {
 214     ALCwinmmPlayback *self = arg;
 215     ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;
 216     WAVEHDR *WaveHdr;
 217     MSG msg;
 218
 219     SetRTPriority();
 220     althrd_setname(althrd_current(), MIXER_THREAD_NAME);
 221
 222     while(GetMessage(&msg, NULL, 0, 0))
 223     {
 224         if(msg.message != WOM_DONE)
 225             continue;
 226
 227         if(self->killNow)
 228         {
 229             if(ReadRef(&self->WaveBuffersCommitted) == 0)
 230                 break;
 231             continue;
 232         }
 233
 234         WaveHdr = ((WAVEHDR*)msg.lParam);
 235         aluMixData(device, WaveHdr->lpData, WaveHdr->dwBufferLength /
 236                                             self->Format.nBlockAlign);
 237
 238         // Send buffer back to play more data
 239         waveOutWrite(self->OutHdl, WaveHdr, sizeof(WAVEHDR));
 240         IncrementRef(&self->WaveBuffersCommitted);
 241     }
 242
 243     return 0;
 244 }
 245
 246
 247 static ALCenum ALCwinmmPlayback_open(ALCwinmmPlayback *self, const ALCchar *deviceName)
 248 {
 249     ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;
 250     const al_string *iter;
 251     UINT DeviceID;
 252     MMRESULT res;
 253
 254     if(VECTOR_SIZE(PlaybackDevices) == 0)
 255         ProbePlaybackDevices();
 256
 257     // Find the Device ID matching the deviceName if valid
 258 #define MATCH_DEVNAME(iter) (!al_string_empty(*(iter)) && \
 259                              (!deviceName || al_string_cmp_cstr(*(iter), deviceName) == 0))
 260     VECTOR_FIND_IF(iter, const al_string, PlaybackDevices, MATCH_DEVNAME);
 261     if(iter == VECTOR_END(PlaybackDevices))
 262         return ALC_INVALID_VALUE;
 263 #undef MATCH_DEVNAME
 264
 265     DeviceID = (UINT)(iter - VECTOR_BEGIN(PlaybackDevices));
 266
 267 retry_open:
 268     memset(&self->Format, 0, sizeof(WAVEFORMATEX));
 269     if(device->FmtType == DevFmtFloat)
 270     {
 271         self->Format.wFormatTag = WAVE_FORMAT_IEEE_FLOAT;
 272         self->Format.wBitsPerSample = 32;
 273     }
 274     else
 275     {
 276         self->Format.wFormatTag = WAVE_FORMAT_PCM;
 277         if(device->FmtType == DevFmtUByte || device->FmtType == DevFmtByte)
 278             self->Format.wBitsPerSample = 8;
 279         else
 280             self->Format.wBitsPerSample = 16;
 281     }
 282     self->Format.nChannels = ((device->FmtChans == DevFmtMono) ? 1 : 2);
 283     self->Format.nBlockAlign = self->Format.wBitsPerSample *
 284                                self->Format.nChannels / 8;
 285     self->Format.nSamplesPerSec = device->Frequency;
 286     self->Format.nAvgBytesPerSec = self->Format.nSamplesPerSec *
 287                                    self->Format.nBlockAlign;
 288     self->Format.cbSize = 0;
 289
 290     if((res=waveOutOpen(&self->OutHdl, DeviceID, &self->Format, (DWORD_PTR)&ALCwinmmPlayback_waveOutProc, (DWORD_PTR)self, CALLBACK_FUNCTION)) != MMSYSERR_NOERROR)
 291     {
 292         if(device->FmtType == DevFmtFloat)
 293         {
 294             device->FmtType = DevFmtShort;
 295             goto retry_open;
 296         }
 297         ERR("waveOutOpen failed: %u\n", res);
 298         goto failure;
 299     }
 300
 301     al_string_copy(&device->DeviceName, VECTOR_ELEM(PlaybackDevices, DeviceID));
 302     return ALC_NO_ERROR;
 303
 304 failure:
 305     if(self->OutHdl)
 306         waveOutClose(self->OutHdl);
 307     self->OutHdl = NULL;
 308
 309     return ALC_INVALID_VALUE;
 310 }
 311
 312 static void ALCwinmmPlayback_close(ALCwinmmPlayback* UNUSED(self))
 313 { }
 314
 315 static ALCboolean ALCwinmmPlayback_reset(ALCwinmmPlayback *self)
 316 {
 317     ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;
 318
 319     device->UpdateSize = (ALuint)((ALuint64)device->UpdateSize *
 320                                   self->Format.nSamplesPerSec /
 321                                   device->Frequency);
 322     device->UpdateSize = (device->UpdateSize*device->NumUpdates + 3) / 4;
 323     device->NumUpdates = 4;
 324     device->Frequency = self->Format.nSamplesPerSec;
 325
 326     if(self->Format.wFormatTag == WAVE_FORMAT_IEEE_FLOAT)
 327     {
 328         if(self->Format.wBitsPerSample == 32)
 329             device->FmtType = DevFmtFloat;
 330         else
 331         {
 332             ERR("Unhandled IEEE float sample depth: %d\n", self->Format.wBitsPerSample);
 333             return ALC_FALSE;
 334         }
 335     }
 336     else if(self->Format.wFormatTag == WAVE_FORMAT_PCM)
 337     {
 338         if(self->Format.wBitsPerSample == 16)
 339             device->FmtType = DevFmtShort;
 340         else if(self->Format.wBitsPerSample == 8)
 341             device->FmtType = DevFmtUByte;
 342         else
 343         {
 344             ERR("Unhandled PCM sample depth: %d\n", self->Format.wBitsPerSample);
 345             return ALC_FALSE;
 346         }
 347     }
 348     else
 349     {
 350         ERR("Unhandled format tag: 0x%04x\n", self->Format.wFormatTag);
 351         return ALC_FALSE;
 352     }
 353
 354     if(self->Format.nChannels == 2)
 355         device->FmtChans = DevFmtStereo;
 356     else if(self->Format.nChannels == 1)
 357         device->FmtChans = DevFmtMono;
 358     else
 359     {
 360         ERR("Unhandled channel count: %d\n", self->Format.nChannels);
 361         return ALC_FALSE;
 362     }
 363     SetDefaultWFXChannelOrder(device);
 364
 365     return ALC_TRUE;
 366 }
 367
 368 static ALCboolean ALCwinmmPlayback_start(ALCwinmmPlayback *self)
 369 {
 370     ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;
 371     ALbyte *BufferData;
 372     ALint BufferSize;
 373     ALuint i;
 374
 375     self->killNow = AL_FALSE;
 376     if(althrd_create(&self->thread, ALCwinmmPlayback_mixerProc, self) != althrd_success)
 377         return ALC_FALSE;
 378
 379     InitRef(&self->WaveBuffersCommitted, 0);
 380
 381     // Create 4 Buffers
 382     BufferSize  = device->UpdateSize*device->NumUpdates / 4;
 383     BufferSize *= FrameSizeFromDevFmt(device->FmtChans, device->FmtType);
 384
 385     BufferData = calloc(4, BufferSize);
 386     for(i = 0;i < 4;i++)
 387     {
 388         memset(&self->WaveBuffer[i], 0, sizeof(WAVEHDR));
 389         self->WaveBuffer[i].dwBufferLength = BufferSize;
 390         self->WaveBuffer[i].lpData = ((i==0) ? (CHAR*)BufferData :
 391                                       (self->WaveBuffer[i-1].lpData +
 392                                        self->WaveBuffer[i-1].dwBufferLength));
 393         waveOutPrepareHeader(self->OutHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 394         waveOutWrite(self->OutHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 395         IncrementRef(&self->WaveBuffersCommitted);
 396     }
 397
 398     return ALC_TRUE;
 399 }
 400
 401 static void ALCwinmmPlayback_stop(ALCwinmmPlayback *self)
 402 {
 403     void *buffer = NULL;
 404     int i;
 405
 406     if(self->killNow)
 407         return;
 408
 409     // Set flag to stop processing headers
 410     self->killNow = AL_TRUE;
 411     althrd_join(self->thread, &i);
 412
 413     // Release the wave buffers
 414     for(i = 0;i < 4;i++)
 415     {
 416         waveOutUnprepareHeader(self->OutHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 417         if(i == 0) buffer = self->WaveBuffer[i].lpData;
 418         self->WaveBuffer[i].lpData = NULL;
 419     }
 420     free(buffer);
 421 }
 422
 423
 424
 425 typedef struct ALCwinmmCapture {
 426     DERIVE_FROM_TYPE(ALCbackend);
 427
 428     RefCount WaveBuffersCommitted;
 429     WAVEHDR WaveBuffer[4];
 430
 431     HWAVEIN InHdl;
 432
 433     ll_ringbuffer_t *Ring;
 434
 435     WAVEFORMATEX Format;
 436
 437     volatile ALboolean killNow;
 438     althrd_t thread;
 439 } ALCwinmmCapture;
 440
 441 static void ALCwinmmCapture_Construct(ALCwinmmCapture *self, ALCdevice *device);
 442 static void ALCwinmmCapture_Destruct(ALCwinmmCapture *self);
 443
 444 static void CALLBACK ALCwinmmCapture_waveInProc(HWAVEIN device, UINT msg, DWORD_PTR instance, DWORD_PTR param1, DWORD_PTR param2);
 445 static int ALCwinmmCapture_captureProc(void *arg);
 446
 447 static ALCenum ALCwinmmCapture_open(ALCwinmmCapture *self, const ALCchar *name);
 448 static void ALCwinmmCapture_close(ALCwinmmCapture *self);
 449 static DECLARE_FORWARD(ALCwinmmCapture, ALCbackend, ALCboolean, reset)
 450 static ALCboolean ALCwinmmCapture_start(ALCwinmmCapture *self);
 451 static void ALCwinmmCapture_stop(ALCwinmmCapture *self);
 452 static ALCenum ALCwinmmCapture_captureSamples(ALCwinmmCapture *self, ALCvoid *buffer, ALCuint samples);
 453 static ALCuint ALCwinmmCapture_availableSamples(ALCwinmmCapture *self);
 454 static DECLARE_FORWARD(ALCwinmmCapture, ALCbackend, ALint64, getLatency)
 455 static DECLARE_FORWARD(ALCwinmmCapture, ALCbackend, void, lock)
 456 static DECLARE_FORWARD(ALCwinmmCapture, ALCbackend, void, unlock)
 457 DECLARE_DEFAULT_ALLOCATORS(ALCwinmmCapture)
 458
 459 DEFINE_ALCBACKEND_VTABLE(ALCwinmmCapture);
 460
 461
 462 static void ALCwinmmCapture_Construct(ALCwinmmCapture *self, ALCdevice *device)
 463 {
 464     ALCbackend_Construct(STATIC_CAST(ALCbackend, self), device);
 465     SET_VTABLE2(ALCwinmmCapture, ALCbackend, self);
 466
 467     InitRef(&self->WaveBuffersCommitted, 0);
 468     self->InHdl = NULL;
 469
 470     self->killNow = AL_TRUE;
 471 }
 472
 473 static void ALCwinmmCapture_Destruct(ALCwinmmCapture *self)
 474 {
 475     if(self->InHdl)
 476         waveInClose(self->InHdl);
 477     self->InHdl = 0;
 478
 479     ALCbackend_Destruct(STATIC_CAST(ALCbackend, self));
 480 }
 481
 482
 483 /* ALCwinmmCapture_waveInProc
 484  *
 485  * Posts a message to 'ALCwinmmCapture_captureProc' everytime a WaveIn Buffer
 486  * is completed and returns to the application (with more data).
 487  */
 488 static void CALLBACK ALCwinmmCapture_waveInProc(HWAVEIN UNUSED(device), UINT msg, DWORD_PTR instance, DWORD_PTR param1, DWORD_PTR UNUSED(param2))
 489 {
 490     ALCwinmmCapture *self = (ALCwinmmCapture*)instance;
 491
 492     if(msg != WIM_DATA)
 493         return;
 494
 495     DecrementRef(&self->WaveBuffersCommitted);
 496     PostThreadMessage(self->thread, msg, 0, param1);
 497 }
 498
 499 static int ALCwinmmCapture_captureProc(void *arg)
 500 {
 501     ALCwinmmCapture *self = arg;
 502     WAVEHDR *WaveHdr;
 503     MSG msg;
 504
 505     althrd_setname(althrd_current(), RECORD_THREAD_NAME);
 506
 507     while(GetMessage(&msg, NULL, 0, 0))
 508     {
 509         if(msg.message != WIM_DATA)
 510             continue;
 511         /* Don't wait for other buffers to finish before quitting. We're
 512          * closing so we don't need them. */
 513         if(self->killNow)
 514             break;
 515
 516         WaveHdr = ((WAVEHDR*)msg.lParam);
 517         ll_ringbuffer_write(self->Ring, WaveHdr->lpData,
 518             WaveHdr->dwBytesRecorded / self->Format.nBlockAlign
 519         );
 520
 521         // Send buffer back to capture more data
 522         waveInAddBuffer(self->InHdl, WaveHdr, sizeof(WAVEHDR));
 523         IncrementRef(&self->WaveBuffersCommitted);
 524     }
 525
 526     return 0;
 527 }
 528
 529
 530 static ALCenum ALCwinmmCapture_open(ALCwinmmCapture *self, const ALCchar *name)
 531 {
 532     ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;
 533     const al_string *iter;
 534     ALbyte *BufferData = NULL;
 535     DWORD CapturedDataSize;
 536     ALint BufferSize;
 537     UINT DeviceID;
 538     MMRESULT res;
 539     ALuint i;
 540
 541     if(VECTOR_SIZE(CaptureDevices) == 0)
 542         ProbeCaptureDevices();
 543
 544     // Find the Device ID matching the deviceName if valid
 545 #define MATCH_DEVNAME(iter) (!al_string_empty(*(iter)) &&  (!name || al_string_cmp_cstr(*iter, name) == 0))
 546     VECTOR_FIND_IF(iter, const al_string, CaptureDevices, MATCH_DEVNAME);
 547     if(iter == VECTOR_END(CaptureDevices))
 548         return ALC_INVALID_VALUE;
 549 #undef MATCH_DEVNAME
 550
 551     DeviceID = (UINT)(iter - VECTOR_BEGIN(CaptureDevices));
 552
 553     switch(device->FmtChans)
 554     {
 555         case DevFmtMono:
 556         case DevFmtStereo:
 557             break;
 558
 559         case DevFmtQuad:
 560         case DevFmtX51:
 561         case DevFmtX51Rear:
 562         case DevFmtX61:
 563         case DevFmtX71:
 564         case DevFmtBFormat3D:
 565             return ALC_INVALID_ENUM;
 566     }
 567
 568     switch(device->FmtType)
 569     {
 570         case DevFmtUByte:
 571         case DevFmtShort:
 572         case DevFmtInt:
 573         case DevFmtFloat:
 574             break;
 575
 576         case DevFmtByte:
 577         case DevFmtUShort:
 578         case DevFmtUInt:
 579             return ALC_INVALID_ENUM;
 580     }
 581
 582     memset(&self->Format, 0, sizeof(WAVEFORMATEX));
 583     self->Format.wFormatTag = ((device->FmtType == DevFmtFloat) ?
 584                                WAVE_FORMAT_IEEE_FLOAT : WAVE_FORMAT_PCM);
 585     self->Format.nChannels = ChannelsFromDevFmt(device->FmtChans);
 586     self->Format.wBitsPerSample = BytesFromDevFmt(device->FmtType) * 8;
 587     self->Format.nBlockAlign = self->Format.wBitsPerSample *
 588                                self->Format.nChannels / 8;
 589     self->Format.nSamplesPerSec = device->Frequency;
 590     self->Format.nAvgBytesPerSec = self->Format.nSamplesPerSec *
 591                                    self->Format.nBlockAlign;
 592     self->Format.cbSize = 0;
 593
 594     if((res=waveInOpen(&self->InHdl, DeviceID, &self->Format, (DWORD_PTR)&ALCwinmmCapture_waveInProc, (DWORD_PTR)self, CALLBACK_FUNCTION)) != MMSYSERR_NOERROR)
 595     {
 596         ERR("waveInOpen failed: %u\n", res);
 597         goto failure;
 598     }
 599
 600     // Allocate circular memory buffer for the captured audio
 601     CapturedDataSize = device->UpdateSize*device->NumUpdates;
 602
 603     // Make sure circular buffer is at least 100ms in size
 604     if(CapturedDataSize < (self->Format.nSamplesPerSec / 10))
 605         CapturedDataSize = self->Format.nSamplesPerSec / 10;
 606
 607     self->Ring = ll_ringbuffer_create(CapturedDataSize+1, self->Format.nBlockAlign);
 608     if(!self->Ring) goto failure;
 609
 610     InitRef(&self->WaveBuffersCommitted, 0);
 611
 612     // Create 4 Buffers of 50ms each
 613     BufferSize = self->Format.nAvgBytesPerSec / 20;
 614     BufferSize -= (BufferSize % self->Format.nBlockAlign);
 615
 616     BufferData = calloc(4, BufferSize);
 617     if(!BufferData) goto failure;
 618
 619     for(i = 0;i < 4;i++)
 620     {
 621         memset(&self->WaveBuffer[i], 0, sizeof(WAVEHDR));
 622         self->WaveBuffer[i].dwBufferLength = BufferSize;
 623         self->WaveBuffer[i].lpData = ((i==0) ? (CHAR*)BufferData :
 624                                       (self->WaveBuffer[i-1].lpData +
 625                                        self->WaveBuffer[i-1].dwBufferLength));
 626         self->WaveBuffer[i].dwFlags = 0;
 627         self->WaveBuffer[i].dwLoops = 0;
 628         waveInPrepareHeader(self->InHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 629         waveInAddBuffer(self->InHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 630         IncrementRef(&self->WaveBuffersCommitted);
 631     }
 632
 633     self->killNow = AL_FALSE;
 634     if(althrd_create(&self->thread, ALCwinmmCapture_captureProc, self) != althrd_success)
 635         goto failure;
 636
 637     al_string_copy(&device->DeviceName, VECTOR_ELEM(CaptureDevices, DeviceID));
 638     return ALC_NO_ERROR;
 639
 640 failure:
 641     if(BufferData)
 642     {
 643         for(i = 0;i < 4;i++)
 644             waveInUnprepareHeader(self->InHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 645         free(BufferData);
 646     }
 647
 648     ll_ringbuffer_free(self->Ring);
 649     self->Ring = NULL;
 650
 651     if(self->InHdl)
 652         waveInClose(self->InHdl);
 653     self->InHdl = NULL;
 654
 655     return ALC_INVALID_VALUE;
 656 }
 657
 658 static void ALCwinmmCapture_close(ALCwinmmCapture *self)
 659 {
 660     void *buffer = NULL;
 661     int i;
 662
 663     /* Tell the processing thread to quit and wait for it to do so. */
 664     self->killNow = AL_TRUE;
 665     PostThreadMessage(self->thread, WM_QUIT, 0, 0);
 666
 667     althrd_join(self->thread, &i);
 668
 669     /* Make sure capture is stopped and all pending buffers are flushed. */
 670     waveInReset(self->InHdl);
 671
 672     // Release the wave buffers
 673     for(i = 0;i < 4;i++)
 674     {
 675         waveInUnprepareHeader(self->InHdl, &self->WaveBuffer[i], sizeof(WAVEHDR));
 676         if(i == 0) buffer = self->WaveBuffer[i].lpData;
 677         self->WaveBuffer[i].lpData = NULL;
 678     }
 679     free(buffer);
 680
 681     ll_ringbuffer_free(self->Ring);
 682     self->Ring = NULL;
 683
 684     // Close the Wave device
 685     waveInClose(self->InHdl);
 686     self->InHdl = NULL;
 687 }
 688
 689 static ALCboolean ALCwinmmCapture_start(ALCwinmmCapture *self)
 690 {
 691     waveInStart(self->InHdl);
 692     return ALC_TRUE;
 693 }
 694
 695 static void ALCwinmmCapture_stop(ALCwinmmCapture *self)
 696 {
 697     waveInStop(self->InHdl);
 698 }
 699
 700 static ALCenum ALCwinmmCapture_captureSamples(ALCwinmmCapture *self, ALCvoid *buffer, ALCuint samples)
 701 {
 702     ll_ringbuffer_read(self->Ring, buffer, samples);
 703     return ALC_NO_ERROR;
 704 }
 705
 706 static ALCuint ALCwinmmCapture_availableSamples(ALCwinmmCapture *self)
 707 {
 708     return ll_ringbuffer_read_space(self->Ring);
 709 }
 710
 711
 712 static inline void AppendAllDevicesList2(const al_string *name)
 713 {
 714     if(!al_string_empty(*name))
 715         AppendAllDevicesList(al_string_get_cstr(*name));
 716 }
 717 static inline void AppendCaptureDeviceList2(const al_string *name)
 718 {
 719     if(!al_string_empty(*name))
 720         AppendCaptureDeviceList(al_string_get_cstr(*name));
 721 }
 722
 723 typedef struct ALCwinmmBackendFactory {
 724     DERIVE_FROM_TYPE(ALCbackendFactory);
 725 } ALCwinmmBackendFactory;
 726 #define ALCWINMMBACKENDFACTORY_INITIALIZER { { GET_VTABLE2(ALCwinmmBackendFactory, ALCbackendFactory) } }
 727
 728 static ALCboolean ALCwinmmBackendFactory_init(ALCwinmmBackendFactory *self);
 729 static void ALCwinmmBackendFactory_deinit(ALCwinmmBackendFactory *self);
 730 static ALCboolean ALCwinmmBackendFactory_querySupport(ALCwinmmBackendFactory *self, ALCbackend_Type type);
 731 static void ALCwinmmBackendFactory_probe(ALCwinmmBackendFactory *self, enum DevProbe type);
 732 static ALCbackend* ALCwinmmBackendFactory_createBackend(ALCwinmmBackendFactory *self, ALCdevice *device, ALCbackend_Type type);
 733
 734 DEFINE_ALCBACKENDFACTORY_VTABLE(ALCwinmmBackendFactory);
 735
 736
 737 static ALCboolean ALCwinmmBackendFactory_init(ALCwinmmBackendFactory* UNUSED(self))
 738 {
 739     VECTOR_INIT(PlaybackDevices);
 740     VECTOR_INIT(CaptureDevices);
 741
 742     return ALC_TRUE;
 743 }
 744
 745 static void ALCwinmmBackendFactory_deinit(ALCwinmmBackendFactory* UNUSED(self))
 746 {
 747     clear_devlist(&PlaybackDevices);
 748     VECTOR_DEINIT(PlaybackDevices);
 749
 750     clear_devlist(&CaptureDevices);
 751     VECTOR_DEINIT(CaptureDevices);
 752 }
 753
 754 static ALCboolean ALCwinmmBackendFactory_querySupport(ALCwinmmBackendFactory* UNUSED(self), ALCbackend_Type type)
 755 {
 756     if(type == ALCbackend_Playback || type == ALCbackend_Capture)
 757         return ALC_TRUE;
 758     return ALC_FALSE;
 759 }
 760
 761 static void ALCwinmmBackendFactory_probe(ALCwinmmBackendFactory* UNUSED(self), enum DevProbe type)
 762 {
 763     switch(type)
 764     {
 765         case ALL_DEVICE_PROBE:
 766             ProbePlaybackDevices();
 767             VECTOR_FOR_EACH(const al_string, PlaybackDevices, AppendAllDevicesList2);
 768             break;
 769
 770         case CAPTURE_DEVICE_PROBE:
 771             ProbeCaptureDevices();
 772             VECTOR_FOR_EACH(const al_string, CaptureDevices, AppendCaptureDeviceList2);
 773             break;
 774     }
 775 }
 776
 777 static ALCbackend* ALCwinmmBackendFactory_createBackend(ALCwinmmBackendFactory* UNUSED(self), ALCdevice *device, ALCbackend_Type type)
 778 {
 779     if(type == ALCbackend_Playback)
 780     {
 781         ALCwinmmPlayback *backend;
 782         NEW_OBJ(backend, ALCwinmmPlayback)(device);
 783         if(!backend) return NULL;
 784         return STATIC_CAST(ALCbackend, backend);
 785     }
 786     if(type == ALCbackend_Capture)
 787     {
 788         ALCwinmmCapture *backend;
 789         NEW_OBJ(backend, ALCwinmmCapture)(device);
 790         if(!backend) return NULL;
 791         return STATIC_CAST(ALCbackend, backend);
 792     }
 793
 794     return NULL;
 795 }
 796
 797 ALCbackendFactory *ALCwinmmBackendFactory_getFactory(void)
 798 {
 799     static ALCwinmmBackendFactory factory = ALCWINMMBACKENDFACTORY_INITIALIZER;
 800     return STATIC_CAST(ALCbackendFactory, &factory);
 801 }