SynchronousSendBindingElement.cs source code in C# .NET

Source code for the .NET framework in C#

                        
Code:

                         / 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Routing / System / ServiceModel / Channels / SynchronousSendBindingElement.cs / 1305376 / SynchronousSendBindingElement.cs
                        

                        
                            //---------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------

namespace System.ServiceModel.Channels 
{
    using System; 
    using System.Runtime; 
    using System.ServiceModel.Routing;
    using System.Collections.Generic; 
    using System.Security.Principal;
    using SR2 = System.ServiceModel.SR;

    class SynchronousSendBindingElement : BindingElement 
    {
        public override BindingElement Clone() 
        { 
            return new SynchronousSendBindingElement();
        } 

        public override T GetProperty(BindingContext context)
        {
            if (context == null) 
            {
                throw FxTrace.Exception.ArgumentNull("context"); 
            } 

            return context.GetInnerProperty(); 
        }

        public override bool CanBuildChannelFactory(BindingContext context)
        { 
            if (context == null)
            { 
                throw FxTrace.Exception.ArgumentNull("context"); 
            }
 

            Type typeofTChannel = typeof(TChannel);

            if (typeofTChannel == typeof(IDuplexChannel) || 
                typeofTChannel == typeof(IDuplexSessionChannel) ||
                typeofTChannel == typeof(IRequestChannel) || 
                typeofTChannel == typeof(IRequestSessionChannel) || 
                typeofTChannel == typeof(IOutputChannel) ||
                typeofTChannel == typeof(IOutputSessionChannel)) 
            {
                return context.CanBuildInnerChannelFactory();
            }
            return false; 
        }
 
        public override IChannelFactory BuildChannelFactory(BindingContext context) 
        {
            if (context == null) 
            {
                throw FxTrace.Exception.ArgumentNull("context");
            }
 
            if (!this.CanBuildChannelFactory(context.Clone()))
            { 
                throw FxTrace.Exception.Argument("TChannel", SR2.GetString(SR2.ChannelTypeNotSupported, typeof(TChannel))); 
            }
 
            IChannelFactory innerFactory = context.BuildInnerChannelFactory();
            if (innerFactory != null)
            {
                return new SynchronousChannelFactory(context.Binding, innerFactory); 
            }
            return null; 
        } 

        class SynchronousChannelFactory : LayeredChannelFactory 
        {
            public SynchronousChannelFactory(IDefaultCommunicationTimeouts timeouts, IChannelFactory innerFactory)
                : base(timeouts, innerFactory)
            { 
            }
 
            protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state) 
            {
                this.InnerChannelFactory.Open(timeout); 
                return new CompletedAsyncResult(callback, state);
            }

            protected override void OnEndOpen(IAsyncResult result) 
            {
                CompletedAsyncResult.End(result); 
            } 

            protected override TChannel OnCreateChannel(EndpointAddress address, Uri via) 
            {
                IChannelFactory factory = (IChannelFactory)this.InnerChannelFactory;
                TChannel channel = factory.CreateChannel(address, via);
                if (channel != null) 
                {
                    Type channelType = typeof(TChannel); 
                    if (channelType == typeof(IDuplexSessionChannel)) 
                    {
                        channel = (TChannel)(object)new SynchronousDuplexSessionChannel(this, (IDuplexSessionChannel)channel); 
                    }
                    else if (channelType == typeof(IRequestChannel))
                    {
                        channel = (TChannel)(object)new SynchronousRequestChannel(this, (IRequestChannel)channel); 
                    }
                    else if (channelType == typeof(IRequestSessionChannel)) 
                    { 
                        channel = (TChannel)(object)new SynchronousRequestSessionChannel(this, (IRequestSessionChannel)channel);
                    } 
                    else if (channelType == typeof(IOutputChannel))
                    {
                        channel = (TChannel)(object)new SynchronousOutputChannel(this, (IOutputChannel)channel);
                    } 
                    else if (channelType == typeof(IOutputSessionChannel))
                    { 
                        channel = (TChannel)(object)new SynchronousOutputSessionChannel(this, (IOutputSessionChannel)channel); 
                    }
                    else if (channelType == typeof(IDuplexChannel)) 
                    {
                        channel = (TChannel)(object)new SynchronousDuplexChannel(this, (IDuplexChannel)channel);
                    }
                    else 
                    {
                        throw FxTrace.Exception.AsError(base.CreateChannelTypeNotSupportedException(typeof(TChannel))); 
                    } 
                }
                return channel; 
            }
        }

        abstract class SynchronousChannelBase : LayeredChannel 
            where TChannel : class, IChannel
        { 
            protected SynchronousChannelBase(ChannelManagerBase manager, TChannel innerChannel) 
                : base(manager, innerChannel)
            { 
            }

            protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state)
            { 
                this.InnerChannel.Open(timeout);
                return new CompletedAsyncResult(callback, state); 
            } 

