Lines Matching refs:plug
1688 static void run_plug(struct btrfs_plug_cb *plug) in run_plug() argument
1698 list_sort(NULL, &plug->rbio_list, plug_cmp); in run_plug()
1699 while (!list_empty(&plug->rbio_list)) { in run_plug()
1700 cur = list_entry(plug->rbio_list.next, in run_plug()
1726 kfree(plug); in run_plug()
1735 struct btrfs_plug_cb *plug; in unplug_work() local
1736 plug = container_of(work, struct btrfs_plug_cb, work); in unplug_work()
1737 run_plug(plug); in unplug_work()
1742 struct btrfs_plug_cb *plug; in btrfs_raid_unplug() local
1743 plug = container_of(cb, struct btrfs_plug_cb, cb); in btrfs_raid_unplug()
1746 btrfs_init_work(&plug->work, unplug_work, NULL, NULL); in btrfs_raid_unplug()
1747 btrfs_queue_work(plug->info->rmw_workers, in btrfs_raid_unplug()
1748 &plug->work); in btrfs_raid_unplug()
1751 run_plug(plug); in btrfs_raid_unplug()
1761 struct btrfs_plug_cb *plug = NULL; in raid56_parity_write() local
1788 cb = blk_check_plugged(btrfs_raid_unplug, fs_info, sizeof(*plug)); in raid56_parity_write()
1790 plug = container_of(cb, struct btrfs_plug_cb, cb); in raid56_parity_write()
1791 if (!plug->info) { in raid56_parity_write()
1792 plug->info = fs_info; in raid56_parity_write()
1793 INIT_LIST_HEAD(&plug->rbio_list); in raid56_parity_write()
1795 list_add_tail(&rbio->plug_list, &plug->rbio_list); in raid56_parity_write()