123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384 |
- #include <common/wait_queue.h>
- #include <sched/sched.h>
- #include <process/process.h>
- #include <mm/slab.h>
- #include <common/spinlock.h>
- void wait_queue_init(wait_queue_node_t *wait_queue, struct process_control_block *pcb)
- {
- list_init(&wait_queue->wait_list);
- wait_queue->pcb = pcb;
- }
- void wait_queue_sleep_on(wait_queue_node_t *wait_queue_head)
- {
- wait_queue_node_t *wait = (wait_queue_node_t *)kmalloc(sizeof(wait_queue_node_t), 0);
- wait_queue_init(wait, current_pcb);
- current_pcb->state = PROC_UNINTERRUPTIBLE;
- list_append(&wait_queue_head->wait_list, &wait->wait_list);
- sched();
- }
- void wait_queue_sleep_on_unlock(wait_queue_node_t *wait_queue_head,
- void *lock)
- {
- wait_queue_node_t *wait = (wait_queue_node_t *)kmalloc(sizeof(wait_queue_node_t), 0);
- wait_queue_init(wait, current_pcb);
- current_pcb->state = PROC_UNINTERRUPTIBLE;
- list_append(&wait_queue_head->wait_list, &wait->wait_list);
- spin_unlock((spinlock_t *)lock);
- sched();
- }
- void wait_queue_sleep_on_interriptible(wait_queue_node_t *wait_queue_head)
- {
- wait_queue_node_t *wait = (wait_queue_node_t *)kmalloc(sizeof(wait_queue_node_t), 0);
- wait_queue_init(wait, current_pcb);
- current_pcb->state = PROC_INTERRUPTIBLE;
- list_append(&wait_queue_head->wait_list, &wait->wait_list);
- sched();
- }
- void wait_queue_wakeup(wait_queue_node_t *wait_queue_head, int64_t state)
- {
- if (list_empty(&wait_queue_head->wait_list))
- return;
- wait_queue_node_t *wait = container_of(list_next(&wait_queue_head->wait_list), wait_queue_node_t, wait_list);
-
- if (wait->pcb->state & state)
- {
- list_del(&wait->wait_list);
- process_wakeup(wait->pcb);
- kfree(wait);
- }
- }
|