Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-05-07 18:56:48 +00:00
Code Issues Projects Releases Packages Wiki Activity

- Remove hack of starting stream automatically when first IRP has arrived

Browse source 
svn path=/trunk/; revision=42460
This commit is contained in:
Johannes Anderwald 2009-08-07 10:16:25 +00:00
parent 7121ab4d0e
commit 8a3b6b1983
4 changed files with 8 additions and 56 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
reactos/drivers/wdm/audio/backpln/portcls/pin_dmus.c
View file

@ -946,12 +946,7 @@ IPortPinDMus_fnFastRead(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) StatusBlock->Status = STATUS_PENDING;
{
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue));
SetStreamState(This, KSSTATE_RUN);
}
return TRUE; return TRUE;
} }
@ -1004,13 +999,7 @@ IPortPinDMus_fnFastWrite(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) StatusBlock->Status = STATUS_PENDING;
{
SetStreamState(This, KSSTATE_RUN);
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings Status %x\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue), Status);
}
return TRUE; return TRUE;
} }

15
reactos/drivers/wdm/audio/backpln/portcls/pin_wavecyclic.c
View file

@ -949,14 +949,8 @@ IPortPinWaveCyclic_fnFastRead(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) StatusBlock->Status = STATUS_PENDING;
{
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue));
This->Stream->lpVtbl->SetState(This->Stream, KSSTATE_RUN);
This->State = KSSTATE_RUN;
}
return TRUE; return TRUE;
} }
@ -995,13 +989,6 @@ IPortPinWaveCyclic_fnFastWrite(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->State != KSSTATE_RUN)
{
SetStreamState(This, KSSTATE_RUN);
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings Status %x\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue), Status);
}
StatusBlock->Status = STATUS_PENDING; StatusBlock->Status = STATUS_PENDING;
return TRUE; return TRUE;

17
reactos/drivers/wdm/audio/backpln/portcls/pin_wavepci.c
View file

@ -888,14 +888,8 @@ IPortPinWavePci_fnFastRead(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) /* set pending status as result */
{ StatusBlock->Status = STATUS_PENDING;
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue));
This->Stream->lpVtbl->SetState(This->Stream, KSSTATE_RUN);
This->State = KSSTATE_RUN;
}
return TRUE; return TRUE;
} }
@ -948,12 +942,7 @@ IPortPinWavePci_fnFastWrite(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) StatusBlock->Status = STATUS_PENDING;
{
SetStreamState(This, KSSTATE_RUN);
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings Status %x\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue), Status);
}
if (This->IrpQueue->lpVtbl->HasLastMappingFailed(This->IrpQueue)) if (This->IrpQueue->lpVtbl->HasLastMappingFailed(This->IrpQueue))
{ {

17
reactos/drivers/wdm/audio/backpln/portcls/pin_wavert.c
View file

@ -878,14 +878,7 @@ IPortPinWaveRT_fnFastRead(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) StatusBlock->Status = STATUS_PENDING;
{
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue));
This->Stream->lpVtbl->SetState(This->Stream, KSSTATE_RUN);
This->State = KSSTATE_RUN;
}
return TRUE; return TRUE;
} }
@ -938,13 +931,7 @@ IPortPinWaveRT_fnFastWrite(
if (!NT_SUCCESS(Status)) if (!NT_SUCCESS(Status))
return FALSE; return FALSE;
if (This->IrpQueue->lpVtbl->MinimumDataAvailable(This->IrpQueue) == TRUE && This->State != KSSTATE_RUN) StatusBlock->Status = STATUS_PENDING;
{
SetStreamState(This, KSSTATE_RUN);
/* some should initiate a state request but didnt do it */
DPRINT1("Starting stream with %lu mappings Status %x\n", This->IrpQueue->lpVtbl->NumMappings(This->IrpQueue), Status);
}
return TRUE; return TRUE;
} }