X-Git-Url: https://scm.lunaixsky.com/lunaix-os.git/blobdiff_plain/98fd6cb58b5bbc55cd9ceb45bd27b45a3b222df7..04ee277abd77fc51c5ab02ee58790a859607ea24:/lunaix-os/includes/lunaix/process.h diff --git a/lunaix-os/includes/lunaix/process.h b/lunaix-os/includes/lunaix/process.h index 291aba2..7d385a4 100644 --- a/lunaix-os/includes/lunaix/process.h +++ b/lunaix-os/includes/lunaix/process.h @@ -6,6 +6,7 @@ #include #include #include +#include #include #include #include @@ -14,34 +15,61 @@ // 虽然内核不是进程,但为了区分,这里使用Pid=-1来指代内核。这主要是方便物理页所有权检查。 #define KERNEL_PID -1 +/* + |C|Bk|De|Tn|Pu|Rn| + \----/ + Dt + + Group Dt: whether this process is terminated. + + Rn: Running + Tn: Terminated + De: Destoryed + Pu: Paused + Bk: Blocked + C : Created +*/ + #define PS_READY 0 #define PS_RUNNING 1 #define PS_TERMNAT 2 #define PS_DESTROY 4 -#define PS_BLOCKED 8 -#define PS_CREATED 16 +#define PS_PAUSED 8 +#define PS_BLOCKED 16 +#define PS_CREATED 32 -#define PROC_TERMINATED(state) (state & 0x6) +#define PS_GrBP (PS_PAUSED | PS_BLOCKED) +#define PS_GrDT (PS_TERMNAT | PS_DESTROY) + +#define proc_terminated(proc) (((proc)->state) & PS_GrDT) +#define proc_hanged(proc) (((proc)->state) & PS_BLOCKED) +#define proc_runnable(proc) (((proc)->state) & PS_PAUSED) #define PROC_FINPAUSE 1 -struct proc_mm +struct sigact { - heap_context_t u_heap; - struct mm_region regions; + struct sigact* prev; + sigset_t sa_mask; + void* sa_actor; + void* sa_handler; + pid_t sender; }; -struct proc_sigstate +struct sighail { - isr_param proc_regs; - char fxstate[512] __attribute__((aligned(16))); + sigset_t sig_pending; + sigset_t sig_mask; + struct sigact* inprogress; + struct sigact signals[_SIG_NUM]; }; struct proc_sig { - void* signal_handler; int sig_num; - struct proc_sigstate prev_context; + void* sigact; + void* sighand; + isr_param* saved_ictx; } __attribute__((packed)); struct proc_info @@ -56,10 +84,9 @@ struct proc_info pid_t pid; // offset = 0 struct proc_info* parent; // offset = 4 - isr_param intr_ctx; // offset = 8 - uintptr_t ustack_top; // offset = 84 -> 56 - void* page_table; // offset = 88 -> 60 - void* fxstate; // offset = 92 -> 64 + isr_param* intr_ctx; // offset = 8 + ptr_t ustack_top; // offset = 84 -> 56 -> 60 -> 12 + ptr_t page_table; // offset = 88 -> 60 -> 64 -> 16 /* ---- critical section end ---- */ @@ -78,14 +105,11 @@ struct proc_info struct proc_mm mm; time_t created; - uint8_t state; + u8_t state; int32_t exit_code; int32_t k_status; - sigset_t sig_pending; - sigset_t sig_mask; - sigset_t sig_inprogress; int flags; - void* sig_handler[_SIG_NUM]; + struct sighail sigctx; struct v_fdtable* fdtable; struct v_dnode* cwd; pid_t pgid; @@ -99,6 +123,18 @@ block_current() __current->state = PS_BLOCKED; } +static inline void +pause_current() +{ + __current->state = PS_PAUSED; +} + +static inline void +resume_current() +{ + __current->state = PS_RUNNING; +} + /** * @brief 分配并初始化一个进程控制块 * @@ -127,7 +163,7 @@ pid_t destroy_process(pid_t pid); void -setup_proc_mem(struct proc_info* proc, uintptr_t kstack_from); +copy_kernel_stack(struct proc_info* proc, ptr_t kstack_from); /** * @brief 复制当前进程(LunaixOS的类 fork (unix) 实现) @@ -156,4 +192,7 @@ orphaned_proc(pid_t pid); struct proc_info* get_process(pid_t pid); +void +proc_setsignal(struct proc_info* proc, int signum); + #endif /* __LUNAIX_PROCESS_H */