lisk77/comet
1
0
Fork 0
mirror of https://github.com/lisk77/comet.git synced 2025-10-23 21:38:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(ecs): added safety boundaries to the IdQueue

Browse source
This commit is contained in:
lisk77 2025-07-21 03:01:40 +02:00
parent 7cf9f5bd29
commit 88fda5c654
1 changed files with 32 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

59
crates/comet_ecs/src/id.rs
View file

@ -1,40 +1,45 @@
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
pub struct IdQueue { pub struct IdQueue {
queue: Vec<u32> queue: Vec<u32>,
} }
impl IdQueue { impl IdQueue {
pub fn new() -> Self { pub fn new() -> Self {
Self { queue: Vec::new() } Self { queue: Vec::new() }
} }
pub fn from_vec(queue: Vec<u32>) -> Self { pub fn from_vec(queue: Vec<u32>) -> Self {
Self { queue } Self { queue }
} }
pub fn front(&self) -> Option<u32> { pub fn front(&self) -> Option<u32> {
Some(self.queue[0]) if self.queue.len() > 0 {
} return Some(self.queue[0]);
}
None
}
pub fn enqueue(&mut self, id: u32) { pub fn enqueue(&mut self, id: u32) {
self.queue.push(id) self.queue.push(id)
} }
pub fn sorted_enqueue(&mut self, id: u32) { pub fn sorted_enqueue(&mut self, id: u32) {
self.enqueue(id); self.enqueue(id);
self.queue.sort(); self.queue.sort();
} }
pub fn dequeue(&mut self) -> Option<u32> { pub fn dequeue(&mut self) -> Option<u32> {
Some(self.queue.remove(0)) if self.queue.len() > 0 {
return Some(self.queue.remove(0));
}
None
}
} pub fn is_empty(&self) -> bool {
self.queue.len() == 0
}
pub fn is_empty(&self) -> bool { pub fn size(&self) -> u32 {
self.queue.len() == 0 self.queue.len() as u32
} }
pub fn size(&self) -> u32 {
self.queue.len() as u32
}
} }