| /spdk/module/bdev/nvme/ |
| H A D | nvme_rpc.c | 26 uint32_t data_len; member 75 if (req->data_len) { in rpc_bdev_nvme_send_cmd_resp_construct() 76 resp->data_text = malloc(spdk_base64_get_encoded_strlen(req->data_len) + 1); in rpc_bdev_nvme_send_cmd_resp_construct() 80 spdk_base64_urlsafe_encode(resp->data_text, req->data, req->data_len); in rpc_bdev_nvme_send_cmd_resp_construct() 186 req->data_len, req->timeout_ms); in rpc_bdev_nvme_send_cmd_exec() 190 req->data_len, req->md, req->md_len, req->timeout_ms); in rpc_bdev_nvme_send_cmd_exec() 284 if (req->data_len) { in rpc_decode_data() 286 if (req->data_len != spdk_base64_get_decoded_len(text_strlen)) { in rpc_decode_data() 291 req->data_len = spdk_base64_get_decoded_len(text_strlen); in rpc_decode_data() 292 req->data = spdk_malloc(req->data_len > 0x1000 ? req->data_len : 0x1000, 0x1000, in rpc_decode_data() [all …]
|
| /spdk/include/spdk_internal/ |
| H A D | sgl.h | 75 spdk_iov_sgl_append(struct spdk_iov_sgl *s, uint8_t *data, uint32_t data_len) in spdk_iov_sgl_append() argument 77 if (s->iov_offset >= data_len) { in spdk_iov_sgl_append() 78 s->iov_offset -= data_len; in spdk_iov_sgl_append() 82 s->iov->iov_len = data_len - s->iov_offset; in spdk_iov_sgl_append() 83 s->total_size += data_len - s->iov_offset; in spdk_iov_sgl_append()
|
| /spdk/test/bdev/bdevio/ |
| H A D | bdevio.c | 46 int data_len; member 236 req->data_len, quick_test_complete, NULL); in __blockdev_write() 239 req->data_len, quick_test_complete, NULL); in __blockdev_write() 256 req->data_len, quick_test_complete, NULL); in __blockdev_write_zeroes() 273 bdev_bytes_to_blocks(bdev, req->data_len), quick_test_complete, NULL); in __blockdev_compare_and_write() 284 int data_len = req->data_len; in sgl_chop_buffer() local 292 for (; data_len > 0 && req->iovcnt < BUFFER_IOVS; req->iovcnt++) { in sgl_chop_buffer() 293 if (data_len < iov_len) { in sgl_chop_buffer() 294 iov_len = data_len; in sgl_chop_buffer() 301 data_len -= iov_len; in sgl_chop_buffer() [all …]
|
| /spdk/lib/scsi/ |
| H A D | scsi_bdev.c | 1456 __copy_desc(struct spdk_bdev_scsi_split_ctx *ctx, uint8_t *data, size_t data_len) in __copy_desc() argument 1465 if (data_len < 8) { in __copy_desc() 1473 if (desc_data_len > (data_len - 8)) { in __copy_desc() 1475 desc_data_len, data_len); in __copy_desc() 1517 int data_len; in bdev_scsi_unmap() local 1537 data_len = task->iovs[0].iov_len; in bdev_scsi_unmap() 1538 desc_count = __copy_desc(ctx, data, data_len); in bdev_scsi_unmap() 1540 data = spdk_scsi_task_gather_data(task, &data_len); in bdev_scsi_unmap() 1542 desc_count = __copy_desc(ctx, data, data_len); in bdev_scsi_unmap() 1865 int data_len = -1; in bdev_scsi_process_primary() local [all …]
|
| H A D | task.c | 242 uint32_t data_len; in spdk_scsi_task_process_null_lun() local 251 data_len = sizeof(buffer); in spdk_scsi_task_process_null_lun() 253 memset(buffer, 0, data_len); in spdk_scsi_task_process_null_lun() 257 buffer[4] = data_len - 5; in spdk_scsi_task_process_null_lun() 260 if (spdk_scsi_task_scatter_data(task, buffer, spdk_min(allocation_len, data_len)) >= 0) { in spdk_scsi_task_process_null_lun() 261 task->data_transferred = data_len; in spdk_scsi_task_process_null_lun()
|
| H A D | scsi_pr.c | 506 uint8_t *data, uint16_t data_len) in scsi_pr_out() argument 571 uint16_t data_len) in scsi_pr_in_read_keys() argument 583 if (((count + 1) * 8 + sizeof(keys->header)) > data_len) { in scsi_pr_in_read_keys() 596 uint8_t *data, uint16_t data_len) in scsi_pr_in_read_reservations() argument 628 uint8_t *data, uint16_t data_len) in scsi_pr_in_report_capabilities() argument 652 uint8_t *data, uint16_t data_len) in scsi_pr_in_read_full_status() argument 670 if (add_len + sizeof(*desc) + sizeof(param->header) > data_len) { in scsi_pr_in_read_full_status() 685 if (add_len + reg->transport_id_len + sizeof(param->header) > data_len) { in scsi_pr_in_read_full_status() 699 uint8_t *data, uint16_t data_len) in scsi_pr_in() argument 705 if (data_len < sizeof(struct spdk_scsi_pr_in_read_header)) { in scsi_pr_in() [all …]
|
| H A D | scsi_internal.h | 188 int scsi_pr_out(struct spdk_scsi_task *task, uint8_t *cdb, uint8_t *data, uint16_t data_len); 189 int scsi_pr_in(struct spdk_scsi_task *task, uint8_t *cdb, uint8_t *data, uint16_t data_len);
|
| /spdk/lib/iscsi/ |
| H A D | iscsi.c | 109 bin2hex(char *buf, size_t len, const uint8_t *data, size_t data_len) in bin2hex() argument 124 for (idx = 0; idx < data_len; idx++) { in bin2hex() 139 hex2bin(uint8_t *data, size_t data_len, const char *str) in hex2bin() argument 154 if (total >= data_len) { in hex2bin() 183 int data_len; in iscsi_reject() local 189 data_len = 0; in iscsi_reject() 214 data_len += ISCSI_BHS_LEN; in iscsi_reject() 218 memcpy(data + data_len, pdu->ahs, total_ahs_len); in iscsi_reject() 219 data_len += total_ahs_len; in iscsi_reject() 223 memcpy(data + data_len, pd in iscsi_reject() 322 uint32_t data_len = DGET24(pdu->bhs.data_segment_len); iscsi_pdu_calc_data_digest() local 359 iscsi_conn_read_data_segment(struct spdk_iscsi_conn * conn,struct spdk_iscsi_pdu * pdu,uint32_t data_offset,uint32_t data_len) iscsi_conn_read_data_segment() argument 394 _iscsi_sgl_append_with_md(struct spdk_iov_sgl * s,void * buf,uint32_t buf_len,uint32_t data_len,struct spdk_dif_ctx * dif_ctx) _iscsi_sgl_append_with_md() argument 435 uint32_t data_len; iscsi_build_iovs() local 729 iscsi_append_text(const char * key,const char * val,uint8_t * data,int alloc_len,int data_len) iscsi_append_text() argument 756 iscsi_append_param(struct spdk_iscsi_conn * conn,const char * key,uint8_t * data,int alloc_len,int data_len) iscsi_append_param() argument 775 iscsi_auth_params(struct spdk_iscsi_conn * conn,struct iscsi_param * params,const char * method,uint8_t * data,int alloc_len,int data_len) iscsi_auth_params() argument 2329 int data_len; iscsi_pdu_payload_op_text() local 2729 size_t data_len; add_transfer_task() local 3010 uint32_t data_len; iscsi_transfer_in() local 3103 size_t data_len; iscsi_task_response() local 3778 int data_len; iscsi_pdu_payload_op_nopout() local 4630 uint32_t data_len; iscsi_pdu_payload_read() local [all...] |
| H A D | param.c | 189 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() 233 val_len = strnlen(key_end + 1, data_len - key_len - 1); in iscsi_parse_param() 887 int data_len) in iscsi_negotiate_params() argument 902 total = data_len; in iscsi_negotiate_params() 903 if (data_len < 0) { in iscsi_negotiate_params()
|
| H A D | param.h | 52 int alloc_len, int data_len);
|
| H A D | tgt_node.h | 80 const char *tiqn, uint8_t *data, int alloc_len, int data_len);
|
| H A D | iscsi.h | 122 uint32_t data_len; member 458 mobj->data_len = 0; in iscsi_datapool_put()
|
| /spdk/lib/util/ |
| H A D | dif.c | 99 _dif_sgl_append(struct _dif_sgl *s, uint8_t *data, uint32_t data_len) in _dif_sgl_append() argument 103 s->iov->iov_len = data_len; in _dif_sgl_append() 104 s->total_size += data_len; in _dif_sgl_append() 116 _dif_sgl_append_split(struct _dif_sgl *dst, struct _dif_sgl *src, uint32_t data_len) in _dif_sgl_append_split() argument 121 while (data_len != 0) { in _dif_sgl_append_split() 123 buf_len = spdk_min(buf_len, data_len); in _dif_sgl_append_split() 130 data_len -= buf_len; in _dif_sgl_append_split() 339 struct _dif_sgl *src_sgl, uint32_t data_len, in _dif_set_apptag() 345 while (offset < data_len) { 349 buf_len = spdk_min(buf_len, data_len in _dif_get_apptag() 641 _dif_generate_split(struct _dif_sgl * sgl,uint32_t offset_in_block,uint32_t data_len,uint64_t guard,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx) _dif_generate_split() argument 884 _dif_verify_split(struct _dif_sgl * sgl,uint32_t offset_in_block,uint32_t data_len,uint64_t * _guard,uint32_t offset_blocks,const struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) _dif_verify_split() argument 1017 _dif_update_crc32c_split(struct _dif_sgl * sgl,uint32_t offset_in_block,uint32_t data_len,uint32_t crc32c,const struct spdk_dif_ctx * ctx) _dif_update_crc32c_split() argument 1798 spdk_dif_set_md_interleave_iovs(struct iovec * iovs,int iovcnt,struct iovec * buf_iovs,int buf_iovcnt,uint32_t data_offset,uint32_t data_len,uint32_t * _mapped_len,const struct spdk_dif_ctx * ctx) spdk_dif_set_md_interleave_iovs() argument 1850 _dif_sgl_setup_stream(struct _dif_sgl * sgl,uint32_t * _buf_offset,uint32_t * _buf_len,uint32_t data_offset,uint32_t data_len,const struct spdk_dif_ctx * ctx) _dif_sgl_setup_stream() argument 1886 spdk_dif_generate_stream(struct iovec * iovs,int iovcnt,uint32_t data_offset,uint32_t data_len,struct spdk_dif_ctx * ctx) spdk_dif_generate_stream() argument 1930 spdk_dif_verify_stream(struct iovec * iovs,int iovcnt,uint32_t data_offset,uint32_t data_len,struct spdk_dif_ctx * ctx,struct spdk_dif_error * err_blk) spdk_dif_verify_stream() argument 1979 spdk_dif_update_crc32c_stream(struct iovec * iovs,int iovcnt,uint32_t data_offset,uint32_t data_len,uint32_t * _crc32c,const struct spdk_dif_ctx * ctx) spdk_dif_update_crc32c_stream() argument 2015 spdk_dif_get_range_with_md(uint32_t data_offset,uint32_t data_len,uint32_t * _buf_offset,uint32_t * _buf_len,const struct spdk_dif_ctx * ctx) spdk_dif_get_range_with_md() argument 2044 spdk_dif_get_length_with_md(uint32_t data_len,const struct spdk_dif_ctx * ctx) spdk_dif_get_length_with_md() argument [all...] |
| H A D | crc16.c | 586 crc_update_fast(uint16_t crc, const void *data, size_t data_len) in crc_update_fast() argument 589 const unsigned char *d_end = d + data_len; in crc_update_fast() 590 const unsigned char *d_last16 = d + (data_len & ~0x0F); in crc_update_fast()
|
| /spdk/python/spdk/rpc/ |
| H A D | nvme.py | 8 data_len=None, metadata_len=None, argument 35 if data_len: 36 params['data_len'] = data_len
|
| /spdk/test/unit/lib/accel/dpdk_cryptodev.c/ |
| H A D | accel_dpdk_cryptodev_ut.c | 460 CU_ASSERT(g_test_crypto_ops[0]->sym->m_src->data_len == src_iov[0].iov_len); in test_simple_encrypt() 479 CU_ASSERT(g_test_crypto_ops[0]->sym->m_src->data_len == src_iov[0].iov_len); in test_simple_encrypt() 486 CU_ASSERT(g_test_crypto_ops[0]->sym->m_dst->data_len == dst_iov.iov_len); in test_simple_encrypt() 504 CU_ASSERT(mbuf->data_len == src_iov[0].iov_len); in test_simple_encrypt() 509 CU_ASSERT(mbuf->data_len == src_iov[i].iov_len); in test_simple_encrypt() 519 CU_ASSERT(g_test_crypto_ops[0]->sym->m_dst->data_len == dst_iov.iov_len); in test_simple_encrypt() 537 CU_ASSERT(mbuf->data_len == ACCEL_DPDK_CRYPTODEV_MAX_MBUF_LEN); in test_simple_encrypt() 542 CU_ASSERT(mbuf->data_len == ACCEL_DPDK_CRYPTODEV_MAX_MBUF_LEN); in test_simple_encrypt() 581 CU_ASSERT(g_test_crypto_ops[0]->sym->m_src->data_len == src_iov[0].iov_len); in test_simple_decrypt() 600 CU_ASSERT(g_test_crypto_ops[0]->sym->m_src->data_len in test_simple_decrypt() [all...] |
| /spdk/lib/nvme/ |
| H A D | nvme_cuse.c | 67 int data_len; member 122 if (ctx->data_len > 0) { in cuse_nvme_passthru_cmd_cb() 124 out_iov[out_iovcnt].iov_len = ctx->data_len; in cuse_nvme_passthru_cmd_cb() 147 ctx->data_len, ctx->metadata, cuse_nvme_passthru_cmd_cb, (void *)ctx); in cuse_nvme_passthru_cmd_execute() 149 rc = spdk_nvme_ctrlr_cmd_admin_raw(ctrlr, &ctx->nvme_cmd, ctx->data, ctx->data_len, in cuse_nvme_passthru_cmd_execute() 186 ctx->data_len = passthru_cmd->data_len; in cuse_nvme_passthru_cmd_send() 189 if (ctx->data_len > 0) { in cuse_nvme_passthru_cmd_send() 190 ctx->data = spdk_malloc(ctx->data_len, 4096, NULL, SPDK_ENV_LCORE_ID_ANY, SPDK_MALLOC_DMA); in cuse_nvme_passthru_cmd_send() 198 memcpy(ctx->data, data, ctx->data_len); in cuse_nvme_passthru_cmd_send() [all...] |
| H A D | nvme_tcp.c | 507 if (spdk_unlikely(mapped_length < pdu->data_len)) { in _tcp_write_pdu() 508 SPDK_ERRLOG("could not map the whole %u bytes (mapped only %u bytes)\n", pdu->data_len, in _tcp_write_pdu() 550 pdu->data_len > 0) { in tcp_write_pdu() 582 pdu->data_len % SPDK_NVME_TCP_DIGEST_ALIGNMENT != 0)) { in pdu_accel_compute_crc32_done() 644 if (pdu->data_len > 0 && g_nvme_tcp_ddgst[pdu->hdr.common.pdu_type] && in pdu_accel_compute_crc32() 1257 tcp_req->datao += pdu->data_len; in nvme_tcp_pdu_ch_handle() 1351 treq->pdu->data_len = pdu->data_len; 1381 pdu->data_len % SPDK_NVME_TCP_DIGEST_ALIGNMENT != 0 || in _nvme_tcp_pdu_payload_handle() 1382 pdu->data_len ! in _nvme_tcp_pdu_payload_handle() 2022 uint32_t data_len; nvme_tcp_read_pdu() local [all...] |
| /spdk/test/unit/lib/nvme/nvme_cuse.c/ |
| H A D | nvme_cuse_ut.c | 221 CU_ASSERT(g_ut_ctx->data_len == in test_cuse_nvme_submit_io_read_write() 239 CU_ASSERT(g_ut_ctx->data_len == in test_cuse_nvme_submit_io_read_write() 283 CU_ASSERT(g_ut_ctx->data_len == in test_cuse_nvme_submit_io_read_write_with_md() 302 CU_ASSERT(g_ut_ctx->data_len == in test_cuse_nvme_submit_io_read_write_with_md() 332 passthru_cmd->data_len = 512; in test_cuse_nvme_submit_passthru_cmd() 347 CU_ASSERT(g_ut_ctx->data_len == 512); in test_cuse_nvme_submit_passthru_cmd() 381 passthru_cmd->data_len = 512; in test_cuse_nvme_submit_passthru_cmd_with_md() 396 CU_ASSERT(g_ut_ctx->data_len == 512); in test_cuse_nvme_submit_passthru_cmd_with_md() 480 CU_ASSERT(g_ut_ctx->data_len == 2 * 4096); in test_cuse_nvme_submit_io() 499 CU_ASSERT(g_ut_ctx->data_len in test_cuse_nvme_submit_io() [all...] |
| /spdk/test/unit/lib/util/dif.c/ |
| H A D | dif_ut.c | 2902 uint32_t dif_check_flags, data_len, read_len, data_offset, mapped_len = 0; in set_md_interleave_iovs_alignment_test() 2925 data_len = 4096 * 4; in set_md_interleave_iovs_alignment_test() 2929 data_offset, data_len, &mapped_len, &ctx); in set_md_interleave_iovs_alignment_test() 2944 data_len -= read_len; in set_md_interleave_iovs_alignment_test() 2948 data_offset, data_len, &mapped_len, &ctx); 2963 data_len -= read_len; in _dif_generate_split_test() 2967 data_offset, data_len, &mapped_len, &ctx); in _dif_generate_split_test() 2982 data_len -= read_len; in _dif_generate_split_test() 2986 data_offset, data_len, &mapped_len, &ctx); in _dif_generate_split_test() 2999 data_len in _dif_generate_split_test() 2481 uint32_t dif_check_flags, data_len, read_len, data_offset, mapped_len = 0; _set_md_interleave_iovs_test() local 2621 uint32_t dif_check_flags, data_len, read_len, data_offset, mapped_len = 0; set_md_interleave_iovs_split_test() local 3045 uint32_t dif_check_flags, data_len, read_len, data_offset, read_offset, mapped_len = 0; _set_md_interleave_iovs_multi_segments_test() local [all...] |
| /spdk/test/app/fuzz/iscsi_fuzz/ |
| H A D | iscsi_fuzz.c | 402 uint32_t data_len; in iscsi_fuzz_read_pdu() local 453 data_len = pdu->data_segment_len; in iscsi_fuzz_read_pdu() 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() 462 if (pdu->data_valid_bytes < data_len) { in iscsi_fuzz_read_pdu() 465 data_len - pdu->data_valid_bytes); in iscsi_fuzz_read_pdu() 471 if (pdu->data_valid_bytes < data_len) { in iscsi_fuzz_read_pdu()
|
| /spdk/scripts/ |
| H A D | iostat.py | 103 data_len = 0 105 data_len = max(data_len, len(x[i])) 107 item_sizes[index] = max(len(header[index]), data_len)
|
| /spdk/test/unit/lib/nvme/nvme_tcp.c/ |
| H A D | nvme_tcp_ut.c | 74 uint32_t data_len; in test_nvme_tcp_pdu_set_data_buf() 120 data_len = 0; in test_nvme_tcp_pdu_set_data_buf() 124 data_len += 512 * (i + 1); in test_nvme_tcp_pdu_set_data_buf() 127 nvme_tcp_pdu_set_data_buf(&pdu, iov, NVME_TCP_MAX_SGL_DESCRIPTORS, 0, data_len); in test_nvme_tcp_pdu_set_data_buf() 149 pdu.data_len = pdu_iov_len * 2; in test_nvme_tcp_build_iovs() 175 pdu.data_len += 123; in test_nvme_tcp_build_iovs() 329 CU_ASSERT(pdu.data_len == 500); in test_nvme_tcp_pdu_set_data_buf_with_md() 337 CU_ASSERT(pdu.data_len == 1000); in test_nvme_tcp_pdu_set_data_buf_with_md() 345 CU_ASSERT(pdu.data_len == 548); in test_nvme_tcp_pdu_set_data_buf_with_md() 369 CU_ASSERT(pdu.data_len in test_nvme_tcp_pdu_set_data_buf_with_md() 73 uint32_t data_len; test_nvme_tcp_pdu_set_data_buf() local [all...] |
| /spdk/include/linux/ |
| H A D | virtio_blk.h | 191 __virtio32 data_len; member
|
| /spdk/test/nvme/e2edp/ |
| H A D | nvme_dp.c | 153 uint32_t md_size, sector_size, data_len; in dp_with_pract_test() local 162 data_len = sector_size * req->lba_count; in dp_with_pract_test() 165 data_len = (sector_size + md_size) * req->lba_count; in dp_with_pract_test() 167 req->contig = spdk_zmalloc(data_len, 0x1000, NULL, SPDK_ENV_LCORE_ID_ANY, in dp_with_pract_test()
|