EventWaitHandle.cs source code in C# .NET

                        
Code:
                         / Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / clr / src / BCL / System / Threading / EventWaitHandle.cs / 1 / EventWaitHandle.cs
                        

                        
                            // ==++== 
//
//   Copyright (c) Microsoft Corporation.  All rights reserved.
//
// ==--== 
/*==============================================================================
** 
** Class: EventWaitHandle	 
**
** 
** Purpose: Base class for representing Events
**
**
=============================================================================*/ 

namespace System.Threading 
{ 
    using System;
    using System.Threading; 
    using System.Runtime.CompilerServices;
    using System.Security.Permissions;
    using System.IO;
    using Microsoft.Win32; 
    using Microsoft.Win32.SafeHandles;
    using System.Runtime.InteropServices; 
    using System.Runtime.Versioning; 
#if !FEATURE_PAL
    using System.Security.AccessControl; 
#endif

    [HostProtection(Synchronization=true, ExternalThreading=true)]
    [ComVisibleAttribute(true)] 
    public class EventWaitHandle : WaitHandle
    { 
        [ResourceExposure(ResourceScope.None)] 
        [ResourceConsumption(ResourceScope.Machine, ResourceScope.Machine)]
        public EventWaitHandle(bool initialState, EventResetMode mode) : this(initialState,mode,null) { } 

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)]
        [ResourceExposure(ResourceScope.Machine)]
        [ResourceConsumption(ResourceScope.Machine)] 
        public EventWaitHandle(bool initialState, EventResetMode mode, string name)
        { 
            if(null != name && System.IO.Path.MAX_PATH < name.Length) 
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_WaitHandleNameTooLong",name)); 
            }

            SafeWaitHandle _handle = null;
            switch(mode) 
            {
                case EventResetMode.ManualReset: 
                    _handle = Win32Native.CreateEvent(null, true, initialState, name); 
                    break;
                case EventResetMode.AutoReset: 
                    _handle = Win32Native.CreateEvent(null, false, initialState, name);
                    break;

                default: 
                    throw new ArgumentException(Environment.GetResourceString("Argument_InvalidFlag",name));
            }; 
 
            if (_handle.IsInvalid)
            { 
                int errorCode = Marshal.GetLastWin32Error();

                _handle.SetHandleAsInvalid();
                if(null != name && 0 != name.Length && Win32Native.ERROR_INVALID_HANDLE == errorCode) 
                    throw new WaitHandleCannotBeOpenedException(Environment.GetResourceString("Threading.WaitHandleCannotBeOpenedException_InvalidHandle",name));
 
                __Error.WinIOError(errorCode, ""); 
            }	
            SetHandleInternal(_handle); 
        }

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)]
        [ResourceExposure(ResourceScope.Machine)] 
        [ResourceConsumption(ResourceScope.Machine)]
        public EventWaitHandle(bool initialState, EventResetMode mode, string name, out bool createdNew) 
#if !FEATURE_PAL 
            : this(initialState, mode, name, out createdNew, null)
        { 
        }

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)]
        [ResourceExposure(ResourceScope.Machine)] 
        [ResourceConsumption(ResourceScope.Machine)]
        public unsafe EventWaitHandle(bool initialState, EventResetMode mode, string name, out bool createdNew, EventWaitHandleSecurity eventSecurity) 
#endif 
        {
            if(null != name && System.IO.Path.MAX_PATH < name.Length) 
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_WaitHandleNameTooLong",name));
            }
            Win32Native.SECURITY_ATTRIBUTES secAttrs = null; 
#if !FEATURE_PAL
            // For ACL's, get the security descriptor from the EventWaitHandleSecurity. 
            if (eventSecurity != null) { 
                secAttrs = new Win32Native.SECURITY_ATTRIBUTES();
                secAttrs.nLength = (int)Marshal.SizeOf(secAttrs); 

                byte[] sd = eventSecurity.GetSecurityDescriptorBinaryForm();
                byte* pSecDescriptor = stackalloc byte[sd.Length];
                Buffer.memcpy(sd, 0, pSecDescriptor, 0, sd.Length); 
                secAttrs.pSecurityDescriptor = pSecDescriptor;
            } 
