Initial upload of cronet for Android.

net/cronet/android/org_chromium_net_UrlRequestContext.cc

+// 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 "net/cronet/android/org_chromium_net_UrlRequestContext.h"
+
+#include <stdio.h>
+
+#include "base/android/base_jni_registrar.h"
+#include "base/android/jni_android.h"
+#include "base/android/jni_registrar.h"
+#include "base/at_exit.h"
+#include "base/i18n/icu_util.h"
+#include "net/android/net_jni_registrar.h"
+#include "net/cronet/android/org_chromium_net_UrlRequest.h"
+#include "net/cronet/android/url_request_context_peer.h"
+#include "net/cronet/android/url_request_peer.h"
+
+// Version of this build of Chromium NET.
+#define CHROMIUM_NET_VERSION "1"
+
+static const char kVersion[] = CHROMIUM_VERSION "/" CHROMIUM_NET_VERSION;
+
+static jclass g_class;
+static jmethodID g_method_initNetworkThread;
+static jfieldID g_field_mRequestContext;

[mmenke, 2014/02/27 23:06:02]

fix names / anonymous namespace

[mef, 2014/03/03 19:15:13]

Done.

+
+static base::AtExitManager* s_at_exit_manager = NULL;

[mmenke, 2014/02/27 23:06:02]

Suggest using a g_ prefix for consistency with above.  We should see if we can
get rid of these globals, but not in this CL.

[mef, 2014/03/03 19:15:13]

Done.

+
+/*
+ * Checks the available version of JNI. Also, caches Java reflection artifacts.
+ */

[mmenke, 2014/02/27 23:06:02]

C++ style comments

[mef, 2014/03/03 19:15:13]

Done.

+jint JNI_OnLoad(JavaVM* vm, void* reserved) {
+  JNIEnv* env;
+  if (vm->GetEnv(reinterpret_cast<void**>(&env), JNI_VERSION_1_6) != JNI_OK) {
+    return -1;
+  }
+
+  const char* class_name = "org/chromium/net/UrlRequestContext";

[mmenke, 2014/02/27 23:06:02]

Seems like this should be "const char kClassName[]".  May also want to move it
to the anonymous namespace up top, given its importance.

[mef, 2014/03/03 19:15:13]

Done.

+  g_class = (jclass) env->NewGlobalRef(env->FindClass(class_name));
+  g_method_initNetworkThread =
+      env->GetMethodID(g_class, "initNetworkThread", "()V");
+  g_field_mRequestContext =
+      env->GetFieldID(g_class, "mRequestContext", "J");
+  if (!g_class || !g_method_initNetworkThread || !g_field_mRequestContext) {
+    return -1;
+  }
+
+  base::android::InitVM(vm);
+
+  if (!base::android::RegisterJni(env)) {
+    return -1;
+  }
+
+  if (!UrlRequestRegisterJni(env)) {
+    return -1;
+  }
+
+  if (!net::android::RegisterJni(env)) {
+    return -1;
+  }
+
+  s_at_exit_manager = new base::AtExitManager();
+
+  base::i18n::InitializeICU();
+
+  return JNI_VERSION_1_6;
+}
+
+JNIEnv* GetEnv(JavaVM* vm) {
+  // We need to make sure this native thread is attached to the JVM before
+  // we can call any Java methods.
+  JNIEnv* env;
+  if (vm->GetEnv(reinterpret_cast<void **>(&env), JNI_VERSION_1_6)
+      == JNI_EDETACHED) {

[mmenke, 2014/02/27 23:06:02]

nit:  "==" on previous line.

[mef, 2014/03/03 19:15:13]

Done.

+    vm->AttachCurrentThread(&env, NULL);
+  }
+  return env;
+}
+
+/*
+ * Delegate of URLRequestContextPeer that delivers callbacks to the Java layer.
+ */

[mmenke, 2014/02/27 23:06:02]

C++-style comment?

[mef, 2014/03/03 19:15:13]

Done.

+class JniURLRequestContextPeerDelegate :

[mmenke, 2014/02/27 23:06:02]

Move into an anonymous namespace?

[mef, 2014/03/03 19:15:13]

Done.

