Home
last modified time | relevance | path

Searched refs:rxrpc_call (Results 1 – 25 of 29) sorted by relevance

12

/linux-6.3-rc2/include/net/
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 *,
43 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *,
53 int rxrpc_kernel_send_data(struct socket *, struct rxrpc_call *,
56 int rxrpc_kernel_recv_data(struct socket *, struct rxrpc_call *,
58 bool rxrpc_kernel_abort_call(struct socket *, struct rxrpc_call *,
60 void rxrpc_kernel_end_call(struct socket *, struct rxrpc_call *);
61 void rxrpc_kernel_get_peer(struct socket *, struct rxrpc_call *,
69 u32 rxrpc_kernel_get_epoch(struct socket *, struct rxrpc_call *);
[all …]
/linux-6.3-rc2/net/rxrpc/
A Dar-internal.h135 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
244 int (*how_much_data)(struct rxrpc_call *, size_t,
254 void (*free_call_crypto)(struct rxrpc_call *);
471 struct rxrpc_call *call; /* Active call */
597 struct rxrpc_call { struct
878 struct rxrpc_call *rxrpc_try_get_call(struct rxrpc_call *, enum rxrpc_call_trace);
881 void rxrpc_cleanup_call(struct rxrpc_call *);
901 bool rxrpc_call_completed(struct rxrpc_call *call);
990 void rxrpc_disconnect_call(struct rxrpc_call *);
1135 int rxrpc_send_abort_packet(struct rxrpc_call *);
[all …]
A Dcall_object.c100 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID()
136 struct rxrpc_call *call; in rxrpc_alloc_call()
204 struct rxrpc_call *call; in rxrpc_alloc_client_call()
339 struct rxrpc_call *call, *xcall; in rxrpc_new_client_call()
445 struct rxrpc_call *call, in rxrpc_incoming_call()
516 struct rxrpc_call *rxrpc_try_get_call(struct rxrpc_call *call, in rxrpc_try_get_call()
607 struct rxrpc_call *call; in rxrpc_release_calls_on_socket()
665 struct rxrpc_call *call = container_of(rcu, struct rxrpc_call, rcu); in rxrpc_rcu_free_call()
678 struct rxrpc_call *call = container_of(work, struct rxrpc_call, destroyer); in rxrpc_destroy_call()
732 struct rxrpc_call *call; in rxrpc_destroy_all_calls()
[all …]
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()
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()
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()
109 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr()
133 struct rxrpc_call *call) in rxrpc_wait_for_tx_window_waitall()
173 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_nonintr()
194 struct rxrpc_call *call, in rxrpc_wait_for_tx_window()
282 struct rxrpc_call *call, in rxrpc_send_data()
572 static struct rxrpc_call *
579 struct rxrpc_call *call; in rxrpc_new_client_call_for_sendmsg()
618 struct rxrpc_call *call; in rxrpc_do_sendmsg()
[all …]
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()
180 void rxrpc_congestion_degrade(struct rxrpc_call *call) in rxrpc_congestion_degrade()
207 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
252 static void rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, in rxrpc_end_tx_phase()
285 static bool rxrpc_receiving_reply(struct rxrpc_call *call) in rxrpc_receiving_reply()
338 static void rxrpc_input_update_ack_window(struct rxrpc_call *call, in rxrpc_input_update_ack_window()
620 static void rxrpc_complete_rtt_probe(struct rxrpc_call *call, in rxrpc_complete_rtt_probe()
718 static void rxrpc_input_soft_acks(struct rxrpc_call *call, u8 *acks, in rxrpc_input_soft_acks()
743 static bool rxrpc_is_ack_valid(struct rxrpc_call *call, in rxrpc_is_ack_valid()
[all …]
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()
69 void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_send_ACK()
106 static void rxrpc_congestion_timeout(struct rxrpc_call *call) in rxrpc_congestion_timeout()
114 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 *call) in rxrpc_transmit_some_data()
[all …]
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()
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()
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()
700 static inline void rxrpc_instant_resend(struct rxrpc_call *call, in rxrpc_instant_resend()
710 void rxrpc_transmit_one(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxrpc_transmit_one()
A Drxperf.c48 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()
A Dconn_client.c73 static struct rxrpc_bundle *rxrpc_alloc_bundle(struct rxrpc_call *call, in rxrpc_alloc_bundle()
240 int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp) in rxrpc_look_up_bundle()
407 struct rxrpc_call *call = list_entry(bundle->waiting_calls.next, in rxrpc_activate_one_channel()
408 struct rxrpc_call, wait_link); in rxrpc_activate_one_channel()
500 struct rxrpc_call *call; in rxrpc_connect_client_calls()
503 struct rxrpc_call, wait_link)) in rxrpc_connect_client_calls()
520 void rxrpc_expose_client_call(struct rxrpc_call *call) in rxrpc_expose_client_call()
560 void rxrpc_disconnect_client_call(struct rxrpc_bundle *bundle, struct rxrpc_call *call) in rxrpc_disconnect_client_call()
A Daf_rxrpc.c281 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock, in rxrpc_kernel_begin_call()
294 struct rxrpc_call *call; in rxrpc_kernel_begin_call()
339 static void rxrpc_dummy_notify_rx(struct sock *sk, struct rxrpc_call *rxcall, in rxrpc_dummy_notify_rx()
352 void rxrpc_kernel_end_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_end_call()
380 const struct rxrpc_call *call) in rxrpc_kernel_check_life()
398 u32 rxrpc_kernel_get_epoch(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_epoch()
433 void rxrpc_kernel_set_max_life(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_set_max_life()
968 "rxrpc_call_jar", sizeof(struct rxrpc_call), 0, in af_rxrpc_init()
A Dtxbuf.c19 struct rxrpc_txbuf *rxrpc_alloc_txbuf(struct rxrpc_call *call, u8 packet_type, in rxrpc_alloc_txbuf()
105 void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *call) in rxrpc_shrink_call_tx_buffer()
A Drxkad.c148 static int rxkad_how_much_data(struct rxrpc_call *call, size_t remain, in rxkad_how_much_data()
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()
291 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_secure_packet_encrypt()
335 static int rxkad_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in rxkad_secure_packet()
406 static int rxkad_verify_packet_1(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_1()
469 static int rxkad_verify_packet_2(struct rxrpc_call *call, struct sk_buff *skb, in rxkad_verify_packet_2()
550 static int rxkad_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in rxkad_verify_packet()
A Dio_thread.c322 struct rxrpc_call *call = NULL; in rxrpc_input_packet_on_conn()
418 struct rxrpc_call *call; in rxrpc_io_thread()
454 struct rxrpc_call, in rxrpc_io_thread()
A Dpeer_event.c205 struct rxrpc_call *call; in rxrpc_distribute_error()
213 struct rxrpc_call, error_link); in rxrpc_distribute_error()
A Drtt.c147 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why, in rxrpc_peer_add_rtt()
A Dconn_event.c190 struct rxrpc_call *call; in rxrpc_abort_calls()
211 static void rxrpc_call_is_secure(struct rxrpc_call *call) in rxrpc_call_is_secure()
A Dconn_object.c154 struct rxrpc_call *call) in __rxrpc_disconnect_call()
193 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call()
A Dpeer_object.c467 void rxrpc_kernel_get_peer(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_get_peer()
482 bool rxrpc_kernel_get_srtt(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_get_srtt()
A Dsecurity.c68 int rxrpc_init_client_call_security(struct rxrpc_call *call) in rxrpc_init_client_call_security()
/linux-6.3-rc2/fs/afs/
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);
284 struct rxrpc_call *rxcall, in afs_notify_end_request_tx()
299 struct rxrpc_call *rxcall; in afs_make_call()
661 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter()
673 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call()
755 static void afs_rx_discard_new_call(struct rxrpc_call *rxcall, in afs_rx_discard_new_call()
767 static void afs_rx_new_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_rx_new_call()
[all …]
/linux-6.3-rc2/include/trace/events/
A Drxrpc.h685 TRACE_EVENT(rxrpc_call,
812 TP_PROTO(struct rxrpc_call *call),
901 TP_PROTO(struct rxrpc_call *call,
1081 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
1572 TP_PROTO(struct rxrpc_call *call, ktime_t now),
1610 TP_PROTO(struct rxrpc_call *call),
1630 TP_PROTO(struct rxrpc_call *call),
1650 TP_PROTO(struct rxrpc_call *call),
1762 TP_PROTO(struct rxrpc_call *call),
1904 TP_PROTO(struct rxrpc_call *call, bool busy,
[all …]

Completed in 53 milliseconds

12