udp.h 9.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337
  1. /*
  2. * INET An implementation of the TCP/IP protocol suite for the LINUX
  3. * operating system. INET is implemented using the BSD Socket
  4. * interface as the means of communication with the user level.
  5. *
  6. * Definitions for the UDP module.
  7. *
  8. * Version: @(#)udp.h 1.0.2 05/07/93
  9. *
  10. * Authors: Ross Biro
  11. * Fred N. van Kempen, <waltje@uWalt.NL.Mugnet.ORG>
  12. *
  13. * Fixes:
  14. * Alan Cox : Turned on udp checksums. I don't want to
  15. * chase 'memory corruption' bugs that aren't!
  16. *
  17. * This program is free software; you can redistribute it and/or
  18. * modify it under the terms of the GNU General Public License
  19. * as published by the Free Software Foundation; either version
  20. * 2 of the License, or (at your option) any later version.
  21. */
  22. #ifndef _UDP_H
  23. #define _UDP_H
  24. #include <linux/list.h>
  25. #include <linux/bug.h>
  26. #include <net/inet_sock.h>
  27. #include <net/sock.h>
  28. #include <net/snmp.h>
  29. #include <net/ip.h>
  30. #include <linux/ipv6.h>
  31. #include <linux/seq_file.h>
  32. #include <linux/poll.h>
  33. /**
  34. * struct udp_skb_cb - UDP(-Lite) private variables
  35. *
  36. * @header: private variables used by IPv4/IPv6
  37. * @cscov: checksum coverage length (UDP-Lite only)
  38. * @partial_cov: if set indicates partial csum coverage
  39. */
  40. struct udp_skb_cb {
  41. union {
  42. struct inet_skb_parm h4;
  43. #if IS_ENABLED(CONFIG_IPV6)
  44. struct inet6_skb_parm h6;
  45. #endif
  46. } header;
  47. __u16 cscov;
  48. __u8 partial_cov;
  49. };
  50. #define UDP_SKB_CB(__skb) ((struct udp_skb_cb *)((__skb)->cb))
  51. /**
  52. * struct udp_hslot - UDP hash slot
  53. *
  54. * @head: head of list of sockets
  55. * @count: number of sockets in 'head' list
  56. * @lock: spinlock protecting changes to head/count
  57. */
  58. struct udp_hslot {
  59. struct hlist_nulls_head head;
  60. int count;
  61. spinlock_t lock;
  62. } __attribute__((aligned(2 * sizeof(long))));
  63. /**
  64. * struct udp_table - UDP table
  65. *
  66. * @hash: hash table, sockets are hashed on (local port)
  67. * @hash2: hash table, sockets are hashed on (local port, local address)
  68. * @mask: number of slots in hash tables, minus 1
  69. * @log: log2(number of slots in hash table)
  70. */
  71. struct udp_table {
  72. struct udp_hslot *hash;
  73. struct udp_hslot *hash2;
  74. unsigned int mask;
  75. unsigned int log;
  76. };
  77. extern struct udp_table udp_table;
  78. void udp_table_init(struct udp_table *, const char *);
  79. static inline struct udp_hslot *udp_hashslot(struct udp_table *table,
  80. struct net *net, unsigned int num)
  81. {
  82. return &table->hash[udp_hashfn(net, num, table->mask)];
  83. }
  84. /*
  85. * For secondary hash, net_hash_mix() is performed before calling
  86. * udp_hashslot2(), this explains difference with udp_hashslot()
  87. */
  88. static inline struct udp_hslot *udp_hashslot2(struct udp_table *table,
  89. unsigned int hash)
  90. {
  91. return &table->hash2[hash & table->mask];
  92. }
  93. extern struct proto udp_prot;
  94. extern atomic_long_t udp_memory_allocated;
  95. /* sysctl variables for udp */
  96. extern long sysctl_udp_mem[3];
  97. extern int sysctl_udp_rmem_min;
  98. extern int sysctl_udp_wmem_min;
  99. struct sk_buff;
  100. /*
  101. * Generic checksumming routines for UDP(-Lite) v4 and v6
  102. */
  103. static inline __sum16 __udp_lib_checksum_complete(struct sk_buff *skb)
  104. {
  105. return (UDP_SKB_CB(skb)->cscov == skb->len ?
  106. __skb_checksum_complete(skb) :
  107. __skb_checksum_complete_head(skb, UDP_SKB_CB(skb)->cscov));
  108. }
  109. static inline int udp_lib_checksum_complete(struct sk_buff *skb)
  110. {
  111. return !skb_csum_unnecessary(skb) &&
  112. __udp_lib_checksum_complete(skb);
  113. }
  114. /**
  115. * udp_csum_outgoing - compute UDPv4/v6 checksum over fragments
  116. * @sk: socket we are writing to
  117. * @skb: sk_buff containing the filled-in UDP header
  118. * (checksum field must be zeroed out)
  119. */
  120. static inline __wsum udp_csum_outgoing(struct sock *sk, struct sk_buff *skb)
  121. {
  122. __wsum csum = csum_partial(skb_transport_header(skb),
  123. sizeof(struct udphdr), 0);
  124. skb_queue_walk(&sk->sk_write_queue, skb) {
  125. csum = csum_add(csum, skb->csum);
  126. }
  127. return csum;
  128. }
  129. static inline __wsum udp_csum(struct sk_buff *skb)
  130. {
  131. __wsum csum = csum_partial(skb_transport_header(skb),
  132. sizeof(struct udphdr), skb->csum);
  133. for (skb = skb_shinfo(skb)->frag_list; skb; skb = skb->next) {
  134. csum = csum_add(csum, skb->csum);
  135. }
  136. return csum;
  137. }
  138. static inline __sum16 udp_v4_check(int len, __be32 saddr,
  139. __be32 daddr, __wsum base)
  140. {
  141. return csum_tcpudp_magic(saddr, daddr, len, IPPROTO_UDP, base);
  142. }
  143. void udp_set_csum(bool nocheck, struct sk_buff *skb,
  144. __be32 saddr, __be32 daddr, int len);
  145. struct sk_buff **udp_gro_receive(struct sk_buff **head, struct sk_buff *skb,
  146. struct udphdr *uh);
  147. int udp_gro_complete(struct sk_buff *skb, int nhoff);
  148. static inline struct udphdr *udp_gro_udphdr(struct sk_buff *skb)
  149. {
  150. struct udphdr *uh;
  151. unsigned int hlen, off;
  152. off = skb_gro_offset(skb);
  153. hlen = off + sizeof(*uh);
  154. uh = skb_gro_header_fast(skb, off);
  155. if (skb_gro_header_hard(skb, hlen))
  156. uh = skb_gro_header_slow(skb, hlen, off);
  157. return uh;
  158. }
  159. /* hash routines shared between UDPv4/6 and UDP-Litev4/6 */
  160. static inline void udp_lib_hash(struct sock *sk)
  161. {
  162. BUG();
  163. }
  164. void udp_lib_unhash(struct sock *sk);
  165. void udp_lib_rehash(struct sock *sk, u16 new_hash);
  166. static inline void udp_lib_close(struct sock *sk, long timeout)
  167. {
  168. sk_common_release(sk);
  169. }
  170. int udp_lib_get_port(struct sock *sk, unsigned short snum,
  171. int (*)(const struct sock *, const struct sock *),
  172. unsigned int hash2_nulladdr);
  173. u32 udp_flow_hashrnd(void);
  174. static inline __be16 udp_flow_src_port(struct net *net, struct sk_buff *skb,
  175. int min, int max, bool use_eth)
  176. {
  177. u32 hash;
  178. if (min >= max) {
  179. /* Use default range */
  180. inet_get_local_port_range(net, &min, &max);
  181. }
  182. hash = skb_get_hash(skb);
  183. if (unlikely(!hash)) {
  184. if (use_eth) {
  185. /* Can't find a normal hash, caller has indicated an
  186. * Ethernet packet so use that to compute a hash.
  187. */
  188. hash = jhash(skb->data, 2 * ETH_ALEN,
  189. (__force u32) skb->protocol);
  190. } else {
  191. /* Can't derive any sort of hash for the packet, set
  192. * to some consistent random value.
  193. */
  194. hash = udp_flow_hashrnd();
  195. }
  196. }
  197. /* Since this is being sent on the wire obfuscate hash a bit
  198. * to minimize possbility that any useful information to an
  199. * attacker is leaked. Only upper 16 bits are relevant in the
  200. * computation for 16 bit port value.
  201. */
  202. hash ^= hash << 16;
  203. return htons((((u64) hash * (max - min)) >> 32) + min);
  204. }
  205. /* net/ipv4/udp.c */
  206. void udp_v4_early_demux(struct sk_buff *skb);
  207. int udp_get_port(struct sock *sk, unsigned short snum,
  208. int (*saddr_cmp)(const struct sock *,
  209. const struct sock *));
  210. void udp_err(struct sk_buff *, u32);
  211. int udp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len);
  212. int udp_push_pending_frames(struct sock *sk);
  213. void udp_flush_pending_frames(struct sock *sk);
  214. void udp4_hwcsum(struct sk_buff *skb, __be32 src, __be32 dst);
  215. int udp_rcv(struct sk_buff *skb);
  216. int udp_ioctl(struct sock *sk, int cmd, unsigned long arg);
  217. int udp_disconnect(struct sock *sk, int flags);
  218. unsigned int udp_poll(struct file *file, struct socket *sock, poll_table *wait);
  219. struct sk_buff *skb_udp_tunnel_segment(struct sk_buff *skb,
  220. netdev_features_t features,
  221. bool is_ipv6);
  222. int udp_lib_getsockopt(struct sock *sk, int level, int optname,
  223. char __user *optval, int __user *optlen);
  224. int udp_lib_setsockopt(struct sock *sk, int level, int optname,
  225. char __user *optval, unsigned int optlen,
  226. int (*push_pending_frames)(struct sock *));
  227. struct sock *udp4_lib_lookup(struct net *net, __be32 saddr, __be16 sport,
  228. __be32 daddr, __be16 dport, int dif);
  229. struct sock *__udp4_lib_lookup(struct net *net, __be32 saddr, __be16 sport,
  230. __be32 daddr, __be16 dport, int dif,
  231. struct udp_table *tbl);
  232. struct sock *udp6_lib_lookup(struct net *net,
  233. const struct in6_addr *saddr, __be16 sport,
  234. const struct in6_addr *daddr, __be16 dport,
  235. int dif);
  236. struct sock *__udp6_lib_lookup(struct net *net,
  237. const struct in6_addr *saddr, __be16 sport,
  238. const struct in6_addr *daddr, __be16 dport,
  239. int dif, struct udp_table *tbl);
  240. /*
  241. * SNMP statistics for UDP and UDP-Lite
  242. */
  243. #define UDP_INC_STATS_USER(net, field, is_udplite) do { \
  244. if (is_udplite) SNMP_INC_STATS_USER((net)->mib.udplite_statistics, field); \
  245. else SNMP_INC_STATS_USER((net)->mib.udp_statistics, field); } while(0)
  246. #define UDP_INC_STATS_BH(net, field, is_udplite) do { \
  247. if (is_udplite) SNMP_INC_STATS_BH((net)->mib.udplite_statistics, field); \
  248. else SNMP_INC_STATS_BH((net)->mib.udp_statistics, field); } while(0)
  249. #define UDP6_INC_STATS_BH(net, field, is_udplite) do { \
  250. if (is_udplite) SNMP_INC_STATS_BH((net)->mib.udplite_stats_in6, field);\
  251. else SNMP_INC_STATS_BH((net)->mib.udp_stats_in6, field); \
  252. } while(0)
  253. #define UDP6_INC_STATS_USER(net, field, __lite) do { \
  254. if (__lite) SNMP_INC_STATS_USER((net)->mib.udplite_stats_in6, field); \
  255. else SNMP_INC_STATS_USER((net)->mib.udp_stats_in6, field); \
  256. } while(0)
  257. #if IS_ENABLED(CONFIG_IPV6)
  258. #define UDPX_INC_STATS_BH(sk, field) \
  259. do { \
  260. if ((sk)->sk_family == AF_INET) \
  261. UDP_INC_STATS_BH(sock_net(sk), field, 0); \
  262. else \
  263. UDP6_INC_STATS_BH(sock_net(sk), field, 0); \
  264. } while (0)
  265. #else
  266. #define UDPX_INC_STATS_BH(sk, field) UDP_INC_STATS_BH(sock_net(sk), field, 0)
  267. #endif
  268. /* /proc */
  269. int udp_seq_open(struct inode *inode, struct file *file);
  270. struct udp_seq_afinfo {
  271. char *name;
  272. sa_family_t family;
  273. struct udp_table *udp_table;
  274. const struct file_operations *seq_fops;
  275. struct seq_operations seq_ops;
  276. };
  277. struct udp_iter_state {
  278. struct seq_net_private p;
  279. sa_family_t family;
  280. int bucket;
  281. struct udp_table *udp_table;
  282. };
  283. #ifdef CONFIG_PROC_FS
  284. int udp_proc_register(struct net *net, struct udp_seq_afinfo *afinfo);
  285. void udp_proc_unregister(struct net *net, struct udp_seq_afinfo *afinfo);
  286. int udp4_proc_init(void);
  287. void udp4_proc_exit(void);
  288. #endif
  289. int udpv4_offload_init(void);
  290. void udp_init(void);
  291. void udp_encap_enable(void);
  292. #if IS_ENABLED(CONFIG_IPV6)
  293. void udpv6_encap_enable(void);
  294. #endif
  295. #endif /* _UDP_H */