Searched refs:endpoint_state (Results 1 – 2 of 2) sorted by relevance
1056 EndpointState& endpoint_state = in AcceptCdsUpdate() local1058 endpoint_state.update.reset(); in AcceptCdsUpdate()1059 for (const auto& p : endpoint_state.watchers) { in AcceptCdsUpdate()1084 EndpointState& endpoint_state = in AcceptEdsUpdate() local1087 if (endpoint_state.update.has_value() && in AcceptEdsUpdate()1088 *endpoint_state.update == eds_update) { in AcceptEdsUpdate()1097 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdate()1099 for (const auto& p : endpoint_state.watchers) { in AcceptEdsUpdate()1100 p.first->OnEndpointChanged(endpoint_state.update.value()); in AcceptEdsUpdate()1931 EndpointState& endpoint_state = endpoint_map_[eds_service_name_str]; in WatchEndpointData() local[all …]
1051 EndpointState& endpoint_state = in AcceptCdsUpdate() local1053 endpoint_state.update.reset(); in AcceptCdsUpdate()1054 for (const auto& p : endpoint_state.watchers) { in AcceptCdsUpdate()1117 EndpointState& endpoint_state = in AcceptEdsUpdate() local1120 if (endpoint_state.update.has_value()) { in AcceptEdsUpdate()1121 const XdsApi::EdsUpdate& prev_update = endpoint_state.update.value(); in AcceptEdsUpdate()1137 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdate()1139 for (const auto& p : endpoint_state.watchers) { in AcceptEdsUpdate()1140 p.first->OnEndpointChanged(endpoint_state.update.value()); in AcceptEdsUpdate()1878 EndpointState& endpoint_state = endpoint_map_[eds_service_name_str]; in WatchEndpointData() local[all …]