Lines Matching refs:bio_queue_data
34 struct bio_queue_data { struct
45 struct bio_queue_data bio_queue_data[]; argument
50 struct bio_queue_data *bio_queue_data = ptr; in start_bio_queue() local
52 blk_start_plug(&bio_queue_data->plug); in start_bio_queue()
57 struct bio_queue_data *bio_queue_data = ptr; in finish_bio_queue() local
59 blk_finish_plug(&bio_queue_data->plug); in finish_bio_queue()
142 struct bio_queue_data *bio_queue_data = &(submitter->bio_queue_data[vio->bio_zone]); in get_bio_list() local
146 mutex_lock(&bio_queue_data->lock); in get_bio_list()
147 vdo_int_map_remove(bio_queue_data->map, in get_bio_list()
149 vdo_int_map_remove(bio_queue_data->map, in get_bio_list()
153 mutex_unlock(&bio_queue_data->lock); in get_bio_list()
274 struct bio_queue_data *bio_queue_data = in try_bio_map_merge() local
275 &vdo->io_submitter->bio_queue_data[vio->bio_zone]; in try_bio_map_merge()
281 mutex_lock(&bio_queue_data->lock); in try_bio_map_merge()
282 prev_vio = get_mergeable_locked(bio_queue_data->map, vio, true); in try_bio_map_merge()
283 next_vio = get_mergeable_locked(bio_queue_data->map, vio, false); in try_bio_map_merge()
290 result = vdo_int_map_put(bio_queue_data->map, in try_bio_map_merge()
295 result = merge_to_prev_tail(bio_queue_data->map, vio, prev_vio); in try_bio_map_merge()
298 result = merge_to_next_head(bio_queue_data->map, vio, next_vio); in try_bio_map_merge()
300 mutex_unlock(&bio_queue_data->lock); in try_bio_map_merge()
383 struct bio_queue_data, "bio submission data", in vdo_make_io_submitter()
392 struct bio_queue_data *bio_queue_data = &io_submitter->bio_queue_data[i]; in vdo_make_io_submitter() local
394 mutex_init(&bio_queue_data->lock); in vdo_make_io_submitter()
404 &bio_queue_data->map); in vdo_make_io_submitter()
416 bio_queue_data->queue_number = i; in vdo_make_io_submitter()
418 &bio_queue_type, 1, (void **) &bio_queue_data); in vdo_make_io_submitter()
424 vdo_int_map_free(vdo_forget(bio_queue_data->map)); in vdo_make_io_submitter()
431 bio_queue_data->queue = vdo->threads[vdo->thread_config.bio_threads[i]].queue; in vdo_make_io_submitter()
452 vdo_finish_work_queue(io_submitter->bio_queue_data[i].queue); in vdo_cleanup_io_submitter()
472 vdo_forget(io_submitter->bio_queue_data[i].queue); in vdo_free_io_submitter()
473 vdo_int_map_free(vdo_forget(io_submitter->bio_queue_data[i].map)); in vdo_free_io_submitter()