Lines Matching refs:ws
48 struct work_struct ws; member
55 INIT_WORK(&k->ws, fn); in init_continuation()
62 queue_work(wq, &k->ws); in queue_continuation()
103 struct work_struct *ws, *tmp; in __commit() local
124 list_for_each_entry_safe(ws, tmp, &work_items, entry) { in __commit()
125 k = container_of(ws, struct continuation, ws); in __commit()
127 INIT_LIST_HEAD(&ws->entry); /* to avoid a WARN_ON */ in __commit()
128 queue_work(b->wq, ws); in __commit()
171 list_add_tail(&k->ws.entry, &b->work_items); in continue_after_commit()
1071 dm_cell_quiesce_v2(mg->cache->prison, mg->cell, &mg->k.ws); in quiesce()
1074 static struct dm_cache_migration *ws_to_mg(struct work_struct *ws) in ws_to_mg() argument
1076 struct continuation *k = container_of(ws, struct continuation, ws); in ws_to_mg()
1225 static void mg_success(struct work_struct *ws) in mg_success() argument
1227 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_success()
1231 static void mg_update_metadata(struct work_struct *ws) in mg_update_metadata() argument
1234 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata()
1293 static void mg_update_metadata_after_copy(struct work_struct *ws) in mg_update_metadata_after_copy() argument
1295 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata_after_copy()
1303 mg_update_metadata(ws); in mg_update_metadata_after_copy()
1306 static void mg_upgrade_lock(struct work_struct *ws) in mg_upgrade_lock() argument
1309 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_upgrade_lock()
1330 mg_update_metadata(ws); in mg_upgrade_lock()
1334 static void mg_full_copy(struct work_struct *ws) in mg_full_copy() argument
1336 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_full_copy()
1343 mg_upgrade_lock(ws); in mg_full_copy()
1351 static void mg_copy(struct work_struct *ws) in mg_copy() argument
1353 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_copy()
1369 mg_full_copy(ws); in mg_copy()
1383 mg_full_copy(ws); in mg_copy()
1414 mg_copy(&mg->k.ws); in mg_lock_writes()
1463 static void invalidate_completed(struct work_struct *ws) in invalidate_completed() argument
1465 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_completed()
1492 static void invalidate_remove(struct work_struct *ws) in invalidate_remove() argument
1495 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_remove()
1541 queue_work(cache->wq, &mg->k.ws); in invalidate_lock()
1792 static void process_deferred_bios(struct work_struct *ws) in process_deferred_bios() argument
1794 struct cache *cache = container_of(ws, struct cache, deferred_bio_worker); in process_deferred_bios()
1845 static void do_waker(struct work_struct *ws) in do_waker() argument
1847 struct cache *cache = container_of(to_delayed_work(ws), struct cache, waker); in do_waker()
1855 static void check_migrations(struct work_struct *ws) in check_migrations() argument
1859 struct cache *cache = container_of(ws, struct cache, migration_worker); in check_migrations()