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
- HtmlTable.cs
- UnsafeNativeMethodsPenimc.cs
- SchemaMapping.cs
- TraceListener.cs
- XmlSchemaSimpleTypeUnion.cs
- StatusStrip.cs
- EventWaitHandle.cs
- FirstMatchCodeGroup.cs
- QuadraticBezierSegment.cs
- SpecularMaterial.cs
- XamlPoint3DCollectionSerializer.cs
- ProfilePropertySettingsCollection.cs
- FamilyMapCollection.cs
- ValueTypeFixupInfo.cs
- DropShadowBitmapEffect.cs
- DesignerCommandAdapter.cs
- DateTimeStorage.cs
- HandlerWithFactory.cs
- XsdValidatingReader.cs
- DrawListViewColumnHeaderEventArgs.cs
- ErrorFormatterPage.cs
- SendingRequestEventArgs.cs
- DateTimePickerDesigner.cs
- TemplateNameScope.cs
- Size.cs
- GCHandleCookieTable.cs
- SecurityCapabilities.cs
- securitycriticaldataClass.cs
- InkCanvasSelectionAdorner.cs
- PolicyVersion.cs
- CaseInsensitiveHashCodeProvider.cs
- autovalidator.cs
- ConstructorExpr.cs
- Button.cs
- MediaPlayerState.cs
- FormsAuthentication.cs
- TypeResolver.cs
- CoTaskMemUnicodeSafeHandle.cs
- ThemeDictionaryExtension.cs
- FileEnumerator.cs
- XsltOutput.cs
- OutputCacheSettingsSection.cs
- XslAstAnalyzer.cs
- versioninfo.cs
- CounterSampleCalculator.cs
- mediaeventshelper.cs
- ProcessHost.cs
- TableLayoutStyle.cs
- TextBox.cs
- WindowsGraphicsWrapper.cs
- FixedDocumentSequencePaginator.cs
- Completion.cs
- ToolStripOverflowButton.cs
- WebPartConnectVerb.cs
- FontStretches.cs
- ForceCopyBuildProvider.cs
- SevenBitStream.cs
- KnownTypesProvider.cs
- SocketAddress.cs
- AnnouncementService.cs
- SqlInfoMessageEvent.cs
- DbDataReader.cs
- GridViewColumnCollection.cs
- DataGrid.cs
- BrowserCapabilitiesCodeGenerator.cs
- StylusCaptureWithinProperty.cs
- LabelLiteral.cs
- PenLineCapValidation.cs
- Resources.Designer.cs
- MetadataArtifactLoaderComposite.cs
- BaseAddressPrefixFilterElement.cs
- StyleCollection.cs
- future.cs
- StylusPointProperties.cs
- LowerCaseStringConverter.cs
- DetailsViewRowCollection.cs
- X509CertificateInitiatorClientCredential.cs
- WebProxyScriptElement.cs
- AssemblyInfo.cs
- SqlMethodCallConverter.cs
- RawMouseInputReport.cs
- SendParametersContent.cs
- PathGradientBrush.cs
- OutOfMemoryException.cs
- Size3D.cs
- ClientUriBehavior.cs
- TableItemStyle.cs
- UnsafeNetInfoNativeMethods.cs
- EntryWrittenEventArgs.cs
- TextSelectionProcessor.cs
- InstancePersistence.cs
- TimeSpanSecondsOrInfiniteConverter.cs
- clipboard.cs
- OpenTypeLayout.cs
- StickyNoteAnnotations.cs
- MouseActionValueSerializer.cs
- SimpleRecyclingCache.cs
- ValidationSummary.cs
- ClientEndpointLoader.cs
- TTSVoice.cs