You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/04/09 11:06:33 UTC
[ignite-3] branch ignite-14330 updated (6d8346d -> f8a9b6b)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14330
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 6d8346d Minor fixes after review.
add 49bfd0f IGNITE-14084 Direct marshalling code converted from 2.x codebase (#82).
add f8a9b6b Merge branch 'main' into ignite-14330
No new revisions were added by this update.
Summary of changes:
modules/core/pom.xml | 5 +
.../ignite/internal/util/DirectBufferCleaner.java} | 14 +-
.../ignite/internal/util/FeatureChecker.java | 40 +
.../apache/ignite/internal/util/GridUnsafe.java | 2013 ++++++++++++++++++++
.../apache/ignite/internal/util/IgniteUtils.java | 116 ++
.../util/ReflectiveDirectBufferCleaner.java | 65 +
.../internal/util/UnsafeDirectBufferCleaner.java} | 39 +-
.../communication/MessageCollectionItemType.java | 102 +
modules/network/pom.xml | 6 +
.../ignite/network/DirectSerializationTest.java | 120 ++
.../ITScaleCubeNetworkClusterMessagingTest.java | 10 +-
.../ignite/network/scalecube/TestMessage.java | 38 +-
.../scalecube/TestMessageMapperProvider.java | 54 -
.../scalecube/TestMessageSerializerProvider.java | 117 ++
...der.java => TestRequestSerializerProvider.java} | 30 +-
...er.java => TestResponseSerializerProvider.java} | 30 +-
.../java/org/apache/ignite/network/Network.java | 12 +-
.../ignite/network/NetworkClusterContext.java | 14 +-
.../ignite/network/internal/MessageReader.java | 287 ++-
.../network/internal/MessageSerializerFactory.java | 55 +
.../ignite/network/internal/MessageWriter.java | 315 ++-
.../internal/direct/DirectMessageReader.java | 410 ++++
.../internal/direct/DirectMessageWriter.java | 373 ++++
.../internal/direct/state/DirectMessageState.java | 96 +
.../direct/state/DirectMessageStateItem.java} | 10 +-
.../direct/stream/DirectByteBufferStream.java | 319 ++++
.../stream/DirectByteBufferStreamImplV1.java | 1805 ++++++++++++++++++
.../message/DefaultMessageMapperProvider.java | 54 -
.../network/message/MessageDeserializer.java | 10 +-
.../ignite/network/message/MessageSerializer.java | 5 +-
...rovider.java => MessageSerializerProvider.java} | 7 +-
.../ignite/network/message/NetworkMessage.java | 3 +
.../network/scalecube/ScaleCubeMessageCodec.java | 133 --
.../network/scalecube/ScaleCubeMessageReader.java | 38 -
.../network/scalecube/ScaleCubeMessageWriter.java | 38 -
.../network/scalecube/ScaleCubeNetworkCluster.java | 11 +-
.../scalecube/ScaleCubeNetworkClusterFactory.java | 3 +-
.../raft/server/ITRaftCounterServerTest.java | 12 +-
.../ignite/raft/server/impl/RaftServerImpl.java | 12 +-
39 files changed, 6365 insertions(+), 456 deletions(-)
copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Factory.java => core/src/main/java/org/apache/ignite/internal/util/DirectBufferCleaner.java} (79%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/FeatureChecker.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/GridUnsafe.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/ReflectiveDirectBufferCleaner.java
copy modules/{configuration/src/main/java/org/apache/ignite/configuration/validation/ConfigurationValidationException.java => core/src/main/java/org/apache/ignite/internal/util/UnsafeDirectBufferCleaner.java} (52%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageCollectionItemType.java
create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/DirectSerializationTest.java
delete mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessageMapperProvider.java
create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessageSerializerProvider.java
rename modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/{TestRequestMapperProvider.java => TestRequestSerializerProvider.java} (59%)
rename modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/{TestResponseMapperProvider.java => TestResponseSerializerProvider.java} (59%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/MessageSerializerFactory.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/direct/DirectMessageReader.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/direct/DirectMessageWriter.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/direct/state/DirectMessageState.java
copy modules/{api/src/main/java/org/apache/ignite/schema/IndexColumn.java => network/src/main/java/org/apache/ignite/network/internal/direct/state/DirectMessageStateItem.java} (82%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/direct/stream/DirectByteBufferStream.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/direct/stream/DirectByteBufferStreamImplV1.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/message/DefaultMessageMapperProvider.java
rename modules/network/src/main/java/org/apache/ignite/network/message/{MessageMapperProvider.java => MessageSerializerProvider.java} (89%)
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageCodec.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageReader.java
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageWriter.java