Chromium Code Reviews| OLD | NEW |
|---|---|
| 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 Loading... | |
| 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 Loading... | |
| 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 Loading... | |
| 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 |
| OLD | NEW |