From 6b511327441a539738cda04530892464debda9c5 Mon Sep 17 00:00:00 2001
From: perror <15058342792@163.com>
Date: Fri, 11 Feb 2022 00:25:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DCPU=E5=8D=A0=E7=94=A8?=
 =?UTF-8?q?=E8=BF=87=E9=AB=98=EF=BC=9Bweb=E9=A1=B5=E9=9D=A2=E5=A2=9E?=
 =?UTF-8?q?=E5=8A=A0=E6=80=BB=E8=AE=A1=E7=BB=9F=E8=AE=A1=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E4=B8=94=E5=8F=AF=E4=BB=A5=E6=B8=85=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 proxy/proxy.go | 15 +++++++--------
 1 file changed, 7 insertions(+), 8 deletions(-)

diff --git a/proxy/proxy.go b/proxy/proxy.go
index c7e1560..6cb0c9d 100644
--- a/proxy/proxy.go
+++ b/proxy/proxy.go
@@ -41,7 +41,7 @@ func New(lconn *net.TCPConn, laddr, raddr *net.TCPAddr) *Proxy {
 // Start - open connection to remote and start proxying data.
 func (p *Proxy) Start() {
 	defer pkg.Recover(true)
-	defer pkg.Error2Null(p.lconn.Close())
+	defer p.lconn.Close()
 	defer func() {
 		if !p.IsClient && p.lconn != nil {
 			status.Del(p.lconn.(net.Conn).RemoteAddr().String())
@@ -49,12 +49,12 @@ func (p *Proxy) Start() {
 	}()
 	conn, err := p.Init()
 	if err != nil || conn == nil {
-		p.err(fmt.Sprintf("请检查 %s 是否能够联通, 可以使用tcping 工具测试, 并检查该ip所在的防火墙是否开放", p.raddr.String()), nil)
+		p.err(fmt.Sprintf("请检查 %s 是否能够联通, 可以使用tcping 工具测试, 并检查该ip所在的防火墙是否开放: %%s", p.raddr.String()), err)
 		return
 	}
 
 	p.rconn = conn
-	defer pkg.Error2Null(p.rconn.Close())
+	defer p.rconn.Close()
 
 	//bidirectional copy
 	go p.pipe(p.lconn, p.rconn)
@@ -68,7 +68,6 @@ func (p *Proxy) Start() {
 
 	//wait for close...
 	<-p.errsig
-	close(p.errsig)
 }
 
 func (p *Proxy) err(s string, err error) {
@@ -405,16 +404,16 @@ func (p *Proxy) pipe(src, dst io.ReadWriter) {
 			switch {
 			case strings.Contains(name, "读取加密数据, 发送明文"):
 				if p.IsClient {
-					p.err("检查服务服是否正确启动, 服务器防火墙是否开启, 本地网络到服务器网络是否畅通, 矿机端是否设置正确", nil)
+					p.err("检查服务服是否正确启动, 服务器防火墙是否开启, 本地网络到服务器网络是否畅通, 矿机端是否设置正确: %s", err)
 					return
 				}
-				p.err("客户端关闭了连接, 请检查矿机/客户端设置", nil)
+				p.err("客户端关闭了连接, 请检查矿机/客户端设置: %s", err)
 			default:
 				if p.IsClient {
-					p.err("矿机关闭了连接, 请检查矿机设置正常", nil)
+					p.err("矿机关闭了连接, 请检查矿机设置正常: %s", err)
 					return
 				}
-				p.err("矿池关闭了连接, 请检查矿池/矿机/客户端设置", nil)
+				p.err("矿池关闭了连接, 请检查矿池/矿机/客户端设置: %s", err)
 			}
 			return
 		}