| /Linux-v4.19/include/net/ |
| D | af_rxrpc.h | 20 struct rxrpc_call;
39 typedef void (*rxrpc_notify_rx_t)(struct sock *, struct rxrpc_call *,
41 typedef void (*rxrpc_notify_end_tx_t)(struct sock *, struct rxrpc_call *,
43 typedef void (*rxrpc_notify_new_call_t)(struct sock *, struct rxrpc_call *,
45 typedef void (*rxrpc_discard_new_call_t)(struct rxrpc_call *, unsigned long);
46 typedef void (*rxrpc_user_attach_call_t)(struct rxrpc_call *, unsigned long);
51 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *,
60 int rxrpc_kernel_send_data(struct socket *, struct rxrpc_call *,
63 int rxrpc_kernel_recv_data(struct socket *, struct rxrpc_call *,
65 bool rxrpc_kernel_abort_call(struct socket *, struct rxrpc_call *,
[all …]
|
| /Linux-v4.19/net/rxrpc/ |
| D | ar-internal.h | 127 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
224 int (*secure_packet)(struct rxrpc_call *,
230 int (*verify_packet)(struct rxrpc_call *, struct sk_buff *,
234 void (*locate_data)(struct rxrpc_call *, struct sk_buff *,
415 struct rxrpc_call __rcu *call; /* Active call */
535 struct rxrpc_call { struct
724 struct rxrpc_call *rxrpc_new_incoming_call(struct rxrpc_local *,
728 struct rxrpc_call *rxrpc_accept_call(struct rxrpc_sock *, unsigned long,
735 void rxrpc_propose_ACK(struct rxrpc_call *, u8, u16, u32, bool, bool,
739 static inline void rxrpc_reduce_call_timer(struct rxrpc_call *call, in rxrpc_reduce_call_timer()
[all …]
|
| D | call_object.c | 50 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired()
66 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx, in rxrpc_find_call_by_user_ID()
69 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
78 call = rb_entry(p, struct rxrpc_call, sock_node); in rxrpc_find_call_by_user_ID()
102 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp, in rxrpc_alloc_call()
105 struct rxrpc_call *call; in rxrpc_alloc_call()
173 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx, in rxrpc_alloc_client_call()
178 struct rxrpc_call *call; in rxrpc_alloc_client_call()
200 static void rxrpc_start_call_timer(struct rxrpc_call *call) in rxrpc_start_call_timer()
220 struct rxrpc_call *rxrpc_new_client_call(struct rxrpc_sock *rx, in rxrpc_new_client_call()
[all …]
|
| D | call_accept.c | 41 struct rxrpc_call *call; in rxrpc_service_prealloc_one()
110 struct rxrpc_call *xcall; in rxrpc_service_prealloc_one()
118 xcall = rb_entry(parent, struct rxrpc_call, sock_node); in rxrpc_service_prealloc_one()
230 struct rxrpc_call *call = b->call_backlog[tail]; in rxrpc_discard_prealloc()
250 static struct rxrpc_call *rxrpc_alloc_incoming_call(struct rxrpc_sock *rx, in rxrpc_alloc_incoming_call()
257 struct rxrpc_call *call; in rxrpc_alloc_incoming_call()
334 struct rxrpc_call *rxrpc_new_incoming_call(struct rxrpc_local *local, in rxrpc_new_incoming_call()
341 struct rxrpc_call *call; in rxrpc_new_incoming_call()
449 struct rxrpc_call *rxrpc_accept_call(struct rxrpc_sock *rx, in rxrpc_accept_call()
455 struct rxrpc_call *call; in rxrpc_accept_call()
[all …]
|
| D | insecure.c | 25 static int none_secure_packet(struct rxrpc_call *call, in none_secure_packet()
33 static int none_verify_packet(struct rxrpc_call *call, struct sk_buff *skb, in none_verify_packet()
40 static void none_locate_data(struct rxrpc_call *call, struct sk_buff *skb, in none_locate_data()
|
| D | recvmsg.c | 27 void rxrpc_notify_socket(struct rxrpc_call *call) in rxrpc_notify_socket()
68 static int rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) in rxrpc_recvmsg_term()
114 struct rxrpc_call *call, in rxrpc_recvmsg_new_call()
140 static void rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) in rxrpc_end_rx_phase()
178 static void rxrpc_rotate_rx_window(struct rxrpc_call *call) in rxrpc_rotate_rx_window()
233 static int rxrpc_verify_packet(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_verify_packet()
268 static int rxrpc_locate_data(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_locate_data()
304 static int rxrpc_recvmsg_data(struct socket *sock, struct rxrpc_call *call, in rxrpc_recvmsg_data()
432 struct rxrpc_call *call; in rxrpc_recvmsg()
491 call = list_entry(l, struct rxrpc_call, recvmsg_link); in rxrpc_recvmsg()
[all …]
|
| D | sendmsg.c | 28 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr()
57 struct rxrpc_call *call) in rxrpc_wait_for_tx_window_nonintr()
102 struct rxrpc_call *call, in rxrpc_wait_for_tx_window()
128 static inline void rxrpc_instant_resend(struct rxrpc_call *call, int ix) in rxrpc_instant_resend()
147 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_notify_end_tx()
158 static void rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_queue_packet()
264 struct rxrpc_call *call, in rxrpc_send_data()
565 static struct rxrpc_call *
572 struct rxrpc_call *call; in rxrpc_new_client_call_for_sendmsg()
614 struct rxrpc_call *call; in rxrpc_do_sendmsg()
[all …]
|
| D | input.c | 31 struct rxrpc_call *call, rxrpc_seq_t seq) in rxrpc_proto_abort()
42 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management()
203 static void rxrpc_send_ping(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_send_ping()
219 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
278 static bool rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
325 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
406 static void rxrpc_input_dup_data(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_input_dup_data()
426 static void rxrpc_input_data(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_input_data()
628 static void rxrpc_input_requested_ack(struct rxrpc_call *call, in rxrpc_input_requested_ack()
665 static void rxrpc_input_check_for_lost_ack(struct rxrpc_call *call) in rxrpc_input_check_for_lost_ack()
[all …]
|
| D | call_event.c | 27 static void rxrpc_propose_ping(struct rxrpc_call *call, in rxrpc_propose_ping()
49 static void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in __rxrpc_propose_ACK()
142 void rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_propose_ACK()
155 static void rxrpc_congestion_timeout(struct rxrpc_call *call) in rxrpc_congestion_timeout()
163 static void rxrpc_resend(struct rxrpc_call *call, unsigned long now_j) in rxrpc_resend()
310 struct rxrpc_call *call = in rxrpc_process_call()
311 container_of(work, struct rxrpc_call, processor); in rxrpc_process_call()
|
| D | af_rxrpc.c | 280 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock, in rxrpc_kernel_begin_call()
292 struct rxrpc_call *call; in rxrpc_kernel_begin_call()
336 static void rxrpc_dummy_notify_rx(struct sock *sk, struct rxrpc_call *rxcall, in rxrpc_dummy_notify_rx()
349 void rxrpc_kernel_end_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_end_call()
381 u32 rxrpc_kernel_check_life(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_check_life()
399 int rxrpc_kernel_check_call(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_check_call()
423 int rxrpc_kernel_retry_call(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_retry_call()
995 "rxrpc_call_jar", sizeof(struct rxrpc_call), 0, in af_rxrpc_init()
|
| D | rxkad.c | 146 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_secure_packet_auth()
183 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_secure_packet_encrypt()
247 static int rxkad_secure_packet(struct rxrpc_call *call, in rxkad_secure_packet()
318 static int rxkad_verify_packet_1(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_1()
404 static int rxkad_verify_packet_2(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_2()
505 static int rxkad_verify_packet(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet()
569 static void rxkad_locate_data_1(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_locate_data_1()
583 static void rxkad_locate_data_2(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_locate_data_2()
597 static void rxkad_locate_data(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_locate_data()
1144 struct rxrpc_call *call; in rxkad_verify_response()
|
| D | conn_client.c | 280 struct rxrpc_call *call, in rxrpc_get_client_conn()
553 struct rxrpc_call *call = list_entry(conn->waiting_calls.next, in rxrpc_activate_one_channel()
554 struct rxrpc_call, chan_wait_link); in rxrpc_activate_one_channel()
646 static int rxrpc_wait_for_channel(struct rxrpc_call *call, gfp_t gfp) in rxrpc_wait_for_channel()
688 struct rxrpc_call *call, in rxrpc_connect_call()
744 void rxrpc_expose_client_call(struct rxrpc_call *call) in rxrpc_expose_client_call()
778 void rxrpc_disconnect_client_call(struct rxrpc_call *call) in rxrpc_disconnect_client_call()
|
| D | proc.c | 64 struct rxrpc_call *call; in rxrpc_call_seq_show()
79 call = list_entry(v, struct rxrpc_call, link); in rxrpc_call_seq_show()
|
| D | output.c | 45 static void rxrpc_set_keepalive(struct rxrpc_call *call) in rxrpc_set_keepalive()
59 struct rxrpc_call *call, in rxrpc_fill_out_ack()
118 int rxrpc_send_ack_packet(struct rxrpc_call *call, bool ping, in rxrpc_send_ack_packet()
244 int rxrpc_send_abort_packet(struct rxrpc_call *call) in rxrpc_send_abort_packet()
312 int rxrpc_send_data_packet(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_send_data_packet()
|
| D | peer_event.c | 278 struct rxrpc_call *call; in rxrpc_distribute_error()
292 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why, in rxrpc_peer_add_rtt()
|
| D | peer_object.c | 472 void rxrpc_kernel_get_peer(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_get_peer()
486 u64 rxrpc_kernel_get_rtt(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_rtt()
|
| D | conn_object.c | 170 struct rxrpc_call *call) in __rxrpc_disconnect_call()
212 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call()
|
| D | conn_event.c | 158 struct rxrpc_call *call; in rxrpc_abort_calls()
268 static void rxrpc_call_is_secure(struct rxrpc_call *call) in rxrpc_call_is_secure()
|
| /Linux-v4.19/include/trace/events/ |
| D | rxrpc.h | 614 TRACE_EVENT(rxrpc_call,
615 TP_PROTO(struct rxrpc_call *call, enum rxrpc_call_trace op,
747 TP_PROTO(struct rxrpc_call *call),
773 TP_PROTO(struct rxrpc_call *call, enum rxrpc_transmit_trace why),
832 TP_PROTO(struct rxrpc_call *call,
869 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
893 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
952 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
1025 TP_PROTO(struct rxrpc_call *call, enum rxrpc_receive_trace why,
1058 TP_PROTO(struct rxrpc_call *call, enum rxrpc_recvmsg_trace why,
[all …]
|
| D | afs.h | 207 TP_PROTO(struct rxrpc_call *rxcall, struct afs_call *call),
339 __field(struct rxrpc_call *, rx_call )
|
| /Linux-v4.19/fs/afs/ |
| D | rxrpc.c | 22 static void afs_wake_up_call_waiter(struct sock *, struct rxrpc_call *, unsigned long);
24 static void afs_wake_up_async_call(struct sock *, struct rxrpc_call *, unsigned long);
26 static void afs_rx_new_call(struct sock *, struct rxrpc_call *, unsigned long);
27 static void afs_rx_discard_new_call(struct rxrpc_call *, unsigned long);
296 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
346 struct rxrpc_call *rxcall; in afs_make_call()
630 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
642 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
706 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in afs_rx_attach()
748 static void afs_rx_discard_new_call(struct rxrpc_call *rxcall, in afs_rx_discard_new_call()
[all …]
|
| D | internal.h | 92 struct rxrpc_call *rxcall; /* RxRPC call handle */
|
| /Linux-v4.19/Documentation/networking/ |
| D | rxrpc.txt | 791 struct rxrpc_call *
834 struct rxrpc_call *call);
847 struct rxrpc_call *call,
869 struct rxrpc_call *call,
904 struct rxrpc_call *call,
957 struct rxrpc_call *
987 void rxrpc_kernel_get_peer(struct socket *sock, struct rxrpc_call *call,
995 struct rxrpc_call *call,
1014 int rxrpc_kernel_check_call(struct socket *sock, struct rxrpc_call *call,
1031 struct rxrpc_call *call,
[all …]
|
