Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.Activities / System / Activities / RuntimeTransactionHandle.cs / 1305376 / RuntimeTransactionHandle.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.Activities { using System; using System.Activities.Runtime; using System.Diagnostics.CodeAnalysis; using System.Runtime; using System.Runtime.Serialization; using System.Transactions; [Fx.Tag.XamlVisible(false)] [DataContract] public sealed class RuntimeTransactionHandle : Handle, IExecutionProperty, IPropertyRegistrationCallback { [DataMember] ActivityExecutor executor; [DataMember(EmitDefaultValue = false)] bool isHandleInitialized; [DataMember(EmitDefaultValue = false)] bool doNotAbort; [DataMember(EmitDefaultValue = false)] bool isPropertyRegistered; [DataMember(EmitDefaultValue = false)] bool isSuppressed; TransactionScope scope; Transaction rootTransaction; public RuntimeTransactionHandle() { } // This ctor is used when we want to make a transaction ambient // without enlisting. This is desirable for scenarios like WorkflowInvoker public RuntimeTransactionHandle(Transaction rootTransaction) { if (rootTransaction == null) { throw FxTrace.Exception.ArgumentNull("rootTransaction"); } this.rootTransaction = rootTransaction; this.AbortInstanceOnTransactionFailure = false; } public bool AbortInstanceOnTransactionFailure { get { return !this.doNotAbort; } set { ThrowIfRegistered(SR.CannotChangeAbortInstanceFlagAfterPropertyRegistration); this.doNotAbort = !value; } } public bool SuppressTransaction { get { return this.isSuppressed; } set { ThrowIfRegistered(SR.CannotSuppressAlreadyRegisteredHandle); this.isSuppressed = value; } } internal bool IsRuntimeOwnedTransaction { get { return this.rootTransaction != null; } } void ThrowIfRegistered(string message) { if (this.isPropertyRegistered) { throw FxTrace.Exception.AsError(new InvalidOperationException(message)); } } void ThrowIfNotRegistered(string message) { if (!this.isPropertyRegistered) { throw FxTrace.Exception.AsError(new InvalidOperationException(message)); } } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.ConsiderPassingBaseTypesAsParameters, Justification = "This method is designed to be called from activities with handle access.")] public Transaction GetCurrentTransaction(NativeActivityContext context) { return GetCurrentTransactionCore(context); } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.ConsiderPassingBaseTypesAsParameters, Justification = "This method is designed to be called from activities with handle access.")] public Transaction GetCurrentTransaction(CodeActivityContext context) { return GetCurrentTransactionCore(context); } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.ConsiderPassingBaseTypesAsParameters, Justification = "This method is designed to be called from activities with handle access.")] public Transaction GetCurrentTransaction(AsyncCodeActivityContext context) { return GetCurrentTransactionCore(context); } Transaction GetCurrentTransactionCore(ActivityContext context) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } context.ThrowIfDisposed(); //If the transaction is a runtime transaction (i.e. an Invoke with ambient transaction case), then //we do not require that it be registered since the handle created for the root transaction is never registered. if (this.rootTransaction == null) { this.ThrowIfNotRegistered(SR.RuntimeTransactionHandleNotRegisteredAsExecutionProperty("GetCurrentTransaction")); } if (!this.isHandleInitialized) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.UnInitializedRuntimeTransactionHandle)); } if (this.SuppressTransaction) { return null; } return this.executor.CurrentTransaction; } protected override void OnInitialize(HandleInitializationContext context) { this.executor = context.Executor; this.isHandleInitialized = true; if (this.rootTransaction != null) { Fx.Assert(this.Owner == null, "this.rootTransaction should only be set at the root"); this.executor.SetTransaction(this, this.rootTransaction, null, null); } base.OnInitialize(context); } protected override void OnUninitialize(HandleInitializationContext context) { if (this.rootTransaction != null) { // If we have a host transaction we're responsible for exiting no persist this.executor.ExitNoPersist(); } this.isHandleInitialized = false; base.OnUninitialize(context); } public void RequestTransactionContext(NativeActivityContext context, Actioncallback, object state) { RequestOrRequireTransactionContextCore(context, callback, state, false); } public void RequireTransactionContext(NativeActivityContext context, Action callback, object state) { RequestOrRequireTransactionContextCore(context, callback, state, true); } void RequestOrRequireTransactionContextCore(NativeActivityContext context, Action callback, object state, bool isRequires) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } context.ThrowIfDisposed(); if (context.HasRuntimeTransaction) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.RuntimeTransactionAlreadyExists)); } if (context.IsInNoPersistScope) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.CannotSetRuntimeTransactionInNoPersist)); } if (!this.isHandleInitialized) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.UnInitializedRuntimeTransactionHandle)); } if (this.SuppressTransaction) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.RuntimeTransactionIsSuppressed)); } if (isRequires) { if (context.RequiresTransactionContextWaiterExists) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.OnlyOneRequireTransactionContextAllowed)); } this.ThrowIfNotRegistered(SR.RuntimeTransactionHandleNotRegisteredAsExecutionProperty("RequireTransactionContext")); } else { this.ThrowIfNotRegistered(SR.RuntimeTransactionHandleNotRegisteredAsExecutionProperty("RequestTransactionContext")); } context.RequestTransactionContext(isRequires, this, callback, state); } public void CompleteTransaction(NativeActivityContext context) { CompleteTransactionCore(context, null); } public void CompleteTransaction(NativeActivityContext context, BookmarkCallback callback) { if (callback == null) { throw FxTrace.Exception.ArgumentNull("callback"); } CompleteTransactionCore(context, callback); } void CompleteTransactionCore(NativeActivityContext context, BookmarkCallback callback) { context.ThrowIfDisposed(); if (this.rootTransaction != null) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.CannotCompleteRuntimeOwnedTransaction)); } if (!context.HasRuntimeTransaction) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.NoRuntimeTransactionExists)); } if (!this.isHandleInitialized) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.UnInitializedRuntimeTransactionHandle)); } if (this.SuppressTransaction) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.RuntimeTransactionIsSuppressed)); } context.CompleteTransaction(this, callback); } [Fx.Tag.Throws(typeof(TransactionException), "The transaction for this property is in a state incompatible with TransactionScope.")] void IExecutionProperty.SetupWorkflowThread() { if (this.SuppressTransaction) { this.scope = new TransactionScope(TransactionScopeOption.Suppress); return; } if ((this.executor != null) && this.executor.HasRuntimeTransaction) { this.scope = Fx.CreateTransactionScope(this.executor.CurrentTransaction); } } void IExecutionProperty.CleanupWorkflowThread() { Fx.CompleteTransactionScope(ref this.scope); } void IPropertyRegistrationCallback.Register(RegistrationContext context) { if (!this.isHandleInitialized) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.UnInitializedRuntimeTransactionHandle)); } RuntimeTransactionHandle handle = (RuntimeTransactionHandle)context.FindProperty(typeof(RuntimeTransactionHandle).FullName); if (handle != null) { if (handle.SuppressTransaction) { this.isSuppressed = true; } } this.isPropertyRegistered = true; } void IPropertyRegistrationCallback.Unregister(RegistrationContext context) { this.isPropertyRegistered = false; } } } // 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
- DataGridViewRowDividerDoubleClickEventArgs.cs
- SchemaMapping.cs
- SessionStateSection.cs
- CompoundFileStorageReference.cs
- IntranetCredentialPolicy.cs
- DataGridPagerStyle.cs
- PanelDesigner.cs
- GcHandle.cs
- BooleanExpr.cs
- DesignBindingEditor.cs
- SecurityHelper.cs
- TextParagraph.cs
- UrlPath.cs
- BamlLocalizableResourceKey.cs
- Viewport3DVisual.cs
- DecoderNLS.cs
- DockPatternIdentifiers.cs
- Int32CAMarshaler.cs
- SymbolMethod.cs
- NamespaceDecl.cs
- TextEditorParagraphs.cs
- WebReferenceOptions.cs
- StringCollection.cs
- MonthChangedEventArgs.cs
- WindowsPrincipal.cs
- QuadraticEase.cs
- StorageFunctionMapping.cs
- DummyDataSource.cs
- Header.cs
- TextEndOfSegment.cs
- CreateUserWizardDesigner.cs
- XmlChoiceIdentifierAttribute.cs
- URIFormatException.cs
- BrowserCapabilitiesFactory.cs
- BorderSidesEditor.cs
- TypeCollectionDesigner.xaml.cs
- RawContentTypeMapper.cs
- XmlDictionary.cs
- ToolboxItem.cs
- TemplateManager.cs
- LinqDataSourceView.cs
- DataGridRowHeader.cs
- EventLogLink.cs
- Point3DAnimationUsingKeyFrames.cs
- PerformanceCounterPermission.cs
- SystemIPGlobalStatistics.cs
- Types.cs
- MsmqElementBase.cs
- NamedPermissionSet.cs
- SafeNativeMethods.cs
- DoubleIndependentAnimationStorage.cs
- DragEventArgs.cs
- TextEffectCollection.cs
- ConvertersCollection.cs
- XmlSerializationWriter.cs
- AudioFileOut.cs
- DbParameterCollection.cs
- hresults.cs
- AttributeTable.cs
- TabPageDesigner.cs
- StringPropertyBuilder.cs
- ParserExtension.cs
- DataGridViewColumnCollectionDialog.cs
- HttpConfigurationSystem.cs
- VirtualizingPanel.cs
- Peer.cs
- keycontainerpermission.cs
- WebServicesDescriptionAttribute.cs
- SourceElementsCollection.cs
- HtmlTextArea.cs
- SecurityContext.cs
- DefinitionUpdate.cs
- SortExpressionBuilder.cs
- Decorator.cs
- CmsInterop.cs
- DomainUpDown.cs
- DiagnosticTrace.cs
- StylusPointCollection.cs
- ExpressionBuilder.cs
- PenContexts.cs
- GroupQuery.cs
- HandlerWithFactory.cs
- BamlBinaryReader.cs
- InternalControlCollection.cs
- ToolstripProfessionalRenderer.cs
- MetaData.cs
- AppDomainFactory.cs
- GifBitmapDecoder.cs
- StatusBarPanel.cs
- RichTextBoxAutomationPeer.cs
- FunctionParameter.cs
- WebPartTracker.cs
- SchemaExporter.cs
- RealizationContext.cs
- GridViewUpdatedEventArgs.cs
- BinaryKeyIdentifierClause.cs
- OdbcErrorCollection.cs
- RegexFCD.cs
- WebPartHeaderCloseVerb.cs
- KeySpline.cs