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/01/18 10:49:36 UTC
[ignite-3] branch main updated (c507456 -> 6b67ecc)
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 c507456 IGNITE-16298 Object identity distinction must be preserved after marshalling+unmarshalling
add 6b67ecc IGNITE-16250 Use direct marshaller and user object serialization for network messaging
No new revisions were added by this update.
Summary of changes:
modules/metastorage-client/pom.xml | 6 +
.../serialization/MessageReaderMethodResolver.java | 4 +-
.../RegistryInitializerGenerator.java | 3 +
...> MessageSerializationRegistryInitializer.java} | 10 +-
modules/network/pom.xml | 6 +
.../network/netty/ItConnectionManagerTest.java | 3 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 6 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 29 +----
.../ignite/utils/ClusterServiceTestUtils.java | 47 +++++++-
.../stream/DirectByteBufferStreamImplV1.java | 33 ++++--
.../internal/network/message/ScaleCubeMessage.java | 10 +-
.../serialization/ClassDescriptorFactory.java | 20 ++--
...ryContext.java => ClassDescriptorRegistry.java} | 6 +-
...ors.java => CompositeIdIndexedDescriptors.java} | 22 ++--
.../PerSessionSerializationService.java | 129 +++++++++++++--------
.../{Null.java => SerializationException.java} | 13 +--
.../serialization/SerializationService.java | 102 +++++++++++-----
.../UserObjectSerializationContext.java | 53 +++++++++
.../UserObjectSerializationException.java} | 22 ++--
.../serialization/UserObjectSerializer.java | 48 --------
.../marshal/DefaultUserObjectMarshaller.java | 15 +--
.../marshal/UserObjectMarshaller.java | 9 ++
.../scalecube/ScaleCubeClusterServiceFactory.java | 25 +++-
.../ScaleCubeDirectMarshallerTransport.java | 34 +++---
.../internal/network/netty/InboundDecoderTest.java | 8 +-
.../internal/network/netty/NettyServerTest.java | 3 +-
.../serialization/ClassDescriptorFactoryTest.java | 18 +--
.../network/serialization/MarshallableTest.java | 71 +++++-------
.../marshal/ContextBasedIdIndexedDescriptors.java | 12 +-
.../DefaultUserObjectMarshallerCommonTest.java | 4 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 4 +-
...efaultUserObjectMarshallerWithBuiltinsTest.java | 4 +-
...UserObjectMarshallerWithExternalizableTest.java | 4 +-
...shallerWithSerializableOverrideStreamsTest.java | 6 +-
...ltUserObjectMarshallerWithSerializableTest.java | 4 +-
modules/raft/pom.xml | 6 +
.../ignite/raft/jraft/core/CliServiceImpl.java | 2 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 5 +-
.../raft/jraft/entity/LocalFileMetaOutter.java | 6 +-
.../raft/jraft/entity/LocalStorageOutter.java | 12 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 26 +++--
.../ignite/raft/jraft/rpc/ActionRequest.java | 5 +-
.../ignite/raft/jraft/rpc/ActionResponse.java | 5 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 70 +++++------
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 40 ++++---
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 44 +++----
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 8 +-
modules/runner/pom.xml | 6 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 10 +-
modules/sql-engine/pom.xml | 4 +-
.../internal/sql/engine/message/ErrorMessage.java | 4 +-
.../sql/engine/message/QueryBatchMessage.java | 4 +-
.../sql/engine/message/QueryStartRequest.java | 5 +-
.../sql/engine/message/QueryStartResponse.java | 4 +-
.../sql/engine/metadata/RelMetadataQueryEx.java | 30 +++--
modules/table/pom.xml | 6 +
.../ignite/internal/table/TxAbstractTest.java | 3 +-
.../internal/tx/message/TxFinishRequest.java | 5 +-
.../internal/tx/message/TxFinishResponse.java | 2 +-
parent/pom.xml | 8 +-
60 files changed, 658 insertions(+), 455 deletions(-)
copy modules/network-api/src/main/java/org/apache/ignite/network/serialization/{package-info.java => MessageSerializationRegistryInitializer.java} (80%)
rename modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{ClassDescriptorFactoryContext.java => ClassDescriptorRegistry.java} (96%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{MapBackedIdIndexedDescriptors.java => CompositeIdIndexedDescriptors.java} (58%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/serialization/{Null.java => SerializationException.java} (79%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializationContext.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkConfigurationException.java => network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializationException.java} (66%)
delete mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializer.java