11676Sjpk /* 21676Sjpk * CDDL HEADER START 31676Sjpk * 41676Sjpk * The contents of this file are subject to the terms of the 51676Sjpk * Common Development and Distribution License (the "License"). 61676Sjpk * You may not use this file except in compliance with the License. 71676Sjpk * 81676Sjpk * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 91676Sjpk * or http://www.opensolaris.org/os/licensing. 101676Sjpk * See the License for the specific language governing permissions 111676Sjpk * and limitations under the License. 121676Sjpk * 131676Sjpk * When distributing Covered Code, include this CDDL HEADER in each 141676Sjpk * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 151676Sjpk * If applicable, add the following below this CDDL HEADER, with the 161676Sjpk * fields enclosed by brackets "[]" replaced with your own identifying 171676Sjpk * information: Portions Copyright [yyyy] [name of copyright owner] 181676Sjpk * 191676Sjpk * CDDL HEADER END 201676Sjpk */ 211676Sjpk /* 228778SErik.Nordmark@Sun.COM * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 231676Sjpk * Use is subject to license terms. 241676Sjpk */ 251676Sjpk 261676Sjpk #include <sys/types.h> 271676Sjpk #include <sys/stream.h> 281676Sjpk #include <sys/strsubr.h> 291676Sjpk #include <sys/stropts.h> 301676Sjpk #include <sys/sunddi.h> 311676Sjpk #include <sys/cred.h> 321676Sjpk #include <sys/debug.h> 331676Sjpk #include <sys/kmem.h> 341676Sjpk #include <sys/errno.h> 351676Sjpk #include <sys/disp.h> 361676Sjpk #include <netinet/in.h> 371676Sjpk #include <netinet/in_systm.h> 381676Sjpk #include <netinet/ip.h> 391676Sjpk #include <netinet/ip_icmp.h> 401676Sjpk #include <netinet/tcp.h> 411676Sjpk #include <inet/common.h> 421676Sjpk #include <inet/ipclassifier.h> 431676Sjpk #include <inet/ip.h> 441676Sjpk #include <inet/mib2.h> 451676Sjpk #include <inet/nd.h> 461676Sjpk #include <inet/tcp.h> 471676Sjpk #include <inet/ip_rts.h> 481676Sjpk #include <inet/ip_ire.h> 491676Sjpk #include <inet/ip_if.h> 501676Sjpk #include <sys/modhash.h> 511676Sjpk 521676Sjpk #include <sys/tsol/label.h> 531676Sjpk #include <sys/tsol/label_macro.h> 541676Sjpk #include <sys/tsol/tnet.h> 551676Sjpk #include <sys/tsol/tndb.h> 561676Sjpk #include <sys/strsun.h> 571676Sjpk 581676Sjpk /* tunable for strict error-reply behavior (TCP RST and ICMP Unreachable) */ 591676Sjpk int tsol_strict_error; 601676Sjpk 611676Sjpk /* 621676Sjpk * Some notes on the Trusted Solaris IRE gateway security attributes: 631676Sjpk * 641676Sjpk * When running in Trusted mode, the routing subsystem determines whether or 651676Sjpk * not a packet can be delivered to an off-link host (not directly reachable 661676Sjpk * through an interface) based on the accreditation checks of the packet's 671676Sjpk * security attributes against those associated with the next-hop gateway. 681676Sjpk * 691676Sjpk * The next-hop gateway's security attributes can be derived from two sources 701676Sjpk * (in order of preference): route-related and the host database. A Trusted 711676Sjpk * system must be configured with at least the host database containing an 721676Sjpk * entry for the next-hop gateway, or otherwise no accreditation checks can 731676Sjpk * be performed, which may result in the inability to send packets to any 741676Sjpk * off-link destination host. 751676Sjpk * 761676Sjpk * The major differences between the two sources are the number and type of 771676Sjpk * security attributes used for accreditation checks. A host database entry 781676Sjpk * can contain at most one set of security attributes, specific only to the 791676Sjpk * next-hop gateway. On contrast, route-related security attributes are made 801676Sjpk * up of a collection of security attributes for the distant networks, and 811676Sjpk * are grouped together per next-hop gateway used to reach those networks. 821676Sjpk * This is the preferred method, and the routing subsystem will fallback to 831676Sjpk * the host database entry only if there are no route-related attributes 841676Sjpk * associated with the next-hop gateway. 851676Sjpk * 861676Sjpk * In Trusted mode, all of the IRE entries (except LOCAL/LOOPBACK/BROADCAST/ 871676Sjpk * INTERFACE type) are initialized to contain a placeholder to store this 881676Sjpk * information. The ire_gw_secattr structure gets allocated, initialized 891676Sjpk * and associated with the IRE during the time of the IRE creation. The 901676Sjpk * initialization process also includes resolving the host database entry 911676Sjpk * of the next-hop gateway for fallback purposes. It does not include any 921676Sjpk * route-related attribute setup, as that process comes separately as part 931676Sjpk * of the route requests (add/change) made to the routing subsystem. 941676Sjpk * 951676Sjpk * The underlying logic which involves associating IREs with the gateway 961676Sjpk * security attributes are represented by the following data structures: 971676Sjpk * 981676Sjpk * tsol_gcdb_t, or "gcdb" 991676Sjpk * 1001676Sjpk * - This is a system-wide collection of records containing the 1011676Sjpk * currently used route-related security attributes, which are fed 1021676Sjpk * through the routing socket interface, e.g. "route add/change". 1031676Sjpk * 1041676Sjpk * tsol_gc_t, or "gc" 1051676Sjpk * 1061676Sjpk * - This is the gateway credential structure, and it provides for the 1071676Sjpk * only mechanism to access the contents of gcdb. More than one gc 1081676Sjpk * entries may refer to the same gcdb record. gc's in the system are 1091676Sjpk * grouped according to the next-hop gateway address. 1101676Sjpk * 1111676Sjpk * tsol_gcgrp_t, or "gcgrp" 1121676Sjpk * 1131676Sjpk * - Group of gateway credentials, and is unique per next-hop gateway 1141676Sjpk * address. When the group is not empty, i.e. when gcgrp_count is 1151676Sjpk * greater than zero, it contains one or more gc's, each pointing to 1161676Sjpk * a gcdb record which indicates the gateway security attributes 1171676Sjpk * associated with the next-hop gateway. 1181676Sjpk * 1191676Sjpk * The fields of the tsol_ire_gw_secattr_t used from within the IRE are: 1201676Sjpk * 1211676Sjpk * igsa_lock 1221676Sjpk * 1231676Sjpk * - Lock that protects all fields within tsol_ire_gw_secattr_t. 1241676Sjpk * 1251676Sjpk * igsa_rhc 1261676Sjpk * 1271676Sjpk * - Remote host cache database entry of next-hop gateway. This is 1281676Sjpk * used in the case when there are no route-related attributes 1291676Sjpk * configured for the IRE. 1301676Sjpk * 1311676Sjpk * igsa_gc 1321676Sjpk * 1331676Sjpk * - A set of route-related attributes that only get set for prefix 1341676Sjpk * IREs. If this is non-NULL, the prefix IRE has been associated 1351676Sjpk * with a set of gateway security attributes by way of route add/ 1361676Sjpk * change functionality. This field stays NULL for IRE_CACHEs. 1371676Sjpk * 1381676Sjpk * igsa_gcgrp 1391676Sjpk * 1401676Sjpk * - Group of gc's which only gets set for IRE_CACHEs. Each of the gc 1411676Sjpk * points to a gcdb record that contains the security attributes 1421676Sjpk * used to perform the credential checks of the packet which uses 1431676Sjpk * the IRE. If the group is not empty, the list of gc's can be 1441676Sjpk * traversed starting at gcgrp_head. This field stays NULL for 1451676Sjpk * prefix IREs. 1461676Sjpk */ 1471676Sjpk 1481676Sjpk static kmem_cache_t *ire_gw_secattr_cache; 1491676Sjpk 1501676Sjpk #define GCDB_HASH_SIZE 101 1511676Sjpk #define GCGRP_HASH_SIZE 101 1521676Sjpk 1531676Sjpk #define GCDB_REFRELE(p) { \ 1541676Sjpk mutex_enter(&gcdb_lock); \ 1551676Sjpk ASSERT((p)->gcdb_refcnt > 0); \ 1561676Sjpk if (--((p)->gcdb_refcnt) == 0) \ 1571676Sjpk gcdb_inactive(p); \ 1581676Sjpk ASSERT(MUTEX_HELD(&gcdb_lock)); \ 1591676Sjpk mutex_exit(&gcdb_lock); \ 1601676Sjpk } 1611676Sjpk 1621676Sjpk static int gcdb_hash_size = GCDB_HASH_SIZE; 1631676Sjpk static int gcgrp_hash_size = GCGRP_HASH_SIZE; 1641676Sjpk static mod_hash_t *gcdb_hash; 1651676Sjpk static mod_hash_t *gcgrp4_hash; 1661676Sjpk static mod_hash_t *gcgrp6_hash; 1671676Sjpk 1681676Sjpk static kmutex_t gcdb_lock; 1691676Sjpk kmutex_t gcgrp_lock; 1701676Sjpk 1711676Sjpk static uint_t gcdb_hash_by_secattr(void *, mod_hash_key_t); 1721676Sjpk static int gcdb_hash_cmp(mod_hash_key_t, mod_hash_key_t); 1731676Sjpk static tsol_gcdb_t *gcdb_lookup(struct rtsa_s *, boolean_t); 1741676Sjpk static void gcdb_inactive(tsol_gcdb_t *); 1751676Sjpk 1761676Sjpk static uint_t gcgrp_hash_by_addr(void *, mod_hash_key_t); 1771676Sjpk static int gcgrp_hash_cmp(mod_hash_key_t, mod_hash_key_t); 1781676Sjpk 1791676Sjpk static int ire_gw_secattr_constructor(void *, void *, int); 1801676Sjpk static void ire_gw_secattr_destructor(void *, void *); 1811676Sjpk 1821676Sjpk void 1831676Sjpk tnet_init(void) 1841676Sjpk { 1851676Sjpk ire_gw_secattr_cache = kmem_cache_create("ire_gw_secattr_cache", 1861676Sjpk sizeof (tsol_ire_gw_secattr_t), 64, ire_gw_secattr_constructor, 1871676Sjpk ire_gw_secattr_destructor, NULL, NULL, NULL, 0); 1881676Sjpk 1891676Sjpk gcdb_hash = mod_hash_create_extended("gcdb_hash", 1901676Sjpk gcdb_hash_size, mod_hash_null_keydtor, mod_hash_null_valdtor, 1911676Sjpk gcdb_hash_by_secattr, NULL, gcdb_hash_cmp, KM_SLEEP); 1921676Sjpk 1931676Sjpk gcgrp4_hash = mod_hash_create_extended("gcgrp4_hash", 1941676Sjpk gcgrp_hash_size, mod_hash_null_keydtor, mod_hash_null_valdtor, 1951676Sjpk gcgrp_hash_by_addr, NULL, gcgrp_hash_cmp, KM_SLEEP); 1961676Sjpk 1971676Sjpk gcgrp6_hash = mod_hash_create_extended("gcgrp6_hash", 1981676Sjpk gcgrp_hash_size, mod_hash_null_keydtor, mod_hash_null_valdtor, 1991676Sjpk gcgrp_hash_by_addr, NULL, gcgrp_hash_cmp, KM_SLEEP); 2001676Sjpk 2011676Sjpk mutex_init(&gcdb_lock, NULL, MUTEX_DEFAULT, NULL); 2021676Sjpk mutex_init(&gcgrp_lock, NULL, MUTEX_DEFAULT, NULL); 2031676Sjpk } 2041676Sjpk 2051676Sjpk void 2061676Sjpk tnet_fini(void) 2071676Sjpk { 2081676Sjpk kmem_cache_destroy(ire_gw_secattr_cache); 2091676Sjpk mod_hash_destroy_hash(gcdb_hash); 2101676Sjpk mod_hash_destroy_hash(gcgrp4_hash); 2111676Sjpk mod_hash_destroy_hash(gcgrp6_hash); 2121676Sjpk mutex_destroy(&gcdb_lock); 2131676Sjpk mutex_destroy(&gcgrp_lock); 2141676Sjpk } 2151676Sjpk 2161676Sjpk /* ARGSUSED */ 2171676Sjpk static int 2181676Sjpk ire_gw_secattr_constructor(void *buf, void *cdrarg, int kmflags) 2191676Sjpk { 2201676Sjpk tsol_ire_gw_secattr_t *attrp = buf; 2211676Sjpk 2221676Sjpk mutex_init(&attrp->igsa_lock, NULL, MUTEX_DEFAULT, NULL); 2231676Sjpk 2241676Sjpk attrp->igsa_rhc = NULL; 2251676Sjpk attrp->igsa_gc = NULL; 2261676Sjpk attrp->igsa_gcgrp = NULL; 2271676Sjpk 2281676Sjpk return (0); 2291676Sjpk } 2301676Sjpk 2311676Sjpk /* ARGSUSED */ 2321676Sjpk static void 2331676Sjpk ire_gw_secattr_destructor(void *buf, void *cdrarg) 2341676Sjpk { 2351676Sjpk tsol_ire_gw_secattr_t *attrp = (tsol_ire_gw_secattr_t *)buf; 2361676Sjpk 2371676Sjpk mutex_destroy(&attrp->igsa_lock); 2381676Sjpk } 2391676Sjpk 2401676Sjpk tsol_ire_gw_secattr_t * 2411676Sjpk ire_gw_secattr_alloc(int kmflags) 2421676Sjpk { 2431676Sjpk return (kmem_cache_alloc(ire_gw_secattr_cache, kmflags)); 2441676Sjpk } 2451676Sjpk 2461676Sjpk void 2471676Sjpk ire_gw_secattr_free(tsol_ire_gw_secattr_t *attrp) 2481676Sjpk { 2491676Sjpk ASSERT(MUTEX_NOT_HELD(&attrp->igsa_lock)); 2501676Sjpk 2511676Sjpk if (attrp->igsa_rhc != NULL) { 2521676Sjpk TNRHC_RELE(attrp->igsa_rhc); 2531676Sjpk attrp->igsa_rhc = NULL; 2541676Sjpk } 2551676Sjpk 2561676Sjpk if (attrp->igsa_gc != NULL) { 2571676Sjpk GC_REFRELE(attrp->igsa_gc); 2581676Sjpk attrp->igsa_gc = NULL; 2591676Sjpk } 2601676Sjpk if (attrp->igsa_gcgrp != NULL) { 2611676Sjpk GCGRP_REFRELE(attrp->igsa_gcgrp); 2621676Sjpk attrp->igsa_gcgrp = NULL; 2631676Sjpk } 2641676Sjpk 2651676Sjpk ASSERT(attrp->igsa_rhc == NULL); 2661676Sjpk ASSERT(attrp->igsa_gc == NULL); 2671676Sjpk ASSERT(attrp->igsa_gcgrp == NULL); 2681676Sjpk 2691676Sjpk kmem_cache_free(ire_gw_secattr_cache, attrp); 2701676Sjpk } 2711676Sjpk 2721676Sjpk /* ARGSUSED */ 2731676Sjpk static uint_t 2741676Sjpk gcdb_hash_by_secattr(void *hash_data, mod_hash_key_t key) 2751676Sjpk { 2761676Sjpk const struct rtsa_s *rp = (struct rtsa_s *)key; 2771676Sjpk const uint32_t *up, *ue; 2781676Sjpk uint_t hash; 2791676Sjpk int i; 2801676Sjpk 2811676Sjpk ASSERT(rp != NULL); 2821676Sjpk 2831676Sjpk /* See comments in hash_bylabel in zone.c for details */ 2841676Sjpk hash = rp->rtsa_doi + (rp->rtsa_doi << 1); 2851676Sjpk up = (const uint32_t *)&rp->rtsa_slrange; 2861676Sjpk ue = up + sizeof (rp->rtsa_slrange) / sizeof (*up); 2871676Sjpk i = 1; 2881676Sjpk while (up < ue) { 2891676Sjpk /* using 2^n + 1, 1 <= n <= 16 as source of many primes */ 2901676Sjpk hash += *up + (*up << ((i % 16) + 1)); 2911676Sjpk up++; 2921676Sjpk i++; 2931676Sjpk } 2941676Sjpk return (hash); 2951676Sjpk } 2961676Sjpk 2971676Sjpk static int 2981676Sjpk gcdb_hash_cmp(mod_hash_key_t key1, mod_hash_key_t key2) 2991676Sjpk { 3001676Sjpk struct rtsa_s *rp1 = (struct rtsa_s *)key1; 3011676Sjpk struct rtsa_s *rp2 = (struct rtsa_s *)key2; 3021676Sjpk 3031676Sjpk ASSERT(rp1 != NULL && rp2 != NULL); 3041676Sjpk 3051676Sjpk if (blequal(&rp1->rtsa_slrange.lower_bound, 3061676Sjpk &rp2->rtsa_slrange.lower_bound) && 3071676Sjpk blequal(&rp1->rtsa_slrange.upper_bound, 3081676Sjpk &rp2->rtsa_slrange.upper_bound) && 3091676Sjpk rp1->rtsa_doi == rp2->rtsa_doi) 3101676Sjpk return (0); 3111676Sjpk 3121676Sjpk /* No match; not found */ 3131676Sjpk return (-1); 3141676Sjpk } 3151676Sjpk 3161676Sjpk /* ARGSUSED */ 3171676Sjpk static uint_t 3181676Sjpk gcgrp_hash_by_addr(void *hash_data, mod_hash_key_t key) 3191676Sjpk { 3201676Sjpk tsol_gcgrp_addr_t *ga = (tsol_gcgrp_addr_t *)key; 3211676Sjpk uint_t idx = 0; 3221676Sjpk uint32_t *ap; 3231676Sjpk 3241676Sjpk ASSERT(ga != NULL); 3251676Sjpk ASSERT(ga->ga_af == AF_INET || ga->ga_af == AF_INET6); 3261676Sjpk 3271676Sjpk ap = (uint32_t *)&ga->ga_addr.s6_addr32[0]; 3281676Sjpk idx ^= *ap++; 3291676Sjpk idx ^= *ap++; 3301676Sjpk idx ^= *ap++; 3311676Sjpk idx ^= *ap; 3321676Sjpk 3331676Sjpk return (idx); 3341676Sjpk } 3351676Sjpk 3361676Sjpk static int 3371676Sjpk gcgrp_hash_cmp(mod_hash_key_t key1, mod_hash_key_t key2) 3381676Sjpk { 3391676Sjpk tsol_gcgrp_addr_t *ga1 = (tsol_gcgrp_addr_t *)key1; 3401676Sjpk tsol_gcgrp_addr_t *ga2 = (tsol_gcgrp_addr_t *)key2; 3411676Sjpk 3421676Sjpk ASSERT(ga1 != NULL && ga2 != NULL); 3431676Sjpk 3441676Sjpk /* Address family must match */ 3451676Sjpk if (ga1->ga_af != ga2->ga_af) 3461676Sjpk return (-1); 3471676Sjpk 3481676Sjpk if (ga1->ga_addr.s6_addr32[0] == ga2->ga_addr.s6_addr32[0] && 3491676Sjpk ga1->ga_addr.s6_addr32[1] == ga2->ga_addr.s6_addr32[1] && 3501676Sjpk ga1->ga_addr.s6_addr32[2] == ga2->ga_addr.s6_addr32[2] && 3511676Sjpk ga1->ga_addr.s6_addr32[3] == ga2->ga_addr.s6_addr32[3]) 3521676Sjpk return (0); 3531676Sjpk 3541676Sjpk /* No match; not found */ 3551676Sjpk return (-1); 3561676Sjpk } 3571676Sjpk 3581676Sjpk #define RTSAFLAGS "\20\11cipso\3doi\2max_sl\1min_sl" 3591676Sjpk 3601676Sjpk int 3611676Sjpk rtsa_validate(const struct rtsa_s *rp) 3621676Sjpk { 3631676Sjpk uint32_t mask = rp->rtsa_mask; 3641676Sjpk 3651676Sjpk /* RTSA_CIPSO must be set, and DOI must not be zero */ 3661676Sjpk if ((mask & RTSA_CIPSO) == 0 || rp->rtsa_doi == 0) { 3671676Sjpk DTRACE_PROBE2(tx__gcdb__log__error__rtsa__validate, char *, 3681676Sjpk "rtsa(1) lacks flag or has 0 doi.", 3691676Sjpk rtsa_s *, rp); 3701676Sjpk return (EINVAL); 3711676Sjpk } 3721676Sjpk /* 3731676Sjpk * SL range must be specified, and it must have its 3741676Sjpk * upper bound dominating its lower bound. 3751676Sjpk */ 3761676Sjpk if ((mask & RTSA_SLRANGE) != RTSA_SLRANGE || 3771676Sjpk !bldominates(&rp->rtsa_slrange.upper_bound, 3781676Sjpk &rp->rtsa_slrange.lower_bound)) { 3791676Sjpk DTRACE_PROBE2(tx__gcdb__log__error__rtsa__validate, char *, 3801676Sjpk "rtsa(1) min_sl and max_sl not set or max_sl is " 3811676Sjpk "not dominating.", rtsa_s *, rp); 3821676Sjpk return (EINVAL); 3831676Sjpk } 3841676Sjpk return (0); 3851676Sjpk } 3861676Sjpk 3871676Sjpk /* 3881676Sjpk * A brief explanation of the reference counting scheme: 3891676Sjpk * 3901676Sjpk * Prefix IREs have a non-NULL igsa_gc and a NULL igsa_gcgrp; 3911676Sjpk * IRE_CACHEs have it vice-versa. 3921676Sjpk * 3931676Sjpk * Apart from dynamic references due to to reference holds done 3941676Sjpk * actively by threads, we have the following references: 3951676Sjpk * 3961676Sjpk * gcdb_refcnt: 3971676Sjpk * - Every tsol_gc_t pointing to a tsol_gcdb_t contributes a reference 3981676Sjpk * to the gcdb_refcnt. 3991676Sjpk * 4001676Sjpk * gc_refcnt: 4011676Sjpk * - A prefix IRE that points to an igsa_gc contributes a reference 4021676Sjpk * to the gc_refcnt. 4031676Sjpk * 4041676Sjpk * gcgrp_refcnt: 4051676Sjpk * - An IRE_CACHE that points to an igsa_gcgrp contributes a reference 4061676Sjpk * to the gcgrp_refcnt of the associated tsol_gcgrp_t. 4071676Sjpk * - Every tsol_gc_t in the chain headed by tsol_gcgrp_t contributes 4081676Sjpk * a reference to the gcgrp_refcnt. 4091676Sjpk */ 4101676Sjpk static tsol_gcdb_t * 4111676Sjpk gcdb_lookup(struct rtsa_s *rp, boolean_t alloc) 4121676Sjpk { 4131676Sjpk tsol_gcdb_t *gcdb = NULL; 4141676Sjpk 4151676Sjpk if (rtsa_validate(rp) != 0) 4161676Sjpk return (NULL); 4171676Sjpk 4181676Sjpk mutex_enter(&gcdb_lock); 4191676Sjpk /* Find a copy in the cache; otherwise, create one and cache it */ 4201676Sjpk if (mod_hash_find(gcdb_hash, (mod_hash_key_t)rp, 4211676Sjpk (mod_hash_val_t *)&gcdb) == 0) { 4221676Sjpk gcdb->gcdb_refcnt++; 4231676Sjpk ASSERT(gcdb->gcdb_refcnt != 0); 4241676Sjpk 4251676Sjpk DTRACE_PROBE2(tx__gcdb__log__info__gcdb__lookup, char *, 4261676Sjpk "gcdb(1) is in gcdb_hash(global)", tsol_gcdb_t *, gcdb); 4271676Sjpk } else if (alloc) { 4281676Sjpk gcdb = kmem_zalloc(sizeof (*gcdb), KM_NOSLEEP); 4291676Sjpk if (gcdb != NULL) { 4301676Sjpk gcdb->gcdb_refcnt = 1; 4311676Sjpk gcdb->gcdb_mask = rp->rtsa_mask; 4321676Sjpk gcdb->gcdb_doi = rp->rtsa_doi; 4331676Sjpk gcdb->gcdb_slrange = rp->rtsa_slrange; 4341676Sjpk 4351676Sjpk if (mod_hash_insert(gcdb_hash, 4361676Sjpk (mod_hash_key_t)&gcdb->gcdb_attr, 4371676Sjpk (mod_hash_val_t)gcdb) != 0) { 4381676Sjpk mutex_exit(&gcdb_lock); 4391676Sjpk kmem_free(gcdb, sizeof (*gcdb)); 4401676Sjpk return (NULL); 4411676Sjpk } 4421676Sjpk 4431676Sjpk DTRACE_PROBE2(tx__gcdb__log__info__gcdb__insert, char *, 4441676Sjpk "gcdb(1) inserted in gcdb_hash(global)", 4451676Sjpk tsol_gcdb_t *, gcdb); 4461676Sjpk } 4471676Sjpk } 4481676Sjpk mutex_exit(&gcdb_lock); 4491676Sjpk return (gcdb); 4501676Sjpk } 4511676Sjpk 4521676Sjpk static void 4531676Sjpk gcdb_inactive(tsol_gcdb_t *gcdb) 4541676Sjpk { 4551676Sjpk ASSERT(MUTEX_HELD(&gcdb_lock)); 4561676Sjpk ASSERT(gcdb != NULL && gcdb->gcdb_refcnt == 0); 4571676Sjpk 4581676Sjpk (void) mod_hash_remove(gcdb_hash, (mod_hash_key_t)&gcdb->gcdb_attr, 4591676Sjpk (mod_hash_val_t *)&gcdb); 4601676Sjpk 4611676Sjpk DTRACE_PROBE2(tx__gcdb__log__info__gcdb__remove, char *, 4621676Sjpk "gcdb(1) removed from gcdb_hash(global)", 4631676Sjpk tsol_gcdb_t *, gcdb); 4641676Sjpk kmem_free(gcdb, sizeof (*gcdb)); 4651676Sjpk } 4661676Sjpk 4671676Sjpk tsol_gc_t * 4681676Sjpk gc_create(struct rtsa_s *rp, tsol_gcgrp_t *gcgrp, boolean_t *gcgrp_xtrarefp) 4691676Sjpk { 4701676Sjpk tsol_gc_t *gc; 4711676Sjpk tsol_gcdb_t *gcdb; 4721676Sjpk 4731676Sjpk *gcgrp_xtrarefp = B_TRUE; 4741676Sjpk 4751676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_WRITER); 4761676Sjpk if ((gcdb = gcdb_lookup(rp, B_TRUE)) == NULL) { 4771676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 4781676Sjpk return (NULL); 4791676Sjpk } 4801676Sjpk 4811676Sjpk for (gc = gcgrp->gcgrp_head; gc != NULL; gc = gc->gc_next) { 4821676Sjpk if (gc->gc_db == gcdb) { 4831676Sjpk ASSERT(gc->gc_grp == gcgrp); 4841676Sjpk 4851676Sjpk gc->gc_refcnt++; 4861676Sjpk ASSERT(gc->gc_refcnt != 0); 4871676Sjpk 4881676Sjpk GCDB_REFRELE(gcdb); 4891676Sjpk 4901676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gc__create, 4911676Sjpk char *, "found gc(1) in gcgrp(2)", 4921676Sjpk tsol_gc_t *, gc, tsol_gcgrp_t *, gcgrp); 4931676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 4941676Sjpk return (gc); 4951676Sjpk } 4961676Sjpk } 4971676Sjpk 4981676Sjpk gc = kmem_zalloc(sizeof (*gc), KM_NOSLEEP); 4991676Sjpk if (gc != NULL) { 5001676Sjpk if (gcgrp->gcgrp_head == NULL) { 5011676Sjpk gcgrp->gcgrp_head = gcgrp->gcgrp_tail = gc; 5021676Sjpk } else { 5031676Sjpk gcgrp->gcgrp_tail->gc_next = gc; 5041676Sjpk gc->gc_prev = gcgrp->gcgrp_tail; 5051676Sjpk gcgrp->gcgrp_tail = gc; 5061676Sjpk } 5071676Sjpk gcgrp->gcgrp_count++; 5081676Sjpk ASSERT(gcgrp->gcgrp_count != 0); 5091676Sjpk 5101676Sjpk /* caller has incremented gcgrp reference for us */ 5111676Sjpk gc->gc_grp = gcgrp; 5121676Sjpk 5131676Sjpk gc->gc_db = gcdb; 5141676Sjpk gc->gc_refcnt = 1; 5151676Sjpk 5161676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gc__create, char *, 5171676Sjpk "added gc(1) to gcgrp(2)", tsol_gc_t *, gc, 5181676Sjpk tsol_gcgrp_t *, gcgrp); 5191676Sjpk 5201676Sjpk *gcgrp_xtrarefp = B_FALSE; 5211676Sjpk } 5221676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 5231676Sjpk 5241676Sjpk return (gc); 5251676Sjpk } 5261676Sjpk 5271676Sjpk void 5281676Sjpk gc_inactive(tsol_gc_t *gc) 5291676Sjpk { 5301676Sjpk tsol_gcgrp_t *gcgrp = gc->gc_grp; 5311676Sjpk 5321676Sjpk ASSERT(gcgrp != NULL); 5331676Sjpk ASSERT(RW_WRITE_HELD(&gcgrp->gcgrp_rwlock)); 5341676Sjpk ASSERT(gc->gc_refcnt == 0); 5351676Sjpk 5361676Sjpk if (gc->gc_prev != NULL) 5371676Sjpk gc->gc_prev->gc_next = gc->gc_next; 5381676Sjpk else 5391676Sjpk gcgrp->gcgrp_head = gc->gc_next; 5401676Sjpk if (gc->gc_next != NULL) 5411676Sjpk gc->gc_next->gc_prev = gc->gc_prev; 5421676Sjpk else 5431676Sjpk gcgrp->gcgrp_tail = gc->gc_prev; 5441676Sjpk ASSERT(gcgrp->gcgrp_count > 0); 5451676Sjpk gcgrp->gcgrp_count--; 5461676Sjpk 5471676Sjpk /* drop lock before it's destroyed */ 5481676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 5491676Sjpk 5501676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gc__remove, char *, 5511676Sjpk "removed inactive gc(1) from gcgrp(2)", 5521676Sjpk tsol_gc_t *, gc, tsol_gcgrp_t *, gcgrp); 5531676Sjpk 5541676Sjpk GCGRP_REFRELE(gcgrp); 5551676Sjpk 5561676Sjpk gc->gc_grp = NULL; 5571676Sjpk gc->gc_prev = gc->gc_next = NULL; 5581676Sjpk 5591676Sjpk if (gc->gc_db != NULL) 5601676Sjpk GCDB_REFRELE(gc->gc_db); 5611676Sjpk 5621676Sjpk kmem_free(gc, sizeof (*gc)); 5631676Sjpk } 5641676Sjpk 5651676Sjpk tsol_gcgrp_t * 5661676Sjpk gcgrp_lookup(tsol_gcgrp_addr_t *ga, boolean_t alloc) 5671676Sjpk { 5681676Sjpk tsol_gcgrp_t *gcgrp = NULL; 5691676Sjpk mod_hash_t *hashp; 5701676Sjpk 5711676Sjpk ASSERT(ga->ga_af == AF_INET || ga->ga_af == AF_INET6); 5721676Sjpk 5731676Sjpk hashp = (ga->ga_af == AF_INET) ? gcgrp4_hash : gcgrp6_hash; 5741676Sjpk 5751676Sjpk mutex_enter(&gcgrp_lock); 5761676Sjpk if (mod_hash_find(hashp, (mod_hash_key_t)ga, 5771676Sjpk (mod_hash_val_t *)&gcgrp) == 0) { 5781676Sjpk gcgrp->gcgrp_refcnt++; 5791676Sjpk ASSERT(gcgrp->gcgrp_refcnt != 0); 5801676Sjpk 5811676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gcgrp__lookup, char *, 5821676Sjpk "found gcgrp(1) in hash(2)", tsol_gcgrp_t *, gcgrp, 5831676Sjpk mod_hash_t *, hashp); 5841676Sjpk 5851676Sjpk } else if (alloc) { 5861676Sjpk gcgrp = kmem_zalloc(sizeof (*gcgrp), KM_NOSLEEP); 5871676Sjpk if (gcgrp != NULL) { 5881676Sjpk gcgrp->gcgrp_refcnt = 1; 5891676Sjpk rw_init(&gcgrp->gcgrp_rwlock, NULL, RW_DEFAULT, NULL); 5901676Sjpk bcopy(ga, &gcgrp->gcgrp_addr, sizeof (*ga)); 5911676Sjpk 5921676Sjpk if (mod_hash_insert(hashp, 5931676Sjpk (mod_hash_key_t)&gcgrp->gcgrp_addr, 5941676Sjpk (mod_hash_val_t)gcgrp) != 0) { 5951676Sjpk mutex_exit(&gcgrp_lock); 5961676Sjpk kmem_free(gcgrp, sizeof (*gcgrp)); 5971676Sjpk return (NULL); 5981676Sjpk } 5991676Sjpk 6001676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gcgrp__insert, 6011676Sjpk char *, "inserted gcgrp(1) in hash(2)", 6021676Sjpk tsol_gcgrp_t *, gcgrp, mod_hash_t *, hashp); 6031676Sjpk } 6041676Sjpk } 6051676Sjpk mutex_exit(&gcgrp_lock); 6061676Sjpk return (gcgrp); 6071676Sjpk } 6081676Sjpk 6091676Sjpk void 6101676Sjpk gcgrp_inactive(tsol_gcgrp_t *gcgrp) 6111676Sjpk { 6121676Sjpk tsol_gcgrp_addr_t *ga; 6131676Sjpk mod_hash_t *hashp; 6141676Sjpk 6151676Sjpk ASSERT(MUTEX_HELD(&gcgrp_lock)); 6161676Sjpk ASSERT(!RW_LOCK_HELD(&gcgrp->gcgrp_rwlock)); 6171676Sjpk ASSERT(gcgrp != NULL && gcgrp->gcgrp_refcnt == 0); 6181676Sjpk ASSERT(gcgrp->gcgrp_head == NULL && gcgrp->gcgrp_count == 0); 6191676Sjpk 6201676Sjpk ga = &gcgrp->gcgrp_addr; 6211676Sjpk ASSERT(ga->ga_af == AF_INET || ga->ga_af == AF_INET6); 6221676Sjpk 6231676Sjpk hashp = (ga->ga_af == AF_INET) ? gcgrp4_hash : gcgrp6_hash; 6241676Sjpk (void) mod_hash_remove(hashp, (mod_hash_key_t)ga, 6251676Sjpk (mod_hash_val_t *)&gcgrp); 6261676Sjpk rw_destroy(&gcgrp->gcgrp_rwlock); 6271676Sjpk 6281676Sjpk DTRACE_PROBE3(tx__gcdb__log__info__gcgrp__remove, char *, 6291676Sjpk "removed inactive gcgrp(1) from hash(2)", 6301676Sjpk tsol_gcgrp_t *, gcgrp, mod_hash_t *, hashp); 6311676Sjpk 6321676Sjpk kmem_free(gcgrp, sizeof (*gcgrp)); 6331676Sjpk } 6341676Sjpk 6351676Sjpk /* 6361676Sjpk * Converts CIPSO option to sensitivity label. 6371676Sjpk * Validity checks based on restrictions defined in 6381676Sjpk * COMMERCIAL IP SECURITY OPTION (CIPSO 2.2) (draft-ietf-cipso-ipsecurity) 6391676Sjpk */ 6401676Sjpk static boolean_t 6411676Sjpk cipso_to_sl(const uchar_t *option, bslabel_t *sl) 6421676Sjpk { 6431676Sjpk const struct cipso_option *co = (const struct cipso_option *)option; 6441676Sjpk const struct cipso_tag_type_1 *tt1; 6451676Sjpk 6461676Sjpk tt1 = (struct cipso_tag_type_1 *)&co->cipso_tag_type[0]; 6471676Sjpk if (tt1->tag_type != 1 || 6481676Sjpk tt1->tag_length < TSOL_TT1_MIN_LENGTH || 6491676Sjpk tt1->tag_length > TSOL_TT1_MAX_LENGTH || 6501676Sjpk tt1->tag_length + TSOL_CIPSO_TAG_OFFSET > co->cipso_length) 6511676Sjpk return (B_FALSE); 6521676Sjpk 6531676Sjpk bsllow(sl); /* assumed: sets compartments to all zeroes */ 6541676Sjpk LCLASS_SET((_bslabel_impl_t *)sl, tt1->tag_sl); 6551676Sjpk bcopy(tt1->tag_cat, &((_bslabel_impl_t *)sl)->compartments, 6561676Sjpk tt1->tag_length - TSOL_TT1_MIN_LENGTH); 6571676Sjpk return (B_TRUE); 6581676Sjpk } 6591676Sjpk 6601676Sjpk /* 6611676Sjpk * Parse the CIPSO label in the incoming packet and construct a ts_label_t 6621676Sjpk * that reflects the CIPSO label and attach it to the dblk cred. Later as 6631676Sjpk * the mblk flows up through the stack any code that needs to examine the 6641676Sjpk * packet label can inspect the label from the dblk cred. This function is 6651676Sjpk * called right in ip_rput for all packets, i.e. locally destined and 6661676Sjpk * to be forwarded packets. The forwarding path needs to examine the label 6671676Sjpk * to determine how to forward the packet. 6681676Sjpk * 6691676Sjpk * For IPv4, IP header options have been pulled up, but other headers might not 6701676Sjpk * have been. For IPv6, any hop-by-hop options have been pulled up, but any 6711676Sjpk * other headers might not be present. 6721676Sjpk */ 6731676Sjpk boolean_t 6741676Sjpk tsol_get_pkt_label(mblk_t *mp, int version) 6751676Sjpk { 6761676Sjpk tsol_tpc_t *src_rhtp; 6771676Sjpk uchar_t *opt_ptr = NULL; 6781676Sjpk const ipha_t *ipha; 6791676Sjpk bslabel_t sl; 6801676Sjpk uint32_t doi; 6811676Sjpk tsol_ip_label_t label_type; 6821676Sjpk const cipso_option_t *co; 6831676Sjpk const void *src; 6841676Sjpk const ip6_t *ip6h; 6858778SErik.Nordmark@Sun.COM cred_t *credp; 6868778SErik.Nordmark@Sun.COM pid_t cpid; 6871676Sjpk 6881676Sjpk ASSERT(DB_TYPE(mp) == M_DATA); 6891676Sjpk 6901676Sjpk if (version == IPV4_VERSION) { 6911676Sjpk ipha = (const ipha_t *)mp->b_rptr; 6921676Sjpk src = &ipha->ipha_src; 6931676Sjpk label_type = tsol_get_option(mp, &opt_ptr); 6941676Sjpk } else { 6951676Sjpk uchar_t *after_secopt; 6961676Sjpk boolean_t hbh_needed; 6971676Sjpk const uchar_t *ip6hbh; 6981676Sjpk size_t optlen; 6991676Sjpk 7001676Sjpk label_type = OPT_NONE; 7011676Sjpk ip6h = (const ip6_t *)mp->b_rptr; 7021676Sjpk src = &ip6h->ip6_src; 7031676Sjpk if (ip6h->ip6_nxt == IPPROTO_HOPOPTS) { 7041676Sjpk ip6hbh = (const uchar_t *)&ip6h[1]; 7051676Sjpk optlen = (ip6hbh[1] + 1) << 3; 7061676Sjpk ASSERT(ip6hbh + optlen <= mp->b_wptr); 7071676Sjpk opt_ptr = tsol_find_secopt_v6(ip6hbh, optlen, 7081676Sjpk &after_secopt, &hbh_needed); 7091676Sjpk /* tsol_find_secopt_v6 guarantees some sanity */ 7101676Sjpk if (opt_ptr != NULL && 7111676Sjpk (optlen = opt_ptr[1]) >= 8) { 7121676Sjpk opt_ptr += 2; 7131676Sjpk bcopy(opt_ptr, &doi, sizeof (doi)); 7141676Sjpk doi = ntohl(doi); 7151676Sjpk if (doi == IP6LS_DOI_V4 && 7161676Sjpk opt_ptr[4] == IP6LS_TT_V4 && 7171676Sjpk opt_ptr[5] <= optlen - 4 && 7181676Sjpk opt_ptr[7] <= optlen - 6) { 7191676Sjpk opt_ptr += sizeof (doi) + 2; 7201676Sjpk label_type = OPT_CIPSO; 7211676Sjpk } 7221676Sjpk } 7231676Sjpk } 7241676Sjpk } 7251676Sjpk 7261676Sjpk switch (label_type) { 7271676Sjpk case OPT_CIPSO: 7281676Sjpk /* 7291676Sjpk * Convert the CIPSO label to the internal format 7301676Sjpk * and attach it to the dblk cred. 7311676Sjpk * Validity checks based on restrictions defined in 7321676Sjpk * COMMERCIAL IP SECURITY OPTION (CIPSO 2.2) 7331676Sjpk * (draft-ietf-cipso-ipsecurity) 7341676Sjpk */ 7351676Sjpk if (version == IPV6_VERSION && ip6opt_ls == 0) 7361676Sjpk return (B_FALSE); 7371676Sjpk co = (const struct cipso_option *)opt_ptr; 7381676Sjpk if ((co->cipso_length < 7391676Sjpk TSOL_CIPSO_TAG_OFFSET + TSOL_TT1_MIN_LENGTH) || 7401676Sjpk (co->cipso_length > IP_MAX_OPT_LENGTH)) 7411676Sjpk return (B_FALSE); 7421676Sjpk bcopy(co->cipso_doi, &doi, sizeof (doi)); 7431676Sjpk doi = ntohl(doi); 7441676Sjpk if (!cipso_to_sl(opt_ptr, &sl)) 7451676Sjpk return (B_FALSE); 7461676Sjpk setbltype(&sl, SUN_SL_ID); 7471676Sjpk break; 7481676Sjpk 7491676Sjpk case OPT_NONE: 7501676Sjpk /* 7511676Sjpk * Handle special cases that are not currently labeled, even 7521676Sjpk * though the sending system may otherwise be configured as 7531676Sjpk * labeled. 7541676Sjpk * - IGMP 7551676Sjpk * - IPv4 ICMP Router Discovery 7561676Sjpk * - IPv6 Neighbor Discovery 7571676Sjpk */ 7581676Sjpk if (version == IPV4_VERSION) { 7591676Sjpk if (ipha->ipha_protocol == IPPROTO_IGMP) 7601676Sjpk return (B_TRUE); 7611676Sjpk if (ipha->ipha_protocol == IPPROTO_ICMP) { 7621676Sjpk const struct icmp *icmp = (const struct icmp *) 7631676Sjpk (mp->b_rptr + IPH_HDR_LENGTH(ipha)); 7641676Sjpk 7651676Sjpk if ((uchar_t *)icmp > mp->b_wptr) { 7661676Sjpk if (!pullupmsg(mp, 7671676Sjpk (uchar_t *)icmp - mp->b_rptr + 1)) 7681676Sjpk return (B_FALSE); 7691676Sjpk icmp = (const struct icmp *) 7701676Sjpk (mp->b_rptr + 7711676Sjpk IPH_HDR_LENGTH(ipha)); 7721676Sjpk } 7731676Sjpk if (icmp->icmp_type == ICMP_ROUTERADVERT || 7741676Sjpk icmp->icmp_type == ICMP_ROUTERSOLICIT) 7751676Sjpk return (B_TRUE); 7761676Sjpk } 7771676Sjpk src = &ipha->ipha_src; 7781676Sjpk } else { 7791676Sjpk if (ip6h->ip6_nxt == IPPROTO_ICMPV6) { 7801676Sjpk const icmp6_t *icmp6 = (const icmp6_t *) 7811676Sjpk (mp->b_rptr + IPV6_HDR_LEN); 7821676Sjpk 7831676Sjpk if ((uchar_t *)icmp6 + ICMP6_MINLEN > 7841676Sjpk mp->b_wptr) { 7851676Sjpk if (!pullupmsg(mp, 7861676Sjpk (uchar_t *)icmp6 - mp->b_rptr + 7871676Sjpk ICMP6_MINLEN)) 7881676Sjpk return (B_FALSE); 7891676Sjpk icmp6 = (const icmp6_t *) 7901676Sjpk (mp->b_rptr + IPV6_HDR_LEN); 7911676Sjpk } 7921676Sjpk if (icmp6->icmp6_type >= MLD_LISTENER_QUERY && 7931676Sjpk icmp6->icmp6_type <= ICMP6_MAX_INFO_TYPE) 7941676Sjpk return (B_TRUE); 7951676Sjpk } 7961676Sjpk src = &ip6h->ip6_src; 7971676Sjpk } 7981676Sjpk 7991676Sjpk /* 8001676Sjpk * Look up the tnrhtp database and get the implicit label 8011676Sjpk * that is associated with this unlabeled host and attach 8021676Sjpk * it to the packet. 8031676Sjpk */ 8041676Sjpk if ((src_rhtp = find_tpc(src, version, B_FALSE)) == NULL) 8051676Sjpk return (B_FALSE); 8061676Sjpk 8071676Sjpk /* If the sender is labeled, drop the unlabeled packet. */ 8081676Sjpk if (src_rhtp->tpc_tp.host_type != UNLABELED) { 8091676Sjpk TPC_RELE(src_rhtp); 8101676Sjpk pr_addr_dbg("unlabeled packet forged from %s\n", 8111676Sjpk version == IPV4_VERSION ? AF_INET : AF_INET6, src); 8121676Sjpk return (B_FALSE); 8131676Sjpk } 8141676Sjpk 8151676Sjpk sl = src_rhtp->tpc_tp.tp_def_label; 8161676Sjpk setbltype(&sl, SUN_SL_ID); 8171676Sjpk doi = src_rhtp->tpc_tp.tp_doi; 8181676Sjpk TPC_RELE(src_rhtp); 8191676Sjpk break; 8201676Sjpk 8211676Sjpk default: 8221676Sjpk return (B_FALSE); 8231676Sjpk } 8241676Sjpk 8251676Sjpk /* Make sure no other thread is messing with this mblk */ 8261676Sjpk ASSERT(DB_REF(mp) == 1); 8278778SErik.Nordmark@Sun.COM /* Preserve db_cpid */ 8288778SErik.Nordmark@Sun.COM credp = msg_extractcred(mp, &cpid); 8298778SErik.Nordmark@Sun.COM if (credp == NULL) { 8308778SErik.Nordmark@Sun.COM credp = newcred_from_bslabel(&sl, doi, KM_NOSLEEP); 8311676Sjpk } else { 8321676Sjpk cred_t *newcr; 8331676Sjpk 8348778SErik.Nordmark@Sun.COM newcr = copycred_from_bslabel(credp, &sl, doi, 8351676Sjpk KM_NOSLEEP); 8368778SErik.Nordmark@Sun.COM crfree(credp); 8378778SErik.Nordmark@Sun.COM credp = newcr; 8381676Sjpk } 839*9041SErik.Nordmark@Sun.COM if (credp == NULL) 840*9041SErik.Nordmark@Sun.COM return (B_FALSE); 841*9041SErik.Nordmark@Sun.COM mblk_setcred(mp, credp, cpid); 842*9041SErik.Nordmark@Sun.COM crfree(credp); /* mblk has ref on cred */ 8431676Sjpk 8441676Sjpk /* 8451676Sjpk * If the source was unlabeled, then flag as such, 8461676Sjpk * while remembering that CIPSO routers add headers. 8471676Sjpk */ 8488778SErik.Nordmark@Sun.COM if (label_type == OPT_NONE) { 8498778SErik.Nordmark@Sun.COM crgetlabel(credp)->tsl_flags |= TSLF_UNLABELED; 8508778SErik.Nordmark@Sun.COM } else if (label_type == OPT_CIPSO) { 8511676Sjpk if ((src_rhtp = find_tpc(src, version, B_FALSE)) == NULL) 8521676Sjpk return (B_FALSE); 8531676Sjpk if (src_rhtp->tpc_tp.host_type == UNLABELED) 8548778SErik.Nordmark@Sun.COM crgetlabel(credp)->tsl_flags |= TSLF_UNLABELED; 8551676Sjpk TPC_RELE(src_rhtp); 8561676Sjpk } 8571676Sjpk 8581676Sjpk return (B_TRUE); 8591676Sjpk } 8601676Sjpk 8611676Sjpk /* 8621676Sjpk * This routine determines whether the given packet should be accepted locally. 8631676Sjpk * It does a range/set check on the packet's label by looking up the given 8641676Sjpk * address in the remote host database. 8651676Sjpk */ 8661676Sjpk boolean_t 8671676Sjpk tsol_receive_local(const mblk_t *mp, const void *addr, uchar_t version, 8681676Sjpk boolean_t shared_addr, const conn_t *connp) 8691676Sjpk { 8701676Sjpk const cred_t *credp; 8711676Sjpk ts_label_t *plabel, *conn_plabel; 8721676Sjpk tsol_tpc_t *tp; 8731676Sjpk boolean_t retv; 8741676Sjpk const bslabel_t *label, *conn_label; 8751676Sjpk 8761676Sjpk /* 8771676Sjpk * The cases in which this can happen are: 8781676Sjpk * - IPv6 Router Alert, where ip_rput_data_v6 deliberately skips 8791676Sjpk * over the label attachment process. 8801676Sjpk * - MLD output looped-back to ourselves. 8811676Sjpk * - IPv4 Router Discovery, where tsol_get_pkt_label intentionally 8821676Sjpk * avoids the labeling process. 8831676Sjpk * We trust that all valid paths in the code set the cred pointer when 8841676Sjpk * needed. 8851676Sjpk */ 8868778SErik.Nordmark@Sun.COM if ((credp = msg_getcred(mp, NULL)) == NULL) 8871676Sjpk return (B_TRUE); 8881676Sjpk 8891676Sjpk /* 8901676Sjpk * If this packet is from the inside (not a remote host) and has the 8911676Sjpk * same zoneid as the selected destination, then no checks are 8921676Sjpk * necessary. Membership in the zone is enough proof. This is 8931676Sjpk * intended to be a hot path through this function. 8941676Sjpk */ 8951676Sjpk if (!crisremote(credp) && 8961676Sjpk crgetzone(credp) == crgetzone(connp->conn_cred)) 8971676Sjpk return (B_TRUE); 8981676Sjpk 8991676Sjpk plabel = crgetlabel(credp); 9001676Sjpk conn_plabel = crgetlabel(connp->conn_cred); 9011676Sjpk ASSERT(plabel != NULL && conn_plabel != NULL); 9021676Sjpk 9031676Sjpk label = label2bslabel(plabel); 9041676Sjpk conn_label = label2bslabel(crgetlabel(connp->conn_cred)); 9051676Sjpk 9061676Sjpk /* 9071676Sjpk * MLPs are always validated using the range and set of the local 9081676Sjpk * address, even when the remote host is unlabeled. 9091676Sjpk */ 9101676Sjpk if (connp->conn_mlp_type == mlptBoth || 9111676Sjpk /* LINTED: no consequent */ 9121676Sjpk connp->conn_mlp_type == (shared_addr ? mlptShared : mlptPrivate)) { 9131676Sjpk ; 9141676Sjpk 9151676Sjpk /* 9161676Sjpk * If this is a packet from an unlabeled sender, then we must apply 9171676Sjpk * different rules. If the label is equal to the zone's label, then 9181676Sjpk * it's allowed. If it's not equal, but the zone is either the global 9191676Sjpk * zone or the label is dominated by the zone's label, then allow it 9201676Sjpk * as long as it's in the range configured for the destination. 9211676Sjpk */ 9221676Sjpk } else if (plabel->tsl_flags & TSLF_UNLABELED) { 9231676Sjpk if (plabel->tsl_doi == conn_plabel->tsl_doi && 9241676Sjpk blequal(label, conn_label)) 9251676Sjpk return (B_TRUE); 9261676Sjpk 9273448Sdh155122 /* 9283448Sdh155122 * conn_zoneid is global for an exclusive stack, thus we use 9293448Sdh155122 * conn_cred to get the zoneid 9303448Sdh155122 */ 9311676Sjpk if (!connp->conn_mac_exempt || 9323448Sdh155122 (crgetzoneid(connp->conn_cred) != GLOBAL_ZONEID && 9331676Sjpk (plabel->tsl_doi != conn_plabel->tsl_doi || 9341676Sjpk !bldominates(conn_label, label)))) { 9351676Sjpk DTRACE_PROBE3( 9361676Sjpk tx__ip__log__drop__receivelocal__mac_unl, 9371676Sjpk char *, 9381676Sjpk "unlabeled packet mp(1) fails mac for conn(2)", 9391676Sjpk mblk_t *, mp, conn_t *, connp); 9401676Sjpk return (B_FALSE); 9411676Sjpk } 9421676Sjpk 9431676Sjpk /* 9444448Skp158701 * If this is a packet from a labeled sender, verify the 9454448Skp158701 * label on the packet matches the connection label. 9461676Sjpk */ 9474448Skp158701 } else { 9484448Skp158701 if (plabel->tsl_doi != conn_plabel->tsl_doi || 9494448Skp158701 !blequal(label, conn_label)) { 9504448Skp158701 DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac__slp, 9514448Skp158701 char *, 9524448Skp158701 "packet mp(1) failed label match to SLP conn(2)", 9534448Skp158701 mblk_t *, mp, conn_t *, connp); 9544448Skp158701 return (B_FALSE); 9554448Skp158701 } 9561676Sjpk /* 9574448Skp158701 * No further checks will be needed if this is a zone- 9584448Skp158701 * specific address because (1) The process for bringing up 9594448Skp158701 * the interface ensures the zone's label is within the zone- 9604448Skp158701 * specific address's valid label range; (2) For cases where 9614448Skp158701 * the conn is bound to the unspecified addresses, ip fanout 9624448Skp158701 * logic ensures conn's zoneid equals the dest addr's zoneid; 9634448Skp158701 * (3) Mac-exempt and mlp logic above already handle all 9644448Skp158701 * cases where the zone label may not be the same as the 9654448Skp158701 * conn label. 9661676Sjpk */ 9674448Skp158701 if (!shared_addr) 9681676Sjpk return (B_TRUE); 9691676Sjpk } 9701676Sjpk 9711676Sjpk tp = find_tpc(addr, version, B_FALSE); 9721676Sjpk if (tp == NULL) { 9731676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__no__tnr, 9741676Sjpk char *, "dropping mp(1), host(2) lacks entry", 9751676Sjpk mblk_t *, mp, void *, addr); 9761676Sjpk return (B_FALSE); 9771676Sjpk } 9781676Sjpk 9791676Sjpk /* 9801676Sjpk * The local host address should not be unlabeled at this point. The 9811676Sjpk * only way this can happen is that the destination isn't unicast. We 9821676Sjpk * assume that the packet should not have had a label, and thus should 9831676Sjpk * have been handled by the TSLF_UNLABELED logic above. 9841676Sjpk */ 9851676Sjpk if (tp->tpc_tp.host_type == UNLABELED) { 9861676Sjpk retv = B_FALSE; 9871676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__flag, char *, 9881676Sjpk "mp(1) unlabeled source, but tp is not unlabeled.", 9891676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 9901676Sjpk 9911676Sjpk } else if (tp->tpc_tp.host_type != SUN_CIPSO) { 9921676Sjpk retv = B_FALSE; 9931676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__tptype, char *, 9941676Sjpk "delivering mp(1), found unrecognized tpc(2) type.", 9951676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 9961676Sjpk 9971676Sjpk } else if (plabel->tsl_doi != tp->tpc_tp.tp_doi) { 9981676Sjpk retv = B_FALSE; 9991676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac, char *, 10001676Sjpk "mp(1) could not be delievered to tp(2), doi mismatch", 10011676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 10021676Sjpk 10031676Sjpk } else if (!_blinrange(label, &tp->tpc_tp.tp_sl_range_cipso) && 10041676Sjpk !blinlset(label, tp->tpc_tp.tp_sl_set_cipso)) { 10051676Sjpk retv = B_FALSE; 10061676Sjpk DTRACE_PROBE3(tx__ip__log__drop__receivelocal__mac, char *, 10071676Sjpk "mp(1) could not be delievered to tp(2), bad mac", 10081676Sjpk mblk_t *, mp, tsol_tpc_t *, tp); 10091676Sjpk } else { 10101676Sjpk retv = B_TRUE; 10111676Sjpk } 10121676Sjpk 10131676Sjpk TPC_RELE(tp); 10141676Sjpk 10151676Sjpk return (retv); 10161676Sjpk } 10171676Sjpk 10181676Sjpk boolean_t 10191676Sjpk tsol_can_accept_raw(mblk_t *mp, boolean_t check_host) 10201676Sjpk { 10211676Sjpk ts_label_t *plabel = NULL; 10221676Sjpk tsol_tpc_t *src_rhtp, *dst_rhtp; 10231676Sjpk boolean_t retv; 10248778SErik.Nordmark@Sun.COM cred_t *credp; 10251676Sjpk 10268778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 10278778SErik.Nordmark@Sun.COM if (credp != NULL) 10288778SErik.Nordmark@Sun.COM plabel = crgetlabel(credp); 10291676Sjpk 10301676Sjpk /* We are bootstrapping or the internal template was never deleted */ 10311676Sjpk if (plabel == NULL) 10321676Sjpk return (B_TRUE); 10331676Sjpk 10341676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 10351676Sjpk ipha_t *ipha = (ipha_t *)mp->b_rptr; 10361676Sjpk 10371676Sjpk src_rhtp = find_tpc(&ipha->ipha_src, IPV4_VERSION, 10381676Sjpk B_FALSE); 10391676Sjpk if (src_rhtp == NULL) 10401676Sjpk return (B_FALSE); 10411676Sjpk dst_rhtp = find_tpc(&ipha->ipha_dst, IPV4_VERSION, 10421676Sjpk B_FALSE); 10431676Sjpk } else { 10441676Sjpk ip6_t *ip6h = (ip6_t *)mp->b_rptr; 10451676Sjpk 10461676Sjpk src_rhtp = find_tpc(&ip6h->ip6_src, IPV6_VERSION, 10471676Sjpk B_FALSE); 10481676Sjpk if (src_rhtp == NULL) 10491676Sjpk return (B_FALSE); 10501676Sjpk dst_rhtp = find_tpc(&ip6h->ip6_dst, IPV6_VERSION, 10511676Sjpk B_FALSE); 10521676Sjpk } 10531676Sjpk if (dst_rhtp == NULL) { 10541676Sjpk TPC_RELE(src_rhtp); 10551676Sjpk return (B_FALSE); 10561676Sjpk } 10571676Sjpk 10581676Sjpk if (label2doi(plabel) != src_rhtp->tpc_tp.tp_doi) { 10591676Sjpk retv = B_FALSE; 10601676Sjpk 10611676Sjpk /* 10621676Sjpk * Check that the packet's label is in the correct range for labeled 10631676Sjpk * sender, or is equal to the default label for unlabeled sender. 10641676Sjpk */ 10651676Sjpk } else if ((src_rhtp->tpc_tp.host_type != UNLABELED && 10661676Sjpk !_blinrange(label2bslabel(plabel), 10671676Sjpk &src_rhtp->tpc_tp.tp_sl_range_cipso) && 10681676Sjpk !blinlset(label2bslabel(plabel), 10691676Sjpk src_rhtp->tpc_tp.tp_sl_set_cipso)) || 10701676Sjpk (src_rhtp->tpc_tp.host_type == UNLABELED && 10711676Sjpk !blequal(&plabel->tsl_label, &src_rhtp->tpc_tp.tp_def_label))) { 10721676Sjpk retv = B_FALSE; 10731676Sjpk 10741676Sjpk } else if (check_host) { 10751676Sjpk retv = B_TRUE; 10761676Sjpk 10771676Sjpk /* 10781676Sjpk * Until we have SL range in the Zone structure, pass it 10791676Sjpk * when our own address lookup returned an internal entry. 10801676Sjpk */ 10811676Sjpk } else switch (dst_rhtp->tpc_tp.host_type) { 10821676Sjpk case UNLABELED: 10831676Sjpk retv = B_TRUE; 10841676Sjpk break; 10851676Sjpk 10861676Sjpk case SUN_CIPSO: 10871676Sjpk retv = _blinrange(label2bslabel(plabel), 10881676Sjpk &dst_rhtp->tpc_tp.tp_sl_range_cipso) || 10891676Sjpk blinlset(label2bslabel(plabel), 10901676Sjpk dst_rhtp->tpc_tp.tp_sl_set_cipso); 10911676Sjpk break; 10921676Sjpk 10931676Sjpk default: 10941676Sjpk retv = B_FALSE; 10951676Sjpk } 10961676Sjpk TPC_RELE(src_rhtp); 10971676Sjpk TPC_RELE(dst_rhtp); 10981676Sjpk return (retv); 10991676Sjpk } 11001676Sjpk 11011676Sjpk /* 11021676Sjpk * This routine determines whether a response to a failed packet delivery or 11031676Sjpk * connection should be sent back. By default, the policy is to allow such 11041676Sjpk * messages to be sent at all times, as these messages reveal little useful 11051676Sjpk * information and are healthy parts of TCP/IP networking. 11061676Sjpk * 11071676Sjpk * If tsol_strict_error is set, then we do strict tests: if the packet label is 11081676Sjpk * within the label range/set of this host/zone, return B_TRUE; otherwise 11091676Sjpk * return B_FALSE, which causes the packet to be dropped silently. 11101676Sjpk * 11111676Sjpk * Note that tsol_get_pkt_label will cause the packet to drop if the sender is 11121676Sjpk * marked as labeled in the remote host database, but the packet lacks a label. 11131676Sjpk * This means that we don't need to do a lookup on the source; the 11141676Sjpk * TSLF_UNLABELED flag is sufficient. 11151676Sjpk */ 11161676Sjpk boolean_t 11171676Sjpk tsol_can_reply_error(const mblk_t *mp) 11181676Sjpk { 11191676Sjpk ts_label_t *plabel = NULL; 11201676Sjpk tsol_tpc_t *rhtp; 11211676Sjpk const ipha_t *ipha; 11221676Sjpk const ip6_t *ip6h; 11231676Sjpk boolean_t retv; 11241676Sjpk bslabel_t *pktbs; 11258778SErik.Nordmark@Sun.COM cred_t *credp; 11261676Sjpk 11271676Sjpk /* Caller must pull up at least the IP header */ 11281676Sjpk ASSERT(MBLKL(mp) >= (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION ? 11291676Sjpk sizeof (*ipha) : sizeof (*ip6h))); 11301676Sjpk 11311676Sjpk if (!tsol_strict_error) 11321676Sjpk return (B_TRUE); 11331676Sjpk 11348778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 11358778SErik.Nordmark@Sun.COM if (credp != NULL) 11368778SErik.Nordmark@Sun.COM plabel = crgetlabel(credp); 11371676Sjpk 11381676Sjpk /* We are bootstrapping or the internal template was never deleted */ 11391676Sjpk if (plabel == NULL) 11401676Sjpk return (B_TRUE); 11411676Sjpk 11421676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 11431676Sjpk ipha = (const ipha_t *)mp->b_rptr; 11441676Sjpk rhtp = find_tpc(&ipha->ipha_dst, IPV4_VERSION, B_FALSE); 11451676Sjpk } else { 11461676Sjpk ip6h = (const ip6_t *)mp->b_rptr; 11471676Sjpk rhtp = find_tpc(&ip6h->ip6_dst, IPV6_VERSION, B_FALSE); 11481676Sjpk } 11491676Sjpk 11501676Sjpk if (rhtp == NULL || label2doi(plabel) != rhtp->tpc_tp.tp_doi) { 11511676Sjpk retv = B_FALSE; 11521676Sjpk } else { 11531676Sjpk /* 11541676Sjpk * If we're in the midst of forwarding, then the destination 11551676Sjpk * address might not be labeled. In that case, allow unlabeled 11561676Sjpk * packets through only if the default label is the same, and 11571676Sjpk * labeled ones if they dominate. 11581676Sjpk */ 11591676Sjpk pktbs = label2bslabel(plabel); 11601676Sjpk switch (rhtp->tpc_tp.host_type) { 11611676Sjpk case UNLABELED: 11621676Sjpk if (plabel->tsl_flags & TSLF_UNLABELED) { 11631676Sjpk retv = blequal(pktbs, 11641676Sjpk &rhtp->tpc_tp.tp_def_label); 11651676Sjpk } else { 11661676Sjpk retv = bldominates(pktbs, 11671676Sjpk &rhtp->tpc_tp.tp_def_label); 11681676Sjpk } 11691676Sjpk break; 11701676Sjpk 11711676Sjpk case SUN_CIPSO: 11721676Sjpk retv = _blinrange(pktbs, 11731676Sjpk &rhtp->tpc_tp.tp_sl_range_cipso) || 11741676Sjpk blinlset(pktbs, rhtp->tpc_tp.tp_sl_set_cipso); 11751676Sjpk break; 11761676Sjpk 11771676Sjpk default: 11781676Sjpk retv = B_FALSE; 11791676Sjpk break; 11801676Sjpk } 11811676Sjpk } 11821676Sjpk 11831676Sjpk if (rhtp != NULL) 11841676Sjpk TPC_RELE(rhtp); 11851676Sjpk 11861676Sjpk return (retv); 11871676Sjpk } 11881676Sjpk 11891676Sjpk /* 11901676Sjpk * Finds the zone associated with the given packet. Returns GLOBAL_ZONEID if 11911676Sjpk * the zone cannot be located. 11921676Sjpk * 11931676Sjpk * This is used by the classifier when the packet matches an ALL_ZONES IRE, and 11941676Sjpk * there's no MLP defined. 11953448Sdh155122 * 11963448Sdh155122 * Note that we assume that this is only invoked in the ALL_ZONES case. 11973448Sdh155122 * Handling other cases would require handle exclusive stack zones where either 11983448Sdh155122 * this routine or the callers would have to map from 11993448Sdh155122 * the zoneid (zone->zone_id) to what IP uses in conn_zoneid etc. 12001676Sjpk */ 12011676Sjpk zoneid_t 12021676Sjpk tsol_packet_to_zoneid(const mblk_t *mp) 12031676Sjpk { 12048778SErik.Nordmark@Sun.COM cred_t *cr = msg_getcred(mp, NULL); 12051676Sjpk zone_t *zone; 12061676Sjpk ts_label_t *label; 12071676Sjpk 12081676Sjpk if (cr != NULL) { 12091676Sjpk if ((label = crgetlabel(cr)) != NULL) { 12101676Sjpk zone = zone_find_by_label(label); 12111676Sjpk if (zone != NULL) { 12121676Sjpk zoneid_t zoneid = zone->zone_id; 12131676Sjpk 12141676Sjpk zone_rele(zone); 12151676Sjpk return (zoneid); 12161676Sjpk } 12171676Sjpk } 12181676Sjpk } 12191676Sjpk return (GLOBAL_ZONEID); 12201676Sjpk } 12211676Sjpk 12221676Sjpk int 12231676Sjpk tsol_ire_match_gwattr(ire_t *ire, const ts_label_t *tsl) 12241676Sjpk { 12251676Sjpk int error = 0; 12261676Sjpk tsol_ire_gw_secattr_t *attrp = NULL; 12271676Sjpk tsol_tnrhc_t *gw_rhc = NULL; 12281676Sjpk tsol_gcgrp_t *gcgrp = NULL; 12291676Sjpk tsol_gc_t *gc = NULL; 12301676Sjpk in_addr_t ga_addr4; 12311676Sjpk void *paddr = NULL; 12321676Sjpk 12331676Sjpk /* Not in Trusted mode or IRE is local/loopback/broadcast/interface */ 12341676Sjpk if (!is_system_labeled() || 12351676Sjpk (ire->ire_type & (IRE_LOCAL | IRE_LOOPBACK | IRE_BROADCAST | 12361676Sjpk IRE_INTERFACE))) 12371676Sjpk goto done; 12381676Sjpk 12391676Sjpk /* 12401676Sjpk * If we don't have a label to compare with, or the IRE does not 12411676Sjpk * contain any gateway security attributes, there's not much that 12421676Sjpk * we can do. We let the former case pass, and the latter fail, 12431676Sjpk * since the IRE doesn't qualify for a match due to the lack of 12441676Sjpk * security attributes. 12451676Sjpk */ 12461676Sjpk if (tsl == NULL || ire->ire_gw_secattr == NULL) { 12471676Sjpk if (tsl != NULL) { 12486596Skp158701 DTRACE_PROBE3(tx__ip__log__drop__irematch__nogwsec, 12496596Skp158701 char *, 12506596Skp158701 "ire(1) lacks ire_gw_secattr matching label(2)", 12516596Skp158701 ire_t *, ire, ts_label_t *, tsl); 12521676Sjpk error = EACCES; 12531676Sjpk } 12541676Sjpk goto done; 12551676Sjpk } 12561676Sjpk 12571676Sjpk attrp = ire->ire_gw_secattr; 12581676Sjpk 12591676Sjpk /* 12601676Sjpk * The possible lock order scenarios related to the tsol gateway 12611676Sjpk * attribute locks are documented at the beginning of ip.c in the 12621676Sjpk * lock order scenario section. 12631676Sjpk */ 12641676Sjpk mutex_enter(&attrp->igsa_lock); 12651676Sjpk 12661676Sjpk /* 12671676Sjpk * Depending on the IRE type (prefix vs. cache), we seek the group 12681676Sjpk * structure which contains all security credentials of the gateway. 12691676Sjpk * A prefix IRE is associated with at most one gateway credential, 12701676Sjpk * while a cache IRE is associated with every credentials that the 12711676Sjpk * gateway has. 12721676Sjpk */ 12731676Sjpk if ((gc = attrp->igsa_gc) != NULL) { /* prefix */ 12741676Sjpk gcgrp = gc->gc_grp; 12751676Sjpk ASSERT(gcgrp != NULL); 12761676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_READER); 12771676Sjpk } else if ((gcgrp = attrp->igsa_gcgrp) != NULL) { /* cache */ 12781676Sjpk rw_enter(&gcgrp->gcgrp_rwlock, RW_READER); 12791676Sjpk gc = gcgrp->gcgrp_head; 12801676Sjpk if (gc == NULL) { 12811676Sjpk /* gc group is empty, so the drop lock now */ 12821676Sjpk ASSERT(gcgrp->gcgrp_count == 0); 12831676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 12841676Sjpk gcgrp = NULL; 12851676Sjpk } 12861676Sjpk } 12871676Sjpk 12881676Sjpk if (gcgrp != NULL) 12891676Sjpk GCGRP_REFHOLD(gcgrp); 12901676Sjpk 12911676Sjpk if ((gw_rhc = attrp->igsa_rhc) != NULL) { 12921676Sjpk /* 12931676Sjpk * If our cached entry has grown stale, then discard it so we 12941676Sjpk * can get a new one. 12951676Sjpk */ 12961676Sjpk if (gw_rhc->rhc_invalid || gw_rhc->rhc_tpc->tpc_invalid) { 12971676Sjpk TNRHC_RELE(gw_rhc); 12981676Sjpk attrp->igsa_rhc = gw_rhc = NULL; 12991676Sjpk } else { 13001676Sjpk TNRHC_HOLD(gw_rhc) 13011676Sjpk } 13021676Sjpk } 13031676Sjpk 13041676Sjpk /* Last attempt at loading the template had failed; try again */ 13051676Sjpk if (gw_rhc == NULL) { 13061676Sjpk if (gcgrp != NULL) { 13071676Sjpk tsol_gcgrp_addr_t *ga = &gcgrp->gcgrp_addr; 13081676Sjpk 13091676Sjpk if (ire->ire_ipversion == IPV4_VERSION) { 13101676Sjpk ASSERT(ga->ga_af == AF_INET); 13111676Sjpk IN6_V4MAPPED_TO_IPADDR(&ga->ga_addr, ga_addr4); 13121676Sjpk paddr = &ga_addr4; 13131676Sjpk } else { 13141676Sjpk ASSERT(ga->ga_af == AF_INET6); 13151676Sjpk paddr = &ga->ga_addr; 13161676Sjpk } 13171676Sjpk } else if (ire->ire_ipversion == IPV6_VERSION && 13181676Sjpk !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6)) { 13191676Sjpk paddr = &ire->ire_gateway_addr_v6; 13201676Sjpk } else if (ire->ire_ipversion == IPV4_VERSION && 13211676Sjpk ire->ire_gateway_addr != INADDR_ANY) { 13221676Sjpk paddr = &ire->ire_gateway_addr; 13231676Sjpk } 13241676Sjpk 13251676Sjpk /* We've found a gateway address to do the template lookup */ 13261676Sjpk if (paddr != NULL) { 13271676Sjpk ASSERT(gw_rhc == NULL); 13283292Skp158701 gw_rhc = find_rhc(paddr, ire->ire_ipversion, B_FALSE); 13291676Sjpk if (gw_rhc != NULL) { 13301676Sjpk /* 13311676Sjpk * Note that if the lookup above returned an 13321676Sjpk * internal template, we'll use it for the 13331676Sjpk * time being, and do another lookup next 13341676Sjpk * time around. 13351676Sjpk */ 13361676Sjpk /* Another thread has loaded the template? */ 13371676Sjpk if (attrp->igsa_rhc != NULL) { 13381676Sjpk TNRHC_RELE(gw_rhc) 13391676Sjpk /* reload, it could be different */ 13401676Sjpk gw_rhc = attrp->igsa_rhc; 13411676Sjpk } else { 13421676Sjpk attrp->igsa_rhc = gw_rhc; 13431676Sjpk } 13441676Sjpk /* 13451676Sjpk * Hold an extra reference just like we did 13461676Sjpk * above prior to dropping the igsa_lock. 13471676Sjpk */ 13481676Sjpk TNRHC_HOLD(gw_rhc) 13491676Sjpk } 13501676Sjpk } 13511676Sjpk } 13521676Sjpk 13531676Sjpk mutex_exit(&attrp->igsa_lock); 13541676Sjpk /* Gateway template not found */ 13551676Sjpk if (gw_rhc == NULL) { 13561676Sjpk /* 13571676Sjpk * If destination address is directly reachable through an 13581676Sjpk * interface rather than through a learned route, pass it. 13591676Sjpk */ 13601676Sjpk if (paddr != NULL) { 13611676Sjpk DTRACE_PROBE3( 13621676Sjpk tx__ip__log__drop__irematch__nogwtmpl, char *, 13631676Sjpk "ire(1), label(2) off-link with no gw_rhc", 13641676Sjpk ire_t *, ire, ts_label_t *, tsl); 13651676Sjpk error = EINVAL; 13661676Sjpk } 13671676Sjpk goto done; 13681676Sjpk } 13691676Sjpk 13701676Sjpk if (gc != NULL) { 13711676Sjpk tsol_gcdb_t *gcdb; 13721676Sjpk /* 13731676Sjpk * In the case of IRE_CACHE we've got one or more gateway 13741676Sjpk * security credentials to compare against the passed in label. 13751676Sjpk * Perform label range comparison against each security 13761676Sjpk * credential of the gateway. In the case of a prefix ire 13771676Sjpk * we need to match against the security attributes of 13781676Sjpk * just the route itself, so the loop is executed only once. 13791676Sjpk */ 13801676Sjpk ASSERT(gcgrp != NULL); 13811676Sjpk do { 13821676Sjpk gcdb = gc->gc_db; 13831676Sjpk if (tsl->tsl_doi == gcdb->gcdb_doi && 13841676Sjpk _blinrange(&tsl->tsl_label, &gcdb->gcdb_slrange)) 13851676Sjpk break; 13861676Sjpk if (ire->ire_type == IRE_CACHE) 13871676Sjpk gc = gc->gc_next; 13881676Sjpk else 13891676Sjpk gc = NULL; 13901676Sjpk } while (gc != NULL); 13911676Sjpk 13921676Sjpk if (gc == NULL) { 13931676Sjpk DTRACE_PROBE3( 13941676Sjpk tx__ip__log__drop__irematch__nogcmatched, 13951676Sjpk char *, "ire(1), tsl(2): all gc failed match", 13961676Sjpk ire_t *, ire, ts_label_t *, tsl); 13971676Sjpk error = EACCES; 13981676Sjpk } 13991676Sjpk } else { 14001676Sjpk /* 14011676Sjpk * We didn't find any gateway credentials in the IRE 14021676Sjpk * attributes; fall back to the gateway's template for 14031676Sjpk * label range checks, if we are required to do so. 14041676Sjpk */ 14051676Sjpk ASSERT(gw_rhc != NULL); 14061676Sjpk switch (gw_rhc->rhc_tpc->tpc_tp.host_type) { 14071676Sjpk case SUN_CIPSO: 14086596Skp158701 if (tsl->tsl_doi != gw_rhc->rhc_tpc->tpc_tp.tp_doi || 14091676Sjpk (!_blinrange(&tsl->tsl_label, 14106596Skp158701 &gw_rhc->rhc_tpc->tpc_tp.tp_sl_range_cipso) && 14111676Sjpk !blinlset(&tsl->tsl_label, 14121676Sjpk gw_rhc->rhc_tpc->tpc_tp.tp_sl_set_cipso))) { 14131676Sjpk error = EACCES; 14141676Sjpk DTRACE_PROBE4( 14151676Sjpk tx__ip__log__drop__irematch__deftmpl, 14161676Sjpk char *, "ire(1), tsl(2), gw_rhc(3) " 14171676Sjpk "failed match (cipso gw)", 14181676Sjpk ire_t *, ire, ts_label_t *, tsl, 14191676Sjpk tsol_tnrhc_t *, gw_rhc); 14201676Sjpk } 14211676Sjpk break; 14221676Sjpk 14231676Sjpk case UNLABELED: 14246596Skp158701 if (tsl->tsl_doi != gw_rhc->rhc_tpc->tpc_tp.tp_doi || 14251676Sjpk (!_blinrange(&tsl->tsl_label, 14261676Sjpk &gw_rhc->rhc_tpc->tpc_tp.tp_gw_sl_range) && 14271676Sjpk !blinlset(&tsl->tsl_label, 14281676Sjpk gw_rhc->rhc_tpc->tpc_tp.tp_gw_sl_set))) { 14291676Sjpk error = EACCES; 14301676Sjpk DTRACE_PROBE4( 14311676Sjpk tx__ip__log__drop__irematch__deftmpl, 14321676Sjpk char *, "ire(1), tsl(2), gw_rhc(3) " 14331676Sjpk "failed match (unlabeled gw)", 14341676Sjpk ire_t *, ire, ts_label_t *, tsl, 14351676Sjpk tsol_tnrhc_t *, gw_rhc); 14361676Sjpk } 14371676Sjpk break; 14381676Sjpk } 14391676Sjpk } 14401676Sjpk 14411676Sjpk done: 14421676Sjpk 14431676Sjpk if (gcgrp != NULL) { 14441676Sjpk rw_exit(&gcgrp->gcgrp_rwlock); 14451676Sjpk GCGRP_REFRELE(gcgrp); 14461676Sjpk } 14471676Sjpk 14481676Sjpk if (gw_rhc != NULL) 14491676Sjpk TNRHC_RELE(gw_rhc) 14501676Sjpk 14511676Sjpk return (error); 14521676Sjpk } 14531676Sjpk 14541676Sjpk /* 14551676Sjpk * Performs label accreditation checks for packet forwarding. 14561676Sjpk * 14571676Sjpk * Returns a pointer to the modified mblk if allowed for forwarding, 14581676Sjpk * or NULL if the packet must be dropped. 14591676Sjpk */ 14601676Sjpk mblk_t * 14611676Sjpk tsol_ip_forward(ire_t *ire, mblk_t *mp) 14621676Sjpk { 14631676Sjpk tsol_ire_gw_secattr_t *attrp = NULL; 14641676Sjpk ipha_t *ipha; 14651676Sjpk ip6_t *ip6h; 14661676Sjpk const void *pdst; 14671676Sjpk const void *psrc; 14681676Sjpk boolean_t off_link; 14691676Sjpk tsol_tpc_t *dst_rhtp, *gw_rhtp; 14701676Sjpk tsol_ip_label_t label_type; 14711676Sjpk uchar_t *opt_ptr = NULL; 14721676Sjpk ts_label_t *tsl; 14731676Sjpk uint8_t proto; 14741676Sjpk int af, adjust; 14751676Sjpk uint16_t iplen; 14762535Ssangeeta boolean_t need_tpc_rele = B_FALSE; 14772535Ssangeeta ipaddr_t *gw; 14783448Sdh155122 ip_stack_t *ipst = ire->ire_ipst; 14798778SErik.Nordmark@Sun.COM cred_t *credp; 14801676Sjpk 14811676Sjpk ASSERT(ire != NULL && mp != NULL); 14821676Sjpk ASSERT(ire->ire_stq != NULL); 14831676Sjpk 14841676Sjpk af = (ire->ire_ipversion == IPV4_VERSION) ? AF_INET : AF_INET6; 14851676Sjpk 14861676Sjpk if (IPH_HDR_VERSION(mp->b_rptr) == IPV4_VERSION) { 14871676Sjpk ASSERT(ire->ire_ipversion == IPV4_VERSION); 14881676Sjpk ipha = (ipha_t *)mp->b_rptr; 14891676Sjpk psrc = &ipha->ipha_src; 14901676Sjpk pdst = &ipha->ipha_dst; 14911676Sjpk proto = ipha->ipha_protocol; 14921676Sjpk 14932535Ssangeeta /* 14942535Ssangeeta * off_link is TRUE if destination not directly reachable. 14952535Ssangeeta * Surya note: we avoid creation of per-dst IRE_CACHE entries 14962535Ssangeeta * for forwarded packets, so we set off_link to be TRUE 14972535Ssangeeta * if the packet dst is different from the ire_addr of 14982535Ssangeeta * the ire for the nexthop. 14992535Ssangeeta */ 15002535Ssangeeta off_link = ((ipha->ipha_dst != ire->ire_addr) || 15012535Ssangeeta (ire->ire_gateway_addr != INADDR_ANY)); 15021676Sjpk } else { 15031676Sjpk ASSERT(ire->ire_ipversion == IPV6_VERSION); 15041676Sjpk ip6h = (ip6_t *)mp->b_rptr; 15051676Sjpk psrc = &ip6h->ip6_src; 15061676Sjpk pdst = &ip6h->ip6_dst; 15071676Sjpk proto = ip6h->ip6_nxt; 15081676Sjpk 15091676Sjpk if (proto != IPPROTO_TCP && proto != IPPROTO_UDP && 15101676Sjpk proto != IPPROTO_ICMPV6) { 15111676Sjpk uint8_t *nexthdrp; 15121676Sjpk uint16_t hdr_len; 15131676Sjpk 15141676Sjpk if (!ip_hdr_length_nexthdr_v6(mp, ip6h, &hdr_len, 15151676Sjpk &nexthdrp)) { 15161676Sjpk /* malformed packet; drop it */ 15171676Sjpk return (NULL); 15181676Sjpk } 15191676Sjpk proto = *nexthdrp; 15201676Sjpk } 15211676Sjpk 15221676Sjpk /* destination not directly reachable? */ 15231676Sjpk off_link = !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6); 15241676Sjpk } 15251676Sjpk 15268778SErik.Nordmark@Sun.COM if ((tsl = msg_getlabel(mp)) == NULL) 15271676Sjpk return (mp); 15281676Sjpk 15291676Sjpk label_type = tsol_get_option(mp, &opt_ptr); 15301676Sjpk 15311676Sjpk ASSERT(psrc != NULL && pdst != NULL); 15321676Sjpk dst_rhtp = find_tpc(pdst, ire->ire_ipversion, B_FALSE); 15331676Sjpk 15341676Sjpk if (dst_rhtp == NULL) { 15351676Sjpk /* 15361676Sjpk * Without a template we do not know if forwarding 15371676Sjpk * violates MAC 15381676Sjpk */ 15391676Sjpk DTRACE_PROBE3(tx__ip__log__drop__forward__nodst, char *, 15401676Sjpk "mp(1) dropped, no template for destination ip4|6(2)", 15411676Sjpk mblk_t *, mp, void *, pdst); 15421676Sjpk return (NULL); 15431676Sjpk } 15441676Sjpk 15451676Sjpk /* 15461676Sjpk * Gateway template must have existed for off-link destinations, 15471676Sjpk * since tsol_ire_match_gwattr has ensured such condition. 15481676Sjpk */ 15492535Ssangeeta if (ire->ire_ipversion == IPV4_VERSION && off_link) { 15502535Ssangeeta /* 15512535Ssangeeta * Surya note: first check if we can get the gw_rhtp from 15522535Ssangeeta * the ire_gw_secattr->igsa_rhc; if this is null, then 15532535Ssangeeta * do a lookup based on the ire_addr (address of gw) 15542535Ssangeeta */ 15552535Ssangeeta if (ire->ire_gw_secattr != NULL && 15562535Ssangeeta ire->ire_gw_secattr->igsa_rhc != NULL) { 15572535Ssangeeta attrp = ire->ire_gw_secattr; 15582535Ssangeeta gw_rhtp = attrp->igsa_rhc->rhc_tpc; 15592535Ssangeeta } else { 15602535Ssangeeta /* 15612535Ssangeeta * use the ire_addr if this is the IRE_CACHE of nexthop 15622535Ssangeeta */ 15632535Ssangeeta gw = (ire->ire_gateway_addr == NULL? &ire->ire_addr : 15642535Ssangeeta &ire->ire_gateway_addr); 15652535Ssangeeta gw_rhtp = find_tpc(gw, ire->ire_ipversion, B_FALSE); 15662535Ssangeeta need_tpc_rele = B_TRUE; 15672535Ssangeeta } 15682535Ssangeeta if (gw_rhtp == NULL) { 15692535Ssangeeta DTRACE_PROBE3(tx__ip__log__drop__forward__nogw, char *, 15702535Ssangeeta "mp(1) dropped, no gateway in ire attributes(2)", 15712535Ssangeeta mblk_t *, mp, tsol_ire_gw_secattr_t *, attrp); 15722535Ssangeeta mp = NULL; 15732535Ssangeeta goto keep_label; 15742535Ssangeeta } 15752535Ssangeeta } 15762535Ssangeeta if (ire->ire_ipversion == IPV6_VERSION && 15772535Ssangeeta ((attrp = ire->ire_gw_secattr) == NULL || attrp->igsa_rhc == NULL || 15781676Sjpk (gw_rhtp = attrp->igsa_rhc->rhc_tpc) == NULL) && off_link) { 15791676Sjpk DTRACE_PROBE3(tx__ip__log__drop__forward__nogw, char *, 15801676Sjpk "mp(1) dropped, no gateway in ire attributes(2)", 15811676Sjpk mblk_t *, mp, tsol_ire_gw_secattr_t *, attrp); 15821676Sjpk mp = NULL; 15831676Sjpk goto keep_label; 15841676Sjpk } 15851676Sjpk 15861676Sjpk /* 15871676Sjpk * Check that the label for the packet is acceptable 15881676Sjpk * by destination host; otherwise, drop it. 15891676Sjpk */ 15901676Sjpk switch (dst_rhtp->tpc_tp.host_type) { 15911676Sjpk case SUN_CIPSO: 15921676Sjpk if (tsl->tsl_doi != dst_rhtp->tpc_tp.tp_doi || 15931676Sjpk (!_blinrange(&tsl->tsl_label, 15941676Sjpk &dst_rhtp->tpc_tp.tp_sl_range_cipso) && 15951676Sjpk !blinlset(&tsl->tsl_label, 15961676Sjpk dst_rhtp->tpc_tp.tp_sl_set_cipso))) { 15971676Sjpk DTRACE_PROBE4(tx__ip__log__drop__forward__mac, char *, 15981676Sjpk "labeled packet mp(1) dropped, label(2) fails " 15991676Sjpk "destination(3) accredation check", 16001676Sjpk mblk_t *, mp, ts_label_t *, tsl, 16011676Sjpk tsol_tpc_t *, dst_rhtp); 16021676Sjpk mp = NULL; 16031676Sjpk goto keep_label; 16041676Sjpk } 16051676Sjpk break; 16061676Sjpk 16071676Sjpk 16081676Sjpk case UNLABELED: 16091676Sjpk if (tsl->tsl_doi != dst_rhtp->tpc_tp.tp_doi || 16101676Sjpk !blequal(&dst_rhtp->tpc_tp.tp_def_label, 16111676Sjpk &tsl->tsl_label)) { 16121676Sjpk DTRACE_PROBE4(tx__ip__log__drop__forward__mac, char *, 16131676Sjpk "unlabeled packet mp(1) dropped, label(2) fails " 16141676Sjpk "destination(3) accredation check", 16151676Sjpk mblk_t *, mp, ts_label_t *, tsl, 16161676Sjpk tsol_tpc_t *, dst_rhtp); 16171676Sjpk mp = NULL; 16181676Sjpk goto keep_label; 16191676Sjpk } 16201676Sjpk break; 16211676Sjpk } 16221676Sjpk if (label_type == OPT_CIPSO) { 16231676Sjpk /* 16241676Sjpk * We keep the label on any of the following cases: 16251676Sjpk * 16261676Sjpk * 1. The destination is labeled (on/off-link). 16271676Sjpk * 2. The unlabeled destination is off-link, 16281676Sjpk * and the next hop gateway is labeled. 16291676Sjpk */ 16301676Sjpk if (dst_rhtp->tpc_tp.host_type != UNLABELED || 16311676Sjpk (off_link && 16321676Sjpk gw_rhtp->tpc_tp.host_type != UNLABELED)) 16331676Sjpk goto keep_label; 16341676Sjpk 16351676Sjpk /* 16361676Sjpk * Strip off the CIPSO option from the packet because: the 16371676Sjpk * unlabeled destination host is directly reachable through 16381676Sjpk * an interface (on-link); or, the unlabeled destination host 16391676Sjpk * is not directly reachable (off-link), and the next hop 16401676Sjpk * gateway is unlabeled. 16411676Sjpk */ 16421676Sjpk adjust = (af == AF_INET) ? tsol_remove_secopt(ipha, MBLKL(mp)) : 16431676Sjpk tsol_remove_secopt_v6(ip6h, MBLKL(mp)); 16441676Sjpk 16451676Sjpk ASSERT(adjust <= 0); 16461676Sjpk if (adjust != 0) { 16471676Sjpk 16481676Sjpk /* adjust is negative */ 16491676Sjpk ASSERT((mp->b_wptr + adjust) >= mp->b_rptr); 16501676Sjpk mp->b_wptr += adjust; 16511676Sjpk 16521676Sjpk if (af == AF_INET) { 16531676Sjpk ipha = (ipha_t *)mp->b_rptr; 16541676Sjpk iplen = ntohs(ipha->ipha_length) + adjust; 16551676Sjpk ipha->ipha_length = htons(iplen); 16561676Sjpk ipha->ipha_hdr_checksum = 0; 16571676Sjpk ipha->ipha_hdr_checksum = ip_csum_hdr(ipha); 16581676Sjpk } 16591676Sjpk DTRACE_PROBE3(tx__ip__log__info__forward__adjust, 16601676Sjpk char *, 16611676Sjpk "mp(1) adjusted(2) for CIPSO option removal", 16621676Sjpk mblk_t *, mp, int, adjust); 16631676Sjpk } 16641676Sjpk goto keep_label; 16651676Sjpk } 16661676Sjpk 16671676Sjpk ASSERT(label_type == OPT_NONE); 16681676Sjpk ASSERT(dst_rhtp != NULL); 16691676Sjpk 16701676Sjpk /* 16711676Sjpk * We need to add CIPSO option if the destination or the next hop 16721676Sjpk * gateway is labeled. Otherwise, pass the packet as is. 16731676Sjpk */ 16741676Sjpk if (dst_rhtp->tpc_tp.host_type == UNLABELED && 16751676Sjpk (!off_link || gw_rhtp->tpc_tp.host_type == UNLABELED)) 16761676Sjpk goto keep_label; 16771676Sjpk 16788778SErik.Nordmark@Sun.COM 16798778SErik.Nordmark@Sun.COM credp = msg_getcred(mp, NULL); 16801676Sjpk if ((af == AF_INET && 16818778SErik.Nordmark@Sun.COM tsol_check_label(credp, &mp, B_FALSE, ipst) != 0) || 16821676Sjpk (af == AF_INET6 && 16838778SErik.Nordmark@Sun.COM tsol_check_label_v6(credp, &mp, B_FALSE, ipst) != 0)) { 16841676Sjpk mp = NULL; 16851676Sjpk goto keep_label; 16861676Sjpk } 16871676Sjpk 16886596Skp158701 if (af == AF_INET) { 16896596Skp158701 ipha = (ipha_t *)mp->b_rptr; 16906596Skp158701 ipha->ipha_hdr_checksum = 0; 16916596Skp158701 ipha->ipha_hdr_checksum = ip_csum_hdr(ipha); 16921676Sjpk } 16931676Sjpk 16941676Sjpk keep_label: 16951676Sjpk TPC_RELE(dst_rhtp); 16962535Ssangeeta if (need_tpc_rele && gw_rhtp != NULL) 16972535Ssangeeta TPC_RELE(gw_rhtp); 16981676Sjpk return (mp); 16991676Sjpk } 17001676Sjpk 17011676Sjpk /* 17024564Swy83408 * Name: tsol_pmtu_adjust() 17034564Swy83408 * 17044564Swy83408 * Returns the adjusted mtu after removing security option. 17054564Swy83408 * Removes/subtracts the option if the packet's cred indicates an unlabeled 17064564Swy83408 * sender or if pkt_diff indicates this system enlarged the packet. 17074564Swy83408 */ 17084564Swy83408 uint32_t 17094564Swy83408 tsol_pmtu_adjust(mblk_t *mp, uint32_t mtu, int pkt_diff, int af) 17104564Swy83408 { 17114564Swy83408 int label_adj = 0; 17124564Swy83408 uint32_t min_mtu = IP_MIN_MTU; 17134564Swy83408 tsol_tpc_t *src_rhtp; 17144564Swy83408 void *src; 17154564Swy83408 17164564Swy83408 /* 17174564Swy83408 * Note: label_adj is non-positive, indicating the number of 17184564Swy83408 * bytes removed by removing the security option from the 17194564Swy83408 * header. 17204564Swy83408 */ 17214564Swy83408 if (af == AF_INET6) { 17224564Swy83408 ip6_t *ip6h; 17234564Swy83408 17244564Swy83408 min_mtu = IPV6_MIN_MTU; 17254564Swy83408 ip6h = (ip6_t *)mp->b_rptr; 17264564Swy83408 src = &ip6h->ip6_src; 17274564Swy83408 if ((src_rhtp = find_tpc(src, IPV6_VERSION, B_FALSE)) == NULL) 17284564Swy83408 return (mtu); 17294564Swy83408 if (pkt_diff > 0 || src_rhtp->tpc_tp.host_type == UNLABELED) { 17304564Swy83408 label_adj = tsol_remove_secopt_v6( 17314564Swy83408 (ip6_t *)mp->b_rptr, MBLKL(mp)); 17324564Swy83408 } 17334564Swy83408 } else { 17344564Swy83408 ipha_t *ipha; 17354564Swy83408 17364564Swy83408 ASSERT(af == AF_INET); 17374564Swy83408 ipha = (ipha_t *)mp->b_rptr; 17384564Swy83408 src = &ipha->ipha_src; 17394564Swy83408 if ((src_rhtp = find_tpc(src, IPV4_VERSION, B_FALSE)) == NULL) 17404564Swy83408 return (mtu); 17414564Swy83408 if (pkt_diff > 0 || src_rhtp->tpc_tp.host_type == UNLABELED) 17424564Swy83408 label_adj = tsol_remove_secopt( 17434564Swy83408 (ipha_t *)mp->b_rptr, MBLKL(mp)); 17444564Swy83408 } 17454564Swy83408 /* 17464564Swy83408 * Make pkt_diff non-negative and the larger of the bytes 17474564Swy83408 * previously added (if any) or just removed, since label 17484564Swy83408 * addition + subtraction may not be completely idempotent. 17494564Swy83408 */ 17504564Swy83408 if (pkt_diff < -label_adj) 17514564Swy83408 pkt_diff = -label_adj; 17524564Swy83408 if (pkt_diff > 0 && pkt_diff < mtu) 17534564Swy83408 mtu -= pkt_diff; 17544564Swy83408 17554564Swy83408 TPC_RELE(src_rhtp); 17564564Swy83408 return (MAX(mtu, min_mtu)); 17574564Swy83408 } 17584564Swy83408 17594564Swy83408 /* 17601676Sjpk * Name: tsol_rtsa_init() 17611676Sjpk * 17621676Sjpk * Normal: Sanity checks on the route security attributes provided by 17631676Sjpk * user. Convert it into a route security parameter list to 17641676Sjpk * be returned to caller. 17651676Sjpk * 17661676Sjpk * Output: EINVAL if bad security attributes in the routing message 17671676Sjpk * ENOMEM if unable to allocate data structures 17681676Sjpk * 0 otherwise. 17691676Sjpk * 17701676Sjpk * Note: On input, cp must point to the end of any addresses in 17711676Sjpk * the rt_msghdr_t structure. 17721676Sjpk */ 17731676Sjpk int 17741676Sjpk tsol_rtsa_init(rt_msghdr_t *rtm, tsol_rtsecattr_t *sp, caddr_t cp) 17751676Sjpk { 17761676Sjpk uint_t sacnt; 17771676Sjpk int err; 17781676Sjpk caddr_t lim; 17791676Sjpk tsol_rtsecattr_t *tp; 17801676Sjpk 17811676Sjpk ASSERT((cp >= (caddr_t)&rtm[1]) && sp != NULL); 17821676Sjpk 17831676Sjpk /* 17841676Sjpk * In theory, we could accept as many security attributes configured 17851676Sjpk * per route destination. However, the current design is limited 17861676Sjpk * such that at most only one set security attributes is allowed to 17871676Sjpk * be associated with a prefix IRE. We therefore assert for now. 17881676Sjpk */ 17891676Sjpk /* LINTED */ 17901676Sjpk ASSERT(TSOL_RTSA_REQUEST_MAX == 1); 17911676Sjpk 17921676Sjpk sp->rtsa_cnt = 0; 17931676Sjpk lim = (caddr_t)rtm + rtm->rtm_msglen; 17941676Sjpk ASSERT(cp <= lim); 17951676Sjpk 17961676Sjpk if ((lim - cp) < sizeof (rtm_ext_t) || 17971676Sjpk ((rtm_ext_t *)cp)->rtmex_type != RTMEX_GATEWAY_SECATTR) 17981676Sjpk return (0); 17991676Sjpk 18001676Sjpk if (((rtm_ext_t *)cp)->rtmex_len < sizeof (tsol_rtsecattr_t)) 18011676Sjpk return (EINVAL); 18021676Sjpk 18031676Sjpk cp += sizeof (rtm_ext_t); 18041676Sjpk 18051676Sjpk if ((lim - cp) < sizeof (*tp) || 18061676Sjpk (tp = (tsol_rtsecattr_t *)cp, (sacnt = tp->rtsa_cnt) == 0) || 18071676Sjpk (lim - cp) < TSOL_RTSECATTR_SIZE(sacnt)) 18081676Sjpk return (EINVAL); 18091676Sjpk 18101676Sjpk /* 18111676Sjpk * Trying to add route security attributes when system 18121676Sjpk * labeling service is not available, or when user supllies 18131676Sjpk * more than the maximum number of security attributes 18141676Sjpk * allowed per request. 18151676Sjpk */ 18161676Sjpk if ((sacnt > 0 && !is_system_labeled()) || 18171676Sjpk sacnt > TSOL_RTSA_REQUEST_MAX) 18181676Sjpk return (EINVAL); 18191676Sjpk 18201676Sjpk /* Ensure valid credentials */ 18211676Sjpk if ((err = rtsa_validate(&((tsol_rtsecattr_t *)cp)-> 18221676Sjpk rtsa_attr[0])) != 0) { 18231676Sjpk cp += sizeof (*sp); 18241676Sjpk return (err); 18251676Sjpk } 18261676Sjpk 18271676Sjpk bcopy(cp, sp, sizeof (*sp)); 18281676Sjpk cp += sizeof (*sp); 18291676Sjpk return (0); 18301676Sjpk } 18311676Sjpk 18321676Sjpk int 18331676Sjpk tsol_ire_init_gwattr(ire_t *ire, uchar_t ipversion, tsol_gc_t *gc, 18341676Sjpk tsol_gcgrp_t *gcgrp) 18351676Sjpk { 18361676Sjpk tsol_ire_gw_secattr_t *attrp; 18371676Sjpk boolean_t exists = B_FALSE; 18381676Sjpk in_addr_t ga_addr4; 18391676Sjpk void *paddr = NULL; 18401676Sjpk 18411676Sjpk ASSERT(ire != NULL); 18421676Sjpk 18431676Sjpk /* 18441676Sjpk * The only time that attrp can be NULL is when this routine is 18451676Sjpk * called for the first time during the creation/initialization 18461676Sjpk * of the corresponding IRE. It will only get cleared when the 18471676Sjpk * IRE is deleted. 18481676Sjpk */ 18491676Sjpk if ((attrp = ire->ire_gw_secattr) == NULL) { 18501676Sjpk attrp = ire_gw_secattr_alloc(KM_NOSLEEP); 18511676Sjpk if (attrp == NULL) 18521676Sjpk return (ENOMEM); 18531676Sjpk ire->ire_gw_secattr = attrp; 18541676Sjpk } else { 18551676Sjpk exists = B_TRUE; 18561676Sjpk mutex_enter(&attrp->igsa_lock); 18571676Sjpk 18581676Sjpk if (attrp->igsa_rhc != NULL) { 18591676Sjpk TNRHC_RELE(attrp->igsa_rhc); 18601676Sjpk attrp->igsa_rhc = NULL; 18611676Sjpk } 18621676Sjpk 18631676Sjpk if (attrp->igsa_gc != NULL) 18641676Sjpk GC_REFRELE(attrp->igsa_gc); 18651676Sjpk if (attrp->igsa_gcgrp != NULL) 18661676Sjpk GCGRP_REFRELE(attrp->igsa_gcgrp); 18671676Sjpk } 18681676Sjpk ASSERT(!exists || MUTEX_HELD(&attrp->igsa_lock)); 18691676Sjpk 18701676Sjpk /* 18711676Sjpk * References already held by caller and we keep them; 18721676Sjpk * note that both gc and gcgrp may be set to NULL to 18731676Sjpk * clear out igsa_gc and igsa_gcgrp, respectively. 18741676Sjpk */ 18751676Sjpk attrp->igsa_gc = gc; 18761676Sjpk attrp->igsa_gcgrp = gcgrp; 18771676Sjpk 18781676Sjpk if (gcgrp == NULL && gc != NULL) { 18791676Sjpk gcgrp = gc->gc_grp; 18801676Sjpk ASSERT(gcgrp != NULL); 18811676Sjpk } 18821676Sjpk 18831676Sjpk /* 18841676Sjpk * Intialize the template for gateway; we use the gateway's 18851676Sjpk * address found in either the passed in gateway credential 18861676Sjpk * or group pointer, or the ire_gateway_addr{_v6} field. 18871676Sjpk */ 18881676Sjpk if (gcgrp != NULL) { 18891676Sjpk tsol_gcgrp_addr_t *ga = &gcgrp->gcgrp_addr; 18901676Sjpk 18911676Sjpk /* 18921676Sjpk * Caller is holding a reference, and that we don't 18931676Sjpk * need to hold any lock to access the address. 18941676Sjpk */ 18951676Sjpk if (ipversion == IPV4_VERSION) { 18961676Sjpk ASSERT(ga->ga_af == AF_INET); 18971676Sjpk IN6_V4MAPPED_TO_IPADDR(&ga->ga_addr, ga_addr4); 18981676Sjpk paddr = &ga_addr4; 18991676Sjpk } else { 19001676Sjpk ASSERT(ga->ga_af == AF_INET6); 19011676Sjpk paddr = &ga->ga_addr; 19021676Sjpk } 19031676Sjpk } else if (ipversion == IPV6_VERSION && 19041676Sjpk !IN6_IS_ADDR_UNSPECIFIED(&ire->ire_gateway_addr_v6)) { 19051676Sjpk paddr = &ire->ire_gateway_addr_v6; 19061676Sjpk } else if (ipversion == IPV4_VERSION && 19071676Sjpk ire->ire_gateway_addr != INADDR_ANY) { 19081676Sjpk paddr = &ire->ire_gateway_addr; 19091676Sjpk } 19101676Sjpk 19111676Sjpk /* 19121676Sjpk * Lookup the gateway template; note that we could get an internal 19131676Sjpk * template here, which we cache anyway. During IRE matching, we'll 19141676Sjpk * try to update this gateway template cache and hopefully get a 19151676Sjpk * real one. 19161676Sjpk */ 19171676Sjpk if (paddr != NULL) { 19183292Skp158701 attrp->igsa_rhc = find_rhc(paddr, ipversion, B_FALSE); 19191676Sjpk } 19201676Sjpk 19211676Sjpk if (exists) 19221676Sjpk mutex_exit(&attrp->igsa_lock); 19231676Sjpk 19241676Sjpk return (0); 19251676Sjpk } 19261676Sjpk 19271676Sjpk /* 19281676Sjpk * This function figures the type of MLP that we'll be using based on the 19291676Sjpk * address that the user is binding and the zone. If the address is 19301676Sjpk * unspecified, then we're looking at both private and shared. If it's one 19311676Sjpk * of the zone's private addresses, then it's private only. If it's one 19321676Sjpk * of the global addresses, then it's shared only. 19331676Sjpk * 19341676Sjpk * If we can't figure out what it is, then return mlptSingle. That's actually 19351676Sjpk * an error case. 19363448Sdh155122 * 19373448Sdh155122 * The callers are assume to pass in zone->zone_id and not the zoneid that 19383448Sdh155122 * is stored in a conn_t (since the latter will be GLOBAL_ZONEID in an 19393448Sdh155122 * exclusive stack zone). 19401676Sjpk */ 19411676Sjpk mlp_type_t 19423448Sdh155122 tsol_mlp_addr_type(zoneid_t zoneid, uchar_t version, const void *addr, 19433448Sdh155122 ip_stack_t *ipst) 19441676Sjpk { 19451676Sjpk in_addr_t in4; 19461676Sjpk ire_t *ire; 19471676Sjpk ipif_t *ipif; 19481676Sjpk zoneid_t addrzone; 19493448Sdh155122 zoneid_t ip_zoneid; 19501676Sjpk 19511676Sjpk ASSERT(addr != NULL); 19521676Sjpk 19533448Sdh155122 /* 19543448Sdh155122 * For exclusive stacks we set the zoneid to zero 19553448Sdh155122 * to operate as if in the global zone for IRE and conn_t comparisons. 19563448Sdh155122 */ 19573448Sdh155122 if (ipst->ips_netstack->netstack_stackid != GLOBAL_NETSTACKID) 19583448Sdh155122 ip_zoneid = GLOBAL_ZONEID; 19593448Sdh155122 else 19603448Sdh155122 ip_zoneid = zoneid; 19613448Sdh155122 19621676Sjpk if (version == IPV6_VERSION && 19631676Sjpk IN6_IS_ADDR_V4MAPPED((const in6_addr_t *)addr)) { 19641676Sjpk IN6_V4MAPPED_TO_IPADDR((const in6_addr_t *)addr, in4); 19651676Sjpk addr = &in4; 19661676Sjpk version = IPV4_VERSION; 19671676Sjpk } 19681676Sjpk 19691676Sjpk if (version == IPV4_VERSION) { 19701676Sjpk in4 = *(const in_addr_t *)addr; 19713448Sdh155122 if (in4 == INADDR_ANY) { 19721676Sjpk return (mlptBoth); 19733448Sdh155122 } 19743448Sdh155122 ire = ire_cache_lookup(in4, ip_zoneid, NULL, ipst); 19751676Sjpk } else { 19763448Sdh155122 if (IN6_IS_ADDR_UNSPECIFIED((const in6_addr_t *)addr)) { 19771676Sjpk return (mlptBoth); 19783448Sdh155122 } 19793448Sdh155122 ire = ire_cache_lookup_v6(addr, ip_zoneid, NULL, ipst); 19801676Sjpk } 19811676Sjpk /* 19821676Sjpk * If we can't find the IRE, then we have to behave exactly like 19831676Sjpk * ip_bind_laddr{,_v6}. That means looking up the IPIF so that users 19841676Sjpk * can bind to addresses on "down" interfaces. 19851676Sjpk * 19861676Sjpk * If we can't find that either, then the bind is going to fail, so 19871676Sjpk * just give up. Note that there's a miniscule chance that the address 19881676Sjpk * is in transition, but we don't bother handling that. 19891676Sjpk */ 19901676Sjpk if (ire == NULL) { 19911676Sjpk if (version == IPV4_VERSION) 19921676Sjpk ipif = ipif_lookup_addr(*(const in_addr_t *)addr, NULL, 19933448Sdh155122 ip_zoneid, NULL, NULL, NULL, NULL, ipst); 19941676Sjpk else 19951676Sjpk ipif = ipif_lookup_addr_v6((const in6_addr_t *)addr, 19963448Sdh155122 NULL, ip_zoneid, NULL, NULL, NULL, NULL, ipst); 19973448Sdh155122 if (ipif == NULL) { 19981676Sjpk return (mlptSingle); 19993448Sdh155122 } 20001676Sjpk addrzone = ipif->ipif_zoneid; 20011676Sjpk ipif_refrele(ipif); 20021676Sjpk } else { 20031676Sjpk addrzone = ire->ire_zoneid; 20041676Sjpk ire_refrele(ire); 20051676Sjpk } 20061676Sjpk return (addrzone == ALL_ZONES ? mlptShared : mlptPrivate); 20071676Sjpk } 20081676Sjpk 20091676Sjpk /* 20101676Sjpk * Since we are configuring local interfaces, and we know trusted 20111676Sjpk * extension CDE requires local interfaces to be cipso host type in 20121676Sjpk * order to function correctly, we'll associate a cipso template 20131676Sjpk * to each local interface and let the interface come up. Configuring 20141676Sjpk * a local interface to be "unlabeled" host type is a configuration error. 20151676Sjpk * We'll override that error and make the interface host type to be cipso 20161676Sjpk * here. 20171676Sjpk * 20181676Sjpk * The code is optimized for the usual "success" case and unwinds things on 20191676Sjpk * error. We don't want to go to the trouble and expense of formatting the 20201676Sjpk * interface name for the usual case where everything is configured correctly. 20211676Sjpk */ 20221676Sjpk boolean_t 20231676Sjpk tsol_check_interface_address(const ipif_t *ipif) 20241676Sjpk { 20251676Sjpk tsol_tpc_t *tp; 20261676Sjpk char addrbuf[INET6_ADDRSTRLEN]; 20271676Sjpk int af; 20281676Sjpk const void *addr; 20291676Sjpk zone_t *zone; 20301676Sjpk ts_label_t *plabel; 20311676Sjpk const bslabel_t *label; 20321676Sjpk char ifbuf[LIFNAMSIZ + 10]; 20331676Sjpk const char *ifname; 20341676Sjpk boolean_t retval; 20351676Sjpk tsol_rhent_t rhent; 20363448Sdh155122 netstack_t *ns = ipif->ipif_ill->ill_ipst->ips_netstack; 20371676Sjpk 20381676Sjpk if (IN6_IS_ADDR_V4MAPPED(&ipif->ipif_v6lcl_addr)) { 20391676Sjpk af = AF_INET; 20401676Sjpk addr = &V4_PART_OF_V6(ipif->ipif_v6lcl_addr); 20411676Sjpk } else { 20421676Sjpk af = AF_INET6; 20431676Sjpk addr = &ipif->ipif_v6lcl_addr; 20441676Sjpk } 20451676Sjpk 20461676Sjpk tp = find_tpc(&ipif->ipif_v6lcl_addr, IPV6_VERSION, B_FALSE); 20473448Sdh155122 20483448Sdh155122 /* assumes that ALL_ZONES implies that there is no exclusive stack */ 20493448Sdh155122 if (ipif->ipif_zoneid == ALL_ZONES) { 20503448Sdh155122 zone = NULL; 20513448Sdh155122 } else if (ns->netstack_stackid == GLOBAL_NETSTACKID) { 20523448Sdh155122 /* Shared stack case */ 20533448Sdh155122 zone = zone_find_by_id(ipif->ipif_zoneid); 20543448Sdh155122 } else { 20553448Sdh155122 /* Exclusive stack case */ 20563448Sdh155122 zone = zone_find_by_id(crgetzoneid(ipif->ipif_ill->ill_credp)); 20573448Sdh155122 } 20581676Sjpk if (zone != NULL) { 20591676Sjpk plabel = zone->zone_slabel; 20601676Sjpk ASSERT(plabel != NULL); 20611676Sjpk label = label2bslabel(plabel); 20621676Sjpk } 20631676Sjpk 20641676Sjpk /* 20651676Sjpk * If it's CIPSO and an all-zones address, then we're done. 20661676Sjpk * If it's a CIPSO zone specific address, the zone's label 20671676Sjpk * must be in the range or set specified in the template. 20681676Sjpk * When the remote host entry is missing or the template 20691676Sjpk * type is incorrect for this interface, we create a 20701676Sjpk * CIPSO host entry in kernel and allow the interface to be 20711676Sjpk * brought up as CIPSO type. 20721676Sjpk */ 20731676Sjpk if (tp != NULL && ( 20741676Sjpk /* The all-zones case */ 20751676Sjpk (tp->tpc_tp.host_type == SUN_CIPSO && 20761676Sjpk tp->tpc_tp.tp_doi == default_doi && 20771676Sjpk ipif->ipif_zoneid == ALL_ZONES) || 20781676Sjpk /* The local-zone case */ 20791676Sjpk (zone != NULL && plabel->tsl_doi == tp->tpc_tp.tp_doi && 20801676Sjpk ((tp->tpc_tp.host_type == SUN_CIPSO && 20811676Sjpk (_blinrange(label, &tp->tpc_tp.tp_sl_range_cipso) || 20821676Sjpk blinlset(label, tp->tpc_tp.tp_sl_set_cipso))))))) { 20831676Sjpk if (zone != NULL) 20841676Sjpk zone_rele(zone); 20851676Sjpk TPC_RELE(tp); 20861676Sjpk return (B_TRUE); 20871676Sjpk } 20881676Sjpk 20891676Sjpk ifname = ipif->ipif_ill->ill_name; 20901676Sjpk if (ipif->ipif_id != 0) { 20911676Sjpk (void) snprintf(ifbuf, sizeof (ifbuf), "%s:%u", ifname, 20921676Sjpk ipif->ipif_id); 20931676Sjpk ifname = ifbuf; 20941676Sjpk } 20951676Sjpk (void) inet_ntop(af, addr, addrbuf, sizeof (addrbuf)); 20961676Sjpk 20971676Sjpk if (tp == NULL) { 20981676Sjpk cmn_err(CE_NOTE, "template entry for %s missing. Default to " 20991676Sjpk "CIPSO type for %s", ifname, addrbuf); 21001676Sjpk retval = B_TRUE; 21011676Sjpk } else if (tp->tpc_tp.host_type == UNLABELED) { 21021676Sjpk cmn_err(CE_NOTE, "template type for %s incorrectly configured. " 21031676Sjpk "Change to CIPSO type for %s", ifname, addrbuf); 21041676Sjpk retval = B_TRUE; 21051676Sjpk } else if (ipif->ipif_zoneid == ALL_ZONES) { 21061676Sjpk if (tp->tpc_tp.host_type != SUN_CIPSO) { 21071676Sjpk cmn_err(CE_NOTE, "%s failed: %s isn't set to CIPSO for " 21081676Sjpk "all-zones. Converted to CIPSO.", ifname, addrbuf); 21091676Sjpk retval = B_TRUE; 21101676Sjpk } else { 21111676Sjpk cmn_err(CE_NOTE, "%s failed: %s has wrong DOI %d " 21121676Sjpk "instead of %d", ifname, addrbuf, 21131676Sjpk tp->tpc_tp.tp_doi, default_doi); 21141676Sjpk retval = B_FALSE; 21151676Sjpk } 21161676Sjpk } else if (zone == NULL) { 21171676Sjpk cmn_err(CE_NOTE, "%s failed: zoneid %d unknown", 21181676Sjpk ifname, ipif->ipif_zoneid); 21191676Sjpk retval = B_FALSE; 21201676Sjpk } else if (plabel->tsl_doi != tp->tpc_tp.tp_doi) { 21211676Sjpk cmn_err(CE_NOTE, "%s failed: zone %s has DOI %d but %s has " 21221676Sjpk "DOI %d", ifname, zone->zone_name, plabel->tsl_doi, 21231676Sjpk addrbuf, tp->tpc_tp.tp_doi); 21241676Sjpk retval = B_FALSE; 21251676Sjpk } else { 21261676Sjpk cmn_err(CE_NOTE, "%s failed: zone %s label incompatible with " 21271676Sjpk "%s", ifname, zone->zone_name, addrbuf); 21281676Sjpk tsol_print_label(label, "zone label"); 21291676Sjpk retval = B_FALSE; 21301676Sjpk } 21311676Sjpk 21321676Sjpk if (zone != NULL) 21331676Sjpk zone_rele(zone); 21341676Sjpk if (tp != NULL) 21351676Sjpk TPC_RELE(tp); 21361676Sjpk if (retval) { 21371676Sjpk /* 21381676Sjpk * we've corrected a config error and let the interface 21391676Sjpk * come up as cipso. Need to insert an rhent. 21401676Sjpk */ 21411676Sjpk if ((rhent.rh_address.ta_family = af) == AF_INET) { 21421676Sjpk rhent.rh_prefix = 32; 21431676Sjpk rhent.rh_address.ta_addr_v4 = *(struct in_addr *)addr; 21441676Sjpk } else { 21451676Sjpk rhent.rh_prefix = 128; 21461676Sjpk rhent.rh_address.ta_addr_v6 = *(in6_addr_t *)addr; 21471676Sjpk } 21481676Sjpk (void) strcpy(rhent.rh_template, "cipso"); 21491676Sjpk if (tnrh_load(&rhent) != 0) { 21501676Sjpk cmn_err(CE_NOTE, "%s failed: Cannot insert CIPSO " 21511676Sjpk "template for local addr %s", ifname, addrbuf); 21521676Sjpk retval = B_FALSE; 21531676Sjpk } 21541676Sjpk } 21551676Sjpk return (retval); 21561676Sjpk } 2157