public class LBaaSPoolHandler extends AbstractHandler
implements INeutronLoadBalancerPoolAware, ConfigInterface {
- private static final Logger logger = LoggerFactory.getLogger(LBaaSPoolHandler.class);
+ private static final Logger LOG = LoggerFactory.getLogger(LBaaSPoolHandler.class);
// The implementation for each of these services is resolved by the OSGi Service Manager
private volatile INeutronLoadBalancerCRUD neutronLBCache;
@Override
public void neutronLoadBalancerPoolCreated(NeutronLoadBalancerPool neutronLBPool) {
- logger.debug("Neutron LB Pool Creation : {}", neutronLBPool.toString());
+ LOG.debug("Neutron LB Pool Creation : {}", neutronLBPool.toString());
enqueueEvent(new NorthboundEvent(neutronLBPool, Action.ADD));
}
List<LoadBalancerConfiguration> lbConfigList = extractLBConfiguration(neutronLBPool);
final List<Node> nodes = nodeCacheManager.getBridgeNodes();
if (lbConfigList == null) {
- logger.debug("Neutron LB configuration invalid for pool {} ", neutronLBPool.getLoadBalancerPoolID());
+ LOG.debug("Neutron LB configuration invalid for pool {} ", neutronLBPool.getLoadBalancerPoolID());
} else if (lbConfigList.size() == 0) {
- logger.debug("No Neutron LB VIP not created yet for pool {} ", neutronLBPool.getLoadBalancerPoolID());
+ LOG.debug("No Neutron LB VIP not created yet for pool {} ", neutronLBPool.getLoadBalancerPoolID());
} else if (nodes.isEmpty()) {
- logger.debug("Noop with LB pool {} creation because no nodes available.", neutronLBPool.getLoadBalancerPoolID());
+ LOG.debug("Noop with LB pool {} creation because no nodes available.", neutronLBPool.getLoadBalancerPoolID());
} else {
for (LoadBalancerConfiguration lbConfig: lbConfigList) {
if (!lbConfig.isValid()) {
- logger.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
- continue;
+ LOG.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
} else {
for (Node node : nodes) {
loadBalancerProvider.programLoadBalancerRules(node, lbConfig, Action.ADD);
@Override
public void neutronLoadBalancerPoolUpdated(NeutronLoadBalancerPool neutronLBPool) {
- logger.debug("Neutron LB Pool Update : {}", neutronLBPool.toString());
+ LOG.debug("Neutron LB Pool Update : {}", neutronLBPool.toString());
enqueueEvent(new NorthboundEvent(neutronLBPool, Action.UPDATE));
}
@Override
public void neutronLoadBalancerPoolDeleted(NeutronLoadBalancerPool neutronLBPool) {
- logger.debug("Neutron LB Pool Deletion : {}", neutronLBPool.toString());
+ LOG.debug("Neutron LB Pool Deletion : {}", neutronLBPool.toString());
enqueueEvent(new NorthboundEvent(neutronLBPool, Action.DELETE));
}
List<LoadBalancerConfiguration> lbConfigList = extractLBConfiguration(neutronLBPool);
final List<Node> nodes = nodeCacheManager.getBridgeNodes();
if (lbConfigList == null) {
- logger.debug("Neutron LB configuration invalid for pool {} ", neutronLBPool.getLoadBalancerPoolID());
+ LOG.debug("Neutron LB configuration invalid for pool {} ", neutronLBPool.getLoadBalancerPoolID());
} else if (lbConfigList.size() == 0) {
- logger.debug("No Neutron LB VIP not created yet for pool {} ", neutronLBPool.getLoadBalancerPoolID());
+ LOG.debug("No Neutron LB VIP not created yet for pool {} ", neutronLBPool.getLoadBalancerPoolID());
} else if (nodes.isEmpty()) {
- logger.debug("Noop with LB pool {} deletion because no nodes available.", neutronLBPool.getLoadBalancerPoolID());
+ LOG.debug("Noop with LB pool {} deletion because no nodes available.", neutronLBPool.getLoadBalancerPoolID());
} else {
for (LoadBalancerConfiguration lbConfig: lbConfigList) {
if (!lbConfig.isValid()) {
- logger.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
- continue;
+ LOG.debug("Neutron LB pool configuration invalid for {} ", lbConfig.getName());
} else {
for (Node node : nodes) {
loadBalancerProvider.programLoadBalancerRules(node, lbConfig, Action.DELETE);
*/
@Override
public void processEvent(AbstractEvent abstractEvent) {
- logger.debug("Processing Loadbalancer Pool event " + abstractEvent);
+ LOG.debug("Processing Loadbalancer Pool event {}", abstractEvent);
if (!(abstractEvent instanceof NorthboundEvent)) {
- logger.error("Unable to process abstract event " + abstractEvent);
+ LOG.error("Unable to process abstract event {}", abstractEvent);
return;
}
NorthboundEvent ev = (NorthboundEvent) abstractEvent;
* Typical upgrade involves changing algorithm. Right now
* we do not support this flexibility. TODO
*/
- logger.warn("Load balancer pool update is not supported");
+ LOG.warn("Load balancer pool update is not supported");
break;
default:
- logger.warn("Unable to process event action " + ev.getAction());
+ LOG.warn("Unable to process event action {}", ev.getAction());
break;
}
}
List<NeutronLoadBalancerPoolMember> poolMembers = neutronLBPool.getLoadBalancerPoolMembers();
if (poolMembers.size() == 0) {
- logger.debug("Neutron LB pool is empty: {}", neutronLBPool);
+ LOG.debug("Neutron LB pool is empty: {}", neutronLBPool);
return null;
}
memberIP = neutronLBPoolMember.getPoolMemberAddress();
memberPort = neutronLBPoolMember.getPoolMemberProtoPort();
if (memberSubnetID == null || memberID == null || memberIP == null || memberPort == null) {
- logger.debug("Neutron LB pool member details incomplete: {}", neutronLBPoolMember);
+ LOG.debug("Neutron LB pool member details incomplete: {}", neutronLBPoolMember);
continue;
}
memberMAC = NeutronCacheUtils.getMacAddress(neutronPortCache, memberSubnetID, memberIP);