set write timeout only

This commit is contained in:
xtaci
2023-02-14 20:15:44 +08:00
parent 5e66fda554
commit f8f99c6782
-5
View File
@@ -321,11 +321,6 @@ func (s *Session) recvLoop() {
}
}
// set timeout conn
if tconn, ok := s.conn.(interface{ SetReadDeadline(t time.Time) error }); ok {
tconn.SetReadDeadline(time.Now().Add(s.config.KeepAliveTimeout))
}
// read header first
if _, err := io.ReadFull(s.conn, hdr[:]); err == nil {
atomic.StoreInt32(&s.dataReady, 1)