Index: net/url_request/url_fetcher_impl_unittest.cc |
diff --git a/net/url_request/url_fetcher_impl_unittest.cc b/net/url_request/url_fetcher_impl_unittest.cc |
index 39e2bb286a9d434c9347422c520a006e16688422..2637b95f46315699a8a3ca52fd8f7b31bee448e9 100644 |
--- a/net/url_request/url_fetcher_impl_unittest.cc |
+++ b/net/url_request/url_fetcher_impl_unittest.cc |
@@ -63,8 +63,7 @@ class ThrottlingTestURLRequestContextGetter |
base::MessageLoopProxy* io_message_loop_proxy, |
TestURLRequestContext* request_context) |
: TestURLRequestContextGetter(io_message_loop_proxy), |
- context_(request_context) { |
- } |
+ context_(request_context) {} |
// TestURLRequestContextGetter: |
virtual TestURLRequestContext* GetURLRequestContext() OVERRIDE { |
@@ -79,8 +78,7 @@ class ThrottlingTestURLRequestContextGetter |
} // namespace |
-class URLFetcherTest : public testing::Test, |
- public URLFetcherDelegate { |
+class URLFetcherTest : public testing::Test, public URLFetcherDelegate { |
public: |
URLFetcherTest() : fetcher_(NULL) {} |
@@ -104,9 +102,7 @@ class URLFetcherTest : public testing::Test, |
return io_message_loop_proxy_; |
} |
- TestURLRequestContext* request_context() { |
- return context_.get(); |
- } |
+ TestURLRequestContext* request_context() { return context_.get(); } |
protected: |
// testing::Test: |
@@ -205,9 +201,8 @@ void URLFetcherMockDnsTest::SetUp() { |
// test_server_.GetURL() returns a URL with 127.0.0.1 (kLocalhost), that is |
// immediately resolved by the MockHostResolver. Use a hostname instead to |
// trigger an async resolve. |
- test_url_ = GURL( |
- base::StringPrintf("http://example.com:%d/defaultresponse", |
- test_server_->host_port_pair().port())); |
+ test_url_ = GURL(base::StringPrintf("http://example.com:%d/defaultresponse", |
+ test_server_->host_port_pair().port())); |
ASSERT_TRUE(test_url_.is_valid()); |
} |
@@ -274,9 +269,7 @@ class URLFetcherEmptyPostTest : public URLFetcherTest { |
class URLFetcherDownloadProgressTest : public URLFetcherTest { |
public: |
URLFetcherDownloadProgressTest() |
- : previous_progress_(0), |
- expected_total_(0) { |
- } |
+ : previous_progress_(0), expected_total_(0) {} |
// URLFetcherTest: |
virtual void CreateFetcher(const GURL& url) OVERRIDE; |
@@ -305,6 +298,7 @@ class URLFetcherDownloadProgressCancelTest : public URLFetcherTest { |
virtual void OnURLFetchDownloadProgress(const URLFetcher* source, |
int64 current, |
int64 total) OVERRIDE; |
+ |
protected: |
bool cancelled_; |
}; |
@@ -319,6 +313,7 @@ class URLFetcherUploadProgressTest : public URLFetcherTest { |
virtual void OnURLFetchUploadProgress(const URLFetcher* source, |
int64 current, |
int64 total) OVERRIDE; |
+ |
protected: |
int64 previous_progress_; |
std::string chunk_; |
@@ -337,6 +332,7 @@ class URLFetcherSocketAddressTest : public URLFetcherTest { |
public: |
// URLFetcherDelegate: |
virtual void OnURLFetchComplete(const URLFetcher* source) OVERRIDE; |
+ |
protected: |
std::string expected_host_; |
uint16 expected_port_; |
@@ -369,6 +365,7 @@ class URLFetcherProtectTest : public URLFetcherTest { |
// URLFetcherDelegate: |
virtual void OnURLFetchComplete(const URLFetcher* source) OVERRIDE; |
+ |
private: |
Time start_time_; |
}; |
@@ -382,6 +379,7 @@ class URLFetcherProtectTestPassedThrough : public URLFetcherTest { |
// URLFetcherDelegate: |
virtual void OnURLFetchComplete(const URLFetcher* source) OVERRIDE; |
+ |
private: |
Time start_time_; |
}; |
@@ -414,8 +412,7 @@ class URLFetcherCancelTest : public URLFetcherTest { |
// thread once it is deleted. |
class CancelTestURLRequestContext : public ThrottlingTestURLRequestContext { |
public: |
- explicit CancelTestURLRequestContext() { |
- } |
+ explicit CancelTestURLRequestContext() {} |
private: |
virtual ~CancelTestURLRequestContext() { |
@@ -426,8 +423,7 @@ class CancelTestURLRequestContext : public ThrottlingTestURLRequestContext { |
} |
}; |
-class CancelTestURLRequestContextGetter |
- : public TestURLRequestContextGetter { |
+class CancelTestURLRequestContextGetter : public TestURLRequestContextGetter { |
public: |
CancelTestURLRequestContextGetter( |
base::MessageLoopProxy* io_message_loop_proxy, |
@@ -435,8 +431,7 @@ class CancelTestURLRequestContextGetter |
: TestURLRequestContextGetter(io_message_loop_proxy), |
io_message_loop_proxy_(io_message_loop_proxy), |
context_created_(false, false), |
- throttle_for_url_(throttle_for_url) { |
- } |
+ throttle_for_url_(throttle_for_url) {} |
// TestURLRequestContextGetter: |
virtual TestURLRequestContext* GetURLRequestContext() OVERRIDE { |
@@ -457,8 +452,8 @@ class CancelTestURLRequestContextGetter |
2.0, |
0.0, |
4000)); |
- context_->throttler_manager() |
- ->OverrideEntryForTests(throttle_for_url_, entry.get()); |
+ context_->throttler_manager()->OverrideEntryForTests(throttle_for_url_, |
+ entry.get()); |
context_created_.Signal(); |
} |
@@ -469,9 +464,7 @@ class CancelTestURLRequestContextGetter |
return io_message_loop_proxy_; |
} |
- void WaitForContextCreation() { |
- context_created_.Wait(); |
- } |
+ void WaitForContextCreation() { context_created_.Wait(); } |
protected: |
virtual ~CancelTestURLRequestContextGetter() {} |
@@ -488,14 +481,15 @@ class URLFetcherMultipleAttemptTest : public URLFetcherTest { |
public: |
// URLFetcherDelegate: |
virtual void OnURLFetchComplete(const URLFetcher* source) OVERRIDE; |
+ |
private: |
std::string data_; |
}; |
class URLFetcherFileTest : public URLFetcherTest { |
public: |
- URLFetcherFileTest() : take_ownership_of_file_(false), |
- expected_file_error_(OK) {} |
+ URLFetcherFileTest() |
+ : take_ownership_of_file_(false), expected_file_error_(OK) {} |
void CreateFetcherForFile(const GURL& url, const base::FilePath& file_path); |
void CreateFetcherForTempFile(const GURL& url); |
@@ -532,8 +526,7 @@ void URLFetcherPostTest::OnURLFetchComplete(const URLFetcher* source) { |
} |
URLFetcherPostFileTest::URLFetcherPostFileTest() |
- : range_offset_(0), |
- range_length_(kuint64max) { |
+ : range_offset_(0), range_length_(kuint64max) { |
PathService::Get(base::DIR_SOURCE_ROOT, &path_); |
path_ = path_.Append(FILE_PATH_LITERAL("net")); |
path_ = path_.Append(FILE_PATH_LITERAL("data")); |
@@ -568,8 +561,8 @@ void URLFetcherPostFileTest::OnURLFetchComplete(const URLFetcher* source) { |
void URLFetcherEmptyPostTest::CreateFetcher(const GURL& url) { |
fetcher_ = new URLFetcherImpl(url, URLFetcher::POST, this); |
- fetcher_->SetRequestContext(new TestURLRequestContextGetter( |
- io_message_loop_proxy())); |
+ fetcher_->SetRequestContext( |
+ new TestURLRequestContextGetter(io_message_loop_proxy())); |
fetcher_->SetUploadData("text/plain", std::string()); |
fetcher_->Start(); |
} |
@@ -595,7 +588,9 @@ void URLFetcherDownloadProgressTest::CreateFetcher(const GURL& url) { |
} |
void URLFetcherDownloadProgressTest::OnURLFetchDownloadProgress( |
- const URLFetcher* source, int64 progress, int64 total) { |
+ const URLFetcher* source, |
+ int64 progress, |
+ int64 total) { |
// Increasing between 0 and total. |
EXPECT_LE(0, progress); |
EXPECT_GE(total, progress); |
@@ -613,7 +608,9 @@ void URLFetcherDownloadProgressCancelTest::CreateFetcher(const GURL& url) { |
} |
void URLFetcherDownloadProgressCancelTest::OnURLFetchDownloadProgress( |
- const URLFetcher* source, int64 current, int64 total) { |
+ const URLFetcher* source, |
+ int64 current, |
+ int64 total) { |
EXPECT_FALSE(cancelled_); |
if (!cancelled_) { |
cancelled_ = true; |
@@ -634,7 +631,7 @@ void URLFetcherUploadProgressTest::CreateFetcher(const GURL& url) { |
io_message_loop_proxy().get(), request_context())); |
previous_progress_ = 0; |
// Large enough data to require more than one read from UploadDataStream. |
- chunk_.assign(1<<16, 'a'); |
+ chunk_.assign(1 << 16, 'a'); |
// Use chunked upload to wait for a timer event of progress notification. |
fetcher_->SetChunkedUpload("application/x-www-form-urlencoded"); |
fetcher_->Start(); |
@@ -643,7 +640,9 @@ void URLFetcherUploadProgressTest::CreateFetcher(const GURL& url) { |
} |
void URLFetcherUploadProgressTest::OnURLFetchUploadProgress( |
- const URLFetcher* source, int64 current, int64 total) { |
+ const URLFetcher* source, |
+ int64 current, |
+ int64 total) { |
// Increasing between 0 and total. |
EXPECT_LE(0, current); |
EXPECT_GE(static_cast<int64>(chunk_.size()) * number_of_chunks_added_, |
@@ -658,8 +657,7 @@ void URLFetcherUploadProgressTest::OnURLFetchUploadProgress( |
} |
} |
-void URLFetcherHeadersTest::OnURLFetchComplete( |
- const URLFetcher* source) { |
+void URLFetcherHeadersTest::OnURLFetchComplete(const URLFetcher* source) { |
std::string header; |
EXPECT_TRUE(source->GetResponseHeaders()->GetNormalizedHeader("cache-control", |
&header)); |
@@ -667,8 +665,7 @@ void URLFetcherHeadersTest::OnURLFetchComplete( |
URLFetcherTest::OnURLFetchComplete(source); |
} |
-void URLFetcherSocketAddressTest::OnURLFetchComplete( |
- const URLFetcher* source) { |
+void URLFetcherSocketAddressTest::OnURLFetchComplete(const URLFetcher* source) { |
EXPECT_EQ("127.0.0.1", source->GetSocketAddress().host()); |
EXPECT_EQ(expected_port_, source->GetSocketAddress().port()); |
URLFetcherTest::OnURLFetchComplete(source); |
@@ -772,7 +769,6 @@ void URLFetcherProtectTestPassedThrough::OnURLFetchComplete( |
CleanupAfterFetchComplete(); |
} |
- |
URLFetcherBadHTTPSTest::URLFetcherBadHTTPSTest() { |
PathService::Get(base::DIR_SOURCE_ROOT, &cert_dir_); |
cert_dir_ = cert_dir_.AppendASCII("chrome"); |
@@ -785,8 +781,7 @@ URLFetcherBadHTTPSTest::URLFetcherBadHTTPSTest() { |
// The "server certificate expired" error should result in automatic |
// cancellation of the request by |
// URLRequest::Delegate::OnSSLCertificateError. |
-void URLFetcherBadHTTPSTest::OnURLFetchComplete( |
- const URLFetcher* source) { |
+void URLFetcherBadHTTPSTest::OnURLFetchComplete(const URLFetcher* source) { |
// This part is different from URLFetcherTest::OnURLFetchComplete |
// because this test expects the request to be cancelled. |
EXPECT_EQ(URLRequestStatus::CANCELED, source->GetStatus().status()); |
@@ -812,8 +807,7 @@ void URLFetcherCancelTest::CreateFetcher(const GURL& url) { |
CancelRequest(); |
} |
-void URLFetcherCancelTest::OnURLFetchComplete( |
- const URLFetcher* source) { |
+void URLFetcherCancelTest::OnURLFetchComplete(const URLFetcher* source) { |
// We should have cancelled the request before completion. |
ADD_FAILURE(); |
CleanupAfterFetchComplete(); |
@@ -871,8 +865,8 @@ void URLFetcherFileTest::OnURLFetchComplete(const URLFetcher* source) { |
EXPECT_EQ(OK, source->GetStatus().error()); |
EXPECT_EQ(200, source->GetResponseCode()); |
- EXPECT_TRUE(source->GetResponseAsFilePath( |
- take_ownership_of_file_, &file_path_)); |
+ EXPECT_TRUE( |
+ source->GetResponseAsFilePath(take_ownership_of_file_, &file_path_)); |
EXPECT_TRUE(base::ContentsEqual(expected_file_, file_path_)); |
} else { |
@@ -909,11 +903,10 @@ TEST_F(URLFetcherTest, DifferentThreadsTest) { |
// scope. |
base::Thread t("URLFetcher test thread"); |
ASSERT_TRUE(t.Start()); |
- t.message_loop()->PostTask( |
- FROM_HERE, |
- base::Bind(&URLFetcherTest::CreateFetcher, |
- base::Unretained(this), |
- test_server.GetURL("defaultresponse"))); |
+ t.message_loop()->PostTask(FROM_HERE, |
+ base::Bind(&URLFetcherTest::CreateFetcher, |
+ base::Unretained(this), |
+ test_server.GetURL("defaultresponse"))); |
base::MessageLoop::current()->Run(); |
} |
@@ -1115,8 +1108,8 @@ TEST_F(URLFetcherDownloadProgressTest, Basic) { |
expected_total_ = kFileSize; |
- CreateFetcher(test_server.GetURL( |
- std::string(kTestServerFilePrefix) + kFileToFetch)); |
+ CreateFetcher( |
+ test_server.GetURL(std::string(kTestServerFilePrefix) + kFileToFetch)); |
base::MessageLoop::current()->Run(); |
} |
@@ -1130,8 +1123,8 @@ TEST_F(URLFetcherDownloadProgressCancelTest, CancelWhileProgressReport) { |
// Get a file large enough to require more than one read into |
// URLFetcher::Core's IOBuffer. |
static const char kFileToFetch[] = "animate1.gif"; |
- CreateFetcher(test_server.GetURL( |
- std::string(kTestServerFilePrefix) + kFileToFetch)); |
+ CreateFetcher( |
+ test_server.GetURL(std::string(kTestServerFilePrefix) + kFileToFetch)); |
base::MessageLoop::current()->Run(); |
} |
@@ -1193,8 +1186,8 @@ TEST_F(URLFetcherProtectTest, Overload) { |
2.0, |
0.0, |
256)); |
- request_context()->throttler_manager() |
- ->OverrideEntryForTests(url, entry.get()); |
+ request_context()->throttler_manager()->OverrideEntryForTests(url, |
+ entry.get()); |
CreateFetcher(url); |
@@ -1222,8 +1215,8 @@ TEST_F(URLFetcherProtectTest, ServerUnavailable) { |
2.0, |
0.0, |
256)); |
- request_context()->throttler_manager() |
- ->OverrideEntryForTests(url, entry.get()); |
+ request_context()->throttler_manager()->OverrideEntryForTests(url, |
+ entry.get()); |
CreateFetcher(url); |
@@ -1253,8 +1246,8 @@ TEST_F(URLFetcherProtectTestPassedThrough, ServerUnavailablePropagateResponse) { |
150000)); |
// Total time if *not* for not doing automatic backoff would be 150s. |
// In reality it should be "as soon as server responds". |
- request_context()->throttler_manager() |
- ->OverrideEntryForTests(url, entry.get()); |
+ request_context()->throttler_manager()->OverrideEntryForTests(url, |
+ entry.get()); |
CreateFetcher(url); |
@@ -1264,9 +1257,8 @@ TEST_F(URLFetcherProtectTestPassedThrough, ServerUnavailablePropagateResponse) { |
TEST_F(URLFetcherBadHTTPSTest, BadHTTPSTest) { |
SpawnedTestServer::SSLOptions ssl_options( |
SpawnedTestServer::SSLOptions::CERT_EXPIRED); |
- SpawnedTestServer test_server(SpawnedTestServer::TYPE_HTTPS, |
- ssl_options, |
- base::FilePath(kDocRoot)); |
+ SpawnedTestServer test_server( |
+ SpawnedTestServer::TYPE_HTTPS, ssl_options, base::FilePath(kDocRoot)); |
ASSERT_TRUE(test_server.Start()); |
CreateFetcher(test_server.GetURL("defaultresponse")); |
@@ -1290,8 +1282,8 @@ TEST_F(URLFetcherCancelTest, ReleasesContext) { |
ASSERT_TRUE(t.Start()); |
t.message_loop()->PostTask( |
FROM_HERE, |
- base::Bind(&URLFetcherCancelTest::CreateFetcher, |
- base::Unretained(this), url)); |
+ base::Bind( |
+ &URLFetcherCancelTest::CreateFetcher, base::Unretained(this), url)); |
base::MessageLoop::current()->Run(); |
} |
@@ -1316,8 +1308,8 @@ TEST_F(URLFetcherCancelTest, CancelWhileDelayedStartTaskPending) { |
2.0, |
0.0, |
4000)); |
- request_context()->throttler_manager() |
- ->OverrideEntryForTests(url, entry.get()); |
+ request_context()->throttler_manager()->OverrideEntryForTests(url, |
+ entry.get()); |
// Fake that a request has just started. |
entry->ReserveSendingTimeForNextRequest(base::TimeTicks()); |
@@ -1366,8 +1358,8 @@ TEST_F(URLFetcherFileTest, SmallGet) { |
base::MessageLoop::current()->Run(); // OnURLFetchComplete() will Quit(). |
- ASSERT_FALSE(base::PathExists(file_path_)) |
- << file_path_.value() << " not removed."; |
+ ASSERT_FALSE(base::PathExists(file_path_)) << file_path_.value() |
+ << " not removed."; |
} |
TEST_F(URLFetcherFileTest, LargeGet) { |
@@ -1414,8 +1406,8 @@ TEST_F(URLFetcherFileTest, SavedOutputFileOwnerhisp) { |
base::MessageLoop::current()->Run(); // OnURLFetchComplete() will Quit(). |
base::MessageLoop::current()->RunUntilIdle(); |
- ASSERT_EQ(kTake[i], base::PathExists(file_path_)) << |
- "FilePath: " << file_path_.value(); |
+ ASSERT_EQ(kTake[i], base::PathExists(file_path_)) |
+ << "FilePath: " << file_path_.value(); |
} |
} |
@@ -1487,8 +1479,8 @@ TEST_F(URLFetcherFileTest, SmallGetToTempFile) { |
base::MessageLoop::current()->Run(); // OnURLFetchComplete() will Quit(). |
- ASSERT_FALSE(base::PathExists(file_path_)) |
- << file_path_.value() << " not removed."; |
+ ASSERT_FALSE(base::PathExists(file_path_)) << file_path_.value() |
+ << " not removed."; |
} |
TEST_F(URLFetcherFileTest, LargeGetToTempFile) { |
@@ -1501,8 +1493,8 @@ TEST_F(URLFetcherFileTest, LargeGetToTempFile) { |
// URLFetcher::Core's IOBuffer. |
static const char kFileToFetch[] = "animate1.gif"; |
expected_file_ = test_server.GetDocumentRoot().AppendASCII(kFileToFetch); |
- CreateFetcherForTempFile(test_server.GetURL( |
- std::string(kTestServerFilePrefix) + kFileToFetch)); |
+ CreateFetcherForTempFile( |
+ test_server.GetURL(std::string(kTestServerFilePrefix) + kFileToFetch)); |
base::MessageLoop::current()->Run(); // OnURLFetchComplete() will Quit(). |
} |
@@ -1522,14 +1514,14 @@ TEST_F(URLFetcherFileTest, SavedOutputTempFileOwnerhisp) { |
// Get a small file. |
static const char kFileToFetch[] = "simple.html"; |
expected_file_ = test_server.GetDocumentRoot().AppendASCII(kFileToFetch); |
- CreateFetcherForTempFile(test_server.GetURL( |
- std::string(kTestServerFilePrefix) + kFileToFetch)); |
+ CreateFetcherForTempFile( |
+ test_server.GetURL(std::string(kTestServerFilePrefix) + kFileToFetch)); |
base::MessageLoop::current()->Run(); // OnURLFetchComplete() will Quit(). |
base::MessageLoop::current()->RunUntilIdle(); |
- ASSERT_EQ(kTake[i], base::PathExists(file_path_)) << |
- "FilePath: " << file_path_.value(); |
+ ASSERT_EQ(kTake[i], base::PathExists(file_path_)) |
+ << "FilePath: " << file_path_.value(); |
} |
} |