Merge changes I16418791,I210f5ddc am: b52609172e
Original change: https://android-review.googlesource.com/c/platform/frameworks/base/+/1948617 Change-Id: I255850295426742033b60d16f30f676e96f6bb4d
This commit is contained in:
@@ -54,7 +54,12 @@ package android.app {
|
||||
package android.app.usage {
|
||||
|
||||
public class NetworkStatsManager {
|
||||
method @RequiresPermission(anyOf={android.net.NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK, android.Manifest.permission.NETWORK_STACK}) public void forceUpdate();
|
||||
method @RequiresPermission(anyOf={android.net.NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK, android.Manifest.permission.NETWORK_STACK}) public void notifyNetworkStatus(@NonNull java.util.List<android.net.Network>, @NonNull java.util.List<android.net.NetworkStateSnapshot>, @Nullable String, @NonNull java.util.List<android.net.UnderlyingNetworkInfo>);
|
||||
method @RequiresPermission(anyOf={android.net.NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK, android.Manifest.permission.NETWORK_STACK}) public void setDefaultGlobalAlert(long);
|
||||
method @RequiresPermission(anyOf={android.net.NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK, android.Manifest.permission.NETWORK_STACK}) public void setPollOnOpen(boolean);
|
||||
method @RequiresPermission(anyOf={android.net.NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK, android.Manifest.permission.NETWORK_STACK}) public void setStatsProviderWarningAndLimitAsync(@NonNull String, long, long);
|
||||
method @RequiresPermission(anyOf={android.net.NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK, android.Manifest.permission.NETWORK_STACK}) public void setUidForeground(int, boolean);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -18,6 +18,7 @@ package android.app.usage;
|
||||
|
||||
import static android.annotation.SystemApi.Client.MODULE_LIBRARIES;
|
||||
|
||||
import android.Manifest;
|
||||
import android.annotation.NonNull;
|
||||
import android.annotation.Nullable;
|
||||
import android.annotation.RequiresPermission;
|
||||
@@ -150,7 +151,13 @@ public class NetworkStatsManager {
|
||||
* @param pollOnOpen true if poll is needed.
|
||||
* @hide
|
||||
*/
|
||||
// @SystemApi(client = MODULE_LIBRARIES)
|
||||
// The system will ignore any non-default values for non-privileged
|
||||
// processes, so processes that don't hold the appropriate permissions
|
||||
// can make no use of this API.
|
||||
@SystemApi(client = MODULE_LIBRARIES)
|
||||
@RequiresPermission(anyOf = {
|
||||
NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK,
|
||||
android.Manifest.permission.NETWORK_STACK})
|
||||
public void setPollOnOpen(boolean pollOnOpen) {
|
||||
if (pollOnOpen) {
|
||||
mFlags |= FLAG_POLL_ON_OPEN;
|
||||
@@ -877,7 +884,7 @@ public class NetworkStatsManager {
|
||||
*
|
||||
* @hide
|
||||
*/
|
||||
// @SystemApi
|
||||
@SystemApi(client = MODULE_LIBRARIES)
|
||||
@RequiresPermission(anyOf = {
|
||||
NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK,
|
||||
android.Manifest.permission.NETWORK_STACK})
|
||||
@@ -890,17 +897,18 @@ public class NetworkStatsManager {
|
||||
}
|
||||
|
||||
/**
|
||||
* Advise persistence threshold; may be overridden internally.
|
||||
* Set default value of global alert bytes, the value will be clamped to [128kB, 2MB].
|
||||
*
|
||||
* @hide
|
||||
*/
|
||||
// @SystemApi
|
||||
@SystemApi(client = MODULE_LIBRARIES)
|
||||
@RequiresPermission(anyOf = {
|
||||
NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK,
|
||||
android.Manifest.permission.NETWORK_STACK})
|
||||
public void advisePersistThreshold(long thresholdBytes) {
|
||||
Manifest.permission.NETWORK_STACK})
|
||||
public void setDefaultGlobalAlert(long alertBytes) {
|
||||
try {
|
||||
mService.advisePersistThreshold(thresholdBytes);
|
||||
// TODO: Sync internal naming with the API surface.
|
||||
mService.advisePersistThreshold(alertBytes);
|
||||
} catch (RemoteException e) {
|
||||
throw e.rethrowFromSystemServer();
|
||||
}
|
||||
@@ -911,7 +919,7 @@ public class NetworkStatsManager {
|
||||
*
|
||||
* @hide
|
||||
*/
|
||||
// @SystemApi
|
||||
@SystemApi(client = MODULE_LIBRARIES)
|
||||
@RequiresPermission(anyOf = {
|
||||
NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK,
|
||||
android.Manifest.permission.NETWORK_STACK})
|
||||
@@ -927,9 +935,17 @@ public class NetworkStatsManager {
|
||||
* Set the warning and limit to all registered custom network stats providers.
|
||||
* Note that invocation of any interface will be sent to all providers.
|
||||
*
|
||||
* Asynchronicity notes : because traffic may be happening on the device at the same time, it
|
||||
* doesn't make sense to wait for the warning and limit to be set – a caller still wouldn't
|
||||
* know when exactly it was effective. All that can matter is that it's done quickly. Also,
|
||||
* this method can't fail, so there is no status to return. All providers will see the new
|
||||
* values soon.
|
||||
* As such, this method returns immediately and sends the warning and limit to all providers
|
||||
* as soon as possible through a one-way binder call.
|
||||
*
|
||||
* @hide
|
||||
*/
|
||||
// @SystemApi
|
||||
@SystemApi(client = MODULE_LIBRARIES)
|
||||
@RequiresPermission(anyOf = {
|
||||
NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK,
|
||||
android.Manifest.permission.NETWORK_STACK})
|
||||
|
||||
@@ -707,12 +707,25 @@ public class NetworkStatsService extends INetworkStatsService.Stub {
|
||||
return now - lastCallTime < POLL_RATE_LIMIT_MS;
|
||||
}
|
||||
|
||||
private INetworkStatsSession openSessionInternal(final int flags, final String callingPackage) {
|
||||
private int restrictFlagsForCaller(int flags) {
|
||||
// All non-privileged callers are not allowed to turn off POLL_ON_OPEN.
|
||||
final boolean isPrivileged = PermissionUtils.checkAnyPermissionOf(mContext,
|
||||
NetworkStack.PERMISSION_MAINLINE_NETWORK_STACK,
|
||||
android.Manifest.permission.NETWORK_STACK);
|
||||
if (!isPrivileged) {
|
||||
flags |= NetworkStatsManager.FLAG_POLL_ON_OPEN;
|
||||
}
|
||||
// Non-system uids are rate limited for POLL_ON_OPEN.
|
||||
final int callingUid = Binder.getCallingUid();
|
||||
final int usedFlags = isRateLimitedForPoll(callingUid)
|
||||
flags = isRateLimitedForPoll(callingUid)
|
||||
? flags & (~NetworkStatsManager.FLAG_POLL_ON_OPEN)
|
||||
: flags;
|
||||
if ((usedFlags & (NetworkStatsManager.FLAG_POLL_ON_OPEN
|
||||
return flags;
|
||||
}
|
||||
|
||||
private INetworkStatsSession openSessionInternal(final int flags, final String callingPackage) {
|
||||
final int restrictedFlags = restrictFlagsForCaller(flags);
|
||||
if ((restrictedFlags & (NetworkStatsManager.FLAG_POLL_ON_OPEN
|
||||
| NetworkStatsManager.FLAG_POLL_FORCE)) != 0) {
|
||||
final long ident = Binder.clearCallingIdentity();
|
||||
try {
|
||||
@@ -726,7 +739,7 @@ public class NetworkStatsService extends INetworkStatsService.Stub {
|
||||
// for its lifetime; when caller closes only weak references remain.
|
||||
|
||||
return new INetworkStatsSession.Stub() {
|
||||
private final int mCallingUid = callingUid;
|
||||
private final int mCallingUid = Binder.getCallingUid();
|
||||
private final String mCallingPackage = callingPackage;
|
||||
private final @NetworkStatsAccess.Level int mAccessLevel = checkAccessLevel(
|
||||
callingPackage);
|
||||
@@ -760,21 +773,21 @@ public class NetworkStatsService extends INetworkStatsService.Stub {
|
||||
@Override
|
||||
public NetworkStats getDeviceSummaryForNetwork(
|
||||
NetworkTemplate template, long start, long end) {
|
||||
return internalGetSummaryForNetwork(template, usedFlags, start, end, mAccessLevel,
|
||||
mCallingUid);
|
||||
return internalGetSummaryForNetwork(template, restrictedFlags, start, end,
|
||||
mAccessLevel, mCallingUid);
|
||||
}
|
||||
|
||||
@Override
|
||||
public NetworkStats getSummaryForNetwork(
|
||||
NetworkTemplate template, long start, long end) {
|
||||
return internalGetSummaryForNetwork(template, usedFlags, start, end, mAccessLevel,
|
||||
mCallingUid);
|
||||
return internalGetSummaryForNetwork(template, restrictedFlags, start, end,
|
||||
mAccessLevel, mCallingUid);
|
||||
}
|
||||
|
||||
@Override
|
||||
public NetworkStatsHistory getHistoryForNetwork(NetworkTemplate template, int fields) {
|
||||
return internalGetHistoryForNetwork(template, usedFlags, fields, mAccessLevel,
|
||||
mCallingUid);
|
||||
return internalGetHistoryForNetwork(template, restrictedFlags, fields,
|
||||
mAccessLevel, mCallingUid);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -5098,7 +5098,8 @@ public class NetworkPolicyManagerService extends INetworkPolicyManager.Stub {
|
||||
// make sure stats are recorded frequently enough; we aim
|
||||
// for 2MB threshold for 2GB/month rules.
|
||||
final long persistThreshold = lowestRule / 1000;
|
||||
mNetworkStats.advisePersistThreshold(persistThreshold);
|
||||
// TODO: Sync internal naming with the API surface.
|
||||
mNetworkStats.setDefaultGlobalAlert(persistThreshold);
|
||||
return true;
|
||||
}
|
||||
case MSG_UPDATE_INTERFACE_QUOTAS: {
|
||||
|
||||
@@ -2092,7 +2092,7 @@ public class NetworkPolicyManagerServiceTest {
|
||||
}
|
||||
|
||||
private void verifyAdvisePersistThreshold() throws Exception {
|
||||
verify(mStatsManager).advisePersistThreshold(anyLong());
|
||||
verify(mStatsManager).setDefaultGlobalAlert(anyLong());
|
||||
}
|
||||
|
||||
private static class TestAbstractFuture<T> extends AbstractFuture<T> {
|
||||
|
||||
@@ -15,20 +15,19 @@
|
||||
*/
|
||||
package com.android.tests.dataidle;
|
||||
|
||||
import static android.net.NetworkStats.METERED_YES;
|
||||
|
||||
import android.app.usage.NetworkStats;
|
||||
import android.app.usage.NetworkStatsManager;
|
||||
import android.content.Context;
|
||||
import android.net.INetworkStatsService;
|
||||
import android.net.INetworkStatsSession;
|
||||
import android.net.NetworkStats;
|
||||
import android.net.NetworkStats.Entry;
|
||||
import android.net.NetworkTemplate;
|
||||
import android.net.TrafficStats;
|
||||
import android.os.Bundle;
|
||||
import android.os.RemoteException;
|
||||
import android.os.ServiceManager;
|
||||
import android.telephony.TelephonyManager;
|
||||
import android.test.InstrumentationTestCase;
|
||||
import android.util.Log;
|
||||
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
* A test that dumps data usage to instrumentation out, used for measuring data usage for idle
|
||||
* devices.
|
||||
@@ -36,7 +35,7 @@ import android.util.Log;
|
||||
public class DataIdleTest extends InstrumentationTestCase {
|
||||
|
||||
private TelephonyManager mTelephonyManager;
|
||||
private INetworkStatsService mStatsService;
|
||||
private NetworkStatsManager mStatsManager;
|
||||
|
||||
private static final String LOG_TAG = "DataIdleTest";
|
||||
private final static int INSTRUMENTATION_IN_PROGRESS = 2;
|
||||
@@ -44,8 +43,7 @@ public class DataIdleTest extends InstrumentationTestCase {
|
||||
protected void setUp() throws Exception {
|
||||
super.setUp();
|
||||
Context c = getInstrumentation().getTargetContext();
|
||||
mStatsService = INetworkStatsService.Stub.asInterface(
|
||||
ServiceManager.getService(Context.NETWORK_STATS_SERVICE));
|
||||
mStatsManager = c.getSystemService(NetworkStatsManager.class);
|
||||
mTelephonyManager = (TelephonyManager) c.getSystemService(Context.TELEPHONY_SERVICE);
|
||||
}
|
||||
|
||||
@@ -53,7 +51,9 @@ public class DataIdleTest extends InstrumentationTestCase {
|
||||
* Test that dumps all the data usage metrics for wifi to instrumentation out.
|
||||
*/
|
||||
public void testWifiIdle() {
|
||||
NetworkTemplate template = NetworkTemplate.buildTemplateWifiWildcard();
|
||||
final NetworkTemplate template = new NetworkTemplate
|
||||
.Builder(NetworkTemplate.MATCH_WIFI)
|
||||
.build();
|
||||
fetchStats(template);
|
||||
}
|
||||
|
||||
@@ -61,8 +61,11 @@ public class DataIdleTest extends InstrumentationTestCase {
|
||||
* Test that dumps all the data usage metrics for all mobile to instrumentation out.
|
||||
*/
|
||||
public void testMobile() {
|
||||
String subscriberId = mTelephonyManager.getSubscriberId();
|
||||
NetworkTemplate template = NetworkTemplate.buildTemplateMobileAll(subscriberId);
|
||||
final String subscriberId = mTelephonyManager.getSubscriberId();
|
||||
NetworkTemplate template = new NetworkTemplate
|
||||
.Builder(NetworkTemplate.MATCH_MOBILE)
|
||||
.setMeteredness(METERED_YES)
|
||||
.setSubscriberIds(Set.of(subscriberId)).build();
|
||||
fetchStats(template);
|
||||
}
|
||||
|
||||
@@ -72,49 +75,26 @@ public class DataIdleTest extends InstrumentationTestCase {
|
||||
* @param template {@link NetworkTemplate} to match.
|
||||
*/
|
||||
private void fetchStats(NetworkTemplate template) {
|
||||
INetworkStatsSession session = null;
|
||||
try {
|
||||
mStatsService.forceUpdate();
|
||||
session = mStatsService.openSession();
|
||||
final NetworkStats stats = session.getSummaryForAllUid(
|
||||
template, Long.MIN_VALUE, Long.MAX_VALUE, false);
|
||||
reportStats(stats);
|
||||
} catch (RemoteException e) {
|
||||
mStatsManager.forceUpdate();
|
||||
final NetworkStats.Bucket bucket =
|
||||
mStatsManager.querySummaryForDevice(template, Long.MIN_VALUE, Long.MAX_VALUE);
|
||||
reportStats(bucket);
|
||||
} catch (RuntimeException e) {
|
||||
Log.w(LOG_TAG, "Failed to fetch network stats.");
|
||||
} finally {
|
||||
TrafficStats.closeQuietly(session);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Print network data usage stats to instrumentation out
|
||||
* @param stats {@link NetworkorStats} to print
|
||||
* @param bucket {@link NetworkStats} to print
|
||||
*/
|
||||
void reportStats(NetworkStats stats) {
|
||||
void reportStats(NetworkStats.Bucket bucket) {
|
||||
Bundle result = new Bundle();
|
||||
long rxBytes = 0;
|
||||
long txBytes = 0;
|
||||
long rxPackets = 0;
|
||||
long txPackets = 0;
|
||||
for (int i = 0; i < stats.size(); ++i) {
|
||||
// Label will be iface_uid_tag_set
|
||||
Entry statsEntry = stats.getValues(i, null);
|
||||
// Debugging use.
|
||||
/*
|
||||
String labelTemplate = String.format("%s_%d_%d_%d", statsEntry.iface, statsEntry.uid,
|
||||
statsEntry.tag, statsEntry.set) + "_%s";
|
||||
result.putLong(String.format(labelTemplate, "rxBytes"), statsEntry.rxBytes);
|
||||
result.putLong(String.format(labelTemplate, "txBytes"), statsEntry.txBytes);
|
||||
*/
|
||||
rxPackets += statsEntry.rxPackets;
|
||||
rxBytes += statsEntry.rxBytes;
|
||||
txPackets += statsEntry.txPackets;
|
||||
txBytes += statsEntry.txBytes;
|
||||
}
|
||||
result.putLong("Total rx Bytes", rxBytes);
|
||||
result.putLong("Total tx Bytes", txBytes);
|
||||
result.putLong("Total rx Packets", rxPackets);
|
||||
result.putLong("Total tx Packets", txPackets);
|
||||
result.putLong("Total rx Bytes", bucket.getRxBytes());
|
||||
result.putLong("Total tx Bytes", bucket.getTxBytes());
|
||||
result.putLong("Total rx Packets", bucket.getRxPackets());
|
||||
result.putLong("Total tx Packets", bucket.getTxPackets());
|
||||
getInstrumentation().sendStatus(INSTRUMENTATION_IN_PROGRESS, result);
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user