Win32NamedPipes.cs source code in C# .NET

                        
Code:
                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / clr / src / ManagedLibraries / Remoting / Channels / IPC / Win32NamedPipes.cs / 1305376 / Win32NamedPipes.cs
                        

                        
                            using System; 
using System.Text;
using System.Runtime.InteropServices;
using System.Threading;
using System.Security; 
using Microsoft.Win32.SafeHandles;
 
namespace System.Runtime.Remoting.Channels.Ipc 
{
    internal class PipeHandle : CriticalHandleMinusOneIsInvalid 
    {
        internal PipeHandle() : base() { }

        internal PipeHandle(IntPtr handle) : base() 
        {
            SetHandle(handle); 
        } 

        public IntPtr Handle 
        {
            get { return handle; }
        }
 
        protected override bool ReleaseHandle()
        { 
            return NativePipe.CloseHandle(handle) != 0; 
        }
    } 

    [StructLayout(LayoutKind.Sequential)]
    internal class SECURITY_ATTRIBUTES {
        internal int nLength = 0; 
        internal IntPtr lpSecurityDescriptor = IntPtr.Zero;
        internal int bInheritHandle = 0; 
    } 

    [SuppressUnmanagedCodeSecurity] 
    internal static class NativePipe
    {
        private const String Kernel32 = "kernel32.dll";
        private const String AdvApi32 = "advapi32.dll"; 
        internal static readonly IntPtr NULL = IntPtr.Zero;
        public const uint PIPE_ACCESS_OUTBOUND = 0x00000002; 
        public const uint PIPE_ACCESS_DUPLEX = 0x00000003; 
        public const uint PIPE_ACCESS_INBOUND = 0x00000001;
 
        public const uint PIPE_WAIT = 0x00000000;
        public const uint PIPE_NOWAIT = 0x00000001;
        public const uint PIPE_READMODE_BYTE = 0x00000000;
        public const uint PIPE_READMODE_MESSAGE = 0x00000002; 
        public const uint PIPE_TYPE_BYTE = 0x00000000;
        public const uint PIPE_TYPE_MESSAGE = 0x00000004; 
 
        public const uint PIPE_CLIENT_END = 0x00000000;
        public const uint PIPE_SERVER_END = 0x00000001; 
        public const uint FILE_FLAG_OVERLAPPED = 0x40000000;
        public const uint FILE_ATTRIBUTE_NORMAL = 0x00000080;
        public const uint FILE_SHARE_READ = 0x00000001;
        public const uint FILE_SHARE_WRITE = 0x00000002; 

        public const uint PIPE_UNLIMITED_INSTANCES = 255; 
 
        public const uint SECURITY_SQOS_PRESENT = 0x00100000;
        public const uint SECURITY_ANONYMOUS = 0 << 16; 
        public const uint SECURITY_IDENTIFICATION = 1 << 16;
        public const uint SECURITY_IMPERSONATION = 2 << 16;
        public const uint SECURITY_DELEGATION = 3 << 16;
 
        internal const int FORMAT_MESSAGE_IGNORE_INSERTS = 0x00000200;
        internal const int FORMAT_MESSAGE_FROM_SYSTEM    = 0x00001000; 
        internal const int FORMAT_MESSAGE_ARGUMENT_ARRAY = 0x00002000; 

        public const uint NMPWAIT_WAIT_FOREVER = 0xffffffff; 
        public const uint NMPWAIT_NOWAIT = 0x00000001;
        public const uint NMPWAIT_USE_DEFAULT_WAIT = 0x00000000;

        public const uint GENERIC_READ = (0x80000000); 
        public const uint GENERIC_WRITE = (0x40000000);
        public const uint GENERIC_EXECUTE = (0x20000000); 
        public const uint GENERIC_ALL = (0x10000000); 

        public const uint CREATE_NEW        = 1; 
        public const uint CREATE_ALWAYS     = 2;
        public const uint OPEN_EXISTING     = 3;
        public const uint OPEN_ALWAYS       = 4;
        public const uint TRUNCATE_EXISTING = 5; 
        public const uint FILE_FLAG_FIRST_PIPE_INSTANCE = 0x00080000;
 
        public const int INVALID_HANDLE_VALUE = -1; 
        public const long ERROR_BROKEN_PIPE = 109;
        public const long ERROR_IO_PENDING = 997; 
        public const long ERROR_PIPE_BUSY = 231;
        public const long ERROR_NO_DATA = 232;
        public const long ERROR_PIPE_NOT_CONNECTED = 233;
        public const long ERROR_PIPE_CONNECTED = 535; 
        public const long ERROR_PIPE_LISTENING = 536;
 
        //CreatePipe 

