# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
-# limitations under the License.
\ No newline at end of file
+# limitations under the License.
vnf_inst_database_info = NfInstModel.objects.filter(vnf_id=self.vnf_model_in_ns_info["vnf_id"],
ns_inst_id=self.ns_inst_id).get()
self.vnf_inst_database_info = vnf_inst_database_info
- logger.info("VNFD MODEL : %s" %vnf_inst_database_info.vnfd_model)
+ logger.info("VNFD MODEL : %s" % vnf_inst_database_info.vnfd_model)
vnfd_model_info = json.loads(vnf_inst_database_info.vnfd_model)
# vnfd_model_info = json.dumps(vnf_inst_database_info.vnfd_model)
# vnfd_model_info = json.dumps(self.vnf_inst_database_info.vnfd_model)
from lcm.ns.sfcs.create_flowcla import CreateFlowClassifier
from lcm.ns.sfcs.create_port_chain import CreatePortChain
from lcm.ns.sfcs.create_portpairgp import CreatePortPairGroup
-from lcm.ns.sfcs.sfc_instance import SfcInstance
from lcm.ns.sfcs.utils import update_fp_status
from lcm.pub.exceptions import NSLCMException
from lcm.pub.utils.jobutil import JobUtil
"fpinstid": self.fp_inst_id
}
-
def update_vnfffg_info(self):
vnffg_database_info = VNFFGInstModel.objects.filter(vnffginstid=self.vnffg_inst_id).get()
fp_inst_list = vnffg_database_info.fplist
return args[oldkey]
return ""
+
def ignor_dot(str):
index = str.find('.')
if index == -1:
- return str;
+ return str
return str[0:index]
+
def get_fp_id(fpindex,ns_model):
- index = int(int(float(fpindex))-1)
+ index = int(int(float(fpindex)) - 1)
return ns_model['fps'][index].get("fp_id")
+
def update_fp_status(fp_inst_id,status_info):
FPInstModel.objects.filter(fpinstid=fp_inst_id).update(status=status_info)
+
def get_fp_model_by_fp_inst_id(ns_model_data, fp_inst_id):
fp_databas_info = FPInstModel.objects.filter(fpinstid=fp_inst_id).get()
fps_model = ns_model_data["fps"]
logger.info("service_function_chain_fpindex : %s" % ignorcase_get(request.data, 'fpindex'))
ns_model_data = request.data['context']
except Exception as e:
+ logger.error("Exception occurs: %s", e.message)
logger.error(traceback.format_exc())
data = {
'nsinstid': ignorcase_get(request.data, 'nsinstanceid'),
worker = CreateSfcWorker(data)
job_id = worker.init_data()
worker.start()
- logger.info("Service Function Chain Thread Sleep start : %s" %time.ctime())
+ logger.info("Service Function Chain Thread Sleep start : %s" % time.ctime())
time.sleep(2)
logger.info("Service Function Chain Thread Sleep end: %s" % time.ctime())
logger.info("Create Service Function Chain end")