#if defined(KERNEL) || defined(_KERNEL)
# undef KERNEL
# undef _KERNEL
# define KERNEL 1
# define _KERNEL 1
#endif
#include <sys/errno.h>
#include <sys/types.h>
#include <sys/param.h>
#include <sys/time.h>
#if defined(_KERNEL) && defined(__FreeBSD__)
# if !defined(IPFILTER_LKM)
# include "opt_inet6.h"
# endif
# include <sys/filio.h>
#else
# include <sys/ioctl.h>
#endif
#if defined(__SVR4) || defined(sun)
# include <sys/filio.h>
#endif
# include <sys/fcntl.h>
#if defined(_KERNEL)
# include <sys/systm.h>
# include <sys/file.h>
#else
# include <stdio.h>
# include <string.h>
# include <stdlib.h>
# include <stddef.h>
# include <sys/file.h>
# define _KERNEL
# include <sys/uio.h>
# undef _KERNEL
#endif
#if !defined(__SVR4)
# include <sys/mbuf.h>
#else
# include <sys/byteorder.h>
# if (SOLARIS2 < 5) && defined(sun)
# include <sys/dditypes.h>
# endif
#endif
# include <sys/protosw.h>
#include <sys/socket.h>
#include <net/if.h>
#ifdef sun
# include <net/af.h>
#endif
#include <netinet/in.h>
#include <netinet/in_systm.h>
#include <netinet/ip.h>
#include <netinet/tcp.h>
# include <netinet/udp.h>
# include <netinet/ip_icmp.h>
#include "netinet/ip_compat.h"
#ifdef USE_INET6
# include <netinet/icmp6.h>
# if !SOLARIS && defined(_KERNEL)
# include <netinet6/in6_var.h>
# endif
#endif
#include "netinet/ip_fil.h"
#include "netinet/ip_nat.h"
#include "netinet/ip_frag.h"
#include "netinet/ip_state.h"
#include "netinet/ip_proxy.h"
#include "netinet/ip_auth.h"
#ifdef IPFILTER_SCAN
# include "netinet/ip_scan.h"
#endif
#include "netinet/ip_sync.h"
#include "netinet/ip_lookup.h"
#include "netinet/ip_pool.h"
#include "netinet/ip_htable.h"
#ifdef IPFILTER_COMPILED
# include "netinet/ip_rules.h"
#endif
#if defined(IPFILTER_BPF) && defined(_KERNEL)
# include <net/bpf.h>
#endif
#if defined(__FreeBSD__)
# include <sys/malloc.h>
#endif
#include "netinet/ipl.h"
#if defined(__NetBSD__) && (__NetBSD_Version__ >= 104230000)
# include <sys/callout.h>
extern struct callout ipf_slowtimer_ch;
#endif
#ifndef _KERNEL
# include "ipf.h"
# include "ipt.h"
extern int opts;
extern int blockreason;
#endif
#define FASTROUTE_RECURSION
#define LBUMP(x) softc->x++
#define LBUMPD(x, y) do { softc->x.y++; DT(y); } while (0)
static inline int ipf_check_ipf(fr_info_t *, frentry_t *, int);
static u_32_t ipf_checkcipso(fr_info_t *, u_char *, int);
static u_32_t ipf_checkripso(u_char *);
static u_32_t ipf_decaps(fr_info_t *, u_32_t, int);
#ifdef IPFILTER_LOG
static frentry_t *ipf_dolog(fr_info_t *, u_32_t *);
#endif
static int ipf_flushlist(ipf_main_softc_t *, int *, frentry_t **);
static int ipf_flush_groups(ipf_main_softc_t *, frgroup_t **,
int);
static ipfunc_t ipf_findfunc(ipfunc_t);
static void *ipf_findlookup(ipf_main_softc_t *, int, frentry_t *,
i6addr_t *, i6addr_t *);
static frentry_t *ipf_firewall(fr_info_t *, u_32_t *);
static int ipf_fr_matcharray(fr_info_t *, int *);
static int ipf_frruleiter(ipf_main_softc_t *, void *, int,
void *);
static void ipf_funcfini(ipf_main_softc_t *, frentry_t *);
static int ipf_funcinit(ipf_main_softc_t *, frentry_t *);
static int ipf_geniter(ipf_main_softc_t *, ipftoken_t *,
ipfgeniter_t *);
static void ipf_getstat(ipf_main_softc_t *,
struct friostat *, int);
static int ipf_group_flush(ipf_main_softc_t *, frgroup_t *);
static void ipf_group_free(frgroup_t *);
static int ipf_grpmapfini(struct ipf_main_softc_s *,
frentry_t *);
static int ipf_grpmapinit(struct ipf_main_softc_s *,
frentry_t *);
static frentry_t *ipf_nextrule(ipf_main_softc_t *, int, int,
frentry_t *, int);
static int ipf_portcheck(frpcmp_t *, u_32_t);
static inline int ipf_pr_ah(fr_info_t *);
static inline void ipf_pr_esp(fr_info_t *);
static inline void ipf_pr_gre(fr_info_t *);
static inline void ipf_pr_udp(fr_info_t *);
static inline void ipf_pr_tcp(fr_info_t *);
static inline void ipf_pr_icmp(fr_info_t *);
static inline void ipf_pr_ipv4hdr(fr_info_t *);
static inline void ipf_pr_short(fr_info_t *, int);
static inline int ipf_pr_tcpcommon(fr_info_t *);
static inline int ipf_pr_udpcommon(fr_info_t *);
static void ipf_rule_delete(ipf_main_softc_t *, frentry_t *f,
int, int);
static void ipf_rule_expire_insert(ipf_main_softc_t *,
frentry_t *, int);
static int ipf_synclist(ipf_main_softc_t *, frentry_t *,
void *);
static void ipf_token_flush(ipf_main_softc_t *);
static void ipf_token_unlink(ipf_main_softc_t *,
ipftoken_t *);
static ipftuneable_t *ipf_tune_findbyname(ipftuneable_t *,
const char *);
static ipftuneable_t *ipf_tune_findbycookie(ipftuneable_t **, void *,
void **);
static int ipf_updateipid(fr_info_t *);
static int ipf_settimeout(struct ipf_main_softc_s *,
struct ipftuneable *,
ipftuneval_t *);
#if !defined(_KERNEL) || SOLARIS
static int ppsratecheck(struct timeval *, int *, int);
#endif
static const struct optlist ipopts[] = {
{ IPOPT_NOP, 0x000001 },
{ IPOPT_RR, 0x000002 },
{ IPOPT_ZSU, 0x000004 },
{ IPOPT_MTUP, 0x000008 },
{ IPOPT_MTUR, 0x000010 },
{ IPOPT_ENCODE, 0x000020 },
{ IPOPT_TS, 0x000040 },
{ IPOPT_TR, 0x000080 },
{ IPOPT_SECURITY, 0x000100 },
{ IPOPT_LSRR, 0x000200 },
{ IPOPT_E_SEC, 0x000400 },
{ IPOPT_CIPSO, 0x000800 },
{ IPOPT_SATID, 0x001000 },
{ IPOPT_SSRR, 0x002000 },
{ IPOPT_ADDEXT, 0x004000 },
{ IPOPT_VISA, 0x008000 },
{ IPOPT_IMITD, 0x010000 },
{ IPOPT_EIP, 0x020000 },
{ IPOPT_FINN, 0x040000 },
{ 0, 0x000000 }
};
#ifdef USE_INET6
static const struct optlist ip6exthdr[] = {
{ IPPROTO_HOPOPTS, 0x000001 },
{ IPPROTO_IPV6, 0x000002 },
{ IPPROTO_ROUTING, 0x000004 },
{ IPPROTO_FRAGMENT, 0x000008 },
{ IPPROTO_ESP, 0x000010 },
{ IPPROTO_AH, 0x000020 },
{ IPPROTO_NONE, 0x000040 },
{ IPPROTO_DSTOPTS, 0x000080 },
{ IPPROTO_MOBILITY, 0x000100 },
{ 0, 0 }
};
#endif
static const struct optlist secopt[] = {
{ IPSO_CLASS_RES4, 0x01 },
{ IPSO_CLASS_TOPS, 0x02 },
{ IPSO_CLASS_SECR, 0x04 },
{ IPSO_CLASS_RES3, 0x08 },
{ IPSO_CLASS_CONF, 0x10 },
{ IPSO_CLASS_UNCL, 0x20 },
{ IPSO_CLASS_RES2, 0x40 },
{ IPSO_CLASS_RES1, 0x80 }
};
static const int interr_tbl[3] = { 152, 156, 153 };
char ipfilter_version[] = IPL_VERSION;
int ipf_features = 0
#ifdef IPFILTER_LKM
| IPF_FEAT_LKM
#endif
#ifdef IPFILTER_LOG
| IPF_FEAT_LOG
#endif
| IPF_FEAT_LOOKUP
#ifdef IPFILTER_BPF
| IPF_FEAT_BPF
#endif
#ifdef IPFILTER_COMPILED
| IPF_FEAT_COMPILED
#endif
#ifdef IPFILTER_CKSUM
| IPF_FEAT_CKSUM
#endif
| IPF_FEAT_SYNC
#ifdef IPFILTER_SCAN
| IPF_FEAT_SCAN
#endif
#ifdef USE_INET6
| IPF_FEAT_IPV6
#endif
;
static ipfunc_resolve_t ipf_availfuncs[] = {
{ "srcgrpmap", ipf_srcgrpmap, ipf_grpmapinit, ipf_grpmapfini },
{ "dstgrpmap", ipf_dstgrpmap, ipf_grpmapinit, ipf_grpmapfini },
{ "", NULL, NULL, NULL }
};
static ipftuneable_t ipf_main_tuneables[] = {
{ { (void *)offsetof(struct ipf_main_softc_s, ipf_flags) },
"ipf_flags", 0, 0xffffffff,
stsizeof(ipf_main_softc_t, ipf_flags),
0, NULL, NULL },
{ { (void *)offsetof(struct ipf_main_softc_s, ipf_active) },
"active", 0, 0,
stsizeof(ipf_main_softc_t, ipf_active),
IPFT_RDONLY, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_control_forwarding) },
"control_forwarding", 0, 1,
stsizeof(ipf_main_softc_t, ipf_control_forwarding),
0, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_update_ipid) },
"update_ipid", 0, 1,
stsizeof(ipf_main_softc_t, ipf_update_ipid),
0, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_chksrc) },
"chksrc", 0, 1,
stsizeof(ipf_main_softc_t, ipf_chksrc),
0, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_minttl) },
"min_ttl", 0, 1,
stsizeof(ipf_main_softc_t, ipf_minttl),
0, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_icmpminfragmtu) },
"icmp_minfragmtu", 0, 1,
stsizeof(ipf_main_softc_t, ipf_icmpminfragmtu),
0, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_pass) },
"default_pass", 0, 0xffffffff,
stsizeof(ipf_main_softc_t, ipf_pass),
0, NULL, NULL },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcpidletimeout) },
"tcp_idle_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcpidletimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcpclosewait) },
"tcp_close_wait", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcpclosewait),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcplastack) },
"tcp_last_ack", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcplastack),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcptimeout) },
"tcp_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcptimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcpsynsent) },
"tcp_syn_sent", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcpsynsent),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcpsynrecv) },
"tcp_syn_received", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcpsynrecv),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcpclosed) },
"tcp_closed", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcpclosed),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcphalfclosed) },
"tcp_half_closed", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcphalfclosed),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_tcptimewait) },
"tcp_time_wait", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_tcptimewait),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_udptimeout) },
"udp_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_udptimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_udpacktimeout) },
"udp_ack_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_udpacktimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_icmptimeout) },
"icmp_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_icmptimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_icmpacktimeout) },
"icmp_ack_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_icmpacktimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_iptimeout) },
"ip_timeout", 1, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_iptimeout),
0, NULL, ipf_settimeout },
{ { (void *)offsetof(ipf_main_softc_t, ipf_max_namelen) },
"max_namelen", 0, 0x7fffffff,
stsizeof(ipf_main_softc_t, ipf_max_namelen),
0, NULL, NULL },
#if defined(INSTANCES) && defined(_KERNEL)
{ { (void *)offsetof(ipf_main_softc_t, ipf_get_loopback) },
"intercept_loopback", 0, 1,
stsizeof(ipf_main_softc_t, ipf_get_loopback),
0, NULL, ipf_set_loopback },
#endif
{ { 0 },
NULL, 0, 0,
0,
0, NULL, NULL }
};
#ifdef USE_INET6
static inline int ipf_pr_ah6(fr_info_t *);
static inline void ipf_pr_esp6(fr_info_t *);
static inline void ipf_pr_gre6(fr_info_t *);
static inline void ipf_pr_udp6(fr_info_t *);
static inline void ipf_pr_tcp6(fr_info_t *);
static inline void ipf_pr_icmp6(fr_info_t *);
static inline void ipf_pr_ipv6hdr(fr_info_t *);
static inline void ipf_pr_short6(fr_info_t *, int);
static inline int ipf_pr_hopopts6(fr_info_t *);
static inline int ipf_pr_mobility6(fr_info_t *);
static inline int ipf_pr_routing6(fr_info_t *);
static inline int ipf_pr_dstopts6(fr_info_t *);
static inline int ipf_pr_fragment6(fr_info_t *);
static inline struct ip6_ext *ipf_pr_ipv6exthdr(fr_info_t *, int, int);
static inline void
ipf_pr_short6(fr_info_t *fin, int xmin)
{
if (fin->fin_dlen < xmin)
fin->fin_flx |= FI_SHORT;
}
static inline void
ipf_pr_ipv6hdr(fr_info_t *fin)
{
ip6_t *ip6 = (ip6_t *)fin->fin_ip;
int p, go = 1, i;
fr_ip_t *fi = &fin->fin_fi;
fin->fin_off = 0;
fi->fi_tos = 0;
fi->fi_optmsk = 0;
fi->fi_secmsk = 0;
fi->fi_auth = 0;
p = ip6->ip6_nxt;
fin->fin_crc = p;
fi->fi_ttl = ip6->ip6_hlim;
fi->fi_src.in6 = ip6->ip6_src;
fin->fin_crc += fi->fi_src.i6[0];
fin->fin_crc += fi->fi_src.i6[1];
fin->fin_crc += fi->fi_src.i6[2];
fin->fin_crc += fi->fi_src.i6[3];
fi->fi_dst.in6 = ip6->ip6_dst;
fin->fin_crc += fi->fi_dst.i6[0];
fin->fin_crc += fi->fi_dst.i6[1];
fin->fin_crc += fi->fi_dst.i6[2];
fin->fin_crc += fi->fi_dst.i6[3];
fin->fin_id = 0;
if (IN6_IS_ADDR_MULTICAST(&fi->fi_dst.in6))
fin->fin_flx |= FI_MULTICAST|FI_MBCAST;
while (go && !(fin->fin_flx & FI_SHORT)) {
switch (p)
{
case IPPROTO_UDP :
ipf_pr_udp6(fin);
go = 0;
break;
case IPPROTO_TCP :
ipf_pr_tcp6(fin);
go = 0;
break;
case IPPROTO_ICMPV6 :
ipf_pr_icmp6(fin);
go = 0;
break;
case IPPROTO_GRE :
ipf_pr_gre6(fin);
go = 0;
break;
case IPPROTO_HOPOPTS :
p = ipf_pr_hopopts6(fin);
break;
case IPPROTO_MOBILITY :
p = ipf_pr_mobility6(fin);
break;
case IPPROTO_DSTOPTS :
p = ipf_pr_dstopts6(fin);
break;
case IPPROTO_ROUTING :
p = ipf_pr_routing6(fin);
break;
case IPPROTO_AH :
p = ipf_pr_ah6(fin);
break;
case IPPROTO_ESP :
ipf_pr_esp6(fin);
go = 0;
break;
case IPPROTO_IPV6 :
for (i = 0; ip6exthdr[i].ol_bit != 0; i++)
if (ip6exthdr[i].ol_val == p) {
fin->fin_flx |= ip6exthdr[i].ol_bit;
break;
}
go = 0;
break;
case IPPROTO_NONE :
go = 0;
break;
case IPPROTO_FRAGMENT :
p = ipf_pr_fragment6(fin);
if (fin->fin_off != 0)
go = 0;
break;
default :
go = 0;
break;
}
if ((go != 0) && (p != IPPROTO_NONE) &&
(ipf_pr_pullup(fin, 0) == -1)) {
p = IPPROTO_NONE;
break;
}
}
if (fin->fin_m == NULL) {
ipf_main_softc_t *softc = fin->fin_main_soft;
LBUMPD(ipf_stats[fin->fin_out], fr_v6_bad);
return;
}
fi->fi_p = p;
if ((go != 0) && (fin->fin_flx & FI_FRAG) && (fin->fin_off == 0)) {
ipf_main_softc_t *softc = fin->fin_main_soft;
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_ipv6_frag_1, fr_info_t *, fin, int, go);
LBUMPD(ipf_stats[fin->fin_out], fr_v6_badfrag);
LBUMP(ipf_stats[fin->fin_out].fr_v6_bad);
}
}
static inline struct ip6_ext *
ipf_pr_ipv6exthdr(fr_info_t *fin, int multiple, int proto)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
struct ip6_ext *hdr;
u_short shift;
int i;
fin->fin_flx |= FI_V6EXTHDR;
if ((fin->fin_dlen - 8) < 0) {
fin->fin_flx |= FI_SHORT;
LBUMPD(ipf_stats[fin->fin_out], fr_v6_ext_short);
return (NULL);
}
if (ipf_pr_pullup(fin, 8) == -1) {
LBUMPD(ipf_stats[fin->fin_out], fr_v6_ext_pullup);
return (NULL);
}
hdr = fin->fin_dp;
switch (proto)
{
case IPPROTO_FRAGMENT :
shift = 8;
break;
default :
shift = 8 + (hdr->ip6e_len << 3);
break;
}
if (shift > fin->fin_dlen) {
fin->fin_flx |= FI_BAD;
DT3(ipf_fi_bad_pr_ipv6exthdr_len, fr_info_t *, fin, u_short, shift, u_short, fin->fin_dlen);
LBUMPD(ipf_stats[fin->fin_out], fr_v6_ext_hlen);
return (NULL);
}
fin->fin_dp = (char *)fin->fin_dp + shift;
fin->fin_dlen -= shift;
if (fin->fin_flx & FI_FRAG)
return (hdr);
for (i = 0; ip6exthdr[i].ol_bit != 0; i++)
if (ip6exthdr[i].ol_val == proto) {
if ((multiple == 0) &&
((fin->fin_optmsk & ip6exthdr[i].ol_bit) != 0)) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_ipv6exthdr_once, fr_info_t *, fin, u_int, (fin->fin_optmsk & ip6exthdr[i].ol_bit));
} else
fin->fin_optmsk |= ip6exthdr[i].ol_bit;
break;
}
return (hdr);
}
static inline int
ipf_pr_hopopts6(fr_info_t *fin)
{
struct ip6_ext *hdr;
hdr = ipf_pr_ipv6exthdr(fin, 0, IPPROTO_HOPOPTS);
if (hdr == NULL)
return (IPPROTO_NONE);
return (hdr->ip6e_nxt);
}
static inline int
ipf_pr_mobility6(fr_info_t *fin)
{
struct ip6_ext *hdr;
hdr = ipf_pr_ipv6exthdr(fin, 0, IPPROTO_MOBILITY);
if (hdr == NULL)
return (IPPROTO_NONE);
return (hdr->ip6e_nxt);
}
static inline int
ipf_pr_routing6(fr_info_t *fin)
{
struct ip6_routing *hdr;
hdr = (struct ip6_routing *)ipf_pr_ipv6exthdr(fin, 0, IPPROTO_ROUTING);
if (hdr == NULL)
return (IPPROTO_NONE);
switch (hdr->ip6r_type)
{
case 0 :
if (((hdr->ip6r_len >> 1) < hdr->ip6r_segleft) ||
(hdr->ip6r_segleft && (hdr->ip6r_len & 1))) {
ipf_main_softc_t *softc = fin->fin_main_soft;
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_routing6, fr_info_t *, fin);
LBUMPD(ipf_stats[fin->fin_out], fr_v6_rh_bad);
return (IPPROTO_NONE);
}
break;
default :
break;
}
return (hdr->ip6r_nxt);
}
static inline int
ipf_pr_fragment6(fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
struct ip6_frag *frag;
fin->fin_flx |= FI_FRAG;
frag = (struct ip6_frag *)ipf_pr_ipv6exthdr(fin, 0, IPPROTO_FRAGMENT);
if (frag == NULL) {
LBUMPD(ipf_stats[fin->fin_out], fr_v6_frag_bad);
return (IPPROTO_NONE);
}
if ((frag->ip6f_offlg & IP6F_MORE_FRAG) != 0) {
if ((fin->fin_plen & 7) != 0) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_frag_not_8, fr_info_t *, fin, u_int, (fin->fin_plen & 7));
}
}
fin->fin_fraghdr = frag;
fin->fin_id = frag->ip6f_ident;
fin->fin_off = ntohs(frag->ip6f_offlg & IP6F_OFF_MASK);
if (fin->fin_off != 0)
fin->fin_flx |= FI_FRAGBODY;
if ((fin->fin_off << 3) + fin->fin_dlen > 65535) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_jumbogram, fr_info_t *, fin, u_int, ((fin->fin_off << 3) + fin->fin_dlen));
}
return (frag->ip6f_nxt);
}
static inline int
ipf_pr_dstopts6(fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
struct ip6_ext *hdr;
hdr = ipf_pr_ipv6exthdr(fin, 0, IPPROTO_DSTOPTS);
if (hdr == NULL) {
LBUMPD(ipf_stats[fin->fin_out], fr_v6_dst_bad);
return (IPPROTO_NONE);
}
return (hdr->ip6e_nxt);
}
static inline void
ipf_pr_icmp6(fr_info_t *fin)
{
int minicmpsz = sizeof(struct icmp6_hdr);
struct icmp6_hdr *icmp6;
if (ipf_pr_pullup(fin, ICMP6ERR_MINPKTLEN - sizeof(ip6_t)) == -1) {
ipf_main_softc_t *softc = fin->fin_main_soft;
LBUMPD(ipf_stats[fin->fin_out], fr_v6_icmp6_pullup);
return;
}
if (fin->fin_dlen > 1) {
ip6_t *ip6;
icmp6 = fin->fin_dp;
fin->fin_data[0] = *(u_short *)icmp6;
if ((icmp6->icmp6_type & ICMP6_INFOMSG_MASK) != 0)
fin->fin_flx |= FI_ICMPQUERY;
switch (icmp6->icmp6_type)
{
case ICMP6_ECHO_REPLY :
case ICMP6_ECHO_REQUEST :
if (fin->fin_dlen >= 6)
fin->fin_data[1] = icmp6->icmp6_id;
minicmpsz = ICMP6ERR_MINPKTLEN - sizeof(ip6_t);
break;
case ICMP6_DST_UNREACH :
case ICMP6_PACKET_TOO_BIG :
case ICMP6_TIME_EXCEEDED :
case ICMP6_PARAM_PROB :
fin->fin_flx |= FI_ICMPERR;
minicmpsz = ICMP6ERR_IPICMPHLEN - sizeof(ip6_t);
if (fin->fin_plen < ICMP6ERR_IPICMPHLEN)
break;
if (M_LEN(fin->fin_m) < fin->fin_plen) {
if (ipf_coalesce(fin) != 1)
return;
}
if (ipf_pr_pullup(fin, ICMP6ERR_MINPKTLEN) == -1)
return;
icmp6 = fin->fin_dp;
ip6 = (ip6_t *)((char *)icmp6 + ICMPERR_ICMPHLEN);
if (IP6_NEQ(&fin->fin_fi.fi_dst,
(i6addr_t *)&ip6->ip6_src)) {
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_icmp6, fr_info_t *, fin);
}
break;
default :
break;
}
}
ipf_pr_short6(fin, minicmpsz);
if ((fin->fin_flx & (FI_SHORT|FI_BAD)) == 0) {
u_char p = fin->fin_p;
fin->fin_p = IPPROTO_ICMPV6;
ipf_checkv6sum(fin);
fin->fin_p = p;
}
}
static inline void
ipf_pr_udp6(fr_info_t *fin)
{
if (ipf_pr_udpcommon(fin) == 0) {
u_char p = fin->fin_p;
fin->fin_p = IPPROTO_UDP;
ipf_checkv6sum(fin);
fin->fin_p = p;
}
}
static inline void
ipf_pr_tcp6(fr_info_t *fin)
{
if (ipf_pr_tcpcommon(fin) == 0) {
u_char p = fin->fin_p;
fin->fin_p = IPPROTO_TCP;
ipf_checkv6sum(fin);
fin->fin_p = p;
}
}
static inline void
ipf_pr_esp6(fr_info_t *fin)
{
if ((fin->fin_off == 0) && (ipf_pr_pullup(fin, 8) == -1)) {
ipf_main_softc_t *softc = fin->fin_main_soft;
LBUMPD(ipf_stats[fin->fin_out], fr_v6_esp_pullup);
return;
}
}
static inline int
ipf_pr_ah6(fr_info_t *fin)
{
authhdr_t *ah;
fin->fin_flx |= FI_AH;
ah = (authhdr_t *)ipf_pr_ipv6exthdr(fin, 0, IPPROTO_HOPOPTS);
if (ah == NULL) {
ipf_main_softc_t *softc = fin->fin_main_soft;
LBUMPD(ipf_stats[fin->fin_out], fr_v6_ah_bad);
return (IPPROTO_NONE);
}
ipf_pr_short6(fin, sizeof(*ah));
return (ah->ah_next);
}
static inline void
ipf_pr_gre6(fr_info_t *fin)
{
grehdr_t *gre;
if (ipf_pr_pullup(fin, sizeof(grehdr_t)) == -1) {
ipf_main_softc_t *softc = fin->fin_main_soft;
LBUMPD(ipf_stats[fin->fin_out], fr_v6_gre_pullup);
return;
}
gre = fin->fin_dp;
if (GRE_REV(gre->gr_flags) == 1)
fin->fin_data[0] = gre->gr_call;
}
#endif
int
ipf_pr_pullup(fr_info_t *fin, int plen)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
if (fin->fin_m != NULL) {
if (fin->fin_dp != NULL)
plen += (char *)fin->fin_dp -
((char *)fin->fin_ip + fin->fin_hlen);
plen += fin->fin_hlen;
if (M_LEN(fin->fin_m) < plen + fin->fin_ipoff) {
#if defined(_KERNEL)
if (ipf_pullup(fin->fin_m, fin, plen) == NULL) {
DT1(ipf_pullup_fail, fr_info_t *, fin);
LBUMP(ipf_stats[fin->fin_out].fr_pull[1]);
fin->fin_reason = FRB_PULLUP;
fin->fin_flx |= FI_BAD;
return (-1);
}
LBUMP(ipf_stats[fin->fin_out].fr_pull[0]);
#else
LBUMP(ipf_stats[fin->fin_out].fr_pull[1]);
fin->fin_reason = FRB_PULLUP;
*fin->fin_mp = NULL;
fin->fin_m = NULL;
fin->fin_ip = NULL;
fin->fin_flx |= FI_BAD;
return (-1);
#endif
}
}
return (0);
}
static inline void
ipf_pr_short(fr_info_t *fin, int xmin)
{
if (fin->fin_off == 0) {
if (fin->fin_dlen < xmin)
fin->fin_flx |= FI_SHORT;
} else if (fin->fin_off < xmin) {
fin->fin_flx |= FI_SHORT;
}
}
static inline void
ipf_pr_icmp(fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
int minicmpsz = sizeof(struct icmp);
icmphdr_t *icmp;
ip_t *oip;
ipf_pr_short(fin, ICMPERR_ICMPHLEN);
if (fin->fin_off != 0) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_icmp_frag);
return;
}
if (ipf_pr_pullup(fin, ICMPERR_ICMPHLEN) == -1) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_icmp_pullup);
return;
}
icmp = fin->fin_dp;
fin->fin_data[0] = *(u_short *)icmp;
fin->fin_data[1] = icmp->icmp_id;
switch (icmp->icmp_type)
{
case ICMP_ECHOREPLY :
case ICMP_ECHO :
case ICMP_ROUTERADVERT :
case ICMP_ROUTERSOLICIT :
fin->fin_flx |= FI_ICMPQUERY;
minicmpsz = ICMP_MINLEN;
break;
case ICMP_TSTAMP :
case ICMP_TSTAMPREPLY :
fin->fin_flx |= FI_ICMPQUERY;
minicmpsz = 20;
break;
case ICMP_IREQ :
case ICMP_IREQREPLY :
case ICMP_MASKREQ :
case ICMP_MASKREPLY :
fin->fin_flx |= FI_ICMPQUERY;
minicmpsz = 12;
break;
case ICMP_UNREACH :
#ifdef icmp_nextmtu
if (icmp->icmp_code == ICMP_UNREACH_NEEDFRAG) {
if (icmp->icmp_nextmtu < softc->ipf_icmpminfragmtu) {
fin->fin_flx |= FI_BAD;
DT3(ipf_fi_bad_icmp_nextmtu, fr_info_t *, fin, u_int, icmp->icmp_nextmtu, u_int, softc->ipf_icmpminfragmtu);
}
}
#endif
case ICMP_SOURCEQUENCH :
case ICMP_REDIRECT :
case ICMP_TIMXCEED :
case ICMP_PARAMPROB :
fin->fin_flx |= FI_ICMPERR;
if (ipf_coalesce(fin) != 1) {
LBUMPD(ipf_stats[fin->fin_out], fr_icmp_coalesce);
return;
}
oip = (ip_t *)((char *)fin->fin_dp + ICMPERR_ICMPHLEN);
if ((ntohs(oip->ip_off) & IP_OFFMASK) != 0) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_icmp_err, fr_info_t, fin, u_int, (ntohs(oip->ip_off) & IP_OFFMASK));
}
if (oip->ip_src.s_addr != fin->fin_daddr) {
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_src_ne_dst, fr_info_t *, fin);
}
break;
default :
break;
}
ipf_pr_short(fin, minicmpsz);
ipf_checkv4sum(fin);
}
static inline int
ipf_pr_tcpcommon(fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
int flags, tlen;
tcphdr_t *tcp;
fin->fin_flx |= FI_TCPUDP;
if (fin->fin_off != 0) {
LBUMPD(ipf_stats[fin->fin_out], fr_tcp_frag);
return (0);
}
if (ipf_pr_pullup(fin, sizeof(*tcp)) == -1) {
LBUMPD(ipf_stats[fin->fin_out], fr_tcp_pullup);
return (-1);
}
tcp = fin->fin_dp;
if (fin->fin_dlen > 3) {
fin->fin_sport = ntohs(tcp->th_sport);
fin->fin_dport = ntohs(tcp->th_dport);
}
if ((fin->fin_flx & FI_SHORT) != 0) {
LBUMPD(ipf_stats[fin->fin_out], fr_tcp_short);
return (1);
}
tlen = TCP_OFF(tcp) << 2;
if (tlen < sizeof(tcphdr_t)) {
LBUMPD(ipf_stats[fin->fin_out], fr_tcp_small);
fin->fin_flx |= FI_BAD;
DT3(ipf_fi_bad_tlen, fr_info_t, fin, u_int, tlen, u_int, sizeof(tcphdr_t));
return (1);
}
flags = tcp_get_flags(tcp);
fin->fin_tcpf = tcp_get_flags(tcp);
if ((flags & TH_URG) != 0 && (tcp->th_urp == 0)) {
fin->fin_flx |= FI_BAD;
DT3(ipf_fi_bad_th_urg, fr_info_t*, fin, u_int, (flags & TH_URG), u_int, tcp->th_urp);
#if 0
} else if ((flags & TH_URG) == 0 && (tcp->th_urp != 0)) {
fin->fin_flx |= FI_BAD;
DT3(ipf_fi_bad_th_urg0, fr_info_t *, fin, u_int, (flags & TH_URG), u_int, tcp->th_urp);
#endif
} else if (((flags & (TH_SYN|TH_FIN)) != 0) &&
((flags & (TH_RST|TH_ACK)) == TH_RST)) {
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_th_fin_rst_ack, fr_info_t, fin);
#if 1
} else if (((flags & TH_SYN) != 0) &&
((flags & (TH_URG|TH_PUSH)) != 0)) {
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_th_syn_urg_psh, fr_info_t *, fin);
#endif
} else if (!(flags & TH_ACK)) {
if ((flags == TH_SYN) && (tcp->th_ack != 0)) {
;
} else if (!(flags & (TH_RST|TH_SYN))) {
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_th_rst_syn, fr_info_t *, fin);
} else if ((flags & (TH_URG|TH_PUSH|TH_FIN)) != 0) {
fin->fin_flx |= FI_BAD;
DT1(ipf_fi_bad_th_urg_push_fin, fr_info_t *, fin);
}
}
if (fin->fin_flx & FI_BAD) {
LBUMPD(ipf_stats[fin->fin_out], fr_tcp_bad_flags);
return (1);
}
if (tlen == sizeof(tcphdr_t)) {
return (0);
}
if (ipf_pr_pullup(fin, tlen) == -1) {
LBUMPD(ipf_stats[fin->fin_out], fr_tcp_pullup);
return (-1);
}
#if 0
tcp = fin->fin_dp;
ip = fin->fin_ip;
s = (u_char *)(tcp + 1);
off = IP_HL(ip) << 2;
# ifdef _KERNEL
if (fin->fin_mp != NULL) {
mb_t *m = *fin->fin_mp;
if (off + tlen > M_LEN(m))
return;
}
# endif
for (tlen -= (int)sizeof(*tcp); tlen > 0; ) {
opt = *s;
if (opt == '\0')
break;
else if (opt == TCPOPT_NOP)
ol = 1;
else {
if (tlen < 2)
break;
ol = (int)*(s + 1);
if (ol < 2 || ol > tlen)
break;
}
for (i = 9, mv = 4; mv >= 0; ) {
op = ipopts + i;
if (opt == (u_char)op->ol_val) {
optmsk |= op->ol_bit;
break;
}
}
tlen -= ol;
s += ol;
}
#endif
return (0);
}
static inline int
ipf_pr_udpcommon(fr_info_t *fin)
{
udphdr_t *udp;
fin->fin_flx |= FI_TCPUDP;
if (!fin->fin_off && (fin->fin_dlen > 3)) {
if (ipf_pr_pullup(fin, sizeof(*udp)) == -1) {
ipf_main_softc_t *softc = fin->fin_main_soft;
fin->fin_flx |= FI_SHORT;
LBUMPD(ipf_stats[fin->fin_out], fr_udp_pullup);
return (1);
}
udp = fin->fin_dp;
fin->fin_sport = ntohs(udp->uh_sport);
fin->fin_dport = ntohs(udp->uh_dport);
}
return (0);
}
static inline void
ipf_pr_tcp(fr_info_t *fin)
{
ipf_pr_short(fin, sizeof(tcphdr_t));
if (ipf_pr_tcpcommon(fin) == 0)
ipf_checkv4sum(fin);
}
static inline void
ipf_pr_udp(fr_info_t *fin)
{
ipf_pr_short(fin, sizeof(udphdr_t));
if (ipf_pr_udpcommon(fin) == 0)
ipf_checkv4sum(fin);
}
static inline void
ipf_pr_esp(fr_info_t *fin)
{
if (fin->fin_off == 0) {
ipf_pr_short(fin, 8);
if (ipf_pr_pullup(fin, 8) == -1) {
ipf_main_softc_t *softc = fin->fin_main_soft;
LBUMPD(ipf_stats[fin->fin_out], fr_v4_esp_pullup);
}
}
}
static inline int
ipf_pr_ah(fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
authhdr_t *ah;
int len;
fin->fin_flx |= FI_AH;
ipf_pr_short(fin, sizeof(*ah));
if (((fin->fin_flx & FI_SHORT) != 0) || (fin->fin_off != 0)) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_ah_bad);
return (IPPROTO_NONE);
}
if (ipf_pr_pullup(fin, sizeof(*ah)) == -1) {
DT(fr_v4_ah_pullup_1);
LBUMP(ipf_stats[fin->fin_out].fr_v4_ah_pullup);
return (IPPROTO_NONE);
}
ah = (authhdr_t *)fin->fin_dp;
len = (ah->ah_plen + 2) << 2;
ipf_pr_short(fin, len);
if (ipf_pr_pullup(fin, len) == -1) {
DT(fr_v4_ah_pullup_2);
LBUMP(ipf_stats[fin->fin_out].fr_v4_ah_pullup);
return (IPPROTO_NONE);
}
fin->fin_dp = (char *)fin->fin_dp + len;
fin->fin_dlen -= len;
return (ah->ah_next);
}
static inline void
ipf_pr_gre(fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
grehdr_t *gre;
ipf_pr_short(fin, sizeof(grehdr_t));
if (fin->fin_off != 0) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_gre_frag);
return;
}
if (ipf_pr_pullup(fin, sizeof(grehdr_t)) == -1) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_gre_pullup);
return;
}
gre = fin->fin_dp;
if (GRE_REV(gre->gr_flags) == 1)
fin->fin_data[0] = gre->gr_call;
}
static inline void
ipf_pr_ipv4hdr(fr_info_t *fin)
{
u_short optmsk = 0, secmsk = 0, auth = 0;
int hlen, ol, mv, p, i;
const struct optlist *op;
u_char *s, opt;
u_short off;
fr_ip_t *fi;
ip_t *ip;
fi = &fin->fin_fi;
hlen = fin->fin_hlen;
ip = fin->fin_ip;
p = ip->ip_p;
fi->fi_p = p;
fin->fin_crc = p;
fi->fi_tos = ip->ip_tos;
fin->fin_id = ntohs(ip->ip_id);
off = ntohs(ip->ip_off);
fi->fi_p = ip->ip_p;
fi->fi_ttl = ip->ip_ttl;
fi->fi_src.i6[1] = 0;
fi->fi_src.i6[2] = 0;
fi->fi_src.i6[3] = 0;
fi->fi_dst.i6[1] = 0;
fi->fi_dst.i6[2] = 0;
fi->fi_dst.i6[3] = 0;
fi->fi_saddr = ip->ip_src.s_addr;
fin->fin_crc += fi->fi_saddr;
fi->fi_daddr = ip->ip_dst.s_addr;
fin->fin_crc += fi->fi_daddr;
if (IN_MULTICAST(ntohl(fi->fi_daddr)))
fin->fin_flx |= FI_MULTICAST|FI_MBCAST;
off &= IP_MF|IP_OFFMASK;
if (off != 0) {
int morefrag = off & IP_MF;
fi->fi_flx |= FI_FRAG;
off &= IP_OFFMASK;
if (off == 1 && p == IPPROTO_TCP) {
fin->fin_flx |= FI_SHORT;
DT1(ipf_fi_tcp_frag_off_1, fr_info_t *, fin);
}
if (off != 0) {
fin->fin_flx |= FI_FRAGBODY;
off <<= 3;
if ((off + fin->fin_dlen > 65535) ||
(fin->fin_dlen == 0) ||
((morefrag != 0) && ((fin->fin_dlen & 7) != 0))) {
fi->fi_flx |= FI_BAD;
DT1(ipf_fi_bad_fragbody_gt_65535, fr_info_t *, fin);
}
}
}
fin->fin_off = off;
if (p == IPPROTO_AH) {
p = ipf_pr_ah(fin);
}
switch (p)
{
case IPPROTO_UDP :
ipf_pr_udp(fin);
break;
case IPPROTO_TCP :
ipf_pr_tcp(fin);
break;
case IPPROTO_ICMP :
ipf_pr_icmp(fin);
break;
case IPPROTO_ESP :
ipf_pr_esp(fin);
break;
case IPPROTO_GRE :
ipf_pr_gre(fin);
break;
}
ip = fin->fin_ip;
if (ip == NULL)
return;
if (hlen == sizeof(*ip)) {
fi->fi_optmsk = 0;
fi->fi_secmsk = 0;
fi->fi_auth = 0;
return;
}
fi->fi_flx |= FI_OPTIONS;
for (s = (u_char *)(ip + 1), hlen -= (int)sizeof(*ip); hlen > 0; ) {
opt = *s;
if (opt == '\0')
break;
else if (opt == IPOPT_NOP)
ol = 1;
else {
if (hlen < 2)
break;
ol = (int)*(s + 1);
if (ol < 2 || ol > hlen)
break;
}
for (i = 9, mv = 4; mv >= 0; ) {
op = ipopts + i;
if ((opt == (u_char)op->ol_val) && (ol > 4)) {
u_32_t doi;
switch (opt)
{
case IPOPT_SECURITY :
if (optmsk & op->ol_bit) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_ipopt_security, fr_info_t *, fin, u_short, (optmsk & op->ol_bit));
} else {
doi = ipf_checkripso(s);
secmsk = doi >> 16;
auth = doi & 0xffff;
}
break;
case IPOPT_CIPSO :
if (optmsk & op->ol_bit) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_ipopt_cipso, fr_info_t *, fin, u_short, (optmsk & op->ol_bit));
} else {
doi = ipf_checkcipso(fin,
s, ol);
secmsk = doi >> 16;
auth = doi & 0xffff;
}
break;
}
optmsk |= op->ol_bit;
}
if (opt < op->ol_val)
i -= mv;
else
i += mv;
mv--;
}
hlen -= ol;
s += ol;
}
if (auth && !(auth & 0x0100))
auth &= 0xff00;
fi->fi_optmsk = optmsk;
fi->fi_secmsk = secmsk;
fi->fi_auth = auth;
}
static u_32_t
ipf_checkripso(u_char *s)
{
const struct optlist *sp;
u_short secmsk = 0, auth = 0;
u_char sec;
int j, m;
sec = *(s + 2);
for (j = 3, m = 2; m >= 0; ) {
sp = secopt + j;
if (sec == sp->ol_val) {
secmsk |= sp->ol_bit;
auth = *(s + 3);
auth *= 256;
auth += *(s + 4);
break;
}
if (sec < sp->ol_val)
j -= m;
else
j += m;
m--;
}
return (secmsk << 16) | auth;
}
static u_32_t
ipf_checkcipso(fr_info_t *fin, u_char *s, int ol)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
fr_ip_t *fi;
u_32_t doi;
u_char *t, tag, tlen, sensitivity;
int len;
if (ol < 6 || ol > 40) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_cipso_bad);
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_ol, fr_info_t *, fin, u_int, ol);
return (0);
}
fi = &fin->fin_fi;
fi->fi_sensitivity = 0;
bcopy(s + 2, &doi, sizeof(doi));
t = (u_char *)s + 6;
for (len = ol - 6; len >= 2; len -= tlen, t+= tlen) {
tag = *t;
tlen = *(t + 1);
if (tlen > len || tlen < 4 || tlen > 34) {
LBUMPD(ipf_stats[fin->fin_out], fr_v4_cipso_tlen);
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_tlen, fr_info_t *, fin, u_int, tlen);
return (0);
}
sensitivity = 0;
if (tag == 0) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_tag, fr_info_t *, fin, u_int, tag);
continue;
} else if (tag == 1) {
if (*(t + 2) != 0) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_tag1_t2, fr_info_t *, fin, u_int, (*t + 2));
continue;
}
sensitivity = *(t + 3);
} else if (tag == 4) {
if (*(t + 2) != 0) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_tag4_t2, fr_info_t *, fin, u_int, (*t + 2));
continue;
}
sensitivity = *(t + 3);
} else if (tag == 5) {
if (*(t + 2) != 0) {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_tag5_t2, fr_info_t *, fin, u_int, (*t + 2));
continue;
}
sensitivity = *(t + 3);
} else if (tag > 127) {
;
} else {
fin->fin_flx |= FI_BAD;
DT2(ipf_fi_bad_checkcipso_tag127, fr_info_t *, fin, u_int, tag);
continue;
}
if (sensitivity > fi->fi_sensitivity)
fi->fi_sensitivity = sensitivity;
}
return (doi);
}
int
ipf_makefrip(int hlen, ip_t *ip, fr_info_t *fin)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
int v;
fin->fin_depth = 0;
fin->fin_hlen = (u_short)hlen;
fin->fin_ip = ip;
fin->fin_rule = 0xffffffff;
fin->fin_group[0] = -1;
fin->fin_group[1] = '\0';
fin->fin_dp = (char *)ip + hlen;
v = fin->fin_v;
if (v == 4) {
fin->fin_plen = ntohs(ip->ip_len);
fin->fin_dlen = fin->fin_plen - hlen;
ipf_pr_ipv4hdr(fin);
#ifdef USE_INET6
} else if (v == 6) {
fin->fin_plen = ntohs(((ip6_t *)ip)->ip6_plen);
fin->fin_dlen = fin->fin_plen;
fin->fin_plen += hlen;
ipf_pr_ipv6hdr(fin);
#endif
}
if (fin->fin_ip == NULL) {
LBUMP(ipf_stats[fin->fin_out].fr_ip_freed);
return (-1);
}
return (0);
}
static inline int
ipf_portcheck(frpcmp_t *frp, u_32_t pop)
{
int err = 1;
u_32_t po;
po = frp->frp_port;
switch (frp->frp_cmp)
{
case FR_EQUAL :
if (pop != po)
err = 0;
break;
case FR_NEQUAL :
if (pop == po)
err = 0;
break;
case FR_LESST :
if (pop >= po)
err = 0;
break;
case FR_GREATERT :
if (pop <= po)
err = 0;
break;
case FR_LESSTE :
if (pop > po)
err = 0;
break;
case FR_GREATERTE :
if (pop < po)
err = 0;
break;
case FR_OUTRANGE :
if (pop >= po && pop <= frp->frp_top)
err = 0;
break;
case FR_INRANGE :
if (pop <= po || pop >= frp->frp_top)
err = 0;
break;
case FR_INCRANGE :
if (pop < po || pop > frp->frp_top)
err = 0;
break;
default :
break;
}
return (err);
}
int
ipf_tcpudpchk(fr_ip_t *fi, frtuc_t *ft)
{
int err = 1;
if (ft->ftu_dcmp)
err = ipf_portcheck(&ft->ftu_dst, fi->fi_ports[1]);
if (err && ft->ftu_scmp)
err = ipf_portcheck(&ft->ftu_src, fi->fi_ports[0]);
if (err && (fi->fi_p == IPPROTO_TCP)) {
if (fi->fi_flx & FI_SHORT)
return (!(ft->ftu_tcpf | ft->ftu_tcpfm));
if (ft->ftu_tcpfm &&
ft->ftu_tcpf != (fi->fi_tcpf & ft->ftu_tcpfm)) {
FR_DEBUG(("f. %#x & %#x != %#x\n", fi->fi_tcpf,
ft->ftu_tcpfm, ft->ftu_tcpf));
err = 0;
}
}
return (err);
}
static inline int
ipf_check_ipf(fr_info_t *fin, frentry_t *fr, int portcmp)
{
u_32_t *ld, *lm, *lip;
fripf_t *fri;
fr_ip_t *fi;
int i;
fi = &fin->fin_fi;
fri = fr->fr_ipf;
lip = (u_32_t *)fi;
lm = (u_32_t *)&fri->fri_mip;
ld = (u_32_t *)&fri->fri_ip;
i = ((*lip & *lm) != *ld);
FR_DEBUG(("0. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
if (i)
return (1);
lip++, lm++, ld++;
i = ((*lip & *lm) != *ld);
FR_DEBUG(("1. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
if (i != 0)
return (1);
lip++, lm++, ld++;
if (fr->fr_satype == FRI_LOOKUP) {
i = (*fr->fr_srcfunc)(fin->fin_main_soft, fr->fr_srcptr,
fi->fi_v, lip, fin->fin_plen);
if (i == -1)
return (1);
lip += 3;
lm += 3;
ld += 3;
} else {
i = ((*lip & *lm) != *ld);
FR_DEBUG(("2a. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
if (fi->fi_v == 6) {
lip++, lm++, ld++;
i |= ((*lip & *lm) != *ld);
FR_DEBUG(("2b. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
lip++, lm++, ld++;
i |= ((*lip & *lm) != *ld);
FR_DEBUG(("2c. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
lip++, lm++, ld++;
i |= ((*lip & *lm) != *ld);
FR_DEBUG(("2d. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
} else {
lip += 3;
lm += 3;
ld += 3;
}
}
i ^= (fr->fr_flags & FR_NOTSRCIP) >> 6;
if (i != 0)
return (1);
lip++, lm++, ld++;
if (fr->fr_datype == FRI_LOOKUP) {
i = (*fr->fr_dstfunc)(fin->fin_main_soft, fr->fr_dstptr,
fi->fi_v, lip, fin->fin_plen);
if (i == -1)
return (1);
lip += 3;
lm += 3;
ld += 3;
} else {
i = ((*lip & *lm) != *ld);
FR_DEBUG(("3a. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
if (fi->fi_v == 6) {
lip++, lm++, ld++;
i |= ((*lip & *lm) != *ld);
FR_DEBUG(("3b. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
lip++, lm++, ld++;
i |= ((*lip & *lm) != *ld);
FR_DEBUG(("3c. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
lip++, lm++, ld++;
i |= ((*lip & *lm) != *ld);
FR_DEBUG(("3d. %#08x & %#08x != %#08x\n",
ntohl(*lip), ntohl(*lm), ntohl(*ld)));
} else {
lip += 3;
lm += 3;
ld += 3;
}
}
i ^= (fr->fr_flags & FR_NOTDSTIP) >> 7;
if (i != 0)
return (1);
lip++, lm++, ld++;
i = (*ld - (*lip & *lm));
FR_DEBUG(("4. %#08x & %#08x != %#08x\n", *lip, *lm, *ld));
lip++, lm++, ld++;
i |= (*ld - (*lip & *lm));
FR_DEBUG(("5. %#08x & %#08x != %#08x\n", *lip, *lm, *ld));
if (i == 0) {
if (portcmp) {
if (!ipf_tcpudpchk(&fin->fin_fi, &fr->fr_tuc))
i = 1;
} else {
if (fr->fr_dcmp || fr->fr_scmp ||
fr->fr_tcpf || fr->fr_tcpfm)
i = 1;
if (fr->fr_icmpm || fr->fr_icmp) {
if (((fi->fi_p != IPPROTO_ICMP) &&
(fi->fi_p != IPPROTO_ICMPV6)) ||
fin->fin_off || (fin->fin_dlen < 2))
i = 1;
else if ((fin->fin_data[0] & fr->fr_icmpm) !=
fr->fr_icmp) {
FR_DEBUG(("i. %#x & %#x != %#x\n",
fin->fin_data[0],
fr->fr_icmpm, fr->fr_icmp));
i = 1;
}
}
}
}
return (i);
}
int
ipf_scanlist(fr_info_t *fin, u_32_t pass)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
int rulen, portcmp, off, skip;
struct frentry *fr, *fnext;
u_32_t passt, passo;
if (fin->fin_depth >= 16)
return (pass);
fr = fin->fin_fr;
if (fr == NULL)
return (pass);
skip = 0;
portcmp = 0;
fin->fin_depth++;
fin->fin_fr = NULL;
off = fin->fin_off;
if ((fin->fin_flx & FI_TCPUDP) && (fin->fin_dlen > 3) && !off)
portcmp = 1;
for (rulen = 0; fr; fr = fnext, rulen++) {
fnext = fr->fr_next;
if (skip != 0) {
FR_VERBOSE(("SKIP %d (%#x)\n", skip, fr->fr_flags));
skip--;
continue;
}
#ifdef _KERNEL
if (fr->fr_ifa && fr->fr_ifa != fin->fin_ifp)
continue;
#else
if (opts & (OPT_VERBOSE|OPT_DEBUG))
printf("\n");
FR_VERBOSE(("%c", FR_ISSKIP(pass) ? 's' :
FR_ISPASS(pass) ? 'p' :
FR_ISACCOUNT(pass) ? 'A' :
FR_ISAUTH(pass) ? 'a' :
(pass & FR_NOMATCH) ? 'n' :'b'));
if (fr->fr_ifa && fr->fr_ifa != fin->fin_ifp)
continue;
FR_VERBOSE((":i"));
#endif
switch (fr->fr_type)
{
case FR_T_IPF :
case FR_T_IPF_BUILTIN :
if (ipf_check_ipf(fin, fr, portcmp))
continue;
break;
#if defined(IPFILTER_BPF)
case FR_T_BPFOPC :
case FR_T_BPFOPC_BUILTIN :
{
u_char *mc;
int wlen;
if (*fin->fin_mp == NULL)
continue;
if (fin->fin_family != fr->fr_family)
continue;
mc = (u_char *)fin->fin_m;
wlen = fin->fin_dlen + fin->fin_hlen;
if (!bpf_filter(fr->fr_data, mc, wlen, 0))
continue;
break;
}
#endif
case FR_T_CALLFUNC_BUILTIN :
{
frentry_t *f;
f = (*fr->fr_func)(fin, &pass);
if (f != NULL)
fr = f;
else
continue;
break;
}
case FR_T_IPFEXPR :
case FR_T_IPFEXPR_BUILTIN :
if (fin->fin_family != fr->fr_family)
continue;
if (ipf_fr_matcharray(fin, fr->fr_data) == 0)
continue;
break;
default :
break;
}
if ((fin->fin_out == 0) && (fr->fr_nattag.ipt_num[0] != 0)) {
if (fin->fin_nattag == NULL)
continue;
if (ipf_matchtag(&fr->fr_nattag, fin->fin_nattag) == 0)
continue;
}
FR_VERBOSE(("=%d/%d.%d *", fr->fr_grhead, fr->fr_group, rulen));
passt = fr->fr_flags;
if ((passt & FR_CALLNOW) != 0) {
frentry_t *frs;
ATOMIC_INC64(fr->fr_hits);
if ((fr->fr_func == NULL) ||
(fr->fr_func == (ipfunc_t)-1))
continue;
frs = fin->fin_fr;
fin->fin_fr = fr;
fr = (*fr->fr_func)(fin, &passt);
if (fr == NULL) {
fin->fin_fr = frs;
continue;
}
passt = fr->fr_flags;
}
fin->fin_fr = fr;
#ifdef IPFILTER_LOG
if ((passt & FR_LOGMASK) == FR_LOG) {
if (ipf_log_pkt(fin, passt) == -1) {
if (passt & FR_LOGORBLOCK) {
DT(frb_logfail);
passt &= ~FR_CMDMASK;
passt |= FR_BLOCK|FR_QUICK;
fin->fin_reason = FRB_LOGFAIL;
}
}
}
#endif
MUTEX_ENTER(&fr->fr_lock);
fr->fr_bytes += (U_QUAD_T)fin->fin_plen;
fr->fr_hits++;
MUTEX_EXIT(&fr->fr_lock);
fin->fin_rule = rulen;
passo = pass;
if (FR_ISSKIP(passt)) {
skip = fr->fr_arg;
continue;
} else if (((passt & FR_LOGMASK) != FR_LOG) &&
((passt & FR_LOGMASK) != FR_DECAPSULATE)) {
pass = passt;
}
if (passt & (FR_RETICMP|FR_FAKEICMP))
fin->fin_icode = fr->fr_icode;
if (fr->fr_group != -1) {
(void) strncpy(fin->fin_group,
FR_NAME(fr, fr_group),
strlen(FR_NAME(fr, fr_group)));
} else {
fin->fin_group[0] = '\0';
}
FR_DEBUG(("pass %#x/%#x/%x\n", passo, pass, passt));
if (fr->fr_grphead != NULL) {
fin->fin_fr = fr->fr_grphead->fg_start;
FR_VERBOSE(("group %s\n", FR_NAME(fr, fr_grhead)));
if (FR_ISDECAPS(passt))
passt = ipf_decaps(fin, pass, fr->fr_icode);
else
passt = ipf_scanlist(fin, pass);
if (fin->fin_fr == NULL) {
fin->fin_rule = rulen;
if (fr->fr_group != -1)
(void) strncpy(fin->fin_group,
fr->fr_names +
fr->fr_group,
strlen(fr->fr_names +
fr->fr_group));
fin->fin_fr = fr;
passt = pass;
}
pass = passt;
}
if (pass & FR_QUICK) {
if ((pass & FR_KEEPSTATE) && !FR_ISAUTH(pass) &&
!(fin->fin_flx & FI_STATE)) {
int out = fin->fin_out;
fin->fin_fr = fr;
if (ipf_state_add(softc, fin, NULL, 0) == 0) {
LBUMPD(ipf_stats[out], fr_ads);
} else {
LBUMPD(ipf_stats[out], fr_bads);
pass = passo;
continue;
}
}
break;
}
}
fin->fin_depth--;
return (pass);
}
frentry_t *
ipf_acctpkt(fr_info_t *fin, u_32_t *passp __unused)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
char group[FR_GROUPLEN];
frentry_t *fr, *frsave;
u_32_t pass, rulen;
fr = softc->ipf_acct[fin->fin_out][softc->ipf_active];
if (fr != NULL) {
frsave = fin->fin_fr;
bcopy(fin->fin_group, group, FR_GROUPLEN);
rulen = fin->fin_rule;
fin->fin_fr = fr;
pass = ipf_scanlist(fin, FR_NOMATCH);
if (FR_ISACCOUNT(pass)) {
LBUMPD(ipf_stats[0], fr_acct);
}
fin->fin_fr = frsave;
bcopy(group, fin->fin_group, FR_GROUPLEN);
fin->fin_rule = rulen;
}
return (NULL);
}
static frentry_t *
ipf_firewall(fr_info_t *fin, u_32_t *passp)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
frentry_t *fr;
u_32_t pass;
int out;
out = fin->fin_out;
pass = *passp;
fin->fin_fr = softc->ipf_rules[out][softc->ipf_active];
if (fin->fin_fr != NULL)
pass = ipf_scanlist(fin, softc->ipf_pass);
if ((pass & FR_NOMATCH)) {
LBUMPD(ipf_stats[out], fr_nom);
}
fr = fin->fin_fr;
if ((fr != NULL) && (fr->fr_pps != 0) &&
!ppsratecheck(&fr->fr_lastpkt, &fr->fr_curpps, fr->fr_pps)) {
DT2(frb_ppsrate, fr_info_t *, fin, frentry_t *, fr);
pass &= ~(FR_CMDMASK|FR_RETICMP|FR_RETRST);
pass |= FR_BLOCK;
LBUMPD(ipf_stats[out], fr_ppshit);
fin->fin_reason = FRB_PPSRATE;
}
if (FR_ISAUTH(pass)) {
if (ipf_auth_new(fin->fin_m, fin) != 0) {
DT1(frb_authnew, fr_info_t *, fin);
fin->fin_m = *fin->fin_mp = NULL;
fin->fin_reason = FRB_AUTHNEW;
fin->fin_error = 0;
} else {
IPFERROR(1);
fin->fin_error = ENOSPC;
}
}
if ((fr != NULL) && (fr->fr_func != NULL) &&
(fr->fr_func != (ipfunc_t)-1) && !(pass & FR_CALLNOW))
(void) (*fr->fr_func)(fin, &pass);
if (FR_ISPREAUTH(pass)) {
pass = ipf_auth_pre_scanlist(softc, fin, pass);
}
if (pass & FR_KEEPFRAG) {
if (fin->fin_flx & FI_FRAG) {
if (ipf_frag_new(softc, fin, pass) == -1) {
LBUMP(ipf_stats[out].fr_bnfr);
} else {
LBUMP(ipf_stats[out].fr_nfr);
}
} else {
LBUMP(ipf_stats[out].fr_cfr);
}
}
fr = fin->fin_fr;
*passp = pass;
return (fr);
}
int
ipf_check(void *ctx, ip_t *ip, int hlen, struct ifnet *ifp, int out
#if defined(_KERNEL) && SOLARIS
, void* qif, mb_t **mp)
#else
, mb_t **mp)
#endif
{
ipf_main_softc_t *softc = ctx;
fr_info_t frinfo;
fr_info_t *fin = &frinfo;
u_32_t pass = softc->ipf_pass;
frentry_t *fr = NULL;
int v = IP_V(ip);
mb_t *mc = NULL;
mb_t *m;
#ifdef _KERNEL
# if SOLARIS
qpktinfo_t *qpi = qif;
# ifdef __sparc
if ((u_int)ip & 0x3)
return (2);
# endif
# else
SPL_INT(s);
# endif
if (softc->ipf_running <= 0) {
return (0);
}
bzero((char *)fin, sizeof(*fin));
# if SOLARIS
if (qpi->qpi_flags & QF_BROADCAST)
fin->fin_flx |= FI_MBCAST|FI_BROADCAST;
if (qpi->qpi_flags & QF_MULTICAST)
fin->fin_flx |= FI_MBCAST|FI_MULTICAST;
m = qpi->qpi_m;
fin->fin_qfm = m;
fin->fin_qpi = qpi;
# else
m = *mp;
# if defined(M_MCAST)
if ((m->m_flags & M_MCAST) != 0)
fin->fin_flx |= FI_MBCAST|FI_MULTICAST;
# endif
# if defined(M_MLOOP)
if ((m->m_flags & M_MLOOP) != 0)
fin->fin_flx |= FI_MBCAST|FI_MULTICAST;
# endif
# if defined(M_BCAST)
if ((m->m_flags & M_BCAST) != 0)
fin->fin_flx |= FI_MBCAST|FI_BROADCAST;
# endif
# ifdef M_CANFASTFWD
m->m_flags &= ~M_CANFASTFWD;
# endif
# if defined(CSUM_DELAY_DATA) && !defined(__FreeBSD__)
if (m->m_pkthdr.csum_flags & CSUM_DELAY_DATA) {
in_delayed_cksum(m);
m->m_pkthdr.csum_flags &= ~CSUM_DELAY_DATA;
}
# endif
# endif
#else
bzero((char *)fin, sizeof(*fin));
m = *mp;
# if defined(M_MCAST)
if ((m->m_flags & M_MCAST) != 0)
fin->fin_flx |= FI_MBCAST|FI_MULTICAST;
# endif
# if defined(M_MLOOP)
if ((m->m_flags & M_MLOOP) != 0)
fin->fin_flx |= FI_MBCAST|FI_MULTICAST;
# endif
# if defined(M_BCAST)
if ((m->m_flags & M_BCAST) != 0)
fin->fin_flx |= FI_MBCAST|FI_BROADCAST;
# endif
#endif
fin->fin_v = v;
fin->fin_m = m;
fin->fin_ip = ip;
fin->fin_mp = mp;
fin->fin_out = out;
fin->fin_ifp = ifp;
fin->fin_error = ENETUNREACH;
fin->fin_hlen = (u_short)hlen;
fin->fin_dp = (char *)ip + hlen;
fin->fin_main_soft = softc;
fin->fin_ipoff = (char *)ip - MTOD(m, char *);
SPL_NET(s);
#ifdef USE_INET6
if (v == 6) {
LBUMP(ipf_stats[out].fr_ipv6);
if (((ip6_t *)ip)->ip6_plen == 0) {
DT1(frb_jumbo, ip6_t *, (ip6_t *)ip);
pass = FR_BLOCK|FR_NOMATCH;
fin->fin_reason = FRB_JUMBO;
goto finished;
}
fin->fin_family = AF_INET6;
} else
#endif
{
fin->fin_family = AF_INET;
}
if (ipf_makefrip(hlen, ip, fin) == -1) {
DT1(frb_makefrip, fr_info_t *, fin);
pass = FR_BLOCK|FR_NOMATCH;
fin->fin_reason = FRB_MAKEFRIP;
goto finished;
}
if (*fin->fin_mp == NULL)
goto finished;
if (!out) {
if (v == 4) {
if (softc->ipf_chksrc && !ipf_verifysrc(fin)) {
LBUMPD(ipf_stats[0], fr_v4_badsrc);
fin->fin_flx |= FI_BADSRC;
}
if (fin->fin_ip->ip_ttl < softc->ipf_minttl) {
LBUMPD(ipf_stats[0], fr_v4_badttl);
fin->fin_flx |= FI_LOWTTL;
}
}
#ifdef USE_INET6
else if (v == 6) {
if (((ip6_t *)ip)->ip6_hlim < softc->ipf_minttl) {
LBUMPD(ipf_stats[0], fr_v6_badttl);
fin->fin_flx |= FI_LOWTTL;
}
}
#endif
}
if (fin->fin_flx & FI_SHORT) {
LBUMPD(ipf_stats[out], fr_short);
}
READ_ENTER(&softc->ipf_mutex);
if (!out) {
switch (fin->fin_v)
{
case 4 :
if (ipf_nat_checkin(fin, &pass) == -1) {
goto filterdone;
}
break;
#ifdef USE_INET6
case 6 :
if (ipf_nat6_checkin(fin, &pass) == -1) {
goto filterdone;
}
break;
#endif
default :
break;
}
}
fr = ipf_auth_check(fin, &pass);
if (!out && (fr == NULL))
(void) ipf_acctpkt(fin, NULL);
if (fr == NULL) {
if ((fin->fin_flx & FI_FRAG) != 0)
fr = ipf_frag_known(fin, &pass);
if (fr == NULL)
fr = ipf_state_check(fin, &pass);
}
if ((pass & FR_NOMATCH) || (fr == NULL))
fr = ipf_firewall(fin, &pass);
if ((pass & FR_KEEPSTATE) && (fin->fin_m != NULL) &&
!(fin->fin_flx & FI_STATE)) {
if (ipf_state_add(softc, fin, NULL, 0) == 0) {
LBUMP(ipf_stats[out].fr_ads);
} else {
LBUMP(ipf_stats[out].fr_bads);
if (FR_ISPASS(pass)) {
DT(frb_stateadd);
pass &= ~FR_CMDMASK;
pass |= FR_BLOCK;
fin->fin_reason = FRB_STATEADD;
}
}
}
fin->fin_fr = fr;
if ((fr != NULL) && !(fin->fin_flx & FI_STATE)) {
fin->fin_dif = &fr->fr_dif;
fin->fin_tif = &fr->fr_tifs[fin->fin_rev];
}
if (out && FR_ISPASS(pass)) {
(void) ipf_acctpkt(fin, NULL);
switch (fin->fin_v)
{
case 4 :
if (ipf_nat_checkout(fin, &pass) == -1) {
;
} else if ((softc->ipf_update_ipid != 0) && (v == 4)) {
if (ipf_updateipid(fin) == -1) {
DT(frb_updateipid);
LBUMP(ipf_stats[1].fr_ipud);
pass &= ~FR_CMDMASK;
pass |= FR_BLOCK;
fin->fin_reason = FRB_UPDATEIPID;
} else {
LBUMP(ipf_stats[0].fr_ipud);
}
}
break;
#ifdef USE_INET6
case 6 :
(void) ipf_nat6_checkout(fin, &pass);
break;
#endif
default :
break;
}
}
filterdone:
#ifdef IPFILTER_LOG
if ((softc->ipf_flags & FF_LOGGING) || (pass & FR_LOGMASK)) {
(void) ipf_dolog(fin, &pass);
}
#endif
fin->fin_flx &= ~FI_STATE;
#if defined(FASTROUTE_RECURSION)
if (fr != NULL) {
MUTEX_ENTER(&fr->fr_lock);
fr->fr_ref++;
MUTEX_EXIT(&fr->fr_lock);
}
RWLOCK_EXIT(&softc->ipf_mutex);
#endif
if ((pass & FR_RETMASK) != 0) {
if (!out) {
if (pass & FR_RETICMP) {
int dst;
if ((pass & FR_RETMASK) == FR_FAKEICMP)
dst = 1;
else
dst = 0;
(void) ipf_send_icmp_err(ICMP_UNREACH, fin,
dst);
LBUMP(ipf_stats[0].fr_ret);
} else if (((pass & FR_RETMASK) == FR_RETRST) &&
!(fin->fin_flx & FI_SHORT)) {
if (((fin->fin_flx & FI_OOW) != 0) ||
(ipf_send_reset(fin) == 0)) {
LBUMP(ipf_stats[1].fr_ret);
}
}
if (FR_ISAUTH(pass) && (fin->fin_m != NULL)) {
DT1(frb_authcapture, fr_info_t *, fin);
fin->fin_m = *fin->fin_mp = NULL;
fin->fin_reason = FRB_AUTHCAPTURE;
m = NULL;
}
} else {
if (pass & FR_RETRST) {
fin->fin_error = ECONNRESET;
}
}
}
if (FR_ISBLOCK(pass) && (fin->fin_flx & FI_NEWNAT))
ipf_nat_uncreate(fin);
if (fr != NULL) {
frdest_t *fdp;
fdp = fin->fin_dif;
if ((fdp != NULL) && (fdp->fd_ptr != NULL) &&
(fdp->fd_ptr != (void *)-1)) {
mc = M_COPY(fin->fin_m);
if (mc != NULL)
ipf_fastroute(mc, &mc, fin, fdp);
}
fdp = fin->fin_tif;
if (!out && (pass & FR_FASTROUTE)) {
(void) ipf_fastroute(fin->fin_m, mp, fin, NULL);
m = *mp = NULL;
} else if ((fdp != NULL) && (fdp->fd_ptr != NULL) &&
(fdp->fd_ptr != (struct ifnet *)-1)) {
ipf_fastroute(fin->fin_m, mp, fin, fdp);
m = *mp = NULL;
}
#if defined(FASTROUTE_RECURSION)
(void) ipf_derefrule(softc, &fr);
#endif
}
#if !defined(FASTROUTE_RECURSION)
RWLOCK_EXIT(&softc->ipf_mutex);
#endif
finished:
if (!FR_ISPASS(pass)) {
LBUMP(ipf_stats[out].fr_block);
if (*mp != NULL) {
#ifdef _KERNEL
FREE_MB_T(*mp);
#endif
m = *mp = NULL;
}
} else {
LBUMP(ipf_stats[out].fr_pass);
}
SPL_X(s);
if (fin->fin_m == NULL && fin->fin_flx & FI_BAD &&
fin->fin_reason == FRB_PULLUP) {
LBUMP(ipf_stats[out].fr_blocked[fin->fin_reason]);
return (-1);
}
#ifdef _KERNEL
if (FR_ISPASS(pass))
return (0);
LBUMP(ipf_stats[out].fr_blocked[fin->fin_reason]);
return (fin->fin_error);
#else
if (*mp != NULL)
(*mp)->mb_ifp = fin->fin_ifp;
blockreason = fin->fin_reason;
FR_VERBOSE(("fin_flx %#x pass %#x ", fin->fin_flx, pass));
if ((pass & FR_NOMATCH) != 0)
return (1);
if ((pass & FR_RETMASK) != 0)
switch (pass & FR_RETMASK)
{
case FR_RETRST :
return (3);
case FR_RETICMP :
return (4);
case FR_FAKEICMP :
return (5);
}
switch (pass & FR_CMDMASK)
{
case FR_PASS :
return (0);
case FR_BLOCK :
return (-1);
case FR_AUTH :
return (-2);
case FR_ACCOUNT :
return (-3);
case FR_PREAUTH :
return (-4);
}
return (2);
#endif
}
#ifdef IPFILTER_LOG
frentry_t *
ipf_dolog(fr_info_t *fin, u_32_t *passp)
{
ipf_main_softc_t *softc = fin->fin_main_soft;
u_32_t pass;
int out;
out = fin->fin_out;
pass = *passp;
if ((softc->ipf_flags & FF_LOGNOMATCH) && (pass & FR_NOMATCH)) {
pass |= FF_LOGNOMATCH;
LBUMPD(ipf_stats[out], fr_npkl);
goto logit;
} else if (((pass & FR_LOGMASK) == FR_LOGP) ||
(FR_ISPASS(pass) && (softc->ipf_flags & FF_LOGPASS))) {
if ((pass & FR_LOGMASK) != FR_LOGP)
pass |= FF_LOGPASS;
LBUMPD(ipf_stats[out], fr_ppkl);
goto logit;
} else if (((pass & FR_LOGMASK) == FR_LOGB) ||
(FR_ISBLOCK(pass) && (softc->ipf_flags & FF_LOGBLOCK))) {
if ((pass & FR_LOGMASK) != FR_LOGB)
pass |= FF_LOGBLOCK;
LBUMPD(ipf_stats[out], fr_bpkl);
logit:
if (ipf_log_pkt(fin, pass) == -1) {
if ((pass & FR_LOGORBLOCK) && FR_ISPASS(pass)) {
DT1(frb_logfail2, u_int, pass);
pass &= ~FR_CMDMASK;
pass |= FR_BLOCK;
fin->fin_reason = FRB_LOGFAIL2;
}
}
*passp = pass;
}
return (fin->fin_fr);
}
#endif
u_short
ipf_cksum(u_short *addr, int len)
{
u_32_t sum = 0;
for (sum = 0; len > 1; len -= 2)
sum += *addr++;
if (len == 1)
sum += *(u_char *)addr;
sum = (sum >> 16) + (sum & 0xffff);
sum += (sum >> 16);
return (u_short)(~sum);
}
u_short
fr_cksum(fr_info_t *fin, ip_t *ip, int l4proto, void *l4hdr)
{
u_short *sp, slen, sumsave, *csump;
u_int sum, sum2;
int hlen;
int off;
#ifdef USE_INET6
ip6_t *ip6;
#endif
csump = NULL;
sumsave = 0;
sp = NULL;
slen = 0;
hlen = 0;
sum = 0;
sum = htons((u_short)l4proto);
#ifdef USE_INET6
if (IP_V(ip) == 4) {
#endif
hlen = IP_HL(ip) << 2;
off = hlen;
sp = (u_short *)&ip->ip_src;
sum += *sp++;
sum += *sp++;
sum += *sp++;
sum += *sp++;
slen = fin->fin_plen - off;
sum += htons(slen);
#ifdef USE_INET6
} else if (IP_V(ip) == 6) {
mb_t *m;
m = fin->fin_m;
ip6 = (ip6_t *)ip;
off = ((caddr_t)ip6 - m->m_data) + sizeof(struct ip6_hdr);
int len = ntohs(ip6->ip6_plen) - (off - sizeof(*ip6));
return (ipf_pcksum6(m, ip6, off, len));
} else {
return (0xffff);
}
#endif
switch (l4proto)
{
case IPPROTO_UDP :
csump = &((udphdr_t *)l4hdr)->uh_sum;
break;
case IPPROTO_TCP :
csump = &((tcphdr_t *)l4hdr)->th_sum;
break;
case IPPROTO_ICMP :
csump = &((icmphdr_t *)l4hdr)->icmp_cksum;
sum = 0;
break;
#ifdef USE_INET6
case IPPROTO_ICMPV6 :
csump = &((struct icmp6_hdr *)l4hdr)->icmp6_cksum;
break;
#endif
default :
break;
}
if (csump != NULL) {
sumsave = *csump;
*csump = 0;
}
sum2 = ipf_pcksum(fin, off, sum);
if (csump != NULL)
*csump = sumsave;
return (sum2);
}
frgroup_t *
ipf_findgroup(ipf_main_softc_t *softc, char *group, minor_t unit, int set,
frgroup_t ***fgpp)
{
frgroup_t *fg, **fgp;
fgp = &softc->ipf_groups[unit][set];
while ((fg = *fgp) != NULL) {
if (strncmp(group, fg->fg_name, FR_GROUPLEN) == 0)
break;
else
fgp = &fg->fg_next;
}
if (fgpp != NULL)
*fgpp = fgp;
return (fg);
}
frgroup_t *
ipf_group_add(ipf_main_softc_t *softc, char *group, void *head, u_32_t flags,
minor_t unit, int set)
{
frgroup_t *fg, **fgp;
u_32_t gflags;
if (group == NULL)
return (NULL);
if (unit == IPL_LOGIPF && *group == '\0')
return (NULL);
fgp = NULL;
gflags = flags & FR_INOUT;
fg = ipf_findgroup(softc, group, unit, set, &fgp);
if (fg != NULL) {
if (fg->fg_head == NULL && head != NULL)
fg->fg_head = head;
if (fg->fg_flags == 0)
fg->fg_flags = gflags;
else if (gflags != fg->fg_flags)
return (NULL);
fg->fg_ref++;
return (fg);
}
KMALLOC(fg, frgroup_t *);
if (fg != NULL) {
fg->fg_head = head;
fg->fg_start = NULL;
fg->fg_next = *fgp;
bcopy(group, fg->fg_name, strnlen(group, FR_GROUPLEN) + 1);
fg->fg_flags = gflags;
fg->fg_ref = 1;
fg->fg_set = &softc->ipf_groups[unit][set];
*fgp = fg;
}
return (fg);
}
void
ipf_group_del(ipf_main_softc_t *softc, frgroup_t *group, frentry_t *fr)
{
if (group->fg_head == fr)
group->fg_head = NULL;
group->fg_ref--;
if ((group->fg_ref == 0) && (group->fg_start == NULL))
ipf_group_free(group);
}
static void
ipf_group_free(frgroup_t *group)
{
frgroup_t **gp;
for (gp = group->fg_set; *gp != NULL; gp = &(*gp)->fg_next) {
if (*gp == group) {
*gp = group->fg_next;
break;
}
}
KFREE(group);
}
static int
ipf_group_flush(ipf_main_softc_t *softc, frgroup_t *group)
{
int gone = 0;
(void) ipf_flushlist(softc, &gone, &group->fg_start);
return (gone);
}
frentry_t *
ipf_getrulen(ipf_main_softc_t *softc, int unit, char *group, u_32_t n)
{
frentry_t *fr;
frgroup_t *fg;
fg = ipf_findgroup(softc, group, unit, softc->ipf_active, NULL);
if (fg == NULL)
return (NULL);
for (fr = fg->fg_start; fr && n; fr = fr->fr_next, n--)
;
if (n != 0)
return (NULL);
return (fr);
}
static int
ipf_flushlist(ipf_main_softc_t *softc, int *nfreedp, frentry_t **listp)
{
int freed = 0;
frentry_t *fp;
while ((fp = *listp) != NULL) {
if ((fp->fr_type & FR_T_BUILTIN) ||
!(fp->fr_flags & FR_COPIED)) {
listp = &fp->fr_next;
continue;
}
*listp = fp->fr_next;
if (fp->fr_next != NULL)
fp->fr_next->fr_pnext = fp->fr_pnext;
fp->fr_pnext = NULL;
if (fp->fr_grphead != NULL) {
freed += ipf_group_flush(softc, fp->fr_grphead);
fp->fr_names[fp->fr_grhead] = '\0';
}
if (fp->fr_icmpgrp != NULL) {
freed += ipf_group_flush(softc, fp->fr_icmpgrp);
fp->fr_names[fp->fr_icmphead] = '\0';
}
if (fp->fr_srctrack.ht_max_nodes)
ipf_rb_ht_flush(&fp->fr_srctrack);
fp->fr_next = NULL;
ASSERT(fp->fr_ref > 0);
if (ipf_derefrule(softc, &fp) == 0)
freed++;
}
*nfreedp += freed;
return (freed);
}
int
ipf_flush(ipf_main_softc_t *softc, minor_t unit, int flags)
{
int flushed = 0, set;
WRITE_ENTER(&softc->ipf_mutex);
set = softc->ipf_active;
if ((flags & FR_INACTIVE) == FR_INACTIVE)
set = 1 - set;
if (flags & FR_OUTQUE) {
ipf_flushlist(softc, &flushed, &softc->ipf_rules[1][set]);
ipf_flushlist(softc, &flushed, &softc->ipf_acct[1][set]);
}
if (flags & FR_INQUE) {
ipf_flushlist(softc, &flushed, &softc->ipf_rules[0][set]);
ipf_flushlist(softc, &flushed, &softc->ipf_acct[0][set]);
}
flushed += ipf_flush_groups(softc, &softc->ipf_groups[unit][set],
flags & (FR_INQUE|FR_OUTQUE));
RWLOCK_EXIT(&softc->ipf_mutex);
if (unit == IPL_LOGIPF) {
int tmp;
tmp = ipf_flush(softc, IPL_LOGCOUNT, flags);
if (tmp >= 0)
flushed += tmp;
}
return (flushed);
}
static int
ipf_flush_groups(ipf_main_softc_t *softc, frgroup_t **grhead, int flags)
{
frentry_t *fr, **frp;
frgroup_t *fg, **fgp;
int flushed = 0;
int removed = 0;
for (fgp = grhead; (fg = *fgp) != NULL; ) {
while ((fg != NULL) && ((fg->fg_flags & flags) == 0))
fg = fg->fg_next;
if (fg == NULL)
break;
removed = 0;
frp = &fg->fg_start;
while ((removed == 0) && ((fr = *frp) != NULL)) {
if ((fr->fr_flags & flags) == 0) {
frp = &fr->fr_next;
} else {
if (fr->fr_next != NULL)
fr->fr_next->fr_pnext = fr->fr_pnext;
*frp = fr->fr_next;
fr->fr_pnext = NULL;
fr->fr_next = NULL;
(void) ipf_derefrule(softc, &fr);
flushed++;
removed++;
}
}
if (removed == 0)
fgp = &fg->fg_next;
}
return (flushed);
}
char *
memstr(const char *src, char *dst, size_t slen, size_t dlen)
{
char *s = NULL;
while (dlen >= slen) {
if (bcmp(src, dst, slen) == 0) {
s = dst;
break;
}
dst++;
dlen--;
}
return (s);
}
void
ipf_fixskip(frentry_t **listp, frentry_t *rp, int addremove)
{
int rules, rn;
frentry_t *fp;
rules = 0;
for (fp = *listp; (fp != NULL) && (fp != rp); fp = fp->fr_next)
rules++;
if (fp == NULL)
return;
for (rn = 0, fp = *listp; fp && (fp != rp); fp = fp->fr_next, rn++)
if (FR_ISSKIP(fp->fr_flags) && (rn + fp->fr_arg >= rules))
fp->fr_arg += addremove;
}
#ifdef _KERNEL
int
count4bits(u_32_t ip)
{
u_32_t ipn;
int cnt = 0, i, j;
ip = ipn = ntohl(ip);
for (i = 32; i; i--, ipn *= 2)
if (ipn & 0x80000000)
cnt++;
else
break;
ipn = 0;
for (i = 32, j = cnt; i; i--, j--) {
ipn *= 2;
if (j > 0)
ipn++;
}
if (ipn == ip)
return (cnt);
return (-1);
}
# ifdef USE_INET6
int
count6bits(u_32_t *msk)
{
int i = 0, k;
u_32_t j;
for (k = 3; k >= 0; k--)
if (msk[k] == 0xffffffff)
i += 32;
else {
for (j = msk[k]; j; j <<= 1)
if (j & 0x80000000)
i++;
}
return (i);
}
# endif
#endif
static int
ipf_synclist(ipf_main_softc_t *softc, frentry_t *fr, void *ifp)
{
frentry_t *frt, *start = fr;
frdest_t *fdp;
char *name;
int error, interr;
void *ifa;
int v, i;
error = 0;
for (; fr; fr = fr->fr_next) {
if (fr->fr_family == AF_INET)
v = 4;
else if (fr->fr_family == AF_INET6)
v = 6;
else
v = 0;
for (i = 0; i < FR_NUM(fr->fr_ifas); i++) {
if ((ifp != NULL) && (fr->fr_ifas[i] != ifp))
continue;
if (fr->fr_ifnames[i] == -1)
continue;
name = FR_NAME(fr, fr_ifnames[i]);
fr->fr_ifas[i] = ipf_resolvenic(softc, name, v);
}
if ((fr->fr_type & ~FR_T_BUILTIN) == FR_T_IPF) {
if ((interr = ipf_check_names_string(fr->fr_names, fr->fr_namelen, fr->fr_sifpidx)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto unwind;
}
if (fr->fr_satype != FRI_NORMAL &&
fr->fr_satype != FRI_LOOKUP) {
ifa = ipf_resolvenic(softc, fr->fr_names +
fr->fr_sifpidx, v);
ipf_ifpaddr(softc, v, fr->fr_satype, ifa,
&fr->fr_src6, &fr->fr_smsk6);
}
if (fr->fr_datype != FRI_NORMAL &&
fr->fr_datype != FRI_LOOKUP) {
ifa = ipf_resolvenic(softc, fr->fr_names +
fr->fr_sifpidx, v);
ipf_ifpaddr(softc, v, fr->fr_datype, ifa,
&fr->fr_dst6, &fr->fr_dmsk6);
}
}
fdp = &fr->fr_tifs[0];
if ((ifp == NULL) || (fdp->fd_ptr == ifp)) {
error = ipf_resolvedest(softc, fr->fr_names, fdp, v);
if (error != 0)
goto unwind;
}
fdp = &fr->fr_tifs[1];
if ((ifp == NULL) || (fdp->fd_ptr == ifp)) {
error = ipf_resolvedest(softc, fr->fr_names, fdp, v);
if (error != 0)
goto unwind;
}
fdp = &fr->fr_dif;
if ((ifp == NULL) || (fdp->fd_ptr == ifp)) {
error = ipf_resolvedest(softc, fr->fr_names, fdp, v);
if (error != 0)
goto unwind;
}
if (((fr->fr_type & ~FR_T_BUILTIN) == FR_T_IPF) &&
(fr->fr_satype == FRI_LOOKUP) && (fr->fr_srcptr == NULL)) {
fr->fr_srcptr = ipf_lookup_res_num(softc,
fr->fr_srctype,
IPL_LOGIPF,
fr->fr_srcnum,
&fr->fr_srcfunc);
}
if (((fr->fr_type & ~FR_T_BUILTIN) == FR_T_IPF) &&
(fr->fr_datype == FRI_LOOKUP) && (fr->fr_dstptr == NULL)) {
fr->fr_dstptr = ipf_lookup_res_num(softc,
fr->fr_dsttype,
IPL_LOGIPF,
fr->fr_dstnum,
&fr->fr_dstfunc);
}
}
return (0);
unwind:
for (frt = start; frt != fr; fr = fr->fr_next) {
if (((frt->fr_type & ~FR_T_BUILTIN) == FR_T_IPF) &&
(frt->fr_satype == FRI_LOOKUP) && (frt->fr_srcptr != NULL))
ipf_lookup_deref(softc, frt->fr_srctype,
frt->fr_srcptr);
if (((frt->fr_type & ~FR_T_BUILTIN) == FR_T_IPF) &&
(frt->fr_datype == FRI_LOOKUP) && (frt->fr_dstptr != NULL))
ipf_lookup_deref(softc, frt->fr_dsttype,
frt->fr_dstptr);
}
return (error);
}
int
ipf_sync(ipf_main_softc_t *softc, void *ifp)
{
int i;
#if !SOLARIS
ipf_nat_sync(softc, ifp);
ipf_state_sync(softc, ifp);
ipf_lookup_sync(softc, ifp);
#endif
WRITE_ENTER(&softc->ipf_mutex);
(void) ipf_synclist(softc, softc->ipf_acct[0][softc->ipf_active], ifp);
(void) ipf_synclist(softc, softc->ipf_acct[1][softc->ipf_active], ifp);
(void) ipf_synclist(softc, softc->ipf_rules[0][softc->ipf_active], ifp);
(void) ipf_synclist(softc, softc->ipf_rules[1][softc->ipf_active], ifp);
for (i = 0; i < IPL_LOGSIZE; i++) {
frgroup_t *g;
for (g = softc->ipf_groups[i][0]; g != NULL; g = g->fg_next)
(void) ipf_synclist(softc, g->fg_start, ifp);
for (g = softc->ipf_groups[i][1]; g != NULL; g = g->fg_next)
(void) ipf_synclist(softc, g->fg_start, ifp);
}
RWLOCK_EXIT(&softc->ipf_mutex);
return (0);
}
int
ipf_copyin_indirect(ipf_main_softc_t *softc, void *src, void *dst, size_t size)
{
caddr_t ca;
int error;
#if SOLARIS
error = COPYIN(src, &ca, sizeof(ca));
if (error != 0)
return (error);
#else
bcopy(src, (caddr_t)&ca, sizeof(ca));
#endif
error = COPYIN(ca, dst, size);
if (error != 0) {
IPFERROR(3);
error = EFAULT;
}
return (error);
}
int
ipf_copyout_indirect(ipf_main_softc_t *softc, void *src, void *dst, size_t size)
{
caddr_t ca;
int error;
bcopy(dst, (caddr_t)&ca, sizeof(ca));
error = COPYOUT(src, ca, size);
if (error != 0) {
IPFERROR(4);
error = EFAULT;
}
return (error);
}
int
ipf_lock(caddr_t data, int *lockp)
{
int arg, err;
err = BCOPYIN(data, &arg, sizeof(arg));
if (err != 0)
return (EFAULT);
err = BCOPYOUT(lockp, data, sizeof(*lockp));
if (err != 0)
return (EFAULT);
*lockp = arg;
return (0);
}
static void
ipf_getstat(ipf_main_softc_t *softc, friostat_t *fiop, int rev)
{
int i;
bcopy((char *)softc->ipf_stats, (char *)fiop->f_st,
sizeof(ipf_statistics_t) * 2);
fiop->f_locks[IPL_LOGSTATE] = -1;
fiop->f_locks[IPL_LOGNAT] = -1;
fiop->f_locks[IPL_LOGIPF] = -1;
fiop->f_locks[IPL_LOGAUTH] = -1;
fiop->f_ipf[0][0] = softc->ipf_rules[0][0];
fiop->f_acct[0][0] = softc->ipf_acct[0][0];
fiop->f_ipf[0][1] = softc->ipf_rules[0][1];
fiop->f_acct[0][1] = softc->ipf_acct[0][1];
fiop->f_ipf[1][0] = softc->ipf_rules[1][0];
fiop->f_acct[1][0] = softc->ipf_acct[1][0];
fiop->f_ipf[1][1] = softc->ipf_rules[1][1];
fiop->f_acct[1][1] = softc->ipf_acct[1][1];
fiop->f_ticks = softc->ipf_ticks;
fiop->f_active = softc->ipf_active;
fiop->f_froute[0] = softc->ipf_frouteok[0];
fiop->f_froute[1] = softc->ipf_frouteok[1];
fiop->f_rb_no_mem = softc->ipf_rb_no_mem;
fiop->f_rb_node_max = softc->ipf_rb_node_max;
fiop->f_running = softc->ipf_running;
for (i = 0; i < IPL_LOGSIZE; i++) {
fiop->f_groups[i][0] = softc->ipf_groups[i][0];
fiop->f_groups[i][1] = softc->ipf_groups[i][1];
}
#ifdef IPFILTER_LOG
fiop->f_log_ok = ipf_log_logok(softc, IPL_LOGIPF);
fiop->f_log_fail = ipf_log_failures(softc, IPL_LOGIPF);
fiop->f_logging = 1;
#else
fiop->f_log_ok = 0;
fiop->f_log_fail = 0;
fiop->f_logging = 0;
#endif
fiop->f_defpass = softc->ipf_pass;
fiop->f_features = ipf_features;
#ifdef IPFILTER_COMPAT
snprintf(fiop->f_version, sizeof(friostat.f_version), "IP Filter: v%d.%d.%d",
(rev / 1000000) % 100,
(rev / 10000) % 100,
(rev / 100) % 100);
#else
(void)rev;
(void) strncpy(fiop->f_version, ipfilter_version,
sizeof(fiop->f_version));
#endif
}
#ifdef USE_INET6
int icmptoicmp6types[ICMP_MAXTYPE+1] = {
ICMP6_ECHO_REPLY,
-1,
-1,
ICMP6_DST_UNREACH,
-1,
ND_REDIRECT,
-1,
-1,
ICMP6_ECHO_REQUEST,
-1,
-1,
ICMP6_TIME_EXCEEDED,
ICMP6_PARAM_PROB,
-1,
-1,
-1,
-1,
-1,
-1,
};
int icmptoicmp6unreach[ICMP_MAX_UNREACH] = {
ICMP6_DST_UNREACH_ADDR,
ICMP6_DST_UNREACH_ADDR,
-1,
ICMP6_DST_UNREACH_NOPORT,
-1,
ICMP6_DST_UNREACH_NOTNEIGHBOR,
ICMP6_DST_UNREACH_ADDR,
ICMP6_DST_UNREACH_ADDR,
-1,
ICMP6_DST_UNREACH_ADMIN,
ICMP6_DST_UNREACH_ADMIN,
-1,
-1,
ICMP6_DST_UNREACH_ADMIN,
};
int icmpreplytype6[ICMP6_MAXTYPE + 1];
#endif
int icmpreplytype4[ICMP_MAXTYPE + 1];
int
ipf_matchicmpqueryreply(int v, icmpinfo_t *ic, icmphdr_t *icmp, int rev)
{
int ictype;
ictype = ic->ici_type;
if (v == 4) {
if ((!rev && (icmp->icmp_type == ictype)) ||
(rev && (icmpreplytype4[ictype] == icmp->icmp_type))) {
if (icmp->icmp_type != ICMP_ECHOREPLY)
return (1);
if (icmp->icmp_id == ic->ici_id)
return (1);
}
}
#ifdef USE_INET6
else if (v == 6) {
if ((!rev && (icmp->icmp_type == ictype)) ||
(rev && (icmpreplytype6[ictype] == icmp->icmp_type))) {
if (icmp->icmp_type != ICMP6_ECHO_REPLY)
return (1);
if (icmp->icmp_id == ic->ici_id)
return (1);
}
}
#endif
return (0);
}
#define IPF_IFNAME_VALID(_a) (_a != -1)
#define IPF_IFNAME_INVALID(_a) (_a == -1)
#define IPF_IFNAMES_DIFFERENT(_a) \
!((IPF_IFNAME_INVALID(fr1->_a) && \
IPF_IFNAME_INVALID(fr2->_a)) || \
(IPF_IFNAME_VALID(fr1->_a) && \
IPF_IFNAME_VALID(fr2->_a) && \
!strcmp(FR_NAME(fr1, _a), FR_NAME(fr2, _a))))
#define IPF_FRDEST_DIFFERENT(_a) \
(memcmp(&fr1->_a.fd_addr, &fr2->_a.fd_addr, \
offsetof(frdest_t, fd_name) - offsetof(frdest_t, fd_addr)) || \
IPF_IFNAMES_DIFFERENT(_a.fd_name))
static int
ipf_rule_compare(frentry_t *fr1, frentry_t *fr2)
{
int i;
if (fr1->fr_cksum != fr2->fr_cksum)
return (1);
if (fr1->fr_size != fr2->fr_size)
return (2);
if (fr1->fr_dsize != fr2->fr_dsize)
return (3);
if (bcmp((char *)&fr1->fr_func, (char *)&fr2->fr_func, FR_CMPSIZ)
!= 0)
return (4);
for (i = 0; i < FR_NUM(fr1->fr_ifnames); i++) {
if (IPF_IFNAMES_DIFFERENT(fr_ifnames[i]))
return (5);
}
if (IPF_FRDEST_DIFFERENT(fr_tif))
return (6);
if (IPF_FRDEST_DIFFERENT(fr_rif))
return (7);
if (IPF_FRDEST_DIFFERENT(fr_dif))
return (8);
if (!fr1->fr_data && !fr2->fr_data)
return (0);
if (fr1->fr_data && fr2->fr_data) {
if (bcmp(fr1->fr_caddr, fr2->fr_caddr, fr1->fr_dsize) == 0)
return (0);
}
return (9);
}
int
frrequest(ipf_main_softc_t *softc, int unit, ioctlcmd_t req, caddr_t data,
int set, int makecopy)
{
int error = 0, in, family, need_free = 0, interr, i;
enum { OP_ADD,
OP_REM,
OP_ZERO }
addrem = OP_ADD;
frentry_t frd, *fp, *f, **fprev, **ftail;
void *ptr, *uptr;
u_int *p, *pp;
frgroup_t *fg;
char *group;
ptr = NULL;
fg = NULL;
fp = &frd;
if (makecopy != 0) {
bzero(fp, sizeof(frd));
error = ipf_inobj(softc, data, NULL, fp, IPFOBJ_FRENTRY);
if (error) {
return (error);
}
if ((fp->fr_type & FR_T_BUILTIN) != 0) {
IPFERROR(6);
return (EINVAL);
}
if (fp->fr_size < sizeof(frd)) {
return (EINVAL);
}
if (sizeof(frd) + fp->fr_namelen != fp->fr_size ) {
IPFERROR(155);
return (EINVAL);
}
if (fp->fr_namelen < 0 || fp->fr_namelen > softc->ipf_max_namelen) {
IPFERROR(156);
return (EINVAL);
}
KMALLOCS(f, frentry_t *, fp->fr_size);
if (f == NULL) {
IPFERROR(131);
return (ENOMEM);
}
bzero(f, fp->fr_size);
error = ipf_inobjsz(softc, data, f, IPFOBJ_FRENTRY,
fp->fr_size);
if (error) {
KFREES(f, fp->fr_size);
return (error);
}
fp = f;
f = NULL;
fp->fr_next = NULL;
fp->fr_dnext = NULL;
fp->fr_pnext = NULL;
fp->fr_pdnext = NULL;
fp->fr_grp = NULL;
fp->fr_grphead = NULL;
fp->fr_icmpgrp = NULL;
fp->fr_isc = (void *)-1;
fp->fr_ptr = NULL;
fp->fr_ref = 0;
fp->fr_flags |= FR_COPIED;
for (i = 0; i <= 3; i++) {
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_ifnames[i])) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
}
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_comment)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_group)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_grhead)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_tif.fd_name)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_rif.fd_name)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
if ((interr = ipf_check_names_string(fp->fr_names, fp->fr_namelen, fp->fr_dif.fd_name)) != 0) {
IPFERROR(interr_tbl[interr-1]);
error = EINVAL;
goto donenolock;
}
} else {
fp = (frentry_t *)data;
if ((fp->fr_type & FR_T_BUILTIN) == 0) {
IPFERROR(7);
return (EINVAL);
}
fp->fr_flags &= ~FR_COPIED;
}
if (((fp->fr_dsize == 0) && (fp->fr_data != NULL)) ||
((fp->fr_dsize != 0) && (fp->fr_data == NULL))) {
IPFERROR(8);
error = EINVAL;
goto donenolock;
}
family = fp->fr_family;
uptr = fp->fr_data;
if (req == (ioctlcmd_t)SIOCINAFR || req == (ioctlcmd_t)SIOCINIFR ||
req == (ioctlcmd_t)SIOCADAFR || req == (ioctlcmd_t)SIOCADIFR)
addrem = OP_ADD;
else if (req == (ioctlcmd_t)SIOCRMAFR || req == (ioctlcmd_t)SIOCRMIFR)
addrem = OP_REM;
else if (req == (ioctlcmd_t)SIOCZRLST)
addrem = OP_ZERO;
else {
IPFERROR(9);
error = EINVAL;
goto donenolock;
}
if (family == AF_INET) {
;
#ifdef USE_INET6
} else if (family == AF_INET6) {
;
#endif
} else if (family != 0) {
IPFERROR(10);
error = EINVAL;
goto donenolock;
}
if ((makecopy == 1) && (fp->fr_func != NULL)) {
if (ipf_findfunc(fp->fr_func) == NULL) {
IPFERROR(11);
error = ESRCH;
goto donenolock;
}
if (addrem == OP_ADD) {
error = ipf_funcinit(softc, fp);
if (error != 0)
goto donenolock;
}
}
if ((fp->fr_flags & FR_CALLNOW) &&
((fp->fr_func == NULL) || (fp->fr_func == (ipfunc_t)-1))) {
IPFERROR(142);
error = ESRCH;
goto donenolock;
}
if (((fp->fr_flags & FR_CMDMASK) == FR_CALL) &&
((fp->fr_func == NULL) || (fp->fr_func == (ipfunc_t)-1))) {
IPFERROR(143);
error = ESRCH;
goto donenolock;
}
ptr = NULL;
if (FR_ISACCOUNT(fp->fr_flags))
unit = IPL_LOGCOUNT;
if (fp->fr_icmphead != -1) {
if ((fp->fr_icmphead < 0) ||
(fp->fr_icmphead >= fp->fr_namelen)) {
IPFERROR(136);
error = EINVAL;
goto donenolock;
}
if (!strcmp(FR_NAME(fp, fr_icmphead), "0"))
fp->fr_names[fp->fr_icmphead] = '\0';
}
if (fp->fr_grhead != -1) {
if ((fp->fr_grhead < 0) ||
(fp->fr_grhead >= fp->fr_namelen)) {
IPFERROR(137);
error = EINVAL;
goto donenolock;
}
if (!strcmp(FR_NAME(fp, fr_grhead), "0"))
fp->fr_names[fp->fr_grhead] = '\0';
}
if (fp->fr_group != -1) {
if ((fp->fr_group < 0) ||
(fp->fr_group >= fp->fr_namelen)) {
IPFERROR(138);
error = EINVAL;
goto donenolock;
}
if ((req != (int)SIOCZRLST) && (fp->fr_group != -1)) {
group = FR_NAME(fp, fr_group);
if (addrem == OP_ADD) {
fg = ipf_group_add(softc, group, NULL,
fp->fr_flags, unit, set);
fp->fr_grp = fg;
} else {
fg = ipf_findgroup(softc, group, unit,
set, NULL);
if (fg == NULL) {
IPFERROR(12);
error = ESRCH;
goto donenolock;
}
}
if (fg->fg_flags == 0) {
fg->fg_flags = fp->fr_flags & FR_INOUT;
} else if (fg->fg_flags != (fp->fr_flags & FR_INOUT)) {
IPFERROR(13);
error = ESRCH;
goto donenolock;
}
}
} else {
if ((fp->fr_flags & (FR_INQUE|FR_OUTQUE)) == 0) {
IPFERROR(14);
error = EINVAL;
goto donenolock;
}
}
in = (fp->fr_flags & FR_INQUE) ? 0 : 1;
ftail = NULL;
fprev = NULL;
if (unit == IPL_LOGAUTH) {
if ((fp->fr_tifs[0].fd_ptr != NULL) ||
(fp->fr_tifs[1].fd_ptr != NULL) ||
(fp->fr_dif.fd_ptr != NULL) ||
(fp->fr_flags & FR_FASTROUTE)) {
softc->ipf_interror = 145;
error = EINVAL;
goto donenolock;
}
fprev = ipf_auth_rulehead(softc);
} else {
if (FR_ISACCOUNT(fp->fr_flags))
fprev = &softc->ipf_acct[in][set];
else if ((fp->fr_flags & (FR_OUTQUE|FR_INQUE)) != 0)
fprev = &softc->ipf_rules[in][set];
}
if (fprev == NULL) {
IPFERROR(15);
error = ESRCH;
goto donenolock;
}
if (fg != NULL)
fprev = &fg->fg_start;
if (fp->fr_dsize != 0) {
if (makecopy != 0) {
KMALLOCS(ptr, void *, fp->fr_dsize);
if (ptr == NULL) {
IPFERROR(16);
error = ENOMEM;
goto donenolock;
}
if (uptr >= (void *)fp &&
uptr < (void *)((char *)fp + fp->fr_size)) {
bcopy(uptr, ptr, fp->fr_dsize);
error = 0;
} else {
error = COPYIN(uptr, ptr, fp->fr_dsize);
if (error != 0) {
IPFERROR(17);
error = EFAULT;
goto donenolock;
}
}
} else {
ptr = uptr;
}
fp->fr_data = ptr;
} else {
fp->fr_data = NULL;
}
switch (fp->fr_type & ~FR_T_BUILTIN)
{
#if defined(IPFILTER_BPF)
case FR_T_BPFOPC :
if (fp->fr_dsize == 0) {
IPFERROR(19);
error = EINVAL;
break;
}
if (!bpf_validate(ptr, fp->fr_dsize/sizeof(struct bpf_insn))) {
IPFERROR(20);
error = EINVAL;
break;
}
break;
#endif
case FR_T_IPF :
if (fp->fr_datype == FRI_LOOKUP)
fp->fr_dstptr = NULL;
if (fp->fr_satype == FRI_LOOKUP)
fp->fr_srcptr = NULL;
if (fp->fr_dsize != sizeof(fripf_t)) {
IPFERROR(21);
error = EINVAL;
break;
}
if ((fp->fr_flags & FR_KEEPSTATE) && (fp->fr_flx & FI_OOW)) {
IPFERROR(22);
error = EINVAL;
break;
}
switch (fp->fr_satype)
{
case FRI_BROADCAST :
case FRI_DYNAMIC :
case FRI_NETWORK :
case FRI_NETMASKED :
case FRI_PEERADDR :
if (fp->fr_sifpidx < 0) {
IPFERROR(23);
error = EINVAL;
}
break;
case FRI_LOOKUP :
fp->fr_srcptr = ipf_findlookup(softc, unit, fp,
&fp->fr_src6,
&fp->fr_smsk6);
if (fp->fr_srcfunc == NULL) {
IPFERROR(132);
error = ESRCH;
break;
}
break;
case FRI_NORMAL :
break;
default :
IPFERROR(133);
error = EINVAL;
break;
}
if (error != 0)
break;
switch (fp->fr_datype)
{
case FRI_BROADCAST :
case FRI_DYNAMIC :
case FRI_NETWORK :
case FRI_NETMASKED :
case FRI_PEERADDR :
if (fp->fr_difpidx < 0) {
IPFERROR(24);
error = EINVAL;
}
break;
case FRI_LOOKUP :
fp->fr_dstptr = ipf_findlookup(softc, unit, fp,
&fp->fr_dst6,
&fp->fr_dmsk6);
if (fp->fr_dstfunc == NULL) {
IPFERROR(134);
error = ESRCH;
}
break;
case FRI_NORMAL :
break;
default :
IPFERROR(135);
error = EINVAL;
}
break;
case FR_T_NONE :
case FR_T_CALLFUNC :
case FR_T_COMPIPF :
break;
case FR_T_IPFEXPR :
if (ipf_matcharray_verify(fp->fr_data, fp->fr_dsize) == -1) {
IPFERROR(25);
error = EINVAL;
}
break;
default :
IPFERROR(26);
error = EINVAL;
break;
}
if (error != 0)
goto donenolock;
if (fp->fr_tif.fd_name != -1) {
if ((fp->fr_tif.fd_name < 0) ||
(fp->fr_tif.fd_name >= fp->fr_namelen)) {
IPFERROR(139);
error = EINVAL;
goto donenolock;
}
}
if (fp->fr_dif.fd_name != -1) {
if ((fp->fr_dif.fd_name < 0) ||
(fp->fr_dif.fd_name >= fp->fr_namelen)) {
IPFERROR(140);
error = EINVAL;
goto donenolock;
}
}
if (fp->fr_rif.fd_name != -1) {
if ((fp->fr_rif.fd_name < 0) ||
(fp->fr_rif.fd_name >= fp->fr_namelen)) {
IPFERROR(141);
error = EINVAL;
goto donenolock;
}
}
error = ipf_synclist(softc, fp, NULL);
if (error != 0)
goto donenolock;
fp->fr_statecnt = 0;
if (fp->fr_srctrack.ht_max_nodes != 0)
ipf_rb_ht_init(&fp->fr_srctrack);
pp = (u_int *)(fp->fr_caddr + fp->fr_dsize);
for (fp->fr_cksum = 0, p = (u_int *)fp->fr_data; p < pp; p++)
fp->fr_cksum += *p;
WRITE_ENTER(&softc->ipf_mutex);
ftail = fprev;
for (f = *ftail; (f = *ftail) != NULL; ftail = &f->fr_next) {
if (fp->fr_collect <= f->fr_collect) {
ftail = fprev;
f = NULL;
break;
}
fprev = ftail;
}
for (; (f = *ftail) != NULL; ftail = &f->fr_next) {
if (ipf_rule_compare(fp, f) == 0)
break;
}
if (addrem == OP_ZERO) {
if (f == NULL) {
IPFERROR(27);
error = ESRCH;
} else {
bcopy((char *)f, (char *)fp, f->fr_size);
fp->fr_data = uptr;
error = ipf_outobj(softc, data, fp, IPFOBJ_FRENTRY);
if (error == 0) {
if ((f->fr_dsize != 0) && (uptr != NULL)) {
error = COPYOUT(f->fr_data, uptr,
f->fr_dsize);
if (error == 0) {
f->fr_hits = 0;
f->fr_bytes = 0;
} else {
IPFERROR(28);
error = EFAULT;
}
}
}
}
if (makecopy != 0) {
if (ptr != NULL) {
KFREES(ptr, fp->fr_dsize);
}
KFREES(fp, fp->fr_size);
}
RWLOCK_EXIT(&softc->ipf_mutex);
return (error);
}
if (f == NULL) {
if (req == (ioctlcmd_t)SIOCADAFR ||
req == (ioctlcmd_t)SIOCADIFR) {
for (ftail = fprev; (f = *ftail) != NULL; ) {
if (f->fr_collect > fp->fr_collect)
break;
ftail = &f->fr_next;
fprev = ftail;
}
ftail = fprev;
f = NULL;
ptr = NULL;
} else if (req == (ioctlcmd_t)SIOCINAFR ||
req == (ioctlcmd_t)SIOCINIFR) {
while ((f = *fprev) != NULL) {
if (f->fr_collect >= fp->fr_collect)
break;
fprev = &f->fr_next;
}
ftail = fprev;
if (fp->fr_hits != 0) {
while (fp->fr_hits && (f = *ftail)) {
if (f->fr_collect != fp->fr_collect)
break;
fprev = ftail;
ftail = &f->fr_next;
fp->fr_hits--;
}
}
f = NULL;
ptr = NULL;
}
}
if (addrem == OP_REM) {
if (f == NULL) {
IPFERROR(29);
error = ESRCH;
} else {
if ((makecopy == 1) && !(f->fr_flags & FR_COPIED)) {
IPFERROR(30);
error = EPERM;
goto done;
}
if (f->fr_ref > 1) {
IPFERROR(31);
error = EBUSY;
goto done;
}
#ifdef IPFILTER_SCAN
if (f->fr_isctag != -1 &&
(f->fr_isc != (struct ipscan *)-1))
ipf_scan_detachfr(f);
#endif
if (unit == IPL_LOGAUTH) {
error = ipf_auth_precmd(softc, req, f, ftail);
goto done;
}
ipf_rule_delete(softc, f, unit, set);
need_free = makecopy;
}
} else {
if (f != NULL) {
IPFERROR(32);
error = EEXIST;
goto done;
}
if (unit == IPL_LOGAUTH) {
error = ipf_auth_precmd(softc, req, fp, ftail);
goto done;
}
MUTEX_NUKE(&fp->fr_lock);
MUTEX_INIT(&fp->fr_lock, "filter rule lock");
if (fp->fr_die != 0)
ipf_rule_expire_insert(softc, fp, set);
fp->fr_hits = 0;
if (makecopy != 0)
fp->fr_ref = 1;
fp->fr_pnext = ftail;
fp->fr_next = *ftail;
if (fp->fr_next != NULL)
fp->fr_next->fr_pnext = &fp->fr_next;
*ftail = fp;
ipf_fixskip(ftail, fp, 1);
fp->fr_icmpgrp = NULL;
if (fp->fr_icmphead != -1) {
group = FR_NAME(fp, fr_icmphead);
fg = ipf_group_add(softc, group, fp, 0, unit, set);
fp->fr_icmpgrp = fg;
}
fp->fr_grphead = NULL;
if (fp->fr_grhead != -1) {
group = FR_NAME(fp, fr_grhead);
fg = ipf_group_add(softc, group, fp, fp->fr_flags,
unit, set);
fp->fr_grphead = fg;
}
}
done:
RWLOCK_EXIT(&softc->ipf_mutex);
donenolock:
if (need_free || (error != 0)) {
if ((fp->fr_type & ~FR_T_BUILTIN) == FR_T_IPF) {
if ((fp->fr_satype == FRI_LOOKUP) &&
(fp->fr_srcptr != NULL))
ipf_lookup_deref(softc, fp->fr_srctype,
fp->fr_srcptr);
if ((fp->fr_datype == FRI_LOOKUP) &&
(fp->fr_dstptr != NULL))
ipf_lookup_deref(softc, fp->fr_dsttype,
fp->fr_dstptr);
}
if (fp->fr_grp != NULL) {
WRITE_ENTER(&softc->ipf_mutex);
ipf_group_del(softc, fp->fr_grp, fp);
RWLOCK_EXIT(&softc->ipf_mutex);
}
if ((ptr != NULL) && (makecopy != 0)) {
KFREES(ptr, fp->fr_dsize);
}
KFREES(fp, fp->fr_size);
}
return (error);
}
static void
ipf_rule_delete(ipf_main_softc_t *softc, frentry_t *f, int unit, int set)
{
if (f->fr_pdnext != NULL) {
*f->fr_pdnext = f->fr_dnext;
if (f->fr_dnext != NULL)
f->fr_dnext->fr_pdnext = f->fr_pdnext;
f->fr_pdnext = NULL;
f->fr_dnext = NULL;
}
ipf_fixskip(f->fr_pnext, f, -1);
if (f->fr_pnext != NULL)
*f->fr_pnext = f->fr_next;
if (f->fr_next != NULL)
f->fr_next->fr_pnext = f->fr_pnext;
f->fr_pnext = NULL;
f->fr_next = NULL;
(void) ipf_derefrule(softc, &f);
}
static void
ipf_rule_expire_insert(ipf_main_softc_t *softc, frentry_t *f, int set)
{
frentry_t *fr;
f->fr_die = softc->ipf_ticks + IPF_TTLVAL(f->fr_die);
for (fr = softc->ipf_rule_explist[set]; fr != NULL;
fr = fr->fr_dnext) {
if (f->fr_die < fr->fr_die)
break;
if (fr->fr_dnext == NULL) {
fr->fr_dnext = f;
f->fr_pdnext = &fr->fr_dnext;
fr = NULL;
break;
}
}
if (softc->ipf_rule_explist[set] == NULL) {
softc->ipf_rule_explist[set] = f;
f->fr_pdnext = &softc->ipf_rule_explist[set];
} else if (fr != NULL) {
f->fr_dnext = fr;
f->fr_pdnext = fr->fr_pdnext;
fr->fr_pdnext = &f->fr_dnext;
}
}
static void *
ipf_findlookup(ipf_main_softc_t *softc, int unit, frentry_t *fr,
i6addr_t *addrp, i6addr_t *maskp)
{
void *ptr = NULL;
switch (addrp->iplookupsubtype)
{
case 0 :
ptr = ipf_lookup_res_num(softc, unit, addrp->iplookuptype,
addrp->iplookupnum,
&maskp->iplookupfunc);
break;
case 1 :
if (addrp->iplookupname < 0)
break;
if (addrp->iplookupname >= fr->fr_namelen)
break;
ptr = ipf_lookup_res_name(softc, unit, addrp->iplookuptype,
fr->fr_names + addrp->iplookupname,
&maskp->iplookupfunc);
break;
default :
break;
}
return (ptr);
}
static int
ipf_funcinit(ipf_main_softc_t *softc, frentry_t *fr)
{
ipfunc_resolve_t *ft;
int err;
IPFERROR(34);
err = ESRCH;
for (ft = ipf_availfuncs; ft->ipfu_addr != NULL; ft++)
if (ft->ipfu_addr == fr->fr_func) {
err = 0;
if (ft->ipfu_init != NULL)
err = (*ft->ipfu_init)(softc, fr);
break;
}
return (err);
}
static void
ipf_funcfini(ipf_main_softc_t *softc, frentry_t *fr)
{
ipfunc_resolve_t *ft;
for (ft = ipf_availfuncs; ft->ipfu_addr != NULL; ft++)
if (ft->ipfu_addr == fr->fr_func) {
if (ft->ipfu_fini != NULL)
(void) (*ft->ipfu_fini)(softc, fr);
break;
}
}
static ipfunc_t
ipf_findfunc(ipfunc_t funcptr)
{
ipfunc_resolve_t *ft;
for (ft = ipf_availfuncs; ft->ipfu_addr != NULL; ft++)
if (ft->ipfu_addr == funcptr)
return (funcptr);
return (NULL);
}
int
ipf_resolvefunc(ipf_main_softc_t *softc, void *data)
{
ipfunc_resolve_t res, *ft;
int error;
error = BCOPYIN(data, &res, sizeof(res));
if (error != 0) {
IPFERROR(123);
return (EFAULT);
}
if (res.ipfu_addr == NULL && res.ipfu_name[0] != '\0') {
for (ft = ipf_availfuncs; ft->ipfu_addr != NULL; ft++)
if (strncmp(res.ipfu_name, ft->ipfu_name,
sizeof(res.ipfu_name)) == 0) {
res.ipfu_addr = ft->ipfu_addr;
res.ipfu_init = ft->ipfu_init;
if (COPYOUT(&res, data, sizeof(res)) != 0) {
IPFERROR(35);
return (EFAULT);
}
return (0);
}
}
if (res.ipfu_addr != NULL && res.ipfu_name[0] == '\0') {
for (ft = ipf_availfuncs; ft->ipfu_addr != NULL; ft++)
if (ft->ipfu_addr == res.ipfu_addr) {
(void) strncpy(res.ipfu_name, ft->ipfu_name,
sizeof(res.ipfu_name));
res.ipfu_init = ft->ipfu_init;
if (COPYOUT(&res, data, sizeof(res)) != 0) {
IPFERROR(36);
return (EFAULT);
}
return (0);
}
}
IPFERROR(37);
return (ESRCH);
}
#if !defined(_KERNEL) || SOLARIS
int
ppsratecheck(struct timeval *lasttime, int *curpps, int maxpps)
{
struct timeval tv, delta;
int rv;
GETKTIME(&tv);
delta.tv_sec = tv.tv_sec - lasttime->tv_sec;
delta.tv_usec = tv.tv_usec - lasttime->tv_usec;
if (delta.tv_usec < 0) {
delta.tv_sec--;
delta.tv_usec += 1000000;
}
if ((lasttime->tv_sec == 0 && lasttime->tv_usec == 0) ||
delta.tv_sec >= 1) {
*lasttime = tv;
*curpps = 0;
rv = 1;
} else if (maxpps < 0)
rv = 1;
else if (*curpps < maxpps)
rv = 1;
else
rv = 0;
*curpps = *curpps + 1;
return (rv);
}
#endif
int
ipf_derefrule(ipf_main_softc_t *softc, frentry_t **frp)
{
frentry_t *fr;
frdest_t *fdp;
fr = *frp;
*frp = NULL;
MUTEX_ENTER(&fr->fr_lock);
fr->fr_ref--;
if (fr->fr_ref == 0) {
MUTEX_EXIT(&fr->fr_lock);
MUTEX_DESTROY(&fr->fr_lock);
ipf_funcfini(softc, fr);
fdp = &fr->fr_tif;
if (fdp->fd_type == FRD_DSTLIST)
ipf_lookup_deref(softc, IPLT_DSTLIST, fdp->fd_ptr);
fdp = &fr->fr_rif;
if (fdp->fd_type == FRD_DSTLIST)
ipf_lookup_deref(softc, IPLT_DSTLIST, fdp->fd_ptr);
fdp = &fr->fr_dif;
if (fdp->fd_type == FRD_DSTLIST)
ipf_lookup_deref(softc, IPLT_DSTLIST, fdp->fd_ptr);
if ((fr->fr_type & ~FR_T_BUILTIN) == FR_T_IPF &&
fr->fr_satype == FRI_LOOKUP)
ipf_lookup_deref(softc, fr->fr_srctype, fr->fr_srcptr);
if ((fr->fr_type & ~FR_T_BUILTIN) == FR_T_IPF &&
fr->fr_datype == FRI_LOOKUP)
ipf_lookup_deref(softc, fr->fr_dsttype, fr->fr_dstptr);
if (fr->fr_grp != NULL)
ipf_group_del(softc, fr->fr_grp, fr);
if (fr->fr_grphead != NULL)
ipf_group_del(softc, fr->fr_grphead, fr);
if (fr->fr_icmpgrp != NULL)
ipf_group_del(softc, fr->fr_icmpgrp, fr);
if ((fr->fr_flags & FR_COPIED) != 0) {
if (fr->fr_dsize) {
KFREES(fr->fr_data, fr->fr_dsize);
}
KFREES(fr, fr->fr_size);
return (0);
}
return (1);
} else {
MUTEX_EXIT(&fr->fr_lock);
}
return (-1);
}
static int
ipf_grpmapinit(ipf_main_softc_t *softc, frentry_t *fr)
{
char name[FR_GROUPLEN];
iphtable_t *iph;
(void) snprintf(name, sizeof(name), "%d", fr->fr_arg);
iph = ipf_lookup_find_htable(softc, IPL_LOGIPF, name);
if (iph == NULL) {
IPFERROR(38);
return (ESRCH);
}
if ((iph->iph_flags & FR_INOUT) != (fr->fr_flags & FR_INOUT)) {
IPFERROR(39);
return (ESRCH);
}
iph->iph_ref++;
fr->fr_ptr = iph;
return (0);
}
static int
ipf_grpmapfini(ipf_main_softc_t *softc, frentry_t *fr)
{
iphtable_t *iph;
iph = fr->fr_ptr;
if (iph != NULL)
ipf_lookup_deref(softc, IPLT_HASH, iph);
return (0);
}
frentry_t *
ipf_srcgrpmap(fr_info_t *fin, u_32_t *passp)
{
frgroup_t *fg;
void *rval;
rval = ipf_iphmfindgroup(fin->fin_main_soft, fin->fin_fr->fr_ptr,
&fin->fin_src);
if (rval == NULL)
return (NULL);
fg = rval;
fin->fin_fr = fg->fg_start;
(void) ipf_scanlist(fin, *passp);
return (fin->fin_fr);
}
frentry_t *
ipf_dstgrpmap(fr_info_t *fin, u_32_t *passp)
{
frgroup_t *fg;
void *rval;
rval = ipf_iphmfindgroup(fin->fin_main_soft, fin->fin_fr->fr_ptr,
&fin->fin_dst);
if (rval == NULL)
return (NULL);
fg = rval;
fin->fin_fr = fg->fg_start;
(void) ipf_scanlist(fin, *passp);
return (fin->fin_fr);
}
ipftq_t *
ipf_addtimeoutqueue(ipf_main_softc_t *softc, ipftq_t **parent, u_int seconds)
{
ipftq_t *ifq;
u_int period;
period = seconds * IPF_HZ_DIVIDE;
MUTEX_ENTER(&softc->ipf_timeoutlock);
for (ifq = *parent; ifq != NULL; ifq = ifq->ifq_next) {
if (ifq->ifq_ttl == period) {
MUTEX_ENTER(&ifq->ifq_lock);
ifq->ifq_flags &= ~IFQF_DELETE;
ifq->ifq_ref++;
MUTEX_EXIT(&ifq->ifq_lock);
MUTEX_EXIT(&softc->ipf_timeoutlock);
return (ifq);
}
}
KMALLOC(ifq, ipftq_t *);
if (ifq != NULL) {
MUTEX_NUKE(&ifq->ifq_lock);
IPFTQ_INIT(ifq, period, "ipftq mutex");
ifq->ifq_next = *parent;
ifq->ifq_pnext = parent;
ifq->ifq_flags = IFQF_USER;
ifq->ifq_ref++;
*parent = ifq;
softc->ipf_userifqs++;
}
MUTEX_EXIT(&softc->ipf_timeoutlock);
return (ifq);
}
int
ipf_deletetimeoutqueue(ipftq_t *ifq)
{
ifq->ifq_ref--;
if ((ifq->ifq_ref == 0) && ((ifq->ifq_flags & IFQF_USER) != 0)) {
ifq->ifq_flags |= IFQF_DELETE;
}
return (ifq->ifq_ref);
}
void
ipf_freetimeoutqueue(ipf_main_softc_t *softc, ipftq_t *ifq)
{
if (((ifq->ifq_flags & IFQF_DELETE) == 0) || (ifq->ifq_ref != 0) ||
((ifq->ifq_flags & IFQF_USER) == 0)) {
printf("ipf_freetimeoutqueue(%lx) flags 0x%x ttl %d ref %d\n",
(u_long)ifq, ifq->ifq_flags, ifq->ifq_ttl,
ifq->ifq_ref);
return;
}
*ifq->ifq_pnext = ifq->ifq_next;
if (ifq->ifq_next != NULL)
ifq->ifq_next->ifq_pnext = ifq->ifq_pnext;
ifq->ifq_next = NULL;
ifq->ifq_pnext = NULL;
MUTEX_DESTROY(&ifq->ifq_lock);
ATOMIC_DEC(softc->ipf_userifqs);
KFREE(ifq);
}
void
ipf_deletequeueentry(ipftqent_t *tqe)
{
ipftq_t *ifq;
ifq = tqe->tqe_ifq;
MUTEX_ENTER(&ifq->ifq_lock);
if (tqe->tqe_pnext != NULL) {
*tqe->tqe_pnext = tqe->tqe_next;
if (tqe->tqe_next != NULL)
tqe->tqe_next->tqe_pnext = tqe->tqe_pnext;
else
ifq->ifq_tail = tqe->tqe_pnext;
tqe->tqe_pnext = NULL;
tqe->tqe_ifq = NULL;
}
(void) ipf_deletetimeoutqueue(ifq);
ASSERT(ifq->ifq_ref > 0);
MUTEX_EXIT(&ifq->ifq_lock);
}
void
ipf_queuefront(ipftqent_t *tqe)
{
ipftq_t *ifq;
ifq = tqe->tqe_ifq;
if (ifq == NULL)
return;
MUTEX_ENTER(&ifq->ifq_lock);
if (ifq->ifq_head != tqe) {
*tqe->tqe_pnext = tqe->tqe_next;
if (tqe->tqe_next)
tqe->tqe_next->tqe_pnext = tqe->tqe_pnext;
else
ifq->ifq_tail = tqe->tqe_pnext;
tqe->tqe_next = ifq->ifq_head;
ifq->ifq_head->tqe_pnext = &tqe->tqe_next;
ifq->ifq_head = tqe;
tqe->tqe_pnext = &ifq->ifq_head;
}
MUTEX_EXIT(&ifq->ifq_lock);
}
void
ipf_queueback(u_long ticks, ipftqent_t *tqe)
{
ipftq_t *ifq;
ifq = tqe->tqe_ifq;
if (ifq == NULL)
return;
tqe->tqe_die = ticks + ifq->ifq_ttl;
tqe->tqe_touched = ticks;
MUTEX_ENTER(&ifq->ifq_lock);
if (tqe->tqe_next != NULL) {
*tqe->tqe_pnext = tqe->tqe_next;
tqe->tqe_next->tqe_pnext = tqe->tqe_pnext;
tqe->tqe_next = NULL;
tqe->tqe_pnext = ifq->ifq_tail;
*ifq->ifq_tail = tqe;
ifq->ifq_tail = &tqe->tqe_next;
}
MUTEX_EXIT(&ifq->ifq_lock);
}
void
ipf_queueappend(u_long ticks, ipftqent_t *tqe, ipftq_t *ifq, void *parent)
{
MUTEX_ENTER(&ifq->ifq_lock);
tqe->tqe_parent = parent;
tqe->tqe_pnext = ifq->ifq_tail;
*ifq->ifq_tail = tqe;
ifq->ifq_tail = &tqe->tqe_next;
tqe->tqe_next = NULL;
tqe->tqe_ifq = ifq;
tqe->tqe_die = ticks + ifq->ifq_ttl;
tqe->tqe_touched = ticks;
ifq->ifq_ref++;
MUTEX_EXIT(&ifq->ifq_lock);
}
void
ipf_movequeue(u_long ticks, ipftqent_t *tqe, ipftq_t *oifq, ipftq_t *nifq)
{
if (oifq == nifq && tqe->tqe_touched == ticks)
return;
MUTEX_ENTER(&oifq->ifq_lock);
tqe->tqe_touched = ticks;
tqe->tqe_die = ticks + nifq->ifq_ttl;
if (oifq == nifq) {
if ((tqe->tqe_next == NULL) ||
(tqe->tqe_next->tqe_die == tqe->tqe_die)) {
MUTEX_EXIT(&oifq->ifq_lock);
return;
}
}
*tqe->tqe_pnext = tqe->tqe_next;
if (tqe->tqe_next)
tqe->tqe_next->tqe_pnext = tqe->tqe_pnext;
else
oifq->ifq_tail = tqe->tqe_pnext;
tqe->tqe_next = NULL;
if (oifq != nifq) {
tqe->tqe_ifq = NULL;
(void) ipf_deletetimeoutqueue(oifq);
MUTEX_EXIT(&oifq->ifq_lock);
MUTEX_ENTER(&nifq->ifq_lock);
tqe->tqe_ifq = nifq;
nifq->ifq_ref++;
}
tqe->tqe_pnext = nifq->ifq_tail;
*nifq->ifq_tail = tqe;
nifq->ifq_tail = &tqe->tqe_next;
MUTEX_EXIT(&nifq->ifq_lock);
}
static int
ipf_updateipid(fr_info_t *fin)
{
u_short id, ido, sums;
u_32_t sumd, sum;
ip_t *ip;
ip = fin->fin_ip;
ido = ntohs(ip->ip_id);
if (fin->fin_off != 0) {
sum = ipf_frag_ipidknown(fin);
if (sum == 0xffffffff)
return (-1);
sum &= 0xffff;
id = (u_short)sum;
ip->ip_id = htons(id);
} else {
ip_fillid(ip, V_ip_random_id);
id = ntohs(ip->ip_id);
if ((fin->fin_flx & FI_FRAG) != 0)
(void) ipf_frag_ipidnew(fin, (u_32_t)id);
}
if (id == ido)
return (0);
CALC_SUMD(ido, id, sumd);
sum = (~ntohs(ip->ip_sum)) & 0xffff;
sum += sumd;
sum = (sum >> 16) + (sum & 0xffff);
sum = (sum >> 16) + (sum & 0xffff);
sums = ~(u_short)sum;
ip->ip_sum = htons(sums);
return (0);
}
#ifdef NEED_FRGETIFNAME
char *
ipf_getifname(struct ifnet *ifp, char *buffer)
{
static char namebuf[LIFNAMSIZ];
# if SOLARIS || defined(__FreeBSD__)
int unit, space;
char temp[20];
char *s;
# endif
if (buffer == NULL)
buffer = namebuf;
(void) strncpy(buffer, ifp->if_name, LIFNAMSIZ);
buffer[LIFNAMSIZ - 1] = '\0';
# if SOLARIS || defined(__FreeBSD__)
for (s = buffer; *s; s++)
;
unit = ifp->if_unit;
space = LIFNAMSIZ - (s - buffer);
if ((space > 0) && (unit >= 0)) {
(void) snprintf(temp, sizeof(name), "%d", unit);
(void) strncpy(s, temp, space);
}
# endif
return (buffer);
}
#endif
int
ipf_ioctlswitch(ipf_main_softc_t *softc, int unit, void *data, ioctlcmd_t cmd,
int mode, int uid, void *ctx)
{
int error = 0;
switch (cmd)
{
case SIOCIPFINTERROR :
error = BCOPYOUT(&softc->ipf_interror, data,
sizeof(softc->ipf_interror));
if (error != 0) {
IPFERROR(40);
error = EFAULT;
}
return (error);
default :
break;
}
switch (unit)
{
case IPL_LOGIPF :
error = ipf_ipf_ioctl(softc, data, cmd, mode, uid, ctx);
break;
case IPL_LOGNAT :
if (softc->ipf_running > 0) {
error = ipf_nat_ioctl(softc, data, cmd, mode,
uid, ctx);
} else {
IPFERROR(42);
error = EIO;
}
break;
case IPL_LOGSTATE :
if (softc->ipf_running > 0) {
error = ipf_state_ioctl(softc, data, cmd, mode,
uid, ctx);
} else {
IPFERROR(43);
error = EIO;
}
break;
case IPL_LOGAUTH :
if (softc->ipf_running > 0) {
error = ipf_auth_ioctl(softc, data, cmd, mode,
uid, ctx);
} else {
IPFERROR(44);
error = EIO;
}
break;
case IPL_LOGSYNC :
if (softc->ipf_running > 0) {
error = ipf_sync_ioctl(softc, data, cmd, mode,
uid, ctx);
} else {
error = EIO;
IPFERROR(45);
}
break;
case IPL_LOGSCAN :
#ifdef IPFILTER_SCAN
if (softc->ipf_running > 0)
error = ipf_scan_ioctl(softc, data, cmd, mode,
uid, ctx);
else
#endif
{
error = EIO;
IPFERROR(46);
}
break;
case IPL_LOGLOOKUP :
if (softc->ipf_running > 0) {
error = ipf_lookup_ioctl(softc, data, cmd, mode,
uid, ctx);
} else {
error = EIO;
IPFERROR(47);
}
break;
default :
IPFERROR(48);
error = EIO;
break;
}
return (error);
}
static const int ipf_objbytes[IPFOBJ_COUNT][3] = {
{ 1, sizeof(struct frentry), 5010000 },
{ 1, sizeof(struct friostat), 5010000 },
{ 0, sizeof(struct fr_info), 5010000 },
{ 0, sizeof(struct ipf_authstat), 4010100 },
{ 0, sizeof(struct ipfrstat), 5010000 },
{ 1, sizeof(struct ipnat), 5010000 },
{ 0, sizeof(struct natstat), 5010000 },
{ 0, sizeof(struct ipstate_save), 5010000 },
{ 1, sizeof(struct nat_save), 5010000 },
{ 0, sizeof(struct natlookup), 5010000 },
{ 1, sizeof(struct ipstate), 5010000 },
{ 0, sizeof(struct ips_stat), 5010000 },
{ 0, sizeof(struct frauth), 5010000 },
{ 0, sizeof(struct ipftune), 4010100 },
{ 0, sizeof(struct nat), 5010000 },
{ 0, sizeof(struct ipfruleiter), 4011400 },
{ 0, sizeof(struct ipfgeniter), 4011400 },
{ 0, sizeof(struct ipftable), 4011400 },
{ 0, sizeof(struct ipflookupiter), 4011400 },
{ 0, sizeof(struct ipftq) * IPF_TCP_NSTATES },
{ 1, 0, 0 },
{ 0, 0, 0 },
{ 0, sizeof (struct fripf), 5010000 }
};
int
ipf_inobj(ipf_main_softc_t *softc, void *data, ipfobj_t *objp, void *ptr,
int type)
{
ipfobj_t obj;
int error;
int size;
if ((type < 0) || (type >= IPFOBJ_COUNT)) {
IPFERROR(49);
return (EINVAL);
}
if (objp == NULL)
objp = &obj;
error = BCOPYIN(data, objp, sizeof(*objp));
if (error != 0) {
IPFERROR(124);
return (EFAULT);
}
if (objp->ipfo_type != type) {
IPFERROR(50);
return (EINVAL);
}
if (objp->ipfo_rev >= ipf_objbytes[type][2]) {
if ((ipf_objbytes[type][0] & 1) != 0) {
if (objp->ipfo_size < ipf_objbytes[type][1]) {
IPFERROR(51);
return (EINVAL);
}
size = ipf_objbytes[type][1];
} else if (objp->ipfo_size == ipf_objbytes[type][1]) {
size = objp->ipfo_size;
} else {
IPFERROR(52);
return (EINVAL);
}
error = COPYIN(objp->ipfo_ptr, ptr, size);
if (error != 0) {
IPFERROR(55);
error = EFAULT;
}
} else {
#ifdef IPFILTER_COMPAT
error = ipf_in_compat(softc, objp, ptr, 0);
#else
IPFERROR(54);
error = EINVAL;
#endif
}
return (error);
}
int
ipf_inobjsz(ipf_main_softc_t *softc, void *data, void *ptr, int type, int sz)
{
ipfobj_t obj;
int error;
if ((type < 0) || (type >= IPFOBJ_COUNT)) {
IPFERROR(56);
return (EINVAL);
}
error = BCOPYIN(data, &obj, sizeof(obj));
if (error != 0) {
IPFERROR(125);
return (EFAULT);
}
if (obj.ipfo_type != type) {
IPFERROR(58);
return (EINVAL);
}
if (obj.ipfo_rev >= ipf_objbytes[type][2]) {
if (((ipf_objbytes[type][0] & 1) == 0) ||
(sz < ipf_objbytes[type][1])) {
IPFERROR(57);
return (EINVAL);
}
error = COPYIN(obj.ipfo_ptr, ptr, sz);
if (error != 0) {
IPFERROR(61);
error = EFAULT;
}
} else {
#ifdef IPFILTER_COMPAT
error = ipf_in_compat(softc, &obj, ptr, sz);
#else
IPFERROR(60);
error = EINVAL;
#endif
}
return (error);
}
int
ipf_outobjsz(ipf_main_softc_t *softc, void *data, void *ptr, int type, int sz)
{
ipfobj_t obj;
int error;
if ((type < 0) || (type >= IPFOBJ_COUNT)) {
IPFERROR(62);
return (EINVAL);
}
error = BCOPYIN(data, &obj, sizeof(obj));
if (error != 0) {
IPFERROR(127);
return (EFAULT);
}
if (obj.ipfo_type != type) {
IPFERROR(63);
return (EINVAL);
}
if (obj.ipfo_rev >= ipf_objbytes[type][2]) {
if (((ipf_objbytes[type][0] & 1) == 0) ||
(sz < ipf_objbytes[type][1])) {
IPFERROR(146);
return (EINVAL);
}
error = COPYOUT(ptr, obj.ipfo_ptr, sz);
if (error != 0) {
IPFERROR(66);
error = EFAULT;
}
} else {
#ifdef IPFILTER_COMPAT
error = ipf_out_compat(softc, &obj, ptr);
#else
IPFERROR(65);
error = EINVAL;
#endif
}
return (error);
}
int
ipf_outobj(ipf_main_softc_t *softc, void *data, void *ptr, int type)
{
ipfobj_t obj;
int error;
if ((type < 0) || (type >= IPFOBJ_COUNT)) {
IPFERROR(67);
return (EINVAL);
}
error = BCOPYIN(data, &obj, sizeof(obj));
if (error != 0) {
IPFERROR(126);
return (EFAULT);
}
if (obj.ipfo_type != type) {
IPFERROR(68);
return (EINVAL);
}
if (obj.ipfo_rev >= ipf_objbytes[type][2]) {
if ((ipf_objbytes[type][0] & 1) != 0) {
if (obj.ipfo_size < ipf_objbytes[type][1]) {
IPFERROR(69);
return (EINVAL);
}
} else if (obj.ipfo_size != ipf_objbytes[type][1]) {
IPFERROR(70);
return (EINVAL);
}
error = COPYOUT(ptr, obj.ipfo_ptr, obj.ipfo_size);
if (error != 0) {
IPFERROR(73);
error = EFAULT;
}
} else {
#ifdef IPFILTER_COMPAT
error = ipf_out_compat(softc, &obj, ptr);
#else
IPFERROR(72);
error = EINVAL;
#endif
}
return (error);
}
int
ipf_outobjk(ipf_main_softc_t *softc, ipfobj_t *obj, void *ptr)
{
int type = obj->ipfo_type;
int error;
if ((type < 0) || (type >= IPFOBJ_COUNT)) {
IPFERROR(147);
return (EINVAL);
}
if (obj->ipfo_rev >= ipf_objbytes[type][2]) {
if ((ipf_objbytes[type][0] & 1) != 0) {
if (obj->ipfo_size < ipf_objbytes[type][1]) {
IPFERROR(148);
return (EINVAL);
}
} else if (obj->ipfo_size != ipf_objbytes[type][1]) {
IPFERROR(149);
return (EINVAL);
}
error = COPYOUT(ptr, obj->ipfo_ptr, obj->ipfo_size);
if (error != 0) {
IPFERROR(150);
error = EFAULT;
}
} else {
#ifdef IPFILTER_COMPAT
error = ipf_out_compat(softc, obj, ptr);
#else
IPFERROR(151);
error = EINVAL;
#endif
}
return (error);
}
inline int
ipf_checkl4sum(fr_info_t *fin)
{
u_short sum, hdrsum, *csump;
udphdr_t *udp;
int dosum;
if ((fin->fin_flx & (FI_FRAG|FI_SHORT|FI_BAD)) != 0)
return (1);
DT2(l4sumo, int, fin->fin_out, int, (int)fin->fin_p);
if (fin->fin_out == 1) {
fin->fin_cksum = FI_CK_SUMOK;
return (0);
}
csump = NULL;
hdrsum = 0;
dosum = 0;
sum = 0;
switch (fin->fin_p)
{
case IPPROTO_TCP :
csump = &((tcphdr_t *)fin->fin_dp)->th_sum;
dosum = 1;
break;
case IPPROTO_UDP :
udp = fin->fin_dp;
if (udp->uh_sum != 0) {
csump = &udp->uh_sum;
dosum = 1;
}
break;
#ifdef USE_INET6
case IPPROTO_ICMPV6 :
csump = &((struct icmp6_hdr *)fin->fin_dp)->icmp6_cksum;
dosum = 1;
break;
#endif
case IPPROTO_ICMP :
csump = &((struct icmp *)fin->fin_dp)->icmp_cksum;
dosum = 1;
break;
default :
return (1);
}
if (csump != NULL) {
hdrsum = *csump;
if (fin->fin_p == IPPROTO_UDP && hdrsum == 0xffff)
hdrsum = 0x0000;
}
if (dosum) {
sum = fr_cksum(fin, fin->fin_ip, fin->fin_p, fin->fin_dp);
}
#if !defined(_KERNEL)
if (sum == hdrsum) {
FR_DEBUG(("checkl4sum: %hx == %hx\n", sum, hdrsum));
} else {
FR_DEBUG(("checkl4sum: %hx != %hx\n", sum, hdrsum));
}
#endif
DT3(l4sums, u_short, hdrsum, u_short, sum, fr_info_t *, fin);
#ifdef USE_INET6
if (hdrsum == sum || (sum == 0 && IP_V(fin->fin_ip) == 6)) {
#else
if (hdrsum == sum) {
#endif
fin->fin_cksum = FI_CK_SUMOK;
return (0);
}
fin->fin_cksum = FI_CK_BAD;
return (-1);
}
int
ipf_ifpfillv4addr(int atype, struct sockaddr_in *sin, struct sockaddr_in *mask,
struct in_addr *inp, struct in_addr *inpmask)
{
if (inpmask != NULL && atype != FRI_NETMASKED)
inpmask->s_addr = 0xffffffff;
if (atype == FRI_NETWORK || atype == FRI_NETMASKED) {
if (atype == FRI_NETMASKED) {
if (inpmask == NULL)
return (-1);
inpmask->s_addr = mask->sin_addr.s_addr;
}
inp->s_addr = sin->sin_addr.s_addr & mask->sin_addr.s_addr;
} else {
inp->s_addr = sin->sin_addr.s_addr;
}
return (0);
}
#ifdef USE_INET6
int
ipf_ifpfillv6addr(int atype, struct sockaddr_in6 *sin,
struct sockaddr_in6 *mask, i6addr_t *inp, i6addr_t *inpmask)
{
i6addr_t *src, *and;
src = (i6addr_t *)&sin->sin6_addr;
and = (i6addr_t *)&mask->sin6_addr;
if (inpmask != NULL && atype != FRI_NETMASKED) {
inpmask->i6[0] = 0xffffffff;
inpmask->i6[1] = 0xffffffff;
inpmask->i6[2] = 0xffffffff;
inpmask->i6[3] = 0xffffffff;
}
if (atype == FRI_NETWORK || atype == FRI_NETMASKED) {
if (atype == FRI_NETMASKED) {
if (inpmask == NULL)
return (-1);
inpmask->i6[0] = and->i6[0];
inpmask->i6[1] = and->i6[1];
inpmask->i6[2] = and->i6[2];
inpmask->i6[3] = and->i6[3];
}
inp->i6[0] = src->i6[0] & and->i6[0];
inp->i6[1] = src->i6[1] & and->i6[1];
inp->i6[2] = src->i6[2] & and->i6[2];
inp->i6[3] = src->i6[3] & and->i6[3];
} else {
inp->i6[0] = src->i6[0];
inp->i6[1] = src->i6[1];
inp->i6[2] = src->i6[2];
inp->i6[3] = src->i6[3];
}
return (0);
}
#endif
int
ipf_matchtag(ipftag_t *tag1, ipftag_t *tag2)
{
if (tag1 == tag2)
return (1);
if ((tag1->ipt_num[0] == 0) && (tag2->ipt_num[0] == 0))
return (1);
if ((tag1->ipt_num[0] == tag2->ipt_num[0]) &&
(tag1->ipt_num[1] == tag2->ipt_num[1]) &&
(tag1->ipt_num[2] == tag2->ipt_num[2]) &&
(tag1->ipt_num[3] == tag2->ipt_num[3]))
return (1);
return (0);
}
int
ipf_coalesce(fr_info_t *fin)
{
if ((fin->fin_flx & FI_COALESCE) != 0)
return (1);
if (fin->fin_m == NULL || fin->fin_mp == NULL)
return (0);
#if defined(_KERNEL)
if (ipf_pullup(fin->fin_m, fin, fin->fin_plen) == NULL) {
ipf_main_softc_t *softc = fin->fin_main_soft;
DT1(frb_coalesce, fr_info_t *, fin);
LBUMP(ipf_stats[fin->fin_out].fr_badcoalesces);
# if SOLARIS
FREE_MB_T(*fin->fin_mp);
# endif
fin->fin_reason = FRB_COALESCE;
*fin->fin_mp = NULL;
fin->fin_m = NULL;
return (-1);
}
#else
fin = fin;
#endif
return (1);
}
static ipftuneable_t *
ipf_tune_findbycookie(ipftuneable_t **ptop, void *cookie, void **next)
{
ipftuneable_t *ta, **tap;
for (ta = *ptop; ta->ipft_name != NULL; ta++)
if (ta == cookie) {
if (next != NULL) {
if ((ta + 1)->ipft_name != NULL)
*next = ta + 1;
else
*next = ptop;
}
return (ta);
}
for (tap = ptop; (ta = *tap) != NULL; tap = &ta->ipft_next)
if (tap == cookie) {
if (next != NULL)
*next = &ta->ipft_next;
return (ta);
}
if (next != NULL)
*next = NULL;
return (NULL);
}
static ipftuneable_t *
ipf_tune_findbyname(ipftuneable_t *top, const char *name)
{
ipftuneable_t *ta;
for (ta = top; ta != NULL; ta = ta->ipft_next)
if (!strcmp(ta->ipft_name, name)) {
return (ta);
}
return (NULL);
}
int
ipf_tune_add_array(ipf_main_softc_t *softc, ipftuneable_t *newtune)
{
ipftuneable_t *nt, *dt;
int error = 0;
for (nt = newtune; nt->ipft_name != NULL; nt++) {
error = ipf_tune_add(softc, nt);
if (error != 0) {
for (dt = newtune; dt != nt; dt++) {
(void) ipf_tune_del(softc, dt);
}
}
}
return (error);
}
int
ipf_tune_array_link(ipf_main_softc_t *softc, ipftuneable_t *array)
{
ipftuneable_t *t, **p;
t = array;
if (t->ipft_name == NULL)
return (-1);
for (; t[1].ipft_name != NULL; t++)
t[0].ipft_next = &t[1];
t->ipft_next = NULL;
for (p = &softc->ipf_tuners; (t = *p) != NULL; p = &t->ipft_next)
if (t->ipft_name == NULL)
break;
*p = array;
return (0);
}
int
ipf_tune_array_unlink(ipf_main_softc_t *softc, ipftuneable_t *array)
{
ipftuneable_t *t, **p;
for (p = &softc->ipf_tuners; (t = *p) != NULL; p = &t->ipft_next)
if (t == array)
break;
if (t == NULL)
return (-1);
for (; t[1].ipft_name != NULL; t++)
;
*p = t->ipft_next;
return (0);
}
ipftuneable_t *
ipf_tune_array_copy(void *base, size_t size, ipftuneable_t *template)
{
ipftuneable_t *copy;
int i;
KMALLOCS(copy, ipftuneable_t *, size);
if (copy == NULL) {
return (NULL);
}
bcopy(template, copy, size);
for (i = 0; copy[i].ipft_name; i++) {
copy[i].ipft_una.ipftp_offset += (u_long)base;
copy[i].ipft_next = copy + i + 1;
}
return (copy);
}
int
ipf_tune_add(ipf_main_softc_t *softc, ipftuneable_t *newtune)
{
ipftuneable_t *ta, **tap;
ta = ipf_tune_findbyname(softc->ipf_tuners, newtune->ipft_name);
if (ta != NULL) {
IPFERROR(74);
return (EEXIST);
}
for (tap = &softc->ipf_tuners; *tap != NULL; tap = &(*tap)->ipft_next)
;
newtune->ipft_next = NULL;
*tap = newtune;
return (0);
}
int
ipf_tune_del(ipf_main_softc_t *softc, ipftuneable_t *oldtune)
{
ipftuneable_t *ta, **tap;
int error = 0;
for (tap = &softc->ipf_tuners; (ta = *tap) != NULL;
tap = &ta->ipft_next) {
if (ta == oldtune) {
*tap = oldtune->ipft_next;
oldtune->ipft_next = NULL;
break;
}
}
if (ta == NULL) {
error = ESRCH;
IPFERROR(75);
}
return (error);
}
int
ipf_tune_del_array(ipf_main_softc_t *softc, ipftuneable_t *oldtune)
{
ipftuneable_t *ot;
int error = 0;
for (ot = oldtune; ot->ipft_name != NULL; ot++) {
error = ipf_tune_del(softc, ot);
if (error != 0)
break;
}
return (error);
}
int
ipf_ipftune(ipf_main_softc_t *softc, ioctlcmd_t cmd, void *data)
{
ipftuneable_t *ta;
ipftune_t tu;
void *cookie;
int error;
error = ipf_inobj(softc, data, NULL, &tu, IPFOBJ_TUNEABLE);
if (error != 0)
return (error);
tu.ipft_name[sizeof(tu.ipft_name) - 1] = '\0';
cookie = tu.ipft_cookie;
ta = NULL;
switch (cmd)
{
case SIOCIPFGETNEXT :
if (cookie != NULL) {
ta = ipf_tune_findbycookie(&softc->ipf_tuners,
cookie, &tu.ipft_cookie);
} else {
ta = softc->ipf_tuners;
tu.ipft_cookie = ta + 1;
}
if (ta != NULL) {
if (ta->ipft_sz > sizeof(tu.ipft_un)) {
IPFERROR(76);
return (EINVAL);
}
tu.ipft_vlong = 0;
if (ta->ipft_sz == sizeof(u_long))
tu.ipft_vlong = *ta->ipft_plong;
else if (ta->ipft_sz == sizeof(u_int))
tu.ipft_vint = *ta->ipft_pint;
else if (ta->ipft_sz == sizeof(u_short))
tu.ipft_vshort = *ta->ipft_pshort;
else if (ta->ipft_sz == sizeof(u_char))
tu.ipft_vchar = *ta->ipft_pchar;
tu.ipft_sz = ta->ipft_sz;
tu.ipft_min = ta->ipft_min;
tu.ipft_max = ta->ipft_max;
tu.ipft_flags = ta->ipft_flags;
bcopy(ta->ipft_name, tu.ipft_name,
MIN(sizeof(tu.ipft_name),
strlen(ta->ipft_name) + 1));
}
error = ipf_outobj(softc, data, &tu, IPFOBJ_TUNEABLE);
break;
case SIOCIPFGET :
case SIOCIPFSET :
IPFERROR(77);
error = ESRCH;
if (cookie != NULL) {
ta = ipf_tune_findbycookie(&softc->ipf_tuners,
cookie, NULL);
if (ta != NULL)
error = 0;
} else if (tu.ipft_name[0] != '\0') {
ta = ipf_tune_findbyname(softc->ipf_tuners,
tu.ipft_name);
if (ta != NULL)
error = 0;
}
if (error != 0)
break;
if (cmd == (ioctlcmd_t)SIOCIPFGET) {
tu.ipft_vlong = 0;
if (ta->ipft_sz == sizeof(u_long))
tu.ipft_vlong = *ta->ipft_plong;
else if (ta->ipft_sz == sizeof(u_int))
tu.ipft_vint = *ta->ipft_pint;
else if (ta->ipft_sz == sizeof(u_short))
tu.ipft_vshort = *ta->ipft_pshort;
else if (ta->ipft_sz == sizeof(u_char))
tu.ipft_vchar = *ta->ipft_pchar;
tu.ipft_cookie = ta;
tu.ipft_sz = ta->ipft_sz;
tu.ipft_min = ta->ipft_min;
tu.ipft_max = ta->ipft_max;
tu.ipft_flags = ta->ipft_flags;
error = ipf_outobj(softc, data, &tu, IPFOBJ_TUNEABLE);
} else if (cmd == (ioctlcmd_t)SIOCIPFSET) {
u_long in;
if (((ta->ipft_flags & IPFT_WRDISABLED) != 0) &&
(softc->ipf_running > 0)) {
IPFERROR(78);
error = EBUSY;
break;
}
in = tu.ipft_vlong;
if (in < ta->ipft_min || in > ta->ipft_max) {
IPFERROR(79);
error = EINVAL;
break;
}
if (ta->ipft_func != NULL) {
SPL_INT(s);
SPL_NET(s);
error = (*ta->ipft_func)(softc, ta,
&tu.ipft_un);
SPL_X(s);
} else if (ta->ipft_sz == sizeof(u_long)) {
tu.ipft_vlong = *ta->ipft_plong;
*ta->ipft_plong = in;
} else if (ta->ipft_sz == sizeof(u_int)) {
tu.ipft_vint = *ta->ipft_pint;
*ta->ipft_pint = (u_int)(in & 0xffffffff);
} else if (ta->ipft_sz == sizeof(u_short)) {
tu.ipft_vshort = *ta->ipft_pshort;
*ta->ipft_pshort = (u_short)(in & 0xffff);
} else if (ta->ipft_sz == sizeof(u_char)) {
tu.ipft_vchar = *ta->ipft_pchar;
*ta->ipft_pchar = (u_char)(in & 0xff);
}
error = ipf_outobj(softc, data, &tu, IPFOBJ_TUNEABLE);
}
break;
default :
IPFERROR(80);
error = EINVAL;
break;
}
return (error);
}
int
ipf_zerostats(ipf_main_softc_t *softc, caddr_t data)
{
friostat_t fio;
ipfobj_t obj;
int error;
error = ipf_inobj(softc, data, &obj, &fio, IPFOBJ_IPFSTAT);
if (error != 0)
return (error);
ipf_getstat(softc, &fio, obj.ipfo_rev);
error = ipf_outobj(softc, data, &fio, IPFOBJ_IPFSTAT);
if (error != 0)
return (error);
WRITE_ENTER(&softc->ipf_mutex);
bzero(&softc->ipf_stats, sizeof(softc->ipf_stats));
RWLOCK_EXIT(&softc->ipf_mutex);
return (0);
}
int
ipf_resolvedest(ipf_main_softc_t *softc, char *base, frdest_t *fdp, int v)
{
int errval = 0;
void *ifp;
ifp = NULL;
if (fdp->fd_name != -1) {
if (fdp->fd_type == FRD_DSTLIST) {
ifp = ipf_lookup_res_name(softc, IPL_LOGIPF,
IPLT_DSTLIST,
base + fdp->fd_name,
NULL);
if (ifp == NULL) {
IPFERROR(144);
errval = ESRCH;
}
} else {
ifp = GETIFP(base + fdp->fd_name, v);
if (ifp == NULL)
ifp = (void *)-1;
}
}
fdp->fd_ptr = ifp;
return (errval);
}
void *
ipf_resolvenic(ipf_main_softc_t *softc __unused, char *name, int v)
{
void *nic;
if (name[0] == '\0')
return (NULL);
if ((name[1] == '\0') && ((name[0] == '-') || (name[0] == '*'))) {
return (NULL);
}
nic = GETIFP(name, v);
if (nic == NULL)
nic = (void *)-1;
return (nic);
}
void
ipf_token_expire(ipf_main_softc_t *softc)
{
ipftoken_t *it;
WRITE_ENTER(&softc->ipf_tokens);
while ((it = softc->ipf_token_head) != NULL) {
if (it->ipt_die > softc->ipf_ticks)
break;
ipf_token_deref(softc, it);
}
RWLOCK_EXIT(&softc->ipf_tokens);
}
static void
ipf_token_flush(ipf_main_softc_t *softc)
{
ipftoken_t *it, *next;
WRITE_ENTER(&softc->ipf_tokens);
for (it = softc->ipf_token_head; it != NULL; it = next) {
next = it->ipt_next;
(void) ipf_token_deref(softc, it);
}
RWLOCK_EXIT(&softc->ipf_tokens);
}
int
ipf_token_del(ipf_main_softc_t *softc, int type, int uid, void *ptr)
{
ipftoken_t *it;
int error;
IPFERROR(82);
error = ESRCH;
WRITE_ENTER(&softc->ipf_tokens);
for (it = softc->ipf_token_head; it != NULL; it = it->ipt_next) {
if (ptr == it->ipt_ctx && type == it->ipt_type &&
uid == it->ipt_uid) {
it->ipt_complete = 2;
ipf_token_deref(softc, it);
error = 0;
break;
}
}
RWLOCK_EXIT(&softc->ipf_tokens);
return (error);
}
void
ipf_token_mark_complete(ipftoken_t *token)
{
if (token->ipt_complete == 0)
token->ipt_complete = 1;
}
ipftoken_t *
ipf_token_find(ipf_main_softc_t *softc, int type, int uid, void *ptr)
{
ipftoken_t *it, *new;
KMALLOC(new, ipftoken_t *);
if (new != NULL)
bzero((char *)new, sizeof(*new));
WRITE_ENTER(&softc->ipf_tokens);
for (it = softc->ipf_token_head; it != NULL; it = it->ipt_next) {
if ((ptr == it->ipt_ctx) && (type == it->ipt_type) &&
(uid == it->ipt_uid) && (it->ipt_complete < 2))
break;
}
if (it == NULL) {
it = new;
new = NULL;
if (it == NULL) {
RWLOCK_EXIT(&softc->ipf_tokens);
return (NULL);
}
it->ipt_ctx = ptr;
it->ipt_uid = uid;
it->ipt_type = type;
it->ipt_ref = 1;
} else {
if (new != NULL) {
KFREE(new);
new = NULL;
}
if (it->ipt_complete > 0)
it = NULL;
else
ipf_token_unlink(softc, it);
}
if (it != NULL) {
it->ipt_pnext = softc->ipf_token_tail;
*softc->ipf_token_tail = it;
softc->ipf_token_tail = &it->ipt_next;
it->ipt_next = NULL;
it->ipt_ref++;
it->ipt_die = softc->ipf_ticks + 20;
}
RWLOCK_EXIT(&softc->ipf_tokens);
return (it);
}
static void
ipf_token_unlink(ipf_main_softc_t *softc, ipftoken_t *token)
{
if (softc->ipf_token_tail == &token->ipt_next)
softc->ipf_token_tail = token->ipt_pnext;
*token->ipt_pnext = token->ipt_next;
if (token->ipt_next != NULL)
token->ipt_next->ipt_pnext = token->ipt_pnext;
token->ipt_next = NULL;
token->ipt_pnext = NULL;
}
int
ipf_token_deref(ipf_main_softc_t *softc, ipftoken_t *token)
{
void *data, **datap;
ASSERT(token->ipt_ref > 0);
token->ipt_ref--;
if (token->ipt_ref > 0)
return (token->ipt_ref);
data = token->ipt_data;
datap = &data;
if ((data != NULL) && (data != (void *)-1)) {
switch (token->ipt_type)
{
case IPFGENITER_IPF :
(void) ipf_derefrule(softc, (frentry_t **)datap);
break;
case IPFGENITER_IPNAT :
WRITE_ENTER(&softc->ipf_nat);
ipf_nat_rule_deref(softc, (ipnat_t **)datap);
RWLOCK_EXIT(&softc->ipf_nat);
break;
case IPFGENITER_NAT :
ipf_nat_deref(softc, (nat_t **)datap);
break;
case IPFGENITER_STATE :
ipf_state_deref(softc, (ipstate_t **)datap);
break;
case IPFGENITER_FRAG :
ipf_frag_pkt_deref(softc, (ipfr_t **)datap);
break;
case IPFGENITER_NATFRAG :
ipf_frag_nat_deref(softc, (ipfr_t **)datap);
break;
case IPFGENITER_HOSTMAP :
WRITE_ENTER(&softc->ipf_nat);
ipf_nat_hostmapdel(softc, (hostmap_t **)datap);
RWLOCK_EXIT(&softc->ipf_nat);
break;
default :
ipf_lookup_iterderef(softc, token->ipt_type, data);
break;
}
}
ipf_token_unlink(softc, token);
KFREE(token);
return (0);
}
static frentry_t *
ipf_nextrule(ipf_main_softc_t *softc, int active, int unit, frentry_t *fr,
int out)
{
frentry_t *next;
frgroup_t *fg;
if (fr != NULL && fr->fr_group != -1) {
fg = ipf_findgroup(softc, fr->fr_names + fr->fr_group,
unit, active, NULL);
if (fg != NULL)
fg = fg->fg_next;
} else {
fg = softc->ipf_groups[unit][active];
}
while (fg != NULL) {
next = fg->fg_start;
while (next != NULL) {
if (out) {
if (next->fr_flags & FR_OUTQUE)
return (next);
} else if (next->fr_flags & FR_INQUE) {
return (next);
}
next = next->fr_next;
}
if (next == NULL)
fg = fg->fg_next;
}
return (NULL);
}
int
ipf_getnextrule(ipf_main_softc_t *softc, ipftoken_t *t, void *ptr)
{
frentry_t *fr, *next, zero;
ipfruleiter_t it;
int error, out;
frgroup_t *fg;
ipfobj_t obj;
int predict;
char *dst;
int unit;
if (t == NULL || ptr == NULL) {
IPFERROR(84);
return (EFAULT);
}
error = ipf_inobj(softc, ptr, &obj, &it, IPFOBJ_IPFITER);
if (error != 0)
return (error);
if ((it.iri_inout < 0) || (it.iri_inout > 3)) {
IPFERROR(85);
return (EINVAL);
}
if ((it.iri_active != 0) && (it.iri_active != 1)) {
IPFERROR(86);
return (EINVAL);
}
if (it.iri_nrules == 0) {
IPFERROR(87);
return (ENOSPC);
}
if (it.iri_rule == NULL) {
IPFERROR(88);
return (EFAULT);
}
fg = NULL;
fr = t->ipt_data;
if ((it.iri_inout & F_OUT) != 0)
out = 1;
else
out = 0;
if ((it.iri_inout & F_ACIN) != 0)
unit = IPL_LOGCOUNT;
else
unit = IPL_LOGIPF;
READ_ENTER(&softc->ipf_mutex);
if (fr == NULL) {
if (*it.iri_group == '\0') {
if (unit == IPL_LOGCOUNT) {
next = softc->ipf_acct[out][it.iri_active];
} else {
next = softc->ipf_rules[out][it.iri_active];
}
if (next == NULL)
next = ipf_nextrule(softc, it.iri_active,
unit, NULL, out);
} else {
fg = ipf_findgroup(softc, it.iri_group, unit,
it.iri_active, NULL);
if (fg != NULL)
next = fg->fg_start;
else
next = NULL;
}
} else {
next = fr->fr_next;
if (next == NULL)
next = ipf_nextrule(softc, it.iri_active, unit,
fr, out);
}
if (next != NULL && next->fr_next != NULL)
predict = 1;
else if (ipf_nextrule(softc, it.iri_active, unit, next, out) != NULL)
predict = 1;
else
predict = 0;
if (fr != NULL)
(void) ipf_derefrule(softc, &fr);
obj.ipfo_type = IPFOBJ_FRENTRY;
dst = (char *)it.iri_rule;
if (next != NULL) {
obj.ipfo_size = next->fr_size;
MUTEX_ENTER(&next->fr_lock);
next->fr_ref++;
MUTEX_EXIT(&next->fr_lock);
t->ipt_data = next;
} else {
obj.ipfo_size = sizeof(frentry_t);
bzero(&zero, sizeof(zero));
next = &zero;
t->ipt_data = NULL;
}
it.iri_rule = predict ? next : NULL;
if (predict == 0)
ipf_token_mark_complete(t);
RWLOCK_EXIT(&softc->ipf_mutex);
obj.ipfo_ptr = dst;
error = ipf_outobjk(softc, &obj, next);
if (error == 0 && t->ipt_data != NULL) {
dst += obj.ipfo_size;
if (next->fr_data != NULL) {
ipfobj_t dobj;
if (next->fr_type == FR_T_IPFEXPR)
dobj.ipfo_type = IPFOBJ_IPFEXPR;
else
dobj.ipfo_type = IPFOBJ_FRIPF;
dobj.ipfo_size = next->fr_dsize;
dobj.ipfo_rev = obj.ipfo_rev;
dobj.ipfo_ptr = dst;
error = ipf_outobjk(softc, &dobj, next->fr_data);
}
}
if ((fr != NULL) && (next == &zero))
(void) ipf_derefrule(softc, &fr);
return (error);
}
static int
ipf_frruleiter(ipf_main_softc_t *softc, void *data, int uid, void *ctx)
{
ipftoken_t *token;
ipfruleiter_t it;
ipfobj_t obj;
int error;
token = ipf_token_find(softc, IPFGENITER_IPF, uid, ctx);
if (token != NULL) {
error = ipf_getnextrule(softc, token, data);
WRITE_ENTER(&softc->ipf_tokens);
ipf_token_deref(softc, token);
RWLOCK_EXIT(&softc->ipf_tokens);
} else {
error = ipf_inobj(softc, data, &obj, &it, IPFOBJ_IPFITER);
if (error != 0)
return (error);
it.iri_rule = NULL;
error = ipf_outobj(softc, data, &it, IPFOBJ_IPFITER);
}
return (error);
}
static int
ipf_geniter(ipf_main_softc_t *softc, ipftoken_t *token, ipfgeniter_t *itp)
{
int error;
switch (itp->igi_type)
{
case IPFGENITER_FRAG :
error = ipf_frag_pkt_next(softc, token, itp);
break;
default :
IPFERROR(92);
error = EINVAL;
break;
}
return (error);
}
int
ipf_genericiter(ipf_main_softc_t *softc, void *data, int uid, void *ctx)
{
ipftoken_t *token;
ipfgeniter_t iter;
int error;
error = ipf_inobj(softc, data, NULL, &iter, IPFOBJ_GENITER);
if (error != 0)
return (error);
token = ipf_token_find(softc, iter.igi_type, uid, ctx);
if (token != NULL) {
token->ipt_subtype = iter.igi_type;
error = ipf_geniter(softc, token, &iter);
WRITE_ENTER(&softc->ipf_tokens);
ipf_token_deref(softc, token);
RWLOCK_EXIT(&softc->ipf_tokens);
} else {
IPFERROR(93);
error = 0;
}
return (error);
}
int
ipf_ipf_ioctl(ipf_main_softc_t *softc, caddr_t data, ioctlcmd_t cmd, int mode,
int uid, void *ctx)
{
friostat_t fio;
int error, tmp;
ipfobj_t obj;
SPL_INT(s);
switch (cmd)
{
case SIOCFRENB :
if (!(mode & FWRITE)) {
IPFERROR(94);
error = EPERM;
} else {
error = BCOPYIN(data, &tmp, sizeof(tmp));
if (error != 0) {
IPFERROR(95);
error = EFAULT;
break;
}
WRITE_ENTER(&softc->ipf_global);
if (tmp) {
if (softc->ipf_running > 0)
error = 0;
else
error = ipfattach(softc);
if (error == 0)
softc->ipf_running = 1;
else
(void) ipfdetach(softc);
} else {
if (softc->ipf_running == 1)
error = ipfdetach(softc);
else
error = 0;
if (error == 0)
softc->ipf_running = -1;
}
RWLOCK_EXIT(&softc->ipf_global);
}
break;
case SIOCIPFSET :
if (!(mode & FWRITE)) {
IPFERROR(96);
error = EPERM;
break;
}
case SIOCIPFGETNEXT :
case SIOCIPFGET :
error = ipf_ipftune(softc, cmd, (void *)data);
break;
case SIOCSETFF :
if (!(mode & FWRITE)) {
IPFERROR(97);
error = EPERM;
} else {
error = BCOPYIN(data, &softc->ipf_flags,
sizeof(softc->ipf_flags));
if (error != 0) {
IPFERROR(98);
error = EFAULT;
}
}
break;
case SIOCGETFF :
error = BCOPYOUT(&softc->ipf_flags, data,
sizeof(softc->ipf_flags));
if (error != 0) {
IPFERROR(99);
error = EFAULT;
}
break;
case SIOCFUNCL :
error = ipf_resolvefunc(softc, (void *)data);
break;
case SIOCINAFR :
case SIOCRMAFR :
case SIOCADAFR :
case SIOCZRLST :
if (!(mode & FWRITE)) {
IPFERROR(100);
error = EPERM;
} else {
error = frrequest(softc, IPL_LOGIPF, cmd, (caddr_t)data,
softc->ipf_active, 1);
}
break;
case SIOCINIFR :
case SIOCRMIFR :
case SIOCADIFR :
if (!(mode & FWRITE)) {
IPFERROR(101);
error = EPERM;
} else {
error = frrequest(softc, IPL_LOGIPF, cmd, (caddr_t)data,
1 - softc->ipf_active, 1);
}
break;
case SIOCSWAPA :
if (!(mode & FWRITE)) {
IPFERROR(102);
error = EPERM;
} else {
WRITE_ENTER(&softc->ipf_mutex);
error = BCOPYOUT(&softc->ipf_active, data,
sizeof(softc->ipf_active));
if (error != 0) {
IPFERROR(103);
error = EFAULT;
} else {
softc->ipf_active = 1 - softc->ipf_active;
}
RWLOCK_EXIT(&softc->ipf_mutex);
}
break;
case SIOCGETFS :
error = ipf_inobj(softc, (void *)data, &obj, &fio,
IPFOBJ_IPFSTAT);
if (error != 0)
break;
ipf_getstat(softc, &fio, obj.ipfo_rev);
error = ipf_outobj(softc, (void *)data, &fio, IPFOBJ_IPFSTAT);
break;
case SIOCFRZST :
if (!(mode & FWRITE)) {
IPFERROR(104);
error = EPERM;
} else
error = ipf_zerostats(softc, (caddr_t)data);
break;
case SIOCIPFFL :
if (!(mode & FWRITE)) {
IPFERROR(105);
error = EPERM;
} else {
error = BCOPYIN(data, &tmp, sizeof(tmp));
if (!error) {
tmp = ipf_flush(softc, IPL_LOGIPF, tmp);
error = BCOPYOUT(&tmp, data, sizeof(tmp));
if (error != 0) {
IPFERROR(106);
error = EFAULT;
}
} else {
IPFERROR(107);
error = EFAULT;
}
}
break;
#ifdef USE_INET6
case SIOCIPFL6 :
if (!(mode & FWRITE)) {
IPFERROR(108);
error = EPERM;
} else {
error = BCOPYIN(data, &tmp, sizeof(tmp));
if (!error) {
tmp = ipf_flush(softc, IPL_LOGIPF, tmp);
error = BCOPYOUT(&tmp, data, sizeof(tmp));
if (error != 0) {
IPFERROR(109);
error = EFAULT;
}
} else {
IPFERROR(110);
error = EFAULT;
}
}
break;
#endif
case SIOCSTLCK :
if (!(mode & FWRITE)) {
IPFERROR(122);
error = EPERM;
} else {
error = BCOPYIN(data, &tmp, sizeof(tmp));
if (error == 0) {
ipf_state_setlock(softc->ipf_state_soft, tmp);
ipf_nat_setlock(softc->ipf_nat_soft, tmp);
ipf_frag_setlock(softc->ipf_frag_soft, tmp);
ipf_auth_setlock(softc->ipf_auth_soft, tmp);
} else {
IPFERROR(111);
error = EFAULT;
}
}
break;
#ifdef IPFILTER_LOG
case SIOCIPFFB :
if (!(mode & FWRITE)) {
IPFERROR(112);
error = EPERM;
} else {
tmp = ipf_log_clear(softc, IPL_LOGIPF);
error = BCOPYOUT(&tmp, data, sizeof(tmp));
if (error) {
IPFERROR(113);
error = EFAULT;
}
}
break;
#endif
case SIOCFRSYN :
if (!(mode & FWRITE)) {
IPFERROR(114);
error = EPERM;
} else {
WRITE_ENTER(&softc->ipf_global);
#if (SOLARIS && defined(_KERNEL)) && !defined(INSTANCES)
error = ipfsync();
#else
ipf_sync(softc, NULL);
error = 0;
#endif
RWLOCK_EXIT(&softc->ipf_global);
}
break;
case SIOCGFRST :
error = ipf_outobj(softc, (void *)data,
ipf_frag_stats(softc->ipf_frag_soft),
IPFOBJ_FRAGSTAT);
break;
#ifdef IPFILTER_LOG
case FIONREAD :
tmp = ipf_log_bytesused(softc, IPL_LOGIPF);
error = BCOPYOUT(&tmp, data, sizeof(tmp));
break;
#endif
case SIOCIPFITER :
SPL_SCHED(s);
error = ipf_frruleiter(softc, data, uid, ctx);
SPL_X(s);
break;
case SIOCGENITER :
SPL_SCHED(s);
error = ipf_genericiter(softc, data, uid, ctx);
SPL_X(s);
break;
case SIOCIPFDELTOK :
error = BCOPYIN(data, &tmp, sizeof(tmp));
if (error == 0) {
SPL_SCHED(s);
error = ipf_token_del(softc, tmp, uid, ctx);
SPL_X(s);
}
break;
default :
IPFERROR(115);
error = EINVAL;
break;
}
return (error);
}
u_32_t
ipf_decaps(fr_info_t *fin, u_32_t pass, int l5proto)
{
fr_info_t fin2, *fino = NULL;
int elen, hlen, nh;
grehdr_t gre;
ip_t *ip;
mb_t *m;
if ((fin->fin_flx & FI_COALESCE) == 0)
if (ipf_coalesce(fin) == -1)
goto cantdecaps;
m = fin->fin_m;
hlen = fin->fin_hlen;
switch (fin->fin_p)
{
case IPPROTO_UDP :
nh = fin->fin_fr->fr_icode;
break;
case IPPROTO_GRE :
bcopy(fin->fin_dp, (char *)&gre, sizeof(gre));
hlen += sizeof(grehdr_t);
if (gre.gr_R|gre.gr_s)
goto cantdecaps;
if (gre.gr_C)
hlen += 4;
if (gre.gr_K)
hlen += 4;
if (gre.gr_S)
hlen += 4;
nh = IPPROTO_IP;
#if 0
if (gre.gr_R) {
u_char off, len, *s;
u_short af;
int end;
end = 0;
s = fin->fin_dp;
s += hlen;
aplen = fin->fin_plen - hlen;
while (aplen > 3) {
af = (s[0] << 8) | s[1];
off = s[2];
len = s[3];
aplen -= 4;
s += 4;
if (af == 0 && len == 0) {
end = 1;
break;
}
if (aplen < len)
break;
s += len;
aplen -= len;
}
if (end != 1)
goto cantdecaps;
hlen = s - (u_char *)fin->fin_dp;
}
#endif
break;
#ifdef IPPROTO_IPIP
case IPPROTO_IPIP :
#endif
nh = IPPROTO_IP;
break;
default :
goto cantdecaps;
}
switch (nh)
{
case IPPROTO_IP :
case IPPROTO_IPV6 :
break;
default :
goto cantdecaps;
}
bcopy((char *)fin, (char *)&fin2, sizeof(fin2));
fino = fin;
fin = &fin2;
elen = hlen;
#if SOLARIS && defined(_KERNEL)
m->b_rptr += elen;
#else
m->m_data += elen;
m->m_len -= elen;
#endif
fin->fin_plen -= elen;
ip = (ip_t *)((char *)fin->fin_ip + elen);
if (IP_V(ip) == 4)
hlen = IP_HL(ip) << 2;
#ifdef USE_INET6
else if (IP_V(ip) == 6)
hlen = sizeof(ip6_t);
#endif
else
goto cantdecaps2;
if (fin->fin_plen < hlen)
goto cantdecaps2;
fin->fin_dp = (char *)ip + hlen;
if (IP_V(ip) == 4) {
if (ipf_cksum((u_short *)ip, hlen))
goto cantdecaps2;
}
if (ipf_makefrip(hlen, ip, fin) == -1) {
cantdecaps2:
if (m != NULL) {
#if SOLARIS && defined(_KERNEL)
m->b_rptr -= elen;
#else
m->m_data -= elen;
m->m_len += elen;
#endif
}
cantdecaps:
DT1(frb_decapfrip, fr_info_t *, fin);
pass &= ~FR_CMDMASK;
pass |= FR_BLOCK|FR_QUICK;
fin->fin_reason = FRB_DECAPFRIP;
return (-1);
}
pass = ipf_scanlist(fin, pass);
fino->fin_flx = fin->fin_flx;
fino->fin_rev = fin->fin_rev;
fino->fin_icode = fin->fin_icode;
fino->fin_rule = fin->fin_rule;
(void) strncpy(fino->fin_group, fin->fin_group, FR_GROUPLEN);
fino->fin_fr = fin->fin_fr;
fino->fin_error = fin->fin_error;
fino->fin_mp = fin->fin_mp;
fino->fin_m = fin->fin_m;
m = fin->fin_m;
if (m != NULL) {
#if SOLARIS && defined(_KERNEL)
m->b_rptr -= elen;
#else
m->m_data -= elen;
m->m_len += elen;
#endif
}
return (pass);
}
int
ipf_matcharray_load(ipf_main_softc_t *softc, caddr_t data, ipfobj_t *objp,
int **arrayptr)
{
int arraysize, *array, error;
*arrayptr = NULL;
error = BCOPYIN(data, objp, sizeof(*objp));
if (error != 0) {
IPFERROR(116);
return (EFAULT);
}
if (objp->ipfo_type != IPFOBJ_IPFEXPR) {
IPFERROR(117);
return (EINVAL);
}
if (((objp->ipfo_size & 3) != 0) || (objp->ipfo_size == 0) ||
(objp->ipfo_size > 1024)) {
IPFERROR(118);
return (EINVAL);
}
arraysize = objp->ipfo_size * sizeof(*array);
KMALLOCS(array, int *, arraysize);
if (array == NULL) {
IPFERROR(119);
return (ENOMEM);
}
error = COPYIN(objp->ipfo_ptr, array, arraysize);
if (error != 0) {
KFREES(array, arraysize);
IPFERROR(120);
return (EFAULT);
}
if (ipf_matcharray_verify(array, arraysize) != 0) {
KFREES(array, arraysize);
IPFERROR(121);
return (EINVAL);
}
*arrayptr = array;
return (0);
}
int
ipf_matcharray_verify(int *array, int arraysize)
{
u_int i, nelem, maxidx;
ipfexp_t *e;
nelem = arraysize / sizeof(*array);
if ((array[0] < 6) || (arraysize < 24) || (arraysize > 4096)) {
return (-1);
}
if (array[0] * sizeof(*array) != arraysize) {
return (-1);
}
maxidx = nelem - 1;
if (array[maxidx] != IPF_EXP_END) {
return (-1);
}
for (i = 1; i < maxidx; ) {
e = (ipfexp_t *)(array + i);
if ((e->ipfe_size < 1 ) ||
(e->ipfe_size + i > maxidx)) {
return (-1);
}
i += e->ipfe_size;
}
return (0);
}
static int
ipf_fr_matcharray(fr_info_t *fin, int *array)
{
u_int i, n, *x, rv, p;
ipfexp_t *e;
rv = 0;
n = array[0];
x = array + 1;
for (; n > 0; x += 3 + x[3], rv = 0) {
e = (ipfexp_t *)x;
if (e->ipfe_cmd == IPF_EXP_END)
break;
n -= e->ipfe_size;
p = e->ipfe_cmd >> 16;
if ((p != 0) && (p != fin->fin_p))
break;
switch (e->ipfe_cmd)
{
case IPF_EXP_IP_PR :
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= (fin->fin_p == e->ipfe_arg0[i]);
}
break;
case IPF_EXP_IP_SRCADDR :
if (fin->fin_v != 4)
break;
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= ((fin->fin_saddr &
e->ipfe_arg0[i * 2 + 1]) ==
e->ipfe_arg0[i * 2]);
}
break;
case IPF_EXP_IP_DSTADDR :
if (fin->fin_v != 4)
break;
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= ((fin->fin_daddr &
e->ipfe_arg0[i * 2 + 1]) ==
e->ipfe_arg0[i * 2]);
}
break;
case IPF_EXP_IP_ADDR :
if (fin->fin_v != 4)
break;
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= ((fin->fin_saddr &
e->ipfe_arg0[i * 2 + 1]) ==
e->ipfe_arg0[i * 2]) ||
((fin->fin_daddr &
e->ipfe_arg0[i * 2 + 1]) ==
e->ipfe_arg0[i * 2]);
}
break;
#ifdef USE_INET6
case IPF_EXP_IP6_SRCADDR :
if (fin->fin_v != 6)
break;
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= IP6_MASKEQ(&fin->fin_src6,
&e->ipfe_arg0[i * 8 + 4],
&e->ipfe_arg0[i * 8]);
}
break;
case IPF_EXP_IP6_DSTADDR :
if (fin->fin_v != 6)
break;
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= IP6_MASKEQ(&fin->fin_dst6,
&e->ipfe_arg0[i * 8 + 4],
&e->ipfe_arg0[i * 8]);
}
break;
case IPF_EXP_IP6_ADDR :
if (fin->fin_v != 6)
break;
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= IP6_MASKEQ(&fin->fin_src6,
&e->ipfe_arg0[i * 8 + 4],
&e->ipfe_arg0[i * 8]) ||
IP6_MASKEQ(&fin->fin_dst6,
&e->ipfe_arg0[i * 8 + 4],
&e->ipfe_arg0[i * 8]);
}
break;
#endif
case IPF_EXP_UDP_PORT :
case IPF_EXP_TCP_PORT :
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= (fin->fin_sport == e->ipfe_arg0[i]) ||
(fin->fin_dport == e->ipfe_arg0[i]);
}
break;
case IPF_EXP_UDP_SPORT :
case IPF_EXP_TCP_SPORT :
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= (fin->fin_sport == e->ipfe_arg0[i]);
}
break;
case IPF_EXP_UDP_DPORT :
case IPF_EXP_TCP_DPORT :
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= (fin->fin_dport == e->ipfe_arg0[i]);
}
break;
case IPF_EXP_TCP_FLAGS :
for (i = 0; !rv && i < e->ipfe_narg; i++) {
rv |= ((fin->fin_tcpf &
e->ipfe_arg0[i * 2 + 1]) ==
e->ipfe_arg0[i * 2]);
}
break;
}
rv ^= e->ipfe_not;
if (rv == 0)
break;
}
return (rv);
}
int
ipf_queueflush(ipf_main_softc_t *softc, ipftq_delete_fn_t deletefn,
ipftq_t *ipfqs, ipftq_t *userqs, u_int *activep, int size, int low)
{
u_long interval, istart, iend;
ipftq_t *ifq, *ifqnext;
ipftqent_t *tqe, *tqn;
int removed = 0;
for (tqn = ipfqs[IPF_TCPS_CLOSED].ifq_head; ((tqe = tqn) != NULL); ) {
tqn = tqe->tqe_next;
if ((*deletefn)(softc, tqe->tqe_parent) == 0)
removed++;
}
if ((*activep * 100 / size) > low) {
for (tqn = ipfqs[IPF_TCPS_TIME_WAIT].ifq_head;
((tqe = tqn) != NULL); ) {
tqn = tqe->tqe_next;
if ((*deletefn)(softc, tqe->tqe_parent) == 0)
removed++;
}
}
if ((*activep * 100 / size) <= low) {
return (removed);
}
if (softc->ipf_ticks > IPF_TTLVAL(43200 * 15 / 10)) {
istart = IPF_TTLVAL(86400 * 4);
interval = IPF_TTLVAL(43200);
} else if (softc->ipf_ticks > IPF_TTLVAL(1800 * 15 / 10)) {
istart = IPF_TTLVAL(43200);
interval = IPF_TTLVAL(1800);
} else if (softc->ipf_ticks > IPF_TTLVAL(30 * 15 / 10)) {
istart = IPF_TTLVAL(1800);
interval = IPF_TTLVAL(30);
} else {
return (0);
}
if (istart > softc->ipf_ticks) {
if (softc->ipf_ticks - interval < interval)
istart = interval;
else
istart = (softc->ipf_ticks / interval) * interval;
}
iend = softc->ipf_ticks - interval;
while ((*activep * 100 / size) > low) {
u_long try;
try = softc->ipf_ticks - istart;
for (ifq = ipfqs; ifq != NULL; ifq = ifq->ifq_next) {
for (tqn = ifq->ifq_head; ((tqe = tqn) != NULL); ) {
if (try < tqe->tqe_touched)
break;
tqn = tqe->tqe_next;
if ((*deletefn)(softc, tqe->tqe_parent) == 0)
removed++;
}
}
for (ifq = userqs; ifq != NULL; ifq = ifqnext) {
ifqnext = ifq->ifq_next;
for (tqn = ifq->ifq_head; ((tqe = tqn) != NULL); ) {
if (try < tqe->tqe_touched)
break;
tqn = tqe->tqe_next;
if ((*deletefn)(softc, tqe->tqe_parent) == 0)
removed++;
}
}
if (try >= iend) {
if (interval == IPF_TTLVAL(43200)) {
interval = IPF_TTLVAL(1800);
} else if (interval == IPF_TTLVAL(1800)) {
interval = IPF_TTLVAL(30);
} else {
break;
}
if (interval >= softc->ipf_ticks)
break;
iend = softc->ipf_ticks - interval;
}
istart -= interval;
}
return (removed);
}
int
ipf_deliverlocal(ipf_main_softc_t *softc, int ipversion, void *ifp,
i6addr_t *ipaddr)
{
i6addr_t addr;
int islocal = 0;
if (ipversion == 4) {
if (ipf_ifpaddr(softc, 4, FRI_NORMAL, ifp, &addr, NULL) == 0) {
if (addr.in4.s_addr == ipaddr->in4.s_addr)
islocal = 1;
}
#ifdef USE_INET6
} else if (ipversion == 6) {
if (ipf_ifpaddr(softc, 6, FRI_NORMAL, ifp, &addr, NULL) == 0) {
if (IP6_EQ(&addr, ipaddr))
islocal = 1;
}
#endif
}
return (islocal);
}
static int
ipf_settimeout(struct ipf_main_softc_s *softc, ipftuneable_t *t,
ipftuneval_t *p)
{
if (ipf_state_settimeout(softc, t, p) == -1)
return (-1);
if (ipf_nat_settimeout(softc, t, p) == -1)
return (-1);
return (0);
}
void
ipf_apply_timeout(ipftq_t *head, u_int seconds)
{
u_int oldtimeout, newtimeout;
ipftqent_t *tqe;
int delta;
MUTEX_ENTER(&head->ifq_lock);
oldtimeout = head->ifq_ttl;
newtimeout = IPF_TTLVAL(seconds);
delta = oldtimeout - newtimeout;
head->ifq_ttl = newtimeout;
for (tqe = head->ifq_head; tqe != NULL; tqe = tqe->tqe_next) {
tqe->tqe_die += delta;
}
MUTEX_EXIT(&head->ifq_lock);
}
int
ipf_settimeout_tcp(ipftuneable_t *t, ipftuneval_t *p, ipftq_t *tab)
{
if (!strcmp(t->ipft_name, "tcp_idle_timeout") ||
!strcmp(t->ipft_name, "tcp_established")) {
ipf_apply_timeout(&tab[IPF_TCPS_ESTABLISHED], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_close_wait")) {
ipf_apply_timeout(&tab[IPF_TCPS_CLOSE_WAIT], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_last_ack")) {
ipf_apply_timeout(&tab[IPF_TCPS_LAST_ACK], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_timeout")) {
ipf_apply_timeout(&tab[IPF_TCPS_LISTEN], p->ipftu_int);
ipf_apply_timeout(&tab[IPF_TCPS_HALF_ESTAB], p->ipftu_int);
ipf_apply_timeout(&tab[IPF_TCPS_CLOSING], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_listen")) {
ipf_apply_timeout(&tab[IPF_TCPS_LISTEN], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_half_established")) {
ipf_apply_timeout(&tab[IPF_TCPS_HALF_ESTAB], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_closing")) {
ipf_apply_timeout(&tab[IPF_TCPS_CLOSING], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_syn_received")) {
ipf_apply_timeout(&tab[IPF_TCPS_SYN_RECEIVED], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_syn_sent")) {
ipf_apply_timeout(&tab[IPF_TCPS_SYN_SENT], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_closed")) {
ipf_apply_timeout(&tab[IPF_TCPS_CLOSED], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_half_closed")) {
ipf_apply_timeout(&tab[IPF_TCPS_CLOSED], p->ipftu_int);
} else if (!strcmp(t->ipft_name, "tcp_time_wait")) {
ipf_apply_timeout(&tab[IPF_TCPS_TIME_WAIT], p->ipftu_int);
} else {
return (-1);
}
return (0);
}
void *
ipf_main_soft_create(void *arg)
{
ipf_main_softc_t *softc;
if (arg == NULL) {
KMALLOC(softc, ipf_main_softc_t *);
if (softc == NULL)
return (NULL);
} else {
softc = arg;
}
bzero((char *)softc, sizeof(*softc));
softc->ipf_dynamic_softc = (arg == NULL) ? 1 : 0;
softc->ipf_tuners = ipf_tune_array_copy(softc,
sizeof(ipf_main_tuneables),
ipf_main_tuneables);
if (softc->ipf_tuners == NULL) {
ipf_main_soft_destroy(softc);
return (NULL);
}
MUTEX_INIT(&softc->ipf_rw, "ipf rw mutex");
MUTEX_INIT(&softc->ipf_timeoutlock, "ipf timeout lock");
RWLOCK_INIT(&softc->ipf_global, "ipf filter load/unload mutex");
RWLOCK_INIT(&softc->ipf_mutex, "ipf filter rwlock");
RWLOCK_INIT(&softc->ipf_tokens, "ipf token rwlock");
RWLOCK_INIT(&softc->ipf_state, "ipf state rwlock");
RWLOCK_INIT(&softc->ipf_nat, "ipf IP NAT rwlock");
RWLOCK_INIT(&softc->ipf_poolrw, "ipf pool rwlock");
RWLOCK_INIT(&softc->ipf_frag, "ipf frag rwlock");
softc->ipf_token_head = NULL;
softc->ipf_token_tail = &softc->ipf_token_head;
softc->ipf_tcpidletimeout = FIVE_DAYS;
softc->ipf_tcpclosewait = IPF_TTLVAL(2 * TCP_MSL);
softc->ipf_tcplastack = IPF_TTLVAL(30);
softc->ipf_tcptimewait = IPF_TTLVAL(2 * TCP_MSL);
softc->ipf_tcptimeout = IPF_TTLVAL(2 * TCP_MSL);
softc->ipf_tcpsynsent = IPF_TTLVAL(2 * TCP_MSL);
softc->ipf_tcpsynrecv = IPF_TTLVAL(2 * TCP_MSL);
softc->ipf_tcpclosed = IPF_TTLVAL(30);
softc->ipf_tcphalfclosed = IPF_TTLVAL(2 * 3600);
softc->ipf_udptimeout = IPF_TTLVAL(120);
softc->ipf_udpacktimeout = IPF_TTLVAL(12);
softc->ipf_icmptimeout = IPF_TTLVAL(60);
softc->ipf_icmpacktimeout = IPF_TTLVAL(6);
softc->ipf_iptimeout = IPF_TTLVAL(60);
#if defined(IPFILTER_DEFAULT_BLOCK)
softc->ipf_pass = FR_BLOCK|FR_NOMATCH;
#else
softc->ipf_pass = (IPF_DEFAULT_PASS)|FR_NOMATCH;
#endif
softc->ipf_minttl = 4;
softc->ipf_icmpminfragmtu = 68;
softc->ipf_max_namelen = 128;
softc->ipf_flags = IPF_LOGGING;
softc->ipf_jail_allowed = 0;
#ifdef LARGE_NAT
softc->ipf_large_nat = 1;
#endif
ipf_fbsd_kenv_get(softc);
return (softc);
}
int
ipf_main_soft_init(ipf_main_softc_t *softc)
{
return (0);
}
void
ipf_main_soft_destroy(ipf_main_softc_t *softc)
{
RW_DESTROY(&softc->ipf_frag);
RW_DESTROY(&softc->ipf_poolrw);
RW_DESTROY(&softc->ipf_nat);
RW_DESTROY(&softc->ipf_state);
RW_DESTROY(&softc->ipf_tokens);
RW_DESTROY(&softc->ipf_mutex);
RW_DESTROY(&softc->ipf_global);
MUTEX_DESTROY(&softc->ipf_timeoutlock);
MUTEX_DESTROY(&softc->ipf_rw);
if (softc->ipf_tuners != NULL) {
KFREES(softc->ipf_tuners, sizeof(ipf_main_tuneables));
}
if (softc->ipf_dynamic_softc == 1) {
KFREE(softc);
}
}
int
ipf_main_soft_fini(ipf_main_softc_t *softc)
{
(void) ipf_flush(softc, IPL_LOGIPF, FR_INQUE|FR_OUTQUE|FR_INACTIVE);
(void) ipf_flush(softc, IPL_LOGIPF, FR_INQUE|FR_OUTQUE);
(void) ipf_flush(softc, IPL_LOGCOUNT, FR_INQUE|FR_OUTQUE|FR_INACTIVE);
(void) ipf_flush(softc, IPL_LOGCOUNT, FR_INQUE|FR_OUTQUE);
return (0);
}
int
ipf_main_load(void)
{
int i;
for (i = 0; i <= ICMP_MAXTYPE; i++)
icmpreplytype4[i] = -1;
icmpreplytype4[ICMP_ECHO] = ICMP_ECHOREPLY;
icmpreplytype4[ICMP_TSTAMP] = ICMP_TSTAMPREPLY;
icmpreplytype4[ICMP_IREQ] = ICMP_IREQREPLY;
icmpreplytype4[ICMP_MASKREQ] = ICMP_MASKREPLY;
#ifdef USE_INET6
for (i = 0; i <= ICMP6_MAXTYPE; i++)
icmpreplytype6[i] = -1;
icmpreplytype6[ICMP6_ECHO_REQUEST] = ICMP6_ECHO_REPLY;
icmpreplytype6[ICMP6_MEMBERSHIP_QUERY] = ICMP6_MEMBERSHIP_REPORT;
icmpreplytype6[ICMP6_NI_QUERY] = ICMP6_NI_REPLY;
icmpreplytype6[ND_ROUTER_SOLICIT] = ND_ROUTER_ADVERT;
icmpreplytype6[ND_NEIGHBOR_SOLICIT] = ND_NEIGHBOR_ADVERT;
#endif
return (0);
}
int
ipf_main_unload(void)
{
return (0);
}
int
ipf_load_all(void)
{
if (ipf_main_load() == -1)
return (-1);
if (ipf_state_main_load() == -1)
return (-1);
if (ipf_nat_main_load() == -1)
return (-1);
if (ipf_frag_main_load() == -1)
return (-1);
if (ipf_auth_main_load() == -1)
return (-1);
if (ipf_proxy_main_load() == -1)
return (-1);
return (0);
}
int
ipf_unload_all(void)
{
if (ipf_proxy_main_unload() == -1)
return (-1);
if (ipf_auth_main_unload() == -1)
return (-1);
if (ipf_frag_main_unload() == -1)
return (-1);
if (ipf_nat_main_unload() == -1)
return (-1);
if (ipf_state_main_unload() == -1)
return (-1);
if (ipf_main_unload() == -1)
return (-1);
return (0);
}
ipf_main_softc_t *
ipf_create_all(void *arg)
{
ipf_main_softc_t *softc;
softc = ipf_main_soft_create(arg);
if (softc == NULL)
return (NULL);
#ifdef IPFILTER_LOG
softc->ipf_log_soft = ipf_log_soft_create(softc);
if (softc->ipf_log_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
#endif
softc->ipf_lookup_soft = ipf_lookup_soft_create(softc);
if (softc->ipf_lookup_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
softc->ipf_sync_soft = ipf_sync_soft_create(softc);
if (softc->ipf_sync_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
softc->ipf_state_soft = ipf_state_soft_create(softc);
if (softc->ipf_state_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
softc->ipf_nat_soft = ipf_nat_soft_create(softc);
if (softc->ipf_nat_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
softc->ipf_frag_soft = ipf_frag_soft_create(softc);
if (softc->ipf_frag_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
softc->ipf_auth_soft = ipf_auth_soft_create(softc);
if (softc->ipf_auth_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
softc->ipf_proxy_soft = ipf_proxy_soft_create(softc);
if (softc->ipf_proxy_soft == NULL) {
ipf_destroy_all(softc);
return (NULL);
}
return (softc);
}
void
ipf_destroy_all(ipf_main_softc_t *softc)
{
if (softc->ipf_state_soft != NULL) {
ipf_state_soft_destroy(softc, softc->ipf_state_soft);
softc->ipf_state_soft = NULL;
}
if (softc->ipf_nat_soft != NULL) {
ipf_nat_soft_destroy(softc, softc->ipf_nat_soft);
softc->ipf_nat_soft = NULL;
}
if (softc->ipf_frag_soft != NULL) {
ipf_frag_soft_destroy(softc, softc->ipf_frag_soft);
softc->ipf_frag_soft = NULL;
}
if (softc->ipf_auth_soft != NULL) {
ipf_auth_soft_destroy(softc, softc->ipf_auth_soft);
softc->ipf_auth_soft = NULL;
}
if (softc->ipf_proxy_soft != NULL) {
ipf_proxy_soft_destroy(softc, softc->ipf_proxy_soft);
softc->ipf_proxy_soft = NULL;
}
if (softc->ipf_sync_soft != NULL) {
ipf_sync_soft_destroy(softc, softc->ipf_sync_soft);
softc->ipf_sync_soft = NULL;
}
if (softc->ipf_lookup_soft != NULL) {
ipf_lookup_soft_destroy(softc, softc->ipf_lookup_soft);
softc->ipf_lookup_soft = NULL;
}
#ifdef IPFILTER_LOG
if (softc->ipf_log_soft != NULL) {
ipf_log_soft_destroy(softc, softc->ipf_log_soft);
softc->ipf_log_soft = NULL;
}
#endif
ipf_main_soft_destroy(softc);
}
int
ipf_init_all(ipf_main_softc_t *softc)
{
if (ipf_main_soft_init(softc) == -1)
return (-1);
#ifdef IPFILTER_LOG
if (ipf_log_soft_init(softc, softc->ipf_log_soft) == -1)
return (-1);
#endif
if (ipf_lookup_soft_init(softc, softc->ipf_lookup_soft) == -1)
return (-1);
if (ipf_sync_soft_init(softc, softc->ipf_sync_soft) == -1)
return (-1);
if (ipf_state_soft_init(softc, softc->ipf_state_soft) == -1)
return (-1);
if (ipf_nat_soft_init(softc, softc->ipf_nat_soft) == -1)
return (-1);
if (ipf_frag_soft_init(softc, softc->ipf_frag_soft) == -1)
return (-1);
if (ipf_auth_soft_init(softc, softc->ipf_auth_soft) == -1)
return (-1);
if (ipf_proxy_soft_init(softc, softc->ipf_proxy_soft) == -1)
return (-1);
return (0);
}
int
ipf_fini_all(ipf_main_softc_t *softc)
{
ipf_token_flush(softc);
if (ipf_proxy_soft_fini(softc, softc->ipf_proxy_soft) == -1)
return (-1);
if (ipf_auth_soft_fini(softc, softc->ipf_auth_soft) == -1)
return (-1);
if (ipf_frag_soft_fini(softc, softc->ipf_frag_soft) == -1)
return (-1);
if (ipf_nat_soft_fini(softc, softc->ipf_nat_soft) == -1)
return (-1);
if (ipf_state_soft_fini(softc, softc->ipf_state_soft) == -1)
return (-1);
if (ipf_sync_soft_fini(softc, softc->ipf_sync_soft) == -1)
return (-1);
if (ipf_lookup_soft_fini(softc, softc->ipf_lookup_soft) == -1)
return (-1);
#ifdef IPFILTER_LOG
if (ipf_log_soft_fini(softc, softc->ipf_log_soft) == -1)
return (-1);
#endif
if (ipf_main_soft_fini(softc) == -1)
return (-1);
return (0);
}
void
ipf_rule_expire(ipf_main_softc_t *softc)
{
frentry_t *fr;
if ((softc->ipf_rule_explist[0] == NULL) &&
(softc->ipf_rule_explist[1] == NULL))
return;
WRITE_ENTER(&softc->ipf_mutex);
while ((fr = softc->ipf_rule_explist[0]) != NULL) {
if (fr->fr_die > softc->ipf_ticks)
break;
ipf_rule_delete(softc, fr, IPL_LOGIPF, 0);
}
while ((fr = softc->ipf_rule_explist[1]) != NULL) {
if (fr->fr_die > softc->ipf_ticks)
break;
ipf_rule_delete(softc, fr, IPL_LOGIPF, 1);
}
RWLOCK_EXIT(&softc->ipf_mutex);
}
static int ipf_ht_node_cmp(struct host_node_s *, struct host_node_s *);
static void ipf_ht_node_make_key(host_track_t *, host_node_t *, int,
i6addr_t *);
host_node_t RBI_ZERO(ipf_rb);
RBI_CODE(ipf_rb, host_node_t, hn_entry, ipf_ht_node_cmp)
static int
ipf_ht_node_cmp(struct host_node_s *k1, struct host_node_s *k2)
{
int i;
i = (k2->hn_addr.adf_family - k1->hn_addr.adf_family);
if (i != 0)
return (i);
if (k1->hn_addr.adf_family == AF_INET)
return (k2->hn_addr.adf_addr.in4.s_addr -
k1->hn_addr.adf_addr.in4.s_addr);
i = k2->hn_addr.adf_addr.i6[3] - k1->hn_addr.adf_addr.i6[3];
if (i != 0)
return (i);
i = k2->hn_addr.adf_addr.i6[2] - k1->hn_addr.adf_addr.i6[2];
if (i != 0)
return (i);
i = k2->hn_addr.adf_addr.i6[1] - k1->hn_addr.adf_addr.i6[1];
if (i != 0)
return (i);
i = k2->hn_addr.adf_addr.i6[0] - k1->hn_addr.adf_addr.i6[0];
return (i);
}
static void
ipf_ht_node_make_key(host_track_t *htp, host_node_t *key, int family,
i6addr_t *addr)
{
key->hn_addr.adf_family = family;
if (family == AF_INET) {
u_32_t mask;
int bits;
key->hn_addr.adf_len = sizeof(key->hn_addr.adf_addr.in4);
bits = htp->ht_netmask;
if (bits >= 32) {
mask = 0xffffffff;
} else {
mask = htonl(0xffffffff << (32 - bits));
}
key->hn_addr.adf_addr.in4.s_addr = addr->in4.s_addr & mask;
#ifdef USE_INET6
} else {
int bits = htp->ht_netmask;
key->hn_addr.adf_len = sizeof(key->hn_addr.adf_addr.in6);
if (bits > 96) {
key->hn_addr.adf_addr.i6[3] = addr->i6[3] &
htonl(0xffffffff << (128 - bits));
key->hn_addr.adf_addr.i6[2] = addr->i6[2];
key->hn_addr.adf_addr.i6[1] = addr->i6[2];
key->hn_addr.adf_addr.i6[0] = addr->i6[2];
} else if (bits > 64) {
key->hn_addr.adf_addr.i6[3] = 0;
key->hn_addr.adf_addr.i6[2] = addr->i6[2] &
htonl(0xffffffff << (96 - bits));
key->hn_addr.adf_addr.i6[1] = addr->i6[1];
key->hn_addr.adf_addr.i6[0] = addr->i6[0];
} else if (bits > 32) {
key->hn_addr.adf_addr.i6[3] = 0;
key->hn_addr.adf_addr.i6[2] = 0;
key->hn_addr.adf_addr.i6[1] = addr->i6[1] &
htonl(0xffffffff << (64 - bits));
key->hn_addr.adf_addr.i6[0] = addr->i6[0];
} else {
key->hn_addr.adf_addr.i6[3] = 0;
key->hn_addr.adf_addr.i6[2] = 0;
key->hn_addr.adf_addr.i6[1] = 0;
key->hn_addr.adf_addr.i6[0] = addr->i6[0] &
htonl(0xffffffff << (32 - bits));
}
#endif
}
}
int
ipf_ht_node_add(ipf_main_softc_t *softc, host_track_t *htp, int family,
i6addr_t *addr)
{
host_node_t *h;
host_node_t k;
ipf_ht_node_make_key(htp, &k, family, addr);
h = RBI_SEARCH(ipf_rb, &htp->ht_root, &k);
if (h == NULL) {
if (htp->ht_cur_nodes >= htp->ht_max_nodes)
return (-1);
KMALLOC(h, host_node_t *);
if (h == NULL) {
DT(ipf_rb_no_mem);
LBUMP(ipf_rb_no_mem);
return (-1);
}
bzero((char *)h, sizeof(*h));
h->hn_addr = k.hn_addr;
h->hn_addr.adf_family = k.hn_addr.adf_family;
RBI_INSERT(ipf_rb, &htp->ht_root, h);
htp->ht_cur_nodes++;
} else {
if ((htp->ht_max_per_node != 0) &&
(h->hn_active >= htp->ht_max_per_node)) {
DT(ipf_rb_node_max);
LBUMP(ipf_rb_node_max);
return (-1);
}
}
h->hn_active++;
return (0);
}
int
ipf_ht_node_del(host_track_t *htp, int family, i6addr_t *addr)
{
host_node_t *h;
host_node_t k;
ipf_ht_node_make_key(htp, &k, family, addr);
h = RBI_SEARCH(ipf_rb, &htp->ht_root, &k);
if (h == NULL) {
return (-1);
} else {
h->hn_active--;
if (h->hn_active == 0) {
(void) RBI_DELETE(ipf_rb, &htp->ht_root, h);
htp->ht_cur_nodes--;
KFREE(h);
}
}
return (0);
}
void
ipf_rb_ht_init(host_track_t *head)
{
RBI_INIT(ipf_rb, &head->ht_root);
}
void
ipf_rb_ht_freenode(host_node_t *node, void *arg)
{
KFREE(node);
}
void
ipf_rb_ht_flush(host_track_t *head)
{
RBI_WALK(ipf_rb, &head->ht_root, ipf_rb_ht_freenode, NULL);
}
void
ipf_slowtimer(ipf_main_softc_t *softc)
{
ipf_token_expire(softc);
ipf_frag_expire(softc);
ipf_state_expire(softc);
ipf_nat_expire(softc);
ipf_auth_expire(softc);
ipf_lookup_expire(softc);
ipf_rule_expire(softc);
ipf_sync_expire(softc);
softc->ipf_ticks++;
}
void
ipf_inet_mask_add(int bits, ipf_v4_masktab_t *mtab)
{
u_32_t mask;
int i, j;
mtab->imt4_masks[bits]++;
if (mtab->imt4_masks[bits] > 1)
return;
if (bits == 0)
mask = 0;
else
mask = 0xffffffff << (32 - bits);
for (i = 0; i < 33; i++) {
if (ntohl(mtab->imt4_active[i]) < mask) {
for (j = 32; j > i; j--)
mtab->imt4_active[j] = mtab->imt4_active[j - 1];
mtab->imt4_active[i] = htonl(mask);
break;
}
}
mtab->imt4_max++;
}
void
ipf_inet_mask_del(int bits, ipf_v4_masktab_t *mtab)
{
u_32_t mask;
int i, j;
mtab->imt4_masks[bits]--;
if (mtab->imt4_masks[bits] > 0)
return;
mask = htonl(0xffffffff << (32 - bits));
for (i = 0; i < 33; i++) {
if (mtab->imt4_active[i] == mask) {
for (j = i + 1; j < 33; j++)
mtab->imt4_active[j - 1] = mtab->imt4_active[j];
break;
}
}
mtab->imt4_max--;
ASSERT(mtab->imt4_max >= 0);
}
#ifdef USE_INET6
void
ipf_inet6_mask_add(int bits, i6addr_t *mask, ipf_v6_masktab_t *mtab)
{
i6addr_t zero;
int i, j;
mtab->imt6_masks[bits]++;
if (mtab->imt6_masks[bits] > 1)
return;
if (bits == 0) {
mask = &zero;
zero.i6[0] = 0;
zero.i6[1] = 0;
zero.i6[2] = 0;
zero.i6[3] = 0;
}
for (i = 0; i < 129; i++) {
if (IP6_LT(&mtab->imt6_active[i], mask)) {
for (j = 128; j > i; j--)
mtab->imt6_active[j] = mtab->imt6_active[j - 1];
mtab->imt6_active[i] = *mask;
break;
}
}
mtab->imt6_max++;
}
void
ipf_inet6_mask_del(int bits, i6addr_t *mask, ipf_v6_masktab_t *mtab)
{
i6addr_t zero;
int i, j;
mtab->imt6_masks[bits]--;
if (mtab->imt6_masks[bits] > 0)
return;
if (bits == 0)
mask = &zero;
zero.i6[0] = 0;
zero.i6[1] = 0;
zero.i6[2] = 0;
zero.i6[3] = 0;
for (i = 0; i < 129; i++) {
if (IP6_EQ(&mtab->imt6_active[i], mask)) {
for (j = i + 1; j < 129; j++) {
mtab->imt6_active[j - 1] = mtab->imt6_active[j];
if (IP6_EQ(&mtab->imt6_active[j - 1], &zero))
break;
}
break;
}
}
mtab->imt6_max--;
ASSERT(mtab->imt6_max >= 0);
}
#endif
int
ipf_check_names_string(char *names, int namelen, int offset)
{
const char *name;
size_t len;
if (offset == -1)
return (0);
if (offset < 0)
return (1);
if (offset > namelen)
return (2);
name = &names[offset];
len = strnlen(name, namelen - offset);
if (len == namelen - offset)
return (3);
return (0);
}
