Lines Matching refs:io_end

56 struct ext4_io_end_vec *ext4_alloc_io_end_vec(ext4_io_end_t *io_end)  in ext4_alloc_io_end_vec()  argument
64 list_add_tail(&io_end_vec->list, &io_end->list_vec); in ext4_alloc_io_end_vec()
68 static void ext4_free_io_end_vec(ext4_io_end_t *io_end) in ext4_free_io_end_vec() argument
72 if (list_empty(&io_end->list_vec)) in ext4_free_io_end_vec()
74 list_for_each_entry_safe(io_end_vec, tmp, &io_end->list_vec, list) { in ext4_free_io_end_vec()
80 struct ext4_io_end_vec *ext4_last_io_end_vec(ext4_io_end_t *io_end) in ext4_last_io_end_vec() argument
82 BUG_ON(list_empty(&io_end->list_vec)); in ext4_last_io_end_vec()
83 return list_last_entry(&io_end->list_vec, struct ext4_io_end_vec, list); in ext4_last_io_end_vec()
150 static void ext4_release_io_end(ext4_io_end_t *io_end) in ext4_release_io_end() argument
154 BUG_ON(!list_empty(&io_end->list)); in ext4_release_io_end()
155 BUG_ON(io_end->flag & EXT4_IO_END_UNWRITTEN); in ext4_release_io_end()
156 WARN_ON(io_end->handle); in ext4_release_io_end()
158 for (bio = io_end->bio; bio; bio = next_bio) { in ext4_release_io_end()
163 ext4_free_io_end_vec(io_end); in ext4_release_io_end()
164 kmem_cache_free(io_end_cachep, io_end); in ext4_release_io_end()
175 static int ext4_end_io_end(ext4_io_end_t *io_end) in ext4_end_io_end() argument
177 struct inode *inode = io_end->inode; in ext4_end_io_end()
178 handle_t *handle = io_end->handle; in ext4_end_io_end()
183 io_end, inode->i_ino, io_end->list.next, io_end->list.prev); in ext4_end_io_end()
185 io_end->handle = NULL; /* Following call will use up the handle */ in ext4_end_io_end()
186 ret = ext4_convert_unwritten_io_end_vec(handle, io_end); in ext4_end_io_end()
193 ext4_clear_io_unwritten_flag(io_end); in ext4_end_io_end()
194 ext4_release_io_end(io_end); in ext4_end_io_end()
202 ext4_io_end_t *io_end, *io_end0, *io_end1; in dump_completed_IO() local
208 list_for_each_entry(io_end, head, list) { in dump_completed_IO()
209 cur = &io_end->list; in dump_completed_IO()
216 io_end, inode->i_ino, io_end0, io_end1); in dump_completed_IO()
222 static void ext4_add_complete_io(ext4_io_end_t *io_end) in ext4_add_complete_io() argument
224 struct ext4_inode_info *ei = EXT4_I(io_end->inode); in ext4_add_complete_io()
225 struct ext4_sb_info *sbi = EXT4_SB(io_end->inode->i_sb); in ext4_add_complete_io()
230 WARN_ON(!(io_end->flag & EXT4_IO_END_UNWRITTEN)); in ext4_add_complete_io()
231 WARN_ON(!io_end->handle && sbi->s_journal); in ext4_add_complete_io()
236 list_add_tail(&io_end->list, &ei->i_rsv_conversion_list); in ext4_add_complete_io()
243 ext4_io_end_t *io_end; in ext4_do_flush_completed_IO() local
255 io_end = list_entry(unwritten.next, ext4_io_end_t, list); in ext4_do_flush_completed_IO()
256 BUG_ON(!(io_end->flag & EXT4_IO_END_UNWRITTEN)); in ext4_do_flush_completed_IO()
257 list_del_init(&io_end->list); in ext4_do_flush_completed_IO()
259 err = ext4_end_io_end(io_end); in ext4_do_flush_completed_IO()
278 ext4_io_end_t *io_end = kmem_cache_zalloc(io_end_cachep, flags); in ext4_init_io_end() local
280 if (io_end) { in ext4_init_io_end()
281 io_end->inode = inode; in ext4_init_io_end()
282 INIT_LIST_HEAD(&io_end->list); in ext4_init_io_end()
283 INIT_LIST_HEAD(&io_end->list_vec); in ext4_init_io_end()
284 refcount_set(&io_end->count, 1); in ext4_init_io_end()
286 return io_end; in ext4_init_io_end()
289 void ext4_put_io_end_defer(ext4_io_end_t *io_end) in ext4_put_io_end_defer() argument
291 if (refcount_dec_and_test(&io_end->count)) { in ext4_put_io_end_defer()
292 if (!(io_end->flag & EXT4_IO_END_UNWRITTEN) || in ext4_put_io_end_defer()
293 list_empty(&io_end->list_vec)) { in ext4_put_io_end_defer()
294 ext4_release_io_end(io_end); in ext4_put_io_end_defer()
297 ext4_add_complete_io(io_end); in ext4_put_io_end_defer()
301 int ext4_put_io_end(ext4_io_end_t *io_end) in ext4_put_io_end() argument
305 if (refcount_dec_and_test(&io_end->count)) { in ext4_put_io_end()
306 if (io_end->flag & EXT4_IO_END_UNWRITTEN) { in ext4_put_io_end()
307 err = ext4_convert_unwritten_io_end_vec(io_end->handle, in ext4_put_io_end()
308 io_end); in ext4_put_io_end()
309 io_end->handle = NULL; in ext4_put_io_end()
310 ext4_clear_io_unwritten_flag(io_end); in ext4_put_io_end()
312 ext4_release_io_end(io_end); in ext4_put_io_end()
317 ext4_io_end_t *ext4_get_io_end(ext4_io_end_t *io_end) in ext4_get_io_end() argument
319 refcount_inc(&io_end->count); in ext4_get_io_end()
320 return io_end; in ext4_get_io_end()
326 ext4_io_end_t *io_end = bio->bi_private; in ext4_end_bio() local
329 if (WARN_ONCE(!io_end, "io_end is NULL: %pg: sector %Lu len %u err %d\n", in ext4_end_bio()
341 struct inode *inode = io_end->inode; in ext4_end_bio()
352 if (io_end->flag & EXT4_IO_END_UNWRITTEN) { in ext4_end_bio()
358 bio->bi_private = xchg(&io_end->bio, bio); in ext4_end_bio()
359 ext4_put_io_end_defer(io_end); in ext4_end_bio()
365 ext4_put_io_end_defer(io_end); in ext4_end_bio()
388 io->io_end = NULL; in ext4_io_submit_init()
404 bio->bi_private = ext4_get_io_end(io->io_end); in io_submit_init_bio()