use alloc::sync::Arc; use core::sync::atomic::{AtomicUsize, Ordering}; use hashbrown::HashMap; use spin::{Once, RwLock, RwLockReadGuard, RwLockWriteGuard}; use crate::{ context, scheme::{self, SchemeId}, sync::WaitQueue, syscall::{ data::Event, error::{Error, Result, EBADF, ESRCH}, flag::EventFlags, usercopy::UserSliceWo, }, }; int_like!(EventQueueId, AtomicEventQueueId, usize, AtomicUsize); pub struct EventQueue { id: EventQueueId, queue: WaitQueue, } impl EventQueue { pub fn new(id: EventQueueId) -> EventQueue { EventQueue { id, queue: WaitQueue::new(), } } pub fn read(&self, buf: UserSliceWo, block: bool) -> Result { self.queue.receive_into_user(buf, block, "EventQueue::read") } pub fn write(&self, events: &[Event]) -> Result { for event in events { let file = { let contexts = context::contexts(); let context_lock = contexts.current().ok_or(Error::new(ESRCH))?; let context = context_lock.read(); let files = context.files.read(); match files.get(event.id).ok_or(Error::new(EBADF))? { Some(file) => file.clone(), None => return Err(Error::new(EBADF)), } }; let (scheme, number) = { let description = file.description.read(); (description.scheme, description.number) }; register( RegKey { scheme, number }, QueueKey { queue: self.id, id: event.id, data: event.data, }, event.flags, ); let flags = sync(RegKey { scheme, number })?; if !flags.is_empty() { trigger(scheme, number, flags); } } Ok(events.len()) } } pub type EventQueueList = HashMap>; // Next queue id static NEXT_QUEUE_ID: AtomicUsize = AtomicUsize::new(0); /// Get next queue id pub fn next_queue_id() -> EventQueueId { EventQueueId::from(NEXT_QUEUE_ID.fetch_add(1, Ordering::SeqCst)) } // Current event queues static QUEUES: Once> = Once::new(); /// Initialize queues, called if needed fn init_queues() -> RwLock { RwLock::new(HashMap::new()) } /// Get the event queues list, const pub fn queues() -> RwLockReadGuard<'static, EventQueueList> { QUEUES.call_once(init_queues).read() } /// Get the event queues list, mutable pub fn queues_mut() -> RwLockWriteGuard<'static, EventQueueList> { QUEUES.call_once(init_queues).write() } #[derive(Debug, PartialEq, Eq, Hash, PartialOrd, Ord)] pub struct RegKey { pub scheme: SchemeId, pub number: usize, } #[derive(Debug, PartialEq, Eq, Hash, PartialOrd, Ord)] pub struct QueueKey { pub queue: EventQueueId, pub id: usize, pub data: usize, } type Registry = HashMap>; static REGISTRY: Once> = Once::new(); /// Initialize registry, called if needed fn init_registry() -> RwLock { RwLock::new(Registry::new()) } /// Get the global schemes list, const fn registry() -> RwLockReadGuard<'static, Registry> { REGISTRY.call_once(init_registry).read() } /// Get the global schemes list, mutable pub fn registry_mut() -> RwLockWriteGuard<'static, Registry> { REGISTRY.call_once(init_registry).write() } pub fn register(reg_key: RegKey, queue_key: QueueKey, flags: EventFlags) { let mut registry = registry_mut(); let entry = registry.entry(reg_key).or_insert_with(|| HashMap::new()); if flags.is_empty() { entry.remove(&queue_key); } else { entry.insert(queue_key, flags); } } pub fn sync(reg_key: RegKey) -> Result { let mut flags = EventFlags::empty(); { let registry = registry(); if let Some(queue_list) = registry.get(®_key) { for (_queue_key, &queue_flags) in queue_list.iter() { flags |= queue_flags; } } } let scheme = scheme::schemes() .get(reg_key.scheme) .ok_or(Error::new(EBADF))? .clone(); scheme.fevent(reg_key.number, flags) } pub fn unregister_file(scheme: SchemeId, number: usize) { let mut registry = registry_mut(); registry.remove(&RegKey { scheme, number }); } //TODO: Implement unregister_queue // pub fn unregister_queue(scheme: SchemeId, number: usize) { // // } pub fn trigger(scheme: SchemeId, number: usize, flags: EventFlags) { let registry = registry(); if let Some(queue_list) = registry.get(&RegKey { scheme, number }) { for (queue_key, &queue_flags) in queue_list.iter() { let common_flags = flags & queue_flags; if !common_flags.is_empty() { let queues = queues(); if let Some(queue) = queues.get(&queue_key.queue) { queue.queue.send(Event { id: queue_key.id, flags: common_flags, data: queue_key.data, }); } } } } }