| /spdk/module/bdev/raid/ |
| H A D | bdev_raid.c | 162 struct raid_base_bdev_info *base_info = &raid_bdev->base_bdev_info[i];
164 if (base_info->is_configured &&
165 spdk_bdev_desc_get_bdev(base_info->desc) == base_bdev) {
166 return base_info; in raid_bdev_ch_process_cleanup()
201 struct raid_base_bdev_info *base_info; in raid_bdev_ch_process_setup()
227 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in raid_bdev_ch_process_setup()
228 uint8_t slot = raid_bdev_base_bdev_slot(base_info); in raid_bdev_ch_process_setup()
230 if (base_info != process->target) { in raid_bdev_ch_process_setup()
378 struct raid_base_bdev_info *base_info;
385 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in raid_bdev_free()
148 struct raid_base_bdev_info *base_info = &raid_bdev->base_bdev_info[i]; raid_bdev_channel_get_base_info() local
187 struct raid_base_bdev_info *base_info; raid_bdev_ch_process_setup() local
364 struct raid_base_bdev_info *base_info; raid_bdev_cleanup() local
396 raid_bdev_deconfigure_base_bdev(struct raid_base_bdev_info * base_info) raid_bdev_deconfigure_base_bdev() argument
416 raid_bdev_free_base_bdev_resource(struct raid_base_bdev_info * base_info) raid_bdev_free_base_bdev_resource() argument
472 struct raid_base_bdev_info *base_info; _raid_bdev_destruct() local
747 struct raid_base_bdev_info *base_info; raid_bdev_submit_reset_request() local
971 struct raid_base_bdev_info *base_info; _raid_bdev_io_type_supported() local
1045 struct raid_base_bdev_info *base_info; raid_bdev_write_info_json() local
1130 struct raid_base_bdev_info *base_info; raid_bdev_write_config_json() local
1172 struct raid_base_bdev_info *base_info; raid_bdev_get_memory_domains() local
1456 struct raid_base_bdev_info *base_info; _raid_bdev_create() local
1861 struct raid_base_bdev_info *base_info; raid_bdev_find_base_info_by_bdev() local
1876 raid_bdev_remove_base_bdev_done(struct raid_base_bdev_info * base_info,int status) raid_bdev_remove_base_bdev_done() argument
1900 struct raid_base_bdev_info *base_info = ctx; raid_bdev_remove_base_bdev_on_unquiesced() local
1914 struct raid_base_bdev_info *base_info = spdk_io_channel_iter_get_ctx(i); raid_bdev_channel_remove_base_bdev() local
1936 struct raid_base_bdev_info *base_info = spdk_io_channel_iter_get_ctx(i); raid_bdev_channels_remove_base_bdev_done() local
1946 raid_bdev_remove_base_bdev_cont(struct raid_base_bdev_info * base_info) raid_bdev_remove_base_bdev_cont() argument
1957 struct raid_base_bdev_info *base_info = ctx; raid_bdev_remove_base_bdev_write_sb_cb() local
1972 struct raid_base_bdev_info *base_info = ctx; raid_bdev_remove_base_bdev_on_quiesced() local
2008 raid_bdev_remove_base_bdev_quiesce(struct raid_base_bdev_info * base_info) raid_bdev_remove_base_bdev_quiesce() argument
2018 struct raid_base_bdev_info *base_info; global() member
2025 struct raid_base_bdev_info *base_info = ctx; _raid_bdev_process_base_bdev_remove_cont() local
2038 struct raid_base_bdev_info *base_info = ctx->base_info; raid_bdev_process_base_bdev_remove_cont() local
2079 raid_bdev_process_base_bdev_remove(struct raid_bdev_process * process,struct raid_base_bdev_info * base_info) raid_bdev_process_base_bdev_remove() argument
2114 _raid_bdev_remove_base_bdev(struct raid_base_bdev_info * base_info,raid_base_bdev_cb cb_fn,void * cb_ctx) _raid_bdev_remove_base_bdev() argument
2187 struct raid_base_bdev_info *base_info; raid_bdev_remove_base_bdev() local
2202 struct raid_base_bdev_info *base_info = ctx; raid_bdev_fail_base_remove_cb() local
2213 struct raid_base_bdev_info *base_info = ctx; _raid_bdev_fail_base_bdev() local
2231 raid_bdev_fail_base_bdev(struct raid_base_bdev_info * base_info) raid_bdev_fail_base_bdev() argument
2259 struct raid_base_bdev_info *base_info; raid_bdev_resize_base_bdev() local
2354 struct raid_base_bdev_info *base_info; raid_bdev_delete() local
2407 struct raid_base_bdev_info *base_info; raid_bdev_process_finish_write_sb() local
3025 struct raid_base_bdev_info *base_info = spdk_io_channel_iter_get_ctx(i); _raid_bdev_configure_base_bdev_cont() local
3037 raid_bdev_configure_base_bdev_cont(struct raid_base_bdev_info * base_info) raid_bdev_configure_base_bdev_cont() argument
3094 struct raid_base_bdev_info *base_info = ctx; raid_bdev_configure_base_bdev_check_sb_cb() local
3126 raid_bdev_configure_base_bdev(struct raid_base_bdev_info * base_info,bool existing,raid_base_bdev_cb cb_fn,void * cb_ctx) raid_bdev_configure_base_bdev() argument
3314 struct raid_base_bdev_info *base_info = NULL, *iter; raid_bdev_add_base_bdev() local
3401 struct raid_base_bdev_info *base_info = &raid_bdev->base_bdev_info[sb_base_bdev->slot]; raid_bdev_create_from_sb() local
3420 struct raid_base_bdev_info *base_info; raid_bdev_examine_no_sb() local
3482 struct raid_base_bdev_info *base_info; raid_bdev_examine_others() local
3526 struct raid_base_bdev_info *iter, *base_info; raid_bdev_examine_sb() local
[all...] |
| H A D | raid1.c | 57 struct raid_base_bdev_info *base_info; in raid1_write_bdev_io_completion() local
59 base_info = raid_bdev_channel_get_base_info(raid_io->raid_ch, bdev_io->bdev); in raid1_write_bdev_io_completion()
60 if (base_info) { in raid1_write_bdev_io_completion()
61 raid_bdev_fail_base_bdev(base_info); in raid1_write_bdev_io_completion()
87 struct raid_base_bdev_info *base_info = raid1_get_read_io_base_bdev(raid_io); in raid1_correct_read_error_completion() local
91 raid_bdev_fail_base_bdev(base_info); in raid1_correct_read_error_completion()
103 struct raid_base_bdev_info *base_info; in raid1_correct_read_error() local
109 base_info = &raid_bdev->base_bdev_info[i]; in raid1_correct_read_error()
114 ret = raid_bdev_writev_blocks_ext(base_info, base_ch, raid_io->iovs, raid_io->iovcnt, in raid1_correct_read_error()
119 raid_bdev_queue_io_wait(raid_io, spdk_bdev_desc_get_bdev(base_info in raid1_correct_read_error()
154 struct raid_base_bdev_info *base_info; raid1_read_other_base_bdev() local
244 struct raid_base_bdev_info *base_info; raid1_submit_read_request() local
280 struct raid_base_bdev_info *base_info; raid1_submit_write_request() local
377 struct raid_base_bdev_info *base_info; raid1_start() local
[all...] |
| H A D | raid0.c | 89 struct raid_base_bdev_info *base_info; in raid0_submit_rw_request() local
107 base_info = &raid_bdev->base_bdev_info[pd_idx]; in raid0_submit_rw_request()
108 if (base_info->desc == NULL) { in raid0_submit_rw_request()
127 ret = raid_bdev_readv_blocks_ext(base_info, base_ch, in raid0_submit_rw_request()
132 struct spdk_bdev *bdev = &base_info->raid_bdev->bdev; in raid0_submit_rw_request()
145 ret = raid_bdev_writev_blocks_ext(base_info, base_ch, in raid0_submit_rw_request()
155 raid_bdev_queue_io_wait(raid_io, spdk_bdev_desc_get_bdev(base_info->desc), in raid0_submit_rw_request()
301 struct raid_base_bdev_info *base_info; in raid0_submit_null_payload_request() local
323 base_info = &raid_bdev->base_bdev_info[disk_idx]; in raid0_submit_null_payload_request()
330 ret = raid_bdev_unmap_blocks(base_info, base_ch, in raid0_submit_null_payload_request()
[all …]
|
| H A D | bdev_raid.h | 383 void raid_bdev_fail_base_bdev(struct raid_base_bdev_info *base_info); in raid_bdev_base_bdev_slot()
386 raid_bdev_base_bdev_slot(struct raid_base_bdev_info *base_info) in raid_bdev_io_set_default_status()
388 return base_info - base_info->raid_bdev->base_bdev_info; in raid_bdev_io_set_default_status()
408 raid_bdev_readv_blocks_ext(struct raid_base_bdev_info *base_info, struct spdk_io_channel *ch, in raid_bdev_readv_blocks_ext()
413 return spdk_bdev_readv_blocks_ext(base_info->desc, ch, iov, iovcnt,
414 base_info->data_offset + offset_blocks, num_blocks, cb, cb_arg, opts);
421 raid_bdev_writev_blocks_ext(struct raid_base_bdev_info *base_info, struct spdk_io_channel *ch, in raid_bdev_writev_blocks_ext()
427 uint64_t remapped_offset_blocks = base_info->data_offset + offset_blocks; in raid_bdev_writev_blocks_ext()
429 if (spdk_unlikely(spdk_bdev_get_dif_type(&base_info in raid_bdev_writev_blocks_ext()
380 raid_bdev_base_bdev_slot(struct raid_base_bdev_info * base_info) raid_bdev_base_bdev_slot() argument
402 raid_bdev_readv_blocks_ext(struct raid_base_bdev_info * base_info,struct spdk_io_channel * ch,struct iovec * iov,int iovcnt,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg,struct spdk_bdev_ext_io_opts * opts) raid_bdev_readv_blocks_ext() argument
415 raid_bdev_writev_blocks_ext(struct raid_base_bdev_info * base_info,struct spdk_io_channel * ch,struct iovec * iov,int iovcnt,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg,struct spdk_bdev_ext_io_opts * opts) raid_bdev_writev_blocks_ext() argument
440 raid_bdev_unmap_blocks(struct raid_base_bdev_info * base_info,struct spdk_io_channel * ch,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg) raid_bdev_unmap_blocks() argument
452 raid_bdev_flush_blocks(struct raid_base_bdev_info * base_info,struct spdk_io_channel * ch,uint64_t offset_blocks,uint64_t num_blocks,spdk_bdev_io_completion_cb cb,void * cb_arg) raid_bdev_flush_blocks() argument
[all...] |
| H A D | concat.c | 75 struct raid_base_bdev_info *base_info; in concat_submit_rw_request() local
91 base_info = &raid_bdev->base_bdev_info[pd_idx]; in concat_submit_rw_request()
92 if (base_info->desc == NULL) { in concat_submit_rw_request()
111 ret = raid_bdev_readv_blocks_ext(base_info, base_ch, in concat_submit_rw_request()
116 ret = raid_bdev_writev_blocks_ext(base_info, base_ch, in concat_submit_rw_request()
126 raid_bdev_queue_io_wait(raid_io, spdk_bdev_desc_get_bdev(base_info->desc), in concat_submit_rw_request()
173 struct raid_base_bdev_info *base_info; in concat_submit_null_payload_request() local
237 base_info = &raid_bdev->base_bdev_info[i]; in concat_submit_null_payload_request()
241 ret = raid_bdev_unmap_blocks(base_info, base_ch, in concat_submit_null_payload_request()
246 ret = raid_bdev_flush_blocks(base_info, base_ch, in concat_submit_null_payload_request()
[all …]
|
| H A D | bdev_raid_sb.c | 68 struct raid_base_bdev_info *base_info; in raid_bdev_init_superblock() local
85 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in raid_bdev_init_superblock()
86 spdk_uuid_copy(&sb_base_bdev->uuid, &base_info->uuid); in raid_bdev_init_superblock()
87 sb_base_bdev->data_offset = base_info->data_offset; in raid_bdev_init_superblock()
88 sb_base_bdev->data_size = base_info->data_size; in raid_bdev_init_superblock()
90 sb_base_bdev->slot = raid_bdev_base_bdev_slot(base_info); in raid_bdev_init_superblock()
344 struct raid_base_bdev_info *base_info; in _raid_bdev_write_superblock() local
349 base_info = &raid_bdev->base_bdev_info[i]; in _raid_bdev_write_superblock()
351 if (!base_info->is_configured || base_info->remove_scheduled) { in _raid_bdev_write_superblock()
358 rc = spdk_bdev_write(base_info->desc, base_info->app_thread_ch, in _raid_bdev_write_superblock()
[all …]
|
| H A D | raid5f.c | 430 struct raid_base_bdev_info *base_info = &raid_bdev->base_bdev_info[chunk->index]; in raid5f_chunk_submit() local
449 ret = raid_bdev_writev_blocks_ext(base_info, base_ch, chunk->iovs, chunk->iovcnt, in raid5f_chunk_submit()
461 ret = raid_bdev_readv_blocks_ext(base_info, base_ch, chunk->iovs, chunk->iovcnt, in raid5f_chunk_submit()
474 raid_bdev_queue_io_wait(raid_io, spdk_bdev_desc_get_bdev(base_info->desc), in raid5f_chunk_submit()
779 struct raid_base_bdev_info *base_info = &raid_bdev->base_bdev_info[chunk_idx]; in raid5f_submit_read_request() local
792 ret = raid_bdev_readv_blocks_ext(base_info, base_ch, raid_io->iovs, raid_io->iovcnt, in raid5f_submit_read_request()
796 raid_bdev_queue_io_wait(raid_io, spdk_bdev_desc_get_bdev(base_info->desc), in raid5f_submit_read_request()
1068 struct raid_base_bdev_info *base_info; in raid5f_start() local
1080 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in raid5f_start()
1081 min_blockcnt = spdk_min(min_blockcnt, base_info->data_size); in raid5f_start()
[all …]
|
| /spdk/test/unit/lib/bdev/raid/raid1.c/ |
| H A D | raid1_ut.c | 60 raid_bdev_fail_base_bdev(struct raid_base_bdev_info *base_info) in raid_bdev_fail_base_bdev()
62 base_info->is_failed = true; in raid_bdev_fail_base_bdev()
263 struct raid_base_bdev_info *base_info; in _test_raid1_write_error()
272 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in _test_raid1_write_error()
273 base_info->is_failed = false; in _test_raid1_write_error()
274 if (raid_bdev_base_bdev_slot(base_info) == 0) { in _test_raid1_write_error()
279 bdev_io.bdev = base_info->desc->bdev; in _test_raid1_write_error()
281 CU_ASSERT(base_info->is_failed == !bdev_io_success); in _test_raid1_write_error()
290 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in _test_raid1_write_error()
291 base_info in _test_raid1_write_error()
59 raid_bdev_fail_base_bdev(struct raid_base_bdev_info * base_info) raid_bdev_fail_base_bdev() argument
262 struct raid_base_bdev_info *base_info; _test_raid1_write_error() local
327 struct raid_base_bdev_info *base_info = &raid_bdev->base_bdev_info[0]; _test_raid1_read_error() local
[all...] |
| /spdk/test/unit/lib/bdev/raid/ |
| H A D | common.c | 105 struct raid_base_bdev_info *base_info; in raid_test_create_raid_bdev() local
146 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in raid_test_create_raid_bdev()
152 bdev->ctxt = base_info; in raid_test_create_raid_bdev()
162 base_info->raid_bdev = raid_bdev; in raid_test_create_raid_bdev()
163 base_info->desc = desc; in raid_test_create_raid_bdev()
164 base_info->data_offset = 0; in raid_test_create_raid_bdev()
165 base_info->data_size = bdev->blockcnt; in raid_test_create_raid_bdev()
174 struct raid_base_bdev_info *base_info; in raid_test_delete_raid_bdev() local
176 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in raid_test_delete_raid_bdev()
177 free(base_info->desc->bdev); in raid_test_delete_raid_bdev()
[all …]
|
| /spdk/test/unit/lib/bdev/raid/bdev_raid_sb.c/ |
| H A D | bdev_raid_sb_ut.c | 197 struct raid_base_bdev_info base_info[3] = {{0}}; in test_raid_bdev_write_superblock() local
199 .num_base_bdevs = SPDK_COUNTOF(base_info), in test_raid_bdev_write_superblock()
200 .base_bdev_info = base_info, in test_raid_bdev_write_superblock()
206 for (i = 0; i < SPDK_COUNTOF(base_info); i++) { in test_raid_bdev_write_superblock()
207 base_info[i].raid_bdev = &raid_bdev; in test_raid_bdev_write_superblock()
209 base_info[i].is_configured = true; in test_raid_bdev_write_superblock()
|
| /spdk/test/unit/lib/bdev/raid/bdev_raid.c/ |
| H A D | bdev_raid_ut.c | 67 struct raid_base_bdev_info *base_info; in ut_raid_start()
69 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in ut_raid_start()
70 min_blockcnt = spdk_min(min_blockcnt, base_info->data_size); in ut_raid_start()
299 struct raid_base_bdev_info *base_info; in check_and_remove_raid_bdev()
304 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in check_and_remove_raid_bdev()
305 if (base_info->desc) { in check_and_remove_raid_bdev()
306 raid_bdev_free_base_bdev_resource(base_info); in check_and_remove_raid_bdev()
729 struct raid_base_bdev_info *base_info; in verify_raid_bdev()
750 RAID_FOR_EACH_BASE_BDEV(pbdev, base_info) { in verify_raid_bdev()
751 CU_ASSERT(base_info in verify_raid_bdev()
66 struct raid_base_bdev_info *base_info; ut_raid_start() local
298 struct raid_base_bdev_info *base_info; check_and_remove_raid_bdev() local
728 struct raid_base_bdev_info *base_info; verify_raid_bdev() local
[all...] |
| /spdk/test/unit/lib/bdev/raid/raid0.c/ |
| H A D | raid0_ut.c | 622 struct raid_base_bdev_info *base_info; in create_raid0() local
641 RAID_FOR_EACH_BASE_BDEV(raid_bdev, base_info) { in create_raid0()
642 struct spdk_bdev *bdev = spdk_bdev_desc_get_bdev(base_info->desc); in create_raid0()
|