Merge branch 'master' into ignite-2523-1
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/be738808 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/be738808 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/be738808 Branch: refs/heads/ignite-2523-1 Commit: be738808d14b6dbeea6c65a0a34387cbf13bef10 Parents: 2566e0b 2ff64c2 Author: vozerov-gridgain <[email protected]> Authored: Sat Apr 23 11:46:46 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Sat Apr 23 11:46:46 2016 +0300 ---------------------------------------------------------------------- .../CacheContinuousAsyncQueryExample.java | 138 ++ .../datagrid/CacheContinuousQueryExample.java | 13 +- .../ignite/cache/query/ContinuousQuery.java | 27 + .../configuration/IgniteConfiguration.java | 32 + .../ignite/internal/GridKernalContext.java | 8 + .../ignite/internal/GridKernalContextImpl.java | 12 + .../apache/ignite/internal/IgniteKernal.java | 3 + .../org/apache/ignite/internal/IgnitionEx.java | 16 +- .../processors/cache/GridCacheEntryEx.java | 5 +- .../processors/cache/GridCacheMapEntry.java | 49 +- .../dht/atomic/GridDhtAtomicCache.java | 98 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 121 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 33 +- .../distributed/near/GridNearAtomicCache.java | 3 +- .../continuous/CacheContinuousQueryEvent.java | 7 + .../continuous/CacheContinuousQueryHandler.java | 446 +++- .../CacheContinuousQueryListener.java | 6 +- .../continuous/CacheContinuousQueryManager.java | 62 +- .../apache/ignite/lang/IgniteAsyncCallback.java | 111 + .../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 +- .../CacheContinuousQueryLostPartitionTest.java | 14 + ...ontinuousQueryOperationFromCallbackTest.java | 627 ++++++ .../CacheContinuousQueryOrderingEventTest.java | 722 +++++++ ...acheContinuousQueryRandomOperationsTest.java | 23 + ...gniteComputeConfigVariationsFullApiTest.java | 2009 ++++++++++++++++++ .../configvariations/ConfigVariations.java | 2 +- .../junits/GridTestKernalContext.java | 1 + .../IgniteConfigVariationsAbstractTest.java | 43 +- ...teBasicConfigVariationsFullApiTestSuite.java | 72 + .../IgniteBinaryCacheQueryTestSuite.java | 1 - .../IgniteCacheQuerySelfTestSuite3.java | 14 +- .../IgniteCacheQuerySelfTestSuite4.java | 7 + .../ignite/schema/generator/CodeGenerator.java | 26 +- .../ignite/schema/generator/XmlGenerator.java | 45 +- .../schema/parser/DatabaseMetadataParser.java | 6 +- .../ignite/schema/ui/SchemaImportApp.java | 30 +- .../schema/test/AbstractSchemaImportTest.java | 10 +- .../schema/test/generator/XmlGeneratorTest.java | 4 +- .../apache/ignite/schema/test/model/Objects.txt | 31 +- .../ignite/schema/test/model/Primitives.txt | 31 +- .../org/apache/ignite/schema/test/model/Tst.txt | 31 +- .../schema/test/model/ignite-type-metadata.xml | 42 + .../test/parser/DbMetadataParserTest.java | 2 +- .../cache/CacheEntryEventAsyncProbe.java | 61 + .../yardstick/cache/CacheEntryEventProbe.java | 33 +- 54 files changed, 6764 insertions(+), 1231 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/be738808/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/be738808/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateFuture.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/be738808/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java ----------------------------------------------------------------------
