?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
wineoss.drv: Remove wave, mixer, and dsound driver code.
[wine/wine-gecko.git] / dlls / winecoreaudio.drv / audio.c
blobf7e2dca6431f527115174cd6e668a9f5e30c5576
1 /*
2 * Wine Driver for CoreAudio based on Jack Driver
3 *
4 * Copyright 1994 Martin Ayotte
5 * Copyright 1999 Eric Pouech (async playing in waveOut/waveIn)
6 * Copyright 2000 Eric Pouech (loops in waveOut)
7 * Copyright 2002 Chris Morgan (jack version of this file)
8 * Copyright 2005, 2006 Emmanuel Maillard
9 *
10 * This library is free software; you can redistribute it and/or
11 * modify it under the terms of the GNU Lesser General Public
12 * License as published by the Free Software Foundation; either
13 * version 2.1 of the License, or (at your option) any later version.
14 *
15 * This library is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
18 * Lesser General Public License for more details.
19 *
20 * You should have received a copy of the GNU Lesser General Public
21 * License along with this library; if not, write to the Free Software
22 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
23 */
24
25 #include "config.h"
26
27 #include <stdlib.h>
28 #include <stdarg.h>
29 #include <stdio.h>
30 #include <string.h>
31 #ifdef HAVE_UNISTD_H
32 # include <unistd.h>
33 #endif
34 #include <fcntl.h>
35 #include <assert.h>
36
37 #ifdef HAVE_COREAUDIO_COREAUDIO_H
38 #include <CoreAudio/CoreAudio.h>
39 #include <CoreFoundation/CoreFoundation.h>
40 #include <libkern/OSAtomic.h>
41 #endif
42
43 #include "windef.h"
44 #include "winbase.h"
45 #include "winnls.h"
46 #include "wingdi.h"
47 #include "winerror.h"
48 #include "mmddk.h"
49 #include "mmreg.h"
50 #include "dsound.h"
51 #include "dsdriver.h"
52 #include "ks.h"
53 #include "coreaudio.h"
54 #include "wine/unicode.h"
55 #include "wine/library.h"
56 #include "wine/debug.h"
57 #include "wine/list.h"
58
59 #include "initguid.h"
60 #include "ksmedia.h"
61
62 WINE_DEFAULT_DEBUG_CHANNEL(wave);
63 WINE_DECLARE_DEBUG_CHANNEL(coreaudio);
64
65 /*
66 Due to AudioUnit headers conflict define some needed types.
67 */
68
69 typedef void *AudioUnit;
70
71 /* From AudioUnit/AUComponents.h */
72 enum
73 {
74 kAudioUnitRenderAction_OutputIsSilence = (1 << 4),
75 /* provides hint on return from Render(): if set the buffer contains all zeroes */
76 };
77 typedef UInt32 AudioUnitRenderActionFlags;
78
79 typedef long ComponentResult;
80 extern ComponentResult
81 AudioUnitRender( AudioUnit ci,
82 AudioUnitRenderActionFlags * ioActionFlags,
83 const AudioTimeStamp * inTimeStamp,
84 UInt32 inOutputBusNumber,
85 UInt32 inNumberFrames,
86 AudioBufferList * ioData) AVAILABLE_MAC_OS_X_VERSION_10_2_AND_LATER;
87
88 /* only allow 10 output devices through this driver, this ought to be adequate */
89 #define MAX_WAVEOUTDRV (1)
90 #define MAX_WAVEINDRV (1)
91
92 /* state diagram for waveOut writing:
93 *
94 * +---------+-------------+---------------+---------------------------------+
95 * | state | function | event | new state |
96 * +---------+-------------+---------------+---------------------------------+
97 * | | open() | | PLAYING |
98 * | PAUSED | write() | | PAUSED |
99 * | PLAYING | write() | HEADER | PLAYING |
100 * | (other) | write() | <error> | |
101 * | (any) | pause() | PAUSING | PAUSED |
102 * | PAUSED | restart() | RESTARTING | PLAYING |
103 * | (any) | reset() | RESETTING | PLAYING |
104 * | (any) | close() | CLOSING | <deallocated> |
105 * +---------+-------------+---------------+---------------------------------+
106 */
107
108 /* states of the playing device */
109 #define WINE_WS_PLAYING 0 /* for waveOut: lpPlayPtr == NULL -> stopped */
110 #define WINE_WS_PAUSED 1
111 #define WINE_WS_STOPPED 2 /* Not used for waveOut */
112 #define WINE_WS_CLOSED 3 /* Not used for waveOut */
113 #define WINE_WS_OPENING 4
114 #define WINE_WS_CLOSING 5
115
116 typedef struct tagCoreAudio_Device {
117 char dev_name[32];
118 char mixer_name[32];
119 unsigned open_count;
120 char* interface_name;
121
122 WAVEOUTCAPSW out_caps;
123 WAVEINCAPSW in_caps;
124 DWORD in_caps_support;
125 int sample_rate;
126 int stereo;
127 int format;
128 unsigned audio_fragment;
129 BOOL full_duplex;
130 BOOL bTriggerSupport;
131 BOOL bOutputEnabled;
132 BOOL bInputEnabled;
133 DSDRIVERDESC ds_desc;
134 DSDRIVERCAPS ds_caps;
135 DSCDRIVERCAPS dsc_caps;
136 GUID ds_guid;
137 GUID dsc_guid;
138
139 AudioDeviceID outputDeviceID;
140 AudioDeviceID inputDeviceID;
141 AudioStreamBasicDescription streamDescription;
142 } CoreAudio_Device;
143
144 /* for now use the default device */
145 static CoreAudio_Device CoreAudio_DefaultDevice;
146
147 typedef struct {
148 struct list entry;
149
150 volatile int state; /* one of the WINE_WS_ manifest constants */
151 WAVEOPENDESC waveDesc;
152 WORD wFlags;
153 PCMWAVEFORMAT format;
154 DWORD woID;
155 AudioUnit audioUnit;
156 AudioStreamBasicDescription streamDescription;
157
158 LPWAVEHDR lpQueuePtr; /* start of queued WAVEHDRs (waiting to be notified) */
159 LPWAVEHDR lpPlayPtr; /* start of not yet fully played buffers */
160 DWORD dwPartialOffset; /* Offset of not yet written bytes in lpPlayPtr */
161
162 LPWAVEHDR lpLoopPtr; /* pointer of first buffer in loop, if any */
163 DWORD dwLoops; /* private copy of loop counter */
164
165 DWORD dwPlayedTotal; /* number of bytes actually played since opening */
166
167 OSSpinLock lock; /* synchronization stuff */
168 } WINE_WAVEOUT_INSTANCE;
169
170 typedef struct {
171 CoreAudio_Device *cadev;
172 WAVEOUTCAPSW caps;
173 char interface_name[32];
174 DWORD device_volume;
175
176 BOOL trace_on;
177 BOOL warn_on;
178 BOOL err_on;
179
180 struct list instances;
181 OSSpinLock lock; /* guards the instances list */
182 } WINE_WAVEOUT;
183
184 typedef struct {
185 /* This device's device number */
186 DWORD wiID;
187
188 /* Access to the following fields is synchronized across threads. */
189 volatile int state;
190 LPWAVEHDR lpQueuePtr;
191 DWORD dwTotalRecorded;
192
193 /* Synchronization mechanism to protect above fields */
194 OSSpinLock lock;
195
196 /* Capabilities description */
197 WAVEINCAPSW caps;
198 char interface_name[32];
199
200 /* Record the arguments used when opening the device. */
201 WAVEOPENDESC waveDesc;
202 WORD wFlags;
203 PCMWAVEFORMAT format;
204
205 AudioUnit audioUnit;
206 AudioBufferList*bufferList;
207 AudioBufferList*bufferListCopy;
208
209 /* Record state of debug channels at open. Used to control fprintf's since
210 * we can't use Wine debug channel calls in non-Wine AudioUnit threads. */
211 BOOL trace_on;
212 BOOL warn_on;
213 BOOL err_on;
214
215 /* These fields aren't used. */
216 #if 0
217 CoreAudio_Device *cadev;
218
219 AudioStreamBasicDescription streamDescription;
220 #endif
221 } WINE_WAVEIN;
222
223 static WINE_WAVEOUT WOutDev [MAX_WAVEOUTDRV];
224 static WINE_WAVEIN WInDev [MAX_WAVEINDRV];
225
226 static HANDLE hThread = NULL; /* Track the thread we create so we can clean it up later */
227 static CFMessagePortRef Port_SendToMessageThread;
228
229 static void wodHelper_PlayPtrNext(WINE_WAVEOUT_INSTANCE* wwo);
230 static void wodHelper_NotifyDoneForList(WINE_WAVEOUT_INSTANCE* wwo, LPWAVEHDR lpWaveHdr);
231 static void wodHelper_NotifyCompletions(WINE_WAVEOUT_INSTANCE* wwo, BOOL force);
232 static void widHelper_NotifyCompletions(WINE_WAVEIN* wwi);
233
234 extern int AudioUnit_CreateDefaultAudioUnit(void *wwo, AudioUnit *au);
235 extern int AudioUnit_CloseAudioUnit(AudioUnit au);
236 extern int AudioUnit_InitializeWithStreamDescription(AudioUnit au, AudioStreamBasicDescription *streamFormat);
237
238 extern OSStatus AudioOutputUnitStart(AudioUnit au);
239 extern OSStatus AudioOutputUnitStop(AudioUnit au);
240 extern OSStatus AudioUnitUninitialize(AudioUnit au);
241
242 extern int AudioUnit_SetVolume(AudioUnit au, float left, float right);
243 extern int AudioUnit_GetVolume(AudioUnit au, float *left, float *right);
244
245 extern int AudioUnit_GetInputDeviceSampleRate(void);
246
247 extern int AudioUnit_CreateInputUnit(void* wwi, AudioUnit* out_au,
248 WORD nChannels, DWORD nSamplesPerSec, WORD wBitsPerSample,
249 UInt32* outFrameCount);
250
251 OSStatus CoreAudio_woAudioUnitIOProc(void *inRefCon,
252 AudioUnitRenderActionFlags *ioActionFlags,
253 const AudioTimeStamp *inTimeStamp,
254 UInt32 inBusNumber,
255 UInt32 inNumberFrames,
256 AudioBufferList *ioData);
257 OSStatus CoreAudio_wiAudioUnitIOProc(void *inRefCon,
258 AudioUnitRenderActionFlags *ioActionFlags,
259 const AudioTimeStamp *inTimeStamp,
260 UInt32 inBusNumber,
261 UInt32 inNumberFrames,
262 AudioBufferList *ioData);
263
264 /* These strings used only for tracing */
265
266 static const char * getMessage(UINT msg)
267 {
268 #define MSG_TO_STR(x) case x: return #x
269 switch(msg) {
270 MSG_TO_STR(DRVM_INIT);
271 MSG_TO_STR(DRVM_EXIT);
272 MSG_TO_STR(DRVM_ENABLE);
273 MSG_TO_STR(DRVM_DISABLE);
274 MSG_TO_STR(WIDM_OPEN);
275 MSG_TO_STR(WIDM_CLOSE);
276 MSG_TO_STR(WIDM_ADDBUFFER);
277 MSG_TO_STR(WIDM_PREPARE);
278 MSG_TO_STR(WIDM_UNPREPARE);
279 MSG_TO_STR(WIDM_GETDEVCAPS);
280 MSG_TO_STR(WIDM_GETNUMDEVS);
281 MSG_TO_STR(WIDM_GETPOS);
282 MSG_TO_STR(WIDM_RESET);
283 MSG_TO_STR(WIDM_START);
284 MSG_TO_STR(WIDM_STOP);
285 MSG_TO_STR(WODM_OPEN);
286 MSG_TO_STR(WODM_CLOSE);
287 MSG_TO_STR(WODM_WRITE);
288 MSG_TO_STR(WODM_PAUSE);
289 MSG_TO_STR(WODM_GETPOS);
290 MSG_TO_STR(WODM_BREAKLOOP);
291 MSG_TO_STR(WODM_PREPARE);
292 MSG_TO_STR(WODM_UNPREPARE);
293 MSG_TO_STR(WODM_GETDEVCAPS);
294 MSG_TO_STR(WODM_GETNUMDEVS);
295 MSG_TO_STR(WODM_GETPITCH);
296 MSG_TO_STR(WODM_SETPITCH);
297 MSG_TO_STR(WODM_GETPLAYBACKRATE);
298 MSG_TO_STR(WODM_SETPLAYBACKRATE);
299 MSG_TO_STR(WODM_GETVOLUME);
300 MSG_TO_STR(WODM_SETVOLUME);
301 MSG_TO_STR(WODM_RESTART);
302 MSG_TO_STR(WODM_RESET);
303 MSG_TO_STR(DRV_QUERYDEVICEINTERFACESIZE);
304 MSG_TO_STR(DRV_QUERYDEVICEINTERFACE);
305 MSG_TO_STR(DRV_QUERYDSOUNDIFACE);
306 MSG_TO_STR(DRV_QUERYDSOUNDDESC);
307 }
308 #undef MSG_TO_STR
309 return wine_dbg_sprintf("UNKNOWN(0x%04x)", msg);
310 }
311
312 #define kStopLoopMessage 0
313 #define kWaveOutNotifyCompletionsMessage 1
314 #define kWaveInNotifyCompletionsMessage 2
315
316 /* Mach Message Handling */
317 static CFDataRef wodMessageHandler(CFMessagePortRef port_ReceiveInMessageThread, SInt32 msgid, CFDataRef data, void *info)
318 {
319 UInt32 *buffer = NULL;
320
321 switch (msgid)
322 {
323 case kWaveOutNotifyCompletionsMessage:
324 wodHelper_NotifyCompletions(*(WINE_WAVEOUT_INSTANCE**)CFDataGetBytePtr(data), FALSE);
325 break;
326 case kWaveInNotifyCompletionsMessage:
327 buffer = (UInt32 *) CFDataGetBytePtr(data);
328 widHelper_NotifyCompletions(&WInDev[buffer[0]]);
329 break;
330 default:
331 CFRunLoopStop(CFRunLoopGetCurrent());
332 break;
333 }
334
335 return NULL;
336 }
337
338 static DWORD WINAPI messageThread(LPVOID p)
339 {
340 CFMessagePortRef port_ReceiveInMessageThread = (CFMessagePortRef) p;
341 CFRunLoopSourceRef source;
342
343 source = CFMessagePortCreateRunLoopSource(kCFAllocatorDefault, port_ReceiveInMessageThread, 0);
344 CFRunLoopAddSource(CFRunLoopGetCurrent(), source, kCFRunLoopDefaultMode);
345
346 CFRunLoopRun();
347
348 CFRunLoopSourceInvalidate(source);
349 CFRelease(source);
350 CFRelease(port_ReceiveInMessageThread);
351
352 return 0;
353 }
354
355 /**************************************************************************
356 * wodSendNotifyCompletionsMessage [internal]
357 * Call from AudioUnit IO thread can't use Wine debug channels.
358 */
359 static void wodSendNotifyCompletionsMessage(WINE_WAVEOUT_INSTANCE* wwo)
360 {
361 CFDataRef data;
362
363 if (!Port_SendToMessageThread)
364 return;
365
366 data = CFDataCreate(kCFAllocatorDefault, (UInt8 *)&wwo, sizeof(wwo));
367 if (!data)
368 return;
369
370 CFMessagePortSendRequest(Port_SendToMessageThread, kWaveOutNotifyCompletionsMessage, data, 0.0, 0.0, NULL, NULL);
371 CFRelease(data);
372 }
373
374 /**************************************************************************
375 * wodSendNotifyInputCompletionsMessage [internal]
376 * Call from AudioUnit IO thread can't use Wine debug channels.
377 */
378 static void wodSendNotifyInputCompletionsMessage(WINE_WAVEIN* wwi)
379 {
380 CFDataRef data;
381 UInt32 buffer;
382
383 if (!Port_SendToMessageThread)
384 return;
385
386 buffer = (UInt32) wwi->wiID;
387
388 data = CFDataCreate(kCFAllocatorDefault, (UInt8 *)&buffer, sizeof(buffer));
389 if (!data)
390 return;
391
392 CFMessagePortSendRequest(Port_SendToMessageThread, kWaveInNotifyCompletionsMessage, data, 0.0, 0.0, NULL, NULL);
393 CFRelease(data);
394 }
395
396 static DWORD bytes_to_mmtime(LPMMTIME lpTime, DWORD position,
397 PCMWAVEFORMAT* format)
398 {
399 TRACE("wType=%04X wBitsPerSample=%u nSamplesPerSec=%u nChannels=%u nAvgBytesPerSec=%u\n",
400 lpTime->wType, format->wBitsPerSample, format->wf.nSamplesPerSec,
401 format->wf.nChannels, format->wf.nAvgBytesPerSec);
402 TRACE("Position in bytes=%u\n", position);
403
404 switch (lpTime->wType) {
405 case TIME_SAMPLES:
406 lpTime->u.sample = position / (format->wBitsPerSample / 8 * format->wf.nChannels);
407 TRACE("TIME_SAMPLES=%u\n", lpTime->u.sample);
408 break;
409 case TIME_MS:
410 lpTime->u.ms = 1000.0 * position / (format->wBitsPerSample / 8 * format->wf.nChannels * format->wf.nSamplesPerSec);
411 TRACE("TIME_MS=%u\n", lpTime->u.ms);
412 break;
413 case TIME_SMPTE:
414 lpTime->u.smpte.fps = 30;
415 position = position / (format->wBitsPerSample / 8 * format->wf.nChannels);
416 position += (format->wf.nSamplesPerSec / lpTime->u.smpte.fps) - 1; /* round up */
417 lpTime->u.smpte.sec = position / format->wf.nSamplesPerSec;
418 position -= lpTime->u.smpte.sec * format->wf.nSamplesPerSec;
419 lpTime->u.smpte.min = lpTime->u.smpte.sec / 60;
420 lpTime->u.smpte.sec -= 60 * lpTime->u.smpte.min;
421 lpTime->u.smpte.hour = lpTime->u.smpte.min / 60;
422 lpTime->u.smpte.min -= 60 * lpTime->u.smpte.hour;
423 lpTime->u.smpte.fps = 30;
424 lpTime->u.smpte.frame = position * lpTime->u.smpte.fps / format->wf.nSamplesPerSec;
425 TRACE("TIME_SMPTE=%02u:%02u:%02u:%02u\n",
426 lpTime->u.smpte.hour, lpTime->u.smpte.min,
427 lpTime->u.smpte.sec, lpTime->u.smpte.frame);
428 break;
429 default:
430 WARN("Format %d not supported, using TIME_BYTES !\n", lpTime->wType);
431 lpTime->wType = TIME_BYTES;
432 /* fall through */
433 case TIME_BYTES:
434 lpTime->u.cb = position;
435 TRACE("TIME_BYTES=%u\n", lpTime->u.cb);
436 break;
437 }
438 return MMSYSERR_NOERROR;
439 }
440
441 static BOOL supportedFormat(LPWAVEFORMATEX wf)
442 {
443 if (wf->nSamplesPerSec < DSBFREQUENCY_MIN || wf->nSamplesPerSec > DSBFREQUENCY_MAX)
444 return FALSE;
445
446 if (wf->wFormatTag == WAVE_FORMAT_PCM) {
447 if (wf->nChannels >= 1 && wf->nChannels <= 2) {
448 if (wf->wBitsPerSample==8||wf->wBitsPerSample==16)
449 return TRUE;
450 }
451 } else if (wf->wFormatTag == WAVE_FORMAT_EXTENSIBLE) {
452 WAVEFORMATEXTENSIBLE * wfex = (WAVEFORMATEXTENSIBLE *)wf;
453
454 if (wf->cbSize == 22 && IsEqualGUID(&wfex->SubFormat, &KSDATAFORMAT_SUBTYPE_PCM)) {
455 if (wf->nChannels >=1 && wf->nChannels <= 8) {
456 if (wf->wBitsPerSample==wfex->Samples.wValidBitsPerSample) {
457 if (wf->wBitsPerSample==8||wf->wBitsPerSample==16)
458 return TRUE;
459 } else
460 WARN("wBitsPerSample != wValidBitsPerSample not supported yet\n");
461 }
462 } else
463 WARN("only KSDATAFORMAT_SUBTYPE_PCM supported\n");
464 } else
465 WARN("only WAVE_FORMAT_PCM and WAVE_FORMAT_EXTENSIBLE supported\n");
466
467 return FALSE;
468 }
469
470 void copyFormat(LPWAVEFORMATEX wf1, LPPCMWAVEFORMAT wf2)
471 {
472 memcpy(wf2, wf1, sizeof(PCMWAVEFORMAT));
473 /* Downgrade WAVE_FORMAT_EXTENSIBLE KSDATAFORMAT_SUBTYPE_PCM
474 * to smaller yet compatible WAVE_FORMAT_PCM structure */
475 if (wf2->wf.wFormatTag == WAVE_FORMAT_EXTENSIBLE)
476 wf2->wf.wFormatTag = WAVE_FORMAT_PCM;
477 }
478
479 /**************************************************************************
480 * CoreAudio_GetDevCaps [internal]
481 */
482 BOOL CoreAudio_GetDevCaps (void)
483 {
484 OSStatus status;
485 UInt32 propertySize;
486 AudioDeviceID devId = CoreAudio_DefaultDevice.outputDeviceID;
487 AudioObjectPropertyAddress propertyAddress;
488
489 CFStringRef name;
490 CFRange range;
491
492 propertySize = sizeof(name);
493 propertyAddress.mSelector = kAudioObjectPropertyName;
494 propertyAddress.mScope = kAudioDevicePropertyScopeOutput;
495 propertyAddress.mElement = kAudioObjectPropertyElementMaster;
496 status = AudioObjectGetPropertyData(devId, &propertyAddress, 0, NULL, &propertySize, &name);
497 if (status) {
498 ERR("AudioObjectGetPropertyData for kAudioObjectPropertyName return %s\n", wine_dbgstr_fourcc(status));
499 return FALSE;
500 }
501
502 CFStringGetCString(name, CoreAudio_DefaultDevice.ds_desc.szDesc,
503 sizeof(CoreAudio_DefaultDevice.ds_desc.szDesc),
504 kCFStringEncodingUTF8);
505 strcpy(CoreAudio_DefaultDevice.ds_desc.szDrvname, "winecoreaudio.drv");
506 range = CFRangeMake(0, min(sizeof(CoreAudio_DefaultDevice.out_caps.szPname) / sizeof(WCHAR) - 1, CFStringGetLength(name)));
507 CFStringGetCharacters(name, range, CoreAudio_DefaultDevice.out_caps.szPname);
508 CoreAudio_DefaultDevice.out_caps.szPname[range.length] = 0;
509 CFStringGetCString(name, CoreAudio_DefaultDevice.dev_name, 32, kCFStringEncodingUTF8);
510 CFRelease(name);
511
512 propertySize = sizeof(CoreAudio_DefaultDevice.streamDescription);
513 /* FIXME: kAudioDevicePropertyStreamFormat is deprecated. We're
514 * "supposed" to get an AudioStream object from the AudioDevice,
515 * then query it for the format with kAudioStreamPropertyVirtualFormat.
516 * Apple says that this is for our own good, because this property
517 * "has been shown to lead to programming mistakes by clients when
518 * working with devices with multiple streams." Only one problem:
519 * which stream? For now, just query the device.
520 */
521 propertyAddress.mSelector = kAudioDevicePropertyStreamFormat;
522 status = AudioObjectGetPropertyData(devId, &propertyAddress, 0, NULL, &propertySize, &CoreAudio_DefaultDevice.streamDescription);
523 if (status != noErr) {
524 ERR("AudioObjectGetPropertyData for kAudioDevicePropertyStreamFormat return %s\n", wine_dbgstr_fourcc(status));
525 return FALSE;
526 }
527
528 TRACE("Device Stream Description mSampleRate : %f\n mFormatID : %s\n"
529 "mFormatFlags : %lX\n mBytesPerPacket : %lu\n mFramesPerPacket : %lu\n"
530 "mBytesPerFrame : %lu\n mChannelsPerFrame : %lu\n mBitsPerChannel : %lu\n",
531 CoreAudio_DefaultDevice.streamDescription.mSampleRate,
532 wine_dbgstr_fourcc(CoreAudio_DefaultDevice.streamDescription.mFormatID),
533 CoreAudio_DefaultDevice.streamDescription.mFormatFlags,
534 CoreAudio_DefaultDevice.streamDescription.mBytesPerPacket,
535 CoreAudio_DefaultDevice.streamDescription.mFramesPerPacket,
536 CoreAudio_DefaultDevice.streamDescription.mBytesPerFrame,
537 CoreAudio_DefaultDevice.streamDescription.mChannelsPerFrame,
538 CoreAudio_DefaultDevice.streamDescription.mBitsPerChannel);
539
540 CoreAudio_DefaultDevice.out_caps.wMid = 0xcafe;
541 CoreAudio_DefaultDevice.out_caps.wPid = 0x0001;
542
543 CoreAudio_DefaultDevice.out_caps.vDriverVersion = 0x0001;
544 CoreAudio_DefaultDevice.out_caps.dwFormats = 0x00000000;
545 CoreAudio_DefaultDevice.out_caps.wReserved1 = 0;
546 CoreAudio_DefaultDevice.out_caps.dwSupport = WAVECAPS_VOLUME;
547 CoreAudio_DefaultDevice.out_caps.dwSupport |= WAVECAPS_LRVOLUME;
548
549 CoreAudio_DefaultDevice.out_caps.wChannels = 2;
550 CoreAudio_DefaultDevice.out_caps.dwFormats|= WAVE_FORMAT_4S16;
551
552 TRACE_(coreaudio)("out dwFormats = %08x, dwSupport = %08x\n",
553 CoreAudio_DefaultDevice.out_caps.dwFormats, CoreAudio_DefaultDevice.out_caps.dwSupport);
554
555 return TRUE;
556 }
557
558 /******************************************************************
559 * CoreAudio_WaveInit
560 *
561 * Initialize CoreAudio_DefaultDevice
562 */
563 LONG CoreAudio_WaveInit(void)
564 {
565 OSStatus status;
566 UInt32 propertySize;
567 AudioObjectPropertyAddress propertyAddress;
568 int i;
569 CFStringRef messageThreadPortName;
570 CFMessagePortRef port_ReceiveInMessageThread;
571 int inputSampleRate;
572
573 TRACE("()\n");
574
575 /* number of sound cards */
576 propertyAddress.mSelector = kAudioHardwarePropertyDevices;
577 propertyAddress.mScope = kAudioObjectPropertyScopeGlobal;
578 propertyAddress.mElement = kAudioObjectPropertyElementMaster;
579 AudioObjectGetPropertyDataSize(kAudioObjectSystemObject, &propertyAddress, 0, NULL, &propertySize);
580 propertySize /= sizeof(AudioDeviceID);
581 TRACE("sound cards : %lu\n", propertySize);
582
583 /* Get the output device */
584 propertySize = sizeof(CoreAudio_DefaultDevice.outputDeviceID);
585 propertyAddress.mSelector = kAudioHardwarePropertyDefaultOutputDevice;
586 status = AudioObjectGetPropertyData(kAudioObjectSystemObject, &propertyAddress, 0, NULL, &propertySize, &CoreAudio_DefaultDevice.outputDeviceID);
587 if (status) {
588 ERR("AudioObjectGetPropertyData return %s for kAudioHardwarePropertyDefaultOutputDevice\n", wine_dbgstr_fourcc(status));
589 return DRV_FAILURE;
590 }
591 if (CoreAudio_DefaultDevice.outputDeviceID == kAudioDeviceUnknown) {
592 ERR("AudioObjectGetPropertyData: CoreAudio_DefaultDevice.outputDeviceID == kAudioDeviceUnknown\n");
593 return DRV_FAILURE;
594 }
595
596 if ( ! CoreAudio_GetDevCaps() )
597 return DRV_FAILURE;
598
599 CoreAudio_DefaultDevice.interface_name=HeapAlloc(GetProcessHeap(),0,strlen(CoreAudio_DefaultDevice.dev_name)+1);
600 strcpy(CoreAudio_DefaultDevice.interface_name, CoreAudio_DefaultDevice.dev_name);
601
602 for (i = 0; i < MAX_WAVEOUTDRV; ++i)
603 {
604 static const WCHAR wszWaveOutFormat[] =
605 {'C','o','r','e','A','u','d','i','o',' ','W','a','v','e','O','u','t',' ','%','d',0};
606
607 list_init(&WOutDev[i].instances);
608 WOutDev[i].cadev = &CoreAudio_DefaultDevice;
609
610 memset(&WOutDev[i].caps, 0, sizeof(WOutDev[i].caps));
611
612 WOutDev[i].caps.wMid = 0xcafe; /* Manufac ID */
613 WOutDev[i].caps.wPid = 0x0001; /* Product ID */
614 snprintfW(WOutDev[i].caps.szPname, sizeof(WOutDev[i].caps.szPname)/sizeof(WCHAR), wszWaveOutFormat, i);
615 snprintf(WOutDev[i].interface_name, sizeof(WOutDev[i].interface_name), "winecoreaudio: %d", i);
616
617 WOutDev[i].caps.vDriverVersion = 0x0001;
618 WOutDev[i].caps.dwFormats = 0x00000000;
619 WOutDev[i].caps.dwSupport = WAVECAPS_VOLUME;
620
621 WOutDev[i].caps.wChannels = 2;
622 /* WOutDev[i].caps.dwSupport |= WAVECAPS_LRVOLUME; */ /* FIXME */
623
624 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_96M08;
625 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_96S08;
626 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_96M16;
627 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_96S16;
628 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_48M08;
629 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_48S08;
630 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_48M16;
631 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_48S16;
632 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_4M08;
633 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_4S08;
634 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_4S16;
635 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_4M16;
636 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_2M08;
637 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_2S08;
638 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_2M16;
639 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_2S16;
640 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_1M08;
641 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_1S08;
642 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_1M16;
643 WOutDev[i].caps.dwFormats |= WAVE_FORMAT_1S16;
644
645 WOutDev[i].device_volume = 0xffffffff;
646
647 WOutDev[i].lock = 0; /* initialize the mutex */
648 }
649
650 /* FIXME: implement sample rate conversion on input */
651 inputSampleRate = AudioUnit_GetInputDeviceSampleRate();
652
653 for (i = 0; i < MAX_WAVEINDRV; ++i)
654 {
655 static const WCHAR wszWaveInFormat[] =
656 {'C','o','r','e','A','u','d','i','o',' ','W','a','v','e','I','n',' ','%','d',0};
657
658 memset(&WInDev[i], 0, sizeof(WInDev[i]));
659 WInDev[i].wiID = i;
660
661 /* Establish preconditions for widOpen */
662 WInDev[i].state = WINE_WS_CLOSED;
663 WInDev[i].lock = 0; /* initialize the mutex */
664
665 /* Fill in capabilities. widGetDevCaps can be called at any time. */
666 WInDev[i].caps.wMid = 0xcafe; /* Manufac ID */
667 WInDev[i].caps.wPid = 0x0001; /* Product ID */
668 WInDev[i].caps.vDriverVersion = 0x0001;
669
670 snprintfW(WInDev[i].caps.szPname, sizeof(WInDev[i].caps.szPname)/sizeof(WCHAR), wszWaveInFormat, i);
671 snprintf(WInDev[i].interface_name, sizeof(WInDev[i].interface_name), "winecoreaudio in: %d", i);
672
673 if (inputSampleRate == 96000)
674 {
675 WInDev[i].caps.dwFormats |= WAVE_FORMAT_96M08;
676 WInDev[i].caps.dwFormats |= WAVE_FORMAT_96S08;
677 WInDev[i].caps.dwFormats |= WAVE_FORMAT_96M16;
678 WInDev[i].caps.dwFormats |= WAVE_FORMAT_96S16;
679 }
680 if (inputSampleRate == 48000)
681 {
682 WInDev[i].caps.dwFormats |= WAVE_FORMAT_48M08;
683 WInDev[i].caps.dwFormats |= WAVE_FORMAT_48S08;
684 WInDev[i].caps.dwFormats |= WAVE_FORMAT_48M16;
685 WInDev[i].caps.dwFormats |= WAVE_FORMAT_48S16;
686 }
687 if (inputSampleRate == 44100)
688 {
689 WInDev[i].caps.dwFormats |= WAVE_FORMAT_4M08;
690 WInDev[i].caps.dwFormats |= WAVE_FORMAT_4S08;
691 WInDev[i].caps.dwFormats |= WAVE_FORMAT_4M16;
692 WInDev[i].caps.dwFormats |= WAVE_FORMAT_4S16;
693 }
694 if (inputSampleRate == 22050)
695 {
696 WInDev[i].caps.dwFormats |= WAVE_FORMAT_2M08;
697 WInDev[i].caps.dwFormats |= WAVE_FORMAT_2S08;
698 WInDev[i].caps.dwFormats |= WAVE_FORMAT_2M16;
699 WInDev[i].caps.dwFormats |= WAVE_FORMAT_2S16;
700 }
701 if (inputSampleRate == 11025)
702 {
703 WInDev[i].caps.dwFormats |= WAVE_FORMAT_1M08;
704 WInDev[i].caps.dwFormats |= WAVE_FORMAT_1S08;
705 WInDev[i].caps.dwFormats |= WAVE_FORMAT_1M16;
706 WInDev[i].caps.dwFormats |= WAVE_FORMAT_1S16;
707 }
708
709 WInDev[i].caps.wChannels = 2;
710 }
711
712 /* create mach messages handler */
713 srandomdev();
714 messageThreadPortName = CFStringCreateWithFormat(kCFAllocatorDefault, NULL,
715 CFSTR("WaveMessagePort.%d.%lu"), getpid(), (unsigned long)random());
716 if (!messageThreadPortName)
717 {
718 ERR("Can't create message thread port name\n");
719 return DRV_FAILURE;
720 }
721
722 port_ReceiveInMessageThread = CFMessagePortCreateLocal(kCFAllocatorDefault, messageThreadPortName,
723 &wodMessageHandler, NULL, NULL);
724 if (!port_ReceiveInMessageThread)
725 {
726 ERR("Can't create message thread local port\n");
727 CFRelease(messageThreadPortName);
728 return DRV_FAILURE;
729 }
730
731 Port_SendToMessageThread = CFMessagePortCreateRemote(kCFAllocatorDefault, messageThreadPortName);
732 CFRelease(messageThreadPortName);
733 if (!Port_SendToMessageThread)
734 {
735 ERR("Can't create port for sending to message thread\n");
736 CFRelease(port_ReceiveInMessageThread);
737 return DRV_FAILURE;
738 }
739
740 /* Cannot WAIT for any events because we are called from the loader (which has a lock on loading stuff) */
741 /* We might want to wait for this thread to be created -- but we cannot -- not here at least */
742 /* Instead track the thread so we can clean it up later */
743 if ( hThread )
744 {
745 ERR("Message thread already started -- expect problems\n");
746 }
747 hThread = CreateThread(NULL, 0, messageThread, (LPVOID)port_ReceiveInMessageThread, 0, NULL);
748 if ( !hThread )
749 {
750 ERR("Can't create message thread\n");
751 CFRelease(port_ReceiveInMessageThread);
752 CFRelease(Port_SendToMessageThread);
753 Port_SendToMessageThread = NULL;
754 return DRV_FAILURE;
755 }
756
757 /* The message thread is responsible for releasing port_ReceiveInMessageThread. */
758
759 return DRV_SUCCESS;
760 }
761
762 void CoreAudio_WaveRelease(void)
763 {
764 /* Stop CFRunLoop in messageThread */
765 TRACE("()\n");
766
767 if (!Port_SendToMessageThread)
768 return;
769
770 CFMessagePortSendRequest(Port_SendToMessageThread, kStopLoopMessage, NULL, 0.0, 0.0, NULL, NULL);
771 CFRelease(Port_SendToMessageThread);
772 Port_SendToMessageThread = NULL;
773
774 /* Wait for the thread to finish and clean it up */
775 /* This rids us of any quick start/shutdown driver crashes */
776 WaitForSingleObject(hThread, INFINITE);
777 CloseHandle(hThread);
778 hThread = NULL;
779 }
780
781 /*======================================================================*
782 * Low level WAVE OUT implementation *
783 *======================================================================*/
784
785 /**************************************************************************
786 * wodNotifyClient [internal]
787 */
788 static void wodNotifyClient(WINE_WAVEOUT_INSTANCE* wwo, WORD wMsg, DWORD_PTR dwParam1, DWORD_PTR dwParam2)
789 {
790 TRACE("wMsg = 0x%04x dwParm1 = %04lx dwParam2 = %04lx\n", wMsg, dwParam1, dwParam2);
791
792 switch (wMsg) {
793 case WOM_OPEN:
794 case WOM_CLOSE:
795 case WOM_DONE:
796 DriverCallback(wwo->waveDesc.dwCallback, wwo->wFlags,
797 (HDRVR)wwo->waveDesc.hWave, wMsg, wwo->waveDesc.dwInstance,
798 dwParam1, dwParam2);
799 break;
800 default:
801 FIXME("Unknown callback message %u\n", wMsg);
802 }
803 }
804
805
806 /**************************************************************************
807 * wodGetDevCaps [internal]
808 */
809 static DWORD wodGetDevCaps(WORD wDevID, LPWAVEOUTCAPSW lpCaps, DWORD dwSize)
810 {
811 TRACE("(%u, %p, %u);\n", wDevID, lpCaps, dwSize);
812
813 if (lpCaps == NULL) return MMSYSERR_NOTENABLED;
814
815 if (wDevID >= MAX_WAVEOUTDRV)
816 {
817 TRACE("MAX_WAVOUTDRV reached !\n");
818 return MMSYSERR_BADDEVICEID;
819 }
820
821 TRACE("dwSupport=(0x%x), dwFormats=(0x%x)\n", WOutDev[wDevID].caps.dwSupport, WOutDev[wDevID].caps.dwFormats);
822 memcpy(lpCaps, &WOutDev[wDevID].caps, min(dwSize, sizeof(*lpCaps)));
823 return MMSYSERR_NOERROR;
824 }
825
826 /**************************************************************************
827 * wodOpen [internal]
828 */
829 static DWORD wodOpen(WORD wDevID, WINE_WAVEOUT_INSTANCE** pInstance, LPWAVEOPENDESC lpDesc, DWORD dwFlags)
830 {
831 WINE_WAVEOUT_INSTANCE* wwo;
832 DWORD ret;
833 AudioStreamBasicDescription streamFormat;
834 AudioUnit audioUnit = NULL;
835 BOOL auInited = FALSE;
836
837 TRACE("(%u, %p, %p, %08x);\n", wDevID, pInstance, lpDesc, dwFlags);
838 if (lpDesc == NULL)
839 {
840 WARN("Invalid Parameter !\n");
841 return MMSYSERR_INVALPARAM;
842 }
843 if (wDevID >= MAX_WAVEOUTDRV) {
844 TRACE("MAX_WAVOUTDRV reached !\n");
845 return MMSYSERR_BADDEVICEID;
846 }
847
848 TRACE("Format: tag=%04X nChannels=%d nSamplesPerSec=%d wBitsPerSample=%d !\n",
849 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
850 lpDesc->lpFormat->nSamplesPerSec, lpDesc->lpFormat->wBitsPerSample);
851
852 if (!supportedFormat(lpDesc->lpFormat))
853 {
854 WARN("Bad format: tag=%04X nChannels=%d nSamplesPerSec=%d wBitsPerSample=%d !\n",
855 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
856 lpDesc->lpFormat->nSamplesPerSec, lpDesc->lpFormat->wBitsPerSample);
857 return WAVERR_BADFORMAT;
858 }
859
860 if (dwFlags & WAVE_FORMAT_QUERY)
861 {
862 TRACE("Query format: tag=%04X nChannels=%d nSamplesPerSec=%d !\n",
863 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
864 lpDesc->lpFormat->nSamplesPerSec);
865 return MMSYSERR_NOERROR;
866 }
867
868 /* nBlockAlign and nAvgBytesPerSec are output variables for dsound */
869 if (lpDesc->lpFormat->nBlockAlign != lpDesc->lpFormat->nChannels*lpDesc->lpFormat->wBitsPerSample/8) {
870 lpDesc->lpFormat->nBlockAlign = lpDesc->lpFormat->nChannels*lpDesc->lpFormat->wBitsPerSample/8;
871 WARN("Fixing nBlockAlign\n");
872 }
873 if (lpDesc->lpFormat->nAvgBytesPerSec!= lpDesc->lpFormat->nSamplesPerSec*lpDesc->lpFormat->nBlockAlign) {
874 lpDesc->lpFormat->nAvgBytesPerSec = lpDesc->lpFormat->nSamplesPerSec*lpDesc->lpFormat->nBlockAlign;
875 WARN("Fixing nAvgBytesPerSec\n");
876 }
877
878 /* We proceed in three phases:
879 * o Allocate the device instance, marking it as opening
880 * o Create, configure, and start the Audio Unit. To avoid deadlock,
881 * this has to be done without holding wwo->lock.
882 * o If that was successful, finish setting up our instance and add it
883 * to the device's list.
884 * Otherwise, clean up and deallocate the instance.
885 */
886 wwo = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*wwo));
887 if (!wwo)
888 return MMSYSERR_NOMEM;
889
890 wwo->woID = wDevID;
891 wwo->state = WINE_WS_OPENING;
892
893 if (!AudioUnit_CreateDefaultAudioUnit((void *) wwo, &audioUnit))
894 {
895 ERR("CoreAudio_CreateDefaultAudioUnit(0x%04x) failed\n", wDevID);
896 ret = MMSYSERR_ERROR;
897 goto error;
898 }
899
900 streamFormat.mFormatID = kAudioFormatLinearPCM;
901 streamFormat.mFormatFlags = kLinearPCMFormatFlagIsPacked;
902 /* FIXME check for 32bits float -> kLinearPCMFormatFlagIsFloat */
903 if (lpDesc->lpFormat->wBitsPerSample != 8)
904 streamFormat.mFormatFlags |= kLinearPCMFormatFlagIsSignedInteger;
905 # ifdef WORDS_BIGENDIAN
906 streamFormat.mFormatFlags |= kLinearPCMFormatFlagIsBigEndian; /* FIXME Wave format is little endian */
907 # endif
908
909 streamFormat.mSampleRate = lpDesc->lpFormat->nSamplesPerSec;
910 streamFormat.mChannelsPerFrame = lpDesc->lpFormat->nChannels;
911 streamFormat.mFramesPerPacket = 1;
912 streamFormat.mBitsPerChannel = lpDesc->lpFormat->wBitsPerSample;
913 streamFormat.mBytesPerFrame = streamFormat.mBitsPerChannel * streamFormat.mChannelsPerFrame / 8;
914 streamFormat.mBytesPerPacket = streamFormat.mBytesPerFrame * streamFormat.mFramesPerPacket;
915
916 ret = AudioUnit_InitializeWithStreamDescription(audioUnit, &streamFormat);
917 if (!ret)
918 {
919 ret = WAVERR_BADFORMAT; /* FIXME return an error based on the OSStatus */
920 goto error;
921 }
922 auInited = TRUE;
923
924 AudioUnit_SetVolume(audioUnit, LOWORD(WOutDev[wDevID].device_volume) / 65535.0f,
925 HIWORD(WOutDev[wDevID].device_volume) / 65535.0f);
926
927 /* Our render callback CoreAudio_woAudioUnitIOProc may be called before
928 * AudioOutputUnitStart returns. Core Audio will grab its own internal
929 * lock before calling it and the callback grabs wwo->lock. This would
930 * deadlock if we were holding wwo->lock.
931 * Also, the callback has to safely do nothing in that case, because
932 * wwo hasn't been completely filled out, yet. This is assured by state
933 * being WINE_WS_OPENING. */
934 ret = AudioOutputUnitStart(audioUnit);
935 if (ret)
936 {
937 ERR("AudioOutputUnitStart failed: %08x\n", ret);
938 ret = MMSYSERR_ERROR; /* FIXME return an error based on the OSStatus */
939 goto error;
940 }
941
942
943 OSSpinLockLock(&wwo->lock);
944 assert(wwo->state == WINE_WS_OPENING);
945
946 wwo->audioUnit = audioUnit;
947 wwo->streamDescription = streamFormat;
948
949 wwo->state = WINE_WS_PLAYING;
950
951 wwo->wFlags = HIWORD(dwFlags & CALLBACK_TYPEMASK);
952
953 wwo->waveDesc = *lpDesc;
954 copyFormat(lpDesc->lpFormat, &wwo->format);
955
956 WOutDev[wDevID].trace_on = TRACE_ON(wave);
957 WOutDev[wDevID].warn_on = WARN_ON(wave);
958 WOutDev[wDevID].err_on = ERR_ON(wave);
959
960 OSSpinLockUnlock(&wwo->lock);
961
962 OSSpinLockLock(&WOutDev[wDevID].lock);
963 list_add_head(&WOutDev[wDevID].instances, &wwo->entry);
964 OSSpinLockUnlock(&WOutDev[wDevID].lock);
965
966 *pInstance = wwo;
967 TRACE("opened instance %p\n", wwo);
968
969 wodNotifyClient(wwo, WOM_OPEN, 0L, 0L);
970
971 return MMSYSERR_NOERROR;
972
973 error:
974 if (audioUnit)
975 {
976 if (auInited)
977 AudioUnitUninitialize(audioUnit);
978 AudioUnit_CloseAudioUnit(audioUnit);
979 }
980
981 OSSpinLockLock(&wwo->lock);
982 assert(wwo->state == WINE_WS_OPENING);
983 /* OSSpinLockUnlock(&wwo->lock); *//* No need, about to free */
984 HeapFree(GetProcessHeap(), 0, wwo);
985
986 return ret;
987 }
988
989 /**************************************************************************
990 * wodClose [internal]
991 */
992 static DWORD wodClose(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo)
993 {
994 DWORD ret = MMSYSERR_NOERROR;
995
996 TRACE("(%u, %p);\n", wDevID, wwo);
997
998 if (wDevID >= MAX_WAVEOUTDRV)
999 {
1000 WARN("bad device ID !\n");
1001 return MMSYSERR_BADDEVICEID;
1002 }
1003
1004 OSSpinLockLock(&wwo->lock);
1005 if (wwo->lpQueuePtr)
1006 {
1007 OSSpinLockUnlock(&wwo->lock);
1008 WARN("buffers still playing !\n");
1009 return WAVERR_STILLPLAYING;
1010 } else
1011 {
1012 OSStatus err;
1013 AudioUnit audioUnit = wwo->audioUnit;
1014
1015 /* sanity check: this should not happen since the device must have been reset before */
1016 if (wwo->lpQueuePtr || wwo->lpPlayPtr) ERR("out of sync\n");
1017
1018 wwo->state = WINE_WS_CLOSING; /* mark the device as closing */
1019 wwo->audioUnit = NULL;
1020
1021 OSSpinLockUnlock(&wwo->lock);
1022
1023 err = AudioUnitUninitialize(audioUnit);
1024 if (err) {
1025 ERR("AudioUnitUninitialize return %s\n", wine_dbgstr_fourcc(err));
1026 return MMSYSERR_ERROR; /* FIXME return an error based on the OSStatus */
1027 }
1028
1029 if ( !AudioUnit_CloseAudioUnit(audioUnit) )
1030 {
1031 ERR("Can't close AudioUnit\n");
1032 return MMSYSERR_ERROR; /* FIXME return an error based on the OSStatus */
1033 }
1034
1035 OSSpinLockLock(&WOutDev[wDevID].lock);
1036 list_remove(&wwo->entry);
1037 OSSpinLockUnlock(&WOutDev[wDevID].lock);
1038
1039 wodNotifyClient(wwo, WOM_CLOSE, 0L, 0L);
1040
1041 HeapFree(GetProcessHeap(), 0, wwo);
1042 }
1043
1044 return ret;
1045 }
1046
1047 /**************************************************************************
1048 * wodPrepare [internal]
1049 */
1050 static DWORD wodPrepare(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo, LPWAVEHDR lpWaveHdr, DWORD dwSize)
1051 {
1052 TRACE("(%u, %p, %p, %08x);\n", wDevID, wwo, lpWaveHdr, dwSize);
1053
1054 if (wDevID >= MAX_WAVEOUTDRV) {
1055 WARN("bad device ID !\n");
1056 return MMSYSERR_BADDEVICEID;
1057 }
1058
1059 if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
1060 return WAVERR_STILLPLAYING;
1061
1062 lpWaveHdr->dwFlags |= WHDR_PREPARED;
1063 lpWaveHdr->dwFlags &= ~WHDR_DONE;
1064
1065 return MMSYSERR_NOERROR;
1066 }
1067
1068 /**************************************************************************
1069 * wodUnprepare [internal]
1070 */
1071 static DWORD wodUnprepare(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo, LPWAVEHDR lpWaveHdr, DWORD dwSize)
1072 {
1073 TRACE("(%u, %p, %p, %08x);\n", wDevID, wwo, lpWaveHdr, dwSize);
1074
1075 if (wDevID >= MAX_WAVEOUTDRV) {
1076 WARN("bad device ID !\n");
1077 return MMSYSERR_BADDEVICEID;
1078 }
1079
1080 if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
1081 return WAVERR_STILLPLAYING;
1082
1083 lpWaveHdr->dwFlags &= ~WHDR_PREPARED;
1084 lpWaveHdr->dwFlags |= WHDR_DONE;
1085
1086 return MMSYSERR_NOERROR;
1087 }
1088
1089
1090 /**************************************************************************
1091 * wodHelper_CheckForLoopBegin [internal]
1092 *
1093 * Check if the new waveheader is the beginning of a loop, and set up
1094 * state if so.
1095 * This is called with the WAVEOUT_INSTANCE lock held.
1096 * Call from AudioUnit IO thread can't use Wine debug channels.
1097 */
1098 static void wodHelper_CheckForLoopBegin(WINE_WAVEOUT_INSTANCE* wwo)
1099 {
1100 LPWAVEHDR lpWaveHdr = wwo->lpPlayPtr;
1101
1102 if (lpWaveHdr->dwFlags & WHDR_BEGINLOOP)
1103 {
1104 if (wwo->lpLoopPtr)
1105 {
1106 if (WOutDev[wwo->woID].warn_on)
1107 fprintf(stderr, "warn:winecoreaudio:wodHelper_CheckForLoopBegin Already in a loop. Discarding loop on this header (%p)\n", lpWaveHdr);
1108 }
1109 else
1110 {
1111 if (WOutDev[wwo->woID].trace_on)
1112 fprintf(stderr, "trace:winecoreaudio:wodHelper_CheckForLoopBegin Starting loop (%dx) with %p\n", lpWaveHdr->dwLoops, lpWaveHdr);
1113
1114 wwo->lpLoopPtr = lpWaveHdr;
1115 /* Windows does not touch WAVEHDR.dwLoops,
1116 * so we need to make an internal copy */
1117 wwo->dwLoops = lpWaveHdr->dwLoops;
1118 }
1119 }
1120 }
1121
1122
1123 /**************************************************************************
1124 * wodHelper_PlayPtrNext [internal]
1125 *
1126 * Advance the play pointer to the next waveheader, looping if required.
1127 * This is called with the WAVEOUT_INSTANCE lock held.
1128 * Call from AudioUnit IO thread can't use Wine debug channels.
1129 */
1130 static void wodHelper_PlayPtrNext(WINE_WAVEOUT_INSTANCE* wwo)
1131 {
1132 BOOL didLoopBack = FALSE;
1133
1134 wwo->dwPartialOffset = 0;
1135 if ((wwo->lpPlayPtr->dwFlags & WHDR_ENDLOOP) && wwo->lpLoopPtr)
1136 {
1137 /* We're at the end of a loop, loop if required */
1138 if (wwo->dwLoops > 1)
1139 {
1140 wwo->dwLoops--;
1141 wwo->lpPlayPtr = wwo->lpLoopPtr;
1142 didLoopBack = TRUE;
1143 }
1144 else
1145 {
1146 wwo->lpLoopPtr = NULL;
1147 }
1148 }
1149 if (!didLoopBack)
1150 {
1151 /* We didn't loop back. Advance to the next wave header */
1152 wwo->lpPlayPtr = wwo->lpPlayPtr->lpNext;
1153
1154 if (wwo->lpPlayPtr)
1155 wodHelper_CheckForLoopBegin(wwo);
1156 }
1157 }
1158
1159 /* Send the "done" notification for each WAVEHDR in a list. The list must be
1160 * free-standing. It should not be part of a device instance's queue.
1161 * This function must be called with the WAVEOUT_INSTANCE lock *not* held.
1162 * Furthermore, it does not lock it, itself. That's because the callback to the
1163 * application may prompt the application to operate on the device, and we don't
1164 * want to deadlock.
1165 */
1166 static void wodHelper_NotifyDoneForList(WINE_WAVEOUT_INSTANCE* wwo, LPWAVEHDR lpWaveHdr)
1167 {
1168 while (lpWaveHdr)
1169 {
1170 LPWAVEHDR lpNext = lpWaveHdr->lpNext;
1171
1172 lpWaveHdr->lpNext = NULL;
1173 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
1174 lpWaveHdr->dwFlags |= WHDR_DONE;
1175 wodNotifyClient(wwo, WOM_DONE, (DWORD_PTR)lpWaveHdr, 0);
1176
1177 lpWaveHdr = lpNext;
1178 }
1179 }
1180
1181 /* if force is TRUE then notify the client that all the headers were completed
1182 */
1183 static void wodHelper_NotifyCompletions(WINE_WAVEOUT_INSTANCE* wwo, BOOL force)
1184 {
1185 LPWAVEHDR lpFirstDoneWaveHdr = NULL;
1186
1187 OSSpinLockLock(&wwo->lock);
1188
1189 /* First, excise all of the done headers from the queue into
1190 * a free-standing list. */
1191 if (force)
1192 {
1193 lpFirstDoneWaveHdr = wwo->lpQueuePtr;
1194 wwo->lpQueuePtr = NULL;
1195 }
1196 else
1197 {
1198 LPWAVEHDR lpWaveHdr;
1199 LPWAVEHDR lpLastDoneWaveHdr = NULL;
1200
1201 /* Start from lpQueuePtr and keep notifying until:
1202 * - we hit an unwritten wavehdr
1203 * - we hit the beginning of a running loop
1204 * - we hit a wavehdr which hasn't finished playing
1205 */
1206 for (
1207 lpWaveHdr = wwo->lpQueuePtr;
1208 lpWaveHdr &&
1209 lpWaveHdr != wwo->lpPlayPtr &&
1210 lpWaveHdr != wwo->lpLoopPtr;
1211 lpWaveHdr = lpWaveHdr->lpNext
1212 )
1213 {
1214 if (!lpFirstDoneWaveHdr)
1215 lpFirstDoneWaveHdr = lpWaveHdr;
1216 lpLastDoneWaveHdr = lpWaveHdr;
1217 }
1218
1219 if (lpLastDoneWaveHdr)
1220 {
1221 wwo->lpQueuePtr = lpLastDoneWaveHdr->lpNext;
1222 lpLastDoneWaveHdr->lpNext = NULL;
1223 }
1224 }
1225
1226 OSSpinLockUnlock(&wwo->lock);
1227
1228 /* Now, send the "done" notification for each header in our list. */
1229 wodHelper_NotifyDoneForList(wwo, lpFirstDoneWaveHdr);
1230 }
1231
1232
1233 /**************************************************************************
1234 * wodWrite [internal]
1235 *
1236 */
1237 static DWORD wodWrite(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo, LPWAVEHDR lpWaveHdr, DWORD dwSize)
1238 {
1239 LPWAVEHDR*wh;
1240
1241 TRACE("(%u, %p, %p, %lu, %08X);\n", wDevID, wwo, lpWaveHdr, (unsigned long)lpWaveHdr->dwBufferLength, dwSize);
1242
1243 /* first, do the sanity checks... */
1244 if (wDevID >= MAX_WAVEOUTDRV)
1245 {
1246 WARN("bad dev ID !\n");
1247 return MMSYSERR_BADDEVICEID;
1248 }
1249
1250 if (lpWaveHdr->lpData == NULL || !(lpWaveHdr->dwFlags & WHDR_PREPARED))
1251 {
1252 TRACE("unprepared\n");
1253 return WAVERR_UNPREPARED;
1254 }
1255
1256 if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
1257 {
1258 TRACE("still playing\n");
1259 return WAVERR_STILLPLAYING;
1260 }
1261
1262 lpWaveHdr->dwFlags &= ~WHDR_DONE;
1263 lpWaveHdr->dwFlags |= WHDR_INQUEUE;
1264 lpWaveHdr->lpNext = 0;
1265
1266 OSSpinLockLock(&wwo->lock);
1267 /* insert buffer at the end of queue */
1268 for (wh = &(wwo->lpQueuePtr); *wh; wh = &((*wh)->lpNext))
1269 /* Do nothing */;
1270 *wh = lpWaveHdr;
1271
1272 if (!wwo->lpPlayPtr)
1273 {
1274 wwo->lpPlayPtr = lpWaveHdr;
1275
1276 wodHelper_CheckForLoopBegin(wwo);
1277
1278 wwo->dwPartialOffset = 0;
1279 }
1280 OSSpinLockUnlock(&wwo->lock);
1281
1282 return MMSYSERR_NOERROR;
1283 }
1284
1285 /**************************************************************************
1286 * wodPause [internal]
1287 */
1288 static DWORD wodPause(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo)
1289 {
1290 OSStatus status;
1291
1292 TRACE("(%u, %p);!\n", wDevID, wwo);
1293
1294 if (wDevID >= MAX_WAVEOUTDRV)
1295 {
1296 WARN("bad device ID !\n");
1297 return MMSYSERR_BADDEVICEID;
1298 }
1299
1300 /* The order of the following operations is important since we can't hold
1301 * the mutex while we make an Audio Unit call. Stop the Audio Unit before
1302 * setting the PAUSED state. In wodRestart, the order is reversed. This
1303 * guarantees that we can't get into a situation where the state is
1304 * PLAYING but the Audio Unit isn't running. Although we can be in PAUSED
1305 * state with the Audio Unit still running, that's harmless because the
1306 * render callback will just produce silence.
1307 */
1308 status = AudioOutputUnitStop(wwo->audioUnit);
1309 if (status)
1310 WARN("AudioOutputUnitStop return %s\n", wine_dbgstr_fourcc(status));
1311
1312 OSSpinLockLock(&wwo->lock);
1313 if (wwo->state == WINE_WS_PLAYING)
1314 wwo->state = WINE_WS_PAUSED;
1315 OSSpinLockUnlock(&wwo->lock);
1316
1317 return MMSYSERR_NOERROR;
1318 }
1319
1320 /**************************************************************************
1321 * wodRestart [internal]
1322 */
1323 static DWORD wodRestart(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo)
1324 {
1325 OSStatus status;
1326
1327 TRACE("(%u, %p);\n", wDevID, wwo);
1328
1329 if (wDevID >= MAX_WAVEOUTDRV )
1330 {
1331 WARN("bad device ID !\n");
1332 return MMSYSERR_BADDEVICEID;
1333 }
1334
1335 /* The order of the following operations is important since we can't hold
1336 * the mutex while we make an Audio Unit call. Set the PLAYING
1337 * state before starting the Audio Unit. In wodPause, the order is
1338 * reversed. This guarantees that we can't get into a situation where
1339 * the state is PLAYING but the Audio Unit isn't running.
1340 * Although we can be in PAUSED state with the Audio Unit still running,
1341 * that's harmless because the render callback will just produce silence.
1342 */
1343 OSSpinLockLock(&wwo->lock);
1344 if (wwo->state == WINE_WS_PAUSED)
1345 wwo->state = WINE_WS_PLAYING;
1346 OSSpinLockUnlock(&wwo->lock);
1347
1348 status = AudioOutputUnitStart(wwo->audioUnit);
1349 if (status) {
1350 ERR("AudioOutputUnitStart return %s\n", wine_dbgstr_fourcc(status));
1351 return MMSYSERR_ERROR; /* FIXME return an error based on the OSStatus */
1352 }
1353
1354 return MMSYSERR_NOERROR;
1355 }
1356
1357 /**************************************************************************
1358 * wodReset [internal]
1359 */
1360 static DWORD wodReset(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo)
1361 {
1362 OSStatus status;
1363 LPWAVEHDR lpSavedQueuePtr;
1364
1365 TRACE("(%u, %p);\n", wDevID, wwo);
1366
1367 if (wDevID >= MAX_WAVEOUTDRV)
1368 {
1369 WARN("bad device ID !\n");
1370 return MMSYSERR_BADDEVICEID;
1371 }
1372
1373 OSSpinLockLock(&wwo->lock);
1374
1375 if (wwo->state == WINE_WS_CLOSING || wwo->state == WINE_WS_OPENING)
1376 {
1377 OSSpinLockUnlock(&wwo->lock);
1378 WARN("resetting a closed device\n");
1379 return MMSYSERR_INVALHANDLE;
1380 }
1381
1382 lpSavedQueuePtr = wwo->lpQueuePtr;
1383 wwo->lpPlayPtr = wwo->lpQueuePtr = wwo->lpLoopPtr = NULL;
1384 wwo->state = WINE_WS_PLAYING;
1385 wwo->dwPlayedTotal = 0;
1386
1387 wwo->dwPartialOffset = 0; /* Clear partial wavehdr */
1388
1389 OSSpinLockUnlock(&wwo->lock);
1390
1391 status = AudioOutputUnitStart(wwo->audioUnit);
1392
1393 if (status) {
1394 ERR( "AudioOutputUnitStart return %s\n", wine_dbgstr_fourcc(status));
1395 return MMSYSERR_ERROR; /* FIXME return an error based on the OSStatus */
1396 }
1397
1398 /* Now, send the "done" notification for each header in our list. */
1399 /* Do this last so the reset operation is effectively complete before the
1400 * app does whatever it's going to do in response to these notifications. */
1401 wodHelper_NotifyDoneForList(wwo, lpSavedQueuePtr);
1402
1403 return MMSYSERR_NOERROR;
1404 }
1405
1406 /**************************************************************************
1407 * wodBreakLoop [internal]
1408 */
1409 static DWORD wodBreakLoop(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo)
1410 {
1411 TRACE("(%u, %p);\n", wDevID, wwo);
1412
1413 if (wDevID >= MAX_WAVEOUTDRV)
1414 {
1415 WARN("bad device ID !\n");
1416 return MMSYSERR_BADDEVICEID;
1417 }
1418
1419 OSSpinLockLock(&wwo->lock);
1420
1421 if (wwo->lpLoopPtr != NULL)
1422 {
1423 /* ensure exit at end of current loop */
1424 wwo->dwLoops = 1;
1425 }
1426
1427 OSSpinLockUnlock(&wwo->lock);
1428
1429 return MMSYSERR_NOERROR;
1430 }
1431
1432 /**************************************************************************
1433 * wodGetPosition [internal]
1434 */
1435 static DWORD wodGetPosition(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo, LPMMTIME lpTime, DWORD uSize)
1436 {
1437 DWORD val;
1438
1439 TRACE("(%u, %p, %p, %u);\n", wDevID, wwo, lpTime, uSize);
1440
1441 if (wDevID >= MAX_WAVEOUTDRV)
1442 {
1443 WARN("bad device ID !\n");
1444 return MMSYSERR_BADDEVICEID;
1445 }
1446
1447 /* if null pointer to time structure return error */
1448 if (lpTime == NULL) return MMSYSERR_INVALPARAM;
1449
1450 OSSpinLockLock(&wwo->lock);
1451 val = wwo->dwPlayedTotal;
1452 OSSpinLockUnlock(&wwo->lock);
1453
1454 return bytes_to_mmtime(lpTime, val, &wwo->format);
1455 }
1456
1457 /**************************************************************************
1458 * wodGetVolume [internal]
1459 */
1460 static DWORD wodGetVolume(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo, LPDWORD lpdwVol)
1461 {
1462 if (wDevID >= MAX_WAVEOUTDRV)
1463 {
1464 WARN("bad device ID !\n");
1465 return MMSYSERR_BADDEVICEID;
1466 }
1467
1468 TRACE("(%u, %p, %p);\n", wDevID, wwo, lpdwVol);
1469
1470 if (wwo)
1471 {
1472 float left;
1473 float right;
1474
1475 AudioUnit_GetVolume(wwo->audioUnit, &left, &right);
1476 *lpdwVol = (WORD)(left * 0xFFFFl) + ((WORD)(right * 0xFFFFl) << 16);
1477 }
1478 else
1479 *lpdwVol = WOutDev[wDevID].device_volume;
1480
1481 return MMSYSERR_NOERROR;
1482 }
1483
1484 /**************************************************************************
1485 * wodSetVolume [internal]
1486 */
1487 static DWORD wodSetVolume(WORD wDevID, WINE_WAVEOUT_INSTANCE* wwo, DWORD dwParam)
1488 {
1489 float left;
1490 float right;
1491
1492 if (wDevID >= MAX_WAVEOUTDRV)
1493 {
1494 WARN("bad device ID !\n");
1495 return MMSYSERR_BADDEVICEID;
1496 }
1497
1498 left = LOWORD(dwParam) / 65535.0f;
1499 right = HIWORD(dwParam) / 65535.0f;
1500
1501 TRACE("(%u, %p, %08x);\n", wDevID, wwo, dwParam);
1502
1503 if (wwo)
1504 AudioUnit_SetVolume(wwo->audioUnit, left, right);
1505 else
1506 {
1507 OSSpinLockLock(&WOutDev[wDevID].lock);
1508 LIST_FOR_EACH_ENTRY(wwo, &WOutDev[wDevID].instances, WINE_WAVEOUT_INSTANCE, entry)
1509 AudioUnit_SetVolume(wwo->audioUnit, left, right);
1510 OSSpinLockUnlock(&WOutDev[wDevID].lock);
1511
1512 WOutDev[wDevID].device_volume = dwParam;
1513 }
1514
1515 return MMSYSERR_NOERROR;
1516 }
1517
1518 /**************************************************************************
1519 * wodGetNumDevs [internal]
1520 */
1521 static DWORD wodGetNumDevs(void)
1522 {
1523 TRACE("\n");
1524 return MAX_WAVEOUTDRV;
1525 }
1526
1527 /**************************************************************************
1528 * wodDevInterfaceSize [internal]
1529 */
1530 static DWORD wodDevInterfaceSize(UINT wDevID, LPDWORD dwParam1)
1531 {
1532 TRACE("(%u, %p)\n", wDevID, dwParam1);
1533
1534 *dwParam1 = MultiByteToWideChar(CP_UNIXCP, 0, WOutDev[wDevID].cadev->interface_name, -1,
1535 NULL, 0 ) * sizeof(WCHAR);
1536 return MMSYSERR_NOERROR;
1537 }
1538
1539 /**************************************************************************
1540 * wodDevInterface [internal]
1541 */
1542 static DWORD wodDevInterface(UINT wDevID, PWCHAR dwParam1, DWORD dwParam2)
1543 {
1544 TRACE("\n");
1545 if (dwParam2 >= MultiByteToWideChar(CP_UNIXCP, 0, WOutDev[wDevID].cadev->interface_name, -1,
1546 NULL, 0 ) * sizeof(WCHAR))
1547 {
1548 MultiByteToWideChar(CP_UNIXCP, 0, WOutDev[wDevID].cadev->interface_name, -1,
1549 dwParam1, dwParam2 / sizeof(WCHAR));
1550 return MMSYSERR_NOERROR;
1551 }
1552 return MMSYSERR_INVALPARAM;
1553 }
1554
1555 /**************************************************************************
1556 * widDsCreate [internal]
1557 */
1558 static DWORD wodDsCreate(UINT wDevID, PIDSDRIVER* drv)
1559 {
1560 TRACE("(%d,%p)\n",wDevID,drv);
1561
1562 FIXME("DirectSound not implemented\n");
1563 FIXME("The (slower) DirectSound HEL mode will be used instead.\n");
1564 return MMSYSERR_NOTSUPPORTED;
1565 }
1566
1567 /**************************************************************************
1568 * wodDsDesc [internal]
1569 */
1570 static DWORD wodDsDesc(UINT wDevID, PDSDRIVERDESC desc)
1571 {
1572 /* The DirectSound HEL will automatically wrap a non-DirectSound-capable
1573 * driver in a DirectSound adaptor, thus allowing the driver to be used by
1574 * DirectSound clients. However, it only does this if we respond
1575 * successfully to the DRV_QUERYDSOUNDDESC message. It's enough to fill in
1576 * the driver and device names of the description output parameter. */
1577 *desc = WOutDev[wDevID].cadev->ds_desc;
1578 return MMSYSERR_NOERROR;
1579 }
1580
1581 /**************************************************************************
1582 * wodMessage (WINECOREAUDIO.7)
1583 */
1584 DWORD WINAPI CoreAudio_wodMessage(UINT wDevID, UINT wMsg, DWORD_PTR dwUser,
1585 DWORD_PTR dwParam1, DWORD_PTR dwParam2)
1586 {
1587 WINE_WAVEOUT_INSTANCE* wwo = (WINE_WAVEOUT_INSTANCE*)dwUser;
1588
1589 TRACE("(%u, %s, %p, %p, %p);\n",
1590 wDevID, getMessage(wMsg), (void*)dwUser, (void*)dwParam1, (void*)dwParam2);
1591
1592 switch (wMsg) {
1593 case DRVM_INIT:
1594 case DRVM_EXIT:
1595 case DRVM_ENABLE:
1596 case DRVM_DISABLE:
1597
1598 /* FIXME: Pretend this is supported */
1599 return 0;
1600 case WODM_OPEN: return wodOpen(wDevID, (WINE_WAVEOUT_INSTANCE**)dwUser, (LPWAVEOPENDESC) dwParam1, dwParam2);
1601 case WODM_CLOSE: return wodClose(wDevID, wwo);
1602 case WODM_WRITE: return wodWrite(wDevID, wwo, (LPWAVEHDR) dwParam1, dwParam2);
1603 case WODM_PAUSE: return wodPause(wDevID, wwo);
1604 case WODM_GETPOS: return wodGetPosition(wDevID, wwo, (LPMMTIME) dwParam1, dwParam2);
1605 case WODM_BREAKLOOP: return wodBreakLoop(wDevID, wwo);
1606 case WODM_PREPARE: return wodPrepare(wDevID, wwo, (LPWAVEHDR)dwParam1, dwParam2);
1607 case WODM_UNPREPARE: return wodUnprepare(wDevID, wwo, (LPWAVEHDR)dwParam1, dwParam2);
1608
1609 case WODM_GETDEVCAPS: return wodGetDevCaps(wDevID, (LPWAVEOUTCAPSW) dwParam1, dwParam2);
1610 case WODM_GETNUMDEVS: return wodGetNumDevs();
1611
1612 case WODM_GETPITCH:
1613 case WODM_SETPITCH:
1614 case WODM_GETPLAYBACKRATE:
1615 case WODM_SETPLAYBACKRATE: return MMSYSERR_NOTSUPPORTED;
1616 case WODM_GETVOLUME: return wodGetVolume(wDevID, wwo, (LPDWORD)dwParam1);
1617 case WODM_SETVOLUME: return wodSetVolume(wDevID, wwo, dwParam1);
1618 case WODM_RESTART: return wodRestart(wDevID, wwo);
1619 case WODM_RESET: return wodReset(wDevID, wwo);
1620
1621 case DRV_QUERYDEVICEINTERFACESIZE: return wodDevInterfaceSize (wDevID, (LPDWORD)dwParam1);
1622 case DRV_QUERYDEVICEINTERFACE: return wodDevInterface (wDevID, (PWCHAR)dwParam1, dwParam2);
1623 case DRV_QUERYDSOUNDIFACE: return wodDsCreate (wDevID, (PIDSDRIVER*)dwParam1);
1624 case DRV_QUERYDSOUNDDESC: return wodDsDesc (wDevID, (PDSDRIVERDESC)dwParam1);
1625
1626 default:
1627 FIXME("unknown message %d!\n", wMsg);
1628 }
1629
1630 return MMSYSERR_NOTSUPPORTED;
1631 }
1632
1633 /*======================================================================*
1634 * Low level DSOUND implementation *
1635 *======================================================================*/
1636
1637 typedef struct IDsDriverImpl IDsDriverImpl;
1638 typedef struct IDsDriverBufferImpl IDsDriverBufferImpl;
1639
1640 struct IDsDriverImpl
1641 {
1642 /* IUnknown fields */
1643 const IDsDriverVtbl *lpVtbl;
1644 DWORD ref;
1645 /* IDsDriverImpl fields */
1646 UINT wDevID;
1647 IDsDriverBufferImpl*primary;
1648 };
1649
1650 struct IDsDriverBufferImpl
1651 {
1652 /* IUnknown fields */
1653 const IDsDriverBufferVtbl *lpVtbl;
1654 DWORD ref;
1655 /* IDsDriverBufferImpl fields */
1656 IDsDriverImpl* drv;
1657 DWORD buflen;
1658 };
1659
1660
1661 /*
1662 CoreAudio IO threaded callback,
1663 we can't call Wine debug channels, critical section or anything using NtCurrentTeb here.
1664 */
1665 OSStatus CoreAudio_woAudioUnitIOProc(void *inRefCon,
1666 AudioUnitRenderActionFlags *ioActionFlags,
1667 const AudioTimeStamp *inTimeStamp,
1668 UInt32 inBusNumber,
1669 UInt32 inNumberFrames,
1670 AudioBufferList *ioData)
1671 {
1672 UInt32 buffer;
1673 WINE_WAVEOUT_INSTANCE* wwo = (WINE_WAVEOUT_INSTANCE*)inRefCon;
1674 int needNotify = 0;
1675
1676 unsigned int dataNeeded = ioData->mBuffers[0].mDataByteSize;
1677 unsigned int dataProvided = 0;
1678
1679 OSSpinLockLock(&wwo->lock);
1680
1681 /* We might have been called before wwo has been completely filled out by
1682 * wodOpen, or while it's being closed in wodClose. We have to do nothing
1683 * in that case. The check of wwo->state below ensures that. */
1684 while (dataNeeded > 0 && wwo->state == WINE_WS_PLAYING && wwo->lpPlayPtr)
1685 {
1686 unsigned int available = wwo->lpPlayPtr->dwBufferLength - wwo->dwPartialOffset;
1687 unsigned int toCopy;
1688
1689 if (available >= dataNeeded)
1690 toCopy = dataNeeded;
1691 else
1692 toCopy = available;
1693
1694 if (toCopy > 0)
1695 {
1696 memcpy((char*)ioData->mBuffers[0].mData + dataProvided,
1697 wwo->lpPlayPtr->lpData + wwo->dwPartialOffset, toCopy);
1698 wwo->dwPartialOffset += toCopy;
1699 wwo->dwPlayedTotal += toCopy;
1700 dataProvided += toCopy;
1701 dataNeeded -= toCopy;
1702 available -= toCopy;
1703 }
1704
1705 if (available == 0)
1706 {
1707 wodHelper_PlayPtrNext(wwo);
1708 needNotify = 1;
1709 }
1710 }
1711 ioData->mBuffers[0].mDataByteSize = dataProvided;
1712
1713 OSSpinLockUnlock(&wwo->lock);
1714
1715 /* We can't provide any more wave data. Fill the rest with silence. */
1716 if (dataNeeded > 0)
1717 {
1718 if (!dataProvided)
1719 *ioActionFlags |= kAudioUnitRenderAction_OutputIsSilence;
1720 memset((char*)ioData->mBuffers[0].mData + dataProvided, 0, dataNeeded);
1721 dataProvided += dataNeeded;
1722 dataNeeded = 0;
1723 }
1724
1725 /* We only fill buffer 0. Set any others that might be requested to 0. */
1726 for (buffer = 1; buffer < ioData->mNumberBuffers; buffer++)
1727 {
1728 memset(ioData->mBuffers[buffer].mData, 0, ioData->mBuffers[buffer].mDataByteSize);
1729 }
1730
1731 if (needNotify) wodSendNotifyCompletionsMessage(wwo);
1732 return noErr;
1733 }
1734
1735
1736 /*======================================================================*
1737 * Low level WAVE IN implementation *
1738 *======================================================================*/
1739
1740 /**************************************************************************
1741 * widNotifyClient [internal]
1742 */
1743 static void widNotifyClient(WINE_WAVEIN* wwi, WORD wMsg, DWORD_PTR dwParam1, DWORD_PTR dwParam2)
1744 {
1745 TRACE("wMsg = 0x%04x dwParm1 = %04lX dwParam2 = %04lX\n", wMsg, dwParam1, dwParam2);
1746
1747 switch (wMsg)
1748 {
1749 case WIM_OPEN:
1750 case WIM_CLOSE:
1751 case WIM_DATA:
1752 DriverCallback(wwi->waveDesc.dwCallback, wwi->wFlags,
1753 (HDRVR)wwi->waveDesc.hWave, wMsg, wwi->waveDesc.dwInstance,
1754 dwParam1, dwParam2);
1755 break;
1756 default:
1757 FIXME("Unknown callback message %u\n", wMsg);
1758 }
1759 }
1760
1761
1762 /**************************************************************************
1763 * widHelper_NotifyCompletions [internal]
1764 */
1765 static void widHelper_NotifyCompletions(WINE_WAVEIN* wwi)
1766 {
1767 LPWAVEHDR lpWaveHdr;
1768 LPWAVEHDR lpFirstDoneWaveHdr = NULL;
1769 LPWAVEHDR lpLastDoneWaveHdr = NULL;
1770
1771 OSSpinLockLock(&wwi->lock);
1772
1773 /* First, excise all of the done headers from the queue into
1774 * a free-standing list. */
1775
1776 /* Start from lpQueuePtr and keep notifying until:
1777 * - we hit an unfilled wavehdr
1778 * - we hit the end of the list
1779 */
1780 for (
1781 lpWaveHdr = wwi->lpQueuePtr;
1782 lpWaveHdr &&
1783 lpWaveHdr->dwBytesRecorded >= lpWaveHdr->dwBufferLength;
1784 lpWaveHdr = lpWaveHdr->lpNext
1785 )
1786 {
1787 if (!lpFirstDoneWaveHdr)
1788 lpFirstDoneWaveHdr = lpWaveHdr;
1789 lpLastDoneWaveHdr = lpWaveHdr;
1790 }
1791
1792 if (lpLastDoneWaveHdr)
1793 {
1794 wwi->lpQueuePtr = lpLastDoneWaveHdr->lpNext;
1795 lpLastDoneWaveHdr->lpNext = NULL;
1796 }
1797
1798 OSSpinLockUnlock(&wwi->lock);
1799
1800 /* Now, send the "done" notification for each header in our list. */
1801 lpWaveHdr = lpFirstDoneWaveHdr;
1802 while (lpWaveHdr)
1803 {
1804 LPWAVEHDR lpNext = lpWaveHdr->lpNext;
1805
1806 lpWaveHdr->lpNext = NULL;
1807 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
1808 lpWaveHdr->dwFlags |= WHDR_DONE;
1809 widNotifyClient(wwi, WIM_DATA, (DWORD_PTR)lpWaveHdr, 0);
1810
1811 lpWaveHdr = lpNext;
1812 }
1813 }
1814
1815
1816 /**************************************************************************
1817 * widGetDevCaps [internal]
1818 */
1819 static DWORD widGetDevCaps(WORD wDevID, LPWAVEINCAPSW lpCaps, DWORD dwSize)
1820 {
1821 TRACE("(%u, %p, %u);\n", wDevID, lpCaps, dwSize);
1822
1823 if (lpCaps == NULL) return MMSYSERR_NOTENABLED;
1824
1825 if (wDevID >= MAX_WAVEINDRV)
1826 {
1827 TRACE("MAX_WAVEINDRV reached !\n");
1828 return MMSYSERR_BADDEVICEID;
1829 }
1830
1831 memcpy(lpCaps, &WInDev[wDevID].caps, min(dwSize, sizeof(*lpCaps)));
1832 return MMSYSERR_NOERROR;
1833 }
1834
1835
1836 /**************************************************************************
1837 * widHelper_DestroyAudioBufferList [internal]
1838 * Convenience function to dispose of our audio buffers
1839 */
1840 static void widHelper_DestroyAudioBufferList(AudioBufferList* list)
1841 {
1842 if (list)
1843 {
1844 UInt32 i;
1845 for (i = 0; i < list->mNumberBuffers; i++)
1846 {
1847 if (list->mBuffers[i].mData)
1848 HeapFree(GetProcessHeap(), 0, list->mBuffers[i].mData);
1849 }
1850 HeapFree(GetProcessHeap(), 0, list);
1851 }
1852 }
1853
1854
1855 #define AUDIOBUFFERLISTSIZE(numBuffers) (offsetof(AudioBufferList, mBuffers) + (numBuffers) * sizeof(AudioBuffer))
1856
1857 /**************************************************************************
1858 * widHelper_AllocateAudioBufferList [internal]
1859 * Convenience function to allocate our audio buffers
1860 */
1861 static AudioBufferList* widHelper_AllocateAudioBufferList(UInt32 numChannels, UInt32 bitsPerChannel, UInt32 bufferFrames, BOOL interleaved)
1862 {
1863 UInt32 numBuffers;
1864 UInt32 channelsPerFrame;
1865 UInt32 bytesPerFrame;
1866 UInt32 bytesPerBuffer;
1867 AudioBufferList* list;
1868 UInt32 i;
1869
1870 if (interleaved)
1871 {
1872 /* For interleaved audio, we allocate one buffer for all channels. */
1873 numBuffers = 1;
1874 channelsPerFrame = numChannels;
1875 }
1876 else
1877 {
1878 numBuffers = numChannels;
1879 channelsPerFrame = 1;
1880 }
1881
1882 bytesPerFrame = bitsPerChannel * channelsPerFrame / 8;
1883 bytesPerBuffer = bytesPerFrame * bufferFrames;
1884
1885 list = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, AUDIOBUFFERLISTSIZE(numBuffers));
1886 if (list == NULL)
1887 return NULL;
1888
1889 list->mNumberBuffers = numBuffers;
1890 for (i = 0; i < numBuffers; ++i)
1891 {
1892 list->mBuffers[i].mNumberChannels = channelsPerFrame;
1893 list->mBuffers[i].mDataByteSize = bytesPerBuffer;
1894 list->mBuffers[i].mData = HeapAlloc(GetProcessHeap(), 0, bytesPerBuffer);
1895 if (list->mBuffers[i].mData == NULL)
1896 {
1897 widHelper_DestroyAudioBufferList(list);
1898 return NULL;
1899 }
1900 }
1901 return list;
1902 }
1903
1904
1905 /**************************************************************************
1906 * widOpen [internal]
1907 */
1908 static DWORD widOpen(WORD wDevID, LPWAVEOPENDESC lpDesc, DWORD dwFlags)
1909 {
1910 WINE_WAVEIN* wwi;
1911 UInt32 frameCount;
1912
1913 TRACE("(%u, %p, %08X);\n", wDevID, lpDesc, dwFlags);
1914 if (lpDesc == NULL)
1915 {
1916 WARN("Invalid Parameter !\n");
1917 return MMSYSERR_INVALPARAM;
1918 }
1919 if (wDevID >= MAX_WAVEINDRV)
1920 {
1921 TRACE ("MAX_WAVEINDRV reached !\n");
1922 return MMSYSERR_BADDEVICEID;
1923 }
1924
1925 TRACE("Format: tag=%04X nChannels=%d nSamplesPerSec=%d wBitsPerSample=%d !\n",
1926 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
1927 lpDesc->lpFormat->nSamplesPerSec, lpDesc->lpFormat->wBitsPerSample);
1928
1929 if (!supportedFormat(lpDesc->lpFormat) ||
1930 lpDesc->lpFormat->nSamplesPerSec != AudioUnit_GetInputDeviceSampleRate()
1931 )
1932 {
1933 WARN("Bad format: tag=%04X nChannels=%d nSamplesPerSec=%d wBitsPerSample=%d !\n",
1934 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
1935 lpDesc->lpFormat->nSamplesPerSec, lpDesc->lpFormat->wBitsPerSample);
1936 return WAVERR_BADFORMAT;
1937 }
1938
1939 if (dwFlags & WAVE_FORMAT_QUERY)
1940 {
1941 TRACE("Query format: tag=%04X nChannels=%d nSamplesPerSec=%d !\n",
1942 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
1943 lpDesc->lpFormat->nSamplesPerSec);
1944 return MMSYSERR_NOERROR;
1945 }
1946
1947 /* nBlockAlign and nAvgBytesPerSec are output variables for dsound */
1948 if (lpDesc->lpFormat->nBlockAlign != lpDesc->lpFormat->nChannels*lpDesc->lpFormat->wBitsPerSample/8) {
1949 lpDesc->lpFormat->nBlockAlign = lpDesc->lpFormat->nChannels*lpDesc->lpFormat->wBitsPerSample/8;
1950 WARN("Fixing nBlockAlign\n");
1951 }
1952 if (lpDesc->lpFormat->nAvgBytesPerSec!= lpDesc->lpFormat->nSamplesPerSec*lpDesc->lpFormat->nBlockAlign) {
1953 lpDesc->lpFormat->nAvgBytesPerSec = lpDesc->lpFormat->nSamplesPerSec*lpDesc->lpFormat->nBlockAlign;
1954 WARN("Fixing nAvgBytesPerSec\n");
1955 }
1956
1957 wwi = &WInDev[wDevID];
1958 if (!OSSpinLockTry(&wwi->lock))
1959 return MMSYSERR_ALLOCATED;
1960
1961 if (wwi->state != WINE_WS_CLOSED)
1962 {
1963 OSSpinLockUnlock(&wwi->lock);
1964 return MMSYSERR_ALLOCATED;
1965 }
1966
1967 wwi->state = WINE_WS_STOPPED;
1968 wwi->wFlags = HIWORD(dwFlags & CALLBACK_TYPEMASK);
1969
1970 wwi->waveDesc = *lpDesc;
1971 copyFormat(lpDesc->lpFormat, &wwi->format);
1972
1973 wwi->dwTotalRecorded = 0;
1974
1975 wwi->trace_on = TRACE_ON(wave);
1976 wwi->warn_on = WARN_ON(wave);
1977 wwi->err_on = ERR_ON(wave);
1978
1979 if (!AudioUnit_CreateInputUnit(wwi, &wwi->audioUnit,
1980 wwi->format.wf.nChannels, wwi->format.wf.nSamplesPerSec,
1981 wwi->format.wBitsPerSample, &frameCount))
1982 {
1983 OSSpinLockUnlock(&wwi->lock);
1984 ERR("AudioUnit_CreateInputUnit failed\n");
1985 return MMSYSERR_ERROR;
1986 }
1987
1988 /* Allocate our audio buffers */
1989 wwi->bufferList = widHelper_AllocateAudioBufferList(wwi->format.wf.nChannels,
1990 wwi->format.wBitsPerSample, frameCount, TRUE);
1991 if (wwi->bufferList == NULL)
1992 {
1993 AudioUnitUninitialize(wwi->audioUnit);
1994 AudioUnit_CloseAudioUnit(wwi->audioUnit);
1995 OSSpinLockUnlock(&wwi->lock);
1996 ERR("Failed to allocate buffer list\n");
1997 return MMSYSERR_NOMEM;
1998 }
1999
2000 /* Keep a copy of the buffer list structure (but not the buffers themselves)
2001 * in case AudioUnitRender clobbers the original, as it tends to do. */
2002 wwi->bufferListCopy = HeapAlloc(GetProcessHeap(), 0, AUDIOBUFFERLISTSIZE(wwi->bufferList->mNumberBuffers));
2003 if (wwi->bufferListCopy == NULL)
2004 {
2005 widHelper_DestroyAudioBufferList(wwi->bufferList);
2006 AudioUnitUninitialize(wwi->audioUnit);
2007 AudioUnit_CloseAudioUnit(wwi->audioUnit);
2008 OSSpinLockUnlock(&wwi->lock);
2009 ERR("Failed to allocate buffer list copy\n");
2010 return MMSYSERR_NOMEM;
2011 }
2012 memcpy(wwi->bufferListCopy, wwi->bufferList, AUDIOBUFFERLISTSIZE(wwi->bufferList->mNumberBuffers));
2013
2014 OSSpinLockUnlock(&wwi->lock);
2015
2016 widNotifyClient(wwi, WIM_OPEN, 0L, 0L);
2017
2018 return MMSYSERR_NOERROR;
2019 }
2020
2021
2022 /**************************************************************************
2023 * widClose [internal]
2024 */
2025 static DWORD widClose(WORD wDevID)
2026 {
2027 DWORD ret = MMSYSERR_NOERROR;
2028 WINE_WAVEIN* wwi;
2029 OSStatus err;
2030
2031 TRACE("(%u);\n", wDevID);
2032
2033 if (wDevID >= MAX_WAVEINDRV)
2034 {
2035 WARN("bad device ID !\n");
2036 return MMSYSERR_BADDEVICEID;
2037 }
2038
2039 wwi = &WInDev[wDevID];
2040 OSSpinLockLock(&wwi->lock);
2041 if (wwi->state == WINE_WS_CLOSED || wwi->state == WINE_WS_CLOSING)
2042 {
2043 WARN("Device already closed.\n");
2044 ret = MMSYSERR_INVALHANDLE;
2045 }
2046 else if (wwi->lpQueuePtr)
2047 {
2048 WARN("Buffers in queue.\n");
2049 ret = WAVERR_STILLPLAYING;
2050 }
2051 else
2052 {
2053 wwi->state = WINE_WS_CLOSING;
2054 }
2055
2056 OSSpinLockUnlock(&wwi->lock);
2057
2058 if (ret != MMSYSERR_NOERROR)
2059 return ret;
2060
2061
2062 /* Clean up and close the audio unit. This has to be done without
2063 * wwi->lock being held to avoid deadlock. AudioUnitUninitialize will
2064 * grab an internal Core Audio lock while waiting for the device work
2065 * thread to exit. Meanwhile the device work thread may be holding
2066 * that lock and trying to grab the wwi->lock in the callback. */
2067 err = AudioUnitUninitialize(wwi->audioUnit);
2068 if (err)
2069 ERR("AudioUnitUninitialize return %s\n", wine_dbgstr_fourcc(err));
2070
2071 if (!AudioUnit_CloseAudioUnit(wwi->audioUnit))
2072 ERR("Can't close AudioUnit\n");
2073
2074
2075 OSSpinLockLock(&wwi->lock);
2076 assert(wwi->state == WINE_WS_CLOSING);
2077
2078 /* Dellocate our audio buffers */
2079 widHelper_DestroyAudioBufferList(wwi->bufferList);
2080 wwi->bufferList = NULL;
2081 HeapFree(GetProcessHeap(), 0, wwi->bufferListCopy);
2082 wwi->bufferListCopy = NULL;
2083
2084 wwi->audioUnit = NULL;
2085 wwi->state = WINE_WS_CLOSED;
2086 OSSpinLockUnlock(&wwi->lock);
2087
2088 widNotifyClient(wwi, WIM_CLOSE, 0L, 0L);
2089
2090 return ret;
2091 }
2092
2093
2094 /**************************************************************************
2095 * widAddBuffer [internal]
2096 */
2097 static DWORD widAddBuffer(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
2098 {
2099 DWORD ret = MMSYSERR_NOERROR;
2100 WINE_WAVEIN* wwi;
2101
2102 TRACE("(%u, %p, %08X);\n", wDevID, lpWaveHdr, dwSize);
2103
2104 if (wDevID >= MAX_WAVEINDRV)
2105 {
2106 WARN("invalid device ID\n");
2107 return MMSYSERR_INVALHANDLE;
2108 }
2109 if (!(lpWaveHdr->dwFlags & WHDR_PREPARED))
2110 {
2111 TRACE("never been prepared !\n");
2112 return WAVERR_UNPREPARED;
2113 }
2114 if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
2115 {
2116 TRACE("header already in use !\n");
2117 return WAVERR_STILLPLAYING;
2118 }
2119
2120 wwi = &WInDev[wDevID];
2121 OSSpinLockLock(&wwi->lock);
2122
2123 if (wwi->state == WINE_WS_CLOSED || wwi->state == WINE_WS_CLOSING)
2124 {
2125 WARN("Trying to add buffer to closed device.\n");
2126 ret = MMSYSERR_INVALHANDLE;
2127 }
2128 else
2129 {
2130 LPWAVEHDR* wh;
2131
2132 lpWaveHdr->dwFlags |= WHDR_INQUEUE;
2133 lpWaveHdr->dwFlags &= ~WHDR_DONE;
2134 lpWaveHdr->dwBytesRecorded = 0;
2135 lpWaveHdr->lpNext = NULL;
2136
2137 /* insert buffer at end of queue */
2138 for (wh = &(wwi->lpQueuePtr); *wh; wh = &((*wh)->lpNext))
2139 /* Do nothing */;
2140 *wh = lpWaveHdr;
2141 }
2142
2143 OSSpinLockUnlock(&wwi->lock);
2144
2145 return ret;
2146 }
2147
2148
2149 /**************************************************************************
2150 * widStart [internal]
2151 */
2152 static DWORD widStart(WORD wDevID)
2153 {
2154 DWORD ret = MMSYSERR_NOERROR;
2155 WINE_WAVEIN* wwi;
2156
2157 TRACE("(%u);\n", wDevID);
2158 if (wDevID >= MAX_WAVEINDRV)
2159 {
2160 WARN("invalid device ID\n");
2161 return MMSYSERR_INVALHANDLE;
2162 }
2163
2164 /* The order of the following operations is important since we can't hold
2165 * the mutex while we make an Audio Unit call. Set the PLAYING state
2166 * before starting the Audio Unit. In widStop, the order is reversed.
2167 * This guarantees that we can't get into a situation where the state is
2168 * PLAYING but the Audio Unit isn't running. Although we can be in STOPPED
2169 * state with the Audio Unit still running, that's harmless because the
2170 * input callback will just throw away the sound data.
2171 */
2172 wwi = &WInDev[wDevID];
2173 OSSpinLockLock(&wwi->lock);
2174
2175 if (wwi->state == WINE_WS_CLOSED || wwi->state == WINE_WS_CLOSING)
2176 {
2177 WARN("Trying to start closed device.\n");
2178 ret = MMSYSERR_INVALHANDLE;
2179 }
2180 else
2181 wwi->state = WINE_WS_PLAYING;
2182
2183 OSSpinLockUnlock(&wwi->lock);
2184
2185 if (ret == MMSYSERR_NOERROR)
2186 {
2187 /* Start pulling for audio data */
2188 OSStatus err = AudioOutputUnitStart(wwi->audioUnit);
2189 if (err != noErr)
2190 ERR("Failed to start AU: %08lx\n", err);
2191
2192 TRACE("Recording started...\n");
2193 }
2194
2195 return ret;
2196 }
2197
2198
2199 /**************************************************************************
2200 * widStop [internal]
2201 */
2202 static DWORD widStop(WORD wDevID)
2203 {
2204 DWORD ret = MMSYSERR_NOERROR;
2205 WINE_WAVEIN* wwi;
2206 WAVEHDR* lpWaveHdr = NULL;
2207 OSStatus err;
2208
2209 TRACE("(%u);\n", wDevID);
2210 if (wDevID >= MAX_WAVEINDRV)
2211 {
2212 WARN("invalid device ID\n");
2213 return MMSYSERR_INVALHANDLE;
2214 }
2215
2216 wwi = &WInDev[wDevID];
2217
2218 /* The order of the following operations is important since we can't hold
2219 * the mutex while we make an Audio Unit call. Stop the Audio Unit before
2220 * setting the STOPPED state. In widStart, the order is reversed. This
2221 * guarantees that we can't get into a situation where the state is
2222 * PLAYING but the Audio Unit isn't running. Although we can be in STOPPED
2223 * state with the Audio Unit still running, that's harmless because the
2224 * input callback will just throw away the sound data.
2225 */
2226 err = AudioOutputUnitStop(wwi->audioUnit);
2227 if (err != noErr)
2228 WARN("Failed to stop AU: %08lx\n", err);
2229
2230 TRACE("Recording stopped.\n");
2231
2232 OSSpinLockLock(&wwi->lock);
2233
2234 if (wwi->state == WINE_WS_CLOSED || wwi->state == WINE_WS_CLOSING)
2235 {
2236 WARN("Trying to stop closed device.\n");
2237 ret = MMSYSERR_INVALHANDLE;
2238 }
2239 else if (wwi->state != WINE_WS_STOPPED)
2240 {
2241 wwi->state = WINE_WS_STOPPED;
2242 /* If there's a buffer in progress, it's done. Remove it from the
2243 * queue so that we can return it to the app, below. */
2244 if (wwi->lpQueuePtr)
2245 {
2246 lpWaveHdr = wwi->lpQueuePtr;
2247 wwi->lpQueuePtr = lpWaveHdr->lpNext;
2248 }
2249 }
2250
2251 OSSpinLockUnlock(&wwi->lock);
2252
2253 if (lpWaveHdr)
2254 {
2255 lpWaveHdr->lpNext = NULL;
2256 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
2257 lpWaveHdr->dwFlags |= WHDR_DONE;
2258 widNotifyClient(wwi, WIM_DATA, (DWORD_PTR)lpWaveHdr, 0);
2259 }
2260
2261 return ret;
2262 }
2263
2264 /**************************************************************************
2265 * widGetPos [internal]
2266 */
2267 static DWORD widGetPos(WORD wDevID, LPMMTIME lpTime, UINT size)
2268 {
2269 DWORD val;
2270 WINE_WAVEIN* wwi;
2271
2272 TRACE("(%u);\n", wDevID);
2273 if (wDevID >= MAX_WAVEINDRV)
2274 {
2275 WARN("invalid device ID\n");
2276 return MMSYSERR_INVALHANDLE;
2277 }
2278
2279 wwi = &WInDev[wDevID];
2280
2281 OSSpinLockLock(&WInDev[wDevID].lock);
2282 val = wwi->dwTotalRecorded;
2283 OSSpinLockUnlock(&WInDev[wDevID].lock);
2284
2285 return bytes_to_mmtime(lpTime, val, &wwi->format);
2286 }
2287
2288 /**************************************************************************
2289 * widReset [internal]
2290 */
2291 static DWORD widReset(WORD wDevID)
2292 {
2293 DWORD ret = MMSYSERR_NOERROR;
2294 WINE_WAVEIN* wwi;
2295 WAVEHDR* lpWaveHdr = NULL;
2296
2297 TRACE("(%u);\n", wDevID);
2298 if (wDevID >= MAX_WAVEINDRV)
2299 {
2300 WARN("invalid device ID\n");
2301 return MMSYSERR_INVALHANDLE;
2302 }
2303
2304 wwi = &WInDev[wDevID];
2305 OSSpinLockLock(&wwi->lock);
2306
2307 if (wwi->state == WINE_WS_CLOSED || wwi->state == WINE_WS_CLOSING)
2308 {
2309 WARN("Trying to reset a closed device.\n");
2310 ret = MMSYSERR_INVALHANDLE;
2311 }
2312 else
2313 {
2314 lpWaveHdr = wwi->lpQueuePtr;
2315 wwi->lpQueuePtr = NULL;
2316 wwi->state = WINE_WS_STOPPED;
2317 wwi->dwTotalRecorded = 0;
2318 }
2319
2320 OSSpinLockUnlock(&wwi->lock);
2321
2322 if (ret == MMSYSERR_NOERROR)
2323 {
2324 OSStatus err = AudioOutputUnitStop(wwi->audioUnit);
2325 if (err != noErr)
2326 WARN("Failed to stop AU: %08lx\n", err);
2327
2328 TRACE("Recording stopped.\n");
2329 }
2330
2331 while (lpWaveHdr)
2332 {
2333 WAVEHDR* lpNext = lpWaveHdr->lpNext;
2334
2335 lpWaveHdr->lpNext = NULL;
2336 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
2337 lpWaveHdr->dwFlags |= WHDR_DONE;
2338 widNotifyClient(wwi, WIM_DATA, (DWORD_PTR)lpWaveHdr, 0);
2339
2340 lpWaveHdr = lpNext;
2341 }
2342
2343 return ret;
2344 }
2345
2346
2347 /**************************************************************************
2348 * widGetNumDevs [internal]
2349 */
2350 static DWORD widGetNumDevs(void)
2351 {
2352 return MAX_WAVEINDRV;
2353 }
2354
2355
2356 /**************************************************************************
2357 * widDevInterfaceSize [internal]
2358 */
2359 static DWORD widDevInterfaceSize(UINT wDevID, LPDWORD dwParam1)
2360 {
2361 TRACE("(%u, %p)\n", wDevID, dwParam1);
2362
2363 *dwParam1 = MultiByteToWideChar(CP_UNIXCP, 0, WInDev[wDevID].interface_name, -1,
2364 NULL, 0 ) * sizeof(WCHAR);
2365 return MMSYSERR_NOERROR;
2366 }
2367
2368
2369 /**************************************************************************
2370 * widDevInterface [internal]
2371 */
2372 static DWORD widDevInterface(UINT wDevID, PWCHAR dwParam1, DWORD dwParam2)
2373 {
2374 if (dwParam2 >= MultiByteToWideChar(CP_UNIXCP, 0, WInDev[wDevID].interface_name, -1,
2375 NULL, 0 ) * sizeof(WCHAR))
2376 {
2377 MultiByteToWideChar(CP_UNIXCP, 0, WInDev[wDevID].interface_name, -1,
2378 dwParam1, dwParam2 / sizeof(WCHAR));
2379 return MMSYSERR_NOERROR;
2380 }
2381 return MMSYSERR_INVALPARAM;
2382 }
2383
2384
2385 /**************************************************************************
2386 * widDsCreate [internal]
2387 */
2388 static DWORD widDsCreate(UINT wDevID, PIDSCDRIVER* drv)
2389 {
2390 TRACE("(%d,%p)\n",wDevID,drv);
2391
2392 FIXME("DirectSoundCapture not implemented\n");
2393 FIXME("The (slower) DirectSound HEL mode will be used instead.\n");
2394 return MMSYSERR_NOTSUPPORTED;
2395 }
2396
2397 /**************************************************************************
2398 * widDsDesc [internal]
2399 */
2400 static DWORD widDsDesc(UINT wDevID, PDSDRIVERDESC desc)
2401 {
2402 /* The DirectSound HEL will automatically wrap a non-DirectSound-capable
2403 * driver in a DirectSound adaptor, thus allowing the driver to be used by
2404 * DirectSound clients. However, it only does this if we respond
2405 * successfully to the DRV_QUERYDSOUNDDESC message. It's enough to fill in
2406 * the driver and device names of the description output parameter. */
2407 memset(desc, 0, sizeof(*desc));
2408 lstrcpynA(desc->szDrvname, "winecoreaudio.drv", sizeof(desc->szDrvname) - 1);
2409 lstrcpynA(desc->szDesc, WInDev[wDevID].interface_name, sizeof(desc->szDesc) - 1);
2410 return MMSYSERR_NOERROR;
2411 }
2412
2413
2414 /**************************************************************************
2415 * widMessage (WINECOREAUDIO.6)
2416 */
2417 DWORD WINAPI CoreAudio_widMessage(WORD wDevID, WORD wMsg, DWORD dwUser,
2418 DWORD dwParam1, DWORD dwParam2)
2419 {
2420 TRACE("(%u, %04X, %08X, %08X, %08X);\n",
2421 wDevID, wMsg, dwUser, dwParam1, dwParam2);
2422
2423 switch (wMsg)
2424 {
2425 case DRVM_INIT:
2426 case DRVM_EXIT:
2427 case DRVM_ENABLE:
2428 case DRVM_DISABLE:
2429 /* FIXME: Pretend this is supported */
2430 return 0;
2431 case WIDM_OPEN: return widOpen (wDevID, (LPWAVEOPENDESC)dwParam1, dwParam2);
2432 case WIDM_CLOSE: return widClose (wDevID);
2433 case WIDM_ADDBUFFER: return widAddBuffer (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
2434 case WIDM_PREPARE: return MMSYSERR_NOTSUPPORTED;
2435 case WIDM_UNPREPARE: return MMSYSERR_NOTSUPPORTED;
2436 case WIDM_GETDEVCAPS: return widGetDevCaps (wDevID, (LPWAVEINCAPSW)dwParam1, dwParam2);
2437 case WIDM_GETNUMDEVS: return widGetNumDevs ();
2438 case WIDM_RESET: return widReset (wDevID);
2439 case WIDM_START: return widStart (wDevID);
2440 case WIDM_STOP: return widStop (wDevID);
2441 case WIDM_GETPOS: return widGetPos (wDevID, (LPMMTIME)dwParam1, (UINT)dwParam2 );
2442 case DRV_QUERYDEVICEINTERFACESIZE: return widDevInterfaceSize (wDevID, (LPDWORD)dwParam1);
2443 case DRV_QUERYDEVICEINTERFACE: return widDevInterface (wDevID, (PWCHAR)dwParam1, dwParam2);
2444 case DRV_QUERYDSOUNDIFACE: return widDsCreate (wDevID, (PIDSCDRIVER*)dwParam1);
2445 case DRV_QUERYDSOUNDDESC: return widDsDesc (wDevID, (PDSDRIVERDESC)dwParam1);
2446 default:
2447 FIXME("unknown message %d!\n", wMsg);
2448 }
2449
2450 return MMSYSERR_NOTSUPPORTED;
2451 }
2452
2453
2454 OSStatus CoreAudio_wiAudioUnitIOProc(void *inRefCon,
2455 AudioUnitRenderActionFlags *ioActionFlags,
2456 const AudioTimeStamp *inTimeStamp,
2457 UInt32 inBusNumber,
2458 UInt32 inNumberFrames,
2459 AudioBufferList *ioData)
2460 {
2461 WINE_WAVEIN* wwi = (WINE_WAVEIN*)inRefCon;
2462 OSStatus err = noErr;
2463 BOOL needNotify = FALSE;
2464 WAVEHDR* lpStorePtr;
2465 unsigned int dataToStore;
2466 unsigned int dataStored = 0;
2467
2468
2469 if (wwi->trace_on)
2470 fprintf(stderr, "trace:wave:CoreAudio_wiAudioUnitIOProc (ioActionFlags = %08lx, "
2471 "inTimeStamp = { %f, %x%08x, %f, %x%08x, %08lx }, inBusNumber = %lu, inNumberFrames = %lu)\n",
2472 *ioActionFlags, inTimeStamp->mSampleTime, (DWORD)(inTimeStamp->mHostTime >>32),
2473 (DWORD)inTimeStamp->mHostTime, inTimeStamp->mRateScalar, (DWORD)(inTimeStamp->mWordClockTime >> 32),
2474 (DWORD)inTimeStamp->mWordClockTime, inTimeStamp->mFlags, inBusNumber, inNumberFrames);
2475
2476 /* Render into audio buffer */
2477 /* FIXME: implement sample rate conversion on input. This will require
2478 * a different render strategy. We'll need to buffer the sound data
2479 * received here and pass it off to an AUConverter in another thread. */
2480 err = AudioUnitRender(wwi->audioUnit, ioActionFlags, inTimeStamp, inBusNumber, inNumberFrames, wwi->bufferList);
2481 if (err)
2482 {
2483 if (wwi->err_on)
2484 fprintf(stderr, "err:wave:CoreAudio_wiAudioUnitIOProc AudioUnitRender failed with error %li\n", err);
2485 return err;
2486 }
2487
2488 /* Copy from audio buffer to the wavehdrs */
2489 dataToStore = wwi->bufferList->mBuffers[0].mDataByteSize;
2490
2491 OSSpinLockLock(&wwi->lock);
2492
2493 lpStorePtr = wwi->lpQueuePtr;
2494
2495 /* We might have been called while the waveIn device is being closed in
2496 * widClose. We have to do nothing in that case. The check of wwi->state
2497 * below ensures that. */
2498 while (dataToStore > 0 && wwi->state == WINE_WS_PLAYING && lpStorePtr)
2499 {
2500 unsigned int room = lpStorePtr->dwBufferLength - lpStorePtr->dwBytesRecorded;
2501 unsigned int toCopy;
2502
2503 if (wwi->trace_on)
2504 fprintf(stderr, "trace:wave:CoreAudio_wiAudioUnitIOProc Looking to store %u bytes to wavehdr %p, which has room for %u\n",
2505 dataToStore, lpStorePtr, room);
2506
2507 if (room >= dataToStore)
2508 toCopy = dataToStore;
2509 else
2510 toCopy = room;
2511
2512 if (toCopy > 0)
2513 {
2514 memcpy(lpStorePtr->lpData + lpStorePtr->dwBytesRecorded,
2515 (char*)wwi->bufferList->mBuffers[0].mData + dataStored, toCopy);
2516 lpStorePtr->dwBytesRecorded += toCopy;
2517 wwi->dwTotalRecorded += toCopy;
2518 dataStored += toCopy;
2519 dataToStore -= toCopy;
2520 room -= toCopy;
2521 }
2522
2523 if (room == 0)
2524 {
2525 lpStorePtr = lpStorePtr->lpNext;
2526 needNotify = TRUE;
2527 }
2528 }
2529
2530 OSSpinLockUnlock(&wwi->lock);
2531
2532 /* Restore the audio buffer list structure from backup, in case
2533 * AudioUnitRender clobbered it. (It modifies mDataByteSize and may even
2534 * give us a different mData buffer to avoid a copy.) */
2535 memcpy(wwi->bufferList, wwi->bufferListCopy, AUDIOBUFFERLISTSIZE(wwi->bufferList->mNumberBuffers));
2536
2537 if (needNotify) wodSendNotifyInputCompletionsMessage(wwi);
2538 return err;
2539 }
Wine tree for Wine Gecko development