diff --git a/protocol/grpc/client.go b/protocol/grpc/client.go index 54983fbd659a311d80580725646add5e790b91ef..0738dc75c9acae29210feb6adde1ccae772c9c0f 100644 --- a/protocol/grpc/client.go +++ b/protocol/grpc/client.go @@ -44,14 +44,9 @@ type Client struct { // NewClient ... func NewClient(url common.URL) *Client { - var ( - conn *grpc.ClientConn - err error - tracer opentracing.Tracer - ) // if global trace instance was set , it means trace function enabled. If not , will return Nooptracer - tracer = opentracing.GlobalTracer() - conn, err = grpc.Dial(url.Location, grpc.WithInsecure(), grpc.WithBlock(), + tracer := opentracing.GlobalTracer() + conn, err := grpc.Dial(url.Location, grpc.WithInsecure(), grpc.WithBlock(), grpc.WithUnaryInterceptor( otgrpc.OpenTracingClientInterceptor(tracer, otgrpc.LogPayloads()))) if err != nil { diff --git a/protocol/grpc/server.go b/protocol/grpc/server.go index b25125a06c418fd9b12d4542b6a1b13c09463d5e..3e0ee64ca85db0891c21f4821cac441b870a81bc 100644 --- a/protocol/grpc/server.go +++ b/protocol/grpc/server.go @@ -60,8 +60,8 @@ type DubboGrpcService interface { // Start ... func (s *Server) Start(url common.URL) { var ( - addr string - err error + addr string + err error ) addr = url.Location lis, err := net.Listen("tcp", addr)