mirror of
https://github.com/ilyakooo0/urbit.git
synced 2024-09-17 13:37:20 +03:00
Merge pull request #6783 from urbit/pkova/dear
lull, ames: add %dear task to receive lane from unix
This commit is contained in:
commit
e355b5090e
@ -764,6 +764,7 @@
|
|||||||
:: Messaging Tasks
|
:: Messaging Tasks
|
||||||
::
|
::
|
||||||
:: %hear: packet from unix
|
:: %hear: packet from unix
|
||||||
|
:: %dear: lane from unix
|
||||||
:: %heed: track peer's responsiveness; gives %clog if slow
|
:: %heed: track peer's responsiveness; gives %clog if slow
|
||||||
:: %jilt: stop tracking peer's responsiveness
|
:: %jilt: stop tracking peer's responsiveness
|
||||||
:: %cork: request to delete message flow
|
:: %cork: request to delete message flow
|
||||||
@ -794,6 +795,7 @@
|
|||||||
+$ task
|
+$ task
|
||||||
$+ ames-task
|
$+ ames-task
|
||||||
$% [%hear =lane =blob]
|
$% [%hear =lane =blob]
|
||||||
|
[%dear =ship =lane]
|
||||||
[%heed =ship]
|
[%heed =ship]
|
||||||
[%jilt =ship]
|
[%jilt =ship]
|
||||||
[%cork =ship]
|
[%cork =ship]
|
||||||
|
@ -2119,6 +2119,27 @@
|
|||||||
%^ enqueue-alien-todo ship ship-state
|
%^ enqueue-alien-todo ship ship-state
|
||||||
|= todos=alien-agenda
|
|= todos=alien-agenda
|
||||||
todos(heeds (~(del in heeds.todos) duct))
|
todos(heeds (~(del in heeds.todos) duct))
|
||||||
|
:: +on-dear: handle lane from unix
|
||||||
|
::
|
||||||
|
++ on-dear
|
||||||
|
|= [=ship =lane]
|
||||||
|
^+ event-core
|
||||||
|
?: ?=(%.y -.lane)
|
||||||
|
event-core
|
||||||
|
=/ ip=@if (end [0 32] p.lane)
|
||||||
|
=/ pt=@ud (cut 0 [32 16] p.lane)
|
||||||
|
?: =(%czar (clan:title ship))
|
||||||
|
%- %^ ev-trace odd.veb ship
|
||||||
|
|.("ignoring %dear lane {(scow %if ip)}:{(scow %ud pt)} for galaxy")
|
||||||
|
event-core
|
||||||
|
=/ peer-state=(unit peer-state) (get-peer-state ship)
|
||||||
|
?~ peer-state
|
||||||
|
%- %^ ev-trace odd.veb ship
|
||||||
|
|.("no peer-state for ship, ignoring %dear")
|
||||||
|
event-core
|
||||||
|
%- %^ ev-trace rcv.veb ship
|
||||||
|
|.("incoming %dear lane {(scow %if ip)}:{(scow %ud pt)}")
|
||||||
|
abet:(on-dear:(abed-peer:pe ship u.peer-state) lane)
|
||||||
:: +on-hear: handle raw packet receipt
|
:: +on-hear: handle raw packet receipt
|
||||||
::
|
::
|
||||||
++ on-hear
|
++ on-hear
|
||||||
@ -3312,6 +3333,11 @@
|
|||||||
=. keens (~(put by keens) path *keen-state)
|
=. keens (~(put by keens) path *keen-state)
|
||||||
fi-abet:(fi-start:(abed:fi path) duct)
|
fi-abet:(fi-start:(abed:fi path) duct)
|
||||||
::
|
::
|
||||||
|
++ on-dear
|
||||||
|
|= =lane
|
||||||
|
^+ peer-core
|
||||||
|
peer-core(route.peer-state `[%.y lane])
|
||||||
|
::
|
||||||
++ on-tame
|
++ on-tame
|
||||||
^+ peer-core
|
^+ peer-core
|
||||||
peer-core(route.peer-state ~)
|
peer-core(route.peer-state ~)
|
||||||
@ -4973,6 +4999,7 @@
|
|||||||
?- -.task
|
?- -.task
|
||||||
%born on-born:event-core
|
%born on-born:event-core
|
||||||
%hear (on-hear:event-core [lane blob ~]:task)
|
%hear (on-hear:event-core [lane blob ~]:task)
|
||||||
|
%dear (on-dear:event-core +.task)
|
||||||
%heed (on-heed:event-core ship.task)
|
%heed (on-heed:event-core ship.task)
|
||||||
%init on-init:event-core
|
%init on-init:event-core
|
||||||
%jilt (on-jilt:event-core ship.task)
|
%jilt (on-jilt:event-core ship.task)
|
||||||
|
Loading…
Reference in New Issue
Block a user