| /* |
| * Copyright (C) 2017 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. |
| */ |
| |
| #include "ListCommand.h" |
| |
| #include <getopt.h> |
| |
| #include <fstream> |
| #include <iomanip> |
| #include <iostream> |
| #include <map> |
| #include <sstream> |
| #include <regex> |
| |
| #include <android-base/parseint.h> |
| #include <android/hidl/manager/1.0/IServiceManager.h> |
| #include <hidl-util/FQName.h> |
| #include <private/android_filesystem_config.h> |
| #include <sys/stat.h> |
| #include <vintf/HalManifest.h> |
| #include <vintf/parse_xml.h> |
| |
| #include "Lshal.h" |
| #include "PipeRelay.h" |
| #include "Timeout.h" |
| #include "utils.h" |
| |
| using ::android::hardware::hidl_string; |
| using ::android::hidl::manager::V1_0::IServiceManager; |
| |
| namespace android { |
| namespace lshal { |
| |
| ListCommand::ListCommand(Lshal &lshal) : mLshal(lshal), mErr(lshal.err()), mOut(lshal.out()) { |
| } |
| |
| std::string getCmdline(pid_t pid) { |
| std::ifstream ifs("/proc/" + std::to_string(pid) + "/cmdline"); |
| std::string cmdline; |
| if (!ifs.is_open()) { |
| return ""; |
| } |
| ifs >> cmdline; |
| return cmdline; |
| } |
| |
| const std::string &ListCommand::getCmdline(pid_t pid) { |
| auto pair = mCmdlines.find(pid); |
| if (pair != mCmdlines.end()) { |
| return pair->second; |
| } |
| mCmdlines[pid] = ::android::lshal::getCmdline(pid); |
| return mCmdlines[pid]; |
| } |
| |
| void ListCommand::removeDeadProcesses(Pids *pids) { |
| static const pid_t myPid = getpid(); |
| pids->erase(std::remove_if(pids->begin(), pids->end(), [this](auto pid) { |
| return pid == myPid || this->getCmdline(pid).empty(); |
| }), pids->end()); |
| } |
| |
| bool scanBinderContext(pid_t pid, |
| const std::string &contextName, |
| std::function<void(const std::string&)> eachLine) { |
| std::ifstream ifs("/d/binder/proc/" + std::to_string(pid)); |
| if (!ifs.is_open()) { |
| return false; |
| } |
| |
| static const std::regex kContextLine("^context (\\w+)$"); |
| |
| bool isDesiredContext = false; |
| std::string line; |
| std::smatch match; |
| while(getline(ifs, line)) { |
| if (std::regex_search(line, match, kContextLine)) { |
| isDesiredContext = match.str(1) == contextName; |
| continue; |
| } |
| |
| if (!isDesiredContext) { |
| continue; |
| } |
| |
| eachLine(line); |
| } |
| return true; |
| } |
| |
| bool ListCommand::getPidInfo( |
| pid_t serverPid, PidInfo *pidInfo) const { |
| static const std::regex kReferencePrefix("^\\s*node \\d+:\\s+u([0-9a-f]+)\\s+c([0-9a-f]+)\\s+"); |
| static const std::regex kThreadPrefix("^\\s*thread \\d+:\\s+l\\s+(\\d)(\\d)"); |
| |
| std::smatch match; |
| return scanBinderContext(serverPid, "hwbinder", [&](const std::string& line) { |
| if (std::regex_search(line, match, kReferencePrefix)) { |
| const std::string &ptrString = "0x" + match.str(2); // use number after c |
| uint64_t ptr; |
| if (!::android::base::ParseUint(ptrString.c_str(), &ptr)) { |
| // Should not reach here, but just be tolerant. |
| mErr << "Could not parse number " << ptrString << std::endl; |
| return; |
| } |
| const std::string proc = " proc "; |
| auto pos = line.rfind(proc); |
| if (pos != std::string::npos) { |
| for (const std::string &pidStr : split(line.substr(pos + proc.size()), ' ')) { |
| int32_t pid; |
| if (!::android::base::ParseInt(pidStr, &pid)) { |
| mErr << "Could not parse number " << pidStr << std::endl; |
| return; |
| } |
| pidInfo->refPids[ptr].push_back(pid); |
| } |
| } |
| |
| return; |
| } |
| |
| if (std::regex_search(line, match, kThreadPrefix)) { |
| // "1" is waiting in binder driver |
| // "2" is poll. It's impossible to tell if these are in use. |
| // and HIDL default code doesn't use it. |
| bool isInUse = match.str(1) != "1"; |
| // "0" is a thread that has called into binder |
| // "1" is looper thread |
| // "2" is main looper thread |
| bool isHwbinderThread = match.str(2) != "0"; |
| |
| if (!isHwbinderThread) { |
| return; |
| } |
| |
| if (isInUse) { |
| pidInfo->threadUsage++; |
| } |
| |
| pidInfo->threadCount++; |
| return; |
| } |
| |
| // not reference or thread line |
| return; |
| }); |
| } |
| |
| // Must process hwbinder services first, then passthrough services. |
| void ListCommand::forEachTable(const std::function<void(Table &)> &f) { |
| f(mServicesTable); |
| f(mPassthroughRefTable); |
| f(mImplementationsTable); |
| } |
| void ListCommand::forEachTable(const std::function<void(const Table &)> &f) const { |
| f(mServicesTable); |
| f(mPassthroughRefTable); |
| f(mImplementationsTable); |
| } |
| |
| void ListCommand::postprocess() { |
| forEachTable([this](Table &table) { |
| if (mSortColumn) { |
| std::sort(table.begin(), table.end(), mSortColumn); |
| } |
| for (TableEntry &entry : table) { |
| entry.serverCmdline = getCmdline(entry.serverPid); |
| removeDeadProcesses(&entry.clientPids); |
| for (auto pid : entry.clientPids) { |
| entry.clientCmdlines.push_back(this->getCmdline(pid)); |
| } |
| } |
| }); |
| // use a double for loop here because lshal doesn't care about efficiency. |
| for (TableEntry &packageEntry : mImplementationsTable) { |
| std::string packageName = packageEntry.interfaceName; |
| FQName fqPackageName{packageName.substr(0, packageName.find("::"))}; |
| if (!fqPackageName.isValid()) { |
| continue; |
| } |
| for (TableEntry &interfaceEntry : mPassthroughRefTable) { |
| if (interfaceEntry.arch != ARCH_UNKNOWN) { |
| continue; |
| } |
| FQName interfaceName{splitFirst(interfaceEntry.interfaceName, '/').first}; |
| if (!interfaceName.isValid()) { |
| continue; |
| } |
| if (interfaceName.getPackageAndVersion() == fqPackageName) { |
| interfaceEntry.arch = packageEntry.arch; |
| } |
| } |
| } |
| } |
| |
| void ListCommand::printLine( |
| const std::string &interfaceName, |
| const std::string &transport, |
| const std::string &arch, |
| const std::string &threadUsage, |
| const std::string &server, |
| const std::string &serverCmdline, |
| const std::string &address, |
| const std::string &clients, |
| const std::string &clientCmdlines) const { |
| if (mSelectedColumns & ENABLE_INTERFACE_NAME) |
| mOut << std::setw(80) << interfaceName << "\t"; |
| if (mSelectedColumns & ENABLE_TRANSPORT) |
| mOut << std::setw(10) << transport << "\t"; |
| if (mSelectedColumns & ENABLE_ARCH) |
| mOut << std::setw(5) << arch << "\t"; |
| if (mSelectedColumns & ENABLE_THREADS) { |
| mOut << std::setw(8) << threadUsage << "\t"; |
| } |
| if (mSelectedColumns & ENABLE_SERVER_PID) { |
| if (mEnableCmdlines) { |
| mOut << std::setw(15) << serverCmdline << "\t"; |
| } else { |
| mOut << std::setw(5) << server << "\t"; |
| } |
| } |
| if (mSelectedColumns & ENABLE_SERVER_ADDR) |
| mOut << std::setw(16) << address << "\t"; |
| if (mSelectedColumns & ENABLE_CLIENT_PIDS) { |
| if (mEnableCmdlines) { |
| mOut << std::setw(0) << clientCmdlines; |
| } else { |
| mOut << std::setw(0) << clients; |
| } |
| } |
| mOut << std::endl; |
| } |
| |
| static inline bool findAndBumpVersion(vintf::ManifestHal* hal, const vintf::Version& version) { |
| for (vintf::Version& v : hal->versions) { |
| if (v.majorVer == version.majorVer) { |
| v.minorVer = std::max(v.minorVer, version.minorVer); |
| return true; |
| } |
| } |
| return false; |
| } |
| |
| void ListCommand::dumpVintf() const { |
| using vintf::operator|=; |
| mOut << "<!-- " << std::endl |
| << " This is a skeleton device manifest. Notes: " << std::endl |
| << " 1. android.hidl.*, android.frameworks.*, android.system.* are not included." << std::endl |
| << " 2. If a HAL is supported in both hwbinder and passthrough transport, " << std::endl |
| << " only hwbinder is shown." << std::endl |
| << " 3. It is likely that HALs in passthrough transport does not have" << std::endl |
| << " <interface> declared; users will have to write them by hand." << std::endl |
| << " 4. A HAL with lower minor version can be overridden by a HAL with" << std::endl |
| << " higher minor version if they have the same name and major version." << std::endl |
| << " 5. sepolicy version is set to 0.0. It is recommended that the entry" << std::endl |
| << " is removed from the manifest file and written by assemble_vintf" << std::endl |
| << " at build time." << std::endl |
| << "-->" << std::endl; |
| |
| vintf::HalManifest manifest; |
| forEachTable([this, &manifest] (const Table &table) { |
| for (const TableEntry &entry : table) { |
| |
| std::string fqInstanceName = entry.interfaceName; |
| |
| if (&table == &mImplementationsTable) { |
| // Quick hack to work around *'s |
| replaceAll(&fqInstanceName, '*', 'D'); |
| } |
| auto splittedFqInstanceName = splitFirst(fqInstanceName, '/'); |
| FQName fqName(splittedFqInstanceName.first); |
| if (!fqName.isValid()) { |
| mErr << "Warning: '" << splittedFqInstanceName.first |
| << "' is not a valid FQName." << std::endl; |
| continue; |
| } |
| // Strip out system libs. |
| if (fqName.inPackage("android.hidl") || |
| fqName.inPackage("android.frameworks") || |
| fqName.inPackage("android.system")) { |
| continue; |
| } |
| std::string interfaceName = |
| &table == &mImplementationsTable ? "" : fqName.name(); |
| std::string instanceName = |
| &table == &mImplementationsTable ? "" : splittedFqInstanceName.second; |
| |
| vintf::Version version{fqName.getPackageMajorVersion(), |
| fqName.getPackageMinorVersion()}; |
| vintf::Transport transport; |
| vintf::Arch arch; |
| if (entry.transport == "hwbinder") { |
| transport = vintf::Transport::HWBINDER; |
| arch = vintf::Arch::ARCH_EMPTY; |
| } else if (entry.transport == "passthrough") { |
| transport = vintf::Transport::PASSTHROUGH; |
| switch (entry.arch) { |
| case lshal::ARCH32: |
| arch = vintf::Arch::ARCH_32; break; |
| case lshal::ARCH64: |
| arch = vintf::Arch::ARCH_64; break; |
| case lshal::ARCH_BOTH: |
| arch = vintf::Arch::ARCH_32_64; break; |
| case lshal::ARCH_UNKNOWN: // fallthrough |
| default: |
| mErr << "Warning: '" << fqName.package() |
| << "' doesn't have bitness info, assuming 32+64." << std::endl; |
| arch = vintf::Arch::ARCH_32_64; |
| } |
| } else { |
| mErr << "Warning: '" << entry.transport << "' is not a valid transport." << std::endl; |
| continue; |
| } |
| |
| bool done = false; |
| for (vintf::ManifestHal *hal : manifest.getHals(fqName.package())) { |
| if (hal->transport() != transport) { |
| if (transport != vintf::Transport::PASSTHROUGH) { |
| mErr << "Fatal: should not reach here. Generated result may be wrong for '" |
| << hal->name << "'." |
| << std::endl; |
| } |
| done = true; |
| break; |
| } |
| if (findAndBumpVersion(hal, version)) { |
| if (&table != &mImplementationsTable) { |
| hal->interfaces[interfaceName].name = interfaceName; |
| hal->interfaces[interfaceName].instances.insert(instanceName); |
| } |
| hal->transportArch.arch |= arch; |
| done = true; |
| break; |
| } |
| } |
| if (done) { |
| continue; // to next TableEntry |
| } |
| decltype(vintf::ManifestHal::interfaces) interfaces; |
| if (&table != &mImplementationsTable) { |
| interfaces[interfaceName].name = interfaceName; |
| interfaces[interfaceName].instances.insert(instanceName); |
| } |
| if (!manifest.add(vintf::ManifestHal{ |
| .format = vintf::HalFormat::HIDL, |
| .name = fqName.package(), |
| .versions = {version}, |
| .transportArch = {transport, arch}, |
| .interfaces = interfaces})) { |
| mErr << "Warning: cannot add hal '" << fqInstanceName << "'" << std::endl; |
| } |
| } |
| }); |
| mOut << vintf::gHalManifestConverter(manifest); |
| } |
| |
| static const std::string &getArchString(Architecture arch) { |
| static const std::string sStr64 = "64"; |
| static const std::string sStr32 = "32"; |
| static const std::string sStrBoth = "32+64"; |
| static const std::string sStrUnknown = ""; |
| switch (arch) { |
| case ARCH64: |
| return sStr64; |
| case ARCH32: |
| return sStr32; |
| case ARCH_BOTH: |
| return sStrBoth; |
| case ARCH_UNKNOWN: // fall through |
| default: |
| return sStrUnknown; |
| } |
| } |
| |
| static Architecture fromBaseArchitecture(::android::hidl::base::V1_0::DebugInfo::Architecture a) { |
| switch (a) { |
| case ::android::hidl::base::V1_0::DebugInfo::Architecture::IS_64BIT: |
| return ARCH64; |
| case ::android::hidl::base::V1_0::DebugInfo::Architecture::IS_32BIT: |
| return ARCH32; |
| case ::android::hidl::base::V1_0::DebugInfo::Architecture::UNKNOWN: // fallthrough |
| default: |
| return ARCH_UNKNOWN; |
| } |
| } |
| |
| void ListCommand::dumpTable() { |
| mServicesTable.description = |
| "All binderized services (registered services through hwservicemanager)"; |
| mPassthroughRefTable.description = |
| "All interfaces that getService() has ever return as a passthrough interface;\n" |
| "PIDs / processes shown below might be inaccurate because the process\n" |
| "might have relinquished the interface or might have died.\n" |
| "The Server / Server CMD column can be ignored.\n" |
| "The Clients / Clients CMD column shows all process that have ever dlopen'ed \n" |
| "the library and successfully fetched the passthrough implementation."; |
| mImplementationsTable.description = |
| "All available passthrough implementations (all -impl.so files)"; |
| forEachTable([this] (const Table &table) { |
| if (!mNeat) { |
| mOut << table.description << std::endl; |
| } |
| mOut << std::left; |
| if (!mNeat) { |
| printLine("Interface", "Transport", "Arch", "Thread Use", "Server", |
| "Server CMD", "PTR", "Clients", "Clients CMD"); |
| } |
| |
| for (const auto &entry : table) { |
| printLine(entry.interfaceName, |
| entry.transport, |
| getArchString(entry.arch), |
| entry.getThreadUsage(), |
| entry.serverPid == NO_PID ? "N/A" : std::to_string(entry.serverPid), |
| entry.serverCmdline, |
| entry.serverObjectAddress == NO_PTR ? "N/A" : toHexString(entry.serverObjectAddress), |
| join(entry.clientPids, " "), |
| join(entry.clientCmdlines, ";")); |
| |
| // We're only interested in dumping debug info for already |
| // instantiated services. There's little value in dumping the |
| // debug info for a service we create on the fly, so we only operate |
| // on the "mServicesTable". |
| if (mEmitDebugInfo && &table == &mServicesTable) { |
| auto pair = splitFirst(entry.interfaceName, '/'); |
| mLshal.emitDebugInfo(pair.first, pair.second, {}, mOut.buf(), |
| NullableOStream<std::ostream>(nullptr)); |
| } |
| } |
| if (!mNeat) { |
| mOut << std::endl; |
| } |
| }); |
| |
| } |
| |
| void ListCommand::dump() { |
| if (mVintf) { |
| dumpVintf(); |
| if (!!mFileOutput) { |
| mFileOutput.buf().close(); |
| delete &mFileOutput.buf(); |
| mFileOutput = nullptr; |
| } |
| mOut = std::cout; |
| } else { |
| dumpTable(); |
| } |
| } |
| |
| void ListCommand::putEntry(TableEntrySource source, TableEntry &&entry) { |
| Table *table = nullptr; |
| switch (source) { |
| case HWSERVICEMANAGER_LIST : |
| table = &mServicesTable; break; |
| case PTSERVICEMANAGER_REG_CLIENT : |
| table = &mPassthroughRefTable; break; |
| case LIST_DLLIB : |
| table = &mImplementationsTable; break; |
| default: |
| mErr << "Error: Unknown source of entry " << source << std::endl; |
| } |
| if (table) { |
| table->entries.push_back(std::forward<TableEntry>(entry)); |
| } |
| } |
| |
| Status ListCommand::fetchAllLibraries(const sp<IServiceManager> &manager) { |
| using namespace ::android::hardware; |
| using namespace ::android::hidl::manager::V1_0; |
| using namespace ::android::hidl::base::V1_0; |
| using std::literals::chrono_literals::operator""s; |
| auto ret = timeoutIPC(2s, manager, &IServiceManager::debugDump, [&] (const auto &infos) { |
| std::map<std::string, TableEntry> entries; |
| for (const auto &info : infos) { |
| std::string interfaceName = std::string{info.interfaceName.c_str()} + "/" + |
| std::string{info.instanceName.c_str()}; |
| entries.emplace(interfaceName, TableEntry{ |
| .interfaceName = interfaceName, |
| .transport = "passthrough", |
| .serverPid = NO_PID, |
| .serverObjectAddress = NO_PTR, |
| .clientPids = info.clientPids, |
| .arch = ARCH_UNKNOWN |
| }).first->second.arch |= fromBaseArchitecture(info.arch); |
| } |
| for (auto &&pair : entries) { |
| putEntry(LIST_DLLIB, std::move(pair.second)); |
| } |
| }); |
| if (!ret.isOk()) { |
| mErr << "Error: Failed to call list on getPassthroughServiceManager(): " |
| << ret.description() << std::endl; |
| return DUMP_ALL_LIBS_ERROR; |
| } |
| return OK; |
| } |
| |
| Status ListCommand::fetchPassthrough(const sp<IServiceManager> &manager) { |
| using namespace ::android::hardware; |
| using namespace ::android::hardware::details; |
| using namespace ::android::hidl::manager::V1_0; |
| using namespace ::android::hidl::base::V1_0; |
| auto ret = timeoutIPC(manager, &IServiceManager::debugDump, [&] (const auto &infos) { |
| for (const auto &info : infos) { |
| if (info.clientPids.size() <= 0) { |
| continue; |
| } |
| putEntry(PTSERVICEMANAGER_REG_CLIENT, { |
| .interfaceName = |
| std::string{info.interfaceName.c_str()} + "/" + |
| std::string{info.instanceName.c_str()}, |
| .transport = "passthrough", |
| .serverPid = info.clientPids.size() == 1 ? info.clientPids[0] : NO_PID, |
| .serverObjectAddress = NO_PTR, |
| .clientPids = info.clientPids, |
| .arch = fromBaseArchitecture(info.arch) |
| }); |
| } |
| }); |
| if (!ret.isOk()) { |
| mErr << "Error: Failed to call debugDump on defaultServiceManager(): " |
| << ret.description() << std::endl; |
| return DUMP_PASSTHROUGH_ERROR; |
| } |
| return OK; |
| } |
| |
| Status ListCommand::fetchBinderized(const sp<IServiceManager> &manager) { |
| using namespace ::std; |
| using namespace ::android::hardware; |
| using namespace ::android::hidl::manager::V1_0; |
| using namespace ::android::hidl::base::V1_0; |
| const std::string mode = "hwbinder"; |
| |
| hidl_vec<hidl_string> fqInstanceNames; |
| // copying out for timeoutIPC |
| auto listRet = timeoutIPC(manager, &IServiceManager::list, [&] (const auto &names) { |
| fqInstanceNames = names; |
| }); |
| if (!listRet.isOk()) { |
| mErr << "Error: Failed to list services for " << mode << ": " |
| << listRet.description() << std::endl; |
| return DUMP_BINDERIZED_ERROR; |
| } |
| |
| Status status = OK; |
| // server pid, .ptr value of binder object, child pids |
| std::map<std::string, DebugInfo> allDebugInfos; |
| std::map<pid_t, PidInfo> allPids; |
| for (const auto &fqInstanceName : fqInstanceNames) { |
| const auto pair = splitFirst(fqInstanceName, '/'); |
| const auto &serviceName = pair.first; |
| const auto &instanceName = pair.second; |
| auto getRet = timeoutIPC(manager, &IServiceManager::get, serviceName, instanceName); |
| if (!getRet.isOk()) { |
| mErr << "Warning: Skipping \"" << fqInstanceName << "\": " |
| << "cannot be fetched from service manager:" |
| << getRet.description() << std::endl; |
| status |= DUMP_BINDERIZED_ERROR; |
| continue; |
| } |
| sp<IBase> service = getRet; |
| if (service == nullptr) { |
| mErr << "Warning: Skipping \"" << fqInstanceName << "\": " |
| << "cannot be fetched from service manager (null)" |
| << std::endl; |
| status |= DUMP_BINDERIZED_ERROR; |
| continue; |
| } |
| auto debugRet = timeoutIPC(service, &IBase::getDebugInfo, [&] (const auto &debugInfo) { |
| allDebugInfos[fqInstanceName] = debugInfo; |
| if (debugInfo.pid >= 0) { |
| allPids[static_cast<pid_t>(debugInfo.pid)] = PidInfo(); |
| } |
| }); |
| if (!debugRet.isOk()) { |
| mErr << "Warning: Skipping \"" << fqInstanceName << "\": " |
| << "debugging information cannot be retrieved:" |
| << debugRet.description() << std::endl; |
| status |= DUMP_BINDERIZED_ERROR; |
| } |
| } |
| |
| for (auto &pair : allPids) { |
| pid_t serverPid = pair.first; |
| if (!getPidInfo(serverPid, &allPids[serverPid])) { |
| mErr << "Warning: no information for PID " << serverPid |
| << ", are you root?" << std::endl; |
| status |= DUMP_BINDERIZED_ERROR; |
| } |
| } |
| for (const auto &fqInstanceName : fqInstanceNames) { |
| auto it = allDebugInfos.find(fqInstanceName); |
| if (it == allDebugInfos.end()) { |
| putEntry(HWSERVICEMANAGER_LIST, { |
| .interfaceName = fqInstanceName, |
| .transport = mode, |
| .serverPid = NO_PID, |
| .serverObjectAddress = NO_PTR, |
| .clientPids = {}, |
| .threadUsage = 0, |
| .threadCount = 0, |
| .arch = ARCH_UNKNOWN |
| }); |
| continue; |
| } |
| const DebugInfo &info = it->second; |
| bool writePidInfo = info.pid != NO_PID && info.ptr != NO_PTR; |
| |
| putEntry(HWSERVICEMANAGER_LIST, { |
| .interfaceName = fqInstanceName, |
| .transport = mode, |
| .serverPid = info.pid, |
| .serverObjectAddress = info.ptr, |
| .clientPids = writePidInfo ? allPids[info.pid].refPids[info.ptr] : Pids{}, |
| .threadUsage = writePidInfo ? allPids[info.pid].threadUsage : 0, |
| .threadCount = writePidInfo ? allPids[info.pid].threadCount : 0, |
| .arch = fromBaseArchitecture(info.arch), |
| }); |
| } |
| return status; |
| } |
| |
| Status ListCommand::fetch() { |
| Status status = OK; |
| auto bManager = mLshal.serviceManager(); |
| if (bManager == nullptr) { |
| mErr << "Failed to get defaultServiceManager()!" << std::endl; |
| status |= NO_BINDERIZED_MANAGER; |
| } else { |
| status |= fetchBinderized(bManager); |
| // Passthrough PIDs are registered to the binderized manager as well. |
| status |= fetchPassthrough(bManager); |
| } |
| |
| auto pManager = mLshal.passthroughManager(); |
| if (pManager == nullptr) { |
| mErr << "Failed to get getPassthroughServiceManager()!" << std::endl; |
| status |= NO_PASSTHROUGH_MANAGER; |
| } else { |
| status |= fetchAllLibraries(pManager); |
| } |
| return status; |
| } |
| |
| Status ListCommand::parseArgs(const std::string &command, const Arg &arg) { |
| static struct option longOptions[] = { |
| // long options with short alternatives |
| {"help", no_argument, 0, 'h' }, |
| {"interface", no_argument, 0, 'i' }, |
| {"transport", no_argument, 0, 't' }, |
| {"arch", no_argument, 0, 'r' }, |
| {"pid", no_argument, 0, 'p' }, |
| {"address", no_argument, 0, 'a' }, |
| {"clients", no_argument, 0, 'c' }, |
| {"threads", no_argument, 0, 'e' }, |
| {"cmdline", no_argument, 0, 'm' }, |
| {"debug", optional_argument, 0, 'd' }, |
| |
| // long options without short alternatives |
| {"sort", required_argument, 0, 's' }, |
| {"init-vintf",optional_argument, 0, 'v' }, |
| {"neat", no_argument, 0, 'n' }, |
| { 0, 0, 0, 0 } |
| }; |
| |
| int optionIndex; |
| int c; |
| // Lshal::parseArgs has set optind to the next option to parse |
| for (;;) { |
| // using getopt_long in case we want to add other options in the future |
| c = getopt_long(arg.argc, arg.argv, |
| "hitrpacmde", longOptions, &optionIndex); |
| if (c == -1) { |
| break; |
| } |
| switch (c) { |
| case 's': { |
| if (strcmp(optarg, "interface") == 0 || strcmp(optarg, "i") == 0) { |
| mSortColumn = TableEntry::sortByInterfaceName; |
| } else if (strcmp(optarg, "pid") == 0 || strcmp(optarg, "p") == 0) { |
| mSortColumn = TableEntry::sortByServerPid; |
| } else { |
| mErr << "Unrecognized sorting column: " << optarg << std::endl; |
| mLshal.usage(command); |
| return USAGE; |
| } |
| break; |
| } |
| case 'v': { |
| if (optarg) { |
| mFileOutput = new std::ofstream{optarg}; |
| mOut = mFileOutput; |
| if (!mFileOutput.buf().is_open()) { |
| mErr << "Could not open file '" << optarg << "'." << std::endl; |
| return IO_ERROR; |
| } |
| } |
| mVintf = true; |
| } |
| case 'i': { |
| mSelectedColumns |= ENABLE_INTERFACE_NAME; |
| break; |
| } |
| case 't': { |
| mSelectedColumns |= ENABLE_TRANSPORT; |
| break; |
| } |
| case 'r': { |
| mSelectedColumns |= ENABLE_ARCH; |
| break; |
| } |
| case 'p': { |
| mSelectedColumns |= ENABLE_SERVER_PID; |
| break; |
| } |
| case 'a': { |
| mSelectedColumns |= ENABLE_SERVER_ADDR; |
| break; |
| } |
| case 'c': { |
| mSelectedColumns |= ENABLE_CLIENT_PIDS; |
| break; |
| } |
| case 'e': { |
| mSelectedColumns |= ENABLE_THREADS; |
| break; |
| } |
| case 'm': { |
| mEnableCmdlines = true; |
| break; |
| } |
| case 'd': { |
| mEmitDebugInfo = true; |
| |
| if (optarg) { |
| mFileOutput = new std::ofstream{optarg}; |
| mOut = mFileOutput; |
| if (!mFileOutput.buf().is_open()) { |
| mErr << "Could not open file '" << optarg << "'." << std::endl; |
| return IO_ERROR; |
| } |
| chown(optarg, AID_SHELL, AID_SHELL); |
| } |
| break; |
| } |
| case 'n': { |
| mNeat = true; |
| break; |
| } |
| case 'h': // falls through |
| default: // see unrecognized options |
| mLshal.usage(command); |
| return USAGE; |
| } |
| } |
| if (optind < arg.argc) { |
| // see non option |
| mErr << "Unrecognized option `" << arg.argv[optind] << "`" << std::endl; |
| } |
| |
| if (mSelectedColumns == 0) { |
| mSelectedColumns = ENABLE_INTERFACE_NAME | ENABLE_SERVER_PID | ENABLE_CLIENT_PIDS | ENABLE_THREADS; |
| } |
| return OK; |
| } |
| |
| Status ListCommand::main(const std::string &command, const Arg &arg) { |
| Status status = parseArgs(command, arg); |
| if (status != OK) { |
| return status; |
| } |
| status = fetch(); |
| postprocess(); |
| dump(); |
| return status; |
| } |
| |
| } // namespace lshal |
| } // namespace android |
| |