Lines Matching defs:errch
96 struct accel_error_channel *errch = spdk_io_channel_get_ctx(ch);
97 struct accel_error_inject_info *info = &errch->injects[task->op_code];
123 struct accel_error_channel *errch = spdk_io_channel_get_ctx(ch);
125 struct accel_error_inject_info *info = &errch->injects[task->op_code];
133 errtask->ch = errch;
146 STAILQ_INSERT_TAIL(&errch->tasks, errtask, link);
152 return g_sw_module->submit_tasks(errch->swch, task);
158 struct accel_error_channel *errch = arg;
163 if (STAILQ_EMPTY(&errch->tasks)) {
168 STAILQ_SWAP(&tasks, &errch->tasks, accel_error_task);
185 struct accel_error_channel *errch = spdk_io_channel_get_ctx(ch);
187 struct accel_error_inject_info *info = &errch->injects[opts->opcode];
222 struct accel_error_channel *errch = ctx;
225 STAILQ_INIT(&errch->tasks);
226 errch->poller = SPDK_POLLER_REGISTER(accel_error_poller, errch, 0);
227 if (errch->poller == NULL) {
231 errch->swch = g_sw_module->get_io_channel();
232 if (errch->swch == NULL) {
233 spdk_poller_unregister(&errch->poller);
237 for (i = 0; i < SPDK_COUNTOF(errch->injects); ++i) {
238 memcpy(&errch->injects[i].opts, &g_injects[i], sizeof(g_injects[i]));
239 errch->injects[i].count = 0;
248 struct accel_error_channel *errch = ctx;
250 assert(STAILQ_EMPTY(&errch->tasks));
251 spdk_poller_unregister(&errch->poller);
252 spdk_put_io_channel(errch->swch);