commit a16f761faa258415b521aa6c9376c58d6c865529
author Mark Salyzyn <salyzyn@google.com> Thu Aug 07 08:16:52 2014 -0700
committer Mark Salyzyn <salyzyn@google.com> Tue Aug 12 18:59:35 2014 +0000
tree 7ddce79b1cd7fb66862d35f068a669fb4cc565bd
parent 8750fa76090ee735677022f5e2d73419dd7faa93

logd: persistent reader threads

(cherry picked from commit c113c5813ebd620e0bc60ece9a32ea14c08ea237)

Bug: 16822776
Change-Id: I5bea468a41089b51108880044f32e2b2df1278e7

logd/LogTimes.h

diff --git a/logd/LogTimes.h b/logd/LogTimes.h
index beaf646..0bfa7a2 100644
--- a/logd/LogTimes.h
+++ b/logd/LogTimes.h
@@ -31,7 +31,7 @@
     bool mRelease;
     bool mError;
     bool threadRunning;
-    bool threadTriggered;
+    pthread_cond_t threadTriggeredCondition;
     pthread_t mThread;
     LogReader &mReader;
     static void *threadStart(void *me);
@@ -63,12 +63,16 @@
     bool runningReader_Locked(void) const {
         return threadRunning || mRelease || mError || mNonBlock;
     }
-    void triggerReader_Locked(void) { threadTriggered = true; }
+    void triggerReader_Locked(void) {
+        pthread_cond_signal(&threadTriggeredCondition);
+    }
+
     void triggerSkip_Locked(unsigned int skip) { skipAhead = skip; }
 
     // Called after LogTimeEntry removed from list, lock implicitly held
     void release_Locked(void) {
         mRelease = true;
+        pthread_cond_signal(&threadTriggeredCondition);
         if (mRefCount || threadRunning) {
             return;
         }
@@ -78,7 +82,7 @@
 
     // Called to mark socket in jeopardy
     void error_Locked(void) { mError = true; }
-    void error(void) { lock(); mError = true; unlock(); }
+    void error(void) { lock(); error_Locked(); unlock(); }
 
     bool isError_Locked(void) const { return mRelease || mError; }