Commit: 1f00dd48f696e86925a47da7a9f29b0e65d2fe31 - system-hardware-interfaces (git)

system/hardware/interfaces

Commit MetaInfo

• Revision: 1f00dd48f696e86925a47da7a9f29b0e65d2fe31 (tree)
• Time: 2018-09-06 14:12:26
• Author: Tri Vo <trong@goog...>
• Commiter: android-build-merger

Log Message

Add IWakeLock::release() method.
am: d502490bac

Change-Id: Id5e96044930c08c01589afdf1d213c98f39efb92

Change Summary

• modified: suspend/1.0/IWakeLock.hal
• modified: suspend/1.0/default/SystemSuspend.cpp
• modified: suspend/1.0/default/SystemSuspend.h
• modified: suspend/1.0/default/SystemSuspendUnitTest.cpp

Incremental Difference

--- a/suspend/1.0/IWakeLock.hal
+++ b/suspend/1.0/IWakeLock.hal
@@ -18,6 +18,14 @@ package android.system.suspend@1.0;
 
 /**
  * Allocating an IWakeLock instance must block system suspend. Deallocating an
- * IWakeLock must initiate system suspend if no other wake lock is allocated.
+ * IWakeLock must unblock system suspend in a manner equivalent to calling
+ * IWakeLock::release().
  */
-interface IWakeLock {};
+interface IWakeLock {
+    /**
+     *  Releases IWakeLock instance. This method only has effect first time its
+     *  called. Subsequent calls must result in no-ops. If no unreleased wake
+     *  lock is present, system is allowed to suspend.
+     */
+    oneway release();
+};

--- a/suspend/1.0/default/SystemSuspend.cpp
+++ b/suspend/1.0/default/SystemSuspend.cpp
@@ -57,13 +57,24 @@ static inline int getCallingPid() {
     return IPCThreadState::self()->getCallingPid();
 }
 
-WakeLock::WakeLock(SystemSuspend* systemSuspend) : mSystemSuspend(systemSuspend) {
+WakeLock::WakeLock(SystemSuspend* systemSuspend) : mReleased(), mSystemSuspend(systemSuspend) {
     mSystemSuspend->incSuspendCounter();
 }
 
 WakeLock::~WakeLock() {
-    mSystemSuspend->decSuspendCounter();
-    mSystemSuspend->deleteWakeLockStatsEntry(reinterpret_cast<uint64_t>(this));
+    releaseOnce();
+}
+
+Return<void> WakeLock::release() {
+    releaseOnce();
+    return Void();
+}
+
+void WakeLock::releaseOnce() {
+    std::call_once(mReleased, [this]() {
+        mSystemSuspend->decSuspendCounter();
+        mSystemSuspend->deleteWakeLockStatsEntry(reinterpret_cast<uint64_t>(this));
+    });
 }
 
 SystemSuspend::SystemSuspend(unique_fd wakeupCountFd, unique_fd stateFd)

--- a/suspend/1.0/default/SystemSuspend.h
+++ b/suspend/1.0/default/SystemSuspend.h
@@ -45,7 +45,12 @@ class WakeLock : public IWakeLock {
     WakeLock(SystemSuspend* systemSuspend);
     ~WakeLock();
 
+    Return<void> release();
+
    private:
+    inline void releaseOnce();
+    std::once_flag mReleased;
+
     SystemSuspend* mSystemSuspend;
 };
 

--- a/suspend/1.0/default/SystemSuspendUnitTest.cpp
+++ b/suspend/1.0/default/SystemSuspendUnitTest.cpp
@@ -183,6 +183,16 @@ TEST_F(SystemSuspendTest, WakeLockDestructor) {
     ASSERT_FALSE(isSystemSuspendBlocked());
 }
 
+// Tests that upon WakeLock::release() SystemSuspend HAL is unblocked.
+TEST_F(SystemSuspendTest, WakeLockRelease) {
+    sp<IWakeLock> wl = acquireWakeLock();
+    ASSERT_NE(wl, nullptr);
+    unblockSystemSuspendFromWakeupCount();
+    ASSERT_TRUE(isSystemSuspendBlocked());
+    wl->release();
+    ASSERT_FALSE(isSystemSuspendBlocked());
+}
+
 // Tests that multiple WakeLocks correctly block SystemSuspend HAL.
 TEST_F(SystemSuspendTest, MultipleWakeLocks) {
     {
@@ -248,7 +258,9 @@ TEST_F(SystemSuspendTest, WakeLockStressTest) {
     for (int i = 0; i < numThreads; i++) {
         tds[i] = std::thread([this] {
             for (int i = 0; i < numLocks; i++) {
-                sp<IWakeLock> wl = acquireWakeLock();
+                sp<IWakeLock> wl1 = acquireWakeLock();
+                sp<IWakeLock> wl2 = acquireWakeLock();
+                wl2->release();
             }
         });
     }