Home
last modified time | relevance | path

Searched refs:curr_task (Results 1 – 25 of 74) sorted by relevance

123

/dports/net-p2p/libktorrent/libktorrent-21.12.3/src/dht/
H A Ddhtpeersource.cpp22 , 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 Ddhtpeersource.h48 AnnounceTask *curr_task; variable
/dports/multimedia/v4l_compat/linux-5.13-rc2/kernel/bpf/
H A Dtask_iter.c142 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 Dtask_iter.c142 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 Dtask_iter.c142 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 Dltask.cpp14 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 Dlstate.cpp64 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 Dlstate.h100 struct lua_Task *curr_task; member
/dports/net/mpich2/mpich2-1.5/src/mpe2/src/graphics/contrib/mastermind/
H A Dgmm.c130 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 Dms_conn.c205 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 Dms_task.c88 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 Dms_conn.h184 ms_task_t curr_task; /* current running task */ member
/dports/databases/libmemcached/libmemcached-1.0.18/clients/
H A Dms_conn.c205 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 Dms_task.c88 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 Dms_conn.h184 ms_task_t curr_task; /* current running task */ member
/dports/net/haproxy18/haproxy-1.8.30/src/
H A Dtask.c41 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 Dtask.h94 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 Dstep_based_curriculum_wrapper_env.py203 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 Dnest_asyncio.py194 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 Dtask.c44 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 Dmtk-cmdq-mailbox.c215 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 Dmtk-cmdq-mailbox.c215 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 Dmtk-cmdq-mailbox.c215 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 Dtask.c44 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 Dtask.h93 extern THREAD_LOCAL struct task *curr_task; /* task currently running or NULL */
251 if (t == curr_task || !(t->state & TASK_RUNNING)) in task_free()

123