summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsr20255772 <sravya.sherla@wipro.com>2022-11-17 14:59:54 +0000
committerLukasz Rajewski <lukasz.rajewski@t-mobile.pl>2023-01-11 09:10:14 +0000
commitd04f54dedba3e4ade3ac92282c1e3a408a29e70b (patch)
tree7b50e9c150a33b7bb86fa4994c5f218b05b3d224
parent3e1963019895ce83c17816943c3a191bbd4994f7 (diff)
Support Allocate feature for NSMF based TN slices
Issue-ID: SO-4029 Signed-off-by: sr20255772 <sravya.sherla@wipro.com> Change-Id: Ifad4e0a65dc810a843d30800a94c08081bcfd981
-rw-r--r--bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy20
-rw-r--r--bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy2
-rw-r--r--bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn4
3 files changed, 15 insertions, 11 deletions
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy
index a22819f2e9..2317e98dac 100644
--- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSIandNSSI.groovy
@@ -80,7 +80,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
logger.trace("Enter preProcessRequest()")
Map<String, Object> nssiMap = new HashMap<>()
int nsstCount=execution.getVariable("nsstCount") as int
- if(nsstCount==5){
+ if(nsstCount==6){
execution.setVariable("processFHandMH", true)
}
else{
@@ -313,7 +313,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
SliceProfile sliceProfile = new SliceProfile()
sliceProfile.setProfileId(profileId)
- sliceProfile.setCoverageAreaTAList(anSliceProfile.coverageAreaTAList)
+ sliceProfile.setCoverageAreaTAList(anSliceProfile.coverageAreaTAList as String)
sliceProfile.setMaxNumberOfUEs(anSliceProfile.maxNumberOfUEs)
sliceProfile.setLatency(anSliceProfile.latency)
sliceProfile.setMaxNumberOfPDUSession(anSliceProfile.maxNumberOfPDUSession)
@@ -1197,8 +1197,8 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
TransportSliceNetwork transportSliceNetwork = new TransportSliceNetwork()
List<ConnectionLink> connectionLinks = new ArrayList<>()
ConnectionLink connectionLink = new ConnectionLink()
- connectionLink.setTransportEndpointA(execution.getVariable("tranportEp_ID_RU") as String)
- connectionLink.setTransportEndpointB(execution.getVariable("tranportEp_ID_DUIN") as String)
+ connectionLink.setTransportEndpointA(UUID.randomUUID().toString())
+ connectionLink.setTransportEndpointB(UUID.randomUUID().toString())
connectionLinks.add(connectionLink)
transportSliceNetwork.setConnectionLinks(connectionLinks)
transportSliceNetworks.add(transportSliceNetwork)
@@ -1222,7 +1222,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
.subscriptionServiceType(subscriptionServiceType)
.nsiId(sliceParams.getSuggestNsiId())
.serviceInvariantUuid(sliceTaskInfo.getNSSTInfo().getInvariantUUID())
- .setServiceUuid(sliceTaskInfo.getNSSTInfo().getUUID())
+ .serviceUuid(sliceTaskInfo.getNSSTInfo().getUUID())
.nssiId(sliceTaskInfo.getSuggestNssiId())
.sST(sliceTaskInfo.getSliceProfile().getSST() ?: sliceParams.getServiceProfile().get("sST"))
.nssiName("nssi_tn_fh_" + execution.getVariable("sliceServiceInstanceName") as String)
@@ -1234,7 +1234,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
execution.setVariable("TnFHAllocateNssiNbiRequest", nbiRequest)
execution.setVariable("tnFHSliceTaskInfo", sliceTaskInfo)
- execution.setVariable("tnFHSubnetType", SubnetType.TN_BH)
+ execution.setVariable("tnFHSubnetType", SubnetType.TN_FH)
}
/**
@@ -1350,8 +1350,8 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
TransportSliceNetwork transportSliceNetwork = new TransportSliceNetwork()
List<ConnectionLink> connectionLinks = new ArrayList<>()
ConnectionLink connectionLink = new ConnectionLink()
- connectionLink.setTransportEndpointA(execution.getVariable("tranportEp_ID_DUEG") as String)
- connectionLink.setTransportEndpointB(execution.getVariable("tranportEp_ID_CUIN") as String)
+ connectionLink.setTransportEndpointA(UUID.randomUUID().toString())
+ connectionLink.setTransportEndpointB(UUID.randomUUID().toString())
connectionLinks.add(connectionLink)
transportSliceNetwork.setConnectionLinks(connectionLinks)
transportSliceNetworks.add(transportSliceNetwork)
@@ -1378,7 +1378,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
.serviceUuid(sliceTaskInfo.getNSSTInfo().getUUID())
.nssiId(sliceTaskInfo.getSuggestNssiId())
.sST(sliceTaskInfo.getSliceProfile().getSST() ?: sliceParams.getServiceProfile().get("sST"))
- .nssiName("nssi_tn_bh_" + execution.getVariable("sliceServiceInstanceName") as String)
+ .nssiName("nssi_tn_mh_" + execution.getVariable("sliceServiceInstanceName") as String)
.build()
nbiRequest.setServiceInfo(serviceInfo)
@@ -1387,7 +1387,7 @@ class DoAllocateNSIandNSSI extends AbstractServiceTaskProcessor{
execution.setVariable("TnMHAllocateNssiNbiRequest", nbiRequest)
execution.setVariable("tnMHSliceTaskInfo", sliceTaskInfo)
- execution.setVariable("tnMHSubnetType", SubnetType.TN_BH)
+ execution.setVariable("tnMHSubnetType", SubnetType.TN_MH)
}
/**
diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy
index 6981d94324..fc873be28e 100644
--- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy
+++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateNSSI.groovy
@@ -110,7 +110,9 @@ class DoAllocateNSSI extends AbstractServiceTaskProcessor {
execution.setVariable("nssiAllocateStatus", jobStatusResponse)
if (jobStatusResponse.getResponseDescriptor().getProgress() == 100) {
+ if (nssiId == null) {
nssiAllocateResult.setNssiId(jobStatusResponse.getResponseDescriptor().getNssiId())
+ }
execution.setVariable("jobFinished", true)
}
}
diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn
index 51f96ee8a9..e35a197b7b 100644
--- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn
+++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoAllocateNSIandNSSI.bpmn
@@ -413,7 +413,9 @@ dcnsio.updateTnMHRelationship(execution)</bpmn:script>
<bpmn:incoming>Flow_13i03hb</bpmn:incoming>
<bpmn:linkEventDefinition id="LinkEventDefinition_1rscmuw" name="CreateTnFHSliceProfile" />
</bpmn:intermediateThrowEvent>
- <bpmn:sequenceFlow id="Flow_0ehx22x" sourceRef="Gateway_0tpcoai" targetRef="EndEvent_02c8wsp" />
+ <bpmn:sequenceFlow id="Flow_0ehx22x" name="no" sourceRef="Gateway_0tpcoai" targetRef="EndEvent_02c8wsp">
+ <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("processFHandMH" ) == false)}</bpmn:conditionExpression>
+ </bpmn:sequenceFlow>
<bpmn:sequenceFlow id="Flow_13i03hb" name="yes" sourceRef="Gateway_0tpcoai" targetRef="Event_1hemevb">
<bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("processFHandMH" ) == true)}</bpmn:conditionExpression>
</bpmn:sequenceFlow>