| /spdk/test/unit/lib/bdev/raid/ |
| H A D | common.c | 47 void raid_test_destroy_io_channel(struct raid_bdev_io_channel *raid_ch);
49 struct raid_bdev_io_channel *raid_ch,
190 raid_bdev_channel_get_base_channel(struct raid_bdev_io_channel *raid_ch, uint8_t idx) in raid_bdev_channel_get_base_channel() argument
192 return raid_ch->_base_channels[idx]; in raid_bdev_channel_get_base_channel()
196 raid_bdev_channel_get_module_ctx(struct raid_bdev_io_channel *raid_ch) in raid_bdev_channel_get_module_ctx() argument
198 return spdk_io_channel_get_ctx(raid_ch->_module_channel); in raid_bdev_channel_get_module_ctx()
204 struct raid_bdev_io_channel *raid_ch; in raid_test_create_io_channel() local
207 raid_ch = calloc(1, sizeof(*raid_ch)); in raid_test_create_io_channel()
208 SPDK_CU_ASSERT_FATAL(raid_ch != NULL); in raid_test_create_io_channel()
210 raid_ch->_base_channels = calloc(raid_bdev->num_base_bdevs, sizeof(struct spdk_io_channel *)); in raid_test_create_io_channel()
[all …]
|
| /spdk/test/unit/lib/bdev/raid/raid1.c/ |
| H A D | raid1_ut.c | 27 struct raid_bdev_io_channel *raid_ch,
149 get_raid_io(struct raid1_info *r1_info, struct raid_bdev_io_channel *raid_ch, in get_raid_io()
157 raid_test_bdev_io_init(raid_io, r1_info->raid_bdev, raid_ch, io_type, 0, num_blocks, NULL, 0, NULL); in get_raid_io()
178 struct raid_bdev_io_channel *raid_ch)) in run_for_each_raid1_config()
184 struct raid_bdev_io_channel *raid_ch; in run_for_each_raid1_config()
187 raid_ch = raid_test_create_io_channel(r1_info->raid_bdev); in run_for_each_raid1_config()
189 test_fn(r1_info->raid_bdev, raid_ch); in run_for_each_raid1_config()
191 raid_test_destroy_io_channel(raid_ch); in run_for_each_raid1_config()
197 _test_raid1_read_balancing(struct raid_bdev *raid_bdev, struct raid_bdev_io_channel *raid_ch) in _test_raid1_read_balancing()
200 struct raid1_io_channel *raid1_ch = raid_bdev_channel_get_module_ctx(raid_ch); in _test_raid1_read_balancing()
148 get_raid_io(struct raid1_info * r1_info,struct raid_bdev_io_channel * raid_ch,enum spdk_bdev_io_type io_type,uint64_t num_blocks) get_raid_io() argument
177 run_for_each_raid1_config(void (* test_fn)(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch)) run_for_each_raid1_config() argument
183 struct raid_bdev_io_channel *raid_ch; run_for_each_raid1_config() local
196 _test_raid1_read_balancing(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) _test_raid1_read_balancing() argument
258 _test_raid1_write_error(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) _test_raid1_write_error() argument
324 _test_raid1_read_error(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) _test_raid1_read_error() argument
[all...] |
| /spdk/module/bdev/raid/ |
| H A D | raid1.c | 22 raid1_channel_inc_read_counters(struct raid_bdev_io_channel *raid_ch, uint8_t idx, in raid1_channel_inc_read_counters() argument
25 struct raid1_io_channel *raid1_ch = raid_bdev_channel_get_module_ctx(raid_ch); in raid1_channel_inc_read_counters()
32 raid1_channel_dec_read_counters(struct raid_bdev_io_channel *raid_ch, uint8_t idx, in raid1_channel_dec_read_counters() argument
35 struct raid1_io_channel *raid1_ch = raid_bdev_channel_get_module_ctx(raid_ch); in raid1_channel_dec_read_counters()
59 base_info = raid_bdev_channel_get_base_info(raid_io->raid_ch, bdev_io->bdev); in raid1_write_bdev_io_completion()
110 base_ch = raid_bdev_channel_get_base_channel(raid_io->raid_ch, i); in raid1_correct_read_error()
162 base_ch = raid_bdev_channel_get_base_channel(raid_io->raid_ch, i); in raid1_read_other_base_bdev()
197 raid1_channel_dec_read_counters(raid_io->raid_ch, raid_io->base_bdev_io_submitted, in raid1_read_bdev_io_completion()
220 raid1_channel_next_read_base_bdev(struct raid_bdev *raid_bdev, struct raid_bdev_io_channel *raid_ch) in raid1_channel_next_read_base_bdev() argument
222 struct raid1_io_channel *raid1_ch = raid_bdev_channel_get_module_ctx(raid_ch); in raid1_channel_next_read_base_bdev()
242 struct raid_bdev_io_channel *raid_ch = raid_io->raid_ch; raid1_submit_read_request() local
483 raid1_submit_process_request(struct raid_bdev_process_request * process_req,struct raid_bdev_io_channel * raid_ch) raid1_submit_process_request() argument
[all...] |
| H A D | bdev_raid.c | 71 struct raid_bdev_io_channel *raid_ch;
141 raid_bdev_channel_get_base_channel(struct raid_bdev_io_channel *raid_ch, uint8_t idx) in raid_bdev_channel_get_base_info() argument
143 return raid_ch->base_channel[idx]; in raid_bdev_channel_get_base_info()
147 raid_bdev_channel_get_module_ctx(struct raid_bdev_io_channel *raid_ch) in raid_bdev_channel_get_base_info()
149 assert(raid_ch->module_channel != NULL); in raid_bdev_channel_get_base_info()
151 return spdk_io_channel_get_ctx(raid_ch->module_channel); in raid_bdev_channel_get_base_info()
155 raid_bdev_channel_get_base_info(struct raid_bdev_io_channel *raid_ch, struct spdk_bdev *base_bdev) in raid_bdev_channel_get_base_info()
157 struct spdk_io_channel *ch = spdk_io_channel_from_ctx(raid_ch); in raid_bdev_channel_get_base_info()
180 raid_bdev_ch_process_cleanup(struct raid_bdev_io_channel *raid_ch) in raid_bdev_ch_process_cleanup()
182 raid_ch
59 struct raid_bdev_io_channel *raid_ch; global() member
127 raid_bdev_channel_get_base_channel(struct raid_bdev_io_channel * raid_ch,uint8_t idx) raid_bdev_channel_get_base_channel() argument
133 raid_bdev_channel_get_module_ctx(struct raid_bdev_io_channel * raid_ch) raid_bdev_channel_get_module_ctx() argument
166 raid_bdev_ch_process_cleanup(struct raid_bdev_io_channel * raid_ch) raid_bdev_ch_process_cleanup() argument
183 raid_bdev_ch_process_setup(struct raid_bdev_io_channel * raid_ch,struct raid_bdev_process * process) raid_bdev_ch_process_setup() argument
247 struct raid_bdev_io_channel *raid_ch = ctx_buf; raid_bdev_create_cb() local
328 struct raid_bdev_io_channel *raid_ch = ctx_buf; raid_bdev_destroy_cb() local
822 struct raid_bdev_io_channel *raid_ch = raid_io->raid_ch; raid_bdev_submit_rw_request() local
877 raid_bdev_io_init(struct raid_bdev_io * raid_io,struct raid_bdev_io_channel * raid_ch,enum spdk_bdev_io_type type,uint64_t offset_blocks,uint64_t num_blocks,struct iovec * iovs,int iovcnt,void * md_buf,struct spdk_memory_domain * memory_domain,void * memory_domain_ctx) raid_bdev_io_init() argument
1916 struct raid_bdev_io_channel *raid_ch = spdk_io_channel_get_ctx(ch); raid_bdev_channel_remove_base_bdev() local
2536 struct raid_bdev_io_channel *raid_ch = spdk_io_channel_get_ctx(ch); raid_bdev_channel_process_finish() local
2658 struct raid_bdev_io_channel *raid_ch = spdk_io_channel_get_ctx(ch); raid_bdev_process_channel_update() local
2845 struct raid_bdev_io_channel *raid_ch = spdk_io_channel_get_ctx(ch); raid_bdev_channel_abort_start_process() local
2899 struct raid_bdev_io_channel *raid_ch = spdk_io_channel_get_ctx(ch); raid_bdev_channel_start_process() local
[all...] |
| H A D | bdev_raid.h | 141 struct raid_bdev_io_channel *raid_ch; member
350 struct raid_bdev_io_channel *raid_ch);
373 struct spdk_io_channel *raid_bdev_channel_get_base_channel(struct raid_bdev_io_channel *raid_ch,
375 void *raid_bdev_channel_get_module_ctx(struct raid_bdev_io_channel *raid_ch);
376 struct raid_base_bdev_info *raid_bdev_channel_get_base_info(struct raid_bdev_io_channel *raid_ch,
379 void raid_bdev_io_init(struct raid_bdev_io *raid_io, struct raid_bdev_io_channel *raid_ch,
|
| H A D | concat.c | 68 struct raid_bdev_io_channel *raid_ch = raid_io->raid_ch; in concat_submit_rw_request() local
102 assert(raid_ch != NULL); in concat_submit_rw_request()
103 base_ch = raid_bdev_channel_get_base_channel(raid_ch, pd_idx); in concat_submit_rw_request()
238 base_ch = raid_bdev_channel_get_base_channel(raid_io->raid_ch, i); in concat_submit_null_payload_request()
|
| H A D | raid0.c | 79 struct raid_bdev_io_channel *raid_ch = raid_io->raid_ch; in raid0_submit_rw_request() local
118 assert(raid_ch != NULL); in raid0_submit_rw_request()
119 base_ch = raid_bdev_channel_get_base_channel(raid_ch, pd_idx); in raid0_submit_rw_request()
324 base_ch = raid_bdev_channel_get_base_channel(raid_io->raid_ch, disk_idx); in raid0_submit_null_payload_request()
|
| H A D | raid5f.c | 431 struct spdk_io_channel *base_ch = raid_bdev_channel_get_base_channel(raid_io->raid_ch, in raid5f_chunk_submit()
628 struct raid5f_io_channel *r5ch = raid_bdev_channel_get_module_ctx(raid_io->raid_ch); in raid5f_submit_write_request()
649 …if (raid_bdev_channel_get_base_channel(raid_io->raid_ch, stripe_req->parity_chunk->index) != NULL)… in raid5f_submit_write_request()
710 struct raid5f_io_channel *r5ch = raid_bdev_channel_get_module_ctx(raid_io->raid_ch); in raid5f_submit_reconstruct_read()
780 struct spdk_io_channel *base_ch = raid_bdev_channel_get_base_channel(raid_io->raid_ch, chunk_idx); in raid5f_submit_read_request()
1207 struct raid_bdev_io_channel *raid_ch) in raid5f_submit_process_request() argument
1209 struct spdk_io_channel *ch = spdk_io_channel_from_ctx(raid_ch); in raid5f_submit_process_request()
1223 raid_bdev_io_init(raid_io, raid_ch, SPDK_BDEV_IO_TYPE_READ, in raid5f_submit_process_request()
|
| /spdk/test/unit/lib/bdev/raid/concat.c/ |
| H A D | concat_ut.c | 276 raid_io_initialize(struct raid_bdev_io *raid_io, struct raid_bdev_io_channel *raid_ch, in raid_io_initialize() argument
297 raid_test_bdev_io_init(raid_io, raid_bdev, raid_ch, iotype, lba, blocks, iovs, iovcnt, md_buf); in raid_io_initialize()
305 struct raid_bdev_io_channel *raid_ch; in submit_and_verify_rw() local
316 raid_ch = raid_test_create_io_channel(raid_bdev); in submit_and_verify_rw()
320 raid_io_initialize(raid_io, raid_ch, raid_bdev, lba, blocks, SPDK_BDEV_IO_TYPE_WRITE); in submit_and_verify_rw()
324 raid_io_initialize(raid_io, raid_ch, raid_bdev, lba, blocks, SPDK_BDEV_IO_TYPE_READ); in submit_and_verify_rw()
328 raid_io_initialize(raid_io, raid_ch, raid_bdev, lba, blocks, SPDK_BDEV_IO_TYPE_UNMAP); in submit_and_verify_rw()
332 raid_io_initialize(raid_io, raid_ch, raid_bdev, lba, blocks, SPDK_BDEV_IO_TYPE_FLUSH); in submit_and_verify_rw()
349 raid_test_destroy_io_channel(raid_ch); in submit_and_verify_rw()
376 struct raid_bdev_io_channel *raid_ch; in submit_and_verify_null_payload() local
[all …]
|
| /spdk/test/unit/lib/bdev/raid/raid5f.c/ |
| H A D | raid5f_ut.c | 27 struct raid_bdev_io_channel *raid_ch,
207 struct raid_bdev_io_channel *raid_ch; member
321 raid_test_bdev_io_init(raid_io, raid_bdev, io_info->raid_ch, io_info->io_type, in get_raid_io()
607 if (!raid_bdev_channel_get_base_channel(io_info->raid_ch, i)) { in test_raid5f_write_request()
683 struct raid_bdev_io_channel *raid_ch, enum spdk_bdev_io_type io_type, in init_io_info() argument
732 io_info->raid_ch = raid_ch; in init_io_info()
830 test_raid5f_submit_rw_request(struct raid5f_info *r5f_info, struct raid_bdev_io_channel *raid_ch, in test_raid5f_submit_rw_request() argument
836 init_io_info(&io_info, r5f_info, raid_ch, io_type, stripe_index, stripe_offset_blocks, num_blocks); in test_raid5f_submit_rw_request()
864 struct raid_bdev_io_channel *raid_ch)) in run_for_each_raid5f_config() argument
870 struct raid_bdev_io_channel *raid_ch; run_for_each_raid5f_config() local
890 __test_raid5f_submit_read_request(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) __test_raid5f_submit_read_request() argument
925 __test_raid5f_stripe_request_map_iovecs(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) __test_raid5f_stripe_request_map_iovecs() argument
991 __test_raid5f_submit_full_stripe_write_request(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) __test_raid5f_submit_full_stripe_write_request() argument
1008 __test_raid5f_chunk_write_error(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) __test_raid5f_chunk_write_error() argument
1060 __test_raid5f_chunk_write_error_with_enomem(struct raid_bdev * raid_bdev,struct raid_bdev_io_channel * raid_ch) __test_raid5f_chunk_write_error_with_enomem() argument
[all...] |
| /spdk/test/unit/lib/bdev/raid/raid0.c/ |
| H A D | raid0_ut.c | 428 raid_io_initialize(struct raid_bdev_io *raid_io, struct raid_bdev_io_channel *raid_ch, in raid_io_initialize() argument
449 raid_test_bdev_io_init(raid_io, raid_bdev, raid_ch, iotype, lba, blocks, iovs, iovcnt, md_buf); in raid_io_initialize()
497 CU_ASSERT(raid_bdev_channel_get_base_channel(raid_io->raid_ch, pd_idx) == output->ch); in verify_io()
607 CU_ASSERT(raid_bdev_channel_get_base_channel(raid_io->raid_ch, disk_idx) == output->ch); in verify_io_without_payload()
666 struct raid_bdev_io_channel *raid_ch; in test_write_io() local
671 raid_ch = raid_test_create_io_channel(raid_bdev); in test_write_io()
678 raid_io_initialize(raid_io, raid_ch, raid_bdev, lba, io_len, SPDK_BDEV_IO_TYPE_WRITE); in test_write_io()
689 raid_test_destroy_io_channel(raid_ch); in test_write_io()
703 struct raid_bdev_io_channel *raid_ch; in test_read_io() local
708 raid_ch = raid_test_create_io_channel(raid_bdev); in test_read_io()
[all …]
|
| /spdk/test/unit/lib/bdev/raid/bdev_raid.c/ |
| H A D | bdev_raid_ut.c | 117 struct raid_bdev_io_channel *raid_ch) in ut_raid_submit_process_request()
119 struct raid_bdev *raid_bdev = spdk_io_channel_get_io_device(spdk_io_channel_from_ctx(raid_ch)); in ut_raid_submit_process_request()
1498 struct raid_bdev_io_channel *raid_ch; in test_raid_io_split()
1527 raid_ch = spdk_io_channel_get_ctx(ch); in test_raid_io_split()
1539 raid_ch->process.offset = split_offset; in test_raid_io_split()
1586 raid_ch->process.offset = split_offset; in test_raid_io_split()
1625 raid_ch->process.offset = split_offset; in test_raid_io_split()
1661 raid_ch->process.offset = split_offset; in test_raid_io_split()
1702 raid_ch->process.offset = split_offset;
116 ut_raid_submit_process_request(struct raid_bdev_process_request * process_req,struct raid_bdev_io_channel * raid_ch) ut_raid_submit_process_request() argument
1425 struct raid_bdev_io_channel *raid_ch; test_raid_io_split() local
|