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:45 UTC
[incubator-skywalking] branch mesh-receiver created (now a6fbbfe)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch mesh-receiver
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git.
at a6fbbfe Make receiver more effective
This branch includes the following new commits:
new a6fbbfe Make receiver more effective
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-skywalking] 01/01: Make receiver more effective
Posted by wu...@apache.org.
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);
+ }
}
/**