Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 1 | /* |
| 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 Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 36 | #include "FirewallController.h" |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 37 | #include "TrafficController.h" |
| 38 | #include "bpf/BpfUtils.h" |
| 39 | |
| 40 | using namespace android::bpf; |
| 41 | |
| 42 | using ::testing::_; |
| 43 | using ::testing::ByMove; |
| 44 | using ::testing::Invoke; |
| 45 | using ::testing::Return; |
| 46 | using ::testing::StrictMock; |
| 47 | using ::testing::Test; |
| 48 | |
| 49 | namespace android { |
| 50 | namespace net { |
| 51 | |
| 52 | using base::unique_fd; |
| 53 | using netdutils::status::ok; |
| 54 | |
| 55 | constexpr int TEST_MAP_SIZE = 10; |
| 56 | constexpr uid_t TEST_UID = 10086; |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 57 | constexpr uid_t TEST_UID2 = 54321; |
| 58 | constexpr uid_t TEST_UID3 = 98765; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 59 | constexpr uint32_t TEST_TAG = 42; |
| 60 | constexpr int TEST_COUNTERSET = 1; |
| 61 | constexpr int DEFAULT_COUNTERSET = 0; |
| 62 | |
Chenbo Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 63 | #define SKIP_IF_BPF_NOT_SUPPORTED \ |
| 64 | do { \ |
| 65 | if (!hasBpfSupport()) return; \ |
| 66 | } while (0); |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 67 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 68 | class 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 Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 76 | unique_fd mFakeDozableUidMap; |
| 77 | unique_fd mFakeStandbyUidMap; |
| 78 | unique_fd mFakePowerSaveUidMap; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 79 | |
| 80 | void SetUp() { |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 81 | std::lock_guard<std::mutex> guard(mTc.mOwnerMatchMutex); |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 82 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 83 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 84 | 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 Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 93 | sizeof(struct StatsValue), TEST_MAP_SIZE, 0)); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 94 | ASSERT_LE(0, mFakeUidStatsMap); |
| 95 | |
| 96 | mFakeTagStatsMap = unique_fd(createMap(BPF_MAP_TYPE_HASH, sizeof(struct StatsKey), |
Chenbo Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 97 | sizeof(struct StatsValue), TEST_MAP_SIZE, 0)); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 98 | ASSERT_LE(0, mFakeTagStatsMap); |
| 99 | |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 100 | 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 Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 111 | // 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 Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 118 | mTc.mDozableUidMap.reset(mFakeDozableUidMap); |
| 119 | mTc.mStandbyUidMap.reset(mFakeStandbyUidMap); |
| 120 | mTc.mPowerSaveUidMap.reset(mFakePowerSaveUidMap); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 121 | } |
| 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 Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 154 | StatsValue statsMapValue = {.rxPackets = 1, .rxBytes = 100}; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 155 | 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 Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 160 | // put tag information back to statsKey |
| 161 | key->tag = tag; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 162 | } |
| 163 | |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 164 | 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 Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 220 | void TearDown() { |
| 221 | mFakeCookieTagMap.reset(); |
| 222 | mFakeUidCounterSetMap.reset(); |
| 223 | mFakeUidStatsMap.reset(); |
| 224 | mFakeTagStatsMap.reset(); |
| 225 | } |
| 226 | }; |
| 227 | |
| 228 | TEST_F(TrafficControllerTest, TestTagSocketV4) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 229 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 230 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 231 | 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 | |
| 239 | TEST_F(TrafficControllerTest, TestReTagSocket) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 240 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 241 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 242 | 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 | |
| 249 | TEST_F(TrafficControllerTest, TestTagTwoSockets) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 250 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 251 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 252 | 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 | |
| 265 | TEST_F(TrafficControllerTest, TestTagSocketV6) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 266 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 267 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 268 | 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 | |
| 276 | TEST_F(TrafficControllerTest, TestTagInvalidSocket) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 277 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 278 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 279 | int invalidSocket = -1; |
| 280 | ASSERT_GT(0, mTc.tagSocket(invalidSocket, TEST_TAG, TEST_UID)); |
| 281 | expectTagMapEmpty(); |
| 282 | } |
| 283 | |
| 284 | TEST_F(TrafficControllerTest, TestUntagInvalidSocket) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 285 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 286 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 287 | 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 | |
| 294 | TEST_F(TrafficControllerTest, TestSetCounterSet) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 295 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 296 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 297 | 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 | |
| 308 | TEST_F(TrafficControllerTest, TestSetInvalidCounterSet) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 309 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 310 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 311 | 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 | |
| 319 | TEST_F(TrafficControllerTest, TestDeleteTagData) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 320 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 321 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 322 | 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 Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 333 | StatsValue statsMapResult; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 334 | ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey, &statsMapResult)); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 335 | tagStatsMapKey.tag = 0; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 336 | ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey, &statsMapResult)); |
Chenbo Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 337 | ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets); |
| 338 | ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 339 | } |
| 340 | |
| 341 | TEST_F(TrafficControllerTest, TestDeleteAllUidData) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 342 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 343 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 344 | 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 Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 354 | StatsValue statsMapResult; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 355 | 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 Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 360 | ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets); |
| 361 | ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 362 | } |
| 363 | |
| 364 | TEST_F(TrafficControllerTest, TestDeleteDataWithTwoTags) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 365 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 366 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 367 | 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 Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 385 | StatsValue statsMapResult; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 386 | ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey1, &statsMapResult)); |
| 387 | ASSERT_EQ(0, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey2, &statsMapResult)); |
Chenbo Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 388 | ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets); |
| 389 | ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 390 | } |
| 391 | |
| 392 | TEST_F(TrafficControllerTest, TestDeleteDataWithTwoUids) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 393 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 394 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 395 | 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 Feng | f43bf81 | 2017-12-15 18:27:22 -0800 | [diff] [blame] | 414 | StatsValue statsMapResult; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 415 | ASSERT_EQ(-1, findMapEntry(mFakeTagStatsMap, &tagStatsMapKey2, &statsMapResult)); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 416 | tagStatsMapKey2.tag = 0; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 417 | ASSERT_EQ(-1, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey2, &statsMapResult)); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 418 | tagStatsMapKey1.tag = 0; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 419 | ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &tagStatsMapKey1, &statsMapResult)); |
Chenbo Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 420 | ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets); |
| 421 | ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 422 | StatsKey removedStatsKey= {.uid = 0, .tag = 0, .counterSet = COUNTERSETS_LIMIT, |
| 423 | .ifaceIndex = 0}; |
| 424 | ASSERT_EQ(0, findMapEntry(mFakeUidStatsMap, &removedStatsKey, &statsMapResult)); |
Chenbo Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 425 | ASSERT_EQ((uint64_t)1, statsMapResult.rxPackets); |
| 426 | ASSERT_EQ((uint64_t)100, statsMapResult.rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 427 | |
| 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 Feng | eac6c47 | 2018-02-05 15:06:23 -0800 | [diff] [blame] | 433 | ASSERT_EQ((uint64_t)2, statsMapResult.rxPackets); |
| 434 | ASSERT_EQ((uint64_t)200, statsMapResult.rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 435 | } |
| 436 | |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame^] | 437 | TEST_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 | |
| 466 | TEST_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 | |
| 476 | TEST_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 Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 486 | } // namespace net |
| 487 | } // namespace android |