Transaction.cs source code in C# .NET

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

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

#define USE_ISINTRANSACTION 
 
namespace System.Transactions
{ 
    using System;
    using System.Collections;
    using System.Configuration;
    using System.Diagnostics; 
    using SysES = System.EnterpriseServices;
    using System.Runtime; 
    using System.Runtime.InteropServices; 
    using System.Runtime.Serialization;
    using System.Runtime.Remoting.Messaging; 
    using System.Security.Permissions;
    using System.Threading;
    using System.Transactions.Diagnostics;
 
    using System.Transactions.Configuration;
 
 
    internal enum EnterpriseServicesState
    { 
        Unknown = 0,
        Available = -1,
        Unavailable = 1
    } 

 
    public class TransactionEventArgs : EventArgs 
    {
        internal Transaction transaction; 
        public Transaction Transaction
        {
            get
            { 
                return this.transaction;
            } 
        } 
    }
 
    public delegate void TransactionCompletedEventHandler(object sender, TransactionEventArgs e);


    public enum IsolationLevel 
    {
        Serializable = 0, 
        RepeatableRead = 1, 
        ReadCommitted = 2,
        ReadUncommitted = 3, 
        Snapshot = 4,
        Chaos = 5,
        Unspecified = 6,
    } 

 
    public enum TransactionStatus 
    {
        Active = 0, 
        Committed = 1,
        Aborted = 2,
        InDoubt = 3
    } 

 
    public enum DependentCloneOption 
    {
        BlockCommitUntilComplete = 0, 
        RollbackIfNotComplete = 1,
    }

 
    [Flags]
    public enum EnlistmentOptions 
    { 
        None = 0x0,
        EnlistDuringPrepareRequired = 0x1, 
    }


