Searched refs:events (Results 1 – 8 of 8) sorted by relevance
| /DragonOS-0.1.9/tools/debugging/logmonitor/src/ |
| D | main.rs | 42 let events = EventHandler::new(250); in start_headless_app() localVariable
43 let _app_backend = logmonitor::backend::AppBackend::new(cmdargs.clone(), events.sender()); in start_headless_app()
46 match events.next()? { in start_headless_app()
74 let events = EventHandler::new(250); in start_tui_app() localVariable
75 let mut tui = Tui::new(terminal, events); in start_tui_app()
77 let _app_backend = logmonitor::backend::AppBackend::new(cmdargs.clone(), tui.events.sender()); in start_tui_app()
84 match tui.events.next()? { in start_tui_app()
|
| D | tui.rs | 21 pub events: EventHandler, field
26 pub fn new(terminal: Terminal<B>, events: EventHandler) -> Self { in new()
27 Self { terminal, events } in new()
|
| /DragonOS-0.1.9/kernel/src/net/event_poll/ |
| D | mod.rs | 85 events: EPollEvent, in new()
91 event: RwLock::new(events), in new()
119 if let Ok(events) = file.unwrap().lock_irqsave().poll() { in ep_item_poll()
120 let events = events as u32 & self.event.read().events; in ep_item_poll() localVariable
121 return EPollEventType::from_bits_truncate(events); in ep_item_poll()
289 epds.events &= !EPollEventType::EPOLLWAKEUP.bits(); in do_epoll_ctl()
292 let events = EPollEventType::from_bits_truncate(epds.events); in do_epoll_ctl() localVariable
301 if op != EPollCtlOption::EpollCtlDel && events.contains(EPollEventType::EPOLLEXCLUSIVE) { in do_epoll_ctl()
309 || !events in do_epoll_ctl()
371 if ep_item.event.read().events & EPollEventType::EPOLLEXCLUSIVE.bits() != 0 { in do_epoll_ctl()
[all …]
|
| D | syscall.rs | 35 events: VirtAddr, in epoll_wait()
57 events.as_ptr::<EPollEvent>(), in epoll_wait()
|
| /DragonOS-0.1.9/kernel/src/libs/ |
| D | wait_queue.rs | 293 pub fn sleep(&self, events: u64) { in sleep()
299 guard.push((events, ProcessManager::current_pcb())); in sleep()
304 pub unsafe fn sleep_without_schedule(&self, events: u64) { in sleep_without_schedule()
310 guard.push((events, ProcessManager::current_pcb())); in sleep_without_schedule()
314 pub fn sleep_unlock_spinlock<T>(&self, events: u64, to_unlock: SpinLockGuard<T>) { in sleep_unlock_spinlock()
322 guard.push((events, ProcessManager::current_pcb())); in sleep_unlock_spinlock()
334 pub fn wakeup_any(&self, events: u64) -> usize { in wakeup_any()
339 if *es & events > 0 { in wakeup_any()
360 pub fn wakeup(&self, events: u64) -> usize { in wakeup()
364 if *es == events { in wakeup()
|
| /DragonOS-0.1.9/kernel/src/net/ |
| D | net_core.rs | 201 let mut events = in send_event() localVariable
211 .wakeup_any(events); in send_event()
216 events |= TcpSocket::CAN_ACCPET; in send_event()
219 events |= TcpSocket::CAN_CONNECT; in send_event()
225 .wakeup_any(events); in send_event()
235 EPollEventType::from_bits_truncate(events as u32), in send_event()
|
| /DragonOS-0.1.9/kernel/src/net/socket/ |
| D | mod.rs | 356 let events = self.0.lock_irqsave().poll(); in poll() localVariable
357 return Ok(events.bits() as usize); in poll()
422 events: u64, in sleep()
430 .sleep_without_schedule(events) in sleep()
793 let mut events = EPollEventType::empty(); in tcp_poll() localVariable
795 events.insert(EPollEventType::EPOLLIN | EPollEventType::EPOLLRDNORM); in tcp_poll()
796 return events; in tcp_poll()
801 events.insert(EPollEventType::EPOLLHUP) in tcp_poll()
804 events.insert( in tcp_poll()
813 events.insert(EPollEventType::EPOLLIN | EPollEventType::EPOLLRDNORM); in tcp_poll()
[all …]
|
| /DragonOS-0.1.9/kernel/src/ipc/ |
| D | pipe.rs | 62 let mut events = EPollEventType::empty(); in poll() localVariable
73 events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLRDNORM); in poll()
78 events.insert(EPollEventType::EPOLLHUP) in poll()
85 events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLWRNORM); in poll()
90 events.insert(EPollEventType::EPOLLERR); in poll()
94 Ok(events.bits() as usize) in poll()
|