Lines Matching full:server
2 /* AFS server record management
14 static unsigned afs_server_gc_delay = 10; /* Server record timeout in seconds */
22 * Find a server by one of its addresses.
26 struct afs_server *server = (struct afs_server *)rxrpc_kernel_get_peer_data(peer); in afs_find_server() local
28 if (!server) in afs_find_server()
30 return afs_use_server(server, false, afs_server_trace_use_cm_call); in afs_find_server()
34 * Look up a server by its UUID and mark it active. The caller must hold
39 struct afs_server *server; in afs_find_server_by_uuid() local
47 server = rb_entry(p, struct afs_server, uuid_rb); in afs_find_server_by_uuid()
49 diff = memcmp(uuid, &server->uuid, sizeof(*uuid)); in afs_find_server_by_uuid()
55 if (test_bit(AFS_SERVER_FL_UNCREATED, &server->flags)) in afs_find_server_by_uuid()
57 afs_use_server(server, true, afs_server_trace_use_by_uuid); in afs_find_server_by_uuid()
58 return server; in afs_find_server_by_uuid()
66 * Install a server record in the cell tree. The caller must hold an exclusive
72 struct afs_server *server; in afs_install_server() local
79 /* Firstly install the server in the UUID lookup tree */ in afs_install_server()
85 server = rb_entry(p, struct afs_server, uuid_rb); in afs_install_server()
86 diff = memcmp(&(*candidate)->uuid, &server->uuid, sizeof(uuid_t)); in afs_install_server()
95 server = *candidate; in afs_install_server()
97 rb_link_node(&server->uuid_rb, p, pp); in afs_install_server()
98 rb_insert_color(&server->uuid_rb, &cell->fs_servers); in afs_install_server()
100 hlist_add_head_rcu(&server->proc_link, &net->fs_proc); in afs_install_server()
106 afs_use_server(server, true, afs_server_trace_use_install); in afs_install_server()
107 return server; in afs_install_server()
111 * Allocate a new server record and mark it as active but uncreated.
115 struct afs_server *server; in afs_alloc_server() local
120 server = kzalloc(sizeof(struct afs_server), GFP_KERNEL); in afs_alloc_server()
121 if (!server) in afs_alloc_server()
124 refcount_set(&server->ref, 1); in afs_alloc_server()
125 atomic_set(&server->active, 0); in afs_alloc_server()
126 __set_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_alloc_server()
127 server->debug_id = atomic_inc_return(&afs_server_debug_id); in afs_alloc_server()
128 server->uuid = *uuid; in afs_alloc_server()
129 rwlock_init(&server->fs_lock); in afs_alloc_server()
130 INIT_WORK(&server->destroyer, &afs_server_destroyer); in afs_alloc_server()
131 timer_setup(&server->timer, afs_server_timer, 0); in afs_alloc_server()
132 INIT_LIST_HEAD(&server->volumes); in afs_alloc_server()
133 init_waitqueue_head(&server->probe_wq); in afs_alloc_server()
134 INIT_LIST_HEAD(&server->probe_link); in afs_alloc_server()
135 INIT_HLIST_NODE(&server->proc_link); in afs_alloc_server()
136 spin_lock_init(&server->probe_lock); in afs_alloc_server()
137 server->cell = cell; in afs_alloc_server()
138 server->rtt = UINT_MAX; in afs_alloc_server()
139 server->service_id = FS_SERVICE; in afs_alloc_server()
140 server->probe_counter = 1; in afs_alloc_server()
141 server->probed_at = jiffies - LONG_MAX / 2; in afs_alloc_server()
144 _leave(" = %p", server); in afs_alloc_server()
145 return server; in afs_alloc_server()
149 * Look up an address record for a server
151 static struct afs_addr_list *afs_vl_lookup_addrs(struct afs_server *server, in afs_vl_lookup_addrs() argument
159 if (afs_begin_vlserver_operation(&vc, server->cell, key)) { in afs_vl_lookup_addrs()
161 if (test_bit(AFS_VLSERVER_FL_IS_YFS, &vc.server->flags)) in afs_vl_lookup_addrs()
162 alist = afs_yfsvl_get_endpoints(&vc, &server->uuid); in afs_vl_lookup_addrs()
164 alist = afs_vl_get_addrs_u(&vc, &server->uuid); in afs_vl_lookup_addrs()
181 struct afs_server *server, *candidate = NULL; in afs_lookup_server() local
188 server = afs_find_server_by_uuid(cell, uuid); in afs_lookup_server()
192 if (server) { in afs_lookup_server()
193 timer_delete_sync(&server->timer); in afs_lookup_server()
194 if (test_bit(AFS_SERVER_FL_CREATING, &server->flags)) in afs_lookup_server()
196 if (server->addr_version != addr_version) in afs_lookup_server()
197 set_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_lookup_server()
198 return server; in afs_lookup_server()
208 server = afs_install_server(cell, &candidate); in afs_lookup_server()
209 if (test_bit(AFS_SERVER_FL_CREATING, &server->flags)) { in afs_lookup_server()
214 if (test_bit(AFS_SERVER_FL_UNCREATED, &server->flags)) { in afs_lookup_server()
215 set_bit(AFS_SERVER_FL_CREATING, &server->flags); in afs_lookup_server()
216 clear_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_lookup_server()
220 timer_delete_sync(&server->timer); in afs_lookup_server()
222 /* If we get to create the server, we look up the addresses and then in afs_lookup_server()
228 alist = afs_vl_lookup_addrs(server, key); in afs_lookup_server()
234 ret = afs_fs_probe_fileserver(cell->net, server, alist, key); in afs_lookup_server()
238 clear_and_wake_up_bit(AFS_SERVER_FL_CREATING, &server->flags); in afs_lookup_server()
244 kfree(rcu_access_pointer(server->endpoint_state)); in afs_lookup_server()
248 return server ?: ERR_PTR(ret); in afs_lookup_server()
251 afs_see_server(server, afs_server_trace_wait_create); in afs_lookup_server()
252 wait_on_bit(&server->flags, AFS_SERVER_FL_CREATING, TASK_UNINTERRUPTIBLE); in afs_lookup_server()
253 if (test_bit_acquire(AFS_SERVER_FL_UNCREATED, &server->flags)) { in afs_lookup_server()
255 ret = READ_ONCE(server->create_error); in afs_lookup_server()
256 afs_put_server(cell->net, server, afs_server_trace_unuse_create_fail); in afs_lookup_server()
257 server = NULL; in afs_lookup_server()
267 WRITE_ONCE(server->create_error, ret); in afs_lookup_server()
269 set_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_lookup_server()
271 clear_and_wake_up_bit(AFS_SERVER_FL_CREATING, &server->flags); in afs_lookup_server()
273 if (test_bit(AFS_SERVER_FL_UNCREATED, &server->flags)) { in afs_lookup_server()
274 clear_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_lookup_server()
277 afs_unuse_server(cell->net, server, afs_server_trace_unuse_create_fail); in afs_lookup_server()
278 server = NULL; in afs_lookup_server()
285 * Set/reduce a server's timer.
287 static void afs_set_server_timer(struct afs_server *server, unsigned int delay_secs) in afs_set_server_timer() argument
289 mod_timer(&server->timer, jiffies + delay_secs * HZ); in afs_set_server_timer()
293 * Get a reference on a server object.
295 struct afs_server *afs_get_server(struct afs_server *server, in afs_get_server() argument
301 __refcount_inc(&server->ref, &r); in afs_get_server()
302 a = atomic_read(&server->active); in afs_get_server()
303 trace_afs_server(server->debug_id, r + 1, a, reason); in afs_get_server()
304 return server; in afs_get_server()
308 * Get an active count on a server object and maybe remove from the inactive
311 struct afs_server *afs_use_server(struct afs_server *server, bool activate, in afs_use_server() argument
317 __refcount_inc(&server->ref, &r); in afs_use_server()
318 a = atomic_inc_return(&server->active); in afs_use_server()
320 !test_bit(AFS_SERVER_FL_EXPIRED, &server->flags)) in afs_use_server()
321 timer_delete(&server->timer); in afs_use_server()
323 trace_afs_server(server->debug_id, r + 1, a, reason); in afs_use_server()
324 return server; in afs_use_server()
328 * Release a reference on a server record.
330 void afs_put_server(struct afs_net *net, struct afs_server *server, in afs_put_server() argument
333 unsigned int a, debug_id = server->debug_id; in afs_put_server()
337 if (!server) in afs_put_server()
340 a = atomic_read(&server->active); in afs_put_server()
341 zero = __refcount_dec_and_test(&server->ref, &r); in afs_put_server()
344 __afs_put_server(net, server); in afs_put_server()
348 * Drop an active count on a server object without updating the last-unused
351 void afs_unuse_server_notime(struct afs_net *net, struct afs_server *server, in afs_unuse_server_notime() argument
354 if (!server) in afs_unuse_server_notime()
357 if (atomic_dec_and_test(&server->active)) { in afs_unuse_server_notime()
358 if (test_bit(AFS_SERVER_FL_EXPIRED, &server->flags) || in afs_unuse_server_notime()
359 READ_ONCE(server->cell->state) >= AFS_CELL_REMOVING) in afs_unuse_server_notime()
360 schedule_work(&server->destroyer); in afs_unuse_server_notime()
363 afs_put_server(net, server, reason); in afs_unuse_server_notime()
367 * Drop an active count on a server object.
369 void afs_unuse_server(struct afs_net *net, struct afs_server *server, in afs_unuse_server() argument
372 if (!server) in afs_unuse_server()
375 if (atomic_dec_and_test(&server->active)) { in afs_unuse_server()
376 if (!test_bit(AFS_SERVER_FL_EXPIRED, &server->flags) && in afs_unuse_server()
377 READ_ONCE(server->cell->state) < AFS_CELL_REMOVING) { in afs_unuse_server()
380 server->unuse_time = unuse_time; in afs_unuse_server()
381 afs_set_server_timer(server, afs_server_gc_delay); in afs_unuse_server()
383 schedule_work(&server->destroyer); in afs_unuse_server()
387 afs_put_server(net, server, reason); in afs_unuse_server()
392 struct afs_server *server = container_of(rcu, struct afs_server, rcu); in afs_server_rcu() local
394 trace_afs_server(server->debug_id, refcount_read(&server->ref), in afs_server_rcu()
395 atomic_read(&server->active), afs_server_trace_free); in afs_server_rcu()
396 afs_put_endpoint_state(rcu_access_pointer(server->endpoint_state), in afs_server_rcu()
398 afs_put_cell(server->cell, afs_cell_trace_put_server); in afs_server_rcu()
399 kfree(server); in afs_server_rcu()
402 static void __afs_put_server(struct afs_net *net, struct afs_server *server) in __afs_put_server() argument
404 call_rcu(&server->rcu, afs_server_rcu); in __afs_put_server()
408 static void afs_give_up_callbacks(struct afs_net *net, struct afs_server *server) in afs_give_up_callbacks() argument
410 struct afs_endpoint_state *estate = rcu_access_pointer(server->endpoint_state); in afs_give_up_callbacks()
413 afs_fs_give_up_all_callbacks(net, server, &alist->addrs[alist->preferred], NULL); in afs_give_up_callbacks()
417 * Check to see if the server record has expired.
419 static bool afs_has_server_expired(const struct afs_server *server) in afs_has_server_expired() argument
423 if (atomic_read(&server->active)) in afs_has_server_expired()
426 if (server->cell->net->live || in afs_has_server_expired()
427 server->cell->state >= AFS_CELL_REMOVING) { in afs_has_server_expired()
428 trace_afs_server(server->debug_id, refcount_read(&server->ref), in afs_has_server_expired()
433 expires_at = server->unuse_time; in afs_has_server_expired()
434 if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) && in afs_has_server_expired()
435 !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags)) in afs_has_server_expired()
442 * Remove a server record from it's parent cell's database.
444 static bool afs_remove_server_from_cell(struct afs_server *server) in afs_remove_server_from_cell() argument
446 struct afs_cell *cell = server->cell; in afs_remove_server_from_cell()
450 if (!afs_has_server_expired(server)) { in afs_remove_server_from_cell()
455 set_bit(AFS_SERVER_FL_EXPIRED, &server->flags); in afs_remove_server_from_cell()
456 _debug("expire %pU %u", &server->uuid, atomic_read(&server->active)); in afs_remove_server_from_cell()
457 afs_see_server(server, afs_server_trace_see_expired); in afs_remove_server_from_cell()
458 rb_erase(&server->uuid_rb, &cell->fs_servers); in afs_remove_server_from_cell()
466 struct afs_server *server = container_of(work, struct afs_server, destroyer); in afs_server_destroyer() local
467 struct afs_net *net = server->cell->net; in afs_server_destroyer()
469 afs_see_server(server, afs_server_trace_see_destroyer); in afs_server_destroyer()
471 if (test_bit(AFS_SERVER_FL_EXPIRED, &server->flags)) in afs_server_destroyer()
474 if (!afs_remove_server_from_cell(server)) in afs_server_destroyer()
477 timer_shutdown_sync(&server->timer); in afs_server_destroyer()
478 cancel_work(&server->destroyer); in afs_server_destroyer()
480 if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags)) in afs_server_destroyer()
481 afs_give_up_callbacks(net, server); in afs_server_destroyer()
483 /* Unbind the rxrpc_peer records from the server. */ in afs_server_destroyer()
484 estate = rcu_access_pointer(server->endpoint_state); in afs_server_destroyer()
486 afs_set_peer_appdata(server, estate->addresses, NULL); in afs_server_destroyer()
489 list_del_init(&server->probe_link); in afs_server_destroyer()
490 if (!hlist_unhashed(&server->proc_link)) in afs_server_destroyer()
491 hlist_del_rcu(&server->proc_link); in afs_server_destroyer()
494 afs_put_server(net, server, afs_server_trace_destroy); in afs_server_destroyer()
499 struct afs_server *server = container_of(timer, struct afs_server, timer); in afs_server_timer() local
501 afs_see_server(server, afs_server_trace_see_timer); in afs_server_timer()
502 if (!test_bit(AFS_SERVER_FL_EXPIRED, &server->flags)) in afs_server_timer()
503 schedule_work(&server->destroyer); in afs_server_timer()
511 struct afs_server *server; in afs_purge_servers() local
516 server = rb_entry(rb, struct afs_server, uuid_rb); in afs_purge_servers()
517 afs_see_server(server, afs_server_trace_see_purge); in afs_purge_servers()
518 schedule_work(&server->destroyer); in afs_purge_servers()
537 * Get an update for a server's address list.
540 struct afs_server *server, in afs_update_server_record() argument
549 trace_afs_server(server->debug_id, refcount_read(&server->ref), in afs_update_server_record()
550 atomic_read(&server->active), in afs_update_server_record()
553 alist = afs_vl_lookup_addrs(server, op->key); in afs_update_server_record()
556 estate = rcu_dereference(server->endpoint_state); in afs_update_server_record()
572 if (server->addr_version != alist->version) in afs_update_server_record()
573 afs_fs_probe_fileserver(op->net, server, alist, key); in afs_update_server_record()
581 * See if a server's address list needs updating.
583 bool afs_check_server_record(struct afs_operation *op, struct afs_server *server, in afs_check_server_record() argument
591 ASSERT(server); in afs_check_server_record()
594 if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags)) in afs_check_server_record()
596 if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags)) in afs_check_server_record()
602 if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) { in afs_check_server_record()
603 clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_check_server_record()
604 success = afs_update_server_record(op, server, key); in afs_check_server_record()
605 clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags); in afs_check_server_record()
606 wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING); in afs_check_server_record()
612 ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING, in afs_check_server_record()