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

minor message-pump cleanup

Browse Source
This commit is contained in:
Ted Blackman 2019-06-18 16:33:53 -07:00
parent 61ff792ccf
commit 8c3b45aa16
1 changed files with 19 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
sys/vane/alef.hoon
View File

@ -1270,31 +1270,35 @@
|%
++ message-pump .
++ give |=(gift=message-pump-gift message-pump(gifts [gift gifts]))
++ packet-pump
(make-packet-pump packet-pump-state.state channel)
++ packet-pump (make-packet-pump packet-pump-state.state channel)
:: +work: handle a $message-pump-task
::
++ work
|= task=message-pump-task
^+ [gifts state]
::
=~ ?- -.task
%hear-ack
?- -.ack-meat.task
%&
(on-hear-fragment-ack [message-num fragment-num=p.ack-meat]:task)
::
%|
(on-hear-message-ack [message-num [ok lag]:p.ack-meat]:task)
==
::
%send (on-send message.task)
%wake (run-packet-pump task)
==
=~ (dispatch-task task)
feed-packets
(run-packet-pump %finalize ~)
[(flop gifts) state]
==
:: +dispatch-task: perform task-specific processing
::
++ dispatch-task
|= task=message-pump-task
^+ message-pump
::
?- -.task
%send (on-send message.task)
%wake (run-packet-pump task)
%hear-ack
?- -.ack-meat.task
%& %- on-hear-fragment-ack
[message-num fragment-num=p.ack-meat]:task
::
%| %- on-hear-message-ack
[message-num [ok lag]:p.ack-meat]:task
== ==
:: +on-send: handle request to send a message
::
++ on-send