[geode] 12/12: spA

[bross]

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

bross pushed a commit to branch support/1.12
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 5d1803ac03ed3216a78ccf39555a122cd49ff513
Author: Sarah <sab...@pivotal.io>
AuthorDate: Fri Apr 9 16:49:32 2021 -0400

    spA
---
 .../apache/geode/session/tests/CargoTestBase.java   | 21 ++++++++++++++-------
 1 file changed, 14 insertions(+), 7 deletions(-)

diff --git 
a/geode-assembly/src/distributedTest/java/org/apache/geode/session/tests/CargoTestBase.java
 
b/geode-assembly/src/distributedTest/java/org/apache/geode/session/tests/CargoTestBase.java
index f9f866d..8bb1949 100644
--- 
a/geode-assembly/src/distributedTest/java/org/apache/geode/session/tests/CargoTestBase.java
+++ 
b/geode-assembly/src/distributedTest/java/org/apache/geode/session/tests/CargoTestBase.java
@@ -171,7 +171,8 @@ public abstract class CargoTestBase {
 
     client.setPort(Integer.parseInt(manager.getContainerPort(0)));
     Client.Response resp = client.get(null);
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(null, "", resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(null, "", 
resp.getSessionCookie()));
   }
 
   /**
@@ -187,7 +188,8 @@ public abstract class CargoTestBase {
 
     client.setPort(Integer.parseInt(manager.getContainerPort(0)));
     Client.Response resp = client.set(key, value);
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(key, value, resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(key, value, 
resp.getSessionCookie()));
   }
 
   /**
@@ -208,7 +210,8 @@ public abstract class CargoTestBase {
     manager.stopContainer(0);
     manager.removeContainer(0);
 
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(key, value, resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(key, value, 
resp.getSessionCookie()));
 
     checkLogs();
   }
@@ -251,7 +254,8 @@ public abstract class CargoTestBase {
 
     client.setPort(Integer.parseInt(manager.getContainerPort(0)));
     Client.Response resp = client.set(key, value);
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(key, value, resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(key, value, 
resp.getSessionCookie()));
     client.setMaxInactive(1); // max inactive time is 1 second. Lets wait a 
second.
     Thread.sleep(2000);
 
@@ -353,7 +357,8 @@ public abstract class CargoTestBase {
 
     client.setPort(Integer.parseInt(manager.getContainerPort(0)));
     Client.Response resp = client.set(key, value);
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(key, value, resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(key, value, 
resp.getSessionCookie()));
     client.setPort(Integer.parseInt(manager.getContainerPort(0)));
     client.remove(key);
 
@@ -376,7 +381,8 @@ public abstract class CargoTestBase {
     client.setPort(Integer.parseInt(manager.getContainerPort(0)));
     Client.Response resp = client.set(key, value);
 
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(key, value, resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(key, value, 
resp.getSessionCookie()));
     int numContainers = manager.numContainers();
     // Add and start new container
     manager.addContainer(install);
@@ -385,7 +391,8 @@ public abstract class CargoTestBase {
     manager.startAllInactiveContainers();
     // Check that a container was added
     assertEquals(numContainers + 1, manager.numContainers());
-    GeodeAwaitility.await().untilAsserted(() -> 
getKeyValueDataOnAllClients(key, value, resp.getSessionCookie()));
+    GeodeAwaitility.await()
+        .untilAsserted(() -> getKeyValueDataOnAllClients(key, value, 
resp.getSessionCookie()));
   }
 
   @Test