Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id DD175200BFE for ; Mon, 16 Jan 2017 15:12:02 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id DBC3D160B30; Mon, 16 Jan 2017 14:12:02 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 25328160B57 for ; Mon, 16 Jan 2017 15:12:01 +0100 (CET) Received: (qmail 92208 invoked by uid 500); 16 Jan 2017 14:12:01 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 92113 invoked by uid 99); 16 Jan 2017 14:12:01 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Jan 2017 14:12:01 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 1E1FCDFCFB; Mon, 16 Jan 2017 14:12:01 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.apache.org Date: Mon, 16 Jan 2017 14:12:04 -0000 Message-Id: <5b346cce399444bba241ec925a99f02c@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [05/12] ignite git commit: ignite-gg-8.0.2.ea2 fix IgniteCacheP2pUnmarshallingErrorTest.testResponseMessageOnUnmarshallingFailed and IgniteCacheClientQueryReplicatedNodeRestartSelfTest.testRestarts archived-at: Mon, 16 Jan 2017 14:12:03 -0000 ignite-gg-8.0.2.ea2 fix IgniteCacheP2pUnmarshallingErrorTest.testResponseMessageOnUnmarshallingFailed and IgniteCacheClientQueryReplicatedNodeRestartSelfTest.testRestarts Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e1b84b41 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e1b84b41 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e1b84b41 Branch: refs/heads/ignite-gg-11810-1 Commit: e1b84b41bd4ae52631f17f79396d6921385c0dcc Parents: 2254d37 Author: Dmitriy Govorukhin Authored: Fri Jan 13 19:27:47 2017 +0300 Committer: Dmitriy Govorukhin Committed: Fri Jan 13 19:27:47 2017 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheAdapter.java | 2 +- .../ignite/internal/processors/cache/GridCacheMapEntry.java | 3 +-- .../internal/processors/query/h2/database/H2TreeIndex.java | 5 ++--- 3 files changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e1b84b41/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index 93270ea..2d688da 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -2180,7 +2180,7 @@ public abstract class GridCacheAdapter implements IgniteInternalCache(e); } catch (IgniteCheckedException e) { return new GridFinishedFuture<>(e); http://git-wip-us.apache.org/repos/asf/ignite/blob/e1b84b41/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java index 3363124..c1acb84 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java @@ -573,9 +573,8 @@ public abstract class GridCacheMapEntry extends GridMetadataAwareAdapter impleme val = this.val; if (val == null) { - if (isStartVersion()) { + if (isStartVersion()) val = unswap(true, false); - } } if (val != null) { http://git-wip-us.apache.org/repos/asf/ignite/blob/e1b84b41/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 31df27c..3268d9d 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 @@ -79,7 +79,7 @@ public class H2TreeIndex extends GridH2IndexBase { name = BPlusTree.treeName(name, "H2Tree"); - if (!cctx.kernalContext().clientNode()) { + if (!cctx.kernalContext().clientNode() && cctx.affinityNode()) { IgniteCacheDatabaseSharedManager dbMgr = cctx.shared().database(); RootPage page = cctx.offheap().rootPageForIndex(name); @@ -87,8 +87,7 @@ public class H2TreeIndex extends GridH2IndexBase { tree = new H2Tree(name, cctx.offheap().reuseListForIndex(name), cctx.cacheId(), dbMgr.pageMemory(), cctx.shared().wal(), cctx.offheap().globalRemoveId(), tbl.rowFactory(), page.pageId().pageId(), page.isAllocated()) { - @Override - protected int compare(BPlusIO io, ByteBuffer buf, int idx, SearchRow row) + @Override protected int compare(BPlusIO io, ByteBuffer buf, int idx, SearchRow row) throws IgniteCheckedException { return compareRows(getRow(io, buf, idx), row); }