| /spdk/lib/nvme/ |
| H A D | nvme_discovery.c | 21 struct nvme_discovery_ctx *ctx = cb_arg; in get_log_page_completion_final() local
25 free(ctx->log_page); in get_log_page_completion_final()
26 ctx->cb_fn(ctx->cb_arg, 0, cpl, NULL); in get_log_page_completion_final()
27 free(ctx); in get_log_page_completion_final()
32 if (ctx->start_genctr == ctx->end_genctr) { in get_log_page_completion_final()
33 ctx->cb_fn(ctx->cb_arg, 0, cpl, ctx in get_log_page_completion_final()
47 struct nvme_discovery_ctx *ctx = cb_arg; get_log_page_completion() local
71 struct nvme_discovery_ctx *ctx = cb_arg; discovery_log_header_completion() local
140 struct nvme_discovery_ctx *ctx; spdk_nvme_ctrlr_get_discovery_log_page() local
[all...] |
| H A D | nvme_cuse.c | 74 cuse_io_ctx_free(struct cuse_io_ctx *ctx) in cuse_io_ctx_free() argument
76 spdk_free(ctx->data); in cuse_io_ctx_free()
77 spdk_free(ctx->metadata); in cuse_io_ctx_free()
78 free(ctx); in cuse_io_ctx_free()
110 struct cuse_io_ctx *ctx = arg; in cuse_nvme_passthru_cmd_cb() local
121 if (ctx->data_transfer == SPDK_NVME_DATA_CONTROLLER_TO_HOST) { in cuse_nvme_passthru_cmd_cb()
122 if (ctx->data_len > 0) { in cuse_nvme_passthru_cmd_cb()
123 out_iov[out_iovcnt].iov_base = ctx->data; in cuse_nvme_passthru_cmd_cb()
124 out_iov[out_iovcnt].iov_len = ctx->data_len; in cuse_nvme_passthru_cmd_cb()
127 if (ctx in cuse_nvme_passthru_cmd_cb()
142 struct cuse_io_ctx *ctx = arg; cuse_nvme_passthru_cmd_execute() local
162 struct cuse_io_ctx *ctx; cuse_nvme_passthru_cmd_send() local
408 struct cuse_io_ctx *ctx = (struct cuse_io_ctx *)ref; cuse_nvme_submit_io_write_done() local
420 struct cuse_io_ctx *ctx = arg; cuse_nvme_submit_io_write_cb() local
443 struct cuse_io_ctx *ctx; cuse_nvme_submit_io_write() local
501 struct cuse_io_ctx *ctx = (struct cuse_io_ctx *)ref; cuse_nvme_submit_io_read_done() local
525 struct cuse_io_ctx *ctx = arg; cuse_nvme_submit_io_read_cb() local
548 struct cuse_io_ctx *ctx; cuse_nvme_submit_io_read() local
[all...] |
| /spdk/lib/init/ |
| H A D | json_config.c | 105 app_json_config_load_done(struct load_json_config_ctx *ctx, int rc) in app_json_config_load_done() argument
107 spdk_poller_unregister(&ctx->client_conn_poller); in app_json_config_load_done()
108 if (ctx->client_conn != NULL) { in app_json_config_load_done()
109 spdk_jsonrpc_client_close(ctx->client_conn); in app_json_config_load_done()
112 spdk_rpc_server_finish(ctx->rpc_socket_path_temp); in app_json_config_load_done()
115 ctx->cb_fn(rc, ctx->cb_arg); in app_json_config_load_done()
117 free(ctx->json_data); in app_json_config_load_done()
118 free(ctx->values); in app_json_config_load_done()
119 free(ctx); in app_json_config_load_done()
123 rpc_client_set_timeout(struct load_json_config_ctx * ctx,uint64_t timeout_us) rpc_client_set_timeout() argument
129 rpc_client_check_timeout(struct load_json_config_ctx * ctx) rpc_client_check_timeout() argument
161 struct load_json_config_ctx *ctx = arg; rpc_client_poller() local
222 struct load_json_config_ctx *ctx = _ctx; rpc_client_connect_poller() local
244 client_send_request(struct load_json_config_ctx * ctx,struct spdk_jsonrpc_client_request * request,client_resp_handler client_resp_cb) client_send_request() argument
315 app_json_config_load_subsystem_config_entry_next(struct load_json_config_ctx * ctx,struct spdk_jsonrpc_client_response * resp) app_json_config_load_subsystem_config_entry_next() argument
329 struct load_json_config_ctx *ctx = _ctx; app_json_config_load_subsystem_config_entry() local
449 struct load_json_config_ctx *ctx = arg1; subsystem_init_done() local
496 struct load_json_config_ctx *ctx = _ctx; app_json_config_load_subsystem() local
529 parse_json(void * json,ssize_t json_size,struct load_json_config_ctx * ctx) parse_json() argument
578 struct load_json_config_ctx *ctx = calloc(1, sizeof(*ctx)); json_config_prepare_ctx() local
[all...] |
| /spdk/test/external_code/accel/ |
| H A D | app_module.c | 29 test_ctx_fail(struct test_ctx *ctx) in test_ctx_fail() argument
31 ctx->status = 1; in test_ctx_fail()
32 ctx->state = TEST_STATE_DONE; in test_ctx_fail()
40 struct test_ctx *ctx = arg; in fill_cb() local
45 test_ctx_fail(ctx); in fill_cb()
50 if (memcmp(ctx->buf1, expected, TEST_XFER_SIZE) != 0) { in fill_cb()
52 test_ctx_fail(ctx); in fill_cb()
56 ctx->state = TEST_STATE_COPY; in fill_cb()
58 process_accel(ctx); in fill_cb()
64 struct test_ctx *ctx = arg; in copy_cb() local
[all …]
|
| H A D | app_driver.c | 30 struct test_ctx *ctx = _ctx; in test_seq_complete_cb() local
46 if (memcmp(ctx->buf1, expected_buf1, TEST_XFER_SIZE) != 0 || in test_seq_complete_cb()
47 memcmp(ctx->buf2, expected_buf2, TEST_XFER_SIZE) != 0 || in test_seq_complete_cb()
48 memcmp(ctx->buf1_bck, expected_buf1_bck, TEST_XFER_SIZE != 0) || in test_seq_complete_cb()
49 memcmp(ctx->buf2_bck, expected_buf2_bck, TEST_XFER_SIZE != 0)) { in test_seq_complete_cb()
54 spdk_put_io_channel(ctx->ch); in test_seq_complete_cb()
62 struct test_ctx *ctx = _ctx; in start_driver() local
65 ctx->ch = spdk_accel_get_io_channel(); in start_driver()
66 if (ctx->ch == NULL) { in start_driver()
73 memset(ctx->buf1, INITIAL_PATTERN_1, TEST_XFER_SIZE); in start_driver()
[all …]
|
| /spdk/module/blobfs/bdev/ |
| H A D | blobfs_bdev.c | 56 struct blobfs_bdev_operation_ctx *ctx = _ctx; in _blobfs_bdev_unload_cb() local
59 SPDK_ERRLOG("Failed to unload blobfs on bdev %s: errno %d\n", ctx->bdev_name, fserrno); in _blobfs_bdev_unload_cb()
62 if (ctx->cb_fn) { in _blobfs_bdev_unload_cb()
63 ctx->cb_fn(ctx->cb_arg, fserrno); in _blobfs_bdev_unload_cb()
66 free(ctx); in _blobfs_bdev_unload_cb()
72 struct blobfs_bdev_operation_ctx *ctx = _ctx; in blobfs_bdev_unload() local
74 spdk_fs_unload(ctx->fs, _blobfs_bdev_unload_cb, ctx); in blobfs_bdev_unload()
80 struct blobfs_bdev_operation_ctx *ctx = _ctx; in blobfs_bdev_load_cb_to_unload() local
83 ctx->cb_fn(ctx->cb_arg, fserrno); in blobfs_bdev_load_cb_to_unload()
84 free(ctx); in blobfs_bdev_load_cb_to_unload()
[all …]
|
| /spdk/lib/nvmf/ |
| H A D | nvmf_rpc.c | 656 nvmf_rpc_listener_ctx_free(struct nvmf_rpc_listener_ctx *ctx)
658 free(ctx->nqn);
659 free(ctx->tgt_name);
660 free_rpc_listen_address(&ctx->address);
661 free(ctx->ana_state_str);
662 free(ctx);
669 struct nvmf_rpc_listener_ctx *ctx = cb_arg;
672 request = ctx->request;
673 if (ctx->response_sent) {
675 nvmf_rpc_listener_ctx_free(ctx);
682 nvmf_rpc_listener_ctx_free(struct nvmf_rpc_listener_ctx * ctx) nvmf_rpc_listener_ctx_free() argument
695 struct nvmf_rpc_listener_ctx *ctx = cb_arg; nvmf_rpc_listen_resumed() local
713 struct nvmf_rpc_listener_ctx *ctx = cb_arg; nvmf_rpc_subsystem_listen() local
737 struct nvmf_rpc_listener_ctx *ctx = cb_arg; nvmf_rpc_stop_listen_async_done() local
759 struct nvmf_rpc_listener_ctx *ctx = cb_arg; nvmf_rpc_set_ana_state_done() local
782 struct nvmf_rpc_listener_ctx *ctx = cb_arg; nvmf_rpc_listen_paused() local
891 struct nvmf_rpc_listener_ctx *ctx; rpc_nvmf_subsystem_add_listener() local
983 struct nvmf_rpc_listener_ctx *ctx; rpc_nvmf_subsystem_remove_listener() local
1073 nvmf_rpc_referral_ctx_free(struct nvmf_rpc_referral_ctx * ctx) nvmf_rpc_referral_ctx_free() argument
1084 struct nvmf_rpc_referral_ctx ctx = {}; rpc_nvmf_add_referral() local
1159 struct nvmf_rpc_referral_ctx ctx = {}; rpc_nvmf_remove_referral() local
1244 free_rpc_get_referrals_ctx(struct rpc_get_referrals_ctx * ctx) free_rpc_get_referrals_ctx() argument
1254 struct rpc_get_referrals_ctx *ctx; rpc_nvmf_get_referrals() local
1336 struct nvmf_rpc_listener_ctx *ctx; rpc_nvmf_subsystem_listener_set_ana_state() local
1456 nvmf_rpc_ns_ctx_free(struct nvmf_rpc_ns_ctx * ctx) nvmf_rpc_ns_ctx_free() argument
1469 struct nvmf_rpc_ns_ctx *ctx = cb_arg; nvmf_rpc_ns_failback_resumed() local
1487 struct nvmf_rpc_ns_ctx *ctx = cb_arg; nvmf_rpc_ns_resumed() local
1529 struct nvmf_rpc_ns_ctx *ctx = cb_arg; nvmf_rpc_ns_paused() local
1571 struct nvmf_rpc_ns_ctx *ctx; rpc_nvmf_subsystem_add_ns() local
1640 nvmf_rpc_remove_ns_ctx_free(struct nvmf_rpc_remove_ns_ctx * ctx) nvmf_rpc_remove_ns_ctx_free() argument
1651 struct nvmf_rpc_remove_ns_ctx *ctx = cb_arg; nvmf_rpc_remove_ns_resumed() local
1668 struct nvmf_rpc_remove_ns_ctx *ctx = cb_arg; nvmf_rpc_remove_ns_paused() local
1691 struct nvmf_rpc_remove_ns_ctx *ctx; rpc_nvmf_subsystem_remove_ns() local
1762 nvmf_rpc_ns_visible_ctx_free(struct nvmf_rpc_ns_visible_ctx * ctx) nvmf_rpc_ns_visible_ctx_free() argument
1774 struct nvmf_rpc_ns_visible_ctx *ctx = cb_arg; nvmf_rpc_ns_visible_resumed() local
1789 struct nvmf_rpc_ns_visible_ctx *ctx = cb_arg; nvmf_rpc_ns_visible_paused() local
1817 struct nvmf_rpc_ns_visible_ctx *ctx; nvmf_rpc_ns_visible() local
1903 nvmf_rpc_host_ctx_free(struct nvmf_rpc_host_ctx * ctx) nvmf_rpc_host_ctx_free() argument
1916 struct nvmf_rpc_host_ctx ctx = {}; rpc_nvmf_subsystem_add_host() local
1988 struct nvmf_rpc_host_ctx *ctx = _ctx; rpc_nvmf_subsystem_remove_host_done() local
1999 struct nvmf_rpc_host_ctx *ctx; rpc_nvmf_subsystem_remove_host() local
2074 struct nvmf_rpc_host_ctx ctx = {}; rpc_nvmf_subsystem_allow_any_host() local
2185 struct nvmf_rpc_target_ctx ctx = {0}; rpc_nvmf_create_target() local
2230 nvmf_rpc_destroy_target_done(void * ctx,int status) nvmf_rpc_destroy_target_done() argument
2241 struct nvmf_rpc_target_ctx ctx = {0}; rpc_nvmf_delete_target() local
2398 nvmf_rpc_create_transport_ctx_free(struct nvmf_rpc_create_transport_ctx * ctx) nvmf_rpc_create_transport_ctx_free() argument
2408 struct nvmf_rpc_create_transport_ctx *ctx = cb_arg; nvmf_rpc_transport_destroy_done_cb() local
2418 struct nvmf_rpc_create_transport_ctx *ctx = cb_arg; nvmf_rpc_tgt_add_transport_done() local
2434 struct nvmf_rpc_create_transport_ctx *ctx = cb_arg; nvmf_rpc_create_transport_done() local
2454 struct nvmf_rpc_create_transport_ctx *ctx; rpc_nvmf_create_transport() local
2608 free_get_stats_ctx(struct rpc_nvmf_get_stats_ctx * ctx) free_get_stats_ctx() argument
2617 struct rpc_nvmf_get_stats_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_nvmf_get_stats_done() local
2628 struct rpc_nvmf_get_stats_ctx *ctx = spdk_io_channel_iter_get_ctx(i); _rpc_nvmf_get_stats() local
2646 struct rpc_nvmf_get_stats_ctx *ctx; rpc_nvmf_get_stats() local
2817 free_rpc_subsystem_query_ctx(struct rpc_subsystem_query_ctx * ctx) free_rpc_subsystem_query_ctx() argument
2828 struct rpc_subsystem_query_ctx *ctx = cb_arg; rpc_nvmf_get_controllers_paused() local
2853 struct rpc_subsystem_query_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_nvmf_get_qpairs_done() local
2869 struct rpc_subsystem_query_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_nvmf_get_qpairs() local
2890 struct rpc_subsystem_query_ctx *ctx = cb_arg; rpc_nvmf_get_qpairs_paused() local
2906 struct rpc_subsystem_query_ctx *ctx = cb_arg; rpc_nvmf_get_listeners_paused() local
2936 struct rpc_subsystem_query_ctx *ctx; _rpc_nvmf_subsystem_query() local
[all...] |
| /spdk/lib/util/ |
| H A D | dif.c | 294 uint32_t len, const struct spdk_dif_ctx *ctx) in _dif_generate_guard()
301 end = start + spdk_min(len, ctx->guard_interval - start);
307 if (ctx->dif_flags & SPDK_DIF_FLAGS_GUARD_CHECK) { in _dif_generate_guard_copy()
308 guard = _dif_generate_guard(guard, buf, buf_len, ctx->dif_pi_format); in _dif_generate_guard_copy()
519 _dif_ignore(struct spdk_dif *dif, const struct spdk_dif_ctx *ctx) in spdk_dif_ctx_init()
521 switch (ctx->dif_type) { in spdk_dif_ctx_init()
527 if (_dif_apptag_ignore(dif, ctx->dif_pi_format)) { in spdk_dif_ctx_init()
537 if (_dif_apptag_ignore(dif, ctx->dif_pi_format) && in spdk_dif_ctx_init()
538 _dif_reftag_ignore(dif, ctx->dif_pi_format)) { in spdk_dif_ctx_init()
577 spdk_dif_ctx_init(struct spdk_dif_ctx *ctx, uint32_ in spdk_dif_ctx_set_remapped_init_ref_tag()
459 _dif_ignore(struct spdk_dif * dif,const struct spdk_dif_ctx * ctx) _dif_ignore() argument
490 spdk_dif_ctx_init(struct spdk_dif_ctx * ctx,uint32_t block_size,uint32_t md_size,bool md_interleave,bool dif_loc,enum spdk_dif_type dif_type,uint32_t dif_flags,uint32_t init_ref_tag,uint16_t apptag_mask,uint16_t app_tag,uint32_t data_offset,uint64_t guard_seed,struct spdk_dif_ctx_init_ext_opts * opts) spdk_dif_ctx_init() argument
557 spdk_dif_ctx_set_data_offset(struct spdk_dif_ctx * ctx,uint32_t data_offset) spdk_dif_ctx_set_data_offset() argument
572 spdk_dif_ctx_set_remapped_init_ref_tag(struct spdk_dif_ctx * ctx,uint32_t remapped_init_ref_tag) spdk_dif_ctx_set_remapped_init_ref_tag() argument
580 _dif_generate(void * _dif,uint64_t guard,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx) _dif_generate() argument
620 dif_generate(struct _dif_sgl * sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) dif_generate() argument
642 _dif_generate_split(struct _dif_sgl * sgl,uint32_t offset_in_block,uint32_t data_len,uint64_t guard,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx) _dif_generate_split() argument
704 dif_generate_split(struct _dif_sgl * sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) dif_generate_split() argument
720 spdk_dif_generate(struct iovec * iovs,int iovcnt,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) spdk_dif_generate() argument
757 _dif_reftag_check(struct spdk_dif * dif,const struct spdk_dif_ctx * ctx,uint64_t expected_reftag,uint32_t offset_blocks,struct spdk_dif_error * err_blk) _dif_reftag_check() argument
797 _dif_verify(void * _dif,uint64_t guard,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) _dif_verify() argument
857 dif_verify(struct _dif_sgl * sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) dif_verify() argument
886 _dif_verify_split(struct _dif_sgl * sgl,uint32_t offset_in_block,uint32_t data_len,uint64_t * _guard,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) _dif_verify_split() argument
953 dif_verify_split(struct _dif_sgl * sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) dif_verify_split() argument
976 spdk_dif_verify(struct iovec * iovs,int iovcnt,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) spdk_dif_verify() argument
1000 dif_update_crc32c(struct _dif_sgl * sgl,uint32_t num_blocks,uint32_t crc32c,const struct spdk_dif_ctx * ctx) dif_update_crc32c() argument
1018 _dif_update_crc32c_split(struct _dif_sgl * sgl,uint32_t offset_in_block,uint32_t data_len,uint32_t crc32c,const struct spdk_dif_ctx * ctx) _dif_update_crc32c_split() argument
1046 dif_update_crc32c_split(struct _dif_sgl * sgl,uint32_t num_blocks,uint32_t crc32c,const struct spdk_dif_ctx * ctx) dif_update_crc32c_split() argument
1059 spdk_dif_update_crc32c(struct iovec * iovs,int iovcnt,uint32_t num_blocks,uint32_t * _crc32c,const struct spdk_dif_ctx * ctx) spdk_dif_update_crc32c() argument
1085 dif_generate_copy(struct _dif_sgl * src_sgl,struct _dif_sgl * dst_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) dif_generate_copy() argument
1117 _dif_generate_copy_split(struct _dif_sgl * src_sgl,struct _dif_sgl * dst_sgl,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx) _dif_generate_copy_split() argument
1162 dif_generate_copy_split(struct _dif_sgl * src_sgl,struct _dif_sgl * dst_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) dif_generate_copy_split() argument
1174 spdk_dif_generate_copy(struct iovec * iovs,int iovcnt,struct iovec * bounce_iovs,int bounce_iovcnt,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) spdk_dif_generate_copy() argument
1209 dif_verify_copy(struct _dif_sgl * src_sgl,struct _dif_sgl * dst_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) dif_verify_copy() argument
1248 _dif_verify_copy_split(struct _dif_sgl * src_sgl,struct _dif_sgl * dst_sgl,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) _dif_verify_copy_split() argument
1294 dif_verify_copy_split(struct _dif_sgl * src_sgl,struct _dif_sgl * dst_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) dif_verify_copy_split() argument
1313 spdk_dif_verify_copy(struct iovec * iovs,int iovcnt,struct iovec * bounce_iovs,int bounce_iovcnt,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) spdk_dif_verify_copy() argument
1420 spdk_dif_inject_error(struct iovec * iovs,int iovcnt,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,uint32_t inject_flags,uint32_t * inject_offset) spdk_dif_inject_error() argument
1489 dix_generate(struct _dif_sgl * data_sgl,struct _dif_sgl * md_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) dix_generate() argument
1517 _dix_generate_split(struct _dif_sgl * data_sgl,struct _dif_sgl * md_sgl,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx) _dix_generate_split() argument
1555 dix_generate_split(struct _dif_sgl * data_sgl,struct _dif_sgl * md_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) dix_generate_split() argument
1566 spdk_dix_generate(struct iovec * iovs,int iovcnt,struct iovec * md_iov,uint32_t num_blocks,const struct spdk_dif_ctx * ctx) spdk_dix_generate() argument
1594 dix_verify(struct _dif_sgl * data_sgl,struct _dif_sgl * md_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) dix_verify() argument
1629 _dix_verify_split(struct _dif_sgl * data_sgl,struct _dif_sgl * md_sgl,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) _dix_verify_split() argument
1668 dix_verify_split(struct _dif_sgl * data_sgl,struct _dif_sgl * md_sgl,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) dix_verify_split() argument
1686 spdk_dix_verify(struct iovec * iovs,int iovcnt,struct iovec * md_iov,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) spdk_dix_verify() argument
1718 spdk_dix_inject_error(struct iovec * iovs,int iovcnt,struct iovec * md_iov,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,uint32_t inject_flags,uint32_t * inject_offset) spdk_dix_inject_error() argument
1800 spdk_dif_set_md_interleave_iovs(struct iovec * iovs,int iovcnt,struct iovec * buf_iovs,int buf_iovcnt,uint32_t data_offset,uint32_t data_len,uint32_t * _mapped_len,const struct spdk_dif_ctx * ctx) spdk_dif_set_md_interleave_iovs() argument
1851 _dif_sgl_setup_stream(struct _dif_sgl * sgl,uint32_t * _buf_offset,uint32_t * _buf_len,uint32_t data_offset,uint32_t data_len,const struct spdk_dif_ctx * ctx) _dif_sgl_setup_stream() argument
1887 spdk_dif_generate_stream(struct iovec * iovs,int iovcnt,uint32_t data_offset,uint32_t data_len,struct spdk_dif_ctx * ctx) spdk_dif_generate_stream() argument
1931 spdk_dif_verify_stream(struct iovec * iovs,int iovcnt,uint32_t data_offset,uint32_t data_len,struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) spdk_dif_verify_stream() argument
1980 spdk_dif_update_crc32c_stream(struct iovec * iovs,int iovcnt,uint32_t data_offset,uint32_t data_len,uint32_t * _crc32c,const struct spdk_dif_ctx * ctx) spdk_dif_update_crc32c_stream() argument
2017 spdk_dif_get_range_with_md(uint32_t data_offset,uint32_t data_len,uint32_t * _buf_offset,uint32_t * _buf_len,const struct spdk_dif_ctx * ctx) spdk_dif_get_range_with_md() argument
2044 spdk_dif_get_length_with_md(uint32_t data_len,const struct spdk_dif_ctx * ctx) spdk_dif_get_length_with_md() argument
2059 _dif_remap_ref_tag(struct _dif_sgl * sgl,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk,bool check_ref_tag) _dif_remap_ref_tag() argument
2126 spdk_dif_remap_ref_tag(struct iovec * iovs,int iovcnt,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk,bool check_ref_tag) spdk_dif_remap_ref_tag() argument
2160 _dix_remap_ref_tag(struct _dif_sgl * md_sgl,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk,bool check_ref_tag) _dix_remap_ref_tag() argument
2202 spdk_dix_remap_ref_tag(struct iovec * md_iov,uint32_t num_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk,bool check_ref_tag) spdk_dix_remap_ref_tag() argument
[all...] |
| /spdk/module/bdev/raid/ |
| H A D | bdev_raid_sb.c | 136 raid_bdev_parse_superblock(struct raid_bdev_read_sb_ctx *ctx) in raid_bdev_parse_superblock() argument
138 struct raid_bdev_superblock *sb = ctx->buf; in raid_bdev_parse_superblock()
139 struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(ctx->desc); in raid_bdev_parse_superblock()
149 spdk_divide_round_up(ctx->buf_size, bdev->blocklen)) { in raid_bdev_parse_superblock()
188 raid_bdev_read_sb_ctx_free(struct raid_bdev_read_sb_ctx *ctx) in raid_bdev_read_sb_ctx_free() argument
190 spdk_dma_free(ctx->buf); in raid_bdev_read_sb_ctx_free()
192 free(ctx); in raid_bdev_read_sb_ctx_free()
198 raid_bdev_read_sb_remainder(struct raid_bdev_read_sb_ctx *ctx) in raid_bdev_read_sb_remainder() argument
200 struct raid_bdev_superblock *sb = ctx->buf; in raid_bdev_read_sb_remainder()
201 struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(ctx->desc); in raid_bdev_read_sb_remainder()
[all …]
|
| H A D | bdev_raid_rpc.c | 198 free_rpc_bdev_raid_create_ctx(struct rpc_bdev_raid_create_ctx *ctx) in free_rpc_bdev_raid_create_ctx() argument
203 if (!ctx) { in free_rpc_bdev_raid_create_ctx()
207 req = &ctx->req; in free_rpc_bdev_raid_create_ctx()
214 free(ctx); in free_rpc_bdev_raid_create_ctx()
220 struct rpc_bdev_raid_create_ctx *ctx = _ctx; in rpc_bdev_raid_create_add_base_bdev_cb() local
223 ctx->status = status; in rpc_bdev_raid_create_add_base_bdev_cb()
226 assert(ctx->remaining != 0); in rpc_bdev_raid_create_add_base_bdev_cb()
227 if (--ctx->remaining > 0) { in rpc_bdev_raid_create_add_base_bdev_cb()
231 if (ctx->status != 0) { in rpc_bdev_raid_create_add_base_bdev_cb()
232 raid_bdev_delete(ctx in rpc_bdev_raid_create_add_base_bdev_cb()
262 struct rpc_bdev_raid_create_ctx *ctx; rpc_bdev_raid_create() local
373 struct rpc_bdev_raid_delete_ctx *ctx = cb_arg; bdev_raid_delete_done() local
405 struct rpc_bdev_raid_delete_ctx *ctx; rpc_bdev_raid_delete() local
478 rpc_bdev_raid_add_base_bdev_done(void * ctx,int status) rpc_bdev_raid_add_base_bdev_done() argument
551 rpc_bdev_raid_remove_base_bdev_done(void * ctx,int status) rpc_bdev_raid_remove_base_bdev_done() argument
[all...] |
| /spdk/module/bdev/nvme/ |
| H A D | bdev_mdns_client.c | 41 struct mdns_discovery_ctx *ctx;
64 create_mdns_discovery_entry_ctx(struct mdns_discovery_ctx *ctx, struct spdk_nvme_transport_id *trid) in create_mdns_discovery_entry_ctx()
68 assert(ctx); in create_mdns_discovery_entry_ctx()
76 new_ctx->ctx = ctx; in create_mdns_discovery_entry_ctx()
78 snprintf(new_ctx->name, sizeof(new_ctx->name), "%s%u_nvme", ctx->name, ctx->seqno); in create_mdns_discovery_entry_ctx()
79 memcpy(&new_ctx->drv_opts, &ctx->drv_opts, sizeof(ctx->drv_opts)); in create_mdns_discovery_entry_ctx()
80 snprintf(new_ctx->drv_opts.hostnqn, sizeof(ctx in create_mdns_discovery_entry_ctx()
40 struct mdns_discovery_ctx *ctx; global() member
63 create_mdns_discovery_entry_ctx(struct mdns_discovery_ctx * ctx,struct spdk_nvme_transport_id * trid) create_mdns_discovery_entry_ctx() argument
103 free_mdns_discovery_entry_ctx(struct mdns_discovery_ctx * ctx) free_mdns_discovery_entry_ctx() argument
118 free_mdns_discovery_ctx(struct mdns_discovery_ctx * ctx) free_mdns_discovery_ctx() argument
210 struct mdns_discovery_ctx *ctx = NULL, *tmp_ctx = NULL; get_mdns_discovery_ctx_by_svcname() local
248 struct mdns_discovery_ctx *ctx = NULL; mdns_resolve_handler() local
420 struct mdns_discovery_ctx *ctx = arg; bdev_nvme_avahi_iterate() local
448 struct mdns_discovery_ctx *ctx = arg; start_mdns_discovery_poller() local
463 struct mdns_discovery_ctx *ctx; bdev_nvme_start_mdns_discovery() local
549 mdns_stop_discovery_entry(struct mdns_discovery_ctx * ctx) mdns_stop_discovery_entry() argument
563 struct mdns_discovery_ctx *ctx; bdev_nvme_stop_mdns_discovery() local
584 struct mdns_discovery_ctx *ctx; bdev_nvme_get_mdns_discovery_info() local
615 struct mdns_discovery_ctx *ctx; bdev_nvme_mdns_discovery_config_json() local
[all...] |
| H A D | bdev_nvme_rpc.c | 187 rpc_bdev_nvme_set_hotplug_done(void *ctx) in rpc_bdev_nvme_set_hotplug_done()
189 struct spdk_jsonrpc_request *request = ctx; in rpc_bdev_nvme_set_hotplug_done()
354 free_rpc_bdev_nvme_attach_controller_ctx(struct rpc_bdev_nvme_attach_controller_ctx *ctx) in free_rpc_bdev_nvme_attach_controller_ctx()
356 free_rpc_bdev_nvme_attach_controller(&ctx->req); in free_rpc_bdev_nvme_attach_controller_ctx()
357 free(ctx->names); in free_rpc_bdev_nvme_attach_controller_ctx()
358 free(ctx); in free_rpc_bdev_nvme_attach_controller_ctx()
364 struct rpc_bdev_nvme_attach_controller_ctx *ctx = cb_ctx; in rpc_bdev_nvme_attach_controller_examined()
365 struct spdk_jsonrpc_request *request = ctx->request; in rpc_bdev_nvme_attach_controller_examined()
371 for (i = 0; i < ctx->bdev_count; i++) { in rpc_bdev_nvme_attach_controller_examined()
372 spdk_json_write_string(w, ctx in rpc_bdev_nvme_attach_controller_examined()
186 rpc_bdev_nvme_set_hotplug_done(void * ctx) rpc_bdev_nvme_set_hotplug_done() argument
353 free_rpc_bdev_nvme_attach_controller_ctx(struct rpc_bdev_nvme_attach_controller_ctx * ctx) free_rpc_bdev_nvme_attach_controller_ctx() argument
363 struct rpc_bdev_nvme_attach_controller_ctx *ctx = cb_ctx; rpc_bdev_nvme_attach_controller_examined() local
382 struct rpc_bdev_nvme_attach_controller_ctx *ctx = cb_ctx; rpc_bdev_nvme_attach_controller_done() local
399 struct rpc_bdev_nvme_attach_controller_ctx *ctx; rpc_bdev_nvme_attach_controller() local
642 rpc_dump_nvme_bdev_controller_info(struct nvme_bdev_ctrlr * nbdev_ctrlr,void * ctx) rpc_dump_nvme_bdev_controller_info() argument
934 _apply_firmware_complete_reset(void * ctx) _apply_firmware_complete_reset() argument
976 _apply_firmware_complete(void * ctx) _apply_firmware_complete() argument
1228 struct rpc_bdev_nvme_transport_stat_ctx *ctx; rpc_bdev_nvme_stats_per_channel() local
1283 struct rpc_bdev_nvme_transport_stat_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_bdev_nvme_stats_done() local
1295 struct rpc_bdev_nvme_transport_stat_ctx *ctx; rpc_bdev_nvme_get_transport_statistics() local
1675 rpc_bdev_nvme_start_discovery_done(void * ctx,int status) rpc_bdev_nvme_start_discovery_done() argument
1690 struct rpc_bdev_nvme_start_discovery_ctx *ctx; rpc_bdev_nvme_start_discovery() local
1803 struct rpc_bdev_nvme_stop_discovery_ctx *ctx = cb_ctx; rpc_bdev_nvme_stop_discovery_done() local
1814 struct rpc_bdev_nvme_stop_discovery_ctx *ctx; rpc_bdev_nvme_stop_discovery() local
1919 struct rpc_add_error_injection_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_add_error_injection_done() local
1936 struct rpc_add_error_injection_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_add_error_injection_per_channel() local
1956 struct rpc_add_error_injection_ctx *ctx; rpc_bdev_nvme_add_error_injection() local
2036 struct rpc_remove_error_injection_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_remove_error_injection_done() local
2053 struct rpc_remove_error_injection_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_remove_error_injection_per_channel() local
2069 struct rpc_remove_error_injection_ctx *ctx; rpc_bdev_nvme_remove_error_injection() local
2136 struct rpc_get_io_paths_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_bdev_nvme_get_io_paths_done() local
2153 struct rpc_get_io_paths_ctx *ctx = spdk_io_channel_iter_get_ctx(i); _rpc_bdev_nvme_get_io_paths() local
2188 struct rpc_get_io_paths_ctx *ctx; rpc_bdev_nvme_get_io_paths() local
2246 struct rpc_bdev_nvme_set_preferred_path_ctx *ctx = cb_arg; rpc_bdev_nvme_set_preferred_path_done() local
2262 struct rpc_bdev_nvme_set_preferred_path_ctx *ctx; rpc_bdev_nvme_set_preferred_path() local
2354 struct rpc_set_multipath_policy_ctx *ctx = cb_arg; rpc_bdev_nvme_set_multipath_policy_done() local
2370 struct rpc_set_multipath_policy_ctx *ctx; rpc_bdev_nvme_set_multipath_policy() local
2449 struct rpc_bdev_nvme_start_mdns_discovery_ctx *ctx; rpc_bdev_nvme_start_mdns_discovery() local
2506 struct rpc_bdev_nvme_stop_mdns_discovery_ctx *ctx; rpc_bdev_nvme_stop_mdns_discovery() local
2578 dummy_bdev_event_cb(enum spdk_bdev_event_type type,struct spdk_bdev * bdev,void * ctx) dummy_bdev_event_cb() argument
2585 struct rpc_bdev_nvme_path_stat_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_bdev_nvme_path_stat_per_channel() local
2611 struct rpc_bdev_nvme_path_stat_ctx *ctx = spdk_io_channel_iter_get_ctx(i); rpc_bdev_nvme_path_stat_done() local
2658 struct rpc_bdev_nvme_path_stat_ctx *ctx; rpc_bdev_nvme_get_path_iostat() local
[all...] |
| H A D | nvme_rpc.c | 49 free_rpc_bdev_nvme_send_cmd_ctx(struct rpc_bdev_nvme_send_cmd_ctx *ctx) in free_rpc_bdev_nvme_send_cmd_ctx() argument
51 assert(ctx != NULL); in free_rpc_bdev_nvme_send_cmd_ctx()
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()
57 free(ctx->resp.cpl_text); in free_rpc_bdev_nvme_send_cmd_ctx()
58 free(ctx->resp.data_text); in free_rpc_bdev_nvme_send_cmd_ctx()
59 free(ctx->resp.md_text); in free_rpc_bdev_nvme_send_cmd_ctx()
60 free(ctx); in free_rpc_bdev_nvme_send_cmd_ctx()
[all …]
|
| /spdk/lib/ftl/upgrade/ |
| H A D | ftl_layout_upgrade.c | 139 region_verify(struct spdk_ftl_dev *dev, struct ftl_layout_upgrade_ctx *ctx) in region_verify()
143 assert(ctx->reg); in region_verify()
144 ver = ctx->reg->current.version; in region_verify()
145 if (ver > ctx->upgrade->latest_ver) { in region_verify()
150 while (ver < ctx->upgrade->latest_ver) { in region_verify()
151 int rc = ctx->upgrade->desc[ver].verify(dev, ctx->reg); in region_verify()
155 ftl_bug(ver > ctx->upgrade->desc[ver].new_version); in region_verify()
156 ftl_bug(ctx->upgrade->desc[ver].new_version > ctx in region_verify()
138 region_verify(struct spdk_ftl_dev * dev,struct ftl_layout_upgrade_ctx * ctx) region_verify() argument
162 ftl_region_upgrade(struct spdk_ftl_dev * dev,struct ftl_layout_upgrade_ctx * ctx) ftl_region_upgrade() argument
178 ftl_region_upgrade_completed(struct spdk_ftl_dev * dev,struct ftl_layout_upgrade_ctx * ctx,uint64_t entry_size,uint64_t num_entries,int status) ftl_region_upgrade_completed() argument
211 struct ftl_layout_upgrade_ctx ctx = {0}; ftl_layout_verify() local
254 struct ftl_layout_upgrade_ctx ctx = {0}; ftl_superblock_upgrade() local
282 layout_upgrade_select_next_region(struct spdk_ftl_dev * dev,struct ftl_layout_upgrade_ctx * ctx) layout_upgrade_select_next_region() argument
319 ftl_layout_upgrade_init_ctx(struct spdk_ftl_dev * dev,struct ftl_layout_upgrade_ctx * ctx) ftl_layout_upgrade_init_ctx() argument
[all...] |
| H A D | ftl_chunk_upgrade.c | 19 struct upgrade_ctx *ctx = lctx->ctx; in v1_to_v2_upgrade_cleanup() local
21 if (ctx->md_v2) { in v1_to_v2_upgrade_cleanup()
22 ftl_md_destroy(ctx->md_v2, 0); in v1_to_v2_upgrade_cleanup()
23 ctx->md_v2 = NULL; in v1_to_v2_upgrade_cleanup()
30 struct upgrade_ctx *ctx = lctx->ctx; in v1_to_v2_upgrade_finish() local
33 ftl_region_upgrade_completed(dev, lctx, ctx->reg_v2.entry_size, ctx->reg_v2.num_entries, status); in v1_to_v2_upgrade_finish()
39 struct upgrade_ctx *ctx = lctx->ctx; in v1_to_v2_upgrade_set() local
40 struct ftl_nv_cache_chunk_md *md = ftl_md_get_buffer(ctx->md_v2); in v1_to_v2_upgrade_set()
43 for (uint64_t i = 0; i < ctx->reg_v2.current.blocks; i++, md++) { in v1_to_v2_upgrade_set()
60 struct upgrade_ctx *ctx = lctx->ctx; in v1_to_v2_upgrade_setup_ctx() local
[all …]
|
| H A D | ftl_trim_upgrade.c | 19 struct upgrade_ctx *ctx = lctx->ctx; in v0_to_v1_upgrade_cleanup() local
21 if (ctx->md) { in v0_to_v1_upgrade_cleanup()
22 ftl_md_destroy(ctx->md, 0); in v0_to_v1_upgrade_cleanup()
23 ctx->md = NULL; in v0_to_v1_upgrade_cleanup()
30 struct upgrade_ctx *ctx = lctx->ctx; in v0_to_v1_upgrade_finish() local
33 ftl_region_upgrade_completed(dev, lctx, ctx->reg.entry_size, ctx->reg.num_entries, status); in v0_to_v1_upgrade_finish()
48 struct upgrade_ctx *ctx = lctx->ctx; in v0_to_v1_upgrade_setup_ctx() local
53 &ctx->reg)) { in v0_to_v1_upgrade_setup_ctx()
56 ctx->md = ftl_md_create(dev, ctx->reg.current.blocks, 0, ctx->reg.name, FTL_MD_CREATE_HEAP, in v0_to_v1_upgrade_setup_ctx()
57 &ctx->reg); in v0_to_v1_upgrade_setup_ctx()
[all …]
|
| H A D | ftl_band_upgrade.c | 18 struct upgrade_ctx *ctx = lctx->ctx; in v2_upgrade_cleanup() local
20 if (ctx->md) { in v2_upgrade_cleanup()
21 ftl_md_destroy(ctx->md, 0); in v2_upgrade_cleanup()
22 ctx->md = NULL; in v2_upgrade_cleanup()
29 struct upgrade_ctx *ctx = lctx->ctx; in v2_upgrade_finish() local
32 ftl_region_upgrade_completed(dev, lctx, ctx->reg.entry_size, ctx->reg.num_entries, status); in v2_upgrade_finish()
47 struct upgrade_ctx *ctx = lctx->ctx; in v2_upgrade_md_restore_cb() local
71 ctx->md->cb = v2_upgrade_md_persist_cb; in v2_upgrade_md_restore_cb()
72 ftl_md_set_region(ctx->md, &ctx->reg); in v2_upgrade_md_restore_cb()
73 ftl_md_persist(ctx->md); in v2_upgrade_md_restore_cb()
[all …]
|
| H A D | ftl_p2l_upgrade.c | 18 struct upgrade_ctx *ctx = lctx->ctx; in v2_upgrade_cleanup() local
20 if (ctx->md) { in v2_upgrade_cleanup()
21 ftl_md_destroy(ctx->md, 0); in v2_upgrade_cleanup()
22 ctx->md = NULL; in v2_upgrade_cleanup()
29 struct upgrade_ctx *ctx = lctx->ctx; in v2_upgrade_finish() local
32 ftl_region_upgrade_completed(dev, lctx, ctx->reg.entry_size, ctx->reg.num_entries, status); in v2_upgrade_finish()
46 struct upgrade_ctx *ctx = lctx->ctx; in v2_upgrade_setup_ctx() local
54 dev->layout.p2l.ckpt_pages, &ctx->reg)) { in v2_upgrade_setup_ctx()
58 ctx->md = ftl_md_create(dev, ctx->reg.current.blocks, 0, ctx->reg.name, FTL_MD_CREATE_HEAP, in v2_upgrade_setup_ctx()
59 &ctx->reg); in v2_upgrade_setup_ctx()
[all …]
|
| /spdk/lib/event/ |
| H A D | app_rpc.c | 137 struct rpc_get_stats_ctx *ctx = arg; in rpc_thread_get_stats_done() local
139 spdk_json_write_array_end(ctx->w); in rpc_thread_get_stats_done()
140 spdk_json_write_object_end(ctx->w); in rpc_thread_get_stats_done()
141 spdk_jsonrpc_end_result(ctx->request, ctx->w); in rpc_thread_get_stats_done()
143 free(ctx); in rpc_thread_get_stats_done()
149 struct rpc_get_stats_ctx *ctx; in rpc_thread_get_stats_for_each() local
151 ctx = calloc(1, sizeof(*ctx)); in rpc_thread_get_stats_for_each()
152 if (!ctx) { in rpc_thread_get_stats_for_each()
170 struct rpc_get_stats_ctx *ctx = arg; _rpc_thread_get_stats() local
249 struct rpc_get_stats_ctx *ctx = arg; _rpc_thread_get_pollers() local
308 struct rpc_get_stats_ctx *ctx = arg; _rpc_thread_get_io_channels() local
343 struct rpc_get_stats_ctx *ctx = arg1; rpc_framework_get_reactors_done() local
357 struct rpc_get_stats_ctx *ctx = arg1; _rpc_framework_get_reactors() local
416 struct rpc_get_stats_ctx *ctx; rpc_framework_get_reactors() local
623 struct rpc_thread_set_cpumask_ctx *ctx = _ctx; rpc_thread_set_cpumask_done() local
638 struct rpc_thread_set_cpumask_ctx *ctx = _ctx; _rpc_thread_set_cpumask() local
660 struct rpc_thread_set_cpumask_ctx *ctx; rpc_thread_set_cpumask() local
[all...] |
| /spdk/lib/ftl/mngt/ |
| H A D | ftl_mngt_upgrade.c | 21 struct ftl_mngt_upgrade_ctx *ctx = _ctx; in region_upgrade_cb() local
23 free(ctx->upgrade_ctx.ctx); in region_upgrade_cb()
24 ctx->upgrade_ctx.ctx = NULL; in region_upgrade_cb()
27 FTL_ERRLOG(dev, "Upgrade failed for region %d (rc=%d)\n", ctx->upgrade_ctx.reg->type, status); in region_upgrade_cb()
28 ftl_mngt_fail_step(ctx->mngt); in region_upgrade_cb()
31 ftl_mngt_next_step(ctx->mngt); in region_upgrade_cb()
38 struct ftl_mngt_upgrade_ctx *ctx = ftl_mngt_get_caller_ctx(mngt); in region_upgrade() local
39 struct ftl_layout_upgrade_ctx *upgrade_ctx = &ctx->upgrade_ctx; in region_upgrade()
43 assert(upgrade_ctx->ctx == NULL); in region_upgrade()
45 upgrade_ctx->ctx = calloc(1, ctx_size); in region_upgrade()
[all …]
|
| H A D | ftl_mngt_p2l.c | 20 static void ftl_p2l_wipe_md_region(struct spdk_ftl_dev *dev, struct ftl_mngt_p2l_md_ctx *ctx); in ftl_mngt_p2l_init_ckpt()
42 struct ftl_mngt_p2l_md_ctx *ctx = md->owner.cb_ctx; in ftl_p2l_wipe_md_region_cb()
45 ftl_mngt_fail_step(ctx->mngt); in ftl_p2l_wipe_md_region_cb()
49 if (ctx->md_region == ctx->md_region_max) { in ftl_p2l_wipe_md_region_cb()
50 ftl_mngt_next_step(ctx->mngt); in ftl_p2l_wipe_md_region_cb()
54 ctx->md_region++;
55 ftl_p2l_wipe_md_region(dev, ctx);
59 ftl_p2l_wipe_md_region(struct spdk_ftl_dev *dev, struct ftl_mngt_p2l_md_ctx *ctx) in ftl_p2l_wipe_md_region()
62 struct ftl_md *md = layout->md[ctx in ftl_p2l_wipe_md_region()
39 struct ftl_mngt_p2l_md_ctx *ctx = md->owner.cb_ctx; ftl_p2l_wipe_md_region_cb() local
56 ftl_p2l_wipe_md_region(struct spdk_ftl_dev * dev,struct ftl_mngt_p2l_md_ctx * ctx) ftl_p2l_wipe_md_region() argument
77 struct ftl_mngt_p2l_md_ctx *ctx; ftl_mngt_p2l_wipe() local
108 struct ftl_mngt_p2l_md_ctx *ctx = md->owner.cb_ctx; ftl_mngt_p2l_restore_ckpt_cb() local
128 struct ftl_mngt_p2l_md_ctx *ctx; ftl_mngt_p2l_restore_ckpt() local
[all...] |
| /spdk/lib/ftl/ |
| H A D | ftl_debug.c | 39 ftl_band_validate_md_pin(struct ftl_band_validate_ctx *ctx) in ftl_band_validate_md_pin() argument
41 struct ftl_band *band = ctx->band; in ftl_band_validate_md_pin()
46 .cb_ctx = ctx in ftl_band_validate_md_pin()
52 ctx->remaining = 1; in ftl_band_validate_md_pin()
54 ftl_get_num_blocks_in_band(dev) - ctx->current_offset); in ftl_band_validate_md_pin()
56 for (i = ctx->current_offset; i < ctx->current_offset + size; ++i) { in ftl_band_validate_md_pin()
58 ctx->l2p_pin_ctx[i].lba = FTL_LBA_INVALID; in ftl_band_validate_md_pin()
63 ctx->remaining++; in ftl_band_validate_md_pin()
64 ctx->pin_cnt++; in ftl_band_validate_md_pin()
65 ftl_l2p_pin(dev, p2l_map->band_map[i].lba, 1, ftl_band_validate_md_l2p_pin_cb, ctx, in ftl_band_validate_md_pin()
[all …]
|
| H A D | ftl_init.c | 63 exit_thread(void *ctx) in exit_thread() argument
65 struct spdk_thread *thread = ctx; in exit_thread()
140 struct ftl_dev_init_ctx *ctx = _ctx; in dev_init_cb() local
146 rc = spdk_ftl_dev_init(&dev->conf, ctx->cb_fn, ctx->cb_arg); in dev_init_cb()
149 free(ctx); in dev_init_cb()
158 ctx->cb_fn(dev, ctx->cb_arg, status); in dev_init_cb()
159 free(ctx); in dev_init_cb()
166 struct ftl_dev_init_ctx *ctx; in spdk_ftl_dev_init() local
169 ctx = calloc(1, sizeof(*ctx)); in spdk_ftl_dev_init()
170 if (!ctx) { in spdk_ftl_dev_init()
[all …]
|
| /spdk/module/blob/bdev/ |
| H A D | blob_bdev.c | 76 struct blob_resubmit *ctx; in bdev_blob_queue_io() local
78 ctx = calloc(1, sizeof(struct blob_resubmit)); in bdev_blob_queue_io()
80 if (ctx == NULL) { in bdev_blob_queue_io()
86 ctx->io_type = io_type; in bdev_blob_queue_io()
87 ctx->dev = dev; in bdev_blob_queue_io()
88 ctx->channel = channel; in bdev_blob_queue_io()
89 ctx->payload = payload; in bdev_blob_queue_io()
90 ctx->iovcnt = iovcnt; in bdev_blob_queue_io()
91 ctx->lba = lba; in bdev_blob_queue_io()
92 ctx in bdev_blob_queue_io()
287 struct blob_resubmit *ctx = (struct blob_resubmit *) arg; bdev_blob_resubmit() local
[all...] |
| /spdk/module/bdev/aio/ |
| H A D | bdev_aio_rpc.c | 27 free_rpc_construct_aio(struct rpc_construct_aio_ctx *ctx) in free_rpc_construct_aio()
29 free(ctx->req.name); in free_rpc_construct_aio()
30 free(ctx->req.filename); in free_rpc_construct_aio()
31 free(ctx); in free_rpc_construct_aio()
46 struct rpc_construct_aio_ctx *ctx = cb_arg; in rpc_bdev_aio_create_cb()
47 struct spdk_jsonrpc_request *request = ctx->request; in rpc_bdev_aio_create_cb()
51 spdk_json_write_string(w, ctx->req.name); in rpc_bdev_aio_create_cb()
53 free_rpc_construct_aio(ctx);
60 struct rpc_construct_aio_ctx *ctx; in rpc_bdev_aio_create()
63 ctx in rpc_bdev_aio_create()
26 free_rpc_construct_aio(struct rpc_construct_aio_ctx * ctx) free_rpc_construct_aio() argument
44 struct rpc_construct_aio_ctx *ctx = cb_arg; rpc_bdev_aio_create_cb() local
58 struct rpc_construct_aio_ctx *ctx; rpc_bdev_aio_create() local
[all...] |