|
77 | 77 | import org.apache.commons.collections4.CollectionUtils; |
78 | 78 | import org.apache.commons.lang3.ObjectUtils; |
79 | 79 | import org.apache.commons.lang3.StringUtils; |
80 | | -import org.jetbrains.annotations.NotNull; |
81 | 80 | import org.springframework.beans.factory.annotation.Autowired; |
82 | 81 | import org.springframework.beans.factory.annotation.Qualifier; |
83 | 82 |
|
@@ -540,8 +539,8 @@ public boolean configure(final String name, final Map<String, Object> params) th |
540 | 539 |
|
541 | 540 | final Map<String, String> configs = _configDao.getConfiguration("AgentManager", params); |
542 | 541 |
|
543 | | - int _routerRamSize = NumbersUtil.parseInt(configs.get("router.ram.size"), DEFAULT_ROUTER_VM_RAMSIZE); |
544 | | - int _routerCpuMHz = NumbersUtil.parseInt(configs.get("router.cpu.mhz"), DEFAULT_ROUTER_CPU_MHZ); |
| 542 | + int routerRamSize = NumbersUtil.parseInt(configs.get("router.ram.size"), DEFAULT_ROUTER_VM_RAMSIZE); |
| 543 | + int routerCpuMHz = NumbersUtil.parseInt(configs.get("router.cpu.mhz"), DEFAULT_ROUTER_CPU_MHZ); |
545 | 544 |
|
546 | 545 | _routerExtraPublicNics = NumbersUtil.parseInt(_configDao.getValue(Config.RouterExtraPublicNics.key()), 2); |
547 | 546 |
|
@@ -578,12 +577,12 @@ public boolean configure(final String name, final Map<String, Object> params) th |
578 | 577 |
|
579 | 578 | _dnsBasicZoneUpdates = String.valueOf(_configDao.getValue(Config.DnsBasicZoneUpdates.key())); |
580 | 579 |
|
581 | | - logger.info("Router configurations: " + "ramsize=" + _routerRamSize); |
| 580 | + logger.info("Router configurations: " + "ramsize=" + routerRamSize); |
582 | 581 |
|
583 | 582 | _agentMgr.registerForHostEvents(new SshKeysDistriMonitor(_agentMgr, _hostDao, _configDao), true, false, false); |
584 | 583 |
|
585 | 584 | final List<ServiceOfferingVO> offerings = _serviceOfferingDao.createSystemServiceOfferings("System Offering For Software Router", |
586 | | - ServiceOffering.routerDefaultOffUniqueName, 1, _routerRamSize, _routerCpuMHz, null, |
| 585 | + ServiceOffering.routerDefaultOffUniqueName, 1, routerRamSize, routerCpuMHz, null, |
587 | 586 | null, true, null, ProvisioningType.THIN, true, null, true, VirtualMachine.Type.DomainRouter, true); |
588 | 587 | // this can sometimes happen, if DB is manually or programmatically manipulated |
589 | 588 | if (offerings == null || offerings.size() < 2) { |
@@ -1312,7 +1311,7 @@ private void updateRouterHealthCheckResult(final long routerId, String checkName |
1312 | 1311 | private RouterHealthCheckResultVO parseHealthCheckVOFromJson(final long routerId, |
1313 | 1312 | final String checkName, final String checkType, final Map<String, String> checkData, |
1314 | 1313 | final Map<String, Map<String, RouterHealthCheckResultVO>> checksInDb) { |
1315 | | - RouterHealthStatus success = RouterHealthStatus.valueOf(checkData.get("success")); |
| 1314 | + RouterHealthStatus success = getRouterHealthStatus(checkData.get("success")); |
1316 | 1315 | Date lastUpdate = new Date(Long.parseLong(checkData.get("lastUpdate"))); |
1317 | 1316 | double lastRunDuration = Double.parseDouble(checkData.get("lastRunDuration")); |
1318 | 1317 | String message = checkData.get("message"); |
@@ -1340,6 +1339,16 @@ private RouterHealthCheckResultVO parseHealthCheckVOFromJson(final long routerId |
1340 | 1339 | return hcVo; |
1341 | 1340 | } |
1342 | 1341 |
|
| 1342 | + private static RouterHealthStatus getRouterHealthStatus(String status) { |
| 1343 | + RouterHealthStatus success; |
| 1344 | + try { |
| 1345 | + success = RouterHealthStatus.valueOf(status.trim()); |
| 1346 | + } catch (IllegalArgumentException | NullPointerException e) { |
| 1347 | + success = RouterHealthStatus.UNKNOWN; |
| 1348 | + } |
| 1349 | + return success; |
| 1350 | + } |
| 1351 | + |
1343 | 1352 | /** |
1344 | 1353 | * |
1345 | 1354 | * @param checksJson JSON expected is |
@@ -1851,7 +1860,6 @@ protected void getRouterAlerts() { |
1851 | 1860 | } |
1852 | 1861 | } |
1853 | 1862 |
|
1854 | | - @NotNull |
1855 | 1863 | private static GetRouterAlertsCommand getGetRouterAlertsCommand(OpRouterMonitorServiceVO opRouterMonitorServiceVO, String controlIP) { |
1856 | 1864 | GetRouterAlertsCommand command; |
1857 | 1865 | if (opRouterMonitorServiceVO == null) { |
@@ -2277,7 +2285,7 @@ public boolean finalizeCommandsOnStart(final Commands cmds, final VirtualMachine |
2277 | 2285 |
|
2278 | 2286 | // restart network if restartNetwork = false is not specified in profile |
2279 | 2287 | // parameters |
2280 | | - boolean reprogramGuestNtwks = ! Boolean.FALSE.equals(profile.getParameter(Param.ReProgramGuestNetworks)); |
| 2288 | + boolean reprogramGuestNtwks = !Boolean.FALSE.equals(profile.getParameter(Param.ReProgramGuestNetworks)); |
2281 | 2289 |
|
2282 | 2290 | final Provider provider = getVrProvider(router); |
2283 | 2291 |
|
@@ -2624,7 +2632,6 @@ private void createDefaultEgressFirewallRule(final List<FirewallRule> rules, fin |
2624 | 2632 | } |
2625 | 2633 | } |
2626 | 2634 |
|
2627 | | - @NotNull |
2628 | 2635 | private static FirewallRule getFirewallRule(String cidr, String allIp4Cidrs, long networkId, NetworkVO network, Purpose firewall) { |
2629 | 2636 | final List<String> sourceCidr = new ArrayList<>(); |
2630 | 2637 | final List<String> destCidr = new ArrayList<>(); |
|
0 commit comments