| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/child/web_url_loader_impl.h" | 5 #include "content/child/web_url_loader_impl.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 #include <string.h> | 8 #include <string.h> |
| 9 | 9 |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 175 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 186 EXPECT_EQ("", error_.domain.Utf8()); | 186 EXPECT_EQ("", error_.domain.Utf8()); |
| 187 | 187 |
| 188 received_data_.append(data, dataLength); | 188 received_data_.append(data, dataLength); |
| 189 | 189 |
| 190 if (delete_on_receive_data_) | 190 if (delete_on_receive_data_) |
| 191 loader_.reset(); | 191 loader_.reset(); |
| 192 } | 192 } |
| 193 | 193 |
| 194 void DidFinishLoading(double finishTime, | 194 void DidFinishLoading(double finishTime, |
| 195 int64_t totalEncodedDataLength, | 195 int64_t totalEncodedDataLength, |
| 196 int64_t totalEncodedBodyLength) override { | 196 int64_t totalEncodedBodyLength, |
| 197 int64_t totalDecodedBodyLength) override { |
| 197 EXPECT_TRUE(loader_); | 198 EXPECT_TRUE(loader_); |
| 198 EXPECT_TRUE(did_receive_response_); | 199 EXPECT_TRUE(did_receive_response_); |
| 199 EXPECT_FALSE(did_finish_); | 200 EXPECT_FALSE(did_finish_); |
| 200 did_finish_ = true; | 201 did_finish_ = true; |
| 201 | 202 |
| 202 if (delete_on_finish_) | 203 if (delete_on_finish_) |
| 203 loader_.reset(); | 204 loader_.reset(); |
| 204 } | 205 } |
| 205 | 206 |
| 206 void DidFail(const blink::WebURLError& error, | 207 void DidFail(const blink::WebURLError& error, |
| 207 int64_t totalEncodedDataLength, | 208 int64_t totalEncodedDataLength, |
| 208 int64_t totalEncodedBodyLength) override { | 209 int64_t totalEncodedBodyLength, |
| 210 int64_t totalDecodedBodyLength) override { |
| 209 EXPECT_TRUE(loader_); | 211 EXPECT_TRUE(loader_); |
| 210 EXPECT_FALSE(did_finish_); | 212 EXPECT_FALSE(did_finish_); |
| 211 error_ = error; | 213 error_ = error; |
| 212 | 214 |
| 213 if (delete_on_fail_) | 215 if (delete_on_fail_) |
| 214 loader_.reset(); | 216 loader_.reset(); |
| 215 } | 217 } |
| 216 | 218 |
| 217 WebURLLoaderImpl* loader() { return loader_.get(); } | 219 WebURLLoaderImpl* loader() { return loader_.get(); } |
| 218 void DeleteLoader() { | 220 void DeleteLoader() { |
| (...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 316 EXPECT_EQ("", client()->received_data()); | 318 EXPECT_EQ("", client()->received_data()); |
| 317 auto size = strlen(kTestData); | 319 auto size = strlen(kTestData); |
| 318 peer()->OnReceivedData( | 320 peer()->OnReceivedData( |
| 319 base::MakeUnique<FixedReceivedData>(kTestData, size)); | 321 base::MakeUnique<FixedReceivedData>(kTestData, size)); |
| 320 EXPECT_EQ(kTestData, client()->received_data()); | 322 EXPECT_EQ(kTestData, client()->received_data()); |
| 321 } | 323 } |
| 322 | 324 |
| 323 void DoCompleteRequest() { | 325 void DoCompleteRequest() { |
| 324 EXPECT_FALSE(client()->did_finish()); | 326 EXPECT_FALSE(client()->did_finish()); |
| 325 peer()->OnCompletedRequest(net::OK, false, false, base::TimeTicks(), | 327 peer()->OnCompletedRequest(net::OK, false, false, base::TimeTicks(), |
| 326 strlen(kTestData), strlen(kTestData)); | 328 strlen(kTestData), strlen(kTestData), |
| 329 strlen(kTestData)); |
| 327 EXPECT_TRUE(client()->did_finish()); | 330 EXPECT_TRUE(client()->did_finish()); |
| 328 // There should be no error. | 331 // There should be no error. |
| 329 EXPECT_EQ(net::OK, client()->error().reason); | 332 EXPECT_EQ(net::OK, client()->error().reason); |
| 330 EXPECT_EQ("", client()->error().domain.Utf8()); | 333 EXPECT_EQ("", client()->error().domain.Utf8()); |
| 331 } | 334 } |
| 332 | 335 |
| 333 void DoFailRequest() { | 336 void DoFailRequest() { |
| 334 EXPECT_FALSE(client()->did_finish()); | 337 EXPECT_FALSE(client()->did_finish()); |
| 335 peer()->OnCompletedRequest(net::ERR_FAILED, false, false, base::TimeTicks(), | 338 peer()->OnCompletedRequest(net::ERR_FAILED, false, false, base::TimeTicks(), |
| 336 strlen(kTestData), strlen(kTestData)); | 339 strlen(kTestData), strlen(kTestData), |
| 340 strlen(kTestData)); |
| 337 EXPECT_FALSE(client()->did_finish()); | 341 EXPECT_FALSE(client()->did_finish()); |
| 338 EXPECT_EQ(net::ERR_FAILED, client()->error().reason); | 342 EXPECT_EQ(net::ERR_FAILED, client()->error().reason); |
| 339 EXPECT_EQ(net::kErrorDomain, client()->error().domain.Utf8()); | 343 EXPECT_EQ(net::kErrorDomain, client()->error().domain.Utf8()); |
| 340 } | 344 } |
| 341 | 345 |
| 342 void DoReceiveResponseFtp() { | 346 void DoReceiveResponseFtp() { |
| 343 EXPECT_FALSE(client()->did_receive_response()); | 347 EXPECT_FALSE(client()->did_receive_response()); |
| 344 content::ResourceResponseInfo response_info; | 348 content::ResourceResponseInfo response_info; |
| 345 response_info.mime_type = kFtpDirMimeType; | 349 response_info.mime_type = kFtpDirMimeType; |
| 346 peer()->OnReceivedResponse(response_info); | 350 peer()->OnReceivedResponse(response_info); |
| (...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 566 | 570 |
| 567 TEST_F(WebURLLoaderImplTest, FtpDeleteOnReceiveMoreData) { | 571 TEST_F(WebURLLoaderImplTest, FtpDeleteOnReceiveMoreData) { |
| 568 DoStartAsyncRequest(); | 572 DoStartAsyncRequest(); |
| 569 DoReceiveResponseFtp(); | 573 DoReceiveResponseFtp(); |
| 570 DoReceiveDataFtp(); | 574 DoReceiveDataFtp(); |
| 571 | 575 |
| 572 // Directory listings are only parsed once the request completes, so this will | 576 // Directory listings are only parsed once the request completes, so this will |
| 573 // cancel in DoReceiveDataFtp, before the request finishes. | 577 // cancel in DoReceiveDataFtp, before the request finishes. |
| 574 client()->set_delete_on_receive_data(); | 578 client()->set_delete_on_receive_data(); |
| 575 peer()->OnCompletedRequest(net::OK, false, false, base::TimeTicks(), | 579 peer()->OnCompletedRequest(net::OK, false, false, base::TimeTicks(), |
| 576 strlen(kTestData), strlen(kTestData)); | 580 strlen(kTestData), strlen(kTestData), |
| 581 strlen(kTestData)); |
| 577 EXPECT_FALSE(client()->did_finish()); | 582 EXPECT_FALSE(client()->did_finish()); |
| 578 } | 583 } |
| 579 | 584 |
| 580 TEST_F(WebURLLoaderImplTest, FtpDeleteOnFinish) { | 585 TEST_F(WebURLLoaderImplTest, FtpDeleteOnFinish) { |
| 581 client()->set_delete_on_finish(); | 586 client()->set_delete_on_finish(); |
| 582 DoStartAsyncRequest(); | 587 DoStartAsyncRequest(); |
| 583 DoReceiveResponseFtp(); | 588 DoReceiveResponseFtp(); |
| 584 DoReceiveDataFtp(); | 589 DoReceiveDataFtp(); |
| 585 DoCompleteRequest(); | 590 DoCompleteRequest(); |
| 586 } | 591 } |
| (...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 687 int64_t encoded_body_length = 0; | 692 int64_t encoded_body_length = 0; |
| 688 client()->loader()->LoadSynchronously( | 693 client()->loader()->LoadSynchronously( |
| 689 request, response, error, data, encoded_data_length, encoded_body_length); | 694 request, response, error, data, encoded_data_length, encoded_body_length); |
| 690 | 695 |
| 691 EXPECT_EQ(kEncodedBodyLength, encoded_body_length); | 696 EXPECT_EQ(kEncodedBodyLength, encoded_body_length); |
| 692 EXPECT_EQ(kEncodedDataLength, encoded_data_length); | 697 EXPECT_EQ(kEncodedDataLength, encoded_data_length); |
| 693 } | 698 } |
| 694 | 699 |
| 695 } // namespace | 700 } // namespace |
| 696 } // namespace content | 701 } // namespace content |
| OLD | NEW |