Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-6748
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c6f92cb9 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c6f92cb9 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c6f92cb9 Branch: refs/heads/ignite-6748 Commit: c6f92cb96171569beead847e6fa5cb999578844c Parents: c9f0707 555b71e Author: Alexey Goncharuk <[email protected]> Authored: Mon Oct 30 15:25:57 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Mon Oct 30 15:25:57 2017 +0300 ---------------------------------------------------------------------- .../apache/ignite/IgniteSystemProperties.java | 6 + .../org/apache/ignite/cache/QueryEntity.java | 11 +- .../cache/query/annotations/QuerySqlField.java | 7 + .../org/apache/ignite/internal/IgnitionEx.java | 34 +- .../internal/managers/discovery/DiscoCache.java | 45 ++- .../discovery/DiscoveryCustomMessage.java | 13 +- .../discovery/GridDiscoveryManager.java | 190 ++++++----- .../ignite/internal/pagemem/PageIdUtils.java | 19 ++ .../pagemem/impl/PageMemoryNoStoreImpl.java | 6 +- .../cache/CacheAffinityChangeMessage.java | 8 + .../ClientCacheChangeDiscoveryMessage.java | 9 + .../ClientCacheChangeDummyDiscoveryMessage.java | 9 + .../cache/DynamicCacheChangeBatch.java | 9 + .../binary/MetadataUpdateAcceptedMessage.java | 9 + .../binary/MetadataUpdateProposedMessage.java | 9 + .../dht/atomic/GridDhtAtomicCache.java | 7 +- .../GridDhtPartitionsExchangeFuture.java | 3 +- .../GridCacheDatabaseSharedManager.java | 16 +- .../persistence/freelist/FreeListImpl.java | 18 +- .../snapshot/IgniteCacheSnapshotManager.java | 6 +- .../persistence/snapshot/SnapshotOperation.java | 6 +- .../cache/persistence/tree/io/DataPageIO.java | 17 +- .../cache/query/QueryEntityIndexDescriptor.java | 2 + .../cache/query/QueryEntityTypeDescriptor.java | 19 ++ .../cluster/ChangeGlobalStateFinishMessage.java | 9 + .../cluster/ChangeGlobalStateMessage.java | 11 +- .../continuous/AbstractContinuousMessage.java | 10 + .../StartRoutineAckDiscoveryMessage.java | 2 +- .../StartRoutineDiscoveryMessage.java | 2 +- .../StopRoutineAckDiscoveryMessage.java | 2 +- .../continuous/StopRoutineDiscoveryMessage.java | 2 +- .../datastreamer/DataStreamerImpl.java | 23 +- .../marshaller/MappingAcceptedMessage.java | 9 + .../marshaller/MappingProposedMessage.java | 9 + .../message/SchemaAbstractDiscoveryMessage.java | 10 + .../message/SchemaProposeDiscoveryMessage.java | 3 +- .../communication/tcp/TcpCommunicationSpi.java | 17 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 52 ++- .../ignite/spi/discovery/tcp/ServerImpl.java | 313 ++++++++++--------- .../spi/discovery/tcp/TcpDiscoveryImpl.java | 4 +- ...entConnectAfterCommunicationFailureTest.java | 156 +++++++++ .../cache/CacheRebalancingSelfTest.java | 2 + .../cache/IgniteOutOfMemoryPropagationTest.java | 251 +++++++++++++++ .../IgniteDiscoveryCacheReuseSelfTest.java | 89 ++++++ ...lientDiscoverySpiFailureTimeoutSelfTest.java | 20 +- .../tcp/TcpClientDiscoverySpiSelfTest.java | 275 +++++++++++++++- .../testsuites/IgniteCacheTestSuite6.java | 5 + .../IgniteClientReconnectTestSuite.java | 4 +- .../testsuites/IgniteReproducingSuite.java | 42 +++ .../IgniteSpiDiscoverySelfTestSuite.java | 6 +- modules/dev-utils/pom.xml | 13 + .../processors/query/h2/IgniteH2Indexing.java | 27 +- .../processors/query/h2/opt/GridH2Table.java | 60 ++++ .../IgniteCacheInsertSqlQuerySelfTest.java | 18 ++ .../query/IgniteSqlNotNullConstraintTest.java | 35 ++- .../ml/math/decompositions/LUDecomposition.java | 2 +- .../Binary/BinaryBuilderSelfTest.cs | 10 +- .../Binary/EnumsTest.cs | 2 +- .../Client/Cache/CacheTest.cs | 42 +++ .../Client/RawSocketTest.cs | 2 +- .../ProjectFilesTest.cs | 8 +- .../Impl/Binary/BinaryUtils.cs | 30 +- .../Impl/Binary/Marshaller.cs | 4 +- .../Impl/Binary/SerializableSerializer.cs | 18 +- .../frontend/app/modules/sql/sql.controller.js | 2 +- .../frontend/app/utils/SimpleWorkerPool.js | 1 + .../ignite/console/demo/AgentClusterDemo.java | 32 +- .../demo/service/DemoCachesLoadService.java | 3 +- 68 files changed, 1730 insertions(+), 385 deletions(-) ----------------------------------------------------------------------
