Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 49) sorted by relevance

12

/spdk/test/unit/lib/scsi/scsi_pr.c/
H A Dscsi_pr_ut.c18 spdk_scsi_task_set_status(struct spdk_scsi_task *task, int sc, int sk, in SPDK_LOG_REGISTER_COMPONENT()
21 task->status = sc; in SPDK_LOG_REGISTER_COMPONENT()
131 struct spdk_scsi_task task = {0}; in test_build_registrants() local
135 task.lun = &g_lun; in test_build_registrants()
136 task.target_port = &g_t_port_0; in test_build_registrants()
141 task.initiator_port = &g_i_port_a; in test_build_registrants()
143 task.status = 0; in test_build_registrants()
144 rc = scsi_pr_out_register(&task, SPDK_SCSI_PR_OUT_REGISTER, in test_build_registrants()
153 task.status = 0; in test_build_registrants()
154 rc = scsi_pr_out_register(&task, SPDK_SCSI_PR_OUT_REGISTER, in test_build_registrants()
[all …]
/spdk/lib/scsi/
H A Dtask.c13 scsi_task_free_data(struct spdk_scsi_task *task) in scsi_task_free_data() argument
15 if (task->alloc_len != 0) { in scsi_task_free_data()
16 spdk_dma_free(task->iov.iov_base); in scsi_task_free_data()
17 task->alloc_len = 0; in scsi_task_free_data()
20 task->iov.iov_base = NULL; in scsi_task_free_data()
21 task->iov.iov_len = 0; in scsi_task_free_data()
25 spdk_scsi_task_put(struct spdk_scsi_task *task) in spdk_scsi_task_put() argument
27 if (!task) { in spdk_scsi_task_put()
31 assert(task->ref > 0); in spdk_scsi_task_put()
32 task->ref--; in spdk_scsi_task_put()
[all …]
H A Dlun.c18 scsi_lun_complete_task(struct spdk_scsi_lun *lun, struct spdk_scsi_task *task) in scsi_lun_complete_task() argument
21 TAILQ_REMOVE(&lun->tasks, task, scsi_link); in scsi_lun_complete_task()
22 spdk_trace_record(TRACE_SCSI_TASK_DONE, lun->dev->id, 0, (uintptr_t)task); in scsi_lun_complete_task()
24 task->cpl_fn(task); in scsi_lun_complete_task()
28 scsi_lun_complete_mgmt_task(struct spdk_scsi_lun *lun, struct spdk_scsi_task *task) in scsi_lun_complete_mgmt_task() argument
30 TAILQ_REMOVE(&lun->mgmt_tasks, task, scsi_link); in scsi_lun_complete_mgmt_task()
32 task->cpl_fn(task); in scsi_lun_complete_mgmt_task()
66 struct spdk_scsi_task *task = (struct spdk_scsi_task *)arg; in scsi_lun_reset_check_outstanding_tasks() local
67 struct spdk_scsi_lun *lun = task->lun; in scsi_lun_reset_check_outstanding_tasks()
74 scsi_lun_complete_mgmt_task(lun, task); in scsi_lun_reset_check_outstanding_tasks()
[all …]
H A Dscsi_bdev.c122 bdev_scsi_inquiry(struct spdk_bdev *bdev, struct spdk_scsi_task *task, in bdev_scsi_inquiry() argument
142 lun = task->lun; in bdev_scsi_inquiry()
144 port = task->target_port; in bdev_scsi_inquiry()
151 spdk_scsi_task_set_status(task, SPDK_SCSI_STATUS_CHECK_CONDITION, in bdev_scsi_inquiry()
228 spdk_scsi_task_set_status(task, SPDK_SCSI_STATUS_CHECK_CONDITION, in bdev_scsi_inquiry()
730 task->data_transferred = 0; in bdev_scsi_inquiry()
731 spdk_scsi_task_set_status(task, SPDK_SCSI_STATUS_CHECK_CONDITION, in bdev_scsi_inquiry()
759 uint8_t *data, struct spdk_scsi_task *task) in bdev_scsi_mode_sense_page() argument
776 spdk_scsi_task_set_status(task, SPDK_SCSI_STATUS_CHECK_CONDITION, in bdev_scsi_mode_sense_page()
882 cp ? &cp[len] : NULL, task); in bdev_scsi_mode_sense_page()
[all …]
H A Dscsi_pr.c172 scsi_pr_out_reserve(struct spdk_scsi_task *task, in scsi_pr_out_reserve() argument
176 struct spdk_scsi_lun *lun = task->lun; in scsi_pr_out_reserve()
186 spdk_scsi_task_set_status(task, SPDK_SCSI_STATUS_CHECK_CONDITION, in scsi_pr_out_reserve()
193 reg = scsi_pr_get_registrant(lun, task->initiator_port, task->target_port); in scsi_pr_out_reserve()
226 spdk_scsi_task_set_status(task, SPDK_SCSI_STATUS_RESERVATION_CONFLICT, in scsi_pr_out_reserve()
234 scsi_pr_out_register(struct spdk_scsi_task *task, in scsi_pr_out_register() argument
239 struct spdk_scsi_lun *lun = task->lun; in scsi_pr_out_register()
255 reg = scsi_pr_get_registrant(lun, task->initiator_port, task->target_port); in scsi_pr_out_register()
273 return scsi_pr_register_registrant(lun, task->initiator_port, in scsi_pr_out_register()
274 task->target_port, sa_rkey); in scsi_pr_out_register()
[all …]
/spdk/test/accel/dif/
H A Ddif.c120 alloc_dif_verify_bufs(struct dif_task *task, uint32_t chained_count) in alloc_dif_verify_bufs()
126 task->src_iovcnt = chained_count; in alloc_dif_verify_bufs()
127 task->src_iovs = calloc(task->src_iovcnt, sizeof(struct iovec)); in alloc_dif_verify_bufs()
128 if (spdk_unlikely(task->src_iovs == NULL)) { in alloc_dif_verify_bufs()
134 for (i = 0; i < task->src_iovcnt; i++) { in alloc_dif_verify_bufs()
135 task->src_iovs[i].iov_base = spdk_dma_zmalloc(src_buff_len, 0, NULL); in alloc_dif_verify_bufs()
136 if (spdk_unlikely(task->src_iovs[i].iov_base == NULL)) { in alloc_dif_verify_bufs()
140 memset(task->src_iovs[i].iov_base, DATA_PATTERN, src_buff_len); in alloc_dif_verify_bufs()
141 task in alloc_dif_verify_bufs()
114 alloc_dif_verify_bufs(struct dif_task * task,uint32_t chained_count) alloc_dif_verify_bufs() argument
144 free_dif_verify_bufs(struct dif_task * task) free_dif_verify_bufs() argument
159 alloc_dif_verify_copy_bufs(struct dif_task * task,uint32_t chained_count) alloc_dif_verify_copy_bufs() argument
207 free_dif_verify_copy_bufs(struct dif_task * task) free_dif_verify_copy_bufs() argument
231 alloc_dif_generate_copy_bufs(struct dif_task * task,uint32_t chained_count) alloc_dif_generate_copy_bufs() argument
279 free_dif_generate_copy_bufs(struct dif_task * task) free_dif_generate_copy_bufs() argument
353 struct dif_task *task = &g_dif_task; accel_dif_verify_op_dif_generated_do_check() local
421 struct dif_task *task = &g_dif_task; accel_dif_verify_op_dif_not_generated_do_check() local
477 struct dif_task *task = &g_dif_task; accel_dif_verify_op_apptag_correct_apptag_check() local
517 struct dif_task *task = &g_dif_task; accel_dif_verify_op_apptag_incorrect_apptag_check() local
565 struct dif_task *task = &g_dif_task; accel_dif_verify_op_tag_incorrect_no_check_or_ignore() local
631 struct dif_task *task = &g_dif_task; accel_dif_verify_op_reftag_init_correct_reftag_check() local
671 struct dif_task *task = &g_dif_task; accel_dif_verify_op_reftag_init_incorrect_reftag_check() local
719 struct dif_task *task = &g_dif_task; accel_dif_verify_copy_op_dif_generated_do_check() local
789 struct dif_task *task = &g_dif_task; accel_dif_verify_copy_op_dif_not_generated_do_check() local
847 struct dif_task *task = &g_dif_task; accel_dif_generate_copy_op_dif_generated_do_check() local
920 struct dif_task *task = &g_dif_task; accel_dif_generate_copy_op_dif_generated_no_guard_check_flag_set() local
972 struct dif_task *task = &g_dif_task; accel_dif_generate_copy_op_dif_generated_no_apptag_check_flag_set() local
1024 struct dif_task *task = &g_dif_task; accel_dif_generate_copy_op_dif_generated_no_reftag_check_flag_set() local
1075 struct dif_task *task = &g_dif_task; accel_dif_generate_copy_op_iovecs_len_validate() local
1118 struct dif_task *task = &g_dif_task; accel_dif_generate_copy_op_buf_align_validate() local
[all...]
/spdk/test/unit/lib/scsi/scsi_bdev.c/
H A Dscsi_bdev_ut.c81 DEFINE_STUB(scsi_pr_out, int, (struct spdk_scsi_task *task,
84 DEFINE_STUB(scsi_pr_in, int, (struct spdk_scsi_task *task, uint8_t *cdb,
87 DEFINE_STUB(scsi2_reserve, int, (struct spdk_scsi_task *task, uint8_t *cdb), 0);
88 DEFINE_STUB(scsi2_release, int, (struct spdk_scsi_task *task), 0);
91 scsi_lun_complete_task(struct spdk_scsi_lun *lun, struct spdk_scsi_task *task) in scsi_lun_complete_task() argument
97 (struct spdk_scsi_lun *lun, struct spdk_scsi_task *task));
111 ut_put_task(struct spdk_scsi_task *task) in ut_put_task() argument
113 if (task->alloc_len) { in ut_put_task()
114 free(task->iov.iov_base); in ut_put_task()
117 task->iov.iov_base = NULL; in ut_put_task()
[all …]
/spdk/lib/iscsi/
H A Dtask.c17 struct spdk_iscsi_task *task = iscsi_task_from_scsi_task(scsi_task); in iscsi_task_free() local
19 if (task->conn->target->histogram) { in iscsi_task_free()
20 tsc_diff = spdk_get_ticks() - task->start_tsc; in iscsi_task_free()
21 spdk_histogram_data_tally(task->conn->target->histogram, tsc_diff); in iscsi_task_free()
24 if (task->parent) { in iscsi_task_free()
25 if (task->scsi.dxfer_dir == SPDK_SCSI_DIR_FROM_DEV) { in iscsi_task_free()
26 assert(task->conn->data_in_cnt > 0); in iscsi_task_free()
27 task->conn->data_in_cnt--; in iscsi_task_free()
30 spdk_scsi_task_put(&task->parent->scsi); in iscsi_task_free()
31 task->parent = NULL; in iscsi_task_free()
[all …]
H A Dtask.h81 iscsi_task_put(struct spdk_iscsi_task *task) in iscsi_task_put() argument
83 spdk_scsi_task_put(&task->scsi); in iscsi_task_put()
87 iscsi_task_get_pdu(struct spdk_iscsi_task *task) in iscsi_task_get_pdu() argument
89 return task->pdu; in iscsi_task_get_pdu()
93 iscsi_task_set_pdu(struct spdk_iscsi_task *task, struct spdk_iscsi_pdu *pdu) in iscsi_task_set_pdu() argument
95 task->pdu = pdu; in iscsi_task_set_pdu()
99 iscsi_task_get_bhs(struct spdk_iscsi_task *task) in iscsi_task_get_bhs() argument
101 return &iscsi_task_get_pdu(task)->bhs; in iscsi_task_get_bhs()
105 iscsi_task_associate_pdu(struct spdk_iscsi_task *task, struct spdk_iscsi_pdu *pdu) in iscsi_task_associate_pdu() argument
107 iscsi_task_set_pdu(task, pdu); in iscsi_task_associate_pdu()
[all …]
H A Discsi.c23 #include "iscsi/task.h"
2607 struct spdk_iscsi_task *task, int offset, in iscsi_send_r2t() argument
2623 fmt_lun = spdk_scsi_lun_id_int_to_fmt(task->lun_id); in iscsi_send_r2t()
2625 to_be32(&rsph->itt, task->tag); in iscsi_send_r2t()
2635 task->r2t_datasn = 0; /* next expected datasn to ack */ in iscsi_send_r2t()
2639 task->desired_data_transfer_length = (size_t)len; in iscsi_send_r2t()
2641 /* we need to hold onto this task/cmd because until the PDU has been in iscsi_send_r2t()
2643 rsp_pdu->task = task; in iscsi_send_r2t()
2644 task in iscsi_send_r2t()
2654 iscsi_remove_r2t_pdu_from_snack_list(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,uint32_t r2t_sn) iscsi_remove_r2t_pdu_from_snack_list() argument
2677 iscsi_send_r2t_recovery(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,uint32_t r2t_sn,bool send_new_r2tsn) iscsi_send_r2t_recovery() argument
2724 add_transfer_task(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) add_transfer_task() argument
2793 struct spdk_iscsi_task *task, *tmp; start_queued_transfer_tasks() local
2808 struct spdk_iscsi_task *task, *tmp; iscsi_del_transfer_task() local
2835 struct spdk_iscsi_task *task, *task_tmp; iscsi_clear_all_transfer_task() local
2881 struct spdk_iscsi_task *task; get_transfer_task() local
2902 iscsi_send_datain(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,int datain_flag,int residual_len,int offset,int DataSN,int len) iscsi_send_datain() argument
3006 iscsi_transfer_in(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_transfer_in() argument
3096 iscsi_task_response(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_task_response() argument
3207 struct spdk_iscsi_task *task; iscsi_compare_pdu_bhs_within_existed_r2t_tasks() local
3225 iscsi_queue_task(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_queue_task() argument
3234 iscsi_pdu_payload_op_scsi_read(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_pdu_payload_op_scsi_read() argument
3254 iscsi_submit_write_subtask(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,struct spdk_iscsi_pdu * pdu,struct spdk_mobj * mobj) iscsi_submit_write_subtask() argument
3281 iscsi_pdu_payload_op_scsi_write(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_pdu_payload_op_scsi_write() argument
3343 struct spdk_iscsi_task *task; iscsi_pdu_hdr_op_scsi() local
3458 struct spdk_iscsi_task *task; iscsi_pdu_payload_op_scsi() local
3491 iscsi_task_mgmt_response(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_task_mgmt_response() argument
3547 iscsi_queue_mgmt_task(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) iscsi_queue_mgmt_task() argument
3565 struct spdk_iscsi_task *task = arg; _iscsi_op_abort_task() local
3579 iscsi_op_abort_task(struct spdk_iscsi_task * task,uint32_t ref_task_tag) iscsi_op_abort_task() argument
3589 struct spdk_iscsi_task *task = arg; _iscsi_op_abort_task_set() local
3604 iscsi_op_abort_task_set(struct spdk_iscsi_task * task,uint8_t function) iscsi_op_abort_task_set() argument
3619 struct spdk_iscsi_task *task; iscsi_pdu_hdr_op_task() local
3890 iscsi_handle_r2t_snack(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,struct spdk_iscsi_pdu * pdu,uint32_t beg_run,uint32_t run_length,int32_t task_tag) iscsi_handle_r2t_snack() argument
3932 iscsi_handle_recovery_datain(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,struct spdk_iscsi_pdu * pdu,uint32_t beg_run,uint32_t run_length,uint32_t task_tag) iscsi_handle_recovery_datain() argument
4051 struct spdk_iscsi_task *task; iscsi_handle_data_ack() local
4111 struct spdk_iscsi_task *task; iscsi_pdu_hdr_op_snack() local
4189 struct spdk_iscsi_task *task; iscsi_pdu_hdr_op_data() local
4323 struct spdk_iscsi_task *task; iscsi_pdu_payload_op_data() local
[all...]
H A Dconn.c20 #include "iscsi/task.h"
284 if (pdu->task) { in iscsi_conn_free_pdu()
285 iscsi_task_put(pdu->task); in iscsi_conn_free_pdu()
314 * have to ensure there is no associated task in conn->queued_datain_tasks. in iscsi_conn_free_tasks()
440 struct spdk_iscsi_task *task; in iscsi_conn_check_tasks_for_lun() local
446 if (lun == pdu->task->scsi.lun) { in iscsi_conn_check_tasks_for_lun()
452 TAILQ_FOREACH(task, &conn->queued_datain_tasks, link) { in iscsi_conn_check_tasks_for_lun()
453 if (lun == task->scsi.lun) { in iscsi_conn_check_tasks_for_lun()
462 if (pdu->task && lun == pdu->task in iscsi_conn_check_tasks_for_lun()
657 struct spdk_iscsi_task *task; iscsi_conn_destruct() local
927 _iscsi_conn_abort_queued_datain_task(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task) _iscsi_conn_abort_queued_datain_task() argument
964 struct spdk_iscsi_task *task; iscsi_conn_abort_queued_datain_task() local
980 struct spdk_iscsi_task *task, *task_tmp; iscsi_conn_abort_queued_datain_tasks() local
1001 struct spdk_iscsi_task *task; iscsi_conn_handle_queued_datain_tasks() local
1042 struct spdk_iscsi_task *task = iscsi_task_from_scsi_task(scsi_task); iscsi_task_mgmt_cpl() local
1071 process_read_task_completion(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,struct spdk_iscsi_task * primary) process_read_task_completion() argument
1137 process_non_read_task_completion(struct spdk_iscsi_conn * conn,struct spdk_iscsi_task * task,struct spdk_iscsi_task * primary) process_non_read_task_completion() argument
1180 struct spdk_iscsi_task *task = iscsi_task_from_scsi_task(scsi_task); iscsi_task_cpl() local
[all...]
/spdk/module/accel/dsa/
H A Daccel_dsa.c48 struct spdk_accel_task task;
128 if (idxd_task->task.op_code == SPDK_ACCEL_OPC_DIF_VERIFY || in dsa_done()
129 idxd_task->task.op_code == SPDK_ACCEL_OPC_DIF_VERIFY_COPY) { in dsa_done()
130 rc = spdk_dif_verify(idxd_task->task.s.iovs, idxd_task->task.s.iovcnt, in dsa_done()
131 idxd_task->task.dif.num_blocks, in dsa_done()
132 idxd_task->task.dif.ctx, idxd_task->task.dif.err); in dsa_done()
135 idxd_task->task.dif.err->err_type, in dsa_done()
136 idxd_task->task in dsa_done()
45 struct spdk_accel_task task; global() member
145 struct spdk_accel_task *task = &idxd_task->task; idxd_submit_dualcast() local
162 check_dsa_dif_strip_overlap_bufs(struct spdk_accel_task * task) check_dsa_dif_strip_overlap_bufs() argument
196 struct spdk_accel_task *task = (struct spdk_accel_task *)ctx; spdk_accel_sw_task_complete() local
202 _process_single_task(struct spdk_io_channel * ch,struct spdk_accel_task * task) _process_single_task() argument
296 dsa_submit_task(struct spdk_io_channel * ch,struct spdk_accel_task * task) dsa_submit_task() argument
326 struct spdk_accel_task *task, *tmp; dsa_submit_queued_tasks() local
[all...]
/spdk/test/dma/test_dma/
H A Dtest_dma.c26 struct dma_test_task *task;
59 uint32_t idx; /* sequential number of this task */
107 struct dma_test_task *task; in print_total_stats()
119 TAILQ_FOREACH(task, &g_tasks, link) { in print_total_stats()
120 if (!task->stats.io_completed) { in print_total_stats()
123 task_iops = (double)task->stats.io_completed * SPDK_SEC_TO_USEC / test_time_usec; in print_total_stats()
125 task_avg_lat = (double)task->stats.total_tsc / task->stats.io_completed * SPDK_SEC_TO_USEC / in print_total_stats()
127 task_min_lat = (double)task->stats.min_tsc * SPDK_SEC_TO_USEC / tsc_rate; in print_total_stats()
128 task_max_lat = (double)task in print_total_stats()
24 struct dma_test_task *task; global() member
98 struct dma_test_task *task; print_total_stats() local
147 struct dma_test_task *task; print_periodic_stats() local
182 dma_test_check_and_signal_task_done(struct dma_test_task * task) dma_test_check_and_signal_task_done() argument
193 dma_test_task_update_stats(struct dma_test_task * task,uint64_t submit_tsc) dma_test_task_update_stats() argument
211 struct dma_test_task *task = req->task; dma_test_bdev_io_completion_cb() local
236 dma_test_get_offset_in_ios(struct dma_test_task * task) dma_test_get_offset_in_ios() argument
253 dma_test_task_is_read(struct dma_test_task * task) dma_test_task_is_read() argument
384 struct dma_test_task *task = req->task; dma_test_submit_io() local
421 struct dma_test_task *task = event_ctx; dma_test_bdev_event_cb() local
437 struct dma_test_task *task = ctx; dma_test_task_run() local
449 struct dma_test_task *task = ctx; dma_test_drain_task() local
457 struct dma_test_task *task; dma_test_shutdown_cb() local
485 struct dma_test_task *task; dma_test_construct_task_done() local
519 struct dma_test_task *task = ctx; dma_test_construct_task_on_thread() local
600 struct dma_test_task *task; allocate_task() local
654 destroy_task(struct dma_test_task * task) destroy_task() argument
674 struct dma_test_task *task, *tmp_task; destroy_tasks() local
684 struct dma_test_task *task; verify_tasks() local
743 struct dma_test_task *task; dma_test_start() local
[all...]
/spdk/test/unit/lib/scsi/lun.c/
H A Dlun_ut.c31 (struct spdk_bdev *bdev, struct spdk_scsi_task *task,
35 spdk_lun_ut_cpl_task(struct spdk_scsi_task *task) in spdk_lun_ut_cpl_task() argument
42 spdk_lun_ut_free_task(struct spdk_scsi_task *task) in spdk_lun_ut_free_task() argument
47 ut_init_task(struct spdk_scsi_task *task) in ut_init_task() argument
49 memset(task, 0, sizeof(*task)); in ut_init_task()
50 spdk_scsi_task_construct(task, spdk_lun_ut_cpl_task, in ut_init_task()
75 (struct spdk_scsi_dev *dev, struct spdk_scsi_task *task));
80 DEFINE_STUB(scsi_pr_check, int, (struct spdk_scsi_task *task), 0);
81 DEFINE_STUB(scsi2_reserve_check, int, (struct spdk_scsi_task *task), 0);
84 bdev_scsi_reset(struct spdk_scsi_task *task) in bdev_scsi_reset() argument
[all …]
/spdk/test/unit/lib/accel/dpdk_cryptodev.c/
H A Daccel_dpdk_cryptodev_ut.c224 DEFINE_STUB_V(spdk_accel_task_complete, (struct spdk_accel_task *task, int status));
375 struct accel_dpdk_cryptodev_task task = {}; in test_error_paths() local
380 task.base.op_code = SPDK_ACCEL_OPC_ENCRYPT; in test_error_paths()
381 task.base.s.iovcnt = 1; in test_error_paths()
382 task.base.s.iovs = &src_iov; in test_error_paths()
383 task.base.d.iovcnt = 1; in test_error_paths()
384 task.base.d.iovs = &dst_iov; in test_error_paths()
385 task.base.block_size = 512; in test_error_paths()
386 task.base.crypto_key = &g_key; in test_error_paths()
387 task in test_error_paths()
440 struct accel_dpdk_cryptodev_task task = {}; test_simple_encrypt() local
561 struct accel_dpdk_cryptodev_task task = {}; test_simple_decrypt() local
680 struct accel_dpdk_cryptodev_task task = {}; test_large_enc_dec() local
932 struct accel_dpdk_cryptodev_task task = {}; test_dev_full() local
1061 struct accel_dpdk_cryptodev_task task = {}; test_crazy_rw() local
1333 struct accel_dpdk_cryptodev_task task = {}; test_poller() local
[all...]
/spdk/module/accel/iaa/
H A Daccel_iaa.c44 struct spdk_accel_task task; member
119 spdk_accel_task_complete(&idxd_task->task, status); in iaa_done()
123 _process_single_task(struct spdk_io_channel *ch, struct spdk_accel_task *task) in _process_single_task() argument
130 idxd_task = SPDK_CONTAINEROF(task, struct idxd_task, task); in _process_single_task()
134 if (task->d.iovcnt > 1 || task->s.iovcnt > 1) { in _process_single_task()
139 switch (task->op_code) { in _process_single_task()
141 rc = spdk_idxd_submit_compress(chan->chan, task->d.iovs[0].iov_base, task in _process_single_task()
167 struct spdk_accel_task *task, *tmp; iaa_submit_tasks() local
218 struct spdk_accel_task *task = NULL; idxd_poll() local
[all...]
/spdk/test/unit/lib/iscsi/
H A Dcommon.c34 struct spdk_iscsi_task *task; in iscsi_task_get() local
40 task = calloc(1, sizeof(*task)); in iscsi_task_get()
41 if (!task) { in iscsi_task_get()
45 task->conn = conn; in iscsi_task_get()
46 task->scsi.cpl_fn = cpl_fn; in iscsi_task_get()
49 task->parent = parent; in iscsi_task_get()
50 task->tag = parent->tag; in iscsi_task_get()
51 task->lun_id = parent->lun_id; in iscsi_task_get()
52 task->scsi.dxfer_dir = parent->scsi.dxfer_dir; in iscsi_task_get()
53 task->scsi.transfer_len = parent->scsi.transfer_len; in iscsi_task_get()
[all …]
/spdk/lib/vhost/
H A Dvhost_scsi.c109 /* If set, the task is currently used for I/O processing. */
145 scsi_task_init(struct spdk_vhost_scsi_task *task) in scsi_task_init() argument
147 memset(&task->scsi, 0, sizeof(task->scsi)); in scsi_task_init()
149 * Here means task->tmf_resp = task->resp = NULL. in scsi_task_init()
151 task->resp = NULL; in scsi_task_init()
152 task->used = true; in scsi_task_init()
153 task->used_len = 0; in scsi_task_init()
157 vhost_scsi_task_put(struct spdk_vhost_scsi_task *task) in vhost_scsi_task_put() argument
165 struct spdk_vhost_scsi_task *task = SPDK_CONTAINEROF(scsi_task, struct spdk_vhost_scsi_task, scsi); vhost_scsi_task_free_cb() local
328 submit_completion(struct spdk_vhost_scsi_task * task) submit_completion() argument
342 struct spdk_vhost_scsi_task *task = SPDK_CONTAINEROF(scsi_task, struct spdk_vhost_scsi_task, scsi); vhost_scsi_task_mgmt_cpl() local
350 struct spdk_vhost_scsi_task *task = SPDK_CONTAINEROF(scsi_task, struct spdk_vhost_scsi_task, scsi); vhost_scsi_task_cpl() local
370 task_submit(struct spdk_vhost_scsi_task * task) task_submit() argument
377 mgmt_task_submit(struct spdk_vhost_scsi_task * task,enum spdk_scsi_task_func func) mgmt_task_submit() argument
385 invalid_request(struct spdk_vhost_scsi_task * task) invalid_request() argument
398 vhost_scsi_task_init_target(struct spdk_vhost_scsi_task * task,const __u8 * lun) vhost_scsi_task_init_target() argument
426 process_ctrl_request(struct spdk_vhost_scsi_task * task) process_ctrl_request() argument
528 task_data_setup(struct spdk_vhost_scsi_task * task,struct virtio_scsi_cmd_req ** req) task_data_setup() argument
664 process_request(struct spdk_vhost_scsi_task * task) process_request() argument
697 struct spdk_vhost_scsi_task *task; process_scsi_task() local
1370 struct spdk_vhost_scsi_task *task; alloc_vq_task_pool() local
[all...]
H A Dvhost_blk.c50 /* If set, the task is currently used for I/O processing. */
75 static void vhost_user_blk_request_finish(uint8_t status, struct spdk_vhost_blk_task *task,
121 blk_task_inc_task_cnt(struct spdk_vhost_user_blk_task *task)
123 task->bvsession->vsession.task_cnt++; in to_blk_dev()
127 blk_task_dec_task_cnt(struct spdk_vhost_user_blk_task *task) in to_blk_dev()
129 assert(task->bvsession->vsession.task_cnt > 0); in to_blk_dev()
130 task->bvsession->vsession.task_cnt--; in to_blk_dev()
134 blk_task_finish(struct spdk_vhost_user_blk_task *task) in to_blk_dev()
136 blk_task_dec_task_cnt(task);
137 task
154 blk_task_inc_task_cnt(struct spdk_vhost_user_blk_task * task) blk_task_inc_task_cnt() argument
163 blk_task_dec_task_cnt(struct spdk_vhost_user_blk_task * task) blk_task_dec_task_cnt() argument
173 blk_task_finish(struct spdk_vhost_user_blk_task * task) blk_task_finish() argument
180 blk_task_init(struct spdk_vhost_user_blk_task * task) blk_task_init() argument
192 blk_task_enqueue(struct spdk_vhost_user_blk_task * task) blk_task_enqueue() argument
206 vhost_user_blk_request_finish(uint8_t status,struct spdk_vhost_blk_task * task,void * cb_arg) vhost_user_blk_request_finish() argument
220 blk_request_finish(uint8_t status,struct spdk_vhost_blk_task * task) blk_request_finish() argument
462 struct spdk_vhost_blk_task *task = cb_arg; blk_request_complete_cb() local
471 struct spdk_vhost_blk_task *task = arg; blk_request_resubmit() local
485 blk_request_queue_io(struct spdk_vhost_dev * vdev,struct spdk_io_channel * ch,struct spdk_vhost_blk_task * task) blk_request_queue_io() argument
504 virtio_blk_process_request(struct spdk_vhost_dev * vdev,struct spdk_io_channel * ch,struct spdk_vhost_blk_task * task,virtio_blk_request_cb cb,void * cb_arg) virtio_blk_process_request() argument
690 struct spdk_vhost_user_blk_task *task; process_blk_task() local
731 struct spdk_vhost_user_blk_task *task; process_packed_blk_task() local
799 struct spdk_vhost_user_blk_task *task; process_packed_inflight_blk_task() local
1021 struct spdk_vhost_user_blk_task *task; no_bdev_process_packed_vq() local
1410 struct spdk_vhost_user_blk_task *task; alloc_vq_task_pool() local
[all...]
/spdk/test/unit/lib/iscsi/conn.c/
H A Dconn_ut.c86 struct spdk_iscsi_task *task; in iscsi_task_get() local
88 task = g_new_task; in iscsi_task_get()
89 if (task == NULL) { in iscsi_task_get()
92 memset(task, 0, sizeof(*task)); in iscsi_task_get()
94 task->scsi.ref = 1; in iscsi_task_get()
95 task->conn = conn; in iscsi_task_get()
96 task->scsi.cpl_fn = cpl_fn; in iscsi_task_get()
99 task->parent = parent; in iscsi_task_get()
100 task->scsi.dxfer_dir = parent->scsi.dxfer_dir; in iscsi_task_get()
101 task->scsi.transfer_len = parent->scsi.transfer_len; in iscsi_task_get()
[all …]
/spdk/module/bdev/malloc/
H A Dbdev_malloc.c192 struct malloc_task *task = (struct malloc_task *)ref; in malloc_done()
193 struct spdk_bdev_io *bdev_io = spdk_bdev_io_from_ctx(task); in malloc_done()
198 if (task->status == SPDK_BDEV_IO_STATUS_SUCCESS) { in malloc_done()
199 task->status = SPDK_BDEV_IO_STATUS_NOMEM; in malloc_done()
202 task->status = SPDK_BDEV_IO_STATUS_FAILED;
206 if (--task->num_outstanding != 0) { in malloc_complete_task()
211 task->status == SPDK_BDEV_IO_STATUS_SUCCESS) {
237 task->status = SPDK_BDEV_IO_STATUS_FAILED; in malloc_disk_free()
241 assert(!bdev_io->u.bdev.accel_sequence || task->status == SPDK_BDEV_IO_STATUS_NOMEM); in malloc_disk_free()
242 spdk_bdev_io_complete(spdk_bdev_io_from_ctx(task), tas in malloc_disk_free()
162 struct malloc_task *task = (struct malloc_task *)ref; malloc_done() local
203 malloc_complete_task(struct malloc_task * task,struct malloc_channel * mch,enum spdk_bdev_io_status status) malloc_complete_task() argument
295 malloc_sequence_fail(struct malloc_task * task,int status) malloc_sequence_fail() argument
311 struct malloc_task *task = ctx; malloc_sequence_done() local
321 bdev_malloc_readv(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,struct spdk_bdev_io * bdev_io) bdev_malloc_readv() argument
374 bdev_malloc_writev(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,struct spdk_bdev_io * bdev_io) bdev_malloc_writev() argument
426 bdev_malloc_unmap(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,uint64_t offset,uint64_t byte_count) bdev_malloc_unmap() argument
439 bdev_malloc_copy(struct malloc_disk * mdisk,struct spdk_io_channel * ch,struct malloc_task * task,uint64_t dst_offset,uint64_t src_offset,size_t len) bdev_malloc_copy() argument
461 struct malloc_task *task = (struct malloc_task *)bdev_io->driver_ctx; _bdev_malloc_submit_request() local
872 struct malloc_task *task; malloc_completion_poller() local
[all...]
/spdk/module/accel/mlx5/
H A Daccel_mlx5.c35 #define ACCEL_MLX5_UPDATE_ON_WR_SUBMITTED(qp, task) \
40 assert((task)->num_wrs < UINT16_MAX); \
41 (task)->num_wrs++; \
44 #define ACCEL_MLX5_UPDATE_ON_WR_SUBMITTED_SIGNALED(dev, qp, task) \
51 assert((task)->num_wrs < UINT16_MAX); \
52 (task)->num_wrs++; \
181 /* tasks submitted to HW. We can't complete a task even in error case until we reap completions for all in mlx5_qp_init_2_rts()
220 int (*init)(struct accel_mlx5_task *task); in mlx5_qp_init_2_rts()
221 int (*process)(struct accel_mlx5_task *task); in mlx5_qp_init_2_rts()
222 int (*cont)(struct accel_mlx5_task *task); in mlx5_qp_init_2_rts()
66 struct accel_mlx5_task *task; global() member
266 accel_mlx5_task_complete(struct accel_mlx5_task * task) accel_mlx5_task_complete() argument
282 struct accel_mlx5_task *task; accel_mlx5_flush_wrs() local
394 accel_mlx5_task_alloc_reqs(struct accel_mlx5_task * task) accel_mlx5_task_alloc_reqs() argument
428 struct spdk_accel_task *task = &mlx5_task->base; accel_mlx5_task_process() local
531 accel_mlx5_task_continue(struct accel_mlx5_task * task) accel_mlx5_task_continue() argument
558 struct spdk_accel_task *task = &mlx5_task->base; accel_mlx5_task_init() local
620 accel_mlx5_submit_tasks(struct spdk_io_channel * _ch,struct spdk_accel_task * task) accel_mlx5_submit_tasks() argument
656 struct accel_mlx5_task *task; accel_mlx5_poll_cq() local
728 struct accel_mlx5_task *task, *tmp; accel_mlx5_resubmit_nomem_tasks() local
[all...]
/spdk/module/accel/dpdk_cryptodev/
H A Daccel_dpdk_cryptodev.c160 uint32_t cryop_total; /* Total number of crypto operations in this task */
200 struct accel_dpdk_cryptodev_task *task);
241 struct accel_dpdk_cryptodev_task *task; in accel_dpdk_cryptodev_poll_qp()
256 * particular task so need to look at each and determine if it's in accel_dpdk_cryptodev_poll_qp()
257 * the last one for it's task or not. in accel_dpdk_cryptodev_poll_qp()
259 task = (struct accel_dpdk_cryptodev_task *)*RTE_MBUF_DYNFIELD(dequeued_ops[i]->sym->m_src, in accel_dpdk_cryptodev_poll_qp()
261 assert(task != NULL); in accel_dpdk_cryptodev_poll_qp()
265 /* Update the task status to error, we'll still process the in accel_dpdk_cryptodev_poll_qp()
266 * rest of the crypto ops for this task though so they in accel_dpdk_cryptodev_poll_qp()
269 task in accel_dpdk_cryptodev_poll_qp()
240 struct accel_dpdk_cryptodev_task *task; accel_dpdk_cryptodev_poll_qp() local
325 struct accel_dpdk_cryptodev_task *task, *task_tmp; accel_dpdk_cryptodev_poller() local
378 accel_dpdk_cryptodev_mbuf_chain_remainder(struct accel_dpdk_cryptodev_task * task,struct rte_mbuf * orig_mbuf,uint8_t * addr,uint64_t * _remainder) accel_dpdk_cryptodev_mbuf_chain_remainder() argument
411 accel_dpdk_cryptodev_mbuf_attach_buf(struct accel_dpdk_cryptodev_task * task,struct rte_mbuf * mbuf,uint8_t * addr,uint32_t len) accel_dpdk_cryptodev_mbuf_attach_buf() argument
514 accel_dpdk_cryptodev_mbuf_add_single_block(struct spdk_iov_sgl * sgl,struct rte_mbuf * mbuf,struct accel_dpdk_cryptodev_task * task) accel_dpdk_cryptodev_mbuf_add_single_block() argument
573 accel_dpdk_cryptodev_process_task(struct accel_dpdk_cryptodev_io_channel * crypto_ch,struct accel_dpdk_cryptodev_task * task) accel_dpdk_cryptodev_process_task() argument
945 struct accel_dpdk_cryptodev_task *task = SPDK_CONTAINEROF(_task, struct accel_dpdk_cryptodev_task, accel_dpdk_cryptodev_submit_tasks() local
[all...]
/spdk/module/bdev/daos/
H A Dbdev_daos.c203 struct bdev_daos_task *task = bdev_daos_task; in _bdev_daos_io_complete() local
206 task->offset, task->io_status ? "FAILURE" : "SUCCESS", task->io_status); in _bdev_daos_io_complete()
208 if (task->io_status == 0) { in _bdev_daos_io_complete()
209 spdk_bdev_io_complete(spdk_bdev_io_from_ctx(task), SPDK_BDEV_IO_STATUS_SUCCESS); in _bdev_daos_io_complete()
211 spdk_bdev_io_complete_aio_status(spdk_bdev_io_from_ctx(task), task->io_status); in _bdev_daos_io_complete()
218 struct bdev_daos_task *task = (struct bdev_daos_task *)bdev_io->driver_ctx; in bdev_daos_io_complete() local
221 assert(task->submit_td != NULL); in bdev_daos_io_complete()
223 task->io_status = io_status; in bdev_daos_io_complete()
224 if (task->submit_td != current_thread) { in bdev_daos_io_complete()
225 spdk_thread_send_msg(task->submit_td, _bdev_daos_io_complete, task); in bdev_daos_io_complete()
[all …]
/spdk/module/accel/error/
H A Daccel_error.c45 accel_error_get_task_ctx(struct spdk_accel_task *task) in accel_error_corrupt_task()
47 return (void *)((uint8_t *)task + g_task_offset); in accel_error_corrupt_task()
57 accel_error_corrupt_task(struct spdk_accel_task *task) in accel_error_task_complete_cb()
59 switch (task->op_code) { in accel_error_task_complete_cb()
61 *task->crc_dst += 1; in accel_error_task_complete_cb()
71 struct spdk_accel_task *task = arg; in accel_error_task_complete_cb()
72 struct accel_error_task *errtask = accel_error_get_task_ctx(task); in accel_error_task_complete_cb()
76 accel_error_corrupt_task(task); in accel_error_task_complete_cb()
83 struct spdk_accel_task *task = arg; in accel_error_task_complete_cb()
84 struct accel_error_task *errtask = accel_error_get_task_ctx(task); in accel_error_task_complete_cb()
36 accel_error_get_task_ctx(struct spdk_accel_task * task) accel_error_get_task_ctx() argument
42 accel_error_corrupt_task(struct spdk_accel_task * task) accel_error_corrupt_task() argument
56 struct spdk_accel_task *task = arg; accel_error_task_complete_cb() local
88 accel_error_submit_tasks(struct spdk_io_channel * ch,struct spdk_accel_task * task) accel_error_submit_tasks() argument
[all...]

12