}
n, err = conn.Read(buf[prev:])
if err != nil {
- c.logger.WithFields(fields).WithFields(
+ c.logger.WithFields(
+ fields,
+ ).WithFields(
c.LogFields(),
).Debug("Packet timeouted")
c.timeouted <- struct{}{}
prev += n
_, err = c.idsCache.Find(buf[:prev])
if err != nil {
- c.logger.WithFields(fields).WithFields(
+ c.logger.WithFields(
+ fields,
+ ).WithFields(
c.LogFields(),
).WithError(err).Debug("Can't find peer in ids")
continue
peer, err = hs.Client(buf[:prev])
prev = 0
if err != nil {
- c.logger.WithFields(fields).WithError(err).WithFields(
+ c.logger.WithFields(
+ fields,
+ ).WithError(
+ err,
+ ).WithFields(
c.LogFields(),
).Debug("Can't create new peer")
continue
default:
}
if prev == len(buf) {
- c.logger.WithFields(c.LogFields()).Debug("Packet timeouted")
+ c.logger.WithFields(
+ c.LogFields(),
+ ).Debug("Packet timeouted")
c.timeouted <- struct{}{}
break TransportCycle
}
}
n, err = conn.Read(buf[prev:])
if err != nil {
- c.logger.WithError(err).WithFields(c.LogFields()).Debug("Connection timeouted")
+ c.logger.WithError(
+ err,
+ ).WithFields(
+ c.LogFields(),
+ ).Debug("Connection timeouted")
c.timeouted <- struct{}{}
break TransportCycle
}