Home
last modified time | relevance | path

Searched refs:logd_lock (Results 1 – 19 of 19) sorted by relevance

/aosp12/system/logging/logd/
H A DLogReaderThread.h49 void Release() REQUIRES(logd_lock) { in Release()
56 bool IsWatching(log_id_t id) const REQUIRES(logd_lock) { in IsWatching()
59 bool IsWatchingMultiple(LogMask log_mask) const REQUIRES(logd_lock) { in IsWatchingMultiple()
63 std::string name() const REQUIRES(logd_lock) { return writer_->name(); } in name()
72 REQUIRES(logd_lock);
74 REQUIRES(logd_lock);
79 std::unique_ptr<LogWriter> writer_ GUARDED_BY(logd_lock);
82 bool release_ GUARDED_BY(logd_lock) = false;
89 unsigned int skip_ahead_[LOG_ID_MAX] GUARDED_BY(logd_lock);
91 std::unique_ptr<FlushToState> flush_to_state_ GUARDED_BY(logd_lock);
[all …]
H A DSerializedFlushToState.h49 REQUIRES(logd_lock);
56 bool HasUnreadLogs() REQUIRES(logd_lock);
60 LogWithId PopNextUnreadLog() REQUIRES(logd_lock);
64 void Prune(log_id_t log_id) REQUIRES(logd_lock);
69 void UpdateLogsNeeded(log_id_t log_id) REQUIRES(logd_lock);
73 void CreateLogPosition(log_id_t log_id) REQUIRES(logd_lock);
77 void CheckForNewLogs() REQUIRES(logd_lock);
79 std::list<SerializedLogChunk>* logs_ GUARDED_BY(logd_lock) = nullptr;
82 std::optional<LogPosition> log_positions_[LOG_ID_MAX] GUARDED_BY(logd_lock);
87 std::bitset<LOG_ID_MAX> logs_needed_from_next_position_ GUARDED_BY(logd_lock) = {};
H A DSimpleLogBuffer.h39 REQUIRES(logd_lock) override;
43 REQUIRES(logd_lock) override;
52 virtual bool Prune(log_id_t id, unsigned long prune_rows, uid_t uid) REQUIRES(logd_lock);
53 virtual void LogInternal(LogBufferElement&& elem) REQUIRES(logd_lock);
57 std::list<LogBufferElement>::iterator GetOldest(log_id_t log_id) REQUIRES(logd_lock);
59 REQUIRES(logd_lock);
61 REQUIRES(logd_lock);
65 size_t max_size(log_id_t id) REQUIRES_SHARED(logd_lock) { return max_size_[id]; } in max_size()
70 void MaybePrune(log_id_t id) REQUIRES(logd_lock);
78 size_t max_size_[LOG_ID_MAX] GUARDED_BY(logd_lock);
[all …]
H A DChattyLogBuffer.h45 LogBufferIteratorMap mLastWorst[LOG_ID_MAX] GUARDED_BY(logd_lock);
48 LogBufferPidIteratorMap mLastWorstPidOfSystem[LOG_ID_MAX] GUARDED_BY(logd_lock);
56 bool Prune(log_id_t id, unsigned long pruneRows, uid_t uid) REQUIRES(logd_lock) override;
57 void LogInternal(LogBufferElement&& elem) REQUIRES(logd_lock) override;
61 bool coalesce = false) REQUIRES(logd_lock);
66 std::optional<LogBufferElement> last_logged_elements_[LOG_ID_MAX] GUARDED_BY(logd_lock);
69 std::optional<LogBufferElement> duplicate_elements_[LOG_ID_MAX] GUARDED_BY(logd_lock);
H A DSerializedLogBuffer.h48 REQUIRES(logd_lock) override;
52 REQUIRES(logd_lock) override;
62 void MaybePrune(log_id_t log_id) REQUIRES(logd_lock);
63 void Prune(log_id_t log_id, size_t bytes_to_free) REQUIRES(logd_lock);
64 void UidClear(log_id_t log_id, uid_t uid) REQUIRES(logd_lock);
66 size_t GetSizeUsed(log_id_t id) REQUIRES(logd_lock);
72 size_t max_size_[LOG_ID_MAX] GUARDED_BY(logd_lock) = {};
73 std::list<SerializedLogChunk> logs_[LOG_ID_MAX] GUARDED_BY(logd_lock);
H A DSimpleLogBuffer.cpp39 auto lock = std::lock_guard{logd_lock}; in Init()
98 auto lock = std::lock_guard{logd_lock}; in Log()
201 logd_lock.unlock(); in FlushTo()
205 logd_lock.lock(); in FlushTo()
208 logd_lock.lock(); in FlushTo()
219 auto lock = std::lock_guard{logd_lock}; in Clear()
231 auto lock = std::lock_guard{logd_lock}; in Clear()
236 auto lock = std::lock_guard{logd_lock}; in Clear()
245 auto lock = std::lock_guard{logd_lock}; in Clear()
251 auto lock = std::lock_guard{logd_lock}; in GetSize()
[all …]
H A DSerializedFlushToStateTest.cpp40 REQUIRES(logd_lock) { in TestReport()
85 void TestAllReading() REQUIRES(logd_lock) { in TestAllReading()
101 REQUIRES(logd_lock) { in TestAllReadingWithFutureMessages()
118 REQUIRES(logd_lock) { in TestReading()
151 const std::vector<std::string>& messages) REQUIRES(logd_lock) { in AddChunkWithMessages()
178 auto lock = std::lock_guard{logd_lock}; in TEST_F()
192 auto lock = std::lock_guard{logd_lock}; in TEST_F()
209 auto lock = std::lock_guard{logd_lock}; in TEST_F()
210 auto write_logs = [&](int loop_count) REQUIRES(logd_lock) { in TEST_F()
258 auto lock = std::lock_guard{logd_lock}; in TEST_F()
[all …]
H A DSerializedLogBuffer.cpp52 log_id_t log_id, LogStatistics* stats) REQUIRES(logd_lock) { in ClearLogsByUid()
108 auto lock = std::lock_guard{logd_lock}; in Init()
153 auto lock = std::lock_guard{logd_lock}; in Log()
287 logd_lock.unlock(); in FlushTo()
290 logd_lock.lock(); in FlushTo()
294 logd_lock.lock(); in FlushTo()
302 auto lock = std::lock_guard{logd_lock}; in Clear()
322 auto lock = std::lock_guard{logd_lock}; in GetSize()
335 auto lock = std::lock_guard{logd_lock}; in SetSize()
H A DLogReaderList.h29 void NotifyNewLog(LogMask log_mask) const REQUIRES(logd_lock);
31 std::list<std::unique_ptr<LogReaderThread>>& reader_threads() REQUIRES(logd_lock) { in reader_threads()
36 std::list<std::unique_ptr<LogReaderThread>> reader_threads_ GUARDED_BY(logd_lock);
H A DLogBufferTest.h102 auto lock = std::lock_guard{logd_lock};
123 auto lock = std::lock_guard{logd_lock}; in TestReaderThread()
151 auto lock = std::lock_guard{logd_lock}; in ReadLogMessagesNonBlockingThread()
159 auto lock = std::lock_guard{logd_lock}; in ReleaseAndJoinReaders()
168 auto lock = std::lock_guard{logd_lock}; in ReleaseAndJoinReaders()
H A DLogReaderThread.cpp53 auto lock = std::unique_lock{logd_lock}; in ThreadFunction()
54 auto lock_assertion = android::base::ScopedLockAssertion{logd_lock}; in ThreadFunction()
72 log_time realtime) REQUIRES(logd_lock) { in ThreadFunction()
79 logd_lock) { return FilterSecondPass(log_id, pid, sequence, realtime); }); in ThreadFunction()
H A DLogReader.cpp156 logd_lock.lock(); in onDataAvailable()
157 logd_lock.unlock(); in onDataAvailable()
195 auto lock = std::lock_guard{logd_lock}; in onDataAvailable()
217 auto lock = std::lock_guard{logd_lock}; in onDataAvailable()
235 auto lock = std::lock_guard{logd_lock}; in DoSocketDelete()
H A DLogBuffer.h68 REQUIRES(logd_lock) = 0;
72 log_time realtime)>& filter) REQUIRES(logd_lock) = 0;
H A DLogBufferTest.cpp326 auto lock = std::lock_guard{logd_lock}; in TEST_P()
351 auto lock = std::lock_guard{logd_lock}; in TEST_P()
397 auto lock = std::lock_guard{logd_lock}; in TEST_P()
415 auto lock = std::lock_guard{logd_lock}; in TEST_P()
451 auto lock = std::lock_guard{logd_lock}; in TEST_P()
469 auto lock = std::lock_guard{logd_lock}; in TEST_P()
H A DReplayMessages.cpp324 auto lock = std::lock_guard{logd_lock}; in End()
376 auto lock = std::unique_lock{logd_lock}; in PrintAllLogs()
394 auto lock = std::lock_guard{logd_lock}; in End()
401 auto lock = std::lock_guard{logd_lock}; in End()
H A DLogdLock.cpp19 std::mutex logd_lock; variable
H A DLogdLock.h21 extern std::mutex logd_lock;
H A DSerializedLogChunk.h68 void NotifyReadersOfPrune(log_id_t log_id) REQUIRES(logd_lock);
/aosp12/system/logging/logd/fuzz/
H A Dlog_buffer_log_fuzzer.cpp129 auto lock = std::unique_lock{logd_lock}; in LLVMFuzzerTestOneInput()
140 auto lock = std::unique_lock{logd_lock}; in LLVMFuzzerTestOneInput()