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