You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by li...@apache.org on 2019/12/03 06:18:35 UTC
[servicecomb-java-chassis] 06/14: ServerListFilterExt add switch
This is an automated email from the ASF dual-hosted git repository.
liubao pushed a commit to branch 1.3.x
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git
commit 1e8b28c74919f406b03a1a60fc4a3787fb3a75ec
Author: GuoYL <gy...@gmail.com>
AuthorDate: Fri Nov 8 12:35:03 2019 +0800
ServerListFilterExt add switch
---
.../src/main/java/org/apache/servicecomb/loadbalance/LoadBalancer.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadBalancer.java b/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadBalancer.java
index 6439cec..aced1f5 100644
--- a/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadBalancer.java
+++ b/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadBalancer.java
@@ -58,6 +58,9 @@ public class LoadBalancer {
List<ServiceCombServer> servers = invocation.getLocalContext(LoadbalanceHandler.CONTEXT_KEY_SERVER_LIST);
int serversCount = servers.size();
for (ServerListFilterExt filterExt : filters) {
+ if(!filterExt.enabled()) {
+ continue;
+ }
servers = filterExt.getFilteredListOfServers(servers, invocation);
if (servers.isEmpty() && serversCount > 0) {
LOGGER.warn("There are not servers exist after filtered by {}.", filterExt.getClass());