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 | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 36 | #include "netdutils/Status.h" |
| 37 | #include "netdutils/StatusOr.h" |
| 38 | |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 39 | #include "FirewallController.h" |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 40 | #include "TrafficController.h" |
| 41 | #include "bpf/BpfUtils.h" |
| 42 | |
| 43 | using namespace android::bpf; |
| 44 | |
| 45 | using ::testing::_; |
| 46 | using ::testing::ByMove; |
| 47 | using ::testing::Invoke; |
| 48 | using ::testing::Return; |
| 49 | using ::testing::StrictMock; |
| 50 | using ::testing::Test; |
| 51 | |
| 52 | namespace android { |
| 53 | namespace net { |
| 54 | |
| 55 | using base::unique_fd; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 56 | using netdutils::isOk; |
| 57 | using netdutils::Status; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 58 | using netdutils::status::ok; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 59 | using netdutils::StatusOr; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 60 | |
| 61 | constexpr int TEST_MAP_SIZE = 10; |
| 62 | constexpr uid_t TEST_UID = 10086; |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 63 | constexpr uid_t TEST_UID2 = 54321; |
| 64 | constexpr uid_t TEST_UID3 = 98765; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 65 | constexpr uint32_t TEST_TAG = 42; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 66 | constexpr uint32_t TEST_COUNTERSET = 1; |
| 67 | constexpr uint32_t DEFAULT_COUNTERSET = 0; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 68 | |
| 69 | class TrafficControllerTest : public ::testing::Test { |
| 70 | protected: |
| 71 | TrafficControllerTest() {} |
| 72 | TrafficController mTc; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 73 | BpfMap<uint64_t, UidTag> mFakeCookieTagMap; |
| 74 | BpfMap<uint32_t, uint8_t> mFakeUidCounterSetMap; |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 75 | BpfMap<uint32_t, StatsValue> mFakeAppUidStatsMap; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 76 | BpfMap<StatsKey, StatsValue> mFakeUidStatsMap; |
| 77 | BpfMap<StatsKey, StatsValue> mFakeTagStatsMap; |
| 78 | BpfMap<uint32_t, uint8_t> mFakeDozableUidMap; |
| 79 | BpfMap<uint32_t, uint8_t> mFakeStandbyUidMap; |
| 80 | BpfMap<uint32_t, uint8_t> mFakePowerSaveUidMap; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 81 | |
| 82 | void SetUp() { |
Chenbo Feng | ef1cab3 | 2018-04-13 19:50:49 -0700 | [diff] [blame] | 83 | std::lock_guard<std::mutex> ownerGuard(mTc.mOwnerMatchMutex); |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 84 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 85 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 86 | mFakeCookieTagMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(uint64_t), |
| 87 | sizeof(struct UidTag), TEST_MAP_SIZE, 0)); |
| 88 | ASSERT_LE(0, mFakeCookieTagMap.getMap()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 89 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 90 | mFakeUidCounterSetMap.reset( |
| 91 | createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), TEST_MAP_SIZE, 0)); |
| 92 | ASSERT_LE(0, mFakeUidCounterSetMap.getMap()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 93 | |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 94 | mFakeAppUidStatsMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), |
| 95 | sizeof(struct StatsValue), TEST_MAP_SIZE, 0)); |
| 96 | ASSERT_LE(0, mFakeAppUidStatsMap.getMap()); |
| 97 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 98 | mFakeUidStatsMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(struct StatsKey), |
| 99 | sizeof(struct StatsValue), TEST_MAP_SIZE, 0)); |
| 100 | ASSERT_LE(0, mFakeUidStatsMap.getMap()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 101 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 102 | mFakeTagStatsMap.reset(createMap(BPF_MAP_TYPE_HASH, sizeof(struct StatsKey), |
| 103 | sizeof(struct StatsValue), TEST_MAP_SIZE, 0)); |
| 104 | ASSERT_LE(0, mFakeTagStatsMap.getMap()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 105 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 106 | mFakeDozableUidMap.reset( |
| 107 | createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), TEST_MAP_SIZE, 0)); |
| 108 | ASSERT_LE(0, mFakeDozableUidMap.getMap()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 109 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 110 | mFakeStandbyUidMap.reset( |
| 111 | createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), TEST_MAP_SIZE, 0)); |
| 112 | ASSERT_LE(0, mFakeStandbyUidMap.getMap()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 113 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 114 | mFakePowerSaveUidMap.reset( |
| 115 | createMap(BPF_MAP_TYPE_HASH, sizeof(uint32_t), sizeof(uint8_t), TEST_MAP_SIZE, 0)); |
| 116 | ASSERT_LE(0, mFakePowerSaveUidMap.getMap()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 117 | // Make sure trafficController use the eBPF code path. |
| 118 | mTc.ebpfSupported = true; |
| 119 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 120 | mTc.mCookieTagMap.reset(mFakeCookieTagMap.getMap()); |
| 121 | mTc.mUidCounterSetMap.reset(mFakeUidCounterSetMap.getMap()); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 122 | mTc.mAppUidStatsMap.reset(mFakeAppUidStatsMap.getMap()); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 123 | mTc.mUidStatsMap.reset(mFakeUidStatsMap.getMap()); |
| 124 | mTc.mTagStatsMap.reset(mFakeTagStatsMap.getMap()); |
| 125 | mTc.mDozableUidMap.reset(mFakeDozableUidMap.getMap()); |
| 126 | mTc.mStandbyUidMap.reset(mFakeStandbyUidMap.getMap()); |
| 127 | mTc.mPowerSaveUidMap.reset(mFakePowerSaveUidMap.getMap()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 128 | } |
| 129 | |
| 130 | int setUpSocketAndTag(int protocol, uint64_t* cookie, uint32_t tag, uid_t uid) { |
| 131 | int sock = socket(protocol, SOCK_STREAM, 0); |
| 132 | EXPECT_LE(0, sock); |
| 133 | *cookie = getSocketCookie(sock); |
Chenbo Feng | ef1cab3 | 2018-04-13 19:50:49 -0700 | [diff] [blame] | 134 | EXPECT_NE(NONEXISTENT_COOKIE, *cookie); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 135 | EXPECT_EQ(0, mTc.tagSocket(sock, tag, uid)); |
| 136 | return sock; |
| 137 | } |
| 138 | |
| 139 | void expectUidTag(uint64_t cookie, uid_t uid, uint32_t tag) { |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 140 | 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 Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 144 | } |
| 145 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 146 | void expectNoTag(uint64_t cookie) { EXPECT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie))); } |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 147 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 148 | void expectTagMapEmpty() { EXPECT_FALSE(isOk(mFakeCookieTagMap.getFirstKey())); } |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 149 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 150 | void populateFakeStats(uint64_t cookie, uint32_t uid, uint32_t tag, StatsKey* key) { |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 151 | UidTag cookieMapkey = {.uid = (uint32_t)uid, .tag = tag}; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 152 | EXPECT_TRUE(isOk(mFakeCookieTagMap.writeValue(cookie, cookieMapkey, BPF_ANY))); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 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 | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 155 | uint8_t counterSet = TEST_COUNTERSET; |
| 156 | EXPECT_TRUE(isOk(mFakeUidCounterSetMap.writeValue(uid, counterSet, BPF_ANY))); |
| 157 | EXPECT_TRUE(isOk(mFakeTagStatsMap.writeValue(*key, statsMapValue, BPF_ANY))); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 158 | key->tag = 0; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 159 | EXPECT_TRUE(isOk(mFakeUidStatsMap.writeValue(*key, statsMapValue, BPF_ANY))); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 160 | EXPECT_TRUE(isOk(mFakeAppUidStatsMap.writeValue(uid, statsMapValue, BPF_ANY))); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 161 | // put tag information back to statsKey |
| 162 | key->tag = tag; |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 163 | } |
| 164 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 165 | void checkUidOwnerRuleForChain(ChildChain chain, BpfMap<uint32_t, uint8_t>& targetMap) { |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 166 | uint32_t uid = TEST_UID; |
| 167 | EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, DENY, BLACKLIST)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 168 | StatusOr<uint8_t> value = targetMap.readValue(uid); |
| 169 | EXPECT_TRUE(isOk(value)); |
| 170 | EXPECT_EQ(BPF_DROP, value.value()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 171 | |
| 172 | uid = TEST_UID2; |
| 173 | EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, ALLOW, WHITELIST)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 174 | value = targetMap.readValue(uid); |
| 175 | EXPECT_TRUE(isOk(value)); |
| 176 | EXPECT_EQ(BPF_PASS, value.value()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 177 | |
| 178 | EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, DENY, WHITELIST)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 179 | value = targetMap.readValue(uid); |
| 180 | EXPECT_FALSE(isOk(value)); |
| 181 | EXPECT_EQ(ENOENT, value.status().code()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 182 | |
| 183 | uid = TEST_UID; |
| 184 | EXPECT_EQ(0, mTc.changeUidOwnerRule(chain, uid, ALLOW, BLACKLIST)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 185 | value = targetMap.readValue(uid); |
| 186 | EXPECT_FALSE(isOk(value)); |
| 187 | EXPECT_EQ(ENOENT, value.status().code()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 188 | |
| 189 | uid = TEST_UID3; |
| 190 | EXPECT_EQ(-ENOENT, mTc.changeUidOwnerRule(chain, uid, ALLOW, BLACKLIST)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 191 | value = targetMap.readValue(uid); |
| 192 | EXPECT_FALSE(isOk(value)); |
| 193 | EXPECT_EQ(ENOENT, value.status().code()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 194 | } |
| 195 | |
| 196 | void checkEachUidValue(const std::vector<int32_t>& uids, const uint8_t expectValue, |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 197 | BpfMap<uint32_t, uint8_t>& targetMap) { |
| 198 | for (uint32_t uid : uids) { |
| 199 | StatusOr<uint8_t> value = targetMap.readValue(uid); |
| 200 | EXPECT_TRUE(isOk(value)); |
| 201 | EXPECT_EQ(expectValue, value.value()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 202 | } |
| 203 | std::set<uint32_t> uidSet(uids.begin(), uids.end()); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 204 | const auto checkNoOtherUid = [&uidSet](const int32_t& key, |
| 205 | const BpfMap<uint32_t, uint8_t>&) { |
| 206 | EXPECT_NE(uidSet.end(), uidSet.find(key)); |
| 207 | return netdutils::status::ok; |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 208 | }; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 209 | EXPECT_TRUE(isOk(targetMap.iterate(checkNoOtherUid))); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 210 | } |
| 211 | |
| 212 | void checkUidMapReplace(const std::string& name, const std::vector<int32_t>& uids, |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 213 | BpfMap<uint32_t, uint8_t>& targetMap) { |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 214 | bool isWhitelist = true; |
| 215 | EXPECT_EQ(0, mTc.replaceUidOwnerMap(name, isWhitelist, uids)); |
| 216 | checkEachUidValue(uids, BPF_PASS, targetMap); |
| 217 | |
| 218 | isWhitelist = false; |
| 219 | EXPECT_EQ(0, mTc.replaceUidOwnerMap(name, isWhitelist, uids)); |
| 220 | checkEachUidValue(uids, BPF_DROP, targetMap); |
| 221 | } |
| 222 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 223 | void TearDown() { |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 224 | std::lock_guard<std::mutex> ownerGuard(mTc.mOwnerMatchMutex); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 225 | mFakeCookieTagMap.reset(); |
| 226 | mFakeUidCounterSetMap.reset(); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 227 | mFakeAppUidStatsMap.reset(); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 228 | mFakeUidStatsMap.reset(); |
| 229 | mFakeTagStatsMap.reset(); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 230 | mTc.mDozableUidMap.reset(); |
| 231 | mTc.mStandbyUidMap.reset(); |
| 232 | mTc.mPowerSaveUidMap.reset(); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 233 | } |
| 234 | }; |
| 235 | |
| 236 | TEST_F(TrafficControllerTest, TestTagSocketV4) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 237 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 238 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 239 | uint64_t sockCookie; |
| 240 | int v4socket = setUpSocketAndTag(AF_INET, &sockCookie, TEST_TAG, TEST_UID); |
| 241 | expectUidTag(sockCookie, TEST_UID, TEST_TAG); |
| 242 | ASSERT_EQ(0, mTc.untagSocket(v4socket)); |
| 243 | expectNoTag(sockCookie); |
| 244 | expectTagMapEmpty(); |
| 245 | } |
| 246 | |
| 247 | TEST_F(TrafficControllerTest, TestReTagSocket) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 248 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 249 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 250 | uint64_t sockCookie; |
| 251 | int v4socket = setUpSocketAndTag(AF_INET, &sockCookie, TEST_TAG, TEST_UID); |
| 252 | expectUidTag(sockCookie, TEST_UID, TEST_TAG); |
| 253 | ASSERT_EQ(0, mTc.tagSocket(v4socket, TEST_TAG + 1, TEST_UID + 1)); |
| 254 | expectUidTag(sockCookie, TEST_UID + 1, TEST_TAG + 1); |
| 255 | } |
| 256 | |
| 257 | TEST_F(TrafficControllerTest, TestTagTwoSockets) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 258 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 259 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 260 | uint64_t sockCookie1; |
| 261 | uint64_t sockCookie2; |
| 262 | int v4socket1 = setUpSocketAndTag(AF_INET, &sockCookie1, TEST_TAG, TEST_UID); |
| 263 | setUpSocketAndTag(AF_INET, &sockCookie2, TEST_TAG, TEST_UID); |
| 264 | expectUidTag(sockCookie1, TEST_UID, TEST_TAG); |
| 265 | expectUidTag(sockCookie2, TEST_UID, TEST_TAG); |
| 266 | ASSERT_EQ(0, mTc.untagSocket(v4socket1)); |
| 267 | expectNoTag(sockCookie1); |
| 268 | expectUidTag(sockCookie2, TEST_UID, TEST_TAG); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 269 | ASSERT_FALSE(isOk(mFakeCookieTagMap.getNextKey(sockCookie2))); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 270 | } |
| 271 | |
| 272 | TEST_F(TrafficControllerTest, TestTagSocketV6) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 273 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 274 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 275 | uint64_t sockCookie; |
| 276 | int v6socket = setUpSocketAndTag(AF_INET6, &sockCookie, TEST_TAG, TEST_UID); |
| 277 | expectUidTag(sockCookie, TEST_UID, TEST_TAG); |
| 278 | ASSERT_EQ(0, mTc.untagSocket(v6socket)); |
| 279 | expectNoTag(sockCookie); |
| 280 | expectTagMapEmpty(); |
| 281 | } |
| 282 | |
| 283 | TEST_F(TrafficControllerTest, TestTagInvalidSocket) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 284 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 285 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 286 | int invalidSocket = -1; |
| 287 | ASSERT_GT(0, mTc.tagSocket(invalidSocket, TEST_TAG, TEST_UID)); |
| 288 | expectTagMapEmpty(); |
| 289 | } |
| 290 | |
| 291 | TEST_F(TrafficControllerTest, TestUntagInvalidSocket) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 292 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 293 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 294 | int invalidSocket = -1; |
| 295 | ASSERT_GT(0, mTc.untagSocket(invalidSocket)); |
| 296 | int v4socket = socket(AF_INET, SOCK_STREAM, 0); |
| 297 | ASSERT_GT(0, mTc.untagSocket(v4socket)); |
| 298 | expectTagMapEmpty(); |
| 299 | } |
| 300 | |
| 301 | TEST_F(TrafficControllerTest, TestSetCounterSet) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 302 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 303 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 304 | ASSERT_EQ(0, mTc.setCounterSet(TEST_COUNTERSET, TEST_UID)); |
| 305 | uid_t uid = TEST_UID; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 306 | StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid); |
| 307 | ASSERT_TRUE(isOk(counterSetResult)); |
| 308 | ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value()); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 309 | ASSERT_EQ(0, mTc.setCounterSet(DEFAULT_COUNTERSET, TEST_UID)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 310 | ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid))); |
| 311 | ASSERT_FALSE(isOk(mFakeUidCounterSetMap.getFirstKey())); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 312 | } |
| 313 | |
| 314 | TEST_F(TrafficControllerTest, TestSetInvalidCounterSet) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 315 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 316 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 317 | ASSERT_GT(0, mTc.setCounterSet(OVERFLOW_COUNTERSET, TEST_UID)); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 318 | uid_t uid = TEST_UID; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 319 | ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid))); |
| 320 | ASSERT_FALSE(isOk(mFakeUidCounterSetMap.getFirstKey())); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 321 | } |
| 322 | |
| 323 | TEST_F(TrafficControllerTest, TestDeleteTagData) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 324 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 325 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 326 | uint64_t cookie = 1; |
| 327 | uid_t uid = TEST_UID; |
| 328 | uint32_t tag = TEST_TAG; |
| 329 | StatsKey tagStatsMapKey; |
| 330 | populateFakeStats(cookie, uid, tag, &tagStatsMapKey); |
| 331 | ASSERT_EQ(0, mTc.deleteTagData(TEST_TAG, TEST_UID)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 332 | ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie))); |
| 333 | StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid); |
| 334 | ASSERT_TRUE(isOk(counterSetResult)); |
| 335 | ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value()); |
| 336 | ASSERT_FALSE(isOk(mFakeTagStatsMap.readValue(tagStatsMapKey))); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 337 | tagStatsMapKey.tag = 0; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 338 | StatusOr<StatsValue> statsMapResult = mFakeUidStatsMap.readValue(tagStatsMapKey); |
| 339 | ASSERT_TRUE(isOk(statsMapResult)); |
| 340 | ASSERT_EQ((uint64_t)1, statsMapResult.value().rxPackets); |
| 341 | ASSERT_EQ((uint64_t)100, statsMapResult.value().rxBytes); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 342 | auto appStatsResult = mFakeAppUidStatsMap.readValue(TEST_UID); |
| 343 | ASSERT_TRUE(isOk(appStatsResult)); |
| 344 | ASSERT_EQ((uint64_t)1, appStatsResult.value().rxPackets); |
| 345 | ASSERT_EQ((uint64_t)100, appStatsResult.value().rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 346 | } |
| 347 | |
| 348 | TEST_F(TrafficControllerTest, TestDeleteAllUidData) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 349 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 350 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 351 | uint64_t cookie = 1; |
| 352 | uid_t uid = TEST_UID; |
| 353 | uint32_t tag = TEST_TAG; |
| 354 | StatsKey tagStatsMapKey; |
| 355 | populateFakeStats(cookie, uid, tag, &tagStatsMapKey); |
| 356 | ASSERT_EQ(0, mTc.deleteTagData(0, TEST_UID)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 357 | ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie))); |
| 358 | ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid))); |
| 359 | ASSERT_FALSE(isOk(mFakeTagStatsMap.readValue(tagStatsMapKey))); |
| 360 | tagStatsMapKey.tag = 0; |
| 361 | ASSERT_FALSE(isOk(mFakeUidStatsMap.readValue(tagStatsMapKey))); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 362 | ASSERT_FALSE(isOk(mFakeAppUidStatsMap.readValue(TEST_UID))); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 363 | } |
| 364 | |
| 365 | TEST_F(TrafficControllerTest, TestDeleteDataWithTwoTags) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 366 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 367 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 368 | uint64_t cookie1 = 1; |
| 369 | uint64_t cookie2 = 2; |
| 370 | uid_t uid = TEST_UID; |
| 371 | uint32_t tag1 = TEST_TAG; |
| 372 | uint32_t tag2 = TEST_TAG + 1; |
| 373 | StatsKey tagStatsMapKey1; |
| 374 | StatsKey tagStatsMapKey2; |
| 375 | populateFakeStats(cookie1, uid, tag1, &tagStatsMapKey1); |
| 376 | populateFakeStats(cookie2, uid, tag2, &tagStatsMapKey2); |
| 377 | ASSERT_EQ(0, mTc.deleteTagData(TEST_TAG, TEST_UID)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 378 | ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie1))); |
| 379 | StatusOr<UidTag> cookieMapResult = mFakeCookieTagMap.readValue(cookie2); |
| 380 | ASSERT_TRUE(isOk(cookieMapResult)); |
| 381 | ASSERT_EQ(TEST_UID, cookieMapResult.value().uid); |
| 382 | ASSERT_EQ(TEST_TAG + 1, cookieMapResult.value().tag); |
| 383 | StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid); |
| 384 | ASSERT_TRUE(isOk(counterSetResult)); |
| 385 | ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value()); |
| 386 | ASSERT_FALSE(isOk(mFakeTagStatsMap.readValue(tagStatsMapKey1))); |
| 387 | StatusOr<StatsValue> statsMapResult = mFakeTagStatsMap.readValue(tagStatsMapKey2); |
| 388 | ASSERT_TRUE(isOk(statsMapResult)); |
| 389 | ASSERT_EQ((uint64_t)1, statsMapResult.value().rxPackets); |
| 390 | ASSERT_EQ((uint64_t)100, statsMapResult.value().rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 391 | } |
| 392 | |
| 393 | TEST_F(TrafficControllerTest, TestDeleteDataWithTwoUids) { |
Lorenzo Colitti | 23e5c7f | 2018-01-12 17:55:59 +0900 | [diff] [blame] | 394 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 395 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 396 | uint64_t cookie1 = 1; |
| 397 | uint64_t cookie2 = 2; |
| 398 | uid_t uid1 = TEST_UID; |
| 399 | uid_t uid2 = TEST_UID + 1; |
| 400 | uint32_t tag = TEST_TAG; |
| 401 | StatsKey tagStatsMapKey1; |
| 402 | StatsKey tagStatsMapKey2; |
| 403 | populateFakeStats(cookie1, uid1, tag, &tagStatsMapKey1); |
| 404 | populateFakeStats(cookie2, uid2, tag, &tagStatsMapKey2); |
| 405 | |
| 406 | // Delete the stats of one of the uid. Check if it is properly collected by |
| 407 | // removedStats. |
| 408 | ASSERT_EQ(0, mTc.deleteTagData(0, uid2)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 409 | ASSERT_FALSE(isOk(mFakeCookieTagMap.readValue(cookie2))); |
| 410 | StatusOr<uint8_t> counterSetResult = mFakeUidCounterSetMap.readValue(uid1); |
| 411 | ASSERT_TRUE(isOk(counterSetResult)); |
| 412 | ASSERT_EQ(TEST_COUNTERSET, counterSetResult.value()); |
| 413 | ASSERT_FALSE(isOk(mFakeUidCounterSetMap.readValue(uid2))); |
| 414 | ASSERT_FALSE(isOk(mFakeTagStatsMap.readValue(tagStatsMapKey2))); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 415 | tagStatsMapKey2.tag = 0; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 416 | ASSERT_FALSE(isOk(mFakeUidStatsMap.readValue(tagStatsMapKey2))); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 417 | ASSERT_FALSE(isOk(mFakeAppUidStatsMap.readValue(uid2))); |
Chenbo Feng | 63ad559 | 2018-01-22 23:14:12 -0800 | [diff] [blame] | 418 | tagStatsMapKey1.tag = 0; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 419 | StatusOr<StatsValue> statsMapResult = mFakeUidStatsMap.readValue(tagStatsMapKey1); |
| 420 | ASSERT_TRUE(isOk(statsMapResult)); |
| 421 | ASSERT_EQ((uint64_t)1, statsMapResult.value().rxPackets); |
| 422 | ASSERT_EQ((uint64_t)100, statsMapResult.value().rxBytes); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 423 | auto appStatsResult = mFakeAppUidStatsMap.readValue(uid1); |
| 424 | ASSERT_TRUE(isOk(appStatsResult)); |
| 425 | ASSERT_EQ((uint64_t)1, appStatsResult.value().rxPackets); |
| 426 | ASSERT_EQ((uint64_t)100, appStatsResult.value().rxBytes); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 427 | |
Chenbo Feng | ef1cab3 | 2018-04-13 19:50:49 -0700 | [diff] [blame] | 428 | // Delete the stats of the other uid. |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 429 | ASSERT_EQ(0, mTc.deleteTagData(0, uid1)); |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 430 | ASSERT_FALSE(isOk(mFakeUidStatsMap.readValue(tagStatsMapKey1))); |
Chenbo Feng | bc4a15f | 2018-05-11 19:15:15 -0700 | [diff] [blame] | 431 | ASSERT_FALSE(isOk(mFakeAppUidStatsMap.readValue(uid1))); |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 432 | } |
| 433 | |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 434 | TEST_F(TrafficControllerTest, TestUpdateOwnerMapEntry) { |
| 435 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 436 | |
| 437 | uint32_t uid = TEST_UID; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 438 | ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, DENY, BLACKLIST))); |
| 439 | StatusOr<uint8_t> value = mFakeDozableUidMap.readValue(uid); |
| 440 | ASSERT_TRUE(isOk(value)); |
| 441 | ASSERT_EQ(BPF_DROP, value.value()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 442 | |
| 443 | uid = TEST_UID2; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 444 | ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, ALLOW, WHITELIST))); |
| 445 | value = mFakeDozableUidMap.readValue(uid); |
| 446 | ASSERT_TRUE(isOk(value)); |
| 447 | ASSERT_EQ(BPF_PASS, value.value()); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 448 | |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 449 | ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, DENY, WHITELIST))); |
| 450 | ASSERT_FALSE(isOk(mFakeDozableUidMap.readValue(uid))); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 451 | |
| 452 | uid = TEST_UID; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 453 | ASSERT_TRUE(isOk(mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, ALLOW, BLACKLIST))); |
| 454 | ASSERT_FALSE(isOk(mFakeDozableUidMap.readValue(uid))); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 455 | |
| 456 | uid = TEST_UID3; |
Chenbo Feng | 4f6c237 | 2018-04-26 10:37:55 -0700 | [diff] [blame] | 457 | ASSERT_FALSE(isOk(mTc.updateOwnerMapEntry(mFakeDozableUidMap, uid, ALLOW, BLACKLIST))); |
| 458 | ASSERT_FALSE(isOk(mFakeDozableUidMap.readValue(uid))); |
Chenbo Feng | 89c12f1 | 2018-03-21 10:29:18 -0700 | [diff] [blame] | 459 | } |
| 460 | |
| 461 | TEST_F(TrafficControllerTest, TestChangeUidOwnerRule) { |
| 462 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 463 | |
| 464 | checkUidOwnerRuleForChain(DOZABLE, mFakeDozableUidMap); |
| 465 | checkUidOwnerRuleForChain(STANDBY, mFakeStandbyUidMap); |
| 466 | checkUidOwnerRuleForChain(POWERSAVE, mFakePowerSaveUidMap); |
| 467 | ASSERT_EQ(-EINVAL, mTc.changeUidOwnerRule(NONE, TEST_UID, ALLOW, WHITELIST)); |
| 468 | ASSERT_EQ(-EINVAL, mTc.changeUidOwnerRule(INVALID_CHAIN, TEST_UID, ALLOW, WHITELIST)); |
| 469 | } |
| 470 | |
| 471 | TEST_F(TrafficControllerTest, TestReplaceUidOwnerMap) { |
| 472 | SKIP_IF_BPF_NOT_SUPPORTED; |
| 473 | |
| 474 | std::vector<int32_t> uids = {TEST_UID, TEST_UID2, TEST_UID3}; |
| 475 | checkUidMapReplace("fw_dozable", uids, mFakeDozableUidMap); |
| 476 | checkUidMapReplace("fw_standby", uids, mFakeStandbyUidMap); |
| 477 | checkUidMapReplace("fw_powersave", uids, mFakePowerSaveUidMap); |
| 478 | ASSERT_EQ(-EINVAL, mTc.replaceUidOwnerMap("unknow", true, uids)); |
| 479 | } |
| 480 | |
Chenbo Feng | ed37fea | 2017-12-13 19:35:01 -0800 | [diff] [blame] | 481 | } // namespace net |
| 482 | } // namespace android |