28     std::vector<std::string>* urls,  in PartitionUrlsBySetMembership()  argument
31       urls->begin(), urls->end(), [&membership_test](const std::string& url) {  in PartitionUrlsBySetMembership()
60 void UrlAvailabilityRequester::AddObserver(const std::vector<std::string>& urls,  in AddObserver()  argument
62   for (const auto& url : urls) {  in AddObserver()
67     receiver->GetOrRequestAvailabilities(urls, observer);  in AddObserver()
72     const std::vector<std::string>& urls,  in RemoveObserverUrls()  argument
75   for (const auto& url : urls) {  in RemoveObserverUrls()
125   std::vector<std::string> urls;  in AddReceiver()  local
126   urls.reserve(observers_by_url_.size());  in AddReceiver()
128     urls.push_back(url.first);  in AddReceiver()
129   receiver->RequestUrlAvailabilities(std::move(urls));  in AddReceiver()
207     std::vector<std::string> urls) {  in RequestUrlAvailabilities()  argument
208   if (urls.empty())  in RequestUrlAvailabilities()
212   if (!connection || (watch_id_or_error = SendRequest(request_id, urls))) {  in RequestUrlAvailabilities()
214                           Request{watch_id_or_error.value(), std::move(urls)});  in RequestUrlAvailabilities()
216     for (const auto& url : urls)  in RequestUrlAvailabilities()
224     const std::vector<std::string>& urls) {  in SendRequest()  argument
228   cbor_request.urls = urls;  in SendRequest()
237         watch_id, Watch{listener->now_function_() + kWatchDuration, urls});  in SendRequest()
260       new_requests.emplace_back(std::move(watch.urls));  in RefreshWatches()
278     const std::vector<std::string>& urls,  in UpdateAvailabilities()  argument
281   if (urls.size() != availabilities.size()) {  in UpdateAvailabilities()
284   for (const auto& url : urls) {  in UpdateAvailabilities()
320     auto split = PartitionUrlsBySetMembership(&request.urls, unobserved_urls);  in RemoveUnobservedRequests()
321     if (split == request.urls.end())  in RemoveUnobservedRequests()
323     MoveVectorSegment(request.urls.begin(), split, &still_observed_urls);  in RemoveUnobservedRequests()
330     std::vector<std::string> urls;  in RemoveUnobservedRequests()  local
331     urls.reserve(still_observed_urls.size());  in RemoveUnobservedRequests()
333       urls.emplace_back(std::move(url));  in RemoveUnobservedRequests()
335         (watch_id_or_error = SendRequest(new_request_id, urls))) {  in RemoveUnobservedRequests()
337                            Request{watch_id_or_error.value(), std::move(urls)});  in RemoveUnobservedRequests()
339       for (const auto& url : urls)  in RemoveUnobservedRequests()
357     auto split = PartitionUrlsBySetMembership(&watch.urls, unobserved_urls);  in RemoveUnobservedWatches()
358     if (split == watch.urls.end()) {  in RemoveUnobservedWatches()
362     MoveVectorSegment(watch.urls.begin(), split, &still_observed_urls);  in RemoveUnobservedWatches()
366   std::vector<std::string> urls;  in RemoveUnobservedWatches()  local
367   urls.reserve(still_observed_urls.size());  in RemoveUnobservedWatches()
369     urls.emplace_back(std::move(url));  in RemoveUnobservedWatches()
370   RequestUrlAvailabilities(std::move(urls));  in RemoveUnobservedWatches()
397     if ((watch_id_or_error = SendRequest(entry->first, entry->second.urls))) {  in OnConnectionOpened()
413     for (auto& url : request.urls) {  in OnConnectionFailed()
448         std::vector<std::string>& urls = request_entry->second.urls;  in OnStreamMessage()  local
449         if (urls.size() != response.url_availabilities.size()) {  in OnStreamMessage()
450           OSP_LOG_WARN << "bad response size: expected " << urls.size()  in OnStreamMessage()
455             UpdateAvailabilities(urls, response.url_availabilities);  in OnStreamMessage()
477           std::vector<std::string> urls = watch_entry->second.urls;  in OnStreamMessage()  local
479               UpdateAvailabilities(urls, event.url_availabilities);  in OnStreamMessage()