diff --git a/third-party/thrift/src/thrift/lib/go/thrift/header_server.go b/third-party/thrift/src/thrift/lib/go/thrift/header_server.go index 6763a89f5fb74..3d4abb6d916e4 100644 --- a/third-party/thrift/src/thrift/lib/go/thrift/header_server.go +++ b/third-party/thrift/src/thrift/lib/go/thrift/header_server.go @@ -83,7 +83,7 @@ func (p *headerServer) acceptLoop(ctx context.Context) error { go func(ctx context.Context, conn net.Conn) { ctx = p.connContext(ctx, conn) if err := p.processRequests(ctx, conn); err != nil { - p.log.Printf("error processing request from %s: %s", conn.RemoteAddr().String(), err) + p.log.Printf("error processing request from %s: %s\n", conn.RemoteAddr(), err) } }(ctx, conn) } diff --git a/third-party/thrift/src/thrift/lib/go/thrift/rocket_server_transport.go b/third-party/thrift/src/thrift/lib/go/thrift/rocket_server_transport.go index 11fa624e7b56c..9371cb5ba044c 100644 --- a/third-party/thrift/src/thrift/lib/go/thrift/rocket_server_transport.go +++ b/third-party/thrift/src/thrift/lib/go/thrift/rocket_server_transport.go @@ -107,28 +107,28 @@ func (r *rocketServerTransport) processRequests(ctx context.Context, conn net.Co processor := newRocketUpgradeProcessor(r.processor) headerProtocol, err := NewHeaderProtocol(conn) if err != nil { - r.log.Printf("thrift: error constructing header protocol from %s: %s", conn.RemoteAddr().String(), err) + r.log.Printf("thrift: error constructing header protocol from %s: %s\n", conn.RemoteAddr(), err) return } if err := r.processHeaderRequest(ctx, headerProtocol, processor); err != nil { - r.log.Printf("thrift: error processing request from %s: %s", conn.RemoteAddr().String(), err) + r.log.Printf("thrift: error processing request from %s: %s\n", conn.RemoteAddr(), err) return } if processor.upgraded { r.processRocketRequests(ctx, conn) } else { if err := r.processHeaderRequests(ctx, headerProtocol, processor); err != nil { - r.log.Printf("thrift: error processing request from %s: %s", conn.RemoteAddr().String(), err) + r.log.Printf("thrift: error processing request from %s: %s\n", conn.RemoteAddr(), err) } } case TransportIDHeader: headerProtocol, err := NewHeaderProtocol(conn) if err != nil { - r.log.Printf("thrift: error constructing header protocol from %s: %s", conn.RemoteAddr().String(), err) + r.log.Printf("thrift: error constructing header protocol from %s: %s\n", conn.RemoteAddr(), err) return } if err := r.processHeaderRequests(ctx, headerProtocol, r.processor); err != nil { - r.log.Printf("thrift: error processing request from %s: %s", conn.RemoteAddr().String(), err) + r.log.Printf("thrift: error processing request from %s: %s\n", conn.RemoteAddr(), err) } } }