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

ames: fix another comet bug

Browse Source
This commit is contained in:
Ted Blackman 2019-11-26 23:52:43 -05:00
parent f91a1f4873
commit 7fdb940b5c
2 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bin/solid.pill
View File

@ -1,3 +1,3 @@
version https://git-lfs.github.com/spec/v1 version https://git-lfs.github.com/spec/v1
oid sha256:3dea0bc261bf9b42cb7f6d8cbe325776968511ca2bbaf0168992e8234b525db1 oid sha256:7fdeedf0449041a6ca8fa8ee0204f6e86a3b37eb80585fa81d2d1e2c9c1bc6f0
size 10476754 size 10486202

28
pkg/arvo/sys/vane/alef.hoon
View File

@ -1091,14 +1091,12 @@
?> .= rcvr.open-packet our ?> .= rcvr.open-packet our
?> .= sndr-life.open-packet 1 ?> .= sndr-life.open-packet 1
?> .= rcvr-life.open-packet life.ames-state ?> .= rcvr-life.open-packet life.ames-state
:: no ghost comets allowed :: only a star can sponsor a comet
:: ::
?> (lte 256 (^sein:title sndr.packet)) ?> =(%king (clan:title (^sein:title sndr.packet)))
:: comet public-key must hash to its @p address :: comet public-key must hash to its @p address
:: ::
:: TODO how does this validation work elsewhere? ?> =(sndr.packet fig:ex:(com:nu:crub:crypto public-key.open-packet))
::
?> =(`@`sndr.packet `@`(shaf %pawn public-key.open-packet))
:: everything after .signature is signed :: everything after .signature is signed
:: ::
:: TODO: should this double-cue instead of re-jamming? :: TODO: should this double-cue instead of re-jamming?
@ -1178,7 +1176,7 @@
=/ =peer-state (got-peer-state her) =/ =peer-state (got-peer-state her)
=/ =channel [[our her] now |2.ames-state -.peer-state] =/ =channel [[our her] now |2.ames-state -.peer-state]
:: ::
abet:(on-memo:(make-peer-core peer-state channel) bone payload) abet:(on-memo:(make-peer-core peer-state channel) bone payload %boon)
:: +on-plea: handle request to send message :: +on-plea: handle request to send message
:: ::
++ on-plea ++ on-plea
@ -1203,7 +1201,7 @@
=/ rcvr [ship her-life.channel] =/ rcvr [ship her-life.channel]
"plea {<sndr^rcvr^bone^vane.plea^path.plea>}" "plea {<sndr^rcvr^bone^vane.plea^path.plea>}"
:: ::
abet:(on-memo:(make-peer-core peer-state channel) bone plea) abet:(on-memo:(make-peer-core peer-state channel) bone plea %plea)
:: +on-take-wake: receive wakeup or error notification from behn :: +on-take-wake: receive wakeup or error notification from behn
:: ::
++ on-take-wake ++ on-take-wake
@ -1635,11 +1633,15 @@
:: print message :: print message
:: ::
=. peer-core (emit duct %pass /qos %d %flog %text u.text) =. peer-core (emit duct %pass /qos %d %flog %text u.text)
:: if peer is ok, we're done :: if peer has stopped responding, check if %boon's are backing up
:: ::
?. ?=(?(%dead %unborn) -.qos.peer-state) ?. ?=(?(%dead %unborn) -.qos.peer-state)
peer-core peer-core
:: peer has stopped responding; check if our responses are backing up check-clog
:: +check-clog: notify clients if peer has stopped responding
::
++ check-clog
^+ peer-core
:: ::
:: Only look at response bones. Request bones are unregulated, :: Only look at response bones. Request bones are unregulated,
:: since requests tend to be much smaller than responses. :: since requests tend to be much smaller than responses.
@ -1686,11 +1688,15 @@
:: +on-memo: handle request to send message :: +on-memo: handle request to send message
:: ::
++ on-memo ++ on-memo
|= [=bone payload=*] |= [=bone payload=* valence=?(%plea %boon)]
^+ peer-core ^+ peer-core
:: ::
=/ =message-blob (jam payload) =/ =message-blob (jam payload)
(run-message-pump bone %memo message-blob) =. peer-core (run-message-pump bone %memo message-blob)
::
?: &(=(%boon valence) ?=(?(%dead %unborn) -.qos.peer-state))
check-clog
peer-core
:: +on-wake: handle timer expiration :: +on-wake: handle timer expiration
:: ::
++ on-wake ++ on-wake