Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / NetNamedPipeBinding.cs / 1 / NetNamedPipeBinding.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel { using System; using System.Text; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Configuration; using System.Globalization; using System.Net; using System.Net.Security; using System.Runtime.Serialization; using System.Security.Principal; using System.ServiceModel.Channels; using System.ServiceModel.Configuration; using System.ServiceModel.Security; using System.Xml; using System.Net.Sockets; public class NetNamedPipeBinding : Binding, IBindingRuntimePreferences { // private BindingElements TransactionFlowBindingElement context; BinaryMessageEncodingBindingElement encoding; NamedPipeTransportBindingElement namedPipe; NetNamedPipeSecurity security = new NetNamedPipeSecurity(); public NetNamedPipeBinding() : base() { Initialize(); } public NetNamedPipeBinding(NetNamedPipeSecurityMode securityMode) : this() { this.security.Mode = securityMode; } public NetNamedPipeBinding(string configurationName) : this() { ApplyConfiguration(configurationName); } NetNamedPipeBinding(NetNamedPipeSecurity security) : this() { this.security = security; } public bool TransactionFlow { get { return context.Transactions; } set { context.Transactions = value; } } public TransactionProtocol TransactionProtocol { get { return this.context.TransactionProtocol; } set { this.context.TransactionProtocol = value; } } public TransferMode TransferMode { get { return namedPipe.TransferMode; } set { namedPipe.TransferMode = value; } } public HostNameComparisonMode HostNameComparisonMode { get { return namedPipe.HostNameComparisonMode; } set { namedPipe.HostNameComparisonMode = value; } } public long MaxBufferPoolSize { get { return namedPipe.MaxBufferPoolSize; } set { namedPipe.MaxBufferPoolSize = value; } } public int MaxBufferSize { get { return namedPipe.MaxBufferSize; } set { namedPipe.MaxBufferSize = value; } } public int MaxConnections { get { return namedPipe.MaxPendingConnections; } set { namedPipe.MaxPendingConnections = value; namedPipe.ConnectionPoolSettings.MaxOutboundConnectionsPerEndpoint = value; } } public long MaxReceivedMessageSize { get { return namedPipe.MaxReceivedMessageSize; } set { namedPipe.MaxReceivedMessageSize = value; } } public XmlDictionaryReaderQuotas ReaderQuotas { get { return encoding.ReaderQuotas; } set { if (value == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("value"); value.CopyTo(encoding.ReaderQuotas); } } bool IBindingRuntimePreferences.ReceiveSynchronously { get { return false; } } public override string Scheme { get { return namedPipe.Scheme; } } public EnvelopeVersion EnvelopeVersion { get { return EnvelopeVersion.Soap12; } } public NetNamedPipeSecurity Security { get { return this.security; } } static TransactionFlowBindingElement GetDefaultTransactionFlowBindingElement() { return new TransactionFlowBindingElement(false); } void Initialize() { namedPipe = new NamedPipeTransportBindingElement(); encoding = new BinaryMessageEncodingBindingElement(); context = GetDefaultTransactionFlowBindingElement(); } void InitializeFrom(NamedPipeTransportBindingElement namedPipe, BinaryMessageEncodingBindingElement encoding, TransactionFlowBindingElement context) { Initialize(); this.HostNameComparisonMode = namedPipe.HostNameComparisonMode; this.MaxBufferPoolSize = namedPipe.MaxBufferPoolSize; this.MaxBufferSize = namedPipe.MaxBufferSize; this.MaxConnections = namedPipe.MaxPendingConnections; this.MaxReceivedMessageSize = namedPipe.MaxReceivedMessageSize; this.TransferMode = namedPipe.TransferMode; this.ReaderQuotas = encoding.ReaderQuotas; this.TransactionFlow = context.Transactions; this.TransactionProtocol = context.TransactionProtocol; } // check that properties of the HttpTransportBindingElement and // MessageEncodingBindingElement not exposed as properties on BasicHttpBinding // match default values of the binding elements bool IsBindingElementsMatch(NamedPipeTransportBindingElement namedPipe, BinaryMessageEncodingBindingElement encoding, TransactionFlowBindingElement context) { if (!this.namedPipe.IsMatch(namedPipe)) return false; if (!this.encoding.IsMatch(encoding)) return false; if (!this.context.IsMatch(context)) return false; return true; } void ApplyConfiguration(string configurationName) { NetNamedPipeBindingCollectionElement section = NetNamedPipeBindingCollectionElement.GetBindingCollectionElement(); NetNamedPipeBindingElement element = section.Bindings[configurationName]; if (element == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ConfigurationErrorsException( SR.GetString(SR.ConfigInvalidBindingConfigurationName, configurationName, ConfigurationStrings.NetNamedPipeBindingCollectionElementName))); } else { element.ApplyConfiguration(this); } } public override BindingElementCollection CreateBindingElements() { // return collection of BindingElements BindingElementCollection bindingElements = new BindingElementCollection(); // order of BindingElements is important // add context bindingElements.Add(context); // add encoding bindingElements.Add(encoding); // add transport security WindowsStreamSecurityBindingElement transportSecurity = CreateTransportSecurity(); if (transportSecurity != null) { bindingElements.Add(transportSecurity); } // add transport (named pipes) bindingElements.Add(this.namedPipe); return bindingElements.Clone(); } internal static bool TryCreate(BindingElementCollection elements, out Binding binding) { binding = null; if (elements.Count > 4) return false; TransactionFlowBindingElement context = null; BinaryMessageEncodingBindingElement encoding = null; WindowsStreamSecurityBindingElement security = null; NamedPipeTransportBindingElement namedPipe = null; foreach (BindingElement element in elements) { if (element is TransactionFlowBindingElement) context = element as TransactionFlowBindingElement; else if (element is BinaryMessageEncodingBindingElement) encoding = element as BinaryMessageEncodingBindingElement; else if (element is WindowsStreamSecurityBindingElement) security = element as WindowsStreamSecurityBindingElement; else if (element is NamedPipeTransportBindingElement) namedPipe = element as NamedPipeTransportBindingElement; else return false; } if (namedPipe == null) return false; if (encoding == null) return false; if (context == null) context = GetDefaultTransactionFlowBindingElement(); NetNamedPipeSecurity pipeSecurity; if (!TryCreateSecurity(security, out pipeSecurity)) return false; NetNamedPipeBinding netNamedPipeBinding = new NetNamedPipeBinding(pipeSecurity); netNamedPipeBinding.InitializeFrom(namedPipe, encoding, context); if (!netNamedPipeBinding.IsBindingElementsMatch(namedPipe, encoding, context)) return false; binding = netNamedPipeBinding; return true; } WindowsStreamSecurityBindingElement CreateTransportSecurity() { if (this.security.Mode == NetNamedPipeSecurityMode.Transport) { return this.security.CreateTransportSecurity(); } else { return null; } } static bool TryCreateSecurity(WindowsStreamSecurityBindingElement wssbe, out NetNamedPipeSecurity security) { NetNamedPipeSecurityMode mode = wssbe == null ? NetNamedPipeSecurityMode.None : NetNamedPipeSecurityMode.Transport; return NetNamedPipeSecurity.TryCreate(wssbe, mode, out security); } } } // 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
- SkinBuilder.cs
- XamlReader.cs
- AddInContractAttribute.cs
- ToolStripContentPanelRenderEventArgs.cs
- TabletDeviceInfo.cs
- CollectionEditor.cs
- EnumConverter.cs
- JsonReaderWriterFactory.cs
- MonitoringDescriptionAttribute.cs
- ProgressChangedEventArgs.cs
- XsdDuration.cs
- _SSPIWrapper.cs
- TextEditorCopyPaste.cs
- GeometryGroup.cs
- DbgCompiler.cs
- Compilation.cs
- SqlBooleanMismatchVisitor.cs
- StylusButtonEventArgs.cs
- CmsUtils.cs
- AdRotatorDesigner.cs
- NetworkCredential.cs
- PartialTrustHelpers.cs
- Debug.cs
- ControllableStoryboardAction.cs
- TextLineBreak.cs
- TypeToStringValueConverter.cs
- DiscreteKeyFrames.cs
- ConfigPathUtility.cs
- RoleManagerModule.cs
- SecUtil.cs
- EntityClassGenerator.cs
- ScriptingScriptResourceHandlerSection.cs
- ProfileSection.cs
- InputProcessorProfilesLoader.cs
- OrderPreservingSpoolingTask.cs
- TabControlAutomationPeer.cs
- ParallelForEach.cs
- OperationResponse.cs
- RemoteWebConfigurationHost.cs
- EventArgs.cs
- GenericAuthenticationEventArgs.cs
- BinaryKeyIdentifierClause.cs
- SocketInformation.cs
- NotCondition.cs
- URLAttribute.cs
- RadioButtonList.cs
- xml.cs
- WindowsContainer.cs
- _ListenerResponseStream.cs
- ReferencedType.cs
- DirtyTextRange.cs
- PowerModeChangedEventArgs.cs
- WriteableBitmap.cs
- CompositeDuplexElement.cs
- NamedPipeTransportBindingElement.cs
- _SecureChannel.cs
- EllipseGeometry.cs
- CultureTableRecord.cs
- DataTransferEventArgs.cs
- Panel.cs
- SerializationEventsCache.cs
- httpserverutility.cs
- XmlSortKey.cs
- SiteMapDataSourceView.cs
- CallSiteHelpers.cs
- PointCollectionValueSerializer.cs
- DesignerEditorPartChrome.cs
- QueryOperatorEnumerator.cs
- DiscoveryClientElement.cs
- baseshape.cs
- PageSetupDialog.cs
- Exception.cs
- ExceptionHandler.cs
- ImageAutomationPeer.cs
- TextClipboardData.cs
- IndividualDeviceConfig.cs
- DataSourceHelper.cs
- GraphicsState.cs
- XmlDocument.cs
- DrawingCollection.cs
- SamlSecurityTokenAuthenticator.cs
- TextViewSelectionProcessor.cs
- PasswordTextNavigator.cs
- SocketInformation.cs
- MaskDescriptors.cs
- SecurityDescriptor.cs
- AffineTransform3D.cs
- TreeViewCancelEvent.cs
- PersonalizationEntry.cs
- ImpersonationContext.cs
- PageMediaSize.cs
- DetailsView.cs
- FormViewCommandEventArgs.cs
- VectorValueSerializer.cs
- DataSourceCache.cs
- ExtentKey.cs
- SHA1.cs
- DataColumnCollection.cs
- _NegoStream.cs
- QualificationDataAttribute.cs