Repository: incubator-ignite Updated Branches: refs/heads/ignite-51 2168c9424 -> af7cc24b7
# ignite-51 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/af7cc24b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/af7cc24b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/af7cc24b Branch: refs/heads/ignite-51 Commit: af7cc24b7829e8b13337f69f342b2d2a76e8c6c1 Parents: 2168c94 Author: sboikov <sboi...@gridgain.com> Authored: Fri Mar 6 13:40:44 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Mar 6 13:40:44 2015 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/internal/util/F0.java | 31 +++++++++++++++++++- 1 file changed, 30 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/af7cc24b/modules/core/src/main/java/org/apache/ignite/internal/util/F0.java ---------------------------------------------------------------------- diff --git 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 index a7faa0a..859077b 100644 --- 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 @@ -157,6 +157,22 @@ 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); + } + } + } }); } @@ -184,12 +200,25 @@ public class F0 { if (p != null && !p.apply(e)) return false; - for (CacheEntryPredicate p : ps) + for (CacheEntryPredicate p : ps) { if (p != null && !p.apply(e)) return false; + } 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); + } + } }); }
