| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/npapi/plugin_stream_url.h" | 5 #include "content/child/npapi/plugin_stream_url.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "base/strings/string_util.h" | 10 #include "base/strings/string_util.h" |
| 11 #include "content/child/npapi/plugin_host.h" | 11 #include "content/child/npapi/plugin_host.h" |
| 12 #include "content/child/npapi/plugin_instance.h" | 12 #include "content/child/npapi/plugin_instance.h" |
| 13 #include "content/child/npapi/plugin_lib.h" | 13 #include "content/child/npapi/plugin_lib.h" |
| 14 #include "content/child/npapi/plugin_url_fetcher.h" | 14 #include "content/child/npapi/plugin_url_fetcher.h" |
| 15 #include "content/child/npapi/webplugin.h" | 15 #include "content/child/npapi/webplugin.h" |
| 16 #include "net/http/http_response_headers.h" | 16 #include "net/http/http_response_headers.h" |
| 17 | 17 |
| 18 namespace content { | 18 namespace content { |
| 19 | 19 |
| 20 PluginStreamUrl::PluginStreamUrl( | 20 PluginStreamUrl::PluginStreamUrl( |
| 21 unsigned long resource_id, | 21 unsigned long resource_id, |
| 22 const GURL &url, | 22 const GURL &url, |
| 23 PluginInstance *instance, | 23 PluginInstance *instance) |
| 24 bool notify_needed, | 24 : PluginStream(instance, url.spec().c_str()), |
| 25 void *notify_data) | |
| 26 : PluginStream(instance, url.spec().c_str(), notify_needed, notify_data), | |
| 27 url_(url), | 25 url_(url), |
| 28 id_(resource_id) { | 26 id_(resource_id) { |
| 29 } | 27 } |
| 30 | 28 |
| 31 void PluginStreamUrl::SetPluginURLFetcher(PluginURLFetcher* fetcher) { | 29 void PluginStreamUrl::SetPluginURLFetcher(PluginURLFetcher* fetcher) { |
| 32 plugin_url_fetcher_.reset(fetcher); | 30 plugin_url_fetcher_.reset(fetcher); |
| 33 } | 31 } |
| 34 | 32 |
| 35 void PluginStreamUrl::URLRedirectResponse(bool allow) { | 33 void PluginStreamUrl::URLRedirectResponse(bool allow) { |
| 36 if (plugin_url_fetcher_.get()) { | 34 if (plugin_url_fetcher_.get()) { |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 83 for (size_t i = 0; i < range_requests_.size(); ++i) | 81 for (size_t i = 0; i < range_requests_.size(); ++i) |
| 84 instance()->webplugin()->CancelResource(range_requests_[i]); | 82 instance()->webplugin()->CancelResource(range_requests_[i]); |
| 85 } | 83 } |
| 86 | 84 |
| 87 range_requests_.clear(); | 85 range_requests_.clear(); |
| 88 | 86 |
| 89 STLDeleteElements(&range_request_fetchers_); | 87 STLDeleteElements(&range_request_fetchers_); |
| 90 } | 88 } |
| 91 | 89 |
| 92 void PluginStreamUrl::WillSendRequest(const GURL& url, int http_status_code) { | 90 void PluginStreamUrl::WillSendRequest(const GURL& url, int http_status_code) { |
| 93 if (notify_needed()) { | |
| 94 // If the plugin participates in HTTP url redirect handling then notify it. | |
| 95 if (net::HttpResponseHeaders::IsRedirectResponseCode(http_status_code) && | |
| 96 instance()->handles_url_redirects()) { | |
| 97 pending_redirect_url_ = url.spec(); | |
| 98 instance()->NPP_URLRedirectNotify(url.spec().c_str(), http_status_code, | |
| 99 notify_data()); | |
| 100 return; | |
| 101 } | |
| 102 } | |
| 103 url_ = url; | 91 url_ = url; |
| 104 UpdateUrl(url.spec().c_str()); | 92 UpdateUrl(url.spec().c_str()); |
| 105 } | 93 } |
| 106 | 94 |
| 107 void PluginStreamUrl::DidReceiveResponse(const std::string& mime_type, | 95 void PluginStreamUrl::DidReceiveResponse(const std::string& mime_type, |
| 108 const std::string& headers, | 96 const std::string& headers, |
| 109 uint32 expected_length, | 97 uint32 expected_length, |
| 110 uint32 last_modified, | 98 uint32 last_modified, |
| 111 bool request_is_seekable) { | 99 bool request_is_seekable) { |
| 112 // Protect the stream against it being destroyed or the whole plugin instance | 100 // Protect the stream against it being destroyed or the whole plugin instance |
| (...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 208 } | 196 } |
| 209 | 197 |
| 210 void PluginStreamUrl::UpdateUrl(const char* url) { | 198 void PluginStreamUrl::UpdateUrl(const char* url) { |
| 211 DCHECK(!open()); | 199 DCHECK(!open()); |
| 212 free(const_cast<char*>(stream()->url)); | 200 free(const_cast<char*>(stream()->url)); |
| 213 stream()->url = base::strdup(url); | 201 stream()->url = base::strdup(url); |
| 214 pending_redirect_url_.clear(); | 202 pending_redirect_url_.clear(); |
| 215 } | 203 } |
| 216 | 204 |
| 217 } // namespace content | 205 } // namespace content |
| OLD | NEW |