Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(219)

Side by Side Diff: content/browser/webui/url_data_manager_backend.cc

Issue 1273813005: Revert of Fix cancellation of a pair of URLRequestJob subclasses (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « no previous file | content/browser/webui/url_data_manager_backend_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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/browser/webui/url_data_manager_backend.h" 5 #include "content/browser/webui/url_data_manager_backend.h"
6 6
7 #include <set> 7 #include <set>
8 8
9 #include "base/basictypes.h" 9 #include "base/basictypes.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
104 headers.GetHeader(net::HttpRequestHeaders::kOrigin, &result); 104 headers.GetHeader(net::HttpRequestHeaders::kOrigin, &result);
105 return result; 105 return result;
106 } 106 }
107 107
108 } // namespace 108 } // namespace
109 109
110 // URLRequestChromeJob is a net::URLRequestJob that manages running 110 // URLRequestChromeJob is a net::URLRequestJob that manages running
111 // chrome-internal resource requests asynchronously. 111 // chrome-internal resource requests asynchronously.
112 // It hands off URL requests to ChromeURLDataManager, which asynchronously 112 // It hands off URL requests to ChromeURLDataManager, which asynchronously
113 // calls back once the data is available. 113 // calls back once the data is available.
114 class URLRequestChromeJob : public net::URLRequestJob { 114 class URLRequestChromeJob : public net::URLRequestJob,
115 public base::SupportsWeakPtr<URLRequestChromeJob> {
115 public: 116 public:
116 // |is_incognito| set when job is generated from an incognito profile. 117 // |is_incognito| set when job is generated from an incognito profile.
117 URLRequestChromeJob(net::URLRequest* request, 118 URLRequestChromeJob(net::URLRequest* request,
118 net::NetworkDelegate* network_delegate, 119 net::NetworkDelegate* network_delegate,
119 URLDataManagerBackend* backend, 120 URLDataManagerBackend* backend,
120 bool is_incognito); 121 bool is_incognito);
121 122
122 // net::URLRequestJob implementation. 123 // net::URLRequestJob implementation.
123 void Start() override; 124 void Start() override;
124 void Kill() override; 125 void Kill() override;
125 bool ReadRawData(net::IOBuffer* buf, int buf_size, int* bytes_read) override; 126 bool ReadRawData(net::IOBuffer* buf, int buf_size, int* bytes_read) override;
126 bool GetMimeType(std::string* mime_type) const override; 127 bool GetMimeType(std::string* mime_type) const override;
127 int GetResponseCode() const override; 128 int GetResponseCode() const override;
128 void GetResponseInfo(net::HttpResponseInfo* info) override; 129 void GetResponseInfo(net::HttpResponseInfo* info) override;
129 130
130 // Used to notify that the requested data's |mime_type| is ready. 131 // Used to notify that the requested data's |mime_type| is ready.
131 void MimeTypeAvailable(const std::string& mime_type); 132 void MimeTypeAvailable(const std::string& mime_type);
132 133
133 // Called by ChromeURLDataManager to notify us that the data blob is ready 134 // Called by ChromeURLDataManager to notify us that the data blob is ready
134 // for us. 135 // for us.
135 void DataAvailable(base::RefCountedMemory* bytes); 136 void DataAvailable(base::RefCountedMemory* bytes);
136 137
137 // Returns a weak pointer to the job.
138 base::WeakPtr<URLRequestChromeJob> AsWeakPtr();
139
140 void set_mime_type(const std::string& mime_type) { 138 void set_mime_type(const std::string& mime_type) {
141 mime_type_ = mime_type; 139 mime_type_ = mime_type;
142 } 140 }
143 141
144 void set_allow_caching(bool allow_caching) { 142 void set_allow_caching(bool allow_caching) {
145 allow_caching_ = allow_caching; 143 allow_caching_ = allow_caching;
146 } 144 }
147 145
148 void set_add_content_security_policy(bool add_content_security_policy) { 146 void set_add_content_security_policy(bool add_content_security_policy) {
149 add_content_security_policy_ = add_content_security_policy; 147 add_content_security_policy_ = add_content_security_policy;
(...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after
262 void URLRequestChromeJob::Start() { 260 void URLRequestChromeJob::Start() {
263 int render_process_id, unused; 261 int render_process_id, unused;
264 bool is_renderer_request = ResourceRequestInfo::GetRenderFrameForRequest( 262 bool is_renderer_request = ResourceRequestInfo::GetRenderFrameForRequest(
265 request_, &render_process_id, &unused); 263 request_, &render_process_id, &unused);
266 if (!is_renderer_request) 264 if (!is_renderer_request)
267 render_process_id = kNoRenderProcessId; 265 render_process_id = kNoRenderProcessId;
268 BrowserThread::PostTask( 266 BrowserThread::PostTask(
269 BrowserThread::UI, 267 BrowserThread::UI,
270 FROM_HERE, 268 FROM_HERE,
271 base::Bind(&URLRequestChromeJob::CheckStoragePartitionMatches, 269 base::Bind(&URLRequestChromeJob::CheckStoragePartitionMatches,
272 render_process_id, request_->url(), 270 render_process_id, request_->url(), AsWeakPtr()));
273 weak_factory_.GetWeakPtr()));
274 TRACE_EVENT_ASYNC_BEGIN1("browser", "DataManager:Request", this, "URL", 271 TRACE_EVENT_ASYNC_BEGIN1("browser", "DataManager:Request", this, "URL",
275 request_->url().possibly_invalid_spec()); 272 request_->url().possibly_invalid_spec());
276 } 273 }
277 274
278 void URLRequestChromeJob::Kill() { 275 void URLRequestChromeJob::Kill() {
279 weak_factory_.InvalidateWeakPtrs();
280 backend_->RemoveRequest(this); 276 backend_->RemoveRequest(this);
281 URLRequestJob::Kill();
282 } 277 }
283 278
284 bool URLRequestChromeJob::GetMimeType(std::string* mime_type) const { 279 bool URLRequestChromeJob::GetMimeType(std::string* mime_type) const {
285 *mime_type = mime_type_; 280 *mime_type = mime_type_;
286 return !mime_type_.empty(); 281 return !mime_type_.empty();
287 } 282 }
288 283
289 int URLRequestChromeJob::GetResponseCode() const { 284 int URLRequestChromeJob::GetResponseCode() const {
290 return net::HTTP_OK; 285 return net::HTTP_OK;
291 } 286 }
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after
347 pending_buf_ = NULL; 342 pending_buf_ = NULL;
348 NotifyReadComplete(bytes_read); 343 NotifyReadComplete(bytes_read);
349 } 344 }
350 } else { 345 } else {
351 // The request failed. 346 // The request failed.
352 NotifyDone(net::URLRequestStatus(net::URLRequestStatus::FAILED, 347 NotifyDone(net::URLRequestStatus(net::URLRequestStatus::FAILED,
353 net::ERR_FAILED)); 348 net::ERR_FAILED));
354 } 349 }
355 } 350 }
356 351
357 base::WeakPtr<URLRequestChromeJob> URLRequestChromeJob::AsWeakPtr() {
358 return weak_factory_.GetWeakPtr();
359 }
360
361 bool URLRequestChromeJob::ReadRawData(net::IOBuffer* buf, int buf_size, 352 bool URLRequestChromeJob::ReadRawData(net::IOBuffer* buf, int buf_size,
362 int* bytes_read) { 353 int* bytes_read) {
363 if (!data_.get()) { 354 if (!data_.get()) {
364 SetStatus(net::URLRequestStatus(net::URLRequestStatus::IO_PENDING, 0)); 355 SetStatus(net::URLRequestStatus(net::URLRequestStatus::IO_PENDING, 0));
365 DCHECK(!pending_buf_.get()); 356 DCHECK(!pending_buf_.get());
366 CHECK(buf->data()); 357 CHECK(buf->data());
367 pending_buf_ = buf; 358 pending_buf_ = buf;
368 pending_buf_size_ = buf_size; 359 pending_buf_size_ = buf_size;
369 return false; // Tell the caller we're still waiting for data. 360 return false; // Tell the caller we're still waiting for data.
370 } 361 }
(...skipping 402 matching lines...) Expand 10 before | Expand all | Expand 10 after
773 764
774 } // namespace 765 } // namespace
775 766
776 net::URLRequestJobFactory::ProtocolHandler* 767 net::URLRequestJobFactory::ProtocolHandler*
777 CreateDevToolsProtocolHandler(content::ResourceContext* resource_context, 768 CreateDevToolsProtocolHandler(content::ResourceContext* resource_context,
778 bool is_incognito) { 769 bool is_incognito) {
779 return new DevToolsJobFactory(resource_context, is_incognito); 770 return new DevToolsJobFactory(resource_context, is_incognito);
780 } 771 }
781 772
782 } // namespace content 773 } // namespace content
OLDNEW
« no previous file with comments | « no previous file | content/browser/webui/url_data_manager_backend_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698