blob: bb56d978cda1d24535870eceed9a6e34026e95ec [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 Feng4f6c2372018-04-26 10:37:55 -070036#include "netdutils/StatusOr.h"
37
Chenbo Feng89c12f12018-03-21 10:29:18 -070038#include "FirewallController.h"
Chenbo Fenged37fea2017-12-13 19:35:01 -080039#include "TrafficController.h"
40#include "bpf/BpfUtils.h"
41
Bernie Innocenti7e25ec02018-07-02 19:32:17 +090042using namespace android::bpf; // NOLINT(google-build-using-namespace): grandfathered
Chenbo Fenged37fea2017-12-13 19:35:01 -080043
Chenbo Fenged37fea2017-12-13 19:35:01 -080044namespace android {
45namespace net {
46
Chenbo Feng4f6c2372018-04-26 10:37:55 -070047using netdutils::isOk;
Chenbo Feng4f6c2372018-04-26 10:37:55 -070048using netdutils::StatusOr;
Chenbo Fenged37fea2017-12-13 19:35:01 -080049
50constexpr int TEST_MAP_SIZE = 10;
51constexpr uid_t TEST_UID = 10086;
Chenbo Feng89c12f12018-03-21 10:29:18 -070052constexpr uid_t TEST_UID2 = 54321;
53constexpr uid_t TEST_UID3 = 98765;
Chenbo Fenged37fea2017-12-13 19:35:01 -080054constexpr uint32_t TEST_TAG = 42;
Chenbo Feng4f6c2372018-04-26 10:37:55 -070055constexpr uint32_t TEST_COUNTERSET = 1;
56constexpr uint32_t DEFAULT_COUNTERSET = 0;
Chenbo Fenged37fea2017-12-13 19:35:01 -080057
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070058#define ASSERT_VALID(x) ASSERT_TRUE((x).isValid())
59
Chenbo Fenged37fea2017-12-13 19:35:01 -080060class TrafficControllerTest : public ::testing::Test {
61 protected:
62 TrafficControllerTest() {}
63 TrafficController mTc;
Chenbo Feng4f6c2372018-04-26 10:37:55 -070064 BpfMap<uint64_t, UidTag> mFakeCookieTagMap;
65 BpfMap<uint32_t, uint8_t> mFakeUidCounterSetMap;
Chenbo Fengbc4a15f2018-05-11 19:15:15 -070066 BpfMap<uint32_t, StatsValue> mFakeAppUidStatsMap;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070067 BpfMap<StatsKey, StatsValue> mFakeStatsMapA;
Chenbo Feng703798e2018-06-15 17:07:59 -070068 BpfMap<uint32_t, uint8_t> mFakeConfigurationMap;
Rubin Xuec27ff22019-01-08 21:33:03 +000069 BpfMap<uint32_t, UidOwnerValue> mFakeUidOwnerMap;
Chenbo Feng48eaed32018-12-26 17:40:21 -080070 BpfMap<uint32_t, uint8_t> mFakeUidPermissionMap;
Chenbo Fenged37fea2017-12-13 19:35:01 -080071
72 void SetUp() {
Chenbo Feng84d9f9f2019-04-12 15:31:02 -070073 std::lock_guard guard(mTc.mMutex);
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +090074 SKIP_IF_BPF_NOT_SUPPORTED;
Chenbo Fengef01d8d2019-04-09 11:53:45 -070075 ASSERT_EQ(0, setrlimitForTest());
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +090076
Chenbo Feng4f6c2372018-04-26 10:37:55 -070077 mFakeCookieTagMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(uint64_t),
78 sizeof(struct UidTag), TEST_MAP_SIZE, 0));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070079 ASSERT_VALID(mFakeCookieTagMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -080080
Chenbo Feng4f6c2372018-04-26 10:37:55 -070081 mFakeUidCounterSetMap.reset(
82 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), TEST_MAP_SIZE, 0));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070083 ASSERT_VALID(mFakeUidCounterSetMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -080084
Chenbo Fengbc4a15f2018-05-11 19:15:15 -070085 mFakeAppUidStatsMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t),
86 sizeof(struct StatsValue), TEST_MAP_SIZE, 0));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070087 ASSERT_VALID(mFakeAppUidStatsMap);
Chenbo Fengbc4a15f2018-05-11 19:15:15 -070088
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070089 mFakeStatsMapA.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(struct StatsKey),
90 sizeof(struct StatsValue), TEST_MAP_SIZE, 0));
91 ASSERT_VALID(mFakeStatsMapA);
Chenbo Fenged37fea2017-12-13 19:35:01 -080092
Chenbo Feng703798e2018-06-15 17:07:59 -070093 mFakeConfigurationMap.reset(
94 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), 1, 0));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070095 ASSERT_VALID(mFakeConfigurationMap);
Chenbo Feng89c12f12018-03-21 10:29:18 -070096
Rubin Xuec27ff22019-01-08 21:33:03 +000097 mFakeUidOwnerMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(UidOwnerValue),
98 TEST_MAP_SIZE, 0));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -070099 ASSERT_VALID(mFakeUidOwnerMap);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800100 mFakeUidPermissionMap.reset(
101 createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), TEST_MAP_SIZE, 0));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700102 ASSERT_VALID(mFakeUidPermissionMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800103
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700104 mTc.mCookieTagMap.reset(dupFd(mFakeCookieTagMap.getMap()));
105 ASSERT_VALID(mTc.mCookieTagMap);
106 mTc.mUidCounterSetMap.reset(dupFd(mFakeUidCounterSetMap.getMap()));
107 ASSERT_VALID(mTc.mUidCounterSetMap);
108 mTc.mAppUidStatsMap.reset(dupFd(mFakeAppUidStatsMap.getMap()));
109 ASSERT_VALID(mTc.mAppUidStatsMap);
110 mTc.mStatsMapA.reset(dupFd(mFakeStatsMapA.getMap()));
111 ASSERT_VALID(mTc.mStatsMapA);
112 mTc.mConfigurationMap.reset(dupFd(mFakeConfigurationMap.getMap()));
113 ASSERT_VALID(mTc.mConfigurationMap);
114
115 // Always write to stats map A by default.
116 ASSERT_TRUE(isOk(mTc.mConfigurationMap.writeValue(CURRENT_STATS_MAP_CONFIGURATION_KEY,
Chenbo Fengb0495132019-04-10 12:54:41 -0700117 SELECT_MAP_A, BPF_ANY)));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700118 mTc.mUidOwnerMap.reset(dupFd(mFakeUidOwnerMap.getMap()));
119 ASSERT_VALID(mTc.mUidOwnerMap);
120 mTc.mUidPermissionMap.reset(dupFd(mFakeUidPermissionMap.getMap()));
121 ASSERT_VALID(mTc.mUidPermissionMap);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800122 mTc.mPrivilegedUser.clear();
Chenbo Fenged37fea2017-12-13 19:35:01 -0800123 }
124
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700125 int dupFd(const android::base::unique_fd& mapFd) {
126 return fcntl(mapFd.get(), F_DUPFD_CLOEXEC, 0);
127 }
128
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800129 int setUpSocketAndTag(int protocol, uint64_t* cookie, uint32_t tag, uid_t uid,
130 uid_t callingUid) {
Bernie Innocenti15bb55c2018-06-03 16:19:51 +0900131 int sock = socket(protocol, SOCK_STREAM | SOCK_CLOEXEC, 0);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800132 EXPECT_LE(0, sock);
133 *cookie = getSocketCookie(sock);
Chenbo Fengef1cab32018-04-13 19:50:49 -0700134 EXPECT_NE(NONEXISTENT_COOKIE, *cookie);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800135 EXPECT_EQ(0, mTc.tagSocket(sock, tag, uid, callingUid));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800136 return sock;
137 }
138
139 void expectUidTag(uint64_t cookie, uid_t uid, uint32_t tag) {
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700140 StatusOr<UidTag> tagResult = mFakeCookieTagMap.readValue(cookie);
141 EXPECT_TRUE(isOk(tagResult));
142 EXPECT_EQ(uid, tagResult.value().uid);
143 EXPECT_EQ(tag, tagResult.value().tag);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800144 }
145
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700146 void expectNoTag(uint64_t cookie) { EXPECT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie))); }
Chenbo Fenged37fea2017-12-13 19:35:01 -0800147
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700148 void populateFakeStats(uint64_t cookie, uint32_t uid, uint32_t tag, StatsKey* key) {
Chenbo Fenged37fea2017-12-13 19:35:01 -0800149 UidTag cookieMapkey = {.uid = (uint32_t)uid, .tag = tag};
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700150 EXPECT_TRUE(isOk(mFakeCookieTagMap.writeValue(cookie, cookieMapkey, BPF_ANY)));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800151 *key = {.uid = uid, .tag = tag, .counterSet = TEST_COUNTERSET, .ifaceIndex = 1};
Chenbo Fengeac6c472018-02-05 15:06:23 -0800152 StatsValue statsMapValue = {.rxPackets = 1, .rxBytes = 100};
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700153 uint8_t counterSet = TEST_COUNTERSET;
154 EXPECT_TRUE(isOk(mFakeUidCounterSetMap.writeValue(uid, counterSet, BPF_ANY)));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700155 EXPECT_TRUE(isOk(mFakeStatsMapA.writeValue(*key, statsMapValue, BPF_ANY)));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800156 key->tag = 0;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700157 EXPECT_TRUE(isOk(mFakeStatsMapA.writeValue(*key, statsMapValue, BPF_ANY)));
Chenbo Fengbc4a15f2018-05-11 19:15:15 -0700158 EXPECT_TRUE(isOk(mFakeAppUidStatsMap.writeValue(uid, statsMapValue, BPF_ANY)));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800159 // put tag information back to statsKey
160 key->tag = tag;
Chenbo Fenged37fea2017-12-13 19:35:01 -0800161 }
162
Chenbo Feng703798e2018-06-15 17:07:59 -0700163 void checkUidOwnerRuleForChain(ChildChain chain, UidOwnerMatchType match) {
Chenbo Feng89c12f12018-03-21 10:29:18 -0700164 uint32_t uid = TEST_UID;
165 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, DENY, BLACKLIST));
Rubin Xuec27ff22019-01-08 21:33:03 +0000166 StatusOr<UidOwnerValue> value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700167 EXPECT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000168 EXPECT_TRUE(value.value().rule & match);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700169
170 uid = TEST_UID2;
171 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, ALLOW, WHITELIST));
Chenbo Feng703798e2018-06-15 17:07:59 -0700172 value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700173 EXPECT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000174 EXPECT_TRUE(value.value().rule & match);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700175
176 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, DENY, WHITELIST));
Chenbo Feng703798e2018-06-15 17:07:59 -0700177 value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700178 EXPECT_FALSE(isOk(value));
179 EXPECT_EQ(ENOENT, value.status().code());
Chenbo Feng89c12f12018-03-21 10:29:18 -0700180
181 uid = TEST_UID;
182 EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, ALLOW, BLACKLIST));
Chenbo Feng703798e2018-06-15 17:07:59 -0700183 value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700184 EXPECT_FALSE(isOk(value));
185 EXPECT_EQ(ENOENT, value.status().code());
Chenbo Feng89c12f12018-03-21 10:29:18 -0700186
187 uid = TEST_UID3;
188 EXPECT_EQ(-ENOENT, mTc.changeUidOwnerRule(chain, uid, ALLOW, BLACKLIST));
Chenbo Feng703798e2018-06-15 17:07:59 -0700189 value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700190 EXPECT_FALSE(isOk(value));
191 EXPECT_EQ(ENOENT, value.status().code());
Chenbo Feng89c12f12018-03-21 10:29:18 -0700192 }
193
Chenbo Feng703798e2018-06-15 17:07:59 -0700194 void checkEachUidValue(const std::vector<int32_t>& uids, UidOwnerMatchType match) {
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700195 for (uint32_t uid : uids) {
Rubin Xuec27ff22019-01-08 21:33:03 +0000196 StatusOr<UidOwnerValue> value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700197 EXPECT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000198 EXPECT_TRUE(value.value().rule & match);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700199 }
200 std::set<uint32_t> uidSet(uids.begin(), uids.end());
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700201 const auto checkNoOtherUid = [&uidSet](const int32_t& key,
Rubin Xuec27ff22019-01-08 21:33:03 +0000202 const BpfMap<uint32_t, UidOwnerValue>&) {
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700203 EXPECT_NE(uidSet.end(), uidSet.find(key));
204 return netdutils::status::ok;
Chenbo Feng89c12f12018-03-21 10:29:18 -0700205 };
Chenbo Feng703798e2018-06-15 17:07:59 -0700206 EXPECT_TRUE(isOk(mFakeUidOwnerMap.iterate(checkNoOtherUid)));
Chenbo Feng89c12f12018-03-21 10:29:18 -0700207 }
208
209 void checkUidMapReplace(const std::string& name, const std::vector<int32_t>& uids,
Chenbo Feng703798e2018-06-15 17:07:59 -0700210 UidOwnerMatchType match) {
Chenbo Feng89c12f12018-03-21 10:29:18 -0700211 bool isWhitelist = true;
212 EXPECT_EQ(0, mTc.replaceUidOwnerMap(name, isWhitelist, uids));
Chenbo Feng703798e2018-06-15 17:07:59 -0700213 checkEachUidValue(uids, match);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700214
215 isWhitelist = false;
216 EXPECT_EQ(0, mTc.replaceUidOwnerMap(name, isWhitelist, uids));
Chenbo Feng703798e2018-06-15 17:07:59 -0700217 checkEachUidValue(uids, match);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700218 }
Rubin Xuec27ff22019-01-08 21:33:03 +0000219 void expectUidOwnerMapValues(const std::vector<std::string>& appStrUids, uint8_t expectedRule,
220 uint32_t expectedIif) {
Bernie Innocenti7e25ec02018-07-02 19:32:17 +0900221 for (const std::string& strUid : appStrUids) {
Chenbo Feng95892f32018-06-07 14:52:02 -0700222 uint32_t uid = stoi(strUid);
Rubin Xuec27ff22019-01-08 21:33:03 +0000223 StatusOr<UidOwnerValue> value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng95892f32018-06-07 14:52:02 -0700224 EXPECT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000225 EXPECT_EQ(expectedRule, value.value().rule)
226 << "Expected rule for UID " << uid << " to be " << expectedRule << ", but was "
227 << value.value().rule;
228 EXPECT_EQ(expectedIif, value.value().iif)
229 << "Expected iif for UID " << uid << " to be " << expectedIif << ", but was "
230 << value.value().iif;
Chenbo Feng95892f32018-06-07 14:52:02 -0700231 }
232 }
233
Rubin Xuec27ff22019-01-08 21:33:03 +0000234 template <class Key, class Value>
235 void expectMapEmpty(BpfMap<Key, Value>& map) {
Chenbo Fengc16827b2018-06-08 15:58:11 -0700236 auto isEmpty = map.isEmpty();
237 EXPECT_TRUE(isOk(isEmpty));
238 EXPECT_TRUE(isEmpty.value());
239 }
240
Chenbo Feng48eaed32018-12-26 17:40:21 -0800241 void expectUidPermissionMapValues(const std::vector<uid_t>& appUids, uint8_t expectedValue) {
242 for (uid_t uid : appUids) {
243 StatusOr<uint8_t> value = mFakeUidPermissionMap.readValue(uid);
244 EXPECT_TRUE(isOk(value));
245 EXPECT_EQ(expectedValue, value.value())
246 << "Expected value for UID " << uid << " to be " << expectedValue
247 << ", but was " << value.value();
248 }
249 }
250
251 void expectPrivilegedUserSet(const std::vector<uid_t>& appUids) {
Chenbo Feng84d9f9f2019-04-12 15:31:02 -0700252 std::lock_guard guard(mTc.mMutex);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800253 EXPECT_EQ(appUids.size(), mTc.mPrivilegedUser.size());
254 for (uid_t uid : appUids) {
255 EXPECT_NE(mTc.mPrivilegedUser.end(), mTc.mPrivilegedUser.find(uid));
256 }
257 }
258
Chenbo Feng84d9f9f2019-04-12 15:31:02 -0700259 void expectPrivilegedUserSetEmpty() {
260 std::lock_guard guard(mTc.mMutex);
261 EXPECT_TRUE(mTc.mPrivilegedUser.empty());
262 }
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800263
264 void addPrivilegedUid(uid_t uid) {
265 std::vector privilegedUid = {uid};
266 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, privilegedUid);
267 }
268
269 void removePrivilegedUid(uid_t uid) {
270 std::vector privilegedUid = {uid};
271 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, privilegedUid);
272 }
273
274 void expectFakeStatsUnchanged(uint64_t cookie, uint32_t tag, uint32_t uid,
275 StatsKey tagStatsMapKey) {
276 StatusOr<UidTag> cookieMapResult = mFakeCookieTagMap.readValue(cookie);
277 EXPECT_TRUE(isOk(cookieMapResult));
278 EXPECT_EQ(uid, cookieMapResult.value().uid);
279 EXPECT_EQ(tag, cookieMapResult.value().tag);
280 StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid);
281 EXPECT_TRUE(isOk(counterSetResult));
282 EXPECT_EQ(TEST_COUNTERSET, counterSetResult.value());
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700283 StatusOr<StatsValue> statsMapResult = mFakeStatsMapA.readValue(tagStatsMapKey);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800284 EXPECT_TRUE(isOk(statsMapResult));
285 EXPECT_EQ((uint64_t)1, statsMapResult.value().rxPackets);
286 EXPECT_EQ((uint64_t)100, statsMapResult.value().rxBytes);
287 tagStatsMapKey.tag = 0;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700288 statsMapResult = mFakeStatsMapA.readValue(tagStatsMapKey);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800289 EXPECT_TRUE(isOk(statsMapResult));
290 EXPECT_EQ((uint64_t)1, statsMapResult.value().rxPackets);
291 EXPECT_EQ((uint64_t)100, statsMapResult.value().rxBytes);
292 auto appStatsResult = mFakeAppUidStatsMap.readValue(uid);
293 EXPECT_TRUE(isOk(appStatsResult));
294 EXPECT_EQ((uint64_t)1, appStatsResult.value().rxPackets);
295 EXPECT_EQ((uint64_t)100, appStatsResult.value().rxBytes);
296 }
Chenbo Fenged37fea2017-12-13 19:35:01 -0800297};
298
299TEST_F(TrafficControllerTest, TestTagSocketV4) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900300 SKIP_IF_BPF_NOT_SUPPORTED;
301
Chenbo Fenged37fea2017-12-13 19:35:01 -0800302 uint64_t sockCookie;
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800303 int v4socket = setUpSocketAndTag(AF_INET, &sockCookie, TEST_TAG, TEST_UID, TEST_UID);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800304 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
305 ASSERT_EQ(0, mTc.untagSocket(v4socket));
306 expectNoTag(sockCookie);
Chenbo Fengc16827b2018-06-08 15:58:11 -0700307 expectMapEmpty(mFakeCookieTagMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800308}
309
310TEST_F(TrafficControllerTest, TestReTagSocket) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900311 SKIP_IF_BPF_NOT_SUPPORTED;
312
Chenbo Fenged37fea2017-12-13 19:35:01 -0800313 uint64_t sockCookie;
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800314 int v4socket = setUpSocketAndTag(AF_INET, &sockCookie, TEST_TAG, TEST_UID, TEST_UID);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800315 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800316 ASSERT_EQ(0, mTc.tagSocket(v4socket, TEST_TAG + 1, TEST_UID + 1, TEST_UID + 1));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800317 expectUidTag(sockCookie, TEST_UID + 1, TEST_TAG + 1);
318}
319
320TEST_F(TrafficControllerTest, TestTagTwoSockets) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900321 SKIP_IF_BPF_NOT_SUPPORTED;
322
Chenbo Fenged37fea2017-12-13 19:35:01 -0800323 uint64_t sockCookie1;
324 uint64_t sockCookie2;
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800325 int v4socket1 = setUpSocketAndTag(AF_INET, &sockCookie1, TEST_TAG, TEST_UID, TEST_UID);
326 setUpSocketAndTag(AF_INET, &sockCookie2, TEST_TAG, TEST_UID, TEST_UID);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800327 expectUidTag(sockCookie1, TEST_UID, TEST_TAG);
328 expectUidTag(sockCookie2, TEST_UID, TEST_TAG);
329 ASSERT_EQ(0, mTc.untagSocket(v4socket1));
330 expectNoTag(sockCookie1);
331 expectUidTag(sockCookie2, TEST_UID, TEST_TAG);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700332 ASSERT_FALSE(isOk(mFakeCookieTagMap.getNextKey(sockCookie2)));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800333}
334
335TEST_F(TrafficControllerTest, TestTagSocketV6) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900336 SKIP_IF_BPF_NOT_SUPPORTED;
337
Chenbo Fenged37fea2017-12-13 19:35:01 -0800338 uint64_t sockCookie;
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800339 int v6socket = setUpSocketAndTag(AF_INET6, &sockCookie, TEST_TAG, TEST_UID, TEST_UID);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800340 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
341 ASSERT_EQ(0, mTc.untagSocket(v6socket));
342 expectNoTag(sockCookie);
Chenbo Fengc16827b2018-06-08 15:58:11 -0700343 expectMapEmpty(mFakeCookieTagMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800344}
345
346TEST_F(TrafficControllerTest, TestTagInvalidSocket) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900347 SKIP_IF_BPF_NOT_SUPPORTED;
348
Chenbo Fenged37fea2017-12-13 19:35:01 -0800349 int invalidSocket = -1;
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800350 ASSERT_GT(0, mTc.tagSocket(invalidSocket, TEST_TAG, TEST_UID, TEST_UID));
Chenbo Fengc16827b2018-06-08 15:58:11 -0700351 expectMapEmpty(mFakeCookieTagMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800352}
353
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800354TEST_F(TrafficControllerTest, TestTagSocketWithoutPermission) {
355 SKIP_IF_BPF_NOT_SUPPORTED;
356
357 int sock = socket(AF_INET6, SOCK_STREAM | SOCK_CLOEXEC, 0);
358 ASSERT_NE(-1, sock);
359 ASSERT_EQ(-EPERM, mTc.tagSocket(sock, TEST_TAG, TEST_UID, TEST_UID2));
360 expectMapEmpty(mFakeCookieTagMap);
361}
362
363TEST_F(TrafficControllerTest, TestTagSocketWithPermission) {
364 SKIP_IF_BPF_NOT_SUPPORTED;
365
366 // Grant permission to calling uid.
367 std::vector<uid_t> callingUid = {TEST_UID2};
368 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, callingUid);
369
370 // Tag a socket to a different uid other then callingUid.
371 uint64_t sockCookie;
372 int v6socket = setUpSocketAndTag(AF_INET6, &sockCookie, TEST_TAG, TEST_UID, TEST_UID2);
373 expectUidTag(sockCookie, TEST_UID, TEST_TAG);
374 EXPECT_EQ(0, mTc.untagSocket(v6socket));
375 expectNoTag(sockCookie);
376 expectMapEmpty(mFakeCookieTagMap);
377
378 // Clean up the permission
379 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, callingUid);
380 expectPrivilegedUserSetEmpty();
381}
382
Chenbo Fenged37fea2017-12-13 19:35:01 -0800383TEST_F(TrafficControllerTest, TestUntagInvalidSocket) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900384 SKIP_IF_BPF_NOT_SUPPORTED;
385
Chenbo Fenged37fea2017-12-13 19:35:01 -0800386 int invalidSocket = -1;
387 ASSERT_GT(0, mTc.untagSocket(invalidSocket));
Bernie Innocenti15bb55c2018-06-03 16:19:51 +0900388 int v4socket = socket(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800389 ASSERT_GT(0, mTc.untagSocket(v4socket));
Chenbo Fengc16827b2018-06-08 15:58:11 -0700390 expectMapEmpty(mFakeCookieTagMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800391}
392
393TEST_F(TrafficControllerTest, TestSetCounterSet) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900394 SKIP_IF_BPF_NOT_SUPPORTED;
395
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800396 uid_t callingUid = TEST_UID2;
397 addPrivilegedUid(callingUid);
398 ASSERT_EQ(0, mTc.setCounterSet(TEST_COUNTERSET, TEST_UID, callingUid));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800399 uid_t uid = TEST_UID;
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700400 StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid);
401 ASSERT_TRUE(isOk(counterSetResult));
402 ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value());
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800403 ASSERT_EQ(0, mTc.setCounterSet(DEFAULT_COUNTERSET, TEST_UID, callingUid));
404 ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid)));
405 expectMapEmpty(mFakeUidCounterSetMap);
406}
407
408TEST_F(TrafficControllerTest, TestSetCounterSetWithoutPermission) {
409 SKIP_IF_BPF_NOT_SUPPORTED;
410
411 ASSERT_EQ(-EPERM, mTc.setCounterSet(TEST_COUNTERSET, TEST_UID, TEST_UID2));
412 uid_t uid = TEST_UID;
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700413 ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid)));
Chenbo Fengc16827b2018-06-08 15:58:11 -0700414 expectMapEmpty(mFakeUidCounterSetMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800415}
416
417TEST_F(TrafficControllerTest, TestSetInvalidCounterSet) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900418 SKIP_IF_BPF_NOT_SUPPORTED;
419
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800420 uid_t callingUid = TEST_UID2;
421 addPrivilegedUid(callingUid);
422 ASSERT_GT(0, mTc.setCounterSet(OVERFLOW_COUNTERSET, TEST_UID, callingUid));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800423 uid_t uid = TEST_UID;
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700424 ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid)));
Chenbo Fengc16827b2018-06-08 15:58:11 -0700425 expectMapEmpty(mFakeUidCounterSetMap);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800426}
427
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800428TEST_F(TrafficControllerTest, TestDeleteTagDataWithoutPermission) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900429 SKIP_IF_BPF_NOT_SUPPORTED;
430
Chenbo Fenged37fea2017-12-13 19:35:01 -0800431 uint64_t cookie = 1;
432 uid_t uid = TEST_UID;
433 uint32_t tag = TEST_TAG;
434 StatsKey tagStatsMapKey;
435 populateFakeStats(cookie, uid, tag, &tagStatsMapKey);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800436 ASSERT_EQ(-EPERM, mTc.deleteTagData(0, TEST_UID, TEST_UID2));
437
438 expectFakeStatsUnchanged(cookie, tag, uid, tagStatsMapKey);
439}
440
441TEST_F(TrafficControllerTest, TestDeleteTagData) {
442 SKIP_IF_BPF_NOT_SUPPORTED;
443
444 uid_t callingUid = TEST_UID2;
445 addPrivilegedUid(callingUid);
446 uint64_t cookie = 1;
447 uid_t uid = TEST_UID;
448 uint32_t tag = TEST_TAG;
449 StatsKey tagStatsMapKey;
450 populateFakeStats(cookie, uid, tag, &tagStatsMapKey);
451 ASSERT_EQ(0, mTc.deleteTagData(TEST_TAG, TEST_UID, callingUid));
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700452 ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie)));
453 StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid);
454 ASSERT_TRUE(isOk(counterSetResult));
455 ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value());
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700456 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey)));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800457 tagStatsMapKey.tag = 0;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700458 StatusOr<StatsValue> statsMapResult = mFakeStatsMapA.readValue(tagStatsMapKey);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700459 ASSERT_TRUE(isOk(statsMapResult));
460 ASSERT_EQ((uint64_t)1, statsMapResult.value().rxPackets);
461 ASSERT_EQ((uint64_t)100, statsMapResult.value().rxBytes);
Chenbo Fengbc4a15f2018-05-11 19:15:15 -0700462 auto appStatsResult = mFakeAppUidStatsMap.readValue(TEST_UID);
463 ASSERT_TRUE(isOk(appStatsResult));
464 ASSERT_EQ((uint64_t)1, appStatsResult.value().rxPackets);
465 ASSERT_EQ((uint64_t)100, appStatsResult.value().rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800466}
467
468TEST_F(TrafficControllerTest, TestDeleteAllUidData) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900469 SKIP_IF_BPF_NOT_SUPPORTED;
470
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800471 uid_t callingUid = TEST_UID2;
472 addPrivilegedUid(callingUid);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800473 uint64_t cookie = 1;
474 uid_t uid = TEST_UID;
475 uint32_t tag = TEST_TAG;
476 StatsKey tagStatsMapKey;
477 populateFakeStats(cookie, uid, tag, &tagStatsMapKey);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800478 ASSERT_EQ(0, mTc.deleteTagData(0, TEST_UID, callingUid));
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700479 ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie)));
480 ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid)));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700481 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey)));
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700482 tagStatsMapKey.tag = 0;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700483 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey)));
Chenbo Fengbc4a15f2018-05-11 19:15:15 -0700484 ASSERT_FALSE(isOk(mFakeAppUidStatsMap.readValue(TEST_UID)));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800485}
486
487TEST_F(TrafficControllerTest, TestDeleteDataWithTwoTags) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900488 SKIP_IF_BPF_NOT_SUPPORTED;
489
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800490 uid_t callingUid = TEST_UID2;
491 addPrivilegedUid(callingUid);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800492 uint64_t cookie1 = 1;
493 uint64_t cookie2 = 2;
494 uid_t uid = TEST_UID;
495 uint32_t tag1 = TEST_TAG;
496 uint32_t tag2 = TEST_TAG + 1;
497 StatsKey tagStatsMapKey1;
498 StatsKey tagStatsMapKey2;
499 populateFakeStats(cookie1, uid, tag1, &tagStatsMapKey1);
500 populateFakeStats(cookie2, uid, tag2, &tagStatsMapKey2);
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800501 ASSERT_EQ(0, mTc.deleteTagData(TEST_TAG, TEST_UID, callingUid));
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700502 ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie1)));
503 StatusOr<UidTag> cookieMapResult = mFakeCookieTagMap.readValue(cookie2);
504 ASSERT_TRUE(isOk(cookieMapResult));
505 ASSERT_EQ(TEST_UID, cookieMapResult.value().uid);
506 ASSERT_EQ(TEST_TAG + 1, cookieMapResult.value().tag);
507 StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid);
508 ASSERT_TRUE(isOk(counterSetResult));
509 ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value());
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700510 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey1)));
511 StatusOr<StatsValue> statsMapResult = mFakeStatsMapA.readValue(tagStatsMapKey2);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700512 ASSERT_TRUE(isOk(statsMapResult));
513 ASSERT_EQ((uint64_t)1, statsMapResult.value().rxPackets);
514 ASSERT_EQ((uint64_t)100, statsMapResult.value().rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800515}
516
517TEST_F(TrafficControllerTest, TestDeleteDataWithTwoUids) {
Lorenzo Colitti23e5c7f2018-01-12 17:55:59 +0900518 SKIP_IF_BPF_NOT_SUPPORTED;
519
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800520 uid_t callingUid = TEST_UID2;
521 addPrivilegedUid(callingUid);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800522 uint64_t cookie1 = 1;
523 uint64_t cookie2 = 2;
524 uid_t uid1 = TEST_UID;
525 uid_t uid2 = TEST_UID + 1;
526 uint32_t tag = TEST_TAG;
527 StatsKey tagStatsMapKey1;
528 StatsKey tagStatsMapKey2;
529 populateFakeStats(cookie1, uid1, tag, &tagStatsMapKey1);
530 populateFakeStats(cookie2, uid2, tag, &tagStatsMapKey2);
531
532 // Delete the stats of one of the uid. Check if it is properly collected by
533 // removedStats.
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800534 ASSERT_EQ(0, mTc.deleteTagData(0, uid2, callingUid));
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700535 ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie2)));
536 StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid1);
537 ASSERT_TRUE(isOk(counterSetResult));
538 ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value());
539 ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid2)));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700540 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey2)));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800541 tagStatsMapKey2.tag = 0;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700542 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey2)));
Chenbo Fengbc4a15f2018-05-11 19:15:15 -0700543 ASSERT_FALSE(isOk(mFakeAppUidStatsMap.readValue(uid2)));
Chenbo Feng63ad5592018-01-22 23:14:12 -0800544 tagStatsMapKey1.tag = 0;
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700545 StatusOr<StatsValue> statsMapResult = mFakeStatsMapA.readValue(tagStatsMapKey1);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700546 ASSERT_TRUE(isOk(statsMapResult));
547 ASSERT_EQ((uint64_t)1, statsMapResult.value().rxPackets);
548 ASSERT_EQ((uint64_t)100, statsMapResult.value().rxBytes);
Chenbo Fengbc4a15f2018-05-11 19:15:15 -0700549 auto appStatsResult = mFakeAppUidStatsMap.readValue(uid1);
550 ASSERT_TRUE(isOk(appStatsResult));
551 ASSERT_EQ((uint64_t)1, appStatsResult.value().rxPackets);
552 ASSERT_EQ((uint64_t)100, appStatsResult.value().rxBytes);
Chenbo Fenged37fea2017-12-13 19:35:01 -0800553
Chenbo Fengef1cab32018-04-13 19:50:49 -0700554 // Delete the stats of the other uid.
Chenbo Fengb4a4fa12019-01-09 17:20:45 -0800555 ASSERT_EQ(0, mTc.deleteTagData(0, uid1, callingUid));
Chenbo Fengdfc75ef2019-04-15 15:10:27 -0700556 ASSERT_FALSE(isOk(mFakeStatsMapA.readValue(tagStatsMapKey1)));
Chenbo Fengbc4a15f2018-05-11 19:15:15 -0700557 ASSERT_FALSE(isOk(mFakeAppUidStatsMap.readValue(uid1)));
Chenbo Fenged37fea2017-12-13 19:35:01 -0800558}
559
Chenbo Feng89c12f12018-03-21 10:29:18 -0700560TEST_F(TrafficControllerTest, TestUpdateOwnerMapEntry) {
561 SKIP_IF_BPF_NOT_SUPPORTED;
562
563 uint32_t uid = TEST_UID;
Chenbo Feng703798e2018-06-15 17:07:59 -0700564 ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(STANDBY_MATCH, uid, DENY, BLACKLIST)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000565 StatusOr<UidOwnerValue> value = mFakeUidOwnerMap.readValue(uid);
Chenbo Feng4f6c2372018-04-26 10:37:55 -0700566 ASSERT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000567 ASSERT_TRUE(value.value().rule & STANDBY_MATCH);
Chenbo Feng703798e2018-06-15 17:07:59 -0700568
569 ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(DOZABLE_MATCH, uid, ALLOW, WHITELIST)));
570 value = mFakeUidOwnerMap.readValue(uid);
571 ASSERT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000572 ASSERT_TRUE(value.value().rule & DOZABLE_MATCH);
Chenbo Feng703798e2018-06-15 17:07:59 -0700573
574 ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(DOZABLE_MATCH, uid, DENY, WHITELIST)));
575 value = mFakeUidOwnerMap.readValue(uid);
576 ASSERT_TRUE(isOk(value));
Rubin Xuec27ff22019-01-08 21:33:03 +0000577 ASSERT_FALSE(value.value().rule & DOZABLE_MATCH);
Chenbo Feng703798e2018-06-15 17:07:59 -0700578
579 ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(STANDBY_MATCH, uid, ALLOW, BLACKLIST)));
580 ASSERT_FALSE(isOk(mFakeUidOwnerMap.readValue(uid)));
Chenbo Feng89c12f12018-03-21 10:29:18 -0700581
582 uid = TEST_UID2;
Chenbo Feng703798e2018-06-15 17:07:59 -0700583 ASSERT_FALSE(isOk(mTc.updateOwnerMapEntry(STANDBY_MATCH, uid, ALLOW, BLACKLIST)));
584 ASSERT_FALSE(isOk(mFakeUidOwnerMap.readValue(uid)));
Chenbo Feng89c12f12018-03-21 10:29:18 -0700585}
586
587TEST_F(TrafficControllerTest, TestChangeUidOwnerRule) {
588 SKIP_IF_BPF_NOT_SUPPORTED;
589
Chenbo Feng703798e2018-06-15 17:07:59 -0700590 checkUidOwnerRuleForChain(DOZABLE, DOZABLE_MATCH);
591 checkUidOwnerRuleForChain(STANDBY, STANDBY_MATCH);
592 checkUidOwnerRuleForChain(POWERSAVE, POWERSAVE_MATCH);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700593 ASSERT_EQ(-EINVAL, mTc.changeUidOwnerRule(NONE, TEST_UID, ALLOW, WHITELIST));
594 ASSERT_EQ(-EINVAL, mTc.changeUidOwnerRule(INVALID_CHAIN, TEST_UID, ALLOW, WHITELIST));
595}
596
597TEST_F(TrafficControllerTest, TestReplaceUidOwnerMap) {
598 SKIP_IF_BPF_NOT_SUPPORTED;
599
600 std::vector<int32_t> uids = {TEST_UID, TEST_UID2, TEST_UID3};
Chenbo Feng703798e2018-06-15 17:07:59 -0700601 checkUidMapReplace("fw_dozable", uids, DOZABLE_MATCH);
602 checkUidMapReplace("fw_standby", uids, STANDBY_MATCH);
603 checkUidMapReplace("fw_powersave", uids, POWERSAVE_MATCH);
Chenbo Feng89c12f12018-03-21 10:29:18 -0700604 ASSERT_EQ(-EINVAL, mTc.replaceUidOwnerMap("unknow", true, uids));
605}
606
Chenbo Feng703798e2018-06-15 17:07:59 -0700607TEST_F(TrafficControllerTest, TestReplaceSameChain) {
608 SKIP_IF_BPF_NOT_SUPPORTED;
609
610 std::vector<int32_t> uids = {TEST_UID, TEST_UID2, TEST_UID3};
611 checkUidMapReplace("fw_dozable", uids, DOZABLE_MATCH);
612 std::vector<int32_t> newUids = {TEST_UID2, TEST_UID3};
613 checkUidMapReplace("fw_dozable", newUids, DOZABLE_MATCH);
614}
615
Chenbo Feng95892f32018-06-07 14:52:02 -0700616TEST_F(TrafficControllerTest, TestBlacklistUidMatch) {
617 SKIP_IF_BPF_NOT_SUPPORTED;
618
619 std::vector<std::string> appStrUids = {"1000", "1001", "10012"};
Chenbo Feng703798e2018-06-15 17:07:59 -0700620 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReject,
621 BandwidthController::IptOpInsert)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000622 expectUidOwnerMapValues(appStrUids, PENALTY_BOX_MATCH, 0);
Chenbo Feng703798e2018-06-15 17:07:59 -0700623 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReject,
624 BandwidthController::IptOpDelete)));
625 expectMapEmpty(mFakeUidOwnerMap);
Chenbo Feng95892f32018-06-07 14:52:02 -0700626}
627
628TEST_F(TrafficControllerTest, TestWhitelistUidMatch) {
629 SKIP_IF_BPF_NOT_SUPPORTED;
630
631 std::vector<std::string> appStrUids = {"1000", "1001", "10012"};
Chenbo Feng703798e2018-06-15 17:07:59 -0700632 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReturn,
633 BandwidthController::IptOpInsert)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000634 expectUidOwnerMapValues(appStrUids, HAPPY_BOX_MATCH, 0);
Chenbo Feng703798e2018-06-15 17:07:59 -0700635 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReturn,
636 BandwidthController::IptOpDelete)));
637 expectMapEmpty(mFakeUidOwnerMap);
Chenbo Feng95892f32018-06-07 14:52:02 -0700638}
639
640TEST_F(TrafficControllerTest, TestReplaceMatchUid) {
Bernie Innocenti093d6622018-07-09 20:52:48 +0900641 SKIP_IF_BPF_NOT_SUPPORTED;
642
Chenbo Feng95892f32018-06-07 14:52:02 -0700643 std::vector<std::string> appStrUids = {"1000", "1001", "10012"};
Chenbo Feng703798e2018-06-15 17:07:59 -0700644 // Add appStrUids to the blacklist and expect that their values are all PENALTY_BOX_MATCH.
645 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReject,
646 BandwidthController::IptOpInsert)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000647 expectUidOwnerMapValues(appStrUids, PENALTY_BOX_MATCH, 0);
Chenbo Feng95892f32018-06-07 14:52:02 -0700648
Chenbo Feng703798e2018-06-15 17:07:59 -0700649 // Add the same UIDs to the whitelist and expect that we get PENALTY_BOX_MATCH |
650 // HAPPY_BOX_MATCH.
651 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReturn,
652 BandwidthController::IptOpInsert)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000653 expectUidOwnerMapValues(appStrUids, HAPPY_BOX_MATCH | PENALTY_BOX_MATCH, 0);
Chenbo Feng95892f32018-06-07 14:52:02 -0700654
Chenbo Feng703798e2018-06-15 17:07:59 -0700655 // Remove the same UIDs from the whitelist and check the PENALTY_BOX_MATCH is still there.
656 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReturn,
657 BandwidthController::IptOpDelete)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000658 expectUidOwnerMapValues(appStrUids, PENALTY_BOX_MATCH, 0);
Chenbo Feng95892f32018-06-07 14:52:02 -0700659
660 // Remove the same UIDs from the blacklist and check the map is empty.
Chenbo Feng703798e2018-06-15 17:07:59 -0700661 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReject,
662 BandwidthController::IptOpDelete)));
663 ASSERT_FALSE(isOk(mFakeUidOwnerMap.getFirstKey()));
Chenbo Feng95892f32018-06-07 14:52:02 -0700664}
665
666TEST_F(TrafficControllerTest, TestDeleteWrongMatchSilentlyFails) {
Bernie Innocenti093d6622018-07-09 20:52:48 +0900667 SKIP_IF_BPF_NOT_SUPPORTED;
668
Chenbo Feng95892f32018-06-07 14:52:02 -0700669 std::vector<std::string> appStrUids = {"1000", "1001", "10012"};
670 // If the uid does not exist in the map, trying to delete a rule about it will fail.
Chenbo Feng703798e2018-06-15 17:07:59 -0700671 ASSERT_FALSE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReturn,
672 BandwidthController::IptOpDelete)));
673 expectMapEmpty(mFakeUidOwnerMap);
Chenbo Feng95892f32018-06-07 14:52:02 -0700674
675 // Add blacklist rules for appStrUids.
Chenbo Feng703798e2018-06-15 17:07:59 -0700676 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReturn,
677 BandwidthController::IptOpInsert)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000678 expectUidOwnerMapValues(appStrUids, HAPPY_BOX_MATCH, 0);
Chenbo Feng95892f32018-06-07 14:52:02 -0700679
680 // Delete (non-existent) blacklist rules for appStrUids, and check that this silently does
681 // nothing if the uid is in the map but does not have blacklist match. This is required because
682 // NetworkManagementService will try to remove a uid from blacklist after adding it to the
683 // whitelist and if the remove fails it will not update the uid status.
Chenbo Feng703798e2018-06-15 17:07:59 -0700684 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap(appStrUids, BandwidthController::IptJumpReject,
685 BandwidthController::IptOpDelete)));
Rubin Xuec27ff22019-01-08 21:33:03 +0000686 expectUidOwnerMapValues(appStrUids, HAPPY_BOX_MATCH, 0);
687}
688
689TEST_F(TrafficControllerTest, TestAddUidInterfaceFilteringRules) {
690 SKIP_IF_BPF_NOT_SUPPORTED;
691
692 int iif0 = 15;
693 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif0, {1000, 1001})));
694 expectUidOwnerMapValues({"1000", "1001"}, IIF_MATCH, iif0);
695
696 // Add some non-overlapping new uids. They should coexist with existing rules
697 int iif1 = 16;
698 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif1, {2000, 2001})));
699 expectUidOwnerMapValues({"1000", "1001"}, IIF_MATCH, iif0);
700 expectUidOwnerMapValues({"2000", "2001"}, IIF_MATCH, iif1);
701
702 // Overwrite some existing uids
703 int iif2 = 17;
704 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif2, {1000, 2000})));
705 expectUidOwnerMapValues({"1001"}, IIF_MATCH, iif0);
706 expectUidOwnerMapValues({"2001"}, IIF_MATCH, iif1);
707 expectUidOwnerMapValues({"1000", "2000"}, IIF_MATCH, iif2);
708}
709
710TEST_F(TrafficControllerTest, TestRemoveUidInterfaceFilteringRules) {
711 SKIP_IF_BPF_NOT_SUPPORTED;
712
713 int iif0 = 15;
714 int iif1 = 16;
715 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif0, {1000, 1001})));
716 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif1, {2000, 2001})));
717 expectUidOwnerMapValues({"1000", "1001"}, IIF_MATCH, iif0);
718 expectUidOwnerMapValues({"2000", "2001"}, IIF_MATCH, iif1);
719
720 // Rmove some uids
721 ASSERT_TRUE(isOk(mTc.removeUidInterfaceRules({1001, 2001})));
722 expectUidOwnerMapValues({"1000"}, IIF_MATCH, iif0);
723 expectUidOwnerMapValues({"2000"}, IIF_MATCH, iif1);
724 checkEachUidValue({1000, 2000}, IIF_MATCH); // Make sure there are only two uids remaining
725
726 // Remove non-existent uids shouldn't fail
727 ASSERT_TRUE(isOk(mTc.removeUidInterfaceRules({2000, 3000})));
728 expectUidOwnerMapValues({"1000"}, IIF_MATCH, iif0);
729 checkEachUidValue({1000}, IIF_MATCH); // Make sure there are only one uid remaining
730
731 // Remove everything
732 ASSERT_TRUE(isOk(mTc.removeUidInterfaceRules({1000})));
733 expectMapEmpty(mFakeUidOwnerMap);
734}
735
736TEST_F(TrafficControllerTest, TestUidInterfaceFilteringRulesCoexistWithExistingMatches) {
737 SKIP_IF_BPF_NOT_SUPPORTED;
738
739 // Set up existing PENALTY_BOX_MATCH rules
740 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap({"1000", "1001", "10012"},
741 BandwidthController::IptJumpReject,
742 BandwidthController::IptOpInsert)));
743 expectUidOwnerMapValues({"1000", "1001", "10012"}, PENALTY_BOX_MATCH, 0);
744
745 // Add some partially-overlapping uid owner rules and check result
746 int iif1 = 32;
747 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif1, {10012, 10013, 10014})));
748 expectUidOwnerMapValues({"1000", "1001"}, PENALTY_BOX_MATCH, 0);
749 expectUidOwnerMapValues({"10012"}, PENALTY_BOX_MATCH | IIF_MATCH, iif1);
750 expectUidOwnerMapValues({"10013", "10014"}, IIF_MATCH, iif1);
751
752 // Removing some PENALTY_BOX_MATCH rules should not change uid interface rule
753 ASSERT_TRUE(isOk(mTc.updateUidOwnerMap({"1001", "10012"}, BandwidthController::IptJumpReject,
754 BandwidthController::IptOpDelete)));
755 expectUidOwnerMapValues({"1000"}, PENALTY_BOX_MATCH, 0);
756 expectUidOwnerMapValues({"10012", "10013", "10014"}, IIF_MATCH, iif1);
757
758 // Remove all uid interface rules
759 ASSERT_TRUE(isOk(mTc.removeUidInterfaceRules({10012, 10013, 10014})));
760 expectUidOwnerMapValues({"1000"}, PENALTY_BOX_MATCH, 0);
761 // Make sure these are the only uids left
762 checkEachUidValue({1000}, PENALTY_BOX_MATCH);
763}
764
765TEST_F(TrafficControllerTest, TestUidInterfaceFilteringRulesCoexistWithNewMatches) {
766 SKIP_IF_BPF_NOT_SUPPORTED;
767
768 int iif1 = 56;
769 // Set up existing uid interface rules
770 ASSERT_TRUE(isOk(mTc.addUidInterfaceRules(iif1, {10001, 10002})));
771 expectUidOwnerMapValues({"10001", "10002"}, IIF_MATCH, iif1);
772
773 // Add some partially-overlapping doze rules
774 EXPECT_EQ(0, mTc.replaceUidOwnerMap("fw_dozable", true, {10002, 10003}));
775 expectUidOwnerMapValues({"10001"}, IIF_MATCH, iif1);
776 expectUidOwnerMapValues({"10002"}, DOZABLE_MATCH | IIF_MATCH, iif1);
777 expectUidOwnerMapValues({"10003"}, DOZABLE_MATCH, 0);
778
779 // Introduce a third rule type (powersave) on various existing UIDs
780 EXPECT_EQ(0, mTc.replaceUidOwnerMap("fw_powersave", true, {10000, 10001, 10002, 10003}));
781 expectUidOwnerMapValues({"10000"}, POWERSAVE_MATCH, 0);
782 expectUidOwnerMapValues({"10001"}, POWERSAVE_MATCH | IIF_MATCH, iif1);
783 expectUidOwnerMapValues({"10002"}, POWERSAVE_MATCH | DOZABLE_MATCH | IIF_MATCH, iif1);
784 expectUidOwnerMapValues({"10003"}, POWERSAVE_MATCH | DOZABLE_MATCH, 0);
785
786 // Remove all doze rules
787 EXPECT_EQ(0, mTc.replaceUidOwnerMap("fw_dozable", true, {}));
788 expectUidOwnerMapValues({"10000"}, POWERSAVE_MATCH, 0);
789 expectUidOwnerMapValues({"10001"}, POWERSAVE_MATCH | IIF_MATCH, iif1);
790 expectUidOwnerMapValues({"10002"}, POWERSAVE_MATCH | IIF_MATCH, iif1);
791 expectUidOwnerMapValues({"10003"}, POWERSAVE_MATCH, 0);
792
793 // Remove all powersave rules, expect ownerMap to only have uid interface rules left
794 EXPECT_EQ(0, mTc.replaceUidOwnerMap("fw_powersave", true, {}));
795 expectUidOwnerMapValues({"10001", "10002"}, IIF_MATCH, iif1);
796 // Make sure these are the only uids left
797 checkEachUidValue({10001, 10002}, IIF_MATCH);
Chenbo Feng95892f32018-06-07 14:52:02 -0700798}
Chenbo Feng48eaed32018-12-26 17:40:21 -0800799
800TEST_F(TrafficControllerTest, TestGrantInternetPermission) {
801 SKIP_IF_BPF_NOT_SUPPORTED;
802
803 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
804
805 mTc.setPermissionForUids(INetd::PERMISSION_INTERNET, appUids);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800806 expectMapEmpty(mFakeUidPermissionMap);
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800807 expectPrivilegedUserSetEmpty();
Chenbo Feng48eaed32018-12-26 17:40:21 -0800808}
809
810TEST_F(TrafficControllerTest, TestRevokeInternetPermission) {
811 SKIP_IF_BPF_NOT_SUPPORTED;
812
813 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
814
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800815 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, appUids);
816 expectUidPermissionMapValues(appUids, INetd::NO_PERMISSIONS);
817}
818
819TEST_F(TrafficControllerTest, TestPermissionUninstalled) {
820 SKIP_IF_BPF_NOT_SUPPORTED;
821
822 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
823
824 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, appUids);
825 expectUidPermissionMapValues(appUids, INetd::PERMISSION_UPDATE_DEVICE_STATS);
826 expectPrivilegedUserSet(appUids);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800827
828 std::vector<uid_t> uidToRemove = {TEST_UID};
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800829 mTc.setPermissionForUids(INetd::PERMISSION_UNINSTALLED, uidToRemove);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800830
831 std::vector<uid_t> uidRemain = {TEST_UID3, TEST_UID2};
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800832 expectUidPermissionMapValues(uidRemain, INetd::PERMISSION_UPDATE_DEVICE_STATS);
833 expectPrivilegedUserSet(uidRemain);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800834
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800835 mTc.setPermissionForUids(INetd::PERMISSION_UNINSTALLED, uidRemain);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800836 expectMapEmpty(mFakeUidPermissionMap);
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800837 expectPrivilegedUserSetEmpty();
Chenbo Feng48eaed32018-12-26 17:40:21 -0800838}
839
840TEST_F(TrafficControllerTest, TestGrantUpdateStatsPermission) {
841 SKIP_IF_BPF_NOT_SUPPORTED;
842
843 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
844
845 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, appUids);
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800846 expectUidPermissionMapValues(appUids, INetd::PERMISSION_UPDATE_DEVICE_STATS);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800847 expectPrivilegedUserSet(appUids);
848
849 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, appUids);
850 expectPrivilegedUserSetEmpty();
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800851 expectUidPermissionMapValues(appUids, INetd::NO_PERMISSIONS);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800852}
853
854TEST_F(TrafficControllerTest, TestRevokeUpdateStatsPermission) {
855 SKIP_IF_BPF_NOT_SUPPORTED;
856
857 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
858
859 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, appUids);
860 expectPrivilegedUserSet(appUids);
861
862 std::vector<uid_t> uidToRemove = {TEST_UID};
863 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, uidToRemove);
864
865 std::vector<uid_t> uidRemain = {TEST_UID3, TEST_UID2};
866 expectPrivilegedUserSet(uidRemain);
867
868 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, uidRemain);
869 expectPrivilegedUserSetEmpty();
870}
871
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800872TEST_F(TrafficControllerTest, TestGrantWrongPermission) {
Chenbo Feng48eaed32018-12-26 17:40:21 -0800873 SKIP_IF_BPF_NOT_SUPPORTED;
874
875 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
876
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800877 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, appUids);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800878 expectPrivilegedUserSetEmpty();
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800879 expectUidPermissionMapValues(appUids, INetd::NO_PERMISSIONS);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800880}
881
882TEST_F(TrafficControllerTest, TestGrantDuplicatePermissionSlientlyFail) {
883 SKIP_IF_BPF_NOT_SUPPORTED;
884
885 std::vector<uid_t> appUids = {TEST_UID, TEST_UID2, TEST_UID3};
886
887 mTc.setPermissionForUids(INetd::PERMISSION_INTERNET, appUids);
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800888 expectMapEmpty(mFakeUidPermissionMap);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800889
890 std::vector<uid_t> uidToAdd = {TEST_UID};
891 mTc.setPermissionForUids(INetd::PERMISSION_INTERNET, uidToAdd);
892
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800893 expectPrivilegedUserSetEmpty();
Chenbo Feng48eaed32018-12-26 17:40:21 -0800894
895 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, appUids);
Chenbo Fengbf660aa2019-02-26 16:12:27 -0800896 expectUidPermissionMapValues(appUids, INetd::NO_PERMISSIONS);
Chenbo Feng48eaed32018-12-26 17:40:21 -0800897
898 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, appUids);
899 expectPrivilegedUserSet(appUids);
900
901 mTc.setPermissionForUids(INetd::PERMISSION_UPDATE_DEVICE_STATS, uidToAdd);
902 expectPrivilegedUserSet(appUids);
903
904 mTc.setPermissionForUids(INetd::NO_PERMISSIONS, appUids);
905 expectPrivilegedUserSetEmpty();
906}
907
Chenbo Fenged37fea2017-12-13 19:35:01 -0800908} // namespace net
909} // namespace android