Skip to content
Snippets Groups Projects
Commit 8b7b9642 authored by Stefano Borini's avatar Stefano Borini
Browse files

Fixed overall import strategy

parent 3fb56bfe
No related branches found
No related tags found
1 merge request!79Deliver notification info
...@@ -21,6 +21,8 @@ from .mco.i_mco_factory import IMCOFactory # noqa ...@@ -21,6 +21,8 @@ from .mco.i_mco_factory import IMCOFactory # noqa
from .mco.parameters.base_mco_parameter_factory import BaseMCOParameterFactory # noqa from .mco.parameters.base_mco_parameter_factory import BaseMCOParameterFactory # noqa
from .mco.parameters.base_mco_parameter import BaseMCOParameter # noqa from .mco.parameters.base_mco_parameter import BaseMCOParameter # noqa
from .mco.events import * # noqa
from .notification_listeners.i_notification_listener_factory import INotificationListenerFactory # noqa from .notification_listeners.i_notification_listener_factory import INotificationListenerFactory # noqa
from .notification_listeners.base_notification_listener import BaseNotificationListener # noqa from .notification_listeners.base_notification_listener import BaseNotificationListener # noqa
from .notification_listeners.base_notification_listener_factory import BaseNotificationListenerFactory # noqa from .notification_listeners.base_notification_listener_factory import BaseNotificationListenerFactory # noqa
......
from force_bdss.api import BaseNotificationListener from force_bdss.api import (
from force_bdss.mco.events import ( BaseNotificationListener,
MCOStartEvent, MCOFinishEvent, MCOProgressEvent) MCOStartEvent,
MCOFinishEvent,
MCOProgressEvent
)
class DummyNotificationListener(BaseNotificationListener): class DummyNotificationListener(BaseNotificationListener):
......
from traits.api import String from traits.api import String
from force_bdss.ids import factory_id from force_bdss.api import (
from force_bdss.notification_listeners.base_notification_listener_factory \ factory_id,
import \ BaseNotificationListenerFactory)
BaseNotificationListenerFactory
from .dummy_notification_listener import DummyNotificationListener from .dummy_notification_listener import DummyNotificationListener
from .dummy_notification_listener_model import DummyNotificationListenerModel from .dummy_notification_listener_model import DummyNotificationListenerModel
......
from force_bdss.notification_listeners.base_notification_listener_model \ from force_bdss.api import BaseNotificationListenerModel
import \
BaseNotificationListenerModel
class DummyNotificationListenerModel(BaseNotificationListenerModel): class DummyNotificationListenerModel(BaseNotificationListenerModel):
......
from force_bdss.api import BaseExtensionPlugin, plugin_id from force_bdss.api import BaseExtensionPlugin, plugin_id
from force_bdss.core_plugins.dummy.dummy_notification_listener\ from .dummy_notification_listener.dummy_notification_listener_factory import (
.dummy_notification_listener_factory import \
DummyNotificationListenerFactory DummyNotificationListenerFactory
from force_bdss.core_plugins.dummy.ui_notification.ui_notification_factory \ )
import \ from .ui_notification.ui_notification_factory import UINotificationFactory
UINotificationFactory
from .csv_extractor.csv_extractor_factory import CSVExtractorFactory from .csv_extractor.csv_extractor_factory import CSVExtractorFactory
from .kpi_adder.kpi_adder_factory import KPIAdderFactory from .kpi_adder.kpi_adder_factory import KPIAdderFactory
from .dummy_dakota.dakota_factory import DummyDakotaFactory from .dummy_dakota.dakota_factory import DummyDakotaFactory
......
...@@ -2,14 +2,20 @@ import errno ...@@ -2,14 +2,20 @@ import errno
import logging import logging
from traits.api import Any, List from traits.api import Any, List
from force_bdss.api import BaseNotificationListener from force_bdss.api import (
import zmq BaseNotificationListener,
MCOStartEvent,
from force_bdss.mco.events import MCOStartEvent, MCOFinishEvent, \ MCOFinishEvent,
MCOProgressEvent MCOProgressEvent
)
import zmq
class UINotification(BaseNotificationListener): class UINotification(BaseNotificationListener):
"""
Notification engine for the UI. Uses zeromq for the traffic handling.
"""
#: The ZMQ context. #: The ZMQ context.
_context = Any() _context = Any()
...@@ -49,6 +55,15 @@ class UINotification(BaseNotificationListener): ...@@ -49,6 +55,15 @@ class UINotification(BaseNotificationListener):
self._rep_socket = self._context.socket(zmq.REP) self._rep_socket = self._context.socket(zmq.REP)
self._rep_socket.bind("tcp://*:12346") self._rep_socket.bind("tcp://*:12346")
def finalize(self, model):
self._pub_socket.close()
self._rep_socket.close()
self._context.term()
self._pub_socket = None
self._rep_socket = None
self._context = None
def _format_event(self, event): def _format_event(self, event):
if isinstance(event, MCOStartEvent): if isinstance(event, MCOStartEvent):
data = "MCO_START" data = "MCO_START"
...@@ -63,8 +78,3 @@ class UINotification(BaseNotificationListener): ...@@ -63,8 +78,3 @@ class UINotification(BaseNotificationListener):
return ("EVENT\n{}".format(data)).encode("utf-8") return ("EVENT\n{}".format(data)).encode("utf-8")
def finalize(self, model):
self._context.destroy()
self._pub_socket = None
self._rep_socket = None
self._context = None
from traits.api import String from traits.api import String
from force_bdss.ids import factory_id from force_bdss.api import factory_id, BaseNotificationListenerFactory
from force_bdss.notification_listeners.base_notification_listener_factory \
import \
BaseNotificationListenerFactory
from .ui_notification import UINotification from .ui_notification import UINotification
from .ui_notification_model import UINotificationModel from .ui_notification_model import UINotificationModel
......
from force_bdss.notification_listeners.base_notification_listener_model \ from force_bdss.api import BaseNotificationListenerModel
import \
BaseNotificationListenerModel
class UINotificationModel(BaseNotificationListenerModel): class UINotificationModel(BaseNotificationListenerModel):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment