| /net/rxrpc/ |
| 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 …]
|
| 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()
203 __acquires(rxnet->conn_lock) in rxrpc_bundle_seq_start()
220 __releases(rxnet->conn_lock) in rxrpc_bundle_seq_stop()
591 memset(&rxnet->stat_tx_acks, 0, sizeof(rxnet->stat_tx_acks)); in rxrpc_stats_clear()
592 memset(&rxnet->stat_rx_acks, 0, sizeof(rxnet->stat_rx_acks)); in rxrpc_stats_clear()
593 memset(&rxnet->stat_tx_jumbo, 0, sizeof(rxnet->stat_tx_jumbo)); in rxrpc_stats_clear()
594 memset(&rxnet->stat_rx_jumbo, 0, sizeof(rxnet->stat_rx_jumbo)); in rxrpc_stats_clear()
[all …]
|
| A D | conn_object.c | 74 conn->rxnet = rxnet; in rxrpc_alloc_connection()
280 if (rxnet->live) in rxrpc_set_service_reap_timer()
291 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_rcu_free_connection() local
300 wake_up_var(&rxnet->nr_conns); in rxrpc_rcu_free_connection()
310 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_clean_up_connection() local
322 write_lock(&rxnet->conn_lock); in rxrpc_clean_up_connection()
390 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
402 write_lock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
473 atomic_dec(&rxnet->nr_conns); in rxrpc_destroy_all_connections()
479 write_lock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
[all …]
|
| A D | peer_event.c | 254 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
292 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
303 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
311 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
312 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
315 if (!rxnet->live) in rxrpc_peer_keepalive_worker()
325 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
339 rxnet->peer_keepalive_base = base; in rxrpc_peer_keepalive_worker()
340 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
345 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
[all …]
|
| A D | peer_object.c | 122 struct rxrpc_net *rxnet = local->rxnet; in __rxrpc_lookup_peer_rcu() local
319 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_new_incoming_peer() local
325 spin_lock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
328 spin_unlock(&rxnet->peer_hash_lock); in rxrpc_new_incoming_peer()
338 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_lookup_peer() local
360 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_lookup_peer()
367 hash_add_rcu(rxnet->peer_hash, in rxrpc_lookup_peer()
370 &rxnet->peer_keepalive_new); in rxrpc_lookup_peer()
419 struct rxrpc_net *rxnet = peer->local->rxnet; in __rxrpc_put_peer() local
423 spin_lock_bh(&rxnet->peer_hash_lock); in __rxrpc_put_peer()
[all …]
|
| A D | call_object.c | 179 call->rxnet = rxnet; in rxrpc_alloc_call()
181 atomic_inc(&rxnet->nr_calls); in rxrpc_alloc_call()
329 struct rxrpc_net *rxnet; in rxrpc_new_client_call() local
387 rxnet = call->rxnet; in rxrpc_new_client_call()
388 spin_lock(&rxnet->call_lock); in rxrpc_new_client_call()
390 spin_unlock(&rxnet->call_lock); in rxrpc_new_client_call()
645 struct rxrpc_net *rxnet = call->rxnet; in rxrpc_put_call() local
673 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 …]
|
| A D | local_object.c | 120 local->rxnet = rxrpc_net(net); in rxrpc_alloc_local()
251 struct rxrpc_net *rxnet = rxrpc_net(net); in rxrpc_lookup_local() local
259 mutex_lock(&rxnet->local_mutex); in rxrpc_lookup_local()
305 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
312 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
319 mutex_unlock(&rxnet->local_mutex); in rxrpc_lookup_local()
423 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_destroy_local() local
429 mutex_lock(&rxnet->local_mutex); in rxrpc_destroy_local()
431 mutex_unlock(&rxnet->local_mutex); in rxrpc_destroy_local()
478 mutex_lock(&rxnet->local_mutex); in rxrpc_destroy_all_locals()
[all …]
|
| 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()
565 if (local->rxnet->live) in rxrpc_set_client_reap_timer()
729 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
[all …]
|
| 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()
|
| A D | call_accept.c | 41 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()
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()
182 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_discard_prealloc() local
208 write_lock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
211 write_unlock(&rxnet->conn_lock); in rxrpc_discard_prealloc()
213 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_discard_prealloc()
[all …]
|
| A D | output.c | 166 rxrpc_inc_stat(call->rxnet, stat_tx_ack_fill); in rxrpc_fill_out_ack()
272 rxrpc_inc_stat(call->rxnet, stat_tx_ack_send); in rxrpc_send_ack_packet()
313 rxrpc_inc_stat(call->rxnet, stat_tx_acks[ack_reason]); in rxrpc_send_ACK()
485 rxrpc_inc_stat(call->rxnet, stat_why_req_ack[why]); in rxrpc_prepare_data_subpacket()
661 stat_ix = umin(req->n, ARRAY_SIZE(call->rxnet->stat_tx_jumbo)) - 1; in rxrpc_send_data_packet()
662 atomic_inc(&call->rxnet->stat_tx_jumbo[stat_ix]); in rxrpc_send_data_packet()
712 rxrpc_inc_stat(call->rxnet, stat_tx_data_send); in rxrpc_send_data_packet()
717 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_msgsize); in rxrpc_send_data_packet()
721 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_fail); in rxrpc_send_data_packet()
892 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
|
| A D | ar-internal.h | 334 struct rxrpc_net *rxnet; /* Our bits in the network namespace */ member
528 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
700 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member
1493 #define rxrpc_inc_stat(rxnet, s) atomic_inc(&(rxnet)->s) argument
1494 #define rxrpc_dec_stat(rxnet, s) atomic_dec(&(rxnet)->s) argument
|
| A D | input.c | 194 rxrpc_inc_stat(call->rxnet, stat_tx_data_cwnd_reset); in rxrpc_congestion_degrade()
483 rxrpc_inc_stat(call->rxnet, stat_rx_data); in rxrpc_input_data_one()
485 rxrpc_inc_stat(call->rxnet, stat_rx_data_reqack); in rxrpc_input_data_one()
487 rxrpc_inc_stat(call->rxnet, stat_rx_data_jumbo); in rxrpc_input_data_one()
657 stat_ix = umin(count, ARRAY_SIZE(call->rxnet->stat_rx_jumbo)) - 1; in rxrpc_input_split_jumbo()
658 atomic_inc(&call->rxnet->stat_rx_jumbo[stat_ix]); in rxrpc_input_split_jumbo()
1078 rxrpc_inc_stat(call->rxnet, stat_rx_acks[summary.ack_reason]); in rxrpc_input_ack()
|
| A D | call_event.c | 74 rxrpc_inc_stat(call->rxnet, stat_tx_data_retrans); in rxrpc_retransmit_data()
274 rxrpc_inc_stat(call->rxnet, stat_tx_data_underflow); in rxrpc_transmit_some_data()
|
| A D | af_rxrpc.c | 807 struct rxrpc_net *rxnet; in rxrpc_create() local
849 rxnet = rxrpc_net(sock_net(&rx->sk)); in rxrpc_create()
850 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1); in rxrpc_create()
|
| A D | io_thread.c | 470 rxrpc_inc_stat(local->rxnet, stat_io_loop); in rxrpc_io_thread()
|
| A D | sendmsg.c | 249 rxrpc_inc_stat(call->rxnet, stat_tx_data); in rxrpc_queue_packet()
|