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

Timestamp:

Apr 30, 2001, 11:08:00 PM (24 years ago)

Author:

sandervl

Message:

DirectAudio interface updates

File:

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

sbliveos2/trunk/drv16/dwavestrm.cpp

@@ -26 +26 @@
 
 #include <devhelp.h>
+#include <include.h>
 
 #include "dwavestrm.hpp"
@@ -32 +33 @@
 #include "ioctl.h"
 #include "malloc.h"
+#include <ossidc.h>
 
 void cdecl HookHandler(ULONG ulSysFileNum)
 {
     PDWAVESTREAM pStream;
-    PSTREAMBUFFEREX temp;
+    PSTREAMBUFFER temp;
     int rc;
 
@@ -46 +48 @@
     }
 
-    temp = (PSTREAMBUFFEREX)pStream->qhReturn.PopHead();
+    temp = (PSTREAMBUFFER)pStream->qhReturn.PopHead();
     while(temp) {
         if(pStream->hSem) {
@@ -58 +60 @@
         delete temp;
 
-        temp = (PSTREAMBUFFEREX)pStream->qhReturn.PopHead();
+        temp = (PSTREAMBUFFER)pStream->qhReturn.PopHead();
     }
     return;
@@ -64 +66 @@
 
 
-ULONG DWAVESTREAM::Write(PSTREAMBUF pbuf, ULONG uLength)
-{
-    PSTREAMBUFFEREX pStreamBuf;
+ULONG DWAVESTREAM::Write(PSTREAMBUF pbuf, ULONG uLength, BOOL fLooping)
+{
+    PSTREAMBUFFER pStreamBuf;
     LIN             linAddr;
     PULONG          pLock;
@@ -73 +75 @@
     int             rc;
 
-    pStreamBuf = new STREAMBUFFEREX(uLength, (PSTREAMBUF)0);
+    pStreamBuf = new STREAMBUFFER(uLength, (PSTREAMBUF)0, fLooping);
     if(pStreamBuf == NULL) {
         DebugInt3();
@@ -110 +112 @@
 void DWAVESTREAM::ReturnBuffer(void)
 {
-   PSTREAMBUFFEREX temp = (PSTREAMBUFFEREX)qhDone.PopHead();
+   PSTREAMBUFFER temp = (PSTREAMBUFFER)qhDone.PopHead();
 
    if(temp)
@@ -148 +150 @@
 }
 
+//
+//
+ULONG DWAVESTREAM::StartStream(void)
+{
+   return WAVESTREAM::StartStream();
+}
+
+
+void DWAVESTREAM::AddBuffers(BOOL fFirst)
+{
+   PSTREAMBUFFER pTemp = (PSTREAMBUFFER)qhDone.Tail();
+   ULONG space, Buff_left, byteswritten;
+
+   if(!pTemp) pTemp = (PSTREAMBUFFER)qhInProcess.Tail();
+
+   if(ulStreamType & STREAM_WRITE && pTemp && pTemp->looping) 
+   {
+        Buff_left = pTemp->ulBuffsz - pTemp->ulBuffpos;
+
+        space = OSS16_StreamGetSpace(this);
+        if(fFirst) {
+             space = min(space, 4*fragsize);
+        }
+        else space = min(space, fragsize);
+
+        if(space) {
+            if(space >= Buff_left) {
+                 byteswritten = AddBuffer(Buff_left);
+                 if(byteswritten == Buff_left) {
+                     pTemp->ulBuffpos = 0; //reset fill position
+                     AddBuffer(space - Buff_left);
+                 }
+            }
+            else AddBuffer(space);
+        }       
+        pTemp->ulDonepos = 0; //make sure it ::Process never thinks it's done
+   }
+   else WAVESTREAM::AddBuffers(fFirst);
+}
+
+BOOL DWAVESTREAM::SetProperty(int type, ULONG value, ULONG reserved)
+{
+   switch(type) {
+   case PROPERTY_LOOPING:
+   {
+       cli();
+       PSTREAMBUFFER pTemp = (PSTREAMBUFFER)qhInProcess.Head();
+
+       if(!pTemp) pTemp = (PSTREAMBUFFER)qhDone.Head();
+
+       if(pTemp) {
+           pTemp->looping = (BOOL)value;
+           if(pTemp->looping == FALSE) {
+               //calculate current play position
+               pTemp->ulDonepos = (_ulBytesProcessed % pTemp->ulBuffsz);
+           }
+       }
+       sti();
+   }
+   case PROPERTY_FREQUENCY:
+       break;
+
+   default:
+       return WAVESTREAM::SetProperty(type, value, reserved);
+
+   }
+   return TRUE;
+}
+
+ULONG DWAVESTREAM::GetProperty(int type) 
+{
+   switch(type) {
+   case PROPERTY_LOOPING:
+   {
+       cli();
+       PSTREAMBUFFER pTemp = (PSTREAMBUFFER)qhInProcess.Head();
+       ULONG         ret = FALSE;
+
+       if(!pTemp) pTemp = (PSTREAMBUFFER)qhDone.Head();
+
+       if(pTemp) {
+           ret = pTemp->looping;
+       }
+       sti();
+       return ret;
+   }
+
+   default:
+       return WAVESTREAM::GetProperty(type);
+   }
+}
 
 DWAVESTREAM::DWAVESTREAM(ULONG streamtype, LPMCI_AUDIO_INIT pinit, USHORT filesysnum):
@@ -161 +254 @@
 {
     if (ulStreamState == STREAM_STREAMING) {
-        CONTROL_PARM cParm;
-        StopStream(&cParm);
+         CONTROL_PARM cParm;
+         StopStream(&cParm);
     }
     else ReturnBuffers();