Change the 2LS reflected fault op to take a ctx
[akaros.git] / user / parlib / include / uthread.h
index d60273f..b108110 100644 (file)
@@ -1,7 +1,7 @@
-#ifndef PARLIB_UTHREAD_H
-#define PARLIB_UTHREAD_H
+#pragma once
 
 #include <parlib/vcore.h>
+#include <parlib/signal.h>
 #include <ros/syscall.h>
 
 __BEGIN_DECLS
@@ -29,6 +29,7 @@ struct uthread {
        void *tls_desc;
        int flags;
        int state;
+       struct sigstate sigstate;
        int notif_disabled_depth;
        struct syscall *sysc;   /* syscall we're blocking on, if any */
        struct syscall local_sysc;      /* for when we don't want to use the stack */
@@ -37,19 +38,25 @@ struct uthread {
        int err_no;
        char err_str[MAX_ERRSTR_LEN];
 };
-typedef struct uthread uthread_t;
 extern __thread struct uthread *current_uthread;
+typedef void* uth_mutex_t;
 
 /* 2L-Scheduler operations.  Examples in pthread.c. */
 struct schedule_ops {
+       /**** These functions must be defined ****/
        /* Functions supporting thread ops */
        void (*sched_entry)(void);
        void (*thread_runnable)(struct uthread *);
        void (*thread_paused)(struct uthread *);
        void (*thread_blockon_sysc)(struct uthread *, void *);
        void (*thread_has_blocked)(struct uthread *, int);
-       void (*thread_refl_fault)(struct uthread *, unsigned int, unsigned int,
-                                                         unsigned long);
+       void (*thread_refl_fault)(struct uthread *, struct user_context *);
+       /**** Defining these functions is optional. ****/
+       /* 2LSs can leave the mutex funcs empty for a default implementation */
+       uth_mutex_t (*mutex_alloc)(void);
+       void (*mutex_free)(uth_mutex_t);
+       void (*mutex_lock)(uth_mutex_t);
+       void (*mutex_unlock)(uth_mutex_t);
        /* Functions event handling wants */
        void (*preempt_pending)(void);
 };
@@ -82,15 +89,13 @@ void uthread_yield(bool save_state, void (*yield_func)(struct uthread*, void*),
 void uthread_sleep(unsigned int seconds);
 void uthread_usleep(unsigned int usecs);
 void uthread_has_blocked(struct uthread *uthread, int flags);
+void uthread_paused(struct uthread *uthread);
 
 /* Utility functions */
 bool __check_preempt_pending(uint32_t vcoreid);        /* careful: check the code */
 void uth_disable_notifs(void);
 void uth_enable_notifs(void);
 
-bool register_evq(struct syscall *sysc, struct event_queue *ev_q);
-void deregister_evq(struct syscall *sysc);
-
 /* Helpers, which sched_entry() can call */
 void highjack_current_uthread(struct uthread *uthread);
 void run_current_uthread(void);
@@ -121,6 +126,11 @@ static inline void init_uthread_ctx(struct uthread *uth, void (*entry)(void),
        val;                                                                       \
 })
 
-__END_DECLS
+/* Generic Uthread Mutexes.  2LSs implement their own methods, but we need a
+ * 2LS-independent interface and default implementation. */
+uth_mutex_t uth_mutex_alloc(void);
+void uth_mutex_free(uth_mutex_t m);
+void uth_mutex_lock(uth_mutex_t m);
+void uth_mutex_unlock(uth_mutex_t m);
 
-#endif /* PARLIB_UTHREAD_H */
+__END_DECLS