[geode] branch feature/bruce_ssl_wip updated: disabling other tests for a short run

[bs...@apache.org]

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

bschuchardt pushed a commit to branch feature/bruce_ssl_wip
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/bruce_ssl_wip by this push:
     new ce2f783  disabling other tests for a short run
ce2f783 is described below

commit ce2f783e8c80881ce86fe0d5b2d7589b5ac57c0b
Author: Bruce Schuchardt <bs...@pivotal.io>
AuthorDate: Mon Nov 11 08:54:06 2019 -0800

    disabling other tests for a short run
---
 .../java/org/apache/geode/ClusterCommunicationsDUnitTest.java     | 8 ++++----
 .../src/main/java/org/apache/geode/internal/net/NioSslEngine.java | 2 ++
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/geode-core/src/distributedTest/java/org/apache/geode/ClusterCommunicationsDUnitTest.java b/geode-core/src/distributedTest/java/org/apache/geode/ClusterCommunicationsDUnitTest.java
index f25e61d..c98acce 100644
--- a/geode-core/src/distributedTest/java/org/apache/geode/ClusterCommunicationsDUnitTest.java
+++ b/geode-core/src/distributedTest/java/org/apache/geode/ClusterCommunicationsDUnitTest.java
@@ -145,7 +145,7 @@ public class ClusterCommunicationsDUnitTest implements Serializable {
     addIgnoredException("Remote host closed connection during handshake");
   }
 
-  @Test
+  // @Test
   public void createEntryAndVerifyUpdate() {
     int locatorPort = createLocator(getVM(0));
     for (int i = 1; i <= NUM_SERVERS; i++) {
@@ -178,7 +178,7 @@ public class ClusterCommunicationsDUnitTest implements Serializable {
     performUpdateWithLargeValue(vm1);
   }
 
-  @Test
+  // @Test
   public void receiveBigResponse() {
     invokeInEveryVM(
         () -> InternalDataSerializer.getDSFIDSerializer().registerDSFID(SERIAL_ACKED_MESSAGE,
@@ -204,7 +204,7 @@ public class ClusterCommunicationsDUnitTest implements Serializable {
     }
   }
 
-  @Test
+  // @Test
   public void performARollingUpgrade() {
     List<String> testVersions = VersionManager.getInstance().getVersionsWithoutCurrent();
     String testVersion = testVersions.get(testVersions.size() - 1);
@@ -278,7 +278,7 @@ public class ClusterCommunicationsDUnitTest implements Serializable {
       byte[] value = new byte[70000];
       Arrays.fill(value, (byte) 1);
       long start = System.currentTimeMillis();
-      for (int i = 0; i < 50000; i++) {
+      for (int i = 0; i < 50; i++) {
         cache.getRegion(regionName).put("testKey", value);
       }
       long end = System.currentTimeMillis();
diff --git a/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java b/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
index 517db72..86dbe05 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
@@ -331,6 +331,8 @@ public class NioSslEngine implements NioFilter {
     while (peerAppData.remaining() < bytes) {
       wrappedBuffer.limit(wrappedBuffer.capacity());
       stats.incAsyncThreads(1);
+      logger.info("BRUCE: reading from socket {} with receive buffer size {}",
+          Long.toHexString(channel.socket().hashCode()), channel.socket().getReceiveBufferSize());
       int amountRead = channel.read(wrappedBuffer);
       if (amountRead < 0) {
         throw new EOFException();