DiscoveryInnerClientAdhocCD1.cs source code in C# .NET

                        Code:
                         / 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Discovery / VersionCD1 / DiscoveryInnerClientAdhocCD1.cs / 1305376 / DiscoveryInnerClientAdhocCD1.cs
                        
                        
                            //---------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------

namespace System.ServiceModel.Discovery.VersionCD1 
{
    using System; 
    using System.Runtime; 
    using System.ServiceModel.Description;
 
    class DiscoveryInnerClientAdhocCD1 : IDiscoveryInnerClient, IDiscoveryResponseContractCD1
    {
        IDiscoveryInnerClientResponse responseReceiver;
        DuplexClientCD1 duplexInnerClient; 

        public DiscoveryInnerClientAdhocCD1(DiscoveryEndpoint discoveryEndpoint, IDiscoveryInnerClientResponse responseReceiver) 
        { 
            Fx.Assert(discoveryEndpoint != null, "The discoveryEndpoint parameter cannot be null");
            Fx.Assert(responseReceiver != null, "The responseReceiver parameter cannot be null"); 

            this.responseReceiver = responseReceiver;
            if (discoveryEndpoint.Behaviors.Find() == null)
            { 
                discoveryEndpoint.Behaviors.Insert(0, new DiscoveryCallbackBehavior());
            } 
 
            this.duplexInnerClient = new DuplexClientCD1(this, discoveryEndpoint);
        } 

        public ClientCredentials ClientCredentials
        {
            get 
            {
                return this.duplexInnerClient.ClientCredentials; 
            } 
        }
 
        public ChannelFactory ChannelFactory
        {
            get
            { 
                return this.duplexInnerClient.ChannelFactory;
            } 
        } 

        public IClientChannel InnerChannel 
        {
            get
            {
                return this.duplexInnerClient.InnerChannel; 
            }
        } 
 
        public ServiceEndpoint Endpoint
        { 
            get
            {
                return this.duplexInnerClient.Endpoint;
            } 
        }
 
        public ICommunicationObject InnerCommunicationObject 
        {
            get 
            {
                return this.duplexInnerClient as ICommunicationObject;
            }
        } 

        public bool IsRequestResponse 
        { 
            get
            { 
                return false;
            }
        }
 
        public IAsyncResult BeginProbeOperation(FindCriteria findCriteria, AsyncCallback callback, object state)
        { 
            ProbeMessageCD1 request = new ProbeMessageCD1(); 
            request.Probe = FindCriteriaCD1.FromFindCriteria(findCriteria);
            return this.duplexInnerClient.BeginProbeOperation(request, callback, state); 
        }

        public IAsyncResult BeginResolveOperation(ResolveCriteria resolveCriteria, AsyncCallback callback, object state)
        { 
            ResolveMessageCD1 request = new ResolveMessageCD1();
            request.Resolve = ResolveCriteriaCD1.FromResolveCriteria(resolveCriteria); 
            return this.duplexInnerClient.BeginResolveOperation(request, callback, state); 
        }
 
        public void EndProbeOperation(IAsyncResult result)
        {
            this.duplexInnerClient.EndProbeOperation(result);
        } 

        public void EndResolveOperation(IAsyncResult result) 
        { 
            this.duplexInnerClient.EndResolveOperation(result);
        } 

        public void ProbeOperation(FindCriteria findCriteria)
        {
            ProbeMessageCD1 request = new ProbeMessageCD1(); 
            request.Probe = FindCriteriaCD1.FromFindCriteria(findCriteria);
            this.duplexInnerClient.ProbeOperation(request); 
        } 

        public void ResolveOperation(ResolveCriteria resolveCriteria) 
        {
            ResolveMessageCD1 request = new ResolveMessageCD1();
            request.Resolve = ResolveCriteriaCD1.FromResolveCriteria(resolveCriteria);
            this.duplexInnerClient.ResolveOperation(request); 
        }
 
