Lines Matching full:probe
19 * Start the probe polling timer. We have to supply it with an inc on the
43 bool responded = server->probe.responded; in afs_finished_fs_probe()
59 * Handle the completion of a probe.
72 * Handle inability to send a probe due to ENOMEM when trying to allocate a
87 server->probe.local_failure = true; in afs_fs_probe_not_done()
88 if (server->probe.error == 0) in afs_fs_probe_not_done()
89 server->probe.error = -ENOMEM; in afs_fs_probe_not_done()
115 server->probe.error = 0; in afs_fileserver_probe_result()
118 if (!server->probe.responded) { in afs_fileserver_probe_result()
119 server->probe.abort_code = call->abort_code; in afs_fileserver_probe_result()
120 server->probe.error = ret; in afs_fileserver_probe_result()
126 server->probe.local_failure = true; in afs_fileserver_probe_result()
141 if (!server->probe.responded && in afs_fileserver_probe_result()
142 (server->probe.error == 0 || in afs_fileserver_probe_result()
143 server->probe.error == -ETIMEDOUT || in afs_fileserver_probe_result()
144 server->probe.error == -ETIME)) in afs_fileserver_probe_result()
145 server->probe.error = ret; in afs_fileserver_probe_result()
154 server->probe.is_yfs = true; in afs_fileserver_probe_result()
158 server->probe.not_yfs = true; in afs_fileserver_probe_result()
159 if (!server->probe.is_yfs) { in afs_fileserver_probe_result()
171 if (rtt_us < server->probe.rtt) { in afs_fileserver_probe_result()
172 server->probe.rtt = rtt_us; in afs_fileserver_probe_result()
178 server->probe.responded = true; in afs_fileserver_probe_result()
184 _debug("probe %pU [%u] %pISpc rtt=%u ret=%d", in afs_fileserver_probe_result()
192 * Probe one or all of a fileserver's addresses to find out the best route and
212 memset(&server->probe, 0, sizeof(server->probe)); in afs_fs_probe_fileserver()
213 server->probe.rtt = UINT_MAX; in afs_fs_probe_fileserver()
244 /* Only wait for servers that have a probe outstanding. */ in afs_wait_for_fs_probes()
250 if (server->probe.responded) in afs_wait_for_fs_probes()
276 if (server->probe.responded) in afs_wait_for_fs_probes()
316 * Probe timer. We have an increment on fs_outstanding that we need to pass
328 * Dispatch a probe to a server.
336 * one of the queues on the completion of the probe. in afs_dispatch_fs_probe()
348 * Probe a server immediately without waiting for its due time to come
360 * Probe dispatcher to regularly dispatch probes to keep NAT alive.
412 _debug("probe %pU", &server->uuid); in afs_fs_probe_dispatcher()
437 * Wait for a probe on a particular fileserver to complete for 2s.
452 server->probe.responded || in afs_wait_for_one_fs_probe()
462 if (server->probe.responded) in afs_wait_for_one_fs_probe()