#endif 

            SafeWaitHandle _handle = null; 
            Boolean isManualReset;
            switch(mode)
            {
                case EventResetMode.ManualReset: 
                    isManualReset = true;
                    break; 
                case EventResetMode.AutoReset: 
                    isManualReset = false;
                    break; 

                default:
                    throw new ArgumentException(Environment.GetResourceString("Argument_InvalidFlag",name));
            }; 

            _handle = Win32Native.CreateEvent(secAttrs, isManualReset, initialState, name); 
            int errorCode = Marshal.GetLastWin32Error(); 

            if (_handle.IsInvalid) 
            {

                _handle.SetHandleAsInvalid();
                if(null != name && 0 != name.Length && Win32Native.ERROR_INVALID_HANDLE == errorCode) 
                    throw new WaitHandleCannotBeOpenedException(Environment.GetResourceString("Threading.WaitHandleCannotBeOpenedException_InvalidHandle",name));
 
                __Error.WinIOError(errorCode, name); 
            }
            createdNew = errorCode != Win32Native.ERROR_ALREADY_EXISTS; 
            SetHandleInternal(_handle);
        }

        private EventWaitHandle(SafeWaitHandle handle) 
        {
            SetHandleInternal(handle); 
        } 

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)] 
        [ResourceExposure(ResourceScope.Machine)]
        [ResourceConsumption(ResourceScope.Machine)]
        public static EventWaitHandle OpenExisting(string name)
        { 
#if !FEATURE_PAL
            return OpenExisting(name, EventWaitHandleRights.Modify | EventWaitHandleRights.Synchronize); 
        } 

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)] 
        [ResourceExposure(ResourceScope.Machine)]
        [ResourceConsumption(ResourceScope.Machine)]
        public static EventWaitHandle OpenExisting(string name, EventWaitHandleRights rights)
        { 
#endif  // !FEATURE_PAL
            if (name == null) 
            { 
                throw new ArgumentNullException("name", Environment.GetResourceString("ArgumentNull_WithParamName"));
            } 

            if(name.Length  == 0)
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_EmptyName"), "name"); 
            }
 
            if(null != name && System.IO.Path.MAX_PATH < name.Length) 
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_WaitHandleNameTooLong",name)); 
            }


#if FEATURE_PAL 
            SafeWaitHandle myHandle = Win32Native.OpenEvent(Win32Native.EVENT_MODIFY_STATE | Win32Native.SYNCHRONIZE, false, name);
#else 
            SafeWaitHandle myHandle = Win32Native.OpenEvent((int) rights, false, name); 
#endif
 
            if (myHandle.IsInvalid)
            {
                int errorCode = Marshal.GetLastWin32Error();
 
                if(Win32Native.ERROR_FILE_NOT_FOUND == errorCode || Win32Native.ERROR_INVALID_NAME == errorCode)
                    throw new WaitHandleCannotBeOpenedException(); 
                if(null != name && 0 != name.Length && Win32Native.ERROR_INVALID_HANDLE == errorCode) 
                    throw new WaitHandleCannotBeOpenedException(Environment.GetResourceString("Threading.WaitHandleCannotBeOpenedException_InvalidHandle",name));
                //this is for passed through Win32Native Errors 
                __Error.WinIOError(errorCode,"");
            }
            return new EventWaitHandle(myHandle);
        } 
        public bool Reset()
        { 
            bool res = Win32Native.ResetEvent(safeWaitHandle); 
            if (!res)
                __Error.WinIOError(); 
            return res;
        }
        public bool Set()
        { 
            bool res = Win32Native.SetEvent(safeWaitHandle);
 
            if (!res) 
                __Error.WinIOError();
 
            return res;
        }

#if !FEATURE_PAL 
        public EventWaitHandleSecurity GetAccessControl()
        { 
            return new EventWaitHandleSecurity(safeWaitHandle, AccessControlSections.Access | AccessControlSections.Owner | AccessControlSections.Group); 
        }
 
        public void SetAccessControl(EventWaitHandleSecurity eventSecurity)
        {
            if (eventSecurity == null)
                throw new ArgumentNullException("eventSecurity"); 

            eventSecurity.Persist(safeWaitHandle); 
        } 
