[ros-diffs] [greatlrd] 19414: adding code for waveTheard it is not complete yet

adding code for waveTheard it is not complete yet
Modified: trunk/reactos/lib/mmdrv/wave.c
  _____  

Modified: trunk/reactos/lib/mmdrv/wave.c
--- trunk/reactos/lib/mmdrv/wave.c	2005-11-21 18:38:09 UTC (rev
19413)
+++ trunk/reactos/lib/mmdrv/wave.c	2005-11-21 18:49:41 UTC (rev
19414)
@@ -17,17 +17,15 @@

 #define NDEBUG
 #include <debug.h>
 
-PWAVEALLOC WaveLists;   
+#define WHDR_COMPLETE 0x80000000
+PWAVEALLOC WaveLists; 
 
+
 /* ============================
  *  INTERNAL
  *  functions start here
  * ============================
  */
-static DWORD waveThread(LPVOID lpParameter)
-{
-  return MMSYSERR_NOERROR;
-}
 
 MMRESULT GetDeviceCapabilities(DWORD ID, UINT DeviceType,
                                       LPBYTE pCaps, DWORD Size)
@@ -69,6 +67,126 @@
     return Result;
 }
 
+static DWORD waveThread(LPVOID lpParameter)
+{
+
+    PWAVEALLOC pClient;
+    BOOL Terminate;
+
+    SetThreadPriority(GetCurrentThread(),
THREAD_PRIORITY_TIME_CRITICAL);
+    SetEvent(pClient->AuxEvent2);
+    WaitForSingleObject(pClient->AuxEvent1, INFINITE);
+
+    for (;;) 
+    {
+        switch (pClient->AuxFunction) 
+        {
+            case WaveThreadAddBuffer:
+                 DPRINT("UNIMPLMENENT WaveThreadAddBuffer ");
+                 break;
+
+            case WaveThreadSetState:
+                 DPRINT("UNIMPLMENENT WaveThreadSetState ");
+                 break;
+
+            case WaveThreadGetData:
+                 DPRINT("UNIMPLMENENT WaveThreadGetData ");
+                 break;
+
+            case WaveThreadSetData:
+                 DPRINT("UNIMPLMENENT WaveThreadGetData ");
+                 break;
+
+            case WaveThreadBreakLoop:
+                 pClient->AuxReturnCode = MMSYSERR_NOERROR;
+                 if (pClient->LoopHead)                 
+                    pClient->LoopCount = 0;                          
+                 break;
+
+            case WaveThreadClose:
+                 if (pClient->DeviceQueue != NULL)                  
+                    pClient->AuxReturnCode = WAVERR_STILLPLAYING;
+                 else                 
+                    pClient->AuxReturnCode = MMSYSERR_NOERROR;
+                 break;
+
+            case WaveThreadTerminate:
+                 Terminate = TRUE;
+                 break;
+
+            default:
+                 DPRINT("WaveThread Error");
+                 break;
+
+        }
+
+        pClient->AuxFunction = WaveThreadInvalid;
+
+        while (pClient->DeviceQueue && (pClient->DeviceQueue->dwFlags
&
WHDR_COMPLETE)) 
+        {
+            PWAVEHDR pHdr;        
+            PWAVEALLOC pWav;
+
+            pHdr = pClient->DeviceQueue;        
+            pClient->DeviceQueue = pHdr->lpNext;
+    
+            pHdr->dwFlags &= ~WHDR_COMPLETE;
+            pHdr->dwFlags &= ~WHDR_INQUEUE;
+            pHdr->lpNext = NULL;
+            pHdr->dwFlags |= WHDR_DONE;
+
+            pWav = (PWAVEALLOC)pHdr->reserved;
+                
+            if (pWav->dwCallback)
+            {
+                DriverCallback(pWav->dwCallback, HIWORD(pWav->dwFlags),
(HDRVR)pWav->hWave,  
+                           pClient->DeviceType == WaveOutDevice ?
WOM_DONE : WIM_DATA, 
+                           pWav->dwInstance, (DWORD)pHdr, 0L); 
+            }
+        }
+
+        //waveStart;
+
+        if (Terminate) return 1; 
+        SetEvent(pClient->AuxEvent2);
+        while (WaitForSingleObjectEx(pClient->AuxEvent1, INFINITE,
TRUE) == WAIT_IO_COMPLETION) 
+        {
+           while (pClient->DeviceQueue &&
(pClient->DeviceQueue->dwFlags & WHDR_COMPLETE)) 
+           {
+                PWAVEHDR pHdr;        
+                PWAVEALLOC pWav;
+
+                pHdr = pClient->DeviceQueue;        
+                pClient->DeviceQueue = pHdr->lpNext;
+    
+                pHdr->dwFlags &= ~WHDR_COMPLETE;
+                pHdr->dwFlags &= ~WHDR_INQUEUE;
+                pHdr->lpNext = NULL;
+                pHdr->dwFlags |= WHDR_DONE;
+
+                pWav = (PWAVEALLOC)pHdr->reserved;
+                
+                if (pWav->dwCallback)
+                {
+                    DriverCallback(pWav->dwCallback,
HIWORD(pWav->dwFlags), (HDRVR)pWav->hWave,  
+                           pClient->DeviceType == WaveOutDevice ?
WOM_DONE : WIM_DATA, 
+                           pWav->dwInstance, (DWORD)pHdr, 0L); 
+                }
+            }
+
+        //waveStart;
+        }
+    }
+
+
+  return MMSYSERR_NOERROR;
+}
+
+
+
+
+
+
 static MMRESULT OpenWaveDevice(UINT  DeviceType,
 								DWORD
id,
 								DWORD
dwUser,