| Index: components/cronet/android/cronet_url_request.cc
|
| diff --git a/components/cronet/android/cronet_url_request.cc b/components/cronet/android/cronet_url_request.cc
|
| deleted file mode 100644
|
| index 04489bfce73fe7c108f2c4ee7517424f609f2fac..0000000000000000000000000000000000000000
|
| --- a/components/cronet/android/cronet_url_request.cc
|
| +++ /dev/null
|
| @@ -1,293 +0,0 @@
|
| -// Copyright 2014 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "components/cronet/android/cronet_url_request.h"
|
| -
|
| -#include "base/android/jni_android.h"
|
| -#include "base/android/jni_string.h"
|
| -#include "base/android/scoped_java_ref.h"
|
| -#include "base/logging.h"
|
| -#include "base/macros.h"
|
| -#include "components/cronet/android/cronet_url_request_adapter.h"
|
| -#include "components/cronet/android/cronet_url_request_context_adapter.h"
|
| -#include "jni/CronetUrlRequest_jni.h"
|
| -#include "net/base/net_errors.h"
|
| -#include "net/base/request_priority.h"
|
| -#include "net/http/http_response_headers.h"
|
| -#include "net/http/http_util.h"
|
| -
|
| -using base::android::ConvertUTF8ToJavaString;
|
| -
|
| -// This file contains all the plumbing to handle the bidirectional communication
|
| -// between the Java CronetURLRequest and C++ CronetURLRequestAdapter.
|
| -
|
| -namespace cronet {
|
| -namespace {
|
| -
|
| -// A delegate of CronetURLRequestAdapter that delivers callbacks to the Java
|
| -// layer. Created on a Java thread, but always called and destroyed on the
|
| -// Network thread.
|
| -class JniCronetURLRequestAdapterDelegate
|
| - : public CronetURLRequestAdapter::CronetURLRequestAdapterDelegate {
|
| - public:
|
| - JniCronetURLRequestAdapterDelegate(JNIEnv* env, jobject owner) {
|
| - owner_.Reset(env, owner);
|
| - }
|
| -
|
| - // CronetURLRequestAdapter::CronetURLRequestAdapterDelegate implementation.
|
| -
|
| - void OnRedirect(const GURL& new_location, int http_status_code) override {
|
| - JNIEnv* env = base::android::AttachCurrentThread();
|
| - cronet::Java_CronetUrlRequest_onRedirect(
|
| - env,
|
| - owner_.obj(),
|
| - ConvertUTF8ToJavaString(env, new_location.spec()).obj(),
|
| - http_status_code);
|
| - }
|
| -
|
| - void OnResponseStarted(int http_status_code) override {
|
| - JNIEnv* env = base::android::AttachCurrentThread();
|
| - cronet::Java_CronetUrlRequest_onResponseStarted(env,
|
| - owner_.obj(),
|
| - http_status_code);
|
| - }
|
| -
|
| - void OnBytesRead(unsigned char* bytes,
|
| - int bytes_read) override {
|
| - JNIEnv* env = base::android::AttachCurrentThread();
|
| - base::android::ScopedJavaLocalRef<jobject> java_buffer(
|
| - env, env->NewDirectByteBuffer(bytes, bytes_read));
|
| - cronet::Java_CronetUrlRequest_onDataReceived(
|
| - env, owner_.obj(), java_buffer.obj());
|
| - }
|
| -
|
| - void OnRequestFinished() override {
|
| - JNIEnv* env = base::android::AttachCurrentThread();
|
| - cronet::Java_CronetUrlRequest_onSucceeded(env, owner_.obj());
|
| - }
|
| -
|
| - void OnError(int net_error) override {
|
| - JNIEnv* env = base::android::AttachCurrentThread();
|
| - cronet::Java_CronetUrlRequest_onError(
|
| - env,
|
| - owner_.obj(),
|
| - net_error,
|
| - ConvertUTF8ToJavaString(env, net::ErrorToString(net_error)).obj());
|
| - }
|
| -
|
| - private:
|
| - ~JniCronetURLRequestAdapterDelegate() override {
|
| - }
|
| -
|
| - // Java object that owns the CronetURLRequestContextAdapter, which owns this
|
| - // delegate.
|
| - base::android::ScopedJavaGlobalRef<jobject> owner_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(JniCronetURLRequestAdapterDelegate);
|
| -};
|
| -
|
| -} // namespace
|
| -
|
| -// Explicitly register static JNI functions.
|
| -bool CronetUrlRequestRegisterJni(JNIEnv* env) {
|
| - return RegisterNativesImpl(env);
|
| -}
|
| -
|
| -static jlong CreateRequestAdapter(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_context_adapter,
|
| - jstring jurl_string,
|
| - jint jpriority) {
|
| - CronetURLRequestContextAdapter* context_adapter =
|
| - reinterpret_cast<CronetURLRequestContextAdapter*>(
|
| - jurl_request_context_adapter);
|
| - DCHECK(context_adapter);
|
| -
|
| - GURL url(base::android::ConvertJavaStringToUTF8(env, jurl_string));
|
| -
|
| - VLOG(1) << "New chromium network request_adapter: "
|
| - << url.possibly_invalid_spec();
|
| -
|
| - scoped_ptr<CronetURLRequestAdapter::CronetURLRequestAdapterDelegate> delegate(
|
| - new JniCronetURLRequestAdapterDelegate(env, jurl_request));
|
| -
|
| - CronetURLRequestAdapter* adapter = new CronetURLRequestAdapter(
|
| - context_adapter,
|
| - delegate.Pass(),
|
| - url,
|
| - static_cast<net::RequestPriority>(jpriority));
|
| -
|
| - return reinterpret_cast<jlong>(adapter);
|
| -}
|
| -
|
| -static jboolean SetHttpMethod(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter,
|
| - jstring jmethod) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - std::string method(base::android::ConvertJavaStringToUTF8(env, jmethod));
|
| - // Http method is a token, just as header name.
|
| - if (!net::HttpUtil::IsValidHeaderName(method))
|
| - return JNI_FALSE;
|
| - request_adapter->set_method(method);
|
| - return JNI_TRUE;
|
| -}
|
| -
|
| -static jboolean AddHeader(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter,
|
| - jstring jname,
|
| - jstring jvalue) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - std::string name(base::android::ConvertJavaStringToUTF8(env, jname));
|
| - std::string value(base::android::ConvertJavaStringToUTF8(env, jvalue));
|
| - if (!net::HttpUtil::IsValidHeaderName(name) ||
|
| - !net::HttpUtil::IsValidHeaderValue(value)) {
|
| - return JNI_FALSE;
|
| - }
|
| - request_adapter->AddRequestHeader(name, value);
|
| - return JNI_TRUE;
|
| -}
|
| -
|
| -static void Start(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - request_adapter->PostTaskToNetworkThread(
|
| - FROM_HERE,
|
| - base::Bind(&CronetURLRequestAdapter::Start,
|
| - base::Unretained(request_adapter)));
|
| -}
|
| -
|
| -static void DestroyRequestAdapter(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - request_adapter->PostTaskToNetworkThread(
|
| - FROM_HERE,
|
| - base::Bind(&CronetURLRequestAdapter::Destroy,
|
| - base::Unretained(request_adapter)));
|
| -}
|
| -
|
| -static void ReceiveData(JNIEnv* env,
|
| - jobject jcaller,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - request_adapter->PostTaskToNetworkThread(
|
| - FROM_HERE,
|
| - base::Bind(&CronetURLRequestAdapter::ReadData,
|
| - base::Unretained(request_adapter)));
|
| -}
|
| -
|
| -static void FollowDeferredRedirect(JNIEnv* env,
|
| - jobject jcaller,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - request_adapter->PostTaskToNetworkThread(
|
| - FROM_HERE,
|
| - base::Bind(&CronetURLRequestAdapter::FollowDeferredRedirect,
|
| - base::Unretained(request_adapter)));
|
| -}
|
| -
|
| -static void DisableCache(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(!request_adapter->IsOnNetworkThread());
|
| - request_adapter->DisableCache();
|
| -}
|
| -
|
| -static void PopulateResponseHeaders(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter,
|
| - jobject jheaders_list) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(request_adapter->IsOnNetworkThread());
|
| -
|
| - const net::HttpResponseHeaders* headers =
|
| - request_adapter->GetResponseHeaders();
|
| - if (headers == nullptr)
|
| - return;
|
| -
|
| - void* iter = nullptr;
|
| - std::string header_name;
|
| - std::string header_value;
|
| - while (headers->EnumerateHeaderLines(&iter, &header_name, &header_value)) {
|
| - ScopedJavaLocalRef<jstring> name =
|
| - ConvertUTF8ToJavaString(env, header_name);
|
| - ScopedJavaLocalRef<jstring> value =
|
| - ConvertUTF8ToJavaString(env, header_value);
|
| - Java_CronetUrlRequest_onAppendResponseHeader(
|
| - env, jurl_request, jheaders_list, name.obj(), value.obj());
|
| - }
|
| -}
|
| -
|
| -static jstring GetNegotiatedProtocol(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(request_adapter->IsOnNetworkThread());
|
| - return ConvertUTF8ToJavaString(
|
| - env, request_adapter->GetNegotiatedProtocol()).Release();
|
| -}
|
| -
|
| -static jboolean GetWasCached(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(request_adapter->IsOnNetworkThread());
|
| - return request_adapter->GetWasCached() ? JNI_TRUE : JNI_FALSE;
|
| -}
|
| -
|
| -static jlong GetTotalReceivedBytes(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(request_adapter->IsOnNetworkThread());
|
| - return request_adapter->GetTotalReceivedBytes();
|
| -}
|
| -
|
| -static jstring GetHttpStatusText(JNIEnv* env,
|
| - jobject jurl_request,
|
| - jlong jurl_request_adapter) {
|
| - DCHECK(jurl_request_adapter);
|
| - CronetURLRequestAdapter* request_adapter =
|
| - reinterpret_cast<CronetURLRequestAdapter*>(jurl_request_adapter);
|
| - DCHECK(request_adapter->IsOnNetworkThread());
|
| - const net::HttpResponseHeaders* headers =
|
| - request_adapter->GetResponseHeaders();
|
| - if (headers == NULL)
|
| - return ConvertUTF8ToJavaString(env, "").Release();
|
| - return ConvertUTF8ToJavaString(env, headers->GetStatusText()).Release();
|
| -}
|
| -
|
| -} // namespace cronet
|
|
|