Android/frameworks_base
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge "NetdEventListenerService extends BaseNetdEventListener"

Browse Source
This commit is contained in:
Suprabh Shukla
2023-02-14 23:42:42 +00:00
committed by Gerrit Code Review
parent 3cbfa9d080 7adf98bebb
commit 3c825a4d89
1 changed files with 28 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
services/core/java/com/android/server/connectivity/NetdEventListenerService.java
View File

@@ -28,7 +28,6 @@ import android.net.NetworkCapabilities;
import android.net.NetworkRequest; import android.net.NetworkRequest;
import android.net.metrics.ConnectStats; import android.net.metrics.ConnectStats;
import android.net.metrics.DnsEvent; import android.net.metrics.DnsEvent;
import android.net.metrics.INetdEventListener;
import android.net.metrics.NetworkMetrics; import android.net.metrics.NetworkMetrics;
import android.net.metrics.WakeupEvent; import android.net.metrics.WakeupEvent;
import android.net.metrics.WakeupStats; import android.net.metrics.WakeupStats;
@@ -44,6 +43,7 @@ import com.android.internal.util.BitUtils;
import com.android.internal.util.FrameworkStatsLog; import com.android.internal.util.FrameworkStatsLog;
import com.android.internal.util.RingBuffer; import com.android.internal.util.RingBuffer;
import com.android.internal.util.TokenBucket; import com.android.internal.util.TokenBucket;
import com.android.net.module.util.BaseNetdEventListener;
import com.android.server.connectivity.metrics.nano.IpConnectivityLogClass.IpConnectivityEvent; import com.android.server.connectivity.metrics.nano.IpConnectivityLogClass.IpConnectivityEvent;
import java.io.PrintWriter; import java.io.PrintWriter;
@@ -54,7 +54,7 @@ import java.util.StringJoiner;
/** /**
* Implementation of the INetdEventListener interface. * Implementation of the INetdEventListener interface.
*/ */
public class NetdEventListenerService extends INetdEventListener.Stub { public class NetdEventListenerService extends BaseNetdEventListener {
public static final String SERVICE_NAME = "netd_listener"; public static final String SERVICE_NAME = "netd_listener";
@@ -208,15 +208,18 @@ public class NetdEventListenerService extends INetdEventListener.Stub {
// Called concurrently by multiple binder threads. // Called concurrently by multiple binder threads.
// This method must not block or perform long-running operations. // This method must not block or perform long-running operations.
public synchronized void onDnsEvent(int netId, int eventType, int returnCode, int latencyMs, public synchronized void onDnsEvent(int netId, int eventType, int returnCode, int latencyMs,
String hostname, String[] ipAddresses, int ipAddressesCount, int uid) String hostname, String[] ipAddresses, int ipAddressesCount, int uid) {
throws RemoteException {
long timestamp = System.currentTimeMillis(); long timestamp = System.currentTimeMillis();
getMetricsForNetwork(timestamp, netId).addDnsResult(eventType, returnCode, latencyMs); getMetricsForNetwork(timestamp, netId).addDnsResult(eventType, returnCode, latencyMs);
for (INetdEventCallback callback : mNetdEventCallbackList) { for (INetdEventCallback callback : mNetdEventCallbackList) {
if (callback != null) { if (callback != null) {
callback.onDnsEvent(netId, eventType, returnCode, hostname, ipAddresses, try {
ipAddressesCount, timestamp, uid); callback.onDnsEvent(netId, eventType, returnCode, hostname, ipAddresses,
ipAddressesCount, timestamp, uid);
} catch (RemoteException e) {
throw e.rethrowFromSystemServer();
}
} }
} }
} }
@@ -225,11 +228,14 @@ public class NetdEventListenerService extends INetdEventListener.Stub {
// Called concurrently by multiple binder threads. // Called concurrently by multiple binder threads.
// This method must not block or perform long-running operations. // This method must not block or perform long-running operations.
public synchronized void onNat64PrefixEvent(int netId, public synchronized void onNat64PrefixEvent(int netId,
boolean added, String prefixString, int prefixLength) boolean added, String prefixString, int prefixLength) {
throws RemoteException {
for (INetdEventCallback callback : mNetdEventCallbackList) { for (INetdEventCallback callback : mNetdEventCallbackList) {
if (callback != null) { if (callback != null) {
callback.onNat64PrefixEvent(netId, added, prefixString, prefixLength); try {
callback.onNat64PrefixEvent(netId, added, prefixString, prefixLength);
} catch (RemoteException e) {
throw e.rethrowFromSystemServer();
}
} }
} }
} }
@@ -238,11 +244,14 @@ public class NetdEventListenerService extends INetdEventListener.Stub {
// Called concurrently by multiple binder threads. // Called concurrently by multiple binder threads.
// This method must not block or perform long-running operations. // This method must not block or perform long-running operations.
public synchronized void onPrivateDnsValidationEvent(int netId, public synchronized void onPrivateDnsValidationEvent(int netId,
String ipAddress, String hostname, boolean validated) String ipAddress, String hostname, boolean validated) {
throws RemoteException {
for (INetdEventCallback callback : mNetdEventCallbackList) { for (INetdEventCallback callback : mNetdEventCallbackList) {
if (callback != null) { if (callback != null) {
callback.onPrivateDnsValidationEvent(netId, ipAddress, hostname, validated); try {
callback.onPrivateDnsValidationEvent(netId, ipAddress, hostname, validated);
} catch (RemoteException e) {
throw e.rethrowFromSystemServer();
}
} }
} }
} }
@@ -251,13 +260,17 @@ public class NetdEventListenerService extends INetdEventListener.Stub {
// Called concurrently by multiple binder threads. // Called concurrently by multiple binder threads.
// This method must not block or perform long-running operations. // This method must not block or perform long-running operations.
public synchronized void onConnectEvent(int netId, int error, int latencyMs, String ipAddr, public synchronized void onConnectEvent(int netId, int error, int latencyMs, String ipAddr,
int port, int uid) throws RemoteException { int port, int uid) {
long timestamp = System.currentTimeMillis(); long timestamp = System.currentTimeMillis();
getMetricsForNetwork(timestamp, netId).addConnectResult(error, latencyMs, ipAddr); getMetricsForNetwork(timestamp, netId).addConnectResult(error, latencyMs, ipAddr);
for (INetdEventCallback callback : mNetdEventCallbackList) { for (INetdEventCallback callback : mNetdEventCallbackList) {
if (callback != null) { if (callback != null) {
callback.onConnectEvent(ipAddr, port, timestamp, uid); try {
callback.onConnectEvent(ipAddr, port, timestamp, uid);
} catch (RemoteException e) {
throw e.rethrowFromSystemServer();
}
} }
} }
} }
@@ -315,7 +328,7 @@ public class NetdEventListenerService extends INetdEventListener.Stub {
} }
@Override @Override
public int getInterfaceVersion() throws RemoteException { public int getInterfaceVersion() {
return this.VERSION; return this.VERSION;
} }