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

eshu11 pushed a commit to branch feature/GEODE-5376
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-5376 by this 
push:
     new b9aa006  fix a review comment.
b9aa006 is described below

commit b9aa006b7a5421d1ba2cbfb0a79e3bdc884ea4bf
Author: eshu <[email protected]>
AuthorDate: Thu Jul 19 15:31:48 2018 -0700

    fix a review comment.
---
 geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java 
b/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java
index d9c5a05..211c801 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java
@@ -1000,7 +1000,7 @@ public class TXState implements TXStateInterface {
    * @see org.apache.geode.internal.cache.TXStateInterface#beforeCompletion()
    */
   @Override
-  public void beforeCompletion() throws SynchronizationCommitConflictException 
{
+  public synchronized void beforeCompletion() throws 
SynchronizationCommitConflictException {
     if (this.closed) {
       throw new TXManagerCancelledException();
     }
@@ -1066,7 +1066,7 @@ public class TXState implements TXStateInterface {
    * @see org.apache.geode.internal.cache.TXStateInterface#afterCompletion(int)
    */
   @Override
-  public void afterCompletion(int status) {
+  public synchronized void afterCompletion(int status) {
     this.proxy.getTxMgr().setTXState(null);
     // For commit, beforeCompletion should be called. Otherwise
     // throw FailedSynchronizationException().

Reply via email to