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
- ProtocolsConfigurationEntry.cs
- DataGridViewCellMouseEventArgs.cs
- TypefaceMap.cs
- ConnectionManagementElementCollection.cs
- ActiveDocumentEvent.cs
- TabRenderer.cs
- SchemaComplexType.cs
- ContentControl.cs
- IDispatchConstantAttribute.cs
- DataGridItemCollection.cs
- RegexWriter.cs
- Memoizer.cs
- XamlTypeMapper.cs
- ThreadStaticAttribute.cs
- AuthenticationServiceManager.cs
- XmlWrappingReader.cs
- PropertyValueUIItem.cs
- ChooseAction.cs
- SortQuery.cs
- QilDataSource.cs
- RequestBringIntoViewEventArgs.cs
- MdiWindowListStrip.cs
- Utils.cs
- Binding.cs
- LoginCancelEventArgs.cs
- FileSystemWatcher.cs
- Types.cs
- FamilyMap.cs
- ZipIOExtraFieldZip64Element.cs
- Repeater.cs
- ZoneMembershipCondition.cs
- Comparer.cs
- DataStorage.cs
- SplashScreen.cs
- GradientBrush.cs
- ComboBoxRenderer.cs
- XmlNodeChangedEventManager.cs
- isolationinterop.cs
- ManagementNamedValueCollection.cs
- ServiceProviders.cs
- PointHitTestParameters.cs
- FtpWebRequest.cs
- SizeConverter.cs
- oledbmetadatacollectionnames.cs
- ItemMap.cs
- SizeIndependentAnimationStorage.cs
- UnsafePeerToPeerMethods.cs
- HttpFileCollection.cs
- RegexCharClass.cs
- Cursor.cs
- Simplifier.cs
- IconConverter.cs
- Publisher.cs
- CompositeDesignerAccessibleObject.cs
- BitmapEffectOutputConnector.cs
- SecurityContextKeyIdentifierClause.cs
- MessageHeaderException.cs
- TextFragmentEngine.cs
- StylusOverProperty.cs
- Calendar.cs
- WebPartsPersonalization.cs
- PipelineModuleStepContainer.cs
- dataobject.cs
- HttpWrapper.cs
- CombinedGeometry.cs
- SqlTriggerContext.cs
- List.cs
- EmptyEnumerator.cs
- OracleConnectionStringBuilder.cs
- ClientSettings.cs
- StringDictionary.cs
- SQLDecimal.cs
- ByteStack.cs
- IgnoreFlushAndCloseStream.cs
- Queue.cs
- ConfigXmlText.cs
- EntityKeyElement.cs
- UrlMapping.cs
- HostSecurityManager.cs
- StorageEntityContainerMapping.cs
- FileDataSourceCache.cs
- BindableTemplateBuilder.cs
- ProxyAttribute.cs
- DoubleAnimationClockResource.cs
- LocationSectionRecord.cs
- RegexInterpreter.cs
- PhotoPrintingIntent.cs
- PointAnimationUsingPath.cs
- SessionIDManager.cs
- WebContext.cs
- ObjectViewEntityCollectionData.cs
- StickyNoteHelper.cs
- QueryableDataSourceHelper.cs
- HeaderFilter.cs
- StateBag.cs
- EdmToObjectNamespaceMap.cs
- NameValueCollection.cs
- CSharpCodeProvider.cs
- BaseDataListDesigner.cs
- _UncName.cs