2LS op for handling reflected faults
[akaros.git] / user / pthread / pthread.c
index bec5098..a1eafb2 100644 (file)
@@ -21,6 +21,7 @@ struct pthread_queue active_queue = TAILQ_HEAD_INITIALIZER(active_queue);
 struct mcs_pdr_lock queue_lock;
 int threads_ready = 0;
 int threads_active = 0;
+atomic_t threads_total;
 bool can_adjust_vcores = TRUE;
 bool need_tls = TRUE;
 
@@ -38,6 +39,8 @@ void pth_thread_runnable(struct uthread *uthread);
 void pth_thread_paused(struct uthread *uthread);
 void pth_thread_blockon_sysc(struct uthread *uthread, void *sysc);
 void pth_thread_has_blocked(struct uthread *uthread, int flags);
+void pth_thread_refl_fault(struct uthread *uthread, unsigned int trap_nr,
+                           unsigned int err, unsigned long aux);
 void pth_preempt_pending(void);
 void pth_spawn_thread(uintptr_t pc_start, void *data);
 
@@ -50,6 +53,7 @@ struct schedule_ops pthread_sched_ops = {
        pth_thread_paused,
        pth_thread_blockon_sysc,
        pth_thread_has_blocked,
+       pth_thread_refl_fault,
        0, /* pth_preempt_pending, */
        0, /* pth_spawn_thread, */
 };
@@ -222,7 +226,6 @@ void pth_thread_blockon_sysc(struct uthread *uthread, void *syscall)
 {
        struct syscall *sysc = (struct syscall*)syscall;
        int old_flags;
-       bool need_to_restart = FALSE;
        uint32_t vcoreid = vcore_id();
        /* rip from the active queue */
        struct pthread_tcb *pthread = (struct pthread_tcb*)uthread;
@@ -255,6 +258,44 @@ void pth_thread_has_blocked(struct uthread *uthread, int flags)
                printf("For great justice!\n");
 }
 
+void pth_thread_refl_fault(struct uthread *uthread, unsigned int trap_nr,
+                           unsigned int err, unsigned long aux)
+{
+       struct pthread_tcb *pthread = (struct pthread_tcb*)uthread;
+       pthread->state = PTH_BLK_SYSC;
+       mcs_pdr_lock(&queue_lock);
+       threads_active--;
+       TAILQ_REMOVE(&active_queue, pthread, next);
+       mcs_pdr_unlock(&queue_lock);
+
+       if (trap_nr != 14) {
+               printf("Pthread has unhandled fault\n");
+               print_user_context(&uthread->u_ctx);
+               exit(-1);
+       }
+
+       if (!(err & PF_VMR_BACKED)) {
+               /* TODO: put your SIGSEGV handling here */
+               printf("Pthread page faulted outside a VMR\n");
+               print_user_context(&uthread->u_ctx);
+               exit(-1);
+       }
+       /* stitching for the event handler.  sysc -> uth, uth -> sysc */
+       uthread->local_sysc.u_data = uthread;
+       uthread->sysc = &uthread->local_sysc;
+       pthread->state = PTH_BLK_SYSC;
+       /* one downside is that we'll never check the return val of the syscall.  if
+        * we errored out, we wouldn't know til we PF'd again, and inspected the old
+        * retval/err and other sysc fields (make sure the PF is on the same addr,
+        * etc).  could run into this issue on truncated files too. */
+       syscall_async(&uthread->local_sysc, SYS_populate_va, aux, 1);
+       if (!register_evq(&uthread->local_sysc, sysc_mgmt[vcore_id()].ev_q)) {
+               /* Lost the race with the call being done.  The kernel won't send the
+                * event.  Just restart him. */
+               restart_thread(&uthread->local_sysc);
+       }
+}
+
 void pth_preempt_pending(void)
 {
 }
@@ -415,6 +456,7 @@ void pthread_lib_init(void)
         * have its init stuff use things like vcore stacks or TLSs, we'll need to
         * change this. */
        uthread_lib_init((struct uthread*)t);
+       atomic_init(&threads_total, 1);                 /* one for thread0 */
 }
 
 int pthread_create(pthread_t *thread, const pthread_attr_t *attr,
@@ -456,6 +498,7 @@ int pthread_create(pthread_t *thread, const pthread_attr_t *attr,
        uthread_init((struct uthread*)pthread, &uth_attr);
        pth_thread_runnable((struct uthread*)pthread);
        *thread = pthread;
+       atomic_inc(&threads_total);
        return 0;
 }
 
@@ -549,11 +592,19 @@ static void __pth_exit_cb(struct uthread *uthread, void *junk)
                        pth_thread_runnable((struct uthread*)temp_pth);
                }
        }
+       /* If we were the last pthread, we exit for the whole process.  Keep in mind
+        * that thread0 is counted in this, so this will only happen if that thread
+        * calls pthread_exit(). */
+       if ((atomic_fetch_and_add(&threads_total, -1) == 1))
+               exit(0);
 }
 
 void pthread_exit(void *ret)
 {
        struct pthread_tcb *pthread = pthread_self();
+       /* Some apps could call pthread_exit before initing.  This will slow down
+        * our pthread exits slightly. */
+       pthread_lib_init();
        pthread->retval = ret;
        destroy_dtls();
        uthread_yield(FALSE, __pth_exit_cb, 0);