| /spdk/python/spdk/rpc/ |
| H A D | bdev.py | 19 params = dict()
21 params['bdev_io_pool_size'] = bdev_io_pool_size
23 params['bdev_io_cache_size'] = bdev_io_cache_size
25 params['bdev_auto_examine'] = bdev_auto_examine
27 params['iobuf_small_cache_size'] = iobuf_small_cache_size
29 params['iobuf_large_cache_size'] = iobuf_large_cache_size
30 return client.call('bdev_set_options', params)
39 params = dict()
40 params['name'] = name
41 return client.call('bdev_examine', params)
[all...] |
| H A D | nvmf.py | 18 params = {}
20 params['max_subsystems'] = max_subsystems
21 return client.call('nvmf_set_max_subsystems', params)
38 params = {}
43 params['admin_cmd_passthru'] = admin_cmd_passthru
45 params['poll_groups_mask'] = poll_groups_mask
47 params['discovery_filter'] = discovery_filter
49 params['dhchap_digests'] = dhchap_digests
51 params['dhchap_dhgroups'] = dhchap_dhgroups
53 return client.call('nvmf_set_config', params)
105 nvmf_create_transport(client, **params) global() argument
256 nvmf_subsystem_add_listener(client, **params) global() argument
371 nvmf_discovery_add_referral(client, **params) global() argument
459 nvmf_subsystem_add_ns(client, **params) global() argument
[all...] |
| H A D | iscsi.py | 59 params = {}
62 params['auth_file'] = auth_file
64 params['node_base'] = node_base
66 params['nop_timeout'] = nop_timeout
68 params['nop_in_interval'] = nop_in_interval
70 params['disable_chap'] = disable_chap
72 params['require_chap'] = require_chap
74 params['mutual_chap'] = mutual_chap
76 params['chap_group'] = chap_group
78 params['max_sessions'] = max_sessions
[all …]
|
| H A D | lvol.py | 23 params = {'bdev_name': bdev_name, 'lvs_name': lvs_name}
25 params['cluster_sz'] = cluster_sz
27 params['clear_method'] = clear_method
29 params['num_md_pages_per_cluster_ratio'] = num_md_pages_per_cluster_ratio
31 params['md_page_size'] = md_page_size
32 return client.call('bdev_lvol_create_lvstore', params)
42 params = {
46 return client.call('bdev_lvol_rename_lvstore', params)
58 params = {}
60 params['uui
[all...] |
| H A D | vhost.py | 15 params = {
20 return client.call('vhost_controller_set_coalescing', params)
32 params = {}
35 params['name'] = name
37 return client.call('virtio_blk_get_transports', params)
40 def virtio_blk_create_transport(client, **params): argument
45 strip_globals(params)
46 remove_null(params)
48 return client.call('virtio_blk_create_transport', params)
58 params = {'ctrlr': ctrlr, 'delay': delay}
[all …]
|
| H A D | nvme.py | 26 params = {'name': name,
32 params['data'] = data
34 params['metadata'] = metadata
36 params['data_len'] = data_len
38 params['metadata_len'] = metadata_len
40 params['timeout_ms'] = timeout_ms
42 return client.call('bdev_nvme_send_cmd', params)
54 params = {}
56 params['name'] = name
57 return client.call('bdev_nvme_get_controllers', params)
[all …]
|
| H A D | accel.py | 29 params = {
34 return client.call('accel_assign_opc', params)
47 params = {
53 params['key2'] = key2
55 params['tweak_mode'] = tweak_mode
57 return client.call('accel_crypto_key_create', params)
66 params = {
70 return client.call('accel_crypto_key_destroy', params)
79 params = {}
82 params['key_name'] = key_name
[all …]
|
| H A D | sock.py | 12 params = {}
14 params['impl_name'] = impl_name
16 return client.call('sock_impl_get_options', params)
46 params = {}
48 params['impl_name'] = impl_name
50 params['recv_buf_size'] = recv_buf_size
52 params['send_buf_size'] = send_buf_size
54 params['enable_recv_pipe'] = enable_recv_pipe
56 params['enable_quickack'] = enable_quickack
58 params['enable_placement_id'] = enable_placement_id
[all …]
|
| H A D | vfio_user.py | 12 params = {
16 return client.call('vfu_tgt_set_base_path', params)
25 params = {
29 return client.call('vfu_virtio_delete_endpoint', params)
43 params = {
48 params['cpumask'] = cpumask
50 params['num_queues'] = num_queues
52 params['qsize'] = qsize
54 params['packed_ring'] = packed_ring
56 return client.call('vfu_virtio_create_blk_endpoint', params)
[all...] |
| H A D | ublk.py | 7 params = {}
9 params['cpumask'] = cpumask
11 params['disable_user_copy'] = True
12 return client.call('ublk_create_target', params)
20 params = {
25 params['num_queues'] = num_queues
27 params['queue_depth'] = queue_depth
28 return client.call('ublk_start_disk', params)
32 params = {'ublk_id': ublk_id}
33 return client.call('ublk_stop_disk', params)
[all...] |
| H A D | app.py | 12 params = {'sig_name': sig_name}
13 return client.call('spdk_kill_instance', params)
25 params = {}
27 params['enabled'] = enabled
28 return client.call('framework_monitor_context_switch', params)
50 params = {'name': name}
52 params['period'] = period
54 params['load_limit'] = load_limit
56 params['core_limit'] = core_limit
58 params['core_bus
[all...] |
| H A D | blobfs.py | 15 params = {
18 return client.call('blobfs_detect', params)
28 params = {
32 params['cluster_sz'] = cluster_sz
33 return client.call('blobfs_create', params)
43 params = {
47 return client.call('blobfs_mount', params)
59 params = {
62 return client.call('blobfs_set_cache_size', params)
|
| H A D | nbd.py | 7 params = {
11 params['nbd_device'] = nbd_device
12 return client.call('nbd_start_disk', params)
16 params = {'nbd_device': nbd_device}
17 return client.call('nbd_stop_disk', params)
21 params = {}
23 params['nbd_device'] = nbd_device
24 return client.call('nbd_get_disks', params)
|
| H A D | trace.py | 12 params = {'name': name}
13 return client.call('trace_enable_tpoint_group', params)
22 params = {'name': name}
23 return client.call('trace_disable_tpoint_group', params)
34 params = {'name': name, 'tpoint_mask': tpoint_mask}
35 return client.call('trace_set_tpoint_mask', params)
46 params = {'name': name, 'tpoint_mask': tpoint_mask}
47 return client.call('trace_clear_tpoint_mask', params)
|
| H A D | log.py | 12 params = {'flag': flag}
13 return client.call('log_set_flag', params)
22 params = {'flag': flag}
23 return client.call('log_clear_flag', params)
41 params = {'level': level}
42 return client.call('log_set_level', params)
60 params = {'level': level}
61 return client.call('log_set_print_level', params)
|
| H A D | iobuf.py | 16 params = {}
19 params['small_pool_count'] = small_pool_count
21 params['large_pool_count'] = large_pool_count
23 params['small_bufsize'] = small_bufsize
25 params['large_bufsize'] = large_bufsize
27 params['enable_numa'] = enable_numa
29 return client.call('iobuf_set_options', params)
|
| /spdk/test/unit/lib/reduce/reduce.c/ |
| H A D | reduce_ut.c | 95 struct spdk_reduce_vol_params params; in get_pm_file_size()
98 params.backing_io_unit_size = 4096; in get_pm_file_size()
99 params.chunk_size = 4096 * 4; in get_pm_file_size()
100 params.vol_size = 4096 * 4 * 100; in get_pm_file_size()
102 pm_size = _get_pm_file_size(¶ms); in get_pm_file_size()
203 struct spdk_reduce_vol_params params = {}; in init_failure()
212 params.vol_size = 0; in init_failure()
213 params.chunk_size = 16 * 1024; in init_failure()
214 params.backing_io_unit_size = backing_dev.blocklen; in init_failure()
215 params in init_failure()
93 struct spdk_reduce_vol_params params; get_pm_file_size() local
201 struct spdk_reduce_vol_params params = {}; init_failure() local
528 backing_dev_init(struct spdk_reduce_backing_dev * backing_dev,struct spdk_reduce_vol_params * params,uint32_t backing_blocklen) backing_dev_init() argument
554 struct spdk_reduce_vol_params params = {}; init_md() local
605 struct spdk_reduce_vol_params params = {}; _init_backing_dev() local
652 struct spdk_reduce_vol_params params = {}; _load() local
724 struct spdk_reduce_vol_params params = {}; _write_maps() local
822 struct spdk_reduce_vol_params params = {}; _read_write() local
983 struct spdk_reduce_vol_params params = {}; _readv_writev() local
1028 struct spdk_reduce_vol_params params = {}; destroy() local
1077 struct spdk_reduce_vol_params params = {}; defer_bdev_io() local
1138 struct spdk_reduce_vol_params params = {}; overlapped() local
[all...] |
| /spdk/lib/iscsi/ |
| H A D | param.h | 35 void iscsi_param_free(struct iscsi_param *params);
37 iscsi_param_find(struct iscsi_param *params, const char *key);
38 int iscsi_param_del(struct iscsi_param **params, const char *key);
39 int iscsi_param_add(struct iscsi_param **params, const char *key,
41 int iscsi_param_set(struct iscsi_param *params, const char *key,
43 int iscsi_param_set_int(struct iscsi_param *params, const char *key, uint32_t val);
44 int iscsi_parse_params(struct iscsi_param **params, const uint8_t *data,
46 char *iscsi_param_get_val(struct iscsi_param *params, const char *key);
47 int iscsi_param_eq_val(struct iscsi_param *params, const char *key,
55 int iscsi_conn_params_init(struct iscsi_param **params);
[all …]
|
| H A D | param.c | 26 iscsi_param_free(struct iscsi_param *params) in iscsi_param_free() argument
30 if (params == NULL) { in iscsi_param_free()
33 for (param = params; param != NULL; param = next_param) { in iscsi_param_free()
58 iscsi_param_find(struct iscsi_param *params, const char *key) in iscsi_param_find() argument
62 if (params == NULL || key == NULL) { in iscsi_param_find()
65 for (param = params; param != NULL; param = param->next) { in iscsi_param_find()
75 iscsi_param_del(struct iscsi_param **params, const char *key) in iscsi_param_del() argument
80 if (params == NULL || key == NULL) { in iscsi_param_del()
83 for (param = *params; param != NULL; param = param->next) { in iscsi_param_del()
89 *params = param->next; in iscsi_param_del()
[all …]
|
| /spdk/go/rpc/client/ |
| H A D | client_test.go | 15 params any
19 params: nil,
23 params: &struct{}{},
27 params: [3]string{"a", "b", "c"},
31 params: map[string]int{"a": 1, "b": 2, "c": 3},
35 params: []string{"a", "b", "c"},
39 params: struct{}{},
43 params: "invalidParam",
52 gotRequest, err := createRequest(method, requestId, tt.params)
56 Params: tt.params,
|
| /spdk/test/unit/lib/bdev/raid/concat.c/ |
| H A D | concat_ut.c | 200 struct raid_params params = { in test_setup() local
206 if (params.strip_size == 0 || in test_setup()
207 params.strip_size > params.base_bdev_blockcnt) { in test_setup()
210 raid_test_params_add(¶ms); in test_setup()
227 create_concat(struct raid_params *params) in create_concat() argument
229 struct raid_bdev *raid_bdev = raid_test_create_raid_bdev(params, &g_concat_module); in create_concat()
246 struct raid_params *params; in test_concat_start() local
251 RAID_PARAMS_FOR_EACH(params) { in test_concat_start()
252 raid_bdev = create_concat(params); in test_concat_start()
255 for (i = 0; i < params->num_base_bdevs; i++) { in test_concat_start()
[all …]
|
| /spdk/test/unit/lib/iscsi/param.c/ |
| H A D | param_ut.c | 38 struct iscsi_param *params; in burst_length_param_negotiation() local
45 params = NULL; in burst_length_param_negotiation()
46 params_p = ¶ms; in burst_length_param_negotiation()
55 sess.params = NULL; in burst_length_param_negotiation()
62 rc = iscsi_sess_params_init(&sess.params); in burst_length_param_negotiation()
65 rc = iscsi_param_set_int(sess.params, "FirstBurstLength", in burst_length_param_negotiation()
69 rc = iscsi_param_set_int(sess.params, "MaxBurstLength", in burst_length_param_negotiation()
73 rc = iscsi_param_set(sess.params, "InitialR2T", in burst_length_param_negotiation()
81 rc = iscsi_conn_params_init(&conn.params); in burst_length_param_negotiation()
116 iscsi_param_free(sess.params); in burst_length_param_negotiation()
[all …]
|
| /spdk/lib/reduce/ |
| H A D | reduce.c | 35 struct spdk_reduce_vol_params params;
122 struct spdk_reduce_vol_params params;
229 assert(chunk_map_index < _get_total_chunks(vol->params.vol_size, vol->params.chunk_size)); in _validate_vol_params()
239 _validate_vol_params(struct spdk_reduce_vol_params *params) in _validate_vol_params()
241 if (params->vol_size > 0) { in _validate_vol_params()
249 if (params->chunk_size == 0 || params->backing_io_unit_size == 0 ||
250 params->logical_block_size == 0) {
255 if ((params in _get_vol_size()
32 struct spdk_reduce_vol_params params; global() member
116 struct spdk_reduce_vol_params params; global() member
222 _validate_vol_params(struct spdk_reduce_vol_params * params) _validate_vol_params() argument
265 _get_pm_file_size(struct spdk_reduce_vol_params * params) _get_pm_file_size() argument
541 spdk_reduce_vol_init(struct spdk_reduce_vol_params * params,struct spdk_reduce_backing_dev * backing_dev,const char * pm_file_dir,spdk_reduce_vol_op_with_handle_complete cb_fn,void * cb_arg) spdk_reduce_vol_init() argument
[all...] |
| /spdk/test/event/scheduler/ |
| H A D | scheduler_plugin.py | 9 params = {'active': args.active}
11 params['name'] = args.name
13 params['cpu_mask'] = args.cpu_mask
14 return args.client.call('scheduler_thread_create', params)
22 params = {'thread_id': args.thread_id, 'active': args.active}
23 return args.client.call('scheduler_thread_set_active', params)
27 params = {'thread_id': args.thread_id}
28 return args.client.call('scheduler_thread_delete', params)
|
| /spdk/test/rpc_plugins/ |
| H A D | scheduler_plugin.py | 9 params = {'active': args.active}
11 params['name'] = args.name
13 params['cpu_mask'] = args.cpu_mask
14 return args.client.call('scheduler_thread_create', params)
22 params = {'thread_id': args.thread_id, 'active': args.active}
23 return args.client.call('scheduler_thread_set_active', params)
27 params = {'thread_id': args.thread_id}
28 return args.client.call('scheduler_thread_delete', params)
|