Commit | Line | Data |
---|---|---|
2874c5fd | 1 | /* SPDX-License-Identifier: GPL-2.0-or-later */ |
17926a79 DH |
2 | /* AF_RXRPC internal definitions |
3 | * | |
4 | * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved. | |
5 | * Written by David Howells (dhowells@redhat.com) | |
17926a79 DH |
6 | */ |
7 | ||
be6e6707 | 8 | #include <linux/atomic.h> |
8496af50 | 9 | #include <linux/seqlock.h> |
c410bf01 | 10 | #include <linux/win_minmax.h> |
2baec2c3 DH |
11 | #include <net/net_namespace.h> |
12 | #include <net/netns/generic.h> | |
e0e4d82f | 13 | #include <net/sock.h> |
be6e6707 | 14 | #include <net/af_rxrpc.h> |
41057ebd | 15 | #include <keys/rxrpc-type.h> |
ddc6c70f | 16 | #include "protocol.h" |
17926a79 | 17 | |
17926a79 DH |
18 | #define FCRYPT_BSIZE 8 |
19 | struct rxrpc_crypt { | |
20 | union { | |
21 | u8 x[FCRYPT_BSIZE]; | |
91e916cf | 22 | __be32 n[2]; |
17926a79 DH |
23 | }; |
24 | } __attribute__((aligned(8))); | |
25 | ||
651350d1 DH |
26 | #define rxrpc_queue_work(WS) queue_work(rxrpc_workqueue, (WS)) |
27 | #define rxrpc_queue_delayed_work(WS,D) \ | |
28 | queue_delayed_work(rxrpc_workqueue, (WS), (D)) | |
29 | ||
12da59fc | 30 | struct key_preparsed_payload; |
cc8feb8e | 31 | struct rxrpc_connection; |
02a19356 | 32 | struct rxrpc_txbuf; |
cc8feb8e | 33 | |
d001648e | 34 | /* |
ece64fec DH |
35 | * Mark applied to socket buffers in skb->mark. skb->priority is used |
36 | * to pass supplementary information. | |
d001648e DH |
37 | */ |
38 | enum rxrpc_skb_mark { | |
446b3e14 | 39 | RXRPC_SKB_MARK_PACKET, /* Received packet */ |
ff734825 | 40 | RXRPC_SKB_MARK_ERROR, /* Error notification */ |
2953d3b8 | 41 | RXRPC_SKB_MARK_SERVICE_CONN_SECURED, /* Service connection response has been verified */ |
ece64fec DH |
42 | RXRPC_SKB_MARK_REJECT_BUSY, /* Reject with BUSY */ |
43 | RXRPC_SKB_MARK_REJECT_ABORT, /* Reject with ABORT (code in skb->priority) */ | |
d001648e DH |
44 | }; |
45 | ||
17926a79 DH |
46 | /* |
47 | * sk_state for RxRPC sockets | |
48 | */ | |
49 | enum { | |
2341e077 DH |
50 | RXRPC_UNBOUND = 0, |
51 | RXRPC_CLIENT_UNBOUND, /* Unbound socket used as client */ | |
17926a79 | 52 | RXRPC_CLIENT_BOUND, /* client local address bound */ |
17926a79 | 53 | RXRPC_SERVER_BOUND, /* server local address bound */ |
28036f44 | 54 | RXRPC_SERVER_BOUND2, /* second server local address bound */ |
17926a79 | 55 | RXRPC_SERVER_LISTENING, /* server listening for connections */ |
210f0353 | 56 | RXRPC_SERVER_LISTEN_DISABLED, /* server listening disabled */ |
17926a79 DH |
57 | RXRPC_CLOSE, /* socket is being closed */ |
58 | }; | |
59 | ||
2baec2c3 DH |
60 | /* |
61 | * Per-network namespace data. | |
62 | */ | |
63 | struct rxrpc_net { | |
64 | struct proc_dir_entry *proc_net; /* Subdir in /proc/net */ | |
65 | u32 epoch; /* Local epoch for detecting local-end reset */ | |
66 | struct list_head calls; /* List of calls active in this namespace */ | |
ad25f5cb | 67 | spinlock_t call_lock; /* Lock for ->calls */ |
d3be4d24 | 68 | atomic_t nr_calls; /* Count of allocated calls */ |
2baec2c3 | 69 | |
31f5f9a1 | 70 | atomic_t nr_conns; |
d2ce4a84 | 71 | struct list_head bundle_proc_list; /* List of bundles for proc */ |
2baec2c3 DH |
72 | struct list_head conn_proc_list; /* List of conns in this namespace for proc */ |
73 | struct list_head service_conns; /* Service conns in this namespace */ | |
74 | rwlock_t conn_lock; /* Lock for ->conn_proc_list, ->service_conns */ | |
3d18cbb7 DH |
75 | struct work_struct service_conn_reaper; |
76 | struct timer_list service_conn_reap_timer; | |
2baec2c3 | 77 | |
f859ab61 | 78 | bool live; |
245500d8 | 79 | |
245500d8 | 80 | atomic_t nr_client_conns; |
2baec2c3 | 81 | |
33912c26 | 82 | struct hlist_head local_endpoints; |
2baec2c3 DH |
83 | struct mutex local_mutex; /* Lock for ->local_endpoints */ |
84 | ||
2baec2c3 | 85 | DECLARE_HASHTABLE (peer_hash, 10); |
ace45bec DH |
86 | spinlock_t peer_hash_lock; /* Lock for ->peer_hash */ |
87 | ||
88 | #define RXRPC_KEEPALIVE_TIME 20 /* NAT keepalive time in seconds */ | |
89 | u8 peer_keepalive_cursor; | |
330bdcfa DH |
90 | time64_t peer_keepalive_base; |
91 | struct list_head peer_keepalive[32]; | |
92 | struct list_head peer_keepalive_new; | |
ace45bec DH |
93 | struct timer_list peer_keepalive_timer; |
94 | struct work_struct peer_keepalive_work; | |
b0154246 DH |
95 | |
96 | atomic_t stat_tx_data; | |
97 | atomic_t stat_tx_data_retrans; | |
98 | atomic_t stat_tx_data_send; | |
99 | atomic_t stat_tx_data_send_frag; | |
32cf8edb DH |
100 | atomic_t stat_tx_data_send_fail; |
101 | atomic_t stat_tx_data_underflow; | |
102 | atomic_t stat_tx_data_cwnd_reset; | |
b0154246 DH |
103 | atomic_t stat_rx_data; |
104 | atomic_t stat_rx_data_reqack; | |
105 | atomic_t stat_rx_data_jumbo; | |
f2a676d1 DH |
106 | |
107 | atomic_t stat_tx_ack_fill; | |
108 | atomic_t stat_tx_ack_send; | |
109 | atomic_t stat_tx_ack_skip; | |
110 | atomic_t stat_tx_acks[256]; | |
111 | atomic_t stat_rx_acks[256]; | |
f7fa5242 DH |
112 | |
113 | atomic_t stat_why_req_ack[8]; | |
a275da62 DH |
114 | |
115 | atomic_t stat_io_loop; | |
2baec2c3 DH |
116 | }; |
117 | ||
00e90712 DH |
118 | /* |
119 | * Service backlog preallocation. | |
120 | * | |
121 | * This contains circular buffers of preallocated peers, connections and calls | |
122 | * for incoming service calls and their head and tail pointers. This allows | |
123 | * calls to be set up in the data_ready handler, thereby avoiding the need to | |
124 | * shuffle packets around so much. | |
125 | */ | |
126 | struct rxrpc_backlog { | |
127 | unsigned short peer_backlog_head; | |
128 | unsigned short peer_backlog_tail; | |
129 | unsigned short conn_backlog_head; | |
130 | unsigned short conn_backlog_tail; | |
131 | unsigned short call_backlog_head; | |
132 | unsigned short call_backlog_tail; | |
133 | #define RXRPC_BACKLOG_MAX 32 | |
134 | struct rxrpc_peer *peer_backlog[RXRPC_BACKLOG_MAX]; | |
135 | struct rxrpc_connection *conn_backlog[RXRPC_BACKLOG_MAX]; | |
136 | struct rxrpc_call *call_backlog[RXRPC_BACKLOG_MAX]; | |
137 | }; | |
138 | ||
17926a79 DH |
139 | /* |
140 | * RxRPC socket definition | |
141 | */ | |
142 | struct rxrpc_sock { | |
143 | /* WARNING: sk has to be the first member */ | |
144 | struct sock sk; | |
d001648e | 145 | rxrpc_notify_new_call_t notify_new_call; /* Func to notify of new call */ |
00e90712 | 146 | rxrpc_discard_new_call_t discard_new_call; /* Func to discard a new call */ |
17926a79 | 147 | struct rxrpc_local *local; /* local endpoint */ |
00e90712 | 148 | struct rxrpc_backlog *backlog; /* Preallocation for services */ |
248f219c DH |
149 | spinlock_t incoming_lock; /* Incoming call vs service shutdown lock */ |
150 | struct list_head sock_calls; /* List of calls owned by this socket */ | |
151 | struct list_head to_be_accepted; /* calls awaiting acceptance */ | |
152 | struct list_head recvmsg_q; /* Calls awaiting recvmsg's attention */ | |
223f5901 | 153 | spinlock_t recvmsg_lock; /* Lock for recvmsg_q */ |
17926a79 DH |
154 | struct key *key; /* security for this socket */ |
155 | struct key *securities; /* list of server security descriptors */ | |
00e90712 | 156 | struct rb_root calls; /* User ID -> call mapping */ |
17926a79 | 157 | unsigned long flags; |
2341e077 | 158 | #define RXRPC_SOCK_CONNECTED 0 /* connect_srx is set */ |
17926a79 DH |
159 | rwlock_t call_lock; /* lock for calls */ |
160 | u32 min_sec_level; /* minimum security level */ | |
161 | #define RXRPC_SECURITY_MAX RXRPC_SECURITY_ENCRYPT | |
cc8feb8e | 162 | bool exclusive; /* Exclusive connection for a client socket */ |
28036f44 | 163 | u16 second_service; /* Additional service bound to the endpoint */ |
4722974d DH |
164 | struct { |
165 | /* Service upgrade information */ | |
166 | u16 from; /* Service ID to upgrade (if not 0) */ | |
167 | u16 to; /* service ID to upgrade to */ | |
168 | } service_upgrade; | |
cc8feb8e | 169 | sa_family_t family; /* Protocol family created with */ |
4722974d | 170 | struct sockaddr_rxrpc srx; /* Primary Service/local addresses */ |
2341e077 | 171 | struct sockaddr_rxrpc connect_srx; /* Default client address from connect() */ |
17926a79 DH |
172 | }; |
173 | ||
174 | #define rxrpc_sk(__sk) container_of((__sk), struct rxrpc_sock, sk) | |
175 | ||
0d12f8a4 DH |
176 | /* |
177 | * CPU-byteorder normalised Rx packet header. | |
178 | */ | |
179 | struct rxrpc_host_header { | |
180 | u32 epoch; /* client boot timestamp */ | |
181 | u32 cid; /* connection and channel ID */ | |
182 | u32 callNumber; /* call ID (0 for connection-level packets) */ | |
183 | u32 seq; /* sequence number of pkt in call stream */ | |
184 | u32 serial; /* serial number of pkt sent to network */ | |
185 | u8 type; /* packet type */ | |
186 | u8 flags; /* packet flags */ | |
187 | u8 userStatus; /* app-layer defined status */ | |
188 | u8 securityIndex; /* security protocol ID */ | |
189 | union { | |
190 | u16 _rsvd; /* reserved */ | |
191 | u16 cksum; /* kerberos security checksum */ | |
192 | }; | |
193 | u16 serviceId; /* service ID */ | |
194 | } __packed; | |
195 | ||
17926a79 DH |
196 | /* |
197 | * RxRPC socket buffer private variables | |
198 | * - max 48 bytes (struct sk_buff::cb) | |
199 | */ | |
200 | struct rxrpc_skb_priv { | |
41b7fa15 | 201 | union { |
4b68137a | 202 | struct rxrpc_connection *conn; /* Connection referred to (poke packet) */ |
41b7fa15 DH |
203 | struct { |
204 | u16 offset; /* Offset of data */ | |
205 | u16 len; /* Length of data */ | |
206 | u8 flags; | |
d4d02d8b | 207 | #define RXRPC_RX_VERIFIED 0x01 |
41b7fa15 DH |
208 | }; |
209 | struct { | |
210 | rxrpc_seq_t first_ack; /* First packet in acks table */ | |
4b68137a DH |
211 | rxrpc_seq_t prev_ack; /* Highest seq seen */ |
212 | rxrpc_serial_t acked_serial; /* Packet in response to (or 0) */ | |
213 | u8 reason; /* Reason for ack */ | |
41b7fa15 DH |
214 | u8 nr_acks; /* Number of acks+nacks */ |
215 | u8 nr_nacks; /* Number of nacks */ | |
4b68137a | 216 | } ack; |
41b7fa15 | 217 | }; |
d4d02d8b | 218 | struct rxrpc_host_header hdr; /* RxRPC packet header from this packet */ |
17926a79 DH |
219 | }; |
220 | ||
221 | #define rxrpc_skb(__skb) ((struct rxrpc_skb_priv *) &(__skb)->cb) | |
222 | ||
17926a79 DH |
223 | /* |
224 | * RxRPC security module interface | |
225 | */ | |
226 | struct rxrpc_security { | |
17926a79 DH |
227 | const char *name; /* name of this service */ |
228 | u8 security_index; /* security type provided */ | |
063c60d3 | 229 | u32 no_key_abort; /* Abort code indicating no key */ |
17926a79 | 230 | |
648af7fc DH |
231 | /* Initialise a security service */ |
232 | int (*init)(void); | |
233 | ||
234 | /* Clean up a security service */ | |
235 | void (*exit)(void); | |
236 | ||
12da59fc DH |
237 | /* Parse the information from a server key */ |
238 | int (*preparse_server_key)(struct key_preparsed_payload *); | |
239 | ||
240 | /* Clean up the preparse buffer after parsing a server key */ | |
241 | void (*free_preparse_server_key)(struct key_preparsed_payload *); | |
242 | ||
243 | /* Destroy the payload of a server key */ | |
244 | void (*destroy_server_key)(struct key *); | |
245 | ||
d5953f65 DH |
246 | /* Describe a server key */ |
247 | void (*describe_server_key)(const struct key *, struct seq_file *); | |
248 | ||
17926a79 | 249 | /* initialise a connection's security */ |
41057ebd DH |
250 | int (*init_connection_security)(struct rxrpc_connection *, |
251 | struct rxrpc_key_token *); | |
17926a79 | 252 | |
d7d775b1 | 253 | /* Work out how much data we can store in a packet, given an estimate |
49489bb0 | 254 | * of the amount of data remaining and allocate a data buffer. |
d7d775b1 | 255 | */ |
49489bb0 | 256 | struct rxrpc_txbuf *(*alloc_txbuf)(struct rxrpc_call *call, size_t remaining, gfp_t gfp); |
17926a79 DH |
257 | |
258 | /* impose security on a packet */ | |
a4ea4c47 | 259 | int (*secure_packet)(struct rxrpc_call *, struct rxrpc_txbuf *); |
17926a79 DH |
260 | |
261 | /* verify the security on a received packet */ | |
d4d02d8b | 262 | int (*verify_packet)(struct rxrpc_call *, struct sk_buff *); |
248f219c | 263 | |
1db88c53 DH |
264 | /* Free crypto request on a call */ |
265 | void (*free_call_crypto)(struct rxrpc_call *); | |
266 | ||
17926a79 DH |
267 | /* issue a challenge */ |
268 | int (*issue_challenge)(struct rxrpc_connection *); | |
269 | ||
270 | /* respond to a challenge */ | |
271 | int (*respond_to_challenge)(struct rxrpc_connection *, | |
a00ce28b | 272 | struct sk_buff *); |
17926a79 DH |
273 | |
274 | /* verify a response */ | |
275 | int (*verify_response)(struct rxrpc_connection *, | |
a00ce28b | 276 | struct sk_buff *); |
17926a79 DH |
277 | |
278 | /* clear connection security */ | |
279 | void (*clear)(struct rxrpc_connection *); | |
280 | }; | |
281 | ||
282 | /* | |
4f95dd78 DH |
283 | * RxRPC local transport endpoint description |
284 | * - owned by a single AF_RXRPC socket | |
285 | * - pointed to by transport socket struct sk_user_data | |
17926a79 DH |
286 | */ |
287 | struct rxrpc_local { | |
4f95dd78 | 288 | struct rcu_head rcu; |
730c5fd4 | 289 | atomic_t active_users; /* Number of users of the local endpoint */ |
a0575429 | 290 | refcount_t ref; /* Number of references to the structure */ |
8a758d98 DH |
291 | struct net *net; /* The network namespace */ |
292 | struct rxrpc_net *rxnet; /* Our bits in the network namespace */ | |
33912c26 | 293 | struct hlist_node link; |
17926a79 | 294 | struct socket *socket; /* my UDP socket */ |
a275da62 | 295 | struct task_struct *io_thread; |
8fbcc833 | 296 | struct completion io_thread_ready; /* Indication that the I/O thread started */ |
49489bb0 | 297 | struct page_frag_cache tx_alloc; /* Tx control packet allocation (I/O thread only) */ |
42f229c3 | 298 | struct rxrpc_sock *service; /* Service(s) listening on this endpoint */ |
af094824 DH |
299 | #ifdef CONFIG_AF_RXRPC_INJECT_RX_DELAY |
300 | struct sk_buff_head rx_delay_queue; /* Delay injection queue */ | |
301 | #endif | |
a275da62 | 302 | struct sk_buff_head rx_queue; /* Received packets */ |
f2cce89a | 303 | struct list_head conn_attend_q; /* Conns requiring immediate attention */ |
15f661dc | 304 | struct list_head call_attend_q; /* Calls requiring immediate attention */ |
0d6bf319 | 305 | |
245500d8 DH |
306 | struct rb_root client_bundles; /* Client connection bundles by socket params */ |
307 | spinlock_t client_bundles_lock; /* Lock for client_bundles */ | |
0d6bf319 | 308 | bool kill_all_client_conns; |
0d6bf319 DH |
309 | struct list_head idle_client_conns; |
310 | struct timer_list client_conn_reap_timer; | |
311 | unsigned long client_conn_flags; | |
312 | #define RXRPC_CLIENT_CONN_REAP_TIMER 0 /* The client conn reap timer expired */ | |
313 | ||
17926a79 DH |
314 | spinlock_t lock; /* access lock */ |
315 | rwlock_t services_lock; /* lock for services list */ | |
17926a79 | 316 | int debug_id; /* debug ID for printks */ |
4f95dd78 | 317 | bool dead; |
f859ab61 | 318 | bool service_closed; /* Service socket closed */ |
f06cb291 | 319 | struct idr conn_ids; /* List of connection IDs */ |
9d35d880 DH |
320 | struct list_head new_client_calls; /* Newly created client calls need connection */ |
321 | spinlock_t client_call_lock; /* Lock for ->new_client_calls */ | |
17926a79 DH |
322 | struct sockaddr_rxrpc srx; /* local address */ |
323 | }; | |
324 | ||
325 | /* | |
326 | * RxRPC remote transport endpoint definition | |
be6e6707 | 327 | * - matched by local endpoint, remote port, address and protocol type |
17926a79 DH |
328 | */ |
329 | struct rxrpc_peer { | |
be6e6707 | 330 | struct rcu_head rcu; /* This must be first */ |
a0575429 | 331 | refcount_t ref; |
be6e6707 DH |
332 | unsigned long hash_key; |
333 | struct hlist_node hash_link; | |
334 | struct rxrpc_local *local; | |
f66d7490 | 335 | struct hlist_head error_targets; /* targets for net error distribution */ |
aa390bbe | 336 | struct rb_root service_conns; /* Service connections */ |
330bdcfa | 337 | struct list_head keepalive_link; /* Link in net->peer_keepalive[] */ |
ace45bec | 338 | time64_t last_tx_at; /* Last time packet sent here */ |
8496af50 | 339 | seqlock_t service_conn_lock; |
17926a79 | 340 | spinlock_t lock; /* access lock */ |
95c96174 ED |
341 | unsigned int if_mtu; /* interface MTU for this peer */ |
342 | unsigned int mtu; /* network MTU for this peer */ | |
343 | unsigned int maxdata; /* data size (MTU - hdrsize) */ | |
17926a79 DH |
344 | unsigned short hdrsize; /* header size (IP + UDP + RxRPC) */ |
345 | int debug_id; /* debug ID for printks */ | |
17926a79 DH |
346 | struct sockaddr_rxrpc srx; /* remote address */ |
347 | ||
348 | /* calculated RTT cache */ | |
349 | #define RXRPC_RTT_CACHE_SIZE 32 | |
c1e15b49 | 350 | spinlock_t rtt_input_lock; /* RTT lock for input routine */ |
0d4b103c | 351 | ktime_t rtt_last_req; /* Time of last RTT request */ |
c410bf01 DH |
352 | unsigned int rtt_count; /* Number of samples we've got */ |
353 | ||
354 | u32 srtt_us; /* smoothed round trip time << 3 in usecs */ | |
355 | u32 mdev_us; /* medium deviation */ | |
356 | u32 mdev_max_us; /* maximal mdev for the last rtt period */ | |
357 | u32 rttvar_us; /* smoothed mdev_max */ | |
153f90a0 DH |
358 | u32 rto_us; /* Retransmission timeout in usec */ |
359 | u8 backoff; /* Backoff timeout (as shift) */ | |
f7aec129 | 360 | |
1fc4fa2a | 361 | u8 cong_ssthresh; /* Congestion slow-start threshold */ |
17926a79 DH |
362 | }; |
363 | ||
19ffa01c DH |
364 | /* |
365 | * Keys for matching a connection. | |
366 | */ | |
367 | struct rxrpc_conn_proto { | |
e8d70ce1 DH |
368 | union { |
369 | struct { | |
370 | u32 epoch; /* epoch of this connection */ | |
371 | u32 cid; /* connection ID */ | |
372 | }; | |
373 | u64 index_key; | |
19ffa01c DH |
374 | }; |
375 | }; | |
376 | ||
377 | struct rxrpc_conn_parameters { | |
378 | struct rxrpc_local *local; /* Representation of local endpoint */ | |
72904d7b | 379 | struct rxrpc_peer *peer; /* Representation of remote endpoint */ |
19ffa01c DH |
380 | struct key *key; /* Security details */ |
381 | bool exclusive; /* T if conn is exclusive */ | |
4e255721 | 382 | bool upgrade; /* T if service ID can be upgraded */ |
19ffa01c DH |
383 | u16 service_id; /* Service ID for this connection */ |
384 | u32 security_level; /* Security level selected */ | |
385 | }; | |
386 | ||
a00ce28b DH |
387 | /* |
388 | * Call completion condition (state == RXRPC_CALL_COMPLETE). | |
389 | */ | |
390 | enum rxrpc_call_completion { | |
391 | RXRPC_CALL_SUCCEEDED, /* - Normal termination */ | |
392 | RXRPC_CALL_REMOTELY_ABORTED, /* - call aborted by peer */ | |
393 | RXRPC_CALL_LOCALLY_ABORTED, /* - call aborted locally on error or close */ | |
394 | RXRPC_CALL_LOCAL_ERROR, /* - call failed due to local error */ | |
395 | RXRPC_CALL_NETWORK_ERROR, /* - call terminated by network error */ | |
396 | NR__RXRPC_CALL_COMPLETIONS | |
397 | }; | |
398 | ||
bba304db DH |
399 | /* |
400 | * Bits in the connection flags. | |
401 | */ | |
402 | enum rxrpc_conn_flag { | |
001c1122 | 403 | RXRPC_CONN_IN_SERVICE_CONNS, /* Conn is in peer->service_conns */ |
45025bce | 404 | RXRPC_CONN_DONT_REUSE, /* Don't reuse this connection */ |
4e255721 | 405 | RXRPC_CONN_PROBING_FOR_UPGRADE, /* Probing for service upgrade */ |
3136ef49 DH |
406 | RXRPC_CONN_FINAL_ACK_0, /* Need final ACK for channel 0 */ |
407 | RXRPC_CONN_FINAL_ACK_1, /* Need final ACK for channel 1 */ | |
408 | RXRPC_CONN_FINAL_ACK_2, /* Need final ACK for channel 2 */ | |
409 | RXRPC_CONN_FINAL_ACK_3, /* Need final ACK for channel 3 */ | |
bba304db DH |
410 | }; |
411 | ||
3136ef49 DH |
412 | #define RXRPC_CONN_FINAL_ACK_MASK ((1UL << RXRPC_CONN_FINAL_ACK_0) | \ |
413 | (1UL << RXRPC_CONN_FINAL_ACK_1) | \ | |
414 | (1UL << RXRPC_CONN_FINAL_ACK_2) | \ | |
415 | (1UL << RXRPC_CONN_FINAL_ACK_3)) | |
416 | ||
bba304db DH |
417 | /* |
418 | * Events that can be raised upon a connection. | |
419 | */ | |
420 | enum rxrpc_conn_event { | |
421 | RXRPC_CONN_EV_CHALLENGE, /* Send challenge packet */ | |
a00ce28b | 422 | RXRPC_CONN_EV_ABORT_CALLS, /* Abort attached calls */ |
bba304db DH |
423 | }; |
424 | ||
425 | /* | |
426 | * The connection protocol state. | |
427 | */ | |
428 | enum rxrpc_conn_proto_state { | |
429 | RXRPC_CONN_UNUSED, /* Connection not yet attempted */ | |
9d35d880 | 430 | RXRPC_CONN_CLIENT_UNSECURED, /* Client connection needs security init */ |
bba304db | 431 | RXRPC_CONN_CLIENT, /* Client connection */ |
00e90712 | 432 | RXRPC_CONN_SERVICE_PREALLOC, /* Service connection preallocation */ |
bba304db DH |
433 | RXRPC_CONN_SERVICE_UNSECURED, /* Service unsecured connection */ |
434 | RXRPC_CONN_SERVICE_CHALLENGING, /* Service challenging for security */ | |
435 | RXRPC_CONN_SERVICE, /* Service secured connection */ | |
a00ce28b | 436 | RXRPC_CONN_ABORTED, /* Conn aborted */ |
bba304db DH |
437 | RXRPC_CONN__NR_STATES |
438 | }; | |
439 | ||
245500d8 DH |
440 | /* |
441 | * RxRPC client connection bundle. | |
442 | */ | |
443 | struct rxrpc_bundle { | |
2cc80086 DH |
444 | struct rxrpc_local *local; /* Representation of local endpoint */ |
445 | struct rxrpc_peer *peer; /* Remote endpoint */ | |
446 | struct key *key; /* Security details */ | |
d2ce4a84 | 447 | struct list_head proc_link; /* Link in net->bundle_proc_list */ |
1bab27af | 448 | const struct rxrpc_security *security; /* applied security module */ |
a0575429 | 449 | refcount_t ref; |
3bcd6c7e | 450 | atomic_t active; /* Number of active users */ |
245500d8 | 451 | unsigned int debug_id; |
2cc80086 DH |
452 | u32 security_level; /* Security level selected */ |
453 | u16 service_id; /* Service ID for this connection */ | |
245500d8 | 454 | bool try_upgrade; /* True if the bundle is attempting upgrade */ |
2cc80086 DH |
455 | bool exclusive; /* T if conn is exclusive */ |
456 | bool upgrade; /* T if service ID can be upgraded */ | |
9d35d880 | 457 | unsigned short alloc_error; /* Error from last conn allocation */ |
245500d8 DH |
458 | struct rb_node local_node; /* Node in local->client_conns */ |
459 | struct list_head waiting_calls; /* Calls waiting for channels */ | |
460 | unsigned long avail_chans; /* Mask of available channels */ | |
d2ce4a84 | 461 | unsigned int conn_ids[4]; /* Connection IDs. */ |
245500d8 DH |
462 | struct rxrpc_connection *conns[4]; /* The connections in the bundle (max 4) */ |
463 | }; | |
464 | ||
17926a79 DH |
465 | /* |
466 | * RxRPC connection definition | |
aa390bbe | 467 | * - matched by { local, peer, epoch, conn_id, direction } |
17926a79 DH |
468 | * - each connection can only handle four simultaneous calls |
469 | */ | |
470 | struct rxrpc_connection { | |
19ffa01c | 471 | struct rxrpc_conn_proto proto; |
2cc80086 DH |
472 | struct rxrpc_local *local; /* Representation of local endpoint */ |
473 | struct rxrpc_peer *peer; /* Remote endpoint */ | |
3cec055c | 474 | struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ |
2cc80086 | 475 | struct key *key; /* Security details */ |
f2cce89a | 476 | struct list_head attend_link; /* Link in local->conn_attend_q */ |
19ffa01c | 477 | |
a0575429 | 478 | refcount_t ref; |
3cec055c | 479 | atomic_t active; /* Active count for service conns */ |
45025bce DH |
480 | struct rcu_head rcu; |
481 | struct list_head cache_link; | |
a1399f8b | 482 | |
245500d8 | 483 | unsigned char act_chans; /* Mask of active channels */ |
a1399f8b | 484 | struct rxrpc_channel { |
3136ef49 | 485 | unsigned long final_ack_at; /* Time at which to issue final ACK */ |
9d35d880 | 486 | struct rxrpc_call *call; /* Active call */ |
4764c0da | 487 | unsigned int call_debug_id; /* call->debug_id */ |
a1399f8b DH |
488 | u32 call_id; /* ID of current call */ |
489 | u32 call_counter; /* Call ID counter */ | |
490 | u32 last_call; /* ID of last call */ | |
18bfeba5 | 491 | u8 last_type; /* Type of last packet */ |
18bfeba5 DH |
492 | union { |
493 | u32 last_seq; | |
494 | u32 last_abort; | |
495 | }; | |
a1399f8b | 496 | } channels[RXRPC_MAXCALLS]; |
999b69f8 | 497 | |
3136ef49 | 498 | struct timer_list timer; /* Conn event timer */ |
17926a79 | 499 | struct work_struct processor; /* connection event processor */ |
3cec055c | 500 | struct work_struct destructor; /* In-process-context destroyer */ |
245500d8 DH |
501 | struct rxrpc_bundle *bundle; /* Client connection bundle */ |
502 | struct rb_node service_node; /* Node in peer->service_conns */ | |
4d028b2c | 503 | struct list_head proc_link; /* link in procfs list */ |
17926a79 | 504 | struct list_head link; /* link in master connection list */ |
17926a79 | 505 | struct sk_buff_head rx_queue; /* received conn-level packets */ |
49489bb0 DH |
506 | struct page_frag_cache tx_data_alloc; /* Tx DATA packet allocation */ |
507 | struct mutex tx_data_alloc_lock; | |
521bb304 | 508 | |
9d35d880 | 509 | struct mutex security_lock; /* Lock for security management */ |
648af7fc | 510 | const struct rxrpc_security *security; /* applied security module */ |
521bb304 DH |
511 | union { |
512 | struct { | |
513 | struct crypto_sync_skcipher *cipher; /* encryption handle */ | |
514 | struct rxrpc_crypt csum_iv; /* packet checksum base */ | |
515 | u32 nonce; /* response re-use preventer */ | |
516 | } rxkad; | |
517 | }; | |
4a3388c8 | 518 | unsigned long flags; |
17926a79 | 519 | unsigned long events; |
f51b4480 | 520 | unsigned long idle_timestamp; /* Time at which last became idle */ |
17926a79 | 521 | spinlock_t state_lock; /* state-change lock */ |
cf13258f | 522 | enum rxrpc_conn_proto_state state; /* current state of connection */ |
a00ce28b DH |
523 | enum rxrpc_call_completion completion; /* Completion condition */ |
524 | s32 abort_code; /* Abort code of connection abort */ | |
17926a79 | 525 | int debug_id; /* debug ID for printks */ |
f3104141 | 526 | rxrpc_serial_t tx_serial; /* Outgoing packet serial number counter */ |
563ea7d5 | 527 | unsigned int hi_serial; /* highest serial number received */ |
c1e15b49 | 528 | u32 service_id; /* Service ID, possibly upgraded */ |
2cc80086 | 529 | u32 security_level; /* Security level selected */ |
17926a79 | 530 | u8 security_ix; /* security type */ |
17926a79 | 531 | u8 out_clientflag; /* RXRPC_CLIENT_INITIATED if we are client */ |
245500d8 | 532 | u8 bundle_shift; /* Index into bundle->avail_chans */ |
2cc80086 DH |
533 | bool exclusive; /* T if conn is exclusive */ |
534 | bool upgrade; /* T if service ID can be upgraded */ | |
535 | u16 orig_service_id; /* Originally requested service ID */ | |
64753092 | 536 | short error; /* Local error code */ |
17926a79 DH |
537 | }; |
538 | ||
dc71db34 DH |
539 | static inline bool rxrpc_to_server(const struct rxrpc_skb_priv *sp) |
540 | { | |
541 | return sp->hdr.flags & RXRPC_CLIENT_INITIATED; | |
542 | } | |
543 | ||
544 | static inline bool rxrpc_to_client(const struct rxrpc_skb_priv *sp) | |
545 | { | |
546 | return !rxrpc_to_server(sp); | |
547 | } | |
548 | ||
5b8848d1 DH |
549 | /* |
550 | * Flags in call->flags. | |
551 | */ | |
552 | enum rxrpc_call_flag { | |
553 | RXRPC_CALL_RELEASED, /* call has been released - no more message to userspace */ | |
5b8848d1 | 554 | RXRPC_CALL_HAS_USERID, /* has a user ID attached */ |
dabe5a79 | 555 | RXRPC_CALL_IS_SERVICE, /* Call is service call */ |
45025bce | 556 | RXRPC_CALL_EXPOSED, /* The call was exposed to the world */ |
248f219c DH |
557 | RXRPC_CALL_RX_LAST, /* Received the last packet (at rxtx_top) */ |
558 | RXRPC_CALL_TX_LAST, /* Last packet in Tx buffer (at rxtx_top) */ | |
a4ea4c47 | 559 | RXRPC_CALL_TX_ALL_ACKED, /* Last packet has been hard-acked */ |
a5af7e1f | 560 | RXRPC_CALL_SEND_PING, /* A ping will need to be sent */ |
57494343 | 561 | RXRPC_CALL_RETRANS_TIMEOUT, /* Retransmission due to timeout occurred */ |
c54e43d7 | 562 | RXRPC_CALL_BEGAN_RX_TIMER, /* We began the expect_rx_by timer */ |
1a025028 | 563 | RXRPC_CALL_RX_HEARD, /* The peer responded at least once to this call */ |
5273a191 | 564 | RXRPC_CALL_DISCONNECTED, /* The call has been disconnected */ |
b7a7d674 | 565 | RXRPC_CALL_KERNEL, /* The call was made by the kernel */ |
245500d8 | 566 | RXRPC_CALL_UPGRADE, /* Service upgrade was requested for the call */ |
f3441d41 | 567 | RXRPC_CALL_EXCLUSIVE, /* The call uses a once-only connection */ |
93368b6b DH |
568 | RXRPC_CALL_RX_IS_IDLE, /* recvmsg() is idle - send an ACK */ |
569 | RXRPC_CALL_RECVMSG_READ_ALL, /* recvmsg() read all of the received data */ | |
5b8848d1 DH |
570 | }; |
571 | ||
572 | /* | |
573 | * Events that can be raised on a call. | |
574 | */ | |
575 | enum rxrpc_call_event { | |
bd1fdf8c | 576 | RXRPC_CALL_EV_ACK_LOST, /* ACK may be lost, send ping */ |
5e6ef4f1 | 577 | RXRPC_CALL_EV_INITIAL_PING, /* Send initial ping for a new service call */ |
5b8848d1 DH |
578 | }; |
579 | ||
580 | /* | |
581 | * The states that a call can be in. | |
582 | */ | |
583 | enum rxrpc_call_state { | |
999b69f8 DH |
584 | RXRPC_CALL_UNINITIALISED, |
585 | RXRPC_CALL_CLIENT_AWAIT_CONN, /* - client waiting for connection to become available */ | |
5b8848d1 DH |
586 | RXRPC_CALL_CLIENT_SEND_REQUEST, /* - client sending request phase */ |
587 | RXRPC_CALL_CLIENT_AWAIT_REPLY, /* - client awaiting reply */ | |
588 | RXRPC_CALL_CLIENT_RECV_REPLY, /* - client receiving reply phase */ | |
00e90712 | 589 | RXRPC_CALL_SERVER_PREALLOC, /* - service preallocation */ |
5b8848d1 | 590 | RXRPC_CALL_SERVER_SECURING, /* - server securing request connection */ |
5b8848d1 DH |
591 | RXRPC_CALL_SERVER_RECV_REQUEST, /* - server receiving request */ |
592 | RXRPC_CALL_SERVER_ACK_REQUEST, /* - server pending ACK of request */ | |
593 | RXRPC_CALL_SERVER_SEND_REPLY, /* - server sending reply */ | |
594 | RXRPC_CALL_SERVER_AWAIT_ACK, /* - server awaiting final ACK */ | |
f5c17aae | 595 | RXRPC_CALL_COMPLETE, /* - call complete */ |
f5c17aae DH |
596 | NR__RXRPC_CALL_STATES |
597 | }; | |
598 | ||
57494343 DH |
599 | /* |
600 | * Call Tx congestion management modes. | |
601 | */ | |
602 | enum rxrpc_congest_mode { | |
603 | RXRPC_CALL_SLOW_START, | |
604 | RXRPC_CALL_CONGEST_AVOIDANCE, | |
605 | RXRPC_CALL_PACKET_LOSS, | |
606 | RXRPC_CALL_FAST_RETRANSMIT, | |
607 | NR__RXRPC_CONGEST_MODES | |
608 | }; | |
609 | ||
17926a79 DH |
610 | /* |
611 | * RxRPC call definition | |
612 | * - matched by { connection, call_id } | |
613 | */ | |
614 | struct rxrpc_call { | |
dee46364 | 615 | struct rcu_head rcu; |
17926a79 | 616 | struct rxrpc_connection *conn; /* connection carrying call */ |
1bab27af | 617 | struct rxrpc_bundle *bundle; /* Connection bundle to use */ |
df5d8bf7 | 618 | struct rxrpc_peer *peer; /* Peer record for remote address */ |
f3441d41 | 619 | struct rxrpc_local *local; /* Representation of local endpoint */ |
8d94aa38 | 620 | struct rxrpc_sock __rcu *socket; /* socket responsible */ |
d3be4d24 | 621 | struct rxrpc_net *rxnet; /* Network namespace to which call belongs */ |
f3441d41 | 622 | struct key *key; /* Security details */ |
91fcfbe8 | 623 | const struct rxrpc_security *security; /* applied security module */ |
540b1c48 | 624 | struct mutex user_mutex; /* User access mutex */ |
f3441d41 | 625 | struct sockaddr_rxrpc dest_srx; /* Destination address */ |
153f90a0 DH |
626 | ktime_t delay_ack_at; /* When DELAY ACK needs to happen */ |
627 | ktime_t ack_lost_at; /* When ACK is figured as lost */ | |
628 | ktime_t resend_at; /* When next resend needs to happen */ | |
629 | ktime_t ping_at; /* When next to send a ping */ | |
630 | ktime_t keepalive_at; /* When next to send a keepalive ping */ | |
631 | ktime_t expect_rx_by; /* When we expect to get a packet by */ | |
632 | ktime_t expect_req_by; /* When we expect to get a request DATA packet by */ | |
633 | ktime_t expect_term_by; /* When we expect call termination by */ | |
634 | u32 next_rx_timo; /* Timeout for next Rx packet (ms) */ | |
635 | u32 next_req_timo; /* Timeout for next Rx request packet (ms) */ | |
636 | u32 hard_timo; /* Maximum lifetime or 0 (s) */ | |
248f219c | 637 | struct timer_list timer; /* Combined event timer */ |
3feda9d6 | 638 | struct work_struct destroyer; /* In-process-context destroyer */ |
d001648e | 639 | rxrpc_notify_rx_t notify_rx; /* kernel service Rx notification function */ |
17926a79 | 640 | struct list_head link; /* link in master call list */ |
9d35d880 | 641 | struct list_head wait_link; /* Link in local->new_client_calls */ |
f66d7490 | 642 | struct hlist_node error_link; /* link in error distribution list */ |
248f219c DH |
643 | struct list_head accept_link; /* Link in rx->acceptq */ |
644 | struct list_head recvmsg_link; /* Link in rx->recvmsg_q */ | |
645 | struct list_head sock_link; /* Link in rx->sock_calls */ | |
646 | struct rb_node sock_node; /* Node in rx->calls */ | |
15f661dc | 647 | struct list_head attend_link; /* Link in local->call_attend_q */ |
a4ea4c47 | 648 | struct rxrpc_txbuf *tx_pending; /* Tx buffer being filled */ |
45025bce | 649 | wait_queue_head_t waitq; /* Wait queue for channel or Tx */ |
e754eba6 | 650 | s64 tx_total_len; /* Total length left to be transmitted (or -1) */ |
17926a79 | 651 | unsigned long user_call_ID; /* user-defined call ID */ |
17926a79 | 652 | unsigned long flags; |
17926a79 | 653 | unsigned long events; |
20acbd9a | 654 | spinlock_t notify_lock; /* Kernel notification lock */ |
57af281e | 655 | unsigned int send_abort_why; /* Why the abort [enum rxrpc_abort_reason] */ |
a343b174 DH |
656 | s32 send_abort; /* Abort code to be sent */ |
657 | short send_abort_err; /* Error to be associated with the abort */ | |
57af281e | 658 | rxrpc_seq_t send_abort_seq; /* DATA packet that incurred the abort (or 0) */ |
a343b174 | 659 | s32 abort_code; /* Local/remote abort code */ |
f5c17aae | 660 | int error; /* Local error incurred */ |
96b4059f | 661 | enum rxrpc_call_state _state; /* Current state of call (needs barrier) */ |
cf13258f | 662 | enum rxrpc_call_completion completion; /* Call completion condition */ |
a0575429 | 663 | refcount_t ref; |
278ac0cd | 664 | u8 security_ix; /* Security type */ |
e138aa7d | 665 | enum rxrpc_interruptibility interruptibility; /* At what point call may be interrupted */ |
dabe5a79 DH |
666 | u32 call_id; /* call ID on connection */ |
667 | u32 cid; /* connection ID plus channel index */ | |
f3441d41 | 668 | u32 security_level; /* Security level selected */ |
dabe5a79 | 669 | int debug_id; /* debug ID for printks */ |
8e83134d DH |
670 | unsigned short rx_pkt_offset; /* Current recvmsg packet offset */ |
671 | unsigned short rx_pkt_len; /* Current recvmsg packet len */ | |
17926a79 | 672 | |
5d7edbc9 | 673 | /* Transmitted data tracking. */ |
a4ea4c47 | 674 | spinlock_t tx_lock; /* Transmit queue lock */ |
cf37b598 | 675 | struct list_head tx_sendmsg; /* Sendmsg prepared packets */ |
a4ea4c47 DH |
676 | struct list_head tx_buffer; /* Buffer of transmissible packets */ |
677 | rxrpc_seq_t tx_bottom; /* First packet in buffer */ | |
678 | rxrpc_seq_t tx_transmitted; /* Highest packet transmitted */ | |
cf37b598 | 679 | rxrpc_seq_t tx_prepared; /* Highest Tx slot prepared. */ |
248f219c | 680 | rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */ |
153f90a0 | 681 | u16 tx_backoff; /* Delay to insert due to Tx failure (ms) */ |
5d7edbc9 | 682 | u8 tx_winsize; /* Maximum size of Tx window */ |
a4ea4c47 | 683 | #define RXRPC_TX_MAX_WINDOW 128 |
1fc4fa2a | 684 | ktime_t tx_last_sent; /* Last time a transmission occurred */ |
5d7edbc9 DH |
685 | |
686 | /* Received data tracking */ | |
687 | struct sk_buff_head recvmsg_queue; /* Queue of packets ready for recvmsg() */ | |
688 | struct sk_buff_head rx_oos_queue; /* Queue of out of sequence packets */ | |
689 | ||
690 | rxrpc_seq_t rx_highest_seq; /* Higest sequence number received */ | |
691 | rxrpc_seq_t rx_consumed; /* Highest packet consumed */ | |
692 | rxrpc_serial_t rx_serial; /* Highest serial received for this call */ | |
693 | u8 rx_winsize; /* Size of Rx window */ | |
57494343 DH |
694 | |
695 | /* TCP-style slow-start congestion control [RFC5681]. Since the SMSS | |
696 | * is fixed, we keep these numbers in terms of segments (ie. DATA | |
697 | * packets) rather than bytes. | |
698 | */ | |
699 | #define RXRPC_TX_SMSS RXRPC_JUMBO_DATALEN | |
ba4e1038 | 700 | #define RXRPC_MIN_CWND 4 |
57494343 DH |
701 | u8 cong_cwnd; /* Congestion window size */ |
702 | u8 cong_extra; /* Extra to send for congestion management */ | |
703 | u8 cong_ssthresh; /* Slow-start threshold */ | |
704 | enum rxrpc_congest_mode cong_mode:8; /* Congestion management mode */ | |
705 | u8 cong_dup_acks; /* Count of ACKs showing missing packets */ | |
706 | u8 cong_cumul_acks; /* Cumulative ACK count */ | |
707 | ktime_t cong_tstamp; /* Last time cwnd was changed */ | |
41b7fa15 | 708 | struct sk_buff *cong_last_nack; /* Last ACK with nacks received */ |
57494343 | 709 | |
8940ba3c | 710 | /* Receive-phase ACK management (ACKs we send). */ |
4e36a95e | 711 | u8 ackr_reason; /* reason to ACK */ |
f21e9348 | 712 | u16 ackr_sack_base; /* Starting slot in SACK table ring */ |
5bbf9533 DH |
713 | rxrpc_seq_t ackr_window; /* Base of SACK window */ |
714 | rxrpc_seq_t ackr_wtop; /* Base of SACK window */ | |
715 | unsigned int ackr_nr_unacked; /* Number of unacked packets */ | |
9a3dedcf | 716 | atomic_t ackr_nr_consumed; /* Number of packets needing hard ACK */ |
5d7edbc9 DH |
717 | struct { |
718 | #define RXRPC_SACK_SIZE 256 | |
719 | /* SACK table for soft-acked packets */ | |
720 | u8 ackr_sack_table[RXRPC_SACK_SIZE]; | |
721 | } __aligned(8); | |
a5af7e1f | 722 | |
4700c4d8 DH |
723 | /* RTT management */ |
724 | rxrpc_serial_t rtt_serial[4]; /* Serial number of DATA or PING sent */ | |
725 | ktime_t rtt_sent_at[4]; /* Time packet sent */ | |
726 | unsigned long rtt_avail; /* Mask of available slots in bits 0-3, | |
727 | * Mask of pending samples in 8-11 */ | |
728 | #define RXRPC_CALL_RTT_AVAIL_MASK 0xf | |
729 | #define RXRPC_CALL_RTT_PEND_SHIFT 8 | |
17926a79 | 730 | |
8940ba3c | 731 | /* Transmission-phase ACK management (ACKs we've received). */ |
57494343 | 732 | ktime_t acks_latest_ts; /* Timestamp of latest ACK received */ |
8940ba3c | 733 | rxrpc_seq_t acks_first_seq; /* first sequence number received */ |
81524b63 | 734 | rxrpc_seq_t acks_prev_seq; /* Highest previousPacket received */ |
a4ea4c47 | 735 | rxrpc_seq_t acks_hard_ack; /* Latest hard-ack point */ |
31a1b989 | 736 | rxrpc_seq_t acks_lowest_nak; /* Lowest NACK in the buffer (or ==tx_hard_ack) */ |
589a0c1e | 737 | rxrpc_serial_t acks_highest_serial; /* Highest serial number ACK'd */ |
31a1b989 DH |
738 | }; |
739 | ||
740 | /* | |
57494343 | 741 | * Summary of a new ACK and the changes it made to the Tx buffer packet states. |
31a1b989 DH |
742 | */ |
743 | struct rxrpc_ack_summary { | |
1fc4fa2a DH |
744 | u16 nr_acks; /* Number of ACKs in packet */ |
745 | u16 nr_new_acks; /* Number of new ACKs in packet */ | |
41b7fa15 DH |
746 | u16 nr_new_nacks; /* Number of new nacks in packet */ |
747 | u16 nr_retained_nacks; /* Number of nacks retained between ACKs */ | |
31a1b989 | 748 | u8 ack_reason; |
d57a3a15 | 749 | bool saw_nacks; /* Saw NACKs in packet */ |
31a1b989 | 750 | bool new_low_nack; /* T if new low NACK found */ |
57494343 DH |
751 | bool retrans_timeo; /* T if reTx due to timeout happened */ |
752 | u8 flight_size; /* Number of unreceived transmissions */ | |
753 | /* Place to stash values for tracing */ | |
754 | enum rxrpc_congest_mode mode:8; | |
755 | u8 cwnd; | |
756 | u8 ssthresh; | |
757 | u8 dup_acks; | |
758 | u8 cumulative_acks; | |
17926a79 DH |
759 | }; |
760 | ||
48124178 DH |
761 | /* |
762 | * sendmsg() cmsg-specified parameters. | |
763 | */ | |
764 | enum rxrpc_command { | |
765 | RXRPC_CMD_SEND_DATA, /* send data message */ | |
766 | RXRPC_CMD_SEND_ABORT, /* request abort generation */ | |
48124178 | 767 | RXRPC_CMD_REJECT_BUSY, /* [server] reject a call as busy */ |
2d914c1b | 768 | RXRPC_CMD_CHARGE_ACCEPT, /* [server] charge accept preallocation */ |
48124178 DH |
769 | }; |
770 | ||
771 | struct rxrpc_call_params { | |
772 | s64 tx_total_len; /* Total Tx data length (if send data) */ | |
773 | unsigned long user_call_ID; /* User's call ID */ | |
774 | struct { | |
775 | u32 hard; /* Maximum lifetime (sec) */ | |
776 | u32 idle; /* Max time since last data packet (msec) */ | |
777 | u32 normal; /* Max time since last call packet (msec) */ | |
778 | } timeouts; | |
779 | u8 nr_timeouts; /* Number of timeouts specified */ | |
b7a7d674 | 780 | bool kernel; /* T if kernel is making the call */ |
e138aa7d | 781 | enum rxrpc_interruptibility interruptibility; /* How is interruptible is the call? */ |
48124178 DH |
782 | }; |
783 | ||
784 | struct rxrpc_send_params { | |
785 | struct rxrpc_call_params call; | |
786 | u32 abort_code; /* Abort code to Tx (if abort) */ | |
787 | enum rxrpc_command command : 8; /* The command to implement */ | |
788 | bool exclusive; /* Shared or exclusive call */ | |
789 | bool upgrade; /* If the connection is upgradeable */ | |
790 | }; | |
791 | ||
02a19356 DH |
792 | /* |
793 | * Buffer of data to be output as a packet. | |
794 | */ | |
795 | struct rxrpc_txbuf { | |
cf37b598 | 796 | struct list_head call_link; /* Link in call->tx_sendmsg/tx_buffer */ |
02a19356 | 797 | struct list_head tx_link; /* Link in live Enc queue or Tx queue */ |
02a19356 DH |
798 | ktime_t last_sent; /* Time at which last transmitted */ |
799 | refcount_t ref; | |
800 | rxrpc_seq_t seq; /* Sequence number of this packet */ | |
ba132d84 | 801 | rxrpc_serial_t serial; /* Last serial number transmitted with */ |
02a19356 DH |
802 | unsigned int call_debug_id; |
803 | unsigned int debug_id; | |
804 | unsigned int len; /* Amount of data in buffer */ | |
805 | unsigned int space; /* Remaining data space */ | |
806 | unsigned int offset; /* Offset of fill point */ | |
12bdff73 DH |
807 | unsigned int flags; |
808 | #define RXRPC_TXBUF_WIRE_FLAGS 0xff /* The wire protocol flags */ | |
809 | #define RXRPC_TXBUF_RESENT 0x100 /* Set if has been resent */ | |
41b8debb | 810 | __be16 cksum; /* Checksum to go in header */ |
8985f2b0 | 811 | unsigned short ack_rwind; /* ACK receive window */ |
72f0c6fb | 812 | u8 /*enum rxrpc_propose_ack_trace*/ ack_why; /* If ack, why */ |
49489bb0 DH |
813 | u8 nr_kvec; /* Amount of kvec[] used */ |
814 | struct kvec kvec[3]; | |
02a19356 DH |
815 | }; |
816 | ||
817 | static inline bool rxrpc_sending_to_server(const struct rxrpc_txbuf *txb) | |
818 | { | |
12bdff73 | 819 | return txb->flags & RXRPC_CLIENT_INITIATED; |
02a19356 DH |
820 | } |
821 | ||
822 | static inline bool rxrpc_sending_to_client(const struct rxrpc_txbuf *txb) | |
823 | { | |
824 | return !rxrpc_sending_to_server(txb); | |
825 | } | |
826 | ||
df844fd4 DH |
827 | #include <trace/events/rxrpc.h> |
828 | ||
f3104141 DH |
829 | /* |
830 | * Allocate the next serial number on a connection. 0 must be skipped. | |
831 | */ | |
832 | static inline rxrpc_serial_t rxrpc_get_next_serial(struct rxrpc_connection *conn) | |
833 | { | |
834 | rxrpc_serial_t serial; | |
835 | ||
836 | serial = conn->tx_serial; | |
837 | if (serial == 0) | |
838 | serial = 1; | |
839 | conn->tx_serial = serial + 1; | |
840 | return serial; | |
841 | } | |
842 | ||
17926a79 | 843 | /* |
651350d1 | 844 | * af_rxrpc.c |
17926a79 | 845 | */ |
a4ea4c47 | 846 | extern atomic_t rxrpc_n_rx_skbs; |
651350d1 | 847 | extern struct workqueue_struct *rxrpc_workqueue; |
17926a79 DH |
848 | |
849 | /* | |
0d81a51a | 850 | * call_accept.c |
17926a79 | 851 | */ |
00e90712 DH |
852 | int rxrpc_service_prealloc(struct rxrpc_sock *, gfp_t); |
853 | void rxrpc_discard_prealloc(struct rxrpc_sock *); | |
57af281e DH |
854 | bool rxrpc_new_incoming_call(struct rxrpc_local *local, |
855 | struct rxrpc_peer *peer, | |
856 | struct rxrpc_connection *conn, | |
857 | struct sockaddr_rxrpc *peer_srx, | |
858 | struct sk_buff *skb); | |
2d914c1b | 859 | int rxrpc_user_charge_accept(struct rxrpc_sock *, unsigned long); |
17926a79 DH |
860 | |
861 | /* | |
0d81a51a | 862 | * call_event.c |
17926a79 | 863 | */ |
72f0c6fb DH |
864 | void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial, |
865 | enum rxrpc_propose_ack_trace why); | |
530403d9 DH |
866 | void rxrpc_propose_delay_ACK(struct rxrpc_call *, rxrpc_serial_t, |
867 | enum rxrpc_propose_ack_trace); | |
a4ea4c47 | 868 | void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *); |
5e6ef4f1 | 869 | void rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb); |
17926a79 | 870 | |
57af281e | 871 | bool rxrpc_input_call_event(struct rxrpc_call *call, struct sk_buff *skb); |
5e6ef4f1 | 872 | |
17926a79 | 873 | /* |
0d81a51a | 874 | * call_object.c |
17926a79 | 875 | */ |
f5c17aae DH |
876 | extern const char *const rxrpc_call_states[]; |
877 | extern const char *const rxrpc_call_completions[]; | |
17926a79 | 878 | extern struct kmem_cache *rxrpc_call_jar; |
17926a79 | 879 | |
15f661dc | 880 | void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what); |
2341e077 | 881 | struct rxrpc_call *rxrpc_find_call_by_user_ID(struct rxrpc_sock *, unsigned long); |
a25e21f0 | 882 | struct rxrpc_call *rxrpc_alloc_call(struct rxrpc_sock *, gfp_t, unsigned int); |
2341e077 | 883 | struct rxrpc_call *rxrpc_new_client_call(struct rxrpc_sock *, |
19ffa01c | 884 | struct rxrpc_conn_parameters *, |
a25e21f0 DH |
885 | struct rxrpc_call_params *, gfp_t, |
886 | unsigned int); | |
9d35d880 | 887 | void rxrpc_start_call_timer(struct rxrpc_call *call); |
248f219c DH |
888 | void rxrpc_incoming_call(struct rxrpc_sock *, struct rxrpc_call *, |
889 | struct sk_buff *); | |
8d94aa38 | 890 | void rxrpc_release_call(struct rxrpc_sock *, struct rxrpc_call *); |
c1b1203d | 891 | void rxrpc_release_calls_on_socket(struct rxrpc_sock *); |
cb0fc0c9 | 892 | void rxrpc_see_call(struct rxrpc_call *, enum rxrpc_call_trace); |
5e6ef4f1 | 893 | struct rxrpc_call *rxrpc_try_get_call(struct rxrpc_call *, enum rxrpc_call_trace); |
fff72429 DH |
894 | void rxrpc_get_call(struct rxrpc_call *, enum rxrpc_call_trace); |
895 | void rxrpc_put_call(struct rxrpc_call *, enum rxrpc_call_trace); | |
00e90712 | 896 | void rxrpc_cleanup_call(struct rxrpc_call *); |
2baec2c3 | 897 | void rxrpc_destroy_all_calls(struct rxrpc_net *); |
17926a79 | 898 | |
dabe5a79 DH |
899 | static inline bool rxrpc_is_service_call(const struct rxrpc_call *call) |
900 | { | |
901 | return test_bit(RXRPC_CALL_IS_SERVICE, &call->flags); | |
902 | } | |
903 | ||
904 | static inline bool rxrpc_is_client_call(const struct rxrpc_call *call) | |
905 | { | |
906 | return !rxrpc_is_service_call(call); | |
907 | } | |
908 | ||
0b9bb322 DH |
909 | /* |
910 | * call_state.c | |
911 | */ | |
0b9bb322 DH |
912 | bool rxrpc_set_call_completion(struct rxrpc_call *call, |
913 | enum rxrpc_call_completion compl, | |
914 | u32 abort_code, | |
915 | int error); | |
0b9bb322 | 916 | bool rxrpc_call_completed(struct rxrpc_call *call); |
0b9bb322 DH |
917 | bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq, |
918 | u32 abort_code, int error, enum rxrpc_abort_reason why); | |
96b4059f DH |
919 | void rxrpc_prefail_call(struct rxrpc_call *call, enum rxrpc_call_completion compl, |
920 | int error); | |
921 | ||
922 | static inline void rxrpc_set_call_state(struct rxrpc_call *call, | |
923 | enum rxrpc_call_state state) | |
924 | { | |
925 | /* Order write of completion info before write of ->state. */ | |
926 | smp_store_release(&call->_state, state); | |
9d35d880 | 927 | wake_up(&call->waitq); |
96b4059f DH |
928 | } |
929 | ||
930 | static inline enum rxrpc_call_state __rxrpc_call_state(const struct rxrpc_call *call) | |
931 | { | |
932 | return call->_state; /* Only inside I/O thread */ | |
933 | } | |
934 | ||
935 | static inline bool __rxrpc_call_is_complete(const struct rxrpc_call *call) | |
936 | { | |
937 | return __rxrpc_call_state(call) == RXRPC_CALL_COMPLETE; | |
938 | } | |
0b9bb322 | 939 | |
d41b3f5b DH |
940 | static inline enum rxrpc_call_state rxrpc_call_state(const struct rxrpc_call *call) |
941 | { | |
96b4059f DH |
942 | /* Order read ->state before read of completion info. */ |
943 | return smp_load_acquire(&call->_state); | |
d41b3f5b DH |
944 | } |
945 | ||
946 | static inline bool rxrpc_call_is_complete(const struct rxrpc_call *call) | |
947 | { | |
948 | return rxrpc_call_state(call) == RXRPC_CALL_COMPLETE; | |
949 | } | |
950 | ||
951 | static inline bool rxrpc_call_has_failed(const struct rxrpc_call *call) | |
952 | { | |
953 | return rxrpc_call_is_complete(call) && call->completion != RXRPC_CALL_SUCCEEDED; | |
954 | } | |
955 | ||
4a3388c8 DH |
956 | /* |
957 | * conn_client.c | |
958 | */ | |
45025bce | 959 | extern unsigned int rxrpc_reap_client_connections; |
a158bdd3 DH |
960 | extern unsigned long rxrpc_conn_idle_client_expiry; |
961 | extern unsigned long rxrpc_conn_idle_client_fast_expiry; | |
4a3388c8 | 962 | |
9d35d880 | 963 | void rxrpc_purge_client_connections(struct rxrpc_local *local); |
fa3492ab DH |
964 | struct rxrpc_bundle *rxrpc_get_bundle(struct rxrpc_bundle *, enum rxrpc_bundle_trace); |
965 | void rxrpc_put_bundle(struct rxrpc_bundle *, enum rxrpc_bundle_trace); | |
9d35d880 DH |
966 | int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp); |
967 | void rxrpc_connect_client_calls(struct rxrpc_local *local); | |
45025bce | 968 | void rxrpc_expose_client_call(struct rxrpc_call *); |
245500d8 | 969 | void rxrpc_disconnect_client_call(struct rxrpc_bundle *, struct rxrpc_call *); |
1bab27af | 970 | void rxrpc_deactivate_bundle(struct rxrpc_bundle *bundle); |
0d6bf319 | 971 | void rxrpc_discard_expired_client_conns(struct rxrpc_local *local); |
d12040b6 | 972 | void rxrpc_clean_up_local_conns(struct rxrpc_local *); |
4a3388c8 | 973 | |
17926a79 | 974 | /* |
0d81a51a DH |
975 | * conn_event.c |
976 | */ | |
30df927b DH |
977 | void rxrpc_conn_retransmit_call(struct rxrpc_connection *conn, struct sk_buff *skb, |
978 | unsigned int channel); | |
a00ce28b | 979 | int rxrpc_abort_conn(struct rxrpc_connection *conn, struct sk_buff *skb, |
57af281e | 980 | s32 abort_code, int err, enum rxrpc_abort_reason why); |
0d81a51a | 981 | void rxrpc_process_connection(struct work_struct *); |
ddc7834a | 982 | void rxrpc_process_delayed_final_acks(struct rxrpc_connection *, bool); |
57af281e | 983 | bool rxrpc_input_conn_packet(struct rxrpc_connection *conn, struct sk_buff *skb); |
f2cce89a | 984 | void rxrpc_input_conn_event(struct rxrpc_connection *conn, struct sk_buff *skb); |
0d81a51a | 985 | |
a00ce28b DH |
986 | static inline bool rxrpc_is_conn_aborted(const struct rxrpc_connection *conn) |
987 | { | |
988 | /* Order reading the abort info after the state check. */ | |
989 | return smp_load_acquire(&conn->state) == RXRPC_CONN_ABORTED; | |
990 | } | |
991 | ||
0d81a51a DH |
992 | /* |
993 | * conn_object.c | |
17926a79 | 994 | */ |
dad8aff7 | 995 | extern unsigned int rxrpc_connection_expiry; |
f859ab61 | 996 | extern unsigned int rxrpc_closed_conn_expiry; |
17926a79 | 997 | |
f2cce89a | 998 | void rxrpc_poke_conn(struct rxrpc_connection *conn, enum rxrpc_conn_trace why); |
3cec055c | 999 | struct rxrpc_connection *rxrpc_alloc_connection(struct rxrpc_net *, gfp_t); |
5e6ef4f1 DH |
1000 | struct rxrpc_connection *rxrpc_find_client_connection_rcu(struct rxrpc_local *, |
1001 | struct sockaddr_rxrpc *, | |
1002 | struct sk_buff *); | |
45025bce | 1003 | void __rxrpc_disconnect_call(struct rxrpc_connection *, struct rxrpc_call *); |
999b69f8 | 1004 | void rxrpc_disconnect_call(struct rxrpc_call *); |
3cec055c DH |
1005 | void rxrpc_kill_client_conn(struct rxrpc_connection *); |
1006 | void rxrpc_queue_conn(struct rxrpc_connection *, enum rxrpc_conn_trace); | |
7fa25105 DH |
1007 | void rxrpc_see_connection(struct rxrpc_connection *, enum rxrpc_conn_trace); |
1008 | struct rxrpc_connection *rxrpc_get_connection(struct rxrpc_connection *, | |
1009 | enum rxrpc_conn_trace); | |
1010 | struct rxrpc_connection *rxrpc_get_connection_maybe(struct rxrpc_connection *, | |
1011 | enum rxrpc_conn_trace); | |
3cec055c | 1012 | void rxrpc_put_connection(struct rxrpc_connection *, enum rxrpc_conn_trace); |
2baec2c3 DH |
1013 | void rxrpc_service_connection_reaper(struct work_struct *); |
1014 | void rxrpc_destroy_all_connections(struct rxrpc_net *); | |
17926a79 | 1015 | |
19ffa01c DH |
1016 | static inline bool rxrpc_conn_is_client(const struct rxrpc_connection *conn) |
1017 | { | |
1018 | return conn->out_clientflag; | |
1019 | } | |
1020 | ||
1021 | static inline bool rxrpc_conn_is_service(const struct rxrpc_connection *conn) | |
1022 | { | |
e8d70ce1 | 1023 | return !rxrpc_conn_is_client(conn); |
19ffa01c DH |
1024 | } |
1025 | ||
3136ef49 DH |
1026 | static inline void rxrpc_reduce_conn_timer(struct rxrpc_connection *conn, |
1027 | unsigned long expire_at) | |
1028 | { | |
1029 | timer_reduce(&conn->timer, expire_at); | |
1030 | } | |
1031 | ||
7877a4a4 DH |
1032 | /* |
1033 | * conn_service.c | |
1034 | */ | |
8496af50 DH |
1035 | struct rxrpc_connection *rxrpc_find_service_conn_rcu(struct rxrpc_peer *, |
1036 | struct sk_buff *); | |
2baec2c3 | 1037 | struct rxrpc_connection *rxrpc_prealloc_service_connection(struct rxrpc_net *, gfp_t); |
063c60d3 | 1038 | void rxrpc_new_incoming_connection(struct rxrpc_sock *, struct rxrpc_connection *, |
ec832bd0 | 1039 | const struct rxrpc_security *, struct sk_buff *); |
001c1122 | 1040 | void rxrpc_unpublish_service_conn(struct rxrpc_connection *); |
7877a4a4 | 1041 | |
17926a79 | 1042 | /* |
0d81a51a | 1043 | * input.c |
17926a79 | 1044 | */ |
5086d9a9 | 1045 | void rxrpc_congestion_degrade(struct rxrpc_call *); |
5e6ef4f1 DH |
1046 | void rxrpc_input_call_packet(struct rxrpc_call *, struct sk_buff *); |
1047 | void rxrpc_implicit_end_call(struct rxrpc_call *, struct sk_buff *); | |
96b2d69b DH |
1048 | |
1049 | /* | |
1050 | * io_thread.c | |
1051 | */ | |
446b3e14 | 1052 | int rxrpc_encap_rcv(struct sock *, struct sk_buff *); |
ff734825 | 1053 | void rxrpc_error_report(struct sock *); |
57af281e DH |
1054 | bool rxrpc_direct_abort(struct sk_buff *skb, enum rxrpc_abort_reason why, |
1055 | s32 abort_code, int err); | |
a275da62 DH |
1056 | int rxrpc_io_thread(void *data); |
1057 | static inline void rxrpc_wake_up_io_thread(struct rxrpc_local *local) | |
1058 | { | |
1059 | wake_up_process(local->io_thread); | |
1060 | } | |
17926a79 | 1061 | |
57af281e DH |
1062 | static inline bool rxrpc_protocol_error(struct sk_buff *skb, enum rxrpc_abort_reason why) |
1063 | { | |
1064 | return rxrpc_direct_abort(skb, why, RX_PROTOCOL_ERROR, -EPROTO); | |
1065 | } | |
1066 | ||
17926a79 | 1067 | /* |
0d81a51a | 1068 | * insecure.c |
17926a79 | 1069 | */ |
0d81a51a | 1070 | extern const struct rxrpc_security rxrpc_no_security; |
17926a79 DH |
1071 | |
1072 | /* | |
0d81a51a | 1073 | * key.c |
17926a79 | 1074 | */ |
0d81a51a | 1075 | extern struct key_type key_type_rxrpc; |
0d81a51a | 1076 | |
a7b75c5a | 1077 | int rxrpc_request_key(struct rxrpc_sock *, sockptr_t , int); |
10674a03 | 1078 | int rxrpc_get_server_data_key(struct rxrpc_connection *, const void *, time64_t, |
0d81a51a | 1079 | u32); |
17926a79 | 1080 | |
87563616 DH |
1081 | /* |
1082 | * local_event.c | |
1083 | */ | |
020c69c1 | 1084 | void rxrpc_gen_version_string(void); |
5e6ef4f1 DH |
1085 | void rxrpc_send_version_request(struct rxrpc_local *local, |
1086 | struct rxrpc_host_header *hdr, | |
1087 | struct sk_buff *skb); | |
87563616 | 1088 | |
17926a79 | 1089 | /* |
0d81a51a | 1090 | * local_object.c |
17926a79 | 1091 | */ |
87220143 | 1092 | void rxrpc_local_dont_fragment(const struct rxrpc_local *local, bool set); |
2baec2c3 | 1093 | struct rxrpc_local *rxrpc_lookup_local(struct net *, const struct sockaddr_rxrpc *); |
0fde882f DH |
1094 | struct rxrpc_local *rxrpc_get_local(struct rxrpc_local *, enum rxrpc_local_trace); |
1095 | struct rxrpc_local *rxrpc_get_local_maybe(struct rxrpc_local *, enum rxrpc_local_trace); | |
1096 | void rxrpc_put_local(struct rxrpc_local *, enum rxrpc_local_trace); | |
1097 | struct rxrpc_local *rxrpc_use_local(struct rxrpc_local *, enum rxrpc_local_trace); | |
1098 | void rxrpc_unuse_local(struct rxrpc_local *, enum rxrpc_local_trace); | |
a275da62 | 1099 | void rxrpc_destroy_local(struct rxrpc_local *local); |
2baec2c3 | 1100 | void rxrpc_destroy_all_locals(struct rxrpc_net *); |
17926a79 | 1101 | |
0fde882f DH |
1102 | static inline bool __rxrpc_use_local(struct rxrpc_local *local, |
1103 | enum rxrpc_local_trace why) | |
1104 | { | |
1105 | int r, u; | |
1106 | ||
1107 | r = refcount_read(&local->ref); | |
1108 | u = atomic_fetch_add_unless(&local->active_users, 1, 0); | |
1109 | trace_rxrpc_local(local->debug_id, why, r, u); | |
1110 | return u != 0; | |
04d36d74 DH |
1111 | } |
1112 | ||
0fde882f DH |
1113 | static inline void rxrpc_see_local(struct rxrpc_local *local, |
1114 | enum rxrpc_local_trace why) | |
04d36d74 | 1115 | { |
0fde882f DH |
1116 | int r, u; |
1117 | ||
1118 | r = refcount_read(&local->ref); | |
1119 | u = atomic_read(&local->active_users); | |
1120 | trace_rxrpc_local(local->debug_id, why, r, u); | |
04d36d74 DH |
1121 | } |
1122 | ||
17926a79 | 1123 | /* |
0d81a51a | 1124 | * misc.c |
17926a79 | 1125 | */ |
0d81a51a | 1126 | extern unsigned int rxrpc_max_backlog __read_mostly; |
a158bdd3 DH |
1127 | extern unsigned long rxrpc_soft_ack_delay; |
1128 | extern unsigned long rxrpc_idle_ack_delay; | |
0d81a51a DH |
1129 | extern unsigned int rxrpc_rx_window_size; |
1130 | extern unsigned int rxrpc_rx_mtu; | |
1131 | extern unsigned int rxrpc_rx_jumbo_max; | |
af094824 DH |
1132 | #ifdef CONFIG_AF_RXRPC_INJECT_RX_DELAY |
1133 | extern unsigned long rxrpc_inject_rx_delay; | |
1134 | #endif | |
17926a79 | 1135 | |
2baec2c3 DH |
1136 | /* |
1137 | * net_ns.c | |
1138 | */ | |
1139 | extern unsigned int rxrpc_net_id; | |
1140 | extern struct pernet_operations rxrpc_net_ops; | |
1141 | ||
1142 | static inline struct rxrpc_net *rxrpc_net(struct net *net) | |
1143 | { | |
1144 | return net_generic(net, rxrpc_net_id); | |
1145 | } | |
1146 | ||
17926a79 | 1147 | /* |
0d81a51a | 1148 | * output.c |
17926a79 | 1149 | */ |
99afb28c DH |
1150 | void rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, |
1151 | rxrpc_serial_t serial, enum rxrpc_propose_ack_trace why); | |
26cb02aa | 1152 | int rxrpc_send_abort_packet(struct rxrpc_call *); |
a00ce28b | 1153 | void rxrpc_send_conn_abort(struct rxrpc_connection *conn); |
5e6ef4f1 | 1154 | void rxrpc_reject_packet(struct rxrpc_local *local, struct sk_buff *skb); |
ace45bec | 1155 | void rxrpc_send_keepalive(struct rxrpc_peer *); |
cf37b598 | 1156 | void rxrpc_transmit_one(struct rxrpc_call *call, struct rxrpc_txbuf *txb); |
17926a79 DH |
1157 | |
1158 | /* | |
abe89ef0 | 1159 | * peer_event.c |
0d81a51a | 1160 | */ |
ff734825 | 1161 | void rxrpc_input_error(struct rxrpc_local *, struct sk_buff *); |
ace45bec | 1162 | void rxrpc_peer_keepalive_worker(struct work_struct *); |
0d81a51a DH |
1163 | |
1164 | /* | |
1165 | * peer_object.c | |
17926a79 | 1166 | */ |
be6e6707 DH |
1167 | struct rxrpc_peer *rxrpc_lookup_peer_rcu(struct rxrpc_local *, |
1168 | const struct sockaddr_rxrpc *); | |
8a758d98 DH |
1169 | struct rxrpc_peer *rxrpc_lookup_peer(struct rxrpc_local *local, |
1170 | struct sockaddr_rxrpc *srx, gfp_t gfp); | |
47c810a7 DH |
1171 | struct rxrpc_peer *rxrpc_alloc_peer(struct rxrpc_local *, gfp_t, |
1172 | enum rxrpc_peer_trace); | |
8a758d98 | 1173 | void rxrpc_new_incoming_peer(struct rxrpc_local *local, struct rxrpc_peer *peer); |
17226f12 | 1174 | void rxrpc_destroy_all_peers(struct rxrpc_net *); |
47c810a7 DH |
1175 | struct rxrpc_peer *rxrpc_get_peer(struct rxrpc_peer *, enum rxrpc_peer_trace); |
1176 | struct rxrpc_peer *rxrpc_get_peer_maybe(struct rxrpc_peer *, enum rxrpc_peer_trace); | |
1177 | void rxrpc_put_peer(struct rxrpc_peer *, enum rxrpc_peer_trace); | |
17926a79 DH |
1178 | |
1179 | /* | |
0d81a51a | 1180 | * proc.c |
17926a79 | 1181 | */ |
c3506372 CH |
1182 | extern const struct seq_operations rxrpc_call_seq_ops; |
1183 | extern const struct seq_operations rxrpc_connection_seq_ops; | |
d2ce4a84 | 1184 | extern const struct seq_operations rxrpc_bundle_seq_ops; |
bc0e7cf4 | 1185 | extern const struct seq_operations rxrpc_peer_seq_ops; |
33912c26 | 1186 | extern const struct seq_operations rxrpc_local_seq_ops; |
17926a79 DH |
1187 | |
1188 | /* | |
0d81a51a | 1189 | * recvmsg.c |
17926a79 | 1190 | */ |
248f219c | 1191 | void rxrpc_notify_socket(struct rxrpc_call *); |
1b784140 | 1192 | int rxrpc_recvmsg(struct socket *, struct msghdr *, size_t, int); |
17926a79 | 1193 | |
3067bf8c DH |
1194 | /* |
1195 | * Abort a call due to a protocol error. | |
1196 | */ | |
57af281e DH |
1197 | static inline int rxrpc_abort_eproto(struct rxrpc_call *call, |
1198 | struct sk_buff *skb, | |
1199 | s32 abort_code, | |
1200 | enum rxrpc_abort_reason why) | |
3067bf8c DH |
1201 | { |
1202 | struct rxrpc_skb_priv *sp = rxrpc_skb(skb); | |
1203 | ||
57af281e DH |
1204 | rxrpc_abort_call(call, sp->hdr.seq, abort_code, -EPROTO, why); |
1205 | return -EPROTO; | |
3067bf8c DH |
1206 | } |
1207 | ||
c410bf01 DH |
1208 | /* |
1209 | * rtt.c | |
1210 | */ | |
4700c4d8 | 1211 | void rxrpc_peer_add_rtt(struct rxrpc_call *, enum rxrpc_rtt_rx_trace, int, |
c410bf01 | 1212 | rxrpc_serial_t, rxrpc_serial_t, ktime_t, ktime_t); |
153f90a0 | 1213 | ktime_t rxrpc_get_rto_backoff(struct rxrpc_peer *peer, bool retrans); |
c410bf01 DH |
1214 | void rxrpc_peer_init_rtt(struct rxrpc_peer *); |
1215 | ||
17926a79 | 1216 | /* |
0d81a51a DH |
1217 | * rxkad.c |
1218 | */ | |
1219 | #ifdef CONFIG_RXKAD | |
1220 | extern const struct rxrpc_security rxkad; | |
1221 | #endif | |
1222 | ||
1223 | /* | |
1224 | * security.c | |
17926a79 | 1225 | */ |
648af7fc | 1226 | int __init rxrpc_init_security(void); |
12da59fc | 1227 | const struct rxrpc_security *rxrpc_security_lookup(u8); |
648af7fc | 1228 | void rxrpc_exit_security(void); |
f3441d41 | 1229 | int rxrpc_init_client_call_security(struct rxrpc_call *); |
c1b1203d | 1230 | int rxrpc_init_client_conn_security(struct rxrpc_connection *); |
ec832bd0 DH |
1231 | const struct rxrpc_security *rxrpc_get_incoming_security(struct rxrpc_sock *, |
1232 | struct sk_buff *); | |
1233 | struct key *rxrpc_look_up_server_security(struct rxrpc_connection *, | |
1234 | struct sk_buff *, u32, u32); | |
71a17de3 | 1235 | |
0b58b8a1 DH |
1236 | /* |
1237 | * sendmsg.c | |
1238 | */ | |
57af281e DH |
1239 | bool rxrpc_propose_abort(struct rxrpc_call *call, s32 abort_code, int error, |
1240 | enum rxrpc_abort_reason why); | |
0b58b8a1 | 1241 | int rxrpc_do_sendmsg(struct rxrpc_sock *, struct msghdr *, size_t); |
17926a79 | 1242 | |
ca7fb100 DH |
1243 | /* |
1244 | * server_key.c | |
1245 | */ | |
1246 | extern struct key_type key_type_rxrpc_s; | |
1247 | ||
1248 | int rxrpc_server_keyring(struct rxrpc_sock *, sockptr_t, int); | |
1249 | ||
17926a79 | 1250 | /* |
0d81a51a | 1251 | * skbuff.c |
17926a79 | 1252 | */ |
d001648e | 1253 | void rxrpc_kernel_data_consumed(struct rxrpc_call *, struct sk_buff *); |
71f3ca40 DH |
1254 | void rxrpc_new_skb(struct sk_buff *, enum rxrpc_skb_trace); |
1255 | void rxrpc_see_skb(struct sk_buff *, enum rxrpc_skb_trace); | |
d0d5c0cd | 1256 | void rxrpc_eaten_skb(struct sk_buff *, enum rxrpc_skb_trace); |
71f3ca40 DH |
1257 | void rxrpc_get_skb(struct sk_buff *, enum rxrpc_skb_trace); |
1258 | void rxrpc_free_skb(struct sk_buff *, enum rxrpc_skb_trace); | |
df844fd4 | 1259 | void rxrpc_purge_queue(struct sk_buff_head *); |
17926a79 | 1260 | |
b0154246 DH |
1261 | /* |
1262 | * stats.c | |
1263 | */ | |
1264 | int rxrpc_stats_show(struct seq_file *seq, void *v); | |
1265 | int rxrpc_stats_clear(struct file *file, char *buf, size_t size); | |
1266 | ||
1267 | #define rxrpc_inc_stat(rxnet, s) atomic_inc(&(rxnet)->s) | |
1268 | #define rxrpc_dec_stat(rxnet, s) atomic_dec(&(rxnet)->s) | |
1269 | ||
5873c083 DH |
1270 | /* |
1271 | * sysctl.c | |
1272 | */ | |
1273 | #ifdef CONFIG_SYSCTL | |
1274 | extern int __init rxrpc_sysctl_init(void); | |
1275 | extern void rxrpc_sysctl_exit(void); | |
1276 | #else | |
1277 | static inline int __init rxrpc_sysctl_init(void) { return 0; } | |
1278 | static inline void rxrpc_sysctl_exit(void) {} | |
1279 | #endif | |
1280 | ||
02a19356 DH |
1281 | /* |
1282 | * txbuf.c | |
1283 | */ | |
1284 | extern atomic_t rxrpc_nr_txbuf; | |
49489bb0 DH |
1285 | struct rxrpc_txbuf *rxrpc_alloc_data_txbuf(struct rxrpc_call *call, size_t data_size, |
1286 | size_t data_align, gfp_t gfp); | |
1287 | struct rxrpc_txbuf *rxrpc_alloc_ack_txbuf(struct rxrpc_call *call, size_t sack_size); | |
02a19356 DH |
1288 | void rxrpc_get_txbuf(struct rxrpc_txbuf *txb, enum rxrpc_txbuf_trace what); |
1289 | void rxrpc_see_txbuf(struct rxrpc_txbuf *txb, enum rxrpc_txbuf_trace what); | |
1290 | void rxrpc_put_txbuf(struct rxrpc_txbuf *txb, enum rxrpc_txbuf_trace what); | |
1291 | ||
be6e6707 DH |
1292 | /* |
1293 | * utils.c | |
1294 | */ | |
5a790b73 | 1295 | int rxrpc_extract_addr_from_skb(struct sockaddr_rxrpc *, struct sk_buff *); |
be6e6707 | 1296 | |
248f219c DH |
1297 | static inline bool before(u32 seq1, u32 seq2) |
1298 | { | |
1299 | return (s32)(seq1 - seq2) < 0; | |
1300 | } | |
1301 | static inline bool before_eq(u32 seq1, u32 seq2) | |
1302 | { | |
1303 | return (s32)(seq1 - seq2) <= 0; | |
1304 | } | |
1305 | static inline bool after(u32 seq1, u32 seq2) | |
1306 | { | |
1307 | return (s32)(seq1 - seq2) > 0; | |
1308 | } | |
1309 | static inline bool after_eq(u32 seq1, u32 seq2) | |
1310 | { | |
1311 | return (s32)(seq1 - seq2) >= 0; | |
1312 | } | |
1313 | ||
17926a79 DH |
1314 | /* |
1315 | * debug tracing | |
1316 | */ | |
95c96174 | 1317 | extern unsigned int rxrpc_debug; |
17926a79 DH |
1318 | |
1319 | #define dbgprintk(FMT,...) \ | |
9f389f4b | 1320 | printk("[%-6.6s] "FMT"\n", current->comm ,##__VA_ARGS__) |
17926a79 | 1321 | |
0dc47877 HH |
1322 | #define kenter(FMT,...) dbgprintk("==> %s("FMT")",__func__ ,##__VA_ARGS__) |
1323 | #define kleave(FMT,...) dbgprintk("<== %s()"FMT"",__func__ ,##__VA_ARGS__) | |
17926a79 | 1324 | #define kdebug(FMT,...) dbgprintk(" "FMT ,##__VA_ARGS__) |
17926a79 DH |
1325 | |
1326 | ||
1327 | #if defined(__KDEBUG) | |
1328 | #define _enter(FMT,...) kenter(FMT,##__VA_ARGS__) | |
1329 | #define _leave(FMT,...) kleave(FMT,##__VA_ARGS__) | |
1330 | #define _debug(FMT,...) kdebug(FMT,##__VA_ARGS__) | |
17926a79 DH |
1331 | |
1332 | #elif defined(CONFIG_AF_RXRPC_DEBUG) | |
1333 | #define RXRPC_DEBUG_KENTER 0x01 | |
1334 | #define RXRPC_DEBUG_KLEAVE 0x02 | |
1335 | #define RXRPC_DEBUG_KDEBUG 0x04 | |
17926a79 DH |
1336 | |
1337 | #define _enter(FMT,...) \ | |
1338 | do { \ | |
1339 | if (unlikely(rxrpc_debug & RXRPC_DEBUG_KENTER)) \ | |
1340 | kenter(FMT,##__VA_ARGS__); \ | |
1341 | } while (0) | |
1342 | ||
1343 | #define _leave(FMT,...) \ | |
1344 | do { \ | |
1345 | if (unlikely(rxrpc_debug & RXRPC_DEBUG_KLEAVE)) \ | |
1346 | kleave(FMT,##__VA_ARGS__); \ | |
1347 | } while (0) | |
1348 | ||
1349 | #define _debug(FMT,...) \ | |
1350 | do { \ | |
1351 | if (unlikely(rxrpc_debug & RXRPC_DEBUG_KDEBUG)) \ | |
1352 | kdebug(FMT,##__VA_ARGS__); \ | |
1353 | } while (0) | |
1354 | ||
17926a79 | 1355 | #else |
12fdff3f DH |
1356 | #define _enter(FMT,...) no_printk("==> %s("FMT")",__func__ ,##__VA_ARGS__) |
1357 | #define _leave(FMT,...) no_printk("<== %s()"FMT"",__func__ ,##__VA_ARGS__) | |
1358 | #define _debug(FMT,...) no_printk(" "FMT ,##__VA_ARGS__) | |
17926a79 DH |
1359 | #endif |
1360 | ||
1361 | /* | |
1362 | * debug assertion checking | |
1363 | */ | |
1364 | #if 1 // defined(__KDEBUGALL) | |
1365 | ||
1366 | #define ASSERT(X) \ | |
1367 | do { \ | |
1368 | if (unlikely(!(X))) { \ | |
9b6d5398 | 1369 | pr_err("Assertion failed\n"); \ |
17926a79 DH |
1370 | BUG(); \ |
1371 | } \ | |
b4f1342f | 1372 | } while (0) |
17926a79 DH |
1373 | |
1374 | #define ASSERTCMP(X, OP, Y) \ | |
1375 | do { \ | |
cf13258f DH |
1376 | __typeof__(X) _x = (X); \ |
1377 | __typeof__(Y) _y = (__typeof__(X))(Y); \ | |
9b6d5398 | 1378 | if (unlikely(!(_x OP _y))) { \ |
cf13258f DH |
1379 | pr_err("Assertion failed - %lu(0x%lx) %s %lu(0x%lx) is false\n", \ |
1380 | (unsigned long)_x, (unsigned long)_x, #OP, \ | |
1381 | (unsigned long)_y, (unsigned long)_y); \ | |
17926a79 DH |
1382 | BUG(); \ |
1383 | } \ | |
b4f1342f | 1384 | } while (0) |
17926a79 DH |
1385 | |
1386 | #define ASSERTIF(C, X) \ | |
1387 | do { \ | |
1388 | if (unlikely((C) && !(X))) { \ | |
9b6d5398 | 1389 | pr_err("Assertion failed\n"); \ |
17926a79 DH |
1390 | BUG(); \ |
1391 | } \ | |
b4f1342f | 1392 | } while (0) |
17926a79 DH |
1393 | |
1394 | #define ASSERTIFCMP(C, X, OP, Y) \ | |
1395 | do { \ | |
cf13258f DH |
1396 | __typeof__(X) _x = (X); \ |
1397 | __typeof__(Y) _y = (__typeof__(X))(Y); \ | |
9b6d5398 JP |
1398 | if (unlikely((C) && !(_x OP _y))) { \ |
1399 | pr_err("Assertion failed - %lu(0x%lx) %s %lu(0x%lx) is false\n", \ | |
cf13258f DH |
1400 | (unsigned long)_x, (unsigned long)_x, #OP, \ |
1401 | (unsigned long)_y, (unsigned long)_y); \ | |
17926a79 DH |
1402 | BUG(); \ |
1403 | } \ | |
b4f1342f | 1404 | } while (0) |
17926a79 DH |
1405 | |
1406 | #else | |
1407 | ||
1408 | #define ASSERT(X) \ | |
1409 | do { \ | |
b4f1342f | 1410 | } while (0) |
17926a79 DH |
1411 | |
1412 | #define ASSERTCMP(X, OP, Y) \ | |
1413 | do { \ | |
b4f1342f | 1414 | } while (0) |
17926a79 DH |
1415 | |
1416 | #define ASSERTIF(C, X) \ | |
1417 | do { \ | |
b4f1342f | 1418 | } while (0) |
17926a79 DH |
1419 | |
1420 | #define ASSERTIFCMP(C, X, OP, Y) \ | |
1421 | do { \ | |
b4f1342f | 1422 | } while (0) |
17926a79 DH |
1423 | |
1424 | #endif /* __KDEBUGALL */ |