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

ames: print bone if "hear last in-progress"

Browse Source
This commit is contained in:
yosoyubik 2022-06-30 17:12:07 +02:00
parent cb5893ac05
commit a967b42c30
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2576,7 +2576,7 @@
(~(gut by rcv.peer-state) bone *message-sink-state)
::
=/ message-sink (make-message-sink message-sink-state channel)
=^ sink-gifts message-sink-state (work:message-sink task)
=^ sink-gifts message-sink-state (work:message-sink bone task)
=. rcv.peer-state (~(put by rcv.peer-state) bone message-sink-state)
:: process effects from |message-sink
::
@ -3467,7 +3467,7 @@
:: +work: handle a $message-sink-task
::
++ work
|= task=message-sink-task
|= [=bone task=message-sink-task]
^+ [gifts state]
::
=- [(flop gifts) state]
@ -3475,12 +3475,12 @@
?- -.task
%done (on-done ok.task cork.task)
%drop (on-drop message-num.task)
%hear (on-hear [lane shut-packet ok]:task)
%hear (on-hear bone [lane shut-packet ok]:task)
==
:: +on-hear: receive message fragment, possibly completing message
::
++ on-hear
|= [=lane =shut-packet ok=?]
|= [=bone =lane =shut-packet ok=?]
^+ message-sink
:: we know this is a fragment, not an ack; expose into namespace
::
@ -3523,7 +3523,7 @@
%- %+ trace rcv.veb
|. ^- tape
=/ data
:* her.channel seq=seq
:* her.channel seq=seq bone=bone
fragment-num=fragment-num num-fragments=num-fragments
la=last-acked.state lh=last-heard.state
==