Skip to content

Commit

Permalink
Merge branch 'xds_watcher_api_change' into xds_watcher_api_change2
Browse files Browse the repository at this point in the history
  • Loading branch information
markdroth committed Dec 27, 2024
2 parents 16a9341 + 1424fc1 commit 4644141
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions src/core/xds/xds_client/xds_client.cc
Original file line number Diff line number Diff line change
Expand Up @@ -547,10 +547,10 @@ void XdsClient::XdsChannel::SetChannelStatusLocked(absl::Status status) {
MaybeFallbackLocked(a.first, a.second)) {
continue;
}
for (const auto& t : a.second.resource_map) { // type
for (const auto& r : t.second) { // resource id
auto& watchers = r.second.HasResource() ? watchers_cached
: watchers_uncached;
for (const auto& t : a.second.resource_map) { // type
for (const auto& r : t.second) { // resource id
auto& watchers =
r.second.HasResource() ? watchers_cached : watchers_uncached;
for (const auto& w : r.second.watchers()) { // watchers
watchers.insert(w);
}
Expand Down Expand Up @@ -1032,9 +1032,9 @@ void XdsClient::XdsChannel::AdsCall::ParseResource(
// If we previously had connectivity problems, notify watchers that
// the ambient error has been cleared.
if (!xds_channel()->status().ok()) {
xds_client()->NotifyWatchersOnAmbientError(
absl::OkStatus(), resource_state.watchers(),
context->read_delay_handle);
xds_client()->NotifyWatchersOnAmbientError(absl::OkStatus(),
resource_state.watchers(),
context->read_delay_handle);
}
return;
}
Expand Down

0 comments on commit 4644141

Please sign in to comment.