Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Dispatcher / EndpointDispatcherTable.cs / 1 / EndpointDispatcherTable.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Dispatcher { using System.ServiceModel; using System.ServiceModel.Channels; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Diagnostics; using System.ServiceModel.Diagnostics; using System.Threading; class EndpointDispatcherTable { MessageFilterTablefilters; object thisLock; const int optimizationThreshold = 2; List cachedEndpoints; public EndpointDispatcherTable(object thisLock) { this.thisLock = thisLock; } public int Count { get { return ((this.cachedEndpoints != null) ? cachedEndpoints.Count : 0) + ((this.filters != null) ? this.filters.Count : 0); } } object ThisLock { get { return thisLock; } } public void AddEndpoint(EndpointDispatcher endpoint) { lock (ThisLock) { MessageFilter filter = endpoint.EndpointFilter; int priority = endpoint.FilterPriority; if (filters == null) { if (this.cachedEndpoints == null) { this.cachedEndpoints = new List (optimizationThreshold); } if (this.cachedEndpoints.Count < optimizationThreshold) { this.cachedEndpoints.Add(endpoint); } else { filters = new MessageFilterTable (); for (int i = 0; i < this.cachedEndpoints.Count; i++) { int cachedPriority = cachedEndpoints[i].FilterPriority; MessageFilter cachedFilter = cachedEndpoints[i].EndpointFilter; filters.Add(cachedFilter, cachedEndpoints[i], cachedPriority); } filters.Add(filter, endpoint, priority); this.cachedEndpoints = null; } } else { filters.Add(filter, endpoint, priority); } } } public void RemoveEndpoint(EndpointDispatcher endpoint) { lock (ThisLock) { if (filters == null) { if (cachedEndpoints != null && cachedEndpoints.Contains(endpoint)) { cachedEndpoints.Remove(endpoint); } } else { MessageFilter filter = endpoint.EndpointFilter; filters.Remove(filter); } } } EndpointDispatcher LookupInCache(Message message, out bool addressMatched) { EndpointDispatcher result = null; int priority = int.MinValue; bool duplicatePriority = false; addressMatched = false; if (this.cachedEndpoints != null && this.cachedEndpoints.Count > 0) { for (int i = 0; i < this.cachedEndpoints.Count; i++) { EndpointDispatcher cachedEndpoint = cachedEndpoints[i]; int cachedPriority = cachedEndpoint.FilterPriority; MessageFilter cachedFilter = cachedEndpoint.EndpointFilter; bool matchResult; AndMessageFilter andFilter = cachedFilter as AndMessageFilter; if (andFilter != null) { bool addressResult; matchResult = andFilter.Match(message, out addressResult); addressMatched |= addressResult; } else { matchResult = cachedFilter.Match(message); } if (matchResult) { addressMatched = true; if (cachedPriority > priority || result == null) { result = cachedEndpoint; priority = cachedPriority; duplicatePriority = false; } else if (cachedPriority == priority && result != null) { duplicatePriority = true; } } } } if (duplicatePriority) { throw TraceUtility.ThrowHelperError(new MultipleFilterMatchesException(SR.GetString(SR.FilterMultipleMatches)), message); } return result; } public EndpointDispatcher Lookup(Message message, out bool addressMatched) { EndpointDispatcher data = null; data = LookupInCache(message, out addressMatched); if (data == null) { lock (ThisLock) { data = LookupInCache(message, out addressMatched); if (data == null && filters != null) { filters.GetMatchingValue(message, out data, out addressMatched); } } } return data; } } } // 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
- MenuItemBinding.cs
- ServiceModelConfiguration.cs
- MasterPageBuildProvider.cs
- StylusDevice.cs
- GroupBoxRenderer.cs
- SessionStateSection.cs
- ImageField.cs
- XmlValidatingReader.cs
- _TransmitFileOverlappedAsyncResult.cs
- PrimitiveList.cs
- DataBoundControl.cs
- ExpressionBuilder.cs
- PropertyReference.cs
- ToolBarButtonClickEvent.cs
- ReadOnlyTernaryTree.cs
- RuntimeArgumentHandle.cs
- DecimalKeyFrameCollection.cs
- MouseWheelEventArgs.cs
- SrgsText.cs
- OLEDB_Util.cs
- Header.cs
- UIPropertyMetadata.cs
- ExternalFile.cs
- TextBoxDesigner.cs
- TextDecoration.cs
- InstanceContextManager.cs
- ReadOnlyNameValueCollection.cs
- SpeechSynthesizer.cs
- MatrixValueSerializer.cs
- FocusChangedEventArgs.cs
- NotifyParentPropertyAttribute.cs
- TypeBuilder.cs
- DataSetMappper.cs
- PointConverter.cs
- MissingFieldException.cs
- QueryStack.cs
- PopupRootAutomationPeer.cs
- FtpWebResponse.cs
- DataSourceComponent.cs
- PhonemeConverter.cs
- AssemblySettingAttributes.cs
- InstanceNotReadyException.cs
- PropertyInformationCollection.cs
- UserPersonalizationStateInfo.cs
- StronglyTypedResourceBuilder.cs
- CLSCompliantAttribute.cs
- TextElementEditingBehaviorAttribute.cs
- MsmqInputChannelListenerBase.cs
- PathSegmentCollection.cs
- ElementInit.cs
- SplineKeyFrames.cs
- PersistenceTypeAttribute.cs
- SecurityTokenTypes.cs
- MimeMapping.cs
- NotFiniteNumberException.cs
- SmiEventSink_Default.cs
- DataServiceConfiguration.cs
- CqlLexer.cs
- xdrvalidator.cs
- CodeMemberMethod.cs
- WS2007FederationHttpBindingCollectionElement.cs
- PkcsMisc.cs
- ValidationErrorCollection.cs
- UiaCoreTypesApi.cs
- SoapMessage.cs
- WizardPanel.cs
- NestedContainer.cs
- CodeIdentifier.cs
- ContextProperty.cs
- SimpleNameService.cs
- CanonicalXml.cs
- ControlPropertyNameConverter.cs
- UnsafeMethods.cs
- TableLayoutSettingsTypeConverter.cs
- _ScatterGatherBuffers.cs
- DataGridViewHeaderCell.cs
- DataDocumentXPathNavigator.cs
- LinqDataSource.cs
- BrowserCapabilitiesFactoryBase.cs
- DynamicResourceExtensionConverter.cs
- TypeGeneratedEventArgs.cs
- SafeBitVector32.cs
- SourceInterpreter.cs
- EncryptedReference.cs
- ConfigXmlAttribute.cs
- DecimalMinMaxAggregationOperator.cs
- Buffer.cs
- XmlObjectSerializer.cs
- DependentList.cs
- Matrix3DStack.cs
- RulePatternOps.cs
- OptimalBreakSession.cs
- CubicEase.cs
- Cast.cs
- TranslateTransform3D.cs
- ResolvedKeyFrameEntry.cs
- SafeSystemMetrics.cs
- XamlReader.cs
- Assert.cs
- OdbcParameterCollection.cs