+    public URLRequestContextPeer::URLRequestContextPeerDelegate {
+  jobject owner_;
+  JavaVM* vm_;

[mmenke, 2014/02/27 23:06:02]

These should go at bottom of class, in aa private section.

[mef, 2014/03/03 19:15:13]

Done.

+
+ public:
+  JniURLRequestContextPeerDelegate(JNIEnv* env, jobject owner) {
+    owner_ = env->NewGlobalRef(owner);

[mmenke, 2014/02/27 23:06:02]

This can be set in an initializer list.

[mef, 2014/03/03 19:15:13]

Done.

+
+    env->GetJavaVM(&vm_);
+  }
+
+  virtual void OnContextInitialized(URLRequestContextPeer* context) OVERRIDE {
+    JNIEnv* env = GetEnv(vm_);
+    env->CallVoidMethod(owner_, g_method_initNetworkThread);
+    if (env->ExceptionOccurred()) {
+      env->ExceptionDescribe();
+      env->ExceptionClear();
+    }
+
+    // TODO(dplotnikov): figure out if we need to detach from the thread.
+    // The documentation says we should detach just before the thread exits.
+  }
+
+ protected:
+  virtual ~JniURLRequestContextPeerDelegate() {
+    GetEnv(vm_)->DeleteGlobalRef(owner_);
+  }
+};
+
+/*
+ * Stores a reference to the peer in a java field.
+ */
+static void SetNativeObject(JNIEnv *env, jobject object,
+                            URLRequestContextPeer* peer) {
+  env->SetLongField(object, g_field_mRequestContext,
+                    reinterpret_cast<jlong>(peer));
+}
+
+/*
+ * Returns a reference to the peer, which is stored in a field of
+ * the java object.
+ */
+static URLRequestContextPeer* GetNativeObject(JNIEnv* env, jobject object) {

[mmenke, 2014/02/27 23:06:02]

Move these into an anonymous namespace?

[mef, 2014/03/03 19:15:13]

Done.

+  return reinterpret_cast<URLRequestContextPeer *>(
+      env->GetLongField(object, g_field_mRequestContext));
+}
+
+URLRequestContextPeer* GetURLRequestContextPeer(JNIEnv* env,
+                                                jobject request_context) {
+  return GetNativeObject(env, request_context);
+}
+
+JNIEXPORT jstring JNICALL
+Java_org_chromium_net_UrlRequestContext_getVersion(
+    JNIEnv* env, jobject object) {
+  return env->NewStringUTF(kVersion);
+}
+
+/*
+ * Sets global user-agent to be used for all subsequent requests.
+ */
+JNIEXPORT void JNICALL
+Java_org_chromium_net_UrlRequestContext_nativeInitialize(
+    JNIEnv* env,
+    jobject object,
+    jobject context,
+    jstring user_agent,
+    jint log_level) {
+  const char *user_agent_utf8 = env->GetStringUTFChars(user_agent, NULL);
+  std::string user_agent_string(user_agent_utf8);
+  env->ReleaseStringUTFChars(user_agent, user_agent_utf8);
+
+  // Set application context

[mmenke, 2014/02/27 23:06:02]

Comments should end in periods, here and below.

[mef, 2014/03/03 19:15:13]

Done.

+  base::android::ScopedJavaLocalRef<jobject> scoped_context(env, context);
+  base::android::InitApplicationContext(env, scoped_context);
+
+  int logging_level = log_level;
+
+  // TODO(dplotnikov): set application context
+  URLRequestContextPeer* peer = new URLRequestContextPeer(
+      new JniURLRequestContextPeerDelegate(env, object), user_agent_string,
+      logging_level, kVersion);
+  peer->AddRef();  // Hold onto this ref-counted object.
+
+  SetNativeObject(env, object, peer);
+
+  peer->Initialize();
+}
+
+/*
+ * Releases native objects.
+ */
+JNIEXPORT void JNICALL
+Java_org_chromium_net_UrlRequestContext_nativeFinalize(
+    JNIEnv* env, jobject object) {
+  // URLRequestContextPeer is a ref-counted object, so we need to release it
+  // instead of deleting outright.
+  GetNativeObject(env, object)->Release();
+  SetNativeObject(env, object, NULL);
+}