Home
last modified time | relevance | path

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

/net/rxrpc/
Dnet_ns.c15 struct rxrpc_net *rxnet = in rxrpc_client_conn_reap_timeout() local
18 if (rxnet->live) in rxrpc_client_conn_reap_timeout()
19 rxrpc_queue_work(&rxnet->client_conn_reaper); 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()
28 rxrpc_queue_work(&rxnet->service_conn_reaper); 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()
37 rxrpc_queue_work(&rxnet->peer_keepalive_work); in rxrpc_peer_keepalive_timeout()
45 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_init_net() local
[all …]
Dproc.c30 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_start() local
33 return seq_list_start_head_rcu(&rxnet->calls, *_pos); in rxrpc_call_seq_start()
38 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_next() local
40 return seq_list_next_rcu(v, &rxnet->calls, pos); in rxrpc_call_seq_next()
55 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_show() local
60 if (v == &rxnet->calls) { in rxrpc_call_seq_show()
127 __acquires(rxnet->conn_lock) in rxrpc_connection_seq_start()
129 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_connection_seq_start() local
131 read_lock(&rxnet->conn_lock); in rxrpc_connection_seq_start()
132 return seq_list_start_head(&rxnet->conn_proc_list, *_pos); in rxrpc_connection_seq_start()
[all …]
Dconn_client.c54 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_get_client_connection_id() local
70 conn->proto.epoch = rxnet->epoch; in rxrpc_get_client_connection_id()
167 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_alloc_client_connection() local
193 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
194 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
195 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
196 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
207 atomic_inc(&rxnet->nr_client_conns); in rxrpc_alloc_client_connection()
225 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
231 rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn()
[all …]
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()
324 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, in rxrpc_set_service_reap_timer() argument
327 if (rxnet->live) in rxrpc_set_service_reap_timer()
328 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); in rxrpc_set_service_reap_timer()
343 rxrpc_set_service_reap_timer(conn->params.local->rxnet, in rxrpc_put_service_conn()
369 if (atomic_dec_and_test(&conn->params.local->rxnet->nr_conns)) in rxrpc_destroy_connection()
370 wake_up_var(&conn->params.local->rxnet->nr_conns); in rxrpc_destroy_connection()
383 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
[all …]
Dlocal_object.c75 static struct rxrpc_local *rxrpc_alloc_local(struct rxrpc_net *rxnet, in rxrpc_alloc_local() argument
84 local->rxnet = rxnet; in rxrpc_alloc_local()
183 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_lookup_local() local
192 mutex_lock(&rxnet->local_mutex); in rxrpc_lookup_local()
194 hlist_for_each(cursor, &rxnet->local_endpoints) { in rxrpc_lookup_local()
223 local = rxrpc_alloc_local(rxnet, srx); in rxrpc_lookup_local()
235 hlist_add_head_rcu(&local->link, &rxnet->local_endpoints); in rxrpc_lookup_local()
240 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
251 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
258 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
[all …]
Dpeer_object.c120 struct rxrpc_net *rxnet = local->rxnet; in __rxrpc_lookup_peer_rcu() local
122 hash_for_each_possible_rcu(rxnet->peer_hash, peer, hash_link, hash_key) { in __rxrpc_lookup_peer_rcu()
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()
323 hash_add_rcu(rxnet->peer_hash, &peer->hash_link, hash_key); in rxrpc_new_incoming_peer()
324 list_add_tail(&peer->keepalive_link, &rxnet->peer_keepalive_new); 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()
[all …]
Dcall_object.c126 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_alloc_call() local
179 call->rxnet = rxnet; in rxrpc_alloc_call()
181 atomic_inc(&rxnet->nr_calls); in rxrpc_alloc_call()
279 struct rxrpc_net *rxnet; in rxrpc_new_client_call() local
341 rxnet = call->rxnet; in rxrpc_new_client_call()
342 spin_lock_bh(&rxnet->call_lock); in rxrpc_new_client_call()
343 list_add_tail_rcu(&call->link, &rxnet->calls); in rxrpc_new_client_call()
344 spin_unlock_bh(&rxnet->call_lock); in rxrpc_new_client_call()
623 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_put_call() local
638 spin_lock_bh(&rxnet->call_lock); in rxrpc_put_call()
[all …]
Dpeer_event.c521 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet, in rxrpc_peer_keepalive_dispatch() argument
527 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_dispatch()
531 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
542 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
561 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
563 &rxnet->peer_keepalive[slot & mask]); in rxrpc_peer_keepalive_dispatch()
569 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
577 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
579 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_worker()
585 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
[all …]
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 spin_lock_bh(&rxnet->call_lock); in rxrpc_service_prealloc_one()
144 list_add_tail_rcu(&call->link, &rxnet->calls); in rxrpc_service_prealloc_one()
145 spin_unlock_bh(&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 …]
Dconn_service.c126 struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *rxnet, in rxrpc_prealloc_service_connection() argument
139 atomic_inc(&rxnet->nr_conns); in rxrpc_prealloc_service_connection()
140 write_lock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
141 list_add_tail(&conn->link, &rxnet->service_conns); in rxrpc_prealloc_service_connection()
142 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_prealloc_service_connection()
143 write_unlock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
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()
Dar-internal.h275 struct rxrpc_net *rxnet; /* The network ns in which this resides */ member
567 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
Doutput.c648 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()