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/05/14 08:49:12 UTC
[ignite-3] branch ignite-14077 updated (602d409 -> f88ea34)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14077
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 602d409 Minor.
add 22c060a IGNITE-14664 Implemented MetaStorageService and corresponding raft commands. Fixes #116
add 66bb2ef Revert "IGNITE-14664 Implemented MetaStorageService and corresponding raft commands. Fixes #116"
add ad1fa86 IGNITE-14664 Implemented MetaStorageService and corresponding raft commands. Fixes #116
add 3279a9a IGNITE-14088 ScaleCube transport API over Netty (#102)
add c231e86 IGNITE-14712 Fix MetaStorageServiceTest (#124)
add d2c38f0 Revert "IGNITE-14088 ScaleCube transport API over Netty (#102)"
add 33d0385 IGNITE-14666 Added proper listener handling in DistributedConfigurationStorage and LocalConfigurationStorage. Fixes #114
add 21ebca1 IGNITE-14707 Fixed topology events processing when nodes are restarted in quick succession (#126).
add 865a066 IGNITE-14237 Implemented affinity calculation based on events. Fixes #120
add d2dcab5 IGNITE-14088 ScaleCube transport API over Netty (#125)
add f88ea34 Merge branch 'main' into ignite-14077
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/affinity/AffinityManager.java | 188 ++--
.../affinity/RendezvousAffinityFunction.java | 11 +-
.../internal/affinity/event/AffinityEvent.java} | 14 +-
.../affinity/event/AffinityEventParameters.java | 64 ++
.../affinity/RendezvousAffinityFunctionTest.java | 3 +-
.../ignite/internal/baseline/BaselineManager.java | 1 +
.../storage/TestConfigurationStorage.java | 4 +-
.../ignite/configuration/ConfigurationChanger.java | 6 +-
.../storage/ConfigurationStorage.java | 16 +-
.../apache/ignite/configuration/storage/Data.java | 24 +-
modules/metastorage-client/pom.xml | 29 +
.../metastorage/client/MetaStorageServiceTest.java | 1076 ++++++++++++++++++++
.../internal/metastorage/client/CursorImpl.java | 99 ++
.../metastorage/client/MetaStorageServiceImpl.java | 361 +++++++
.../metastorage/client/MetaStorageService.java | 4 +-
modules/metastorage-common/pom.xml | 5 +
.../internal/metastorage/common/DummyEntry.java | 104 ++
.../metastorage/common/command/GetAllCommand.java | 79 ++
.../common/command/GetAndPutAllCommand.java | 63 ++
.../common/command/GetAndPutCommand.java | 58 ++
.../common/command/GetAndRemoveAllCommand.java | 54 +
.../common/command/GetAndRemoveCommand.java} | 27 +-
.../metastorage/common/command/GetCommand.java | 69 ++
.../metastorage/common/command/PutAllCommand.java | 54 +
.../metastorage/common/command/PutCommand.java | 58 ++
.../metastorage/common/command/RangeCommand.java | 83 ++
.../common/command/RemoveAllCommand.java | 51 +
.../metastorage/common/command/RemoveCommand.java} | 26 +-
.../common/command/WatchExactKeysCommand.java | 64 ++
.../common/command/WatchRangeKeysCommand.java | 82 ++
.../common/command/cursor/CursorCloseCommand.java} | 26 +-
.../command/cursor/CursorHasNextCommand.java} | 26 +-
.../common/command/cursor/CursorNextCommand.java} | 26 +-
.../apache/ignite/metastorage/common/Entry.java | 7 +
.../org/apache/ignite/metastorage/common/Key.java | 3 +-
.../ignite/metastorage/common/KeyValueStorage.java | 91 ++
.../metastorage/common/KeyValueStorageImpl.java | 183 ++++
.../ignite/metastorage/common/WatchEvent.java | 36 +-
.../common/raft/MetaStorageCommandListener.java | 297 ++++++
.../internal/metastorage/MetaStorageManager.java | 243 ++++-
.../internal/metastorage/WatchAggregatorTest.java | 30 +-
modules/network/pom.xml | 19 +
.../ignite/network/ConnectionManagerTest.java | 184 ++++
.../ignite/network/DirectSerializationTest.java | 110 --
.../network/TestMessageSerializationFactory.java | 4 +-
.../network/scalecube/ITNodeRestartsTest.java | 142 +++
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 36 +-
.../TestScaleCubeClusterServiceFactory.java} | 37 +-
.../org/apache/ignite/network/ClusterNode.java | 41 +-
.../apache/ignite/network/NetworkException.java | 33 -
.../org/apache/ignite/network/TopologyService.java | 9 +
.../internal/direct/DirectMarshallingUtils.java} | 30 +-
.../internal/direct/DirectMessageReader.java | 2 +-
.../internal/direct/DirectMessageWriter.java | 14 +-
.../stream/DirectByteBufferStreamImplV1.java | 2 +-
.../network/internal/netty/ConnectionManager.java | 250 +++++
.../network/internal/netty/InboundDecoder.java | 125 +++
.../network/internal/netty/MessageHandler.java | 48 +
.../ignite/network/internal/netty/NettyClient.java | 162 +++
.../ignite/network/internal/netty/NettySender.java | 166 +++
.../ignite/network/internal/netty/NettyServer.java | 276 +++++
.../ignite/network/internal/netty/NettyUtils.java | 77 ++
.../scalecube/DelegatingTransportFactory.java | 27 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 27 +-
.../ScaleCubeDirectMarshallerTransport.java | 248 +++++
.../scalecube/ScaleCubeMessagingService.java | 26 +-
.../scalecube/ScaleCubeTopologyService.java | 53 +-
.../scalecube/message/ScaleCubeMessage.java | 62 ++
.../ScaleCubeMessageSerializationFactory.java} | 52 +-
.../ignite/network/internal/AllTypesMessage.java | 154 +++
.../network/internal/AllTypesMessageGenerator.java | 215 ++++
.../AllTypesMessageSerializationFactory.java | 562 ++++++++++
.../ignite/network/internal/TestFieldType.java} | 16 +-
.../network/internal/netty/InboundDecoderTest.java | 208 ++++
.../network/internal/netty/NettyClientTest.java | 209 ++++
.../network/internal/netty/NettyServerTest.java | 180 ++++
.../message/MessageSerializationRegistryTest.java | 105 ++
.../src/test/resources/simplelogger.properties | 52 +
.../raft/client/service/RaftGroupServiceTest.java | 6 +-
.../raft/server/ITRaftCounterServerTest.java | 11 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 12 +
.../ignite/raft/server/impl/RaftServerImpl.java | 2 -
.../json/TestConfigurationStorage.java | 4 +-
.../ignite/internal/runner/app/IgnitionTest.java | 11 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 123 +--
.../storage/DistributedConfigurationStorage.java | 205 +++-
.../storage/LocalConfigurationStorage.java | 79 +-
modules/table/pom.xml | 11 +-
.../internal/table/distributed/TableManager.java | 303 +++---
.../distributed/storage/InternalTableImpl.java | 14 +-
.../table/distributed/DistributedTableTest.java | 6 +-
.../apache/ignite/internal/vault/VaultManager.java | 34 +-
.../internal/vault/impl/VaultServiceImpl.java | 16 +-
.../internal/vault/service/VaultService.java | 21 +-
94 files changed, 7609 insertions(+), 957 deletions(-)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/event/TableEvent.java => affinity/src/main/java/org/apache/ignite/internal/affinity/event/AffinityEvent.java} (75%)
create mode 100644 modules/affinity/src/main/java/org/apache/ignite/internal/affinity/event/AffinityEventParameters.java
create mode 100644 modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/MetaStorageServiceTest.java
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/CursorImpl.java
create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/MetaStorageServiceImpl.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/DummyEntry.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAllCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndPutAllCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndPutCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndRemoveAllCommand.java
copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndRemoveCommand.java} (53%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/PutAllCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/PutCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/RangeCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/RemoveAllCommand.java
copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/RemoveCommand.java} (56%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/WatchExactKeysCommand.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/WatchRangeKeysCommand.java
copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorCloseCommand.java} (56%)
copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorHasNextCommand.java} (55%)
copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorNextCommand.java} (55%)
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/KeyValueStorage.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/KeyValueStorageImpl.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/raft/MetaStorageCommandListener.java
create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/ConnectionManagerTest.java
delete mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/DirectSerializationTest.java
create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ITNodeRestartsTest.java
copy modules/{cli/src/main/java/org/apache/ignite/cli/VersionProvider.java => network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestScaleCubeClusterServiceFactory.java} (50%)
delete mode 100644 modules/network/src/main/java/org/apache/ignite/network/NetworkException.java
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/registry/SchemaRegistryException.java => network/src/main/java/org/apache/ignite/network/internal/direct/DirectMarshallingUtils.java} (55%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/ConnectionManager.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/InboundDecoder.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/MessageHandler.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyClient.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettySender.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyServer.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/internal/netty/NettyUtils.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeDirectMarshallerTransport.java
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/message/ScaleCubeMessage.java
copy modules/network/src/{integrationTest/java/org/apache/ignite/network/TestMessageSerializationFactory.java => main/java/org/apache/ignite/network/scalecube/message/ScaleCubeMessageSerializationFactory.java} (61%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/internal/AllTypesMessage.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/internal/AllTypesMessageGenerator.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/internal/AllTypesMessageSerializationFactory.java
copy modules/{core/src/main/java/org/apache/ignite/internal/tostring/IgniteToStringExclude.java => network/src/test/java/org/apache/ignite/network/internal/TestFieldType.java} (71%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/internal/netty/InboundDecoderTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/internal/netty/NettyClientTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/internal/netty/NettyServerTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/message/MessageSerializationRegistryTest.java
create mode 100644 modules/network/src/test/resources/simplelogger.properties