2 * Transparent proxy support for Linux/iptables
4 * Copyright (c) 2006-2010 BalaBit IT Ltd.
5 * Author: Balazs Scheidler, Krisztian Kovacs
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2 as
9 * published by the Free Software Foundation.
12 #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
13 #include <linux/module.h>
14 #include <linux/skbuff.h>
16 #include <net/checksum.h>
19 #include <net/inet_sock.h>
20 #include <net/inet_hashtables.h>
21 #include <linux/inetdevice.h>
22 #include <linux/netfilter/x_tables.h>
23 #include <linux/netfilter_ipv4/ip_tables.h>
25 #include <net/netfilter/ipv4/nf_defrag_ipv4.h>
27 #if IS_ENABLED(CONFIG_IP6_NF_IPTABLES)
28 #define XT_TPROXY_HAVE_IPV6 1
29 #include <net/if_inet6.h>
30 #include <net/addrconf.h>
31 #include <net/inet6_hashtables.h>
32 #include <linux/netfilter_ipv6/ip6_tables.h>
33 #include <net/netfilter/ipv6/nf_defrag_ipv6.h>
36 #include <linux/netfilter/xt_TPROXY.h>
38 enum nf_tproxy_lookup_t
{
40 NFT_LOOKUP_ESTABLISHED
,
43 static bool tproxy_sk_is_transparent(struct sock
*sk
)
45 switch (sk
->sk_state
) {
47 if (inet_twsk(sk
)->tw_transparent
)
50 case TCP_NEW_SYN_RECV
:
51 if (inet_rsk(inet_reqsk(sk
))->no_srccheck
)
55 if (inet_sk(sk
)->transparent
)
64 tproxy_laddr4(struct sk_buff
*skb
, __be32 user_laddr
, __be32 daddr
)
66 struct in_device
*indev
;
74 indev
= __in_dev_get_rcu(skb
->dev
);
75 for_primary_ifa(indev
) {
76 laddr
= ifa
->ifa_local
;
81 return laddr
? laddr
: daddr
;
85 * This is used when the user wants to intercept a connection matching
86 * an explicit iptables rule. In this case the sockets are assumed
87 * matching in preference order:
89 * - match: if there's a fully established connection matching the
90 * _packet_ tuple, it is returned, assuming the redirection
91 * already took place and we process a packet belonging to an
92 * established connection
94 * - match: if there's a listening socket matching the redirection
95 * (e.g. on-port & on-ip of the connection), it is returned,
96 * regardless if it was bound to 0.0.0.0 or an explicit
97 * address. The reasoning is that if there's an explicit rule, it
98 * does not really matter if the listener is bound to an interface
99 * or to 0. The user already stated that he wants redirection
100 * (since he added the rule).
102 * Please note that there's an overlap between what a TPROXY target
103 * and a socket match will match. Normally if you have both rules the
104 * "socket" match will be the first one, effectively all packets
105 * belonging to established connections going through that one.
107 static inline struct sock
*
108 nf_tproxy_get_sock_v4(struct net
*net
, const u8 protocol
,
109 const __be32 saddr
, const __be32 daddr
,
110 const __be16 sport
, const __be16 dport
,
111 const struct net_device
*in
,
112 const enum nf_tproxy_lookup_t lookup_type
)
118 switch (lookup_type
) {
119 case NFT_LOOKUP_LISTENER
:
120 sk
= inet_lookup_listener(net
, &tcp_hashinfo
,
125 /* NOTE: we return listeners even if bound to
126 * 0.0.0.0, those are filtered out in
127 * xt_socket, since xt_TPROXY needs 0 bound
131 case NFT_LOOKUP_ESTABLISHED
:
132 sk
= inet_lookup_established(net
, &tcp_hashinfo
,
133 saddr
, sport
, daddr
, dport
,
141 sk
= udp4_lib_lookup(net
, saddr
, sport
, daddr
, dport
,
144 int connected
= (sk
->sk_state
== TCP_ESTABLISHED
);
145 int wildcard
= (inet_sk(sk
)->inet_rcv_saddr
== 0);
147 /* NOTE: we return listeners even if bound to
148 * 0.0.0.0, those are filtered out in
149 * xt_socket, since xt_TPROXY needs 0 bound
152 if ((lookup_type
== NFT_LOOKUP_ESTABLISHED
&& (!connected
|| wildcard
)) ||
153 (lookup_type
== NFT_LOOKUP_LISTENER
&& connected
)) {
164 pr_debug("tproxy socket lookup: proto %u %08x:%u -> %08x:%u, lookup type: %d, sock %p\n",
165 protocol
, ntohl(saddr
), ntohs(sport
), ntohl(daddr
), ntohs(dport
), lookup_type
, sk
);
170 #ifdef XT_TPROXY_HAVE_IPV6
171 static inline struct sock
*
172 nf_tproxy_get_sock_v6(struct net
*net
, const u8 protocol
,
173 const struct in6_addr
*saddr
, const struct in6_addr
*daddr
,
174 const __be16 sport
, const __be16 dport
,
175 const struct net_device
*in
,
176 const enum nf_tproxy_lookup_t lookup_type
)
182 switch (lookup_type
) {
183 case NFT_LOOKUP_LISTENER
:
184 sk
= inet6_lookup_listener(net
, &tcp_hashinfo
,
189 /* NOTE: we return listeners even if bound to
190 * 0.0.0.0, those are filtered out in
191 * xt_socket, since xt_TPROXY needs 0 bound
195 case NFT_LOOKUP_ESTABLISHED
:
196 sk
= __inet6_lookup_established(net
, &tcp_hashinfo
,
197 saddr
, sport
, daddr
, ntohs(dport
),
205 sk
= udp6_lib_lookup(net
, saddr
, sport
, daddr
, dport
,
208 int connected
= (sk
->sk_state
== TCP_ESTABLISHED
);
209 int wildcard
= ipv6_addr_any(&sk
->sk_v6_rcv_saddr
);
211 /* NOTE: we return listeners even if bound to
212 * 0.0.0.0, those are filtered out in
213 * xt_socket, since xt_TPROXY needs 0 bound
216 if ((lookup_type
== NFT_LOOKUP_ESTABLISHED
&& (!connected
|| wildcard
)) ||
217 (lookup_type
== NFT_LOOKUP_LISTENER
&& connected
)) {
228 pr_debug("tproxy socket lookup: proto %u %pI6:%u -> %pI6:%u, lookup type: %d, sock %p\n",
229 protocol
, saddr
, ntohs(sport
), daddr
, ntohs(dport
), lookup_type
, sk
);
236 * tproxy_handle_time_wait4 - handle IPv4 TCP TIME_WAIT reopen redirections
237 * @skb: The skb being processed.
238 * @laddr: IPv4 address to redirect to or zero.
239 * @lport: TCP port to redirect to or zero.
240 * @sk: The TIME_WAIT TCP socket found by the lookup.
242 * We have to handle SYN packets arriving to TIME_WAIT sockets
243 * differently: instead of reopening the connection we should rather
244 * redirect the new connection to the proxy if there's a listener
247 * tproxy_handle_time_wait4() consumes the socket reference passed in.
249 * Returns the listener socket if there's one, the TIME_WAIT socket if
250 * no such listener is found, or NULL if the TCP header is incomplete.
253 tproxy_handle_time_wait4(struct net
*net
, struct sk_buff
*skb
,
254 __be32 laddr
, __be16 lport
, struct sock
*sk
)
256 const struct iphdr
*iph
= ip_hdr(skb
);
257 struct tcphdr _hdr
, *hp
;
259 hp
= skb_header_pointer(skb
, ip_hdrlen(skb
), sizeof(_hdr
), &_hdr
);
261 inet_twsk_put(inet_twsk(sk
));
265 if (hp
->syn
&& !hp
->rst
&& !hp
->ack
&& !hp
->fin
) {
266 /* SYN to a TIME_WAIT socket, we'd rather redirect it
267 * to a listener socket if there's one */
270 sk2
= nf_tproxy_get_sock_v4(net
, iph
->protocol
,
271 iph
->saddr
, laddr
? laddr
: iph
->daddr
,
272 hp
->source
, lport
? lport
: hp
->dest
,
273 skb
->dev
, NFT_LOOKUP_LISTENER
);
275 inet_twsk_deschedule_put(inet_twsk(sk
));
283 /* assign a socket to the skb -- consumes sk */
285 nf_tproxy_assign_sock(struct sk_buff
*skb
, struct sock
*sk
)
289 skb
->destructor
= sock_edemux
;
293 tproxy_tg4(struct net
*net
, struct sk_buff
*skb
, __be32 laddr
, __be16 lport
,
294 u_int32_t mark_mask
, u_int32_t mark_value
)
296 const struct iphdr
*iph
= ip_hdr(skb
);
297 struct udphdr _hdr
, *hp
;
300 hp
= skb_header_pointer(skb
, ip_hdrlen(skb
), sizeof(_hdr
), &_hdr
);
304 /* check if there's an ongoing connection on the packet
305 * addresses, this happens if the redirect already happened
306 * and the current packet belongs to an already established
308 sk
= nf_tproxy_get_sock_v4(net
, iph
->protocol
,
309 iph
->saddr
, iph
->daddr
,
310 hp
->source
, hp
->dest
,
311 skb
->dev
, NFT_LOOKUP_ESTABLISHED
);
313 laddr
= tproxy_laddr4(skb
, laddr
, iph
->daddr
);
317 /* UDP has no TCP_TIME_WAIT state, so we never enter here */
318 if (sk
&& sk
->sk_state
== TCP_TIME_WAIT
)
319 /* reopening a TIME_WAIT connection needs special handling */
320 sk
= tproxy_handle_time_wait4(net
, skb
, laddr
, lport
, sk
);
322 /* no, there's no established connection, check if
323 * there's a listener on the redirected addr/port */
324 sk
= nf_tproxy_get_sock_v4(net
, iph
->protocol
,
327 skb
->dev
, NFT_LOOKUP_LISTENER
);
329 /* NOTE: assign_sock consumes our sk reference */
330 if (sk
&& tproxy_sk_is_transparent(sk
)) {
331 /* This should be in a separate target, but we don't do multiple
332 targets on the same rule yet */
333 skb
->mark
= (skb
->mark
& ~mark_mask
) ^ mark_value
;
335 pr_debug("redirecting: proto %hhu %pI4:%hu -> %pI4:%hu, mark: %x\n",
336 iph
->protocol
, &iph
->daddr
, ntohs(hp
->dest
),
337 &laddr
, ntohs(lport
), skb
->mark
);
339 nf_tproxy_assign_sock(skb
, sk
);
343 pr_debug("no socket, dropping: proto %hhu %pI4:%hu -> %pI4:%hu, mark: %x\n",
344 iph
->protocol
, &iph
->saddr
, ntohs(hp
->source
),
345 &iph
->daddr
, ntohs(hp
->dest
), skb
->mark
);
350 tproxy_tg4_v0(struct sk_buff
*skb
, const struct xt_action_param
*par
)
352 const struct xt_tproxy_target_info
*tgi
= par
->targinfo
;
354 return tproxy_tg4(par
->net
, skb
, tgi
->laddr
, tgi
->lport
, tgi
->mark_mask
, tgi
->mark_value
);
358 tproxy_tg4_v1(struct sk_buff
*skb
, const struct xt_action_param
*par
)
360 const struct xt_tproxy_target_info_v1
*tgi
= par
->targinfo
;
362 return tproxy_tg4(par
->net
, skb
, tgi
->laddr
.ip
, tgi
->lport
, tgi
->mark_mask
, tgi
->mark_value
);
365 #ifdef XT_TPROXY_HAVE_IPV6
367 static inline const struct in6_addr
*
368 tproxy_laddr6(struct sk_buff
*skb
, const struct in6_addr
*user_laddr
,
369 const struct in6_addr
*daddr
)
371 struct inet6_dev
*indev
;
372 struct inet6_ifaddr
*ifa
;
373 struct in6_addr
*laddr
;
375 if (!ipv6_addr_any(user_laddr
))
380 indev
= __in6_dev_get(skb
->dev
);
382 list_for_each_entry(ifa
, &indev
->addr_list
, if_list
) {
383 if (ifa
->flags
& (IFA_F_TENTATIVE
| IFA_F_DEPRECATED
))
391 return laddr
? laddr
: daddr
;
395 * tproxy_handle_time_wait6 - handle IPv6 TCP TIME_WAIT reopen redirections
396 * @skb: The skb being processed.
397 * @tproto: Transport protocol.
398 * @thoff: Transport protocol header offset.
399 * @par: Iptables target parameters.
400 * @sk: The TIME_WAIT TCP socket found by the lookup.
402 * We have to handle SYN packets arriving to TIME_WAIT sockets
403 * differently: instead of reopening the connection we should rather
404 * redirect the new connection to the proxy if there's a listener
407 * tproxy_handle_time_wait6() consumes the socket reference passed in.
409 * Returns the listener socket if there's one, the TIME_WAIT socket if
410 * no such listener is found, or NULL if the TCP header is incomplete.
413 tproxy_handle_time_wait6(struct sk_buff
*skb
, int tproto
, int thoff
,
414 const struct xt_action_param
*par
,
417 const struct ipv6hdr
*iph
= ipv6_hdr(skb
);
418 struct tcphdr _hdr
, *hp
;
419 const struct xt_tproxy_target_info_v1
*tgi
= par
->targinfo
;
421 hp
= skb_header_pointer(skb
, thoff
, sizeof(_hdr
), &_hdr
);
423 inet_twsk_put(inet_twsk(sk
));
427 if (hp
->syn
&& !hp
->rst
&& !hp
->ack
&& !hp
->fin
) {
428 /* SYN to a TIME_WAIT socket, we'd rather redirect it
429 * to a listener socket if there's one */
432 sk2
= nf_tproxy_get_sock_v6(par
->net
, tproto
,
434 tproxy_laddr6(skb
, &tgi
->laddr
.in6
, &iph
->daddr
),
436 tgi
->lport
? tgi
->lport
: hp
->dest
,
437 skb
->dev
, NFT_LOOKUP_LISTENER
);
439 inet_twsk_deschedule_put(inet_twsk(sk
));
448 tproxy_tg6_v1(struct sk_buff
*skb
, const struct xt_action_param
*par
)
450 const struct ipv6hdr
*iph
= ipv6_hdr(skb
);
451 const struct xt_tproxy_target_info_v1
*tgi
= par
->targinfo
;
452 struct udphdr _hdr
, *hp
;
454 const struct in6_addr
*laddr
;
459 tproto
= ipv6_find_hdr(skb
, &thoff
, -1, NULL
, NULL
);
461 pr_debug("unable to find transport header in IPv6 packet, dropping\n");
465 hp
= skb_header_pointer(skb
, thoff
, sizeof(_hdr
), &_hdr
);
467 pr_debug("unable to grab transport header contents in IPv6 packet, dropping\n");
471 /* check if there's an ongoing connection on the packet
472 * addresses, this happens if the redirect already happened
473 * and the current packet belongs to an already established
475 sk
= nf_tproxy_get_sock_v6(par
->net
, tproto
,
476 &iph
->saddr
, &iph
->daddr
,
477 hp
->source
, hp
->dest
,
478 par
->in
, NFT_LOOKUP_ESTABLISHED
);
480 laddr
= tproxy_laddr6(skb
, &tgi
->laddr
.in6
, &iph
->daddr
);
481 lport
= tgi
->lport
? tgi
->lport
: hp
->dest
;
483 /* UDP has no TCP_TIME_WAIT state, so we never enter here */
484 if (sk
&& sk
->sk_state
== TCP_TIME_WAIT
)
485 /* reopening a TIME_WAIT connection needs special handling */
486 sk
= tproxy_handle_time_wait6(skb
, tproto
, thoff
, par
, sk
);
488 /* no there's no established connection, check if
489 * there's a listener on the redirected addr/port */
490 sk
= nf_tproxy_get_sock_v6(par
->net
, tproto
,
493 par
->in
, NFT_LOOKUP_LISTENER
);
495 /* NOTE: assign_sock consumes our sk reference */
496 if (sk
&& tproxy_sk_is_transparent(sk
)) {
497 /* This should be in a separate target, but we don't do multiple
498 targets on the same rule yet */
499 skb
->mark
= (skb
->mark
& ~tgi
->mark_mask
) ^ tgi
->mark_value
;
501 pr_debug("redirecting: proto %hhu %pI6:%hu -> %pI6:%hu, mark: %x\n",
502 tproto
, &iph
->saddr
, ntohs(hp
->source
),
503 laddr
, ntohs(lport
), skb
->mark
);
505 nf_tproxy_assign_sock(skb
, sk
);
509 pr_debug("no socket, dropping: proto %hhu %pI6:%hu -> %pI6:%hu, mark: %x\n",
510 tproto
, &iph
->saddr
, ntohs(hp
->source
),
511 &iph
->daddr
, ntohs(hp
->dest
), skb
->mark
);
516 static int tproxy_tg6_check(const struct xt_tgchk_param
*par
)
518 const struct ip6t_ip6
*i
= par
->entryinfo
;
520 if ((i
->proto
== IPPROTO_TCP
|| i
->proto
== IPPROTO_UDP
) &&
521 !(i
->invflags
& IP6T_INV_PROTO
))
524 pr_info("Can be used only in combination with "
525 "either -p tcp or -p udp\n");
530 static int tproxy_tg4_check(const struct xt_tgchk_param
*par
)
532 const struct ipt_ip
*i
= par
->entryinfo
;
534 if ((i
->proto
== IPPROTO_TCP
|| i
->proto
== IPPROTO_UDP
)
535 && !(i
->invflags
& IPT_INV_PROTO
))
538 pr_info("Can be used only in combination with "
539 "either -p tcp or -p udp\n");
543 static struct xt_target tproxy_tg_reg
[] __read_mostly
= {
546 .family
= NFPROTO_IPV4
,
548 .target
= tproxy_tg4_v0
,
550 .targetsize
= sizeof(struct xt_tproxy_target_info
),
551 .checkentry
= tproxy_tg4_check
,
552 .hooks
= 1 << NF_INET_PRE_ROUTING
,
557 .family
= NFPROTO_IPV4
,
559 .target
= tproxy_tg4_v1
,
561 .targetsize
= sizeof(struct xt_tproxy_target_info_v1
),
562 .checkentry
= tproxy_tg4_check
,
563 .hooks
= 1 << NF_INET_PRE_ROUTING
,
566 #ifdef XT_TPROXY_HAVE_IPV6
569 .family
= NFPROTO_IPV6
,
571 .target
= tproxy_tg6_v1
,
573 .targetsize
= sizeof(struct xt_tproxy_target_info_v1
),
574 .checkentry
= tproxy_tg6_check
,
575 .hooks
= 1 << NF_INET_PRE_ROUTING
,
582 static int __init
tproxy_tg_init(void)
584 nf_defrag_ipv4_enable();
585 #ifdef XT_TPROXY_HAVE_IPV6
586 nf_defrag_ipv6_enable();
589 return xt_register_targets(tproxy_tg_reg
, ARRAY_SIZE(tproxy_tg_reg
));
592 static void __exit
tproxy_tg_exit(void)
594 xt_unregister_targets(tproxy_tg_reg
, ARRAY_SIZE(tproxy_tg_reg
));
597 module_init(tproxy_tg_init
);
598 module_exit(tproxy_tg_exit
);
599 MODULE_LICENSE("GPL");
600 MODULE_AUTHOR("Balazs Scheidler, Krisztian Kovacs");
601 MODULE_DESCRIPTION("Netfilter transparent proxy (TPROXY) target module.");
602 MODULE_ALIAS("ipt_TPROXY");
603 MODULE_ALIAS("ip6t_TPROXY");