Home
last modified time | relevance | path

Searched refs:rxnet (Results 1 – 13 of 13) sorted by relevance

/linux/net/rxrpc/
A Dnet_ns.c15 struct rxrpc_net *rxnet = in rxrpc_client_conn_reap_timeout() local
18 if (rxnet->live) in rxrpc_client_conn_reap_timeout()
24 struct rxrpc_net *rxnet = in rxrpc_service_conn_reap_timeout() local
27 if (rxnet->live) in rxrpc_service_conn_reap_timeout()
33 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_timeout() local
36 if (rxnet->live) in rxrpc_peer_keepalive_timeout()
48 rxnet->live = true; in rxrpc_init_net()
49 get_random_bytes(&rxnet->epoch, sizeof(rxnet->epoch)); in rxrpc_init_net()
90 if (!rxnet->proc_net) in rxrpc_init_net()
104 rxnet->live = false; in rxrpc_init_net()
[all …]
A Dproc.c29 __acquires(rxnet->call_lock) in rxrpc_call_seq_start()
34 read_lock(&rxnet->call_lock); in rxrpc_call_seq_start()
42 return seq_list_next(v, &rxnet->calls, pos); in rxrpc_call_seq_next()
46 __releases(rxnet->call_lock) in rxrpc_call_seq_stop()
51 read_unlock(&rxnet->call_lock); in rxrpc_call_seq_stop()
66 if (v == &rxnet->calls) { in rxrpc_call_seq_show()
133 __acquires(rxnet->conn_lock) in rxrpc_connection_seq_start()
137 read_lock(&rxnet->conn_lock); in rxrpc_connection_seq_start()
150 __releases(rxnet->conn_lock) in rxrpc_connection_seq_stop()
154 read_unlock(&rxnet->conn_lock); in rxrpc_connection_seq_stop()
[all …]
A Dconn_client.c52 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_get_client_connection_id() local
161 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_alloc_client_connection() local
219 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
225 rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn()
565 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_unidle_conn() local
701 struct rxrpc_net *rxnet = cp->local->rxnet; in rxrpc_connect_call() local
778 if (rxnet->live) in rxrpc_set_client_reap_timer()
790 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_disconnect_client_call() local
951 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
989 struct rxrpc_net *rxnet = in rxrpc_discard_expired_client_conns() local
[all …]
A Dpeer_event.c312 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
342 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
358 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
366 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
367 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
370 if (!rxnet->live) in rxrpc_peer_keepalive_worker()
380 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
394 rxnet->peer_keepalive_base = base; in rxrpc_peer_keepalive_worker()
395 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
400 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
[all …]
A Dconn_object.c234 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_kill_connection() local
242 write_lock(&rxnet->conn_lock); in rxrpc_kill_connection()
244 write_unlock(&rxnet->conn_lock); in rxrpc_kill_connection()
325 if (rxnet->live) in rxrpc_set_service_reap_timer()
382 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
393 write_lock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
432 write_unlock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
463 atomic_dec(&rxnet->nr_conns); in rxrpc_destroy_all_connections()
470 write_lock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
476 write_unlock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
[all …]
A Dlocal_object.c84 local->rxnet = rxnet; in rxrpc_alloc_local()
188 mutex_lock(&rxnet->local_mutex); in rxrpc_lookup_local()
222 local = rxrpc_alloc_local(rxnet, srx); in rxrpc_lookup_local()
237 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
248 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
255 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
367 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_local_destroyer() local
373 mutex_lock(&rxnet->local_mutex); in rxrpc_local_destroyer()
375 mutex_unlock(&rxnet->local_mutex); in rxrpc_local_destroyer()
459 mutex_lock(&rxnet->local_mutex); in rxrpc_destroy_all_locals()
[all …]
A Dpeer_object.c120 struct rxrpc_net *rxnet = local->rxnet; in __rxrpc_lookup_peer_rcu() local
316 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_new_incoming_peer() local
322 spin_lock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
325 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
336 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_lookup_peer() local
358 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_lookup_peer()
365 hash_add_rcu(rxnet->peer_hash, in rxrpc_lookup_peer()
368 &rxnet->peer_keepalive_new); in rxrpc_lookup_peer()
420 struct rxrpc_net *rxnet = peer->local->rxnet; in __rxrpc_put_peer() local
424 spin_lock_bh(&rxnet->peer_hash_lock); in __rxrpc_put_peer()
[all …]
A Dcall_object.c159 call->rxnet = rxnet; in rxrpc_alloc_call()
161 atomic_inc(&rxnet->nr_calls); in rxrpc_alloc_call()
259 struct rxrpc_net *rxnet; in rxrpc_new_client_call() local
319 rxnet = call->rxnet; in rxrpc_new_client_call()
320 write_lock(&rxnet->call_lock); in rxrpc_new_client_call()
322 write_unlock(&rxnet->call_lock); in rxrpc_new_client_call()
589 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_put_call() local
619 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_destroy_call() local
627 wake_up_var(&rxnet->nr_calls); in rxrpc_destroy_call()
701 atomic_dec(&rxnet->nr_calls); in rxrpc_destroy_all_calls()
[all …]
A Dcall_accept.c43 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_service_prealloc_one() local
86 conn = rxrpc_prealloc_service_connection(rxnet, gfp); in rxrpc_service_prealloc_one()
142 rxnet = call->rxnet; in rxrpc_service_prealloc_one()
143 write_lock(&rxnet->call_lock); in rxrpc_service_prealloc_one()
144 list_add_tail(&call->link, &rxnet->calls); in rxrpc_service_prealloc_one()
145 write_unlock(&rxnet->call_lock); in rxrpc_service_prealloc_one()
183 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_discard_prealloc() local
209 write_lock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
212 write_unlock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
214 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_discard_prealloc()
[all …]
A Dconn_service.c125 struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *rxnet, in rxrpc_prealloc_service_connection() argument
138 atomic_inc(&rxnet->nr_conns); in rxrpc_prealloc_service_connection()
139 write_lock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
140 list_add_tail(&conn->link, &rxnet->service_conns); in rxrpc_prealloc_service_connection()
141 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_prealloc_service_connection()
142 write_unlock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
A Daf_rxrpc.c749 struct rxrpc_net *rxnet; in rxrpc_create() local
789 rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_create()
790 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1); in rxrpc_create()
A Dar-internal.h283 struct rxrpc_net *rxnet; /* The network ns in which this resides */ member
574 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
A Doutput.c644 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()

Completed in 793 milliseconds