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
- ToolStripItemImageRenderEventArgs.cs
- Label.cs
- ControlPropertyNameConverter.cs
- OdbcRowUpdatingEvent.cs
- SqlBuilder.cs
- RepeaterCommandEventArgs.cs
- HttpStreams.cs
- BaseCodePageEncoding.cs
- EventWaitHandle.cs
- WebEventCodes.cs
- DocumentOrderQuery.cs
- HwndTarget.cs
- OrthographicCamera.cs
- BitmapEffectGroup.cs
- Vector3DCollectionConverter.cs
- CheckPair.cs
- ScriptMethodAttribute.cs
- diagnosticsswitches.cs
- DbExpressionVisitor_TResultType.cs
- safelinkcollection.cs
- _LoggingObject.cs
- Symbol.cs
- DataGridTablesFactory.cs
- ExpandoClass.cs
- WebServiceMethodData.cs
- XpsSerializerFactory.cs
- RegexWorker.cs
- DisposableCollectionWrapper.cs
- WpfPayload.cs
- EmissiveMaterial.cs
- WinCategoryAttribute.cs
- FixedSOMFixedBlock.cs
- DataSvcMapFileSerializer.cs
- ListParaClient.cs
- SafeIUnknown.cs
- ProgressBarHighlightConverter.cs
- Compiler.cs
- SByteConverter.cs
- ComplexBindingPropertiesAttribute.cs
- IndentedWriter.cs
- ResXBuildProvider.cs
- BinaryNode.cs
- FontUnitConverter.cs
- ModifierKeysConverter.cs
- ReflectTypeDescriptionProvider.cs
- InstanceStore.cs
- MarginsConverter.cs
- TimersDescriptionAttribute.cs
- Geometry3D.cs
- ObjectQuery.cs
- FixUp.cs
- DecoderReplacementFallback.cs
- WindowsHyperlink.cs
- FreezableCollection.cs
- DataPagerField.cs
- _AutoWebProxyScriptEngine.cs
- DocumentViewerBase.cs
- ApplicationId.cs
- Buffer.cs
- AuthenticationServiceManager.cs
- XmlDataContract.cs
- _IPv6Address.cs
- safex509handles.cs
- TdsParser.cs
- RequestQueryParser.cs
- BinaryMethodMessage.cs
- Triplet.cs
- RequiredFieldValidator.cs
- DataSourceHelper.cs
- WebBrowserDocumentCompletedEventHandler.cs
- _Semaphore.cs
- DataBoundControlAdapter.cs
- Add.cs
- HttpApplicationFactory.cs
- SetterBase.cs
- DataRelationCollection.cs
- UnsafeCollabNativeMethods.cs
- TableAdapterManagerMethodGenerator.cs
- backend.cs
- JsonServiceDocumentSerializer.cs
- BindingMAnagerBase.cs
- UxThemeWrapper.cs
- Rotation3D.cs
- TreeNode.cs
- SerialStream.cs
- DataGridViewElement.cs
- HttpCookie.cs
- VSWCFServiceContractGenerator.cs
- EventLog.cs
- CollectionAdapters.cs
- BindUriHelper.cs
- Axis.cs
- OperandQuery.cs
- TargetControlTypeAttribute.cs
- CaseKeyBox.ViewModel.cs
- MatrixAnimationUsingPath.cs
- SharedHttpsTransportManager.cs
- DbParameterHelper.cs
- ExtensionDataObject.cs
- MembershipPasswordException.cs