pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

More explicit error on shm push overruns

fsp_drunken_alignment
Tyler Goodlet 2021-09-23 10:08:01 -04:00
parent 92d7ffd332
commit 31f4dbef7d
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
piker/data/_sharedmem.py
View File

@ -31,7 +31,7 @@ import tractor
import numpy as np import numpy as np
from ..log import get_logger from ..log import get_logger
from ._source import base_ohlc_dtype, base_iohlc_dtype from ._source import base_iohlc_dtype
log = get_logger(__name__) log = get_logger(__name__)
@ -221,6 +221,11 @@ class ShmArray:
if prepend: if prepend:
index = self._first.value - length index = self._first.value - length
if index < 0:
raise ValueError(
f'Array size of {self._len} was overrun during prepend.\n'
'You have passed {abs(index)} too many datums.'
)
else: else:
index = self._last.value index = self._last.value
@ -290,8 +295,10 @@ class ShmArray:
# how much is probably dependent on lifestyle # how much is probably dependent on lifestyle
_secs_in_day = int(60 * 60 * 12) _secs_in_day = int(60 * 60 * 24)
_default_size = 2 * _secs_in_day # we try for 3 times but only on a run-every-other-day kinda week.
_default_size = 3 * _secs_in_day
def open_shm_array( def open_shm_array(
key: Optional[str] = None, key: Optional[str] = None,