func (c *MConnection) flush() {
if err := c.bufWriter.Flush(); err != nil {
- log.WithFields(log.Fields{"module": logModule, "error": err}).Error("MConnection flush failed")
+ log.WithFields(log.Fields{"module": logModule, "error": err}).Warn("MConnection flush failed")
}
}
return
}
if err != nil {
- log.WithFields(log.Fields{"module": logModule, "conn": c, "error": err}).Error("Connection failed @ sendRoutine")
+ log.WithFields(log.Fields{"module": logModule, "conn": c, "error": err}).Warn("Connection failed @ sendRoutine")
c.stopForError(err)
return
}