urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2025-01-04 10:32:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #6341 from uqbar-dao/i/6340/ames-packet-size

Browse Source 
ames: store packet bloq size in subject
This commit is contained in:
Ted Blackman 2023-02-22 09:41:55 -05:00 committed by GitHub
commit 38d2e2987c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -104,6 +104,7 @@
rot=`?`%.n :: routing attempts rot=`?`%.n :: routing attempts
kay=`?`%.n :: is ok/not responding kay=`?`%.n :: is ok/not responding
== ==
=/ packet-size 13
=> =>
~% %ames ..part ~ ~% %ames ..part ~
|% |%
@ -156,7 +157,7 @@
|= [=message-num =message-blob] |= [=message-num =message-blob]
^- (list static-fragment) ^- (list static-fragment)
:: ::
=/ num-fragments=fragment-num (met 13 message-blob) =/ num-fragments=fragment-num (met packet-size message-blob)
=| counter=@ =| counter=@
:: ::
|- ^- (list static-fragment) |- ^- (list static-fragment)
@ -180,7 +181,7 @@
sorted sorted
$(index +(index), sorted [(~(got by fragments) index) sorted]) $(index +(index), sorted [(~(got by fragments) index) sorted])
:: ::
(cue (rep 13 (flop sorted))) (cue (rep packet-size (flop sorted)))
:: +jim: caching +jam :: +jim: caching +jam
:: ::
++ jim |=(n=* ~+((jam n))) ++ jim |=(n=* ~+((jam n)))
@ -439,11 +440,11 @@
:: ::
=? meat.shut-packet =? meat.shut-packet
?& ?=(%& -.meat.shut-packet) ?& ?=(%& -.meat.shut-packet)
(gth (met 13 fragment.p.meat.shut-packet) 1) (gth (met packet-size fragment.p.meat.shut-packet) 1)
== ==
%_ meat.shut-packet %_ meat.shut-packet
fragment.p fragment.p
(cut 13 [[fragment-num 1] fragment]:p.meat.shut-packet) (cut packet-size [[fragment-num 1] fragment]:p.meat.shut-packet)
== ==
:: ::
=/ vec ~[sndr rcvr sndr-life rcvr-life] =/ vec ~[sndr rcvr sndr-life rcvr-life]
@ -2724,7 +2725,7 @@
++ dedup-message ++ dedup-message
|= =message-blob |= =message-blob
^+ message-blob ^+ message-blob
?: (lte (met 13 message-blob) 1) ?: (lte (met packet-size message-blob) 1)
message-blob message-blob
=/ peers-l=(list [=ship =ship-state]) ~(tap by peers.ames-state) =/ peers-l=(list [=ship =ship-state]) ~(tap by peers.ames-state)
|- ^+ message-blob |- ^+ message-blob