            protected override void OnEndOpen(IAsyncResult result) 
            {
                CompletedAsyncResult.End(result);
            }
        } 

        class SynchronousDuplexChannelBase : SynchronousOutputChannelBase 
            where TChannel : class, IDuplexChannel 
        {
            public SynchronousDuplexChannelBase(ChannelManagerBase manager, TChannel innerChannel) 
                : base(manager, innerChannel)
            {
            }
 
            public IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state)
            { 
                return this.InnerChannel.BeginReceive(timeout, callback, state); 
            }
 
            public IAsyncResult BeginReceive(AsyncCallback callback, object state)
            {
                return this.InnerChannel.BeginReceive(callback, state);
            } 

            public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) 
            { 
                return this.InnerChannel.BeginTryReceive(timeout, callback, state);
            } 

            public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state)
            {
                return this.InnerChannel.BeginWaitForMessage(timeout, callback, state); 
            }
 
            public Message EndReceive(IAsyncResult result) 
            {
                return this.InnerChannel.EndReceive(result); 
            }

            public bool EndTryReceive(IAsyncResult result, out Message message)
            { 
                return this.InnerChannel.EndTryReceive(result, out message);
            } 
 
            public bool EndWaitForMessage(IAsyncResult result)
            { 
                return this.InnerChannel.EndWaitForMessage(result);
            }

            public EndpointAddress LocalAddress 
            {
                get { return this.InnerChannel.LocalAddress; } 
            } 

            public Message Receive(TimeSpan timeout) 
            {
                return this.InnerChannel.Receive(timeout);
            }
 
            public Message Receive()
            { 
                return this.InnerChannel.Receive(); 
            }
 
            public bool TryReceive(TimeSpan timeout, out Message message)
            {
                return this.InnerChannel.TryReceive(timeout, out message);
            } 

            public bool WaitForMessage(TimeSpan timeout) 
            { 
                return this.InnerChannel.WaitForMessage(timeout);
            } 
        }

        class SynchronousDuplexChannel : SynchronousDuplexChannelBase, IDuplexChannel
        { 
            public SynchronousDuplexChannel(ChannelManagerBase manager, IDuplexChannel innerChannel)
                : base(manager, innerChannel) 
            { 
            }
        } 

        class SynchronousDuplexSessionChannel : SynchronousDuplexChannelBase, IDuplexSessionChannel
        {
            public SynchronousDuplexSessionChannel(ChannelManagerBase manager, IDuplexSessionChannel innerChannel) 
                : base(manager, innerChannel)
            { 
            } 

            IDuplexSession ISessionChannel.Session 
            {
                get { return this.InnerChannel.Session; }
            }
        } 

        abstract class SynchronousOutputChannelBase : SynchronousChannelBase 
            where TChannel : class, IOutputChannel 
        {
            public SynchronousOutputChannelBase(ChannelManagerBase manager, TChannel innerChannel) 
                : base(manager, innerChannel)
            {
            }
 
            public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
            { 
                this.InnerChannel.Send(message, timeout); 
                return new CompletedAsyncResult(callback, state);
            } 

            public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
            {
                this.InnerChannel.Send(message); 
                return new CompletedAsyncResult(callback, state);
            } 
 
            public void EndSend(IAsyncResult result)
            { 
                CompletedAsyncResult.End(result);
            }

            public EndpointAddress RemoteAddress 
            {
                get { return this.InnerChannel.RemoteAddress; } 
            } 

            public void Send(Message message, TimeSpan timeout) 
            {
                this.InnerChannel.Send(message, timeout);
            }
 
            public void Send(Message message)
            { 
                this.InnerChannel.Send(message); 
            }
 
            public Uri Via
            {
                get { return this.InnerChannel.Via; }
            } 
        }
 
        class SynchronousOutputChannel : SynchronousOutputChannelBase, IOutputChannel 
        {
            public SynchronousOutputChannel(ChannelManagerBase manager, IOutputChannel innerChannel) 
                : base(manager, innerChannel)
            {
            }
        } 

        class SynchronousOutputSessionChannel : SynchronousOutputChannelBase, IOutputSessionChannel 
        { 
            public SynchronousOutputSessionChannel(ChannelManagerBase manager, IOutputSessionChannel innerChannel)
                : base(manager, innerChannel) 
            {
            }

            IOutputSession ISessionChannel.Session 
            {
                get { return this.InnerChannel.Session; } 
            } 
        }
 
        abstract class SynchronousRequestChannelBase : SynchronousChannelBase
            where TChannel : class, IRequestChannel
        {
            public SynchronousRequestChannelBase(ChannelManagerBase manager, TChannel innerChannel) 
                : base(manager, innerChannel)
            { 
            } 

            public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) 
            {
                Message reply = this.InnerChannel.Request(message, timeout);
                return new CompletedAsyncResult(reply, callback, state);
            } 

            public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state) 
            { 
                Message reply = this.InnerChannel.Request(message);
                return new CompletedAsyncResult(reply, callback, state); 
            }

            public Message EndRequest(IAsyncResult result)
            { 
                return CompletedAsyncResult.End(result);
            } 
 
            public EndpointAddress RemoteAddress
            { 
                get { return this.InnerChannel.RemoteAddress; }
            }

            public Message Request(Message message, TimeSpan timeout) 
            {
                return this.InnerChannel.Request(message, timeout); 
            } 

            public Message Request(Message message) 
            {
                return this.InnerChannel.Request(message);
            }
 
            public Uri Via
            { 
                get { return this.InnerChannel.Via; } 
            }
        } 

        class SynchronousRequestChannel : SynchronousRequestChannelBase, IRequestChannel
        {
            public SynchronousRequestChannel(ChannelManagerBase manager, IRequestChannel innerChannel) 
                : base(manager, innerChannel)
            { 
            } 
        }
 
        class SynchronousRequestSessionChannel : SynchronousRequestChannelBase, IRequestSessionChannel
        {
            public SynchronousRequestSessionChannel(ChannelManagerBase manager, IRequestSessionChannel innerChannel)
                : base(manager, innerChannel) 
            {
            } 
 
            public IOutputSession Session
            { 
                get
                {
                    return this.InnerChannel.Session;
                } 
            }
        } 
    } 
}

// 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