Code Review / mdsal.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: f9aecc3) | patch
Add basic netty replication utility 65/90465/5
authorRobert Varga <robert.varga@pantheon.tech>
Wed, 17 Jun 2020 10:29:12 +0000 (12:29 +0200)
committerRobert Varga <robert.varga@pantheon.tech>
Wed, 17 Jun 2020 17:59:38 +0000 (19:59 +0200)
commitd7b666857c54c07d9bf5c8e5e38671151d89fb4c
tree7a874f45efb015798d23a8b146855593c7d09f23tree | snapshot
parentf9aecc3936ed7968207102ac4a633d4e6d2201bdcommit | 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>
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