<properties>
<stax.version>1.0.1</stax.version>
- <yang.jmx.plugin>0.2.4-SNAPSHOT</yang.jmx.plugin>
<zeromq.version>0.3.1</zeromq.version>
</properties>
<dependency>
<groupId>org.opendaylight.controller</groupId>
<artifactId>yang-jmx-generator-plugin</artifactId>
- <version>${yang.jmx.plugin}</version>
+ <version>${config.version}</version>
</dependency>
<dependency>
<groupId>org.opendaylight.yangtools</groupId>
Thread.sleep(100);
} catch (InterruptedException e1) {
- logger.warn("TopologyNotify interrupted {}",
+ logger.trace("TopologyNotify interrupted {}",
e1.getMessage());
if (shuttingDown) {
return;
}
}
} catch (InterruptedException e1) {
- logger.warn(
+ logger.trace(
"Edge Bandwidth Utilization Notify Thread interrupted {}",
e1.getMessage());
if (shuttingDown) {
logger.debug("Bulk Notify container:{}", containerName);
TopologyBulkUpdate(containerName);
} catch (InterruptedException e) {
- logger.warn("Topology Bulk update thread interrupted");
+ logger.trace("Topology Bulk update thread interrupted");
if (shuttingDown) {
- return;
- }
+ return; }
}
}
}
protected void pollTxBitRates() {
Map<NodeConnector, Pair<Edge, Set<Property>>> globalContainerEdges = edgeMap
.get(GlobalConstants.DEFAULT.toString());
+ if (shuttingDown) {
+ logger.trace("Getting out the pollTxBitRates because bundle going down");
+ return;
+ }
if (globalContainerEdges == null) {
return;
}
logger.trace("STOP called!");
shuttingDown = true;
notifyThread.interrupt();
+ bwUtilNotifyThread.interrupt();
+ ofPluginTopoBulkUpdate.interrupt();
+ pollTimer.cancel();
}
void setTopologyServiceShimListener(Map<?, ?> props,