Initial commit

[ta/config-manager.git] / cmframework / src / cmframework / utils / cmactivationwork.py

diff --git a/cmframework/src/cmframework/utils/cmactivationwork.py b/cmframework/src/cmframework/utils/cmactivationwork.py
new file mode 100644 (file)
index 0000000..8bec756
--- /dev/null
+++ b/cmframework/src/cmframework/utils/cmactivationwork.py
@@ -0,0 +1,127 @@
+# Copyright 2019 Nokia
+
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# 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.
+from threading import Condition
+import json
+
+from cmframework.apis import cmerror
+
+
+class CMActivationWork(object):
+    """
+    Serialize/Deserialize the work to/from json, the structure of the json data is the following:
+    {
+        'operation': <operation number>,
+        'csn': <csn number>,
+        'properties': {
+            '<name>': '<value>',
+            ....
+        }
+    }
+    """
+
+    OPER_NONE = 0
+    OPER_SET = 1
+    OPER_DELETE = 2
+    OPER_FULL = 3
+    OPER_NODE = 4
+
+    OPER_NAMES = ('NONE', 'SET', 'DELETE', 'FULL', 'NODE')
+
+    def __init__(self,
+                 operation=OPER_NONE,
+                 csn=0,
+                 props=None,
+                 target=None,
+                 startup_activation=False):
+        self.operation = operation
+        self.csn = csn
+        if not props:
+            self.props = {}
+        else:
+            self.props = props
+        self.target = target
+        self.condition = Condition()
+        self.condition.acquire()
+        self.result = None
+        self.uuid_value = None
+        self.startup_activation = startup_activation
+
+    def __str__(self):
+        return '(%r %d %r %r %r)' % (self._get_operation_name(),
+                                     self.csn,
+                                     self.props,
+                                     self.target,
+                                     self.startup_activation)
+
+    def _get_operation_name(self):
+        return CMActivationWork.OPER_NAMES[self.operation]
+
+    def get_operation(self):
+        return self.operation
+
+    def get_csn(self):
+        return self.csn
+
+    def get_props(self):
+        return self.props
+
+    def get_target(self):
+        return self.target
+
+    def add_result(self, result):
+        self.condition.acquire()
+        self.result = result
+        self.condition.notify()
+        self.condition.release()
+
+    def get_result(self):
+        self.condition.acquire()
+        self.condition.wait()
+        self.condition.release()
+        return self.result
+
+    def release(self):
+        self.condition.notify()
+        self.condition.release()
+
+    def is_startup_activation(self):
+        return self.startup_activation
+
+    def serialize(self):
+        try:
+            data = {}
+            data['operation'] = self.operation
+            data['csn'] = self.csn
+            data['properties'] = self.props
+            data['result'] = self.result
+            data['startup_activation'] = self.startup_activation
+            return json.dumps(data)
+        except Exception as exp:
+            raise cmerror.CMError(str(exp))
+
+    def deserialize(self, msg):
+        try:
+            data = json.loads(msg)
+            self.operation = data['operation']
+            self.csn = data['csn']
+            self.props = data['properties']
+            self.result = data['result']
+            self.startup_activation = data['startup_activation']
+        except Exception as exp:
+            raise cmerror.CMError(str(exp))
+
+
+if __name__ == '__main__':
+    work = CMActivationWork(CMActivationWork.OPER_FULL, 10, {})
+    print 'Work is %s' % work