X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fswitchmanager%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fswitchmanager%2Finternal%2FSwitchManagerImpl.java;h=443c7a42ab7da517fbb8df65082c36d1a220a79e;hp=2937fe7e14710c3655cf99e954bcc6cd4aefa05c;hb=eae5ef7cfee9bacecc5281cc378a904fe9ae4b96;hpb=2aa5c39bdd7c498a3b33db434d3943c130e05bc8 diff --git a/opendaylight/switchmanager/implementation/src/main/java/org/opendaylight/controller/switchmanager/internal/SwitchManagerImpl.java b/opendaylight/switchmanager/implementation/src/main/java/org/opendaylight/controller/switchmanager/internal/SwitchManagerImpl.java index 2937fe7e14..443c7a42ab 100644 --- a/opendaylight/switchmanager/implementation/src/main/java/org/opendaylight/controller/switchmanager/internal/SwitchManagerImpl.java +++ b/opendaylight/switchmanager/implementation/src/main/java/org/opendaylight/controller/switchmanager/internal/SwitchManagerImpl.java @@ -820,6 +820,8 @@ CommandProvider { @Override public void updateNode(Node node, UpdateType type, Set props) { + log.debug("updateNode: {} type {} props {} for container {}", + new Object[] { node, type, props, containerName }); switch (type) { case ADDED: addNode(node, props); @@ -841,7 +843,8 @@ CommandProvider { Node node = nodeConnector.getNode(); Map propMap = new HashMap(); - log.trace("{} {}", nodeConnector, type); + log.debug("updateNodeConnector: {} type {} props {} for container {}", + new Object[] { nodeConnector, type, props, containerName }); if (nodeConnectorProps == null) { return; @@ -1335,6 +1338,8 @@ CommandProvider { Set nodeSet = nodeProps.keySet(); if (nodeSet != null) { for (Node node : nodeSet) { + log.debug("getInventories: {} added for container {}", + new Object[] { node, containerName }); addNode(node, null); } } @@ -1384,17 +1389,17 @@ CommandProvider { } private void bulkUpdateService(IInventoryListener service) { + Map propMap; + UpdateType type = UpdateType.ADDED; + for (Node node : getNodes()) { - service.notifyNode(node, UpdateType.ADDED, null); + propMap = nodeProps.get(node); + service.notifyNode(node, type, propMap); } - Map propMap = new HashMap(); - propMap.put(State.StatePropName, new State(State.EDGE_UP)); for (NodeConnector nodeConnector : nodeConnectorProps.keySet()) { - if (isNodeConnectorEnabled(nodeConnector)) { - service.notifyNodeConnector(nodeConnector, UpdateType.ADDED, - propMap); - } + propMap = nodeConnectorProps.get(nodeConnector); + service.notifyNodeConnector(nodeConnector, type, propMap); } } @@ -1457,10 +1462,11 @@ CommandProvider { String nodeName = (desc == null) ? "" : desc.getValue(); MacAddress mac = (MacAddress) getNodeProp(node, MacAddress.name); + String macAddr = (mac == null) ? "" : HexEncode + .bytesToHexStringFormat(mac.getMacAddress()); int tierNum = (tier == null) ? 0 : tier.getValue(); - ci.println(node + " " + node.getType() + " " - + HexEncode.bytesToHexStringFormat(mac.getMacAddress()) - + " " + nodeName + " " + tierNum ); + ci.println(node + " " + node.getType() + " " + macAddr + + " " + nodeName + " " + tierNum); } ci.println("Total number of Nodes: " + nodeSet.size()); } @@ -1645,7 +1651,8 @@ CommandProvider { @Override public byte[] getNodeMAC(Node node) { - MacAddress mac = (MacAddress) nodeProps.get(MacAddress.name); + MacAddress mac = (MacAddress) this.getNodeProp(node, + MacAddress.name); return (mac != null) ? mac.getMacAddress() : null; } @@ -1697,7 +1704,7 @@ CommandProvider { List ncLists = new ArrayList(); for (NodeConnector nodeConnector : nodeConncetors) { - if (!spanNodeConnectors.contains(nodeConnector)) { + if (spanNodeConnectors.contains(nodeConnector)) { ncLists.add(nodeConnector); } }