Merge changes I289d935f,I0121a4ac am: 7ed442881c
Change-Id: I7c413c9e1f2efc3aba55453c6b98bf682f3d4116
This commit is contained in:
@@ -16,8 +16,6 @@
|
||||
|
||||
package android.net;
|
||||
|
||||
import static android.os.Process.CLAT_UID;
|
||||
|
||||
import android.annotation.IntDef;
|
||||
import android.annotation.NonNull;
|
||||
import android.annotation.Nullable;
|
||||
@@ -1069,11 +1067,10 @@ public final class NetworkStats implements Parcelable {
|
||||
* @param baseTraffic Traffic on the base interfaces. Will be mutated.
|
||||
* @param stackedTraffic Stats with traffic stacked on top of our ifaces. Will also be mutated.
|
||||
* @param stackedIfaces Mapping ipv6if -> ipv4if interface where traffic is counted on both.
|
||||
* @param useBpfStats True if eBPF is in use.
|
||||
* @hide
|
||||
*/
|
||||
public static void apply464xlatAdjustments(NetworkStats baseTraffic,
|
||||
NetworkStats stackedTraffic, Map<String, String> stackedIfaces, boolean useBpfStats) {
|
||||
NetworkStats stackedTraffic, Map<String, String> stackedIfaces) {
|
||||
// For recycling
|
||||
Entry entry = null;
|
||||
for (int i = 0; i < stackedTraffic.size; i++) {
|
||||
@@ -1096,12 +1093,6 @@ public final class NetworkStats implements Parcelable {
|
||||
entry.txBytes += entry.txPackets * IPV4V6_HEADER_DELTA;
|
||||
stackedTraffic.setValues(i, entry);
|
||||
}
|
||||
|
||||
// Theoretically there should be no traffic accounted to the clat daemon's uid:
|
||||
// see ebpf program 'netd.c's early returns
|
||||
// and iptables '-m owner --uid-owner clat -j RETURN' rules prior to accounting
|
||||
// TODO: remove this - should definitely be safe once ebpf only.
|
||||
baseTraffic.removeUids(new int[] {CLAT_UID});
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -1113,8 +1104,8 @@ public final class NetworkStats implements Parcelable {
|
||||
* @param stackedIfaces Mapping ipv6if -> ipv4if interface where traffic is counted on both.
|
||||
* @hide
|
||||
*/
|
||||
public void apply464xlatAdjustments(Map<String, String> stackedIfaces, boolean useBpfStats) {
|
||||
apply464xlatAdjustments(this, this, stackedIfaces, useBpfStats);
|
||||
public void apply464xlatAdjustments(Map<String, String> stackedIfaces) {
|
||||
apply464xlatAdjustments(this, this, stackedIfaces);
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -152,12 +152,10 @@ public class NetworkStatsFactory {
|
||||
|
||||
/**
|
||||
* Applies 464xlat adjustments with ifaces noted with {@link #noteStackedIface(String, String)}.
|
||||
* @see NetworkStats#apply464xlatAdjustments(NetworkStats, NetworkStats, Map, boolean)
|
||||
* @see NetworkStats#apply464xlatAdjustments(NetworkStats, NetworkStats, Map)
|
||||
*/
|
||||
public void apply464xlatAdjustments(NetworkStats baseTraffic,
|
||||
NetworkStats stackedTraffic, boolean useBpfStats) {
|
||||
NetworkStats.apply464xlatAdjustments(baseTraffic, stackedTraffic, mStackedIfaces,
|
||||
useBpfStats);
|
||||
public void apply464xlatAdjustments(NetworkStats baseTraffic, NetworkStats stackedTraffic) {
|
||||
NetworkStats.apply464xlatAdjustments(baseTraffic, stackedTraffic, mStackedIfaces);
|
||||
}
|
||||
|
||||
public NetworkStatsFactory() {
|
||||
@@ -380,7 +378,7 @@ public class NetworkStatsFactory {
|
||||
// network, the overhead is their fault.
|
||||
// No locking here: apply464xlatAdjustments behaves fine with an add-only
|
||||
// ConcurrentHashMap.
|
||||
delta.apply464xlatAdjustments(mStackedIfaces, mUseBpfStats);
|
||||
delta.apply464xlatAdjustments(mStackedIfaces);
|
||||
|
||||
// Migrate data usage over a VPN to the TUN network.
|
||||
for (VpnInfo info : vpnArray) {
|
||||
|
||||
@@ -1877,14 +1877,13 @@ public class NetworkStatsService extends INetworkStatsService.Stub {
|
||||
// fold tethering stats and operations into uid snapshot
|
||||
final NetworkStats tetherSnapshot = getNetworkStatsTethering(STATS_PER_UID);
|
||||
tetherSnapshot.filter(UID_ALL, ifaces, TAG_ALL);
|
||||
mStatsFactory.apply464xlatAdjustments(uidSnapshot, tetherSnapshot,
|
||||
mUseBpfTrafficStats);
|
||||
mStatsFactory.apply464xlatAdjustments(uidSnapshot, tetherSnapshot);
|
||||
uidSnapshot.combineAllValues(tetherSnapshot);
|
||||
|
||||
// get a stale copy of uid stats snapshot provided by providers.
|
||||
final NetworkStats providerStats = getNetworkStatsFromProviders(STATS_PER_UID);
|
||||
providerStats.filter(UID_ALL, ifaces, TAG_ALL);
|
||||
mStatsFactory.apply464xlatAdjustments(uidSnapshot, providerStats, mUseBpfTrafficStats);
|
||||
mStatsFactory.apply464xlatAdjustments(uidSnapshot, providerStats);
|
||||
uidSnapshot.combineAllValues(providerStats);
|
||||
|
||||
uidSnapshot.combineAllValues(mUidOperations);
|
||||
|
||||
@@ -926,21 +926,14 @@ public class NetworkStatsTest {
|
||||
3 /* txPackets */,
|
||||
0 /* operations */);
|
||||
|
||||
final NetworkStats statsXt = new NetworkStats(TEST_START, 3)
|
||||
final NetworkStats stats = new NetworkStats(TEST_START, 3)
|
||||
.insertEntry(appEntry)
|
||||
.insertEntry(rootUidEntry)
|
||||
.insertEntry(otherEntry);
|
||||
|
||||
final NetworkStats statsEbpf = new NetworkStats(TEST_START, 3)
|
||||
.insertEntry(appEntry)
|
||||
.insertEntry(rootUidEntry)
|
||||
.insertEntry(otherEntry);
|
||||
stats.apply464xlatAdjustments(stackedIface);
|
||||
|
||||
statsXt.apply464xlatAdjustments(stackedIface, false);
|
||||
statsEbpf.apply464xlatAdjustments(stackedIface, true);
|
||||
|
||||
assertEquals(3, statsXt.size());
|
||||
assertEquals(3, statsEbpf.size());
|
||||
assertEquals(3, stats.size());
|
||||
final NetworkStats.Entry expectedAppUid = new NetworkStats.Entry(
|
||||
v4Iface, appUid, SET_DEFAULT, TAG_NONE,
|
||||
30949510,
|
||||
@@ -955,12 +948,9 @@ public class NetworkStatsTest {
|
||||
17607,
|
||||
97,
|
||||
0);
|
||||
assertEquals(expectedAppUid, statsXt.getValues(0, null));
|
||||
assertEquals(expectedRootUid, statsXt.getValues(1, null));
|
||||
assertEquals(otherEntry, statsXt.getValues(2, null));
|
||||
assertEquals(expectedAppUid, statsEbpf.getValues(0, null));
|
||||
assertEquals(expectedRootUid, statsEbpf.getValues(1, null));
|
||||
assertEquals(otherEntry, statsEbpf.getValues(2, null));
|
||||
assertEquals(expectedAppUid, stats.getValues(0, null));
|
||||
assertEquals(expectedRootUid, stats.getValues(1, null));
|
||||
assertEquals(otherEntry, stats.getValues(2, null));
|
||||
}
|
||||
|
||||
@Test
|
||||
@@ -985,7 +975,7 @@ public class NetworkStatsTest {
|
||||
.insertEntry(secondEntry);
|
||||
|
||||
// Empty map: no adjustment
|
||||
stats.apply464xlatAdjustments(new ArrayMap<>(), false);
|
||||
stats.apply464xlatAdjustments(new ArrayMap<>());
|
||||
|
||||
assertEquals(2, stats.size());
|
||||
assertEquals(firstEntry, stats.getValues(0, null));
|
||||
|
||||
@@ -41,5 +41,3 @@ idx iface acct_tag_hex uid_tag_int cnt_set rx_bytes rx_packets tx_bytes tx_packe
|
||||
41 dummy0 0x0 0 1 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0
|
||||
42 lo 0x0 0 0 1288 16 1288 16 0 0 532 8 756 8 0 0 532 8 756 8
|
||||
43 lo 0x0 0 1 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0
|
||||
44 wlan0 0x0 1029 0 0 0 312046 5113 0 0 0 0 0 0 306544 5046 3230 38 2272 29
|
||||
45 wlan0 0x0 1029 1 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0
|
||||
@@ -2,4 +2,3 @@ idx iface acct_tag_hex uid_tag_int cnt_set rx_bytes rx_packets tx_bytes tx_packe
|
||||
2 v4-wlan0 0x0 10060 0 42600 213 4100 41 42600 213 0 0 0 0 4100 41 0 0 0 0
|
||||
3 v4-wlan0 0x0 10060 1 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0
|
||||
4 wlan0 0x0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0
|
||||
5 wlan0 0x0 1029 0 0 0 4920 41 0 0 0 0 0 0 4920 41 0 0 0 0
|
||||
|
||||
Reference in New Issue
Block a user