various unicode fixes
Change-Id: Ia3a83b678a5084fd1d43b8cf513b296fdbde3d91 Reviewed-on: https://forge.frm2.tum.de/review/19198 Tested-by: JenkinsCodeReview <bjoern_pedersen@frm2.tum.de> Reviewed-by: Enrico Faulhaber <enrico.faulhaber@frm2.tum.de>
This commit is contained in:
parent
10f08f6dca
commit
9824b9216d
@ -36,16 +36,16 @@ import unicodedata
|
|||||||
from os import path
|
from os import path
|
||||||
|
|
||||||
|
|
||||||
repodir = path.abspath(path.join(path.dirname(__file__), '..', '..'))
|
repodir = path.abspath(path.join(path.dirname(__file__), u'..', u'..'))
|
||||||
|
|
||||||
CONFIG = {
|
CONFIG = {
|
||||||
'piddir': os.path.join(repodir, 'pid'),
|
u'piddir': os.path.join(repodir, u'pid'),
|
||||||
'logdir': os.path.join(repodir, 'log'),
|
u'logdir': os.path.join(repodir, u'log'),
|
||||||
'confdir': os.path.join(repodir, 'etc'),
|
u'confdir': os.path.join(repodir, u'etc'),
|
||||||
} if os.path.exists(os.path.join(repodir, '.git')) else {
|
} if os.path.exists(os.path.join(repodir, u'.git')) else {
|
||||||
'piddir': '/var/run/secop',
|
u'piddir': u'/var/run/secop',
|
||||||
'logdir': '/var/log',
|
u'logdir': u'/var/log',
|
||||||
'confdir': '/etc/secop',
|
u'confdir': u'/etc/secop',
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -180,7 +180,9 @@ class Module(object):
|
|||||||
# (self.name, k, e))
|
# (self.name, k, e))
|
||||||
# note: this will call write_* methods which will
|
# note: this will call write_* methods which will
|
||||||
# write to the hardware, if possible!
|
# write to the hardware, if possible!
|
||||||
|
if k != u'value':
|
||||||
setattr(self, k, v)
|
setattr(self, k, v)
|
||||||
|
cfgdict.pop(k)
|
||||||
|
|
||||||
# Adopt units AFTER applying the cfgdict
|
# Adopt units AFTER applying the cfgdict
|
||||||
for k, v in self.accessibles.items():
|
for k, v in self.accessibles.items():
|
||||||
|
@ -73,6 +73,7 @@ class Dispatcher(object):
|
|||||||
# active (i.e. broadcast-receiving) connections
|
# active (i.e. broadcast-receiving) connections
|
||||||
self._active_connections = set()
|
self._active_connections = set()
|
||||||
# map eventname -> list of subscribed connections
|
# map eventname -> list of subscribed connections
|
||||||
|
# eventname is <modulename> or <modulename>:<parametername>
|
||||||
self._subscriptions = {}
|
self._subscriptions = {}
|
||||||
self._lock = threading.RLock()
|
self._lock = threading.RLock()
|
||||||
|
|
||||||
@ -178,10 +179,9 @@ class Dispatcher(object):
|
|||||||
mod_desc[propname] = prop
|
mod_desc[propname] = prop
|
||||||
result[u'modules'].extend([modulename, mod_desc])
|
result[u'modules'].extend([modulename, mod_desc])
|
||||||
result[u'equipment_id'] = self.equipment_id
|
result[u'equipment_id'] = self.equipment_id
|
||||||
result[u'firmware'] = u'The SECoP playground'
|
result[u'firmware'] = u'FRAPPY - The Python Framework for SECoP'
|
||||||
result[u'version'] = u'2017.07'
|
result[u'version'] = u'2018.09'
|
||||||
result.update(self.nodeopts)
|
result.update(self.nodeopts)
|
||||||
# XXX: what else?
|
|
||||||
return result
|
return result
|
||||||
|
|
||||||
def _execute_command(self, modulename, command, arguments=None):
|
def _execute_command(self, modulename, command, arguments=None):
|
||||||
|
@ -61,7 +61,7 @@ class Server(object):
|
|||||||
name.endswith('.cfg'):
|
name.endswith('.cfg'):
|
||||||
self._cfgfile = name
|
self._cfgfile = name
|
||||||
self._pidfile = os.path.join(cfg[u'piddir'],
|
self._pidfile = os.path.join(cfg[u'piddir'],
|
||||||
name[:-4].replace(os.path.sep, '_') + u'.pid')
|
name[:-4].replace(os.path.sep, u'_') + u'.pid')
|
||||||
name = os.path.basename(name[:-4])
|
name = os.path.basename(name[:-4])
|
||||||
else:
|
else:
|
||||||
self._cfgfile = os.path.join(cfg[u'confdir'], name + u'.cfg')
|
self._cfgfile = os.path.join(cfg[u'confdir'], name + u'.cfg')
|
||||||
|
@ -20,6 +20,13 @@
|
|||||||
# *****************************************************************************
|
# *****************************************************************************
|
||||||
"""testing devices"""
|
"""testing devices"""
|
||||||
|
|
||||||
|
try:
|
||||||
|
# py2
|
||||||
|
unicode
|
||||||
|
except NameError:
|
||||||
|
# py3
|
||||||
|
unicode = str # pylint: disable=redefined-builtin
|
||||||
|
|
||||||
import random
|
import random
|
||||||
|
|
||||||
from secop.modules import Readable, Drivable, Communicator, Parameter
|
from secop.modules import Readable, Drivable, Communicator, Parameter
|
||||||
@ -89,4 +96,4 @@ class Temp(Drivable):
|
|||||||
class Lower(Communicator):
|
class Lower(Communicator):
|
||||||
"""Communicator returning a lowercase version of the request"""
|
"""Communicator returning a lowercase version of the request"""
|
||||||
def do_communicate(self, request):
|
def do_communicate(self, request):
|
||||||
return str(request).lower()
|
return unicode(request).lower()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user