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()
1063 dm_cell_quiesce_v2(mg->cache->prison, mg->cell, &mg->k.ws); in quiesce()
1066 static struct dm_cache_migration *ws_to_mg(struct work_struct *ws) in ws_to_mg() argument
1068 struct continuation *k = container_of(ws, struct continuation, ws); in ws_to_mg()
1217 static void mg_success(struct work_struct *ws) in mg_success() argument
1219 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_success()
1223 static void mg_update_metadata(struct work_struct *ws) in mg_update_metadata() argument
1226 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata()
1285 static void mg_update_metadata_after_copy(struct work_struct *ws) in mg_update_metadata_after_copy() argument
1287 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata_after_copy()
1295 mg_update_metadata(ws); in mg_update_metadata_after_copy()
1298 static void mg_upgrade_lock(struct work_struct *ws) in mg_upgrade_lock() argument
1301 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_upgrade_lock()
1322 mg_update_metadata(ws); in mg_upgrade_lock()
1326 static void mg_full_copy(struct work_struct *ws) in mg_full_copy() argument
1328 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_full_copy()
1335 mg_upgrade_lock(ws); in mg_full_copy()
1343 static void mg_copy(struct work_struct *ws) in mg_copy() argument
1345 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_copy()
1361 mg_full_copy(ws); in mg_copy()
1375 mg_full_copy(ws); in mg_copy()
1406 mg_copy(&mg->k.ws); in mg_lock_writes()
1455 static void invalidate_completed(struct work_struct *ws) in invalidate_completed() argument
1457 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_completed()
1484 static void invalidate_remove(struct work_struct *ws) in invalidate_remove() argument
1487 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_remove()
1533 queue_work(cache->wq, &mg->k.ws); in invalidate_lock()
1784 static void process_deferred_bios(struct work_struct *ws) in process_deferred_bios() argument
1786 struct cache *cache = container_of(ws, struct cache, deferred_bio_worker); in process_deferred_bios()
1837 static void do_waker(struct work_struct *ws) in do_waker() argument
1839 struct cache *cache = container_of(to_delayed_work(ws), struct cache, waker); in do_waker()
1847 static void check_migrations(struct work_struct *ws) in check_migrations() argument
1851 struct cache *cache = container_of(ws, struct cache, migration_worker); in check_migrations()