fix(native): bound JD receive waits and persist progress

This commit is contained in:
冰朔 2026-08-06 23:31:27 +08:00
commit 97f862052f
6 changed files with 36 additions and 1 deletions

View file

@ -201,6 +201,11 @@ def main() -> None:
peer.sendto(reply, address)
if repetition + 1 < args.native_ack_repetitions:
time.sleep(args.native_ack_interval)
print(
f"native_ack sequence={sequence} source={source} "
f"repetitions={args.native_ack_repetitions}",
flush=True,
)
acknowledged.add(sequence)
sources.add(source)
if len(acknowledged) == len(pipeline) and completed_at is None:

View file

@ -87,6 +87,7 @@ with pathlib.Path(sys.argv[1]).open("rb") as disk:
assert proof[42:44] == bytes([0x7F, 0])
assert proof[90] == 13
assert proof[93:105] == bytes([1] * 12)
assert proof[105] == 16
assert sector(135).startswith(b"GHOS_HLDP_WORLD_STORE_V1\n")
assert sector(136).startswith(b"GHOS_CODE_CHANNEL_STORE_V1\n")
assert sector(137) == sector(136)

View file

@ -44,6 +44,7 @@ assert proof[88:90] == bytes([1, 1])
assert proof[90] == 13
assert proof[91:99] == bytes([1, 1, 1, 1, 1, 1, 1, 1])
assert proof[99:105] == bytes([1, 1, 1, 1, 1, 1])
assert proof[105] == 16
world = (root / "lba135-138.native-world.bin").read_bytes()
assert world[:512].startswith(b"GHOS_HLDP_WORLD_STORE_V1\n")