| /linux/net/rxrpc/ |
| H A 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()
24 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_timeout() local
27 if (rxnet->live) in rxrpc_peer_keepalive_timeout()
39 rxnet->live = true; in rxrpc_init_net()
40 get_random_bytes(&rxnet->epoch, sizeof(rxnet->epoch)); in rxrpc_init_net()
43 INIT_LIST_HEAD(&rxnet->calls); in rxrpc_init_net()
62 hash_init(rxnet->peer_hash); in rxrpc_init_net()
74 if (!rxnet->proc_net) in rxrpc_init_net()
96 rxnet->live = false; in rxrpc_init_net()
[all …]
|
| H A D | proc.c | 59 if (v == &rxnet->calls) { in rxrpc_call_seq_show()
116 __acquires(rxnet->conn_lock) in rxrpc_connection_seq_start()
120 read_lock(&rxnet->conn_lock); in rxrpc_connection_seq_start()
133 __releases(rxnet->conn_lock) in rxrpc_connection_seq_stop()
137 read_unlock(&rxnet->conn_lock); in rxrpc_connection_seq_stop()
203 __acquires(rxnet->conn_lock) in rxrpc_bundle_seq_start()
207 read_lock(&rxnet->conn_lock); in rxrpc_bundle_seq_start()
220 __releases(rxnet->conn_lock) in rxrpc_bundle_seq_stop()
568 memset(&rxnet->stat_tx_acks, 0, sizeof(rxnet->stat_tx_acks)); in rxrpc_stats_clear()
569 memset(&rxnet->stat_rx_acks, 0, sizeof(rxnet->stat_rx_acks)); in rxrpc_stats_clear()
[all …]
|
| H A D | peer_event.c | 241 spin_lock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
272 spin_lock(&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
298 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
302 if (!rxnet->live) in rxrpc_peer_keepalive_worker()
312 spin_lock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
324 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
326 rxnet->peer_keepalive_base = base; in rxrpc_peer_keepalive_worker()
[all …]
|
| H A D | conn_object.c | 73 conn->rxnet = rxnet; in rxrpc_alloc_connection()
278 if (rxnet->live) in rxrpc_set_service_reap_timer()
289 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_rcu_free_connection() local
298 wake_up_var(&rxnet->nr_conns); in rxrpc_rcu_free_connection()
308 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_clean_up_connection() local
320 write_lock(&rxnet->conn_lock); in rxrpc_clean_up_connection()
383 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
395 write_lock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
466 atomic_dec(&rxnet->nr_conns); in rxrpc_destroy_all_connections()
472 write_lock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
[all …]
|
| H A D | peer_object.c | 122 struct rxrpc_net *rxnet = local->rxnet; in __rxrpc_lookup_peer_rcu() local
310 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_new_incoming_peer() local
316 spin_lock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
319 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
329 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_lookup_peer() local
351 spin_lock(&rxnet->peer_hash_lock); in rxrpc_lookup_peer()
358 hash_add_rcu(rxnet->peer_hash, in rxrpc_lookup_peer()
361 &rxnet->peer_keepalive_new); in rxrpc_lookup_peer()
410 struct rxrpc_net *rxnet = peer->local->rxnet; in __rxrpc_put_peer() local
414 spin_lock(&rxnet->peer_hash_lock); in __rxrpc_put_peer()
[all …]
|
| H A D | call_object.c | 180 call->rxnet = rxnet; in rxrpc_alloc_call()
182 atomic_inc(&rxnet->nr_calls); in rxrpc_alloc_call()
330 struct rxrpc_net *rxnet; in rxrpc_new_client_call() local
388 rxnet = call->rxnet; in rxrpc_new_client_call()
389 spin_lock(&rxnet->call_lock); in rxrpc_new_client_call()
391 spin_unlock(&rxnet->call_lock); in rxrpc_new_client_call()
633 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_put_call() local
661 struct rxrpc_net *rxnet = READ_ONCE(call->rxnet); in rxrpc_rcu_free_call() local
733 spin_lock(&rxnet->call_lock); in rxrpc_destroy_all_calls()
756 atomic_dec(&rxnet->nr_calls); in rxrpc_destroy_all_calls()
[all …]
|
| H A D | local_object.c | 120 local->rxnet = rxrpc_net(net); in rxrpc_alloc_local()
254 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_lookup_local() local
262 mutex_lock(&rxnet->local_mutex); in rxrpc_lookup_local()
308 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
315 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
322 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
426 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_destroy_local() local
432 mutex_lock(&rxnet->local_mutex); in rxrpc_destroy_local()
434 mutex_unlock(&rxnet->local_mutex); in rxrpc_destroy_local()
483 mutex_lock(&rxnet->local_mutex); in rxrpc_destroy_all_locals()
[all …]
|
| H A D | conn_client.c | 156 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_alloc_client_connection() local
191 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
192 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
194 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
198 atomic_inc(&rxnet->nr_client_conns); in rxrpc_alloc_client_connection()
208 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
214 rxnet = conn->rxnet; in rxrpc_may_reuse_conn()
220 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
563 if (local->rxnet->live) in rxrpc_set_client_reap_timer()
727 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
[all …]
|
| H A D | conn_service.c | 120 struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *rxnet, in rxrpc_prealloc_service_connection() argument
123 struct rxrpc_connection *conn = rxrpc_alloc_connection(rxnet, gfp); in rxrpc_prealloc_service_connection()
132 atomic_inc(&rxnet->nr_conns); in rxrpc_prealloc_service_connection()
133 write_lock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
134 list_add_tail(&conn->link, &rxnet->service_conns); in rxrpc_prealloc_service_connection()
135 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_prealloc_service_connection()
136 write_unlock(&rxnet->conn_lock); in rxrpc_prealloc_service_connection()
|
| H A 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 …]
|
| H A D | output.c | 92 rxrpc_inc_stat(call->rxnet, stat_tx_ack_fill); in rxrpc_fill_out_ack()
207 rxrpc_inc_stat(call->rxnet, stat_tx_ack_send); in rxrpc_send_ack_packet()
240 rxrpc_inc_stat(call->rxnet, stat_tx_acks[ack_reason]); in rxrpc_send_ACK()
368 rxrpc_inc_stat(call->rxnet, stat_why_req_ack[why]); in rxrpc_prepare_data_subpacket()
487 rxrpc_inc_stat(call->rxnet, stat_tx_data_send); in rxrpc_send_data_packet()
492 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_fail); in rxrpc_send_data_packet()
664 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
|
| H A D | ar-internal.h | 292 struct rxrpc_net *rxnet; /* Our bits in the network namespace */ member
474 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
621 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
1267 #define rxrpc_inc_stat(rxnet, s) atomic_inc(&(rxnet)->s) argument
1268 #define rxrpc_dec_stat(rxnet, s) atomic_dec(&(rxnet)->s) argument
|
| H A D | input.c | 206 rxrpc_inc_stat(call->rxnet, stat_tx_data_cwnd_reset); in rxrpc_congestion_degrade()
392 rxrpc_inc_stat(call->rxnet, stat_rx_data); in rxrpc_input_data_one()
394 rxrpc_inc_stat(call->rxnet, stat_rx_data_reqack); in rxrpc_input_data_one()
396 rxrpc_inc_stat(call->rxnet, stat_rx_data_jumbo); in rxrpc_input_data_one()
877 rxrpc_inc_stat(call->rxnet, stat_rx_acks[summary.ack_reason]); in rxrpc_input_ack()
|
| H A D | call_event.c | 169 rxrpc_inc_stat(call->rxnet, stat_tx_data_retrans); in rxrpc_resend()
292 rxrpc_inc_stat(call->rxnet, stat_tx_data_underflow); in rxrpc_transmit_some_data()
|
| H A D | af_rxrpc.c | 815 struct rxrpc_net *rxnet; in rxrpc_create() local
855 rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_create()
856 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1); in rxrpc_create()
|
| H A D | io_thread.c | 449 rxrpc_inc_stat(local->rxnet, stat_io_loop); in rxrpc_io_thread()
|
| H A D | sendmsg.c | 245 rxrpc_inc_stat(call->rxnet, stat_tx_data); in rxrpc_queue_packet()
|