l := c.logger.WithField("func", logFuncPrefix+"Client.startTCP")
// initialize using a file descriptor
if c.config.FileDescriptor > 0 {
- l.WithField("fd", c.config.FileDescriptor).Debug("Connect using file descriptor")
+ l.WithField("fd", c.config.FileDescriptor).Debug("Connecting using file descriptor")
var err error
conn, err = net.FileConn(os.NewFile(
uintptr(c.config.FileDescriptor),
}
} else {
// TODO move resolution into the loop, as the name might change over time
- l.WithField("fd", c.config.RemoteAddress).Debug("Connect using TCP")
+ l.WithField("fd", c.config.RemoteAddress).Debug("Connecting using TCP")
remote, err := net.ResolveTCPAddr("tcp", c.config.RemoteAddress)
if err != nil {
c.Error <- errors.Wrapf(err, "net.ResolveTCPAdd %s", c.config.RemoteAddress)
fields,
).WithFields(
c.LogFields(),
- ).WithError(err).Debug("Can't find peer in ids")
+ ).WithError(err).Debug("Can not find peer in ids")
continue
}
peer, err = hs.Client(buf[:prev])
err,
).WithFields(
c.LogFields(),
- ).Debug("Can't create new peer")
+ ).Debug("Can not create new peer")
continue
}
c.logger.WithFields(fields).WithFields(c.LogFields()).Info("Handshake completed")
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
}