| 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/net_adapters.h" | 10 #include "content/common/net_adapters.h" |
| (...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 148 } | 148 } |
| 149 | 149 |
| 150 return base::MakeUnique<net::ElementsUploadDataStream>( | 150 return base::MakeUnique<net::ElementsUploadDataStream>( |
| 151 std::move(element_readers), body->identifier()); | 151 std::move(element_readers), body->identifier()); |
| 152 } | 152 } |
| 153 | 153 |
| 154 } // namespace | 154 } // namespace |
| 155 | 155 |
| 156 URLLoaderImpl::URLLoaderImpl( | 156 URLLoaderImpl::URLLoaderImpl( |
| 157 NetworkContext* context, | 157 NetworkContext* context, |
| 158 mojom::URLLoaderAssociatedRequest url_loader_request, | 158 mojom::URLLoaderRequest url_loader_request, |
| 159 int32_t options, | 159 int32_t options, |
| 160 const ResourceRequest& request, | 160 const ResourceRequest& request, |
| 161 mojom::URLLoaderClientPtr url_loader_client, | 161 mojom::URLLoaderClientPtr url_loader_client, |
| 162 const net::NetworkTrafficAnnotationTag& traffic_annotation) | 162 const net::NetworkTrafficAnnotationTag& traffic_annotation) |
| 163 : context_(context), | 163 : context_(context), |
| 164 options_(options), | 164 options_(options), |
| 165 connected_(true), | 165 connected_(true), |
| 166 binding_(this, std::move(url_loader_request)), | 166 binding_(this, std::move(url_loader_request)), |
| 167 url_loader_client_(std::move(url_loader_client)), | 167 url_loader_client_(std::move(url_loader_client)), |
| 168 writable_handle_watcher_(FROM_HERE, | 168 writable_handle_watcher_(FROM_HERE, |
| (...skipping 224 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 393 ReadMore(); | 393 ReadMore(); |
| 394 } | 394 } |
| 395 | 395 |
| 396 void URLLoaderImpl::DeleteIfNeeded() { | 396 void URLLoaderImpl::DeleteIfNeeded() { |
| 397 bool has_data_pipe = pending_write_.get() || response_body_stream_.is_valid(); | 397 bool has_data_pipe = pending_write_.get() || response_body_stream_.is_valid(); |
| 398 if (!connected_ && !has_data_pipe) | 398 if (!connected_ && !has_data_pipe) |
| 399 delete this; | 399 delete this; |
| 400 } | 400 } |
| 401 | 401 |
| 402 } // namespace content | 402 } // namespace content |
| OLD | NEW |