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

Side by Side Diff: components/cronet/android/java/src/org/chromium/net/CronetLibraryLoader.java

Issue 1927863004: Revert of [Cronet] Avoid crashing when CronetEngines are created on multiple threads (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 7 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/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java » ('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 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 package org.chromium.net; 5 package org.chromium.net;
6 6
7 import android.content.Context; 7 import android.content.Context;
8 import android.os.Handler; 8 import android.os.Handler;
9 import android.os.Looper; 9 import android.os.Looper;
10 10
11 import org.chromium.base.ContextUtils; 11 import org.chromium.base.ContextUtils;
12 import org.chromium.base.Log; 12 import org.chromium.base.Log;
13 import org.chromium.base.annotations.JNINamespace; 13 import org.chromium.base.annotations.JNINamespace;
14 14
15 /** 15 /**
16 * CronetLibraryLoader loads and initializes native library on main thread. 16 * CronetLibraryLoader loads and initializes native library on main thread.
17 */ 17 */
18 @JNINamespace("cronet") 18 @JNINamespace("cronet")
19 class CronetLibraryLoader { 19 class CronetLibraryLoader {
20 // Synchronize initialization. 20 /**
21 * Synchronize access to sInitTaskPosted and initialization routine.
22 */
21 private static final Object sLoadLock = new Object(); 23 private static final Object sLoadLock = new Object();
22 private static final String TAG = "CronetLibraryLoader"; 24 private static final String TAG = "CronetLibraryLoader";
23 // Has library loading commenced? Setting guarded by sLoadLock. 25 private static boolean sInitTaskPosted = false;
24 private static volatile boolean sInitStarted = false;
25 // Has ensureMainThreadInitialized() completed? Only accessed on main threa d.
26 private static boolean sMainThreadInitDone = false;
27 26
28 /** 27 /**
29 * Ensure that native library is loaded and initialized. Can be called from 28 * Ensure that native library is loaded and initialized. Can be called from
30 * any thread, the load and initialization is performed on main thread. 29 * any thread, the load and initialization is performed on main thread.
31 */ 30 */
32 static void ensureInitialized(final Context context, final CronetEngine.Buil der builder) { 31 public static void ensureInitialized(
32 final Context context, final CronetEngine.Builder builder) {
33 synchronized (sLoadLock) { 33 synchronized (sLoadLock) {
34 if (sInitStarted) { 34 if (sInitTaskPosted) {
35 return; 35 return;
36 } 36 }
37 sInitStarted = true;
38 builder.loadLibrary(); 37 builder.loadLibrary();
39 if (!Version.CRONET_VERSION.equals(nativeGetCronetVersion())) { 38 if (!Version.CRONET_VERSION.equals(nativeGetCronetVersion())) {
40 throw new RuntimeException(String.format( 39 throw new RuntimeException(String.format(
41 "Expected Cronet version number %s, " 40 "Expected Cronet version number %s, "
42 + "actual version number %s.", 41 + "actual version number %s.",
43 Version.CRONET_VERSION, 42 Version.CRONET_VERSION,
44 nativeGetCronetVersion())); 43 nativeGetCronetVersion()));
45 } 44 }
46 Log.i(TAG, "Cronet version: %s, arch: %s", 45 Log.i(TAG, "Cronet version: %s, arch: %s",
47 Version.CRONET_VERSION, System.getProperty("os.arch")); 46 Version.CRONET_VERSION, System.getProperty("os.arch"));
48 ContextUtils.initApplicationContext(context.getApplicationContext()) ; 47 ContextUtils.initApplicationContext(context.getApplicationContext()) ;
49 // Init native Chromium CronetEngine on Main UI thread. 48 // Init native Chromium CronetEngine on Main UI thread.
50 Runnable task = new Runnable() { 49 Runnable task = new Runnable() {
51 public void run() { 50 public void run() {
52 ensureInitializedOnMainThread(context); 51 initOnMainThread(context);
53 } 52 }
54 }; 53 };
55 // Run task immediately or post it to the UI thread. 54 // Run task immediately or post it to the UI thread.
56 if (Looper.getMainLooper() == Looper.myLooper()) { 55 if (Looper.getMainLooper() == Looper.myLooper()) {
57 task.run(); 56 task.run();
58 } else { 57 } else {
59 // The initOnMainThread will complete on the main thread prior 58 // The initOnMainThread will complete on the main thread prior
60 // to other tasks posted to the main thread. 59 // to other tasks posted to the main thread.
61 new Handler(Looper.getMainLooper()).post(task); 60 new Handler(Looper.getMainLooper()).post(task);
62 } 61 }
62 sInitTaskPosted = true;
63 } 63 }
64 } 64 }
65 65
66 /** 66 private static void initOnMainThread(final Context context) {
67 * Ensure that the main thread initialization has completed. Can only be cal led from
68 * the main thread. Ensures that the NetworkChangeNotifier is initialzied an d the
69 * main thread native MessageLoop is initialized.
70 */
71 static void ensureInitializedOnMainThread(Context context) {
72 assert sInitStarted;
73 assert Looper.getMainLooper() == Looper.myLooper();
74 if (sMainThreadInitDone) {
75 return;
76 }
77 NetworkChangeNotifier.init(context); 67 NetworkChangeNotifier.init(context);
78 // Registers to always receive network notifications. Note 68 // Registers to always receive network notifications. Note
79 // that this call is fine for Cronet because Cronet 69 // that this call is fine for Cronet because Cronet
80 // embedders do not have API access to create network change 70 // embedders do not have API access to create network change
81 // observers. Existing observers in the net stack do not 71 // observers. Existing observers in the net stack do not
82 // perform expensive work. 72 // perform expensive work.
83 NetworkChangeNotifier.registerToReceiveNotificationsAlways(); 73 NetworkChangeNotifier.registerToReceiveNotificationsAlways();
84 // registerToReceiveNotificationsAlways() is called before the native 74 // registerToReceiveNotificationsAlways() is called before the native
85 // NetworkChangeNotifierAndroid is created, so as to avoid receiving 75 // NetworkChangeNotifierAndroid is created, so as to avoid receiving
86 // the undesired initial network change observer notification, which 76 // the undesired initial network change observer notification, which
87 // will cause active requests to fail with ERR_NETWORK_CHANGED. 77 // will cause active requests to fail with ERR_NETWORK_CHANGED.
88 nativeCronetInitOnMainThread(); 78 nativeCronetInitOnMainThread();
89 sMainThreadInitDone = true;
90 } 79 }
91 80
92 // Native methods are implemented in cronet_library_loader.cc. 81 // Native methods are implemented in cronet_library_loader.cc.
93 private static native void nativeCronetInitOnMainThread(); 82 private static native void nativeCronetInitOnMainThread();
94 private static native String nativeGetCronetVersion(); 83 private static native String nativeGetCronetVersion();
95 } 84 }
OLDNEW
« no previous file with comments | « no previous file | components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698