Searched refs:eds_update (Results 1 – 4 of 4) sorted by relevance
1066 XdsApi::EdsUpdate& eds_update = p.second; in AcceptEdsUpdate() local1074 xds_client(), eds_update.priority_list_update.size(), in AcceptEdsUpdate()1075 eds_update.drop_config->drop_category_list().size(), in AcceptEdsUpdate()1076 eds_update.drop_config->drop_all()); in AcceptEdsUpdate()1078 priority < eds_update.priority_list_update.size(); ++priority) { in AcceptEdsUpdate()1079 const auto* locality_map_update = eds_update.priority_list_update.Find( in AcceptEdsUpdate()1108 i < eds_update.drop_config->drop_category_list().size(); ++i) { in AcceptEdsUpdate()1110 eds_update.drop_config->drop_category_list()[i]; in AcceptEdsUpdate()1123 prev_update.priority_list_update != eds_update.priority_list_update; in AcceptEdsUpdate()1126 *prev_update.drop_config != *eds_update.drop_config; in AcceptEdsUpdate()[all …]
1686 XdsApi::EdsUpdate eds_update; in EdsResponseParse() local1725 eds_update.priority_list_update.Add(locality); in EdsResponseParse()1728 priority < eds_update.priority_list_update.size(); ++priority) { in EdsResponseParse()1729 auto* locality_map = eds_update.priority_list_update.Find(priority); in EdsResponseParse()1736 eds_update.drop_config = MakeRefCounted<XdsApi::DropConfig>(); in EdsResponseParse()1747 DropParseAndAppend(drop_overload[j], eds_update.drop_config.get()); in EdsResponseParse()1752 std::move(eds_update)); in EdsResponseParse()
2123 XdsApi::EdsUpdate& eds_update = (*eds_update_map)[eds_service_name]; in EdsResponseParse() local2139 while (eds_update.priorities.size() < priority + 1) { in EdsResponseParse()2140 eds_update.priorities.emplace_back(); in EdsResponseParse()2142 eds_update.priorities[priority].localities.emplace(locality.name.get(), in EdsResponseParse()2154 for (const auto& priority : eds_update.priorities) { in EdsResponseParse()2163 eds_update.drop_config = MakeRefCounted<XdsApi::EdsUpdate::DropConfig>(); in EdsResponseParse()2175 DropParseAndAppend(drop_overload[j], eds_update.drop_config.get()); in EdsResponseParse()
1077 XdsApi::EdsUpdate& eds_update = p.second; in AcceptEdsUpdate() local1082 eds_service_name, eds_update.ToString().c_str()); in AcceptEdsUpdate()1088 *endpoint_state.update == eds_update) { in AcceptEdsUpdate()1097 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdate()