EnlistmentState.cs source code in C# .NET

                        
Code:
                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / tx / System / Transactions / EnlistmentState.cs / 1305376 / EnlistmentState.cs
                        

                        
                            //------------------------------------------------------------------------------ 
// 
//     Copyright (c) Microsoft Corporation.  All rights reserved.
// 
//----------------------------------------------------------------------------- 

namespace System.Transactions 
{ 
    using System;
    using System.Diagnostics; 
    using System.Globalization;
    using System.Threading;
    using System.Transactions.Diagnostics;
 

    // Base class for all enlistment states 
    abstract class EnlistmentState 
    {
        internal abstract void EnterState( InternalEnlistment enlistment ); 


        internal static EnlistmentStatePromoted _enlistmentStatePromoted;
 
        // Object for synchronizing access to the entire class( avoiding lock( typeof( ... )) )
        private static object classSyncObject; 
 

        // Helper object for static synchronization 
        private static object ClassSyncObject
        {
            get
            { 
                if( classSyncObject == null )
                { 
                    object o = new object(); 
                    Interlocked.CompareExchange( ref classSyncObject, o, null );
                } 
                return classSyncObject;
            }
        }
 

        internal  static EnlistmentStatePromoted _EnlistmentStatePromoted 
        { 
            get
            { 
                if (_enlistmentStatePromoted == null)
                {
                    lock (ClassSyncObject)
                    { 
                        if (_enlistmentStatePromoted == null)
                        { 
                            EnlistmentStatePromoted temp = new EnlistmentStatePromoted(); 
                            Thread.MemoryBarrier();
                            _enlistmentStatePromoted = temp; 
                        }
                    }
                }
 
                return _enlistmentStatePromoted;
            } 
        } 

 

        internal virtual void EnlistmentDone( InternalEnlistment enlistment )
        {
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 
 
        internal virtual void Prepared( InternalEnlistment enlistment )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }

 
        internal virtual void ForceRollback( InternalEnlistment enlistment, Exception e )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 

        internal virtual void Committed( InternalEnlistment enlistment )
        {
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 
 
        internal virtual void Aborted( InternalEnlistment enlistment, Exception e )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }

 
        internal virtual void InDoubt( InternalEnlistment enlistment, Exception e )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 

        internal virtual byte[] RecoveryInformation( InternalEnlistment enlistment )
        {
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 
 
        internal virtual void InternalAborted( InternalEnlistment enlistment )
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }
 

        internal virtual void InternalCommitted( InternalEnlistment enlistment ) 
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }


        internal virtual void InternalIndoubt( InternalEnlistment enlistment ) 
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 

        internal virtual void ChangeStateCommitting( InternalEnlistment enlistment )
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        } 
 

        internal virtual void ChangeStatePromoted( InternalEnlistment enlistment, IPromotedEnlistment promotedEnlistment ) 
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        } 

 
        internal virtual void ChangeStateDelegated( InternalEnlistment enlistment ) 
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }

 
        internal virtual void ChangeStatePreparing( InternalEnlistment enlistment )
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        } 


        internal virtual void ChangeStateSinglePhaseCommit( InternalEnlistment enlistment )
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        } 
    }
 


    internal class EnlistmentStatePromoted : EnlistmentState
    { 
        internal override void EnterState( InternalEnlistment enlistment )
        { 
            enlistment.State = this; 
        }
 

        internal override void EnlistmentDone( InternalEnlistment enlistment )
        {
            Monitor.Exit( enlistment.SyncRoot ); 
            try
            { 
                enlistment.PromotedEnlistment.EnlistmentDone(); 
            }
            finally 
            {
#pragma warning disable 0618
                //@
                Monitor.Enter(enlistment.SyncRoot); 
#pragma warning restore 0618
            } 
        } 

 
        internal override void Prepared( InternalEnlistment enlistment )
        {
            Monitor.Exit( enlistment.SyncRoot );
            try 
            {
                enlistment.PromotedEnlistment.Prepared(); 
            } 
            finally
            { 
#pragma warning disable 0618
                //@
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618 
            }
        } 
 

        internal override void ForceRollback( InternalEnlistment enlistment, Exception e ) 
        {
            Monitor.Exit( enlistment.SyncRoot );
            try
            { 
                enlistment.PromotedEnlistment.ForceRollback( e );
            } 
            finally 
            {
#pragma warning disable 0618 
                //@
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618
            } 
        }
 
 
        internal override void Committed( InternalEnlistment enlistment )
        { 
            Monitor.Exit( enlistment.SyncRoot );
            try
            {
                enlistment.PromotedEnlistment.Committed(); 
            }
            finally 
            { 
#pragma warning disable 0618
                //@ 
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618
            }
        } 

 
        internal override void Aborted( InternalEnlistment enlistment, Exception e ) 
        {
            Monitor.Exit( enlistment.SyncRoot ); 
            try
            {
                enlistment.PromotedEnlistment.Aborted( e );
            } 
            finally
            { 
#pragma warning disable 0618 
                //@
                Monitor.Enter(enlistment.SyncRoot); 
#pragma warning restore 0618
            }
        }
 

        internal override void InDoubt( InternalEnlistment enlistment, Exception e ) 
        { 
            Monitor.Exit( enlistment.SyncRoot );
            try 
            {
                enlistment.PromotedEnlistment.InDoubt( e );
            }
            finally 
            {
#pragma warning disable 0618 
                //@ 
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618 
            }
        }

 
        internal override byte[] RecoveryInformation( InternalEnlistment enlistment )
        { 
            Monitor.Exit( enlistment.SyncRoot ); 
            try
            { 
                return enlistment.PromotedEnlistment.GetRecoveryInformation();
            }
            finally
            { 
#pragma warning disable 0618
                //@ 
                Monitor.Enter(enlistment.SyncRoot); 
#pragma warning restore 0618
            } 
        }
    }
}
 

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

namespace System.Transactions 
{ 
    using System;
    using System.Diagnostics; 
    using System.Globalization;
    using System.Threading;
    using System.Transactions.Diagnostics;
 

    // Base class for all enlistment states 
    abstract class EnlistmentState 
    {
        internal abstract void EnterState( InternalEnlistment enlistment ); 


        internal static EnlistmentStatePromoted _enlistmentStatePromoted;
 
        // Object for synchronizing access to the entire class( avoiding lock( typeof( ... )) )
        private static object classSyncObject; 
 

        // Helper object for static synchronization 
        private static object ClassSyncObject
        {
            get
            { 
                if( classSyncObject == null )
                { 
                    object o = new object(); 
                    Interlocked.CompareExchange( ref classSyncObject, o, null );
                } 
                return classSyncObject;
            }
        }
 

        internal  static EnlistmentStatePromoted _EnlistmentStatePromoted 
        { 
            get
            { 
                if (_enlistmentStatePromoted == null)
                {
                    lock (ClassSyncObject)
                    { 
                        if (_enlistmentStatePromoted == null)
                        { 
                            EnlistmentStatePromoted temp = new EnlistmentStatePromoted(); 
                            Thread.MemoryBarrier();
                            _enlistmentStatePromoted = temp; 
                        }
                    }
                }
 
                return _enlistmentStatePromoted;
            } 
        } 

 

        internal virtual void EnlistmentDone( InternalEnlistment enlistment )
        {
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 
 
        internal virtual void Prepared( InternalEnlistment enlistment )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }

 
        internal virtual void ForceRollback( InternalEnlistment enlistment, Exception e )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 

        internal virtual void Committed( InternalEnlistment enlistment )
        {
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 
 
        internal virtual void Aborted( InternalEnlistment enlistment, Exception e )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }

 
        internal virtual void InDoubt( InternalEnlistment enlistment, Exception e )
        { 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 

        internal virtual byte[] RecoveryInformation( InternalEnlistment enlistment )
        {
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 
 
        internal virtual void InternalAborted( InternalEnlistment enlistment )
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }
 

        internal virtual void InternalCommitted( InternalEnlistment enlistment ) 
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }


        internal virtual void InternalIndoubt( InternalEnlistment enlistment ) 
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        }
 

        internal virtual void ChangeStateCommitting( InternalEnlistment enlistment )
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        } 
 

        internal virtual void ChangeStatePromoted( InternalEnlistment enlistment, IPromotedEnlistment promotedEnlistment ) 
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        } 

 
        internal virtual void ChangeStateDelegated( InternalEnlistment enlistment ) 
        {
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        }

 
        internal virtual void ChangeStatePreparing( InternalEnlistment enlistment )
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() )); 
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null );
        } 


        internal virtual void ChangeStateSinglePhaseCommit( InternalEnlistment enlistment )
        { 
            Debug.Assert( false, string.Format( null, "Invalid Event for InternalEnlistment State; Current State: {0}", this.GetType() ));
            throw TransactionException.CreateEnlistmentStateException( SR.GetString( SR.TraceSourceLtm ), null ); 
        } 
    }
 


    internal class EnlistmentStatePromoted : EnlistmentState
    { 
        internal override void EnterState( InternalEnlistment enlistment )
        { 
            enlistment.State = this; 
        }
 

        internal override void EnlistmentDone( InternalEnlistment enlistment )
        {
            Monitor.Exit( enlistment.SyncRoot ); 
            try
            { 
                enlistment.PromotedEnlistment.EnlistmentDone(); 
            }
            finally 
            {
#pragma warning disable 0618
                //@
                Monitor.Enter(enlistment.SyncRoot); 
#pragma warning restore 0618
            } 
        } 

 
        internal override void Prepared( InternalEnlistment enlistment )
        {
            Monitor.Exit( enlistment.SyncRoot );
            try 
            {
                enlistment.PromotedEnlistment.Prepared(); 
            } 
            finally
            { 
#pragma warning disable 0618
                //@
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618 
            }
        } 
 

        internal override void ForceRollback( InternalEnlistment enlistment, Exception e ) 
        {
            Monitor.Exit( enlistment.SyncRoot );
            try
            { 
                enlistment.PromotedEnlistment.ForceRollback( e );
            } 
            finally 
            {
#pragma warning disable 0618 
                //@
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618
            } 
        }
 
 
        internal override void Committed( InternalEnlistment enlistment )
        { 
            Monitor.Exit( enlistment.SyncRoot );
            try
            {
                enlistment.PromotedEnlistment.Committed(); 
            }
            finally 
            { 
#pragma warning disable 0618
                //@ 
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618
            }
        } 

 
        internal override void Aborted( InternalEnlistment enlistment, Exception e ) 
        {
            Monitor.Exit( enlistment.SyncRoot ); 
            try
            {
                enlistment.PromotedEnlistment.Aborted( e );
            } 
            finally
            { 
#pragma warning disable 0618 
                //@
                Monitor.Enter(enlistment.SyncRoot); 
#pragma warning restore 0618
            }
        }
 

        internal override void InDoubt( InternalEnlistment enlistment, Exception e ) 
        { 
            Monitor.Exit( enlistment.SyncRoot );
            try 
            {
                enlistment.PromotedEnlistment.InDoubt( e );
            }
            finally 
            {
#pragma warning disable 0618 
                //@ 
                Monitor.Enter(enlistment.SyncRoot);
#pragma warning restore 0618 
            }
        }

 
        internal override byte[] RecoveryInformation( InternalEnlistment enlistment )
        { 
            Monitor.Exit( enlistment.SyncRoot ); 
            try
            { 
                return enlistment.PromotedEnlistment.GetRecoveryInformation();
            }
            finally
            { 
#pragma warning disable 0618
                //@ 
                Monitor.Enter(enlistment.SyncRoot); 
#pragma warning restore 0618
            } 
        }
    }
}
 

