Commit 8367f3e8 authored by Robert Ogden's avatar Robert Ogden Committed by Commit Bot

Remove previews-specific traffic annotation from prober

Next CL will see this code moved to a new dir under //chrome/browser

Bug: 986359
Change-Id: Id6d0a43b684db7aa3bcd751c6d3b7e58702ec208
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1715105Reviewed-by: default avatarTarun Bansal <tbansal@chromium.org>
Commit-Queue: Robert Ogden <robertogden@chromium.org>
Cr-Commit-Position: refs/heads/master@{#680080}
parent 57e5df81
...@@ -26,7 +26,6 @@ ...@@ -26,7 +26,6 @@
#include "net/base/load_flags.h" #include "net/base/load_flags.h"
#include "net/base/net_errors.h" #include "net/base/net_errors.h"
#include "net/http/http_status_code.h" #include "net/http/http_status_code.h"
#include "net/traffic_annotation/network_traffic_annotation.h"
#include "services/network/public/cpp/resource_request.h" #include "services/network/public/cpp/resource_request.h"
#include "services/network/public/cpp/shared_url_loader_factory.h" #include "services/network/public/cpp/shared_url_loader_factory.h"
#include "services/network/public/cpp/simple_url_loader.h" #include "services/network/public/cpp/simple_url_loader.h"
...@@ -221,6 +220,7 @@ PreviewsProber::PreviewsProber( ...@@ -221,6 +220,7 @@ PreviewsProber::PreviewsProber(
const net::HttpRequestHeaders headers, const net::HttpRequestHeaders headers,
const RetryPolicy& retry_policy, const RetryPolicy& retry_policy,
const TimeoutPolicy& timeout_policy, const TimeoutPolicy& timeout_policy,
const net::NetworkTrafficAnnotationTag& traffic_annotation,
const size_t max_cache_entries, const size_t max_cache_entries,
base::TimeDelta revalidate_cache_after) base::TimeDelta revalidate_cache_after)
: PreviewsProber(delegate, : PreviewsProber(delegate,
...@@ -232,6 +232,7 @@ PreviewsProber::PreviewsProber( ...@@ -232,6 +232,7 @@ PreviewsProber::PreviewsProber(
headers, headers,
retry_policy, retry_policy,
timeout_policy, timeout_policy,
traffic_annotation,
max_cache_entries, max_cache_entries,
revalidate_cache_after, revalidate_cache_after,
base::DefaultTickClock::GetInstance(), base::DefaultTickClock::GetInstance(),
...@@ -247,6 +248,7 @@ PreviewsProber::PreviewsProber( ...@@ -247,6 +248,7 @@ PreviewsProber::PreviewsProber(
const net::HttpRequestHeaders headers, const net::HttpRequestHeaders headers,
const RetryPolicy& retry_policy, const RetryPolicy& retry_policy,
const TimeoutPolicy& timeout_policy, const TimeoutPolicy& timeout_policy,
const net::NetworkTrafficAnnotationTag& traffic_annotation,
const size_t max_cache_entries, const size_t max_cache_entries,
base::TimeDelta revalidate_cache_after, base::TimeDelta revalidate_cache_after,
const base::TickClock* tick_clock, const base::TickClock* tick_clock,
...@@ -261,6 +263,7 @@ PreviewsProber::PreviewsProber( ...@@ -261,6 +263,7 @@ PreviewsProber::PreviewsProber(
timeout_policy_(timeout_policy), timeout_policy_(timeout_policy),
max_cache_entries_(max_cache_entries), max_cache_entries_(max_cache_entries),
revalidate_cache_after_(revalidate_cache_after), revalidate_cache_after_(revalidate_cache_after),
traffic_annotation_(traffic_annotation),
successive_retry_count_(0), successive_retry_count_(0),
successive_timeout_count_(0), successive_timeout_count_(0),
cached_probe_results_(std::make_unique<base::DictionaryValue>()), cached_probe_results_(std::make_unique<base::DictionaryValue>()),
...@@ -385,28 +388,6 @@ void PreviewsProber::CreateAndStartURLLoader() { ...@@ -385,28 +388,6 @@ void PreviewsProber::CreateAndStartURLLoader() {
url = url.ReplaceComponents(replacements); url = url.ReplaceComponents(replacements);
} }
net::NetworkTrafficAnnotationTag traffic_annotation =
net::DefineNetworkTrafficAnnotation("previews_prober", R"(
semantics {
sender: "Previews Prober"
description:
"Requests a small resource to test network connectivity to a given "
"resource or domain which will either be a Google owned domain or"
"the website that the user is navigating to."
trigger:
"Requested when Lite mode and Previews are enabled on startup and "
"on every network change."
data: "None."
destination: WEBSITE
}
policy {
cookies_allowed: NO
setting:
"Users can control Lite mode on Android via the settings menu. "
"Lite mode is not available on iOS, and on desktop only for "
"developer testing."
policy_exception_justification: "Not implemented."
})");
auto request = std::make_unique<network::ResourceRequest>(); auto request = std::make_unique<network::ResourceRequest>();
request->url = url; request->url = url;
request->method = HttpMethodToString(http_method_); request->method = HttpMethodToString(http_method_);
...@@ -415,7 +396,7 @@ void PreviewsProber::CreateAndStartURLLoader() { ...@@ -415,7 +396,7 @@ void PreviewsProber::CreateAndStartURLLoader() {
request->allow_credentials = false; request->allow_credentials = false;
url_loader_ = url_loader_ =
network::SimpleURLLoader::Create(std::move(request), traffic_annotation); network::SimpleURLLoader::Create(std::move(request), traffic_annotation_);
url_loader_->SetAllowHttpErrorResults(true); url_loader_->SetAllowHttpErrorResults(true);
url_loader_->DownloadToString( url_loader_->DownloadToString(
......
...@@ -23,6 +23,7 @@ ...@@ -23,6 +23,7 @@
#include "build/build_config.h" #include "build/build_config.h"
#include "net/base/net_errors.h" #include "net/base/net_errors.h"
#include "net/http/http_request_headers.h" #include "net/http/http_request_headers.h"
#include "net/traffic_annotation/network_traffic_annotation.h"
#include "services/network/public/cpp/network_connection_tracker.h" #include "services/network/public/cpp/network_connection_tracker.h"
#include "services/network/public/cpp/resource_response.h" #include "services/network/public/cpp/resource_response.h"
#include "url/gurl.h" #include "url/gurl.h"
...@@ -140,6 +141,7 @@ class PreviewsProber ...@@ -140,6 +141,7 @@ class PreviewsProber
const net::HttpRequestHeaders headers, const net::HttpRequestHeaders headers,
const RetryPolicy& retry_policy, const RetryPolicy& retry_policy,
const TimeoutPolicy& timeout_policy, const TimeoutPolicy& timeout_policy,
const net::NetworkTrafficAnnotationTag& traffic_annotation,
const size_t max_cache_entries, const size_t max_cache_entries,
base::TimeDelta revalidate_cache_after); base::TimeDelta revalidate_cache_after);
~PreviewsProber() override; ~PreviewsProber() override;
...@@ -180,6 +182,7 @@ class PreviewsProber ...@@ -180,6 +182,7 @@ class PreviewsProber
const net::HttpRequestHeaders headers, const net::HttpRequestHeaders headers,
const RetryPolicy& retry_policy, const RetryPolicy& retry_policy,
const TimeoutPolicy& timeout_policy, const TimeoutPolicy& timeout_policy,
const net::NetworkTrafficAnnotationTag& traffic_annotation,
const size_t max_cache_entries, const size_t max_cache_entries,
base::TimeDelta revalidate_cache_after, base::TimeDelta revalidate_cache_after,
const base::TickClock* tick_clock, const base::TickClock* tick_clock,
...@@ -234,6 +237,9 @@ class PreviewsProber ...@@ -234,6 +237,9 @@ class PreviewsProber
// background. // background.
const base::TimeDelta revalidate_cache_after_; const base::TimeDelta revalidate_cache_after_;
// The traffic annotation to use for creating |url_loader_|.
const net::NetworkTrafficAnnotationTag traffic_annotation_;
// The number of retries that have been attempted. This count does not include // The number of retries that have been attempted. This count does not include
// the original probe. // the original probe.
size_t successive_retry_count_; size_t successive_retry_count_;
......
...@@ -19,6 +19,7 @@ ...@@ -19,6 +19,7 @@
#include "net/test/embedded_test_server/embedded_test_server.h" #include "net/test/embedded_test_server/embedded_test_server.h"
#include "net/test/embedded_test_server/http_request.h" #include "net/test/embedded_test_server/http_request.h"
#include "net/test/embedded_test_server/http_response.h" #include "net/test/embedded_test_server/http_response.h"
#include "net/traffic_annotation/network_traffic_annotation_test_helper.h"
#include "services/network/public/mojom/network_service_test.mojom.h" #include "services/network/public/mojom/network_service_test.mojom.h"
#include "services/service_manager/public/cpp/connector.h" #include "services/service_manager/public/cpp/connector.h"
...@@ -133,7 +134,8 @@ IN_PROC_BROWSER_TEST_F(PreviewsProberBrowserTest, OK) { ...@@ -133,7 +134,8 @@ IN_PROC_BROWSER_TEST_F(PreviewsProberBrowserTest, OK) {
browser()->profile()->GetPrefs(), browser()->profile()->GetPrefs(),
PreviewsProber::ClientName::kLitepages, url, PreviewsProber::ClientName::kLitepages, url,
PreviewsProber::HttpMethod::kGet, headers, retry_policy, PreviewsProber::HttpMethod::kGet, headers, retry_policy,
timeout_policy, 1, base::TimeDelta::FromDays(1)); timeout_policy, TRAFFIC_ANNOTATION_FOR_TESTS, 1,
base::TimeDelta::FromDays(1));
prober.SendNowIfInactive(false); prober.SendNowIfInactive(false);
WaitForCompletedProbe(&prober); WaitForCompletedProbe(&prober);
...@@ -155,7 +157,8 @@ IN_PROC_BROWSER_TEST_F(PreviewsProberBrowserTest, Timeout) { ...@@ -155,7 +157,8 @@ IN_PROC_BROWSER_TEST_F(PreviewsProberBrowserTest, Timeout) {
browser()->profile()->GetPrefs(), browser()->profile()->GetPrefs(),
PreviewsProber::ClientName::kLitepages, url, PreviewsProber::ClientName::kLitepages, url,
PreviewsProber::HttpMethod::kGet, headers, retry_policy, PreviewsProber::HttpMethod::kGet, headers, retry_policy,
timeout_policy, 1, base::TimeDelta::FromDays(1)); timeout_policy, TRAFFIC_ANNOTATION_FOR_TESTS, 1,
base::TimeDelta::FromDays(1));
prober.SendNowIfInactive(false); prober.SendNowIfInactive(false);
WaitForCompletedProbe(&prober); WaitForCompletedProbe(&prober);
...@@ -180,7 +183,8 @@ IN_PROC_BROWSER_TEST_F(PreviewsProberBrowserTest, MAYBE_NetworkChange) { ...@@ -180,7 +183,8 @@ IN_PROC_BROWSER_TEST_F(PreviewsProberBrowserTest, MAYBE_NetworkChange) {
browser()->profile()->GetPrefs(), browser()->profile()->GetPrefs(),
PreviewsProber::ClientName::kLitepages, url, PreviewsProber::ClientName::kLitepages, url,
PreviewsProber::HttpMethod::kGet, headers, retry_policy, PreviewsProber::HttpMethod::kGet, headers, retry_policy,
timeout_policy, 1, base::TimeDelta::FromDays(1)); timeout_policy, TRAFFIC_ANNOTATION_FOR_TESTS, 1,
base::TimeDelta::FromDays(1));
SimulateNetworkChange(network::mojom::ConnectionType::CONNECTION_4G); SimulateNetworkChange(network::mojom::ConnectionType::CONNECTION_4G);
WaitForCompletedProbe(&prober); WaitForCompletedProbe(&prober);
......
...@@ -16,6 +16,7 @@ ...@@ -16,6 +16,7 @@
#include "net/base/load_flags.h" #include "net/base/load_flags.h"
#include "net/base/net_errors.h" #include "net/base/net_errors.h"
#include "net/http/http_status_code.h" #include "net/http/http_status_code.h"
#include "net/traffic_annotation/network_traffic_annotation_test_helper.h"
#include "services/network/public/cpp/resource_request.h" #include "services/network/public/cpp/resource_request.h"
#include "services/network/public/cpp/resource_response.h" #include "services/network/public/cpp/resource_response.h"
#include "services/network/public/cpp/weak_wrapper_shared_url_loader_factory.h" #include "services/network/public/cpp/weak_wrapper_shared_url_loader_factory.h"
...@@ -63,6 +64,7 @@ class TestPreviewsProber : public PreviewsProber { ...@@ -63,6 +64,7 @@ class TestPreviewsProber : public PreviewsProber {
const net::HttpRequestHeaders headers, const net::HttpRequestHeaders headers,
const RetryPolicy& retry_policy, const RetryPolicy& retry_policy,
const TimeoutPolicy& timeout_policy, const TimeoutPolicy& timeout_policy,
const net::NetworkTrafficAnnotationTag& traffic_annotation,
const size_t max_cache_entries, const size_t max_cache_entries,
base::TimeDelta revalidate_cache_after, base::TimeDelta revalidate_cache_after,
const base::TickClock* tick_clock, const base::TickClock* tick_clock,
...@@ -76,6 +78,7 @@ class TestPreviewsProber : public PreviewsProber { ...@@ -76,6 +78,7 @@ class TestPreviewsProber : public PreviewsProber {
headers, headers,
retry_policy, retry_policy,
timeout_policy, timeout_policy,
traffic_annotation,
max_cache_entries, max_cache_entries,
revalidate_cache_after, revalidate_cache_after,
tick_clock, tick_clock,
...@@ -125,8 +128,9 @@ class PreviewsProberTest : public testing::Test { ...@@ -125,8 +128,9 @@ class PreviewsProberTest : public testing::Test {
delegate, test_shared_loader_factory_, &test_prefs_, delegate, test_shared_loader_factory_, &test_prefs_,
PreviewsProber::ClientName::kLitepages, kTestUrl, PreviewsProber::ClientName::kLitepages, kTestUrl,
PreviewsProber::HttpMethod::kGet, headers, retry_policy, PreviewsProber::HttpMethod::kGet, headers, retry_policy,
timeout_policy, 1, kCacheRevalidateAfter, timeout_policy, TRAFFIC_ANNOTATION_FOR_TESTS, 1,
thread_bundle_.GetMockTickClock(), thread_bundle_.GetMockClock()); kCacheRevalidateAfter, thread_bundle_.GetMockTickClock(),
thread_bundle_.GetMockClock());
prober->SetOnCompleteCallback(base::BindRepeating( prober->SetOnCompleteCallback(base::BindRepeating(
&PreviewsProberTest::OnProbeComplete, base::Unretained(this))); &PreviewsProberTest::OnProbeComplete, base::Unretained(this)));
return prober; return prober;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment