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/servicecomb-java-chassis.git


The following commit(s) were added to refs/heads/master by this push:
     new 6e2df7eaf [SCB-2622] Use math api instead of manual calculate (#3159)
6e2df7eaf is described below

commit 6e2df7eafbdcd7609c2e97cb55f0efe4f69ddf45
Author: ZhangJian He <[email protected]>
AuthorDate: Thu Jun 30 09:14:37 2022 +0800

    [SCB-2622] Use math api instead of manual calculate (#3159)
---
 .../servicecomb/service/center/client/ServiceCenterClientTest.java   | 1 -
 .../foundation/vertx/stream/OutputStreamToWriteStream.java           | 2 +-
 .../huaweicloud/dashboard/monitor/data/MonitorConstant.java          | 5 +----
 .../apache/servicecomb/transport/common/TransportConfigUtils.java    | 2 +-
 4 files changed, 3 insertions(+), 7 deletions(-)

diff --git 
a/clients/service-center-client/src/test/java/org/apache/servicecomb/service/center/client/ServiceCenterClientTest.java
 
b/clients/service-center-client/src/test/java/org/apache/servicecomb/service/center/client/ServiceCenterClientTest.java
index 79566fed9..0c2abfbd1 100755
--- 
a/clients/service-center-client/src/test/java/org/apache/servicecomb/service/center/client/ServiceCenterClientTest.java
+++ 
b/clients/service-center-client/src/test/java/org/apache/servicecomb/service/center/client/ServiceCenterClientTest.java
@@ -487,7 +487,6 @@ public class ServiceCenterClientTest {
     boolean result = serviceCenterClient
         .updateServiceSchemaContext("111", new SchemaInfo());
 
-    Assertions.assertNotNull(result);
     Assertions.assertTrue(result);
   }
 }
diff --git 
a/foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/stream/OutputStreamToWriteStream.java
 
b/foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/stream/OutputStreamToWriteStream.java
index 464b1411b..95ea0b507 100644
--- 
a/foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/stream/OutputStreamToWriteStream.java
+++ 
b/foundations/foundation-vertx/src/main/java/org/apache/servicecomb/foundation/vertx/stream/OutputStreamToWriteStream.java
@@ -141,7 +141,7 @@ public class OutputStreamToWriteStream implements 
WriteStream<Buffer>, AsyncClos
 
   @Override
   public WriteStream<Buffer> setWriteQueueMaxSize(int maxSize) {
-    this.maxBuffers = maxSize < SMALLEST_MAX_BUFFERS ? SMALLEST_MAX_BUFFERS : 
maxSize;
+    this.maxBuffers = Math.max(maxSize, SMALLEST_MAX_BUFFERS);
     this.drainMark = maxBuffers / 2;
     return this;
   }
diff --git 
a/huawei-cloud/dashboard/src/main/java/org/apache/servicecomb/huaweicloud/dashboard/monitor/data/MonitorConstant.java
 
b/huawei-cloud/dashboard/src/main/java/org/apache/servicecomb/huaweicloud/dashboard/monitor/data/MonitorConstant.java
index eb3adf4ba..9bf37e298 100644
--- 
a/huawei-cloud/dashboard/src/main/java/org/apache/servicecomb/huaweicloud/dashboard/monitor/data/MonitorConstant.java
+++ 
b/huawei-cloud/dashboard/src/main/java/org/apache/servicecomb/huaweicloud/dashboard/monitor/data/MonitorConstant.java
@@ -119,10 +119,7 @@ public class MonitorConstant {
     DynamicIntProperty property = DynamicPropertyFactory.getInstance().
         getIntProperty("servicecomb.monitor.client.interval", 
DEFAULT_INTERVAL);
     int val = property.getValue();
-    if (val < MIN_INTERVAL_MILLISECONDS) {
-      return MIN_INTERVAL_MILLISECONDS;
-    }
-    return val;
+    return Math.max(val, MIN_INTERVAL_MILLISECONDS);
   }
 
   public static Boolean isProxyEnable() {
diff --git 
a/transports/transport-common/src/main/java/org/apache/servicecomb/transport/common/TransportConfigUtils.java
 
b/transports/transport-common/src/main/java/org/apache/servicecomb/transport/common/TransportConfigUtils.java
index 2278fb69a..29a7b9533 100644
--- 
a/transports/transport-common/src/main/java/org/apache/servicecomb/transport/common/TransportConfigUtils.java
+++ 
b/transports/transport-common/src/main/java/org/apache/servicecomb/transport/common/TransportConfigUtils.java
@@ -42,7 +42,7 @@ public final class TransportConfigUtils {
     }
 
     // default value
-    count = Runtime.getRuntime().availableProcessors() > 8 ? 8 : 
Runtime.getRuntime().availableProcessors();
+    count = Math.min(Runtime.getRuntime().availableProcessors(), 8);
     LOGGER.info("{} not defined, set to {}.", key, count);
     return count;
   }

Reply via email to