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

12

/linux-master/include/net/
H A Daf_rxrpc.h17 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-master/net/rxrpc/
H A Dcall_state.c13 bool rxrpc_set_call_completion(struct rxrpc_call *call,
35 bool rxrpc_call_completed(struct rxrpc_call *call)
43 bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,
60 void rxrpc_prefail_call(struct rxrpc_call *call, enum rxrpc_call_completion compl,
H A Dinsecure.c20 static struct rxrpc_txbuf *none_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp)
25 static int none_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb)
30 static int none_verify_packet(struct rxrpc_call *call, struct sk_buff *skb)
38 static void none_free_call_crypto(struct rxrpc_call *call)
H A Dar-internal.h136 struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX];
256 struct rxrpc_txbuf *(*alloc_txbuf)(struct rxrpc_call *call, size_t remaining, gfp_t gfp);
259 int (*secure_packet)(struct rxrpc_call *, struct rxrpc_txbuf *);
262 int (*verify_packet)(struct rxrpc_call *, struct sk_buff *);
265 void (*free_call_crypto)(struct rxrpc_call *);
486 struct rxrpc_call *call; /* Active call */
614 struct rxrpc_call { struct
865 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
867 void rxrpc_propose_delay_ACK(struct rxrpc_call *, rxrpc_serial_t,
869 void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *);
[all...]
H A Dcall_object.c46 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what)
68 struct rxrpc_call *call = from_timer(call, t, timer);
86 struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *rx,
89 struct rxrpc_call *call;
98 call = rb_entry(p, struct rxrpc_call, sock_node);
122 struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *rx, gfp_t gfp,
125 struct rxrpc_call *call;
194 static struct rxrpc_call *rxrpc_alloc_client_call(struct rxrpc_sock *rx,
200 struct rxrpc_call *call;
253 void rxrpc_start_call_timer(struct rxrpc_call *cal
[all...]
H A Dsendmsg.c23 bool rxrpc_propose_abort(struct rxrpc_call *call, s32 abort_code, int error,
45 static int rxrpc_wait_to_be_connected(struct rxrpc_call *call, long *timeo)
94 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win)
105 struct rxrpc_call *call,
129 struct rxrpc_call *call)
169 struct rxrpc_call *call,
190 struct rxrpc_call *call,
226 static void rxrpc_notify_end_tx(struct rxrpc_sock *rx, struct rxrpc_call *call,
238 static void rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call,
278 struct rxrpc_call *cal
[all...]
H A Dcall_event.c23 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
40 void rxrpc_propose_delay_ACK(struct rxrpc_call *call, rxrpc_serial_t serial,
60 static void rxrpc_congestion_timeout(struct rxrpc_call *call)
68 void rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb)
205 static void rxrpc_begin_service_reply(struct rxrpc_call *call)
218 static void rxrpc_close_tx_phase(struct rxrpc_call *call)
234 static bool rxrpc_tx_window_has_space(struct rxrpc_call *call)
249 static void rxrpc_decant_prepared_tx(struct rxrpc_call *call)
278 static void rxrpc_transmit_some_data(struct rxrpc_call *call)
306 static void rxrpc_send_initial_ping(struct rxrpc_call *cal
[all...]
H A Dinput.c12 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq,
21 static void rxrpc_congestion_management(struct rxrpc_call *call,
179 void rxrpc_congestion_degrade(struct rxrpc_call *call)
206 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to,
250 static void rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun,
291 static bool rxrpc_receiving_reply(struct rxrpc_call *call)
315 static void rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial)
340 static void rxrpc_input_update_ack_window(struct rxrpc_call *call,
350 static void rxrpc_input_queue_data(struct rxrpc_call *call, struct sk_buff *skb,
367 static void rxrpc_input_data_one(struct rxrpc_call *cal
[all...]
H A Drecvmsg.c23 void rxrpc_notify_socket(struct rxrpc_call *call)
64 static int rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg)
106 static void rxrpc_rotate_rx_window(struct rxrpc_call *call)
148 static int rxrpc_verify_data(struct rxrpc_call *call, struct sk_buff *skb)
163 static int rxrpc_recvmsg_data(struct socket *sock, struct rxrpc_call *call,
281 struct rxrpc_call *call;
342 call = list_entry(l, struct rxrpc_call, recvmsg_link);
489 int rxrpc_kernel_recv_data(struct socket *sock, struct rxrpc_call *call,
H A Doutput.c48 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret)
66 static void rxrpc_set_keepalive(struct rxrpc_call *call, ktime_t now)
77 static void rxrpc_fill_out_ack(struct rxrpc_call *call,
150 static void rxrpc_begin_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial,
178 static void rxrpc_send_ack_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb)
232 void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason,
263 int rxrpc_send_abort_packet(struct rxrpc_call *call)
327 static void rxrpc_prepare_data_subpacket(struct rxrpc_call *call, struct rxrpc_txbuf *txb,
384 static size_t rxrpc_prepare_data_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb)
399 static void rxrpc_tstamp_data_packets(struct rxrpc_call *cal
[all...]
H A Dcall_accept.c25 static void rxrpc_dummy_notify(struct sock *sk, struct rxrpc_call *call,
41 struct rxrpc_call *call, *xcall;
115 xcall = rb_entry(parent, struct rxrpc_call, sock_node);
220 struct rxrpc_call *call = b->call_backlog[tail];
242 static struct rxrpc_call *rxrpc_alloc_incoming_call(struct rxrpc_sock *rx,
251 struct rxrpc_call *call;
337 struct rxrpc_call *call = NULL;
H A Drxperf.c48 struct rxrpc_call *rxcall;
98 static void rxperf_rx_discard_new_call(struct rxrpc_call *rxcall,
104 static void rxperf_rx_new_call(struct sock *sk, struct rxrpc_call *rxcall,
115 static void rxperf_notify_rx(struct sock *sk, struct rxrpc_call *rxcall,
124 static void rxperf_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID)
132 struct rxrpc_call *rxcall,
H A Dtxbuf.c19 struct rxrpc_txbuf *rxrpc_alloc_data_txbuf(struct rxrpc_call *call, size_t data_size,
85 struct rxrpc_txbuf *rxrpc_alloc_ack_txbuf(struct rxrpc_call *call, size_t sack_size)
209 void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *call)
H A Drtt.c147 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why,
H A Daf_rxrpc.c328 struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *sock,
343 struct rxrpc_call *call;
388 static void rxrpc_dummy_notify_rx(struct sock *sk, struct rxrpc_call *rxcall,
401 void rxrpc_kernel_shutdown_call(struct socket *sock, struct rxrpc_call *call)
427 void rxrpc_kernel_put_call(struct socket *sock, struct rxrpc_call *call)
442 const struct rxrpc_call *call)
460 u32 rxrpc_kernel_get_epoch(struct socket *sock, struct rxrpc_call *call)
495 void rxrpc_kernel_set_max_life(struct socket *sock, struct rxrpc_call *call,
1030 "rxrpc_call_jar", sizeof(struct rxrpc_call), 0,
H A Dconn_client.c73 static struct rxrpc_bundle *rxrpc_alloc_bundle(struct rxrpc_call *call,
250 int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp)
417 struct rxrpc_call *call = list_entry(bundle->waiting_calls.next,
418 struct rxrpc_call, wait_link);
510 struct rxrpc_call *call;
513 struct rxrpc_call, wait_link))
530 void rxrpc_expose_client_call(struct rxrpc_call *call)
570 void rxrpc_disconnect_client_call(struct rxrpc_bundle *bundle, struct rxrpc_call *call)
H A Drxkad.c148 static struct rxrpc_txbuf *rxkad_alloc_txbuf(struct rxrpc_call *call, size_t remain, gfp_t gfp)
233 static struct skcipher_request *rxkad_get_call_crypto(struct rxrpc_call *call)
243 static void rxkad_free_call_crypto(struct rxrpc_call *call)
250 static int rxkad_secure_packet_auth(const struct rxrpc_call *call,
292 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call,
337 static int rxkad_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb)
408 static int rxkad_verify_packet_1(struct rxrpc_call *call, struct sk_buff *skb,
471 static int rxkad_verify_packet_2(struct rxrpc_call *call, struct sk_buff *skb,
552 static int rxkad_verify_packet(struct rxrpc_call *call, struct sk_buff *skb)
H A Dsecurity.c68 int rxrpc_init_client_call_security(struct rxrpc_call *call)
H A Dpeer_event.c205 struct rxrpc_call *call;
213 struct rxrpc_call, error_link);
H A Dio_thread.c333 struct rxrpc_call *call = NULL;
429 struct rxrpc_call *call;
465 struct rxrpc_call,
H A Dconn_object.c155 struct rxrpc_call *call)
194 void rxrpc_disconnect_call(struct rxrpc_call *call)
H A Dconn_event.c198 struct rxrpc_call *call;
219 static void rxrpc_call_is_secure(struct rxrpc_call *call)
H A Dproc.c52 struct rxrpc_call *call;
68 call = list_entry(v, struct rxrpc_call, link);
/linux-master/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);
286 struct rxrpc_call *rxcall,
300 struct rxrpc_call *rxcall;
633 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall,
645 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall,
683 static void afs_rx_attach(struct rxrpc_call *rxcall, unsigned long user_call_ID)
727 static void afs_rx_discard_new_call(struct rxrpc_call *rxcal
[all...]
/linux-master/include/trace/events/
H A Drxrpc.h682 TRACE_EVENT(rxrpc_call,
809 TP_PROTO(struct rxrpc_call *call),
835 TP_PROTO(struct rxrpc_call *call, enum rxrpc_txqueue_trace why),
898 TP_PROTO(struct rxrpc_call *call,
935 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1019 TP_PROTO(struct rxrpc_call *call, rxrpc_serial_t serial,
1078 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq,
1152 TP_PROTO(struct rxrpc_call *call, enum rxrpc_receive_trace why,
1209 TP_PROTO(struct rxrpc_call *call, enum rxrpc_recvmsg_trace why,
1243 TP_PROTO(struct rxrpc_call *cal
[all...]

Completed in 329 milliseconds

12