| /spdk/test/bdev/ |
| H A D | bdev_raid.sh | 109 local num_base_bdevs
145 num_base_bdevs=$(echo $raid_bdev_info | jq -r '[.base_bdevs_list[]] | length')
146 tmp=$(echo $raid_bdev_info | jq -r '.num_base_bdevs')
147 if [ "$num_base_bdevs" != "$tmp" ]; then
148 echo "incorrect num_base_bdevs: $tmp, expected: $num_base_bdevs"
206 local num_base_bdevs=$2
209 local base_bdevs=($(for ((i = 1; i <= num_base_bdevs; i++)); do echo BaseBdev$i; done))
236 verify_raid_bdev_state $raid_bdev_name "configuring" $raid_level $strip_size $num_base_bdevs
244 verify_raid_bdev_state $raid_bdev_name "configuring" $raid_level $strip_size $num_base_bdevs
[all...] |
| /spdk/module/bdev/raid/ |
| H A D | raid0.c | 95 if (start_strip != end_strip && raid_bdev->num_base_bdevs > 1) { in raid0_submit_rw_request()
102 pd_strip = start_strip / raid_bdev->num_base_bdevs; in raid0_submit_rw_request()
103 pd_idx = start_strip % raid_bdev->num_base_bdevs; in raid0_submit_rw_request()
178 uint8_t num_base_bdevs, uint64_t strip_size, uint64_t strip_size_shift, in _raid0_get_io_range() argument
191 io_range->start_strip_in_disk = start_strip / num_base_bdevs; in _raid0_get_io_range()
192 io_range->end_strip_in_disk = end_strip / num_base_bdevs; in _raid0_get_io_range()
202 io_range->start_disk = start_strip % num_base_bdevs; in _raid0_get_io_range()
203 io_range->end_disk = end_strip % num_base_bdevs; in _raid0_get_io_range()
209 io_range->n_disks_involved = spdk_min((end_strip - start_strip + 1), num_base_bdevs); in _raid0_get_io_range()
306 _raid0_get_io_range(&io_range, raid_bdev->num_base_bdevs, in raid0_submit_null_payload_request()
[all …]
|
| H A D | bdev_raid_rpc.c | 113 size_t num_base_bdevs; member
174 RPC_MAX_BASE_BDEVS, &base_bdevs->num_base_bdevs, sizeof(char *)); in decode_base_bdevs()
210 for (i = 0; i < req->base_bdevs.num_base_bdevs; i++) { in free_rpc_bdev_raid_create_ctx()
263 uint8_t num_base_bdevs; in rpc_bdev_raid_create() local
279 num_base_bdevs = req->base_bdevs.num_base_bdevs; in rpc_bdev_raid_create()
281 for (i = 0; i < num_base_bdevs; i++) { in rpc_bdev_raid_create()
290 rc = raid_bdev_create(req->name, req->strip_size_kb, num_base_bdevs, in rpc_bdev_raid_create()
301 ctx->remaining = num_base_bdevs; in rpc_bdev_raid_create()
303 assert(num_base_bdevs > in rpc_bdev_raid_create()
[all...] |
| H A D | raid1.c | 159 for (i = raid_bdev->num_base_bdevs - raid_io->base_bdev_io_remaining; i < raid_bdev->num_base_bdevs; in raid1_read_other_base_bdev()
201 raid_io->base_bdev_io_remaining = raid_io->raid_bdev->num_base_bdevs; in raid1_read_bdev_io_completion()
227 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in raid1_channel_next_read_base_bdev()
287 raid_io->base_bdev_io_remaining = raid_bdev->num_base_bdevs; in raid1_submit_write_request()
292 for (idx = raid_io->base_bdev_io_submitted; idx < raid_bdev->num_base_bdevs; idx++) { in raid1_submit_write_request()
313 base_bdev_io_not_submitted = raid_bdev->num_base_bdevs - in raid1_submit_write_request()
401 sizeof(struct raid1_io_channel) + raid_bdev->num_base_bdevs * sizeof(uint64_t), in raid1_start()
|
| H A D | concat.c | 81 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in concat_submit_rw_request()
192 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in concat_submit_null_payload_request()
277 block_range = calloc(raid_bdev->num_base_bdevs, sizeof(struct concat_block_range)); in concat_start()
280 raid_bdev->num_base_bdevs); in concat_start()
300 total_blockcnt, raid_bdev->num_base_bdevs, raid_bdev->strip_size_shift); in concat_start()
|
| H A D | bdev_raid_sb.c | 81 sb->num_base_bdevs = sb->base_bdevs_size = raid_bdev->num_base_bdevs; in raid_bdev_init_superblock()
177 if (sb_base_bdev->slot >= sb->num_base_bdevs) { in raid_bdev_parse_superblock()
348 for (i = ctx->submitted; i < raid_bdev->num_base_bdevs; i++) { in _raid_bdev_write_superblock()
407 ctx->remaining = raid_bdev->num_base_bdevs + 1; in raid_bdev_write_superblock()
|
| H A D | bdev_raid.h | 211 uint8_t num_base_bdevs;
218 * will be less than num_base_bdevs when starting a degraded array.
254 for (i = r->base_bdev_info; i < r->base_bdev_info + r->num_base_bdevs; i++)
265 int raid_bdev_create(const char *name, uint32_t strip_size, uint8_t num_base_bdevs,
532 uint8_t num_base_bdevs;
209 uint8_t num_base_bdevs; global() member
526 uint8_t num_base_bdevs; global() member
|
| H A D | bdev_raid.c | 161 for (i = 0; i < raid_bdev->num_base_bdevs; i++) {
221 raid_ch_processed->base_channel = calloc(raid_bdev->num_base_bdevs, in raid_bdev_ch_process_setup()
270 raid_ch->base_channel = calloc(raid_bdev->num_base_bdevs, sizeof(struct spdk_io_channel *)); in raid_bdev_create_cb()
276 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in raid_bdev_create_cb()
316 for (i = 0; i < raid_bdev->num_base_bdevs; i++) {
354 for (i = 0; i < raid_bdev->num_base_bdevs; i++) {
773 raid_io->base_bdev_io_remaining = raid_bdev->num_base_bdevs; in raid_bdev_submit_reset_request()
776 for (i = raid_io->base_bdev_io_submitted; i < raid_bdev->num_base_bdevs; i++) { in raid_bdev_submit_reset_request()
1081 spdk_json_write_named_uint32(w, "num_base_bdevs", raid_bdev->num_base_bdevs); in raid_bdev_write_info_json()
1449 _raid_bdev_create(const char * name,uint32_t strip_size,uint8_t num_base_bdevs,enum raid_level level,bool superblock_enabled,const struct spdk_uuid * uuid,struct raid_bdev ** raid_bdev_out) _raid_bdev_create() argument
1590 raid_bdev_create(const char * name,uint32_t strip_size,uint8_t num_base_bdevs,enum raid_level level,bool superblock_enabled,const struct spdk_uuid * uuid,struct raid_bdev ** raid_bdev_out) raid_bdev_create() argument
[all...] |
| H A D | raid5f.c | 140 c < req->chunks + raid5f_ch_to_r5f_info(req->r5ch)->raid_bdev->num_base_bdevs
176 return raid5f_stripe_data_chunks_num(raid_bdev) - stripe_index % raid_bdev->num_base_bdevs; in raid5f_stripe_parity_chunk_index()
316 raid_bdev->num_base_bdevs, in raid5f_xor_stripe()
485 base_bdev_io_not_submitted = raid_bdev->num_base_bdevs - in raid5f_chunk_submit()
647 raid_io->base_bdev_io_remaining = raid_bdev->num_base_bdevs; in raid5f_submit_write_request()
761 raid_io->base_bdev_io_remaining = raid_bdev->num_base_bdevs; in raid5f_submit_reconstruct_read()
885 stripe_req = calloc(1, sizeof(*stripe_req) + sizeof(*chunk) * raid_bdev->num_base_bdevs); in raid5f_stripe_request_alloc()
954 stripe_req->chunk_iov_iters = malloc(SPDK_IOVITER_SIZE(raid_bdev->num_base_bdevs)); in raid5f_stripe_request_alloc()
1041 r5ch->chunk_xor_buffers = calloc(raid_bdev->num_base_bdevs, sizeof(*r5ch->chunk_xor_buffers)); in raid5f_ioch_create()
1046 r5ch->chunk_xor_iovs = calloc(raid_bdev->num_base_bdevs, sizeof(*r5ch->chunk_xor_iovs)); in raid5f_ioch_create()
[all …]
|
| /spdk/test/unit/lib/bdev/raid/raid1.c/ |
| H A D | raid1_ut.c | 71 uint8_t *num_base_bdevs; in test_setup()
85 ARRAY_FOR_EACH(num_base_bdevs_values, num_base_bdevs) { in test_setup()
89 .num_base_bdevs = *num_base_bdevs, in test_setup()
211 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in _test_raid1_read_balancing()
219 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in _test_raid1_read_balancing()
233 blocks_remaining = big_io_blocks * (raid_bdev->num_base_bdevs - 1); in _test_raid1_read_balancing()
242 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in _test_raid1_read_balancing()
345 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs - 1)); in _test_raid1_read_error()
370 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs in _test_raid1_read_error()
70 uint8_t *num_base_bdevs; test_setup() local
[all...] |
| /spdk/test/unit/lib/bdev/raid/ |
| H A D | common.c | 33 uint8_t num_base_bdevs; member
114 raid_bdev->num_base_bdevs = params->num_base_bdevs; in raid_test_create_raid_bdev()
118 raid_bdev->min_base_bdevs_operational = raid_bdev->num_base_bdevs - in raid_test_create_raid_bdev()
125 raid_bdev->min_base_bdevs_operational = raid_bdev->num_base_bdevs; in raid_test_create_raid_bdev()
142 raid_bdev->base_bdev_info = calloc(raid_bdev->num_base_bdevs, in raid_test_create_raid_bdev()
210 raid_ch->_base_channels = calloc(raid_bdev->num_base_bdevs, sizeof(struct spdk_io_channel *)); in raid_test_create_io_channel()
213 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in raid_test_create_io_channel()
|
| /spdk/test/unit/lib/bdev/raid/concat.c/ |
| H A D | concat_ut.c | 180 uint8_t *num_base_bdevs; in test_setup() local
196 ARRAY_FOR_EACH(num_base_bdevs_values, num_base_bdevs) { in test_setup()
201 .num_base_bdevs = *num_base_bdevs, in test_setup()
255 for (i = 0; i < params->num_base_bdevs; i++) { in test_concat_start()
311 for (i = 0; i < params->num_base_bdevs; i++) { in submit_and_verify_rw()
389 if (params->base_bdev_blockcnt == 1 && params->num_base_bdevs == 3) { in submit_and_verify_null_payload()
414 if (params->num_base_bdevs == 3) { in submit_and_verify_null_payload()
|
| /spdk/test/unit/lib/bdev/raid/raid5f.c/ |
| H A D | raid5f_ut.c | 93 uint8_t *num_base_bdevs; in test_suite_init() local
111 ARRAY_FOR_EACH(num_base_bdevs_values, num_base_bdevs) { in test_suite_init()
117 .num_base_bdevs = *num_base_bdevs, in test_suite_init()
185 CU_ASSERT_EQUAL(r5f_info->stripe_blocks, params->strip_size * (params->num_base_bdevs - 1)); in test_raid5f_start()
189 (params->num_base_bdevs - 1)); in test_raid5f_start()
606 for (i = 0; i < raid_bdev->num_base_bdevs; i++) { in test_raid5f_write_request()
612 SPDK_CU_ASSERT_FATAL(i != raid_bdev->num_base_bdevs); in test_raid5f_write_request()
887 for (i = 0; i < spdk_min(raid_bdev->num_base_bdevs, ((struct raid5f_info *)raid_bdev->module_private)->total_stripes); i++)
936 { .iov_base = (void *)0x3ff0000, .iov_len = strip_bytes * raid_bdev->num_base_bdevs }, in __test_raid5f_stripe_request_map_iovecs()
[all...] |
| /spdk/test/unit/lib/bdev/raid/bdev_raid_sb.c/ |
| H A D | bdev_raid_sb_ut.c | 199 .num_base_bdevs = SPDK_COUNTOF(base_info), in test_raid_bdev_write_superblock()
222 CU_ASSERT(g_write_counter == raid_bdev.num_base_bdevs - 1); in test_raid_bdev_write_superblock()
239 CU_ASSERT(g_write_counter == raid_bdev.num_base_bdevs - 1); in test_raid_bdev_write_superblock()
375 sb->base_bdevs[0].slot = sb->num_base_bdevs = sb->base_bdevs_size = 2; in test_raid_bdev_parse_superblock()
|
| /spdk/test/unit/lib/bdev/raid/bdev_raid.c/ |
| H A D | bdev_raid_ut.c | 439 } else if (strcmp(name, "num_base_bdevs") == 0) { in spdk_json_write_named_uint32()
440 CU_ASSERT(req->base_bdevs.num_base_bdevs == val); in spdk_json_write_named_uint32()
446 CU_ASSERT(req->base_bdevs.num_base_bdevs == val); in spdk_json_write_named_uint32()
532 _out->base_bdevs.num_base_bdevs = req->base_bdevs.num_base_bdevs; in spdk_json_decode_object()
533 for (i = 0; i < req->base_bdevs.num_base_bdevs; i++) { in spdk_json_decode_object()
746 CU_ASSERT(pbdev->num_base_bdevs == r->base_bdevs.num_base_bdevs); in verify_raid_bdev()
747 CU_ASSERT(pbdev->num_base_bdevs_discovered == r->base_bdevs.num_base_bdevs); in verify_raid_bdev()
836 r->base_bdevs.num_base_bdevs in create_test_req()
[all...] |
| /spdk/test/unit/lib/bdev/raid/raid0.c/ |
| H A D | raid0_ut.c | 456 uint8_t num_base_drives = raid_bdev->num_base_bdevs; in verify_io()
513 uint8_t num_base_drives = raid_bdev->num_base_bdevs; in verify_io_without_payload()
624 .num_base_bdevs = g_max_base_drives, in create_raid0()
|