        [DllImport(Kernel32, SetLastError=true)] 
        public static extern PipeHandle CreateNamedPipe(String lpName,             // pipe name
                                                 uint dwOpenMode,            // pipe open mode
                                                 uint dwPipeMode,             // pipe-specific modes
                                                 uint nMaxInstances,          // maximum number of instances 
                                                 uint nOutBufferSize,         // output buffer size
                                                 uint nInBufferSize,          // input buffer size 
                                                 uint nDefaultTimeOut,       // time-out interval 
                                                 SECURITY_ATTRIBUTES pipeSecurityDescriptor	//SecurityAttributes attr					 // SD
                                                 ); 


        [DllImport(Kernel32, SetLastError=true)]
        public static extern bool ConnectNamedPipe(PipeHandle hNamedPipe,        // handle to named pipe 
                                                    Overlapped lpOverlapped  // overlapped structure
                                                    ); 
 

        [DllImport(AdvApi32, SetLastError=true)] 
        public static extern bool ImpersonateNamedPipeClient(PipeHandle hNamedPipe        // handle to named pipe
                                                       );

        [DllImport(AdvApi32)] 
        public static extern bool RevertToSelf();
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static extern PipeHandle CreateFile(String lpFileName,               // file name
                                             uint dwDesiredAccess,          // access mode 
                                             uint dwShareMode,             // share mode
                                             IntPtr attr,        // SecurityDescriptor
                                             uint dwCreationDisposition,     // how to create
                                             uint dwFlagsAndAttributes,    // file attributes 
                                             IntPtr hTemplateFile);           // handle to template file
 
 
        [DllImport(Kernel32, SetLastError=true)]
        public static unsafe extern bool ReadFile(PipeHandle hFile,                       // handle to file 
                                           byte* lpBuffer,                 // data buffer
                                           int nNumberOfBytesToRead,   // number of bytes to read
                                           ref int lpNumberOfBytesRead,  // number of bytes read
                                           IntPtr mustBeZero               // this should be IntPtr.Zero 
                                           );
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static unsafe extern bool ReadFile(PipeHandle hFile,                       // handle to file
                                           byte* lpBuffer,                 // data buffer 
                                           int nNumberOfBytesToRead,   // number of bytes to read
                                           IntPtr numBytesRead_mustBeZero,  // number of bytes must be zero
                                           NativeOverlapped* lpOverlapped   // overlapped buffer
                                           ); 

 
        [DllImport(Kernel32, SetLastError=true)] 
        public static unsafe extern bool WriteFile(
                                            PipeHandle hFile,                          // handle to file 
                                            byte* lpBuffer,                  // data buffer
                                            int nNumberOfBytesToWrite,   // number of bytes to write
                                            ref int lpNumberOfBytesWritten, // number of bytes written
                                            IntPtr lpOverlapped                 // overlapped buffer 
                                            );
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static extern bool WaitNamedPipe(String name,
                                                 int timeout); 

        [DllImport(Kernel32, SetLastError=true, CharSet=CharSet.Auto)]
        internal static extern int FormatMessage(int dwFlags, IntPtr lpSource,
                    int dwMessageId, int dwLanguageId, StringBuilder lpBuffer, 
                    int nSize, IntPtr va_list_arguments);
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static extern int CloseHandle(IntPtr hObject);
 
    }

}
 


// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
using System; 
using System.Text;
using System.Runtime.InteropServices;
using System.Threading;
using System.Security; 
using Microsoft.Win32.SafeHandles;
 
namespace System.Runtime.Remoting.Channels.Ipc 
{
    internal class PipeHandle : CriticalHandleMinusOneIsInvalid 
    {
        internal PipeHandle() : base() { }

        internal PipeHandle(IntPtr handle) : base() 
        {
            SetHandle(handle); 
        } 

        public IntPtr Handle 
        {
            get { return handle; }
        }
 
        protected override bool ReleaseHandle()
        { 
            return NativePipe.CloseHandle(handle) != 0; 
        }
    } 

    [StructLayout(LayoutKind.Sequential)]
    internal class SECURITY_ATTRIBUTES {
        internal int nLength = 0; 
        internal IntPtr lpSecurityDescriptor = IntPtr.Zero;
        internal int bInheritHandle = 0; 
    } 

    [SuppressUnmanagedCodeSecurity] 
    internal static class NativePipe
    {
        private const String Kernel32 = "kernel32.dll";
        private const String AdvApi32 = "advapi32.dll"; 
        internal static readonly IntPtr NULL = IntPtr.Zero;
        public const uint PIPE_ACCESS_OUTBOUND = 0x00000002; 
        public const uint PIPE_ACCESS_DUPLEX = 0x00000003; 
        public const uint PIPE_ACCESS_INBOUND = 0x00000001;
 
