| /spdk/scripts/ |
| H A D | rpc.py | 66 def framework_start_init(args): argument 67 rpc.framework_start_init(args.client) 72 def framework_wait_init(args): argument 73 rpc.framework_wait_init(args.client) 78 def rpc_get_methods(args): argument 79 print_dict(rpc.rpc_get_methods(args.client, 80 current=args.current, 81 include_aliases=args.include_aliases)) 88 def spdk_get_version(args): argument 89 print_json(rpc.spdk_get_version(args 94 save_config(args) global() argument 105 load_config(args) global() argument 114 save_subsystem_config(args) global() argument 127 load_subsystem_config(args) global() argument 136 spdk_kill_instance(args) global() argument 144 framework_monitor_context_switch(args) global() argument 159 framework_get_reactors(args) global() argument 166 framework_set_scheduler(args) global() argument 183 framework_get_scheduler(args) global() argument 190 framework_get_governor(args) global() argument 197 framework_disable_cpumask_locks(args) global() argument 204 framework_enable_cpumask_locks(args) global() argument 212 bdev_set_options(args) global() argument 232 bdev_examine(args) global() argument 241 bdev_wait_for_examine(args) global() argument 248 bdev_compress_create(args) global() argument 260 bdev_compress_delete(args) global() argument 268 bdev_compress_get_orphans(args) global() argument 276 bdev_crypto_create(args) global() argument 295 bdev_crypto_delete(args) global() argument 303 bdev_ocf_create(args) global() argument 323 bdev_ocf_delete(args) global() argument 331 bdev_ocf_get_stats(args) global() argument 338 bdev_ocf_reset_stats(args) global() argument 345 bdev_ocf_get_bdevs(args) global() argument 352 bdev_ocf_set_cache_mode(args) global() argument 362 bdev_ocf_set_seqcutoff(args) global() argument 379 bdev_ocf_flush_start(args) global() argument 386 bdev_ocf_flush_status(args) global() argument 393 bdev_malloc_create(args) global() argument 426 bdev_malloc_delete(args) global() argument 434 bdev_null_create(args) global() argument 464 bdev_null_delete(args) global() argument 472 bdev_null_resize(args) global() argument 483 bdev_aio_create(args) global() argument 499 bdev_aio_rescan(args) global() argument 507 bdev_aio_delete(args) global() argument 515 bdev_uring_create(args) global() argument 529 bdev_uring_rescan(args) global() argument 537 bdev_uring_delete(args) global() argument 545 bdev_xnvme_create(args) global() argument 558 bdev_xnvme_delete(args) global() argument 566 bdev_nvme_set_options(args) global() argument 686 bdev_nvme_set_hotplug(args) global() argument 696 bdev_nvme_attach_controller(args) global() argument 784 bdev_nvme_get_controllers(args) global() argument 793 bdev_nvme_detach_controller(args) global() argument 822 bdev_nvme_reset_controller(args) global() argument 833 bdev_nvme_enable_controller(args) global() argument 844 bdev_nvme_disable_controller(args) global() argument 855 bdev_nvme_start_discovery(args) global() argument 908 bdev_nvme_stop_discovery(args) global() argument 915 bdev_nvme_get_discovery_info(args) global() argument 921 bdev_nvme_get_io_paths(args) global() argument 928 bdev_nvme_set_preferred_path(args) global() argument 939 bdev_nvme_set_multipath_policy(args) global() argument 956 bdev_nvme_get_path_iostat(args) global() argument 966 bdev_nvme_cuse_register(args) global() argument 976 bdev_nvme_cuse_unregister(args) global() argument 986 bdev_zone_block_create(args) global() argument 1001 bdev_zone_block_delete(args) global() argument 1009 bdev_rbd_register_cluster(args) global() argument 1037 bdev_rbd_unregister_cluster(args) global() argument 1045 bdev_rbd_get_clusters_info(args) global() argument 1053 bdev_rbd_create(args) global() argument 1084 bdev_rbd_delete(args) global() argument 1092 bdev_rbd_resize(args) global() argument 1103 bdev_delay_create(args) global() argument 1128 bdev_delay_delete(args) global() argument 1136 bdev_delay_update_latency(args) global() argument 1148 bdev_error_create(args) global() argument 1158 bdev_error_delete(args) global() argument 1166 bdev_iscsi_set_options(args) global() argument 1174 bdev_iscsi_create(args) global() argument 1187 bdev_iscsi_delete(args) global() argument 1195 bdev_passthru_create(args) global() argument 1207 bdev_passthru_delete(args) global() argument 1215 bdev_get_bdevs(args) global() argument 1228 bdev_get_iostat(args) global() argument 1240 bdev_reset_iostat(args) global() argument 1249 bdev_enable_histogram(args) global() argument 1259 bdev_get_histogram(args) global() argument 1267 bdev_set_qd_sampling_period(args) global() argument 1280 bdev_set_qos_limit(args) global() argument 1305 bdev_error_inject_error(args) global() argument 1329 bdev_nvme_apply_firmware(args) global() argument 1339 bdev_nvme_get_transport_statistics(args) global() argument 1346 bdev_nvme_get_controller_health_info(args) global() argument 1356 iscsi_set_options(args) global() argument 1411 iscsi_set_discovery_auth(args) global() argument 1430 iscsi_create_auth_group(args) global() argument 1445 iscsi_delete_auth_group(args) global() argument 1453 iscsi_auth_group_add_secret(args) global() argument 1471 iscsi_auth_group_remove_secret(args) global() argument 1480 iscsi_get_auth_groups(args) global() argument 1487 iscsi_get_portal_groups(args) global() argument 1493 iscsi_get_initiator_groups(args) global() argument 1500 iscsi_get_target_nodes(args) global() argument 1506 iscsi_enable_histogram(args) global() argument 1516 iscsi_get_histogram(args) global() argument 1524 iscsi_create_target_node(args) global() argument 1578 iscsi_target_node_add_lun(args) global() argument 1594 iscsi_target_node_set_auth(args) global() argument 1616 iscsi_target_node_add_pg_ig_maps(args) global() argument 1636 iscsi_target_node_remove_pg_ig_maps(args) global() argument 1654 iscsi_target_node_set_redirect(args) global() argument 1671 iscsi_target_node_request_logout(args) global() argument 1684 iscsi_create_portal_group(args) global() argument 1719 iscsi_start_portal_group(args) global() argument 1728 iscsi_create_initiator_group(args) global() argument 1751 iscsi_initiator_group_add_initiators(args) global() argument 1779 iscsi_initiator_group_remove_initiators(args) global() argument 1807 iscsi_delete_target_node(args) global() argument 1817 iscsi_delete_portal_group(args) global() argument 1826 iscsi_delete_initiator_group(args) global() argument 1835 iscsi_portal_group_set_auth(args) global() argument 1857 iscsi_get_connections(args) global() argument 1864 iscsi_get_stats(args) global() argument 1871 iscsi_get_options(args) global() argument 1878 scsi_get_devices(args) global() argument 1885 trace_enable_tpoint_group(args) global() argument 1895 trace_disable_tpoint_group(args) global() argument 1905 trace_set_tpoint_mask(args) global() argument 1919 trace_clear_tpoint_mask(args) global() argument 1933 trace_get_tpoint_group_mask(args) global() argument 1939 trace_get_info(args) global() argument 1947 log_set_flag(args) global() argument 1955 log_clear_flag(args) global() argument 1963 log_get_flags(args) global() argument 1969 log_set_level(args) global() argument 1976 log_get_level(args) global() argument 1982 log_set_print_level(args) global() argument 1989 log_get_print_level(args) global() argument 1996 bdev_lvol_create_lvstore(args) global() argument 2016 bdev_lvol_rename_lvstore(args) global() argument 2026 bdev_lvol_grow_lvstore(args) global() argument 2037 bdev_lvol_create(args) global() argument 2056 bdev_lvol_snapshot(args) global() argument 2066 bdev_lvol_clone(args) global() argument 2076 bdev_lvol_clone_bdev(args) global() argument 2089 bdev_lvol_rename(args) global() argument 2099 bdev_lvol_inflate(args) global() argument 2107 bdev_lvol_decouple_parent(args) global() argument 2115 bdev_lvol_resize(args) global() argument 2125 bdev_lvol_set_read_only(args) global() argument 2133 bdev_lvol_delete(args) global() argument 2141 bdev_lvol_start_shallow_copy(args) global() argument 2153 bdev_lvol_check_shallow_copy(args) global() argument 2161 bdev_lvol_set_parent(args) global() argument 2171 bdev_lvol_set_parent_bdev(args) global() argument 2181 bdev_lvol_delete_lvstore(args) global() argument 2191 bdev_lvol_get_lvstores(args) global() argument 2201 bdev_lvol_get_lvols(args) global() argument 2211 bdev_raid_set_options(args) global() argument 2222 bdev_raid_get_bdevs(args) global() argument 2235 bdev_raid_create(args) global() argument 2257 bdev_raid_delete(args) global() argument 2264 bdev_raid_add_base_bdev(args) global() argument 2273 bdev_raid_remove_base_bdev(args) global() argument 2281 bdev_split_create(args) global() argument 2297 bdev_split_delete(args) global() argument 2306 bdev_ftl_create(args) global() argument 2334 bdev_ftl_load(args) global() argument 2361 bdev_ftl_unload(args) global() argument 2369 bdev_ftl_delete(args) global() argument 2377 bdev_ftl_unmap(args) global() argument 2388 bdev_ftl_get_stats(args) global() argument 2395 bdev_ftl_get_properties(args) global() argument 2402 bdev_ftl_set_property(args) global() argument 2414 vmd_enable(args) global() argument 2420 vmd_remove_device(args) global() argument 2427 vmd_rescan(args) global() argument 2434 ublk_create_target(args) global() argument 2444 ublk_destroy_target(args) global() argument 2450 ublk_start_disk(args) global() argument 2465 ublk_stop_disk(args) global() argument 2474 ublk_recover_disk(args) global() argument 2485 ublk_get_disks(args) global() argument 2495 nbd_start_disk(args) global() argument 2506 nbd_stop_disk(args) global() argument 2515 nbd_get_disks(args) global() argument 2525 nvmf_set_max_subsystems(args) global() argument 2534 nvmf_set_config(args) global() argument 2554 nvmf_create_transport(args) global() argument 2594 nvmf_get_transports(args) global() argument 2602 nvmf_get_subsystems(args) global() argument 2610 nvmf_create_subsystem(args) global() argument 2643 nvmf_delete_subsystem(args) global() argument 2654 nvmf_subsystem_add_listener(args) global() argument 2669 nvmf_subsystem_remove_listener(args) global() argument 2687 nvmf_subsystem_listener_set_ana_state(args) global() argument 2709 nvmf_discovery_add_referral(args) global() argument 2723 nvmf_discovery_remove_referral(args) global() argument 2741 nvmf_discovery_get_referrals(args) global() argument 2750 nvmf_subsystem_add_ns(args) global() argument 2767 nvmf_subsystem_remove_ns(args) global() argument 2779 nvmf_ns_add_host(args) global() argument 2797 nvmf_ns_remove_host(args) global() argument 2809 nvmf_subsystem_add_host(args) global() argument 2827 nvmf_subsystem_remove_host(args) global() argument 2839 nvmf_subsystem_allow_any_host(args) global() argument 2852 nvmf_subsystem_get_controllers(args) global() argument 2863 nvmf_subsystem_get_qpairs(args) global() argument 2874 nvmf_subsystem_get_listeners(args) global() argument 2885 nvmf_get_stats(args) global() argument 2893 nvmf_set_crdt(args) global() argument 2905 nvmf_publish_mdns_prr(args) global() argument 2913 nvmf_stop_mdns_prr(args) global() argument 2922 framework_get_subsystems(args) global() argument 2930 framework_get_config(args) global() argument 2938 vhost_controller_set_coalescing(args) global() argument 2950 virtio_blk_create_transport(args) global() argument 2958 virtio_blk_get_transports(args) global() argument 2965 vhost_create_scsi_controller(args) global() argument 2977 vhost_start_scsi_controller(args) global() argument 2985 vhost_scsi_controller_add_target(args) global() argument 2997 vhost_scsi_controller_remove_target(args) global() argument 3008 vhost_create_blk_controller(args) global() argument 3020 vhost_get_controllers(args) global() argument 3027 vhost_delete_controller(args) global() argument 3035 bdev_virtio_attach_controller(args) global() argument 3060 bdev_virtio_scsi_get_devices(args) global() argument 3066 bdev_virtio_detach_controller(args) global() argument 3075 bdev_virtio_blk_set_hotplug(args) global() argument 3086 vfu_tgt_set_base_path(args) global() argument 3093 vfu_virtio_delete_endpoint(args) global() argument 3100 vfu_virtio_create_blk_endpoint(args) global() argument 3118 vfu_virtio_scsi_add_target(args) global() argument 3130 vfu_virtio_scsi_remove_target(args) global() argument 3140 vfu_virtio_create_scsi_endpoint(args) global() argument 3157 accel_get_opc_assignments(args) global() argument 3163 accel_get_module_info(args) global() argument 3170 accel_assign_opc(args) global() argument 3178 accel_crypto_key_create(args) global() argument 3194 accel_crypto_key_destroy(args) global() argument 3202 accel_crypto_keys_get(args) global() argument 3210 accel_set_driver(args) global() argument 3218 accel_set_options(args) global() argument 3230 accel_get_stats(args) global() argument 3237 ioat_scan_accel_module(args) global() argument 3245 compressdev_scan_accel_module(args) global() argument 3253 dsa_scan_accel_module(args) global() argument 3263 iaa_scan_accel_module(args) global() argument 3270 dpdk_cryptodev_scan_accel_module(args) global() argument 3277 dpdk_cryptodev_set_driver(args) global() argument 3286 dpdk_cryptodev_get_driver(args) global() argument 3293 mlx5_scan_accel_module(args) global() argument 3306 accel_error_inject_error(args) global() argument 3323 bdev_nvme_opal_init(args) global() argument 3333 bdev_nvme_opal_revert(args) global() argument 3342 bdev_opal_create(args) global() argument 3360 bdev_opal_get_info(args) global() argument 3370 bdev_opal_delete(args) global() argument 3380 bdev_opal_new_user(args) global() argument 3394 bdev_opal_set_lock_state(args) global() argument 3410 bdev_nvme_send_cmd(args) global() argument 3436 notify_get_types(args) global() argument 3442 notify_get_notifications(args) global() argument 3453 thread_get_stats(args) global() argument 3460 thread_set_cpumask(args) global() argument 3471 log_enable_timestamps(args) global() argument 3480 thread_get_pollers(args) global() argument 3487 thread_get_io_channels(args) global() argument 3494 env_dpdk_get_mem_stats(args) global() argument 3502 blobfs_detect(args) global() argument 3510 blobfs_create(args) global() argument 3521 blobfs_mount(args) global() argument 3531 blobfs_set_cache_size(args) global() argument 3540 sock_impl_get_options(args) global() argument 3548 sock_impl_set_options(args) global() argument 3593 sock_set_default_impl(args) global() argument 3601 sock_get_default_impl(args) global() argument 3607 framework_get_pci_devices(args) global() argument 3627 bdev_nvme_add_error_injection(args) global() argument 3652 bdev_nvme_remove_error_injection(args) global() argument 3664 bdev_daos_create(args) global() argument 3686 bdev_daos_delete(args) global() argument 3695 bdev_daos_resize(args) global() argument 3706 iobuf_set_options(args) global() argument 3719 iobuf_get_stats(args) global() argument 3725 bdev_nvme_start_mdns_discovery(args) global() argument 3737 bdev_nvme_stop_mdns_discovery(args) global() argument 3744 bdev_nvme_get_mdns_discovery_info(args) global() argument 3750 keyring_file_add_key(args) global() argument 3758 keyring_file_remove_key(args) global() argument 3765 keyring_get_keys(args) global() argument 3771 keyring_linux_set_options(args) global() argument 3789 call_rpc_func(args) global() argument 3814 load_plugin(args) global() argument 3837 replace_arg_underscores(args) global() argument 3853 args = parser.parse_args() global() variable [all...] |
| H A D | iostat.py | 347 def io_stat_display(args, cpu_info, stat): argument 348 if args.cpu_stat and not args.bdev_stat: 353 if args.bdev_stat and not args.cpu_stat: 354 _stat = get_bdev_stat(args.client, args.name) 356 stat, _stat, args.mb_display, args.use_uptime, args.extended_display) 362 _stat = get_bdev_stat(args.client, args.name) 363 … bdev_stats = read_bdev_stat(stat, _stat, args.mb_display, args.use_uptime, args.extended_display) 367 def io_stat_display_loop(args): argument 368 interval = args.interval 369 time_in_second = args.time_in_second [all …]
|
| H A D | rpc_http_proxy.py | 130 args = parser.parse_args() 131 rpc_sock = args.sock 134 key = base64.b64encode((args.user+':'+args.password).encode(encoding='ascii')).decode('ascii') 138 httpd = HTTPServer((args.host, args.port), ServerHandler) 139 if args.cert is not None: 140 httpd.socket = ssl.wrap_socket(httpd.socket, certfile=args.cert, server_side=True)
|
| H A D | spdkcli.py | 55 args = parser.parse_args() 58 client = JSONRPCClient(args.server_addr, port=args.port) 65 root_node.verbose = args.verbose 71 if args.commands: 74 spdk_shell.run_cmdline(" ".join(args.commands))
|
| H A D | genconfig.py | 14 args = os.environ.copy() variable 20 args[var] = val 33 if var in args: 34 val = args[var]
|
| H A D | spdk-gpt.py | 68 args = parser.parse_args() variable 70 if is_spdk_gpt(args.block.replace("/dev/", ""), args.entry): 74 print("Failed to read GPT data from %s (%s)" % (args.block, e))
|
| /spdk/test/json_config/ |
| H A D | clear_config.py | 58 def clear_bdev_subsystem(args, bdev_config): argument 59 rpc_bdevs = args.client.call("bdev_get_bdevs") 65 args.client.call(destroy_method, {bdev_name_key: bdev_name}) 67 nvme_controllers = args.client.call("bdev_nvme_get_controllers") 69 args.client.call('bdev_nvme_detach_controller', {'name': ctrlr['name']}) 72 rpc.bdev.bdev_nvme_set_hotplug(args.client, False) 83 def clear_nvmf_subsystem(args, nvmf_config): argument 87 args.client.call(destroy_method, {'nqn': nvmf['params']['nqn']}) 113 def clear_iscsi_subsystem(args, iscsi_config): argument 117 args.client.call(destroy_method, {get_iscsi_name_key(iscsi): get_iscsi_name(iscsi)}) [all …]
|
| H A D | config_filter.py | 101 args = parser.parse_args() 102 if args.method == "delete_global_parameters": 104 elif args.method == "delete_configs": 106 elif args.method == "check_empty": 108 elif args.method == "sort": 114 raise ValueError("Invalid method '{}'\n\n{}".format(args.method, parser.format_help())) 100 args = parser.parse_args() global() variable
|
| /spdk/test/app/fuzz/common/ |
| H A D | fuzz_rpc.py | 67 def fuzz_vhost_create_dev(args): argument 69 args.client, 70 args.socket, 71 args.is_blk, 72 args.use_bogus_buffer, 73 args.use_valid_buffer, 74 args.test_scsi_tmf, 75 args.valid_lun) 86 def call_rpc_func(args): argument 88 args.func(args) [all …]
|
| /spdk/test/nvmf/target/ |
| H A D | multitarget_rpc.py | 39 def nvmf_create_target(args): argument 40 print_dict(rpc.nvmf.nvmf_create_target(args.client, 41 name=args.name, 42 max_subsystems=args.max_subsystems)) 50 def nvmf_delete_target(args): argument 51 print_dict(rpc.nvmf.nvmf_delete_target(args.client, 52 name=args.name)) 58 def nvmf_get_targets(args): argument 59 print_dict(rpc.nvmf.nvmf_get_targets(args.client)) 64 def call_rpc_func(args): argument [all …]
|
| /spdk/test/event/scheduler/ |
| H A D | scheduler_plugin.py | 8 def thread_create(args): argument 9 params = {'active': args.active} 10 if args.name: 11 params['name'] = args.name 12 if args.cpu_mask: 13 params['cpu_mask'] = args.cpu_mask 14 return args.client.call('scheduler_thread_create', params) 17 def create_thread(args): argument 18 print_json(thread_create(args)) 21 def thread_set_active(args): argument [all …]
|
| /spdk/test/rpc_plugins/ |
| H A D | scheduler_plugin.py | 8 def thread_create(args): argument 9 params = {'active': args.active} 10 if args.name: 11 params['name'] = args.name 12 if args.cpu_mask: 13 params['cpu_mask'] = args.cpu_mask 14 return args.client.call('scheduler_thread_create', params) 17 def create_thread(args): argument 18 print_json(thread_create(args)) 21 def thread_set_active(args): argument [all …]
|
| H A D | rpc_plugin.py | 8 def malloc_create(args): argument 10 return args.client.call('bdev_malloc_create', params) 13 def malloc_delete(args): argument 14 params = {'name': args.name} 15 return args.client.call('bdev_malloc_delete', params) 18 def create_malloc(args): argument 19 print_json(malloc_create(args))
|
| /spdk/test/bdev/bdevio/ |
| H A D | tests.py | 62 def perform_tests(args): argument 63 print_dict(perform_tests_func(args.client, name=args.name)) 69 def call_rpc_func(args): argument 71 args.func(args) 80 args = parser.parse_args(shlex.split(rpc_call)) 81 args.client = client 82 call_rpc_func(args) 84 args = parser.parse_args() variable 85 …args.client = rpc.client.JSONRPCClient(args.server_addr, args.port, args.timeout, log_level=getatt… 86 if hasattr(args, 'func'): [all …]
|
| /spdk/lib/nvmf/ |
| H A D | fc.c | 507 struct spdk_nvmf_fc_poller_api_remove_hwqp_args *args = cb_data; in nvmf_fc_poll_group_remove_hwqp_cb() 511 "Remove hwqp%d from fgroup success\n", args->hwqp->hwqp_id); in nvmf_fc_poll_group_remove_hwqp_cb() 513 SPDK_ERRLOG("Remove hwqp%d from fgroup failed.\n", args->hwqp->hwqp_id); in nvmf_fc_poll_group_remove_hwqp_cb() 516 if (args->cb_fn) { in nvmf_fc_poll_group_remove_hwqp_cb() 517 args->cb_fn(args->cb_ctx, 0); in nvmf_fc_poll_group_remove_hwqp_cb() 520 free(args); 527 struct spdk_nvmf_fc_poller_api_remove_hwqp_args *args; in nvmf_fc_poll_group_remove_hwqp() 554 args = calloc(1, sizeof(struct spdk_nvmf_fc_poller_api_remove_hwqp_args)); in nvmf_fc_poll_group_remove_hwqp() 555 if (args in nvmf_fc_poll_group_remove_hwqp() 505 struct spdk_nvmf_fc_poller_api_remove_hwqp_args *args = cb_data; nvmf_fc_poll_group_remove_hwqp_cb() local 525 struct spdk_nvmf_fc_poller_api_remove_hwqp_args *args; nvmf_fc_poll_group_remove_hwqp() local 596 struct spdk_nvmf_fc_poller_api_abts_recvd_args *args, *poller_arg; nvmf_fc_queue_synced_cb() local 632 struct spdk_nvmf_fc_poller_api_queue_sync_args *args, *poller_arg; nvmf_fc_handle_abts_notfound() local 742 struct spdk_nvmf_fc_poller_api_abts_recvd_args *args = NULL, *poller_arg; nvmf_fc_handle_abts_frame() local 2346 nvmf_fc_adm_hw_port_data_init(struct spdk_nvmf_fc_port * fc_port,struct spdk_nvmf_fc_hw_port_init_args * args) nvmf_fc_adm_hw_port_data_init() argument 2434 nvmf_fc_adm_i_t_delete_cb(void * args,uint32_t err) nvmf_fc_adm_i_t_delete_cb() argument 2477 nvmf_fc_adm_i_t_delete_assoc_cb(void * args,uint32_t err) nvmf_fc_adm_i_t_delete_assoc_cb() argument 2681 struct spdk_nvmf_fc_poller_api_quiesce_queue_args *args; nvmf_fc_adm_hw_queue_quiesce() local 2795 struct spdk_nvmf_fc_hw_port_init_args *args = (struct spdk_nvmf_fc_hw_port_init_args *) nvmf_fc_adm_evnt_hw_port_init() local 2863 struct spdk_nvmf_fc_poller_api_queue_sync_args *args = NULL, *tmp = NULL; nvmf_fc_adm_hwqp_clean_sync_cb() local 2886 struct spdk_nvmf_fc_hw_port_free_args *args = (struct spdk_nvmf_fc_hw_port_free_args *) nvmf_fc_adm_evnt_hw_port_free() local 2938 struct spdk_nvmf_fc_hw_port_online_args *args = (struct spdk_nvmf_fc_hw_port_online_args *) nvmf_fc_adm_evnt_hw_port_online() local 2986 struct spdk_nvmf_fc_hw_port_offline_args *args = remove_hwqp_args->cb_args; nvmf_fc_adm_hw_port_offline_cb() local 3022 struct spdk_nvmf_fc_hw_port_offline_args *args = (struct spdk_nvmf_fc_hw_port_offline_args *) nvmf_fc_adm_evnt_hw_port_offline() local 3174 struct spdk_nvmf_fc_nport_create_args *args = (struct spdk_nvmf_fc_nport_create_args *) nvmf_fc_adm_evnt_nport_create() local 3319 struct spdk_nvmf_fc_nport_delete_args *args = (struct spdk_nvmf_fc_nport_delete_args *) nvmf_fc_adm_evnt_nport_delete() local 3457 struct spdk_nvmf_fc_hw_i_t_add_args *args = (struct spdk_nvmf_fc_hw_i_t_add_args *) nvmf_fc_adm_evnt_i_t_add() local 3546 struct spdk_nvmf_fc_hw_i_t_delete_args *args = (struct spdk_nvmf_fc_hw_i_t_delete_args *) nvmf_fc_adm_evnt_i_t_delete() local 3684 struct spdk_nvmf_fc_abts_args *args = (struct spdk_nvmf_fc_abts_args *)api_data->api_args; nvmf_fc_adm_evnt_abts_recv() local 3742 struct spdk_nvmf_fc_hw_port_reset_args *args = reset_ctx->reset_args; nvmf_fc_adm_hw_port_quiesce_reset_cb() local 3821 struct spdk_nvmf_fc_hw_port_reset_args *args = (struct spdk_nvmf_fc_hw_port_reset_args *) nvmf_fc_adm_evnt_hw_port_reset() local 3881 nvmf_fc_adm_run_on_main_thread(spdk_msg_fn fn,void * args) nvmf_fc_adm_run_on_main_thread() argument 3893 nvmf_fc_main_enqueue_event(enum spdk_fc_event event_type,void * args,spdk_nvmf_fc_callback cb_func) nvmf_fc_main_enqueue_event() argument [all...] |
| H A D | fc_ls.c | 412 struct spdk_nvmf_fc_conn *fc_conn = dp->args.fc_conn; in nvmf_fc_ls_poller_delete_conn_cb() 450 api_data->args.fc_conn = fc_conn; in nvmf_fc_ls_poller_delete_conn() 451 api_data->args.send_abts = send_abts; in nvmf_fc_ls_poller_delete_conn() 452 api_data->args.backend_initiated = backend_initiated; in nvmf_fc_ls_poller_delete_conn() 453 api_data->args.hwqp = fc_conn->hwqp; in nvmf_fc_ls_poller_delete_conn() 454 api_data->args.cb_info.cb_thread = spdk_get_thread(); in nvmf_fc_ls_poller_delete_conn() 455 api_data->args.cb_info.cb_func = nvmf_fc_ls_poller_delete_conn_cb; in nvmf_fc_ls_poller_delete_conn() 456 api_data->args.cb_info.cb_data = opd; in nvmf_fc_ls_poller_delete_conn() 463 nvmf_fc_poller_api_func(api_data->args.hwqp, in nvmf_fc_ls_poller_delete_conn() 465 &api_data->args); in nvmf_fc_ls_poller_delete_conn() 621 nvmf_fs_send_ls_disconnect_cb(void * hwqp,int32_t status,void * args) nvmf_fs_send_ls_disconnect_cb() argument 1561 struct spdk_nvmf_fc_poller_api_abts_recvd_args *args = cb_args; nvmf_fc_poller_abts_done() local 1574 struct spdk_nvmf_fc_poller_api_abts_recvd_args *args = arg; nvmf_fc_poller_api_abts_received() local 1590 struct spdk_nvmf_fc_poller_api_queue_sync_args *args = arg; nvmf_fc_poller_api_queue_sync() local 1602 struct spdk_nvmf_fc_poller_api_queue_sync_done_args *args = arg; nvmf_fc_poller_api_queue_sync_done() local 1646 struct spdk_nvmf_fc_poller_api_remove_hwqp_args *args = arg; nvmf_fc_poller_api_remove_hwqp() local [all...] |
| /spdk/scripts/bpf/ |
| H A D | trace.py | 45 args: Dict[str, DTraceArgument] 47 def __init__(self, name, args): argument 49 self.args = {a.name: a for a in args} 56 args: Dict[str, TypeVar('ArgumentType', str, int)] 58 def __init__(self, probe, args): argument 62 self.args = {} 63 for name, value in args.items(): 64 arg = probe.args.get(name) 67 self.args[name] = valmap[arg.type](value) 82 for arg in probe.args.values(): [all …]
|
| /spdk/test/rpc/ |
| H A D | rpc_plugin.py | 8 def malloc_create(args): argument 10 return args.client.call('bdev_malloc_create', params) 13 def malloc_delete(args): argument 14 params = {'name': args.name} 15 return args.client.call('bdev_malloc_delete', params) 18 def create_malloc(args): argument 19 print_json(malloc_create(args))
|
| /spdk/docker/spdk-app/ |
| H A D | init | 7 app=spdk_tgt args=() limit_args=() 16 args=($SPDK_ARGS) 26 args+=("${limit_args[@]}") 30 args+=("--json" "/config")
|
| /spdk/examples/interrupt_tgt/ |
| H A D | interrupt_plugin.py | 8 def reactor_set_interrupt_mode(args): argument 9 params = {'lcore': args.lcore, 'disable_interrupt': args.disable_interrupt} 10 return args.client.call('reactor_set_interrupt_mode', params)
|
| /spdk/lib/trace/ |
| H A D | trace_flags.c | 429 max_name_length = sizeof(tpoint->args[0].name); in trace_register_description() 431 if (!opts->args[i].name || opts->args[i].name[0] == '\0') { in trace_register_description() 435 switch (opts->args[i].type) { in trace_register_description() 439 assert(opts->args[i].size == 4 || opts->args[i].size == 8); in trace_register_description() 443 assert(opts->args[i].size > 0); in trace_register_description() 450 if (strnlen(opts->args[i].name, max_name_length) == max_name_length) { in trace_register_description() 451 SPDK_ERRLOG("argument name (%s) is too long\n", opts->args[i].name); in trace_register_description() 454 snprintf(tpoint->args[i].name, sizeof(tpoint->args[i].name), in trace_register_description() 455 "%s", opts->args[i].name); in trace_register_description() 456 tpoint->args[i].type = opts->args[i].type; in trace_register_description() [all …]
|
| /spdk/lib/util/ |
| H A D | string.c | 12 spdk_vsprintf_append_realloc(char *buffer, const char *format, va_list args) in spdk_vsprintf_append_realloc() argument 24 va_copy(args_copy, args); in spdk_vsprintf_append_realloc() 38 vsnprintf(new_buffer + orig_size, new_size - orig_size, format, args); in spdk_vsprintf_append_realloc() 46 va_list args; in spdk_sprintf_append_realloc() local 49 va_start(args, format); in spdk_sprintf_append_realloc() 50 ret = spdk_vsprintf_append_realloc(buffer, format, args); in spdk_sprintf_append_realloc() 51 va_end(args); in spdk_sprintf_append_realloc() 57 spdk_vsprintf_alloc(const char *format, va_list args) in spdk_vsprintf_alloc() argument 59 return spdk_vsprintf_append_realloc(NULL, format, args); in spdk_vsprintf_alloc() 65 va_list args; in spdk_sprintf_alloc() local [all …]
|
| /spdk/module/bdev/ftl/ |
| H A D | bdev_ftl.c | 570 struct bdev_ftl_set_property_args *args = bdev_ftl_action_ctx(action, sizeof(*args)); in bdev_ftl_set_property_cb() local 572 free(args->property); in bdev_ftl_set_property_cb() 573 free(args->value); in bdev_ftl_set_property_cb() 574 args->property = NULL; in bdev_ftl_set_property_cb() 575 args->value = NULL; in bdev_ftl_set_property_cb() 584 struct bdev_ftl_set_property_args *args; in bdev_ftl_set_property() local 586 action = bdev_ftl_action_start(name, sizeof(*args), cb_fn, cb_arg); in bdev_ftl_set_property() 591 args = bdev_ftl_action_ctx(action, sizeof(*args)); in bdev_ftl_set_property() 592 args->property = strdup(property); in bdev_ftl_set_property() 593 args->value = strdup(value); in bdev_ftl_set_property() [all …]
|
| /spdk/app/trace/ |
| H A D | trace.cpp | 175 if (entry->args[i].is_related) { in print_event() 181 switch (d->args[i].type) { in print_event() 183 print_ptr(d->args[i].name, (uint64_t)entry->args[i].u.pointer); in print_event() 186 print_uint64(d->args[i].name, entry->args[i].u.integer); in print_event() 189 print_string(d->args[i].name, entry->args[i].u.string); in print_event() 250 switch (d->args[i].type) { in print_event_json() 252 spdk_json_write_uint64(g_json, (uint64_t)entry->args[i].u.pointer); in print_event_json() 255 spdk_json_write_uint64(g_json, entry->args[i].u.integer); in print_event_json() 258 spdk_json_write_string(g_json, entry->args[i].u.string); in print_event_json() 296 spdk_json_write_named_string(g_json, "name", tpoint->args[j].name); in print_tpoint_definitions() [all …]
|
| /spdk/lib/trace_parser/ |
| H A D | trace.cpp | 50 * offset needs to be adjusted to the start of the spdk_trace_entry.args array in argument_context() 52 offset = offsetof(spdk_trace_entry, args) - in argument_context() 130 pe->args[argid].is_related = false; in build_arg() 134 pe->args[argid].u.integer = 0; in build_arg() 148 if (argoff < sizeof(pe->args[0].u.string)) { in build_arg() 149 memcpy(&pe->args[argid].u.string[argoff], &buffer->data[argctx->offset], in build_arg() 150 spdk_min(curlen, sizeof(pe->args[0].u.string) - argoff)); in build_arg() 197 if (!build_arg(&argctx, &tpoint->args[i], i, pe)) { in next_entry() 211 (pe->args[tpoint->related_objects[i].arg_index].u.pointer)); in next_entry() 217 pe->args[tpoin in next_entry() [all...] |