Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- EntityWrapper.cs
- SqlCharStream.cs
- AssemblyUtil.cs
- CacheChildrenQuery.cs
- EventManager.cs
- MimeWriter.cs
- SqlRewriteScalarSubqueries.cs
- FormatConvertedBitmap.cs
- IndentedTextWriter.cs
- UIElementIsland.cs
- RtfControlWordInfo.cs
- MissingSatelliteAssemblyException.cs
- DebugController.cs
- DoubleAnimationUsingPath.cs
- DataReaderContainer.cs
- BuilderElements.cs
- ValidationErrorCollection.cs
- InternalTypeHelper.cs
- XMLSchema.cs
- HttpResponse.cs
- XmlNamespaceManager.cs
- Root.cs
- ToolStripDropDownMenu.cs
- PopupEventArgs.cs
- WindowsTitleBar.cs
- Splitter.cs
- HighlightVisual.cs
- EdmSchemaError.cs
- ProxyDataContractResolver.cs
- CustomAttribute.cs
- RecordsAffectedEventArgs.cs
- WaitHandleCannotBeOpenedException.cs
- MulticastIPAddressInformationCollection.cs
- ZipIOExtraFieldPaddingElement.cs
- CompositeKey.cs
- IResourceProvider.cs
- CodeEventReferenceExpression.cs
- DataSourceNameHandler.cs
- ToolStripGrip.cs
- JpegBitmapDecoder.cs
- HttpRequest.cs
- KeyboardEventArgs.cs
- FolderLevelBuildProvider.cs
- DataGridViewControlCollection.cs
- Command.cs
- CopyAttributesAction.cs
- FixedFlowMap.cs
- ChildrenQuery.cs
- PropertyOverridesDialog.cs
- _ProxyRegBlob.cs
- NavigationCommands.cs
- OleDbConnectionInternal.cs
- LineServicesCallbacks.cs
- GcSettings.cs
- AttachmentCollection.cs
- ChangeBlockUndoRecord.cs
- EntityPropertyMappingAttribute.cs
- UnicodeEncoding.cs
- UIElement.cs
- SafeFileMapViewHandle.cs
- filewebresponse.cs
- ObjectContext.cs
- EventLogSession.cs
- UnsafeNativeMethods.cs
- PositiveTimeSpanValidatorAttribute.cs
- GACMembershipCondition.cs
- DataTableCollection.cs
- SQLString.cs
- MessageHeaderException.cs
- DataServiceProcessingPipeline.cs
- HwndMouseInputProvider.cs
- SortedDictionary.cs
- Stopwatch.cs
- FrameworkReadOnlyPropertyMetadata.cs
- BitmapEffectRenderDataResource.cs
- WindowsGraphicsWrapper.cs
- SqlWriter.cs
- CheckBoxAutomationPeer.cs
- StandardBindingElement.cs
- String.cs
- SemanticValue.cs
- DecimalConstantAttribute.cs
- DigitShape.cs
- TableChangeProcessor.cs
- RouteParameter.cs
- DataKeyArray.cs
- EventSchemaTraceListener.cs
- CompilationAssemblyInstallComponent.cs
- SqlInfoMessageEvent.cs
- WebServiceMethodData.cs
- DataServiceQueryOfT.cs
- LinqMaximalSubtreeNominator.cs
- WinFormsComponentEditor.cs
- SByteConverter.cs
- DesigntimeLicenseContextSerializer.cs
- BoundPropertyEntry.cs
- InvokeAction.cs
- SimpleWebHandlerParser.cs
- WebZoneDesigner.cs
- AppDomainProtocolHandler.cs