Merge remote-tracking branch 'remotes/origin/master' into ignite-4929
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3a988bda Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3a988bda Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3a988bda Branch: refs/heads/ignite-4929 Commit: 3a988bda91c62c2087fe8a3003cddc6bcffe2972 Parents: dffea71 027b2c2 Author: sboikov <[email protected]> Authored: Thu Apr 13 16:16:57 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Apr 13 16:16:57 2017 +0300 ---------------------------------------------------------------------- .gitignore | 31 +- examples/pom.xml | 6 + .../examples/springdata/PersonRepository.java | 59 + .../examples/springdata/SpringAppCfg.java | 69 + .../examples/springdata/SpringDataExample.java | 154 +++ .../examples/SpringDataExampleSelfTest.java | 32 + .../testsuites/IgniteExamplesSelfTestSuite.java | 2 + .../java/org/apache/ignite/IgniteCache.java | 265 ++-- .../rendezvous/RendezvousAffinityFunction.java | 309 +++-- .../communication/GridIoMessageFactory.java | 8 +- .../GridCachePartitionExchangeManager.java | 29 +- .../processors/cache/GridCachePreloader.java | 4 +- .../cache/GridCachePreloaderAdapter.java | 4 +- .../dht/preloader/GridDhtPartitionDemander.java | 2 +- .../dht/preloader/GridDhtPartitionSupplier.java | 310 +---- .../GridDhtPartitionSupplyMessage.java | 99 +- .../GridDhtPartitionSupplyMessageV2.java | 384 ------ .../dht/preloader/GridDhtPreloader.java | 3 +- .../cache/distributed/near/GridNearTxLocal.java | 5 +- .../transactions/IgniteTransactionsImpl.java | 4 +- .../datastructures/GridCacheSemaphoreImpl.java | 86 +- .../datastructures/GridCacheSemaphoreState.java | 22 + .../ignite/internal/util/lang/GridFunc.java | 1223 ++---------------- .../ignite/internal/util/lang/GridTupleV.java | 1 - .../lang/gridfunc/AlwaysFalsePredicate.java | 46 + .../util/lang/gridfunc/AlwaysTruePredicate.java | 46 + .../util/lang/gridfunc/AlwaysTrueReducer.java | 56 + .../gridfunc/AtomicIntegerFactoryCallable.java | 40 + .../gridfunc/CacheEntryGetValueClosure.java | 42 + .../gridfunc/CacheEntryHasPeekPredicate.java | 41 + .../lang/gridfunc/ClusterNodeGetIdClosure.java | 41 + .../ConcurrentDequeFactoryCallable.java | 40 + .../ConcurrentHashSetFactoryCallable.java | 40 + .../gridfunc/ConcurrentMapFactoryCallable.java | 41 + .../lang/gridfunc/ContainsNodeIdsPredicate.java | 52 + .../util/lang/gridfunc/ContainsPredicate.java | 55 + .../gridfunc/EntryByKeyEvaluationPredicate.java | 53 + .../gridfunc/EqualsClusterNodeIdPredicate.java | 51 + .../util/lang/gridfunc/EqualsUuidPredicate.java | 50 + .../lang/gridfunc/FlatCollectionWrapper.java | 66 + .../util/lang/gridfunc/FlatIterator.java | 104 ++ .../util/lang/gridfunc/HasEqualIdPredicate.java | 51 + .../lang/gridfunc/HasNotEqualIdPredicate.java | 51 + .../util/lang/gridfunc/IdentityClosure.java | 39 + .../util/lang/gridfunc/IntSumReducer.java | 51 + .../util/lang/gridfunc/IsAllPredicate.java | 52 + .../util/lang/gridfunc/IsNotAllPredicate.java | 52 + .../util/lang/gridfunc/IsNotNullPredicate.java | 44 + .../util/lang/gridfunc/LongSumReducer.java | 51 + .../util/lang/gridfunc/MapFactoryCallable.java | 41 + .../util/lang/gridfunc/MultipleIterator.java | 106 ++ .../util/lang/gridfunc/NoOpClosure.java | 39 + .../lang/gridfunc/NotContainsPredicate.java | 54 + .../util/lang/gridfunc/NotEqualPredicate.java | 53 + .../lang/gridfunc/PredicateCollectionView.java | 78 ++ .../util/lang/gridfunc/PredicateMapView.java | 121 ++ .../util/lang/gridfunc/PredicateSetView.java | 153 +++ .../lang/gridfunc/ReadOnlyCollectionView.java | 95 ++ .../lang/gridfunc/ReadOnlyCollectionView2X.java | 100 ++ .../lang/gridfunc/RunnableWrapperClosure.java | 51 + .../util/lang/gridfunc/SetFactoryCallable.java | 41 + .../util/lang/gridfunc/StringConcatReducer.java | 79 ++ .../util/lang/gridfunc/ToStringClosure.java | 42 + .../lang/gridfunc/TransformCollectionView.java | 79 ++ .../gridfunc/TransformFilteringIterator.java | 138 ++ .../util/lang/gridfunc/TransformMapView.java | 168 +++ .../util/lang/gridfunc/TransformMapView2.java | 165 +++ .../util/lang/gridfunc/package-info.java | 22 + .../TransactionDeadlockException.java | 4 +- .../transactions/TransactionException.java | 80 ++ .../TransactionHeuristicException.java | 4 +- .../TransactionOptimisticException.java | 4 +- .../TransactionRollbackException.java | 4 +- .../TransactionTimeoutException.java | 4 +- .../resources/META-INF/classnames.properties | 1 - ...inityFunctionFastPowerOfTwoHashSelfTest.java | 33 + ...ndezvousAffinityFunctionSimpleBenchmark.java | 1100 ++++++++++++++++ ...ousAffinityFunctionStandardHashSelfTest.java | 33 + .../IgniteClientReconnectCacheTest.java | 16 +- .../internal/binary/BinaryEnumsSelfTest.java | 2 + .../cache/CacheKeepBinaryTransactionTest.java | 121 ++ .../GridCachePartitionedAffinitySpreadTest.java | 169 --- ...eAbstractDataStructuresFailoverSelfTest.java | 21 +- ...SemaphoreFailoverSafeReleasePermitsTest.java | 9 +- ...dCachePartitionedQueueEntryMoveSelfTest.java | 2 +- .../CacheLateAffinityAssignmentTest.java | 6 +- ...ridCachePartitionNotLoadedEventSelfTest.java | 2 + .../IgniteCacheReadFromBackupTest.java | 6 +- .../atomic/IgniteCacheAtomicProtocolTest.java | 3 +- .../near/GridCacheNearTxForceKeyTest.java | 6 +- ...cheRebalancingPartitionDistributionTest.java | 2 +- .../datastreamer/DataStreamerImplSelfTest.java | 36 - ...gniteServiceConfigVariationsFullApiTest.java | 9 +- .../IgniteServiceDynamicCachesSelfTest.java | 12 +- .../ignite/testframework/GridTestNode.java | 12 +- .../testsuites/IgniteCacheTestSuite2.java | 4 + .../testsuites/IgniteCacheTestSuite5.java | 2 + ...PartitionOnAffinityRunAtomicCacheOpTest.java | 46 +- .../h2/GridIndexingSpiAbstractSelfTest.java | 2 - .../binary/include/ignite/binary/binary_type.h | 129 +- .../ignite/impl/binary/binary_id_resolver.h | 33 +- .../ignite/impl/binary/binary_object_impl.h | 3 +- .../ignite/impl/binary/binary_reader_impl.h | 80 +- .../ignite/impl/binary/binary_type_impl.h | 12 +- .../include/ignite/impl/binary/binary_utils.h | 6 +- .../ignite/impl/binary/binary_writer_impl.h | 15 +- .../core-test/include/ignite/binary_test_defs.h | 117 +- .../cpp/core-test/include/ignite/complex_type.h | 30 +- .../cpp/core-test/include/ignite/test_type.h | 37 +- .../src/binary_identity_resolver_test.cpp | 92 +- .../cpp/core-test/src/binary_object_test.cpp | 4 +- .../cpp/core-test/src/binary_test_defs.cpp | 5 + .../cpp/core-test/src/cache_invoke_test.cpp | 18 +- .../cpp/core-test/src/cache_query_test.cpp | 12 +- .../platforms/cpp/core-test/src/cache_test.cpp | 38 +- .../cpp/core-test/src/continuous_query_test.cpp | 34 +- .../cpp/core/include/ignite/ignite_binding.h | 6 +- .../impl/cache/cache_entry_processor_holder.h | 33 +- .../cpp/odbc-test/include/complex_type.h | 26 +- .../platforms/cpp/odbc-test/include/test_type.h | 37 +- modules/spring-data/README.txt | 32 + modules/spring-data/licenses/apache-2.0.txt | 202 +++ modules/spring-data/pom.xml | 79 ++ .../springdata/repository/IgniteRepository.java | 58 + .../config/EnableIgniteRepositories.java | 119 ++ .../config/IgniteRepositoriesRegistar.java | 36 + .../IgniteRepositoryConfigurationExtension.java | 49 + .../springdata/repository/config/Query.java | 37 + .../repository/config/RepositoryConfig.java | 39 + .../repository/config/package-info.java | 22 + .../springdata/repository/package-info.java | 22 + .../repository/query/IgniteQuery.java | 83 ++ .../repository/query/IgniteQueryGenerator.java | 243 ++++ .../repository/query/IgniteRepositoryQuery.java | 306 +++++ .../repository/query/package-info.java | 22 + .../support/IgniteRepositoryFactory.java | 168 +++ .../support/IgniteRepositoryFactoryBean.java | 85 ++ .../support/IgniteRepositoryImpl.java | 160 +++ .../repository/support/package-info.java | 22 + .../IgniteSpringDataCrudSelfTest.java | 233 ++++ .../IgniteSpringDataQueriesSelfTest.java | 291 +++++ .../misc/ApplicationConfiguration.java | 46 + .../apache/ignite/springdata/misc/Person.java | 97 ++ .../springdata/misc/PersonRepository.java | 92 ++ .../springdata/misc/PersonSecondRepository.java | 40 + .../testsuites/IgniteSpringDataTestSuite.java | 41 + modules/web-console/frontend/.eslintrc | 2 +- modules/web-console/frontend/app/app.js | 3 - .../form-field-datepicker.pug | 59 - .../form-field-datepicker.scss | 20 - .../list-of-registered-users.categories.js | 4 +- .../list-of-registered-users.column-defs.js | 44 +- .../list-of-registered-users.controller.js | 141 +- .../list-of-registered-users.scss | 4 + .../list-of-registered-users.tpl.pug | 76 +- .../ui-grid-header/ui-grid-header.scss | 91 -- .../ui-grid-header/ui-grid-header.tpl.pug | 29 - .../ui-grid-settings/ui-grid-settings.pug | 33 - .../ui-grid-settings/ui-grid-settings.scss | 144 --- .../frontend/app/helpers/jade/mixins.pug | 3 + .../frontend/app/modules/states/admin.state.js | 11 +- .../frontend/app/primitives/badge/index.scss | 4 + .../frontend/app/primitives/btn/index.scss | 41 + .../app/primitives/datepicker/index.pug | 60 + .../app/primitives/datepicker/index.scss | 64 + .../frontend/app/primitives/dropdown/index.pug | 43 + .../frontend/app/primitives/dropdown/index.scss | 82 ++ .../frontend/app/primitives/index.js | 8 + .../frontend/app/primitives/page/index.scss | 35 + .../frontend/app/primitives/panel/index.scss | 51 + .../frontend/app/primitives/tabs/index.scss | 15 + .../app/primitives/ui-grid-header/index.scss | 91 ++ .../app/primitives/ui-grid-header/index.tpl.pug | 29 + .../app/primitives/ui-grid-settings/index.pug | 33 + .../app/primitives/ui-grid-settings/index.scss | 171 +++ .../frontend/app/primitives/ui-grid/index.scss | 329 +++++ .../frontend/public/stylesheets/style.scss | 5 - modules/web-console/frontend/views/base2.pug | 22 + .../frontend/views/settings/admin.tpl.pug | 3 +- .../web-console/frontend/views/sql/sql.tpl.pug | 1 - .../cache/websession/WebSessionFilter.java | 22 +- parent/pom.xml | 1 + pom.xml | 1 + 183 files changed, 9555 insertions(+), 3357 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3a988bda/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/IgniteCacheAtomicProtocolTest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3a988bda/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java ----------------------------------------------------------------------
