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));