| /external/crosvm/devices/src/virtio/fs/ |
| D | worker.rs | 48 tube: Arc<Mutex<Tube>>, field
53 fn new(tube: Arc<Mutex<Tube>>, slot: u32) -> Self { in new()
54 Self { tube, slot } in new()
58 let tube = self.tube.lock().map_err(|e| { in process_request() localVariable
63 tube.send(request).map_err(|e| { in process_request()
68 match tube.recv() { in process_request()
132 tube: Arc<Mutex<Tube>>, field
142 tube: Arc<Mutex<Tube>>, in new()
150 tube, in new()
158 let mapper = Mapper::new(Arc::clone(&self.tube), self.slot); in process_queue()
|
| D | mod.rs | 135 tube: Option<Tube>, field
145 tube: Tube, in new()
171 tube: Some(tube), in new()
203 if let Some(rd) = self.tube.as_ref().map(|s| s.as_raw_descriptor()) { in keep_rds()
253 let socket = self.tube.take().expect("missing mapping socket"); in activate()
|
| /external/crosvm/devices/src/ |
| D | bat.rs | 108 tube: Option<Tube>, field
145 tube: Tube, in command_monitor()
153 (&Descriptor(tube.as_raw_descriptor()), Token::Commands), in command_monitor()
204 let req = match tube.recv() { in command_monitor()
234 if let Err(e) = tube.send(&BatControlResult::Ok) { in command_monitor()
311 tube: Tube, in new()
340 tube: Some(tube), in new()
352 if let Some(tube) = &self.tube { in keep_rds()
353 rds.push(tube.as_raw_descriptor()); in keep_rds()
377 if let Some(tube) = self.tube.take() { in start_monitor()
[all …]
|
| D | proxy.rs | 71 fn child_proc<D: BusDevice>(tube: Tube, device: &mut D) { in child_proc()
75 let cmd = match tube.recv() { in child_proc()
87 tube.send(&CommandResult::ReadResult(buffer)) in child_proc()
97 tube.send(&CommandResult::ReadConfigResult(val)) in child_proc()
108 tube.send(&CommandResult::WriteConfigResult { in child_proc()
115 tube.send(&CommandResult::Ok) in child_proc()
129 tube: Tube, field
186 tube: parent_tube, in new()
198 let res = self.tube.send(cmd); in send_no_result()
210 match self.tube.recv() { in sync_send()
|
| /external/crosvm/devices/src/virtio/ |
| D | resource_bridge.rs | 90 tube: &Tube, in get_resource_info()
93 if let Err(e) = tube.send(&request) { in get_resource_info()
97 match tube.recv() { in get_resource_info()
|
| /external/crosvm/base/src/ |
| D | lib.rs | 13 mod tube; module
32 pub use tube::{AsyncTube, Error as TubeError, Result as TubeResult, Tube};
|
| /external/crosvm/src/ |
| D | linux.rs | 362 Fs(tube) | Vm(tube) | VmMemory(tube) | VmIrq(tube) | VmMsync(tube) => tube, in as_ref()
762 fn create_balloon_device(cfg: &Config, tube: Tube) -> DeviceResult { in create_balloon_device()
763 let dev = virtio::Balloon::new(virtio::base_features(cfg.protected_vm), tube) in create_balloon_device()
2588 for (handle, tube) in vcpu_handles { in kick_all_vcpus()
2589 if let Err(e) = tube.send(VcpuControl::RunState(run_mode.clone())) { in kick_all_vcpus()
3034 TaggedControlTube::Vm(tube) => match tube.recv::<VmRequest>() { in run_control()
3044 if let Err(e) = tube.send(&response) { in run_control()
3074 TaggedControlTube::VmMemory(tube) => { in run_control()
3075 match tube.recv::<VmMemoryRequest>() { in run_control()
3083 if let Err(e) = tube.send(&response) { in run_control()
[all …]
|
| /external/crosvm/devices/src/usb/host_backend/ |
| D | host_backend_device_provider.rs | 256 let tube = self.control_tube.lock(); in on_event_helper() localVariable
257 let cmd = tube.recv().map_err(Error::ReadControlTube)?; in on_event_helper()
263 tube.send(&result).map_err(Error::WriteControlTube)?; in on_event_helper()
|
| /external/icu/icu4j/demos/src/com/ibm/icu/dev/demo/translit/resources/ |
| D | Transliterator_Kanji_English.txt | 2402 #"梘>'[bamboo tube]'",
|
| /external/icu/icu4j/main/shared/data/ |
| D | Transliterator_Han_Latin_Definition.txt | 885 㻶 < a\-jade\-tube\-with\-white\-and\-nature\-colors;
1520 琯 < a\-jade\-tube\-used\-as\-an\-instrument;
3108 籝 < a\-tube\-to\-hold\-chopsticks;
11017 梘 < bamboo\-tube;
36582 㻶 > a\-jade\-tube\-with\-white\-and\-nature\-colors;
36952 琯 > a\-jade\-tube\-used\-as\-an\-instrument;
38109 籝 > a\-tube\-to\-hold\-chopsticks;
43399 梘 > bamboo\-tube;
43404 枧 > bamboo\-tube;
|
| /external/selinux/policycoreutils/po/ |
| D | fr.po | 2172 "tube nommé\n"
|
| /external/libtextclassifier/native/annotator/pod_ner/test_data/ |
| D | vocab.txt | 7271 tube
|
| /external/unicode/ |
| D | emoji-test.txt | 4198 1F9EA ; fully-qualified # �� E11.0 test tube
|
| /external/jline/src/src/test/resources/jline/example/ |
| D | english.gz | |
| /external/cldr/tools/java/org/unicode/cldr/util/data/emoji/ |
| D | emoji-test.txt | 4198 1F9EA ; fully-qualified # �� E11.0 test tube
|
| /external/brotli/tests/testdata/ |
| D | plrabn12.txt | 2528 Through his glazed optick tube yet never saw.
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/resources/ |
| D | ospd.txt.gz | |
| /external/one-true-awk/testdir/ |
| D | funstack.in | 16314 …nds on the shading technique used to paint the objects on the cathode-ray tube screen. The shading…
19766 … arcs can be drawn on an incremental display device such as a cathode ray tube, digital plotter, o…
|