未验证 提交 93347b23 编写于 作者: wu-sheng's avatar wu-sheng 提交者: GitHub

Envoy heartbeat update bug (#2334)

上级 c2a7e8e5
......@@ -96,6 +96,7 @@ public class MetricServiceGRPCHandler extends MetricsServiceGrpc.MetricsServiceI
if (serviceInstanceId != Const.NONE) {
List<Metrics.MetricFamily> list = message.getEnvoyMetricsList();
boolean needHeartbeatUpdate = true;
for (int i = 0; i < list.size(); i++) {
counter.inc();
HistogramMetric.Timer timer = histogram.createTimer();
......@@ -123,10 +124,11 @@ public class MetricServiceGRPCHandler extends MetricsServiceGrpc.MetricsServiceI
default:
continue;
}
if (i == 0) {
if (needHeartbeatUpdate) {
// Send heartbeat
serviceInventoryRegister.heartbeat(serviceId, timestamp);
serviceInstanceInventoryRegister.heartbeat(serviceInstanceId, timestamp);
needHeartbeatUpdate = false;
}
} finally {
timer.finish();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册