linse/frappy
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix handling of unknown sea messages

Browse Source
This commit is contained in:
zolliker
2021-04-23 09:21:47 +02:00
parent 48d5fe5ea2
commit 99eb600d90
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
secop_psi/sea.py
View File

@ -229,10 +229,13 @@ class SeaClient(ProxyClient, Module):
started_callback = None
continue
if flag != 'hdbevent':
if obj != 'frappy_async_client':
if obj not in ('frappy_async_client', 'get_all_param'):
print('SKIP', msg)
continue
if data is None:
if not data:
continue
if not isinstance(data, dict):
print('what means %r' % msg)
continue
now = time.time()
for path, value in data.items():
@ -413,7 +416,7 @@ class SeaModule(Module):
if result[0]['path'] != '':
pass # TODO: check these cases
result[0]['key'] = 'value'
logger.info('PARAMS %s %r', name, result)
# logger.info('PARAMS %s %r', name, result)
base = descr['base']
params = descr['params']
extra_module_set = cfgdict.pop('extra_modules', ())
@ -466,7 +469,7 @@ class SeaModule(Module):
extra_modules[name + '.' + key] = sea_object, base, paramdesc
continue # skip this parameter
path2param[hdbpath] = (name, key)
logger.info('PARAM %s %s %s', hdbpath, name, key)
# logger.info('PARAM %s %s %s', hdbpath, name, key)
attributes[key] = pobj
# if hasattr(cls, 'read_' + key):
# print('override %s.read_%s' % (cls.__name__, key))
@ -601,4 +604,4 @@ class SeaDrivable(SeaModule, Drivable):
self.target = value
def stop(self):
self._iodev.query('%s is_running 0' % self.sea_object)
self._iodev.query('%s is_running 0' % self.sea_object)