pikers
/
piker
3
0
Fork 0
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Assign unique shm keys for duplicate fsps to avoid array clobbering

fsp_feeds
Tyler Goodlet 2021-09-05 13:20:50 -04:00
parent 709288d034
commit 35fe26cb95
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
piker/ui/_chart.py
View File

@ -351,7 +351,7 @@ class LinkedSplits(QWidget):
# self.xaxis.hide() # self.xaxis.hide()
self.splitter = QtWidgets.QSplitter(QtCore.Qt.Vertical) self.splitter = QtWidgets.QSplitter(QtCore.Qt.Vertical)
self.splitter.setMidLineWidth(2) self.splitter.setMidLineWidth(1)
self.splitter.setHandleWidth(0) self.splitter.setHandleWidth(0)
self.layout = QtWidgets.QVBoxLayout(self) self.layout = QtWidgets.QVBoxLayout(self)
@ -1331,6 +1331,8 @@ async def spawn_fsps(
linkedsplits.focus() linkedsplits.focus()
uid = tractor.current_actor().uid
# spawns sub-processes which execute cpu bound FSP code # spawns sub-processes which execute cpu bound FSP code
async with tractor.open_nursery(loglevel=loglevel) as n: async with tractor.open_nursery(loglevel=loglevel) as n:
@ -1351,7 +1353,7 @@ async def spawn_fsps(
# TODO: should `index` be a required internal field? # TODO: should `index` be a required internal field?
fsp_dtype = np.dtype([('index', int), (fsp_func_name, float)]) fsp_dtype = np.dtype([('index', int), (fsp_func_name, float)])
key = f'{sym}.fsp.' + display_name key = f'{sym}.fsp.{display_name}.{".".join(uid)}'
# this is all sync currently # this is all sync currently
shm, opened = maybe_open_shm_array( shm, opened = maybe_open_shm_array(
@ -1361,9 +1363,10 @@ async def spawn_fsps(
readonly=True, readonly=True,
) )
# XXX: fsp may have been opened by a duplicate chart. Error for # XXX: fsp may have been opened by a duplicate chart.
# now until we figure out how to wrap fsps as "feeds". # Error for now until we figure out how to wrap fsps as
# assert opened, f"A chart for {key} likely already exists?" # "feeds". assert opened, f"A chart for {key} likely
# already exists?"
conf['shm'] = shm conf['shm'] = shm