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

Side by Side Diff: components/cronet/android/cronet_url_request_adapter.cc

Issue 2334623003: Store net::ProxyServer in HttpResponseInfo object (Closed)
Patch Set: Rebased, addressed eroman comments Created 4 years, 2 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 | components/data_reduction_proxy/core/browser/data_reduction_proxy_bypass_protocol.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 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 "components/cronet/android/cronet_url_request_adapter.h" 5 #include "components/cronet/android/cronet_url_request_adapter.h"
6 6
7 #include <limits> 7 #include <limits>
8 #include <utility> 8 #include <utility>
9 #include <vector> 9 #include <vector>
10 10
11 #include "base/bind.h" 11 #include "base/bind.h"
12 #include "base/location.h" 12 #include "base/location.h"
13 #include "base/logging.h" 13 #include "base/logging.h"
14 #include "components/cronet/android/cronet_url_request_context_adapter.h" 14 #include "components/cronet/android/cronet_url_request_context_adapter.h"
15 #include "components/cronet/android/io_buffer_with_byte_buffer.h" 15 #include "components/cronet/android/io_buffer_with_byte_buffer.h"
16 #include "components/cronet/android/url_request_error.h" 16 #include "components/cronet/android/url_request_error.h"
17 #include "jni/CronetUrlRequest_jni.h" 17 #include "jni/CronetUrlRequest_jni.h"
18 #include "net/base/load_flags.h" 18 #include "net/base/load_flags.h"
19 #include "net/base/load_states.h" 19 #include "net/base/load_states.h"
20 #include "net/base/net_errors.h" 20 #include "net/base/net_errors.h"
21 #include "net/base/request_priority.h" 21 #include "net/base/request_priority.h"
22 #include "net/cert/cert_status_flags.h" 22 #include "net/cert/cert_status_flags.h"
23 #include "net/http/http_response_headers.h" 23 #include "net/http/http_response_headers.h"
24 #include "net/http/http_status_code.h" 24 #include "net/http/http_status_code.h"
25 #include "net/http/http_util.h" 25 #include "net/http/http_util.h"
26 #include "net/proxy/proxy_server.h"
26 #include "net/quic/core/quic_protocol.h" 27 #include "net/quic/core/quic_protocol.h"
27 #include "net/ssl/ssl_info.h" 28 #include "net/ssl/ssl_info.h"
28 #include "net/url_request/redirect_info.h" 29 #include "net/url_request/redirect_info.h"
29 #include "net/url_request/url_request_context.h" 30 #include "net/url_request/url_request_context.h"
30 31
31 using base::android::ConvertUTF8ToJavaString; 32 using base::android::ConvertUTF8ToJavaString;
32 using base::android::JavaParamRef; 33 using base::android::JavaParamRef;
33 34
34 namespace cronet { 35 namespace cronet {
35 36
(...skipping 173 matching lines...) Expand 10 before | Expand all | Expand 10 after
209 FROM_HERE, base::Bind(&CronetURLRequestAdapter::DestroyOnNetworkThread, 210 FROM_HERE, base::Bind(&CronetURLRequestAdapter::DestroyOnNetworkThread,
210 base::Unretained(this), jsend_on_canceled)); 211 base::Unretained(this), jsend_on_canceled));
211 } 212 }
212 213
213 void CronetURLRequestAdapter::OnReceivedRedirect( 214 void CronetURLRequestAdapter::OnReceivedRedirect(
214 net::URLRequest* request, 215 net::URLRequest* request,
215 const net::RedirectInfo& redirect_info, 216 const net::RedirectInfo& redirect_info,
216 bool* defer_redirect) { 217 bool* defer_redirect) {
217 DCHECK(context_->IsOnNetworkThread()); 218 DCHECK(context_->IsOnNetworkThread());
218 JNIEnv* env = base::android::AttachCurrentThread(); 219 JNIEnv* env = base::android::AttachCurrentThread();
220
221 const net::HostPortPair host_port_pair =
mmenke 2016/10/06 14:58:04 "host_port_pair" is too generic. proxy_host_port_
mmenke 2016/10/06 14:58:04 nit: Prevailing style is not to use const except
222 !request->response_info().proxy_server.is_valid() ||
223 request->response_info().proxy_server.is_direct()
224 ? net::HostPortPair()
225 : request->response_info().proxy_server.host_port_pair();
mmenke 2016/10/06 14:58:04 I think this would be a lot easier to read as: ne
219 cronet::Java_CronetUrlRequest_onRedirectReceived( 226 cronet::Java_CronetUrlRequest_onRedirectReceived(
220 env, owner_.obj(), 227 env, owner_.obj(),
221 ConvertUTF8ToJavaString(env, redirect_info.new_url.spec()).obj(), 228 ConvertUTF8ToJavaString(env, redirect_info.new_url.spec()).obj(),
222 redirect_info.status_code, 229 redirect_info.status_code,
223 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText()) 230 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText())
224 .obj(), 231 .obj(),
225 GetResponseHeaders(env).obj(), 232 GetResponseHeaders(env).obj(),
226 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE, 233 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE,
227 ConvertUTF8ToJavaString(env, 234 ConvertUTF8ToJavaString(env,
228 request->response_info().alpn_negotiated_protocol) 235 request->response_info().alpn_negotiated_protocol)
229 .obj(), 236 .obj(),
230 ConvertUTF8ToJavaString(env, 237 ConvertUTF8ToJavaString(env, host_port_pair.ToString()).obj(),
231 request->response_info().proxy_server.ToString())
232 .obj(),
233 request->GetTotalReceivedBytes()); 238 request->GetTotalReceivedBytes());
234 *defer_redirect = true; 239 *defer_redirect = true;
235 } 240 }
236 241
237 void CronetURLRequestAdapter::OnCertificateRequested( 242 void CronetURLRequestAdapter::OnCertificateRequested(
238 net::URLRequest* request, 243 net::URLRequest* request,
239 net::SSLCertRequestInfo* cert_request_info) { 244 net::SSLCertRequestInfo* cert_request_info) {
240 DCHECK(context_->IsOnNetworkThread()); 245 DCHECK(context_->IsOnNetworkThread());
241 // Cronet does not support client certificates. 246 // Cronet does not support client certificates.
242 request->ContinueWithCertificate(nullptr, nullptr); 247 request->ContinueWithCertificate(nullptr, nullptr);
(...skipping 17 matching lines...) Expand all
260 void CronetURLRequestAdapter::OnResponseStarted(net::URLRequest* request, 265 void CronetURLRequestAdapter::OnResponseStarted(net::URLRequest* request,
261 int net_error) { 266 int net_error) {
262 DCHECK_NE(net::ERR_IO_PENDING, net_error); 267 DCHECK_NE(net::ERR_IO_PENDING, net_error);
263 DCHECK(context_->IsOnNetworkThread()); 268 DCHECK(context_->IsOnNetworkThread());
264 269
265 if (net_error != net::OK) { 270 if (net_error != net::OK) {
266 ReportError(request, net_error); 271 ReportError(request, net_error);
267 return; 272 return;
268 } 273 }
269 JNIEnv* env = base::android::AttachCurrentThread(); 274 JNIEnv* env = base::android::AttachCurrentThread();
275 const net::HostPortPair host_port_pair =
276 !request->response_info().proxy_server.is_valid() ||
277 request->response_info().proxy_server.is_direct()
278 ? net::HostPortPair()
279 : request->response_info().proxy_server.host_port_pair();
mmenke 2016/10/06 14:58:04 Same comments as above...Or better, can we make a
270 cronet::Java_CronetUrlRequest_onResponseStarted( 280 cronet::Java_CronetUrlRequest_onResponseStarted(
271 env, owner_.obj(), request->GetResponseCode(), 281 env, owner_.obj(), request->GetResponseCode(),
272 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText()) 282 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText())
273 .obj(), 283 .obj(),
274 GetResponseHeaders(env).obj(), 284 GetResponseHeaders(env).obj(),
275 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE, 285 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE,
276 ConvertUTF8ToJavaString(env, 286 ConvertUTF8ToJavaString(env,
277 request->response_info().alpn_negotiated_protocol) 287 request->response_info().alpn_negotiated_protocol)
278 .obj(), 288 .obj(),
279 ConvertUTF8ToJavaString(env, 289 ConvertUTF8ToJavaString(env, host_port_pair.ToString()).obj());
280 request->response_info().proxy_server.ToString())
281 .obj());
282 } 290 }
283 291
284 void CronetURLRequestAdapter::OnReadCompleted(net::URLRequest* request, 292 void CronetURLRequestAdapter::OnReadCompleted(net::URLRequest* request,
285 int bytes_read) { 293 int bytes_read) {
286 DCHECK(context_->IsOnNetworkThread()); 294 DCHECK(context_->IsOnNetworkThread());
287 295
288 if (bytes_read < 0) { 296 if (bytes_read < 0) {
289 ReportError(request, bytes_read); 297 ReportError(request, bytes_read);
290 return; 298 return;
291 } 299 }
(...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after
432 ConvertTime(base::TimeTicks::Now(), start_ticks, start_time), 440 ConvertTime(base::TimeTicks::Now(), start_ticks, start_time),
433 // TODO(mgersh): report total bytes sent 441 // TODO(mgersh): report total bytes sent
434 metrics.socket_reused, 0, url_request_->GetTotalReceivedBytes()); 442 metrics.socket_reused, 0, url_request_->GetTotalReceivedBytes());
435 } 443 }
436 444
437 net::URLRequest* CronetURLRequestAdapter::GetURLRequestForTesting() { 445 net::URLRequest* CronetURLRequestAdapter::GetURLRequestForTesting() {
438 return url_request_.get(); 446 return url_request_.get();
439 } 447 }
440 448
441 } // namespace cronet 449 } // namespace cronet
OLDNEW
« no previous file with comments | « no previous file | components/data_reduction_proxy/core/browser/data_reduction_proxy_bypass_protocol.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698