| /aosp_15_r20/system/logging/logd/ |
| H A D | SimpleLogBuffer.cpp | 40 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init() local
41 reader_thread->TriggerReader(); in Init()
203 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Clear() local
204 if (reader_thread->IsWatching(id)) { in Clear()
205 LOG(WARNING) << "Kicking blocked reader, " << reader_thread->name() in Clear()
207 reader_thread->Release(); in Clear()
244 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune() local
245 if (!reader_thread->IsWatching(id)) { in Prune()
248 if (!oldest || oldest->start() > reader_thread->start() || in Prune()
249 (oldest->start() == reader_thread->start() && in Prune()
[all …]
|
| H A D | SerializedLogBuffer.cpp | 109 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init() local
110 reader_thread->TriggerReader(); in Init()
189 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune() local
190 if (!reader_thread->IsWatching(log_id)) { in Prune()
194 if (reader_thread->deadline().time_since_epoch().count() != 0) { in Prune()
202 reader_thread->TriggerReader(); in Prune()
209 if (reader_thread->start() <= it->highest_sequence_number()) { in Prune()
210 LOG(WARNING) << "Skipping entries from slow reader, " << reader_thread->name() in Prune()
234 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in UidClear() local
235 if (!reader_thread->IsWatching(log_id)) { in UidClear()
[all …]
|
| /aosp_15_r20/external/cronet/build/android/pylib/symbols/ |
| H A D | expensive_line_transformer.py | 108 reader_thread = reraiser_thread.ReraiserThread(_reader)
109 reader_thread.start()
119 reader_thread.join(timeout)
124 if reader_thread.is_alive():
|
| /aosp_15_r20/external/angle/build/android/pylib/symbols/ |
| H A D | expensive_line_transformer.py | 108 reader_thread = reraiser_thread.ReraiserThread(_reader)
109 reader_thread.start()
119 reader_thread.join(timeout)
124 if reader_thread.is_alive():
|
| /aosp_15_r20/external/squashfs-tools/squashfs-tools/ |
| H A D | restore.c | 49 extern pthread_t reader_thread, writer_thread, main_thread;
86 pthread_cancel(reader_thread); in restore_thrd()
87 pthread_join(reader_thread, NULL); in restore_thrd()
|
| H A D | mksquashfs.c | 301 pthread_t reader_thread, writer_thread, main_thread; variable
4478 pthread_create(&reader_thread, NULL, reader, NULL); in initialise_threads()
|
| /aosp_15_r20/external/pigweed/pw_multisink/ |
| H A D | multisink_threaded_test.cc | 206 Thread reader_thread(test::MultiSinkTestThreadOptions(), reader_thread_core); in TEST_F() local
214 reader_thread.join(); in TEST_F()
230 Thread reader_thread(test::MultiSinkTestThreadOptions(), reader_thread_core); in TEST_F() local
238 reader_thread.join(); in TEST_F()
|
| /aosp_15_r20/external/chromium-trace/catapult/devil/devil/utils/ |
| H A D | cmd_helper.py | 413 reader_thread = threading.Thread(target=read_process_stdout)
414 reader_thread.start()
438 reader_thread.join()
|
| /aosp_15_r20/external/perfetto/src/profiling/memory/ |
| H A D | shared_ring_buffer_unittest.cc | 247 std::thread reader_thread(reader_thread_fn); in TEST() local
254 reader_thread.join(); in TEST()
|
| /aosp_15_r20/bionic/tests/ |
| H A D | pthread_test.cpp | 1350 pthread_t reader_thread; in TEST() local
1352 helper.CreateReaderThread(reader_thread, reader_tid); in TEST()
1353 ASSERT_EQ(0, pthread_join(reader_thread, nullptr)); in TEST()
1372 pthread_t reader_thread; in TEST() local
1374 helper.CreateReaderThread(reader_thread, reader_tid); in TEST()
1379 ASSERT_EQ(0, pthread_join(reader_thread, nullptr)); in TEST()
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
| H A D | end2end_test.cc | 1366 std::thread reader_thread(ReaderThreadFunc, stream.get(), &ev); in TEST_P() local
1369 reader_thread.join(); in TEST_P()
|