This is an automated email from the ASF dual-hosted git repository. upthewaterspout pushed a commit to branch feature/redis-performance-testing in repository https://gitbox.apache.org/repos/asf/geode-benchmarks.git
commit b9c9e637ce1f66cf74c1f7d0e363909e94b5fd71 Author: Dan Smith <dasm...@vmware.com> AuthorDate: Thu Apr 1 15:32:19 2021 -0700 gradle spA --- .../java/org/apache/geode/benchmark/parameters/GeodeProperties.java | 1 - .../src/main/java/org/apache/geode/benchmark/tasks/ProcessControl.java | 2 +- .../java/org/apache/geode/benchmark/tasks/redis/JedisClientManager.java | 2 +- .../org/apache/geode/benchmark/tasks/redis/LettuceClientManager.java | 2 +- 4 files changed, 3 insertions(+), 4 deletions(-) diff --git a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/parameters/GeodeProperties.java b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/parameters/GeodeProperties.java index fa37465..bef313b 100644 --- a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/parameters/GeodeProperties.java +++ b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/parameters/GeodeProperties.java @@ -25,7 +25,6 @@ import static org.apache.geode.distributed.ConfigurationProperties.CONSERVE_SOCK import static org.apache.geode.distributed.ConfigurationProperties.DISTRIBUTED_SYSTEM_ID; import static org.apache.geode.distributed.ConfigurationProperties.ENABLE_CLUSTER_CONFIGURATION; import static org.apache.geode.distributed.ConfigurationProperties.ENABLE_TIME_STATISTICS; -import static org.apache.geode.distributed.ConfigurationProperties.LOCATOR_WAIT_TIME; import static org.apache.geode.distributed.ConfigurationProperties.LOG_DISK_SPACE_LIMIT; import static org.apache.geode.distributed.ConfigurationProperties.LOG_FILE_SIZE_LIMIT; import static org.apache.geode.distributed.ConfigurationProperties.LOG_LEVEL; diff --git a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/ProcessControl.java b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/ProcessControl.java index 57905a3..3567157 100644 --- a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/ProcessControl.java +++ b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/ProcessControl.java @@ -65,7 +65,7 @@ public class ProcessControl { format("'%s' command exited with status %d", join(" ", processBuilder.command()), exitStatus, System.getProperty("user.dir")); logger.error(msg); - if(System.nanoTime() - start > RETRY_TIMEOUT.toNanos()) { + if (System.nanoTime() - start > RETRY_TIMEOUT.toNanos()) { throw new RuntimeException(msg); } Thread.sleep(100); diff --git a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/JedisClientManager.java b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/JedisClientManager.java index 713d987..2b33700 100644 --- a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/JedisClientManager.java +++ b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/JedisClientManager.java @@ -94,7 +94,7 @@ public final class JedisClientManager implements RedisClientManager { } logger.debug(clusterInfo); } catch (Exception e) { - if(System.nanoTime() - start > CONNECT_TIMEOUT.toNanos()) { + if (System.nanoTime() - start > CONNECT_TIMEOUT.toNanos()) { throw e; } Thread.sleep(50); diff --git a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/LettuceClientManager.java b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/LettuceClientManager.java index df9b160..bc82546 100644 --- a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/LettuceClientManager.java +++ b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/redis/LettuceClientManager.java @@ -93,7 +93,7 @@ public final class LettuceClientManager implements RedisClientManager { } logger.debug(clusterInfo); } catch (Exception e) { - if(System.nanoTime() - start > CONNECT_TIMEOUT.toNanos()) { + if (System.nanoTime() - start > CONNECT_TIMEOUT.toNanos()) { throw e; } logger.info("Failed connecting.", e);