/*For every port check whether security grouplist contains the current
* security group.*/
try {
- for (NeutronPort neutronPort:neutronL3Adapter.getPortCleanupCache()) {
+ for (String neutronPortUuid:neutronL3Adapter.getPortCleanupCache().keySet()) {
+ NeutronPort neutronPort = neutronL3Adapter.getPortCleanupCache().get(neutronPortUuid);
if (!neutronPort.getDeviceOwner().contains("compute")) {
LOG.debug("getVMListForSecurityGroup : the port {} is not "
+ "compute port belongs to {}", neutronPort.getID(), neutronPort.getDeviceOwner());
return;
}
NeutronNetwork neutronNetwork = neutronNetworkCache.getNetwork(port.getNetworkUUID());
+ if (null == neutronNetwork) {
+ neutronNetwork = neutronL3Adapter.getNetworkFromCleanupCache(port.getNetworkUUID());
+ }
if (neutronNetwork == null) {
return;
}
return;
}
NeutronNetwork neutronNetwork = neutronNetworkCache.getNetwork(port.getNetworkUUID());
+ if (null == neutronNetwork) {
+ neutronNetwork = neutronL3Adapter.getNetworkFromCleanupCache(port.getNetworkUUID());
+ }
if (neutronNetwork == null) {
return;
}
if (dpid == 0L) {
return;
}
- if ("IPv4".equals(securityRule.getSecurityRuleEthertype())
- && "ingress".equals(securityRule.getSecurityRuleDirection())) {
-
- ingressAclProvider.programPortSecurityRule(dpid, segmentationId, attachedMac, localPort,
- securityRule, vmIp, write);
- } else if (securityRule.getSecurityRuleEthertype().equals("IPv4")
- && securityRule.getSecurityRuleDirection().equals("egress")) {
- egressAclProvider.programPortSecurityRule(dpid, segmentationId, attachedMac, localPort,
- securityRule, vmIp, write);
+ if (NeutronSecurityRule.ETHERTYPE_IPV4.equals(securityRule.getSecurityRuleEthertype())) {
+ if (NeutronSecurityRule.DIRECTION_INGRESS.equals(securityRule.getSecurityRuleDirection())) {
+ ingressAclProvider.programPortSecurityRule(dpid, segmentationId, attachedMac, localPort,
+ securityRule, vmIp, write);
+ } else if (NeutronSecurityRule.DIRECTION_EGRESS.equals(securityRule.getSecurityRuleDirection())) {
+ egressAclProvider.programPortSecurityRule(dpid, segmentationId, attachedMac, localPort,
+ securityRule, vmIp, write);
+ }
}
}
}