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
- SelectionProcessor.cs
- TableLayoutPanel.cs
- StateMachineTimers.cs
- HttpServerUtilityWrapper.cs
- ErrorWrapper.cs
- SqlVersion.cs
- JoinGraph.cs
- OleDbConnectionPoolGroupProviderInfo.cs
- BehaviorEditorPart.cs
- XmlArrayItemAttributes.cs
- Vector3DConverter.cs
- xmlfixedPageInfo.cs
- WorkflowTraceTransfer.cs
- SubtreeProcessor.cs
- PaginationProgressEventArgs.cs
- CompilerInfo.cs
- MessageDispatch.cs
- Menu.cs
- ExtentKey.cs
- ListenerAdaptersInstallComponent.cs
- CategoryNameCollection.cs
- ProtocolsSection.cs
- OleDbRowUpdatingEvent.cs
- RelationshipEndCollection.cs
- ServiceModelEnumValidator.cs
- UmAlQuraCalendar.cs
- WebPartTracker.cs
- CompositeScriptReference.cs
- HighlightVisual.cs
- EntityDataSourceColumn.cs
- MouseCaptureWithinProperty.cs
- PopupEventArgs.cs
- Model3DGroup.cs
- TagPrefixCollection.cs
- _SSPIWrapper.cs
- PartialCachingAttribute.cs
- StylusPointPropertyId.cs
- RectangleGeometry.cs
- EnumerableCollectionView.cs
- EmptyElement.cs
- WebScriptMetadataInstanceContextProvider.cs
- VirtualDirectoryMappingCollection.cs
- BamlTreeMap.cs
- WebBrowserContainer.cs
- SchemaCollectionPreprocessor.cs
- PropertyFilterAttribute.cs
- EventRouteFactory.cs
- CodeDirectoryCompiler.cs
- MenuItem.cs
- SafeBitVector32.cs
- VirtualPathProvider.cs
- DnsPermission.cs
- ExpressionBuilderContext.cs
- HttpModulesSection.cs
- WebPartMinimizeVerb.cs
- ToolBarButtonClickEvent.cs
- ColorConvertedBitmap.cs
- RemotingServices.cs
- DataGridViewRowPostPaintEventArgs.cs
- SpanIndex.cs
- TreeNodeEventArgs.cs
- LinqTreeNodeEvaluator.cs
- MediaEntryAttribute.cs
- FileVersion.cs
- FreezableCollection.cs
- TextBox.cs
- ApplicationBuildProvider.cs
- Range.cs
- TreeSet.cs
- GZipStream.cs
- DelegateTypeInfo.cs
- SafeSecurityHelper.cs
- ArgumentException.cs
- TemplateField.cs
- ListenerTraceUtility.cs
- CollectionViewGroup.cs
- BrowserTree.cs
- WebEventCodes.cs
- _Semaphore.cs
- ReachUIElementCollectionSerializer.cs
- WindowsGraphics2.cs
- Thickness.cs
- ContentPresenter.cs
- UserControl.cs
- Quad.cs
- SystemThemeKey.cs
- RegexFCD.cs
- RemoveStoryboard.cs
- HostingEnvironment.cs
- StringWriter.cs
- RouteParser.cs
- HttpResponseInternalBase.cs
- PointAnimation.cs
- StickyNoteContentControl.cs
- Schedule.cs
- FloaterParaClient.cs
- Parallel.cs
- MailMessage.cs
- RadioButtonStandardAdapter.cs
- DictionaryKeyPropertyAttribute.cs