Code Review / mdsal.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 56ed93d) | patch
Add basic netty replication utility 15/90515/4
authorRobert Varga <robert.varga@pantheon.tech>
Wed, 17 Jun 2020 10:29:12 +0000 (12:29 +0200)
committerRobert Varga <robert.varga@pantheon.tech>
Mon, 22 Jun 2020 08:54:18 +0000 (10:54 +0200)
commitcd61eab688c3bbd7d54d04b2c72021838ee3ca71
treef51df26163192d6fb8b7277f7d3491c47f1f79f3tree | snapshot
parent56ed93d523a05f6d38f3e20d7f88e87ad830d484commit | diff
Add basic netty replication utility

This adds a source/sink datastore replication component based on
Netty TCP channels. The sink (consumer) connects to source (producer)
via a channel, specifies which data tree it wants replicated and
then listens for DataTreeCandidates to arrive from the source.

Change-Id: Ib283baa9a186ae2fb4ccf909b257006d4645de37
Signed-off-by: Tibor Král <tibor.kral@pantheon.tech>
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
(cherry picked from commit d7b666857c54c07d9bf5c8e5e38671151d89fb4c)
32 files changed:
artifacts/pom.xml diff | blob | history
docs/pom.xml diff | blob | history
features/features-mdsal-experimental/pom.xml diff | blob | history
features/odl-mdsal-exp-replicate-common/pom.xml [new file with mode: 0644] blob
features/odl-mdsal-exp-replicate-netty/pom.xml [new file with mode: 0644] blob
features/pom.xml diff | blob | history
pom.xml diff | blob | history
replicate/mdsal-replicate-common/pom.xml [new file with mode: 0644] blob
replicate/mdsal-replicate-common/src/main/java/org/opendaylight/mdsal/replicate/common/DOMDataBrokerModification.java [new file with mode: 0644] blob
replicate/mdsal-replicate-common/src/main/java/org/opendaylight/mdsal/replicate/common/DOMStoreModification.java [new file with mode: 0644] blob
replicate/mdsal-replicate-common/src/main/java/org/opendaylight/mdsal/replicate/common/DataTreeCandidateUtils.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/pom.xml [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/AbstractBootstrapSupport.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/AbstractSourceMessage.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/BootstrapSupport.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/Constants.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/DeltaEncoder.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/EpollBootstrapSupport.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/MessageFrameDecoder.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/MessageFrameEncoder.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/NettyReplication.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/NioBootstrapSupport.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkRequestHandler.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkSingletonService.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkTransactionChainListener.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceSingletonService.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SplittingOutputStream.java [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/resources/org/opendaylight/blueprint/netty-replication-common.xml [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/resources/org/opendaylight/blueprint/netty-replication-sink.xml [new file with mode: 0644] blob
replicate/mdsal-replicate-netty/src/main/resources/org/opendaylight/blueprint/netty-replication-source.xml [new file with mode: 0644] blob
replicate/pom.xml [new file with mode: 0644] blob
MD-SAL: Model-Driven Service Adaptation Layer