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
- OleDbReferenceCollection.cs
- IdentityModelStringsVersion1.cs
- CodeNamespaceImportCollection.cs
- GeneralTransform.cs
- IPAddress.cs
- RelationshipSet.cs
- ClientFormsAuthenticationCredentials.cs
- ToolboxItemWrapper.cs
- DbDataSourceEnumerator.cs
- TextBox.cs
- Vector3DValueSerializer.cs
- ButtonColumn.cs
- ToolBarButtonClickEvent.cs
- ToolStripMenuItemDesigner.cs
- TypeLoadException.cs
- Int16Animation.cs
- TemplateParser.cs
- IncomingWebResponseContext.cs
- EntityDataSourceView.cs
- TypeConverter.cs
- RoutedPropertyChangedEventArgs.cs
- OutputCacheProfile.cs
- ListViewGroupConverter.cs
- SHA1.cs
- Pool.cs
- ByteStreamGeometryContext.cs
- UserControlCodeDomTreeGenerator.cs
- SortedSet.cs
- RectangleHotSpot.cs
- TimeoutHelper.cs
- IntSecurity.cs
- HtmlWindow.cs
- DataGridViewIntLinkedList.cs
- PointCollectionConverter.cs
- OSFeature.cs
- DeleteStoreRequest.cs
- NumberFunctions.cs
- InternalDispatchObject.cs
- CompiledRegexRunnerFactory.cs
- CryptoApi.cs
- EventLogInformation.cs
- CustomAttribute.cs
- CqlIdentifiers.cs
- Unit.cs
- WebBrowserHelper.cs
- ReflectionUtil.cs
- SQLInt16Storage.cs
- SoapAttributes.cs
- XmlSchemaSimpleType.cs
- ContextBase.cs
- AssemblyUtil.cs
- _IPv4Address.cs
- UIntPtr.cs
- NumericUpDownAcceleration.cs
- AppSettingsSection.cs
- ColumnProvider.cs
- EntityTransaction.cs
- MarkupWriter.cs
- ObjectAnimationUsingKeyFrames.cs
- ArrayWithOffset.cs
- ObjectContextServiceProvider.cs
- GraphicsContainer.cs
- wgx_render.cs
- HostingMessageProperty.cs
- LinqDataSourceStatusEventArgs.cs
- InvokeWebServiceDesigner.cs
- InputChannelBinder.cs
- IntegerValidator.cs
- ToolTipService.cs
- Formatter.cs
- ValueExpressions.cs
- DataGridDefaultColumnWidthTypeConverter.cs
- ImportDesigner.xaml.cs
- _NegoState.cs
- FloatUtil.cs
- ApplicationServicesHostFactory.cs
- OperatingSystemVersionCheck.cs
- TreeNodeCollection.cs
- SocketInformation.cs
- FontEmbeddingManager.cs
- Int16Converter.cs
- Slider.cs
- InvalidProgramException.cs
- ColumnMap.cs
- SerTrace.cs
- diagnosticsswitches.cs
- LineMetrics.cs
- TypeFieldSchema.cs
- TdsParserSessionPool.cs
- QueueProcessor.cs
- ToolStripPanelRenderEventArgs.cs
- UnsafeCollabNativeMethods.cs
- TypeConverterValueSerializer.cs
- SendActivityValidator.cs
- Module.cs
- WebPartsSection.cs
- ClientBuildManager.cs
- RuleEngine.cs
- WindowsGraphicsCacheManager.cs
- GeometryCombineModeValidation.cs