Home
last modified time | relevance | path

Searched refs:rxrpc_call (Results 1 - 25 of 51) sorted by relevance

123

/kernel/linux/linux-5.10/include/net/
H A Daf_rxrpc.h17 struct rxrpc_call;
30 typedef void (*rxrpc_notify_rx_t)(struct sock *, struct rxrpc_call *,
32 typedef void (*rxrpc_notify_end_tx_t)(struct sock *, struct rxrpc_call *,
34 typedef void (*rxrpc_notify_new_call_t)(struct sock *, struct rxrpc_call *,
36 typedef void (*rxrpc_discard_new_call_t)(struct rxrpc_call *, unsigned long);
37 typedef void (*rxrpc_user_attach_call_t)(struct rxrpc_call *, unsigned long);
42 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *,
52 int rxrpc_kernel_send_data(struct socket *, struct rxrpc_call *,
55 int rxrpc_kernel_recv_data(struct socket *, struct rxrpc_call *,
57 bool rxrpc_kernel_abort_call(struct socket *, struct rxrpc_call *,
[all...]
/kernel/linux/linux-6.6/include/net/
H A Daf_rxrpc.h17 struct rxrpc_call;
31 typedef void (*rxrpc_notify_rx_t)(struct sock *, struct rxrpc_call *,
33 typedef void (*rxrpc_notify_end_tx_t)(struct sock *, struct rxrpc_call *,
35 typedef void (*rxrpc_notify_new_call_t)(struct sock *, struct rxrpc_call *,
37 typedef void (*rxrpc_discard_new_call_t)(struct rxrpc_call *, unsigned long);
38 typedef void (*rxrpc_user_attach_call_t)(struct rxrpc_call *, unsigned long);
43 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock,
54 int rxrpc_kernel_send_data(struct socket *, struct rxrpc_call *,
57 int rxrpc_kernel_recv_data(struct socket *, struct rxrpc_call *,
59 bool rxrpc_kernel_abort_call(struct socket *, struct rxrpc_call *,
[all...]
/kernel/linux/linux-5.10/net/rxrpc/
H A Dcall_object.c50 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired()
62 void rxrpc_reduce_call_timer(struct rxrpc_call *call, in rxrpc_reduce_call_timer()
74 void rxrpc_delete_call_timer(struct rxrpc_call *call) in rxrpc_delete_call_timer()
86 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx, in rxrpc_find_call_by_user_ID()
89 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
98 call = rb_entry(p, struct rxrpc_call, sock_node); in rxrpc_find_call_by_user_ID()
122 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp, in rxrpc_alloc_call()
125 struct rxrpc_call *call; in rxrpc_alloc_call()
194 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx, in rxrpc_alloc_client_call()
199 struct rxrpc_call *cal in rxrpc_alloc_client_call()
[all...]
H A Dar-internal.h114 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
218 int (*secure_packet)(struct rxrpc_call *,
224 int (*verify_packet)(struct rxrpc_call *, struct sk_buff *,
228 void (*free_call_crypto)(struct rxrpc_call *);
231 void (*locate_data)(struct rxrpc_call *, struct sk_buff *,
415 struct rxrpc_call __rcu *call; /* Active call */
545 struct rxrpc_call { struct
744 struct rxrpc_call *rxrpc_new_incoming_call(struct rxrpc_local *,
753 void rxrpc_propose_ACK(struct rxrpc_call *, u8, u32, bool, bool,
757 void rxrpc_reduce_call_timer(struct rxrpc_call *cal
[all...]
H A Dinsecure.c21 static int none_secure_packet(struct rxrpc_call *call, in none_secure_packet()
29 static int none_verify_packet(struct rxrpc_call *call, struct sk_buff *skb, in none_verify_packet()
36 static void none_free_call_crypto(struct rxrpc_call *call) in none_free_call_crypto()
40 static void none_locate_data(struct rxrpc_call *call, struct sk_buff *skb, in none_locate_data()
H A Drecvmsg.c23 void rxrpc_notify_socket(struct rxrpc_call *call) in rxrpc_notify_socket()
64 bool __rxrpc_set_call_completion(struct rxrpc_call *call, in __rxrpc_set_call_completion()
82 bool rxrpc_set_call_completion(struct rxrpc_call *call, in rxrpc_set_call_completion()
100 bool __rxrpc_call_completed(struct rxrpc_call *call) in __rxrpc_call_completed()
105 bool rxrpc_call_completed(struct rxrpc_call *call) in rxrpc_call_completed()
120 bool __rxrpc_abort_call(const char *why, struct rxrpc_call *call, in __rxrpc_abort_call()
129 bool rxrpc_abort_call(const char *why, struct rxrpc_call *call, in rxrpc_abort_call()
143 static int rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) in rxrpc_recvmsg_term()
184 static void rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) in rxrpc_end_rx_phase()
222 static void rxrpc_rotate_rx_window(struct rxrpc_call *cal
[all...]
H A Dsendmsg.c23 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space()
39 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr()
63 struct rxrpc_call *call) in rxrpc_wait_for_tx_window_waitall()
104 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_nonintr()
125 struct rxrpc_call *call, in rxrpc_wait_for_tx_window()
160 static inline void rxrpc_instant_resend(struct rxrpc_call *call, int ix) in rxrpc_instant_resend()
179 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_notify_end_tx()
191 static int rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_queue_packet()
288 struct rxrpc_call *call, in rxrpc_send_data()
619 static struct rxrpc_call *
[all...]
H A Dcall_accept.c25 static void rxrpc_dummy_notify(struct sock *sk, struct rxrpc_call *call, in rxrpc_dummy_notify()
42 struct rxrpc_call *call, *xcall; in rxrpc_service_prealloc_one()
117 xcall = rb_entry(parent, struct rxrpc_call, sock_node); in rxrpc_service_prealloc_one()
222 struct rxrpc_call *call = b->call_backlog[tail]; in rxrpc_discard_prealloc()
244 static void rxrpc_send_ping(struct rxrpc_call *call, struct sk_buff *skb) in rxrpc_send_ping()
260 static struct rxrpc_call *rxrpc_alloc_incoming_call(struct rxrpc_sock *rx, in rxrpc_alloc_incoming_call()
269 struct rxrpc_call *call; in rxrpc_alloc_incoming_call()
348 struct rxrpc_call *rxrpc_new_incoming_call(struct rxrpc_local *local, in rxrpc_new_incoming_call()
356 struct rxrpc_call *call = NULL; in rxrpc_new_incoming_call()
H A Dinput.c27 struct rxrpc_call *call, rxrpc_seq_t seq) in rxrpc_proto_abort()
38 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management()
198 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
257 static bool rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
303 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
390 static void rxrpc_input_dup_data(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_input_dup_data()
411 static void rxrpc_input_data(struct rxrpc_call *call, struct sk_buff *skb) in rxrpc_input_data()
622 static void rxrpc_complete_rtt_probe(struct rxrpc_call *call, in rxrpc_complete_rtt_probe()
680 static void rxrpc_input_check_for_lost_ack(struct rxrpc_call *call) in rxrpc_input_check_for_lost_ack()
713 static void rxrpc_input_ping_response(struct rxrpc_call *cal
[all...]
H A Dcall_event.c23 static void rxrpc_propose_ping(struct rxrpc_call *call, in rxrpc_propose_ping()
45 static void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in __rxrpc_propose_ACK()
136 void rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_propose_ACK()
149 static void rxrpc_congestion_timeout(struct rxrpc_call *call) in rxrpc_congestion_timeout()
157 static void rxrpc_resend(struct rxrpc_call *call, unsigned long now_j) in rxrpc_resend()
289 struct rxrpc_call *call = in rxrpc_process_call()
290 container_of(work, struct rxrpc_call, processor); in rxrpc_process_call()
/kernel/linux/linux-6.6/net/rxrpc/
H A Dar-internal.h135 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
252 int (*how_much_data)(struct rxrpc_call *, size_t,
256 int (*secure_packet)(struct rxrpc_call *, struct rxrpc_txbuf *);
259 int (*verify_packet)(struct rxrpc_call *, struct sk_buff *);
262 void (*free_call_crypto)(struct rxrpc_call *);
479 struct rxrpc_call *call; /* Active call */
605 struct rxrpc_call { struct
866 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
868 void rxrpc_send_ACK(struct rxrpc_call *, u8, rxrpc_serial_t, enum rxrpc_propose_ack_trace);
869 void rxrpc_propose_delay_ACK(struct rxrpc_call *, rxrpc_serial_
[all...]
H A Dcall_object.c46 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what) in rxrpc_poke_call()
68 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired()
78 void rxrpc_reduce_call_timer(struct rxrpc_call *call, in rxrpc_reduce_call_timer()
95 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx, in rxrpc_find_call_by_user_ID()
98 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
107 call = rb_entry(p, struct rxrpc_call, sock_node); in rxrpc_find_call_by_user_ID()
131 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp, in rxrpc_alloc_call()
134 struct rxrpc_call *call; in rxrpc_alloc_call()
195 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx, in rxrpc_alloc_client_call()
202 struct rxrpc_call *cal in rxrpc_alloc_client_call()
[all...]
H A Dinsecure.c20 static int none_how_much_data(struct rxrpc_call *call, size_t remain, in none_how_much_data()
28 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()
41 static void none_free_call_crypto(struct rxrpc_call *call) in none_free_call_crypto()
H A Dcall_state.c13 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 Dsendmsg.c23 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()
94 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space()
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()
226 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_notify_end_tx()
238 static void rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call, in rxrpc_queue_packet()
278 struct rxrpc_call *cal in rxrpc_send_data()
[all...]
H A Dcall_event.c23 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()
67 void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_send_ACK()
104 static void rxrpc_congestion_timeout(struct rxrpc_call *call) in rxrpc_congestion_timeout()
112 void rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb) in rxrpc_resend()
258 static void rxrpc_begin_service_reply(struct rxrpc_call *call) in rxrpc_begin_service_reply()
273 static void rxrpc_close_tx_phase(struct rxrpc_call *call) in rxrpc_close_tx_phase()
289 static bool rxrpc_tx_window_has_space(struct rxrpc_call *call) in rxrpc_tx_window_has_space()
304 static void rxrpc_decant_prepared_tx(struct rxrpc_call *call) in rxrpc_decant_prepared_tx()
333 static void rxrpc_transmit_some_data(struct rxrpc_call *cal
[all...]
H A Dinput.c12 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_proto_abort()
21 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management()
179 void rxrpc_congestion_degrade(struct rxrpc_call *call) in rxrpc_congestion_degrade()
206 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
250 static void rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
288 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
316 static void rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) in rxrpc_end_rx_phase()
341 static void rxrpc_input_update_ack_window(struct rxrpc_call *call, in rxrpc_input_update_ack_window()
351 static void rxrpc_input_queue_data(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_input_queue_data()
368 static void rxrpc_input_data_one(struct rxrpc_call *cal
[all...]
H A Drecvmsg.c23 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 Dcall_accept.c25 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 Dconn_client.c73 static struct rxrpc_bundle *rxrpc_alloc_bundle(struct rxrpc_call *call, in rxrpc_alloc_bundle()
243 int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp) in rxrpc_look_up_bundle()
408 struct rxrpc_call *call = list_entry(bundle->waiting_calls.next, in rxrpc_activate_one_channel()
409 struct rxrpc_call, wait_link); in rxrpc_activate_one_channel()
501 struct rxrpc_call *call; in rxrpc_connect_client_calls()
504 struct rxrpc_call, wait_link)) in rxrpc_connect_client_calls()
521 void rxrpc_expose_client_call(struct rxrpc_call *call) in rxrpc_expose_client_call()
561 void rxrpc_disconnect_client_call(struct rxrpc_bundle *bundle, struct rxrpc_call *call) in rxrpc_disconnect_client_call()
H A Doutput.c48 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret) in rxrpc_tx_backoff()
68 static void rxrpc_set_keepalive(struct rxrpc_call *call) in rxrpc_set_keepalive()
82 struct rxrpc_call *call, in rxrpc_fill_out_ack()
144 static int rxrpc_begin_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_begin_rtt_probe()
173 static void rxrpc_cancel_rtt_probe(struct rxrpc_call *call, in rxrpc_cancel_rtt_probe()
187 int rxrpc_send_ack_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxrpc_send_ack_packet()
260 int rxrpc_send_abort_packet(struct rxrpc_call *call) in rxrpc_send_abort_packet()
324 int rxrpc_send_data_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxrpc_send_data_packet()
698 static inline void rxrpc_instant_resend(struct rxrpc_call *call, in rxrpc_instant_resend()
708 void rxrpc_transmit_one(struct rxrpc_call *cal
[all...]
/kernel/linux/linux-6.6/include/trace/events/
H A Drxrpc.h687 TRACE_EVENT(rxrpc_call,
814 TP_PROTO(struct rxrpc_call *call),
840 TP_PROTO(struct rxrpc_call *call, enum rxrpc_txqueue_trace why),
903 TP_PROTO(struct rxrpc_call *call,
940 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1024 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1083 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
1159 TP_PROTO(struct rxrpc_call *call, enum rxrpc_receive_trace why,
1216 TP_PROTO(struct rxrpc_call *call, enum rxrpc_recvmsg_trace why,
1250 TP_PROTO(struct rxrpc_call *cal
[all...]
/kernel/linux/linux-5.10/fs/afs/
H A Drxrpc.c19 static void afs_wake_up_call_waiter(struct sock *, struct rxrpc_call *, unsigned long);
20 static void afs_wake_up_async_call(struct sock *, struct rxrpc_call *, unsigned long);
22 static void afs_rx_new_call(struct sock *, struct rxrpc_call *, unsigned long);
23 static void afs_rx_discard_new_call(struct rxrpc_call *, unsigned long);
312 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
363 struct rxrpc_call *rxcall; in afs_make_call()
685 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
697 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
736 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in afs_rx_attach()
780 static void afs_rx_discard_new_call(struct rxrpc_call *rxcal
[all...]
/kernel/linux/linux-6.6/fs/afs/
H A Drxrpc.c21 static void afs_wake_up_call_waiter(struct sock *, struct rxrpc_call *, unsigned long);
22 static void afs_wake_up_async_call(struct sock *, struct rxrpc_call *, unsigned long);
24 static void afs_rx_new_call(struct sock *, struct rxrpc_call *, unsigned long);
25 static void afs_rx_discard_new_call(struct rxrpc_call *, unsigned long);
285 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
300 struct rxrpc_call *rxcall; in afs_make_call()
658 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
670 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
708 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID) in afs_rx_attach()
752 static void afs_rx_discard_new_call(struct rxrpc_call *rxcal
[all...]
/kernel/linux/linux-5.10/include/trace/events/
H A Drxrpc.h599 TRACE_EVENT(rxrpc_call,
735 TP_PROTO(struct rxrpc_call *call),
761 TP_PROTO(struct rxrpc_call *call, enum rxrpc_transmit_trace why),
820 TP_PROTO(struct rxrpc_call *call,
857 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
881 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
940 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
1013 TP_PROTO(struct rxrpc_call *call, enum rxrpc_receive_trace why,
1046 TP_PROTO(struct rxrpc_call *call, enum rxrpc_recvmsg_trace why,
1080 TP_PROTO(struct rxrpc_call *cal
[all...]

Completed in 21 milliseconds

123