145    private static Span currentSpan() {
 146      Span span = Java8BytecodeBridge.currentSpan();
 147      if (span == null || !span.getSpanContext().isValid()) {
 148        return null;
 149      }
 150      return span;
 151    }
 152  
 153    private static String truncate(String v) {
 154      return v.length() > MAX_VALUE_LENGTH ? v.substring(0, MAX_VALUE_LENGTH) : v;

  30      public static void premain(String agentArgs, Instrumentation inst) {
  31          if (LOG_ID_ENABLED) {
  32              installLogIdHolder(inst);
  33          }
  34          if (MDC_ENABLED) {
  35              installMdcAdapter(inst);
  36          }
  37      }
  38  
  39      private static void installLogIdHolder(Instrumentation inst) {
  40          final String[] tokens = CLASS_TOKENS.split(",");

  25    public Result invoke(Invoker<?> invoker, Invocation invocation) {
  26      if (!(invocation instanceof RpcInvocation)) {
  27        return invoker.invoke(invocation);
  28      }
  29  
  30      RpcContext rpcContext = RpcContext.getContext();
  31      if (rpcContext.getUrl() == null || "injvm".equals(rpcContext.getUrl().getProtocol())) {
  32        return invoker.invoke(invocation);
  33      }
  34  
  35      Context parentContext = Context.current();
  36      DubboRequest request = DubboRequest.create((RpcInvocation) invocation, rpcContext);
  37  
  38      if (!instrumenter.shouldStart(parentContext, request)) {
  39        return invoker.invoke(invocation);
  40      }
  41  
  42      Context context = instrumenter.start(parentContext, request);
  43      Span span = Span.fromContext(context);
  44  
  45      try {
  46        Map<String, String> biz = BizFieldExtractor.extractBizFields(invocation.getArguments());
  47        String memberId = biz.get(BizFieldExtractor.MEMBER_ID);
  48        if (memberId != null) {
  49          span.setAttribute(BizFieldExtractor.MEMBER_ID, memberId);
  50        }
  51        String memberTransId = biz.get(BizFieldExtractor.MEMBER_TRANS_ID);
  52        if (memberTransId != null) {
  53          span.setAttribute(BizFieldExtractor.MEMBER_TRANS_ID, memberTransId);
  54        }
  55      } catch (Throwable ignored) {
  56      }
  57  
  58      Result result;
  59      try (Scope ignored = context.makeCurrent()) {
  60        result = invoker.invoke(invocation);
  61      } catch (Throwable e) {
  62        instrumenter.end(context, request, null, e);
  63        throw e;
  64      }
  65  
  66      try {
  67        if (result != null && result.getValue() != null) {
  68          String errorCode = BizFieldExtractor.extractErrorCode(result.getValue());
  69          if (errorCode != null) {

  15      Span span = Span.current();
  16      boolean recording = span != null && span.getSpanContext().isValid();
  17  
  18      if (recording) {
  19        try {
  20          Map<String, String> biz = BizFieldExtractor.extractBizFields(invocation.getArguments());
  21          String memberId = biz.get(BizFieldExtractor.MEMBER_ID);
  22          if (memberId != null) {
  23            span.setAttribute(BizFieldExtractor.MEMBER_ID, memberId);
  24          }
  25          String memberTransId = biz.get(BizFieldExtractor.MEMBER_TRANS_ID);
  26          if (memberTransId != null) {
  27            span.setAttribute(BizFieldExtractor.MEMBER_TRANS_ID, memberTransId);
  28          }
  29        } catch (Throwable ignored) {
  30        }
  31      }
  32  
  33      Result result = invoker.invoke(invocation);
  34  
  35      if (recording) {
  36        try {
  37          Object value = result == null ? null : result.getValue();
  38          if (value != null) {
  39            String errorCode = BizFieldExtractor.extractErrorCode(value);
  40            if (errorCode != null) {
  41              span.setAttribute("errorCode", errorCode);
  42            }
  43          }
  44        } catch (Throwable ignored) {
  45        }
  46      }

  72    public static void tagLogId(String value) {
  73      if (value == null || value.isEmpty()) {
  74        return;
  75      }
  76      Span span = currentSpan();
  77      if (span == null) {
  78        return;
  79      }
  80      String v = truncate(value);
  81      String spanId = span.getSpanContext().getSpanId();
  82      LogIds acc = LOG_IDS.get();
  83      if (acc == null || !acc.spanId.equals(spanId)) {
  84        acc = new LogIds(spanId);
  85        LOG_IDS.set(acc);
  86      }
  87      // logback 渲染每条日志都会调进来，而绝大多数情况下值根本没变。
  88      // 值没变就一次 span 操作都不做——setAttribute 在 SDK 里是要加锁的，
  89      // 这一层短路比改动前每条日志都写一次还省。
  90      if (v.equals(acc.last)) {
  91        return;
  92      }
  93      acc.last = v;
  94      // 保持原有语义：logId 始终是最近一次见到的值，下游已有查询不受影响
  95      span.setAttribute(LOG_ID_KEY, v);
  96  
  97      if (acc.values.contains(v) || acc.truncated) {
  98        return;
  99      }
 100      if (acc.values.size() >= MAX_LOG_IDS) {
 101        acc.truncated = true;
 102        span.setAttribute(LOG_ID_TRUNCATED_KEY, true);
 103        return;
 104      }
 105      acc.values.add(v);
 106      // 只有一个 logId 时不额外写，避免给绝大多数 span 平白多两个属性
 107      if (acc.values.size() == 1) {
 108        return;
 109      }
 110      // 每个 logId 单独一个属性：logId1 / logId2 / ...
 111      // 不用 logId.1 这种写法——OTel 的点号会被展开成嵌套 JSON，
 112      // 和标量的 logId 撞在同一个 key 上，Doris 侧会类型冲突。
 113      span.setAttribute(indexedKey(acc.values.size()), v);
 114      // 再拼一份逗号分隔的，反查「这个 logId 属于哪条链路」时一个条件就够，不用 OR 一串
 115      span.setAttribute(LOG_ID_ALL_KEY, String.join(",", acc.values));
 116    }
 117  
 118    private static AttributeKey<String> indexedKey(int index) {
 119      return attributeKey(LOG_ID + index);
 120    }
 121  
 122    public static void tagMdc(String key, String value) {
 123      if (key == null || value == null || key.isEmpty() || value.isEmpty()) {

 122    public static void tagMdc(String key, String value) {
 123      if (key == null || value == null || key.isEmpty() || value.isEmpty()) {
 124        return;
 125      }
 126      Span span = currentSpan();
 127      if (span == null) {
 128        return;
 129      }
 130      String v = truncate(value);
 131      // 值就是这个 span 自己的 trace/span id 时直接跳过：打上去和 trace_id / span_id 两列完全重复，
 132      // 而且 traceId 会命中 isLogIdKey 被当成 logId 记一遍，造出一个和业务无关的假 logId。
 133      // infra-tracing 每次请求都会 MDC.put("traceId", ...)，正好走到这里。
 134      SpanContext ctx = span.getSpanContext();
 135      if (v.equals(ctx.getTraceId()) || v.equals(ctx.getSpanId())) {
 136        return;
 137      }
 138      span.setAttribute(attributeKey(key), v);
 139      if (isLogIdKey(key)) {
 140        // 走同一条累积逻辑，否则 MDC 这条路径进来的 logId 又会退化成只留最后一个
 141        tagLogId(v);
 142      }
 143    }
 144  
 145    private static Span currentSpan() {
 146      Span span = Java8BytecodeBridge.currentSpan();
 147      if (span == null || !span.getSpanContext().isValid()) {
 148        return null;

  25    private void applyRatio(double newRatio) {
  26      if (newRatio >= 1.0d) {
  27        this.current = defaultSampler;
  28      } else if (newRatio <= 0.0d) {
  29        this.current = Sampler.parentBased(Sampler.alwaysOff());
  30      } else {
  31        this.current = Sampler.parentBased(Sampler.traceIdRatioBased(newRatio));
  32      }
  33      this.ratio = newRatio;
  34    }

  27      this.key = System.getProperty("baofoo.sampler.key", "otel.agent.sampling.ratio");
  28      this.intervalSeconds = intProp("baofoo.sampler.interval.seconds", 60);
  29      this.timeoutMillis = intProp("baofoo.sampler.timeout.seconds", 5) * 1000;

 267  func (tsp *tailSamplingSpanProcessor) setSamplingPolicyE(cfgs []PolicyCfg) error {
 268  	policies, err := tsp.loadSamplingPolicies(tsp.host, cfgs)
 269  	if err != nil {
 270  		return err
 271  	}
 272  	tsp.newPolicyChan <- newPolicyCmd{policies: policies}
 273  	return nil
 274  }
 275  

  98  	policies, err := parsePolicies(body)
  99  	if err != nil {
 100  		w.logger.Error("failed to parse sampling policies, keeping current ones", zap.Error(err))
 101  		return
 102  	}
 103  	if len(policies) == 0 {
 104  		w.logger.Warn("remote sampling policies are empty, keeping current ones")
 105  		return
 106  	}
 107  
 108  	if err := w.apply(policies); err != nil {
 109  		w.logger.Error("remote sampling policies rejected, keeping current ones", zap.Error(err))
 110  		return
 111  	}
 112  	w.lastSum = cur
 113  	w.logger.Info("sampling policies hot-reloaded", zap.Int("count", len(policies)))
 114  }
 115  

 594  		// Drain any pending configuration updates before processing the batch.
 595  		// Go's select is non-deterministic, so when both workChan and a config
 596  		// update channel are ready simultaneously, the workChan case may be
 597  		// selected before the config update is applied. By draining config
 598  		// channels here (non-blocking), we ensure that calls like
 599  		// SetMaximumTraceSizeBytes or SetSamplingPolicy are always reflected
 600  		// before the incoming traces are evaluated against them.
 601  		select {
 602  		case cmd := <-tsp.newPolicyChan:
 603  			tsp.policies = cmd.policies
 604  			tsp.logger.Debug("New policies loaded", zap.Int("policies.len", len(tsp.policies)))
 605  		default:
 606  		}
 607  		select {
 608  		case maxTraceSize := <-tsp.newTraceSizeChan:
 609  			tsp.maxTraceSizeBytes = maxTraceSize
 610  			tsp.logger.Debug("New maximum trace size loaded", zap.Uint64("size", maxTraceSize))

  64  func (p *provider) Retrieve(ctx context.Context, uri string, _ confmap.WatcherFunc) (*confmap.Retrieved, error) {
  65  	if !strings.HasPrefix(uri, schemeName+":") {
  66  		return nil, fmt.Errorf("%q uri is not supported by %q provider", uri, schemeName)
  67  	}
  68  	path := strings.TrimPrefix(uri, schemeName+":")
  69  
  70  	meta := strings.TrimSpace(os.Getenv(metaEnv))
  71  	if meta == "" {
  72  		return nil, fmt.Errorf("%s must be set to the apollo config service address, e.g. http://a-config.baofoo.cn:18080", metaEnv)
  73  	}
  74  	meta = strings.TrimSuffix(meta, "/")
  75  
  76  	if err := validatePath(path); err != nil {
  77  		return nil, err
  78  	}
  79  
  80  	content, err := p.fetchContent(ctx, meta+"/configs/"+path)
  81  	if err != nil {
  82  		return nil, err
  83  	}
  84  
  85  	// content 是一段 YAML 文本，解析成 map 交给 Collector
  86  	var conf map[string]any
  87  	if err := yaml.Unmarshal([]byte(content), &conf); err != nil {
  88  		return nil, fmt.Errorf("apollo namespace %q does not contain valid yaml: %w", path, err)
  89  	}
  90  	if len(conf) == 0 {
  91  		return nil, fmt.Errorf("apollo namespace %q is empty", path)
  92  	}
  93  	return confmap.NewRetrieved(conf)
  94  }
  95  
  96  // validatePath 要求 <appId>/<cluster>/<namespace> 三段都在，
  97  // 少一段的话 Apollo 会返回 404，报错很含糊，不如提前挡掉。

  27    tail_sampling:
  28      # 收到某条 trace 的第一个 span 后，等待多久做判定。
  29      # 等待期间该 trace 的所有 span 驻留内存。
  30      # 应大于绝大多数请求的耗时，否则慢请求会在结束前被判定。
  31      decision_wait: 10s
  32      # 内存中同时保留的 trace 数上限，环形缓冲。
  33      # 超出后最早的 trace 会被挤出，表现为链路残缺。
  34      # 内存占用约等于 num_traces × 每条 trace 的平均 span 数。
  35      num_traces: 50000
  36      # 预估的每秒新增 trace 数，用于内部结构预分配。
  37      expected_new_traces_per_sec: 100
  38  
  39      # 从 Apollo 拉取策略并热替换（本地二开功能）。
  40      # 修改策略后无需重启容器，其余配置项的修改仍需重启。
  41      policy_source:

  81        if [ $start_type = "jar" ];then
  82           echo "is is jar"
  83           java \
  84               -XX:+UseContainerSupport -XX:InitialRAMPercentage=30.0 -XX:MaxRAMPercentage=70.0 -Xss256k -XX:MetaspaceSize=128m \
  85               -XX:+UseG1GC -XX:MaxGCPauseMillis=200 \
  86               -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -Xloggc:/tmp/jvm.log -XX:+HeapDumpOnOutOfMemoryError \
  87               -Djute.maxbuffer=666666666 \
  88               -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=4445 \
  89               -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false \
  90               -javaagent:/pinpoint-agent/skywalking-agent/skywalking-agent.jar \
  91               -Dskywalking.agent.service_name=${PROJECT_NAME} \
  92               -Dskywalking.plugin.kafka.bootstrap_servers=10.254.166.138:9092 \
  93               -XX:HeapDumpPath=/tmp/heapdump.hprof \
  94               -jar /data/appdeploy/${PROJECT_JAR} > $JETTY_LOGS/$PROJECT_NAME.log
  95        fi