1 # -*- coding: utf-8 -*-
4 # Copyright 2018 Telefonica S.A.
6 # Licensed under the Apache License, Version 2.0 (the "License"); you may
7 # not use this file except in compliance with the License. You may obtain
8 # a copy of the License at
10 # http://www.apache.org/licenses/LICENSE-2.0
12 # Unless required by applicable law or agreed to in writing, software
13 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
14 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
15 # License for the specific language governing permissions and limitations
19 from collections
import OrderedDict
20 from osm_common
.dbbase
import DbException
22 __author__
= "Alfonso Tierno"
25 class LcmException(Exception):
29 class LcmExceptionNoMgmtIP(LcmException
):
34 """utility for compare dot separate versions. Fills with zeros to proper number comparison
35 package version will be something like 4.0.1.post11+gb3f024d.dirty-1. Where 4.0.1 is the git tag, postXX is the
36 number of commits from this tag, and +XXXXXXX is the git commit short id. Total length is 16 with until 999 commits
39 for point
in v
.split("."):
40 filled
.append(point
.zfill(16))
46 Implements a registry of task needed for later cancelation, look for related tasks that must be completed before
47 etc. It stores a four level dict
48 First level is the topic, ns, vim_account, sdn
49 Second level is the _id
50 Third level is the operation id
51 Fourth level is a descriptive name, the value is the task class
55 self
.task_registry
= {
62 def register(self
, topic
, _id
, op_id
, task_name
, task
):
65 :param topic: Can be "ns", "nsi", "vim_account", "sdn"
66 :param _id: _id of the related item
67 :param op_id: id of the operation of the related item
68 :param task_name: Task descriptive name, as create, instantiate, terminate. Must be unique in this op_id
69 :param task: Task class
72 if _id
not in self
.task_registry
[topic
]:
73 self
.task_registry
[topic
][_id
] = OrderedDict()
74 if op_id
not in self
.task_registry
[topic
][_id
]:
75 self
.task_registry
[topic
][_id
][op_id
] = {task_name
: task
}
77 self
.task_registry
[topic
][_id
][op_id
][task_name
] = task
78 # print("registering task", topic, _id, op_id, task_name, task)
80 def remove(self
, topic
, _id
, op_id
, task_name
=None):
82 When task is ended, it should removed. It ignores missing tasks
83 :param topic: Can be "ns", "nsi", "vim_account", "sdn"
84 :param _id: _id of the related item
85 :param op_id: id of the operation of the related item
86 :param task_name: Task descriptive name. If note it deletes all
89 if not self
.task_registry
[topic
].get(_id
) or not self
.task_registry
[topic
][_id
].get(op_id
):
92 # print("deleting tasks", topic, _id, op_id, self.task_registry[topic][_id][op_id])
93 del self
.task_registry
[topic
][_id
][op_id
]
94 elif task_name
in self
.task_registry
[topic
][_id
][op_id
]:
95 # print("deleting tasks", topic, _id, op_id, task_name, self.task_registry[topic][_id][op_id][task_name])
96 del self
.task_registry
[topic
][_id
][op_id
][task_name
]
97 if not self
.task_registry
[topic
][_id
][op_id
]:
98 del self
.task_registry
[topic
][_id
][op_id
]
99 if not self
.task_registry
[topic
][_id
]:
100 del self
.task_registry
[topic
][_id
]
102 def lookfor_related(self
, topic
, _id
, my_op_id
=None):
105 if _id
not in self
.task_registry
[topic
]:
106 return "", task_name_list
107 for op_id
in reversed(self
.task_registry
[topic
][_id
]):
109 if my_op_id
== op_id
:
110 my_op_id
= None # so that the next task is taken
113 for task_name
, task
in self
.task_registry
[topic
][_id
][op_id
].items():
114 task_list
.append(task
)
115 task_name_list
.append(task_name
)
117 return ", ".join(task_name_list
), task_list
119 def cancel(self
, topic
, _id
, target_op_id
=None, target_task_name
=None):
121 Cancel all active tasks of a concrete ns, nsi, vim_account, sdn identified for _id. If op_id is supplied only
122 this is cancelled, and the same with task_name
124 if not self
.task_registry
[topic
].get(_id
):
126 for op_id
in reversed(self
.task_registry
[topic
][_id
]):
127 if target_op_id
and target_op_id
!= op_id
:
129 for task_name
, task
in self
.task_registry
[topic
][_id
][op_id
].items():
130 if target_task_name
and target_task_name
!= task_name
:
135 # self.logger.debug("{} _id={} order_id={} task={} cancelled".format(topic, _id, op_id, task_name))
140 def __init__(self
, db
, msg
, fs
, logger
):
143 :param db: database connection
150 def update_db_2(self
, item
, _id
, _desc
):
152 Updates database with _desc information. Upon success _desc is cleared
161 self
.db
.set_one(item
, {"_id": _id
}, _desc
)
163 except DbException
as e
:
164 self
.logger
.error("Updating {} _id={} with '{}'. Error: {}".format(item
, _id
, _desc
, e
))