Changeset 483 for OCO/trunk/drv16/ssm_idc.cpp

Timestamp:

May 6, 2010, 3:08:34 AM (15 years ago)

Author:

David Azarewicz

Message:

Rework buffer management

File:

• OCO/trunk/drv16/ssm_idc.cpp (modified) (8 diffs)

OCO/trunk/drv16/ssm_idc.cpp

@@ -43 +43 @@
    }
 #endif
-
    switch (pCommon->ulFunction) {
 
       case DDCMD_SETUP: {
+         ddprintf(("DDCMD_SETUP"));
          if (!pstream)
          {
@@ -56 +56 @@
          pstream->SetCurrentTime(psp->ulStreamTime);
 
-           // if there is a flags field in the SETUP_PARM
-           // the tell MMPM it can send us 'RECURRING' events....
-         if (p->ulSetupParmSize > sizeof(ULONG)) 
+         // if there is a flags field in the SETUP_PARM
+         // the tell MMPM it can send us 'RECURRING' events....
+         if (p->ulSetupParmSize > sizeof(ULONG))
          {
-//            dprintf(("DDCMD_SETUP ParmSize %ld", p->ulSetupParmSize));
+                        // dprintf(("DDCMD_SETUP ParmSize %ld", p->ulSetupParmSize));
             psp->ulFlags = SETUP_RECURRING_EVENTS;
          }
@@ -68 +68 @@
          ddprintf(("DDCMD_READ"));
          PDDCMDREADWRITE p=(PDDCMDREADWRITE) pCommon;
-
 
          if (!pstream)
@@ -79 +78 @@
       }
       // Task time
-      case DDCMD_WRITE: 
+      case DDCMD_WRITE:
       {
            PDDCMDREADWRITE p=(PDDCMDREADWRITE) pCommon;
-           ULONG           Space;
 
            if (!pstream)
@@ -89 +87 @@
               return ERROR_INVALID_STREAM;
            }
-#ifdef PS_Thinking
-           OSS16_WaveGetSpace(pstream->StreamId, &Space);
-           ddprintf(("DDCMD_WRITE %lx space %lx",p->ulBufferSize, Space));
-           if (Space < p->ulBufferSize)
-           {
-               DevHelp_ProcBlock (pstream->StreamId, 2, 0);
-               ddprintf(("DDCMD_WRITE after %lx space %lx",p->ulBufferSize, Space));
-           }
-#endif
-//           ddprintf(("DDCMD_WRITE"));
            ulReturnCode = pstream->Write((PSTREAMBUF) p->pBuffer,(unsigned) p->ulBufferSize);
-           ddprintf(("DDCMD_WRITE %lx rc=%ld",p->ulBufferSize, ulReturnCode));
+           ddprintf(("DDCMD_WRITE %lx %lx rc=%ld", p->pBuffer, p->ulBufferSize, ulReturnCode));
            if (ulReturnCode)
               return ulReturnCode;
@@ -106 +94 @@
       }
       case DDCMD_STATUS: {
-         ddprintf(("DDCMD_STATUS"));
-         PDDCMDSTATUS p = (PDDCMDSTATUS) pCommon;
-         PSTATUS_PARM p2 = (PSTATUS_PARM) p->pStatus;
-         if (!pstream)
-           return ERROR_INVALID_STREAM;
-         p2->ulTime = pstream->GetCurrentTime();
-//         ddprintf(("DDCMD_STATUS time:%ld",p2->ulTime));
-         break;
+                PDDCMDSTATUS p = (PDDCMDSTATUS) pCommon;
+                PSTATUS_PARM p2 = (PSTATUS_PARM) p->pStatus;
+                if (!pstream)
+                        return ERROR_INVALID_STREAM;
+                p2->ulTime = pstream->GetCurrentTime();
+                ddprintf(("DDCMD_STATUS time:%lx", p2->ulTime));
+                break;
       }
-      case DDCMD_CONTROL: 
+      case DDCMD_CONTROL:
       {
          PDDCMDCONTROL p = (PDDCMDCONTROL) pCommon;
@@ -124 +111 @@
          }
 
-         switch (p->ulCmd) 
+         switch (p->ulCmd)
          {
          case DDCMD_START:
              ddprintf(("DDCMD_START"));
              ulReturnCode = pstream->StartStream();
-             ddprintf(("DDCMD_START End rc=%ld",ulReturnCode));
+             //ddprintf(("DDCMD_START End rc=%ld",ulReturnCode));
              return ulReturnCode;
          case DDCMD_STOP:
              ddprintf(("DDCMD_STOP"));
-//             DevHelp_ProcBlock ((ULONG)p, 2, 0);
+                        //DevHelp_ProcBlock ((ULONG)p, 2, 0);
              p->ulParmSize=sizeof(ULONG);
              return pstream->StopStream((PCONTROL_PARM)p->pParm);
@@ -156 +143 @@
              return pstream->ResumeStreamTime();
          default:
+                ddprintf(("DDCMD INVALID REQUEST\n"));
             return ERROR_INVALID_REQUEST;
          } /* endswitch */
       }
-      case DDCMD_REG_STREAM: 
+      case DDCMD_REG_STREAM:
       {
          ddprintf(("DDCMD_REG_STREAM size:%lx countbuf:%lx",((PDDCMDREGISTER) pCommon)->ulBufSize, ((PDDCMDREGISTER) pCommon)->ulNumBufs));