#endif
    } 
}


// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// ==++== 
//
//   Copyright (c) Microsoft Corporation.  All rights reserved.
//
// ==--== 
/*==============================================================================
** 
** Class: EventWaitHandle	 
**
** 
** Purpose: Base class for representing Events
**
**
=============================================================================*/ 

namespace System.Threading 
{ 
    using System;
    using System.Threading; 
    using System.Runtime.CompilerServices;
    using System.Security.Permissions;
    using System.IO;
    using Microsoft.Win32; 
    using Microsoft.Win32.SafeHandles;
    using System.Runtime.InteropServices; 
    using System.Runtime.Versioning; 
#if !FEATURE_PAL
    using System.Security.AccessControl; 
#endif

    [HostProtection(Synchronization=true, ExternalThreading=true)]
    [ComVisibleAttribute(true)] 
    public class EventWaitHandle : WaitHandle
    { 
        [ResourceExposure(ResourceScope.None)] 
        [ResourceConsumption(ResourceScope.Machine, ResourceScope.Machine)]
        public EventWaitHandle(bool initialState, EventResetMode mode) : this(initialState,mode,null) { } 

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)]
        [ResourceExposure(ResourceScope.Machine)]
        [ResourceConsumption(ResourceScope.Machine)] 
        public EventWaitHandle(bool initialState, EventResetMode mode, string name)
        { 
            if(null != name && System.IO.Path.MAX_PATH < name.Length) 
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_WaitHandleNameTooLong",name)); 
            }

            SafeWaitHandle _handle = null;
            switch(mode) 
            {
                case EventResetMode.ManualReset: 
                    _handle = Win32Native.CreateEvent(null, true, initialState, name); 
                    break;
                case EventResetMode.AutoReset: 
                    _handle = Win32Native.CreateEvent(null, false, initialState, name);
                    break;

                default: 
                    throw new ArgumentException(Environment.GetResourceString("Argument_InvalidFlag",name));
            }; 
 
            if (_handle.IsInvalid)
            { 
                int errorCode = Marshal.GetLastWin32Error();

                _handle.SetHandleAsInvalid();
                if(null != name && 0 != name.Length && Win32Native.ERROR_INVALID_HANDLE == errorCode) 
                    throw new WaitHandleCannotBeOpenedException(Environment.GetResourceString("Threading.WaitHandleCannotBeOpenedException_InvalidHandle",name));
 
                __Error.WinIOError(errorCode, ""); 
            }	
            SetHandleInternal(_handle); 
        }

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)]
        [ResourceExposure(ResourceScope.Machine)] 
        [ResourceConsumption(ResourceScope.Machine)]
        public EventWaitHandle(bool initialState, EventResetMode mode, string name, out bool createdNew) 
#if !FEATURE_PAL 
            : this(initialState, mode, name, out createdNew, null)
        { 
        }

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)]
        [ResourceExposure(ResourceScope.Machine)] 
        [ResourceConsumption(ResourceScope.Machine)]
        public unsafe EventWaitHandle(bool initialState, EventResetMode mode, string name, out bool createdNew, EventWaitHandleSecurity eventSecurity) 
#endif 
        {
            if(null != name && System.IO.Path.MAX_PATH < name.Length) 
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_WaitHandleNameTooLong",name));
            }
            Win32Native.SECURITY_ATTRIBUTES secAttrs = null; 
#if !FEATURE_PAL
            // For ACL's, get the security descriptor from the EventWaitHandleSecurity. 
            if (eventSecurity != null) { 
                secAttrs = new Win32Native.SECURITY_ATTRIBUTES();
                secAttrs.nLength = (int)Marshal.SizeOf(secAttrs); 

                byte[] sd = eventSecurity.GetSecurityDescriptorBinaryForm();
                byte* pSecDescriptor = stackalloc byte[sd.Length];
                Buffer.memcpy(sd, 0, pSecDescriptor, 0, sd.Length); 
                secAttrs.pSecurityDescriptor = pSecDescriptor;
            } 
