| /** |
| * Copyright (c) 2018, The Android Open Source Project |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #define LOG_TAG "TestUnsolService" |
| |
| #include <cinttypes> |
| #include <vector> |
| |
| #include <android-base/stringprintf.h> |
| #include <android-base/strings.h> |
| #include <log/log.h> |
| #include <utils/Errors.h> |
| #include <utils/String16.h> |
| |
| #include <binder/IPCThreadState.h> |
| #include <binder/IServiceManager.h> |
| #include "android/net/BnNetdUnsolicitedEventListener.h" |
| |
| #include "TestUnsolService.h" |
| |
| using android::base::StringPrintf; |
| |
| namespace android { |
| namespace net { |
| |
| TestUnsolService* TestUnsolService::start() { |
| IPCThreadState::self()->disableBackgroundScheduling(true); |
| sp<IServiceManager> sm(defaultServiceManager()); |
| |
| auto service = new TestUnsolService(); |
| const status_t ret = sm->addService(String16(getServiceName()), service, false, |
| IServiceManager::DUMP_FLAG_PRIORITY_DEFAULT); |
| if (ret != android::OK) { |
| return nullptr; |
| } |
| sp<ProcessState> ps(ProcessState::self()); |
| ps->startThreadPool(); |
| ps->giveThreadPoolName(); |
| |
| return service; |
| } |
| |
| namespace { |
| |
| bool containsSubstring(const std::vector<std::string>& vec, const std::string& subStr) { |
| return std::any_of(vec.begin(), vec.end(), [&subStr](const std::string& str) { |
| return (str.find(subStr) != std::string::npos); |
| }); |
| } |
| |
| } // namespace |
| |
| void TestUnsolService::checkTarget(const std::string& ifName, uint32_t flag) { |
| if (containsSubstring(tarVec, ifName)) { |
| received_ |= flag; |
| maybeNotify(); |
| }; |
| } |
| |
| void TestUnsolService::maybeNotify() { |
| // We only have test case for below event currently. |
| if (received_ == (InterfaceAddressUpdated | InterfaceAdded | InterfaceRemoved | |
| InterfaceLinkStatusChanged | RouteChanged)) { |
| std::lock_guard lock(cv_mutex_); |
| cv_.notify_one(); |
| } |
| } |
| |
| binder::Status TestUnsolService::onInterfaceClassActivityChanged(bool isActive, int label, |
| int64_t timestamp, int uid) { |
| events_.push_back(StringPrintf("onInterfaceClassActivityChanged %d %d %" PRId64 "%d", isActive, |
| label, timestamp, uid)); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onQuotaLimitReached(const std::string& alertName, |
| const std::string& ifName) { |
| events_.push_back(StringPrintf("onQuotaLimitReached %s %s", alertName.c_str(), ifName.c_str())); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceDnsServerInfo(const std::string& ifName, |
| int64_t lifetime, |
| const std::vector<std::string>& servers) { |
| events_.push_back(StringPrintf("onInterfaceDnsServerInfo %s %" PRId64 "%s", ifName.c_str(), |
| lifetime, base::Join(servers, ", ").c_str())); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceAddressUpdated(const std::string&, |
| const std::string& ifName, int, int) { |
| checkTarget(ifName, InterfaceAddressUpdated); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceAddressRemoved(const std::string& addr, |
| const std::string& ifName, int flags, |
| int scope) { |
| events_.push_back(StringPrintf("onInterfaceAddressRemoved %s %s %d %d", addr.c_str(), |
| ifName.c_str(), flags, scope)); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceAdded(const std::string& ifName) { |
| checkTarget(ifName, InterfaceAdded); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceRemoved(const std::string& ifName) { |
| checkTarget(ifName, InterfaceRemoved); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceChanged(const std::string& ifName, bool status) { |
| events_.push_back(StringPrintf("onInterfaceChanged %s %d", ifName.c_str(), status)); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onInterfaceLinkStateChanged(const std::string& ifName, bool) { |
| checkTarget(ifName, InterfaceLinkStatusChanged); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onRouteChanged(bool, const std::string&, const std::string&, |
| const std::string& ifName) { |
| checkTarget(ifName, RouteChanged); |
| return binder::Status::ok(); |
| } |
| |
| binder::Status TestUnsolService::onStrictCleartextDetected(int uid, const std::string& hex) { |
| events_.push_back(StringPrintf("onStrictCleartextDetected %d %s", uid, hex.c_str())); |
| return binder::Status::ok(); |
| } |
| |
| } // namespace net |
| } // namespace android |