bec/ophyd_devices
0
0
Fork 0
mirror of https://github.com/bec-project/ophyd_devices.git synced 2025-05-29 08:00:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

bug fixes for sls devices

Browse Source
This commit is contained in:
Wakonig Klaus 2022-11-18 09:59:49 +01:00
parent e0c0469795
commit 62054c56af
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ophyd_devices/sls_devices/sls_devices.py
View File

@ -7,6 +7,8 @@ from ophyd import EpicsSignalRO
class SLSOperatorMessages(Device):
SUB_VALUE = "value"
_default_sub = SUB_VALUE
messages_info = {
f"message{i}": (EpicsSignalRO, f"ACOAU-ACCU:OP-MSG{i}", {}) for i in range(1, 6)
}
@ -14,6 +16,14 @@ class SLSOperatorMessages(Device):
date_info = {f"message{i}": (EpicsSignalRO, f"ACOAU-ACCU:OP-DATE{i}", {}) for i in range(1, 6)}
date = Dcpt(date_info)
def __init__(self, prefix="", *, name, **kwargs):
super().__init__(prefix, name=name, **kwargs)
self.messages.message1.subscribe(self._emit_value)
def _emit_value(self, **kwargs):
timestamp = kwargs.pop("timestamp", time.time())
self.wait_for_connection()
self._run_subs(sub_type=self.SUB_VALUE, timestamp=timestamp, obj=self)
class SLSInfo(Device):
SUB_VALUE = "value"
@ -46,5 +56,5 @@ class SLSInfo(Device):
def _emit_value(self, **kwargs):
timestamp = kwargs.pop("timestamp", time.time())
value = self.read()
self._run_subs(sub_type=self.SUB_VALUE, timestamp=timestamp, value=value, **kwargs)
self.wait_for_connection()
self._run_subs(sub_type=self.SUB_VALUE, timestamp=timestamp, obj=self)