regress/lib/libc/asr/bin/threads.c

126

r = pthread_create(&th[i], NULL, task, (void *) &th_args[i]);

regress/lib/libc/asr/bin/threads.c

134

task(&n);

regress/usr.bin/nc/client-tcp.c

50

struct task todo[100];

regress/usr.bin/nc/server-tcp.c

51

struct task todo[100];

regress/usr.bin/nc/util.c

33

task_enqueue(struct task *todo, int ch, const char *msg)

regress/usr.bin/nc/util.c

56

task_run(int s, struct task *todolist, size_t tlen)

regress/usr.bin/nc/util.h

24

void task_enqueue(struct task *, int, const char *);

regress/usr.bin/nc/util.h

25

void task_run(int, struct task *, size_t);

regress/usr.sbin/rpki-client/test-rrdp.c

211

switch (s->task) {

regress/usr.sbin/rpki-client/test-rrdp.c

245

if (s->task != NOTIFICATION) {

regress/usr.sbin/rpki-client/test-rrdp.c

261

if (s->task != NOTIFICATION)

regress/usr.sbin/rpki-client/test-rrdp.c

292

s->task = DELTA;

regress/usr.sbin/rpki-client/test-rrdp.c

312

s->task = NOTIFICATION;

regress/usr.sbin/rpki-client/test-rrdp.c

324

s->task = SNAPSHOT;

regress/usr.sbin/rpki-client/test-rrdp.c

69

enum rrdp_task task;

sys/arch/arm/arm/cpu.c

615

struct task cpu_opp_task;

sys/arch/arm64/arm64/cpu.c

2275

struct task cpu_opp_task;

sys/arch/arm64/dev/acpicpu.c

70

struct task acpicpu_setperf_task;

sys/arch/arm64/dev/apldc.c

267

struct task ag_task;

sys/arch/arm64/dev/apm.c

61

struct task suspend_task;

sys/arch/arm64/dev/apm.c

64

struct task hibernate_task;

sys/arch/arm64/dev/rtkit.c

113

struct task crashlog_task;

sys/arch/arm64/dev/rtkit.c

117

struct task ioreport_task;

sys/arch/arm64/dev/rtkit.c

121

struct task oslog_task;

sys/arch/arm64/dev/rtkit.c

125

struct task syslog_task;

sys/arch/armv7/exynos/crosec_kbd.c

140

task_set(&sc->keyboard.task, cros_ec_poll_keystate, sc);

sys/arch/armv7/exynos/crosec_kbd.c

163

task_add(sc->keyboard.taskq, &sc->keyboard.task);

sys/arch/armv7/exynos/crosecvar.h

56

struct task task;

sys/arch/macppc/dev/abtn.c

75

struct task eject_task =

sys/arch/macppc/dev/adb.c

255

struct task adb_shutdown_task = TASK_INITIALIZER(adb_shutdown, NULL);

sys/arch/macppc/dev/adb.c

258

struct task adb_suspend_task = TASK_INITIALIZER(adb_suspend, NULL);

sys/arch/macppc/macppc/cpu.c

159

struct task ppc64_setperf_task;

sys/arch/octeon/dev/if_cnmacvar.h

82

struct task sc_free_task;

sys/arch/riscv64/riscv64/cpu.c

726

struct task cpu_opp_task;

sys/arch/sparc64/dev/vdsp.c

238

struct task sc_open_task;

sys/arch/sparc64/dev/vdsp.c

239

struct task sc_alloc_task;

sys/arch/sparc64/dev/vdsp.c

240

struct task sc_close_task;

sys/arch/sparc64/dev/vdsp.c

247

struct task sc_read_task;

sys/arch/sparc64/dev/vdsp.c

250

struct task sc_vd_task;

sys/dev/acpi/asmc.c

84

struct task sc_task_backlight;

sys/dev/ata/atascsi.c

1079

task_set(&xa->task, atascsi_disk_unmap_task, xs);

sys/dev/ata/atascsi.c

1080

task_add(systq, &xa->task);

sys/dev/ata/atascsi.h

328

struct task task;

sys/dev/audio.c

149

struct task wskbd_task;

sys/dev/cardbus/cardslotvar.h

76

struct task sc_event_task;

sys/dev/fdt/fusbtc.c

199

struct task sc_task;

sys/dev/fdt/gpiobl.c

40

struct task sc_task;

sys/dev/fdt/if_cad.c

304

struct task sc_statchg_task;

sys/dev/fdt/qcpas.c

104

struct task sc_glink_rx;

sys/dev/fdt/rkdrm.h

74

struct task switchtask;

sys/dev/fdt/tcpci.c

166

struct task sc_task;

sys/dev/fdt/xhci_fdt.c

55

struct task sc_snps_connect_task;

sys/dev/ic/athvar.h

368

#define ATH_TASK_INIT(task, func, context) \

sys/dev/ic/athvar.h

370

(task)->t_func = (func); \

sys/dev/ic/athvar.h

371

(task)->t_context = (context); \

sys/dev/ic/athvar.h

373

#define ATH_TASK_RUN_OR_ENQUEUE(task) ((*(task)->t_func)((task)->t_context, 1))

sys/dev/ic/bwfmvar.h

183

struct task sc_task;

sys/dev/ic/dwqevar.h

82

struct task sc_statchg_task;

sys/dev/ic/mpivar.h

156

struct task sc_evt_rescan;

sys/dev/ic/qla.c

1708

qla_update_done(struct qla_softc *sc, int task)

sys/dev/ic/qla.c

1710

atomic_clearbits_int(&sc->sc_update_tasks, task);

sys/dev/ic/qla.c

1714

qla_update_start(struct qla_softc *sc, int task)

sys/dev/ic/qla.c

1716

atomic_setbits_int(&sc->sc_update_tasks, task);

sys/dev/ic/qlavar.h

158

struct task sc_update_task;

sys/dev/ic/qlw.c

1184

qlw_update(struct qlw_softc *sc, int task)

sys/dev/ic/qlwvar.h

124

struct task sc_update_task;

sys/dev/ic/qwx.c

344

qwx_add_task(struct qwx_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/ic/qwx.c

354

if (!task_add(taskq, task))

sys/dev/ic/qwx.c

360

qwx_del_task(struct qwx_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/ic/qwx.c

362

if (task_del(taskq, task))

sys/dev/ic/qwxvar.h

1835

struct task init_task; /* NB: not reference-counted */

sys/dev/ic/qwxvar.h

1838

struct task newstate_task;

sys/dev/ic/qwxvar.h

1845

struct task setkey_task;

sys/dev/ic/qwxvar.h

1862

struct task ba_task;

sys/dev/ic/qwxvar.h

1867

struct task set_cc_task;

sys/dev/ic/qwxvar.h

1885

struct task bgscan_task;

sys/dev/ic/qwxvar.h

1886

struct task bgscan_done_task;

sys/dev/ic/qwz.c

308

qwz_add_task(struct qwz_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/ic/qwz.c

318

if (!task_add(taskq, task))

sys/dev/ic/qwz.c

324

qwz_del_task(struct qwz_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/ic/qwz.c

326

if (task_del(taskq, task))

sys/dev/ic/qwzvar.h

1928

struct task init_task; /* NB: not reference-counted */

sys/dev/ic/qwzvar.h

1931

struct task newstate_task;

sys/dev/ic/qwzvar.h

1936

struct task setkey_task;

sys/dev/ic/qwzvar.h

1953

struct task ba_task;

sys/dev/ic/rtl81x9reg.h

895

struct task rl_start;

sys/dev/ic/rtwnvar.h

69

struct task init_task;

sys/dev/ipmi.c

1766

struct task *t;

sys/dev/ipmi.c

969

struct task t;

sys/dev/ipmivar.h

127

struct task sc_wdog_tickle_task;

sys/dev/ofw/ofw_thermal.c

80

struct task tz_poll_task;

sys/dev/pci/arc.c

669

struct task t;

sys/dev/pci/drm/amd/amdgpu/amdgpu.h

973

struct task switchtask;

sys/dev/pci/drm/amd/amdgpu/amdgpu.h

980

struct task burner_task;

sys/dev/pci/drm/amd/amdgpu/amdgpu_debugfs.c

1789

seq_printf(m, "pid:%d\tProcess:%s ----------\n", ti->task.pid, ti->process_name);

sys/dev/pci/drm/amd/amdgpu/amdgpu_dev_coredump.c

223

if (coredump->reset_task_info.task.pid)

sys/dev/pci/drm/amd/amdgpu/amdgpu_dev_coredump.c

226

coredump->reset_task_info.task.pid);

sys/dev/pci/drm/amd/amdgpu/amdgpu_device.c

6781

ti ? &ti->task : NULL);

sys/dev/pci/drm/amd/amdgpu/amdgpu_gem.c

1423

struct task_struct *task;

sys/dev/pci/drm/amd/amdgpu/amdgpu_gem.c

1436

task = pid_task(pid, PIDTYPE_TGID);

sys/dev/pci/drm/amd/amdgpu/amdgpu_gem.c

1438

task ? task->comm : "<unknown>");

sys/dev/pci/drm/amd/amdgpu/amdgpu_gem.c

383

dev_warn(adev->dev, "pid %d\n", ti->task.pid);

sys/dev/pci/drm/amd/amdgpu/amdgpu_job.c

129

info = &ti->task;

sys/dev/pci/drm/amd/amdgpu/amdgpu_ras.c

253

((blk_info.task.pid != task_pid_nr(current)) ||

sys/dev/pci/drm/amd/amdgpu/amdgpu_ras.c

254

strncmp(blk_info.task.comm, current->comm, TASK_COMM_LEN)))

sys/dev/pci/drm/amd/amdgpu/amdgpu_ras.c

256

((blk_info.task.pid != curproc->p_p->ps_pid) ||

sys/dev/pci/drm/amd/amdgpu/amdgpu_ras.c

257

strncmp(blk_info.task.comm, curproc->p_p->ps_comm,

sys/dev/pci/drm/amd/amdgpu/amdgpu_ras.c

262

(blk_info.task.pid == con->init_task_pid) &&

sys/dev/pci/drm/amd/amdgpu/amdgpu_ras.c

263

!strncmp(blk_info.task.comm, con->init_task_comm, TASK_COMM_LEN))

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2609

if (vm->task_info->task.pid == current->pid)

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2612

vm->task_info->task.pid = current->pid;

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2613

get_task_comm(vm->task_info->task.comm, current);

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2621

if (vm->task_info->task.pid == curproc->p_tid)

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2625

vm->task_info->task.pid = curproc->p_tid;

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2626

strlcpy(vm->task_info->task.comm, curproc->p_p->ps_comm,

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2627

sizeof(vm->task_info->task.comm));

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

2912

ti->process_name, ti->task.pid, ti->task.comm, ti->tgid);

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.c

3297

task_info->task.comm, task_info->task.pid);

sys/dev/pci/drm/amd/amdgpu/amdgpu_vm.h

239

struct drm_wedge_task_info task;

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

422

memcpy(&info->task, &vres->task, sizeof(vres->task));

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

569

vres->task.pid = task_pid_nr(current);

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

570

get_task_comm(vres->task.comm, current);

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

572

vres->task.pid = curproc->p_p->ps_pid;

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

573

strlcpy(vres->task.comm, curproc->p_p->ps_comm,

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

574

sizeof(vres->task.comm));

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.c

657

memset(&vres->task, 0, sizeof(vres->task));

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.h

49

struct amdgpu_vres_task task;

sys/dev/pci/drm/amd/amdgpu/amdgpu_vram_mgr.h

57

struct amdgpu_vres_task task;

sys/dev/pci/drm/amd/amdgpu/sdma_v4_0.c

2190

task_info->task.comm, task_info->task.pid);

sys/dev/pci/drm/amd/amdgpu/sdma_v4_4_2.c

1885

task_info->task.comm, task_info->task.pid);

sys/dev/pci/drm/amd/amdgpu/vcn_v1_0.c

157

