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()
148 static void ext4_release_io_end(ext4_io_end_t *io_end) in ext4_release_io_end() argument
152 BUG_ON(!list_empty(&io_end->list)); in ext4_release_io_end()
153 BUG_ON(io_end->flag & EXT4_IO_END_UNWRITTEN); in ext4_release_io_end()
154 WARN_ON(io_end->handle); in ext4_release_io_end()
156 for (bio = io_end->bio; bio; bio = next_bio) { in ext4_release_io_end()
161 ext4_free_io_end_vec(io_end); in ext4_release_io_end()
162 kmem_cache_free(io_end_cachep, io_end); in ext4_release_io_end()
173 static int ext4_end_io_end(ext4_io_end_t *io_end) in ext4_end_io_end() argument
175 struct inode *inode = io_end->inode; in ext4_end_io_end()
176 handle_t *handle = io_end->handle; in ext4_end_io_end()
181 io_end, inode->i_ino, io_end->list.next, io_end->list.prev); in ext4_end_io_end()
183 io_end->handle = NULL; /* Following call will use up the handle */ in ext4_end_io_end()
184 ret = ext4_convert_unwritten_io_end_vec(handle, io_end); in ext4_end_io_end()
191 ext4_clear_io_unwritten_flag(io_end); in ext4_end_io_end()
192 ext4_release_io_end(io_end); in ext4_end_io_end()
200 ext4_io_end_t *io_end, *io_end0, *io_end1; in dump_completed_IO() local
206 list_for_each_entry(io_end, head, list) { in dump_completed_IO()
207 cur = &io_end->list; in dump_completed_IO()
214 io_end, inode->i_ino, io_end0, io_end1); in dump_completed_IO()
220 static void ext4_add_complete_io(ext4_io_end_t *io_end) in ext4_add_complete_io() argument
222 struct ext4_inode_info *ei = EXT4_I(io_end->inode); in ext4_add_complete_io()
223 struct ext4_sb_info *sbi = EXT4_SB(io_end->inode->i_sb); in ext4_add_complete_io()
228 WARN_ON(!(io_end->flag & EXT4_IO_END_UNWRITTEN)); in ext4_add_complete_io()
229 WARN_ON(!io_end->handle && sbi->s_journal); in ext4_add_complete_io()
234 list_add_tail(&io_end->list, &ei->i_rsv_conversion_list); in ext4_add_complete_io()
241 ext4_io_end_t *io_end; in ext4_do_flush_completed_IO() local
253 io_end = list_entry(unwritten.next, ext4_io_end_t, list); in ext4_do_flush_completed_IO()
254 BUG_ON(!(io_end->flag & EXT4_IO_END_UNWRITTEN)); in ext4_do_flush_completed_IO()
255 list_del_init(&io_end->list); in ext4_do_flush_completed_IO()
257 err = ext4_end_io_end(io_end); in ext4_do_flush_completed_IO()
276 ext4_io_end_t *io_end = kmem_cache_zalloc(io_end_cachep, flags); in ext4_init_io_end() local
278 if (io_end) { in ext4_init_io_end()
279 io_end->inode = inode; in ext4_init_io_end()
280 INIT_LIST_HEAD(&io_end->list); in ext4_init_io_end()
281 INIT_LIST_HEAD(&io_end->list_vec); in ext4_init_io_end()
282 atomic_set(&io_end->count, 1); in ext4_init_io_end()
284 return io_end; in ext4_init_io_end()
287 void ext4_put_io_end_defer(ext4_io_end_t *io_end) in ext4_put_io_end_defer() argument
289 if (atomic_dec_and_test(&io_end->count)) { in ext4_put_io_end_defer()
290 if (!(io_end->flag & EXT4_IO_END_UNWRITTEN) || in ext4_put_io_end_defer()
291 list_empty(&io_end->list_vec)) { in ext4_put_io_end_defer()
292 ext4_release_io_end(io_end); in ext4_put_io_end_defer()
295 ext4_add_complete_io(io_end); in ext4_put_io_end_defer()
299 int ext4_put_io_end(ext4_io_end_t *io_end) in ext4_put_io_end() argument
303 if (atomic_dec_and_test(&io_end->count)) { in ext4_put_io_end()
304 if (io_end->flag & EXT4_IO_END_UNWRITTEN) { in ext4_put_io_end()
305 err = ext4_convert_unwritten_io_end_vec(io_end->handle, in ext4_put_io_end()
306 io_end); in ext4_put_io_end()
307 io_end->handle = NULL; in ext4_put_io_end()
308 ext4_clear_io_unwritten_flag(io_end); in ext4_put_io_end()
310 ext4_release_io_end(io_end); in ext4_put_io_end()
315 ext4_io_end_t *ext4_get_io_end(ext4_io_end_t *io_end) in ext4_get_io_end() argument
317 atomic_inc(&io_end->count); in ext4_get_io_end()
318 return io_end; in ext4_get_io_end()
324 ext4_io_end_t *io_end = bio->bi_private; in ext4_end_bio() local
328 if (WARN_ONCE(!io_end, "io_end is NULL: %s: sector %Lu len %u err %d\n", in ext4_end_bio()
340 struct inode *inode = io_end->inode; in ext4_end_bio()
351 if (io_end->flag & EXT4_IO_END_UNWRITTEN) { in ext4_end_bio()
357 bio->bi_private = xchg(&io_end->bio, bio); in ext4_end_bio()
358 ext4_put_io_end_defer(io_end); in ext4_end_bio()
364 ext4_put_io_end_defer(io_end); in ext4_end_bio()
377 io->io_bio->bi_write_hint = io->io_end->inode->i_write_hint; in ext4_io_submit()
389 io->io_end = NULL; in ext4_io_submit_init()
406 bio->bi_private = ext4_get_io_end(io->io_end); in io_submit_init_bio()