commit	e1d4caf48ecca2b8fbb71d29e67716500ac4f910	[log] [tgz]
author	Semyon Danilov <samvimes@yandex.ru>	Fri May 28 12:26:30 2021 +0300
committer	GitHub <noreply@github.com>	Fri May 28 12:26:30 2021 +0300
tree	1e88b25b959ed896e2bf6a7ad3198a9da9519e6c
parent	d70bfa50a9ffcd957434857aac6888d9ddc6639b [diff]

IGNITE-14082 Implemented handshake protocol in new netty-based networking implementation. (#135)

modules/configuration-annotation-processor/src/main/java/org/apache/ignite/configuration/processor/internal/Processor.java[diff]
modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/ITMetaStorageServiceTest.java[diff]
modules/network-annotation-processor/src/integrationTest/java/org/apache/ignite/network/messages/internal/processor/ITAutoSerializableProcessorTest.java[diff]
modules/network-annotation-processor/src/main/java/org/apache/ignite/network/processor/internal/AutoSerializableProcessor.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/AbstractClusterService.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/ClusterLocalConfiguration.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/ClusterNode.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/ClusterService.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/ClusterServiceFactory.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/MessagingService.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/TopologyEventHandler.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/TopologyService.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/serialization/MessageReader.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/serialization/MessageSerializationRegistry.java[diff]
modules/network-api/src/main/java/org/apache/ignite/network/serialization/MessageWriter.java[diff]
modules/network/src/integrationTest/java/org/apache/ignite/network/ConnectionManagerTest.java[Deleted - diff]
modules/network/src/integrationTest/java/org/apache/ignite/network/TestMessage.java[diff]
modules/network/src/integrationTest/java/org/apache/ignite/network/internal/netty/ConnectionManagerTest.java[Added - diff]
modules/network/src/integrationTest/java/org/apache/ignite/network/internal/recovery/RecoveryHandshakeTest.java[Added - diff]
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ITNodeRestartsTest.java[diff]
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ITScaleCubeNetworkMessagingTest.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/direct/stream/DirectByteBufferStream.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/direct/stream/DirectByteBufferStreamImplV1.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/handshake/HandshakeAction.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/handshake/HandshakeException.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/handshake/HandshakeManager.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/ConnectionManager.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/HandshakeHandler.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/InboundDecoder.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyClient.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettySender.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyServer.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyUtils.java[diff]
modules/network/src/main/java/org/apache/ignite/network/internal/netty/OutboundEncoder.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/RecoveryClientHandshakeManager.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/RecoveryServerHandshakeManager.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/message/HandshakeMessageFactory.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/message/HandshakeStartMessage.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/message/HandshakeStartMessageImpl.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/message/HandshakeStartResponseMessage.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/internal/recovery/message/HandshakeStartResponseMessageImpl.java[Added - diff]
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeClusterServiceFactory.java[diff]
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeDirectMarshallerTransport.java[diff]
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessagingService.java[diff]
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeTopologyService.java[diff]
modules/network/src/test/java/org/apache/ignite/network/internal/netty/InboundDecoderTest.java[diff]
modules/network/src/test/java/org/apache/ignite/network/internal/netty/NettyClientTest.java[diff]
modules/network/src/test/java/org/apache/ignite/network/internal/netty/NettyServerTest.java[diff]
modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ITRaftCounterServerTest.java[diff]
modules/runner/src/main/java/org/apache/ignite/internal/app/IgnitionImpl.java[diff]
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ITDistributedTableTest.java[diff]

51 files changed

tree: 1e88b25b959ed896e2bf6a7ad3198a9da9519e6c

assembly/
check-rules/
docs/
idea/
modules/
parent/
.asf.yaml
.gitignore
DEVNOTES.md
LICENSE
pom.xml
README.md

README.md

Apache Ignite 3.x