Skip to main content

[xadisk~svn:557] Changes for JIRA issue #152.

  • From: nitin_verma@...
  • To: commits@...
  • Subject: [xadisk~svn:557] Changes for JIRA issue #152.
  • Date: Tue, 15 Oct 2013 08:46:26 +0000

Project:    xadisk
Repository: svn
Revision:   557
Author:     nitin_verma
Date:       2013-10-15 08:46:24 UTC
Link:       

Log Message:
------------
Changes for JIRA issue #152.


Revisions:
----------
557


Modified Paths:
---------------
trunk/src/org/xadisk/filesystem/NativeSession.java


Diffs:
------
Index: trunk/src/org/xadisk/filesystem/NativeSession.java
===================================================================
--- trunk/src/org/xadisk/filesystem/NativeSession.java  (revision 556)
+++ trunk/src/org/xadisk/filesystem/NativeSession.java  (revision 557)
@@ -24,6 +24,7 @@
 import java.util.HashSet;
 import java.util.Iterator;
 import java.util.concurrent.locks.ReentrantLock;
+import org.xadisk.bridge.proxies.impl.RemoteConcurrencyControl;
 import org.xadisk.bridge.proxies.interfaces.XAFileInputStream;
 import org.xadisk.filesystem.exceptions.DeadLockVictimizedException;
 import org.xadisk.filesystem.exceptions.DirectoryNotEmptyException;
@@ -1095,6 +1096,9 @@
             
concurrencyControl.releaseRenamePinOnDirectories(directoriesPinnedInThisSession);
         }
 
+        if(concurrencyControl instanceof RemoteConcurrencyControl)
+            concurrencyControl.shutdown();
+
         for (Buffer buffer : transactionInMemoryBuffers) {
             if (buffer instanceof PooledBuffer) {
                 xaFileSystem.getBufferPool().checkIn((PooledBuffer) buffer);





[xadisk~svn:557] Changes for JIRA issue #152.

nitin_verma 10/15/2013
 
 
Close
loading
Please Confirm
Close