Changeset 167 for sbliveos2/trunk/drv16/dwavestrm.cpp

Timestamp:

Mar 23, 2001, 12:33:12 AM (24 years ago)

Author:

sandervl

Message:

update

File:

• sbliveos2/trunk/drv16/dwavestrm.cpp (modified) (8 diffs)

sbliveos2/trunk/drv16/dwavestrm.cpp

@@ -31 +31 @@
 #include <dbgos2.h>
 #include "ioctl.h"
+#include "malloc.h"
 
 
@@ -55 +56 @@
         }
         DevHelp_VMFree((LIN)temp->pBuffptr);
-        DevHelp_VMUnLock(temp->hLock);
+        DevHelp_VMUnLock(temp->linLock);
+        free(temp->pLock);
         delete temp;
     }
@@ -65 +67 @@
 {
     PSTREAMBUFFEREX pStreamBuf;
-    ULONG pGlobalAddr;
-    LIN   linAddr = (LIN)&pGlobalAddr;
-    ULONG lock;
-    LIN   linLock = (LIN)&lock;
+    LIN   linAddr;
+    PULONG pLock;
+    ULONG PageListCount;
+    LIN   linLock;
     int   rc;
 
-    rc = DevHelp_VirtToLin(SELECTOROF(linAddr), OFFSETOF(linAddr), &linAddr);
+    pLock = (PULONG)malloc(12);
+    if(pLock == NULL) {
+        DebugInt3();
+        return 1;
+    }
+
+    rc = DevHelp_VirtToLin(SELECTOROF(pLock), OFFSETOF(pLock), &linLock);
     if(rc) {
         DebugInt3();
@@ -77 +85 @@
     }
 
-    rc = DevHelp_VirtToLin(SELECTOROF(linLock), OFFSETOF(linLock), &linLock);
+    rc = DevHelp_VMLock(VMDHL_LONG | VMDHL_WRITE, (LIN)pbuf, uLength, -1L, linLock, (PULONG)&PageListCount);
+    if(rc) {
+        DebugInt3();
+        DevHelp_VMFree(linAddr);
+        return rc;
+    }
+
+    rc = DevHelp_VMProcessToGlobal(VMDHGP_WRITE, (LIN)pbuf, uLength, (PLIN)&linAddr);
     if(rc) {
         DebugInt3();
@@ -83 +98 @@
     }
 
-    rc = DevHelp_VMLock(VMDHL_LONG | VMDHL_WRITE, (LIN)pbuf, uLength, -1L, linLock, (PULONG)-1L);
-    if(rc) {
-        DebugInt3();
-        return rc;
-    }
+    pStreamBuf = new STREAMBUFFEREX(uLength, (PSTREAMBUF)linAddr, linLock, pLock);
 
-    rc = DevHelp_VMProcessToGlobal(VMDHGP_WRITE, (LIN)pbuf, uLength, (PLIN)linAddr);
-    if(rc) {
-        return rc;
-    }
-
-    pStreamBuf = new STREAMBUFFEREX(uLength, (PSTREAMBUF)pGlobalAddr, lock);
-
-    return WAVESTREAM::Write((STREAMBUFFER *)pStreamBuf);
+    return WAVESTREAM::Write((PSTREAMBUFFER)pStreamBuf);
 }
 
@@ -111 +115 @@
         else {
             DevHelp_VMFree((LIN)temp->pBuffptr);
-            DevHelp_VMUnLock(temp->hLock);
+            DevHelp_VMUnLock(temp->linLock);
+            free(temp->pLock);
             delete temp;
         }
@@ -117 +122 @@
 }
 
+ULONG DWAVESTREAM::Register(PDDCMDREGISTER pReg)
+{
+    hSem = pReg->hStream;
+
+    if(DevHelp_OpenEventSem(hSem) != 0) {
+        dprintf(("DevHlp_OpenEventSem %lx failed!", hSem));
+        hSem = 0;
+        return 1;
+    }
+    return WAVESTREAM::Register(pReg);
+}
+
+void DWAVESTREAM::DeRegister(void)
+{
+    if(DevHelp_CloseEventSem(hSem) != 0) {
+        dprintf(("DevHlp_CloseEventSemaphore %lx failed!", hSem));
+        return;
+    }
+    hSem = 0;
+    WAVESTREAM::DeRegister();
+}
+
+
 DWAVESTREAM::DWAVESTREAM(ULONG streamtype, LPMCI_AUDIO_INIT pinit, USHORT filesysnum):
-   WAVESTREAM(streamtype, pinit, filesysnum), fError(FALSE), hCtxHook(0)
+   WAVESTREAM(streamtype, pinit, filesysnum), fError(FALSE), hCtxHook(0), hSem(0)
 {
     if(DevHelp_AllocateCtxHook((NPFN)HookHandlerAsm, &hCtxHook)) {
@@ -132 +160 @@
         StopStream(&cParm);
     }
+    else ReturnBuffers();
+
+    if(hSem) {
+        if(DevHelp_CloseEventSem(hSem) != 0) {
+            dprintf(("DevHlp_CloseEventSemaphore %lx failed!", hSem));
+        }
+    }
     if(hCtxHook) {
         DevHelp_FreeCtxHook(hCtxHook);