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
- TaskHelper.cs
- HtmlPhoneCallAdapter.cs
- ObjectMemberMapping.cs
- DesignBindingConverter.cs
- UnmanagedMemoryStreamWrapper.cs
- ToolstripProfessionalRenderer.cs
- ListViewDataItem.cs
- Win32.cs
- TimeSpanFormat.cs
- CountAggregationOperator.cs
- FileStream.cs
- OrderByQueryOptionExpression.cs
- Image.cs
- List.cs
- LabelInfo.cs
- _Semaphore.cs
- SqlBinder.cs
- UTF7Encoding.cs
- TextServicesContext.cs
- TextEditor.cs
- TableLayout.cs
- RankException.cs
- NativeMethods.cs
- UnsafeNativeMethodsPenimc.cs
- LabelDesigner.cs
- SqlWebEventProvider.cs
- PassportAuthentication.cs
- WindowsUpDown.cs
- ProviderUtil.cs
- AspNetSynchronizationContext.cs
- NameValueCollection.cs
- ManagementEventWatcher.cs
- LazyInitializer.cs
- StreamAsIStream.cs
- ModuleBuilder.cs
- ObjectIDGenerator.cs
- userdatakeys.cs
- CodeDirectoryCompiler.cs
- PackageDigitalSignatureManager.cs
- AsyncPostBackErrorEventArgs.cs
- ClonableStack.cs
- ItemType.cs
- QilNode.cs
- XsdBuildProvider.cs
- PrintDialogDesigner.cs
- PartialCachingControl.cs
- DefaultMemberAttribute.cs
- StructuralType.cs
- RuleSetDialog.cs
- ModelVisual3D.cs
- SymbolEqualComparer.cs
- OracleRowUpdatedEventArgs.cs
- DecoderExceptionFallback.cs
- HtmlControlPersistable.cs
- WindowsAuthenticationModule.cs
- TimeSpanMinutesOrInfiniteConverter.cs
- ClientRuntimeConfig.cs
- Tool.cs
- FileEnumerator.cs
- MessageSmuggler.cs
- RefreshEventArgs.cs
- EtwTrackingBehaviorElement.cs
- DataTablePropertyDescriptor.cs
- BasicCellRelation.cs
- TreeBuilderBamlTranslator.cs
- SrgsElementFactory.cs
- PrinterUnitConvert.cs
- UrlParameterWriter.cs
- Brush.cs
- AssociationProvider.cs
- PtsPage.cs
- DataGridCellItemAutomationPeer.cs
- OAVariantLib.cs
- ChainedAsyncResult.cs
- Camera.cs
- NamedPipeAppDomainProtocolHandler.cs
- SessionStateUtil.cs
- EDesignUtil.cs
- CompositeActivityTypeDescriptorProvider.cs
- TdsParserSafeHandles.cs
- DesignTimeVisibleAttribute.cs
- XPathNavigatorReader.cs
- MaskedTextProvider.cs
- DataGridViewAccessibleObject.cs
- GridToolTip.cs
- Function.cs
- Variant.cs
- AppSecurityManager.cs
- MediaElement.cs
- ProxyFragment.cs
- HttpModulesSection.cs
- InvalidStoreProtectionKeyException.cs
- XsdBuildProvider.cs
- SegmentInfo.cs
- XmlHierarchicalDataSourceView.cs
- DebugHandleTracker.cs
- ContextMenuService.cs
- UpdateTracker.cs
- ReverseInheritProperty.cs
- _SslState.cs