You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/02/01 09:01:48 UTC
ignite git commit: IGNITE-2513: Fix.
Repository: ignite
Updated Branches:
refs/heads/ignite-2513 [created] 72b613110
IGNITE-2513: Fix.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/72b61311
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/72b61311
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/72b61311
Branch: refs/heads/ignite-2513
Commit: 72b6131102e45867733baee8f5dbd4304eb463c3
Parents: 5500a18
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Mon Feb 1 11:01:38 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Mon Feb 1 11:01:38 2016 +0300
----------------------------------------------------------------------
.../org/apache/ignite/internal/binary/GridBinaryMarshaller.java | 5 +----
.../internal/processors/cache/transactions/IgniteTxManager.java | 2 +-
.../ignite/internal/processors/task/GridTaskProcessor.java | 2 +-
.../marshaller/optimized/OptimizedObjectStreamRegistry.java | 4 ++--
.../internal/processors/query/h2/opt/GridH2IndexBase.java | 5 +----
.../internal/processors/query/h2/opt/GridH2TreeIndex.java | 2 +-
6 files changed, 7 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/72b61311/modules/core/src/main/java/org/apache/ignite/internal/binary/GridBinaryMarshaller.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/binary/GridBinaryMarshaller.java b/modules/core/src/main/java/org/apache/ignite/internal/binary/GridBinaryMarshaller.java
index b4f4291..da43558 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/GridBinaryMarshaller.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/GridBinaryMarshaller.java
@@ -316,10 +316,7 @@ public class GridBinaryMarshaller {
* @param oldCtx Old binary context.
*/
private static void popContext(@Nullable BinaryContext oldCtx) {
- if (oldCtx == null)
- BINARY_CTX.remove();
- else
- BINARY_CTX.set(oldCtx);
+ BINARY_CTX.set(oldCtx);
}
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/72b61311/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
index 7a3b8ff..3e43726 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
@@ -644,7 +644,7 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter {
*/
public boolean setTxTopologyHint(@Nullable AffinityTopologyVersion topVer) {
if (topVer == null)
- txTop.remove();
+ txTop.set(null);
else {
if (txTop.get() == null) {
txTop.set(topVer);
http://git-wip-us.apache.org/repos/asf/ignite/blob/72b61311/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java
index b8d1d78..2a2e3fd 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java
@@ -486,7 +486,7 @@ public class GridTaskProcessor extends GridProcessorAdapter {
map = EMPTY_ENUM_MAP;
else
// Reset thread-local context.
- thCtx.remove();
+ thCtx.set(null);
Long timeout = (Long)map.get(TC_TIMEOUT);
http://git-wip-us.apache.org/repos/asf/ignite/blob/72b61311/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectStreamRegistry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectStreamRegistry.java b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectStreamRegistry.java
index e0e4872..d7d0209 100644
--- a/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectStreamRegistry.java
+++ b/modules/core/src/main/java/org/apache/ignite/marshaller/optimized/OptimizedObjectStreamRegistry.java
@@ -95,7 +95,7 @@ class OptimizedObjectStreamRegistry {
holder.releaseOut();
if (pool != null) {
- holders.remove();
+ holders.set(null);
boolean b = pool.offer(holder);
@@ -117,7 +117,7 @@ class OptimizedObjectStreamRegistry {
holder.releaseIn();
if (pool != null) {
- holders.remove();
+ holders.set(null);
boolean b = pool.offer(holder);
http://git-wip-us.apache.org/repos/asf/ignite/blob/72b61311/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
index 39664ff..fe90dec 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
@@ -59,10 +59,7 @@ public abstract class GridH2IndexBase extends BaseIndex {
* @param fs Filters.
*/
public static void setFiltersForThread(IndexingQueryFilter fs) {
- if (fs == null)
- filters.remove();
- else
- filters.set(fs);
+ filters.set(fs);
}
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/72b61311/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2TreeIndex.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2TreeIndex.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2TreeIndex.java
index 28adeee..2c95b66 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2TreeIndex.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2TreeIndex.java
@@ -187,7 +187,7 @@ public class GridH2TreeIndex extends GridH2IndexBase implements Comparator<GridS
ConcurrentNavigableMap<GridSearchRowPointer, GridH2Row> s = snapshot.get();
- snapshot.remove();
+ snapshot.set(null);
if (s instanceof Closeable)
U.closeQuiet((Closeable)s);