Home
last modified time | relevance | path

Searched defs:Worker (Results 1 – 25 of 59) sorted by relevance

123

/external/crosvm/devices/src/virtio/vhost/
Dworker.rs16 pub struct Worker<T: Vhost> { struct
26 impl<T: Vhost> Worker<T> { argument
/external/crosvm/devices/src/virtio/vhost/user/
Dworker.rs21 pub struct Worker { struct
27 impl Worker { impl
/external/crosvm/devices/src/virtio/video/
Dworker.rs23 pub struct Worker { struct
35 impl Worker { implementation
/external/crosvm/devices/src/virtio/
Dtpm.rs32 struct Worker { struct
33 interrupt: Interrupt,
34 queue: Queue,
35 mem: GuestMemory,
36 queue_evt: Event,
37 kill_evt: Event,
38 device: Device,
82 impl Worker { impl
Drng.rs35 struct Worker { struct
42 impl Worker { argument
Dp9.rs80 struct Worker { struct
87 impl Worker { argument
Dpmem.rs82 struct Worker { struct
91 impl Worker { impl
Dnet.rs148 struct Worker<T: TapT> { struct
160 impl<T> Worker<T> argument
Dconsole.rs37 struct Worker { struct
49 impl Worker { argument
Dblock.rs251 struct Worker { struct
263 impl Worker { argument
/external/crosvm/devices/src/virtio/fs/
Dworker.rs127 pub struct Worker<F: FileSystem + Sync> { struct
136 impl<F: FileSystem + Sync> Worker<F> { argument
/external/rust/crates/tokio/src/runtime/thread_pool/
Dworker.rs23 pub(super) struct Worker { struct
47 run_queue: queue::Local<Arc<Worker>>, argument
284 fn run(worker: Arc<Worker>) { in run()
494 fn transition_from_searching(&mut self, worker: &Worker) { in transition_from_searching()
504 fn transition_to_parked(&mut self, worker: &Worker) { in transition_to_parked()
543 fn maintenance(&mut self, worker: &Worker) { in maintenance()
554 fn pre_shutdown(&mut self, worker: &Worker) { in pre_shutdown()
586 fn drain_pending_drop(&mut self, worker: &Worker) { in drain_pending_drop()
605 impl Worker { impl
607 fn inject(&self) -> &queue::Inject<Arc<Worker>> { in inject()
[all …]
/external/caliper/caliper/src/main/java/com/google/caliper/worker/
DWorker.java30 public abstract class Worker { class
42 protected Worker(Object benchmark, Method method) { in Worker() method in Worker
/external/perfetto/src/trace_processor/importers/ninja/
Dninja_log_parser.cc143 struct Worker { in NotifyEndOfFile() struct
144 int64_t busy_until; in NotifyEndOfFile()
145 TrackId track_id; in NotifyEndOfFile()
/external/tensorflow/tensorflow/core/data/service/
Ddispatcher_state.h73 struct Worker { struct
74 explicit Worker(const std::string& address, in Worker() argument
78 const std::string address;
79 const std::string transfer_address;
/external/google-benchmark/test/
Dinternal_threading_test.cc80 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/
DParallelTest.java47 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/gpu/
Dmod.rs677 struct Worker { struct
690 impl Worker { argument
/external/crosvm/devices/src/virtio/input/
Dmod.rs342 struct Worker<T: EventSource> { struct
350 impl<T: EventSource> Worker<T> { argument
/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/
DSpanExporterImpl.java107 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/cpython2/Lib/test/
Dthreaded_import_hangers.py21 class Worker(threading.Thread): class
/external/python/cpython3/Lib/test/test_importlib/
Dthreaded_import_hangers.py21 class Worker(threading.Thread): class
/external/perfetto/test/stress_test/
Dstress_producer.cc52 class Worker { class in perfetto::__anon2202aaec0111::StressTestDataSource
54 explicit Worker(uint32_t id) : id_(id) {} in Worker() function in perfetto::__anon2202aaec0111::StressTestDataSource::Worker
/external/rust/crates/crossbeam-deque/src/
Ddeque.rs191 pub struct Worker<T> { struct
205 unsafe impl<T: Send> Send for Worker<T> {} argument
207 impl<T> Worker<T> { implementation
538 impl<T> fmt::Debug for Worker<T> { implementation
/external/drm_hwcomposer/utils/
DWorker.cpp24 Worker::Worker(const char *name, int priority) in Worker() function in android::Worker

123