Lines Matching refs:ws

50 	struct work_struct ws;  member
57 INIT_WORK(&k->ws, fn); in init_continuation()
64 queue_work(wq, &k->ws); in queue_continuation()
105 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()
1080 dm_cell_quiesce_v2(mg->cache->prison, mg->cell, &mg->k.ws); in quiesce()
1083 static struct dm_cache_migration *ws_to_mg(struct work_struct *ws) in ws_to_mg() argument
1085 struct continuation *k = container_of(ws, struct continuation, ws); in ws_to_mg()
1235 static void mg_success(struct work_struct *ws) in mg_success() argument
1237 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_success()
1242 static void mg_update_metadata(struct work_struct *ws) in mg_update_metadata() argument
1245 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata()
1304 static void mg_update_metadata_after_copy(struct work_struct *ws) in mg_update_metadata_after_copy() argument
1306 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_update_metadata_after_copy()
1314 mg_update_metadata(ws); in mg_update_metadata_after_copy()
1317 static void mg_upgrade_lock(struct work_struct *ws) in mg_upgrade_lock() argument
1320 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_upgrade_lock()
1341 mg_update_metadata(ws); in mg_upgrade_lock()
1345 static void mg_full_copy(struct work_struct *ws) in mg_full_copy() argument
1347 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_full_copy()
1354 mg_upgrade_lock(ws); in mg_full_copy()
1362 static void mg_copy(struct work_struct *ws) in mg_copy() argument
1364 struct dm_cache_migration *mg = ws_to_mg(ws); in mg_copy()
1381 mg_full_copy(ws); in mg_copy()
1395 mg_full_copy(ws); in mg_copy()
1426 mg_copy(&mg->k.ws); in mg_lock_writes()
1477 static void invalidate_completed(struct work_struct *ws) in invalidate_completed() argument
1479 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_completed()
1509 static void invalidate_remove(struct work_struct *ws) in invalidate_remove() argument
1512 struct dm_cache_migration *mg = ws_to_mg(ws); in invalidate_remove()
1558 queue_work(cache->wq, &mg->k.ws); in invalidate_lock()
1813 static void process_deferred_bios(struct work_struct *ws) in process_deferred_bios() argument
1815 struct cache *cache = container_of(ws, struct cache, deferred_bio_worker); in process_deferred_bios()
1867 static void do_waker(struct work_struct *ws) in do_waker() argument
1869 struct cache *cache = container_of(to_delayed_work(ws), struct cache, waker); in do_waker()
1877 static void check_migrations(struct work_struct *ws) in check_migrations() argument
1881 struct cache *cache = container_of(ws, struct cache, migration_worker); in check_migrations()