| /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 *,
38 typedef void (*rxrpc_discard_new_call_t)(struct rxrpc_call *, unsigned long);
39 typedef void (*rxrpc_user_attach_call_t)(struct rxrpc_call *, unsigned long);
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 *,
[all …]
|
| /linux/net/rxrpc/ |
| H A D | ar-internal.h | 140 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
259 struct rxrpc_txbuf *(*alloc_txbuf)(struct rxrpc_call *call, size_t remaining, gfp_t gfp);
262 int (*secure_packet)(struct rxrpc_call *, struct rxrpc_txbuf *);
265 int (*verify_packet)(struct rxrpc_call *, struct sk_buff *);
268 void (*free_call_crypto)(struct rxrpc_call *);
497 struct rxrpc_call *call; /* Active call */
640 struct rxrpc_call { struct
981 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
983 void rxrpc_propose_delay_ACK(struct rxrpc_call *, rxrpc_serial_t,
985 void rxrpc_resend_tlp(struct rxrpc_call *call);
[all …]
|
| H A D | call_object.c | 45 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what) in rxrpc_poke_call()
67 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired()
85 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx, in rxrpc_find_call_by_user_ID()
88 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
97 call = rb_entry(p, struct rxrpc_call, sock_node); in rxrpc_find_call_by_user_ID()
121 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp, in rxrpc_alloc_call()
124 struct rxrpc_call *call; in rxrpc_alloc_call()
188 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx, in rxrpc_alloc_client_call()
194 struct rxrpc_call *call; in rxrpc_alloc_client_call()
247 void rxrpc_start_call_timer(struct rxrpc_call *call) in rxrpc_start_call_timer()
[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 | sendmsg.c | 23 bool rxrpc_propose_abort(struct rxrpc_call *call, s32 abort_code, int error, in rxrpc_propose_abort()
46 static int rxrpc_wait_to_be_connected(struct rxrpc_call *call, long *timeo) in rxrpc_wait_to_be_connected()
95 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space()
108 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr()
132 struct rxrpc_call *call) in rxrpc_wait_for_tx_window_waitall()
172 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_nonintr()
193 struct rxrpc_call *call, in rxrpc_wait_for_tx_window()
229 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_notify_end_tx()
241 static void rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_queue_packet()
281 static int rxrpc_alloc_txqueue(struct sock *sk, struct rxrpc_call *call) in rxrpc_alloc_txqueue()
[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()
177 void rxrpc_congestion_degrade(struct rxrpc_call *call) in rxrpc_congestion_degrade()
204 static void rxrpc_add_data_rtt_sample(struct rxrpc_call *call, in rxrpc_add_data_rtt_sample()
220 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
347 static void rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
385 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
409 static void rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) in rxrpc_end_rx_phase()
434 static void rxrpc_input_update_ack_window(struct rxrpc_call *call, in rxrpc_input_update_ack_window()
444 static void rxrpc_input_queue_data(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_input_queue_data()
[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 int rxrpc_alloc_ack(struct rxrpc_call *call, size_t sack_size) in rxrpc_alloc_ack()
114 static void rxrpc_free_ack(struct rxrpc_call *call) in rxrpc_free_ack()
124 static void rxrpc_begin_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_begin_rtt_probe()
152 static int rxrpc_fill_out_ack(struct rxrpc_call *call, int nr_kv, u8 ack_reason, in rxrpc_fill_out_ack()
245 static void rxrpc_send_ack_packet(struct rxrpc_call *call, int nr_kv, size_t len, in rxrpc_send_ack_packet()
302 void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_send_ACK()
355 void rxrpc_send_probe_for_pmtud(struct rxrpc_call *call) in rxrpc_send_probe_for_pmtud()
364 int rxrpc_send_abort_packet(struct rxrpc_call *call) in rxrpc_send_abort_packet()
[all …]
|
| 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 | rxkad.c | 148 static struct rxrpc_txbuf *rxkad_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp) in rxkad_alloc_txbuf()
239 static struct skcipher_request *rxkad_get_call_crypto(struct rxrpc_call *call) in rxkad_get_call_crypto()
249 static void rxkad_free_call_crypto(struct rxrpc_call *call) in rxkad_free_call_crypto()
256 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_secure_packet_auth()
297 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_secure_packet_encrypt()
338 static int rxkad_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxkad_secure_packet()
422 static int rxkad_verify_packet_1(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_1()
485 static int rxkad_verify_packet_2(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_2()
566 static int rxkad_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in rxkad_verify_packet()
|
| 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()
|
| H A D | conn_event.c | 205 struct rxrpc_call *call; in rxrpc_abort_calls()
229 static void rxrpc_call_is_secure(struct rxrpc_call *call) in rxrpc_call_is_secure()
|
| H A D | peer_event.c | 218 struct rxrpc_call *call; in rxrpc_distribute_error()
226 struct rxrpc_call, error_link); in rxrpc_distribute_error()
|
| H A D | conn_object.c | 151 struct rxrpc_call *call) in __rxrpc_disconnect_call()
190 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call()
|
| H A D | peer_object.c | 479 struct rxrpc_peer *rxrpc_kernel_get_call_peer(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_call_peer()
|
| /linux/include/trace/events/ |
| H A D | rxrpc.h | 761 TRACE_EVENT(rxrpc_call,
855 TP_PROTO(const struct rxrpc_call *call, int abort_code),
913 TP_PROTO(struct rxrpc_call *call),
939 TP_PROTO(struct rxrpc_call *call, enum rxrpc_txqueue_trace why),
975 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t send_top, int space),
1016 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq, rxrpc_seq_t to),
1069 TP_PROTO(struct rxrpc_call *call, struct rxrpc_skb_priv *sp),
1107 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1214 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1273 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
[all …]
|
| H A D | afs.h | 627 TP_PROTO(struct rxrpc_call *rxcall, struct afs_call *call),
874 __field(struct rxrpc_call *, rx_call)
|
| /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);
306 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
320 struct rxrpc_call *rxcall; in afs_make_call()
659 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
672 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
710 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in afs_rx_attach()
754 static void afs_rx_discard_new_call(struct rxrpc_call *rxcall, in afs_rx_discard_new_call()
[all …]
|
| H A D | internal.h | 134 struct rxrpc_call *rxcall; /* RxRPC call handle */
|
| /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 *
1018 void rxrpc_kernel_get_peer(struct socket *sock, struct rxrpc_call *call,
1026 struct rxrpc_call *call,
1036 u64 rxrpc_kernel_get_rtt(struct socket *sock, struct rxrpc_call *call);
[all …]
|