blob: b66ff9e59e54aa98a41227ec7506b1975e2a3710 [file] [log] [blame]
Mark Salyzyn0175b072014-02-26 09:50:16 -08001/*
2 * Copyright (C) 2012-2013 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17#ifndef _LOGD_LOG_TIMES_H__
18#define _LOGD_LOG_TIMES_H__
19
20#include <pthread.h>
21#include <time.h>
22#include <sys/types.h>
Mark Salyzyn98dca2d2015-08-19 13:10:14 -070023
24#include <list>
25
Mark Salyzyn0175b072014-02-26 09:50:16 -080026#include <sysutils/SocketClient.h>
TraianX Schiauda6495d2014-12-17 10:53:41 +020027#include <log/log.h>
Mark Salyzyn0175b072014-02-26 09:50:16 -080028
29class LogReader;
Mark Salyzyn317bfb92016-02-23 08:55:43 -080030class LogBufferElement;
Mark Salyzyn0175b072014-02-26 09:50:16 -080031
32class LogTimeEntry {
33 static pthread_mutex_t timesLock;
34 unsigned int mRefCount;
35 bool mRelease;
36 bool mError;
37 bool threadRunning;
Mark Salyzyn047cc072015-06-04 13:35:30 -070038 bool leadingDropped;
Mark Salyzyna16f7612014-08-07 08:16:52 -070039 pthread_cond_t threadTriggeredCondition;
Mark Salyzyn0175b072014-02-26 09:50:16 -080040 pthread_t mThread;
41 LogReader &mReader;
42 static void *threadStart(void *me);
43 static void threadStop(void *me);
44 const unsigned int mLogMask;
45 const pid_t mPid;
TraianX Schiauda6495d2014-12-17 10:53:41 +020046 unsigned int skipAhead[LOG_ID_MAX];
Mark Salyzyn0175b072014-02-26 09:50:16 -080047 unsigned long mCount;
48 unsigned long mTail;
49 unsigned long mIndex;
50
51public:
52 LogTimeEntry(LogReader &reader, SocketClient *client, bool nonBlock,
Mark Salyzynfa3716b2014-02-14 16:05:05 -080053 unsigned long tail, unsigned int logMask, pid_t pid,
Mark Salyzynb75cce02015-11-30 11:35:56 -080054 uint64_t start, uint64_t timeout);
Mark Salyzyn0175b072014-02-26 09:50:16 -080055
56 SocketClient *mClient;
Mark Salyzynf7c0f752015-03-03 13:39:37 -080057 uint64_t mStart;
Mark Salyzynb75cce02015-11-30 11:35:56 -080058 struct timespec mTimeout;
Mark Salyzyn0175b072014-02-26 09:50:16 -080059 const bool mNonBlock;
Mark Salyzynf7c0f752015-03-03 13:39:37 -080060 const uint64_t mEnd; // only relevant if mNonBlock
Mark Salyzyn0175b072014-02-26 09:50:16 -080061
62 // Protect List manipulations
63 static void lock(void) { pthread_mutex_lock(&timesLock); }
64 static void unlock(void) { pthread_mutex_unlock(&timesLock); }
65
66 void startReader_Locked(void);
67
Mark Salyzync03e72c2014-02-18 11:23:53 -080068 bool runningReader_Locked(void) const {
Mark Salyzyn0175b072014-02-26 09:50:16 -080069 return threadRunning || mRelease || mError || mNonBlock;
70 }
Mark Salyzyna16f7612014-08-07 08:16:52 -070071 void triggerReader_Locked(void) {
72 pthread_cond_signal(&threadTriggeredCondition);
73 }
74
TraianX Schiauda6495d2014-12-17 10:53:41 +020075 void triggerSkip_Locked(log_id_t id, unsigned int skip) { skipAhead[id] = skip; }
76 void cleanSkip_Locked(void);
Mark Salyzyn0175b072014-02-26 09:50:16 -080077
Mark Salyzync3484162016-03-01 14:59:32 -080078 // These called after LogTimeEntry removed from list, lock implicitly held
79 void release_nodelete_Locked(void) {
80 mRelease = true;
81 pthread_cond_signal(&threadTriggeredCondition);
82 // assumes caller code path will call decRef_Locked()
83 }
84
Mark Salyzync03e72c2014-02-18 11:23:53 -080085 void release_Locked(void) {
Mark Salyzyn0175b072014-02-26 09:50:16 -080086 mRelease = true;
Mark Salyzyna16f7612014-08-07 08:16:52 -070087 pthread_cond_signal(&threadTriggeredCondition);
Mark Salyzyn0175b072014-02-26 09:50:16 -080088 if (mRefCount || threadRunning) {
89 return;
90 }
91 // No one else is holding a reference to this
92 delete this;
93 }
94
95 // Called to mark socket in jeopardy
96 void error_Locked(void) { mError = true; }
Mark Salyzyna16f7612014-08-07 08:16:52 -070097 void error(void) { lock(); error_Locked(); unlock(); }
Mark Salyzyn0175b072014-02-26 09:50:16 -080098
99 bool isError_Locked(void) const { return mRelease || mError; }
100
101 // Mark Used
102 // Locking implied, grabbed when protection around loop iteration
103 void incRef_Locked(void) { ++mRefCount; }
104
105 bool owned_Locked(void) const { return mRefCount != 0; }
106
Mark Salyzync03e72c2014-02-18 11:23:53 -0800107 void decRef_Locked(void) {
Mark Salyzyn0175b072014-02-26 09:50:16 -0800108 if ((mRefCount && --mRefCount) || !mRelease || threadRunning) {
109 return;
110 }
111 // No one else is holding a reference to this
112 delete this;
113 }
TraianX Schiauda6495d2014-12-17 10:53:41 +0200114 bool isWatching(log_id_t id) { return (mLogMask & (1<<id)) != 0; }
Mark Salyzyn0175b072014-02-26 09:50:16 -0800115 // flushTo filter callbacks
Mark Salyzynf7c0f752015-03-03 13:39:37 -0800116 static int FilterFirstPass(const LogBufferElement *element, void *me);
117 static int FilterSecondPass(const LogBufferElement *element, void *me);
Mark Salyzyn0175b072014-02-26 09:50:16 -0800118};
119
Mark Salyzyn98dca2d2015-08-19 13:10:14 -0700120typedef std::list<LogTimeEntry *> LastLogTimes;
Mark Salyzyn0175b072014-02-26 09:50:16 -0800121
Mark Salyzyn98dca2d2015-08-19 13:10:14 -0700122#endif // _LOGD_LOG_TIMES_H__