Lines Matching defs:task
45 accel_error_get_task_ctx(struct spdk_accel_task *task)
47 return (void *)((uint8_t *)task + g_task_offset);
57 accel_error_corrupt_task(struct spdk_accel_task *task)
59 switch (task->op_code) {
61 *task->crc_dst += 1;
71 struct spdk_accel_task *task = arg;
72 struct accel_error_task *errtask = accel_error_get_task_ctx(task);
76 accel_error_corrupt_task(task);
83 struct spdk_accel_task *task = arg;
84 struct accel_error_task *errtask = accel_error_get_task_ctx(task);
88 accel_error_corrupt_task(task);
94 accel_error_should_inject(struct spdk_io_channel *ch, struct spdk_accel_task *task)
97 struct accel_error_inject_info *info = &errch->injects[task->op_code];
121 accel_error_submit_tasks(struct spdk_io_channel *ch, struct spdk_accel_task *task)
124 struct accel_error_task *errtask = accel_error_get_task_ctx(task);
125 struct accel_error_inject_info *info = &errch->injects[task->op_code];
127 if (!accel_error_should_inject(ch, task)) {
134 errtask->cb_arg = task->cb_arg;
135 task->cb_arg = task;
136 if (task->seq != NULL) {
137 errtask->cb_fn.step = task->step_cb_fn;
138 task->step_cb_fn = accel_error_corrupt_step_cb;
140 errtask->cb_fn.cpl = task->cb_fn;
141 task->cb_fn = accel_error_corrupt_cb;
152 return g_sw_module->submit_tasks(errch->swch, task);
161 struct spdk_accel_task *task;
174 task = accel_error_get_task_from_ctx(errtask);
175 spdk_accel_task_complete(task, errtask->status);