diff --git a/lib/mux/mux.go b/lib/mux/mux.go index 02b017a..ae9f335 100644 --- a/lib/mux/mux.go +++ b/lib/mux/mux.go @@ -34,6 +34,7 @@ type Mux struct { func NewMux(c net.Conn, connType string) *Mux { //c.(*net.TCPConn).SetReadBuffer(0) //c.(*net.TCPConn).SetWriteBuffer(0) + _ = c.SetDeadline(time.Time{}) m := &Mux{ conn: c, connMap: NewConnMap(), @@ -173,7 +174,7 @@ func (s *Mux) ping() { s.sendInfo(common.MUX_PING_FLAG, common.MUX_PING, now) // send the ping flag and get the latency first ticker := time.NewTicker(time.Second * 5) - defer ticker.Stop() + defer ticker.Stop() for { if s.IsClose { break @@ -198,7 +199,7 @@ func (s *Mux) ping() { } atomic.AddUint32(&s.pingOk, 1) } - return + return }() }