Repository: ignite Updated Branches: refs/heads/ignite-2004 907cb2503 -> e97718427
IGNITE-2004 WIP Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e9771842 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e9771842 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e9771842 Branch: refs/heads/ignite-2004 Commit: e977184275c2dbb3709071427381580c1bba24f2 Parents: 907cb25 Author: nikolay_tikhonov <[email protected]> Authored: Wed Apr 13 17:05:25 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Wed Apr 13 17:05:25 2016 +0300 ---------------------------------------------------------------------- .../CacheContinuousQueryOperationFromCallbackTest.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e9771842/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 e7dc108..8f2de16 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 @@ -89,6 +89,9 @@ public class CacheContinuousQueryOperationFromCallbackTest extends GridCommonAbs public static final int ITERATION_CNT = 20; /** */ + public static final int SYSTEM_POOL_SIZE = 10; + + /** */ private boolean client; /** */ @@ -98,6 +101,8 @@ public class CacheContinuousQueryOperationFromCallbackTest extends GridCommonAbs @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(gridName); + cfg.setSystemThreadPoolSize(SYSTEM_POOL_SIZE); + ((TcpDiscoverySpi)cfg.getDiscoverySpi()).setIpFinder(ipFinder); ((TcpCommunicationSpi)cfg.getCommunicationSpi()).setSharedMemoryPort(-1); @@ -263,7 +268,7 @@ public class CacheContinuousQueryOperationFromCallbackTest extends GridCommonAbs final AtomicInteger cbCntr = new AtomicInteger(0); - final int threadCnt = IgniteConfiguration.DFLT_SYSTEM_CORE_THREAD_CNT * 2; + final int threadCnt = SYSTEM_POOL_SIZE * 2; for (int idx = 0; idx < NODES; idx++) { Set<T2<QueryTestKey, QueryTestValue>> evts = Collections.