        public const uint PIPE_WAIT = 0x00000000;
        public const uint PIPE_NOWAIT = 0x00000001;
        public const uint PIPE_READMODE_BYTE = 0x00000000;
        public const uint PIPE_READMODE_MESSAGE = 0x00000002; 
        public const uint PIPE_TYPE_BYTE = 0x00000000;
        public const uint PIPE_TYPE_MESSAGE = 0x00000004; 
 
        public const uint PIPE_CLIENT_END = 0x00000000;
        public const uint PIPE_SERVER_END = 0x00000001; 
        public const uint FILE_FLAG_OVERLAPPED = 0x40000000;
        public const uint FILE_ATTRIBUTE_NORMAL = 0x00000080;
        public const uint FILE_SHARE_READ = 0x00000001;
        public const uint FILE_SHARE_WRITE = 0x00000002; 

        public const uint PIPE_UNLIMITED_INSTANCES = 255; 
 
        public const uint SECURITY_SQOS_PRESENT = 0x00100000;
        public const uint SECURITY_ANONYMOUS = 0 << 16; 
        public const uint SECURITY_IDENTIFICATION = 1 << 16;
        public const uint SECURITY_IMPERSONATION = 2 << 16;
        public const uint SECURITY_DELEGATION = 3 << 16;
 
        internal const int FORMAT_MESSAGE_IGNORE_INSERTS = 0x00000200;
        internal const int FORMAT_MESSAGE_FROM_SYSTEM    = 0x00001000; 
        internal const int FORMAT_MESSAGE_ARGUMENT_ARRAY = 0x00002000; 

        public const uint NMPWAIT_WAIT_FOREVER = 0xffffffff; 
        public const uint NMPWAIT_NOWAIT = 0x00000001;
        public const uint NMPWAIT_USE_DEFAULT_WAIT = 0x00000000;

        public const uint GENERIC_READ = (0x80000000); 
        public const uint GENERIC_WRITE = (0x40000000);
        public const uint GENERIC_EXECUTE = (0x20000000); 
        public const uint GENERIC_ALL = (0x10000000); 

        public const uint CREATE_NEW        = 1; 
        public const uint CREATE_ALWAYS     = 2;
        public const uint OPEN_EXISTING     = 3;
        public const uint OPEN_ALWAYS       = 4;
        public const uint TRUNCATE_EXISTING = 5; 
        public const uint FILE_FLAG_FIRST_PIPE_INSTANCE = 0x00080000;
 
        public const int INVALID_HANDLE_VALUE = -1; 
        public const long ERROR_BROKEN_PIPE = 109;
        public const long ERROR_IO_PENDING = 997; 
        public const long ERROR_PIPE_BUSY = 231;
        public const long ERROR_NO_DATA = 232;
        public const long ERROR_PIPE_NOT_CONNECTED = 233;
        public const long ERROR_PIPE_CONNECTED = 535; 
        public const long ERROR_PIPE_LISTENING = 536;
 
        //CreatePipe 

        [DllImport(Kernel32, SetLastError=true)] 
        public static extern PipeHandle CreateNamedPipe(String lpName,             // pipe name
                                                 uint dwOpenMode,            // pipe open mode
                                                 uint dwPipeMode,             // pipe-specific modes
                                                 uint nMaxInstances,          // maximum number of instances 
                                                 uint nOutBufferSize,         // output buffer size
                                                 uint nInBufferSize,          // input buffer size 
                                                 uint nDefaultTimeOut,       // time-out interval 
                                                 SECURITY_ATTRIBUTES pipeSecurityDescriptor	//SecurityAttributes attr					 // SD
                                                 ); 


        [DllImport(Kernel32, SetLastError=true)]
        public static extern bool ConnectNamedPipe(PipeHandle hNamedPipe,        // handle to named pipe 
                                                    Overlapped lpOverlapped  // overlapped structure
                                                    ); 
 

        [DllImport(AdvApi32, SetLastError=true)] 
        public static extern bool ImpersonateNamedPipeClient(PipeHandle hNamedPipe        // handle to named pipe
                                                       );

