File: | net/pf_if.c |
Warning: | line 920, column 3 Value stored to 'n' is never read |
Press '?' to see keyboard shortcuts
Keyboard shortcuts:
1 | /* $OpenBSD: pf_if.c,v 1.111 2023/06/30 09:58:30 mvs Exp $ */ |
2 | |
3 | /* |
4 | * Copyright 2005 Henning Brauer <henning@openbsd.org> |
5 | * Copyright 2005 Ryan McBride <mcbride@openbsd.org> |
6 | * Copyright (c) 2001 Daniel Hartmeier |
7 | * Copyright (c) 2003 Cedric Berger |
8 | * All rights reserved. |
9 | * |
10 | * Redistribution and use in source and binary forms, with or without |
11 | * modification, are permitted provided that the following conditions |
12 | * are met: |
13 | * |
14 | * - Redistributions of source code must retain the above copyright |
15 | * notice, this list of conditions and the following disclaimer. |
16 | * - Redistributions in binary form must reproduce the above |
17 | * copyright notice, this list of conditions and the following |
18 | * disclaimer in the documentation and/or other materials provided |
19 | * with the distribution. |
20 | * |
21 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
22 | * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
23 | * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS |
24 | * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE |
25 | * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, |
26 | * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, |
27 | * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
28 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER |
29 | * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT |
30 | * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN |
31 | * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE |
32 | * POSSIBILITY OF SUCH DAMAGE. |
33 | */ |
34 | |
35 | #include <sys/param.h> |
36 | #include <sys/systm.h> |
37 | #include <sys/mbuf.h> |
38 | #include <sys/filio.h> |
39 | #include <sys/socket.h> |
40 | #include <sys/socketvar.h> |
41 | #include <sys/kernel.h> |
42 | #include <sys/device.h> |
43 | #include <sys/time.h> |
44 | #include <sys/pool.h> |
45 | #include <sys/syslog.h> |
46 | |
47 | #include <net/if.h> |
48 | #include <net/if_var.h> |
49 | |
50 | #include <netinet/in.h> |
51 | #include <netinet/ip.h> |
52 | #include <netinet/ip_var.h> |
53 | |
54 | #include <net/pfvar.h> |
55 | |
56 | #include <netinet/ip_icmp.h> |
57 | #include <netinet/tcp.h> |
58 | #include <netinet/udp.h> |
59 | |
60 | #ifdef INET61 |
61 | #include <netinet/ip6.h> |
62 | #include <netinet/icmp6.h> |
63 | #endif /* INET6 */ |
64 | |
65 | #include <net/pfvar_priv.h> |
66 | |
67 | #define isupper(c)((c) >= 'A' && (c) <= 'Z') ((c) >= 'A' && (c) <= 'Z') |
68 | #define islower(c)((c) >= 'a' && (c) <= 'z') ((c) >= 'a' && (c) <= 'z') |
69 | #define isalpha(c)(((c) >= 'A' && (c) <= 'Z')||((c) >= 'a' && (c) <= 'z')) (isupper(c)((c) >= 'A' && (c) <= 'Z')||islower(c)((c) >= 'a' && (c) <= 'z')) |
70 | |
71 | struct pfi_kif *pfi_all = NULL((void *)0); |
72 | struct pool pfi_addr_pl; |
73 | struct pfi_ifhead pfi_ifs; |
74 | long pfi_update = 1; |
75 | struct pfr_addr *pfi_buffer; |
76 | int pfi_buffer_cnt; |
77 | int pfi_buffer_max; |
78 | |
79 | void pfi_kif_update(struct pfi_kif *); |
80 | void pfi_dynaddr_update(struct pfi_dynaddr *dyn); |
81 | void pfi_table_update(struct pfr_ktable *, struct pfi_kif *, |
82 | u_int8_t, int); |
83 | void pfi_kifaddr_update(void *); |
84 | void pfi_instance_add(struct ifnet *, u_int8_t, int); |
85 | void pfi_address_add(struct sockaddr *, sa_family_t, u_int8_t); |
86 | int pfi_if_compare(struct pfi_kif *, struct pfi_kif *); |
87 | int pfi_skip_if(const char *, struct pfi_kif *); |
88 | int pfi_unmask(void *); |
89 | void pfi_group_change(const char *); |
90 | |
91 | RB_PROTOTYPE(pfi_ifhead, pfi_kif, pfik_tree, pfi_if_compare)void pfi_ifhead_RB_INSERT_COLOR(struct pfi_ifhead *, struct pfi_kif *); void pfi_ifhead_RB_REMOVE_COLOR(struct pfi_ifhead *, struct pfi_kif *, struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_REMOVE (struct pfi_ifhead *, struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_INSERT (struct pfi_ifhead *, struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_FIND (struct pfi_ifhead *, struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_NFIND (struct pfi_ifhead *, struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_NEXT (struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_PREV(struct pfi_kif *); struct pfi_kif *pfi_ifhead_RB_MINMAX(struct pfi_ifhead *, int);; |
92 | RB_GENERATE(pfi_ifhead, pfi_kif, pfik_tree, pfi_if_compare)void pfi_ifhead_RB_INSERT_COLOR(struct pfi_ifhead *head, struct pfi_kif *elm) { struct pfi_kif *parent, *gparent, *tmp; while ((parent = (elm)->pfik_tree.rbe_parent) && (parent )->pfik_tree.rbe_color == 1) { gparent = (parent)->pfik_tree .rbe_parent; if (parent == (gparent)->pfik_tree.rbe_left) { tmp = (gparent)->pfik_tree.rbe_right; if (tmp && ( tmp)->pfik_tree.rbe_color == 1) { (tmp)->pfik_tree.rbe_color = 0; do { (parent)->pfik_tree.rbe_color = 0; (gparent)-> pfik_tree.rbe_color = 1; } while (0); elm = gparent; continue ; } if ((parent)->pfik_tree.rbe_right == elm) { do { (tmp) = (parent)->pfik_tree.rbe_right; if (((parent)->pfik_tree .rbe_right = (tmp)->pfik_tree.rbe_left)) { ((tmp)->pfik_tree .rbe_left)->pfik_tree.rbe_parent = (parent); } do {} while (0); if (((tmp)->pfik_tree.rbe_parent = (parent)->pfik_tree .rbe_parent)) { if ((parent) == ((parent)->pfik_tree.rbe_parent )->pfik_tree.rbe_left) ((parent)->pfik_tree.rbe_parent) ->pfik_tree.rbe_left = (tmp); else ((parent)->pfik_tree .rbe_parent)->pfik_tree.rbe_right = (tmp); } else (head)-> rbh_root = (tmp); (tmp)->pfik_tree.rbe_left = (parent); (parent )->pfik_tree.rbe_parent = (tmp); do {} while (0); if (((tmp )->pfik_tree.rbe_parent)) do {} while (0); } while (0); tmp = parent; parent = elm; elm = tmp; } do { (parent)->pfik_tree .rbe_color = 0; (gparent)->pfik_tree.rbe_color = 1; } while (0); do { (tmp) = (gparent)->pfik_tree.rbe_left; if (((gparent )->pfik_tree.rbe_left = (tmp)->pfik_tree.rbe_right)) { ( (tmp)->pfik_tree.rbe_right)->pfik_tree.rbe_parent = (gparent ); } do {} while (0); if (((tmp)->pfik_tree.rbe_parent = ( gparent)->pfik_tree.rbe_parent)) { if ((gparent) == ((gparent )->pfik_tree.rbe_parent)->pfik_tree.rbe_left) ((gparent )->pfik_tree.rbe_parent)->pfik_tree.rbe_left = (tmp); else ((gparent)->pfik_tree.rbe_parent)->pfik_tree.rbe_right = (tmp); } else (head)->rbh_root = (tmp); (tmp)->pfik_tree .rbe_right = (gparent); (gparent)->pfik_tree.rbe_parent = ( tmp); do {} while (0); if (((tmp)->pfik_tree.rbe_parent)) do {} while (0); } while (0); } else { tmp = (gparent)->pfik_tree .rbe_left; if (tmp && (tmp)->pfik_tree.rbe_color == 1) { (tmp)->pfik_tree.rbe_color = 0; do { (parent)->pfik_tree .rbe_color = 0; (gparent)->pfik_tree.rbe_color = 1; } while (0); elm = gparent; continue; } if ((parent)->pfik_tree.rbe_left == elm) { do { (tmp) = (parent)->pfik_tree.rbe_left; if ( ((parent)->pfik_tree.rbe_left = (tmp)->pfik_tree.rbe_right )) { ((tmp)->pfik_tree.rbe_right)->pfik_tree.rbe_parent = (parent); } do {} while (0); if (((tmp)->pfik_tree.rbe_parent = (parent)->pfik_tree.rbe_parent)) { if ((parent) == ((parent )->pfik_tree.rbe_parent)->pfik_tree.rbe_left) ((parent) ->pfik_tree.rbe_parent)->pfik_tree.rbe_left = (tmp); else ((parent)->pfik_tree.rbe_parent)->pfik_tree.rbe_right = (tmp); } else (head)->rbh_root = (tmp); (tmp)->pfik_tree .rbe_right = (parent); (parent)->pfik_tree.rbe_parent = (tmp ); do {} while (0); if (((tmp)->pfik_tree.rbe_parent)) do { } while (0); } while (0); tmp = parent; parent = elm; elm = tmp ; } do { (parent)->pfik_tree.rbe_color = 0; (gparent)-> pfik_tree.rbe_color = 1; } while (0); do { (tmp) = (gparent)-> pfik_tree.rbe_right; if (((gparent)->pfik_tree.rbe_right = (tmp)->pfik_tree.rbe_left)) { ((tmp)->pfik_tree.rbe_left )->pfik_tree.rbe_parent = (gparent); } do {} while (0); if (((tmp)->pfik_tree.rbe_parent = (gparent)->pfik_tree.rbe_parent )) { if ((gparent) == ((gparent)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left) ((gparent)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left = (tmp); else ((gparent)->pfik_tree.rbe_parent )->pfik_tree.rbe_right = (tmp); } else (head)->rbh_root = (tmp); (tmp)->pfik_tree.rbe_left = (gparent); (gparent) ->pfik_tree.rbe_parent = (tmp); do {} while (0); if (((tmp )->pfik_tree.rbe_parent)) do {} while (0); } while (0); } } (head->rbh_root)->pfik_tree.rbe_color = 0; } void pfi_ifhead_RB_REMOVE_COLOR (struct pfi_ifhead *head, struct pfi_kif *parent, struct pfi_kif *elm) { struct pfi_kif *tmp; while ((elm == ((void *)0) || ( elm)->pfik_tree.rbe_color == 0) && elm != (head)-> rbh_root) { if ((parent)->pfik_tree.rbe_left == elm) { tmp = (parent)->pfik_tree.rbe_right; if ((tmp)->pfik_tree. rbe_color == 1) { do { (tmp)->pfik_tree.rbe_color = 0; (parent )->pfik_tree.rbe_color = 1; } while (0); do { (tmp) = (parent )->pfik_tree.rbe_right; if (((parent)->pfik_tree.rbe_right = (tmp)->pfik_tree.rbe_left)) { ((tmp)->pfik_tree.rbe_left )->pfik_tree.rbe_parent = (parent); } do {} while (0); if ( ((tmp)->pfik_tree.rbe_parent = (parent)->pfik_tree.rbe_parent )) { if ((parent) == ((parent)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left) ((parent)->pfik_tree.rbe_parent)->pfik_tree .rbe_left = (tmp); else ((parent)->pfik_tree.rbe_parent)-> pfik_tree.rbe_right = (tmp); } else (head)->rbh_root = (tmp ); (tmp)->pfik_tree.rbe_left = (parent); (parent)->pfik_tree .rbe_parent = (tmp); do {} while (0); if (((tmp)->pfik_tree .rbe_parent)) do {} while (0); } while (0); tmp = (parent)-> pfik_tree.rbe_right; } if (((tmp)->pfik_tree.rbe_left == ( (void *)0) || ((tmp)->pfik_tree.rbe_left)->pfik_tree.rbe_color == 0) && ((tmp)->pfik_tree.rbe_right == ((void *) 0) || ((tmp)->pfik_tree.rbe_right)->pfik_tree.rbe_color == 0)) { (tmp)->pfik_tree.rbe_color = 1; elm = parent; parent = (elm)->pfik_tree.rbe_parent; } else { if ((tmp)->pfik_tree .rbe_right == ((void *)0) || ((tmp)->pfik_tree.rbe_right)-> pfik_tree.rbe_color == 0) { struct pfi_kif *oleft; if ((oleft = (tmp)->pfik_tree.rbe_left)) (oleft)->pfik_tree.rbe_color = 0; (tmp)->pfik_tree.rbe_color = 1; do { (oleft) = (tmp) ->pfik_tree.rbe_left; if (((tmp)->pfik_tree.rbe_left = ( oleft)->pfik_tree.rbe_right)) { ((oleft)->pfik_tree.rbe_right )->pfik_tree.rbe_parent = (tmp); } do {} while (0); if ((( oleft)->pfik_tree.rbe_parent = (tmp)->pfik_tree.rbe_parent )) { if ((tmp) == ((tmp)->pfik_tree.rbe_parent)->pfik_tree .rbe_left) ((tmp)->pfik_tree.rbe_parent)->pfik_tree.rbe_left = (oleft); else ((tmp)->pfik_tree.rbe_parent)->pfik_tree .rbe_right = (oleft); } else (head)->rbh_root = (oleft); ( oleft)->pfik_tree.rbe_right = (tmp); (tmp)->pfik_tree.rbe_parent = (oleft); do {} while (0); if (((oleft)->pfik_tree.rbe_parent )) do {} while (0); } while (0); tmp = (parent)->pfik_tree .rbe_right; } (tmp)->pfik_tree.rbe_color = (parent)->pfik_tree .rbe_color; (parent)->pfik_tree.rbe_color = 0; if ((tmp)-> pfik_tree.rbe_right) ((tmp)->pfik_tree.rbe_right)->pfik_tree .rbe_color = 0; do { (tmp) = (parent)->pfik_tree.rbe_right ; if (((parent)->pfik_tree.rbe_right = (tmp)->pfik_tree .rbe_left)) { ((tmp)->pfik_tree.rbe_left)->pfik_tree.rbe_parent = (parent); } do {} while (0); if (((tmp)->pfik_tree.rbe_parent = (parent)->pfik_tree.rbe_parent)) { if ((parent) == ((parent )->pfik_tree.rbe_parent)->pfik_tree.rbe_left) ((parent) ->pfik_tree.rbe_parent)->pfik_tree.rbe_left = (tmp); else ((parent)->pfik_tree.rbe_parent)->pfik_tree.rbe_right = (tmp); } else (head)->rbh_root = (tmp); (tmp)->pfik_tree .rbe_left = (parent); (parent)->pfik_tree.rbe_parent = (tmp ); do {} while (0); if (((tmp)->pfik_tree.rbe_parent)) do { } while (0); } while (0); elm = (head)->rbh_root; break; } } else { tmp = (parent)->pfik_tree.rbe_left; if ((tmp)-> pfik_tree.rbe_color == 1) { do { (tmp)->pfik_tree.rbe_color = 0; (parent)->pfik_tree.rbe_color = 1; } while (0); do { (tmp) = (parent)->pfik_tree.rbe_left; if (((parent)->pfik_tree .rbe_left = (tmp)->pfik_tree.rbe_right)) { ((tmp)->pfik_tree .rbe_right)->pfik_tree.rbe_parent = (parent); } do {} while (0); if (((tmp)->pfik_tree.rbe_parent = (parent)->pfik_tree .rbe_parent)) { if ((parent) == ((parent)->pfik_tree.rbe_parent )->pfik_tree.rbe_left) ((parent)->pfik_tree.rbe_parent) ->pfik_tree.rbe_left = (tmp); else ((parent)->pfik_tree .rbe_parent)->pfik_tree.rbe_right = (tmp); } else (head)-> rbh_root = (tmp); (tmp)->pfik_tree.rbe_right = (parent); ( parent)->pfik_tree.rbe_parent = (tmp); do {} while (0); if (((tmp)->pfik_tree.rbe_parent)) do {} while (0); } while ( 0); tmp = (parent)->pfik_tree.rbe_left; } if (((tmp)->pfik_tree .rbe_left == ((void *)0) || ((tmp)->pfik_tree.rbe_left)-> pfik_tree.rbe_color == 0) && ((tmp)->pfik_tree.rbe_right == ((void *)0) || ((tmp)->pfik_tree.rbe_right)->pfik_tree .rbe_color == 0)) { (tmp)->pfik_tree.rbe_color = 1; elm = parent ; parent = (elm)->pfik_tree.rbe_parent; } else { if ((tmp) ->pfik_tree.rbe_left == ((void *)0) || ((tmp)->pfik_tree .rbe_left)->pfik_tree.rbe_color == 0) { struct pfi_kif *oright ; if ((oright = (tmp)->pfik_tree.rbe_right)) (oright)-> pfik_tree.rbe_color = 0; (tmp)->pfik_tree.rbe_color = 1; do { (oright) = (tmp)->pfik_tree.rbe_right; if (((tmp)->pfik_tree .rbe_right = (oright)->pfik_tree.rbe_left)) { ((oright)-> pfik_tree.rbe_left)->pfik_tree.rbe_parent = (tmp); } do {} while (0); if (((oright)->pfik_tree.rbe_parent = (tmp)-> pfik_tree.rbe_parent)) { if ((tmp) == ((tmp)->pfik_tree.rbe_parent )->pfik_tree.rbe_left) ((tmp)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left = (oright); else ((tmp)->pfik_tree.rbe_parent )->pfik_tree.rbe_right = (oright); } else (head)->rbh_root = (oright); (oright)->pfik_tree.rbe_left = (tmp); (tmp)-> pfik_tree.rbe_parent = (oright); do {} while (0); if (((oright )->pfik_tree.rbe_parent)) do {} while (0); } while (0); tmp = (parent)->pfik_tree.rbe_left; } (tmp)->pfik_tree.rbe_color = (parent)->pfik_tree.rbe_color; (parent)->pfik_tree.rbe_color = 0; if ((tmp)->pfik_tree.rbe_left) ((tmp)->pfik_tree. rbe_left)->pfik_tree.rbe_color = 0; do { (tmp) = (parent)-> pfik_tree.rbe_left; if (((parent)->pfik_tree.rbe_left = (tmp )->pfik_tree.rbe_right)) { ((tmp)->pfik_tree.rbe_right) ->pfik_tree.rbe_parent = (parent); } do {} while (0); if ( ((tmp)->pfik_tree.rbe_parent = (parent)->pfik_tree.rbe_parent )) { if ((parent) == ((parent)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left) ((parent)->pfik_tree.rbe_parent)->pfik_tree .rbe_left = (tmp); else ((parent)->pfik_tree.rbe_parent)-> pfik_tree.rbe_right = (tmp); } else (head)->rbh_root = (tmp ); (tmp)->pfik_tree.rbe_right = (parent); (parent)->pfik_tree .rbe_parent = (tmp); do {} while (0); if (((tmp)->pfik_tree .rbe_parent)) do {} while (0); } while (0); elm = (head)-> rbh_root; break; } } } if (elm) (elm)->pfik_tree.rbe_color = 0; } struct pfi_kif * pfi_ifhead_RB_REMOVE(struct pfi_ifhead *head, struct pfi_kif *elm) { struct pfi_kif *child, *parent , *old = elm; int color; if ((elm)->pfik_tree.rbe_left == ( (void *)0)) child = (elm)->pfik_tree.rbe_right; else if (( elm)->pfik_tree.rbe_right == ((void *)0)) child = (elm)-> pfik_tree.rbe_left; else { struct pfi_kif *left; elm = (elm)-> pfik_tree.rbe_right; while ((left = (elm)->pfik_tree.rbe_left )) elm = left; child = (elm)->pfik_tree.rbe_right; parent = (elm)->pfik_tree.rbe_parent; color = (elm)->pfik_tree. rbe_color; if (child) (child)->pfik_tree.rbe_parent = parent ; if (parent) { if ((parent)->pfik_tree.rbe_left == elm) ( parent)->pfik_tree.rbe_left = child; else (parent)->pfik_tree .rbe_right = child; do {} while (0); } else (head)->rbh_root = child; if ((elm)->pfik_tree.rbe_parent == old) parent = elm; (elm)->pfik_tree = (old)->pfik_tree; if ((old)-> pfik_tree.rbe_parent) { if (((old)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left == old) ((old)->pfik_tree.rbe_parent)-> pfik_tree.rbe_left = elm; else ((old)->pfik_tree.rbe_parent )->pfik_tree.rbe_right = elm; do {} while (0); } else (head )->rbh_root = elm; ((old)->pfik_tree.rbe_left)->pfik_tree .rbe_parent = elm; if ((old)->pfik_tree.rbe_right) ((old)-> pfik_tree.rbe_right)->pfik_tree.rbe_parent = elm; if (parent ) { left = parent; do { do {} while (0); } while ((left = (left )->pfik_tree.rbe_parent)); } goto color; } parent = (elm)-> pfik_tree.rbe_parent; color = (elm)->pfik_tree.rbe_color; if (child) (child)->pfik_tree.rbe_parent = parent; if (parent ) { if ((parent)->pfik_tree.rbe_left == elm) (parent)-> pfik_tree.rbe_left = child; else (parent)->pfik_tree.rbe_right = child; do {} while (0); } else (head)->rbh_root = child ; color: if (color == 0) pfi_ifhead_RB_REMOVE_COLOR(head, parent , child); return (old); } struct pfi_kif * pfi_ifhead_RB_INSERT (struct pfi_ifhead *head, struct pfi_kif *elm) { struct pfi_kif *tmp; struct pfi_kif *parent = ((void *)0); int comp = 0; tmp = (head)->rbh_root; while (tmp) { parent = tmp; comp = (pfi_if_compare )(elm, parent); if (comp < 0) tmp = (tmp)->pfik_tree.rbe_left ; else if (comp > 0) tmp = (tmp)->pfik_tree.rbe_right; else return (tmp); } do { (elm)->pfik_tree.rbe_parent = parent ; (elm)->pfik_tree.rbe_left = (elm)->pfik_tree.rbe_right = ((void *)0); (elm)->pfik_tree.rbe_color = 1; } while (0 ); if (parent != ((void *)0)) { if (comp < 0) (parent)-> pfik_tree.rbe_left = elm; else (parent)->pfik_tree.rbe_right = elm; do {} while (0); } else (head)->rbh_root = elm; pfi_ifhead_RB_INSERT_COLOR (head, elm); return (((void *)0)); } struct pfi_kif * pfi_ifhead_RB_FIND (struct pfi_ifhead *head, struct pfi_kif *elm) { struct pfi_kif *tmp = (head)->rbh_root; int comp; while (tmp) { comp = pfi_if_compare (elm, tmp); if (comp < 0) tmp = (tmp)->pfik_tree.rbe_left ; else if (comp > 0) tmp = (tmp)->pfik_tree.rbe_right; else return (tmp); } return (((void *)0)); } struct pfi_kif * pfi_ifhead_RB_NFIND (struct pfi_ifhead *head, struct pfi_kif *elm) { struct pfi_kif *tmp = (head)->rbh_root; struct pfi_kif *res = ((void *)0 ); int comp; while (tmp) { comp = pfi_if_compare(elm, tmp); if (comp < 0) { res = tmp; tmp = (tmp)->pfik_tree.rbe_left ; } else if (comp > 0) tmp = (tmp)->pfik_tree.rbe_right ; else return (tmp); } return (res); } struct pfi_kif * pfi_ifhead_RB_NEXT (struct pfi_kif *elm) { if ((elm)->pfik_tree.rbe_right) { elm = (elm)->pfik_tree.rbe_right; while ((elm)->pfik_tree. rbe_left) elm = (elm)->pfik_tree.rbe_left; } else { if ((elm )->pfik_tree.rbe_parent && (elm == ((elm)->pfik_tree .rbe_parent)->pfik_tree.rbe_left)) elm = (elm)->pfik_tree .rbe_parent; else { while ((elm)->pfik_tree.rbe_parent && (elm == ((elm)->pfik_tree.rbe_parent)->pfik_tree.rbe_right )) elm = (elm)->pfik_tree.rbe_parent; elm = (elm)->pfik_tree .rbe_parent; } } return (elm); } struct pfi_kif * pfi_ifhead_RB_PREV (struct pfi_kif *elm) { if ((elm)->pfik_tree.rbe_left) { elm = (elm)->pfik_tree.rbe_left; while ((elm)->pfik_tree.rbe_right ) elm = (elm)->pfik_tree.rbe_right; } else { if ((elm)-> pfik_tree.rbe_parent && (elm == ((elm)->pfik_tree. rbe_parent)->pfik_tree.rbe_right)) elm = (elm)->pfik_tree .rbe_parent; else { while ((elm)->pfik_tree.rbe_parent && (elm == ((elm)->pfik_tree.rbe_parent)->pfik_tree.rbe_left )) elm = (elm)->pfik_tree.rbe_parent; elm = (elm)->pfik_tree .rbe_parent; } } return (elm); } struct pfi_kif * pfi_ifhead_RB_MINMAX (struct pfi_ifhead *head, int val) { struct pfi_kif *tmp = (head )->rbh_root; struct pfi_kif *parent = ((void *)0); while ( tmp) { parent = tmp; if (val < 0) tmp = (tmp)->pfik_tree .rbe_left; else tmp = (tmp)->pfik_tree.rbe_right; } return (parent); }; |
93 | |
94 | #define PFI_BUFFER_MAX0x10000 0x10000 |
95 | #define PFI_MTYPE6 M_PF6 |
96 | |
97 | struct pfi_kif * |
98 | pfi_kif_alloc(const char *kif_name, int mflags) |
99 | { |
100 | struct pfi_kif *kif; |
101 | |
102 | kif = malloc(sizeof(*pfi_all), PFI_MTYPE6, mflags|M_ZERO0x0008); |
103 | if (kif == NULL((void *)0)) |
104 | return (NULL((void *)0)); |
105 | strlcpy(kif->pfik_name, kif_name, sizeof(kif->pfik_name)); |
106 | kif->pfik_tzero = gettime(); |
107 | TAILQ_INIT(&kif->pfik_dynaddrs)do { (&kif->pfik_dynaddrs)->tqh_first = ((void *)0) ; (&kif->pfik_dynaddrs)->tqh_last = &(&kif-> pfik_dynaddrs)->tqh_first; } while (0); |
108 | |
109 | if (!strcmp(kif->pfik_name, "any")) { |
110 | /* both so it works in the ioctl and the regular case */ |
111 | kif->pfik_flags |= PFI_IFLAG_ANY0x0200; |
112 | kif->pfik_flags_new |= PFI_IFLAG_ANY0x0200; |
113 | } |
114 | |
115 | return (kif); |
116 | } |
117 | |
118 | void |
119 | pfi_kif_free(struct pfi_kif *kif) |
120 | { |
121 | if (kif == NULL((void *)0)) |
122 | return; |
123 | |
124 | if (kif->pfik_rules || kif->pfik_states || kif->pfik_routes || |
125 | kif->pfik_srcnodes || kif->pfik_flagrefs) |
126 | panic("kif is still alive"); |
127 | |
128 | free(kif, PFI_MTYPE6, sizeof(*kif)); |
129 | } |
130 | |
131 | void |
132 | pfi_initialize(void) |
133 | { |
134 | /* |
135 | * The first time we arrive here is during kernel boot, |
136 | * when if_attachsetup() for the first time. No locking |
137 | * is needed in this case, because it's granted there |
138 | * is a single thread, which sets pfi_all global var. |
139 | */ |
140 | if (pfi_all != NULL((void *)0)) /* already initialized */ |
141 | return; |
142 | |
143 | pool_init(&pfi_addr_pl, sizeof(struct pfi_dynaddr), 0, IPL_SOFTNET0x2, 0, |
144 | "pfiaddrpl", NULL((void *)0)); |
145 | pfi_buffer_max = 64; |
146 | pfi_buffer = mallocarray(pfi_buffer_max, sizeof(*pfi_buffer), |
147 | PFI_MTYPE6, M_WAITOK0x0001); |
148 | |
149 | pfi_all = pfi_kif_alloc(IFG_ALL"all", M_WAITOK0x0001); |
150 | |
151 | if (RB_INSERT(pfi_ifhead, &pfi_ifs, pfi_all)pfi_ifhead_RB_INSERT(&pfi_ifs, pfi_all) != NULL((void *)0)) |
152 | panic("IFG_ALL kif found already"); |
153 | } |
154 | |
155 | struct pfi_kif * |
156 | pfi_kif_find(const char *kif_name) |
157 | { |
158 | struct pfi_kif_cmp s; |
159 | |
160 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
161 | |
162 | memset(&s, 0, sizeof(s))__builtin_memset((&s), (0), (sizeof(s))); |
163 | strlcpy(s.pfik_name, kif_name, sizeof(s.pfik_name)); |
164 | return (RB_FIND(pfi_ifhead, &pfi_ifs, (struct pfi_kif *)&s)pfi_ifhead_RB_FIND(&pfi_ifs, (struct pfi_kif *)&s)); |
165 | } |
166 | |
167 | struct pfi_kif * |
168 | pfi_kif_get(const char *kif_name, struct pfi_kif **prealloc) |
169 | { |
170 | struct pfi_kif *kif; |
171 | |
172 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
173 | |
174 | if ((kif = pfi_kif_find(kif_name))) |
175 | return (kif); |
176 | |
177 | /* create new one */ |
178 | if ((prealloc == NULL((void *)0)) || (*prealloc == NULL((void *)0))) { |
179 | kif = pfi_kif_alloc(kif_name, M_NOWAIT0x0002); |
180 | if (kif == NULL((void *)0)) |
181 | return (NULL((void *)0)); |
182 | } else { |
183 | kif = *prealloc; |
184 | *prealloc = NULL((void *)0); |
185 | } |
186 | |
187 | RB_INSERT(pfi_ifhead, &pfi_ifs, kif)pfi_ifhead_RB_INSERT(&pfi_ifs, kif); |
188 | return (kif); |
189 | } |
190 | |
191 | void |
192 | pfi_kif_ref(struct pfi_kif *kif, enum pfi_kif_refs what) |
193 | { |
194 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
195 | |
196 | switch (what) { |
197 | case PFI_KIF_REF_RULE: |
198 | kif->pfik_rules++; |
199 | break; |
200 | case PFI_KIF_REF_STATE: |
201 | kif->pfik_states++; |
202 | break; |
203 | case PFI_KIF_REF_ROUTE: |
204 | kif->pfik_routes++; |
205 | break; |
206 | case PFI_KIF_REF_SRCNODE: |
207 | kif->pfik_srcnodes++; |
208 | break; |
209 | case PFI_KIF_REF_FLAG: |
210 | kif->pfik_flagrefs++; |
211 | break; |
212 | default: |
213 | panic("pfi_kif_ref with unknown type"); |
214 | } |
215 | } |
216 | |
217 | void |
218 | pfi_kif_unref(struct pfi_kif *kif, enum pfi_kif_refs what) |
219 | { |
220 | if (kif == NULL((void *)0)) |
221 | return; |
222 | |
223 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
224 | |
225 | switch (what) { |
226 | case PFI_KIF_REF_NONE: |
227 | break; |
228 | case PFI_KIF_REF_RULE: |
229 | if (kif->pfik_rules <= 0) { |
230 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): rules refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
231 | "pfi_kif_unref (%s): rules refcount <= 0",do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): rules refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
232 | kif->pfik_name)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): rules refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0); |
233 | return; |
234 | } |
235 | kif->pfik_rules--; |
236 | break; |
237 | case PFI_KIF_REF_STATE: |
238 | if (kif->pfik_states <= 0) { |
239 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): state refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
240 | "pfi_kif_unref (%s): state refcount <= 0",do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): state refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
241 | kif->pfik_name)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): state refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0); |
242 | return; |
243 | } |
244 | kif->pfik_states--; |
245 | break; |
246 | case PFI_KIF_REF_ROUTE: |
247 | if (kif->pfik_routes <= 0) { |
248 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): route refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
249 | "pfi_kif_unref (%s): route refcount <= 0",do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): route refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
250 | kif->pfik_name)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): route refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0); |
251 | return; |
252 | } |
253 | kif->pfik_routes--; |
254 | break; |
255 | case PFI_KIF_REF_SRCNODE: |
256 | if (kif->pfik_srcnodes <= 0) { |
257 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): src-node refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
258 | "pfi_kif_unref (%s): src-node refcount <= 0",do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): src-node refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
259 | kif->pfik_name)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): src-node refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0); |
260 | return; |
261 | } |
262 | kif->pfik_srcnodes--; |
263 | break; |
264 | case PFI_KIF_REF_FLAG: |
265 | if (kif->pfik_flagrefs <= 0) { |
266 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): flags refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
267 | "pfi_kif_unref (%s): flags refcount <= 0",do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): flags refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0) |
268 | kif->pfik_name)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_kif_unref (%s): flags refcount <= 0", kif->pfik_name ); addlog("\n"); } } while (0); |
269 | return; |
270 | } |
271 | kif->pfik_flagrefs--; |
272 | break; |
273 | default: |
274 | panic("pfi_kif_unref (%s) with unknown type", kif->pfik_name); |
275 | } |
276 | |
277 | if (kif->pfik_ifp != NULL((void *)0) || kif->pfik_group != NULL((void *)0) || kif == pfi_all) |
278 | return; |
279 | |
280 | if (kif->pfik_rules || kif->pfik_states || kif->pfik_routes || |
281 | kif->pfik_srcnodes || kif->pfik_flagrefs) |
282 | return; |
283 | |
284 | RB_REMOVE(pfi_ifhead, &pfi_ifs, kif)pfi_ifhead_RB_REMOVE(&pfi_ifs, kif); |
285 | free(kif, PFI_MTYPE6, sizeof(*kif)); |
286 | } |
287 | |
288 | int |
289 | pfi_kif_match(struct pfi_kif *rule_kif, struct pfi_kif *packet_kif) |
290 | { |
291 | struct ifg_list *p; |
292 | |
293 | if (rule_kif == NULL((void *)0) || rule_kif == packet_kif) |
294 | return (1); |
295 | |
296 | if (rule_kif->pfik_group != NULL((void *)0)) |
297 | TAILQ_FOREACH(p, &packet_kif->pfik_ifp->if_groups, ifgl_next)for((p) = ((&packet_kif->pfik_ifp->if_groups)->tqh_first ); (p) != ((void *)0); (p) = ((p)->ifgl_next.tqe_next)) |
298 | if (p->ifgl_group == rule_kif->pfik_group) |
299 | return (1); |
300 | |
301 | if (rule_kif->pfik_flags & PFI_IFLAG_ANY0x0200 && packet_kif->pfik_ifp && |
302 | !(packet_kif->pfik_ifp->if_flags & IFF_LOOPBACK0x8)) |
303 | return (1); |
304 | |
305 | return (0); |
306 | } |
307 | |
308 | void |
309 | pfi_attach_ifnet(struct ifnet *ifp) |
310 | { |
311 | struct pfi_kif *kif; |
312 | struct task *t; |
313 | |
314 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
315 | pfi_initialize(); |
316 | pfi_update++; |
317 | if ((kif = pfi_kif_get(ifp->if_xname, NULL((void *)0))) == NULL((void *)0)) |
318 | panic("%s: pfi_kif_get failed", __func__); |
319 | |
320 | kif->pfik_ifp = ifp; |
321 | ifp->if_pf_kif = (caddr_t)kif; |
322 | |
323 | t = malloc(sizeof(*t), PFI_MTYPE6, M_WAITOK0x0001); |
324 | task_set(t, pfi_kifaddr_update, kif); |
325 | if_addrhook_add(ifp, t); |
326 | kif->pfik_ah_cookie = t; |
327 | |
328 | pfi_kif_update(kif); |
329 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
330 | } |
331 | |
332 | void |
333 | pfi_detach_ifnet(struct ifnet *ifp) |
334 | { |
335 | struct pfi_kif *kif; |
336 | struct task *t; |
337 | |
338 | if ((kif = (struct pfi_kif *)ifp->if_pf_kif) == NULL((void *)0)) |
339 | return; |
340 | |
341 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
342 | pfi_update++; |
343 | t = kif->pfik_ah_cookie; |
344 | kif->pfik_ah_cookie = NULL((void *)0); |
345 | if_addrhook_del(ifp, t); |
346 | free(t, PFI_MTYPE6, sizeof(*t)); |
347 | |
348 | pfi_kif_update(kif); |
349 | |
350 | kif->pfik_ifp = NULL((void *)0); |
351 | ifp->if_pf_kif = NULL((void *)0); |
352 | pfi_kif_unref(kif, PFI_KIF_REF_NONE); |
353 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
354 | } |
355 | |
356 | void |
357 | pfi_attach_ifgroup(struct ifg_group *ifg) |
358 | { |
359 | struct pfi_kif *kif; |
360 | |
361 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
362 | pfi_initialize(); |
363 | pfi_update++; |
364 | if ((kif = pfi_kif_get(ifg->ifg_group, NULL((void *)0))) == NULL((void *)0)) |
365 | panic("%s: pfi_kif_get failed", __func__); |
366 | |
367 | kif->pfik_group = ifg; |
368 | ifg->ifg_pf_kif = (caddr_t)kif; |
369 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
370 | } |
371 | |
372 | void |
373 | pfi_detach_ifgroup(struct ifg_group *ifg) |
374 | { |
375 | struct pfi_kif *kif; |
376 | |
377 | if ((kif = (struct pfi_kif *)ifg->ifg_pf_kif) == NULL((void *)0)) |
378 | return; |
379 | |
380 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
381 | pfi_update++; |
382 | |
383 | kif->pfik_group = NULL((void *)0); |
384 | ifg->ifg_pf_kif = NULL((void *)0); |
385 | pfi_kif_unref(kif, PFI_KIF_REF_NONE); |
386 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
387 | } |
388 | |
389 | void |
390 | pfi_group_change(const char *group) |
391 | { |
392 | struct pfi_kif *kif; |
393 | |
394 | pfi_update++; |
395 | if ((kif = pfi_kif_get(group, NULL((void *)0))) == NULL((void *)0)) |
396 | panic("%s: pfi_kif_get failed", __func__); |
397 | |
398 | pfi_kif_update(kif); |
399 | } |
400 | |
401 | void |
402 | pfi_group_delmember(const char *group) |
403 | { |
404 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
405 | pfi_group_change(group); |
406 | pfi_xcommit(); |
407 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
408 | } |
409 | |
410 | void |
411 | pfi_group_addmember(const char *group) |
412 | { |
413 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
414 | pfi_group_change(group); |
415 | pfi_xcommit(); |
416 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
417 | } |
418 | |
419 | int |
420 | pfi_match_addr(struct pfi_dynaddr *dyn, struct pf_addr *a, sa_family_t af) |
421 | { |
422 | switch (af) { |
423 | case AF_INET2: |
424 | switch (dyn->pfid_acnt4) { |
425 | case 0: |
426 | return (0); |
427 | case 1: |
428 | return (pf_match_addr(0, &dyn->pfid_addr4, |
429 | &dyn->pfid_mask4, a, AF_INET2)); |
430 | default: |
431 | return (pfr_match_addr(dyn->pfid_kt, a, AF_INET2)); |
432 | } |
433 | break; |
434 | #ifdef INET61 |
435 | case AF_INET624: |
436 | switch (dyn->pfid_acnt6) { |
437 | case 0: |
438 | return (0); |
439 | case 1: |
440 | return (pf_match_addr(0, &dyn->pfid_addr6, |
441 | &dyn->pfid_mask6, a, AF_INET624)); |
442 | default: |
443 | return (pfr_match_addr(dyn->pfid_kt, a, AF_INET624)); |
444 | } |
445 | break; |
446 | #endif /* INET6 */ |
447 | default: |
448 | return (0); |
449 | } |
450 | } |
451 | |
452 | int |
453 | pfi_dynaddr_setup(struct pf_addr_wrap *aw, sa_family_t af, int wait) |
454 | { |
455 | struct pfi_dynaddr *dyn; |
456 | char tblname[PF_TABLE_NAME_SIZE32]; |
457 | struct pf_ruleset *ruleset = NULL((void *)0); |
458 | int rv = 0; |
459 | |
460 | if (aw->type != PF_ADDR_DYNIFTL) |
461 | return (0); |
462 | if ((dyn = pool_get(&pfi_addr_pl, wait|PR_LIMITFAIL0x0004|PR_ZERO0x0008)) == NULL((void *)0)) |
463 | return (1); |
464 | |
465 | if (!strcmp(aw->v.ifname, "self")) |
466 | dyn->pfid_kif = pfi_kif_get(IFG_ALL"all", NULL((void *)0)); |
467 | else |
468 | dyn->pfid_kif = pfi_kif_get(aw->v.ifname, NULL((void *)0)); |
469 | if (dyn->pfid_kif == NULL((void *)0)) { |
470 | rv = 1; |
471 | goto _bad; |
472 | } |
473 | pfi_kif_ref(dyn->pfid_kif, PFI_KIF_REF_RULE); |
474 | |
475 | dyn->pfid_net = pfi_unmask(&aw->v.a.mask); |
476 | if (af == AF_INET2 && dyn->pfid_net == 32) |
477 | dyn->pfid_net = 128; |
478 | strlcpy(tblname, aw->v.ifname, sizeof(tblname)); |
479 | if (aw->iflags & PFI_AFLAG_NETWORK0x01) |
480 | strlcat(tblname, ":network", sizeof(tblname)); |
481 | if (aw->iflags & PFI_AFLAG_BROADCAST0x02) |
482 | strlcat(tblname, ":broadcast", sizeof(tblname)); |
483 | if (aw->iflags & PFI_AFLAG_PEER0x04) |
484 | strlcat(tblname, ":peer", sizeof(tblname)); |
485 | if (aw->iflags & PFI_AFLAG_NOALIAS0x08) |
486 | strlcat(tblname, ":0", sizeof(tblname)); |
487 | if (dyn->pfid_net != 128) |
488 | snprintf(tblname + strlen(tblname), |
489 | sizeof(tblname) - strlen(tblname), "/%d", dyn->pfid_net); |
490 | if ((ruleset = pf_find_or_create_ruleset(PF_RESERVED_ANCHOR"_pf")) == NULL((void *)0)) { |
491 | rv = 1; |
492 | goto _bad; |
493 | } |
494 | |
495 | if ((dyn->pfid_kt = pfr_attach_table(ruleset, tblname, wait)) == NULL((void *)0)) { |
496 | rv = 1; |
497 | goto _bad; |
498 | } |
499 | |
500 | dyn->pfid_kt->pfrkt_flagspfrkt_ts.pfrts_t.pfrt_flags |= PFR_TFLAG_ACTIVE0x00000004; |
501 | dyn->pfid_iflags = aw->iflags; |
502 | dyn->pfid_af = af; |
503 | |
504 | TAILQ_INSERT_TAIL(&dyn->pfid_kif->pfik_dynaddrs, dyn, entry)do { (dyn)->entry.tqe_next = ((void *)0); (dyn)->entry. tqe_prev = (&dyn->pfid_kif->pfik_dynaddrs)->tqh_last ; *(&dyn->pfid_kif->pfik_dynaddrs)->tqh_last = ( dyn); (&dyn->pfid_kif->pfik_dynaddrs)->tqh_last = &(dyn)->entry.tqe_next; } while (0); |
505 | aw->p.dyn = dyn; |
506 | pfi_kif_update(dyn->pfid_kif); |
507 | return (0); |
508 | |
509 | _bad: |
510 | if (dyn->pfid_kt != NULL((void *)0)) |
511 | pfr_detach_table(dyn->pfid_kt); |
512 | if (ruleset != NULL((void *)0)) |
513 | pf_remove_if_empty_ruleset(ruleset); |
514 | if (dyn->pfid_kif != NULL((void *)0)) |
515 | pfi_kif_unref(dyn->pfid_kif, PFI_KIF_REF_RULE); |
516 | pool_put(&pfi_addr_pl, dyn); |
517 | return (rv); |
518 | } |
519 | |
520 | void |
521 | pfi_kif_update(struct pfi_kif *kif) |
522 | { |
523 | struct ifg_list *ifgl; |
524 | struct pfi_dynaddr *p; |
525 | |
526 | /* update all dynaddr */ |
527 | TAILQ_FOREACH(p, &kif->pfik_dynaddrs, entry)for((p) = ((&kif->pfik_dynaddrs)->tqh_first); (p) != ((void *)0); (p) = ((p)->entry.tqe_next)) |
528 | pfi_dynaddr_update(p); |
529 | |
530 | /* again for all groups kif is member of */ |
531 | if (kif->pfik_ifp != NULL((void *)0)) |
532 | TAILQ_FOREACH(ifgl, &kif->pfik_ifp->if_groups, ifgl_next)for((ifgl) = ((&kif->pfik_ifp->if_groups)->tqh_first ); (ifgl) != ((void *)0); (ifgl) = ((ifgl)->ifgl_next.tqe_next )) |
533 | pfi_kif_update((struct pfi_kif *) |
534 | ifgl->ifgl_group->ifg_pf_kif); |
535 | } |
536 | |
537 | void |
538 | pfi_dynaddr_update(struct pfi_dynaddr *dyn) |
539 | { |
540 | struct pfi_kif *kif; |
541 | struct pfr_ktable *kt; |
542 | |
543 | if (dyn == NULL((void *)0) || dyn->pfid_kif == NULL((void *)0) || dyn->pfid_kt == NULL((void *)0)) |
544 | panic("pfi_dynaddr_update"); |
545 | |
546 | kif = dyn->pfid_kif; |
547 | kt = dyn->pfid_kt; |
548 | |
549 | if (kt->pfrkt_larg != pfi_update) { |
550 | /* this table needs to be brought up-to-date */ |
551 | pfi_table_update(kt, kif, dyn->pfid_net, dyn->pfid_iflags); |
552 | kt->pfrkt_larg = pfi_update; |
553 | } |
554 | pfr_dynaddr_update(kt, dyn); |
555 | } |
556 | |
557 | void |
558 | pfi_table_update(struct pfr_ktable *kt, struct pfi_kif *kif, u_int8_t net, int flags) |
559 | { |
560 | int e, size2 = 0; |
561 | struct ifg_member *ifgm; |
562 | |
563 | pfi_buffer_cnt = 0; |
564 | |
565 | if (kif->pfik_ifp != NULL((void *)0)) |
566 | pfi_instance_add(kif->pfik_ifp, net, flags); |
567 | else if (kif->pfik_group != NULL((void *)0)) |
568 | TAILQ_FOREACH(ifgm, &kif->pfik_group->ifg_members, ifgm_next)for((ifgm) = ((&kif->pfik_group->ifg_members)->tqh_first ); (ifgm) != ((void *)0); (ifgm) = ((ifgm)->ifgm_next.tqe_next )) |
569 | pfi_instance_add(ifgm->ifgm_ifp, net, flags); |
570 | |
571 | if ((e = pfr_set_addrs(&kt->pfrkt_tpfrkt_ts.pfrts_t, pfi_buffer, pfi_buffer_cnt, &size2, |
572 | NULL((void *)0), NULL((void *)0), NULL((void *)0), 0, PFR_TFLAG_ALLMASK0x0000007F))) |
573 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_table_update: cannot set %d new addresses " "into table %s: %d" , pfi_buffer_cnt, kt->pfrkt_ts.pfrts_t.pfrt_name, e); addlog ("\n"); } } while (0) |
574 | "pfi_table_update: cannot set %d new addresses "do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_table_update: cannot set %d new addresses " "into table %s: %d" , pfi_buffer_cnt, kt->pfrkt_ts.pfrts_t.pfrt_name, e); addlog ("\n"); } } while (0) |
575 | "into table %s: %d", pfi_buffer_cnt, kt->pfrkt_name, e)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_table_update: cannot set %d new addresses " "into table %s: %d" , pfi_buffer_cnt, kt->pfrkt_ts.pfrts_t.pfrt_name, e); addlog ("\n"); } } while (0); |
576 | } |
577 | |
578 | void |
579 | pfi_instance_add(struct ifnet *ifp, u_int8_t net, int flags) |
580 | { |
581 | struct ifaddr *ifa; |
582 | int got4 = 0, got6 = 0; |
583 | int net2, af; |
584 | |
585 | if (ifp == NULL((void *)0)) |
586 | return; |
587 | TAILQ_FOREACH(ifa, &ifp->if_addrlist, ifa_list)for((ifa) = ((&ifp->if_addrlist)->tqh_first); (ifa) != ((void *)0); (ifa) = ((ifa)->ifa_list.tqe_next)) { |
588 | if (ifa->ifa_addr == NULL((void *)0)) |
589 | continue; |
590 | af = ifa->ifa_addr->sa_family; |
591 | if (af != AF_INET2 && af != AF_INET624) |
592 | continue; |
593 | if ((flags & PFI_AFLAG_BROADCAST0x02) && af == AF_INET624) |
594 | continue; |
595 | if ((flags & PFI_AFLAG_BROADCAST0x02) && |
596 | !(ifp->if_flags & IFF_BROADCAST0x2)) |
597 | continue; |
598 | if ((flags & PFI_AFLAG_PEER0x04) && |
599 | !(ifp->if_flags & IFF_POINTOPOINT0x10)) |
600 | continue; |
601 | if ((flags & PFI_AFLAG_NETWORK0x01) && af == AF_INET624 && |
602 | IN6_IS_ADDR_LINKLOCAL((((&((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr )->__u6_addr.__u6_addr8[0] == 0xfe) && (((&((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr)->__u6_addr .__u6_addr8[1] & 0xc0) == 0x80)) |
603 | &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr)(((&((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr )->__u6_addr.__u6_addr8[0] == 0xfe) && (((&((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr)->__u6_addr .__u6_addr8[1] & 0xc0) == 0x80))) |
604 | continue; |
605 | if (flags & PFI_AFLAG_NOALIAS0x08) { |
606 | if (af == AF_INET2 && got4) |
607 | continue; |
608 | if (af == AF_INET624 && got6) |
609 | continue; |
610 | } |
611 | if (af == AF_INET2) |
612 | got4 = 1; |
613 | else if (af == AF_INET624) |
614 | got6 = 1; |
615 | net2 = net; |
616 | if (net2 == 128 && (flags & PFI_AFLAG_NETWORK0x01)) { |
617 | if (af == AF_INET2) |
618 | net2 = pfi_unmask(&((struct sockaddr_in *) |
619 | ifa->ifa_netmask)->sin_addr); |
620 | else if (af == AF_INET624) |
621 | net2 = pfi_unmask(&((struct sockaddr_in6 *) |
622 | ifa->ifa_netmask)->sin6_addr); |
623 | } |
624 | if (af == AF_INET2 && net2 > 32) |
625 | net2 = 32; |
626 | if (flags & PFI_AFLAG_BROADCAST0x02) |
627 | pfi_address_add(ifa->ifa_broadaddrifa_dstaddr, af, net2); |
628 | else if (flags & PFI_AFLAG_PEER0x04) |
629 | pfi_address_add(ifa->ifa_dstaddr, af, net2); |
630 | else |
631 | pfi_address_add(ifa->ifa_addr, af, net2); |
632 | } |
633 | } |
634 | |
635 | void |
636 | pfi_address_add(struct sockaddr *sa, sa_family_t af, u_int8_t net) |
637 | { |
638 | struct pfr_addr *p; |
639 | int i; |
640 | |
641 | if (pfi_buffer_cnt >= pfi_buffer_max) { |
642 | int new_max = pfi_buffer_max * 2; |
643 | |
644 | if (new_max > PFI_BUFFER_MAX0x10000) { |
645 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_address_add: address buffer full (%d/%d)", pfi_buffer_cnt , 0x10000); addlog("\n"); } } while (0) |
646 | "pfi_address_add: address buffer full (%d/%d)",do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_address_add: address buffer full (%d/%d)", pfi_buffer_cnt , 0x10000); addlog("\n"); } } while (0) |
647 | pfi_buffer_cnt, PFI_BUFFER_MAX)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_address_add: address buffer full (%d/%d)", pfi_buffer_cnt , 0x10000); addlog("\n"); } } while (0); |
648 | return; |
649 | } |
650 | p = mallocarray(new_max, sizeof(*pfi_buffer), PFI_MTYPE6, |
651 | M_DONTWAIT0x0002); |
652 | if (p == NULL((void *)0)) { |
653 | DPFPRINTF(LOG_ERR,do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_address_add: no memory to grow buffer " "(%d/%d)", pfi_buffer_cnt , 0x10000); addlog("\n"); } } while (0) |
654 | "pfi_address_add: no memory to grow buffer "do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_address_add: no memory to grow buffer " "(%d/%d)", pfi_buffer_cnt , 0x10000); addlog("\n"); } } while (0) |
655 | "(%d/%d)", pfi_buffer_cnt, PFI_BUFFER_MAX)do { if (pf_status.debug >= (3)) { log(3, "pf: "); addlog( "pfi_address_add: no memory to grow buffer " "(%d/%d)", pfi_buffer_cnt , 0x10000); addlog("\n"); } } while (0); |
656 | return; |
657 | } |
658 | memcpy(p, pfi_buffer, pfi_buffer_max * sizeof(*pfi_buffer))__builtin_memcpy((p), (pfi_buffer), (pfi_buffer_max * sizeof( *pfi_buffer))); |
659 | /* no need to zero buffer */ |
660 | free(pfi_buffer, PFI_MTYPE6, pfi_buffer_max * sizeof(*pfi_buffer)); |
661 | pfi_buffer = p; |
662 | pfi_buffer_max = new_max; |
663 | } |
664 | if (af == AF_INET2 && net > 32) |
665 | net = 128; |
666 | p = pfi_buffer + pfi_buffer_cnt++; |
667 | memset(p, 0, sizeof(*p))__builtin_memset((p), (0), (sizeof(*p))); |
668 | p->pfra_af = af; |
669 | p->pfra_net = net; |
670 | if (af == AF_INET2) |
671 | p->pfra_ip4addrpfra_u._pfra_ip4addr = ((struct sockaddr_in *)sa)->sin_addr; |
672 | else if (af == AF_INET624) { |
673 | p->pfra_ip6addrpfra_u._pfra_ip6addr = ((struct sockaddr_in6 *)sa)->sin6_addr; |
674 | if (IN6_IS_SCOPE_EMBED(&p->pfra_ip6addr)(((((&p->pfra_u._pfra_ip6addr)->__u6_addr.__u6_addr8 [0] == 0xfe) && (((&p->pfra_u._pfra_ip6addr)-> __u6_addr.__u6_addr8[1] & 0xc0) == 0x80))) || ((((&p-> pfra_u._pfra_ip6addr)->__u6_addr.__u6_addr8[0] == 0xff) && (((&p->pfra_u._pfra_ip6addr)->__u6_addr.__u6_addr8 [1] & 0x0f) == 0x02))) || ((((&p->pfra_u._pfra_ip6addr )->__u6_addr.__u6_addr8[0] == 0xff) && (((&p-> pfra_u._pfra_ip6addr)->__u6_addr.__u6_addr8[1] & 0x0f) == 0x01))))) |
675 | p->pfra_ip6addrpfra_u._pfra_ip6addr.s6_addr16__u6_addr.__u6_addr16[1] = 0; |
676 | } |
677 | /* mask network address bits */ |
678 | if (net < 128) |
679 | ((caddr_t)p)[p->pfra_net/8] &= ~(0xFF >> (p->pfra_net%8)); |
680 | for (i = (p->pfra_net+7)/8; i < sizeof(p->pfra_u); i++) |
681 | ((caddr_t)p)[i] = 0; |
682 | } |
683 | |
684 | void |
685 | pfi_dynaddr_remove(struct pf_addr_wrap *aw) |
686 | { |
687 | if (aw->type != PF_ADDR_DYNIFTL || aw->p.dyn == NULL((void *)0) || |
688 | aw->p.dyn->pfid_kif == NULL((void *)0) || aw->p.dyn->pfid_kt == NULL((void *)0)) |
689 | return; |
690 | |
691 | TAILQ_REMOVE(&aw->p.dyn->pfid_kif->pfik_dynaddrs, aw->p.dyn, entry)do { if (((aw->p.dyn)->entry.tqe_next) != ((void *)0)) ( aw->p.dyn)->entry.tqe_next->entry.tqe_prev = (aw-> p.dyn)->entry.tqe_prev; else (&aw->p.dyn->pfid_kif ->pfik_dynaddrs)->tqh_last = (aw->p.dyn)->entry.tqe_prev ; *(aw->p.dyn)->entry.tqe_prev = (aw->p.dyn)->entry .tqe_next; ((aw->p.dyn)->entry.tqe_prev) = ((void *)-1) ; ((aw->p.dyn)->entry.tqe_next) = ((void *)-1); } while (0); |
692 | pfi_kif_unref(aw->p.dyn->pfid_kif, PFI_KIF_REF_RULE); |
693 | aw->p.dyn->pfid_kif = NULL((void *)0); |
694 | pfr_detach_table(aw->p.dyn->pfid_kt); |
695 | aw->p.dyn->pfid_kt = NULL((void *)0); |
696 | pool_put(&pfi_addr_pl, aw->p.dyn); |
697 | aw->p.dyn = NULL((void *)0); |
698 | } |
699 | |
700 | void |
701 | pfi_dynaddr_copyout(struct pf_addr_wrap *aw) |
702 | { |
703 | if (aw->type != PF_ADDR_DYNIFTL || aw->p.dyn == NULL((void *)0) || |
704 | aw->p.dyn->pfid_kif == NULL((void *)0)) |
705 | return; |
706 | aw->p.dyncnt = aw->p.dyn->pfid_acnt4 + aw->p.dyn->pfid_acnt6; |
707 | } |
708 | |
709 | void |
710 | pfi_kifaddr_update(void *v) |
711 | { |
712 | struct pfi_kif *kif = (struct pfi_kif *)v; |
713 | |
714 | NET_ASSERT_LOCKED()do { int _s = rw_status(&netlock); if ((splassert_ctl > 0) && (_s != 0x0001UL && _s != 0x0002UL)) splassert_fail (0x0002UL, _s, __func__); } while (0); |
715 | |
716 | PF_LOCK()do { rw_enter_write(&pf_lock); } while (0); |
717 | pfi_update++; |
718 | pfi_kif_update(kif); |
719 | PF_UNLOCK()do { do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail (0x0001UL, rw_status(&pf_lock),__func__); } while (0); rw_exit_write (&pf_lock); } while (0); |
720 | } |
721 | |
722 | int |
723 | pfi_if_compare(struct pfi_kif *p, struct pfi_kif *q) |
724 | { |
725 | return (strncmp(p->pfik_name, q->pfik_name, IFNAMSIZ16)); |
726 | } |
727 | |
728 | void |
729 | pfi_update_status(const char *name, struct pf_status *pfs) |
730 | { |
731 | struct pfi_kif *p; |
732 | struct pfi_kif_cmp key; |
733 | struct ifg_member p_member, *ifgm; |
734 | TAILQ_HEAD(, ifg_member)struct { struct ifg_member *tqh_first; struct ifg_member **tqh_last ; } ifg_members; |
735 | int i, j, k; |
736 | |
737 | if (*name == '\0' && pfs == NULL((void *)0)) { |
738 | RB_FOREACH(p, pfi_ifhead, &pfi_ifs)for ((p) = pfi_ifhead_RB_MINMAX(&pfi_ifs, -1); (p) != ((void *)0); (p) = pfi_ifhead_RB_NEXT(p)) { |
739 | memset(p->pfik_packets, 0, sizeof(p->pfik_packets))__builtin_memset((p->pfik_packets), (0), (sizeof(p->pfik_packets ))); |
740 | memset(p->pfik_bytes, 0, sizeof(p->pfik_bytes))__builtin_memset((p->pfik_bytes), (0), (sizeof(p->pfik_bytes ))); |
741 | p->pfik_tzero = gettime(); |
742 | } |
743 | return; |
744 | } |
745 | |
746 | strlcpy(key.pfik_name, name, sizeof(key.pfik_name)); |
747 | p = RB_FIND(pfi_ifhead, &pfi_ifs, (struct pfi_kif *)&key)pfi_ifhead_RB_FIND(&pfi_ifs, (struct pfi_kif *)&key); |
748 | if (p == NULL((void *)0)) { |
749 | return; |
750 | } |
751 | if (p->pfik_group != NULL((void *)0)) { |
752 | memcpy(&ifg_members, &p->pfik_group->ifg_members,__builtin_memcpy((&ifg_members), (&p->pfik_group-> ifg_members), (sizeof(ifg_members))) |
753 | sizeof(ifg_members))__builtin_memcpy((&ifg_members), (&p->pfik_group-> ifg_members), (sizeof(ifg_members))); |
754 | } else { |
755 | /* build a temporary list for p only */ |
756 | memset(&p_member, 0, sizeof(p_member))__builtin_memset((&p_member), (0), (sizeof(p_member))); |
757 | p_member.ifgm_ifp = p->pfik_ifp; |
758 | TAILQ_INIT(&ifg_members)do { (&ifg_members)->tqh_first = ((void *)0); (&ifg_members )->tqh_last = &(&ifg_members)->tqh_first; } while (0); |
759 | TAILQ_INSERT_TAIL(&ifg_members, &p_member, ifgm_next)do { (&p_member)->ifgm_next.tqe_next = ((void *)0); (& p_member)->ifgm_next.tqe_prev = (&ifg_members)->tqh_last ; *(&ifg_members)->tqh_last = (&p_member); (&ifg_members )->tqh_last = &(&p_member)->ifgm_next.tqe_next; } while (0); |
760 | } |
761 | if (pfs) { |
762 | memset(pfs->pcounters, 0, sizeof(pfs->pcounters))__builtin_memset((pfs->pcounters), (0), (sizeof(pfs->pcounters ))); |
763 | memset(pfs->bcounters, 0, sizeof(pfs->bcounters))__builtin_memset((pfs->bcounters), (0), (sizeof(pfs->bcounters ))); |
764 | } |
765 | TAILQ_FOREACH(ifgm, &ifg_members, ifgm_next)for((ifgm) = ((&ifg_members)->tqh_first); (ifgm) != (( void *)0); (ifgm) = ((ifgm)->ifgm_next.tqe_next)) { |
766 | if (ifgm->ifgm_ifp == NULL((void *)0)) |
767 | continue; |
768 | p = (struct pfi_kif *)ifgm->ifgm_ifp->if_pf_kif; |
769 | |
770 | /* just clear statistics */ |
771 | if (pfs == NULL((void *)0)) { |
772 | memset(p->pfik_packets, 0, sizeof(p->pfik_packets))__builtin_memset((p->pfik_packets), (0), (sizeof(p->pfik_packets ))); |
773 | memset(p->pfik_bytes, 0, sizeof(p->pfik_bytes))__builtin_memset((p->pfik_bytes), (0), (sizeof(p->pfik_bytes ))); |
774 | p->pfik_tzero = gettime(); |
775 | continue; |
776 | } |
777 | for (i = 0; i < 2; i++) |
778 | for (j = 0; j < 2; j++) |
779 | for (k = 0; k < 2; k++) { |
780 | pfs->pcounters[i][j][k] += |
781 | p->pfik_packets[i][j][k]; |
782 | pfs->bcounters[i][j] += |
783 | p->pfik_bytes[i][j][k]; |
784 | } |
785 | } |
786 | } |
787 | |
788 | void |
789 | pfi_get_ifaces(const char *name, struct pfi_kif *buf, int *size) |
790 | { |
791 | struct pfi_kif *p; |
792 | int n = 0; |
793 | |
794 | RB_FOREACH(p, pfi_ifhead, &pfi_ifs)for ((p) = pfi_ifhead_RB_MINMAX(&pfi_ifs, -1); (p) != ((void *)0); (p) = pfi_ifhead_RB_NEXT(p)) { |
795 | if (pfi_skip_if(name, p)) |
796 | continue; |
797 | if (*size <= ++n) |
798 | break; |
799 | if (!p->pfik_tzero) |
800 | p->pfik_tzero = gettime(); |
801 | memcpy(buf++, p, sizeof(*buf))__builtin_memcpy((buf++), (p), (sizeof(*buf))); |
802 | } |
803 | *size = n; |
804 | } |
805 | |
806 | int |
807 | pfi_skip_if(const char *filter, struct pfi_kif *p) |
808 | { |
809 | struct ifg_list *i; |
810 | int n; |
811 | |
812 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
813 | |
814 | if (filter == NULL((void *)0) || !*filter) |
815 | return (0); |
816 | if (!strcmp(p->pfik_name, filter)) |
817 | return (0); /* exact match */ |
818 | n = strlen(filter); |
819 | if (n < 1 || n >= IFNAMSIZ16) |
820 | return (1); /* sanity check */ |
821 | if (filter[n-1] >= '0' && filter[n-1] <= '9') |
822 | return (1); /* group names may not end in a digit */ |
823 | if (p->pfik_ifp != NULL((void *)0)) |
824 | TAILQ_FOREACH(i, &p->pfik_ifp->if_groups, ifgl_next)for((i) = ((&p->pfik_ifp->if_groups)->tqh_first) ; (i) != ((void *)0); (i) = ((i)->ifgl_next.tqe_next)) |
825 | if (!strncmp(i->ifgl_group->ifg_group, filter, IFNAMSIZ16)) |
826 | return (0); /* iface is in group "filter" */ |
827 | return (1); |
828 | } |
829 | |
830 | int |
831 | pfi_set_flags(const char *name, int flags) |
832 | { |
833 | struct pfi_kif *p; |
834 | size_t n; |
835 | |
836 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
837 | |
838 | if (name != NULL((void *)0) && name[0] != '\0') { |
839 | p = pfi_kif_find(name); |
840 | if (p == NULL((void *)0)) { |
841 | n = strlen(name); |
842 | if (n < 1 || n >= IFNAMSIZ16) |
843 | return (EINVAL22); |
844 | |
845 | if (!isalpha(name[0])(((name[0]) >= 'A' && (name[0]) <= 'Z')||((name [0]) >= 'a' && (name[0]) <= 'z'))) |
846 | return (EINVAL22); |
847 | |
848 | p = pfi_kif_get(name, NULL((void *)0)); |
849 | if (p != NULL((void *)0)) { |
850 | p->pfik_flags_new = p->pfik_flags | flags; |
851 | /* |
852 | * We use pfik_flagrefs counter as an |
853 | * indication whether the kif has been created |
854 | * on behalf of 'pfi_set_flags()' or not. |
855 | */ |
856 | KASSERT(p->pfik_flagrefs == 0)((p->pfik_flagrefs == 0) ? (void)0 : __assert("diagnostic " , "/usr/src/sys/net/pf_if.c", 856, "p->pfik_flagrefs == 0" )); |
857 | if (ISSET(p->pfik_flags_new, PFI_IFLAG_SKIP)((p->pfik_flags_new) & (0x0100))) |
858 | pfi_kif_ref(p, PFI_KIF_REF_FLAG); |
859 | } else |
860 | panic("%s pfi_kif_get() returned NULL\n", |
861 | __func__); |
862 | } else |
863 | p->pfik_flags_new = p->pfik_flags | flags; |
864 | } else { |
865 | RB_FOREACH(p, pfi_ifhead, &pfi_ifs)for ((p) = pfi_ifhead_RB_MINMAX(&pfi_ifs, -1); (p) != ((void *)0); (p) = pfi_ifhead_RB_NEXT(p)) |
866 | p->pfik_flags_new = p->pfik_flags | flags; |
867 | } |
868 | |
869 | return (0); |
870 | } |
871 | |
872 | int |
873 | pfi_clear_flags(const char *name, int flags) |
874 | { |
875 | struct pfi_kif *p, *w; |
876 | |
877 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
878 | |
879 | if (name != NULL((void *)0) && name[0] != '\0') { |
880 | p = pfi_kif_find(name); |
881 | if (p != NULL((void *)0)) { |
882 | p->pfik_flags_new = p->pfik_flags & ~flags; |
883 | |
884 | KASSERT((p->pfik_flagrefs == 0) ||(((p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)) ? (void)0 : __assert("diagnostic ", "/usr/src/sys/net/pf_if.c" , 885, "(p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)" )) |
885 | (p->pfik_flagrefs == 1))(((p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)) ? (void)0 : __assert("diagnostic ", "/usr/src/sys/net/pf_if.c" , 885, "(p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)" )); |
886 | |
887 | if (!ISSET(p->pfik_flags_new, PFI_IFLAG_SKIP)((p->pfik_flags_new) & (0x0100)) && |
888 | (p->pfik_flagrefs == 1)) |
889 | pfi_kif_unref(p, PFI_KIF_REF_FLAG); |
890 | } else |
891 | return (ESRCH3); |
892 | |
893 | } else |
894 | RB_FOREACH_SAFE(p, pfi_ifhead, &pfi_ifs, w)for ((p) = pfi_ifhead_RB_MINMAX(&pfi_ifs, -1); ((p) != (( void *)0)) && ((w) = pfi_ifhead_RB_NEXT(p), 1); (p) = (w)) { |
895 | p->pfik_flags_new = p->pfik_flags & ~flags; |
896 | |
897 | KASSERT((p->pfik_flagrefs == 0) ||(((p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)) ? (void)0 : __assert("diagnostic ", "/usr/src/sys/net/pf_if.c" , 898, "(p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)" )) |
898 | (p->pfik_flagrefs == 1))(((p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)) ? (void)0 : __assert("diagnostic ", "/usr/src/sys/net/pf_if.c" , 898, "(p->pfik_flagrefs == 0) || (p->pfik_flagrefs == 1)" )); |
899 | |
900 | if (!ISSET(p->pfik_flags_new, PFI_IFLAG_SKIP)((p->pfik_flags_new) & (0x0100)) && |
901 | (p->pfik_flagrefs == 1)) |
902 | pfi_kif_unref(p, PFI_KIF_REF_FLAG); |
903 | } |
904 | |
905 | return (0); |
906 | } |
907 | |
908 | void |
909 | pfi_xcommit(void) |
910 | { |
911 | struct pfi_kif *p, *gkif; |
912 | struct ifg_list *g; |
913 | struct ifnet *ifp; |
914 | size_t n; |
915 | |
916 | PF_ASSERT_LOCKED()do { if (rw_status(&pf_lock) != 0x0001UL) splassert_fail( 0x0001UL, rw_status(&pf_lock),__func__); } while (0); |
917 | |
918 | RB_FOREACH(p, pfi_ifhead, &pfi_ifs)for ((p) = pfi_ifhead_RB_MINMAX(&pfi_ifs, -1); (p) != ((void *)0); (p) = pfi_ifhead_RB_NEXT(p)) { |
919 | p->pfik_flags = p->pfik_flags_new; |
920 | n = strlen(p->pfik_name); |
Value stored to 'n' is never read | |
921 | ifp = p->pfik_ifp; |
922 | /* |
923 | * if kif is backed by existing interface, then we must use |
924 | * skip flags found in groups. We use pfik_flags_new, otherwise |
925 | * we would need to do two RB_FOREACH() passes: the first to |
926 | * commit group changes the second to commit flag changes for |
927 | * interfaces. |
928 | */ |
929 | if (ifp != NULL((void *)0)) |
930 | TAILQ_FOREACH(g, &ifp->if_groups, ifgl_next)for((g) = ((&ifp->if_groups)->tqh_first); (g) != (( void *)0); (g) = ((g)->ifgl_next.tqe_next)) { |
931 | gkif = |
932 | (struct pfi_kif *)g->ifgl_group->ifg_pf_kif; |
933 | KASSERT(gkif != NULL)((gkif != ((void *)0)) ? (void)0 : __assert("diagnostic ", "/usr/src/sys/net/pf_if.c" , 933, "gkif != NULL")); |
934 | p->pfik_flags |= gkif->pfik_flags_new; |
935 | } |
936 | } |
937 | } |
938 | |
939 | /* from pf_print_state.c */ |
940 | int |
941 | pfi_unmask(void *addr) |
942 | { |
943 | struct pf_addr *m = addr; |
944 | int i = 31, j = 0, b = 0; |
945 | u_int32_t tmp; |
946 | |
947 | while (j < 4 && m->addr32pfa.addr32[j] == 0xffffffff) { |
948 | b += 32; |
949 | j++; |
950 | } |
951 | if (j < 4) { |
952 | tmp = ntohl(m->addr32[j])(__uint32_t)(__builtin_constant_p(m->pfa.addr32[j]) ? (__uint32_t )(((__uint32_t)(m->pfa.addr32[j]) & 0xff) << 24 | ((__uint32_t)(m->pfa.addr32[j]) & 0xff00) << 8 | ((__uint32_t)(m->pfa.addr32[j]) & 0xff0000) >> 8 | ((__uint32_t)(m->pfa.addr32[j]) & 0xff000000) >> 24) : __swap32md(m->pfa.addr32[j])); |
953 | for (i = 31; tmp & (1 << i); --i) |
954 | b++; |
955 | } |
956 | return (b); |
957 | } |
958 |