Merge branch 'rel/5.1' into core-future

Author: bharnden

daemon/core/emane/commeffect.py

@@ -9,7 +9,10 @@
 try:
     from emane.events.commeffectevent import CommEffectEvent
 except ImportError:
-    logger.info("emane 1.2.1 not found")
+    try:
+        from emanesh.events.commeffectevent import CommEffectEvent
+    except ImportError:
+        logger.warn("compatible emane python bindings not installed")
 
 
 def convert_none(x):

daemon/core/emane/emanemanager.py

@@ -34,7 +34,12 @@
     from emane.events import LocationEvent
     from emane.events.eventserviceexception import EventServiceException
 except ImportError:
-    logger.info("emane 1.2.1 not found")
+    try:
+        from emanesh.events import EventService
+        from emanesh.events import LocationEvent
+        from emanesh.events.eventserviceexception import EventServiceException
+    except ImportError:
+        logger.warn("compatible emane python bindings not installed")
 
 EMANE_MODELS = [
     EmaneRfPipeModel,
@@ -76,7 +81,7 @@ def __init__(self, session):
         self.transformport = self.session.get_config_item_int("emane_transform_port", 8200)
         self.doeventloop = False
         self.eventmonthread = None
-        self.logversion()
+
         # model for global EMANE configuration options
         self.emane_config = EmaneGlobalModel(session, None)
         session.broker.handlers.add(self.handledistributed)
@@ -86,24 +91,28 @@ def __init__(self, session):
             self.emane_config.name: self.emane_config
         }
 
-        # load provided models
-        self.load_models(EMANE_MODELS)
-
-        # load custom models
-        custom_models_path = session.config.get("emane_models_dir")
-        if custom_models_path:
-            emane_models = utils.load_classes(custom_models_path, EmaneModel)
-            self.load_models(emane_models)
-
         self.service = None
+        self.emane_check()
 
-    def logversion(self):
+    def emane_check(self):
         """
-        Log the installed EMANE version.
+        Check if emane is installed and load models.
+
+        :return: nothing
         """
         try:
+            # check for emane
             emane_version = utils.check_cmd(["emane", "--version"])
             logger.info("using EMANE: %s", emane_version)
+
+            # load default emane models
+            self.load_models(EMANE_MODELS)
+
+            # load custom models
+            custom_models_path = self.session.config.get("emane_models_dir")
+            if custom_models_path:
+                emane_models = utils.load_classes(custom_models_path, EmaneModel)
+                self.load_models(emane_models)
         except CoreCommandError:
             logger.info("emane is not installed")
 

daemon/core/emane/emanemanifest.py

@@ -1,10 +1,14 @@
 from core import logger
 from core.enumerations import ConfigDataTypes
 
+manifest = None
 try:
     from emane.shell import manifest
 except ImportError:
-    logger.info("emane 1.2.1 not found")
+    try:
+        from emanesh import manifest
+    except ImportError:
+        logger.warn("compatible emane python bindings not installed")
 
 
 def _type_value(config_type):
@@ -77,6 +81,10 @@ def parse(manifest_path, defaults):
     :rtype: list
     """
 
+    # no results when emane bindings are not present
+    if not manifest:
+        return []
+
     # load configuration file
     manifest_file = manifest.Manifest(manifest_path)
     manifest_configurations = manifest_file.getAllConfiguration()

daemon/core/emane/nodes.py

@@ -15,7 +15,10 @@
 try:
     from emane.events import LocationEvent
 except ImportError:
-    logger.info("emane 1.2.1 not found")
+    try:
+        from emanesh.events import LocationEvent
+    except ImportError:
+        logger.warn("compatible emane python bindings not installed")
 
 
 class EmaneNet(PyCoreNet):

daemon/core/service.py

@@ -72,6 +72,8 @@ def add_services(cls, path):
         """
         services = utils.load_classes(path, CoreService)
         for service in services:
+            if not service._name:
+                continue
             service.on_load()
             cls.add(service)
 

daemon/core/services/bird.py

@@ -90,7 +90,7 @@ class BirdService(CoreService):
     common to Bird's routing daemons.
     """
 
-    _name = "BirdDaemon"
+    _name = None
     _group = "BIRD"
     _depends = ("bird",)
     _dirs = ()

daemon/core/services/nrl.py

@@ -13,7 +13,7 @@ class NrlService(CoreService):
     Parent class for NRL services. Defines properties and methods
     common to NRL's routing daemons.
     """""
-    _name = "Protean"
+    _name = None
     _group = "ProtoSvc"
     _depends = ()
     _dirs = ()

daemon/core/services/quagga.py

@@ -222,7 +222,7 @@ class QuaggaService(CoreService):
     Parent class for Quagga services. Defines properties and methods
     common to Quagga's routing daemons.
     """
-    _name = "QuaggaDaemon"
+    _name = None
     _group = "Quagga"
     _depends = ("zebra",)
     _dirs = ()

daemon/core/services/sdn.py

@@ -11,7 +11,7 @@ class SdnService(CoreService):
     """
     Parent class for SDN services.
     """
-    _name = "SdnProcess"
+    _name = None
     _group = "SDN"
     _depends = ()
     _dirs = ()

daemon/core/services/utility.py

@@ -16,7 +16,7 @@ class UtilService(CoreService):
     """
     Parent class for utility services.
     """
-    _name = "UtilityProcess"
+    _name = None
     _group = "Utility"
     _depends = ()
     _dirs = ()