Lines Matching +full:keep +full:- +full:a +full:- +full:live
1 // SPDX-License-Identifier: GPL-2.0-or-later
24 __refcount_inc(&estate->ref, &r); in afs_get_endpoint_state()
25 trace_afs_estate(estate->server_id, estate->probe_seq, r, where); in afs_get_endpoint_state()
34 trace_afs_estate(estate->server_id, estate->probe_seq, refcount_read(&estate->ref), in afs_endpoint_state_rcu()
36 afs_put_addrlist(estate->addresses, afs_alist_trace_put_estate); in afs_endpoint_state_rcu()
43 unsigned int server_id = estate->server_id, probe_seq = estate->probe_seq; in afs_put_endpoint_state()
47 dead = __refcount_dec_and_test(&estate->ref, &r); in afs_put_endpoint_state()
50 call_rcu(&estate->rcu, afs_endpoint_state_rcu); in afs_put_endpoint_state()
63 if (!net->live) in afs_schedule_fs_probe()
66 atj = server->probed_at; in afs_schedule_fs_probe()
70 if (timer_reduce(&net->fs_probe_timer, atj)) in afs_schedule_fs_probe()
75 * Handle the completion of a set of probes.
80 bool responded = test_bit(AFS_ESTATE_RESPONDED, &estate->flags); in afs_finished_fs_probe()
82 write_seqlock(&net->fs_lock); in afs_finished_fs_probe()
84 list_add_tail(&server->probe_link, &net->fs_probe_slow); in afs_finished_fs_probe()
86 server->rtt = UINT_MAX; in afs_finished_fs_probe()
87 clear_bit(AFS_SERVER_FL_RESPONDING, &server->flags); in afs_finished_fs_probe()
88 list_add_tail(&server->probe_link, &net->fs_probe_fast); in afs_finished_fs_probe()
91 write_sequnlock(&net->fs_lock); in afs_finished_fs_probe()
97 * Handle the completion of a probe.
104 if (atomic_dec_and_test(&estate->nr_probing)) in afs_done_one_fs_probe()
107 wake_up_all(&server->probe_wq); in afs_done_one_fs_probe()
111 * Handle inability to send a probe due to ENOMEM when trying to allocate a
121 trace_afs_io_error(0, -ENOMEM, afs_io_error_fs_probe_fail); in afs_fs_probe_not_done()
122 spin_lock(&server->probe_lock); in afs_fs_probe_not_done()
124 set_bit(AFS_ESTATE_LOCAL_FAILURE, &estate->flags); in afs_fs_probe_not_done()
125 if (estate->error == 0) in afs_fs_probe_not_done()
126 estate->error = -ENOMEM; in afs_fs_probe_not_done()
128 set_bit(index, &estate->failed_set); in afs_fs_probe_not_done()
130 spin_unlock(&server->probe_lock); in afs_fs_probe_not_done()
135 * Process the result of probing a fileserver. This is called after successful
140 struct afs_endpoint_state *estate = call->probe; in afs_fileserver_probe_result()
141 struct afs_addr_list *alist = estate->addresses; in afs_fileserver_probe_result()
142 struct afs_address *addr = &alist->addrs[call->probe_index]; in afs_fileserver_probe_result()
143 struct afs_server *server = call->server; in afs_fileserver_probe_result()
144 unsigned int index = call->probe_index; in afs_fileserver_probe_result()
145 unsigned int rtt_us = -1, cap0; in afs_fileserver_probe_result()
146 int ret = call->error; in afs_fileserver_probe_result()
148 _enter("%pU,%u", &server->uuid, index); in afs_fileserver_probe_result()
150 WRITE_ONCE(addr->last_error, ret); in afs_fileserver_probe_result()
152 spin_lock(&server->probe_lock); in afs_fileserver_probe_result()
156 estate->error = 0; in afs_fileserver_probe_result()
158 case -ECONNABORTED: in afs_fileserver_probe_result()
159 if (!test_bit(AFS_ESTATE_RESPONDED, &estate->flags)) { in afs_fileserver_probe_result()
160 estate->abort_code = call->abort_code; in afs_fileserver_probe_result()
161 estate->error = ret; in afs_fileserver_probe_result()
164 case -ENOMEM: in afs_fileserver_probe_result()
165 case -ENONET: in afs_fileserver_probe_result()
166 clear_bit(index, &estate->responsive_set); in afs_fileserver_probe_result()
167 set_bit(AFS_ESTATE_LOCAL_FAILURE, &estate->flags); in afs_fileserver_probe_result()
168 trace_afs_io_error(call->debug_id, ret, afs_io_error_fs_probe_fail); in afs_fileserver_probe_result()
170 case -ECONNRESET: /* Responded, but call expired. */ in afs_fileserver_probe_result()
171 case -ERFKILL: in afs_fileserver_probe_result()
172 case -EADDRNOTAVAIL: in afs_fileserver_probe_result()
173 case -ENETUNREACH: in afs_fileserver_probe_result()
174 case -EHOSTUNREACH: in afs_fileserver_probe_result()
175 case -EHOSTDOWN: in afs_fileserver_probe_result()
176 case -ECONNREFUSED: in afs_fileserver_probe_result()
177 case -ETIMEDOUT: in afs_fileserver_probe_result()
178 case -ETIME: in afs_fileserver_probe_result()
180 clear_bit(index, &estate->responsive_set); in afs_fileserver_probe_result()
181 set_bit(index, &estate->failed_set); in afs_fileserver_probe_result()
182 if (!test_bit(AFS_ESTATE_RESPONDED, &estate->flags) && in afs_fileserver_probe_result()
183 (estate->error == 0 || in afs_fileserver_probe_result()
184 estate->error == -ETIMEDOUT || in afs_fileserver_probe_result()
185 estate->error == -ETIME)) in afs_fileserver_probe_result()
186 estate->error = ret; in afs_fileserver_probe_result()
187 trace_afs_io_error(call->debug_id, ret, afs_io_error_fs_probe_fail); in afs_fileserver_probe_result()
192 clear_bit(index, &estate->failed_set); in afs_fileserver_probe_result()
194 if (call->service_id == YFS_FS_SERVICE) { in afs_fileserver_probe_result()
195 set_bit(AFS_ESTATE_IS_YFS, &estate->flags); in afs_fileserver_probe_result()
196 set_bit(AFS_SERVER_FL_IS_YFS, &server->flags); in afs_fileserver_probe_result()
197 server->service_id = call->service_id; in afs_fileserver_probe_result()
199 set_bit(AFS_ESTATE_NOT_YFS, &estate->flags); in afs_fileserver_probe_result()
200 if (!test_bit(AFS_ESTATE_IS_YFS, &estate->flags)) { in afs_fileserver_probe_result()
201 clear_bit(AFS_SERVER_FL_IS_YFS, &server->flags); in afs_fileserver_probe_result()
202 server->service_id = call->service_id; in afs_fileserver_probe_result()
204 cap0 = ntohl(call->tmp); in afs_fileserver_probe_result()
206 set_bit(AFS_SERVER_FL_HAS_FS64, &server->flags); in afs_fileserver_probe_result()
208 clear_bit(AFS_SERVER_FL_HAS_FS64, &server->flags); in afs_fileserver_probe_result()
211 rtt_us = rxrpc_kernel_get_srtt(addr->peer); in afs_fileserver_probe_result()
212 if (rtt_us < estate->rtt) { in afs_fileserver_probe_result()
213 estate->rtt = rtt_us; in afs_fileserver_probe_result()
214 server->rtt = rtt_us; in afs_fileserver_probe_result()
215 alist->preferred = index; in afs_fileserver_probe_result()
219 set_bit(AFS_ESTATE_RESPONDED, &estate->flags); in afs_fileserver_probe_result()
220 set_bit(index, &estate->responsive_set); in afs_fileserver_probe_result()
221 set_bit(AFS_SERVER_FL_RESPONDING, &server->flags); in afs_fileserver_probe_result()
223 spin_unlock(&server->probe_lock); in afs_fileserver_probe_result()
225 trace_afs_fs_probe(server, false, estate, index, call->error, call->abort_code, rtt_us); in afs_fileserver_probe_result()
227 estate->probe_seq, &server->uuid, index, in afs_fileserver_probe_result()
228 rxrpc_kernel_remote_addr(alist->addrs[index].peer), in afs_fileserver_probe_result()
231 return afs_done_one_fs_probe(call->net, server, estate); in afs_fileserver_probe_result()
235 * Probe all of a fileserver's addresses to find out the best route and to
245 _enter("%pU", &server->uuid); in afs_fs_probe_fileserver()
251 refcount_set(&estate->ref, 1); in afs_fs_probe_fileserver()
252 estate->server_id = server->debug_id; in afs_fs_probe_fileserver()
253 estate->rtt = UINT_MAX; in afs_fs_probe_fileserver()
255 write_lock(&server->fs_lock); in afs_fs_probe_fileserver()
257 old = rcu_dereference_protected(server->endpoint_state, in afs_fs_probe_fileserver()
258 lockdep_is_held(&server->fs_lock)); in afs_fs_probe_fileserver()
259 estate->responsive_set = old->responsive_set; in afs_fs_probe_fileserver()
260 estate->addresses = afs_get_addrlist(new_alist ?: old->addresses, in afs_fs_probe_fileserver()
262 alist = estate->addresses; in afs_fs_probe_fileserver()
263 estate->probe_seq = ++server->probe_counter; in afs_fs_probe_fileserver()
264 atomic_set(&estate->nr_probing, alist->nr_addrs); in afs_fs_probe_fileserver()
266 rcu_assign_pointer(server->endpoint_state, estate); in afs_fs_probe_fileserver()
267 set_bit(AFS_ESTATE_SUPERSEDED, &old->flags); in afs_fs_probe_fileserver()
268 write_unlock(&server->fs_lock); in afs_fs_probe_fileserver()
270 trace_afs_estate(estate->server_id, estate->probe_seq, refcount_read(&estate->ref), in afs_fs_probe_fileserver()
275 server->probed_at = jiffies; in afs_fs_probe_fileserver()
276 unprobed = (1UL << alist->nr_addrs) - 1; in afs_fs_probe_fileserver()
279 int best_prio = -1; in afs_fs_probe_fileserver()
281 for (i = 0; i < alist->nr_addrs; i++) { in afs_fs_probe_fileserver()
283 alist->addrs[i].prio > best_prio) { in afs_fs_probe_fileserver()
285 best_prio = alist->addrs[i].prio; in afs_fs_probe_fileserver()
299 * Wait for the first as-yet untried fileserver to respond, for the probe state
305 struct afs_server_list *slist = op->server_list; in afs_wait_for_fs_probes()
309 _enter("%u", slist->nr_servers); in afs_wait_for_fs_probes()
311 for (i = 0; i < slist->nr_servers; i++) { in afs_wait_for_fs_probes()
313 if (test_bit(AFS_ESTATE_SUPERSEDED, &estate->flags)) in afs_wait_for_fs_probes()
315 if (atomic_read(&estate->nr_probing)) in afs_wait_for_fs_probes()
317 if (estate->responsive_set & states[i].untried_addrs) in afs_wait_for_fs_probes()
323 for (i = 0; i < slist->nr_servers; i++) in afs_wait_for_fs_probes()
324 add_wait_queue(&slist->servers[i].server->probe_wq, &states[i].probe_waiter); in afs_wait_for_fs_probes()
330 for (i = 0; i < slist->nr_servers; i++) { in afs_wait_for_fs_probes()
332 if (test_bit(AFS_ESTATE_SUPERSEDED, &estate->flags)) { in afs_wait_for_fs_probes()
336 if (atomic_read(&estate->nr_probing)) in afs_wait_for_fs_probes()
338 if (estate->responsive_set & states[i].untried_addrs) { in afs_wait_for_fs_probes()
352 for (i = 0; i < slist->nr_servers; i++) in afs_wait_for_fs_probes()
353 remove_wait_queue(&slist->servers[i].server->probe_wq, &states[i].probe_waiter); in afs_wait_for_fs_probes()
356 ret = -ERESTARTSYS; in afs_wait_for_fs_probes()
368 if (!net->live || !queue_work(afs_wq, &net->fs_prober)) in afs_fs_probe_timer()
373 * Dispatch a probe to a server.
376 __releases(&net->fs_lock) in afs_dispatch_fs_probe()
380 /* We remove it from the queues here - it will be added back to in afs_dispatch_fs_probe()
383 list_del_init(&server->probe_link); in afs_dispatch_fs_probe()
386 write_sequnlock(&net->fs_lock); in afs_dispatch_fs_probe()
393 * Probe a server immediately without waiting for its due time to come
398 write_seqlock(&net->fs_lock); in afs_probe_fileserver()
399 if (!list_empty(&server->probe_link)) in afs_probe_fileserver()
401 write_sequnlock(&net->fs_lock); in afs_probe_fileserver()
405 * Probe dispatcher to regularly dispatch probes to keep NAT alive.
414 if (!net->live) { in afs_fs_probe_dispatcher()
421 if (list_empty(&net->fs_probe_fast) && list_empty(&net->fs_probe_slow)) { in afs_fs_probe_dispatcher()
428 write_seqlock(&net->fs_lock); in afs_fs_probe_dispatcher()
434 if (!list_empty(&net->fs_probe_fast)) { in afs_fs_probe_dispatcher()
435 fast = list_first_entry(&net->fs_probe_fast, struct afs_server, probe_link); in afs_fs_probe_dispatcher()
436 poll_at = fast->probed_at + afs_fs_probe_fast_poll_interval; in afs_fs_probe_dispatcher()
444 if (!list_empty(&net->fs_probe_slow)) { in afs_fs_probe_dispatcher()
445 slow = list_first_entry(&net->fs_probe_slow, struct afs_server, probe_link); in afs_fs_probe_dispatcher()
446 poll_at = slow->probed_at + afs_fs_probe_slow_poll_interval; in afs_fs_probe_dispatcher()
457 _debug("probe %pU", &server->uuid); in afs_fs_probe_dispatcher()
465 write_sequnlock(&net->fs_lock); in afs_fs_probe_dispatcher()
468 if (!queue_work(afs_wq, &net->fs_prober)) in afs_fs_probe_dispatcher()
472 if (timer_reduce(&net->fs_probe_timer, timer_at)) in afs_fs_probe_dispatcher()
482 * Wait for a probe on a particular fileserver to complete for 2s.
490 if (atomic_read(&estate->nr_probing) == 0) in afs_wait_for_one_fs_probe()
495 prepare_to_wait_event(&server->probe_wq, &wait, in afs_wait_for_one_fs_probe()
498 test_bit(AFS_ESTATE_SUPERSEDED, &estate->flags) || in afs_wait_for_one_fs_probe()
499 (estate->responsive_set & ~exclude) || in afs_wait_for_one_fs_probe()
500 atomic_read(&estate->nr_probing) == 0 || in afs_wait_for_one_fs_probe()
506 finish_wait(&server->probe_wq, &wait); in afs_wait_for_one_fs_probe()
509 if (test_bit(AFS_ESTATE_SUPERSEDED, &estate->flags)) in afs_wait_for_one_fs_probe()
511 if (estate->responsive_set & ~exclude) in afs_wait_for_one_fs_probe()
514 return -ERESTARTSYS; in afs_wait_for_one_fs_probe()
516 return -ETIME; in afs_wait_for_one_fs_probe()
517 return -EDESTADDRREQ; in afs_wait_for_one_fs_probe()
525 if (del_timer_sync(&net->fs_probe_timer)) in afs_fs_probe_cleanup()