richedit: Avoid rewrapping all text for isolated format changes.
[wine] / dlls / winealsa.drv / alsa.c
1 /*
2  * Wine Driver for ALSA
3  *
4  * Copyright    2002 Eric Pouech
5  * Copyright    2007 Maarten Lankhorst
6  *
7  * This file has a few shared generic subroutines shared among the alsa
8  * implementation.
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 <stdarg.h>
28
29 #include "windef.h"
30 #include "winbase.h"
31 #include "wingdi.h"
32 #include "winuser.h"
33 #include "mmddk.h"
34
35 #include "ks.h"
36 #include "guiddef.h"
37 #include "ksmedia.h"
38
39 #include "alsa.h"
40
41 #ifdef HAVE_ALSA
42
43 #include "wine/library.h"
44 #include "wine/unicode.h"
45 #include "wine/debug.h"
46
47 WINE_DEFAULT_DEBUG_CHANNEL(alsa);
48 /* unless someone makes a wineserver kernel module, Unix pipes are faster than win32 events */
49 #define USE_PIPE_SYNC
50
51 #ifdef USE_PIPE_SYNC
52 #define INIT_OMR(omr) do { if (pipe(omr->msg_pipe) < 0) { omr->msg_pipe[0] = omr->msg_pipe[1] = -1; } } while (0)
53 #define CLOSE_OMR(omr) do { close(omr->msg_pipe[0]); close(omr->msg_pipe[1]); } while (0)
54 #define SIGNAL_OMR(omr) do { int x = 0; write((omr)->msg_pipe[1], &x, sizeof(x)); } while (0)
55 #define CLEAR_OMR(omr) do { int x = 0; read((omr)->msg_pipe[0], &x, sizeof(x)); } while (0)
56 #define RESET_OMR(omr) do { } while (0)
57 #define WAIT_OMR(omr, sleep) \
58   do { struct pollfd pfd; pfd.fd = (omr)->msg_pipe[0]; \
59        pfd.events = POLLIN; poll(&pfd, 1, sleep); } while (0)
60 #else
61 #define INIT_OMR(omr) do { omr->msg_event = CreateEventW(NULL, FALSE, FALSE, NULL); } while (0)
62 #define CLOSE_OMR(omr) do { CloseHandle(omr->msg_event); } while (0)
63 #define SIGNAL_OMR(omr) do { SetEvent((omr)->msg_event); } while (0)
64 #define CLEAR_OMR(omr) do { } while (0)
65 #define RESET_OMR(omr) do { ResetEvent((omr)->msg_event); } while (0)
66 #define WAIT_OMR(omr, sleep) \
67   do { WaitForSingleObject((omr)->msg_event, sleep); } while (0)
68 #endif
69
70 #define ALSA_RING_BUFFER_INCREMENT      64
71
72 /******************************************************************
73  *              ALSA_InitRingMessage
74  *
75  * Initialize the ring of messages for passing between driver's caller and playback/record
76  * thread
77  */
78 int ALSA_InitRingMessage(ALSA_MSG_RING* omr)
79 {
80     omr->msg_toget = 0;
81     omr->msg_tosave = 0;
82     INIT_OMR(omr);
83     omr->ring_buffer_size = ALSA_RING_BUFFER_INCREMENT;
84     omr->messages = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,omr->ring_buffer_size * sizeof(ALSA_MSG));
85
86     InitializeCriticalSection(&omr->msg_crst);
87     omr->msg_crst.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": ALSA_MSG_RING.msg_crst");
88     return 0;
89 }
90
91 /******************************************************************
92  *              ALSA_DestroyRingMessage
93  *
94  */
95 int ALSA_DestroyRingMessage(ALSA_MSG_RING* omr)
96 {
97     CLOSE_OMR(omr);
98     HeapFree(GetProcessHeap(),0,omr->messages);
99     omr->ring_buffer_size = 0;
100     omr->msg_crst.DebugInfo->Spare[0] = 0;
101     DeleteCriticalSection(&omr->msg_crst);
102     return 0;
103 }
104 /******************************************************************
105  *              ALSA_ResetRingMessage
106  *
107  */
108 void ALSA_ResetRingMessage(ALSA_MSG_RING* omr)
109 {
110     RESET_OMR(omr);
111 }
112
113 /******************************************************************
114  *              ALSA_WaitRingMessage
115  *
116  */
117 void ALSA_WaitRingMessage(ALSA_MSG_RING* omr, DWORD sleep)
118 {
119     WAIT_OMR(omr, sleep);
120 }
121
122 /******************************************************************
123  *              ALSA_AddRingMessage
124  *
125  * Inserts a new message into the ring (should be called from DriverProc derived routines)
126  */
127 int ALSA_AddRingMessage(ALSA_MSG_RING* omr, enum win_wm_message msg, DWORD_PTR param, BOOL wait)
128 {
129     HANDLE      hEvent = INVALID_HANDLE_VALUE;
130
131     EnterCriticalSection(&omr->msg_crst);
132     if ((omr->msg_toget == ((omr->msg_tosave + 1) % omr->ring_buffer_size)))
133     {
134         int old_ring_buffer_size = omr->ring_buffer_size;
135         omr->ring_buffer_size += ALSA_RING_BUFFER_INCREMENT;
136         omr->messages = HeapReAlloc(GetProcessHeap(),0,omr->messages, omr->ring_buffer_size * sizeof(ALSA_MSG));
137         /* Now we need to rearrange the ring buffer so that the new
138            buffers just allocated are in between omr->msg_tosave and
139            omr->msg_toget.
140         */
141         if (omr->msg_tosave < omr->msg_toget)
142         {
143             memmove(&(omr->messages[omr->msg_toget + ALSA_RING_BUFFER_INCREMENT]),
144                     &(omr->messages[omr->msg_toget]),
145                     sizeof(ALSA_MSG)*(old_ring_buffer_size - omr->msg_toget)
146                     );
147             omr->msg_toget += ALSA_RING_BUFFER_INCREMENT;
148         }
149     }
150     if (wait)
151     {
152         hEvent = CreateEventW(NULL, FALSE, FALSE, NULL);
153         if (hEvent == INVALID_HANDLE_VALUE)
154         {
155             ERR("can't create event !?\n");
156             LeaveCriticalSection(&omr->msg_crst);
157             return 0;
158         }
159         if (omr->msg_toget != omr->msg_tosave && omr->messages[omr->msg_toget].msg != WINE_WM_HEADER)
160             FIXME("two fast messages in the queue!!!! toget = %d(%s), tosave=%d(%s)\n",
161                   omr->msg_toget,ALSA_getCmdString(omr->messages[omr->msg_toget].msg),
162                   omr->msg_tosave,ALSA_getCmdString(omr->messages[omr->msg_tosave].msg));
163
164         /* fast messages have to be added at the start of the queue */
165         omr->msg_toget = (omr->msg_toget + omr->ring_buffer_size - 1) % omr->ring_buffer_size;
166
167         omr->messages[omr->msg_toget].msg = msg;
168         omr->messages[omr->msg_toget].param = param;
169         omr->messages[omr->msg_toget].hEvent = hEvent;
170     }
171     else
172     {
173         omr->messages[omr->msg_tosave].msg = msg;
174         omr->messages[omr->msg_tosave].param = param;
175         omr->messages[omr->msg_tosave].hEvent = INVALID_HANDLE_VALUE;
176         omr->msg_tosave = (omr->msg_tosave + 1) % omr->ring_buffer_size;
177     }
178     LeaveCriticalSection(&omr->msg_crst);
179     /* signal a new message */
180     SIGNAL_OMR(omr);
181     if (wait)
182     {
183         /* wait for playback/record thread to have processed the message */
184         WaitForSingleObject(hEvent, INFINITE);
185         CloseHandle(hEvent);
186     }
187     return 1;
188 }
189
190 /******************************************************************
191  *              ALSA_RetrieveRingMessage
192  *
193  * Get a message from the ring. Should be called by the playback/record thread.
194  */
195 int ALSA_RetrieveRingMessage(ALSA_MSG_RING* omr, enum win_wm_message *msg,
196                              DWORD_PTR *param, HANDLE *hEvent)
197 {
198     EnterCriticalSection(&omr->msg_crst);
199
200     if (omr->msg_toget == omr->msg_tosave) /* buffer empty ? */
201     {
202         LeaveCriticalSection(&omr->msg_crst);
203         return 0;
204     }
205
206     *msg = omr->messages[omr->msg_toget].msg;
207     omr->messages[omr->msg_toget].msg = 0;
208     *param = omr->messages[omr->msg_toget].param;
209     *hEvent = omr->messages[omr->msg_toget].hEvent;
210     omr->msg_toget = (omr->msg_toget + 1) % omr->ring_buffer_size;
211     CLEAR_OMR(omr);
212     LeaveCriticalSection(&omr->msg_crst);
213     return 1;
214 }
215
216 /******************************************************************
217  *              ALSA_PeekRingMessage
218  *
219  * Peek at a message from the ring but do not remove it.
220  * Should be called by the playback/record thread.
221  */
222 int ALSA_PeekRingMessage(ALSA_MSG_RING* omr,
223                          enum win_wm_message *msg,
224                          DWORD_PTR *param, HANDLE *hEvent)
225 {
226     EnterCriticalSection(&omr->msg_crst);
227
228     if (omr->msg_toget == omr->msg_tosave) /* buffer empty ? */
229     {
230         LeaveCriticalSection(&omr->msg_crst);
231         return 0;
232     }
233
234     *msg = omr->messages[omr->msg_toget].msg;
235     *param = omr->messages[omr->msg_toget].param;
236     *hEvent = omr->messages[omr->msg_toget].hEvent;
237     LeaveCriticalSection(&omr->msg_crst);
238     return 1;
239 }
240
241 /*======================================================================*
242  *                  Utility functions                                   *
243  *======================================================================*/
244
245 /* These strings used only for tracing */
246 const char * ALSA_getCmdString(enum win_wm_message msg)
247 {
248     static char unknown[32];
249 #define MSG_TO_STR(x) case x: return #x
250     switch(msg) {
251     MSG_TO_STR(WINE_WM_PAUSING);
252     MSG_TO_STR(WINE_WM_RESTARTING);
253     MSG_TO_STR(WINE_WM_RESETTING);
254     MSG_TO_STR(WINE_WM_HEADER);
255     MSG_TO_STR(WINE_WM_UPDATE);
256     MSG_TO_STR(WINE_WM_BREAKLOOP);
257     MSG_TO_STR(WINE_WM_CLOSING);
258     MSG_TO_STR(WINE_WM_STARTING);
259     MSG_TO_STR(WINE_WM_STOPPING);
260     }
261 #undef MSG_TO_STR
262     sprintf(unknown, "UNKNOWN(0x%08x)", msg);
263     return unknown;
264 }
265
266 const char * ALSA_getMessage(UINT msg)
267 {
268     static char unknown[32];
269 #define MSG_TO_STR(x) case x: return #x
270     switch(msg) {
271     MSG_TO_STR(DRVM_INIT);
272     MSG_TO_STR(DRVM_EXIT);
273     MSG_TO_STR(DRVM_ENABLE);
274     MSG_TO_STR(DRVM_DISABLE);
275     MSG_TO_STR(WIDM_OPEN);
276     MSG_TO_STR(WIDM_CLOSE);
277     MSG_TO_STR(WIDM_ADDBUFFER);
278     MSG_TO_STR(WIDM_PREPARE);
279     MSG_TO_STR(WIDM_UNPREPARE);
280     MSG_TO_STR(WIDM_GETDEVCAPS);
281     MSG_TO_STR(WIDM_GETNUMDEVS);
282     MSG_TO_STR(WIDM_GETPOS);
283     MSG_TO_STR(WIDM_RESET);
284     MSG_TO_STR(WIDM_START);
285     MSG_TO_STR(WIDM_STOP);
286     MSG_TO_STR(WODM_OPEN);
287     MSG_TO_STR(WODM_CLOSE);
288     MSG_TO_STR(WODM_WRITE);
289     MSG_TO_STR(WODM_PAUSE);
290     MSG_TO_STR(WODM_GETPOS);
291     MSG_TO_STR(WODM_BREAKLOOP);
292     MSG_TO_STR(WODM_PREPARE);
293     MSG_TO_STR(WODM_UNPREPARE);
294     MSG_TO_STR(WODM_GETDEVCAPS);
295     MSG_TO_STR(WODM_GETNUMDEVS);
296     MSG_TO_STR(WODM_GETPITCH);
297     MSG_TO_STR(WODM_SETPITCH);
298     MSG_TO_STR(WODM_GETPLAYBACKRATE);
299     MSG_TO_STR(WODM_SETPLAYBACKRATE);
300     MSG_TO_STR(WODM_GETVOLUME);
301     MSG_TO_STR(WODM_SETVOLUME);
302     MSG_TO_STR(WODM_RESTART);
303     MSG_TO_STR(WODM_RESET);
304     MSG_TO_STR(DRV_QUERYDEVICEINTERFACESIZE);
305     MSG_TO_STR(DRV_QUERYDEVICEINTERFACE);
306     MSG_TO_STR(DRV_QUERYDSOUNDIFACE);
307     MSG_TO_STR(DRV_QUERYDSOUNDDESC);
308     }
309 #undef MSG_TO_STR
310     sprintf(unknown, "UNKNOWN(0x%04x)", msg);
311     return unknown;
312 }
313
314 const char * ALSA_getFormat(WORD wFormatTag)
315 {
316     static char unknown[32];
317 #define FMT_TO_STR(x) case x: return #x
318     switch(wFormatTag) {
319     FMT_TO_STR(WAVE_FORMAT_PCM);
320     FMT_TO_STR(WAVE_FORMAT_EXTENSIBLE);
321     FMT_TO_STR(WAVE_FORMAT_MULAW);
322     FMT_TO_STR(WAVE_FORMAT_ALAW);
323     FMT_TO_STR(WAVE_FORMAT_ADPCM);
324     }
325 #undef FMT_TO_STR
326     sprintf(unknown, "UNKNOWN(0x%04x)", wFormatTag);
327     return unknown;
328 }
329
330 /* Allow 1% deviation for sample rates (some ES137x cards) */
331 BOOL ALSA_NearMatch(int rate1, int rate2)
332 {
333     return (((100 * (rate1 - rate2)) / rate1) == 0);
334 }
335
336 DWORD ALSA_bytes_to_mmtime(LPMMTIME lpTime, DWORD position, WAVEFORMATPCMEX* format)
337 {
338     TRACE("wType=%04X wBitsPerSample=%u nSamplesPerSec=%u nChannels=%u nAvgBytesPerSec=%u\n",
339           lpTime->wType, format->Format.wBitsPerSample, format->Format.nSamplesPerSec,
340           format->Format.nChannels, format->Format.nAvgBytesPerSec);
341     TRACE("Position in bytes=%u\n", position);
342
343     switch (lpTime->wType) {
344     case TIME_SAMPLES:
345         lpTime->u.sample = position / (format->Format.wBitsPerSample / 8 * format->Format.nChannels);
346         TRACE("TIME_SAMPLES=%u\n", lpTime->u.sample);
347         break;
348     case TIME_MS:
349         lpTime->u.ms = 1000.0 * position / (format->Format.wBitsPerSample / 8 * format->Format.nChannels * format->Format.nSamplesPerSec);
350         TRACE("TIME_MS=%u\n", lpTime->u.ms);
351         break;
352     case TIME_SMPTE:
353         lpTime->u.smpte.fps = 30;
354         position = position / (format->Format.wBitsPerSample / 8 * format->Format.nChannels);
355         position += (format->Format.nSamplesPerSec / lpTime->u.smpte.fps) - 1; /* round up */
356         lpTime->u.smpte.sec = position / format->Format.nSamplesPerSec;
357         position -= lpTime->u.smpte.sec * format->Format.nSamplesPerSec;
358         lpTime->u.smpte.min = lpTime->u.smpte.sec / 60;
359         lpTime->u.smpte.sec -= 60 * lpTime->u.smpte.min;
360         lpTime->u.smpte.hour = lpTime->u.smpte.min / 60;
361         lpTime->u.smpte.min -= 60 * lpTime->u.smpte.hour;
362         lpTime->u.smpte.fps = 30;
363         lpTime->u.smpte.frame = position * lpTime->u.smpte.fps / format->Format.nSamplesPerSec;
364         TRACE("TIME_SMPTE=%02u:%02u:%02u:%02u\n",
365               lpTime->u.smpte.hour, lpTime->u.smpte.min,
366               lpTime->u.smpte.sec, lpTime->u.smpte.frame);
367         break;
368     default:
369         WARN("Format %d not supported, using TIME_BYTES !\n", lpTime->wType);
370         lpTime->wType = TIME_BYTES;
371         /* fall through */
372     case TIME_BYTES:
373         lpTime->u.cb = position;
374         TRACE("TIME_BYTES=%u\n", lpTime->u.cb);
375         break;
376     }
377     return MMSYSERR_NOERROR;
378 }
379
380 void ALSA_copyFormat(LPWAVEFORMATEX wf1, LPWAVEFORMATPCMEX wf2)
381 {
382     unsigned int iLength;
383
384     ZeroMemory(wf2, sizeof(wf2));
385     if (wf1->wFormatTag == WAVE_FORMAT_PCM)
386         iLength = sizeof(PCMWAVEFORMAT);
387     else if (wf1->wFormatTag == WAVE_FORMAT_EXTENSIBLE)
388         iLength = sizeof(WAVEFORMATPCMEX);
389     else
390         iLength = sizeof(WAVEFORMATEX) + wf1->cbSize;
391     if (iLength > sizeof(WAVEFORMATPCMEX)) {
392         ERR("calculated %u bytes, capping\n", iLength);
393         iLength = sizeof(WAVEFORMATPCMEX);
394     }
395     memcpy(wf2, wf1, iLength);
396 }
397
398 BOOL ALSA_supportedFormat(LPWAVEFORMATEX wf)
399 {
400     TRACE("(%p)\n",wf);
401
402     if (wf->nSamplesPerSec<DSBFREQUENCY_MIN||wf->nSamplesPerSec>DSBFREQUENCY_MAX)
403         return FALSE;
404
405     if (wf->wFormatTag == WAVE_FORMAT_PCM) {
406         if (wf->nChannels==1||wf->nChannels==2) {
407             if (wf->wBitsPerSample==8||wf->wBitsPerSample==16)
408                 return TRUE;
409         }
410     } else if (wf->wFormatTag == WAVE_FORMAT_EXTENSIBLE) {
411         WAVEFORMATEXTENSIBLE    * wfex = (WAVEFORMATEXTENSIBLE *)wf;
412
413         if (wf->cbSize == 22 &&
414             (IsEqualGUID(&wfex->SubFormat, &KSDATAFORMAT_SUBTYPE_PCM) ||
415              IsEqualGUID(&wfex->SubFormat, &KSDATAFORMAT_SUBTYPE_IEEE_FLOAT))) {
416             if (wf->nChannels>=1 && wf->nChannels<=6) {
417                 if (wf->wBitsPerSample==wfex->Samples.wValidBitsPerSample) {
418                     if (wf->wBitsPerSample==8||wf->wBitsPerSample==16||
419                         wf->wBitsPerSample==24||wf->wBitsPerSample==32) {
420                         return TRUE;
421                     }
422                 } else
423                     WARN("wBitsPerSample != wValidBitsPerSample not supported yet\n");
424             }
425         } else
426             WARN("only KSDATAFORMAT_SUBTYPE_PCM and KSDATAFORMAT_SUBTYPE_IEEE_FLOAT "
427                  "supported\n");
428     } else if (wf->wFormatTag == WAVE_FORMAT_MULAW || wf->wFormatTag == WAVE_FORMAT_ALAW) {
429         if (wf->wBitsPerSample==8)
430             return TRUE;
431         else
432             ERR("WAVE_FORMAT_MULAW and WAVE_FORMAT_ALAW wBitsPerSample must = 8\n");
433
434     } else if (wf->wFormatTag == WAVE_FORMAT_ADPCM) {
435         if (wf->wBitsPerSample==4)
436             return TRUE;
437         else
438             ERR("WAVE_FORMAT_ADPCM wBitsPerSample must = 4\n");
439     } else
440         WARN("only WAVE_FORMAT_PCM and WAVE_FORMAT_EXTENSIBLE supported\n");
441
442     return FALSE;
443 }
444
445 /*======================================================================*
446  *                  Low level WAVE implementation                       *
447  *======================================================================*/
448
449 /**************************************************************************
450  *                      ALSA_CheckSetVolume             [internal]
451  *
452  *  Helper function for Alsa volume queries.  This tries to simplify
453  * the process of managing the volume.  All parameters are optional
454  * (pass NULL to ignore or not use).
455  *  Return values are MMSYSERR_NOERROR on success, or !0 on failure;
456  * error codes are normalized into the possible documented return
457  * values from waveOutGetVolume.
458  */
459 int ALSA_CheckSetVolume(snd_hctl_t *hctl, int *out_left, int *out_right,
460             int *out_min, int *out_max, int *out_step,
461             int *new_left, int *new_right)
462 {
463     int rc = MMSYSERR_NOERROR;
464     int value_count = 0;
465     snd_hctl_elem_t *           elem = NULL;
466     snd_ctl_elem_info_t *       eleminfop = NULL;
467     snd_ctl_elem_value_t *      elemvaluep = NULL;
468     snd_ctl_elem_id_t *         elemidp = NULL;
469
470
471 #define EXIT_ON_ERROR(f,txt,exitcode) do \
472 { \
473     int err; \
474     if ( (err = (f) ) < 0) \
475     { \
476         ERR(txt " failed: %s\n", snd_strerror(err)); \
477         rc = exitcode; \
478         goto out; \
479     } \
480 } while(0)
481
482     if (! hctl)
483         return MMSYSERR_NOTSUPPORTED;
484
485     /* Allocate areas to return information about the volume */
486     EXIT_ON_ERROR(snd_ctl_elem_id_malloc(&elemidp), "snd_ctl_elem_id_malloc", MMSYSERR_NOMEM);
487     EXIT_ON_ERROR(snd_ctl_elem_value_malloc (&elemvaluep), "snd_ctl_elem_value_malloc", MMSYSERR_NOMEM);
488     EXIT_ON_ERROR(snd_ctl_elem_info_malloc (&eleminfop), "snd_ctl_elem_info_malloc", MMSYSERR_NOMEM);
489     snd_ctl_elem_id_clear(elemidp);
490     snd_ctl_elem_value_clear(elemvaluep);
491     snd_ctl_elem_info_clear(eleminfop);
492
493     /* Setup and find an element id that exactly matches the characteristic we want
494     ** FIXME:  It is probably short sighted to hard code and fixate on PCM Playback Volume */
495     snd_ctl_elem_id_set_name(elemidp, "PCM Playback Volume");
496     snd_ctl_elem_id_set_interface(elemidp, SND_CTL_ELEM_IFACE_MIXER);
497     elem = snd_hctl_find_elem(hctl, elemidp);
498     if (elem)
499     {
500         /* Read and return volume information */
501         EXIT_ON_ERROR(snd_hctl_elem_info(elem, eleminfop), "snd_hctl_elem_info", MMSYSERR_NOTSUPPORTED);
502         value_count = snd_ctl_elem_info_get_count(eleminfop);
503         if (out_min || out_max || out_step)
504         {
505             if (!snd_ctl_elem_info_is_readable(eleminfop))
506             {
507                 ERR("snd_ctl_elem_info_is_readable returned false; cannot return info\n");
508                 rc = MMSYSERR_NOTSUPPORTED;
509                 goto out;
510             }
511
512             if (out_min)
513                 *out_min = snd_ctl_elem_info_get_min(eleminfop);
514
515             if (out_max)
516                 *out_max = snd_ctl_elem_info_get_max(eleminfop);
517
518             if (out_step)
519                 *out_step = snd_ctl_elem_info_get_step(eleminfop);
520         }
521
522         if (out_left || out_right)
523         {
524             EXIT_ON_ERROR(snd_hctl_elem_read(elem, elemvaluep), "snd_hctl_elem_read", MMSYSERR_NOTSUPPORTED);
525
526             if (out_left)
527                 *out_left = snd_ctl_elem_value_get_integer(elemvaluep, 0);
528
529             if (out_right)
530             {
531                 if (value_count == 1)
532                     *out_right = snd_ctl_elem_value_get_integer(elemvaluep, 0);
533                 else if (value_count == 2)
534                     *out_right = snd_ctl_elem_value_get_integer(elemvaluep, 1);
535                 else
536                 {
537                     ERR("Unexpected value count %d from snd_ctl_elem_info_get_count while getting volume info\n", value_count);
538                     rc = -1;
539                     goto out;
540                 }
541             }
542         }
543
544         /* Set the volume */
545         if (new_left || new_right)
546         {
547             EXIT_ON_ERROR(snd_hctl_elem_read(elem, elemvaluep), "snd_hctl_elem_read", MMSYSERR_NOTSUPPORTED);
548             if (new_left)
549                 snd_ctl_elem_value_set_integer(elemvaluep, 0, *new_left);
550             if (new_right)
551             {
552                 if (value_count == 1)
553                     snd_ctl_elem_value_set_integer(elemvaluep, 0, *new_right);
554                 else if (value_count == 2)
555                     snd_ctl_elem_value_set_integer(elemvaluep, 1, *new_right);
556                 else
557                 {
558                     ERR("Unexpected value count %d from snd_ctl_elem_info_get_count while setting volume info\n", value_count);
559                     rc = -1;
560                     goto out;
561                 }
562             }
563
564             EXIT_ON_ERROR(snd_hctl_elem_write(elem, elemvaluep), "snd_hctl_elem_write", MMSYSERR_NOTSUPPORTED);
565         }
566     }
567     else
568     {
569         ERR("Could not find 'PCM Playback Volume' element\n");
570         rc = MMSYSERR_NOTSUPPORTED;
571     }
572
573
574 #undef EXIT_ON_ERROR
575
576 out:
577
578     if (elemvaluep)
579         snd_ctl_elem_value_free(elemvaluep);
580     if (eleminfop)
581         snd_ctl_elem_info_free(eleminfop);
582     if (elemidp)
583         snd_ctl_elem_id_free(elemidp);
584
585     return rc;
586 }
587
588
589 /**************************************************************************
590  *                      ALSA_XRUNRecovery               [internal]
591  *
592  * used to recovery from XRUN errors (buffer underflow/overflow)
593  */
594 int ALSA_XRUNRecovery(WINE_WAVEDEV * wwo, int err)
595 {
596     if (err == -EPIPE) {    /* under-run */
597         err = snd_pcm_prepare(wwo->pcm);
598         if (err < 0)
599              ERR( "underrun recovery failed. prepare failed: %s\n", snd_strerror(err));
600         return 0;
601     } else if (err == -ESTRPIPE) {
602         while ((err = snd_pcm_resume(wwo->pcm)) == -EAGAIN)
603             sleep(1);       /* wait until the suspend flag is released */
604         if (err < 0) {
605             err = snd_pcm_prepare(wwo->pcm);
606             if (err < 0)
607                 ERR("recovery from suspend failed, prepare failed: %s\n", snd_strerror(err));
608         }
609         return 0;
610     }
611     return err;
612 }
613
614 /**************************************************************************
615  *                      ALSA_TraceParameters            [internal]
616  *
617  * used to trace format changes, hw and sw parameters
618  */
619 void ALSA_TraceParameters(snd_pcm_hw_params_t * hw_params, snd_pcm_sw_params_t * sw, int full)
620 {
621     int err;
622     snd_pcm_format_t   format;
623     snd_pcm_access_t   access;
624
625 #define X(x) ((x)? "true" : "false")
626     if (full)
627         TRACE("FLAGS: sampleres=%s overrng=%s pause=%s resume=%s syncstart=%s batch=%s block=%s double=%s "
628               "halfd=%s joint=%s\n",
629               X(snd_pcm_hw_params_can_mmap_sample_resolution(hw_params)),
630               X(snd_pcm_hw_params_can_overrange(hw_params)),
631               X(snd_pcm_hw_params_can_pause(hw_params)),
632               X(snd_pcm_hw_params_can_resume(hw_params)),
633               X(snd_pcm_hw_params_can_sync_start(hw_params)),
634               X(snd_pcm_hw_params_is_batch(hw_params)),
635               X(snd_pcm_hw_params_is_block_transfer(hw_params)),
636               X(snd_pcm_hw_params_is_double(hw_params)),
637               X(snd_pcm_hw_params_is_half_duplex(hw_params)),
638               X(snd_pcm_hw_params_is_joint_duplex(hw_params)));
639 #undef X
640
641     err = snd_pcm_hw_params_get_access(hw_params, &access);
642     if (err >= 0)
643     {
644         TRACE("access=%s\n", snd_pcm_access_name(access));
645     }
646     else
647     {
648         snd_pcm_access_mask_t * acmask;
649
650         acmask = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, snd_pcm_access_mask_sizeof());
651         snd_pcm_hw_params_get_access_mask(hw_params, acmask);
652         for ( access = SND_PCM_ACCESS_MMAP_INTERLEAVED; access <= SND_PCM_ACCESS_LAST; access++)
653             if (snd_pcm_access_mask_test(acmask, access))
654                 TRACE("access=%s\n", snd_pcm_access_name(access));
655         HeapFree( GetProcessHeap(), 0, acmask );
656     }
657
658     err = snd_pcm_hw_params_get_format(hw_params, &format);
659     if (err >= 0)
660     {
661         TRACE("format=%s\n", snd_pcm_format_name(format));
662
663     }
664     else
665     {
666         snd_pcm_format_mask_t *     fmask;
667
668         fmask = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, snd_pcm_format_mask_sizeof());
669         snd_pcm_hw_params_get_format_mask(hw_params, fmask);
670         for ( format = SND_PCM_FORMAT_S8; format <= SND_PCM_FORMAT_LAST ; format++)
671             if ( snd_pcm_format_mask_test(fmask, format) )
672                 TRACE("format=%s\n", snd_pcm_format_name(format));
673         HeapFree( GetProcessHeap(), 0, fmask );
674     }
675
676     do {
677       int err=0;
678       unsigned int val=0;
679       err = snd_pcm_hw_params_get_channels(hw_params, &val);
680       if (err<0) {
681         unsigned int min = 0;
682         unsigned int max = 0;
683         err = snd_pcm_hw_params_get_channels_min(hw_params, &min),
684         err = snd_pcm_hw_params_get_channels_max(hw_params, &max);
685         TRACE("channels_min=%u, channels_min_max=%u\n", min, max);
686       } else {
687         TRACE("channels=%d\n", val);
688       }
689     } while(0);
690     do {
691       int err=0;
692       snd_pcm_uframes_t val=0;
693       err = snd_pcm_hw_params_get_buffer_size(hw_params, &val);
694       if (err<0) {
695         snd_pcm_uframes_t min = 0;
696         snd_pcm_uframes_t max = 0;
697         err = snd_pcm_hw_params_get_buffer_size_min(hw_params, &min),
698         err = snd_pcm_hw_params_get_buffer_size_max(hw_params, &max);
699         TRACE("buffer_size_min=%lu, buffer_size_min_max=%lu\n", min, max);
700       } else {
701         TRACE("buffer_size=%lu\n", val);
702       }
703     } while(0);
704
705 #define X(x) do { \
706 int err=0; \
707 int dir=0; \
708 unsigned int val=0; \
709 err = snd_pcm_hw_params_get_##x(hw_params,&val, &dir); \
710 if (err<0) { \
711   unsigned int min = 0; \
712   unsigned int max = 0; \
713   err = snd_pcm_hw_params_get_##x##_min(hw_params, &min, &dir); \
714   err = snd_pcm_hw_params_get_##x##_max(hw_params, &max, &dir); \
715   TRACE(#x "_min=%u " #x "_max=%u\n", min, max); \
716 } else \
717     TRACE(#x "=%d\n", val); \
718 } while(0)
719
720     X(rate);
721     X(buffer_time);
722     X(periods);
723     do {
724       int err=0;
725       int dir=0;
726       snd_pcm_uframes_t val=0;
727       err = snd_pcm_hw_params_get_period_size(hw_params, &val, &dir);
728       if (err<0) {
729         snd_pcm_uframes_t min = 0;
730         snd_pcm_uframes_t max = 0;
731         err = snd_pcm_hw_params_get_period_size_min(hw_params, &min, &dir),
732         err = snd_pcm_hw_params_get_period_size_max(hw_params, &max, &dir);
733         TRACE("period_size_min=%lu, period_size_min_max=%lu\n", min, max);
734       } else {
735         TRACE("period_size=%lu\n", val);
736       }
737     } while(0);
738
739     X(period_time);
740 #undef X
741
742     if (!sw)
743         return;
744 }
745
746 #endif
747
748 /**************************************************************************
749  *                              DriverProc (WINEALSA.@)
750  */
751 LRESULT CALLBACK ALSA_DriverProc(DWORD_PTR dwDevID, HDRVR hDriv, UINT wMsg,
752                                  LPARAM dwParam1, LPARAM dwParam2)
753 {
754 /* EPP     TRACE("(%08lX, %04X, %08lX, %08lX, %08lX)\n",  */
755 /* EPP    dwDevID, hDriv, wMsg, dwParam1, dwParam2); */
756
757     switch(wMsg) {
758 #ifdef HAVE_ALSA
759     case DRV_LOAD:              ALSA_WaveInit();
760                                 ALSA_MidiInit();
761                                 return 1;
762     case DRV_FREE:              return 1;
763     case DRV_OPEN:              return 1;
764     case DRV_CLOSE:             return 1;
765     case DRV_ENABLE:            return 1;
766     case DRV_DISABLE:           return 1;
767     case DRV_QUERYCONFIGURE:    return 1;
768     case DRV_CONFIGURE:         MessageBoxA(0, "ALSA MultiMedia Driver !", "ALSA Driver", MB_OK);       return 1;
769     case DRV_INSTALL:           return DRVCNF_RESTART;
770     case DRV_REMOVE:            return DRVCNF_RESTART;
771 #endif
772     default:
773         return DefDriverProc(dwDevID, hDriv, wMsg, dwParam1, dwParam2);
774     }
775 }