| /spdk/test/nvme/e2edp/ |
| H A D | nvme_dp.c | 60 ns_data_buffer_reset(struct spdk_nvme_ns *ns, struct io_request *req, uint8_t data_pattern) in ns_data_buffer_reset() argument
69 for (i = 0; i < req->lba_count; i++) { in ns_data_buffer_reset()
70 if (req->use_extended_lba) { in ns_data_buffer_reset()
76 buf = (uint8_t *)req->contig + offset; in ns_data_buffer_reset()
84 struct io_request *req = (struct io_request *)cb_arg; in nvme_req_reset_sgl() local
86 req->sgl_offset = sgl_offset; in nvme_req_reset_sgl()
93 struct io_request *req = (struct io_request *)cb_arg; in nvme_req_next_sge() local
96 payload = req->contig + req->sgl_offset; in nvme_req_next_sge()
99 *length = req in nvme_req_next_sge()
106 dp_guard_check_extended_lba_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_guard_check_extended_lba_test() argument
150 dp_with_pract_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_with_pract_test() argument
196 dp_without_pract_extended_lba_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_without_pract_extended_lba_test() argument
240 dp_without_flags_extended_lba_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_without_flags_extended_lba_test() argument
268 dp_without_pract_separate_meta_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_without_pract_separate_meta_test() argument
318 dp_without_pract_separate_meta_apptag_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_without_pract_separate_meta_apptag_test() argument
360 dp_without_flags_separate_meta_test(struct spdk_nvme_ns * ns,struct io_request * req,uint32_t * io_flags) dp_without_flags_separate_meta_test() argument
393 free_req(struct io_request * req) free_req() argument
411 ns_data_buffer_compare(struct spdk_nvme_ns * ns,struct io_request * req,uint8_t data_pattern) ns_data_buffer_compare() argument
445 struct io_request *req; write_read_e2e_dp_tests() local
[all...] |
| /spdk/module/bdev/virtio/ |
| H A D | bdev_virtio_rpc.c | 33 struct rpc_bdev_virtio_blk_hotplug req = {false, 0}; in rpc_bdev_virtio_blk_set_hotplug() local
37 SPDK_COUNTOF(rpc_bdev_virtio_blk_hotplug_decoders), &req)) { in rpc_bdev_virtio_blk_set_hotplug()
43 rc = bdev_virtio_pci_blk_set_hotplug(req.enabled, req.period_us); in rpc_bdev_virtio_blk_set_hotplug()
81 struct rpc_remove_virtio_dev req = {NULL}; in rpc_bdev_virtio_detach_controller() local
86 &req)) { in rpc_bdev_virtio_detach_controller()
92 rc = bdev_virtio_blk_dev_remove(req.name, rpc_bdev_virtio_detach_controller_cb, request); in rpc_bdev_virtio_detach_controller()
94 rc = bdev_virtio_scsi_dev_remove(req.name, rpc_bdev_virtio_detach_controller_cb, request); in rpc_bdev_virtio_detach_controller()
102 free(req.name); in rpc_bdev_virtio_detach_controller()
146 free_rpc_bdev_virtio_attach_controller_ctx(struct rpc_bdev_virtio_attach_controller_ctx *req) in free_rpc_bdev_virtio_attach_controller_ctx() argument
148 free(req->name); in free_rpc_bdev_virtio_attach_controller_ctx()
[all …]
|
| /spdk/test/nvme/sgl/ |
| H A D | sgl.c | 53 struct io_request *req = (struct io_request *)cb_arg; in nvme_request_reset_sgl() local
55 for (i = 0; i < req->nseg; i++) { in nvme_request_reset_sgl()
56 iov = &req->iovs[i]; in nvme_request_reset_sgl()
62 req->current_iov_index = i; in nvme_request_reset_sgl()
63 req->current_iov_bytes_left = offset - sgl_offset; in nvme_request_reset_sgl()
70 struct io_request *req = (struct io_request *)cb_arg; in nvme_request_next_sge() local
73 if (req->current_iov_index >= req->nseg) { in nvme_request_next_sge()
79 iov = &req->iovs[req in nvme_request_next_sge()
106 build_io_request_0(struct io_request * req) build_io_request_0() argument
115 build_io_request_1(struct io_request * req) build_io_request_1() argument
125 build_io_request_2(struct io_request * req) build_io_request_2() argument
135 build_io_request_3(struct io_request * req) build_io_request_3() argument
155 build_io_request_4(struct io_request * req) build_io_request_4() argument
173 build_io_request_5(struct io_request * req) build_io_request_5() argument
183 build_io_request_6(struct io_request * req) build_io_request_6() argument
197 build_io_request_7(struct io_request * req) build_io_request_7() argument
214 build_io_request_8(struct io_request * req) build_io_request_8() argument
236 build_io_request_9(struct io_request * req) build_io_request_9() argument
259 build_io_request_10(struct io_request * req) build_io_request_10() argument
281 build_io_request_11(struct io_request * req) build_io_request_11() argument
302 free_req(struct io_request * req) free_req() argument
325 struct io_request *req; writev_readv_tests() local
[all...] |
| /spdk/lib/ublk/ |
| H A D | ublk_rpc.c | 23 free_rpc_ublk_create_target(struct rpc_ublk_create_target *req) in free_rpc_ublk_create_target() argument
25 free(req->cpumask); in free_rpc_ublk_create_target()
32 struct rpc_ublk_create_target req = {}; in rpc_ublk_create_target() local
37 &req)) { in rpc_ublk_create_target()
43 rc = ublk_create_target(req.cpumask, params); in rpc_ublk_create_target()
48 free_rpc_ublk_create_target(&req); in rpc_ublk_create_target()
53 free_rpc_ublk_create_target(&req); in rpc_ublk_create_target()
60 struct spdk_jsonrpc_request *req = arg; in ublk_destroy_target_done() local
62 spdk_jsonrpc_send_bool_response(req, true); in ublk_destroy_target_done()
95 free_rpc_ublk_start_disk(struct rpc_ublk_start_disk *req) in free_rpc_ublk_start_disk() argument
[all …]
|
| /spdk/module/blobfs/bdev/ |
| H A D | blobfs_bdev_rpc.c | 36 struct rpc_blobfs_set_cache_size req; in rpc_blobfs_set_cache_size() local
41 &req)) { in rpc_blobfs_set_cache_size()
49 if (req.size_in_mb == 0) { in rpc_blobfs_set_cache_size()
56 rc = spdk_fs_set_cache_size(req.size_in_mb); in rpc_blobfs_set_cache_size()
75 free_rpc_blobfs_detect(struct rpc_blobfs_detect *req) in free_rpc_blobfs_detect() argument
77 free(req->bdev_name); in free_rpc_blobfs_detect()
78 free(req); in free_rpc_blobfs_detect()
88 struct rpc_blobfs_detect *req = cb_arg; in _rpc_blobfs_detect_done() local
95 spdk_jsonrpc_send_error_response(req->request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in _rpc_blobfs_detect_done()
97 free_rpc_blobfs_detect(req); in _rpc_blobfs_detect_done()
[all …]
|
| /spdk/module/vfu_device/ |
| H A D | vfu_virtio_rpc.c | 26 free_rpc_delete_vfu_endpoint(struct rpc_delete_vfu_endpoint *req) in free_rpc_delete_vfu_endpoint()
28 free(req->name); in free_rpc_delete_vfu_endpoint()
35 struct rpc_delete_vfu_endpoint req = {0}; in rpc_vfu_virtio_delete_endpoint()
40 &req)) { in rpc_vfu_virtio_delete_endpoint()
46 rc = spdk_vfu_delete_endpoint(req.name); in rpc_vfu_virtio_delete_endpoint()
50 free_rpc_delete_vfu_endpoint(&req); in rpc_vfu_virtio_delete_endpoint()
56 free_rpc_delete_vfu_endpoint(&req); in rpc_vfu_virtio_delete_endpoint()
82 free_rpc_vfu_virtio_create_blk(struct rpc_vfu_virtio_create_blk *req) in free_rpc_vfu_virtio_create_blk()
84 free(req->name); in free_rpc_vfu_virtio_create_blk()
85 free(req in free_rpc_vfu_virtio_create_blk()
25 free_rpc_delete_vfu_endpoint(struct rpc_delete_vfu_endpoint * req) free_rpc_delete_vfu_endpoint() argument
34 struct rpc_delete_vfu_endpoint req = {0}; rpc_vfu_virtio_delete_endpoint() local
81 free_rpc_vfu_virtio_create_blk(struct rpc_vfu_virtio_create_blk * req) free_rpc_vfu_virtio_create_blk() argument
92 struct rpc_vfu_virtio_create_blk req = {0}; rpc_vfu_virtio_create_blk_endpoint() local
141 free_rpc_vfu_virtio_scsi(struct rpc_vfu_virtio_scsi * req) free_rpc_vfu_virtio_scsi() argument
151 struct rpc_vfu_virtio_scsi req = {0}; rpc_vfu_virtio_scsi_add_target() local
190 free_rpc_vfu_virtio_scsi_remove(struct rpc_vfu_virtio_scsi_remove * req) free_rpc_vfu_virtio_scsi_remove() argument
199 struct rpc_vfu_virtio_scsi_remove req = {0}; rpc_vfu_virtio_scsi_remove_target() local
244 free_rpc_vfu_virtio_create_scsi(struct rpc_vfu_virtio_create_scsi * req) free_rpc_vfu_virtio_create_scsi() argument
254 struct rpc_vfu_virtio_create_scsi req = {0}; rpc_vfu_virtio_create_scsi_endpoint() local
[all...] |
| /spdk/lib/lvol/ |
| H A D | lvol.c | 132 struct spdk_lvol_with_handle_req *req = cb_arg; in lvol_open_cb() local
133 struct spdk_lvol *lvol = req->lvol; in lvol_open_cb()
143 req->cb_fn(req->cb_arg, lvol, lvolerrno); in lvol_open_cb()
144 free(req); in lvol_open_cb()
150 struct spdk_lvol_with_handle_req *req; in spdk_lvol_open() local
173 req = calloc(1, sizeof(*req)); in spdk_lvol_open()
174 if (req == NULL) { in spdk_lvol_open()
180 req in spdk_lvol_open()
193 struct spdk_lvs_with_handle_req *req = (struct spdk_lvs_with_handle_req *)cb_arg; bs_unload_with_error_cb() local
202 struct spdk_lvs_with_handle_req *req = cb_arg; load_next_lvol() local
294 struct spdk_lvs_with_handle_req *req = (struct spdk_lvs_with_handle_req *)cb_arg; close_super_cb() local
313 struct spdk_lvs_with_handle_req *req = (struct spdk_lvs_with_handle_req *)cb_arg; close_super_blob_with_error_cb() local
325 struct spdk_lvs_with_handle_req *req = (struct spdk_lvs_with_handle_req *)cb_arg; lvs_read_uuid() local
381 struct spdk_lvs_with_handle_req *req = (struct spdk_lvs_with_handle_req *)cb_arg; lvs_open_super() local
399 struct spdk_lvs_with_handle_req *req = (struct spdk_lvs_with_handle_req *)cb_arg; lvs_load_cb() local
426 struct spdk_lvs_with_handle_req *req; lvs_load() local
496 exit_error_lvs_req(struct spdk_lvs_with_handle_req * req,struct spdk_lvol_store * lvs,int lvolerrno) exit_error_lvs_req() argument
507 struct spdk_lvs_with_handle_req *req = cb_arg; super_create_close_cb() local
523 struct spdk_lvs_with_handle_req *req = cb_arg; super_blob_set_cb() local
539 struct spdk_lvs_with_handle_req *req = cb_arg; super_blob_init_cb() local
560 struct spdk_lvs_with_handle_req *req = cb_arg; super_blob_create_open_cb() local
578 struct spdk_lvs_with_handle_req *req = cb_arg; super_blob_create_cb() local
763 struct spdk_lvs_req *req = cb_arg; lvs_rename_cb() local
789 struct spdk_lvs_req *req = cb_arg; lvs_rename_sync_cb() local
802 struct spdk_lvs_req *req = cb_arg; lvs_rename_open_cb() local
827 struct spdk_lvs_req *req; spdk_lvs_rename() local
991 struct spdk_lvol_req *req = cb_arg; lvol_close_blob_cb() local
1021 struct spdk_lvol_req *req = cb_arg; lvol_delete_blob_cb() local
1056 struct spdk_lvol_with_handle_req *req = cb_arg; lvol_create_open_cb() local
1083 struct spdk_lvol_with_handle_req *req = cb_arg; lvol_create_cb() local
1182 struct spdk_lvol_with_handle_req *req; spdk_lvol_create() local
1236 struct spdk_lvol_with_handle_req *req; spdk_lvol_create_esnap_clone() local
1303 struct spdk_lvol_with_handle_req *req; spdk_lvol_create_snapshot() local
1362 struct spdk_lvol_with_handle_req *req; spdk_lvol_create_clone() local
1420 struct spdk_lvol_req *req = cb_arg; lvol_resize_done() local
1429 struct spdk_lvol_req *req = cb_arg; lvol_blob_resize_cb() local
1447 struct spdk_lvol_req *req; spdk_lvol_resize() local
1466 struct spdk_lvol_req *req = cb_arg; lvol_set_read_only_cb() local
1475 struct spdk_lvol_req *req; spdk_lvol_set_read_only() local
1493 struct spdk_lvol_req *req = cb_arg; lvol_rename_cb() local
1511 struct spdk_lvol_req *req; spdk_lvol_rename() local
1554 struct spdk_lvol_req *req; spdk_lvol_destroy() local
1609 struct spdk_lvol_req *req; spdk_lvol_close() local
1653 struct spdk_lvol_req *req = cb_arg; lvol_inflate_cb() local
1668 struct spdk_lvol_req *req; spdk_lvol_inflate() local
1704 struct spdk_lvol_req *req; spdk_lvol_decouple_parent() local
1740 struct spdk_lvs_req *req = (struct spdk_lvs_req *)cb_arg; lvs_grow_live_cb() local
1752 struct spdk_lvs_req *req; spdk_lvs_grow_live() local
1773 struct spdk_lvs_with_handle_req *req; spdk_lvs_grow() local
2000 struct lvs_esnap_hotplug_req *req = cb_arg; lvs_esnap_hotplug_done() local
2021 struct lvs_esnap_hotplug_req *req; lvs_esnap_degraded_hotplug() local
2249 struct spdk_lvol_copy_req *req = cb_arg; lvol_shallow_copy_cb() local
2267 struct spdk_lvol_copy_req *req; spdk_lvol_shallow_copy() local
2318 struct spdk_lvol_req *req = cb_arg; lvol_set_parent_cb() local
2332 struct spdk_lvol_req *req; spdk_lvol_set_parent() local
2370 struct spdk_lvol_bs_dev_req *req = cb_arg; lvol_set_external_parent_cb() local
2385 struct spdk_lvol_bs_dev_req *req; spdk_lvol_set_external_parent() local
[all...] |
| /spdk/lib/reduce/ |
| H A D | reduce.c | 157 static void _start_readv_request(struct spdk_reduce_vol_request *req); in _reduce_persist()
158 static void _start_writev_request(struct spdk_reduce_vol_request *req); in _reduce_persist()
371 struct spdk_reduce_vol_request *req; in _allocate_vol_requests()
394 vol->request_mem = calloc(REDUCE_NUM_VOL_REQUESTS, sizeof(*req)); in _allocate_vol_requests()
430 req = &vol->request_mem[i];
431 TAILQ_INSERT_HEAD(&vol->free_requests, req, tailq); in _init_load_cleanup()
432 req->backing_io = (struct spdk_reduce_backing_io *)(vol->buf_backing_io_mem + i * in _init_load_cleanup()
436 req->decomp_buf_iov = &vol->buf_iov_mem[(2 * i) * vol->backing_io_units_per_chunk]; in _init_load_cleanup()
437 req->comp_buf_iov = &vol->buf_iov_mem[(2 * i + 1) * vol->backing_io_units_per_chunk]; in _init_load_cleanup()
439 rc = _set_buffer(&req in _init_load_cleanup()
353 struct spdk_reduce_vol_request *req; _allocate_vol_requests() local
993 _reduce_vol_complete_req(struct spdk_reduce_vol_request * req,int reduce_errno) _reduce_vol_complete_req() argument
1020 struct spdk_reduce_vol_request *req = _req; _write_write_done() local
1072 _issue_backing_ops(struct spdk_reduce_vol_request * req,struct spdk_reduce_vol * vol,reduce_request_fn next_fn,bool is_write) _issue_backing_ops() argument
1106 _reduce_vol_write_chunk(struct spdk_reduce_vol_request * req,reduce_request_fn next_fn,uint32_t compressed_size) _reduce_vol_write_chunk() argument
1173 struct spdk_reduce_vol_request *req = _req; _write_compress_done() local
1189 _reduce_vol_compress_chunk(struct spdk_reduce_vol_request * req,reduce_request_fn next_fn) _reduce_vol_compress_chunk() argument
1203 _reduce_vol_decompress_chunk_scratch(struct spdk_reduce_vol_request * req,reduce_request_fn next_fn) _reduce_vol_decompress_chunk_scratch() argument
1219 _reduce_vol_decompress_chunk(struct spdk_reduce_vol_request * req,reduce_request_fn next_fn) _reduce_vol_decompress_chunk() argument
1284 _prepare_compress_chunk_copy_user_buffers(struct spdk_reduce_vol_request * req,bool zero_paddings) _prepare_compress_chunk_copy_user_buffers() argument
1332 _prepare_compress_chunk(struct spdk_reduce_vol_request * req,bool zero_paddings) _prepare_compress_chunk() argument
1386 struct spdk_reduce_vol_request *req = _req; _write_decompress_done() local
1409 struct spdk_reduce_vol_request *req = _req; _write_read_done() local
1437 struct spdk_reduce_vol_request *req = _req; _read_decompress_done() local
1472 struct spdk_reduce_vol_request *req = _req; _read_read_done() local
1512 _reduce_vol_read_chunk(struct spdk_reduce_vol_request * req,reduce_request_fn next_fn) _reduce_vol_read_chunk() argument
1548 struct spdk_reduce_vol_request *req; _check_overlap() local
1560 _start_readv_request(struct spdk_reduce_vol_request * req) _start_readv_request() argument
1571 struct spdk_reduce_vol_request *req; spdk_reduce_vol_readv() local
1633 _start_writev_request(struct spdk_reduce_vol_request * req) _start_writev_request() argument
1660 struct spdk_reduce_vol_request *req; spdk_reduce_vol_writev() local
[all...] |
| /spdk/module/bdev/nvme/ |
| H A D | vbdev_opal_rpc.c | 20 free_rpc_bdev_nvme_opal_init(struct rpc_bdev_nvme_opal_init *req) in free_rpc_bdev_nvme_opal_init() argument
22 free(req->nvme_ctrlr_name); in free_rpc_bdev_nvme_opal_init()
23 free(req->password); in free_rpc_bdev_nvme_opal_init()
35 struct rpc_bdev_nvme_opal_init req = {}; in rpc_bdev_nvme_opal_init() local
41 &req)) { in rpc_bdev_nvme_opal_init()
48 nvme_ctrlr = nvme_ctrlr_get_by_name(req.nvme_ctrlr_name); in rpc_bdev_nvme_opal_init()
50 SPDK_ERRLOG("%s not support opal\n", req.nvme_ctrlr_name); in rpc_bdev_nvme_opal_init()
56 rc = spdk_opal_cmd_take_ownership(nvme_ctrlr->opal_dev, req.password); in rpc_bdev_nvme_opal_init()
75 rc = spdk_opal_cmd_activate_locking_sp(nvme_ctrlr->opal_dev, req.password); in rpc_bdev_nvme_opal_init()
85 free_rpc_bdev_nvme_opal_init(&req); in rpc_bdev_nvme_opal_init()
[all …]
|
| H A D | nvme_rpc.c | 42 struct rpc_bdev_nvme_send_cmd_req req; member
53 free(ctx->req.name); in free_rpc_bdev_nvme_send_cmd_ctx()
54 free(ctx->req.cmdbuf); in free_rpc_bdev_nvme_send_cmd_ctx()
55 spdk_free(ctx->req.data); in free_rpc_bdev_nvme_send_cmd_ctx()
56 spdk_free(ctx->req.md); in free_rpc_bdev_nvme_send_cmd_ctx()
65 struct rpc_bdev_nvme_send_cmd_req *req, in rpc_bdev_nvme_send_cmd_resp_construct() argument
74 if (req->data_direction == SPDK_NVME_DATA_CONTROLLER_TO_HOST) { in rpc_bdev_nvme_send_cmd_resp_construct()
75 if (req->data_len) { in rpc_bdev_nvme_send_cmd_resp_construct()
76 resp->data_text = malloc(spdk_base64_get_encoded_strlen(req->data_len) + 1); in rpc_bdev_nvme_send_cmd_resp_construct()
80 spdk_base64_urlsafe_encode(resp->data_text, req->data, req->data_len); in rpc_bdev_nvme_send_cmd_resp_construct()
[all …]
|
| H A D | bdev_nvme_rpc.c | 198 struct rpc_bdev_nvme_hotplug req = {false, 0}; in rpc_bdev_nvme_set_hotplug()
202 SPDK_COUNTOF(rpc_bdev_nvme_hotplug_decoders), &req)) { in rpc_bdev_nvme_set_hotplug()
208 rc = bdev_nvme_set_hotplug(req.enabled, req.period_us, rpc_bdev_nvme_set_hotplug_done, in rpc_bdev_nvme_set_hotplug()
247 free_rpc_bdev_nvme_attach_controller(struct rpc_bdev_nvme_attach_controller *req) in free_rpc_bdev_nvme_attach_controller()
249 free(req->name); in free_rpc_bdev_nvme_attach_controller()
250 free(req->trtype); in free_rpc_bdev_nvme_attach_controller()
251 free(req->adrfam); in free_rpc_bdev_nvme_attach_controller()
252 free(req->traddr); in free_rpc_bdev_nvme_attach_controller()
253 free(req in free_rpc_bdev_nvme_attach_controller()
197 struct rpc_bdev_nvme_hotplug req = {false, 0}; rpc_bdev_nvme_set_hotplug() local
246 free_rpc_bdev_nvme_attach_controller(struct rpc_bdev_nvme_attach_controller * req) free_rpc_bdev_nvme_attach_controller() argument
346 struct rpc_bdev_nvme_attach_controller req; global() member
676 struct rpc_bdev_nvme_get_controllers req = {}; rpc_bdev_nvme_get_controllers() local
728 free_rpc_bdev_nvme_detach_controller(struct rpc_bdev_nvme_detach_controller * req) free_rpc_bdev_nvme_detach_controller() argument
767 struct rpc_bdev_nvme_detach_controller req = {NULL}; rpc_bdev_nvme_detach_controller() local
882 free_rpc_apply_firmware(struct rpc_apply_firmware * req) free_rpc_apply_firmware() argument
907 struct rpc_apply_firmware req; global() member
1355 struct rpc_bdev_nvme_controller_op_req req = {NULL}; rpc_bdev_nvme_controller_op() local
1594 struct rpc_get_controller_health_info req = {}; rpc_bdev_nvme_get_controller_health_info() local
1645 free_rpc_bdev_nvme_start_discovery(struct rpc_bdev_nvme_start_discovery * req) free_rpc_bdev_nvme_start_discovery() argument
1670 struct rpc_bdev_nvme_start_discovery req; global() member
1796 struct rpc_bdev_nvme_stop_discovery req; global() member
1878 free_rpc_add_error_injection(struct rpc_add_error_injection * req) free_rpc_add_error_injection() argument
2017 free_rpc_remove_error_injection(struct rpc_remove_error_injection * req) free_rpc_remove_error_injection() argument
2128 struct rpc_get_io_paths req; global() member
2228 free_rpc_bdev_nvme_set_preferred_path(struct rpc_bdev_nvme_set_preferred_path * req) free_rpc_bdev_nvme_set_preferred_path() argument
2239 struct rpc_bdev_nvme_set_preferred_path req; global() member
2300 free_rpc_set_multipath_policy(struct rpc_set_multipath_policy * req) free_rpc_set_multipath_policy() argument
2347 struct rpc_set_multipath_policy req; global() member
2427 free_rpc_bdev_nvme_start_mdns_discovery(struct rpc_bdev_nvme_start_mdns_discovery * req) free_rpc_bdev_nvme_start_mdns_discovery() argument
2441 struct rpc_bdev_nvme_start_mdns_discovery req; global() member
2498 struct rpc_bdev_nvme_stop_mdns_discovery req; global() member
2568 free_rpc_get_path_stat(struct rpc_get_path_stat * req) free_rpc_get_path_stat() argument
2652 struct rpc_get_path_stat req = {}; rpc_bdev_nvme_get_path_iostat() local
[all...] |
| /spdk/lib/vhost/ |
| H A D | vhost_rpc.c | 25 free_rpc_vhost_scsi_ctrlr(struct rpc_vhost_scsi_ctrlr *req) in free_rpc_vhost_scsi_ctrlr() argument
27 free(req->ctrlr); in free_rpc_vhost_scsi_ctrlr()
28 free(req->cpumask); in free_rpc_vhost_scsi_ctrlr()
41 struct rpc_vhost_scsi_ctrlr req = {0}; in rpc_vhost_create_scsi_controller() local
46 &req)) { in rpc_vhost_create_scsi_controller()
52 if (req.delay) { in rpc_vhost_create_scsi_controller()
53 rc = spdk_vhost_scsi_dev_construct_no_start(req.ctrlr, req.cpumask); in rpc_vhost_create_scsi_controller()
55 rc = spdk_vhost_scsi_dev_construct(req.ctrlr, req in rpc_vhost_create_scsi_controller()
79 free_rpc_start_vhost_scsi_ctrlr(struct rpc_start_vhost_scsi_ctrlr * req) free_rpc_start_vhost_scsi_ctrlr() argument
92 struct rpc_start_vhost_scsi_ctrlr req = {0}; rpc_vhost_start_scsi_controller() local
128 free_rpc_vhost_scsi_ctrlr_add_target(struct rpc_vhost_scsi_ctrlr_add_target * req) free_rpc_vhost_scsi_ctrlr_add_target() argument
144 struct rpc_vhost_scsi_ctrlr_add_target req = {0}; rpc_vhost_scsi_controller_add_target() local
192 free_rpc_remove_vhost_scsi_ctrlr_target(struct rpc_remove_vhost_scsi_ctrlr_target * req) free_rpc_remove_vhost_scsi_ctrlr_target() argument
215 struct rpc_remove_vhost_scsi_ctrlr_target req = {0}; rpc_vhost_scsi_controller_remove_target() local
270 free_rpc_vhost_blk_ctrlr(struct rpc_vhost_blk_ctrlr * req) free_rpc_vhost_blk_ctrlr() argument
282 struct rpc_vhost_blk_ctrlr req = {0}; rpc_vhost_create_blk_controller() local
321 free_rpc_delete_vhost_ctrlr(struct rpc_delete_vhost_ctrlr * req) free_rpc_delete_vhost_ctrlr() argument
330 struct rpc_delete_vhost_ctrlr req = {0}; rpc_vhost_delete_controller() local
403 free_rpc_get_vhost_ctrlrs(struct rpc_get_vhost_ctrlrs * req) free_rpc_get_vhost_ctrlrs() argument
412 struct rpc_get_vhost_ctrlrs req = {0}; rpc_vhost_get_controllers() local
483 free_rpc_set_vhost_controllers_event_coalescing(struct rpc_vhost_ctrlr_coalescing * req) free_rpc_set_vhost_controllers_event_coalescing() argument
492 struct rpc_vhost_ctrlr_coalescing req = {0}; rpc_vhost_controller_set_coalescing() local
542 struct rpc_get_transport req = { 0 }; rpc_virtio_blk_get_transports() local
593 free_rpc_virtio_blk_create_transport(struct rpc_virtio_blk_create_transport * req) free_rpc_virtio_blk_create_transport() argument
602 struct rpc_virtio_blk_create_transport req = {0}; rpc_virtio_blk_create_transport() local
[all...] |
| /spdk/test/unit/lib/nvme/nvme_ctrlr_cmd.c/ |
| H A D | nvme_ctrlr_cmd_ut.c | 43 typedef void (*verify_request_fn_t)(struct nvme_request *req);
48 int (*iter_fn)(struct nvme_request *req, void *arg),
66 verify_firmware_log_page(struct nvme_request *req) in verify_firmware_log_page() argument
70 CU_ASSERT(req->cmd.opc == SPDK_NVME_OPC_GET_LOG_PAGE); in verify_firmware_log_page()
71 CU_ASSERT(req->cmd.nsid == SPDK_NVME_GLOBAL_NS_TAG); in verify_firmware_log_page()
75 CU_ASSERT(req->cmd.cdw10 == temp_cdw10); in verify_firmware_log_page()
79 verify_health_log_page(struct nvme_request *req) in verify_health_log_page() argument
83 CU_ASSERT(req->cmd.opc == SPDK_NVME_OPC_GET_LOG_PAGE); in verify_health_log_page()
84 CU_ASSERT(req->cmd.nsid == health_log_nsid); in verify_health_log_page()
88 CU_ASSERT(req->cmd.cdw10 == temp_cdw10); in verify_health_log_page()
[all …]
|
| /spdk/module/bdev/rbd/ |
| H A D | bdev_rbd_rpc.c | 24 free_rpc_create_rbd(struct rpc_create_rbd *req) in free_rpc_create_rbd() argument
26 free(req->name); in free_rpc_create_rbd()
27 free(req->user_id); in free_rpc_create_rbd()
28 free(req->pool_name); in free_rpc_create_rbd()
29 free(req->rbd_name); in free_rpc_create_rbd()
30 bdev_rbd_free_config(req->config); in free_rpc_create_rbd()
31 free(req->cluster_name); in free_rpc_create_rbd()
91 struct rpc_create_rbd req = {}; in rpc_bdev_rbd_create() local
98 &req)) { in rpc_bdev_rbd_create()
105 rc = bdev_rbd_create(&bdev, req.name, req.user_id, req.pool_name, in rpc_bdev_rbd_create()
[all …]
|
| /spdk/lib/nbd/ |
| H A D | nbd_rpc.c | 26 free_rpc_nbd_start_disk(struct rpc_nbd_start_disk *req) in free_rpc_nbd_start_disk() argument
28 free(req->bdev_name); in free_rpc_nbd_start_disk()
29 free(req->nbd_device); in free_rpc_nbd_start_disk()
30 free(req); in free_rpc_nbd_start_disk()
113 struct rpc_nbd_start_disk *req = cb_arg; in rpc_start_nbd_done() local
114 struct spdk_jsonrpc_request *request = req->request; in rpc_start_nbd_done()
118 if (rc == -EBUSY && req->nbd_idx_specified == false) { in rpc_start_nbd_done()
119 free(req->nbd_device); in rpc_start_nbd_done()
121 req->nbd_device = find_available_nbd_disk(req->nbd_idx, &req->nbd_idx); in rpc_start_nbd_done()
122 if (req->nbd_device != NULL) { in rpc_start_nbd_done()
[all …]
|
| /spdk/test/unit/lib/reduce/reduce.c/ |
| H A D | reduce_ut.c | 1413 struct spdk_reduce_vol_request req = {}; in test_prepare_compress_chunk()
1440 req.vol = &vol; in test_prepare_compress_chunk()
1441 req.decomp_buf = decomp_buffer; in test_prepare_compress_chunk()
1442 req.comp_buf = comp_buffer; in test_prepare_compress_chunk()
1443 req.iov = user_iov; in test_prepare_compress_chunk()
1444 req.iovcnt = 2; in test_prepare_compress_chunk()
1445 req.offset = 0; in test_prepare_compress_chunk()
1450 req.iov[i].iov_base = aligned_user_buffer + i * user_buffer_iov_len; in test_prepare_compress_chunk()
1451 req.iov[i].iov_len = user_buffer_iov_len; in test_prepare_compress_chunk()
1454 _prepare_compress_chunk(&req, fals in test_prepare_compress_chunk()
1271 struct spdk_reduce_vol_request req = {}; test_prepare_compress_chunk() local
1562 struct spdk_reduce_vol_request req = {}; test_reduce_decompress_chunk() local
[all...] |
| /spdk/module/bdev/null/ |
| H A D | bdev_null_rpc.c | 15 free_rpc_construct_null(struct null_bdev_opts *req)
17 free(req->name);
36 struct null_bdev_opts req = {};
43 &req)) { in rpc_bdev_null_create()
50 rc = bdev_null_create(&bdev, &req); in rpc_bdev_null_create()
59 free_rpc_construct_null(&req); in rpc_bdev_null_create()
63 free_rpc_construct_null(&req); in rpc_bdev_null_create()
72 free_rpc_delete_null(struct rpc_delete_null *req) in rpc_bdev_null_create()
74 free(req->name); in rpc_bdev_null_create()
97 struct rpc_delete_null req in rpc_bdev_null_create()
26 free_rpc_construct_null(struct rpc_construct_null * req) free_rpc_construct_null() argument
46 struct rpc_construct_null req = {}; rpc_bdev_null_create() local
126 free_rpc_delete_null(struct rpc_delete_null * req) free_rpc_delete_null() argument
151 struct rpc_delete_null req = {NULL}; rpc_bdev_null_delete() local
183 free_rpc_bdev_null_resize(struct rpc_bdev_null_resize * req) free_rpc_bdev_null_resize() argument
192 struct rpc_bdev_null_resize req = {}; spdk_rpc_bdev_null_resize() local
[all...] |
| /spdk/test/accel/dif/ |
| H A D | dif.c | 468 struct accel_dif_request *req = arg; in accel_dif_verify_op_dif_not_generated_reftag_check()
471 rc = spdk_accel_submit_dif_verify(req->channel, req->src_iovs, req->src_iovcnt,
472 req->num_blocks, req->ctx, req->err,
473 req->cb_fn, req->cb_arg); in accel_dif_verify_op_apptag_correct_apptag_check()
483 struct accel_dif_request *req in accel_dif_verify_op_apptag_correct_apptag_check()
306 struct accel_dif_request *req = arg; accel_dif_verify_test() local
321 struct accel_dif_request *req = arg; accel_dif_verify_copy_test() local
337 struct accel_dif_request *req = arg; accel_dif_generate_copy_test() local
352 struct accel_dif_request req; accel_dif_verify_op_dif_generated_do_check() local
420 struct accel_dif_request req; accel_dif_verify_op_dif_not_generated_do_check() local
476 struct accel_dif_request req; accel_dif_verify_op_apptag_correct_apptag_check() local
516 struct accel_dif_request req; accel_dif_verify_op_apptag_incorrect_apptag_check() local
564 struct accel_dif_request req; accel_dif_verify_op_tag_incorrect_no_check_or_ignore() local
630 struct accel_dif_request req; accel_dif_verify_op_reftag_init_correct_reftag_check() local
670 struct accel_dif_request req; accel_dif_verify_op_reftag_init_incorrect_reftag_check() local
718 struct accel_dif_request req; accel_dif_verify_copy_op_dif_generated_do_check() local
788 struct accel_dif_request req; accel_dif_verify_copy_op_dif_not_generated_do_check() local
846 struct accel_dif_request req; accel_dif_generate_copy_op_dif_generated_do_check() local
919 struct accel_dif_request req; accel_dif_generate_copy_op_dif_generated_no_guard_check_flag_set() local
971 struct accel_dif_request req; accel_dif_generate_copy_op_dif_generated_no_apptag_check_flag_set() local
1023 struct accel_dif_request req; accel_dif_generate_copy_op_dif_generated_no_reftag_check_flag_set() local
1074 struct accel_dif_request req; accel_dif_generate_copy_op_iovecs_len_validate() local
1117 struct accel_dif_request req; accel_dif_generate_copy_op_buf_align_validate() local
[all...] |
| /spdk/module/bdev/lvol/ |
| H A D | vbdev_lvol_rpc.c | 72 free_rpc_bdev_lvol_create_lvstore(struct rpc_bdev_lvol_create_lvstore *req) in free_rpc_bdev_lvol_create_lvstore()
74 free(req->bdev_name); in free_rpc_bdev_lvol_create_lvstore()
75 free(req->lvs_name); in free_rpc_bdev_lvol_create_lvstore()
76 free(req->clear_method); in free_rpc_bdev_lvol_create_lvstore()
112 struct rpc_bdev_lvol_create_lvstore req = {}; in rpc_bdev_lvol_create_lvstore()
118 &req)) { in rpc_bdev_lvol_create_lvstore()
125 if (req.clear_method != NULL) { in rpc_bdev_lvol_create_lvstore()
126 if (!strcasecmp(req.clear_method, "none")) { in rpc_bdev_lvol_create_lvstore()
128 } else if (!strcasecmp(req.clear_method, "unmap")) { in rpc_bdev_lvol_create_lvstore()
130 } else if (!strcasecmp(req in rpc_bdev_lvol_create_lvstore()
71 free_rpc_bdev_lvol_create_lvstore(struct rpc_bdev_lvol_create_lvstore * req) free_rpc_bdev_lvol_create_lvstore() argument
110 struct rpc_bdev_lvol_create_lvstore req = {}; rpc_bdev_lvol_create_lvstore() local
159 free_rpc_bdev_lvol_rename_lvstore(struct rpc_bdev_lvol_rename_lvstore * req) free_rpc_bdev_lvol_rename_lvstore() argument
191 struct rpc_bdev_lvol_rename_lvstore req = {}; rpc_bdev_lvol_rename_lvstore() local
223 free_rpc_bdev_lvol_delete_lvstore(struct rpc_bdev_lvol_delete_lvstore * req) free_rpc_bdev_lvol_delete_lvstore() argument
255 struct rpc_bdev_lvol_delete_lvstore req = {}; rpc_bdev_lvol_delete_lvstore() local
291 free_rpc_bdev_lvol_create(struct rpc_bdev_lvol_create * req) free_rpc_bdev_lvol_create() argument
332 struct rpc_bdev_lvol_create req = {}; rpc_bdev_lvol_create() local
388 free_rpc_bdev_lvol_snapshot(struct rpc_bdev_lvol_snapshot * req) free_rpc_bdev_lvol_snapshot() argument
423 struct rpc_bdev_lvol_snapshot req = {}; rpc_bdev_lvol_snapshot() local
466 free_rpc_bdev_lvol_clone(struct rpc_bdev_lvol_clone * req) free_rpc_bdev_lvol_clone() argument
501 struct rpc_bdev_lvol_clone req = {}; rpc_bdev_lvol_clone() local
546 free_rpc_bdev_lvol_clone_bdev(struct rpc_bdev_lvol_clone_bdev * req) free_rpc_bdev_lvol_clone_bdev() argument
571 struct rpc_bdev_lvol_clone_bdev req = {}; rpc_bdev_lvol_clone_bdev() local
627 free_rpc_bdev_lvol_rename(struct rpc_bdev_lvol_rename * req) free_rpc_bdev_lvol_rename() argument
659 struct rpc_bdev_lvol_rename req = {}; rpc_bdev_lvol_rename() local
701 free_rpc_bdev_lvol_inflate(struct rpc_bdev_lvol_inflate * req) free_rpc_bdev_lvol_inflate() argument
731 struct rpc_bdev_lvol_inflate req = {}; rpc_bdev_lvol_inflate() local
772 struct rpc_bdev_lvol_inflate req = {}; rpc_bdev_lvol_decouple_parent() local
815 free_rpc_bdev_lvol_resize(struct rpc_bdev_lvol_resize * req) free_rpc_bdev_lvol_resize() argument
846 struct rpc_bdev_lvol_resize req = {}; rpc_bdev_lvol_resize() local
888 free_rpc_set_ro_lvol_bdev(struct rpc_set_ro_lvol_bdev * req) free_rpc_set_ro_lvol_bdev() argument
918 struct rpc_set_ro_lvol_bdev req = {}; rpc_bdev_lvol_set_read_only() local
965 free_rpc_bdev_lvol_delete(struct rpc_bdev_lvol_delete * req) free_rpc_bdev_lvol_delete() argument
995 struct rpc_bdev_lvol_delete req = {}; rpc_bdev_lvol_delete() local
1058 free_rpc_bdev_lvol_get_lvstores(struct rpc_bdev_lvol_get_lvstores * req) free_rpc_bdev_lvol_get_lvstores() argument
1095 struct rpc_bdev_lvol_get_lvstores req = {}; rpc_bdev_lvol_get_lvstores() local
1152 free_rpc_bdev_lvol_get_lvols(struct rpc_bdev_lvol_get_lvols * req) free_rpc_bdev_lvol_get_lvols() argument
1201 struct rpc_bdev_lvol_get_lvols req = {}; rpc_bdev_lvol_get_lvols() local
1257 free_rpc_bdev_lvol_grow_lvstore(struct rpc_bdev_lvol_grow_lvstore * req) free_rpc_bdev_lvol_grow_lvstore() argument
1289 struct rpc_bdev_lvol_grow_lvstore req = {}; rpc_bdev_lvol_grow_lvstore() local
1326 free_rpc_bdev_lvol_shallow_copy(struct rpc_bdev_lvol_shallow_copy * req) free_rpc_bdev_lvol_shallow_copy() argument
1359 struct rpc_bdev_lvol_shallow_copy req = {}; rpc_bdev_lvol_start_shallow_copy() local
1446 free_rpc_bdev_lvol_shallow_copy_status(struct rpc_bdev_lvol_shallow_copy_status * req) free_rpc_bdev_lvol_shallow_copy_status() argument
1459 struct rpc_bdev_lvol_shallow_copy_status req = {}; rpc_bdev_lvol_check_shallow_copy() local
1528 free_rpc_bdev_lvol_set_parent(struct rpc_bdev_lvol_set_parent * req) free_rpc_bdev_lvol_set_parent() argument
1560 struct rpc_bdev_lvol_set_parent req = {}; rpc_bdev_lvol_set_parent() local
1615 struct rpc_bdev_lvol_set_parent req = {}; rpc_bdev_lvol_set_parent_bdev() local
[all...] |
| /spdk/lib/nvmf/ |
| H A D | ctrlr_bdev.c | 73 struct spdk_nvmf_request *req = cb_arg; in nvmf_bdev_ctrlr_complete_cmd() local
74 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; in nvmf_bdev_ctrlr_complete_cmd()
78 if (spdk_unlikely(req->first_fused)) { in nvmf_bdev_ctrlr_complete_cmd()
79 struct spdk_nvmf_request *first_req = req->first_fused_req; in nvmf_bdev_ctrlr_complete_cmd()
91 req->first_fused_req = NULL; in nvmf_bdev_ctrlr_complete_cmd()
92 req->first_fused = false; in nvmf_bdev_ctrlr_complete_cmd()
101 spdk_nvmf_request_complete(req); in nvmf_bdev_ctrlr_complete_cmd()
109 struct spdk_nvmf_request *req = cb_arg; in nvmf_bdev_ctrlr_complete_admin_cmd() local
111 if (req->cmd_cb_fn) { in nvmf_bdev_ctrlr_complete_admin_cmd()
112 req in nvmf_bdev_ctrlr_complete_admin_cmd()
237 struct spdk_nvmf_request *req = arg; nvmf_ctrlr_process_io_cmd_resubmit() local
249 struct spdk_nvmf_request *req = arg; nvmf_ctrlr_process_admin_cmd_resubmit() local
259 nvmf_bdev_ctrl_queue_io(struct spdk_nvmf_request * req,struct spdk_bdev * bdev,struct spdk_io_channel * ch,spdk_bdev_io_wait_cb cb_fn,void * cb_arg) nvmf_bdev_ctrl_queue_io() argument
283 nvmf_bdev_ctrlr_read_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_read_cmd() argument
335 nvmf_bdev_ctrlr_write_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_write_cmd() argument
388 nvmf_bdev_ctrlr_compare_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_compare_cmd() argument
487 nvmf_bdev_ctrlr_write_zeroes_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_write_zeroes_cmd() argument
537 nvmf_bdev_ctrlr_flush_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_flush_cmd() argument
566 struct spdk_nvmf_request *req; global() member
579 struct spdk_nvmf_request *req = unmap_ctx->req; nvmf_bdev_ctrlr_unmap_cpl() local
608 struct spdk_nvmf_request *req = unmap_ctx->req; nvmf_bdev_ctrlr_unmap_resubmit() local
618 nvmf_bdev_ctrlr_unmap(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req,struct nvmf_bdev_ctrlr_unmap * unmap_ctx) nvmf_bdev_ctrlr_unmap() argument
702 nvmf_bdev_ctrlr_dsm_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_dsm_cmd() argument
718 nvmf_bdev_ctrlr_copy_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_copy_cmd() argument
783 nvmf_bdev_ctrlr_nvme_passthru_io(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_nvme_passthru_io() argument
806 spdk_nvmf_bdev_ctrlr_nvme_passthru_admin(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req,spdk_nvmf_nvme_passthru_cmd_cb cb_fn) spdk_nvmf_bdev_ctrlr_nvme_passthru_admin() argument
844 struct spdk_nvmf_request *req = cb_arg; nvmf_bdev_ctrlr_complete_abort_cmd() local
856 spdk_nvmf_bdev_ctrlr_abort_cmd(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req,struct spdk_nvmf_request * req_to_abort) spdk_nvmf_bdev_ctrlr_abort_cmd() argument
915 struct spdk_nvmf_request *req = cb_arg; nvmf_bdev_ctrlr_zcopy_start_complete() local
953 nvmf_bdev_ctrlr_zcopy_start(struct spdk_bdev * bdev,struct spdk_bdev_desc * desc,struct spdk_io_channel * ch,struct spdk_nvmf_request * req) nvmf_bdev_ctrlr_zcopy_start() argument
1000 struct spdk_nvmf_request *req = cb_arg; nvmf_bdev_ctrlr_zcopy_end_complete() local
1019 nvmf_bdev_ctrlr_zcopy_end(struct spdk_nvmf_request * req,bool commit) nvmf_bdev_ctrlr_zcopy_end() argument
[all...] |
| H A D | auth.c | 64 nvmf_auth_request_complete(struct spdk_nvmf_request *req, int sct, int sc, int dnr) in nvmf_auth_request_complete()
66 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; in nvmf_auth_request_complete()
72 spdk_nvmf_request_complete(req); in nvmf_auth_request_complete()
113 nvmf_auth_request_fail1(struct spdk_nvmf_request *req, int reason) in nvmf_auth_request_fail1()
115 struct spdk_nvmf_qpair *qpair = req->qpair; in nvmf_auth_request_fail1()
124 nvmf_auth_request_complete(req, SPDK_NVME_SCT_GENERIC, SPDK_NVME_SC_SUCCESS, 0); in nvmf_auth_request_fail1()
191 nvmf_auth_check_command(struct spdk_nvmf_request *req, uint8_t secp, in nvmf_auth_check_command()
194 struct spdk_nvmf_qpair *qpair = req->qpair; in nvmf_auth_check_command()
204 if (len != req->length) {
205 AUTH_ERRLOG(qpair, "invalid length: %"PRIu32" != %"PRIu32"\n", len, req
63 nvmf_auth_request_complete(struct spdk_nvmf_request * req,int sct,int sc,int dnr) nvmf_auth_request_complete() argument
112 nvmf_auth_request_fail1(struct spdk_nvmf_request * req,int reason) nvmf_auth_request_fail1() argument
184 nvmf_auth_check_command(struct spdk_nvmf_request * req,uint8_t secp,uint8_t spsp0,uint8_t spsp1,uint32_t len) nvmf_auth_check_command() argument
206 nvmf_auth_get_message(struct spdk_nvmf_request * req,size_t size) nvmf_auth_get_message() argument
216 nvmf_auth_negotiate_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_auth_negotiate * msg) nvmf_auth_negotiate_exec() argument
335 nvmf_auth_reply_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_dhchap_reply * msg) nvmf_auth_reply_exec() argument
470 nvmf_auth_success2_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_dhchap_success2 * msg) nvmf_auth_success2_exec() argument
499 nvmf_auth_failure2_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_auth_failure * msg) nvmf_auth_failure2_exec() argument
527 nvmf_auth_send_exec(struct spdk_nvmf_request * req) nvmf_auth_send_exec() argument
584 nvmf_auth_recv_complete(struct spdk_nvmf_request * req,uint32_t length) nvmf_auth_recv_complete() argument
592 nvmf_auth_recv_failure1(struct spdk_nvmf_request * req,int fail_reason) nvmf_auth_recv_failure1() argument
643 nvmf_auth_recv_challenge(struct spdk_nvmf_request * req) nvmf_auth_recv_challenge() argument
710 nvmf_auth_recv_success1(struct spdk_nvmf_request * req) nvmf_auth_recv_success1() argument
755 nvmf_auth_recv_exec(struct spdk_nvmf_request * req) nvmf_auth_recv_exec() argument
793 nvmf_auth_request_exec(struct spdk_nvmf_request * req) nvmf_auth_request_exec() argument
[all...] |
| /spdk/lib/iscsi/ |
| H A D | iscsi_rpc.c | 113 struct rpc_initiator_group req = {}; in rpc_iscsi_create_initiator_group() local
116 SPDK_COUNTOF(rpc_initiator_group_decoders), &req)) { in rpc_iscsi_create_initiator_group()
121 if (req.initiator_list.num_initiators == 0 || in rpc_iscsi_create_initiator_group()
122 req.netmask_list.num_netmasks == 0) { in rpc_iscsi_create_initiator_group()
126 if (iscsi_init_grp_create_from_initiator_list(req.tag, in rpc_iscsi_create_initiator_group()
127 req.initiator_list.num_initiators, in rpc_iscsi_create_initiator_group()
128 req.initiator_list.initiators, in rpc_iscsi_create_initiator_group()
129 req.netmask_list.num_netmasks, in rpc_iscsi_create_initiator_group()
130 req.netmask_list.netmasks)) { in rpc_iscsi_create_initiator_group()
135 free_rpc_initiator_group(&req); in rpc_iscsi_create_initiator_group()
[all …]
|
| /spdk/lib/nvme/ |
| H A D | nvme_ctrlr_cmd.c | 15 struct nvme_request *req; in spdk_nvme_ctrlr_io_cmd_raw_no_payload_build() local
23 req = nvme_allocate_request(qpair, &payload, 0, 0, cb_fn, cb_arg); in spdk_nvme_ctrlr_io_cmd_raw_no_payload_build()
25 if (req == NULL) { in spdk_nvme_ctrlr_io_cmd_raw_no_payload_build()
29 memcpy(&req->cmd, cmd, sizeof(req->cmd)); in spdk_nvme_ctrlr_io_cmd_raw_no_payload_build()
31 return nvme_qpair_submit_request(qpair, req); in spdk_nvme_ctrlr_io_cmd_raw_no_payload_build()
41 struct nvme_request *req; in spdk_nvme_ctrlr_cmd_io_raw() local
43 req = nvme_allocate_request_contig(qpair, buf, len, cb_fn, cb_arg); in spdk_nvme_ctrlr_cmd_io_raw()
45 if (req == NULL) { in spdk_nvme_ctrlr_cmd_io_raw()
49 memcpy(&req in spdk_nvme_ctrlr_cmd_io_raw()
61 struct nvme_request *req; spdk_nvme_ctrlr_cmd_io_raw_with_md() local
95 struct nvme_request *req; spdk_nvme_ctrlr_cmd_iov_raw_with_md() local
130 struct nvme_request *req; spdk_nvme_ctrlr_cmd_admin_raw() local
153 struct nvme_request *req; nvme_ctrlr_cmd_identify() local
183 struct nvme_request *req; nvme_ctrlr_cmd_attach_ns() local
211 struct nvme_request *req; nvme_ctrlr_cmd_detach_ns() local
239 struct nvme_request *req; nvme_ctrlr_cmd_create_ns() local
266 struct nvme_request *req; nvme_ctrlr_cmd_delete_ns() local
292 struct nvme_request *req; nvme_ctrlr_cmd_doorbell_buffer_config() local
318 struct nvme_request *req; nvme_ctrlr_cmd_format() local
345 struct nvme_request *req; spdk_nvme_ctrlr_cmd_set_feature() local
374 struct nvme_request *req; spdk_nvme_ctrlr_cmd_get_feature() local
403 struct nvme_request *req; spdk_nvme_ctrlr_cmd_get_feature_ns() local
433 struct nvme_request *req; spdk_nvme_ctrlr_cmd_set_feature_ns() local
524 struct nvme_request *req; spdk_nvme_ctrlr_cmd_get_log_page_ext() local
623 _nvme_ctrlr_submit_abort_request(struct spdk_nvme_ctrlr * ctrlr,struct nvme_request * req) _nvme_ctrlr_submit_abort_request() argument
638 struct nvme_request *req = ctx; nvme_ctrlr_cmd_abort_cpl() local
655 struct nvme_request *req; spdk_nvme_ctrlr_cmd_abort() local
686 struct nvme_request *req = ctx; nvme_complete_abort_request() local
709 nvme_request_add_abort(struct nvme_request * req,void * arg) nvme_request_add_abort() argument
854 struct nvme_request *req; nvme_ctrlr_cmd_fw_commit() local
881 struct nvme_request *req; nvme_ctrlr_cmd_fw_image_download() local
908 struct nvme_request *req; spdk_nvme_ctrlr_cmd_security_receive() local
939 struct nvme_request *req; spdk_nvme_ctrlr_cmd_security_send() local
970 struct nvme_request *req; nvme_ctrlr_cmd_sanitize() local
1000 struct nvme_request *req = NULL; nvme_ctrlr_cmd_directive() local
[all...] |
| /spdk/module/bdev/delay/ |
| H A D | vbdev_delay_rpc.c | 26 free_rpc_update_latency(struct rpc_update_latency *req) in free_rpc_update_latency() argument
28 free(req->delay_bdev_name); in free_rpc_update_latency()
29 free(req->latency_type); in free_rpc_update_latency()
36 struct rpc_update_latency req = {NULL}; in rpc_bdev_delay_update_latency() local
42 &req)) { in rpc_bdev_delay_update_latency()
49 if (!strncmp(req.latency_type, "avg_read", 9)) { in rpc_bdev_delay_update_latency()
51 } else if (!strncmp(req.latency_type, "p99_read", 9)) { in rpc_bdev_delay_update_latency()
53 } else if (!strncmp(req.latency_type, "avg_write", 10)) { in rpc_bdev_delay_update_latency()
55 } else if (!strncmp(req.latency_type, "p99_write", 10)) { in rpc_bdev_delay_update_latency()
63 rc = vbdev_delay_update_latency_value(req.delay_bdev_name, req.latency_us, latency_type); in rpc_bdev_delay_update_latency()
[all …]
|
| /spdk/module/bdev/crypto/ |
| H A D | vbdev_crypto_rpc.c | 87 struct rpc_construct_crypto req = {}; in rpc_bdev_crypto_create() local
96 &req)) { in rpc_bdev_crypto_create()
102 if (!req.name) { in rpc_bdev_crypto_create()
108 if (req.param.key_name) { in rpc_bdev_crypto_create()
110 key = spdk_accel_crypto_key_get(req.param.key_name); in rpc_bdev_crypto_create()
112 if (req.param.hex_key || req.param.cipher || req.crypto_pmd) { in rpc_bdev_crypto_create()
115 SPDK_NOTICELOG("Found key \"%s\"\n", req.param.key_name); in rpc_bdev_crypto_create()
121 if (req.param.key_name) { in rpc_bdev_crypto_create()
127 if (req.param.cipher == NULL) { in rpc_bdev_crypto_create()
128 req.param.cipher = strdup(BDEV_CRYPTO_DEFAULT_CIPHER); in rpc_bdev_crypto_create()
[all …]
|