Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / TcpTransportBindingElement.cs / 1 / TcpTransportBindingElement.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.ServiceModel.Activation; using System.Collections.Generic; using System.Net; using System.Net.Security; using System.Net.Sockets; using System.Runtime.Serialization; using System.Xml; public class TcpTransportBindingElement : ConnectionOrientedTransportBindingElement { int listenBacklog; bool portSharingEnabled; bool teredoEnabled; TcpConnectionPoolSettings connectionPoolSettings; public TcpTransportBindingElement() : base() { this.listenBacklog = TcpTransportDefaults.ListenBacklog; this.portSharingEnabled = TcpTransportDefaults.PortSharingEnabled; this.teredoEnabled = TcpTransportDefaults.TeredoEnabled; this.connectionPoolSettings = new TcpConnectionPoolSettings(); } protected TcpTransportBindingElement(TcpTransportBindingElement elementToBeCloned) : base(elementToBeCloned) { this.listenBacklog = elementToBeCloned.listenBacklog; this.portSharingEnabled = elementToBeCloned.portSharingEnabled; this.teredoEnabled = elementToBeCloned.teredoEnabled; this.connectionPoolSettings = elementToBeCloned.connectionPoolSettings.Clone(); } public TcpConnectionPoolSettings ConnectionPoolSettings { get { return this.connectionPoolSettings; } } public int ListenBacklog { get { return this.listenBacklog; } set { if (value <= 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentOutOfRangeException("value", SR.GetString(SR.ValueMustBePositive))); } this.listenBacklog = value; } } // server public bool PortSharingEnabled { get { return this.portSharingEnabled; } set { this.portSharingEnabled = value; } } public override string Scheme { get { return "net.tcp"; } } // server public bool TeredoEnabled { get { return this.teredoEnabled; } set { this.teredoEnabled = value; } } internal override string WsdlTransportUri { get { return TransportPolicyConstants.TcpTransportUri; } } public override BindingElement Clone() { return new TcpTransportBindingElement(this); } public override IChannelFactoryBuildChannelFactory (BindingContext context) { if (context == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); } if (!this.CanBuildChannelFactory (context)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgument("TChannel", SR.GetString(SR.ChannelTypeNotSupported, typeof(TChannel))); } return (IChannelFactory )(object)new TcpChannelFactory (this, context); } public override IChannelListener BuildChannelListener (BindingContext context) { if (context == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); } if (!this.CanBuildChannelListener (context)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgument("TChannel", SR.GetString(SR.ChannelTypeNotSupported, typeof(TChannel))); } TcpChannelListener listener; if (typeof(TChannel) == typeof(IReplyChannel)) { listener = new TcpReplyChannelListener(this, context); } else if (typeof(TChannel) == typeof(IDuplexSessionChannel)) { listener = new TcpDuplexChannelListener(this, context); } else { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgument("TChannel", SR.GetString(SR.ChannelTypeNotSupported, typeof(TChannel))); } VirtualPathExtension.ApplyHostedContext(listener, context); return (IChannelListener )(object)listener; } public override T GetProperty (BindingContext context) { if (context == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); } if (typeof(T) == typeof(IBindingDeliveryCapabilities)) { return (T)(object)new BindingDeliveryCapabilitiesHelper(); } else { return base.GetProperty (context); } } internal override bool IsMatch(BindingElement b) { if (!base.IsMatch(b)) { return false; } TcpTransportBindingElement tcp = b as TcpTransportBindingElement; if (tcp == null) { return false; } if (this.listenBacklog != tcp.listenBacklog) { return false; } if (this.portSharingEnabled != tcp.portSharingEnabled) { return false; } if (this.teredoEnabled != tcp.teredoEnabled) { return false; } if (!this.connectionPoolSettings.IsMatch(tcp.connectionPoolSettings)) { return false; } return true; } class BindingDeliveryCapabilitiesHelper : IBindingDeliveryCapabilities { internal BindingDeliveryCapabilitiesHelper() { } bool IBindingDeliveryCapabilities.AssuresOrderedDelivery { get { return true; } } bool IBindingDeliveryCapabilities.QueuedDelivery { get { return false; } } } } } // 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
- ISCIIEncoding.cs
- CallTemplateAction.cs
- ISessionStateStore.cs
- PipelineModuleStepContainer.cs
- SortedList.cs
- XmlNamedNodeMap.cs
- FragmentNavigationEventArgs.cs
- MethodMessage.cs
- NavigationFailedEventArgs.cs
- TrayIconDesigner.cs
- ListViewItemSelectionChangedEvent.cs
- QuotaExceededException.cs
- BinaryObjectInfo.cs
- ExecutionScope.cs
- TcpAppDomainProtocolHandler.cs
- CompilerWrapper.cs
- RestHandlerFactory.cs
- SchemaNotation.cs
- GB18030Encoding.cs
- CompilerWrapper.cs
- SafeArrayTypeMismatchException.cs
- DesignerForm.cs
- ExpressionConverter.cs
- ResourceCategoryAttribute.cs
- LayoutUtils.cs
- DataGridViewRowsRemovedEventArgs.cs
- ExpressionEditorSheet.cs
- ClientCredentialsSecurityTokenManager.cs
- xmlfixedPageInfo.cs
- RemotingConfigParser.cs
- SqlDataSourceCache.cs
- ParallelSeparator.xaml.cs
- MouseActionValueSerializer.cs
- _DigestClient.cs
- DataPointer.cs
- GridViewRow.cs
- ApplicationServicesHostFactory.cs
- OperandQuery.cs
- ValidationEventArgs.cs
- ScrollableControl.cs
- XhtmlBasicPageAdapter.cs
- AnimationTimeline.cs
- DBParameter.cs
- TripleDESCryptoServiceProvider.cs
- MarkedHighlightComponent.cs
- RijndaelManagedTransform.cs
- EntityDataSourceColumn.cs
- AutoGeneratedFieldProperties.cs
- _SslSessionsCache.cs
- DataServiceQuery.cs
- UpdateProgress.cs
- BlurBitmapEffect.cs
- DiscoveryEndpointElement.cs
- ButtonBaseAdapter.cs
- Base64Decoder.cs
- CroppedBitmap.cs
- webproxy.cs
- CompiledQuery.cs
- XhtmlBasicTextViewAdapter.cs
- CmsInterop.cs
- QueryIntervalOp.cs
- TextServicesContext.cs
- PageThemeParser.cs
- _ShellExpression.cs
- OracleDataAdapter.cs
- WindowsListViewSubItem.cs
- ImageListStreamer.cs
- RangeContentEnumerator.cs
- CacheModeConverter.cs
- RegisteredExpandoAttribute.cs
- ObjectQuery_EntitySqlExtensions.cs
- HashRepartitionEnumerator.cs
- ProxyElement.cs
- ListViewGroupConverter.cs
- unsafeIndexingFilterStream.cs
- SmtpNetworkElement.cs
- TransportElement.cs
- ComplexTypeEmitter.cs
- SqlStream.cs
- WebRequestModuleElement.cs
- XmlRawWriter.cs
- PassportAuthenticationModule.cs
- ScrollBarRenderer.cs
- CreatingCookieEventArgs.cs
- SmtpCommands.cs
- MatrixTransform.cs
- SecurityUniqueId.cs
- MatrixKeyFrameCollection.cs
- PipelineModuleStepContainer.cs
- PerformanceCounterCategory.cs
- ContainerParagraph.cs
- RelationshipEndCollection.cs
- Int32Converter.cs
- ResetableIterator.cs
- SerializationStore.cs
- CustomAttributeBuilder.cs
- StringSorter.cs
- DataGridViewCheckBoxCell.cs
- RenderData.cs
- HwndTarget.cs