pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Use new profiler arg name, add more marks throughout flow update

pre_flow
Tyler Goodlet 2022-05-13 16:16:17 -04:00
parent 60ef3ba258
commit a8fa034b61
1 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
piker/ui/_flows.py
View File

@ -46,7 +46,10 @@ from ..data._sharedmem import (
ShmArray, ShmArray,
# open_shm_array, # open_shm_array,
) )
from .._profile import pg_profile_enabled, ms_slower_then from .._profile import (
pg_profile_enabled,
ms_slower_then,
)
from ._ohlc import ( from ._ohlc import (
BarItems, BarItems,
gen_qpath, gen_qpath,
@ -331,11 +334,13 @@ class Flow(msgspec.Struct): # , frozen=True):
''' '''
profiler = profiler or pg.debug.Profiler( # profiler = profiler or pg.debug.Profiler(
profiler = pg.debug.Profiler(
msg=f'Flow.update_graphics() for {self.name}', msg=f'Flow.update_graphics() for {self.name}',
disabled=not pg_profile_enabled(), disabled=not pg_profile_enabled(),
gt=ms_slower_then, # disabled=False,
delayed=True, ms_threshold=4,
# ms_threshold=ms_slower_then,
) )
# shm read and slice to view # shm read and slice to view
read = ( read = (
@ -591,6 +596,7 @@ class Flow(msgspec.Struct): # , frozen=True):
# ``FastAppendCurve`` case: # ``FastAppendCurve`` case:
array_key = array_key or self.name array_key = array_key or self.name
uppx = graphics.x_uppx() uppx = graphics.x_uppx()
profiler('read uppx')
if graphics._step_mode and self.gy is None: if graphics._step_mode and self.gy is None:
self._iflat_first = self.shm._first.value self._iflat_first = self.shm._first.value
@ -616,6 +622,7 @@ class Flow(msgspec.Struct): # , frozen=True):
# start y at origin level # start y at origin level
self.gy[0, 0] = 0 self.gy[0, 0] = 0
profiler('generated step mode data')
if graphics._step_mode: if graphics._step_mode:
( (
@ -631,6 +638,7 @@ class Flow(msgspec.Struct): # , frozen=True):
) )
il = max(iflat - 1, 0) il = max(iflat - 1, 0)
profiler('read step mode incr update indices')
# check for shm prepend updates since last read. # check for shm prepend updates since last read.
if iflat_first != ishm_first: if iflat_first != ishm_first:
@ -650,6 +658,7 @@ class Flow(msgspec.Struct): # , frozen=True):
# write newly prepended data to flattened copy # write newly prepended data to flattened copy
self.gy[ishm_first:iflat_first] = y2_prepend self.gy[ishm_first:iflat_first] = y2_prepend
self._iflat_first = ishm_first self._iflat_first = ishm_first
profiler('prepended step mode history')
append_diff = ishm_last - iflat append_diff = ishm_last - iflat
if append_diff: if append_diff:
@ -679,6 +688,7 @@ class Flow(msgspec.Struct): # , frozen=True):
x_step = self.gx[ishm_first:ishm_last+2] x_step = self.gx[ishm_first:ishm_last+2]
# shape to 1d # shape to 1d
x = x_step.reshape(-1) x = x_step.reshape(-1)
profiler('sliced step x')
y_step = self.gy[ishm_first:ishm_last+2] y_step = self.gy[ishm_first:ishm_last+2]
lasts = self.shm.array[['index', array_key]] lasts = self.shm.array[['index', array_key]]
@ -690,7 +700,7 @@ class Flow(msgspec.Struct): # , frozen=True):
# s = 6 # s = 6
# print(f'lasts: {x[-2*s:]}, {y[-2*s:]}') # print(f'lasts: {x[-2*s:]}, {y[-2*s:]}')
profiler('sliced step data') profiler('sliced step y')
# do all the same for only in-view data # do all the same for only in-view data
ys_iv = y_step[ivl:ivr+1] ys_iv = y_step[ivl:ivr+1]
@ -703,7 +713,7 @@ class Flow(msgspec.Struct): # , frozen=True):
# f'xs_iv: {xs_iv[-s:]}\n' # f'xs_iv: {xs_iv[-s:]}\n'
# f'x_iv: {x_iv[-s:]}\n' # f'x_iv: {x_iv[-s:]}\n'
# ) # )
profiler('flattened ustruct in-view OHLC data') profiler('sliced in view step data')
# legacy full-recompute-everytime method # legacy full-recompute-everytime method
# x, y = ohlc_flatten(array) # x, y = ohlc_flatten(array)
@ -738,9 +748,11 @@ class Flow(msgspec.Struct): # , frozen=True):
# NOTE: already passed through by display loop? # NOTE: already passed through by display loop?
# do_append=uppx < 16, # do_append=uppx < 16,
profiler=profiler,
**kwargs **kwargs
) )
profiler('updated step mode curve')
# graphics.reset_cache() # graphics.reset_cache()
# print( # print(
# f"path br: {graphics.path.boundingRect()}\n", # f"path br: {graphics.path.boundingRect()}\n",
@ -754,9 +766,9 @@ class Flow(msgspec.Struct): # , frozen=True):
y = array[array_key] y = array[array_key]
x_iv = in_view['index'] x_iv = in_view['index']
y_iv = in_view[array_key] y_iv = in_view[array_key]
profiler('sliced input arrays')
# graphics.draw_last(x, y) # graphics.draw_last(x, y)
profiler(f'draw last segment {array_key}')
graphics.update_from_array( graphics.update_from_array(
x=x, x=x,
@ -769,8 +781,10 @@ class Flow(msgspec.Struct): # , frozen=True):
# NOTE: already passed through by display loop? # NOTE: already passed through by display loop?
# do_append=uppx < 16, # do_append=uppx < 16,
profiler=profiler,
**kwargs **kwargs
) )
profiler(f'`graphics.update_from_array()` complete')
return graphics return graphics