md/dm-vdo/dedupe.c

628  * finish_unlocking() - Handle the result of the agent for the lock releasing a read lock on
741  * finish_updating() - Process the result of a UDS update performed by the agent for the lock.
873 	int result;
879 	result = VDO_ASSERT(!list_empty(&zone->lock_pool),
881 	if (result != VDO_SUCCESS)
882 		return result;
893 	result = vdo_int_map_put(zone->hash_lock_map, hash_lock_key(new_lock),
895 	if (result != VDO_SUCCESS) {
897 		return result;
948 	int result;
950 	result = acquire_lock(new_agent->hash_zone, &new_agent->record_name, old_lock,
952 	if (result != VDO_SUCCESS) {
953 		continue_data_vio_with_error(new_agent, result);
1071  * finish_verifying() - Handle the result of the agent for the lock comparing its data to the
1087 	 * Only count the result of the initial verification of the advice as valid or stale, and
1149 	int result;
1151 	result = uncompress_data_vio(agent, agent->duplicate.state,
1153 	if (result == VDO_SUCCESS) {
1165 	int result = blk_status_to_errno(bio->bi_status);
1168 	if (result != VDO_SUCCESS) {
1197 	int result;
1207 	result = vio_reset_bio(vio, buffer, verify_endio, REQ_OP_READ,
1209 	if (result != VDO_SUCCESS) {
1211 		continue_data_vio_with_error(agent, result);
1220  * finish_locking() - Handle the result of the agent for the lock attempting to obtain a PBN read
1285 	int result = vdo_acquire_provisional_reference(slab, agent->duplicate.pbn, lock);
1287 	if (result == VDO_SUCCESS)
1290 	vdo_log_warning_strerror(result,
1295 	continue_data_vio_with_error(agent, result);
1313 	int result;
1338 	result = vdo_attempt_physical_zone_pbn_lock(zone, agent->duplicate.pbn,
1340 	if (result != VDO_SUCCESS) {
1341 		continue_data_vio_with_error(agent, result);
1610 	int result;
1635 	result = vdo_get_physical_zone(vdo, advice->pbn, &advice->zone);
1636 	if ((result != VDO_SUCCESS) || (advice->zone == NULL)) {
1661  * finish_querying() - Process the result of a UDS query performed by the agent for the lock.
1736  * compressing, or deduplicating, so it can share the result with any data_vios waiting in the hash
1812 	int result;
1815 	result = VDO_ASSERT(data_vio->hash_lock == NULL,
1817 	if (result != VDO_SUCCESS)
1818 		return result;
1820 	result = VDO_ASSERT(list_empty(&data_vio->hash_lock_entry),
1822 	if (result != VDO_SUCCESS)
1823 		return result;
1842 	int result;
1846 	result = assert_hash_lock_preconditions(data_vio);
1847 	if (result != VDO_SUCCESS) {
1848 		continue_data_vio_with_error(data_vio, result);
1852 	result = acquire_lock(data_vio->hash_zone, &data_vio->record_name, NULL, &lock);
1853 	if (result != VDO_SUCCESS) {
1854 		continue_data_vio_with_error(data_vio, result);
2044 	int result;
2053 	result = uds_close_index(zones->index_session);
2055 	if (result != UDS_SUCCESS)
2056 		vdo_log_error_strerror(result, "Error closing index");
2059 	zones->error_flag |= result != UDS_SUCCESS;
2067 	int result;
2080 	result = uds_open_index(create_flag ? UDS_CREATE : UDS_LOAD,
2082 	if (result != UDS_SUCCESS)
2083 		vdo_log_error_strerror(result, "Error opening index");
2087 		switch (result) {
2100 	if (result == UDS_SUCCESS) {
2172 	int result;
2202 	result = uds_create_index_session(&zones->index_session);
2203 	if (result != UDS_SUCCESS)
2204 		return result;
2206 	result = vdo_make_thread(vdo, vdo->thread_config.dedupe_thread, &uds_queue_type,
2208 	if (result != VDO_SUCCESS) {
2210 		vdo_log_error("UDS index queue initialization failed (%d)", result);
2211 		return result;
2351 	int result;
2355 	result = vdo_int_map_create(VDO_LOCK_MAP_CAPACITY, &zone->hash_lock_map);
2356 	if (result != VDO_SUCCESS)
2357 		return result;
2366 	result = vdo_allocate(LOCK_POOL_CAPACITY, struct hash_lock, "hash_lock array",
2368 	if (result != VDO_SUCCESS)
2369 		return result;
2376 	result = vdo_make_funnel_queue(&zone->timed_out_complete);
2377 	if (result != VDO_SUCCESS)
2378 		return result;
2412 	int result;
2420 	result = vdo_allocate_extended(struct hash_zones, zone_count, struct hash_zone,
2422 	if (result != VDO_SUCCESS)
2423 		return result;
2425 	result = initialize_index(vdo, zones);
2426 	if (result != VDO_SUCCESS) {
2428 		return result;
2435 		result = initialize_zone(vdo, zones, z);
2436 		if (result != VDO_SUCCESS) {
2438 			return result;
2442 	result = vdo_make_action_manager(zones->zone_count, get_thread_id_for_zone,
2445 	if (result != VDO_SUCCESS) {
2447 		return result;
2501 		int result;
2503 		result = uds_suspend_index_session(zones->index_session, save);
2504 		if (result != UDS_SUCCESS)
2505 			vdo_log_error_strerror(result, "Error suspending dedupe index");
2583 	int result;
2586 	result = uds_resume_index_session(zones->index_session, zones->parameters.bdev);
2587 	if (result != UDS_SUCCESS)
2588 		vdo_log_error_strerror(result, "Error resuming dedupe index");
2657 	int result;
2666 	result = uds_get_index_session_stats(zones->index_session, &index_stats);
2667 	if (result != UDS_SUCCESS) {
2668 		vdo_log_error_strerror(result, "Error reading index stats");
2908 	int result;
2934 	result = uds_launch_request(&context->request);
2935 	if (result != UDS_SUCCESS) {
2936 		context->request.status = result;