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
![Network programming in C#, Network Programming in VB.NET, Network Programming in .NET](/images/book.jpg)
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- MDIWindowDialog.cs
- IncrementalCompileAnalyzer.cs
- ListControl.cs
- Size.cs
- DetailsView.cs
- LayeredChannelListener.cs
- KnownIds.cs
- Serializer.cs
- UInt32Storage.cs
- FamilyMapCollection.cs
- AxisAngleRotation3D.cs
- MimeParameters.cs
- SafeLibraryHandle.cs
- XmlQueryStaticData.cs
- SelectionPattern.cs
- ColumnBinding.cs
- DataGridViewMethods.cs
- ExpressionPrefixAttribute.cs
- ComponentChangedEvent.cs
- ClientConfigPaths.cs
- XmlSerializerFaultFormatter.cs
- ReturnValue.cs
- XsdBuilder.cs
- LinkUtilities.cs
- TdsParserStaticMethods.cs
- Peer.cs
- TaiwanLunisolarCalendar.cs
- ConfigPathUtility.cs
- GenericEnumerator.cs
- ComponentConverter.cs
- X509AsymmetricSecurityKey.cs
- Itemizer.cs
- TrustManager.cs
- BaseCollection.cs
- AutomationPatternInfo.cs
- HotCommands.cs
- RefreshEventArgs.cs
- ExtensionSimplifierMarkupObject.cs
- WindowsScroll.cs
- MasterPage.cs
- LinkConverter.cs
- ProvidePropertyAttribute.cs
- XmlArrayAttribute.cs
- GlyphElement.cs
- HTTPRemotingHandler.cs
- ColumnPropertiesGroup.cs
- NotEqual.cs
- SoapExtensionImporter.cs
- WindowsRichEdit.cs
- DriveInfo.cs
- PropertyManager.cs
- CodeRegionDirective.cs
- SqlDataSource.cs
- ComplexObject.cs
- NativeObjectSecurity.cs
- StorageMappingItemCollection.cs
- ColumnResizeAdorner.cs
- MetafileHeader.cs
- CalculatedColumn.cs
- DataServiceQuery.cs
- MemberAssignment.cs
- TextDecoration.cs
- ErrorRuntimeConfig.cs
- StaticResourceExtension.cs
- ExceptionUtil.cs
- codemethodreferenceexpression.cs
- PageWrapper.cs
- DbXmlEnabledProviderManifest.cs
- HttpRequestBase.cs
- AdjustableArrowCap.cs
- NullableBoolConverter.cs
- DispatcherOperation.cs
- Menu.cs
- CodeObjectCreateExpression.cs
- QueryCacheKey.cs
- CodeMethodInvokeExpression.cs
- SystemIPAddressInformation.cs
- FieldBuilder.cs
- SourceLineInfo.cs
- XamlFigureLengthSerializer.cs
- TableLayoutSettingsTypeConverter.cs
- NestPullup.cs
- PseudoWebRequest.cs
- PersonalizationAdministration.cs
- FormViewInsertedEventArgs.cs
- MemberMaps.cs
- Validator.cs
- StrokeNodeOperations2.cs
- ConnectionPointCookie.cs
- FormsIdentity.cs
- EncryptedType.cs
- TypeConverter.cs
- DependencyPropertyKind.cs
- QuaternionAnimationBase.cs
- StickyNote.cs
- PathFigureCollectionValueSerializer.cs
- ReadWriteSpinLock.cs
- printdlgexmarshaler.cs
- EntityTypeEmitter.cs
- Listbox.cs