From commits-return-126777-archive-asf-public=cust-asf.ponee.io@ignite.apache.org Mon Jul 13 11:20:05 2020 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id F250218037A for ; Mon, 13 Jul 2020 13:20:03 +0200 (CEST) Received: (qmail 69280 invoked by uid 500); 13 Jul 2020 11:20:03 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 69234 invoked by uid 99); 13 Jul 2020 11:20:03 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Jul 2020 11:20:03 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 957D9811CC; Mon, 13 Jul 2020 11:20:02 +0000 (UTC) Date: Mon, 13 Jul 2020 11:20:00 +0000 To: "commits@ignite.apache.org" Subject: [ignite] branch ignite-12248 updated (951f134 -> da93769) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <159463920019.16824.3864742581248331122@gitbox.apache.org> From: gvvinblade@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: ignite X-Git-Refname: refs/heads/ignite-12248 X-Git-Reftype: branch X-Git-Oldrev: 951f1347b4bc5d78d581703c648d385bd5bdad9e X-Git-Newrev: da9376957e982fe4ab80a49c64bd1d1c07c60f50 X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. gvvinblade pushed a change to branch ignite-12248 in repository https://gitbox.apache.org/repos/asf/ignite.git. from 951f134 Fix checkstyle. add 9d2824d IGNITE-12978: Add cancel snapshot command (#7827) add 84edb3d IGNITE-12343 Remote filter and transformer of ContinuousQueries have to run inside the Ignite Sandbox - Fixes #7677. add ee5acaf IGNITE-13074 Thin client: Fix default compute cluster group - Fixes #7850. add 6955ac2 IGNITE-13082 Fix deadlock between topology update and CQ registration. (#7858) add 5130dde IGNITE-13089: Add README.md project activity badges (#7871) add 41e8a93 IGNITE-13041 PDS (Indexing) is failed with 137 code - Fixes #7820. add 09a50e0 IGNITE-13048 Fix of WAL segments validation if archiver is not enabled. - Fixes #7829. add 8c7a76e IGNITE-13062 Race in state processor fixed - Fixes #7837. add e0c10a7 IGNITE-13058 Ensure that all clients have the cache in test - Fixes #7834. add 4b3d155 IGNITE-13075 NPE on request JDBC metadata. (#7851) add 9479377 IGNITE-13044 Additional possibility to check for high contending keys generated by the transaction payload. - Fixes #7824 add b0c5a15 IGNITE-12823 .NET: Fix service method calls with typed array args add 0139490 IGNITE-12359 Migrate RocketMQ module to ignite-extensions - Fixes #7809. add 0971768 IGNITE-13081 Fix rest processor hanging on node shutdown if start failed #7859 - Fixes #7859. add b2089a6 IGNITE-13050 Added nodes cache in ClusterGroupAdapter - Fixes #7831. add b31e11b IGNITE-12780 Fix deadlock between db-checkpoint-thread and checkpoint-runner - Fixes #7816. add e7d9d99 IGNITE-12712 Reorder write throttle init and segments initialization to fix NPE - Fixes #7463. add d3fc970 IGNITE-13100 Fix exceptions raised when cache group metrics are read on client node - Fixes #7875. add 8e5f779 IGNITE-5214 Prevent concurrent access to pendingEvts when debug is on - Fixes #7874. add f809525 IGNITE-13051 still validate MVCC if cache will not start (#7852) add f5fc261 IGNITE-13083 Remove odd segment archived storage observer addition - Fixes #7860. add d3c8686 IGNITE-13108: Decrease number of starting clients for IgniteCache150ClientsTest (#7892) add e9aa94b IGNITE-13095 .NET: Fix Thin Client compute task cancellation add a1c9561 IGNITE-13094 Fix peer loading errors when package name contains 'class' - Fixes #7887. add da2ed14 IGNITE-13115 Master key can't be changed if Unicode symbols present (#7898) add 6b716bb IGNITE-12876 Extend test coverage to test deadlock absence between checkpoint, entry update and TTL worker - Fixes #7643. add e3c09bb IGNITE-13104 Fixed incorrect logic in spring-data repositories for findAllById() and deleteAllById() methods. Code cleanup. #7886 - Fixes #7886. add a723735 IGNITE-13122: Fix NullPointerException on snapshot deletion (#7904) add f151563 IGNITE-13105 Fixed cursors leak in RunningQueryManager. Code cleanup. #7888 - Fixes #7888. add 7dd45dd IGNITE-13071 Improve test coverage for read-only cluster state - Fixes #7853. add c8a3b90 IGNITE-13103 Fix SerializedLambda deployment by not registering capturingClass with marshaller - Fixes #7880. add 4544651 IGNITE-13096 Java thin client: Fix binary type schema registration for nested objects - Fixes #7878. add 657c50ab IGNITE-13088 Avoid NPE being thrown from checkProxyIsValid on client restart - Fixes #7873. add b7682cc IGNITE-13119 fix data race when getting index rebuild status (#7901) add 2026b25 IGNITE-7105 .NET: Add IgniteLock add 1bd45aa IGNITE-13084 Update BouncyCastle dependency to fix potential vulnerability - Fixes #7861. add 5f3a4ac IGNITE-12085: ThreadPool metrics register before components start. (#7818) add d30485e IGNITE-13017 Remove hardcoded delay from re-marking failed node as alive. (#7870) add 847537d IGNITE-12383 Add distances measures between two vectors (#7349) add 9cf09f6 IGNITE-13140 Fixed Pull Request checklist add b4bdddf IGNITE-13052 Calculate result of reserveHistoryForExchange in advance - Fixes #7911. add c3a2deb IGNITE-13145 Fix NPE on node stop causing JVM halt with default failure handler - Fixes #7925. add 1873228 IGNITE-13106 Java thin client: Fix race between response and notification for compute tasks - Fixes #7885. add c90a828 IGNITE-13128 Fix NPE when IgniteLock is removed before use add 10f4d95 IGNITE-13031 .NET: Allow SqlFieldsQuery as ContinuousQuery.InitialQuery add 974fb5a IGNITE-13138 Add tests for cluster state change via REST commands - Fixes #7918. add 35feee3 IGNITE-13135 Fix CacheRegisterMetadataLocallyTest.testClientFindsValueByAffinityKeyStaticCacheWithoutExtraRequest - Fixes #7914. add 22af51e IGNITE-12994 Binary metadata and marshaller directories moved to PDS directory. Fixes #7792 add 5413914 IGNITE-13147 Avoid DHT topology map updates before it's initialization - Fixes #7927. add 7e0d656 IGNITE-13033 Java thin client: Service invocation - Fixes #7908. add 1e84d44 IGNITE-12765 Slim release assemblies. add 3485b92 IGNITE-12808 Allow register started caches in indexing to enable SQL query on them. (#7627) add 32d3baa IGNITE-10708 Add partition states system view (#7932) add be38229 IGNITE-13166 Flaky H2RowCachePageEvictionTest and IgniteCacheQueryH2IndexingLeakTest tests (#7947) add a15a25a IGNITE-13144 Refactor ClusterState.active(), ClusterState.lesserOf() methods - Fixes #7924. add 16a7035 IGNITE-13170 Java thin client: Fix transactions "withLabel" - Fixes #7951. add 385ff65 IGNITE-12111 Cluster ID and tag to identify cluster - Fixes #7922. add bec7f31 IGNITE-13078: C++: Add CMake build system support add 1336f1b IGNITE-13164 Thin client: Fix nodeIds format for execute compute tasks request - Fixes #7944. add c915cea IGNITE-13168 Retrigger historical rebalance if it was cancelled in case WAL history is still available - Fixes #7948. add cf15f48 IGNITE-13066: Print which tests are started in quite mode too (#7840) add 87aad40 IGNITE-13012 Make node connection checking rely on the configuration. Simplify node ping routine. (#7835) add a95bd9b IGNITE-13042: Re-generated C++ SSL certificates and added script add 832cf80 IGNITE-12986 Fixed the order of elements for mget method. add 11d9c89 IGNITE-13155: Fix NullPointerException on in-memory cluster for snapshot creation (#7959) add 6ed72a5 IGNITE-13010 Fixed NPE during handle of EVT_CACHE_STOPPED event (#7921) add c95befa IGNITE-13172 Fix ignite-scalar module compilation on JDK 11+ (#7955) add 1413af0 IGNITE-13051 #2 check mvcc configuration after register caches futu… (#7902) add b6bd5a3 IGNITE-13154 Add command line commands (control.sh) to manage binary types (#7936) add 78f5788 IGNITE-13187 Skip spring-data module as classpath for platforms tests. add 40377b1 IGNITE-12903 Fixed ML + SQL examples (#7965) add d03749b IGNITE-13015 : Use nano time in node failure detection. (#7872) add 0e385f8 IGNITE-13194 Fix test IgnitePdsBinaryMetadataOnClusterRestartTest#testNodeWithIncompatibleMetadataIsProhibitedToJoinTheCluste: change expected error message (#7969) add b0d1a4f IGNITE-13176 C++: Remove autotools build system add 9e99074 IGNITE-13005 Spring Data 2 - "JPA style" and working with multiple Ignite instances on same JVM add dc3ddf0 IGNITE-12845 Fix GridNioServer events lost - Fixes #7879. add 2fbbb67 IGNITE-13197 Import order rule added. (#7978) add f90bcaa IGNITE-13205 : Represent in logs, javadoc affection of several node addresses on failure detection. (#7985) add 236f30b IGNITE-13192 Java thin client: Fix binary type schema registration for already cached typeId - Fixes #7990. add fde65a6 IGNITE-13193 Added fallback to full rebalance if historical one has failed. add f55901d IGNITE-12935 Improved logging for historical rebalancing. - Fixes #7722. add 48700d9 IGNITE-13216 "Name" parameter of QuerySqlField annotation that was ignored during uniqueness validation of field's name - Fixes #7993. add 5f0e242 IGNITE-13212 Fixed p2p deployment of scan queries transformer class - Fixes #8000. add 69c5b51 IGNITE-13226 .NET: Fix ClientNotificationHandler leak in ClientSocket add 071bb4e IGNITE-13123 Move control utility to a separate module - Fixes #7910. add c7aca28 IGNITE-13185 CLI and JMX APIs and new event for Cluster ID and Tag feature - Fixes #7964. add b7d637b IGNITE-13185 Fix compilation after IGNITE-13123 merge. add 1d7ad0d IGNITE-13146 Fix OpenCensus example maven build - Fixes #7999. add 3006dd8 IGNITE-11393 Fix javadoc maven build for java9+ - Fixes #7983. add c0ed2f6 IGNITE-13180 Added subject address to AuthenticationContext when subject is IgniteClient - Fixes #7960. add 6c69aa31 IGNITE-12346 .NET: Fix query cursor thread safety add 3dd359b IGNITE-13200 SQL: fix node stops on create index on invalid data type (#7982) add ed0767d IGNITE-12438 Extend communication protocol to support one-way client-server connections - Fixes #7639. add 0aceb36 IGNITE-13214 .NET: Fix TransactionScope for read operations add 60f38e6 IGNITE-13142 Fixed wrongful error message regarding SQL not-null constraint - Fixes #7961. add bca6316 IGNITE-13142 Checkstyle fix add e730185 IGNITE-10959: Add continuous query pending buffer limit (#7881) add 3bd9870 IGNITE-12362 Migrate MQTT module to ignite-extensions - Fixes #7950. new ca4cdf5 Merge branch 'master' into ignite-12248 new da93769 Fix after merge The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .github/PULL_REQUEST_TEMPLATE.md | 4 +- .gitignore | 30 +- DEVNOTES.txt | 12 +- LICENSE | 6 + README.md | 6 +- assembly/dependencies-apache-ignite-slim.xml | 222 ++ assembly/dependencies-apache-ignite.xml | 2 + assembly/libs/README.txt | 5 - assembly/release-apache-ignite-base.xml | 16 +- assembly/release-apache-ignite-slim.xml | 50 + checkstyle/checkstyle.xml | 9 + examples/README-slim.txt | 32 + examples/pom-standalone-lgpl.xml | 18 + examples/pom-standalone.xml | 18 + .../examples/datagrid/SpatialQueryExample.java | 14 +- .../ComputeClientBinaryTaskExecutionExample.java | 2 +- .../binary/computegrid/ComputeClientTask.java | 2 +- .../examples/client/ClientPutGetExample.java | 4 +- .../examples/datagrid/DataRegionsExample.java | 2 +- .../dataset/AlgorithmSpecificDatasetExample.java | 2 +- .../inference/h2o/H2OMojoModelParserExample.java | 2 +- ...eeClassificationTrainerSQLInferenceExample.java | 36 +- ...onTreeClassificationTrainerSQLTableExample.java | 109 +- .../org/apache/ignite/examples/model/Address.java | 2 +- .../OpenCensusMetricsExporterExample.java | 4 +- .../spark/JavaIgniteDataFrameWriteExample.java | 3 +- .../ignite/examples/spark/SharedRDDExample.java | 5 +- .../ignite/examples/CacheExamplesSelfTest.java | 2 +- idea/ignite_codeStyle.xml | 2 + .../apache/ignite/gridify/BasicAopSelfTest.java | 5 +- modules/aws/pom.xml | 12 + .../ignite/spi/checkpoint/s3/S3CheckpointSpi.java | 20 +- .../tcp/ipfinder/elb/TcpDiscoveryAlbIpFinder.java | 8 +- .../tcp/ipfinder/elb/TcpDiscoveryElbIpFinder.java | 9 +- .../spi/checkpoint/s3/S3CheckpointSpiSelfTest.java | 6 +- .../tcp/ipfinder/s3/client/DummyObjectListing.java | 4 +- .../ipfinder/s3/client/DummyObjectListingTest.java | 4 +- .../tcp/ipfinder/s3/client/DummyS3Client.java | 22 +- .../tcp/ipfinder/s3/client/DummyS3ClientTest.java | 6 +- .../internal/benchmarks/jmh/algo/BenchmarkCRC.java | 5 +- .../benchmarks/jmh/cache/JmhCacheBenchmark.java | 3 +- .../GridDhtPartitionsStateValidatorBenchmark.java | 11 +- .../benchmarks/jmh/misc/JmhIncrementBenchmark.java | 3 +- .../jmh/runner/JmhIdeBenchmarkRunner.java | 3 +- .../jmh/sequence/JmhSequenceBenchmark.java | 2 +- .../jmh/streamer/JmhStreamerAddDataBenchmark.java | 6 +- .../benchmarks/jol/GridMetricsJolBenchmark.java | 2 +- .../ignite/internal/benchmarks/model/IntValue.java | 9 +- .../stream/camel/IgniteCamelStreamerTest.java | 14 +- .../store/cassandra/serializer/KryoSerializer.java | 8 +- .../apache/ignite/tests/KryoSerializerTest.java | 2 - .../cache/store/cassandra/CassandraCacheStore.java | 8 +- .../store/cassandra/common/CassandraHelper.java | 6 +- .../cassandra/common/PropertyMappingHelper.java | 4 +- .../persistence/KeyValuePersistenceSettings.java | 2 +- .../persistence/PersistenceController.java | 7 +- .../cassandra/persistence/PersistenceSettings.java | 10 +- .../store/cassandra/persistence/PojoField.java | 7 +- .../cassandra/persistence/PojoFieldAccessor.java | 3 +- .../store/cassandra/session/CassandraSession.java | 3 +- .../session/GenericBatchExecutionAssistant.java | 2 +- .../session/LoadCacheCustomQueryWorker.java | 2 +- .../session/WrappedPreparedStatement.java | 5 +- .../session/transaction/WriteMutation.java | 2 - .../tests/CassandraDirectPersistenceTest.java | 15 +- .../ignite/tests/CassandraSessionImplTest.java | 28 +- .../ignite/tests/DatasourceSerializationTest.java | 17 +- .../ignite/tests/IgnitePersistentStoreTest.java | 18 +- .../tests/LoadTestsCassandraArtifactsCreator.java | 5 +- .../apache/ignite/tests/pojos/SimplePerson.java | 3 +- .../apache/ignite/tests/pojos/SimplePersonId.java | 3 +- .../apache/ignite/tests/utils/CassandraHelper.java | 11 +- .../apache/ignite/tests/utils/TestTransaction.java | 3 +- .../org/apache/ignite/tests/utils/TestsHelper.java | 24 +- .../client/ClientDefaultCacheSelfTest.java | 4 +- .../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 3 +- .../internal/jdbc2/JdbcBulkLoadSelfTest.java | 17 +- .../internal/jdbc2/JdbcEmptyCacheSelfTest.java | 17 +- .../internal/jdbc2/JdbcMetadataSelfTest.java | 3 +- .../rest/AbstractRestProcessorSelfTest.java | 8 + .../rest/ChangeStateCommandHandlerTest.java | 5 +- .../rest/JettyRestProcessorAbstractSelfTest.java | 175 +- .../rest/JettyRestProcessorCommonSelfTest.java | 4 +- .../rest/JettyRestProcessorGetAllAsArrayTest.java | 2 +- .../tcp/redis/RedisProtocolStringSelfTest.java | 75 + .../apache/ignite/jdbc/JdbcMetadataSelfTest.java | 8 +- .../apache/ignite/jdbc/JdbcResultSetSelfTest.java | 25 +- .../ignite/jdbc/JdbcVersionMismatchSelfTest.java | 7 +- ...eJdbcThinDriverPartitionAwarenessTestSuite.java | 2 +- .../ignite/jdbc/thin/JdbcThinBulkLoadSelfTest.java | 8 +- .../JdbcThinComplexDmlDdlCustomSchemaSelfTest.java | 3 +- .../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 117 +- .../thin/JdbcThinPreparedStatementLeakTest.java | 7 +- .../jdbc/thin/JdbcThinWalModeChangeSelfTest.java | 9 +- .../ipfinder/cloud/TcpDiscoveryCloudIpFinder.java | 8 +- .../cloud/TcpDiscoveryCloudIpFinderSelfTest.java | 3 +- .../SystemViewRowAttributeWalkerGenerator.java | 8 +- .../persistence/FoldersReuseCompatibilityTest.java | 3 +- ...IgnitePersistenceCompatibilityAbstractTest.java | 3 +- .../MoveBinaryMetadataCompatibility.java | 111 + .../junits/IgniteCompatibilityNodeRunner.java | 2 +- .../testframework/util/MavenUtils.java | 5 +- .../IgniteCompatibilityBasicTestSuite.java | 4 +- .../compress/CompressionProcessorImpl.java | 2 +- .../processors/compress/FileSystemUtilsTest.java | 4 +- .../licenses/apache-2.0.txt | 0 modules/control-utility/pom.xml | 117 + .../internal/commandline/ActivateCommand.java | 0 .../internal/commandline/BaselineCommand.java | 281 +++ .../commandline/ClusterChangeTagCommand.java | 115 + .../commandline/ClusterStateChangeCommand.java | 0 .../ignite/internal/commandline/Command.java | 0 .../internal/commandline/CommandArgIterator.java | 191 ++ .../internal/commandline/CommandHandler.java | 0 .../ignite/internal/commandline/CommandList.java | 129 ++ .../ignite/internal/commandline/CommandLogger.java | 0 .../internal/commandline/CommonArgParser.java | 350 +++ .../commandline/ConnectionAndSslParameters.java | 0 .../internal/commandline/DeactivateCommand.java | 0 .../ignite/internal/commandline/GridConsole.java | 0 .../internal/commandline/GridConsoleAdapter.java | 0 .../ignite/internal/commandline/NoopConsole.java | 0 .../ignite/internal/commandline/OutputFormat.java | 0 .../ignite/internal/commandline/StateCommand.java | 97 + .../ignite/internal/commandline/TaskExecutor.java | 0 .../ignite/internal/commandline/TxCommandArg.java | 0 .../ignite/internal/commandline/TxCommands.java | 558 +++++ .../ignite/internal/commandline/WalCommands.java | 0 .../internal/commandline/argument/CommandArg.java | 0 .../commandline/argument/CommandArgUtils.java | 0 .../commandline/baseline/AutoAdjustCommandArg.java | 0 .../commandline/baseline/BaselineArguments.java | 0 .../commandline/baseline/BaselineSubcommands.java | 0 .../commandline/cache/CacheCommandList.java | 0 .../internal/commandline/cache/CacheCommands.java | 0 .../commandline/cache/CacheContention.java | 0 .../commandline/cache/CacheDistribution.java | 0 .../commandline/cache/CacheSubcommands.java | 0 .../commandline/cache/CacheValidateIndexes.java | 344 +++ .../internal/commandline/cache/CacheViewer.java | 0 .../commandline/cache/CheckIndexInlineSizes.java | 0 .../commandline/cache/FindAndDeleteGarbage.java | 0 .../internal/commandline/cache/IdleVerify.java | 371 ++++ .../commandline/cache/ResetLostPartitions.java | 0 .../cache/argument/DistributionCommandArg.java | 0 .../cache/argument/FindAndDeleteGarbageArg.java | 0 .../cache/argument/IdleVerifyCommandArg.java | 0 .../commandline/cache/argument/ListCommandArg.java | 0 .../cache/argument/ValidateIndexesCommandArg.java | 0 .../commandline/diagnostic/DiagnosticCommand.java | 0 .../diagnostic/DiagnosticSubCommand.java | 0 .../commandline/diagnostic/PageLocksCommand.java | 0 .../commandline/encryption/EncryptionCommand.java | 0 .../encryption/EncryptionSubcommand.java | 0 .../internal/commandline/meta/MetadataCommand.java | 164 ++ .../commandline/meta/MetadataSubCommandsList.java | 78 + .../subcommands/MetadataAbstractSubCommand.java | 123 ++ .../meta/subcommands/MetadataDetailsCommand.java | 91 + .../meta/subcommands/MetadataHelpCommand.java | 54 + .../meta/subcommands/MetadataListCommand.java | 56 + .../meta/subcommands/MetadataRemoveCommand.java | 117 + .../meta/subcommands/MetadataUpdateCommand.java | 88 + .../internal/commandline/query/KillCommand.java | 226 ++ .../internal/commandline/query/KillSubcommand.java | 57 + .../commandline/snapshot/SnapshotCommand.java | 113 + .../commandline/snapshot/SnapshotSubcommand.java | 59 + .../main/resources/META-INF/classnames.properties | 27 + .../commandline/CommandHandlerParsingTest.java | 650 ++++++ .../GridCommandHandlerSslWithSecurityTest.java | 147 ++ .../testsuites/IgniteControlUtilityTestSuite.java | 66 + .../ZookeeperIgniteControlUtilityTestSuite.java | 43 + .../util/GridCommandHandlerAbstractTest.java | 437 ++++ .../util/GridCommandHandlerBrokenIndexTest.java | 0 ...idCommandHandlerCheckIndexesInlineSizeTest.java | 0 ...idCommandHandlerClusterByClassAbstractTest.java | 0 .../util/GridCommandHandlerClusterByClassTest.java | 1741 +++++++++++++++ ...ridCommandHandlerClusterByClassWithSSLTest.java | 0 ...CommandHandlerClusterPerMethodAbstractTest.java | 0 .../GridCommandHandlerIndexingCheckSizeTest.java | 0 ...idCommandHandlerIndexingClusterByClassTest.java | 197 ++ ...ndHandlerIndexingClusterByClassWithSSLTest.java | 0 .../util/GridCommandHandlerIndexingTest.java | 347 +++ .../util/GridCommandHandlerIndexingUtils.java | 0 .../GridCommandHandlerIndexingWithSSLTest.java | 0 .../util/GridCommandHandlerMetadataTest.java | 384 ++++ .../ignite/util/GridCommandHandlerSslTest.java | 0 .../apache/ignite/util/GridCommandHandlerTest.java | 2265 ++++++++++++++++++++ .../ignite/util/GridCommandHandlerTestUtils.java | 0 .../ignite/util/GridCommandHandlerWithSSLTest.java | 0 .../ignite/util/KillCommandsCommandShTest.java | 198 ++ .../main/java/org/apache/ignite/IgniteCluster.java | 42 +- .../java/org/apache/ignite/IgniteFileSystem.java | 2 +- .../java/org/apache/ignite/IgniteServices.java | 2 +- .../java/org/apache/ignite/IgniteSnapshot.java | 9 + .../org/apache/ignite/IgniteSystemProperties.java | 8 + .../ignite/binary/BinaryTypeConfiguration.java | 5 +- .../java/org/apache/ignite/cache/CacheMetrics.java | 12 + .../java/org/apache/ignite/cache/QueryEntity.java | 2 +- .../ignite/cache/query/BulkLoadContextCursor.java | 7 +- .../org/apache/ignite/client/ClientServices.java | 56 + .../org/apache/ignite/client/IgniteClient.java | 20 + .../org/apache/ignite/cluster/ClusterState.java | 47 +- .../configuration/DataStorageConfiguration.java | 6 + .../configuration/FileSystemConfiguration.java | 3 +- .../ignite/configuration/HadoopConfiguration.java | 2 +- .../ignite/configuration/IgniteConfiguration.java | 2 +- .../configuration/PlatformCacheConfiguration.java | 3 +- .../ignite/events/ClusterTagUpdatedEvent.java | 82 + .../java/org/apache/ignite/events/EventType.java | 18 +- .../igfs/IgfsParentNotDirectoryException.java | 2 +- .../local/LocalIgfsSecondaryFileSystem.java | 37 +- .../ignite/internal/GridEventConsumeHandler.java | 12 +- .../apache/ignite/internal/GridKernalContext.java | 2 +- .../ignite/internal/GridKernalContextImpl.java | 2 +- .../java/org/apache/ignite/internal/GridTopic.java | 5 +- .../org/apache/ignite/internal/IgniteFeatures.java | 12 +- .../org/apache/ignite/internal/IgniteKernal.java | 69 +- .../ignite/internal/MarshallerContextImpl.java | 32 +- .../internal/MarshallerMappingFileStore.java | 65 +- .../ignite/internal/SecurityAwareBiPredicate.java | 8 +- .../ignite/internal/TransactionsMXBeanImpl.java | 10 + .../internal/binary/BinaryClassDescriptor.java | 4 +- .../ignite/internal/binary/BinaryContext.java | 11 +- .../ignite/internal/binary/BinaryEnumCache.java | 3 +- .../ignite/internal/binary/BinaryFieldImpl.java | 4 +- .../internal/binary/BinaryFieldMetadata.java | 5 +- .../internal/binary/BinaryMethodWriteReplacer.java | 5 +- .../ignite/internal/binary/BinaryRawWriterEx.java | 2 +- .../internal/binary/BinaryReaderHandles.java | 3 +- .../ignite/internal/binary/BinarySchema.java | 3 +- .../internal/binary/BinarySchemaRegistry.java | 3 +- .../binary/BinarySerializedFieldComparator.java | 3 +- .../internal/binary/BinaryThreadLocalContext.java | 2 +- .../ignite/internal/binary/BinaryTreeMap.java | 9 +- .../binary/BinaryTreeMapWriteReplacer.java | 3 +- .../ignite/internal/binary/BinaryTreeSet.java | 7 +- .../binary/BinaryTreeSetWriteReplacer.java | 3 +- .../ignite/internal/binary/BinaryTypeImpl.java | 6 +- .../ignite/internal/binary/BinaryTypeProxy.java | 3 +- .../apache/ignite/internal/binary/BinaryUtils.java | 7 +- .../ignite/internal/binary/BinaryWriterExImpl.java | 2 +- .../internal/binary/GridBinaryMarshaller.java | 2 +- .../internal/binary/builder/BinaryBuilderEnum.java | 4 +- .../binary/builder/BinaryBuilderReader.java | 21 +- .../binary/builder/BinaryEnumArrayLazyValue.java | 4 +- .../binary/builder/BinaryLazyArrayList.java | 2 +- .../binary/builder/BinaryLazyLinkedList.java | 2 +- .../internal/binary/builder/BinaryLazyMap.java | 2 +- .../internal/binary/builder/BinaryLazySet.java | 2 +- .../binary/builder/BinaryObjectArrayLazyValue.java | 4 +- .../binary/builder/BinaryPlainBinaryObject.java | 2 +- .../internal/client/GridClientClusterState.java | 18 +- .../client/impl/GridClientClusterStateImpl.java | 24 + .../GridClientZipOptimizedMarshaller.java | 2 +- .../client/router/impl/GridRouterClientImpl.java | 2 +- .../client/thin/ClientClusterGroupImpl.java | 14 +- .../internal/client/thin/ClientClusterImpl.java | 12 + .../internal/client/thin/ClientComputeImpl.java | 57 +- .../internal/client/thin/ClientOperation.java | 4 +- .../internal/client/thin/ClientServicesImpl.java | 180 ++ .../ignite/internal/client/thin/ClientUtils.java | 11 +- .../client/thin/ProtocolBitmaskFeature.java | 5 +- .../internal/client/thin/ProtocolContext.java | 12 + .../internal/client/thin/ReliableChannel.java | 12 + .../client/thin/TcpClientTransactions.java | 64 +- .../internal/client/thin/TcpIgniteClient.java | 137 +- .../internal/cluster/ClusterGroupAdapter.java | 220 +- .../internal/cluster/ClusterNodeLocalMapImpl.java | 2 +- .../internal/cluster/IgniteClusterAsyncImpl.java | 15 + .../ignite/internal/cluster/IgniteClusterImpl.java | 68 + .../internal/commandline/BaselineCommand.java | 281 --- .../internal/commandline/CommandArgIterator.java | 158 -- .../ignite/internal/commandline/CommandList.java | 122 -- .../internal/commandline/CommonArgParser.java | 350 --- .../ignite/internal/commandline/StateCommand.java | 88 - .../ignite/internal/commandline/TxCommands.java | 558 ----- .../commandline/cache/CacheValidateIndexes.java | 344 --- .../internal/commandline/cache/IdleVerify.java | 394 ---- .../CheckIndexInlineSizesTask.java | 5 +- .../commandline/meta/subcommands/VoidDto.java | 42 + .../commandline/meta/tasks/MetadataInfoTask.java | 88 + .../commandline/meta/tasks/MetadataListResult.java | 74 + .../commandline/meta/tasks/MetadataMarshalled.java | 86 + .../commandline/meta/tasks/MetadataRemoveTask.java | 148 ++ .../commandline/meta/tasks/MetadataTypeArgs.java | 96 + .../commandline/meta/tasks/MetadataUpdateTask.java | 97 + .../internal/commandline/query/KillCommand.java | 214 -- .../internal/commandline/query/KillSubcommand.java | 52 - .../commandline/snapshot/SnapshotCommand.java | 100 - .../commandline/snapshot/SnapshotSubcommand.java | 56 - .../org/apache/ignite/internal/jdbc/JdbcUtils.java | 2 +- .../internal/jdbc/thin/JdbcThinConnection.java | 8 +- .../internal/managers/IgniteMBeansManager.java | 4 +- .../managers/communication/GridIoManager.java | 241 ++- .../managers/communication/GridIoMessage.java | 15 +- .../communication/GridIoMessageFactory.java | 2 + .../communication/GridIoSecurityAwareMessage.java | 8 +- .../managers/deployment/GridDeployment.java | 2 +- .../deployment/GridDeploymentCommunication.java | 9 +- .../managers/discovery/ClusterMetricsImpl.java | 2 +- .../managers/discovery/GridDiscoveryManager.java | 5 +- .../systemview/walker/ComputeJobViewWalker.java | 2 +- .../walker/PartitionStateViewWalker.java | 75 + .../pagemem/impl/PageMemoryNoStoreImpl.java | 4 +- .../pagemem/wal/record/CheckpointRecord.java | 3 +- .../pagemem/wal/record/MasterKeyChangeRecord.java | 2 +- .../affinity/GridAffinityAssignmentCache.java | 7 + .../processors/bulkload/BulkLoadCsvFormat.java | 3 +- .../processors/bulkload/BulkLoadCsvParser.java | 13 +- .../processors/bulkload/BulkLoadParser.java | 3 +- .../bulkload/pipeline/CharsetDecoderBlock.java | 5 +- .../bulkload/pipeline/CsvLineProcessorBlock.java | 3 +- .../bulkload/pipeline/LineSplitterBlock.java | 3 +- .../cache/CacheAffinitySharedManager.java | 6 + .../cache/CacheClusterMetricsMXBeanImpl.java | 5 + .../cache/CacheDefaultBinaryAffinityKeyMapper.java | 5 +- .../processors/cache/CacheGroupMetricsImpl.java | 10 +- .../cache/CacheLocalMetricsMXBeanImpl.java | 5 + .../processors/cache/CacheMetricsImpl.java | 62 +- .../processors/cache/CacheMetricsSnapshot.java | 5 + .../processors/cache/CacheMetricsSnapshotV2.java | 12 + .../cache/CachePartialUpdateCheckedException.java | 7 + .../processors/cache/ClusterCachesInfo.java | 77 +- .../processors/cache/DynamicCacheDescriptor.java | 31 +- .../internal/processors/cache/ExchangeActions.java | 6 +- .../cache/GatewayProtectedCacheProxy.java | 8 +- .../processors/cache/GridCacheAdapter.java | 6 + .../processors/cache/GridCacheContext.java | 37 +- .../processors/cache/GridCacheContextInfo.java | 31 +- .../processors/cache/GridCacheEntryInfo.java | 3 +- .../cache/GridCacheLockTimeoutException.java | 2 +- .../cache/GridCachePartitionExchangeManager.java | 368 ++-- .../processors/cache/GridCachePreloader.java | 5 +- .../cache/GridCachePreloaderAdapter.java | 5 +- .../processors/cache/GridCacheProcessor.java | 222 +- .../internal/processors/cache/GridCacheUtils.java | 38 + .../processors/cache/IgniteCacheProxyImpl.java | 59 +- .../cache/LongOperationsDumpSettingsClosure.java | 8 +- .../processors/cache/StateChangeRequest.java | 4 +- .../cache/ValidationOnNodeJoinUtils.java | 31 +- .../processors/cache/WalStateAbstractMessage.java | 3 +- .../processors/cache/WalStateAckMessage.java | 5 +- .../cache/WalStateDistributedProcess.java | 9 +- .../internal/processors/cache/WalStateManager.java | 2 +- .../cache/binary/BinaryMetadataFileStore.java | 283 ++- .../cache/binary/BinaryMetadataHolder.java | 32 +- .../cache/binary/BinaryMetadataTransport.java | 446 ++-- .../binary/CacheObjectBinaryProcessorImpl.java | 117 +- .../processors/cache/binary/IgniteBinaryImpl.java | 7 +- .../binary/MetadataRemoveAcceptedMessage.java | 96 + .../binary/MetadataRemoveProposedMessage.java | 143 ++ .../distributed/GridDistributedCacheEntry.java | 4 + .../GridDistributedTxFinishRequest.java | 2 +- .../GridDistributedTxRemoteAdapter.java | 2 +- .../dht/GridDhtAssignmentFetchFuture.java | 2 +- .../cache/distributed/dht/GridDhtCacheAdapter.java | 4 +- .../dht/GridDhtTopologyFutureAdapter.java | 8 +- .../dht/preloader/GridDhtPartitionDemander.java | 57 +- .../dht/preloader/GridDhtPartitionSupplier.java | 91 +- .../preloader/GridDhtPartitionsExchangeFuture.java | 393 +++- .../dht/preloader/GridDhtPreloader.java | 36 +- .../IgniteDhtPartitionHistorySuppliersMap.java | 15 +- .../IgniteHistoricalIteratorException.java | 48 + .../preloader/RebalanceReassignExchangeTask.java | 15 +- .../dht/preloader/SupplyPartitionInfo.java | 99 + .../dht/topology/GridClientPartitionTopology.java | 2 +- .../dht/topology/GridDhtPartitionTopology.java | 2 +- .../dht/topology/GridDhtPartitionTopologyImpl.java | 71 +- .../distributed/near/IgniteTxMappingsImpl.java | 2 +- .../cache/local/GridLocalLockFuture.java | 4 +- .../processors/cache/mvcc/MvccProcessorImpl.java | 14 +- .../processors/cache/mvcc/MvccVersionImpl.java | 3 +- .../cache/persistence/DataStorageMetricsImpl.java | 2 +- .../cache/persistence/DataStructure.java | 4 +- .../GridCacheDatabaseSharedManager.java | 227 +- .../cache/persistence/GridCacheOffheapManager.java | 157 +- .../IgniteCacheDatabaseSharedManager.java | 15 +- .../persistence/checkpoint/CheckpointEntry.java | 15 +- .../persistence/checkpoint/CheckpointHistory.java | 305 ++- .../persistence/checkpoint/CheckpointProgress.java | 3 +- .../checkpoint/CheckpointProgressImpl.java | 9 +- .../checkpoint/PartitionDestroyQueue.java | 5 +- .../persistence/checkpoint/ReservationReason.java | 50 + .../pagelocktracker/stack/LockStack.java | 2 +- .../evict/Random2LruPageEvictionTracker.java | 2 +- .../cache/persistence/file/EncryptedFileIO.java | 4 +- .../persistence/file/EncryptedFileIOFactory.java | 2 +- .../filename/PdsConsistentIdProcessor.java | 3 + .../cache/persistence/pagemem/PageMemoryImpl.java | 12 +- .../partstorage/PartitionMetaStorage.java | 2 +- .../snapshot/IgniteSnapshotManager.java | 170 +- .../persistence/snapshot/SnapshotFutureTask.java | 8 +- .../persistence/snapshot/SnapshotMXBeanImpl.java | 5 + .../persistence/tree/reuse/ReuseListImpl.java | 2 +- .../cache/persistence/tree/util/PageHandler.java | 2 +- .../persistence/wal/FileWriteAheadLogManager.java | 4 +- .../wal/aware/SegmentCompressStorage.java | 4 +- .../wal/io/LockedSegmentFileInputFactory.java | 2 +- .../wal/reader/StandaloneGridKernalContext.java | 4 +- .../query/GridCacheDistributedQueryManager.java | 7 +- .../cache/query/GridCacheQueryManager.java | 14 +- .../cache/query/GridCacheQueryMetricsAdapter.java | 2 +- .../query/GridCacheQuerySqlMetadataJobV2.java | 13 +- .../cache/query/GridCacheQuerySqlMetadataV2.java | 5 +- .../cache/query/IgniteQueryErrorCode.java | 3 + .../cache/query/QueryEntityTypeDescriptor.java | 14 +- .../CacheContinuousQueryEventBuffer.java | 169 +- .../continuous/CacheContinuousQueryHandler.java | 18 +- .../continuous/CacheContinuousQueryListener.java | 12 +- .../continuous/CacheContinuousQueryManager.java | 28 +- .../CacheContinuousQueryPartitionRecovery.java | 16 +- .../query/continuous/SecurityAwareFilter.java | 22 +- .../SecurityAwareTransformerFactory.java | 22 +- .../cache/store/CacheOsStoreManager.java | 2 +- .../cache/transactions/IgniteTxManager.java | 290 ++- .../TxCollisionsDumpSettingsClosure.java | 54 + .../cache/verify/IdleVerifyResultV2.java | 4 +- .../verify/VerifyBackupPartitionsDumpTask.java | 26 +- .../cache/verify/VerifyBackupPartitionsTaskV2.java | 2 +- .../cacheobject/IgniteCacheObjectProcessor.java | 10 + .../cluster/ChangeGlobalStateFinishMessage.java | 4 +- .../cluster/ChangeGlobalStateMessage.java | 2 +- .../ClientGetClusterStateComputeRequest.java | 42 + .../ClientSetClusterStateComputeRequest.java | 84 + .../processors/cluster/ClusterIdAndTag.java | 80 + .../processors/cluster/ClusterProcessor.java | 264 ++- .../processors/cluster/ClusterTagGenerator.java | 862 ++++++++ .../cluster/DiscoveryDataClusterState.java | 2 +- .../cluster/GridClusterStateProcessor.java | 221 +- .../cluster/IgniteClusterMXBeanImpl.java | 62 + .../datastreamer/DataStreamProcessor.java | 7 +- .../datastructures/DataStructureInfoKey.java | 3 +- .../datastructures/DataStructuresCacheKey.java | 3 +- .../datastructures/GridCacheAtomicLongImpl.java | 2 +- .../GridCacheAtomicSequenceImpl.java | 11 +- .../GridCacheCountDownLatchImpl.java | 2 +- .../datastructures/GridCacheLockImpl.java | 5 +- .../datastructures/GridCacheSemaphoreImpl.java | 2 +- .../processors/hadoop/HadoopClassLoader.java | 21 +- .../processors/hadoop/HadoopNoopHelper.java | 3 +- .../hadoop/shuffle/HadoopDirectShuffleMessage.java | 9 +- .../hadoop/shuffle/HadoopShuffleAck.java | 11 +- .../hadoop/shuffle/HadoopShuffleFinishRequest.java | 9 +- .../shuffle/HadoopShuffleFinishResponse.java | 9 +- .../processors/igfs/IgfsAbstractOutputStream.java | 7 +- .../processors/igfs/IgfsClientSession.java | 2 +- .../internal/processors/igfs/IgfsCreateResult.java | 3 +- .../internal/processors/igfs/IgfsDataManager.java | 4 +- .../internal/processors/igfs/IgfsDeleteWorker.java | 15 +- .../processors/igfs/IgfsDirectoryInfo.java | 15 +- .../internal/processors/igfs/IgfsEntryInfo.java | 13 +- .../internal/processors/igfs/IgfsFileImpl.java | 13 +- .../internal/processors/igfs/IgfsFileInfo.java | 13 +- .../processors/igfs/IgfsFileWorkerBatch.java | 9 +- .../processors/igfs/IgfsInputStreamImpl.java | 21 +- .../internal/processors/igfs/IgfsIpcHandler.java | 15 +- ...sLazySecondaryFileSystemPositionedReadable.java | 3 +- .../internal/processors/igfs/IgfsListingEntry.java | 9 +- .../processors/igfs/IgfsOutputStreamImpl.java | 7 +- .../processors/igfs/IgfsOutputStreamProxyImpl.java | 7 +- .../internal/processors/igfs/IgfsPathIds.java | 5 +- .../processors/igfs/IgfsPathsCreateResult.java | 3 +- .../internal/processors/igfs/IgfsProcessor.java | 2 +- .../igfs/IgfsSecondaryFileSystemCreateContext.java | 5 +- .../igfs/IgfsSecondaryFileSystemImpl.java | 7 +- .../ignite/internal/processors/igfs/IgfsUtils.java | 29 +- .../igfs/client/IgfsClientAffinityCallable.java | 3 +- .../igfs/client/IgfsClientListFilesCallable.java | 3 +- .../igfs/client/IgfsClientListPathsCallable.java | 3 +- .../igfs/client/IgfsClientMkdirsCallable.java | 3 +- .../igfs/client/IgfsClientUpdateCallable.java | 3 +- .../meta/IgfsClientMetaIdsForPathCallable.java | 3 +- .../processors/igfs/data/IgfsDataPutProcessor.java | 15 +- .../meta/IgfsMetaDirectoryCreateProcessor.java | 19 +- .../meta/IgfsMetaDirectoryListingAddProcessor.java | 17 +- .../IgfsMetaDirectoryListingRemoveProcessor.java | 19 +- .../IgfsMetaDirectoryListingRenameProcessor.java | 19 +- .../IgfsMetaDirectoryListingReplaceProcessor.java | 19 +- .../igfs/meta/IgfsMetaFileCreateProcessor.java | 17 +- .../igfs/meta/IgfsMetaFileLockProcessor.java | 15 +- .../meta/IgfsMetaFileRangeDeleteProcessor.java | 15 +- .../meta/IgfsMetaFileRangeUpdateProcessor.java | 15 +- .../meta/IgfsMetaFileReserveSpaceProcessor.java | 15 +- .../igfs/meta/IgfsMetaFileUnlockProcessor.java | 15 +- .../meta/IgfsMetaUpdatePropertiesProcessor.java | 17 +- .../igfs/meta/IgfsMetaUpdateTimesProcessor.java | 15 +- .../local/LocalFileSystemPositionedReadable.java | 3 +- .../igfs/secondary/local/LocalFileSystemUtils.java | 13 +- .../internal/processors/job/GridJobProcessor.java | 2 +- .../metastorage/DistributedMetaStorage.java | 5 + .../processors/metric/GridMetricManager.java | 2 +- .../metric/PushMetricsExporterAdapter.java | 2 +- .../ClientListenerAbstractConnectionContext.java | 11 +- .../odbc/ClientListenerBufferedParser.java | 7 +- .../processors/odbc/ClientListenerProcessor.java | 138 +- .../odbc/jdbc/JdbcConnectionContext.java | 2 +- .../odbc/odbc/OdbcConnectionContext.java | 2 +- .../processors/odbc/odbc/OdbcRequestHandler.java | 4 +- .../odbc/odbc/OdbcRequestHandlerWorker.java | 3 +- .../processors/odbc/odbc/OdbcTableMeta.java | 3 +- .../odbc/odbc/escape/OdbcEscapeUtils.java | 5 +- .../platform/PlatformConfigurationEx.java | 5 +- .../processors/platform/PlatformContext.java | 3 +- .../processors/platform/PlatformContextImpl.java | 15 +- .../platform/PlatformDefaultJavaObjectFactory.java | 3 +- .../platform/PlatformJavaObjectFactoryEx.java | 3 +- .../platform/PlatformJavaObjectFactoryProxy.java | 13 +- .../internal/processors/platform/PlatformLock.java | 107 + .../platform/PlatformNativeException.java | 3 +- .../processors/platform/PlatformProcessorImpl.java | 34 +- .../platform/binary/PlatformBinaryProcessor.java | 5 +- .../processors/platform/cache/PlatformCache.java | 3 + .../cache/PlatformCacheEntryProcessorImpl.java | 13 +- .../cache/PlatformCachePartialUpdateException.java | 3 +- .../platform/cache/affinity/PlatformAffinity.java | 2 +- .../cache/affinity/PlatformAffinityFunction.java | 13 +- .../affinity/PlatformAffinityFunctionTarget.java | 3 +- .../cache/affinity/PlatformAffinityUtils.java | 7 +- .../cache/expiry/PlatformExpiryPolicy.java | 2 +- .../cache/query/PlatformContinuousQuery.java | 3 +- .../cache/query/PlatformContinuousQueryImpl.java | 107 +- .../query/PlatformContinuousQueryRemoteFilter.java | 17 +- .../cache/query/PlatformFieldsQueryCursor.java | 19 +- .../platform/client/ClientBitmaskFeature.java | 5 +- .../platform/client/ClientConnectionContext.java | 2 +- .../platform/client/ClientMessageParser.java | 12 +- .../platform/client/IgniteClientException.java | 3 +- .../client/binary/ClientBinaryTypeGetResponse.java | 2 +- .../cache/ClientCacheConfigurationSerializer.java | 16 +- .../client/cache/ClientCacheEntryQueryCursor.java | 3 +- .../client/cache/ClientCacheFieldsQueryCursor.java | 3 +- .../client/cache/ClientCacheGetAllRequest.java | 3 +- .../client/cache/ClientCacheGetAllResponse.java | 3 +- .../client/cache/ClientCacheGetNamesRequest.java | 3 +- .../client/cache/ClientCacheGetNamesResponse.java | 3 +- .../client/cache/ClientCacheQueryCursor.java | 5 +- .../platform/client/cache/ClientCacheRequest.java | 3 +- .../cache/ClientCacheSqlFieldsQueryResponse.java | 3 +- .../cluster/ClientClusterGetStateRequest.java | 2 +- .../ClientClusterGroupGetNodeIdsResponse.java | 3 +- .../ClientClusterGroupGetNodesDetailsRequest.java | 5 +- ...lientClusterGroupGetNodesEndpointsResponse.java | 6 +- .../platform/client/compute/ClientComputeTask.java | 4 +- .../client/compute/ClientExecuteTaskRequest.java | 2 +- .../client/service/ClientServiceInvokeRequest.java | 323 +++ .../platform/compute/PlatformAbstractFunc.java | 3 +- .../platform/compute/PlatformFullTask.java | 2 +- .../cpp/PlatformCppConfigurationClosure.java | 9 +- .../platform/cpp/PlatformCppConfigurationEx.java | 3 +- .../datastreamer/PlatformDataStreamer.java | 2 +- .../datastreamer/PlatformStreamReceiverImpl.java | 11 +- .../platform/dotnet/PlatformDotNetBootstrap.java | 3 +- .../platform/dotnet/PlatformDotNetCacheStore.java | 17 +- .../dotnet/PlatformDotNetConfigurationClosure.java | 7 +- .../dotnet/PlatformDotNetConfigurationEx.java | 5 +- .../dotnet/PlatformDotNetConsoleStream.java | 3 +- ...latformDotNetEntityFrameworkCacheExtension.java | 17 +- .../PlatformDotNetEntityFrameworkCacheKey.java | 3 +- ...NetEntityFrameworkIncreaseVersionProcessor.java | 3 +- .../events/PlatformEventFilterListenerImpl.java | 11 +- .../processors/platform/events/PlatformEvents.java | 9 +- .../platform/message/PlatformMessageFilter.java | 3 +- .../messaging/PlatformMessageFilterImpl.java | 3 +- .../messaging/PlatformMessageLocalFilter.java | 3 +- .../platform/messaging/PlatformMessaging.java | 3 +- .../platform/services/PlatformServices.java | 51 +- .../transactions/PlatformTransactions.java | 9 +- .../platform/utils/PlatformConfigurationUtils.java | 20 +- .../platform/utils/PlatformListenable.java | 4 +- .../processors/platform/utils/PlatformUtils.java | 33 +- .../PlatformDotNetSessionCacheExtension.java | 5 +- .../websession/PlatformDotNetSessionData.java | 9 +- .../PlatformDotNetSessionLockProcessor.java | 9 +- .../PlatformDotNetSessionLockResult.java | 3 +- ...PlatformDotNetSessionSetAndUnlockProcessor.java | 11 +- .../processors/plugin/CachePluginManager.java | 3 +- .../processors/query/GridQueryIndexDescriptor.java | 3 +- .../processors/query/GridQueryProcessor.java | 385 +++- .../internal/processors/query/QueryEntityEx.java | 5 +- .../internal/processors/query/QueryField.java | 3 +- .../processors/query/QueryIndexDescriptorImpl.java | 11 +- .../internal/processors/query/QueryIndexKey.java | 3 +- .../processors/query/QueryKeyValueIterable.java | 5 +- .../processors/query/QueryKeyValueIterator.java | 7 +- .../internal/processors/query/QuerySchema.java | 50 +- .../processors/query/QueryTypeDescriptorImpl.java | 9 +- .../internal/processors/query/QueryUtils.java | 26 +- .../query/property/QueryFieldAccessor.java | 3 +- .../query/property/QueryMethodsAccessor.java | 3 +- .../property/QueryReadOnlyMethodsAccessor.java | 3 +- .../SchemaIndexOperationCancellationToken.java | 3 +- .../query/schema/SchemaOperationClientFuture.java | 3 +- .../query/schema/SchemaOperationException.java | 6 + .../query/schema/SchemaOperationManager.java | 11 +- .../query/schema/SchemaOperationWorker.java | 6 +- .../message/SchemaOperationStatusMessage.java | 5 +- .../schema/operation/SchemaAbstractOperation.java | 3 +- .../operation/SchemaAddQueryEntityOperation.java | 82 + .../operation/SchemaIndexCreateOperation.java | 3 +- .../schema/operation/SchemaIndexDropOperation.java | 3 +- .../internal/processors/rest/GridRestCommand.java | 4 +- .../processors/rest/GridRestProcessor.java | 15 +- .../redis/string/GridRedisMGetCommandHandler.java | 2 +- .../tcp/redis/GridRedisProtocolParser.java | 40 + .../AbstractSecurityAwareExternalizable.java | 17 + .../processors/security/SecurityUtils.java | 11 +- .../processors/service/GridServiceProxy.java | 10 +- .../internal/sql/command/SqlBulkLoadCommand.java | 7 +- .../sql/command/SqlCreateIndexCommand.java | 13 +- .../optimizer/affinity/PartitionTableModel.java | 3 +- .../ignite/internal/tck/TCKMBeanServerBuilder.java | 2 +- .../internal/util/GridConcurrentFactory.java | 2 +- .../util/GridConcurrentMultiPairQueue.java | 5 +- .../org/apache/ignite/internal/util/GridDebug.java | 4 +- .../apache/ignite/internal/util/GridKeyLock.java | 2 +- .../apache/ignite/internal/util/IgniteUtils.java | 30 + .../internal/util/SerializableTransient.java | 3 +- .../apache/ignite/internal/util/lang/GridFunc.java | 14 + .../ignite/internal/util/lang/GridInClosure3X.java | 5 +- .../gridfunc/ConcurrentMapFactoryCallable.java | 2 +- .../ignite/internal/util/nio/GridNioServer.java | 10 +- .../apache/ignite/internal/util/scala/impl.java | 6 +- .../util/tostring/GridToStringBuilder.java | 2 +- .../util/tostring/GridToStringInclude.java | 3 +- .../internal/util/tostring/SBLimitedLength.java | 2 +- .../apache/ignite/internal/util/typedef/CI3.java | 3 +- .../ignite/internal/visor/cache/VisorCache.java | 2 +- .../internal/visor/cache/VisorCacheJdbcType.java | 3 +- .../internal/visor/cache/VisorPartitionMap.java | 2 +- .../visor/encryption/VisorChangeMasterKeyTask.java | 2 - .../encryption/VisorGetMasterKeyNameTask.java | 2 - .../visor/misc/VisorClusterChangeTagTask.java | 88 + .../visor/misc/VisorClusterChangeTagTaskArg.java | 59 + .../misc/VisorClusterChangeTagTaskResult.java | 88 + .../internal/visor/misc/VisorIdAndTagViewTask.java | 68 + .../visor/misc/VisorIdAndTagViewTaskResult.java | 74 + .../visor/node/VisorMemoryConfiguration.java | 2 +- .../visor/snapshot/VisorSnapshotCancelTask.java | 60 + .../visor/snapshot/VisorSnapshotCreateTask.java | 2 - .../websession/WebSessionAttributeProcessor.java | 11 +- .../internal/websession/WebSessionEntity.java | 9 +- .../AbstractNodeNameAwareMarshaller.java | 5 +- .../apache/ignite/mxbean/CacheMetricsMXBean.java | 17 +- .../apache/ignite/mxbean/IgniteClusterMXBean.java | 56 + .../org/apache/ignite/mxbean/SnapshotMXBean.java | 10 +- .../apache/ignite/mxbean/TransactionsMXBean.java | 20 + .../dotnet/PlatformDotNetAffinityFunction.java | 15 +- .../dotnet/PlatformDotNetBinaryConfiguration.java | 3 +- .../dotnet/PlatformDotNetCacheStoreFactory.java | 5 +- .../PlatformDotNetCacheStoreFactoryNative.java | 3 +- .../dotnet/PlatformDotNetConfiguration.java | 5 +- .../dotnet/PlatformDotNetLifecycleBean.java | 3 +- .../apache/ignite/plugin/CachePluginProvider.java | 3 +- .../ignite/plugin/PluginValidationException.java | 5 +- .../ignite/plugin/security/SecurityPermission.java | 5 +- .../spi/IgniteSpiOperationTimeoutHelper.java | 16 + .../spi/communication/tcp/TcpCommunicationSpi.java | 275 ++- .../tcp/internal/ConnectionRequestFuture.java | 28 + .../tcp/internal/ConnectionRequestor.java | 32 + .../tcp/internal/NodeUnreachableException.java | 49 + .../internal/TcpConnectionIndexAwareMessage.java | 31 + .../TcpConnectionRequestDiscoveryMessage.java | 97 + .../TcpInverseConnectionResponseMessage.java | 117 + .../spi/deployment/local/LocalDeploymentSpi.java | 2 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 126 +- .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 9 + .../TcpDiscoveryServerOnlyCustomEventMessage.java | 6 +- .../spi/indexing/IndexingQueryCacheFilter.java | 3 +- .../spi/indexing/IndexingQueryFilterImpl.java | 3 +- .../adaptive/AdaptiveLoadBalancingSpi.java | 2 +- .../ignite/spi/systemview/view/CacheGroupView.java | 2 +- .../ignite/spi/systemview/view/CacheView.java | 2 +- .../spi/systemview/view/PartitionStateView.java | 91 + .../main/resources/META-INF/classnames.properties | 66 +- .../test/java/org/apache/ignite/GridTestJob.java | 3 +- .../RendezvousAffinityFunctionSimpleBenchmark.java | 23 +- ...StoreSessionListenerWriteBehindEnabledTest.java | 2 +- .../cache/store/CacheStoreWriteErrorTest.java | 2 +- .../store/StoreResourceInjectionSelfTest.java | 14 +- ...JdbcPojoWriteBehindStoreWithCoalescingTest.java | 3 +- .../ignite/cache/store/jdbc/model/TestPojo.java | 2 +- .../org/apache/ignite/client/AsyncChannelTest.java | 16 +- .../ignite/client/ConnectToStartingNodeTest.java | 12 +- .../org/apache/ignite/client/FunctionalTest.java | 102 + .../org/apache/ignite/client/IgniteBinaryTest.java | 65 + .../test/java/org/apache/ignite/client/Person.java | 6 + .../ignite/internal/ClusterGroupSelfTest.java | 118 +- .../ignite/internal/GridGetOrStartSelfTest.java | 9 +- .../BinaryArrayIdentityResolverSelfTest.java | 7 +- .../BinaryConfigurationConsistencySelfTest.java | 2 +- .../binary/BinaryFieldsAbstractSelfTest.java | 11 +- .../internal/binary/BinaryMarshallerSelfTest.java | 2 +- .../BinaryObjectBuilderAdditionalSelfTest.java | 8 +- .../BinaryObjectBuilderDefaultMappersSelfTest.java | 4 +- .../internal/binary/BinaryObjectToStringTest.java | 2 +- .../BinarySerialiedFieldComparatorSelfTest.java | 13 +- .../binary/GridBinaryAffinityKeySelfTest.java | 2 +- .../binary/GridBinaryWildcardsSelfTest.java | 2 +- ...DefaultBinaryMappersBinaryMetaDataSelfTest.java | 14 +- .../GridBinaryMarshalerAwareTestClass.java | 4 +- .../binary/mutabletest/GridBinaryTestClasses.java | 2 +- .../client/thin/AbstractThinClientTest.java | 79 + .../internal/client/thin/ClusterApiTest.java | 13 +- .../internal/client/thin/ClusterGroupTest.java | 19 +- .../internal/client/thin/ComputeTaskTest.java | 63 +- .../ignite/internal/client/thin/ServicesTest.java | 417 ++++ .../internal/client/thin/TestFailoverTask.java | 7 +- .../internal/client/thin/TestResultCacheTask.java | 5 +- .../ignite/internal/client/thin/TestTask.java | 11 +- .../FullyConnectedComponentSearcherTest.java | 2 +- .../internal/cluster/IgniteClusterIdTagTest.java | 427 ++++ .../commandline/CommandHandlerParsingTest.java | 635 ------ .../encryption/AbstractEncryptionTest.java | 5 +- .../encryption/EncryptedCacheCreateTest.java | 2 +- .../internal/encryption/MasterKeyChangeTest.java | 43 + .../MessageDirectTypeIdConflictTest.java | 1 - .../GridDeploymentMessageCountSelfTest.java | 2 +- .../optimized/OptimizedMarshallerTest.java | 4 +- .../internal/metric/IoStatisticsCacheSelfTest.java | 2 +- .../ignite/internal/metric/SystemViewSelfTest.java | 4 +- .../affinity/GridAffinityAssignmentV2Test.java | 4 +- ...eateDestroyClusterReadOnlyModeAbstractTest.java | 45 + .../CacheCreateDestroyClusterReadOnlyModeTest.java | 186 ++ .../processors/cache/CacheGroupMetricsTest.java | 68 +- .../cache/CacheGroupsMetricsRebalanceTest.java | 2 +- .../cache/CacheLockCandidatesThreadTest.java | 13 +- .../processors/cache/CacheMetricsManageTest.java | 342 ++- .../cache/CacheOffheapMapEntrySelfTest.java | 2 +- .../processors/cache/CacheRemoveAllSelfTest.java | 2 +- ...ActiveStateChangeWithNodeOutOfBaselineTest.java | 6 +- .../cache/ClusterReadOnlyModeTestUtils.java | 87 +- .../processors/cache/ClusterStateAbstractTest.java | 2 +- .../cache/ClusterStateServerAbstractTest.java | 2 +- ...dCacheAbstractFullApiMultithreadedSelfTest.java | 2 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 18 +- .../cache/GridCacheAbstractLocalStoreSelfTest.java | 2 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 2 +- .../cache/GridCacheAbstractRemoveFailureTest.java | 2 +- .../GridCacheInterceptorAbstractSelfTest.java | 2 +- ...ultinodeUpdateNearEnabledNoBackupsSelfTest.java | 2 +- ...ridCacheMultinodeUpdateNearEnabledSelfTest.java | 2 +- .../cache/GridCacheP2PUndeploySelfTest.java | 2 +- .../cache/GridCachePutAllFailoverSelfTest.java | 2 +- ...dLocalCacheStoreManagerDeserializationTest.java | 5 +- .../cache/GridLocalIgniteSerializationTest.java | 17 +- .../IgniteAbstractDynamicCacheStartFailTest.java | 20 +- .../processors/cache/IgniteCacheAbstractTest.java | 2 +- ...IgniteCacheClusterReadOnlyModeAbstractTest.java | 263 +++ .../IgniteCacheClusterReadOnlyModeSelfTest.java | 531 +++++ .../processors/cache/IgniteCacheGroupsTest.java | 2 +- ...niteCacheInvokeClusterReadOnlyModeSelfTest.java | 141 ++ .../cache/IgniteCachePeekModesAbstractTest.java | 2 +- ...gniteCacheStoreClusterReadOnlyModeSelfTest.java | 302 +++ .../cache/IgniteCacheStoreCollectionTest.java | 2 +- .../cache/IgniteCacheTxNearPeekModesTest.java | 3 +- .../cache/IgniteCachingProviderSelfTest.java | 2 +- .../cache/IgniteClusterActivateDeactivateTest.java | 41 +- ...usterActivateDeactivateTestWithPersistence.java | 8 +- .../cache/IgniteDynamicCacheAndNodeStop.java | 14 +- .../cache/IgniteDynamicCacheStartSelfTest.java | 45 +- .../cache/IgniteIncompleteCacheObjectSelfTest.java | 5 +- ...hallerCacheClientRequestsMappingOnMissTest.java | 5 +- .../cache/IgniteMarshallerCacheFSRestoreTest.java | 11 +- ...IgniteNearCacheClusterReadOnlyModeSelfTest.java | 33 + ...NearCacheInvokeClusterReadOnlyModeSelfTest.java | 35 + .../cache/IgniteOnePhaseCommitNearSelfTest.java | 61 +- .../processors/cache/MapCacheStoreStrategy.java | 2 +- .../MarshallerCacheJobRunNodeRestartTest.java | 3 +- ...NonAffinityCoordinatorDynamicStartStopTest.java | 4 +- .../SetTxTimeoutOnPartitionMapExchangeTest.java | 6 +- .../binary/BinaryMetadataMoveLegacyFolderTest.java | 225 ++ .../cache/binary/BinaryMetadataRemoveTest.java | 308 +++ .../BinaryMetadataRemoveWithPersistenceTest.java | 86 + .../GridCacheBinaryStoreAbstractSelfTest.java | 4 +- ...ridCacheClientNodeBinaryObjectMetadataTest.java | 2 +- .../DataStreamProcessorBinarySelfTest.java | 2 +- .../GridCacheAffinityRoutingBinarySelfTest.java | 4 +- ...riesNearPartitionedByteArrayValuesSelfTest.java | 2 +- ...riesPartitionedOnlyByteArrayValuesSelfTest.java | 2 +- .../IgniteAtomicLongClusterReadOnlyTest.java | 150 ++ .../IgniteAtomicReferenceClusterReadOnlyTest.java | 114 + .../IgniteAtomicSequenceClusterReadOnlyTest.java | 126 ++ .../IgniteAtomicStampedClusterReadOnlyTest.java | 132 ++ ...niteCollectionsClusterReadOnlyAbstractTest.java | 227 ++ .../IgniteCountDownLatchClusterReadOnlyTest.java | 129 ++ .../IgniteDataStructureUniqueNameTest.java | 2 +- ...tructuresCreateDeniedInClusterReadOnlyMode.java | 156 ++ .../IgniteDataStructuresTestUtils.java | 129 ++ .../datastructures/IgniteLockAbstractSelfTest.java | 19 + .../IgniteQueueClusterReadOnlyTest.java | 91 + .../IgniteSetClusterReadOnlyTest.java | 62 + .../SemaphoreFailoverNoWaitingAcquirerTest.java | 3 +- ...chePartitionedQueueCreateMultiNodeSelfTest.java | 1 - .../CacheClientsConcurrentStartTest.java | 23 +- .../distributed/CacheLockChangingTopologyTest.java | 9 +- .../distributed/CacheOperationsInterruptTest.java | 7 +- .../CachePartitionLossWithRestartsTest.java | 36 +- .../cache/distributed/CachePartitionStateTest.java | 4 +- .../distributed/IgniteCache150ClientsTest.java | 193 -- ...gniteCacheClientNodePartitionsExchangeTest.java | 2 +- .../IgniteCacheClientReconnectTest.java | 63 + .../IgniteCacheMultiClientsStartTest.java | 193 ++ .../distributed/IgniteCacheTxIteratorSelfTest.java | 3 +- .../dht/GridCacheAtomicFullApiSelfTest.java | 2 +- .../dht/GridCacheDhtPreloadPerformanceTest.java | 3 +- .../dht/IgniteCacheCrossCacheTxFailoverTest.java | 2 +- .../dht/IgniteCacheLockFailoverSelfTest.java | 2 +- .../PartitionsEvictManagerAbstractTest.java | 2 +- .../eviction/EvictionPolicyFailureHandlerTest.java | 2 +- .../eviction/paged/PageEvictionAbstractTest.java | 2 +- .../IgniteCacheExpireWhileRebalanceTest.java | 9 +- .../IgniteCacheLoadAllAbstractTest.java | 2 +- .../GridCacheFastNodeLeftForTransactionTest.java | 56 +- .../local/GridCacheLocalMultithreadedSelfTest.java | 2 +- .../cache/mvcc/CacheMvccClientTopologyTest.java | 305 +++ .../mvcc/CacheMvccRemoteTxOnNearNodeStartTest.java | 2 +- .../cache/mvcc/MvccUnsupportedTxModesTest.java | 2 +- .../persistence/CheckpointReadLockFailureTest.java | 2 - ...gniteLostPartitionsOnLeaveBaselineSelfTest.java | 2 +- .../IgnitePdsBinaryMetadataAsyncWritingTest.java | 25 +- ...gnitePdsBinaryMetadataOnClusterRestartTest.java | 17 +- .../IgnitePdsCacheEntriesExpirationTest.java | 323 +++ .../IgnitePdsCacheRebalancingAbstractTest.java | 6 +- .../persistence/IgnitePdsCorruptedIndexTest.java | 4 +- .../IgnitePdsNoSpaceLeftOnDeviceTest.java | 4 +- .../IgnitePersistenceSequentialCheckpointTest.java | 2 +- .../persistence/WalPreloadingConcurrentTest.java | 10 +- .../ClientAffinityAssignmentWithBaselineTest.java | 2 +- .../persistence/db/CheckpointFailingIoFactory.java | 9 +- .../db/IgnitePdsMultiNodePutGetRestartTest.java | 22 +- .../cache/persistence/db/IgnitePdsWithTtlTest.java | 4 +- .../db/IgniteSequentialNodeCrashRecoveryTest.java | 130 +- .../IgniteShutdownOnSupplyMessageFailureTest.java | 17 + .../db/file/IgnitePdsCheckpointSimpleTest.java | 2 +- .../db/file/IgnitePdsPageReplacementTest.java | 4 +- .../IgniteUidAsConsistentIdMigrationTest.java | 6 +- .../db/wal/HistoricalReservationTest.java | 227 ++ .../db/wal/IgniteWalFlushFailoverTest.java | 2 +- .../db/wal/IgniteWalHistoryReservationsTest.java | 144 +- .../db/wal/IgniteWalRebalanceLoggingTest.java | 275 +++ .../persistence/db/wal/IgniteWalRebalanceTest.java | 581 ++++- .../db/wal/IgniteWalRecoveryPPCTest.java | 8 +- .../db/wal/IgniteWalReplayingAfterRestartTest.java | 26 +- .../persistence/db/wal/WalOnNodeStartTest.java | 1 + .../db/wal/WalRebalanceRestartTest.java | 321 +++ .../db/wal/crc/IgniteDataIntegrityTests.java | 3 +- .../db/wal/crc/IgnitePureJavaCrcCompatibility.java | 5 +- .../db/wal/reader/IgniteWalReaderTest.java | 5 +- .../dumpprocessors/ToFileDumpProcessorTest.java | 2 +- .../cache/persistence/file/FileDownloaderTest.java | 2 +- .../BPlusTreeReuseListPageMemoryImplTest.java | 4 +- .../IgnitePageMemReplaceDelayedWriteUnitTest.java | 4 +- .../pagemem/IgniteThrottlingUnitTest.java | 2 +- .../pagemem/IndexStoragePageMemoryImplTest.java | 2 +- .../pagemem/PageMemoryImplNoLoadTest.java | 4 +- .../persistence/pagemem/PageMemoryImplTest.java | 8 +- .../snapshot/AbstractSnapshotSelfTest.java | 91 +- .../snapshot/IgniteClusterSnapshotSelfTest.java | 51 +- .../snapshot/IgniteSnapshotMXBeanTest.java | 17 + .../snapshot/IgniteSnapshotManagerSelfTest.java | 6 +- .../standbycluster/IgniteStandByClusterTest.java | 2 +- .../join/JoinActiveNodeToActiveCluster.java | 2 +- .../join/JoinInActiveNodeToActiveCluster.java | 2 +- ...inActiveNodeToActiveClusterWithPersistence.java | 2 +- ...ActiveNodeToInActiveClusterWithPersistence.java | 2 +- ...InActiveNodeToActiveClusterWithPersistence.java | 2 +- ...ActiveNodeToInActiveClusterWithPersistence.java | 2 +- ...niteStandByClientReconnectToNewClusterTest.java | 2 +- .../PageMemoryTrackerPluginProvider.java | 2 +- .../ScanQueryOffheapExpiryPolicySelfTest.java | 7 +- .../CacheContinuousQueryBufferLimitTest.java | 334 +++ ...eContinuousQueryFilterDeploymentFailedTest.java | 3 + .../CacheContinuousQueryLongP2PTest.java | 4 +- .../AbstractDeadlockDetectionTest.java | 5 +- .../transactions/PartitionUpdateCounterTest.java | 4 +- ...ionIntegrityWithPrimaryIndexCorruptionTest.java | 4 +- .../cache/transactions/TxDeadlockCauseTest.java | 31 +- .../TxPartitionCounterStateConsistencyTest.java | 215 +- ...unterStateConsistencyVolatileRebalanceTest.java | 6 + .../TxPessimisticDeadlockDetectionTest.java | 4 +- .../transactions/TxWithKeyContentionSelfTest.java | 338 +++ .../TxWithSmallTimeoutAndContentionOneKeyTest.java | 9 + .../cluster/ClusterReadOnlyModeSelfTest.java | 57 +- .../TestDistibutedConfigurationPlugin.java | 9 +- .../database/IgniteDbMemoryLeakAbstractTest.java | 2 +- .../database/SwapPathConstructionSelfTest.java | 6 +- .../datastreamer/DataStreamerImplSelfTest.java | 5 +- .../failure/FailureProcessorLoggingTest.java | 2 +- .../processors/igfs/IgfsAbstractSelfTest.java | 36 +- .../processors/igfs/IgfsDataManagerSelfTest.java | 13 +- .../processors/igfs/IgfsDualAbstractSelfTest.java | 11 +- ...calSecondaryFileSystemDualAbstractSelfTest.java | 15 +- .../IgfsLocalSecondaryFileSystemTestAdapter.java | 15 +- .../processors/igfs/IgfsMetaManagerSelfTest.java | 11 +- .../ignite/internal/processors/igfs/IgfsMock.java | 7 +- .../igfs/IgfsProcessorValidationSelfTest.java | 11 +- .../igfs/IgfsSecondaryFileSystemTestAdapter.java | 5 +- .../processors/igfs/IgfsStartCacheTest.java | 7 +- .../processors/igfs/IgfsStreamsSelfTest.java | 21 +- .../internal/processors/igfs/IgfsTaskSelfTest.java | 13 +- .../odbc/OdbcEscapeSequenceSelfTest.java | 3 +- .../processors/rest/RestProcessorHangTest.java | 148 ++ .../rest/RestProcessorInitializationTest.java | 2 +- .../cache/GridCacheCommandHandlerSelfTest.java | 3 +- .../query/GridQueryCommandHandlerTest.java | 3 +- .../AbstractTestSecurityPluginProvider.java | 2 +- .../GridCommandHandlerSslWithSecurityTest.java | 112 - ...eOperationPermissionCreateDestroyCheckTest.java | 4 +- .../IgniteClientContainSubjectAddressTest.java | 101 + .../TestCertificateSecurityPluginProvider.java | 2 +- .../AbstractContinuousQuerySandboxTest.java | 132 ++ .../sandbox/ContinuousQuerySandboxTest.java | 64 + .../ContinuousQueryWithTransformerSandboxTest.java | 73 + .../GridServiceClusterReadOnlyModeTest.java | 114 + .../GridServiceDeployClusterReadOnlyModeTest.java | 393 ++++ ...oyment2ClassLoadersOptimizedMarshallerTest.java | 2 +- ...loymentClassLoadingOptimizedMarshallerTest.java | 2 +- .../IgniteServiceProxyTimeoutInitializedTest.java | 11 +- .../internal/sql/SqlParserAbstractSelfTest.java | 3 +- .../util/GridConcurrentMultiPairQueueTest.java | 9 +- .../offheap/GridOffHeapMapAbstractSelfTest.java | 2 +- .../util/tostring/GridToStringBuilderSelfTest.java | 2 +- .../utils/IgniteOffheapReadWriteLockSelfTest.java | 11 +- .../colocation/GridTestLifecycleBean.java | 4 +- .../communication/GridIoManagerBenchmark.java | 2 +- .../redeploy/GridSingleSplitsRedeployLoadTest.java | 2 +- .../marshaller/GridMarshallerPerformanceTest.java | 8 +- .../marshaller/MarshallerContextSelfTest.java | 3 +- .../messaging/IgniteMessagingSendAsyncTest.java | 4 +- ...GridP2PComputeWithNestedEntryProcessorTest.java | 4 +- .../p2p/GridP2PScanQueryWithTransformerTest.java | 406 ++++ .../apache/ignite/p2p/SharedDeploymentTest.java | 60 +- .../platform/AbstractPlatformServiceCallTask.java | 30 + .../platform/PlatformCacheEntryEventFilter.java | 13 +- .../PlatformCacheEntryEventFilterFactory.java | 7 +- .../platform/PlatformCacheWriteMetricsTask.java | 12 +- .../PlatformComputeActiveTaskFuturesTask.java | 69 + .../PlatformComputeBinarizableArgTask.java | 15 +- .../platform/PlatformComputeBroadcastTask.java | 13 +- .../platform/PlatformComputeDecimalTask.java | 17 +- .../ignite/platform/PlatformComputeEchoTask.java | 7 +- .../platform/PlatformComputeGetThreadNameTask.java | 7 +- .../PlatformDefaultJavaObjectFactorySelfTest.java | 11 +- .../ignite/platform/PlatformDeployServiceTask.java | 18 +- .../platform/PlatformEventsWriteEventTask.java | 20 +- .../ignite/platform/PlatformExceptionTask.java | 30 +- .../platform/PlatformIsPartitionReservedTask.java | 7 +- .../PlatformJavaObjectFactoryProxySelfTest.java | 11 +- .../ignite/platform/PlatformMaxMemoryTask.java | 9 +- .../ignite/platform/PlatformMinMemoryTask.java | 9 +- .../PlatformServiceCallCollectionsTask.java | 9 +- .../PlatformServiceCallCollectionsThinTask.java | 65 + .../ignite/platform/PlatformServiceCallTask.java | 58 +- .../platform/PlatformServiceCallThinTask.java | 76 + .../ignite/platform/PlatformSqlQueryTask.java | 21 +- .../ignite/platform/PlatformStartIgniteTask.java | 7 +- .../ignite/platform/PlatformStopIgniteTask.java | 7 +- .../ignite/platform/PlatformStringTestTask.java | 7 +- .../ignite/platform/PlatformThreadNamesTask.java | 9 +- .../lifecycle/PlatformJavaLifecycleTask.java | 9 +- .../security/SecurityPermissionSetBuilderTest.java | 2 +- .../session/GridSessionCheckpointSelfTest.java | 2 +- ...unicationInverseConnectionEstablishingTest.java | 417 ++++ ...municationSpiSkipWaitHandshakeOnClientTest.java | 2 +- .../tcp/TcpCommunicationSpiFreezingClientTest.java | 2 +- .../discovery/LongClientConnectToClusterTest.java | 12 +- .../TestReconnectSecurityPluginProvider.java | 2 +- .../spi/discovery/tcp/IgniteClientConnectTest.java | 5 +- .../tcp/TcpDiscoverySnapshotHistoryTest.java | 3 +- .../discovery/tcp/TcpDiscoverySpiMBeanTest.java | 5 +- .../apache/ignite/ssl/MultipleSSLContextsTest.java | 21 - .../stream/socket/SocketStreamerSelfTest.java | 4 +- .../apache/ignite/testframework/GridTestUtils.java | 28 +- .../ConfigVariationsTestSuiteBuilder.java | 2 +- .../testframework/http/GridEmbeddedHttpServer.java | 10 +- .../testframework/junits/GridAbstractTest.java | 60 +- .../apache/ignite/testframework/junits/Repeat.java | 5 +- .../junits/common/GridCommonAbstractTest.java | 11 +- .../common/GridRollingRestartAbstractTest.java | 5 +- .../junits/multijvm/IgniteClusterProcessProxy.java | 15 + .../IgniteBasicWithPersistenceTestSuite.java | 15 +- .../testsuites/IgniteBinaryObjectsTestSuite.java | 10 +- .../IgniteCacheDataStructuresSelfTestSuite.java | 17 + .../IgniteCacheFullApiSelfTestSuite.java | 11 + .../testsuites/IgniteCacheMvccTestSuite.java | 2 + .../testsuites/IgniteCacheMvccTestSuite5.java | 2 + .../testsuites/IgniteCacheMvccTestSuite6.java | 4 +- .../ignite/testsuites/IgniteCacheTestSuite2.java | 2 +- .../ignite/testsuites/IgniteCacheTestSuite5.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite6.java | 4 +- .../ignite/testsuites/IgniteCacheTestSuite7.java | 3 + .../ignite/testsuites/IgniteCacheTestSuite8.java | 2 +- .../ignite/testsuites/IgniteIgfsTestSuite.java | 20 +- .../testsuites/IgniteMarshallerSelfTestSuite.java | 1 - .../ignite/testsuites/IgniteP2PSelfTestSuite.java | 6 +- .../ignite/testsuites/IgnitePdsMvccTestSuite2.java | 2 + .../ignite/testsuites/IgnitePdsMvccTestSuite4.java | 2 + .../ignite/testsuites/IgnitePdsTestSuite2.java | 3 + .../ignite/testsuites/IgnitePdsTestSuite4.java | 9 +- .../testsuites/IgniteRestHandlerTestSuite.java | 4 +- .../testsuites/IgniteServiceGridTestSuite.java | 4 + .../IgniteSpiCommunicationSelfTestSuite.java | 5 +- .../ignite/testsuites/IgniteUtilSelfTestSuite.java | 8 +- .../ignite/testsuites/SecurityTestSuite.java | 12 +- .../ignite/thread/ThreadPoolMetricsTest.java | 131 ++ .../util/GridCommandHandlerAbstractTest.java | 437 ---- .../util/GridCommandHandlerClusterByClassTest.java | 1739 --------------- .../apache/ignite/util/GridCommandHandlerTest.java | 2151 ------------------- .../ignite/util/mbeans/GridMBeanBaselineTest.java | 4 +- ...ridCommandHandlerClusterByClassTest_help.output | 31 + ...andHandlerClusterByClassWithSSLTest_help.output | 31 + modules/core/src/test/resources/tde.jks | Bin 813 -> 1033 bytes .../modulestest/IgniteLaunchInModularEnvTest.java | 5 +- .../cache/persistence/file/AlignedBuffers.java | 2 +- .../file/AlignedBuffersDirectFileIO.java | 6 +- .../cache/persistence/file/IgniteNativeIoLib.java | 6 +- modules/extdata/p2p/META-INF/ignite.xml | 2 +- .../CacheDeploymentCachePluginConfiguration.java | 3 +- .../ignite/tests/p2p/SingleSplitTestTask.java | 79 - .../tests/p2p/cache/ScanQueryTestTransformer.java | 42 + .../p2p/cache/ScanQueryTestTransformerWrapper.java | 41 + .../tests/p2p/classic/SingleSplitTestTask.java | 80 + .../ignite/tests/p2p/compute/ExternalLambda.java | 40 + ...tformTestPluginConfigurationClosureFactory.java | 5 +- .../plugin/PlatformTestPluginProvider.java | 7 +- .../plugin/cache/PlatformGetCachePluginsTask.java | 7 +- ...latformTestCachePluginConfigurationClosure.java | 5 +- .../cache/PlatformTestCachePluginProvider.java | 3 +- .../uri/tasks/GridUriDeploymentTestTask10.java | 5 +- .../uri/tasks/GridUriDeploymentTestTask11.java | 5 +- .../uri/tasks/GridUriDeploymentTestTask8.java | 5 +- .../uri/tasks/GridUriDeploymentTestTask9.java | 7 +- .../tasks/GridUriDeploymentTestWithNameTask10.java | 5 +- .../tasks/GridUriDeploymentTestWithNameTask11.java | 5 +- .../tasks/GridUriDeploymentTestWithNameTask8.java | 5 +- .../ignite/tests/p2p/compute/ExternalLambda.java | 40 + .../gce/TcpDiscoveryGoogleStorageIpFinder.java | 20 +- .../testsuites/GeoSpatialIndexingTestSuite.java | 2 +- .../hadoop/fs/BasicHadoopFileSystemFactory.java | 9 +- .../ignite/hadoop/fs/HadoopFileSystemFactory.java | 3 +- .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 9 +- .../hadoop/fs/KerberosHadoopFileSystemFactory.java | 5 +- .../IgniteHadoopWeightedMapReducePlanner.java | 33 +- .../planner/HadoopAbstractMapReducePlanner.java | 11 +- .../ignite/hadoop/util/BasicUserNameMapper.java | 3 +- .../ignite/hadoop/util/ChainedUserNameMapper.java | 3 +- .../apache/ignite/hadoop/util/UserNameMapper.java | 3 +- .../processors/hadoop/HadoopAttributes.java | 11 +- .../processors/hadoop/HadoopCommonUtils.java | 5 +- .../processors/hadoop/HadoopExternalSplit.java | 5 +- .../processors/hadoop/HadoopHelperImpl.java | 5 +- .../processors/hadoop/HadoopProcessor.java | 9 +- .../hadoop/delegate/HadoopDelegateUtils.java | 7 +- .../delegate/HadoopFileSystemFactoryDelegate.java | 3 +- .../hadoop/impl/HadoopMapReduceCounterGroup.java | 7 +- .../hadoop/impl/HadoopMapReduceCounters.java | 21 +- .../processors/hadoop/impl/HadoopUtils.java | 25 +- .../HadoopBasicFileSystemFactoryDelegate.java | 11 +- .../HadoopCachingFileSystemFactoryDelegate.java | 3 +- .../HadoopDefaultFileSystemFactoryDelegate.java | 3 +- .../HadoopFileSystemCounterWriterDelegateImpl.java | 7 +- .../HadoopIgfsSecondaryFileSystemDelegateImpl.java | 17 +- .../HadoopKerberosFileSystemFactoryDelegate.java | 5 +- .../hadoop/impl/fs/HadoopFileSystemCacheUtils.java | 5 +- .../hadoop/impl/fs/HadoopLazyConcurrentMap.java | 9 +- .../hadoop/impl/fs/HadoopLocalFileSystemV1.java | 3 +- .../hadoop/impl/fs/HadoopLocalFileSystemV2.java | 7 +- .../hadoop/impl/fs/HadoopRawLocalFileSystem.java | 19 +- .../processors/hadoop/impl/igfs/HadoopIgfs.java | 7 +- .../processors/hadoop/impl/igfs/HadoopIgfsEx.java | 3 +- .../hadoop/impl/igfs/HadoopIgfsInputStream.java | 7 +- .../hadoop/impl/igfs/HadoopIgfsIpcIo.java | 27 +- .../hadoop/impl/igfs/HadoopIgfsOutProc.java | 7 +- .../hadoop/impl/igfs/HadoopIgfsOutputStream.java | 5 +- .../hadoop/impl/igfs/HadoopIgfsProperties.java | 3 +- .../impl/igfs/HadoopIgfsProxyInputStream.java | 5 +- .../impl/igfs/HadoopIgfsProxyOutputStream.java | 5 +- ...pIgfsSecondaryFileSystemPositionedReadable.java | 3 +- .../hadoop/impl/igfs/HadoopIgfsUtils.java | 5 +- .../hadoop/impl/proto/HadoopClientProtocol.java | 5 +- .../hadoop/impl/v1/HadoopV1CleanupTask.java | 3 +- .../processors/hadoop/impl/v1/HadoopV1Counter.java | 7 +- .../hadoop/impl/v1/HadoopV1OutputCollector.java | 3 +- .../hadoop/impl/v1/HadoopV1SetupTask.java | 3 +- .../hadoop/impl/v1/HadoopV1Splitter.java | 9 +- .../processors/hadoop/impl/v1/HadoopV1Task.java | 5 +- .../hadoop/impl/v2/HadoopSerializationWrapper.java | 11 +- .../hadoop/impl/v2/HadoopV2CleanupTask.java | 3 +- .../processors/hadoop/impl/v2/HadoopV2Context.java | 7 +- .../processors/hadoop/impl/v2/HadoopV2Counter.java | 5 +- .../processors/hadoop/impl/v2/HadoopV2Job.java | 39 +- .../hadoop/impl/v2/HadoopV2JobResourceManager.java | 21 +- .../hadoop/impl/v2/HadoopV2SetupTask.java | 3 +- .../hadoop/impl/v2/HadoopV2Splitter.java | 13 +- .../processors/hadoop/impl/v2/HadoopV2Task.java | 3 +- .../hadoop/impl/v2/HadoopV2TaskContext.java | 21 +- .../impl/v2/HadoopWritableSerialization.java | 7 +- .../hadoop/jobtracker/HadoopJobMetadata.java | 2 +- .../hadoop/jobtracker/HadoopJobTracker.java | 6 +- .../hadoop/mapreduce/MapReduceClient.java | 7 +- .../hadoop/planner/HadoopDefaultMapReducePlan.java | 7 +- .../hadoop/planner/HadoopMapReducePlanGroup.java | 5 +- .../planner/HadoopMapReducePlanTopology.java | 5 +- .../processors/hadoop/shuffle/HadoopShuffle.java | 13 +- .../hadoop/shuffle/HadoopShuffleJob.java | 21 +- .../hadoop/shuffle/HadoopShuffleRemoteState.java | 3 +- .../shuffle/direct/HadoopDirectDataInput.java | 9 +- .../shuffle/direct/HadoopDirectDataOutput.java | 5 +- .../direct/HadoopDirectDataOutputContext.java | 5 +- .../hadoop/taskexecutor/HadoopExecutorService.java | 2 +- .../external/HadoopExternalTaskExecutor.java | 4 +- .../processors/hadoop/HadoopTestClassLoader.java | 9 +- .../hadoop/impl/HadoopAbstractWordCountTest.java | 2 +- .../hadoop/impl/HadoopCommandLineTest.java | 2 +- .../processors/hadoop/impl/HadoopGroupingTest.java | 21 +- .../hadoop/impl/HadoopPlannerMockJob.java | 7 +- .../hadoop/impl/HadoopTaskExecutionSelfTest.java | 2 +- .../processors/hadoop/impl/HadoopTasksV1Test.java | 2 +- .../processors/hadoop/impl/HadoopTasksV2Test.java | 2 +- .../impl/HadoopTasksVersionsAbstractTest.java | 2 +- .../processors/hadoop/impl/HadoopTestUtils.java | 7 +- .../hadoop/impl/HadoopUserLibsSelfTest.java | 5 +- .../hadoop/impl/HadoopV2JobSelfTest.java | 2 +- .../impl/HadoopWeightedMapReducePlannerTest.java | 27 +- .../hadoop/impl/examples/HadoopPopularWords.java | 2 +- .../impl/igfs/HadoopFIleSystemFactorySelfTest.java | 11 +- .../impl/igfs/HadoopIgfsDualAbstractSelfTest.java | 7 +- .../HadoopIgfsSecondaryFileSystemTestAdapter.java | 2 +- ...HadoopSecondaryFileSystemConfigurationTest.java | 13 +- .../igfs/IgniteHadoopFileSystemLoggerSelfTest.java | 11 +- .../HadoopConcurrentHashMultimapSelftest.java | 4 +- .../shuffle/collections/HadoopHashMapSelfTest.java | 11 +- .../collections/HadoopSkipListSelfTest.java | 4 +- .../shuffle/streams/HadoopDataStreamSelfTest.java | 1 - .../taskexecutor/HadoopExecutorServiceTest.java | 5 +- .../HadoopExternalTaskExecutionSelfTest.java | 2 +- .../impl/util/BasicUserNameMapperSelfTest.java | 5 +- .../impl/util/ChainedUserNameMapperSelfTest.java | 5 +- .../hadoop/state/HadoopGroupingTestState.java | 5 +- .../state/HadoopJobTrackerSelfTestState.java | 3 +- .../HadoopMapReduceEmbeddedSelfTestState.java | 3 +- .../state/HadoopTaskExecutionSelfTestValues.java | 3 +- .../ignite/testsuites/IgniteHadoopTestSuite.java | 95 +- .../processors/cache/query/QueryTable.java | 3 +- .../processors/query/h2/CommandProcessor.java | 43 +- .../processors/query/h2/CommandResult.java | 3 +- .../processors/query/h2/ConcurrentStripedPool.java | 32 +- .../processors/query/h2/ConnectionManager.java | 7 +- .../processors/query/h2/H2DatabaseType.java | 7 +- .../processors/query/h2/H2SqlFieldMetadata.java | 9 +- .../processors/query/h2/H2StatementCache.java | 22 +- .../processors/query/h2/IgniteH2Indexing.java | 16 +- .../processors/query/h2/IndexBuildClosure.java | 2 +- .../query/h2/IndexRebuildPartialClosure.java | 11 +- .../internal/processors/query/h2/UpdateResult.java | 5 +- .../processors/query/h2/database/H2TreeIndex.java | 12 + .../query/h2/dml/DmlBulkLoadDataConverter.java | 3 +- .../query/h2/dml/DmlPageProcessingErrorResult.java | 5 +- .../query/h2/dml/DmlPageProcessingResult.java | 3 +- .../query/h2/dml/DmlUpdateResultsIterator.java | 5 +- .../processors/query/h2/opt/GridH2ProxyIndex.java | 5 +- .../query/h2/opt/GridH2ProxySpatialIndex.java | 5 +- .../processors/query/h2/opt/GridH2Table.java | 48 +- .../processors/query/h2/opt/GridLuceneIndex.java | 2 +- .../processors/query/h2/opt/H2CacheRow.java | 19 +- .../processors/query/h2/opt/H2TableScanIndex.java | 3 +- .../processors/query/h2/opt/QueryContextKey.java | 3 +- .../query/h2/opt/join/BroadcastCursor.java | 9 +- .../query/h2/opt/join/CursorIteratorWrapper.java | 3 +- .../query/h2/opt/join/DistributedJoinContext.java | 7 +- .../h2/opt/join/ProxyDistributedLookupBatch.java | 5 +- .../processors/query/h2/opt/join/RangeSource.java | 7 +- .../processors/query/h2/opt/join/RangeStream.java | 13 +- .../query/h2/sql/GridSqlQueryParser.java | 2 +- .../query/h2/sql/SplitterQueryModel.java | 5 +- .../processors/query/h2/sql/SplitterUtils.java | 3 +- .../processors/query/h2/sys/SqlSystemIndex.java | 3 +- .../processors/query/h2/twostep/MapRequestKey.java | 3 +- .../query/h2/twostep/PartitionReservation.java | 5 +- .../h2/twostep/ReducePartitionsSpecializer.java | 3 +- .../query/h2/twostep/ReduceSourceKey.java | 3 +- .../query/h2/twostep/ReduceTableEngine.java | 7 +- .../visor/verify/ValidateIndexesClosure.java | 3 +- .../org/apache/ignite/client/ClientTestSuite.java | 2 + .../apache/ignite/client/FunctionalQueryTest.java | 36 +- ...aryMetadataConcurrentUpdateWithIndexesTest.java | 2 +- .../cache/BinarySerializationQuerySelfTest.java | 23 +- .../cache/CacheIteratorScanQueryTest.java | 7 +- .../cache/CacheRegisterMetadataLocallyTest.java | 2 +- .../ClientReconnectAfterClusterRestartTest.java | 2 +- .../GridCacheSqlDdlClusterReadOnlyModeTest.java | 172 ++ .../IgniteCacheAbstractFieldsQuerySelfTest.java | 4 +- ...gniteCacheJoinPartitionedAndReplicatedTest.java | 11 +- .../IgniteCacheLockPartitionOnAffinityRunTest.java | 2 +- .../IgniteCachePrimitiveFieldsQuerySelfTest.java | 5 +- .../cache/IgniteCacheQueryH2IndexingLeakTest.java | 202 +- .../IgniteDynamicEnableIndexingRestoreTest.java | 274 +++ ...ingleNodeWithIndexingPutGetPersistenceTest.java | 2 +- .../cache/QueryEntityCaseMismatchTest.java | 9 +- ...acheDistributedQueryDefaultTimeoutSelfTest.java | 2 +- ...tributedQueryStopOnCancelOrTimeoutSelfTest.java | 2 +- .../near/IgniteSqlQueryWithBaselineTest.java | 4 +- .../cache/index/AbstractSchemaSelfTest.java | 2 +- .../index/DynamicEnableIndexingAbstractTest.java | 305 +++ .../index/DynamicEnableIndexingBasicSelfTest.java | 160 ++ .../DynamicEnableIndexingConcurrentSelfTest.java | 636 ++++++ .../cache/index/H2DynamicTableSelfTest.java | 104 +- .../cache/index/H2RowCachePageEvictionTest.java | 1 + .../index/IoStatisticsBasicIndexSelfTest.java | 2 +- .../cache/index/QueryEntityValidationSelfTest.java | 68 + ...niteCacheLocalQueryCancelOrTimeoutSelfTest.java | 2 +- .../cache/metric/SqlViewExporterSpiTest.java | 196 +- .../cache/mvcc/CacheMvccTxNodeMappingTest.java | 4 +- .../cache/mvcc/MvccRepeatableReadBulkOpsTest.java | 6 +- .../db/IgniteCacheGroupsWithRestartsTest.java | 35 +- .../persistence/db/wal/IgniteWalRecoveryTest.java | 200 +- .../IgniteClusterSnapshotWithIndexesTest.java | 15 +- .../ttl/CacheTtlAtomicPartitionedSelfTest.java | 2 +- ...ntConnectorConfigurationValidationSelfTest.java | 17 +- .../processors/client/IgniteDataStreamerTest.java | 2 + .../query/CreateIndexOnInvalidDataTypeTest.java | 207 ++ .../query/IgniteQueryDedicatedPoolTest.java | 2 +- .../processors/query/RunningQueriesTest.java | 2 +- .../query/SqlNotNullKeyValueFieldTest.java | 122 ++ .../query/SqlPartOfComplexPkLookupTest.java | 2 +- .../processors/query/SqlSystemViewsSelfTest.java | 22 +- .../query/h2/GridIndexFullRebuildTest.java | 2 +- .../query/h2/GridIndexRebuildSelfTest.java | 66 +- .../query/h2/sql/ParameterTypeInferenceTest.java | 11 +- .../IgniteBinaryCacheQueryTestSuite.java | 6 +- .../IgniteBinaryCacheQueryTestSuite2.java | 8 + .../testsuites/IgniteCacheMvccSqlTestSuite.java | 2 +- .../testsuites/IgniteCacheQuerySelfTestSuite3.java | 4 +- .../testsuites/IgniteCacheQuerySelfTestSuite6.java | 2 +- ...teCacheWithIndexingAndPersistenceTestSuite.java | 14 - .../IgniteCacheWithIndexingTestSuite.java | 2 + ...idCommandHandlerIndexingClusterByClassTest.java | 197 -- .../util/GridCommandHandlerIndexingTest.java | 347 --- .../ignite/util/KillCommandsCommandShTest.java | 176 -- .../apache/ignite/util/KillCommandsMXBeanTest.java | 51 +- .../apache/ignite/util/KillCommandsSQLTest.java | 5 +- .../org/apache/ignite/util/KillCommandsTests.java | 8 +- .../stream/jms11/IgniteJmsStreamerTestSuite.java | 4 +- .../cache/jta/AbstractCacheJtaSelfTest.java | 4 +- .../ignite/testsuites/IgniteJtaTestSuite.java | 2 +- .../ignite/stream/kafka/TestKafkaBroker.java | 4 +- .../kubernetes/TcpDiscoveryKubernetesIpFinder.java | 26 +- .../ignite/mesos/resource/IgniteProvider.java | 4 +- .../org/apache/ignite/ml/h2o/H2OMojoModel.java | 7 +- .../apache/ignite/ml/h2o/H2OMojoModelParser.java | 5 +- .../gmm/CovarianceMatricesAggregator.java | 9 +- .../gmm/NewComponentStatisticsAggregator.java | 3 +- .../ignite/ml/dataset/feature/ObjectHistogram.java | 6 +- .../BootstrappedDatasetPartition.java | 3 +- .../impl/bootstrapping/BootstrappedVector.java | 5 +- .../ignite/ml/dataset/primitive/SimpleDataset.java | 2 +- .../ignite/ml/knn/NNClassificationModel.java | 2 +- .../main/java/org/apache/ignite/ml/math/Blas.java | 2 +- .../ml/math/distances/ChebyshevDistance.java | 31 + .../ignite/ml/math/distances/CosineSimilarity.java | 31 + .../ignite/ml/math/distances/DistanceMeasure.java | 22 +- .../ml/math/distances/EuclideanDistance.java | 16 +- .../ignite/ml/math/distances/HammingDistance.java | 18 - .../ignite/ml/math/distances/JaccardIndex.java | 41 + .../ml/math/distances/ManhattanDistance.java | 18 - .../ml/math/distances/MinkowskiDistance.java | 63 + .../ignite/ml/math/isolve/lsqr/AbstractLSQR.java | 2 +- .../ignite/ml/math/isolve/lsqr/LSQROnHeap.java | 2 +- .../matrix/storage/SparseMatrixStorage.java | 8 +- .../math/primitives/vector/impl/SparseVector.java | 2 +- .../vector/storage/SparseVectorStorage.java | 4 +- .../apache/ignite/ml/math/stat/Distribution.java | 3 +- .../ignite/ml/math/stat/DistributionMixture.java | 7 +- .../ignite/ml/multiclass/MultiClassModel.java | 7 +- .../discrete/DiscreteNaiveBayesModel.java | 5 +- .../gaussian/GaussianNaiveBayesModel.java | 5 +- .../updatecalculators/RPropParameterUpdate.java | 9 +- .../updatecalculators/SimpleGDParameterUpdate.java | 7 +- .../ml/selection/cv/DebugCrossValidation.java | 3 +- .../scoring/cursor/LocalLabelPairCursor.java | 7 +- .../selection/scoring/evaluator/package-info.java | 4 +- .../randomforest/data/impurity/GiniHistogram.java | 13 +- .../data/impurity/ImpurityHistogram.java | 3 +- .../data/impurity/ImpurityHistogramsComputer.java | 13 +- .../randomforest/data/impurity/MSEHistogram.java | 9 +- .../data/statistics/LeafValuesComputer.java | 13 +- .../NormalDistributionStatisticsComputer.java | 9 +- .../primitives/vector/VectorGenerator.java | 15 +- .../primitives/vector/VectorGeneratorsFamily.java | 9 +- .../apache/ignite/ml/common/KeepBinaryTest.java | 3 +- .../convergence/ConvergenceCheckerTest.java | 7 +- .../deploy/DeployingContextImplTest.java | 2 +- .../apache/ignite/ml/knn/LabeledDatasetHelper.java | 5 +- .../ignite/ml/math/MathImplLocalTestSuite.java | 4 + .../ml/math/distances/CosineSimilarityTest.java | 41 + .../ignite/ml/math/distances/DistanceTest.java | 108 +- .../ignite/ml/math/distances/JaccardIndexTest.java | 43 + .../ignite/ml/nn/MLPTrainerIntegrationTest.java | 10 +- .../org/apache/ignite/ml/nn/MLPTrainerTest.java | 18 +- .../ml/selection/cv/CrossValidationTest.java | 9 +- .../gini/GiniImpurityMeasureCalculatorTest.java | 2 +- .../mse/MSEImpurityMeasureCalculatorTest.java | 2 +- .../data/impurity/MSEHistogramTest.java | 5 +- modules/mqtt/README.txt | 29 - modules/mqtt/licenses/apache-2.0.txt | 202 -- modules/mqtt/pom.xml | 123 -- .../apache/ignite/stream/mqtt/MqttStreamer.java | 709 ------ .../apache/ignite/stream/mqtt/package-info.java | 22 - .../ignite/stream/mqtt/IgniteMqttStreamerTest.java | 649 ------ .../stream/mqtt/IgniteMqttStreamerTestSuite.java | 32 - .../apache/ignite/stream/mqtt/package-info.java | 22 - .../opencensus/OpenCensusMetricExporterSpi.java | 14 +- .../OpenCensusMetricExporterSpiTest.java | 4 +- .../org/apache/ignite/osgi/IgniteOsgiUtils.java | 2 +- modules/platforms/cpp/CMakeLists.txt | 83 + modules/platforms/cpp/DEVNOTES.txt | 77 +- modules/platforms/cpp/Makefile.am | 77 - modules/platforms/cpp/Makefile.amrel | 59 - modules/platforms/cpp/binary/CMakeLists.txt | 73 + modules/platforms/cpp/binary/Makefile.am | 74 - modules/platforms/cpp/binary/configure.ac | 62 - modules/platforms/cpp/binary/include/Makefile.am | 51 - modules/platforms/cpp/cmake/FindIgnite.cmake | 45 + modules/platforms/cpp/cmake/FindODBC.cmake | 148 ++ modules/platforms/cpp/common/CMakeLists.txt | 81 + modules/platforms/cpp/common/Makefile.am | 63 - modules/platforms/cpp/common/configure.ac | 62 - modules/platforms/cpp/common/include/Makefile.am | 45 - .../cpp/common/os/linux/include/Makefile.am | 25 - .../os/linux/include/ignite/common/concurrent_os.h | 6 +- .../common/os/linux/src/common/platform_utils.cpp | 5 +- modules/platforms/cpp/configure.ac | 126 -- modules/platforms/cpp/configure.acrel | 109 - modules/platforms/cpp/core-test/CMakeLists.txt | 76 + modules/platforms/cpp/core-test/Makefile.am | 96 - modules/platforms/cpp/core-test/configure.ac | 62 - .../platforms/cpp/core-test/include/Makefile.am | 24 - modules/platforms/cpp/core/CMakeLists.txt | 54 + modules/platforms/cpp/core/Makefile.am | 85 - modules/platforms/cpp/core/configure.ac | 62 - modules/platforms/cpp/core/ignite.pc.in | 9 - modules/platforms/cpp/core/include/Makefile.am | 82 - modules/platforms/cpp/examples/CMakeLists.txt | 36 + modules/platforms/cpp/examples/Makefile.am | 28 - modules/platforms/cpp/examples/README.txt | 21 +- .../cpp/examples/compute-example/CMakeLists.txt | 31 + .../cpp/examples/compute-example/Makefile.am | 59 - modules/platforms/cpp/examples/configure.ac | 64 - .../continuous-query-example/CMakeLists.txt | 31 + .../examples/continuous-query-example/Makefile.am | 58 - modules/platforms/cpp/examples/include/Makefile.am | 24 - .../cpp/examples/odbc-example/CMakeLists.txt | 33 + .../cpp/examples/odbc-example/Makefile.am | 59 - .../cpp/examples/put-get-example/CMakeLists.txt | 31 + .../cpp/examples/put-get-example/Makefile.am | 58 - .../cpp/examples/query-example/CMakeLists.txt | 31 + .../cpp/examples/query-example/Makefile.am | 58 - .../thin-client-put-get-example/CMakeLists.txt | 28 + .../thin-client-put-get-example/Makefile.am | 53 - modules/platforms/cpp/ignite/CMakeLists.txt | 32 + modules/platforms/cpp/ignite/Makefile.am | 61 - modules/platforms/cpp/ignite/configure.ac | 62 - modules/platforms/cpp/jni/CMakeLists.txt | 43 + modules/platforms/cpp/jni/Makefile.am | 65 - modules/platforms/cpp/jni/configure.ac | 62 - modules/platforms/cpp/jni/include/Makefile.am | 25 - modules/platforms/cpp/jni/os/linux/src/utils.cpp | 33 +- modules/platforms/cpp/jni/os/win/src/utils.cpp | 24 +- modules/platforms/cpp/network/CMakeLists.txt | 74 + modules/platforms/cpp/network/Makefile.am | 63 - modules/platforms/cpp/network/configure.ac | 62 - modules/platforms/cpp/network/include/Makefile.am | 28 - .../os/linux/src/network/tcp_socket_client.cpp | 5 +- .../cpp/network/src/network/ssl/ssl_gateway.cpp | 16 +- modules/platforms/cpp/odbc-test/CMakeLists.txt | 104 + modules/platforms/cpp/odbc-test/Makefile.am | 127 -- modules/platforms/cpp/odbc-test/config/ssl/ca.pem | 50 +- .../cpp/odbc-test/config/ssl/client_full.pem | 132 +- .../cpp/odbc-test/config/ssl/client_unknown.pem | 94 +- .../odbc-test/config/ssl/generate_certificates.sh | 119 + .../platforms/cpp/odbc-test/config/ssl/server.jks | Bin 4256 -> 2392 bytes .../platforms/cpp/odbc-test/config/ssl/trust.jks | Bin 1089 -> 1199 bytes .../platforms/cpp/odbc-test/include/Makefile.am | 26 - modules/platforms/cpp/odbc/CMakeLists.txt | 108 + modules/platforms/cpp/odbc/Makefile.am | 106 - modules/platforms/cpp/odbc/configure.ac | 62 - modules/platforms/cpp/odbc/include/Makefile.am | 73 - .../platforms/cpp/thin-client-test/CMakeLists.txt | 53 + modules/platforms/cpp/thin-client-test/Makefile.am | 79 - .../cpp/thin-client-test/config/ssl/ca.pem | 50 +- .../thin-client-test/config/ssl/client_full.pem | 132 +- .../thin-client-test/config/ssl/client_unknown.pem | 94 +- .../config/ssl/generate_certificates.sh | 119 + .../cpp/thin-client-test/config/ssl/server.jks | Bin 4256 -> 2392 bytes .../cpp/thin-client-test/config/ssl/trust.jks | Bin 1089 -> 1199 bytes .../platforms/cpp/thin-client-test/configure.ac | 62 - .../cpp/thin-client-test/include/Makefile.am | 24 - modules/platforms/cpp/thin-client/CMakeLists.txt | 48 + modules/platforms/cpp/thin-client/Makefile.am | 75 - .../platforms/cpp/thin-client/include/Makefile.am | 32 - .../ExpiryCacheHolderTest.cs | 7 +- .../Apache.Ignite.Core.Tests.DotNetCore.csproj | 37 + .../Common/TestRunner.cs | 2 +- .../Apache.Ignite.Core.Tests.csproj | 3 + .../ApiParity/ClusterParityTest.cs | 4 +- .../Cache/CacheAbstractTransactionalTest.cs | 55 +- .../Cache/CacheTestAsyncWrapper.cs | 8 +- .../Cache/OptimisticTransactionTest.cs | 134 ++ .../Cache/Platform/PlatformCacheTest.cs | 277 +-- .../Cache/Query/CacheQueriesTest.cs | 42 +- .../Continuous/ContinuousQueryAbstractTest.cs | 142 +- .../Continuous/ContinuousQueryAtomicBackupTest.cs | 7 +- .../ContinuousQueryAtomicNoBackupTest.cs | 7 +- .../ContinuousQueryNoBackupAbstractTest.cs | 3 +- .../ContinuousQueryTransactionalBackupTest.cs | 3 + .../ContinuousQueryTransactionalNoBackupTest.cs | 3 + .../Client/ClientConnectionTest.cs | 48 +- .../Client/Compute/ComputeClientTests.cs | 134 +- .../IgniteConfigurationTest.cs | 2 +- .../IgniteLockFailoverTests.cs | 105 + .../Apache.Ignite.Core.Tests/IgniteLockTests.cs | 329 +++ .../Process/ListDataReader.cs | 5 + .../Services/CallPlatformServiceTest.cs | 37 +- .../Services/ServicesTest.cs | 173 +- .../dotnet/Apache.Ignite.Core.Tests/TestBase.cs | 31 +- .../Apache.Ignite.Core.Tests/TestUtils.Common.cs | 33 +- .../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 5 + .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 42 +- .../Query/Continuous/IContinuousQueryHandle.cs | 2 +- .../Continuous/IContinuousQueryHandleFields.cs | 37 + .../Apache.Ignite.Core/Cache/Query/QueryBase.cs | 17 +- .../Cache/Query/SqlFieldsQuery.cs | 43 +- .../Apache.Ignite.Core/Client/ClientStatusCode.cs | 12 +- .../Configuration/LockConfiguration.cs | 68 + .../platforms/dotnet/Apache.Ignite.Core/IIgnite.cs | 33 +- .../dotnet/Apache.Ignite.Core/IIgniteLock.cs | 81 + .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 148 +- .../Query/Continuous/ContinuousQueryHandleImpl.cs | 53 +- .../Impl/Cache/Query/FieldsQueryCursor.cs | 20 +- .../Impl/Cache/Query/IQueryBaseInternal.cs | 39 + .../Impl/Cache/Query/QueryCursorBase.cs | 96 +- .../Impl/Client/Cache/CacheClient.cs | 28 +- .../Client/Cache/Query/ClientFieldsQueryCursor.cs | 6 +- .../Impl/Client/Cache/Query/ClientQueryCursor.cs | 6 +- .../Client/Cache/Query/ClientQueryCursorBase.cs | 19 +- .../Impl/Client/ClientNotificationHandler.cs | 25 +- .../Apache.Ignite.Core/Impl/Client/ClientSocket.cs | 67 +- .../Impl/Client/Compute/ComputeClient.cs | 59 +- .../Apache.Ignite.Core/Impl/Common/Classpath.cs | 9 +- .../Impl/Common/DelegateConverter.cs | 65 +- .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 6 +- .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 37 +- .../dotnet/Apache.Ignite.Core/Impl/IgniteLock.cs | 114 + .../Impl/Transactions/CacheTransactionManager.cs | 24 +- .../Impl/Unmanaged/UnmanagedCallbacks.cs | 2 + .../Apache.Ignite.DotNetCore.sln.DotSettings | 2 + .../http/jetty/GridJettyObjectMapper.java | 12 +- .../protocols/http/jetty/GridJettyRestHandler.java | 6 +- .../jetty/IgniteBinaryObjectJsonDeserializer.java | 8 +- .../protocols/http/jetty/RestSetupSimpleTest.java | 4 +- modules/rocketmq/README.txt | 25 - modules/rocketmq/pom.xml | 94 - .../ignite/stream/rocketmq/RocketMQStreamer.java | 151 -- .../ignite/stream/rocketmq/package-info.java | 21 - .../stream/rocketmq/RocketMQStreamerTest.java | 215 -- .../stream/rocketmq/RocketMQStreamerTestSuite.java | 31 - .../ignite/stream/rocketmq/TestRocketMQServer.java | 148 -- .../ignite/stream/rocketmq/package-info.java | 21 - .../schedule/IgniteScheduleProcessor.java | 2 +- .../processors/schedule/ScheduleFutureImpl.java | 8 +- .../spark/JavaStandaloneIgniteRDDSelfTest.java | 7 +- .../spark/JavaStandaloneIgniteRDDSelfTest.java | 7 +- modules/spring-data-2.0/README.txt | 15 + modules/spring-data-2.0/pom.xml | 6 + .../springdata20/repository/IgniteRepository.java | 73 +- .../repository/config/DynamicQueryConfig.java | 348 +++ .../config/EnableIgniteRepositories.java | 4 +- .../IgniteRepositoryConfigurationExtension.java | 2 +- .../springdata20/repository/config/Query.java | 106 +- .../repository/config/RepositoryConfig.java | 38 +- .../repository/query/DeclaredQuery.java | 96 + .../repository/query/EmptyDeclaredQuery.java | 74 + .../query/ExpressionBasedStringQuery.java | 153 ++ .../springdata20/repository/query/IgniteQuery.java | 74 +- .../repository/query/IgniteQueryGenerator.java | 33 +- .../repository/query/IgniteRepositoryQuery.java | 955 ++++++++- .../springdata20/repository/query/QueryUtils.java | 307 +++ .../springdata20/repository/query/StringQuery.java | 879 ++++++++ .../repository/query/spel/SpelEvaluator.java | 96 + .../repository/query/spel/SpelQueryContext.java | 342 +++ .../repository/support/ConditionFalse.java | 5 +- .../support/IgniteRepositoryFactory.java | 195 +- .../support/IgniteRepositoryFactoryBean.java | 58 +- .../repository/support/IgniteRepositoryImpl.java | 129 +- .../IgniteSpringDataCrudSelfExpressionTest.java | 49 +- .../springdata/IgniteSpringDataCrudSelfTest.java | 154 +- .../IgniteSpringDataQueriesSelfTest.java | 102 +- .../springdata/misc/ApplicationConfiguration.java | 53 +- .../ignite/springdata/misc/CacheNamesBean.java | 11 +- .../ignite/springdata/misc/FullNameProjection.java | 33 + .../org/apache/ignite/springdata/misc/Person.java | 18 +- .../apache/ignite/springdata/misc/PersonKey.java | 54 + .../ignite/springdata/misc/PersonProjection.java | 43 + .../ignite/springdata/misc/PersonRepository.java | 39 +- .../misc/PersonRepositoryOtherIgniteInstance.java | 143 ++ .../misc/PersonRepositoryWithCompoundKey.java | 28 + .../springdata/misc/PersonSecondRepository.java | 2 +- .../misc/SampleEvaluationContextExtension.java | 92 + modules/spring-data-2.2/README.txt | 15 + modules/spring-data-2.2/pom.xml | 6 + .../springdata22/repository/IgniteRepository.java | 73 +- .../repository/config/DynamicQueryConfig.java | 348 +++ .../config/EnableIgniteRepositories.java | 5 +- .../config/IgniteRepositoriesRegistar.java | 1 + .../IgniteRepositoryConfigurationExtension.java | 2 +- .../springdata22/repository/config/Query.java | 105 +- .../repository/config/RepositoryConfig.java | 38 + .../repository/query/DeclaredQuery.java | 96 + .../repository/query/EmptyDeclaredQuery.java | 74 + .../query/ExpressionBasedStringQuery.java | 153 ++ .../springdata22/repository/query/IgniteQuery.java | 74 +- .../repository/query/IgniteQueryGenerator.java | 33 +- .../repository/query/IgniteRepositoryQuery.java | 955 ++++++++- .../springdata22/repository/query/QueryUtils.java | 307 +++ .../springdata22/repository/query/StringQuery.java | 879 ++++++++ .../repository/support/ConditionFalse.java | 5 +- .../support/IgniteRepositoryFactory.java | 195 +- .../support/IgniteRepositoryFactoryBean.java | 58 +- .../repository/support/IgniteRepositoryImpl.java | 129 +- .../IgniteSpringDataCrudSelfExpressionTest.java | 50 +- .../springdata/IgniteSpringDataCrudSelfTest.java | 158 +- .../IgniteSpringDataQueriesSelfTest.java | 102 +- .../springdata/misc/ApplicationConfiguration.java | 53 +- .../ignite/springdata/misc/CacheNamesBean.java | 12 +- .../ignite/springdata/misc/FullNameProjection.java | 33 + .../org/apache/ignite/springdata/misc/Person.java | 18 +- .../apache/ignite/springdata/misc/PersonKey.java | 54 + .../ignite/springdata/misc/PersonProjection.java | 43 + .../ignite/springdata/misc/PersonRepository.java | 40 +- .../misc/PersonRepositoryOtherIgniteInstance.java | 143 ++ .../misc/PersonRepositoryWithCompoundKey.java | 28 + .../springdata/misc/PersonSecondRepository.java | 3 +- .../misc/SampleEvaluationContextExtension.java | 93 + .../repository/query/IgniteRepositoryQuery.java | 72 +- .../repository/support/IgniteRepositoryImpl.java | 51 +- .../springdata/IgniteSpringDataCrudSelfTest.java | 169 +- .../IgniteSpringDataQueriesSelfTest.java | 2 +- .../springdata/misc/ApplicationConfiguration.java | 25 +- .../org/apache/ignite/springdata/misc/Person.java | 19 +- .../apache/ignite/springdata/misc/PersonKey.java | 54 + .../ignite/springdata/misc/PersonRepository.java | 7 +- .../misc/PersonRepositoryWithCompoundKey.java | 28 + .../GridServiceInjectionSpringResourceTest.java | 13 +- .../ignite/testsuites/IgniteSpringTestSuite.java | 12 +- .../util/nodestart/StartNodeCallableImpl.java | 10 +- .../tools/ant/beautifier/GridJavadocAntTask.java | 5 +- .../ignite/tools/javadoc/IgniteLinkTaglet.java | 109 +- .../ignite/tools/javadoc/IgniteLinkTaglet.java | 4 +- .../visor/commands/start/VisorStartCommand.scala | 4 +- .../apache/ignite/console/agent/AgentLauncher.java | 6 +- .../apache/ignite/console/agent/AgentUtils.java | 6 +- .../console/agent/handlers/AbstractListener.java | 6 +- .../console/agent/handlers/ClusterListener.java | 6 +- .../console/agent/handlers/DatabaseListener.java | 2 +- .../ignite/console/agent/rest/RestExecutor.java | 4 +- .../ignite/console/demo/AgentClusterDemo.java | 6 +- .../console/agent/rest/RestExecutorSelfTest.java | 6 +- .../apache/ignite/webtest/TestJtaTxServlet.java | 2 +- .../ignite/cache/websession/WebSessionV2.java | 21 +- .../internal/websession/WebSessionSelfTest.java | 20 +- .../config/benchmark-thin-services.properties | 78 + .../yardstick/config/ignite-services-config.xml | 51 + .../ignite/yardstick/IgniteAbstractBenchmark.java | 2 +- .../ignite/yardstick/IgniteBenchmarkArguments.java | 6 +- .../cache/IgniteCreateIndexBenchmark.java | 17 +- .../cache/IgniteInvokeWithInjectionBenchmark.java | 5 +- .../cache/IgnitePutGetWithPageReplacements.java | 13 +- .../yardstick/cache/IgnitePutValue8Benchmark.java | 3 +- .../cache/WaitMapExchangeFinishCallable.java | 2 +- .../failover/IgniteFailoverAbstractBenchmark.java | 2 +- .../IgniteThinServiceInvocationBenchmark.java | 45 + .../yardstick/thin/service/SimpleService.java | 28 + .../yardstick/thin/service/SimpleServiceImpl.java | 46 + .../yardstick/upload/UploadBenchmarkArguments.java | 2 +- .../zk/ZookeeperDiscoverySpiTestSuite2.java | 6 +- parent/pom.xml | 35 +- pom.xml | 105 +- 1587 files changed, 51590 insertions(+), 21819 deletions(-) create mode 100644 assembly/dependencies-apache-ignite-slim.xml create mode 100644 assembly/release-apache-ignite-slim.xml create mode 100644 examples/README-slim.txt create mode 100644 modules/compatibility/src/test/java/org/apache/ignite/compatibility/persistence/MoveBinaryMetadataCompatibility.java rename modules/{rocketmq => control-utility}/licenses/apache-2.0.txt (100%) create mode 100644 modules/control-utility/pom.xml rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/ActivateCommand.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/BaselineCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/ClusterChangeTagCommand.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/ClusterStateChangeCommand.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/Command.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommandArgIterator.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/CommandHandler.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommandList.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/CommandLogger.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/CommonArgParser.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/ConnectionAndSslParameters.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/DeactivateCommand.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/GridConsole.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/GridConsoleAdapter.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/NoopConsole.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/OutputFormat.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/StateCommand.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/TaskExecutor.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/TxCommandArg.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/TxCommands.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/WalCommands.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/argument/CommandArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/argument/CommandArgUtils.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/baseline/AutoAdjustCommandArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/baseline/BaselineArguments.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/baseline/BaselineSubcommands.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CacheCommandList.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CacheCommands.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CacheContention.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CacheDistribution.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CacheSubcommands.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/CacheValidateIndexes.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CacheViewer.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/CheckIndexInlineSizes.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/FindAndDeleteGarbage.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/cache/IdleVerify.java rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/ResetLostPartitions.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/argument/DistributionCommandArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/argument/FindAndDeleteGarbageArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/argument/IdleVerifyCommandArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/argument/ListCommandArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/cache/argument/ValidateIndexesCommandArg.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/diagnostic/DiagnosticCommand.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/diagnostic/DiagnosticSubCommand.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/diagnostic/PageLocksCommand.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/encryption/EncryptionCommand.java (100%) rename modules/{core => control-utility}/src/main/java/org/apache/ignite/internal/commandline/encryption/EncryptionSubcommand.java (100%) create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/MetadataCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/MetadataSubCommandsList.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataAbstractSubCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataDetailsCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataHelpCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataListCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataRemoveCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/MetadataUpdateCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/query/KillCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/query/KillSubcommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCommand.java create mode 100644 modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotSubcommand.java create mode 100644 modules/control-utility/src/main/resources/META-INF/classnames.properties create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/internal/commandline/CommandHandlerParsingTest.java create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/internal/processors/security/GridCommandHandlerSslWithSecurityTest.java create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/testsuites/IgniteControlUtilityTestSuite.java create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/testsuites/ZookeeperIgniteControlUtilityTestSuite.java create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerAbstractTest.java rename modules/{indexing => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerBrokenIndexTest.java (100%) rename modules/{indexing => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerCheckIndexesInlineSizeTest.java (100%) rename modules/{core => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerClusterByClassAbstractTest.java (100%) create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerClusterByClassTest.java rename modules/{core => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerClusterByClassWithSSLTest.java (100%) rename modules/{core => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerClusterPerMethodAbstractTest.java (100%) rename modules/{indexing => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingCheckSizeTest.java (100%) create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingClusterByClassTest.java rename modules/{indexing => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingClusterByClassWithSSLTest.java (100%) create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingTest.java rename modules/{indexing => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingUtils.java (100%) rename modules/{indexing => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingWithSSLTest.java (100%) create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerMetadataTest.java rename modules/{core => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerSslTest.java (100%) create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerTest.java rename modules/{core => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerTestUtils.java (100%) rename modules/{core => control-utility}/src/test/java/org/apache/ignite/util/GridCommandHandlerWithSSLTest.java (100%) create mode 100644 modules/control-utility/src/test/java/org/apache/ignite/util/KillCommandsCommandShTest.java create mode 100644 modules/core/src/main/java/org/apache/ignite/client/ClientServices.java create mode 100644 modules/core/src/main/java/org/apache/ignite/events/ClusterTagUpdatedEvent.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientServicesImpl.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/BaselineCommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/CommandArgIterator.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/CommandList.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/CommonArgParser.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/StateCommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/TxCommands.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/cache/CacheValidateIndexes.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/cache/IdleVerify.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/subcommands/VoidDto.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataInfoTask.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataListResult.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataMarshalled.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataRemoveTask.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataTypeArgs.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/meta/tasks/MetadataUpdateTask.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/query/KillCommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/query/KillSubcommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotCommand.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/snapshot/SnapshotSubcommand.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/managers/systemview/walker/PartitionStateViewWalker.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveAcceptedMessage.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/IgniteHistoricalIteratorException.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/SupplyPartitionInfo.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/checkpoint/ReservationReason.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxCollisionsDumpSettingsClosure.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClientGetClusterStateComputeRequest.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClientSetClusterStateComputeRequest.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterIdAndTag.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/ClusterTagGenerator.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/IgniteClusterMXBeanImpl.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformLock.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/service/ClientServiceInvokeRequest.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/operation/SchemaAddQueryEntityOperation.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/misc/VisorClusterChangeTagTask.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/misc/VisorClusterChangeTagTaskArg.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/misc/VisorClusterChangeTagTaskResult.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/misc/VisorIdAndTagViewTask.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/misc/VisorIdAndTagViewTaskResult.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/snapshot/VisorSnapshotCancelTask.java create mode 100644 modules/core/src/main/java/org/apache/ignite/mxbean/IgniteClusterMXBean.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ConnectionRequestFuture.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/ConnectionRequestor.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/NodeUnreachableException.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpConnectionIndexAwareMessage.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpConnectionRequestDiscoveryMessage.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpInverseConnectionResponseMessage.java create mode 100644 modules/core/src/main/java/org/apache/ignite/spi/systemview/view/PartitionStateView.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/client/thin/AbstractThinClientTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/client/thin/ServicesTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/cluster/IgniteClusterIdTagTest.java delete mode 100644 modules/core/src/test/java/org/apache/ignite/internal/commandline/CommandHandlerParsingTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheCreateDestroyClusterReadOnlyModeAbstractTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheCreateDestroyClusterReadOnlyModeTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheClusterReadOnlyModeAbstractTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheClusterReadOnlyModeSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeClusterReadOnlyModeSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheStoreClusterReadOnlyModeSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteNearCacheClusterReadOnlyModeSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteNearCacheInvokeClusterReadOnlyModeSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataMoveLegacyFolderTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataRemoveTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataRemoveWithPersistenceTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteAtomicLongClusterReadOnlyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteAtomicReferenceClusterReadOnlyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteAtomicSequenceClusterReadOnlyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteAtomicStampedClusterReadOnlyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCollectionsClusterReadOnlyAbstractTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCountDownLatchClusterReadOnlyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructuresCreateDeniedInClusterReadOnlyMode.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructuresTestUtils.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteQueueClusterReadOnlyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteSetClusterReadOnlyTest.java delete mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCache150ClientsTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheMultiClientsStartTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccClientTopologyTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsCacheEntriesExpirationTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/HistoricalReservationTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgniteWalRebalanceLoggingTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/WalRebalanceRestartTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryBufferLimitTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxWithKeyContentionSelfTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorHangTest.java delete mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/GridCommandHandlerSslWithSecurityTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/client/IgniteClientContainSubjectAddressTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/sandbox/AbstractContinuousQuerySandboxTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/sandbox/ContinuousQuerySandboxTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/sandbox/ContinuousQueryWithTransformerSandboxTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceClusterReadOnlyModeTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceDeployClusterReadOnlyModeTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/p2p/GridP2PScanQueryWithTransformerTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/platform/PlatformComputeActiveTaskFuturesTask.java create mode 100644 modules/core/src/test/java/org/apache/ignite/platform/PlatformServiceCallCollectionsThinTask.java create mode 100644 modules/core/src/test/java/org/apache/ignite/platform/PlatformServiceCallThinTask.java create mode 100644 modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/GridTcpCommunicationInverseConnectionEstablishingTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/thread/ThreadPoolMetricsTest.java delete mode 100644 modules/core/src/test/java/org/apache/ignite/util/GridCommandHandlerAbstractTest.java delete mode 100644 modules/core/src/test/java/org/apache/ignite/util/GridCommandHandlerClusterByClassTest.java delete mode 100644 modules/core/src/test/java/org/apache/ignite/util/GridCommandHandlerTest.java delete mode 100644 modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/SingleSplitTestTask.java create mode 100644 modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/ScanQueryTestTransformer.java create mode 100644 modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/ScanQueryTestTransformerWrapper.java create mode 100644 modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/classic/SingleSplitTestTask.java create mode 100644 modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/compute/ExternalLambda.java create mode 100644 modules/extdata/uri/src/main/java/org/apache/ignite/tests/p2p/compute/ExternalLambda.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheSqlDdlClusterReadOnlyModeTest.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteDynamicEnableIndexingRestoreTest.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingAbstractTest.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingBasicSelfTest.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingConcurrentSelfTest.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/CreateIndexOnInvalidDataTypeTest.java create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/SqlNotNullKeyValueFieldTest.java delete mode 100644 modules/indexing/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingClusterByClassTest.java delete mode 100644 modules/indexing/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingTest.java delete mode 100644 modules/indexing/src/test/java/org/apache/ignite/util/KillCommandsCommandShTest.java create mode 100644 modules/ml/src/main/java/org/apache/ignite/ml/math/distances/ChebyshevDistance.java create mode 100644 modules/ml/src/main/java/org/apache/ignite/ml/math/distances/CosineSimilarity.java create mode 100644 modules/ml/src/main/java/org/apache/ignite/ml/math/distances/JaccardIndex.java create mode 100644 modules/ml/src/main/java/org/apache/ignite/ml/math/distances/MinkowskiDistance.java create mode 100644 modules/ml/src/test/java/org/apache/ignite/ml/math/distances/CosineSimilarityTest.java create mode 100644 modules/ml/src/test/java/org/apache/ignite/ml/math/distances/JaccardIndexTest.java delete mode 100644 modules/mqtt/README.txt delete mode 100644 modules/mqtt/licenses/apache-2.0.txt delete mode 100644 modules/mqtt/pom.xml delete mode 100644 modules/mqtt/src/main/java/org/apache/ignite/stream/mqtt/MqttStreamer.java delete mode 100644 modules/mqtt/src/main/java/org/apache/ignite/stream/mqtt/package-info.java delete mode 100644 modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java delete mode 100644 modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTestSuite.java delete mode 100644 modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/package-info.java create mode 100644 modules/platforms/cpp/CMakeLists.txt delete mode 100644 modules/platforms/cpp/Makefile.am delete mode 100644 modules/platforms/cpp/Makefile.amrel create mode 100644 modules/platforms/cpp/binary/CMakeLists.txt delete mode 100644 modules/platforms/cpp/binary/Makefile.am delete mode 100644 modules/platforms/cpp/binary/configure.ac delete mode 100644 modules/platforms/cpp/binary/include/Makefile.am create mode 100644 modules/platforms/cpp/cmake/FindIgnite.cmake create mode 100644 modules/platforms/cpp/cmake/FindODBC.cmake create mode 100644 modules/platforms/cpp/common/CMakeLists.txt delete mode 100644 modules/platforms/cpp/common/Makefile.am delete mode 100644 modules/platforms/cpp/common/configure.ac delete mode 100644 modules/platforms/cpp/common/include/Makefile.am delete mode 100644 modules/platforms/cpp/common/os/linux/include/Makefile.am delete mode 100644 modules/platforms/cpp/configure.ac delete mode 100644 modules/platforms/cpp/configure.acrel create mode 100644 modules/platforms/cpp/core-test/CMakeLists.txt delete mode 100644 modules/platforms/cpp/core-test/Makefile.am delete mode 100644 modules/platforms/cpp/core-test/configure.ac delete mode 100644 modules/platforms/cpp/core-test/include/Makefile.am create mode 100644 modules/platforms/cpp/core/CMakeLists.txt delete mode 100644 modules/platforms/cpp/core/Makefile.am delete mode 100644 modules/platforms/cpp/core/configure.ac delete mode 100644 modules/platforms/cpp/core/ignite.pc.in delete mode 100644 modules/platforms/cpp/core/include/Makefile.am create mode 100644 modules/platforms/cpp/examples/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/Makefile.am create mode 100644 modules/platforms/cpp/examples/compute-example/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/compute-example/Makefile.am delete mode 100644 modules/platforms/cpp/examples/configure.ac create mode 100644 modules/platforms/cpp/examples/continuous-query-example/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/continuous-query-example/Makefile.am delete mode 100644 modules/platforms/cpp/examples/include/Makefile.am create mode 100644 modules/platforms/cpp/examples/odbc-example/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/odbc-example/Makefile.am create mode 100644 modules/platforms/cpp/examples/put-get-example/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/put-get-example/Makefile.am create mode 100644 modules/platforms/cpp/examples/query-example/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/query-example/Makefile.am create mode 100644 modules/platforms/cpp/examples/thin-client-put-get-example/CMakeLists.txt delete mode 100644 modules/platforms/cpp/examples/thin-client-put-get-example/Makefile.am create mode 100644 modules/platforms/cpp/ignite/CMakeLists.txt delete mode 100644 modules/platforms/cpp/ignite/Makefile.am delete mode 100644 modules/platforms/cpp/ignite/configure.ac create mode 100644 modules/platforms/cpp/jni/CMakeLists.txt delete mode 100644 modules/platforms/cpp/jni/Makefile.am delete mode 100644 modules/platforms/cpp/jni/configure.ac delete mode 100644 modules/platforms/cpp/jni/include/Makefile.am create mode 100644 modules/platforms/cpp/network/CMakeLists.txt delete mode 100644 modules/platforms/cpp/network/Makefile.am delete mode 100644 modules/platforms/cpp/network/configure.ac delete mode 100644 modules/platforms/cpp/network/include/Makefile.am create mode 100644 modules/platforms/cpp/odbc-test/CMakeLists.txt delete mode 100644 modules/platforms/cpp/odbc-test/Makefile.am create mode 100755 modules/platforms/cpp/odbc-test/config/ssl/generate_certificates.sh delete mode 100644 modules/platforms/cpp/odbc-test/include/Makefile.am create mode 100644 modules/platforms/cpp/odbc/CMakeLists.txt delete mode 100644 modules/platforms/cpp/odbc/Makefile.am delete mode 100644 modules/platforms/cpp/odbc/configure.ac delete mode 100644 modules/platforms/cpp/odbc/include/Makefile.am create mode 100644 modules/platforms/cpp/thin-client-test/CMakeLists.txt delete mode 100644 modules/platforms/cpp/thin-client-test/Makefile.am create mode 100755 modules/platforms/cpp/thin-client-test/config/ssl/generate_certificates.sh delete mode 100644 modules/platforms/cpp/thin-client-test/configure.ac delete mode 100644 modules/platforms/cpp/thin-client-test/include/Makefile.am create mode 100644 modules/platforms/cpp/thin-client/CMakeLists.txt delete mode 100644 modules/platforms/cpp/thin-client/Makefile.am delete mode 100644 modules/platforms/cpp/thin-client/include/Makefile.am create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/OptimisticTransactionTest.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteLockFailoverTests.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/IgniteLockTests.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Cache/Query/Continuous/IContinuousQueryHandleFields.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Configuration/LockConfiguration.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/IIgniteLock.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/IQueryBaseInternal.cs create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/IgniteLock.cs delete mode 100644 modules/rocketmq/README.txt delete mode 100644 modules/rocketmq/pom.xml delete mode 100644 modules/rocketmq/src/main/java/org/apache/ignite/stream/rocketmq/RocketMQStreamer.java delete mode 100644 modules/rocketmq/src/main/java/org/apache/ignite/stream/rocketmq/package-info.java delete mode 100644 modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTest.java delete mode 100644 modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/RocketMQStreamerTestSuite.java delete mode 100644 modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/TestRocketMQServer.java delete mode 100644 modules/rocketmq/src/test/java/org/apache/ignite/stream/rocketmq/package-info.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/config/DynamicQueryConfig.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/DeclaredQuery.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/EmptyDeclaredQuery.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/ExpressionBasedStringQuery.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/QueryUtils.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/StringQuery.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/spel/SpelEvaluator.java create mode 100644 modules/spring-data-2.0/src/main/java/org/apache/ignite/springdata20/repository/query/spel/SpelQueryContext.java create mode 100644 modules/spring-data-2.0/src/test/java/org/apache/ignite/springdata/misc/FullNameProjection.java create mode 100644 modules/spring-data-2.0/src/test/java/org/apache/ignite/springdata/misc/PersonKey.java create mode 100644 modules/spring-data-2.0/src/test/java/org/apache/ignite/springdata/misc/PersonProjection.java create mode 100644 modules/spring-data-2.0/src/test/java/org/apache/ignite/springdata/misc/PersonRepositoryOtherIgniteInstance.java create mode 100644 modules/spring-data-2.0/src/test/java/org/apache/ignite/springdata/misc/PersonRepositoryWithCompoundKey.java create mode 100644 modules/spring-data-2.0/src/test/java/org/apache/ignite/springdata/misc/SampleEvaluationContextExtension.java create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/DynamicQueryConfig.java create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/DeclaredQuery.java create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/EmptyDeclaredQuery.java create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/ExpressionBasedStringQuery.java create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/QueryUtils.java create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/StringQuery.java create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/FullNameProjection.java create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/PersonKey.java create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/PersonProjection.java create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/PersonRepositoryOtherIgniteInstance.java create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/PersonRepositoryWithCompoundKey.java create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/SampleEvaluationContextExtension.java create mode 100644 modules/spring-data/src/test/java/org/apache/ignite/springdata/misc/PersonKey.java create mode 100644 modules/spring-data/src/test/java/org/apache/ignite/springdata/misc/PersonRepositoryWithCompoundKey.java create mode 100644 modules/yardstick/config/benchmark-thin-services.properties create mode 100644 modules/yardstick/config/ignite-services-config.xml create mode 100644 modules/yardstick/src/main/java/org/apache/ignite/yardstick/thin/service/IgniteThinServiceInvocationBenchmark.java create mode 100644 modules/yardstick/src/main/java/org/apache/ignite/yardstick/thin/service/SimpleService.java create mode 100644 modules/yardstick/src/main/java/org/apache/ignite/yardstick/thin/service/SimpleServiceImpl.java