| 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 160 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 171 did_receive_response_ = true; | 171 did_receive_response_ = true; |
| 172 response_ = response; | 172 response_ = response; |
| 173 if (delete_on_receive_response_) | 173 if (delete_on_receive_response_) |
| 174 loader_.reset(); | 174 loader_.reset(); |
| 175 } | 175 } |
| 176 | 176 |
| 177 void didDownloadData(int dataLength, int encodedDataLength) override { | 177 void didDownloadData(int dataLength, int encodedDataLength) override { |
| 178 EXPECT_TRUE(loader_); | 178 EXPECT_TRUE(loader_); |
| 179 } | 179 } |
| 180 | 180 |
| 181 void didReceiveData(const char* data, | 181 void didReceiveData(const char* data, int dataLength) override { |
| 182 int dataLength, | |
| 183 int encodedDataLength) override { | |
| 184 EXPECT_TRUE(loader_); | 182 EXPECT_TRUE(loader_); |
| 185 // The response should have started, but must not have finished, or failed. | 183 // The response should have started, but must not have finished, or failed. |
| 186 EXPECT_TRUE(did_receive_response_); | 184 EXPECT_TRUE(did_receive_response_); |
| 187 EXPECT_FALSE(did_finish_); | 185 EXPECT_FALSE(did_finish_); |
| 188 EXPECT_EQ(net::OK, error_.reason); | 186 EXPECT_EQ(net::OK, error_.reason); |
| 189 EXPECT_EQ("", error_.domain.utf8()); | 187 EXPECT_EQ("", error_.domain.utf8()); |
| 190 | 188 |
| 191 received_data_.append(data, dataLength); | 189 received_data_.append(data, dataLength); |
| 192 | 190 |
| 193 if (delete_on_receive_data_) | 191 if (delete_on_receive_data_) |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 310 EXPECT_FALSE(client()->did_receive_response()); | 308 EXPECT_FALSE(client()->did_receive_response()); |
| 311 peer()->OnReceivedResponse(content::ResourceResponseInfo()); | 309 peer()->OnReceivedResponse(content::ResourceResponseInfo()); |
| 312 EXPECT_TRUE(client()->did_receive_response()); | 310 EXPECT_TRUE(client()->did_receive_response()); |
| 313 } | 311 } |
| 314 | 312 |
| 315 // Assumes it is called only once for a request. | 313 // Assumes it is called only once for a request. |
| 316 void DoReceiveData() { | 314 void DoReceiveData() { |
| 317 EXPECT_EQ("", client()->received_data()); | 315 EXPECT_EQ("", client()->received_data()); |
| 318 auto size = strlen(kTestData); | 316 auto size = strlen(kTestData); |
| 319 peer()->OnReceivedData( | 317 peer()->OnReceivedData( |
| 320 base::MakeUnique<FixedReceivedData>(kTestData, size, size)); | 318 base::MakeUnique<FixedReceivedData>(kTestData, size)); |
| 321 EXPECT_EQ(kTestData, client()->received_data()); | 319 EXPECT_EQ(kTestData, client()->received_data()); |
| 322 } | 320 } |
| 323 | 321 |
| 324 void DoCompleteRequest() { | 322 void DoCompleteRequest() { |
| 325 EXPECT_FALSE(client()->did_finish()); | 323 EXPECT_FALSE(client()->did_finish()); |
| 326 peer()->OnCompletedRequest(net::OK, false, false, base::TimeTicks(), | 324 peer()->OnCompletedRequest(net::OK, false, false, base::TimeTicks(), |
| 327 strlen(kTestData), strlen(kTestData)); | 325 strlen(kTestData), strlen(kTestData)); |
| 328 EXPECT_TRUE(client()->did_finish()); | 326 EXPECT_TRUE(client()->did_finish()); |
| 329 // There should be no error. | 327 // There should be no error. |
| 330 EXPECT_EQ(net::OK, client()->error().reason); | 328 EXPECT_EQ(net::OK, client()->error().reason); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 344 EXPECT_FALSE(client()->did_receive_response()); | 342 EXPECT_FALSE(client()->did_receive_response()); |
| 345 content::ResourceResponseInfo response_info; | 343 content::ResourceResponseInfo response_info; |
| 346 response_info.mime_type = kFtpDirMimeType; | 344 response_info.mime_type = kFtpDirMimeType; |
| 347 peer()->OnReceivedResponse(response_info); | 345 peer()->OnReceivedResponse(response_info); |
| 348 EXPECT_TRUE(client()->did_receive_response()); | 346 EXPECT_TRUE(client()->did_receive_response()); |
| 349 } | 347 } |
| 350 | 348 |
| 351 void DoReceiveDataFtp() { | 349 void DoReceiveDataFtp() { |
| 352 auto size = strlen(kFtpDirListing); | 350 auto size = strlen(kFtpDirListing); |
| 353 peer()->OnReceivedData( | 351 peer()->OnReceivedData( |
| 354 base::MakeUnique<FixedReceivedData>(kFtpDirListing, size, size)); | 352 base::MakeUnique<FixedReceivedData>(kFtpDirListing, size)); |
| 355 // The FTP delegate should modify the data the client sees. | 353 // The FTP delegate should modify the data the client sees. |
| 356 EXPECT_NE(kFtpDirListing, client()->received_data()); | 354 EXPECT_NE(kFtpDirListing, client()->received_data()); |
| 357 } | 355 } |
| 358 | 356 |
| 359 TestWebURLLoaderClient* client() { return client_.get(); } | 357 TestWebURLLoaderClient* client() { return client_.get(); } |
| 360 TestResourceDispatcher* dispatcher() { return &dispatcher_; } | 358 TestResourceDispatcher* dispatcher() { return &dispatcher_; } |
| 361 RequestPeer* peer() { return dispatcher()->peer(); } | 359 RequestPeer* peer() { return dispatcher()->peer(); } |
| 362 base::MessageLoop* message_loop() { return &message_loop_; } | 360 base::MessageLoop* message_loop() { return &message_loop_; } |
| 363 | 361 |
| 364 private: | 362 private: |
| (...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 687 int64_t encoded_body_length = 0; | 685 int64_t encoded_body_length = 0; |
| 688 client()->loader()->loadSynchronously( | 686 client()->loader()->loadSynchronously( |
| 689 request, response, error, data, encoded_data_length, encoded_body_length); | 687 request, response, error, data, encoded_data_length, encoded_body_length); |
| 690 | 688 |
| 691 EXPECT_EQ(kEncodedBodyLength, encoded_body_length); | 689 EXPECT_EQ(kEncodedBodyLength, encoded_body_length); |
| 692 EXPECT_EQ(kEncodedDataLength, encoded_data_length); | 690 EXPECT_EQ(kEncodedDataLength, encoded_data_length); |
| 693 } | 691 } |
| 694 | 692 |
| 695 } // namespace | 693 } // namespace |
| 696 } // namespace content | 694 } // namespace content |
| OLD | NEW |