Home
last modified time | relevance | path

Searched refs:request (Results 1 – 25 of 117) sorted by relevance

12345

/spdk/lib/jsonrpc/
H A Djsonrpc_server.c85 parse_single_request(struct spdk_jsonrpc_request *request, struct spdk_json_val *values) in parse_single_request() argument
109 request->id = req.id; in parse_single_request()
126 jsonrpc_server_handle_request(request, req.method, params); in parse_single_request()
130 jsonrpc_server_handle_error(request, SPDK_JSONRPC_ERROR_INVALID_REQUEST); in parse_single_request()
136 struct spdk_jsonrpc_request *request = cb_ctx; in jsonrpc_server_write_cb() local
137 size_t new_size = request->send_buf_size; in jsonrpc_server_write_cb()
139 while (new_size - request->send_len < size) { in jsonrpc_server_write_cb()
149 if (new_size != request->send_buf_size) { in jsonrpc_server_write_cb()
153 new_buf = realloc(request->send_buf, new_size + 1); in jsonrpc_server_write_cb()
156 request->send_buf_size, new_size); in jsonrpc_server_write_cb()
[all …]
H A Djsonrpc_server_tcp.c70 struct spdk_jsonrpc_request *request = NULL; in jsonrpc_server_dequeue_request() local
73 request = STAILQ_FIRST(&conn->send_queue); in jsonrpc_server_dequeue_request()
74 if (request) { in jsonrpc_server_dequeue_request()
78 return request; in jsonrpc_server_dequeue_request()
84 struct spdk_jsonrpc_request *request; in jsonrpc_server_free_conn_request() local
92 STAILQ_FOREACH(request, &conn->outstanding_queue, link) { in jsonrpc_server_free_conn_request()
93 request->conn = NULL; in jsonrpc_server_free_conn_request()
97 while ((request = jsonrpc_server_dequeue_request(conn)) != NULL) { in jsonrpc_server_free_conn_request()
98 jsonrpc_free_request(request); in jsonrpc_server_free_conn_request()
229 jsonrpc_server_handle_request(struct spdk_jsonrpc_request *request, in jsonrpc_server_handle_request() argument
[all …]
/spdk/lib/event/
H A Dlog_rpc.c74 rpc_log_set_print_level(struct spdk_jsonrpc_request *request, in rpc_log_set_print_level() argument
83 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_log_set_print_level()
91 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_log_set_print_level()
97 spdk_jsonrpc_send_bool_response(request, true); in rpc_log_set_print_level()
105 rpc_log_get_print_level(struct spdk_jsonrpc_request *request, in rpc_log_get_print_level() argument
113 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_log_get_print_level()
121 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_log_get_print_level()
126 w = spdk_jsonrpc_begin_result(request); in rpc_log_get_print_level()
129 spdk_jsonrpc_end_result(request, w); in rpc_log_get_print_level()
135 rpc_log_set_level(struct spdk_jsonrpc_request *request, in rpc_log_set_level() argument
166 rpc_log_get_level(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_log_get_level() argument
195 rpc_log_set_flag(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_log_set_flag() argument
229 rpc_log_clear_flag(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_log_clear_flag() argument
264 rpc_log_get_flags(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_log_get_flags() argument
298 rpc_log_enable_timestamps(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_log_enable_timestamps() argument
[all...]
H A Dapp_rpc.c37 rpc_spdk_kill_instance(struct spdk_jsonrpc_request *request, in rpc_spdk_kill_instance() argument
79 spdk_jsonrpc_send_bool_response(request, true); in rpc_spdk_kill_instance()
83 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_spdk_kill_instance()
98 rpc_framework_monitor_context_switch(struct spdk_jsonrpc_request *request, in rpc_framework_monitor_context_switch() argument
109 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_framework_monitor_context_switch()
116 w = spdk_jsonrpc_begin_result(request); in rpc_framework_monitor_context_switch()
122 spdk_jsonrpc_end_result(request, w); in rpc_framework_monitor_context_switch()
129 struct spdk_jsonrpc_request *request; member
141 spdk_jsonrpc_end_result(ctx->request, ctx->w); in rpc_thread_get_stats_done()
147 rpc_thread_get_stats_for_each(struct spdk_jsonrpc_request *request, spdk_msg_f argument
211 rpc_thread_get_stats(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_thread_get_stats() argument
282 rpc_thread_get_pollers(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_thread_get_pollers() argument
326 rpc_thread_get_io_channels(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_thread_get_io_channels() argument
413 rpc_framework_get_reactors(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_framework_get_reactors() argument
463 rpc_framework_set_scheduler(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_framework_set_scheduler() argument
524 rpc_framework_get_scheduler(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_framework_get_scheduler() argument
558 rpc_framework_get_governor(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_framework_get_governor() argument
614 struct spdk_jsonrpc_request *request; global() member
656 rpc_thread_set_cpumask(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_thread_set_cpumask() argument
[all...]
/spdk/module/bdev/ocf/
H A Dvbdev_ocf_rpc.c61 struct spdk_jsonrpc_request *request = cb_arg; in construct_cb() local
65 spdk_jsonrpc_send_error_response_fmt(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in construct_cb()
69 w = spdk_jsonrpc_begin_result(request); in construct_cb()
71 spdk_jsonrpc_end_result(request, w); in construct_cb()
76 rpc_bdev_ocf_create(struct spdk_jsonrpc_request *request, in rpc_bdev_ocf_create() argument
86 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_bdev_ocf_create()
93 req.core_bdev_name, false, construct_cb, request); in rpc_bdev_ocf_create()
101 struct spdk_jsonrpc_request *request = cb_arg; in delete_cb() local
104 spdk_jsonrpc_send_error_response_fmt(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in delete_cb()
108 spdk_jsonrpc_send_bool_response(request, true); in delete_cb()
[all …]
/spdk/module/bdev/lvol/
H A Dvbdev_lvol_rpc.c92 struct spdk_jsonrpc_request *request = cb_arg; in rpc_lvol_store_construct_cb()
98 w = spdk_jsonrpc_begin_result(request); in rpc_lvol_store_construct_cb()
100 spdk_jsonrpc_end_result(request, w); in rpc_lvol_store_construct_cb()
104 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_lvol_store_construct_cb()
109 rpc_bdev_lvol_create_lvstore(struct spdk_jsonrpc_request *request, in rpc_bdev_lvol_create_lvstore()
120 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_lvol_create_lvstore()
133 spdk_jsonrpc_send_error_response(request, -EINVAL, "Invalid clear_method parameter"); in rpc_bdev_lvol_create_lvstore()
142 rpc_lvol_store_construct_cb, request); in rpc_bdev_lvol_create_lvstore()
144 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_bdev_lvol_create_lvstore()
176 struct spdk_jsonrpc_request *request in rpc_bdev_lvol_rename_lvstore_cb()
90 struct spdk_jsonrpc_request *request = cb_arg; rpc_lvol_store_construct_cb() local
107 rpc_bdev_lvol_create_lvstore(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_create_lvstore() argument
173 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_rename_lvstore_cb() local
188 rpc_bdev_lvol_rename_lvstore(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_rename_lvstore() argument
237 struct spdk_jsonrpc_request *request = cb_arg; rpc_lvol_store_destroy_cb() local
252 rpc_bdev_lvol_delete_lvstore(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_delete_lvstore() argument
312 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_create_cb() local
329 rpc_bdev_lvol_create(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_create() argument
403 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_snapshot_cb() local
420 rpc_bdev_lvol_snapshot(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_snapshot() argument
481 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_clone_cb() local
498 rpc_bdev_lvol_clone(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_clone() argument
569 rpc_bdev_lvol_clone_bdev(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_clone_bdev() argument
641 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_rename_cb() local
656 rpc_bdev_lvol_rename(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_rename() argument
713 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_inflate_cb() local
728 rpc_bdev_lvol_inflate(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_inflate() argument
769 rpc_bdev_lvol_decouple_parent(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_decouple_parent() argument
828 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_resize_cb() local
843 rpc_bdev_lvol_resize(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_resize() argument
900 struct spdk_jsonrpc_request *request = cb_arg; rpc_set_ro_lvol_bdev_cb() local
915 rpc_bdev_lvol_set_read_only(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_set_read_only() argument
977 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_delete_cb() local
992 rpc_bdev_lvol_delete(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_delete() argument
1092 rpc_bdev_lvol_get_lvstores(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_get_lvstores() argument
1199 rpc_bdev_lvol_get_lvols(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_get_lvols() argument
1271 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_grow_lvstore_cb() local
1286 rpc_bdev_lvol_grow_lvstore(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_grow_lvstore() argument
1321 struct spdk_jsonrpc_request *request; global() member
1356 rpc_bdev_lvol_start_shallow_copy(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_start_shallow_copy() argument
1456 rpc_bdev_lvol_check_shallow_copy(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_check_shallow_copy() argument
1542 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_lvol_set_parent_cb() local
1557 rpc_bdev_lvol_set_parent(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_set_parent() argument
1612 rpc_bdev_lvol_set_parent_bdev(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_lvol_set_parent_bdev() argument
[all...]
/spdk/lib/nvmf/
H A Dnvmf_rpc.c264 rpc_nvmf_get_subsystems(struct spdk_jsonrpc_request *request,
277 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_nvmf_get_subsystems()
284 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_nvmf_get_subsystems()
295 spdk_jsonrpc_send_error_response(request, -ENODEV, spdk_strerror(ENODEV)); in rpc_nvmf_get_subsystems()
302 w = spdk_jsonrpc_begin_result(request); in rpc_nvmf_get_subsystems()
315 spdk_jsonrpc_end_result(request, w); in rpc_nvmf_get_subsystems()
355 struct spdk_jsonrpc_request *request = cb_arg; in rpc_nvmf_subsystem_started() local
358 spdk_jsonrpc_send_bool_response(request, true); in rpc_nvmf_subsystem_started()
360 spdk_jsonrpc_send_error_response_fmt(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_nvmf_subsystem_started()
368 rpc_nvmf_create_subsystem(struct spdk_jsonrpc_request *request, in rpc_nvmf_create_subsystem() argument
266 rpc_nvmf_get_subsystems(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_get_subsystems() argument
491 struct spdk_jsonrpc_request *request = cb_arg; rpc_nvmf_subsystem_destroy_complete_cb() local
500 struct spdk_jsonrpc_request *request = cb_arg; rpc_nvmf_subsystem_stopped() local
525 rpc_nvmf_delete_subsystem(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_delete_subsystem() argument
658 struct spdk_jsonrpc_request *request; global() member
696 struct spdk_jsonrpc_request *request; nvmf_rpc_listen_resumed() local
888 rpc_nvmf_subsystem_add_listener(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_add_listener() argument
980 rpc_nvmf_subsystem_remove_listener(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_remove_listener() argument
1081 rpc_nvmf_add_referral(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_add_referral() argument
1156 rpc_nvmf_remove_referral(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_remove_referral() argument
1251 rpc_nvmf_get_referrals(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_get_referrals() argument
1333 rpc_nvmf_subsystem_listener_set_ana_state(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_listener_set_ana_state() argument
1444 struct spdk_jsonrpc_request *request; global() member
1470 struct spdk_jsonrpc_request *request = ctx->request; nvmf_rpc_ns_failback_resumed() local
1488 struct spdk_jsonrpc_request *request = ctx->request; nvmf_rpc_ns_resumed() local
1568 rpc_nvmf_subsystem_add_ns(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_add_ns() argument
1629 struct spdk_jsonrpc_request *request; global() member
1652 struct spdk_jsonrpc_request *request = ctx->request; nvmf_rpc_remove_ns_resumed() local
1688 rpc_nvmf_subsystem_remove_ns(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_remove_ns() argument
1745 struct spdk_jsonrpc_request *request; global() member
1775 struct spdk_jsonrpc_request *request = ctx->request; nvmf_rpc_ns_visible_resumed() local
1813 nvmf_rpc_ns_visible(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params,bool visible) nvmf_rpc_ns_visible() argument
1869 rpc_nvmf_ns_add_host(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_ns_add_host() argument
1877 rpc_nvmf_ns_remove_host(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_ns_remove_host() argument
1885 struct spdk_jsonrpc_request *request; global() member
1913 rpc_nvmf_subsystem_add_host(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_add_host() argument
1996 rpc_nvmf_subsystem_remove_host(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_remove_host() argument
2071 rpc_nvmf_subsystem_allow_any_host(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_allow_any_host() argument
2181 rpc_nvmf_create_target(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_create_target() argument
2232 struct spdk_jsonrpc_request *request = ctx; nvmf_rpc_destroy_target_done() local
2238 rpc_nvmf_delete_target(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_delete_target() argument
2269 rpc_nvmf_get_targets(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_get_targets() argument
2302 struct spdk_jsonrpc_request *request; global() member
2451 rpc_nvmf_create_transport(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_create_transport() argument
2539 rpc_nvmf_get_transports(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_get_transports() argument
2599 struct spdk_jsonrpc_request *request; global() member
2643 rpc_nvmf_get_stats(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_get_stats() argument
2807 struct spdk_jsonrpc_request *request; global() member
2932 _rpc_nvmf_subsystem_query(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params,spdk_nvmf_subsystem_state_change_done cb_fn) _rpc_nvmf_subsystem_query() argument
2988 rpc_nvmf_subsystem_get_controllers(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_get_controllers() argument
2997 rpc_nvmf_subsystem_get_qpairs(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_get_qpairs() argument
3005 rpc_nvmf_subsystem_get_listeners(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_subsystem_get_listeners() argument
3022 rpc_nvmf_publish_mdns_prr(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_publish_mdns_prr() argument
3066 rpc_nvmf_stop_mdns_prr(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_nvmf_stop_mdns_prr() argument
[all...]
/spdk/module/bdev/ftl/
H A Dbdev_ftl_rpc.c19 struct spdk_jsonrpc_request *request = cb_arg; in rpc_bdev_ftl_basic_cb() local
22 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_ftl_basic_cb()
24 spdk_jsonrpc_send_error_response(request, bdeverrno, spdk_strerror(-bdeverrno)); in rpc_bdev_ftl_basic_cb()
62 struct spdk_jsonrpc_request *request = ctx; in rpc_bdev_ftl_create_cb() local
66 spdk_jsonrpc_send_error_response_fmt(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_ftl_create_cb()
72 w = spdk_jsonrpc_begin_result(request); in rpc_bdev_ftl_create_cb()
77 spdk_jsonrpc_end_result(request, w); in rpc_bdev_ftl_create_cb()
81 rpc_bdev_ftl_create(struct spdk_jsonrpc_request *request, in rpc_bdev_ftl_create() argument
93 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_bdev_ftl_create()
104 spdk_jsonrpc_send_error_response_fmt(request, SPDK_JSONRPC_ERROR_INVALID_PARAM in rpc_bdev_ftl_create()
123 rpc_bdev_ftl_load(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_load() argument
144 rpc_bdev_ftl_delete(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_delete() argument
164 rpc_bdev_ftl_unload(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_unload() argument
185 rpc_bdev_ftl_unmap(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_unmap() argument
204 struct spdk_jsonrpc_request *request = ftl_stats_ctx->request; _rpc_bdev_ftl_get_stats() local
273 rpc_bdev_ftl_get_stats(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_get_stats() argument
302 struct spdk_jsonrpc_request *request = ctx; rpc_bdev_ftl_get_properties_cb() local
310 rpc_bdev_ftl_get_properties(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_get_properties() argument
341 rpc_bdev_ftl_set_property(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_ftl_set_property() argument
[all...]
/spdk/module/blobfs/bdev/
H A Dblobfs_bdev_rpc.c33 rpc_blobfs_set_cache_size(struct spdk_jsonrpc_request *request, in rpc_blobfs_set_cache_size() argument
43 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_blobfs_set_cache_size()
50 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_blobfs_set_cache_size()
59 spdk_jsonrpc_send_bool_response(request, true); in rpc_blobfs_set_cache_size()
61 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_blobfs_set_cache_size()
71 struct spdk_jsonrpc_request *request; member
95 spdk_jsonrpc_send_error_response(req->request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in _rpc_blobfs_detect_done()
101 spdk_jsonrpc_send_bool_response(req->request, existed); in _rpc_blobfs_detect_done()
107 rpc_blobfs_detect(struct spdk_jsonrpc_request *request, in rpc_blobfs_detect() argument
115 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, "Out of memory"); in rpc_blobfs_detect()
[all …]
/spdk/lib/ublk/
H A Dublk_rpc.c29 rpc_ublk_create_target(struct spdk_jsonrpc_request *request, const struct spdk_json_val *params) in rpc_ublk_create_target() argument
47 spdk_jsonrpc_send_bool_response(request, true); in rpc_ublk_create_target()
52 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, spdk_strerror(-rc)); in rpc_ublk_create_target()
67 rpc_ublk_destroy_target(struct spdk_jsonrpc_request *request, const struct spdk_json_val *params) in rpc_ublk_destroy_target() argument
71 rc = ublk_destroy_target(ublk_destroy_target_done, request); in rpc_ublk_destroy_target()
73 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, spdk_strerror(-rc)); in rpc_ublk_destroy_target()
84 struct spdk_jsonrpc_request *request; member
108 w = spdk_jsonrpc_begin_result(req->request); in rpc_ublk_start_disk_done()
110 spdk_jsonrpc_end_result(req->request, w); in rpc_ublk_start_disk_done()
112 spdk_jsonrpc_send_error_response(req->request, rc, spdk_strerror(-rc)); in rpc_ublk_start_disk_done()
[all …]
/spdk/module/bdev/raid/
H A Dbdev_raid_rpc.c28 * req - pointer to RPC request
56 * request - pointer to json rpc request
57 * params - pointer to request parameters
62 rpc_bdev_raid_get_bdevs(struct spdk_jsonrpc_request *request, in rpc_bdev_raid_get_bdevs() argument
73 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_PARSE_ERROR, in rpc_bdev_raid_get_bdevs()
80 spdk_jsonrpc_send_error_response(request, -EINVAL, spdk_strerror(EINVAL)); in rpc_bdev_raid_get_bdevs()
84 w = spdk_jsonrpc_begin_result(request); in rpc_bdev_raid_get_bdevs()
101 spdk_jsonrpc_end_result(request, w); in rpc_bdev_raid_get_bdevs()
192 struct spdk_jsonrpc_request *request; member
255 rpc_bdev_raid_create(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_raid_create() argument
359 struct spdk_jsonrpc_request *request; global() member
374 struct spdk_jsonrpc_request *request = ctx->request; bdev_raid_delete_done() local
402 rpc_bdev_raid_delete(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_raid_delete() argument
480 struct spdk_jsonrpc_request *request = ctx; rpc_bdev_raid_add_base_bdev_done() local
507 rpc_bdev_raid_add_base_bdev(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_raid_add_base_bdev() argument
553 struct spdk_jsonrpc_request *request = ctx; rpc_bdev_raid_remove_base_bdev_done() local
574 rpc_bdev_raid_remove_base_bdev(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_raid_remove_base_bdev() argument
613 rpc_bdev_raid_set_options(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_raid_set_options() argument
[all...]
/spdk/module/bdev/iscsi/
H A Dbdev_iscsi_rpc.c18 rpc_bdev_iscsi_set_options(struct spdk_jsonrpc_request *request, in rpc_bdev_iscsi_set_options() argument
29 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_iscsi_set_options()
36 spdk_jsonrpc_send_error_response(request, -EPERM, in rpc_bdev_iscsi_set_options()
39 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_bdev_iscsi_set_options()
41 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_iscsi_set_options()
72 struct spdk_jsonrpc_request *request = cb_arg; in bdev_iscsi_create_cb() local
76 spdk_jsonrpc_send_error_response_fmt(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in bdev_iscsi_create_cb()
79 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in bdev_iscsi_create_cb()
82 w = spdk_jsonrpc_begin_result(request); in bdev_iscsi_create_cb()
84 spdk_jsonrpc_end_result(request, w); in bdev_iscsi_create_cb()
[all …]
/spdk/module/bdev/aio/
H A Dbdev_aio_rpc.c23 struct spdk_jsonrpc_request *request;
47 struct spdk_jsonrpc_request *request = ctx->request; in rpc_bdev_aio_create_cb()
50 w = spdk_jsonrpc_begin_result(request); in rpc_bdev_aio_create_cb()
52 spdk_jsonrpc_end_result(request, w); in rpc_bdev_aio_create_cb()
57 rpc_bdev_aio_create(struct spdk_jsonrpc_request *request, in rpc_bdev_aio_create()
65 spdk_jsonrpc_send_error_response(request, -ENOMEM, spdk_strerror(ENOMEM)); in rpc_bdev_aio_create()
73 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_aio_create()
79 ctx->request = request; in rpc_bdev_aio_create()
22 struct spdk_jsonrpc_request *request; global() member
45 struct spdk_jsonrpc_request *request = ctx->request; rpc_bdev_aio_create_cb() local
55 rpc_bdev_aio_create(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_aio_create() argument
99 rpc_bdev_aio_rescan(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_aio_rescan() argument
143 struct spdk_jsonrpc_request *request = cb_arg; _rpc_bdev_aio_delete_cb() local
153 rpc_bdev_aio_delete(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_aio_delete() argument
[all...]
/spdk/lib/iscsi/
H A Discsi_rpc.c21 rpc_iscsi_get_initiator_groups(struct spdk_jsonrpc_request *request, in rpc_iscsi_get_initiator_groups() argument
27 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_iscsi_get_initiator_groups()
32 w = spdk_jsonrpc_begin_result(request); in rpc_iscsi_get_initiator_groups()
37 spdk_jsonrpc_end_result(request, w); in rpc_iscsi_get_initiator_groups()
110 rpc_iscsi_create_initiator_group(struct spdk_jsonrpc_request *request, in rpc_iscsi_create_initiator_group() argument
137 spdk_jsonrpc_send_bool_response(request, true); in rpc_iscsi_create_initiator_group()
141 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_iscsi_create_initiator_group()
154 rpc_iscsi_initiator_group_add_initiators(struct spdk_jsonrpc_request *request, in rpc_iscsi_initiator_group_add_initiators() argument
176 spdk_jsonrpc_send_bool_response(request, true); in rpc_iscsi_initiator_group_add_initiators()
180 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_iscsi_initiator_group_add_initiators()
[all …]
/spdk/module/bdev/virtio/
H A Dbdev_virtio_rpc.c30 rpc_bdev_virtio_blk_set_hotplug(struct spdk_jsonrpc_request *request, in rpc_bdev_virtio_blk_set_hotplug() argument
48 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_virtio_blk_set_hotplug()
51 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, spdk_strerror(-rc)); in rpc_bdev_virtio_blk_set_hotplug()
66 struct spdk_jsonrpc_request *request = ctx; in rpc_bdev_virtio_detach_controller_cb() local
69 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_bdev_virtio_detach_controller_cb()
74 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_virtio_detach_controller_cb()
78 rpc_bdev_virtio_detach_controller(struct spdk_jsonrpc_request *request, in rpc_bdev_virtio_detach_controller() argument
87 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, 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()
[all …]
/spdk/module/bdev/nvme/
H A Dbdev_nvme_rpc.c145 rpc_bdev_nvme_set_options(struct spdk_jsonrpc_request *request, in rpc_bdev_nvme_set_options()
156 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_nvme_set_options()
163 spdk_jsonrpc_send_error_response(request, -EPERM, in rpc_bdev_nvme_set_options()
166 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_bdev_nvme_set_options()
168 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_nvme_set_options()
189 struct spdk_jsonrpc_request *request = ctx; in rpc_bdev_nvme_set_hotplug_done()
191 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_nvme_set_hotplug_done()
195 rpc_bdev_nvme_set_hotplug(struct spdk_jsonrpc_request *request, in rpc_bdev_nvme_set_hotplug()
209 request); in rpc_bdev_nvme_set_hotplug()
216 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAM in rpc_bdev_nvme_set_hotplug()
144 rpc_bdev_nvme_set_options(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_set_options() argument
188 struct spdk_jsonrpc_request *request = ctx; rpc_bdev_nvme_set_hotplug_done() local
194 rpc_bdev_nvme_set_hotplug(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_set_hotplug() argument
349 struct spdk_jsonrpc_request *request; global() member
364 struct spdk_jsonrpc_request *request = ctx->request; rpc_bdev_nvme_attach_controller_examined() local
383 struct spdk_jsonrpc_request *request = ctx->request; rpc_bdev_nvme_attach_controller_done() local
396 rpc_bdev_nvme_attach_controller(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_attach_controller() argument
673 rpc_bdev_nvme_get_controllers(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_controllers() argument
754 struct spdk_jsonrpc_request *request = arg; rpc_bdev_nvme_detach_controller_done() local
764 rpc_bdev_nvme_detach_controller(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_detach_controller() argument
905 struct spdk_jsonrpc_request *request; global() member
1052 rpc_bdev_nvme_apply_firmware(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_apply_firmware() argument
1166 struct spdk_jsonrpc_request *request; global() member
1292 rpc_bdev_nvme_get_transport_statistics(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_transport_statistics() argument
1341 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_nvme_controller_op_cb() local
1351 rpc_bdev_nvme_controller_op(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params,enum nvme_ctrlr_op op) rpc_bdev_nvme_controller_op() argument
1391 rpc_bdev_nvme_reset_controller(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_reset_controller() argument
1399 rpc_bdev_nvme_enable_controller(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_enable_controller() argument
1407 rpc_bdev_nvme_disable_controller(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_disable_controller() argument
1420 struct spdk_jsonrpc_request *request; global() member
1452 struct spdk_jsonrpc_request *request = context->request; get_health_log_page_completion() local
1568 get_controller_health_info(struct spdk_jsonrpc_request * request,struct spdk_nvme_ctrlr * ctrlr) get_controller_health_info() argument
1591 rpc_bdev_nvme_get_controller_health_info(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_controller_health_info() argument
1671 struct spdk_jsonrpc_request *request; global() member
1677 struct spdk_jsonrpc_request *request = ctx; rpc_bdev_nvme_start_discovery_done() local
1687 rpc_bdev_nvme_start_discovery(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_start_discovery() argument
1797 struct spdk_jsonrpc_request *request; global() member
1811 rpc_bdev_nvme_stop_discovery(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_stop_discovery() argument
1849 rpc_bdev_nvme_get_discovery_info(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_discovery_info() argument
1912 struct spdk_jsonrpc_request *request; global() member
1953 rpc_bdev_nvme_add_error_injection(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_add_error_injection() argument
2029 struct spdk_jsonrpc_request *request; global() member
2066 rpc_bdev_nvme_remove_error_injection(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_remove_error_injection() argument
2129 struct spdk_jsonrpc_request *request; global() member
2185 rpc_bdev_nvme_get_io_paths(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_io_paths() argument
2240 struct spdk_jsonrpc_request *request; global() member
2259 rpc_bdev_nvme_set_preferred_path(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_set_preferred_path() argument
2348 struct spdk_jsonrpc_request *request; global() member
2367 rpc_bdev_nvme_set_multipath_policy(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_set_multipath_policy() argument
2442 struct spdk_jsonrpc_request *request; global() member
2446 rpc_bdev_nvme_start_mdns_discovery(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_start_mdns_discovery() argument
2499 struct spdk_jsonrpc_request *request; global() member
2503 rpc_bdev_nvme_stop_mdns_discovery(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_stop_mdns_discovery() argument
2541 rpc_bdev_nvme_get_mdns_discovery_info(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_mdns_discovery_info() argument
2561 struct spdk_jsonrpc_request *request; global() member
2649 rpc_bdev_nvme_get_path_iostat(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_nvme_get_path_iostat() argument
[all...]
H A Dvbdev_opal_rpc.c32 rpc_bdev_nvme_opal_init(struct spdk_jsonrpc_request *request, in rpc_bdev_nvme_opal_init() argument
43 …spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_bdev_nvme_opal_init()
51 …spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_bdev_nvme_opal_init()
61 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_nvme_opal_init()
65 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_nvme_opal_init()
69 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, "Internal error"); in rpc_bdev_nvme_opal_init()
78 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, "Internal error"); in rpc_bdev_nvme_opal_init()
82 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_nvme_opal_init()
107 rpc_bdev_nvme_opal_revert(struct spdk_jsonrpc_request *request, in rpc_bdev_nvme_opal_revert() argument
118 …spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, "Invalid parameters"); in rpc_bdev_nvme_opal_revert()
[all …]
/spdk/python/spdk/sma/
H A Dsma.py29 def wrapper(self, request, context): argument
31 return f(self, request, context)
66 def CreateDevice(self, request, context): argument
70 if request.HasField('volume'):
71 volume_id, existing = self._volume_mgr.connect_volume(request.volume)
73 manager = self._find_device_by_name(request.WhichOneof('params'))
77 response = manager.create_device(request)
93 def DeleteDevice(self, request, context): argument
96 device = self._find_device_by_handle(request.handle)
100 if not device.allow_delete_volumes and self._volume_mgr.has_volumes(request.handle):
[all …]
/spdk/test/event/scheduler/
H A Dscheduler.c30 struct spdk_jsonrpc_request *request; member
56 rpc_scheduler_thread_create_cb(struct spdk_jsonrpc_request *request, uint64_t thread_id) in rpc_scheduler_thread_create_cb() argument
60 w = spdk_jsonrpc_begin_result(request); in rpc_scheduler_thread_create_cb()
62 spdk_jsonrpc_end_result(request, w); in rpc_scheduler_thread_create_cb()
135 if (sched_thread->request != NULL) { in rpc_register_poller()
136 rpc_scheduler_thread_create_cb(sched_thread->request, spdk_thread_get_id(sched_thread->thread)); in rpc_register_poller()
137 sched_thread->request = NULL; in rpc_register_poller()
142 rpc_scheduler_thread_create(struct spdk_jsonrpc_request *request, in rpc_scheduler_thread_create() argument
153 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_scheduler_thread_create()
160 spdk_jsonrpc_send_error_response(request, -EINVAL, spdk_strerror(EINVAL)); in rpc_scheduler_thread_create()
[all …]
/spdk/lib/nbd/
H A Dnbd_rpc.c22 struct spdk_jsonrpc_request *request; member
114 struct spdk_jsonrpc_request *request = req->request; in rpc_start_nbd_done() local
132 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_start_nbd_done()
137 w = spdk_jsonrpc_begin_result(request); in rpc_start_nbd_done()
139 spdk_jsonrpc_end_result(request, w); in rpc_start_nbd_done()
145 rpc_nbd_start_disk(struct spdk_jsonrpc_request *request, in rpc_nbd_start_disk() argument
154 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, "Out of memory"); in rpc_nbd_start_disk()
162 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_nbd_start_disk()
176 spdk_jsonrpc_send_error_response(request, -EBUSY, spdk_strerror(-rc)); in rpc_nbd_start_disk()
182 spdk_jsonrpc_send_error_response_fmt(request, -ENODEV, in rpc_nbd_start_disk()
[all …]
/spdk/module/event/subsystems/vmd/
H A Dvmd_rpc.c17 rpc_vmd_enable(struct spdk_jsonrpc_request *request, const struct spdk_json_val *params) in rpc_vmd_enable() argument
21 spdk_jsonrpc_send_bool_response(request, true); in rpc_vmd_enable()
35 rpc_vmd_remove_device(struct spdk_jsonrpc_request *request, const struct spdk_json_val *params) in rpc_vmd_remove_device() argument
42 spdk_jsonrpc_send_error_response(request, -EPERM, "VMD subsystem is disabled"); in rpc_vmd_remove_device()
50 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_vmd_remove_device()
57 spdk_jsonrpc_send_error_response(request, -EINVAL, "Failed to parse PCI address"); in rpc_vmd_remove_device()
63 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_vmd_remove_device()
67 spdk_jsonrpc_send_bool_response(request, true); in rpc_vmd_remove_device()
74 rpc_vmd_rescan(struct spdk_jsonrpc_request *request, const struct spdk_json_val *params) in rpc_vmd_rescan() argument
80 spdk_jsonrpc_send_error_response(request, -EPERM, "VMD subsystem is disabled"); in rpc_vmd_rescan()
[all …]
/spdk/test/rpc_client/
H A Drpc_client_test.c57 struct spdk_jsonrpc_client_request *request; in spdk_jsonrpc_client_check_rpc_method() local
59 request = spdk_jsonrpc_client_create_request(); in spdk_jsonrpc_client_check_rpc_method()
60 if (request == NULL) { in spdk_jsonrpc_client_check_rpc_method()
64 w = spdk_jsonrpc_begin_request(request, 1, "rpc_get_methods"); in spdk_jsonrpc_client_check_rpc_method()
65 spdk_jsonrpc_end_request(request, w); in spdk_jsonrpc_client_check_rpc_method()
66 spdk_jsonrpc_client_send_request(client, request); in spdk_jsonrpc_client_check_rpc_method()
123 struct spdk_jsonrpc_client_request *request; in spdk_jsonrpc_client_check_null_params_method() local
125 request = spdk_jsonrpc_client_create_request(); in spdk_jsonrpc_client_check_null_params_method()
126 if (request == NULL) { in spdk_jsonrpc_client_check_null_params_method()
130 w = spdk_jsonrpc_begin_request(request, 1, "test_null_params"); in spdk_jsonrpc_client_check_null_params_method()
[all …]
/spdk/lib/sock/
H A Dsock_rpc.c21 rpc_sock_impl_get_options(struct spdk_jsonrpc_request *request, in rpc_sock_impl_get_options() argument
33 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_sock_impl_get_options()
41 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_sock_impl_get_options()
46 w = spdk_jsonrpc_begin_result(request); in rpc_sock_impl_get_options()
59 spdk_jsonrpc_end_result(request, w); in rpc_sock_impl_get_options()
118 rpc_sock_impl_set_options(struct spdk_jsonrpc_request *request, in rpc_sock_impl_set_options() argument
129 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_sock_impl_set_options()
139 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_sock_impl_set_options()
148 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_sock_impl_set_options()
156 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INVALID_PARAMS, in rpc_sock_impl_set_options()
[all …]
/spdk/module/bdev/rbd/
H A Dbdev_rbd_rpc.c88 rpc_bdev_rbd_create(struct spdk_jsonrpc_request *request, in rpc_bdev_rbd_create() argument
100 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_rbd_create()
110 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_bdev_rbd_create()
114 w = spdk_jsonrpc_begin_result(request); in rpc_bdev_rbd_create()
116 spdk_jsonrpc_end_result(request, w); in rpc_bdev_rbd_create()
140 struct spdk_jsonrpc_request *request = cb_arg; in _rpc_bdev_rbd_delete_cb() local
143 spdk_jsonrpc_send_bool_response(request, true); in _rpc_bdev_rbd_delete_cb()
145 spdk_jsonrpc_send_error_response(request, bdeverrno, spdk_strerror(-bdeverrno)); in _rpc_bdev_rbd_delete_cb()
150 rpc_bdev_rbd_delete(struct spdk_jsonrpc_request *request, in rpc_bdev_rbd_delete() argument
158 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_rbd_delete()
[all …]
/spdk/module/bdev/null/
H A Dbdev_null_rpc.c33 rpc_bdev_null_create(struct spdk_jsonrpc_request *request,
45 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, in rpc_bdev_null_create()
52 spdk_jsonrpc_send_error_response(request, rc, spdk_strerror(-rc)); in rpc_bdev_null_create()
56 w = spdk_jsonrpc_begin_result(request); in rpc_bdev_null_create()
58 spdk_jsonrpc_end_result(request, w); in rpc_bdev_null_create()
84 struct spdk_jsonrpc_request *request = cb_arg; in rpc_bdev_null_create()
87 spdk_jsonrpc_send_bool_response(request, true); in rpc_bdev_null_create()
89 spdk_jsonrpc_send_error_response(request, bdeverrno, spdk_strerror(-bdeverrno)); in rpc_bdev_null_create()
94 rpc_bdev_null_delete(struct spdk_jsonrpc_request *request, in rpc_bdev_null_create()
102 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERRO in rpc_bdev_null_create()
43 rpc_bdev_null_create(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_null_create() argument
138 struct spdk_jsonrpc_request *request = cb_arg; rpc_bdev_null_delete_cb() local
148 rpc_bdev_null_delete(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) rpc_bdev_null_delete() argument
189 spdk_rpc_bdev_null_resize(struct spdk_jsonrpc_request * request,const struct spdk_json_val * params) spdk_rpc_bdev_null_resize() argument
[all...]

12345