| /device/google/cuttlefish/host/commands/gnss_grpc_proxy/ |
| D | gnss_grpc_proxy.cpp | 189 std::thread([this]() { WriteFixedLocationFromQueue(); }); in StartServer()
191 std::thread([this]() { ReadMeasurementLoop(); }); in StartServer()
193 std::thread([this]() { ReadFixedLocLoop(); }); in StartServer()
199 std::thread([this]() { ReadFixedLocationFromLocalFile(); }); in StartReadFixedLocationFileThread()
205 std::thread([this]() { ReadGnssRawMeasurement(); }); in StartReadGnssRawMeasurementFileThread()
388 std::thread measurement_read_thread_;
389 std::thread fixed_location_read_thread_;
390 std::thread fixed_location_file_read_thread_;
391 std::thread fixed_location_write_thread_;
392 std::thread measurement_file_read_thread_;
|
| /device/google/cuttlefish/host/frontend/webrtc/libcommon/ |
| D | peer_connection_utils.cpp | 38 auto thread = rtc::Thread::CreateWithSocketServer(); in CreateAndStartThread() local
39 CF_EXPECTF(thread.get(), "Failed to create \"{}\" thread", name); in CreateAndStartThread()
40 thread->SetName(name, nullptr); in CreateAndStartThread()
41 CF_EXPECTF(thread->Start(), "Failed to start \"{}\" thread", name); in CreateAndStartThread()
42 return thread; in CreateAndStartThread()
|
| /device/google/cuttlefish/common/libs/utils/ |
| D | socket2socket_proxy.cpp | 76 c2t_ = std::thread(&ProxyPair::Forward, this, "c2t", from, to, stop_fd_, in Start()
78 t2c_ = std::thread(&ProxyPair::Forward, this, "t2c", to, from, stop_fd_, in Start()
108 std::thread c2t_;
109 std::thread t2c_;
120 server_ = std::thread([&, server_fd = std::move(server), in ProxyServer()
|
| D | subprocess.cpp | 532 std::vector<std::thread*> threads_;
534 ThreadJoiner(const std::vector<std::thread*> threads) : threads_(threads) {} in ThreadJoiner()
536 for (auto& thread : threads_) { in ~ThreadJoiner() local
537 if (thread->joinable()) { in ~ThreadJoiner()
538 thread->join(); in ~ThreadJoiner()
558 std::thread stdin_thread, stdout_thread, stderr_thread; in RunWithManagedStdio()
570 stdin_thread = std::thread([pipe_write, stdin_str, &io_error]() { in RunWithManagedStdio()
586 stdout_thread = std::thread([pipe_read, stdout_str, &io_error]() { in RunWithManagedStdio()
602 stderr_thread = std::thread([pipe_read, stderr_str, &io_error]() { in RunWithManagedStdio()
|
| /device/google/trout/hal/vehicle/2.0/ |
| D | GarageModeServerSideHandler.cpp | 55 for (auto& thread : mThreads) { in ~GarageModeServerSideHandlerImpl() local
56 if (thread.joinable()) { in ~GarageModeServerSideHandlerImpl()
57 thread.join(); in ~GarageModeServerSideHandlerImpl()
83 std::vector<std::thread> mThreads;
|
| D | GrpcVehicleClient.cpp | 79 std::thread mPollingThread;
139 mPollingThread = std::thread([this]() { in StartValuePollingThread()
144 std::thread shuttingdown_watcher([this, &rpc_ok, &context]() { in StartValuePollingThread()
|
| /device/google/cuttlefish/guest/hals/light/lights/ |
| D | lights_vsock_server.rs | 28 use std::thread;
49 thread_handle: Option<thread::JoinHandle<anyhow::Result<()>>>,
63 thread::spawn(move || -> anyhow::Result<()> { in new()
|
| /device/google/trout/hal/sensors/2.1/tests/ |
| D | MultiPoll.cpp | 101 std::thread pollerThread([&mp, &f]() -> void { mp.poll(f); }); in TEST()
164 std::thread pollerThread([&mp, &f, &called]() -> void { in TEST()
190 std::thread pollerThread([&mp, &f, &called]() -> void { in TEST()
|
| /device/google/cuttlefish/host/commands/run_cvd/ |
| D | boot_state_machine.cc | 230 restore_complete_handler_ = std::thread( in ResultSetup()
283 std::thread([this, boot_events_pipe, restore_complete_pipe]() { in ResultSetup()
420 std::thread boot_event_handler_;
421 std::thread restore_complete_handler_;
|
| /device/generic/opengl-transport/host/libs/virglrenderer/ |
| D | README.md | 68 thread safe. We do not require thread safety because no decoder state is shared
77 process. The second kind of context is per-thread, used by the EGL/GLES
79 processed in their own thread by AVDVirglRenderer so as to minimize the number
|
| D | Context.h | 80 worker = std::thread(&Context::worker_func, this); in setPidTid()
112 std::thread worker;
|
| /device/google/trout/tools/tracing/tooling/ |
| D | tracing_agent.py | 98 self.thread = Thread(target=self.run)
139 self.thread.start()
142 self.thread.join()
|
| /device/google/cuttlefish/guest/hals/confirmationui/ |
| D | TrustyConfirmationUI.h | 93 std::thread callback_thread_;
107 std::thread host_cmd_fetcher_thread_;
|
| /device/google/cuttlefish/host/commands/secure_env/ |
| D | secure_env_windows_lib.cpp | 46 std::thread keymaster_thread([=]() { in StartSecureEnvWithHandles()
71 std::thread gatekeeper_thread([=]() { in StartSecureEnvWithHandles()
|
| D | secure_env_not_windows_main.cpp | 125 std::thread StartKernelEventMonitor(SharedFD kernel_events_fd, in StartKernelEventMonitor()
127 return std::thread([kernel_events_fd, &oemlock_lock]() { in StartKernelEventMonitor()
270 std::vector<std::thread> threads; in SecureEnvMain()
|
| /device/google/cuttlefish/host/frontend/webrtc/libdevice/ |
| D | server_connection.cpp | 50 std::thread thread_;
143 std::thread message_loop_;
222 thread_ = std::thread([this](){ReadLoop();}); in Connect()
349 message_loop_ = std::thread([this]() { in Start()
|
| /device/google/cuttlefish/host/commands/tcp_connector/ |
| D | main.cpp | 95 auto guest_to_host = std::thread([&]() { in main()
115 auto host_to_guest = std::thread([&]() { in main()
|
| /device/generic/goldfish/audio/ |
| D | device_port_sink.cpp | 66 mConsumeThread = std::thread(&TinyalsaSink::consumeThread, this); in TinyalsaSink()
68 mConsumeThread = std::thread([](){}); in TinyalsaSink()
255 std::thread mConsumeThread;
|
| D | device_port_source.cpp | 68 mProduceThread = std::thread(&TinyalsaSource::producerThread, this); in TinyalsaSource()
70 mProduceThread = std::thread([](){}); in TinyalsaSource()
226 std::thread mProduceThread;
|
| /device/generic/goldfish/sensors/include/ |
| D | multihal_sensors.h | 132 std::thread m_sensorThread;
163 std::thread m_batchThread;
|
| /device/google/contexthub/contexthubhal/ |
| D | nanohubhal.h | 121 std::thread mPollThread;
122 std::thread mAppThread;
|
| /device/generic/goldfish/camera/ |
| D | CameraDeviceSession.h | 139 std::thread mCaptureThread;
140 std::thread mDelayedCaptureThread;
|
| /device/google/trout/tools/tracing/proto/ |
| D | perfetto_trace.proto | 539 // If enabled thread names are also recoded (this is redundant if sched_switch
564 // Size of the cache for thread time_in_state cpu freq values.
2874 optional int32 thread = 2; field
6559 // from both the compositor thread and main-threads were handled).
6563 // (e.g. missed updates from the main-thread, but included updates from the
6564 // compositor thread).
6582 // Frame was dropped because of the main-thread.
6583 // The main-thread may cause a frame to be dropped, e.g. if the main-thread
6616 // If any main thread animation is active during this frame.
6618 // If any compositor thread animation is active during this frame.
[all …]
|
| /device/amlogic/yukawa/hal/hdmicec/ |
| D | hdmi_cec.c | 50 pthread_t thread; member
462 pthread_join(ctx->thread, NULL); in hdmicec_close()
583 if (pthread_create(&ctx->thread, NULL, event_thread, ctx)) { in open_hdmi_cec()
|
| /device/google/cuttlefish/host/commands/console_forwarder/ |
| D | main.cpp | 64 writer_thread_ = std::thread([this]() { WriteLoop(); }); in StartServer()
205 std::thread writer_thread_;
|