client (reference) in projects: spdk - OpenGrok search results

Project(s)

Full Search
Definition
Symbol
File Path
History
Type

Searched refs:client (Results 1 – 25 of 82) sorted by relevance

12 3 4

/spdk/python/spdk/rpc/
H A D	bdev.py	8 def bdev_set_options(client, bdev_io_pool_size=None, bdev_io_cache_size=None, argument 30 return client.call('bdev_set_options', params) 33 def bdev_examine(client, name): argument 41 return client.call('bdev_examine', params) 44 def bdev_wait_for_examine(client): argument 47 return client.call('bdev_wait_for_examine') 50 def bdev_compress_create(client, base_bdev_name, pm_path, lb_size=None, comp_algo=None, comp_level=None): argument 70 return client.call('bdev_compress_create', params) 73 def bdev_compress_delete(client, name): 80 return client 67 bdev_compress_delete(client, name) global() argument 77 bdev_compress_get_orphans(client, name=None) global() argument 90 bdev_crypto_create(client, base_bdev_name, name, crypto_pmd=None, key=None, cipher=None, key2=None, key_name=None) global() argument 119 bdev_crypto_delete(client, name) global() argument 129 bdev_ocf_create(client, name, mode, cache_bdev_name, core_bdev_name, cache_line_size=None) global() argument 150 bdev_ocf_delete(client, name) global() argument 160 bdev_ocf_get_stats(client, name) global() argument 172 bdev_ocf_reset_stats(client, name) global() argument 184 bdev_ocf_get_bdevs(client, name=None) global() argument 197 bdev_ocf_set_cache_mode(client, name, mode) global() argument 211 bdev_ocf_set_seqcutoff(client, name, policy, threshold=None, promotion_count=None) global() argument 229 bdev_ocf_flush_start(client, name) global() argument 239 bdev_ocf_flush_status(client, name) global() argument 251 bdev_malloc_create(client, num_blocks, block_size, physical_block_size=None, name=None, uuid=None, optimal_io_boundary=None, md_size=None, md_interleave=None, dif_type=None, dif_is_head_of_md=None) global() argument 290 bdev_malloc_delete(client, name) global() argument 300 bdev_null_create(client, num_blocks, block_size, name, physical_block_size=None, uuid=None, md_size=None, dif_type=None, dif_is_head_of_md=None) global() argument 332 bdev_null_delete(client, name) global() argument 342 bdev_null_resize(client, name, new_size) global() argument 354 bdev_raid_set_options(client, process_window_size_kb=None) global() argument 365 bdev_raid_get_bdevs(client, category) global() argument 377 bdev_raid_create(client, name, raid_level, base_bdevs, strip_size_kb=None, uuid=None, superblock=None) global() argument 403 bdev_raid_delete(client, name) global() argument 415 bdev_raid_add_base_bdev(client, base_bdev, raid_bdev) global() argument 429 bdev_raid_remove_base_bdev(client, name) global() argument 441 bdev_aio_create(client, filename, name, block_size=None, readonly=None, fallocate=None) global() argument 464 bdev_aio_rescan(client, name) global() argument 474 bdev_aio_delete(client, name) global() argument 484 bdev_uring_create(client, filename, name, block_size=None, uuid=None) global() argument 504 bdev_uring_rescan(client, name) global() argument 514 bdev_uring_delete(client, name) global() argument 524 bdev_xnvme_create(client, filename, name, io_mechanism, conserve_cpu=None) global() argument 543 bdev_xnvme_delete(client, name) global() argument 553 bdev_nvme_set_options(client, action_on_timeout=None, timeout_us=None, timeout_admin_us=None, keep_alive_timeout_ms=None, arbitration_burst=None, low_priority_weight=None, medium_priority_weight=None, high_priority_weight=None, nvme_adminq_poll_period_us=None, nvme_ioq_poll_period_us=None, io_queue_requests=None, delay_cmd_submit=None, transport_retry_count=None, bdev_retry_count=None, transport_ack_timeout=None, ctrlr_loss_timeout_sec=None, reconnect_delay_sec=None, fast_io_fail_timeout_sec=None, disable_auto_failback=None, generate_uuids=None, transport_tos=None, nvme_error_stat=None, rdma_srq_size=None, io_path_stat=None, allow_accel_sequence=None, rdma_max_cq_size=None, rdma_cm_event_timeout_ms=None, dhchap_digests=None, dhchap_dhgroups=None) global() argument 674 bdev_nvme_set_hotplug(client, enable, period_us=None) global() argument 687 bdev_nvme_attach_controller(client, name, trtype, traddr, adrfam=None, trsvcid=None, priority=None, subnqn=None, hostnqn=None, hostaddr=None, hostsvcid=None, prchk_reftag=None, prchk_guard=None, hdgst=None, ddgst=None, fabrics_connect_timeout_us=None, multipath=None, num_io_queues=None, ctrlr_loss_timeout_sec=None, reconnect_delay_sec=None, fast_io_fail_timeout_sec=None, psk=None, max_bdevs=None, dhchap_key=None, dhchap_ctrlr_key=None) global() argument 783 bdev_nvme_detach_controller(client, name, trtype=None, traddr=None, adrfam=None, trsvcid=None, subnqn=None, hostaddr=None, hostsvcid=None) global() argument 820 bdev_nvme_reset_controller(client, name, cntlid=None) global() argument 833 bdev_nvme_enable_controller(client, name, cntlid=None) global() argument 846 bdev_nvme_disable_controller(client, name, cntlid=None) global() argument 859 bdev_nvme_start_discovery(client, name, trtype, traddr, adrfam=None, trsvcid=None, hostnqn=None, wait_for_attach=None, ctrlr_loss_timeout_sec=None, reconnect_delay_sec=None, fast_io_fail_timeout_sec=None, attach_timeout_ms=None) global() argument 911 bdev_nvme_stop_discovery(client, name) global() argument 921 bdev_nvme_get_discovery_info(client) global() argument 927 bdev_nvme_get_io_paths(client, name=None) global() argument 940 bdev_nvme_set_preferred_path(client, name, cntlid) global() argument 952 bdev_nvme_set_multipath_policy(client, name, policy, selector=None, rr_min_io=None) global() argument 970 bdev_nvme_get_path_iostat(client, name) global() argument 982 bdev_nvme_cuse_register(client, name) global() argument 992 bdev_nvme_cuse_unregister(client, name) global() argument 1002 bdev_zone_block_create(client, name, base_bdev, zone_capacity, optimal_open_zones) global() argument 1020 bdev_zone_block_delete(client, name) global() argument 1030 bdev_rbd_register_cluster(client, name=None, user_id=None, config_param=None, config_file=None, key_file=None, core_mask=None) global() argument 1058 bdev_rbd_unregister_cluster(client, name) global() argument 1068 bdev_rbd_get_clusters_info(client, name=None) global() argument 1081 bdev_rbd_create(client, pool_name, rbd_name, block_size, name=None, user_id=None, config=None, cluster_name=None, uuid=None) global() argument 1114 bdev_rbd_delete(client, name) global() argument 1124 bdev_rbd_resize(client, name, new_size) global() argument 1136 bdev_error_create(client, base_name, uuid=None) global() argument 1149 bdev_delay_create(client, base_bdev_name, name, avg_read_latency, p99_read_latency, avg_write_latency, p99_write_latency, uuid=None) global() argument 1174 bdev_delay_delete(client, name) global() argument 1184 bdev_delay_update_latency(client, delay_bdev_name, latency_type, latency_us) global() argument 1200 bdev_error_delete(client, name) global() argument 1210 bdev_iscsi_set_options(client, timeout_sec=None) global() argument 1221 bdev_iscsi_create(client, name, url, initiator_iqn) global() argument 1237 bdev_iscsi_delete(client, name) global() argument 1247 bdev_passthru_create(client, base_bdev_name, name, uuid=None) global() argument 1264 bdev_passthru_delete(client, name) global() argument 1274 bdev_opal_create(client, nvme_ctrlr_name, nsid, locking_range_id, range_start, range_length, password) global() argument 1296 bdev_opal_get_info(client, bdev_name, password) global() argument 1310 bdev_opal_delete(client, bdev_name, password) global() argument 1322 bdev_opal_new_user(client, bdev_name, admin_password, user_id, user_password) global() argument 1338 bdev_opal_set_lock_state(client, bdev_name, user_id, password, lock_state) global() argument 1354 bdev_split_create(client, base_bdev, split_count, split_size_mb=None) global() argument 1371 bdev_split_delete(client, base_bdev) global() argument 1381 bdev_ftl_create(client, name, base_bdev, cache, kwargs) global() argument 1399 bdev_ftl_load(client, name, base_bdev, cache, kwargs) global() argument 1417 bdev_ftl_unload(client, name, fast_shutdown=None) global() argument 1430 bdev_ftl_delete(client, name, fast_shutdown=None) global() argument 1443 bdev_ftl_unmap(client, name, lba, num_blocks) global() argument 1457 bdev_ftl_get_stats(client, name) global() argument 1467 bdev_ftl_get_properties(client, name) global() argument 1477 bdev_ftl_set_property(client, name, ftl_property, value) global() argument 1491 bdev_get_bdevs(client, name=None, timeout=None) global() argument 1507 bdev_get_iostat(client, name=None, per_channel=None) global() argument 1523 bdev_reset_iostat(client, name=None, mode=None) global() argument 1537 bdev_enable_histogram(client, name, enable) global() argument 1549 bdev_get_histogram(client, name) global() argument 1559 bdev_error_inject_error(client, name, io_type, error_type, num=None, queue_depth=None, corrupt_offset=None, corrupt_value=None) global() argument 1586 bdev_set_qd_sampling_period(client, name, period) global() argument 1599 bdev_set_qos_limit( client, name, rw_ios_per_sec=None, rw_mbytes_per_sec=None, r_mbytes_per_sec=None, w_mbytes_per_sec=None) global() argument 1626 bdev_nvme_apply_firmware(client, bdev_name, filename) global() argument 1638 bdev_nvme_get_transport_statistics(client) global() argument 1643 bdev_nvme_get_controller_health_info(client, name) global() argument 1655 bdev_daos_create(client, num_blocks, block_size, pool, cont, name, oclass=None, uuid=None) global() argument 1681 bdev_daos_delete(client, name) global() argument 1691 bdev_daos_resize(client, name, new_size) global() argument 1703 bdev_nvme_start_mdns_discovery(client, name, svcname, hostnqn=None) global() argument 1718 bdev_nvme_stop_mdns_discovery(client, name) global() argument 1728 bdev_nvme_get_mdns_discovery_info(client) global() argument [all...]
H A D	iscsi.py	`7 client, argument 106 return client.call('iscsi_set_options', params) 110 client, argument 137 return client.call('iscsi_set_discovery_auth', params) 140 def iscsi_get_auth_groups(client): argument 146 return client.call('iscsi_get_auth_groups') 149 def iscsi_get_portal_groups(client): argument 155 return client.call('iscsi_get_portal_groups') 158 def iscsi_get_initiator_groups(client): argument 164 return client.call('iscsi_get_initiator_groups') [all …]`
H A D	lvol.py	7 def bdev_lvol_create_lvstore(client, bdev_name, lvs_name, cluster_sz=None, argument 32 return client.call('bdev_lvol_create_lvstore', params) 35 def bdev_lvol_rename_lvstore(client, old_name, new_name): 46 return client.call('bdev_lvol_rename_lvstore', params) 49 def bdev_lvol_grow_lvstore(client, uuid=None, lvs_name=None): 63 return client.call('bdev_lvol_grow_lvstore', params) 66 def bdev_lvol_create(client, lvol_name, size_in_mib, thin_provision=False, uuid=None, lvs_name=None, clear_method=None): 93 return client.call('bdev_lvol_create', params) 96 def bdev_lvol_snapshot(client, lvol_name, snapshot_name): 110 return client 31 bdev_lvol_rename_lvstore(client, old_name, new_name) global() argument 45 bdev_lvol_grow_lvstore(client, uuid=None, lvs_name=None) global() argument 62 bdev_lvol_create(client, lvol_name, size_in_mib, thin_provision=False, uuid=None, lvs_name=None, clear_method=None) global() argument 92 bdev_lvol_snapshot(client, lvol_name, snapshot_name) global() argument 109 bdev_lvol_clone(client, snapshot_name, clone_name) global() argument 126 bdev_lvol_clone_bdev(client, bdev, lvs_name, clone_name) global() argument 150 bdev_lvol_rename(client, old_name, new_name) global() argument 164 bdev_lvol_resize(client, name, size_in_mib) global() argument 178 bdev_lvol_set_read_only(client, name) global() argument 190 bdev_lvol_delete(client, name) global() argument 202 bdev_lvol_inflate(client, name) global() argument 214 bdev_lvol_decouple_parent(client, name) global() argument 226 bdev_lvol_start_shallow_copy(client, src_lvol_name, dst_bdev_name) global() argument 241 bdev_lvol_check_shallow_copy(client, operation_id) global() argument 253 bdev_lvol_set_parent(client, lvol_name, snapshot_name) global() argument 267 bdev_lvol_set_parent_bdev(client, lvol_name, esnap_name) global() argument 281 bdev_lvol_delete_lvstore(client, uuid=None, lvs_name=None) global() argument 301 bdev_lvol_get_lvstores(client, uuid=None, lvs_name=None) global() argument 321 bdev_lvol_get_lvols(client, lvs_uuid=None, lvs_name=None) global() argument [all...]
H A D	nvmf.py	8 def nvmf_set_max_subsystems(client, argument 21 return client.call('nvmf_set_max_subsystems', params) 24 def nvmf_set_config(client, argument 53 return client.call('nvmf_set_config', params) 56 def nvmf_create_target(client, argument 76 return client.call("nvmf_create_target", params) 79 def nvmf_delete_target(client, argument 92 return client.call("nvmf_delete_target", params) 95 def nvmf_get_targets(client): argument 102 return client 105 nvmf_create_transport(client, params) global() argument 146 nvmf_get_transports(client, trtype=None, tgt_name=None) global() argument 167 nvmf_get_subsystems(client, nqn=None, tgt_name=None) global() argument 188 nvmf_create_subsystem(client, nqn, serial_number, tgt_name=None, model_number='SPDK bdev Controller', allow_any_host=False, max_namespaces=0, ana_reporting=False, min_cntlid=1, max_cntlid=0xffef, max_discard_size_kib=0, max_write_zeroes_size_kib=0) global() argument 256 nvmf_subsystem_add_listener(client, params) global() argument 285 nvmf_subsystem_remove_listener( client, nqn, trtype, traddr, trsvcid, adrfam, tgt_name=None) global() argument 327 nvmf_subsystem_listener_set_ana_state( client, nqn, ana_state, trtype, traddr, trsvcid, adrfam, tgt_name=None, anagrpid=None) global() argument 371 nvmf_discovery_add_referral(client, params) global() argument 401 nvmf_discovery_remove_referral( client, trtype, traddr, trsvcid, adrfam, tgt_name=None, subnqn=None) global() argument 442 nvmf_discovery_get_referrals(client, tgt_name=None) global() argument 459 nvmf_subsystem_add_ns(client, params) global() argument 486 nvmf_subsystem_remove_ns(client, nqn, nsid, tgt_name=None) global() argument 506 nvmf_ns_visible(visible, client, nqn, nsid, host, tgt_name=None) global() argument 531 nvmf_subsystem_add_host(client, nqn, host, tgt_name=None, psk=None, dhchap_key=None, dhchap_ctrlr_key=None) global() argument 561 nvmf_subsystem_remove_host(client, nqn, host, tgt_name=None) global() argument 581 nvmf_subsystem_allow_any_host(client, nqn, disable, tgt_name=None) global() argument 600 nvmf_delete_subsystem(client, nqn, tgt_name=None) global() argument 618 nvmf_subsystem_get_controllers(client, nqn, tgt_name=None) global() argument 636 nvmf_subsystem_get_qpairs(client, nqn, tgt_name=None) global() argument 654 nvmf_subsystem_get_listeners(client, nqn, tgt_name=None) global() argument 672 nvmf_get_stats(client, tgt_name=None) global() argument 692 nvmf_set_crdt(client, crdt1=None, crdt2=None, crdt3=None) global() argument 714 nvmf_publish_mdns_prr(client, tgt_name=None) global() argument 730 nvmf_stop_mdns_prr(client, tgt_name=None) global() argument [all...]
H A D	vhost.py	8 def vhost_controller_set_coalescing(client, ctrlr, delay_base_us, iops_threshold): argument 20 return client.call('vhost_controller_set_coalescing', params) 23 def virtio_blk_get_transports(client, name=None): argument 37 return client.call('virtio_blk_get_transports', params) 40 def virtio_blk_create_transport(client, **params): argument 48 return client.call('virtio_blk_create_transport', params) 51 def vhost_create_scsi_controller(client, ctrlr, delay=False, cpumask=None): argument 63 return client.call('vhost_create_scsi_controller', params) 66 def vhost_start_scsi_controller(client, ctrlr): argument 73 return client.call('vhost_start_scsi_controller', params) [all …]
H A D	app.py	6 def spdk_kill_instance(client, sig_name): argument 13 return client.call('spdk_kill_instance', params) 16 def framework_monitor_context_switch(client, enabled=None): argument 28 return client.call('framework_monitor_context_switch', params) 31 def framework_get_reactors(client): argument 37 return client.call('framework_get_reactors') 40 def framework_set_scheduler(client, name, period=None, load_limit=None, core_limit=None, argument 61 return client.call('framework_set_scheduler', params) 64 def framework_get_scheduler(client): 70 return client 62 framework_get_scheduler(client) global() argument 71 framework_get_governor(client) global() argument 80 thread_get_stats(client) global() argument 89 thread_set_cpumask(client, id, cpumask) global() argument 103 log_enable_timestamps(client, enabled) global() argument 116 thread_get_pollers(client) global() argument 125 thread_get_io_channels(client) global() argument [all...]
H A D	accel.py	9 def accel_get_opc_assignments(client): argument 12 return client.call('accel_get_opc_assignments') 16 def accel_get_module_info(client): argument 19 return client.call('accel_get_module_info') 22 def accel_assign_opc(client, opname, module): argument 34 return client.call('accel_assign_opc', params) 37 def accel_crypto_key_create(client, cipher, key, key2, tweak_mode, name): argument 57 return client.call('accel_crypto_key_create', params) 60 def accel_crypto_key_destroy(client, key_name): argument 70 return client.call('accel_crypto_key_destroy', params) [all …]
H A D	__init__.py	39 from . import client as rpc_client 42 def framework_start_init(client): 44 return client.call('framework_start_init') 47 def framework_wait_init(client): 49 return client.call('framework_wait_init') 52 def framework_disable_cpumask_locks(client): 54 return client.call('framework_disable_cpumask_locks') 57 def framework_enable_cpumask_locks(client): 59 return client.call('framework_enable_cpumask_locks') 62 def rpc_get_methods(client, curren 41 framework_start_init(client) global() argument 46 framework_wait_init(client) global() argument 51 framework_disable_cpumask_locks(client) global() argument 56 framework_enable_cpumask_locks(client) global() argument 61 rpc_get_methods(client, current=None, include_aliases=None) global() argument 77 spdk_get_version(client) global() argument 102 save_config(client, fd, indent=2) global() argument 123 load_config(client, fd, include_aliases=False) global() argument 177 save_subsystem_config(client, fd, indent=2, name=None) global() argument 192 load_subsystem_config(client, fd) global() argument [all...]
H A D	log.py	`6 def log_set_flag(client, flag): argument 13 return client.call('log_set_flag', params) 16 def log_clear_flag(client, flag): argument 23 return client.call('log_clear_flag', params) 26 def log_get_flags(client): argument 32 return client.call('log_get_flags') 35 def log_set_level(client, level): argument 42 return client.call('log_set_level', params) 45 def log_get_level(client): argument 51 return client.call('log_get_level') [all …]`
H A D	trace.py	6 def trace_enable_tpoint_group(client, name): argument 13 return client.call('trace_enable_tpoint_group', params) 16 def trace_disable_tpoint_group(client, name): argument 23 return client.call('trace_disable_tpoint_group', params) 26 def trace_set_tpoint_mask(client, name, tpoint_mask): argument 35 return client.call('trace_set_tpoint_mask', params) 38 def trace_clear_tpoint_mask(client, name, tpoint_mask): argument 47 return client.call('trace_clear_tpoint_mask', params) 50 def trace_get_tpoint_group_mask(client): argument 56 return client.call('trace_get_tpoint_group_mask') [all …]
H A D	ublk.py	6 def ublk_create_target(client, cpumask=None, disable_user_copy=None): argument 12 return client.call('ublk_create_target', params) 15 def ublk_destroy_target(client): argument 16 return client.call('ublk_destroy_target') 19 def ublk_start_disk(client, bdev_name, ublk_id=1, num_queues=1, queue_depth=128): argument 28 return client.call('ublk_start_disk', params) 31 def ublk_stop_disk(client, ublk_id=1): argument 33 return client.call('ublk_stop_disk', params) 36 def ublk_recover_disk(client, bdev_name, ublk_id): argument 41 return client 44 ublk_get_disks(client, ublk_id=1) global() argument [all...]
H A D	vfio_user.py	6 def vfu_tgt_set_base_path(client, path): argument 16 return client.call('vfu_tgt_set_base_path', params) 19 def vfu_virtio_delete_endpoint(client, name): argument 29 return client.call('vfu_virtio_delete_endpoint', params) 32 def vfu_virtio_create_blk_endpoint(client, name, bdev_name, cpumask, num_queues, qsize, packed_ring): argument 56 return client.call('vfu_virtio_create_blk_endpoint', params) 59 def vfu_virtio_scsi_add_target(client, name, scsi_target_num, bdev_name): argument 73 return client.call('vfu_virtio_scsi_add_target', params) 76 def vfu_virtio_scsi_remove_target(client, name, scsi_target_num): argument 88 return client 91 vfu_virtio_create_scsi_endpoint(client, name, cpumask, num_io_queues, qsize, packed_ring) global() argument [all...]
H A D	nvme.py	6 def bdev_nvme_send_cmd(client, name, cmd_type, data_direction, cmdbuf, argument 42 return client.call('bdev_nvme_send_cmd', params) 45 def bdev_nvme_get_controllers(client, name=None): argument 57 return client.call('bdev_nvme_get_controllers', params) 60 def bdev_nvme_opal_init(client, nvme_ctrlr_name, password): argument 72 return client.call('bdev_nvme_opal_init', params) 75 def bdev_nvme_opal_revert(client, nvme_ctrlr_name, password): argument 87 return client.call('bdev_nvme_opal_revert', params) 90 def bdev_nvme_add_error_injection(client, name, opc, cmd_type, do_not_submit, timeout_in_us, argument 122 return client.call('bdev_nvme_add_error_injection', params) [all …]
H A D	keyring.py	`5 def keyring_file_add_key(client, name, path): argument 6 return client.call('keyring_file_add_key', {'name': name, 10 def keyring_file_remove_key(client, name): argument 11 return client.call('keyring_file_remove_key', {'name': name}) 14 def keyring_get_keys(client): argument 15 return client.call('keyring_get_keys') 18 def keyring_linux_set_options(client, enable=None): argument 22 return client.call('keyring_linux_set_options', params)`
H A D	blobfs.py	`6 def blobfs_detect(client, bdev_name): argument 18 return client.call('blobfs_detect', params) 21 def blobfs_create(client, bdev_name, cluster_sz=None): argument 33 return client.call('blobfs_create', params) 36 def blobfs_mount(client, bdev_name, mountpoint): argument 47 return client.call('blobfs_mount', params) 50 def blobfs_set_cache_size(client, size_in_mb): argument 62 return client.call('blobfs_set_cache_size', params)`
H A D	sock.py	`6 def sock_impl_get_options(client, impl_name=None): argument 16 return client.call('sock_impl_get_options', params) 19 def sock_impl_set_options(client, argument 70 return client.call('sock_impl_set_options', params) 73 def sock_set_default_impl(client, impl_name=None): argument 83 return client.call('sock_set_default_impl', params) 86 def sock_get_default_impl(client): argument 89 return client.call('sock_get_default_impl')`
H A D	dpdk_cryptodev.py	`6 def dpdk_cryptodev_scan_accel_module(client): argument 9 return client.call('dpdk_cryptodev_scan_accel_module') 12 def dpdk_cryptodev_set_driver(client, driver_name): argument 20 return client.call('dpdk_cryptodev_set_driver', params) 23 def dpdk_cryptodev_get_driver(client): argument 26 return client.call('dpdk_cryptodev_get_driver')`
/spdk/lib/jsonrpc/
H A D	jsonrpc_client_tcp.c	13 jsonrpc_client_send_request(struct spdk_jsonrpc_client client) in jsonrpc_client_send_request() argument 16 struct spdk_jsonrpc_client_request request = client->request; in jsonrpc_client_send_request() 23 rc = send(client->sockfd, request->send_buf + request->send_offset, in jsonrpc_client_send_request() 42 client->request = NULL; in jsonrpc_client_send_request() 50 recv_buf_expand(struct spdk_jsonrpc_client client) in recv_buf_expand() argument 54 if (client->recv_buf_size 2 > SPDK_JSONRPC_SEND_BUF_SIZE_MAX) { in recv_buf_expand() 58 new_buf = realloc(client->recv_buf, client->recv_buf_size * 2); in recv_buf_expand() 61 client->recv_buf_size, client->recv_buf_size * 2); in recv_buf_expand() 65 client->recv_buf = new_buf; in recv_buf_expand() 66 client->recv_buf_size *= 2; in recv_buf_expand() [all …]
/spdk/python/spdk/spdkcli/
H A D	ui_root.py	`16 def __init__(self, client, shell): argument 24 self.set_rpc_target(client) 52 def set_rpc_target(self, client): argument 53 self.client = client 64 self.client.log_set_level("INFO" if self.verbose else "ERROR") 66 self.client.log_set_level("ERROR") 82 if rpc.framework_start_init(self.client): 88 rpc.load_config(self.client, fd) 92 rpc.load_subsystem_config(self.client, f [all...]`
/spdk/python/spdk/sma/device/
H A D	nvmf_vfiouser.py	`13 from spdk.rpc.client import JSONRPCException 26 def __init__(self, client): argument 27 super().__init__('vfiouser', 'nvme', client) 52 with self._client() as client: 53 transports = client.call('nvmf_get_transports') 57 return client.call('nvmf_create_transport', {'trtype': 'vfiouser'}) 65 with self._client() as client: 66 yield client 71 def _get_subsys(self, client, nqn): argument 73 return client.call('nvmf_get_subsystems', {'nqn': nqn})[0] [all …]`
H A D	nvmf_tcp.py	`8 from spdk.rpc.client import JSONRPCException 18 def __init__(self, client): argument 19 super().__init__('nvmf_tcp', 'nvmf_tcp', client) 26 with self._client() as client: 27 transports = client.call('nvmf_get_transports') 32 return client.call('nvmf_create_transport', 66 with self._client() as client: 68 subsystems = client.call('nvmf_get_subsystems') 74 result = client.call('nvmf_create_subsystem', 83 client.call('nvmf_subsystem_add_host', [all …]`
H A D	vhost_blk.py	11 from spdk.rpc.client import JSONRPCException 22 def __init__(self, client): argument 23 super().__init__('vhost_blk', 'virtio_blk', client, allow_delete_volumes=True) 46 def _find_controller(self, client, controller): argument 48 ctrlrs = client.call('vhost_get_controllers') 74 def _delete_controller(self, client, ctrlr): argument 75 if self._find_controller(client, ctrlr) is None: 78 return client.call('vhost_delete_controller', {'ctrlr': ctrlr}) 83 def _find_bdev(self, client, guid): argument 86 return client.call('bdev_get_bdevs', {'name': bdev_name})[0] [all …]
/spdk/test/json_config/
H A D	clear_config.py	12 from spdk.rpc.client import print_dict, JSONRPCException 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) 87 args.client.call(destroy_method, {'nqn': nvmf['params']['nqn']}) 117 args.client.call(destroy_method, {get_iscsi_name_key(iscsi): get_iscsi_name(iscsi)}) 130 args.client.call(destroy_method, {'nbd_device': nbd['params']['nbd_device']}) 142 args.client.call(destroy_method, {'ublk_device': ublk['params']['ublk_device']}) [all …]
/spdk/scripts/
H A D	sma.py	`20 import spdk.rpc.client as rpcclient # noqa 74 def init_crypto(config, client): argument 84 sma.get_crypto_engine().init(client, crypto_config.get('params', {})) 90 def load_plugins(plugins, client): argument 96 devices.append(device(client)) 104 def wait_for_listen(client, timeout): argument 108 with client() as _client: 140 client = get_build_client(config['socket']) variable 143 wait_for_listen(client, timeout=60.0) 145 agent = sma.StorageManagementAgent(config, client) [all …]`
/spdk/test/rpc_client/
H A D	rpc_client_test.c	27 _rpc_client_wait_for_response(struct spdk_jsonrpc_client client) in _rpc_client_wait_for_response() argument 32 rc = spdk_jsonrpc_client_poll(client, 1); in _rpc_client_wait_for_response() 51 spdk_jsonrpc_client_check_rpc_method(struct spdk_jsonrpc_client client, char method_name) in spdk_jsonrpc_client_check_rpc_method() argument 66 spdk_jsonrpc_client_send_request(client, request); in spdk_jsonrpc_client_check_rpc_method() 68 rc = _rpc_client_wait_for_response(client); in spdk_jsonrpc_client_check_rpc_method() 73 json_resp = spdk_jsonrpc_client_get_response(client); in spdk_jsonrpc_client_check_rpc_method() 117 spdk_jsonrpc_client_check_null_params_method(struct spdk_jsonrpc_client client) in spdk_jsonrpc_client_check_null_params_method() argument 134 spdk_jsonrpc_client_send_request(client, request); in spdk_jsonrpc_client_check_null_params_method() 136 rc = _rpc_client_wait_for_response(client); in spdk_jsonrpc_client_check_null_params_method() 141 json_resp = spdk_jsonrpc_client_get_response(client); in spdk_jsonrpc_client_check_null_params_method() [all …]

12 3 4