Lines Matching refs:endpoint_state
1263 EndpointState& endpoint_state = xds_client() in AcceptEdsUpdateLocked() local
1267 if (endpoint_state.update.has_value() && in AcceptEdsUpdateLocked()
1268 *endpoint_state.update == eds_update) { in AcceptEdsUpdateLocked()
1277 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdateLocked()
1278 endpoint_state.meta = CreateResourceMetadataAcked( in AcceptEdsUpdateLocked()
1281 auto& watchers_list = endpoint_state.watchers; in AcceptEdsUpdateLocked()
1282 auto& value = endpoint_state.update.value(); in AcceptEdsUpdateLocked()
2351 EndpointState& endpoint_state = authority_state.endpoint_map[resource->id]; in WatchEndpointData() local
2352 endpoint_state.watchers[w] = watcher; in WatchEndpointData()
2355 if (endpoint_state.update.has_value()) { in WatchEndpointData()
2361 auto& value = endpoint_state.update.value(); in WatchEndpointData()
2388 EndpointState& endpoint_state = authority_state.endpoint_map[resource->id]; in CancelEndpointDataWatch() local
2389 auto it = endpoint_state.watchers.find(watcher); in CancelEndpointDataWatch()
2390 if (it == endpoint_state.watchers.end()) { in CancelEndpointDataWatch()
2394 endpoint_state.watchers.erase(it); in CancelEndpointDataWatch()
2395 if (!endpoint_state.watchers.empty()) return; in CancelEndpointDataWatch()
2561 const EndpointState& endpoint_state = p.second; in NotifyOnErrorLocked() local
2562 for (const auto& q : endpoint_state.watchers) { in NotifyOnErrorLocked()