/linux-master/net/rxrpc/ |
H A D | net_ns.c | 15 struct rxrpc_net *rxnet = local 18 if (rxnet->live) 19 rxrpc_queue_work(&rxnet->service_conn_reaper); 24 struct rxrpc_net *rxnet = local 27 if (rxnet->live) 28 rxrpc_queue_work(&rxnet->peer_keepalive_work); 36 struct rxrpc_net *rxnet = rxrpc_net(net); local 39 rxnet->live = true; 40 get_random_bytes(&rxnet->epoch, sizeof(rxnet 105 struct rxrpc_net *rxnet = rxrpc_net(net); local [all...] |
H A D | proc.c | 30 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 33 return seq_list_start_head_rcu(&rxnet->calls, *_pos); 38 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 40 return seq_list_next_rcu(v, &rxnet->calls, pos); 53 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 59 if (v == &rxnet->calls) { 116 __acquires(rxnet->conn_lock) 118 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); variable in typeref:struct:rxrpc_net 120 read_lock(&rxnet->conn_lock); 121 return seq_list_start_head(&rxnet 127 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 135 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); variable in typeref:struct:rxrpc_net 143 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 205 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); variable in typeref:struct:rxrpc_net 214 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 222 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); variable in typeref:struct:rxrpc_net 230 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 318 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 353 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 433 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 450 struct rxrpc_net *rxnet = rxrpc_net(seq_file_net(seq)); local 476 struct rxrpc_net *rxnet = rxrpc_net(seq_file_single_net(seq)); local 549 struct rxrpc_net *rxnet = rxrpc_net(seq_file_single_net(m)); local [all...] |
H A D | peer_event.c | 230 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet, argument 236 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; 241 spin_lock(&rxnet->peer_hash_lock); 252 spin_unlock(&rxnet->peer_hash_lock); 272 spin_lock(&rxnet->peer_hash_lock); 274 &rxnet->peer_keepalive[slot & mask]); 275 spin_unlock(&rxnet->peer_hash_lock); 279 spin_lock(&rxnet->peer_hash_lock); 282 spin_unlock(&rxnet->peer_hash_lock); 290 struct rxrpc_net *rxnet local [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, argument 73 conn->rxnet = rxnet; 215 rxrpc_set_service_reap_timer(conn->rxnet, 280 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, argument 283 if (rxnet->live) 284 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); 294 struct rxrpc_net *rxnet = conn->rxnet; local 313 struct rxrpc_net *rxnet = conn->rxnet; local 388 struct rxrpc_net *rxnet = local 464 rxrpc_destroy_all_connections(struct rxrpc_net *rxnet) argument [all...] |
H A D | peer_object.c | 122 struct rxrpc_net *rxnet = local->rxnet; local 124 hash_for_each_possible_rcu(rxnet->peer_hash, peer, hash_link, hash_key) { 310 struct rxrpc_net *rxnet = local->rxnet; local 316 spin_lock(&rxnet->peer_hash_lock); 317 hash_add_rcu(rxnet->peer_hash, &peer->hash_link, hash_key); 318 list_add_tail(&peer->keepalive_link, &rxnet->peer_keepalive_new); 319 spin_unlock(&rxnet->peer_hash_lock); 329 struct rxrpc_net *rxnet local 410 struct rxrpc_net *rxnet = peer->local->rxnet; local 443 rxrpc_destroy_all_peers(struct rxrpc_net *rxnet) argument [all...] |
H A D | conn_service.c | 120 struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *rxnet, argument 123 struct rxrpc_connection *conn = rxrpc_alloc_connection(rxnet, gfp); 132 atomic_inc(&rxnet->nr_conns); 133 write_lock(&rxnet->conn_lock); 134 list_add_tail(&conn->link, &rxnet->service_conns); 135 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); 136 write_unlock(&rxnet->conn_lock);
|
H A D | local_object.c | 120 local->rxnet = rxrpc_net(net); 254 struct rxrpc_net *rxnet = rxrpc_net(net); local 262 mutex_lock(&rxnet->local_mutex); 264 hlist_for_each(cursor, &rxnet->local_endpoints) { 304 hlist_add_head_rcu(&local->link, &rxnet->local_endpoints); 308 mutex_unlock(&rxnet->local_mutex); 315 mutex_unlock(&rxnet->local_mutex); 322 mutex_unlock(&rxnet->local_mutex); 426 struct rxrpc_net *rxnet = local->rxnet; local 474 rxrpc_destroy_all_locals(struct rxrpc_net *rxnet) argument [all...] |
H A D | call_object.c | 126 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); local 185 call->rxnet = rxnet; 187 atomic_inc(&rxnet->nr_calls); 335 struct rxrpc_net *rxnet; variable in typeref:struct:rxrpc_net 393 rxnet = call->rxnet; 394 spin_lock(&rxnet->call_lock); 395 list_add_tail_rcu(&call->link, &rxnet->calls); 396 spin_unlock(&rxnet 638 struct rxrpc_net *rxnet = call->rxnet; local 666 struct rxrpc_net *rxnet = READ_ONCE(call->rxnet); local 731 rxrpc_destroy_all_calls(struct rxrpc_net *rxnet) argument [all...] |
H A D | conn_client.c | 95 write_lock(&bundle->local->rxnet->conn_lock); 96 list_add_tail(&bundle->proc_link, &bundle->local->rxnet->bundle_proc_list); 97 write_unlock(&bundle->local->rxnet->conn_lock); 116 write_lock(&bundle->local->rxnet->conn_lock); 118 write_unlock(&bundle->local->rxnet->conn_lock); 156 struct rxrpc_net *rxnet = local->rxnet; local 161 conn = rxrpc_alloc_connection(rxnet, GFP_ATOMIC | __GFP_NOWARN); 174 conn->proto.epoch = local->rxnet->epoch; 191 atomic_inc(&rxnet 208 struct rxrpc_net *rxnet; local 723 struct rxrpc_net *rxnet = local->rxnet; local [all...] |
H A D | call_accept.c | 42 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); local 87 conn = rxrpc_prealloc_service_connection(rxnet, gfp); 140 rxnet = call->rxnet; 141 spin_lock(&rxnet->call_lock); 142 list_add_tail_rcu(&call->link, &rxnet->calls); 143 spin_unlock(&rxnet->call_lock); 181 struct rxrpc_net *rxnet = rxrpc_net(sock_net(&rx->sk)); local 207 write_lock(&rxnet->conn_lock); 210 write_unlock(&rxnet [all...] |
H A D | ar-internal.h | 292 struct rxrpc_net *rxnet; /* Our bits in the network namespace */ member in struct:rxrpc_local 474 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member in struct:rxrpc_connection 621 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ member in struct:rxrpc_call 1269 #define rxrpc_inc_stat(rxnet, s) atomic_inc(&(rxnet)->s) 1270 #define rxrpc_dec_stat(rxnet, s) atomic_dec(&(rxnet)->s)
|
H A D | output.c | 92 rxrpc_inc_stat(call->rxnet, stat_tx_ack_fill); 207 rxrpc_inc_stat(call->rxnet, stat_tx_ack_send); 240 rxrpc_inc_stat(call->rxnet, stat_tx_acks[ack_reason]); 368 rxrpc_inc_stat(call->rxnet, stat_why_req_ack[why]); 487 rxrpc_inc_stat(call->rxnet, stat_tx_data_send); 492 rxrpc_inc_stat(call->rxnet, stat_tx_data_send_fail); 664 whdr.epoch = htonl(peer->local->rxnet->epoch);
|
H A D | input.c | 195 rxrpc_inc_stat(call->rxnet, stat_tx_data_cwnd_reset); 381 rxrpc_inc_stat(call->rxnet, stat_rx_data); 383 rxrpc_inc_stat(call->rxnet, stat_rx_data_reqack); 385 rxrpc_inc_stat(call->rxnet, stat_rx_data_jumbo); 856 rxrpc_inc_stat(call->rxnet, stat_rx_acks[summary.ack_reason]);
|
H A D | call_event.c | 169 rxrpc_inc_stat(call->rxnet, stat_tx_data_retrans); 292 rxrpc_inc_stat(call->rxnet, stat_tx_data_underflow);
|
H A D | af_rxrpc.c | 815 struct rxrpc_net *rxnet; local 855 rxnet = rxrpc_net(sock_net(&rx->sk)); 856 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1);
|
H A D | io_thread.c | 443 rxrpc_inc_stat(local->rxnet, stat_io_loop);
|
H A D | sendmsg.c | 245 rxrpc_inc_stat(call->rxnet, stat_tx_data);
|