IGNITE-14085 Implement network recovery protocol
authorSemyon Danilov <samvimes@yandex.ru>
Sat, 30 Apr 2022 21:59:42 +0000 (01:59 +0400)
committerSemyon Danilov <samvimes@yandex.ru>
Fri, 13 May 2022 15:38:03 +0000 (19:38 +0400)
commit8c075cdd8defd5ff811c1fa68864650d22c7d06e
tree49869ee59156ffd5fa7f6be92a09291020ca00af
parent7fc6738168449ec6765f573b4619866ad56f5fb8
IGNITE-14085 Implement network recovery protocol
32 files changed:
modules/network-annotation-processor/src/main/java/org/apache/ignite/internal/network/processor/MessageClass.java
modules/network-api/src/main/java/org/apache/ignite/network/NetworkMessage.java
modules/network/src/integrationTest/java/org/apache/ignite/internal/network/netty/ItConnectionManagerTest.java
modules/network/src/integrationTest/java/org/apache/ignite/internal/network/recovery/ItRecoveryHandshakeTest.java [deleted file]
modules/network/src/main/java/org/apache/ignite/internal/network/NetworkMessageTypes.java
modules/network/src/main/java/org/apache/ignite/internal/network/handshake/HandshakeManager.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/ConnectionManager.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/DefaultRecoveryDescriptorProvider.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/netty/HandshakeHandler.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/InboundDecoder.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/InboundRecoveryHandler.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/netty/IoExceptionSuppressingHandler.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/MessageHandler.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyClient.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/NettyServer.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/OutboundEncoder.java
modules/network/src/main/java/org/apache/ignite/internal/network/netty/OutboundRecoveryHandler.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/netty/PipelineUtils.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/RecoveryClientHandshakeManager.java
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/RecoveryDescriptor.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/RecoveryDescriptorProvider.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/RecoveryServerHandshakeManager.java
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/AcknowledgementMessage.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/HandshakeFinishMessage.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/HandshakeStartMessage.java
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/HandshakeStartResponseMessage.java
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/InternalMessage.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/network/OutNetworkObject.java
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeClusterServiceFactory.java
modules/network/src/test/java/org/apache/ignite/internal/network/netty/NettyClientTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/netty/NettyServerTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/netty/RecoveryHandshakeTest.java [new file with mode: 0644]