?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
winealsa: Clear dwBytesRecorded in waveheader when adding buffer.
[wine/gsoc_dplay.git] / dlls / winealsa.drv / wavein.c
blob200879b9f44434fdd6b73ddc81fcc6b81bb4d5eb
1 /*
2 * Sample Wine Driver for Advanced Linux Sound System (ALSA)
3 * Based on version <final> of the ALSA API
4 *
5 * Copyright 2002 Eric Pouech
6 * 2002 Marco Pietrobono
7 * 2003 Christian Costa : WaveIn support
8 * 2006-2007 Maarten Lankhorst
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 /*======================================================================*
26 * Low level WAVE IN implementation *
27 *======================================================================*/
28
29 #include "config.h"
30 #include "wine/port.h"
31
32 #include <stdlib.h>
33 #include <stdarg.h>
34 #include <stdio.h>
35 #include <string.h>
36 #ifdef HAVE_UNISTD_H
37 # include <unistd.h>
38 #endif
39 #include <errno.h>
40 #include <limits.h>
41 #include <fcntl.h>
42 #ifdef HAVE_SYS_IOCTL_H
43 # include <sys/ioctl.h>
44 #endif
45 #ifdef HAVE_SYS_MMAN_H
46 # include <sys/mman.h>
47 #endif
48 #include "windef.h"
49 #include "winbase.h"
50 #include "wingdi.h"
51 #include "winuser.h"
52 #include "winnls.h"
53 #include "mmddk.h"
54
55 #include "alsa.h"
56 #include "wine/library.h"
57 #include "wine/unicode.h"
58 #include "wine/debug.h"
59
60 WINE_DEFAULT_DEBUG_CHANNEL(wave);
61
62 #ifdef HAVE_ALSA
63
64 WINE_WAVEDEV *WInDev;
65 DWORD ALSA_WidNumMallocedDevs;
66 DWORD ALSA_WidNumDevs;
67
68 /**************************************************************************
69 * widNotifyClient [internal]
70 */
71 static DWORD widNotifyClient(WINE_WAVEDEV* wwi, WORD wMsg, DWORD dwParam1, DWORD dwParam2)
72 {
73 TRACE("wMsg = 0x%04x dwParm1 = %04X dwParam2 = %04X\n", wMsg, dwParam1, dwParam2);
74
75 switch (wMsg) {
76 case WIM_OPEN:
77 case WIM_CLOSE:
78 case WIM_DATA:
79 if (wwi->wFlags != DCB_NULL &&
80 !DriverCallback(wwi->waveDesc.dwCallback, wwi->wFlags, (HDRVR)wwi->waveDesc.hWave,
81 wMsg, wwi->waveDesc.dwInstance, dwParam1, dwParam2)) {
82 WARN("can't notify client !\n");
83 return MMSYSERR_ERROR;
84 }
85 break;
86 default:
87 FIXME("Unknown callback message %u\n", wMsg);
88 return MMSYSERR_INVALPARAM;
89 }
90 return MMSYSERR_NOERROR;
91 }
92
93 /**************************************************************************
94 * widGetDevCaps [internal]
95 */
96 static DWORD widGetDevCaps(WORD wDevID, LPWAVEINCAPSW lpCaps, DWORD dwSize)
97 {
98 TRACE("(%u, %p, %u);\n", wDevID, lpCaps, dwSize);
99
100 if (lpCaps == NULL) return MMSYSERR_NOTENABLED;
101
102 if (wDevID >= ALSA_WidNumDevs) {
103 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
104 return MMSYSERR_BADDEVICEID;
105 }
106
107 memcpy(lpCaps, &WInDev[wDevID].incaps, min(dwSize, sizeof(*lpCaps)));
108 return MMSYSERR_NOERROR;
109 }
110
111 /**************************************************************************
112 * widRecorder_ReadHeaders [internal]
113 */
114 static void widRecorder_ReadHeaders(WINE_WAVEDEV * wwi)
115 {
116 enum win_wm_message tmp_msg;
117 DWORD tmp_param;
118 HANDLE tmp_ev;
119 WAVEHDR* lpWaveHdr;
120
121 while (ALSA_RetrieveRingMessage(&wwi->msgRing, &tmp_msg, &tmp_param, &tmp_ev)) {
122 if (tmp_msg == WINE_WM_HEADER) {
123 LPWAVEHDR* wh;
124 lpWaveHdr = (LPWAVEHDR)tmp_param;
125 lpWaveHdr->lpNext = 0;
126
127 if (wwi->lpQueuePtr == 0)
128 wwi->lpQueuePtr = lpWaveHdr;
129 else {
130 for (wh = &(wwi->lpQueuePtr); *wh; wh = &((*wh)->lpNext));
131 *wh = lpWaveHdr;
132 }
133 } else {
134 ERR("should only have headers left\n");
135 }
136 }
137 }
138
139 /**************************************************************************
140 * widRecorder [internal]
141 */
142 static DWORD CALLBACK widRecorder(LPVOID pmt)
143 {
144 WORD uDevID = (DWORD)pmt;
145 WINE_WAVEDEV* wwi = (WINE_WAVEDEV*)&WInDev[uDevID];
146 WAVEHDR* lpWaveHdr;
147 DWORD dwSleepTime;
148 DWORD bytesRead;
149 enum win_wm_message msg;
150 DWORD param;
151 HANDLE ev;
152 DWORD frames_per_period;
153
154 wwi->state = WINE_WS_STOPPED;
155 InterlockedExchange((LONG*)&wwi->dwTotalRecorded, 0);
156 wwi->lpQueuePtr = NULL;
157
158 SetEvent(wwi->hStartUpEvent);
159
160 /* make sleep time to be # of ms to output a period */
161 dwSleepTime = (wwi->dwPeriodSize * 1000) / wwi->format.Format.nAvgBytesPerSec;
162 frames_per_period = snd_pcm_bytes_to_frames(wwi->pcm, wwi->dwPeriodSize);
163 TRACE("sleeptime=%d ms, total buffer length=%d ms (%d bytes)\n", dwSleepTime, wwi->dwBufferSize * 1000 / wwi->format.Format.nAvgBytesPerSec, wwi->dwBufferSize);
164
165 for (;;) {
166 /* wait for dwSleepTime or an event in thread's queue */
167 /* FIXME: could improve wait time depending on queue state,
168 * ie, number of queued fragments
169 */
170 if (wwi->lpQueuePtr != NULL && wwi->state == WINE_WS_PLAYING)
171 {
172 DWORD frames;
173 DWORD bytes;
174 DWORD read;
175
176 lpWaveHdr = wwi->lpQueuePtr;
177 /* read all the fragments accumulated so far */
178 frames = snd_pcm_avail_update(wwi->pcm);
179 bytes = snd_pcm_frames_to_bytes(wwi->pcm, frames);
180
181 TRACE("frames = %d bytes = %d state=%d\n", frames, bytes, snd_pcm_state(wwi->pcm));
182 if (snd_pcm_state(wwi->pcm) == SND_PCM_STATE_XRUN)
183 {
184 FIXME("Recovering from XRUN!\n");
185 snd_pcm_prepare(wwi->pcm);
186 frames = snd_pcm_avail_update(wwi->pcm);
187 bytes = snd_pcm_frames_to_bytes(wwi->pcm, frames);
188 snd_pcm_start(wwi->pcm);
189 snd_pcm_forward(wwi->pcm, frames - snd_pcm_bytes_to_frames(wwi->pcm, wwi->dwPeriodSize));
190 continue;
191 }
192 while (frames > 0 && wwi->lpQueuePtr)
193 {
194 TRACE("bytes = %d\n", bytes);
195 if (lpWaveHdr->dwBufferLength - lpWaveHdr->dwBytesRecorded < bytes)
196 {
197 bytes = lpWaveHdr->dwBufferLength - lpWaveHdr->dwBytesRecorded;
198 frames = snd_pcm_bytes_to_frames(wwi->pcm, bytes);
199 }
200 /* directly read fragment in wavehdr */
201 read = wwi->read(wwi->pcm, lpWaveHdr->lpData + lpWaveHdr->dwBytesRecorded, frames);
202 bytesRead = snd_pcm_frames_to_bytes(wwi->pcm, read);
203
204 TRACE("bytesRead=(%d(%d)/(%d)) -> (%d/%d) \n", bytesRead, read, frames, lpWaveHdr->dwBufferLength, lpWaveHdr->dwBufferLength - lpWaveHdr->dwBytesRecorded);
205 if (read != (DWORD) -1)
206 {
207 /* update number of bytes recorded in current buffer and by this device */
208 lpWaveHdr->dwBytesRecorded += bytesRead;
209 InterlockedExchangeAdd((LONG*)&wwi->dwTotalRecorded, bytesRead);
210 frames -= read;
211 bytes -= bytesRead;
212
213 /* buffer is full. notify client */
214 if (!snd_pcm_bytes_to_frames(wwi->pcm, lpWaveHdr->dwBytesRecorded - lpWaveHdr->dwBufferLength))
215 {
216 /* must copy the value of next waveHdr, because we have no idea of what
217 * will be done with the content of lpWaveHdr in callback
218 */
219 LPWAVEHDR lpNext = lpWaveHdr->lpNext;
220
221 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
222 lpWaveHdr->dwFlags |= WHDR_DONE;
223
224 wwi->lpQueuePtr = lpNext;
225 widNotifyClient(wwi, WIM_DATA, (DWORD)lpWaveHdr, 0);
226 lpWaveHdr = lpNext;
227 }
228 } else {
229 WARN("read(%s, %p, %d) failed (%d/%s)\n", wwi->pcmname,
230 lpWaveHdr->lpData + lpWaveHdr->dwBytesRecorded,
231 frames, frames, snd_strerror(read));
232 }
233 }
234 }
235
236 ALSA_WaitRingMessage(&wwi->msgRing, dwSleepTime);
237
238 while (ALSA_RetrieveRingMessage(&wwi->msgRing, &msg, &param, &ev))
239 {
240 TRACE("msg=%s param=0x%x\n", ALSA_getCmdString(msg), param);
241 switch (msg) {
242 case WINE_WM_PAUSING:
243 wwi->state = WINE_WS_PAUSED;
244 /*FIXME("Device should stop recording\n");*/
245 SetEvent(ev);
246 break;
247 case WINE_WM_STARTING:
248 wwi->state = WINE_WS_PLAYING;
249 snd_pcm_start(wwi->pcm);
250 SetEvent(ev);
251 break;
252 case WINE_WM_HEADER:
253 lpWaveHdr = (LPWAVEHDR)param;
254 lpWaveHdr->lpNext = 0;
255
256 /* insert buffer at the end of queue */
257 {
258 LPWAVEHDR* wh;
259 for (wh = &(wwi->lpQueuePtr); *wh; wh = &((*wh)->lpNext));
260 *wh = lpWaveHdr;
261 }
262 break;
263 case WINE_WM_STOPPING:
264 if (wwi->state != WINE_WS_STOPPED)
265 {
266 snd_pcm_drain(wwi->pcm);
267
268 /* read any headers in queue */
269 widRecorder_ReadHeaders(wwi);
270
271 /* return current buffer to app */
272 lpWaveHdr = wwi->lpQueuePtr;
273 if (lpWaveHdr)
274 {
275 LPWAVEHDR lpNext = lpWaveHdr->lpNext;
276 TRACE("stop %p %p\n", lpWaveHdr, lpWaveHdr->lpNext);
277 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
278 lpWaveHdr->dwFlags |= WHDR_DONE;
279 wwi->lpQueuePtr = lpNext;
280 widNotifyClient(wwi, WIM_DATA, (DWORD)lpWaveHdr, 0);
281 }
282 }
283 wwi->state = WINE_WS_STOPPED;
284 SetEvent(ev);
285 break;
286 case WINE_WM_RESETTING:
287 if (wwi->state != WINE_WS_STOPPED)
288 {
289 snd_pcm_drain(wwi->pcm);
290 }
291 wwi->state = WINE_WS_STOPPED;
292 wwi->dwTotalRecorded = 0;
293
294 /* read any headers in queue */
295 widRecorder_ReadHeaders(wwi);
296
297 /* return all buffers to the app */
298 for (lpWaveHdr = wwi->lpQueuePtr; lpWaveHdr; lpWaveHdr = lpWaveHdr->lpNext) {
299 TRACE("reset %p %p\n", lpWaveHdr, lpWaveHdr->lpNext);
300 lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
301 lpWaveHdr->dwFlags |= WHDR_DONE;
302 wwi->lpQueuePtr = lpWaveHdr->lpNext;
303 widNotifyClient(wwi, WIM_DATA, (DWORD)lpWaveHdr, 0);
304 }
305
306 wwi->lpQueuePtr = NULL;
307 SetEvent(ev);
308 break;
309 case WINE_WM_CLOSING:
310 wwi->hThread = 0;
311 wwi->state = WINE_WS_CLOSED;
312 SetEvent(ev);
313 ExitThread(0);
314 /* shouldn't go here */
315 default:
316 FIXME("unknown message %d\n", msg);
317 break;
318 }
319 }
320 }
321 ExitThread(0);
322 /* just for not generating compilation warnings... should never be executed */
323 return 0;
324 }
325
326 /**************************************************************************
327 * widOpen [internal]
328 */
329 static DWORD widOpen(WORD wDevID, LPWAVEOPENDESC lpDesc, DWORD dwFlags)
330 {
331 WINE_WAVEDEV* wwi;
332 snd_pcm_hw_params_t * hw_params;
333 snd_pcm_sw_params_t * sw_params;
334 snd_pcm_access_t access;
335 snd_pcm_format_t format;
336 unsigned int rate;
337 unsigned int buffer_time = 500000;
338 unsigned int period_time = 10000;
339 snd_pcm_uframes_t buffer_size;
340 snd_pcm_uframes_t period_size;
341 int flags;
342 snd_pcm_t * pcm;
343 int err;
344 int dir;
345 DWORD ret;
346
347 /* JPW TODO - review this code */
348 TRACE("(%u, %p, %08X);\n", wDevID, lpDesc, dwFlags);
349 if (lpDesc == NULL) {
350 WARN("Invalid Parameter !\n");
351 return MMSYSERR_INVALPARAM;
352 }
353 if (wDevID >= ALSA_WidNumDevs) {
354 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
355 return MMSYSERR_BADDEVICEID;
356 }
357
358 /* only PCM format is supported so far... */
359 if (!ALSA_supportedFormat(lpDesc->lpFormat)) {
360 WARN("Bad format: tag=%04X nChannels=%d nSamplesPerSec=%d !\n",
361 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
362 lpDesc->lpFormat->nSamplesPerSec);
363 return WAVERR_BADFORMAT;
364 }
365
366 if (dwFlags & WAVE_FORMAT_QUERY) {
367 TRACE("Query format: tag=%04X nChannels=%d nSamplesPerSec=%d !\n",
368 lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
369 lpDesc->lpFormat->nSamplesPerSec);
370 return MMSYSERR_NOERROR;
371 }
372
373 wwi = &WInDev[wDevID];
374
375 if (wwi->pcm != NULL) {
376 WARN("already allocated\n");
377 return MMSYSERR_ALLOCATED;
378 }
379
380 wwi->pcm = 0;
381 flags = SND_PCM_NONBLOCK;
382
383 if ( (err=snd_pcm_open(&pcm, wwi->pcmname, SND_PCM_STREAM_CAPTURE, flags)) < 0 )
384 {
385 ERR("Error open: %s\n", snd_strerror(err));
386 return MMSYSERR_NOTENABLED;
387 }
388
389 wwi->wFlags = HIWORD(dwFlags & CALLBACK_TYPEMASK);
390
391 memcpy(&wwi->waveDesc, lpDesc, sizeof(WAVEOPENDESC));
392 ALSA_copyFormat(lpDesc->lpFormat, &wwi->format);
393
394 if (wwi->format.Format.wBitsPerSample == 0) {
395 WARN("Resetting zeroed wBitsPerSample\n");
396 wwi->format.Format.wBitsPerSample = 8 *
397 (wwi->format.Format.nAvgBytesPerSec /
398 wwi->format.Format.nSamplesPerSec) /
399 wwi->format.Format.nChannels;
400 }
401
402 hw_params = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, snd_pcm_hw_params_sizeof() );
403 sw_params = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, snd_pcm_sw_params_sizeof() );
404
405 snd_pcm_hw_params_any(pcm, hw_params);
406
407 #define EXIT_ON_ERROR(f,e,txt) do \
408 { \
409 int err; \
410 if ( (err = (f) ) < 0) \
411 { \
412 WARN(txt ": %s\n", snd_strerror(err)); \
413 ret = (e); \
414 goto error; \
415 } \
416 } while(0)
417
418 access = SND_PCM_ACCESS_MMAP_INTERLEAVED;
419 if ( ( err = snd_pcm_hw_params_set_access(pcm, hw_params, access ) ) < 0) {
420 WARN("mmap not available. switching to standard write.\n");
421 access = SND_PCM_ACCESS_RW_INTERLEAVED;
422 EXIT_ON_ERROR( snd_pcm_hw_params_set_access(pcm, hw_params, access ), MMSYSERR_INVALPARAM, "unable to set access for playback");
423 wwi->read = snd_pcm_readi;
424 }
425 else
426 wwi->read = snd_pcm_mmap_readi;
427
428 EXIT_ON_ERROR( snd_pcm_hw_params_set_channels(pcm, hw_params, wwi->format.Format.nChannels), WAVERR_BADFORMAT, "unable to set required channels");
429
430 if ((wwi->format.Format.wFormatTag == WAVE_FORMAT_PCM) ||
431 ((wwi->format.Format.wFormatTag == WAVE_FORMAT_EXTENSIBLE) &&
432 IsEqualGUID(&wwi->format.SubFormat, &KSDATAFORMAT_SUBTYPE_PCM))) {
433 format = (wwi->format.Format.wBitsPerSample == 8) ? SND_PCM_FORMAT_U8 :
434 (wwi->format.Format.wBitsPerSample == 16) ? SND_PCM_FORMAT_S16_LE :
435 (wwi->format.Format.wBitsPerSample == 24) ? SND_PCM_FORMAT_S24_3LE :
436 (wwi->format.Format.wBitsPerSample == 32) ? SND_PCM_FORMAT_S32_LE : -1;
437 } else if ((wwi->format.Format.wFormatTag == WAVE_FORMAT_EXTENSIBLE) &&
438 IsEqualGUID(&wwi->format.SubFormat, &KSDATAFORMAT_SUBTYPE_IEEE_FLOAT)){
439 format = (wwi->format.Format.wBitsPerSample == 32) ? SND_PCM_FORMAT_FLOAT_LE : -1;
440 } else if (wwi->format.Format.wFormatTag == WAVE_FORMAT_MULAW) {
441 FIXME("unimplemented format: WAVE_FORMAT_MULAW\n");
442 ret = WAVERR_BADFORMAT;
443 goto error;
444 } else if (wwi->format.Format.wFormatTag == WAVE_FORMAT_ALAW) {
445 FIXME("unimplemented format: WAVE_FORMAT_ALAW\n");
446 ret = WAVERR_BADFORMAT;
447 goto error;
448 } else if (wwi->format.Format.wFormatTag == WAVE_FORMAT_ADPCM) {
449 FIXME("unimplemented format: WAVE_FORMAT_ADPCM\n");
450 ret = WAVERR_BADFORMAT;
451 goto error;
452 } else {
453 ERR("invalid format: %0x04x\n", wwi->format.Format.wFormatTag);
454 ret = WAVERR_BADFORMAT;
455 goto error;
456 }
457
458 EXIT_ON_ERROR( snd_pcm_hw_params_set_format(pcm, hw_params, format), WAVERR_BADFORMAT, "unable to set required format");
459
460 rate = wwi->format.Format.nSamplesPerSec;
461 dir = 0;
462 err = snd_pcm_hw_params_set_rate_near(pcm, hw_params, &rate, &dir);
463 if (err < 0) {
464 WARN("Rate %d Hz not available for playback: %s\n", wwi->format.Format.nSamplesPerSec, snd_strerror(rate));
465 ret = WAVERR_BADFORMAT;
466 goto error;
467 }
468 if (!ALSA_NearMatch(rate, wwi->format.Format.nSamplesPerSec)) {
469 WARN("Rate doesn't match (requested %d Hz, got %d Hz)\n", wwi->format.Format.nSamplesPerSec, rate);
470 ret = WAVERR_BADFORMAT;
471 goto error;
472 }
473
474 dir=0;
475 EXIT_ON_ERROR( snd_pcm_hw_params_set_buffer_time_near(pcm, hw_params, &buffer_time, &dir), MMSYSERR_INVALPARAM, "unable to set buffer time");
476 dir=0;
477 EXIT_ON_ERROR( snd_pcm_hw_params_set_period_time_near(pcm, hw_params, &period_time, &dir), MMSYSERR_INVALPARAM, "unable to set period time");
478
479 EXIT_ON_ERROR( snd_pcm_hw_params(pcm, hw_params), MMSYSERR_INVALPARAM, "unable to set hw params for playback");
480
481 dir=0;
482 err = snd_pcm_hw_params_get_period_size(hw_params, &period_size, &dir);
483 err = snd_pcm_hw_params_get_buffer_size(hw_params, &buffer_size);
484
485 snd_pcm_sw_params_current(pcm, sw_params);
486 EXIT_ON_ERROR( snd_pcm_sw_params_set_start_threshold(pcm, sw_params, 1), MMSYSERR_ERROR, "unable to set start threshold");
487 EXIT_ON_ERROR( snd_pcm_sw_params_set_silence_size(pcm, sw_params, 0), MMSYSERR_ERROR, "unable to set silence size");
488 EXIT_ON_ERROR( snd_pcm_sw_params_set_avail_min(pcm, sw_params, period_size), MMSYSERR_ERROR, "unable to set avail min");
489 EXIT_ON_ERROR( snd_pcm_sw_params_set_xfer_align(pcm, sw_params, 1), MMSYSERR_ERROR, "unable to set xfer align");
490 EXIT_ON_ERROR( snd_pcm_sw_params_set_silence_threshold(pcm, sw_params, 0), MMSYSERR_ERROR, "unable to set silence threshold");
491 EXIT_ON_ERROR( snd_pcm_sw_params(pcm, sw_params), MMSYSERR_ERROR, "unable to set sw params for playback");
492 #undef EXIT_ON_ERROR
493
494 snd_pcm_prepare(pcm);
495
496 if (TRACE_ON(wave))
497 ALSA_TraceParameters(hw_params, sw_params, FALSE);
498
499 /* now, we can save all required data for later use... */
500 if ( wwi->hw_params )
501 snd_pcm_hw_params_free(wwi->hw_params);
502 snd_pcm_hw_params_malloc(&(wwi->hw_params));
503 snd_pcm_hw_params_copy(wwi->hw_params, hw_params);
504
505 wwi->dwBufferSize = snd_pcm_frames_to_bytes(pcm, buffer_size);
506 wwi->lpQueuePtr = wwi->lpPlayPtr = wwi->lpLoopPtr = NULL;
507 wwi->pcm = pcm;
508
509 ALSA_InitRingMessage(&wwi->msgRing);
510
511 wwi->dwPeriodSize = snd_pcm_frames_to_bytes(pcm, period_size);
512 TRACE("dwPeriodSize=%u\n", wwi->dwPeriodSize);
513 TRACE("wBitsPerSample=%u, nAvgBytesPerSec=%u, nSamplesPerSec=%u, nChannels=%u nBlockAlign=%u!\n",
514 wwi->format.Format.wBitsPerSample, wwi->format.Format.nAvgBytesPerSec,
515 wwi->format.Format.nSamplesPerSec, wwi->format.Format.nChannels,
516 wwi->format.Format.nBlockAlign);
517
518 wwi->hStartUpEvent = CreateEventW(NULL, FALSE, FALSE, NULL);
519 wwi->hThread = CreateThread(NULL, 0, widRecorder, (LPVOID)(DWORD)wDevID, 0, &(wwi->dwThreadID));
520 if (wwi->hThread)
521 SetThreadPriority(wwi->hThread, THREAD_PRIORITY_TIME_CRITICAL);
522 WaitForSingleObject(wwi->hStartUpEvent, INFINITE);
523 CloseHandle(wwi->hStartUpEvent);
524 wwi->hStartUpEvent = INVALID_HANDLE_VALUE;
525
526 HeapFree( GetProcessHeap(), 0, hw_params );
527 HeapFree( GetProcessHeap(), 0, sw_params );
528 return widNotifyClient(wwi, WIM_OPEN, 0L, 0L);
529
530 error:
531 snd_pcm_close(pcm);
532 HeapFree( GetProcessHeap(), 0, hw_params );
533 HeapFree( GetProcessHeap(), 0, sw_params );
534 return ret;
535 }
536
537
538 /**************************************************************************
539 * widClose [internal]
540 */
541 static DWORD widClose(WORD wDevID)
542 {
543 DWORD ret = MMSYSERR_NOERROR;
544 WINE_WAVEDEV* wwi;
545
546 TRACE("(%u);\n", wDevID);
547
548 if (wDevID >= ALSA_WidNumDevs) {
549 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
550 return MMSYSERR_BADDEVICEID;
551 }
552
553 if (WInDev[wDevID].pcm == NULL) {
554 WARN("Requested to close already closed device %d!\n", wDevID);
555 return MMSYSERR_BADDEVICEID;
556 }
557
558 wwi = &WInDev[wDevID];
559 if (wwi->lpQueuePtr) {
560 WARN("buffers still playing !\n");
561 ret = WAVERR_STILLPLAYING;
562 } else {
563 if (wwi->hThread != INVALID_HANDLE_VALUE) {
564 ALSA_AddRingMessage(&wwi->msgRing, WINE_WM_CLOSING, 0, TRUE);
565 }
566 ALSA_DestroyRingMessage(&wwi->msgRing);
567
568 snd_pcm_hw_params_free(wwi->hw_params);
569 wwi->hw_params = NULL;
570
571 snd_pcm_close(wwi->pcm);
572 wwi->pcm = NULL;
573
574 ret = widNotifyClient(wwi, WIM_CLOSE, 0L, 0L);
575 }
576
577 return ret;
578 }
579
580 /**************************************************************************
581 * widAddBuffer [internal]
582 *
583 */
584 static DWORD widAddBuffer(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
585 {
586 TRACE("(%u, %p, %08X);\n", wDevID, lpWaveHdr, dwSize);
587
588 /* first, do the sanity checks... */
589 if (wDevID >= ALSA_WidNumDevs) {
590 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
591 return MMSYSERR_BADDEVICEID;
592 }
593
594 if (WInDev[wDevID].pcm == NULL) {
595 WARN("Requested to add buffer to already closed device %d!\n", wDevID);
596 return MMSYSERR_BADDEVICEID;
597 }
598
599 if (lpWaveHdr->lpData == NULL || !(lpWaveHdr->dwFlags & WHDR_PREPARED))
600 return WAVERR_UNPREPARED;
601
602 if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
603 return WAVERR_STILLPLAYING;
604
605 lpWaveHdr->dwFlags &= ~WHDR_DONE;
606 lpWaveHdr->dwFlags |= WHDR_INQUEUE;
607 lpWaveHdr->dwBytesRecorded = 0;
608 lpWaveHdr->lpNext = 0;
609
610 ALSA_AddRingMessage(&WInDev[wDevID].msgRing, WINE_WM_HEADER, (DWORD)lpWaveHdr, FALSE);
611
612 return MMSYSERR_NOERROR;
613 }
614
615 /**************************************************************************
616 * widStart [internal]
617 *
618 */
619 static DWORD widStart(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
620 {
621 TRACE("(%u, %p, %08X);\n", wDevID, lpWaveHdr, dwSize);
622
623 /* first, do the sanity checks... */
624 if (wDevID >= ALSA_WidNumDevs) {
625 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
626 return MMSYSERR_BADDEVICEID;
627 }
628
629 if (WInDev[wDevID].pcm == NULL) {
630 WARN("Requested to start closed device %d!\n", wDevID);
631 return MMSYSERR_BADDEVICEID;
632 }
633
634 ALSA_AddRingMessage(&WInDev[wDevID].msgRing, WINE_WM_STARTING, 0, TRUE);
635
636 return MMSYSERR_NOERROR;
637 }
638
639 /**************************************************************************
640 * widStop [internal]
641 *
642 */
643 static DWORD widStop(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
644 {
645 TRACE("(%u, %p, %08X);\n", wDevID, lpWaveHdr, dwSize);
646
647 /* first, do the sanity checks... */
648 if (wDevID >= ALSA_WidNumDevs) {
649 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
650 return MMSYSERR_BADDEVICEID;
651 }
652
653 if (WInDev[wDevID].pcm == NULL) {
654 WARN("Requested to stop closed device %d!\n", wDevID);
655 return MMSYSERR_BADDEVICEID;
656 }
657
658 ALSA_AddRingMessage(&WInDev[wDevID].msgRing, WINE_WM_STOPPING, 0, TRUE);
659
660 return MMSYSERR_NOERROR;
661 }
662
663 /**************************************************************************
664 * widReset [internal]
665 */
666 static DWORD widReset(WORD wDevID)
667 {
668 TRACE("(%u);\n", wDevID);
669 if (wDevID >= ALSA_WidNumDevs) {
670 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
671 return MMSYSERR_BADDEVICEID;
672 }
673
674 if (WInDev[wDevID].pcm == NULL) {
675 WARN("Requested to reset closed device %d!\n", wDevID);
676 return MMSYSERR_BADDEVICEID;
677 }
678
679 ALSA_AddRingMessage(&WInDev[wDevID].msgRing, WINE_WM_RESETTING, 0, TRUE);
680 return MMSYSERR_NOERROR;
681 }
682
683 /**************************************************************************
684 * widGetPosition [internal]
685 */
686 static DWORD widGetPosition(WORD wDevID, LPMMTIME lpTime, DWORD uSize)
687 {
688 WINE_WAVEDEV* wwi;
689
690 TRACE("(%u, %p, %u);\n", wDevID, lpTime, uSize);
691
692 if (wDevID >= ALSA_WidNumDevs) {
693 TRACE("Requested device %d, but only %d are known!\n", wDevID, ALSA_WidNumDevs);
694 return MMSYSERR_BADDEVICEID;
695 }
696
697 if (WInDev[wDevID].state == WINE_WS_CLOSED) {
698 WARN("Requested position of closed device %d!\n", wDevID);
699 return MMSYSERR_BADDEVICEID;
700 }
701
702 if (lpTime == NULL) {
703 WARN("invalid parameter: lpTime = NULL\n");
704 return MMSYSERR_INVALPARAM;
705 }
706
707 wwi = &WInDev[wDevID];
708 return ALSA_bytes_to_mmtime(lpTime, wwi->dwTotalRecorded, &wwi->format);
709 }
710
711 /**************************************************************************
712 * widGetNumDevs [internal]
713 */
714 static DWORD widGetNumDevs(void)
715 {
716 return ALSA_WidNumDevs;
717 }
718
719 /**************************************************************************
720 * widDevInterfaceSize [internal]
721 */
722 static DWORD widDevInterfaceSize(UINT wDevID, LPDWORD dwParam1)
723 {
724 TRACE("(%u, %p)\n", wDevID, dwParam1);
725
726 *dwParam1 = MultiByteToWideChar(CP_ACP, 0, WInDev[wDevID].interface_name, -1,
727 NULL, 0 ) * sizeof(WCHAR);
728 return MMSYSERR_NOERROR;
729 }
730
731 /**************************************************************************
732 * widDevInterface [internal]
733 */
734 static DWORD widDevInterface(UINT wDevID, PWCHAR dwParam1, DWORD dwParam2)
735 {
736 if (dwParam2 >= MultiByteToWideChar(CP_ACP, 0, WInDev[wDevID].interface_name, -1,
737 NULL, 0 ) * sizeof(WCHAR))
738 {
739 MultiByteToWideChar(CP_ACP, 0, WInDev[wDevID].interface_name, -1,
740 dwParam1, dwParam2 / sizeof(WCHAR));
741 return MMSYSERR_NOERROR;
742 }
743 return MMSYSERR_INVALPARAM;
744 }
745
746 /**************************************************************************
747 * widMessage (WINEALSA.@)
748 */
749 DWORD WINAPI ALSA_widMessage(UINT wDevID, UINT wMsg, DWORD dwUser,
750 DWORD dwParam1, DWORD dwParam2)
751 {
752 TRACE("(%u, %s, %08X, %08X, %08X);\n",
753 wDevID, ALSA_getMessage(wMsg), dwUser, dwParam1, dwParam2);
754
755 switch (wMsg) {
756 case DRVM_INIT:
757 case DRVM_EXIT:
758 case DRVM_ENABLE:
759 case DRVM_DISABLE:
760 /* FIXME: Pretend this is supported */
761 return 0;
762 case WIDM_OPEN: return widOpen (wDevID, (LPWAVEOPENDESC)dwParam1, dwParam2);
763 case WIDM_CLOSE: return widClose (wDevID);
764 case WIDM_ADDBUFFER: return widAddBuffer (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
765 case WIDM_PREPARE: return MMSYSERR_NOTSUPPORTED;
766 case WIDM_UNPREPARE: return MMSYSERR_NOTSUPPORTED;
767 case WIDM_GETDEVCAPS: return widGetDevCaps (wDevID, (LPWAVEINCAPSW)dwParam1, dwParam2);
768 case WIDM_GETNUMDEVS: return widGetNumDevs ();
769 case WIDM_GETPOS: return widGetPosition (wDevID, (LPMMTIME)dwParam1, dwParam2);
770 case WIDM_RESET: return widReset (wDevID);
771 case WIDM_START: return widStart (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
772 case WIDM_STOP: return widStop (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
773 case DRV_QUERYDEVICEINTERFACESIZE: return widDevInterfaceSize (wDevID, (LPDWORD)dwParam1);
774 case DRV_QUERYDEVICEINTERFACE: return widDevInterface (wDevID, (PWCHAR)dwParam1, dwParam2);
775 case DRV_QUERYDSOUNDIFACE: return widDsCreate (wDevID, (PIDSCDRIVER*)dwParam1);
776 case DRV_QUERYDSOUNDDESC: return widDsDesc (wDevID, (PDSDRIVERDESC)dwParam1);
777 default:
778 FIXME("unknown message %d!\n", wMsg);
779 }
780 return MMSYSERR_NOTSUPPORTED;
781 }
782
783 #else /* HAVE_ALSA */
784
785 /**************************************************************************
786 * widMessage (WINEALSA.@)
787 */
788 DWORD WINAPI ALSA_widMessage(WORD wDevID, WORD wMsg, DWORD dwUser,
789 DWORD dwParam1, DWORD dwParam2)
790 {
791 FIXME("(%u, %04X, %08X, %08X, %08X):stub\n", wDevID, wMsg, dwUser, dwParam1, dwParam2);
792 return MMSYSERR_NOTENABLED;
793 }
794
795 #endif /* HAVE_ALSA */
DirectPlay implementation for GSoC