You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2018/10/22 03:08:46 UTC
[incubator-skywalking] 01/01: Make receiver more effective
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch mesh-receiver
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
commit a6fbbfe3124196408f4398b677d1160617f580ae
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Mon Oct 22 11:08:31 2018 +0800
Make receiver more effective
---
.../aop/server/receiver/mesh/TelemetryDataDispatcher.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
index 4dfcc4e..a56260a 100644
--- a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
+++ b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java
@@ -59,7 +59,12 @@ public class TelemetryDataDispatcher {
}
public static void preProcess(ServiceMeshMetric data) {
- CACHE.in(data);
+ ServiceMeshMetricDataDecorator decorator = new ServiceMeshMetricDataDecorator(data);
+ if (decorator.tryMetaDataRegister()) {
+ TelemetryDataDispatcher.doDispatch(decorator);
+ } else {
+ CACHE.in(data);
+ }
}
/**