Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2006-2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2006-2009 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 // An implementation of WebURLLoader in terms of ResourceLoaderBridge. | 5 // An implementation of WebURLLoader in terms of ResourceLoaderBridge. |
| 6 | 6 |
| 7 #include "webkit/glue/weburlloader_impl.h" | 7 #include "webkit/glue/weburlloader_impl.h" |
| 8 | 8 |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "base/process_util.h" | 10 #include "base/process_util.h" |
| 11 #include "base/string_util.h" | 11 #include "base/string_util.h" |
| 12 #include "base/time.h" | 12 #include "base/time.h" |
| 13 #include "net/base/data_url.h" | 13 #include "net/base/data_url.h" |
| 14 #include "net/base/load_flags.h" | 14 #include "net/base/load_flags.h" |
| 15 #include "net/base/net_errors.h" | 15 #include "net/base/net_errors.h" |
| 16 #include "net/base/net_util.h" | 16 #include "net/base/net_util.h" |
| 17 #include "net/http/http_response_headers.h" | 17 #include "net/http/http_response_headers.h" |
| 18 #include "webkit/api/public/WebHTTPHeaderVisitor.h" | 18 #include "webkit/api/public/WebHTTPHeaderVisitor.h" |
| 19 #include "webkit/api/public/WebURL.h" | 19 #include "webkit/api/public/WebURL.h" |
| 20 #include "webkit/api/public/WebURLError.h" | 20 #include "webkit/api/public/WebURLError.h" |
| 21 #include "webkit/api/public/WebURLLoaderClient.h" | 21 #include "webkit/api/public/WebURLLoaderClient.h" |
| 22 #include "webkit/api/public/WebURLRequest.h" | 22 #include "webkit/api/public/WebURLRequest.h" |
| 23 #include "webkit/api/public/WebURLResponse.h" | 23 #include "webkit/api/public/WebURLResponse.h" |
| 24 #include "webkit/glue/ftp_directory_listing_response_delegate.h" | |
| 24 #include "webkit/glue/glue_util.h" | 25 #include "webkit/glue/glue_util.h" |
| 25 #include "webkit/glue/multipart_response_delegate.h" | 26 #include "webkit/glue/multipart_response_delegate.h" |
| 26 #include "webkit/glue/resource_loader_bridge.h" | 27 #include "webkit/glue/resource_loader_bridge.h" |
| 27 #include "webkit/glue/webkit_glue.h" | 28 #include "webkit/glue/webkit_glue.h" |
| 28 | 29 |
| 29 using base::Time; | 30 using base::Time; |
| 30 using base::TimeDelta; | 31 using base::TimeDelta; |
| 31 using WebKit::WebData; | 32 using WebKit::WebData; |
| 32 using WebKit::WebHTTPBody; | 33 using WebKit::WebHTTPBody; |
| 33 using WebKit::WebHTTPHeaderVisitor; | 34 using WebKit::WebHTTPHeaderVisitor; |
| (...skipping 184 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 218 private: | 219 private: |
| 219 friend class base::RefCounted<Context>; | 220 friend class base::RefCounted<Context>; |
| 220 ~Context() {} | 221 ~Context() {} |
| 221 | 222 |
| 222 void HandleDataURL(); | 223 void HandleDataURL(); |
| 223 | 224 |
| 224 WebURLLoaderImpl* loader_; | 225 WebURLLoaderImpl* loader_; |
| 225 WebURLRequest request_; | 226 WebURLRequest request_; |
| 226 WebURLLoaderClient* client_; | 227 WebURLLoaderClient* client_; |
| 227 scoped_ptr<ResourceLoaderBridge> bridge_; | 228 scoped_ptr<ResourceLoaderBridge> bridge_; |
| 229 scoped_ptr<FtpDirectoryListingResponseDelegate> ftp_listing_delegate_; | |
| 228 scoped_ptr<MultipartResponseDelegate> multipart_delegate_; | 230 scoped_ptr<MultipartResponseDelegate> multipart_delegate_; |
| 229 int64 expected_content_length_; | 231 int64 expected_content_length_; |
| 230 }; | 232 }; |
| 231 | 233 |
| 232 WebURLLoaderImpl::Context::Context(WebURLLoaderImpl* loader) | 234 WebURLLoaderImpl::Context::Context(WebURLLoaderImpl* loader) |
| 233 : loader_(loader), | 235 : loader_(loader), |
| 234 client_(NULL) { | 236 client_(NULL) { |
| 235 } | 237 } |
| 236 | 238 |
| 237 void WebURLLoaderImpl::Context::Cancel() { | 239 void WebURLLoaderImpl::Context::Cancel() { |
| (...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 420 if (!client_) | 422 if (!client_) |
| 421 return; | 423 return; |
| 422 | 424 |
| 423 WebURLResponse response; | 425 WebURLResponse response; |
| 424 response.initialize(); | 426 response.initialize(); |
| 425 PopulateURLResponse(request_.url(), info, &response); | 427 PopulateURLResponse(request_.url(), info, &response); |
| 426 response.setIsContentFiltered(content_filtered); | 428 response.setIsContentFiltered(content_filtered); |
| 427 | 429 |
| 428 expected_content_length_ = response.expectedContentLength(); | 430 expected_content_length_ = response.expectedContentLength(); |
| 429 | 431 |
| 432 if (info.mime_type == "text/vnd.chromium.ftp-dir") | |
|
eroman
2009/09/23 21:14:49
I am still not convinced that we want to expose th
| |
| 433 response.setMIMEType(WebString::fromUTF8("text/html")); | |
|
eroman
2009/09/23 21:14:49
should we additionally specify the charset? Or is
| |
| 434 | |
| 430 client_->didReceiveResponse(loader_, response); | 435 client_->didReceiveResponse(loader_, response); |
| 431 | 436 |
| 432 // we may have been cancelled after didReceiveResponse, which would leave us | 437 // We may have been cancelled after didReceiveResponse, which would leave us |
| 433 // without a client and therefore without much need to do multipart handling. | 438 // without a client and therefore without much need to do further handling. |
| 434 if (!client_) | 439 if (!client_) |
| 435 return; | 440 return; |
| 436 | 441 |
| 442 DCHECK(!ftp_listing_delegate_.get()); | |
| 437 DCHECK(!multipart_delegate_.get()); | 443 DCHECK(!multipart_delegate_.get()); |
| 438 if (info.headers && info.mime_type == "multipart/x-mixed-replace") { | 444 if (info.headers && info.mime_type == "multipart/x-mixed-replace") { |
| 439 std::string content_type; | 445 std::string content_type; |
| 440 info.headers->EnumerateHeader(NULL, "content-type", &content_type); | 446 info.headers->EnumerateHeader(NULL, "content-type", &content_type); |
| 441 | 447 |
| 442 std::string boundary = net::GetHeaderParamValue(content_type, "boundary"); | 448 std::string boundary = net::GetHeaderParamValue(content_type, "boundary"); |
| 443 TrimString(boundary, " \"", &boundary); | 449 TrimString(boundary, " \"", &boundary); |
| 444 | 450 |
| 445 // If there's no boundary, just handle the request normally. In the gecko | 451 // If there's no boundary, just handle the request normally. In the gecko |
| 446 // code, nsMultiMixedConv::OnStartRequest throws an exception. | 452 // code, nsMultiMixedConv::OnStartRequest throws an exception. |
| 447 if (!boundary.empty()) { | 453 if (!boundary.empty()) { |
| 448 multipart_delegate_.reset( | 454 multipart_delegate_.reset( |
| 449 new MultipartResponseDelegate(client_, loader_, response, boundary)); | 455 new MultipartResponseDelegate(client_, loader_, response, boundary)); |
| 450 } | 456 } |
| 457 } else if (info.mime_type == "text/vnd.chromium.ftp-dir") { | |
| 458 ftp_listing_delegate_.reset( | |
| 459 new FtpDirectoryListingResponseDelegate(client_, loader_, response)); | |
| 451 } | 460 } |
| 452 } | 461 } |
| 453 | 462 |
| 454 void WebURLLoaderImpl::Context::OnReceivedData(const char* data, int len) { | 463 void WebURLLoaderImpl::Context::OnReceivedData(const char* data, int len) { |
| 455 if (!client_) | 464 if (!client_) |
| 456 return; | 465 return; |
| 457 | 466 |
| 458 if (multipart_delegate_.get()) { | 467 if (ftp_listing_delegate_.get()) { |
| 468 // The FTP listing delegate will make the appropriate calls to | |
| 469 // client_->didReceiveData and client_->didReceiveResponse. | |
| 470 ftp_listing_delegate_->OnReceivedData(data, len); | |
| 471 } else if (multipart_delegate_.get()) { | |
| 459 // The multipart delegate will make the appropriate calls to | 472 // The multipart delegate will make the appropriate calls to |
| 460 // client_->didReceiveData and client_->didReceiveResponse. | 473 // client_->didReceiveData and client_->didReceiveResponse. |
| 461 multipart_delegate_->OnReceivedData(data, len); | 474 multipart_delegate_->OnReceivedData(data, len); |
| 462 } else { | 475 } else { |
| 463 client_->didReceiveData(loader_, data, len, expected_content_length_); | 476 client_->didReceiveData(loader_, data, len, expected_content_length_); |
| 464 } | 477 } |
| 465 } | 478 } |
| 466 | 479 |
| 467 void WebURLLoaderImpl::Context::OnCompletedRequest( | 480 void WebURLLoaderImpl::Context::OnCompletedRequest( |
| 468 const URLRequestStatus& status, | 481 const URLRequestStatus& status, |
| 469 const std::string& security_info) { | 482 const std::string& security_info) { |
| 470 if (multipart_delegate_.get()) { | 483 if (ftp_listing_delegate_.get()) { |
| 484 ftp_listing_delegate_->OnCompletedRequest(); | |
| 485 ftp_listing_delegate_.reset(NULL); | |
| 486 } else if (multipart_delegate_.get()) { | |
| 471 multipart_delegate_->OnCompletedRequest(); | 487 multipart_delegate_->OnCompletedRequest(); |
| 472 multipart_delegate_.reset(NULL); | 488 multipart_delegate_.reset(NULL); |
| 473 } | 489 } |
| 474 | 490 |
| 475 // Prevent any further IPC to the browser now that we're complete. | 491 // Prevent any further IPC to the browser now that we're complete. |
| 476 bridge_.reset(); | 492 bridge_.reset(); |
| 477 | 493 |
| 478 if (client_) { | 494 if (client_) { |
| 479 if (status.status() != URLRequestStatus::SUCCESS) { | 495 if (status.status() != URLRequestStatus::SUCCESS) { |
| 480 int error_code; | 496 int error_code; |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 566 | 582 |
| 567 void WebURLLoaderImpl::cancel() { | 583 void WebURLLoaderImpl::cancel() { |
| 568 context_->Cancel(); | 584 context_->Cancel(); |
| 569 } | 585 } |
| 570 | 586 |
| 571 void WebURLLoaderImpl::setDefersLoading(bool value) { | 587 void WebURLLoaderImpl::setDefersLoading(bool value) { |
| 572 context_->SetDefersLoading(value); | 588 context_->SetDefersLoading(value); |
| 573 } | 589 } |
| 574 | 590 |
| 575 } // namespace webkit_glue | 591 } // namespace webkit_glue |
| OLD | NEW |