/dports/net-p2p/libktorrent/libktorrent-21.12.3/src/dht/ |
H A D | dhtpeersource.cpp | 22 , curr_task(nullptr) in DHTPeerSource() 36 if (curr_task) in ~DHTPeerSource() 37 curr_task->kill(); in ~DHTPeerSource() 50 curr_task = nullptr; in dhtStopped() 56 if (curr_task) { in stop() 57 curr_task->kill(); in stop() 73 if (curr_task) in doRequest() 78 if (curr_task) { in doRequest() 92 if (curr_task == t) { in onFinished() 94 curr_task = nullptr; in onFinished() [all …]
|
H A D | dhtpeersource.h | 48 AnnounceTask *curr_task; variable
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/kernel/bpf/ |
H A D | task_iter.c | 142 struct task_struct *curr_task; in task_file_seq_get_next() local 151 curr_task = info->task; in task_file_seq_get_next() 162 info->task = curr_task; in task_file_seq_get_next() 188 put_task_struct(curr_task); in task_file_seq_get_next() 322 curr_task = info->task; in task_vma_seq_get_next() 375 if (!curr_task) { in task_vma_seq_get_next() 394 if (!curr_task->mm) in task_vma_seq_get_next() 428 info->task = curr_task; in task_vma_seq_get_next() 433 put_task_struct(curr_task); in task_vma_seq_get_next() 439 if (curr_task) in task_vma_seq_get_next() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/kernel/bpf/ |
H A D | task_iter.c | 142 struct task_struct *curr_task; in task_file_seq_get_next() local 151 curr_task = info->task; in task_file_seq_get_next() 162 info->task = curr_task; in task_file_seq_get_next() 188 put_task_struct(curr_task); in task_file_seq_get_next() 322 curr_task = info->task; in task_vma_seq_get_next() 375 if (!curr_task) { in task_vma_seq_get_next() 394 if (!curr_task->mm) in task_vma_seq_get_next() 428 info->task = curr_task; in task_vma_seq_get_next() 433 put_task_struct(curr_task); in task_vma_seq_get_next() 439 if (curr_task) in task_vma_seq_get_next() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/kernel/bpf/ |
H A D | task_iter.c | 142 struct task_struct *curr_task; in task_file_seq_get_next() local 151 curr_task = info->task; in task_file_seq_get_next() 162 info->task = curr_task; in task_file_seq_get_next() 188 put_task_struct(curr_task); in task_file_seq_get_next() 322 curr_task = info->task; in task_vma_seq_get_next() 375 if (!curr_task) { in task_vma_seq_get_next() 394 if (!curr_task->mm) in task_vma_seq_get_next() 428 info->task = curr_task; in task_vma_seq_get_next() 433 put_task_struct(curr_task); in task_vma_seq_get_next() 439 if (curr_task) in task_vma_seq_get_next() [all …]
|
/dports/games/scummvm-tools/scummvm-tools-2.5.0/engines/grim/lua/ |
H A D | ltask.cpp | 14 if ((L->curr_task != t) && (t->Tstate != DONE)) in pause_scripts() 23 if ((L->curr_task != t) && (t->Tstate != DONE)) in unpause_scripts() 29 struct lua_Task *old_task = L->curr_task, *new_task; in start_script() 59 L->curr_task = old_task; in start_script() 100 if (t == L->curr_task) { in stop_script() 221 if (L->curr_task == L->root_task) { in break_here() 233 if (L->curr_task == L->root_task) { in current_script() 237 nvalue(L->stack.top) = (real)L->curr_task->id; in current_script() 244 struct lua_Task *old_task = L->curr_task; in lua_runtasks() 288 if (L->curr_task != old_task) { in lua_runtasks()
|
H A D | lstate.cpp | 64 L->curr_task = L->root_task; in lua_resetglobals() 148 savetask(L->curr_task); in luaI_switchtask() 149 L->curr_task = t; in luaI_switchtask() 156 savetask(L->curr_task); in luaI_newtask() 158 L->curr_task = result; in luaI_newtask()
|
H A D | lstate.h | 100 struct lua_Task *curr_task; member
|
/dports/net/mpich2/mpich2-1.5/src/mpe2/src/graphics/contrib/mastermind/ |
H A D | gmm.c | 130 TASKT *free_tasks, *curr_task; variable 132 #define CURR_GUESS (curr_task->guess) 276 curr_task = &task_storage[0]; in slave() 387 (curr_task->guess_number)++; in slave() 429 curr_task = curr_task->next; in slave() 459 if (curr_task->next == curr_task) 466 curr_task->next->previous = curr_task->previous; 467 curr_task->previous->next = curr_task->next; 468 tmp = curr_task->previous; 469 add_to_free_list(curr_task); [all …]
|
/dports/databases/p5-Memcached-libmemcached/Memcached-libmemcached-1.001801/src/libmemcached/clients/ |
H A D | ms_conn.c | 205 c->curr_task.cmd= CMD_NULL; in ms_task_init() 206 c->curr_task.item= 0; in ms_task_init() 207 c->curr_task.verify= false; in ms_task_init() 209 c->curr_task.get_miss= true; in ms_task_init() 211 c->curr_task.get_opt= 0; in ms_task_init() 212 c->curr_task.set_opt= 0; in ms_task_init() 213 c->curr_task.cycle_undo_get= 0; in ms_task_init() 214 c->curr_task.cycle_undo_set= 0; in ms_task_init() 215 c->curr_task.verified_get= 0; in ms_task_init() 216 c->curr_task.overwrite_set= 0; in ms_task_init() [all …]
|
H A D | ms_task.c | 88 return c->curr_task.item; in ms_get_cur_opt_item() 483 ms_task_t *task= &c->curr_task; in ms_get_task() 834 if ((c->precmd.cmd == CMD_GET) && c->curr_task.get_miss) in ms_update_single_get_result() 840 if ((c->precmd.cmd == CMD_GET) && c->curr_task.verify in ms_update_single_get_result() 841 && ! c->curr_task.finish_verify) in ms_update_single_get_result() 946 c->curr_task.set_opt++; in ms_update_set_result() 947 c->curr_task.cycle_undo_set--; in ms_update_set_result() 985 if (c->curr_task.get_miss) in ms_update_stat_result()
|
H A D | ms_conn.h | 184 ms_task_t curr_task; /* current running task */ member
|
/dports/databases/libmemcached/libmemcached-1.0.18/clients/ |
H A D | ms_conn.c | 205 c->curr_task.cmd= CMD_NULL; in ms_task_init() 206 c->curr_task.item= 0; in ms_task_init() 207 c->curr_task.verify= false; in ms_task_init() 209 c->curr_task.get_miss= true; in ms_task_init() 211 c->curr_task.get_opt= 0; in ms_task_init() 212 c->curr_task.set_opt= 0; in ms_task_init() 213 c->curr_task.cycle_undo_get= 0; in ms_task_init() 214 c->curr_task.cycle_undo_set= 0; in ms_task_init() 215 c->curr_task.verified_get= 0; in ms_task_init() 216 c->curr_task.overwrite_set= 0; in ms_task_init() [all …]
|
H A D | ms_task.c | 88 return c->curr_task.item; in ms_get_cur_opt_item() 483 ms_task_t *task= &c->curr_task; in ms_get_task() 834 if ((c->precmd.cmd == CMD_GET) && c->curr_task.get_miss) in ms_update_single_get_result() 840 if ((c->precmd.cmd == CMD_GET) && c->curr_task.verify in ms_update_single_get_result() 841 && ! c->curr_task.finish_verify) in ms_update_single_get_result() 946 c->curr_task.set_opt++; in ms_update_set_result() 947 c->curr_task.cycle_undo_set--; in ms_update_set_result() 985 if (c->curr_task.get_miss) in ms_update_stat_result()
|
H A D | ms_conn.h | 184 ms_task_t curr_task; /* current running task */ member
|
/dports/net/haproxy18/haproxy-1.8.30/src/ |
H A D | task.c | 41 THREAD_LOCAL struct task *curr_task = NULL; /* task currently running or NULL */ variable 224 curr_task = t; in process_runnable_tasks() 238 curr_task = NULL; in process_runnable_tasks() 315 curr_task = t; in process_runnable_tasks() 326 curr_task = NULL; in process_runnable_tasks()
|
/dports/net/haproxy20/haproxy-2.0.26/include/proto/ |
H A D | task.h | 94 extern THREAD_LOCAL struct task *curr_task; /* task currently running or NULL */ 338 if (t == curr_task) { in __task_free() 339 curr_task = NULL; in __task_free() 367 if (t == curr_task || !(t->state & (TASK_QUEUED | TASK_RUNNING))) in task_destroy() 380 if ((struct task *)tl == curr_task) { in tasklet_free() 381 curr_task = NULL; in tasklet_free()
|
/dports/devel/py-bullet3/bullet3-3.21/examples/pybullet/gym/pybullet_envs/minitaur/envs_v2/env_wrappers/ |
H A D | step_based_curriculum_wrapper_env.py | 203 curr_task = np.random.choice(self._tasks) 207 self._gym_env.scene.scene_type = curr_task.name 208 for curriculum_parameter in curr_task.curriculum_parameters:
|
/dports/devel/py-nest-asyncio/nest_asyncio-1.5.3/ |
H A D | nest_asyncio.py | 194 curr_task = curr_tasks.get(task._loop) 198 if curr_task is None: 201 curr_tasks[task._loop] = curr_task
|
/dports/net/haproxy20/haproxy-2.0.26/src/ |
H A D | task.c | 44 THREAD_LOCAL struct task *curr_task = NULL; /* task currently running or NULL */ variable 413 curr_task = (struct task *)t; in process_runnable_tasks() 421 curr_task = NULL; in process_runnable_tasks() 429 curr_task = NULL; in process_runnable_tasks()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/mailbox/ |
H A D | mtk-cmdq-mailbox.c | 215 struct cmdq_task *task, *tmp, *curr_task = NULL; in cmdq_thread_irq_handler() local 244 curr_task = task; in cmdq_thread_irq_handler() 246 if (!curr_task || curr_pa == task_end_pa - CMDQ_INST_SIZE) { in cmdq_thread_irq_handler() 251 cmdq_task_handle_error(curr_task); in cmdq_thread_irq_handler() 255 if (curr_task) in cmdq_thread_irq_handler()
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/mailbox/ |
H A D | mtk-cmdq-mailbox.c | 215 struct cmdq_task *task, *tmp, *curr_task = NULL; in cmdq_thread_irq_handler() local 244 curr_task = task; in cmdq_thread_irq_handler() 246 if (!curr_task || curr_pa == task_end_pa - CMDQ_INST_SIZE) { in cmdq_thread_irq_handler() 251 cmdq_task_handle_error(curr_task); in cmdq_thread_irq_handler() 255 if (curr_task) in cmdq_thread_irq_handler()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/mailbox/ |
H A D | mtk-cmdq-mailbox.c | 215 struct cmdq_task *task, *tmp, *curr_task = NULL; in cmdq_thread_irq_handler() local 244 curr_task = task; in cmdq_thread_irq_handler() 246 if (!curr_task || curr_pa == task_end_pa - CMDQ_INST_SIZE) { in cmdq_thread_irq_handler() 251 cmdq_task_handle_error(curr_task); in cmdq_thread_irq_handler() 255 if (curr_task) in cmdq_thread_irq_handler()
|
/dports/net/haproxy19/haproxy-1.9.16/src/ |
H A D | task.c | 44 THREAD_LOCAL struct task *curr_task = NULL; /* task currently running or NULL */ variable 386 curr_task = (struct task *)t; in process_runnable_tasks() 397 curr_task = NULL; in process_runnable_tasks()
|
/dports/net/haproxy18/haproxy-1.8.30/include/proto/ |
H A D | task.h | 93 extern THREAD_LOCAL struct task *curr_task; /* task currently running or NULL */ 251 if (t == curr_task || !(t->state & TASK_RUNNING)) in task_free()
|