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
- IfJoinedCondition.cs
- PrintDialogException.cs
- AnnotationResourceChangedEventArgs.cs
- InputMethodStateChangeEventArgs.cs
- ProviderUtil.cs
- ManagementEventArgs.cs
- GroupBoxAutomationPeer.cs
- WinFormsUtils.cs
- RawStylusInputCustomData.cs
- Single.cs
- SqlUtils.cs
- HttpListenerContext.cs
- BuildManagerHost.cs
- SupportsEventValidationAttribute.cs
- ButtonBase.cs
- MouseEvent.cs
- ContainsRowNumberChecker.cs
- GcHandle.cs
- ConfigurationConverterBase.cs
- FacetChecker.cs
- TagElement.cs
- BinaryObjectReader.cs
- AxDesigner.cs
- LinkButton.cs
- FieldAccessException.cs
- RichTextBox.cs
- PackageStore.cs
- InvalidPrinterException.cs
- UnsafeNativeMethods.cs
- ProcessHostMapPath.cs
- ApplicationCommands.cs
- EventData.cs
- SecurityCriticalDataForSet.cs
- SplineKeyFrames.cs
- CodeLabeledStatement.cs
- StateChangeEvent.cs
- PrivacyNoticeBindingElementImporter.cs
- SequenceFullException.cs
- Span.cs
- WindowsListViewGroupHelper.cs
- DynamicObject.cs
- EndpointAddressAugust2004.cs
- TextControl.cs
- IItemProperties.cs
- PeerEndPoint.cs
- ChildDocumentBlock.cs
- DataGridViewCellValidatingEventArgs.cs
- WebZone.cs
- TrustManagerPromptUI.cs
- PowerModeChangedEventArgs.cs
- NodeLabelEditEvent.cs
- webbrowsersite.cs
- ListCollectionView.cs
- DispatcherHooks.cs
- _BufferOffsetSize.cs
- Opcode.cs
- SqlBulkCopyColumnMapping.cs
- HttpCacheParams.cs
- SpotLight.cs
- Cursor.cs
- HyperLinkDesigner.cs
- AsyncStreamReader.cs
- documentsequencetextcontainer.cs
- MSAANativeProvider.cs
- FormsAuthenticationModule.cs
- CompiledRegexRunner.cs
- WebPartDescriptionCollection.cs
- EditingCommands.cs
- Attachment.cs
- SafeRightsManagementQueryHandle.cs
- ContextMenuStripGroupCollection.cs
- StoreItemCollection.Loader.cs
- DesignRelationCollection.cs
- TextFindEngine.cs
- Currency.cs
- WebBrowser.cs
- ObjectContextServiceProvider.cs
- FreezableDefaultValueFactory.cs
- ExpandButtonVisibilityConverter.cs
- GregorianCalendar.cs
- LoaderAllocator.cs
- DocumentPageViewAutomationPeer.cs
- GiveFeedbackEvent.cs
- PasswordTextNavigator.cs
- OpenTypeLayoutCache.cs
- HttpConfigurationSystem.cs
- Tablet.cs
- RuntimeWrappedException.cs
- SqlBulkCopyColumnMapping.cs
- RightsManagementEncryptedStream.cs
- SelectionWordBreaker.cs
- WindowsRichEdit.cs
- PackagePartCollection.cs
- Trace.cs
- Floater.cs
- TypeGeneratedEventArgs.cs
- PolyLineSegment.cs
- CroppedBitmap.cs
- SessionMode.cs
- DelegatingTypeDescriptionProvider.cs