X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=mdsal.git;a=blobdiff_plain;f=replicate%2Fmdsal-replicate-netty%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Freplicate%2Fnetty%2FSourceRequestHandler.java;h=b7811f01845eca02166532d4bd18b1120a550ce3;hp=f302ca156de1f3820a36e95adcbca2e8f0e465b3;hb=625453e1d93ae3f66131bc1c87059b3a233fa073;hpb=54eeeeaa0eb9c98933c20f30336f82fb15501566 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 f302ca156d..b7811f0184 100644 --- 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 { 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 changes) { + LOG.debug("Channel {} tree {} has {} changes", channel, dataTree, changes.size()); channel.writeAndFlush(AbstractSourceMessage.of(changes)); } });