#include "OplusGameOpt.h" #include <math.h> #include <stdlib.h> #include <utils/Log.h> #include <utils/String8.h> #include <android/binder_manager.h> #include <android/binder_process.h> #include <log/log.h> #include <android-base/logging.h> using namespace std; using namespace android; using android::hidl::base::V1_0::IBase; using ::android::sp; using ::aidl::vendor::oplus::hardware::gameopt::IGameOptHalService; template<typename T> using Return = hardware::Return<T>; ANDROID_SINGLETON_STATIC_INSTANCE(OplusGameOpt); OplusGameOpt::OplusGameOpt() { ALOGI("OplusGameOpt init"); Mutex::Autolock _l(mLock); checkService(); } OplusGameOpt::~OplusGameOpt() { delete mDeathMonitor; mDeathMonitor = nullptr; } bool OplusGameOpt::checkService() { if (mService != nullptr) { return true; } else { std::string aidl_instance = std::string() + IGameOptHalService::descriptor + "/default"; mService = IGameOptHalService::fromBinder(ndk::SpAIBinder(AServiceManager_checkService(aidl_instance.c_str()))); if (mService == nullptr) { ALOGE("unable to get OplusGameOpt service"); } else { ALOGD("succeed in getting OplusGameOpt service"); if (mDeathMonitor == nullptr) { ALOGD("create DeathMonitor()"); mDeathMonitor = new DeathMonitor(); } else { ALOGD("delete old DeathMonitor() and create a new one"); delete mDeathMonitor; mDeathMonitor = nullptr; mDeathMonitor = new DeathMonitor(); } mDeathMonitor->init(mService); return true; } } mService = nullptr; return false; } void OplusGameOpt::handleServiceDied() { Mutex::Autolock _l(mLock); mService = NULL; } void OplusGameOpt::notifySFBufferProduced(int32_t bufferNum, int64_t timeStamp) { Mutex::Autolock _l(mLock); if (!checkService()) { ALOGE("OplusGameOpt notifySFBufferProduced check service failed"); return; } ndk::ScopedAStatus ret = mService->notifySFBufferProduced(bufferNum, timeStamp); if (!ret.isOk()) { ALOGE("OplusGameOpt notifySFBufferProduced failed: %s", ret.getDescription().c_str()); } } void OplusGameOpt::notifyGameInfo(int32_t type, const string& data) { Mutex::Autolock _l(mLock); if (!checkService()) { ALOGE("OplusGameOpt notifyGameInfo check service failed"); return; } ndk::ScopedAStatus ret = mService->notifyGameInfo(type, data); if (!ret.isOk()) { ALOGE("OplusGameOpt notifyGameInfo failed: %s", ret.getDescription().c_str()); } } DeathMonitor::DeathMonitor(): mDeathRecipient(AIBinder_DeathRecipient_new(DeathMonitor::serviceDied)) { } DeathMonitor::~DeathMonitor() { //AIBinder_DeathRecipient_delete(mDeathRecipient.get()); } void DeathMonitor::init(std::shared_ptr<::aidl::vendor::oplus::hardware::gameopt::IGameOptHalService> obj) { mObj = obj; if (mObj == nullptr) { return; } auto status = ::ndk::ScopedAStatus::fromStatus(::AIBinder_linkToDeath( mObj->asBinder().get(), mDeathRecipient.get(), this)); if (!status.isOk()) { ALOGE("AIBinder_linkToDeath failed"); } } void DeathMonitor::serviceDied(void* cookie) { DeathMonitor* monitor = static_cast<DeathMonitor*>(cookie); monitor->serviceDied(); } void DeathMonitor::serviceDied() { if (mObj != nullptr) { auto ret = ::ndk::ScopedAStatus::fromStatus(::AIBinder_unlinkToDeath( mObj->asBinder().get(), mDeathRecipient.get(), this)); if (!ret.isOk()) { ALOGE("AIBinder_unlinkToDeath failed"); } } mObj = nullptr; OplusGameOpt::getInstance().handleServiceDied(); } 解释代码含义