Merge branch 'ignite-2004' into ignite-3004-1
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/13db6642 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/13db6642 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/13db6642 Branch: refs/heads/ignite-3004 Commit: 13db6642c7f61be1eb89e617d9fbbc2276da5c33 Parents: 735351f 021780b Author: nikolay_tikhonov <[email protected]> Authored: Thu Apr 21 10:50:57 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Thu Apr 21 10:50:57 2016 +0300 ---------------------------------------------------------------------- .../CacheContinuousAsyncQueryExample.java | 138 ++ .../datagrid/CacheContinuousQueryExample.java | 15 +- .../main/java/org/apache/ignite/Ignition.java | 19 +- .../ignite/cache/query/ContinuousQuery.java | 22 +- .../configuration/ConnectorConfiguration.java | 3 + .../configuration/IgniteConfiguration.java | 37 + .../ignite/internal/GridKernalContext.java | 8 + .../ignite/internal/GridKernalContextImpl.java | 12 + .../apache/ignite/internal/IgniteKernal.java | 3 + .../org/apache/ignite/internal/IgnitionEx.java | 76 +- .../processors/cache/CacheOperationFilter.java | 61 + .../processors/cache/GridCacheAtomicFuture.java | 5 - .../processors/cache/GridCacheEntryEx.java | 5 +- .../processors/cache/GridCacheMapEntry.java | 49 +- .../dht/atomic/GridDhtAtomicCache.java | 205 ++- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 126 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 33 +- .../GridNearAtomicAbstractUpdateFuture.java | 244 +++ .../GridNearAtomicSingleUpdateFuture.java | 645 ++++++++ .../dht/atomic/GridNearAtomicUpdateFuture.java | 1392 ++++++++---------- .../distributed/near/GridNearAtomicCache.java | 3 +- .../continuous/CacheContinuousQueryEvent.java | 7 + .../continuous/CacheContinuousQueryHandler.java | 448 ++++-- .../CacheContinuousQueryListener.java | 6 +- .../continuous/CacheContinuousQueryManager.java | 62 +- .../processors/clock/GridClockServer.java | 3 +- .../closure/GridClosureProcessor.java | 6 + .../rest/protocols/tcp/GridTcpRestProtocol.java | 7 +- .../apache/ignite/lang/IgniteAsyncCallback.java | 107 ++ .../communication/tcp/TcpCommunicationSpi.java | 4 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 36 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 2 + .../thread/IgniteStripedThreadPoolExecutor.java | 164 +-- .../processors/cache/GridCacheTestEntryEx.java | 4 +- ...FailoverAtomicPrimaryWriteOrderSelfTest.java | 50 + ...sQueryAsyncFailoverTxReplicatedSelfTest.java | 37 + ...eContinuousQueryAsyncFailoverTxSelfTest.java | 44 + ...eContinuousQueryAsyncFilterListenerTest.java | 986 +++++++++++++ ...ryFactoryAsyncFilterRandomOperationTest.java | 131 ++ ...usQueryFactoryFilterRandomOperationTest.java | 725 +++++++++ .../CacheContinuousQueryFactoryFilterTest.java | 714 --------- ...ContinuousQueryFailoverAbstractSelfTest.java | 63 +- ...ontinuousQueryOperationFromCallbackTest.java | 672 +++++++++ .../CacheContinuousQueryOrderingEventTest.java | 722 +++++++++ ...acheContinuousQueryRandomOperationsTest.java | 23 + .../GridTcpCommunicationSpiConfigSelfTest.java | 22 + .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 148 +- .../tcp/TcpDiscoverySpiConfigSelfTest.java | 22 + .../junits/GridTestKernalContext.java | 1 + .../IgniteBinaryCacheQueryTestSuite.java | 1 - .../IgniteCacheQuerySelfTestSuite3.java | 12 +- .../IgniteCacheQuerySelfTestSuite4.java | 7 + .../http/jetty/GridJettyRestProtocol.java | 4 +- .../ignite/schema/generator/GeneratorUtils.java | 17 + .../org/apache/ignite/spark/IgniteContext.scala | 73 +- .../apache/ignite/spark/JavaIgniteContext.scala | 14 +- .../spark/JavaEmbeddedIgniteRDDSelfTest.java | 343 +++++ .../ignite/spark/JavaIgniteRDDSelfTest.java | 302 ---- .../spark/JavaStandaloneIgniteRDDSelfTest.java | 302 ++++ .../ignite/testsuites/IgniteRDDTestSuite.java | 40 + .../ignite/internal/GridFactorySelfTest.java | 85 ++ .../ignite/cache/websession/WebSession.java | 7 +- .../internal/websession/WebSessionSelfTest.java | 88 +- .../config/benchmark-cache-load-win.properties | 2 +- .../config/benchmark-cache-load.properties | 53 +- .../config/ignite-base-load-config.xml | 256 ++++ .../config/ignite-cache-load-config.xml | 70 + .../cache/CacheEntryEventAsyncProbe.java | 61 + .../yardstick/cache/CacheEntryEventProbe.java | 33 +- .../IgniteCacheRandomOperationBenchmark.java | 176 ++- .../yardstick/cache/load/model/ModelUtil.java | 2 +- 71 files changed, 7800 insertions(+), 2465 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/13db6642/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java ----------------------------------------------------------------------
