Refactor: reduce to number of column for better readability at SONA
Change-Id: Ic8dd78cfc219272f98f37651f244c3564755960c
diff --git a/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DefaultOpenstackNodeHandler.java b/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DefaultOpenstackNodeHandler.java
index 7be2074..dab1fc11 100644
--- a/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DefaultOpenstackNodeHandler.java
+++ b/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DefaultOpenstackNodeHandler.java
@@ -149,7 +149,8 @@
/** OVSDB server listen port. */
private int ovsdbPortNum = OVSDB_PORT_NUM_DEFAULT;
- /** A flag which indicates whether auto-recover openstack node status on switch reconnecting event. */
+ /** A flag which indicates whether auto-recover openstack node status on
+ * switch reconnecting event. */
private boolean autoRecovery = AUTO_RECOVERY_DEFAULT;
private final ExecutorService eventExecutor = newSingleThreadExecutor(
@@ -229,14 +230,14 @@
if (osNode.dpdkConfig() != null && osNode.dpdkConfig().dpdkIntfs() != null) {
osNode.dpdkConfig().dpdkIntfs().stream()
- .filter(dpdkInterface -> dpdkInterface.deviceName().equals(TUNNEL_BRIDGE))
- .forEach(dpdkInterface -> addOrRemoveDpdkInterface(
- osNode, dpdkInterface, ovsdbPortNum, ovsdbController, true));
+ .filter(dpdkintf -> dpdkintf.deviceName().equals(TUNNEL_BRIDGE))
+ .forEach(dpdkintf -> addOrRemoveDpdkInterface(
+ osNode, dpdkintf, ovsdbPortNum, ovsdbController, true));
osNode.dpdkConfig().dpdkIntfs().stream()
- .filter(dpdkInterface -> dpdkInterface.deviceName().equals(INTEGRATION_BRIDGE))
- .forEach(dpdkInterface -> addOrRemoveDpdkInterface(
- osNode, dpdkInterface, ovsdbPortNum, ovsdbController, true));
+ .filter(dpdkintf -> dpdkintf.deviceName().equals(INTEGRATION_BRIDGE))
+ .forEach(dpdkintf -> addOrRemoveDpdkInterface(
+ osNode, dpdkintf, ovsdbPortNum, ovsdbController, true));
}
osNode.phyIntfs().forEach(i -> {
@@ -249,7 +250,7 @@
if (osNode.vlanIntf() != null &&
!isIntfEnabled(osNode, osNode.vlanIntf())) {
addOrRemoveSystemInterface(osNode, INTEGRATION_BRIDGE,
- osNode.vlanIntf(), deviceService, true);
+ osNode.vlanIntf(), deviceService, true);
}
} catch (Exception e) {
log.error("Exception occurred because of {}", e.toString());
@@ -367,7 +368,8 @@
}
/**
- * Checks whether a given network interface in a given openstack node is enabled or not.
+ * Checks whether a given network interface in a given openstack node
+ * is enabled or not.
*
* @param osNode openstack node
* @param intf network interface name
@@ -390,7 +392,8 @@
private boolean isCurrentStateDone(OpenstackNode osNode) {
switch (osNode.state()) {
case INIT:
- if (!isOvsdbConnected(osNode, ovsdbPortNum, ovsdbController, deviceService)) {
+ if (!isOvsdbConnected(osNode, ovsdbPortNum,
+ ovsdbController, deviceService)) {
return false;
}
@@ -445,15 +448,15 @@
Set<OvsdbPort> ports = client.getPorts();
- for (DpdkInterface dpdkInterface : dpdkInterfaces) {
+ for (DpdkInterface dpdkIntf : dpdkInterfaces) {
Optional<OvsdbPort> port = ports.stream()
- .filter(ovsdbPort -> ovsdbPort.portName().value().equals(dpdkInterface.intf()))
+ .filter(ovsdbPort -> ovsdbPort.portName().value().equals(dpdkIntf.intf()))
.findAny();
if (!port.isPresent()) {
return false;
}
- Interface intf = client.getInterface(dpdkInterface.intf());
+ Interface intf = client.getInterface(dpdkIntf.intf());
if (intf == null) {
return false;
}
@@ -468,8 +471,8 @@
return false;
}
- if (!mtu.set().contains(dpdkInterface.mtu().intValue()) ||
- !option.toString().contains(dpdkInterface.pciAddress())) {
+ if (!mtu.set().contains(dpdkIntf.mtu().intValue()) ||
+ !option.toString().contains(dpdkIntf.pciAddress())) {
log.trace("The dpdk interface {} was created but mtu or " +
"pci address is different from the config.");
return false;
@@ -516,21 +519,23 @@
private void removeVlanInterface(OpenstackNode osNode) {
if (osNode.vlanIntf() != null) {
- Optional<DpdkInterface> dpdkInterface = dpdkInterfaceByIntfName(osNode, osNode.vlanIntf());
+ Optional<DpdkInterface> dpdkIntf =
+ dpdkInterfaceByIntfName(osNode, osNode.vlanIntf());
- removeInterfaceOnIntegrationBridge(osNode, osNode.vlanIntf(), dpdkInterface);
+ removeInterfaceOnIntegrationBridge(osNode, osNode.vlanIntf(), dpdkIntf);
}
}
private void removePhysicalInterface(OpenstackNode osNode) {
osNode.phyIntfs().forEach(phyIntf -> {
- Optional<DpdkInterface> dpdkInterface = dpdkInterfaceByIntfName(osNode, phyIntf.intf());
+ Optional<DpdkInterface> dpdkIntf = dpdkInterfaceByIntfName(osNode, phyIntf.intf());
- removeInterfaceOnIntegrationBridge(osNode, phyIntf.intf(), dpdkInterface);
+ removeInterfaceOnIntegrationBridge(osNode, phyIntf.intf(), dpdkIntf);
});
}
- private Optional<DpdkInterface> dpdkInterfaceByIntfName(OpenstackNode osNode, String intf) {
+ private Optional<DpdkInterface> dpdkInterfaceByIntfName(OpenstackNode osNode,
+ String intf) {
return osNode.dpdkConfig() == null ? Optional.empty() :
osNode.dpdkConfig().dpdkIntfs().stream()
.filter(dpdkIntf -> dpdkIntf.intf().equals(intf))
diff --git a/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DistributedOpenstackNodeStore.java b/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DistributedOpenstackNodeStore.java
index 188520f..9014076 100644
--- a/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DistributedOpenstackNodeStore.java
+++ b/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/DistributedOpenstackNodeStore.java
@@ -82,8 +82,10 @@
private static final String ERR_NOT_FOUND = " does not exist";
private static final String ERR_DUPLICATE = " already exists";
+ private static final String APP_ID = "org.onosproject.openstacknode";
- private static final KryoNamespace SERIALIZER_OPENSTACK_NODE = KryoNamespace.newBuilder()
+ private static final KryoNamespace
+ SERIALIZER_OPENSTACK_NODE = KryoNamespace.newBuilder()
.register(KryoNamespaces.API)
.register(OpenstackNode.class)
.register(DefaultOpenstackNode.class)
@@ -122,7 +124,7 @@
@Activate
protected void activate() {
- ApplicationId appId = coreService.registerApplication("org.onosproject.openstacknode");
+ ApplicationId appId = coreService.registerApplication(APP_ID);
osNodeStore = storageService.<String, OpenstackNode>consistentMapBuilder()
.withSerializer(Serializer.using(SERIALIZER_OPENSTACK_NODE))
.withName("openstack-nodestore")
@@ -180,7 +182,8 @@
/**
* An internal openstack node map listener.
*/
- private class OpenstackNodeMapListener implements MapEventListener<String, OpenstackNode> {
+ private class OpenstackNodeMapListener
+ implements MapEventListener<String, OpenstackNode> {
@Override
public void event(MapEvent<String, OpenstackNode> event) {
diff --git a/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/OpenstackNodeManager.java b/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/OpenstackNodeManager.java
index d990fae..0060e03 100644
--- a/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/OpenstackNodeManager.java
+++ b/apps/openstacknode/app/src/main/java/org/onosproject/openstacknode/impl/OpenstackNodeManager.java
@@ -78,7 +78,8 @@
OVSDB_PORT + ":Integer=" + OVSDB_PORT_NUM_DEFAULT
}
)
-public class OpenstackNodeManager extends ListenerRegistry<OpenstackNodeEvent, OpenstackNodeListener>
+public class OpenstackNodeManager
+ extends ListenerRegistry<OpenstackNodeEvent, OpenstackNodeListener>
implements OpenstackNodeService, OpenstackNodeAdminService {
private final Logger log = getLogger(getClass());
@@ -210,8 +211,8 @@
}
if (!intfsRemovedFromExistNode(existingNode)) {
- log.error("Updated node failed because intfs of existingNode {} are not removed properly",
- existingNode.toString());
+ log.error("Updated node failed because intfs of existingNode {} " +
+ "are not removed properly", existingNode.toString());
return;
}
@@ -291,7 +292,8 @@
connectSwitch(osNode);
- addOrRemoveSystemInterface(osNode, INTEGRATION_BRIDGE, portName, deviceService, true);
+ addOrRemoveSystemInterface(osNode, INTEGRATION_BRIDGE, portName,
+ deviceService, true);
}
@Override
@@ -300,7 +302,8 @@
connectSwitch(osNode);
- addOrRemoveSystemInterface(osNode, INTEGRATION_BRIDGE, portName, deviceService, false);
+ addOrRemoveSystemInterface(osNode, INTEGRATION_BRIDGE, portName,
+ deviceService, false);
}
private boolean intfsRemovedFromExistNode(OpenstackNode osNode) {
@@ -347,8 +350,8 @@
try {
ovsdbController.connect(osNode.managementIp(), tpPort(ovsdbPortNum));
} catch (Exception e) {
- log.error("Failed to connect to the openstackNode via ovsdb protocol because of exception {}",
- e.toString());
+ log.error("Failed to connect to the openstackNode via ovsdb " +
+ "protocol because of exception {}", e);
}
}
}