geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jensde...@apache.org
Subject [geode] branch develop updated: GEODE-6317: Fix intermittent CacheConnectionJUnitTest failures (#3117)
Date Thu, 24 Jan 2019 21:03:13 GMT
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 <jdeppe@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());


Mime
View raw message