| 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 |