Lines Matching full:probe
18 * Start the probe polling timer. We have to supply it with an inc on the
42 bool responded = server->probe.responded; in afs_finished_fs_probe()
58 * Handle the completion of a probe.
71 * Handle inability to send a probe due to ENOMEM when trying to allocate a
86 server->probe.local_failure = true; in afs_fs_probe_not_done()
87 if (server->probe.error == 0) in afs_fs_probe_not_done()
88 server->probe.error = -ENOMEM; in afs_fs_probe_not_done()
114 server->probe.error = 0; in afs_fileserver_probe_result()
117 if (!server->probe.responded) { in afs_fileserver_probe_result()
118 server->probe.abort_code = call->abort_code; in afs_fileserver_probe_result()
119 server->probe.error = ret; in afs_fileserver_probe_result()
125 server->probe.local_failure = true; in afs_fileserver_probe_result()
140 if (!server->probe.responded && in afs_fileserver_probe_result()
141 (server->probe.error == 0 || in afs_fileserver_probe_result()
142 server->probe.error == -ETIMEDOUT || in afs_fileserver_probe_result()
143 server->probe.error == -ETIME)) in afs_fileserver_probe_result()
144 server->probe.error = ret; in afs_fileserver_probe_result()
153 server->probe.is_yfs = true; in afs_fileserver_probe_result()
157 server->probe.not_yfs = true; in afs_fileserver_probe_result()
158 if (!server->probe.is_yfs) { in afs_fileserver_probe_result()
165 rtt_us < server->probe.rtt) { in afs_fileserver_probe_result()
166 server->probe.rtt = rtt_us; in afs_fileserver_probe_result()
172 server->probe.responded = true; in afs_fileserver_probe_result()
178 _debug("probe %pU [%u] %pISpc rtt=%u ret=%d", in afs_fileserver_probe_result()
186 * Probe one or all of a fileserver's addresses to find out the best route and
206 memset(&server->probe, 0, sizeof(server->probe)); in afs_fs_probe_fileserver()
207 server->probe.rtt = UINT_MAX; in afs_fs_probe_fileserver()
238 /* Only wait for servers that have a probe outstanding. */ in afs_wait_for_fs_probes()
244 if (server->probe.responded) in afs_wait_for_fs_probes()
270 if (server->probe.responded) in afs_wait_for_fs_probes()
310 * Probe timer. We have an increment on fs_outstanding that we need to pass
322 * Dispatch a probe to a server.
330 * one of the queues on the completion of the probe. in afs_dispatch_fs_probe()
342 * Probe a server immediately without waiting for its due time to come
354 * Probe dispatcher to regularly dispatch probes to keep NAT alive.
403 _debug("probe %pU", &server->uuid); in afs_fs_probe_dispatcher()
428 * Wait for a probe on a particular fileserver to complete for 2s.
443 server->probe.responded || in afs_wait_for_one_fs_probe()
453 if (server->probe.responded) in afs_wait_for_one_fs_probe()