/linux-master/net/rxrpc/ |
H A D | txbuf.c | 19 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 D | sendmsg.c | 23 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 D | rxkad.c | 148 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 D | rtt.c | 147 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why,
|
H A D | output.c | 48 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 D | proc.c | 52 struct rxrpc_call *call; 68 call = list_entry(v, struct rxrpc_call, link);
|
H A D | input.c | 12 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 D | io_thread.c | 333 struct rxrpc_call *call = NULL; 429 struct rxrpc_call *call; 465 struct rxrpc_call,
|
H A D | insecure.c | 20 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 D | conn_object.c | 155 struct rxrpc_call *call) 194 void rxrpc_disconnect_call(struct rxrpc_call *call)
|
H A D | conn_event.c | 198 struct rxrpc_call *call; 219 static void rxrpc_call_is_secure(struct rxrpc_call *call)
|
H A D | call_object.c | 46 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 D | conn_client.c | 73 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 D | call_event.c | 23 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 D | ar-internal.h | 136 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 D | af_rxrpc.c | 328 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 D | peer_object.c | 468 struct rxrpc_peer *rxrpc_kernel_get_call_peer(struct socket *sock, struct rxrpc_call *call)
|
H A D | rxperf.c | 48 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 D | recvmsg.c | 23 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 D | call_accept.c | 25 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;
|
/linux-master/include/trace/events/ |
H A D | rxrpc.h | 682 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...] |
H A D | afs.h | 570 TP_PROTO(struct rxrpc_call *rxcall, struct afs_call *call), 817 __field(struct rxrpc_call *, rx_call)
|
/linux-master/fs/afs/ |
H A D | internal.h | 133 struct rxrpc_call *rxcall; /* RxRPC call handle */
|
H A D | rxrpc.c | 21 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/net/ |
H A D | af_rxrpc.h | 17 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...] |