Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / InternalDuplexBindingElement.cs / 1 / InternalDuplexBindingElement.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Collections.Generic; using System.Runtime.Serialization; using System.Xml; using System.ServiceModel.Security; using System.ServiceModel.Dispatcher; sealed class InternalDuplexBindingElement : BindingElement { InputChannelDemuxer clientChannelDemuxer; bool providesCorrelation; public InternalDuplexBindingElement() : this(false) { } // internal InternalDuplexBindingElement(bool providesCorrelation) : base() { this.providesCorrelation = providesCorrelation; } InternalDuplexBindingElement(InternalDuplexBindingElement elementToBeCloned) : base(elementToBeCloned) { this.clientChannelDemuxer = elementToBeCloned.ClientChannelDemuxer; this.providesCorrelation = elementToBeCloned.ProvidesCorrelation; } internal InputChannelDemuxer ClientChannelDemuxer { get { return this.clientChannelDemuxer; } } internal bool ProvidesCorrelation { get { return this.providesCorrelation; } } public override BindingElement Clone() { return new InternalDuplexBindingElement(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))); } IChannelFactory innerChannelFactory = context.Clone().BuildInnerChannelFactory (); if (this.clientChannelDemuxer == null) { this.clientChannelDemuxer = new InputChannelDemuxer(context); } else { #pragma warning suppress 56506 // [....], context.RemainingBindingElements will never be null context.RemainingBindingElements.Clear(); } LocalAddressProvider localAddressProvider = context.BindingParameters.Remove (); return (IChannelFactory )(object) new InternalDuplexChannelFactory(this, context, this.clientChannelDemuxer, innerChannelFactory, localAddressProvider); } public override IChannelListener BuildChannelListener (BindingContext context) { if (context == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); } if (typeof(TChannel) != typeof(IDuplexChannel)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgument("TChannel", SR.GetString(SR.ChannelTypeNotSupported, typeof(TChannel))); } return (IChannelListener )(object)new InternalDuplexChannelListener(this, context); } public override bool CanBuildChannelFactory (BindingContext context) { if (context == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); return typeof(TChannel) == typeof(IDuplexChannel) && context.CanBuildInnerChannelFactory () && context.CanBuildInnerChannelListener (); } public override bool CanBuildChannelListener (BindingContext context) { if (context == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); return typeof(TChannel) == typeof(IDuplexChannel) && context.CanBuildInnerChannelFactory () && context.CanBuildInnerChannelListener (); } internal static T GetSecurityCapabilities (ISecurityCapabilities lowerCapabilities) { DiagnosticUtility.DebugAssert(typeof(T) == typeof(ISecurityCapabilities), "Can only be used with ISecurityCapabilities"); if (lowerCapabilities != null) { // composite duplex cannot ensure that messages it receives are from the part it sends // messages to. So it cannot offer server auth return (T)(object)(new SecurityCapabilities(lowerCapabilities.SupportsClientAuthentication, false, lowerCapabilities.SupportsClientWindowsIdentity, lowerCapabilities.SupportedRequestProtectionLevel, System.Net.Security.ProtectionLevel.None)); } else { return (T)(object)null; } } public override T GetProperty (BindingContext context) { if (typeof(T) == typeof(ISecurityCapabilities) && !this.ProvidesCorrelation) { return InternalDuplexBindingElement.GetSecurityCapabilities (context.GetInnerProperty ()); } else { return context.GetInnerProperty (); } } internal override bool IsMatch(BindingElement b) { if (b == null) return false; return (b is InternalDuplexBindingElement); } public static void AddDuplexFactorySupport(BindingContext context, ref InternalDuplexBindingElement internalDuplexBindingElement) { if (context.CanBuildInnerChannelFactory ()) return; if (context.RemainingBindingElements.Find () == null) return; if (context.CanBuildInnerChannelFactory () && context.CanBuildInnerChannelListener ()) { if (context.CanBuildInnerChannelFactory ()) return; if (context.CanBuildInnerChannelFactory ()) return; if (context.CanBuildInnerChannelFactory ()) return; if (context.CanBuildInnerChannelFactory ()) return; if (internalDuplexBindingElement == null) internalDuplexBindingElement = new InternalDuplexBindingElement(); context.RemainingBindingElements.Insert(0, internalDuplexBindingElement); } } public static void AddDuplexListenerSupport(BindingContext context, ref InternalDuplexBindingElement internalDuplexBindingElement) { if (context.CanBuildInnerChannelListener ()) return; if (context.RemainingBindingElements.Find () == null) return; if (context.CanBuildInnerChannelFactory () && context.CanBuildInnerChannelListener ()) { if (context.CanBuildInnerChannelListener ()) return; if (context.CanBuildInnerChannelListener ()) return; if (context.CanBuildInnerChannelListener ()) return; if (context.CanBuildInnerChannelListener ()) return; if (internalDuplexBindingElement == null) internalDuplexBindingElement = new InternalDuplexBindingElement(); context.RemainingBindingElements.Insert(0, internalDuplexBindingElement); } } public static void AddDuplexListenerSupport(CustomBinding binding, ref InternalDuplexBindingElement internalDuplexBindingElement) { if (binding.CanBuildChannelListener ()) return; if (binding.Elements.Find () == null) return; if (binding.CanBuildChannelFactory () && binding.CanBuildChannelListener ()) { if (binding.CanBuildChannelListener ()) return; if (binding.CanBuildChannelListener ()) return; if (binding.CanBuildChannelListener ()) return; if (binding.CanBuildChannelListener ()) return; if (internalDuplexBindingElement == null) internalDuplexBindingElement = new InternalDuplexBindingElement(); binding.Elements.Insert(0, internalDuplexBindingElement); } } } class LocalAddressProvider { EndpointAddress localAddress; MessageFilter filter; int priority; public LocalAddressProvider(EndpointAddress localAddress, MessageFilter filter) { if (localAddress == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("localAddress"); } if (filter == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("filter"); } this.localAddress = localAddress; this.filter = filter; if (localAddress.Headers.FindHeader(XD.UtilityDictionary.UniqueEndpointHeaderName.Value, XD.UtilityDictionary.UniqueEndpointHeaderNamespace.Value) == null) { this.priority = Int32.MaxValue - 1; } else { this.priority = Int32.MaxValue; } } public EndpointAddress LocalAddress { get { return this.localAddress; } } public MessageFilter Filter { get { return this.filter; } } public int Priority { get { return this.priority; } } } } // 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
- BufferedGraphicsManager.cs
- ClusterRegistryConfigurationProvider.cs
- DataSourceCache.cs
- CancelEventArgs.cs
- LongAverageAggregationOperator.cs
- PointHitTestResult.cs
- CharacterMetricsDictionary.cs
- CqlLexerHelpers.cs
- GACMembershipCondition.cs
- WindowsUserNameSecurityTokenAuthenticator.cs
- DataGridViewColumnConverter.cs
- GridEntryCollection.cs
- TriState.cs
- DataGridColumn.cs
- EntitySetDataBindingList.cs
- Freezable.cs
- XamlFigureLengthSerializer.cs
- FilteredXmlReader.cs
- DataGridRowEventArgs.cs
- ResourcesChangeInfo.cs
- UnsafeNativeMethods.cs
- PointHitTestParameters.cs
- xdrvalidator.cs
- FileLogRecordStream.cs
- ServiceSecurityAuditElement.cs
- GeometryModel3D.cs
- ProvideValueServiceProvider.cs
- ViewStateModeByIdAttribute.cs
- TriggerBase.cs
- ByteAnimationBase.cs
- XmlDocumentFieldSchema.cs
- XXXInfos.cs
- CLRBindingWorker.cs
- SelectorAutomationPeer.cs
- SoapElementAttribute.cs
- SafeHandles.cs
- AutomationProperties.cs
- FixedSOMElement.cs
- ReadWriteSpinLock.cs
- SoapProcessingBehavior.cs
- mansign.cs
- Pair.cs
- SqlDataSource.cs
- SaveWorkflowCommand.cs
- StackBuilderSink.cs
- handlecollector.cs
- RuntimeConfigLKG.cs
- DataRelation.cs
- LinqDataSourceSelectEventArgs.cs
- Column.cs
- XsltLoader.cs
- COM2IDispatchConverter.cs
- ApplicationSecurityManager.cs
- AddInPipelineAttributes.cs
- ScalarType.cs
- SortAction.cs
- CommandManager.cs
- PagePropertiesChangingEventArgs.cs
- TrackingProfileSerializer.cs
- InputScopeNameConverter.cs
- XmlNamedNodeMap.cs
- ResourcePart.cs
- invalidudtexception.cs
- StylusPointCollection.cs
- SqlClientWrapperSmiStream.cs
- SchemaEntity.cs
- MimeReturn.cs
- CompiledScopeCriteria.cs
- SiteMapProvider.cs
- Size.cs
- MonitoringDescriptionAttribute.cs
- QuaternionConverter.cs
- ParserContext.cs
- FormViewInsertedEventArgs.cs
- WebBrowserHelper.cs
- DebugView.cs
- SspiSafeHandles.cs
- XamlPointCollectionSerializer.cs
- Type.cs
- DataGridPageChangedEventArgs.cs
- MimeParameter.cs
- GacUtil.cs
- ToolstripProfessionalRenderer.cs
- MachineKeyConverter.cs
- NonVisualControlAttribute.cs
- UIntPtr.cs
- RadioButtonAutomationPeer.cs
- HierarchicalDataSourceConverter.cs
- FindCriteria.cs
- cryptoapiTransform.cs
- ConnectionPointConverter.cs
- HexParser.cs
- TableProvider.cs
- ConfigurationLockCollection.cs
- PrimaryKeyTypeConverter.cs
- UIPropertyMetadata.cs
- InfoCardKeyedHashAlgorithm.cs
- HtmlTextArea.cs
- ImageField.cs
- ListenerAdapterBase.cs