Revert "Fix race conditions in NetworkMonitor."

This reverts commit 1f4cb9f22d87287cec331c4713c6969da50d8bd6.

Reason for revert: Suspect this CL break downstream projects.

Original change's description:
> Fix race conditions in NetworkMonitor.
> This change makes the class thread-safe.
> 
> Bug: b/73773043
> Change-Id: I1ad13e4f15907e3dd1fef1307f9c654e53b69b22
> Reviewed-on: https://webrtc-review.googlesource.com/57040
> Commit-Queue: Honghai Zhang <honghaiz@webrtc.org>
> Reviewed-by: Sami Kalliomäki <sakal@webrtc.org>
> Cr-Commit-Position: refs/heads/master@{#22238}

TBR=sakal@webrtc.org,pthatcher@webrtc.org,honghaiz@webrtc.org

Change-Id: I549fa2ad50a414693682fb66584affd62036a09d
No-Presubmit: true
No-Tree-Checks: true
No-Try: true
Bug: b/73773043
Reviewed-on: https://webrtc-review.googlesource.com/59120
Reviewed-by: Philip Eliasson <philipel@webrtc.org>
Commit-Queue: Philip Eliasson <philipel@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#22246}
This commit is contained in:
Philip Eliasson
2018-03-01 10:36:11 +00:00
committed by Commit Bot
parent e88b04fab1
commit b12e434d4c

View File

@ -20,12 +20,12 @@ import org.webrtc.NetworkMonitorAutoDetect.ConnectionType;
import org.webrtc.NetworkMonitorAutoDetect.NetworkInformation;
/**
* Borrowed from Chromium's
* src/net/android/java/src/org/chromium/net/NetworkChangeNotifier.java
* Borrowed from Chromium's src/net/android/java/src/org/chromium/net/NetworkChangeNotifier.java
*
* <p>Triggers updates to the underlying network state from OS networking events.
*
* <p>This class is thread-safe.
* <p>Thread-safety is ensured for methods that may be called from both native code and java code,
* including getInstance(), startMonitoring(), and stopMonitoring().
*/
public class NetworkMonitor {
/**
@ -54,13 +54,12 @@ public class NetworkMonitor {
// Also guarded by autoDetectorLock.
private int numMonitors;
private volatile ConnectionType currentConnectionType;
private ConnectionType currentConnectionType = ConnectionType.CONNECTION_UNKNOWN;
private NetworkMonitor() {
nativeNetworkObservers = new ArrayList<Long>();
networkObservers = new ArrayList<NetworkObserver>();
numMonitors = 0;
currentConnectionType = ConnectionType.CONNECTION_UNKNOWN;
}
// TODO(sakal): Remove once downstream dependencies have been updated.
@ -112,9 +111,7 @@ public class NetworkMonitor {
startMonitoring();
// The native observers expect a network list update after they call startMonitoring.
synchronized (nativeNetworkObservers) {
nativeNetworkObservers.add(nativeObserver);
}
nativeNetworkObservers.add(nativeObserver);
updateObserverActiveNetworkList(nativeObserver);
// currentConnectionType was updated in startMonitoring().
// Need to notify the native observers here.
@ -135,9 +132,7 @@ public class NetworkMonitor {
private void stopMonitoring(long nativeObserver) {
Logging.d(TAG, "Stop monitoring with native observer " + nativeObserver);
stopMonitoring();
synchronized (nativeNetworkObservers) {
nativeNetworkObservers.remove(nativeObserver);
}
nativeNetworkObservers.remove(nativeObserver);
}
// Returns true if network binding is supported on this platform.
@ -190,35 +185,23 @@ public class NetworkMonitor {
/** Alerts all observers of a connection change. */
private void notifyObserversOfConnectionTypeChange(ConnectionType newConnectionType) {
synchronized (nativeNetworkObservers) {
for (Long nativeObserver : nativeNetworkObservers) {
nativeNotifyConnectionTypeChanged(nativeObserver);
}
for (long nativeObserver : nativeNetworkObservers) {
nativeNotifyConnectionTypeChanged(nativeObserver);
}
// This avoids calling external methods while locking on an object.
NetworkObserver[] javaObservers;
synchronized (networkObservers) {
javaObservers = new NetworkObserver[networkObservers.size()];
javaObservers = networkObservers.toArray(javaObservers);
}
for (NetworkObserver observer : javaObservers) {
for (NetworkObserver observer : networkObservers) {
observer.onConnectionTypeChanged(newConnectionType);
}
}
private void notifyObserversOfNetworkConnect(NetworkInformation networkInfo) {
synchronized (nativeNetworkObservers) {
for (Long nativeObserver : nativeNetworkObservers) {
nativeNotifyOfNetworkConnect(nativeObserver, networkInfo);
}
for (long nativeObserver : nativeNetworkObservers) {
nativeNotifyOfNetworkConnect(nativeObserver, networkInfo);
}
}
private void notifyObserversOfNetworkDisconnect(long networkHandle) {
synchronized (nativeNetworkObservers) {
for (Long nativeObserver : nativeNetworkObservers) {
nativeNotifyOfNetworkDisconnect(nativeObserver, networkHandle);
}
for (long nativeObserver : nativeNetworkObservers) {
nativeNotifyOfNetworkDisconnect(nativeObserver, networkHandle);
}
}
@ -247,9 +230,7 @@ public class NetworkMonitor {
}
public void addObserver(NetworkObserver observer) {
synchronized (networkObservers) {
networkObservers.add(observer);
}
networkObservers.add(observer);
}
/**
@ -263,9 +244,7 @@ public class NetworkMonitor {
}
public void removeObserver(NetworkObserver observer) {
synchronized (networkObservers) {
networkObservers.remove(observer);
}
networkObservers.remove(observer);
}
/** Checks if there currently is connectivity. */