joe пре 4 година
родитељ
комит
09ab63008c
3 измењених фајлова са 5 додато и 5 уклоњено
  1. 3 3
      sample/tcpws/echo_client.go
  2. 1 1
      sample/tcpws/echo_protocol.go
  3. 1 1
      sample/tcpws/echo_server.go

+ 3 - 3
sample/tcpws/echo_client.go

@@ -77,8 +77,8 @@ func start_ws_client() {
 	clt := cpn.NewWsClient(&nnet.DefHubConfig, &ClientSessionCb{}, &WsProtocol{})
 	u := url.URL{
 		Scheme: "ws",
-		Host:SERVER_ADDR,
-		Path:WS_PATH,
+		Host:   SERVER_ADDR,
+		Path:   WS_PATH,
 	}
 	err := clt.NewConnection(u.String(), 5)
 	if err != nil {
@@ -102,7 +102,7 @@ func start_ws_client() {
 				fmt.Println("ERROR:", err)
 				continue
 			}
-		}else{
+		} else {
 			fmt.Println("not found session")
 		}
 		if line == "quit" || line == "q" {

+ 1 - 1
sample/tcpws/echo_protocol.go

@@ -36,7 +36,7 @@ func (self *TcpProtocol) ReadPacket(conn nnet.IConn) (nnet.IPacket, error) {
 	}
 	pkt := &EchoPacket{}
 	dataLen := binary.LittleEndian.Uint32(buf[:4])
-	n, err = io.ReadFull(conn, buf[4:4 + dataLen])
+	n, err = io.ReadFull(conn, buf[4:4+dataLen])
 	if n != int(dataLen) {
 		fmt.Println("ERROR3:", "n != dataLen", n, "!=", dataLen)
 		return nil, nnet.ErrReadBlocking

+ 1 - 1
sample/tcpws/echo_server.go

@@ -13,7 +13,7 @@ import (
 
 const (
 	SERVER_ADDR = "127.0.0.1:3200"
-	WS_PATH = "/echo"
+	WS_PATH     = "/echo"
 )
 
 type ServerSessionCb struct {