-
Notifications
You must be signed in to change notification settings - Fork 4k
xds: gRFC A88 - Changes to XdsClient Watcher APIs #12446
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
kannanjgithub
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Sending what I could review today.
kannanjgithub
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Review comments.
|
Note: The failing test log shown here in github Actions is not failing in local even after clean run/build. |
|
Why is it incorrect? A88 does not say it is modifying the A57 ADS stream
error handling behavior after a response is received, A88 only mentions
cases where no response was received on the ADS stream and the stream was
terminated.
…On Mon, Nov 24, 2025 at 11:44 AM MV Shiva ***@***.***> wrote:
***@***.**** commented on this pull request.
------------------------------
In xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java
<#12446 (comment)>:
> @@ -453,44 +453,29 @@ private void handleRpcStreamClosed(Status status) {
stopwatch.reset();
}
- Status newStatus = status;
- if (responseReceived) {
The previous logic would incorrectly treat any stream error as Status.OK
if a response had already been received. This would have prevented us from
ever calling the new onAmbientError callback for these transient failures.
This new implementation ensures that all stream failures are correctly
propagated, which then allows XdsClientImpl to decide whether to call
onResourceChanged or onAmbientError as defined in gRFC A88.
—
Reply to this email directly, view it on GitHub
<#12446 (comment)>, or
unsubscribe
<https://github.com/notifications/unsubscribe-auth/AHB2YHA3EQ6BWCHDQ3P2LMT36KO4VAVCNFSM6AAAAACKKR4ZPSVHI2DSMVQWIX3LMV43YUDVNRWFEZLROVSXG5CSMV3GSZLXHMZTIOJYGQ3DGNJUGE>
.
You are receiving this because your review was requested.Message ID:
***@***.***>
|
|
The purpose of gRFC A88 is to introduce onAmbientError to notify watchers of transient errors without them having to drop their cached data. If the underlying ControlPlaneClient hides the error and reports Status.OK, then XdsClientImpl would never know a transient failure occurred and would therefore never be able to call onAmbientError on the watchers. This would completely break this new mechanism. |
|
Note: I added a TODO in |
This above code block was the initial fix for the failing fallback test that was mentioned above. The solution is to restructure the logic in the
|
Implements https://github.com/grpc/proposal/blob/master/A88-xds-data-error-handling.md#a88-xds-data-error-handling