This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-28739-new
in repository https://gitbox.apache.org/repos/asf/ignite.git
from edbd593e265 IGNITE-28739 code-style
add 341b2557a01 IGNITE-28920 Reduce MarshallableMessage scope:
GridCacheEntryInfo uses marshal hooks only to rebase expireTime (#13447)
add f83f8a55305 IGNITE-28790 Use MessageSerializer to transfer continuous
query DTO's in DataBag. (#13426)
add ec42c2273f2 IGNITE-28947 Handle recursive CTE planning gracefully
(#13429)
add fb0a892ab6f IGNITE-28975 Added ClassNotFoundException handling for
ObjectInputStream.GetField#get method on JDK 21 (#13469)
add 4aaecc77230 IGNITE-28977 Remove SelfMarshallingMessage implementation
by ColocationGroup (#13468)
add 05f03f64837 IGNITE-28978 Make MDC-aware discovery ring mode testable
in a single JVM (#13471)
add 6105e021b6c IGNITE-28919 Add communication and discovery IO test
commands (#13399)
add 270a71f03b3 IGNITE-28270 Investigate possibity to use
MessageSerializer for ComputeJobSibling (#13445)
add dda84bf0603 IGNITE-28983 Fixed thin client hanging if the remote
endpoint stops responding during the SSL handshake without closing the socket
(#13477)
add b39a51d288a Merge branch 'master' into ignite-28739-new
add 7e58dc1b8da IGNITE-28739 After review 3.0
No new revisions were added by this update.
Summary of changes:
docs/_docs/tools/control-script.adoc | 50 ++
.../query/calcite/exec/LogicalRelImplementor.java | 4 -
.../query/calcite/message/QueryStartRequest.java | 4 +-
.../query/calcite/metadata/ColocationGroup.java | 35 +-
.../calcite/metadata/FragmentDescription.java | 35 +-
.../query/calcite/metadata/IgniteMdCollation.java | 4 +-
.../calcite/metadata/IgniteMdDistribution.java | 4 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 11 +-
.../integration/LimitOffsetIntegrationTest.java | 10 -
.../integration/RecursiveCteIntegrationTest.java | 60 ++
.../ignite/testsuites/IntegrationTestSuite.java | 2 +
.../commandline/CommandHandlerParsingTest.java | 2 +
.../testsuites/IgniteControlUtilityTestSuite2.java | 2 +
.../org/apache/ignite/util/IoTestCommandTest.java | 126 ++++
.../ignite/internal/CoreMessagesProvider.java | 22 +
.../ignite/internal/GridEventConsumeHandler.java | 76 +--
.../ignite/internal/GridJobExecuteRequest.java | 38 +-
.../apache/ignite/internal/GridJobSiblingImpl.java | 35 +-
.../ignite/internal/GridJobSiblingsResponse.java | 19 +-
.../ignite/internal/GridMessageListenHandler.java | 113 ++--
.../ignite/internal/GridTaskSessionImpl.java | 6 +-
.../org/apache/ignite/internal/IgniteKernal.java | 20 -
.../apache/ignite/internal/IgniteMXBeanImpl.java | 28 +-
.../internal/management/IgniteCommandRegistry.java | 4 +-
.../{cdc/CdcCommand.java => io/IoTestCommand.java} | 12 +-
.../management/io/IoTestCommunicationCommand.java | 152 +++++
.../io/IoTestCommunicationCommandArg.java | 120 ++++
.../management/io/IoTestCommunicationTask.java | 113 ++++
.../management/io/IoTestDiscoveryCommand.java | 136 ++++
.../management/io/IoTestDiscoveryCommandArg.java | 96 +++
.../IoTestDiscoveryTask.java} | 38 +-
.../managers/communication/GridIoManager.java | 707 +------------------
.../communication/IgniteIoTestMessage.java | 299 ++------
.../managers/communication/IoTestHandler.java | 753 +++++++++++++++++++++
.../managers/communication/IoTestResult.java | 234 +++++++
.../deployment/GridDeploymentInfoMessage.java | 2 +-
.../managers/discovery/GridDiscoveryManager.java | 10 +
.../discovery/IoTestDiscoveryAckMessage.java | 69 ++
.../managers/discovery/IoTestDiscoveryHandler.java | 275 ++++++++
.../managers/discovery/IoTestDiscoveryMessage.java | 88 +++
.../managers/discovery/IoTestDiscoveryResult.java | 181 +++++
.../processors/affinity/GridAffinityUtils.java | 2 +-
.../processors/cache/GridCacheEntryInfo.java | 128 ++--
.../processors/cache/GridCacheMapEntry.java | 16 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 20 +-
.../distributed/dht/GridDhtGetSingleFuture.java | 20 +-
.../dht/preloader/GridDhtPartitionSupplier.java | 20 +-
.../CacheContinuousQueryDeployableObject.java | 37 +-
.../continuous/CacheContinuousQueryHandler.java | 333 ++++-----
.../ContinousRoutineDiscoveryData.java} | 47 +-
.../ContinousRoutineDiscoveryDataItem.java | 96 +++
.../continuous/ContinousRoutineLocalInfo.java | 133 ++++
.../continuous/ContinuousRoutineInfo.java | 44 +-
.../ContinuousRoutinesCommonDiscoveryData.java | 14 +-
...ContinuousRoutinesJoiningNodeDiscoveryData.java | 14 +-
.../continuous/GridContinuousHandler.java | 4 +-
.../continuous/GridContinuousProcessor.java | 387 ++---------
.../processors/continuous/StartRequestData.java | 5 +-
.../internal/processors/job/GridJobProcessor.java | 35 +-
.../session/GridTaskSessionProcessor.java | 2 +-
.../internal/processors/task/GridTaskWorker.java | 2 +-
.../org/apache/ignite/mxbean/IgniteMXBean.java | 10 +-
.../security/SecurityBasicPermissionSet.java | 2 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 4 +-
.../ignite/spi/discovery/DiscoveryDataBag.java | 8 -
.../ignite/spi/discovery/tcp/ClientImpl.java | 2 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 9 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 13 +
.../tcp/internal/TcpDiscoveryNodesRing.java | 8 +-
.../main/resources/META-INF/classnames.properties | 1 -
.../thin/ThinClientHandshakeTimeoutTest.java | 199 ++++++
.../communication/IgniteIoTestMessagesTest.java | 308 ++++++++-
.../processors/cache/GridCacheTestEntryEx.java | 11 +-
.../CacheContinuousQueryEntriesExpireTest.java | 4 +-
...ueryRemoteFilterMissingInClassPathSelfTest.java | 53 +-
...coveryDataDeserializationFailureHanderTest.java | 1 +
...GridCacheContinuousQueryNodesFilteringTest.java | 15 +-
.../continuous/GridEventConsumeSelfTest.java | 9 +-
.../OperationContextAttributePropagationTest.java | 4 +-
...unicationInverseConnectionEstablishingTest.java | 6 +-
.../tcp/GridTotallyUnreachableClientTest.java | 4 +-
.../IgniteTcpCommunicationHandshakeWaitTest.java | 2 +-
...ridCommandHandlerClusterByClassTest_help.output | 19 +
...andHandlerClusterByClassWithSSLTest_help.output | 19 +
.../org/apache/ignite/client/ClientTestSuite.java | 2 +
.../ignite/internal/client/thin/ClientUtils.java | 23 +
.../internal/client/thin/TcpClientChannel.java | 22 +-
.../GridNioClientConnectionMultiplexer.java | 101 ++-
.../cache/IgniteIoTestSendAllBenchmark.java | 2 +-
.../cache/IgniteIoTestSendRandomBenchmark.java | 2 +-
.../yardstick/io/IgniteIoTestSendAllBenchmark.java | 2 +-
.../io/IgniteIoTestSendRandomBenchmark.java | 2 +-
.../zk/internal/ZookeeperDiscoveryImpl.java | 2 +-
93 files changed, 4183 insertions(+), 2040 deletions(-)
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/RecursiveCteIntegrationTest.java
create mode 100644
modules/control-utility/src/test/java/org/apache/ignite/util/IoTestCommandTest.java
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{cdc/CdcCommand.java
=> io/IoTestCommand.java} (79%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestCommunicationCommand.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestCommunicationCommandArg.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestCommunicationTask.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestDiscoveryCommand.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestDiscoveryCommandArg.java
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{kill/ScanQueryCancelTask.java
=> io/IoTestDiscoveryTask.java} (59%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IoTestHandler.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IoTestResult.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryAckMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryHandler.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryResult.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/{authentication/AuthentificationDataBagItem.java
=> continuous/ContinousRoutineDiscoveryData.java} (54%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/ContinousRoutineDiscoveryDataItem.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/ContinousRoutineLocalInfo.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/client/thin/ThinClientHandshakeTimeoutTest.java
