| /external/crosvm/devices/src/virtio/vhost/user/vmm/handler/ |
| D | worker.rs | 21 pub struct Worker { struct
29 impl Worker { implementation
|
| /external/crosvm/devices/src/virtio/vhost/ |
| D | worker.rs | 25 pub struct Worker<T: Vhost> { struct
35 impl<T: Vhost> Worker<T> { implementation
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | worker.rs | 33 pub struct Worker { struct
47 impl Worker { argument
61 ) -> Result<Worker> { in try_new()
534 impl Drop for Worker { implementation
|
| /external/crosvm/devices/src/virtio/ |
| D | console.rs | 178 struct Worker { struct
179 mem: GuestMemory,
180 interrupt: Interrupt,
181 input: Option<Arc<Mutex<VecDeque<u8>>>>,
182 output: Box<dyn io::Write + Send>,
183 kill_evt: Event,
184 in_avail_evt: Event,
185 receive_queue: Queue,
186 receive_evt: Event,
187 transmit_queue: Queue,
[all …]
|
| D | rng.rs | 40 struct Worker { struct
47 impl Worker { argument
|
| D | p9.rs | 79 struct Worker { struct
87 impl Worker { implementation
|
| D | tpm.rs | 44 struct Worker { struct
56 impl Worker { argument
|
| D | net.rs | 309 pub(super) struct Worker<T: TapT> { struct
330 impl<T> Worker<T> argument
|
| /external/crosvm/devices/src/virtio/video/ |
| D | worker.rs | 48 pub struct Worker<I: SignalableInterrupt> { struct
66 impl<I: SignalableInterrupt> Worker<I> { impl
|
| /external/crosvm/devices/src/virtio/fs/ |
| D | worker.rs | 143 pub struct Worker<F: FileSystem + Sync> { struct
144 mem: GuestMemory,
145 queue: Queue,
146 server: Arc<fuse::Server<F>>,
147 irq: Interrupt,
148 tube: Arc<Mutex<Tube>>,
149 slot: u32,
176 impl<F: FileSystem + Sync> Worker<F> { implementation
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | proxy.rs | 252 struct Worker { struct
253 mem: GuestMemory,
254 interrupt: Interrupt,
255 rx_queue: Queue,
256 tx_queue: Queue,
259 main_process_tube: Tube,
262 io_pci_bar: Alloc,
265 shmem_pci_bar: Alloc,
269 shmem_pci_bar_mem_offset: usize,
273 vrings: [Vring; MAX_VHOST_DEVICE_QUEUES],
[all …]
|
| /external/tensorflow/tensorflow/core/data/service/ |
| 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;
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | worker.rs | 74 pub(super) struct Worker { struct
76 handle: Arc<Handle>,
79 index: usize,
82 core: AtomicCell<Core>,
370 fn run(worker: Arc<Worker>) { in run()
643 fn transition_from_searching(&mut self, worker: &Worker) { in transition_from_searching()
704 fn maintenance(&mut self, worker: &Worker) { in maintenance()
716 fn pre_shutdown(&mut self, worker: &Worker) { in pre_shutdown()
736 impl Worker { implementation
|
| /external/perfetto/src/trace_processor/importers/ninja/ |
| D | ninja_log_parser.cc | 133 struct Worker { in NotifyEndOfFile() struct
134 int64_t busy_until; in NotifyEndOfFile()
135 TrackId track_id; in NotifyEndOfFile()
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| D | Worker.java | 30 public abstract class Worker { class
42 protected Worker(Object benchmark, Method method) { in Worker() method in Worker
|
| /external/crosvm/metrics/src/sys/windows/ |
| D | system_metrics.rs | 53 struct Worker { struct
62 impl Worker { argument
|
| /external/google-benchmark/test/ |
| D | internal_threading_test.cc | 80 std::thread Worker(&MyBusySpinwait); in BM_WorkerThread() local
123 std::thread Worker(&MyBusySpinwait); in BM_MainThreadAndWorkerThread() local
|
| /external/snakeyaml/src/test/java/org/yaml/snakeyaml/stress/ |
| D | ParallelTest.java | 47 private class Worker implements Runnable { class in ParallelTest
51 public Worker(int id, String doc) { in Worker() method in ParallelTest.Worker
|
| /external/crosvm/devices/src/virtio/vsock/sys/windows/ |
| D | vsock.rs | 299 struct Worker { struct
309 impl Worker { impl
315 ) -> Worker { in new()
|
| /external/crosvm/devices/src/virtio/sys/unix/ |
| D | net.rs | 123 impl<T> Worker<T> impl
|
| /external/crosvm/devices/src/virtio/gpu/ |
| D | mod.rs | 813 struct Worker { struct
828 impl Worker { argument
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 345 struct Worker<T: EventSource> { struct
353 impl<T: EventSource> Worker<T> { impl
|
| /external/crosvm/swap/src/ |
| D | worker.rs | 32 pub struct Worker<T> { struct
38 impl<T: Task + Send + 'static> Worker<T> { argument
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| D | SpanExporterImpl.java | 107 private static final class Worker implements Runnable { class in SpanExporterImpl
154 private Worker(int bufferSize, Duration scheduleDelay) { in Worker() method in SpanExporterImpl.Worker
|
| /external/python/cpython3/Lib/test/test_importlib/ |
| D | threaded_import_hangers.py | 21 class Worker(threading.Thread): class
|