xds: gRFC A88 - Changes to XdsClient Watcher APIs#12446
xds: gRFC A88 - Changes to XdsClient Watcher APIs#12446shivaspeaks merged 29 commits intogrpc:masterfrom
Conversation
kannanjgithub
left a comment
There was a problem hiding this comment.
Sending what I could review today.
|
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