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 2017/10/19 00:14:09 UTC
[geode] branch feature/GEODE-3521 updated: Modify test to use
public suspend resume when testSuspendResumeOnDifferentThread
This is an automated email from the ASF dual-hosted git repository.
eshu11 pushed a commit to branch feature/GEODE-3521
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-3521 by this push:
new 8783980 Modify test to use public suspend resume when testSuspendResumeOnDifferentThread
8783980 is described below
commit 87839805fe8096936f79cfdca7682c66e5fc2ca2
Author: eshu <es...@pivotal.io>
AuthorDate: Wed Oct 18 17:12:36 2017 -0700
Modify test to use public suspend resume when testSuspendResumeOnDifferentThread
---
.../geode/internal/cache/ClientServerTransactionDUnitTest.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/ClientServerTransactionDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/ClientServerTransactionDUnitTest.java
index 29b4674..035eb06 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/ClientServerTransactionDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/ClientServerTransactionDUnitTest.java
@@ -2435,13 +2435,14 @@ public class ClientServerTransactionDUnitTest extends RemoteTransactionDUnitTest
mgr.begin();
pr.put(custId, new Customer("name10", "address10"));
r.put(10, "value10");
- final TXStateProxy txState = mgr.pauseTransaction();
+
+ final TransactionId txId = mgr.suspend();
assertNull(pr.get(custId));
assertNull(r.get(10));
final CountDownLatch latch = new CountDownLatch(1);
Thread t = new Thread(new Runnable() {
public void run() {
- mgr.unpauseTransaction(txState);
+ mgr.resume(txId);
mgr.commit();
latch.countDown();
}
@@ -2916,7 +2917,8 @@ public class ClientServerTransactionDUnitTest extends RemoteTransactionDUnitTest
Map<CustId, Customer> m = new HashMap<CustId, Customer>();
m.put(new CustId(2), new Customer("name2", "address2"));
r.putAll(m);
- TXStateProxyImpl tx = (TXStateProxyImpl) mgr.pauseTransaction();
+ TXStateProxyImpl tx = (TXStateProxyImpl) mgr.getTXState();
+ TransactionId txId = mgr.suspend();
ClientTXStateStub txStub = (ClientTXStateStub) tx.getRealDeal(null, null);
txStub.setAfterLocalLocks(new Runnable() {
public void run() {
@@ -2928,7 +2930,7 @@ public class ClientServerTransactionDUnitTest extends RemoteTransactionDUnitTest
}
}
});
- mgr.unpauseTransaction(tx);
+ mgr.resume(txId);
mgr.commit();
}
});
--
To stop receiving notification emails like this one, please contact
['"commits@geode.apache.org" <co...@geode.apache.org>'].