| /DragonOS/kernel/src/net/event_poll/ |
| H A D | mod.rs | 92 events: EPollEvent, in new()
98 event: RwLock::new(events), in new()
126 if let Ok(events) = file.unwrap().poll() { in ep_item_poll()
127 let events = events as u32 & self.event.read().events; in ep_item_poll() localVariable
128 return EPollEventType::from_bits_truncate(events); in ep_item_poll()
302 epds.events &= !EPollEventType::EPOLLWAKEUP.bits(); in do_epoll_ctl()
305 let events = EPollEventType::from_bits_truncate(epds.events); in do_epoll_ctl() localVariable
314 if op != EPollCtlOption::Del && events.contains(EPollEventType::EPOLLEXCLUSIVE) { in do_epoll_ctl()
322 || !events in do_epoll_ctl()
384 if ep_item.event.read().events & EPollEventType::EPOLLEXCLUSIVE.bits() != 0 { in do_epoll_ctl()
[all …]
|
| H A D | syscall.rs | 35 events: VirtAddr, in epoll_wait()
57 events.as_ptr::<EPollEvent>(), in epoll_wait()
|
| /DragonOS/tools/debugging/logmonitor/src/ |
| H A 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()
|
| H A 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/kernel/src/libs/ |
| H A D | wait_queue.rs | 331 pub fn sleep(&self, events: u64) { in sleep()
337 guard.push((events, ProcessManager::current_pcb())); in sleep()
342 pub unsafe fn sleep_without_schedule(&self, events: u64) { in sleep_without_schedule()
348 guard.push((events, ProcessManager::current_pcb())); in sleep_without_schedule()
352 pub fn sleep_unlock_spinlock<T>(&self, events: u64, to_unlock: SpinLockGuard<T>) { in sleep_unlock_spinlock()
360 guard.push((events, ProcessManager::current_pcb())); in sleep_unlock_spinlock()
372 pub fn wakeup_any(&self, events: u64) -> usize { in wakeup_any()
377 if *es & events > 0 { in wakeup_any()
398 pub fn wakeup(&self, events: u64) -> usize { in wakeup()
402 if *es == events { in wakeup()
|
| /DragonOS/kernel/src/net/ |
| H A D | net_core.rs | 210 let mut events = SocketPollMethod::poll(socket_type, handle_item).bits() as u64; in send_event() localVariable
215 posix_item.wakeup_any(events); in send_event()
220 events |= TcpSocket::CAN_ACCPET; in send_event()
223 events |= TcpSocket::CAN_CONNECT; in send_event()
226 events |= EPollEventType::EPOLLHUP.bits() as u64; in send_event()
229 posix_item.wakeup_any(events); in send_event()
236 EPollEventType::from_bits_truncate(events as u32), in send_event()
|
| /DragonOS/kernel/src/net/socket/ |
| H A D | mod.rs | 373 let events = self.0.lock_irqsave().poll(); in poll() localVariable
374 return Ok(events.bits() as usize); in poll()
420 pub fn sleep(&self, events: u64) { in sleep()
423 self.wait_queue.sleep_without_schedule(events); in sleep()
454 pub fn wakeup_any(&self, events: u64) { in wakeup_any()
455 self.wait_queue.wakeup_any(events); in wakeup_any()
798 let mut events = EPollEventType::empty(); in tcp_poll() localVariable
804 events.insert(EPollEventType::EPOLL_LISTEN_CAN_ACCEPT); in tcp_poll()
808 return events; in tcp_poll()
814 events.insert(EPollEventType::EPOLLHUP); in tcp_poll()
[all …]
|
| /DragonOS/kernel/src/filesystem/ |
| H A D | eventfd.rs | 195 let mut events = EPollEventType::empty(); in poll() localVariable
197 events |= EPollEventType::EPOLLIN | EPollEventType::EPOLLRDNORM; in poll()
200 events |= EPollEventType::EPOLLOUT | EPollEventType::EPOLLWRNORM; in poll()
202 return Ok(events.bits() as usize); in poll()
|
| /DragonOS/kernel/src/ipc/ |
| H A D | pipe.rs | 67 let mut events = EPollEventType::empty(); in poll() localVariable
78 events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLRDNORM); in poll()
83 events.insert(EPollEventType::EPOLLHUP) in poll()
90 events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLWRNORM); in poll()
95 events.insert(EPollEventType::EPOLLERR); in poll()
99 Ok(events.bits() as usize) in poll()
|