atenet: give resume callers independent park budgets - #980
atenet: give resume callers independent park budgets#980Du Bin (dubin555) wants to merge 1 commit into
Conversation
Replace the fixed-budget singleflight with an explicit per-Actor flight whose execution deadline follows the latest caller while each request retains its own wait budget. Wake an accumulated long backoff when fresh demand arrives and document the resulting lifecycle.\n\nFixes agent-substrate#613
|
Thanks for your pull request! It looks like this may be your first contribution to a Google open source project. Before we can look at your pull request, you'll need to sign a Contributor License Agreement (CLA). View this failed invocation of the CLA check for more information. For the most up to date status, view the checks section at the bottom of the pull request. |
|
Aditya Shantanu (@aditya-shantanu) I implemented the per-caller budget behavior described in #613 while preserving a shared per-Actor resume flight. Late joiners now keep their own wait budget and extend the shared flight deadline; the regression tests cover a late caller outliving the original leader and avoiding an accumulated long backoff. Would you be willing to review this approach? |
Fixes #613
Summary
Testing
Tests pass
Appropriate changes to documentation are included in the PR
go test ./cmd/atenet/internal/router/... -count=1
go test ./cmd/atenet/internal/router/ingress -run LateJoiner -count=100
go test -race ./cmd/atenet/internal/router/ingress -count=1
go vet ./cmd/atenet/internal/router/...
hack/verify/golangci-lint.sh
git diff --check