You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2019/04/24 02:47:10 UTC
[incubator-dubbo] branch master updated: do not filter thread pool
by port (#3919)
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new ddcdb29 do not filter thread pool by port (#3919)
ddcdb29 is described below
commit ddcdb299f0d8d4029c28b9ea94cb5bafb3924cfd
Author: min <z8...@gmail.com>
AuthorDate: Wed Apr 24 10:47:00 2019 +0800
do not filter thread pool by port (#3919)
---
.../src/main/java/org/apache/dubbo/monitor/dubbo/MetricsFilter.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/dubbo-monitor/dubbo-monitor-default/src/main/java/org/apache/dubbo/monitor/dubbo/MetricsFilter.java b/dubbo-monitor/dubbo-monitor-default/src/main/java/org/apache/dubbo/monitor/dubbo/MetricsFilter.java
index c613f75..90544aa 100644
--- a/dubbo-monitor/dubbo-monitor-default/src/main/java/org/apache/dubbo/monitor/dubbo/MetricsFilter.java
+++ b/dubbo-monitor/dubbo-monitor-default/src/main/java/org/apache/dubbo/monitor/dubbo/MetricsFilter.java
@@ -173,10 +173,6 @@ public class MetricsFilter implements Filter {
ExecutorService executor = (ExecutorService) entry.getValue();
if (executor instanceof ThreadPoolExecutor) {
ThreadPoolExecutor tp = (ThreadPoolExecutor) executor;
- // ignore metrcis service
- if (port.equals(this.port + "")) {
- continue;
- }
threadPoolMtricList.add(value2MetricObject("threadPool.active", tp.getActiveCount(), MetricLevel.MAJOR));
threadPoolMtricList.add(value2MetricObject("threadPool.core", tp.getCorePoolSize(), MetricLevel.MAJOR));