Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Channels / DuplicateMessageDetector.cs / 1305376 / DuplicateMessageDetector.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.Runtime; using System.Security.Cryptography; using System.ServiceModel.Discovery; sealed class DuplicateMessageDetector : IDisposable { HashAlgorithm hashAlgorithm; [Fx.Tag.Cache(typeof(string), Fx.Tag.CacheAttrition.PartialPurgeOnEachAccess, SizeLimit = "maxListLength parameter to constructor")] DuplicateDetectorduplicateDetector; [Fx.Tag.SynchronizationObject()] object thisLock; bool disposed; public DuplicateMessageDetector(int maxListLength) { Fx.Assert(maxListLength > 0, "maxListLength must be > 0"); this.disposed = false; this.hashAlgorithm = HashAlgorithm.Create(); this.thisLock = new object(); this.duplicateDetector = new DuplicateDetector (maxListLength); } public bool IsDuplicate(ArraySegment msgBytes, out string hashString) { Fx.Assert(msgBytes != null, "messageBytes can't be null"); Fx.Assert(msgBytes.Count > 0, "messageBytes.Count must be > 0"); byte[] hash; bool notDuplicate = true; lock (this.thisLock) { if (disposed) { throw FxTrace.Exception.AsError(new ObjectDisposedException(this.GetType().ToString())); } hash = this.hashAlgorithm.ComputeHash(msgBytes.Array, msgBytes.Offset, msgBytes.Count); } hashString = Convert.ToBase64String(hash); Fx.Assert(string.IsNullOrEmpty(hashString) == false, "computed hashstring is null or empty"); lock (this.thisLock) { //the act of retreiving an existing item pushes it to the front of the MRU list, ensuring //that the oldest hashes are trimmed first when we hit the max length. notDuplicate = this.duplicateDetector.AddIfNotDuplicate(hashString); } return !notDuplicate; } public void RemoveEntry(string msgHash) { Fx.Assert(!string.IsNullOrEmpty(msgHash), "Message hash should never be null or empty"); lock (this.thisLock) { if (this.disposed) { throw FxTrace.Exception.AsError(new ObjectDisposedException(this.GetType().ToString())); } this.duplicateDetector.Remove(msgHash); } } public void Dispose() { if (this.disposed) { return; } lock (this.thisLock) { if (!this.disposed) { this.disposed = true; if (this.duplicateDetector != null) { this.duplicateDetector.Clear(); } this.hashAlgorithm.Clear(); this.hashAlgorithm = null; } } } } } // 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
- Point3DAnimationUsingKeyFrames.cs
- TaskFileService.cs
- MenuCommand.cs
- OutputScope.cs
- SrgsItemList.cs
- RoutedEventConverter.cs
- SqlHelper.cs
- EventToken.cs
- errorpatternmatcher.cs
- PageParserFilter.cs
- Win32MouseDevice.cs
- ServiceOperation.cs
- SoapSchemaExporter.cs
- DescendentsWalkerBase.cs
- SqlWebEventProvider.cs
- DiagnosticsConfiguration.cs
- ParallelRangeManager.cs
- SafeFileMapViewHandle.cs
- XMLUtil.cs
- _SafeNetHandles.cs
- basecomparevalidator.cs
- HttpModulesSection.cs
- util.cs
- XPathAncestorIterator.cs
- DrawingImage.cs
- cache.cs
- OleDbRowUpdatingEvent.cs
- PerformanceCounterPermissionEntry.cs
- CommonGetThemePartSize.cs
- _OSSOCK.cs
- Choices.cs
- _ConnectionGroup.cs
- JapaneseCalendar.cs
- AssignDesigner.xaml.cs
- Cursor.cs
- Bind.cs
- StylusPointPropertyUnit.cs
- SoapFormatExtensions.cs
- RoutedEventConverter.cs
- MultiAsyncResult.cs
- Win32SafeHandles.cs
- DbBuffer.cs
- DbParameterCollection.cs
- WebPartManagerInternals.cs
- TextEditorCharacters.cs
- IndexOutOfRangeException.cs
- xml.cs
- AppDomainGrammarProxy.cs
- HTTPRemotingHandler.cs
- MarkupCompiler.cs
- XmlSchemaSet.cs
- SqlTypesSchemaImporter.cs
- DataGridCellInfo.cs
- ScrollPatternIdentifiers.cs
- SqlLiftIndependentRowExpressions.cs
- DoWorkEventArgs.cs
- WindowsStreamSecurityElement.cs
- DataGridAddNewRow.cs
- WorkflowRuntimeServiceElement.cs
- codemethodreferenceexpression.cs
- InheritanceUI.cs
- ToolStripDesigner.cs
- Thickness.cs
- OrCondition.cs
- SurrogateEncoder.cs
- PerspectiveCamera.cs
- DataGridViewControlCollection.cs
- XsdDataContractImporter.cs
- DispatchRuntime.cs
- Frame.cs
- DataSourceConverter.cs
- CodeTypeOfExpression.cs
- CompilerTypeWithParams.cs
- Int64KeyFrameCollection.cs
- ExpressionParser.cs
- SourceFileBuildProvider.cs
- SimpleHandlerFactory.cs
- xamlnodes.cs
- OperandQuery.cs
- DataGridViewSelectedCellsAccessibleObject.cs
- PropertyKey.cs
- ChannelToken.cs
- ContentPosition.cs
- WmpBitmapEncoder.cs
- EventDescriptor.cs
- ContentPosition.cs
- XhtmlBasicFormAdapter.cs
- SecurityTokenTypes.cs
- SafeFileMapViewHandle.cs
- SortDescriptionCollection.cs
- WorkflowApplicationUnhandledExceptionEventArgs.cs
- ReadOnlyCollectionBase.cs
- UInt32.cs
- SiteMapDataSourceView.cs
- WebPartDisplayMode.cs
- X509ChainPolicy.cs
- ServiceDefaults.cs
- Positioning.cs
- RuntimeEnvironment.cs
- __Error.cs