Get All Policy Type Instance

[ric-plt/a1.git] / a1 / run.py

diff --git a/a1/run.py b/a1/run.py
index feaada3..e13d199 100644 (file)
--- a/a1/run.py
+++ b/a1/run.py
@@ -1,6 +1,3 @@
-"""
-A1 entrypoint
-"""

 # ==================================================================================
 #       Copyright (c) 2019 Nokia
 #       Copyright (c) 2018-2019 AT&T Intellectual Property.
 # ==================================================================================
 #       Copyright (c) 2019 Nokia
 #       Copyright (c) 2018-2019 AT&T Intellectual Property.


@@ -17,22 +14,30 @@ A1 entrypoint
 #   See the License for the specific language governing permissions and
 #   limitations under the License.
 # ==================================================================================
 #   See the License for the specific language governing permissions and
 #   limitations under the License.
 # ==================================================================================

+"""
+A1 entrypoint
+"""
+from os import environ

 from gevent.pywsgi import WSGIServer
 from mdclogpy import Logger
 from a1 import app
 from a1 import a1rmr
 
 
 from gevent.pywsgi import WSGIServer
 from mdclogpy import Logger
 from a1 import app
 from a1 import a1rmr
 
 

-mdc_logger = Logger(name=__name__)
+mdc_logger = Logger()
+mdc_logger.mdclog_format_init(configmap_monitor=True)

 
 
 def main():
     """Entrypoint"""
 
 
 def main():
     """Entrypoint"""

+    mdc_logger.debug("A1Mediator starts")

     # start rmr thread
     # start rmr thread

-    mdc_logger.debug("Initializing rmr thread. A1s webserver will not start until rmr initialization is complete.")
+    mdc_logger.debug("Starting RMR thread with RMR_RTG_SVC {0}, RMR_SEED_RT {1}".format(environ.get('RMR_RTG_SVC'), environ.get('RMR_SEED_RT')))
+    mdc_logger.debug("RMR initialization must complete before webserver can start")

     a1rmr.start_rmr_thread()
     a1rmr.start_rmr_thread()

-
+    mdc_logger.debug("RMR initialization complete")

     # start webserver
     # start webserver

-    mdc_logger.debug("Starting gevent server")
-    http_server = WSGIServer(("", 10000), app)
+    port = 10000
+    mdc_logger.debug("Starting gevent webserver on port {0}".format(port))
+    http_server = WSGIServer(("", port), app)

     http_server.serve_forever()
     http_server.serve_forever()