Home
last modified time | relevance | path

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

/system/logging/logd/
DLogBufferTest.h77 log_buffer_.reset(new SerializedLogBuffer(&reader_list_, &tags_, &stats_)); in SetUp()
79 log_buffer_.reset(new SimpleLogBuffer(&reader_list_, &tags_, &stats_)); in SetUp()
128 test_.log_buffer_.get(), &test_.reader_list_, std::move(test_writer), in TestReaderThread()
131 test_.reader_list_.AddAndRunThread(std::move(log_reader)); in TestReaderThread()
171 EXPECT_EQ(0U, reader_list_.running_reader_threads().size()); in ReadLogMessagesNonBlockingThread()
179 for (auto& reader : reader_list_.running_reader_threads()) { in ReleaseAndJoinReaders()
188 if (reader_list_.running_reader_threads().size() == 0) { in ReleaseAndJoinReaders()
196 LogReaderList reader_list_; variable
DLogdNativeService.cpp21 LogdNativeService::LogdNativeService(LogReaderList* reader_list) : reader_list_(reader_list) {} in LogdNativeService()
24 reader_list_->HandlePendingThread(uid, gid, pid, fd, true); in approve()
30 reader_list_->HandlePendingThread(uid, gid, pid, fd, false); in decline()
DLogReader.cpp104 : SocketListener(getLogSocket(), true), log_buffer_(logbuf), reader_list_(reader_list) {} in LogReader()
244 auto entry = std::make_unique<LogReaderThread>(log_buffer_, reader_list_, in onDataAvailable()
262 reader_list_->AddAndRunThread(std::move(entry)); in onDataAvailable()
264 if (GetLogdBinderServiceStatus(reader_list_)) { in onDataAvailable()
265 reader_list_->AddPendingThread(std::move(entry)); in onDataAvailable()
270 reader_list_->AddAndRunThread(std::move(entry)); in onDataAvailable()
285 return reader_list_->ReleaseThreadByName(cli_name); in DoSocketDelete()
DReplayMessages.cpp212 LogReaderList reader_list_; member in PrintInteresting
217 SimpleLogBuffer simple_log_buffer_{&reader_list_, &tags_, &stats_simple_};
220 SerializedLogBuffer serialized_log_buffer_{&reader_list_, &tags_, &stats_serialized_};
228 log_buffer_.reset(new SimpleLogBuffer(&reader_list_, &tags_, stats_.get())); in SingleBufferOperation()
231 log_buffer_.reset(new SerializedLogBuffer(&reader_list_, &tags_, stats_.get())); in SingleBufferOperation()
254 LogReaderList reader_list_; member in SingleBufferOperation
357 new LogReaderThread(log_buffer_.get(), &reader_list_, std::move(stdout_writer), in PrintAllLogs()
359 reader_list_.AddAndRunThread(std::move(log_reader)); in PrintAllLogs()
373 reader_list_.running_reader_threads().back()->Release(); in End()
380 if (reader_list_.running_reader_threads().size() == 0) { in End()
DSimpleLogBuffer.cpp25 : reader_list_(reader_list), tags_(tags), stats_(stats) { in SimpleLogBuffer()
40 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init()
110 reader_list_->NotifyNewLog(1 << log_id); in LogInternal()
203 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Clear()
244 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune()
DSerializedLogBuffer.cpp96 : reader_list_(reader_list), tags_(tags), stats_(stats) { in SerializedLogBuffer()
109 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init()
160 reader_list_->NotifyNewLog(1 << log_id); in Log()
189 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune()
234 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in UidClear()
DLogReader.h38 LogReaderList* reader_list_; variable
DSimpleLogBuffer.h64 LogReaderList* reader_list() { return reader_list_; } in reader_list()
72 LogReaderList* reader_list_; variable
DLogdNativeService.h30 LogReaderList* reader_list_;
DLogReaderThread.cpp35 reader_list_(reader_list), in LogReaderThread()
109 reader_list_->RemoveRunningThread(this); in ThreadFunction()
DSerializedLogBuffer.h68 LogReaderList* reader_list_; variable
DLogReaderThread.h101 LogReaderList* reader_list_; variable
DLogBufferTest.cpp327 if (reader_list_.running_reader_threads().back()->start() == 4) { in TEST_P()
352 if (reader_list_.running_reader_threads().back()->start() == 7) { in TEST_P()