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