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
- SafeTimerHandle.cs
- WSTrust.cs
- BaseDataListDesigner.cs
- FlowDocumentPage.cs
- ConstraintConverter.cs
- TagNameToTypeMapper.cs
- InheritanceRules.cs
- NavigationService.cs
- securitymgrsite.cs
- CqlErrorHelper.cs
- CacheMemory.cs
- ImageMapEventArgs.cs
- SlotInfo.cs
- CurrentChangedEventManager.cs
- ServiceModelConfigurationSectionCollection.cs
- ResourceFallbackManager.cs
- DBPropSet.cs
- FontCacheLogic.cs
- DuplicateWaitObjectException.cs
- FormsAuthentication.cs
- shaperfactoryquerycachekey.cs
- GetReadStreamResult.cs
- DataColumnCollection.cs
- WebPartConnection.cs
- HtmlShim.cs
- PropertyMetadata.cs
- Filter.cs
- Line.cs
- ListView.cs
- AggregateException.cs
- PassportAuthenticationModule.cs
- GridViewRowPresenterBase.cs
- ArraySortHelper.cs
- TerminatorSinks.cs
- SafeThemeHandle.cs
- PersonalizationProvider.cs
- ConfigurationSettings.cs
- RectangleConverter.cs
- CqlGenerator.cs
- PersonalizationStateInfo.cs
- TemplateBindingExtensionConverter.cs
- MetadataArtifactLoaderCompositeFile.cs
- QueryStringParameter.cs
- CopyAction.cs
- keycontainerpermission.cs
- WarningException.cs
- TextTreePropertyUndoUnit.cs
- DataBindingCollectionConverter.cs
- UrlMappingsSection.cs
- BigInt.cs
- ButtonColumn.cs
- entityreference_tresulttype.cs
- AnnotationObservableCollection.cs
- ConfigurationErrorsException.cs
- Pkcs7Signer.cs
- OpCodes.cs
- QueryStringHandler.cs
- Transform3DCollection.cs
- IndentTextWriter.cs
- SynchronizationLockException.cs
- GridViewColumnHeader.cs
- EditorBrowsableAttribute.cs
- UserControlBuildProvider.cs
- SemaphoreSecurity.cs
- MetadataCacheItem.cs
- DragStartedEventArgs.cs
- RectAnimationClockResource.cs
- _TransmitFileOverlappedAsyncResult.cs
- ProtocolViolationException.cs
- UnknownWrapper.cs
- ReturnValue.cs
- HttpModule.cs
- XmlDataSourceNodeDescriptor.cs
- InputReportEventArgs.cs
- SimpleLine.cs
- OletxVolatileEnlistment.cs
- SqlColumnizer.cs
- MessageDecoder.cs
- BitmapEffectInput.cs
- WeakReadOnlyCollection.cs
- XamlWrappingReader.cs
- TransformerTypeCollection.cs
- HyperLinkStyle.cs
- JournalEntryStack.cs
- GridToolTip.cs
- SourceItem.cs
- ExclusiveTcpListener.cs
- WeakRefEnumerator.cs
- ThemeDirectoryCompiler.cs
- DbDataRecord.cs
- MsmqBindingElementBase.cs
- SHA384.cs
- RecognizerStateChangedEventArgs.cs
- WebBrowserDesigner.cs
- CheckPair.cs
- BitStack.cs
- InstanceDescriptor.cs
- RSACryptoServiceProvider.cs
- ObjectMaterializedEventArgs.cs
- ActivityContext.cs