Lines Matching defs:raid_io
22 DEFINE_STUB_V(raid_bdev_queue_io_wait, (struct raid_bdev_io *raid_io, struct spdk_bdev *bdev,
26 DEFINE_STUB_V(raid_bdev_io_init, (struct raid_bdev_io *raid_io,
152 struct raid_bdev_io *raid_io;
154 raid_io = calloc(1, sizeof(*raid_io));
155 SPDK_CU_ASSERT_FATAL(raid_io != NULL);
157 raid_test_bdev_io_init(raid_io, r1_info->raid_bdev, raid_ch, io_type, 0, num_blocks, NULL, 0, NULL);
159 return raid_io;
163 put_raid_io(struct raid_bdev_io *raid_io)
165 free(raid_io);
169 raid_test_bdev_io_complete(struct raid_bdev_io *raid_io, enum spdk_bdev_io_status status)
173 put_raid_io(raid_io);
205 struct raid_bdev_io *raid_io;
212 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, small_io_blocks);
213 raid1_submit_read_request(raid_io);
214 CU_ASSERT(raid_io->base_bdev_io_submitted == i);
215 put_raid_io(raid_io);
228 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, big_io_blocks);
229 raid1_submit_read_request(raid_io);
230 big_io_base_bdev_idx = raid_io->base_bdev_io_submitted;
231 put_raid_io(raid_io);
235 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, small_io_blocks);
236 raid1_submit_read_request(raid_io);
237 CU_ASSERT(raid_io->base_bdev_io_submitted != big_io_base_bdev_idx);
238 put_raid_io(raid_io);
246 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, small_io_blocks);
247 raid1_submit_read_request(raid_io);
248 CU_ASSERT(raid_io->base_bdev_io_submitted == big_io_base_bdev_idx);
249 put_raid_io(raid_io);
262 struct raid_bdev_io *raid_io;
269 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_WRITE, 64);
270 raid1_submit_write_request(raid_io);
280 raid1_write_bdev_io_completion(&bdev_io, bdev_io_success, raid_io);
287 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_WRITE, 64);
288 raid1_submit_write_request(raid_io);
298 raid1_write_bdev_io_completion(&bdev_io, bdev_io_success, raid_io);
305 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_WRITE, 64);
306 raid1_submit_write_request(raid_io);
312 raid1_write_bdev_io_completion(&bdev_io, bdev_io_success, raid_io);
330 struct raid_bdev_io *raid_io;
336 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, 64);
337 raid1_submit_read_request(raid_io);
338 CU_ASSERT(raid_io->base_bdev_io_submitted == 0);
339 CU_ASSERT(raid_io->base_bdev_io_remaining == 0);
343 raid1_read_bdev_io_completion(&bdev_io, false, raid_io);
345 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs - 1));
349 raid1_read_other_completion(&bdev_io, true, raid_io);
354 raid1_correct_read_error_completion(&bdev_io, true, raid_io);
361 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, 64);
362 raid1_submit_read_request(raid_io);
363 CU_ASSERT(raid_io->base_bdev_io_submitted == 0);
364 CU_ASSERT(raid_io->base_bdev_io_remaining == 0);
368 raid1_read_bdev_io_completion(&bdev_io, false, raid_io);
370 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs - 1));
374 raid1_read_other_completion(&bdev_io, true, raid_io);
379 raid1_correct_read_error_completion(&bdev_io, false, raid_io);
386 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, 64);
387 raid1_submit_read_request(raid_io);
388 CU_ASSERT(raid_io->base_bdev_io_submitted == 0);
389 CU_ASSERT(raid_io->base_bdev_io_remaining == 0);
393 raid1_read_bdev_io_completion(&bdev_io, false, raid_io);
395 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs - 1));
397 while (raid_io->base_bdev_io_remaining > 1) {
399 raid1_read_other_completion(&bdev_io, false, raid_io);
405 raid1_read_other_completion(&bdev_io, true, raid_io);
410 raid1_correct_read_error_completion(&bdev_io, true, raid_io);
417 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, 64);
418 raid1_submit_read_request(raid_io);
419 CU_ASSERT(raid_io->base_bdev_io_submitted == 0);
420 CU_ASSERT(raid_io->base_bdev_io_remaining == 0);
424 raid1_read_bdev_io_completion(&bdev_io, false, raid_io);
426 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs - 1));
428 while (raid_io->base_bdev_io_remaining > 1) {
430 raid1_read_other_completion(&bdev_io, false, raid_io);
436 raid1_read_other_completion(&bdev_io, false, raid_io);
445 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, 64);
446 raid1_submit_read_request(raid_io);
447 CU_ASSERT(raid_io->base_bdev_io_submitted == 1);
448 CU_ASSERT(raid_io->base_bdev_io_remaining == 0);
452 raid1_read_bdev_io_completion(&bdev_io, false, raid_io);
454 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == raid_bdev->num_base_bdevs);
458 raid1_read_other_completion(&bdev_io, true, raid_io);
463 raid1_correct_read_error_completion(&bdev_io, true, raid_io);
471 raid_io = get_raid_io(r1_info, raid_ch, SPDK_BDEV_IO_TYPE_READ, 64);
472 raid1_submit_read_request(raid_io);
473 CU_ASSERT(raid_io->base_bdev_io_submitted == 1);
474 CU_ASSERT(raid_io->base_bdev_io_remaining == 0);
478 raid1_read_bdev_io_completion(&bdev_io, false, raid_io);
481 CU_ASSERT((uint8_t)raid_io->base_bdev_io_remaining == (raid_bdev->num_base_bdevs - 2));
485 raid1_read_other_completion(&bdev_io, true, raid_io);
490 raid1_correct_read_error_completion(&bdev_io, true, raid_io);