Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Activities / System / ServiceModel / Activities / CorrelationHandle.cs / 1305376 / CorrelationHandle.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Activities { using System; using System.Activities; using System.Collections.ObjectModel; using System.Runtime; using System.Runtime.DurableInstancing; using System.Runtime.Serialization; [DataContract] public class CorrelationHandle : Handle { internal static readonly string StaticExecutionPropertyName = typeof(CorrelationHandle).FullName; static readonly Type requestReplyCorrelationInitializerType = typeof(RequestReplyCorrelationInitializer); // CorrelationHandles to support Context/Durable Duplex // For processing the CallBackContextMessageProperty static readonly Type callbackCorrelationInitializerType = typeof(CallbackCorrelationInitializer); // This is for passing the Context information that we get in the reply message from the Server in the initial handshake // to the next Sendmessage activity from the client to the server static readonly Type contextCorrelationInitializerType = typeof(ContextCorrelationInitializer); //// To get to the same instance on the server side( between SendReply and following Receive) and on the client side( between Send and following send) //static readonly Type followingContextCorrelationInitializerType = typeof(FollowingContextCorrelationInitializer); CorrelationCallbackContext callbackContext; CorrelationContext context; // This is never null when it matters because the CorrelationHandle sets this during OnInitialize [DataMember] NoPersistHandle noPersistHandle; // This is never null when it matters because the CorrelationHandle sets this during OnInitialize [DataMember] BookmarkScopeHandle bookmarkScopeHandle; public CorrelationHandle() : base() { } internal CorrelationRequestContext RequestContext { get; private set; } internal CorrelationResponseContext ResponseContext { get; private set; } [DataMember(EmitDefaultValue = false)] internal CorrelationCallbackContext CallbackContext { get { return this.callbackContext; } set { Fx.Assert(this.callbackContext == null || this.callbackContext == value, "cannot set two different callback contexts"); this.callbackContext = value; } } [DataMember(EmitDefaultValue = false)] internal CorrelationContext Context { get { return this.context; } set { Fx.Assert(this.context == null || this.context == value, "cannot set two different callback contexts"); this.context = value; } } [DataMember(EmitDefaultValue = false)] internal BookmarkScope Scope { get; set; } protected override void OnInitialize(HandleInitializationContext context) { this.noPersistHandle = context.CreateAndInitializeHandle(); this.bookmarkScopeHandle = context.CreateAndInitializeHandle (); } protected override void OnUninitialize(HandleInitializationContext context) { context.UninitializeHandle(this.noPersistHandle); context.UninitializeHandle(this.bookmarkScopeHandle); } internal BookmarkScope EnsureBookmarkScope(NativeActivityContext executionContext) { if (this.Scope == null) { this.Scope = executionContext.DefaultBookmarkScope; } return this.Scope; } internal bool TryRegisterRequestContext(NativeActivityContext executionContext, CorrelationRequestContext requestContext) { Fx.Assert(requestContext != null, "requires a valid requestContext"); if(this.noPersistHandle == null) { return false; } if (this.RequestContext == null) { this.noPersistHandle.Enter(executionContext); this.RequestContext = requestContext; return true; } return object.ReferenceEquals(this.RequestContext, requestContext); } internal bool TryRegisterResponseContext(NativeActivityContext executionContext, CorrelationResponseContext responseContext) { Fx.Assert(responseContext != null, "requires a valid responseContext"); if (this.noPersistHandle == null) { return false; } if (this.ResponseContext == null) { this.noPersistHandle.Enter(executionContext); this.ResponseContext = responseContext; return true; } return object.ReferenceEquals(this.ResponseContext, responseContext); } internal bool TryAcquireRequestContext(NativeActivityContext executionContext, out CorrelationRequestContext requestContext) { if (this.RequestContext != null) { // We have a context, and we should disassociate it from the correlation handle this.noPersistHandle.Exit(executionContext); requestContext = this.RequestContext; this.RequestContext = null; return true; } else { requestContext = null; return false; } } internal bool TryAcquireResponseContext(NativeActivityContext executionContext, out CorrelationResponseContext responseContext) { if (this.ResponseContext != null) { // We have a context, and we should disassociate it from the correlation handle this.noPersistHandle.Exit(executionContext); responseContext = this.ResponseContext; this.ResponseContext = null; return true; } else { responseContext = null; return false; } } internal void InitializeBookmarkScope(NativeActivityContext context, InstanceKey instanceKey) { Fx.Assert(context != null, "executionContext cannot be null"); Fx.Assert(instanceKey != null, "instanceKey cannot be null"); if (this.Scope == null) { this.bookmarkScopeHandle.CreateBookmarkScope(context, instanceKey.Value); this.Scope = this.bookmarkScopeHandle.BookmarkScope; } else { if(this.Scope.IsInitialized) { if (this.Scope.Id != instanceKey.Value) { throw FxTrace.Exception.AsError( new InvalidOperationException(SR.CorrelationHandleInUse(this.Scope.Id, instanceKey.Value))); } } else { this.Scope.Initialize(context, instanceKey.Value); } } } internal bool IsInitalized() { if (this.Scope != null || this.CallbackContext != null || this.Context != null || this.ResponseContext != null || this.RequestContext != null) { return true; } return false; } internal static CorrelationHandle GetExplicitChannelCorrelation(NativeActivityContext context, Collection correlationInitializers) { return GetTypedCorrelationHandle(context, correlationInitializers, requestReplyCorrelationInitializerType); } internal static CorrelationHandle GetExplicitCallbackCorrelation(NativeActivityContext context, Collection correlationInitializers) { return GetTypedCorrelationHandle(context, correlationInitializers, callbackCorrelationInitializerType); } internal static CorrelationHandle GetExplicitContextCorrelation(NativeActivityContext context, Collection correlationInitializers) { return GetTypedCorrelationHandle(context, correlationInitializers, contextCorrelationInitializerType); } internal static CorrelationHandle GetTypedCorrelationHandle(NativeActivityContext context, Collection correlationInitializers, Type correlationInitializerType) { CorrelationHandle typedCorrelationHandle = null; if (correlationInitializers != null && correlationInitializers.Count > 0) { foreach (CorrelationInitializer correlation in correlationInitializers) { if (correlationInitializerType == correlation.GetType()) { typedCorrelationHandle = correlation.CorrelationHandle.Get(context); // We return the first handle we find break; } } } return typedCorrelationHandle; } } } // 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
- NonBatchDirectoryCompiler.cs
- FileSecurity.cs
- XmlSchemaComplexContentRestriction.cs
- UserControlBuildProvider.cs
- EventLogConfiguration.cs
- DeclarativeCatalogPartDesigner.cs
- ISAPIApplicationHost.cs
- WindowsGraphicsWrapper.cs
- TypeConverterAttribute.cs
- XamlVector3DCollectionSerializer.cs
- ContainerAction.cs
- ConstructorExpr.cs
- TreeViewBindingsEditorForm.cs
- ByteStorage.cs
- ISFTagAndGuidCache.cs
- SystemInformation.cs
- TakeQueryOptionExpression.cs
- AuthenticationServiceManager.cs
- Point3DCollectionValueSerializer.cs
- ProfileManager.cs
- UnsafeNativeMethods.cs
- WindowCollection.cs
- Environment.cs
- DataColumnPropertyDescriptor.cs
- WebHeaderCollection.cs
- DocumentScope.cs
- DecoderBestFitFallback.cs
- OrthographicCamera.cs
- CommonDialog.cs
- TextContainer.cs
- NotImplementedException.cs
- FormsIdentity.cs
- Queue.cs
- CmsUtils.cs
- FormsAuthenticationUserCollection.cs
- Brush.cs
- HttpModuleActionCollection.cs
- ItemList.cs
- SemanticAnalyzer.cs
- XmlnsPrefixAttribute.cs
- DataGridViewColumnConverter.cs
- CompilerGeneratedAttribute.cs
- MulticastOption.cs
- SqlNode.cs
- PackUriHelper.cs
- FixedDocumentSequencePaginator.cs
- WebPartVerb.cs
- WindowsMenu.cs
- RefreshResponseInfo.cs
- TypeConvertions.cs
- BamlRecordReader.cs
- HttpCookie.cs
- CodeAssignStatement.cs
- SmiContextFactory.cs
- ValueUnavailableException.cs
- SqlExpressionNullability.cs
- TableAutomationPeer.cs
- ChannelDispatcher.cs
- XslAst.cs
- FontSource.cs
- QueryCacheEntry.cs
- ImageDrawing.cs
- _OverlappedAsyncResult.cs
- MultiplexingFormatMapping.cs
- GridViewPageEventArgs.cs
- __FastResourceComparer.cs
- SpeechUI.cs
- XmlSchemaComplexContent.cs
- CursorConverter.cs
- KoreanLunisolarCalendar.cs
- SqlCacheDependencyDatabaseCollection.cs
- LookupNode.cs
- DataRowView.cs
- HttpListenerResponse.cs
- ExpressionBuilder.cs
- HttpCapabilitiesSectionHandler.cs
- TableCell.cs
- WebScriptEnablingBehavior.cs
- GridLength.cs
- OdbcError.cs
- AppDomainFactory.cs
- IDictionary.cs
- DataServiceKeyAttribute.cs
- TransportManager.cs
- GeneralTransform3D.cs
- MsmqHostedTransportManager.cs
- ReadWriteObjectLock.cs
- AuthStoreRoleProvider.cs
- AutoResetEvent.cs
- Label.cs
- HttpHeaderCollection.cs
- SocketException.cs
- TableRowGroup.cs
- KeyboardDevice.cs
- FlowNode.cs
- FileNotFoundException.cs
- Converter.cs
- ExpandSegmentCollection.cs
- InitializationEventAttribute.cs
- AssertSection.cs