Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Routing / System / ServiceModel / Routing / RoutingService.cs / 1305376 / RoutingService.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- [assembly : System.Diagnostics.CodeAnalysis.SuppressMessage(System.Runtime.FxCop.Category.Performance, System.Runtime.FxCop.Rule.AvoidUncalledPrivateCode, Scope = "member", Target = "System.ServiceModel.Routing.SR.RoutingExtensionNotFound", Justification = "gets called in RoutingService.ctor(). bug in fxcop")] namespace System.ServiceModel.Routing { using System; using System.Collections.Generic; using System.Configuration; using System.Diagnostics.CodeAnalysis; using System.Runtime; using System.ServiceModel; using System.ServiceModel.Activation; using System.ServiceModel.Channels; using System.ServiceModel.Description; using System.ServiceModel.Dispatcher; using System.Transactions; using SR2 = System.ServiceModel.Routing.SR; // Some of the [ServiceBehavior] settings are configured in RoutingBehavior class since // we need to pick the options dynamically based on whether we have transactions or not [SuppressMessage(FxCop.Category.Xaml, FxCop.Rule.TypesMustHaveXamlCallableConstructors)] [SuppressMessage(FxCop.Category.Xaml, FxCop.Rule.TypesShouldHavePublicParameterlessConstructors)] [ServiceBehavior(AddressFilterMode = AddressFilterMode.Any, InstanceContextMode = InstanceContextMode.PerSession, UseSynchronizationContext = false, ValidateMustUnderstand = false)] [AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)] public sealed class RoutingService : ISimplexDatagramRouter, ISimplexSessionRouter, IRequestReplyRouter, IDuplexSessionRouter, IDisposable { SessionChannels perMessageChannels; OperationContext operationContext; RoutingService() { this.SessionMessages = new List(1); //We only need to call this here if we trace in this method. BeginXXX methods call it again. //FxTrace.Trace.SetAndTraceTransfer(this.ActivityID, true); this.operationContext = OperationContext.Current; IContextChannel channel = this.operationContext.Channel; ServiceHostBase host = this.operationContext.Host; this.ChannelExtension = channel.Extensions.Find (); if (this.ChannelExtension == null) { throw FxTrace.Exception.AsError(new ConfigurationErrorsException(SR2.RoutingExtensionNotFound)); } this.RoutingConfig = host.Extensions.Find ().RoutingConfiguration; this.RoutingConfig.VerifyConfigured(); this.ChannelExtension.AttachService(this); } [SuppressMessage(FxCop.Category.Performance, FxCop.Rule.AvoidUncalledPrivateCode, Justification = "private setter does get called")] internal RoutingChannelExtension ChannelExtension { get; private set; } [SuppressMessage(FxCop.Category.Performance, FxCop.Rule.AvoidUncalledPrivateCode, Justification = "private setter does get called")] internal RoutingConfiguration RoutingConfig { get; private set; } internal CommittableTransaction RetryTransaction { get; private set; } internal Exception SessionException { get; set; } [SuppressMessage(FxCop.Category.Performance, FxCop.Rule.AvoidUncalledPrivateCode, Justification = "private setter does get called")] internal IList SessionMessages { get; private set; } Transaction ReceiveTransaction { get; set; } internal void CreateNewTransactionIfNeeded(MessageRpc messageRpc) { if (messageRpc.Transaction != null && this.ChannelExtension.TransactedReceiveEnabled) { if (TD.RoutingServiceUsingExistingTransactionIsEnabled()) { TD.RoutingServiceUsingExistingTransaction(messageRpc.Transaction.TransactionInformation.LocalIdentifier); } Fx.Assert(this.ReceiveTransaction == null, "Should only happen at the start of a session."); this.ReceiveTransaction = messageRpc.Transaction; return; } else if (!this.ChannelExtension.TransactedReceiveEnabled || !this.ChannelExtension.ReceiveContextEnabled) { return; } Fx.Assert(this.RetryTransaction == null, "Logic error, we shouldn't be calling CreateNewTransactionIfNeeded if we have a RC Transaction"); ChannelDispatcher channelDispatcher = this.operationContext.EndpointDispatcher.ChannelDispatcher; TimeSpan timeout = channelDispatcher.TransactionTimeout; IsolationLevel isolation = channelDispatcher.TransactionIsolationLevel; TransactionOptions options = new TransactionOptions(); if (timeout > TimeSpan.Zero) { options.Timeout = timeout; } if (isolation != IsolationLevel.Unspecified) { options.IsolationLevel = isolation; } this.RetryTransaction = new CommittableTransaction(options); if (TD.RoutingServiceCreatingTransactionIsEnabled()) { TD.RoutingServiceCreatingTransaction(this.RetryTransaction.TransactionInformation.LocalIdentifier); } } internal IRoutingClient GetOrCreateClient (RoutingEndpointTrait endpointTrait, bool impersonating) { if (impersonating && !this.ChannelExtension.HasSession) { if (this.perMessageChannels == null) { this.perMessageChannels = new SessionChannels(this.ChannelExtension.ActivityID); } return this.perMessageChannels.GetOrCreateClient (endpointTrait, this, impersonating); } else { return this.ChannelExtension.SessionChannels.GetOrCreateClient (endpointTrait, this, impersonating); } } internal Transaction GetTransactionForSending(MessageRpc messageRpc) { if (messageRpc != null && messageRpc.Transaction != null) { return messageRpc.Transaction; } if (this.ReceiveTransaction != null) { //This is the transaction used for the receive, we cannot perform error handling since we //didn't create it. return this.ReceiveTransaction; } else { //This could be null, indicating non-transactional behavior return this.RetryTransaction; } } void IDisposable.Dispose() { if (this.perMessageChannels != null) { //This is for impersonation, thus it's supposed to complete [....] IAsyncResult result = this.perMessageChannels.BeginClose(this.ChannelExtension.OperationTimeout, null, null); this.perMessageChannels.EndClose(result); this.perMessageChannels = null; } } internal void ResetSession() { //Are we in a transactional error handling case (i.e. ReceiveContext)? if (this.RetryTransaction != null) { if (this.ChannelExtension.HasSession) { this.ChannelExtension.SessionChannels.AbortAll(); } RoutingUtilities.SafeRollbackTransaction(this.RetryTransaction); this.RetryTransaction = null; } } [OperationBehavior(Impersonation = ImpersonationOption.Allowed)] IAsyncResult ISimplexSessionRouter.BeginProcessMessage(Message message, AsyncCallback callback, object state) { return this.BeginProcessMessage (message, callback, state); } void ISimplexSessionRouter.EndProcessMessage(IAsyncResult result) { this.EndProcessMessage (result); } [OperationBehavior(Impersonation = ImpersonationOption.Allowed)] IAsyncResult IRequestReplyRouter.BeginProcessRequest(Message message, AsyncCallback callback, object state) { return this.BeginProcessRequest (message, callback, state); } Message IRequestReplyRouter.EndProcessRequest(IAsyncResult result) { return this.EndProcessRequest (result); } [OperationBehavior(Impersonation=ImpersonationOption.Allowed)] IAsyncResult IDuplexSessionRouter.BeginProcessMessage(Message message, AsyncCallback callback, object state) { return this.BeginProcessMessage (message, callback, state); } void IDuplexSessionRouter.EndProcessMessage(IAsyncResult result) { this.EndProcessMessage (result); } [OperationBehavior(Impersonation = ImpersonationOption.Allowed)] IAsyncResult ISimplexDatagramRouter.BeginProcessMessage(Message message, AsyncCallback callback, object state) { return this.BeginProcessMessage (message, callback, state); } void ISimplexDatagramRouter.EndProcessMessage(IAsyncResult result) { this.EndProcessMessage (result); } IAsyncResult BeginProcessMessage (Message message, AsyncCallback callback, object state) { try { FxTrace.Trace.SetAndTraceTransfer(this.ChannelExtension.ActivityID, true); return new ProcessMessagesAsyncResult (message, this, this.ChannelExtension.OperationTimeout, callback, state); } catch (Exception exception) { if (TD.RoutingServiceProcessingFailureIsEnabled()) { TD.RoutingServiceProcessingFailure(OperationContext.Current.Channel.LocalAddress.ToString(), exception); } throw; } } void EndProcessMessage (IAsyncResult result) { try { FxTrace.Trace.SetAndTraceTransfer(this.ChannelExtension.ActivityID, true); ProcessMessagesAsyncResult .End(result); } catch (Exception exception) { if (TD.RoutingServiceProcessingFailureIsEnabled()) { TD.RoutingServiceProcessingFailure(OperationContext.Current.Channel.LocalAddress.ToString(), exception); } throw; } } IAsyncResult BeginProcessRequest (Message message, AsyncCallback callback, object state) { try { FxTrace.Trace.SetAndTraceTransfer(this.ChannelExtension.ActivityID, true); return new ProcessRequestAsyncResult (this, message, callback, state); } catch (Exception exception) { if (TD.RoutingServiceProcessingFailureIsEnabled()) { TD.RoutingServiceProcessingFailure(OperationContext.Current.Channel.LocalAddress.ToString(), exception); } throw; } } Message EndProcessRequest (IAsyncResult result) { try { FxTrace.Trace.SetAndTraceTransfer(this.ChannelExtension.ActivityID, true); return ProcessRequestAsyncResult .End(result); } catch (Exception exception) { if (TD.RoutingServiceProcessingFailureIsEnabled()) { TD.RoutingServiceProcessingFailure(OperationContext.Current.Channel.LocalAddress.ToString(), exception); } throw; } } } } // 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
- ExtentJoinTreeNode.cs
- UserNamePasswordValidationMode.cs
- XmlUtilWriter.cs
- DataKeyCollection.cs
- ExceptionUtility.cs
- figurelengthconverter.cs
- Input.cs
- CompatibleComparer.cs
- SerializerWriterEventHandlers.cs
- ViewCellSlot.cs
- WinInetCache.cs
- DataKey.cs
- webbrowsersite.cs
- AsyncOperation.cs
- Exception.cs
- PathGeometry.cs
- DataBinder.cs
- ColorConverter.cs
- XpsFilter.cs
- SqlStream.cs
- SessionPageStateSection.cs
- ViewLoader.cs
- DrawingDrawingContext.cs
- EventEntry.cs
- DNS.cs
- PaintValueEventArgs.cs
- TraceListeners.cs
- Statements.cs
- _ChunkParse.cs
- handlecollector.cs
- XmlEntityReference.cs
- OpenTypeLayout.cs
- CssTextWriter.cs
- SchemaInfo.cs
- SynchronizingStream.cs
- ProviderMetadata.cs
- HttpCacheParams.cs
- ShapeTypeface.cs
- httpstaticobjectscollection.cs
- StubHelpers.cs
- DataGridAddNewRow.cs
- KnownTypesHelper.cs
- Utility.cs
- UIElement.cs
- SimpleWorkerRequest.cs
- DiagnosticSection.cs
- WindowsSlider.cs
- IPEndPointCollection.cs
- _ConnectStream.cs
- Missing.cs
- Assembly.cs
- MemberExpression.cs
- HwndTarget.cs
- SmiEventSink_Default.cs
- BufferBuilder.cs
- DesignerObject.cs
- SchemaDeclBase.cs
- Expressions.cs
- PartialTrustVisibleAssembly.cs
- CredentialCache.cs
- LassoHelper.cs
- DesignTimeType.cs
- IntSecurity.cs
- DetailsViewPageEventArgs.cs
- Int64Animation.cs
- ScrollContentPresenter.cs
- UnmanagedMemoryStreamWrapper.cs
- TypeBuilder.cs
- WindowsClientElement.cs
- UriScheme.cs
- BufferModeSettings.cs
- AnnotationObservableCollection.cs
- AssemblyHash.cs
- XsdDateTime.cs
- OdbcEnvironmentHandle.cs
- ProviderMetadata.cs
- Walker.cs
- WebPartConnectionsDisconnectVerb.cs
- TreeNode.cs
- DataServiceRequest.cs
- ObjectViewFactory.cs
- UrlMapping.cs
- DateTimeFormatInfoScanner.cs
- ChineseLunisolarCalendar.cs
- QilNode.cs
- StrokeNodeEnumerator.cs
- SmiContextFactory.cs
- ValidationErrorInfo.cs
- LabelEditEvent.cs
- UpdateTracker.cs
- Int32Storage.cs
- SimpleApplicationHost.cs
- TemplateField.cs
- BinHexEncoder.cs
- Publisher.cs
- LocalizableAttribute.cs
- XmlSerializerAssemblyAttribute.cs
- SecondaryViewProvider.cs
- AssemblyResourceLoader.cs
- SignedXmlDebugLog.cs