Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Discovery / ServiceDiscoveryBehavior.cs / 1305376 / ServiceDiscoveryBehavior.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Discovery { using System.Collections.Generic; using System.Collections.ObjectModel; using System.Diagnostics.CodeAnalysis; using System.Runtime; using System.ServiceModel.Channels; using System.ServiceModel.Description; using System.ServiceModel.Dispatcher; [Fx.Tag.XamlVisible(false)] public class ServiceDiscoveryBehavior : IServiceBehavior { NonNullItemCollectionannouncementEndpoints; public ServiceDiscoveryBehavior() { this.announcementEndpoints = new NonNullItemCollection (); } public Collection AnnouncementEndpoints { get { return this.announcementEndpoints; } } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.InterfaceMethodsShouldBeCallableByChildTypes)] void IServiceBehavior.AddBindingParameters(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase, Collection endpoints, BindingParameterCollection bindingParameters) { } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.InterfaceMethodsShouldBeCallableByChildTypes)] void IServiceBehavior.Validate(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase) { if (serviceDescription == null) { throw FxTrace.Exception.ArgumentNull("serviceDescription"); } if (serviceHostBase == null) { throw FxTrace.Exception.ArgumentNull("serviceHostBase"); } List appEndpoints = this.GetApplicationEndpoints(serviceDescription); DiscoveryServiceExtension discoveryServiceExtension = serviceHostBase.Extensions.Find (); if (discoveryServiceExtension == null) { if (serviceDescription.Endpoints.Count > appEndpoints.Count) { discoveryServiceExtension = new DefaultDiscoveryServiceExtension(DiscoveryDefaults.DuplicateMessageHistoryLength); } else { discoveryServiceExtension = new DefaultDiscoveryServiceExtension(0); } serviceHostBase.Extensions.Add(discoveryServiceExtension); } for (int i = 0; i < appEndpoints.Count; i++) { appEndpoints[i].Behaviors.Add( new EndpointDiscoveryMetadataInitializer( discoveryServiceExtension.InternalPublishedEndpoints)); } } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.InterfaceMethodsShouldBeCallableByChildTypes)] void IServiceBehavior.ApplyDispatchBehavior(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase) { if (serviceDescription == null) { throw FxTrace.Exception.ArgumentNull("serviceDescription"); } if (serviceHostBase == null) { throw FxTrace.Exception.ArgumentNull("serviceHostBase"); } DiscoveryServiceExtension discoveryServiceExtension = serviceHostBase.Extensions.Find (); if (discoveryServiceExtension != null) { DiscoveryService discoveryService = discoveryServiceExtension.ValidateAndGetDiscoveryService(); ServiceDiscoveryBehavior.SetDiscoveryImplementation(serviceHostBase, discoveryService); if (this.announcementEndpoints.Count > 0) { serviceHostBase.ChannelDispatchers.Add( new OnlineAnnouncementChannelDispatcher( serviceHostBase, this.announcementEndpoints, discoveryServiceExtension.InternalPublishedEndpoints, discoveryService.MessageSequenceGenerator)); serviceHostBase.ChannelDispatchers.Insert(0, new OfflineAnnouncementChannelDispatcher( serviceHostBase, this.announcementEndpoints, discoveryServiceExtension.InternalPublishedEndpoints, discoveryService.MessageSequenceGenerator)); } } } static void SetDiscoveryImplementation(ServiceHostBase host, DiscoveryService discoveryService) { foreach (ChannelDispatcherBase channelDispatcherBase in host.ChannelDispatchers) { ChannelDispatcher channelDispatcher = channelDispatcherBase as ChannelDispatcher; if (channelDispatcher != null) { foreach (EndpointDispatcher endpointDispatcher in channelDispatcher.Endpoints) { if ((endpointDispatcher != null) && EndpointDiscoveryMetadata.IsDiscoverySystemEndpoint(endpointDispatcher)) { SetDiscoveryImplementation(endpointDispatcher, discoveryService); } } } } } static void SetDiscoveryImplementation(EndpointDispatcher endpointDispatcher, DiscoveryService discoveryService) { DispatchRuntime dispatchRuntime = endpointDispatcher.DispatchRuntime; dispatchRuntime.SynchronizationContext = null; dispatchRuntime.ConcurrencyMode = ConcurrencyMode.Multiple; ServiceDiscoveryInstanceContextProvider provider = new ServiceDiscoveryInstanceContextProvider(discoveryService); dispatchRuntime.InstanceContextProvider = provider; dispatchRuntime.InstanceProvider = provider; dispatchRuntime.Type = discoveryService.GetType(); } List GetApplicationEndpoints(ServiceDescription serviceDescription) { List appEndpoints = new List (serviceDescription.Endpoints.Count); foreach (ServiceEndpoint endpoint in serviceDescription.Endpoints) { if (!EndpointDiscoveryMetadata.IsDiscoverySystemEndpoint(endpoint)) { appEndpoints.Add(endpoint); } } return appEndpoints; } class EndpointDiscoveryMetadataInitializer : IEndpointBehavior { Collection publishedEndpointCollection; internal EndpointDiscoveryMetadataInitializer(Collection publishedEndpointCollection) { this.publishedEndpointCollection = publishedEndpointCollection; } void IEndpointBehavior.AddBindingParameters(ServiceEndpoint endpoint, BindingParameterCollection bindingParameters) { } void IEndpointBehavior.ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime) { } void IEndpointBehavior.ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher) { EndpointDiscoveryMetadata endpointDiscoveryMetadata = EndpointDiscoveryMetadata.FromServiceEndpoint(endpoint, endpointDispatcher); if (endpointDiscoveryMetadata != null) { this.publishedEndpointCollection.Add(endpointDiscoveryMetadata); } } void IEndpointBehavior.Validate(ServiceEndpoint endpoint) { } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- FrameworkElementFactory.cs
- SocketPermission.cs
- DropDownButton.cs
- BaseTemplateBuildProvider.cs
- SqlBulkCopy.cs
- DialogWindow.cs
- XmlILStorageConverter.cs
- Token.cs
- TrustLevelCollection.cs
- Win32PrintDialog.cs
- PrintDocument.cs
- ActivityCodeDomSerializationManager.cs
- BasicDesignerLoader.cs
- SelectionEditingBehavior.cs
- BaseCAMarshaler.cs
- SafeEventLogWriteHandle.cs
- Enum.cs
- SimpleApplicationHost.cs
- Ops.cs
- Imaging.cs
- ContractMethodParameterInfo.cs
- DesignerToolboxInfo.cs
- UIPropertyMetadata.cs
- PtsPage.cs
- ConnectionsZone.cs
- HtmlInputHidden.cs
- LocalizationComments.cs
- MgmtConfigurationRecord.cs
- ToolBar.cs
- WebPartsSection.cs
- AccessControlEntry.cs
- LineInfo.cs
- GenerateTemporaryTargetAssembly.cs
- OperationAbortedException.cs
- Pen.cs
- ASCIIEncoding.cs
- TraceSection.cs
- ConnectionStringSettingsCollection.cs
- DebuggerAttributes.cs
- TextParaLineResult.cs
- DataServiceResponse.cs
- Hyperlink.cs
- VersionPair.cs
- ImageMetadata.cs
- ResourceCodeDomSerializer.cs
- Nodes.cs
- milexports.cs
- FormClosingEvent.cs
- X509Chain.cs
- OneWayBindingElement.cs
- KeyProperty.cs
- ConnectionConsumerAttribute.cs
- SelectManyQueryOperator.cs
- SafeLocalMemHandle.cs
- ProcessThreadCollection.cs
- TemplateModeChangedEventArgs.cs
- FontSizeConverter.cs
- TextReader.cs
- DataGridViewCheckBoxColumn.cs
- CultureInfoConverter.cs
- StackOverflowException.cs
- X509ClientCertificateAuthentication.cs
- KeyValueConfigurationCollection.cs
- FormsAuthenticationModule.cs
- SqlCrossApplyToCrossJoin.cs
- PathNode.cs
- SQLResource.cs
- TemplatedWizardStep.cs
- IntermediatePolicyValidator.cs
- HttpBrowserCapabilitiesWrapper.cs
- EncryptedPackage.cs
- DataPagerField.cs
- TdsRecordBufferSetter.cs
- controlskin.cs
- ClaimTypeElementCollection.cs
- ChainedAsyncResult.cs
- ScriptResourceHandler.cs
- UnmanagedMemoryStreamWrapper.cs
- Documentation.cs
- KeyedCollection.cs
- AnchoredBlock.cs
- InternalsVisibleToAttribute.cs
- AggregateException.cs
- ToolStripMenuItemCodeDomSerializer.cs
- ApplyTemplatesAction.cs
- FileUtil.cs
- SmiConnection.cs
- DiscoveryServiceExtension.cs
- DrawingGroup.cs
- SHA1.cs
- ObjectKeyFrameCollection.cs
- GroupDescription.cs
- VersionPair.cs
- PageBuildProvider.cs
- StorageComplexTypeMapping.cs
- XPathConvert.cs
- ResourceFallbackManager.cs
- NamedPermissionSet.cs
- UseManagedPresentationElement.cs
- PriorityQueue.cs