Changeset 188 for sbliveos2/trunk/drv16/wavestrm.cpp

Timestamp:

Sep 9, 2001, 5:31:35 PM (24 years ago)

Author:

sandervl

Message:

joystick reactivated; version increase; Rudi's fixes

File:

• sbliveos2/trunk/drv16/wavestrm.cpp (modified) (5 diffs)

sbliveos2/trunk/drv16/wavestrm.cpp

@@ -165 +165 @@
                 //underrun: stop playback
                 dprintf(("underrun: stop playback"));
-                pahw->Stop(this);
+                pahw->Stop(this);
                 fUnderrun = TRUE;
                 return;
@@ -171 +171 @@
         space = OSS16_StreamGetSpace(this);
         while(space) {
-                byteswritten = AddBuffer(space);
+                byteswritten = AddBuffer(space);
+                if(byteswritten == (ULONG)-1) break;
                 space -= byteswritten;
-                if(byteswritten == 0) break;
-        }       
+        }
    }
 }
@@ -191 +191 @@
 
    if(!pTemp || pTemp->ulBuffpos >= (pTemp->ulBuffsz & 0xFFFFFFFC)) {
-        pTemp = (PSTREAMBUFFER)qhInProcess.Head();
+        pTemp = (PSTREAMBUFFER)qhInProcess.Head();
    }
    if(!pTemp) {
         dprintf4(("AddBuffer: pTemp == NULL"));
-        return 0;
+        return (ULONG)-1;
    }
 
@@ -202 +202 @@
    Buff_left = pTemp->ulBuffsz - pTemp->ulBuffpos;
 
-   // write the audio buffer
-   Buff_left = min(Buff_left, space);
-   byteswritten = OSS16_StreamAddBuffer(this, pdataBuf, Buff_left);
-   if(byteswritten == 0) {
-        return 0; //no more room
-   }
-
-   // update the buffer pos counter
-   pTemp->ulBuffpos += byteswritten;
-
-   if(pTemp != qhDone.Tail()) {
-        qhDone.PushOnTail(qhInProcess.PopHead());
+   if(Buff_left) {
+        // write the audio buffer
+        Buff_left = min(Buff_left, space);
+        byteswritten = OSS16_StreamAddBuffer(this, pdataBuf, Buff_left);
+        if(byteswritten == 0) {
+            return (ULONG)-1; //no more room
+        }
+
+        // update the buffer pos counter
+        pTemp->ulBuffpos += byteswritten;
+   } 
+   else byteswritten = 0;
+
+   if(pTemp == qhInProcess.Head()) {
+        qhDone.PushOnTail(qhInProcess.PopHead());
    }
    dprintf4(("AddBuffer %lx size %d, bytes written %d", pdataBuf, (USHORT)Buff_left, (USHORT)byteswritten));
@@ -299 +302 @@
           else  break; //shouldn't happen
         }
-
-        //Get rid of empty buffers
-        ptemp = (PSTREAMBUFFER)qhInProcess.Head();
-        if(ptemp && (ptemp->ulBuffsz == 0 || ptemp->pBuffptr == NULL)) {
-                dprintf(("Returning 0 size buffer immediately"));
-                ReturnBuffer();
-        }
-        AddBuffers(FALSE);
-        break;
-   }
-   case STREAM_READ:            
-        while(_vReadAudioBuf());
-        break;
+        AddBuffers(FALSE);
+        break;
+   }
+   case STREAM_READ:
+        while(_vReadAudioBuf());
+        break;
    default:
       break;