You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by es...@apache.org on 2018/08/27 20:52:02 UTC
[geode] branch feature/GEODE-5624 updated: wip.
This is an automated email from the ASF dual-hosted git repository.
eshu11 pushed a commit to branch feature/GEODE-5624
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-5624 by this push:
new c19decb wip.
c19decb is described below
commit c19decb1e2ea05b7b40a265f01afc3e2f237b167
Author: eshu <es...@pivotal.io>
AuthorDate: Mon Aug 27 13:51:39 2018 -0700
wip.
---
.../geode/internal/jta/ClientServerJTAFailoverDistributedTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/geode-core/src/distributedTest/java/org/apache/geode/internal/jta/ClientServerJTAFailoverDistributedTest.java b/geode-core/src/distributedTest/java/org/apache/geode/internal/jta/ClientServerJTAFailoverDistributedTest.java
index d518153..5d60b6b 100644
--- a/geode-core/src/distributedTest/java/org/apache/geode/internal/jta/ClientServerJTAFailoverDistributedTest.java
+++ b/geode-core/src/distributedTest/java/org/apache/geode/internal/jta/ClientServerJTAFailoverDistributedTest.java
@@ -192,9 +192,9 @@ public class ClientServerJTAFailoverDistributedTest implements Serializable {
TXManagerImpl txManager = (TXManagerImpl) cache.getCacheTransactionManager();
txManager.begin();
region.put(key, newValue);
- if (hasReplicateRegion)
+ if (hasReplicateRegion) {
replicateRegion.put(key, newValue);
-
+ }
TXStateProxyImpl txStateProxy = (TXStateProxyImpl) txManager.getTXState();
ClientTXStateStub clientTXStateStub = (ClientTXStateStub) txStateProxy.getRealDeal(null, null);
clientTXStateStub.beforeCompletion();
@@ -223,8 +223,9 @@ public class ClientServerJTAFailoverDistributedTest implements Serializable {
}
if (isCommit) {
assertEquals(newValue, region.get(key));
- if (hasReplicateRegion)
+ if (hasReplicateRegion) {
assertEquals(newValue, replicateRegion.get(key));
+ }
} else {
assertEquals(value, region.get(key));
}