    // When we serialize a Transaction, we specify the type OletxTransaction, so a Transaction never 
    // actually gets deserialized.
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Usage", "CA2229:ImplementSerializationConstructors")] 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Usage", "CA2240:ImplementISerializableCorrectly")] 
    [Serializable]
    public class Transaction : IDisposable, ISerializable 
    {
        private static EnterpriseServicesState _enterpriseServicesOk = EnterpriseServicesState.Unknown;
        internal static bool EnterpriseServicesOk
        { 
            get
            { 
                if( _enterpriseServicesOk == EnterpriseServicesState.Unknown ) 
                {
                    if( null != Type.GetType( "System.EnterpriseServices.ContextUtil, " + AssemblyRef.SystemEnterpriseServices, false )) 
                    {
                        _enterpriseServicesOk = EnterpriseServicesState.Available;
                    }
                    else 
                    {
                        _enterpriseServicesOk = EnterpriseServicesState.Unavailable; 
                    } 
                }
                return (_enterpriseServicesOk == EnterpriseServicesState.Available); 
            }
        }

 
        internal static void VerifyEnterpriseServicesOk()
        { 
            if( !EnterpriseServicesOk ) 
            {
                throw new NotSupportedException( SR.GetString( SR.EsNotSupported )); 
            }
        }

        private static Guid IID_IObjContext = new Guid("000001c6-0000-0000-C000-000000000046"); 

        [System.Runtime.CompilerServices.MethodImplAttribute(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] 
        // Get Transaction is a non destructive action.  The transaction that is returned is given back to the 
        // calling code but that is precicely what System.Transactions is supposed to do.  The threat model
        // for System.Transactions notes that you should be careful about the code you call when you have a 
        // transaction in Current.
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Security", "CA2116:AptcaMethodsShouldOnlyCallAptcaMethods")]
        // The handle returned here by DangerousGetHandle is not stored anywhere so this is not a reliability issue.
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Reliability", "CA2001:AvoidCallingProblematicMethods")] 
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Security", "CA2122:DoNotIndirectlyExposeMethodsWithLinkDemands")]
        private static Transaction JitSafeGetContextTransaction(ContextData contextData) 
        { 
            // Attempt to see if we are in the default context in which case we don't need to
            // call SystemTransaction at all. 
            SafeIUnknown defaultContext = null;

            if( contextData.WeakDefaultComContext != null )
            { 
                defaultContext = (SafeIUnknown)contextData.WeakDefaultComContext.Target;
            } 
 
            if( contextData.DefaultComContextState == DefaultComContextState.Unknown ||
                (contextData.DefaultComContextState == DefaultComContextState.Available && 
                 defaultContext == null)
              )
            {
                try 
                {
                    NativeMethods.CoGetDefaultContext( -1, ref IID_IObjContext, out defaultContext ); 
                    contextData.WeakDefaultComContext = new WeakReference(defaultContext); 
                    contextData.DefaultComContextState = DefaultComContextState.Available;
                } 
                catch(System.EntryPointNotFoundException e)
                {
                    if ( DiagnosticTrace.Verbose )
                    { 
                        ExceptionConsumedTraceRecord.Trace( SR.GetString( SR.TraceSourceBase ),
                            e ); 
                    } 
                    contextData.DefaultComContextState = DefaultComContextState.Unavailable;
                } 
            }

            if( contextData.DefaultComContextState == DefaultComContextState.Available )
            { 
                IntPtr contextToken = IntPtr.Zero;
                NativeMethods.CoGetContextToken( out contextToken ); 
 
                // Check to see if the context token is the default context.
                if( defaultContext.DangerousGetHandle() == contextToken ) 
                {
                    return null;
                }
            } 

 
#if USE_ISINTRANSACTION 
            if( !SysES.ContextUtil.IsInTransaction )
            { 
                return null;
            }
#endif
 
            return (Transaction)SysES.ContextUtil.SystemTransaction;
        } 
 

        // GetContextTransaction 
        //
        // Get a transaction from Com+ through EnterpriseServices
        internal static Transaction GetContextTransaction(ContextData contextData)
        { 
            if( EnterpriseServicesOk )
            { 
                return JitSafeGetContextTransaction(contextData); 
            }
            return null; 
        }


        // UseServiceDomain 
        //
        // Property tells parts of system.transactions if it should use a 
        // service domain for current. 
        [System.Runtime.CompilerServices.MethodImplAttribute(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)]
        // IsDefaultContext is a non destructive call and the information it provides is not exposed directly 
        // to code that is calling Transaction.Current.
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Security", "CA2116:AptcaMethodsShouldOnlyCallAptcaMethods")]
        internal static bool UseServiceDomainForCurrent()
        { 
            return !SysES.ContextUtil.IsDefaultContext();
        } 
 

        // InteropMode 
        //
        // This property figures out the current interop mode based on the
        // top of the transaction scope stack as well as the default mode
        // from config. 
        internal static EnterpriseServicesInteropOption InteropMode(TransactionScope currentScope)
        { 
            if( currentScope != null ) 
            {
                return currentScope.InteropMode; 
            }

            return EnterpriseServicesInteropOption.None;
        } 

 
        internal static Transaction FastGetTransaction( TransactionScope currentScope, ContextData contextData, out Transaction contextTransaction ) 
        {
            Transaction current = null; 
            contextTransaction = null;

            contextTransaction = contextData.CurrentTransaction;
 
            switch( InteropMode(currentScope) )
            { 
                case EnterpriseServicesInteropOption.None: 

                    current = contextTransaction; 

                    // If there is a transaction in the execution context or if there is a current transaction scope
                    // then honer the transaction context.
                    if( current == null && currentScope == null ) 
                    {
                        // Otherwise check for an external current. 
                        if( TransactionManager.currentDelegateSet ) 
                        {
                            current = TransactionManager.currentDelegate(); 
                        }
                        else
                        {
                            current = GetContextTransaction(contextData); 
                        }
                    } 
                    break; 

                case EnterpriseServicesInteropOption.Full: 
                    current = GetContextTransaction( contextData );
                    break;

                case EnterpriseServicesInteropOption.Automatic: 

                    if( UseServiceDomainForCurrent() ) 
                    { 
                        current = GetContextTransaction( contextData );
                    } 
                    else
                    {
                        current = contextData.CurrentTransaction;
                    } 

                    break; 
            } 

            return current; 
        }


        // GetCurrentTransactionAndScope 
        //
        // Returns both the current transaction and scope.  This is implemented for optimizations 
        // in TransactionScope because it is required to get both of them in several cases. 
        internal static void GetCurrentTransactionAndScope(
            out Transaction current, 
            out TransactionScope currentScope,
            out ContextData contextData,
            out Transaction contextTransaction
            ) 
        {
            contextData = ContextData.CurrentData; 
            currentScope = contextData.CurrentScope; 
            current = FastGetTransaction( currentScope, contextData, out contextTransaction );
        } 


        public static Transaction Current
        { 
            get
            { 
                if ( DiagnosticTrace.Verbose ) 
                {
                    MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceBase ), 
                        "Transaction.get_Current"
                        );
                }
 
                Transaction current = null;
                TransactionScope currentScope = null; 
                ContextData contextData = null; 
                Transaction contextValue = null;
                GetCurrentTransactionAndScope( out current, out currentScope, out contextData, out contextValue ); 

                if( currentScope != null )
                {
                    if( currentScope.ScopeComplete ) 
                    {
                        throw new InvalidOperationException( SR.GetString( SR.TransactionScopeComplete )); 
                    } 
                }
 
                if ( DiagnosticTrace.Verbose )
                {
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceBase ),
                        "Transaction.get_Current" 
                        );
                } 
 
                return current;
            } 

            set
            {
                if( !TransactionManager._platformValidated ) TransactionManager.ValidatePlatform(); 

                if ( DiagnosticTrace.Verbose ) 
                { 
                    MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceBase ),
                        "Transaction.set_Current" 
                        );
                }

                if( InteropMode( ContextData.CurrentData.CurrentScope ) != EnterpriseServicesInteropOption.None ) 
                {
                    if ( DiagnosticTrace.Error ) 
                    { 
                        InvalidOperationExceptionTraceRecord.Trace( SR.GetString( SR.TraceSourceBase ),
                            SR.GetString( SR.CannotSetCurrent ) 
                            );
                    }

                    throw new InvalidOperationException( SR.GetString( SR.CannotSetCurrent )); 
                }
 
                ContextData.CurrentData.CurrentTransaction = value; 

                if ( DiagnosticTrace.Verbose ) 
                {
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceBase ),
                        "Transaction.set_Current"
                        ); 
                }
            } 
        } 

 
        // Storage for the transaction isolation level
        internal IsolationLevel isoLevel;

        // Storage for the consistent flag 
        internal bool complete = false;
 
        // Record an identifier for this clone 
        internal int cloneId;
 
        // Storage for a disposed flag
        internal const int disposedTrueValue = 1;
        internal int disposed = 0;
        internal bool Disposed { get { return this.disposed == Transaction.disposedTrueValue; } } 

 
        // Internal synchronization object for transactions.  It is not safe to lock on the 
        // transaction object because it is public and users of the object may lock it for
        // other purposes. 
        internal InternalTransaction internalTransaction;

        // The TransactionTraceIdentifier for the transaction instance.
        internal TransactionTraceIdentifier traceIdentifier; 

        // Not used by anyone 
        private Transaction() {} 

        // Create a transaction with the given settings 
        //
        internal Transaction(
            IsolationLevel isoLevel,
            InternalTransaction internalTransaction 
            )
        { 
            TransactionManager.ValidateIsolationLevel(isoLevel); 

            this.isoLevel = isoLevel; 

            // Never create a transaction with an IsolationLevel of Unspecified.
            if ( IsolationLevel.Unspecified == this.isoLevel )
            { 
                this.isoLevel = System.Transactions.TransactionManager.DefaultIsolationLevel;
            } 
 
            if( internalTransaction != null )
            { 
                this.internalTransaction = internalTransaction;
                this.cloneId = Interlocked.Increment( ref this.internalTransaction.cloneCount );
            }
            else 
            {
                // Null is passed from the constructor of a CommittableTransaction.  That 
                // constructor will fill in the traceIdentifier because it has allocated the 
                // internal transaction.
            } 
        }


        internal Transaction( 
            Oletx.OletxTransaction oleTransaction
            ) 
        { 
            this.isoLevel = oleTransaction.IsolationLevel;
            this.internalTransaction = new InternalTransaction( this, oleTransaction ); 
            this.cloneId = Interlocked.Increment( ref this.internalTransaction.cloneCount );
        }

 
        internal Transaction(
            IsolationLevel isoLevel, 
            ISimpleTransactionSuperior superior 
            )
        { 
            TransactionManager.ValidateIsolationLevel(isoLevel);

            if( superior == null )
            { 
                throw new ArgumentNullException("superior");
            } 
 
            this.isoLevel = isoLevel;
 
            // Never create a transaction with an IsolationLevel of Unspecified.
            if ( IsolationLevel.Unspecified == this.isoLevel )
            {
                this.isoLevel = System.Transactions.TransactionManager.DefaultIsolationLevel; 
            }
 
            this.internalTransaction = new InternalTransaction( this, superior ); 
            this.cloneId = 1;
        } 

        #region System.Object Overrides

        // Don't use the identifier for the hash code. 
        //
        ///  
        public override int GetHashCode() 
        {
            return this.internalTransaction.TransactionHash; 
        }


        // Don't allow equals to get the identifier 
        //
        ///  
        public override bool Equals(object obj) 
        {
            Transaction transaction = obj as Transaction; 

            // If we can't cast the object as a Transaction, it must not be equal
            // to this, which is a Transaction.
            if ( null == transaction ) 
            {
                return false; 
            } 

            // Check the internal transaction object for equality. 
            return this.internalTransaction.TransactionHash == transaction.internalTransaction.TransactionHash;
        }

        // This would be a breaking change for little benefit. 
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1704:IdentifiersShouldBeSpelledCorrectly")]
        public static bool operator ==(Transaction x, Transaction y) 
        { 
            if( ((object)x) != null )
            { 
                return x.Equals(y);
            }
            return ((object)y) == null;
        } 

        // This would be a breaking change for little benefit. 
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1704:IdentifiersShouldBeSpelledCorrectly")] 
        public static bool operator !=(Transaction x, Transaction y)
        { 
            if( ((object)x) != null )
            {
                return !x.Equals(y);
            } 
            return ((object)y) != null;
        } 
 

        #endregion 

        public TransactionInformation TransactionInformation
        {
            get 
            {
                if ( DiagnosticTrace.Verbose ) 
                { 
                    MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                        "Transaction.get_TransactionInformation" 
                        );
                }

                if( Disposed ) 
                {
                    throw new ObjectDisposedException( "Transaction" ); 
                } 

                TransactionInformation txInfo = this.internalTransaction.transactionInformation; 
                if( txInfo == null )
                {
                    // A ---- would only result in an extra allocation
                    txInfo = new TransactionInformation( this.internalTransaction ); 
                    this.internalTransaction.transactionInformation = txInfo;
                } 
 
                if ( DiagnosticTrace.Verbose )
                { 
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                        "Transaction.get_TransactionInformation"
                        );
                } 

                return txInfo; 
            } 
        }
 

        // Return the Isolation Level for the given transaction
        //
        ///  
        public IsolationLevel IsolationLevel
        { 
            get 
            {
                if ( DiagnosticTrace.Verbose ) 
                {
                    MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                        "Transaction.get_IsolationLevel"
                        ); 
                }
                if( Disposed ) 
                { 
                    throw new ObjectDisposedException( "Transaction" );
                } 

                if ( DiagnosticTrace.Verbose )
                {
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                        "Transaction.get_IsolationLevel"
                        ); 
                } 
                return this.isoLevel;
            } 
        }


        [System.Security.Permissions.PermissionSetAttribute(System.Security.Permissions.SecurityAction.LinkDemand, Name="FullTrust")] 
        public Enlistment EnlistDurable(
            Guid resourceManagerIdentifier, 
            IEnlistmentNotification enlistmentNotification, 
            EnlistmentOptions enlistmentOptions
            ) 
        {
            if ( DiagnosticTrace.Verbose )
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.EnlistDurable( IEnlistmentNotification )"
                    ); 
            } 

            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" );
            }
 
            if( resourceManagerIdentifier == Guid.Empty )
            { 
                throw new ArgumentException( SR.GetString( SR.BadResourceManagerId ), "resourceManagerIdentifier" ); 
            }
 
            if( enlistmentNotification == null )
            {
                throw new ArgumentNullException( "enlistmentNotification" );
            } 

            if( enlistmentOptions != EnlistmentOptions.None && enlistmentOptions != EnlistmentOptions.EnlistDuringPrepareRequired ) 
            { 
                throw new ArgumentOutOfRangeException( "enlistmentOptions" );
            } 

            if( this.complete )
            {
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) ); 
            }
 
            lock( this.internalTransaction ) 
            {
                Enlistment enlistment = this.internalTransaction.State.EnlistDurable( this.internalTransaction, 
                    resourceManagerIdentifier, enlistmentNotification, enlistmentOptions, this );

                if ( DiagnosticTrace.Verbose )
                { 
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                        "Transaction.EnlistDurable( IEnlistmentNotification )" 
                        ); 
                }
                return enlistment; 
            }
        }

 
        // Forward request to the state machine to take the appropriate action.
        // 
        ///  
        [System.Security.Permissions.PermissionSetAttribute(System.Security.Permissions.SecurityAction.LinkDemand, Name="FullTrust")]
        public Enlistment EnlistDurable( 
            Guid resourceManagerIdentifier,
            ISinglePhaseNotification singlePhaseNotification,
            EnlistmentOptions enlistmentOptions
            ) 
        {
            if ( DiagnosticTrace.Verbose ) 
            { 
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.EnlistDurable( ISinglePhaseNotification )" 
                    );
            }

            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" ); 
            } 

            if( resourceManagerIdentifier == Guid.Empty ) 
            {
                throw new ArgumentException( SR.GetString( SR.BadResourceManagerId ), "resourceManagerIdentifier" );
            }
 
            if( singlePhaseNotification == null )
            { 
                throw new ArgumentNullException( "singlePhaseNotification" ); 
            }
 
            if( enlistmentOptions != EnlistmentOptions.None && enlistmentOptions != EnlistmentOptions.EnlistDuringPrepareRequired )
            {
                throw new ArgumentOutOfRangeException( "enlistmentOptions" );
            } 

            if( this.complete ) 
            { 
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) );
            } 

            lock( this.internalTransaction )
            {
                Enlistment enlistment = this.internalTransaction.State.EnlistDurable( this.internalTransaction, 
                    resourceManagerIdentifier, singlePhaseNotification, enlistmentOptions, this );
 
                if ( DiagnosticTrace.Verbose ) 
                {
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                        "Transaction.EnlistDurable( ISinglePhaseNotification )"
                        );
                }
                return enlistment; 
            }
        } 
 

        public void Rollback() 
        {
            if ( DiagnosticTrace.Verbose )
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.Rollback"
                    ); 
            } 

            if ( DiagnosticTrace.Warning ) 
            {
                TransactionRollbackCalledTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    this.TransactionTraceId
                    ); 
            }
 
            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" ); 
            }

            lock( this.internalTransaction )
            { 
                Debug.Assert( this.internalTransaction.State != null );
                this.internalTransaction.State.Rollback( this.internalTransaction, null ); 
            } 

            if ( DiagnosticTrace.Verbose ) 
            {
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.Rollback"
                    ); 
            }
        } 
 

        // Changing the e paramater name would be a breaking change for little benefit. 
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1704:IdentifiersShouldBeSpelledCorrectly")]
        public void Rollback( Exception e )
        {
            if ( DiagnosticTrace.Verbose ) 
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.Rollback" 
                    );
            } 

            if ( DiagnosticTrace.Warning )
            {
                TransactionRollbackCalledTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    this.TransactionTraceId
                    ); 
            } 

            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" );
            }
 
            lock( this.internalTransaction )
            { 
                Debug.Assert( this.internalTransaction.State != null ); 
                this.internalTransaction.State.Rollback( this.internalTransaction, e );
            } 

            if ( DiagnosticTrace.Verbose )
            {
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.Rollback"
                    ); 
            } 
        }
 

        // Forward request to the state machine to take the appropriate action.
        //
        ///  
        public Enlistment EnlistVolatile(
            IEnlistmentNotification enlistmentNotification, 
            EnlistmentOptions enlistmentOptions 
            )
        { 
            if ( DiagnosticTrace.Verbose )
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.EnlistVolatile( IEnlistmentNotification )" 
                    );
            } 
 
            if( Disposed )
            { 
                throw new ObjectDisposedException( "Transaction" );
            }

            if( enlistmentNotification == null ) 
            {
                throw new ArgumentNullException( "enlistmentNotification" ); 
            } 

            if( enlistmentOptions != EnlistmentOptions.None && enlistmentOptions != EnlistmentOptions.EnlistDuringPrepareRequired ) 
            {
                throw new ArgumentOutOfRangeException( "enlistmentOptions" );
            }
 
            if( this.complete )
            { 
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) ); 
            }
 
            lock( this.internalTransaction )
            {
                Enlistment enlistment = this.internalTransaction.State.EnlistVolatile( this.internalTransaction,
                    enlistmentNotification, enlistmentOptions, this ); 

                if ( DiagnosticTrace.Verbose ) 
                { 
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                        "Transaction.EnlistVolatile( IEnlistmentNotification )" 
                        );
                }
                return enlistment;
            } 
        }
 
 
        // Forward request to the state machine to take the appropriate action.
        // 
        /// 
        public Enlistment EnlistVolatile(
            ISinglePhaseNotification singlePhaseNotification,
            EnlistmentOptions enlistmentOptions 
            )
        { 
            if ( DiagnosticTrace.Verbose ) 
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.EnlistVolatile( ISinglePhaseNotification )"
                    );
            }
 
            if( Disposed )
            { 
                throw new ObjectDisposedException( "Transaction" ); 
            }
 
            if( singlePhaseNotification == null )
            {
                throw new ArgumentNullException( "singlePhaseNotification" );
            } 

            if( enlistmentOptions != EnlistmentOptions.None && enlistmentOptions != EnlistmentOptions.EnlistDuringPrepareRequired ) 
            { 
                throw new ArgumentOutOfRangeException( "enlistmentOptions" );
            } 

            if( this.complete )
            {
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) ); 
            }
 
            lock( this.internalTransaction ) 
            {
                Enlistment enlistment = this.internalTransaction.State.EnlistVolatile( this.internalTransaction, 
                    singlePhaseNotification, enlistmentOptions, this );

                if ( DiagnosticTrace.Verbose )
                { 
                    MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                        "Transaction.EnlistVolatile( ISinglePhaseNotification )" 
                        ); 
                }
                return enlistment; 
            }
        }

 

        // Create a clone of the transaction that forwards requests to this object. 
        // 
        /// 
        public Transaction Clone() 
        {
            if ( DiagnosticTrace.Verbose )
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.Clone"
                    ); 
            } 

            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" );
            }
 
            if( this.complete )
            { 
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) ); 
            }
 
            Transaction clone = InternalClone();

            if ( DiagnosticTrace.Verbose )
            { 
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.Clone" 
                    ); 
            }
            return clone; 
        }


        internal Transaction InternalClone() 
        {
            Transaction clone = new Transaction( this.isoLevel, 
                this.internalTransaction ); 

            if ( DiagnosticTrace.Verbose ) 
            {
                CloneCreatedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    clone.TransactionTraceId
                    ); 
            }
 
            return clone; 
        }
 

        // Create a dependent clone of the transaction that forwards requests to this object.
        //
        ///  
        public DependentTransaction DependentClone(
            DependentCloneOption cloneOption 
            ) 
        {
            if ( DiagnosticTrace.Verbose ) 
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.DependentClone"
                    ); 
            }
 
            if( cloneOption != DependentCloneOption.BlockCommitUntilComplete 
                && cloneOption != DependentCloneOption.RollbackIfNotComplete )
            { 
                throw new ArgumentOutOfRangeException( "cloneOption" );
            }

            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" ); 
            } 

            if( this.complete ) 
            {
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) );
            }
 
            DependentTransaction clone = new DependentTransaction(
                this.isoLevel, this.internalTransaction, cloneOption == DependentCloneOption.BlockCommitUntilComplete ); 
 
            if ( DiagnosticTrace.Information )
            { 
                DependentCloneCreatedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    clone.TransactionTraceId,
                    cloneOption
                    ); 
            }
            if ( DiagnosticTrace.Verbose ) 
            { 
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.DependentClone" 
                    );
            }
            return clone;
        } 

 
        internal TransactionTraceIdentifier TransactionTraceId 
        {
            get 
            {
                if( this.traceIdentifier == TransactionTraceIdentifier.Empty )
                {
                    lock( this.internalTransaction ) 
                    {
                        if( this.traceIdentifier == TransactionTraceIdentifier.Empty ) 
                        { 
                            TransactionTraceIdentifier temp = new TransactionTraceIdentifier(
                                this.internalTransaction.TransactionTraceId.TransactionIdentifier, 
                                this.cloneId );
                            Thread.MemoryBarrier();
                            this.traceIdentifier = temp;
                        } 
                    }
                } 
                return this.traceIdentifier; 
            }
        } 


        // Forward request to the state machine to take the appropriate action.
        // 
        /// 
        public event TransactionCompletedEventHandler TransactionCompleted 
        { 
            add
            { 
                if( Disposed )
                {
                    throw new ObjectDisposedException( "Transaction" );
                } 

                lock( this.internalTransaction ) 
                { 
                    // Register for completion with the inner transaction
                    this.internalTransaction.State.AddOutcomeRegistrant( this.internalTransaction, value ); 
                }
            }

            remove 
            {
                lock( this.internalTransaction ) 
                { 
                    this.internalTransaction.transactionCompletedDelegate = (TransactionCompletedEventHandler)
                        System.Delegate.Remove( this.internalTransaction.transactionCompletedDelegate, value ); 
                }
            }
        }
 

        public void Dispose() 
        { 
            InternalDispose();
        } 


        // Handle Transaction Disposal.
        // 
        /// 
        internal virtual void InternalDispose() 
        { 
            if ( DiagnosticTrace.Verbose )
            { 
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "IDisposable.Dispose"
                    );
            } 

            if( Interlocked.Exchange( ref this.disposed, Transaction.disposedTrueValue ) == Transaction.disposedTrueValue ) 
            { 
                return;
            } 

            // Attempt to clean up the internal transaction
            long remainingITx = Interlocked.Decrement( ref this.internalTransaction.cloneCount );
            if( remainingITx == 0 ) 
            {
                this.internalTransaction.Dispose(); 
            } 

            if ( DiagnosticTrace.Verbose ) 
            {
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "IDisposable.Dispose"
                    ); 
            }
        } 
 

        // Ask the state machine for serialization info. 
        //
        /// 
        [SecurityPermissionAttribute(SecurityAction.Demand, SerializationFormatter=true)]
        void ISerializable.GetObjectData( 
            SerializationInfo serializationInfo,
            StreamingContext context 
            ) 
        {
            if ( DiagnosticTrace.Verbose ) 
            {
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "ISerializable.GetObjectData"
                    ); 
            }
 
            if( Disposed ) 
            {
                throw new ObjectDisposedException( "Transaction" ); 
            }

            if( serializationInfo == null )
            { 
                throw new ArgumentNullException( "serializationInfo" );
            } 
 
            if( this.complete )
            { 
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) );
            }

            lock( this.internalTransaction ) 
            {
                this.internalTransaction.State.GetObjectData( this.internalTransaction, serializationInfo, context ); 
            } 

            if ( DiagnosticTrace.Information ) 
            {
                TransactionSerializedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    this.TransactionTraceId
                    ); 
            }
 
            if ( DiagnosticTrace.Verbose ) 
            {
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "ISerializable.GetObjectData"
                    );
            }
        } 

 
        // We apparently didn't spell Promotable like FXCop thinks it should be spelled. 
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1704:IdentifiersShouldBeSpelledCorrectly")]
        [System.Security.Permissions.PermissionSetAttribute(System.Security.Permissions.SecurityAction.LinkDemand, Name="FullTrust")] 
        public bool EnlistPromotableSinglePhase( IPromotableSinglePhaseNotification promotableSinglePhaseNotification )
        {
            if ( DiagnosticTrace.Verbose )
            { 
                MethodEnteredTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ),
                    "Transaction.EnlistPromotableSinglePhase" 
                    ); 
            }
 
            if( Disposed )
            {
                throw new ObjectDisposedException( "Transaction" );
            } 

            if( promotableSinglePhaseNotification == null ) 
            { 
                throw new ArgumentNullException( "promotableSinglePhaseNotification" );
            } 

            if( this.complete )
            {
                throw TransactionException.CreateTransactionCompletedException( SR.GetString( SR.TraceSourceLtm ) ); 
            }
 
            bool succeeded = false; 

            lock( this.internalTransaction ) 
            {
                succeeded = this.internalTransaction.State.EnlistPromotableSinglePhase( this.internalTransaction, promotableSinglePhaseNotification, this );
            }
 
            if ( DiagnosticTrace.Verbose )
            { 
                MethodExitedTraceRecord.Trace( SR.GetString( SR.TraceSourceLtm ), 
                    "Transaction.EnlistPromotableSinglePhase"
                    ); 
            }

            return succeeded;
        } 

 
        internal Oletx.OletxTransaction Promote() 
        {
            lock( this.internalTransaction ) 
            {
                this.internalTransaction.State.Promote( this.internalTransaction );
                return this.internalTransaction.PromotedTransaction;
            } 
        }
    } 
 

    // 
    // The following code & data is related to management of Transaction.Current
    //

    enum DefaultComContextState 
    {
        Unknown = 0, 
        Unavailable = -1, 
        Available = 1
    } 


    [System.Security.SuppressUnmanagedCodeSecurity]
    static class NativeMethods 
    {
        // User code is not allowed to pass arbitrary data to either of these methods. 
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Security", "CA2118:ReviewSuppressUnmanagedCodeSecurityUsage")] 
        [System.Runtime.InteropServices.DllImport("Ole32"), System.Security.SuppressUnmanagedCodeSecurityAttribute()]
        internal static extern void CoGetContextToken(out IntPtr contextToken); 

        // User code is not allowed to pass arbitrary data to either of these methods.
        [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Security", "CA2118:ReviewSuppressUnmanagedCodeSecurityUsage")]
        [System.Runtime.InteropServices.DllImport("Ole32"), System.Security.SuppressUnmanagedCodeSecurityAttribute()] 
        internal static extern void CoGetDefaultContext(Int32 aptType, ref Guid contextInterface, out SafeIUnknown safeUnknown);
    } 
 

    class ContextData 
    {
        internal TransactionScope CurrentScope;
        internal Transaction CurrentTransaction;
 
        internal DefaultComContextState DefaultComContextState;
        internal WeakReference WeakDefaultComContext; 
 
        [ThreadStatic]
        private static ContextData staticData; 

        internal static ContextData CurrentData
        {
            get 
            {
                ContextData data = staticData; 
                if( data == null ) 
                {
                    data = new ContextData(); 
                    staticData = data;
                }
                return data;
            } 
        }
    } 
} 

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

