| /aosp_15_r20/external/crosvm/devices/src/virtio/snd/vios_backend/ |
| H A D | worker.rs | 29 pub struct Worker { struct
46 impl Worker { argument
56 ) -> Result<Worker> { in try_new()
508 impl Drop for Worker { implementation
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/vhost/ |
| H A D | worker.rs | 34 pub struct Worker<T: Vhost> { struct
43 impl<T: Vhost> Worker<T> { argument
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/vhost_user_frontend/ |
| H A D | worker.rs | 26 pub struct Worker { struct
33 impl Worker { argument
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/ |
| H A D | net.rs | 329 pub(super) struct Worker<T: TapT> { struct
349 impl<T> Worker<T> argument
|
| H A D | p9.rs | 72 struct Worker { struct
78 impl Worker { implementation
|
| H A D | tpm.rs | 40 struct Worker { struct
50 impl Worker { impl
|
| H A D | rng.rs | 32 struct Worker { struct
37 impl Worker { implementation
|
| H A D | media.rs | 415 struct Worker<D: VirtioMediaDevice<Reader, Writer>> { struct
421 impl<D> Worker<D> argument
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/console/ |
| H A D | worker.rs | 103 pub struct Worker { struct
112 ports: Vec<WorkerPort>, argument
117 worker_receiver: mpsc::Receiver<WorkerRequest>, argument
121 impl Worker { argument
|
| /aosp_15_r20/tools/netsim/rust/daemon/src/http_server/ |
| H A D | thread_pool.rs | 77 struct Worker { struct
82 impl Worker { argument
83 fn new(id: usize, receiver: Arc<Mutex<mpsc::Receiver<Job>>>) -> Worker { in new()
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/fs/ |
| H A D | worker.rs | 141 pub struct Worker<F: FileSystem + Sync> { struct
142 pub(crate) queue: Queue,
143 server: Arc<fuse::Server<F>>,
167 impl<F: FileSystem + Sync> Worker<F> { implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | worker.rs | 89 pub(super) struct Worker { struct
91 handle: Arc<Handle>,
94 index: usize,
97 core: AtomicCell<Core>,
469 fn run(worker: Arc<Worker>) { in run()
885 fn transition_from_searching(&mut self, worker: &Worker) { in transition_from_searching()
968 fn maintenance(&mut self, worker: &Worker) { in maintenance()
986 fn pre_shutdown(&mut self, worker: &Worker) { in pre_shutdown()
1013 fn tune_global_queue_interval(&mut self, worker: &Worker) { in tune_global_queue_interval()
1025 impl Worker { implementation
|
| /aosp_15_r20/external/crosvm/metrics/src/sys/windows/ |
| H A D | system_metrics.rs | 54 struct Worker { struct
63 impl Worker { implementation
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/video/ |
| H A D | worker.rs | 42 pub struct Worker { struct
54 impl Worker { implementation
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/data/service/ |
| H A D | dispatcher_state.h | 89 struct Worker { struct
90 explicit Worker(const RegisterWorkerUpdate& register_worker) in Worker() function
97 const std::string address;
98 const std::string transfer_address;
99 const std::vector<std::string> tags;
100 const int64_t uid;
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/buffer/ |
| D | worker.rs | 51 impl<T, Request> Worker<T, Request> impl
67 impl<T, Request> Worker<T, Request> implementation
168 impl<T, Request> Future for Worker<T, Request> implementation
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/vsock/sys/windows/ |
| H A D | vsock.rs | 421 struct Worker { struct
434 impl Worker { implementation
442 ) -> Worker { in new()
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/gpu/ |
| H A D | mod.rs | 901 struct Worker { struct
902 request_receiver: mpsc::Receiver<WorkerRequest>, argument
903 response_sender: mpsc::Sender<anyhow::Result<WorkerResponse>>, argument
918 enum WorkerStopReason { argument
929 impl Worker { argument
951 ) -> anyhow::Result<Worker> { in new()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | worker.rs | 86 pub(super) struct Worker { struct
88 tick: u32,
91 pub(super) is_shutdown: bool,
94 is_traced: bool,
98 num_seq_local_queue_polls: u32,
101 global_queue_interval: u32,
104 workers_to_notify: Vec<usize>,
107 idle_snapshot: idle::Snapshot,
109 stats: stats::Ephemeral,
551 impl Worker { impl
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-deque/src/ |
| D | deque.rs | 192 pub struct Worker<T> { struct
206 unsafe impl<T: Send> Send for Worker<T> {} argument
208 impl<T> Worker<T> { impl
539 impl<T> fmt::Debug for Worker<T> { implementation
|
| /aosp_15_r20/external/crosvm/swap/src/ |
| H A D | worker.rs | 32 pub struct Worker<T> { struct
38 impl<T: Task + Send + 'static> Worker<T> { impl
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/input/ |
| H A D | mod.rs | 358 struct Worker<T: EventSource> { struct
366 impl<T: EventSource> Worker<T> { argument
|
| /aosp_15_r20/external/perfetto/src/trace_processor/importers/ninja/ |
| H A D | ninja_log_parser.cc | 141 struct Worker { in NotifyEndOfFile() struct
142 int64_t busy_until; in NotifyEndOfFile()
143 TrackId track_id; in NotifyEndOfFile()
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_5542_1.cpp | 11 class Worker class
15 Worker() in Worker() function in Worker
|
| /aosp_15_r20/external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| H A D | Worker.java | 30 public abstract class Worker { class
42 protected Worker(Object benchmark, Method method) { in Worker() method in Worker
|