Netd unsolicited event porting
Use another buffer to log unsolicited event.
Test: built, flashed, booted
Test: 1. manual test datacall/wifi work
2. manual test tethering work
3. run cts StrictModeTest pass
4. manual test data alert work
5. manual idletimer work
Change-Id: I1e4ed360b0c9d60c14bc7f0ffdf578fc557d3643
diff --git a/tests/TestUnsolService.cpp b/tests/TestUnsolService.cpp
new file mode 100644
index 0000000..134328b
--- /dev/null
+++ b/tests/TestUnsolService.cpp
@@ -0,0 +1,149 @@
+/**
+ * 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
\ No newline at end of file