*/
package org.opendaylight.openflowplugin.applications.bulk.o.matic;
+import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
-import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.concurrent.ExecutionException;
try (ReadTransaction readOnlyTransaction = dataBroker.newReadOnlyTransaction()) {
Optional<Nodes> nodesDataNode = readOnlyTransaction.read(LogicalDatastoreType.OPERATIONAL, nodes).get();
if (nodesDataNode.isPresent()) {
- List<Node> nodesCollection = nodesDataNode.get().getNode();
- if (nodesCollection != null && !nodesCollection.isEmpty()) {
+ Collection<Node> nodesCollection = nodesDataNode.get().nonnullNode().values();
+ if (!nodesCollection.isEmpty()) {
for (Node node : nodesCollection) {
LOG.info("Switch with ID {} discovered !!", node.getId().getValue());
nodeIds.add(node.getId().getValue());
AddFlowInput addFlowInput = builder.build();
- LOG.debug("RPC invocation for adding flow-id {} with input {}", flowId, addFlowInput.toString());
+ LOG.debug("RPC invocation for adding flow-id {} with input {}", flowId, addFlowInput);
LoggingFutures.addErrorLogging(flowService.addFlow(addFlowInput), LOG, "addFlow");
if (i % batchSize == 0) {