This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-28896
in repository https://gitbox.apache.org/repos/asf/ignite.git
from 3d4e2f37234 Merge branch 'master' into ignite-28896
add cf98859f16a IGNITE-28794 Use MessageSerializer to transfer
ServiceProcessorCommonDiscoveryData (#13344)
add 34786b9a281 IGNITE-28908 Fixed features activation completion on
client nodes with missing component (#13384)
add 834acdaa45f IGNITE-28909 Added test for node join with the same
features but smaller version (#13385)
add 7ab0f6e8c4d [MINOR] Fix javadoc (#13388)
add 0f357eb7e0b IGNITE-28714 Add data center ID to client connections
system view (#13379)
add 0a612438b3d IGNITE-24098 Remove PROTO COL_V2_VERSION_SINCE (#13394)
add 1e407c43e6a [MINOR] Remove ClassCache interface (#13395)
add 47fb44979ef IGNITE-28902 Fixed Operation Context propagation for
discovery ack messages via TCP Discovery SPI (#13381)
add 5403270fa96 IGNITE-28914 Remove MarshallableMessage interface from
GridDhtPartitionsFullMessage (#13392)
add 940b73c82de IGNITE-28913 GitHub Actions: run fork PR checks without
checking out untrusted code in a privileged context (#13390)
add 04286dff940 IGNITE-28917 Implemented tracking of previous cluster
version feature set and sending it to joining nodes (#13393)
add 36179fa4ed3 Bump commons-io:commons-io from 2.11.0 to 2.22.0 (#13398)
add e665ebf5666 IGNITE-28671 Describe healthy cluster behavior in general
tips guide (#13130)
add 3dfb9229134 IGNITE-28738 Implement basic Rolling Upgrade test using
testcontainers (#13184)
add 099ca1d2b38 IGNITE-28910 Ignite Tracing public API was deprecated and
internal implementation was removed (#13387)
add be8f8e28410 IGNITE-28894 C++: add nested thin-client modules to the
dev-mode classpath (#13373)
add 08637025d24 IGNITE-28921 Remove unused internal classes (#13401)
add e1803947e17 IGNITE-28916 Added support for Management API Client
version validation (#13400)
add e8b7486f2ef IGNITE-28915 Fixed Operation Context propagation for
postponed messages (#13396)
add 46f54000f27 IGNITE-28915 Reused existing operation context snapshot
for discovery ack messages. (#13404)
add c676f7ac326 IGNITE-28870 Restore snapshot temporary files cleanup
logic (#13358)
add 970c1dda892 IGNITE-28923 Update Jackson dependency to 2.21.5 (#13402)
add bfdc573e0fe IGNITE-28520 Auto-generate message serialization /
marshalling / deployment (#13095)
add bf93f5cf9f4 IGNITE-26585 Fixed NPE on task name resolution (#13403)
add f087fad8c6d IGNITE-28926 Update zstd to 1.5.7-11, lz4 to 1.11.1
(#13406)
add e330af5355a IGNITE-28929 Move marshaller info into Messages classes
(#13410)
add a668494620f IGNITE-27833 [ducktests] Add Multi-DC Integration Test for
Cross-DC Network Partition Resilience (#12740)
add f9ebf2aa13b IGNITE-28934 Create message with direct constructor call
(#13416)
add 4927eec73bf IGNITE-28356 Get rid of redundant wire companion fields
and hand-written marshalling in messages (#13408)
add e59277bfcf2 IGNITE-28925 SQL Calcite: Fix unexpected
downstream().end() call for execution nodes - Fixes #13407.
add a20d1c0f302 IGNITE-28928 Use MessageSerializer for
SecurityPermissionSet (#13414)
add 5c899284ac5 IGNITE-28855 Client node permanently loses discovery
events delivered right after the reconnect response (#13327)
add 32bbb11c1e5 IGNITE-28936 Remove dead marshalling code from
GridDhtAtomicUpdateRequest (#13419)
add 2cb678f080d IGNITE-28924 SQL Calcite: Add the ability to implement a
custom DistinctAccumulator (#13405)
add 5e1e3ee4480 IGNITE-28943 Fix incorrect test file name in
MessageProcessorTest (#13423)
add 5394a9fa23a IGNITE-28736 Fixed order of fields in
BinaryType#fieldNames (#13411)
add a4b46a1f88b IGNITE-28937 Register core messages uniformly: drop
withSchema/withNoSchema (#13421)
add 152157d0040 IGNITE-27606 Replace GridUnsafe with byte-array VarHandle
views in PartitionUpdateCountersMessage (#13422)
add bc4c25c5ef3 IGNITE-28792 Use MessageSerializer to transfer
CacheGroupData and CacheData (#13386)
add 8d3c137db8c Merge branch 'master' into ignite-28896
add f9273aef880 IGNITE-28946 Statically configured
IgniteMarshallerClassFilter (#13425)
add 4b92f71c2bb IGNITE-28901 Split GridEventStorageMessage into a request
and a response (#13428)
add 54f054c4fd7 IGNITE-28953 Init CalciteMessageFactory with marshallers
in Calcite tests (#13434)
add 19c424181c0 IGNITE-28793 Use MessageSerializer to transfer
BaselineStateAndHistoryData (#13412)
add 746cbb37d7f IGNITE-28791 Use MessageSerializer to transfer metastorage
DTO's in DataBag (#13409)
add 5cbb7fc2c1c IGNITE-28271 Use the generated marshalling for
GridJobExecuteResponse (#13435)
add 88d7dfb824f IGNITE-28930 Default field values are lost on remote nodes
when a query entity is added dynamically (#13430)
add 3209af44754 IGNITE-28938 Split MarshallableMessage: a message with a
custom wire form needs no marshaller (#13427)
add 601c69f6a7b IGNITE-28844 Calcite. Improve type checking in LIMIT /
OFFSET clauses (#13311)
add 4742153b893 Merge branch 'master' into ignite-28896
add 710c7c15087 IGNITE-28896 Wip
No new revisions were added by this update.
Summary of changes:
.github/workflows/check-protected-classes.yml | 165 ++-
.github/workflows/commit-check.yml | 7 +-
.gitignore | 4 +
checkstyle/checkstyle-suppressions.xml | 3 -
docs/_data/toc.yaml | 2 -
docs/_docs/clustering/multi-data-center.adoc | 10 +-
docs/_docs/code-snippets/java/pom.xml | 5 -
.../java/org/apache/ignite/snippets/Tracing.java | 110 --
docs/_docs/code-snippets/xml/tracing.xml | 45 -
docs/_docs/key-value-api/transactions.adoc | 2 -
docs/_docs/monitoring-metrics/system-views.adoc | 1 +
docs/_docs/monitoring-metrics/tracing.adoc | 240 ----
.../general-perf-tips.adoc | 459 +++++++-
.../images/healthy-cluster-checkpoint-jconsole.png | Bin 0 -> 195423 bytes
.../images/healthy-cluster-queues-jconsole.png | Bin 0 -> 145243 bytes
docs/_docs/tools/control-script.adoc | 66 --
examples/pom.xml | 2 +-
.../direct/JmhDirectMessageReaderBenchmark.java | 3 +-
.../jmh/misc/JmhTracingContextBenchmark.java | 108 --
.../java/org/apache/ignite/binary/BinaryType.java | 6 +-
.../ignite/internal/binary/BinaryContext.java | 2 +-
.../ignite/internal/binary/BinaryMetadata.java | 7 +-
.../internal/binary/BinaryMetadataCollector.java | 6 +-
.../internal/processors/cache/CacheObject.java | 4 +-
.../ignite/marshaller/MarshallerContext.java | 8 -
.../apache/ignite/marshaller/MarshallerUtils.java | 87 +-
.../org/apache/ignite/marshaller/Marshallers.java | 9 -
.../ignite/marshaller/MarshallersFactory.java | 8 -
.../internal/binary/BinaryEnumObjectImpl.java | 4 +-
.../ignite/internal/binary/BinaryObjectImpl.java | 6 +-
.../internal/binary/BinaryObjectOffheapImpl.java | 4 +-
.../optimized/OptimizedObjectInputStream.java | 5 +-
.../ignite/marshaller/MarshallersFactoryImpl.java | 12 +-
.../marshaller/jdk}/IgniteObjectInputFilter.java | 16 +-
.../ignite/marshaller/jdk/JdkMarshallerImpl.java | 41 +-
.../jdk/JdkMarshallerObjectInputStream.java | 12 +-
.../query/calcite/exec/ExchangeServiceImpl.java | 11 +-
.../calcite/exec}/FetchOffsetRoundingPolicy.java | 4 +-
.../query/calcite/exec/LogicalRelImplementor.java | 82 +-
.../query/calcite/exec/exp/agg/Accumulator.java | 5 +
.../query/calcite/exec/exp/agg/Accumulators.java | 18 +-
.../query/calcite/exec/rel/AbstractNode.java | 5 +-
.../rel/AbstractRightMaterializedJoinNode.java | 3 -
.../query/calcite/exec/rel/CollectNode.java | 11 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 12 +-
.../query/calcite/exec/rel/LimitNode.java | 132 ++-
.../query/calcite/exec/rel/MergeJoinNode.java | 3 -
.../query/calcite/exec/rel/SortAggregateNode.java | 10 +-
.../query/calcite/exec/rel/SortNode.java | 68 +-
.../query/calcite/message/CalciteErrorMessage.java | 3 +-
.../calcite/message/CalciteMessageFactory.java | 32 +-
.../query/calcite/message/GenericValueMessage.java | 26 +-
.../query/calcite/message/MessageServiceImpl.java | 99 +-
.../query/calcite/message/QueryBatchMessage.java | 17 +-
.../query/calcite/message/QueryStartRequest.java | 47 +-
.../query/calcite/message/QueryStartResponse.java | 4 +-
.../query/calcite/message/QueryTxEntry.java | 31 +-
.../query/calcite/metadata/ColocationGroup.java | 12 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 102 +-
.../query/calcite/util/IgniteResource.java | 12 +-
.../calcite/exec/LogicalRelImplementorTest.java | 5 +-
.../calcite/exec/rel/ContinuousExecutionTest.java | 7 +-
.../query/calcite/exec/rel/LimitExecutionTest.java | 64 +-
.../integration/CollectIntegrationTest.java | 52 +
.../DynamicParametersIntegrationTest.java | 10 +
.../integration/LimitOffsetIntegrationTest.java | 132 +--
.../OperatorsExtensionIntegrationTest.java | 100 ++
.../integration/QueryMetadataIntegrationTest.java | 80 +-
.../integration/SortAggregateIntegrationTest.java | 26 +
...lciteCommunicationMessageSerializationTest.java | 7 +-
...lciteMessageUnmarshalThreadIntegrationTest.java | 92 ++
.../query/calcite/planner/AbstractPlannerTest.java | 137 ++-
.../planner/DynamicParametersPlannerTest.java | 85 ++
.../query/calcite/planner/HashJoinPlannerTest.java | 4 +-
.../query/calcite/planner/PlanExecutionTest.java | 7 +-
.../ignite/testsuites/IntegrationTestSuite.java | 4 +
.../apache/ignite/testsuites/PlannerTestSuite.java | 2 +
modules/calcite/src/test/sql/order/test_limit.test | 62 +-
modules/clients/pom.xml | 7 +
.../client/suite/IgniteClientTestSuite.java | 9 +-
.../rest/JettyRestProcessorAbstractSelfTest.java | 64 +-
.../rest/JettyRestProcessorClassFilterTest.java | 121 ++
.../rest/TcpRestUnmarshalVulnerabilityTest.java | 196 ++--
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 5 -
.../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 1 +
.../client/ClientMarshallerBenchmarkTest.java | 16 +-
.../org/apache/ignite/internal/Marshalled.java | 49 +
.../ignite/internal/MessageCompanionGenerator.java | 292 +++++
.../internal/MessageDeploymentGenerator.java | 267 +++++
.../internal/MessageMarshallerGenerator.java | 1219 ++++++++++++++++++++
.../apache/ignite/internal/MessageProcessor.java | 219 +++-
.../internal/MessageSerializerGenerator.java | 1008 +++++-----------
.../java/org/apache/ignite/internal/NioField.java} | 25 +-
.../internal/idto/IDTOSerializerGenerator.java | 22 +-
.../idto/IgniteDataTransferObjectProcessor.java | 22 +-
.../internal/thread/context/OperationContext.java | 97 +-
.../apache/ignite/internal/util/CommonUtils.java | 4 +-
.../java/org/apache/ignite/spi/tracing/Scope.java | 4 +
modules/compatibility/DEVNOTES.md | 152 +++
modules/compatibility/pom.xml | 43 +
.../MoveBinaryMetadataCompatibility.java | 23 +-
.../ru/IgniteRebalanceOnUpgradeTest.java | 338 ++++++
.../testcontainers/ContainerAddressResolver.java | 45 +
.../testcontainers/IgniteClusterContainer.java | 65 ++
.../testcontainers/IgniteContainer.java | 593 ++++++++++
.../IgniteRollingUpgradeDockerTestSuite.java} | 14 +-
.../src/test/resources/docker/build_distrib.sh | 74 ++
.../test/resources/docker/build_docker_image.sh | 180 +++
.../src/test/resources/docker/test-config.xml | 69 ++
.../src/test/resources/log4j2-test.xml | 34 +
.../commandline/CommandHandlerParsingTest.java | 184 ---
.../testsuites/IgniteControlUtilityTestSuite2.java | 3 -
.../apache/ignite/util/CdcResendCommandTest.java | 2 +-
.../util/GridCommandHandlerClusterByClassTest.java | 1 -
...GridCommandHandlerTracingConfigurationTest.java | 394 -------
.../apache/ignite/util/SystemViewCommandTest.java | 4 +-
.../src/main/java/org/apache/ignite/Ignite.java | 3 +
.../org/apache/ignite/IgniteSystemProperties.java | 4 +
.../java/org/apache/ignite/IgniteTransactions.java | 5 +-
.../ignite/configuration/IgniteConfiguration.java | 15 +-
.../org/apache/ignite/events/DiscoveryEvent.java | 22 -
.../ignite/internal/CoreMessagesProvider.java | 669 +++++------
.../ignite/internal/DeferredUnmarshalMessage.java} | 18 +-
.../ignite/internal/GridEventConsumeHandler.java | 2 +-
.../ignite/internal/GridJobExecuteRequest.java | 65 +-
.../ignite/internal/GridJobExecuteResponse.java | 141 +--
.../ignite/internal/GridJobSiblingsResponse.java | 27 +-
.../apache/ignite/internal/GridKernalContext.java | 8 -
.../ignite/internal/GridKernalContextImpl.java | 18 +-
.../ignite/internal/GridTaskSessionRequest.java | 1 +
.../apache/ignite/internal/GridTopicMessage.java | 5 +-
.../ignite/internal/IgniteComponentType.java | 7 -
.../ignite/internal/IgniteDiagnosticRequest.java | 1 +
.../org/apache/ignite/internal/IgniteKernal.java | 45 +-
.../org/apache/ignite/internal/IgnitionEx.java | 6 +-
.../ignite/internal/MarshallableMessage.java | 12 +-
.../ignite/internal/MarshallerContextImpl.java | 34 +-
.../ignite/internal/SelfMarshallingMessage.java | 38 +
.../org/apache/ignite/internal/TxEntriesInfo.java | 26 +-
...ontextMessage.java => UseBinaryMarshaller.java} | 34 +-
.../marshaller/jdk/GridClientJdkMarshaller.java | 35 +-
.../optimized/GridClientOptimizedMarshaller.java | 4 +-
.../direct/stream/DirectByteBufferStream.java | 14 +-
.../internal/dto/IgniteDataTransferObject.java | 20 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 13 +-
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 2 +-
.../internal/management/IgniteCommandRegistry.java | 2 -
.../AbstractTracingConfigurationCommand.java | 49 -
.../tracing/TracingConfigurationCommand.java | 90 --
.../TracingConfigurationGetAllCommandArg.java | 61 -
.../tracing/TracingConfigurationGetCommand.java | 31 -
.../tracing/TracingConfigurationGetCommandArg.java | 76 --
.../tracing/TracingConfigurationItem.java | 150 ---
.../TracingConfigurationResetAllCommand.java | 37 -
.../tracing/TracingConfigurationResetCommand.java | 36 -
.../tracing/TracingConfigurationSetCommand.java | 34 -
.../tracing/TracingConfigurationSetCommandArg.java | 66 --
.../tracing/TracingConfigurationTask.java | 214 ----
.../tracing/TracingConfigurationTaskResult.java | 91 --
.../managers/communication/CompressedMessage.java | 4 +-
.../communication/CompressedMessageSerializer.java | 5 +
.../managers/communication/ErrorMessage.java | 5 +-
.../managers/communication/GridIoManager.java | 343 ++++--
.../managers/communication/GridIoMessage.java | 43 +-
.../managers/communication/GridIoUserMessage.java | 2 +
.../communication/IgniteIoTestMessage.java | 26 +-
.../communication/IgniteMessageFactory.java | 89 ++
.../communication/IgniteMessageFactoryImpl.java | 101 +-
.../managers/communication/MessageMarshalling.java | 140 +++
.../communication/MessageUnmarshalOnceCheck.java | 109 ++
.../communication/SessionChannelMessage.java | 2 -
.../managers/communication/TraceRunnable.java | 63 -
.../managers/discovery/GridDiscoveryManager.java | 33 +-
.../discovery/GridDiscoveryTopologySnapshot.java | 73 --
.../managers/eventstorage/EventsDataBagItem.java | 2 +
.../eventstorage/GridEventStorageManager.java | 29 +-
.../eventstorage/GridEventStorageMessage.java | 233 ----
.../eventstorage/GridEventStorageRequest.java | 141 +++
.../eventstorage/GridEventStorageResponse.java} | 61 +-
.../managers/tracing/GridTracingManager.java | 541 ---------
...AbstractMarshallableMessageFactoryProvider.java | 95 --
.../plugin/AbstractMessageFactoryProvider.java | 181 +++
.../processors/bulkload/BulkLoadProcessor.java | 36 +-
.../cache/CacheAffinitySharedManager.java | 7 -
.../internal/processors/cache/CacheData.java | 134 +--
.../processors/cache/CacheEntryPredicate.java | 14 -
.../cache/CacheEntryPredicateAdapter.java | 16 +-
.../processors/cache/CacheEvictionEntry.java | 2 +
.../internal/processors/cache/CacheGroupData.java | 103 +-
.../processors/cache/CacheInvokeDirectResult.java | 29 +-
.../cache/CacheNodeCommonDiscoveryData.java | 61 +-
.../processors/cache/CacheObjectByteArrayImpl.java | 4 +-
.../internal/processors/cache/CacheObjectImpl.java | 4 +-
...y.java => CacheObjectNotResolvedException.java} | 17 +-
.../processors/cache/ClusterCachesInfo.java | 16 +-
...eEntryPredicate.java => DeployableMessage.java} | 26 +-
.../cache/DynamicCacheChangeRequest.java | 41 +-
.../processors/cache/GridCacheAdapter.java | 48 +-
.../processors/cache/GridCacheDeployable.java | 4 +-
.../cache/GridCacheDeploymentManager.java | 4 +-
.../processors/cache/GridCacheEntryInfo.java | 70 +-
.../processors/cache/GridCacheIdMessage.java | 9 +-
.../processors/cache/GridCacheIoManager.java | 102 +-
.../processors/cache/GridCacheMapEntry.java | 4 +-
.../processors/cache/GridCacheMessage.java | 316 ++---
.../processors/cache/GridCacheMessageDeployer.java | 55 +
.../cache/GridCachePartitionExchangeManager.java | 24 -
.../processors/cache/GridCacheProcessor.java | 2 +-
.../internal/processors/cache/GridCacheReturn.java | 86 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 20 +-
.../processors/cache/KeyCacheObjectImpl.java | 7 +-
.../internal/processors/cache/StoredCacheData.java | 37 +-
.../cache/binary/BinaryMetadataVersionInfo.java | 29 +-
.../binary/MetadataUpdateProposedMessage.java | 22 +-
.../distributed/GridCacheTtlUpdateRequest.java | 29 +-
.../distributed/GridDistributedLockRequest.java | 24 +-
.../distributed/GridDistributedLockResponse.java | 19 +-
.../GridDistributedTxPrepareRequest.java | 100 +-
.../cache/distributed/GridNearUnlockRequest.java | 21 +-
.../cache/distributed/dht/GridDhtCacheAdapter.java | 4 +-
.../cache/distributed/dht/GridDhtLockFuture.java | 71 +-
.../cache/distributed/dht/GridDhtLockRequest.java | 81 +-
.../cache/distributed/dht/GridDhtLockResponse.java | 25 +-
.../distributed/dht/GridDhtTxFinishFuture.java | 104 +-
.../distributed/dht/GridDhtTxFinishResponse.java | 35 +-
.../cache/distributed/dht/GridDhtTxLocal.java | 2 +-
.../distributed/dht/GridDhtTxLocalAdapter.java | 2 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 253 ++--
.../distributed/dht/GridDhtTxPrepareRequest.java | 95 +-
.../distributed/dht/GridDhtTxPrepareResponse.java | 50 +-
.../cache/distributed/dht/GridDhtTxRemote.java | 2 +-
.../distributed/dht/GridDhtUnlockRequest.java | 17 +-
.../dht/PartitionUpdateCountersMessage.java | 37 +-
.../dht/TransactionAttributesAwareRequest.java | 14 +-
.../AtomicApplicationAttributesAwareRequest.java | 14 +-
.../atomic/GridDhtAtomicAbstractUpdateFuture.java | 7 -
.../atomic/GridDhtAtomicAbstractUpdateRequest.java | 27 -
.../distributed/dht/atomic/GridDhtAtomicCache.java | 39 +-
.../dht/atomic/GridDhtAtomicNearResponse.java | 18 -
.../atomic/GridDhtAtomicSingleUpdateFuture.java | 2 -
.../atomic/GridDhtAtomicSingleUpdateRequest.java | 82 +-
.../dht/atomic/GridDhtAtomicUpdateFuture.java | 2 -
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 158 +--
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 30 +-
.../atomic/GridNearAtomicAbstractUpdateFuture.java | 2 +-
.../atomic/GridNearAtomicFullUpdateRequest.java | 119 +-
.../GridNearAtomicSingleUpdateFilterRequest.java | 42 +-
.../atomic/GridNearAtomicSingleUpdateFuture.java | 6 +-
.../GridNearAtomicSingleUpdateInvokeRequest.java | 61 +-
.../atomic/GridNearAtomicSingleUpdateRequest.java | 32 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 6 +-
.../dht/atomic/GridNearAtomicUpdateResponse.java | 46 +-
.../distributed/dht/atomic/NearCacheUpdates.java | 2 +
.../cache/distributed/dht/atomic/UpdateErrors.java | 15 +-
.../dht/colocated/GridDhtColocatedLockFuture.java | 136 +--
.../dht/preloader/GridDhtForceKeysRequest.java | 23 +-
.../dht/preloader/GridDhtForceKeysResponse.java | 35 +-
.../preloader/GridDhtPartitionSupplyMessage.java | 23 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 65 +-
.../preloader/GridDhtPartitionsFullMessage.java | 33 +-
.../preloader/GridDhtPartitionsSingleMessage.java | 13 +-
.../dht/preloader/latch/ExchangeLatchManager.java | 30 +-
.../dht/topology/PartitionReservationManager.java | 71 +-
.../distributed/near/CacheVersionedValue.java | 48 +-
.../distributed/near/GridNearAtomicCache.java | 14 +-
.../cache/distributed/near/GridNearGetFuture.java | 2 -
.../cache/distributed/near/GridNearGetRequest.java | 87 +-
.../distributed/near/GridNearGetResponse.java | 30 +-
...dNearOptimisticSerializableTxPrepareFuture.java | 46 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 127 +-
.../GridNearOptimisticTxPrepareFutureAdapter.java | 55 +-
.../near/GridNearPessimisticTxPrepareFuture.java | 72 +-
.../distributed/near/GridNearSingleGetRequest.java | 27 +-
.../near/GridNearSingleGetResponse.java | 36 +-
.../distributed/near/GridNearTxFinishFuture.java | 133 +--
.../cache/distributed/near/GridNearTxLocal.java | 805 +++++++------
.../near/GridNearTxPrepareFutureAdapter.java | 8 +-
.../distributed/near/GridNearTxPrepareRequest.java | 27 +-
.../near/GridNearTxPrepareResponse.java | 143 +--
.../cache/distributed/near/GridNearTxRemote.java | 27 +-
.../near/KeyedVersionedValue.java} | 45 +-
.../cache/persistence/RecoveryDebug.java | 167 ---
.../cache/persistence/file/FileDownloader.java | 225 ----
.../cache/persistence/file/FileUploader.java | 94 --
.../cache/persistence/filename/FileTreeUtils.java | 25 +-
.../partstate/PartitionRecoverState.java | 52 -
.../snapshot/IncrementalSnapshotAwareMessage.java | 13 -
.../snapshot/IncrementalSnapshotVerifyResult.java | 2 +-
.../wal/reader/StandaloneGridKernalContext.java | 10 +-
.../cache/query/GridCacheQueryRequest.java | 134 +--
.../cache/query/GridCacheQueryResponse.java | 106 +-
.../continuous/CacheContinuousQueryEntry.java | 99 +-
.../CacheContinuousQueryEventBuffer.java | 6 +-
.../continuous/CacheContinuousQueryHandler.java | 18 +-
.../continuous/CacheContinuousQueryManager.java | 28 +-
.../cache/transactions/IgniteTransactionsImpl.java | 28 +-
.../cache/transactions/IgniteTxEntry.java | 116 +-
.../cache/transactions/IgniteTxHandler.java | 545 +++++----
.../processors/cache/transactions/IgniteTxKey.java | 29 +-
.../cache/transactions/IgniteTxLocalAdapter.java | 4 +-
.../cache/transactions/IgniteTxManager.java | 8 +-
.../cache/transactions/TransactionProxyImpl.java | 200 ++--
.../cache/transactions/TxDeadlockDetection.java | 5 +-
.../cache/transactions/TxEntryValueHolder.java | 24 +-
.../cache/transactions/TxLocksRequest.java | 54 +-
.../cache/transactions/TxLocksResponse.java | 100 +-
.../cache/verify/PartitionHashRecord.java | 31 +-
.../cache/verify/TransactionsHashRecord.java | 22 +-
.../cluster/BaselineStateAndHistoryData.java | 53 +
.../cluster/BaselineTopologyHistory.java | 18 +-
.../cluster/BaselineTopologyHistoryItem.java | 41 +-
.../cluster/ChangeGlobalStateMessage.java | 22 +-
.../cluster/DiscoveryDataClusterState.java | 180 +--
.../cluster/GridClusterStateProcessor.java | 34 +-
.../continuous/GridContinuousMessage.java | 3 +-
.../continuous/GridContinuousProcessor.java | 17 +-
.../processors/continuous/StartRequestData.java | 4 +-
.../datastreamer/DataStreamProcessor.java | 14 +
.../processors/datastreamer/DataStreamerEntry.java | 2 +
.../processors/datastreamer/DataStreamerImpl.java | 6 +-
.../datastreamer/DataStreamerRequest.java | 11 +-
.../datastreamer/DataStreamerResponse.java | 1 -
.../datastreamer/DataStreamerUpdateJob.java | 4 +-
.../internal/processors/job/GridJobProcessor.java | 27 +-
.../internal/processors/job/GridJobWorker.java | 39 +-
.../DistributedMetaStorageCasMessage.java | 8 +-
.../DistributedMetaStorageClusterNodeData.java | 104 +-
.../DistributedMetaStorageHistoryItem.java | 21 +-
.../DistributedMetaStorageHistoryItemMessage.java | 67 ++
.../persistence/DistributedMetaStorageImpl.java | 161 ++-
.../DistributedMetaStorageJoiningNodeData.java | 61 +-
.../DistributedMetaStorageKeyValuePair.java | 70 --
.../DistributedMetaStorageUpdateMessage.java | 4 +-
.../persistence/DistributedMetaStorageVersion.java | 2 +-
.../metastorage/persistence/DmsDataWriter.java | 26 +-
...InMemoryCachedDistributedMetaStorageBridge.java | 16 +-
.../processors/odbc/ClientListenerNioListener.java | 2 +-
.../processors/platform/utils/PlatformUtils.java | 2 +-
.../processors/plugin/PluginsDataBagItem.java | 22 +-
.../internal/processors/pool/PoolProcessor.java | 2 +-
.../query/running/GridRunningQueryInfo.java | 13 -
.../query/running/RunningQueryManager.java | 159 ++-
.../query/schema/message/QueryEntityMessage.java | 27 +-
.../operation/SchemaAddQueryEntityOperation.java | 2 +-
.../resource/GridResourceSupplierInjector.java | 64 -
.../rest/handlers/task/GridTaskResultResponse.java | 26 +-
.../rest/protocols/tcp/GridTcpRestParser.java | 11 +-
.../rest/protocols/tcp/GridTcpRestProtocol.java | 15 +-
.../rollingupgrade/RollingUpgradeClusterData.java | 22 +-
.../rollingupgrade/RollingUpgradeProcessor.java | 11 +-
.../feature/IgniteComponentFeatureSet.java | 4 +-
.../feature/IgniteCoreFeatureSet.java | 2 +-
.../feature/IgniteFeatureManager.java | 42 +-
.../security/IgniteSecurityProcessor.java | 4 +-
.../security/SecurityContextWrapper.java | 6 +-
.../processors/service/IgniteServiceProcessor.java | 2 +-
.../service/LazyServiceConfiguration.java | 28 +
.../service/LazyServiceConfigurationMessage.java | 127 ++
.../service/ServiceDeploymentRequest.java | 36 +-
.../internal/processors/service/ServiceInfo.java | 65 +-
.../ServiceProcessorCommonDiscoveryData.java | 31 +-
.../ServiceProcessorJoinNodeDiscoveryData.java | 35 +-
.../service/ServiceSingleNodeDeploymentResult.java | 4 +-
.../processors/service/ServiceTopology.java | 30 +-
.../processors/task/GridTaskProcessor.java | 9 +-
.../internal/processors/task/GridTaskWorker.java | 11 +-
.../internal/processors/tracing/DeferredSpan.java | 91 --
.../internal/processors/tracing/NoopTracing.java | 49 -
.../internal/processors/tracing/SpanImpl.java | 104 --
.../processors/tracing/TraceableIterator.java | 66 --
.../internal/processors/tracing/Tracing.java | 45 -
.../DistributedTracingConfiguration.java | 56 -
.../GridTracingConfigurationManager.java | 222 ----
.../NoopTracingConfigurationManager.java | 6 +-
.../processors/tracing/messages/SpanContainer.java | 82 --
.../tracing/messages/TraceableMessage.java | 28 -
.../tracing/messages/TraceableMessagesHandler.java | 106 --
.../tracing/messages/TraceableMessagesTable.java | 88 --
...te.java => DistributedAttributeIdRegistry.java} | 21 +-
.../thread/context/OperationContextDispatcher.java | 101 +-
.../context/OperationContextSnapshotMessage.java | 93 ++
.../util/GridCloseableIteratorAdapterEx.java | 127 --
.../ignite/internal/util/GridCollections.java | 650 -----------
.../util/GridConcurrentPhantomHashSet.java | 408 -------
.../internal/util/GridFixedSizeInputStream.java | 86 --
.../org/apache/ignite/internal/util/GridMutex.java | 57 -
.../ignite/internal/util/GridSerializableList.java | 33 -
.../util/GridSpiCloseableIteratorWrapper.java | 62 -
.../ignite/internal/util/GridSynchronizedMap.java | 102 --
.../ignite/internal/util/GridWeakIterator.java | 55 -
.../internal/util/future/IgniteRemoteMapTask.java | 143 ---
.../util/io/GridReversedLinesFileReader.java | 367 ------
.../util/lang/GridPeerDeployAwareAdapter.java | 69 --
.../util/lang/gridfunc/LongSumReducer.java | 51 -
.../util/lang/gridfunc/MapFactoryCallable.java | 41 -
.../util/lang/gridfunc/TransformMapView2.java | 161 ---
.../ignite/internal/visor/VisorTaskArgument.java | 53 +
.../extensions/communication/CacheIdAware.java} | 20 +-
.../communication/MessageFactoryProvider.java | 3 +-
.../extensions/communication/MessageFormatter.java | 4 +-
.../communication/MessageMarshaller.java | 75 ++
.../communication/NonMarshallableMessage.java} | 10 +-
.../security/SecurityBasicPermissionSet.java | 52 +-
.../plugin/security/SecurityPermissionSet.java | 3 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 33 +-
.../spi/communication/tcp/TcpCommunicationSpi.java | 4 -
.../tcp/internal/GridNioServerWrapper.java | 58 +-
.../tcp/internal/InboundConnectionHandler.java | 9 -
.../TcpCommunicationConfigInitializer.java | 7 -
.../tcp/internal/TcpHandshakeExecutor.java | 10 +-
.../TcpInverseConnectionResponseMessage.java | 1 -
.../spi/discovery/DiscoveryNotification.java | 16 +-
.../discovery/SerializableDataBagItemWrapper.java | 4 +-
.../discovery/isolated/IsolatedDiscoverySpi.java | 6 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 486 ++++----
.../ignite/spi/discovery/tcp/ServerImpl.java | 257 +----
.../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 10 -
.../spi/discovery/tcp/TcpDiscoveryIoSession.java | 17 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 6 +-
.../discovery/tcp/internal/TcpDiscoveryNode.java | 35 +-
.../tcp/messages/TcpDiscoveryAbstractMessage.java | 20 +-
.../TcpDiscoveryAbstractTraceableMessage.java | 95 --
.../messages/TcpDiscoveryCustomEventMessage.java | 2 +-
.../messages/TcpDiscoveryJoinRequestMessage.java | 2 +-
.../TcpDiscoveryNodeAddFinishedMessage.java | 23 +-
.../tcp/messages/TcpDiscoveryNodeAddedMessage.java | 2 +-
.../messages/TcpDiscoveryNodeFailedMessage.java | 2 +-
.../tcp/messages/TcpDiscoveryNodeLeftMessage.java | 2 +-
.../spi/systemview/view/ClientConnectionView.java | 14 +
.../ignite/spi/tracing/NoopSpiSpecificSpan.java | 4 +
.../apache/ignite/spi/tracing/NoopTracingSpi.java | 10 +-
.../apache/ignite/spi/tracing/SpiSpecificSpan.java | 4 +
.../tracing/TracingConfigurationCoordinates.java | 26 +
.../spi/tracing/TracingConfigurationManager.java | 4 +
.../tracing/TracingConfigurationParameters.java | 31 +-
.../org/apache/ignite/spi/tracing/TracingSpi.java | 4 +
.../ignite/stream/socket/SocketStreamer.java | 3 +-
.../main/resources/META-INF/classnames.properties | 26 -
.../test/config/class_list_exploit_included.txt | 2 +-
.../org/apache/ignite/cdc/CdcCacheVersionTest.java | 2 +-
.../org/apache/ignite/client/IgniteBinaryTest.java | 23 +
.../internal/GridAffinityNoCacheSelfTest.java | 4 +-
.../internal/MarshallerContextLockingSelfTest.java | 2 +-
.../internal/TestManagementVisorOneNodeTask.java | 10 +-
.../internal/TestRecordingCommunicationSpi.java | 20 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 51 +-
.../GridBinaryMarshallerCtxDisabledSelfTest.java | 6 -
.../binary/RawBinaryObjectExtractorTest.java | 6 -
.../internal/codegen/MessageProcessorTest.java | 308 ++++-
.../direct/DirectMarshallingMessagesTest.java | 9 +-
...irectByteBufferStreamImplByteOrderSelfTest.java | 12 +-
.../managers/AbstractMessageSerializationTest.java | 5 +-
.../IgniteCoreMessagesSerializationTest.java | 3 +-
.../communication/CompressedMessageTest.java | 7 +-
.../communication/ErrorMessageSelfTest.java | 4 +-
.../GridCommunicationSendMessageSelfTest.java | 7 +-
.../GridIoManagerOrderedUnmarshalFailureTest.java | 257 +++++
.../IgniteMessageFactoryImplTest.java | 17 +-
.../MessageDirectTypeIdConflictTest.java | 5 +-
...MessageFactoryMarshallerInitializationTest.java | 11 +-
.../internal/metric/SystemViewClientTest.java | 41 +
.../cache/CacheMetricsCacheSizeTest.java | 7 +-
.../cache/ClientSlowDiscoveryAbstractTest.java | 2 -
.../cache/GridCacheEntryMemorySizeSelfTest.java | 5 -
.../cache/GridCacheIoManagerRetryTest.java | 17 +-
.../cache/IgniteIncompleteCacheObjectSelfTest.java | 4 +-
...teMarshallerCacheClientRequestsMappingTest.java | 4 -
...IgniteExchangeLatchManagerDiscoHistoryTest.java | 296 -----
.../dht/PartitionUpdateCountersMessageTest.java | 118 ++
...IgniteExchangeLatchManagerDiscoHistoryTest.java | 71 ++
.../near/GridNearTxPrepareDestroyedCacheTest.java | 196 ++++
.../near/GridNearTxRecreateEvictionTest.java | 136 +++
.../db/IgniteSequentialNodeCrashRecoveryTest.java | 2 -
.../cache/persistence/file/FileDownloaderTest.java | 118 --
.../snapshot/IgniteSnapshotManagerSelfTest.java | 134 +++
.../snapshot/IncrementalSnapshotTest.java | 16 +-
.../snapshot/dump/IgniteCacheDumpSelf2Test.java | 2 +-
.../IncrementalSnapshotJoiningClientTest.java | 2 -
.../query/GridCacheQueryResponseUnmarshalTest.java | 85 ++
...niteCacheContinuousQueryImmutableEntryTest.java | 85 +-
.../TxDeadlockDetectionMessageMarshallingTest.java | 7 +-
.../processors/database/CacheFreeListSelfTest.java | 4 +-
.../datastreamer/DataStreamerImplSelfTest.java | 12 +-
.../DistributedMetaStorageClassloadingTest.java | 96 +-
.../metastorage/DistributedMetaStorageTest.java | 20 +-
.../metastorage/persistence/DmsDataWriterTest.java | 14 +-
...moryCachedDistributedMetaStorageBridgeTest.java | 27 +-
.../query/schema/IndexWithSameNameTestBase.java | 2 -
.../QueryEntityMessageSerializationTest.java | 85 +-
.../rollingupgrade/AbstractRollingUpgradeTest.java | 111 +-
.../CoreVersionRollingUpgradeTest.java | 67 +-
.../PluginVersionRollingUpgradeTest.java | 11 +-
.../ManagementApiVersionValidationTest.java | 108 ++
.../feature/TestIgniteReleaseFeatures_2_19_1.java | 3 -
.../feature/TestIgniteReleaseFeatures_2_19_2.java | 2 +-
.../security/TaskNameResolutionTest.java | 55 +
...rviceConfigurationMessageSerializationTest.java | 182 +++
.../OperationContextAttributePropagationTest.java | 421 +++++++
.../OperationContextSendAttributesTest.java | 278 -----
.../nio/IgniteExceptionInNioWorkerSelfTest.java | 54 +-
.../TcpCommunicationSpiSslVolatilePayloadTest.java | 4 +-
.../marshaller/MarshallerContextSelfTest.java | 2 +-
.../marshaller/MarshallerContextTestImpl.java | 2 +-
.../marshaller/ObjectInputStreamFilteringTest.java | 27 -
.../p2p/ClassLoadingProblemExceptionTest.java | 3 +-
.../communication/MessageMarshalOnceTest.java | 267 +++++
.../MessageUnmarshalOnceCheckTest.java | 74 ++
...ecurityBasicPermissionSetSerializationTest.java | 149 +++
.../security/SecurityPermissionSetBuilderTest.java | 2 +-
.../apache/ignite/spi/MessagesPluginProvider.java | 22 +-
.../GridAbstractCommunicationSelfTest.java | 2 +-
.../communication/GridCacheMessageSelfTest.java | 10 +-
.../ignite/spi/communication/GridTestMessage.java | 2 +-
...pCommunicationSpiConcurrentConnectSelfTest.java | 2 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 2 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 2 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 2 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 2 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 2 +-
.../TcpCommunicationSpiSkipMessageSendTest.java | 2 +-
.../spi/communication/tcp/TestDelayMessage.java | 32 +-
...essage.java => TestDelayMessageSerializer.java} | 50 +-
.../spi/discovery/tcp/BlockTcpDiscoverySpi.java | 2 -
.../tcp/DiscoveryDeserializationExceptionTest.java | 2 +-
.../tcp/DiscoveryUnmarshalVulnerabilityTest.java | 308 +++--
.../ignite/spi/discovery/tcp/ExploitMessage.java | 4 +-
...cpClientDiscoverySpiFailureTimeoutSelfTest.java | 3 +-
.../tcp/TcpDiscoveryClientTopologyGapTest.java | 135 +++
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 77 +-
.../tcp/TcpDiscoverySslSecuredUnsecuredTest.java | 3 +-
.../spi/discovery/tcp/TestTcpDiscoverySpi.java | 7 +-
.../SocketStreamerUnmarshalVulnerabilityTest.java | 246 ++--
.../ignite/testframework/GridSpiTestContext.java | 4 +-
.../apache/ignite/testframework/GridTestUtils.java | 37 +-
.../testframework/junits/GridAbstractTest.java | 2 +
.../junits/GridTestKernalContext.java | 3 +-
.../ignite/testframework/junits/IgniteMock.java | 4 +-
.../junits/common/GridCommonAbstractTest.java | 10 +-
.../ignite/testsuites/IgniteBasicTestSuite.java | 10 +
.../ignite/testsuites/IgniteCacheTestSuite10.java | 2 +
.../ignite/testsuites/IgniteCacheTestSuite16.java | 2 +-
.../ignite/testsuites/IgniteCacheTestSuite2.java | 4 +
.../ignite/testsuites/IgnitePdsTestSuite4.java | 2 -
.../testsuites/IgniteServiceGridTestSuite.java | 4 +-
.../IgniteSpiDiscoverySelfTestSuite2.java | 10 +-
.../testsuites/IgniteStreamSelfTestSuite.java | 7 +-
.../ignite/testsuites/SecurityTestSuite.java | 8 +-
.../resources/codegen/ChildMessageSerializer.java | 11 +-
...ustomEnumMapperOnNonEnumCollectionMessage.java} | 11 +-
...va => CustomEnumMapperOnNonEnumMapMessage.java} | 11 +-
.../codegen/CustomMapperEnumFieldsMessage.java | 7 +-
.../CustomMapperEnumFieldsMessageSerializer.java | 34 +-
.../codegen/DefaultMapperEnumFieldsMessage.java | 9 +
.../DefaultMapperEnumFieldsMessageSerializer.java | 57 +-
... => DefaultMapperEnumMapCollectionMessage.java} | 9 +-
...dsMessage.java => NioFieldNeedsCtxMessage.java} | 20 +-
.../codegen/NioFieldOnNonMessageMessage.java} | 18 +-
...mFieldsMessage.java => TestCacheIdMessage.java} | 25 +-
.../codegen/TestCacheIdMessageDeployer.java} | 40 +-
.../resources/codegen/TestCollectionsMessage.java | 4 +
.../codegen/TestCollectionsMessageMarshaller.java | 57 +
.../codegen/TestCollectionsMessageSerializer.java | 77 +-
.../resources/codegen/TestDeployableMessage.java} | 35 +-
.../codegen/TestDeployableMessageDeployer.java} | 36 +-
.../src/test/resources/codegen/TestMapMessage.java | 5 +
.../codegen/TestMapMessageMarshaller.java | 84 ++
.../codegen/TestMapMessageSerializer.java | 77 +-
.../resources/codegen/TestMarshallableMessage.java | 7 +-
.../codegen/TestMarshallableMessageMarshaller.java | 50 +
...java => TestMarshallableMessageSerializer.java} | 38 +-
.../codegen/TestMarshalledArrayMapMessage.java} | 35 +-
.../TestMarshalledArrayMapMessageMarshaller.java | 156 +++
...> TestMarshalledArrayMapMessageSerializer.java} | 45 +-
...e.java => TestMarshalledCollectionMessage.java} | 13 +-
.../TestMarshalledCollectionMessageMarshaller.java | 55 +
...TestMarshalledCollectionMessageSerializer.java} | 26 +-
...sMessage.java => TestMarshalledMapMessage.java} | 14 +-
.../TestMarshalledMapMessageMarshaller.java | 64 +
...ava => TestMarshalledMapMessageSerializer.java} | 31 +-
.../resources/codegen/TestMarshalledMessage.java} | 20 +-
.../codegen/TestMarshalledMessageMarshaller.java | 56 +
...r.java => TestMarshalledMessageSerializer.java} | 23 +-
...sage.java => TestMarshalledObjectsMessage.java} | 12 +-
.../TestMarshalledObjectsMessageMarshaller.java | 78 ++
...=> TestMarshalledObjectsMessageSerializer.java} | 25 +-
.../src/test/resources/codegen/TestMessage.java | 5 +
.../resources/codegen/TestMessageMarshaller.java | 63 +
.../resources/codegen/TestMessageSerializer.java | 31 +-
...dsMessage.java => TestNestedDeployMessage.java} | 14 +-
.../codegen/TestNestedDeployMessageDeployer.java} | 27 +-
...eldsMessage.java => TestNoCacheCtxMessage.java} | 15 +-
...essage.java => TestSelfMarshallingMessage.java} | 18 +-
.../TestSelfMarshallingMessageMarshaller.java} | 30 +-
...a => TestSelfMarshallingMessageSerializer.java} | 25 +-
...a => TwoDifferentEnumsInCollectionMessage.java} | 10 +-
...ssage.java => WrongNonMarshallableMessage.java} | 13 +-
.../codegen/WrongSelfMarshallingMessage.java} | 24 +-
...ridCommandHandlerClusterByClassTest_help.output | 66 --
...andHandlerClusterByClassWithSSLTest_help.output | 66 --
.../ducktest/tests/dto/IndexedDataRecord.java | 96 ++
.../internal/ducktest/tests/mdc/LoadMode.java} | 50 +-
.../tests/mdc/MdcCacheAwareApplication.java | 177 +++
.../tests/mdc/MdcContinuousLoadApplication.java | 304 +++++
.../tests/mdc/MdcDataCheckerApplication.java | 72 ++
.../tests/mdc/MdcDataGeneratorApplication.java | 76 ++
.../tests/mdc/MdcThinClientLoadApplication.java | 145 +++
.../DataLoaderAndCheckerApplication.java | 68 +-
.../ignite/internal/ducktest/utils/OpStats.java | 66 ++
.../ignite/internal/ducktest/utils/Utils.java | 84 ++
.../checks/services/network_group/check_manager.py | 141 +++
.../tests/checks/utils/check_cache_distribution.py | 128 ++
modules/ducktests/tests/docker/Dockerfile | 1 +
modules/ducktests/tests/docker/requirements.txt | 1 +
modules/ducktests/tests/docker/run_tests.sh | 5 +
.../tests/ignitetest/services/ignite_app.py | 16 +-
.../tests/ignitetest/services/mdc/__init__.py} | 9 +-
.../tests/ignitetest/services/mdc/mdc_cluster.py | 559 +++++++++
.../services/network_group/__init__.py} | 9 +-
.../services/network_group/configuration.py | 64 +
.../ignitetest/services/network_group/manager.py | 476 ++++++++
.../services/network_group/tc_rule_args.py | 135 +++
.../services/utils/cdc/kafka_to_ignite.py | 2 +-
.../ignitetest/services/utils/control_utility.py | 142 ++-
.../ignitetest/services/utils/ignite_aware.py | 22 +
.../utils/ignite_configuration/__init__.py | 1 +
.../utils/ignite_configuration/communication.py | 4 +-
.../tests/ignitetest/services/utils/ignite_spec.py | 2 +
.../tests/ignitetest/services/utils/log_utils.py | 14 +-
.../utils/templates/ignite_configuration_macro.j2 | 1 +
.../tests/control_utility/baseline_test.py | 12 +-
.../tests/ignitetest/tests/index_rebuild_test.py | 4 +-
.../tests/mdc/__init__.py} | 6 +-
.../tests/mdc/partition_resilience_test.py | 215 ++++
.../tests/ignitetest/tests/mdc/thin_client_test.py | 156 +++
.../tests/mdc/transactional_partition_test.py | 154 +++
.../processors/query/h2/CommandProcessor.java | 2 +-
.../processors/query/h2/H2FieldsIterator.java | 7 +-
.../processors/query/h2/H2ResultSetIterator.java | 25 +-
.../processors/query/h2/IgniteH2Indexing.java | 182 ++-
.../internal/processors/query/h2/QueryParser.java | 16 +-
.../processors/query/h2/RegisteredQueryCursor.java | 61 +-
.../processors/query/h2/database/H2TreeIndex.java | 181 ++-
.../processors/query/h2/dml/DmlBatchSender.java | 35 +-
.../internal/processors/query/h2/dml/DmlUtils.java | 39 +-
.../query/h2/twostep/AbstractReducer.java | 53 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 233 ++--
.../query/h2/twostep/GridReduceQueryExecutor.java | 106 +-
.../query/h2/twostep/ReduceIndexIterator.java | 17 +-
.../query/h2/twostep/msg/GridH2CacheObject.java | 4 +-
.../query/h2/twostep/msg/GridH2Null.java | 2 +-
.../query/h2/twostep/msg/GridH2ValueMessage.java | 4 +-
.../h2/twostep/msg/GridH2ValueMessageFactory.java | 61 +-
.../cache/metric/SqlViewExporterSpiTest.java | 13 +-
.../internal/jackson/IgniteObjectMapper.java | 7 +-
.../ignite/internal/processors/tracing/MTC.java | 114 --
.../internal/processors/tracing/NoopSpan.java | 74 --
.../processors/tracing/NoopSpanManager.java | 58 -
.../ignite/internal/processors/tracing/Span.java | 85 --
.../internal/processors/tracing/SpanManager.java | 80 --
.../internal/processors/tracing/SpanTags.java | 127 --
.../internal/processors/tracing/SpanType.java | 329 ------
.../processors/tracing/messages/SpanTransport.java | 35 -
.../ignite/internal/util/nio/GridDirectParser.java | 5 +-
.../util/nio/GridNioMessageReaderFactory.java | 3 +-
.../ignite/internal/util/nio/GridNioServer.java | 161 +--
.../internal/util/nio/GridNioTracerFilter.java | 126 --
.../util/nio/GridSelectorNioSessionImpl.java | 14 -
.../internal/util/nio/MessageSerialization.java | 68 ++
.../internal/util/nio/SessionWriteRequest.java | 8 -
.../plugin/extensions/communication/Message.java | 38 +-
.../communication/MessageCollectionItemType.java | 5 +-
.../extensions/communication/MessageEnumType.java} | 47 +-
.../extensions/communication/MessageFactory.java | 24 +-
.../extensions/communication/MessageRegistry.java | 73 ++
.../communication/MessageSerializer.java | 8 +-
modules/opencensus/pom.xml | 13 -
.../exporter/trace/TimeLimitedHandler.java | 146 ---
.../tracing/opencensus/OpenCensusSpanAdapter.java | 82 --
.../opencensus/OpenCensusTraceExporter.java | 68 --
.../tracing/opencensus/OpenCensusTracingSpi.java | 159 ---
.../spi/tracing/opencensus/StatusMatchTable.java | 56 -
.../ignite/TracingConfigurationValidationTest.java | 122 --
.../monitoring/opencensus/AbstractTracingTest.java | 507 --------
.../opencensus/IgniteOpenCensusSuite.java | 15 +-
.../monitoring/opencensus/MixedTracingSpiTest.java | 126 --
.../opencensus/OpenCensusDiscoveryTracingTest.java | 339 ------
.../opencensus/OpenCensusSqlJdbcTracingTest.java | 222 ----
.../opencensus/OpenCensusSqlNativeTracingTest.java | 787 -------------
.../OpenCensusTracingConfigurationGetAllTest.java | 106 --
.../OpenCensusTracingConfigurationGetTest.java | 149 ---
...OpenCensusTracingConfigurationResetAllTest.java | 98 --
.../OpenCensusTracingConfigurationResetTest.java | 154 ---
.../opencensus/OpenCensusTracingSpiTest.java | 374 ------
.../OpenCensusTxTracingConfigurationTest.java | 294 -----
.../opencensus/OpenCensusTxTracingTest.java | 1084 -----------------
modules/platforms/cpp/core-test/CMakeLists.txt | 3 +-
.../platforms/cpp/core-test/src/classpath_test.cpp | 89 ++
.../platforms/cpp/core/src/jni/os/linux/utils.cpp | 4 +
.../platforms/cpp/core/src/jni/os/win/utils.cpp | 4 +
.../client/thin/ClientChannelConfiguration.java | 9 +-
.../ignite/internal/client/thin/ClientUtils.java | 5 +-
.../internal/client/thin/ReliableChannelImpl.java | 37 +-
.../internal/client/thin/TcpIgniteClient.java | 13 +-
.../zk/internal/DiscoveryMessageParser.java | 32 +-
.../zk/internal/ZkDiscoveryCustomEventData.java | 4 +-
.../discovery/zk/internal/ZkMessageFactory.java | 20 +-
.../ZkOperationContextAwareCustomMessage.java | 16 +-
.../zk/internal/ZookeeperDiscoveryImpl.java | 34 +-
.../zk/ZookeeperDiscoverySpiTestSuite4.java | 4 +-
.../ZkOperationContextSendAttributesTest.java | 32 -
parent/pom.xml | 9 +-
711 files changed, 20770 insertions(+), 25118 deletions(-)
delete mode 100644
docs/_docs/code-snippets/java/src/main/java/org/apache/ignite/snippets/Tracing.java
delete mode 100644 docs/_docs/code-snippets/xml/tracing.xml
delete mode 100644 docs/_docs/monitoring-metrics/tracing.adoc
create mode 100644
docs/_docs/perf-and-troubleshooting/images/healthy-cluster-checkpoint-jconsole.png
create mode 100644
docs/_docs/perf-and-troubleshooting/images/healthy-cluster-queues-jconsole.png
delete mode 100644
modules/benchmarks/src/main/java/org/apache/ignite/internal/benchmarks/jmh/misc/JmhTracingContextBenchmark.java
rename modules/binary/{api/src/main/java/org/apache/ignite/marshaller =>
impl/src/main/java/org/apache/ignite/marshaller/jdk}/IgniteObjectInputFilter.java
(72%)
rename modules/calcite/src/main/java/org/apache/{calcite/adapter/enumerable =>
ignite/internal/processors/query/calcite/exec}/FetchOffsetRoundingPolicy.java
(88%)
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/CollectIntegrationTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMessageUnmarshalThreadIntegrationTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/DynamicParametersPlannerTest.java
create mode 100644
modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorClassFilterTest.java
create mode 100644
modules/codegen/src/main/java/org/apache/ignite/internal/Marshalled.java
create mode 100644
modules/codegen/src/main/java/org/apache/ignite/internal/MessageCompanionGenerator.java
create mode 100644
modules/codegen/src/main/java/org/apache/ignite/internal/MessageDeploymentGenerator.java
create mode 100644
modules/codegen/src/main/java/org/apache/ignite/internal/MessageMarshallerGenerator.java
copy
modules/{core/src/test/resources/codegen/DefaultMapperEnumFieldsMessage.java =>
codegen/src/main/java/org/apache/ignite/internal/NioField.java} (62%)
create mode 100644 modules/compatibility/DEVNOTES.md
create mode 100644
modules/compatibility/src/test/java/org/apache/ignite/compatibility/ru/IgniteRebalanceOnUpgradeTest.java
create mode 100644
modules/compatibility/src/test/java/org/apache/ignite/compatibility/testframework/testcontainers/ContainerAddressResolver.java
create mode 100644
modules/compatibility/src/test/java/org/apache/ignite/compatibility/testframework/testcontainers/IgniteClusterContainer.java
create mode 100644
modules/compatibility/src/test/java/org/apache/ignite/compatibility/testframework/testcontainers/IgniteContainer.java
copy
modules/{core/src/test/java/org/apache/ignite/testsuites/IgniteStreamSelfTestSuite.java
=>
compatibility/src/test/java/org/apache/ignite/compatibility/testsuites/IgniteRollingUpgradeDockerTestSuite.java}
(73%)
create mode 100755
modules/compatibility/src/test/resources/docker/build_distrib.sh
create mode 100755
modules/compatibility/src/test/resources/docker/build_docker_image.sh
create mode 100644
modules/compatibility/src/test/resources/docker/test-config.xml
create mode 100644 modules/compatibility/src/test/resources/log4j2-test.xml
delete mode 100644
modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerTracingConfigurationTest.java
copy
modules/core/src/{test/resources/codegen/DefaultMapperEnumFieldsMessage.java =>
main/java/org/apache/ignite/internal/DeferredUnmarshalMessage.java} (68%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/SelfMarshallingMessage.java
copy
modules/core/src/main/java/org/apache/ignite/internal/{OperationContextMessage.java
=> UseBinaryMarshaller.java} (56%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/AbstractTracingConfigurationCommand.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationCommand.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationGetAllCommandArg.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationGetCommand.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationGetCommandArg.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationItem.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationResetAllCommand.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationResetCommand.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationSetCommand.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationSetCommandArg.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationTask.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationTaskResult.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IgniteMessageFactory.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/MessageMarshalling.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/MessageUnmarshalOnceCheck.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/TraceRunnable.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryTopologySnapshot.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageRequest.java
copy
modules/core/src/main/java/org/apache/ignite/internal/{processors/datastreamer/DataStreamerResponse.java
=> managers/eventstorage/GridEventStorageResponse.java} (53%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/tracing/GridTracingManager.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/plugin/AbstractMarshallableMessageFactoryProvider.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/plugin/AbstractMessageFactoryProvider.java
rename
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/{persistence/file/UnzipFileIOFactory.java
=> CacheObjectNotResolvedException.java} (63%)
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/{CacheEntryPredicate.java
=> DeployableMessage.java} (60%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessageDeployer.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/{CacheEvictionEntry.java
=> distributed/near/KeyedVersionedValue.java} (54%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/RecoveryDebug.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/file/FileDownloader.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/file/FileUploader.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/partstate/PartitionRecoverState.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/BaselineStateAndHistoryData.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageHistoryItemMessage.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageKeyValuePair.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/resource/GridResourceSupplierInjector.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/service/LazyServiceConfigurationMessage.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/DeferredSpan.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/NoopTracing.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/SpanImpl.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/TraceableIterator.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/Tracing.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/configuration/DistributedTracingConfiguration.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/configuration/GridTracingConfigurationManager.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/messages/SpanContainer.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/messages/TraceableMessage.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/messages/TraceableMessagesHandler.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/tracing/messages/TraceableMessagesTable.java
rename
modules/core/src/main/java/org/apache/ignite/internal/thread/context/{DistributedOperationContextAttribute.java
=> DistributedAttributeIdRegistry.java} (68%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/thread/context/OperationContextSnapshotMessage.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridCloseableIteratorAdapterEx.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridCollections.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentPhantomHashSet.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridFixedSizeInputStream.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridMutex.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableList.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridSpiCloseableIteratorWrapper.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridSynchronizedMap.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/GridWeakIterator.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteRemoteMapTask.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/io/GridReversedLinesFileReader.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAwareAdapter.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/LongSumReducer.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/MapFactoryCallable.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView2.java
rename
modules/{commons/src/main/java/org/apache/ignite/internal/util/ClassCache.java
=>
core/src/main/java/org/apache/ignite/plugin/extensions/communication/CacheIdAware.java}
(64%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageMarshaller.java
rename
modules/{opencensus/src/main/java/org/apache/ignite/spi/tracing/opencensus/package-info.java
=>
core/src/main/java/org/apache/ignite/plugin/extensions/communication/NonMarshallableMessage.java}
(79%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryAbstractTraceableMessage.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/managers/communication/GridIoManagerOrderedUnmarshalFailureTest.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteExchangeLatchManagerDiscoHistoryTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/PartitionUpdateCountersMessageTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/IgniteExchangeLatchManagerDiscoHistoryTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareDestroyedCacheTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxRecreateEvictionTest.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/file/FileDownloaderTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponseUnmarshalTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/rollingupgrade/feature/ManagementApiVersionValidationTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/security/TaskNameResolutionTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/service/LazyServiceConfigurationMessageSerializationTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/thread/context/OperationContextAttributePropagationTest.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/thread/context/OperationContextSendAttributesTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/plugin/extensions/communication/MessageMarshalOnceTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/plugin/extensions/communication/MessageUnmarshalOnceCheckTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/plugin/security/SecurityBasicPermissionSetSerializationTest.java
copy
modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/{TestDelayMessage.java
=> TestDelayMessageSerializer.java} (55%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryClientTopologyGapTest.java
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
CustomEnumMapperOnNonEnumCollectionMessage.java} (80%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
CustomEnumMapperOnNonEnumMapMessage.java} (80%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
DefaultMapperEnumMapCollectionMessage.java} (84%)
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessage.java =>
NioFieldNeedsCtxMessage.java} (73%)
rename
modules/core/src/{main/java/org/apache/ignite/internal/processors/cache/CachePeekModes.java
=> test/resources/codegen/NioFieldOnNonMessageMessage.java} (75%)
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessage.java =>
TestCacheIdMessage.java} (60%)
copy
modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteContextMarshallableMessage.java
=> core/src/test/resources/codegen/TestCacheIdMessageDeployer.java} (52%)
create mode 100644
modules/core/src/test/resources/codegen/TestCollectionsMessageMarshaller.java
copy
modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteContextMarshallableMessage.java
=> core/src/test/resources/codegen/TestDeployableMessage.java} (55%)
rename
modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteContextMarshallableMessage.java
=> core/src/test/resources/codegen/TestDeployableMessageDeployer.java} (55%)
create mode 100644
modules/core/src/test/resources/codegen/TestMapMessageMarshaller.java
create mode 100644
modules/core/src/test/resources/codegen/TestMarshallableMessageMarshaller.java
rename
modules/core/src/test/resources/codegen/{TestMarshallableMessageMarshallableSerializer.java
=> TestMarshallableMessageSerializer.java} (68%)
rename
modules/core/src/{main/java/org/apache/ignite/internal/OperationContextMessage.java
=> test/resources/codegen/TestMarshalledArrayMapMessage.java} (60%)
create mode 100644
modules/core/src/test/resources/codegen/TestMarshalledArrayMapMessageMarshaller.java
copy modules/core/src/test/resources/codegen/{ChildMessageSerializer.java =>
TestMarshalledArrayMapMessageSerializer.java} (51%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
TestMarshalledCollectionMessage.java} (79%)
create mode 100644
modules/core/src/test/resources/codegen/TestMarshalledCollectionMessageMarshaller.java
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessageSerializer.java
=> TestMarshalledCollectionMessageSerializer.java} (59%)
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessage.java =>
TestMarshalledMapMessage.java} (72%)
create mode 100644
modules/core/src/test/resources/codegen/TestMarshalledMapMessageMarshaller.java
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessageSerializer.java
=> TestMarshalledMapMessageSerializer.java} (61%)
rename
modules/core/src/{main/java/org/apache/ignite/internal/util/GridSerializableIterable.java
=> test/resources/codegen/TestMarshalledMessage.java} (73%)
create mode 100644
modules/core/src/test/resources/codegen/TestMarshalledMessageMarshaller.java
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessageSerializer.java
=> TestMarshalledMessageSerializer.java} (66%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
TestMarshalledObjectsMessage.java} (80%)
create mode 100644
modules/core/src/test/resources/codegen/TestMarshalledObjectsMessageMarshaller.java
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessageSerializer.java
=> TestMarshalledObjectsMessageSerializer.java} (61%)
create mode 100644
modules/core/src/test/resources/codegen/TestMessageMarshaller.java
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
TestNestedDeployMessage.java} (75%)
copy
modules/core/src/{main/java/org/apache/ignite/internal/MarshallableMessage.java
=> test/resources/codegen/TestNestedDeployMessageDeployer.java} (57%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
TestNoCacheCtxMessage.java} (75%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
TestSelfMarshallingMessage.java} (75%)
copy
modules/{indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2ValueMessage.java
=> core/src/test/resources/codegen/TestSelfMarshallingMessageMarshaller.java}
(54%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessageSerializer.java
=> TestSelfMarshallingMessageSerializer.java} (66%)
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessage.java =>
TwoDifferentEnumsInCollectionMessage.java} (84%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
WrongNonMarshallableMessage.java} (75%)
rename
modules/core/src/{main/java/org/apache/ignite/internal/management/tracing/TracingConfigurationGetAllCommand.java
=> test/resources/codegen/WrongSelfMarshallingMessage.java} (65%)
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/dto/IndexedDataRecord.java
rename
modules/{core/src/main/java/org/apache/ignite/internal/tracing/TracingSpiType.java
=>
ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/LoadMode.java}
(51%)
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcCacheAwareApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcContinuousLoadApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcDataCheckerApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcDataGeneratorApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcThinClientLoadApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/utils/OpStats.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/utils/Utils.java
create mode 100644
modules/ducktests/tests/checks/services/network_group/check_manager.py
create mode 100644
modules/ducktests/tests/checks/utils/check_cache_distribution.py
rename modules/{core/src/test/config/class_list_test_excluded.txt =>
ducktests/tests/ignitetest/services/mdc/__init__.py} (82%)
create mode 100644
modules/ducktests/tests/ignitetest/services/mdc/mdc_cluster.py
copy modules/ducktests/tests/{docker/requirements.txt =>
ignitetest/services/network_group/__init__.py} (82%)
create mode 100644
modules/ducktests/tests/ignitetest/services/network_group/configuration.py
create mode 100644
modules/ducktests/tests/ignitetest/services/network_group/manager.py
create mode 100644
modules/ducktests/tests/ignitetest/services/network_group/tc_rule_args.py
copy modules/ducktests/tests/{docker/requirements.txt =>
ignitetest/tests/mdc/__init__.py} (93%)
create mode 100644
modules/ducktests/tests/ignitetest/tests/mdc/partition_resilience_test.py
create mode 100644
modules/ducktests/tests/ignitetest/tests/mdc/thin_client_test.py
create mode 100644
modules/ducktests/tests/ignitetest/tests/mdc/transactional_partition_test.py
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/MTC.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/NoopSpan.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/NoopSpanManager.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/Span.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/SpanManager.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/SpanTags.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/SpanType.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/processors/tracing/messages/SpanTransport.java
delete mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/util/nio/GridNioTracerFilter.java
create mode 100644
modules/nio/src/main/java/org/apache/ignite/internal/util/nio/MessageSerialization.java
rename
modules/{core/src/main/java/org/apache/ignite/internal/util/lang/GridTriple.java
=>
nio/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageEnumType.java}
(50%)
create mode 100644
modules/nio/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageRegistry.java
delete mode 100644
modules/opencensus/src/main/java/io/opencensus/exporter/trace/TimeLimitedHandler.java
delete mode 100644
modules/opencensus/src/main/java/org/apache/ignite/spi/tracing/opencensus/OpenCensusSpanAdapter.java
delete mode 100644
modules/opencensus/src/main/java/org/apache/ignite/spi/tracing/opencensus/OpenCensusTraceExporter.java
delete mode 100644
modules/opencensus/src/main/java/org/apache/ignite/spi/tracing/opencensus/OpenCensusTracingSpi.java
delete mode 100644
modules/opencensus/src/main/java/org/apache/ignite/spi/tracing/opencensus/StatusMatchTable.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/TracingConfigurationValidationTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/AbstractTracingTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/MixedTracingSpiTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusDiscoveryTracingTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlJdbcTracingTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusSqlNativeTracingTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTracingConfigurationGetAllTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTracingConfigurationGetTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTracingConfigurationResetAllTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTracingConfigurationResetTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTracingSpiTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTxTracingConfigurationTest.java
delete mode 100644
modules/opencensus/src/test/java/org/apache/ignite/internal/processors/monitoring/opencensus/OpenCensusTxTracingTest.java
create mode 100644 modules/platforms/cpp/core-test/src/classpath_test.cpp
delete mode 100644
modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZkOperationContextSendAttributesTest.java
