Logs are added to identify the flows and groups being added in 60/63260/4
authoreeiillu <suja.t@ericsson.com>
Tue, 19 Sep 2017 06:08:25 +0000 (11:38 +0530)
committerSujaT <suja.t@ericsson.com>
Wed, 11 Apr 2018 05:58:24 +0000 (11:28 +0530)
the node for the corresponding transaction ID when it's pushed in
the form of bundle messages going via bundle experimenter messages.

Change-Id: I880a7f9e88535a6215912f9b17b63c9a9e9ce9de
Signed-off-by: eeiillu <suja.t@ericsson.com>
openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalExperimenterMessageServiceImpl.java

index aab332a83fa5d6a0ff822bd073ba87f13a0f5d07..0d6f4b0de8993957e08c0f6f6b177f3eeca3e35c 100644 (file)
@@ -21,16 +21,21 @@ import org.opendaylight.openflowplugin.impl.services.AbstractVoidService;
 import org.opendaylight.openflowplugin.impl.services.util.ServiceException;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.message.service.rev151020.SalExperimenterMessageService;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.message.service.rev151020.SendExperimenterInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterInputBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.experimenter.core.ExperimenterDataOfChoice;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.experimenter.types.rev151020.experimenter.core.message.ExperimenterMessageOfChoice;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.send.experimenter.input.experimenter.message.of.choice.BundleAddMessageSal;
 import org.opendaylight.yangtools.yang.common.RpcResult;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 
 public class SalExperimenterMessageServiceImpl extends AbstractVoidService<SendExperimenterInput>
                                                implements SalExperimenterMessageService {
 
+    private static final Logger LOG = LoggerFactory.getLogger(SalExperimenterMessageServiceImpl.class);
     private final ExtensionConverterProvider extensionConverterProvider;
 
     public SalExperimenterMessageServiceImpl(final RequestContextStack requestContextStack,
@@ -56,6 +61,13 @@ public class SalExperimenterMessageServiceImpl extends AbstractVoidService<SendE
         if (messageConverter instanceof BundleMessageDataInjector) {
             ((BundleMessageDataInjector) messageConverter).setNode(input.getNode());
             ((BundleMessageDataInjector) messageConverter).setXid(xid.getValue());
+            if (LOG.isDebugEnabled()) {
+                LOG.debug("Flows and groups pushed to the node: {} with transaction id : {} are {}",
+                        ((BundleAddMessageSal) input.getExperimenterMessageOfChoice())
+                                .getSalAddMessageData().getBundleInnerMessage(),
+                        input.getNode().getValue().firstKeyOf(Node.class).getId(),
+                        xid);
+            }
         }
 
         try {