• SqlDataReaderSmi.cs
• BrowserCapabilitiesCodeGenerator.cs
• SelectionProcessor.cs
• PropertyGeneratedEventArgs.cs
• AvtEvent.cs
• EdmPropertyAttribute.cs
• DockPattern.cs
• XamlSerializerUtil.cs
• XmlSerializerFaultFormatter.cs
• ConfigXmlReader.cs
• ClonableStack.cs
• TextParagraphView.cs
• controlskin.cs
• PageStatePersister.cs
• GZipDecoder.cs
• WebScriptMetadataMessage.cs
• BufferBuilder.cs
• SoapClientProtocol.cs
• SpecialFolderEnumConverter.cs
• DesignerContextDescriptor.cs
• CodeTypeReferenceCollection.cs
• EventDescriptorCollection.cs
• TextRangeEdit.cs
• EventLogConfiguration.cs
• RepeaterItemEventArgs.cs
• Msec.cs
• MemoryMappedFile.cs
• indexingfiltermarshaler.cs
• ContainsSearchOperator.cs
• SolidColorBrush.cs
• TraceUtility.cs
• AsyncStreamReader.cs
• SqlDeflator.cs
• WebServiceParameterData.cs
• EmbossBitmapEffect.cs
• BindingManagerDataErrorEventArgs.cs
• MsmqNonTransactedPoisonHandler.cs
• WorkerRequest.cs
• HandlerBase.cs
• OrderedEnumerableRowCollection.cs
• objectresult_tresulttype.cs
• TextWriter.cs
• FileDialog_Vista_Interop.cs
• InstalledFontCollection.cs
• ContextMarshalException.cs
• StrokeSerializer.cs
• LocalizationParserHooks.cs
• TrailingSpaceComparer.cs
• AsynchronousChannel.cs
• DecryptRequest.cs
• exports.cs
• Comparer.cs
• LayoutEditorPart.cs
• InfoCardHelper.cs
• FrugalMap.cs
• InkCanvasFeedbackAdorner.cs
• HebrewCalendar.cs
• TypefaceMap.cs
• HandleRef.cs
• PrefixQName.cs
• LayoutEvent.cs
• PartialArray.cs
• BitmapVisualManager.cs
• CompositeCollectionView.cs
• SqlCachedBuffer.cs
• Exception.cs
• TraceSection.cs
• SurrogateChar.cs
• OleDbPropertySetGuid.cs
• CompositeKey.cs
• GridViewColumnCollection.cs
• XmlExpressionDumper.cs
• DrawListViewColumnHeaderEventArgs.cs
• DbParameterHelper.cs
• DataListAutoFormat.cs
• TableRow.cs
• HelpEvent.cs
• SchemaImporterExtensionElement.cs
• ExpressionBuilderCollection.cs
• DoubleCollection.cs
• MultipartIdentifier.cs
• IntSecurity.cs
• MaskedTextProvider.cs
• FactoryRecord.cs
• DockProviderWrapper.cs
• CommandPlan.cs
• ContainerUtilities.cs
• DebugViewWriter.cs
• UnsafePeerToPeerMethods.cs
• HelpEvent.cs
• RangeValidator.cs
• MeshGeometry3D.cs
• ThaiBuddhistCalendar.cs
• MachineKeySection.cs
• MimeParameter.cs
• ExpressionBuilderContext.cs
• InputMethodStateTypeInfo.cs
• ControlBindingsCollection.cs
• MachineKeyConverter.cs
• FieldMetadata.cs