Changeset 2300 for trunk/src/kernel32/npipe.cpp

Timestamp:

Jan 2, 2000, 11:51:12 PM (26 years ago)

Author:

sandervl

Message:

PB: Started with named pipe api implementation

File:

• trunk/src/kernel32/npipe.cpp (modified) (2 diffs)

trunk/src/kernel32/npipe.cpp

@@ -1 @@
-/* $Id: npipe.cpp,v 1.2 1999-06-10 20:48:01 phaller Exp $ */
-
 /*
+ * Win32 Named pipes API 
+ *
+ * Copyright 1998 Sander van Leeuwen
+ * Copyright 2000 Przemyslaw Dobrowolski
  *
  * Project Odin Software License can be found in LICENSE.TXT
- *
  */
-/*
- * Win32 Named pipes API stub functions
- *
- * Copyright 1998 Sander van Leeuwen
- *
- */
+#include <odin.h>
+#include <odinwrap.h>
 #include <os2win.h>
-
-//TODO: Not done!!
+#include <stdlib.h>
+#include <unicode.h>
+#include <heapstring.h>
+#include <options.h>
+#include "debugtools.h"
+#include "oslibdos.h"
+
+ODINDEBUGCHANNEL(KERNEL32-NPIPE)
 
 //******************************************************************************
 //******************************************************************************
 BOOL WIN32API PeekNamedPipe(HANDLE hPipe, LPVOID lpvBuffer, DWORD cbBuffer,
-                                                 LPDWORD lpcbRead, LPDWORD lpcbAvail, LPDWORD lpcbMessage)
-{
-  dprintf(("PeekNamedPipe Not Implemented!\n"));
+                            LPDWORD lpcbRead, LPDWORD lpcbAvail, LPDWORD lpcbMessage)
+{
+  dprintf(("PeekNamedPipe Not Implemented! - yet\n"));
   return(FALSE);
 }
@@ -34 +37 @@
 //******************************************************************************
 //******************************************************************************
