Lines Matching refs:ws
49 struct work_struct ws; member
56 INIT_WORK(&k->ws, fn); in init_continuation()
63 queue_work(wq, &k->ws); in queue_continuation()
104 struct work_struct *ws, *tmp; in __commit() local
125 list_for_each_entry_safe(ws, tmp, &work_items, entry) { in __commit()
126 k = container_of(ws, struct continuation, ws); in __commit()
128 INIT_LIST_HEAD(&ws->entry); /* to avoid a WARN_ON */ in __commit()
129 queue_work(b->wq, ws); in __commit()
172 list_add_tail(&k->ws.entry, &b->work_items); in continue_after_commit()
1075 dm_cell_quiesce_v2(mg->cache->prison, mg->cell, &mg->k.ws); in quiesce()
1078 static struct dm_cache_migration *ws_to_mg(struct work_struct *ws) in ws_to_mg() argument
1080 struct continuation *k = container_of(ws, struct continuation, ws); in ws_to_mg()
1230 static void mg_success(struct work_struct *ws) in mg_success() argument
1232 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_success()
1237 static void mg_update_metadata(struct work_struct *ws) in mg_update_metadata() argument
1240 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata()
1299 static void mg_update_metadata_after_copy(struct work_struct *ws) in mg_update_metadata_after_copy() argument
1301 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata_after_copy()
1309 mg_update_metadata(ws); in mg_update_metadata_after_copy()
1312 static void mg_upgrade_lock(struct work_struct *ws) in mg_upgrade_lock() argument
1315 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_upgrade_lock()
1336 mg_update_metadata(ws); in mg_upgrade_lock()
1340 static void mg_full_copy(struct work_struct *ws) in mg_full_copy() argument
1342 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_full_copy()
1349 mg_upgrade_lock(ws); in mg_full_copy()
1357 static void mg_copy(struct work_struct *ws) in mg_copy() argument
1359 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_copy()
1376 mg_full_copy(ws); in mg_copy()
1390 mg_full_copy(ws); in mg_copy()
1421 mg_copy(&mg->k.ws); in mg_lock_writes()
1472 static void invalidate_completed(struct work_struct *ws) in invalidate_completed() argument
1474 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_completed()
1504 static void invalidate_remove(struct work_struct *ws) in invalidate_remove() argument
1507 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_remove()
1553 queue_work(cache->wq, &mg->k.ws); in invalidate_lock()
1808 static void process_deferred_bios(struct work_struct *ws) in process_deferred_bios() argument
1810 struct cache *cache = container_of(ws, struct cache, deferred_bio_worker); in process_deferred_bios()
1864 static void do_waker(struct work_struct *ws) in do_waker() argument
1866 struct cache *cache = container_of(to_delayed_work(ws), struct cache, waker); in do_waker()
1874 static void check_migrations(struct work_struct *ws) in check_migrations() argument
1878 struct cache *cache = container_of(ws, struct cache, migration_worker); in check_migrations()