#endif 

            SafeWaitHandle _handle = null; 
            Boolean isManualReset;
            switch(mode)
            {
                case EventResetMode.ManualReset: 
                    isManualReset = true;
                    break; 
                case EventResetMode.AutoReset: 
                    isManualReset = false;
                    break; 

                default:
                    throw new ArgumentException(Environment.GetResourceString("Argument_InvalidFlag",name));
            }; 

            _handle = Win32Native.CreateEvent(secAttrs, isManualReset, initialState, name); 
            int errorCode = Marshal.GetLastWin32Error(); 

            if (_handle.IsInvalid) 
            {

                _handle.SetHandleAsInvalid();
                if(null != name && 0 != name.Length && Win32Native.ERROR_INVALID_HANDLE == errorCode) 
                    throw new WaitHandleCannotBeOpenedException(Environment.GetResourceString("Threading.WaitHandleCannotBeOpenedException_InvalidHandle",name));
 
                __Error.WinIOError(errorCode, name); 
            }
            createdNew = errorCode != Win32Native.ERROR_ALREADY_EXISTS; 
            SetHandleInternal(_handle);
        }

        private EventWaitHandle(SafeWaitHandle handle) 
        {
            SetHandleInternal(handle); 
        } 

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)] 
        [ResourceExposure(ResourceScope.Machine)]
        [ResourceConsumption(ResourceScope.Machine)]
        public static EventWaitHandle OpenExisting(string name)
        { 
#if !FEATURE_PAL
            return OpenExisting(name, EventWaitHandleRights.Modify | EventWaitHandleRights.Synchronize); 
        } 

        [SecurityPermissionAttribute(SecurityAction.LinkDemand,Flags=SecurityPermissionFlag.UnmanagedCode)] 
        [ResourceExposure(ResourceScope.Machine)]
        [ResourceConsumption(ResourceScope.Machine)]
        public static EventWaitHandle OpenExisting(string name, EventWaitHandleRights rights)
        { 
#endif  // !FEATURE_PAL
            if (name == null) 
            { 
                throw new ArgumentNullException("name", Environment.GetResourceString("ArgumentNull_WithParamName"));
            } 

            if(name.Length  == 0)
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_EmptyName"), "name"); 
            }
 
            if(null != name && System.IO.Path.MAX_PATH < name.Length) 
            {
                throw new ArgumentException(Environment.GetResourceString("Argument_WaitHandleNameTooLong",name)); 
            }


#if FEATURE_PAL 
            SafeWaitHandle myHandle = Win32Native.OpenEvent(Win32Native.EVENT_MODIFY_STATE | Win32Native.SYNCHRONIZE, false, name);
#else 
            SafeWaitHandle myHandle = Win32Native.OpenEvent((int) rights, false, name); 
#endif
 
            if (myHandle.IsInvalid)
            {
                int errorCode = Marshal.GetLastWin32Error();
 
                if(Win32Native.ERROR_FILE_NOT_FOUND == errorCode || Win32Native.ERROR_INVALID_NAME == errorCode)
                    throw new WaitHandleCannotBeOpenedException(); 
                if(null != name && 0 != name.Length && Win32Native.ERROR_INVALID_HANDLE == errorCode) 
                    throw new WaitHandleCannotBeOpenedException(Environment.GetResourceString("Threading.WaitHandleCannotBeOpenedException_InvalidHandle",name));
                //this is for passed through Win32Native Errors 
                __Error.WinIOError(errorCode,"");
            }
            return new EventWaitHandle(myHandle);
        } 
        public bool Reset()
        { 
            bool res = Win32Native.ResetEvent(safeWaitHandle); 
            if (!res)
                __Error.WinIOError(); 
            return res;
        }
        public bool Set()
        { 
            bool res = Win32Native.SetEvent(safeWaitHandle);
 
            if (!res) 
                __Error.WinIOError();
 
            return res;
        }

