| /linux/net/rxrpc/ |
| H A D | ar-internal.h | 162 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
295 struct rxrpc_txbuf *(*alloc_txbuf)(struct rxrpc_call *call, size_t remaining, gfp_t gfp);
298 int (*secure_packet)(struct rxrpc_call *, struct rxrpc_txbuf *);
301 int (*verify_packet)(struct rxrpc_call *, struct sk_buff *);
304 void (*free_call_crypto)(struct rxrpc_call *);
558 struct rxrpc_call *call; /* Active call */
713 struct rxrpc_call { struct
1062 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
1064 void rxrpc_propose_delay_ACK(struct rxrpc_call *, rxrpc_serial_t,
1066 void rxrpc_resend_tlp(struct rxrpc_call *call);
[all …]
|
| H A D | call_object.c | 47 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what) in rxrpc_poke_call()
69 struct rxrpc_call *call = timer_container_of(call, t, timer); in rxrpc_call_timer_expired()
87 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx, in rxrpc_find_call_by_user_ID()
90 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
99 call = rb_entry(p, struct rxrpc_call, sock_node); in rxrpc_find_call_by_user_ID()
123 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp, in rxrpc_alloc_call()
126 struct rxrpc_call *call; in rxrpc_alloc_call()
191 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx, in rxrpc_alloc_client_call()
197 struct rxrpc_call *call; in rxrpc_alloc_client_call()
250 void rxrpc_start_call_timer(struct rxrpc_call *call) in rxrpc_start_call_timer()
[all …]
|
| H A D | input_rack.c | 23 static void rxrpc_rack_mark_lost(struct rxrpc_call *call, in rxrpc_rack_mark_lost()
62 static void rxrpc_rack_update(struct rxrpc_call *call, in rxrpc_rack_update()
103 static void rxrpc_rack_detect_reordering(struct rxrpc_call *call, in rxrpc_rack_detect_reordering()
121 void rxrpc_input_rack_one(struct rxrpc_call *call, in rxrpc_input_rack_one()
130 void rxrpc_input_rack(struct rxrpc_call *call, in rxrpc_input_rack()
156 static ktime_t rxrpc_rack_update_reo_wnd(struct rxrpc_call *call, in rxrpc_rack_update_reo_wnd()
197 static ktime_t rxrpc_rack_detect_loss(struct rxrpc_call *call, in rxrpc_rack_detect_loss()
244 void rxrpc_rack_detect_loss_and_arm_timer(struct rxrpc_call *call, in rxrpc_rack_detect_loss_and_arm_timer()
260 static void rxrpc_rack_mark_losses_on_rto(struct rxrpc_call *call) in rxrpc_rack_mark_losses_on_rto()
290 ktime_t rxrpc_tlp_calc_pto(struct rxrpc_call *call, ktime_t now) in rxrpc_tlp_calc_pto()
[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()
33 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()
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 | 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 bool rxrpc_retransmit_data(struct rxrpc_call *call, in rxrpc_retransmit_data()
86 static void rxrpc_resend(struct rxrpc_call *call) in rxrpc_resend()
131 void rxrpc_resend_tlp(struct rxrpc_call *call) in rxrpc_resend_tlp()
162 static void rxrpc_begin_service_reply(struct rxrpc_call *call) in rxrpc_begin_service_reply()
175 static void rxrpc_close_tx_phase(struct rxrpc_call *call) in rxrpc_close_tx_phase()
194 static void rxrpc_transmit_fresh_data(struct rxrpc_call *call, unsigned int limit, in rxrpc_transmit_fresh_data()
261 void rxrpc_transmit_some_data(struct rxrpc_call *call, unsigned int limit, in rxrpc_transmit_some_data()
291 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()
177 void rxrpc_congestion_degrade(struct rxrpc_call *call) in rxrpc_congestion_degrade()
205 static void rxrpc_add_data_rtt_sample(struct rxrpc_call *call, in rxrpc_add_data_rtt_sample()
221 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
350 static void rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
389 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
421 static void rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) in rxrpc_end_rx_phase()
446 static void rxrpc_input_update_ack_window(struct rxrpc_call *call, in rxrpc_input_update_ack_window()
456 static void rxrpc_input_queue_data(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_input_queue_data()
[all …]
|
| H A D | recvmsg.c | 23 void rxrpc_notify_socket(struct rxrpc_call *call) in rxrpc_notify_socket()
66 static int rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) in rxrpc_recvmsg_term()
108 static void rxrpc_rotate_rx_window(struct rxrpc_call *call) in rxrpc_rotate_rx_window()
157 static int rxrpc_verify_data(struct rxrpc_call *call, struct sk_buff *skb) in rxrpc_verify_data()
199 static int rxrpc_recvmsg_user_id(struct rxrpc_call *call, struct msghdr *msg, in rxrpc_recvmsg_user_id()
279 static int rxrpc_recvmsg_data(struct socket *sock, struct rxrpc_call *call, in rxrpc_recvmsg_data()
410 struct rxrpc_call *call; in rxrpc_recvmsg()
483 call = list_entry(l, struct rxrpc_call, recvmsg_link); in rxrpc_recvmsg()
644 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()
40 struct rxrpc_call *call, *xcall; in rxrpc_service_prealloc_one()
114 xcall = rb_entry(parent, struct rxrpc_call, sock_node); in rxrpc_service_prealloc_one()
221 struct rxrpc_call *call = b->call_backlog[tail]; in rxrpc_discard_prealloc()
245 static struct rxrpc_call *rxrpc_alloc_incoming_call(struct rxrpc_sock *rx, in rxrpc_alloc_incoming_call()
254 struct rxrpc_call *call; in rxrpc_alloc_incoming_call()
343 struct rxrpc_call *call = NULL; in rxrpc_new_incoming_call()
|
| H A D | output.c | 46 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret) in rxrpc_tx_backoff()
64 static void rxrpc_set_keepalive(struct rxrpc_call *call, ktime_t now) in rxrpc_set_keepalive()
75 static int rxrpc_alloc_ack(struct rxrpc_call *call, size_t sack_size) in rxrpc_alloc_ack()
112 static void rxrpc_free_ack(struct rxrpc_call *call) in rxrpc_free_ack()
122 static void rxrpc_begin_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_begin_rtt_probe()
150 static int rxrpc_fill_out_ack(struct rxrpc_call *call, int nr_kv, u8 ack_reason, in rxrpc_fill_out_ack()
243 static void rxrpc_send_ack_packet(struct rxrpc_call *call, int nr_kv, size_t len, in rxrpc_send_ack_packet()
300 void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_send_ACK()
353 void rxrpc_send_probe_for_pmtud(struct rxrpc_call *call) in rxrpc_send_probe_for_pmtud()
362 int rxrpc_send_abort_packet(struct rxrpc_call *call) in rxrpc_send_abort_packet()
[all …]
|
| 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()
518 struct rxrpc_call, wait_link))) { in rxrpc_connect_client_calls()
533 void rxrpc_expose_client_call(struct rxrpc_call *call) in rxrpc_expose_client_call()
573 void rxrpc_disconnect_client_call(struct rxrpc_bundle *bundle, struct rxrpc_call *call) in rxrpc_disconnect_client_call()
|
| H A D | rxperf.c | 49 struct rxrpc_call *rxcall;
99 static void rxperf_rx_discard_new_call(struct rxrpc_call *rxcall, in rxperf_rx_discard_new_call()
105 static void rxperf_rx_new_call(struct sock *sk, struct rxrpc_call *rxcall, in rxperf_rx_new_call()
116 static void rxperf_notify_rx(struct sock *sk, struct rxrpc_call *rxcall, in rxperf_notify_rx()
125 static void rxperf_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in rxperf_rx_attach()
133 struct rxrpc_call *rxcall, in rxperf_notify_end_reply_tx()
|
| H A D | af_rxrpc.c | 340 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock, in rxrpc_kernel_begin_call()
355 struct rxrpc_call *call; in rxrpc_kernel_begin_call()
400 static void rxrpc_dummy_notify_rx(struct sock *sk, struct rxrpc_call *rxcall, in rxrpc_dummy_notify_rx()
413 void rxrpc_kernel_shutdown_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_shutdown_call()
439 void rxrpc_kernel_put_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_put_call()
456 const struct rxrpc_call *call) in rxrpc_kernel_check_life()
1045 "rxrpc_call_jar", sizeof(struct rxrpc_call), 0, in af_rxrpc_init()
|
| H A D | rxkad.c | 139 static struct rxrpc_txbuf *rxkad_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp) in rxkad_init_connection_security()
209 static void rxkad_free_call_crypto(struct rxrpc_call *call) in rxkad_prime_packet_security()
216 static void rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_prime_packet_security()
245 static void rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_get_call_crypto()
278 static int rxkad_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxkad_secure_packet_auth()
351 static int rxkad_verify_packet_1(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_secure_packet()
395 static int rxkad_verify_packet_2(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_secure_packet()
447 static int rxkad_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in rxkad_verify_packet_1()
|
| H A D | rxgk.c | 276 static void rxgk_free_call_crypto(struct rxrpc_call *call) in rxgk_free_call_crypto()
283 static struct rxrpc_txbuf *rxgk_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp) in rxgk_alloc_txbuf()
343 static int rxgk_secure_packet_integrity(const struct rxrpc_call *call, in rxgk_secure_packet_integrity()
389 static int rxgk_secure_packet_encrypted(const struct rxrpc_call *call, in rxgk_secure_packet_encrypted()
430 static int rxgk_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxgk_secure_packet()
469 static int rxgk_verify_packet_integrity(struct rxrpc_call *call, in rxgk_verify_packet_integrity()
524 static int rxgk_verify_packet_encrypted(struct rxrpc_call *call, in rxgk_verify_packet_encrypted()
587 static int rxgk_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in rxgk_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 | io_thread.c | 333 struct rxrpc_call *call = NULL; in rxrpc_input_packet_on_conn()
435 struct rxrpc_call *call; in rxrpc_io_thread()
525 struct rxrpc_call, in rxrpc_io_thread()
|
| H A D | conn_event.c | 213 struct rxrpc_call *call; in rxrpc_abort_calls()
237 static void rxrpc_call_is_secure(struct rxrpc_call *call) in rxrpc_call_is_secure()
437 struct rxrpc_call *call = NULL; in rxrpc_post_challenge()
|
| 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 | 152 struct rxrpc_call *call) in __rxrpc_disconnect_call()
191 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call()
|
| H A D | security.c | 71 int rxrpc_init_client_call_security(struct rxrpc_call *call) in rxrpc_init_client_call_security()
|
| H A D | proc.c | 56 struct rxrpc_call *call; in rxrpc_call_seq_show()
72 call = list_entry(v, struct rxrpc_call, link); in rxrpc_call_seq_show()
|
| /linux/include/trace/events/ |
| H A D | rxrpc.h | 823 TRACE_EVENT(rxrpc_call,
917 TP_PROTO(const struct rxrpc_call *call, int abort_code),
975 TP_PROTO(struct rxrpc_call *call),
1001 TP_PROTO(struct rxrpc_call *call, enum rxrpc_txqueue_trace why),
1037 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t send_top, int space),
1078 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq, rxrpc_seq_t to),
1131 TP_PROTO(struct rxrpc_call *call, struct rxrpc_skb_priv *sp),
1169 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1358 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1417 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
[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);
27 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID);
333 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
347 struct rxrpc_call *rxcall; in afs_make_call()
686 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
699 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
737 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in afs_rx_attach()
[all …]
|