| /linux/include/net/ |
| H A D | af_rxrpc.h | 17 struct rxrpc_call;
32 typedef void (*rxrpc_notify_rx_t)(struct sock *, struct rxrpc_call *,
34 typedef void (*rxrpc_notify_end_tx_t)(struct sock *, struct rxrpc_call *,
36 typedef void (*rxrpc_notify_new_call_t)(struct sock *, struct rxrpc_call *,
44 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock,
56 int rxrpc_kernel_send_data(struct socket *, struct rxrpc_call *,
59 int rxrpc_kernel_recv_data(struct socket *, struct rxrpc_call *,
61 bool rxrpc_kernel_abort_call(struct socket *, struct rxrpc_call *,
64 void rxrpc_kernel_put_call(struct socket *sock, struct rxrpc_call *call);
78 u32 rxrpc_kernel_get_epoch(struct socket *, struct rxrpc_call *);
[all …]
|
| /linux/net/rxrpc/ |
| H A D | ar-internal.h | 136 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
265 void (*free_call_crypto)(struct rxrpc_call *);
486 struct rxrpc_call *call; /* Active call */
614 struct rxrpc_call { struct
893 struct rxrpc_call *rxrpc_try_get_call(struct rxrpc_call *, enum rxrpc_call_trace);
896 void rxrpc_cleanup_call(struct rxrpc_call *);
916 bool rxrpc_call_completed(struct rxrpc_call *call);
968 void rxrpc_expose_client_call(struct rxrpc_call *);
1004 void rxrpc_disconnect_call(struct rxrpc_call *);
1152 int rxrpc_send_abort_packet(struct rxrpc_call *);
[all …]
|
| H A D | call_object.c | 89 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
125 struct rxrpc_call *call; in rxrpc_alloc_call()
195 struct rxrpc_call *call; in rxrpc_alloc_client_call()
329 struct rxrpc_call *call, *xcall; in rxrpc_new_client_call()
440 struct rxrpc_call *call, in rxrpc_incoming_call()
511 struct rxrpc_call *rxrpc_try_get_call(struct rxrpc_call *call, in rxrpc_try_get_call()
602 struct rxrpc_call *call; in rxrpc_release_calls_on_socket()
660 struct rxrpc_call *call = container_of(rcu, struct rxrpc_call, rcu); in rxrpc_rcu_free_call()
673 struct rxrpc_call *call = container_of(work, struct rxrpc_call, destroyer); in rxrpc_destroy_call()
728 struct rxrpc_call *call; in rxrpc_destroy_all_calls()
[all …]
|
| H A D | call_state.c | 13 bool rxrpc_set_call_completion(struct rxrpc_call *call, in rxrpc_set_call_completion()
35 bool rxrpc_call_completed(struct rxrpc_call *call) in rxrpc_call_completed()
43 bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_abort_call()
60 void rxrpc_prefail_call(struct rxrpc_call *call, enum rxrpc_call_completion compl, in rxrpc_prefail_call()
|
| H A D | insecure.c | 20 static struct rxrpc_txbuf *none_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp) in none_alloc_txbuf()
25 static int none_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in none_secure_packet()
30 static int none_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in none_verify_packet()
38 static void none_free_call_crypto(struct rxrpc_call *call) in none_free_call_crypto()
|
| H A D | sendmsg.c | 23 bool rxrpc_propose_abort(struct rxrpc_call *call, s32 abort_code, int error, in rxrpc_propose_abort()
45 static int rxrpc_wait_to_be_connected(struct rxrpc_call *call, long *timeo) in rxrpc_wait_to_be_connected()
105 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr()
129 struct rxrpc_call *call) in rxrpc_wait_for_tx_window_waitall()
169 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_nonintr()
190 struct rxrpc_call *call, in rxrpc_wait_for_tx_window()
278 struct rxrpc_call *call, in rxrpc_send_data()
556 static struct rxrpc_call *
564 struct rxrpc_call *call; in rxrpc_new_client_call_for_sendmsg()
611 struct rxrpc_call *call; in rxrpc_do_sendmsg()
[all …]
|
| H A D | call_event.c | 23 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial, in rxrpc_propose_ping()
40 void rxrpc_propose_delay_ACK(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_propose_delay_ACK()
60 static void rxrpc_congestion_timeout(struct rxrpc_call *call) in rxrpc_congestion_timeout()
68 void rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb) in rxrpc_resend()
205 static void rxrpc_begin_service_reply(struct rxrpc_call *call) in rxrpc_begin_service_reply()
218 static void rxrpc_close_tx_phase(struct rxrpc_call *call) in rxrpc_close_tx_phase()
234 static bool rxrpc_tx_window_has_space(struct rxrpc_call *call) in rxrpc_tx_window_has_space()
249 static void rxrpc_decant_prepared_tx(struct rxrpc_call *call) in rxrpc_decant_prepared_tx()
278 static void rxrpc_transmit_some_data(struct rxrpc_call *call) in rxrpc_transmit_some_data()
306 static void rxrpc_send_initial_ping(struct rxrpc_call *call) in rxrpc_send_initial_ping()
[all …]
|
| H A D | input.c | 23 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_proto_abort()
32 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management()
190 void rxrpc_congestion_degrade(struct rxrpc_call *call) in rxrpc_congestion_degrade()
217 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
261 static void rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
302 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
351 static void rxrpc_input_update_ack_window(struct rxrpc_call *call, in rxrpc_input_update_ack_window()
644 static void rxrpc_complete_rtt_probe(struct rxrpc_call *call, in rxrpc_complete_rtt_probe()
729 static rxrpc_seq_t rxrpc_input_check_prev_ack(struct rxrpc_call *call, in rxrpc_input_check_prev_ack()
771 static void rxrpc_input_soft_acks(struct rxrpc_call *call, in rxrpc_input_soft_acks()
[all …]
|
| H A D | output.c | 48 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret) in rxrpc_tx_backoff()
66 static void rxrpc_set_keepalive(struct rxrpc_call *call, ktime_t now) in rxrpc_set_keepalive()
77 static void rxrpc_fill_out_ack(struct rxrpc_call *call, in rxrpc_fill_out_ack()
150 static void rxrpc_begin_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_begin_rtt_probe()
178 static void rxrpc_send_ack_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxrpc_send_ack_packet()
232 void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_send_ACK()
263 int rxrpc_send_abort_packet(struct rxrpc_call *call) in rxrpc_send_abort_packet()
399 static void rxrpc_tstamp_data_packets(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxrpc_tstamp_data_packets()
432 static int rxrpc_send_data_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxrpc_send_data_packet()
699 static inline void rxrpc_instant_resend(struct rxrpc_call *call, in rxrpc_instant_resend()
[all …]
|
| H A D | recvmsg.c | 23 void rxrpc_notify_socket(struct rxrpc_call *call) in rxrpc_notify_socket()
64 static int rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) in rxrpc_recvmsg_term()
106 static void rxrpc_rotate_rx_window(struct rxrpc_call *call) in rxrpc_rotate_rx_window()
148 static int rxrpc_verify_data(struct rxrpc_call *call, struct sk_buff *skb) in rxrpc_verify_data()
163 static int rxrpc_recvmsg_data(struct socket *sock, struct rxrpc_call *call, in rxrpc_recvmsg_data()
281 struct rxrpc_call *call; in rxrpc_recvmsg()
342 call = list_entry(l, struct rxrpc_call, recvmsg_link); in rxrpc_recvmsg()
489 int rxrpc_kernel_recv_data(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_recv_data()
|
| H A D | call_accept.c | 25 static void rxrpc_dummy_notify(struct sock *sk, struct rxrpc_call *call, in rxrpc_dummy_notify()
41 struct rxrpc_call *call, *xcall; in rxrpc_service_prealloc_one()
115 xcall = rb_entry(parent, struct rxrpc_call, sock_node); in rxrpc_service_prealloc_one()
220 struct rxrpc_call *call = b->call_backlog[tail]; in rxrpc_discard_prealloc()
242 static struct rxrpc_call *rxrpc_alloc_incoming_call(struct rxrpc_sock *rx, in rxrpc_alloc_incoming_call()
251 struct rxrpc_call *call; in rxrpc_alloc_incoming_call()
337 struct rxrpc_call *call = NULL; in rxrpc_new_incoming_call()
|
| H A D | rxperf.c | 48 struct rxrpc_call *rxcall;
98 static void rxperf_rx_discard_new_call(struct rxrpc_call *rxcall, in rxperf_rx_discard_new_call()
104 static void rxperf_rx_new_call(struct sock *sk, struct rxrpc_call *rxcall, in rxperf_rx_new_call()
115 static void rxperf_notify_rx(struct sock *sk, struct rxrpc_call *rxcall, in rxperf_notify_rx()
124 static void rxperf_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in rxperf_rx_attach()
132 struct rxrpc_call *rxcall, in rxperf_notify_end_reply_tx()
|
| H A D | af_rxrpc.c | 328 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock, in rxrpc_kernel_begin_call()
343 struct rxrpc_call *call; in rxrpc_kernel_begin_call()
388 static void rxrpc_dummy_notify_rx(struct sock *sk, struct rxrpc_call *rxcall, in rxrpc_dummy_notify_rx()
401 void rxrpc_kernel_shutdown_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_shutdown_call()
427 void rxrpc_kernel_put_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_put_call()
442 const struct rxrpc_call *call) in rxrpc_kernel_check_life()
460 u32 rxrpc_kernel_get_epoch(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_epoch()
495 void rxrpc_kernel_set_max_life(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_set_max_life()
1030 "rxrpc_call_jar", sizeof(struct rxrpc_call), 0, in af_rxrpc_init()
|
| H A D | conn_client.c | 73 static struct rxrpc_bundle *rxrpc_alloc_bundle(struct rxrpc_call *call, in rxrpc_alloc_bundle()
250 int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp) in rxrpc_look_up_bundle()
417 struct rxrpc_call *call = list_entry(bundle->waiting_calls.next, in rxrpc_activate_one_channel()
418 struct rxrpc_call, wait_link); in rxrpc_activate_one_channel()
510 struct rxrpc_call *call; in rxrpc_connect_client_calls()
513 struct rxrpc_call, wait_link)) in rxrpc_connect_client_calls()
531 void rxrpc_expose_client_call(struct rxrpc_call *call) in rxrpc_expose_client_call()
571 void rxrpc_disconnect_client_call(struct rxrpc_bundle *bundle, struct rxrpc_call *call) in rxrpc_disconnect_client_call()
|
| H A D | txbuf.c | 19 struct rxrpc_txbuf *rxrpc_alloc_data_txbuf(struct rxrpc_call *call, size_t data_size, in rxrpc_alloc_data_txbuf()
85 struct rxrpc_txbuf *rxrpc_alloc_ack_txbuf(struct rxrpc_call *call, size_t sack_size) in rxrpc_alloc_ack_txbuf()
209 void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *call) in rxrpc_shrink_call_tx_buffer()
|
| H A D | rxkad.c | 148 static struct rxrpc_txbuf *rxkad_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp) in rxkad_alloc_txbuf()
233 static struct skcipher_request *rxkad_get_call_crypto(struct rxrpc_call *call) in rxkad_get_call_crypto()
243 static void rxkad_free_call_crypto(struct rxrpc_call *call) in rxkad_free_call_crypto()
250 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_secure_packet_auth()
292 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_secure_packet_encrypt()
337 static int rxkad_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxkad_secure_packet()
408 static int rxkad_verify_packet_1(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_1()
471 static int rxkad_verify_packet_2(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_2()
552 static int rxkad_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in rxkad_verify_packet()
|
| H A D | peer_event.c | 205 struct rxrpc_call *call; in rxrpc_distribute_error()
213 struct rxrpc_call, error_link); in rxrpc_distribute_error()
|
| H A D | io_thread.c | 339 struct rxrpc_call *call = NULL; in rxrpc_input_packet_on_conn()
435 struct rxrpc_call *call; in rxrpc_io_thread()
471 struct rxrpc_call, in rxrpc_io_thread()
|
| H A D | rtt.c | 147 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why, in rxrpc_peer_add_rtt()
|
| H A D | conn_event.c | 198 struct rxrpc_call *call; in rxrpc_abort_calls()
219 static void rxrpc_call_is_secure(struct rxrpc_call *call) in rxrpc_call_is_secure()
|
| H A D | conn_object.c | 150 struct rxrpc_call *call) in __rxrpc_disconnect_call()
189 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call()
|
| H A D | security.c | 68 int rxrpc_init_client_call_security(struct rxrpc_call *call) in rxrpc_init_client_call_security()
|
| /linux/include/trace/events/ |
| H A D | rxrpc.h | 683 TRACE_EVENT(rxrpc_call,
810 TP_PROTO(struct rxrpc_call *call),
899 TP_PROTO(struct rxrpc_call *call,
1400 TP_PROTO(struct rxrpc_call *call),
1594 TP_PROTO(struct rxrpc_call *call, ktime_t now),
1632 TP_PROTO(struct rxrpc_call *call),
1652 TP_PROTO(struct rxrpc_call *call),
1672 TP_PROTO(struct rxrpc_call *call),
1784 TP_PROTO(struct rxrpc_call *call),
1926 TP_PROTO(struct rxrpc_call *call, bool busy,
[all …]
|
| /linux/fs/afs/ |
| H A D | rxrpc.c | 22 static void afs_wake_up_call_waiter(struct sock *, struct rxrpc_call *, unsigned long);
23 static void afs_wake_up_async_call(struct sock *, struct rxrpc_call *, unsigned long);
25 static void afs_rx_new_call(struct sock *, struct rxrpc_call *, unsigned long);
26 static void afs_rx_discard_new_call(struct rxrpc_call *, unsigned long);
320 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
334 struct rxrpc_call *rxcall; in afs_make_call()
667 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
680 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
762 static void afs_rx_discard_new_call(struct rxrpc_call *rxcall, in afs_rx_discard_new_call()
774 static void afs_rx_new_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_rx_new_call()
[all …]
|
| /linux/Documentation/networking/ |
| H A D | rxrpc.rst | 802 struct rxrpc_call *
854 struct rxrpc_call *call);
863 struct rxrpc_call *call);
874 struct rxrpc_call *call,
896 struct rxrpc_call *call,
933 struct rxrpc_call *call,
988 struct rxrpc_call *
1026 struct rxrpc_call *call,
1044 struct rxrpc_call *call,
1047 struct rxrpc_call *call);
[all …]
|