IGNITE-16250 Use direct marshaller and user object serialization for network messaging
authorSemyon Danilov <samvimes@yandex.ru>
Mon, 10 Jan 2022 16:34:19 +0000 (19:34 +0300)
committerSemyon Danilov <samvimes@yandex.ru>
Tue, 18 Jan 2022 10:48:30 +0000 (13:48 +0300)
commit6b67ecc564ecf50b6af7815b75c5e79dea255217
tree6e94e558185282f20ef546909eeb1fa10e6aeb2e
parentc507456fcf6bf83ac600f148fde8dc26b5bf57a1
IGNITE-16250 Use direct marshaller and user object serialization for network messaging
59 files changed:
modules/metastorage-client/pom.xml
modules/network-annotation-processor/src/main/java/org/apache/ignite/internal/network/processor/serialization/MessageReaderMethodResolver.java
modules/network-annotation-processor/src/main/java/org/apache/ignite/internal/network/processor/serialization/RegistryInitializerGenerator.java
modules/network-api/src/main/java/org/apache/ignite/network/serialization/MessageSerializationRegistryInitializer.java [new file with mode: 0644]
modules/network/pom.xml
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
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ItScaleCubeNetworkMessagingTest.java
modules/network/src/integrationTest/java/org/apache/ignite/utils/ClusterServiceTestUtils.java
modules/network/src/main/java/org/apache/ignite/internal/network/direct/stream/DirectByteBufferStreamImplV1.java
modules/network/src/main/java/org/apache/ignite/internal/network/message/ScaleCubeMessage.java
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/ClassDescriptorFactory.java
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/ClassDescriptorRegistry.java [moved from modules/network/src/main/java/org/apache/ignite/internal/network/serialization/ClassDescriptorFactoryContext.java with 96% similarity]
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/CompositeIdIndexedDescriptors.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/PerSessionSerializationService.java
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/SerializationException.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/SerializationService.java
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializationContext.java [new file with mode: 0644]
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializationException.java [moved from modules/network/src/main/java/org/apache/ignite/internal/network/serialization/UserObjectSerializer.java with 53% similarity]
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshaller.java
modules/network/src/main/java/org/apache/ignite/internal/network/serialization/marshal/UserObjectMarshaller.java
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeClusterServiceFactory.java
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeDirectMarshallerTransport.java
modules/network/src/test/java/org/apache/ignite/internal/network/netty/InboundDecoderTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/netty/NettyServerTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/ClassDescriptorFactoryTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/MarshallableTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/ContextBasedIdIndexedDescriptors.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerCommonTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithArbitraryObjectsTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithBuiltinsTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithExternalizableTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithSerializableOverrideStreamsTest.java
modules/network/src/test/java/org/apache/ignite/internal/network/serialization/marshal/DefaultUserObjectMarshallerWithSerializableTest.java
modules/raft/pom.xml
modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/CliServiceImpl.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/core/NodeImpl.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/entity/LocalFileMetaOutter.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/entity/LocalStorageOutter.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/entity/RaftOutter.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/ActionRequest.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/ActionResponse.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/CliRequests.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/RpcRequests.java
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/RaftGroupServiceImpl.java
modules/raft/src/test/java/org/apache/ignite/raft/jraft/rpc/AbstractRpcTest.java
modules/runner/pom.xml
modules/runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java
modules/sql-engine/pom.xml
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/ErrorMessage.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryBatchMessage.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryStartRequest.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/QueryStartResponse.java
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/RelMetadataQueryEx.java
modules/table/pom.xml
modules/table/src/test/java/org/apache/ignite/internal/table/TxAbstractTest.java
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishRequest.java
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishResponse.java
parent/pom.xml