task_set(&adev->vcn.inst[0].idle_work.work.task,

sys/dev/pci/drm/amd/amdgpu/vcn_v2_5.c

312

task_set(&adev->vcn.inst[j].idle_work.work.task,

sys/dev/pci/drm/amd/amdkfd/kfd_events.c

1316

ti->process_name, ti->tgid, ti->task.comm, ti->task.pid);

sys/dev/pci/drm/amd/amdkfd/kfd_priv.h

1055

struct kfd_process *kfd_get_process(const struct task_struct *task);

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

967

struct task_struct *task = NULL;

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

971

task = current;

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

972

get_task_struct(task);

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

974

task = get_pid_task(pid, PIDTYPE_PID);

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

977

if (task) {

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

978

p = find_process(task, true);

sys/dev/pci/drm/amd/amdkfd/kfd_process.c

979

put_task_struct(task);

sys/dev/pci/drm/amd/amdkfd/kfd_smi_events.c

256

if (task_info->task.pid)

sys/dev/pci/drm/amd/amdkfd/kfd_smi_events.c

258

task_info->task.pid, task_info->task.comm));

sys/dev/pci/drm/amd/amdkfd/kfd_smi_events.c

362

KFD_EVENT_FMT_PROCESS(task_info->task.pid,

sys/dev/pci/drm/amd/amdkfd/kfd_smi_events.c

363

task_info->task.comm));

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

334

struct SMU_Task *task = &toc->tasks[smu8_smu->toc_entry_used_count++];

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

336

task->type = type;

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

337

task->arg = smu8_translate_firmware_enum_to_arg(hwmgr, fw_enum);

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

338

task->next = is_last ? END_OF_TASK_LIST : smu8_smu->toc_entry_used_count;

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

349

task->addr.low = lower_32_bits(smu8_smu->scratch_buffer[i].mc_addr);

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

350

task->addr.high = upper_32_bits(smu8_smu->scratch_buffer[i].mc_addr);

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

351

task->size_bytes = smu8_smu->scratch_buffer[i].data_size;

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

371

struct SMU_Task *task = &toc->tasks[smu8_smu->toc_entry_used_count++];

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

373

task->type = TASK_TYPE_UCODE_LOAD;

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

374

task->arg = smu8_translate_firmware_enum_to_arg(hwmgr, fw_enum);

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

375

task->next = is_last ? END_OF_TASK_LIST : smu8_smu->toc_entry_used_count;

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

386

task->addr.low = lower_32_bits(smu8_smu->driver_buffer[i].mc_addr);

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

387

task->addr.high = upper_32_bits(smu8_smu->driver_buffer[i].mc_addr);

sys/dev/pci/drm/amd/pm/powerplay/smumgr/smu8_smumgr.c

388

task->size_bytes = smu8_smu->driver_buffer[i].data_size;

sys/dev/pci/drm/apple/apldcp.c

109

struct task task;

sys/dev/pci/drm/apple/apldcp.c

204

task_set(&rtktask->task, apple_rtkit_do_recv, rtktask);

sys/dev/pci/drm/apple/apldcp.c

205

task_add(rtk->tq, &rtktask->task);

sys/dev/pci/drm/apple/apldrm.c

50

struct task sc_switchtask;

sys/dev/pci/drm/apple/apldrm.c

53

struct task sc_burner_task;

sys/dev/pci/drm/drm_debugfs.c

105

task = pid_task(pid, PIDTYPE_TGID);

sys/dev/pci/drm/drm_debugfs.c

106

uid = task ? __task_cred(task)->euid : GLOBAL_ROOT_UID;

sys/dev/pci/drm/drm_debugfs.c

108

task ? task->comm : "<unknown>",

sys/dev/pci/drm/drm_debugfs.c

317

struct task_struct *task;

sys/dev/pci/drm/drm_debugfs.c

325

task = pid_task(pid, PIDTYPE_TGID);

sys/dev/pci/drm/drm_debugfs.c

327

seq_printf(m, "pid: %d\n", task ? task->pid : 0);

sys/dev/pci/drm/drm_debugfs.c

328

seq_printf(m, "comm: %s\n", task ? task->comm : "Unset");

sys/dev/pci/drm/drm_debugfs.c

99

struct task_struct *task;

sys/dev/pci/drm/drm_file.c

1060

struct task_struct *task;

sys/dev/pci/drm/drm_file.c

1062

struct proc *task;

sys/dev/pci/drm/drm_file.c

1074

task = pid_task(pid, PIDTYPE_TGID);

sys/dev/pci/drm/drm_file.c

1077

task ? task->comm : "Unset",

sys/dev/pci/drm/drm_file.c

1078

task ? task->pid : 0, file_priv->client_id,

sys/dev/pci/drm/drm_file.c

1081

task = NULL;

sys/dev/pci/drm/drm_file.c

1083

task ? task->p_p->ps_comm : "Unset",

sys/dev/pci/drm/drm_file.c

1084

task ? task->p_p->ps_pid : 0, file_priv->client_id,

sys/dev/pci/drm/drm_flip_work.c

109

struct drm_flip_task *task, *tmp;

sys/dev/pci/drm/drm_flip_work.c

120

