summaryrefslogtreecommitdiffstats
path: root/adapters/mso-vfc-adapter/src
diff options
context:
space:
mode:
Diffstat (limited to 'adapters/mso-vfc-adapter/src')
-rw-r--r--adapters/mso-vfc-adapter/src/main/java/org/openecomp/mso/adapters/vfc/VfcManager.java40
1 files changed, 20 insertions, 20 deletions
diff --git a/adapters/mso-vfc-adapter/src/main/java/org/openecomp/mso/adapters/vfc/VfcManager.java b/adapters/mso-vfc-adapter/src/main/java/org/openecomp/mso/adapters/vfc/VfcManager.java
index afea05c2bb..171949aa8e 100644
--- a/adapters/mso-vfc-adapter/src/main/java/org/openecomp/mso/adapters/vfc/VfcManager.java
+++ b/adapters/mso-vfc-adapter/src/main/java/org/openecomp/mso/adapters/vfc/VfcManager.java
@@ -117,17 +117,17 @@ public class VfcManager {
AaiUtil.addRelation(segInput.getNsOperationKey().getServiceId(), nsInstanceId);
// Step 6: save resource operation information
- ResourceOperationStatus nsOperInfo = RequestsDatabase.getResourceOperationStatus(
+ ResourceOperationStatus nsOperInfo = (RequestsDatabase.getInstance()).getResourceOperationStatus(
segInput.getNsOperationKey().getServiceId(), segInput.getNsOperationKey().getOperationId(),
segInput.getNsOperationKey().getNodeTemplateId());
nsOperInfo.setStatus(RequestsDbConstant.Status.PROCESSING);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
if(!HttpCode.isSucess(createRsp.getStatus())) {
LOGGER.error("update segment operation status : fail to create ns");
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setErrorCode(String.valueOf(createRsp.getStatus()));
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR, DriverExceptionID.FAIL_TO_CREATE_NS);
}
LOGGER.info("save segment and operation info -> end");
@@ -155,7 +155,7 @@ public class VfcManager {
LOGGER.info("delete ns response status is : {}", deleteRsp.getStatus());
LOGGER.info("delete ns response content is : {}", deleteRsp.getResponseContent());
LOGGER.info("delete ns -> end");
- ResourceOperationStatus nsOperInfo = RequestsDatabase.getResourceOperationStatus(nsOperationKey.getServiceId(),
+ ResourceOperationStatus nsOperInfo = (RequestsDatabase.getInstance()).getResourceOperationStatus(nsOperationKey.getServiceId(),
nsOperationKey.getOperationId(), nsOperationKey.getNodeTemplateId());
if(!HttpCode.isSucess(deleteRsp.getStatus())) {
LOGGER.error("fail to delete ns");
@@ -163,7 +163,7 @@ public class VfcManager {
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setErrorCode(String.valueOf(deleteRsp.getStatus()));
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.TERMINATE_NS_FAILED);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR, DriverExceptionID.FAIL_TO_DELETE_NS);
}
@@ -174,7 +174,7 @@ public class VfcManager {
// Step4: update service segment operation status
nsOperInfo.setStatus(RequestsDbConstant.Status.FINISHED);
nsOperInfo.setErrorCode(String.valueOf(deleteRsp.getStatus()));
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
LOGGER.info("update segment operaton status for delete -> end");
return deleteRsp;
@@ -213,7 +213,7 @@ public class VfcManager {
@SuppressWarnings("unchecked")
Map<String, String> rsp = JsonUtil.unMarshal(instRsp.getResponseContent(), Map.class);
String jobId = rsp.get(CommonConstant.JOB_ID);
- ResourceOperationStatus nsOperInfo = RequestsDatabase.getResourceOperationStatus(
+ ResourceOperationStatus nsOperInfo = (RequestsDatabase.getInstance()).getResourceOperationStatus(
segInput.getNsOperationKey().getServiceId(), segInput.getNsOperationKey().getOperationId(),
segInput.getNsOperationKey().getNodeTemplateId());
if(ValidateUtil.isStrEmpty(jobId)) {
@@ -221,7 +221,7 @@ public class VfcManager {
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setErrorCode(String.valueOf(instRsp.getStatus()));
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.INSTANTIATE_NS_FAILED);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR,
DriverExceptionID.INVALID_RESPONSE_FROM_INSTANTIATE_OPERATION);
}
@@ -232,14 +232,14 @@ public class VfcManager {
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setErrorCode(String.valueOf(instRsp.getStatus()));
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.INSTANTIATE_NS_FAILED);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR, DriverExceptionID.FAIL_TO_INSTANTIATE_NS);
}
// Step 3: update segment operation job id
LOGGER.info("update resource operation status job id -> begin");
nsOperInfo.setJobId(jobId);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
LOGGER.info("update segment operation job id -> end");
return instRsp;
@@ -257,10 +257,10 @@ public class VfcManager {
public RestfulResponse terminateNs(NsOperationKey nsOperationKey, String nsInstanceId) {
// Step1: save segment operation info for delete process
LOGGER.info("save segment operation for delete process");
- ResourceOperationStatus nsOperInfo = RequestsDatabase.getResourceOperationStatus(nsOperationKey.getServiceId(),
+ ResourceOperationStatus nsOperInfo = (RequestsDatabase.getInstance()).getResourceOperationStatus(nsOperationKey.getServiceId(),
nsOperationKey.getOperationId(), nsOperationKey.getNodeTemplateId());
nsOperInfo.setStatus(RequestsDbConstant.Status.PROCESSING);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
LOGGER.info("terminate ns -> begin");
// Step2: prepare url and method type
@@ -286,7 +286,7 @@ public class VfcManager {
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setErrorCode(String.valueOf(terminateRsp.getStatus()));
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.TERMINATE_NS_FAILED);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR,
DriverExceptionID.INVALID_RESPONSE_FROM_TERMINATE_OPERATION);
}
@@ -298,13 +298,13 @@ public class VfcManager {
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setErrorCode(String.valueOf(terminateRsp.getStatus()));
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.TERMINATE_NS_FAILED);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR, DriverExceptionID.FAIL_TO_TERMINATE_NS);
}
LOGGER.info("update segment job id -> begin");
nsOperInfo.setJobId(jobId);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
LOGGER.info("update segment job id -> end");
return terminateRsp;
@@ -323,7 +323,7 @@ public class VfcManager {
ValidateUtil.assertObjectNotNull(jobId);
// Step 1: query the current resource operation status
- ResourceOperationStatus nsOperInfo = RequestsDatabase.getResourceOperationStatus(nsOperationKey.getServiceId(),
+ ResourceOperationStatus nsOperInfo = (RequestsDatabase.getInstance()).getResourceOperationStatus(nsOperationKey.getServiceId(),
nsOperationKey.getOperationId(), nsOperationKey.getNodeTemplateId());
// Step 2: start query
@@ -341,7 +341,7 @@ public class VfcManager {
nsOperInfo.setErrorCode(String.valueOf(rsp.getStatus()));
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.QUERY_JOB_STATUS_FAILED);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR, DriverExceptionID.FAIL_TO_QUERY_JOB_STATUS);
}
// Step 4: Process Network Service Instantiate Response
@@ -351,7 +351,7 @@ public class VfcManager {
nsOperInfo.setProgress(rspDesc.getProgress());
nsOperInfo.setStatusDescription(rspDesc.getStatusDescription());
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
// Step 6: update segment operation status
if(RequestsDbConstant.Progress.ONE_HUNDRED.equals(rspDesc.getProgress())
@@ -363,13 +363,13 @@ public class VfcManager {
if(RequestsDbConstant.OperationType.CREATE.equals(nsOperInfo.getOperType())) {
nsOperInfo.setStatus(RequestsDbConstant.Status.FINISHED);
}
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
} else if(RequestsDbConstant.Status.ERROR.equals(rspDesc.getStatus())) {
LOGGER.error("job result is failed, operType is {}", nsOperInfo.getOperType());
nsOperInfo.setErrorCode(String.valueOf(rsp.getStatus()));
nsOperInfo.setStatusDescription(CommonConstant.StatusDesc.QUERY_JOB_STATUS_FAILED);
nsOperInfo.setStatus(RequestsDbConstant.Status.ERROR);
- RequestsDatabase.updateResOperStatus(nsOperInfo);
+ (RequestsDatabase.getInstance()).updateResOperStatus(nsOperInfo);
throw new ApplicationException(HttpCode.INTERNAL_SERVER_ERROR, DriverExceptionID.JOB_STATUS_ERROR);
} else {
LOGGER.error("unexcepted response status");