X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=models%2Fopenmano%2Fpython%2Frift%2Fopenmano%2Frift2openmano.py;h=44e80b637033f2e5f07b5d9611c476d858832bd3;hb=2528ad516da7a243d2477c78f9e1239c1e580e7c;hp=61e195b0810f8b0b3d7e2303179777cdf5eecd17;hpb=bf4c4085771a2396b9808c080f8e5bcde4e829f6;p=osm%2FSO.git diff --git a/models/openmano/python/rift/openmano/rift2openmano.py b/models/openmano/python/rift/openmano/rift2openmano.py index 61e195b0..44e80b63 100755 --- a/models/openmano/python/rift/openmano/rift2openmano.py +++ b/models/openmano/python/rift/openmano/rift2openmano.py @@ -339,7 +339,8 @@ def rift2openmano_vnfd_nsd(rift_nsd, rift_vnfds, openmano_vnfd_ids,rift_vnfd_id= openmano_vnfd_id = openmano_vnfd_ids.get(rift_vnfd_id,None) for rvnfd_id in rift_nsd.constituent_vnfds: if rvnfd_id.vnfd_id_ref == rift_vnfd_id: - topology["nodes"][rift_vnfd_id+'__'+str(rvnfd_id.member_vnf_index)] = { + rift_vnfd = rift_vnfds[rift_vnfd_id] + topology["nodes"][rift_vnfd.name +'__'+str(rvnfd_id.member_vnf_index)] = { "type": "VNF", "vnf_id": openmano_vnfd_id } @@ -374,7 +375,7 @@ def rift2openmano_vnfd_nsd(rift_nsd, rift_vnfds, openmano_vnfd_ids,rift_vnfd_id= topology["connections"][vld.name]["type"] = "link" # Vnf ref is the vnf name with the member_vnf_idx appended member_idx = vnfd_cp.member_vnf_index_ref - vnf_ref = rift_vnfd_id + "__" + str(member_idx) + vnf_ref = vnfd.name + "__" + str(member_idx) topology["connections"][vld.name]["nodes"].append( { vnf_ref: vnfd_cp.vnfd_connection_point_ref @@ -559,6 +560,9 @@ def rift2openmano_vnfd(rift_vnfd, rift_nsd): if numa_node_policy.has_field("node"): numa_node = numa_node_policy.node[0] + if numa_node.has_field("num_cores"): + vnfc["numas"][0]["cores"] = numa_node.num_cores + if numa_node.has_field("paired_threads"): if numa_node.paired_threads.has_field("num_paired_threads"): vnfc["numas"][0]["paired-threads"] = numa_node.paired_threads.num_paired_threads @@ -569,6 +573,8 @@ def rift2openmano_vnfd(rift_vnfd, rift_nsd): [pair.thread_a, pair.thread_b] ) + if numa_node.has_field("num_threads"): + vnfc["numas"][0]["threads"] = numa_node.num_threads else: if vdu.vm_flavor.has_field("vcpu_count"): vnfc["numas"][0]["cores"] = max(vdu.vm_flavor.vcpu_count, 1)