| /Linux-v6.6/net/rxrpc/ |
| D | net_ns.c | 15 struct rxrpc_net *rxnet = in rxrpc_service_conn_reap_timeout() local
18 if (rxnet->live) in rxrpc_service_conn_reap_timeout()
19 rxrpc_queue_work(&rxnet->service_conn_reaper); in rxrpc_service_conn_reap_timeout()
24 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_timeout() local
27 if (rxnet->live) in rxrpc_peer_keepalive_timeout()
28 rxrpc_queue_work(&rxnet->peer_keepalive_work); in rxrpc_peer_keepalive_timeout()
36 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_init_net() local
39 rxnet->live = true; in rxrpc_init_net()
40 get_random_bytes(&rxnet->epoch, sizeof(rxnet->epoch)); in rxrpc_init_net()
41 rxnet->epoch |= RXRPC_RANDOM_EPOCH; in rxrpc_init_net()
[all …]
|
| D | proc.c | 30 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()
53 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_call_seq_show() local
59 if (v == &rxnet->calls) { in rxrpc_call_seq_show()
118 __acquires(rxnet->conn_lock) in rxrpc_connection_seq_start()
120 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); in rxrpc_connection_seq_start() local
122 read_lock(&rxnet->conn_lock); in rxrpc_connection_seq_start()
123 return seq_list_start_head(&rxnet->conn_proc_list, *_pos); in rxrpc_connection_seq_start()
[all …]
|
| D | peer_event.c | 230 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet, in rxrpc_peer_keepalive_dispatch() argument
236 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_dispatch()
241 spin_lock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
252 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
272 spin_lock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
274 &rxnet->peer_keepalive[slot & mask]); in rxrpc_peer_keepalive_dispatch()
275 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
279 spin_lock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
282 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
290 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
[all …]
|
| D | conn_object.c | 23 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet,
55 struct rxrpc_connection *rxrpc_alloc_connection(struct rxrpc_net *rxnet, in rxrpc_alloc_connection() argument
72 conn->rxnet = rxnet; in rxrpc_alloc_connection()
214 rxrpc_set_service_reap_timer(conn->rxnet, in rxrpc_disconnect_call()
279 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, in rxrpc_set_service_reap_timer() argument
282 if (rxnet->live) in rxrpc_set_service_reap_timer()
283 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); in rxrpc_set_service_reap_timer()
293 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_rcu_free_connection() local
301 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_rcu_free_connection()
302 wake_up_var(&rxnet->nr_conns); in rxrpc_rcu_free_connection()
[all …]
|
| D | peer_object.c | 120 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()
308 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_new_incoming_peer() local
314 spin_lock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
315 hash_add_rcu(rxnet->peer_hash, &peer->hash_link, hash_key); in rxrpc_new_incoming_peer()
316 list_add_tail(&peer->keepalive_link, &rxnet->peer_keepalive_new); in rxrpc_new_incoming_peer()
317 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
327 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_lookup_peer() local
349 spin_lock(&rxnet->peer_hash_lock); in rxrpc_lookup_peer()
356 hash_add_rcu(rxnet->peer_hash, in rxrpc_lookup_peer()
[all …]
|
| D | local_object.c | 109 local->rxnet = rxrpc_net(net); in rxrpc_alloc_local()
243 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_lookup_local() local
251 mutex_lock(&rxnet->local_mutex); in rxrpc_lookup_local()
253 hlist_for_each(cursor, &rxnet->local_endpoints) { in rxrpc_lookup_local()
293 hlist_add_head_rcu(&local->link, &rxnet->local_endpoints); in rxrpc_lookup_local()
297 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
304 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
311 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
415 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_destroy_local() local
421 mutex_lock(&rxnet->local_mutex); in rxrpc_destroy_local()
[all …]
|
| D | call_object.c | 135 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_alloc_call() local
186 call->rxnet = rxnet; in rxrpc_alloc_call()
188 atomic_inc(&rxnet->nr_calls); in rxrpc_alloc_call()
345 struct rxrpc_net *rxnet; in rxrpc_new_client_call() local
398 rxnet = call->rxnet; in rxrpc_new_client_call()
399 spin_lock(&rxnet->call_lock); in rxrpc_new_client_call()
400 list_add_tail_rcu(&call->link, &rxnet->calls); in rxrpc_new_client_call()
401 spin_unlock(&rxnet->call_lock); in rxrpc_new_client_call()
643 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_put_call() local
656 spin_lock(&rxnet->call_lock); in rxrpc_put_call()
[all …]
|
| D | conn_service.c | 119 struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *rxnet, in rxrpc_prealloc_service_connection() argument
122 struct rxrpc_connection *conn = rxrpc_alloc_connection(rxnet, gfp); in rxrpc_prealloc_service_connection()
131 atomic_inc(&rxnet->nr_conns); in rxrpc_prealloc_service_connection()
132 write_lock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
133 list_add_tail(&conn->link, &rxnet->service_conns); in rxrpc_prealloc_service_connection()
134 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_prealloc_service_connection()
135 write_unlock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
|
| D | conn_client.c | 146 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_alloc_client_connection() local
151 conn = rxrpc_alloc_connection(rxnet, GFP_ATOMIC | __GFP_NOWARN); in rxrpc_alloc_client_connection()
164 conn->proto.epoch = local->rxnet->epoch; in rxrpc_alloc_client_connection()
181 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
182 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
183 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
184 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
188 atomic_inc(&rxnet->nr_client_conns); in rxrpc_alloc_client_connection()
198 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
204 rxnet = conn->rxnet; in rxrpc_may_reuse_conn()
[all …]
|
| D | call_accept.c | 42 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_service_prealloc_one() local
87 conn = rxrpc_prealloc_service_connection(rxnet, gfp); in rxrpc_service_prealloc_one()
140 rxnet = call->rxnet; in rxrpc_service_prealloc_one()
141 spin_lock(&rxnet->call_lock); in rxrpc_service_prealloc_one()
142 list_add_tail_rcu(&call->link, &rxnet->calls); in rxrpc_service_prealloc_one()
143 spin_unlock(&rxnet->call_lock); in rxrpc_service_prealloc_one()
181 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_discard_prealloc() local
207 write_lock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
210 write_unlock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
212 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_discard_prealloc()
[all …]
|
| D | output.c | 95 rxrpc_inc_stat(call->rxnet, stat_tx_ack_fill); in rxrpc_fill_out_ack()
229 rxrpc_inc_stat(call->rxnet, stat_tx_ack_send); in rxrpc_send_ack_packet()
381 rxrpc_inc_stat(call->rxnet, stat_why_req_ack[why]); in rxrpc_send_data_packet()
426 rxrpc_inc_stat(call->rxnet, stat_tx_data_send); in rxrpc_send_data_packet()
431 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_fail); in rxrpc_send_data_packet()
499 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_frag); in rxrpc_send_data_packet()
512 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_fail); in rxrpc_send_data_packet()
665 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
|
| D | ar-internal.h | 281 struct rxrpc_net *rxnet; /* Our bits in the network namespace */ member
459 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
604 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
1252 #define rxrpc_inc_stat(rxnet, s) atomic_inc(&(rxnet)->s) argument
1253 #define rxrpc_dec_stat(rxnet, s) atomic_dec(&(rxnet)->s) argument
|
| D | call_event.c | 77 rxrpc_inc_stat(call->rxnet, stat_tx_acks[ack_reason]); in rxrpc_send_ACK()
214 rxrpc_inc_stat(call->rxnet, stat_tx_data_retrans); in rxrpc_resend()
347 rxrpc_inc_stat(call->rxnet, stat_tx_data_underflow); in rxrpc_transmit_some_data()
|
| D | input.c | 196 rxrpc_inc_stat(call->rxnet, stat_tx_data_cwnd_reset); in rxrpc_congestion_degrade()
379 rxrpc_inc_stat(call->rxnet, stat_rx_data); in rxrpc_input_data_one()
381 rxrpc_inc_stat(call->rxnet, stat_rx_data_reqack); in rxrpc_input_data_one()
383 rxrpc_inc_stat(call->rxnet, stat_rx_data_jumbo); in rxrpc_input_data_one()
802 rxrpc_inc_stat(call->rxnet, stat_rx_acks[ack.reason]); in rxrpc_input_ack()
|
| D | af_rxrpc.c | 769 struct rxrpc_net *rxnet; in rxrpc_create() local
809 rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_create()
810 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1); in rxrpc_create()
|
| D | io_thread.c | 432 rxrpc_inc_stat(local->rxnet, stat_io_loop); in rxrpc_io_thread()
|
| D | sendmsg.c | 245 rxrpc_inc_stat(call->rxnet, stat_tx_data); in rxrpc_queue_packet()
|