list_for_each_entry_safe(task, tmp, &tasks, node) {

sys/dev/pci/drm/drm_flip_work.c

121

work->func(work, task->data);

sys/dev/pci/drm/drm_flip_work.c

122

kfree(task);

sys/dev/pci/drm/drm_flip_work.c

38

struct drm_flip_task *task;

sys/dev/pci/drm/drm_flip_work.c

40

task = kzalloc(sizeof(*task), flags);

sys/dev/pci/drm/drm_flip_work.c

41

if (task)

sys/dev/pci/drm/drm_flip_work.c

42

task->data = data;

sys/dev/pci/drm/drm_flip_work.c

44

return task;

sys/dev/pci/drm/drm_flip_work.c

47

static void drm_flip_work_queue_task(struct drm_flip_work *work, struct drm_flip_task *task)

sys/dev/pci/drm/drm_flip_work.c

52

list_add_tail(&task->node, &work->queued);

sys/dev/pci/drm/drm_flip_work.c

66

struct drm_flip_task *task;

sys/dev/pci/drm/drm_flip_work.c

68

task = drm_flip_work_allocate_task(val,

sys/dev/pci/drm/drm_flip_work.c

70

if (task) {

sys/dev/pci/drm/drm_flip_work.c

71

drm_flip_work_queue_task(work, task);

sys/dev/pci/drm/drm_linux.c

1652

task_set(&bd->task, backlight_do_update_status, bd);

sys/dev/pci/drm/drm_linux.c

1670

task_add(systq, &bd->task);

sys/dev/pci/drm/drm_linux.c

329

task_set(&work->task, (void (*)(void *))func, work);

sys/dev/pci/drm/drm_linux.c

336

return task_add(work->tq, &work->task);

sys/dev/pci/drm/drm_linux.c

342

return task_del(work->tq, &work->task);

sys/dev/pci/drm/drm_syncobj.c

1097

wake_up_process(wait->task);

sys/dev/pci/drm/drm_syncobj.c

1118

wake_up_process(wait->task);

sys/dev/pci/drm/drm_syncobj.c

1169

entries[i].task = current;

sys/dev/pci/drm/drm_syncobj.c

1171

entries[i].task = curproc;

sys/dev/pci/drm/drm_syncobj.c

218

struct task_struct *task;

sys/dev/pci/drm/drm_syncobj.c

220

struct proc *task;

sys/dev/pci/drm/drm_syncobj.c

493

wait.task = current;

sys/dev/pci/drm/drm_syncobj.c

495

wait.task = curproc;

sys/dev/pci/drm/drm_vblank_work.c

293

sched_set_fifo(worker->task);

sys/dev/pci/drm/i915/i915_drv.h

237

struct task switchtask;

sys/dev/pci/drm/i915/i915_drv.h

240

struct task burner_task;

sys/dev/pci/drm/i915/i915_gpu_error.c

1511

struct task_struct *task;

sys/dev/pci/drm/i915/i915_gpu_error.c

1524

task = pid_task(ctx->pid, PIDTYPE_PID);

sys/dev/pci/drm/i915/i915_gpu_error.c

1525

if (task) {

sys/dev/pci/drm/i915/i915_gpu_error.c

1526

strscpy(e->comm, task->comm);

sys/dev/pci/drm/i915/i915_gpu_error.c

1527

e->pid = task->pid;

sys/dev/pci/drm/i915/i915_request.c

229

wrk->task.t_func(wrk);

sys/dev/pci/drm/include/linux/backlight.h

39

struct task task;

sys/dev/pci/drm/include/linux/interrupt.h

113

task_del(taskletq, &ts->task);

sys/dev/pci/drm/include/linux/interrupt.h

121

task_add(taskletq, &ts->task);

sys/dev/pci/drm/include/linux/interrupt.h

128

task_add(taskletq, &ts->task);

sys/dev/pci/drm/include/linux/interrupt.h

58

struct task task;

sys/dev/pci/drm/include/linux/interrupt.h

81

task_set(&ts->task, tasklet_run, ts);

sys/dev/pci/drm/include/linux/interrupt.h

93

task_set(&ts->task, tasklet_run, ts);

sys/dev/pci/drm/include/linux/irq_work.h

36

struct task task;

sys/dev/pci/drm/include/linux/irq_work.h

47

task_set(&work->task, (void (*)(void *))func, work);

sys/dev/pci/drm/include/linux/irq_work.h

53

return task_add(work->tq, &work->task);

sys/dev/pci/drm/include/linux/kthread.h

20

struct task task;

sys/dev/pci/drm/include/linux/workqueue.h

105

task_del(work->tq, &work->task);

sys/dev/pci/drm/include/linux/workqueue.h

112

return task_del(work->tq, &work->task);

sys/dev/pci/drm/include/linux/workqueue.h

116

#define work_pending(work) task_pending(&(work)->task)

sys/dev/pci/drm/include/linux/workqueue.h

137

task_add(dwork->tq, &dwork->work.task);

sys/dev/pci/drm/include/linux/workqueue.h

158

.work.task = TASK_INITIALIZER((void (*)(void *))(fn), &(dw).work) \

sys/dev/pci/drm/include/linux/workqueue.h

165

return task_add(work->tq, &work->task);

sys/dev/pci/drm/include/linux/workqueue.h

198

return task_del(dwork->tq, &dwork->work.task);

sys/dev/pci/drm/include/linux/workqueue.h

208

return task_del(dwork->tq, &dwork->work.task);

sys/dev/pci/drm/include/linux/workqueue.h

216

return task_pending(&dwork->work.task);

sys/dev/pci/drm/include/linux/workqueue.h

239

task_del(work->tq, &work->task);

sys/dev/pci/drm/include/linux/workqueue.h

73

struct task task;

sys/dev/pci/drm/include/linux/workqueue.h

83

task_set(&work->task, (void (*)(void *))func, work);

sys/dev/pci/drm/include/linux/workqueue.h

92

return task_add(work->tq, &work->task);

sys/dev/pci/drm/radeon/radeon.h

2333

struct task switchtask;

sys/dev/pci/drm/radeon/radeon.h

2338

struct task burner_task;

sys/dev/pci/drm/radeon/radeon_fence.c

1000

wake_up_process(wait->task);

sys/dev/pci/drm/radeon/radeon_fence.c

1010

cb.task = curproc;

sys/dev/pci/drm/radeon/radeon_fence.c

991

void *task;

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

179

struct task_struct *task = s_timer->ctx->task;

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

181

do_send_sig_info(SIGTERM, SEND_SIG_PRIV, task, PIDTYPE_PID);

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

214

struct task_struct *task;

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

219

task = kthread_create(threaded_ttm_bo_reserve, bo, "ttm-bo-reserve");

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

221

if (IS_ERR(task))

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

227

wake_up_process(task);

sys/dev/pci/drm/ttm/tests/ttm_bo_test.c

229

err = kthread_stop(task);

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

598

struct task_struct *task;

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

617

task = kthread_create(threaded_dma_resv_signal, bo, "dma-resv-signal");

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

618

if (IS_ERR(task))

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

621

wake_up_process(task);

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

711

struct task_struct *task;

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

738

task = kthread_create(threaded_fence_signal, man->move, "move-fence-signal");

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

739

if (IS_ERR(task))

sys/dev/pci/drm/ttm/tests/ttm_bo_validate_test.c

742

wake_up_process(task);

sys/dev/pci/if_iavf.c

671

struct task sc_reset_task;

sys/dev/pci/if_ice.c

292

struct task sc_admin_task;

sys/dev/pci/if_ipwvar.h

119

struct task sc_scantask;

sys/dev/pci/if_ipwvar.h

120

struct task sc_authandassoctask;

sys/dev/pci/if_iwivar.h

113

struct task init_task;

sys/dev/pci/if_iwm.c

479

void iwm_add_task(struct iwm_softc *, struct taskq *, struct task *);

sys/dev/pci/if_iwm.c

480

void iwm_del_task(struct iwm_softc *, struct taskq *, struct task *);

sys/dev/pci/if_iwm.c

8481

iwm_add_task(struct iwm_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/pci/if_iwm.c

8491

if (!task_add(taskq, task))

sys/dev/pci/if_iwm.c

8497

iwm_del_task(struct iwm_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/pci/if_iwm.c

8499

if (task_del(taskq, task))

sys/dev/pci/if_iwmvar.h

484

struct task init_task; /* NB: not reference-counted */

sys/dev/pci/if_iwmvar.h

486

struct task newstate_task;

sys/dev/pci/if_iwmvar.h

493

struct task ba_task;

sys/dev/pci/if_iwmvar.h

498

struct task mac_ctxt_task;

sys/dev/pci/if_iwmvar.h

501

struct task phy_ctxt_task;

sys/dev/pci/if_iwmvar.h

601

struct task bgscan_done_task;

sys/dev/pci/if_iwnvar.h

269

struct task init_task;

sys/dev/pci/if_iwx.c

439

void iwx_add_task(struct iwx_softc *, struct taskq *, struct task *);

sys/dev/pci/if_iwx.c

440

void iwx_del_task(struct iwx_softc *, struct taskq *, struct task *);

sys/dev/pci/if_iwx.c

8217

iwx_add_task(struct iwx_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/pci/if_iwx.c

8227

if (!task_add(taskq, task))

sys/dev/pci/if_iwx.c

8233

iwx_del_task(struct iwx_softc *sc, struct taskq *taskq, struct task *task)

sys/dev/pci/if_iwx.c

8235

if (task_del(taskq, task))

sys/dev/pci/if_iwxvar.h

643

struct task init_task; /* NB: not reference-counted */

sys/dev/pci/if_iwxvar.h

645

struct task newstate_task;

sys/dev/pci/if_iwxvar.h

652

struct task ba_task;

sys/dev/pci/if_iwxvar.h

657

struct task setkey_task;

sys/dev/pci/if_iwxvar.h

671

struct task mac_ctxt_task;

sys/dev/pci/if_iwxvar.h

674

struct task phy_ctxt_task;

sys/dev/pci/if_iwxvar.h

777

struct task bgscan_done_task;

sys/dev/pci/if_ixl.c

1243

struct task sc_arq_task;

sys/dev/pci/if_ixl.c

1251

struct task sc_link_state_task;

sys/dev/pci/if_mcx.c

2493

struct task sc_port_change;

sys/dev/pci/if_mwx.c

320

struct task sc_newstate_task;

sys/dev/pci/if_mwx.c

321

struct task sc_bgscan_done_task;

sys/dev/pci/if_mwx.c

322

struct task sc_setkey_task;

sys/dev/pci/if_mwx.c

323

struct task sc_scan_task;

sys/dev/pci/if_mwx.c

324

struct task sc_reset_task;

sys/dev/pci/if_qwx_pci.c

371

struct task rddm_task;

sys/dev/pci/if_qwz_pci.c

372

struct task rddm_task;

sys/dev/pci/if_rgereg.h

423

struct task sc_task;

sys/dev/pci/if_wpivar.h

168

struct task init_task;

sys/dev/pci/mfii.c

295

struct task sc_aen_task;

sys/dev/pci/mfii.c

299

struct task sc_abort_task;

sys/dev/pci/mpii.c

228

struct task sc_evt_sas_task;

sys/dev/pci/ppb.c

81

struct task sc_insert_task;

sys/dev/pci/ppb.c

82

struct task sc_rescan_task;

sys/dev/pci/ppb.c

83

struct task sc_remove_task;

sys/dev/pci/qle.c

1591

qle_update_done(struct qle_softc *sc, int task)

sys/dev/pci/qle.c

1593

atomic_clearbits_int(&sc->sc_update_tasks, task);

sys/dev/pci/qle.c

1605

qle_update_start(struct qle_softc *sc, int task)

sys/dev/pci/qle.c

1607

atomic_setbits_int(&sc->sc_update_tasks, task);

sys/dev/pci/qle.c

1613

qle_update_defer(struct qle_softc *sc, int task)

sys/dev/pci/qle.c

1615

atomic_setbits_int(&sc->sc_update_tasks, task);

sys/dev/pci/qle.c

185

struct task sc_update_task;

sys/dev/pci/vmwpvs.c

316

struct task sc_msg_task;

sys/dev/pckbc/pms.c

166

struct task sc_rsttask;

sys/dev/pv/hvs.c

215

struct task sc_probetask;

sys/dev/pv/hypervvar.h

159

struct task sc_sdtask; /* shutdown */

sys/dev/pv/hypervvar.h

84

struct task ch_task;

sys/dev/pv/viomb.c

99

struct task sc_task;

sys/dev/pv/vmt.c

243

struct task sc_quiesce_task;

sys/dev/pv/vmt.c

244

struct task sc_nicinfo_task;

sys/dev/pv/xenstore.c

143

struct task *xsw_task;

sys/dev/pv/xenstore.c

820

xs_watch(void *xsc, const char *path, const char *property, struct task *task,

sys/dev/pv/xenstore.c

839

task_set(task, cb, arg);

sys/dev/pv/xenstore.c

840

xsw->xsw_task = task;

sys/dev/pv/xenvar.h

115

struct task sc_ctltsk; /* control task */

sys/dev/pv/xenvar.h

190

int xs_watch(void *, const char *, const char *, struct task *,

sys/dev/pv/xenvar.h

50

struct task xi_task;

sys/dev/pv/xenvar.h

80

struct task dl_task;

sys/dev/rasops/rasops.h

131

struct task ri_switchtask;

sys/dev/rnd.c

324

struct task rnd_task = TASK_INITIALIZER(rnd_init, NULL);

sys/dev/sdmmc/if_bwfm_sdio.c

112

struct task sc_task;

sys/dev/sdmmc/sdmmc.c

240

struct sdmmc_task *task;

sys/dev/sdmmc/sdmmc.c

248

for (task = TAILQ_FIRST(&sc->sc_tskq); task != NULL;

sys/dev/sdmmc/sdmmc.c

249

task = TAILQ_FIRST(&sc->sc_tskq)) {

sys/dev/sdmmc/sdmmc.c

251

sdmmc_del_task(task);

sys/dev/sdmmc/sdmmc.c

252

task->func(task->arg);

sys/dev/sdmmc/sdmmc.c

280

sdmmc_add_task(struct sdmmc_softc *sc, struct sdmmc_task *task)

sys/dev/sdmmc/sdmmc.c

285

TAILQ_INSERT_TAIL(&sc->sc_tskq, task, next);

sys/dev/sdmmc/sdmmc.c

286

task->onqueue = 1;

sys/dev/sdmmc/sdmmc.c

287

task->sc = sc;

sys/dev/sdmmc/sdmmc.c

293

sdmmc_del_task(struct sdmmc_task *task)

sys/dev/sdmmc/sdmmc.c

295

struct sdmmc_softc *sc = task->sc;

sys/dev/sdmmc/sdmmc.c

302

task->sc = NULL;

sys/dev/sdmmc/sdmmc.c

303

task->onqueue = 0;

sys/dev/sdmmc/sdmmc.c

304

TAILQ_REMOVE(&sc->sc_tskq, task, next);

sys/dev/softraidvar.h

410

struct task swu_task;

sys/dev/softraidvar.h

626

struct task sd_meta_save_task;

sys/dev/softraidvar.h

627

struct task sd_hotspare_rebuild_task;

sys/dev/usb/dwc2/dwc2.h

262

struct task work;

sys/dev/usb/dwc2/dwc2_core.h

1138

struct task wf_otg;

sys/dev/usb/dwc2/dwc2var.h

113

void dwc2_worker(struct task *, void *);

sys/dev/usb/umcs.c

95

struct task sc_status_task;

sys/dev/usb/umstc.c

45

struct task sc_brightness_task;

sys/dev/usb/usb.c

293

usb_add_task(struct usbd_device *dev, struct usb_task *task)

sys/dev/usb/usb.c

303

if (usbd_is_dying(dev) && (task->type != USB_TASK_TYPE_ABORT))

sys/dev/usb/usb.c

306

DPRINTFN(2,("%s: task=%p state=%d type=%d\n", __func__, task,

sys/dev/usb/usb.c

307

task->state, task->type));

sys/dev/usb/usb.c

310

if (!(task->state & USB_TASK_STATE_ONQ)) {

sys/dev/usb/usb.c

311

switch (task->type) {

sys/dev/usb/usb.c

313

TAILQ_INSERT_TAIL(&usb_abort_tasks, task, next);

sys/dev/usb/usb.c

316

TAILQ_INSERT_TAIL(&usb_explore_tasks, task, next);

sys/dev/usb/usb.c

319

TAILQ_INSERT_TAIL(&usb_generic_tasks, task, next);

sys/dev/usb/usb.c

322

task->state |= USB_TASK_STATE_ONQ;

sys/dev/usb/usb.c

323

task->dev = dev;

sys/dev/usb/usb.c

325

if (task->type == USB_TASK_TYPE_ABORT)

sys/dev/usb/usb.c

333

usb_rem_task(struct usbd_device *dev, struct usb_task *task)

sys/dev/usb/usb.c

337

if (!(task->state & USB_TASK_STATE_ONQ))

sys/dev/usb/usb.c

340

DPRINTFN(2,("%s: task=%p state=%d type=%d\n", __func__, task,

sys/dev/usb/usb.c

341

task->state, task->type));

sys/dev/usb/usb.c

345

switch (task->type) {

sys/dev/usb/usb.c

347

TAILQ_REMOVE(&usb_abort_tasks, task, next);

sys/dev/usb/usb.c

350

TAILQ_REMOVE(&usb_explore_tasks, task, next);

sys/dev/usb/usb.c

353

TAILQ_REMOVE(&usb_generic_tasks, task, next);

sys/dev/usb/usb.c

356

task->state &= ~USB_TASK_STATE_ONQ;

sys/dev/usb/usb.c

357

if (task->state == USB_TASK_STATE_NONE)

sys/dev/usb/usb.c

358

wakeup(task);

sys/dev/usb/usb.c

364

usb_wait_task(struct usbd_device *dev, struct usb_task *task)

sys/dev/usb/usb.c

368

DPRINTFN(2,("%s: task=%p state=%d type=%d\n", __func__, task,

sys/dev/usb/usb.c

369

task->state, task->type));

sys/dev/usb/usb.c

371

if (task->state == USB_TASK_STATE_NONE)

sys/dev/usb/usb.c

375

while (task->state != USB_TASK_STATE_NONE) {

sys/dev/usb/usb.c

377

tsleep_nsec(task, PWAIT, "endtask", INFSLP);

sys/dev/usb/usb.c

383

usb_rem_wait_task(struct usbd_device *dev, struct usb_task *task)

sys/dev/usb/usb.c

385

usb_rem_task(dev, task);

sys/dev/usb/usb.c

386

usb_wait_task(dev, task);

sys/dev/usb/usb.c

392

struct usb_task *task;

sys/dev/usb/usb.c

399

if ((task = TAILQ_FIRST(&usb_explore_tasks)) != NULL)

sys/dev/usb/usb.c

400

TAILQ_REMOVE(&usb_explore_tasks, task, next);

sys/dev/usb/usb.c

401

else if ((task = TAILQ_FIRST(&usb_generic_tasks)) != NULL)

sys/dev/usb/usb.c

402

TAILQ_REMOVE(&usb_generic_tasks, task, next);

sys/dev/usb/usb.c

413

task->state |= USB_TASK_STATE_RUN;

sys/dev/usb/usb.c

414

task->state &= ~USB_TASK_STATE_ONQ;

sys/dev/usb/usb.c

416

if (!usbd_is_dying(task->dev)) {

sys/dev/usb/usb.c

418

task->fun(task->arg);

sys/dev/usb/usb.c

421

task->state &= ~USB_TASK_STATE_RUN;

sys/dev/usb/usb.c

422

if (task->state == USB_TASK_STATE_NONE)

sys/dev/usb/usb.c

423

wakeup(task);

sys/dev/usb/usb.c

438

struct usb_task *task;

sys/dev/usb/usb.c

445

if ((task = TAILQ_FIRST(&usb_abort_tasks)) != NULL)

sys/dev/usb/usb.c

446

TAILQ_REMOVE(&usb_abort_tasks, task, next);

sys/dev/usb/usb.c

458

task->state |= USB_TASK_STATE_RUN;

sys/dev/usb/usb.c

459

task->state &= ~USB_TASK_STATE_ONQ;

sys/dev/usb/usb.c

461

task->fun(task->arg);

sys/dev/usb/usb.c

463

task->state &= ~USB_TASK_STATE_RUN;

sys/dev/usb/usb.c

464

if (task->state == USB_TASK_STATE_NONE)

sys/dev/usb/usb.c

465

wakeup(task);

sys/dev/vscsi.c

475

struct task t;

sys/dev/wscons/wsdisplay.c

87

struct task scr_emulbell_task;

sys/dev/wscons/wskbd.c

180

struct task sc_kbd_backlight_task;

sys/dev/wscons/wskbd.c

183

struct task sc_brightness_task;

sys/kern/kern_sched.c

720

struct task task;

sys/kern/kern_sched.c

736

task_set(&task, sched_barrier_task, &sb);

sys/kern/kern_sched.c

738

task_add(systqmp, &task);

sys/kern/kern_sensors.c

178

struct task task;

sys/kern/kern_sensors.c

207

task_set(&st->task, sensor_task_work, st);

sys/kern/kern_sensors.c

234

task_add(sensors_taskq, &st->task);

sys/kern/kern_task.c

131

int taskq_next_work(struct taskq *, struct task *);

sys/kern/kern_task.c

275

struct task t = TASK_INITIALIZER(taskq_barrier_task, tq);

sys/kern/kern_task.c

332

taskq_del_barrier(struct taskq *tq, struct task *t)

sys/kern/kern_task.c

341

task_set(struct task *t, void (*fn)(void *), void *arg)

sys/kern/kern_task.c

349

task_add(struct taskq *tq, struct task *w)

sys/kern/kern_task.c

375

task_del(struct taskq *tq, struct task *w)

sys/kern/kern_task.c

394

taskq_next_work(struct taskq *tq, struct task *work)

sys/kern/kern_task.c

396

struct task *next;

sys/kern/kern_task.c

427

struct task work;

sys/kern/kern_time.c

1012

struct task resettodr_task = TASK_INITIALIZER(perform_resettodr, NULL);

sys/kern/kern_xxx.c

90

struct task powerdown_task = TASK_INITIALIZER(do_powerdown, NULL);

sys/kern/subr_disk.c

1108

task_set(&dat->task, disk_attach_callback, dat);

sys/kern/subr_disk.c

1109

task_add(systq, &dat->task);

sys/kern/subr_disk.c

99

struct task task;

sys/kern/subr_pool.c

272

struct task pool_gc_task = TASK_INITIALIZER(pool_gc_pages, NULL);

sys/kern/uipc_usrreq.c

104

struct task unp_gc_task = TASK_INITIALIZER(unp_gc, NULL);

sys/net/art.c

107

static struct task art_table_gc_task =

sys/net/art.c

112

static struct task art_node_gc_task = TASK_INITIALIZER(art_gc, NULL);

sys/net/bfd.h

137

struct task bc_bfd_task;

sys/net/bfd.h

138

struct task bc_bfd_send_task;

sys/net/bfd.h

139

struct task bc_upcall_task;

sys/net/bfd.h

140

struct task bc_clear_task;

sys/net/bpfdesc.h

106

struct task bd_wake_task; /* defer pgsigio() and selwakeup() */

sys/net/if.c

1186

struct task *t, *nt;

sys/net/if.c

1187

struct task cursor = { .t_func = NULL };

sys/net/if.c

1245

if_detachhook_add(struct ifnet *ifp, struct task *t)

sys/net/if.c

1253

if_detachhook_del(struct ifnet *ifp, struct task *t)

sys/net/if.c

1895

if_linkstatehook_add(struct ifnet *ifp, struct task *t)

sys/net/if.c

1903

if_linkstatehook_del(struct ifnet *ifp, struct task *t)

sys/net/if.c

247

struct task if_input_task_locked = TASK_INITIALIZER(if_netisr, NULL);

sys/net/if.c

3654

if_addrhook_add(struct ifnet *ifp, struct task *t)

sys/net/if.c

3662

if_addrhook_del(struct ifnet *ifp, struct task *t)

sys/net/if.c

3823

struct task barriers[NET_TASKQ];

sys/net/if_aggr.c

360

struct task p_lhook;

sys/net/if_aggr.c

361

struct task p_dhook;

sys/net/if_aggr.c

386

struct task p_rxm_task;

sys/net/if_bpe.c

81

struct task sc_ltask;

sys/net/if_bpe.c

82

struct task sc_dtask;

sys/net/if_bridge.h

376

struct task bp_ltask; /* if linkstate hook */

sys/net/if_bridge.h

469

struct task bif_dtask;

sys/net/if_ethersubr.c

1362

struct task epg_hook;

sys/net/if_gre.c

414

struct task sc_send_task;

sys/net/if_gre.c

417

struct task sc_ltask;

sys/net/if_gre.c

418

struct task sc_dtask;

sys/net/if_pflow.h

249

struct task sc_outputtask;

sys/net/if_pfsync.c

160

struct task s_task;

sys/net/if_pfsync.c

164

struct task s_send;

sys/net/if_pfsync.c

168

struct task s_deferrals_task;

sys/net/if_pfsync.c

205

struct task sc_ltask;

sys/net/if_pfsync.c

206

struct task sc_dtask;

sys/net/if_sec.c

111

static struct task sec_tdb_gc_task =

sys/net/if_sec.c

75

struct task sc_send;

sys/net/if_sppp.h

147

struct task set_addr_task; /* set address from process context */

sys/net/if_sppp.h

148

struct task clear_addr_task; /* clear address from process context */

sys/net/if_sppp.h

177

struct task pp_autodial;

sys/net/if_tpmr.c

76

struct task p_ltask;

sys/net/if_tpmr.c

77

struct task p_dtask;

sys/net/if_trunk.h

181

struct task tp_ltask; /* if state hook */

sys/net/if_trunk.h

182

struct task tp_dtask; /* if detach hook */

sys/net/if_var.h

206

struct task if_watchdogtask; /* [I] watchdog task */

sys/net/if_var.h

207

struct task if_linkstatetask; /* [I] task to do route updates */

sys/net/if_var.h

397

void if_addrhook_add(struct ifnet *, struct task *);

sys/net/if_var.h

398

void if_addrhook_del(struct ifnet *, struct task *);

sys/net/if_var.h

400

void if_linkstatehook_add(struct ifnet *, struct task *);

sys/net/if_var.h

401

void if_linkstatehook_del(struct ifnet *, struct task *);

sys/net/if_var.h

402

void if_detachhook_add(struct ifnet *, struct task *);

sys/net/if_var.h

403

void if_detachhook_del(struct ifnet *, struct task *);

sys/net/if_var.h

92

struct task;

sys/net/if_veb.c

147

struct task p_ltask;

sys/net/if_veb.c

148

struct task p_dtask;

sys/net/if_vlan.c

100

struct task sc_ltask;

sys/net/if_vlan.c

101

struct task sc_dtask;

sys/net/if_vxlan.c

136

struct task sc_dtask;

sys/net/if_vxlan.c

149

struct task sc_send_task;

sys/net/if_wg.c

218

struct task p_send_initiation;

sys/net/if_wg.c

219

struct task p_send_keepalive;

sys/net/if_wg.c

220

struct task p_clear_secrets;

sys/net/if_wg.c

221

struct task p_deliver_out;

sys/net/if_wg.c

222

struct task p_deliver_in;

sys/net/if_wg.c

272

struct task sc_handshake;

sys/net/if_wg.c

275

struct task sc_encap;

sys/net/if_wg.c

276

struct task sc_decap;

sys/net/ifq.c

189

struct task t = TASK_INITIALIZER(cond_signal_handler, &c);

sys/net/ifq.c

86

ifq_serialize(struct ifqueue *ifq, struct task *t)

sys/net/ifq.c

88

struct task work;

sys/net/ifq.h

445

void ifq_serialize(struct ifqueue *, struct task *);

sys/net/ifq.h

65

struct task ifq_bundle;

sys/net/ifq.h

68

struct task ifq_start;

sys/net/ifq.h

69

struct task ifq_restart;

sys/net/ifq.h

89

struct task ifiq_task;

sys/net/netisr.h

58

extern struct task if_input_task_locked;

sys/net/pf.c

1880

struct task pf_purge_states_task =

sys/net/pf.c

1952

struct task pf_purge_task =

sys/net/pf_if.c

307

struct task *t;

sys/net/pf_if.c

331

struct task *t;

sys/net/pfvar_priv.h

617

extern struct task pf_purge_task;

sys/net80211/ieee80211_var.h

328

struct task ic_rtm_80211info_task;

sys/netinet/ip_carp.c

123

struct task sc_atask;

sys/netinet/ip_carp.c

124

struct task sc_ltask;

sys/netinet/ip_carp.c

125

struct task sc_dtask;

sys/netinet/ip_carp.c

129

struct task sc_itask;

sys/netinet/ip_input.c

160

static struct task ipsend_task = TASK_INITIALIZER(ip_send_dispatch, &ipsend_mq);

sys/netinet/ip_input.c

161

static struct task ipsendraw_task =

sys/netinet6/ip6_input.c

121

static struct task ip6send_task =

sys/netinet6/nd6.c

107

struct task nd6_expire_task;

sys/scsi/scsi_base.c

156

task_set(&p->task, scsi_plug_probe, p);

sys/scsi/scsi_base.c

161

task_add(systq, &p->task);

sys/scsi/scsi_base.c

175

task_set(&p->task, scsi_plug_detach, p);

sys/scsi/scsi_base.c

181

task_add(systq, &p->task);

sys/scsi/scsi_base.c

68

struct task task;

sys/sys/eventvar.h

66

struct task kq_task; /* deferring of activation */

sys/sys/socketvar.h

76

struct task ssp_task; /* task for somove */

sys/sys/task.h

27

TAILQ_ENTRY(task) t_entry;

sys/sys/task.h

38

TAILQ_HEAD(task_list, task);

sys/sys/task.h

52

void taskq_del_barrier(struct taskq *, struct task *);

sys/sys/task.h

54

void task_set(struct task *, void (*)(void *), void *);

sys/sys/task.h

55

int task_add(struct taskq *, struct task *);

sys/sys/task.h

56

int task_del(struct taskq *, struct task *);

sys/uvm/uvm_swap.c

198

struct task vb_task;

usr.bin/dig/dig.h

289

onrun_callback(isc_task_t *task, isc_event_t *event);

usr.bin/dig/dighost.c

195

recv_done(isc_task_t *task, isc_event_t *event);

usr.bin/dig/dighost.c

201

connect_timeout(isc_task_t *task, isc_event_t *event);

usr.bin/dig/dighost.c

2476

connect_done(isc_task_t *task, isc_event_t *event);

usr.bin/dig/dighost.c

2663

connect_timeout(isc_task_t *task, isc_event_t *event) {

usr.bin/dig/dighost.c

2667

UNUSED(task);

usr.bin/dig/dighost.c

2730

tcp_length_done(isc_task_t *task, isc_event_t *event) {

usr.bin/dig/dighost.c

2741

UNUSED(task);

usr.bin/dig/dighost.c

2802

result = isc_socket_recvv(query->sock, &query->recvlist, length, task,

usr.bin/dig/dighost.c

2880

connect_done(isc_task_t *task, isc_event_t *event) {

usr.bin/dig/dighost.c

2886

UNUSED(task);

usr.bin/dig/dighost.c

3208

recv_done(isc_task_t *task, isc_event_t *event) {

usr.bin/dig/dighost.c

3222

UNUSED(task);

usr.bin/dig/dighost.c

3756

onrun_callback(isc_task_t *task, isc_event_t *event) {

usr.bin/dig/dighost.c

3757

UNUSED(task);

usr.bin/dig/lib/isc/include/isc/app.h

100

isc_app_onrun(isc_task_t *task, isc_taskaction_t action,

usr.bin/dig/lib/isc/include/isc/socket.h

237

isc_socket_cancel(isc_socket_t *sock, isc_task_t *task,

usr.bin/dig/lib/isc/include/isc/socket.h

335

isc_task_t *task, isc_taskaction_t action,

usr.bin/dig/lib/isc/include/isc/socket.h

371

isc_task_t *task, isc_taskaction_t action, void *arg);

usr.bin/dig/lib/isc/include/isc/socket.h

448

isc_task_t *task, isc_taskaction_t action, void *arg);

usr.bin/dig/lib/isc/include/isc/socket.h

451

isc_task_t *task, isc_taskaction_t action, void *arg,

usr.bin/dig/lib/isc/include/isc/task.h

176

isc_task_send(isc_task_t *task, isc_event_t **eventp);

usr.bin/dig/lib/isc/include/isc/task.h

217

isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first,

usr.bin/dig/lib/isc/include/isc/task.h

243

isc_task_setname(isc_task_t *task, const char *name, void *tag);

usr.bin/dig/lib/isc/include/isc/timer.h

106

isc_task_t *task,

usr.bin/dig/lib/isc/task.c

109

push_readyq(isc_taskmgr_t *manager, isc_task_t *task);

usr.bin/dig/lib/isc/task.c

116

task_finished(isc_task_t *task) {

usr.bin/dig/lib/isc/task.c

117

isc_taskmgr_t *manager = task->manager;

usr.bin/dig/lib/isc/task.c

119

REQUIRE(EMPTY(task->events));

usr.bin/dig/lib/isc/task.c

120

REQUIRE(task->nevents == 0);

usr.bin/dig/lib/isc/task.c

121

REQUIRE(EMPTY(task->on_shutdown));

usr.bin/dig/lib/isc/task.c

122

REQUIRE(task->references == 0);

usr.bin/dig/lib/isc/task.c

123

REQUIRE(task->state == task_state_done);

usr.bin/dig/lib/isc/task.c

125

UNLINK(manager->tasks, task, link);

usr.bin/dig/lib/isc/task.c

127

free(task);

usr.bin/dig/lib/isc/task.c

134

isc_task_t *task;

usr.bin/dig/lib/isc/task.c

139

task = malloc(sizeof(*task));

usr.bin/dig/lib/isc/task.c

140

if (task == NULL)

usr.bin/dig/lib/isc/task.c

142

task->manager = manager;

usr.bin/dig/lib/isc/task.c

143

task->state = task_state_idle;

usr.bin/dig/lib/isc/task.c

144

task->references = 1;

usr.bin/dig/lib/isc/task.c

145

INIT_LIST(task->events);

usr.bin/dig/lib/isc/task.c

146

INIT_LIST(task->on_shutdown);

usr.bin/dig/lib/isc/task.c

147

task->nevents = 0;

usr.bin/dig/lib/isc/task.c

148

task->quantum = quantum;

usr.bin/dig/lib/isc/task.c

149

task->flags = 0;

usr.bin/dig/lib/isc/task.c

150

task->now = 0;

usr.bin/dig/lib/isc/task.c

151

memset(task->name, 0, sizeof(task->name));

usr.bin/dig/lib/isc/task.c

152

task->tag = NULL;

usr.bin/dig/lib/isc/task.c

153

INIT_LINK(task, link);

usr.bin/dig/lib/isc/task.c

154

INIT_LINK(task, ready_link);

usr.bin/dig/lib/isc/task.c

155

INIT_LINK(task, ready_priority_link);

usr.bin/dig/lib/isc/task.c

159

if (task->quantum == 0)

usr.bin/dig/lib/isc/task.c

160

task->quantum = manager->default_quantum;

usr.bin/dig/lib/isc/task.c

161

APPEND(manager->tasks, task, link);

usr.bin/dig/lib/isc/task.c

166

free(task);

usr.bin/dig/lib/isc/task.c

170

*taskp = (isc_task_t *)task;

usr.bin/dig/lib/isc/task.c

190

task_shutdown(isc_task_t *task) {

usr.bin/dig/lib/isc/task.c

198

if (! TASK_SHUTTINGDOWN(task)) {

usr.bin/dig/lib/isc/task.c

199

task->flags |= TASK_F_SHUTTINGDOWN;

usr.bin/dig/lib/isc/task.c

200

if (task->state == task_state_idle) {

usr.bin/dig/lib/isc/task.c

201

INSIST(EMPTY(task->events));

usr.bin/dig/lib/isc/task.c

202

task->state = task_state_ready;

usr.bin/dig/lib/isc/task.c

205

INSIST(task->state == task_state_ready ||

usr.bin/dig/lib/isc/task.c

206

task->state == task_state_running);

usr.bin/dig/lib/isc/task.c

211

for (event = TAIL(task->on_shutdown);

usr.bin/dig/lib/isc/task.c

215

DEQUEUE(task->on_shutdown, event, ev_link);

usr.bin/dig/lib/isc/task.c

216

ENQUEUE(task->events, event, ev_link);

usr.bin/dig/lib/isc/task.c

217

task->nevents++;

usr.bin/dig/lib/isc/task.c

230

task_ready(isc_task_t *task) {

usr.bin/dig/lib/isc/task.c

231

isc_taskmgr_t *manager = task->manager;

usr.bin/dig/lib/isc/task.c

233

REQUIRE(task->state == task_state_ready);

usr.bin/dig/lib/isc/task.c

235

push_readyq(manager, task);

usr.bin/dig/lib/isc/task.c

239

task_detach(isc_task_t *task) {

usr.bin/dig/lib/isc/task.c

245

REQUIRE(task->references > 0);

usr.bin/dig/lib/isc/task.c

247

task->references--;

usr.bin/dig/lib/isc/task.c

248

if (task->references == 0 && task->state == task_state_idle) {

usr.bin/dig/lib/isc/task.c

249

INSIST(EMPTY(task->events));

usr.bin/dig/lib/isc/task.c

258

task->state = task_state_ready;

usr.bin/dig/lib/isc/task.c

267

isc_task_t *task;

usr.bin/dig/lib/isc/task.c

275

task = (isc_task_t *)*taskp;

usr.bin/dig/lib/isc/task.c

277

was_idle = task_detach(task);

usr.bin/dig/lib/isc/task.c

280

task_ready(task);

usr.bin/dig/lib/isc/task.c

286

task_send(isc_task_t *task, isc_event_t **eventp) {

usr.bin/dig/lib/isc/task.c

298

REQUIRE(task->state != task_state_done);

usr.bin/dig/lib/isc/task.c

301

if (task->state == task_state_idle) {

usr.bin/dig/lib/isc/task.c

303

INSIST(EMPTY(task->events));

usr.bin/dig/lib/isc/task.c

304

task->state = task_state_ready;

usr.bin/dig/lib/isc/task.c

306

INSIST(task->state == task_state_ready ||

usr.bin/dig/lib/isc/task.c

307

task->state == task_state_running);

usr.bin/dig/lib/isc/task.c

308

ENQUEUE(task->events, event, ev_link);

usr.bin/dig/lib/isc/task.c

309

task->nevents++;

usr.bin/dig/lib/isc/task.c

316

isc_task_send(isc_task_t *task, isc_event_t **eventp) {

usr.bin/dig/lib/isc/task.c

328

was_idle = task_send(task, eventp);

usr.bin/dig/lib/isc/task.c

346

task_ready(task);

usr.bin/dig/lib/isc/task.c

353

isc_task_t *task;

usr.bin/dig/lib/isc/task.c

361

task = (isc_task_t *)*taskp;

usr.bin/dig/lib/isc/task.c

363

idle1 = task_send(task, eventp);

usr.bin/dig/lib/isc/task.c

364

idle2 = task_detach(task);

usr.bin/dig/lib/isc/task.c

374

task_ready(task);

usr.bin/dig/lib/isc/task.c

382

dequeue_events(isc_task_t *task, void *sender, isc_eventtype_t first,

usr.bin/dig/lib/isc/task.c

399

for (event = HEAD(task->events); event != NULL; event = next_event) {

usr.bin/dig/lib/isc/task.c

405

DEQUEUE(task->events, event, ev_link);

usr.bin/dig/lib/isc/task.c

406

task->nevents--;

usr.bin/dig/lib/isc/task.c

416

isc_task_purgerange(isc_task_t *task, void *sender, isc_eventtype_t first,

usr.bin/dig/lib/isc/task.c

429

count = dequeue_events(task, sender, first, last, tag, &events,

usr.bin/dig/lib/isc/task.c

446

isc_task_setname(isc_task_t *task, const char *name, void *tag) {

usr.bin/dig/lib/isc/task.c

451

strlcpy(task->name, name, sizeof(task->name));

usr.bin/dig/lib/isc/task.c

452

task->tag = tag;

usr.bin/dig/lib/isc/task.c

488

isc_task_t *task;

usr.bin/dig/lib/isc/task.c

491

task = HEAD(manager->ready_tasks);

usr.bin/dig/lib/isc/task.c

493

task = HEAD(manager->ready_priority_tasks);

usr.bin/dig/lib/isc/task.c

495

if (task != NULL) {

usr.bin/dig/lib/isc/task.c

496

DEQUEUE(manager->ready_tasks, task, ready_link);

usr.bin/dig/lib/isc/task.c

497

if (ISC_LINK_LINKED(task, ready_priority_link))

usr.bin/dig/lib/isc/task.c

498

DEQUEUE(manager->ready_priority_tasks, task,

usr.bin/dig/lib/isc/task.c

502

return (task);

usr.bin/dig/lib/isc/task.c

512

push_readyq(isc_taskmgr_t *manager, isc_task_t *task) {

usr.bin/dig/lib/isc/task.c

513

ENQUEUE(manager->ready_tasks, task, ready_link);

usr.bin/dig/lib/isc/task.c

514

if ((task->flags & TASK_F_PRIVILEGED) != 0)

usr.bin/dig/lib/isc/task.c

515

ENQUEUE(manager->ready_priority_tasks, task,

usr.bin/dig/lib/isc/task.c

522

isc_task_t *task;

usr.bin/dig/lib/isc/task.c

536

task = pop_readyq(manager);

usr.bin/dig/lib/isc/task.c

537

if (task != NULL) {

usr.bin/dig/lib/isc/task.c

552

INSIST(task->state == task_state_ready);

usr.bin/dig/lib/isc/task.c

553

task->state = task_state_running;

usr.bin/dig/lib/isc/task.c

554

time(&task->now);

usr.bin/dig/lib/isc/task.c

556

if (!EMPTY(task->events)) {

usr.bin/dig/lib/isc/task.c

557

event = HEAD(task->events);

usr.bin/dig/lib/isc/task.c

558

DEQUEUE(task->events, event, ev_link);

usr.bin/dig/lib/isc/task.c

559

task->nevents--;

usr.bin/dig/lib/isc/task.c

566

(isc_task_t *)task,

usr.bin/dig/lib/isc/task.c

573

if (task->references == 0 &&

usr.bin/dig/lib/isc/task.c

574

EMPTY(task->events) &&

usr.bin/dig/lib/isc/task.c

575

!TASK_SHUTTINGDOWN(task)) {

usr.bin/dig/lib/isc/task.c

600

was_idle = task_shutdown(task);

usr.bin/dig/lib/isc/task.c

604

if (EMPTY(task->events)) {

usr.bin/dig/lib/isc/task.c

609

if (task->references == 0 &&

usr.bin/dig/lib/isc/task.c

610

TASK_SHUTTINGDOWN(task)) {

usr.bin/dig/lib/isc/task.c

615

task->state = task_state_done;

usr.bin/dig/lib/isc/task.c

617

task->state = task_state_idle;

usr.bin/dig/lib/isc/task.c

619

} else if (dispatch_count >= task->quantum) {

usr.bin/dig/lib/isc/task.c

630

task->state = task_state_ready;

usr.bin/dig/lib/isc/task.c

637

task_finished(task);

usr.bin/dig/lib/isc/task.c

660

ENQUEUE(new_ready_tasks, task, ready_link);

usr.bin/dig/lib/isc/task.c

661

if ((task->flags & TASK_F_PRIVILEGED) != 0)

usr.bin/dig/lib/isc/task.c

662

ENQUEUE(new_priority_tasks, task,

usr.bin/dig/lib/isc/task.c

739

isc_task_t *task;

usr.bin/dig/lib/isc/task.c

786

for (task = HEAD(manager->tasks);

usr.bin/dig/lib/isc/task.c

787

task != NULL;

usr.bin/dig/lib/isc/task.c

788

task = NEXT(task, link)) {

usr.bin/dig/lib/isc/task.c

789

if (task_shutdown(task))

usr.bin/dig/lib/isc/task.c

790

push_readyq(manager, task);

usr.bin/dig/lib/isc/timer.c

147

(void)isc_task_purgerange(timer->task,

usr.bin/dig/lib/isc/timer.c

155

isc_task_detach(&timer->task);

usr.bin/dig/lib/isc/timer.c

161

isc_task_t *task, isc_taskaction_t action, void *arg,

usr.bin/dig/lib/isc/timer.c

177

REQUIRE(task != NULL);

usr.bin/dig/lib/isc/timer.c

199

timer->task = NULL;

usr.bin/dig/lib/isc/timer.c

200

isc_task_attach(task, &timer->task);

usr.bin/dig/lib/isc/timer.c

221

isc_task_detach(&timer->task);

usr.bin/dig/lib/isc/timer.c

253

(void)isc_task_purgerange(timer->task,

usr.bin/dig/lib/isc/timer.c

354

isc_task_send(timer->task,

usr.bin/dig/lib/isc/timer.c

39

isc_task_t * task;

usr.bin/dig/lib/isc/unix/app.c

100

task, action, arg));

usr.bin/dig/lib/isc/unix/app.c

104

isc_app_ctxonrun(isc_appctx_t *ctx, isc_task_t *task,

usr.bin/dig/lib/isc/unix/app.c

120

isc_task_attach(task, &cloned_task);

usr.bin/dig/lib/isc/unix/app.c

205

isc_task_t *task;

usr.bin/dig/lib/isc/unix/app.c

218

task = event->ev_sender;

usr.bin/dig/lib/isc/unix/app.c

220

isc_task_sendanddetach(&task, &event);

usr.bin/dig/lib/isc/unix/app.c

64

static isc_result_t isc_app_ctxonrun(isc_appctx_t *ctx, isc_task_t *task,

usr.bin/dig/lib/isc/unix/app.c

96

isc_app_onrun(isc_task_t *task, isc_taskaction_t action,

usr.bin/dig/lib/isc/unix/socket.c

1530

isc_task_t *task;

usr.bin/dig/lib/isc/unix/socket.c

1532

task = (*dev)->ev_sender;

usr.bin/dig/lib/isc/unix/socket.c

1541

isc_task_sendanddetach(&task, (isc_event_t **)dev);

usr.bin/dig/lib/isc/unix/socket.c

1543

isc_task_send(task, (isc_event_t **)dev);

usr.bin/dig/lib/isc/unix/socket.c

1553

isc_task_t *task;

usr.bin/dig/lib/isc/unix/socket.c

1557

task = (*dev)->ev_sender;

usr.bin/dig/lib/isc/unix/socket.c

1565

isc_task_sendanddetach(&task, (isc_event_t **)dev);

usr.bin/dig/lib/isc/unix/socket.c

1567

isc_task_send(task, (isc_event_t **)dev);

usr.bin/dig/lib/isc/unix/socket.c

1934

socket_recv(isc_socket_t *sock, isc_socketevent_t *dev, isc_task_t *task,

usr.bin/dig/lib/isc/unix/socket.c

1941

dev->ev_sender = task;

usr.bin/dig/lib/isc/unix/socket.c

1960

isc_task_attach(task, &ntask);

usr.bin/dig/lib/isc/unix/socket.c

1995

unsigned int minimum, isc_task_t *task,

usr.bin/dig/lib/isc/unix/socket.c

2005

REQUIRE(task != NULL);

usr.bin/dig/lib/isc/unix/socket.c

2040

return (socket_recv(sock, dev, task, 0));

usr.bin/dig/lib/isc/unix/socket.c

2044

socket_send(isc_socket_t *sock, isc_socketevent_t *dev, isc_task_t *task,

usr.bin/dig/lib/isc/unix/socket.c

2052

dev->ev_sender = task;

usr.bin/dig/lib/isc/unix/socket.c

2089

isc_task_attach(task, &ntask);

usr.bin/dig/lib/isc/unix/socket.c

2126

isc_task_t *task, isc_taskaction_t action, void *arg)

usr.bin/dig/lib/isc/unix/socket.c

2128

return (isc_socket_sendtov2(sock, buflist, task, action, arg, NULL,

usr.bin/dig/lib/isc/unix/socket.c

2134

isc_task_t *task, isc_taskaction_t action, void *arg,

usr.bin/dig/lib/isc/unix/socket.c

2145

REQUIRE(task != NULL);

usr.bin/dig/lib/isc/unix/socket.c

2166

return (socket_send(sock, dev, task, address, pktinfo, flags));

usr.bin/dig/lib/isc/unix/socket.c

2217

isc_task_t *task, isc_taskaction_t action, void *arg)

usr.bin/dig/lib/isc/unix/socket.c

2227

REQUIRE(task != NULL);

usr.bin/dig/lib/isc/unix/socket.c

2294

isc_task_send(task, ISC_EVENT_PTR(&dev));

usr.bin/dig/lib/isc/unix/socket.c

2307

isc_task_send(task, ISC_EVENT_PTR(&dev));

usr.bin/dig/lib/isc/unix/socket.c

2317

isc_task_attach(task, &ntask);

usr.bin/dig/lib/isc/unix/socket.c

2343

isc_task_t *task;

usr.bin/dig/lib/isc/unix/socket.c

2432

task = dev->ev_sender;

usr.bin/dig/lib/isc/unix/socket.c

2434

isc_task_sendanddetach(&task, ISC_EVENT_PTR(&dev));

usr.bin/dig/lib/isc/unix/socket.c

2442

isc_socket_cancel(isc_socket_t *sock0, isc_task_t *task, unsigned int how) {

usr.bin/dig/lib/isc/unix/socket.c

2474

if ((task == NULL) || (task == current_task)) {

usr.bin/dig/lib/isc/unix/socket.c

2494

if ((task == NULL) || (task == current_task)) {

usr.bin/dig/lib/isc/unix/socket.c

2516

if ((task == NULL) || (task == current_task)) {

usr.bin/dig/nslookup.c

126

static void getinput(isc_task_t *task, isc_event_t *event);

usr.bin/dig/nslookup.c

873

getinput(isc_task_t *task, isc_event_t *event) {

usr.bin/dig/nslookup.c

874

UNUSED(task);

usr.sbin/iscsid/connection.c

217

conn_task_issue(struct connection *c, struct task *t)

usr.sbin/iscsid/connection.c

226

struct task *t = TAILQ_FIRST(&c->tasks);

usr.sbin/iscsid/connection.c

248

conn_task_cleanup(struct connection *c, struct task *t)

usr.sbin/iscsid/initiator.c

213

task_init(&tl->task, c->session, 1, tl, initiator_login_cb, NULL);

usr.sbin/iscsid/initiator.c

214

task_pdu_add(&tl->task, p);

usr.sbin/iscsid/initiator.c

215

conn_task_issue(c, &tl->task);

usr.sbin/iscsid/initiator.c

221

struct task *t;

usr.sbin/iscsid/initiator.c

280

task_init(&tl->task, s, 0, tl, initiator_logout_cb, NULL);

usr.sbin/iscsid/initiator.c

281

task_pdu_add(&tl->task, p);

usr.sbin/iscsid/initiator.c

283

conn_task_issue(c, &tl->task);

usr.sbin/iscsid/initiator.c

285

session_logout_issue(s, &tl->task);

usr.sbin/iscsid/initiator.c

292

struct task *t;

usr.sbin/iscsid/initiator.c

39

struct task task;

usr.sbin/iscsid/initiator.c

436

initiator_text_build(struct task *t, struct session *s, struct kvp *kvp)

usr.sbin/iscsid/initiator.c

46

struct task task;

usr.sbin/iscsid/initiator.c

524

conn_task_cleanup(c, &tl->task);

usr.sbin/iscsid/initiator.c

532

conn_task_cleanup(c, &tl->task);

usr.sbin/iscsid/initiator.c

534

task_pdu_add(&tl->task, p);

usr.sbin/iscsid/initiator.c

535

conn_task_issue(c, &tl->task);

usr.sbin/iscsid/initiator.c

545

struct task *t = arg;

usr.sbin/iscsid/initiator.c

55

struct pdu *initiator_text_build(struct task *, struct session *,

usr.sbin/iscsid/initiator.c

625

conn_task_cleanup(c, &tl->task);

usr.sbin/iscsid/iscsid.h

288

TAILQ_ENTRY(task) entry;

usr.sbin/iscsid/iscsid.h

357

void session_task_issue(struct session *, struct task *);

usr.sbin/iscsid/iscsid.h

358

void session_logout_issue(struct session *, struct task *);

usr.sbin/iscsid/iscsid.h

366

void conn_task_issue(struct connection *, struct task *);

usr.sbin/iscsid/iscsid.h

368

void conn_task_cleanup(struct connection *, struct task *);

usr.sbin/iscsid/iscsid.h

399

void task_init(struct task *, struct session *, int, void *,

usr.sbin/iscsid/iscsid.h

403

void task_pdu_add(struct task *, struct pdu *);

usr.sbin/iscsid/iscsid.h

75

TAILQ_HEAD(taskq, task);

usr.sbin/iscsid/session.c

109

session_task_issue(struct session *s, struct task *t)

usr.sbin/iscsid/session.c

116

session_logout_issue(struct session *s, struct task *t)

usr.sbin/iscsid/session.c

144

struct task *t = TAILQ_FIRST(&s->tasks);

usr.sbin/iscsid/task.c

41

task_init(struct task *t, struct session *s, int immediate, void *carg,

usr.sbin/iscsid/task.c

62

struct task *t;

usr.sbin/iscsid/task.c

74

task_pdu_add(struct task *t, struct pdu *p)

usr.sbin/iscsid/task.c

98

struct task *t;

usr.sbin/iscsid/vscsi.c

142

task_init(&t->task, s, 0, t, vscsi_callback, vscsi_fail);

usr.sbin/iscsid/vscsi.c

143

task_pdu_add(&t->task, p);

usr.sbin/iscsid/vscsi.c

144

session_task_issue(s, &t->task);

usr.sbin/iscsid/vscsi.c

221

conn_task_cleanup(c, &t->task);

usr.sbin/iscsid/vscsi.c

267

conn_task_cleanup(c, &t->task);

usr.sbin/iscsid/vscsi.c

273

conn_task_cleanup(c, &t->task);

usr.sbin/iscsid/vscsi.c

334

task_pdu_add(&t->task, p);

usr.sbin/iscsid/vscsi.c

336

conn_task_issue(c, &t->task);

usr.sbin/iscsid/vscsi.c

43

struct task task;

usr.sbin/nsd/difffile.c

2057

task_process_expire(namedb_type* db, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2060

zone_type* z = namedb_find_zone(db, task->zname);

usr.sbin/nsd/difffile.c

2061

assert(task->task_type == task_expire);

usr.sbin/nsd/difffile.c

2064

dname_to_string(task->zname, NULL),

usr.sbin/nsd/difffile.c

2065

task->yesno?"expired":"unexpired"));

usr.sbin/nsd/difffile.c

2069

dname_to_string(task->zname,0),

usr.sbin/nsd/difffile.c

2070

task->yesno?"expired":"unexpired"));

usr.sbin/nsd/difffile.c

2072

ok = !task->yesno;

usr.sbin/nsd/difffile.c

2082

task_process_set_verbosity(struct task_list_d* task)

usr.sbin/nsd/difffile.c

2084

DEBUG(DEBUG_IPC,1, (LOG_INFO, "verbosity task %d", (int)task->yesno));

usr.sbin/nsd/difffile.c

2085

verbosity = task->yesno;

usr.sbin/nsd/difffile.c

2090

struct task_list_d* task)

usr.sbin/nsd/difffile.c

2094

if(task->yesno) {

usr.sbin/nsd/difffile.c

2096

task->zname);

usr.sbin/nsd/difffile.c

2106

task_process_writezones(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2108

if(task->yesno) {

usr.sbin/nsd/difffile.c

2110

task->zname);

usr.sbin/nsd/difffile.c

2120

struct task_list_d* task)

usr.sbin/nsd/difffile.c

2124

const char* zname = (const char*)task->zname;

usr.sbin/nsd/difffile.c

2151

z->zonestatid = (unsigned)task->yesno;

usr.sbin/nsd/difffile.c

2159

task_process_del_zone(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2164

task->zname, NULL)));

usr.sbin/nsd/difffile.c

2165

zone = namedb_find_zone(nsd->db, task->zname);

usr.sbin/nsd/difffile.c

2170

nsec3_superzone_clear_for_apex(nsd->db, task->zname);

usr.sbin/nsd/difffile.c

2180

nsec3_superzone_precompile_for_apex(nsd->db, task->zname);

usr.sbin/nsd/difffile.c

2187

task_process_add_key(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2190

key.name = (char*)task->zname;

usr.sbin/nsd/difffile.c

2199

task_process_del_key(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2201

char* name = (char*)task->zname;

usr.sbin/nsd/difffile.c

2208

task_process_cookies(struct nsd* nsd, struct task_list_d* task) {

usr.sbin/nsd/difffile.c

2210

task->newserial ? "yes" : "no", (int)task->yesno));

usr.sbin/nsd/difffile.c

2212

nsd->do_answer_cookie = (int) task->newserial;

usr.sbin/nsd/difffile.c

2213

nsd->cookie_count = (size_t) task->yesno;

usr.sbin/nsd/difffile.c

2214

memmove(nsd->cookie_secrets, task->zname, sizeof(nsd->cookie_secrets));

usr.sbin/nsd/difffile.c

2215

explicit_bzero(task->zname, sizeof(nsd->cookie_secrets));

usr.sbin/nsd/difffile.c

2219

task_process_add_pattern(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2224

buffer_create_from(&buffer, task->zname, task->yesno);

usr.sbin/nsd/difffile.c

2232

task_process_del_pattern(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2234

char* name = (char*)task->zname;

usr.sbin/nsd/difffile.c

2240

task_process_opt_change(struct nsd* nsd, struct task_list_d* task)

usr.sbin/nsd/difffile.c

2244

nsd->options->rrl_ratelimit = task->oldserial;

usr.sbin/nsd/difffile.c

2245

nsd->options->rrl_whitelist_ratelimit = task->newserial;

usr.sbin/nsd/difffile.c

2246

nsd->options->rrl_slip = task->yesno;

usr.sbin/nsd/difffile.c

2250

(void)nsd; (void)task;

usr.sbin/nsd/difffile.c

2257

struct task_list_d* task)

usr.sbin/nsd/difffile.c

2259

DEBUG(DEBUG_IPC,1, (LOG_INFO, "zonestat_inc task %u", (unsigned)task->oldserial));

usr.sbin/nsd/difffile.c

2260

nsd->zonestatdesired = (unsigned)task->oldserial;

usr.sbin/nsd/difffile.c

2267

task_process_apply_xfr(struct nsd* nsd, udb_base* udb, udb_ptr* task)

usr.sbin/nsd/difffile.c

2274

TASKLIST(task)->zname, NULL)));

usr.sbin/nsd/difffile.c

2275

zone = namedb_find_zone(nsd->db, TASKLIST(task)->zname);

usr.sbin/nsd/difffile.c

2279

udb_ptr_free_space(task, udb, TASKLIST(task)->size);

usr.sbin/nsd/difffile.c

2285

df = xfrd_open_xfrfile(nsd, TASKLIST(task)->yesno, "r");

usr.sbin/nsd/difffile.c

2291

udb_ptr_free_space(task, udb, TASKLIST(task)->size);

usr.sbin/nsd/difffile.c

2296

TASKLIST(task)->yesno)) {

usr.sbin/nsd/difffile.c

2313

udb_ptr_free_space(task, udb, TASKLIST(task)->size);

usr.sbin/nsd/difffile.c

2318

udb_ptr* task)

usr.sbin/nsd/difffile.c

2320

switch(TASKLIST(task)->task_type) {

usr.sbin/nsd/difffile.c

2322

task_process_expire(nsd->db, TASKLIST(task));

usr.sbin/nsd/difffile.c

2325

task_process_checkzones(nsd, udb, last_task, TASKLIST(task));

usr.sbin/nsd/difffile.c

2328

task_process_writezones(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2331

task_process_set_verbosity(TASKLIST(task));

usr.sbin/nsd/difffile.c

2334

task_process_add_zone(nsd, udb, last_task, TASKLIST(task));

usr.sbin/nsd/difffile.c

2337

task_process_del_zone(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2340

task_process_add_key(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2343

task_process_del_key(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2346

task_process_add_pattern(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2349

task_process_del_pattern(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2352

task_process_opt_change(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2356

task_process_zonestat_inc(nsd, udb, last_task, TASKLIST(task));

usr.sbin/nsd/difffile.c

2360

task_process_cookies(nsd, TASKLIST(task));

usr.sbin/nsd/difffile.c

2364

(int)TASKLIST(task)->task_type);

usr.sbin/nsd/difffile.c

2367

udb_ptr_free_space(task, udb, TASKLIST(task)->size);

usr.sbin/nsd/difffile.h

158

void task_process_apply_xfr(struct nsd* nsd, udb_base* udb, udb_ptr *task);

usr.sbin/nsd/difffile.h

160

udb_ptr* task);

usr.sbin/nsd/difffile.h

161

void task_process_expire(namedb_type* db, struct task_list_d* task);

usr.sbin/nsd/dnstap/dnstap_collector.c

440

udb_base_free_keep_mmap(nsd->task[0]);

usr.sbin/nsd/dnstap/dnstap_collector.c

441

udb_base_free_keep_mmap(nsd->task[1]);

usr.sbin/nsd/ipc.c

411

udb_ptr_unlink(xfrd->last_task, xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/ipc.c

412

task_process_sync(xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/ipc.c

415

udb_ptr_init(xfrd->last_task, xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/ipc.c

416

udb_ptr_set(xfrd->last_task, xfrd->nsd->task[xfrd->nsd->mytask], p);

usr.sbin/nsd/ipc.c

426

task_remap(xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/ipc.c

427

udb_ptr_init(xfrd->last_task, xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/ipc.c

428

assert(udb_base_get_userdata(xfrd->nsd->task[xfrd->nsd->mytask])->data == 0);

usr.sbin/nsd/ipc.c

567

xfrd->nsd->task[1-xfrd->nsd->mytask]);

usr.sbin/nsd/ipc.c

587

task_new_check_zonefiles(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/nsd.h

257

struct udb_base* task[2];

usr.sbin/nsd/remote.c

1206

task_new_set_verbosity(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1289

task_new_zonestat_inc(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1353

task_new_del_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1382

task_new_add_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1450

task_new_add_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1514

task_new_del_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1613

task_new_del_key(xfrd->nsd->task[xfrd->nsd->mytask], xfrd->last_task,

usr.sbin/nsd/remote.c

1624

task_new_add_key(xfrd->nsd->task[xfrd->nsd->mytask], xfrd->last_task,

usr.sbin/nsd/remote.c

1686

task_new_del_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1727

task_new_add_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1749

task_new_del_pattern(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

1760

task_new_add_pattern(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

2110

task_new_opt_change(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

2132

task_new_cookies( xfrd->nsd->task[xfrd->nsd->mytask]

usr.sbin/nsd/remote.c

2316

task_new_add_key(xfrd->nsd->task[xfrd->nsd->mytask], xfrd->last_task,

usr.sbin/nsd/remote.c

2460

task_new_add_pattern(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

2583

task_new_cookies(xfrd->nsd->task[xfrd->nsd->mytask], xfrd->last_task,

usr.sbin/nsd/remote.c

907

task_new_check_zonefiles(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/remote.c

920

task_new_write_zonefiles(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/server.c

1546

unlink(nsd->task[0]->fname);

usr.sbin/nsd/server.c

1547

unlink(nsd->task[1]->fname);

usr.sbin/nsd/server.c

1661

udb_base_free_keep_mmap(nsd->task[0]);

usr.sbin/nsd/server.c

1662

udb_base_free_keep_mmap(nsd->task[1]);

usr.sbin/nsd/server.c

1681

nsd->task[0] = task_file_create(tmpfile);

usr.sbin/nsd/server.c

1682

if(!nsd->task[0]) {

usr.sbin/nsd/server.c

1695

nsd->task[1] = task_file_create(tmpfile);

usr.sbin/nsd/server.c

1696

if(!nsd->task[1]) {

usr.sbin/nsd/server.c

1697

unlink(nsd->task[0]->fname);

usr.sbin/nsd/server.c

1708

assert(udb_base_get_userdata(nsd->task[0])->data == 0);

usr.sbin/nsd/server.c

1709

assert(udb_base_get_userdata(nsd->task[1])->data == 0);

usr.sbin/nsd/server.c

1754

char* tmpfile = nsd->task[1-nsd->mytask]->fname;

usr.sbin/nsd/server.c

1755

nsd->task[1-nsd->mytask]->fname = NULL;

usr.sbin/nsd/server.c

1757

udb_alloc_delete(nsd->task[1-nsd->mytask]->alloc);

usr.sbin/nsd/server.c

1758

nsd->task[1-nsd->mytask]->alloc = NULL;

usr.sbin/nsd/server.c

1759

udb_base_free(nsd->task[1-nsd->mytask]);

usr.sbin/nsd/server.c

1761

nsd->task[1-nsd->mytask] = task_file_create(tmpfile);

usr.sbin/nsd/server.c

1866

struct udb_base* taskudb = nsd->task[nsd->mytask];

usr.sbin/nsd/server.c

1877

unlink(nsd->task[0]->fname);

usr.sbin/nsd/server.c

1878

unlink(nsd->task[1]->fname);

usr.sbin/nsd/server.c

1893

taskudb = nsd->task[1-nsd->mytask];

usr.sbin/nsd/server.c

1924

taskudb = nsd->task[nsd->mytask];

usr.sbin/nsd/server.c

2380

udb_base* u = nsd->task[nsd->mytask];

usr.sbin/nsd/server.c

2415

udb_base* u = nsd->task[nsd->mytask];

usr.sbin/nsd/server.c

2614

task_new_soainfo(nsd->task[nsd->mytask], last_task,

usr.sbin/nsd/server.c

2619

task_new_soainfo(nsd->task[nsd->mytask], last_task,

usr.sbin/nsd/server.c

2720

udb_ptr_set(last_task, nsd->task[nsd->mytask], 0);

usr.sbin/nsd/server.c

2721

task_process_sync(nsd->task[nsd->mytask]);

usr.sbin/nsd/server.c

2871

task_process_sync(nsd->task[nsd->mytask]);

usr.sbin/nsd/server.c

2975

task_process_sync(nsd->task[nsd->mytask]);

usr.sbin/nsd/server.c

3031

task_remap(nsd->task[nsd->mytask]);

usr.sbin/nsd/server.c

3032

udb_ptr_init(&xfrs2process, nsd->task[nsd->mytask]);

usr.sbin/nsd/server.c

3033

udb_ptr_init(&last_task , nsd->task[nsd->mytask]);

usr.sbin/nsd/server.c

3050

udb_ptr_set(&last_task, nsd->task[nsd->mytask], 0);

usr.sbin/nsd/server.c

3051

udb_ptr_set(&xfrs2process, nsd->task[nsd->mytask], 0);

usr.sbin/nsd/server.c

3083

udb_ptr_set(&last_task, nsd->task[nsd->mytask], 0);

usr.sbin/nsd/server.c

3084

udb_ptr_set(&xfrs2process, nsd->task[nsd->mytask], 0);

usr.sbin/nsd/server.c

3175

unlink(nsd->task[0]->fname);

usr.sbin/nsd/server.c

3176

unlink(nsd->task[1]->fname);

usr.sbin/nsd/xfrd-catalog-zones.c

1188

task_new_apply_xfr( xfrd->nsd->task[xfrd->nsd->mytask], xfrd->last_task

usr.sbin/nsd/xfrd-catalog-zones.c

353

task_new_del_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd-catalog-zones.c

68

task_new_zonestat_inc(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd-catalog-zones.c

753

xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd-catalog-zones.c

775

xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd-catalog-zones.c

858

task_new_add_zone(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd.c

1613

task_new_expire(xfrd->nsd->task[xfrd->nsd->mytask], xfrd->last_task,

usr.sbin/nsd/xfrd.c

172

udb_ptr_init(xfrd->last_task, xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/xfrd.c

173

assert(shortsoa || udb_base_get_userdata(xfrd->nsd->task[xfrd->nsd->mytask])->data == 0);

usr.sbin/nsd/xfrd.c

2669

xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd.c

2991

xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd.c

3017

xfrd_process_zonestat_inc_task(xfrd_state_type* xfrd, struct task_list_d* task)

usr.sbin/nsd/xfrd.c

3019

xfrd->zonestat_safe = (unsigned)task->oldserial;

usr.sbin/nsd/xfrd.c

3028

xfrd_handle_taskresult(xfrd_state_type* xfrd, struct task_list_d* task)

usr.sbin/nsd/xfrd.c

3033

switch(task->task_type) {

usr.sbin/nsd/xfrd.c

3035

xfrd_process_soa_info_task(task);

usr.sbin/nsd/xfrd.c

3039

xfrd_process_zonestat_inc_task(xfrd, task);

usr.sbin/nsd/xfrd.c

304

task_new_check_zonefiles(xfrd->nsd->task[

usr.sbin/nsd/xfrd.c

3044

"reload type %d", (int)task->task_type);

usr.sbin/nsd/xfrd.c

3100

task_new_write_zonefiles(xfrd->nsd->task[xfrd->nsd->mytask],

usr.sbin/nsd/xfrd.c

436

xfrd_clean_pending_tasks(xfrd->nsd, xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/nsd/xfrd.c

494

udb_base_free(nsd.task[0]);

usr.sbin/nsd/xfrd.c

495

udb_base_free(nsd.task[1]);

usr.sbin/nsd/xfrd.c

696

xfrd_process_soa_info_task(struct task_list_d* task)

usr.sbin/nsd/xfrd.c

712

dname_to_string(task->zname, 0)));

usr.sbin/nsd/xfrd.c

713

zone = (xfrd_zone_type*)rbtree_search(xfrd->zones, task->zname);

usr.sbin/nsd/xfrd.c

714

hint = (enum soainfo_hint)task->yesno;

usr.sbin/nsd/xfrd.c

715

if(task->size <= sizeof(struct task_list_d)+dname_total_size(

usr.sbin/nsd/xfrd.c

716

task->zname)+sizeof(uint32_t)*6 + sizeof(uint8_t)*2) {

usr.sbin/nsd/xfrd.c

718

dname_to_string(task->zname,0),

usr.sbin/nsd/xfrd.c

726

uint8_t* p = (uint8_t*)task->zname + dname_total_size(

usr.sbin/nsd/xfrd.c

727

task->zname);

usr.sbin/nsd/xfrd.c

754

dname_to_string(task->zname,0),

usr.sbin/nsd/xfrd.c

767

rbtree_search(xfrd->catalog_producer_zones, task->zname))) {

usr.sbin/nsd/xfrd.c

771

dname_to_string(task->zname,0)));

usr.sbin/nsd/xfrd.c

780

dname_to_string(task->zname,0), pxfr->serial));

usr.sbin/nsd/xfrd.c

808

task->zname, soa_ptr);

usr.sbin/nsd/xfrd.c

813

dname_to_string(task->zname,0)));

usr.sbin/nsd/xfrd.c

815

task->zname, soa_ptr);

usr.sbin/nsd/xfrd.c

824

xfrd->catalog_consumer_zones, task->zname))) {

usr.sbin/nsd/xfrd.c

825

dbzone = namedb_find_or_create_zone( xfrd->nsd->db, task->zname

usr.sbin/nsd/xfrd.c

925

struct udb_base* xtask = xfrd->nsd->task[xfrd->nsd->mytask];

usr.sbin/nsd/xfrd.c

966

xtask = xfrd->nsd->task[xfrd->nsd->mytask];

usr.sbin/nsd/xfrd.c

975

udb_ptr_init(xfrd->last_task, xfrd->nsd->task[xfrd->nsd->mytask]);

usr.sbin/rpki-client/rrdp.c

252

if (s->task == DELTA && !s->aborted) {

usr.sbin/rpki-client/rrdp.c

258

s->task = SNAPSHOT;

usr.sbin/rpki-client/rrdp.c

313

switch (s->task) {

usr.sbin/rpki-client/rrdp.c

315

s->task = notification_done(s->nxml, s->last_mod);

usr.sbin/rpki-client/rrdp.c

317

switch (s->task) {

usr.sbin/rpki-client/rrdp.c

363

} else if (s->res == HTTP_NOT_MOD && s->task == NOTIFICATION) {

usr.sbin/rpki-client/rrdp.c

508

if (s->task != NOTIFICATION) {

usr.sbin/rpki-client/rrdp.c

524

if (s->task != NOTIFICATION)

usr.sbin/rpki-client/rrdp.c

562

switch (s->task) {

usr.sbin/rpki-client/rrdp.c

571

s->task);

usr.sbin/rpki-client/rrdp.c

63

enum rrdp_task task;

usr.sbin/rpki-client/rrdp_notification.c

563

enum rrdp_task task)

usr.sbin/rpki-client/rrdp_notification.c

567

switch (task) {

usr.sbin/smtpd/mta.c

1531

struct mta_task *task;

usr.sbin/smtpd/mta.c

1544

while ((task = TAILQ_FIRST(&relay->tasks))) {

usr.sbin/smtpd/mta.c

1545

TAILQ_REMOVE(&relay->tasks, task, entry);

usr.sbin/smtpd/mta.c

1546

while ((e = TAILQ_FIRST(&task->envelopes))) {

usr.sbin/smtpd/mta.c

1547

TAILQ_REMOVE(&task->envelopes, e, entry);

usr.sbin/smtpd/mta.c

1572

free(task->sender);

usr.sbin/smtpd/mta.c

1573

free(task);

usr.sbin/smtpd/mta.c

1790

evp->task->sender,

usr.sbin/smtpd/mta.c

654

struct mta_task *task;

usr.sbin/smtpd/mta.c

656

if ((task = TAILQ_FIRST(&relay->tasks))) {

usr.sbin/smtpd/mta.c

657

TAILQ_REMOVE(&relay->tasks, task, entry);

usr.sbin/smtpd/mta.c

659

task->relay = NULL;

usr.sbin/smtpd/mta.c

683

return (task);

usr.sbin/smtpd/mta.c

690

struct mta_task *task;

usr.sbin/smtpd/mta.c

768

task = NULL;

usr.sbin/smtpd/mta.c

769

TAILQ_FOREACH(task, &relay->tasks, entry)

usr.sbin/smtpd/mta.c

770

if (task->msgid == evpid_to_msgid(evp->id))

usr.sbin/smtpd/mta.c

773

if (task == NULL) {

usr.sbin/smtpd/mta.c

774

task = xmalloc(sizeof *task);

usr.sbin/smtpd/mta.c

775

TAILQ_INIT(&task->envelopes);

usr.sbin/smtpd/mta.c

776

task->relay = relay;

usr.sbin/smtpd/mta.c

778

TAILQ_INSERT_TAIL(&relay->tasks, task, entry);

usr.sbin/smtpd/mta.c

779

task->msgid = evpid_to_msgid(evp->id);

usr.sbin/smtpd/mta.c

796

task->sender = xstrdup(buf);

usr.sbin/smtpd/mta.c

811

e->task = task;

usr.sbin/smtpd/mta.c

819

TAILQ_INSERT_TAIL(&task->envelopes, e, entry);

usr.sbin/smtpd/mta_session.c

1017

mta_report_tx_begin(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1018

mta_report_tx_mail(s, s->task->msgid, s->task->sender, 1);

usr.sbin/smtpd/mta_session.c

1042

mta_report_tx_rollback(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1043

mta_report_tx_reset(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1051

TAILQ_REMOVE(&s->task->envelopes, e, entry);

usr.sbin/smtpd/mta_session.c

1087

if (TAILQ_EMPTY(&s->task->envelopes)) {

usr.sbin/smtpd/mta_session.c

1098

s->task->msgid, e->dest, 1);

usr.sbin/smtpd/mta_session.c

1102

s->task->msgid, e->dest, -1);

usr.sbin/smtpd/mta_session.c

1106

s->task->msgid, e->dest, 0);

usr.sbin/smtpd/mta_session.c

1118

mta_report_tx_data(s, s->task->msgid, 1);

usr.sbin/smtpd/mta_session.c

1127

mta_report_tx_data(s, s->task->msgid,

usr.sbin/smtpd/mta_session.c

1129

mta_report_tx_rollback(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1130

mta_report_tx_reset(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1147

mta_report_tx_rollback(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1148

mta_report_tx_reset(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

115

struct mta_task *task;

usr.sbin/smtpd/mta_session.c

1151

mta_report_tx_commit(s, s->task->msgid, s->datalen);

usr.sbin/smtpd/mta_session.c

1152

mta_report_tx_reset(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1155

if (s->task) {

usr.sbin/smtpd/mta_session.c

1176

if (s->task) {

usr.sbin/smtpd/mta_session.c

1177

mta_report_tx_rollback(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1178

mta_report_tx_reset(s, s->task->msgid);

usr.sbin/smtpd/mta_session.c

1475

while ((e = TAILQ_FIRST(&s->task->envelopes))) {

usr.sbin/smtpd/mta_session.c

1482

TAILQ_REMOVE(&s->task->envelopes, e, entry);

usr.sbin/smtpd/mta_session.c

1514

free(s->task->sender);

usr.sbin/smtpd/mta_session.c

1515

free(s->task);

usr.sbin/smtpd/mta_session.c

1516

s->task = NULL;

usr.sbin/smtpd/mta_session.c

1561

if (s->task)

usr.sbin/smtpd/mta_session.c

389

if (s->task)

usr.sbin/smtpd/mta_session.c

729

else if (s->task)

usr.sbin/smtpd/mta_session.c

732

if (s->task == NULL)

usr.sbin/smtpd/mta_session.c

733

s->task = mta_route_next_task(s->relay, s->route);

usr.sbin/smtpd/mta_session.c

734

if (s->task == NULL) {

usr.sbin/smtpd/mta_session.c

759

m_add_msgid(p_queue, s->task->msgid);

usr.sbin/smtpd/mta_session.c

767

s->currevp = TAILQ_FIRST(&s->task->envelopes);

usr.sbin/smtpd/mta_session.c

780

strchr(s->task->sender, '@') &&

usr.sbin/smtpd/mta_session.c

784

srs_sender = srs_encode(s->task->sender,

usr.sbin/smtpd/mta_session.c

787

free(s->task->sender);

usr.sbin/smtpd/mta_session.c

788

s->task->sender = xstrdup(srs_sender);

usr.sbin/smtpd/mta_session.c

794

s->task->sender,

usr.sbin/smtpd/mta_session.c

800

mta_send(s, "MAIL FROM:<%s>", s->task->sender);

usr.sbin/smtpd/mta_session.c

805

s->currevp = TAILQ_FIRST(&s->task->envelopes);

usr.sbin/smtpd/mta_session.c

818

mta_report_tx_envelope(s, s->task->msgid, e->id);

usr.sbin/smtpd/smtpd.h

854

struct mta_task *task;