ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-09-21 23:47:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

ames: printfs

Browse Source
This commit is contained in:
Philip Monk 2019-11-27 16:43:09 -08:00
parent fc74ab2dbd
commit fdb1069b33
No known key found for this signature in database
GPG Key ID: B66E1F02604E44EC
1 changed files with 30 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
pkg/arvo/sys/vane/ames.hoon
View File

@ -66,6 +66,7 @@
rcv=%.y
odd=%.y
msg=%.y
ges=%.y
==
|%
++ trace
@ -1652,6 +1653,7 @@
=/ pumps=(list message-pump-state)
%+ murn ~(tap by snd.peer-state)
|= [=bone =message-pump-state]
~& >>> pump-bone=bone
?: =(0 (end 0 1 bone))
~
`u=message-pump-state
@ -1661,7 +1663,9 @@
=| acc=@ud
|- ^- ?
?~ pumps
~& >>> %clog-nah
%.n
~& [acc=acc next.i.pumps current.i.pumps ~(wyt in unsent-messages.i.pumps)]
=. acc
%+ add acc
%+ add
@ -1673,12 +1677,15 @@
~(wyt in unsent-messages.i.pumps)
::
?: (gte acc 5)
~& >>> %clog-yah
%.y
$(pumps t.pumps)
:: if clogged, notify client vanek
::
?. clogged
~& >>> %clog-free
peer-core
~& >>> [%since-ninety-three heeds.peer-state]
%+ roll ~(tap in heeds.peer-state)
|=([d=^duct core=_peer-core] (emit:core d %give %clog her.channel))
:: +on-hear-shut-packet: handle receipt of ack or message fragment
@ -1707,7 +1714,9 @@
=. peer-core (run-message-pump bone %memo message-blob)
::
?: &(=(%boon valence) ?=(?(%dead %unborn) -.qos.peer-state))
~& >>> %mebbe-clog
check-clog
~& >>> %no-check-clog
peer-core
:: +on-wake: handle timer expiration
::
@ -1897,13 +1906,16 @@
(~(gut by rcv.peer-state) bone *message-sink-state)
::
=/ message-sink (make-message-sink message-sink-state channel)
~& >> [%starting-work task]
=^ sink-gifts message-sink-state (work:message-sink task)
~& >> [%finishing-work task]
=. rcv.peer-state (~(put by rcv.peer-state) bone message-sink-state)
:: process effects from |message-sink
::
|^ ^+ peer-core
?~ sink-gifts peer-core
?~ sink-gifts ~& >> %no-sink-gifts peer-core
=* gift i.sink-gifts
~& >> [%sink-gift gift]
=. peer-core
?- -.gift
%memo (on-sink-memo [message-num message]:gift)
@ -1930,6 +1942,7 @@
:: even bone, 1 second bit: nack-trace %boon message
::
++ on-sink-memo
~& > [%sink-memo bone=bone]
?: =(1 (end 0 1 bone))
on-sink-plea
?: =(0 (end 0 1 (rsh 0 1 bone)))
@ -2159,10 +2172,12 @@
:: if nothing to send, no-op
::
?: &(=(~ unsent-messages) =(~ unsent-fragments)):state
~& > %feed-none
message-pump
:: we have unsent fragments of the current message; feed them
::
?. =(~ unsent-fragments.state)
~& > %feed-unsent
=/ res (feed:packet-pump unsent-fragments.state)
=+ [unsent packet-pump-gifts packet-pump-state]=res
::
@ -2175,6 +2190,7 @@
?~ unsent
feed-packets
message-pump
~& > %feed-no-unsent
:: .unsent-messages is nonempty; pop a message off and feed it
::
=^ =message-blob unsent-messages.state ~(get to unsent-messages.state)
@ -2289,6 +2305,7 @@
=/ num-slots num-slots:gauge
=/ sent (scag num-slots fragments)
=/ unsent (slag num-slots fragments)
~& > [%feeding num-slots=num-slots sent=sent unsent=unsent lent=(lent fragments)]
::
:- unsent
^+ packet-pump
@ -2453,13 +2470,16 @@
:: very likely to happen, so it's more important we stay correct.
::
?: (lth message-num.key message-num)
~& > [%ooo message-num.key message-num]
[new-val=`val stop=%.y metrics]
:: if packet was from acked message, delete it and continue
::
?: =(message-num.key message-num)
~& > [%acked message-num.key message-num]
[new-val=~ stop=%.n metrics=(on-ack:gauge -.val)]
:: we've gone past the acked message; we're done
::
~& > [%past message-num.key message-num]
[new-val=`val stop=%.y metrics]
:: +set-wake: set, unset, or reset timer, emitting moves
::
@ -2552,6 +2572,8 @@
(sub rtt rtt-datum)
:: exponential weighting ratio for .rtt and .rttvar
::
%- %+ trace ges.veb
|.("ack update {<show rtt-datum=rtt-datum rtt-error=rtt-error>}")
=. rtt (div (add rtt-datum (mul rtt 7)) 8)
=. rttvar (div (add rtt-error (mul rttvar 7)) 8)
=. rto (clamp-rto (add rtt (mul 4 rttvar)))
@ -2575,6 +2597,8 @@
++ on-timeout
^- pump-metrics
::
%- %+ trace ges.veb
|.("timeout update {<show>}")
=: ssthresh (max 1 (div cwnd 2))
cwnd 1
rto (clamp-rto (mul rto 2))
@ -2679,7 +2703,7 @@
?: is-last-fragment
:: drop last packet since we don't know whether to ack or nack
::
%- (trace rcv.veb |.("hear last in-progress {<her.channel^seq>}"))
%- (trace rcv.veb |.("hear last in-progress {<her.channel^seq^fragment-num^num-fragments^la=last-acked.state^lh=last-heard.state>}"))
message-sink
:: ack all other packets
::
@ -2742,6 +2766,7 @@
:: we have whole message; update state, assemble, and send to vane
::
=. last-heard.state +(last-heard.state)
~& > [%incremented-last-heard last-heard.state last-acked.state]
=. live-messages.state (~(del by live-messages.state) seq)
::
%- (trace msg.veb |.("hear {<her.channel>} {<seq>} {<num-fragments.u.live>}kb"))
@ -2756,8 +2781,10 @@
^+ message-sink
::
=/ empty=? =(~ pending-vane-ack.state)
~? !empty already-pending=pending-vane-ack.state
=. pending-vane-ack.state (~(put to pending-vane-ack.state) seq message)
?. empty
~& > [%not-empty pending=pending-vane-ack.state]
message-sink
(give %memo seq message)
:: +on-done: handle confirmation of message processing from vane
@ -2770,6 +2797,7 @@
=/ =message-num message-num.p.pending
::
=. last-acked.state +(last-acked.state)
~& > [%incremented-last-acked last-heard.state last-acked.state]
=? nax.state !ok (~(put in nax.state) message-num)
::
=. message-sink (give %send message-num %| ok lag=`@dr`0)