power-libperfmgr: Implement IPowerHintSession.setThreads

Implement IPowerHintSession.setThreads, when threads are updated,
remove all previous threads and readd new threads, set the boost to
initial state.

Minor: Update IPower version to 4.

Bug: b/244216750
Bug: b/257217984
Test: manual
Change-Id: I29e2574d3a107a3e75bf27a4528635e3eedc2d14

Author: lpy

power-libperfmgr/aidl/PowerHintSession.cpp

@@ -363,6 +363,25 @@ ndk::ScopedAStatus PowerHintSession::sendHint(SessionHint hint) {
     return ndk::ScopedAStatus::ok();
 }
 
+ndk::ScopedAStatus PowerHintSession::setThreads(const std::vector<int32_t> &threadIds) {
+    if (mSessionClosed) {
+        ALOGE("Error: session is dead");
+        return ndk::ScopedAStatus::fromExceptionCode(EX_ILLEGAL_STATE);
+    }
+    if (threadIds.size() == 0) {
+        LOG(ERROR) << "Error: threadIds.size() shouldn't be " << threadIds.size();
+        return ndk::ScopedAStatus::fromExceptionCode(EX_ILLEGAL_ARGUMENT);
+    }
+
+    PowerSessionManager::getInstance()->removeThreadsFromPowerSession(this);
+    mDescriptor->threadIds.resize(threadIds.size());
+    std::copy(threadIds.begin(), threadIds.end(), back_inserter(mDescriptor->threadIds));
+    PowerSessionManager::getInstance()->addThreadsFromPowerSession(this);
+    // init boost
+    setSessionUclampMin(HintManager::GetInstance()->GetAdpfProfile()->mUclampMinInit);
+    return ndk::ScopedAStatus::ok();
+}
+
 std::string AppHintDesc::toString() const {
     std::string out =
             StringPrintf("session %" PRIxPTR "\n", reinterpret_cast<uintptr_t>(this) & 0xffff);
@@ -398,7 +417,7 @@ bool PowerHintSession::isTimeout() {
     return now >= staleTime;
 }
 
-const std::vector<int> &PowerHintSession::getTidList() const {
+const std::vector<int32_t> &PowerHintSession::getTidList() const {
     return mDescriptor->threadIds;
 }
 

power-libperfmgr/aidl/PowerHintSession.h

@@ -44,7 +44,7 @@ using std::chrono::steady_clock;
 using std::chrono::time_point;
 
 struct AppHintDesc {
-    AppHintDesc(int32_t tgid, int32_t uid, std::vector<int> threadIds)
+    AppHintDesc(int32_t tgid, int32_t uid, std::vector<int32_t> threadIds)
         : tgid(tgid),
           uid(uid),
           threadIds(std::move(threadIds)),
@@ -57,7 +57,7 @@ struct AppHintDesc {
     std::string toString() const;
     const int32_t tgid;
     const int32_t uid;
-    const std::vector<int> threadIds;
+    std::vector<int32_t> threadIds;
     nanoseconds duration;
     int current_min;
     // status
@@ -80,6 +80,7 @@ class PowerHintSession : public BnPowerHintSession {
     ndk::ScopedAStatus reportActualWorkDuration(
             const std::vector<WorkDuration> &actualDurations) override;
     ndk::ScopedAStatus sendHint(SessionHint hint) override;
+    ndk::ScopedAStatus setThreads(const std::vector<int32_t> &threadIds) override;
     bool isActive();
     bool isTimeout();
     void setStale();

power-libperfmgr/aidl/PowerSessionManager.cpp

@@ -104,6 +104,22 @@ int PowerSessionManager::getDisplayRefreshRate() {
 }
 
 void PowerSessionManager::addPowerSession(PowerHintSession *session) {
+    addThreadsFromPowerSession(session);
+    {
+        std::lock_guard<std::mutex> guard(mLock);
+        mSessions.insert(session);
+    }
+}
+
+void PowerSessionManager::removePowerSession(PowerHintSession *session) {
+    removeThreadsFromPowerSession(session);
+    {
+        std::lock_guard<std::mutex> guard(mLock);
+        mSessions.erase(session);
+    }
+}
+
+void PowerSessionManager::addThreadsFromPowerSession(PowerHintSession *session) {
     std::lock_guard<std::mutex> guard(mLock);
     for (auto t : session->getTidList()) {
         mTidSessionListMap[t].insert(session);
@@ -121,10 +137,9 @@ void PowerSessionManager::addPowerSession(PowerHintSession *session) {
         }
         mTidRefCountMap[t]++;
     }
-    mSessions.insert(session);
 }
 
-void PowerSessionManager::removePowerSession(PowerHintSession *session) {
+void PowerSessionManager::removeThreadsFromPowerSession(PowerHintSession *session) {
     std::lock_guard<std::mutex> guard(mLock);
     for (auto t : session->getTidList()) {
         if (mTidRefCountMap.find(t) == mTidRefCountMap.end()) {
@@ -140,7 +155,6 @@ void PowerSessionManager::removePowerSession(PowerHintSession *session) {
             mTidRefCountMap.erase(t);
         }
     }
-    mSessions.erase(session);
 }
 
 void PowerSessionManager::setUclampMin(PowerHintSession *session, int val) {

power-libperfmgr/aidl/PowerSessionManager.h

@@ -50,6 +50,8 @@ class PowerSessionManager : public MessageHandler {
     // monitoring session status
     void addPowerSession(PowerHintSession *session);
     void removePowerSession(PowerHintSession *session);
+    void addThreadsFromPowerSession(PowerHintSession *session);
+    void removeThreadsFromPowerSession(PowerHintSession *session);
     void setUclampMin(PowerHintSession *session, int min);
     void setUclampMinLocked(PowerHintSession *session, int min);
     void handleMessage(const Message &message) override;

power-libperfmgr/aidl/android.hardware.power-service.lineage.xml

@@ -1,7 +1,7 @@
 <manifest version="1.0" type="device">
     <hal format="aidl">
         <name>android.hardware.power</name>
-        <version>3</version>
+        <version>4</version>
         <fqname>IPower/default</fqname>
     </hal>
 </manifest>