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
- ToolStripItemClickedEventArgs.cs
- ExtenderControl.cs
- MembershipPasswordException.cs
- ToolStripButton.cs
- ChangeDirector.cs
- TableNameAttribute.cs
- WebPartConnectionsEventArgs.cs
- SqlReferenceCollection.cs
- SystemIPGlobalProperties.cs
- HttpCapabilitiesSectionHandler.cs
- XmlCDATASection.cs
- HttpListenerRequestUriBuilder.cs
- EventMemberCodeDomSerializer.cs
- AQNBuilder.cs
- MobileListItem.cs
- SystemFonts.cs
- MemberPath.cs
- RawMouseInputReport.cs
- ApplicationManager.cs
- DataColumnMappingCollection.cs
- HttpHandlersSection.cs
- ContractListAdapter.cs
- UnmanagedMemoryStreamWrapper.cs
- BrowserCapabilitiesFactory.cs
- XMLSchema.cs
- XmlIgnoreAttribute.cs
- HttpCacheParams.cs
- CodeDefaultValueExpression.cs
- OleDbParameterCollection.cs
- MaskedTextProvider.cs
- IChannel.cs
- MasterPageParser.cs
- _CommandStream.cs
- NegotiationTokenAuthenticatorState.cs
- MasterPageParser.cs
- WhereQueryOperator.cs
- PasswordValidationException.cs
- Assert.cs
- ReflectEventDescriptor.cs
- DtdParser.cs
- XsdDataContractImporter.cs
- DataTableTypeConverter.cs
- MemberJoinTreeNode.cs
- EncoderExceptionFallback.cs
- HtmlTableCellCollection.cs
- XPathDocument.cs
- EventManager.cs
- Line.cs
- TreeView.cs
- TextTreeInsertElementUndoUnit.cs
- DbParameterCollectionHelper.cs
- Page.cs
- DeclaredTypeValidatorAttribute.cs
- XdrBuilder.cs
- AlphaSortedEnumConverter.cs
- CopyOfAction.cs
- ToolStripLabel.cs
- ObjectAssociationEndMapping.cs
- MailMessageEventArgs.cs
- ControlPropertyNameConverter.cs
- DesignTimeParseData.cs
- SQLMoney.cs
- XmlEncoding.cs
- XsltCompileContext.cs
- TreeNodeCollection.cs
- WebPartConnectionsEventArgs.cs
- AsymmetricAlgorithm.cs
- EventNotify.cs
- _BufferOffsetSize.cs
- TypeToken.cs
- MultiBindingExpression.cs
- InstanceValue.cs
- Renderer.cs
- _NativeSSPI.cs
- Privilege.cs
- Aes.cs
- ToolStripItemEventArgs.cs
- BufferedWebEventProvider.cs
- ConnectionInterfaceCollection.cs
- SvcFileManager.cs
- GroupQuery.cs
- XmlDataSourceDesigner.cs
- KnownColorTable.cs
- ConstraintConverter.cs
- TabControl.cs
- MasterPageBuildProvider.cs
- HttpApplicationStateBase.cs
- Int32Converter.cs
- HtmlHistory.cs
- HtmlElement.cs
- XmlSerializationReader.cs
- TextDecorationCollection.cs
- DbRetry.cs
- BamlRecordHelper.cs
- OutputCacheModule.cs
- UInt16Storage.cs
- DoubleLinkList.cs
- ParserContext.cs
- BulletDecorator.cs
- UIInitializationException.cs