Merge branch 'wip' of gitlab.psi.ch-samenv:samenv/frappy into wip

secop_psi/sea.py

@@ -110,10 +110,13 @@ class SeaClient(ProxyClient, Module):
     visibility = 'expert'
     default_json_file = {}
     _connect_thread = None
+    _service_manager = None
+    _instance = None
 
     def __init__(self, name, log, opts, srv):
         instance = srv.node_cfg['name'].rsplit('_', 1)[0]
         if 'uri' not in opts:
+            self._instance = instance
             port = get_sea_port(instance)
             if port is None:
                 raise ConfigError('missing sea port for %s' % instance)
@@ -140,6 +143,11 @@ class SeaClient(ProxyClient, Module):
         self._connect_thread = mkthread(self._connect, start_events.get_trigger())
 
     def _connect(self, started_callback):
+        if self._instance:
+            if not self._service_manager:
+                from servicemanager import SeaManager
+                self._service_manager = SeaManager()
+            self._service_manager.do_start(self._instance)
         if '//' not in self.uri:
             self.uri = 'tcp://' + self.uri
         self.asynio = AsynConn(self.uri)
@@ -607,7 +615,8 @@ class SeaModule(Module):
             except Exception as e:
                 readerror = secop_error(e)
         pobj.readerror = readerror
-        self.DISPATCHER.broadcast_event(make_update(self.name, pobj))
+        if pobj.export:
+            self.DISPATCHER.broadcast_event(make_update(self.name, pobj))
 
     def initModule(self):
         self.io.register_obj(self, self.sea_object)