[geode] branch develop updated: GEODE-6317: Fix intermittent CacheConnectionJUnitTest failures (#3117)

[jensdeppe]

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

jensdeppe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
     new 99ed110  GEODE-6317: Fix intermittent CacheConnectionJUnitTest 
failures (#3117)
99ed110 is described below

commit 99ed1106c79dabad261a528d91f13d1ddf1c937c
Author: Jens Deppe <jde...@pivotal.io>
AuthorDate: Thu Jan 24 13:02:57 2019 -0800

    GEODE-6317: Fix intermittent CacheConnectionJUnitTest failures (#3117)
    
    
    - This test would fail intermittently on Windows with JDK11. It seems like 
the
      protobuf message is still being processed on the server, when the sending
      socket is closed by the test. Just wait to start reading something back on
      the socket before continuing.
---
 .../protocol/protobuf/v1/acceptance/CacheConnectionJUnitTest.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/geode-protobuf/src/integrationTest/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/CacheConnectionJUnitTest.java
 
b/geode-protobuf/src/integrationTest/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/CacheConnectionJUnitTest.java
index 73e3e48..8ac82b3 100644
--- 
a/geode-protobuf/src/integrationTest/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/CacheConnectionJUnitTest.java
+++ 
b/geode-protobuf/src/integrationTest/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/CacheConnectionJUnitTest.java
@@ -205,6 +205,8 @@ public class CacheConnectionJUnitTest {
     ClientProtocol.Message getMessage =
         MessageUtil.makeGetRequestMessage(serializationService, TEST_KEY, 
TEST_REGION);
     protobufProtocolSerializer.serialize(getMessage, outputStream);
+    // Make sure we're done processing the message server side.
+    socket.getInputStream().read();
 
     // make sure socket is still open
     assertFalse(socket.isClosed());