this.cfg = neutronNorthboundApiConfig;
this.jsonRestconfService = jsonRestconfService;
- boolean preRegister = cfg.isPreRegisterPortStatusWebsocket() == null || cfg.isPreRegisterPortStatusWebsocket();
-
- if (preRegister) {
+ if (!Boolean.FALSE.equals(cfg.getPreRegisterPortStatusWebsocket())) {
subscribeWebsocket();
} else {
LOG.info("PortStatusUpdateInitializer: Skipping pre-register of websockets");
}
}
- protected <M extends AdminAttributes, S1 extends INeutronAdminAttributes<S1>>
- void fromMdAdminAttributes(M attr, S1 answer) {
- if (attr.isAdminStateUp() != null) {
- answer.setAdminStateUp(attr.isAdminStateUp());
+ protected <M extends AdminAttributes, S1 extends INeutronAdminAttributes<S1>> void fromMdAdminAttributes(M attr,
+ S1 answer) {
+ if (attr.getAdminStateUp() != null) {
+ answer.setAdminStateUp(attr.getAdminStateUp());
}
if (attr.getStatus() != null) {
answer.setStatus(attr.getStatus());
final NeutronBgpvpn result = new NeutronBgpvpn();
fromMdBaseAttributes(bgpvpn, result);
fromMdAdminAttributes(bgpvpn, result);
- result.setAutoAggregate(bgpvpn.isAutoAggregate());
+ result.setAutoAggregate(bgpvpn.getAutoAggregate());
if (bgpvpn.getVni() != null) {
result.setVni(bgpvpn.getVni().toJava());
}
protected NeutronFirewall fromMd(Firewall firewall) {
final NeutronFirewall answer = new NeutronFirewall();
fromMdBaseAttributes(firewall, answer);
- answer.setFirewallAdminStateIsUp(firewall.isAdminStateUp());
- if (firewall.isShared() != null) {
- answer.setFirewallIsShared(firewall.isShared());
+ answer.setFirewallAdminStateIsUp(firewall.getAdminStateUp());
+ if (firewall.getShared() != null) {
+ answer.setFirewallIsShared(firewall.getShared());
}
if (firewall.getFirewallPolicyId() != null) {
answer.setFirewallPolicyID(firewall.getFirewallPolicyId().getValue());
protected NeutronFirewallPolicy fromMd(FirewallPolicy policy) {
final NeutronFirewallPolicy answer = new NeutronFirewallPolicy();
fromMdBaseAttributes(policy, answer);
- if (policy.isShared() != null) {
- answer.setFirewallPolicyIsShared(policy.isShared());
+ if (policy.getShared() != null) {
+ answer.setFirewallPolicyIsShared(policy.getShared());
}
- if (policy.isAudited() != null) {
- answer.setFirewallPolicyIsAudited(policy.isAudited());
+ if (policy.getAudited() != null) {
+ answer.setFirewallPolicyIsAudited(policy.getAudited());
}
return answer;
}
private static final ImmutableBiMap<Class<? extends IpVersionBase>,
Integer> IP_VERSION_MAP = new ImmutableBiMap.Builder<Class<? extends IpVersionBase>, Integer>()
- .put(IpVersionV4.class, Integer.valueOf(4)).put(IpVersionV6.class, Integer.valueOf(6)).build();
+ .put(IpVersionV4.class, 4).put(IpVersionV6.class, 6).build();
@Inject
public NeutronFirewallRuleInterface(DataBroker db) {
protected NeutronFirewallRule fromMd(FirewallRule rule) {
final NeutronFirewallRule answer = new NeutronFirewallRule();
fromMdBaseAttributes(rule, answer);
- if (rule.isShared() != null) {
- answer.setFirewallRuleIsShared(rule.isShared());
+ if (rule.getShared() != null) {
+ answer.setFirewallRuleIsShared(rule.getShared());
}
- if (rule.isEnabled() != null) {
- answer.setFirewallRuleIsEnabled(rule.isEnabled());
+ if (rule.getEnabled() != null) {
+ answer.setFirewallRuleIsEnabled(rule.getEnabled());
}
if (rule.getFirewallPolicyId() != null) {
answer.setFirewallRulePolicyID(rule.getFirewallPolicyId().getValue());
answer.setFirewallRuleDstPortRangeMax(rule.getDestinationPortRangeMax().toJava());
}
if (rule.getPosition() != null) {
- answer.setFirewallRulePosition(Integer.valueOf(rule.getPosition().intValue()));
+ answer.setFirewallRulePosition(rule.getPosition().intValue());
}
if (rule.getAction() != null) {
answer.setFirewallRuleAction(ACTION_MAP.get(rule.getAction()));
protected NeutronLoadBalancerHealthMonitor fromMd(Healthmonitor healthMonitor) {
final NeutronLoadBalancerHealthMonitor answer = new NeutronLoadBalancerHealthMonitor();
fromMdIds(healthMonitor, answer);
- if (healthMonitor.isAdminStateUp() != null) {
- answer.setLoadBalancerHealthMonitorAdminStateIsUp(healthMonitor.isAdminStateUp());
+ if (healthMonitor.getAdminStateUp() != null) {
+ answer.setLoadBalancerHealthMonitorAdminStateIsUp(healthMonitor.getAdminStateUp());
}
if (healthMonitor.getDelay() != null) {
answer.setLoadBalancerHealthMonitorDelay(healthMonitor.getDelay().intValue());
protected NeutronLoadBalancerListener fromMd(Listener listener) {
final NeutronLoadBalancerListener answer = new NeutronLoadBalancerListener();
fromMdBaseAttributes(listener, answer);
- if (listener.isAdminStateUp() != null) {
- answer.setLoadBalancerListenerAdminStateIsUp(listener.isAdminStateUp());
+ if (listener.getAdminStateUp() != null) {
+ answer.setLoadBalancerListenerAdminStateIsUp(listener.getAdminStateUp());
}
if (listener.getConnectionLimit() != null) {
answer.setNeutronLoadBalancerListenerConnectionLimit(listener.getConnectionLimit());
protected NeutronLoadBalancerPool fromMd(Pool pool) {
final NeutronLoadBalancerPool answer = new NeutronLoadBalancerPool();
fromMdBaseAttributes(pool, answer);
- if (pool.isAdminStateUp() != null) {
- answer.setLoadBalancerPoolAdminStateIsUp(pool.isAdminStateUp());
+ if (pool.getAdminStateUp() != null) {
+ answer.setLoadBalancerPoolAdminStateIsUp(pool.getAdminStateUp());
}
if (pool.getHealthmonitorId() != null) {
answer.setLoadBalancerPoolHealthMonitorID(pool.getHealthmonitorId().getValue());
protected NeutronLoadBalancerPoolMember fromMemberMd(Member member) {
final NeutronLoadBalancerPoolMember answer = new NeutronLoadBalancerPoolMember();
fromMdIds(member, answer);
- if (member.isAdminStateUp() != null) {
- answer.setPoolMemberAdminStateIsUp(member.isAdminStateUp());
+ if (member.getAdminStateUp() != null) {
+ answer.setPoolMemberAdminStateIsUp(member.getAdminStateUp());
}
if (member.getAddress() != null) {
answer.setPoolMemberAddress(member.getAddress().stringValue());
protected NeutronMeteringLabel fromMd(MeteringLabel label) {
final NeutronMeteringLabel answer = new NeutronMeteringLabel();
fromMdBaseAttributes(label, answer);
- if (label.isShared() != null) {
- answer.setMeteringLabelShared(label.isShared());
+ if (label.getShared() != null) {
+ answer.setMeteringLabelShared(label.getShared());
}
return answer;
}
if (rule.getRemoteIpPrefix() != null) {
answer.setMeteringLabelRuleRemoteIpPrefix(rule.getRemoteIpPrefix().stringValue());
}
- answer.setMeteringLabelRuleExcluded(rule.isExcluded());
+ answer.setMeteringLabelRuleExcluded(rule.getExcluded());
return answer;
}
}
result.initDefaults();
fromMdBaseAttributes(network, result);
fromMdAdminAttributes(network, result);
- result.setShared(network.isShared());
- result.setVlanTransparent(network.isVlanTransparent());
+ result.setShared(network.getShared());
+ result.setVlanTransparent(network.getVlanTransparent());
final NetworkL3Extension l3Extension = network.augmentation(NetworkL3Extension.class);
- result.setRouterExternal(l3Extension.isExternal());
+ result.setRouterExternal(l3Extension.getExternal());
final NetworkProviderExtension providerExtension = network.augmentation(NetworkProviderExtension.class);
result.setProviderPhysicalNetwork(providerExtension.getPhysicalNetwork());
// TODO: consolidate this map with NeutronSubnetInterface.IPV_MAP
private static final ImmutableBiMap<Class<? extends IpVersionBase>,
Integer> IPV_MAP = new ImmutableBiMap.Builder<Class<? extends IpVersionBase>, Integer>()
- .put(IpVersionV4.class, Integer.valueOf(4)).put(IpVersionV6.class, Integer.valueOf(6)).build();
+ .put(IpVersionV4.class, 4).put(IpVersionV6.class, 6).build();
@Inject
public NeutronPortInterface(DataBroker db) {
result.setBindingvnicType(binding.getVnicType());
}
- private void portSecurityExtension(Port port, NeutronPort result) {
+ private static void portSecurityExtension(Port port, NeutronPort result) {
final PortSecurityExtension portSecurity = port.augmentation(PortSecurityExtension.class);
- if (portSecurity != null && portSecurity.isPortSecurityEnabled() != null) {
- result.setPortSecurityEnabled(portSecurity.isPortSecurityEnabled());
+ if (portSecurity != null && portSecurity.getPortSecurityEnabled() != null) {
+ result.setPortSecurityEnabled(portSecurity.getPortSecurityEnabled());
}
}
- private void qosExtension(Port port, NeutronPort result) {
+ private static void qosExtension(Port port, NeutronPort result) {
final QosPortExtension qos = port.augmentation(QosPortExtension.class);
if (qos != null && qos.getQosPolicyId() != null) {
result.setQosPolicyId(qos.getQosPolicyId().getValue());
protected NeutronQosPolicy fromMd(QosPolicy qosPolicy) {
final NeutronQosPolicy result = new NeutronQosPolicy();
fromMdBaseAttributes(qosPolicy, result);
- if (qosPolicy.isShared() != null) {
- result.setPolicyIsShared(qosPolicy.isShared());
+ if (qosPolicy.getShared() != null) {
+ result.setPolicyIsShared(qosPolicy.getShared());
}
if (qosPolicy.getBandwidthLimitRules() != null) {
final List<NeutronQosBandwidthLimitRule> bandwidthLimitRules = new ArrayList<>();
final NeutronRouter result = new NeutronRouter();
fromMdBaseAttributes(router, result);
fromMdAdminAttributes(router, result);
- result.setDistributed(router.isDistributed());
+ result.setDistributed(router.getDistributed());
if (router.getGatewayPortId() != null) {
result.setGatewayPortId(String.valueOf(router.getGatewayPortId().getValue()));
}
if (router.getExternalGatewayInfo() != null) {
final NeutronRouterNetworkReference extGwInfo = new NeutronRouterNetworkReference();
extGwInfo.setNetworkID(String.valueOf(router.getExternalGatewayInfo().getExternalNetworkId().getValue()));
- extGwInfo.setEnableSNAT(router.getExternalGatewayInfo().isEnableSnat());
+ extGwInfo.setEnableSNAT(router.getExternalGatewayInfo().getEnableSnat());
if (router.getExternalGatewayInfo().getExternalFixedIps() != null) {
final List<NeutronIps> fixedIps = new ArrayList<>();
for (final ExternalFixedIps mdFixedIp
private static final ImmutableBiMap<Class<? extends IpVersionBase>,
Integer> IPV_MAP = new ImmutableBiMap.Builder<Class<? extends IpVersionBase>, Integer>()
- .put(IpVersionV4.class, Integer.valueOf(IPV4_VERSION))
- .put(IpVersionV6.class, Integer.valueOf(IPV6_VERSION)).build();
+ .put(IpVersionV4.class, IPV4_VERSION)
+ .put(IpVersionV6.class, IPV6_VERSION).build();
private static final ImmutableBiMap<Class<? extends Dhcpv6Base>,
String> DHCPV6_MAP = new ImmutableBiMap.Builder<Class<? extends Dhcpv6Base>, String>()
if (subnet.getIpv6AddressMode() != null) {
result.setIpV6AddressMode(DHCPV6_MAP.get(subnet.getIpv6AddressMode()));
}
- result.setEnableDHCP(subnet.isEnableDhcp());
+ result.setEnableDHCP(subnet.getEnableDhcp());
if (subnet.getAllocationPools() != null) {
final List<NeutronSubnetIpAllocationPool> allocationPools = new ArrayList<>();
for (final AllocationPools allocationPool : subnet.getAllocationPools().values()) {