Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Discovery / Version11 / DiscoveryInnerClientManaged11.cs / 1305376 / DiscoveryInnerClientManaged11.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Discovery.Version11 { using System; using System.ServiceModel; using System.ServiceModel.Channels; using System.Runtime; using System.ServiceModel.Description; class DiscoveryInnerClientManaged11 : ClientBase, IDiscoveryInnerClient { IDiscoveryInnerClientResponse responseReceiver; internal DiscoveryInnerClientManaged11(DiscoveryEndpoint discoveryEndpoint, IDiscoveryInnerClientResponse responseReceiver) : base(discoveryEndpoint) { Fx.Assert(responseReceiver != null, "The responseReceiver parameter cannot be null"); this.responseReceiver = responseReceiver; } public new ClientCredentials ClientCredentials { get { return base.ClientCredentials; } } public new ChannelFactory ChannelFactory { get { return base.ChannelFactory; } } public new IClientChannel InnerChannel { get { return base.InnerChannel; } } public new ServiceEndpoint Endpoint { get { return base.Endpoint; } } public ICommunicationObject InnerCommunicationObject { get { return this as ICommunicationObject; } } public bool IsRequestResponse { get { return true; } } public IAsyncResult BeginProbeOperation(FindCriteria findCriteria, AsyncCallback callback, object state) { ProbeMessage11 request = new ProbeMessage11(); request.Probe = FindCriteria11.FromFindCriteria(findCriteria); return base.Channel.BeginProbeOperation(request, callback, state); } public IAsyncResult BeginResolveOperation(ResolveCriteria resolveCriteria, AsyncCallback callback, object state) { ResolveMessage11 request = new ResolveMessage11(); request.Resolve = ResolveCriteria11.FromResolveCriteria(resolveCriteria); return base.Channel.BeginResolveOperation(request, callback, state); } public void EndProbeOperation(IAsyncResult result) { ProbeMatchesMessage11 response = base.Channel.EndProbeOperation(result); AsyncOperationContext context = (AsyncOperationContext)result.AsyncState; if ((response != null) && (response.ProbeMatches != null)) { this.responseReceiver.ProbeMatchOperation( context.OperationId, DiscoveryUtility.ToDiscoveryMessageSequenceOrNull(response.MessageSequence), DiscoveryUtility.ToEndpointDiscoveryMetadataCollection(response.ProbeMatches), true); } else { this.responseReceiver.PostFindCompletedAndRemove(context.OperationId, false, null); } } public void EndResolveOperation(IAsyncResult result) { ResolveMatchesMessage11 response = base.Channel.EndResolveOperation(result); AsyncOperationContext context = (AsyncOperationContext)result.AsyncState; if ((response != null) && (response.ResolveMatches != null) && (response.ResolveMatches.ResolveMatch != null)) { this.responseReceiver.ResolveMatchOperation( context.OperationId, DiscoveryUtility.ToDiscoveryMessageSequenceOrNull(response.MessageSequence), response.ResolveMatches.ResolveMatch.ToEndpointDiscoveryMetadata()); } else { this.responseReceiver.PostResolveCompletedAndRemove(context.OperationId, false, null); } } public void ProbeOperation(FindCriteria findCriteria) { ProbeMessage11 request = new ProbeMessage11(); request.Probe = FindCriteria11.FromFindCriteria(findCriteria); ProbeMatchesMessage11 response = base.Channel.ProbeOperation(request); if ((response != null) && (response.ProbeMatches != null)) { this.responseReceiver.ProbeMatchOperation( OperationContext.Current.IncomingMessageHeaders.RelatesTo, DiscoveryUtility.ToDiscoveryMessageSequenceOrNull(response.MessageSequence), DiscoveryUtility.ToEndpointDiscoveryMetadataCollection(response.ProbeMatches), true); } else { this.responseReceiver.PostFindCompletedAndRemove(OperationContext.Current.IncomingMessageHeaders.RelatesTo, false, null); } } public void ResolveOperation(ResolveCriteria resolveCriteria) { ResolveMessage11 request = new ResolveMessage11(); request.Resolve = ResolveCriteria11.FromResolveCriteria(resolveCriteria); ResolveMatchesMessage11 response = base.Channel.ResolveOperation(request); if ((response != null) && (response.ResolveMatches != null) && (response.ResolveMatches.ResolveMatch != null)) { this.responseReceiver.ResolveMatchOperation( OperationContext.Current.IncomingMessageHeaders.RelatesTo, DiscoveryUtility.ToDiscoveryMessageSequenceOrNull(response.MessageSequence), response.ResolveMatches.ResolveMatch.ToEndpointDiscoveryMetadata()); } else { this.responseReceiver.PostResolveCompletedAndRemove(OperationContext.Current.IncomingMessageHeaders.RelatesTo, false, 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
- SafeSecurityHandles.cs
- RuntimeVariablesExpression.cs
- ResourceProperty.cs
- IDataContractSurrogate.cs
- BoolExpr.cs
- InfoCardRSAPKCS1KeyExchangeDeformatter.cs
- RsaSecurityTokenAuthenticator.cs
- RichTextBox.cs
- GeneratedCodeAttribute.cs
- SQLMoney.cs
- RegexCode.cs
- Viewport3DAutomationPeer.cs
- Preprocessor.cs
- DispatcherOperation.cs
- ContextQuery.cs
- CounterCreationData.cs
- OdbcInfoMessageEvent.cs
- MethodToken.cs
- BaseTreeIterator.cs
- MergeFilterQuery.cs
- DataControlFieldCollection.cs
- DataGridViewCellLinkedList.cs
- ContextQuery.cs
- StylusSystemGestureEventArgs.cs
- SoapInteropTypes.cs
- FunctionQuery.cs
- ReversePositionQuery.cs
- ClientProxyGenerator.cs
- ParseChildrenAsPropertiesAttribute.cs
- GeneralTransform.cs
- TextEffect.cs
- DataGridRelationshipRow.cs
- SecurityPermission.cs
- InkCanvas.cs
- CompilerTypeWithParams.cs
- MetadataItemSerializer.cs
- MemberInfoSerializationHolder.cs
- RadioButtonBaseAdapter.cs
- ObjectFactoryCodeDomTreeGenerator.cs
- StrokeNode.cs
- XsdDuration.cs
- TextAnchor.cs
- CursorConverter.cs
- IsolatedStoragePermission.cs
- WmfPlaceableFileHeader.cs
- ValidationErrorCollection.cs
- HtmlElementErrorEventArgs.cs
- XPathSingletonIterator.cs
- OneToOneMappingSerializer.cs
- NewArrayExpression.cs
- MergablePropertyAttribute.cs
- ProbeMatches11.cs
- GlyphInfoList.cs
- MD5CryptoServiceProvider.cs
- LinkUtilities.cs
- KeyProperty.cs
- FontStyleConverter.cs
- XPathScanner.cs
- DataServiceRequest.cs
- DataBindingCollectionEditor.cs
- HandlerMappingMemo.cs
- Pipe.cs
- LogManagementAsyncResult.cs
- HttpContext.cs
- HttpPostServerProtocol.cs
- TextAutomationPeer.cs
- BaseDataList.cs
- MultiPropertyDescriptorGridEntry.cs
- FacetEnabledSchemaElement.cs
- ObjectView.cs
- ISAPIApplicationHost.cs
- DeadCharTextComposition.cs
- IgnoreSection.cs
- HotCommands.cs
- Encoder.cs
- StringUtil.cs
- CellLabel.cs
- Scene3D.cs
- SqlDataRecord.cs
- InvalidComObjectException.cs
- _SafeNetHandles.cs
- SymbolEqualComparer.cs
- BoolExpr.cs
- ToolBarTray.cs
- AttributeQuery.cs
- HttpCachePolicy.cs
- BooleanAnimationBase.cs
- XmlTextWriter.cs
- CodeRemoveEventStatement.cs
- WorkflowRuntime.cs
- Compensation.cs
- InfiniteIntConverter.cs
- WebPartCatalogCloseVerb.cs
- ReturnEventArgs.cs
- VisualStateChangedEventArgs.cs
- TextBreakpoint.cs
- PageCodeDomTreeGenerator.cs
- InsufficientMemoryException.cs
- TargetConverter.cs
- DeadCharTextComposition.cs