blob: c55dd9de1b0d90ef4a7f28c34a34d1918dbab9b7 [file] [log] [blame]
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -08001/*
2 * Copyright (C) 2005 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
Steven Moreland85d985c2022-09-12 20:57:51 +000017#define LOG_TAG "ServiceManagerCppClient"
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -080018
Mathias Agopianc5b2c0b2009-05-19 19:08:10 -070019#include <binder/IServiceManager.h>
Tomasz Wasilczykfe25f122024-06-26 12:45:57 -070020#include "BackendUnifiedServiceManager.h"
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -080021
Tom Cherry8fda97f2020-07-22 17:15:44 -070022#include <inttypes.h>
23#include <unistd.h>
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -070024#include <chrono>
Tomasz Wasilczyke97f3a82024-04-30 10:37:32 -070025#include <condition_variable>
Tom Cherry8fda97f2020-07-22 17:15:44 -070026
Steven Moreland454bfd92022-07-20 20:53:36 +000027#include <android-base/properties.h>
Steven Moreland1c47b582019-08-27 18:05:27 -070028#include <android/os/BnServiceCallback.h>
Alice Wang8578f132024-05-03 09:01:56 +000029#include <android/os/IAccessor.h>
Steven Moreland80e1e6d2019-06-21 12:35:59 -070030#include <android/os/IServiceManager.h>
Mathias Agopian375f5632009-06-15 18:24:59 -070031#include <binder/IPCThreadState.h>
Steven Moreland28723ae2019-04-01 18:52:30 -070032#include <binder/Parcel.h>
Steven Moreland28723ae2019-04-01 18:52:30 -070033#include <utils/String8.h>
Steven Moreland28723ae2019-04-01 18:52:30 -070034
Jiyong Park47f876b2018-04-17 13:56:46 +090035#ifndef __ANDROID_VNDK__
36#include <binder/IPermissionController.h>
37#endif
Steven Moreland28723ae2019-04-01 18:52:30 -070038
Steven Morelanded3b5632019-09-20 11:24:28 -070039#ifdef __ANDROID__
Yunfan Chen788e1c42018-03-29 16:52:09 +090040#include <cutils/properties.h>
Yifan Hongf7760012021-06-04 16:04:42 -070041#else
42#include "ServiceManagerHost.h"
Steven Moreland28723ae2019-04-01 18:52:30 -070043#endif
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -080044
Jooyung Han75fc06f2024-02-03 03:56:59 +090045#if defined(__ANDROID__) && !defined(__ANDROID_RECOVERY__) && !defined(__ANDROID_NATIVE_BRIDGE__)
46#include <android/apexsupport.h>
47#include <vndksupport/linker.h>
48#endif
49
Steven Morelanda4853cd2019-07-12 15:44:37 -070050#include "Static.h"
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -070051#include "Utils.h"
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -080052
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -080053namespace android {
54
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -070055using namespace std::chrono_literals;
56
Jayant Chowdhary30700942022-01-31 14:12:40 -080057using AidlRegistrationCallback = IServiceManager::LocalRegistrationCallback;
58
Steven Moreland80e1e6d2019-06-21 12:35:59 -070059using AidlServiceManager = android::os::IServiceManager;
60using android::binder::Status;
Alice Wang8578f132024-05-03 09:01:56 +000061using android::os::IAccessor;
62using android::os::Service;
Steven Moreland80e1e6d2019-06-21 12:35:59 -070063
Steven Moreland635a2912019-10-02 15:50:10 -070064// libbinder's IServiceManager.h can't rely on the values generated by AIDL
65// because many places use its headers via include_dirs (meaning, without
66// declaring the dependency in the build system). So, for now, we can just check
67// the values here.
68static_assert(AidlServiceManager::DUMP_FLAG_PRIORITY_CRITICAL == IServiceManager::DUMP_FLAG_PRIORITY_CRITICAL);
69static_assert(AidlServiceManager::DUMP_FLAG_PRIORITY_HIGH == IServiceManager::DUMP_FLAG_PRIORITY_HIGH);
70static_assert(AidlServiceManager::DUMP_FLAG_PRIORITY_NORMAL == IServiceManager::DUMP_FLAG_PRIORITY_NORMAL);
71static_assert(AidlServiceManager::DUMP_FLAG_PRIORITY_DEFAULT == IServiceManager::DUMP_FLAG_PRIORITY_DEFAULT);
72static_assert(AidlServiceManager::DUMP_FLAG_PRIORITY_ALL == IServiceManager::DUMP_FLAG_PRIORITY_ALL);
73static_assert(AidlServiceManager::DUMP_FLAG_PROTO == IServiceManager::DUMP_FLAG_PROTO);
74
Steven Moreland583685e2019-10-02 16:45:11 -070075const String16& IServiceManager::getInterfaceDescriptor() const {
76 return AidlServiceManager::descriptor;
77}
78IServiceManager::IServiceManager() {}
79IServiceManager::~IServiceManager() {}
80
81// From the old libbinder IServiceManager interface to IServiceManager.
Parth Sanec7b58642024-08-07 10:31:15 +000082class CppBackendShim : public IServiceManager {
Steven Moreland583685e2019-10-02 16:45:11 -070083public:
Parth Sanec7b58642024-08-07 10:31:15 +000084 explicit CppBackendShim(const sp<BackendUnifiedServiceManager>& impl);
Steven Moreland583685e2019-10-02 16:45:11 -070085
86 sp<IBinder> getService(const String16& name) const override;
87 sp<IBinder> checkService(const String16& name) const override;
88 status_t addService(const String16& name, const sp<IBinder>& service,
89 bool allowIsolated, int dumpsysPriority) override;
90 Vector<String16> listServices(int dumpsysPriority) override;
91 sp<IBinder> waitForService(const String16& name16) override;
Steven Morelandb82b8f82019-10-28 10:52:34 -070092 bool isDeclared(const String16& name) override;
Steven Moreland2e293aa2020-09-23 00:25:16 +000093 Vector<String16> getDeclaredInstances(const String16& interface) override;
Steven Morelandedd4e072021-04-21 00:27:29 +000094 std::optional<String16> updatableViaApex(const String16& name) override;
Jooyung Han76944fe2022-10-25 17:02:45 +090095 Vector<String16> getUpdatableNames(const String16& apexName) override;
Devin Moore5e4c2f12021-09-09 22:36:33 +000096 std::optional<IServiceManager::ConnectionInfo> getConnectionInfo(const String16& name) override;
Jayant Chowdhary30700942022-01-31 14:12:40 -080097 class RegistrationWaiter : public android::os::BnServiceCallback {
98 public:
99 explicit RegistrationWaiter(const sp<AidlRegistrationCallback>& callback)
100 : mImpl(callback) {}
101 Status onRegistration(const std::string& name, const sp<IBinder>& binder) override {
102 mImpl->onServiceRegistration(String16(name.c_str()), binder);
103 return Status::ok();
104 }
Steven Moreland583685e2019-10-02 16:45:11 -0700105
Jayant Chowdhary30700942022-01-31 14:12:40 -0800106 private:
107 sp<AidlRegistrationCallback> mImpl;
108 };
109
110 status_t registerForNotifications(const String16& service,
111 const sp<AidlRegistrationCallback>& cb) override;
112
113 status_t unregisterForNotifications(const String16& service,
114 const sp<AidlRegistrationCallback>& cb) override;
Jayant Chowdharya0a8eb22022-05-20 03:30:09 +0000115
116 std::vector<IServiceManager::ServiceDebugInfo> getServiceDebugInfo() override;
Steven Moreland583685e2019-10-02 16:45:11 -0700117 // for legacy ABI
118 const String16& getInterfaceDescriptor() const override {
Parth Sane56a04712024-04-22 14:21:07 +0000119 return mUnifiedServiceManager->getInterfaceDescriptor();
Steven Moreland583685e2019-10-02 16:45:11 -0700120 }
Parth Sane56a04712024-04-22 14:21:07 +0000121 IBinder* onAsBinder() override { return IInterface::asBinder(mUnifiedServiceManager).get(); }
Yifan Hongf7760012021-06-04 16:04:42 -0700122
123protected:
Parth Sane56a04712024-04-22 14:21:07 +0000124 sp<BackendUnifiedServiceManager> mUnifiedServiceManager;
Jayant Chowdhary30700942022-01-31 14:12:40 -0800125 // AidlRegistrationCallback -> services that its been registered for
126 // notifications.
127 using LocalRegistrationAndWaiter =
128 std::pair<sp<LocalRegistrationCallback>, sp<RegistrationWaiter>>;
129 using ServiceCallbackMap = std::map<std::string, std::vector<LocalRegistrationAndWaiter>>;
130 ServiceCallbackMap mNameToRegistrationCallback;
131 std::mutex mNameToRegistrationLock;
132
133 void removeRegistrationCallbackLocked(const sp<AidlRegistrationCallback>& cb,
134 ServiceCallbackMap::iterator* it,
135 sp<RegistrationWaiter>* waiter);
Yifan Hongf7760012021-06-04 16:04:42 -0700136
137 // Directly get the service in a way that, for lazy services, requests the service to be started
Parth Sanec7b58642024-08-07 10:31:15 +0000138 // if it is not currently started. This way, calls directly to CppBackendShim::getService
Yifan Hongf7760012021-06-04 16:04:42 -0700139 // will still have the 5s delay that is expected by a large amount of Android code.
140 //
Parth Sanec7b58642024-08-07 10:31:15 +0000141 // When implementing CppBackendShim, use realGetService instead of
142 // mUnifiedServiceManager->getService so that it can be overridden in CppServiceManagerHostShim.
Yifan Hongf7760012021-06-04 16:04:42 -0700143 virtual Status realGetService(const std::string& name, sp<IBinder>* _aidl_return) {
Alice Wang8578f132024-05-03 09:01:56 +0000144 Service service;
Alice Wang11da1502024-07-25 12:03:22 +0000145 Status status = mUnifiedServiceManager->getService2(name, &service);
Alice Wang8578f132024-05-03 09:01:56 +0000146 *_aidl_return = service.get<Service::Tag::binder>();
147 return status;
Yifan Hongf7760012021-06-04 16:04:42 -0700148 }
Steven Moreland583685e2019-10-02 16:45:11 -0700149};
150
Steven Moreland1698ffd2020-05-15 23:43:52 +0000151[[clang::no_destroy]] static std::once_flag gSmOnce;
152[[clang::no_destroy]] static sp<IServiceManager> gDefaultServiceManager;
Brett Chabot38dbade2020-01-24 12:59:43 -0800153
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800154sp<IServiceManager> defaultServiceManager()
155{
Martijn Coenen402c8672020-02-03 10:01:36 +0100156 std::call_once(gSmOnce, []() {
Parth Sanec7b58642024-08-07 10:31:15 +0000157 gDefaultServiceManager = sp<CppBackendShim>::make(getBackendUnifiedServiceManager());
Martijn Coenen402c8672020-02-03 10:01:36 +0100158 });
Daniel Eratc2832702015-10-13 15:29:32 -0600159
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800160 return gDefaultServiceManager;
161}
162
Brett Chabot38dbade2020-01-24 12:59:43 -0800163void setDefaultServiceManager(const sp<IServiceManager>& sm) {
Martijn Coenen402c8672020-02-03 10:01:36 +0100164 bool called = false;
165 std::call_once(gSmOnce, [&]() {
166 gDefaultServiceManager = sm;
167 called = true;
168 });
169
170 if (!called) {
171 LOG_ALWAYS_FATAL("setDefaultServiceManager() called after defaultServiceManager().");
172 }
Brett Chabot38dbade2020-01-24 12:59:43 -0800173}
174
Atneya Nair5b9cbbf2022-05-24 20:39:48 -0400175#if !defined(__ANDROID_VNDK__)
Jiyong Park47f876b2018-04-17 13:56:46 +0900176// IPermissionController is not accessible to vendors
177
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800178bool checkCallingPermission(const String16& permission)
179{
Yi Kongfdd8da92018-06-07 17:52:27 -0700180 return checkCallingPermission(permission, nullptr, nullptr);
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800181}
182
Steven Moreland1b264072021-06-03 23:04:02 +0000183static StaticString16 _permission(u"permission");
Mathias Agopian375f5632009-06-15 18:24:59 -0700184
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800185bool checkCallingPermission(const String16& permission, int32_t* outPid, int32_t* outUid)
186{
187 IPCThreadState* ipcState = IPCThreadState::self();
Mathias Agopian375f5632009-06-15 18:24:59 -0700188 pid_t pid = ipcState->getCallingPid();
189 uid_t uid = ipcState->getCallingUid();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800190 if (outPid) *outPid = pid;
Mathias Agopian375f5632009-06-15 18:24:59 -0700191 if (outUid) *outUid = uid;
192 return checkPermission(permission, pid, uid);
193}
194
Jayant Chowdhary49bc34b2021-07-28 20:27:21 +0000195bool checkPermission(const String16& permission, pid_t pid, uid_t uid, bool logPermissionFailure) {
Tomasz Wasilczyk66ee1922023-10-26 14:53:49 -0700196 static std::mutex gPermissionControllerLock;
Steven Moreland92b17c62019-04-02 15:46:24 -0700197 static sp<IPermissionController> gPermissionController;
198
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800199 sp<IPermissionController> pc;
Steven Moreland92b17c62019-04-02 15:46:24 -0700200 gPermissionControllerLock.lock();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800201 pc = gPermissionController;
Steven Moreland92b17c62019-04-02 15:46:24 -0700202 gPermissionControllerLock.unlock();
Daniel Eratc2832702015-10-13 15:29:32 -0600203
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700204 auto startTime = std::chrono::steady_clock::now().min();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800205
206 while (true) {
Yi Kongfdd8da92018-06-07 17:52:27 -0700207 if (pc != nullptr) {
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800208 bool res = pc->checkPermission(permission, pid, uid);
209 if (res) {
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700210 if (startTime != startTime.min()) {
211 const auto waitTime = std::chrono::steady_clock::now() - startTime;
212 ALOGI("Check passed after %" PRIu64 "ms for %s from uid=%d pid=%d",
213 to_ms(waitTime), String8(permission).c_str(), uid, pid);
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800214 }
215 return res;
216 }
Daniel Eratc2832702015-10-13 15:29:32 -0600217
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800218 // Is this a permission failure, or did the controller go away?
Marco Nelissen097ca272014-11-14 08:01:01 -0800219 if (IInterface::asBinder(pc)->isBinderAlive()) {
Jayant Chowdhary49bc34b2021-07-28 20:27:21 +0000220 if (logPermissionFailure) {
Tomasz Wasilczyk0bfea2d2023-08-11 00:06:51 +0000221 ALOGW("Permission failure: %s from uid=%d pid=%d", String8(permission).c_str(),
Jayant Chowdhary49bc34b2021-07-28 20:27:21 +0000222 uid, pid);
223 }
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800224 return false;
225 }
Daniel Eratc2832702015-10-13 15:29:32 -0600226
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800227 // Object is dead!
Steven Moreland92b17c62019-04-02 15:46:24 -0700228 gPermissionControllerLock.lock();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800229 if (gPermissionController == pc) {
Yi Kongfdd8da92018-06-07 17:52:27 -0700230 gPermissionController = nullptr;
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800231 }
Steven Moreland92b17c62019-04-02 15:46:24 -0700232 gPermissionControllerLock.unlock();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800233 }
Daniel Eratc2832702015-10-13 15:29:32 -0600234
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800235 // Need to retrieve the permission controller.
236 sp<IBinder> binder = defaultServiceManager()->checkService(_permission);
Yi Kongfdd8da92018-06-07 17:52:27 -0700237 if (binder == nullptr) {
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800238 // Wait for the permission controller to come back...
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700239 if (startTime == startTime.min()) {
240 startTime = std::chrono::steady_clock::now();
Steve Blocka19954a2012-01-04 20:05:49 +0000241 ALOGI("Waiting to check permission %s from uid=%d pid=%d",
Tomasz Wasilczyk0bfea2d2023-08-11 00:06:51 +0000242 String8(permission).c_str(), uid, pid);
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800243 }
244 sleep(1);
245 } else {
246 pc = interface_cast<IPermissionController>(binder);
Daniel Eratc2832702015-10-13 15:29:32 -0600247 // Install the new permission controller, and try again.
Steven Moreland92b17c62019-04-02 15:46:24 -0700248 gPermissionControllerLock.lock();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800249 gPermissionController = pc;
Steven Moreland92b17c62019-04-02 15:46:24 -0700250 gPermissionControllerLock.unlock();
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800251 }
252 }
253}
254
Steven Moreland576662a2024-08-09 23:12:03 +0000255#endif //__ANDROID_VNDK__
256
Jooyung Han75fc06f2024-02-03 03:56:59 +0900257void* openDeclaredPassthroughHal(const String16& interface, const String16& instance, int flag) {
Steven Moreland576662a2024-08-09 23:12:03 +0000258#if defined(__ANDROID__) && !defined(__ANDROID_VENDOR__) && !defined(__ANDROID_RECOVERY__) && \
259 !defined(__ANDROID_NATIVE_BRIDGE__)
Jooyung Han75fc06f2024-02-03 03:56:59 +0900260 sp<IServiceManager> sm = defaultServiceManager();
261 String16 name = interface + String16("/") + instance;
262 if (!sm->isDeclared(name)) {
263 return nullptr;
264 }
265 String16 libraryName = interface + String16(".") + instance + String16(".so");
266 if (auto updatableViaApex = sm->updatableViaApex(name); updatableViaApex.has_value()) {
267 return AApexSupport_loadLibrary(String8(libraryName).c_str(),
268 String8(*updatableViaApex).c_str(), flag);
269 }
270 return android_load_sphal_library(String8(libraryName).c_str(), flag);
271#else
272 (void)interface;
273 (void)instance;
274 (void)flag;
275 return nullptr;
276#endif
277}
278
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800279// ----------------------------------------------------------------------
280
Parth Sanec7b58642024-08-07 10:31:15 +0000281CppBackendShim::CppBackendShim(const sp<BackendUnifiedServiceManager>& impl)
Parth Sane43e3b8b2024-08-05 13:39:04 +0000282 : mUnifiedServiceManager(impl) {}
Brad Fitzpatrick702ea9d2010-06-18 13:07:53 -0700283
Steven Moreland5af7d852020-04-29 15:40:29 -0700284// This implementation could be simplified and made more efficient by delegating
285// to waitForService. However, this changes the threading structure in some
286// cases and could potentially break prebuilts. Once we have higher logistical
287// complexity, this could be attempted.
Parth Sanec7b58642024-08-07 10:31:15 +0000288sp<IBinder> CppBackendShim::getService(const String16& name) const {
Steven Moreland583685e2019-10-02 16:45:11 -0700289 static bool gSystemBootCompleted = false;
290
291 sp<IBinder> svc = checkService(name);
292 if (svc != nullptr) return svc;
293
294 const bool isVendorService =
295 strcmp(ProcessState::self()->getDriverName().c_str(), "/dev/vndbinder") == 0;
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700296 constexpr auto timeout = 5s;
297 const auto startTime = std::chrono::steady_clock::now();
Steven Moreland583685e2019-10-02 16:45:11 -0700298 // Vendor code can't access system properties
299 if (!gSystemBootCompleted && !isVendorService) {
300#ifdef __ANDROID__
301 char bootCompleted[PROPERTY_VALUE_MAX];
302 property_get("sys.boot_completed", bootCompleted, "0");
303 gSystemBootCompleted = strcmp(bootCompleted, "1") == 0 ? true : false;
304#else
305 gSystemBootCompleted = true;
306#endif
307 }
308 // retry interval in millisecond; note that vendor services stay at 100ms
Jiyong Park16c6e702020-11-13 20:53:12 +0900309 const useconds_t sleepTime = gSystemBootCompleted ? 1000 : 100;
Steven Moreland583685e2019-10-02 16:45:11 -0700310
Tomasz Wasilczyk0bfea2d2023-08-11 00:06:51 +0000311 ALOGI("Waiting for service '%s' on '%s'...", String8(name).c_str(),
Tom Cherry8fda97f2020-07-22 17:15:44 -0700312 ProcessState::self()->getDriverName().c_str());
313
Steven Moreland583685e2019-10-02 16:45:11 -0700314 int n = 0;
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700315 while (std::chrono::steady_clock::now() - startTime < timeout) {
Steven Moreland583685e2019-10-02 16:45:11 -0700316 n++;
Steven Moreland583685e2019-10-02 16:45:11 -0700317 usleep(1000*sleepTime);
Steven Moreland92b17c62019-04-02 15:46:24 -0700318
Yunfan Chen788e1c42018-03-29 16:52:09 +0900319 sp<IBinder> svc = checkService(name);
Tom Cherry8fda97f2020-07-22 17:15:44 -0700320 if (svc != nullptr) {
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700321 const auto waitTime = std::chrono::steady_clock::now() - startTime;
322 ALOGI("Waiting for service '%s' on '%s' successful after waiting %" PRIu64 "ms",
Tomasz Wasilczyk0bfea2d2023-08-11 00:06:51 +0000323 String8(name).c_str(), ProcessState::self()->getDriverName().c_str(),
Tomasz Wasilczyk1d46f582024-05-21 15:06:29 -0700324 to_ms(waitTime));
Tom Cherry8fda97f2020-07-22 17:15:44 -0700325 return svc;
326 }
Steven Moreland583685e2019-10-02 16:45:11 -0700327 }
Tomasz Wasilczyk0bfea2d2023-08-11 00:06:51 +0000328 ALOGW("Service %s didn't start. Returning NULL", String8(name).c_str());
Steven Moreland583685e2019-10-02 16:45:11 -0700329 return nullptr;
330}
Yunfan Chen788e1c42018-03-29 16:52:09 +0900331
Parth Sanec7b58642024-08-07 10:31:15 +0000332sp<IBinder> CppBackendShim::checkService(const String16& name) const {
Alice Wang8578f132024-05-03 09:01:56 +0000333 Service ret;
Parth Sane56a04712024-04-22 14:21:07 +0000334 if (!mUnifiedServiceManager->checkService(String8(name).c_str(), &ret).isOk()) {
Steven Moreland583685e2019-10-02 16:45:11 -0700335 return nullptr;
336 }
Alice Wang8578f132024-05-03 09:01:56 +0000337 return ret.get<Service::Tag::binder>();
Steven Moreland583685e2019-10-02 16:45:11 -0700338}
339
Parth Sanec7b58642024-08-07 10:31:15 +0000340status_t CppBackendShim::addService(const String16& name, const sp<IBinder>& service,
341 bool allowIsolated, int dumpsysPriority) {
Parth Sane56a04712024-04-22 14:21:07 +0000342 Status status = mUnifiedServiceManager->addService(String8(name).c_str(), service,
343 allowIsolated, dumpsysPriority);
Steven Moreland583685e2019-10-02 16:45:11 -0700344 return status.exceptionCode();
345}
346
Parth Sanec7b58642024-08-07 10:31:15 +0000347Vector<String16> CppBackendShim::listServices(int dumpsysPriority) {
Steven Moreland583685e2019-10-02 16:45:11 -0700348 std::vector<std::string> ret;
Parth Sane56a04712024-04-22 14:21:07 +0000349 if (!mUnifiedServiceManager->listServices(dumpsysPriority, &ret).isOk()) {
Steven Moreland583685e2019-10-02 16:45:11 -0700350 return {};
351 }
352
353 Vector<String16> res;
354 res.setCapacity(ret.size());
355 for (const std::string& name : ret) {
356 res.push(String16(name.c_str()));
357 }
358 return res;
359}
360
Parth Sanec7b58642024-08-07 10:31:15 +0000361sp<IBinder> CppBackendShim::waitForService(const String16& name16) {
Steven Moreland583685e2019-10-02 16:45:11 -0700362 class Waiter : public android::os::BnServiceCallback {
363 Status onRegistration(const std::string& /*name*/,
364 const sp<IBinder>& binder) override {
365 std::unique_lock<std::mutex> lock(mMutex);
366 mBinder = binder;
367 lock.unlock();
Jon Spivack9f503a42019-10-22 16:49:19 -0700368 // Flushing here helps ensure the service's ref count remains accurate
369 IPCThreadState::self()->flushCommands();
Steven Moreland583685e2019-10-02 16:45:11 -0700370 mCv.notify_one();
371 return Status::ok();
Yunfan Chen788e1c42018-03-29 16:52:09 +0900372 }
Steven Moreland583685e2019-10-02 16:45:11 -0700373 public:
374 sp<IBinder> mBinder;
375 std::mutex mMutex;
376 std::condition_variable mCv;
377 };
Yunfan Chen788e1c42018-03-29 16:52:09 +0900378
Jon Spivackfed6db42019-11-18 16:43:59 -0800379 // Simple RAII object to ensure a function call immediately before going out of scope
380 class Defer {
381 public:
Jiyong Park70072fd2020-11-13 17:19:14 +0900382 explicit Defer(std::function<void()>&& f) : mF(std::move(f)) {}
Jon Spivackfed6db42019-11-18 16:43:59 -0800383 ~Defer() { mF(); }
384 private:
385 std::function<void()> mF;
386 };
387
Steven Moreland583685e2019-10-02 16:45:11 -0700388 const std::string name = String8(name16).c_str();
Yunfan Chen788e1c42018-03-29 16:52:09 +0900389
Steven Moreland583685e2019-10-02 16:45:11 -0700390 sp<IBinder> out;
Yifan Hongf7760012021-06-04 16:04:42 -0700391 if (Status status = realGetService(name, &out); !status.isOk()) {
Steven Morelanda1d70172021-05-24 22:03:42 +0000392 ALOGW("Failed to getService in waitForService for %s: %s", name.c_str(),
393 status.toString8().c_str());
Elie Kheirallah27c26952022-09-07 21:45:26 +0000394 if (0 == ProcessState::self()->getThreadPoolMaxTotalThreadCount()) {
395 ALOGW("Got service, but may be racey because we could not wait efficiently for it. "
396 "Threadpool has 0 guaranteed threads. "
397 "Is the threadpool configured properly? "
398 "See ProcessState::startThreadPool and "
399 "ProcessState::setThreadPoolMaxThreadCount.");
400 }
Steven Moreland583685e2019-10-02 16:45:11 -0700401 return nullptr;
402 }
Jon Spivackfed6db42019-11-18 16:43:59 -0800403 if (out != nullptr) return out;
Steven Moreland583685e2019-10-02 16:45:11 -0700404
Steven Moreland1a3a8ef2021-04-02 02:52:46 +0000405 sp<Waiter> waiter = sp<Waiter>::make();
Parth Sane56a04712024-04-22 14:21:07 +0000406 if (Status status = mUnifiedServiceManager->registerForNotifications(name, waiter);
Steven Morelanda1d70172021-05-24 22:03:42 +0000407 !status.isOk()) {
408 ALOGW("Failed to registerForNotifications in waitForService for %s: %s", name.c_str(),
409 status.toString8().c_str());
Yi Kongfdd8da92018-06-07 17:52:27 -0700410 return nullptr;
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800411 }
Parth Sane56a04712024-04-22 14:21:07 +0000412 Defer unregister([&] { mUnifiedServiceManager->unregisterForNotifications(name, waiter); });
Brad Fitzpatrick702ea9d2010-06-18 13:07:53 -0700413
Steven Moreland583685e2019-10-02 16:45:11 -0700414 while(true) {
415 {
Steven Morelandf2677e22020-07-14 19:58:08 +0000416 // It would be really nice if we could read binder commands on this
417 // thread instead of needing a threadpool to be started, but for
418 // instance, if we call getAndExecuteCommand, it might be the case
419 // that another thread serves the callback, and we never get a
420 // command, so we hang indefinitely.
Steven Moreland583685e2019-10-02 16:45:11 -0700421 std::unique_lock<std::mutex> lock(waiter->mMutex);
Steven Moreland3d37ef22023-04-25 18:25:14 +0000422 waiter->mCv.wait_for(lock, 1s, [&] {
423 return waiter->mBinder != nullptr;
424 });
Steven Moreland583685e2019-10-02 16:45:11 -0700425 if (waiter->mBinder != nullptr) return waiter->mBinder;
Steven Moreland80e1e6d2019-06-21 12:35:59 -0700426 }
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800427
Steven Moreland3d37ef22023-04-25 18:25:14 +0000428 ALOGW("Waited one second for %s (is service started? Number of threads started in the "
Elie Kheirallah27c26952022-09-07 21:45:26 +0000429 "threadpool: %zu. Are binder threads started and available?)",
430 name.c_str(), ProcessState::self()->getThreadPoolMaxTotalThreadCount());
Steven Morelandf2677e22020-07-14 19:58:08 +0000431
Steven Moreland583685e2019-10-02 16:45:11 -0700432 // Handle race condition for lazy services. Here is what can happen:
433 // - the service dies (not processed by init yet).
434 // - sm processes death notification.
435 // - sm gets getService and calls init to start service.
436 // - init gets the start signal, but the service already appears
437 // started, so it does nothing.
438 // - init gets death signal, but doesn't know it needs to restart
439 // the service
440 // - we need to request service again to get it to start
Yifan Hongf7760012021-06-04 16:04:42 -0700441 if (Status status = realGetService(name, &out); !status.isOk()) {
Steven Morelanda1d70172021-05-24 22:03:42 +0000442 ALOGW("Failed to getService in waitForService on later try for %s: %s", name.c_str(),
443 status.toString8().c_str());
Steven Moreland1c47b582019-08-27 18:05:27 -0700444 return nullptr;
445 }
Jon Spivackfed6db42019-11-18 16:43:59 -0800446 if (out != nullptr) return out;
Steven Moreland1c47b582019-08-27 18:05:27 -0700447 }
Steven Moreland583685e2019-10-02 16:45:11 -0700448}
The Android Open Source Projectedbf3b62009-03-03 19:31:44 -0800449
Parth Sanec7b58642024-08-07 10:31:15 +0000450bool CppBackendShim::isDeclared(const String16& name) {
Steven Morelandb82b8f82019-10-28 10:52:34 -0700451 bool declared;
Parth Sane56a04712024-04-22 14:21:07 +0000452 if (Status status = mUnifiedServiceManager->isDeclared(String8(name).c_str(), &declared);
Steven Morelanda1d70172021-05-24 22:03:42 +0000453 !status.isOk()) {
Vova Sharaienkoca71b452022-12-08 01:38:29 +0000454 ALOGW("Failed to get isDeclared for %s: %s", String8(name).c_str(),
Steven Morelanda1d70172021-05-24 22:03:42 +0000455 status.toString8().c_str());
Steven Morelandb82b8f82019-10-28 10:52:34 -0700456 return false;
457 }
458 return declared;
459}
460
Parth Sanec7b58642024-08-07 10:31:15 +0000461Vector<String16> CppBackendShim::getDeclaredInstances(const String16& interface) {
Steven Moreland2e293aa2020-09-23 00:25:16 +0000462 std::vector<std::string> out;
Steven Morelanda1d70172021-05-24 22:03:42 +0000463 if (Status status =
Parth Sane56a04712024-04-22 14:21:07 +0000464 mUnifiedServiceManager->getDeclaredInstances(String8(interface).c_str(), &out);
Steven Morelanda1d70172021-05-24 22:03:42 +0000465 !status.isOk()) {
466 ALOGW("Failed to getDeclaredInstances for %s: %s", String8(interface).c_str(),
467 status.toString8().c_str());
Steven Moreland2e293aa2020-09-23 00:25:16 +0000468 return {};
469 }
470
471 Vector<String16> res;
472 res.setCapacity(out.size());
473 for (const std::string& instance : out) {
474 res.push(String16(instance.c_str()));
475 }
476 return res;
477}
478
Parth Sanec7b58642024-08-07 10:31:15 +0000479std::optional<String16> CppBackendShim::updatableViaApex(const String16& name) {
Steven Morelandedd4e072021-04-21 00:27:29 +0000480 std::optional<std::string> declared;
Parth Sane56a04712024-04-22 14:21:07 +0000481 if (Status status = mUnifiedServiceManager->updatableViaApex(String8(name).c_str(), &declared);
Steven Morelanda1d70172021-05-24 22:03:42 +0000482 !status.isOk()) {
483 ALOGW("Failed to get updatableViaApex for %s: %s", String8(name).c_str(),
484 status.toString8().c_str());
Steven Morelandedd4e072021-04-21 00:27:29 +0000485 return std::nullopt;
486 }
487 return declared ? std::optional<String16>(String16(declared.value().c_str())) : std::nullopt;
488}
489
Parth Sanec7b58642024-08-07 10:31:15 +0000490Vector<String16> CppBackendShim::getUpdatableNames(const String16& apexName) {
Jooyung Han76944fe2022-10-25 17:02:45 +0900491 std::vector<std::string> out;
Parth Sane56a04712024-04-22 14:21:07 +0000492 if (Status status = mUnifiedServiceManager->getUpdatableNames(String8(apexName).c_str(), &out);
Jooyung Han76944fe2022-10-25 17:02:45 +0900493 !status.isOk()) {
494 ALOGW("Failed to getUpdatableNames for %s: %s", String8(apexName).c_str(),
495 status.toString8().c_str());
496 return {};
497 }
498
499 Vector<String16> res;
500 res.setCapacity(out.size());
501 for (const std::string& instance : out) {
502 res.push(String16(instance.c_str()));
503 }
504 return res;
505}
506
Parth Sanec7b58642024-08-07 10:31:15 +0000507std::optional<IServiceManager::ConnectionInfo> CppBackendShim::getConnectionInfo(
Devin Moore5e4c2f12021-09-09 22:36:33 +0000508 const String16& name) {
509 std::optional<os::ConnectionInfo> connectionInfo;
510 if (Status status =
Parth Sane56a04712024-04-22 14:21:07 +0000511 mUnifiedServiceManager->getConnectionInfo(String8(name).c_str(), &connectionInfo);
Devin Moore5e4c2f12021-09-09 22:36:33 +0000512 !status.isOk()) {
513 ALOGW("Failed to get ConnectionInfo for %s: %s", String8(name).c_str(),
514 status.toString8().c_str());
515 }
516 return connectionInfo.has_value()
517 ? std::make_optional<IServiceManager::ConnectionInfo>(
518 {connectionInfo->ipAddress, static_cast<unsigned int>(connectionInfo->port)})
519 : std::nullopt;
520}
521
Parth Sanec7b58642024-08-07 10:31:15 +0000522status_t CppBackendShim::registerForNotifications(const String16& name,
523 const sp<AidlRegistrationCallback>& cb) {
Jayant Chowdhary30700942022-01-31 14:12:40 -0800524 if (cb == nullptr) {
525 ALOGE("%s: null cb passed", __FUNCTION__);
526 return BAD_VALUE;
527 }
528 std::string nameStr = String8(name).c_str();
529 sp<RegistrationWaiter> registrationWaiter = sp<RegistrationWaiter>::make(cb);
530 std::lock_guard<std::mutex> lock(mNameToRegistrationLock);
531 if (Status status =
Parth Sane56a04712024-04-22 14:21:07 +0000532 mUnifiedServiceManager->registerForNotifications(nameStr, registrationWaiter);
Jayant Chowdhary30700942022-01-31 14:12:40 -0800533 !status.isOk()) {
534 ALOGW("Failed to registerForNotifications for %s: %s", nameStr.c_str(),
535 status.toString8().c_str());
536 return UNKNOWN_ERROR;
537 }
538 mNameToRegistrationCallback[nameStr].push_back(std::make_pair(cb, registrationWaiter));
539 return OK;
540}
541
Parth Sanec7b58642024-08-07 10:31:15 +0000542void CppBackendShim::removeRegistrationCallbackLocked(const sp<AidlRegistrationCallback>& cb,
543 ServiceCallbackMap::iterator* it,
544 sp<RegistrationWaiter>* waiter) {
Jayant Chowdhary30700942022-01-31 14:12:40 -0800545 std::vector<LocalRegistrationAndWaiter>& localRegistrationAndWaiters = (*it)->second;
546 for (auto lit = localRegistrationAndWaiters.begin();
547 lit != localRegistrationAndWaiters.end();) {
548 if (lit->first == cb) {
549 if (waiter) {
550 *waiter = lit->second;
551 }
552 lit = localRegistrationAndWaiters.erase(lit);
553 } else {
554 ++lit;
555 }
556 }
557
558 if (localRegistrationAndWaiters.empty()) {
559 mNameToRegistrationCallback.erase(*it);
560 }
561}
562
Parth Sanec7b58642024-08-07 10:31:15 +0000563status_t CppBackendShim::unregisterForNotifications(const String16& name,
564 const sp<AidlRegistrationCallback>& cb) {
Jayant Chowdhary30700942022-01-31 14:12:40 -0800565 if (cb == nullptr) {
566 ALOGE("%s: null cb passed", __FUNCTION__);
567 return BAD_VALUE;
568 }
569 std::string nameStr = String8(name).c_str();
570 std::lock_guard<std::mutex> lock(mNameToRegistrationLock);
571 auto it = mNameToRegistrationCallback.find(nameStr);
572 sp<RegistrationWaiter> registrationWaiter;
573 if (it != mNameToRegistrationCallback.end()) {
574 removeRegistrationCallbackLocked(cb, &it, &registrationWaiter);
575 } else {
576 ALOGE("%s no callback registered for notifications on %s", __FUNCTION__, nameStr.c_str());
577 return BAD_VALUE;
578 }
579 if (registrationWaiter == nullptr) {
580 ALOGE("%s Callback passed wasn't used to register for notifications", __FUNCTION__);
581 return BAD_VALUE;
582 }
Parth Sane56a04712024-04-22 14:21:07 +0000583 if (Status status = mUnifiedServiceManager->unregisterForNotifications(String8(name).c_str(),
Jayant Chowdhary30700942022-01-31 14:12:40 -0800584 registrationWaiter);
585 !status.isOk()) {
586 ALOGW("Failed to get service manager to unregisterForNotifications for %s: %s",
587 String8(name).c_str(), status.toString8().c_str());
588 return UNKNOWN_ERROR;
589 }
590 return OK;
591}
592
Parth Sanec7b58642024-08-07 10:31:15 +0000593std::vector<IServiceManager::ServiceDebugInfo> CppBackendShim::getServiceDebugInfo() {
Jayant Chowdharya0a8eb22022-05-20 03:30:09 +0000594 std::vector<os::ServiceDebugInfo> serviceDebugInfos;
595 std::vector<IServiceManager::ServiceDebugInfo> ret;
Parth Sane56a04712024-04-22 14:21:07 +0000596 if (Status status = mUnifiedServiceManager->getServiceDebugInfo(&serviceDebugInfos);
Jayant Chowdharya0a8eb22022-05-20 03:30:09 +0000597 !status.isOk()) {
598 ALOGW("%s Failed to get ServiceDebugInfo", __FUNCTION__);
599 return ret;
600 }
601 for (const auto& serviceDebugInfo : serviceDebugInfos) {
602 IServiceManager::ServiceDebugInfo retInfo;
603 retInfo.pid = serviceDebugInfo.debugPid;
604 retInfo.name = serviceDebugInfo.name;
605 ret.emplace_back(retInfo);
606 }
607 return ret;
608}
609
Yifan Hongf7760012021-06-04 16:04:42 -0700610#ifndef __ANDROID__
Parth Sanec7b58642024-08-07 10:31:15 +0000611// CppBackendShim for host. Implements the old libbinder android::IServiceManager API.
Yifan Hongf7760012021-06-04 16:04:42 -0700612// The internal implementation of the AIDL interface android::os::IServiceManager calls into
613// on-device service manager.
Parth Sanec7b58642024-08-07 10:31:15 +0000614class CppServiceManagerHostShim : public CppBackendShim {
Yifan Hongf7760012021-06-04 16:04:42 -0700615public:
Parth Sanec7b58642024-08-07 10:31:15 +0000616 CppServiceManagerHostShim(const sp<AidlServiceManager>& impl,
617 const RpcDelegateServiceManagerOptions& options)
618 : CppBackendShim(sp<BackendUnifiedServiceManager>::make(impl)), mOptions(options) {}
619 // CppBackendShim::getService is based on checkService, so no need to override it.
Yifan Hongf7760012021-06-04 16:04:42 -0700620 sp<IBinder> checkService(const String16& name) const override {
Yifan Hong5a05ef72021-10-08 17:33:47 -0700621 return getDeviceService({String8(name).c_str()}, mOptions);
Yifan Hongf7760012021-06-04 16:04:42 -0700622 }
623
624protected:
Parth Sanec7b58642024-08-07 10:31:15 +0000625 // Override realGetService for CppBackendShim::waitForService.
Tomasz Wasilczyke97f3a82024-04-30 10:37:32 -0700626 Status realGetService(const std::string& name, sp<IBinder>* _aidl_return) override {
Yifan Hong5a05ef72021-10-08 17:33:47 -0700627 *_aidl_return = getDeviceService({"-g", name}, mOptions);
Yifan Hongf7760012021-06-04 16:04:42 -0700628 return Status::ok();
629 }
Yifan Hong5a05ef72021-10-08 17:33:47 -0700630
631private:
632 RpcDelegateServiceManagerOptions mOptions;
Yifan Hongf7760012021-06-04 16:04:42 -0700633};
Yifan Hong5a05ef72021-10-08 17:33:47 -0700634sp<IServiceManager> createRpcDelegateServiceManager(
635 const RpcDelegateServiceManagerOptions& options) {
636 auto binder = getDeviceService({"manager"}, options);
Yifan Hongf7760012021-06-04 16:04:42 -0700637 if (binder == nullptr) {
638 ALOGE("getDeviceService(\"manager\") returns null");
639 return nullptr;
640 }
641 auto interface = AidlServiceManager::asInterface(binder);
642 if (interface == nullptr) {
643 ALOGE("getDeviceService(\"manager\") returns non service manager");
644 return nullptr;
645 }
Parth Sanec7b58642024-08-07 10:31:15 +0000646 return sp<CppServiceManagerHostShim>::make(interface, options);
Yifan Hongf7760012021-06-04 16:04:42 -0700647}
648#endif
649
Steven Moreland61ff8492019-09-26 16:05:45 -0700650} // namespace android