TCPSConn.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;

namespace FObjBase
{
    //public class TCPSConn : TCPConn
    //{
    //    public TCPSConn(Socket sock) 
    //    {
    //        this.sock = sock;
    //    }

    //    public virtual int OnPoll()
    //    {
    //        int ret = 0;
    //        Init();


    //        if (Send_Poll() < 0)
    //        {
    //            ret = -1;
    //            goto end;
    //        }
    //        int reclen = Receive_Poll();
    //        if (reclen < 0)
    //        {
    //            ret = -1;
    //            goto end;
    //        }
    //        if (reclen == 0)
    //        {
    //            if (DateTime.Now.Subtract(comm_time) > TimeSpan.FromMilliseconds(Silent_Time))
    //            {
    //                FDEBUG.Debug.LogMessage(this, 10, "ERROR 超时出错!");
    //                ret = -2;
    //                goto end;
    //            }
    //            else if (MAX_BUFFER == in_len)
    //            {
    //                string str = "";
    //                for (int i = 0; i < 10; i++)
    //                {
    //                    str += in_buffer[i].ToString("X2") + " ";
    //                }
    //                FDEBUG.Debug.LogMessage(this, 10, "ERROR 缓冲区塞满! in_buffer[0~9]=(" + str + ")");
    //                ret = -3;
    //                goto end;
    //            }
    //            goto end;
    //        }
    //        packet_start = 0;
    //        while ((packet_len = GetRecvInfoPacket()) > 0)
    //        {
    //            Parse_Packet();
    //            packet_start += packet_len;
    //        }
    //        Clear_Packet();

    //    end:

    //        if (ret != 0)
    //        {
    //            //连接断开
    //            Enable = false;
    //        }
    //        return ret;
    //    }
    //}
}