Home
last modified time | relevance | path

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

/system/logging/logd/
DLogBufferTest.h74 log_buffer_.reset(new ChattyLogBuffer(&reader_list_, &tags_, &prune_, &stats_)); in SetUp()
76 log_buffer_.reset(new SerializedLogBuffer(&reader_list_, &tags_, &stats_)); in SetUp()
78 log_buffer_.reset(new SimpleLogBuffer(&reader_list_, &tags_, &stats_)); in SetUp()
126 test_.log_buffer_.get(), &test_.reader_list_, std::move(test_writer), in TestReaderThread()
129 test_.reader_list_.reader_threads().emplace_back(std::move(log_reader)); in TestReaderThread()
152 EXPECT_EQ(0U, reader_list_.reader_threads().size()); in ReadLogMessagesNonBlockingThread()
160 for (auto& reader : reader_list_.reader_threads()) { in ReleaseAndJoinReaders()
169 if (reader_list_.reader_threads().size() == 0) { in ReleaseAndJoinReaders()
177 LogReaderList reader_list_; variable
DReplayMessages.cpp227 LogReaderList reader_list_; member in PrintInteresting
232 SimpleLogBuffer simple_log_buffer_{&reader_list_, &tags_, &stats_simple_};
235 ChattyLogBuffer chatty_log_buffer_{&reader_list_, &tags_, &prune_list_, &stats_chatty_};
238 SerializedLogBuffer serialized_log_buffer_{&reader_list_, &tags_, &stats_serialized_};
246 log_buffer_.reset(new SimpleLogBuffer(&reader_list_, &tags_, stats_.get())); in SingleBufferOperation()
250 new ChattyLogBuffer(&reader_list_, &tags_, &prune_list_, stats_.get())); in SingleBufferOperation()
253 log_buffer_.reset(new SerializedLogBuffer(&reader_list_, &tags_, stats_.get())); in SingleBufferOperation()
276 LogReaderList reader_list_; member in SingleBufferOperation
379 new LogReaderThread(log_buffer_.get(), &reader_list_, std::move(stdout_writer), in PrintAllLogs()
381 reader_list_.reader_threads().emplace_back(std::move(log_reader)); in PrintAllLogs()
[all …]
DLogReader.cpp78 : SocketListener(getLogSocket(), true), log_buffer_(logbuf), reader_list_(reader_list) {} in LogReader()
218 auto entry = std::make_unique<LogReaderThread>(log_buffer_, reader_list_, in onDataAvailable()
223 reader_list_->reader_threads().emplace_front(std::move(entry)); in onDataAvailable()
236 for (const auto& reader : reader_list_->reader_threads()) { in DoSocketDelete()
DSerializedLogBuffer.cpp96 : reader_list_(reader_list), tags_(tags), stats_(stats) { in SerializedLogBuffer()
109 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init()
160 reader_list_->NotifyNewLog(1 << log_id); in Log()
189 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune()
234 for (const auto& reader_thread : reader_list_->reader_threads()) { in UidClear()
DSimpleLogBuffer.cpp25 : reader_list_(reader_list), tags_(tags), stats_(stats) { in SimpleLogBuffer()
40 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init()
110 reader_list_->NotifyNewLog(1 << log_id); in LogInternal()
237 for (const auto& reader_thread : reader_list_->reader_threads()) { in Clear()
278 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune()
DLogReader.h38 LogReaderList* reader_list_; variable
DSimpleLogBuffer.h64 LogReaderList* reader_list() { return reader_list_; } in reader_list()
72 LogReaderList* reader_list_; variable
DLogReaderThread.cpp35 reader_list_(reader_list), in LogReaderThread()
107 auto& log_reader_threads = reader_list_->reader_threads(); in ThreadFunction()
DLogReaderThread.h78 LogReaderList* reader_list_; variable
DSerializedLogBuffer.h68 LogReaderList* reader_list_; variable
DLogBufferTest.cpp327 if (reader_list_.reader_threads().back()->start() == 4) { in TEST_P()
352 if (reader_list_.reader_threads().back()->start() == 7) { in TEST_P()