Orange Pi5 kernel

^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   2) /* Handle vlserver selection and rotation.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   3)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   4)  * Copyright (C) 2018 Red Hat, Inc. All Rights Reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   5)  * Written by David Howells (dhowells@redhat.com)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   6)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   7) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   8) #include <linux/kernel.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   9) #include <linux/sched.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  10) #include <linux/sched/signal.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  11) #include "internal.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  12) #include "afs_vl.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  13) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  14) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  15)  * Begin an operation on a volume location server.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  16)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  17) bool afs_begin_vlserver_operation(struct afs_vl_cursor *vc, struct afs_cell *cell,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  18) 				  struct key *key)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  19) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  20) 	memset(vc, 0, sizeof(*vc));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  21) 	vc->cell = cell;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  22) 	vc->key = key;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  23) 	vc->error = -EDESTADDRREQ;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  24) 	vc->ac.error = SHRT_MAX;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  25) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  26) 	if (signal_pending(current)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  27) 		vc->error = -EINTR;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  28) 		vc->flags |= AFS_VL_CURSOR_STOP;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  29) 		return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  30) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  31) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  32) 	return true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  33) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  34) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  35) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  36)  * Begin iteration through a server list, starting with the last used server if
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  37)  * possible, or the last recorded good server if not.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  38)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  39) static bool afs_start_vl_iteration(struct afs_vl_cursor *vc)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  40) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  41) 	struct afs_cell *cell = vc->cell;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  42) 	unsigned int dns_lookup_count;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  43) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  44) 	if (cell->dns_source == DNS_RECORD_UNAVAILABLE ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  45) 	    cell->dns_expiry <= ktime_get_real_seconds()) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  46) 		dns_lookup_count = smp_load_acquire(&cell->dns_lookup_count);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  47) 		set_bit(AFS_CELL_FL_DO_LOOKUP, &cell->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  48) 		afs_queue_cell(cell, afs_cell_trace_get_queue_dns);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  49) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  50) 		if (cell->dns_source == DNS_RECORD_UNAVAILABLE) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  51) 			if (wait_var_event_interruptible(
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  52) 				    &cell->dns_lookup_count,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  53) 				    smp_load_acquire(&cell->dns_lookup_count)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  54) 				    != dns_lookup_count) < 0) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  55) 				vc->error = -ERESTARTSYS;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  56) 				return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  57) 			}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  58) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  59) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  60) 		/* Status load is ordered after lookup counter load */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  61) 		if (cell->dns_source == DNS_RECORD_UNAVAILABLE) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  62) 			vc->error = -EDESTADDRREQ;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  63) 			return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  64) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  65) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  66) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  67) 	read_lock(&cell->vl_servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  68) 	vc->server_list = afs_get_vlserverlist(
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  69) 		rcu_dereference_protected(cell->vl_servers,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  70) 					  lockdep_is_held(&cell->vl_servers_lock)));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  71) 	read_unlock(&cell->vl_servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  72) 	if (!vc->server_list->nr_servers)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  73) 		return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  74) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  75) 	vc->untried = (1UL << vc->server_list->nr_servers) - 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  76) 	vc->index = -1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  77) 	return true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  78) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  79) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  80) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  81)  * Select the vlserver to use.  May be called multiple times to rotate
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  82)  * through the vlservers.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  83)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  84) bool afs_select_vlserver(struct afs_vl_cursor *vc)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  85) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  86) 	struct afs_addr_list *alist;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  87) 	struct afs_vlserver *vlserver;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  88) 	struct afs_error e;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  89) 	u32 rtt;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  90) 	int error = vc->ac.error, i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  91) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  92) 	_enter("%lx[%d],%lx[%d],%d,%d",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  93) 	       vc->untried, vc->index,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  94) 	       vc->ac.tried, vc->ac.index,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  95) 	       error, vc->ac.abort_code);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  96) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  97) 	if (vc->flags & AFS_VL_CURSOR_STOP) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  98) 		_leave(" = f [stopped]");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  99) 		return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) 	vc->nr_iterations++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) 	/* Evaluate the result of the previous operation, if there was one. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) 	switch (error) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) 	case SHRT_MAX:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) 		goto start;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) 	default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) 	case 0:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) 		/* Success or local failure.  Stop. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) 		vc->error = error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) 		vc->flags |= AFS_VL_CURSOR_STOP;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) 		_leave(" = f [okay/local %d]", vc->ac.error);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) 		return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) 	case -ECONNABORTED:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) 		/* The far side rejected the operation on some grounds.  This
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) 		 * might involve the server being busy or the volume having been moved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) 		 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) 		switch (vc->ac.abort_code) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) 		case AFSVL_IO:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) 		case AFSVL_BADVOLOPER:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) 		case AFSVL_NOMEM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) 			/* The server went weird. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) 			vc->error = -EREMOTEIO;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) 			//write_lock(&vc->cell->vl_servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) 			//vc->server_list->weird_mask |= 1 << vc->index;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) 			//write_unlock(&vc->cell->vl_servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) 			goto next_server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) 		default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) 			vc->error = afs_abort_to_error(vc->ac.abort_code);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) 			goto failed;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) 	case -ERFKILL:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) 	case -EADDRNOTAVAIL:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) 	case -ENETUNREACH:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) 	case -EHOSTUNREACH:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) 	case -EHOSTDOWN:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) 	case -ECONNREFUSED:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) 	case -ETIMEDOUT:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) 	case -ETIME:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) 		_debug("no conn %d", error);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) 		vc->error = error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) 		goto iterate_address;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) 	case -ECONNRESET:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) 		_debug("call reset");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) 		vc->error = error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) 		vc->flags |= AFS_VL_CURSOR_RETRY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) 		goto next_server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) 	case -EOPNOTSUPP:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) 		_debug("notsupp");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) 		goto next_server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) restart_from_beginning:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) 	_debug("restart");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) 	afs_end_cursor(&vc->ac);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) 	afs_put_vlserverlist(vc->cell->net, vc->server_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) 	vc->server_list = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) 	if (vc->flags & AFS_VL_CURSOR_RETRIED)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) 		goto failed;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) 	vc->flags |= AFS_VL_CURSOR_RETRIED;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) start:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) 	_debug("start");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) 	if (!afs_start_vl_iteration(vc))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) 		goto failed;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) 	error = afs_send_vl_probes(vc->cell->net, vc->key, vc->server_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) 	if (error < 0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176) 		goto failed_set_error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178) pick_server:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179) 	_debug("pick [%lx]", vc->untried);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) 	error = afs_wait_for_vl_probes(vc->server_list, vc->untried);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) 	if (error < 0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) 		goto failed_set_error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) 	/* Pick the untried server with the lowest RTT. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) 	vc->index = vc->server_list->preferred;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) 	if (test_bit(vc->index, &vc->untried))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) 		goto selected_server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) 	vc->index = -1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) 	rtt = U32_MAX;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) 	for (i = 0; i < vc->server_list->nr_servers; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) 		struct afs_vlserver *s = vc->server_list->servers[i].server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) 		if (!test_bit(i, &vc->untried) ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) 		    !test_bit(AFS_VLSERVER_FL_RESPONDING, &s->flags))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) 			continue;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) 		if (s->probe.rtt < rtt) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) 			vc->index = i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) 			rtt = s->probe.rtt;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) 	if (vc->index == -1)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) 		goto no_more_servers;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) selected_server:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) 	_debug("use %d", vc->index);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) 	__clear_bit(vc->index, &vc->untried);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211) 	/* We're starting on a different vlserver from the list.  We need to
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) 	 * check it, find its address list and probe its capabilities before we
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) 	 * use it.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) 	ASSERTCMP(vc->ac.alist, ==, NULL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) 	vlserver = vc->server_list->servers[vc->index].server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) 	vc->server = vlserver;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) 	_debug("USING VLSERVER: %s", vlserver->name);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) 	read_lock(&vlserver->lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) 	alist = rcu_dereference_protected(vlserver->addresses,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) 					  lockdep_is_held(&vlserver->lock));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) 	afs_get_addrlist(alist);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) 	read_unlock(&vlserver->lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) 	memset(&vc->ac, 0, sizeof(vc->ac));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) 	if (!vc->ac.alist)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) 		vc->ac.alist = alist;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) 	else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) 		afs_put_addrlist(alist);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) 	vc->ac.index = -1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) iterate_address:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) 	ASSERT(vc->ac.alist);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) 	/* Iterate over the current server's address list to try and find an
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) 	 * address on which it will respond to us.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) 	if (!afs_iterate_addresses(&vc->ac))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) 		goto next_server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) 	_debug("VL address %d/%d", vc->ac.index, vc->ac.alist->nr_addrs);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) 	_leave(" = t %pISpc", &vc->ac.alist->addrs[vc->ac.index].transport);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) 	return true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) next_server:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) 	_debug("next");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) 	afs_end_cursor(&vc->ac);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) 	goto pick_server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) no_more_servers:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255) 	/* That's all the servers poked to no good effect.  Try again if some
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) 	 * of them were busy.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) 	if (vc->flags & AFS_VL_CURSOR_RETRY)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) 		goto restart_from_beginning;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) 	e.error = -EDESTADDRREQ;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) 	e.responded = false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) 	for (i = 0; i < vc->server_list->nr_servers; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) 		struct afs_vlserver *s = vc->server_list->servers[i].server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) 		if (test_bit(AFS_VLSERVER_FL_RESPONDING, &s->flags))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) 			e.responded = true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268) 		afs_prioritise_error(&e, READ_ONCE(s->probe.error),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) 				     s->probe.abort_code);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272) 	error = e.error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) failed_set_error:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275) 	vc->error = error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276) failed:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) 	vc->flags |= AFS_VL_CURSOR_STOP;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278) 	afs_end_cursor(&vc->ac);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) 	_leave(" = f [failed %d]", vc->error);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) 	return false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284)  * Dump cursor state in the case of the error being EDESTADDRREQ.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286) static void afs_vl_dump_edestaddrreq(const struct afs_vl_cursor *vc)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288) 	static int count;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289) 	int i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) 	if (!IS_ENABLED(CONFIG_AFS_DEBUG_CURSOR) || count > 3)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) 		return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) 	count++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) 	rcu_read_lock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296) 	pr_notice("EDESTADDR occurred\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) 	pr_notice("VC: ut=%lx ix=%u ni=%hu fl=%hx err=%hd\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298) 		  vc->untried, vc->index, vc->nr_iterations, vc->flags, vc->error);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 299) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 300) 	if (vc->server_list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 301) 		const struct afs_vlserver_list *sl = vc->server_list;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 302) 		pr_notice("VC: SL nr=%u ix=%u\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 303) 			  sl->nr_servers, sl->index);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 304) 		for (i = 0; i < sl->nr_servers; i++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 305) 			const struct afs_vlserver *s = sl->servers[i].server;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 306) 			pr_notice("VC: server %s+%hu fl=%lx E=%hd\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 307) 				  s->name, s->port, s->flags, s->probe.error);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 308) 			if (s->addresses) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 309) 				const struct afs_addr_list *a =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 310) 					rcu_dereference(s->addresses);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 311) 				pr_notice("VC:  - nr=%u/%u/%u pf=%u\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 312) 					  a->nr_ipv4, a->nr_addrs, a->max_addrs,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 313) 					  a->preferred);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 314) 				pr_notice("VC:  - R=%lx F=%lx\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 315) 					  a->responded, a->failed);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 316) 				if (a == vc->ac.alist)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 317) 					pr_notice("VC:  - current\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 318) 			}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 319) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 320) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 321) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 322) 	pr_notice("AC: t=%lx ax=%u ac=%d er=%d r=%u ni=%u\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 323) 		  vc->ac.tried, vc->ac.index, vc->ac.abort_code, vc->ac.error,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 324) 		  vc->ac.responded, vc->ac.nr_iterations);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 325) 	rcu_read_unlock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 326) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 327) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 328) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 329)  * Tidy up a volume location server cursor and unlock the vnode.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 330)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 331) int afs_end_vlserver_operation(struct afs_vl_cursor *vc)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 332) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 333) 	struct afs_net *net = vc->cell->net;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 334) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 335) 	if (vc->error == -EDESTADDRREQ ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 336) 	    vc->error == -EADDRNOTAVAIL ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 337) 	    vc->error == -ENETUNREACH ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 338) 	    vc->error == -EHOSTUNREACH)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 339) 		afs_vl_dump_edestaddrreq(vc);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 340) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 341) 	afs_end_cursor(&vc->ac);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 342) 	afs_put_vlserverlist(net, vc->server_list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 343) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 344) 	if (vc->error == -ECONNABORTED)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 345) 		vc->error = afs_abort_to_error(vc->ac.abort_code);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 346) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 347) 	return vc->error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 348) }