You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ti...@apache.org on 2025/06/11 10:03:22 UTC
(ignite) 01/01: Merge branch 'master' of github.com:apache/ignite into IGNITE-23856__thin_cln_channels_duplication
This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a commit to branch IGNITE-23856__thin_cln_channels_duplication
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 32e9487b94a952bc07fd5148fdcffe5c8004962f
Merge: d316195d646 ea4b33fe435
Author: Maksim Timonin <ti...@gmail.com>
AuthorDate: Wed Jun 11 13:02:58 2025 +0300
Merge branch 'master' of github.com:apache/ignite into IGNITE-23856__thin_cln_channels_duplication
.asf.yaml | 2 +-
.gitignore | 2 +
assembly/dependencies-apache-ignite-lgpl.xml | 3 +
assembly/dependencies-apache-ignite-slim.xml | 3 +
assembly/dependencies-apache-ignite.xml | 3 +
docs/_data/toc.yaml | 2 +
docs/_docs/SQL/custom-sql-func.adoc | 5 +-
.../ignite/snippets/IgniteSessionContext.java | 116 +
docs/_docs/data-structures/atomic-types.adoc | 2 +-
docs/_docs/monitoring-metrics/system-views.adoc | 30 +
docs/_docs/session-context.adoc | 69 +
docs/_docs/sql-reference/dml.adoc | 4 +-
docs/_docs/tools/control-script.adoc | 6 +-
docs/_layouts/default.html | 27 +-
examples/pom.xml | 6 +
modules/benchmarks/pom.xml | 25 +
.../benchmarks/jmh/sql/tpch/TpchBenchmark.java | 336 +++
modules/{codegen => binary/api}/pom.xml | 23 +-
.../apache/ignite/binary/BinaryBasicIdMapper.java | 0
.../ignite/binary/BinaryBasicNameMapper.java | 0
.../ignite/binary/BinaryCollectionFactory.java | 0
.../java/org/apache/ignite/binary/BinaryField.java | 0
.../org/apache/ignite/binary/BinaryIdMapper.java | 0
.../ignite/binary/BinaryInvalidTypeException.java | 0
.../org/apache/ignite/binary/BinaryMapFactory.java | 0
.../org/apache/ignite/binary/BinaryNameMapper.java | 4 +-
.../org/apache/ignite/binary/BinaryObject.java | 0
.../apache/ignite/binary/BinaryObjectBuilder.java | 0
.../ignite/binary/BinaryObjectException.java | 0
.../org/apache/ignite/binary/BinaryRawReader.java | 0
.../org/apache/ignite/binary/BinaryRawWriter.java | 0
.../org/apache/ignite/binary/BinaryReader.java | 0
.../ignite/binary/BinaryReflectiveSerializer.java | 0
.../org/apache/ignite/binary/BinarySerializer.java | 0
.../java/org/apache/ignite/binary/BinaryType.java | 0
.../ignite/binary/BinaryTypeConfiguration.java | 5 +-
.../org/apache/ignite/binary/BinaryWriter.java | 0
.../org/apache/ignite/binary/Binarylizable.java | 0
.../org/apache/ignite/binary/package-info.java | 0
modules/bom/pom.xml | 10 +
modules/calcite/pom.xml | 31 +
modules/calcite/src/main/codegen/config.fmpp | 1 -
.../query/calcite/CalciteQueryProcessor.java | 71 +-
.../query/calcite/exec/IndexFirstLastScan.java | 4 +-
.../processors/query/calcite/exec/IndexScan.java | 4 +-
.../query/calcite/exec/LogicalRelImplementor.java | 40 +-
.../query/calcite/exec/PartitionExtractor.java | 2 +
.../calcite/exec/exp/ExpressionFactoryImpl.java | 12 +-
.../query/calcite/exec/exp/RexToLixTranslator.java | 4 +-
.../query/calcite/exec/rel/MemoryTrackingNode.java | 5 +-
.../query/calcite/exec/rel/MergeJoinNode.java | 14 +-
.../processors/query/calcite/exec/rel/Outbox.java | 39 +-
.../query/calcite/exec/rel/ScanNode.java | 6 +-
.../query/calcite/exec/rel/UncollectNode.java | 245 ++
.../exec/task/AbstractQueryTaskExecutor.java | 3 +
.../exec/task/QueryBlockingTaskExecutor.java | 4 +-
.../exec/task/StripedQueryTaskExecutor.java | 4 +-
.../calcite/exec/tracker/ObjectSizeCalculator.java | 36 +-
.../query/calcite/externalize/RelJson.java | 6 +-
.../query/calcite/hint/HintDefinition.java | 8 +-
.../query/calcite/message/ErrorMessage.java | 24 +-
.../query/calcite/message/GenericValueMessage.java | 16 +-
.../query/calcite/message/InboxCloseMessage.java | 24 +-
.../message/QueryBatchAcknowledgeMessage.java | 28 +-
.../query/calcite/message/QueryBatchMessage.java | 36 +-
.../query/calcite/message/QueryCloseMessage.java | 16 +-
.../query/calcite/message/QueryStartRequest.java | 56 +-
.../query/calcite/message/QueryStartResponse.java | 24 +-
.../query/calcite/message/QueryTxEntry.java | 28 +-
.../query/calcite/metadata/ColocationGroup.java | 28 +-
.../calcite/metadata/FragmentDescription.java | 28 +-
.../query/calcite/metadata/FragmentMapping.java | 29 +-
.../calcite/metadata/IgniteMdSelectivity.java | 2 +
.../processors/query/calcite/prepare/Cloner.java | 6 +
.../processors/query/calcite/prepare/Fragment.java | 19 +
.../query/calcite/prepare/IgnitePlanner.java | 137 +-
.../query/calcite/prepare/IgnitePrograms.java | 12 +-
.../query/calcite/prepare/IgniteRelShuttle.java | 6 +
.../calcite/prepare/IgniteSqlCallRewriteTable.java | 42 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 10 +-
.../query/calcite/prepare/PlannerHelper.java | 270 +-
.../query/calcite/prepare/PlannerPhase.java | 29 +-
.../query/calcite/prepare/PlanningContext.java | 6 +-
.../query/calcite/rel/AbstractIgniteJoin.java | 2 +-
.../processors/query/calcite/rel/IgniteFilter.java | 10 +
.../query/calcite/rel/IgniteRelVisitor.java | 5 +
.../query/calcite/rel/IgniteUncollect.java | 121 +
.../rel/ProjectableFilterableTableScan.java | 2 +-
.../rel/agg/IgniteColocatedAggregateBase.java | 2 +-
.../calcite/rel/agg/IgniteReduceSortAggregate.java | 5 +
...{CollectRule.java => CollectConverterRule.java} | 8 +-
...ollectRule.java => UncollectConverterRule.java} | 24 +-
.../rule/logical/IgniteMultiJoinOptimizeRule.java | 446 +++
.../calcite/schema/CacheTableDescriptorImpl.java | 67 +-
.../query/calcite/schema/SchemaHolderImpl.java | 4 +-
.../calcite/sql/generated/IgniteSqlParserImpl.java | 1860 ++++++------
.../calcite/sql/stat/IgniteSqlStatisticsTable.java | 7 +-
.../query/calcite/util/ListFieldsQueryCursor.java | 4 +-
.../processors/query/calcite/util/RexUtils.java | 68 +
.../processors/query/calcite/util/TypeUtils.java | 17 +-
.../processors/query/calcite/QueryChecker.java | 37 +-
.../query/calcite/RuleApplyListener.java | 76 +
.../calcite/exec/rel/AbstractExecutionTest.java | 24 +-
.../query/calcite/exec/rel/BaseAggregateTest.java | 11 +-
.../query/calcite/exec/rel/ExecutionTest.java | 9 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 7 +-
.../query/calcite/exec/rel/LimitExecutionTest.java | 25 +-
.../calcite/exec/rel/MergeJoinExecutionTest.java | 7 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 8 +-
.../calcite/exec/rel/TableSpoolExecutionTest.java | 18 +-
.../calcite/exec/rel/UncollectExecutionTest.java | 160 ++
.../exec/task/QueryBlockingTaskExecutorTest.java | 3 +
.../integration/AbstractBasicIntegrationTest.java | 28 +
.../CalciteBasicSecondaryIndexIntegrationTest.java | 4 +-
.../integration/CalcitePlanningDumpTest.java | 77 +
...st.java => DistributedJoinIntegrationTest.java} | 78 +-
.../DynamicParametersIntegrationTest.java | 179 +-
.../query/calcite/integration/FunctionsTest.java | 22 +
.../integration/LimitOffsetIntegrationTest.java | 4 +-
.../QueryWithPartitionsIntegrationTest.java | 18 +-
.../integration/RunningQueriesIntegrationTest.java | 36 +-
.../integration/ScalarInIntegrationTest.java | 108 +
.../integration/SortAggregateIntegrationTest.java | 23 +-
.../integration/SqlDiagnosticIntegrationTest.java | 141 +
.../integration/SqlPlanHistoryIntegrationTest.java | 135 +-
.../calcite/integration/StdSqlOperatorsTest.java | 2 +
.../integration/TableDdlIntegrationTest.java | 4 +-
.../integration/TableDmlIntegrationTest.java | 3 +
.../calcite/integration/UnnestIntegrationTest.java | 145 +
.../query/calcite/integration/tpch/TpchHelper.java | 460 +++
.../query/calcite/integration/tpch/TpchTest.java | 63 +
.../query/calcite/planner/AbstractPlannerTest.java | 77 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 106 +-
.../planner/CorrelatedSubqueryPlannerTest.java | 39 +
.../calcite/planner/JoinColocationPlannerTest.java | 25 +
.../calcite/planner/JoinCommutePlannerTest.java | 220 +-
.../query/calcite/planner/PlannerTest.java | 2 +-
.../planner/RexSimplificationPlannerTest.java | 196 ++
.../calcite/planner/UncollectPlannerTest.java | 141 +
.../planner/hints/JoinTypeHintPlannerTest.java | 168 +-
.../calcite/rules/JoinOrderOptimizationTest.java | 234 ++
.../query/calcite/sql/SqlReservedWordsTest.java | 1 +
.../ignite/testsuites/ExecutionTestSuite.java | 2 +
.../ignite/testsuites/IntegrationTestSuite.java | 14 +-
.../apache/ignite/testsuites/PlannerTestSuite.java | 6 +-
.../query/calcite/integration/tpch/ddl.sql | 105 +
.../query/calcite/integration/tpch/q1.sql | 28 +
.../query/calcite/integration/tpch/q10.sql | 40 +
.../query/calcite/integration/tpch/q11.sql | 34 +
.../query/calcite/integration/tpch/q12.sql | 35 +
.../query/calcite/integration/tpch/q13.sql | 27 +
.../query/calcite/integration/tpch/q14.sql | 20 +
.../query/calcite/integration/tpch/q15.sql | 38 +
.../query/calcite/integration/tpch/q16.sql | 37 +
.../query/calcite/integration/tpch/q17.sql | 24 +
.../query/calcite/integration/tpch/q18.sql | 40 +
.../query/calcite/integration/tpch/q19.sql | 42 +
.../query/calcite/integration/tpch/q2.sql | 51 +
.../query/calcite/integration/tpch/q20.sql | 44 +
.../query/calcite/integration/tpch/q21.sql | 47 +
.../query/calcite/integration/tpch/q22.sql | 44 +
.../query/calcite/integration/tpch/q3.sql | 30 +
.../query/calcite/integration/tpch/q4.sql | 28 +
.../query/calcite/integration/tpch/q5.sql | 31 +
.../query/calcite/integration/tpch/q6.sql | 16 +
.../query/calcite/integration/tpch/q7.sql | 46 +
.../query/calcite/integration/tpch/q8.sql | 44 +
.../query/calcite/integration/tpch/q9.sql | 39 +
...est_large_in.test_ignore => test_large_in.test} | 1 -
modules/clients/pom.xml | 12 +
.../clients/src/test/config/jdbc-bin-config.xml | 4 -
.../ClientAbstractConnectivitySelfTest.java | 9 +-
.../client/suite/IgniteClientTestSuite.java | 3 -
.../internal/client/util/ClientByteUtilsTest.java | 189 --
.../internal/jdbc2/JdbcBinaryBufferTest.java | 2 +-
.../apache/ignite/internal/jdbc2/JdbcBlobTest.java | 2 +-
.../rest/JettyRestProcessorAbstractSelfTest.java | 6 +-
...ttyRestProcessorAuthenticationAbstractTest.java | 3 +-
.../rest/JettyRestProcessorBaselineSelfTest.java | 3 +-
.../internal/processors/rest/TestBinaryClient.java | 8 +-
.../JdbcThinAuthenticateConnectionSelfTest.java | 3 +-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 4 +-
.../thin/JdbcThinPreparedStatementSelfTest.java | 2 +-
modules/codegen/pom.xml | 4 +
.../ignite/codegen/MessageCodeGenerator.java | 159 +-
modules/{codegen => commons}/pom.xml | 23 +-
.../org/apache/ignite/IgniteCheckedException.java | 0
.../ignite/IgniteCommonsSystemProperties.java | 264 ++
.../java/org/apache/ignite/IgniteException.java | 0
.../java/org/apache/ignite/SystemProperty.java | 0
.../apache/ignite/internal/util/CommonUtils.java | 179 ++
.../ignite/internal/util/GridArgumentCheck.java | 0
.../internal/util/GridConcurrentHashSet.java | 0
.../ignite/internal/util/GridEmptyIterator.java | 0
.../apache/ignite/internal/util/GridLeanMap.java | 74 +-
.../apache/ignite/internal/util/GridLeanSet.java | 0
.../internal/util/GridSerializableCollection.java | 0
.../internal/util/GridSerializableIterator.java | 0
.../ignite/internal/util/GridSerializableMap.java | 0
.../ignite/internal/util/GridSerializableSet.java | 0
.../ignite/internal/util/GridSetWrapper.java | 0
.../ignite/internal/util/GridStringBuilder.java | 3 +-
.../ignite/internal/util/lang/GridAbsClosure.java | 4 -
.../internal/util/lang/GridClosureException.java | 0
.../apache/ignite/internal/util/lang/GridFunc.java | 1511 +---------
.../ignite/internal/util/lang/GridIterable.java | 0
.../ignite/internal/util/lang/GridIterator.java | 0
.../internal/util/lang/GridIteratorAdapter.java | 0
.../ignite/internal/util/lang/GridTuple.java | 0
.../ignite/internal/util/lang/GridTuple3.java | 4 +-
.../ignite/internal/util/lang/GridTuple4.java | 4 +-
.../ignite/internal/util/lang/GridTuple5.java | 5 +-
.../ignite/internal/util/lang/GridTuple6.java | 5 +-
.../ignite/internal/util/lang/IgnitePair.java | 0
.../util/lang/gridfunc/AlwaysFalsePredicate.java | 0
.../util/lang/gridfunc/AlwaysTruePredicate.java | 0
.../util/lang/gridfunc/AlwaysTrueReducer.java | 0
.../lang/gridfunc/CacheEntryGetValueClosure.java | 0
.../lang/gridfunc/CacheEntryHasPeekPredicate.java | 0
.../gridfunc/ConcurrentHashSetFactoryCallable.java | 0
.../gridfunc/ConcurrentMapFactoryCallable.java | 0
.../gridfunc/EntryByKeyEvaluationPredicate.java | 0
.../util/lang/gridfunc/EqualsUuidPredicate.java | 0
.../util/lang/gridfunc/FlatCollectionWrapper.java | 0
.../internal/util/lang/gridfunc/FlatIterator.java | 0
.../util/lang/gridfunc/IdentityClosure.java | 0
.../util/lang/gridfunc/IsAllPredicate.java | 0
.../util/lang/gridfunc/IsNotAllPredicate.java | 0
.../util/lang/gridfunc/IsNotNullPredicate.java | 0
.../util/lang/gridfunc/MultipleIterator.java | 0
.../util/lang/gridfunc/NotContainsPredicate.java | 0
.../util/lang/gridfunc/NotEqualPredicate.java | 4 +-
.../lang/gridfunc/PredicateCollectionView.java | 0
.../util/lang/gridfunc/PredicateMapView.java | 0
.../util/lang/gridfunc/PredicateSetView.java | 0
.../util/lang/gridfunc/ReadOnlyCollectionView.java | 0
.../lang/gridfunc/ReadOnlyCollectionView2X.java | 0
.../util/lang/gridfunc/SetFactoryCallable.java | 0
.../util/lang/gridfunc/StringConcatReducer.java | 0
.../lang/gridfunc/TransformCollectionView.java | 0
.../lang/gridfunc/TransformFilteringIterator.java | 0
.../util/lang/gridfunc/TransformMapView.java | 0
.../util/tostring/CircularStringBuilder.java | 0
.../util/tostring/GridToStringBuilder.java | 42 +-
.../util/tostring/GridToStringClassDescriptor.java | 0
.../util/tostring/GridToStringExclude.java | 0
.../util/tostring/GridToStringFieldDescriptor.java | 64 +-
.../util/tostring/GridToStringInclude.java | 4 +-
.../internal/util/tostring/GridToStringOrder.java | 0
.../ReflectionToStringFieldDescriptor.java | 135 +
.../internal/util/tostring/SBLengthLimit.java | 5 +-
.../internal/util/tostring/SBLimitedLength.java | 0
.../internal/util/tostring/package-info.java | 0
.../apache/ignite/internal/util/typedef/C1.java | 0
.../apache/ignite/internal/util/typedef/C2.java | 0
.../apache/ignite/internal/util/typedef/CI1.java | 0
.../apache/ignite/internal/util/typedef/CI2.java | 0
.../apache/ignite/internal/util/typedef/CO.java | 0
.../org/apache/ignite/internal/util/typedef/F.java | 0
.../apache/ignite/internal/util/typedef/P1.java | 0
.../apache/ignite/internal/util/typedef/P2.java | 0
.../apache/ignite/internal/util/typedef/PCE.java | 0
.../apache/ignite/internal/util/typedef/PKV.java | 0
.../apache/ignite/internal/util/typedef/R1.java | 0
.../apache/ignite/internal/util/typedef/T1.java | 1 -
.../apache/ignite/internal/util/typedef/T2.java | 1 -
.../apache/ignite/internal/util/typedef/T3.java | 1 -
.../apache/ignite/internal/util/typedef/T4.java | 1 -
.../apache/ignite/internal/util/typedef/T5.java | 1 -
.../apache/ignite/internal/util/typedef/T6.java | 1 -
.../org/apache/ignite/internal/util/typedef/X.java | 73 +-
.../ignite/internal/util/typedef/internal/A.java | 0
.../ignite/internal/util/typedef/internal/S.java | 0
.../ignite/internal/util/typedef/internal/SB.java | 0
.../org/apache/ignite/lang/IgniteBiClosure.java | 0
.../org/apache/ignite/lang/IgniteBiInClosure.java | 0
.../org/apache/ignite/lang/IgniteBiPredicate.java | 0
.../java/org/apache/ignite/lang/IgniteBiTuple.java | 7 +-
.../org/apache/ignite/lang/IgniteCallable.java | 0
.../java/org/apache/ignite/lang/IgniteClosure.java | 0
.../org/apache/ignite/lang/IgniteInClosure.java | 0
.../org/apache/ignite/lang/IgniteOutClosure.java | 0
.../org/apache/ignite/lang/IgnitePredicate.java | 0
.../java/org/apache/ignite/lang/IgniteReducer.java | 0
.../org/apache/ignite/lang/IgniteRunnable.java | 0
.../compatibility/IgniteReleasedVersion.java | 5 +-
.../persistence/FoldersReuseCompatibilityTest.java | 12 +-
...IgnitePersistenceCompatibilityAbstractTest.java | 31 +-
...gratingToWalV2SerializerWithCompactionTest.java | 10 +-
.../persistence/SnapshotCompatibilityTest.java | 330 +++
.../IgniteCompatibilityBasicTestSuite.java | 2 +
modules/compress/pom.xml | 12 +
.../snapshot/SnapshotCompressionBasicTest.java | 7 +-
modules/control-utility/pom.xml | 12 +
.../commandline/CliIgniteClientInvoker.java | 6 +-
.../internal/commandline/CommandHandler.java | 35 +-
.../commandline/indexreader/IgniteIndexReader.java | 17 +-
.../indexreader/IgniteIndexReaderTest.java | 53 +-
.../testsuites/IgniteControlUtilityTestSuite.java | 2 +
.../ZookeeperIgniteControlUtilityTestSuite.java | 2 +
.../org/apache/ignite/util/CdcCommandTest.java | 3 +-
.../GridCommandHandlerFactoryAbstractTest.java | 23 +-
.../GridCommandHandlerIndexForceRebuildTest.java | 5 +-
.../GridCommandHandlerIndexRebuildStatusTest.java | 17 +-
.../util/GridCommandHandlerIndexingTest.java | 20 +-
.../util/GridCommandHandlerIndexingUtils.java | 2 +-
.../util/GridCommandHandlerMetadataTest.java | 5 +-
.../util/GridCommandHandlerPropertiesTest.java | 40 +
.../apache/ignite/util/GridCommandHandlerTest.java | 437 +--
.../ignite/util/GridPersistenceCommandsTest.java | 471 ++++
.../util/PerformanceStatisticsCommandTest.java | 8 +-
modules/core/pom.xml | 26 +
.../org/apache/ignite/IgniteSystemProperties.java | 273 +-
.../java/org/apache/ignite/cache/QueryEntity.java | 24 +-
.../java/org/apache/ignite/cache/QueryIndex.java | 6 +-
.../cache/store/jdbc/CacheAbstractJdbcStore.java | 38 +-
.../ignite/configuration/CacheConfiguration.java | 38 +-
.../configuration/DataStorageConfiguration.java | 35 +-
.../ignite/configuration/IgniteConfiguration.java | 35 -
.../ignite/configuration/SqlConfiguration.java | 12 +-
.../java/org/apache/ignite/dump/DumpEntry.java | 3 +-
.../java/org/apache/ignite/dump/DumpReader.java | 216 +-
.../ignite/dump/DumpReaderConfiguration.java | 68 +-
.../ignite/internal/GridEventConsumeHandler.java | 6 +-
.../ignite/internal/GridJobCancelRequest.java | 24 +-
.../ignite/internal/GridJobExecuteRequest.java | 112 +-
.../ignite/internal/GridJobExecuteResponse.java | 44 +-
.../ignite/internal/GridJobSiblingsRequest.java | 20 +-
.../ignite/internal/GridJobSiblingsResponse.java | 16 +-
.../apache/ignite/internal/GridKernalContext.java | 6 +
.../ignite/internal/GridKernalContextImpl.java | 9 +
.../ignite/internal/GridMessageListenHandler.java | 4 +-
.../ignite/internal/GridTaskCancelRequest.java | 16 +-
.../ignite/internal/GridTaskSessionImpl.java | 6 +-
.../ignite/internal/GridTaskSessionRequest.java | 24 +-
.../ignite/internal/IgniteDiagnosticMessage.java | 205 +-
.../internal/IgniteDiagnosticPrepareContext.java | 127 +-
.../org/apache/ignite/internal/IgniteKernal.java | 142 +-
.../org/apache/ignite/internal/IgnitionEx.java | 28 +-
.../internal/MarshallerMappingFileStore.java | 3 +-
.../binary/BinaryAbstractIdentityResolver.java | 2 +-
.../apache/ignite/internal/binary/BinaryArray.java | 44 +-
.../binary/BinaryArrayIdentityResolver.java | 26 +-
.../binary/BinaryCachingMetadataHandler.java | 4 +-
.../internal/binary/BinaryClassDescriptor.java | 73 +-
.../ignite/internal/binary/BinaryContext.java | 167 +-
.../internal/binary/BinaryContextHolder.java | 2 +-
.../ignite/internal/binary/BinaryEnumArray.java | 2 +-
.../ignite/internal/binary/BinaryEnumCache.java | 6 +-
.../internal/binary/BinaryEnumObjectImpl.java | 32 +-
.../internal/binary/BinaryFieldAccessor.java | 60 +-
.../ignite/internal/binary/BinaryFieldEx.java | 50 -
.../ignite/internal/binary/BinaryFieldImpl.java | 175 +-
.../internal/binary/BinaryIdentityResolver.java | 2 +-
.../internal/binary/BinaryInternalMapper.java | 2 +-
.../ignite/internal/binary/BinaryMetadata.java | 27 +-
.../internal/binary/BinaryMetadataCollector.java | 2 +-
.../internal/binary/BinaryMethodWriteReplacer.java | 2 +-
.../internal/binary/BinaryNoopMetadataHandler.java | 4 +-
.../ignite/internal/binary/BinaryObjectEx.java | 58 +
.../ignite/internal/binary/BinaryObjectExImpl.java | 30 +-
.../ignite/internal/binary/BinaryObjectImpl.java | 59 +-
.../internal/binary/BinaryObjectOffheapImpl.java | 37 +-
.../ignite/internal/binary/BinaryRawWriterEx.java | 60 -
...{BinaryRawReaderEx.java => BinaryReaderEx.java} | 50 +-
.../ignite/internal/binary/BinaryReaderExImpl.java | 70 +-
.../internal/binary/BinaryReaderHandles.java | 2 +-
.../internal/binary/BinaryReaderHandlesHolder.java | 9 +-
.../binary/BinaryReaderHandlesHolderImpl.java | 7 +-
.../ignite/internal/binary/BinarySchema.java | 12 +-
.../internal/binary/BinarySchemaRegistry.java | 4 +-
.../binary/BinarySerializedFieldComparator.java | 7 +-
.../internal/binary/BinaryThreadLocalContext.java | 6 +-
.../ignite/internal/binary/BinaryTreeMap.java | 2 +-
.../binary/BinaryTreeMapWriteReplacer.java | 2 +-
.../ignite/internal/binary/BinaryTreeSet.java | 2 +-
.../binary/BinaryTreeSetWriteReplacer.java | 2 +-
.../ignite/internal/binary/BinaryTypeImpl.java | 3 +-
.../ignite/internal/binary/BinaryTypeProxy.java | 2 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 705 +++--
.../ignite/internal/binary/BinaryWriteMode.java | 2 +-
.../internal/binary/BinaryWriteReplacer.java | 2 +-
.../ignite/internal/binary/BinaryWriterEx.java | 210 ++
.../ignite/internal/binary/BinaryWriterExImpl.java | 1557 ++++-------
.../internal/binary/BinaryWriterHandles.java | 2 +-
.../internal/binary/BinaryWriterSchemaHolder.java | 2 +-
.../binary/CrossObjectReferenceResolver.java | 2 +-
.../internal/binary/GridBinaryMarshaller.java | 104 +-
.../ignite/internal/binary/ObjectDetachHelper.java | 4 +-
.../internal/binary/builder/BinaryBuilderEnum.java | 8 +-
.../binary/builder/BinaryBuilderReader.java | 50 +-
.../builder/BinaryBuilderSerializationAware.java | 4 +-
.../binary/builder/BinaryBuilderSerializer.java | 39 +-
.../binary/builder/BinaryEnumArrayLazyValue.java | 6 +-
.../binary/builder/BinaryLazyArrayList.java | 4 +-
.../binary/builder/BinaryLazyLinkedList.java | 4 +-
.../internal/binary/builder/BinaryLazyMap.java | 4 +-
.../internal/binary/builder/BinaryLazySet.java | 4 +-
.../binary/builder/BinaryModifiableLazyValue.java | 6 +-
.../binary/builder/BinaryObjectArrayLazyValue.java | 6 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 83 +-
.../binary/builder/BinaryObjectBuilders.java | 72 +
.../binary/builder/BinaryPlainBinaryObject.java | 17 +-
.../binary/builder/BinaryPlainLazyValue.java | 4 +-
.../binary/builder/BinaryValueWithType.java | 4 +-
.../binary/streams/BinaryAbstractInputStream.java | 2 +-
.../binary/streams/BinaryAbstractOutputStream.java | 12 +-
.../binary/streams/BinaryAbstractStream.java | 6 +-
.../streams/BinaryByteBufferInputStream.java | 10 +-
.../binary/streams/BinaryHeapInputStream.java | 14 +-
.../binary/streams/BinaryHeapOutputStream.java | 8 +-
.../binary/streams/BinaryMemoryAllocator.java | 11 +-
.../binary/streams/BinaryOffheapInputStream.java | 4 +-
.../binary/streams/BinaryOffheapOutputStream.java | 2 +-
.../binary/streams/BinaryOutputStream.java | 7 +
.../internal/binary/streams/BinaryStream.java | 2 +-
.../internal/binary/streams/BinaryStreams.java | 108 +
.../internal/cache/query/index/IndexProcessor.java | 2 +-
.../DurableBackgroundCleanupIndexTreeTask.java | 322 ---
.../DurableBackgroundCleanupIndexTreeTaskV2.java | 5 +-
.../cache/query/index/sorted/IndexRowCache.java | 4 +-
.../query/index/sorted/QueryIndexRowHandler.java | 9 +-
.../sorted/inline/JavaObjectKeySerializer.java | 10 +-
.../index/sorted/keys/CacheJavaObjectIndexKey.java | 8 +-
.../query/index/sorted/keys/IndexKeyFactory.java | 4 +-
.../ignite/internal/cdc/CdcConsumerState.java | 92 +-
.../org/apache/ignite/internal/cdc/CdcMain.java | 46 +-
.../internal/cdc/CdcUtilityActiveCdcManager.java | 9 +-
.../internal/client/thin/ClientAtomicLongImpl.java | 6 +-
.../ignite/internal/client/thin/ClientBinary.java | 22 +-
.../client/thin/ClientBinaryMarshaller.java | 10 +-
.../client/thin/ClientCacheAffinityMapping.java | 17 +-
.../thin/ClientCacheEntryListenerHandler.java | 4 +-
.../client/thin/ClientClusterGroupImpl.java | 27 +-
.../internal/client/thin/ClientClusterImpl.java | 6 +-
.../client/thin/ClientClusterNodeImpl.java | 5 +-
.../internal/client/thin/ClientComputeImpl.java | 8 +-
.../client/thin/ClientDiscoveryContext.java | 4 +-
.../internal/client/thin/ClientIgniteSetImpl.java | 20 +-
.../internal/client/thin/ClientServicesImpl.java | 14 +-
.../ignite/internal/client/thin/ClientUtils.java | 116 +-
.../internal/client/thin/PayloadInputChannel.java | 5 +-
.../internal/client/thin/PayloadOutputChannel.java | 7 +-
.../internal/client/thin/TcpClientCache.java | 10 +-
.../internal/client/thin/TcpClientChannel.java | 19 +-
.../client/thin/TcpClientTransactions.java | 6 +-
.../internal/client/thin/TcpIgniteClient.java | 14 +-
.../internal/cluster/ClusterGroupAdapter.java | 60 +-
.../CheckIndexInlineSizesResult.java | 5 +-
.../cache/distribution/CacheDistributionGroup.java | 7 +-
.../cache/distribution/CacheDistributionNode.java | 7 +-
.../distribution/CacheDistributionPartition.java | 6 +-
.../cache/distribution/CacheDistributionTask.java | 6 +-
.../distribution/CacheDistributionTaskResult.java | 7 +-
.../CacheResetLostPartitionsTaskResult.java | 6 +-
.../internal/direct/DirectMessageReader.java | 71 +-
.../internal/direct/DirectMessageWriter.java | 61 +-
.../direct/stream/DirectByteBufferStream.java | 4 -
.../internal/dto/IgniteDataTransferObject.java | 45 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 7 +-
.../JdbcThinPartitionAwarenessMappingGroup.java | 10 +-
.../jdbc/thin/JdbcThinPreparedStatement.java | 2 +-
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 33 +-
.../ignite/internal/jdbc2/JdbcBinaryBuffer.java | 2 +-
.../internal/logger/platform/PlatformLogger.java | 4 +-
.../internal/maintenance/MaintenanceFileStore.java | 11 +-
.../internal/management/ChangeTagCommandArg.java | 2 +-
.../management/ClusterChangeTagTaskResult.java | 2 +-
.../internal/management/DeactivateCommandArg.java | 2 +-
.../internal/management/IgniteCommandRegistry.java | 4 +
.../internal/management/SetStateCommandArg.java | 2 +-
.../management/ShutdownPolicyCommandArg.java | 2 +-
.../management/ShutdownPolicyTaskResult.java | 2 +-
.../ignite/internal/management/StateCommand.java | 4 +-
.../internal/management/SystemViewCommandArg.java | 2 +-
.../internal/management/SystemViewTaskResult.java | 2 +-
.../management/api/CommandRegistryImpl.java | 8 +-
.../internal/management/api/CommandUtils.java | 3 +-
.../api/CommandWarningException.java} | 12 +-
.../internal/management/api}/CommandsProvider.java | 7 +-
.../ignite/internal/management/api/NoArg.java | 2 +-
.../management/baseline/BaselineAddCommandArg.java | 4 +-
.../baseline/BaselineAutoAdjustCommandArg.java | 4 +-
.../baseline/BaselineAutoAdjustSettings.java | 6 +-
.../management/baseline/BaselineCommand.java | 2 +-
.../internal/management/baseline/BaselineNode.java | 24 +-
.../management/baseline/BaselineTaskResult.java | 29 +-
.../baseline/BaselineVersionCommandArg.java | 4 +-
.../cache/CacheAffinityConfiguration.java | 6 +-
.../management/cache/CacheClearCommandArg.java | 2 +-
.../management/cache/CacheConfiguration.java | 20 +-
.../cache/CacheConfigurationCollectorTask.java | 6 +-
.../cache/CacheConfigurationCollectorTaskArg.java | 15 +-
.../cache/CacheContentionCommandArg.java | 2 +-
.../management/cache/CacheCreateCommandArg.java | 2 +-
.../management/cache/CacheDestroyCommandArg.java | 2 +-
.../cache/CacheDistributionCommandArg.java | 2 +-
.../cache/CacheEvictionConfiguration.java | 6 +-
.../cache/CacheFindGarbageCommandArg.java | 2 +-
.../cache/CacheIdleVerifyCommandArg.java | 2 +-
.../cache/CacheIndexesForceRebuildCommandArg.java | 2 +-
.../cache/CacheIndexesListCommandArg.java | 2 +-
.../cache/CacheIndexesRebuildStatusCommandArg.java | 2 +-
.../internal/management/cache/CacheInfo.java | 13 +-
.../internal/management/cache/CacheJdbcType.java | 6 +-
.../management/cache/CacheJdbcTypeField.java | 6 +-
.../management/cache/CacheListCommandArg.java | 2 +-
.../management/cache/CacheMetricsCommandArg.java | 2 +-
.../management/cache/CacheNearConfiguration.java | 6 +-
.../cache/CacheRebalanceConfiguration.java | 6 +-
.../cache/CacheResetLostPartitionsCommandArg.java | 2 +-
.../CacheScheduleIndexesRebuildCommandArg.java | 2 +-
.../management/cache/CacheStoreConfiguration.java | 6 +-
.../cache/CacheValidateIndexesCommandArg.java | 2 +-
.../management/cache/ContentionJobResult.java | 6 +-
.../management/cache/ContentionTaskResult.java | 7 +-
.../FindAndDeleteGarbageInPersistenceClosure.java | 4 +-
...FindAndDeleteGarbageInPersistenceJobResult.java | 2 +-
...indAndDeleteGarbageInPersistenceTaskResult.java | 2 +-
.../management/cache/IdleVerifyDumpResult.java | 7 +-
.../management/cache/IdleVerifyResult.java | 272 +-
.../management/cache/IndexForceRebuildTaskRes.java | 2 +-
.../management/cache/IndexIntegrityCheckIssue.java | 6 +-
.../management/cache/IndexListInfoContainer.java | 2 +-
.../cache/IndexRebuildStatusInfoContainer.java | 4 +-
.../management/cache/IndexValidationIssue.java | 6 +-
.../management/cache/QueryConfiguration.java | 6 +-
.../internal/management/cache/QueryEntity.java | 9 +-
.../internal/management/cache/QueryIndex.java | 6 +-
.../internal/management/cache/QueryIndexField.java | 6 +-
.../cache/ScheduleIndexRebuildJobRes.java | 2 +-
.../cache/ScheduleIndexRebuildTaskRes.java | 2 +-
.../cache/ValidateIndexesCheckSizeIssue.java | 5 +-
.../cache/ValidateIndexesCheckSizeResult.java | 5 +-
.../management/cache/ValidateIndexesClosure.java | 3 +-
.../management/cache/ValidateIndexesJobResult.java | 5 +-
.../cache/ValidateIndexesPartitionResult.java | 11 +-
.../cache/ValidateIndexesTaskResult.java | 6 +-
.../cache/VerifyBackupPartitionsTask.java | 20 +-
.../management/cache/ViewCacheTaskResult.java | 6 +-
.../management/cache/scan/CacheScanCommandArg.java | 2 +-
.../management/cache/scan/CacheScanTaskResult.java | 2 +-
.../management/cdc/CdcCacheDataResendTask.java | 4 +-
.../cdc/CdcDeleteLostSegmentLinksCommandArg.java | 2 +-
.../management/cdc/CdcDeleteLostSegmentsTask.java | 12 +-
.../management/cdc/CdcResendCommandArg.java | 2 +-
.../consistency/ConsistencyRepairCommandArg.java | 2 +-
.../consistency/ConsistencyTaskResult.java | 3 +-
.../defragmentation/DefragmentationCommand.java | 2 +-
.../DefragmentationScheduleCommandArg.java | 4 +-
.../defragmentation/DefragmentationTaskResult.java | 2 +-
.../management/diagnostic/ConnectivityResult.java | 2 +-
.../diagnostic/DiagnosticConnectivityCommand.java | 4 +-
.../DiagnosticConnectivityCommandArg.java | 2 +-
.../diagnostic/DiagnosticPagelocksCommandArg.java | 2 +-
.../management/diagnostic/PageLocksResult.java | 2 +-
.../encryption/CacheGroupEncryptionTaskResult.java | 2 +-
.../encryption/EncryptionCacheGroupArg.java | 2 +-
.../EncryptionChangeMasterKeyCommandArg.java | 2 +-
.../encryption/EncryptionKeyIdsTask.java | 2 +-
.../EncryptionReencryptionRateLimitCommandArg.java | 2 +-
.../EncryptionReencryptionStatusCommandArg.java | 2 +-
.../encryption/ReencryptionRateTask.java | 2 +-
.../encryption/ReencryptionStatusTask.java | 2 +-
.../encryption/ReencryptionSuspendTask.java | 2 +-
.../management/kill/KillClientCommandArg.java | 2 +-
.../management/kill/KillComputeCommandArg.java | 2 +-
.../management/kill/KillContinuousCommandArg.java | 2 +-
.../management/kill/KillScanCommandArg.java | 2 +-
.../management/kill/KillServiceCommandArg.java | 2 +-
.../management/kill/KillSnapshotCommandArg.java | 2 +-
.../management/kill/KillSqlCommandArg.java | 2 +-
.../management/kill/KillTransactionCommandArg.java | 2 +-
.../management/meta/MetaDetailsCommand.java | 6 +-
.../management/meta/MetaDetailsCommandArg.java | 2 +-
.../internal/management/meta/MetaListCommand.java | 2 +-
.../management/meta/MetaRemoveCommand.java | 4 +-
.../management/meta/MetaRemoveCommandArg.java | 4 +-
.../management/meta/MetaUpdateCommandArg.java | 2 +-
.../management/meta/MetadataListResult.java | 5 +-
.../management/meta/MetadataMarshalled.java | 5 +-
.../management/metric/MetricCommandArg.java | 2 +-
.../metric/MetricConfigureHistogramCommandArg.java | 4 +-
.../metric/MetricConfigureHitrateCommandArg.java | 4 +-
.../PerformanceStatisticsCommand.java | 2 +-
.../persistence/PersistenceAbstractCommand.java | 10 +-
.../PersistenceBackupCachesTaskArg.java | 4 +-
.../persistence/PersistenceCleanCachesTaskArg.java | 4 +-
.../management/persistence/PersistenceCommand.java | 2 +-
.../management/persistence/PersistenceTask.java | 42 +-
.../persistence/PersistenceTaskResult.java | 20 +-
.../management/property/PropertiesListResult.java | 5 +-
.../management/property/PropertyGetCommandArg.java | 2 +-
.../property/PropertyListCommandArg.java | 2 +-
.../property/PropertyOperationResult.java | 5 +-
.../management/property/PropertySetCommandArg.java | 4 +-
.../snapshot/SnapshotCancelCommandArg.java | 2 +-
.../snapshot/SnapshotCheckCommandArg.java | 2 +-
.../snapshot/SnapshotCreateCommandArg.java | 2 +-
.../management/snapshot/SnapshotCreateTask.java | 40 +-
.../snapshot/SnapshotRestoreCommandArg.java | 2 +-
.../management/snapshot/SnapshotStatusTask.java | 3 +-
.../tracing/TracingConfigurationCommand.java | 2 +-
.../TracingConfigurationGetAllCommandArg.java | 4 +-
.../tracing/TracingConfigurationGetCommandArg.java | 4 +-
.../tracing/TracingConfigurationItem.java | 3 +-
.../tracing/TracingConfigurationSetCommandArg.java | 4 +-
.../tracing/TracingConfigurationTaskResult.java | 2 +-
.../internal/management/tx/TxCommandArg.java | 2 +-
.../ignite/internal/management/tx/TxInfo.java | 39 +-
.../internal/management/tx/TxInfoCommandArg.java | 2 +-
.../ignite/internal/management/tx/TxTask.java | 3 +-
.../internal/management/tx/TxTaskResult.java | 6 +-
.../internal/management/tx/TxVerboseInfo.java | 5 +-
.../internal/management/tx/TxVerboseKey.java | 5 +-
.../internal/management/wal/ClusterNode.java | 6 +-
.../management/wal/WalDeleteCommandArg.java | 2 +-
.../ignite/internal/management/wal/WalTask.java | 5 +-
.../internal/management/wal/WalTaskResult.java | 6 +-
.../managers/checkpoint/GridCheckpointManager.java | 2 +-
.../managers/checkpoint/GridCheckpointRequest.java | 24 +-
.../managers/communication/GridIoManager.java | 15 +-
.../managers/communication/GridIoMessage.java | 44 +-
.../communication/GridIoMessageFactory.java | 10 +-
.../communication/GridIoSecurityAwareMessage.java | 16 +-
.../managers/communication/GridIoUserMessage.java | 40 +-
.../communication/IgniteIoTestMessage.java | 72 +-
.../communication/SessionChannelMessage.java | 16 +-
.../deployment/GridDeploymentCommunication.java | 2 +-
.../deployment/GridDeploymentInfoBean.java | 32 +-
.../deployment/GridDeploymentLocalStore.java | 4 +-
.../deployment/GridDeploymentPerLoaderStore.java | 4 +-
.../deployment/GridDeploymentPerVersionStore.java | 4 +-
.../managers/deployment/GridDeploymentRequest.java | 32 +-
.../deployment/GridDeploymentResponse.java | 24 +-
.../managers/discovery/GridDiscoveryManager.java | 15 +-
.../encryption/GenerateEncryptionKeyRequest.java | 20 +-
.../encryption/GenerateEncryptionKeyResponse.java | 24 +-
.../managers/encryption/GridEncryptionManager.java | 4 +-
.../eventstorage/GridEventStorageManager.java | 8 +-
.../eventstorage/GridEventStorageMessage.java | 48 +-
.../managers/tracing/GridTracingManager.java | 8 +-
.../ignite/internal/pagemem/PageSupport.java | 7 +
.../pagemem/impl/PageMemoryNoStoreImpl.java | 8 +-
.../affinity/AffinityTopologyVersion.java | 20 +-
.../affinity/GridAffinityAssignmentV2.java | 6 +-
.../processors/affinity/GridAffinityProcessor.java | 3 +-
.../affinity/HistoryAffinityAssignmentImpl.java | 4 +-
.../IgniteAuthenticationProcessor.java | 9 +-
.../internal/processors/authentication/User.java | 2 +-
.../UserAuthenticateRequestMessage.java | 24 +-
.../UserAuthenticateResponseMessage.java | 20 +-
.../authentication/UserManagementOperation.java | 4 +-
.../UserManagementOperationFinishedMessage.java | 20 +-
.../processors/cache/CacheEntryInfoCollection.java | 16 +-
.../cache/CacheEntryPredicateAdapter.java | 12 +-
.../cache/CacheEntryPredicateContainsValue.java | 21 +-
.../cache/CacheEntrySerializablePredicate.java | 16 +-
.../processors/cache/CacheEvictionEntry.java | 24 +-
.../processors/cache/CacheGroupContext.java | 2 +-
.../processors/cache/CacheInvokeDirectResult.java | 24 +-
.../processors/cache/CacheMetricsSnapshot.java | 2 +-
.../processors/cache/CacheObjectAdapter.java | 16 +-
.../processors/cache/CacheObjectByteArrayImpl.java | 16 +-
.../processors/cache/CacheObjectContext.java | 2 +-
.../processors/cache/CacheObjectUtils.java | 5 +-
.../internal/processors/cache/CachesRegistry.java | 5 +-
.../processors/cache/ClearCachesTaskResult.java | 6 +-
.../processors/cache/ClusterCachesInfo.java | 28 +-
.../internal/processors/cache/ExchangeContext.java | 21 +-
.../processors/cache/GridCacheAdapter.java | 26 +-
.../processors/cache/GridCacheAffinityManager.java | 5 +-
.../processors/cache/GridCacheContext.java | 51 +-
.../cache/GridCacheDeploymentManager.java | 3 +-
.../processors/cache/GridCacheEntryInfo.java | 36 +-
.../processors/cache/GridCacheEventManager.java | 7 +-
.../processors/cache/GridCacheGroupIdMessage.java | 16 +-
.../processors/cache/GridCacheIdMessage.java | 16 +-
.../processors/cache/GridCacheMapEntry.java | 19 +-
.../processors/cache/GridCacheMessage.java | 24 +-
.../cache/GridCachePartitionExchangeManager.java | 49 +-
.../processors/cache/GridCacheProcessor.java | 13 +-
.../internal/processors/cache/GridCacheReturn.java | 32 +-
.../processors/cache/GridCacheSharedContext.java | 2 +-
.../internal/processors/cache/GridCacheUtils.java | 20 +-
.../processors/cache/GridCacheValueCollection.java | 5 +-
.../GridChangeGlobalStateMessageResponse.java | 20 +-
.../processors/cache/GridLocalConfigManager.java | 106 +-
.../processors/cache/IgniteCacheProxyImpl.java | 26 +-
.../processors/cache/KeyCacheObjectImpl.java | 16 +-
.../cache/ValidationOnNodeJoinUtils.java | 40 +-
.../processors/cache/WalStateAckMessage.java | 29 +-
.../cache/WalStateDistributedProcess.java | 3 +-
.../internal/processors/cache/WalStateManager.java | 22 +-
.../cache/binary/BinaryMetadataFileStore.java | 17 +-
.../cache/binary/BinaryMetadataTransport.java | 3 +-
.../binary/CacheObjectBinaryProcessorImpl.java | 291 +-
.../cache/binary/MetadataRequestMessage.java | 16 +-
.../cache/binary/MetadataResponseMessage.java | 24 +-
.../distributed/GridCacheTtlUpdateRequest.java | 36 +-
.../distributed/GridCacheTxRecoveryRequest.java | 36 +-
.../distributed/GridCacheTxRecoveryResponse.java | 24 +-
.../distributed/GridDistributedBaseMessage.java | 23 +-
.../distributed/GridDistributedLockRequest.java | 64 +-
.../distributed/GridDistributedLockResponse.java | 24 +-
.../GridDistributedTxFinishRequest.java | 64 +-
.../GridDistributedTxFinishResponse.java | 28 +-
.../GridDistributedTxPrepareRequest.java | 64 +-
.../GridDistributedTxPrepareResponse.java | 24 +-
.../distributed/GridDistributedUnlockRequest.java | 16 +-
.../dht/GridDhtAffinityAssignmentRequest.java | 24 +-
.../dht/GridDhtAffinityAssignmentResponse.java | 36 +-
.../cache/distributed/dht/GridDhtLockFuture.java | 3 +-
.../cache/distributed/dht/GridDhtLockRequest.java | 48 +-
.../cache/distributed/dht/GridDhtLockResponse.java | 24 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 6 +-
.../distributed/dht/GridDhtTxFinishRequest.java | 24 +-
.../distributed/dht/GridDhtTxFinishResponse.java | 24 +-
.../cache/distributed/dht/GridDhtTxLocal.java | 4 +-
.../dht/GridDhtTxOnePhaseCommitAckRequest.java | 16 +-
.../distributed/dht/GridDhtTxPrepareRequest.java | 68 +-
.../distributed/dht/GridDhtTxPrepareResponse.java | 32 +-
.../distributed/dht/GridDhtUnlockRequest.java | 16 +-
.../dht/PartitionUpdateCountersMessage.java | 20 +-
.../dht/TransactionAttributesAwareRequest.java | 18 +-
.../AtomicApplicationAttributesAwareRequest.java | 18 +-
.../atomic/GridDhtAtomicAbstractUpdateFuture.java | 3 +-
.../atomic/GridDhtAtomicAbstractUpdateRequest.java | 44 +-
.../distributed/dht/atomic/GridDhtAtomicCache.java | 17 +-
.../GridDhtAtomicDeferredUpdateResponse.java | 16 +-
.../dht/atomic/GridDhtAtomicNearResponse.java | 32 +-
.../atomic/GridDhtAtomicSingleUpdateRequest.java | 32 +-
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 76 +-
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 28 +-
.../GridNearAtomicAbstractUpdateRequest.java | 36 +-
.../atomic/GridNearAtomicCheckUpdateRequest.java | 20 +-
.../atomic/GridNearAtomicFullUpdateRequest.java | 48 +-
.../GridNearAtomicSingleUpdateFilterRequest.java | 16 +-
.../GridNearAtomicSingleUpdateInvokeRequest.java | 20 +-
.../atomic/GridNearAtomicSingleUpdateRequest.java | 20 +-
.../dht/atomic/GridNearAtomicUpdateResponse.java | 40 +-
.../distributed/dht/atomic/NearCacheUpdates.java | 36 +-
.../cache/distributed/dht/atomic/UpdateErrors.java | 20 +-
.../dht/preloader/CacheGroupAffinityMessage.java | 24 +-
.../dht/preloader/GridDhtForceKeysFuture.java | 3 +-
.../dht/preloader/GridDhtForceKeysRequest.java | 28 +-
.../dht/preloader/GridDhtForceKeysResponse.java | 32 +-
.../preloader/GridDhtPartitionDemandMessage.java | 36 +-
.../dht/preloader/GridDhtPartitionExchangeId.java | 24 +-
.../GridDhtPartitionSupplyErrorMessage.java | 16 +-
.../preloader/GridDhtPartitionSupplyMessage.java | 48 +-
.../GridDhtPartitionsAbstractMessage.java | 24 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 9 +-
.../preloader/GridDhtPartitionsFullMessage.java | 64 +-
.../preloader/GridDhtPartitionsSingleMessage.java | 52 +-
.../preloader/GridDhtPartitionsSingleRequest.java | 16 +-
.../dht/preloader/InitNewCoordinatorFuture.java | 6 +-
.../dht/preloader/latch/LatchAckMessage.java | 24 +-
.../dht/topology/GridClientPartitionTopology.java | 15 +-
.../dht/topology/GridDhtLocalPartition.java | 6 +-
.../dht/topology/GridDhtPartitionTopology.java | 11 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 56 +-
.../dht/topology/PartitionReservationKey.java | 4 +-
.../dht/topology/PartitionReservationManager.java | 5 +-
.../dht/topology/PartitionsEvictManager.java | 2 +-
.../distributed/near/CacheVersionedValue.java | 20 +-
.../cache/distributed/near/GridNearCacheEntry.java | 5 +-
.../cache/distributed/near/GridNearGetRequest.java | 56 +-
.../distributed/near/GridNearGetResponse.java | 40 +-
.../distributed/near/GridNearLockRequest.java | 44 +-
.../distributed/near/GridNearLockResponse.java | 40 +-
.../distributed/near/GridNearSingleGetRequest.java | 44 +-
.../near/GridNearSingleGetResponse.java | 32 +-
.../distributed/near/GridNearTxFinishRequest.java | 16 +-
.../distributed/near/GridNearTxFinishResponse.java | 24 +-
.../cache/distributed/near/GridNearTxLocal.java | 19 +-
.../distributed/near/GridNearTxPrepareRequest.java | 36 +-
.../near/GridNearTxPrepareResponse.java | 52 +-
.../distributed/near/GridNearUnlockRequest.java | 12 +-
.../cache/persistence/CacheDataRowAdapter.java | 3 +-
.../CheckCorruptedCacheStoresCleanAction.java | 12 +-
.../CleanCacheStoresMaintenanceAction.java | 13 +-
.../CorruptedPdsMaintenanceCallback.java | 49 +-
.../GridCacheDatabaseSharedManager.java | 29 +-
.../cache/persistence/GridCacheOffheapManager.java | 25 +-
.../persistence/checkpoint/CheckpointStatus.java | 4 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 5 +-
.../checkpoint/EarliestCheckpointMapSnapshot.java | 4 +-
.../CachePartitionDefragmentationManager.java | 74 +-
.../defragmentation/DefragmentationFileUtils.java | 267 +-
.../persistence/file/FilePageStoreManager.java | 323 +--
.../cache/persistence/filename/CacheFileTree.java | 269 ++
.../cache/persistence/filename/FileTreeUtils.java | 129 +
.../cache/persistence/filename/NodeFileTree.java | 678 ++++-
.../filename/PdsConsistentIdProcessor.java | 9 +-
.../persistence/filename/PdsFolderResolver.java | 6 +-
.../persistence/filename/PdsFolderSettings.java | 8 -
.../cache/persistence/filename/SharedFileTree.java | 25 +-
.../persistence/filename/SnapshotFileTree.java | 285 +-
.../cache/persistence/freelist/PagesList.java | 5 +-
.../cache/persistence/metastorage/MetaStorage.java | 3 -
.../cache/persistence/pagemem/PageMemoryImpl.java | 5 +
.../snapshot/AbstractCreateSnapshotFutureTask.java | 11 +-
.../snapshot/AbstractSnapshotMessage.java | 11 +-
.../snapshot/AbstractSnapshotVerificationTask.java | 38 +-
.../snapshot/IgniteSnapshotManager.java | 747 ++---
.../snapshot/IncrementalSnapshotAwareMessage.java | 28 +-
.../snapshot/IncrementalSnapshotFutureTask.java | 58 +-
.../snapshot/IncrementalSnapshotProcessor.java | 58 +-
.../IncrementalSnapshotVerificationTask.java | 94 +-
.../IncrementalSnapshotVerificationTaskResult.java | 2 +-
.../snapshot/SnapshotFilesFailureMessage.java | 16 +-
.../snapshot/SnapshotFilesRequestMessage.java | 28 +-
.../persistence/snapshot/SnapshotFutureTask.java | 131 +-
.../snapshot/SnapshotHandlerContext.java | 16 +-
.../snapshot/SnapshotHandlerRestoreTask.java | 21 +-
.../snapshot/SnapshotMetadataVerificationTask.java | 41 +-
.../SnapshotMetadataVerificationTaskArg.java | 15 +-
.../SnapshotMetadataVerificationTaskResult.java | 2 +-
.../snapshot/SnapshotOperationRequest.java | 19 +
.../snapshot/SnapshotPartitionsVerifyHandler.java | 170 +-
.../snapshot/SnapshotPartitionsVerifyTask.java | 23 +-
.../snapshot/SnapshotPartitionsVerifyTaskArg.java | 6 +-
.../SnapshotPartitionsVerifyTaskResult.java | 2 +-
.../snapshot/SnapshotResponseRemoteFutureTask.java | 127 +-
.../snapshot/SnapshotRestoreProcess.java | 250 +-
.../cache/persistence/snapshot/SnapshotSender.java | 43 +-
.../snapshot/SnapshotWarningException.java | 2 +-
.../snapshot/dump/CreateDumpFutureTask.java | 60 +-
.../cache/persistence/snapshot/dump/Dump.java | 197 +-
.../snapshot/dump/DumpEntrySerializer.java | 5 +-
.../persistence/wal/FileWriteAheadLogManager.java | 45 +-
.../wal/reader/IgniteWalIteratorFactory.java | 46 +-
.../wal/reader/StandaloneGridKernalContext.java | 60 +-
.../wal/serializer/RecordV1Serializer.java | 4 +-
.../wal/serializer/RecordV2Serializer.java | 4 +-
.../query/GridCacheDistributedQueryManager.java | 3 +-
.../query/GridCacheQueryDetailMetricsKey.java | 4 +-
.../cache/query/GridCacheQueryManager.java | 5 +-
.../cache/query/GridCacheQueryMarshallable.java | 7 +-
.../cache/query/GridCacheQueryMetricsKey.java | 4 +-
.../cache/query/GridCacheQueryRequest.java | 104 +-
.../cache/query/GridCacheQueryResponse.java | 40 +-
.../processors/cache/query/GridCacheSqlQuery.java | 28 +-
.../continuous/CacheContinuousQueryBatchAck.java | 20 +-
.../continuous/CacheContinuousQueryEntry.java | 52 +-
.../continuous/CacheContinuousQueryManager.java | 3 +-
.../cache/store/CacheOsStoreManager.java | 3 +-
.../cache/store/GridCacheWriteBehindStore.java | 12 +-
.../cache/transactions/IgniteTxEntry.java | 64 +-
.../processors/cache/transactions/IgniteTxKey.java | 20 +-
.../cache/transactions/IgniteTxManager.java | 6 +-
.../cache/transactions/TxEntryValueHolder.java | 24 +-
.../processors/cache/transactions/TxLock.java | 28 +-
.../processors/cache/transactions/TxLockList.java | 16 +-
.../cache/transactions/TxLocksRequest.java | 20 +-
.../cache/transactions/TxLocksResponse.java | 28 +-
.../cache/verify/PartitionHashRecord.java | 19 +-
.../cache/verify/TransactionsHashRecord.java | 2 +-
.../cache/version/GridCacheRawVersionedEntry.java | 34 +-
.../processors/cache/version/GridCacheVersion.java | 24 +-
.../cache/version/GridCacheVersionEx.java | 16 +-
.../cacheobject/IgniteCacheObjectProcessor.java | 21 +-
.../processors/closure/GridClosureProcessor.java | 2 +-
.../cluster/ClusterMetricsUpdateMessage.java | 20 +-
.../processors/cluster/ClusterProcessor.java | 48 +-
.../cluster/GridClusterStateProcessor.java | 5 +-
.../processors/compress/CompressionHandler.java | 2 +-
.../ContinuousRoutineStartResultMessage.java | 28 +-
.../continuous/GridContinuousMessage.java | 32 +-
.../continuous/GridContinuousProcessor.java | 7 +-
.../datastreamer/DataStreamProcessor.java | 2 +-
.../processors/datastreamer/DataStreamerEntry.java | 20 +-
.../processors/datastreamer/DataStreamerImpl.java | 4 +-
.../datastreamer/DataStreamerRequest.java | 76 +-
.../datastreamer/DataStreamerResponse.java | 24 +-
.../GridCacheAtomicReferenceImpl.java | 10 +-
.../datastructures/GridCacheAtomicStampedImpl.java | 6 +-
.../datastructures/GridCacheInternalKeyImpl.java | 3 +-
.../dr/IgniteDrDataStreamerCacheUpdater.java | 2 +-
.../internal/processors/job/GridJobProcessor.java | 2 +-
.../internal/processors/job/GridJobWorker.java | 2 +-
.../marshaller/MissingMappingRequestMessage.java | 20 +-
.../marshaller/MissingMappingResponseMessage.java | 24 +-
.../DistributedMetaStorageHistoryItem.java | 2 +-
.../persistence/DistributedMetaStorageVersion.java | 2 +-
.../processors/metric/MetricRegistryImpl.java | 107 +-
.../OsDiscoveryNodeValidationProcessor.java | 4 +-
.../odbc/ClientListenerConnectionContext.java | 4 +-
.../processors/odbc/ClientListenerNioListener.java | 46 +-
.../odbc/ClientListenerProtocolVersion.java | 5 +-
.../odbc/ClientListenerRequestHandler.java | 4 +-
.../internal/processors/odbc/ClientMessage.java | 11 +-
.../internal/processors/odbc/SqlListenerUtils.java | 24 +-
.../odbc/jdbc/JdbcBatchExecuteRequest.java | 8 +-
.../odbc/jdbc/JdbcBatchExecuteResult.java | 8 +-
.../odbc/jdbc/JdbcBinaryTypeGetRequest.java | 8 +-
.../odbc/jdbc/JdbcBinaryTypeGetResult.java | 8 +-
.../odbc/jdbc/JdbcBinaryTypeNameGetRequest.java | 8 +-
.../odbc/jdbc/JdbcBinaryTypeNameGetResult.java | 8 +-
.../odbc/jdbc/JdbcBinaryTypeNamePutRequest.java | 8 +-
.../odbc/jdbc/JdbcBinaryTypePutRequest.java | 8 +-
.../odbc/jdbc/JdbcBulkLoadAckResult.java | 8 +-
.../odbc/jdbc/JdbcBulkLoadBatchRequest.java | 8 +-
.../odbc/jdbc/JdbcCachePartitionsRequest.java | 8 +-
.../odbc/jdbc/JdbcCachePartitionsResult.java | 8 +-
.../odbc/jdbc/JdbcClientInfoAwareRequest.java | 8 +-
.../processors/odbc/jdbc/JdbcColumnMeta.java | 13 +-
.../processors/odbc/jdbc/JdbcColumnMetaV2.java | 8 +-
.../processors/odbc/jdbc/JdbcColumnMetaV3.java | 8 +-
.../processors/odbc/jdbc/JdbcColumnMetaV4.java | 8 +-
.../odbc/jdbc/JdbcConnectionContext.java | 4 +-
.../processors/odbc/jdbc/JdbcIndexMeta.java | 13 +-
.../processors/odbc/jdbc/JdbcMessageParser.java | 24 +-
.../odbc/jdbc/JdbcMetaColumnsRequest.java | 8 +-
.../odbc/jdbc/JdbcMetaColumnsResult.java | 8 +-
.../odbc/jdbc/JdbcMetaIndexesRequest.java | 8 +-
.../odbc/jdbc/JdbcMetaIndexesResult.java | 8 +-
.../odbc/jdbc/JdbcMetaParamsRequest.java | 8 +-
.../processors/odbc/jdbc/JdbcMetaParamsResult.java | 8 +-
.../odbc/jdbc/JdbcMetaPrimaryKeysRequest.java | 8 +-
.../odbc/jdbc/JdbcMetaPrimaryKeysResult.java | 8 +-
.../odbc/jdbc/JdbcMetaSchemasRequest.java | 8 +-
.../odbc/jdbc/JdbcMetaSchemasResult.java | 8 +-
.../odbc/jdbc/JdbcMetaTablesRequest.java | 8 +-
.../processors/odbc/jdbc/JdbcMetaTablesResult.java | 8 +-
.../odbc/jdbc/JdbcOrderedBatchExecuteRequest.java | 8 +-
.../odbc/jdbc/JdbcOrderedBatchExecuteResult.java | 8 +-
.../processors/odbc/jdbc/JdbcParameterMeta.java | 8 +-
.../processors/odbc/jdbc/JdbcPrimaryKeyMeta.java | 12 +-
.../internal/processors/odbc/jdbc/JdbcQuery.java | 8 +-
.../odbc/jdbc/JdbcQueryCancelRequest.java | 8 +-
.../odbc/jdbc/JdbcQueryCloseRequest.java | 8 +-
.../JdbcQueryExecuteMultipleStatementsResult.java | 8 +-
.../odbc/jdbc/JdbcQueryExecuteRequest.java | 8 +-
.../odbc/jdbc/JdbcQueryExecuteResult.java | 8 +-
.../odbc/jdbc/JdbcQueryFetchRequest.java | 8 +-
.../processors/odbc/jdbc/JdbcQueryFetchResult.java | 8 +-
.../odbc/jdbc/JdbcQueryMetadataRequest.java | 8 +-
.../odbc/jdbc/JdbcQueryMetadataResult.java | 8 +-
.../processors/odbc/jdbc/JdbcRawBinarylizable.java | 8 +-
.../internal/processors/odbc/jdbc/JdbcRequest.java | 14 +-
.../processors/odbc/jdbc/JdbcRequestHandler.java | 4 +-
.../processors/odbc/jdbc/JdbcResponse.java | 8 +-
.../internal/processors/odbc/jdbc/JdbcResult.java | 10 +-
.../processors/odbc/jdbc/JdbcResultInfo.java | 8 +-
.../odbc/jdbc/JdbcSetTxParametersRequest.java | 8 +-
.../processors/odbc/jdbc/JdbcTableMeta.java | 11 +-
.../processors/odbc/jdbc/JdbcTxEndRequest.java | 8 +-
.../processors/odbc/jdbc/JdbcTxEndResult.java | 8 +-
.../odbc/jdbc/JdbcUpdateBinarySchemaResult.java | 8 +-
.../internal/processors/odbc/jdbc/JdbcUtils.java | 22 +-
.../odbc/odbc/OdbcConnectionContext.java | 4 +-
.../processors/odbc/odbc/OdbcMessageParser.java | 25 +-
.../internal/processors/odbc/odbc/OdbcQuery.java | 8 +-
.../processors/odbc/odbc/OdbcRequestHandler.java | 4 +-
.../processors/odbc/odbc/OdbcTableMeta.java | 4 +-
.../processors/offheap/GridOffHeapProcessor.java | 2 +-
.../FilePerformanceStatisticsReader.java | 463 ++-
.../FilePerformanceStatisticsWriter.java | 55 +-
.../performancestatistics/OperationType.java | 50 +-
.../PerformanceStatisticsHandler.java | 9 +
.../PerformanceStatisticsProcessor.java | 10 +
.../performancestatistics/StringCache.java | 47 +
.../SystemViewFileWriter.java | 264 ++
.../platform/PlatformAbstractTarget.java | 18 +-
.../processors/platform/PlatformAsyncResult.java | 4 +-
.../processors/platform/PlatformContext.java | 28 +-
.../processors/platform/PlatformContextImpl.java | 43 +-
.../platform/PlatformExtendedException.java | 4 +-
.../platform/PlatformJavaObjectFactoryProxy.java | 8 +-
.../processors/platform/PlatformProcessorImpl.java | 26 +-
.../processors/platform/PlatformTarget.java | 20 +-
.../platform/PlatformTargetProxyImpl.java | 22 +-
.../platform/binary/PlatformBinaryProcessor.java | 12 +-
.../processors/platform/cache/PlatformCache.java | 50 +-
.../cache/PlatformCacheEntryFilterImpl.java | 6 +-
.../cache/PlatformCacheEntryProcessorImpl.java | 10 +-
.../platform/cache/PlatformCacheExtension.java | 4 +-
.../platform/cache/PlatformCacheIterator.java | 4 +-
.../cache/PlatformCachePartialUpdateException.java | 4 +-
.../platform/cache/affinity/PlatformAffinity.java | 19 +-
.../cache/affinity/PlatformAffinityFunction.java | 10 +-
.../affinity/PlatformAffinityFunctionTarget.java | 8 +-
.../cache/affinity/PlatformAffinityManager.java | 4 +-
.../cache/affinity/PlatformAffinityUtils.java | 6 +-
.../cache/query/PlatformAbstractQueryCursor.java | 10 +-
.../cache/query/PlatformContinuousQueryImpl.java | 7 +-
.../query/PlatformContinuousQueryRemoteFilter.java | 4 +-
.../cache/query/PlatformFieldsQueryCursor.java | 6 +-
.../platform/cache/query/PlatformQueryCursor.java | 4 +-
.../platform/client/ClientBooleanResponse.java | 4 +-
.../platform/client/ClientByteResponse.java | 4 +-
.../platform/client/ClientConnectionContext.java | 4 +-
.../platform/client/ClientIntResponse.java | 4 +-
.../platform/client/ClientLongResponse.java | 4 +-
.../platform/client/ClientMessageParser.java | 23 +-
.../platform/client/ClientNotification.java | 4 +-
.../platform/client/ClientObjectNotification.java | 4 +-
.../platform/client/ClientObjectResponse.java | 4 +-
.../platform/client/ClientOutgoingMessage.java | 4 +-
.../platform/client/ClientRequestHandler.java | 4 +-
.../processors/platform/client/ClientResponse.java | 6 +-
.../platform/client/ClientStringResponse.java | 4 +-
.../ClientBinaryConfigurationGetResponse.java | 4 +-
.../client/binary/ClientBinaryTypeGetResponse.java | 4 +-
.../client/binary/ClientBinaryTypePutRequest.java | 4 +-
.../client/cache/ClientCacheClearKeyRequest.java | 4 +-
.../client/cache/ClientCacheClearKeysRequest.java | 4 +-
.../cache/ClientCacheConfigurationSerializer.java | 6 +-
.../cache/ClientCacheContainsKeyRequest.java | 4 +-
.../cache/ClientCacheContainsKeysRequest.java | 4 +-
.../cache/ClientCacheEntryEventNotification.java | 4 +-
.../client/cache/ClientCacheEntryQueryCursor.java | 4 +-
.../client/cache/ClientCacheFieldsQueryCursor.java | 4 +-
.../client/cache/ClientCacheGetAllRequest.java | 4 +-
.../client/cache/ClientCacheGetAllResponse.java | 4 +-
.../cache/ClientCacheGetAndPutIfAbsentRequest.java | 4 +-
.../client/cache/ClientCacheGetAndPutRequest.java | 4 +-
.../cache/ClientCacheGetAndRemoveRequest.java | 4 +-
.../cache/ClientCacheGetAndReplaceRequest.java | 4 +-
.../cache/ClientCacheGetConfigurationResponse.java | 4 +-
.../client/cache/ClientCacheGetNamesResponse.java | 4 +-
.../client/cache/ClientCacheGetRequest.java | 4 +-
.../client/cache/ClientCacheIndexQueryRequest.java | 10 +-
.../client/cache/ClientCacheInvokeAllRequest.java | 4 +-
.../client/cache/ClientCacheInvokeAllResponse.java | 4 +-
.../client/cache/ClientCacheInvokeRequest.java | 12 +-
.../client/cache/ClientCacheKeyRequest.java | 4 +-
.../client/cache/ClientCacheKeyValueRequest.java | 4 +-
.../client/cache/ClientCacheKeysRequest.java | 6 +-
.../client/cache/ClientCacheLocalPeekRequest.java | 4 +-
.../cache/ClientCacheNodePartitionsResponse.java | 4 +-
.../cache/ClientCachePartitionsResponse.java | 4 +-
.../cache/ClientCachePutAllConflictRequest.java | 4 +-
.../client/cache/ClientCachePutAllRequest.java | 4 +-
.../cache/ClientCachePutIfAbsentRequest.java | 4 +-
.../client/cache/ClientCachePutRequest.java | 4 +-
.../cache/ClientCacheQueryContinuousRequest.java | 8 +-
.../cache/ClientCacheQueryContinuousResponse.java | 4 +-
.../client/cache/ClientCacheQueryCursor.java | 6 +-
.../cache/ClientCacheQueryNextPageResponse.java | 4 +-
.../client/cache/ClientCacheQueryResponse.java | 4 +-
.../cache/ClientCacheRemoveAllConflictRequest.java | 4 +-
.../cache/ClientCacheRemoveIfEqualsRequest.java | 4 +-
.../client/cache/ClientCacheRemoveKeyRequest.java | 4 +-
.../client/cache/ClientCacheRemoveKeysRequest.java | 4 +-
.../cache/ClientCacheReplaceIfEqualsRequest.java | 4 +-
.../client/cache/ClientCacheReplaceRequest.java | 4 +-
.../client/cache/ClientCacheScanQueryRequest.java | 4 +-
.../cache/ClientCacheSqlFieldsQueryRequest.java | 4 +-
.../cache/ClientCacheSqlFieldsQueryResponse.java | 4 +-
.../client/cache/ClientCacheSqlQueryRequest.java | 4 +-
.../ClientClusterGroupGetNodeIdsResponse.java | 4 +-
.../ClientClusterGroupGetNodesDetailsResponse.java | 4 +-
...lientClusterGroupGetNodesEndpointsResponse.java | 8 +-
.../platform/client/compute/ClientComputeTask.java | 4 +-
.../client/compute/ClientExecuteTaskRequest.java | 4 +-
.../client/compute/ClientExecuteTaskResponse.java | 4 +-
.../ClientIgniteSetGetOrCreateRequest.java | 4 +-
.../ClientIgniteSetIteratorGetPageRequest.java | 4 +-
.../ClientIgniteSetIteratorStartRequest.java | 6 +-
.../datastructures/ClientIgniteSetKeyRequest.java | 4 +-
.../datastructures/ClientIgniteSetKeysRequest.java | 4 +-
.../ClientIgniteSetValueAddAllRequest.java | 4 +-
.../ClientIgniteSetValueAddRequest.java | 4 +-
.../ClientIgniteSetValueContainsAllRequest.java | 4 +-
.../ClientIgniteSetValueContainsRequest.java | 4 +-
.../ClientIgniteSetValueRemoveAllRequest.java | 4 +-
.../ClientIgniteSetValueRemoveRequest.java | 4 +-
.../ClientIgniteSetValueRetainAllRequest.java | 4 +-
.../service/ClientServiceDescriptorResponse.java | 4 +-
.../service/ClientServiceDescriptorsResponse.java | 6 +-
.../client/service/ClientServiceInvokeRequest.java | 11 +-
.../service/ClientServiceMappingsResponse.java | 4 +-
.../streamer/ClientDataStreamerAddDataRequest.java | 4 +-
.../client/streamer/ClientDataStreamerReader.java | 4 +-
.../streamer/ClientDataStreamerStartRequest.java | 4 +-
.../platform/cluster/PlatformClusterGroup.java | 14 +-
.../cluster/PlatformClusterNodeFilterImpl.java | 4 +-
.../platform/compute/PlatformAbstractJob.java | 4 +-
.../platform/compute/PlatformAbstractTask.java | 6 +-
.../platform/compute/PlatformClosureJob.java | 4 +-
.../platform/compute/PlatformCompute.java | 21 +-
.../compute/PlatformComputeTaskSession.java | 8 +-
.../platform/compute/PlatformFullJob.java | 6 +-
.../platform/compute/PlatformFullTask.java | 12 +-
.../cpp/PlatformCppConfigurationClosure.java | 14 -
.../datastreamer/PlatformDataStreamer.java | 4 +-
.../datastreamer/PlatformStreamReceiverImpl.java | 4 +-
.../datastructures/PlatformAtomicLong.java | 4 +-
.../datastructures/PlatformAtomicReference.java | 12 +-
.../platform/dotnet/PlatformDotNetCacheStore.java | 58 +-
.../dotnet/PlatformDotNetConfigurationClosure.java | 38 +-
...latformDotNetEntityFrameworkCacheExtension.java | 4 +-
.../events/PlatformEventFilterListenerImpl.java | 6 +-
.../processors/platform/events/PlatformEvents.java | 31 +-
.../events/PlatformLocalEventListener.java | 4 +-
.../messaging/PlatformMessageFilterImpl.java | 6 +-
.../messaging/PlatformMessageLocalFilter.java | 4 +-
.../platform/messaging/PlatformMessaging.java | 12 +-
.../platform/services/PlatformAbstractService.java | 18 +-
.../platform/services/PlatformServices.java | 48 +-
.../transactions/PlatformTransactions.java | 14 +-
.../platform/utils/PlatformConfigurationUtils.java | 20 +-
.../platform/utils/PlatformFutureUtils.java | 10 +-
.../platform/utils/PlatformReaderBiClosure.java | 4 +-
.../platform/utils/PlatformReaderClosure.java | 4 +-
.../processors/platform/utils/PlatformUtils.java | 146 +-
.../platform/utils/PlatformWriterBiClosure.java | 4 +-
.../platform/utils/PlatformWriterClosure.java | 4 +-
.../PlatformDotNetSessionCacheExtension.java | 20 +-
.../internal/processors/pool/PoolProcessor.java | 117 +
.../query/CacheQueryObjectValueContext.java | 3 +-
.../processors/query/ColumnInformation.java | 5 +-
.../processors/query/GridQueryProcessor.java | 67 +-
.../internal/processors/query/QueryEntityEx.java | 8 +-
.../internal/processors/query/QueryIndexKey.java | 4 +-
.../internal/processors/query/QuerySchema.java | 12 +-
.../processors/query/QueryTypeDescriptorImpl.java | 14 +-
.../internal/processors/query/QueryUtils.java | 28 +-
.../query/aware/IndexRebuildCacheInfo.java | 12 +-
.../twostep/messages/GridQueryCancelRequest.java | 16 +-
.../h2/twostep/messages/GridQueryFailResponse.java | 24 +-
.../twostep/messages/GridQueryNextPageRequest.java | 32 +-
.../messages/GridQueryNextPageResponse.java | 52 +-
.../query/messages/GridQueryKillRequest.java | 24 +-
.../query/messages/GridQueryKillResponse.java | 20 +-
.../query/property/QueryBinaryProperty.java | 6 +-
.../processors/query/running/QueryHistoryKey.java | 4 +-
.../query/running/RunningQueryManager.java | 10 +-
.../internal/processors/query/running/SqlPlan.java | 5 +-
.../query/running/SqlPlanHistoryTracker.java | 2 +-
.../query/schema/SchemaOperationManager.java | 4 +-
.../management/AbstractIndexDescriptorFactory.java | 7 +-
.../query/schema/management/SchemaManager.java | 24 +-
.../management/SortedIndexDescriptorFactory.java | 2 +-
.../query/schema/management/TableDescriptor.java | 3 +-
.../message/SchemaOperationStatusMessage.java | 24 +-
.../query/stat/ColumnStatisticsCollector.java | 7 +-
.../stat/IgniteStatisticsPersistenceStoreImpl.java | 3 +
.../query/stat/messages/StatisticsColumnData.java | 48 +-
.../stat/messages/StatisticsDecimalMessage.java | 20 +-
.../query/stat/messages/StatisticsKeyMessage.java | 24 +-
.../query/stat/messages/StatisticsObjectData.java | 36 +-
.../query/stat/messages/StatisticsRequest.java | 32 +-
.../query/stat/messages/StatisticsResponse.java | 20 +-
.../handlers/cache/GridCacheCommandHandler.java | 5 +-
.../rest/handlers/task/GridTaskCommandHandler.java | 3 +-
.../rest/handlers/task/GridTaskResultRequest.java | 20 +-
.../rest/handlers/task/GridTaskResultResponse.java | 28 +-
.../rest/protocols/tcp/GridTcpRestParser.java | 7 +-
.../processors/security/IgniteSecurityAdapter.java | 4 +-
.../security/IgniteSecurityProcessor.java | 3 +-
.../processors/service/GridServiceProxy.java | 11 +-
.../processors/service/IgniteServiceProcessor.java | 2 +-
.../service/ServiceDeploymentProcessId.java | 23 +-
.../processors/service/ServiceDeploymentTask.java | 3 +-
.../service/ServiceSingleNodeDeploymentResult.java | 20 +-
.../ServiceSingleNodeDeploymentResultBatch.java | 20 +-
.../processors/task/GridTaskProcessor.java | 8 +-
.../internal/processors/task/GridTaskWorker.java | 5 +-
.../org/apache/ignite/internal/sql/SqlKeyword.java | 4 +-
.../apache/ignite/internal/sql/SqlParserUtils.java | 3 +-
.../optimizer/affinity/PartitionCompositeNode.java | 8 +-
.../optimizer/affinity/PartitionJoinCondition.java | 6 +-
.../affinity/PartitionResultMarshaler.java | 28 +-
.../optimizer/affinity/PartitionSingleNode.java | 6 +-
.../sql/optimizer/affinity/PartitionTable.java | 4 +-
.../affinity/PartitionTableAffinityDescriptor.java | 4 +-
.../java/org/apache/ignite/internal/util/F0.java | 14 +-
.../ignite/internal/util/GridByteArrayList.java | 20 +-
.../ignite/internal/util/GridClientByteUtils.java | 238 --
.../apache/ignite/internal/util/GridIntList.java | 20 +-
.../apache/ignite/internal/util/GridLongList.java | 20 +-
.../internal/util/GridMessageCollection.java | 16 +-
.../apache/ignite/internal/util/GridUnsafe.java | 19 +
.../ignite/internal/util/HostAndPortRange.java | 3 +-
.../apache/ignite/internal/util/IgniteUtils.java | 2951 ++------------------
.../ignite/internal/util/OffheapReadWriteLock.java | 14 +
.../internal/util/UUIDCollectionMessage.java | 16 +-
.../util/distributed/DistributedProcess.java | 11 +-
.../util/distributed/SingleNodeMessage.java | 28 +-
.../ignite/internal/util/io/GridFileUtils.java | 4 +-
.../internal/util/io/GridUnsafeDataInput.java | 2 +-
.../internal/util/io/GridUnsafeDataOutput.java | 17 +-
.../ignite/internal/util/lang/ClusterNodeFunc.java | 183 ++
.../ignite/internal/util/lang/GridMapEntry.java | 4 +-
.../lang/gridfunc/ClusterNodeGetIdClosure.java | 41 -
.../internal/util/lang/gridfunc/package-info.java | 2 +-
.../ignite/internal/util/nio/GridDirectParser.java | 6 +-
.../ignite/internal/util/nio/GridNioServer.java | 19 +-
.../ignite/internal/util/nio/GridNioWorker.java | 5 -
.../tostring/UnsafeToStringFieldDescriptor.java | 83 +
.../internal/visor/VisorDataTransferObject.java | 136 -
.../visor/VisorDataTransferObjectInput.java | 158 --
.../visor/VisorDataTransferObjectOutput.java | 143 -
.../ignite/internal/visor/VisorOneNodeTask.java | 11 +
.../ignite/internal/visor/VisorTaskArgument.java | 5 +-
.../ignite/internal/visor/VisorTaskResult.java | 2 +-
.../compute/VisorComputeCancelSessionsTaskArg.java | 6 +-
.../visor/misc/VisorIdAndTagViewTaskResult.java | 2 +-
.../plugin/extensions/communication/Message.java | 7 -
.../extensions/communication/MessageReader.java | 106 +-
.../extensions/communication/MessageWriter.java | 91 +-
.../security/SecurityBasicPermissionSet.java | 10 +-
.../plugin/security/SecurityCredentials.java | 4 +-
.../spi/checkpoint/cache/CacheCheckpointSpi.java | 3 +-
.../checkpoint/sharedfs/SharedFsCheckpointSpi.java | 6 +-
.../collision/jobstealing/JobStealingRequest.java | 16 +-
.../spi/communication/tcp/TcpCommunicationSpi.java | 88 -
.../tcp/internal/GridNioServerWrapper.java | 9 +-
.../TcpInverseConnectionResponseMessage.java | 16 +-
.../tcp/messages/HandshakeMessage.java | 20 +-
.../tcp/messages/HandshakeMessage2.java | 105 -
.../tcp/messages/HandshakeWaitMessage.java | 5 -
.../communication/tcp/messages/NodeIdMessage.java | 20 -
.../tcp/messages/RecoveryLastReceivedMessage.java | 5 -
.../ignite/spi/discovery/tcp/ServerImpl.java | 16 +-
.../tcp/internal/DiscoveryDataPacket.java | 15 -
.../discovery/tcp/internal/TcpDiscoveryNode.java | 3 +-
.../tcp/internal/TcpDiscoveryNodesRing.java | 5 +-
.../TcpDiscoveryClientReconnectMessage.java | 8 +-
.../messages/TcpDiscoveryCustomEventMessage.java | 6 +-
.../messages/TcpDiscoveryJoinRequestMessage.java | 5 +-
.../messages/TcpDiscoveryStatusCheckMessage.java | 6 +-
.../spi/indexing/IndexingQueryCacheFilter.java | 8 +-
.../spi/indexing/IndexingQueryFilterImpl.java | 8 +-
.../spi/systemview/view/BinaryMetadataView.java | 10 +-
.../systemview/view/sql/SqlTableColumnView.java | 5 +-
.../spi/systemview/view/sql/SqlTableView.java | 4 +-
.../apache/ignite/startup/BasicWarmupClosure.java | 7 +-
.../ignite/startup/cmdline/CommandLineStartup.java | 10 +-
.../thread/IgniteStripedThreadPoolExecutor.java | 18 +-
.../apache/ignite/util/AttributeNodeFilter.java | 4 +-
.../main/resources/META-INF/classnames.properties | 16 +-
modules/core/src/test/config/example-cache.xml | 4 -
.../src/test/config/spring-start-nodes-attr.xml | 4 -
.../core/src/test/config/spring-start-nodes.xml | 4 -
.../test/config/websession/example-cache-base.xml | 4 -
...finityFunctionBackupFilterAbstractSelfTest.java | 6 +-
...NodeAttributeColocatedBackupFilterSelfTest.java | 5 +-
.../RendezvousAffinityFunctionSimpleBenchmark.java | 2 +-
.../org/apache/ignite/cdc/AbstractCdcTest.java | 6 +-
.../ignite/cdc/CdcIgniteNodeActiveModeTest.java | 3 +-
.../ignite/client/BinaryConfigurationTest.java | 14 +-
.../java/org/apache/ignite/client/Comparers.java | 6 +-
.../org/apache/ignite/client/IgniteBinaryTest.java | 4 +-
.../ignite/internal/ClusterGroupAbstractTest.java | 7 +-
.../ignite/internal/ClusterGroupSelfTest.java | 6 +-
.../internal/ClusterNodeMetricsSelfTest.java | 2 +-
.../ConcurrentMappingFileReadWriteTest.java | 2 +-
.../internal/GridAffinityNoCacheSelfTest.java | 5 -
.../ignite/internal/GridDiscoverySelfTest.java | 3 +-
...idEventStorageRuntimeConfigurationSelfTest.java | 14 +-
.../ignite/internal/GridEventStorageSelfTest.java | 8 +-
.../internal/GridLifecycleAwareSelfTest.java | 31 -
.../internal/GridProjectionForCachesSelfTest.java | 3 +-
.../org/apache/ignite/internal/GridSelfTest.java | 9 +-
.../ignite/internal/GridStopWithWaitSelfTest.java | 5 +-
.../internal/IgniteClientReconnectCacheTest.java | 3 +-
.../IgniteClientReconnectDelayedSpiTest.java | 4 +-
...teConnectionConcurrentReserveAndRemoveTest.java | 4 +-
.../internal/binary/AbstractBinaryArraysTest.java | 4 +-
.../BinaryArrayIdentityResolverSelfTest.java | 4 +-
.../internal/binary/BinaryArraySelfTest.java | 4 +-
.../binary/BinaryContextPredefinedTypesTest.java | 2 +-
.../internal/binary/BinaryEnumsSelfTest.java | 4 +-
.../binary/BinaryFieldExtractionSelfTest.java | 110 +-
.../binary/BinaryFieldsAbstractSelfTest.java | 2 +-
.../BinaryFooterOffsetsAbstractSelfTest.java | 2 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 83 +-
.../BinaryObjectBuilderDefaultMappersSelfTest.java | 13 +-
.../binary/BinaryObjectExceptionSelfTest.java | 2 +-
.../internal/binary/BinaryObjectTestUtils.java | 56 +
.../BinarySerialiedFieldComparatorSelfTest.java | 4 +-
.../BinarySimpleNameTestPropertySelfTest.java | 25 -
.../GridBinaryMarshallerCtxDisabledSelfTest.java | 2 +-
.../binary/GridBinaryWildcardsSelfTest.java | 2 +-
.../binary/RawBinaryObjectExtractorTest.java | 15 +-
.../BinaryObjectBuilderAdditionalSelfTest.java | 20 +-
...yObjectBuilderAdditionalNonCompactSelfTest.java | 2 +-
.../streams/BinaryAbstractOutputStreamTest.java | 3 +-
.../binary/streams/BinaryStreamsTestUtils.java} | 17 +-
.../inline/InlineIndexKeyTypeRegistryTest.java | 6 +-
.../client/thin/CacheEntryListenersTest.java | 3 +-
.../internal/client/thin/ClusterGroupTest.java | 3 +-
.../internal/client/thin/ComputeTaskTest.java | 12 +-
.../client/thin/MetadataRegistrationTest.java | 2 +-
.../internal/client/thin/RecoveryModeTest.java | 6 +
.../ignite/internal/client/thin/ServicesTest.java | 6 +-
.../ignite/internal/client/thin/TimeoutTest.java | 4 +-
.../client/thin/events/FakeIgniteServer.java | 14 +-
.../internal/cluster/IgniteClusterNameTest.java | 89 +
.../encryption/EncryptedCacheCreateTest.java | 3 +-
.../managers/IgniteDiagnosticMessagesTest.java | 36 +-
...tractCommunicationMessageSerializationTest.java | 265 +-
.../GridCommunicationSendMessageSelfTest.java | 14 +-
.../GridIoManagerFileTransmissionSelfTest.java | 20 +-
.../communication/GridIoManagerSelfTest.java | 12 +-
...iteIoCommunicationMessageSerializationTest.java | 27 +-
.../IgniteMessageFactoryImplTest.java | 15 -
.../MessageDirectTypeIdConflictTest.java | 8 +-
.../GridDeploymentManagerStopSelfTest.java | 2 -
.../optimized/OptimizedMarshallerEnumSelfTest.java | 39 +-
.../OptimizedMarshallerNodeFailoverTest.java | 349 ---
.../OptimizedMarshallerPooledSelfTest.java | 5 +-
.../optimized/OptimizedMarshallerSelfTest.java | 4 +-
...edMarshallerSerialPersistentFieldsSelfTest.java | 5 +-
.../optimized/OptimizedMarshallerTest.java | 48 -
.../ignite/internal/metric/JmxExporterSpiTest.java | 4 +-
.../internal/metric/MetricsConfigurationTest.java | 8 +-
.../ignite/internal/metric/SystemViewSelfTest.java | 4 +-
.../processors/DeadLockOnNodeLeftExchangeTest.java | 111 -
.../Authentication1kUsersNodeRestartTest.java | 3 +-
.../AuthenticationConfigurationClusterTest.java | 3 +-
.../AuthenticationOnNotActiveClusterTest.java | 2 +-
.../AuthenticationProcessorNPEOnStartTest.java | 3 +-
.../AuthenticationProcessorNodeRestartTest.java | 2 +-
.../AuthenticationProcessorSelfTest.java | 2 +-
.../cache/AbstractDataTypesCoverageTest.java | 8 +-
.../cache/CacheEnumOperationsAbstractTest.java | 4 +-
.../cache/CacheMetricsCacheSizeTest.java | 2 +-
.../cache/ConnectionEnabledPropertyTest.java | 3 +
...dCacheAbstractFullApiMultithreadedSelfTest.java | 10 +-
.../cache/GridCacheAbstractFullApiSelfTest.java | 5 +-
.../cache/GridCacheAbstractRemoveFailureTest.java | 3 +-
.../cache/GridCacheAffinityApiSelfTest.java | 11 +-
.../cache/GridCacheClearAllSelfTest.java | 3 +-
.../cache/GridCacheClearLocallySelfTest.java | 4 +-
.../GridCacheConditionalDeploymentSelfTest.java | 5 -
.../cache/GridCacheEntryMemorySizeSelfTest.java | 10 -
.../cache/GridCacheEntryVersionSelfTest.java | 3 +-
.../cache/GridCacheOnCopyFlagAbstractSelfTest.java | 14 +-
.../cache/GridCacheP2PUndeploySelfTest.java | 298 --
.../GridCacheStoreManagerDeserializationTest.java | 55 -
.../cache/GridLocalIgniteSerializationTest.java | 17 +-
.../cache/IgniteCachePartitionMapUpdateTest.java | 4 +-
.../IgniteCachePutKeyAttachedBinaryObjectTest.java | 3 +-
.../cache/IgniteCacheStoreValueAbstractTest.java | 6 +-
.../cache/IgniteIncompleteCacheObjectSelfTest.java | 5 -
...niteMarshallerCacheConcurrentReadWriteTest.java | 4 +-
.../processors/cache/IgniteTxAbstractTest.java | 6 +-
.../cache/WalModeChangeAdvancedSelfTest.java | 22 +-
.../cache/WalModeChangeCommonAbstractSelfTest.java | 4 +-
.../GridBinaryCacheEntryMemorySizeSelfTest.java | 3 +-
.../GridCacheBinaryObjectsAbstractSelfTest.java | 15 +-
...GridCachePartitionedQueueEntryMoveSelfTest.java | 4 +-
.../CacheLateAffinityAssignmentTest.java | 303 +-
.../CachePartitionLossWithPersistenceTest.java | 2 +-
.../GridCacheClientModesAbstractSelfTest.java | 3 +-
.../distributed/GridCacheEventAbstractTest.java | 3 +-
.../GridCacheMultithreadedFailoverTest.java | 10 +-
.../GridCachePreloadRestartAbstractSelfTest.java | 6 +-
.../GridCacheTransformEventSelfTest.java | 6 +-
...gniteCacheClientNodePartitionsExchangeTest.java | 65 +-
...teTxOriginatingNodeFailureAbstractSelfTest.java | 4 +-
...acheColocatedOptimisticTransactionSelfTest.java | 4 +-
.../distributed/dht/GridCacheDhtEntrySelfTest.java | 3 +-
.../GridCacheDhtEvictionNearReadersSelfTest.java | 7 +-
.../dht/GridCacheDhtPreloadDelayedSelfTest.java | 3 +-
.../dht/GridCacheDhtPreloadDisabledSelfTest.java | 13 +-
.../dht/GridCacheDhtPreloadSelfTest.java | 5 +-
...achePrimaryNodeFailureRecoveryAbstractTest.java | 114 +-
.../near/GridCacheNearMultiNodeSelfTest.java | 3 +-
.../GridCacheNearOnlyMultiNodeFullApiSelfTest.java | 3 +-
.../near/GridCacheNearReaderPreloadSelfTest.java | 5 +-
.../near/GridCachePartitionedAffinitySelfTest.java | 3 +-
.../near/GridCachePartitionedEvictionSelfTest.java | 6 +-
...idCachePartitionedMultiNodeCounterSelfTest.java | 5 +-
...idCachePartitionedMultiNodeFullApiSelfTest.java | 3 +-
.../GridCacheRendezvousAffinityClientSelfTest.java | 7 +-
.../GridCacheRebalancingPartitionCountersTest.java | 21 +-
...acheRebalancingUnmarshallingFailedSelfTest.java | 39 -
.../GridCacheReplicatedPreloadSelfTest.java | 4 +-
...gnitePdsBinaryMetadataOnClusterRestartTest.java | 42 +-
...CacheConfigurationFileConsistencyCheckTest.java | 19 +-
.../persistence/IgnitePdsCorruptedStoreTest.java | 9 +-
.../persistence/IgnitePdsDefragmentationTest.java | 141 +-
.../cache/persistence/IgnitePdsOnClientTest.java | 5 +-
.../IgnitePdsPartitionFilesDestroyTest.java | 28 +-
.../IgnitePdsRemoveDuringRebalancingTest.java | 8 +-
...tePdsRestartAfterFailedToWriteMetaPageTest.java | 3 +-
...NoChangeDuringRebalanceOnNonNodeAssignTest.java | 20 +-
.../persistence/MaintenanceRegistrySimpleTest.java | 35 +-
.../PagesPossibleCorruptionDiagnosticTest.java | 7 +-
.../persistence/PendingTreeCorruptionTest.java | 112 +-
.../ClientAffinityAssignmentWithBaselineTest.java | 6 +-
.../persistence/db/CheckpointFailingIoFactory.java | 3 +-
.../db/IgnitePdsCheckpointRecoveryTest.java | 6 +-
.../db/IgnitePdsDataRegionMetricsTest.java | 5 +-
.../db/IgniteSequentialNodeCrashRecoveryTest.java | 3 +-
.../db/checkpoint/CheckpointFreeListTest.java | 3 +-
.../db/checkpoint/IgniteMassLoadSandboxTest.java | 8 +-
.../IgniteUidAsConsistentIdMigrationTest.java | 21 +-
.../persistence/db/wal/IgniteLocalWalSizeTest.java | 19 +-
.../wal/IgniteNodeStoppedDuringDisableWALTest.java | 15 +-
...eWalFlushMultiNodeFailoverAbstractSelfTest.java | 6 +-
.../db/wal/IgniteWalIteratorSwitchSegmentTest.java | 7 +-
.../persistence/db/wal/IgniteWalRebalanceTest.java | 3 +-
.../db/wal/WalCompactionSwitchOnTest.java | 6 +-
.../persistence/db/wal/WalCompactionTest.java | 5 +-
.../persistence/db/wal/WalOnNodeStartTest.java | 8 +-
.../db/wal/reader/IgniteWalReaderTest.java | 25 +-
.../db/wal/reader/MockWalIteratorFactory.java | 2 +-
.../AbstractDataRegionRelativeStoragePathTest.java | 228 ++
.../filename/CacheConfigStoragePathTest.java | 238 ++
.../CustomCacheStorageConfigurationSelfTest.java | 312 +++
.../persistence/filename/FileTreeTestUtils.java} | 20 +-
.../SnapshotCreationNonDefaultStoragePathTest.java | 175 ++
.../snapshot/AbstractSnapshotSelfTest.java | 84 +-
.../snapshot/EncryptedSnapshotTest.java | 9 +-
.../snapshot/IgniteClusterSnapshotCheckTest.java | 12 +-
.../snapshot/IgniteClusterSnapshotDeltaTest.java | 31 +-
.../snapshot/IgniteClusterSnapshotHandlerTest.java | 6 +-
.../IgniteClusterSnapshotRestoreSelfTest.java | 67 +-
.../snapshot/IgniteClusterSnapshotSelfTest.java | 18 +-
.../IgniteClusterSnapshotStreamerTest.java | 3 -
.../snapshot/IgniteSnapshotManagerSelfTest.java | 120 +-
.../snapshot/IgniteSnapshotRemoteRequestTest.java | 22 +-
.../IgniteSnapshotRestoreFromRemoteTest.java | 13 +-
.../persistence/snapshot/PlainSnapshotTest.java | 23 +-
.../snapshot/dump/AbstractCacheDumpTest.java | 102 +-
.../snapshot/dump/IgniteCacheDumpFilterTest.java | 308 ++
.../snapshot/dump/IgniteCacheDumpSelf2Test.java | 248 +-
.../snapshot/dump/IgniteCacheDumpSelfTest.java | 7 +-
.../IncrementalSnapshotCheckBeforeRestoreTest.java | 21 +-
.../IncrementalSnapshotRestoreTest.java | 8 +-
.../reader/StandaloneWalRecordsIteratorTest.java | 12 +-
.../cache/query/CacheScanQueryFailoverTest.java | 2 +-
...cheContinuousQueryFailoverAbstractSelfTest.java | 7 +-
.../CacheContinuousQueryVariationsTest.java | 4 +-
.../CacheEntryProcessorNonSerializableTest.java | 433 ---
...ueryRemoteFilterMissingInClassPathSelfTest.java | 4 +-
.../TxDeadlockOnEntryToStringTest.java | 4 +-
...titionCounterStateOnePrimaryTwoBackupsTest.java | 29 +-
.../TxTimeoutOnInitializationTest.java | 80 +
.../warmup/LoadAllWarmUpStrategySelfTest.java | 2 +-
.../closure/GridClosureProcessorSelfTest.java | 3 +-
.../cluster/ClusterNameBeforeActivation.java | 106 -
.../cluster/ClusterStateChangeOnNodeJoinTest.java | 186 ++
.../continuous/GridEventConsumeSelfTest.java | 44 +-
.../processors/database/CacheFreeListSelfTest.java | 7 -
.../database/FreeListCutTailDifferentGcTest.java | 283 ++
.../internal/processors/localtask/SimpleTask.java | 5 +-
.../AbstractPerformanceStatisticsTest.java | 38 +-
.../ForwardReadQueryPropertyTest.java | 103 +
.../PerformanceStatisticsMultipleStartTest.java | 3 +-
.../PerformanceStatisticsPropertiesTest.java | 21 +-
.../PerformanceStatisticsRotateFileTest.java | 8 +-
.../PerformanceStatisticsSystemViewTest.java | 225 ++
.../PerformanceStatisticsThinClientTest.java | 68 +-
.../performancestatistics/StringCacheTest.java | 40 +-
.../NodeSecurityContextPropagationTest.java | 8 +-
.../client/ThinClientPermissionCheckTest.java | 25 +-
.../service/GridServiceReassignmentSelfTest.java | 4 +-
...ployment2ClassLoadersDefaultMarshallerTest.java | 10 -
...ceDeployment2ClassLoadersJdkMarshallerTest.java | 31 -
...oyment2ClassLoadersOptimizedMarshallerTest.java | 31 -
...eploymentClassLoadingDefaultMarshallerTest.java | 10 -
...iceDeploymentClassLoadingJdkMarshallerTest.java | 31 -
...loymentClassLoadingOptimizedMarshallerTest.java | 31 -
.../ignite/internal/util/IgniteUtilsSelfTest.java | 382 ++-
.../ignite/internal/util/lang/ConsumerX.java | 5 +-
.../internal/util/lang/GridFuncSelfTest.java | 54 -
.../TcpCommunicationSpiSslVolatilePayloadTest.java | 17 +-
.../apache/ignite/lang/GridSetWrapperSelfTest.java | 4 +-
.../utils/GridConcurrentWeakHashSetSelfTest.java | 3 +-
.../ignite/loadtests/GridLoadTestStatistics.java | 3 +-
.../communication/GridIoManagerBenchmark.java | 4 +-
.../loadtests/communication/GridTestMessage.java | 5 -
.../marshaller/GridMarshallerAbstractTest.java | 5 +-
.../MarshallerEnumDeadlockMultiJvmTest.java | 68 +-
.../p2p/ClassLoadingProblemExceptionTest.java | 4 +-
.../ignite/p2p/GridP2PClassLoadingSelfTest.java | 4 +-
.../platform/PlatformCacheWriteMetricsTask.java | 4 +-
.../PlatformComputeBinarizableArgTask.java | 3 +-
.../ignite/platform/PlatformDeployServiceTask.java | 9 +-
.../platform/PlatformEventsWriteEventTask.java | 4 +-
.../platform/PlatformGetInternalCachesTask.java | 11 +-
.../platform/PlatformSetUseBinaryArrayTask.java | 4 +-
.../GridSessionCheckpointAbstractSelfTest.java | 6 +-
.../session/GridSessionCheckpointSelfTest.java | 6 +-
.../GridJobStealingCollisionSpiSelfTest.java | 3 +-
.../communication/GridCacheMessageSelfTest.java | 84 +-
.../ignite/spi/communication/GridTestMessage.java | 27 +-
.../communication/TestVolatilePayloadMessage.java | 19 +-
.../tcp/CommunicationWorkerThreadUtils.java | 15 +
.../tcp/GridCacheDhtLockBackupSelfTest.java | 7 -
...unicationInverseConnectionEstablishingTest.java | 4 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 76 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 2 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 4 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 12 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 8 +-
...cpCommunicationSpiHalfOpenedConnectionTest.java | 6 +-
...mmunicationSpiInverseConnectionLoggingTest.java | 2 +-
.../TooManyOpenFilesTcpCommunicationSpiTest.java | 4 +
.../TcpClientDiscoveryMarshallerCheckSelfTest.java | 57 +-
.../tcp/TcpClientDiscoverySpiSelfTest.java | 5 +-
.../tcp/TcpDiscoveryMarshallerCheckSelfTest.java | 94 -
.../TcpDiscoveryPendingMessageDeliveryTest.java | 6 +
.../spi/discovery/tcp/TcpDiscoveryRestartTest.java | 3 +-
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 4 +-
.../ignite/testframework/GridSpiTestContext.java | 3 +-
.../testframework/GridTestSafeThreadFactory.java | 11 +-
.../apache/ignite/testframework/GridTestUtils.java | 49 +-
.../configvariations/ConfigVariations.java | 13 -
.../testframework/junits/GridAbstractTest.java | 53 +-
.../junits/GridTestBinaryMarshaller.java | 7 +-
.../junits/IgniteConfigVariationsAbstractTest.java | 3 +-
.../ignite/testframework/junits/IgniteMock.java | 14 +-
.../testframework/junits/IgniteTestResources.java | 38 +-
.../junits/common/GridCommonAbstractTest.java | 49 +-
.../junits/multijvm/IgniteNodeRunner.java | 20 +-
.../junits/multijvm/IgniteProcessProxy.java | 11 -
.../test/ConfigVariationsTestSuiteBuilderTest.java | 12 +-
.../ignite/testsuites/IgniteBasicTestSuite2.java | 6 +-
.../IgniteBasicWithPersistenceTestSuite.java | 4 +
.../testsuites/IgniteBinaryObjectsTestSuite.java | 2 +-
.../ignite/testsuites/IgniteCacheTestSuite.java | 4 -
.../ignite/testsuites/IgniteCacheTestSuite13.java | 4 +-
.../ignite/testsuites/IgniteCacheTestSuite6.java | 2 +
...mputeBasicConfigVariationsFullApiTestSuite.java | 8 -
.../testsuites/IgniteKernalSelfTestSuite.java | 4 +-
.../testsuites/IgniteMarshallerSelfTestSuite.java | 2 -
...teMessagingConfigVariationFullApiTestSuite.java | 8 -
.../ignite/testsuites/IgnitePdsTestSuite8.java | 6 +
.../ignite/testsuites/IgniteReproducingSuite.java | 4 +-
.../testsuites/IgniteServiceGridTestSuite.java | 8 -
.../testsuites/IgniteSnapshotTestSuite3.java | 2 +
.../IgniteSpiDiscoverySelfTestSuite.java | 2 -
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 2 -
.../test/webapp/META-INF/ignite-webapp-config.xml | 7 -
modules/dev-utils/pom.xml | 12 +
.../development/utils/IgniteWalConverter.java | 11 +-
.../utils/IgniteWalConverterArguments.java | 168 +-
.../utils/IgniteEncryptedWalConverterTest.java | 5 +-
.../utils/IgniteWalConverterArgumentsTest.java | 189 +-
.../utils/IgniteWalConverterSensitiveDataTest.java | 10 +-
.../development/utils/IgniteWalConverterTest.java | 34 +-
modules/ducktests/pom.xml | 12 +
.../tests/ignitetest/services/utils/jmx_utils.py | 22 +
.../tests/control_utility/perf_stat_test.py | 2 +-
modules/extdata/p2p/pom.xml | 12 +
.../ignite/tests/p2p/GridTestMessageTopic.java | 2 +-
.../p2p/NoValueClassOnServerAbstractClient.java | 3 +-
.../ignite/tests/p2p/P2PTestTaskExternalPath1.java | 4 +-
.../ignite/tests/p2p/P2PTestTaskExternalPath2.java | 4 +-
modules/extdata/platform/pom.xml | 12 +
.../platform/plugin/PlatformTestPluginTarget.java | 26 +-
.../commandline/CommandsProviderExtImpl.java | 3 +-
.../commandline/ExtendedControlUtilityTest.java | 3 +
...gnite.internal.management.api.CommandsProvider} | 0
modules/extdata/uri/pom.xml | 6 +
modules/indexing/pom.xml | 12 +
.../query/h2/DmlStatementsProcessor.java | 71 +-
.../processors/query/h2/H2CachedStatementKey.java | 4 +-
.../internal/processors/query/h2/H2Connection.java | 22 +-
.../internal/processors/query/h2/H2QueryInfo.java | 7 +-
.../internal/processors/query/h2/H2TypeKey.java | 4 +-
.../internal/processors/query/h2/H2Utils.java | 30 +-
.../processors/query/h2/IgniteH2Indexing.java | 38 +-
.../internal/processors/query/h2/QueryParser.java | 3 +-
.../internal/processors/query/h2/QueryTable.java | 24 +-
.../query/h2/affinity/PartitionExtractor.java | 8 +-
.../processors/query/h2/dml/DmlBatchSender.java | 4 +-
.../internal/processors/query/h2/dml/DmlUtils.java | 28 +-
.../processors/query/h2/dml/UpdatePlan.java | 16 +-
.../processors/query/h2/dml/UpdatePlanBuilder.java | 137 +-
.../processors/query/h2/opt/GridH2Table.java | 7 +-
.../query/h2/opt/GridH2ValueCacheObject.java | 8 +-
.../processors/query/h2/opt/QueryContextKey.java | 4 +-
.../query/h2/sql/GridSqlQueryParser.java | 32 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 2 +-
.../query/h2/twostep/MapQueryResult.java | 4 +-
.../processors/query/h2/twostep/MapRequestKey.java | 4 +-
.../query/h2/twostep/ReduceSourceKey.java | 4 +-
.../query/h2/twostep/msg/GridH2Array.java | 16 +-
.../query/h2/twostep/msg/GridH2Boolean.java | 16 +-
.../query/h2/twostep/msg/GridH2Byte.java | 16 +-
.../query/h2/twostep/msg/GridH2Bytes.java | 16 +-
.../query/h2/twostep/msg/GridH2CacheObject.java | 16 +-
.../query/h2/twostep/msg/GridH2Date.java | 16 +-
.../query/h2/twostep/msg/GridH2Decimal.java | 20 +-
.../query/h2/twostep/msg/GridH2DmlRequest.java | 75 +-
.../query/h2/twostep/msg/GridH2DmlResponse.java | 47 +-
.../query/h2/twostep/msg/GridH2Double.java | 16 +-
.../query/h2/twostep/msg/GridH2Float.java | 16 +-
.../query/h2/twostep/msg/GridH2Geometry.java | 16 +-
.../h2/twostep/msg/GridH2IndexRangeRequest.java | 36 +-
.../h2/twostep/msg/GridH2IndexRangeResponse.java | 44 +-
.../query/h2/twostep/msg/GridH2Integer.java | 16 +-
.../query/h2/twostep/msg/GridH2JavaObject.java | 16 +-
.../query/h2/twostep/msg/GridH2Long.java | 16 +-
.../query/h2/twostep/msg/GridH2Null.java | 12 +-
.../query/h2/twostep/msg/GridH2QueryRequest.java | 87 +-
.../query/h2/twostep/msg/GridH2RowMessage.java | 16 +-
.../query/h2/twostep/msg/GridH2RowRange.java | 24 +-
.../query/h2/twostep/msg/GridH2RowRangeBounds.java | 24 +-
.../query/h2/twostep/msg/GridH2Short.java | 16 +-
.../query/h2/twostep/msg/GridH2String.java | 16 +-
.../query/h2/twostep/msg/GridH2Time.java | 16 +-
.../query/h2/twostep/msg/GridH2Timestamp.java | 20 +-
.../query/h2/twostep/msg/GridH2Uuid.java | 20 +-
.../org/apache/ignite/client/SecurityTest.java | 7 +-
.../ignite/internal/dump/DumpCacheConfigTest.java | 7 +-
.../cache/CacheGroupMetricsWithIndexTest.java | 36 +-
.../cache/IgniteCacheNoClassQuerySelfTest.java | 101 -
.../authentication/SqlUserCommandSelfTest.java | 3 +-
.../cache/index/AbstractIndexingCommonTest.java | 6 +-
.../cache/index/AbstractRebuildIndexTest.java | 14 +-
.../cache/index/AbstractSchemaSelfTest.java | 7 +-
.../processors/cache/index/ArrayIndexTest.java | 6 +-
.../DynamicColumnsAbstractConcurrentSelfTest.java | 6 +-
.../cache/index/H2RowCachePageEvictionTest.java | 2 +-
.../index/OptimizedMarshallerIndexNameTest.java | 269 --
.../cache/index/ResumeRebuildIndexTest.java | 11 +-
.../cache/index/SchemaExchangeSelfTest.java | 3 +-
.../IgnitePdsIndexingDefragmentationTest.java | 20 +-
.../persistence/RebuildIndexLogMessageTest.java | 9 +-
.../db/IgniteCacheGroupsWithRestartsTest.java | 9 +-
.../db/LongDestroyDurableBackgroundTaskTest.java | 37 -
.../persistence/db/wal/IgniteWalRecoveryTest.java | 12 +-
.../filename/SQLCacheConfigStoragePathTest.java | 101 +
.../snapshot/IgniteClusterSnapshotMetricsTest.java | 13 +-
.../transaction/DmlInsideTransactionTest.java | 4 +-
.../processors/database/RebuildIndexTest.java | 10 +-
.../RebuildIndexWithHistoricalRebalanceTest.java | 18 +-
.../WalDisabledDuringIndexRecreateTest.java | 5 +-
.../PerformanceStatisticsQueryTest.java | 3 +-
.../PerformanceStatisticsSystemViewTablesTest.java | 159 ++
.../query/DropTableAfterCteSqlQueryTest.java | 222 ++
.../query/IgniteQueryDedicatedPoolTest.java | 4 +-
.../query/IgniteSqlNotNullConstraintTest.java | 7 +-
...gniteSqlSkipReducerOnUpdateDmlFlagSelfTest.java | 3 +-
.../IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 6 +-
...SqlFieldTypeValidationOnKeyValueInsertTest.java | 3 +-
.../query/SqlFieldTypeValidationTypesTest.java | 3 +-
.../processors/query/SqlIllegalSchemaSelfTest.java | 4 +-
.../processors/query/SqlMergeOnClientNodeTest.java | 11 +-
.../internal/processors/query/SqlMergeTest.java | 97 +-
.../processors/query/SqlSchemaSelfTest.java | 4 +-
.../processors/query/SqlSystemViewsSelfTest.java | 3 +-
.../query/h2/DmlStatementsProcessorTest.java | 153 -
.../query/h2/GridIndexRebuildSelfTest.java | 8 +-
.../processors/query/h2/GridIndexRebuildTest.java | 34 +-
.../inlinecolumn/InlineIndexColumnTest.java | 6 +-
.../query/stat/ManagerStatisticsTypesTest.java | 6 +-
.../org/apache/ignite/sqltests/BaseSqlTest.java | 3 +-
.../IgniteBinaryCacheQueryTestSuite3.java | 4 -
.../IgniteBinaryCacheQueryTestSuite4.java | 3 -
.../testsuites/IgniteCacheQuerySelfTestSuite6.java | 4 +
.../IgniteCacheWithIndexingTestSuite.java | 4 +-
modules/json/pom.xml | 12 +
.../internal/binary/BinaryArraySerializer.java} | 19 +-
.../binary/BinaryObjectImplSerializer.java | 75 +
.../ignite/internal/binary/BinarySerializers.java} | 16 +-
.../internal/jackson/IgniteObjectMapper.java | 77 +-
.../org/apache/ignite/dump/IgniteJsonSuite.java | 3 +-
.../java/org/apache/ignite/dump/JsonArrayTest.java | 192 ++
modules/log4j2/pom.xml | 6 +
modules/opencensus/pom.xml | 6 +
.../Apache.Ignite.Core.Tests.DotNetCore.csproj | 2 -
.../Apache.Ignite.Core.Tests.csproj | 2 -
.../Compute/ComputeApiTest.JavaTask.cs | 257 +-
.../Config/Compute/compute-grid2.xml | 4 -
.../Config/marshaller-explicit.xml | 54 -
.../Config/marshaller-invalid.xml | 47 -
.../Apache.Ignite.Core.Tests/MarshallerTest.cs | 29 -
.../Apache.Ignite.Core/Impl/Binary/BinaryUtils.cs | 33 +-
modules/rest-http/pom.xml | 12 +
modules/spring/pom.xml | 6 +
.../ignite/internal/GridFactorySelfTest.java | 3 +-
modules/urideploy/pom.xml | 6 +
.../GridTaskUriDeploymentDeadlockSelfTest.java | 2 +-
modules/web/pom.xml | 6 +
.../ignite/cache/websession/WebSessionFilter.java | 9 +-
.../internal/websession/WebSessionSelfTest.java | 37 +-
.../test/webapp2/META-INF/ignite-webapp-config.xml | 7 -
.../config/ignite-bin-multicast-config.xml | 4 -
.../config/ignite-int-max-values-onheap-config.xml | 10 -
modules/yardstick/config/ignite-jdbc-config.xml | 4 -
modules/yardstick/pom.xml | 12 +
.../cache/IgniteIoTestAbstractBenchmark.java | 5 +-
.../io/IgniteIoTestAbstractBenchmark.java | 5 +-
modules/zookeeper/pom.xml | 5 +
.../zk/internal/ZookeeperClusterNode.java | 3 +-
.../zk/internal/ZookeeperDiscoveryImpl.java | 5 +-
.../zk/internal/ZookeeperDiscoveryMiscTest.java | 4 +-
.../zk/internal/ZookeeperDiscoverySpiTestBase.java | 21 +-
...perDiscoveryTopologyChangeAndReconnectTest.java | 89 +-
parent/pom.xml | 19 +-
pom.xml | 2 +
1694 files changed, 26764 insertions(+), 25821 deletions(-)