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

Limit l1 graphics updates to half the refresh rate

web_utils
Tyler Goodlet 2021-05-27 17:20:26 -04:00
parent d0e3f5a51c
commit 1a7b06c147
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
piker/ui/_chart.py
View File

@ -192,7 +192,6 @@ class ChartSpace(QtGui.QWidget):
loglevel, loglevel,
) )
self.set_chart_symbol(fqsn, linkedcharts) self.set_chart_symbol(fqsn, linkedcharts)
self.vbox.addWidget(linkedcharts) self.vbox.addWidget(linkedcharts)
@ -1079,13 +1078,8 @@ async def chart_from_quotes(
last = time.time() last = time.time()
async for quotes in stream: async for quotes in stream:
now = time.time() now = time.time()
period = now - last period = now - last
if period <= 1/_quote_throttle_rate - 0.001:
# faster then display refresh rate
# print(f'quote too fast: {1/period}')
continue
for sym, quote in quotes.items(): for sym, quote in quotes.items():
for tick in quote.get('ticks', ()): for tick in quote.get('ticks', ()):
@ -1101,6 +1095,12 @@ async def chart_from_quotes(
if ticktype in ('trade', 'utrade', 'last'): if ticktype in ('trade', 'utrade', 'last'):
# throttle clearing price updates to ~ 60 FPS
if period <= 1/_quote_throttle_rate - 0.001:
# faster then display refresh rate
# print(f'quote too fast: {1/period}')
continue
array = ohlcv.array array = ohlcv.array
# update price sticky(s) # update price sticky(s)
@ -1121,6 +1121,19 @@ async def chart_from_quotes(
chart.update_curve_from_array( chart.update_curve_from_array(
'bar_wap', ohlcv.array) 'bar_wap', ohlcv.array)
else: # non-clearing tick
now = time.time()
period = now - last
# throttle the book graphics updates at a lower rate
# since they aren't as critical for a manual user
# viewing the chart
if period <= 1/_quote_throttle_rate/2:
# print(f'skipping\n{tick}')
continue
# compute max and min trade values to display in view # compute max and min trade values to display in view
# TODO: we need a streaming minmax algorithm here, see # TODO: we need a streaming minmax algorithm here, see
# def above. # def above.
@ -1133,6 +1146,7 @@ async def chart_from_quotes(
# XXX: prettty sure this is correct? # XXX: prettty sure this is correct?
# if ticktype in ('trade', 'last'): # if ticktype in ('trade', 'last'):
if ticktype in ('last',): # 'size'): if ticktype in ('last',): # 'size'):
label = { label = {
l1.ask_label.fields['level']: l1.ask_label, l1.ask_label.fields['level']: l1.ask_label,
l1.bid_label.fields['level']: l1.bid_label, l1.bid_label.fields['level']: l1.bid_label,