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
- WebPartEditorApplyVerb.cs
- EtwProvider.cs
- Panel.cs
- Literal.cs
- IncrementalCompileAnalyzer.cs
- ExternalFile.cs
- ToolStripItemCollection.cs
- BoundColumn.cs
- DeviceSpecificDialogCachedState.cs
- SafeMarshalContext.cs
- XmlSchemaResource.cs
- RoutedPropertyChangedEventArgs.cs
- QueryResults.cs
- ToolStripItemClickedEventArgs.cs
- Int32.cs
- VideoDrawing.cs
- X509CertificateChain.cs
- PreApplicationStartMethodAttribute.cs
- ConfigurationConverterBase.cs
- SqlDataSourceCommandEventArgs.cs
- SingleKeyFrameCollection.cs
- ResourceManager.cs
- Lock.cs
- AxHost.cs
- TextElementCollectionHelper.cs
- TextRunCache.cs
- ReturnEventArgs.cs
- _NTAuthentication.cs
- SafeCancelMibChangeNotify.cs
- DatasetMethodGenerator.cs
- UrlAuthorizationModule.cs
- UriScheme.cs
- ExpressionBuilder.cs
- Html32TextWriter.cs
- MouseWheelEventArgs.cs
- HwndHostAutomationPeer.cs
- DataGridViewBindingCompleteEventArgs.cs
- RegexStringValidator.cs
- FileLoadException.cs
- BitmapDecoder.cs
- TimelineClockCollection.cs
- ContentPresenter.cs
- x509utils.cs
- dataobject.cs
- Rotation3D.cs
- ConditionalDesigner.cs
- EntitySqlQueryState.cs
- DefaultValueTypeConverter.cs
- ItemsControl.cs
- LogWriteRestartAreaState.cs
- CollectionChange.cs
- Configuration.cs
- ResolveCriteriaCD1.cs
- LiteralControl.cs
- HtmlContainerControl.cs
- ReaderOutput.cs
- ClientTargetSection.cs
- StorageEndPropertyMapping.cs
- SplashScreen.cs
- DecimalAnimationBase.cs
- OperationInvokerTrace.cs
- SerializationTrace.cs
- ProjectedSlot.cs
- COSERVERINFO.cs
- FixedBufferAttribute.cs
- SchemaDeclBase.cs
- IriParsingElement.cs
- RadioButtonList.cs
- AbstractSvcMapFileLoader.cs
- ExpressionBinding.cs
- WorkflowExecutor.cs
- DbConnectionPoolCounters.cs
- CustomSignedXml.cs
- DataGridState.cs
- EdmFunction.cs
- TextBoxAutoCompleteSourceConverter.cs
- SqlDataSourceCache.cs
- PersistenceTypeAttribute.cs
- SuppressMergeCheckAttribute.cs
- PerformanceCounter.cs
- Misc.cs
- Rotation3D.cs
- DataObjectFieldAttribute.cs
- UserPreferenceChangingEventArgs.cs
- ViewStateModeByIdAttribute.cs
- SvcMapFileSerializer.cs
- EventRouteFactory.cs
- cache.cs
- CompModSwitches.cs
- AppDomain.cs
- CFGGrammar.cs
- WSSecureConversationDec2005.cs
- CustomAttributeFormatException.cs
- XNodeValidator.cs
- TypeGeneratedEventArgs.cs
- TraversalRequest.cs
- UserMapPath.cs
- TraceShell.cs
- EntityTypeBase.cs
- RequestedSignatureDialog.cs