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
- CodeRegionDirective.cs
- NGCSerializerAsync.cs
- BindingsCollection.cs
- TableLayoutColumnStyleCollection.cs
- ConvertersCollection.cs
- PackageRelationshipCollection.cs
- DataGridColumnFloatingHeader.cs
- RuleSettingsCollection.cs
- CmsUtils.cs
- ScrollItemPattern.cs
- TreeViewItem.cs
- AssemblyResourceLoader.cs
- DataGridTable.cs
- CommandValueSerializer.cs
- SelfIssuedAuthAsymmetricKey.cs
- DocumentGridContextMenu.cs
- milrender.cs
- ObjectHandle.cs
- JournalEntry.cs
- InternalTransaction.cs
- TabItemWrapperAutomationPeer.cs
- HashSetDebugView.cs
- URI.cs
- PtsHost.cs
- URIFormatException.cs
- DataControlFieldCell.cs
- HitTestWithPointDrawingContextWalker.cs
- SqlReorderer.cs
- BinaryFormatterWriter.cs
- OrCondition.cs
- TypeResolvingOptions.cs
- EnumType.cs
- ConfigurationSection.cs
- _ListenerRequestStream.cs
- XmlDataProvider.cs
- GeometryValueSerializer.cs
- HwndKeyboardInputProvider.cs
- StrongName.cs
- ObjectHelper.cs
- NoneExcludedImageIndexConverter.cs
- RefreshResponseInfo.cs
- GridViewEditEventArgs.cs
- CommandBindingCollection.cs
- StatusBar.cs
- IODescriptionAttribute.cs
- BaseParagraph.cs
- BitmapEditor.cs
- Panel.cs
- SqlMethodCallConverter.cs
- DefaultTraceListener.cs
- Overlapped.cs
- ValidatingCollection.cs
- WindowsListViewItemCheckBox.cs
- GroupItemAutomationPeer.cs
- ReferencedType.cs
- DataControlFieldHeaderCell.cs
- ProgressChangedEventArgs.cs
- HeaderUtility.cs
- DesignerOptionService.cs
- HttpFileCollectionBase.cs
- CreateUserWizardStep.cs
- GridViewColumnCollection.cs
- BindingContext.cs
- XmlValidatingReader.cs
- PropertyMetadata.cs
- DataSourceXmlSerializer.cs
- XmlRootAttribute.cs
- ExtractedStateEntry.cs
- XPathItem.cs
- GeneralTransform.cs
- DeleteIndexBinder.cs
- SR.Designer.cs
- TypeToken.cs
- xamlnodes.cs
- ItemCollection.cs
- SByteStorage.cs
- TextRangeSerialization.cs
- OletxTransactionManager.cs
- TemplateBindingExtensionConverter.cs
- ObjectStateManager.cs
- ViewStateException.cs
- FontWeight.cs
- JsonCollectionDataContract.cs
- _SSPISessionCache.cs
- XmlSchemaAttributeGroup.cs
- WebPartTransformerCollection.cs
- ConnectionInterfaceCollection.cs
- CodeCatchClause.cs
- PersonalizationEntry.cs
- ResourceDescriptionAttribute.cs
- RuleSettingsCollection.cs
- TdsParameterSetter.cs
- EraserBehavior.cs
- ExpressionEditorAttribute.cs
- SubclassTypeValidator.cs
- RectIndependentAnimationStorage.cs
- CaseKeyBox.xaml.cs
- BindingGroup.cs
- MULTI_QI.cs
- DrawListViewColumnHeaderEventArgs.cs