Lines Matching refs:server
28 struct afs_server *server = NULL; in afs_find_server() local
35 if (server) in afs_find_server()
36 afs_unuse_server_notime(net, server, afs_server_trace_put_find_rsq); in afs_find_server()
37 server = NULL; in afs_find_server()
42 hlist_for_each_entry_rcu(server, &net->fs_addresses6, addr6_link) { in afs_find_server()
43 alist = rcu_dereference(server->addresses); in afs_find_server()
58 hlist_for_each_entry_rcu(server, &net->fs_addresses4, addr4_link) { in afs_find_server()
59 alist = rcu_dereference(server->addresses); in afs_find_server()
73 server = NULL; in afs_find_server()
76 server = afs_maybe_use_server(server, afs_server_trace_get_by_addr); in afs_find_server()
83 return server; in afs_find_server()
91 struct afs_server *server = NULL; in afs_find_server_by_uuid() local
102 if (server) in afs_find_server_by_uuid()
103 afs_unuse_server(net, server, afs_server_trace_put_uuid_rsq); in afs_find_server_by_uuid()
104 server = NULL; in afs_find_server_by_uuid()
110 server = rb_entry(p, struct afs_server, uuid_rb); in afs_find_server_by_uuid()
112 diff = memcmp(uuid, &server->uuid, sizeof(*uuid)); in afs_find_server_by_uuid()
118 afs_use_server(server, afs_server_trace_get_by_uuid); in afs_find_server_by_uuid()
122 server = NULL; in afs_find_server_by_uuid()
128 _leave(" = %p", server); in afs_find_server_by_uuid()
129 return server; in afs_find_server_by_uuid()
141 struct afs_server *server, *next; in afs_install_server() local
156 server = rb_entry(p, struct afs_server, uuid_rb); in afs_install_server()
157 diff = memcmp(&candidate->uuid, &server->uuid, sizeof(uuid_t)); in afs_install_server()
163 if (server->cell == cell) in afs_install_server()
171 server->uuid_next, in afs_install_server()
175 server = next; in afs_install_server()
177 rcu_assign_pointer(server->uuid_next, candidate); in afs_install_server()
178 candidate->uuid_prev = server; in afs_install_server()
179 server = candidate; in afs_install_server()
184 server = candidate; in afs_install_server()
185 rb_link_node(&server->uuid_rb, p, pp); in afs_install_server()
186 rb_insert_color(&server->uuid_rb, &net->fs_servers); in afs_install_server()
187 hlist_add_head_rcu(&server->proc_link, &net->fs_proc); in afs_install_server()
191 alist = rcu_dereference_protected(server->addresses, in afs_install_server()
203 hlist_add_head_rcu(&server->addr4_link, &net->fs_addresses4); in afs_install_server()
205 hlist_add_head_rcu(&server->addr6_link, &net->fs_addresses6); in afs_install_server()
210 afs_get_server(server, afs_server_trace_get_install); in afs_install_server()
212 return server; in afs_install_server()
222 struct afs_server *server; in afs_alloc_server() local
227 server = kzalloc(sizeof(struct afs_server), GFP_KERNEL); in afs_alloc_server()
228 if (!server) in afs_alloc_server()
231 atomic_set(&server->ref, 1); in afs_alloc_server()
232 atomic_set(&server->active, 1); in afs_alloc_server()
233 server->debug_id = atomic_inc_return(&afs_server_debug_id); in afs_alloc_server()
234 RCU_INIT_POINTER(server->addresses, alist); in afs_alloc_server()
235 server->addr_version = alist->version; in afs_alloc_server()
236 server->uuid = *uuid; in afs_alloc_server()
237 rwlock_init(&server->fs_lock); in afs_alloc_server()
238 init_waitqueue_head(&server->probe_wq); in afs_alloc_server()
239 INIT_LIST_HEAD(&server->probe_link); in afs_alloc_server()
240 spin_lock_init(&server->probe_lock); in afs_alloc_server()
241 server->cell = cell; in afs_alloc_server()
242 server->rtt = UINT_MAX; in afs_alloc_server()
245 trace_afs_server(server, 1, 1, afs_server_trace_alloc); in afs_alloc_server()
246 _leave(" = %p", server); in afs_alloc_server()
247 return server; in afs_alloc_server()
267 if (test_bit(AFS_VLSERVER_FL_IS_YFS, &vc.server->flags)) in afs_vl_lookup_addrs()
286 struct afs_server *server, *candidate; in afs_lookup_server() local
290 server = afs_find_server_by_uuid(cell->net, uuid); in afs_lookup_server()
291 if (server) { in afs_lookup_server()
292 if (server->addr_version != addr_version) in afs_lookup_server()
293 set_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_lookup_server()
294 return server; in afs_lookup_server()
307 server = afs_install_server(cell, candidate); in afs_lookup_server()
308 if (server != candidate) { in afs_lookup_server()
316 afs_fs_probe_fileserver(cell->net, server, key, true); in afs_lookup_server()
319 return server; in afs_lookup_server()
351 struct afs_server *afs_get_server(struct afs_server *server, in afs_get_server() argument
354 unsigned int u = atomic_inc_return(&server->ref); in afs_get_server()
356 trace_afs_server(server, u, atomic_read(&server->active), reason); in afs_get_server()
357 return server; in afs_get_server()
363 static struct afs_server *afs_maybe_use_server(struct afs_server *server, in afs_maybe_use_server() argument
366 unsigned int r = atomic_fetch_add_unless(&server->ref, 1, 0); in afs_maybe_use_server()
372 a = atomic_inc_return(&server->active); in afs_maybe_use_server()
373 trace_afs_server(server, r, a, reason); in afs_maybe_use_server()
374 return server; in afs_maybe_use_server()
380 struct afs_server *afs_use_server(struct afs_server *server, enum afs_server_trace reason) in afs_use_server() argument
382 unsigned int r = atomic_inc_return(&server->ref); in afs_use_server()
383 unsigned int a = atomic_inc_return(&server->active); in afs_use_server()
385 trace_afs_server(server, r, a, reason); in afs_use_server()
386 return server; in afs_use_server()
392 void afs_put_server(struct afs_net *net, struct afs_server *server, in afs_put_server() argument
397 if (!server) in afs_put_server()
400 usage = atomic_dec_return(&server->ref); in afs_put_server()
401 trace_afs_server(server, usage, atomic_read(&server->active), reason); in afs_put_server()
403 __afs_put_server(net, server); in afs_put_server()
410 void afs_unuse_server_notime(struct afs_net *net, struct afs_server *server, in afs_unuse_server_notime() argument
413 if (server) { in afs_unuse_server_notime()
414 unsigned int active = atomic_dec_return(&server->active); in afs_unuse_server_notime()
418 afs_put_server(net, server, reason); in afs_unuse_server_notime()
425 void afs_unuse_server(struct afs_net *net, struct afs_server *server, in afs_unuse_server() argument
428 if (server) { in afs_unuse_server()
429 server->unuse_time = ktime_get_real_seconds(); in afs_unuse_server()
430 afs_unuse_server_notime(net, server, reason); in afs_unuse_server()
436 struct afs_server *server = container_of(rcu, struct afs_server, rcu); in afs_server_rcu() local
438 trace_afs_server(server, atomic_read(&server->ref), in afs_server_rcu()
439 atomic_read(&server->active), afs_server_trace_free); in afs_server_rcu()
440 afs_put_addrlist(rcu_access_pointer(server->addresses)); in afs_server_rcu()
441 kfree(server); in afs_server_rcu()
444 static void __afs_put_server(struct afs_net *net, struct afs_server *server) in __afs_put_server() argument
446 call_rcu(&server->rcu, afs_server_rcu); in __afs_put_server()
450 static void afs_give_up_callbacks(struct afs_net *net, struct afs_server *server) in afs_give_up_callbacks() argument
452 struct afs_addr_list *alist = rcu_access_pointer(server->addresses); in afs_give_up_callbacks()
459 afs_fs_give_up_all_callbacks(net, server, &ac, NULL); in afs_give_up_callbacks()
465 static void afs_destroy_server(struct afs_net *net, struct afs_server *server) in afs_destroy_server() argument
467 if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags)) in afs_destroy_server()
468 afs_give_up_callbacks(net, server); in afs_destroy_server()
470 afs_put_server(net, server, afs_server_trace_destroy); in afs_destroy_server()
478 struct afs_server *server, *next, *prev; in afs_gc_servers() local
481 while ((server = gc_list)) { in afs_gc_servers()
482 gc_list = server->gc_next; in afs_gc_servers()
486 active = atomic_read(&server->active); in afs_gc_servers()
488 trace_afs_server(server, atomic_read(&server->ref), in afs_gc_servers()
491 server->uuid_next, lockdep_is_held(&net->fs_lock.lock)); in afs_gc_servers()
492 prev = server->uuid_prev; in afs_gc_servers()
496 rb_erase(&server->uuid_rb, &net->fs_servers); in afs_gc_servers()
498 rb_replace_node_rcu(&server->uuid_rb, in afs_gc_servers()
510 list_del(&server->probe_link); in afs_gc_servers()
511 hlist_del_rcu(&server->proc_link); in afs_gc_servers()
512 if (!hlist_unhashed(&server->addr4_link)) in afs_gc_servers()
513 hlist_del_rcu(&server->addr4_link); in afs_gc_servers()
514 if (!hlist_unhashed(&server->addr6_link)) in afs_gc_servers()
515 hlist_del_rcu(&server->addr6_link); in afs_gc_servers()
520 afs_destroy_server(net, server); in afs_gc_servers()
547 struct afs_server *server = in afs_manage_servers() local
549 int active = atomic_read(&server->active); in afs_manage_servers()
551 _debug("manage %pU %u", &server->uuid, active); in afs_manage_servers()
554 trace_afs_server(server, atomic_read(&server->ref), in afs_manage_servers()
557 pr_notice("Can't purge s=%08x\n", server->debug_id); in afs_manage_servers()
561 time64_t expire_at = server->unuse_time; in afs_manage_servers()
563 if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) && in afs_manage_servers()
564 !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags)) in afs_manage_servers()
567 server->gc_next = gc_list; in afs_manage_servers()
568 gc_list = server; in afs_manage_servers()
628 struct afs_server *server) in afs_update_server_record() argument
634 trace_afs_server(server, atomic_read(&server->ref), atomic_read(&server->active), in afs_update_server_record()
637 alist = afs_vl_lookup_addrs(op->volume->cell, op->key, &server->uuid); in afs_update_server_record()
642 server->addresses) { in afs_update_server_record()
652 if (server->addr_version != alist->version) { in afs_update_server_record()
653 write_lock(&server->fs_lock); in afs_update_server_record()
654 discard = rcu_dereference_protected(server->addresses, in afs_update_server_record()
655 lockdep_is_held(&server->fs_lock)); in afs_update_server_record()
656 rcu_assign_pointer(server->addresses, alist); in afs_update_server_record()
657 server->addr_version = alist->version; in afs_update_server_record()
658 write_unlock(&server->fs_lock); in afs_update_server_record()
669 bool afs_check_server_record(struct afs_operation *op, struct afs_server *server) in afs_check_server_record() argument
676 ASSERT(server); in afs_check_server_record()
679 if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags)) in afs_check_server_record()
681 if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags)) in afs_check_server_record()
687 if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) { in afs_check_server_record()
688 clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_check_server_record()
689 success = afs_update_server_record(op, server); in afs_check_server_record()
690 clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags); in afs_check_server_record()
691 wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING); in afs_check_server_record()
697 ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING, in afs_check_server_record()