Skip to content

Commit 8c853b1

Browse files
author
奇淼(piexlmax
authored
Merge pull request #34 from piexlmax/main
fixed:grpc server traceid
2 parents a11f3bc + a297ae2 commit 8c853b1

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

core/grpc/newServer/replacement.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,12 @@ func NewServer(opt ...grpc.ServerOption) *grpc.Server {
3030
// interceptor 一元拦截器
3131
func interceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
3232
md, _ := metadata.FromIncomingContext(ctx)
33-
Traceid := md.Get("dt-traceid")[0]
3433
worker, _ := utils.NewWorker(global.AgentId)
34+
dt := md.Get("dt-traceid")
35+
var Traceid = global.TargetTraceId + "." + strconv.Itoa(global.AgentId) + ".0.0." + strconv.Itoa(int(worker.GetId()))
36+
if len(dt) != 0 {
37+
Traceid = dt[0]
38+
}
3539
four := strconv.Itoa(int(worker.GetId()))
3640
tranceids := strings.Split(Traceid, ".")
3741
tranceids[AgentId] = strconv.Itoa(global.AgentId)

0 commit comments

Comments
 (0)