/kernel/linux/linux-5.10/kernel/sched/ |
H A D | swait.c | 12 INIT_LIST_HEAD(&q->task_list); in __init_swait_queue_head() 26 if (list_empty(&q->task_list)) in swake_up_locked() 29 curr = list_first_entry(&q->task_list, typeof(*curr), task_list); in swake_up_locked() 31 list_del_init(&curr->task_list); in swake_up_locked() 44 while (!list_empty(&q->task_list)) in swake_up_all_locked() 68 list_splice_init(&q->task_list, &tmp); in swake_up_all() 70 curr = list_first_entry(&tmp, typeof(*curr), task_list); in swake_up_all() 73 list_del_init(&curr->task_list); in swake_up_all() 88 if (list_empty(&wait->task_list)) in __prepare_to_swait() [all...] |
/kernel/linux/linux-6.6/kernel/sched/ |
H A D | swait.c | 11 INIT_LIST_HEAD(&q->task_list); in __init_swait_queue_head() 25 if (list_empty(&q->task_list)) in swake_up_locked() 28 curr = list_first_entry(&q->task_list, typeof(*curr), task_list); in swake_up_locked() 30 list_del_init(&curr->task_list); in swake_up_locked() 43 while (!list_empty(&q->task_list)) in swake_up_all_locked() 67 list_splice_init(&q->task_list, &tmp); in swake_up_all() 69 curr = list_first_entry(&tmp, typeof(*curr), task_list); in swake_up_all() 72 list_del_init(&curr->task_list); in swake_up_all() 87 if (list_empty(&wait->task_list)) in __prepare_to_swait() [all...] |
/third_party/ltp/testcases/kernel/controllers/pids/ |
H A D | pids.sh | 47 task_list=$(cgroup_get_task_list "pids") 63 echo $! > "$path/$task_list" 66 if [ $(wc -l < "$path/$task_list") -ne "$nb" ]; then 81 for i in $(cat "$path/$task_list"); do 92 pids_task1 "$testpath/$task_list" 115 pids_task1 "$testpath/$task_list" 137 pids_task1 "$testpath/$task_list" 183 pids_task1 "$testpath/$task_list" 214 pids_task1 "$testpath/$task_list" 226 pids_task1 "$testpath/child$i/$task_list" [all...] |
/kernel/linux/linux-5.10/include/linux/ |
H A D | swait.h | 45 struct list_head task_list; member 50 struct list_head task_list; member 55 .task_list = LIST_HEAD_INIT((name).task_list), \ 63 .task_list = LIST_HEAD_INIT((name).task_list), \ 123 return !list_empty(&wq->task_list); in swait_active() 138 * modifications to the wait queue (task_list). in swq_has_sleeper() 164 INIT_LIST_HEAD(&__wait.task_list); \
|
/kernel/linux/linux-6.6/include/linux/ |
H A D | swait.h | 45 struct list_head task_list; member 50 struct list_head task_list; member 55 .task_list = LIST_HEAD_INIT((name).task_list), \ 63 .task_list = LIST_HEAD_INIT((name).task_list), \ 123 return !list_empty(&wq->task_list); in swait_active() 138 * modifications to the wait queue (task_list). in swq_has_sleeper() 164 INIT_LIST_HEAD(&__wait.task_list); \
|
H A D | io_uring_types.h | 66 struct llist_head task_list; member
|
/third_party/ltp/testcases/kernel/controllers/cgroup_fj/ |
H A D | cgroup_fj_common.sh | 25 ROD echo "$pid" \> "$path/$task_list" 27 for task in $(cat "$path/$task_list"); do 29 tst_res TINFO "Unexpected pid $task in $path/$task_list, expected $pid" 64 task_list=$(cgroup_get_task_list "$subsystem")
|
H A D | cgroup_fj_function.sh | 119 for pid in $(cat "$start_path/ltp_1/$task_list"); do 120 echo $pid > "$mount_point/$task_list" 2> /dev/null 138 ROD echo "$pid" \> "$start_path/ltp_1/$task_list" 161 if rm "$start_path/ltp_1/$task_list" > /dev/null 2>&1; then 162 tst_res TFAIL "Tasks file $start_path/ltp_1/$task_list could be removed"
|
/third_party/ltp/testcases/kernel/controllers/memcg/regression/ |
H A D | memcg_regression_test.sh | 67 task_list=$(cgroup_get_task_list "memory") 112 ./memcg_test_1 "$test_path/$task_list" 198 for pid in $(cat "$mount_point/$task_list"); do 199 echo $pid > "$test_path/$task_list" 2> /dev/null 202 for pid in $(cat "$test_path/$task_list"); do 203 echo $pid > "$mount_point/$task_list" 2> /dev/null
|
/third_party/ltp/testcases/kernel/controllers/memcg/control/ |
H A D | memcg_control_test.sh | 26 ROD echo $! \> "$test_dir/$task_list" 71 task_list=$(cgroup_get_task_list "memory")
|
/third_party/ltp/testcases/kernel/controllers/memcg/stress/ |
H A D | memcg_stress_test.sh | 27 task_list=$(cgroup_get_task_list "memory") 74 ROD echo $! \> "$test_path/$i/$task_list"
|
/test/testfwk/xdevice/src/xdevice/_core/executor/ |
H A D | scheduler.py | 566 task_list = {} 570 if module_subsystem not in task_list: 571 task_list.update({module_subsystem: 1}) 573 task_list.update({module_subsystem: task_list.get(module_subsystem) + 1}) 613 LOG.debug(task_list) 616 setattr(root, "task_list", task_list)
|
H A D | concurrent.py | 814 task.root.task_list.update({module_subsystem: task.root.task_list.get(module_subsystem) - 1}) 842 LOG.info(self.task.root.task_list.get(module_subsystem)) 843 if self.task.root.task_list.get(module_subsystem) <= 0:
|
/third_party/ltp/testcases/kernel/controllers/cpuset/ |
H A D | cpuset_regression_test.sh | 129 task_list=$(cgroup_get_task_list "cpuset")
|
/third_party/node/src/ |
H A D | cares_wrap.cc | 119 auto it = channel->task_list()->find(&lookup_task); in ares_sockstate_cb() 121 task = (it == channel->task_list()->end()) ? nullptr : *it; in ares_sockstate_cb() 136 channel->task_list()->insert(task); in ares_sockstate_cb() 152 channel->task_list()->erase(it); in ares_sockstate_cb() 155 if (channel->task_list()->empty()) { in ares_sockstate_cb() 654 tracker->TrackField("task_list", task_list_, "NodeAresTask::List"); in MemoryInfo() 685 CHECK_EQ(false, channel->task_list()->empty()); in AresTimeout()
|
H A D | cares_wrap.h | 174 inline NodeAresTask::List* task_list() { return &task_list_; } in task_list() function in node::cares_wrap::final
|
/kernel/linux/linux-6.6/io_uring/ |
H A D | tctx.c | 89 init_llist_head(&tctx->task_list); in io_uring_alloc_task_context()
|
H A D | io_uring.c | 1219 struct llist_node *node = llist_del_all(&tctx->task_list); in io_fallback_tw() 1259 node = llist_del_all(&tctx->task_list); in tctx_task_work() 1329 if (!llist_add(&req->io_task_work.node, &tctx->task_list)) in io_req_normal_work_add()
|
/kernel/linux/linux-5.10/io_uring/ |
H A D | io_uring.c | 476 struct io_wq_work_list task_list; member 2191 if (!tctx->task_list.first && locked && ctx->submit_state.compl_nr) in tctx_task_work() 2195 node = tctx->task_list.first; in tctx_task_work() 2196 INIT_WQ_LIST(&tctx->task_list); in tctx_task_work() 2244 wq_list_add_tail(&req->io_task_work.node, &tctx->task_list); in io_req_task_work_add() 2268 node = tctx->task_list.first; in io_req_task_work_add() 2269 INIT_WQ_LIST(&tctx->task_list); in io_req_task_work_add() 8697 INIT_WQ_LIST(&tctx->task_list); in io_uring_alloc_task_context()
|