Lines Matching defs:rpc
24 import spdk.rpc as rpc # noqa
25 from spdk.rpc.client import print_dict, print_json, JSONRPCException # noqa
26 from spdk.rpc.helpers import deprecated_aliases # noqa
56 help="Start listening on stdin, parse each line as a regular rpc.py execution and create \
60 pipes and can be used as a faster way to send RPC commands. If enabled, rpc.py \
67 rpc.framework_start_init(args.client)
73 rpc.framework_wait_init(args.client)
79 print_dict(rpc.rpc_get_methods(args.client,
89 print_json(rpc.spdk_get_version(args.client))
95 rpc.save_config(args.client,
108 rpc.load_config(args.client, args.json_conf,
117 rpc.save_subsystem_config(args.client,
130 rpc.load_subsystem_config(args.client,
139 rpc.app.spdk_kill_instance(args.client,
152 print_dict(rpc.app.framework_monitor_context_switch(args.client,
162 print_dict(rpc.app.framework_get_reactors(args.client))
169 rpc.app.framework_set_scheduler(args.client,
188 print_dict(rpc.app.framework_get_scheduler(args.client))
195 print_dict(rpc.app.framework_get_governor(args.client))
202 rpc.app.scheduler_set_options(args.client,
212 rpc.framework_disable_cpumask_locks(args.client)
219 rpc.framework_enable_cpumask_locks(args.client)
227 rpc.bdev.bdev_set_options(args.client,
247 rpc.bdev.bdev_examine(args.client,
256 rpc.bdev.bdev_wait_for_examine(args.client)
263 print_json(rpc.bdev.bdev_compress_create(args.client,
283 rpc.bdev.bdev_compress_delete(args.client,
291 print_dict(rpc.bdev.bdev_compress_get_orphans(args.client,
299 print_json(rpc.bdev.bdev_crypto_create(args.client,
318 rpc.bdev.bdev_crypto_delete(args.client,
326 print_json(rpc.bdev.bdev_ocf_create(args.client,
346 rpc.bdev.bdev_ocf_delete(args.client,
354 print_dict(rpc.bdev.bdev_ocf_get_stats(args.client,
361 print_dict(rpc.bdev.bdev_ocf_reset_stats(args.client,
368 print_dict(rpc.bdev.bdev_ocf_get_bdevs(args.client,
375 print_json(rpc.bdev.bdev_ocf_set_cache_mode(args.client,
385 rpc.bdev.bdev_ocf_set_seqcutoff(args.client,
402 rpc.bdev.bdev_ocf_flush_start(args.client, name=args.name)
409 print_json(rpc.bdev.bdev_ocf_flush_status(args.client, name=args.name))
417 print_json(rpc.bdev.bdev_malloc_create(args.client,
453 rpc.bdev.bdev_malloc_delete(args.client,
465 print_json(rpc.bdev.bdev_null_create(args.client,
495 rpc.bdev.bdev_null_delete(args.client,
503 print_json(rpc.bdev.bdev_null_resize(args.client,
514 print_json(rpc.bdev.bdev_aio_create(args.client,
532 print_json(rpc.bdev.bdev_aio_rescan(args.client,
540 rpc.bdev.bdev_aio_delete(args.client,
548 print_json(rpc.bdev.bdev_uring_create(args.client,
562 print_json(rpc.bdev.bdev_uring_rescan(args.client,
570 rpc.bdev.bdev_uring_delete(args.client,
578 print_json(rpc.bdev.bdev_xnvme_create(args.client,
592 rpc.bdev.bdev_xnvme_delete(args.client,
600 rpc.bdev.bdev_nvme_set_options(args.client,
727 rpc.bdev.bdev_nvme_set_hotplug(args.client, enable=args.enable, period_us=args.period_us)
737 print_array(rpc.bdev.bdev_nvme_attach_controller(args.client,
828 print_dict(rpc.nvme.bdev_nvme_get_controllers(args.client,
837 rpc.bdev.bdev_nvme_detach_controller(args.client,
866 rpc.bdev.bdev_nvme_reset_controller(args.client,
877 rpc.bdev.bdev_nvme_enable_controller(args.client,
888 rpc.bdev.bdev_nvme_disable_controller(args.client,
899 rpc.bdev.bdev_nvme_start_discovery(args.client,
952 rpc.bdev.bdev_nvme_stop_discovery(args.client, name=args.name)
959 print_dict(rpc.bdev.bdev_nvme_get_discovery_info(args.client))
965 print_dict(rpc.bdev.bdev_nvme_get_io_paths(args.client, name=args.name))
972 rpc.bdev.bdev_nvme_set_preferred_path(args.client,
983 rpc.bdev.bdev_nvme_set_multipath_policy(args.client,
1000 print_dict(rpc.bdev.bdev_nvme_get_path_iostat(args.client,
1010 rpc.bdev.bdev_nvme_cuse_register(args.client,
1020 rpc.bdev.bdev_nvme_cuse_unregister(args.client,
1030 rpc.bdev.bdev_nvme_set_keys(args.client, args.name, args.dhchap_key, args.dhchap_ctrlr_key)
1041 print_json(rpc.bdev.bdev_zone_block_create(args.client,
1056 rpc.bdev.bdev_zone_block_delete(args.client,
1072 print_json(rpc.bdev.bdev_rbd_register_cluster(args.client,
1092 rpc.bdev.bdev_rbd_unregister_cluster(args.client, name=args.name)
1100 print_json(rpc.bdev.bdev_rbd_get_clusters_info(args.client, name=args.name))
1116 print_json(rpc.bdev.bdev_rbd_create(args.client,
1139 rpc.bdev.bdev_rbd_delete(args.client,
1147 print_json(rpc.bdev.bdev_rbd_resize(args.client,
1158 print_json(rpc.bdev.bdev_delay_create(args.client,
1183 rpc.bdev.bdev_delay_delete(args.client,
1191 print_json(rpc.bdev.bdev_delay_update_latency(args.client,
1203 print_json(rpc.bdev.bdev_error_create(args.client,
1213 rpc.bdev.bdev_error_delete(args.client,
1221 rpc.bdev.bdev_iscsi_set_options(args.client,
1229 print_json(rpc.bdev.bdev_iscsi_create(args.client,
1242 rpc.bdev.bdev_iscsi_delete(args.client,
1250 print_json(rpc.bdev.bdev_passthru_create(args.client,
1262 rpc.bdev.bdev_passthru_delete(args.client,
1270 print_dict(rpc.bdev.bdev_get_bdevs(args.client,
1283 print_dict(rpc.bdev.bdev_get_iostat(args.client,
1297 rpc.bdev.bdev_reset_iostat(args.client, name=args.name, mode=args.mode)
1306 rpc.bdev.bdev_enable_histogram(args.client, name=args.name, enable=args.enable, opc=args.opc)
1318 print_dict(rpc.bdev.bdev_get_histogram(args.client, name=args.name))
1326 rpc.bdev.bdev_set_qd_sampling_period(args.client,
1339 rpc.bdev.bdev_set_qos_limit(args.client,
1364 rpc.bdev.bdev_error_inject_error(args.client,
1388 print_dict(rpc.bdev.bdev_nvme_apply_firmware(args.client,
1398 print_dict(rpc.bdev.bdev_nvme_get_transport_statistics(args.client))
1405 print_dict(rpc.bdev.bdev_nvme_get_controller_health_info(args.client,
1415 rpc.iscsi.iscsi_set_options(
1470 rpc.iscsi.iscsi_set_discovery_auth(
1493 rpc.iscsi.iscsi_create_auth_group(args.client, tag=args.tag, secrets=secrets)
1504 rpc.iscsi.iscsi_delete_auth_group(args.client, tag=args.tag)
1512 rpc.iscsi.iscsi_auth_group_add_secret(
1530 rpc.iscsi.iscsi_auth_group_remove_secret(args.client, tag=args.tag, user=args.user)
1539 print_dict(rpc.iscsi.iscsi_get_auth_groups(args.client))
1546 print_dict(rpc.iscsi.iscsi_get_portal_groups(args.client))
1552 print_dict(rpc.iscsi.iscsi_get_initiator_groups(args.client))
1559 print_dict(rpc.iscsi.iscsi_get_target_nodes(args.client))
1565 rpc.iscsi.iscsi_enable_histogram(args.client, name=args.name, enable=args.enable)
1575 print_dict(rpc.iscsi.iscsi_get_histogram(args.client, name=args.name))
1593 rpc.iscsi.iscsi_create_target_node(
1637 rpc.iscsi.iscsi_target_node_add_lun(
1653 rpc.iscsi.iscsi_target_node_set_auth(
1679 rpc.iscsi.iscsi_target_node_add_pg_ig_maps(
1699 rpc.iscsi.iscsi_target_node_remove_pg_ig_maps(
1713 rpc.iscsi.iscsi_target_node_set_redirect(
1730 rpc.iscsi.iscsi_target_node_request_logout(
1755 rpc.iscsi.iscsi_create_portal_group(
1778 rpc.iscsi.iscsi_start_portal_group(args.client, tag=args.tag)
1793 rpc.iscsi.iscsi_create_initiator_group(
1820 rpc.iscsi.iscsi_initiator_group_add_initiators(
1848 rpc.iscsi.iscsi_initiator_group_remove_initiators(
1866 rpc.iscsi.iscsi_delete_target_node(
1876 rpc.iscsi.iscsi_delete_portal_group(args.client, tag=args.tag)
1885 rpc.iscsi.iscsi_delete_initiator_group(args.client, tag=args.tag)
1894 rpc.iscsi.iscsi_portal_group_set_auth(
1916 print_dict(rpc.iscsi.iscsi_get_connections(args.client))
1923 print_dict(rpc.iscsi.iscsi_get_stats(args.client))
1930 print_dict(rpc.iscsi.iscsi_get_options(args.client))
1937 print_dict(rpc.iscsi.scsi_get_devices(args.client))
1944 rpc.trace.trace_enable_tpoint_group(args.client, name=args.name)
1954 rpc.trace.trace_disable_tpoint_group(args.client, name=args.name)
1964 rpc.trace.trace_set_tpoint_mask(args.client, name=args.name, tpoint_mask=args.tpoint_mask)
1978 rpc.trace.trace_clear_tpoint_mask(args.client, name=args.name, tpoint_mask=args.tpoint_mask)
1992 print_dict(rpc.trace.trace_get_tpoint_group_mask(args.client))
1998 print_dict(rpc.trace.trace_get_info(args.client))
2006 rpc.log.log_set_flag(args.client, flag=args.flag)
2014 rpc.log.log_clear_flag(args.client, flag=args.flag)
2022 print_dict(rpc.log.log_get_flags(args.client))
2028 rpc.log.log_set_level(args.client, level=args.level)
2035 print_dict(rpc.log.log_get_level(args.client))
2041 rpc.log.log_set_print_level(args.client, level=args.level)
2048 print_dict(rpc.log.log_get_print_level(args.client))
2058 print_json(rpc.lvol.bdev_lvol_create_lvstore(args.client,
2077 rpc.lvol.bdev_lvol_rename_lvstore(args.client,
2087 print_dict(rpc.lvol.bdev_lvol_grow_lvstore(args.client,
2098 print_json(rpc.lvol.bdev_lvol_create(args.client,
2117 print_json(rpc.lvol.bdev_lvol_snapshot(args.client,
2127 print_json(rpc.lvol.bdev_lvol_clone(args.client,
2137 print_json(rpc.lvol.bdev_lvol_clone_bdev(args.client,
2150 rpc.lvol.bdev_lvol_rename(args.client,
2160 rpc.lvol.bdev_lvol_inflate(args.client,
2168 rpc.lvol.bdev_lvol_decouple_parent(args.client,
2176 rpc.lvol.bdev_lvol_resize(args.client,
2186 rpc.lvol.bdev_lvol_set_read_only(args.client,
2194 rpc.lvol.bdev_lvol_delete(args.client,
2202 print_json(rpc.lvol.bdev_lvol_start_shallow_copy(args.client,
2214 print_json(rpc.lvol.bdev_lvol_check_shallow_copy(args.client,
2222 rpc.lvol.bdev_lvol_set_parent(args.client,
2232 rpc.lvol.bdev_lvol_set_parent_bdev(args.client,
2242 rpc.lvol.bdev_lvol_delete_lvstore(args.client,
2252 print_dict(rpc.lvol.bdev_lvol_get_lvstores(args.client,
2262 print_dict(rpc.lvol.bdev_lvol_get_lvols(args.client,
2272 rpc.bdev.bdev_raid_set_options(args.client,
2286 print_json(rpc.bdev.bdev_raid_get_bdevs(args.client,
2303 rpc.bdev.bdev_raid_create(args.client,
2321 rpc.bdev.bdev_raid_delete(args.client,
2328 rpc.bdev.bdev_raid_add_base_bdev(args.client,
2337 rpc.bdev.bdev_raid_remove_base_bdev(args.client,
2345 print_array(rpc.bdev.bdev_split_create(args.client,
2361 rpc.bdev.bdev_split_delete(args.client,
2370 print_dict(rpc.bdev.bdev_ftl_create(args.client,
2398 print_dict(rpc.bdev.bdev_ftl_load(args.client,
2425 print_dict(rpc.bdev.bdev_ftl_unload(args.client, name=args.name, fast_shutdown=args.fast_shutdown))
2433 print_dict(rpc.bdev.bdev_ftl_delete(args.client, name=args.name, fast_shutdown=args.fast_shutdown))
2441 print_dict(rpc.bdev.bdev_ftl_unmap(args.client, name=args.name,
2452 print_dict(rpc.bdev.bdev_ftl_get_stats(args.client, name=args.name))
2459 print_dict(rpc.bdev.bdev_ftl_get_properties(args.client, name=args.name))
2466 print_dict(rpc.bdev.bdev_ftl_set_property(args.client, name=args.name,
2478 print_dict(rpc.vmd.vmd_enable(args.client))
2484 print_dict(rpc.vmd.vmd_remove_device(args.client, addr=args.addr))
2491 print_dict(rpc.vmd.vmd_rescan(args.client))
2498 rpc.ublk.ublk_create_target(args.client,
2508 rpc.ublk.ublk_destroy_target(args.client)
2514 print(rpc.ublk.ublk_start_disk(args.client,
2529 rpc.ublk.ublk_stop_disk(args.client,
2538 print(rpc.ublk.ublk_recover_disk(args.client,
2549 print_dict(rpc.ublk.ublk_get_disks(args.client,
2559 print(rpc.nbd.nbd_start_disk(args.client,
2570 rpc.nbd.nbd_stop_disk(args.client,
2579 print_dict(rpc.nbd.nbd_get_disks(args.client,
2589 rpc.nvmf.nvmf_set_max_subsystems(args.client,
2598 rpc.nvmf.nvmf_set_config(args.client,
2618 rpc.nvmf.nvmf_create_transport(**vars(args))
2658 print_dict(rpc.nvmf.nvmf_get_transports(args.client, trtype=args.trtype, tgt_name=args.tgt_name))
2666 print_dict(rpc.nvmf.nvmf_get_subsystems(args.client, nqn=args.nqn, tgt_name=args.tgt_name))
2674 rpc.nvmf.nvmf_create_subsystem(args.client,
2710 rpc.nvmf.nvmf_delete_subsystem(args.client,
2721 rpc.nvmf.nvmf_subsystem_add_listener(**vars(args))
2736 rpc.nvmf.nvmf_subsystem_remove_listener(args.client,
2754 rpc.nvmf.nvmf_subsystem_listener_set_ana_state(args.client,
2776 rpc.nvmf.nvmf_discovery_add_referral(**vars(args))
2790 rpc.nvmf.nvmf_discovery_remove_referral(args.client,
2808 print_dict(rpc.nvmf.nvmf_discovery_get_referrals(args.client,
2817 rpc.nvmf.nvmf_subsystem_add_ns(**vars(args))
2836 rpc.nvmf.nvmf_subsystem_set_ns_ana_group(args.client,
2850 rpc.nvmf.nvmf_subsystem_remove_ns(args.client,
2862 rpc.nvmf.nvmf_ns_visible(True,
2880 rpc.nvmf.nvmf_ns_visible(False,
2892 rpc.nvmf.nvmf_subsystem_add_host(args.client,
2910 rpc.nvmf.nvmf_subsystem_remove_host(args.client,
2922 rpc.nvmf.nvmf_subsystem_set_keys(args.client,
2938 rpc.nvmf.nvmf_subsystem_allow_any_host(args.client,
2951 print_dict(rpc.nvmf.nvmf_subsystem_get_controllers(args.client,
2962 print_dict(rpc.nvmf.nvmf_subsystem_get_qpairs(args.client,
2973 print_dict(rpc.nvmf.nvmf_subsystem_get_listeners(args.client,
2984 print_dict(rpc.nvmf.nvmf_get_stats(args.client, tgt_name=args.tgt_name))
2992 print_dict(rpc.nvmf.nvmf_set_crdt(args.client, args.crdt1, args.crdt2, args.crdt3))
3004 rpc.nvmf.nvmf_publish_mdns_prr(args.client, args.tgt_name)
3012 rpc.nvmf.nvmf_stop_mdns_prr(args.client, args.tgt_name)
3021 print_dict(rpc.subsystem.framework_get_subsystems(args.client))
3029 print_dict(rpc.subsystem.framework_get_config(args.client, args.name))
3037 rpc.vhost.vhost_controller_set_coalescing(args.client,
3049 rpc.vhost.virtio_blk_create_transport(**vars(args))
3057 print_dict(rpc.vhost.virtio_blk_get_transports(args.client, name=args.name))
3064 rpc.vhost.vhost_create_scsi_controller(args.client,
3076 rpc.vhost.vhost_start_scsi_controller(args.client,
3084 print_json(rpc.vhost.vhost_scsi_controller_add_target(args.client,
3096 rpc.vhost.vhost_scsi_controller_remove_target(args.client,
3107 rpc.vhost.vhost_create_blk_controller(**vars(args))
3119 print_dict(rpc.vhost.vhost_get_controllers(args.client, args.name))
3126 rpc.vhost.vhost_delete_controller(args.client,
3134 print_array(rpc.vhost.bdev_virtio_attach_controller(args.client,
3159 print_dict(rpc.vhost.bdev_virtio_scsi_get_devices(args.client))
3165 rpc.vhost.bdev_virtio_detach_controller(args.client,
3174 rpc.vhost.bdev_virtio_blk_set_hotplug(args.client, enable=args.enable, period_us=args.period_us)
3185 rpc.vfio_user.vfu_tgt_set_base_path(args.client, path=args.path)
3192 rpc.vfio_user.vfu_virtio_delete_endpoint(args.client, name=args.name)
3199 rpc.vfio_user.vfu_virtio_create_blk_endpoint(args.client,
3217 rpc.vfio_user.vfu_virtio_scsi_add_target(args.client,
3229 rpc.vfio_user.vfu_virtio_scsi_remove_target(args.client,
3239 rpc.vfio_user.vfu_virtio_create_scsi_endpoint(args.client,
3255 rpc.vfio_user.vfu_virtio_create_fs_endpoint(args.client,
3276 print_dict(rpc.accel.accel_get_opc_assignments(args.client))
3282 print_dict(rpc.accel.accel_get_module_info(args.client))
3289 rpc.accel.accel_assign_opc(args.client, opname=args.opname, module=args.module)
3297 print_dict(rpc.accel.accel_crypto_key_create(args.client,
3313 print_dict(rpc.accel.accel_crypto_key_destroy(args.client,
3321 print_dict(rpc.accel.accel_crypto_keys_get(args.client,
3329 rpc.accel.accel_set_driver(args.client, name=args.name)
3337 rpc.accel.accel_set_options(args.client, args.small_cache_size, args.large_cache_size,
3349 print_dict(rpc.accel.accel_get_stats(args.client))
3356 rpc.ioat.ioat_scan_accel_module(args.client)
3364 rpc.compressdev.compressdev_scan_accel_module(args.client, pmd=args.pmd)
3372 rpc.dsa.dsa_scan_accel_module(args.client, config_kernel_mode=args.config_kernel_mode)
3382 rpc.iaa.iaa_scan_accel_module(args.client)
3389 rpc.dpdk_cryptodev.dpdk_cryptodev_scan_accel_module(args.client)
3396 rpc.dpdk_cryptodev.dpdk_cryptodev_set_driver(args.client,
3405 print_dict(rpc.dpdk_cryptodev.dpdk_cryptodev_get_driver(args.client))
3412 rpc.mlx5.mlx5_scan_accel_module(args.client,
3430 print_dict(rpc.mlx5.accel_mlx5_dump_stats(args.client, level=args.level))
3438 rpc.accel.accel_error_inject_error(args.client, opcode=args.opcode,
3455 rpc.nvme.bdev_nvme_opal_init(args.client,
3465 rpc.nvme.bdev_nvme_opal_revert(args.client,
3474 print_json(rpc.bdev.bdev_opal_create(args.client,
3492 print_dict(rpc.bdev.bdev_opal_get_info(args.client,
3502 rpc.bdev.bdev_opal_delete(args.client,
3512 rpc.bdev.bdev_opal_new_user(args.client,
3526 rpc.bdev.bdev_opal_set_lock_state(args.client,
3542 print_dict(rpc.nvme.bdev_nvme_send_cmd(args.client,
3568 print_dict(rpc.notify.notify_get_types(args.client))
3574 ret = rpc.notify.notify_get_notifications(args.client,
3585 print_dict(rpc.app.thread_get_stats(args.client))
3592 ret = rpc.app.thread_set_cpumask(args.client,
3603 ret = rpc.app.log_enable_timestamps(args.client,
3612 print_dict(rpc.app.thread_get_pollers(args.client))
3619 print_dict(rpc.app.thread_get_io_channels(args.client))
3626 print_dict(rpc.env_dpdk.env_dpdk_get_mem_stats(args.client))
3634 print(rpc.blobfs.blobfs_detect(args.client,
3642 print(rpc.blobfs.blobfs_create(args.client,
3653 print(rpc.blobfs.blobfs_mount(args.client,
3663 print(rpc.blobfs.blobfs_set_cache_size(args.client,
3672 print_json(rpc.fsdev.fsdev_get_opts(args.client))
3678 print(rpc.fsdev.fsdev_set_opts(args.client, fsdev_io_pool_size=args.fsdev_io_pool_size,
3687 print(rpc.fsdev.fsdev_aio_create(args.client, name=args.name, root_path=args.root_path,
3712 print(rpc.fsdev.fsdev_aio_delete(args.client, name=args.name))
3720 print_json(rpc.sock.sock_impl_get_options(args.client,
3728 rpc.sock.sock_impl_set_options(args.client,
3773 print_json(rpc.sock.sock_set_default_impl(args.client,
3781 print_json(rpc.sock.sock_get_default_impl(args.client))
3790 devices = rpc.subsystem.framework_get_pci_devices(args.client)
3807 print_dict(rpc.nvme.bdev_nvme_add_error_injection(args.client,
3832 print_dict(rpc.nvme.bdev_nvme_remove_error_injection(args.client,
3845 print_json(rpc.bdev.bdev_daos_create(args.client,
3866 rpc.bdev.bdev_daos_delete(args.client,
3875 print_json(rpc.bdev.bdev_daos_resize(args.client,
3886 rpc.iobuf.iobuf_set_options(args.client,
3901 print_dict(rpc.iobuf.iobuf_get_stats(args.client))
3907 rpc.bdev.bdev_nvme_start_mdns_discovery(args.client,
3919 rpc.bdev.bdev_nvme_stop_mdns_discovery(args.client, name=args.name)
3926 print_dict(rpc.bdev.bdev_nvme_get_mdns_discovery_info(args.client))
3932 rpc.keyring.keyring_file_add_key(args.client, args.name, args.path)
3940 rpc.keyring.keyring_file_remove_key(args.client, args.name)
3947 print_dict(rpc.keyring.keyring_get_keys(args.client))
3953 rpc.keyring.keyring_linux_set_options(args.client, args.enable)
4058 tmp_args.client = rpc.client.JSONRPCGoClient(tmp_args.server_addr,
4061 tmp_args.client = rpc.client.JSONRPCClient(
4077 args.client = rpc.client.JSONRPCGoClient(args.server_addr,
4084 args.client = rpc.client.JSONRPCClient(args.server_addr, args.port, args.timeout,