Home
last modified time | relevance | path

Searched refs:process_req (Results 1 – 7 of 7) sorted by relevance

/spdk/module/bdev/raid/
H A Draid1.c428 struct raid_bdev_process_request *process_req = cb_arg; in raid1_process_write_completed() local
432 raid_bdev_process_request_complete(process_req, success ? 0 : -EIO); in raid1_process_write_completed()
435 static void raid1_process_submit_write(struct raid_bdev_process_request *process_req);
440 struct raid_bdev_process_request *process_req = ctx; in _raid1_process_submit_write() local
442 raid1_process_submit_write(process_req); in _raid1_process_submit_write()
446 raid1_process_submit_write(struct raid_bdev_process_request *process_req) in raid1_process_submit_write() argument
448 struct raid_bdev_io *raid_io = &process_req->raid_io; in raid1_process_submit_write()
453 ret = raid_bdev_writev_blocks_ext(process_req->target, process_req->target_ch, in raid1_process_submit_write()
456 raid1_process_write_completed, process_req, in raid1_process_submit_write()
470 struct raid_bdev_process_request *process_req = SPDK_CONTAINEROF(raid_io, raid1_process_read_completed() local
482 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 Draid5f.c1146 struct raid_bdev_process_request *process_req = cb_arg; in raid5f_process_write_completed() local
1150 raid_bdev_process_request_complete(process_req, success ? 0 : -EIO); in raid5f_process_write_completed()
1153 static void raid5f_process_submit_write(struct raid_bdev_process_request *process_req);
1158 struct raid_bdev_process_request *process_req = ctx; in _raid5f_process_submit_write() local
1160 raid5f_process_submit_write(process_req); in _raid5f_process_submit_write()
1164 raid5f_process_submit_write(struct raid_bdev_process_request *process_req) in raid5f_process_submit_write() argument
1166 struct raid_bdev_io *raid_io = &process_req->raid_io; in raid5f_process_submit_write()
1169 uint64_t stripe_index = process_req->offset_blocks / r5f_info->stripe_blocks; in raid5f_process_submit_write()
1174 ret = raid_bdev_writev_blocks_ext(process_req->target, process_req->target_ch, in raid5f_process_submit_write()
1177 raid5f_process_write_completed, process_req, &io_opts); in raid5f_process_submit_write()
[all …]
H A Dbdev_raid.c2724 raid_bdev_process_request_complete(struct raid_bdev_process_request *process_req, int status) in raid_bdev_submit_process_request()
2726 struct raid_bdev_process *process = process_req->process;
2728 TAILQ_INSERT_TAIL(&process->requests, process_req, link); in _raid_bdev_process_thread_run()
2731 assert(process->window_remaining >= process_req->num_blocks); in _raid_bdev_process_thread_run()
2737 process->window_remaining -= process_req->num_blocks; in _raid_bdev_process_thread_run()
2754 struct raid_bdev_process_request *process_req; in raid_bdev_process_window_range_locked()
2757 process_req = TAILQ_FIRST(&process->requests); in raid_bdev_process_window_range_locked()
2758 if (process_req == NULL) { in raid_bdev_process_window_range_locked()
2763 process_req->target = process->target; in raid_bdev_process_window_range_locked()
2764 process_req in raid_bdev_process_window_range_locked()
2666 raid_bdev_process_request_complete(struct raid_bdev_process_request * process_req,int status) raid_bdev_process_request_complete() argument
2696 struct raid_bdev_process_request *process_req; raid_bdev_submit_process_request() local
2919 raid_bdev_process_request_free(struct raid_bdev_process_request * process_req) raid_bdev_process_request_free() argument
2930 struct raid_bdev_process_request *process_req; raid_bdev_process_alloc_request() local
2958 struct raid_bdev_process_request *process_req; raid_bdev_process_free() local
2973 struct raid_bdev_process_request *process_req; raid_bdev_process_alloc() local
[all...]
H A Dbdev_raid.h349 int (*submit_process_request)(struct raid_bdev_process_request *process_req,
378 void raid_bdev_process_request_complete(struct raid_bdev_process_request *process_req, int status);
/spdk/test/unit/lib/bdev/raid/bdev_raid.c/
H A Dbdev_raid_ut.c110 struct raid_bdev_process_request *process_req = ctx; in ut_raid_complete_process_request()
112 raid_bdev_process_request_complete(process_req, 0); in ut_raid_complete_process_request()
116 ut_raid_submit_process_request(struct raid_bdev_process_request *process_req, in ut_raid_submit_process_request()
121 *(uint64_t *)raid_bdev->module_private += process_req->num_blocks; in ut_raid_submit_process_request()
123 spdk_thread_send_msg(spdk_get_thread(), ut_raid_complete_process_request, process_req); in ut_raid_submit_process_request()
125 return process_req->num_blocks; in ut_raid_submit_process_request()
109 struct raid_bdev_process_request *process_req = ctx; ut_raid_complete_process_request() local
115 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
/spdk/test/unit/lib/bdev/raid/raid1.c/
H A Draid1_ut.c24 DEFINE_STUB_V(raid_bdev_process_request_complete, (struct raid_bdev_process_request *process_req,
/spdk/test/unit/lib/bdev/raid/raid5f.c/
H A Draid5f_ut.c24 DEFINE_STUB_V(raid_bdev_process_request_complete, (struct raid_bdev_process_request *process_req,