X-Git-Url: https://scm.lunaixsky.com/lunaix-os.git/blobdiff_plain/61a1daa59589212608039e2734009870818bacd3..946c3fdd31300074cc78841795bd47af908ddddb:/lunaix-os/includes/lunaix/process.h diff --git a/lunaix-os/includes/lunaix/process.h b/lunaix-os/includes/lunaix/process.h index c7b925e..bb55f02 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,31 +15,68 @@ // 虽然内核不是进程,但为了区分,这里使用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(state) ((state)&PS_GrDT) +#define PROC_HANGED(state) ((state)&PS_BLOCKED) +#define PROC_RUNNABLE(state) ((state)&PS_PAUSED) #define PROC_FINPAUSE 1 -struct proc_mm +struct proc_sigstate { - heap_context_t u_heap; - struct mm_region regions; + isr_param proc_regs; + char fxstate[512] __attribute__((aligned(16))); }; -struct proc_sig +struct sigact { - void* signal_handler; - int sig_num; - isr_param prev_context; + struct sigact* prev; + sigset_t sa_mask; + void* sa_actor; + void* sa_handler; + pid_t sender; }; -#define PROC_SIG_SIZE sizeof(struct proc_sig) // size=84 +struct sighail +{ + sigset_t sig_pending; + sigset_t sig_mask; + struct sigact* inprogress; + struct sigact signals[_SIG_NUM]; +}; + +struct proc_sig +{ + int sig_num; + void* sigact; + void* sighand; + struct proc_sigstate prev_context; +} __attribute__((packed)); struct proc_info { @@ -50,11 +88,12 @@ struct proc_info /* ---- critical section start ---- */ - pid_t pid; - struct proc_info* parent; - isr_param intr_ctx; // size=76 - uintptr_t ustack_top; - void* page_table; + pid_t pid; // offset = 0 + struct proc_info* parent; // offset = 4 + isr_param* intr_ctx; // offset = 8 + ptr_t ustack_top; // offset = 84 -> 56 -> 60 -> 12 + ptr_t page_table; // offset = 88 -> 60 -> 64 -> 16 + void* fxstate; // offset = 92 -> 64 -> 68 -> 20 /* ---- critical section end ---- */ @@ -73,14 +112,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; @@ -88,6 +124,24 @@ struct proc_info extern volatile struct proc_info* __current; +static inline void +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 分配并初始化一个进程控制块 * @@ -116,7 +170,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) 实现) @@ -145,4 +199,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 */