        [DllImport(AdvApi32)] 
        public static extern bool RevertToSelf();
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static extern PipeHandle CreateFile(String lpFileName,               // file name
                                             uint dwDesiredAccess,          // access mode 
                                             uint dwShareMode,             // share mode
                                             IntPtr attr,        // SecurityDescriptor
                                             uint dwCreationDisposition,     // how to create
                                             uint dwFlagsAndAttributes,    // file attributes 
                                             IntPtr hTemplateFile);           // handle to template file
 
 
        [DllImport(Kernel32, SetLastError=true)]
        public static unsafe extern bool ReadFile(PipeHandle hFile,                       // handle to file 
                                           byte* lpBuffer,                 // data buffer
                                           int nNumberOfBytesToRead,   // number of bytes to read
                                           ref int lpNumberOfBytesRead,  // number of bytes read
                                           IntPtr mustBeZero               // this should be IntPtr.Zero 
                                           );
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static unsafe extern bool ReadFile(PipeHandle hFile,                       // handle to file
                                           byte* lpBuffer,                 // data buffer 
                                           int nNumberOfBytesToRead,   // number of bytes to read
                                           IntPtr numBytesRead_mustBeZero,  // number of bytes must be zero
                                           NativeOverlapped* lpOverlapped   // overlapped buffer
                                           ); 

 
        [DllImport(Kernel32, SetLastError=true)] 
        public static unsafe extern bool WriteFile(
                                            PipeHandle hFile,                          // handle to file 
                                            byte* lpBuffer,                  // data buffer
                                            int nNumberOfBytesToWrite,   // number of bytes to write
                                            ref int lpNumberOfBytesWritten, // number of bytes written
                                            IntPtr lpOverlapped                 // overlapped buffer 
                                            );
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static extern bool WaitNamedPipe(String name,
                                                 int timeout); 

        [DllImport(Kernel32, SetLastError=true, CharSet=CharSet.Auto)]
        internal static extern int FormatMessage(int dwFlags, IntPtr lpSource,
                    int dwMessageId, int dwLanguageId, StringBuilder lpBuffer, 
                    int nSize, IntPtr va_list_arguments);
 
        [DllImport(Kernel32, SetLastError=true)] 
        public static extern int CloseHandle(IntPtr hObject);
 
    }

}
 


// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.

                        

                        

                        
                        

Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK

• IOException.cs
• TagPrefixCollection.cs
• MsmqChannelListenerBase.cs
• NullReferenceException.cs
• SessionStateUtil.cs
• ContentPosition.cs
• StickyNote.cs
• WSFederationHttpBinding.cs
• InvocationExpression.cs
• PropVariant.cs
• IntPtr.cs
• ReadContentAsBinaryHelper.cs
• TypedTableHandler.cs
• ModulesEntry.cs
• XmlExceptionHelper.cs
• Logging.cs
• ZipIOBlockManager.cs
• HMACSHA1.cs
• ProtocolsConfigurationHandler.cs
• UIElement.cs
• GridViewSortEventArgs.cs
• GridView.cs
• AdjustableArrowCap.cs
• IssuedTokenServiceCredential.cs
• Utils.cs
• TableDetailsRow.cs
• LockCookie.cs
• DataRowView.cs
• IsolatedStoragePermission.cs
• TraceSection.cs
• SequentialOutput.cs
• ProviderCollection.cs
• ElapsedEventArgs.cs
• CompModSwitches.cs
• DataTableReaderListener.cs
• PrinterSettings.cs
• HttpCookie.cs
• Directory.cs
• ViewKeyConstraint.cs
• shaperfactoryquerycachekey.cs
• NamespaceMapping.cs
• BitArray.cs
• DecoderBestFitFallback.cs
• KeyValueConfigurationElement.cs
• AssemblyAttributes.cs
• RenameRuleObjectDialog.cs
• RtfControlWordInfo.cs
• DataRecordObjectView.cs
• NetCodeGroup.cs
• MemberPathMap.cs
• TextTreeExtractElementUndoUnit.cs
• IRCollection.cs
• DeviceSpecificChoice.cs
• SerializationSectionGroup.cs
• OperatorExpressions.cs
• SelectionPattern.cs
• RsaSecurityToken.cs
• HttpHandlersSection.cs
• DivideByZeroException.cs
• ErrorStyle.cs
• OleDbCommandBuilder.cs
• UseLicense.cs
• BehaviorDragDropEventArgs.cs
• shaperfactoryquerycachekey.cs
• BamlLocalizableResource.cs
• MatrixTransform.cs
• WpfMemberInvoker.cs
• CodeIndexerExpression.cs
• Figure.cs
• BufferAllocator.cs
• WindowsPen.cs
• NegotiateStream.cs
• HybridWebProxyFinder.cs
• InvokePattern.cs
• RepeatBehavior.cs
• IntSecurity.cs
• ContextMenuAutomationPeer.cs
• ExpanderAutomationPeer.cs
• Visitor.cs
• Screen.cs
• tabpagecollectioneditor.cs
• SelectionManager.cs
• SimpleFieldTemplateUserControl.cs
• BrowserDefinitionCollection.cs
• _HeaderInfoTable.cs
• AutoResizedEvent.cs
• DeviceSpecificChoiceCollection.cs
• PropertyValueChangedEvent.cs
• DataKey.cs
• ThreadPool.cs
• QuadraticBezierSegment.cs
• EastAsianLunisolarCalendar.cs
• BamlTreeNode.cs
• RemotingSurrogateSelector.cs
• PrimitiveXmlSerializers.cs
• X509Utils.cs
• OutputCacheProfileCollection.cs
• ISCIIEncoding.cs
• InputMethod.cs
• MethodToken.cs