Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / ConnectionOrientedTransportManager.cs / 1 / ConnectionOrientedTransportManager.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.ServiceModel.Activation; using System.ServiceModel; using System.Net; using System.Net.Sockets; using System.Collections.Generic; abstract class ConnectionOrientedTransportManager: TransportManager where TChannelListener : ConnectionOrientedTransportChannelListener { UriPrefixTable addressTable; int connectionBufferSize; TimeSpan channelInitializationTimeout; int maxPendingConnections; TimeSpan maxOutputDelay; int maxPendingAccepts; TimeSpan idleTimeout; int maxPooledConnections; MessageReceivedCallback messageReceivedCallback; protected ConnectionOrientedTransportManager() { this.addressTable = new UriPrefixTable (); } UriPrefixTable AddressTable { get { return addressTable; } } protected TimeSpan ChannelInitializationTimeout { get { return channelInitializationTimeout; } } internal void ApplyListenerSettings(IConnectionOrientedListenerSettings listenerSettings) { this.connectionBufferSize = listenerSettings.ConnectionBufferSize; this.channelInitializationTimeout = listenerSettings.ChannelInitializationTimeout; this.maxPendingConnections = listenerSettings.MaxPendingConnections; this.maxOutputDelay = listenerSettings.MaxOutputDelay; this.maxPendingAccepts = listenerSettings.MaxPendingAccepts; this.idleTimeout = listenerSettings.IdleTimeout; this.maxPooledConnections = listenerSettings.MaxPooledConnections; } internal int ConnectionBufferSize { get { return this.connectionBufferSize; } } internal int MaxPendingConnections { get { return this.maxPendingConnections; } } internal TimeSpan MaxOutputDelay { get { return maxOutputDelay; } } internal int MaxPendingAccepts { get { return this.maxPendingAccepts; } } internal TimeSpan IdleTimeout { get { return this.idleTimeout; } } internal int MaxPooledConnections { get { return this.maxPooledConnections; } } internal bool IsCompatible(ConnectionOrientedTransportChannelListener channelListener) { if (channelListener.InheritBaseAddressSettings) return true; return ( (this.ChannelInitializationTimeout == channelListener.ChannelInitializationTimeout) && (this.ConnectionBufferSize == channelListener.ConnectionBufferSize) && (this.MaxPendingConnections == channelListener.MaxPendingConnections) && (this.MaxOutputDelay == channelListener.MaxOutputDelay) && (this.MaxPendingAccepts == channelListener.MaxPendingAccepts) && (this.idleTimeout == channelListener.IdleTimeout) && (this.maxPooledConnections == channelListener.MaxPooledConnections) ); } TChannelListener GetChannelListener(Uri via) { TChannelListener channelListener = null; if (AddressTable.TryLookupUri(via, HostNameComparisonMode.StrongWildcard, out channelListener)) { return channelListener; } if (AddressTable.TryLookupUri(via, HostNameComparisonMode.Exact, out channelListener)) { return channelListener; } AddressTable.TryLookupUri(via, HostNameComparisonMode.WeakWildcard, out channelListener); return channelListener; } internal void OnDemuxerError(Exception exception) { lock (ThisLock) { this.Fault(this.AddressTable, exception); } } internal ISingletonChannelListener OnGetSingletonMessageHandler(ServerSingletonPreambleConnectionReader serverSingletonPreambleReader) { Uri via = serverSingletonPreambleReader.Via; TChannelListener channelListener = GetChannelListener(via); if (channelListener != null) { if (channelListener is IChannelListener ) { channelListener.RaiseMessageReceived(); return (ISingletonChannelListener)channelListener; } else { serverSingletonPreambleReader.SendFault(FramingEncodingString.UnsupportedModeFault); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ProtocolException(SR.GetString(SR.FramingModeNotSupported, FramingMode.Singleton))); } } else { serverSingletonPreambleReader.SendFault(FramingEncodingString.EndpointNotFoundFault); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new EndpointNotFoundException(SR.GetString(SR.EndpointNotFound, via))); } } internal void OnHandleServerSessionPreamble(ServerSessionPreambleConnectionReader serverSessionPreambleReader, ConnectionDemuxer connectionDemuxer) { Uri via = serverSessionPreambleReader.Via; TChannelListener channelListener = GetChannelListener(via); if (channelListener != null) { ISessionPreambleHandler sessionPreambleHandler = channelListener as ISessionPreambleHandler; if (sessionPreambleHandler != null && channelListener is IChannelListener ) { sessionPreambleHandler.HandleServerSessionPreamble(serverSessionPreambleReader, connectionDemuxer); } else { serverSessionPreambleReader.SendFault(FramingEncodingString.UnsupportedModeFault); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ProtocolException(SR.GetString(SR.FramingModeNotSupported, FramingMode.Duplex))); } } else { serverSessionPreambleReader.SendFault(FramingEncodingString.EndpointNotFoundFault); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new EndpointNotFoundException(SR.GetString(SR.DuplexSessionListenerNotFound, via.ToString()))); } } internal IConnectionOrientedTransportFactorySettings OnGetTransportFactorySettings(Uri via) { return GetChannelListener(via); } internal override void Register(TransportChannelListener channelListener) { AddressTable.RegisterUri(channelListener.Uri, channelListener.HostNameComparisonModeInternal, (TChannelListener)channelListener); channelListener.SetMessageReceivedCallback(new MessageReceivedCallback(OnMessageReceived)); } internal override void Unregister(TransportChannelListener channelListener) { EnsureRegistered(AddressTable, (TChannelListener)channelListener, channelListener.HostNameComparisonModeInternal); AddressTable.UnregisterUri(channelListener.Uri, channelListener.HostNameComparisonModeInternal); channelListener.SetMessageReceivedCallback(null); } internal void SetMessageReceivedCallback(MessageReceivedCallback messageReceivedCallback) { this.messageReceivedCallback = messageReceivedCallback; } void OnMessageReceived() { if (messageReceivedCallback != null) { messageReceivedCallback(); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- PathParser.cs
- WeakReadOnlyCollection.cs
- CodeSnippetCompileUnit.cs
- DecimalAnimationBase.cs
- RangeBaseAutomationPeer.cs
- ToolStripItem.cs
- Operator.cs
- IndentedTextWriter.cs
- Formatter.cs
- ViewgenContext.cs
- SoapIncludeAttribute.cs
- X509Certificate2.cs
- Vector3DValueSerializer.cs
- ConnectivityStatus.cs
- SHA384.cs
- SecureEnvironment.cs
- XmlDocumentFieldSchema.cs
- DtdParser.cs
- DataGridViewRowErrorTextNeededEventArgs.cs
- BooleanKeyFrameCollection.cs
- EmissiveMaterial.cs
- MediaTimeline.cs
- PointHitTestResult.cs
- CatalogPart.cs
- CriticalFinalizerObject.cs
- FontStretch.cs
- CanonicalFormWriter.cs
- DynamicResourceExtensionConverter.cs
- DiscoveryExceptionDictionary.cs
- SqlFormatter.cs
- RegistrySecurity.cs
- FontInfo.cs
- CqlLexerHelpers.cs
- ClientOptions.cs
- SpanIndex.cs
- SmiMetaDataProperty.cs
- FocusManager.cs
- HGlobalSafeHandle.cs
- SubpageParaClient.cs
- Point4D.cs
- IdentityModelDictionary.cs
- Point3DAnimationBase.cs
- AssemblyBuilder.cs
- AsyncResult.cs
- DataServiceQueryOfT.cs
- FontFamilyIdentifier.cs
- EntityDataSourceContextCreatedEventArgs.cs
- WmlCalendarAdapter.cs
- DataMemberConverter.cs
- TableLayoutStyleCollection.cs
- CodeEntryPointMethod.cs
- ComponentGuaranteesAttribute.cs
- DLinqTableProvider.cs
- DataGridDetailsPresenterAutomationPeer.cs
- NumericUpDownAccelerationCollection.cs
- TypeValidationEventArgs.cs
- ForceCopyBuildProvider.cs
- PresentationUIStyleResources.cs
- CalendarAutoFormatDialog.cs
- HttpWebRequest.cs
- Menu.cs
- CheckBoxPopupAdapter.cs
- ToolStripGripRenderEventArgs.cs
- WinOEToolBoxItem.cs
- IisNotInstalledException.cs
- LazyTextWriterCreator.cs
- ChineseLunisolarCalendar.cs
- TextFormatterImp.cs
- Nullable.cs
- FontConverter.cs
- Calendar.cs
- InternalCache.cs
- ThreadExceptionDialog.cs
- Funcletizer.cs
- ToolStripDropTargetManager.cs
- ImageListStreamer.cs
- CornerRadiusConverter.cs
- UriParserTemplates.cs
- ControlBuilder.cs
- ConfigurationLocation.cs
- PageContentAsyncResult.cs
- Rect.cs
- GacUtil.cs
- XmlLanguage.cs
- FormViewDeletedEventArgs.cs
- JsonStringDataContract.cs
- SoapFaultCodes.cs
- DataViewListener.cs
- RegexEditorDialog.cs
- CheckBoxStandardAdapter.cs
- StructuredTypeInfo.cs
- PeerResolverSettings.cs
- XmlSchemaRedefine.cs
- StylusDownEventArgs.cs
- LineGeometry.cs
- MailWriter.cs
- SliderAutomationPeer.cs
- DuplicateWaitObjectException.cs
- FlowSwitch.cs
- Thumb.cs