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
- Constants.cs
- DataGridViewDataErrorEventArgs.cs
- Accessible.cs
- PersistencePipeline.cs
- AsymmetricSignatureFormatter.cs
- HtmlControlPersistable.cs
- TextChangedEventArgs.cs
- DragDeltaEventArgs.cs
- cookieexception.cs
- ISCIIEncoding.cs
- XmlComment.cs
- XmlLanguage.cs
- XmlHierarchyData.cs
- PasswordRecovery.cs
- AuthStoreRoleProvider.cs
- CatalogPart.cs
- EventHandlers.cs
- CatalogPartDesigner.cs
- EventLogEntry.cs
- FlowDocumentReader.cs
- Pointer.cs
- FormattedText.cs
- Socket.cs
- WebPartPersonalization.cs
- WorkflowMessageEventArgs.cs
- StylusSystemGestureEventArgs.cs
- Registry.cs
- ChangesetResponse.cs
- CompilerInfo.cs
- FlowDocumentPage.cs
- ConnectionStringSettingsCollection.cs
- FilteredDataSetHelper.cs
- MiniConstructorInfo.cs
- WebScriptMetadataFormatter.cs
- DynamicFilter.cs
- AnimationException.cs
- IssuanceLicense.cs
- _PooledStream.cs
- XmlDataDocument.cs
- SqlInternalConnection.cs
- EntityDataSourceWrapperPropertyDescriptor.cs
- ContentTypeSettingDispatchMessageFormatter.cs
- UnsafeNativeMethods.cs
- TrackingProfile.cs
- TerminatorSinks.cs
- DesignerValidationSummaryAdapter.cs
- WbmpConverter.cs
- Atom10FormatterFactory.cs
- Function.cs
- WebScriptEnablingBehavior.cs
- DiffuseMaterial.cs
- BinaryFormatterWriter.cs
- InputScopeManager.cs
- TableRowGroupCollection.cs
- DataRowChangeEvent.cs
- FileAuthorizationModule.cs
- ByteFacetDescriptionElement.cs
- ElementNotAvailableException.cs
- HtmlTable.cs
- RegionIterator.cs
- StrokeNode.cs
- EntitySqlQueryCacheEntry.cs
- HttpPostClientProtocol.cs
- SapiAttributeParser.cs
- Control.cs
- XmlSchemaType.cs
- ViewStateModeByIdAttribute.cs
- RegularExpressionValidator.cs
- AuthorizationPolicyTypeElementCollection.cs
- FixedSOMFixedBlock.cs
- ReaderWriterLockSlim.cs
- JoinGraph.cs
- TrustLevel.cs
- StringValidatorAttribute.cs
- TypeDescriptorContext.cs
- RankException.cs
- ToolStripLabel.cs
- DataSysAttribute.cs
- XmlSerializerVersionAttribute.cs
- PrivilegeNotHeldException.cs
- DSASignatureFormatter.cs
- LogStore.cs
- RuntimeHandles.cs
- CodeExpressionStatement.cs
- DataGridViewRow.cs
- ObjectDataSourceSelectingEventArgs.cs
- ServiceHttpModule.cs
- DSASignatureFormatter.cs
- OptionUsage.cs
- Context.cs
- controlskin.cs
- WorkflowApplicationIdleEventArgs.cs
- SingleSelectRootGridEntry.cs
- HwndHost.cs
- CustomAttributeFormatException.cs
- ImpersonationContext.cs
- BindableAttribute.cs
- DockingAttribute.cs
- ErrorTolerantObjectWriter.cs
- TextEffect.cs