1 /* 2 * Copyright (C) 2011 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package com.android.internal.net; 18 19 import static android.net.NetworkStats.DEFAULT_NETWORK_NO; 20 import static android.net.NetworkStats.METERED_NO; 21 import static android.net.NetworkStats.ROAMING_NO; 22 import static android.net.NetworkStats.SET_ALL; 23 import static android.net.NetworkStats.SET_DEFAULT; 24 import static android.net.NetworkStats.SET_FOREGROUND; 25 import static android.net.NetworkStats.TAG_NONE; 26 import static android.net.NetworkStats.UID_ALL; 27 import static com.android.server.NetworkManagementSocketTagger.kernelToTag; 28 import static org.junit.Assert.assertEquals; 29 import static org.junit.Assert.fail; 30 31 import android.content.res.Resources; 32 import android.net.NetworkStats; 33 import android.net.TrafficStats; 34 import android.support.test.InstrumentationRegistry; 35 import android.support.test.filters.SmallTest; 36 import android.support.test.runner.AndroidJUnit4; 37 38 import com.android.frameworks.tests.net.R; 39 40 import java.io.File; 41 import java.io.FileOutputStream; 42 import java.io.FileWriter; 43 import java.io.InputStream; 44 import java.io.OutputStream; 45 46 import libcore.io.IoUtils; 47 import libcore.io.Streams; 48 49 import org.junit.runner.RunWith; 50 import org.junit.After; 51 import org.junit.Before; 52 import org.junit.Test; 53 54 /** 55 * Tests for {@link NetworkStatsFactory}. 56 */ 57 @RunWith(AndroidJUnit4.class) 58 @SmallTest 59 public class NetworkStatsFactoryTest { 60 private File mTestProc; 61 private NetworkStatsFactory mFactory; 62 63 @Before 64 public void setUp() throws Exception { 65 mTestProc = new File(InstrumentationRegistry.getContext().getFilesDir(), "proc"); 66 if (mTestProc.exists()) { 67 IoUtils.deleteContents(mTestProc); 68 } 69 70 mFactory = new NetworkStatsFactory(mTestProc, false); 71 } 72 73 @After 74 public void tearDown() throws Exception { 75 mFactory = null; 76 77 if (mTestProc.exists()) { 78 IoUtils.deleteContents(mTestProc); 79 } 80 } 81 82 @Test 83 public void testNetworkStatsDetail() throws Exception { 84 final NetworkStats stats = parseDetailedStats(R.raw.xt_qtaguid_typical); 85 86 assertEquals(70, stats.size()); 87 assertStatsEntry(stats, "wlan0", 0, SET_DEFAULT, 0x0, 18621L, 2898L); 88 assertStatsEntry(stats, "wlan0", 10011, SET_DEFAULT, 0x0, 35777L, 5718L); 89 assertStatsEntry(stats, "wlan0", 10021, SET_DEFAULT, 0x7fffff01, 562386L, 49228L); 90 assertStatsEntry(stats, "rmnet1", 10021, SET_DEFAULT, 0x30100000, 219110L, 227423L); 91 assertStatsEntry(stats, "rmnet2", 10001, SET_DEFAULT, 0x0, 1125899906842624L, 984L); 92 } 93 94 @Test 95 public void testKernelTags() throws Exception { 96 assertEquals(0, kernelToTag("0x0000000000000000")); 97 assertEquals(0x32, kernelToTag("0x0000003200000000")); 98 assertEquals(2147483647, kernelToTag("0x7fffffff00000000")); 99 assertEquals(0, kernelToTag("0x0000000000000000")); 100 assertEquals(2147483136, kernelToTag("0x7FFFFE0000000000")); 101 102 assertEquals(0, kernelToTag("0x0")); 103 assertEquals(0, kernelToTag("0xf00d")); 104 assertEquals(1, kernelToTag("0x100000000")); 105 assertEquals(14438007, kernelToTag("0xdc4e7700000000")); 106 assertEquals(TrafficStats.TAG_SYSTEM_DOWNLOAD, kernelToTag("0xffffff0100000000")); 107 } 108 109 @Test 110 public void testNetworkStatsWithSet() throws Exception { 111 final NetworkStats stats = parseDetailedStats(R.raw.xt_qtaguid_typical); 112 assertEquals(70, stats.size()); 113 assertStatsEntry(stats, "rmnet1", 10021, SET_DEFAULT, 0x30100000, 219110L, 578L, 227423L, 114 676L); 115 assertStatsEntry(stats, "rmnet1", 10021, SET_FOREGROUND, 0x30100000, 742L, 3L, 1265L, 3L); 116 } 117 118 @Test 119 public void testNetworkStatsSingle() throws Exception { 120 stageFile(R.raw.xt_qtaguid_iface_typical, file("net/xt_qtaguid/iface_stat_all")); 121 122 final NetworkStats stats = mFactory.readNetworkStatsSummaryDev(); 123 assertEquals(6, stats.size()); 124 assertStatsEntry(stats, "rmnet0", UID_ALL, SET_ALL, TAG_NONE, 2112L, 24L, 700L, 10L); 125 assertStatsEntry(stats, "test1", UID_ALL, SET_ALL, TAG_NONE, 6L, 8L, 10L, 12L); 126 assertStatsEntry(stats, "test2", UID_ALL, SET_ALL, TAG_NONE, 1L, 2L, 3L, 4L); 127 } 128 129 @Test 130 public void testNetworkStatsXt() throws Exception { 131 stageFile(R.raw.xt_qtaguid_iface_fmt_typical, file("net/xt_qtaguid/iface_stat_fmt")); 132 133 final NetworkStats stats = mFactory.readNetworkStatsSummaryXt(); 134 assertEquals(3, stats.size()); 135 assertStatsEntry(stats, "rmnet0", UID_ALL, SET_ALL, TAG_NONE, 6824L, 16L, 5692L, 10L); 136 assertStatsEntry(stats, "rmnet1", UID_ALL, SET_ALL, TAG_NONE, 11153922L, 8051L, 190226L, 137 2468L); 138 assertStatsEntry(stats, "rmnet2", UID_ALL, SET_ALL, TAG_NONE, 4968L, 35L, 3081L, 39L); 139 } 140 141 @Test 142 public void testDoubleClatAccounting() throws Exception { 143 NetworkStatsFactory.noteStackedIface("v4-wlan0", "wlan0"); 144 145 // xt_qtaguid_with_clat_simple is a synthetic file that simulates 146 // - 213 received 464xlat packets of size 200 bytes 147 // - 41 sent 464xlat packets of size 100 bytes 148 // - no other traffic on base interface for root uid. 149 NetworkStats stats = parseDetailedStats(R.raw.xt_qtaguid_with_clat_simple); 150 assertEquals(4, stats.size()); 151 152 assertStatsEntry(stats, "v4-wlan0", 10060, SET_DEFAULT, 0x0, 46860L, 4920L); 153 assertStatsEntry(stats, "wlan0", 0, SET_DEFAULT, 0x0, 0L, 0L); 154 155 stats = parseDetailedStats(R.raw.xt_qtaguid_with_clat); 156 assertEquals(42, stats.size()); 157 158 assertStatsEntry(stats, "v4-wlan0", 0, SET_DEFAULT, 0x0, 356L, 276L); 159 assertStatsEntry(stats, "v4-wlan0", 1000, SET_DEFAULT, 0x0, 30812L, 2310L); 160 assertStatsEntry(stats, "v4-wlan0", 10102, SET_DEFAULT, 0x0, 10022L, 3330L); 161 assertStatsEntry(stats, "v4-wlan0", 10060, SET_DEFAULT, 0x0, 9532772L, 254112L); 162 assertStatsEntry(stats, "wlan0", 0, SET_DEFAULT, 0x0, 15229L, 5766L); 163 assertStatsEntry(stats, "wlan0", 1000, SET_DEFAULT, 0x0, 6126L, 2013L); 164 assertStatsEntry(stats, "wlan0", 10013, SET_DEFAULT, 0x0, 0L, 144L); 165 assertStatsEntry(stats, "wlan0", 10018, SET_DEFAULT, 0x0, 5980263L, 167667L); 166 assertStatsEntry(stats, "wlan0", 10060, SET_DEFAULT, 0x0, 134356L, 8705L); 167 assertStatsEntry(stats, "wlan0", 10079, SET_DEFAULT, 0x0, 10926L, 1507L); 168 assertStatsEntry(stats, "wlan0", 10102, SET_DEFAULT, 0x0, 25038L, 8245L); 169 assertStatsEntry(stats, "wlan0", 10103, SET_DEFAULT, 0x0, 0L, 192L); 170 assertStatsEntry(stats, "dummy0", 0, SET_DEFAULT, 0x0, 0L, 168L); 171 assertStatsEntry(stats, "lo", 0, SET_DEFAULT, 0x0, 1288L, 1288L); 172 173 NetworkStatsFactory.clearStackedIfaces(); 174 } 175 176 @Test 177 public void testDoubleClatAccounting100MBDownload() throws Exception { 178 // Downloading 100mb from an ipv4 only destination in a foreground activity 179 180 long appRxBytesBefore = 328684029L; 181 long appRxBytesAfter = 439237478L; 182 assertEquals("App traffic should be ~100MB", 110553449, appRxBytesAfter - appRxBytesBefore); 183 184 long rootRxBytesBefore = 1394011L; 185 long rootRxBytesAfter = 1398634L; 186 assertEquals("UID 0 traffic should be ~0", 4623, rootRxBytesAfter - rootRxBytesBefore); 187 188 NetworkStatsFactory.noteStackedIface("v4-wlan0", "wlan0"); 189 NetworkStats stats; 190 191 // Stats snapshot before the download 192 stats = parseDetailedStats(R.raw.xt_qtaguid_with_clat_100mb_download_before); 193 assertStatsEntry(stats, "v4-wlan0", 10106, SET_FOREGROUND, 0x0, appRxBytesBefore, 5199872L); 194 assertStatsEntry(stats, "wlan0", 0, SET_DEFAULT, 0x0, rootRxBytesBefore, 647888L); 195 196 // Stats snapshot after the download 197 stats = parseDetailedStats(R.raw.xt_qtaguid_with_clat_100mb_download_after); 198 assertStatsEntry(stats, "v4-wlan0", 10106, SET_FOREGROUND, 0x0, appRxBytesAfter, 7867488L); 199 assertStatsEntry(stats, "wlan0", 0, SET_DEFAULT, 0x0, rootRxBytesAfter, 647587L); 200 201 NetworkStatsFactory.clearStackedIfaces(); 202 } 203 204 /** 205 * Copy a {@link Resources#openRawResource(int)} into {@link File} for 206 * testing purposes. 207 */ 208 private void stageFile(int rawId, File file) throws Exception { 209 new File(file.getParent()).mkdirs(); 210 InputStream in = null; 211 OutputStream out = null; 212 try { 213 in = InstrumentationRegistry.getContext().getResources().openRawResource(rawId); 214 out = new FileOutputStream(file); 215 Streams.copy(in, out); 216 } finally { 217 IoUtils.closeQuietly(in); 218 IoUtils.closeQuietly(out); 219 } 220 } 221 222 private void stageLong(long value, File file) throws Exception { 223 new File(file.getParent()).mkdirs(); 224 FileWriter out = null; 225 try { 226 out = new FileWriter(file); 227 out.write(Long.toString(value)); 228 } finally { 229 IoUtils.closeQuietly(out); 230 } 231 } 232 233 private File file(String path) throws Exception { 234 return new File(mTestProc, path); 235 } 236 237 private NetworkStats parseDetailedStats(int resourceId) throws Exception { 238 stageFile(resourceId, file("net/xt_qtaguid/stats")); 239 return mFactory.readNetworkStatsDetail(); 240 } 241 242 private static void assertStatsEntry(NetworkStats stats, String iface, int uid, int set, 243 int tag, long rxBytes, long txBytes) { 244 final int i = stats.findIndex(iface, uid, set, tag, METERED_NO, ROAMING_NO, 245 DEFAULT_NETWORK_NO); 246 if (i < 0) { 247 fail(String.format("no NetworkStats for (iface: %s, uid: %d, set: %d, tag: %d)", 248 iface, uid, set, tag)); 249 } 250 final NetworkStats.Entry entry = stats.getValues(i, null); 251 assertEquals("unexpected rxBytes", rxBytes, entry.rxBytes); 252 assertEquals("unexpected txBytes", txBytes, entry.txBytes); 253 } 254 255 private static void assertStatsEntry(NetworkStats stats, String iface, int uid, int set, 256 int tag, long rxBytes, long rxPackets, long txBytes, long txPackets) { 257 final int i = stats.findIndex(iface, uid, set, tag, METERED_NO, ROAMING_NO, 258 DEFAULT_NETWORK_NO); 259 if (i < 0) { 260 fail(String.format("no NetworkStats for (iface: %s, uid: %d, set: %d, tag: %d)", 261 iface, uid, set, tag)); 262 } 263 final NetworkStats.Entry entry = stats.getValues(i, null); 264 assertEquals("unexpected rxBytes", rxBytes, entry.rxBytes); 265 assertEquals("unexpected rxPackets", rxPackets, entry.rxPackets); 266 assertEquals("unexpected txBytes", txBytes, entry.txBytes); 267 assertEquals("unexpected txPackets", txPackets, entry.txPackets); 268 } 269 } 270
