md/dm-vdo/dedupe.c

102  * timer fires, the hash_zone's completion is enqueued to run in the hash_zone where the zone's
138 #include "completion.h"
291 	struct vdo_completion completion;
314 static inline struct hash_zone *as_hash_zone(struct vdo_completion *completion)
316 	vdo_assert_completion_type(completion, VDO_HASH_ZONE_COMPLETION);
317 	return container_of(completion, struct hash_zone, completion);
320 static inline struct hash_zones *as_hash_zones(struct vdo_completion *completion)
322 	vdo_assert_completion_type(completion, VDO_HASH_ZONES_COMPLETION);
323 	return container_of(completion, struct hash_zones, completion);
489 static void unlock_duplicate_pbn(struct vdo_completion *completion);
503 	data_vio->vio.completion.callback = complete_data_vio;
630  * @completion: The completion of the data_vio acting as the lock's agent.
634 static void finish_unlocking(struct vdo_completion *completion)
636 	struct data_vio *agent = as_data_vio(completion);
685  * @completion: The completion of the data_vio acting as the lock's agent.
690 static void unlock_duplicate_pbn(struct vdo_completion *completion)
692 	struct data_vio *agent = as_data_vio(completion);
702 		complete_data_vio(completion);
742  * @completion: The completion of the data_vio that performed the update
746 static void finish_updating(struct vdo_completion *completion)
748 	struct data_vio *agent = as_data_vio(completion);
1073  * @completion: The completion of the data_vio used to verify dedupe
1077 static void finish_verifying(struct vdo_completion *completion)
1079 	struct data_vio *agent = as_data_vio(completion);
1138 static void verify_callback(struct vdo_completion *completion)
1140 	struct data_vio *agent = as_data_vio(completion);
1146 static void uncompress_and_verify(struct vdo_completion *completion)
1148 	struct data_vio *agent = as_data_vio(completion);
1154 		verify_callback(completion);
1216 	vdo_launch_completion_with_priority(&vio->completion, BIO_Q_VERIFY_PRIORITY);
1222  * @completion: The completion of the data_vio that attempted to get the read lock.
1226 static void finish_locking(struct vdo_completion *completion)
1228 	struct data_vio *agent = as_data_vio(completion);
1302  * @completion: The completion of the data_vio attempting to acquire the physical block lock on
1309 static void lock_duplicate_pbn(struct vdo_completion *completion)
1315 	struct data_vio *agent = as_data_vio(completion);
1662  * @completion: The completion of the data_vio that performed the query.
1666 static void finish_querying(struct vdo_completion *completion)
1668 	struct data_vio *agent = as_data_vio(completion);
1741 void vdo_continue_hash_lock(struct vdo_completion *completion)
1743 	struct data_vio *data_vio = as_data_vio(completion);
1838 void vdo_acquire_hash_lock(struct vdo_completion *completion)
1840 	struct data_vio *data_vio = as_data_vio(completion);
2116 static void change_dedupe_state(struct vdo_completion *completion)
2118 	struct hash_zones *zones = as_hash_zones(completion);
2214 	vdo_initialize_completion(&zones->completion, vdo, VDO_HASH_ZONES_COMPLETION);
2215 	vdo_set_completion_callback(&zones->completion, change_dedupe_state,
2294 static void timeout_index_operations_callback(struct vdo_completion *completion)
2297 	struct hash_zone *zone = as_hash_zone(completion);
2334 		report_dedupe_timeouts(completion->vdo->hash_zones, timed_out);
2345 		vdo_launch_completion(&zone->completion);
2362 	vdo_initialize_completion(&zone->completion, vdo, VDO_HASH_ZONE_COMPLETION);
2363 	vdo_set_completion_callback(&zone->completion, timeout_index_operations_callback,
2516 static void suspend_index(void *context, struct vdo_completion *completion)
2521 			   vdo_get_current_manager_operation(zones->manager), completion,
2567 		vdo_launch_completion(&zones->completion);