OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 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/network/url_loader_impl.h" | 5 #include "content/network/url_loader_impl.h" |
6 | 6 |
7 #include "base/task_scheduler/post_task.h" | 7 #include "base/task_scheduler/post_task.h" |
8 #include "base/threading/thread_task_runner_handle.h" | 8 #include "base/threading/thread_task_runner_handle.h" |
9 #include "base/time/time.h" | 9 #include "base/time/time.h" |
10 #include "content/common/url_loader_factory.mojom.h" | 10 #include "content/common/url_loader_factory.mojom.h" |
(...skipping 171 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
182 Referrer::SetReferrerForRequest(url_request_.get(), referrer); | 182 Referrer::SetReferrerForRequest(url_request_.get(), referrer); |
183 | 183 |
184 net::HttpRequestHeaders headers; | 184 net::HttpRequestHeaders headers; |
185 headers.AddHeadersFromString(request.headers); | 185 headers.AddHeadersFromString(request.headers); |
186 url_request_->SetExtraRequestHeaders(headers); | 186 url_request_->SetExtraRequestHeaders(headers); |
187 | 187 |
188 // Resolve elements from request_body and prepare upload data. | 188 // Resolve elements from request_body and prepare upload data. |
189 if (request.request_body.get()) { | 189 if (request.request_body.get()) { |
190 scoped_refptr<base::SequencedTaskRunner> task_runner = | 190 scoped_refptr<base::SequencedTaskRunner> task_runner = |
191 base::CreateSequencedTaskRunnerWithTraits( | 191 base::CreateSequencedTaskRunnerWithTraits( |
192 base::TaskTraits().MayBlock().WithPriority( | 192 {base::MayBlock(), base::TaskPriority::USER_VISIBLE}); |
193 base::TaskPriority::USER_VISIBLE)); | |
194 url_request_->set_upload( | 193 url_request_->set_upload( |
195 CreateUploadDataStream(request.request_body.get(), task_runner.get())); | 194 CreateUploadDataStream(request.request_body.get(), task_runner.get())); |
196 } | 195 } |
197 | 196 |
198 int load_flags = BuildLoadFlagsForRequest(request, false); | 197 int load_flags = BuildLoadFlagsForRequest(request, false); |
199 url_request_->SetLoadFlags(load_flags); | 198 url_request_->SetLoadFlags(load_flags); |
200 | 199 |
201 url_request_->Start(); | 200 url_request_->Start(); |
202 } | 201 } |
203 | 202 |
(...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
404 ReadMore(); | 403 ReadMore(); |
405 } | 404 } |
406 | 405 |
407 void URLLoaderImpl::DeleteIfNeeded() { | 406 void URLLoaderImpl::DeleteIfNeeded() { |
408 bool has_data_pipe = pending_write_.get() || response_body_stream_.is_valid(); | 407 bool has_data_pipe = pending_write_.get() || response_body_stream_.is_valid(); |
409 if (!connected_ && !has_data_pipe) | 408 if (!connected_ && !has_data_pipe) |
410 delete this; | 409 delete this; |
411 } | 410 } |
412 | 411 |
413 } // namespace content | 412 } // namespace content |
OLD | NEW |