From 905b0231e93ce2409a45dd6c4f5f983689fdb790 Mon Sep 17 00:00:00 2001
From: Harry Huang <huangxiangyu5@huawei.com>
Date: Wed, 1 Nov 2017 11:56:50 +0800
Subject: Add compass-deck

RESTful API and DB Handlers for Compass

Change-Id: I1ce411f279943764c286ea48dca9185d453cf254
Signed-off-by: Harry Huang <huangxiangyu5@huawei.com>
---
 compass-deck/utils/daemonize.py | 76 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 76 insertions(+)
 create mode 100644 compass-deck/utils/daemonize.py

(limited to 'compass-deck/utils/daemonize.py')

diff --git a/compass-deck/utils/daemonize.py b/compass-deck/utils/daemonize.py
new file mode 100644
index 0000000..f02bfb9
--- /dev/null
+++ b/compass-deck/utils/daemonize.py
@@ -0,0 +1,76 @@
+# Copyright 2014 Huawei Technologies Co. Ltd
+#
+# 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.
+
+"""Module to provider util functions in all compass code
+
+   .. moduleauthor:: Xiaodong Wang <xiaodongwang@huawei.com>
+"""
+import daemon
+import logging
+import signal
+import sys
+import time
+
+from compass.utils import flags
+
+
+flags.add_bool('daemonize',
+               help='run as daemon',
+               default=False)
+
+
+BUSY = False
+KILLED = False
+
+
+def handle_term(signum, frame):
+    """Handle sig term."""
+    global KILLED
+    logging.info('Caught signal %s in %s', signum, frame)
+    KILLED = True
+    if not BUSY:
+        sys.exit(0)
+
+
+def _daemon(callback, run_interval):
+    """help function to run callback in daemon."""
+    global BUSY
+    signal.signal(signal.SIGTERM, handle_term)
+    signal.signal(signal.SIGHUP, handle_term)
+
+    while True:
+        BUSY = True
+        callback()
+        BUSY = False
+        if KILLED:
+            logging.info('exit loop')
+            break
+
+        if run_interval > 0:
+            logging.info('will rerun after %s seconds',
+                         flags.OPTIONS.run_interval)
+            time.sleep(flags.OPTIONS.run_interval)
+        else:
+            logging.info('finish loop')
+            break
+
+
+def daemonize(callback, run_interval, **kwargs):
+    """daemonize callback and run every run_interval seconds."""
+    if flags.OPTIONS.daemonize:
+        with daemon.DaemonContext(**kwargs):
+            logging.info('run as daemon')
+            _daemon(callback, run_interval)
+    else:
+        _daemon(callback, run_interval)
-- 
cgit 1.2.3-korg