Lines Matching defs:args
66 def framework_start_init(args):
67 rpc.framework_start_init(args.client)
72 def framework_wait_init(args):
73 rpc.framework_wait_init(args.client)
78 def rpc_get_methods(args):
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):
89 print_json(rpc.spdk_get_version(args.client))
94 def save_config(args):
95 rpc.save_config(args.client,
97 indent=args.indent,
98 subsystems=args.subsystems)
107 def load_config(args):
108 rpc.load_config(args.client, args.json_conf,
109 include_aliases=args.include_aliases)
116 def save_subsystem_config(args):
117 rpc.save_subsystem_config(args.client,
119 indent=args.indent,
120 name=args.name)
129 def load_subsystem_config(args):
130 rpc.load_subsystem_config(args.client,
131 args.json_conf)
138 def spdk_kill_instance(args):
139 rpc.app.spdk_kill_instance(args.client,
140 sig_name=args.sig_name)
146 def framework_monitor_context_switch(args):
148 if args.enable:
150 if args.disable:
152 print_dict(rpc.app.framework_monitor_context_switch(args.client,
161 def framework_get_reactors(args):
162 print_dict(rpc.app.framework_get_reactors(args.client))
168 def framework_set_scheduler(args):
169 rpc.app.framework_set_scheduler(args.client,
170 name=args.name,
171 period=args.period,
172 load_limit=args.load_limit,
173 core_limit=args.core_limit,
174 core_busy=args.core_busy,
175 mappings=args.mappings)
187 def framework_get_scheduler(args):
188 print_dict(rpc.app.framework_get_scheduler(args.client))
194 def framework_get_governor(args):
195 print_dict(rpc.app.framework_get_governor(args.client))
201 def scheduler_set_options(args):
202 rpc.app.scheduler_set_options(args.client,
203 isolated_core_mask=args.isolated_core_mask,
204 scheduling_core=args.scheduling_core)
211 def framework_disable_cpumask_locks(args):
212 rpc.framework_disable_cpumask_locks(args.client)
218 def framework_enable_cpumask_locks(args):
219 rpc.framework_enable_cpumask_locks(args.client)
226 def bdev_set_options(args):
227 rpc.bdev.bdev_set_options(args.client,
228 bdev_io_pool_size=args.bdev_io_pool_size,
229 bdev_io_cache_size=args.bdev_io_cache_size,
230 bdev_auto_examine=args.bdev_auto_examine,
231 iobuf_small_cache_size=args.iobuf_small_cache_size,
232 iobuf_large_cache_size=args.iobuf_large_cache_size)
246 def bdev_examine(args):
247 rpc.bdev.bdev_examine(args.client,
248 name=args.name)
255 def bdev_wait_for_examine(args):
256 rpc.bdev.bdev_wait_for_examine(args.client)
262 def bdev_compress_create(args):
263 print_json(rpc.bdev.bdev_compress_create(args.client,
264 base_bdev_name=args.base_bdev_name,
265 pm_path=args.pm_path,
266 lb_size=args.lb_size,
267 comp_algo=args.comp_algo,
268 comp_level=args.comp_level))
282 def bdev_compress_delete(args):
283 rpc.bdev.bdev_compress_delete(args.client,
284 name=args.name)
290 def bdev_compress_get_orphans(args):
291 print_dict(rpc.bdev.bdev_compress_get_orphans(args.client,
292 name=args.name))
298 def bdev_crypto_create(args):
299 print_json(rpc.bdev.bdev_crypto_create(args.client,
300 base_bdev_name=args.base_bdev_name,
301 name=args.name,
302 crypto_pmd=args.crypto_pmd,
303 key=args.key,
304 cipher=args.cipher,
305 key2=args.key2,
306 key_name=args.key_name))
317 def bdev_crypto_delete(args):
318 rpc.bdev.bdev_crypto_delete(args.client,
319 name=args.name)
325 def bdev_ocf_create(args):
326 print_json(rpc.bdev.bdev_ocf_create(args.client,
327 name=args.name,
328 mode=args.mode,
329 cache_line_size=args.cache_line_size,
330 cache_bdev_name=args.cache_bdev_name,
331 core_bdev_name=args.core_bdev_name))
345 def bdev_ocf_delete(args):
346 rpc.bdev.bdev_ocf_delete(args.client,
347 name=args.name)
353 def bdev_ocf_get_stats(args):
354 print_dict(rpc.bdev.bdev_ocf_get_stats(args.client,
355 name=args.name))
360 def bdev_ocf_reset_stats(args):
361 print_dict(rpc.bdev.bdev_ocf_reset_stats(args.client,
362 name=args.name))
367 def bdev_ocf_get_bdevs(args):
368 print_dict(rpc.bdev.bdev_ocf_get_bdevs(args.client,
369 name=args.name))
374 def bdev_ocf_set_cache_mode(args):
375 print_json(rpc.bdev.bdev_ocf_set_cache_mode(args.client,
376 name=args.name,
377 mode=args.mode))
384 def bdev_ocf_set_seqcutoff(args):
385 rpc.bdev.bdev_ocf_set_seqcutoff(args.client,
386 name=args.name,
387 policy=args.policy,
388 threshold=args.threshold,
389 promotion_count=args.promotion_count)
401 def bdev_ocf_flush_start(args):
402 rpc.bdev.bdev_ocf_flush_start(args.client, name=args.name)
408 def bdev_ocf_flush_status(args):
409 print_json(rpc.bdev.bdev_ocf_flush_status(args.client, name=args.name))
415 def bdev_malloc_create(args):
416 num_blocks = (args.total_size * 1024 * 1024) // args.block_size
417 print_json(rpc.bdev.bdev_malloc_create(args.client,
419 block_size=args.block_size,
420 physical_block_size=args.physical_block_size,
421 name=args.name,
422 uuid=args.uuid,
423 optimal_io_boundary=args.optimal_io_boundary,
424 md_size=args.md_size,
425 md_interleave=args.md_interleave,
426 dif_type=args.dif_type,
427 dif_is_head_of_md=args.dif_is_head_of_md,
428 dif_pi_format=args.dif_pi_format))
452 def bdev_malloc_delete(args):
453 rpc.bdev.bdev_malloc_delete(args.client,
454 name=args.name)
460 def bdev_null_create(args):
461 num_blocks = (args.total_size * 1024 * 1024) // args.block_size
462 if args.dif_type and not args.md_size:
465 print_json(rpc.bdev.bdev_null_create(args.client,
467 block_size=args.block_size,
468 physical_block_size=args.physical_block_size,
469 name=args.name,
470 uuid=args.uuid,
471 md_size=args.md_size,
472 dif_type=args.dif_type,
473 dif_is_head_of_md=args.dif_is_head_of_md,
474 dif_pi_format=args.dif_pi_format))
494 def bdev_null_delete(args):
495 rpc.bdev.bdev_null_delete(args.client,
496 name=args.name)
502 def bdev_null_resize(args):
503 print_json(rpc.bdev.bdev_null_resize(args.client,
504 name=args.name,
505 new_size=int(args.new_size)))
513 def bdev_aio_create(args):
514 print_json(rpc.bdev.bdev_aio_create(args.client,
515 filename=args.filename,
516 name=args.name,
517 block_size=args.block_size,
518 readonly=args.readonly,
519 fallocate=args.fallocate,
520 uuid=args.uuid))
531 def bdev_aio_rescan(args):
532 print_json(rpc.bdev.bdev_aio_rescan(args.client,
533 name=args.name))
539 def bdev_aio_delete(args):
540 rpc.bdev.bdev_aio_delete(args.client,
541 name=args.name)
547 def bdev_uring_create(args):
548 print_json(rpc.bdev.bdev_uring_create(args.client,
549 filename=args.filename,
550 name=args.name,
551 block_size=args.block_size,
552 uuid=args.uuid))
561 def bdev_uring_rescan(args):
562 print_json(rpc.bdev.bdev_uring_rescan(args.client,
563 name=args.name))
569 def bdev_uring_delete(args):
570 rpc.bdev.bdev_uring_delete(args.client,
571 name=args.name)
577 def bdev_xnvme_create(args):
578 print_json(rpc.bdev.bdev_xnvme_create(args.client,
579 filename=args.filename,
580 name=args.name,
581 io_mechanism=args.io_mechanism,
582 conserve_cpu=args.conserve_cpu))
591 def bdev_xnvme_delete(args):
592 rpc.bdev.bdev_xnvme_delete(args.client,
593 name=args.name)
599 def bdev_nvme_set_options(args):
600 rpc.bdev.bdev_nvme_set_options(args.client,
601 action_on_timeout=args.action_on_timeout,
602 timeout_us=args.timeout_us,
603 timeout_admin_us=args.timeout_admin_us,
604 keep_alive_timeout_ms=args.keep_alive_timeout_ms,
605 arbitration_burst=args.arbitration_burst,
606 low_priority_weight=args.low_priority_weight,
607 medium_priority_weight=args.medium_priority_weight,
608 high_priority_weight=args.high_priority_weight,
609 nvme_adminq_poll_period_us=args.nvme_adminq_poll_period_us,
610 nvme_ioq_poll_period_us=args.nvme_ioq_poll_period_us,
611 io_queue_requests=args.io_queue_requests,
612 delay_cmd_submit=args.delay_cmd_submit,
613 transport_retry_count=args.transport_retry_count,
614 bdev_retry_count=args.bdev_retry_count,
615 transport_ack_timeout=args.transport_ack_timeout,
616 ctrlr_loss_timeout_sec=args.ctrlr_loss_timeout_sec,
617 reconnect_delay_sec=args.reconnect_delay_sec,
618 fast_io_fail_timeout_sec=args.fast_io_fail_timeout_sec,
619 disable_auto_failback=args.disable_auto_failback,
620 generate_uuids=args.generate_uuids,
621 transport_tos=args.transport_tos,
622 nvme_error_stat=args.nvme_error_stat,
623 rdma_srq_size=args.rdma_srq_size,
624 io_path_stat=args.io_path_stat,
625 allow_accel_sequence=args.allow_accel_sequence,
626 rdma_max_cq_size=args.rdma_max_cq_size,
627 rdma_cm_event_timeout_ms=args.rdma_cm_event_timeout_ms,
628 dhchap_digests=args.dhchap_digests,
629 dhchap_dhgroups=args.dhchap_dhgroups,
630 rdma_umr_per_io=args.rdma_umr_per_io)
726 def bdev_nvme_set_hotplug(args):
727 rpc.bdev.bdev_nvme_set_hotplug(args.client, enable=args.enable, period_us=args.period_us)
736 def bdev_nvme_attach_controller(args):
737 print_array(rpc.bdev.bdev_nvme_attach_controller(args.client,
738 name=args.name,
739 trtype=args.trtype,
740 traddr=args.traddr,
741 adrfam=args.adrfam,
742 trsvcid=args.trsvcid,
743 priority=args.priority,
744 subnqn=args.subnqn,
745 hostnqn=args.hostnqn,
746 hostaddr=args.hostaddr,
747 hostsvcid=args.hostsvcid,
748 prchk_reftag=args.prchk_reftag,
749 prchk_guard=args.prchk_guard,
750 hdgst=args.hdgst,
751 ddgst=args.ddgst,
752 fabrics_connect_timeout_us=args.fabrics_connect_timeout_us,
753 multipath=args.multipath,
754 num_io_queues=args.num_io_queues,
755 ctrlr_loss_timeout_sec=args.ctrlr_loss_timeout_sec,
756 reconnect_delay_sec=args.reconnect_delay_sec,
757 fast_io_fail_timeout_sec=args.fast_io_fail_timeout_sec,
758 psk=args.psk,
759 max_bdevs=args.max_bdevs,
760 dhchap_key=args.dhchap_key,
761 dhchap_ctrlr_key=args.dhchap_ctrlr_key,
762 allow_unrecognized_csi=args.allow_unrecognized_csi))
827 def bdev_nvme_get_controllers(args):
828 print_dict(rpc.nvme.bdev_nvme_get_controllers(args.client,
829 name=args.name))
836 def bdev_nvme_detach_controller(args):
837 rpc.bdev.bdev_nvme_detach_controller(args.client,
838 name=args.name,
839 trtype=args.trtype,
840 traddr=args.traddr,
841 adrfam=args.adrfam,
842 trsvcid=args.trsvcid,
843 subnqn=args.subnqn,
844 hostaddr=args.hostaddr,
845 hostsvcid=args.hostsvcid)
865 def bdev_nvme_reset_controller(args):
866 rpc.bdev.bdev_nvme_reset_controller(args.client,
867 name=args.name,
868 cntlid=args.cntlid)
876 def bdev_nvme_enable_controller(args):
877 rpc.bdev.bdev_nvme_enable_controller(args.client,
878 name=args.name,
879 cntlid=args.cntlid)
887 def bdev_nvme_disable_controller(args):
888 rpc.bdev.bdev_nvme_disable_controller(args.client,
889 name=args.name,
890 cntlid=args.cntlid)
898 def bdev_nvme_start_discovery(args):
899 rpc.bdev.bdev_nvme_start_discovery(args.client,
900 name=args.name,
901 trtype=args.trtype,
902 traddr=args.traddr,
903 adrfam=args.adrfam,
904 trsvcid=args.trsvcid,
905 hostnqn=args.hostnqn,
906 wait_for_attach=args.wait_for_attach,
907 attach_timeout_ms=args.attach_timeout_ms,
908 ctrlr_loss_timeout_sec=args.ctrlr_loss_timeout_sec,
909 reconnect_delay_sec=args.reconnect_delay_sec,
910 fast_io_fail_timeout_sec=args.fast_io_fail_timeout_sec)
951 def bdev_nvme_stop_discovery(args):
952 rpc.bdev.bdev_nvme_stop_discovery(args.client, name=args.name)
958 def bdev_nvme_get_discovery_info(args):
959 print_dict(rpc.bdev.bdev_nvme_get_discovery_info(args.client))
964 def bdev_nvme_get_io_paths(args):
965 print_dict(rpc.bdev.bdev_nvme_get_io_paths(args.client, name=args.name))
971 def bdev_nvme_set_preferred_path(args):
972 rpc.bdev.bdev_nvme_set_preferred_path(args.client,
973 name=args.name,
974 cntlid=args.cntlid)
982 def bdev_nvme_set_multipath_policy(args):
983 rpc.bdev.bdev_nvme_set_multipath_policy(args.client,
984 name=args.name,
985 policy=args.policy,
986 selector=args.selector,
987 rr_min_io=args.rr_min_io)
999 def bdev_nvme_get_path_iostat(args):
1000 print_dict(rpc.bdev.bdev_nvme_get_path_iostat(args.client,
1001 name=args.name))
1009 def bdev_nvme_cuse_register(args):
1010 rpc.bdev.bdev_nvme_cuse_register(args.client,
1011 name=args.name)
1019 def bdev_nvme_cuse_unregister(args):
1020 rpc.bdev.bdev_nvme_cuse_unregister(args.client,
1021 name=args.name)
1029 def bdev_nvme_set_keys(args):
1030 rpc.bdev.bdev_nvme_set_keys(args.client, args.name, args.dhchap_key, args.dhchap_ctrlr_key)
1040 def bdev_zone_block_create(args):
1041 print_json(rpc.bdev.bdev_zone_block_create(args.client,
1042 name=args.name,
1043 base_bdev=args.base_bdev,
1044 zone_capacity=args.zone_capacity,
1045 optimal_open_zones=args.optimal_open_zones))
1055 def bdev_zone_block_delete(args):
1056 rpc.bdev.bdev_zone_block_delete(args.client,
1057 name=args.name)
1063 def bdev_rbd_register_cluster(args):
1065 if args.config_param:
1067 for entry in args.config_param:
1072 print_json(rpc.bdev.bdev_rbd_register_cluster(args.client,
1073 name=args.name,
1074 user_id=args.user,
1076 config_file=args.config_file,
1077 key_file=args.key_file,
1078 core_mask=args.core_mask))
1091 def bdev_rbd_unregister_cluster(args):
1092 rpc.bdev.bdev_rbd_unregister_cluster(args.client, name=args.name)
1099 def bdev_rbd_get_clusters_info(args):
1100 print_json(rpc.bdev.bdev_rbd_get_clusters_info(args.client, name=args.name))
1107 def bdev_rbd_create(args):
1109 if args.config:
1111 for entry in args.config:
1116 print_json(rpc.bdev.bdev_rbd_create(args.client,
1117 name=args.name,
1118 user_id=args.user,
1120 pool_name=args.pool_name,
1121 rbd_name=args.rbd_name,
1122 block_size=args.block_size,
1123 cluster_name=args.cluster_name,
1124 uuid=args.uuid))
1138 def bdev_rbd_delete(args):
1139 rpc.bdev.bdev_rbd_delete(args.client,
1140 name=args.name)
1146 def bdev_rbd_resize(args):
1147 print_json(rpc.bdev.bdev_rbd_resize(args.client,
1148 name=args.name,
1149 new_size=int(args.new_size)))
1157 def bdev_delay_create(args):
1158 print_json(rpc.bdev.bdev_delay_create(args.client,
1159 base_bdev_name=args.base_bdev_name,
1160 name=args.name,
1161 uuid=args.uuid,
1162 avg_read_latency=args.avg_read_latency,
1163 p99_read_latency=args.nine_nine_read_latency,
1164 avg_write_latency=args.avg_write_latency,
1165 p99_write_latency=args.nine_nine_write_latency))
1182 def bdev_delay_delete(args):
1183 rpc.bdev.bdev_delay_delete(args.client,
1184 name=args.name)
1190 def bdev_delay_update_latency(args):
1191 print_json(rpc.bdev.bdev_delay_update_latency(args.client,
1192 delay_bdev_name=args.delay_bdev_name,
1193 latency_type=args.latency_type,
1194 latency_us=args.latency_us))
1202 def bdev_error_create(args):
1203 print_json(rpc.bdev.bdev_error_create(args.client,
1204 base_name=args.base_name,
1205 uuid=args.uuid))
1212 def bdev_error_delete(args):
1213 rpc.bdev.bdev_error_delete(args.client,
1214 name=args.name)
1220 def bdev_iscsi_set_options(args):
1221 rpc.bdev.bdev_iscsi_set_options(args.client,
1222 timeout_sec=args.timeout_sec)
1228 def bdev_iscsi_create(args):
1229 print_json(rpc.bdev.bdev_iscsi_create(args.client,
1230 name=args.name,
1231 url=args.url,
1232 initiator_iqn=args.initiator_iqn))
1241 def bdev_iscsi_delete(args):
1242 rpc.bdev.bdev_iscsi_delete(args.client,
1243 name=args.name)
1249 def bdev_passthru_create(args):
1250 print_json(rpc.bdev.bdev_passthru_create(args.client,
1251 base_bdev_name=args.base_bdev_name,
1252 name=args.name,
1253 uuid=args.uuid))
1261 def bdev_passthru_delete(args):
1262 rpc.bdev.bdev_passthru_delete(args.client,
1263 name=args.name)
1269 def bdev_get_bdevs(args):
1270 print_dict(rpc.bdev.bdev_get_bdevs(args.client,
1271 name=args.name, timeout=args.timeout_ms))
1282 def bdev_get_iostat(args):
1283 print_dict(rpc.bdev.bdev_get_iostat(args.client,
1284 name=args.name,
1285 per_channel=args.per_channel,
1286 reset_mode=args.reset_mode))
1296 def bdev_reset_iostat(args):
1297 rpc.bdev.bdev_reset_iostat(args.client, name=args.name, mode=args.mode)
1305 def bdev_enable_histogram(args):
1306 rpc.bdev.bdev_enable_histogram(args.client, name=args.name, enable=args.enable, opc=args.opc)
1317 def bdev_get_histogram(args):
1318 print_dict(rpc.bdev.bdev_get_histogram(args.client, name=args.name))
1325 def bdev_set_qd_sampling_period(args):
1326 rpc.bdev.bdev_set_qd_sampling_period(args.client,
1327 name=args.name,
1328 period=args.period)
1338 def bdev_set_qos_limit(args):
1339 rpc.bdev.bdev_set_qos_limit(args.client,
1340 name=args.name,
1341 rw_ios_per_sec=args.rw_ios_per_sec,
1342 rw_mbytes_per_sec=args.rw_mbytes_per_sec,
1343 r_mbytes_per_sec=args.r_mbytes_per_sec,
1344 w_mbytes_per_sec=args.w_mbytes_per_sec)
1363 def bdev_error_inject_error(args):
1364 rpc.bdev.bdev_error_inject_error(args.client,
1365 name=args.name,
1366 io_type=args.io_type,
1367 error_type=args.error_type,
1368 num=args.num,
1369 queue_depth=args.queue_depth,
1370 corrupt_offset=args.corrupt_offset,
1371 corrupt_value=args.corrupt_value)
1387 def bdev_nvme_apply_firmware(args):
1388 print_dict(rpc.bdev.bdev_nvme_apply_firmware(args.client,
1389 bdev_name=args.bdev_name,
1390 filename=args.filename))
1397 def bdev_nvme_get_transport_statistics(args):
1398 print_dict(rpc.bdev.bdev_nvme_get_transport_statistics(args.client))
1404 def bdev_nvme_get_controller_health_info(args):
1405 print_dict(rpc.bdev.bdev_nvme_get_controller_health_info(args.client,
1406 name=args.name))
1414 def iscsi_set_options(args):
1416 args.client,
1417 auth_file=args.auth_file,
1418 node_base=args.node_base,
1419 nop_timeout=args.nop_timeout,
1420 nop_in_interval=args.nop_in_interval,
1421 disable_chap=args.disable_chap,
1422 require_chap=args.require_chap,
1423 mutual_chap=args.mutual_chap,
1424 chap_group=args.chap_group,
1425 max_sessions=args.max_sessions,
1426 max_queue_depth=args.max_queue_depth,
1427 max_connections_per_session=args.max_connections_per_session,
1428 default_time2wait=args.default_time2wait,
1429 default_time2retain=args.default_time2retain,
1430 first_burst_length=args.first_burst_length,
1431 immediate_data=args.immediate_data,
1432 error_recovery_level=args.error_recovery_level,
1433 allow_duplicated_isid=args.allow_duplicated_isid,
1434 max_large_datain_per_connection=args.max_large_datain_per_connection,
1435 max_r2t_per_connection=args.max_r2t_per_connection,
1436 pdu_pool_size=args.pdu_pool_size,
1437 immediate_data_pool_size=args.immediate_data_pool_size,
1438 data_out_pool_size=args.data_out_pool_size)
1469 def iscsi_set_discovery_auth(args):
1471 args.client,
1472 disable_chap=args.disable_chap,
1473 require_chap=args.require_chap,
1474 mutual_chap=args.mutual_chap,
1475 chap_group=args.chap_group)
1488 def iscsi_create_auth_group(args):
1490 if args.secrets:
1491 secrets = [dict(u.split(":") for u in a.split(" ")) for a in args.secrets.split(",")]
1493 rpc.iscsi.iscsi_create_auth_group(args.client, tag=args.tag, secrets=secrets)
1503 def iscsi_delete_auth_group(args):
1504 rpc.iscsi.iscsi_delete_auth_group(args.client, tag=args.tag)
1511 def iscsi_auth_group_add_secret(args):
1513 args.client,
1514 tag=args.tag,
1515 user=args.user,
1516 secret=args.secret,
1517 muser=args.muser,
1518 msecret=args.msecret)
1529 def iscsi_auth_group_remove_secret(args):
1530 rpc.iscsi.iscsi_auth_group_remove_secret(args.client, tag=args.tag, user=args.user)
1538 def iscsi_get_auth_groups(args):
1539 print_dict(rpc.iscsi.iscsi_get_auth_groups(args.client))
1545 def iscsi_get_portal_groups(args):
1546 print_dict(rpc.iscsi.iscsi_get_portal_groups(args.client))
1551 def iscsi_get_initiator_groups(args):
1552 print_dict(rpc.iscsi.iscsi_get_initiator_groups(args.client))
1558 def iscsi_get_target_nodes(args):
1559 print_dict(rpc.iscsi.iscsi_get_target_nodes(args.client))
1564 def iscsi_enable_histogram(args):
1565 rpc.iscsi.iscsi_enable_histogram(args.client, name=args.name, enable=args.enable)
1574 def iscsi_get_histogram(args):
1575 print_dict(rpc.iscsi.iscsi_get_histogram(args.client, name=args.name))
1582 def iscsi_create_target_node(args):
1584 for u in args.bdev_name_id_pairs.strip().split(" "):
1589 for u in args.pg_ig_mappings.strip().split(" "):
1594 args.client,
1597 name=args.name,
1598 alias_name=args.alias_name,
1599 queue_depth=args.queue_depth,
1600 chap_group=args.chap_group,
1601 disable_chap=args.disable_chap,
1602 require_chap=args.require_chap,
1603 mutual_chap=args.mutual_chap,
1604 header_digest=args.header_digest,
1605 data_digest=args.data_digest)
1636 def iscsi_target_node_add_lun(args):
1638 args.client,
1639 name=args.name,
1640 bdev_name=args.bdev_name,
1641 lun_id=args.lun_id)
1652 def iscsi_target_node_set_auth(args):
1654 args.client,
1655 name=args.name,
1656 chap_group=args.chap_group,
1657 disable_chap=args.disable_chap,
1658 require_chap=args.require_chap,
1659 mutual_chap=args.mutual_chap)
1674 def iscsi_target_node_add_pg_ig_maps(args):
1676 for u in args.pg_ig_mappings.strip().split(" "):
1680 args.client,
1682 name=args.name)
1694 def iscsi_target_node_remove_pg_ig_maps(args):
1696 for u in args.pg_ig_mappings.strip().split(" "):
1700 args.client, pg_ig_maps=pg_ig_maps, name=args.name)
1712 def iscsi_target_node_set_redirect(args):
1714 args.client,
1715 name=args.name,
1716 pg_tag=args.pg_tag,
1717 redirect_host=args.redirect_host,
1718 redirect_port=args.redirect_port)
1729 def iscsi_target_node_request_logout(args):
1731 args.client,
1732 name=args.name,
1733 pg_tag=args.pg_tag)
1742 def iscsi_create_portal_group(args):
1744 for p in args.portal_list.strip().split(' '):
1756 args.client,
1758 tag=args.tag,
1759 private=args.private,
1760 wait=args.wait)
1777 def iscsi_start_portal_group(args):
1778 rpc.iscsi.iscsi_start_portal_group(args.client, tag=args.tag)
1786 def iscsi_create_initiator_group(args):
1789 for i in args.initiator_list.strip().split(' '):
1791 for n in args.netmask_list.strip().split(' '):
1794 args.client,
1795 tag=args.tag,
1809 def iscsi_initiator_group_add_initiators(args):
1812 if args.initiator_list:
1814 for i in args.initiator_list.strip().split(' '):
1816 if args.netmask_list:
1818 for n in args.netmask_list.strip().split(' '):
1821 args.client,
1822 tag=args.tag,
1837 def iscsi_initiator_group_remove_initiators(args):
1840 if args.initiator_list:
1842 for i in args.initiator_list.strip().split(' '):
1844 if args.netmask_list:
1846 for n in args.netmask_list.strip().split(' '):
1849 args.client,
1850 tag=args.tag,
1865 def iscsi_delete_target_node(args):
1867 args.client, target_node_name=args.target_node_name)
1875 def iscsi_delete_portal_group(args):
1876 rpc.iscsi.iscsi_delete_portal_group(args.client, tag=args.tag)
1884 def iscsi_delete_initiator_group(args):
1885 rpc.iscsi.iscsi_delete_initiator_group(args.client, tag=args.tag)
1893 def iscsi_portal_group_set_auth(args):
1895 args.client,
1896 tag=args.tag,
1897 chap_group=args.chap_group,
1898 disable_chap=args.disable_chap,
1899 require_chap=args.require_chap,
1900 mutual_chap=args.mutual_chap)
1915 def iscsi_get_connections(args):
1916 print_dict(rpc.iscsi.iscsi_get_connections(args.client))
1922 def iscsi_get_stats(args):
1923 print_dict(rpc.iscsi.iscsi_get_stats(args.client))
1929 def iscsi_get_options(args):
1930 print_dict(rpc.iscsi.iscsi_get_options(args.client))
1936 def scsi_get_devices(args):
1937 print_dict(rpc.iscsi.scsi_get_devices(args.client))
1943 def trace_enable_tpoint_group(args):
1944 rpc.trace.trace_enable_tpoint_group(args.client, name=args.name)
1953 def trace_disable_tpoint_group(args):
1954 rpc.trace.trace_disable_tpoint_group(args.client, name=args.name)
1963 def trace_set_tpoint_mask(args):
1964 rpc.trace.trace_set_tpoint_mask(args.client, name=args.name, tpoint_mask=args.tpoint_mask)
1977 def trace_clear_tpoint_mask(args):
1978 rpc.trace.trace_clear_tpoint_mask(args.client, name=args.name, tpoint_mask=args.tpoint_mask)
1991 def trace_get_tpoint_group_mask(args):
1992 print_dict(rpc.trace.trace_get_tpoint_group_mask(args.client))
1997 def trace_get_info(args):
1998 print_dict(rpc.trace.trace_get_info(args.client))
2005 def log_set_flag(args):
2006 rpc.log.log_set_flag(args.client, flag=args.flag)
2013 def log_clear_flag(args):
2014 rpc.log.log_clear_flag(args.client, flag=args.flag)
2021 def log_get_flags(args):
2022 print_dict(rpc.log.log_get_flags(args.client))
2027 def log_set_level(args):
2028 rpc.log.log_set_level(args.client, level=args.level)
2034 def log_get_level(args):
2035 print_dict(rpc.log.log_get_level(args.client))
2040 def log_set_print_level(args):
2041 rpc.log.log_set_print_level(args.client, level=args.level)
2047 def log_get_print_level(args):
2048 print_dict(rpc.log.log_get_print_level(args.client))
2054 def bdev_lvol_create_lvstore(args):
2056 if args.timeout is None:
2057 args.client.timeout = 90.0
2058 print_json(rpc.lvol.bdev_lvol_create_lvstore(args.client,
2059 bdev_name=args.bdev_name,
2060 lvs_name=args.lvs_name,
2061 cluster_sz=args.cluster_sz,
2062 clear_method=args.clear_method,
2063 num_md_pages_per_cluster_ratio=args.md_pages_per_cluster_ratio,
2064 md_page_size=args.md_page_size))
2076 def bdev_lvol_rename_lvstore(args):
2077 rpc.lvol.bdev_lvol_rename_lvstore(args.client,
2078 old_name=args.old_name,
2079 new_name=args.new_name)
2086 def bdev_lvol_grow_lvstore(args):
2087 print_dict(rpc.lvol.bdev_lvol_grow_lvstore(args.client,
2088 uuid=args.uuid,
2089 lvs_name=args.lvs_name))
2097 def bdev_lvol_create(args):
2098 print_json(rpc.lvol.bdev_lvol_create(args.client,
2099 lvol_name=args.lvol_name,
2100 size_in_mib=args.size_in_mib,
2101 thin_provision=args.thin_provision,
2102 clear_method=args.clear_method,
2103 uuid=args.uuid,
2104 lvs_name=args.lvs_name))
2116 def bdev_lvol_snapshot(args):
2117 print_json(rpc.lvol.bdev_lvol_snapshot(args.client,
2118 lvol_name=args.lvol_name,
2119 snapshot_name=args.snapshot_name))
2126 def bdev_lvol_clone(args):
2127 print_json(rpc.lvol.bdev_lvol_clone(args.client,
2128 snapshot_name=args.snapshot_name,
2129 clone_name=args.clone_name))
2136 def bdev_lvol_clone_bdev(args):
2137 print_json(rpc.lvol.bdev_lvol_clone_bdev(args.client,
2138 bdev=args.bdev,
2139 lvs_name=args.lvs_name,
2140 clone_name=args.clone_name))
2149 def bdev_lvol_rename(args):
2150 rpc.lvol.bdev_lvol_rename(args.client,
2151 old_name=args.old_name,
2152 new_name=args.new_name)
2159 def bdev_lvol_inflate(args):
2160 rpc.lvol.bdev_lvol_inflate(args.client,
2161 name=args.name)
2167 def bdev_lvol_decouple_parent(args):
2168 rpc.lvol.bdev_lvol_decouple_parent(args.client,
2169 name=args.name)
2175 def bdev_lvol_resize(args):
2176 rpc.lvol.bdev_lvol_resize(args.client,
2177 name=args.name,
2178 size_in_mib=args.size_in_mib)
2185 def bdev_lvol_set_read_only(args):
2186 rpc.lvol.bdev_lvol_set_read_only(args.client,
2187 name=args.name)
2193 def bdev_lvol_delete(args):
2194 rpc.lvol.bdev_lvol_delete(args.client,
2195 name=args.name)
2201 def bdev_lvol_start_shallow_copy(args):
2202 print_json(rpc.lvol.bdev_lvol_start_shallow_copy(args.client,
2203 src_lvol_name=args.src_lvol_name,
2204 dst_bdev_name=args.dst_bdev_name))
2213 def bdev_lvol_check_shallow_copy(args):
2214 print_json(rpc.lvol.bdev_lvol_check_shallow_copy(args.client,
2215 operation_id=args.operation_id))
2221 def bdev_lvol_set_parent(args):
2222 rpc.lvol.bdev_lvol_set_parent(args.client,
2223 lvol_name=args.lvol_name,
2224 parent_name=args.parent_name)
2231 def bdev_lvol_set_parent_bdev(args):
2232 rpc.lvol.bdev_lvol_set_parent_bdev(args.client,
2233 lvol_name=args.lvol_name,
2234 parent_name=args.parent_name)
2241 def bdev_lvol_delete_lvstore(args):
2242 rpc.lvol.bdev_lvol_delete_lvstore(args.client,
2243 uuid=args.uuid,
2244 lvs_name=args.lvs_name)
2251 def bdev_lvol_get_lvstores(args):
2252 print_dict(rpc.lvol.bdev_lvol_get_lvstores(args.client,
2253 uuid=args.uuid,
2254 lvs_name=args.lvs_name))
2261 def bdev_lvol_get_lvols(args):
2262 print_dict(rpc.lvol.bdev_lvol_get_lvols(args.client,
2263 lvs_uuid=args.lvs_uuid,
2264 lvs_name=args.lvs_name))
2271 def bdev_raid_set_options(args):
2272 rpc.bdev.bdev_raid_set_options(args.client,
2273 process_window_size_kb=args.process_window_size_kb,
2274 process_max_bandwidth_mb_sec=args.process_max_bandwidth_mb_sec)
2285 def bdev_raid_get_bdevs(args):
2286 print_json(rpc.bdev.bdev_raid_get_bdevs(args.client,
2287 category=args.category))
2298 def bdev_raid_create(args):
2300 for u in args.base_bdevs.strip().split():
2303 rpc.bdev.bdev_raid_create(args.client,
2304 name=args.name,
2305 strip_size_kb=args.strip_size_kb,
2306 raid_level=args.raid_level,
2308 uuid=args.uuid,
2309 superblock=args.superblock)
2320 def bdev_raid_delete(args):
2321 rpc.bdev.bdev_raid_delete(args.client,
2322 name=args.name)
2327 def bdev_raid_add_base_bdev(args):
2328 rpc.bdev.bdev_raid_add_base_bdev(args.client,
2329 raid_bdev=args.raid_bdev,
2330 base_bdev=args.base_bdev)
2336 def bdev_raid_remove_base_bdev(args):
2337 rpc.bdev.bdev_raid_remove_base_bdev(args.client,
2338 name=args.name)
2344 def bdev_split_create(args):
2345 print_array(rpc.bdev.bdev_split_create(args.client,
2346 base_bdev=args.base_bdev,
2347 split_count=args.split_count,
2348 split_size_mb=args.split_size_mb))
2360 def bdev_split_delete(args):
2361 rpc.bdev.bdev_split_delete(args.client,
2362 base_bdev=args.base_bdev)
2369 def bdev_ftl_create(args):
2370 print_dict(rpc.bdev.bdev_ftl_create(args.client,
2371 name=args.name,
2372 base_bdev=args.base_bdev,
2373 uuid=args.uuid,
2374 cache=args.cache,
2375 overprovisioning=args.overprovisioning,
2376 l2p_dram_limit=args.l2p_dram_limit,
2377 core_mask=args.core_mask,
2378 fast_shutdown=args.fast_shutdown))
2397 def bdev_ftl_load(args):
2398 print_dict(rpc.bdev.bdev_ftl_load(args.client,
2399 name=args.name,
2400 base_bdev=args.base_bdev,
2401 uuid=args.uuid,
2402 cache=args.cache,
2403 overprovisioning=args.overprovisioning,
2404 l2p_dram_limit=args.l2p_dram_limit,
2405 core_mask=args.core_mask,
2406 fast_shutdown=args.fast_shutdown))
2424 def bdev_ftl_unload(args):
2425 print_dict(rpc.bdev.bdev_ftl_unload(args.client, name=args.name, fast_shutdown=args.fast_shutdown))
2432 def bdev_ftl_delete(args):
2433 print_dict(rpc.bdev.bdev_ftl_delete(args.client, name=args.name, fast_shutdown=args.fast_shutdown))
2440 def bdev_ftl_unmap(args):
2441 print_dict(rpc.bdev.bdev_ftl_unmap(args.client, name=args.name,
2442 lba=args.lba,
2443 num_blocks=args.num_blocks))
2451 def bdev_ftl_get_stats(args):
2452 print_dict(rpc.bdev.bdev_ftl_get_stats(args.client, name=args.name))
2458 def bdev_ftl_get_properties(args):
2459 print_dict(rpc.bdev.bdev_ftl_get_properties(args.client, name=args.name))
2465 def bdev_ftl_set_property(args):
2466 print_dict(rpc.bdev.bdev_ftl_set_property(args.client, name=args.name,
2467 ftl_property=args.property,
2468 value=args.value))
2477 def vmd_enable(args):
2478 print_dict(rpc.vmd.vmd_enable(args.client))
2483 def vmd_remove_device(args):
2484 print_dict(rpc.vmd.vmd_remove_device(args.client, addr=args.addr))
2490 def vmd_rescan(args):
2491 print_dict(rpc.vmd.vmd_rescan(args.client))
2497 def ublk_create_target(args):
2498 rpc.ublk.ublk_create_target(args.client,
2499 cpumask=args.cpumask,
2500 disable_user_copy=args.disable_user_copy)
2507 def ublk_destroy_target(args):
2508 rpc.ublk.ublk_destroy_target(args.client)
2513 def ublk_start_disk(args):
2514 print(rpc.ublk.ublk_start_disk(args.client,
2515 bdev_name=args.bdev_name,
2516 ublk_id=args.ublk_id,
2517 num_queues=args.num_queues,
2518 queue_depth=args.queue_depth))
2528 def ublk_stop_disk(args):
2529 rpc.ublk.ublk_stop_disk(args.client,
2530 ublk_id=args.ublk_id)
2537 def ublk_recover_disk(args):
2538 print(rpc.ublk.ublk_recover_disk(args.client,
2539 bdev_name=args.bdev_name,
2540 ublk_id=args.ublk_id))
2548 def ublk_get_disks(args):
2549 print_dict(rpc.ublk.ublk_get_disks(args.client,
2550 ublk_id=args.ublk_id))
2558 def nbd_start_disk(args):
2559 print(rpc.nbd.nbd_start_disk(args.client,
2560 bdev_name=args.bdev_name,
2561 nbd_device=args.nbd_device))
2569 def nbd_stop_disk(args):
2570 rpc.nbd.nbd_stop_disk(args.client,
2571 nbd_device=args.nbd_device)
2578 def nbd_get_disks(args):
2579 print_dict(rpc.nbd.nbd_get_disks(args.client,
2580 nbd_device=args.nbd_device))
2588 def nvmf_set_max_subsystems(args):
2589 rpc.nvmf.nvmf_set_max_subsystems(args.client,
2590 max_subsystems=args.max_subsystems)
2597 def nvmf_set_config(args):
2598 rpc.nvmf.nvmf_set_config(args.client,
2599 passthru_identify_ctrlr=args.passthru_identify_ctrlr,
2600 poll_groups_mask=args.poll_groups_mask,
2601 discovery_filter=args.discovery_filter,
2602 dhchap_digests=args.dhchap_digests,
2603 dhchap_dhgroups=args.dhchap_dhgroups)
2617 def nvmf_create_transport(args):
2618 rpc.nvmf.nvmf_create_transport(**vars(args))
2657 def nvmf_get_transports(args):
2658 print_dict(rpc.nvmf.nvmf_get_transports(args.client, trtype=args.trtype, tgt_name=args.tgt_name))
2665 def nvmf_get_subsystems(args):
2666 print_dict(rpc.nvmf.nvmf_get_subsystems(args.client, nqn=args.nqn, tgt_name=args.tgt_name))
2673 def nvmf_create_subsystem(args):
2674 rpc.nvmf.nvmf_create_subsystem(args.client,
2675 nqn=args.nqn,
2676 tgt_name=args.tgt_name,
2677 serial_number=args.serial_number,
2678 model_number=args.model_number,
2679 allow_any_host=args.allow_any_host,
2680 max_namespaces=args.max_namespaces,
2681 ana_reporting=args.ana_reporting,
2682 min_cntlid=args.min_cntlid,
2683 max_cntlid=args.max_cntlid,
2684 max_discard_size_kib=args.max_discard_size,
2685 max_write_zeroes_size_kib=args.max_write_zeroes_size,
2686 passthrough=args.passthrough)
2709 def nvmf_delete_subsystem(args):
2710 rpc.nvmf.nvmf_delete_subsystem(args.client,
2711 nqn=args.subsystem_nqn,
2712 tgt_name=args.tgt_name)
2720 def nvmf_subsystem_add_listener(args):
2721 rpc.nvmf.nvmf_subsystem_add_listener(**vars(args))
2735 def nvmf_subsystem_remove_listener(args):
2736 rpc.nvmf.nvmf_subsystem_remove_listener(args.client,
2737 nqn=args.nqn,
2738 trtype=args.trtype,
2739 traddr=args.traddr,
2740 tgt_name=args.tgt_name,
2741 adrfam=args.adrfam,
2742 trsvcid=args.trsvcid)
2753 def nvmf_subsystem_listener_set_ana_state(args):
2754 rpc.nvmf.nvmf_subsystem_listener_set_ana_state(args.client,
2755 nqn=args.nqn,
2756 ana_state=args.ana_state,
2757 trtype=args.trtype,
2758 traddr=args.traddr,
2759 tgt_name=args.tgt_name,
2760 adrfam=args.adrfam,
2761 trsvcid=args.trsvcid,
2762 anagrpid=args.anagrpid)
2775 def nvmf_discovery_add_referral(args):
2776 rpc.nvmf.nvmf_discovery_add_referral(**vars(args))
2789 def nvmf_discovery_remove_referral(args):
2790 rpc.nvmf.nvmf_discovery_remove_referral(args.client,
2791 trtype=args.trtype,
2792 traddr=args.traddr,
2793 tgt_name=args.tgt_name,
2794 adrfam=args.adrfam,
2795 trsvcid=args.trsvcid,
2796 subnqn=args.subnqn)
2807 def nvmf_discovery_get_referrals(args):
2808 print_dict(rpc.nvmf.nvmf_discovery_get_referrals(args.client,
2809 tgt_name=args.tgt_name))
2816 def nvmf_subsystem_add_ns(args):
2817 rpc.nvmf.nvmf_subsystem_add_ns(**vars(args))
2835 def nvmf_subsystem_set_ns_ana_group(args):
2836 rpc.nvmf.nvmf_subsystem_set_ns_ana_group(args.client,
2837 nqn=args.nqn,
2838 nsid=args.nsid,
2839 anagrpid=args.anagrpid,
2840 tgt_name=args.tgt_name)
2849 def nvmf_subsystem_remove_ns(args):
2850 rpc.nvmf.nvmf_subsystem_remove_ns(args.client,
2851 nqn=args.nqn,
2852 nsid=args.nsid,
2853 tgt_name=args.tgt_name)
2861 def nvmf_ns_add_host(args):
2863 args.client,
2864 nqn=args.nqn,
2865 nsid=args.nsid,
2866 host=args.host,
2867 tgt_name=args.tgt_name)
2879 def nvmf_ns_remove_host(args):
2881 args.client,
2882 nqn=args.nqn,
2883 nsid=args.nsid,
2884 host=args.host,
2885 tgt_name=args.tgt_name)
2891 def nvmf_subsystem_add_host(args):
2892 rpc.nvmf.nvmf_subsystem_add_host(args.client,
2893 nqn=args.nqn,
2894 host=args.host,
2895 tgt_name=args.tgt_name,
2896 psk=args.psk,
2897 dhchap_key=args.dhchap_key,
2898 dhchap_ctrlr_key=args.dhchap_ctrlr_key)
2909 def nvmf_subsystem_remove_host(args):
2910 rpc.nvmf.nvmf_subsystem_remove_host(args.client,
2911 nqn=args.nqn,
2912 host=args.host,
2913 tgt_name=args.tgt_name)
2921 def nvmf_subsystem_set_keys(args):
2922 rpc.nvmf.nvmf_subsystem_set_keys(args.client,
2923 nqn=args.nqn,
2924 host=args.host,
2925 tgt_name=args.tgt_name,
2926 dhchap_key=args.dhchap_key,
2927 dhchap_ctrlr_key=args.dhchap_ctrlr_key)
2937 def nvmf_subsystem_allow_any_host(args):
2938 rpc.nvmf.nvmf_subsystem_allow_any_host(args.client,
2939 nqn=args.nqn,
2940 disable=args.disable,
2941 tgt_name=args.tgt_name)
2950 def nvmf_subsystem_get_controllers(args):
2951 print_dict(rpc.nvmf.nvmf_subsystem_get_controllers(args.client,
2952 nqn=args.nqn,
2953 tgt_name=args.tgt_name))
2961 def nvmf_subsystem_get_qpairs(args):
2962 print_dict(rpc.nvmf.nvmf_subsystem_get_qpairs(args.client,
2963 nqn=args.nqn,
2964 tgt_name=args.tgt_name))
2972 def nvmf_subsystem_get_listeners(args):
2973 print_dict(rpc.nvmf.nvmf_subsystem_get_listeners(args.client,
2974 nqn=args.nqn,
2975 tgt_name=args.tgt_name))
2983 def nvmf_get_stats(args):
2984 print_dict(rpc.nvmf.nvmf_get_stats(args.client, tgt_name=args.tgt_name))
2991 def nvmf_set_crdt(args):
2992 print_dict(rpc.nvmf.nvmf_set_crdt(args.client, args.crdt1, args.crdt2, args.crdt3))
3003 def nvmf_publish_mdns_prr(args):
3004 rpc.nvmf.nvmf_publish_mdns_prr(args.client, args.tgt_name)
3011 def nvmf_stop_mdns_prr(args):
3012 rpc.nvmf.nvmf_stop_mdns_prr(args.client, args.tgt_name)
3020 def framework_get_subsystems(args):
3021 print_dict(rpc.subsystem.framework_get_subsystems(args.client))
3028 def framework_get_config(args):
3029 print_dict(rpc.subsystem.framework_get_config(args.client, args.name))
3036 def vhost_controller_set_coalescing(args):
3037 rpc.vhost.vhost_controller_set_coalescing(args.client,
3038 ctrlr=args.ctrlr,
3039 delay_base_us=args.delay_base_us,
3040 iops_threshold=args.iops_threshold)
3048 def virtio_blk_create_transport(args):
3049 rpc.vhost.virtio_blk_create_transport(**vars(args))
3056 def virtio_blk_get_transports(args):
3057 print_dict(rpc.vhost.virtio_blk_get_transports(args.client, name=args.name))
3063 def vhost_create_scsi_controller(args):
3064 rpc.vhost.vhost_create_scsi_controller(args.client,
3065 ctrlr=args.ctrlr,
3066 cpumask=args.cpumask,
3067 delay=args.delay)
3075 def vhost_start_scsi_controller(args):
3076 rpc.vhost.vhost_start_scsi_controller(args.client,
3077 ctrlr=args.ctrlr)
3083 def vhost_scsi_controller_add_target(args):
3084 print_json(rpc.vhost.vhost_scsi_controller_add_target(args.client,
3085 ctrlr=args.ctrlr,
3086 scsi_target_num=args.scsi_target_num,
3087 bdev_name=args.bdev_name))
3095 def vhost_scsi_controller_remove_target(args):
3096 rpc.vhost.vhost_scsi_controller_remove_target(args.client,
3097 ctrlr=args.ctrlr,
3098 scsi_target_num=args.scsi_target_num)
3106 def vhost_create_blk_controller(args):
3107 rpc.vhost.vhost_create_blk_controller(**vars(args))
3118 def vhost_get_controllers(args):
3119 print_dict(rpc.vhost.vhost_get_controllers(args.client, args.name))
3125 def vhost_delete_controller(args):
3126 rpc.vhost.vhost_delete_controller(args.client,
3127 ctrlr=args.ctrlr)
3133 def bdev_virtio_attach_controller(args):
3134 print_array(rpc.vhost.bdev_virtio_attach_controller(args.client,
3135 name=args.name,
3136 trtype=args.trtype,
3137 traddr=args.traddr,
3138 dev_type=args.dev_type,
3139 vq_count=args.vq_count,
3140 vq_size=args.vq_size))
3158 def bdev_virtio_scsi_get_devices(args):
3159 print_dict(rpc.vhost.bdev_virtio_scsi_get_devices(args.client))
3164 def bdev_virtio_detach_controller(args):
3165 rpc.vhost.bdev_virtio_detach_controller(args.client,
3166 name=args.name)
3173 def bdev_virtio_blk_set_hotplug(args):
3174 rpc.vhost.bdev_virtio_blk_set_hotplug(args.client, enable=args.enable, period_us=args.period_us)
3184 def vfu_tgt_set_base_path(args):
3185 rpc.vfio_user.vfu_tgt_set_base_path(args.client, path=args.path)
3191 def vfu_virtio_delete_endpoint(args):
3192 rpc.vfio_user.vfu_virtio_delete_endpoint(args.client, name=args.name)
3198 def vfu_virtio_create_blk_endpoint(args):
3199 rpc.vfio_user.vfu_virtio_create_blk_endpoint(args.client,
3200 name=args.name,
3201 bdev_name=args.bdev_name,
3202 cpumask=args.cpumask,
3203 num_queues=args.num_queues,
3204 qsize=args.qsize,
3205 packed_ring=args.packed_ring)
3216 def vfu_virtio_scsi_add_target(args):
3217 rpc.vfio_user.vfu_virtio_scsi_add_target(args.client,
3218 name=args.name,
3219 scsi_target_num=args.scsi_target_num,
3220 bdev_name=args.bdev_name)
3228 def vfu_virtio_scsi_remove_target(args):
3229 rpc.vfio_user.vfu_virtio_scsi_remove_target(args.client,
3230 name=args.name,
3231 scsi_target_num=args.scsi_target_num)
3238 def vfu_virtio_create_scsi_endpoint(args):
3239 rpc.vfio_user.vfu_virtio_create_scsi_endpoint(args.client,
3240 name=args.name,
3241 cpumask=args.cpumask,
3242 num_io_queues=args.num_io_queues,
3243 qsize=args.qsize,
3244 packed_ring=args.packed_ring)
3254 def vfu_virtio_create_fs_endpoint(args):
3255 rpc.vfio_user.vfu_virtio_create_fs_endpoint(args.client,
3256 name=args.name,
3257 fsdev_name=args.fsdev_name,
3258 tag=args.tag,
3259 cpumask=args.cpumask,
3260 num_queues=args.num_queues,
3261 qsize=args.qsize,
3262 packed_ring=args.packed_ring)
3275 def accel_get_opc_assignments(args):
3276 print_dict(rpc.accel.accel_get_opc_assignments(args.client))
3281 def accel_get_module_info(args):
3282 print_dict(rpc.accel.accel_get_module_info(args.client))
3288 def accel_assign_opc(args):
3289 rpc.accel.accel_assign_opc(args.client, opname=args.opname, module=args.module)
3296 def accel_crypto_key_create(args):
3297 print_dict(rpc.accel.accel_crypto_key_create(args.client,
3298 cipher=args.cipher,
3299 key=args.key,
3300 key2=args.key2,
3301 tweak_mode=args.tweak_mode,
3302 name=args.name))
3312 def accel_crypto_key_destroy(args):
3313 print_dict(rpc.accel.accel_crypto_key_destroy(args.client,
3314 key_name=args.name))
3320 def accel_crypto_keys_get(args):
3321 print_dict(rpc.accel.accel_crypto_keys_get(args.client,
3322 key_name=args.key_name))
3328 def accel_set_driver(args):
3329 rpc.accel.accel_set_driver(args.client, name=args.name)
3336 def accel_set_options(args):
3337 rpc.accel.accel_set_options(args.client, args.small_cache_size, args.large_cache_size,
3338 args.task_count, args.sequence_count, args.buf_count)
3348 def accel_get_stats(args):
3349 print_dict(rpc.accel.accel_get_stats(args.client))
3355 def ioat_scan_accel_module(args):
3356 rpc.ioat.ioat_scan_accel_module(args.client)
3363 def compressdev_scan_accel_module(args):
3364 rpc.compressdev.compressdev_scan_accel_module(args.client, pmd=args.pmd)
3371 def dsa_scan_accel_module(args):
3372 rpc.dsa.dsa_scan_accel_module(args.client, config_kernel_mode=args.config_kernel_mode)
3381 def iaa_scan_accel_module(args):
3382 rpc.iaa.iaa_scan_accel_module(args.client)
3388 def dpdk_cryptodev_scan_accel_module(args):
3389 rpc.dpdk_cryptodev.dpdk_cryptodev_scan_accel_module(args.client)
3395 def dpdk_cryptodev_set_driver(args):
3396 rpc.dpdk_cryptodev.dpdk_cryptodev_set_driver(args.client,
3397 driver_name=args.driver_name)
3404 def dpdk_cryptodev_get_driver(args):
3405 print_dict(rpc.dpdk_cryptodev.dpdk_cryptodev_get_driver(args.client))
3411 def mlx5_scan_accel_module(args):
3412 rpc.mlx5.mlx5_scan_accel_module(args.client,
3413 qp_size=args.qp_size,
3414 num_requests=args.num_requests,
3415 allowed_devs=args.allowed_devs,
3416 crypto_split_blocks=args.crypto_split_blocks,
3417 enable_driver=args.enable_driver)
3429 def accel_mlx5_dump_stats(args):
3430 print_dict(rpc.mlx5.accel_mlx5_dump_stats(args.client, level=args.level))
3437 def accel_error_inject_error(args):
3438 rpc.accel.accel_error_inject_error(args.client, opcode=args.opcode,
3439 type=args.type, count=args.count,
3440 interval=args.interval, errcode=args.errcode)
3454 def bdev_nvme_opal_init(args):
3455 rpc.nvme.bdev_nvme_opal_init(args.client,
3456 nvme_ctrlr_name=args.nvme_ctrlr_name,
3457 password=args.password)
3464 def bdev_nvme_opal_revert(args):
3465 rpc.nvme.bdev_nvme_opal_revert(args.client,
3466 nvme_ctrlr_name=args.nvme_ctrlr_name,
3467 password=args.password)
3473 def bdev_opal_create(args):
3474 print_json(rpc.bdev.bdev_opal_create(args.client,
3475 nvme_ctrlr_name=args.nvme_ctrlr_name,
3476 nsid=args.nsid,
3477 locking_range_id=args.locking_range_id,
3478 range_start=args.range_start,
3479 range_length=args.range_length,
3480 password=args.password))
3491 def bdev_opal_get_info(args):
3492 print_dict(rpc.bdev.bdev_opal_get_info(args.client,
3493 bdev_name=args.bdev_name,
3494 password=args.password))
3501 def bdev_opal_delete(args):
3502 rpc.bdev.bdev_opal_delete(args.client,
3503 bdev_name=args.bdev_name,
3504 password=args.password)
3511 def bdev_opal_new_user(args):
3512 rpc.bdev.bdev_opal_new_user(args.client,
3513 bdev_name=args.bdev_name,
3514 admin_password=args.admin_password,
3515 user_id=args.user_id,
3516 user_password=args.user_password)
3525 def bdev_opal_set_lock_state(args):
3526 rpc.bdev.bdev_opal_set_lock_state(args.client,
3527 bdev_name=args.bdev_name,
3528 user_id=args.user_id,
3529 password=args.password,
3530 lock_state=args.lock_state)
3541 def bdev_nvme_send_cmd(args):
3542 print_dict(rpc.nvme.bdev_nvme_send_cmd(args.client,
3543 name=args.nvme_name,
3544 cmd_type=args.cmd_type,
3545 data_direction=args.data_direction,
3546 cmdbuf=args.cmdbuf,
3547 data=args.data,
3548 metadata=args.metadata,
3549 data_len=args.data_length,
3550 metadata_len=args.metadata_length,
3551 timeout_ms=args.timeout_ms))
3567 def notify_get_types(args):
3568 print_dict(rpc.notify.notify_get_types(args.client))
3573 def notify_get_notifications(args):
3574 ret = rpc.notify.notify_get_notifications(args.client,
3575 id=args.id,
3576 max=args.max)
3584 def thread_get_stats(args):
3585 print_dict(rpc.app.thread_get_stats(args.client))
3591 def thread_set_cpumask(args):
3592 ret = rpc.app.thread_set_cpumask(args.client,
3593 id=args.id,
3594 cpumask=args.cpumask)
3602 def log_enable_timestamps(args):
3603 ret = rpc.app.log_enable_timestamps(args.client,
3604 enabled=args.enabled)
3611 def thread_get_pollers(args):
3612 print_dict(rpc.app.thread_get_pollers(args.client))
3618 def thread_get_io_channels(args):
3619 print_dict(rpc.app.thread_get_io_channels(args.client))
3625 def env_dpdk_get_mem_stats(args):
3626 print_dict(rpc.env_dpdk.env_dpdk_get_mem_stats(args.client))
3633 def blobfs_detect(args):
3634 print(rpc.blobfs.blobfs_detect(args.client,
3635 bdev_name=args.bdev_name))
3641 def blobfs_create(args):
3642 print(rpc.blobfs.blobfs_create(args.client,
3643 bdev_name=args.bdev_name,
3644 cluster_sz=args.cluster_sz))
3652 def blobfs_mount(args):
3653 print(rpc.blobfs.blobfs_mount(args.client,
3654 bdev_name=args.bdev_name,
3655 mountpoint=args.mountpoint))
3662 def blobfs_set_cache_size(args):
3663 print(rpc.blobfs.blobfs_set_cache_size(args.client,
3664 size_in_mb=args.size_in_mb))
3671 def fsdev_get_opts(args):
3672 print_json(rpc.fsdev.fsdev_get_opts(args.client))
3677 def fsdev_set_opts(args):
3678 print(rpc.fsdev.fsdev_set_opts(args.client, fsdev_io_pool_size=args.fsdev_io_pool_size,
3679 fsdev_io_cache_size=args.fsdev_io_cache_size))
3686 def fsdev_aio_create(args):
3687 print(rpc.fsdev.fsdev_aio_create(args.client, name=args.name, root_path=args.root_path,
3688 enable_xattr=args.enable_xattr, enable_writeback_cache=args.enable_writeback_cache,
3689 max_write=args.max_write, skip_rw=args.skip_rw))
3711 def fsdev_aio_delete(args):
3712 print(rpc.fsdev.fsdev_aio_delete(args.client, name=args.name))
3719 def sock_impl_get_options(args):
3720 print_json(rpc.sock.sock_impl_get_options(args.client,
3721 impl_name=args.impl))
3727 def sock_impl_set_options(args):
3728 rpc.sock.sock_impl_set_options(args.client,
3729 impl_name=args.impl,
3730 recv_buf_size=args.recv_buf_size,
3731 send_buf_size=args.send_buf_size,
3732 enable_recv_pipe=args.enable_recv_pipe,
3733 enable_quickack=args.enable_quickack,
3734 enable_placement_id=args.enable_placement_id,
3735 enable_zerocopy_send_server=args.enable_zerocopy_send_server,
3736 enable_zerocopy_send_client=args.enable_zerocopy_send_client,
3737 zerocopy_threshold=args.zerocopy_threshold,
3738 tls_version=args.tls_version,
3739 enable_ktls=args.enable_ktls)
3772 def sock_set_default_impl(args):
3773 print_json(rpc.sock.sock_set_default_impl(args.client,
3774 impl_name=args.impl))
3780 def sock_get_default_impl(args):
3781 print_json(rpc.sock.sock_get_default_impl(args.client))
3786 def framework_get_pci_devices(args):
3790 devices = rpc.subsystem.framework_get_pci_devices(args.client)
3791 if not args.format_lspci:
3806 def bdev_nvme_add_error_injection(args):
3807 print_dict(rpc.nvme.bdev_nvme_add_error_injection(args.client,
3808 name=args.nvme_name,
3809 cmd_type=args.cmd_type,
3810 opc=args.opc,
3811 do_not_submit=args.do_not_submit,
3812 timeout_in_us=args.timeout_in_us,
3813 err_count=args.err_count,
3814 sct=args.sct,
3815 sc=args.sc))
3831 def bdev_nvme_remove_error_injection(args):
3832 print_dict(rpc.nvme.bdev_nvme_remove_error_injection(args.client,
3833 name=args.nvme_name,
3834 cmd_type=args.cmd_type,
3835 opc=args.opc))
3843 def bdev_daos_create(args):
3844 num_blocks = (args.total_size * 1024 * 1024) // args.block_size
3845 print_json(rpc.bdev.bdev_daos_create(args.client,
3847 block_size=args.block_size,
3848 name=args.name,
3849 uuid=args.uuid,
3850 pool=args.pool,
3851 cont=args.cont,
3852 oclass=args.oclass))
3865 def bdev_daos_delete(args):
3866 rpc.bdev.bdev_daos_delete(args.client,
3867 name=args.name)
3874 def bdev_daos_resize(args):
3875 print_json(rpc.bdev.bdev_daos_resize(args.client,
3876 name=args.name,
3877 new_size=int(args.new_size)))
3885 def iobuf_set_options(args):
3886 rpc.iobuf.iobuf_set_options(args.client,
3887 small_pool_count=args.small_pool_count,
3888 large_pool_count=args.large_pool_count,
3889 small_bufsize=args.small_bufsize,
3890 large_bufsize=args.large_bufsize,
3891 enable_numa=args.enable_numa)
3900 def iobuf_get_stats(args):
3901 print_dict(rpc.iobuf.iobuf_get_stats(args.client))
3906 def bdev_nvme_start_mdns_discovery(args):
3907 rpc.bdev.bdev_nvme_start_mdns_discovery(args.client,
3908 name=args.name,
3909 svcname=args.svcname,
3910 hostnqn=args.hostnqn)
3918 def bdev_nvme_stop_mdns_discovery(args):
3919 rpc.bdev.bdev_nvme_stop_mdns_discovery(args.client, name=args.name)
3925 def bdev_nvme_get_mdns_discovery_info(args):
3926 print_dict(rpc.bdev.bdev_nvme_get_mdns_discovery_info(args.client))
3931 def keyring_file_add_key(args):
3932 rpc.keyring.keyring_file_add_key(args.client, args.name, args.path)
3939 def keyring_file_remove_key(args):
3940 rpc.keyring.keyring_file_remove_key(args.client, args.name)
3946 def keyring_get_keys(args):
3947 print_dict(rpc.keyring.keyring_get_keys(args.client))
3952 def keyring_linux_set_options(args):
3953 rpc.keyring.keyring_linux_set_options(args.client, args.enable)
3970 def call_rpc_func(args):
3971 args.func(args)
3972 check_called_name(args.called_rpc_name)
3984 args = parser.parse_args(rpc_args)
3985 args.client = client
3986 args.timeout = timeout
3988 call_rpc_func(args)
3995 def load_plugin(args):
4001 if args is not None:
4002 rpc_module = plugin_parser.parse_known_args(args)[0].rpc_plugin
4018 def replace_arg_underscores(args):
4023 for i in range(len(args)):
4024 arg = args[i]
4027 args[i] = '='.join([opt.replace('_', '-'), *vals])
4034 args = parser.parse_args()
4041 if sys.stdin.isatty() and not hasattr(args, 'func'):
4045 if args.is_server:
4070 elif args.dry_run:
4071 args.client = dry_run_client()
4075 elif args.go_client or use_go_client:
4077 args.client = rpc.client.JSONRPCGoClient(args.server_addr,
4078 log_level=getattr(logging, args.verbose.upper()))
4084 args.client = rpc.client.JSONRPCClient(args.server_addr, args.port, args.timeout,
4085 log_level=getattr(logging, args.verbose.upper()),
4086 conn_retries=args.conn_retries)
4091 if hasattr(args, 'func'):
4093 call_rpc_func(args)
4098 execute_script(parser, args.client, args.timeout, sys.stdin)