DanConwayDev 6b373e9ecd fix(sync): stop self-subscriber when its consumer exits ...

Server shutdown aborts the SyncManager action receiver while its detached self-subscriber may still be sending a batch. The subscriber previously logged one channel-closed error per remaining relay and could ignore shutdown while blocked by channel backpressure.

Monitor receiver closure and shutdown around the entire subscriber lifecycle, including startup reconstruction and batch sends. Stop the batch on the first permanent send failure, including races with cancellation. Pending discovery can be reconstructed from persisted events on startup; this does not redesign ownership of other sync workers.

Validation: all 13 self-subscriber tests pass, including bounded regressions for consumer closure and shutdown during a backpressured startup batch. cargo clippy --lib --tests -- -D warnings, formatting and git diff --check pass. Shutdown behavior is documented.

Assisted-by: GPT-6

2026-10-02 13:27:00 +00:00

..

git

fix(sync): budget outbound Git commands and speculative fetches

2026-10-02 09:38:38 +00:00

grasp06

fix(grasp06): reclaim staging metadata before removing empty views

2026-09-30 13:29:03 +00:00

http

fix(metrics): isolate scrape rendering from async workers

2026-09-14 10:05:48 +00:00

metrics

fix(sync): budget outbound Git commands and speculative fetches

2026-10-02 09:38:38 +00:00

nostr

fix(git): promote staged history before State acceptance

2026-09-29 11:19:31 +00:00

private

feat(http): support path-mounted GRASP services

2026-08-18 11:36:24 +00:00

purgatory

fix(sync): budget outbound Git commands and speculative fetches

2026-10-02 09:38:38 +00:00

sync

fix(sync): stop self-subscriber when its consumer exits

2026-10-02 13:27:00 +00:00

atomic_file.rs

fix(sync): checkpoint recovery state crash-safely

2026-08-08 12:10:16 +00:00

audit_cleanup.rs

refactor(nostr): move deletion orchestration into deletion subsystem

2026-06-19 13:58:23 +00:00

checkpoint.rs

fix(storage): isolate periodic checkpoints from async workers

2026-09-14 10:05:48 +00:00

cleanup_empty_repos.rs

fix(grasp06): exclude /prs/ subtree from cleanup-empty-repos orphan scan

2026-05-15 18:06:11 +00:00

config.rs

feat(security): support scoped integrity validation

2026-08-20 07:57:57 +00:00

docs_export.rs

feat(cli): export deterministic documentation schema

2026-08-28 15:28:21 +00:00

lib.rs

fix(storage): isolate periodic checkpoints from async workers

2026-09-14 10:05:48 +00:00

logging.rs

fix(logging): omit raw relay payloads from SDK diagnostics

2026-09-24 10:56:44 +00:00

main.rs

fix(logging): omit raw relay payloads from SDK diagnostics

2026-09-24 10:56:44 +00:00

outbound.rs

feat(http): support path-mounted GRASP services

2026-08-18 11:36:24 +00:00

server.rs

fix(sync): budget outbound Git commands and speculative fetches

2026-10-02 09:38:38 +00:00

test_listener.rs

fix(test-listener): inspect listening TCP sockets on Darwin

2026-09-19 20:06:37 +00:00