warden fix trace (#300)

5 years ago · a83992e6dd
parent 43902c3d19
commit a83992e6dd
1 changed files with 1 additions and 0 deletions
--- a/pkg/net/rpc/warden/server.go
+++ b/pkg/net/rpc/warden/server.go
@ -111,6 +111,7 @@ func (s *Server) handle() grpc.UnaryServerInterceptor {
 		var t trace.Trace
 		cmd := nmd.MD{}
 		if gmd, ok := metadata.FromIncomingContext(ctx); ok {
+			t, _ = trace.Extract(trace.GRPCFormat, gmd)
 			for key, vals := range gmd {
 				if nmd.IsIncomingKey(key) {
 					cmd[key] = vals[0]