Lines Matching refs:async
782 struct async_submit_bio *async; in run_one_async_start() local
785 async = container_of(work, struct async_submit_bio, work); in run_one_async_start()
786 ret = async->submit_bio_start(async->inode, async->rw, async->bio, in run_one_async_start()
787 async->mirror_num, async->bio_flags, in run_one_async_start()
788 async->bio_offset); in run_one_async_start()
790 async->error = ret; in run_one_async_start()
796 struct async_submit_bio *async; in run_one_async_done() local
799 async = container_of(work, struct async_submit_bio, work); in run_one_async_done()
800 fs_info = BTRFS_I(async->inode)->root->fs_info; in run_one_async_done()
810 if (async->error) { in run_one_async_done()
811 bio_endio(async->bio, async->error); in run_one_async_done()
815 async->submit_bio_done(async->inode, async->rw, async->bio, in run_one_async_done()
816 async->mirror_num, async->bio_flags, in run_one_async_done()
817 async->bio_offset); in run_one_async_done()
822 struct async_submit_bio *async; in run_one_async_free() local
824 async = container_of(work, struct async_submit_bio, work); in run_one_async_free()
825 kfree(async); in run_one_async_free()
835 struct async_submit_bio *async; in btrfs_wq_submit_bio() local
837 async = kmalloc(sizeof(*async), GFP_NOFS); in btrfs_wq_submit_bio()
838 if (!async) in btrfs_wq_submit_bio()
841 async->inode = inode; in btrfs_wq_submit_bio()
842 async->rw = rw; in btrfs_wq_submit_bio()
843 async->bio = bio; in btrfs_wq_submit_bio()
844 async->mirror_num = mirror_num; in btrfs_wq_submit_bio()
845 async->submit_bio_start = submit_bio_start; in btrfs_wq_submit_bio()
846 async->submit_bio_done = submit_bio_done; in btrfs_wq_submit_bio()
848 btrfs_init_work(&async->work, btrfs_worker_helper, run_one_async_start, in btrfs_wq_submit_bio()
851 async->bio_flags = bio_flags; in btrfs_wq_submit_bio()
852 async->bio_offset = bio_offset; in btrfs_wq_submit_bio()
854 async->error = 0; in btrfs_wq_submit_bio()
859 btrfs_set_work_high_priority(&async->work); in btrfs_wq_submit_bio()
861 btrfs_queue_work(fs_info->workers, &async->work); in btrfs_wq_submit_bio()
931 int async = check_async_write(inode, bio_flags); in btree_submit_bio_hook() local
945 } else if (!async) { in btree_submit_bio_hook()