Skip to content

Prevent remote writes from hanging after source death - #25

Open
mkhazraee wants to merge 7 commits into
mainfrom
moein/dead_src_hang
Open

Prevent remote writes from hanging after source death#25
mkhazraee wants to merge 7 commits into
mainfrom
moein/dead_src_hang

Conversation

@mkhazraee

Copy link
Copy Markdown
Collaborator

Summary

Add a control-channel probe when a remote write times out.

  • Fence writes that have not reached NIXL submission.
  • Keep submitted writes quarantined while the source responds.
  • After an unanswered probe timeout, tombstone the source generation and fail the operation.
  • Accept the endpoint again only after it reports a new NIXL agent name.

Testing

  • Remote source and target unit tests
  • Progress and Guard tests
  • Guard failover integration tests

Signed-off-by: Moein <moein@nvidia.com>
Signed-off-by: Moein <moein@nvidia.com>
Retry failed probe sends within the existing grace period and re-probe
unresolved writes when a same-name source returns. Add stall timing to
logs and document the intentional best-effort failure policy.

Signed-off-by: Moein <moein@nvidia.com>
Retain unresolved target writes and their memory registrations during
shutdown. Notify targets after safe source cancellation, and probe
unknown-generation tombstones instead of clearing them.

Signed-off-by: Moein <moein@nvidia.com>
Signed-off-by: Moein <moein@nvidia.com>
Extract probe and cancellation handling; detect late writes.
Track source incarnations through Guard-confirmed death.
Document the best-effort contract and update lifecycle tests.

Signed-off-by: Moein <moein@nvidia.com>
Keep native transfers tracked for cleanup. Report unresolved cancellations
and late writes through an optional handler, logging by default.

Signed-off-by: Moein <moein@nvidia.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant