Lines Matching defs:task
192 struct malloc_task *task = (struct malloc_task *)ref;
193 struct spdk_bdev_io *bdev_io = spdk_bdev_io_from_ctx(task);
198 if (task->status == SPDK_BDEV_IO_STATUS_SUCCESS) {
199 task->status = SPDK_BDEV_IO_STATUS_NOMEM;
202 task->status = SPDK_BDEV_IO_STATUS_FAILED;
206 if (--task->num_outstanding != 0) {
211 task->status == SPDK_BDEV_IO_STATUS_SUCCESS) {
237 task->status = SPDK_BDEV_IO_STATUS_FAILED;
241 assert(!bdev_io->u.bdev.accel_sequence || task->status == SPDK_BDEV_IO_STATUS_NOMEM);
242 spdk_bdev_io_complete(spdk_bdev_io_from_ctx(task), task->status);
246 malloc_complete_task(struct malloc_task *task, struct malloc_channel *mch,
249 task->status = status;
250 TAILQ_INSERT_TAIL(&mch->completed_tasks, task, tailq);
338 malloc_sequence_fail(struct malloc_task *task, int status)
340 struct spdk_bdev_io *bdev_io = spdk_bdev_io_from_ctx(task);
348 malloc_done(task, status);
354 struct malloc_task *task = ctx;
355 struct spdk_bdev_io *bdev_io = spdk_bdev_io_from_ctx(task);
359 malloc_done(task, status != -ENOMEM ? status : -EFAULT);
364 struct malloc_task *task, struct spdk_bdev_io *bdev_io)
373 spdk_bdev_io_complete(spdk_bdev_io_from_ctx(task),
378 task->status = SPDK_BDEV_IO_STATUS_SUCCESS;
379 task->num_outstanding = 0;
380 task->iov.iov_base = mdisk->malloc_buf + offset;
381 task->iov.iov_len = len;
386 task->num_outstanding++;
391 &task->iov, 1, NULL, NULL, NULL, NULL);
393 malloc_sequence_fail(task, res);
398 spdk_accel_sequence_finish(bdev_io->u.bdev.accel_sequence, malloc_sequence_done, task);
407 task->num_outstanding++;
409 malloc_get_md_len(bdev_io), malloc_done, task);
411 malloc_done(task, res);
417 struct malloc_task *task, struct spdk_bdev_io *bdev_io)
426 spdk_bdev_io_complete(spdk_bdev_io_from_ctx(task),
431 task->status = SPDK_BDEV_IO_STATUS_SUCCESS;
432 task->num_outstanding = 0;
433 task->iov.iov_base = mdisk->malloc_buf + offset;
434 task->iov.iov_len = len;
439 task->num_outstanding++;
440 res = spdk_accel_append_copy(&bdev_io->u.bdev.accel_sequence, ch, &task->iov, 1, NULL, NULL,
445 malloc_sequence_fail(task, res);
449 spdk_accel_sequence_finish(bdev_io->u.bdev.accel_sequence, malloc_sequence_done, task);
458 task->num_outstanding++;
460 malloc_get_md_len(bdev_io), malloc_done, task);
462 malloc_done(task, res);
469 struct malloc_task *task,
473 task->status = SPDK_BDEV_IO_STATUS_SUCCESS;
474 task->num_outstanding = 1;
477 byte_count, malloc_done, task);
482 struct malloc_task *task,
492 task->status = SPDK_BDEV_IO_STATUS_SUCCESS;
493 task->num_outstanding = 1;
495 res = spdk_accel_submit_copy(ch, dst, src, len, malloc_done, task);
497 malloc_done(task, res);
504 struct malloc_task *task = (struct malloc_task *)bdev_io->driver_ctx;
521 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_SUCCESS);
529 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_FAILED);
534 bdev_malloc_readv(disk, mch->accel_channel, task, bdev_io);
542 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_FAILED);
547 bdev_malloc_writev(disk, mch->accel_channel, task, bdev_io);
551 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_SUCCESS);
555 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_SUCCESS);
559 return bdev_malloc_unmap(disk, mch->accel_channel, task,
565 return bdev_malloc_unmap(disk, mch->accel_channel, task,
582 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_SUCCESS);
585 malloc_complete_task(task, mch, SPDK_BDEV_IO_STATUS_FAILED);
588 bdev_malloc_copy(disk, mch->accel_channel, task,
917 struct malloc_task *task;
925 task = TAILQ_FIRST(&completed_tasks);
926 TAILQ_REMOVE(&completed_tasks, task, tailq);
927 spdk_bdev_io_complete(spdk_bdev_io_from_ctx(task), task->status);