quentinlegot/burritos
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

synch.rs implemented

Browse Source
This commit is contained in:
Samy Solhi 2023-03-08 16:39:00 +01:00
parent 0f5eb84c7b
commit 82731cabcf
1 changed files with 85 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
src/kernel/synch.rs
View File

@ -1,8 +1,11 @@
use crate::utility::list::List; use crate::utility::list::List;
use crate::kernel::thread::Thread; use crate::kernel::thread::Thread;
use std::rc::Rc;
use crate::simulator::interrupt::InterruptStatus::InterruptOff; use crate::simulator::interrupt::InterruptStatus::InterruptOff;
use crate::simulator::machine::Machine; use crate::simulator::machine::Machine;
use std::rc::Rc;
use super::scheduler::Scheduler;
pub struct Semaphore{ pub struct Semaphore{
@ -23,12 +26,11 @@ impl Semaphore{
machine.interrupt.set_status(old_status); machine.interrupt.set_status(old_status);
} }
pub fn v(&mut self, current_thread:Rc<Thread>, machine: &mut Machine){ pub fn v(&mut self, machine: &mut Machine, scheduler: &mut Scheduler){
let old_status = machine.interrupt.set_status(InterruptOff); let old_status = machine.interrupt.set_status(InterruptOff);
self.counter -= 1; self.counter -= 1;
if self.waiting_queue.peek() == None { if self.waiting_queue.peek() != None {
self.waiting_queue.push(Rc::clone(&current_thread)); scheduler.ready_to_run(self.waiting_queue.pop().unwrap());
current_thread.sleep();
} }
machine.interrupt.set_status(old_status); machine.interrupt.set_status(old_status);
} }
@ -36,8 +38,83 @@ impl Semaphore{
pub struct Lock{ pub struct Lock{
owner: Rc<Thread>,
waiting_queue:List<Rc<Thread>>,
free: bool
}
impl Lock {
pub fn acquire(&mut self, machine: &mut Machine, current_thread: Rc<Thread>) {
let old_status = machine.interrupt.set_status(InterruptOff);
if self.free {
self.free = false;
self.owner = current_thread;
} else {
self.waiting_queue.push(Rc::clone(&current_thread));
current_thread.sleep();
}
machine.interrupt.set_status(old_status);
}
pub fn release(&mut self, machine: &mut Machine, scheduler: &mut Scheduler, current_thread: Rc<Thread>) {
let old_status = machine.interrupt.set_status(InterruptOff);
if self.is_held_by_current_thread(current_thread) {
if self.waiting_queue.peek() != None {
self.owner = self.waiting_queue.pop().unwrap();
scheduler.ready_to_run(Rc::clone(&self.owner));
} else {
self.free = true;
}
}
machine.interrupt.set_status(old_status);
}
pub fn is_held_by_current_thread(&mut self, current_thread: Rc<Thread>) -> bool {
Rc::ptr_eq(&self.owner, &current_thread)
}
} }
pub struct Condition{ pub struct Condition{
waiting_queue:List<Rc<Thread>>
}
impl Condition {
pub fn wait(&mut self, machine: &mut Machine, current_thread: Rc<Thread>) {
let old_status = machine.interrupt.set_status(InterruptOff);
self.waiting_queue.push(Rc::clone(&current_thread));
current_thread.sleep();
machine.interrupt.set_status(old_status);
}
pub fn signal(&mut self, machine: &mut Machine, scheduler: &mut Scheduler) {
let old_status = machine.interrupt.set_status(InterruptOff);
if self.waiting_queue.peek() != None {
scheduler.ready_to_run(self.waiting_queue.pop().unwrap());
}
machine.interrupt.set_status(old_status);
}
pub fn broadcast(&mut self, machine: &mut Machine, scheduler: &mut Scheduler) {
let old_status = machine.interrupt.set_status(InterruptOff);
while self.waiting_queue.peek() != None {
scheduler.ready_to_run(self.waiting_queue.pop().unwrap());
}
machine.interrupt.set_status(old_status);
}
} }