This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from db17a85d6b IGNITE-23771 Remove intermediate conversion to string in
AssignmentsTracker (#4804)
add e812214f2b IGNITE-23796 Optimize network LazyStripedExecutors (#4801)
No new revisions were added by this update.
Summary of changes:
.../deployunit/DeployMessagingService.java | 3 +-
.../deployunit/DeploymentChannelTypeModule.java} | 24 ++---
...niteDistributionZoneManagerNodeRestartTest.java | 4 +-
modules/file-transfer/build.gradle | 2 +
.../ignite/internal/network/file/Channel.java | 2 +-
.../file/FileTransferChannelTypeModule.java} | 24 ++---
modules/network-api/build.gradle | 2 +
...yService.java => ArrayChannelTypeRegistry.java} | 38 +++----
.../ignite/internal/network/ChannelType.java | 81 +++-----------
.../internal/network/ChannelTypeAlreadyExist.java | 33 ------
...usterIdSupplier.java => ChannelTypeModule.java} | 11 +-
...ologyService.java => ChannelTypeRegistrar.java} | 35 +++---
.../internal/network/ChannelTypeRegistry.java | 46 ++++++++
.../network/ChannelTypeRegistryProvider.java} | 35 +++---
.../internal/network/MapChannelTypeRegistry.java | 56 ++++++++++
...plier.java => NetworkApiChannelTypeModule.java} | 16 +--
.../ignite/internal/network/ChannelTypeTest.java | 70 ------------
modules/network/build.gradle | 1 +
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../ArrayStripedExecutorByChannelTypeId.java} | 33 ++++--
.../internal/network/CriticalStripedExecutors.java | 87 +++++++++++++++
.../CriticalStripedThreadPoolExecutorFactory.java | 79 ++++++++++++++
.../internal/network/DefaultMessagingService.java | 80 ++++----------
.../internal/network/LazyStripedExecutors.java | 117 ---------------------
.../network/MapStripedExecutorByChannelTypeId.java | 52 +++++++++
.../network/StripedExecutorByChannelTypeId.java | 43 ++++++++
.../internal/network/netty/ConnectionManager.java | 38 ++++---
.../scalecube/ScaleCubeChannelTypeModule.java} | 19 ++--
.../scalecube/ScaleCubeClusterServiceFactory.java | 72 +++++++------
.../ScaleCubeDirectMarshallerTransport.java | 5 +-
.../network/DefaultMessagingServiceTest.java | 11 +-
.../network/TestNetworkChannelTypeModule.java} | 16 +--
.../network/utils/ClusterServiceTestUtils.java | 10 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
36 files changed, 627 insertions(+), 534 deletions(-)
copy
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/util/concurrent/RejectedExecutionHandler.java
=>
code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeploymentChannelTypeModule.java}
(63%)
copy
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/util/concurrent/RejectedExecutionHandler.java
=>
file-transfer/src/main/java/org/apache/ignite/internal/network/file/FileTransferChannelTypeModule.java}
(64%)
copy
modules/network-api/src/main/java/org/apache/ignite/internal/network/{AbstractTopologyService.java
=> ArrayChannelTypeRegistry.java} (54%)
delete mode 100644
modules/network-api/src/main/java/org/apache/ignite/internal/network/ChannelTypeAlreadyExist.java
copy
modules/network-api/src/main/java/org/apache/ignite/internal/network/{ClusterIdSupplier.java
=> ChannelTypeModule.java} (74%)
copy
modules/network-api/src/main/java/org/apache/ignite/internal/network/{AbstractTopologyService.java
=> ChannelTypeRegistrar.java} (51%)
create mode 100644
modules/network-api/src/main/java/org/apache/ignite/internal/network/ChannelTypeRegistry.java
copy
modules/{network/src/testFixtures/java/org/apache/ignite/internal/network/ConstantClusterIdSupplier.java
=>
network-api/src/main/java/org/apache/ignite/internal/network/ChannelTypeRegistryProvider.java}
(52%)
create mode 100644
modules/network-api/src/main/java/org/apache/ignite/internal/network/MapChannelTypeRegistry.java
copy
modules/network-api/src/main/java/org/apache/ignite/internal/network/{ClusterIdSupplier.java
=> NetworkApiChannelTypeModule.java} (70%)
delete mode 100644
modules/network-api/src/test/java/org/apache/ignite/internal/network/ChannelTypeTest.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/UnresolvableConsistentIdException.java
=>
network/src/main/java/org/apache/ignite/internal/network/ArrayStripedExecutorByChannelTypeId.java}
(51%)
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/CriticalStripedExecutors.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/CriticalStripedThreadPoolExecutorFactory.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/LazyStripedExecutors.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/MapStripedExecutorByChannelTypeId.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/StripedExecutorByChannelTypeId.java
copy
modules/{runner/src/test/java/org/apache/ignite/internal/configuration/TestConfigurationModule.java
=>
network/src/main/java/org/apache/ignite/internal/network/scalecube/ScaleCubeChannelTypeModule.java}
(62%)
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/ClusterIdSupplier.java
=>
network/src/test/java/org/apache/ignite/internal/network/TestNetworkChannelTypeModule.java}
(68%)
