blob: 2d479855347b7c4706948aeb3212a64dc4ae7b97 [file] [log] [blame]
Chenbo Fenged37fea2017-12-13 19:35:01 -08001/*
2 * Copyright 2017 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 * TrafficControllerTest.cpp - unit tests for TrafficController.cpp
17 */
18
19#include <string>
20#include <vector>
21
22#include <fcntl.h>
23#include <inttypes.h>
24#include <linux/inet_diag.h>
25#include <linux/sock_diag.h>
26#include <sys/socket.h>
27#include <sys/types.h>
28#include <unistd.h>
29
30#include <gtest/gtest.h>
31
32#include <android-base/stringprintf.h>
33#include <android-base/strings.h>
34
35#include <netdutils/MockSyscalls.h>
Chenbo Feng89c12f12018-03-21 10:29:18 -070036#include "FirewallController.h"
Chenbo Fenged37fea2017-12-13 19:35:01 -080037#include "TrafficController.h"
38#include "bpf/BpfUtils.h"
39
40using namespace android::bpf;
41
42using ::testing::_;
43using ::testing::ByMove;
44using ::testing::Invoke;
45using ::testing::Return;
46using ::testing::StrictMock;
47using ::testing::Test;
48
49namespace android {
50namespace net {
51
52using base::unique_fd;
53using netdutils::status::ok;
54
55constexpr int TEST_MAP_SIZE = 10;
56constexpr uid_t TEST_UID = 10086;
Chenbo Feng89c12f12018-03-21 10:29:18 -070057constexpr uid_t TEST_UID2 = 54321;
58constexpr uid_t TEST_UID3 = 98765;
Chenbo Fenged37fea2017-12-13 19:35:01 -080059constexpr uint32_t TEST_TAG = 42;
60constexpr int TEST_COUNTERSET = 1;
61constexpr int DEFAULT_COUNTERSET = 0;
62
Chenbo Fengf43bf812017-12-15 18:27:22 -080063#define SKIP_IF_BPF_NOT_SUPPORTED \
64 do { \
65 if (!hasBpfSupport()) return; \
66 } while (0);
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +090067
Chenbo Fenged37fea2017-12-13 19:35:01 -080068class TrafficControllerTest : public ::testing::Test {
69 protected:
70 TrafficControllerTest() {}
71 TrafficController mTc;
72 unique_fd mFakeCookieTagMap;
73 unique_fd mFakeUidCounterSetMap;
74 unique_fd mFakeUidStatsMap;
75 unique_fd mFakeTagStatsMap;
Chenbo Feng89c12f12018-03-21 10:29:18 -070076 unique_fd mFakeDozableUidMap;
77 unique_fd mFakeStandbyUidMap;
78 unique_fd mFakePowerSaveUidMap;
Chenbo Fenged37fea2017-12-13 19:35:01 -080079
80 void SetUp() {
Chenbo Feng89c12f12018-03-21 10:29:18 -070081 std::lock_guard<std::mutex> guard(mTc.mOwnerMatchMutex);
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +090082 SKIP_IF_BPF_NOT_SUPPORTED;
83
Chenbo Fenged37fea2017-12-13 19:35:01 -080084 mFakeCookieTagMap = unique_fd(createMap(BPF_MAP_TYPE_HASH, sizeof(uint64_t),
85 sizeof(struct UidTag), TEST_MAP_SIZE, 0));
86 ASSERT_LE(0, mFakeCookieTagMap);
87
88 mFakeUidCounterSetMap = unique_fd(
89 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint32_t), TEST_MAP_SIZE, 0));
90 ASSERT_LE(0, mFakeUidCounterSetMap);
91
92 mFakeUidStatsMap = unique_fd(createMap(BPF_MAP_TYPE_HASH, sizeof(struct StatsKey),
Chenbo Fengf43bf812017-12-15 18:27:22 -080093 sizeof(struct StatsValue), TEST_MAP_SIZE, 0));
Chenbo Fenged37fea2017-12-13 19:35:01 -080094 ASSERT_LE(0, mFakeUidStatsMap);
95
96 mFakeTagStatsMap = unique_fd(createMap(BPF_MAP_TYPE_HASH, sizeof(struct StatsKey),
Chenbo Fengf43bf812017-12-15 18:27:22 -080097 sizeof(struct StatsValue), TEST_MAP_SIZE, 0));
Chenbo Fenged37fea2017-12-13 19:35:01 -080098 ASSERT_LE(0, mFakeTagStatsMap);
99
Chenbo Feng89c12f12018-03-21 10:29:18 -0700100 mFakeDozableUidMap = unique_fd(
101 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint32_t), TEST_MAP_SIZE, 0));
102 ASSERT_LE(0, mFakeDozableUidMap);
103
104 mFakeStandbyUidMap = unique_fd(
105 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint32_t), TEST_MAP_SIZE, 0));
106 ASSERT_LE(0, mFakeStandbyUidMap);
107
108 mFakePowerSaveUidMap = unique_fd(
109 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint32_t), TEST_MAP_SIZE, 0));
110 ASSERT_LE(0, mFakePowerSaveUidMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800111 // Make sure trafficController use the eBPF code path.
112 mTc.ebpfSupported = true;
113
114 mTc.mCookieTagMap.reset(mFakeCookieTagMap);
115 mTc.mUidCounterSetMap.reset(mFakeUidCounterSetMap);
116 mTc.mUidStatsMap.reset(mFakeUidStatsMap);
117 mTc.mTagStatsMap.reset(mFakeTagStatsMap);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700118 mTc.mDozableUidMap.reset(mFakeDozableUidMap);
119 mTc.mStandbyUidMap.reset(mFakeStandbyUidMap);
120 mTc.mPowerSaveUidMap.reset(mFakePowerSaveUidMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800121 }
122
123 int setUpSocketAndTag(int protocol, uint64_t* cookie, uint32_t tag, uid_t uid) {
124 int sock = socket(protocol, SOCK_STREAM, 0);
125 EXPECT_LE(0, sock);
126 *cookie = getSocketCookie(sock);
127 EXPECT_NE(INET_DIAG_NOCOOKIE, *cookie);
128 EXPECT_EQ(0, mTc.tagSocket(sock, tag, uid));
129 return sock;
130 }
131
132 void expectUidTag(uint64_t cookie, uid_t uid, uint32_t tag) {
133 struct UidTag tagResult;
134 EXPECT_EQ(0, findMapEntry(mFakeCookieTagMap, &cookie, &tagResult));
135 EXPECT_EQ(uid, tagResult.uid);
136 EXPECT_EQ(tag, tagResult.tag);
137 }
138
139 void expectNoTag(uint64_t cookie) {
140 struct UidTag tagResult;
141 EXPECT_EQ(-1, findMapEntry(mFakeCookieTagMap, &cookie, &tagResult));
142 }
143
144 void expectTagMapEmpty() {
145 uint64_t invalidCookie = INET_DIAG_NOCOOKIE;
146 uint64_t cookie;
147 EXPECT_EQ(-1, getNextMapKey(mFakeCookieTagMap, &invalidCookie, &cookie));
148 }
149
150 void populateFakeStats(uint64_t cookie, uid_t uid, uint32_t tag, StatsKey* key) {
151 UidTag cookieMapkey = {.uid = (uint32_t)uid, .tag = tag};
152 EXPECT_EQ(0, writeToMapEntry(mFakeCookieTagMap, &cookie, &cookieMapkey, BPF_ANY));
153 *key = {.uid = uid, .tag = tag, .counterSet = TEST_COUNTERSET, .ifaceIndex = 1};
Chenbo Fengeac6c472018-02-05 15:06:23 -0800154 StatsValue statsMapValue = {.rxPackets = 1, .rxBytes = 100};
Chenbo Fenged37fea2017-12-13 19:35:01 -0800155 int counterSet = TEST_COUNTERSET;
156 EXPECT_EQ(0, writeToMapEntry(mFakeUidCounterSetMap, &uid, &counterSet, BPF_ANY));
157 EXPECT_EQ(0, writeToMapEntry(mFakeTagStatsMap, key, &statsMapValue, BPF_ANY));
158 key->tag = 0;
159 EXPECT_EQ(0, writeToMapEntry(mFakeUidStatsMap, key, &statsMapValue, BPF_ANY));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800160 // put tag information back to statsKey
161 key->tag = tag;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800162 }
163
Chenbo Feng89c12f12018-03-21 10:29:18 -0700164 void checkUidOwnerRuleForChain(ChildChain chain, const unique_fd& targetMap) {
165 uint32_t uid = TEST_UID;
166 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, DENY, BLACKLIST));
167 uint8_t value;
168 EXPECT_EQ(0, findMapEntry(targetMap, &uid, &value));
169 EXPECT_EQ((uint8_t)BPF_DROP, value);
170
171 uid = TEST_UID2;
172 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, ALLOW, WHITELIST));
173 EXPECT_EQ(0, findMapEntry(targetMap, &uid, &value));
174 EXPECT_EQ((uint8_t)BPF_PASS, value);
175
176 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, DENY, WHITELIST));
177 EXPECT_EQ(-1, findMapEntry(targetMap, &uid, &value));
178 EXPECT_EQ(ENOENT, errno);
179
180 uid = TEST_UID;
181 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, ALLOW, BLACKLIST));
182 EXPECT_EQ(-1, findMapEntry(targetMap, &uid, &value));
183 EXPECT_EQ(ENOENT, errno);
184
185 uid = TEST_UID3;
186 EXPECT_EQ(-ENOENT, mTc.changeUidOwnerRule(chain, uid, ALLOW, BLACKLIST));
187 EXPECT_EQ(-1, findMapEntry(targetMap, &uid, &value));
188 EXPECT_EQ(ENOENT, errno);
189 }
190
191 void checkEachUidValue(const std::vector<int32_t>& uids, const uint8_t expectValue,
192 const unique_fd& targetMap) {
193 uint8_t value;
194 for (auto uid : uids) {
195 EXPECT_EQ(0, findMapEntry(targetMap, &uid, &value));
196 EXPECT_EQ((uint8_t)expectValue, value);
197 }
198 std::set<uint32_t> uidSet(uids.begin(), uids.end());
199 auto checkNoOtherUid = [&uidSet](void *key, const base::unique_fd&) {
200 int32_t uid = *(int32_t *)key;
201 EXPECT_NE(uidSet.end(), uidSet.find(uid));
202 return 0;
203 };
204 uint32_t nonExistentKey = NONEXISTENT_UID;
205 uint8_t dummyValue;
206 EXPECT_EQ(0, bpfIterateMap(nonExistentKey, dummyValue, targetMap, checkNoOtherUid));
207 }
208
209 void checkUidMapReplace(const std::string& name, const std::vector<int32_t>& uids,
210 const unique_fd& targetMap) {
211 bool isWhitelist = true;
212 EXPECT_EQ(0, mTc.replaceUidOwnerMap(name, isWhitelist, uids));
213 checkEachUidValue(uids, BPF_PASS, targetMap);
214
215 isWhitelist = false;
216 EXPECT_EQ(0, mTc.replaceUidOwnerMap(name, isWhitelist, uids));
217 checkEachUidValue(uids, BPF_DROP, targetMap);
218 }
219
Chenbo Fenged37fea2017-12-13 19:35:01 -0800220 void TearDown() {
221 mFakeCookieTagMap.reset();
222 mFakeUidCounterSetMap.reset();
223 mFakeUidStatsMap.reset();
224 mFakeTagStatsMap.reset();
225 }
226};
227
228TEST_F(TrafficControllerTest, TestTagSocketV4) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900229 SKIP_IF_BPF_NOT_SUPPORTED;
230
Chenbo Fenged37fea2017-12-13 19:35:01 -0800231 uint64_t sockCookie;
232 int v4socket = setUpSocketAndTag(AF_INET, &sockCookie, TEST_TAG, TEST_UID);
233 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
234 ASSERT_EQ(0, mTc.untagSocket(v4socket));
235 expectNoTag(sockCookie);
236 expectTagMapEmpty();
237}
238
239TEST_F(TrafficControllerTest, TestReTagSocket) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900240 SKIP_IF_BPF_NOT_SUPPORTED;
241
Chenbo Fenged37fea2017-12-13 19:35:01 -0800242 uint64_t sockCookie;
243 int v4socket = setUpSocketAndTag(AF_INET, &sockCookie, TEST_TAG, TEST_UID);
244 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
245 ASSERT_EQ(0, mTc.tagSocket(v4socket, TEST_TAG + 1, TEST_UID + 1));
246 expectUidTag(sockCookie, TEST_UID + 1, TEST_TAG + 1);
247}
248
249TEST_F(TrafficControllerTest, TestTagTwoSockets) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900250 SKIP_IF_BPF_NOT_SUPPORTED;
251
Chenbo Fenged37fea2017-12-13 19:35:01 -0800252 uint64_t sockCookie1;
253 uint64_t sockCookie2;
254 int v4socket1 = setUpSocketAndTag(AF_INET, &sockCookie1, TEST_TAG, TEST_UID);
255 setUpSocketAndTag(AF_INET, &sockCookie2, TEST_TAG, TEST_UID);
256 expectUidTag(sockCookie1, TEST_UID, TEST_TAG);
257 expectUidTag(sockCookie2, TEST_UID, TEST_TAG);
258 ASSERT_EQ(0, mTc.untagSocket(v4socket1));
259 expectNoTag(sockCookie1);
260 expectUidTag(sockCookie2, TEST_UID, TEST_TAG);
261 uint64_t cookieResult;
262 ASSERT_EQ(-1, getNextMapKey(mFakeCookieTagMap, &sockCookie2, &cookieResult));
263}
264
265TEST_F(TrafficControllerTest, TestTagSocketV6) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900266 SKIP_IF_BPF_NOT_SUPPORTED;
267
Chenbo Fenged37fea2017-12-13 19:35:01 -0800268 uint64_t sockCookie;
269 int v6socket = setUpSocketAndTag(AF_INET6, &sockCookie, TEST_TAG, TEST_UID);
270 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
271 ASSERT_EQ(0, mTc.untagSocket(v6socket));
272 expectNoTag(sockCookie);
273 expectTagMapEmpty();
274}
275
276TEST_F(TrafficControllerTest, TestTagInvalidSocket) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900277 SKIP_IF_BPF_NOT_SUPPORTED;
278
Chenbo Fenged37fea2017-12-13 19:35:01 -0800279 int invalidSocket = -1;
280 ASSERT_GT(0, mTc.tagSocket(invalidSocket, TEST_TAG, TEST_UID));
281 expectTagMapEmpty();
282}
283
284TEST_F(TrafficControllerTest, TestUntagInvalidSocket) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900285 SKIP_IF_BPF_NOT_SUPPORTED;
286
Chenbo Fenged37fea2017-12-13 19:35:01 -0800287 int invalidSocket = -1;
288 ASSERT_GT(0, mTc.untagSocket(invalidSocket));
289 int v4socket = socket(AF_INET, SOCK_STREAM, 0);
290 ASSERT_GT(0, mTc.untagSocket(v4socket));
291 expectTagMapEmpty();
292}
293
294TEST_F(TrafficControllerTest, TestSetCounterSet) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900295 SKIP_IF_BPF_NOT_SUPPORTED;
296
Chenbo Fenged37fea2017-12-13 19:35:01 -0800297 ASSERT_EQ(0, mTc.setCounterSet(TEST_COUNTERSET, TEST_UID));
298 uid_t uid = TEST_UID;
299 int counterSetResult;
300 ASSERT_EQ(0, findMapEntry(mFakeUidCounterSetMap, &uid, &counterSetResult));
301 ASSERT_EQ(TEST_COUNTERSET, counterSetResult);
302 ASSERT_EQ(0, mTc.setCounterSet(DEFAULT_COUNTERSET, TEST_UID));
303 ASSERT_EQ(-1, findMapEntry(mFakeUidCounterSetMap, &uid, &counterSetResult));
304 uid = TEST_UID;
305 ASSERT_EQ(-1, getNextMapKey(mFakeUidCounterSetMap, &uid, &counterSetResult));
306}
307
308TEST_F(TrafficControllerTest, TestSetInvalidCounterSet) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900309 SKIP_IF_BPF_NOT_SUPPORTED;
310
Chenbo Fenged37fea2017-12-13 19:35:01 -0800311 ASSERT_GT(0, mTc.setCounterSet(COUNTERSETS_LIMIT, TEST_UID));
312 uid_t uid = TEST_UID;
313 int counterSetResult;
314 ASSERT_EQ(-1, findMapEntry(mFakeUidCounterSetMap, &uid, &counterSetResult));
315 uid = TEST_UID;
316 ASSERT_EQ(-1, getNextMapKey(mFakeUidCounterSetMap, &uid, &counterSetResult));
317}
318
319TEST_F(TrafficControllerTest, TestDeleteTagData) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900320 SKIP_IF_BPF_NOT_SUPPORTED;
321
Chenbo Fenged37fea2017-12-13 19:35:01 -0800322 uint64_t cookie = 1;
323 uid_t uid = TEST_UID;
324 uint32_t tag = TEST_TAG;
325 StatsKey tagStatsMapKey;
326 populateFakeStats(cookie, uid, tag, &tagStatsMapKey);
327 ASSERT_EQ(0, mTc.deleteTagData(TEST_TAG, TEST_UID));
328 UidTag cookieMapkey;
329 ASSERT_EQ(-1, findMapEntry(mFakeCookieTagMap, &cookie, &cookieMapkey));
330 int counterSetResult;
331 ASSERT_EQ(0, findMapEntry(mFakeUidCounterSetMap, &uid, &counterSetResult));
332 ASSERT_EQ(TEST_COUNTERSET, counterSetResult);
Chenbo Fengf43bf812017-12-15 18:27:22 -0800333 StatsValue statsMapResult;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800334 ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey, &statsMapResult));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800335 tagStatsMapKey.tag = 0;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800336 ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey, &statsMapResult));
Chenbo Fengeac6c472018-02-05 15:06:23 -0800337 ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets);
338 ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800339}
340
341TEST_F(TrafficControllerTest, TestDeleteAllUidData) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900342 SKIP_IF_BPF_NOT_SUPPORTED;
343
Chenbo Fenged37fea2017-12-13 19:35:01 -0800344 uint64_t cookie = 1;
345 uid_t uid = TEST_UID;
346 uint32_t tag = TEST_TAG;
347 StatsKey tagStatsMapKey;
348 populateFakeStats(cookie, uid, tag, &tagStatsMapKey);
349 ASSERT_EQ(0, mTc.deleteTagData(0, TEST_UID));
350 UidTag cookieMapkey;
351 ASSERT_EQ(-1, findMapEntry(mFakeCookieTagMap, &cookie, &cookieMapkey));
352 int counterSetResult;
353 ASSERT_EQ(-1, findMapEntry(mFakeUidCounterSetMap, &uid, &counterSetResult));
Chenbo Fengf43bf812017-12-15 18:27:22 -0800354 StatsValue statsMapResult;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800355 ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey, &statsMapResult));
356 ASSERT_EQ(-1, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey, &statsMapResult));
357 StatsKey removedStatsKey= {.uid = 0, .tag = 0, .counterSet = COUNTERSETS_LIMIT,
358 .ifaceIndex = 0};
359 ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &removedStatsKey, &statsMapResult));
Chenbo Fengeac6c472018-02-05 15:06:23 -0800360 ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets);
361 ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800362}
363
364TEST_F(TrafficControllerTest, TestDeleteDataWithTwoTags) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900365 SKIP_IF_BPF_NOT_SUPPORTED;
366
Chenbo Fenged37fea2017-12-13 19:35:01 -0800367 uint64_t cookie1 = 1;
368 uint64_t cookie2 = 2;
369 uid_t uid = TEST_UID;
370 uint32_t tag1 = TEST_TAG;
371 uint32_t tag2 = TEST_TAG + 1;
372 StatsKey tagStatsMapKey1;
373 StatsKey tagStatsMapKey2;
374 populateFakeStats(cookie1, uid, tag1, &tagStatsMapKey1);
375 populateFakeStats(cookie2, uid, tag2, &tagStatsMapKey2);
376 ASSERT_EQ(0, mTc.deleteTagData(TEST_TAG, TEST_UID));
377 UidTag cookieMapResult;
378 ASSERT_EQ(-1, findMapEntry(mFakeCookieTagMap, &cookie1, &cookieMapResult));
379 ASSERT_EQ(0, findMapEntry(mFakeCookieTagMap, &cookie2, &cookieMapResult));
380 ASSERT_EQ(TEST_UID, cookieMapResult.uid);
381 ASSERT_EQ(TEST_TAG + 1, cookieMapResult.tag);
382 int counterSetResult;
383 ASSERT_EQ(0, findMapEntry(mFakeUidCounterSetMap, &uid, &counterSetResult));
384 ASSERT_EQ(TEST_COUNTERSET, counterSetResult);
Chenbo Fengf43bf812017-12-15 18:27:22 -0800385 StatsValue statsMapResult;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800386 ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey1, &statsMapResult));
387 ASSERT_EQ(0, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey2, &statsMapResult));
Chenbo Fengeac6c472018-02-05 15:06:23 -0800388 ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets);
389 ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800390}
391
392TEST_F(TrafficControllerTest, TestDeleteDataWithTwoUids) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900393 SKIP_IF_BPF_NOT_SUPPORTED;
394
Chenbo Fenged37fea2017-12-13 19:35:01 -0800395 uint64_t cookie1 = 1;
396 uint64_t cookie2 = 2;
397 uid_t uid1 = TEST_UID;
398 uid_t uid2 = TEST_UID + 1;
399 uint32_t tag = TEST_TAG;
400 StatsKey tagStatsMapKey1;
401 StatsKey tagStatsMapKey2;
402 populateFakeStats(cookie1, uid1, tag, &tagStatsMapKey1);
403 populateFakeStats(cookie2, uid2, tag, &tagStatsMapKey2);
404
405 // Delete the stats of one of the uid. Check if it is properly collected by
406 // removedStats.
407 ASSERT_EQ(0, mTc.deleteTagData(0, uid2));
408 UidTag cookieMapResult;
409 ASSERT_EQ(-1, findMapEntry(mFakeCookieTagMap, &cookie2, &cookieMapResult));
410 int counterSetResult;
411 ASSERT_EQ(0, findMapEntry(mFakeUidCounterSetMap, &uid1, &counterSetResult));
412 ASSERT_EQ(TEST_COUNTERSET, counterSetResult);
413 ASSERT_EQ(-1, findMapEntry(mFakeUidCounterSetMap, &uid2, &counterSetResult));
Chenbo Fengf43bf812017-12-15 18:27:22 -0800414 StatsValue statsMapResult;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800415 ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey2, &statsMapResult));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800416 tagStatsMapKey2.tag = 0;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800417 ASSERT_EQ(-1, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey2, &statsMapResult));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800418 tagStatsMapKey1.tag = 0;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800419 ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey1, &statsMapResult));
Chenbo Fengeac6c472018-02-05 15:06:23 -0800420 ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets);
421 ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800422 StatsKey removedStatsKey= {.uid = 0, .tag = 0, .counterSet = COUNTERSETS_LIMIT,
423 .ifaceIndex = 0};
424 ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &removedStatsKey, &statsMapResult));
Chenbo Fengeac6c472018-02-05 15:06:23 -0800425 ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets);
426 ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800427
428 // Delete the stats of the other uid. Check if it is properly added on the
429 // previous removedStats data.
430 ASSERT_EQ(0, mTc.deleteTagData(0, uid1));
431 ASSERT_EQ(-1, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey1, &statsMapResult));
432 ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &removedStatsKey, &statsMapResult));
Chenbo Fengeac6c472018-02-05 15:06:23 -0800433 ASSERT_EQ((uint64_t)2, statsMapResult.rxPackets);
434 ASSERT_EQ((uint64_t)200, statsMapResult.rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800435}
436
Chenbo Feng89c12f12018-03-21 10:29:18 -0700437TEST_F(TrafficControllerTest, TestUpdateOwnerMapEntry) {
438 SKIP_IF_BPF_NOT_SUPPORTED;
439
440 uint32_t uid = TEST_UID;
441 ASSERT_EQ(0, mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, DENY, BLACKLIST));
442 uint8_t value;
443 ASSERT_EQ(0, findMapEntry(mFakeDozableUidMap, &uid, &value));
444 ASSERT_EQ((uint8_t)BPF_DROP, value);
445
446 uid = TEST_UID2;
447 ASSERT_EQ(0, mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, ALLOW, WHITELIST));
448 ASSERT_EQ(0, findMapEntry(mFakeDozableUidMap, &uid, &value));
449 ASSERT_EQ((uint8_t)BPF_PASS, value);
450
451 ASSERT_EQ(0, mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, DENY, WHITELIST));
452 ASSERT_EQ(-1, findMapEntry(mFakeDozableUidMap, &uid, &value));
453 ASSERT_EQ(ENOENT, errno);
454
455 uid = TEST_UID;
456 ASSERT_EQ(0, mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, ALLOW, BLACKLIST));
457 ASSERT_EQ(-1, findMapEntry(mFakeDozableUidMap, &uid, &value));
458 ASSERT_EQ(ENOENT, errno);
459
460 uid = TEST_UID3;
461 ASSERT_EQ(-ENOENT, mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, ALLOW, BLACKLIST));
462 ASSERT_EQ(-1, findMapEntry(mFakeDozableUidMap, &uid, &value));
463 ASSERT_EQ(ENOENT, errno);
464}
465
466TEST_F(TrafficControllerTest, TestChangeUidOwnerRule) {
467 SKIP_IF_BPF_NOT_SUPPORTED;
468
469 checkUidOwnerRuleForChain(DOZABLE, mFakeDozableUidMap);
470 checkUidOwnerRuleForChain(STANDBY, mFakeStandbyUidMap);
471 checkUidOwnerRuleForChain(POWERSAVE, mFakePowerSaveUidMap);
472 ASSERT_EQ(-EINVAL, mTc.changeUidOwnerRule(NONE, TEST_UID, ALLOW, WHITELIST));
473 ASSERT_EQ(-EINVAL, mTc.changeUidOwnerRule(INVALID_CHAIN, TEST_UID, ALLOW, WHITELIST));
474}
475
476TEST_F(TrafficControllerTest, TestReplaceUidOwnerMap) {
477 SKIP_IF_BPF_NOT_SUPPORTED;
478
479 std::vector<int32_t> uids = {TEST_UID, TEST_UID2, TEST_UID3};
480 checkUidMapReplace("fw_dozable", uids, mFakeDozableUidMap);
481 checkUidMapReplace("fw_standby", uids, mFakeStandbyUidMap);
482 checkUidMapReplace("fw_powersave", uids, mFakePowerSaveUidMap);
483 ASSERT_EQ(-EINVAL, mTc.replaceUidOwnerMap("unknow", true, uids));
484}
485
Chenbo Fenged37fea2017-12-13 19:35:01 -0800486} // namespace net
487} // namespace android