mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2026-05-04 19:56:49 +02:00
Code Issues Projects Releases Wiki Activity

Output log on a failure of resource registration

Browse Source 
Change-Id: I9a98dc49ae0f5f265fdc3b03142181348f86ee0f
This commit is contained in:
Sho SHIMIZU 2016-12-22 14:47:17 -08:00 committed by Jonathan Hart
parent e113df4c1d
commit f84ea7fb57
1 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
core/net/src/main/java/org/onosproject/net/resource/impl/ResourceDeviceListener.java
View File

@ -142,7 +142,12 @@ final class ResourceDeviceListener implements DeviceListener {
}
private void registerDeviceResource(Device device) {
executor.execute(() -> adminService.register(Resources.discrete(device.id()).resource()));
executor.execute(() -> {
boolean success = adminService.register(Resources.discrete(device.id()).resource());
if (!success) {
log.warn("Failed to register Device: {}", device.id());
}
});
}
private void unregisterDeviceResource(Device device) {
@ -170,33 +175,45 @@ final class ResourceDeviceListener implements DeviceListener {
// for VLAN IDs
Set<VlanId> vlans = queryVlanIds(device.id(), port.number());
if (!vlans.isEmpty()) {
adminService.register(vlans.stream()
boolean success = adminService.register(vlans.stream()
.map(portPath::child)
.collect(Collectors.toList()));
if (!success) {
log.warn("Failed to register VLAN IDs for {}", portPath.id());
}
}
// for MPLS labels
Set<MplsLabel> mplsLabels = queryMplsLabels(device.id(), port.number());
if (!mplsLabels.isEmpty()) {
adminService.register(mplsLabels.stream()
boolean success = adminService.register(mplsLabels.stream()
.map(portPath::child)
.collect(Collectors.toList()));
if (!success) {
log.warn("Failed to register MPLS Labels for {}", portPath.id());
}
}
// for Lambdas
Set<OchSignal> lambdas = queryLambdas(device.id(), port.number());
if (!lambdas.isEmpty()) {
adminService.register(lambdas.stream()
boolean success = adminService.register(lambdas.stream()
.map(portPath::child)
.collect(Collectors.toList()));
if (!success) {
log.warn("Failed to register lambdas for {}", portPath.id());
}
}
// for Tributary slots
Set<TributarySlot> tSlots = queryTributarySlots(device.id(), port.number());
if (!tSlots.isEmpty()) {
adminService.register(tSlots.stream()
boolean success = adminService.register(tSlots.stream()
.map(portPath::child)
.collect(Collectors.toList()));
if (!success) {
log.warn("Failed to register tributary slots for {}", portPath.id());
}
}
});
}