Lines Matching refs:server
39 struct afs_server *server = NULL; in afs_find_server() local
52 if (server) in afs_find_server()
53 afs_put_server(net, server); in afs_find_server()
54 server = NULL; in afs_find_server()
58 hlist_for_each_entry_rcu(server, &net->fs_addresses6, addr6_link) { in afs_find_server()
59 alist = rcu_dereference(server->addresses); in afs_find_server()
73 hlist_for_each_entry_rcu(server, &net->fs_addresses4, addr4_link) { in afs_find_server()
74 alist = rcu_dereference(server->addresses); in afs_find_server()
88 server = NULL; in afs_find_server()
90 if (server && !atomic_inc_not_zero(&server->usage)) in afs_find_server()
91 server = NULL; in afs_find_server()
98 return server; in afs_find_server()
106 struct afs_server *server = NULL; in afs_find_server_by_uuid() local
117 if (server) in afs_find_server_by_uuid()
118 afs_put_server(net, server); in afs_find_server_by_uuid()
119 server = NULL; in afs_find_server_by_uuid()
125 server = rb_entry(p, struct afs_server, uuid_rb); in afs_find_server_by_uuid()
127 diff = memcmp(uuid, &server->uuid, sizeof(*uuid)); in afs_find_server_by_uuid()
133 afs_get_server(server); in afs_find_server_by_uuid()
137 server = NULL; in afs_find_server_by_uuid()
143 _leave(" = %p", server); in afs_find_server_by_uuid()
144 return server; in afs_find_server_by_uuid()
154 struct afs_server *server; in afs_install_server() local
168 server = rb_entry(p, struct afs_server, uuid_rb); in afs_install_server()
169 diff = memcmp(&candidate->uuid, &server->uuid, sizeof(uuid_t)); in afs_install_server()
178 server = candidate; in afs_install_server()
179 rb_link_node(&server->uuid_rb, p, pp); in afs_install_server()
180 rb_insert_color(&server->uuid_rb, &net->fs_servers); in afs_install_server()
181 hlist_add_head_rcu(&server->proc_link, &net->fs_proc); in afs_install_server()
184 alist = rcu_dereference_protected(server->addresses, in afs_install_server()
196 hlist_add_head_rcu(&server->addr4_link, &net->fs_addresses4); in afs_install_server()
198 hlist_add_head_rcu(&server->addr6_link, &net->fs_addresses6); in afs_install_server()
204 afs_get_server(server); in afs_install_server()
206 return server; in afs_install_server()
216 struct afs_server *server; in afs_alloc_server() local
220 server = kzalloc(sizeof(struct afs_server), GFP_KERNEL); in afs_alloc_server()
221 if (!server) in afs_alloc_server()
224 atomic_set(&server->usage, 1); in afs_alloc_server()
225 RCU_INIT_POINTER(server->addresses, alist); in afs_alloc_server()
226 server->addr_version = alist->version; in afs_alloc_server()
227 server->uuid = *uuid; in afs_alloc_server()
228 server->flags = (1UL << AFS_SERVER_FL_NEW); in afs_alloc_server()
229 server->update_at = ktime_get_real_seconds() + afs_server_update_delay; in afs_alloc_server()
230 rwlock_init(&server->fs_lock); in afs_alloc_server()
231 INIT_HLIST_HEAD(&server->cb_volumes); in afs_alloc_server()
232 rwlock_init(&server->cb_break_lock); in afs_alloc_server()
235 _leave(" = %p", server); in afs_alloc_server()
236 return server; in afs_alloc_server()
293 struct afs_server *server, *candidate; in afs_lookup_server() local
297 server = afs_find_server_by_uuid(cell->net, uuid); in afs_lookup_server()
298 if (server) in afs_lookup_server()
299 return server; in afs_lookup_server()
311 server = afs_install_server(cell->net, candidate); in afs_lookup_server()
312 if (server != candidate) { in afs_lookup_server()
317 _leave(" = %p{%d}", server, atomic_read(&server->usage)); in afs_lookup_server()
318 return server; in afs_lookup_server()
350 void afs_put_server(struct afs_net *net, struct afs_server *server) in afs_put_server() argument
354 if (!server) in afs_put_server()
357 server->put_time = ktime_get_real_seconds(); in afs_put_server()
359 usage = atomic_dec_return(&server->usage); in afs_put_server()
371 struct afs_server *server = container_of(rcu, struct afs_server, rcu); in afs_server_rcu() local
373 afs_put_addrlist(rcu_access_pointer(server->addresses)); in afs_server_rcu()
374 kfree(server); in afs_server_rcu()
380 static void afs_destroy_server(struct afs_net *net, struct afs_server *server) in afs_destroy_server() argument
382 struct afs_addr_list *alist = rcu_access_pointer(server->addresses); in afs_destroy_server()
390 _enter("%p", server); in afs_destroy_server()
392 if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags)) in afs_destroy_server()
393 afs_fs_give_up_all_callbacks(net, server, &ac, NULL); in afs_destroy_server()
395 call_rcu(&server->rcu, afs_server_rcu); in afs_destroy_server()
404 struct afs_server *server; in afs_gc_servers() local
408 while ((server = gc_list)) { in afs_gc_servers()
409 gc_list = server->gc_next; in afs_gc_servers()
413 deleted = atomic_try_cmpxchg(&server->usage, &usage, 0); in afs_gc_servers()
415 rb_erase(&server->uuid_rb, &net->fs_servers); in afs_gc_servers()
416 hlist_del_rcu(&server->proc_link); in afs_gc_servers()
422 if (!hlist_unhashed(&server->addr4_link)) in afs_gc_servers()
423 hlist_del_rcu(&server->addr4_link); in afs_gc_servers()
424 if (!hlist_unhashed(&server->addr6_link)) in afs_gc_servers()
425 hlist_del_rcu(&server->addr6_link); in afs_gc_servers()
427 afs_destroy_server(net, server); in afs_gc_servers()
455 struct afs_server *server = in afs_manage_servers() local
457 int usage = atomic_read(&server->usage); in afs_manage_servers()
459 _debug("manage %pU %u", &server->uuid, usage); in afs_manage_servers()
465 time64_t expire_at = server->put_time; in afs_manage_servers()
467 if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) && in afs_manage_servers()
468 !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags)) in afs_manage_servers()
471 server->gc_next = gc_list; in afs_manage_servers()
472 gc_list = server; in afs_manage_servers()
543 afs_fs_get_capabilities(afs_v2net(fc->vnode), fc->cbi->server, in afs_do_probe_fileserver()
548 set_bit(AFS_SERVER_FL_PROBED, &fc->cbi->server->flags); in afs_do_probe_fileserver()
588 if (test_bit(AFS_SERVER_FL_PROBED, &fc->cbi->server->flags)) { in afs_probe_fileserver()
593 if (!test_and_set_bit_lock(AFS_SERVER_FL_PROBING, &fc->cbi->server->flags)) { in afs_probe_fileserver()
595 clear_bit_unlock(AFS_SERVER_FL_PROBING, &fc->cbi->server->flags); in afs_probe_fileserver()
596 wake_up_bit(&fc->cbi->server->flags, AFS_SERVER_FL_PROBING); in afs_probe_fileserver()
602 ret = wait_on_bit(&fc->cbi->server->flags, AFS_SERVER_FL_PROBING, in afs_probe_fileserver()
623 static noinline bool afs_update_server_record(struct afs_fs_cursor *fc, struct afs_server *server) in afs_update_server_record() argument
630 &server->uuid); in afs_update_server_record()
638 if (server->addr_version != alist->version) { in afs_update_server_record()
639 write_lock(&server->fs_lock); in afs_update_server_record()
640 discard = rcu_dereference_protected(server->addresses, in afs_update_server_record()
641 lockdep_is_held(&server->fs_lock)); in afs_update_server_record()
642 rcu_assign_pointer(server->addresses, alist); in afs_update_server_record()
643 server->addr_version = alist->version; in afs_update_server_record()
644 write_unlock(&server->fs_lock); in afs_update_server_record()
647 server->update_at = ktime_get_real_seconds() + afs_server_update_delay; in afs_update_server_record()
656 bool afs_check_server_record(struct afs_fs_cursor *fc, struct afs_server *server) in afs_check_server_record() argument
665 ASSERT(server); in afs_check_server_record()
668 diff = READ_ONCE(server->update_at) - now; in afs_check_server_record()
674 if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) { in afs_check_server_record()
675 success = afs_update_server_record(fc, server); in afs_check_server_record()
676 clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags); in afs_check_server_record()
677 wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING); in afs_check_server_record()
682 ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING, in afs_check_server_record()