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
- EventManager.cs
- DataGridCell.cs
- MetabaseServerConfig.cs
- OverrideMode.cs
- InstanceCompleteException.cs
- SessionEndingEventArgs.cs
- CustomErrorsSection.cs
- SmtpMail.cs
- DataPagerField.cs
- ToolStripGrip.cs
- PersistenceException.cs
- NotImplementedException.cs
- XamlReaderConstants.cs
- PolyLineSegment.cs
- ServiceOperation.cs
- AffineTransform3D.cs
- PropertyConverter.cs
- WorkflowViewStateService.cs
- SplayTreeNode.cs
- _Rfc2616CacheValidators.cs
- SR.cs
- Token.cs
- PersonalizationStateInfo.cs
- AffineTransform3D.cs
- MDIControlStrip.cs
- XPathEmptyIterator.cs
- HwndHost.cs
- Int32.cs
- LineSegment.cs
- OdbcRowUpdatingEvent.cs
- DescendantQuery.cs
- Point3DCollection.cs
- TextEditor.cs
- PointAnimationClockResource.cs
- BitmapEffectInput.cs
- BoundColumn.cs
- TypeValidationEventArgs.cs
- HttpProfileBase.cs
- ComponentGlyph.cs
- _AutoWebProxyScriptHelper.cs
- CustomAttributeBuilder.cs
- SettingsPropertyValue.cs
- WebConfigManager.cs
- TargetInvocationException.cs
- SoapCodeExporter.cs
- TextPointerBase.cs
- ActivitiesCollection.cs
- StylusPointProperty.cs
- ServicePointManager.cs
- CallbackHandler.cs
- Crc32.cs
- AssertHelper.cs
- GeneralTransform3DTo2D.cs
- IntegerFacetDescriptionElement.cs
- StringExpressionSet.cs
- CommonXSendMessage.cs
- PathParser.cs
- HandleCollector.cs
- VectorKeyFrameCollection.cs
- HyperlinkAutomationPeer.cs
- ReceiveContextCollection.cs
- TextRangeEdit.cs
- CachedFontFace.cs
- BufferedStream.cs
- ReadOnlyNameValueCollection.cs
- FusionWrap.cs
- HttpsHostedTransportConfiguration.cs
- BitmapEffectOutputConnector.cs
- VerificationException.cs
- WmiEventSink.cs
- RNGCryptoServiceProvider.cs
- _LoggingObject.cs
- ValidationPropertyAttribute.cs
- SafeNativeMethods.cs
- DictionarySectionHandler.cs
- TdsParameterSetter.cs
- XmlnsDictionary.cs
- AbandonedMutexException.cs
- RegistryExceptionHelper.cs
- QilIterator.cs
- FieldMetadata.cs
- InvalidMessageContractException.cs
- EntryIndex.cs
- Attributes.cs
- FileChangesMonitor.cs
- NativeMethods.cs
- PeerNameResolver.cs
- VariableQuery.cs
- Tablet.cs
- ValueTypeFixupInfo.cs
- ToolStripMenuItemDesigner.cs
- RelationshipType.cs
- TokenBasedSet.cs
- ApplicationInterop.cs
- PersistencePipeline.cs
- CoreSwitches.cs
- prompt.cs
- TreeView.cs
- TogglePattern.cs
- CountAggregationOperator.cs