/spdk/test/unit/lib/ftl/ftl_bitmap.c/ |
H A D | ftl_bitmap_ut.c | 43 uint64_t i; in count_set_bits() local 45 for (i = 0; i < BITMAP_CAPACITY; i++) { in count_set_bits() 46 if (ftl_bitmap_get(bitmap, i)) { in count_set_bits() 72 size_t i; in test_ftl_bitmap_get() local 76 for (i = 0; i < g_test_bits_count; i++) { in test_ftl_bitmap_get() 77 buf[g_test_bits[i].byte_idx] += (1 << g_test_bits[i].byte_bit_idx); in test_ftl_bitmap_get() 82 for (i = 0; i < g_test_bits_count; i++) { in test_ftl_bitmap_get() 83 CU_ASSERT_TRUE(ftl_bitmap_get(g_bitmap, g_test_bits[i].bit_idx)); in test_ftl_bitmap_get() 90 size_t i; in test_ftl_bitmap_set() local 94 for (i = 0; i < g_test_bits_count; i++) { in test_ftl_bitmap_set() [all …]
|
/spdk/test/unit/lib/util/bit_array.c/ |
H A D | bit_array_ut.c | 83 uint32_t i; in test_find() local 90 for (i = 0; i < 256; i++) { in test_find() 91 CU_ASSERT(spdk_bit_array_set(ba, i) == 0); in test_find() 95 for (i = 0; i < 256; i++) { in test_find() 96 CU_ASSERT(spdk_bit_array_find_first_set(ba, i) == i); in test_find() 97 CU_ASSERT(spdk_bit_array_find_first_clear(ba, i) == UINT32_MAX); in test_find() 103 for (i = 0; i < 32; i++) { in test_find() 104 spdk_bit_array_clear(ba, i); in test_find() 107 for (i = 0; i < 32; i++) { in test_find() 108 CU_ASSERT(spdk_bit_array_find_first_set(ba, i) == 32); in test_find() [all …]
|
/spdk/test/unit/lib/event/reactor.c/ |
H A D | reactor_ut.c | 270 uint32_t count = 0, i; in test_for_each_reactor() local 290 for (i = 0; i < 5; i++) { in test_for_each_reactor() 291 reactor = spdk_reactor_get(i); in test_for_each_reactor() 293 MOCK_SET(spdk_env_get_current_core, i); in test_for_each_reactor() 296 CU_ASSERT(count == (i + 1)); in test_for_each_reactor() 507 uint32_t i, events; in _run_events_till_completion() 512 for (i = 0; i < reactor_coun in _run_events_till_completion() 508 uint32_t i, events; _run_events_till_completion() local 542 int i; test_scheduler() local 737 int i; test_bind_thread() local 935 int i; test_governor() local [all...] |
/spdk/test/unit/lib/accel/dpdk_compressdev.c/ |
H A D | accel_dpdk_compressdev_ut.c | 178 int i; in mock_rte_pktmbuf_alloc_bulk() local 191 for (i = 0; i < UT_MBUFS_PER_OP; i++) { in mock_rte_pktmbuf_alloc_bulk() 192 g_src_mbufs[i]->next = NULL; in mock_rte_pktmbuf_alloc_bulk() 193 *mbufs++ = g_src_mbufs[i]; in mock_rte_pktmbuf_alloc_bulk() 197 for (i = 0; i < UT_MBUFS_PER_OP; i++) { in mock_rte_pktmbuf_alloc_bulk() 198 g_dst_mbufs[i] in mock_rte_pktmbuf_alloc_bulk() 301 int i; _get_mbuf_array() local 326 int i, num_src_mbufs = UT_MBUFS_PER_OP; rte_compressdev_enqueue_burst() local 399 int i; test_setup() local 472 int i; test_cleanup() local 504 int rc, i; test_compress_operation() local 626 int rc, i; test_compress_operation_cross_boundary() local 796 int rc, i; test_setup_compress_mbuf() local 867 int i; test_poller() local [all...] |
/spdk/test/unit/lib/util/iov.c/ |
H A D | iov_ut.c | 15 size_t i; in _check_val() local 18 for (i = 0; i < len; i++) { in _check_val() 19 if (data[i] != val) { in _check_val() 85 int i; in test_simple_iov() local 92 for (i = 0; i < 4; i++) { in test_simple_iov() 93 siov[i].iov_base = sdata + (16 * i); in test_simple_iov() 94 siov[i].iov_len = 16; in test_simple_iov() 95 diov[i].iov_base = ddata + (16 * i); in test_simple_iov() 96 diov[i].iov_len = 16; in test_simple_iov() 106 for (i = 0; i < 4; i++) { in test_simple_iov() [all …]
|
/spdk/test/nvme/sgl/ |
H A D | sgl.c | 50 uint32_t i; in nvme_request_reset_sgl() local 55 for (i = 0; i < req->nseg; i++) { in nvme_request_reset_sgl() 56 iov = &req->iovs[i]; in nvme_request_reset_sgl() 62 req->current_iov_index = i; in nvme_request_reset_sgl() 157 uint32_t i; in build_io_request_4() local 166 for (i = 1; i < req->nseg; i in build_io_request_4() 246 uint32_t i; build_io_request_9() local 268 uint32_t i; build_io_request_10() local 287 uint32_t i; build_io_request_11() local 304 uint32_t i; free_req() local 322 uint32_t i, j, nseg, remainder; writev_readv_tests() local [all...] |
/spdk/test/unit/lib/json/json_util.c/ |
H A D | json_util_ut.c | 21 #define NUM_UINT16_PASS(s, i) \ argument 24 CU_ASSERT(u16 == i) 30 #define NUM_INT32_PASS(s, i) \ argument 33 CU_ASSERT(i32 == i) 39 #define NUM_UINT64_PASS(s, i) \ argument 42 CU_ASSERT(u64 == i) 192 /* i.e. I remove the matching decoder from the boolean argument */ in test_decode_object() 353 int32_t i; in test_decode_int32() local 359 i = 0; in test_decode_int32() 360 CU_ASSERT(spdk_json_decode_int32(&v, &i) in test_decode_int32() 455 uint32_t i; test_decode_uint16() local 544 uint32_t i; test_decode_uint32() local 640 uint64_t i; test_decode_uint64() local [all...] |
/spdk/test/vfio_user/nvme/ |
H A D | vfio_user_fio.sh | 27 for i in $(seq 0 $vm_no); do 28 vm_muser_dir="$VM_DIR/$i/muser" 30 mkdir -p $vm_muser_dir/domain/muser${i}/$i 32 $rpc_py nvmf_create_subsystem nqn.2019-07.io.spdk:cnode${i} -s SPDK00${i} -a 33 if ((i == vm_no)); then 35 $rpc_py nvmf_subsystem_add_ns nqn.2019-07.io.spdk:cnode${i} Nvme0n1 37 $rpc_py bdev_malloc_create $MALLOC_BDEV_SIZE $MALLOC_BLOCK_SIZE -b Malloc${i} 38 $rpc_py nvmf_subsystem_add_ns nqn.2019-07.io.spdk:cnode${i} Malloc${i} 40 …_subsystem_add_listener nqn.2019-07.io.spdk:cnode${i} -t VFIOUSER -a $vm_muser_dir/domain/muser${i… 47 for i in $(seq 0 $vm_no); do [all …]
|
/spdk/lib/ftl/ |
H A D | ftl_debug.c | 44 size_t i, size; in ftl_band_validate_md_pin() local 56 for (i = ctx->current_offset; i < ctx->current_offset + size; ++i) { in ftl_band_validate_md_pin() 57 if (!ftl_bitmap_get(p2l_map->valid, i)) { in ftl_band_validate_md_pin() 58 ctx->l2p_pin_ctx[i].lba = FTL_LBA_INVALID; in ftl_band_validate_md_pin() 62 assert(p2l_map->band_map[i].lba != FTL_LBA_INVALID); in ftl_band_validate_md_pin() 65 ftl_l2p_pin(dev, p2l_map->band_map[i].lba, 1, ftl_band_validate_md_l2p_pin_cb, ctx, in ftl_band_validate_md_pin() 66 &ctx->l2p_pin_ctx[i]); in ftl_band_validate_md_pin() 79 size_t i, size; in _ftl_band_validate_md() local 86 for (i = ctx->current_offset; i < ctx->current_offset + size; ++i) { in _ftl_band_validate_md() 87 lba = ctx->l2p_pin_ctx[i].lba; in _ftl_band_validate_md() [all …]
|
H A D | ftl_trace.c | 55 const char source[] = { 'i', 'u' }; 57 int i; 61 for (i = 0; i < FTL_TRACE_SOURCE_MAX; ++i) { 62 snprintf(descbuf, sizeof(descbuf), "%c %s", source[i], "band_reloc"); 63 spdk_trace_register_description(descbuf, FTL_TRACE_BAND_RELOC(i), OWNER_TYPE_FTL, OBJECT_NONE, 0, 0, 65 snprintf(descbuf, sizeof(descbuf), "%c %s", source[i], "band_write"); 66 spdk_trace_register_description(descbuf, FTL_TRACE_BAND_WRITE(i), OWNER_TYPE_FTL, OBJECT_NONE, 0, 0, 68 snprintf(descbuf, sizeof(descbuf), "%c %s", source[i], "limit 56 int i; global() variable [all...] |
/spdk/lib/util/ |
H A D | cpuset.c | 40 unsigned int i; in spdk_cpuset_negate() local 42 for (i = 0; i < sizeof(set->cpus); i++) { in spdk_cpuset_negate() 43 set->cpus[i] = ~set->cpus[i]; in spdk_cpuset_negate() 50 unsigned int i; in spdk_cpuset_and() local 53 for (i = 0; i < sizeof(src->cpus); i++) { in spdk_cpuset_and() 54 dst->cpus[i] &= src->cpus[i]; in spdk_cpuset_and() 61 unsigned int i; in spdk_cpuset_or() local 64 for (i = 0; i < sizeof(src->cpus); i++) { in spdk_cpuset_or() 65 dst->cpus[i] |= src->cpus[i]; in spdk_cpuset_or() 72 unsigned int i; in spdk_cpuset_xor() local [all …]
|
/spdk/test/unit/lib/accel/dpdk_cryptodev.c/ |
H A D | accel_dpdk_cryptodev_ut.c | 68 for (unsigned i = 0; i < count; i++) { in mock_rte_pktmbuf_alloc_bulk() local 69 rte_pktmbuf_reset(mbufs[i]); in mock_rte_pktmbuf_alloc_bulk() 70 mbufs[i]->pool = pool; in mock_rte_pktmbuf_alloc_bulk() 144 int i; in mock_rte_cryptodev_enqueue_burst() local 148 for (i = 0; i < nb_ops; i++) { in mock_rte_cryptodev_enqueue_burst() 152 g_test_dev_full_ops[i] in mock_rte_cryptodev_enqueue_burst() 166 int i; mock_rte_cryptodev_dequeue_burst() local 186 int i; mock_rte_crypto_op_bulk_alloc() local 293 int i, rc; test_setup() local 341 int i; test_cleanup() local 442 int rc, i; test_simple_encrypt() local 563 int rc, i; test_simple_decrypt() local 688 uint32_t i; test_large_enc_dec() local 1068 uint32_t block_len = 512, num_blocks = 4, i; test_crazy_rw() local 1501 int i; test_assign_device_qp() local [all...] |
/spdk/test/thread/lock/ |
H A D | spdk_lock.c | 57 enum spin_error i; in check_spin_err_count() local 60 for (i = SPIN_ERR_NONE; i < SPIN_ERR_LAST; i++) { in check_spin_err_count() 61 if (g_lock_error_count[i] != expect[i]) { in check_spin_err_count() 62 printf("FAIL: %s: Error %d expected %u, got %u\n", __func__, i, in check_spin_err_count() 63 expect[i], g_lock_error_count[i]); in check_spin_err_count() 76 uint32_t i; in do_not_abort() local 83 for (i = 0; i < SPDK_COUNTOF(g_thread); i++) { in do_not_abort() 84 if (g_thread[i] != thread) { in do_not_abort() 180 uint32_t i; in contend_setup() local 187 for (i = 0; i < SPDK_COUNTOF(g_contend_data); i++) { in contend_setup() [all …]
|
/spdk/lib/trace/ |
H A D | trace_flags.c | 77 int i; in spdk_trace_get_tpoint_group_mask() local 79 for (i = 0; i < SPDK_TRACE_MAX_GROUP_ID; i++) { in spdk_trace_get_tpoint_group_mask() 80 if (spdk_trace_get_tpoint_mask(i) != 0) { in spdk_trace_get_tpoint_group_mask() 81 mask |= (1ULL << i); in spdk_trace_get_tpoint_group_mask() 91 int i; in spdk_trace_set_tpoint_group_mask() local 98 for (i = 0; i < SPDK_TRACE_MAX_GROUP_ID; i++) { in spdk_trace_set_tpoint_group_mask() 99 if (tpoint_group_mask & (1ULL << i)) { in spdk_trace_set_tpoint_group_mask() 100 spdk_trace_set_tpoints(i, -1ULL); in spdk_trace_set_tpoint_group_mask() 108 int i; in spdk_trace_clear_tpoint_group_mask() local 115 for (i = 0; i < SPDK_TRACE_MAX_GROUP_ID; i++) { in spdk_trace_clear_tpoint_group_mask() [all …]
|
/spdk/test/bdev/ |
H A D | nbd_common.sh | 12 local i 14 for ((i = 0; i < ${#nbd_list[@]}; i++)); do 15 $rootdir/scripts/rpc.py -s $rpc_server nbd_start_disk ${bdev_list[$i]} ${nbd_list[$i]} 17 waitfornbd $(basename ${nbd_list[$i]}) 24 local i 27 for ((i = 0; i < [all...] |
/spdk/lib/mlx5/ |
H A D | mlx5_crypto.c | 67 size_t i; in mlx5_crypto_dev_allowed() local 73 for (i = 0; i < g_allowed_devices_count; i++) { in mlx5_crypto_dev_allowed() 74 free(g_allowed_devices[i]); in mlx5_crypto_dev_allowed() 84 size_t i; in spdk_mlx5_crypto_devs_allow() 90 for (i = 0; i < g_allowed_devices_count; i++) { in spdk_mlx5_crypto_devs_allow() 91 if (strcmp(g_allowed_devices[i], de in spdk_mlx5_crypto_devs_allow() 50 size_t i; mlx5_crypto_devs_free() local 85 size_t i; spdk_mlx5_crypto_devs_allow() local 115 int num_rdma_devs = 0, i, rc; spdk_mlx5_crypto_devs_get() local 204 uint32_t i; spdk_mlx5_crypto_keytag_destroy() local 233 int num_devs = 0, i, rc; spdk_mlx5_crypto_keytag_create() local 354 uint32_t i; mlx5_crypto_get_dek_by_pd() local [all...] |
/spdk/test/common/lib/ |
H A D | ut_multithread.c | 53 uint32_t i; in allocate_threads() local 62 for (i = 0; i < g_ut_num_threads; i++) { in allocate_threads() 63 set_thread(i); in allocate_threads() 66 g_ut_threads[i].thread = thread; in allocate_threads() 76 uint32_t i, num_threads; in free_threads() local 79 for (i = 0; i < g_ut_num_threads; i++) { in free_threads() 80 set_thread(i); in free_threads() 81 thread = g_ut_threads[i].thread; in free_threads() 88 for (i = 0; i < g_ut_num_threads; i++) { in free_threads() 89 set_thread(i); in free_threads() [all …]
|
/spdk/lib/vfio_user/host/ |
H A D | vfio_user_pci.c | 26 uint32_t i; in spdk_vfio_user_pci_bar_access() local 37 for (i = 0; i < region->nr_mmaps; i++) { in spdk_vfio_user_pci_bar_access() 38 if ((offset >= region->mmaps[i].offset) && in spdk_vfio_user_pci_bar_access() 39 (offset + len <= region->mmaps[i].offset + region->mmaps[i].size)) { in spdk_vfio_user_pci_bar_access() 40 assert(region->mmaps[i].mem != NULL); in spdk_vfio_user_pci_bar_access() 41 void *bar_addr = region->mmaps[i].mem + offset - region->mmaps[i].offset; in spdk_vfio_user_pci_bar_access() 206 uint32_t i, j = 0; in vfio_device_setup_sparse_mmaps() local 216 for (i = 0; i < sparse->nr_areas; i++) { in vfio_device_setup_sparse_mmaps() 217 if (sparse->areas[i].size) { in vfio_device_setup_sparse_mmaps() 218 region->mmaps[j].offset = sparse->areas[i].offset; in vfio_device_setup_sparse_mmaps() [all …]
|
/spdk/test/unit/lib/reduce/reduce.c/ |
H A D | reduce_ut.c | 243 int i; in backing_dev_readv_execute() 246 for (i = 0; i < iovcnt; i++) { in backing_dev_readv_execute() 247 memcpy(iov[i].iov_base, offset, iov[i].iov_len); in backing_dev_readv_execute() 248 offset += iov[i].iov_len; in backing_dev_readv_execute() 295 int i; in backing_dev_writev_execute() 298 for (i = 0; i < iovcn in backing_dev_writev_execute() 241 int i; backing_dev_readv_execute() local 293 int i; backing_dev_writev_execute() local 468 int rc, i; backing_dev_compress() local 495 int rc, i; backing_dev_decompress() local 729 uint32_t num_lbas, i; _write_maps() local 827 uint32_t i; _read_write() local 1281 uint32_t i; test_prepare_compress_chunk() local 1573 uint32_t i; test_reduce_decompress_chunk() local 1803 uint32_t i; test_allocate_vol_requests() local [all...] |
/spdk/test/unit/lib/util/xor.c/ |
H A D | xor_ut.c | 24 size_t i, j; in test_xor_gen() local 28 for (i = 0; i < BUF_COUNT; i++) { in test_xor_gen() 29 ret = posix_memalign(&bufs[i], spdk_xor_get_optimal_alignment(), BUF_SIZE); in test_xor_gen() 32 tmp = bufs[i]; in test_xor_gen() 34 tmp[j] = (i << 16) + j; in test_xor_gen() 44 for (i = 0; i < SRC_BUF_COUNT; i++) { in test_xor_gen() 46 ref[j] ^= ((uint8_t *)bufs[i])[j]; in test_xor_gen() 70 for (i = 0; i < SRC_BUF_COUNT; i++) { in test_xor_gen() 72 ref[j] ^= ((uint8_t *)bufs2[i])[j]; in test_xor_gen() 94 for (i = 0; i < BUF_COUNT; i++) { in test_xor_gen() [all …]
|
/spdk/test/vhost/lvol/ |
H A D | lvol_test.sh | 116 for ((i = 0; i < vm_count; i++)); do 117 vm="vm_$i" 124 setup_cmd="vm_setup --disk-type=$ctrl_type --force=$i" 131 $rpc_py vhost_create_scsi_controller naa.0.$i "${mask_arg[@]}" 133 $rpc_py vhost_scsi_controller_add_target naa.0.$i $j ${bdevs[$j]} 139 $rpc_py vhost_create_blk_controller naa.$j.$i ${bdevs[$j]} "${mask_arg[@]}" 147 used_vms+=" $i" 191 for ((i = 0; i < vm_count; i++)); do 192 notice "Removing devices from vhost SCSI controller naa.0.$i" 194 $rpc_py vhost_scsi_controller_remove_target naa.0.$i $j [all …]
|
/spdk/test/nvmf/target/ |
H A D | multiconnection.sh | 21 for i in $(seq 1 $NVMF_SUBSYS); do 22 $rpc_py bdev_malloc_create $MALLOC_BDEV_SIZE $MALLOC_BLOCK_SIZE -b Malloc$i 23 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode$i -a -s SPDK$i 24 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode$i Malloc$i 25 …$rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode$i -t $TEST_TRANSPORT -a $NVMF_FIRST_… 28 for i in $(seq 1 $NVMF_SUBSYS); do 29 …$NVME_CONNECT "${NVME_HOST[@]}" -t $TEST_TRANSPORT -n "nqn.2016-06.io.spdk:cnode${i}" -a "$NVMF_FI… 30 waitforserial SPDK$i 37 for i in $(seq 1 $NVMF_SUBSYS); do 38 nvme disconnect -n "nqn.2016-06.io.spdk:cnode${i}" [all …]
|
H A D | srq_overwhelm.sh | 22 for i in $(seq 0 5); do 23 $rpc_py nvmf_create_subsystem nqn.2016-06.io.spdk:cnode$i -a -s "SPDK0000000000000${i}" 24 $rpc_py bdev_malloc_create $MALLOC_BDEV_SIZE $MALLOC_BLOCK_SIZE -b Malloc$i 25 $rpc_py nvmf_subsystem_add_ns nqn.2016-06.io.spdk:cnode$i Malloc$i 26 …$rpc_py nvmf_subsystem_add_listener nqn.2016-06.io.spdk:cnode$i -t $TEST_TRANSPORT -a $NVMF_FIRST_… 27 …$NVME_CONNECT "${NVME_HOST[@]}" -t $TEST_TRANSPORT -n "nqn.2016-06.io.spdk:cnode${i}" -a "$NVMF_FI… 28 waitforblk "nvme${i}n1" 40 for i in $(seq 0 5); do 41 nvme disconnect -n "nqn.2016-06.io.spdk:cnode${i}" 42 waitforserial_disconnect "SPDK0000000000000${i}" [all …]
|
/spdk/test/unit/lib/bdev/raid/concat.c/ |
H A D | concat_ut.c | 73 int i = g_req_records.count; in spdk_bdev_readv_blocks_ext() local 75 g_req_records.offset_blocks[i] = offset_blocks; in spdk_bdev_readv_blocks_ext() 76 g_req_records.num_blocks[i] = num_blocks; in spdk_bdev_readv_blocks_ext() 77 g_req_records.io_type[i] = CONCAT_READV; in spdk_bdev_readv_blocks_ext() 93 int i = g_req_records.count; in spdk_bdev_writev_blocks_ext() local 95 g_req_records.offset_blocks[i] = offset_blocks; in spdk_bdev_writev_blocks_ext() 96 g_req_records.num_blocks[i] = num_blocks; in spdk_bdev_writev_blocks_ext() 97 g_req_records.io_type[i] = CONCAT_WRITEV; in spdk_bdev_writev_blocks_ext() 113 int i = g_req_records.count; in spdk_bdev_unmap_blocks() local 115 g_req_records.offset_blocks[i] = offset_blocks; in spdk_bdev_unmap_blocks() [all …]
|
/spdk/app/trace_record/ |
H A D | trace_record.c | 54 int i; in input_trace_file_mmap() local 97 for (i = 0; i < SPDK_TRACE_MAX_LCORE; i++) { in input_trace_file_mmap() 100 history = spdk_get_per_lcore_history(ctx->trace_file, i); in input_trace_file_mmap() 101 ctx->lcore_ports[i].in_history = history; in input_trace_file_mmap() 102 ctx->lcore_ports[i].valid = (history != NULL); in input_trace_file_mmap() 105 printf("Number of trace entries for lcore (%d): %ju\n", i, in input_trace_file_mmap() 119 int i, rc; in output_trace_files_prepare() local 123 for (i = 0; i < SPDK_TRACE_MAX_LCORE; i++) { in output_trace_files_prepare() 124 port_ctx = &ctx->lcore_ports[i]; in output_trace_files_prepare() 127 name_len = snprintf(port_ctx->lcore_file, TRACE_PATH_MAX, "%s-%d", ctx->out_file, i); in output_trace_files_prepare() [all …]
|