Removed a few dependencies on kernel32 functions.
[wine] / dlls / winmm / wineoss / audio.c
1 /* -*- tab-width: 8; c-basic-offset: 4 -*- */
2 /*                                 
3  * Sample Wine Driver for Open Sound System (featured in Linux and FreeBSD)
4  *
5  * Copyright 1994 Martin Ayotte
6  *           1999 Eric Pouech (async playing in waveOut/waveIn)
7  *           2000 Eric Pouech (loops in waveOut)
8  */
9 /*
10  * FIXME:
11  *      pause in waveOut does not work correctly
12  *      full duplex (in/out) is not working (device is opened twice for Out 
13  *      and In) (OSS is known for its poor duplex capabilities, alsa is
14  *      better)
15  */
16
17 /*#define EMULATE_SB16*/
18
19 #include "config.h"
20
21 #include <stdlib.h>
22 #include <stdio.h>
23 #include <string.h>
24 #include <unistd.h>
25 #include <errno.h>
26 #include <fcntl.h>
27 #include <sys/ioctl.h>
28 #ifdef HAVE_SYS_MMAN_H
29 # include <sys/mman.h>
30 #endif
31 #include "windef.h"
32 #include "wingdi.h"
33 #include "winerror.h"
34 #include "wine/winuser16.h"
35 #include "mmddk.h"
36 #include "dsound.h"
37 #include "dsdriver.h"
38 #include "oss.h"
39 #include "heap.h"
40 #include "ldt.h"
41 #include "debugtools.h"
42
43 DEFAULT_DEBUG_CHANNEL(wave);
44
45 /* Allow 1% deviation for sample rates (some ES137x cards) */
46 #define NEAR_MATCH(rate1,rate2) (((100*((int)(rate1)-(int)(rate2)))/(rate1))==0)
47
48 #ifdef HAVE_OSS
49
50 #define SOUND_DEV "/dev/dsp"
51 #define MIXER_DEV "/dev/mixer"
52
53 #define MAX_WAVEOUTDRV  (1)
54 #define MAX_WAVEINDRV   (1)
55
56 /* state diagram for waveOut writing:
57  *
58  * +---------+-------------+---------------+---------------------------------+
59  * |  state  |  function   |     event     |            new state            |
60  * +---------+-------------+---------------+---------------------------------+
61  * |         | open()      |               | STOPPED                         |
62  * | PAUSED  | write()     |               | PAUSED                          |
63  * | STOPPED | write()     | <thrd create> | PLAYING                         |
64  * | PLAYING | write()     | HEADER        | PLAYING                         |
65  * | (other) | write()     | <error>       |                                 |
66  * | (any)   | pause()     | PAUSING       | PAUSED                          |
67  * | PAUSED  | restart()   | RESTARTING    | PLAYING (if no thrd => STOPPED) |
68  * | (any)   | reset()     | RESETTING     | STOPPED                         |
69  * | (any)   | close()     | CLOSING       | CLOSED                          |
70  * +---------+-------------+---------------+---------------------------------+
71  */
72
73 /* states of the playing device */
74 #define WINE_WS_PLAYING         0
75 #define WINE_WS_PAUSED          1
76 #define WINE_WS_STOPPED         2
77 #define WINE_WS_CLOSED          3
78
79 /* events to be send to device */
80 #define WINE_WM_PAUSING         (WM_USER + 1)
81 #define WINE_WM_RESTARTING      (WM_USER + 2)
82 #define WINE_WM_RESETTING       (WM_USER + 3)
83 #define WINE_WM_CLOSING         (WM_USER + 4)
84 #define WINE_WM_HEADER          (WM_USER + 5)
85
86 typedef struct {
87     int                         unixdev;
88     volatile int                state;                  /* one of the WINE_WS_ manifest constants */
89     DWORD                       dwFragmentSize;         /* size of OSS buffer fragment */
90     WAVEOPENDESC                waveDesc;
91     WORD                        wFlags;
92     PCMWAVEFORMAT               format;
93     LPWAVEHDR                   lpQueuePtr;             /* start of queued WAVEHDRs (waiting to be notified) */
94     LPWAVEHDR                   lpPlayPtr;              /* start of not yet fully played buffers */
95     LPWAVEHDR                   lpLoopPtr;              /* pointer of first buffer in loop, if any */
96     
97     DWORD                       dwLastFragDone;         /* time in ms, when last played fragment will be actually played */
98     DWORD                       dwPlayedTotal;          /* number of bytes played since opening */
99
100     /* info on current lpQueueHdr->lpWaveHdr */
101     DWORD                       dwOffCurrHdr;           /* offset in lpPlayPtr->lpData for fragments */
102     DWORD                       dwRemain;               /* number of bytes to write to end the current fragment  */
103
104     /* synchronization stuff */
105     HANDLE                      hThread;
106     DWORD                       dwThreadID;
107     HANDLE                      hEvent;
108     WAVEOUTCAPSA                caps;
109
110     /* DirectSound stuff */
111     LPBYTE                      mapping;
112     DWORD                       maplen;
113 } WINE_WAVEOUT;
114
115 typedef struct {
116     int                         unixdev;
117     volatile int                state;
118     DWORD                       dwFragmentSize;         /* OpenSound '/dev/dsp' give us that size */
119     WAVEOPENDESC                waveDesc;
120     WORD                        wFlags;
121     PCMWAVEFORMAT               format;
122     LPWAVEHDR                   lpQueuePtr;
123     DWORD                       dwTotalRecorded;
124     WAVEINCAPSA                 caps;
125
126     /* synchronization stuff */
127     HANDLE                      hThread;
128     DWORD                       dwThreadID;
129     HANDLE                      hEvent;
130 } WINE_WAVEIN;
131
132 static WINE_WAVEOUT     WOutDev   [MAX_WAVEOUTDRV];
133 static WINE_WAVEIN      WInDev    [MAX_WAVEINDRV ];
134
135 static DWORD wodDsCreate(UINT wDevID, PIDSDRIVER* drv);
136
137 /*======================================================================*
138  *                  Low level WAVE implemantation                       *
139  *======================================================================*/
140
141 LONG OSS_WaveInit(void)
142 {
143     int         audio;
144     int         smplrate;
145     int         samplesize = 16;
146     int         dsp_stereo = 1;
147     int         bytespersmpl;
148     int         caps;
149     int         mask;
150
151     /* start with output device */
152
153     /* FIXME: only one device is supported */
154     memset(&WOutDev[0].caps, 0, sizeof(WOutDev[0].caps));
155
156     if (access(SOUND_DEV,0) != 0 ||
157         (audio = open(SOUND_DEV, O_WRONLY|O_NDELAY, 0)) == -1) {
158         TRACE("Couldn't open out %s (%s)\n", SOUND_DEV, strerror(errno));
159         return -1;
160     }
161
162     ioctl(audio, SNDCTL_DSP_RESET, 0);
163
164     /* FIXME: some programs compare this string against the content of the registry
165      * for MM drivers. The name have to match in order the program to work 
166      * (e.g. MS win9x mplayer.exe)
167      */
168 #ifdef EMULATE_SB16
169     WOutDev[0].caps.wMid = 0x0002;
170     WOutDev[0].caps.wPid = 0x0104;
171     strcpy(WOutDev[0].caps.szPname, "SB16 Wave Out");
172 #else
173     WOutDev[0].caps.wMid = 0x00FF;      /* Manufac ID */
174     WOutDev[0].caps.wPid = 0x0001;      /* Product ID */
175     /*    strcpy(WOutDev[0].caps.szPname, "OpenSoundSystem WAVOUT Driver");*/
176     strcpy(WOutDev[0].caps.szPname, "CS4236/37/38");
177 #endif
178     WOutDev[0].caps.vDriverVersion = 0x0100;
179     WOutDev[0].caps.dwFormats = 0x00000000;
180     WOutDev[0].caps.dwSupport = WAVECAPS_VOLUME;
181     
182     IOCTL(audio, SNDCTL_DSP_GETFMTS, mask);
183     TRACE("OSS dsp out mask=%08x\n", mask);
184
185     /* First bytespersampl, then stereo */
186     bytespersmpl = (IOCTL(audio, SNDCTL_DSP_SAMPLESIZE, samplesize) != 0) ? 1 : 2;
187     
188     WOutDev[0].caps.wChannels = (IOCTL(audio, SNDCTL_DSP_STEREO, dsp_stereo) != 0) ? 1 : 2;
189     if (WOutDev[0].caps.wChannels > 1) WOutDev[0].caps.dwSupport |= WAVECAPS_LRVOLUME;
190     
191     smplrate = 44100;
192     if (IOCTL(audio, SNDCTL_DSP_SPEED, smplrate) == 0) {
193         if (mask & AFMT_U8) {
194             WOutDev[0].caps.dwFormats |= WAVE_FORMAT_4M08;
195             if (WOutDev[0].caps.wChannels > 1)
196                 WOutDev[0].caps.dwFormats |= WAVE_FORMAT_4S08;
197         }
198         if ((mask & AFMT_S16_LE) && bytespersmpl > 1) {
199             WOutDev[0].caps.dwFormats |= WAVE_FORMAT_4M16;
200             if (WOutDev[0].caps.wChannels > 1)
201                 WOutDev[0].caps.dwFormats |= WAVE_FORMAT_4S16;
202         }
203     }
204     smplrate = 22050;
205     if (IOCTL(audio, SNDCTL_DSP_SPEED, smplrate) == 0) {
206         if (mask & AFMT_U8) {
207             WOutDev[0].caps.dwFormats |= WAVE_FORMAT_2M08;
208             if (WOutDev[0].caps.wChannels > 1)
209                 WOutDev[0].caps.dwFormats |= WAVE_FORMAT_2S08;
210         }
211         if ((mask & AFMT_S16_LE) && bytespersmpl > 1) {
212             WOutDev[0].caps.dwFormats |= WAVE_FORMAT_2M16;
213             if (WOutDev[0].caps.wChannels > 1)
214                 WOutDev[0].caps.dwFormats |= WAVE_FORMAT_2S16;
215         }
216     }
217     smplrate = 11025;
218     if (IOCTL(audio, SNDCTL_DSP_SPEED, smplrate) == 0) {
219         if (mask & AFMT_U8) {
220             WOutDev[0].caps.dwFormats |= WAVE_FORMAT_1M08;
221             if (WOutDev[0].caps.wChannels > 1)
222                 WOutDev[0].caps.dwFormats |= WAVE_FORMAT_1S08;
223         }
224         if ((mask & AFMT_S16_LE) && bytespersmpl > 1) {
225             WOutDev[0].caps.dwFormats |= WAVE_FORMAT_1M16;
226             if (WOutDev[0].caps.wChannels > 1)
227                 WOutDev[0].caps.dwFormats |= WAVE_FORMAT_1S16;
228         }
229     }
230     if (IOCTL(audio, SNDCTL_DSP_GETCAPS, caps) == 0) {
231         TRACE("OSS dsp out caps=%08X\n", caps);
232         if ((caps & DSP_CAP_REALTIME) && !(caps & DSP_CAP_BATCH)) {
233             WOutDev[0].caps.dwSupport |= WAVECAPS_SAMPLEACCURATE;
234
235             /* well, might as well use the DirectSound cap flag for something */
236             if ((caps & DSP_CAP_TRIGGER) && (caps & DSP_CAP_MMAP))
237                 WOutDev[0].caps.dwSupport |= WAVECAPS_DIRECTSOUND;
238         }
239     }
240     close(audio);
241     TRACE("out dwFormats = %08lX, dwSupport = %08lX\n",
242           WOutDev[0].caps.dwFormats, WOutDev[0].caps.dwSupport);
243
244     /* then do input device */
245     samplesize = 16;
246     dsp_stereo = 1;
247     
248     if (access(SOUND_DEV,0) != 0 ||
249         (audio = open(SOUND_DEV, O_RDONLY|O_NDELAY, 0)) == -1) {
250         TRACE("Couldn't open in %s (%s)\n", SOUND_DEV, strerror(errno));
251         return -1;
252     }
253
254     ioctl(audio, SNDCTL_DSP_RESET, 0);
255
256 #ifdef EMULATE_SB16
257     WInDev[0].caps.wMid = 0x0002;
258     WInDev[0].caps.wPid = 0x0004;
259     strcpy(WInDev[0].caps.szPname, "SB16 Wave In");
260 #else
261     WInDev[0].caps.wMid = 0x00FF;       /* Manufac ID */
262     WInDev[0].caps.wPid = 0x0001;       /* Product ID */
263     strcpy(WInDev[0].caps.szPname, "OpenSoundSystem WAVIN Driver");
264 #endif
265     WInDev[0].caps.dwFormats = 0x00000000;
266     WInDev[0].caps.wChannels = (IOCTL(audio, SNDCTL_DSP_STEREO, dsp_stereo) != 0) ? 1 : 2;
267
268     IOCTL(audio, SNDCTL_DSP_GETFMTS, mask);
269     TRACE("OSS in dsp mask=%08x\n", mask);
270
271     bytespersmpl = (IOCTL(audio, SNDCTL_DSP_SAMPLESIZE, samplesize) != 0) ? 1 : 2;
272     smplrate = 44100;
273     if (IOCTL(audio, SNDCTL_DSP_SPEED, smplrate) == 0) {
274         if (mask & AFMT_U8) {
275             WInDev[0].caps.dwFormats |= WAVE_FORMAT_4M08;
276             if (WInDev[0].caps.wChannels > 1)
277                 WInDev[0].caps.dwFormats |= WAVE_FORMAT_4S08;
278         }
279         if ((mask & AFMT_S16_LE) && bytespersmpl > 1) {
280             WInDev[0].caps.dwFormats |= WAVE_FORMAT_4M16;
281             if (WInDev[0].caps.wChannels > 1)
282                 WInDev[0].caps.dwFormats |= WAVE_FORMAT_4S16;
283         }
284     }
285     smplrate = 22050;
286     if (IOCTL(audio, SNDCTL_DSP_SPEED, smplrate) == 0) {
287         if (mask & AFMT_U8) {
288             WInDev[0].caps.dwFormats |= WAVE_FORMAT_2M08;
289             if (WInDev[0].caps.wChannels > 1)
290                 WInDev[0].caps.dwFormats |= WAVE_FORMAT_2S08;
291         }
292         if ((mask & AFMT_S16_LE) && bytespersmpl > 1) {
293             WInDev[0].caps.dwFormats |= WAVE_FORMAT_2M16;
294             if (WInDev[0].caps.wChannels > 1)
295                 WInDev[0].caps.dwFormats |= WAVE_FORMAT_2S16;
296         }
297     }
298     smplrate = 11025;
299     if (IOCTL(audio, SNDCTL_DSP_SPEED, smplrate) == 0) {
300         if (mask & AFMT_U8) {
301             WInDev[0].caps.dwFormats |= WAVE_FORMAT_1M08;
302             if (WInDev[0].caps.wChannels > 1)
303                 WInDev[0].caps.dwFormats |= WAVE_FORMAT_1S08;
304         }
305         if ((mask & AFMT_S16_LE) && bytespersmpl > 1) {
306             WInDev[0].caps.dwFormats |= WAVE_FORMAT_1M16;
307             if (WInDev[0].caps.wChannels > 1)
308                 WInDev[0].caps.dwFormats |= WAVE_FORMAT_1S16;
309         }
310     }
311     close(audio);
312     TRACE("in dwFormats = %08lX\n", WInDev[0].caps.dwFormats);
313
314     return 0;
315 }
316
317 /**************************************************************************
318  *                      OSS_NotifyClient                        [internal]
319  */
320 static DWORD OSS_NotifyClient(UINT wDevID, WORD wMsg, DWORD dwParam1, 
321                               DWORD dwParam2)
322 {
323     TRACE("wDevID = %04X wMsg = %d dwParm1 = %04lX dwParam2 = %04lX\n",wDevID, wMsg, dwParam1, dwParam2);
324     
325     switch (wMsg) {
326     case WOM_OPEN:
327     case WOM_CLOSE:
328     case WOM_DONE:
329         if (wDevID >= MAX_WAVEOUTDRV) return MCIERR_INTERNAL;
330         
331         if (WOutDev[wDevID].wFlags != DCB_NULL && 
332             !DriverCallback(WOutDev[wDevID].waveDesc.dwCallback, 
333                             WOutDev[wDevID].wFlags, 
334                             WOutDev[wDevID].waveDesc.hWave, 
335                             wMsg, 
336                             WOutDev[wDevID].waveDesc.dwInstance, 
337                             dwParam1, 
338                             dwParam2)) {
339             WARN("can't notify client !\n");
340             return MMSYSERR_NOERROR;
341         }
342         break;
343         
344     case WIM_OPEN:
345     case WIM_CLOSE:
346     case WIM_DATA:
347         if (wDevID >= MAX_WAVEINDRV) return MCIERR_INTERNAL;
348         
349         if (WInDev[wDevID].wFlags != DCB_NULL && 
350             !DriverCallback(WInDev[wDevID].waveDesc.dwCallback, 
351                             WInDev[wDevID].wFlags, 
352                             WInDev[wDevID].waveDesc.hWave, 
353                             wMsg, 
354                             WInDev[wDevID].waveDesc.dwInstance, 
355                             dwParam1, 
356                             dwParam2)) {
357             WARN("can't notify client !\n");
358             return MMSYSERR_NOERROR;
359         }
360         break;
361     default:
362         FIXME("Unknown CB message %u\n", wMsg);
363         break;
364     }
365     return 0;
366 }
367
368 /*======================================================================*
369  *                  Low level WAVE OUT implemantation                   *
370  *======================================================================*/
371
372 /**************************************************************************
373  *                              wodPlayer_WriteFragments        [internal]
374  *
375  * wodPlayer helper. Writes as many fragments it can to unixdev.
376  * Returns TRUE in case of buffer underrun.
377  */
378 static  BOOL    wodPlayer_WriteFragments(WINE_WAVEOUT* wwo)
379 {
380     LPWAVEHDR           lpWaveHdr;
381     LPBYTE              lpData;
382     int                 count;
383     audio_buf_info      info;
384
385     for (;;) {
386         if (ioctl(wwo->unixdev, SNDCTL_DSP_GETOSPACE, &info) < 0) {
387             ERR("ioctl failed (%s)\n", strerror(errno));
388             return FALSE;
389         }
390         
391         TRACE("Fragments %d/%d\n", info.fragments, info.fragstotal);
392
393         if (!info.fragments)    /* output queue is full, wait a bit */
394             return FALSE;
395
396         lpWaveHdr = wwo->lpPlayPtr;
397         if (!lpWaveHdr) {
398             if (wwo->dwRemain > 0 &&            /* still data to send to complete current fragment */
399                 wwo->dwLastFragDone &&          /* first fragment has been played */
400                 info.fragments + 2 > info.fragstotal) {   /* done with all waveOutWrite()' fragments */
401                 /* FIXME: should do better handling here */
402                 TRACE("Oooch, buffer underrun !\n");
403                 return TRUE; /* force resetting of waveOut device */
404             }
405             return FALSE;       /* wait a bit */
406         }
407         
408         if (wwo->dwOffCurrHdr == 0) {
409             TRACE("Starting a new wavehdr %p of %ld bytes\n", lpWaveHdr, lpWaveHdr->dwBufferLength);
410             if (lpWaveHdr->dwFlags & WHDR_BEGINLOOP) {
411                 if (wwo->lpLoopPtr) {
412                     WARN("Already in a loop. Discarding loop on this header (%p)\n", lpWaveHdr);
413                 } else {
414                     wwo->lpLoopPtr = lpWaveHdr;
415                 }
416             }
417         }
418         
419         lpData = lpWaveHdr->lpData;
420
421         /* finish current wave hdr ? */
422         if (wwo->dwOffCurrHdr + wwo->dwRemain >= lpWaveHdr->dwBufferLength) { 
423             DWORD       toWrite = lpWaveHdr->dwBufferLength - wwo->dwOffCurrHdr;
424             
425             /* write end of current wave hdr */
426             count = write(wwo->unixdev, lpData + wwo->dwOffCurrHdr, toWrite);
427             TRACE("write(%p[%5lu], %5lu) => %d\n", lpData, wwo->dwOffCurrHdr, toWrite, count);
428             
429             if (count > 0 || toWrite == 0) {
430                 DWORD   tc = GetTickCount();
431
432                 if (wwo->dwLastFragDone /* + guard time ?? */ < tc) 
433                     wwo->dwLastFragDone = tc;
434                 wwo->dwLastFragDone += (toWrite * 1000) / wwo->format.wf.nAvgBytesPerSec;
435
436                 lpWaveHdr->reserved = wwo->dwLastFragDone;
437                 TRACE("Tagging hdr %p with %08lx\n", lpWaveHdr, wwo->dwLastFragDone);
438
439                 /* WAVEHDR written, go to next one */
440                 if ((lpWaveHdr->dwFlags & WHDR_ENDLOOP) && wwo->lpLoopPtr) {
441                     if (--wwo->lpLoopPtr->dwLoops > 0) {
442                         wwo->lpPlayPtr = wwo->lpLoopPtr;
443                     } else {
444                         /* last one played */
445                         if (wwo->lpLoopPtr != lpWaveHdr && (lpWaveHdr->dwFlags & WHDR_BEGINLOOP)) {
446                             FIXME("Correctly handled case ? (ending loop buffer also starts a new loop\n");
447                             /* shall we consider the END flag for the closing loop or for
448                              * the opening one or for both ???
449                              * code assumes for closing loop only
450                              */
451                             wwo->lpLoopPtr = lpWaveHdr;
452                         } else {
453                             wwo->lpLoopPtr = NULL;
454                         }
455                         wwo->lpPlayPtr = lpWaveHdr->lpNext;
456                     }
457                 } else {
458                     wwo->lpPlayPtr = lpWaveHdr->lpNext;
459                 }
460                 wwo->dwOffCurrHdr = 0;
461                 if ((wwo->dwRemain -= count) == 0) {
462                     wwo->dwRemain = wwo->dwFragmentSize;
463                 }
464             }
465             continue; /* try to go to use next wavehdr */
466         }  else {
467             count = write(wwo->unixdev, lpData + wwo->dwOffCurrHdr, wwo->dwRemain);
468             TRACE("write(%p[%5lu], %5lu) => %d\n", lpData, wwo->dwOffCurrHdr, wwo->dwRemain, count);
469             if (count > 0) {
470                 DWORD   tc = GetTickCount();
471
472                 if (wwo->dwLastFragDone /* + guard time ?? */ < tc) 
473                     wwo->dwLastFragDone = tc;
474                 wwo->dwLastFragDone += (wwo->dwRemain * 1000) / wwo->format.wf.nAvgBytesPerSec;
475
476                 TRACE("Tagging frag with %08lx\n", wwo->dwLastFragDone);
477
478                 wwo->dwOffCurrHdr += count;
479                 wwo->dwRemain = wwo->dwFragmentSize;
480             }
481         }
482     }
483 }
484
485 /**************************************************************************
486  *                              wodPlayer_Notify                [internal]
487  *
488  * wodPlayer helper. Notifies (and remove from queue) all the wavehdr which content
489  * have been played (actually to speaker, not to unixdev fd).
490  */
491 static  void    wodPlayer_Notify(WINE_WAVEOUT* wwo, WORD uDevID, BOOL force)
492 {
493     LPWAVEHDR           lpWaveHdr;
494     DWORD               tc = GetTickCount();
495
496     while (wwo->lpQueuePtr && 
497            (force || 
498             (wwo->lpQueuePtr != wwo->lpPlayPtr && wwo->lpQueuePtr != wwo->lpLoopPtr))) {
499         lpWaveHdr = wwo->lpQueuePtr;
500             
501         if (lpWaveHdr->reserved > tc && !force) break;
502
503         wwo->dwPlayedTotal += lpWaveHdr->dwBufferLength;
504         wwo->lpQueuePtr = lpWaveHdr->lpNext;
505
506         lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
507         lpWaveHdr->dwFlags |= WHDR_DONE;
508
509         TRACE("Notifying client with %p\n", lpWaveHdr);
510         if (OSS_NotifyClient(uDevID, WOM_DONE, (DWORD)lpWaveHdr, 0) != MMSYSERR_NOERROR) {
511             WARN("can't notify client !\n");
512         }
513     }
514 }
515
516 /**************************************************************************
517  *                              wodPlayer_Reset                 [internal]
518  *
519  * wodPlayer helper. Resets current output stream.
520  */
521 static  void    wodPlayer_Reset(WINE_WAVEOUT* wwo, WORD uDevID, BOOL reset)
522 {
523     /* updates current notify list */
524     wodPlayer_Notify(wwo, uDevID, FALSE);
525
526     /* flush all possible output */
527     if (ioctl(wwo->unixdev, SNDCTL_DSP_RESET, 0) == -1) {
528         perror("ioctl SNDCTL_DSP_RESET");
529         wwo->hThread = 0;
530         wwo->state = WINE_WS_STOPPED;
531         ExitThread(-1);
532     }
533
534     wwo->dwOffCurrHdr = 0;
535     wwo->dwRemain = wwo->dwFragmentSize;
536     if (reset) {
537         /* empty notify list */
538         wodPlayer_Notify(wwo, uDevID, TRUE);
539
540         wwo->lpPlayPtr = wwo->lpQueuePtr = wwo->lpLoopPtr = NULL;
541         wwo->state = WINE_WS_STOPPED;
542         wwo->dwPlayedTotal = 0;
543     } else {
544         /* FIXME: this is not accurate when looping, but can be do better ? */
545         wwo->lpPlayPtr = (wwo->lpLoopPtr) ? wwo->lpLoopPtr : wwo->lpQueuePtr;
546         wwo->state = WINE_WS_PAUSED;
547     }
548 }
549
550 /**************************************************************************
551  *                              wodPlayer                       [internal]
552  */
553 static  DWORD   CALLBACK        wodPlayer(LPVOID pmt)
554 {
555     WORD                uDevID = (DWORD)pmt;
556     WINE_WAVEOUT*       wwo = (WINE_WAVEOUT*)&WOutDev[uDevID];
557     WAVEHDR*            lpWaveHdr;
558     DWORD               dwSleepTime;
559     MSG                 msg;
560
561     PeekMessageA(&msg, 0, 0, 0, 0);
562     wwo->state = WINE_WS_STOPPED;
563
564     wwo->dwLastFragDone = 0;
565     wwo->dwOffCurrHdr = 0;
566     wwo->dwRemain = wwo->dwFragmentSize;
567     wwo->lpQueuePtr = wwo->lpPlayPtr = wwo->lpLoopPtr = NULL;
568     wwo->dwPlayedTotal = 0;
569
570     TRACE("imhere[0]\n");
571     SetEvent(wwo->hEvent);
572
573     /* make sleep time to be # of ms to output a fragment */
574     dwSleepTime = (wwo->dwFragmentSize * 1000) / wwo->format.wf.nAvgBytesPerSec;
575
576     for (;;) {
577         /* wait for dwSleepTime or an event in thread's queue */
578         /* FIXME: could improve wait time depending on queue state,
579          * ie, number of queued fragments
580          */
581         TRACE("imhere[1]\n");
582         MsgWaitForMultipleObjects(0, NULL, FALSE, 
583                                   (wwo->state == WINE_WS_PLAYING) ? 
584                                      2 * dwSleepTime : /*INFINITE*/100, 
585                                   QS_POSTMESSAGE);
586         TRACE("imhere[2] (q=%p p=%p)\n", wwo->lpQueuePtr, wwo->lpPlayPtr);
587         wodPlayer_Notify(wwo, uDevID, FALSE);
588         while (PeekMessageA(&msg, 0, 0, 0, PM_REMOVE)) {
589             switch (msg.message) {
590             case WINE_WM_PAUSING:
591                 wodPlayer_Reset(wwo, uDevID, FALSE);
592                 wwo->state = WINE_WS_PAUSED;
593                 SetEvent(wwo->hEvent);
594                 break;
595             case WINE_WM_RESTARTING:
596                 wwo->state = WINE_WS_PLAYING;
597                 SetEvent(wwo->hEvent);
598                 break;
599             case WINE_WM_HEADER:
600                 lpWaveHdr = (LPWAVEHDR)msg.lParam;
601                 
602                 /* insert buffer at the end of queue */
603                 {
604                     LPWAVEHDR*  wh;
605                     for (wh = &(wwo->lpQueuePtr); *wh; wh = &((*wh)->lpNext));
606                     *wh = lpWaveHdr;
607                 }
608                 if (!wwo->lpPlayPtr) wwo->lpPlayPtr = lpWaveHdr;
609                 if (wwo->state == WINE_WS_STOPPED)
610                     wwo->state = WINE_WS_PLAYING;
611                 break;
612             case WINE_WM_RESETTING:
613                 wodPlayer_Reset(wwo, uDevID, TRUE);
614                 SetEvent(wwo->hEvent);
615                 break;
616             case WINE_WM_CLOSING:
617                 /* sanity check: this should not happen since the device must have been reset before */
618                 if (wwo->lpQueuePtr || wwo->lpPlayPtr) ERR("out of sync\n");
619                 wwo->hThread = 0;
620                 wwo->state = WINE_WS_CLOSED;
621                 SetEvent(wwo->hEvent);
622                 ExitThread(0);
623                 /* shouldn't go here */
624             default:
625                 FIXME("unknown message %d\n", msg.message);
626                 break;
627             }
628         }
629         if (wwo->state == WINE_WS_PLAYING) {
630             wodPlayer_WriteFragments(wwo);
631         }
632         wodPlayer_Notify(wwo, uDevID, FALSE);
633     }
634     ExitThread(0);
635     /* just for not generating compilation warnings... should never be executed */
636     return 0; 
637 }
638
639 /**************************************************************************
640  *                      wodGetDevCaps                           [internal]
641  */
642 static DWORD wodGetDevCaps(WORD wDevID, LPWAVEOUTCAPSA lpCaps, DWORD dwSize)
643 {
644     TRACE("(%u, %p, %lu);\n", wDevID, lpCaps, dwSize);
645     
646     if (lpCaps == NULL) return MMSYSERR_NOTENABLED;
647     
648     if (wDevID >= MAX_WAVEOUTDRV) {
649         TRACE("MAX_WAVOUTDRV reached !\n");
650         return MMSYSERR_BADDEVICEID;
651     }
652
653     memcpy(lpCaps, &WOutDev[wDevID].caps, min(dwSize, sizeof(*lpCaps)));
654     return MMSYSERR_NOERROR;
655 }
656
657 /**************************************************************************
658  *                              wodOpen                         [internal]
659  */
660 static DWORD wodOpen(WORD wDevID, LPWAVEOPENDESC lpDesc, DWORD dwFlags)
661 {
662     int                 audio;
663     int                 format;
664     int                 sample_rate;
665     int                 dsp_stereo;
666     int                 fragment_size;
667     int                 audio_fragment;
668     WINE_WAVEOUT*       wwo;
669
670     TRACE("(%u, %p, %08lX);\n", wDevID, lpDesc, dwFlags);
671     if (lpDesc == NULL) {
672         WARN("Invalid Parameter !\n");
673         return MMSYSERR_INVALPARAM;
674     }
675     if (wDevID >= MAX_WAVEOUTDRV) {
676         TRACE("MAX_WAVOUTDRV reached !\n");
677         return MMSYSERR_BADDEVICEID;
678     }
679
680     /* only PCM format is supported so far... */
681     if (lpDesc->lpFormat->wFormatTag != WAVE_FORMAT_PCM ||
682         lpDesc->lpFormat->nChannels == 0 ||
683         lpDesc->lpFormat->nSamplesPerSec == 0) {
684         WARN("Bad format: tag=%04X nChannels=%d nSamplesPerSec=%ld !\n", 
685              lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
686              lpDesc->lpFormat->nSamplesPerSec);
687         return WAVERR_BADFORMAT;
688     }
689
690     if (dwFlags & WAVE_FORMAT_QUERY) {
691         TRACE("Query format: tag=%04X nChannels=%d nSamplesPerSec=%ld !\n", 
692              lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
693              lpDesc->lpFormat->nSamplesPerSec);
694         return MMSYSERR_NOERROR;
695     }
696
697     wwo = &WOutDev[wDevID];
698
699     if ((dwFlags & WAVE_DIRECTSOUND) && !(wwo->caps.dwSupport & WAVECAPS_DIRECTSOUND))
700         /* not supported, ignore it */
701         dwFlags &= ~WAVE_DIRECTSOUND;
702
703     if (access(SOUND_DEV, 0) != 0) 
704         return MMSYSERR_NOTENABLED;
705     if (dwFlags & WAVE_DIRECTSOUND)
706         /* we want to be able to mmap() the device, which means it must be opened readable,
707          * otherwise mmap() will fail (at least under Linux) */
708         audio = open(SOUND_DEV, O_RDWR|O_NDELAY, 0);
709     else
710         audio = open(SOUND_DEV, O_WRONLY|O_NDELAY, 0);
711     if (audio == -1) {
712         WARN("can't open (%s)!\n", strerror(errno));
713         return MMSYSERR_ALLOCATED;
714     }
715     fcntl(audio, F_SETFD, 1); /* set close on exec flag */
716     wwo->unixdev = audio;
717     wwo->wFlags = HIWORD(dwFlags & CALLBACK_TYPEMASK);
718     
719     memcpy(&wwo->waveDesc, lpDesc,           sizeof(WAVEOPENDESC));
720     memcpy(&wwo->format,   lpDesc->lpFormat, sizeof(PCMWAVEFORMAT));
721     
722     if (wwo->format.wBitsPerSample == 0) {
723         WARN("Resetting zeroed wBitsPerSample\n");
724         wwo->format.wBitsPerSample = 8 *
725             (wwo->format.wf.nAvgBytesPerSec /
726              wwo->format.wf.nSamplesPerSec) /
727             wwo->format.wf.nChannels;
728     }
729     
730     if (dwFlags & WAVE_DIRECTSOUND) {
731         /* with DirectSound, fragments are irrelevant, but a large buffer isn't...
732          * so let's choose a full 64KB for DirectSound */
733         audio_fragment = 0x0020000B;
734     } else {
735         /* shockwave player uses only 4 1k-fragments at a rate of 22050 bytes/sec
736          * thus leading to 46ms per fragment, and a turnaround time of 185ms
737          */
738         /* 2^10=1024 bytes per fragment, 16 fragments max */
739         audio_fragment = 0x000F000A;
740     }
741     sample_rate = wwo->format.wf.nSamplesPerSec;
742     dsp_stereo = (wwo->format.wf.nChannels > 1) ? 1 : 0;
743     format = (wwo->format.wBitsPerSample == 16) ? AFMT_S16_LE : AFMT_U8;
744
745     IOCTL(audio, SNDCTL_DSP_SETFRAGMENT, audio_fragment);
746     /* First size and stereo then samplerate */
747     IOCTL(audio, SNDCTL_DSP_SETFMT, format);
748     IOCTL(audio, SNDCTL_DSP_STEREO, dsp_stereo);
749     IOCTL(audio, SNDCTL_DSP_SPEED, sample_rate);
750
751     /* paranoid checks */
752     if (format != ((wwo->format.wBitsPerSample == 16) ? AFMT_S16_LE : AFMT_U8))
753         ERR("Can't set format to %d (%d)\n", 
754             (wwo->format.wBitsPerSample == 16) ? AFMT_S16_LE : AFMT_U8, format);
755     if (dsp_stereo != (wwo->format.wf.nChannels > 1) ? 1 : 0) 
756         ERR("Can't set stereo to %u (%d)\n", 
757             (wwo->format.wf.nChannels > 1) ? 1 : 0, dsp_stereo);
758     if (!NEAR_MATCH(sample_rate,wwo->format.wf.nSamplesPerSec))
759         ERR("Can't set sample_rate to %lu (%d)\n", 
760             wwo->format.wf.nSamplesPerSec, sample_rate);
761
762     /* even if we set fragment size above, read it again, just in case */
763     IOCTL(audio, SNDCTL_DSP_GETBLKSIZE, fragment_size);
764     if (fragment_size == -1) {
765         WARN("IOCTL can't 'SNDCTL_DSP_GETBLKSIZE' !\n");
766         close(audio);
767         wwo->unixdev = 0;
768         return MMSYSERR_NOTENABLED;
769     }
770     wwo->dwFragmentSize = fragment_size;
771
772     if (!(dwFlags & WAVE_DIRECTSOUND)) {
773         wwo->hEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
774         wwo->hThread = CreateThread(NULL, 0, wodPlayer, (LPVOID)(DWORD)wDevID, 0, &(wwo->dwThreadID));
775         WaitForSingleObject(wwo->hEvent, INFINITE);
776     } else {
777         wwo->hEvent = INVALID_HANDLE_VALUE;
778         wwo->hThread = INVALID_HANDLE_VALUE;
779         wwo->dwThreadID = 0;
780     }
781
782     TRACE("fd=%d fragmentSize=%ld\n", 
783           wwo->unixdev, wwo->dwFragmentSize);
784     if (wwo->dwFragmentSize % wwo->format.wf.nBlockAlign)
785         ERR("Fragment doesn't contain an integral number of data blocks\n");
786
787     TRACE("wBitsPerSample=%u, nAvgBytesPerSec=%lu, nSamplesPerSec=%lu, nChannels=%u nBlockAlign=%u!\n", 
788           wwo->format.wBitsPerSample, wwo->format.wf.nAvgBytesPerSec, 
789           wwo->format.wf.nSamplesPerSec, wwo->format.wf.nChannels,
790           wwo->format.wf.nBlockAlign);
791     
792     if (OSS_NotifyClient(wDevID, WOM_OPEN, 0L, 0L) != MMSYSERR_NOERROR) {
793         WARN("can't notify client !\n");
794         return MMSYSERR_INVALPARAM;
795     }
796     return MMSYSERR_NOERROR;
797 }
798
799 /**************************************************************************
800  *                              wodClose                        [internal]
801  */
802 static DWORD wodClose(WORD wDevID)
803 {
804     DWORD               ret = MMSYSERR_NOERROR;
805     WINE_WAVEOUT*       wwo;
806
807     TRACE("(%u);\n", wDevID);
808     
809     if (wDevID >= MAX_WAVEOUTDRV || WOutDev[wDevID].unixdev == 0) {
810         WARN("bad device ID !\n");
811         return MMSYSERR_BADDEVICEID;
812     }
813     
814     wwo = &WOutDev[wDevID];
815     if (wwo->lpQueuePtr) {
816         WARN("buffers still playing !\n");
817         ret = WAVERR_STILLPLAYING;
818     } else {
819         TRACE("imhere[3-close]\n");
820         if (wwo->hEvent != INVALID_HANDLE_VALUE) {
821             PostThreadMessageA(wwo->dwThreadID, WINE_WM_CLOSING, 0, 0);
822             WaitForSingleObject(wwo->hEvent, INFINITE);
823             CloseHandle(wwo->hEvent);
824         }
825         if (wwo->mapping) {
826             munmap(wwo->mapping, wwo->maplen);
827             wwo->mapping = NULL;
828         }
829
830         close(wwo->unixdev);
831         wwo->unixdev = 0;
832         wwo->dwFragmentSize = 0;
833         if (OSS_NotifyClient(wDevID, WOM_CLOSE, 0L, 0L) != MMSYSERR_NOERROR) {
834             WARN("can't notify client !\n");
835             ret = MMSYSERR_INVALPARAM;
836         }
837     }
838     return ret;
839 }
840
841 /**************************************************************************
842  *                              wodWrite                        [internal]
843  * 
844  */
845 static DWORD wodWrite(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
846 {
847     TRACE("(%u, %p, %08lX);\n", wDevID, lpWaveHdr, dwSize);
848     
849     /* first, do the sanity checks... */
850     if (wDevID >= MAX_WAVEOUTDRV || WOutDev[wDevID].unixdev == 0) {
851         WARN("bad dev ID !\n");
852         return MMSYSERR_BADDEVICEID;
853     }
854     
855     if (lpWaveHdr->lpData == NULL || !(lpWaveHdr->dwFlags & WHDR_PREPARED)) 
856         return WAVERR_UNPREPARED;
857     
858     if (lpWaveHdr->dwFlags & WHDR_INQUEUE) 
859         return WAVERR_STILLPLAYING;
860
861     lpWaveHdr->dwFlags &= ~WHDR_DONE;
862     lpWaveHdr->dwFlags |= WHDR_INQUEUE;
863     lpWaveHdr->lpNext = 0;
864
865     TRACE("imhere[3-HEADER]\n");
866     PostThreadMessageA(WOutDev[wDevID].dwThreadID, WINE_WM_HEADER, 0, (DWORD)lpWaveHdr);
867
868     return MMSYSERR_NOERROR;
869 }
870
871 /**************************************************************************
872  *                              wodPrepare                      [internal]
873  */
874 static DWORD wodPrepare(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
875 {
876     TRACE("(%u, %p, %08lX);\n", wDevID, lpWaveHdr, dwSize);
877     
878     if (wDevID >= MAX_WAVEOUTDRV) {
879         WARN("bad device ID !\n");
880         return MMSYSERR_BADDEVICEID;
881     }
882     
883     if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
884         return WAVERR_STILLPLAYING;
885     
886     lpWaveHdr->dwFlags |= WHDR_PREPARED;
887     lpWaveHdr->dwFlags &= ~WHDR_DONE;
888     return MMSYSERR_NOERROR;
889 }
890
891 /**************************************************************************
892  *                              wodUnprepare                    [internal]
893  */
894 static DWORD wodUnprepare(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
895 {
896     TRACE("(%u, %p, %08lX);\n", wDevID, lpWaveHdr, dwSize);
897     
898     if (wDevID >= MAX_WAVEOUTDRV) {
899         WARN("bad device ID !\n");
900         return MMSYSERR_BADDEVICEID;
901     }
902     
903     if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
904         return WAVERR_STILLPLAYING;
905     
906     lpWaveHdr->dwFlags &= ~WHDR_PREPARED;
907     lpWaveHdr->dwFlags |= WHDR_DONE;
908     
909     return MMSYSERR_NOERROR;
910 }
911
912 /**************************************************************************
913  *                      wodPause                                [internal]
914  */
915 static DWORD wodPause(WORD wDevID)
916 {
917     TRACE("(%u);!\n", wDevID);
918     
919     if (wDevID >= MAX_WAVEOUTDRV || WOutDev[wDevID].unixdev == 0) {
920         WARN("bad device ID !\n");
921         return MMSYSERR_BADDEVICEID;
922     }
923     
924     TRACE("imhere[3-PAUSING]\n");
925     PostThreadMessageA(WOutDev[wDevID].dwThreadID, WINE_WM_PAUSING, 0, 0);
926     WaitForSingleObject(WOutDev[wDevID].hEvent, INFINITE);
927     
928     return MMSYSERR_NOERROR;
929 }
930
931 /**************************************************************************
932  *                      wodRestart                              [internal]
933  */
934 static DWORD wodRestart(WORD wDevID)
935 {
936     TRACE("(%u);\n", wDevID);
937     
938     if (wDevID >= MAX_WAVEOUTDRV || WOutDev[wDevID].unixdev == 0) {
939         WARN("bad device ID !\n");
940         return MMSYSERR_BADDEVICEID;
941     }
942     
943     if (WOutDev[wDevID].state == WINE_WS_PAUSED) {
944         TRACE("imhere[3-RESTARTING]\n");
945         PostThreadMessageA(WOutDev[wDevID].dwThreadID, WINE_WM_RESTARTING, 0, 0);
946         WaitForSingleObject(WOutDev[wDevID].hEvent, INFINITE);
947     }
948     
949     /* FIXME: is NotifyClient with WOM_DONE right ? (Comet Busters 1.3.3 needs this notification) */
950     /* FIXME: Myst crashes with this ... hmm -MM
951        if (OSS_NotifyClient(wDevID, WOM_DONE, 0L, 0L) != MMSYSERR_NOERROR) {
952        WARN("can't notify client !\n");
953        return MMSYSERR_INVALPARAM;
954        }
955     */
956     
957     return MMSYSERR_NOERROR;
958 }
959
960 /**************************************************************************
961  *                      wodReset                                [internal]
962  */
963 static DWORD wodReset(WORD wDevID)
964 {
965     TRACE("(%u);\n", wDevID);
966     
967     if (wDevID >= MAX_WAVEOUTDRV || WOutDev[wDevID].unixdev == 0) {
968         WARN("bad device ID !\n");
969         return MMSYSERR_BADDEVICEID;
970     }
971     
972     TRACE("imhere[3-RESET]\n");
973     PostThreadMessageA(WOutDev[wDevID].dwThreadID, WINE_WM_RESETTING, 0, 0);
974     WaitForSingleObject(WOutDev[wDevID].hEvent, INFINITE);
975     
976     return MMSYSERR_NOERROR;
977 }
978
979
980 /**************************************************************************
981  *                              wodGetPosition                  [internal]
982  */
983 static DWORD wodGetPosition(WORD wDevID, LPMMTIME lpTime, DWORD uSize)
984 {
985     int                 time;
986     DWORD               val;
987     WINE_WAVEOUT*       wwo;
988
989     TRACE("(%u, %p, %lu);\n", wDevID, lpTime, uSize);
990     
991     if (wDevID >= MAX_WAVEOUTDRV || WOutDev[wDevID].unixdev == 0) {
992         WARN("bad device ID !\n");
993         return MMSYSERR_BADDEVICEID;
994     }
995     
996     if (lpTime == NULL) return MMSYSERR_INVALPARAM;
997
998     wwo = &WOutDev[wDevID];
999     val = wwo->dwPlayedTotal;
1000
1001     TRACE("wType=%04X wBitsPerSample=%u nSamplesPerSec=%lu nChannels=%u nAvgBytesPerSec=%lu\n", 
1002           lpTime->wType, wwo->format.wBitsPerSample, 
1003           wwo->format.wf.nSamplesPerSec, wwo->format.wf.nChannels, 
1004           wwo->format.wf.nAvgBytesPerSec); 
1005     TRACE("dwTotalPlayed=%lu\n", val);
1006     
1007     switch (lpTime->wType) {
1008     case TIME_BYTES:
1009         lpTime->u.cb = val;
1010         TRACE("TIME_BYTES=%lu\n", lpTime->u.cb);
1011         break;
1012     case TIME_SAMPLES:
1013         lpTime->u.sample = val * 8 / wwo->format.wBitsPerSample;
1014         TRACE("TIME_SAMPLES=%lu\n", lpTime->u.sample);
1015         break;
1016     case TIME_SMPTE:
1017         time = val / (wwo->format.wf.nAvgBytesPerSec / 1000);
1018         lpTime->u.smpte.hour = time / 108000;
1019         time -= lpTime->u.smpte.hour * 108000;
1020         lpTime->u.smpte.min = time / 1800;
1021         time -= lpTime->u.smpte.min * 1800;
1022         lpTime->u.smpte.sec = time / 30;
1023         time -= lpTime->u.smpte.sec * 30;
1024         lpTime->u.smpte.frame = time;
1025         lpTime->u.smpte.fps = 30;
1026         TRACE("TIME_SMPTE=%02u:%02u:%02u:%02u\n",
1027               lpTime->u.smpte.hour, lpTime->u.smpte.min,
1028               lpTime->u.smpte.sec, lpTime->u.smpte.frame);
1029         break;
1030     default:
1031         FIXME("Format %d not supported ! use TIME_MS !\n", lpTime->wType);
1032         lpTime->wType = TIME_MS;
1033     case TIME_MS:
1034         lpTime->u.ms = val / (wwo->format.wf.nAvgBytesPerSec / 1000);
1035         TRACE("TIME_MS=%lu\n", lpTime->u.ms);
1036         break;
1037     }
1038     return MMSYSERR_NOERROR;
1039 }
1040
1041 /**************************************************************************
1042  *                              wodGetVolume                    [internal]
1043  */
1044 static DWORD wodGetVolume(WORD wDevID, LPDWORD lpdwVol)
1045 {
1046     int         mixer;
1047     int         volume;
1048     DWORD       left, right;
1049     
1050     TRACE("(%u, %p);\n", wDevID, lpdwVol);
1051     
1052     if (lpdwVol == NULL) 
1053         return MMSYSERR_NOTENABLED;
1054     if ((mixer = open(MIXER_DEV, O_RDONLY|O_NDELAY)) < 0) {
1055         WARN("mixer device not available !\n");
1056         return MMSYSERR_NOTENABLED;
1057     }
1058     if (ioctl(mixer, SOUND_MIXER_READ_PCM, &volume) == -1) {
1059         WARN("unable read mixer !\n");
1060         return MMSYSERR_NOTENABLED;
1061     }
1062     close(mixer);
1063     left = LOBYTE(volume);
1064     right = HIBYTE(volume);
1065     TRACE("left=%ld right=%ld !\n", left, right);
1066     *lpdwVol = ((left * 0xFFFFl) / 100) + (((right * 0xFFFFl) / 100) << 16);
1067     return MMSYSERR_NOERROR;
1068 }
1069
1070
1071 /**************************************************************************
1072  *                              wodSetVolume                    [internal]
1073  */
1074 static DWORD wodSetVolume(WORD wDevID, DWORD dwParam)
1075 {
1076     int         mixer;
1077     int         volume;
1078     DWORD       left, right;
1079
1080     TRACE("(%u, %08lX);\n", wDevID, dwParam);
1081
1082     left  = (LOWORD(dwParam) * 100) / 0xFFFFl;
1083     right = (HIWORD(dwParam) * 100) / 0xFFFFl;
1084     volume = left + (right << 8);
1085     
1086     if ((mixer = open(MIXER_DEV, O_WRONLY|O_NDELAY)) < 0) {
1087         WARN("mixer device not available !\n");
1088         return MMSYSERR_NOTENABLED;
1089     }
1090     if (ioctl(mixer, SOUND_MIXER_WRITE_PCM, &volume) == -1) {
1091         WARN("unable set mixer !\n");
1092         return MMSYSERR_NOTENABLED;
1093     } else {
1094         TRACE("volume=%04x\n", (unsigned)volume);
1095     }
1096     close(mixer);
1097     return MMSYSERR_NOERROR;
1098 }
1099
1100 /**************************************************************************
1101  *                              wodGetNumDevs                   [internal]
1102  */
1103 static  DWORD   wodGetNumDevs(void)
1104 {
1105     DWORD       ret = 1;
1106     
1107     /* FIXME: For now, only one sound device (SOUND_DEV) is allowed */
1108     int audio = open(SOUND_DEV, O_WRONLY|O_NDELAY, 0);
1109     
1110     if (audio == -1) {
1111         if (errno != EBUSY)
1112             ret = 0;
1113     } else {
1114         close(audio);
1115     }
1116     return ret;
1117 }
1118
1119 /**************************************************************************
1120  *                              OSS_wodMessage          [sample driver]
1121  */
1122 DWORD WINAPI OSS_wodMessage(UINT wDevID, UINT wMsg, DWORD dwUser, 
1123                             DWORD dwParam1, DWORD dwParam2)
1124 {
1125     TRACE("(%u, %04X, %08lX, %08lX, %08lX);\n",
1126           wDevID, wMsg, dwUser, dwParam1, dwParam2);
1127     
1128     switch (wMsg) {
1129     case DRVM_INIT:
1130     case DRVM_EXIT:
1131     case DRVM_ENABLE:
1132     case DRVM_DISABLE:
1133         /* FIXME: Pretend this is supported */
1134         return 0;
1135     case WODM_OPEN:             return wodOpen          (wDevID, (LPWAVEOPENDESC)dwParam1,      dwParam2);
1136     case WODM_CLOSE:            return wodClose         (wDevID);
1137     case WODM_WRITE:            return wodWrite         (wDevID, (LPWAVEHDR)dwParam1,           dwParam2);
1138     case WODM_PAUSE:            return wodPause         (wDevID);
1139     case WODM_GETPOS:           return wodGetPosition   (wDevID, (LPMMTIME)dwParam1,            dwParam2);
1140     case WODM_BREAKLOOP:        return MMSYSERR_NOTSUPPORTED;
1141     case WODM_PREPARE:          return wodPrepare       (wDevID, (LPWAVEHDR)dwParam1,           dwParam2);
1142     case WODM_UNPREPARE:        return wodUnprepare     (wDevID, (LPWAVEHDR)dwParam1,           dwParam2);
1143     case WODM_GETDEVCAPS:       return wodGetDevCaps    (wDevID, (LPWAVEOUTCAPSA)dwParam1,      dwParam2);
1144     case WODM_GETNUMDEVS:       return wodGetNumDevs    ();
1145     case WODM_GETPITCH:         return MMSYSERR_NOTSUPPORTED;
1146     case WODM_SETPITCH:         return MMSYSERR_NOTSUPPORTED;
1147     case WODM_GETPLAYBACKRATE:  return MMSYSERR_NOTSUPPORTED;
1148     case WODM_SETPLAYBACKRATE:  return MMSYSERR_NOTSUPPORTED;
1149     case WODM_GETVOLUME:        return wodGetVolume     (wDevID, (LPDWORD)dwParam1);
1150     case WODM_SETVOLUME:        return wodSetVolume     (wDevID, dwParam1);
1151     case WODM_RESTART:          return wodRestart       (wDevID);
1152     case WODM_RESET:            return wodReset         (wDevID);
1153     case 0x810:                 return wodDsCreate(wDevID, (PIDSDRIVER*)dwParam1);
1154     default:
1155         FIXME("unknown message %d!\n", wMsg);
1156     }
1157     return MMSYSERR_NOTSUPPORTED;
1158 }
1159
1160 /*======================================================================*
1161  *                  Low level DSOUND implementation                     *
1162  *======================================================================*/
1163
1164 typedef struct IDsDriverImpl IDsDriverImpl;
1165 typedef struct IDsDriverBufferImpl IDsDriverBufferImpl;
1166
1167 struct IDsDriverImpl
1168 {
1169     /* IUnknown fields */
1170     ICOM_VFIELD(IDsDriver);
1171     DWORD               ref;
1172     /* IDsDriverImpl fields */
1173     UINT                wDevID;
1174     IDsDriverBufferImpl*primary;
1175 };
1176
1177 struct IDsDriverBufferImpl
1178 {
1179     /* IUnknown fields */
1180     ICOM_VFIELD(IDsDriverBuffer);
1181     DWORD               ref;
1182     /* IDsDriverBufferImpl fields */
1183     IDsDriverImpl*      drv;
1184     DWORD               buflen;
1185 };
1186
1187 static HRESULT DSDB_MapPrimary(IDsDriverBufferImpl *dsdb)
1188 {
1189     WINE_WAVEOUT *wwo = &(WOutDev[dsdb->drv->wDevID]);
1190     if (!wwo->mapping) {
1191         wwo->mapping = mmap(NULL, wwo->maplen, PROT_WRITE, MAP_SHARED,
1192                             wwo->unixdev, 0);
1193         if (wwo->mapping == (LPBYTE)-1) {
1194             ERR("(%p): Could not map sound device for direct access (errno=%d)\n", dsdb, errno);
1195             return DSERR_GENERIC;
1196         }
1197         TRACE("(%p): sound device has been mapped for direct access at %p, size=%ld\n", dsdb, wwo->mapping, wwo->maplen);
1198     }
1199     return DS_OK;
1200 }
1201
1202 static HRESULT DSDB_UnmapPrimary(IDsDriverBufferImpl *dsdb)
1203 {
1204     WINE_WAVEOUT *wwo = &(WOutDev[dsdb->drv->wDevID]);
1205     if (wwo->mapping) {
1206         if (munmap(wwo->mapping, wwo->maplen) < 0) {
1207             ERR("(%p): Could not unmap sound device (errno=%d)\n", dsdb, errno);
1208             return DSERR_GENERIC;
1209         }
1210         wwo->mapping = NULL;
1211         TRACE("(%p): sound device unmapped\n", dsdb);
1212     }
1213     return DS_OK;
1214 }
1215
1216 static HRESULT WINAPI IDsDriverBufferImpl_QueryInterface(PIDSDRIVERBUFFER iface, REFIID riid, LPVOID *ppobj)
1217 {
1218     /* ICOM_THIS(IDsDriverBufferImpl,iface); */
1219     FIXME("(): stub!\n");
1220     return DSERR_UNSUPPORTED;
1221 }
1222
1223 static ULONG WINAPI IDsDriverBufferImpl_AddRef(PIDSDRIVERBUFFER iface)
1224 {
1225     ICOM_THIS(IDsDriverBufferImpl,iface);
1226     This->ref++;
1227     return This->ref;
1228 }
1229
1230 static ULONG WINAPI IDsDriverBufferImpl_Release(PIDSDRIVERBUFFER iface)
1231 {
1232     ICOM_THIS(IDsDriverBufferImpl,iface);
1233     if (--This->ref)
1234         return This->ref;
1235     if (This == This->drv->primary)
1236         This->drv->primary = NULL;
1237     DSDB_UnmapPrimary(This);
1238     HeapFree(GetProcessHeap(),0,This);
1239     return 0;
1240 }
1241
1242 static HRESULT WINAPI IDsDriverBufferImpl_Lock(PIDSDRIVERBUFFER iface,
1243                                                LPVOID*ppvAudio1,LPDWORD pdwLen1,
1244                                                LPVOID*ppvAudio2,LPDWORD pdwLen2,
1245                                                DWORD dwWritePosition,DWORD dwWriteLen,
1246                                                DWORD dwFlags)
1247 {
1248     /* ICOM_THIS(IDsDriverBufferImpl,iface); */
1249     /* since we (GetDriverDesc flags) have specified DSDDESC_DONTNEEDPRIMARYLOCK,
1250      * and that we don't support secondary buffers, this method will never be called */
1251     TRACE("(%p): stub\n",iface);
1252     return DSERR_UNSUPPORTED;
1253 }
1254
1255 static HRESULT WINAPI IDsDriverBufferImpl_Unlock(PIDSDRIVERBUFFER iface,
1256                                                  LPVOID pvAudio1,DWORD dwLen1,
1257                                                  LPVOID pvAudio2,DWORD dwLen2)
1258 {
1259     /* ICOM_THIS(IDsDriverBufferImpl,iface); */
1260     TRACE("(%p): stub\n",iface);
1261     return DSERR_UNSUPPORTED;
1262 }
1263
1264 static HRESULT WINAPI IDsDriverBufferImpl_SetFormat(PIDSDRIVERBUFFER iface,
1265                                                     LPWAVEFORMATEX pwfx)
1266 {
1267     /* ICOM_THIS(IDsDriverBufferImpl,iface); */
1268
1269     TRACE("(%p,%p)\n",iface,pwfx);
1270     /* On our request (GetDriverDesc flags), DirectSound has by now used
1271      * waveOutClose/waveOutOpen to set the format...
1272      * unfortunately, this means our mmap() is now gone...
1273      * so we need to somehow signal to our DirectSound implementation
1274      * that it should completely recreate this HW buffer...
1275      * this unexpected error code should do the trick... */
1276     return DSERR_BUFFERLOST;
1277 }
1278
1279 static HRESULT WINAPI IDsDriverBufferImpl_SetFrequency(PIDSDRIVERBUFFER iface, DWORD dwFreq)
1280 {
1281     /* ICOM_THIS(IDsDriverBufferImpl,iface); */
1282     TRACE("(%p,%ld): stub\n",iface,dwFreq);
1283     return DSERR_UNSUPPORTED;
1284 }
1285
1286 static HRESULT WINAPI IDsDriverBufferImpl_SetVolumePan(PIDSDRIVERBUFFER iface, PDSVOLUMEPAN pVolPan)
1287 {
1288     /* ICOM_THIS(IDsDriverBufferImpl,iface); */
1289     FIXME("(%p,%p): stub!\n",iface,pVolPan);
1290     return DSERR_UNSUPPORTED;
1291 }
1292
1293 static HRESULT WINAPI IDsDriverBufferImpl_SetPosition(PIDSDRIVERBUFFER iface, DWORD dwNewPos)
1294 {
1295     /* ICOM_THIS(IDsDriverImpl,iface); */
1296     TRACE("(%p,%ld): stub\n",iface,dwNewPos);
1297     return DSERR_UNSUPPORTED;
1298 }
1299
1300 static HRESULT WINAPI IDsDriverBufferImpl_GetPosition(PIDSDRIVERBUFFER iface,
1301                                                       LPDWORD lpdwPlay, LPDWORD lpdwWrite)
1302 {
1303     ICOM_THIS(IDsDriverBufferImpl,iface);
1304     count_info info;
1305     DWORD ptr;
1306
1307     TRACE("(%p)\n",iface);
1308     if (ioctl(WOutDev[This->drv->wDevID].unixdev, SNDCTL_DSP_GETOPTR, &info) < 0) {
1309         ERR("ioctl failed (%d)\n", errno);
1310         return DSERR_GENERIC;
1311     }
1312     ptr = info.ptr & ~3; /* align the pointer, just in case */
1313     if (lpdwPlay) *lpdwPlay = ptr;
1314     if (lpdwWrite) {
1315         /* add some safety margin (not strictly necessary, but...) */
1316         *lpdwWrite = ptr + 32;
1317         while (*lpdwWrite > This->buflen)
1318             *lpdwWrite -= This->buflen;
1319     }
1320     TRACE("playpos=%ld, writepos=%ld\n", lpdwPlay?*lpdwPlay:0, lpdwWrite?*lpdwWrite:0);
1321     return DSERR_UNSUPPORTED;
1322 }
1323
1324 static HRESULT WINAPI IDsDriverBufferImpl_Play(PIDSDRIVERBUFFER iface, DWORD dwRes1, DWORD dwRes2, DWORD dwFlags)
1325 {
1326     ICOM_THIS(IDsDriverBufferImpl,iface);
1327     int enable = PCM_ENABLE_OUTPUT;
1328     TRACE("(%p,%lx,%lx,%lx)\n",iface,dwRes1,dwRes2,dwFlags);
1329     if (ioctl(WOutDev[This->drv->wDevID].unixdev, SNDCTL_DSP_SETTRIGGER, &enable) < 0) {
1330         ERR("ioctl failed (%d)\n", errno);
1331         return DSERR_GENERIC;
1332     }
1333     return DS_OK;
1334 }
1335
1336 static HRESULT WINAPI IDsDriverBufferImpl_Stop(PIDSDRIVERBUFFER iface)
1337 {
1338     ICOM_THIS(IDsDriverBufferImpl,iface);
1339     int enable = 0;
1340     TRACE("(%p)\n",iface);
1341     /* no more playing */
1342     if (ioctl(WOutDev[This->drv->wDevID].unixdev, SNDCTL_DSP_SETTRIGGER, &enable) < 0) {
1343         ERR("ioctl failed (%d)\n", errno);
1344         return DSERR_GENERIC;
1345     }
1346 #if 0
1347     /* the play position must be reset to the beginning of the buffer */
1348     if (ioctl(WOutDev[This->drv->wDevID].unixdev, SNDCTL_DSP_RESET, 0) < 0) {
1349         ERR("ioctl failed (%d)\n", errno);
1350         return DSERR_GENERIC;
1351     }
1352 #endif
1353     return DS_OK;
1354 }
1355
1356 static ICOM_VTABLE(IDsDriverBuffer) dsdbvt =
1357 {
1358     ICOM_MSVTABLE_COMPAT_DummyRTTIVALUE
1359     IDsDriverBufferImpl_QueryInterface,
1360     IDsDriverBufferImpl_AddRef,
1361     IDsDriverBufferImpl_Release,
1362     IDsDriverBufferImpl_Lock,
1363     IDsDriverBufferImpl_Unlock,
1364     IDsDriverBufferImpl_SetFormat,
1365     IDsDriverBufferImpl_SetFrequency,
1366     IDsDriverBufferImpl_SetVolumePan,
1367     IDsDriverBufferImpl_SetPosition,
1368     IDsDriverBufferImpl_GetPosition,
1369     IDsDriverBufferImpl_Play,
1370     IDsDriverBufferImpl_Stop
1371 };
1372
1373 static HRESULT WINAPI IDsDriverImpl_QueryInterface(PIDSDRIVER iface, REFIID riid, LPVOID *ppobj)
1374 {
1375     /* ICOM_THIS(IDsDriverImpl,iface); */
1376     FIXME("(%p): stub!\n",iface);
1377     return DSERR_UNSUPPORTED;
1378 }
1379
1380 static ULONG WINAPI IDsDriverImpl_AddRef(PIDSDRIVER iface)
1381 {
1382     ICOM_THIS(IDsDriverImpl,iface);
1383     This->ref++;
1384     return This->ref;
1385 }
1386
1387 static ULONG WINAPI IDsDriverImpl_Release(PIDSDRIVER iface)
1388 {
1389     ICOM_THIS(IDsDriverImpl,iface);
1390     if (--This->ref)
1391         return This->ref;
1392     HeapFree(GetProcessHeap(),0,This);
1393     return 0;
1394 }
1395
1396 static HRESULT WINAPI IDsDriverImpl_GetDriverDesc(PIDSDRIVER iface, PDSDRIVERDESC pDesc)
1397 {
1398     ICOM_THIS(IDsDriverImpl,iface);
1399     TRACE("(%p,%p)\n",iface,pDesc);
1400     pDesc->dwFlags = DSDDESC_DOMMSYSTEMOPEN | DSDDESC_DOMMSYSTEMSETFORMAT |
1401         DSDDESC_USESYSTEMMEMORY | DSDDESC_DONTNEEDPRIMARYLOCK;
1402     strcpy(pDesc->szDesc,"WineOSS DirectSound Driver");
1403     strcpy(pDesc->szDrvName,"wineoss.drv");
1404     pDesc->dnDevNode            = WOutDev[This->wDevID].waveDesc.dnDevNode;
1405     pDesc->wVxdId               = 0; 
1406     pDesc->wReserved            = 0;
1407     pDesc->ulDeviceNum          = This->wDevID;
1408     pDesc->dwHeapType           = DSDHEAP_NOHEAP;
1409     pDesc->pvDirectDrawHeap     = NULL;
1410     pDesc->dwMemStartAddress    = 0;
1411     pDesc->dwMemEndAddress      = 0;
1412     pDesc->dwMemAllocExtra      = 0;
1413     pDesc->pvReserved1          = NULL;
1414     pDesc->pvReserved2          = NULL;
1415     return DS_OK;
1416 }
1417
1418 static HRESULT WINAPI IDsDriverImpl_Open(PIDSDRIVER iface)
1419 {
1420     ICOM_THIS(IDsDriverImpl,iface);
1421     int enable = 0;
1422
1423     TRACE("(%p)\n",iface);
1424     /* make sure the card doesn't start playing before we want it to */
1425     if (ioctl(WOutDev[This->wDevID].unixdev, SNDCTL_DSP_SETTRIGGER, &enable) < 0) {
1426         ERR("ioctl failed (%d)\n", errno);
1427         return DSERR_GENERIC;
1428     }
1429     return DS_OK;
1430 }
1431
1432 static HRESULT WINAPI IDsDriverImpl_Close(PIDSDRIVER iface)
1433 {
1434     ICOM_THIS(IDsDriverImpl,iface);
1435     TRACE("(%p)\n",iface);
1436     if (This->primary) {
1437         ERR("problem with DirectSound: primary not released\n");
1438         return DSERR_GENERIC;
1439     }
1440     return DS_OK;
1441 }
1442
1443 static HRESULT WINAPI IDsDriverImpl_GetCaps(PIDSDRIVER iface, PDSDRIVERCAPS pCaps)
1444 {
1445     /* ICOM_THIS(IDsDriverImpl,iface); */
1446     TRACE("(%p,%p)\n",iface,pCaps);
1447     memset(pCaps, 0, sizeof(*pCaps));
1448     /* FIXME: need to check actual capabilities */
1449     pCaps->dwFlags = DSCAPS_PRIMARYMONO | DSCAPS_PRIMARYSTEREO |
1450         DSCAPS_PRIMARY8BIT | DSCAPS_PRIMARY16BIT;
1451     pCaps->dwPrimaryBuffers = 1;
1452     /* the other fields only apply to secondary buffers, which we don't support
1453      * (unless we want to mess with wavetable synthesizers and MIDI) */
1454     return DS_OK;
1455 }
1456
1457 static HRESULT WINAPI IDsDriverImpl_CreateSoundBuffer(PIDSDRIVER iface,
1458                                                       LPWAVEFORMATEX pwfx,
1459                                                       DWORD dwFlags, DWORD dwCardAddress,
1460                                                       LPDWORD pdwcbBufferSize,
1461                                                       LPBYTE *ppbBuffer,
1462                                                       LPVOID *ppvObj)
1463 {
1464     ICOM_THIS(IDsDriverImpl,iface);
1465     IDsDriverBufferImpl** ippdsdb = (IDsDriverBufferImpl**)ppvObj;
1466     HRESULT err;
1467     audio_buf_info info;
1468
1469     TRACE("(%p,%p,%lx,%lx)\n",iface,pwfx,dwFlags,dwCardAddress);
1470     /* we only support primary buffers */
1471     if (!(dwFlags & DSBCAPS_PRIMARYBUFFER))
1472         return DSERR_UNSUPPORTED;
1473     if (This->primary)
1474         return DSERR_ALLOCATED;
1475     if (dwFlags & (DSBCAPS_CTRLFREQUENCY | DSBCAPS_CTRLPAN))
1476         return DSERR_CONTROLUNAVAIL;
1477
1478     *ippdsdb = (IDsDriverBufferImpl*)HeapAlloc(GetProcessHeap(),0,sizeof(IDsDriverBufferImpl));
1479     if (*ippdsdb == NULL)
1480         return DSERR_OUTOFMEMORY;
1481     ICOM_VTBL(*ippdsdb) = &dsdbvt;
1482     (*ippdsdb)->ref     = 1;
1483     (*ippdsdb)->drv     = This;
1484
1485     /* check how big the DMA buffer is now */
1486     if (ioctl(WOutDev[This->wDevID].unixdev, SNDCTL_DSP_GETOSPACE, &info) < 0) {
1487         ERR("ioctl failed (%d)\n", errno);
1488         HeapFree(GetProcessHeap(),0,*ippdsdb);
1489         *ippdsdb = NULL;
1490         return DSERR_GENERIC;
1491     }
1492     WOutDev[This->wDevID].maplen = (*ippdsdb)->buflen = info.fragstotal * info.fragsize;
1493
1494     /* map the DMA buffer */
1495     err = DSDB_MapPrimary(*ippdsdb);
1496     if (err != DS_OK) {
1497         HeapFree(GetProcessHeap(),0,*ippdsdb);
1498         *ippdsdb = NULL;
1499         return err;
1500     }
1501
1502     /* primary buffer is ready to go */
1503     *pdwcbBufferSize    = WOutDev[This->wDevID].maplen;
1504     *ppbBuffer          = WOutDev[This->wDevID].mapping;
1505
1506     This->primary = *ippdsdb;
1507
1508     return DS_OK;
1509 }
1510
1511 static HRESULT WINAPI IDsDriverImpl_DuplicateSoundBuffer(PIDSDRIVER iface,
1512                                                          PIDSDRIVERBUFFER pBuffer,
1513                                                          LPVOID *ppvObj)
1514 {
1515     /* ICOM_THIS(IDsDriverImpl,iface); */
1516     TRACE("(%p,%p): stub\n",iface,pBuffer);
1517     return DSERR_INVALIDCALL;
1518 }
1519
1520 static ICOM_VTABLE(IDsDriver) dsdvt =
1521 {
1522     ICOM_MSVTABLE_COMPAT_DummyRTTIVALUE
1523     IDsDriverImpl_QueryInterface,
1524     IDsDriverImpl_AddRef,
1525     IDsDriverImpl_Release,
1526     IDsDriverImpl_GetDriverDesc,
1527     IDsDriverImpl_Open,
1528     IDsDriverImpl_Close,
1529     IDsDriverImpl_GetCaps,
1530     IDsDriverImpl_CreateSoundBuffer,
1531     IDsDriverImpl_DuplicateSoundBuffer
1532 };
1533
1534 static DWORD wodDsCreate(UINT wDevID, PIDSDRIVER* drv)
1535 {
1536     IDsDriverImpl** idrv = (IDsDriverImpl**)drv;
1537
1538     /* the HAL isn't much better than the HEL if we can't do mmap() */
1539     if (!(WOutDev[wDevID].caps.dwSupport & WAVECAPS_DIRECTSOUND)) {
1540         ERR("DirectSound flag not set\n");
1541         MESSAGE("This sound card's driver does not support direct access\n");
1542         MESSAGE("The (slower) DirectSound HEL mode will be used instead.\n");
1543         return MMSYSERR_NOTSUPPORTED;
1544     }
1545
1546     *idrv = (IDsDriverImpl*)HeapAlloc(GetProcessHeap(),0,sizeof(IDsDriverImpl));
1547     if (!*idrv)
1548         return MMSYSERR_NOMEM;
1549     ICOM_VTBL(*idrv)    = &dsdvt;
1550     (*idrv)->ref        = 1;
1551
1552     (*idrv)->wDevID     = wDevID;
1553     (*idrv)->primary    = NULL;
1554     return MMSYSERR_NOERROR;
1555 }
1556
1557 /*======================================================================*
1558  *                  Low level WAVE IN implemantation                    *
1559  *======================================================================*/
1560
1561 /**************************************************************************
1562  *                      widGetDevCaps                           [internal]
1563  */
1564 static DWORD widGetDevCaps(WORD wDevID, LPWAVEINCAPSA lpCaps, DWORD dwSize)
1565 {
1566     TRACE("(%u, %p, %lu);\n", wDevID, lpCaps, dwSize);
1567     
1568     if (lpCaps == NULL) return MMSYSERR_NOTENABLED;
1569     
1570     if (wDevID >= MAX_WAVEINDRV) {
1571         TRACE("MAX_WAVINDRV reached !\n");
1572         return MMSYSERR_BADDEVICEID;
1573     }
1574
1575     memcpy(lpCaps, &WInDev[wDevID].caps, min(dwSize, sizeof(*lpCaps)));
1576     return MMSYSERR_NOERROR;
1577 }
1578
1579 /**************************************************************************
1580  *                              widRecorder                     [internal]
1581  */
1582 static  DWORD   CALLBACK        widRecorder(LPVOID pmt)
1583 {
1584     WORD                uDevID = (DWORD)pmt;
1585     WINE_WAVEIN*        wwi = (WINE_WAVEIN*)&WInDev[uDevID];
1586     WAVEHDR*            lpWaveHdr;
1587     DWORD               dwSleepTime;
1588     MSG                 msg;
1589     DWORD               bytesRead;
1590
1591     PeekMessageA(&msg, 0, 0, 0, 0);
1592     wwi->state = WINE_WS_STOPPED;
1593     wwi->dwTotalRecorded = 0;
1594
1595     TRACE("imhere[0]\n");
1596     SetEvent(wwi->hEvent);
1597
1598     /* make sleep time to be # of ms to output a fragment */
1599     dwSleepTime = (wwi->dwFragmentSize * 1000) / wwi->format.wf.nAvgBytesPerSec;
1600
1601     for (;;) {
1602         /* wait for dwSleepTime or an event in thread's queue */
1603         /* FIXME: could improve wait time depending on queue state,
1604          * ie, number of queued fragments
1605          */
1606         TRACE("imhere[1]\n");
1607
1608         if (wwi->lpQueuePtr != NULL) {
1609             lpWaveHdr = wwi->lpQueuePtr;
1610             TRACE("recording buf=%p size=%lu/read=%lu \n",
1611                   lpWaveHdr->lpData, wwi->lpQueuePtr->dwBufferLength, lpWaveHdr->dwBytesRecorded);
1612
1613             bytesRead = read(wwi->unixdev, lpWaveHdr->lpData + lpWaveHdr->dwBytesRecorded, 
1614                              lpWaveHdr->dwBufferLength - lpWaveHdr->dwBytesRecorded);
1615
1616             if (bytesRead > 0) {
1617                 TRACE("Read=%lu (%ld)\n", bytesRead, lpWaveHdr->dwBufferLength);
1618                 lpWaveHdr->dwBytesRecorded += bytesRead;
1619                 wwi->dwTotalRecorded += bytesRead;
1620                 if (lpWaveHdr->dwBytesRecorded == lpWaveHdr->dwBufferLength) {
1621                     /* removes the current block from the queue */
1622                     wwi->lpQueuePtr = lpWaveHdr->lpNext;
1623
1624                     lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
1625                     lpWaveHdr->dwFlags |= WHDR_DONE;
1626         
1627                     if (OSS_NotifyClient(uDevID, WIM_DATA, (DWORD)lpWaveHdr, lpWaveHdr->dwBytesRecorded) != MMSYSERR_NOERROR) {
1628                         WARN("can't notify client !\n");
1629                     }
1630
1631                 }
1632             } else {
1633                 TRACE("No data (%s)\n", strerror(errno));
1634             }
1635         }
1636
1637         MsgWaitForMultipleObjects(0, NULL, FALSE, dwSleepTime, QS_POSTMESSAGE);
1638         TRACE("imhere[2] (q=%p)\n", wwi->lpQueuePtr);
1639
1640         while (PeekMessageA(&msg, 0, 0, 0, PM_REMOVE)) {
1641             switch (msg.message) {
1642             case WINE_WM_PAUSING:
1643                 wwi->state = WINE_WS_PAUSED;
1644                 SetEvent(wwi->hEvent);
1645                 break;
1646             case WINE_WM_RESTARTING:
1647                 wwi->state = WINE_WS_PLAYING;
1648                 SetEvent(wwi->hEvent);
1649                 break;
1650             case WINE_WM_HEADER:
1651                 lpWaveHdr = (LPWAVEHDR)msg.lParam;
1652                 lpWaveHdr->lpNext = 0;
1653
1654                 /* insert buffer at the end of queue */
1655                 {
1656                     LPWAVEHDR*  wh;
1657                     for (wh = &(wwi->lpQueuePtr); *wh; wh = &((*wh)->lpNext));
1658                     *wh = lpWaveHdr;
1659                 }
1660                 if (wwi->state == WINE_WS_STOPPED)
1661                     wwi->state = WINE_WS_PLAYING;
1662                 break;
1663             case WINE_WM_RESETTING:
1664                 wwi->state = WINE_WS_STOPPED;
1665                 /* return all buffers to the app */
1666                 for (lpWaveHdr = wwi->lpQueuePtr; lpWaveHdr; lpWaveHdr = lpWaveHdr->lpNext) {
1667                     TRACE("reset %p %p\n", lpWaveHdr, lpWaveHdr->lpNext);
1668                     lpWaveHdr->dwFlags &= ~WHDR_INQUEUE;
1669                     lpWaveHdr->dwFlags |= WHDR_DONE;
1670         
1671                     if (OSS_NotifyClient(uDevID, WIM_DATA, (DWORD)lpWaveHdr, 
1672                                          lpWaveHdr->dwBytesRecorded) != MMSYSERR_NOERROR) {
1673                         WARN("can't notify client !\n");
1674                     }
1675                 }
1676                 wwi->lpQueuePtr = NULL;
1677                 SetEvent(wwi->hEvent);
1678                 break;
1679             case WINE_WM_CLOSING:
1680                 wwi->hThread = 0;
1681                 wwi->state = WINE_WS_CLOSED;
1682                 SetEvent(wwi->hEvent);
1683                 ExitThread(0);
1684                 /* shouldn't go here */
1685             default:
1686                 FIXME("unknown message %d\n", msg.message);
1687                 break;
1688             }
1689         }
1690     }
1691     ExitThread(0);
1692     /* just for not generating compilation warnings... should never be executed */
1693     return 0; 
1694 }
1695
1696
1697 /**************************************************************************
1698  *                              widOpen                         [internal]
1699  */
1700 static DWORD widOpen(WORD wDevID, LPWAVEOPENDESC lpDesc, DWORD dwFlags)
1701 {
1702     int                 audio;
1703     int                 fragment_size;
1704     int                 sample_rate;
1705     int                 format;
1706     int                 dsp_stereo;
1707     WINE_WAVEIN*        wwi;
1708
1709     TRACE("(%u, %p, %08lX);\n", wDevID, lpDesc, dwFlags);
1710     if (lpDesc == NULL) {
1711         WARN("Invalid Parameter !\n");
1712         return MMSYSERR_INVALPARAM;
1713     }
1714     if (wDevID >= MAX_WAVEINDRV) return MMSYSERR_BADDEVICEID;
1715
1716     /* only PCM format is supported so far... */
1717     if (lpDesc->lpFormat->wFormatTag != WAVE_FORMAT_PCM ||
1718         lpDesc->lpFormat->nChannels == 0 ||
1719         lpDesc->lpFormat->nSamplesPerSec == 0) {
1720         WARN("Bad format: tag=%04X nChannels=%d nSamplesPerSec=%ld !\n", 
1721              lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
1722              lpDesc->lpFormat->nSamplesPerSec);
1723         return WAVERR_BADFORMAT;
1724     }
1725
1726     if (dwFlags & WAVE_FORMAT_QUERY) {
1727         TRACE("Query format: tag=%04X nChannels=%d nSamplesPerSec=%ld !\n", 
1728              lpDesc->lpFormat->wFormatTag, lpDesc->lpFormat->nChannels,
1729              lpDesc->lpFormat->nSamplesPerSec);
1730         return MMSYSERR_NOERROR;
1731     }
1732
1733     if (access(SOUND_DEV,0) != 0) return MMSYSERR_NOTENABLED;
1734     audio = open(SOUND_DEV, O_RDONLY|O_NDELAY, 0);
1735     if (audio == -1) {
1736         WARN("can't open (%s)!\n", strerror(errno));
1737         return MMSYSERR_ALLOCATED;
1738     }
1739     fcntl(audio, F_SETFD, 1); /* set close on exec flag */
1740
1741     wwi = &WInDev[wDevID];
1742     if (wwi->lpQueuePtr) {
1743         WARN("Should have an empty queue (%p)\n", wwi->lpQueuePtr);
1744         wwi->lpQueuePtr = NULL;
1745     }
1746     wwi->unixdev = audio;
1747     wwi->dwTotalRecorded = 0;
1748     wwi->wFlags = HIWORD(dwFlags & CALLBACK_TYPEMASK);
1749
1750     memcpy(&wwi->waveDesc, lpDesc,           sizeof(WAVEOPENDESC));
1751     memcpy(&wwi->format,   lpDesc->lpFormat, sizeof(PCMWAVEFORMAT));
1752
1753     if (wwi->format.wBitsPerSample == 0) {
1754         WARN("Resetting zeroed wBitsPerSample\n");
1755         wwi->format.wBitsPerSample = 8 *
1756             (wwi->format.wf.nAvgBytesPerSec /
1757              wwi->format.wf.nSamplesPerSec) /
1758             wwi->format.wf.nChannels;
1759     }
1760
1761     sample_rate = wwi->format.wf.nSamplesPerSec;
1762     dsp_stereo = (wwi->format.wf.nChannels > 1) ? TRUE : FALSE;
1763     format = (wwi->format.wBitsPerSample == 16) ? AFMT_S16_LE : AFMT_U8;
1764
1765     IOCTL(audio, SNDCTL_DSP_SETFMT, format);
1766     IOCTL(audio, SNDCTL_DSP_STEREO, dsp_stereo);
1767     IOCTL(audio, SNDCTL_DSP_SPEED,  sample_rate);
1768
1769     /* paranoid checks */
1770     if (format != ((wwi->format.wBitsPerSample == 16) ? AFMT_S16_LE : AFMT_U8))
1771         ERR("Can't set format to %d (%d)\n", 
1772             (wwi->format.wBitsPerSample == 16) ? AFMT_S16_LE : AFMT_U8, format);
1773     if (dsp_stereo != (wwi->format.wf.nChannels > 1) ? 1 : 0) 
1774         ERR("Can't set stereo to %u (%d)\n", 
1775             (wwi->format.wf.nChannels > 1) ? 1 : 0, dsp_stereo);
1776     if (!NEAR_MATCH(sample_rate, wwi->format.wf.nSamplesPerSec))
1777         ERR("Can't set sample_rate to %lu (%d)\n", 
1778             wwi->format.wf.nSamplesPerSec, sample_rate);
1779
1780     IOCTL(audio, SNDCTL_DSP_GETBLKSIZE, fragment_size);
1781     if (fragment_size == -1) {
1782         WARN("IOCTL can't 'SNDCTL_DSP_GETBLKSIZE' !\n");
1783         close(audio);
1784         wwi->unixdev = 0;
1785         return MMSYSERR_NOTENABLED;
1786     }
1787     wwi->dwFragmentSize = fragment_size;
1788
1789     TRACE("wBitsPerSample=%u, nAvgBytesPerSec=%lu, nSamplesPerSec=%lu, nChannels=%u nBlockAlign=%u!\n", 
1790           wwi->format.wBitsPerSample, wwi->format.wf.nAvgBytesPerSec, 
1791           wwi->format.wf.nSamplesPerSec, wwi->format.wf.nChannels,
1792           wwi->format.wf.nBlockAlign);
1793
1794     wwi->hEvent = CreateEventA(NULL, FALSE, FALSE, NULL);
1795     wwi->hThread = CreateThread(NULL, 0, widRecorder, (LPVOID)(DWORD)wDevID, 0, &(wwi->dwThreadID));
1796     WaitForSingleObject(wwi->hEvent, INFINITE);
1797
1798    if (OSS_NotifyClient(wDevID, WIM_OPEN, 0L, 0L) != MMSYSERR_NOERROR) {
1799         WARN("can't notify client !\n");
1800         return MMSYSERR_INVALPARAM;
1801     }
1802     return MMSYSERR_NOERROR;
1803 }
1804
1805 /**************************************************************************
1806  *                              widClose                        [internal]
1807  */
1808 static DWORD widClose(WORD wDevID)
1809 {
1810     WINE_WAVEIN*        wwi;
1811
1812     TRACE("(%u);\n", wDevID);
1813     if (wDevID >= MAX_WAVEINDRV || WInDev[wDevID].unixdev == 0) {
1814         WARN("can't close !\n");
1815         return MMSYSERR_INVALHANDLE;
1816     }
1817
1818     wwi = &WInDev[wDevID];
1819
1820     if (wwi->lpQueuePtr != NULL) {
1821         WARN("still buffers open !\n");
1822         return WAVERR_STILLPLAYING;
1823     }
1824
1825     PostThreadMessageA(wwi->dwThreadID, WINE_WM_CLOSING, 0, 0);
1826     WaitForSingleObject(wwi->hEvent, INFINITE);
1827     CloseHandle(wwi->hEvent);
1828     close(wwi->unixdev);
1829     wwi->unixdev = 0;
1830     wwi->dwFragmentSize = 0;
1831     if (OSS_NotifyClient(wDevID, WIM_CLOSE, 0L, 0L) != MMSYSERR_NOERROR) {
1832         WARN("can't notify client !\n");
1833         return MMSYSERR_INVALPARAM;
1834     }
1835     return MMSYSERR_NOERROR;
1836 }
1837
1838 /**************************************************************************
1839  *                              widAddBuffer            [internal]
1840  */
1841 static DWORD widAddBuffer(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
1842 {
1843     TRACE("(%u, %p, %08lX);\n", wDevID, lpWaveHdr, dwSize);
1844
1845     if (wDevID >= MAX_WAVEINDRV || WInDev[wDevID].unixdev == 0) {
1846         WARN("can't do it !\n");
1847         return MMSYSERR_INVALHANDLE;
1848     }
1849     if (!(lpWaveHdr->dwFlags & WHDR_PREPARED)) {
1850         TRACE("never been prepared !\n");
1851         return WAVERR_UNPREPARED;
1852     }
1853     if (lpWaveHdr->dwFlags & WHDR_INQUEUE) {
1854         TRACE("header already in use !\n");
1855         return WAVERR_STILLPLAYING;
1856     }
1857     lpWaveHdr->dwFlags |= WHDR_INQUEUE;
1858     lpWaveHdr->dwFlags &= ~WHDR_DONE;
1859     lpWaveHdr->dwBytesRecorded = 0;
1860     lpWaveHdr->lpNext = NULL;
1861     PostThreadMessageA(WInDev[wDevID].dwThreadID, WINE_WM_HEADER, 0, (DWORD)lpWaveHdr);
1862     return MMSYSERR_NOERROR;
1863 }
1864
1865 /**************************************************************************
1866  *                              widPrepare                      [internal]
1867  */
1868 static DWORD widPrepare(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
1869 {
1870     TRACE("(%u, %p, %08lX);\n", wDevID, lpWaveHdr, dwSize);
1871
1872     if (wDevID >= MAX_WAVEINDRV) return MMSYSERR_INVALHANDLE;
1873
1874     if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
1875         return WAVERR_STILLPLAYING;
1876
1877     lpWaveHdr->dwFlags |= WHDR_PREPARED;
1878     lpWaveHdr->dwFlags &= ~(WHDR_INQUEUE|WHDR_DONE);
1879     lpWaveHdr->dwBytesRecorded = 0;
1880     TRACE("header prepared !\n");
1881     return MMSYSERR_NOERROR;
1882 }
1883
1884 /**************************************************************************
1885  *                              widUnprepare                    [internal]
1886  */
1887 static DWORD widUnprepare(WORD wDevID, LPWAVEHDR lpWaveHdr, DWORD dwSize)
1888 {
1889     TRACE("(%u, %p, %08lX);\n", wDevID, lpWaveHdr, dwSize);
1890     if (wDevID >= MAX_WAVEINDRV) return MMSYSERR_INVALHANDLE;
1891
1892     if (lpWaveHdr->dwFlags & WHDR_INQUEUE)
1893         return WAVERR_STILLPLAYING;
1894
1895     lpWaveHdr->dwFlags &= ~(WHDR_PREPARED|WHDR_INQUEUE);
1896     lpWaveHdr->dwFlags |= WHDR_DONE;
1897     
1898     return MMSYSERR_NOERROR;
1899 }
1900
1901 /**************************************************************************
1902  *                      widStart                                [internal]
1903  */
1904 static DWORD widStart(WORD wDevID)
1905 {
1906     TRACE("(%u);\n", wDevID);
1907     if (wDevID >= MAX_WAVEINDRV || WInDev[wDevID].unixdev == 0) {
1908         WARN("can't start recording !\n");
1909         return MMSYSERR_INVALHANDLE;
1910     }
1911     
1912     PostThreadMessageA(WInDev[wDevID].dwThreadID, WINE_WM_RESTARTING, 0, 0);
1913     WaitForSingleObject(WInDev[wDevID].hEvent, INFINITE);
1914     
1915     return MMSYSERR_NOERROR;
1916 }
1917
1918 /**************************************************************************
1919  *                      widStop                                 [internal]
1920  */
1921 static DWORD widStop(WORD wDevID)
1922 {
1923     TRACE("(%u);\n", wDevID);
1924     if (wDevID >= MAX_WAVEINDRV || WInDev[wDevID].unixdev == 0) {
1925         WARN("can't stop !\n");
1926         return MMSYSERR_INVALHANDLE;
1927     }
1928     /* FIXME: reset aint stop */
1929     PostThreadMessageA(WInDev[wDevID].dwThreadID, WINE_WM_RESETTING, 0, 0);
1930     WaitForSingleObject(WInDev[wDevID].hEvent, INFINITE);
1931     
1932     return MMSYSERR_NOERROR;
1933 }
1934
1935 /**************************************************************************
1936  *                      widReset                                [internal]
1937  */
1938 static DWORD widReset(WORD wDevID)
1939 {
1940     TRACE("(%u);\n", wDevID);
1941     if (wDevID >= MAX_WAVEINDRV || WInDev[wDevID].unixdev == 0) {
1942         WARN("can't reset !\n");
1943         return MMSYSERR_INVALHANDLE;
1944     }
1945     PostThreadMessageA(WInDev[wDevID].dwThreadID, WINE_WM_RESETTING, 0, 0);
1946     WaitForSingleObject(WInDev[wDevID].hEvent, INFINITE);
1947     return MMSYSERR_NOERROR;
1948 }
1949
1950 /**************************************************************************
1951  *                              widGetPosition                  [internal]
1952  */
1953 static DWORD widGetPosition(WORD wDevID, LPMMTIME lpTime, DWORD uSize)
1954 {
1955     int                 time;
1956     WINE_WAVEIN*        wwi;
1957     
1958     TRACE("(%u, %p, %lu);\n", wDevID, lpTime, uSize);
1959
1960     if (wDevID >= MAX_WAVEINDRV || WInDev[wDevID].unixdev == 0) {
1961         WARN("can't get pos !\n");
1962         return MMSYSERR_INVALHANDLE;
1963     }
1964     if (lpTime == NULL) return MMSYSERR_INVALPARAM;
1965
1966     wwi = &WInDev[wDevID];
1967
1968     TRACE("wType=%04X !\n", lpTime->wType);
1969     TRACE("wBitsPerSample=%u\n", wwi->format.wBitsPerSample); 
1970     TRACE("nSamplesPerSec=%lu\n", wwi->format.wf.nSamplesPerSec); 
1971     TRACE("nChannels=%u\n", wwi->format.wf.nChannels); 
1972     TRACE("nAvgBytesPerSec=%lu\n", wwi->format.wf.nAvgBytesPerSec); 
1973     switch (lpTime->wType) {
1974     case TIME_BYTES:
1975         lpTime->u.cb = wwi->dwTotalRecorded;
1976         TRACE("TIME_BYTES=%lu\n", lpTime->u.cb);
1977         break;
1978     case TIME_SAMPLES:
1979         lpTime->u.sample = wwi->dwTotalRecorded * 8 /
1980             wwi->format.wBitsPerSample;
1981         TRACE("TIME_SAMPLES=%lu\n", lpTime->u.sample);
1982         break;
1983     case TIME_SMPTE:
1984         time = wwi->dwTotalRecorded /
1985             (wwi->format.wf.nAvgBytesPerSec / 1000);
1986         lpTime->u.smpte.hour = time / 108000;
1987         time -= lpTime->u.smpte.hour * 108000;
1988         lpTime->u.smpte.min = time / 1800;
1989         time -= lpTime->u.smpte.min * 1800;
1990         lpTime->u.smpte.sec = time / 30;
1991         time -= lpTime->u.smpte.sec * 30;
1992         lpTime->u.smpte.frame = time;
1993         lpTime->u.smpte.fps = 30;
1994         TRACE("TIME_SMPTE=%02u:%02u:%02u:%02u\n",
1995               lpTime->u.smpte.hour, lpTime->u.smpte.min,
1996               lpTime->u.smpte.sec, lpTime->u.smpte.frame);
1997         break;
1998     case TIME_MS:
1999         lpTime->u.ms = wwi->dwTotalRecorded /
2000             (wwi->format.wf.nAvgBytesPerSec / 1000);
2001         TRACE("TIME_MS=%lu\n", lpTime->u.ms);
2002         break;
2003     default:
2004         FIXME("format not supported (%u) ! use TIME_MS !\n", lpTime->wType);
2005         lpTime->wType = TIME_MS;
2006     }
2007     return MMSYSERR_NOERROR;
2008 }
2009
2010 /**************************************************************************
2011  *                              OSS_widMessage                  [sample driver]
2012  */
2013 DWORD WINAPI OSS_widMessage(WORD wDevID, WORD wMsg, DWORD dwUser, 
2014                             DWORD dwParam1, DWORD dwParam2)
2015 {
2016     TRACE("(%u, %04X, %08lX, %08lX, %08lX);\n",
2017           wDevID, wMsg, dwUser, dwParam1, dwParam2);
2018
2019     switch (wMsg) {
2020     case DRVM_INIT:
2021     case DRVM_EXIT:
2022     case DRVM_ENABLE:
2023     case DRVM_DISABLE:
2024         /* FIXME: Pretend this is supported */
2025         return 0;
2026     case WIDM_OPEN:             return widOpen       (wDevID, (LPWAVEOPENDESC)dwParam1, dwParam2);
2027     case WIDM_CLOSE:            return widClose      (wDevID);
2028     case WIDM_ADDBUFFER:        return widAddBuffer  (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
2029     case WIDM_PREPARE:          return widPrepare    (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
2030     case WIDM_UNPREPARE:        return widUnprepare  (wDevID, (LPWAVEHDR)dwParam1, dwParam2);
2031     case WIDM_GETDEVCAPS:       return widGetDevCaps (wDevID, (LPWAVEINCAPSA)dwParam1, dwParam2);
2032     case WIDM_GETNUMDEVS:       return wodGetNumDevs ();        /* same number of devices in output as in input */
2033     case WIDM_GETPOS:           return widGetPosition(wDevID, (LPMMTIME)dwParam1, dwParam2);
2034     case WIDM_RESET:            return widReset      (wDevID);
2035     case WIDM_START:            return widStart      (wDevID);
2036     case WIDM_STOP:             return widStop       (wDevID);
2037     default:
2038         FIXME("unknown message %u!\n", wMsg);
2039     }
2040     return MMSYSERR_NOTSUPPORTED;
2041 }
2042
2043 #else /* !HAVE_OSS */
2044
2045 /**************************************************************************
2046  *                              OSS_wodMessage                  [sample driver]
2047  */
2048 DWORD WINAPI OSS_wodMessage(WORD wDevID, WORD wMsg, DWORD dwUser, 
2049                             DWORD dwParam1, DWORD dwParam2)
2050 {
2051     FIXME("(%u, %04X, %08lX, %08lX, %08lX):stub\n", wDevID, wMsg, dwUser, dwParam1, dwParam2);
2052     return MMSYSERR_NOTENABLED;
2053 }
2054
2055 /**************************************************************************
2056  *                              OSS_widMessage                  [sample driver]
2057  */
2058 DWORD WINAPI OSS_widMessage(WORD wDevID, WORD wMsg, DWORD dwUser, 
2059                             DWORD dwParam1, DWORD dwParam2)
2060 {
2061     FIXME("(%u, %04X, %08lX, %08lX, %08lX):stub\n", wDevID, wMsg, dwUser, dwParam1, dwParam2);
2062     return MMSYSERR_NOTENABLED;
2063 }
2064
2065 #endif /* HAVE_OSS */