Home
last modified time | relevance | path

Searched refs:data (Results 1 – 25 of 143) sorted by relevance

123456

/spdk/module/bdev/ocf/
H A Ddata.c13 struct bdev_ocf_data *data; in vbdev_ocf_data_alloc() local
15 data = env_malloc(sizeof(*data), ENV_MEM_NOIO); in vbdev_ocf_data_alloc()
16 if (!data) { in vbdev_ocf_data_alloc()
20 data->seek = 0; in vbdev_ocf_data_alloc()
23 data->iovs = env_malloc(sizeof(*data->iovs) * iovcnt, ENV_MEM_NOIO); in vbdev_ocf_data_alloc()
24 if (!data->iovs) { in vbdev_ocf_data_alloc()
25 env_free(data); in vbdev_ocf_data_alloc()
30 data->iovcnt = 0; in vbdev_ocf_data_alloc()
31 data->iovalloc = iovcnt; in vbdev_ocf_data_alloc()
33 return data; in vbdev_ocf_data_alloc()
[all …]
H A Dvolume.c13 #include "data.h"
27 base = vbdev_ocf_get_base_by_name(ocf_volume_get_uuid(volume)->data); in vbdev_ocf_volume_open()
150 struct bdev_ocf_data *data = ocf_forward_get_data(token); in vbdev_ocf_volume_submit_io_cb()
163 if (bytes == data->size) { in vbdev_ocf_volume_submit_io_cb()
164 iovs = data->iovs; in vbdev_ocf_volume_submit_io_cb()
165 iovcnt = data->iovcnt; in vbdev_ocf_volume_submit_io_cb()
167 skip = get_starting_vec(data->iovs, data->iovcnt, &offset); in vbdev_ocf_volume_submit_io_cb()
169 SPDK_ERRLOG("Offset bigger than data size\n"); in vbdev_ocf_volume_submit_io_cb()
174 iovcnt = data in vbdev_ocf_volume_submit_io_cb()
55 vbdev_ocf_volume_io_set_data(struct ocf_io * io,ctx_data_t * data,uint32_t offset) vbdev_ocf_volume_io_set_data() argument
[all...]
H A Dctx.c15 #include "data.h"
22 struct bdev_ocf_data *data; in vbdev_ocf_ctx_data_alloc() local
26 data = vbdev_ocf_data_alloc(1); in vbdev_ocf_ctx_data_alloc()
27 if (data == NULL) { in vbdev_ocf_ctx_data_alloc()
35 vbdev_ocf_data_free(data); in vbdev_ocf_ctx_data_alloc()
39 vbdev_ocf_iovs_add(data, buf, sz); in vbdev_ocf_ctx_data_alloc()
41 data->size = sz; in vbdev_ocf_ctx_data_alloc()
43 return data; in vbdev_ocf_ctx_data_alloc()
49 struct bdev_ocf_data *data = ctx_data; in vbdev_ocf_ctx_data_free() local
52 if (!data) { in vbdev_ocf_ctx_data_free()
258 struct bdev_ocf_data *data = ctx_data; vbdev_ocf_ctx_data_secure_erase() local
[all...]
/spdk/test/unit/lib/iscsi/param.c/
H A Dparam_ut.c29 const char *tiqn, uint8_t *data, int alloc_len, int data_len),
40 char data[8192]; in burst_length_param_negotiation() local
50 memset(data, 0, 8192); in burst_length_param_negotiation()
85 len = snprintf(data + total, 8192 - total, "%s=%d", in burst_length_param_negotiation()
89 len = snprintf(data + total, 8192 - total, "%s=%d", in burst_length_param_negotiation()
93 len = snprintf(data + total, 8192 - total, "%s=%d", in burst_length_param_negotiation()
101 rc = iscsi_parse_params(params_p, data, total, false, NULL); in burst_length_param_negotiation()
106 data, 8192, rc); in burst_length_param_negotiation()
162 data = strconst; \
164 rc = iscsi_parse_params(&params, data, len, partial_enabled, partial_text)
[all …]
/spdk/test/unit/lib/nvmf/rdma.c/
H A Drdma_ut.c135 rdma_req->data.wr.num_sge = 0; in reset_nvmf_rdma_request()
136 rdma_req->data.wr.wr.rdma.remote_addr = 0; in reset_nvmf_rdma_request()
137 rdma_req->data.wr.wr.rdma.rkey = 0; in reset_nvmf_rdma_request()
144 rdma_req->data.wr.sg_list[i].addr = 0; in reset_nvmf_rdma_request()
145 rdma_req->data.wr.sg_list[i].length = 0; in reset_nvmf_rdma_request()
146 rdma_req->data.wr.sg_list[i].lkey = 0; in reset_nvmf_rdma_request()
170 struct spdk_nvmf_rdma_request_data data; in test_spdk_nvmf_rdma_request_parse_sgl()
174 data.wr.sg_list = data.sgl; in test_spdk_nvmf_rdma_request_parse_sgl()
184 rdma_req.data in test_spdk_nvmf_rdma_request_parse_sgl()
168 struct spdk_nvmf_rdma_request_data data; test_spdk_nvmf_rdma_request_parse_sgl() local
837 struct spdk_nvmf_rdma_request_data *data = (struct spdk_nvmf_rdma_request_data *)data_buffer; test_spdk_nvmf_rdma_request_parse_sgl_with_md() local
[all...]
/spdk/lib/json/
H A Djson_parse.c426 uint8_t *data = json; in spdk_json_parse() local
446 while (data < json_end) { in spdk_json_parse()
447 uint8_t c = *data; in spdk_json_parse()
455 data++; in spdk_json_parse()
465 rc = match_literal(data, json_end, lit->str, lit->len); in spdk_json_parse()
467 ADD_VALUE(lit->type, data, data + rc); in spdk_json_parse()
468 data += rc; in spdk_json_parse()
475 rc = json_decode_string(data, json_end, &new_data, flags); in spdk_json_parse()
477 data = new_data; in spdk_json_parse()
485 data + 1, data + rc - 1); in spdk_json_parse()
[all …]
/spdk/include/spdk_internal/
H A Dutf.h118 utf8_decode_unsafe_1(const uint8_t *data) in utf8_decode_unsafe_1() argument
120 return data[0]; in utf8_decode_unsafe_1()
124 utf8_decode_unsafe_2(const uint8_t *data) in utf8_decode_unsafe_2() argument
128 codepoint = ((data[0] & 0x1F) << 6); in utf8_decode_unsafe_2()
129 codepoint |= (data[1] & 0x3F); in utf8_decode_unsafe_2()
135 utf8_decode_unsafe_3(const uint8_t *data) in utf8_decode_unsafe_3() argument
139 codepoint = ((data[0] & 0x0F) << 12); in utf8_decode_unsafe_3()
140 codepoint |= (data[1] & 0x3F) << 6; in utf8_decode_unsafe_3()
141 codepoint |= (data[2] & 0x3F); in utf8_decode_unsafe_3()
147 utf8_decode_unsafe_4(const uint8_t *data) in utf8_decode_unsafe_4() argument
[all …]
/spdk/test/unit/lib/scsi/scsi_bdev.c/
H A Dscsi_bdev_ut.c82 uint8_t *cdb, uint8_t *data, uint16_t data_len), 0);
85 uint8_t *data, uint16_t data_len), 0);
322 char data[24]; in mode_select_6_test() local
340 memset(data, 0, sizeof(data)); in mode_select_6_test()
341 data[4] = 0x08; in mode_select_6_test()
342 data[5] = 0x02; in mode_select_6_test()
343 spdk_scsi_task_set_data(&task, data, sizeof(data)); in mode_select_6_test()
400 unsigned char *data; in mode_sense_6_test() local
424 data = task.iovs[0].iov_base; in mode_sense_6_test()
425 mode_data_len = data[0]; in mode_sense_6_test()
[all …]
/spdk/test/app/fuzz/llvm_vfio_fuzz/
H A Dllvm_vfio_fuzz.c26 typedef int (*fuzzer_fn)(const uint8_t *data, size_t size, struct vfio_device *dev);
70 fuzz_vfio_user_version(const uint8_t *data, size_t size, struct vfio_device *dev) in fuzz_vfio_user_version() argument
74 version->major = ((uint16_t)data[0] << 8) + (uint16_t)data[1]; in fuzz_vfio_user_version()
75 version->minor = ((uint16_t)data[2] << 8) + (uint16_t)data[3]; in fuzz_vfio_user_version()
83 fuzz_vfio_user_region_rw(const uint8_t *data, size_t size, struct vfio_device *dev) in fuzz_vfio_user_region_rw() argument
88 offset = ((uint64_t)data[0] << 8) + (uint64_t)data[1]; in fuzz_vfio_user_region_rw()
90 memcpy(buf, &data[ in fuzz_vfio_user_region_rw()
102 fuzz_vfio_user_get_region_info(const uint8_t * data,size_t size,struct vfio_device * dev) fuzz_vfio_user_get_region_info() argument
123 fuzz_vfio_user_dma_map(const uint8_t * data,size_t size,struct vfio_device * dev) fuzz_vfio_user_dma_map() argument
143 fuzz_vfio_user_dma_unmap(const uint8_t * data,size_t size,struct vfio_device * dev) fuzz_vfio_user_dma_unmap() argument
170 fuzz_vfio_user_irq_set(const uint8_t * data,size_t size,struct vfio_device * dev) fuzz_vfio_user_irq_set() argument
189 fuzz_vfio_user_set_msix(const uint8_t * data,size_t size,struct vfio_device * dev) fuzz_vfio_user_set_msix() argument
219 TestOneInput(const uint8_t * data,size_t size) TestOneInput() argument
[all...]
/spdk/lib/scsi/
H A Dport.c80 struct spdk_scsi_iscsi_transport_id *data; in spdk_scsi_port_set_iscsi_transport_id() local
87 data = (struct spdk_scsi_iscsi_transport_id *)port->transport_id; in spdk_scsi_port_set_iscsi_transport_id()
89 data->protocol_id = (uint8_t)SPDK_SPC_PROTOCOL_IDENTIFIER_ISCSI; in spdk_scsi_port_set_iscsi_transport_id()
90 data->format = 0x1; in spdk_scsi_port_set_iscsi_transport_id()
92 name = data->name; in spdk_scsi_port_set_iscsi_transport_id()
93 len = snprintf(name, SPDK_SCSI_MAX_TRANSPORT_ID_LENGTH - sizeof(*data), in spdk_scsi_port_set_iscsi_transport_id()
104 to_be16(&data->additional_len, len); in spdk_scsi_port_set_iscsi_transport_id()
105 port->transport_id_len = len + sizeof(*data); in spdk_scsi_port_set_iscsi_transport_id()
H A Dscsi_bdev.c58 int sel, uint8_t *data, int alloc_len) in bdev_scsi_report_luns() argument
80 memset(data, 0, 4); in bdev_scsi_report_luns()
83 memset(&data[4], 0, 4); in bdev_scsi_report_luns()
97 to_be64(&data[hlen + len], fmt_lun); in bdev_scsi_report_luns()
102 to_be32(data, len); in bdev_scsi_report_luns()
123 uint8_t *cdb, uint8_t *data, uint16_t alloc_len) in bdev_scsi_inquiry() argument
159 struct spdk_scsi_vpd_page *vpage = (struct spdk_scsi_vpd_page *)data; in bdev_scsi_inquiry()
480 memset(&data[4], 0, 60); in bdev_scsi_inquiry()
494 data[5] = (uint8_t)blocks; in bdev_scsi_inquiry()
504 to_be16(&data[6], optimal_blocks); in bdev_scsi_inquiry()
[all …]
/spdk/scripts/perf/nvmf/
H A Dcommon.py16 data = json.load(json_data)
17 job_data = data["jobs"][0] # 0 because using aggregated results, fio group reporting
139 # Filter out data from DCMI sensors and socket/dram sensors
145 # of power consumption data. If not, use SDR sensors data if available. If SDR sensors are not available,
149 logging.warning("No DCMI or SDR data found for %s, using socket and dram data sensors as a fallback" % job_name)
/spdk/scripts/perf/nvme/
H A Drun_fio_test.py73 data = json.load(json_file)
74 job_name = data['jobs'][job_pos]['jobname']
76 if 'lat_ns' in data['jobs'][job_pos]['read']:
82 read_iops = float(data['jobs'][job_pos]['read']['iops'])
83 read_bw = float(data['jobs'][job_pos]['read']['bw'])
84 read_avg_lat = float(data['jobs'][job_pos]['read'][lat]['mean'])
85 read_min_lat = float(data['jobs'][job_pos]['read'][lat]['min'])
86 read_max_lat = float(data['jobs'][job_pos]['read'][lat]['max'])
87 write_iops = float(data['jobs'][job_pos]['write']['iops'])
88 write_bw = float(data['jobs'][job_pos]['write']['bw'])
[all …]
/spdk/lib/ftl/utils/
H A Dftl_md.c57 md->data = spdk_zmalloc(md->data_blocks * (FTL_BLOCK_SIZE + vss_blksz), FTL_BLOCK_SIZE, NULL, in ftl_md_create_spdk_buf()
60 if (md->data && vss_blksz) { in ftl_md_create_spdk_buf()
61 md->vss_data = ((char *)md->data) + md->data_blocks * FTL_BLOCK_SIZE; in ftl_md_create_spdk_buf()
70 md->data = calloc(md->data_blocks, FTL_BLOCK_SIZE + vss_blksz); in ftl_md_create_heap()
72 if (md->data && vss_blksz) { in ftl_md_create_heap()
73 md->vss_data = ((char *)md->data) + md->data_blocks * FTL_BLOCK_SIZE; in ftl_md_create_heap()
80 if (md->data) { in ftl_md_destroy_spdk_buf()
81 spdk_free(md->data); in ftl_md_destroy_spdk_buf()
82 md->data = NULL; in ftl_md_destroy_spdk_buf()
90 if (md->data) { in ftl_md_destroy_heap()
1029 void *data = md->io.data; pattern_prepare() local
[all...]
/spdk/test/thread/lock/
H A Dspdk_lock.c128 struct contend_worker_data *data = arg; in contend_worker_fn() local
130 const uint32_t mask = 1 << data->bit; in contend_worker_fn()
135 data->wait_time += timediff(&ts0, &ts1); in contend_worker_fn()
137 switch (data->increments & 0x1) { in contend_worker_fn()
149 data->increments++; in contend_worker_fn()
150 spdk_delay_us(data->delay_us); in contend_worker_fn()
152 if (data->increments == g_get_lock_times) { in contend_worker_fn()
154 spdk_poller_unregister(&data->poller); in contend_worker_fn()
155 assert(data->poller == NULL); in contend_worker_fn()
160 data->hold_time += timediff(&ts1, &ts2); in contend_worker_fn()
[all …]
/spdk/test/app/fuzz/iscsi_fuzz/
H A Discsi_fuzz.c143 if (pdu->data) { in iscsi_put_pdu()
144 free(pdu->data); in iscsi_put_pdu()
219 dump_iscsi_cmd(void *ctx, const void *data, size_t size) in dump_iscsi_cmd() argument
221 fprintf(stderr, "%s\n", (const char *)data); in dump_iscsi_cmd()
454 if (data_len != 0 && pdu->data == NULL) { in iscsi_fuzz_read_pdu()
455 pdu->data = calloc(1, data_len); in iscsi_fuzz_read_pdu()
456 if (pdu->data == NULL) { in iscsi_fuzz_read_pdu()
535 req_pdu->data = calloc(1, 8192); in fuzz_iscsi_send_login_request()
536 assert(req_pdu->data != NULL); in fuzz_iscsi_send_login_request()
566 req_pdu->data, req_pdu->data_buf_len, req_pdu->data_segment_len); in fuzz_iscsi_send_login_request()
[all …]
/spdk/test/json_config/
H A Dconfig_filter.py55 data = json.loads(sys.stdin.read())
57 for s in data['subsystems']:
76 data = json.loads(sys.stdin.read())
77 if not data:
80 for s in data['subsystems']:
/spdk/test/unit/lib/util/iov.c/
H A Diov_ut.c16 uint8_t *data = buf; in _check_val() local
19 if (data[i] != val) { in _check_val()
288 uint8_t data[64] = { 0 }; in test_iov_xfer() local
308 spdk_iov_xfer_to_buf(&ix, data, 8); in test_iov_xfer()
309 spdk_iov_xfer_to_buf(&ix, data + 8, 56); in test_iov_xfer()
311 for (i = 0; i < sizeof(data); i++) { in test_iov_xfer()
312 CU_ASSERT(data[i] == i); in test_iov_xfer()
315 for (i = 0; i < sizeof(data); i++) { in test_iov_xfer()
316 data[i] = sizeof(data) - i; in test_iov_xfer()
321 spdk_iov_xfer_from_buf(&ix, data, 5); in test_iov_xfer()
[all …]
/spdk/lib/iscsi/
H A Dparam.c189 iscsi_parse_param(struct iscsi_param **params, const uint8_t *data, uint32_t data_len) in iscsi_parse_param() argument
197 data_len = strnlen(data, data_len); in iscsi_parse_param()
199 key_end = memchr(data, '=', data_len); in iscsi_parse_param()
205 key_len = key_end - data; in iscsi_parse_param()
224 memcpy(key_copy, data, key_len); in iscsi_parse_param()
284 iscsi_parse_params(struct iscsi_param **params, const uint8_t *data, in iscsi_parse_params() argument
299 assert(data != NULL); in iscsi_parse_params()
303 for (i = 0; i < len && data[i] != '\0'; i++) { in iscsi_parse_params()
306 p = spdk_sprintf_alloc("%s%s", *partial_parameter, (const char *)data); in iscsi_parse_params()
318 data = data + i + 1; in iscsi_parse_params()
[all …]
H A Dmd5.c
/spdk/app/spdk_top/
H A DREADME13 threads, pollers, execution times, and relations between those. All data
52 since previous data refresh. Options windows provide hotkeys list
63 - [s] Sorting - change data sorting:
64 Use arrow up / down to select based on which column data should be
67 - [r] Refresh rate - change data refresh rate:
68 Enter new data refresh rate value. Refresh rate accepts value
72 Page indicator show current data page. Error status can be displayed
/spdk/doc/
H A Dcompression.md20 to realize savings from the compression. In these cases, the data may be stored uncompressed on
31 The backing storage device must be sized for the worst case scenario, where no data can be
33 compressed block device. Since this algorithm ensures atomicity by never overwriting data
34 in place, some additional backing storage is required to temporarily store data for writes in
42 A compressed block device compresses and decompresses data in units of chunks, where a chunk is a
115 * Compress the incoming 16KB of data into this allocated buffer
116 * Assume this data compresses to 6KB. This requires 2 4KB backing IO units.
120 * Write the 6KB of data to backing IO units 0 and 1.
123 store the 16KB of data.
149 source data.
[all …]
/spdk/test/spdkcli/
H A Dspdkcli_job.py52 data = line.strip() variable
54 cmd = p.findall(data)
55 if data[-1] != "\'":
56 cmd.append(data.rsplit(" ", 1)[1].strip())
/spdk/include/spdk/
H A Dvfio_user_spec.h58 uint8_t data[]; member
76 char data[]; member
106 uint8_t data[]; member
112 uint8_t data[]; member
/spdk/lib/util/
H A Dcrc16.c586 crc_update_fast(uint16_t crc, const void *data, size_t data_len) in crc_update_fast() argument
588 const unsigned char *d = (const unsigned char *)data; in crc_update_fast()
620 const uint8_t *data = (const uint8_t *)buf; in crc16_table_t10dif() local
623 crc = crc_update_fast(crc, data, len); in crc16_table_t10dif()

123456