This is an automated email from the ASF dual-hosted git repository.
ibessonov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 865a066 IGNITE-14237 Implemented affinity calculation based on
events. Fixes #120
add d2dcab5 IGNITE-14088 ScaleCube transport API over Netty (#125)
No new revisions were added by this update.
Summary of changes:
.../metastorage/client/MetaStorageServiceTest.java | 6 +-
modules/network/pom.xml | 12 +
.../ignite/network/ConnectionManagerTest.java | 184 +++++++
.../ignite/network/DirectSerializationTest.java | 110 ----
.../network/TestMessageSerializationFactory.java | 2 +-
.../network/scalecube/ITNodeRestartsTest.java | 11 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 32 +-
.../apache/ignite/network/NetworkException.java | 33 --
.../internal/direct/DirectMarshallingUtils.java} | 39 +-
.../internal/direct/DirectMessageReader.java | 2 +-
.../internal/direct/DirectMessageWriter.java | 14 +-
.../stream/DirectByteBufferStreamImplV1.java | 2 +-
.../network/internal/netty/ConnectionManager.java | 250 +++++++++
.../network/internal/netty/InboundDecoder.java | 125 +++++
.../network/internal/netty/MessageHandler.java | 48 ++
.../ignite/network/internal/netty/NettyClient.java | 162 ++++++
.../ignite/network/internal/netty/NettySender.java | 166 ++++++
.../ignite/network/internal/netty/NettyServer.java | 276 ++++++++++
.../ignite/network/internal/netty/NettyUtils.java | 77 +++
.../scalecube/DelegatingTransportFactory.java | 25 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 15 +-
.../ScaleCubeDirectMarshallerTransport.java | 248 +++++++++
.../scalecube/message/ScaleCubeMessage.java | 62 +++
.../ScaleCubeMessageSerializationFactory.java} | 50 +-
.../ignite/network/internal/AllTypesMessage.java | 154 ++++++
.../network/internal/AllTypesMessageGenerator.java | 215 ++++++++
.../AllTypesMessageSerializationFactory.java | 562 +++++++++++++++++++++
.../ignite/network/internal/TestFieldType.java} | 16 +-
.../network/internal/netty/InboundDecoderTest.java | 208 ++++++++
.../network/internal/netty/NettyClientTest.java | 209 ++++++++
.../network/internal/netty/NettyServerTest.java | 180 +++++++
.../message/MessageSerializationRegistryTest.java | 105 ++++
.../raft/server/ITRaftCounterServerTest.java | 11 +-
.../ignite/raft/server/impl/RaftServerImpl.java | 2 -
.../apache/ignite/internal/app/IgnitionImpl.java | 5 +-
.../table/distributed/DistributedTableTest.java | 6 +-
36 files changed, 3383 insertions(+), 241 deletions(-)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/ConnectionManagerTest.java
delete mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/DirectSerializationTest.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/network/NetworkException.java
copy modules/{table/src/main/java/org/apache/ignite/binary/BinaryObjects.java
=>
network/src/main/java/org/apache/ignite/network/internal/direct/DirectMarshallingUtils.java}
(55%)
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/ConnectionManager.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/InboundDecoder.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/MessageHandler.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyClient.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettySender.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyServer.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyUtils.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeDirectMarshallerTransport.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/scalecube/message/ScaleCubeMessage.java
copy
modules/network/src/{integrationTest/java/org/apache/ignite/network/TestMessageSerializationFactory.java
=>
main/java/org/apache/ignite/network/scalecube/message/ScaleCubeMessageSerializationFactory.java}
(61%)
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/internal/AllTypesMessage.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/internal/AllTypesMessageGenerator.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/internal/AllTypesMessageSerializationFactory.java
copy
modules/{core/src/main/java/org/apache/ignite/internal/tostring/IgniteToStringExclude.java
=>
network/src/test/java/org/apache/ignite/network/internal/TestFieldType.java}
(71%)
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/internal/netty/InboundDecoderTest.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/internal/netty/NettyClientTest.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/internal/netty/NettyServerTest.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/network/message/MessageSerializationRegistryTest.java
