aboutsummaryrefslogtreecommitdiffstats
path: root/moonv4/moon_router/moon_router/server.py
diff options
context:
space:
mode:
Diffstat (limited to 'moonv4/moon_router/moon_router/server.py')
-rw-r--r--moonv4/moon_router/moon_router/server.py22
1 files changed, 13 insertions, 9 deletions
diff --git a/moonv4/moon_router/moon_router/server.py b/moonv4/moon_router/moon_router/server.py
index 40e2b945..1b2bddee 100644
--- a/moonv4/moon_router/moon_router/server.py
+++ b/moonv4/moon_router/moon_router/server.py
@@ -6,9 +6,8 @@
import os
import threading
import signal
-from oslo_config import cfg
from oslo_log import log as logging
-from moon_utilities import options # noqa
+from moon_utilities import configuration, exceptions
from moon_router.messenger import Server
@@ -21,9 +20,7 @@ class AsyncServer(threading.Thread):
def run(self):
self.server.run()
-LOG = logging.getLogger(__name__)
-CONF = cfg.CONF
-DOMAIN = "moon_router"
+LOG = logging.getLogger("moon.router")
__CWD__ = os.path.dirname(os.path.abspath(__file__))
@@ -37,20 +34,27 @@ def stop_thread():
def main():
global background_threads
- LOG.info("Starting server with IP {}".format(CONF.security_router.host))
+ configuration.init_logging()
+ try:
+ conf = configuration.get_configuration("components/router")
+ except exceptions.ConsulComponentNotFound:
+ conf = configuration.add_component("router", "router")
signal.signal(signal.SIGALRM, stop_thread)
signal.signal(signal.SIGTERM, stop_thread)
signal.signal(signal.SIGABRT, stop_thread)
background_master = None
- if CONF.slave.slave_name:
+ slave = configuration.get_configuration(configuration.SLAVE)["slave"]
+ if slave['name']:
background_master = AsyncServer(add_master_cnx=True)
background_threads.append(background_master)
background_slave = AsyncServer(add_master_cnx=False)
background_threads.append(background_slave)
- if CONF.slave.slave_name:
+ if slave['name']:
background_master.start()
+ LOG.info("Connecting to master...")
background_slave.start()
- if CONF.slave.slave_name:
+ LOG.info("Starting main server {}".format(conf["components/router"]["hostname"]))
+ if slave['name']:
background_master.join()
background_slave.join()