Code Review / mdsal.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: a43bfcc) | patch
Add basic netty replication utility 06/90506/1
authorRobert Varga <robert.varga@pantheon.tech>
Wed, 17 Jun 2020 10:29:12 +0000 (12:29 +0200)
committerRobert Varga <robert.varga@pantheon.tech>
Fri, 19 Jun 2020 08:53:26 +0000 (10:53 +0200)
commit429d57dcd7a3a7838617ee9b37150a486b238942
tree76b4d243935df61e6858e3578ebf7aac0427632atree | snapshot
parenta43bfcc6f0afa8a03f25c1c854bc7a023a7e5fb0commit | 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