per-cpu task lists and init task list on APs

Author: braindigitalis

include/taskswitch.h

@@ -92,7 +92,7 @@ process_t* proc_find(pid_t pid);
  * 
  * @return process_t* process detail or NULL if no current process
  */
-process_t* proc_cur();
+process_t* proc_cur(uint8_t logical_cpu);
 
 /**
  * @brief Mark a process as waiting for another process to complete
@@ -133,13 +133,9 @@ void proc_kill(process_t* proc);
  */
 bool proc_kill_id(pid_t id);
 
-/**
- * @brief Display a diagnostic list of all processes
- */
-void proc_show_list();
-
 /**
  * @brief Run the process scheduling loop.
+ * Each AP and the BSP all have a proc_loop().
  * @note Does not return
  */
 _Noreturn void proc_loop();

src/ap.c

@@ -39,5 +39,6 @@ void kmain_ap(struct limine_smp_info *info)
 	 *    see if a process ours is waiting on still lives.
 	 */
 	 dprintf("Got start signal on cpu #%d\n", info->processor_id);
-	 wait_forever();
+
+	 proc_loop();
 }

src/basic/file_io.c

@@ -6,12 +6,13 @@
 
 const char* make_full_path(const char* relative)
 {
+	uint8_t cpu = logical_cpu_id();
 	if (*relative == '/') {
 		dprintf("make_full_path %s -> %s\n", relative, relative);
 		return relative;
 	}
 
-	const char* csd = proc_cur()->csd;
+	const char* csd = proc_cur(cpu)->csd;
 	char qualified_path[MAX_STRINGLEN];
 
 	if (*relative == 0) {
@@ -309,16 +310,18 @@ char* basic_ramdisk_from_size(struct basic_ctx* ctx)
 
 char* basic_csd(struct basic_ctx* ctx)
 {
-	return gc_strdup(proc_cur()->csd);
+	return gc_strdup(proc_cur(logical_cpu_id())->csd);
 }
 
 void chdir_statement(struct basic_ctx* ctx)
 {
 	accept_or_return(CHDIR, ctx);
 	const char* csd = str_expr(ctx);
 	accept_or_return(NEWLINE, ctx);
-	const char* old = strdup(proc_cur()->csd);
-	const char* new = proc_set_csd(proc_cur(), csd);
+	uint8_t cpu = logical_cpu_id();
+	process_t* proc = proc_cur(cpu);
+	const char* old = strdup(proc->csd);
+	const char* new = proc_set_csd(proc, csd);
 	if (new && fs_is_directory(new)) {
 		kfree_null(&old);
 		return;
@@ -329,7 +332,7 @@ void chdir_statement(struct basic_ctx* ctx)
 		tokenizer_error_print(ctx, "Not a directory");
 	}
 
-	proc_set_csd(proc_cur(), old);
+	proc_set_csd(proc, old);
 	kfree_null(&old);
 }
 

src/basic/main.c

@@ -605,9 +605,11 @@ void init_local_heap(struct basic_ctx* ctx)
 
 void chain_statement(struct basic_ctx* ctx)
 {
+	uint32_t cpu = logical_cpu_id();
+	process_t* proc = proc_cur(cpu);
 	accept_or_return(CHAIN, ctx);
 	const char* pn = str_expr(ctx);
-	process_t* p = proc_load(pn, ctx->cons, proc_cur()->pid, proc_cur()->csd);
+	process_t* p = proc_load(pn, ctx->cons, proc->pid, proc->csd);
 	if (p == NULL) {
 		accept_or_return(NEWLINE, ctx);
 		return;
@@ -634,7 +636,7 @@ void chain_statement(struct basic_ctx* ctx)
 		}
 	}
 
-	proc_wait(proc_cur(), p->pid);
+	proc_wait(proc, p->pid);
 	accept_or_return(NEWLINE, ctx);
 }