This is an automated email from the ASF dual-hosted git repository.
agura pushed a change to branch ignite-14389
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard 6d98268 IGNITE-14389 MetaStorageService integration
discard 7eebebf WIP
discard 5fe099d IGNITE-14389 Implemented cursor for ranges and watches.
discard 36722c6 IGNITE-14389 Added putAll and removeAll. Started cursor
management: ranges and watches (WIP)
discard 904f266 IGNITE-14389 putAll initial (WIP)
discard 02f3371 IGNITE-14389 getAll and tests (WIP)
discard 9cd33ea IGNITE-14389 Added get and do smth semantic
discard ead9ad5 IGNITE-14398: Meta storage: added update counter
discard 4fbbaa9 IGNITE-14389 Meta storage: in-memory implementation WIP
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 9f3e028 IGNITE-14717 Wide use of TestScaleCubeClusterServiceFactory.
(#128)
new a1eb463 IGNITE-14389 Meta storage: in-memory implementation WIP
new de979bd IGNITE-14398: Meta storage: added update counter
new 1a1e8be IGNITE-14389 Added get and do smth semantic
new 7e0547d IGNITE-14389 getAll and tests (WIP)
new 54b1c42 IGNITE-14389 putAll initial (WIP)
new efe4f16 IGNITE-14389 Added putAll and removeAll. Started cursor
management: ranges and watches (WIP)
new a0febd6 IGNITE-14389 Implemented cursor for ranges and watches.
new 67128be WIP
new 51d3fb4 IGNITE-14389 MetaStorageService integration
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6d98268)
\
N -- N -- N refs/heads/ignite-14389 (51d3fb4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../ignite/internal/affinity/AffinityManager.java | 168 ++---
.../affinity/RendezvousAffinityFunction.java | 11 +-
.../internal/affinity/event/AffinityEvent.java} | 14 +-
.../affinity/event/AffinityEventParameters.java} | 44 +-
.../affinity/RendezvousAffinityFunctionTest.java | 3 +-
.../ignite/internal/baseline/BaselineManager.java | 1 +
modules/metastorage-client/pom.xml | 8 +
...viceTest.java => ITMetaStorageServiceTest.java} | 751 ++++++++++-----------
.../internal/metastorage/MetaStorageManager.java | 40 +-
modules/network/pom.xml | 31 +
.../ignite/network/ConnectionManagerTest.java | 184 +++++
.../ignite/network/DirectSerializationTest.java | 110 ---
.../network/TestMessageSerializationFactory.java | 2 +-
.../network/scalecube/ITNodeRestartsTest.java | 142 ++++
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 32 +-
.../TestScaleCubeClusterServiceFactory.java | 40 ++
.../org/apache/ignite/network/ClusterNode.java | 41 +-
.../apache/ignite/network/NetworkException.java | 33 -
.../org/apache/ignite/network/TopologyService.java | 9 +
.../internal/direct/DirectMarshallingUtils.java} | 34 +-
.../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 | 25 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 31 +-
.../ScaleCubeDirectMarshallerTransport.java | 248 +++++++
.../scalecube/ScaleCubeMessagingService.java | 26 +-
.../scalecube/ScaleCubeTopologyService.java | 53 +-
.../scalecube/message/ScaleCubeMessage.java | 62 ++
.../ScaleCubeMessageSerializationFactory.java} | 50 +-
.../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 +-
modules/raft/pom.xml | 7 +
.../raft/server/ITRaftCounterServerTest.java | 15 +-
.../ignite/raft/server/impl/RaftServerImpl.java | 2 -
.../apache/ignite/internal/app/IgnitionImpl.java | 8 +-
modules/table/pom.xml | 16 +-
.../distributed/ITDistributedTableTest.java} | 16 +-
.../internal/table/distributed/TableManager.java | 274 ++++----
parent/pom.xml | 7 +
55 files changed, 4405 insertions(+), 962 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%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/TableSchemaViewImpl.java
=>
affinity/src/main/java/org/apache/ignite/internal/affinity/event/AffinityEventParameters.java}
(52%)
rename
modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/{MetaStorageServiceTest.java
=> ITMetaStorageServiceTest.java} (55%)
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
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestScaleCubeClusterServiceFactory.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/network/NetworkException.java
copy
modules/{metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/MultipleEntryResponse.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
rename
modules/table/src/{test/java/org/apache/ignite/table/distributed/DistributedTableTest.java
=>
integrationTest/java/org/apache/ignite/distributed/ITDistributedTableTest.java}
(95%)