-HANDLE WIN32API CreateNamedPipeA(LPCTSTR lpName, DWORD dwOpenMode, DWORD dwPipeMode,
-                    DWORD nMaxInstances, DWORD nOutBufferSize,
-                    DWORD nInBufferSize, DWORD nDefaultTimeOut,
-                    void *lpSecurityAttributes)
-{
-  dprintf(("CreateNamedPipe Not Implemented!\n"));
-  return(0);
-}
-//******************************************************************************
-//******************************************************************************
-HANDLE WIN32API CreateNamedPipeW(LPCWSTR lpName, DWORD dwOpenMode, DWORD dwPipeMode,
-                    DWORD nMaxInstances, DWORD nOutBufferSize,
-                    DWORD nInBufferSize, DWORD nDefaultTimeOut,
-                    void *lpSecurityAttributes)
-{
-  dprintf(("CreateNamedPipe Not Implemented!\n"));
-  return(0);
-}
-//******************************************************************************
-//******************************************************************************
+//HANDLE WIN32API 
+//                    DWORD nMaxInstances, DWORD nOutBufferSize,
+//                    DWORD nInBufferSize, DWORD nDefaultTimeOut,
+//                    void *lpSecurityAttributes)
+ODINFUNCTION8(HANDLE,CreateNamedPipeA,LPCTSTR,lpName, DWORD,dwOpenMode, DWORD,dwPipeMode,
+                                     DWORD, nMaxInstances, DWORD, nOutBufferSize,
+                                     DWORD, nInBufferSize, DWORD, nDefaultTimeOut,
+                                     void*, lpSecurityAttributes)
+
+{
+  HANDLE hPipe;
+
+  hPipe = OSLibDosCreateNamedPipe(lpName, 
+                                  dwOpenMode, 
+                                  dwPipeMode,
+                                  nMaxInstances,
+                                  nOutBufferSize,
+                                  nInBufferSize, 
+                                  nDefaultTimeOut,
+                                  lpSecurityAttributes);
+
+  return hPipe;
+
+}
+//******************************************************************************
+//******************************************************************************
+ODINFUNCTION8(HANDLE,CreateNamedPipeW,LPCWSTR,lpName, DWORD,dwOpenMode, DWORD,dwPipeMode,
+                                     DWORD, nMaxInstances, DWORD, nOutBufferSize,
+                                     DWORD, nInBufferSize, DWORD, nDefaultTimeOut,
+                                     void *,lpSecurityAttributes)
+{
+  char *asciiname;
+  HANDLE hPipe;
+
+  asciiname  = UnicodeToAsciiString((LPWSTR)lpName);
+
+  hPipe=OSLibDosCreateNamedPipe(asciiname, 
+                           dwOpenMode, 
+                           dwPipeMode,
+                           nMaxInstances,
+                           nOutBufferSize,
+                           nInBufferSize, 
+                           nDefaultTimeOut,
+                           lpSecurityAttributes);
+
+  FreeAsciiString(asciiname);
+
+  return(hPipe);
+}
+//******************************************************************************
+//******************************************************************************
+
+
+/*****************************************************************************
+ * Name      : BOOL WIN32API ConnectNamedPipe
+ * Purpose   : The ConnectNamedPipe function enables a named pipe server process
+ *             to wait for a client process to connect to an instance of a
+ *             named pipe. A client process connects by calling either the
+ *             CreateFile or CallNamedPipe function.
+ * Parameters:  HANDLE hNamedPipe      handle to named pipe to connect
+ *              LPOVERLAPPED lpOverlapped  pointer to overlapped structure
+ * Variables :
+ * Result    : If the function succeeds, the return value is nonzero.
+ *             If the function fails, the return value is zero.
+ *             To get extended error information, call GetLastError.
+ * Remark    :
+ * Status    : NOT FULLY TESTED
+ *
+ * Author    : Przemyslaw Dobrowolski [Thu, 2000/01/02 12:48]
+ *****************************************************************************/
+
+ODINFUNCTION2(BOOL,ConnectNamedPipe,HANDLE,hNamedPipe, LPOVERLAPPED,lpOverlapped)
+{ 
+  return (OSLibDosConnectNamedPipe(hNamedPipe,lpOverlapped));
+}
+
+/*****************************************************************************
+ * Name      : BOOL WIN32AOI CallNamedPipeA
+ * Purpose   : The CallNamedPipe function connects to a message-type pipe
+ *             (and waits if an instance of the pipe is not available),
+ *             writes to and reads from the pipe, and then closes the pipe.
+ * Parameters:  LPCSTR lpNamedPipeName pointer to pipe name
+ *              LPVOID lpInBuffer      pointer to write buffer
+ *              DWORD nInBufferSize    size, in bytes, of write buffer
+ *              LPVOID lpOutBuffer     pointer to read buffer
+ *              DWORD nOutBufferSize   size, in bytes, of read buffer
+ *              LPDWORD lpBytesRead    pointer to number of bytes read
+ *              DWORD nTimeOut         time-out time, in milliseconds
+ * Variables :
+ * Result    : If the function succeeds, the return value is nonzero.
+ *             If the function fails, the return value is zero.
+ *             To get extended error information, call GetLastError.
+ * Remark    : Calling CallNamedPipe is equivalent to calling the CreateFile
+ *             (or WaitNamedPipe, if CreateFile cannot open the pipe immediately),
+ *             TransactNamedPipe, and CloseHandle functions. CreateFile is called
+ *             with an access flag of GENERIC_READ | GENERIC_WRITE, an inherit
+ *             handle flag of FALSE, and a share mode of zero (indicating no
+ *             sharing of this pipe instance).
+ *             If the message written to the pipe by the server process is
+ *             longer than nOutBufferSize, CallNamedPipe returns FALSE, and
+ *             GetLastError returns ERROR_MORE_DATA. The remainder of the
+ *             message is discarded, because CallNamedPipe closes the handle
+ *             to the pipe before returning.
+ *
+ *             CallNamedPipe fails if the pipe is a byte-type pipe.
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Markus Montkowski [Thu, 1998/05/19 11:46]
+ *****************************************************************************/
+
+BOOL WIN32API CallNamedPipeA( LPCSTR lpNamedPipeName,
+                                  LPVOID lpInBuffer, DWORD nInBufferSize,
+                                  LPVOID lpOutBuffer, DWORD nOutBufferSize,
+                                  LPDWORD lpBytesRead, DWORD nTimeOut)
+{
+
+  dprintf(("KERNEL32:  CallNamedPipeA(%08x,%08x,%08x,%08x,%08x,%08x) not implemented\n",
+           lpNamedPipeName, lpInBuffer, nInBufferSize,
+           lpOutBuffer, nOutBufferSize, lpBytesRead,  nTimeOut
+          ));
+
+  return (FALSE);
+}
+
+/*****************************************************************************
+ * Name      : BOOL WIN32AOI CallNamedPipeA
+ * Purpose   : The CallNamedPipe function connects to a message-type pipe
+ *             (and waits if an instance of the pipe is not available),
+ *             writes to and reads from the pipe, and then closes the pipe.
+ * Parameters:  LPCWSTR lpNamedPipeName pointer to pipe name
+ *              LPVOID lpInBuffer      pointer to write buffer
+ *              DWORD nInBufferSize    size, in bytes, of write buffer
+ *              LPVOID lpOutBuffer     pointer to read buffer
+ *              DWORD nOutBufferSize   size, in bytes, of read buffer
+ *              LPDWORD lpBytesRead    pointer to number of bytes read
+ *              DWORD nTimeOut         time-out time, in milliseconds
+ * Variables :
+ * Result    : If the function succeeds, the return value is nonzero.
+ *             If the function fails, the return value is zero.
+ *             To get extended error information, call GetLastError.
+ * Remark    : Calling CallNamedPipe is equivalent to calling the CreateFile
+ *             (or WaitNamedPipe, if CreateFile cannot open the pipe immediately),
+ *             TransactNamedPipe, and CloseHandle functions. CreateFile is called
+ *             with an access flag of GENERIC_READ | GENERIC_WRITE, an inherit
+ *             handle flag of FALSE, and a share mode of zero (indicating no
+ *             sharing of this pipe instance).
+ *             If the message written to the pipe by the server process is
+ *             longer than nOutBufferSize, CallNamedPipe returns FALSE, and
+ *             GetLastError returns ERROR_MORE_DATA. The remainder of the
+ *             message is discarded, because CallNamedPipe closes the handle
+ *             to the pipe before returning.
+ *
+ *             CallNamedPipe fails if the pipe is a byte-type pipe.
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Markus Montkowski [Thu, 1998/05/19 11:46]
+ *****************************************************************************/
+
+BOOL WIN32API CallNamedPipeW( LPCWSTR lpNamedPipeName,
+                                  LPVOID lpInBuffer, DWORD nInBufferSize,
+                                  LPVOID lpOutBuffer, DWORD nOutBufferSize,
+                                  LPDWORD lpBytesRead, DWORD nTimeOut)
+{
+
+  dprintf(("KERNEL32:  CallNamedPipeA(%08x,%08x,%08x,%08x,%08x,%08x) not implemented\n",
+           lpNamedPipeName, lpInBuffer, nInBufferSize,
+           lpOutBuffer, nOutBufferSize, lpBytesRead,  nTimeOut
+          ));
+
+  return (FALSE);
+}
+/*****************************************************************************
+ * Name      : BOOL WIN32API DisconnectNamedPipe
+ * Purpose   : The DisconnectNamedPipe function disconnects the server end
+ *             of a named pipe instance from a client process.
+ * Parameters: HANDLE hNamedPipe    handle to named pipe
+ * Variables :
+ * Result    : If the function succeeds, the return value is nonzero.
+ *             If the function fails, the return value is zero
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Markus Montkowski [Tha, 1998/05/21 17:46]
+ *****************************************************************************/
+
+BOOL WIN32API DisconnectNamedPipe(HANDLE hNamedPipe)
+{
+
+  dprintf(("KERNEL32: DisconnectNamedPipe(%08x) not implemented\n",
+           hNamedPipe
+          ));
+
+  return (FALSE);
+}
+
+/*****************************************************************************
+ * Name      : BOOL GetNamedPipeHandleStateA
+ * Purpose   : The GetNamedPipeHandleStateA function retrieves information about
+ *             a specified named pipe. The information returned can vary during
+ *             the lifetime of an instance of the named pipe.
+ * Parameters: HANDLE  hNamedPipe           handle of named pipe
+ *             LPDWORD lpState              address of flags indicating pipe state
+ *             LPDWORD lpCurInstances       address of number of current pipe instances
+ *             LPDWORD lpMaxCollectionCount address of max. bytes before remote transmission
+ *             LPDWORD lpCollectDataTimeout address of max. time before remote transmission
+ *             LPTSTR  lpUserName           address of user name of client process
+ *             DWORD   nMaxUserNameSize     size, in characters, of user name buffer
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+BOOL WIN32API GetNamedPipeHandleStateA(HANDLE  hNamedPipe,
+                                          LPDWORD lpState,
+                                          LPDWORD lpCurInstances,
+                                          LPDWORD lpMaxCollectionCount,
+                                          LPDWORD lpCollectDataTimeout,
+                                          LPTSTR  lpUserName,
+                                          DWORD   nMaxUserNameSize)
+{
+  dprintf(("KERNEL32: GetNamedPipeHandleStateA(%08xh,%08xh,%08xh,%08xh,%08xh,%08xh,%08xh) not implemented\n",
+           hNamedPipe,
+           lpState,
+           lpCurInstances,
+           lpMaxCollectionCount,
+           lpCollectDataTimeout,
+           lpUserName,
+           nMaxUserNameSize));
+
+  return (FALSE);
+}
+
+
+/*****************************************************************************
+ * Name      : BOOL GetNamedPipeHandleStateW
+ * Purpose   : The GetNamedPipeHandleStateW function retrieves information about
+ *             a specified named pipe. The information returned can vary during
+ *             the lifetime of an instance of the named pipe.
+ * Parameters: HANDLE  hNamedPipe           handle of named pipe
+ *             LPDWORD lpState              address of flags indicating pipe state
+ *             LPDWORD lpCurInstances       address of number of current pipe instances
+ *             LPDWORD lpMaxCollectionCount address of max. bytes before remote transmission
+ *             LPDWORD lpCollectDataTimeout address of max. time before remote transmission
+ *             LPWSTR  lpUserName           address of user name of client process
+ *             DWORD   nMaxUserNameSize     size, in characters, of user name buffer
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+BOOL WIN32API GetNamedPipeHandleStateW(HANDLE  hNamedPipe,
+                                          LPDWORD lpState,
+                                          LPDWORD lpCurInstances,
+                                          LPDWORD lpMaxCollectionCount,
+                                          LPDWORD lpCollectDataTimeout,
+                                          LPWSTR  lpUserName,
+                                          DWORD   nMaxUserNameSize)
+{
+  dprintf(("KERNEL32: GetNamedPipeHandleStateW(%08xh,%08xh,%08xh,%08xh,%08xh,%08xh,%08xh) not implemented\n",
+           hNamedPipe,
+           lpState,
+           lpCurInstances,
+           lpMaxCollectionCount,
+           lpCollectDataTimeout,
+           lpUserName,
+           nMaxUserNameSize));
+
+  return (FALSE);
+}
+
+
+/*****************************************************************************
+ * Name      : BOOL GetNamedPipeInfo
+ * Purpose   : The GetNamedPipeInfo function retrieves information about the specified named pipe.
+ * Parameters: HANDLE  hNamedPipe      handle of named pipe
+ *             LPDWORD lpFlags         address of flags indicating type of pipe
+ *             LPDWORD lpOutBufferSize address of size, in bytes, of pipe's output buffer
+ *             LPDWORD lpInBufferSize  address of size, in bytes, of pipe's input buffer
+ *             LPDWORD lpMaxInstances  address of max. number of pipe instances
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+BOOL WIN32API GetNamedPipeInfo(HANDLE  hNamedPipe,
+                                  LPDWORD lpFlags,
+                                  LPDWORD lpOutBufferSize,
+                                  LPDWORD lpInBufferSize,
+                                  LPDWORD lpMaxInstances)
+{
+  dprintf(("KERNEL32: GetNamedPipeInfo(%08xh,%08xh,%08xh,%08xh,%08xh) not implemented\n",
+           hNamedPipe,
+           lpFlags,
+           lpOutBufferSize,
+           lpInBufferSize,
+           lpMaxInstances));
+
+  return (FALSE);
+}
+
+/*****************************************************************************
+ * Name      : BOOL SetNamedPipeHandleState
+ * Purpose   : The SetNamedPipeHandleState function sets the read mode and the
+ *             blocking mode of the specified named pipe. If the specified handle
+ *             is to the client end of a named pipe and if the named pipe server
+ *             process is on a remote computer, the function can also be used to
+ *             control local buffering.
+ * Parameters: HANDLE  hNamedPipe     handle of named pipe
+ *             LPDWORD lpdwMode       address of new pipe mode
+ *             LPDWORD lpcbMaxCollect address of max. bytes before remote transmission
+ *             LPDWORD lpdwCollectDataTimeout address of max. time before remote transmission
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+BOOL WIN32API SetNamedPipeHandleState(HANDLE  hNamedPipe,
+                                         LPDWORD lpdwMode,
+                                         LPDWORD lpcbMaxCollect,
+                                         LPDWORD lpdwCollectDataTimeout)
+{
+  dprintf(("KERNEL32: SetNamedPipeHandleState(%08xh,%08xh,%08xh,%08xh) not implemented.\n",
+           hNamedPipe,
+           lpdwMode,
+           lpcbMaxCollect,
+           lpdwCollectDataTimeout));
+
+  return (FALSE);
+}
+
+/*****************************************************************************
+ * Name      : DWORD TransactNamedPipe
+ * Purpose   : The TransactNamedPipe function combines into a single network
+ *             operation the functions that write a message to and read a
+ *             message from the specified named pipe.
+ * Parameters: HANDLE       hNamedPipe  handle of named pipe
+ *             LPVOID       lpvWriteBuf address of write buffer
+ *             DWORD        cbWriteBuf  size of the write buffer, in bytes
+ *             LPVOID       lpvReadBuf  address of read buffer
+ *             DWORD        cbReadBuf   size of read buffer, in bytes
+ *             LPDWORD      lpcbRead    address of variable for bytes actually read
+ *             LPOVERLAPPED lpo         address of overlapped structure
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+DWORD WIN32API TransactNamedPipe(HANDLE       hNamedPipe,
+                                    LPVOID       lpvWriteBuf,
+                                    DWORD        cbWriteBuf,
+                                    LPVOID       lpvReadBuf,
+                                    DWORD        cbReadBuf,
+                                    LPDWORD      lpcbRead,
+                                    LPOVERLAPPED lpo)
+{
+  dprintf(("KERNEL32: TransactNamedPipe(%08x,%08x,%08x,%08x,%08x,%08x,%08x) not implemented.\n",
+           hNamedPipe,
+           lpvWriteBuf,
+           cbWriteBuf,
+           lpvReadBuf,
+           cbReadBuf,
+           lpcbRead,
+           lpo));
+
+  return (FALSE);
+}
+
+/*****************************************************************************
+ * Name      : BOOL WaitNamedPipeA
+ * Purpose   : The WaitNamedPipe function waits until either a time-out interval
+ *             elapses or an instance of the specified named pipe is available
+ *             to be connected to (that is, the pipe's server process has a
+ *             pending ConnectNamedPipe operation on the pipe).
+ * Parameters: LPCTSTR lpszNamedPipeName
+ *             DWORD   dwTimeout
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+BOOL WIN32API WaitNamedPipeA(LPCTSTR lpszNamedPipeName,
+                                DWORD   dwTimeout)
+{
+  dprintf(("KERNEL32: WaitNamedPipeA(%s, %u) not implemented.\n",
+           lpszNamedPipeName,
+           dwTimeout));
+
+  return (FALSE);
+}
+
+
+/*****************************************************************************
+ * Name      : BOOL WaitNamedPipeW
+ * Purpose   : The WaitNamedPipe function waits until either a time-out interval
+ *             elapses or an instance of the specified named pipe is available
+ *             to be connected to (that is, the pipe's server process has a
+ *             pending ConnectNamedPipe operation on the pipe).
+ * Parameters: LPCWSTR lpszNamedPipeName
+ *             DWORD   dwTimeout
+ * Variables :
+ * Result    : TRUE / FALSE
+ * Remark    :
+ * Status    : UNTESTED STUB
+ *
+ * Author    : Patrick Haller [Mon, 1998/06/15 08:00]
+ *****************************************************************************/
+
+BOOL WIN32API WaitNamedPipeW(LPCWSTR lpszNamedPipeName,
+                                DWORD   dwTimeout)
+{
+  dprintf(("KERNEL32: WaitNamedPipeW(%s, %u) not implemented.\n",
+           lpszNamedPipeName,
+           dwTimeout));
+
+  return (FALSE);
+}