#if !FEATURE_PAL 
        public EventWaitHandleSecurity GetAccessControl()
        { 
            return new EventWaitHandleSecurity(safeWaitHandle, AccessControlSections.Access | AccessControlSections.Owner | AccessControlSections.Group); 
        }
 
        public void SetAccessControl(EventWaitHandleSecurity eventSecurity)
        {
            if (eventSecurity == null)
                throw new ArgumentNullException("eventSecurity"); 

            eventSecurity.Persist(safeWaitHandle); 
        } 
#endif
    } 
}


// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
                        

                        

                        
                        

Link Menu

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

• Expression.cs
• ComponentCollection.cs
• SmiMetaDataProperty.cs
• ScriptMethodAttribute.cs
• DesignerWidgets.cs
• CheckableControlBaseAdapter.cs
• MultiBindingExpression.cs
• LineGeometry.cs
• TypeLibConverter.cs
• ValidatorCompatibilityHelper.cs
• ProgressBarAutomationPeer.cs
• DoubleAnimationUsingPath.cs
• RegexStringValidator.cs
• CommandDevice.cs
• GridItemProviderWrapper.cs
• HttpCookiesSection.cs
• WpfKnownTypeInvoker.cs
• Symbol.cs
• oledbmetadatacolumnnames.cs
• PersonalizableTypeEntry.cs
• IsolatedStorage.cs
• ProcessModelInfo.cs
• GenericXmlSecurityToken.cs
• COM2ColorConverter.cs
• ViewManager.cs
• ConnectionsZone.cs
• ZipIOLocalFileHeader.cs
• serverconfig.cs
• XmlDomTextWriter.cs
• WebPartEditVerb.cs
• UrlAuthorizationModule.cs
• SoapAttributes.cs
• TimeSpanMinutesOrInfiniteConverter.cs
• DoubleConverter.cs
• ImageSourceValueSerializer.cs
• AutomationAttributeInfo.cs
• Model3D.cs
• ComContractElement.cs
• SqlWriter.cs
• PeerReferralPolicy.cs
• TransformerTypeCollection.cs
• ZipIOCentralDirectoryDigitalSignature.cs
• TableLayoutStyle.cs
• ServiceTimeoutsElement.cs
• AudioFormatConverter.cs
• webclient.cs
• IndexedWhereQueryOperator.cs
• HorizontalAlignConverter.cs
• DataGridViewCellStateChangedEventArgs.cs
• DataGridToolTip.cs
• DesignerDataRelationship.cs
• UpdatableGenericsFeature.cs
• DynamicResourceExtension.cs
• LocalizationComments.cs
• EventHandlingScope.cs
• ControlIdConverter.cs
• CroppedBitmap.cs
• TextBreakpoint.cs
• X509PeerCertificateElement.cs
• ListViewUpdateEventArgs.cs
• BitmapDownload.cs
• DbProviderFactory.cs
• TokenizerHelper.cs
• ErrorFormatter.cs
• XmlSchemaAny.cs
• regiisutil.cs
• WebPermission.cs
• CfgSemanticTag.cs
• ObjectStateFormatter.cs
• FixedLineResult.cs
• CompilerCollection.cs
• RadialGradientBrush.cs
• VoiceSynthesis.cs
• SynchronizedDispatch.cs
• VerticalConnector.xaml.cs
• BoundPropertyEntry.cs
• OperationGenerator.cs
• X509DefaultServiceCertificateElement.cs
• SmtpMail.cs
• QueryPageSettingsEventArgs.cs
• configsystem.cs
• ColumnTypeConverter.cs
• QueryTreeBuilder.cs
• SchemaImporterExtensionElement.cs
• SafeCertificateStore.cs
• ClientSession.cs
• AffineTransform3D.cs
• StringTraceRecord.cs
• Win32MouseDevice.cs
• IItemProperties.cs
• FixedNode.cs
• EmptyQuery.cs
• Wizard.cs
• EmptyControlCollection.cs
• InvalidDocumentContentsException.cs
• rsa.cs
• _PooledStream.cs
• GenericIdentity.cs
• DataContext.cs
• IPHostEntry.cs