2 * Sample Wine Driver for Advanced Linux Sound System (ALSA)
3 * Based on version <final> of the ALSA API
5 * Copyright 2007 - Maarten Lankhorst
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2.1 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
22 /*======================================================================*
23 * Low level dsound input implementation *
24 *======================================================================*/
27 #include "wine/port.h"
39 #ifdef HAVE_SYS_IOCTL_H
40 # include <sys/ioctl.h>
42 #ifdef HAVE_SYS_MMAN_H
43 # include <sys/mman.h>
53 #include "wine/library.h"
54 #include "wine/unicode.h"
55 #include "wine/debug.h"
59 /* Notify timer checks every 10 ms with a resolution of 2 ms */
60 #define DS_TIME_DEL 10
63 WINE_DEFAULT_DEBUG_CHANNEL(dsalsa
);
65 typedef struct IDsCaptureDriverBufferImpl IDsCaptureDriverBufferImpl
;
67 typedef struct IDsCaptureDriverImpl
69 const IDsCaptureDriverVtbl
*lpVtbl
;
71 IDsCaptureDriverBufferImpl
* capture_buffer
;
73 } IDsCaptureDriverImpl
;
75 typedef struct IDsCaptureDriverNotifyImpl
77 const IDsDriverNotifyVtbl
*lpVtbl
;
79 IDsCaptureDriverBufferImpl
*buffer
;
80 DSBPOSITIONNOTIFY
*notifies
;
81 DWORD nrofnotifies
, playpos
;
83 } IDsCaptureDriverNotifyImpl
;
85 struct IDsCaptureDriverBufferImpl
87 const IDsCaptureDriverBufferVtbl
*lpVtbl
;
89 IDsCaptureDriverImpl
*drv
;
90 IDsCaptureDriverNotifyImpl
*notify
;
92 CRITICAL_SECTION pcm_crst
;
93 LPBYTE mmap_buffer
, presented_buffer
;
94 DWORD mmap_buflen_bytes
, play_looping
, mmap_ofs_bytes
;
97 /* Note: snd_pcm_frames_to_bytes(This->pcm, mmap_buflen_frames) != mmap_buflen_bytes */
98 /* The actual buffer may differ in size from the wanted buffer size */
101 snd_pcm_hw_params_t
*hw_params
;
102 snd_pcm_sw_params_t
*sw_params
;
103 snd_pcm_uframes_t mmap_buflen_frames
, mmap_pos
;
106 static void Capture_CheckNotify(IDsCaptureDriverNotifyImpl
*This
, DWORD from
, DWORD len
)
109 for (i
= 0; i
< This
->nrofnotifies
; ++i
) {
110 LPDSBPOSITIONNOTIFY event
= This
->notifies
+ i
;
111 DWORD offset
= event
->dwOffset
;
112 TRACE("checking %d, position %d, event = %p\n", i
, offset
, event
->hEventNotify
);
114 if (offset
== DSBPN_OFFSETSTOP
) {
116 SetEvent(event
->hEventNotify
);
117 TRACE("signalled event %p (%d)\n", event
->hEventNotify
, i
);
123 if (offset
>= from
&& offset
< (from
+ len
))
125 TRACE("signalled event %p (%d)\n", event
->hEventNotify
, i
);
126 SetEvent(event
->hEventNotify
);
131 static void CALLBACK
Capture_Notify(UINT timerID
, UINT msg
, DWORD_PTR dwUser
, DWORD_PTR dw1
, DWORD_PTR dw2
)
133 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)dwUser
;
134 DWORD last_playpos
, playpos
;
135 PIDSCDRIVERBUFFER iface
= (PIDSCDRIVERBUFFER
)This
;
138 /* Don't deadlock since there is a critical section can be held by the timer api itself while running this code */
139 if (!TryEnterCriticalSection(&This
->pcm_crst
)) return;
141 IDsDriverBuffer_GetPosition(iface
, &playpos
, NULL
);
142 last_playpos
= This
->notify
->playpos
;
143 This
->notify
->playpos
= playpos
;
145 if (snd_pcm_state(This
->pcm
) != SND_PCM_STATE_RUNNING
|| last_playpos
== playpos
|| !This
->notify
->nrofnotifies
|| !This
->notify
->notifies
)
148 if (playpos
< last_playpos
)
150 Capture_CheckNotify(This
->notify
, last_playpos
, This
->mmap_buflen_bytes
);
152 Capture_CheckNotify(This
->notify
, 0, playpos
);
154 else Capture_CheckNotify(This
->notify
, last_playpos
, playpos
- last_playpos
);
157 LeaveCriticalSection(&This
->pcm_crst
);
161 static HRESULT WINAPI
IDsCaptureDriverNotifyImpl_QueryInterface(PIDSDRIVERNOTIFY iface
, REFIID riid
, LPVOID
*ppobj
)
163 IDsCaptureDriverNotifyImpl
*This
= (IDsCaptureDriverNotifyImpl
*)iface
;
164 TRACE("(%p,%s,%p)\n",This
,debugstr_guid(riid
),ppobj
);
166 if ( IsEqualGUID(riid
, &IID_IUnknown
) ||
167 IsEqualGUID(riid
, &IID_IDsDriverNotify
) ) {
168 IDsDriverNotify_AddRef(iface
);
173 FIXME( "Unknown IID %s\n", debugstr_guid(riid
));
176 return E_NOINTERFACE
;
179 static ULONG WINAPI
IDsCaptureDriverNotifyImpl_AddRef(PIDSDRIVERNOTIFY iface
)
181 IDsCaptureDriverNotifyImpl
*This
= (IDsCaptureDriverNotifyImpl
*)iface
;
182 ULONG refCount
= InterlockedIncrement(&This
->ref
);
184 TRACE("(%p) ref was %d\n", This
, refCount
- 1);
189 static ULONG WINAPI
IDsCaptureDriverNotifyImpl_Release(PIDSDRIVERNOTIFY iface
)
191 IDsCaptureDriverNotifyImpl
*This
= (IDsCaptureDriverNotifyImpl
*)iface
;
192 ULONG refCount
= InterlockedDecrement(&This
->ref
);
194 TRACE("(%p) ref was %d\n", This
, refCount
+ 1);
197 This
->buffer
->notify
= NULL
;
200 timeKillEvent(This
->timerID
);
201 timeEndPeriod(DS_TIME_RES
);
203 HeapFree(GetProcessHeap(), 0, This
->notifies
);
204 HeapFree(GetProcessHeap(), 0, This
);
205 TRACE("(%p) released\n", This
);
210 static HRESULT WINAPI
IDsCaptureDriverNotifyImpl_SetNotificationPositions(PIDSDRIVERNOTIFY iface
, DWORD howmuch
, LPCDSBPOSITIONNOTIFY notify
)
212 DWORD len
= howmuch
* sizeof(DSBPOSITIONNOTIFY
);
215 IDsCaptureDriverNotifyImpl
*This
= (IDsCaptureDriverNotifyImpl
*)iface
;
216 TRACE("(%p,0x%08x,%p)\n",This
,howmuch
,notify
);
219 WARN("invalid parameter\n");
220 return DSERR_INVALIDPARAM
;
223 if (TRACE_ON(dsalsa
))
224 for (i
=0;i
<howmuch
; ++i
)
225 TRACE("notify at %d to %p\n", notify
[i
].dwOffset
, notify
[i
].hEventNotify
);
228 EnterCriticalSection(&This
->buffer
->pcm_crst
);
230 /* Make an internal copy of the caller-supplied array.
231 * Replace the existing copy if one is already present. */
233 notifies
= HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, This
->notifies
, len
);
235 notifies
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, len
);
239 LeaveCriticalSection(&This
->buffer
->pcm_crst
);
241 return DSERR_OUTOFMEMORY
;
243 This
->notifies
= notifies
;
244 memcpy(This
->notifies
, notify
, len
);
245 This
->nrofnotifies
= howmuch
;
246 IDsDriverBuffer_GetPosition((PIDSCDRIVERBUFFER
)This
->buffer
, &This
->playpos
, NULL
);
250 timeBeginPeriod(DS_TIME_RES
);
251 This
->timerID
= timeSetEvent(DS_TIME_DEL
, DS_TIME_RES
, Capture_Notify
, (DWORD_PTR
)This
->buffer
, TIME_PERIODIC
| TIME_KILL_SYNCHRONOUS
);
254 LeaveCriticalSection(&This
->buffer
->pcm_crst
);
260 static const IDsDriverNotifyVtbl dscdnvt
=
262 IDsCaptureDriverNotifyImpl_QueryInterface
,
263 IDsCaptureDriverNotifyImpl_AddRef
,
264 IDsCaptureDriverNotifyImpl_Release
,
265 IDsCaptureDriverNotifyImpl_SetNotificationPositions
,
269 /** Convert the position an application sees into a position ALSA sees */
270 static snd_pcm_uframes_t
fakepos_to_realpos(const IDsCaptureDriverBufferImpl
* This
, DWORD fakepos
)
272 snd_pcm_uframes_t realpos
;
273 if (fakepos
< This
->mmap_ofs_bytes
)
274 realpos
= This
->mmap_buflen_bytes
+ fakepos
- This
->mmap_ofs_bytes
;
275 else realpos
= fakepos
- This
->mmap_ofs_bytes
;
276 return snd_pcm_bytes_to_frames(This
->pcm
, realpos
) % This
->mmap_buflen_frames
;
280 /** Convert the position ALSA sees into a position an application sees */
281 static DWORD
realpos_to_fakepos(const IDsCaptureDriverBufferImpl
* This
, snd_pcm_uframes_t realpos
)
283 DWORD realposb
= snd_pcm_frames_to_bytes(This
->pcm
, realpos
);
284 return (realposb
+ This
->mmap_ofs_bytes
) % This
->mmap_buflen_bytes
;
287 /** Raw copy data, with buffer wrap around */
288 static void CopyDataWrap(const IDsCaptureDriverBufferImpl
* This
, LPBYTE dest
, DWORD fromwhere
, DWORD copylen
, DWORD buflen
)
290 DWORD remainder
= buflen
- fromwhere
;
291 if (remainder
>= copylen
)
293 CopyMemory(dest
, This
->mmap_buffer
+ fromwhere
, copylen
);
297 CopyMemory(dest
, This
->mmap_buffer
+ fromwhere
, remainder
);
298 copylen
-= remainder
;
299 CopyMemory(dest
, This
->mmap_buffer
, copylen
);
303 /** Copy data from the mmap buffer to backbuffer, taking into account all wraparounds that may occur */
304 static void CopyData(const IDsCaptureDriverBufferImpl
* This
, snd_pcm_uframes_t fromwhere
, snd_pcm_uframes_t len
)
306 DWORD dlen
= snd_pcm_frames_to_bytes(This
->pcm
, len
) % This
->mmap_buflen_bytes
;
309 DWORD ofs
= realpos_to_fakepos(This
, fromwhere
);
310 DWORD remainder
= This
->mmap_buflen_bytes
- ofs
;
313 DWORD realbuflen
= snd_pcm_frames_to_bytes(This
->pcm
, This
->mmap_buflen_frames
);
314 DWORD realofs
= snd_pcm_frames_to_bytes(This
->pcm
, fromwhere
);
316 if (remainder
>= dlen
)
318 CopyDataWrap(This
, This
->presented_buffer
+ ofs
, realofs
, dlen
, realbuflen
);
322 CopyDataWrap(This
, This
->presented_buffer
+ ofs
, realofs
, remainder
, realbuflen
);
324 CopyDataWrap(This
, This
->presented_buffer
, (realofs
+remainder
)%realbuflen
, dlen
, realbuflen
);
328 /** Fill buffers, for starting and stopping
329 * Alsa won't start playing until everything is filled up
330 * This also updates mmap_pos
332 * Returns: Amount of periods in use so snd_pcm_avail_update
333 * doesn't have to be called up to 4x in GetPosition()
335 static snd_pcm_uframes_t
CommitAll(IDsCaptureDriverBufferImpl
*This
, DWORD forced
)
337 const snd_pcm_channel_area_t
*areas
;
338 snd_pcm_uframes_t used
;
339 const snd_pcm_uframes_t commitahead
= This
->mmap_buflen_frames
;
341 used
= This
->mmap_buflen_frames
- snd_pcm_avail_update(This
->pcm
);
342 TRACE("%p needs to commit to %lu, used: %lu\n", This
, commitahead
, used
);
343 if (used
< commitahead
&& (forced
|| This
->play_looping
))
345 snd_pcm_uframes_t done
, putin
= commitahead
- used
;
348 snd_pcm_mmap_begin(This
->pcm
, &areas
, &This
->mmap_pos
, &putin
);
349 CopyData(This
, This
->mmap_pos
, putin
);
350 done
= snd_pcm_mmap_commit(This
->pcm
, This
->mmap_pos
, putin
);
352 This
->mmap_pos
+= done
;
354 putin
= commitahead
- used
;
356 if (This
->mmap_pos
== This
->mmap_buflen_frames
&& (snd_pcm_sframes_t
)putin
> 0 && This
->play_looping
)
358 This
->mmap_ofs_bytes
+= snd_pcm_frames_to_bytes(This
->pcm
, This
->mmap_buflen_frames
);
359 This
->mmap_ofs_bytes
%= This
->mmap_buflen_bytes
;
361 snd_pcm_mmap_begin(This
->pcm
, &areas
, &This
->mmap_pos
, &putin
);
362 CopyData(This
, This
->mmap_pos
, putin
);
363 done
= snd_pcm_mmap_commit(This
->pcm
, This
->mmap_pos
, putin
);
365 This
->mmap_pos
+= done
;
372 snd_pcm_sframes_t ret
;
374 snd_pcm_uframes_t cap
= snd_pcm_bytes_to_frames(This
->pcm
, This
->mmap_buflen_bytes
);
375 pos
= realpos_to_fakepos(This
, This
->mmap_pos
);
376 if (This
->mmap_pos
+ putin
> cap
)
377 putin
= cap
- This
->mmap_pos
;
378 ret
= snd_pcm_readi(This
->pcm
, This
->presented_buffer
+ pos
, putin
);
381 WARN("Underrun occurred\n");
382 snd_pcm_prepare(This
->pcm
);
383 ret
= snd_pcm_readi(This
->pcm
, This
->presented_buffer
+ pos
, putin
);
384 snd_pcm_start(This
->pcm
);
388 WARN("Committing data: %ld / %s (%ld)\n", ret
, snd_strerror(ret
), putin
);
391 This
->mmap_pos
+= ret
;
393 /* At this point mmap_pos may be >= This->mmap_pos this is harmless
394 * realpos_to_fakepos handles it well, and below it is truncated
397 putin
= commitahead
- used
;
400 pos
= realpos_to_fakepos(This
, This
->mmap_pos
);
401 ret
= snd_pcm_readi(This
->pcm
, This
->presented_buffer
+ pos
, putin
);
404 This
->mmap_pos
+= ret
;
412 if (This
->mmap_pos
>= This
->mmap_buflen_frames
)
414 This
->mmap_ofs_bytes
+= snd_pcm_frames_to_bytes(This
->pcm
, This
->mmap_buflen_frames
);
415 This
->mmap_ofs_bytes
%= This
->mmap_buflen_bytes
;
416 This
->mmap_pos
-= This
->mmap_buflen_frames
;
422 static void CheckXRUN(IDsCaptureDriverBufferImpl
* This
)
424 snd_pcm_state_t state
= snd_pcm_state(This
->pcm
);
425 snd_pcm_sframes_t delay
;
428 snd_pcm_hwsync(This
->pcm
);
429 snd_pcm_delay(This
->pcm
, &delay
);
430 if ( state
== SND_PCM_STATE_XRUN
)
432 err
= snd_pcm_prepare(This
->pcm
);
433 CommitAll(This
, FALSE
);
434 snd_pcm_start(This
->pcm
);
435 WARN("xrun occurred\n");
437 ERR("recovery from xrun failed, prepare failed: %s\n", snd_strerror(err
));
439 else if ( state
== SND_PCM_STATE_SUSPENDED
)
441 int err
= snd_pcm_resume(This
->pcm
);
442 TRACE("recovery from suspension occurred\n");
443 if (err
< 0 && err
!= -EAGAIN
){
444 err
= snd_pcm_prepare(This
->pcm
);
446 ERR("recovery from suspend failed, prepare failed: %s\n", snd_strerror(err
));
449 else if ( state
!= SND_PCM_STATE_RUNNING
)
451 WARN("Unhandled state: %d\n", state
);
456 * Allocate the memory-mapped buffer for direct sound, and set up the
459 static int CreateMMAP(IDsCaptureDriverBufferImpl
* pdbi
)
461 snd_pcm_t
*pcm
= pdbi
->pcm
;
462 snd_pcm_format_t format
;
463 snd_pcm_uframes_t frames
, ofs
, avail
, psize
, boundary
;
464 unsigned int channels
, bits_per_sample
, bits_per_frame
;
466 const snd_pcm_channel_area_t
*areas
;
467 snd_pcm_hw_params_t
*hw_params
= pdbi
->hw_params
;
468 snd_pcm_sw_params_t
*sw_params
= pdbi
->sw_params
;
470 mmap_mode
= snd_pcm_type(pcm
);
472 if (mmap_mode
== SND_PCM_TYPE_HW
)
473 TRACE("mmap'd buffer is a direct hardware buffer.\n");
474 else if (mmap_mode
== SND_PCM_TYPE_DMIX
)
475 TRACE("mmap'd buffer is an ALSA dmix buffer\n");
477 TRACE("mmap'd buffer is an ALSA type %d buffer\n", mmap_mode
);
479 err
= snd_pcm_hw_params_get_period_size(hw_params
, &psize
, NULL
);
480 err
= snd_pcm_hw_params_get_format(hw_params
, &format
);
481 err
= snd_pcm_hw_params_get_buffer_size(hw_params
, &frames
);
482 err
= snd_pcm_hw_params_get_channels(hw_params
, &channels
);
483 bits_per_sample
= snd_pcm_format_physical_width(format
);
484 bits_per_frame
= bits_per_sample
* channels
;
486 if (TRACE_ON(dsalsa
))
487 ALSA_TraceParameters(hw_params
, NULL
, FALSE
);
489 TRACE("format=%s frames=%ld channels=%d bits_per_sample=%d bits_per_frame=%d\n",
490 snd_pcm_format_name(format
), frames
, channels
, bits_per_sample
, bits_per_frame
);
492 pdbi
->mmap_buflen_frames
= frames
;
493 snd_pcm_sw_params_current(pcm
, sw_params
);
494 snd_pcm_sw_params_set_start_threshold(pcm
, sw_params
, 0);
495 snd_pcm_sw_params_get_boundary(sw_params
, &boundary
);
496 snd_pcm_sw_params_set_stop_threshold(pcm
, sw_params
, boundary
);
497 snd_pcm_sw_params_set_silence_threshold(pcm
, sw_params
, INT_MAX
);
498 snd_pcm_sw_params_set_silence_size(pcm
, sw_params
, 0);
499 snd_pcm_sw_params_set_avail_min(pcm
, sw_params
, 0);
500 err
= snd_pcm_sw_params(pcm
, sw_params
);
502 pdbi
->mmap_ofs_bytes
= 0;
505 pdbi
->mmap_buffer
= NULL
;
507 frames
= snd_pcm_bytes_to_frames(pdbi
->pcm
, pdbi
->mmap_buflen_bytes
);
508 snd_pcm_format_set_silence(format
, pdbi
->presented_buffer
, frames
);
513 err
= snd_pcm_mmap_begin(pcm
, &areas
, &ofs
, &avail
);
516 ERR("Can't map sound device for direct access: %s/%d\n", snd_strerror(err
), err
);
517 return DSERR_GENERIC
;
519 snd_pcm_format_set_silence(format
, areas
->addr
, pdbi
->mmap_buflen_frames
);
520 pdbi
->mmap_pos
= ofs
+ snd_pcm_mmap_commit(pcm
, ofs
, 0);
521 pdbi
->mmap_buffer
= areas
->addr
;
524 TRACE("created mmap buffer of %ld frames (%d bytes) at %p\n",
525 pdbi
->mmap_buflen_frames
, pdbi
->mmap_buflen_bytes
, pdbi
->mmap_buffer
);
530 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_QueryInterface(PIDSCDRIVERBUFFER iface
, REFIID riid
, LPVOID
*ppobj
)
532 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
533 if ( IsEqualGUID(riid
, &IID_IUnknown
) ||
534 IsEqualGUID(riid
, &IID_IDsCaptureDriverBuffer
) ) {
535 IDsCaptureDriverBuffer_AddRef(iface
);
540 if ( IsEqualGUID( &IID_IDsDriverNotify
, riid
) ) {
543 This
->notify
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, sizeof(IDsCaptureDriverNotifyImpl
));
545 return DSERR_OUTOFMEMORY
;
546 This
->notify
->lpVtbl
= &dscdnvt
;
547 This
->notify
->buffer
= This
;
549 /* Keep a lock on IDsDriverNotify for ourself, so it is destroyed when the buffer is */
550 IDsDriverNotify_AddRef((PIDSDRIVERNOTIFY
)This
->notify
);
552 IDsDriverNotify_AddRef((PIDSDRIVERNOTIFY
)This
->notify
);
553 *ppobj
= This
->notify
;
557 if ( IsEqualGUID( &IID_IDsDriverPropertySet
, riid
) ) {
558 FIXME("Unsupported interface IID_IDsDriverPropertySet\n");
562 FIXME("(): Unknown interface %s\n", debugstr_guid(riid
));
563 return DSERR_UNSUPPORTED
;
566 static ULONG WINAPI
IDsCaptureDriverBufferImpl_AddRef(PIDSCDRIVERBUFFER iface
)
568 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
569 ULONG refCount
= InterlockedIncrement(&This
->ref
);
571 TRACE("(%p)->(ref before=%u)\n",This
, refCount
- 1);
576 static ULONG WINAPI
IDsCaptureDriverBufferImpl_Release(PIDSCDRIVERBUFFER iface
)
578 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
579 ULONG refCount
= InterlockedDecrement(&This
->ref
);
581 TRACE("(%p)->(ref before=%u)\n",This
, refCount
+ 1);
586 EnterCriticalSection(&This
->pcm_crst
);
588 IDsDriverNotify_Release((PIDSDRIVERNOTIFY
)This
->notify
);
589 TRACE("mmap buffer %p destroyed\n", This
->mmap_buffer
);
591 This
->drv
->capture_buffer
= NULL
;
592 LeaveCriticalSection(&This
->pcm_crst
);
593 This
->pcm_crst
.DebugInfo
->Spare
[0] = 0;
594 DeleteCriticalSection(&This
->pcm_crst
);
596 snd_pcm_drop(This
->pcm
);
597 snd_pcm_close(This
->pcm
);
599 HeapFree(GetProcessHeap(), 0, This
->presented_buffer
);
600 HeapFree(GetProcessHeap(), 0, This
->sw_params
);
601 HeapFree(GetProcessHeap(), 0, This
->hw_params
);
602 HeapFree(GetProcessHeap(), 0, This
);
606 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_Lock(PIDSCDRIVERBUFFER iface
, LPVOID
*ppvAudio1
,LPDWORD pdwLen1
,LPVOID
*ppvAudio2
,LPDWORD pdwLen2
, DWORD dwWritePosition
,DWORD dwWriteLen
, DWORD dwFlags
)
608 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
609 TRACE("(%p,%p,%p,%p,%p,%d,%d,0x%08x)\n", This
, ppvAudio1
, pdwLen1
, ppvAudio2
, pdwLen2
, dwWritePosition
, dwWriteLen
, dwFlags
);
612 *ppvAudio1
= (LPBYTE
)This
->presented_buffer
+ dwWritePosition
;
614 if (dwWritePosition
+ dwWriteLen
<= This
->mmap_buflen_bytes
) {
616 *pdwLen1
= dwWriteLen
;
623 *pdwLen1
= This
->mmap_buflen_bytes
- dwWritePosition
;
625 *ppvAudio2
= This
->presented_buffer
;
627 *pdwLen2
= dwWriteLen
- (This
->mmap_buflen_bytes
- dwWritePosition
);
632 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_Unlock(PIDSCDRIVERBUFFER iface
, LPVOID pvAudio1
,DWORD dwLen1
, LPVOID pvAudio2
,DWORD dwLen2
)
634 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
635 TRACE("(%p,%p,%d,%p,%d)\n",This
,pvAudio1
,dwLen1
,pvAudio2
,dwLen2
);
639 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_SetFormat(PIDSCDRIVERBUFFER iface
, LPWAVEFORMATEX pwfx
)
641 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
642 WINE_WAVEDEV
*wwi
= &WInDev
[This
->drv
->wDevID
];
643 snd_pcm_t
*pcm
= NULL
;
644 snd_pcm_hw_params_t
*hw_params
= This
->hw_params
;
645 snd_pcm_format_t format
= -1;
646 snd_pcm_uframes_t buffer_size
;
647 DWORD rate
= pwfx
->nSamplesPerSec
;
651 TRACE("(%p, %p)\n", iface
, pwfx
);
653 switch (pwfx
->wBitsPerSample
)
655 case 8: format
= SND_PCM_FORMAT_U8
; break;
656 case 16: format
= SND_PCM_FORMAT_S16_LE
; break;
657 case 24: format
= SND_PCM_FORMAT_S24_3LE
; break;
658 case 32: format
= SND_PCM_FORMAT_S32_LE
; break;
659 default: FIXME("Unsupported bpp: %d\n", pwfx
->wBitsPerSample
); return DSERR_GENERIC
;
663 EnterCriticalSection(&This
->pcm_crst
);
665 err
= snd_pcm_open(&pcm
, wwi
->pcmname
, SND_PCM_STREAM_CAPTURE
, SND_PCM_NONBLOCK
);
669 if (errno
!= EBUSY
|| !This
->pcm
)
672 LeaveCriticalSection(&This
->pcm_crst
);
673 WARN("Cannot open sound device: %s\n", snd_strerror(err
));
674 return DSERR_GENERIC
;
676 snd_pcm_drop(This
->pcm
);
677 snd_pcm_close(This
->pcm
);
679 err
= snd_pcm_open(&pcm
, wwi
->pcmname
, SND_PCM_STREAM_CAPTURE
, SND_PCM_NONBLOCK
);
683 LeaveCriticalSection(&This
->pcm_crst
);
684 WARN("Cannot open sound device: %s\n", snd_strerror(err
));
685 return DSERR_BUFFERLOST
;
689 /* Set some defaults */
690 snd_pcm_hw_params_any(pcm
, hw_params
);
692 err
= snd_pcm_hw_params_set_channels(pcm
, hw_params
, pwfx
->nChannels
);
693 if (err
< 0) { WARN("Could not set channels to %d\n", pwfx
->nChannels
); goto err
; }
695 err
= snd_pcm_hw_params_set_format(pcm
, hw_params
, format
);
696 if (err
< 0) { WARN("Could not set format to %d bpp\n", pwfx
->wBitsPerSample
); goto err
; }
698 err
= snd_pcm_hw_params_set_rate_near(pcm
, hw_params
, &rate
, NULL
);
699 if (err
< 0) { rate
= pwfx
->nSamplesPerSec
; WARN("Could not set rate\n"); goto err
; }
701 if (!ALSA_NearMatch(rate
, pwfx
->nSamplesPerSec
))
703 WARN("Could not set sound rate to %d, but instead to %d\n", pwfx
->nSamplesPerSec
, rate
);
704 pwfx
->nSamplesPerSec
= rate
;
705 pwfx
->nAvgBytesPerSec
= rate
* pwfx
->nBlockAlign
;
706 /* Let DirectSound detect this */
709 snd_pcm_hw_params_set_periods_integer(pcm
, hw_params
);
710 buffer_size
= This
->mmap_buflen_bytes
/ pwfx
->nBlockAlign
;
711 snd_pcm_hw_params_set_buffer_size_near(pcm
, hw_params
, &buffer_size
);
713 snd_pcm_hw_params_set_period_time_near(pcm
, hw_params
, (unsigned int*)&buffer_size
, NULL
);
715 err
= snd_pcm_hw_params_set_access (pcm
, hw_params
, SND_PCM_ACCESS_MMAP_INTERLEAVED
);
718 err
= snd_pcm_hw_params_set_access (pcm
, hw_params
, SND_PCM_ACCESS_RW_INTERLEAVED
);
719 if (err
< 0) { WARN("Could not set access\n"); goto err
; }
725 err
= snd_pcm_hw_params(pcm
, hw_params
);
726 if (err
< 0) { WARN("Could not set hw parameters\n"); goto err
; }
730 snd_pcm_drop(This
->pcm
);
731 snd_pcm_close(This
->pcm
);
736 snd_pcm_prepare(This
->pcm
);
740 LeaveCriticalSection(&This
->pcm_crst
);
745 WARN("Failed to apply changes: %s\n", snd_strerror(err
));
753 snd_pcm_hw_params_current(This
->pcm
, This
->hw_params
);
756 LeaveCriticalSection(&This
->pcm_crst
);
757 return DSERR_BADFORMAT
;
760 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_GetPosition(PIDSCDRIVERBUFFER iface
, LPDWORD lpdwCappos
, LPDWORD lpdwReadpos
)
762 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
763 snd_pcm_uframes_t hw_pptr
, hw_wptr
;
765 EnterCriticalSection(&This
->pcm_crst
);
769 FIXME("Bad pointer for pcm: %p\n", This
->pcm
);
770 LeaveCriticalSection(&This
->pcm_crst
);
771 return DSERR_GENERIC
;
774 if (snd_pcm_state(This
->pcm
) != SND_PCM_STATE_RUNNING
)
777 hw_pptr
= This
->mmap_pos
;
781 /* FIXME: Unused at the moment */
782 snd_pcm_uframes_t used
= CommitAll(This
, FALSE
);
784 if (This
->mmap_pos
> used
)
785 hw_pptr
= This
->mmap_pos
- used
;
787 hw_pptr
= This
->mmap_buflen_frames
- used
+ This
->mmap_pos
;
789 hw_wptr
= This
->mmap_pos
;
792 *lpdwCappos
= realpos_to_fakepos(This
, hw_pptr
);
794 *lpdwReadpos
= realpos_to_fakepos(This
, hw_wptr
);
796 LeaveCriticalSection(&This
->pcm_crst
);
798 TRACE("hw_pptr=%u, hw_wptr=%u playpos=%u(%p), writepos=%u(%p)\n", (unsigned int)hw_pptr
, (unsigned int)hw_wptr
, realpos_to_fakepos(This
, hw_pptr
), lpdwCappos
, realpos_to_fakepos(This
, hw_wptr
), lpdwReadpos
);
802 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_GetStatus(PIDSCDRIVERBUFFER iface
, LPDWORD lpdwStatus
)
804 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
805 snd_pcm_state_t state
;
806 TRACE("(%p,%p)\n",iface
,lpdwStatus
);
808 state
= snd_pcm_state(This
->pcm
);
811 case SND_PCM_STATE_XRUN
:
812 case SND_PCM_STATE_SUSPENDED
:
813 case SND_PCM_STATE_RUNNING
:
814 *lpdwStatus
= DSCBSTATUS_CAPTURING
| (This
->play_looping
? DSCBSTATUS_LOOPING
: 0);
821 TRACE("State: %d, flags: 0x%08x\n", state
, *lpdwStatus
);
825 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_Start(PIDSCDRIVERBUFFER iface
, DWORD dwFlags
)
827 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
828 TRACE("(%p,%x)\n",iface
,dwFlags
);
831 EnterCriticalSection(&This
->pcm_crst
);
832 snd_pcm_start(This
->pcm
);
833 This
->play_looping
= !!(dwFlags
& DSCBSTART_LOOPING
);
834 if (!This
->play_looping
)
835 /* Not well supported because of the difference in ALSA size and DSOUND's notion of size
836 * what it does right now is fill the buffer once.. ALSA size */
837 FIXME("Non-looping buffers are not properly supported!\n");
838 CommitAll(This
, TRUE
);
840 if (This
->notify
&& This
->notify
->nrofnotifies
&& This
->notify
->notifies
)
842 DWORD playpos
= realpos_to_fakepos(This
, This
->mmap_pos
);
844 Capture_CheckNotify(This
->notify
, 0, playpos
);
845 This
->notify
->playpos
= playpos
;
849 LeaveCriticalSection(&This
->pcm_crst
);
853 static HRESULT WINAPI
IDsCaptureDriverBufferImpl_Stop(PIDSCDRIVERBUFFER iface
)
855 IDsCaptureDriverBufferImpl
*This
= (IDsCaptureDriverBufferImpl
*)iface
;
856 TRACE("(%p)\n",iface
);
859 EnterCriticalSection(&This
->pcm_crst
);
860 This
->play_looping
= FALSE
;
861 snd_pcm_drop(This
->pcm
);
862 snd_pcm_prepare(This
->pcm
);
864 if (This
->notify
&& This
->notify
->notifies
&& This
->notify
->nrofnotifies
)
865 Capture_CheckNotify(This
->notify
, 0, 0);
868 LeaveCriticalSection(&This
->pcm_crst
);
872 static const IDsCaptureDriverBufferVtbl dsdbvt
=
874 IDsCaptureDriverBufferImpl_QueryInterface
,
875 IDsCaptureDriverBufferImpl_AddRef
,
876 IDsCaptureDriverBufferImpl_Release
,
877 IDsCaptureDriverBufferImpl_Lock
,
878 IDsCaptureDriverBufferImpl_Unlock
,
879 IDsCaptureDriverBufferImpl_SetFormat
,
880 IDsCaptureDriverBufferImpl_GetPosition
,
881 IDsCaptureDriverBufferImpl_GetStatus
,
882 IDsCaptureDriverBufferImpl_Start
,
883 IDsCaptureDriverBufferImpl_Stop
886 static HRESULT WINAPI
IDsCaptureDriverImpl_QueryInterface(PIDSCDRIVER iface
, REFIID riid
, LPVOID
*ppobj
)
888 /* IDsCaptureDriverImpl *This = (IDsCaptureDriverImpl *)iface; */
889 FIXME("(%p): stub!\n",iface
);
890 return DSERR_UNSUPPORTED
;
893 static ULONG WINAPI
IDsCaptureDriverImpl_AddRef(PIDSCDRIVER iface
)
895 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
896 ULONG refCount
= InterlockedIncrement(&This
->ref
);
898 TRACE("(%p)->(ref before=%u)\n",This
, refCount
- 1);
903 static ULONG WINAPI
IDsCaptureDriverImpl_Release(PIDSCDRIVER iface
)
905 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
906 ULONG refCount
= InterlockedDecrement(&This
->ref
);
908 TRACE("(%p)->(ref before=%u)\n",This
, refCount
+ 1);
913 HeapFree(GetProcessHeap(), 0, This
);
917 static HRESULT WINAPI
IDsCaptureDriverImpl_GetDriverDesc(PIDSCDRIVER iface
, PDSDRIVERDESC pDesc
)
919 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
920 TRACE("(%p,%p)\n",iface
,pDesc
);
921 *pDesc
= WInDev
[This
->wDevID
].ds_desc
;
923 pDesc
->dnDevNode
= WInDev
[This
->wDevID
].waveDesc
.dnDevNode
;
925 pDesc
->wReserved
= 0;
926 pDesc
->ulDeviceNum
= This
->wDevID
;
927 pDesc
->dwHeapType
= DSDHEAP_NOHEAP
;
928 pDesc
->pvDirectDrawHeap
= NULL
;
929 pDesc
->dwMemStartAddress
= 0xDEAD0000;
930 pDesc
->dwMemEndAddress
= 0xDEAF0000;
931 pDesc
->dwMemAllocExtra
= 0;
932 pDesc
->pvReserved1
= NULL
;
933 pDesc
->pvReserved2
= NULL
;
937 static HRESULT WINAPI
IDsCaptureDriverImpl_Open(PIDSCDRIVER iface
)
940 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
942 snd_pcm_t
*pcm
= NULL
;
943 snd_pcm_hw_params_t
*hw_params
;
945 /* While this is not really needed, it is a good idea to do this,
946 * to see if sound can be initialized */
948 hw_params
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, snd_pcm_hw_params_sizeof());
951 hr
= DSERR_OUTOFMEMORY
;
952 WARN("--> %08x\n", hr
);
956 err
= snd_pcm_open(&pcm
, WInDev
[This
->wDevID
].pcmname
, SND_PCM_STREAM_CAPTURE
, SND_PCM_NONBLOCK
);
957 if (err
< 0) goto err
;
958 err
= snd_pcm_hw_params_any(pcm
, hw_params
);
959 if (err
< 0) goto err
;
960 err
= snd_pcm_hw_params_set_access (pcm
, hw_params
, SND_PCM_ACCESS_MMAP_INTERLEAVED
);
963 err
= snd_pcm_hw_params_set_access (pcm
, hw_params
, SND_PCM_ACCESS_RW_INTERLEAVED
);
964 if (err
< 0) goto err
;
969 HeapFree(GetProcessHeap(), 0, hw_params
);
974 WARN("Failed to open device: %s\n", snd_strerror(err
));
977 HeapFree(GetProcessHeap(), 0, hw_params
);
978 WARN("--> %08x\n", hr
);
982 static HRESULT WINAPI
IDsCaptureDriverImpl_Close(PIDSCDRIVER iface
)
984 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
985 TRACE("(%p) stub, harmless\n",This
);
989 static HRESULT WINAPI
IDsCaptureDriverImpl_GetCaps(PIDSCDRIVER iface
, PDSCDRIVERCAPS pCaps
)
991 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
992 WINE_WAVEDEV
*wwi
= &WInDev
[This
->wDevID
];
993 TRACE("(%p,%p)\n",iface
,pCaps
);
994 pCaps
->dwSize
= sizeof(DSCDRIVERCAPS
);
995 pCaps
->dwFlags
= wwi
->ds_caps
.dwFlags
;
996 pCaps
->dwFormats
= wwi
->incaps
.dwFormats
;
997 pCaps
->dwChannels
= wwi
->incaps
.wChannels
;
1001 static HRESULT WINAPI
IDsCaptureDriverImpl_CreateCaptureBuffer(PIDSCDRIVER iface
,
1002 LPWAVEFORMATEX pwfx
,
1003 DWORD dwFlags
, DWORD dwCardAddress
,
1004 LPDWORD pdwcbBufferSize
,
1008 IDsCaptureDriverImpl
*This
= (IDsCaptureDriverImpl
*)iface
;
1009 IDsCaptureDriverBufferImpl
** ippdsdb
= (IDsCaptureDriverBufferImpl
**)ppvObj
;
1012 TRACE("(%p,%p,%x,%x)\n",iface
,pwfx
,dwFlags
,dwCardAddress
);
1014 if (This
->capture_buffer
)
1015 return DSERR_ALLOCATED
;
1017 This
->capture_buffer
= *ippdsdb
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, sizeof(IDsCaptureDriverBufferImpl
));
1018 if (*ippdsdb
== NULL
)
1019 return DSERR_OUTOFMEMORY
;
1021 (*ippdsdb
)->hw_params
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, snd_pcm_hw_params_sizeof());
1022 (*ippdsdb
)->sw_params
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, snd_pcm_sw_params_sizeof());
1023 (*ippdsdb
)->presented_buffer
= HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY
, *pdwcbBufferSize
);
1024 if (!(*ippdsdb
)->hw_params
|| !(*ippdsdb
)->sw_params
|| !(*ippdsdb
)->presented_buffer
)
1026 HeapFree(GetProcessHeap(), 0, (*ippdsdb
)->sw_params
);
1027 HeapFree(GetProcessHeap(), 0, (*ippdsdb
)->hw_params
);
1028 HeapFree(GetProcessHeap(), 0, (*ippdsdb
)->presented_buffer
);
1029 return DSERR_OUTOFMEMORY
;
1031 (*ippdsdb
)->lpVtbl
= &dsdbvt
;
1032 (*ippdsdb
)->ref
= 1;
1033 (*ippdsdb
)->drv
= This
;
1034 (*ippdsdb
)->mmap_buflen_bytes
= *pdwcbBufferSize
;
1035 InitializeCriticalSection(&(*ippdsdb
)->pcm_crst
);
1036 (*ippdsdb
)->pcm_crst
.DebugInfo
->Spare
[0] = (DWORD_PTR
)(__FILE__
": ALSA_DSCAPTURE.pcm_crst");
1038 /* SetFormat initialises pcm */
1039 err
= IDsDriverBuffer_SetFormat((IDsDriverBuffer
*)*ppvObj
, pwfx
);
1042 WARN("Error occurred: %08x\n", err
);
1045 *ppbBuffer
= (*ippdsdb
)->presented_buffer
;
1047 /* buffer is ready to go */
1048 TRACE("buffer created at %p\n", *ippdsdb
);
1052 HeapFree(GetProcessHeap(), 0, (*ippdsdb
)->presented_buffer
);
1053 HeapFree(GetProcessHeap(), 0, (*ippdsdb
)->sw_params
);
1054 HeapFree(GetProcessHeap(), 0, (*ippdsdb
)->hw_params
);
1055 HeapFree(GetProcessHeap(), 0, *ippdsdb
);
1060 static const IDsCaptureDriverVtbl dscdvt
=
1062 IDsCaptureDriverImpl_QueryInterface
,
1063 IDsCaptureDriverImpl_AddRef
,
1064 IDsCaptureDriverImpl_Release
,
1065 IDsCaptureDriverImpl_GetDriverDesc
,
1066 IDsCaptureDriverImpl_Open
,
1067 IDsCaptureDriverImpl_Close
,
1068 IDsCaptureDriverImpl_GetCaps
,
1069 IDsCaptureDriverImpl_CreateCaptureBuffer
1072 /**************************************************************************
1073 * widDsCreate [internal]
1075 DWORD
widDsCreate(UINT wDevID
, PIDSCDRIVER
* drv
)
1077 IDsCaptureDriverImpl
** idrv
= (IDsCaptureDriverImpl
**)drv
;
1078 TRACE("(%d,%p)\n",wDevID
,drv
);
1080 *idrv
= HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY
,sizeof(IDsCaptureDriverImpl
));
1082 return MMSYSERR_NOMEM
;
1083 (*idrv
)->lpVtbl
= &dscdvt
;
1086 (*idrv
)->wDevID
= wDevID
;
1087 return MMSYSERR_NOERROR
;
1090 /**************************************************************************
1091 * widDsDesc [internal]
1093 DWORD
widDsDesc(UINT wDevID
, PDSDRIVERDESC desc
)
1095 *desc
= WInDev
[wDevID
].ds_desc
;
1096 return MMSYSERR_NOERROR
;
1099 #endif /* HAVE_ALSA */