You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sd...@apache.org on 2022/03/10 08:59:49 UTC
[ignite-3] branch main updated (8b9562e -> 4a05cf2)
This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 8b9562e Merge branch 'main' of https://github.com/apache/ignite-3 into main
add 4a05cf2 IGNITE-16393 Move network's user object serialization to the user thread (#705)
No new revisions were added by this update.
Summary of changes:
.../messages/MessageBuilderGenerator.java | 91 ++++--
.../processor/messages/MessageImplGenerator.java | 309 ++++++++++++++++++++-
.../MessageDeserializerGenerator.java | 11 +-
.../serialization/MessageReaderMethodResolver.java | 5 +-
.../serialization/MessageSerializerGenerator.java | 4 +-
.../serialization/MessageWriterMethodResolver.java | 5 +-
.../org/apache/ignite/network/NetworkMessage.java | 10 +
.../network/serialization/MessageReader.java | 10 -
.../network/serialization/MessageWriter.java | 11 -
modules/network/pom.xml | 12 +
.../network/netty/ItConnectionManagerTest.java | 20 +-
.../ItTransferableObjectProcessorTest.java | 4 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 6 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 10 +-
.../network/processor/AllTypesMessage.java | 0
.../network/processor/ConflictingTypeMessage.java | 0
.../network/processor/ITTestMessageGroup.java | 0
.../network/processor/InheritedMessageClash.java | 0
.../processor/InvalidAnnotatedTypeMessage.java | 0
.../processor/InvalidParameterGetterMessage.java | 0
.../processor/InvalidReturnTypeGetterMessage.java | 0
.../internal/network/processor/SecondGroup.java | 0
.../network/processor/TransitiveMessage.java | 0
.../processor/UnmarshallableTypeMessage.java | 0
.../UnmarshallableTypeNonSerializableMessage.java | 0
.../internal/network/NetworkMessageTypes.java | 6 +
.../network/direct/DirectMessageReader.java | 12 -
.../network/direct/DirectMessageWriter.java | 10 -
.../direct/stream/DirectByteBufferStream.java | 19 --
.../stream/DirectByteBufferStreamImplV1.java | 102 -------
...equest.java => ClassDescriptorListMessage.java} | 18 +-
.../internal/network/netty/ConnectionManager.java | 12 +-
.../internal/network/netty/InNetworkObject.java | 70 +++++
.../internal/network/netty/InboundDecoder.java | 13 +-
.../internal/network/netty/MessageHandler.java | 14 +-
.../network/netty/NamedNioEventLoopGroup.java | 18 +-
.../ignite/internal/network/netty/NettyClient.java | 11 +-
.../ignite/internal/network/netty/NettySender.java | 8 +-
.../ignite/internal/network/netty/NettyServer.java | 10 +-
.../internal/network/netty/OutboundEncoder.java | 59 +++-
.../recovery/RecoveryClientHandshakeManager.java | 4 +-
.../recovery/RecoveryServerHandshakeManager.java | 4 +-
.../PerSessionSerializationService.java | 61 ++--
.../serialization/SerializationService.java | 44 ---
.../ignite/network/DefaultMessagingService.java | 92 +++++-
.../ignite/network/NettyBootstrapFactory.java | 12 +
...StaticNodeFinder.java => OutNetworkObject.java} | 29 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 47 ++--
.../ScaleCubeDirectMarshallerTransport.java | 33 ++-
.../internal/network/netty/NettyClientTest.java | 4 +-
.../internal/network/netty/NettyServerTest.java | 2 +-
.../network/serialization/MarshallableTest.java | 57 +++-
modules/raft/pom.xml | 1 -
.../raft/server/ItJraftCounterServerTest.java | 42 +--
modules/transactions/pom.xml | 5 +
parent/pom.xml | 6 +
56 files changed, 898 insertions(+), 435 deletions(-)
rename modules/{network-annotation-processor => network}/src/integrationTest/java/org/apache/ignite/internal/network/processor/ItTransferableObjectProcessorTest.java (97%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/AllTypesMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/ConflictingTypeMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/ITTestMessageGroup.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InvalidAnnotatedTypeMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InvalidParameterGetterMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InvalidReturnTypeGetterMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/SecondGroup.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/TransitiveMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/UnmarshallableTypeMessage.java (100%)
rename modules/{network-annotation-processor => network}/src/integrationTest/resources/org/apache/ignite/internal/network/processor/UnmarshallableTypeNonSerializableMessage.java (100%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/message/{InvokeRequest.java => ClassDescriptorListMessage.java} (70%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/netty/InNetworkObject.java
copy modules/network/src/main/java/org/apache/ignite/network/{StaticNodeFinder.java => OutNetworkObject.java} (54%)