Home
last modified time | relevance | path

Searched refs:reader_list_ (Results 1 – 12 of 12) sorted by relevance

/system/core/logd/
DLogBufferTest.cpp240 auto lock = std::unique_lock{reader_list_.reader_threads_lock()}; in TEST_P()
243 new LogReaderThread(log_buffer_.get(), &reader_list_, std::move(test_writer), true, in TEST_P()
245 reader_list_.reader_threads().emplace_back(std::move(log_reader)); in TEST_P()
252 auto lock = std::unique_lock{reader_list_.reader_threads_lock()}; in TEST_P()
253 EXPECT_EQ(0U, reader_list_.reader_threads().size()); in TEST_P()
314 auto lock = std::unique_lock{reader_list_.reader_threads_lock()}; in TEST_P()
317 new LogReaderThread(log_buffer_.get(), &reader_list_, std::move(test_writer), true, in TEST_P()
319 reader_list_.reader_threads().emplace_back(std::move(log_reader)); in TEST_P()
326 auto lock = std::unique_lock{reader_list_.reader_threads_lock()}; in TEST_P()
327 EXPECT_EQ(0U, reader_list_.reader_threads().size()); in TEST_P()
[all …]
DLogReader.cpp77 : SocketListener(getLogSocket(), true), log_buffer_(logbuf), reader_list_(reader_list) {} in LogReader()
155 reader_list_->reader_threads_lock().lock(); in onDataAvailable()
156 reader_list_->reader_threads_lock().unlock(); in onDataAvailable()
215 auto lock = std::lock_guard{reader_list_->reader_threads_lock()}; in onDataAvailable()
216 auto entry = std::make_unique<LogReaderThread>(log_buffer_, reader_list_, in onDataAvailable()
221 reader_list_->reader_threads().emplace_front(std::move(entry)); in onDataAvailable()
233 auto lock = std::lock_guard{reader_list_->reader_threads_lock()}; in DoSocketDelete()
234 for (const auto& reader : reader_list_->reader_threads()) { in DoSocketDelete()
DLogBufferTest.h70 log_buffer_.reset(new ChattyLogBuffer(&reader_list_, &tags_, &prune_, &stats_)); in SetUp()
72 log_buffer_.reset(new SerializedLogBuffer(&reader_list_, &tags_, &stats_)); in SetUp()
74 log_buffer_.reset(new SimpleLogBuffer(&reader_list_, &tags_, &stats_)); in SetUp()
87 LogReaderList reader_list_; variable
DSerializedLogBuffer.cpp31 : reader_list_(reader_list), tags_(tags), stats_(stats) { in SerializedLogBuffer()
43 auto reader_threads_lock = std::lock_guard{reader_list_->reader_threads_lock()}; in Init()
44 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init()
101 reader_list_->NotifyNewLog(1 << log_id); in Log()
131 for (const auto& reader_thread : reader_list_->reader_threads()) { in NotifyReadersOfPrune()
140 auto reader_threads_lock = std::lock_guard{reader_list_->reader_threads_lock()}; in Prune()
141 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune()
289 auto reader_threads_lock = std::lock_guard{reader_list_->reader_threads_lock()}; in Clear()
290 for (const auto& reader_thread : reader_list_->reader_threads()) { in Clear()
DLogReaderThread.cpp34 reader_list_(reader_list), in LogReaderThread()
52 auto lock = std::unique_lock{reader_list_->reader_threads_lock()}; in ThreadFunction()
110 auto& log_reader_threads = reader_list_->reader_threads(); in ThreadFunction()
121 auto lock = std::lock_guard{reader_list_->reader_threads_lock()}; in FilterFirstPass()
133 auto lock = std::lock_guard{reader_list_->reader_threads_lock()}; in FilterSecondPass()
DSimpleLogBuffer.cpp24 : reader_list_(reader_list), tags_(tags), stats_(stats) { in SimpleLogBuffer()
38 auto reader_threads_lock = std::lock_guard{reader_list_->reader_threads_lock()}; in Init()
39 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init()
109 reader_list_->NotifyNewLog(1 << log_id); in LogInternal()
236 auto reader_threads_lock = std::lock_guard{reader_list_->reader_threads_lock()}; in Clear()
237 for (const auto& reader_thread : reader_list_->reader_threads()) { in Clear()
276 auto reader_threads_lock = std::lock_guard{reader_list_->reader_threads_lock()}; in Prune()
280 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune()
DReplayMessages.cpp216 LogReaderList reader_list_; member in PrintInteresting
221 SimpleLogBuffer simple_log_buffer_{&reader_list_, &tags_, &stats_simple_};
224 ChattyLogBuffer chatty_log_buffer_{&reader_list_, &tags_, &prune_list_, &stats_chatty_};
227 SerializedLogBuffer serialized_log_buffer_{&reader_list_, &tags_, &stats_serialized_};
235 log_buffer_.reset(new SimpleLogBuffer(&reader_list_, &tags_, stats_.get())); in SingleBufferOperation()
239 new ChattyLogBuffer(&reader_list_, &tags_, &prune_list_, stats_.get())); in SingleBufferOperation()
242 log_buffer_.reset(new SerializedLogBuffer(&reader_list_, &tags_, stats_.get())); in SingleBufferOperation()
265 LogReaderList reader_list_; member in SingleBufferOperation
DChattyLogBufferTest.cpp260 auto lock = std::unique_lock{reader_list_.reader_threads_lock()}; in TEST_P()
263 new LogReaderThread(log_buffer_.get(), &reader_list_, std::move(test_writer), true, in TEST_P()
265 reader_list_.reader_threads().emplace_back(std::move(log_reader)); in TEST_P()
320 auto lock = std::unique_lock{reader_list_.reader_threads_lock()}; in TEST_P()
323 new LogReaderThread(log_buffer_.get(), &reader_list_, std::move(test_writer), true, in TEST_P()
325 reader_list_.reader_threads().emplace_back(std::move(log_reader)); in TEST_P()
DSerializedLogBuffer.h62 REQUIRES(reader_list_->reader_threads_lock());
66 LogReaderList* reader_list_; variable
DLogReader.h40 LogReaderList* reader_list_; variable
DSimpleLogBuffer.h62 LogReaderList* reader_list() { return reader_list_; } in reader_list()
72 LogReaderList* reader_list_; variable
DLogReaderThread.h73 LogReaderList* reader_list_; variable