        public IAsyncResult BeginProbeMatchOperation(ProbeMatchesMessageCD1 response, AsyncCallback callback, object state) 
        {
            Fx.Assert(response != null, "The response message cannot be null."); 
            if ((response.MessageSequence != null) && (response.ProbeMatches != null))
            {
                this.responseReceiver.ProbeMatchOperation(
                    OperationContext.Current.IncomingMessageHeaders.RelatesTo, 
                    response.MessageSequence.ToDiscoveryMessageSequence(),
                    DiscoveryUtility.ToEndpointDiscoveryMetadataCollection(response.ProbeMatches), 
                    false); 
            }
            else 
            {
                if (response.MessageSequence == null && TD.DiscoveryMessageWithNullMessageSequenceIsEnabled())
                {
                    TD.DiscoveryMessageWithNullMessageSequence( 
                        ProtocolStrings.TracingStrings.ProbeMatches,
                        OperationContext.Current.IncomingMessageHeaders.MessageId.ToString()); 
                } 
            }
 
            return new CompletedAsyncResult(callback, state);
        }

        public void EndProbeMatchOperation(IAsyncResult result) 
        {
            CompletedAsyncResult.End(result); 
        } 

        public IAsyncResult BeginResolveMatchOperation(ResolveMatchesMessageCD1 response, AsyncCallback callback, object state) 
        {
            Fx.Assert(response != null, "The response message cannot be null.");
            if ((response.MessageSequence != null) && (response.ResolveMatches != null) && (response.ResolveMatches.ResolveMatch != null))
            { 
                this.responseReceiver.ResolveMatchOperation(
                    OperationContext.Current.IncomingMessageHeaders.RelatesTo, 
                    response.MessageSequence.ToDiscoveryMessageSequence(), 
                    response.ResolveMatches.ResolveMatch.ToEndpointDiscoveryMetadata());
            } 
            else
            {
                if (response.MessageSequence == null && TD.DiscoveryMessageWithNullMessageSequenceIsEnabled())
                { 
                    TD.DiscoveryMessageWithNullMessageSequence(
                        ProtocolStrings.TracingStrings.ResolveMatches, 
                        OperationContext.Current.IncomingMessageHeaders.MessageId.ToString()); 
                }
            } 
            return new CompletedAsyncResult(callback, state);
        }

        public void EndResolveMatchOperation(IAsyncResult result) 
        {
            CompletedAsyncResult.End(result); 
        } 

        public IAsyncResult BeginHelloOperation(HelloMessageCD1 message, AsyncCallback callback, object state) 
        {
            Fx.Assert(message != null, "The message cannot be null.");
            if ((message.MessageSequence != null) && (message.Hello != null))
            { 
                this.responseReceiver.HelloOperation(
                    OperationContext.Current.IncomingMessageHeaders.RelatesTo, 
                    message.MessageSequence.ToDiscoveryMessageSequence(), 
                    message.Hello.ToEndpointDiscoveryMetadata());
            } 
            else
            {
                if (message.MessageSequence == null && TD.DiscoveryMessageWithNullMessageSequenceIsEnabled())
                { 
                    TD.DiscoveryMessageWithNullMessageSequence(
                        ProtocolStrings.TracingStrings.Hello, 
                        OperationContext.Current.IncomingMessageHeaders.MessageId.ToString()); 
                }
            } 
            return new CompletedAsyncResult(callback, state);
        }

        public void EndHelloOperation(IAsyncResult result) 
        {
            CompletedAsyncResult.End(result); 
        } 

        class DuplexClientCD1 : DuplexClientBase 
        {
            public DuplexClientCD1(object callbackInstance, DiscoveryEndpoint discoveryEndpoint)
                : base(callbackInstance, discoveryEndpoint)
            { 
            }
 
            public void ProbeOperation(ProbeMessageCD1 request) 
            {
                base.Channel.ProbeOperation(request); 
            }

            public void ResolveOperation(ResolveMessageCD1 request)
            { 
                base.Channel.ResolveOperation(request);
            } 
 
            public IAsyncResult BeginProbeOperation(ProbeMessageCD1 request, AsyncCallback callback, object state)
            { 
                return base.Channel.BeginProbeOperation(request, callback, state);
            }

            public IAsyncResult BeginResolveOperation(ResolveMessageCD1 request, AsyncCallback callback, object state) 
            {
                return base.Channel.BeginResolveOperation(request, callback, state); 
            } 

            public void EndProbeOperation(IAsyncResult result) 
            {
                base.Channel.EndProbeOperation(result);
            }
 
            public void EndResolveOperation(IAsyncResult result)
            { 
                base.Channel.EndResolveOperation(result); 
            }
        } 
    }
}

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
DiscoveryInnerClientAdhocCD1.cs source code in C# .NET

Source code for the .NET framework in C#

Code:

Link Menu
