Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2024-12-29 02:25:17 +00:00
Code Issues Projects Releases Packages Wiki Activity

Revert part of #17156 and #17157 changes.

Browse source 
svn path=/trunk/; revision=17195
This commit is contained in:
Filip Navara 2005-08-08 09:24:20 +00:00
parent 20732be74c
commit f61e4f1230
1 changed files with 12 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
reactos/drivers/fs/np/rw.c
View file

@ -398,25 +398,23 @@ NpfsRead(IN PDEVICE_OBJECT DeviceObject,
{ {
if (Fcb->ReadDataAvailable == 0) if (Fcb->ReadDataAvailable == 0)
{ {
if (Fcb->PipeState == FILE_PIPE_CONNECTED_STATE)
{
ASSERT(Fcb->OtherSide != NULL);
KeSetEvent(&Fcb->OtherSide->WriteEvent, IO_NO_INCREMENT, FALSE);
}
if (Information > 0 &&
(Fcb->Pipe->ReadMode != FILE_PIPE_BYTE_STREAM_MODE ||
Fcb->PipeState != FILE_PIPE_CONNECTED_STATE))
{
break;
}
if (Fcb->PipeState != FILE_PIPE_CONNECTED_STATE) if (Fcb->PipeState != FILE_PIPE_CONNECTED_STATE)
{ {
DPRINT("PipeState: %x\n", Fcb->PipeState); DPRINT("PipeState: %x\n", Fcb->PipeState);
if (Fcb->PipeState == FILE_PIPE_LISTENING_STATE) Status = STATUS_PIPE_BROKEN;
Status = STATUS_PIPE_LISTENING;
else
Status = STATUS_PIPE_DISCONNECTED;
break; break;
} }
ASSERT(Fcb->OtherSide != NULL);
KeSetEvent(&Fcb->OtherSide->WriteEvent, IO_NO_INCREMENT, FALSE);
if (Information > 0 &&
Fcb->Pipe->ReadMode != FILE_PIPE_BYTE_STREAM_MODE)
{
break;
}
ExReleaseFastMutex(&Fcb->DataListLock); ExReleaseFastMutex(&Fcb->DataListLock);
if (IoIsOperationSynchronous(Irp)) if (IoIsOperationSynchronous(Irp))
{ {