Merge pull request #504 from y-higuchi/cosmetic4
Cosmetic4
diff --git a/src/main/java/net/onrc/onos/ofcontroller/floodlightlistener/NetworkGraphPublisher.java b/src/main/java/net/onrc/onos/ofcontroller/floodlightlistener/NetworkGraphPublisher.java
index 22241ce..ea547fc 100644
--- a/src/main/java/net/onrc/onos/ofcontroller/floodlightlistener/NetworkGraphPublisher.java
+++ b/src/main/java/net/onrc/onos/ofcontroller/floodlightlistener/NetworkGraphPublisher.java
@@ -56,7 +56,7 @@
ILinkDiscoveryListener,
IFloodlightModule,
INetworkGraphService {
-
+
protected IDeviceStorage devStore;
protected ISwitchStorage swStore;
protected ILinkStorage linkStore;
@@ -64,19 +64,19 @@
//protected IDeviceService deviceService;
protected IControllerRegistryService registryService;
protected GraphDBOperation op;
-
+
protected static final String DBConfigFile = "dbconf";
protected static final String CleanupEnabled = "EnableCleanup";
protected IThreadPoolService threadPool;
protected IFloodlightProviderService floodlightProvider;
-
+
protected final int CLEANUP_TASK_INTERVAL = 60; // 1 min
protected SingletonTask cleanupTask;
protected ILinkDiscoveryService linkDiscovery;
protected IDatagridService datagridService;
-
- /**
+
+ /**
* Cleanup and synch switch state from registry
*/
protected class SwitchCleanup implements ControlChangeCallback, Runnable {
@@ -114,7 +114,7 @@
//if (swStore.updateSwitch(HexString.toHexString(dpid), SwitchState.INACTIVE, DM_OPERATION.UPDATE)) {
if (swStore.deactivateSwitch(HexString.toHexString(dpid))) {
registryService.releaseControl(dpid);
-
+
// TODO publish UPDATE_SWITCH event here
//
// NOTE: Here we explicitly send
@@ -144,14 +144,14 @@
} catch (Exception e) {
log.error("Error in SwitchCleanup:controlChanged ", e);
}
- }
+ }
}
}
protected void switchCleanup() {
op.close();
Iterable<ISwitchObject> switches = op.getActiveSwitches();
-
+
log.debug("Checking for inactive switches");
// For each switch check if a controller exists in controller registry
for (ISwitchObject sw: switches) {
@@ -249,7 +249,7 @@
TopologyElement topologyElementPort =
new TopologyElement(sw.getId(), port.getPortNumber());
datagridService.notificationSendTopologyElementAdded(topologyElementPort);
-
+
// Allow links to be discovered on this port now that it's
// in the database
linkDiscovery.RemoveFromSuppressLLDPs(sw.getId(), port.getPortNumber());
@@ -324,7 +324,7 @@
// Allow links to be discovered on this port now that it's
// in the database
linkDiscovery.RemoveFromSuppressLLDPs(switchId, port.getPortNumber());
-
+
// TODO publish ADD_PORT event here
TopologyElement topologyElement =
new TopologyElement(switchId, port.getPortNumber());
@@ -409,7 +409,7 @@
public void deviceVlanChanged(IDevice device) {
// TODO Auto-generated method stub
}
-
+
@Override
public Collection<Class<? extends IFloodlightService>> getModuleServices() {
@@ -446,7 +446,7 @@
Map<String, String> configMap = context.getConfigParams(this);
String conf = configMap.get(DBConfigFile);
op = new GraphDBOperation(conf);
-
+
floodlightProvider =
context.getServiceImpl(IFloodlightProviderService.class);
//deviceService = context.getServiceImpl(IDeviceService.class);
@@ -454,18 +454,18 @@
threadPool = context.getServiceImpl(IThreadPoolService.class);
registryService = context.getServiceImpl(IControllerRegistryService.class);
datagridService = context.getServiceImpl(IDatagridService.class);
-
+
devStore = new DeviceStorageImpl();
devStore.init(conf);
-
+
swStore = new SwitchStorageImpl();
swStore.init(conf);
-
+
linkStore = new LinkStorageImpl();
linkStore.init(conf);
-
+
log.debug("Initializing NetworkGraphPublisher module with {}", conf);
-
+
}
@Override
@@ -476,11 +476,11 @@
//deviceService.addListener(this);
floodlightProvider.addOFSwitchListener(this);
linkDiscovery.addListener(this);
-
+
log.debug("Adding EventListener");
IDBConnection conn = op.getDBConnection();
conn.addEventListener(new LocalTopologyEventListener((GraphDBConnection) conn));
- // Setup the Cleanup task.
+ // Setup the Cleanup task.
if (cleanupNeeded == null || !cleanupNeeded.equals("False")) {
ScheduledExecutorService ses = threadPool.getScheduledExecutor();
cleanupTask = new SingletonTask(ses, new SwitchCleanup());
diff --git a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
index e821a97..53876d2 100644
--- a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
+++ b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowManager.java
@@ -89,6 +89,7 @@
/**
* Shutdown the Flow Manager operation.
*/
+ @Override
public void finalize() {
close();
}
@@ -110,7 +111,7 @@
*/
@Override
public Collection<Class<? extends IFloodlightService>> getModuleServices() {
- Collection<Class<? extends IFloodlightService>> l =
+ Collection<Class<? extends IFloodlightService>> l =
new ArrayList<Class<? extends IFloodlightService>>();
l.add(IFlowService.class);
return l;
@@ -122,7 +123,7 @@
* @return the collection of implemented services.
*/
@Override
- public Map<Class<? extends IFloodlightService>, IFloodlightService>
+ public Map<Class<? extends IFloodlightService>, IFloodlightService>
getServiceImpls() {
Map<Class<? extends IFloodlightService>,
IFloodlightService> m =
@@ -138,7 +139,7 @@
* @return the collection of modules this module depends on.
*/
@Override
- public Collection<Class<? extends IFloodlightService>>
+ public Collection<Class<? extends IFloodlightService>>
getModuleDependencies() {
Collection<Class<? extends IFloodlightService>> l =
new ArrayList<Class<? extends IFloodlightService>>();
@@ -368,6 +369,7 @@
*
* @return the network topology.
*/
+ @Override
public Topology getTopology() {
return flowEventHandler.getTopology();
}
@@ -378,6 +380,7 @@
* @param sw the switch the Flow Entry expired on.
* @param flowEntryId the Flow Entry ID of the expired Flow Entry.
*/
+ @Override
public void flowEntryOnSwitchExpired(IOFSwitch sw,
FlowEntryId flowEntryId) {
// Find the Flow Entry
@@ -406,6 +409,7 @@
* @param entries the collection of <IOFSwitch, FlowEntry> pairs
* that have been pushed.
*/
+ @Override
public void flowEntriesPushedToSwitch(
Collection<Pair<IOFSwitch, FlowEntry>> entries) {