using System;
using System.Diagnostics;
using System.Net.Sockets;

namespace Bro.Common.Link
{
    /// <summary>
    /// TCP连接
    /// </summary>
    public class TCPLink : LinkBase
    {
        // 网络连接数据流
        public NetworkStream netStream      = null;
        // 远端信息
        public string        remoteInfo {get;set;}
        // 是否远端关闭
        public bool         IsRemoteDisconn {get;set;}

        public TCPLink(NetworkStream stream)
        {
            this.netStream          = stream;
            this.IsRemoteDisconn    = false;
        }

        public TCPLink()
        {
            this.IsRemoteDisconn    = false;
        }

        /// <summary>
        /// 初始化
        /// </summary>
        /// <returns></returns>
        public override bool Init()
        {
            // TODO:
            return true;
        }

        /// <summary>
        /// 打开TCP连接
        /// </summary>
        /// <returns></returns>
        public override bool Open()
        {
            // TODO:
            return true;
        }

        /// <summary>
        /// 关闭TCP连接
        /// </summary>
        public override void Close()
        {
            // TODO:
            if ( null == this.netStream )
            {
                return;
            }

            try
            {
                this.netStream.Close();
                this.netStream = null;

                this.IsRemoteDisconn = true;
            }
            catch(Exception ex)
            {
                Trace.TraceError("TCPLink:{0} Close fail, ex:{1}-{2}", this.Desp, ex.Message, ex.StackTrace);
            }
        }

        /// <summary>
        /// 销毁
        /// </summary>
        public override void Fnit()
        {
            this.Close();
        }

        /// <summary>
        /// 接收数据
        /// </summary>
        /// <returns></returns>
        public override int Recv(byte[] rcvBuf, int bufLen)
        {
            int len = -1;
            try
            {
                len = netStream.Read(rcvBuf, 0, bufLen);
            }
            catch(Exception ex)
            {
                this.IsRemoteDisconn = true;

                Trace.TraceError("TCPLink:{0} Recv fail, ex:{1}-{2}", this.Desp, ex.Message, ex.StackTrace);
            }

            return len;
        }

        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="sndBuf"></param>
        /// <param name="bufLen"></param>
        public override bool Send(byte[] sndBuf, int offset, int len)
        {
            try
            {
                netStream.Write(sndBuf, offset, len);

                return true;
            }
            catch(Exception ex)
            {
                this.IsRemoteDisconn = true;

                Trace.TraceError("TCPLink:{0} Send fail, ex:{1}-{2}", this.Desp, ex.Message, ex.StackTrace);
            }

            return false;
        }
    }
}