Home
last modified time | relevance | path

Searched refs:rds_update (Results 1 – 8 of 8) sorted by relevance

/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_api.h153 absl::optional<RdsUpdate> rds_update; member
157 rds_update == other.rds_update;
317 absl::optional<RdsUpdate>* rds_update, CdsUpdateMap* cds_update_map,
Dxds_client.cc242 void AcceptRdsUpdate(absl::optional<XdsApi::RdsUpdate> rds_update);
893 if (lds_update->rds_update.has_value()) { in AcceptLdsUpdate()
895 lds_update->rds_update.value().routes.size()); in AcceptLdsUpdate()
896 for (size_t i = 0; i < lds_update->rds_update.value().routes.size(); in AcceptLdsUpdate()
899 lds_update->rds_update.value().routes[i].ToString().c_str()); in AcceptLdsUpdate()
923 if (xds_client()->lds_result_->rds_update.has_value()) { in AcceptLdsUpdate()
928 xds_client()->lds_result_->rds_update.value(), &service_config); in AcceptLdsUpdate()
943 absl::optional<XdsApi::RdsUpdate> rds_update) { in AcceptRdsUpdate() argument
944 if (!rds_update.has_value()) { in AcceptRdsUpdate()
956 this, rds_update.value().routes.size()); in AcceptRdsUpdate()
[all …]
Dxds_client.h245 void UpdateWeightedClusterIndexMap(const XdsApi::RdsUpdate& rds_update);
248 grpc_error* CreateServiceConfig(const XdsApi::RdsUpdate& rds_update,
Dxds_api.cc1260 const std::string& expected_server_name, XdsApi::RdsUpdate* rds_update) { in RouteConfigParse() argument
1350 rds_update->routes.emplace_back(std::move(rds_route)); in RouteConfigParse()
1352 if (rds_update->routes.empty()) { in RouteConfigParse()
1405 XdsApi::RdsUpdate rds_update; in LdsResponseParse() local
1407 expected_server_name, &rds_update); in LdsResponseParse()
1410 (*lds_update)->rds_update.emplace(std::move(rds_update)); in LdsResponseParse()
1449 absl::optional<XdsApi::RdsUpdate>* rds_update, upb_arena* arena) { in RdsResponseParse() argument
1483 rds_update->emplace(std::move(local_rds_update)); in RdsResponseParse()
1765 absl::optional<RdsUpdate>* rds_update, CdsUpdateMap* cds_update_map, in ParseAdsResponse() argument
1796 expected_route_configuration_names, rds_update, in ParseAdsResponse()
/third_party/grpc/src/core/ext/filters/client_channel/resolver/xds/
Dxds_resolver.cc177 void OnRouteConfigUpdate(XdsApi::RdsUpdate rds_update);
215 update_.rds_update = std::move(update); in Notifier()
251 resolver_->OnRouteConfigUpdate(std::move(*update_.rds_update)); in RunInWorkSerializer()
582 GPR_ASSERT(listener.rds_update.has_value()); in OnListenerUpdate()
583 OnRouteConfigUpdate(std::move(*listener.rds_update)); in OnListenerUpdate()
587 void XdsResolver::OnRouteConfigUpdate(XdsApi::RdsUpdate rds_update) { in OnRouteConfigUpdate() argument
593 rds_update.FindVirtualHostForDomain(server_name_); in OnRouteConfigUpdate()
/third_party/grpc/src/core/ext/xds/
Dxds_api.h215 absl::optional<RdsUpdate> rds_update; member
220 rds_update == other.rds_update &&
Dxds_api.cc418 if (rds_update.has_value()) { in ToString()
420 absl::StrFormat("rds_update=%s", rds_update->ToString())); in ToString()
1161 XdsApi::RdsUpdate* rds_update) { in RouteConfigParse() argument
1169 rds_update->virtual_hosts.emplace_back(); in RouteConfigParse()
1170 XdsApi::RdsUpdate::VirtualHost& vhost = rds_update->virtual_hosts.back(); in RouteConfigParse()
1376 XdsApi::RdsUpdate rds_update; in LdsResponseParseClient() local
1378 RouteConfigParse(client, tracer, symtab, route_config, &rds_update); in LdsResponseParseClient()
1380 lds_update->rds_update = std::move(rds_update); in LdsResponseParseClient()
1616 XdsApi::RdsUpdate& rds_update = (*rds_update_map)[route_config_name]; in RdsResponseParse() local
1618 RouteConfigParse(client, tracer, symtab, route_config, &rds_update); in RdsResponseParse()
Dxds_client.cc960 XdsApi::RdsUpdate& rds_update = p.second; in AcceptRdsUpdate() local
965 rds_update.ToString().c_str()); in AcceptRdsUpdate()
971 *route_config_state.update == rds_update) { in AcceptRdsUpdate()
980 route_config_state.update = std::move(rds_update); in AcceptRdsUpdate()