Repository: ignite
Updated Branches:
  refs/heads/ignite-3477-test [created] a7297cd5a


tmp


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a7297cd5
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a7297cd5
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a7297cd5

Branch: refs/heads/ignite-3477-test
Commit: a7297cd5a2e0b2570f929ed266c48d238816b5e4
Parents: dd82b89
Author: sboikov <sboi...@gridgain.com>
Authored: Fri Feb 17 14:17:07 2017 +0300
Committer: sboikov <sboi...@gridgain.com>
Committed: Fri Feb 17 14:17:07 2017 +0300

----------------------------------------------------------------------
 .../query/h2/database/H2TreeIndex.java          | 21 ++++++++++----------
 1 file changed, 11 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/a7297cd5/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/H2TreeIndex.java
----------------------------------------------------------------------
diff --git 
a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/H2TreeIndex.java
 
b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/H2TreeIndex.java
index 2e9940b..d8b855c 100644
--- 
a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/H2TreeIndex.java
+++ 
b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/database/H2TreeIndex.java
@@ -56,7 +56,7 @@ public class H2TreeIndex extends GridH2IndexBase {
     public static final int IGNITE_MAX_INDEX_PAYLOAD_SIZE_DEFAULT = 0;
 
     /** PageContext for use in IO's */
-    private static final ThreadLocal<H2TreeIndex> currentIndex = new 
ThreadLocal<>();
+    //private static final ThreadLocal<H2TreeIndex> currentIndex = new 
ThreadLocal<>();
 
     /** */
     private final H2Tree tree;
@@ -205,7 +205,8 @@ public class H2TreeIndex extends GridH2IndexBase {
      * @return Tree updated in current thread.
      */
     public static H2TreeIndex getCurrentIndex() {
-        return currentIndex.get();
+        //return currentIndex.get();
+        throw new UnsupportedOperationException();
     }
 
     /**
@@ -272,7 +273,7 @@ public class H2TreeIndex extends GridH2IndexBase {
     /** {@inheritDoc} */
     @Override public GridH2Row put(GridH2Row row) {
         try {
-            currentIndex.set(this);
+            //currentIndex.set(this);
 
             return tree.put(row);
         }
@@ -280,14 +281,14 @@ public class H2TreeIndex extends GridH2IndexBase {
             throw DbException.convert(e);
         }
         finally {
-            currentIndex.remove();
+            //currentIndex.remove();
         }
     }
 
     /** {@inheritDoc} */
     @Override public boolean putx(GridH2Row row) {
         try {
-            currentIndex.set(this);
+            //currentIndex.set(this);
 
             return tree.putx(row);
         }
@@ -295,35 +296,35 @@ public class H2TreeIndex extends GridH2IndexBase {
             throw DbException.convert(e);
         }
         finally {
-            currentIndex.remove();
+            //currentIndex.remove();
         }
     }
 
     /** {@inheritDoc} */
     @Override public GridH2Row remove(SearchRow row) {
         try {
-            currentIndex.set(this);
+            //currentIndex.set(this);
             return tree.remove(row);
         }
         catch (IgniteCheckedException e) {
             throw DbException.convert(e);
         }
         finally {
-            currentIndex.remove();
+            //currentIndex.remove();
         }
     }
 
     /** {@inheritDoc} */
     @Override public void removex(SearchRow row) {
         try {
-            currentIndex.set(this);
+            //currentIndex.set(this);
             tree.removex(row);
         }
         catch (IgniteCheckedException e) {
             throw DbException.convert(e);
         }
         finally {
-            currentIndex.remove();
+            //currentIndex.remove();
         }
     }
 

Reply via email to