Repository: ignite Updated Branches: refs/heads/ignite-2004 39fad6505 -> 3436e1493
IGNITE-2004 Fixed review notes. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3436e149 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3436e149 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3436e149 Branch: refs/heads/ignite-2004 Commit: 3436e149384cd9133e0640b3acd2238f872bfcac Parents: 39fad65 Author: nikolay_tikhonov <[email protected]> Authored: Wed Apr 13 14:54:44 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Wed Apr 13 14:54:44 2016 +0300 ---------------------------------------------------------------------- .../CacheContinuousQueryOperationFromCallbackTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3436e149/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryOperationFromCallbackTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryOperationFromCallbackTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryOperationFromCallbackTest.java index 2ead28a..e6cc287 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryOperationFromCallbackTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryOperationFromCallbackTest.java @@ -344,14 +344,13 @@ public class CacheContinuousQueryOperationFromCallbackTest extends GridCommonAbs if (fromLsnr) { final int expCnt = qryCntr.get() * NODES * KEYS_FROM_CALLBACK; - boolean condition = GridTestUtils.waitForCondition(new PA() { + boolean res = GridTestUtils.waitForCondition(new PA() { @Override public boolean apply() { return cbCntr.get() >= expCnt; } }, TimeUnit.SECONDS.toMillis(60)); - assertTrue("Failed to wait events [exp=" + expCnt + ", act=" + cbCntr.get() + "]", - condition); + assertTrue("Failed to wait events [exp=" + expCnt + ", act=" + cbCntr.get() + "]", res); assertEquals(expCnt, cbCntr.get());
