|
|
|
@ -65,7 +65,7 @@ func (c *client) serve() { |
|
|
|
|
c.closing = make(chan bool) |
|
|
|
|
if onc := c.srv.OnNewConnection; onc != nil { |
|
|
|
|
if err := onc(c.rwc); err != nil { |
|
|
|
|
Logger.Printf("Erreur OnNewConnection: %s", err) |
|
|
|
|
Logger.Debugf("Error OnNewConnection: %s", err) |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
@ -120,9 +120,9 @@ func (c *client) serve() { |
|
|
|
|
messagePacket, err := c.ReadPacket() |
|
|
|
|
if err != nil { |
|
|
|
|
if opErr, ok := err.(*net.OpError); ok && opErr.Timeout() { |
|
|
|
|
Logger.Printf("Sorry client %d, i can not wait anymore (reading timeout) ! %s", c.Numero, err) |
|
|
|
|
Logger.Debugf("Sorry client %d, i can not wait anymore (reading timeout) ! %s", c.Numero, err) |
|
|
|
|
} else { |
|
|
|
|
Logger.Printf("Error readMessagePacket: %s", err) |
|
|
|
|
Logger.Debugf("Error readMessagePacket: %s", err) |
|
|
|
|
} |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
@ -131,7 +131,7 @@ func (c *client) serve() { |
|
|
|
|
message, err := messagePacket.readMessage() |
|
|
|
|
|
|
|
|
|
if err != nil { |
|
|
|
|
Logger.Printf("Error reading Message : %s\n\t%x", err.Error(), messagePacket.bytes) |
|
|
|
|
Logger.Debugf("Error reading Message : %s\n\t%x", err.Error(), messagePacket.bytes) |
|
|
|
|
continue |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|