Merge branch 'ignite-51-client-test' into ignite-51 Conflicts: modules/core/src/main/java/org/apache/ignite/internal/util/F0.java
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/9123d479 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/9123d479 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/9123d479 Branch: refs/heads/ignite-51 Commit: 9123d47940cefe6fbaae0b385ecc57a5d83a80c0 Parents: af7cc24 2fdb49f Author: nikolay_tikhonov <ntikho...@gridgain.com> Authored: Fri Mar 6 13:59:16 2015 +0300 Committer: nikolay_tikhonov <ntikho...@gridgain.com> Committed: Fri Mar 6 13:59:16 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheContext.java | 8 ++++++ .../cache/GridCacheProjectionImpl.java | 2 +- .../org/apache/ignite/internal/util/F0.java | 28 ++++++++++++++++++++ 3 files changed, 37 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9123d479/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9123d479/modules/core/src/main/java/org/apache/ignite/internal/util/F0.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/apache/ignite/internal/util/F0.java index 859077b,cc8e967..14509e8 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/F0.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/F0.java @@@ -158,21 -159,21 +159,37 @@@ public class F0 return true; } + @Override public void entryLocked(boolean locked) { + if (p1 != null) { + for (CacheEntryPredicate p : p1) { + if (p != null) + p.entryLocked(locked); + } + } + + if (p2 != null) { + for (CacheEntryPredicate p : p2) { + if (p != null) + p.entryLocked(locked); + } + } + } ++ + @Override public void prepareMarshal(GridCacheContext ctx) throws IgniteCheckedException { + if (!e1) { + assert p1 != null; + + for (CacheEntryPredicate p : p1) + p.prepareMarshal(ctx); + } + + if (!e2) { + assert p2 != null; + + for (CacheEntryPredicate p : p2) + p.prepareMarshal(ctx); + } + } }); } @@@ -208,17 -208,16 +225,28 @@@ return true; } + @Override public void entryLocked(boolean locked) { + assert ps != null; + + if (p != null) + p.entryLocked(locked); + + for (CacheEntryPredicate p : ps) { + if (p != null) + p.entryLocked(locked); + } + } ++ + @Override public void prepareMarshal(GridCacheContext ctx) throws IgniteCheckedException { + assert ps != null; + + if (p != null) + p.prepareMarshal(ctx); + + for (CacheEntryPredicate p : ps) + if (p != null) + p.prepareMarshal(ctx); + } }); }