| /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()
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 …]
|
| H A 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
74 conn->rxnet = rxnet; in rxrpc_alloc_connection()
212 rxrpc_set_service_reap_timer(conn->rxnet, in rxrpc_disconnect_call()
277 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, in rxrpc_set_service_reap_timer()
280 if (rxnet->live) in rxrpc_set_service_reap_timer()
281 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); in rxrpc_set_service_reap_timer()
291 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_rcu_free_connection()
276 rxrpc_set_service_reap_timer(struct rxrpc_net * rxnet,unsigned long reap_at) rxrpc_set_service_reap_timer() argument
290 struct rxrpc_net *rxnet = conn->rxnet; rxrpc_rcu_free_connection() local
309 struct rxrpc_net *rxnet = conn->rxnet; rxrpc_clean_up_connection() local
388 struct rxrpc_net *rxnet = rxrpc_service_connection_reaper() local
464 rxrpc_destroy_all_connections(struct rxrpc_net * rxnet) rxrpc_destroy_all_connections() argument
[all...] |
| H A D | peer_event.c | 243 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet, in rxrpc_peer_keepalive_dispatch() argument
249 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_dispatch()
254 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
265 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
285 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
287 &rxnet->peer_keepalive[slot & mask]); in rxrpc_peer_keepalive_dispatch()
288 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
292 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
295 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
303 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
[all …]
|
| H A D | peer_object.c | 122 struct rxrpc_net *rxnet = local->rxnet; in __rxrpc_lookup_peer_rcu() local
124 hash_for_each_possible_rcu(rxnet->peer_hash, peer, hash_link, hash_key) { in __rxrpc_lookup_peer_rcu()
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()
326 hash_add_rcu(rxnet->peer_hash, &peer->hash_link, hash_key); in rxrpc_new_incoming_peer()
327 list_add_tail(&peer->keepalive_link, &rxnet->peer_keepalive_new); 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()
[all …]
|
| H A D | call_object.c | 125 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()
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()
389 list_add_tail_rcu(&call->link, &rxnet->calls); 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
658 spin_lock(&rxnet->call_lock); in rxrpc_put_call()
[all …]
|
| H A D | conn_client.c | 95 write_lock(&bundle->local->rxnet->conn_lock); in rxrpc_alloc_bundle()
96 list_add_tail(&bundle->proc_link, &bundle->local->rxnet->bundle_proc_list); in rxrpc_alloc_bundle()
97 write_unlock(&bundle->local->rxnet->conn_lock); in rxrpc_alloc_bundle()
116 write_lock(&bundle->local->rxnet->conn_lock); in rxrpc_free_bundle()
118 write_unlock(&bundle->local->rxnet->conn_lock); in rxrpc_free_bundle()
156 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_alloc_client_connection() local
161 conn = rxrpc_alloc_connection(rxnet, GFP_ATOMIC | __GFP_NOWARN); in rxrpc_alloc_client_connection()
174 conn->proto.epoch = local->rxnet->epoch; in rxrpc_alloc_client_connection()
191 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
192 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
[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 | 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 …]
|
| H 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()
|
| H 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
|
| H 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()
|
| H 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()
|
| H A D | io_thread.c | 470 rxrpc_inc_stat(local->rxnet, stat_io_loop); in rxrpc_io_thread()
|
| H A D | sendmsg.c | 249 rxrpc_inc_stat(call->rxnet, stat_tx_data); in rxrpc_queue_packet()
|