This is an automated email from the ASF dual-hosted git repository. liubao pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-java-chassis.git
commit a64a403c38f5c09076b75a04a0aa9d1a8a8cf999 Author: liubao <bao....@huawei.com> AuthorDate: Fri Apr 13 11:18:21 2018 +0800 [SCB-481]fix typo --- .../servicecomb/qps/ProviderQpsFlowControlHandler.java | 6 +++--- .../org/apache/servicecomb/qps/QpsControllerManager.java | 12 ++++++------ 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/ProviderQpsFlowControlHandler.java b/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/ProviderQpsFlowControlHandler.java index d2ff0d8..88ee936 100644 --- a/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/ProviderQpsFlowControlHandler.java +++ b/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/ProviderQpsFlowControlHandler.java @@ -37,11 +37,11 @@ public class ProviderQpsFlowControlHandler implements Handler { return; } - String microServiceName = invocation.getContext(Const.SRC_MICROSERVICE); + String microserviceName = invocation.getContext(Const.SRC_MICROSERVICE); QpsController qpsController = - StringUtils.isEmpty(microServiceName) + StringUtils.isEmpty(microserviceName) ? qpsControllerMgr.getGlobalQpsController() - : qpsControllerMgr.getOrCreate(microServiceName, invocation); + : qpsControllerMgr.getOrCreate(microserviceName, invocation); if (isLimitNewRequest(qpsController, asyncResp)) { return; } diff --git a/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/QpsControllerManager.java b/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/QpsControllerManager.java index b2d25c1..285db7c 100644 --- a/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/QpsControllerManager.java +++ b/handlers/handler-flowcontrol-qps/src/main/java/org/apache/servicecomb/qps/QpsControllerManager.java @@ -46,10 +46,10 @@ public class QpsControllerManager { private String configKeyPrefix; - public QpsController getOrCreate(String microerviceName, Invocation invocation) { + public QpsController getOrCreate(String microserviceName, Invocation invocation) { return qualifiedNameControllerMap - .computeIfAbsent(microerviceName + SEPARATOR + invocation.getOperationMeta().getSchemaQualifiedName(), key -> { - return create(key, microerviceName, invocation); + .computeIfAbsent(microserviceName + SEPARATOR + invocation.getOperationMeta().getSchemaQualifiedName(), key -> { + return create(key, microserviceName, invocation); }); } @@ -57,11 +57,11 @@ public class QpsControllerManager { * Create relevant qpsLimit dynamicProperty and watch the configuration change. * Search and return a valid qpsController. */ - protected QpsController create(String qualifiedNameKey, String microerviceName, Invocation invocation) { + protected QpsController create(String qualifiedNameKey, String microserviceName, Invocation invocation) { // create "microservice" - createQpsControllerIfNotExist(microerviceName); + createQpsControllerIfNotExist(microserviceName); // create "microservice.schema" - createQpsControllerIfNotExist(qualifiedNameKey.substring(0, microerviceName.length() + invocation.getSchemaId().length() + 1)); + createQpsControllerIfNotExist(qualifiedNameKey.substring(0, microserviceName.length() + invocation.getSchemaId().length() + 1)); // create "microservice.schema.operation" createQpsControllerIfNotExist(qualifiedNameKey); -- To stop receiving notification emails like this one, please contact liu...@apache.org.