Add a unit test for netty replication

[mdsal.git] / replicate / mdsal-replicate-netty / src / main / java / org / opendaylight / mdsal / replicate / netty / SourceRequestHandler.java

diff --git a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java
index f302ca156de1f3820a36e95adcbca2e8f0e465b3..b7811f01845eca02166532d4bd18b1120a550ce3 100644 (file)
--- a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java
+++ b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java
@@ -82,11 +82,13 @@ final class SourceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> {
         reg = dtcs.registerDataTreeChangeListener(dataTree, new ClusteredDOMDataTreeChangeListener() {
             @Override
             public void onInitialData() {
+                LOG.debug("Channel {} tree {} has empty data", channel, dataTree);
                 channel.writeAndFlush(AbstractSourceMessage.empty());
             }
 
             @Override
             public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {
+                LOG.debug("Channel {} tree {} has {} changes", channel, dataTree, changes.size());
                 channel.writeAndFlush(AbstractSourceMessage.of(changes));
             }
         });