--- /dev/null
+/*
+ * PROJECT: ReactOS Sound System "MME Buddy" Library
+ * LICENSE: GPL - See COPYING in the top level directory
+ * FILE: lib/drivers/sound/mmebuddy/wave/streaming.c
+ *
+ * PURPOSE: Wave streaming
+ *
+ * PROGRAMMERS: Andrew Greenwood (silverblade@reactos.org)
+*/
+
+#include "precomp.h"
+
+
+/*
+ DoWaveStreaming
+ Check if there is streaming to be done, and if so, do it.
+*/
+
+VOID
+DoWaveStreaming(
+ IN PSOUND_DEVICE_INSTANCE SoundDeviceInstance)
+{
+ MMRESULT Result;
+ MMDEVICE_TYPE DeviceType;
+ PSOUND_DEVICE SoundDevice;
+ PMMFUNCTION_TABLE FunctionTable;
+ PWAVEHDR Header;
+ PWAVEHDR_EXTENSION HeaderExtension;
+
+ Result = GetSoundDeviceFromInstance(SoundDeviceInstance, &SoundDevice);
+ SND_ASSERT( MMSUCCESS(Result) );
+
+ Result = GetSoundDeviceType(SoundDevice, &DeviceType);
+ SND_ASSERT( MMSUCCESS(Result) );
+
+ Result = GetSoundDeviceFunctionTable(SoundDevice, &FunctionTable);
+ SND_ASSERT( MMSUCCESS(Result) );
+ SND_ASSERT( FunctionTable );
+ SND_ASSERT( FunctionTable->CommitWaveBuffer );
+
+ /* No point in doing anything if no resources available to use */
+ if ( SoundDeviceInstance->OutstandingBuffers >= SoundDeviceInstance->BufferCount )
+ {
+ SND_TRACE(L"DoWaveStreaming: No available buffers to stream with - doing nothing\n");
+ return;
+ }
+
+ /* Is there any work to do? */
+ Header = SoundDeviceInstance->HeadWaveHeader;
+
+ if ( ! Header )
+ {
+ SND_TRACE(L"DoWaveStreaming: No work to do - doing nothing\n");
+ return;
+ }
+
+ while ( ( SoundDeviceInstance->OutstandingBuffers < SoundDeviceInstance->BufferCount ) &&
+ ( Header ) && SoundDeviceInstance->ResetInProgress == FALSE)
+ {
+ HeaderExtension = (PWAVEHDR_EXTENSION) Header->reserved;
+ SND_ASSERT( HeaderExtension );
+
+ /* Saniy checks */
+ SND_ASSERT(Header->dwFlags & WHDR_PREPARED);
+ SND_ASSERT(Header->dwFlags & WHDR_INQUEUE);
+
+ /* Can never be *above* the length */
+ SND_ASSERT( HeaderExtension->BytesCommitted <= Header->dwBufferLength );
+
+ /* Is this header entirely committed? */
+ if ( HeaderExtension->BytesCommitted == Header->dwBufferLength )
+ {
+ {
+ /* Move on to the next header */
+ SND_ASSERT(Header != Header->lpNext);
+ Header = Header->lpNext;
+ }
+ }
+ else
+ {
+ PSOUND_OVERLAPPED Overlap;
+ LPVOID OffsetPtr;
+ DWORD BytesRemaining, BytesToCommit;
+ BOOL OK;
+
+ /* Where within the header buffer to stream from */
+ OffsetPtr = Header->lpData + HeaderExtension->BytesCommitted;
+
+ /* How much of this header has not been committed */
+ BytesRemaining = Header->dwBufferLength - HeaderExtension->BytesCommitted;
+
+ /* We can commit anything up to the buffer size limit */
+ BytesToCommit = BytesRemaining > SoundDeviceInstance->FrameSize ?
+ SoundDeviceInstance->FrameSize :
+ BytesRemaining;
+
+ /* Should always have something to commit by this point */
+ SND_ASSERT( BytesToCommit > 0 );
+
+ /* We need a new overlapped info structure for each buffer */
+ Overlap = AllocateStruct(SOUND_OVERLAPPED);
+
+ if ( Overlap )
+ {
+ ZeroMemory(Overlap, sizeof(SOUND_OVERLAPPED));
+ Overlap->SoundDeviceInstance = SoundDeviceInstance;
+ Overlap->Header = Header;
+
+ /* Don't complete this header if it's part of a loop */
+ Overlap->PerformCompletion = TRUE;
+// ( SoundDeviceInstance->LoopsRemaining > 0 );
+
+ /* Adjust the commit-related counters */
+ HeaderExtension->BytesCommitted += BytesToCommit;
+ ++ SoundDeviceInstance->OutstandingBuffers;
+
+ OK = MMSUCCESS(FunctionTable->CommitWaveBuffer(SoundDeviceInstance,
+ OffsetPtr,
+ BytesToCommit,
+ Overlap,
+ CompleteIO));
+
+ if ( ! OK )
+ {
+ /* Clean-up and try again on the next iteration (is this OK?) */
+ SND_WARN(L"FAILED\n");
+
+ FreeMemory(Overlap);
+ HeaderExtension->BytesCommitted -= BytesToCommit;
+ -- SoundDeviceInstance->OutstandingBuffers;
+ }
+ }
+ }
+ }
+}
+
+
+/*
+ CompleteIO
+ An APC called as a result of a call to CommitWaveHeaderToKernelDevice.
+ This will count up the number of bytes which have been dealt with,
+ and when the entire wave header has been dealt with, will call
+ CompleteWaveHeader to have the wave header returned to the client.
+
+ CommitWaveHeaderToKernelDevice
+ Sends portions of the buffer described by the wave header to a kernel
+ device. This must only be called from within the context of the sound
+ thread. The caller supplies either their own commit routine, or uses
+ WriteFileEx_Committer. The committer is called with portions of the
+ buffer specified in the wave header.
+
+ WriteFileEx_Committer
+ Commit buffers using the WriteFileEx API.
+*/
+
+VOID CALLBACK
+CompleteIO(
+ IN DWORD dwErrorCode,
+ IN DWORD dwNumberOfBytesTransferred,
+ IN LPOVERLAPPED lpOverlapped)
+{
+ MMDEVICE_TYPE DeviceType;
+ PSOUND_DEVICE SoundDevice;
+ PSOUND_DEVICE_INSTANCE SoundDeviceInstance;
+ PSOUND_OVERLAPPED SoundOverlapped = (PSOUND_OVERLAPPED) lpOverlapped;
+ PWAVEHDR WaveHdr;
+ PWAVEHDR_EXTENSION HdrExtension;
+ MMRESULT Result;
+ DWORD Bytes;
+
+ WaveHdr = (PWAVEHDR) SoundOverlapped->Header;
+ SND_ASSERT( WaveHdr );
+
+ HdrExtension = (PWAVEHDR_EXTENSION) WaveHdr->reserved;
+ SND_ASSERT( HdrExtension );
+
+ SoundDeviceInstance = SoundOverlapped->SoundDeviceInstance;
+
+ Result = GetSoundDeviceFromInstance(SoundDeviceInstance, &SoundDevice);
+ SND_ASSERT( MMSUCCESS(Result) );
+
+ Result = GetSoundDeviceType(SoundDevice, &DeviceType);
+ SND_ASSERT( MMSUCCESS(Result) );
+
+ do
+ {
+
+ /* We have an available buffer now */
+ -- SoundDeviceInstance->OutstandingBuffers;
+
+ /* Did we finish a WAVEHDR and aren't looping? */
+ if ( HdrExtension->BytesCompleted + dwNumberOfBytesTransferred >= WaveHdr->dwBufferLength &&
+ SoundOverlapped->PerformCompletion )
+ {
+ /* Wave buffer fully completed */
+ Bytes = WaveHdr->dwBufferLength - HdrExtension->BytesCompleted;
+
+ HdrExtension->BytesCompleted += Bytes;
+ dwNumberOfBytesTransferred -= Bytes;
+
+ CompleteWaveHeader(SoundDeviceInstance, WaveHdr);
+ SND_TRACE(L"%d/%d bytes of wavehdr completed\n", HdrExtension->BytesCompleted, WaveHdr->dwBufferLength);
+ }
+ else
+ {
+ /* Partially completed */
+ HdrExtension->BytesCompleted += dwNumberOfBytesTransferred;
+ SND_TRACE(L"%d/%d bytes of wavehdr completed\n", HdrExtension->BytesCompleted, WaveHdr->dwBufferLength);
+ break;
+ }
+
+ /* Move to next wave header */
+ WaveHdr = WaveHdr->lpNext;
+
+ if (!WaveHdr)
+ {
+ /* No following WaveHdr */
+ SND_ASSERT(dwNumberOfBytesTransferred == 0);
+ break;
+ }
+
+ HdrExtension = (PWAVEHDR_EXTENSION) WaveHdr->reserved;
+ SND_ASSERT( HdrExtension );
+
+
+ }while(dwNumberOfBytesTransferred);
+
+ // AUDIO-BRANCH DIFF
+ // completion callback is performed in a thread
+ DoWaveStreaming(SoundDeviceInstance);
+
+ //CompleteWavePortion(SoundDeviceInstance, dwNumberOfBytesTransferred);
+
+ FreeMemory(lpOverlapped);
+}
+
+MMRESULT
+WriteFileEx_Committer(
+ IN PSOUND_DEVICE_INSTANCE SoundDeviceInstance,
+ IN PVOID OffsetPtr,
+ IN DWORD Length,
+ IN PSOUND_OVERLAPPED Overlap,
+ IN LPOVERLAPPED_COMPLETION_ROUTINE CompletionRoutine)
+{
+ HANDLE Handle;
+
+ VALIDATE_MMSYS_PARAMETER( SoundDeviceInstance );
+ VALIDATE_MMSYS_PARAMETER( OffsetPtr );
+ VALIDATE_MMSYS_PARAMETER( Overlap );
+ VALIDATE_MMSYS_PARAMETER( CompletionRoutine );
+
+ GetSoundDeviceInstanceHandle(SoundDeviceInstance, &Handle);
+
+ if ( ! WriteFileEx(Handle, OffsetPtr, Length, (LPOVERLAPPED)Overlap, CompletionRoutine) )
+ {
+ // TODO
+ }
+
+ return MMSYSERR_NOERROR;
+}
+
+
+/*
+ Stream control functions
+ (External/internal thread pairs)
+
+ TODO - Move elsewhere as these shouldn't be wave specific!
+*/
+
+MMRESULT
+StopStreamingInSoundThread(
+ IN PSOUND_DEVICE_INSTANCE SoundDeviceInstance,
+ IN PVOID Parameter)
+{
+ MMDEVICE_TYPE DeviceType;
+ PMMFUNCTION_TABLE FunctionTable;
+ MMRESULT Result;
+ PSOUND_DEVICE SoundDevice;
+
+ /* set state reset in progress */
+ SoundDeviceInstance->ResetInProgress = TRUE;
+
+ /* Get sound device */
+ Result = GetSoundDeviceFromInstance(SoundDeviceInstance, &SoundDevice);
+ SND_ASSERT( Result == MMSYSERR_NOERROR );
+
+ /* Obtain the function table */
+ Result = GetSoundDeviceFunctionTable(SoundDevice, &FunctionTable);
+ SND_ASSERT( Result == MMSYSERR_NOERROR );
+
+ /* Obtain device instance type */
+ Result = GetSoundDeviceType(SoundDevice, &DeviceType);
+ SND_ASSERT( Result == MMSYSERR_NOERROR );
+
+ /* Check if reset function is supported */
+ if (FunctionTable->ResetStream)
+ {
+ /* cancel all current audio buffers */
+ FunctionTable->ResetStream(SoundDeviceInstance, DeviceType, TRUE);
+ }
+ while(SoundDeviceInstance->OutstandingBuffers)
+ {
+ SND_TRACE(L"StopStreamingInSoundThread OutStandingBufferCount %lu\n", SoundDeviceInstance->OutstandingBuffers);
+ /* wait until pending i/o has completed */
+ SleepEx(10, TRUE);
+ }
+
+ /* complete all current headers */
+ while( SoundDeviceInstance->HeadWaveHeader )
+ {
+ SND_TRACE(L"StopStreamingInSoundThread: Completing Header %p\n", SoundDeviceInstance->HeadWaveHeader);
+ CompleteWaveHeader( SoundDeviceInstance, SoundDeviceInstance->HeadWaveHeader );
+ }
+
+ /* there should be no oustanding buffers now */
+ SND_ASSERT(SoundDeviceInstance->OutstandingBuffers == 0);
+
+
+ /* Check if reset function is supported */
+ if (FunctionTable->ResetStream)
+ {
+ /* finish the reset */
+ FunctionTable->ResetStream(SoundDeviceInstance, DeviceType, FALSE);
+ }
+
+ /* clear state reset in progress */
+ SoundDeviceInstance->ResetInProgress = FALSE;
+
+
+ return MMSYSERR_NOERROR;
+}
+
+MMRESULT
+StopStreaming(
+ IN PSOUND_DEVICE_INSTANCE SoundDeviceInstance)
+{
+ MMRESULT Result;
+ PSOUND_DEVICE SoundDevice;
+ MMDEVICE_TYPE DeviceType;
+
+ if ( ! IsValidSoundDeviceInstance(SoundDeviceInstance) )
+ return MMSYSERR_INVALHANDLE;
+
+ Result = GetSoundDeviceFromInstance(SoundDeviceInstance, &SoundDevice);
+ if ( ! MMSUCCESS(Result) )
+ return TranslateInternalMmResult(Result);
+
+ Result = GetSoundDeviceType(SoundDevice, &DeviceType);
+ if ( ! MMSUCCESS(Result) )
+ return TranslateInternalMmResult(Result);
+
+ if ( DeviceType != WAVE_OUT_DEVICE_TYPE && DeviceType != WAVE_IN_DEVICE_TYPE )
+ return MMSYSERR_NOTSUPPORTED;
+
+ return CallSoundThread(SoundDeviceInstance,
+ StopStreamingInSoundThread,
+ NULL);
+}
+
+MMRESULT
+PerformWaveStreaming(
+ IN PSOUND_DEVICE_INSTANCE SoundDeviceInstance,
+ IN PVOID Parameter)
+{
+ DoWaveStreaming(SoundDeviceInstance);
+
+ return MMSYSERR_NOERROR;
+}
+
+DWORD
+WINAPI
+WaveActivateSoundStreaming(
+ IN PVOID lpParameter)
+{
+ CallSoundThread((PSOUND_DEVICE_INSTANCE)lpParameter,
+ PerformWaveStreaming,
+ NULL);
+
+ ExitThread(0);
+}
+
+VOID
+InitiateSoundStreaming(
+ IN PSOUND_DEVICE_INSTANCE SoundDeviceInstance)
+{
+ HANDLE hThread;
+
+ hThread = CreateThread(NULL, 0, WaveActivateSoundStreaming, (PVOID)SoundDeviceInstance, 0, NULL);
+
+ if (hThread != NULL)
+ CloseHandle(hThread);
+}
projects / reactos.git / blobdiff