Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Discovery / ProbeRequestResponseAsyncResult.cs / 1305376 / ProbeRequestResponseAsyncResult.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Discovery { using System.Collections.ObjectModel; using System.Diagnostics.CodeAnalysis; using System.Runtime; abstract class ProbeRequestResponseAsyncResult: AsyncResult { readonly IDiscoveryServiceImplementation discoveryServiceImpl; readonly FindRequestResponseContext findRequest; readonly DiscoveryOperationContext context; static AsyncCompletion onOnFindCompletedCallback = new AsyncCompletion(OnOnFindCompleted); bool isFindCompleted; [Fx.Tag.SynchronizationObject] object findCompletedLock; [SuppressMessage("Microsoft.Usage", "CA2214:DoNotCallOverridableMethodsInConstructors")] protected ProbeRequestResponseAsyncResult( TProbeMessage probeMessage, IDiscoveryServiceImplementation discoveryServiceImpl, AsyncCallback callback, object state) : base(callback, state) { Fx.Assert(probeMessage != null, "The probeMessage must be non null."); Fx.Assert(discoveryServiceImpl != null, "The discoveryServiceImpl must be non null."); this.discoveryServiceImpl = discoveryServiceImpl; this.findCompletedLock = new object(); if (!this.Validate(probeMessage)) { this.Complete(true); return; } else { this.context = new DiscoveryOperationContext(OperationContext.Current); this.findRequest = new FindRequestResponseContext(this.GetFindCriteria(probeMessage), this); if (this.ProcessFindRequest()) { this.Complete(true); return; } } } protected virtual bool Validate(TProbeMessage probeMessage) { return (DiscoveryService.EnsureMessageId() && this.ValidateContent(probeMessage) && this.EnsureNotDuplicate()); } protected abstract bool ValidateContent(TProbeMessage probeMessage); protected abstract FindCriteria GetFindCriteria(TProbeMessage probeMessage); protected abstract TResponseMessage GetProbeResponse( DiscoveryMessageSequence discoveryMessageSequence, Collection matchingEndpoints); protected TResponseMessage End() { this.context.AddressRequestResponseMessage(OperationContext.Current); return this.GetProbeResponse( this.discoveryServiceImpl.GetNextMessageSequence(), this.findRequest.MatchingEndpoints); } static bool OnOnFindCompleted(IAsyncResult result) { ProbeRequestResponseAsyncResult thisPtr = (ProbeRequestResponseAsyncResult )result.AsyncState; lock (thisPtr.findCompletedLock) { thisPtr.isFindCompleted = true; } thisPtr.discoveryServiceImpl.EndFind(result); return true; } bool ProcessFindRequest() { IAsyncResult result = this.discoveryServiceImpl.BeginFind( this.findRequest, this.PrepareAsyncCompletion(onOnFindCompletedCallback), this); return (result.CompletedSynchronously && OnOnFindCompleted(result)); } bool EnsureNotDuplicate() { bool isDuplicate = this.discoveryServiceImpl.IsDuplicate(OperationContext.Current.IncomingMessageHeaders.MessageId); if (isDuplicate && TD.DuplicateDiscoveryMessageIsEnabled()) { TD.DuplicateDiscoveryMessage( ProtocolStrings.TracingStrings.Probe, OperationContext.Current.IncomingMessageHeaders.MessageId.ToString()); } return !isDuplicate; } class FindRequestResponseContext : FindRequestContext { Collection matchingEndpoints; readonly ProbeRequestResponseAsyncResult probeRequestResponseAsyncResult; public FindRequestResponseContext( FindCriteria criteria, ProbeRequestResponseAsyncResult probeRequestResponseAsyncResult) : base(criteria) { this.matchingEndpoints = new Collection (); this.probeRequestResponseAsyncResult = probeRequestResponseAsyncResult; } public Collection MatchingEndpoints { get { return this.matchingEndpoints; } } protected override void OnAddMatchingEndpoint(EndpointDiscoveryMetadata matchingEndpoint) { lock (this.probeRequestResponseAsyncResult.findCompletedLock) { if (this.probeRequestResponseAsyncResult.isFindCompleted) { throw FxTrace.Exception.AsError( new InvalidOperationException(SR.DiscoveryCannotAddMatchingEndpoint)); } else { this.matchingEndpoints.Add(matchingEndpoint); } } } } } } // 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
- ProcessProtocolHandler.cs
- Classification.cs
- __ComObject.cs
- AttributeEmitter.cs
- XmlUtf8RawTextWriter.cs
- SettingsPropertyIsReadOnlyException.cs
- WebErrorHandler.cs
- BulletedListEventArgs.cs
- DateTimeFormatInfoScanner.cs
- FixedSOMTextRun.cs
- DoubleUtil.cs
- OracleDataAdapter.cs
- Msec.cs
- SevenBitStream.cs
- SnapLine.cs
- XmlSchemaImporter.cs
- CodeEventReferenceExpression.cs
- InkCanvasAutomationPeer.cs
- UnsafeNativeMethods.cs
- HttpProfileBase.cs
- SizeChangedEventArgs.cs
- AmbientProperties.cs
- SkewTransform.cs
- ReadWriteControlDesigner.cs
- DesignerPainter.cs
- OleDbCommand.cs
- AttachedPropertyBrowsableForTypeAttribute.cs
- ContentHostHelper.cs
- ClientSideProviderDescription.cs
- MultipartContentParser.cs
- XPathAxisIterator.cs
- WorkflowApplicationUnloadedException.cs
- TitleStyle.cs
- MailBnfHelper.cs
- CommandEventArgs.cs
- InteropExecutor.cs
- _emptywebproxy.cs
- TraceUtility.cs
- MetadataItemEmitter.cs
- newinstructionaction.cs
- TraceSection.cs
- DataGridCellEditEndingEventArgs.cs
- Panel.cs
- TdsParserStateObject.cs
- MappingModelBuildProvider.cs
- AlternateViewCollection.cs
- WebPartConnectionsCancelEventArgs.cs
- metadatamappinghashervisitor.hashsourcebuilder.cs
- BasePattern.cs
- TextMessageEncodingElement.cs
- SequentialUshortCollection.cs
- Utils.cs
- SimpleNameService.cs
- XmlIncludeAttribute.cs
- NavigationWindowAutomationPeer.cs
- RC2.cs
- EventlogProvider.cs
- ETagAttribute.cs
- TimeSpanMinutesConverter.cs
- WriteableBitmap.cs
- XmlDataContract.cs
- ApplicationContext.cs
- WpfMemberInvoker.cs
- ResourceDictionary.cs
- SystemIPGlobalStatistics.cs
- AdRotator.cs
- OptimizerPatterns.cs
- DefaultPropertyAttribute.cs
- ErrorReporting.cs
- PtsContext.cs
- DSASignatureDeformatter.cs
- TextCompositionManager.cs
- FixedFindEngine.cs
- LogLogRecord.cs
- BypassElement.cs
- OutputCacheSettingsSection.cs
- RuleElement.cs
- DocumentXmlWriter.cs
- MSAAWinEventWrap.cs
- OpenFileDialog.cs
- MatrixKeyFrameCollection.cs
- ImageList.cs
- DataGridViewTextBoxColumn.cs
- SchemaNames.cs
- HighContrastHelper.cs
- DataViewSettingCollection.cs
- SemaphoreFullException.cs
- TcpConnectionPool.cs
- SchemaManager.cs
- TrackingLocationCollection.cs
- XmlSubtreeReader.cs
- OSFeature.cs
- Semaphore.cs
- StructuredTypeEmitter.cs
- MetadataItemSerializer.cs
- ActivityBindForm.Designer.cs
- ResourceProviderFactory.cs
- PaintEvent.cs
- TextSelectionHelper.cs
- XPathItem.cs