dotnet/client-010/client/transport/Channel.cs

/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements.  See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership.  The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License.  You may obtain a copy of the License at
*
*   http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied.  See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
using System;
using org.apache.qpid.transport.network;
using org.apache.qpid.transport.util;

namespace org.apache.qpid.transport
{
    /// <summary> 
    /// Channel
    /// </summary>
    public class Channel : Invoker, IProtocolDelegate<Object>
    {
        private static readonly Logger log = Logger.Get(typeof (Channel));

        private readonly Connection _connection;
        private readonly int _channel;
        private readonly MethodDelegate<Channel> _methoddelegate;
        private readonly SessionDelegate _sessionDelegate;
        // session may be null
        private Session _session;

        public Channel(Connection connection, int channel, SessionDelegate sessionDelegate)
        {
            _connection = connection;
            _channel = channel;
            _methoddelegate = new ChannelDelegate();
            _sessionDelegate = sessionDelegate;
        }

        public Connection Connection
        {
            get { return _connection; }
        }

        // Invoked when a network event is received
        public void On_ReceivedEvent(object sender, ReceivedPayload<IProtocolEvent> payload)
        {
            if (payload.Payload.Channel == _channel)
            {
                payload.Payload.ProcessProtocolEvent(null, this);
            }
        }

        #region ProtocolDelegate<T>

        public void Init(Object v, ProtocolHeader hdr)
        {
            _connection.ConnectionDelegate.Init(this, hdr);
        }

        public void Control(Object v, Method method)
        {
            switch (method.EncodedTrack)
            {
                case Frame.L1:
                    method.Dispatch(this, _connection.ConnectionDelegate);
                    break;
                case Frame.L2:
                    method.Dispatch(this, _methoddelegate);
                    break;
                case Frame.L3:
                    method.ProcessProtocolEvent(_session, _sessionDelegate);
                    break;
                default:
                    throw new Exception("unknown track: " + method.EncodedTrack);
            }
        }

        public void Command(Object v, Method method)
        {
            method.ProcessProtocolEvent(_session, _sessionDelegate);
        }

        public void Error(Object v, ProtocolError error)
        {
            throw new Exception(error.Message);
        }

        #endregion

        public void Exception(Exception t)
        {
            _session.Exception(t);
        }

        public void ClosedFromConnection()
        {
            log.Debug("channel Closed: ", this);
            if (_session != null)
            {
                _session.Closed();
            }
        }

        public void Closed()
        {
            log.Debug("channel Closed: ", this);
            if (_session != null)
            {
                _session.Closed();
            }
            _connection.RemoveChannel(_channel);
        }

        public int EncodedChannel
        {
            get { return _channel; }
        }

        public Session Session
        {
            get { return _session; }
            set { _session = value; }
        }

        public void CloseCode(ConnectionClose close)
        {
            if (_session != null)
            {
                _session.CloseCode(close);
            }
        }

        private void Emit(IProtocolEvent pevent)
        {
            pevent.Channel = _channel;
            _connection.Send(pevent);
        }

        public void Method(Method m)
        {
            Emit(m);

            if (!m.Batch)
            {
                _connection.Flush();
            }
        }

        protected override void Invoke(Method m)
        {
            Method(m);
        }

        public override IFuture Invoke(Method m, IFuture future)
        {
            throw new Exception("UnsupportedOperation");
        }

        public override String ToString()
        {
            return String.Format("{0}:{1}", _connection, _channel);
        }
    }
}