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
- DocumentPageView.cs
- Vertex.cs
- TemplateParser.cs
- ColumnBinding.cs
- SamlSubjectStatement.cs
- Certificate.cs
- Int16AnimationBase.cs
- UriSection.cs
- SynchronizedCollection.cs
- XsltSettings.cs
- OracleCommandSet.cs
- Socket.cs
- WorkflowControlEndpoint.cs
- TypeConvertions.cs
- OpenFileDialog.cs
- ObjectSet.cs
- CommonProperties.cs
- ObjectDataProvider.cs
- ObjectListTitleAttribute.cs
- GroupBoxAutomationPeer.cs
- ListViewUpdateEventArgs.cs
- ToolBarPanel.cs
- SiblingIterators.cs
- StreamWriter.cs
- HideDisabledControlAdapter.cs
- ErrorActivity.cs
- TypeSource.cs
- DictionaryEntry.cs
- SpellCheck.cs
- SQLGuidStorage.cs
- BindingSource.cs
- ApplicationInfo.cs
- InlinedLocationReference.cs
- SQLDoubleStorage.cs
- NameSpaceExtractor.cs
- ConversionValidationRule.cs
- ProtocolViolationException.cs
- ComboBox.cs
- Substitution.cs
- HandlerMappingMemo.cs
- WorkflowInstance.cs
- LabelEditEvent.cs
- ConnectionPointCookie.cs
- WebPageTraceListener.cs
- SqlDataSourceFilteringEventArgs.cs
- ToolConsole.cs
- Registry.cs
- COSERVERINFO.cs
- SystemBrushes.cs
- MaterialCollection.cs
- rsa.cs
- EntityDataSourceContextDisposingEventArgs.cs
- _NegotiateClient.cs
- CanExecuteRoutedEventArgs.cs
- HttpDigestClientCredential.cs
- Encoder.cs
- AppLevelCompilationSectionCache.cs
- Helpers.cs
- GroupLabel.cs
- EncryptRequest.cs
- DataGridViewColumnCollectionEditor.cs
- _HelperAsyncResults.cs
- PolygonHotSpot.cs
- GenericPrincipal.cs
- ArraySegment.cs
- ScriptingSectionGroup.cs
- DivideByZeroException.cs
- XmlTextReader.cs
- ProxyAttribute.cs
- ISO2022Encoding.cs
- ExtendedProperty.cs
- PolygonHotSpot.cs
- CustomCredentialPolicy.cs
- Message.cs
- OrderedDictionaryStateHelper.cs
- ValidationRule.cs
- CompilerGeneratedAttribute.cs
- KnownAssemblyEntry.cs
- HMACSHA1.cs
- IdnElement.cs
- MarkupObject.cs
- lengthconverter.cs
- DefaultHttpHandler.cs
- TogglePattern.cs
- Aggregates.cs
- SQLDoubleStorage.cs
- TextMarkerSource.cs
- KeyFrames.cs
- DoubleUtil.cs
- BulletedList.cs
- StateDesigner.CommentLayoutGlyph.cs
- WebPartManagerInternals.cs
- PeerName.cs
- PriorityChain.cs
- MsmqIntegrationBindingElement.cs
- Set.cs
- XmlWellformedWriter.cs
- ProcessInfo.cs
- codemethodreferenceexpression.cs
- returneventsaver.cs