Decoupling Architectural-specific Code (#35)

[lunaix-os.git] / lunaix-os / kernel / process / sched.c

diff --git a/lunaix-os/kernel/process/sched.c b/lunaix-os/kernel/process/sched.c
index c92cde9efdb3a397042d8ed177ba09ad8f3a63b2..91cf61becdc53c0d2a8411f1f7426990531f4eea 100644 (file)
--- a/lunaix-os/kernel/process/sched.c
+++ b/lunaix-os/kernel/process/sched.c
@@ -1,7 +1,6 @@
 #include <sys/abi.h>
 #include <sys/mm/mempart.h>
 
 #include <sys/abi.h>
 #include <sys/mm/mempart.h>
 

-#include <hal/intc.h>

 #include <sys/cpu.h>
 
 #include <lunaix/fs/taskfs.h>
 #include <sys/cpu.h>
 
 #include <lunaix/fs/taskfs.h>


@@ -18,13 +17,17 @@
 #include <lunaix/status.h>
 #include <lunaix/syscall.h>
 #include <lunaix/syslog.h>
 #include <lunaix/status.h>
 #include <lunaix/syscall.h>
 #include <lunaix/syslog.h>

-#include <lunaix/pcontext.h>
+#include <lunaix/hart_state.h>

 #include <lunaix/kpreempt.h>
 
 #include <lunaix/kpreempt.h>
 

+#include <lunaix/generic/isrm.h>
+

 #include <klibc/string.h>
 
 #include <klibc/string.h>
 

+struct thread empty_thread_obj;
+

 volatile struct proc_info* __current;
 volatile struct proc_info* __current;

-volatile struct thread* current_thread;
+volatile struct thread* current_thread = &empty_thread_obj;

 
 struct scheduler sched_ctx;
 
 
 struct scheduler sched_ctx;
 


@@ -53,6 +56,7 @@ run(struct thread* thread)
     thread->process->state = PS_RUNNING;
     thread->process->th_active = thread;
 
     thread->process->state = PS_RUNNING;
     thread->process->th_active = thread;
 

+    procvm_mount_self(vmspace(thread->process));

     set_current_executing(thread);
 
     switch_context();
     set_current_executing(thread);
 
     switch_context();


@@ -80,9 +84,11 @@ cleanup_detached_threads() {
             continue;
         }
 
             continue;
         }
 

-        vmm_mount_pd(VMS_MOUNT_1, vmroot(pos->process));
-        destory_thread(VMS_MOUNT_1, pos);
-        vmm_unmount_pd(VMS_MOUNT_1);
+        struct proc_mm* mm = vmspace(pos->process);
+
+        procvm_mount(mm);
+        destory_thread(pos);
+        procvm_unmount(mm);

         
         i++;
     }
         
         i++;
     }


@@ -173,8 +179,10 @@ schedule()
     if (!(current_thread->state & ~PS_RUNNING)) {
         current_thread->state = PS_READY;
         __current->state = PS_READY;
     if (!(current_thread->state & ~PS_RUNNING)) {
         current_thread->state = PS_READY;
         __current->state = PS_READY;

+

     }
 
     }
 

+    procvm_unmount_self(vmspace(__current));

     check_sleepers();
 
     // round-robin scheduler
     check_sleepers();
 
     // round-robin scheduler


@@ -200,7 +208,7 @@ schedule()
     sched_ctx.procs_index = to_check->process->pid;
 
 done:
     sched_ctx.procs_index = to_check->process->pid;
 
 done:

-    intc_notify_eos(0);
+    isrm_notify_eos(0);

     run(to_check);
 
     fail("unexpected return from scheduler");
     run(to_check);
 
     fail("unexpected return from scheduler");


@@ -382,7 +390,7 @@ alloc_process()
     proc->created = clock_systime();
     proc->pgid = proc->pid;
 
     proc->created = clock_systime();
     proc->pgid = proc->pid;
 

-    proc->sigreg = vzalloc(sizeof(struct sigregister));
+    proc->sigreg = vzalloc(sizeof(struct sigregistry));

     proc->fdtable = vzalloc(sizeof(struct v_fdtable));
 
     proc->mm = procvm_create(proc);
     proc->fdtable = vzalloc(sizeof(struct v_fdtable));
 
     proc->mm = procvm_create(proc);


@@ -447,7 +455,7 @@ commit_process(struct proc_info* process)
 }
 
 void
 }
 
 void

-destory_thread(ptr_t vm_mnt, struct thread* thread) 
+destory_thread(struct thread* thread) 

 {
     cake_ensure_valid(thread);
     
 {
     cake_ensure_valid(thread);
     


@@ -458,7 +466,7 @@ destory_thread(ptr_t vm_mnt, struct thread* thread)
     llist_delete(&thread->sleep.sleepers);
     waitq_cancel_wait(&thread->waitqueue);
 
     llist_delete(&thread->sleep.sleepers);
     waitq_cancel_wait(&thread->waitqueue);
 

-    thread_release_mem(thread, vm_mnt);
+    thread_release_mem(thread);

 
     proc->thread_count--;
     sched_ctx.ttable_len--;
 
     proc->thread_count--;
     sched_ctx.ttable_len--;


@@ -470,6 +478,7 @@ void
 delete_process(struct proc_info* proc)
 {
     pid_t pid = proc->pid;
 delete_process(struct proc_info* proc)
 {
     pid_t pid = proc->pid;

+    struct proc_mm* mm = vmspace(proc);

 
     assert(pid);    // long live the pid0 !!
 
 
     assert(pid);    // long live the pid0 !!
 


@@ -501,19 +510,17 @@ delete_process(struct proc_info* proc)
 
     vfree(proc->fdtable);
 
 
     vfree(proc->fdtable);
 

-    signal_free_registers(proc->sigreg);
+    signal_free_registry(proc->sigreg);

 
 

-    vmm_mount_pd(VMS_MOUNT_1, vmroot(proc));
+    procvm_mount(mm);

     
     struct thread *pos, *n;
     llist_for_each(pos, n, &proc->threads, proc_sibs) {
         // terminate and destory all thread unconditionally
     
     struct thread *pos, *n;
     llist_for_each(pos, n, &proc->threads, proc_sibs) {
         // terminate and destory all thread unconditionally

-        destory_thread(VMS_MOUNT_1, pos);
+        destory_thread(pos);

     }
 
     }
 

-    procvm_cleanup(VMS_MOUNT_1, proc);
-
-    vmm_unmount_pd(VMS_MOUNT_1);
+    procvm_unmount_release(mm);

 
     cake_release(proc_pile, proc);
 }
 
     cake_release(proc_pile, proc);
 }