| /external/crosvm/devices/src/virtio/ |
| D | rng.rs | 80 fn run(&mut self, queue_evt: EventFd, kill_evt: EventFd) { in run()
94 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
140 kill_evt: Option<EventFd>, field
149 kill_evt: None, in new()
157 if let Some(kill_evt) = self.kill_evt.take() { in drop()
159 let _ = kill_evt.write(1); in drop()
196 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
203 self.kill_evt = Some(self_kill_evt); in activate()
220 worker.run(queue_evts.remove(0), kill_evt); in activate()
|
| D | tpm.rs | 36 kill_evt: EventFd, field
148 .and_then(|pc| pc.add(&self.kill_evt, Token::Kill).and(Ok(pc))) in run()
195 kill_evt: Option<EventFd>, field
202 kill_evt: None, in new()
209 if let Some(kill_evt) = self.kill_evt.take() { in drop()
210 let _ = kill_evt.write(1); in drop()
253 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
260 self.kill_evt = Some(self_kill_evt); in activate()
269 kill_evt, in activate()
|
| D | balloon.rs | 133 fn run(&mut self, mut queue_evts: Vec<EventFd>, kill_evt: EventFd) { in run()
157 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
234 kill_evt: Option<EventFd>, field
246 kill_evt: None, in new()
255 if let Some(kill_evt) = self.kill_evt.take() { in drop()
257 let _ = kill_evt.write(1); in drop()
331 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
338 self.kill_evt = Some(self_kill_evt); in activate()
355 worker.run(queue_evts, kill_evt); in activate()
|
| D | p9.rs | 251 fn run(&mut self, queue_evt: EventFd, kill_evt: EventFd) -> P9Result<()> { in run()
268 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
296 kill_evt: Option<EventFd>, field
322 kill_evt: None, in new()
388 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
395 self.kill_evt = Some(self_kill_evt); in activate()
411 worker.run(queue_evts.remove(0), kill_evt) in activate()
424 if let Some(kill_evt) = self.kill_evt.take() { in drop()
425 if let Err(e) = kill_evt.write(1) { in drop()
|
| D | net.rs | 238 kill_evt: EventFd, in run()
262 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
314 kill_evt: EventFd, field
358 let kill_evt = EventFd::new().map_err(NetError::CreateKillEventFd)?; in from() localVariable
360 workers_kill_evt: Some(kill_evt.try_clone().map_err(NetError::CloneKillEventFd)?), in from()
361 kill_evt, in from()
419 let _ = self.kill_evt.write(1); in drop()
483 if let Some(kill_evt) = self.workers_kill_evt.take() { in activate()
507 let result = worker.run(rx_queue_evt, tx_queue_evt, kill_evt); in activate()
|
| D | pmem.rs | 193 fn run(&mut self, queue_evt: EventFd, kill_evt: EventFd) { in run()
207 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
275 if let Some(kill_evt) = self.kill_event.take() { in drop()
277 let _ = kill_evt.write(1); in drop()
|
| D | block.rs | 754 kill_evt: EventFd, in run()
783 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
865 kill_evt: Option<EventFd>, field
918 kill_evt: None, in new()
930 if let Some(kill_evt) = self.kill_evt.take() { in drop()
932 let _ = kill_evt.write(1); in drop()
996 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
1003 self.kill_evt = Some(self_kill_evt); in activate()
1023 worker.run(queue_evts.remove(0), kill_evt, control_socket); in activate()
|
| D | wl.rs | 1522 fn run(&mut self, mut queue_evts: Vec<EventFd>, kill_evt: EventFd) { in run()
1537 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
1676 kill_evt: Option<EventFd>, field
1690 kill_evt: None, in new()
1701 if let Some(kill_evt) = self.kill_evt.take() { in drop()
1703 let _ = kill_evt.write(1); in drop()
1753 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
1760 self.kill_evt = Some(self_kill_evt); in activate()
1782 .run(queue_evts, kill_evt); in activate()
|
| /external/crosvm/devices/src/virtio/vhost/ |
| D | vsock.rs | 26 kill_evt: Option<EventFd>, field
37 let kill_evt = EventFd::new().map_err(Error::CreateKillEventFd)?; in new() localVariable
48 worker_kill_evt: Some(kill_evt.try_clone().map_err(Error::CloneKillEventFd)?), in new()
49 kill_evt: Some(kill_evt), in new()
61 kill_evt: None, in new_for_testing()
79 if let Some(kill_evt) = &self.kill_evt { in drop()
81 let _ = kill_evt.write(1); in drop()
163 if let Some(kill_evt) = self.worker_kill_evt.take() { in activate()
187 worker.run(queue_evts, QUEUE_SIZES, kill_evt, activate_vqs); in activate()
|
| D | net.rs | 29 kill_evt: EventFd, field
50 let kill_evt = EventFd::new().map_err(Error::CreateKillEventFd)?; in new() localVariable
85 workers_kill_evt: Some(kill_evt.try_clone().map_err(Error::CloneKillEventFd)?), in new()
86 kill_evt, in new()
105 let _ = self.kill_evt.write(1); in drop()
180 if let Some(kill_evt) = self.workers_kill_evt.take() { in activate()
203 worker.run(queue_evts, QUEUE_SIZES, kill_evt, activate_vqs); in activate()
|
| D | worker.rs | 60 kill_evt: EventFd, in run()
128 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
|
| /external/crosvm/tests/ |
| D | plugin_irqfd.c | 78 int kill_evt; member
118 write(ctx->kill_evt, &dummy, sizeof(dummy)); in vcpu_thread()
138 int kill_evt = crosvm_get_shutdown_eventfd(crosvm); in main() local
139 if (kill_evt < 0) { in main()
140 fprintf(stderr, "failed to get kill eventfd: %d\n", kill_evt); in main()
196 ctxs[vcpu_count].kill_evt = kill_evt; in main()
206 ret = read(kill_evt, &dummy, sizeof(dummy)); in main()
|
| D | mini_plugin_template.c | 93 int kill_evt = crosvm_get_shutdown_eventfd(crosvm); in main() local
94 if (kill_evt < 0) {{ in main()
95 fprintf(stderr, "failed to get kill eventfd: %d\n", kill_evt); in main()
152 ret = read(kill_evt, &dummy, sizeof(dummy)); in main()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 470 kill_evt: EventFd, in run()
502 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
551 let _ = kill_evt.read(); in run()
571 kill_evt: Option<EventFd>, field
578 if let Some(kill_evt) = self.kill_evt.take() { in drop()
580 let _ = kill_evt.write(1); in drop()
625 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
632 self.kill_evt = Some(self_kill_evt); in activate()
654 worker.run(event_queue_evt_fd, status_queue_evt_fd, kill_evt); in activate()
674 kill_evt: None, in new_evdev()
[all …]
|
| /external/crosvm/devices/src/virtio/gpu/ |
| D | mod.rs | 478 kill_evt: EventFd, field
511 .and_then(|pc| pc.add(&self.kill_evt, Token::Kill).and(Ok(pc))) in run()
608 kill_evt: Option<EventFd>, field
624 kill_evt: None, in new()
645 if let Some(kill_evt) = self.kill_evt.take() { in drop()
647 let _ = kill_evt.write(1); in drop()
733 let (self_kill_evt, kill_evt) = match EventFd::new().and_then(|e| Ok((e.try_clone()?, e))) { in activate()
740 self.kill_evt = Some(self_kill_evt); in activate()
806 kill_evt, in activate()
|
| /external/crosvm/devices/src/ |
| D | pit.rs | 190 kill_evt: EventFd, field
195 if let Err(e) = self.kill_evt.write(1) { in drop()
273 let (self_kill_evt, kill_evt) = EventFd::new() in new()
280 let evt = kill_evt.try_clone().map_err(PitError::CloneEventFd)?; in new()
288 kill_evt: self_kill_evt, in new()
739 fn run(&mut self, kill_evt: EventFd) -> PitResult<()> { in run()
750 .and_then(|pc| pc.add(&kill_evt, Token::Kill).and(Ok(pc))) in run()
|
| /external/crosvm/src/plugin/ |
| D | process.rs | 124 kill_evt: EventFd, field
185 kill_evt: EventFd::new().map_err(Error::CreateEventFd)?, in new()
261 self.kill_evt.write(1)?; in signal_kill()
564 response_fds.push(self.kill_evt.as_raw_fd()); in handle_socket()
|