From 764f22b32ca5e05b63ec891a27226b8c2f1e9437 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= <zouzongnan1995@icloud.com>
Date: Wed, 7 Jun 2023 13:41:22 +0800
Subject: [PATCH] 1

---
 business/jxstore/event/event_tcp.go | 25 -------------------------
 1 file changed, 25 deletions(-)

diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go
index da0ec0e96..a79f499c9 100644
--- a/business/jxstore/event/event_tcp.go
+++ b/business/jxstore/event/event_tcp.go
@@ -10,7 +10,6 @@ import (
 	"git.rosy.net.cn/jx-callback/business/model/dao"
 	"git.rosy.net.cn/jx-callback/globals"
 	"io"
-	"io/ioutil"
 	"net"
 	"strings"
 	"time"
@@ -59,38 +58,14 @@ func ListenTcp() {
 			}
 		}
 		Poll.AddJob(fn)
-		//go func() {
-		//	defer func() {
-		//		// 捕获异常 防止waitGroup阻塞
-		//		if err := recover(); err != nil {
-		//			fmt.Println("recover err = ", err)
-		//			return
-		//		}
-		//	}()
-		//
-		//	t := NewTcpClient()
-		//	if err := handleConn(c, t); err != nil {
-		//		t = nil
-		//		return
-		//	}
-		//}()
 	}
 }
 
-func ConReadAll(c net.Conn) ([]byte, int, error) {
-	data, err := ioutil.ReadAll(c)
-	return data, len(data), err
-}
 func ConnRead(c net.Conn) ([]byte, int, error) {
 	buffer := make([]byte, 1024*2)
 	n, err := c.Read(buffer)
 	return buffer, n, err
 }
-func ConnReadFull(c net.Conn) ([]byte, int, error) {
-	buffer := make([]byte, 1024)
-	n, err := io.ReadFull(c, buffer)
-	return buffer, n, err
-}
 
 func handleConn(c net.Conn, t *TcpClient) error {
 	if c == nil {