[geode] branch feature/GEODE-3521 updated: Modify test to use public suspend resume when testSuspendResumeOnDifferentThread

[eshu11]

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 <e...@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" <commits@geode.apache.org>'].