Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2024-12-27 09:34:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

Implemented CallNamedPipeW() and TransactNamedPipe().

Browse source 
svn path=/trunk/; revision=3141
This commit is contained in:
Eric Kohl 2002-06-25 18:49:38 +00:00
parent 409ca20cca
commit e8b989193d
1 changed files with 98 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

103
reactos/lib/kernel32/file/npipe.c
View file

@ -1,4 +1,4 @@
/* $Id: npipe.c,v 1.9 2001/11/20 20:35:10 ekohl Exp $
/* $Id: npipe.c,v 1.10 2002/06/25 18:49:38 ekohl Exp $
*
* COPYRIGHT: See COPYING in the top level directory
* PROJECT: ReactOS system libraries
@ -479,8 +479,53 @@ CallNamedPipeW(LPCWSTR lpNamedPipeName,
LPDWORD lpBytesRead,
DWORD nTimeOut)
{
SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
return FALSE;
HANDLE hPipe = INVALID_HANDLE_VALUE;
BOOL bRetry = TRUE;
BOOL bError = FALSE;
DWORD dwPipeMode;
while (TRUE)
{
hPipe = CreateFileW(lpNamedPipeName,
GENERIC_READ | GENERIC_WRITE,
FILE_SHARE_READ | FILE_SHARE_WRITE,
NULL,
OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL,
NULL);
if (hPipe != INVALID_HANDLE_VALUE)
break;
if (bRetry == FALSE)
return(FALSE);
WaitNamedPipeW(lpNamedPipeName,
nTimeOut);
bRetry = FALSE;
}
dwPipeMode = PIPE_READMODE_MESSAGE;
bError = SetNamedPipeHandleState(hPipe,
&dwPipeMode,
NULL,
NULL);
if (!bError)
{
CloseHandle(hPipe);
return(FALSE);
}
bError = TransactNamedPipe(hPipe,
lpInBuffer,
nInBufferSize,
lpOutBuffer,
nOutBufferSize,
lpBytesRead,
NULL);
CloseHandle(hPipe);
return(bError);
}
@ -723,8 +768,56 @@ TransactNamedPipe(HANDLE hNamedPipe,
LPDWORD lpBytesRead,
LPOVERLAPPED lpOverlapped)
{
SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
return FALSE;
IO_STATUS_BLOCK IoStatusBlock;
NTSTATUS Status;
if (lpOverlapped == NULL)
{
Status = NtFsControlFile(hNamedPipe,
NULL,
NULL,
NULL,
&IoStatusBlock,
FSCTL_PIPE_TRANSCEIVE,
lpInBuffer,
nInBufferSize,
lpOutBuffer,
nOutBufferSize);
if (Status == STATUS_PENDING)
{
NtWaitForSingleObject(hNamedPipe,
0,
FALSE);
Status = IoStatusBlock.Status;
}
if (NT_SUCCESS(Status))
{
*lpBytesRead = IoStatusBlock.Information;
}
}
else
{
lpOverlapped->Internal = STATUS_PENDING;
Status = NtFsControlFile(hNamedPipe,
lpOverlapped->hEvent,
NULL,
NULL,
(PIO_STATUS_BLOCK)lpOverlapped,
FSCTL_PIPE_TRANSCEIVE,
lpInBuffer,
nInBufferSize,
lpOutBuffer,
nOutBufferSize);
}
if (!NT_SUCCESS(Status))
{
SetLastErrorByStatus(Status);
return(FALSE);
}
return(TRUE);
}
/* EOF */