Skip to content

Y
ygopro-proxy
Commit 625a7061 authored by Chunchi Che's avatar Chunchi Che
Browse files
Options

update log

parent ab41ee07
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
proxy.go
View file @ 625a7061
...@@ -37,7 +37,7 @@ func ygoEndpoint(w http.ResponseWriter, r *http.Request) { ...@@ -37,7 +37,7 @@ func ygoEndpoint(w http.ResponseWriter, r *http.Request) {
tcp, err := net.Dial("tcp", "127.0.0.1"+PROXY_PORT) tcp, err := net.Dial("tcp", "127.0.0.1"+PROXY_PORT)
if err != nil { if err != nil {
log.Fatal("Connect tcp server error: ", err) log.Fatal(err)
} }
log.Println("Tcp connected") log.Println("Tcp connected")
...@@ -54,7 +54,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) { ...@@ -54,7 +54,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) {
for { for {
messageType, buffer, err := ws.ReadMessage() messageType, buffer, err := ws.ReadMessage()
if err != nil { if err != nil {
log.Println("Websocket read message error: ", err) log.Println(err)
break break
} }
...@@ -71,7 +71,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) { ...@@ -71,7 +71,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) {
_, err = (*tcp).Write(buffer) _, err = (*tcp).Write(buffer)
if err != nil { if err != nil {
log.Fatal("Tcp send message error: ", err) log.Fatal(err)
break break
} }
} }
...@@ -102,7 +102,7 @@ func tcpProxy(tcp *net.Conn, ws *websocket.Conn, wg *sync.WaitGroup) { ...@@ -102,7 +102,7 @@ func tcpProxy(tcp *net.Conn, ws *websocket.Conn, wg *sync.WaitGroup) {
err = ws.WriteMessage(websocket.BinaryMessage, buffer) err = ws.WriteMessage(websocket.BinaryMessage, buffer)
if err != nil { if err != nil {
log.Fatal("Websocket send message error: ", err) log.Fatal(err)
break break
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment