diff options
author | Denes Nemeth <denes.nemeth@nokia.com> | 2018-03-27 15:24:18 +0200 |
---|---|---|
committer | Denes Nemeth <denes.nemeth@nokia.com> | 2018-03-27 15:24:18 +0200 |
commit | 762cc41f264456d12eb2dd277484cea37c2979ae (patch) | |
tree | 986bcc300995c04aa36f4b25ea195c33728d399c /nokiav2/driver/src/main/java/org/onap/vfc/nfvo | |
parent | c088d641a7805e65694884d9f7ff89c88ac7a886 (diff) |
Fix sonar issues
Change-Id: Ia0faaf3b84267ed88dc452a7885d2f33c4d6411b
Issue-ID: VFC-728
Signed-off-by: Denes Nemeth <denes.nemeth@nokia.com>
Diffstat (limited to 'nokiav2/driver/src/main/java/org/onap/vfc/nfvo')
4 files changed, 21 insertions, 31 deletions
diff --git a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/AaiSecurityProvider.java b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/AaiSecurityProvider.java index 688a82fd..1cd3346d 100644 --- a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/AaiSecurityProvider.java +++ b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/AaiSecurityProvider.java @@ -25,24 +25,24 @@ import org.springframework.stereotype.Component; @Component public class AaiSecurityProvider extends GenericSecurityProvider { @Value("${trustedCertificatesForAai}") - private String trustedCertificates; + private String trustedCertificatesForAai; @Value("${skipCertificateVerificationForAai}") - private boolean skipCertificateVerification; + private boolean skipCertificateVerificationForAai; @Value("${skipHostnameVerificationForAai}") - private boolean skipHostnameVerification; + private boolean skipHostnameVerificationForAai; @Override protected boolean skipHostnameVerification() { - return skipHostnameVerification; + return skipHostnameVerificationForAai; } @Override protected boolean skipCertificateVerification() { - return skipCertificateVerification; + return skipCertificateVerificationForAai; } @Override protected String trustedCertificates() { - return trustedCertificates; + return trustedCertificatesForAai; } } diff --git a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/notification/LInterfaceManager.java b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/notification/LInterfaceManager.java index ab216bd7..37a6993a 100644 --- a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/notification/LInterfaceManager.java +++ b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/onap/direct/notification/LInterfaceManager.java @@ -95,22 +95,18 @@ class LInterfaceManager extends AbstractManager { logicalInterface.setInterfaceRole(affectedCp.getCpdId()); logicalInterface.setMacaddr(affectedCp.getMacAddress()); logicalInterface.setProvStatus("active"); + logicalInterface.setL3InterfaceIpv6AddressList(new ArrayList<>()); + logicalInterface.setL3InterfaceIpv4AddressList(new ArrayList<>()); if (affectedCp.getIpAddress() != null) { if (affectedCp.getIpAddress().contains(":")) { L3InterfaceIpv6AddressList ipv6Address = new L3InterfaceIpv6AddressList(); ipv6Address.setL3InterfaceIpv6Address(affectedCp.getIpAddress()); ipv6Address.setNeutronNetworkId(affectedCp.getNetworkProviderId()); - if (logicalInterface.getL3InterfaceIpv6AddressList() == null) { - logicalInterface.setL3InterfaceIpv6AddressList(new ArrayList<>()); - } logicalInterface.getL3InterfaceIpv6AddressList().add(ipv6Address); } else { L3InterfaceIpv4AddressList ipv4Address = new L3InterfaceIpv4AddressList(); ipv4Address.setL3InterfaceIpv4Address(affectedCp.getIpAddress()); ipv4Address.setNeutronNetworkId(affectedCp.getNetworkProviderId()); - if (logicalInterface.getL3InterfaceIpv4AddressList() == null) { - logicalInterface.setL3InterfaceIpv4AddressList(new ArrayList<>()); - } logicalInterface.getL3InterfaceIpv4AddressList().add(ipv4Address); } } diff --git a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/restapi/LcmApi.java b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/restapi/LcmApi.java index c3405201..f7c9ed10 100644 --- a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/restapi/LcmApi.java +++ b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/restapi/LcmApi.java @@ -83,7 +83,7 @@ public class LcmApi { @ResponseBody public JobInfo terminateVnf(@RequestBody VnfTerminateRequest request, @PathVariable("vnfmId") String vnfmId, @PathVariable("vnfId") String vnfInstanceId, HttpServletResponse httpResponse) { logger.info("REST: Terminate VNF"); - return lifecycleManager.terminateVnf(vnfmId, vnfInstanceId, request, httpResponse); + return lifecycleManager.terminateAndDelete(vnfmId, vnfInstanceId, request, httpResponse); } /** diff --git a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/vnfm/LifecycleManager.java b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/vnfm/LifecycleManager.java index 9b69fcfb..94ab240a 100644 --- a/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/vnfm/LifecycleManager.java +++ b/nokiav2/driver/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nokia/vnfm/LifecycleManager.java @@ -398,7 +398,7 @@ public class LifecycleManager { * @param httpResponse the HTTP response * @return the job for polling the progress of the termination */ - public JobInfo terminateVnf(String vnfmId, String vnfId, VnfTerminateRequest request, HttpServletResponse httpResponse) { + public JobInfo terminateAndDelete(String vnfmId, String vnfId, VnfTerminateRequest request, HttpServletResponse httpResponse) { logOperationInput(vnfId, "termination", request); return scheduleExecution(vnfId, httpResponse, "terminate", jobInfo -> { TerminateVnfRequest cbamRequest = new TerminateVnfRequest(); @@ -415,29 +415,34 @@ public class LifecycleManager { cbamRequest.setAdditionalParams(new Gson().toJsonTree(jobInfo).getAsJsonObject()); com.nokia.cbam.lcm.v32.model.VnfInfo vnf = cbamRestApiProvider.getCbamLcmApi(vnfmId).vnfsVnfInstanceIdGet(vnfId, NOKIA_LCM_API_VERSION).blockingFirst(); if (vnf.getInstantiationState() == INSTANTIATED) { - terminateVnf(vnfmId, vnfId, jobInfo, cbamRequest, vnf); + terminateAndDelete(vnfmId, vnfId, jobInfo, cbamRequest, vnf); } else { - cbamRestApiProvider.getCbamLcmApi(vnfmId).vnfsVnfInstanceIdDelete(vnfId, NOKIA_LCM_API_VERSION).blockingFirst(); + logger.debug("The VNF {} with identifier is not instantiated no termination required", vnf.getId()); + deleteVnf(vnfmId, vnfId); } }); } - private void terminateVnf(String vnfmId, String vnfId, JobInfo jobInfo, TerminateVnfRequest cbamRequest, com.nokia.cbam.lcm.v32.model.VnfInfo vnf) { + private void terminateAndDelete(String vnfmId, String vnfId, JobInfo jobInfo, TerminateVnfRequest cbamRequest, com.nokia.cbam.lcm.v32.model.VnfInfo vnf) { String vimId = getVimIdFromInstantiationRequest(vnfmId, vnf); grantManager.requestGrantForTerminate(vnfmId, vnfId, vimId, getVnfdIdFromModifyableAttributes(vnf), vnf, jobInfo.getJobId()); OperationExecution terminationOperation = cbamRestApiProvider.getCbamLcmApi(vnfmId).vnfsVnfInstanceIdTerminatePost(vnfId, cbamRequest, NOKIA_LCM_API_VERSION).blockingFirst(); OperationExecution finishedOperation = waitForOperationToFinish(vnfmId, vnfId, terminationOperation.getId()); if (finishedOperation.getStatus() == FINISHED) { notificationManager.waitForTerminationToBeProcessed(finishedOperation.getId()); - logger.info("Deleting VNF with {}", vnfId); - cbamRestApiProvider.getCbamLcmApi(vnfmId).vnfsVnfInstanceIdDelete(vnfId, NOKIA_LCM_API_VERSION).blockingFirst(); - logger.info("VNF with {} has been deleted", vnfId); + deleteVnf(vnfmId, vnfId); } else { logger.error("Unable to terminate VNF the operation did not finish with success"); } } + private void deleteVnf(String vnfmId, String vnfId) { + logger.info("Deleting VNF with {} identifier", vnfId); + cbamRestApiProvider.getCbamLcmApi(vnfmId).vnfsVnfInstanceIdDelete(vnfId, NOKIA_LCM_API_VERSION).blockingFirst(); + logger.info("The VNF with {} identifier has been deleted", vnfId); + } + private String getVimIdFromInstantiationRequest(String vnfmId, com.nokia.cbam.lcm.v32.model.VnfInfo vnf) { OperationExecution lastInstantiation = findLastInstantiation(vnf.getOperationExecutions()); Object operationParameters = cbamRestApiProvider.getCbamOperationExecutionApi(vnfmId).operationExecutionsOperationExecutionIdOperationParamsGet(lastInstantiation.getId(), NOKIA_LCM_API_VERSION).blockingFirst(); @@ -571,12 +576,6 @@ public class LifecycleManager { logger.error("Unable to " + operation + " VNF with " + vnfId + " identifier", e); jobManager.jobFinished(jobInfo.getJobId()); throw e; - } catch (Exception e) { - String msg = "Unable to " + operation + " VNF with " + vnfId + " identifier"; - logger.error(msg, e); - //the job can only be signaled to be finished after the error is logged - jobManager.jobFinished(jobInfo.getJobId()); - throw new UserVisibleError(msg, e); } jobManager.jobFinished(jobInfo.getJobId()); }); @@ -616,10 +615,5 @@ public class LifecycleManager { this.vnfInfo = vnfInfo; this.vnfdId = vnfdId; } - - public com.nokia.cbam.lcm.v32.model.VnfInfo getVnfInfo() { - return vnfInfo; - } - } } |