From f95dba661166bd5dd8644e89ea267375e43a501c Mon Sep 17 00:00:00 2001
From: kony <2312708932@qq.com>
Date: Wed, 18 Dec 2024 10:15:56 +0800
Subject: [PATCH] u

---
 proxy/proxy_io.go | 8 ++++----
 proxy/proxy_l.go  | 4 ++--
 proxy/proxy_r.go  | 2 +-
 tunnel/local.go   | 6 +++---
 4 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/proxy/proxy_io.go b/proxy/proxy_io.go
index bda0158..0f25128 100644
--- a/proxy/proxy_io.go
+++ b/proxy/proxy_io.go
@@ -11,9 +11,9 @@ import (
 func stunT2QProcess1(tc net.Conn, qc quic.Stream, stun_quic_conn quic.Connection) {
 	for {
 		if n, err := io.Copy(tc, qc); n == 0 || err != nil {
-			log.Printf("stunT2QProcess1 tcp close: %v==>%v\n", tc.RemoteAddr(), tc.LocalAddr())
+			log.Printf("stunT2QProcess1 tcp close: %v ==> %v\n", tc.RemoteAddr(), tc.LocalAddr())
 			tc.Close()
-			log.Printf("stunT2QProcess1 quic stream close: %v, %v==>%v\n", qc.StreamID(), stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
+			log.Printf("stunT2QProcess1 quic stream close: %v, %v ==> %v\n", qc.StreamID(), stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
 			qc.Close()
 			break
 		}
@@ -23,9 +23,9 @@ func stunT2QProcess1(tc net.Conn, qc quic.Stream, stun_quic_conn quic.Connection
 func stunQ2TProcess1(qc quic.Stream, tc net.Conn, stun_quic_conn quic.Connection) {
 	for {
 		if n, err := io.Copy(qc, tc); n == 0 || err != nil {
-			log.Printf("stunQ2TProcess1 tcp close: %v==>%v\n", tc.RemoteAddr(), tc.LocalAddr())
+			log.Printf("stunQ2TProcess1 tcp close: %v ==> %v\n", tc.RemoteAddr(), tc.LocalAddr())
 			tc.Close()
-			log.Printf("stunQ2TProcess1 quic stream close: %v, %v==>%v\n", qc.StreamID(), stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
+			log.Printf("stunQ2TProcess1 quic stream close: %v, %v ==> %v\n", qc.StreamID(), stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
 			qc.Close()
 			break
 		}
diff --git a/proxy/proxy_l.go b/proxy/proxy_l.go
index 08a4567..88019b2 100644
--- a/proxy/proxy_l.go
+++ b/proxy/proxy_l.go
@@ -14,10 +14,10 @@ func ProcessProxyClient(listener net.Listener, stun_quic_conn quic.Connection) {
 	for {
 		new_tcp_conn, err := listener.Accept()
 		if err == nil {
-			log.Printf("ProcessProxyClient listener.Accept: %v==>%v\n", new_tcp_conn.RemoteAddr(), new_tcp_conn.LocalAddr())
+			log.Printf("ProcessProxyClient listener.Accept: %v ==> %v\n", new_tcp_conn.RemoteAddr(), new_tcp_conn.LocalAddr())
 			new_quic_stream, err := stun_quic_conn.OpenStreamSync(context.Background())
 			if err == nil {
-				log.Printf("ProcessProxyClient stun_quic_conn.OpenStreamSync: %v==>%v\n", stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
+				log.Printf("ProcessProxyClient stun_quic_conn.OpenStreamSync: %v ==> %v\n", stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
 				go stunT2QProcess1(new_tcp_conn, new_quic_stream, stun_quic_conn)
 				go stunQ2TProcess1(new_quic_stream, new_tcp_conn, stun_quic_conn)
 				continue
diff --git a/proxy/proxy_r.go b/proxy/proxy_r.go
index b99af27..c6f1b61 100644
--- a/proxy/proxy_r.go
+++ b/proxy/proxy_r.go
@@ -19,7 +19,7 @@ func ProcessProxyServer(addr string, stun_quic_conn quic.Connection) {
 	for {
 		new_quic_stream, err := stun_quic_conn.AcceptStream(context.Background())
 		if err == nil {
-			log.Printf("ProcessProxyServer new_quic_conn.AcceptStream: %v==>%v\n", stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
+			log.Printf("ProcessProxyServer new_quic_conn.AcceptStream: %v ==> %v\n", stun_quic_conn.RemoteAddr(), stun_quic_conn.LocalAddr())
 			new_tcp_conn, err := net.Dial("tcp", addr)
 			if err == nil {
 				go stunT2QProcess1(new_tcp_conn, new_quic_stream, stun_quic_conn)
diff --git a/tunnel/local.go b/tunnel/local.go
index 3537154..9b85a06 100644
--- a/tunnel/local.go
+++ b/tunnel/local.go
@@ -44,7 +44,7 @@ func (c *TunnelClient) process_quic(conn *net.UDPConn, remoteAddr *net.UDPAddr)
 	listener, err := quic.Listen(conn, tls2.GetServerTLSConfig(), nil)
 	tools.AssertErrorToNilf("process_quic quic.Listen: %v", err)
 
-	log.Printf("process_quic conn.WriteToUDP: %v==>%v\n", conn.LocalAddr(), c.remote_addr)
+	log.Printf("process_quic conn.WriteToUDP: %v ==> %v\n", conn.LocalAddr(), c.remote_addr)
 	if _, err := conn.WriteToUDP(c.SendData, c.remote_addr); err != nil {
 		log.Printf("process_quic conn.WriteToUDP: %v\n", err)
 		return
@@ -54,11 +54,11 @@ func (c *TunnelClient) process_quic(conn *net.UDPConn, remoteAddr *net.UDPAddr)
 	new_quic_conn, err := listener.Accept(context.Background())
 	tools.AssertErrorToNilf("process_server5 listener.Accept: %v", err)
 
-	log.Printf("process_server5 quic.AcceptStream: %v==>%v\n", new_quic_conn.RemoteAddr(), new_quic_conn.LocalAddr())
+	log.Printf("process_server5 quic.AcceptStream: %v ==> %v\n", new_quic_conn.RemoteAddr(), new_quic_conn.LocalAddr())
 	new_quic_stream, err := new_quic_conn.AcceptStream(context.Background())
 	tools.AssertErrorToNilf("process_server5 new_quic_conn.AcceptStream: %v", err)
 
-	log.Printf("process_quic new_quic_stream.Read: %v==>%v\n", new_quic_conn.RemoteAddr(), new_quic_conn.LocalAddr())
+	log.Printf("process_quic new_quic_stream.Read: %v ==> %v\n", new_quic_conn.RemoteAddr(), new_quic_conn.LocalAddr())
 	//new_quic_stream.SetDeadline(time.Now().Add(30 * time.Second))
 	if n, err := new_quic_stream.Read(c.RecvData); err == nil && n > 0 {
 		//new_quic_stream.SetDeadline(time.Time{})