err = errFrameTooBig
}
if err != nil {
- if err != io.EOF {
+ if err != io.EOF && ctx.Err() == nil {
log.WithError(err).Info("read error")
}
return
t0 := time.Now()
_, err = ws.Write(buf)
if err != nil {
- log.WithError(err).Error("write failed")
+ if ctx.Err() == nil {
+ log.WithError(err).Error("write failed")
+ }
return
}
log.Debug("sent")
default:
}
}
- continue
case e, ok := <-incoming.Channel():
if !ok {
return