summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFreya Murphy <freya@freyacat.org>2025-04-21 21:57:16 -0400
committerFreya Murphy <freya@freyacat.org>2025-04-21 21:57:16 -0400
commit6911434dc4b98d5939caf3aad5fafdf369f56a55 (patch)
tree9bf6e1a95608dfa8177f9a189d7474b895cc7efb
parentupdate userland to compile (diff)
downloadcomus-6911434dc4b98d5939caf3aad5fafdf369f56a55.tar.gz
comus-6911434dc4b98d5939caf3aad5fafdf369f56a55.tar.bz2
comus-6911434dc4b98d5939caf3aad5fafdf369f56a55.zip
make somce changes to procs
-rw-r--r--Makefile2
-rw-r--r--kernel/include/comus/procs.h155
-rw-r--r--kernel/main.c4
-rw-r--r--kernel/procs.c499
4 files changed, 101 insertions, 559 deletions
diff --git a/Makefile b/Makefile
index b87410f..c3643a9 100644
--- a/Makefile
+++ b/Makefile
@@ -40,7 +40,7 @@ UNAME := $(shell uname)
QEMU = qemu-system-x86_64
QEMUOPTS = -cdrom $(BIN)/$(ISO) \
-no-reboot \
- -drive format=raw,file=$(BIN)/$(IMAGE)\
+ -drive format=raw,file=$(BIN)/user/hello\
-serial mon:stdio \
-m 4G \
-name kern
diff --git a/kernel/include/comus/procs.h b/kernel/include/comus/procs.h
index 2c40f5a..80c4fe4 100644
--- a/kernel/include/comus/procs.h
+++ b/kernel/include/comus/procs.h
@@ -14,6 +14,16 @@
#include <comus/memory.h>
#include <lib.h>
+#define PCB_REG(pcb, x) ((pcb)->regs->x)
+#define PCB_RET(pcb) ((pcb)->regs->rax)
+#define PCB_ARG1(pcb) PCB_REG((pcb), rdi)
+#define PCB_ARG2(pcb) PCB_REG((pcb), rsi)
+#define PCB_ARG3(pcb) PCB_REG((pcb), rdx)
+#define PCB_ARG4(pcb) PCB_REG((pcb), rcx)
+
+/// process id
+typedef unsigned short pid_t;
+
/// process states
enum proc_state {
// pre-viable
@@ -33,71 +43,27 @@ enum proc_state {
N_PROC_STATES,
};
-/// process priority
-enum proc_priority {
- PROC_PRIO_HIGH,
- PROC_PRIO_STD,
- PROC_PRIO_LOW,
- PROC_PRIO_DEFERRED,
- // sentinel
- N_PROC_PRIOS,
-};
-
-/// process quantum length
-/// values are number of clock ticks
-enum proc_quantum {
- PROC_QUANTUM_SHORT = 1,
- PROC_QUANTUM_STANDARD = 3,
- PROC_QUANTUM_LONG = 5,
-};
-
-/// program section information
-struct proc_section {
- uint64_t length;
- uint64_t addr;
-};
-
-#define SECT_L1 0
-#define SECT_L2 1
-#define SECT_L3 2
-#define SECT_STACK 3
-#define N_SECTS 4
-#define N_LOADABLE 3
-
-/// pid type
-typedef unsigned short pid_t;
-
/// process control block
struct pcb {
- // process context
+ // metadata
+ pid_t pid;
+ struct pcb *parent;
+ enum proc_state state;
+ size_t priority;
+ size_t ticks;
+
+ // context
mem_ctx_t memctx;
struct cpu_regs *regs;
- // vm information
- struct proc_section sects[N_SECTS];
-
// queue linkage
struct pcb *next; // next PDB in queue
// process state information
- struct pcb *parent; // pointer to PCB of our parent process
- uint64_t wakeup; // wakeup time, for sleeping processes
- uint8_t exit_status; // termination status, for parent's use
-
- // process metadata
- pid_t pid; // pid of this process
- enum proc_state state; // process' current state
- enum proc_priority priority; // process priority level
- size_t ticks; // remaining ticks in this time slice
+ uint64_t wakeup;
+ uint8_t exit_status;
};
-#define PCB_REG(pcb, x) ((pcb)->regs->x)
-#define PCB_RET(pcb) ((pcb)->regs->rax)
-#define PCB_ARG(pcb, n) (((uint64_t *)(((pcb)->regs) + 1))[(n)])
-
-/// pcb queue structure
-typedef struct pcb_queue_s *pcb_queue_t;
-
/// ordering of pcb queues
enum pcb_queue_order {
O_PCB_FIFO,
@@ -108,6 +74,9 @@ enum pcb_queue_order {
N_PCB_ORDERINGS,
};
+/// pcb queue structure
+typedef struct pcb_queue_s *pcb_queue_t;
+
/// public facing pcb queues
extern pcb_queue_t pcb_freelist;
extern pcb_queue_t ready;
@@ -116,51 +85,40 @@ extern pcb_queue_t sleeping;
extern pcb_queue_t zombie;
/// pointer to the currently-running process
-extern struct pcb *current;
-
+extern struct pcb *current_pcb;
+/// pointer to the pcb for the 'init' process
+extern struct pcb *init_pcb;
/// the process table
extern struct pcb ptable[N_PROCS];
/// next avaliable pid
extern pid_t next_pid;
-/// pointer to the pcb for the 'init' process
-extern struct pcb *init_pcb;
-
-/// table of state name strings
-extern const char *proc_state_str[N_PROC_STATES];
-
-/// table of priority name strings
-extern const char *proc_prio_str[N_PROC_PRIOS];
-
-/// table of queue ordering name strings
-extern const char *pcb_ord_str[N_PCB_ORDERINGS];
-
/**
* Initialization for the process module
*/
void pcb_init(void);
/**
- * Allocate a PCB from the list of free PCBs
+ * allocate a PCB from the free list
+ *
+ * @returns 0 on success or non zero error code
*/
int pcb_alloc(struct pcb **pcb);
/**
- * Return a PCB to the list of free PCBs.
+ * free an allocted PCB back to the free list
*
- * @param pcb Pointer to the PCB to be deallocated.
+ * @param pcb - pointer to the PCB to be deallocated
*/
void pcb_free(struct pcb *pcb);
/**
- * Turn the indicated process into a Zombie. This function
- * does most of the real work for exit() and kill() calls.
- * Is also called from the scheduler and dispatcher.
+ * turn the indicated process into a zombie
*
* @param pcb - pointer to the newly-undead PCB
*/
-void pcb_zombify(register struct pcb *victim);
+void pcb_zombify(struct pcb *victim);
/**
* Reclaim a process' data structures
@@ -260,51 +218,4 @@ void schedule(struct pcb *pcb);
*/
void dispatch(void);
-/**
- * Dumps the contents of this process context to the console
- *
- * @param msg[in] An optional message to print before the dump
- * @param c[in] The context to dump out
- */
-void ctx_dump(const char *msg, register struct cpu_regs *c);
-
-/**
- * dump the process context for all active processes
- *
- * @param msg[in] Optional message to print
- */
-void ctx_dump_all(const char *msg);
-
-/**
- * Dumps the contents of this PCB to the console
- *
- * @param msg[in] An optional message to print before the dump
- * @param p[in] The PCB to dump
- * @param all[in] Dump all the contents?
- */
-void pcb_dump(const char *msg, register struct pcb *p, bool all);
-
-/**
- * Dump the contents of the specified queue to the console
- *
- * @param msg[in] An optional message to print before the dump
- * @param queue[in] The queue to dump
- * @param contents[in] Also dump (some) contents?
- */
-void pcb_queue_dump(const char *msg, pcb_queue_t queue, bool contents);
-
-/**
- * dump the contents of the "active processes" table
- *
- * @param msg[in] Optional message to print
- * @param all[in] Dump all or only part of the relevant data
- */
-void ptable_dump(const char *msg, bool all);
-
-/**
- * Prints basic information about the process table (number of
- * entries, number with each process state, etc.).
- */
-void ptable_dump_counts(void);
-
#endif /* procs.h */
diff --git a/kernel/main.c b/kernel/main.c
index 4953940..4047a64 100644
--- a/kernel/main.c
+++ b/kernel/main.c
@@ -8,6 +8,7 @@
#include <comus/drivers/gpu.h>
#include <comus/drivers/ata.h>
#include <comus/fs.h>
+#include <comus/procs.h>
#include <lib.h>
void kreport(void)
@@ -40,6 +41,9 @@ void main(long magic, volatile void *mboot)
// load file systems
fs_init();
+ // initalize processes
+ pcb_init();
+
// report system state
kreport();
diff --git a/kernel/procs.c b/kernel/procs.c
index f97d358..98cc818 100644
--- a/kernel/procs.c
+++ b/kernel/procs.c
@@ -1,3 +1,4 @@
+#include "lib/klib.h"
#include <comus/procs.h>
#include <comus/error.h>
#include <comus/cpu.h>
@@ -25,74 +26,25 @@ pcb_queue_t waiting;
pcb_queue_t sleeping;
pcb_queue_t zombie;
-// pointer to the currently-running process
-struct pcb *current;
-
/// pointer to the currently-running process
-struct pcb *current;
+struct pcb *current_pcb = NULL;
+
+/// pointer to the pcb for the 'init' process
+struct pcb *init_pcb = NULL;
/// the process table
struct pcb ptable[N_PROCS];
/// next avaliable pid
-pid_t next_pid;
-
-/// pointer to the pcb for the 'init' process
-struct pcb *init_pcb;
-
-/// table of state name strings
-const char *proc_state_str[N_PROC_STATES] = {
- [PROC_STATE_UNUSED] = "Unu", [PROC_STATE_NEW] = "New",
- [PROC_STATE_READY] = "Rdy", [PROC_STATE_RUNNING] = "Run",
- [PROC_STATE_SLEEPING] = "Slp", [PROC_STATE_BLOCKED] = "Blk",
- [PROC_STATE_WAITING] = "Wat", [PROC_STATE_KILLED] = "Kil",
- [PROC_STATE_ZOMBIE] = "Zom",
-};
-
-/// table of priority name strings
-const char *proc_prio_str[N_PROC_PRIOS] = {
- [PROC_PRIO_HIGH] = "High",
- [PROC_PRIO_STD] = "User",
- [PROC_PRIO_LOW] = "Low ",
- [PROC_PRIO_DEFERRED] = "Def ",
-};
-
-/// table of queue ordering name strings
-const char *pcb_ord_str[N_PCB_ORDERINGS] = {
- [O_PCB_FIFO] = "FIFO",
- [O_PCB_PRIO] = "PRIO",
- [O_PCB_PID] = "PID ",
- [O_PCB_WAKEUP] = "WAKE",
-};
+pid_t next_pid = 0;
-/**
- * Priority search functions. These are used to traverse a supplied
- * queue looking for the queue entry that would precede the supplied
- * PCB when that PCB is inserted into the queue.
- *
- * Variations:
- * find_prev_wakeup() compares wakeup times
- * find_prev_priority() compares process priorities
- * find_prev_pid() compares PIDs
- *
- * Each assumes the queue should be in ascending order by the specified
- * comparison value.
- *
- * @param[in] queue The queue to search
- * @param[in] pcb The PCB to look for
- *
- * @return a pointer to the predecessor in the queue, or NULL if
- * this PCB would be at the beginning of the queue.
- */
static struct pcb *find_prev_wakeup(pcb_queue_t queue, struct pcb *pcb)
{
- // sanity checks!
assert(queue != NULL, "find_prev_wakeup: queue is null");
assert(pcb != NULL, "find_prev_wakeup: pcb is null");
struct pcb *prev = NULL;
struct pcb *curr = queue->head;
-
while (curr != NULL && curr->wakeup <= pcb->wakeup) {
prev = curr;
curr = curr->next;
@@ -103,13 +55,11 @@ static struct pcb *find_prev_wakeup(pcb_queue_t queue, struct pcb *pcb)
static struct pcb *find_prev_priority(pcb_queue_t queue, struct pcb *pcb)
{
- // sanity checks!
assert(queue != NULL, "find_prev_priority: queue is null");
assert(pcb != NULL, "find_prev_priority: pcb is null");
struct pcb *prev = NULL;
struct pcb *curr = queue->head;
-
while (curr != NULL && curr->priority <= pcb->priority) {
prev = curr;
curr = curr->next;
@@ -120,13 +70,11 @@ static struct pcb *find_prev_priority(pcb_queue_t queue, struct pcb *pcb)
static struct pcb *find_prev_pid(pcb_queue_t queue, struct pcb *pcb)
{
- // sanity checks!
assert(queue != NULL, "find_prev_pid: queue is null");
assert(pcb != NULL, "find_prev_pid: pcb is null");
struct pcb *prev = NULL;
struct pcb *curr = queue->head;
-
while (curr != NULL && curr->pid <= pcb->pid) {
prev = curr;
curr = curr->next;
@@ -145,7 +93,7 @@ static struct pcb *find_prev_pid(pcb_queue_t queue, struct pcb *pcb)
void pcb_init(void)
{
// there is no current process
- current = NULL;
+ current_pcb = NULL;
// set up the external links to the queues
QINIT(pcb_freelist, O_PCB_FIFO);
@@ -154,12 +102,8 @@ void pcb_init(void)
QINIT(sleeping, O_PCB_WAKEUP);
QINIT(zombie, O_PCB_PID);
- // We statically allocate our PCBs, so we need to add them
- // to the freelist before we can use them. If this changes
- // so that we dynamically allocate PCBs, this step either
- // won't be required, or could be used to pre-allocate some
- // number of PCB structures for future use.
-
+ // setup pcb linked list (free list)
+ // this can be done by calling pcb_free :)
struct pcb *ptr = ptable;
for (int i = 0; i < N_PROCS; ++i) {
pcb_free(ptr);
@@ -169,7 +113,6 @@ void pcb_init(void)
int pcb_alloc(struct pcb **pcb)
{
- // sanity check!
assert(pcb != NULL, "pcb_alloc: allocating a non free pcb pointer");
// remove the first PCB from the free list
@@ -197,208 +140,125 @@ void pcb_free(struct pcb *pcb)
}
}
-void pcb_zombify(register struct pcb *victim)
+void pcb_zombify(struct pcb *victim)
{
- // should this be an error?
if (victim == NULL)
return;
- // every process must have a parent, even if it's 'init'
+ assert(victim->pid != 1,
+ "pcb_zombify: attemped to zombie the init process");
assert(victim->parent != NULL, "pcb_zombify: process missing a parent");
- // We need to locate the parent of this process. We also need
- // to reparent any children of this process. We do these in
- // a single loop.
struct pcb *parent = victim->parent;
struct pcb *zchild = NULL;
+ struct pcb *curr = ptable;
- // two PIDs we will look for
- pid_t vicpid = victim->pid;
-
- // speed up access to the process table entries
- register struct pcb *curr = ptable;
-
+ // find all children of victim and reparent
for (int i = 0; i < N_PROCS; ++i, ++curr) {
- // make sure this is a valid entry
+ // is this a valid entry?
if (curr->state == PROC_STATE_UNUSED)
continue;
- // if this is our parent, just keep going - we continue
- // iterating to find all the children of this process.
- if (curr == parent)
+ // is this not our child?
+ if (curr->parent != victim)
continue;
- if (curr->parent == victim) {
- // found a child - reparent it
- curr->parent = init_pcb;
+ // reparent to init
+ curr->parent = init_pcb;
- // see if this child is already undead
- if (curr->state == PROC_STATE_ZOMBIE) {
- // if it's already a zombie, remember it, so we
- // can pass it on to 'init'; also, if there are
- // two or more zombie children, it doesn't matter
- // which one we pick here, as the others will be
- // collected when 'init' loops
- zchild = curr;
- }
+ // if this child is a zombie
+ if (curr->state == PROC_STATE_ZOMBIE) {
+ // if it's already a zombie, remember it, so we
+ // can pass it on to 'init'; also, if there are
+ // two or more zombie children, it doesn't matter
+ // which one we pick here, as the others will be
+ // collected when 'init' loops
+ zchild = curr;
}
}
- // If we found a child that was already terminated, we need to
- // wake up the init process if it's already waiting.
- //
- // NOTE: we only need to do this for one Zombie child process -
- // init will loop and collect the others after it finishes with
- // this one.
- //
- // Also note: it's possible that the exiting process' parent is
- // also init, which means we're letting one of zombie children
- // of the exiting process be cleaned up by init before the
- // existing process itself is cleaned up by init. This will work,
- // because after init cleans up the zombie, it will loop and
- // call waitpid() again, by which time this exiting process will
- // be marked as a zombie.
-
+ // schedule init if zombie child found
if (zchild != NULL && init_pcb->state == PROC_STATE_WAITING) {
- // dequeue the zombie
assert(pcb_queue_remove(zombie, zchild) == SUCCESS,
"pcb_zombify: cannot remove zombie process from queue");
-
assert(pcb_queue_remove(waiting, init_pcb) == SUCCESS,
"pcb_zombify: cannot remove waiting process from queue");
- // intrinsic return value is the PID
+ // send exited pid to init
PCB_RET(init_pcb) = zchild->pid;
-
- // may also want to return the exit status
- int64_t *ptr = (int64_t *)PCB_ARG(init_pcb, 2);
-
+ // set &status in init's waitpid call
+ int *ptr = (int *)PCB_ARG2(init_pcb);
if (ptr != NULL) {
- // BUG:
- // ********************************************************
- // ** Potential VM issue here! This code assigns the exit
- // ** status into a variable in the parent's address space.
- // ** This works in the baseline because we aren't using
- // ** any type of memory protection. If address space
- // ** separation is implemented, this code will very likely
- // ** STOP WORKING, and will need to be fixed.
- // ********************************************************
+ mem_ctx_switch(init_pcb->memctx);
*ptr = zchild->exit_status;
+ mem_ctx_switch(kernel_mem_ctx);
}
- // all done - schedule 'init', and clean up the zombie
+ // schedule init and cleanup child
schedule(init_pcb);
pcb_cleanup(zchild);
}
- // Now, deal with the parent of this process. If the parent is
- // already waiting, just wake it up and clean up this process.
- // Otherwise, this process becomes a zombie.
- //
- // NOTE: if the exiting process' parent is init and we just woke
- // init up to deal with a zombie child of the exiting process,
- // init's status won't be Waiting any more, so we don't have to
- // worry about it being scheduled twice.
-
+ // if the parent is waiting, wake it up and clean the victim,
+ // otherwise the victim will become a zombie
if (parent->state == PROC_STATE_WAITING) {
// verify that the parent is either waiting for this process
// or is waiting for any of its children
- uint64_t target = PCB_ARG(parent, 1);
-
- if (target == 0 || target == vicpid) {
- // the parent is waiting for this child or is waiting
- // for any of its children, so we can wake it up.
-
- // intrinsic return value is the PID
- PCB_RET(parent) = vicpid;
-
- // may also want to return the exit status
- int64_t *ptr = (int64_t *)PCB_ARG(parent, 2);
+ uint64_t target = PCB_ARG1(parent);
+ if (target != 0 || target == victim->pid) {
+ // send exited pid to parent
+ PCB_RET(parent) = victim->pid;
+ // send &status to parent
+ int *ptr = (int *)PCB_ARG2(parent);
if (ptr != NULL) {
- // ********************************************************
- // ** Potential VM issue here! This code assigns the exit
- // ** status into a variable in the parent's address space.
- // ** This works in the baseline because we aren't using
- // ** any type of memory protection. If address space
- // ** separation is implemented, this code will very likely
- // ** STOP WORKING, and will need to be fixed.
- // ********************************************************
+ mem_ctx_switch(parent->memctx);
*ptr = victim->exit_status;
+ mem_ctx_switch(kernel_mem_ctx);
}
- // all done - schedule the parent, and clean up the zombie
+ // schedule the parent, and clean up the zombie
schedule(parent);
pcb_cleanup(victim);
-
return;
}
}
- // The parent isn't waiting OR is waiting for a specific child
- // that isn't this exiting process, so we become a Zombie.
- //
- // This code assumes that Zombie processes are *not* in
- // a queue, but instead are just in the process table with
- // a state of 'Zombie'. This simplifies life immensely,
- // because we won't need to dequeue it when it is collected
- // by its parent.
-
victim->state = PROC_STATE_ZOMBIE;
assert(pcb_queue_insert(zombie, victim) == SUCCESS,
"cannot insert victim process into zombie queue");
-
- // Note: we don't call _dispatch() here - we leave that for
- // the calling routine, as it's possible we don't need to
- // choose a new current process.
}
void pcb_cleanup(struct pcb *pcb)
{
- // avoid deallocating a NULL pointer
- if (pcb == NULL) {
- // should this be an error?
+ if (pcb == NULL)
return;
- }
-
- // we need to release all the VM data structures and frames
- mem_ctx_free(pcb->memctx);
- // TODO: close open files
-
- // release the PCB itself
+ if (pcb->memctx)
+ mem_ctx_free(pcb->memctx);
pcb_free(pcb);
}
struct pcb *pcb_find_pid(pid_t pid)
{
- // must be a valid PID
- if (pid < 1) {
+ if (pid < 1)
return NULL;
- }
- // scan the process table
struct pcb *p = ptable;
-
for (int i = 0; i < N_PROCS; ++i, ++p) {
if (p->pid == pid && p->state != PROC_STATE_UNUSED) {
return p;
}
}
- // didn't find it!
return NULL;
}
struct pcb *pcb_find_ppid(pid_t pid)
{
- // must be a valid PID
- if (pid < 1) {
+ if (pid < 1)
return NULL;
- }
- // scan the process table
struct pcb *p = ptable;
-
for (int i = 0; i < N_PROCS; ++i, ++p) {
assert(p->parent != NULL,
"pcb_find_ppid: process does not have a parent");
@@ -407,44 +267,33 @@ struct pcb *pcb_find_ppid(pid_t pid)
}
}
- // didn't find it!
return NULL;
}
int pcb_queue_reset(pcb_queue_t queue, enum pcb_queue_order style)
{
- // sanity check
assert(queue != NULL, "pcb_queue_reset: queue is null");
- // make sure the style is valid
- if (style < 0 || style >= N_PCB_ORDERINGS) {
+ if (style < 0 || style >= N_PCB_ORDERINGS)
return E_BAD_PARAM;
- }
- // reset the queue
queue->head = queue->tail = NULL;
queue->order = style;
-
return SUCCESS;
}
bool pcb_queue_empty(pcb_queue_t queue)
{
- // if there is no queue, blow up
assert(queue != NULL, "pcb_queue_empty: queue is empty");
-
return PCB_QUEUE_EMPTY(queue);
}
size_t pcb_queue_length(const pcb_queue_t queue)
{
- // sanity check
assert(queue != NULL, "pcb_queue_length: queue is null");
- // this is pretty simple
- register struct pcb *tmp = queue->head;
- register size_t num = 0;
-
+ struct pcb *tmp = queue->head;
+ size_t num = 0;
while (tmp != NULL) {
++num;
tmp = tmp->next;
@@ -455,27 +304,19 @@ size_t pcb_queue_length(const pcb_queue_t queue)
int pcb_queue_insert(pcb_queue_t queue, struct pcb *pcb)
{
- // sanity checks
assert(queue != NULL, "pcb_queue_insert: queue is null");
assert(pcb != NULL, "pcb_queue_insert: pcb is null");
- // if this PCB is already in a queue, we won't touch it
- if (pcb->next != NULL) {
- // what to do? we let the caller decide
+ if (pcb->next != NULL)
return E_BAD_PARAM;
- }
- // is the queue empty?
if (queue->head == NULL) {
queue->head = queue->tail = pcb;
return SUCCESS;
}
assert(queue->tail != NULL, "pcb_queue_insert: queue tail is null");
- // no, so we need to search it
struct pcb *prev = NULL;
-
- // find the predecessor node
switch (queue->order) {
case O_PCB_FIFO:
prev = queue->tail;
@@ -490,12 +331,10 @@ int pcb_queue_insert(pcb_queue_t queue, struct pcb *pcb)
prev = find_prev_wakeup(queue, pcb);
break;
default:
- // do we need something more specific here?
return E_BAD_PARAM;
}
- // OK, we found the predecessor node; time to do the insertion
-
+ // found the predecessor node, time to do the insertion
if (prev == NULL) {
// there is no predecessor, so we're
// inserting at the front of the queue
@@ -505,12 +344,10 @@ int pcb_queue_insert(pcb_queue_t queue, struct pcb *pcb)
queue->tail = pcb;
}
queue->head = pcb;
-
} else if (prev->next == NULL) {
// append at end
prev->next = pcb;
queue->tail = pcb;
-
} else {
// insert between prev & prev->next
pcb->next = prev->next;
@@ -522,49 +359,33 @@ int pcb_queue_insert(pcb_queue_t queue, struct pcb *pcb)
int pcb_queue_pop(pcb_queue_t queue, struct pcb **pcb)
{
- //sanity checks
assert(queue != NULL, "pcb_queue_pop: queue is null");
assert(pcb != NULL, "pcb_queue_pop: pcb is null");
- // can't get anything if there's nothing to get!
- if (PCB_QUEUE_EMPTY(queue)) {
+ if (PCB_QUEUE_EMPTY(queue))
return E_EMPTY_QUEUE;
- }
- // take the first entry from the queue
struct pcb *tmp = queue->head;
queue->head = tmp->next;
-
- // disconnect it completely
tmp->next = NULL;
-
- // was this the last thing in the queue?
if (queue->head == NULL) {
- // yes, so clear the tail pointer for consistency
queue->tail = NULL;
}
- // save the pointer
*pcb = tmp;
-
return SUCCESS;
}
int pcb_queue_remove(pcb_queue_t queue, struct pcb *pcb)
{
- //sanity checks
assert(queue != NULL, "pcb_queue_remove: queue is null");
assert(pcb != NULL, "pcb_queue_remove: pcb is null");
- // can't get anything if there's nothing to get!
- if (PCB_QUEUE_EMPTY(queue)) {
+ if (PCB_QUEUE_EMPTY(queue))
return E_EMPTY_QUEUE;
- }
- // iterate through the queue until we find the desired PCB
struct pcb *prev = NULL;
struct pcb *curr = queue->head;
-
while (curr != NULL && curr != pcb) {
prev = curr;
curr = curr->next;
@@ -611,7 +432,6 @@ int pcb_queue_remove(pcb_queue_t queue, struct pcb *pcb)
// there's a possible consistancy problem here if somehow
// one of the queue pointers is NULL and the other one
// is not NULL
-
assert((queue->head == NULL && queue->tail == NULL) ||
(queue->head != NULL && queue->tail != NULL),
"pcb_queue_remove: queue consistancy problem");
@@ -621,229 +441,36 @@ int pcb_queue_remove(pcb_queue_t queue, struct pcb *pcb)
struct pcb *pcb_queue_peek(const pcb_queue_t queue)
{
- //sanity check
assert(queue != NULL, "pcb_queue_peek: queue is null");
- // can't get anything if there's nothing to get!
- if (PCB_QUEUE_EMPTY(queue)) {
+ if (PCB_QUEUE_EMPTY(queue))
return NULL;
- }
- // just return the first entry from the queue
return queue->head;
}
void schedule(struct pcb *pcb)
{
- // sanity check
assert(pcb != NULL, "schedule: pcb is null");
- // check for a killed process
if (pcb->state == PROC_STATE_KILLED)
panic("attempted to schedule killed process %d", pcb->pid);
- // mark it as ready
pcb->state = PROC_STATE_READY;
- // add it to the ready queue
if (pcb_queue_insert(ready, pcb) != SUCCESS)
panic("schedule insert fail");
}
void dispatch(void)
{
- // verify that there is no current process
- assert(current == NULL, "dispatch: current process is not null");
+ assert(current_pcb == NULL, "dispatch: current process is not null");
- // grab whoever is at the head of the queue
- int status = pcb_queue_pop(ready, &current);
- if (status != SUCCESS) {
+ int status = pcb_queue_pop(ready, &current_pcb);
+ if (status != SUCCESS)
panic("dispatch queue remove failed, code %d", status);
- }
// set the process up for success
- current->state = PROC_STATE_RUNNING;
- current->ticks = PROC_QUANTUM_STANDARD;
-}
-
-void ctx_dump(const char *msg, register struct cpu_regs *regs)
-{
- // first, the message (if there is one)
- if (msg)
- kputs(msg);
-
- // the pointer
- kprintf(" @ %16p: ", (void *)regs);
-
- // if it's NULL, why did you bother calling me?
- if (regs == NULL) {
- kprintf(" NULL???\n");
- return;
- }
-
- // now, the contents
- kputc('\n');
- cpu_print_regs(regs);
-}
-
-void ctx_dump_all(const char *msg)
-{
- // first, the message (if there is one)
- if (msg)
- kputs(msg);
-
- int n = 0;
- register struct pcb *pcb = ptable;
- for (int i = 0; i < N_PROCS; ++i, ++pcb) {
- if (pcb->state != PROC_STATE_UNUSED) {
- ++n;
- kprintf("%2d(%d): ", n, pcb->pid);
- ctx_dump(NULL, pcb->regs);
- }
- }
-}
-
-void pcb_dump(const char *msg, register struct pcb *pcb, bool all)
-{
- // first, the message (if there is one)
- if (msg)
- kputs(msg);
-
- // the pointer
- kprintf(" @ %16px:", (void *)pcb);
-
- // if it's NULL, why did you bother calling me?
- if (pcb == NULL) {
- kputs(" NULL???\n");
- return;
- }
-
- kprintf(" %d", pcb->pid);
- kprintf(" %s",
- pcb->state >= N_PROC_STATES ? "???" : proc_state_str[pcb->state]);
-
- if (!all) {
- // just printing IDs and states on one line
- return;
- }
-
- // now, the rest of the contents
- kprintf(" %s", pcb->priority >= N_PROC_PRIOS ?
- "???" :
- proc_prio_str[pcb->priority]);
-
- kprintf(" ticks %zu xit %d wake %16lx\n", pcb->ticks, pcb->exit_status,
- pcb->wakeup);
-
- kprintf(" parent %16p", (void *)pcb->regs);
- if (pcb->parent != NULL) {
- kprintf(" (%u)", pcb->parent->pid);
- }
-
- kprintf(" next %16p context %16p memctx %16p", (void *)pcb->next,
- (void *)pcb->regs, (void *)pcb->memctx);
-
- kputc('\n');
-}
-
-void pcb_queue_dump(const char *msg, pcb_queue_t queue, bool contents)
-{
- // report on this queue
- kprintf("%s: ", msg);
- if (queue == NULL) {
- kputs("NULL???\n");
- return;
- }
-
- // first, the basic data
- kprintf("head %16p tail %16p", (void *)queue->head, (void *)queue->tail);
-
- // next, how the queue is ordered
- kprintf(" order %s\n", queue->order >= N_PCB_ORDERINGS ?
- "????" :
- pcb_ord_str[queue->order]);
-
- // if there are members in the queue, dump the first few PIDs
- if (contents && queue->head != NULL) {
- kputs(" PIDs: ");
- struct pcb *tmp = queue->head;
- for (int i = 0; i < 5 && tmp != NULL; ++i, tmp = tmp->next) {
- kprintf(" [%u]", tmp->pid);
- }
-
- if (tmp != NULL) {
- kputs(" ...");
- }
-
- kputc('\n');
- }
-}
-
-void ptable_dump(const char *msg, bool all)
-{
- if (msg)
- kputs(msg);
- kputc(' ');
-
- int used = 0;
- int empty = 0;
-
- register struct pcb *pcb = ptable;
- for (int i = 0; i < N_PROCS; ++i) {
- if (pcb->state == PROC_STATE_UNUSED) {
- // an empty slot
- ++empty;
-
- } else {
- // a non-empty slot
- ++used;
-
- // if not dumping everything, add commas if needed
- if (!all && used) {
- kputc(',');
- }
-
- // report the table slot #
- kprintf(" #%d:", i);
-
- // and dump the contents
- pcb_dump(NULL, pcb, all);
- }
- }
-
- // only need this if we're doing one-line output
- if (!all) {
- kputc('\n');
- }
-
- // sanity check - make sure we saw the correct number of table slots
- if ((used + empty) != N_PROCS) {
- kprintf("Table size %d, used %d + empty %d = %d???\n", N_PROCS, used,
- empty, used + empty);
- }
-}
-
-void ptable_dump_counts(void)
-{
- size_t nstate[N_PROC_STATES] = { 0 };
- size_t unknown = 0;
-
- int n = 0;
- struct pcb *ptr = ptable;
- while (n < N_PROCS) {
- if (ptr->state < 0 || ptr->state >= N_PROC_STATES) {
- ++unknown;
- } else {
- ++nstate[ptr->state];
- }
- ++n;
- ++ptr;
- }
-
- kprintf("Ptable: %zu ***", unknown);
- for (n = 0; n < N_PROC_STATES; ++n) {
- kprintf(" %zu %s", nstate[n],
- proc_state_str[n] != NULL ? proc_state_str[n] : "???");
- }
- kputc('\n');
+ current_pcb->state = PROC_STATE_RUNNING;
+ current_pcb->ticks = 3; // ticks per process
}