// 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

• WSDualHttpSecurityMode.cs
• storepermission.cs
• BlockCollection.cs
• SessionSwitchEventArgs.cs
• messageonlyhwndwrapper.cs
• ProjectionPathSegment.cs
• ApplicationException.cs
• EventLogPermissionAttribute.cs
• InkCanvasAutomationPeer.cs
• ResourceKey.cs
• EmissiveMaterial.cs
• WebPartsSection.cs
• GroupItemAutomationPeer.cs
• MsmqOutputChannel.cs
• WaitHandleCannotBeOpenedException.cs
• FixUp.cs
• ActivationArguments.cs
• SocketManager.cs
• XhtmlStyleClass.cs
• Inline.cs
• SecureEnvironment.cs
• Soap11ServerProtocol.cs
• SizeChangedEventArgs.cs
• InstanceContextMode.cs
• Viewport3DVisual.cs
• BridgeDataRecord.cs
• Vector3DKeyFrameCollection.cs
• TextTreeText.cs
• SoapIncludeAttribute.cs
• ListViewItem.cs
• DataRecordInfo.cs
• RequestCachePolicy.cs
• IntegerValidator.cs
• Command.cs
• Rotation3D.cs
• SmiRequestExecutor.cs
• CharacterBufferReference.cs
• ToolBarButtonClickEvent.cs
• ToolboxControl.cs
• RubberbandSelector.cs
• WeakReferenceKey.cs
• NamespaceDecl.cs
• RuleInfoComparer.cs
• ISAPIRuntime.cs
• APCustomTypeDescriptor.cs
• InputMethod.cs
• EnumMember.cs
• PageMediaSize.cs
• GuidelineCollection.cs
• oledbmetadatacolumnnames.cs
• ProxySimple.cs
• MultiAsyncResult.cs
• KeyGestureValueSerializer.cs
• MediaElementAutomationPeer.cs
• HiddenField.cs
• Quaternion.cs
• PageCatalogPart.cs
• EventMap.cs
• Serializer.cs
• MetadataCache.cs
• XamlTemplateSerializer.cs
• GridItemPattern.cs
• MembershipUser.cs
• QueuedDeliveryRequirementsMode.cs
• XamlTypeMapper.cs
• BinaryObjectWriter.cs
• ExpandCollapseIsCheckedConverter.cs
• VBIdentifierTrimConverter.cs
• OuterGlowBitmapEffect.cs
• OutputCacheModule.cs
• PageContentAsyncResult.cs
• FillErrorEventArgs.cs
• OletxTransactionFormatter.cs
• AccessorTable.cs
• StatusBarAutomationPeer.cs
• StringDictionaryEditor.cs
• XmlValidatingReader.cs
• PanelDesigner.cs
• TreeWalkHelper.cs
• FrameworkElementFactoryMarkupObject.cs
• MbpInfo.cs
• OdbcConnection.cs
• ConfigurationSectionCollection.cs
• SqlUdtInfo.cs
• OracleSqlParser.cs
• FileDialogPermission.cs
• NameValueConfigurationCollection.cs
• OdbcCommandBuilder.cs
• GraphicsContainer.cs
• StrongNameIdentityPermission.cs
• PLINQETWProvider.cs
• CryptoProvider.cs
• ReachFixedPageSerializerAsync.cs
• ObfuscationAttribute.cs
• TableCellCollection.cs
• WebException.cs
• Calendar.cs
• AuthenticationModuleElement.cs
• BufferedGraphicsManager.cs
• MaskedTextProvider.cs