| /Linux-v4.19/net/rxrpc/ |
| D | net_ns.c | 19 struct rxrpc_net *rxnet = in rxrpc_client_conn_reap_timeout() local
22 if (rxnet->live) in rxrpc_client_conn_reap_timeout()
23 rxrpc_queue_work(&rxnet->client_conn_reaper); in rxrpc_client_conn_reap_timeout()
28 struct rxrpc_net *rxnet = in rxrpc_service_conn_reap_timeout() local
31 if (rxnet->live) in rxrpc_service_conn_reap_timeout()
32 rxrpc_queue_work(&rxnet->service_conn_reaper); in rxrpc_service_conn_reap_timeout()
37 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_timeout() local
40 if (rxnet->live) in rxrpc_peer_keepalive_timeout()
41 rxrpc_queue_work(&rxnet->peer_keepalive_work); in rxrpc_peer_keepalive_timeout()
49 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_init_net() local
[all …]
|
| D | conn_client.c | 108 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_get_client_connection_id() local
124 conn->proto.epoch = rxnet->epoch; in rxrpc_get_client_connection_id()
176 struct rxrpc_net *rxnet = cp->local->rxnet; in rxrpc_alloc_client_connection() local
210 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
211 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
212 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
213 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
241 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn() local
247 if (conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
451 static void rxrpc_activate_conn(struct rxrpc_net *rxnet, in rxrpc_activate_conn() argument
[all …]
|
| D | proc.c | 33 __acquires(rxnet->call_lock) in rxrpc_call_seq_start()
35 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_start() local
38 read_lock(&rxnet->call_lock); in rxrpc_call_seq_start()
39 return seq_list_start_head(&rxnet->calls, *_pos); in rxrpc_call_seq_start()
44 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_next() local
46 return seq_list_next(v, &rxnet->calls, pos); in rxrpc_call_seq_next()
50 __releases(rxnet->call_lock) in rxrpc_call_seq_stop()
53 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_stop() local
55 read_unlock(&rxnet->call_lock); in rxrpc_call_seq_stop()
65 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_show() local
[all …]
|
| D | conn_object.c | 239 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_kill_connection() local
247 write_lock(&rxnet->conn_lock); in rxrpc_kill_connection()
249 write_unlock(&rxnet->conn_lock); in rxrpc_kill_connection()
326 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, in rxrpc_set_service_reap_timer() argument
329 if (rxnet->live) in rxrpc_set_service_reap_timer()
330 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); in rxrpc_set_service_reap_timer()
345 rxrpc_set_service_reap_timer(conn->params.local->rxnet, in rxrpc_put_service_conn()
371 if (atomic_dec_and_test(&conn->params.local->rxnet->nr_conns)) in rxrpc_destroy_connection()
372 wake_up_var(&conn->params.local->rxnet->nr_conns); in rxrpc_destroy_connection()
385 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
[all …]
|
| D | peer_event.c | 337 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet, in rxrpc_peer_keepalive_dispatch() argument
343 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_dispatch()
347 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
357 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
375 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
377 &rxnet->peer_keepalive[slot & mask]); in rxrpc_peer_keepalive_dispatch()
381 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
389 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
391 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_worker()
397 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
[all …]
|
| D | peer_object.c | 124 struct rxrpc_net *rxnet = local->rxnet; in __rxrpc_lookup_peer_rcu() local
126 hash_for_each_possible_rcu(rxnet->peer_hash, peer, hash_link, hash_key) { in __rxrpc_lookup_peer_rcu()
310 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_new_incoming_peer() local
317 spin_lock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
318 hash_add_rcu(rxnet->peer_hash, &peer->hash_link, hash_key); in rxrpc_new_incoming_peer()
319 list_add_tail(&peer->keepalive_link, &rxnet->peer_keepalive_new); in rxrpc_new_incoming_peer()
320 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
331 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_lookup_peer() local
353 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_lookup_peer()
360 hash_add_rcu(rxnet->peer_hash, in rxrpc_lookup_peer()
[all …]
|
| D | local_object.c | 78 static struct rxrpc_local *rxrpc_alloc_local(struct rxrpc_net *rxnet, in rxrpc_alloc_local() argument
86 local->rxnet = rxnet; in rxrpc_alloc_local()
237 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_lookup_local() local
246 mutex_lock(&rxnet->local_mutex); in rxrpc_lookup_local()
248 for (cursor = rxnet->local_endpoints.next; in rxrpc_lookup_local()
249 cursor != &rxnet->local_endpoints; in rxrpc_lookup_local()
283 local = rxrpc_alloc_local(rxnet, srx); in rxrpc_lookup_local()
295 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
306 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
312 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
[all …]
|
| D | call_object.c | 106 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_alloc_call() local
159 call->rxnet = rxnet; in rxrpc_alloc_call()
160 atomic_inc(&rxnet->nr_calls); in rxrpc_alloc_call()
230 struct rxrpc_net *rxnet; in rxrpc_new_client_call() local
280 rxnet = call->rxnet; in rxrpc_new_client_call()
281 write_lock(&rxnet->call_lock); in rxrpc_new_client_call()
282 list_add_tail(&call->link, &rxnet->calls); in rxrpc_new_client_call()
283 write_unlock(&rxnet->call_lock); in rxrpc_new_client_call()
626 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_put_call() local
640 write_lock(&rxnet->call_lock); in rxrpc_put_call()
[all …]
|
| D | conn_service.c | 123 struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *rxnet, in rxrpc_prealloc_service_connection() argument
135 atomic_inc(&rxnet->nr_conns); in rxrpc_prealloc_service_connection()
136 write_lock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
137 list_add_tail(&conn->link, &rxnet->service_conns); in rxrpc_prealloc_service_connection()
138 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_prealloc_service_connection()
139 write_unlock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
|
| D | call_accept.c | 42 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_service_prealloc_one() local
84 conn = rxrpc_prealloc_service_connection(rxnet, gfp); in rxrpc_service_prealloc_one()
141 rxnet = call->rxnet; in rxrpc_service_prealloc_one()
142 write_lock(&rxnet->call_lock); in rxrpc_service_prealloc_one()
143 list_add_tail(&call->link, &rxnet->calls); in rxrpc_service_prealloc_one()
144 write_unlock(&rxnet->call_lock); in rxrpc_service_prealloc_one()
192 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_discard_prealloc() local
217 write_lock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
220 write_unlock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
222 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_discard_prealloc()
[all …]
|
| D | af_rxrpc.c | 767 struct rxrpc_net *rxnet; in rxrpc_create() local
807 rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_create()
808 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1); in rxrpc_create()
872 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_release_sock() local
908 rxrpc_queue_work(&rxnet->service_conn_reaper); in rxrpc_release_sock()
909 rxrpc_queue_work(&rxnet->client_conn_reaper); in rxrpc_release_sock()
|
| D | ar-internal.h | 262 struct rxrpc_net *rxnet; /* The network ns in which this resides */ member
540 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
|
| D | output.c | 610 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
|
