[geode-benchmarks] branch sni updated: temporarily dial down client threads to 1

[burcham]

This is an automated email from the ASF dual-hosted git repository.

burcham pushed a commit to branch sni
in repository https://gitbox.apache.org/repos/asf/geode-benchmarks.git


The following commit(s) were added to refs/heads/sni by this push:
     new 153aec9  temporarily dial down client threads to 1
153aec9 is described below

commit 153aec97bf02ef4037aa1b85b8c1af473e6ff280
Author: Bill Burcham <bburc...@pivotal.io>
AuthorDate: Thu May 28 16:03:09 2020 -0700

    temporarily dial down client threads to 1
---
 README.md                                                              | 1 +
 .../main/java/org/apache/geode/benchmark/tasks/PrePopulateRegion.java  | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 9b02d06..aa32ff8 100644
--- a/README.md
+++ b/README.md
@@ -164,6 +164,7 @@ Also we have to provide `-DwithSsl=true` for an SNI test 
even though no SNI test
 * ~~generate `haproxy.cfg` with client-visible SNI hostnames~~
 * ~~turn on SNI via `setPoolSocketFactory` in a new `StartClientSNI` task~~
 * ~~set `--hostname-for-clients` on locator and servers for SNI~~
+* reinstate thread-per-core in `PrePopulateRegion.run()`
 * set `keyRange` back to 1e6 in `PartitionedPutBenchmark[SNI]` after 
client-server connections are healthy
 * remove `-Djavax.net.debug=all` once client-server connections are working
 * turn log-level back to "config" for server and locator 
diff --git 
a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/PrePopulateRegion.java
 
b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/PrePopulateRegion.java
index faae4d7..07589aa 100644
--- 
a/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/PrePopulateRegion.java
+++ 
b/geode-benchmarks/src/main/java/org/apache/geode/benchmark/tasks/PrePopulateRegion.java
@@ -77,7 +77,8 @@ public class PrePopulateRegion implements Task {
     logger.info("*******************************************");
     final Instant start = Instant.now();
 
-    final int numThreads = Runtime.getRuntime().availableProcessors();
+    // TODO: reinstate
+    final int numThreads = 1; //Runtime.getRuntime().availableProcessors();
     final ExecutorService threadPool = 
Executors.newFixedThreadPool(numThreads);
     final List<CompletableFuture<Void>> futures = new ArrayList<>();