Searched refs:rxnet (Results 1 - 17 of 17) sorted by relevance

/linux-master/net/rxrpc/
H A Dnet_ns.c15 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 Dproc.c30 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 Dpeer_event.c230 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 Dconn_object.c23 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 Dpeer_object.c122 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 Dconn_service.c120 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 Dlocal_object.c120 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 Dcall_object.c126 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 Dconn_client.c95 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 Dcall_accept.c42 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 Dar-internal.h292 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 Doutput.c92 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 Dinput.c195 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 Dcall_event.c169 rxrpc_inc_stat(call->rxnet, stat_tx_data_retrans);
292 rxrpc_inc_stat(call->rxnet, stat_tx_data_underflow);
H A Daf_rxrpc.c815 struct rxrpc_net *rxnet; local
855 rxnet = rxrpc_net(sock_net(&rx->sk));
856 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + 1);
H A Dio_thread.c443 rxrpc_inc_stat(local->rxnet, stat_io_loop);
H A Dsendmsg.c245 rxrpc_inc_stat(call->rxnet, stat_tx_data);

Completed in 236 milliseconds