diff --git a/relay.go b/relay.go index ee74641..c84ecc3 100644 --- a/relay.go +++ b/relay.go @@ -264,7 +264,7 @@ func (r *Relay) handleNewStream(s network.Stream) { case pb.CircuitRelay_CAN_HOP: r.handleCanHop(s, &msg) default: - log.Warningf("unexpected relay handshake: %d", msg.GetType()) + log.Warnf("unexpected relay handshake: %d", msg.GetType()) r.handleError(s, pb.CircuitRelay_MALFORMED_MESSAGE) } } @@ -280,7 +280,7 @@ func (r *Relay) handleHopStream(s network.Stream, msg *pb.CircuitRelay) { defer atomic.AddInt32(&r.streamCount, -1) if (streamCount + liveHopCount) > int32(HopStreamLimit) { - log.Warning("hop stream limit exceeded; resetting stream") + log.Warn("hop stream limit exceeded; resetting stream") s.Reset() return } @@ -479,7 +479,7 @@ func (r *Relay) handleCanHop(s network.Stream, msg *pb.CircuitRelay) { } func (r *Relay) handleError(s network.Stream, code pb.CircuitRelay_Status) { - log.Warningf("relay error: %s (%d)", pb.CircuitRelay_Status_name[int32(code)], code) + log.Warnf("relay error: %s (%d)", pb.CircuitRelay_Status_name[int32(code)], code) err := r.writeResponse(s, code) if err != nil { s.Reset()