Home
last modified time | relevance | path

Searched refs:state (Results 1 – 25 of 26) sorted by relevance

12

/DragonOS-0.1.2/kernel/src/process/
Dprocess.rs17 let state: u64 = unsafe { read_volatile(&(*pcb).state) } as u64; in process_is_stopped() localVariable
18 if (state & (PROC_STOPPED as u64)) != 0 { in process_is_stopped()
48 write_volatile(&mut pcb.state, PROC_RUNNING as u64); in process_try_to_wake_up()
57 if unsafe { read_volatile(&pcb.state) } & _state != 0 { in process_try_to_wake_up()
60 write_volatile(&mut pcb.state, PROC_RUNNING as u64); in process_try_to_wake_up()
75 pub extern "C" fn process_wake_up_state(pcb: *mut process_control_block, state: u64) -> bool { in process_wake_up_state()
76 return process_try_to_wake_up(pcb, state, 0); in process_wake_up_state()
Dkthread.c171 current_pcb->state = PROC_UNINTERRUPTIBLE; in kthread()
176 current_pcb->state &= ~PROC_RUNNING; // 设置当前进程不是RUNNING态 in kthread()
218 current_pcb->state = PROC_INTERRUPTIBLE; in kthreadd()
Dproc-types.h78 volatile uint64_t state; member
Dprocess.c57 ….state = PROC_UNINTERRUPTIBLE, .flags = PF_KTHREAD, .preempt_count = 0, .signal = 0, .cpu_id = 0, …
553 pcb->state = PROC_ZOMBIE; in process_do_exit()
637 initial_proc_union.pcb.state = PROC_RUNNING; in process_init()
682 if (pcb->state & PROC_RUNNING) in process_wakeup()
685 pcb->state |= PROC_RUNNING; in process_wakeup()
697 if (pcb->state & PROC_RUNNING) in process_wakeup_immediately()
Dprocess.h222 extern int process_wake_up_state(struct process_control_block *pcb, uint64_t state);
Dfork.c93 tsk->state = PROC_UNINTERRUPTIBLE; in do_fork()
/DragonOS-0.1.2/kernel/src/libs/
Dwait_queue_head.c26 wait->pcb->state = PROC_UNINTERRUPTIBLE; in wait_queue_sleep_with_node()
41 wait->pcb->state = PROC_UNINTERRUPTIBLE; in wait_queue_sleep_with_node_unlock()
57 wait->pcb->state = PROC_INTERRUPTIBLE; in wait_queue_sleep_with_node_interriptible()
69 void wait_queue_wakeup_on_stack(wait_queue_head_t *q, int64_t state) in wait_queue_wakeup_on_stack() argument
77 if (wait->pcb->state & state) in wait_queue_wakeup_on_stack()
Dwait_queue.c28 current_pcb->state = PROC_UNINTERRUPTIBLE; in wait_queue_sleep_on()
44 current_pcb->state = PROC_UNINTERRUPTIBLE; in wait_queue_sleep_on_unlock()
59 current_pcb->state = PROC_INTERRUPTIBLE; in wait_queue_sleep_on_interriptible()
71 void wait_queue_wakeup(wait_queue_node_t *wait_queue_head, int64_t state) in wait_queue_wakeup() argument
78 if (wait->pcb->state & state) in wait_queue_wakeup()
Dsemaphore.c16 current_pcb->state = PROC_UNINTERRUPTIBLE; in semaphore_down()
37 wq->pcb->state = PROC_RUNNING; in semaphore_up()
Dmutex.c19 current_pcb->state = PROC_UNINTERRUPTIBLE; in __mutex_sleep()
Dlz4.c1669 int LZ4_compress_fast_extState(void *state, const char *source, char *dest, int inputSize, int maxO… in LZ4_compress_fast_extState() argument
1671 …LZ4_stream_t_internal *const ctx = &LZ4_initStream(state, sizeof(LZ4_stream_t))->internal_donotuse; in LZ4_compress_fast_extState()
1712 int LZ4_compress_fast_extState_fastReset(void *state, const char *src, char *dst, int srcSize, int … in LZ4_compress_fast_extState_fastReset() argument
1714 LZ4_stream_t_internal *ctx = &((LZ4_stream_t *)state)->internal_donotuse; in LZ4_compress_fast_extState_fastReset()
1793 static int LZ4_compress_destSize_extState(LZ4_stream_t *state, const char *src, char *dst, int *src… in LZ4_compress_destSize_extState() argument
1795 void *const s = LZ4_initStream(state, sizeof(*state)); in LZ4_compress_destSize_extState()
1801 return LZ4_compress_fast_extState(state, src, dst, *srcSizePtr, targetDstSize, 1); in LZ4_compress_destSize_extState()
1807 …return LZ4_compress_generic(&state->internal_donotuse, src, dst, *srcSizePtr, srcSizePtr, targetDs… in LZ4_compress_destSize_extState()
1812 …return LZ4_compress_generic(&state->internal_donotuse, src, dst, *srcSizePtr, srcSizePtr, targetDs… in LZ4_compress_destSize_extState()
3100 int LZ4_compress_limitedOutput_withState(void *state, const char *src, char *dst, int srcSize, int … in LZ4_compress_limitedOutput_withState() argument
[all …]
Didr.c574 bool state[MAX_LEVEL + 1] = {0}; // 标记是否大于等于] in idr_find_next_getid() local
600 state[layer] = cur_state; in idr_find_next_getid()
606 state[layer] = cur_state = true; in idr_find_next_getid()
/DragonOS-0.1.2/kernel/src/exception/
Dtrap.c18 current_pcb->state = PROC_STOPPED; in do_divide_error()
69 current_pcb->state = PROC_STOPPED; in do_overflow()
91 current_pcb->state = PROC_STOPPED; in do_undefined_opcode()
102 current_pcb->state = PROC_STOPPED; in do_dev_not_avaliable()
115 current_pcb->state = PROC_STOPPED; in do_double_fault()
126 current_pcb->state = PROC_STOPPED; in do_coprocessor_segment_overrun()
158 current_pcb->state = PROC_STOPPED; in do_invalid_TSS()
169 current_pcb->state = PROC_STOPPED; in do_segment_not_exists()
180 current_pcb->state = PROC_STOPPED; in do_stack_segment_fault()
208 current_pcb->state = PROC_STOPPED; in do_general_protection()
[all …]
/DragonOS-0.1.2/kernel/src/common/
Dwait_queue.h52 void wait_queue_wakeup(wait_queue_node_t *wait_queue_head, int64_t state);
118 void wait_queue_wakeup_on_stack(wait_queue_head_t *q, int64_t state);
Dlz4.h198 …LZ4LIB_API int LZ4_compress_fast_extState(void *state, const char *src, char *dst, int srcSize, in…
460 …LZ4LIB_STATIC_API int LZ4_compress_fast_extState_fastReset(void *state, const char *src, char *dst…
687 … LZ4LIB_API int LZ4_compress_withState(void *state, const char *source, char *dest, int inputSize);
689 …LZ4LIB_API int LZ4_compress_limitedOutput_withState(void *state, const char *source, char *dest, i…
716 LZ4LIB_API int LZ4_resetStreamState(void *state, char *inputBuffer);
718 LZ4LIB_API char *LZ4_slideInputBuffer(void *state);
/DragonOS-0.1.2/kernel/src/sched/
Dcompletion.c57 static long __wait_for_common(struct completion *x, long (*action)(long), long timeout, int state) in __wait_for_common() argument
68 wait.pcb->state = state; // 清除运行位, 并设置为interuptible/uninteruptible in __wait_for_common()
78 wait.pcb->state = PROC_RUNNING; // 设置为运行, 并清空state， 所以使用等号赋值 in __wait_for_common()
Dcfs.c62 …if (current_pcb->virtual_runtime >= proc->virtual_runtime || !(current_pcb->state & PROC_RUNNING))… in sched_cfs()
66 if (current_pcb->state & PROC_RUNNING) // 本次切换由于时间片到期引发，则再次加入就绪队列，否则交由其它功能模块进行管理 in sched_cfs()
/DragonOS-0.1.2/docs/kernel/sched/
Dwaiting.md61 …ue_wakeup(wait_queue_node_t * wait_queue_head, int64_t state);`函数，从指定的等待队列中，唤醒第一个挂起时的状态与指定的`state`…
121 …于在栈上的wait_node,您可以选择`wait_queue_wakeup_on_stack(wait_queue_head_t *q, int64_t state)`来唤醒队列里面的队列头节点。
/DragonOS-0.1.2/kernel/src/time/
Dsleep.c57 current_pcb->state = PROC_INTERRUPTIBLE; in nanosleep()
Dtimer.c171 current_pcb->state &= ~(PROC_RUNNING); in schedule_timeout_ms()
/DragonOS-0.1.2/kernel/src/driver/usb/xhci/
Dinternal.h85 #define xhci_ep_set_dequeue_cycle_state(ep_ctx_ptr, state) ((ep_ctx_ptr)->tr_dequeue_ptr |= ((state… argument
/DragonOS-0.1.2/kernel/src/ipc/
Dsignal.rs380 let mut state: u64 = 0; in signal_wake_up() localVariable
382 state = PF_WAKEKILL as u64; in signal_wake_up()
384 signal_wake_up_state(pcb, state); in signal_wake_up()
387 fn signal_wake_up_state(pcb: &mut process_control_block, state: u64) { in signal_wake_up_state()
392 if !process_wake_up_state(pcb, state | (PROC_INTERRUPTIBLE as u64)) { in signal_wake_up_state()
/DragonOS-0.1.2/kernel/src/smp/
Dsmp.c159 current_pcb->state = PROC_RUNNING; in smp_ap_start()
/DragonOS-0.1.2/kernel/src/syscall/
Dsyscall.c521 while (child_proc->state != PROC_ZOMBIE) in sys_wait4()
/DragonOS-0.1.2/kernel/src/filesystem/procfs/
Dprocfs.c130 data_puts(fdata, ltoa(pcb_t->state)); in procfs_open()

12