Handle PORT_REMOVED event when a VM removes

Also fixed OpenStack port event log

Change-Id: I0ad4a014dcb3a1fdf7ada7eb93ec80f23f42b087
This commit is contained in:
Hyunsun Moon 2017-02-24 11:12:53 +09:00
parent f8d71b0538
commit b7a9cd2d6d
2 changed files with 9 additions and 2 deletions

View File

@ -189,7 +189,7 @@ public class OpenstackNetworkManager
checkArgument(!Strings.isNullOrEmpty(osPort.getNetworkId()), ERR_NULL_PORT_NET_ID);
osNetworkStore.updatePort(osPort);
log.info(String.format(MSG_SUBNET, osPort.getId(), MSG_UPDATED));
log.info(String.format(MSG_PORT, osPort.getId(), MSG_UPDATED));
}
@Override
@ -202,7 +202,7 @@ public class OpenstackNetworkManager
}
Port osPort = osNetworkStore.removePort(portId);
if (osPort != null) {
log.info(String.format(MSG_SUBNET, osPort.getId(), MSG_REMOVED));
log.info(String.format(MSG_PORT, osPort.getId(), MSG_REMOVED));
}
}
}

View File

@ -239,6 +239,13 @@ public final class OpenstackSwitchingHostProvider extends AbstractProvider imple
processPortAdded(event.port());
});
break;
case PORT_REMOVED:
deviceEventExecutor.execute(() -> {
log.debug("Instance port {} is removed from {}",
event.port().annotations().value(PORT_NAME),
event.subject().id());
processPortRemoved(event.port());
});
default:
break;
}